colleague / study-project · Files

<?php
/**
 * 员工培训激励表Service
 * @author: houyingcai
 * @email:     594609175@qq.com
 * @date :  2017-08-29 16:40:17
 * @version $Id$
 */

namespace Common\Service;

use Common\Common\Integral;
use Common\Common\User;
use Common\Model\EducationModel;
use Common\Model\IncentivesModel;
use Common\Model\RightUsersModel;

class IncentivesService extends AbstractService
{

    // 模版数据标题记录行数
    const TPL_LEN = 2;

    // 激励已发放
    const GIVE_STATUS_OK = 1;
    // 激励未发放
    const GIVE_STATUS_NO = 0;
    // 勋章消息
    const MSG_MEDAL = 1;

    /* @var EducationModel */
    protected $education_d;
    /* @var RightUsersModel */
    protected $right_users_d;

    public function __construct()
    {
        $this->_d = new IncentivesModel();
        $this->education_d = new EducationModel();
        $this->right_users_d = new RightUsersModel();

        parent::__construct();
    }

    /**
     * 格式化激励列表数据
     *
     * @param array $list 激励列表数据
     *
     * @return array
     */
    public function format_list_data($list = [])
    {
        $res_list = [];

        $uids = array_column($res_list, 'sr_uid');

        // 获取用户列表
        $user_list = $this->get_all_user_by_cache($uids);

        foreach ($list as $v) {
            // 获取用户信息
            $user_data = $user_list[$v['sr_uid']];
            $arr['sr_id'] = intval($v['sr_id']);
            $arr['memUsername'] = $user_data['memUsername'];
            $arr['roleName'] = strval($user_data['memJob']);
            $arr['jobName'] = strval($user_data['memRole']);

            // 此处处理部门信息
            $dpName = '';
            if (!empty($user_data['dpName'])) {

                $dpName_arr = array_column($user_data['dpName'], 'dpName');
                $dpName = implode(';', $dpName_arr);
            }

            $arr['dpName'] = $dpName;
            $arr['sr_medal'] = $v['sr_medal'];
            $arr['sr_score'] = intval($v['sr_score']);
            $arr['sr_credit'] = (int)$v['sr_credit'];
            $arr['sr_give_status'] = intval($v['sr_give_status']);

            $res_list[] = $arr;
        }

        return $res_list;
    }

    /**
     * 验证导入模板文件数据
     * @author:daijun
     *
     * @param string $ed_id 培训ID
     * @param array $file POST数据
     *
     * @return bool
     */
    public function xls_validation($ed_id = '', $file = [])
    {
        if (empty($ed_id)) {
            // 培训ID不能为空
            E('_EMPTY_EDUCATION_ID');
        }

        if (empty($file)) {
            // 请上传文件
            E('_ERR_FILE_UNDEFINED');
        }

        if ($file['error'] > 0) {
            // 文件上传失败
            E('_ERR_UPLOAD_FILE');
        }

        if ($file['size'] > 1024 * 2 * 1000) {
            // 文件大小判断(2M以内)
            E('_ERR_FILE_SIZE');
        }

        return true;
    }


    // 获取属性对应字段
    public function getAttr()
    {
        return [
            [
                'attr_name' => '员工姓名',
                'field_name' => 'memUsername',
            ],
            [
                'attr_name' => '手机号码',
                'field_name' => 'memMobile',
            ],
            [
                'attr_name' => '勋章',
                'field_name' => 'medal',
            ],
            [
                'attr_name' => '积分',
                'field_name' => 'score',
            ],
            [
                'attr_name' => '学分',
                'field_name' => 'credit',
            ],
        ];
    }


