report/app/job/Talent.php

<?php

namespace app\job;

use think\queue\Job;
use think\facade\Log;
use think\facade\Db;
use app\common\api\ChuanglanSmsApi;
use app\common\model\MessageRecord;
use app\common\api\TalentLogApi;
use app\common\api\TalentConditionApi;
use app\common\api\TalentState;
use app\enterprise\model\Talent as TalentModel;
use app\common\state\ProjectState;
use app\common\state\CommonConst;

/**
 * Description of Talent
 *
 * @author sgq
 */
class Talent {

    public function fire(Job $job, $data) {
        if ($this->deal($data)) {
            $job->delete();
            return true;
        }
        if ($job->attempts() >= 3) {
            $job->delete();
            return false;
        }
        $job->release(10); //10秒后重试
    }

    /**
     * 处理业务逻辑
     * @param type $data
     * @return bool
     */
    public function deal($data): bool {
        switch ($data["type"]) {
            case 1:
                //部门超时驳回
                $mainId = $data["id"];
                $where[] = ["ti.id", "=", $mainId];
                $where[] = ["ti.checkState", "=", TalentState::FST_VERIFY_PASS];
                $where[] = ["ti.pass_dept_check", "=", 0];
                $talent_info = TalentModel::alias("ti")
                                ->leftJoin("new_talent_condition tc", "tc.id=ti.talent_condition")
                                ->leftJoin("un_enterprise e", "e.id=ti.enterprise_id")
                                ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where md5(concat(createTime,mainId,`type`)) in (select md5(concat(max(createTime),mainId,`type`)) from `new_talent_checklog` where `type`=1 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ti.id")
                                ->where($where)->field("ti.*,tc.companyIds,tc.companyWithFileType")->find();
                if ($talent_info) {
                    $weekDay = date("w"); //0周日，6周六
                    if ($weekDay == 6) {
                        $delay = 2 * 24 * 3600;
                        queue("app\job\Talent", ["type" => 1, "id" => $mainId], $delay);
                        return true;
                    }
                    if (!$weekDay || $weekDay == 0) {
                        $delay = 1 * 24 * 3600;
                        queue("app\job\Talent", ["type" => 1, "id" => $mainId], $delay);
                        return true;
                    }
                    $modify_files = array_filter(explode(",", $talent_info["modify_files"]));
                    $companyAndTypes = [];
                    $companyWithFileType = array_filter(explode(";", $talent_info["companyWithFileType"]));
                    foreach ($companyWithFileType as $c) {
                        list($companyId, $fileTypesStr) = array_filter(explode(":", $c));
                        $companyAndTypes[$companyId] = array_filter(explode(",", $fileTypesStr));
                    }

                    $companyIds = array_filter(explode(",", $talent_info["companyIds"]));
                    if ($companyIds) {
                        /* if ($talent_info["re_check_companys"]) {
                          $unpass_companyIds = array_filter(explode(",", $talent_info["re_check_companys"]));
                          } else {
                          //这边去除已经审核通过的单位，主要通过日志是否存在记录。
                          $pass_companyIds = TalentLogApi::getPassDepts($talent_info["id"]); //已经通过的单位
                          $unpass_companyIds = array_diff($companyIds, (array) $pass_companyIds); //排除已经通过的单位
                          } */
                        $pass_companyIds = TalentLogApi::getPassDepts($talent_info["id"]); //已经通过的单位
                        $re_check_companys = $talent_info["re_check_companys"] ? array_filter(explode(",", $talent_info["re_check_companys"])) : [];
                        $companyIds = \app\common\api\VerifyApi::getNewReCheckCompanyIds($re_check_companys, $companyIds, $pass_companyIds);
                        $unpass_companyIds = array_diff($companyIds, (array) $pass_companyIds); //排除已经通过的单位
                        if (!$unpass_companyIds) {
                            //没有未审部门
                            return true;
                        }
                        //开始驳回操作
                        $fst_dept_check_time = $talent_info["first_dept_check_time"];
                        $log_checkState = TalentState::FST_VERIFY_PASS; //当前状态不变
                        $checkState = TalentState::SCND_SUBMIT; //退回待初审
                        foreach ($unpass_companyIds as $companyId) {
                            $fileTypes = $companyAndTypes[$companyId];
                            $modify_files = array_unique((array_merge((array) $modify_files, (array) $fileTypes)));
                            $dept_log = TalentLogApi::getLogByCompanyId($talent_info["id"], $companyId, $fst_dept_check_time);
                            if ($dept_log) {
                                TalentLogApi::rewrite($dept_log["id"], [$log_checkState, $checkState], "审核超时，系统自动驳回", 1);
                            } else {
                                TalentLogApi::write(ProjectState::TALENT, $talent_info["id"], [$log_checkState, $checkState, 3], "审核超时，系统自动驳回", 1, null, null, $companyId); //补一条记录
                                sleep(1);
                            }
                        }
                        $log_checkState = TalentState::DEPT_VERIFY_REJECT;
                        $save["id"] = $talent_info["id"];
                        $save["modify_files"] = implode(",", $modify_files);
                        $save["checkState"] = $checkState;
                        $save["highProcess"] = $talent_info["highProcess"] > 3 ? $talent_info["highProcess"] : 3;
                        $save["first_dept_check_time"] = null;
                        $save["re_check_companys"] = null;
                        TalentModel::update($save);
                        TalentLogApi::write(1, $talent_info["id"], [$log_checkState, $checkState], "审核超时，系统自动驳回，部门审核结束", 1);
                    }
                    return true;
                }
                break;
            case 2:
                //超过批次提交时间审核失败
                $talentInfo = $data["talentInfo"];
                $projectType = ProjectState::TALENT; //项目类型
                $mainId = $talentInfo["id"]; //申报id
                $checkState = TalentState::FST_VERIFY_FAIL; //系统审核失败状态，初审不通过
                if ($talentInfo["checkState"] == TalentState::SCND_SAVE) {
                    $where = [];
                    $where[] = ["active", "=", 1];
                    $where[] = ["type", "=", $projectType];
                    $where[] = ["source", "=", $talentInfo["enterpriseType"]];
                    $where[] = ["batch", "=", $talentInfo["apply_year"]];
                    $whereRaw = sprintf("submitEndTime is not null and submitEndTime<>'' and submitEndTime < '%s'", date("Y-m-d H:i:s"));
                    $batch = \app\common\model\Batch::where($where)->whereRaw($whereRaw)->find();
                    if ($batch) {
                        $save["id"] = $mainId;
                        $save["checkState"] = $checkState;
                        TalentModel::update($save);
                        TalentLogApi::write($projectType, $mainId, $checkState, "超过该批次提交截止时间未提交审核，系统自动结束该申报", 1);
                    }
                    return true;
                }
                break;
            case 3:
                //撤销超时审核失败
                $talentInfo = $data["talentInfo"];
                $projectType = ProjectState::TALENT; //项目类型
                $mainId = $talentInfo["id"]; //申报id
                $checkState = TalentState::SCND_SAVE; //系统审核失败状态，初审不通过
                $last_log = TalentLogApi::getLastLog($mainId, $projectType, 0, ["active", "=", 1]);
                if ($talentInfo["checkState"] == TalentState::FST_VERIFY_FAIL && $last_log["state"] == TalentState::FST_VERIFY_FAIL && $last_log["createUser"] == "系统") {
                    $where = [];
                    $where[] = ["active", "=", 1];
                    $where[] = ["type", "=", $projectType];
                    $where[] = ["source", "=", $talentInfo["enterpriseType"]];
                    $where[] = ["batch", "=", $talentInfo["apply_year"]];
                    $whereRaw = sprintf("submitEndTime is null or submitEndTime<>'' or submitEndTime > '%s'", date("Y-m-d H:i:s"));
                    $batch = \app\common\model\Batch::where($where)->whereRaw($whereRaw)->find();
                    $extra_where[] = ["active", "=", 1];
                    $extra_where[] = ["createUser", "<>", "系统"];
                    $last_log = TalentLogApi::getLastLogEx($mainId, $projectType, 0, $extra_where);
                    if ($batch && $last_log) {
                        $save["id"] = $mainId;
                        $save["checkState"] = $checkState;
                        TalentModel::update($save);
                        TalentLogApi::write($projectType, $mainId, [$last_log["state"], $last_log["new_state"]], "该批次经人社局操作，已延长申报提交截止时间，现由人才办交办，对被自动审核失败的申报进行状态处理，恢复至初审驳回。该申报已处理。", 1);
                    }
                    return true;
                }
                break;
            case 4:
                //发放人才码后增加积分记录
                try {
                    $mainId = $data["id"];
                    $where = [];
                    $where[] = ["ti.id", "=", $mainId];
                    $where[] = ["ti.checkState", "=", TalentState::CERTIFICATED];
                    $talentInfo = TalentModel::alias("ti")->leftJoin("un_enterprise e", "e.id=ti.enterprise_id")->field("ti.*,e.type as enterpriseType")->where($where)->find();
                    $where = [];
                    $where[] = ["mainId", "=", $mainId];
                    $where[] = ["mainType", "=", "talent"];
                    $integralLog = Db::table("new_integral_log")->where($where)->find();
                    if ($talentInfo && !$integralLog) {
                        $level = $talentInfo["talent_arrange"];
                        $name = $talentInfo["name"]; //姓名
                        $cardType = $talentInfo["card_type"]; //身份证类型
                        $cardNumber = $talentInfo["card_number"]; //身份证
                        $type = $talentInfo["enterpriseType"]; //企业类型
                        $lastPoints = 0; //上次积分
                        $gainPoints = CommonConst::getLayerPointsByLayer($level); //增加积分
                        $desc = sprintf("经人才申报审核通过，认定为集成电路（%s）优秀人才，基础分变更为%d分。", CommonConst::getLayerNameByLayer($level), $gainPoints); //详情

                        /* 查询是否升级 */
                        $where = [];
                        $where[] = ["id", "<>", $mainId];
                        //$where[] = ["name", "=", $name];
                        $where[] = ["card_type", "=", $cardType];
                        $where[] = ["card_number", "=", $cardNumber];
                        $where[] = ["checkState", "=", TalentState::CERTIFICATED];
                        $talentBeforeInfo = TalentModel::where($where)->order("createTime desc")->find();
                        if ($talentBeforeInfo && $level < $talentBeforeInfo["talent_arrange"]) {
                            $beforeLevelName = CommonConst::getLayerNameByLayer($talentBeforeInfo["talent_arrange"]); //之前层次
                            $beforeLevelPoints = CommonConst::getLayerPointsByLayer($talentBeforeInfo["talent_arrange"]); //之前基础分
                            $nowLevelName = CommonConst::getLayerNameByLayer($level); //现在层次
                            $nowLevelPoints = CommonConst::getLayerPointsByLayer($level); //现在基础分
                            $gainPoints -= $beforeLevelPoints;
                            $desc = sprintf("人才层次晋升（%s->%s），基础分增加%d（%d->%d）分。", $beforeLevelName, $nowLevelName, $gainPoints, $beforeLevelPoints, $nowLevelPoints);
                        }

                        /* 查询最后一条积分日志 */
                        $where = [];
                        //$where[] = ["name", "=", $name];
                        $where[] = ["card_type", "=", $cardType];
                        $where[] = ["card_number", "=", $cardNumber];
                        $last_log = Db::table("new_integral_log")->where($where)->order("createTime desc")->find();
                        $lastPoints = $last_log["nowPoints"] ?: 0;

                        $log["id"] = getStringId();
                        $log["type"] = $type;
                        $log["mainType"] = "talent";
                        $log["mainId"] = $mainId;
                        $log["enterprise_id"] = $talentInfo["enterprise_id"];
                        $log["name"] = $name;
                        $log["card_type"] = $cardType;
                        $log["card_number"] = $cardNumber;
                        $log["talentLevel"] = $level;
                        $log["lastPoints"] = $lastPoints;
                        $log["gainPoints"] = $gainPoints;
                        $log["nowPoints"] = $lastPoints + $gainPoints;
                        $log["description"] = $desc;
                        $log["createTime"] = date("Y-m-d H:i:s");
                        Db::table("new_integral_log")->insert($log);
                        return true;
                    }
                } catch (\Exception $e) {
                    Log::write($e->getMessage(), "error");
                }
                break;
        }
        return false;
    }

}