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;

/**
 * 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:
                //发放人才码后增加积分记录
                $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; //上次积分                    
                    $levelAndPoints = [
                        1 => 6000,
                        2 => 4000,
                        3 => 2000,
                        4 => 1000,
                        5 => 500,
                        6 => 200,
                        7 => 100
                    ];
                    $levelAndNames = [
                        1 => "第一层次",
                        2 => "第二层次",
                        3 => "第三层次",
                        4 => "第四层次",
                        5 => "第五层次",
                        6 => "第六层次",
                        7 => "第七层次",
                    ];
                    $gainPoints = $levelAndPoints[$level]; //增加积分
                    $desc = sprintf("首次通过人才申报，增加基础积分%d。", $levelAndPoints[$level]); //详情

                    /* 查询是否升级 */
                    $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 = $levelAndNames[$talentBeforeInfo["talent_arrange"]]; //之前层次
                        $beforeLevelPoints = $levelAndPoints[$talentBeforeInfo["talent_arrange"]]; //之前基础分
                        $nowLevelName = $levelAndNames[$level]; //现在层次
                        $nowLevelPoints = $levelAndPoints[$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["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;
                }
                break;
        }
        return false;
    }

}