    /**
     * 循环格式化excel数据
     *
     * @param array $data excel数据
     *
     * @return array
     */
    public function format_excel_list($data = [])
    {
        // 第一行数据为属性名称
        $head = $data[1];

        $heads = [];

        // 获取属性对应字段
        $attrs = $this->getAttr();

        // 头部属性名对应的属性字段
        $field = [];
        foreach ($head as $k => $v) {
            if (empty($v)) {
                // 排除excel格式带来的干扰数据
                unset($head[$k]);
                continue;
            }

            $heads[] = $v;
            foreach ($attrs as $attr) {
                if ($v == $attr['attr_name']) {
                    $field[] = $attr['field_name'];
                }
            }
        }

        if (empty($field) || count($attrs) != count($field)) {
            E('_ERR_EXCEL_FORMAT');
        }

        // 处理数据列表
        $list = [];

        foreach ($data as $line => $user) {

            $lineNull = true;
            // 整行数据都为空 或 第2行数据以前,跳过
            if (empty($user) || $line < 3) {
                continue;
            }

            foreach ($user as $v) {
                // 每行中第一列第二列都不为空即为有效数据
                if (!empty($v[0]) && !empty($v[1])) {
                    $lineNull = false;
                    break;
                }
            }
            if (!$lineNull) {
                foreach ($user as $k => $v) {
                    // 排除excel格式带来的干扰数据
                    if (empty($field[$k])) {
                        continue;
                    }

                    $list[$line][] = [
                        'key' => $field[$k],
                        'attr_value' => $v ? trim($v) : '',
                    ];
                }
            }
        }

        // 如果没有数据
        if(empty($list)){
           E('_EMPTY_XLS_DATA_LIST');
        }

        return [
            'heads' => $heads,
            'list' => $list
        ];
    }

    /**
     * 获取错误提示
     *
     * @param int $ed_id POST 培训id
     * @param array $params POST 条件
     * @param array &$codes 错误码
     *
     * @return bool
     */
    public function get_code($ed_id, &$params, &$codes)
    {
        // 初始化错误吗
        $codes = [];

        // 姓名不能为空
        if (empty($params['memUsername'])) {

            array_push($codes, ['key' => 'memUsername', 'msg' => '姓名不能为空']);
        }

        // 手机不能为空
        if (empty($params['memMobile']) || strlen($params['memMobile']) != 11) {

            array_push($codes, ['key' => 'memMobile', 'msg' => '手机号码格式有误']);
        }

        // 获取用户信息
        $user = User::instance()->listByConds(
            [
                'memMobile' => $params['memMobile'],
                'memSubscribeStatus' => self::USER_STATUS_FOLLOW
            ]
        );

        $user_data = $user['list'][0];

        if (empty($user_data)) {

            array_push($codes, ['key' => 'memMobile', 'msg' => '此用户不存在']);
        }

        if (!empty($user_data) && $user_data['memUsername'] != $params['memUsername']) {

            array_push($codes, ['key' => 'memUsername', 'msg' => '用户手机号码和名字不匹配']);
        }

        $params['sr_uid'] = $user_data['memUid'];

        // 验证导入人员是否在适用范围内
        $right_cond = [
            'ru_uid' => $params['sr_uid'],
            'ed_id' => $ed_id
        ];
        $right_user = $this->right_users_d->get_by_conds($right_cond);
        if (empty($right_user)) {

            array_push($codes, ['key' => 'memUsername', 'msg' => '此用户不在适用范围内']);
        }

        // 培训信息
        $education = $this->education_d->get($ed_id);
        $right_users_s = new RightUsersService();
        // 验证导入人员是否报名成功
        $sign_up_status = $right_users_s->get_sign_up_status($education, $right_user);
        if ($sign_up_status != RightUsersService::SIGN_SUCCESS) {

            array_push($codes, ['key' => 'memUsername', 'msg' => '此用户没有参加培训']);
        }

        // 判断积分
        if (!empty($params['score']) && !is_numeric($params['score'])) {

            array_push($codes, ['key' => 'score', 'msg' => '积分数据格式有误']);
        }
        $params['sr_score'] = $params['score'];

        // 判断学分
        if (!empty($params['credit']) && !is_numeric($params['credit'])) {
            $codes[] = ['key' => 'credit', 'msg' => '学分数据格式有误'];
        }

        $params['sr_credit'] = $params['credit'];

        // 判断勋章
        if (!empty($params['medal'])) {
            $medal_arr = explode('；', $params['medal']);

            $total = count($medal_arr);
            // 数组去重
            $medal_arr = array_unique($medal_arr);

            if (count($medal_arr) != $total) {
                // 勋章数据重复
                array_push($codes, ['key' => 'medal', 'msg' => '勋章数据重复']);
            }

            // 实例化积分
            $integralUtil = new Integral();

            // 获取勋章列表
            $medal = $integralUtil->listMedal();

            $medal = array_combine_by_key($medal, 'name');

            foreach ($medal_arr as $v) {

                if (empty($medal[$v])) {

                    array_push($codes, ['key' => 'medal', 'msg' => '勋章-' . $v . ',不存在']);
                }
            }
        }

        $params['sr_medal'] = $params['medal'];

        return true;
    }

