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"]); //已经通过的单位
                        $companyIds = \app\common\api\VerifyApi::getNewReCheckCompanyIds($talent_info["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;
        }
        return false;
    }

}