    /**
     * 格式化返回错误数据
     *
     * @param array $params post 请求
     * @param array $codes 错误信息
     *
     * @return array
     */
    public function data_format($params = [], $codes = [])
    {

        $param = $params['data'];

        unset($param['sr_uid'], $param['sr_medal'], $param['sr_score']);

        // 错误数组中的建名
        $error_keys = array_column($codes, 'key');

        // 初始化数组
        $data = [];

        $param_keys = array_keys($param);

        // 遍历数组
        foreach ($param_keys as $v) {

            $data[] = [
                'key' => strval($v),
                'attr_value' => strval($param[$v]),
                'is_error' => in_array($v, $error_keys) ? 1 : 0
            ];

        }

        return $data;
    }

    /**
     * 检查编辑激励数据
     * @author:daijun
     *
     * @param array $data 传入参数
     *
     * @return bool
     */
    public function check_edit_data($data = [])
    {

        if (empty($data['sr_id'])) {
            // 激励ID不能为空
            E('_EMPTY_INCENTIVES_ID');
        }

        $in_data = $this->_d->get($data['sr_id']);

        if (empty($in_data)) {
            // 激励记录不存在
            E('_ERR_INCENTIVES_RECORD');
        }

        if ($in_data['sr_give_status'] == self::GIVE_STATUS_OK) {
            // 激励已发放，不能编辑
            E('_ERR_INCENTIVES_GIVE_STATUS');
        }

        if (!empty($data['medal'])) {

            $medal_arr = $data['medal'];
            $total = count($medal_arr);
            // 数组去重
            $medal_arr = array_unique(array_filter($medal_arr));

            if (count($medal_arr) != $total) {
                // 勋章数据重复
                E('_ERR_MEDAL_REPEAT');
            }

            // 实例化积分
            $integralUtil = new Integral();

            // 获取勋章列表
            $medal = $integralUtil->listMedal();
            $medal = array_combine_by_key($medal, 'name');

            foreach ($medal_arr as $v) {
                if (empty($medal[$v])) {

                    E('_ERR_MEDAL_NAME');
                    break;
                }
            }
        }

        return true;
    }

    /**
     * 激励验证与发放
     *
     * @param array $list 激励ID列表
     * @param array $admin 管理员信息
     *
     * @return bool
     */
    public function check_and_give_out($list = [], $admin = [])
    {

        $sr_ids = array_column($list, 'sr_id');

        if (empty($sr_ids)) {
            // 激励ID不能为空
            E('_EMPTY_INCENTIVES_ID');
        }

        // 查询传入的未发放的激励列表
        $incentives_list = $this->_d->list_by_conds([
            'sr_id' => $sr_ids,
            'sr_give_status' => self::GIVE_STATUS_NO
        ]);

        // 待发放激励员工id集合
        $sr_uids = array_column($incentives_list, 'sr_uid');

        // 培训适用范围内的员工集合
        $right_cond = [
            'ru_uid' => $sr_uids,
            'ed_id' => $incentives_list[0]['ed_id']
        ];
        $right_users = $this->right_users_d->list_by_conds($right_cond);
        $right_users = array_combine_by_key($right_users, 'ru_uid');

        // 获取培训信息
        $education = $this->education_d->get($incentives_list[0]['ed_id']);

        // 获取用户列表
        $user_list = $this->get_all_user_by_cache();

        // 报名成功的员工id集合
        $sign_uids = [];
        $right_users_s = new RightUsersService();
        // 获取没有参加培训的员工id

        foreach ($sr_uids as $uid) {

            $right_user = $right_users[$uid];
            // 验证导入人员是否报名成功
            $sign_up_status = $right_users_s->get_sign_up_status($education, $right_user);
            if (RightUsersService::SIGN_SUCCESS == $sign_up_status) {

                array_push($sign_uids, $uid);
            }
        }

        // 查询传入的未发放的并可发放的激励列表
        $give_incentives_list = $this->_d->list_by_conds([
            'sr_uid' => $sign_uids,
            'ed_id' => $education['ed_id'],
            'sr_give_status' => self::GIVE_STATUS_NO
        ]);

        // 实例化积分
        $integralUtil = new Integral();
        // 获取勋章列表
        $medal = $integralUtil->listMedal();
        // 初始化消息发送数据
        $medal_msg_data = [];
        foreach ($medal as $k => $m) {
            $medal_msg_data[$k] = [
                'name' => $m['name'],
                'sr_uids' => []
            ];
        }
        $medal_msg_data = array_combine_by_key($medal_msg_data, 'name');

        $app_name = cfg('APPLICATION_NAME', null, '');

        try {
            // 开始事务
            $this->start_trans();

            foreach ($give_incentives_list as $v) {

                // 如果积分大于0,发放积分
                if (intval($v['sr_score']) > 0) {

                    $params = [
                        'uids' => $v['sr_uid'],
                        'milOptType' => 2, // 手动增加
                        // 类型为积分
                        'miType' => \VcySDK\Integral::MI_TYPE_INTEGRAL,
                        'integral' => intval($v['sr_score']),
                        'remark' => "【{$app_name}-培训激励】" . $education['ed_name'],
                        'milCreateMemUid' => $admin['eaId'],
                        'milCreateMemUsername' => $admin['eaRealname'],
                        'memUid' => '',
                        'businessId' => $v['ed_id'],
                        'businessAct' => 'train_excitation',
                        'businessKey' => 'offline_train',
                        'prizeName' => '培训激励',
                        'msgIdentifier' => APP_IDENTIFIER // 应用标识（消息推送必要）
                    ];

                    $integralUtil->integralUpdate($params);
                }

                // 如果学分大于0，发放学分
                if ($v['sr_credit'] > 0) {
                    $params = [
                        'uids' => $v['sr_uid'],
                        'milOptType' => 2, // 手动增加
                        // 类型为学分
                        'miType' => \VcySDK\Integral::MI_TYPE_CREDIT,
                        'integral' => (int)$v['sr_credit'],
                        'remark' => "【{$app_name}-培训激励】" . $education['ed_name'],
                        'milCreateMemUid' => $admin['eaId'],
                        'milCreateMemUsername' => $admin['eaRealname'],
                        'memUid' => '',
                        'businessId' => $v['ed_id'],
                        'businessAct' => 'train_excitation',
                        'businessKey' => 'offline_train',
                        'prizeName' => '培训激励',
                        'msgIdentifier' => APP_IDENTIFIER // 应用标识（消息推送必要）
                    ];

                    $integralUtil->integralUpdate($params);
                }

                if (empty($v['sr_medal'])) {
                    // 如果勋章为空
                    continue;
                }

                $medal_arr = explode('；', $v['sr_medal']);
                $total = count($medal_arr);
                // 数组去重
                $medal_arr = array_unique(array_filter($medal_arr));

                if (count($medal_arr) != $total) {
                    // 勋章数据重复
                    E('_ERR_MEDAL_REPEAT');
                }

                // 转换成以勋章名称为键的二维数组
                $medal = array_combine_by_key($medal, 'name');

                // 循环验证发放勋章
                foreach ($medal_arr as $_v) {

                    if (empty($medal[$_v])) {

                        E('_ERR_MEDAL_NAME');
                        break;
                    }
                    // 获取用户信息
                    $user_data = $user_list[$v['sr_uid']];
                    // 发放勋章
                    $res_integral = $integralUtil->endowMedal($medal[$_v]['im_id'], $v['sr_uid'], $user_data['memUsername']);
                    // 勋章发放成功
                    if ($res_integral) {
                        // 将用户id加入到待发消息用户id集合
                        array_push($medal_msg_data[$_v]['sr_uids'], $v['sr_uid']);
                    }
                }
            }

            // 更新发放状态
            $this->_d->update_by_conds(['sr_id' => array_column($give_incentives_list, 'sr_id')], ['sr_give_status' => self::GIVE_STATUS_OK]);

            // 事务提交
            $this->commit();

        } catch (\Think\Exception $e) {
            \Think\Log::record($e);
            // 事务回滚
            $this->rollback();
            E('_ERR_SAVE_FAIL');
        }

        // 勋章消息推送
        foreach ($medal_msg_data as $msg) {

            $sr_uids = array_unique($msg['sr_uids']);
            if (count($sr_uids)) {

                $memIDs = [];
                foreach ($sr_uids as $k => $uid) {

                    $memIDs[$k]['memID'] = $uid;
                }

                // 组装消息提醒参数
                $msg_params = [
                    'name' => $msg['name'],
                    'ed_id' => $education['ed_id'],
                    'ed_name' => $education['ed_name'],
                    'uids' => $memIDs,
                    'my_medal' => self::MSG_MEDAL
                ];

                // 发送消息提醒
                $right_users_s->send_msg($msg_params, RightUsersService::MSG_GIVE_MEDAL);
            }
        }

        return true;
    }
}