report/app/admin/controller/LivingAllowance.php

<?php

namespace app\admin\controller;

use app\admin\common\AdminController;
use app\common\api\ChuanglanSmsApi;
use app\common\api\EnterpriseApi;
use app\common\api\LivingAllowanceApi;
use app\common\state\LivingAllowanceState as LaState;
use app\common\state\CommonConst;
use app\common\model\TalentLog;
use app\common\state\ProjectState;
use app\common\model\LivingAllowance as LaModel;
use app\common\api\DictApi;
use think\facade\Db;

/**
 * Description of LivingAllowance
 *
 * @author sgq
 */
class LivingAllowance extends AdminController {

    public function index() {
        $enterpriseList = EnterpriseApi::getSimpleList();
        $provinceList = \app\common\api\LocationApi::findProvinceSelect();
        $process = $this->request->param("process");
        $message = [];
        if ($this->user["type"] == 1) {
            $message["typeName"] = "晋江市硕博人才生活补贴申报";
            $message["address"] = "聚才网/人才晋江微信公众号";
            $message["dep"] = "中共晋江市委人才办、晋江市纪委监委驻市人力资源和社会保障局纪检监察组或晋江市公共就业和人才服务中心";
            $message["phone"] = "0595-85633128";
            $message["email"] = "jjrc85661234@163.com";
        } else if ($this->user["type"] == 2) {
            $message["typeName"] = "晋江市硕博人才生活补贴申报";
            $message["address"] = "福建（晋江）集成电路产业园官方网站及微信公众号";
            $message["dep"] = "集成电路产业园区";
            $message["phone"] = "0595-82250007、0595-82250001";
            $message["email"] = "jjjcdr@163.com";
        }
        return view("", ["enterpriseList" => $enterpriseList, "provinceList" => $provinceList, "process" => $process, "message" => $message]);
    }

    public function list() {
        $res = LivingAllowanceApi::getList($this->request->param());
        return json($res);
    }

    public function detail() {
        $id = $this->request->param("id");
        $process = $this->request->param("process");
        $info = LivingAllowanceApi::getInfoById($id);

        $info = $this->translateToChinese($info);
        return view("", ["row" => $info, "process" => $process]);
    }

    private function translateToChinese($obj) {
        if ($obj["industryFieldNew"]) {
            $obj["industryFieldNewName"] = DictApi::findByParentCodeAndCode("industry_field", $obj["industryFieldNew"])["name"];
        }
        if ($obj["industryField"]) {
            $industry_field_type = $obj["industryFieldNew"] ? $obj["industryFieldNew"] . "_field" : "un_industryField";
            $obj["industryFieldName"] = DictApi::findByParentCodeAndCode($industry_field_type, $obj["industryField"])["name"];
        }
        if ($obj["address"]) {
            $obj["streetName"] = DictApi::findByParentCodeAndCode("street", $obj["address"])["name"];
        }
        if ($obj["nationality"]) {
            $obj["nationalityName"] = DictApi::findByParentCodeAndCode("nationality", $obj["nationality"])["name"];
        }
        if ($obj["nation"]) {
            $obj["nationName"] = DictApi::findByParentCodeAndCode("nation", $obj["nation"])["name"];
        }
        if ($obj["politics"]) {
            $obj["politicsName"] = DictApi::findByParentCodeAndCode("politics", $obj["politics"])["name"];
        }
        if ($obj["highEducation"]) {
            $obj["educationName"] = DictApi::findByParentCodeAndCode("highest_degree", $obj["highEducation"])["name"];
        }
        if ($obj["introductionMode"]) {
            $obj["introductionModeName"] = DictApi::findByParentCodeAndCode("un_introduction_mode", $obj["introductionMode"])["name"];
        }
        if ($obj["declareType"]) {
            $obj["declareTypeName"] = DictApi::findByParentCodeAndCode("un_master_education", $obj["declareType"])["name"];
        }
        if ($obj["cardType"] == 1) {
            $obj["cardTypeName"] = "身份证";
        } else if ($obj["cardType"] == 2) {
            $obj["cardTypeName"] = "通行证";
        } else if ($obj["cardType"] == 3) {
            $obj["cardTypeName"] = "护照";
        } else {
            $obj["cardTypeName"] = "未知";
        }
        return $obj;
    }

    /**
     * 校验是否在审核范围内
     * @param type $id
     * @param type $process
     * @return type
     */
    public function validateIsCheck($id, $process) {
        $oldInfo = \app\common\api\LivingAllowanceApi::getInfoById($id);
        $responseObj = new \stdClass();
        $responseObj->code = 500;
        switch ($process) {
            case 1:
                if ($oldInfo["checkState"] != LaState::LA_NEED_FIRST_CHECK && $oldInfo["checkState"] != LaState::LA_DEP_REJECT) {
                    $responseObj->msg = "该申报不在审核范围内，无法审核";
                } else {
                    $responseObj->code = 200;
                    $responseObj->msg = "";
                }
                break;
            case 2:
                $company = getCacheById("Company", $this->user["companyId"]);
                if ($oldInfo["checkState"] != LaState::LA_NEED_DEP_CHECK && $oldInfo["checkState"] != LaState::LA_THIRD_REJECT) {
                    $responseObj->msg = "该申报不在审核范围内，无法审核";
                } else if ($company["code"] != CommonConst::JYJ) {
                    $responseObj->msg = "部门审核仅教育局能够审核！";
                } else {
                    $responseObj->code = 200;
                    $responseObj->msg = "";
                }
                break;
            case 3:
                if ($oldInfo["checkState"] != LaState::LA_NEED_THIRD) {
                    $responseObj->msg = "该申报不在审核范围内，无法审核";
                } else if ($oldInfo["creditStatus"] == 1) {
                    $responseObj->msg = "当前申报数据未导入核查数据,无法审核";
                } else {
                    $responseObj->code = 200;
                    $responseObj->msg = "";
                }
                break;
            case 4:
                break;
        }
        if ($responseObj->code == 500) {
            return json($responseObj);
        }
        $where = [];
        $where[] = ["mainId", "=", $id];
        $where[] = ["active", "=", 2];
        $where[] = ["step", "=", $process];
        $log = TalentLog::where($where)->order("createTime desc")->find();

        if ($log) {
            $oldInfo["checkState"] = $log["state"];
            $oldInfo["checkMsg"] = $log["description"];
        } else {
            $oldInfo["checkState"] = null;
            $oldInfo["checkMsg"] = "";
        }
        $res = [];
        $res["obj"] = $oldInfo;
        if ($responseObj->code == 200) {
            $where = [];
            $where[] = ["project", "=", ProjectState::LIVINGALLOWANCE];
            $where[] = ["active", "=", 1];
            $where[] = ["type", "=", $oldInfo["type"]];
            $fileTypeList = \app\common\model\FileType::where($where)->order("sn")->select()->toArray();
            $res["fileList"] = $fileTypeList;
        }
        $responseObj->obj = $res;
        return json($responseObj);
    }

    /**
     * 审核
     * @return type
     */
    public function check() {
        $responseObj = new \stdClass();
        $responseObj->code = 500;
        $obj = $this->request->param();
        if (!$obj) {
            $responseObj->msg = "系统错误，请联系管理员";
            return json($responseObj);
        }
        if (!$obj["checkState"]) {
            $responseObj->msg = "请选择审核状态";
            return json($responseObj);
        }
        Db::startTrans();
        try {
            //保存驳回字段
            $updData["id"] = $obj["id"];
            $updData["fields"] = $obj["fields"];
            $updData["files"] = $obj["files"];
            Db::table("md_living_allowance_info")->save($updData);

            //加入日志
            $newLog["id"] = getStringId();
            $newLog["type"] = ProjectState::LIVINGALLOWANCE;
            $newLog["mainId"] = $obj["id"];
            $newLog["active"] = 2;
            $newLog["state"] = $obj["checkState"];
            $newLog["step"] = $obj["process"];
            $newLog["stateChange"] = "保存未提交";
            $newLog["description"] = $obj["checkMsg"];
            $newLog["createTime"] = date("Y-m-d H:i:s");
            $newLog["createUser"] = sprintf("%s(%s)", $this->user["account"], $this->user["companyName"]);
            Db::table("new_talent_checklog")->insert($newLog);
            $responseObj->code = 200;
            $responseObj->msg = "审核成功";
            Db::commit();
            return json($responseObj);
        } catch (\Exception $e) {
            Db::rollback();
            $responseObj->msg = $e->getMessage();
            return json($responseObj);
        }
    }

    /**
     * 审核不通过
     * @return type
     */
    public function setNotPass() {
        $responseObj = new \stdClass();
        $responseObj->code = 500;
        $ids = trim($this->request->param("ids"));
        $msg = trim($this->request->param("msg"));
        $ids = array_filter(explode(",", $ids));
        if (!$ids) {
            $responseObj->msg = "请选择需要设置审核不通过的数据";
            return json($responseObj);
        }
        if (!$msg) {
            $responseObj->msg = "请填写审核不通过的原因";
            return json($responseObj);
        }
        $where = [];
        $where[] = ["id", "in", $ids];
        $list = LaModel::where($where)->select()->toArray();
        $updates = [];
        $newLogs = [];
        $sb = [];
        Db::startTrans();
        try {
            foreach ($list as $obj) {
                if ($obj["checkState"] != LaState::LA_SAVE && $obj["checkState"] != LaState::LA_FIRST_REJECT) {
                    $sb[] = $obj["name"];
                }
                $oldState = $obj["checkState"];
                $newState = LaState::LA_NOTPASS;
                $update = [
                    "id" => $obj["id"],
                    "checkState" => $newState,
                    "checkMsg" => $msg
                ];
                $updates[] = $update;
                Db::table("md_living_allowance_info")->save($update);
                $newLog["id"] = getStringId();
                $newLog["type"] = ProjectState::LIVINGALLOWANCE;
                $newLog["mainId"] = $obj["id"];
                $newLog["active"] = 1;
                $newLog["state"] = $newState;
                $newLog["step"] = 70; //审核不通过
                $newLog["stateChange"] = LaState::getStateDesc($oldState) . "->" . LaState::getStateDesc($newState);
                $newLog["description"] = "原因：" . $msg;
                $newLog["createTime"] = date("Y-m-d H:i:s");
                $newLog["createUser"] = sprintf("%s(%s)", $this->user["account"], $this->user["companyName"]);

                $newLogs[] = $newLog;
            }
            if ($sb) {
                $responseObj->msg = implode("，", $sb) . "的审核状态既不是待提交，也不是初审驳回";
                return json($responseObj);
            }
            if (!$updates || !$newLogs) {
                $responseObj->msg = "没有待审核项";
                return json($responseObj);
            }
            Db::table("new_talent_checklog")->insertAll($newLogs);
            Db::commit();
            $responseObj->code = 200;
            $responseObj->msg = "设置审核不通过成功";
            return json($responseObj);
        } catch (\Exception $e) {
            Db::rollback();
            return json(["msg" => "设置审核不通过失败：" . $e->getMessage()]);
        }
    }

    public function submitCheck() {
        $id = $this->request->param("id");
        $process = $this->request->param("process");
        $responseObj = new \stdClass();
        $responseObj->code = 500;
        if (!$id) {
            $responseObj->msg = "系统错误,请联系管理员!";
            return json($responseObj);
        }
        $oldInfo = \app\common\api\LivingAllowanceApi::getInfoById($id);
        $oldState = $oldInfo["checkState"];

        $where = [];
        $where[] = ["mainId", "=", $id];
        $where[] = ["active", "=", 2];
        $where[] = ["step", "=", $process];
        $oldLog = TalentLog::where($where)->order("createTime desc")->find();
        if (!$oldLog) {
            $responseObj->msg = "请先审核后再提交";
            return json($responseObj);
        }
        $company = getCacheById("Company", $this->user["companyId"]);
        if ($process == 2 && $company["code"] != CommonConst::JYJ) {
            $responseObj->msg = "部门审核仅教育局能够审核!";
            return $responseObj;
        }
        $updData = [];
        $updData["id"] = $id;
        if (!$oldInfo["highProcess"]) {
            $updData["highProcess"] = $process;
        } else {
            $updData["highProcess"] = $oldInfo["process"] < $process ? $process : $oldInfo["highProcess"];
        }
        switch ($process) {
            case 1:
                if ($oldLog["state"] == -1) {
                    $updData["checkState"] = LaState::LA_NOTPASS;
                    $updData["recommendAmount"] = 0;
                    $updData["isPay"] = -1;
                    $updData["recommendAmountDesc"] = "审核不通过,不予兑现";
                    $updData["recommendJudgmentDetails"] = "审核不通过,不予兑现";
                }
                if ($oldLog["state"] == 2) {
                    $updData["checkState"] = LaState::LA_FIRST_REJECT;
                    //MessageRecord record = new MessageRecord(old.getId(), 2, 2, old.getName(), old.getPhone(), null, SmsProperties.MASTER_ALLOWANCE_REJECT);
                    //Sms253Util.sendMessage(record);
                }
                //审核通过
                if ($oldLog["state"] == 3) {
                    $updData["checkState"] = LaState::LA_NEED_DEP_CHECK;
                    $updData["firstPassTime"] = date("Y-m-d H:i:s");
                }
                break;
            case 2:
                if ($oldLog["state"] == -1) {
                    $updData["checkState"] = LaState::LA_NOTPASS;
                    $updData["recommendAmount"] = 0;
                    $updData["recommendAmountDesc"] = "审核不通过,不予兑现";
                    $updData["recommendJudgmentDetails"] = "审核不通过,不予兑现";
                    $updData["recommendIsPay"] = -1;
                }
                if ($oldLog["state"] == 2) {
                    $updData["checkState"] = LaState::LA_DEP_REJECT;
                    $updData["creditStatus"] = 1;
                    $updData["recommendAmount"] = null;
                    $updData["recommendAmountDesc"] = "";
                    $updData["recommendJudgmentDetails"] = "";
                    $updData["recommendIsPay"] = 0;
                }
                if ($oldLog["state"] == 3) {
                    $updData["checkState"] = LaState::LA_NEED_THIRD;
                    $updData["firstDepPassTime"] = date("Y-m-d H:i:s");
                    $_updData = $this->calculateAmount($oldInfo);
                    $updData = array_merge($updData, $_updData);
                }
                break;
            case 3:
                if ($oldLog["state"] == -1) {
                    $updData["checkState"] = LaState::LA_NOTPASS;
                    $updData["recommendAmount"] = 0;
                    $updData["recommendAmountDesc"] = "审核不通过,不予兑现";
                    $updData["recommendJudgmentDetails"] = "审核不通过,不予兑现";
                    $updData["recommendIsPay"] = -1;
                }
                if ($oldLog["state"] == 2) {
                    $updData["checkState"] = LaState::LA_DEP_REJECT;
                    $updData["creditStatus"] = 1;
                    $updData["recommendAmount"] = null;
                    $updData["recommendAmountDesc"] = "";
                    $updData["recommendJudgmentDetails"] = "";
                    $updData["recommendIsPay"] = 0;
                }
                if ($oldLog["state"] == 3) {
                    $updData["checkState"] = LaState::LA_PASS;
                    $updData["isPublic"] = 2;
                }
                break;
        }
        $newLog["id"] = getStringId();
        $newLog["type"] = ProjectState::LIVINGALLOWANCE;
        $newLog["mainId"] = $id;
        $newLog["active"] = 1;
        $newLog["state"] = $oldLog["state"];
        $newLog["step"] = $process;
        $newLog["stateChange"] = LaState::getStateDesc($oldState) . "->" . LaState::getStateDesc($updData["checkState"]);
        $newLog["description"] = $oldLog["description"];
        $newLog["createTime"] = date("Y-m-d H:i:s");
        $newLog["createUser"] = sprintf("%s(%s)", $this->user["account"], $this->user["companyName"]);
        Db::startTrans();
        try {
            $where = [];
            $where[] = ["mainId", "=", $id];
            $where[] = ["type", "=", ProjectState::LIVINGALLOWANCE];
            $where[] = ["active", "=", 2];
            Db::table("new_talent_checklog")->where($where)->delete();
            Db::table("new_talent_checklog")->insert($newLog);
            Db::table("md_living_allowance_info")->save($updData);
            Db::commit();
            $responseObj->code = 200;
            $responseObj->msg = "提交审核成功";
            return json($responseObj);
        } catch (\think\db\exception\DbException $e) {
            Db::rollback();
            $responseObj->msg = $e->getMessage();
            return json($responseObj);
        }
    }

    /**
     * 查询需要处理的数据
     */
    public function selectNeedCheckData() {
        $response = new \stdClass();
        $response->code = 500;
        $user = $this->user;

        $type = $this->request->param("type");
        $id = $this->request->param("id");
        $name = \StrUtil::getRequestDecodeParam($this->request, "name");
        $sex = $this->request->param("sex");
        $checkState = $this->request->param("checkState");

        if (!in_array($user["type"], [1, 2])) {
            $response->msg = "当前账号类型没有操作权限";
            return json($response);
        }
        $where = [];
        $where[] = ["type", "=", $user["type"]];
        if ($name) {
            $where[] = ["name", "like", "%" . $name . "%"];
        }
        if ($sex) {
            $where[] = ["sex", "=", $sex];
        }
        if ($checkState) {
            $where[] = ["checkState", "=", $checkState];
        }
        switch ($type) {
            case 1:
                $where[] = ["isPublic", "=", 1];
                $where[] = ["checkState", "=", LaState::LA_NEED_THIRD];
                break;
            case 2:
                $where[] = ["isPublic", "=", 1];
                $where[] = ["checkState", "in", [LaState::LA_NOTPASS, LaState::LA_PASS]];
                break;
            case 3:             //公示
            case 7:             //公示预览
                $where[] = ["isPublic", "=", 2];
                $where[] = ["checkState", "in", [LaState::LA_NOTPASS, LaState::LA_PASS]];
                break;
            case 4:
                $where[] = ["isPublic", "=", 3];
                $where[] = ["checkState", "in", [LaState::LA_NOTPASS, LaState::LA_PASS]];
                break;
            case 6:
                $where[] = ["isPublic", "=", 4];
                $where[] = ["checkState", "=", LaState::LA_PASS];
                break;
        }
        $list = Db::table("md_living_allowance_info")->field("id,idCard,name,enterpriseName,checkState")->where($where)->select()->toArray();
        $response->obj = ["rows" => $list, "total" => count($list)];
        $response->code = 200;
        return json($response);
    }

    /**
     * 导出核查征信名单
     * @auth {{/talentInfo/exportHczx}}
     */
    public function exportHczx() {
        $response = new \stdClass();
        $response->code = 500;
        $user = $this->user;
        if (!in_array($user["type"], [1, 2])) {
            $response->msg = "当前账号类型没有操作权限";
            return \StrUtil::back($response, "LivingAllowanceInfo.callBack");
        }
        $where = [];
        $ids = array_filter(explode(",", $this->request->param("ids")));
        $where[] = ["id", "in", $ids];
        $list = LaModel::where($where)->select()->toArray();

        $nationalitys = DictApi::selectByParentCode("nationality"); //查询国籍字典表
        if (!$list) {
            $response->msg = "暂无可核查征信的数据";
            return \StrUtil::back($response, "LivingAllowanceInfo.callBack");
        }
        $title = ["序号", "姓名", "国籍/地区", "证件号码", "工作单位", "征信情况", "社保缴纳情况", "个税缴纳情况", "工商注册情况"];
        $exportList = [];
        for ($i = 0; $i < count($list); $i++) {
            $tmp = $list[$i];
            $exportList[] = [
                $i + 1, $tmp["name"], $nationalitys[$tmp["nationality"]], $tmp["idCard"], $tmp["enterpriseName"], $tmp["outMsg"], $tmp["actualSocialSecurity"], $tmp["actualTax"], $tmp["actualBusinessRegistration"]
            ];
        }
        $fileName = "硕博人才生活补贴核查征信名单导出";
        export($title, $exportList, $fileName);
    }

    /**
     * 导入征信核查结果
     * @auth {{/talentInfo/importProject}}
     */
    public function importProject(\think\Request $request) {
        $response = new \stdClass();
        $response->code = 500;
        if (!$request->file()) {
            $response->msg = "没有导入文件";
            return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
        }
        $file = $request->file("file");
        if (!isExcelFile($file->getMime())) {
            $response->msg = "不是正确的Excel文件";
            return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
        }

        $path = $file->getRealPath();
        $rows = getExcelDatas($path);
        $titleRow = array_shift($rows); //去标题        
        $titles = ["序号", "姓名", "国籍/地区", "证件号码", "工作单位", "征信情况", "社保缴纳情况", "个税缴纳情况", "工商注册情况"];
        Db::startTrans();
        try {
            for ($i = 0; $i < count($titles); $i++) {
                if ($titles[$i] != $titleRow[$i]) {
                    $response->msg = "模板错误";
                    return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
                }
            }
            $total = count($rows);
            if ($total == 0) {
                $response->msg = "没有数据";
                return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
            }
            //------------行数据校验------------------------------------------------------//
            $idCards = [];
            $sbf = [];
            for ($i = 0; $i < $total; $i++) {
                $row = $rows[$i];
                $name = trim($row[1]);
                $idCard = trim($row[3]);
                $creditStatus = trim($row[5]);
                $socialSecurity = trim($row[6]);
                $personalTax = trim($row[7]);
                $businessRegistration = trim($row[8]);
                if (\StrUtil::isEmpOrNull($name)) {
                    $sbf[] = sprintf("第 %d 行模板被修改", $i + 1);
                }
                if (\StrUtil::isEmpOrNull($idCard)) {
                    $sbf[] = sprintf("第 %d 行模板被修改", $i + 1);
                }
                if (\StrUtil::isEmpOrNull($creditStatus) || !in_array($creditStatus, ["无", "在逃人员", "失信被执行人", "意识形态存在问题"])) {
                    $sbf[] = sprintf("第 %d 行征信格式错误，请根据核查情况填写[ 无 | 在逃人员 | 失信被执行人 | 意识形态存在问题 ]", $i + 1);
                }
                //如2022-01,2022-02,2022-03,2022-04
                $datesRegexp = "/^[1-9]{1}\d{3}(01|02|03|04|05|06|07|08|09|10|11|12)(?:-[1-9]{1}\d{3}(01|02|03|04|05|06|07|08|09|10|11|12)){0,1}(?:,[1-9]{1}\d{3}(01|02|03|04|05|06|07|08|09|10|11|12)(?:-[1-9]{1}\d{3}(01|02|03|04|05|06|07|08|09|10|11|12)){0,1})*$/";
                if ($socialSecurity && !preg_match($datesRegexp, $socialSecurity)) {
                    $sbf[] = sprintf("第 %d 行社保核实情况格式不正确，格式例如[ 202202-202205,202207,202209-202212 ]", $i + 1);
                }
                if ($personalTax && !preg_match($datesRegexp, $personalTax)) {
                    $sbf[] = sprintf("第 %d 行个税核实情况格式不正确，格式例如[ 202202-202205,202207,202209-202212 ]", $i + 1);
                }
                if ($businessRegistration && !preg_match($datesRegexp, $businessRegistration)) {
                    $sbf[] = sprintf("第 %d 行工商注册情况格式不正确，格式例如[ 202202-202205,202207,202209-202212 ]", $i + 1);
                }
                $idCards[] = $idCard;
            }
            if ($sbf) {//如果校验 通不过
                $resultStr = implode("<br>", $sbf);
                if (mb_strlen($resultStr) > 200) {
                    $resultStr = mb_substr($resultStr, 0, 200) . "...";
                }
                $response->msg = $resultStr;
                return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
            }
            $where = [];
            $where[] = ["checkState", "=", LaState::LA_NEED_THIRD];
            $where[] = ["isPublic", "=", 1];
            $where[] = ["idCard", "in", $idCards];
            $list = Db::table("md_living_allowance_info")->where($where)->column("*", "idCard");
            for ($i = 0; $i < $total; $i++) {
                $row = $rows[$i];
                $idCard = trim($row[3]);
                $outMsg = trim($row[5]);
                $sbDetail = trim($row[6]);
                $taxDetail = trim($row[7]);
                $gsRegistDetail = trim($row[8]);
                $info = $list[$idCard];
                if ($info) {
                    $info["outMsg"] = $outMsg;
                    $info["actualSocialSecurity"] = $sbDetail;
                    $info["actualTax"] = $taxDetail;
                    $info["actualBusinessRegistration"] = $gsRegistDetail;
                    $info = $this->vailIsCash($info);
                    $info["creditStatus"] = $outMsg != "无" ? 3 : 2;
                    Db::table("md_living_allowance_info")->save($info);
                }
            }

            $response->code = 200;
            $response->msg = "导入成功";
            Db::commit();
            return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
        } catch (\Exception $e) {
            Db::rollback();
            $response->msg = "导入失败，系统错误：" . $e->getMessage();
            return \StrUtil::back($response, "LivingAllowanceInfo.importCallBack");
        }
    }

    /**
     * 公示
     */
    public function publicBatch() {
        $response = new \stdClass();
        $response->code = 200;

        //查询需要公示的数据(勾选)
        $request = $this->request;
        $batch = \StrUtil::getRequestDecodeParam($request, "batch");
        $ids = array_filter(explode(",", \StrUtil::getRequestDecodeParam($request, "ids")));
        $where = [];
        $where[] = ["id", "in", $ids];
        $list = LaModel::where($where)->select()->toArray();
        $recordList = [];
        $sb = [];
        $newLogs = [];
        //MessageRecord sendRecord = new MessageRecord(null, 2, 2, null, null, null, SmsProperties . CHECK_PUBLIC);
        //sendRecord . setId(IdWorker . getIdStr());
        Db::startTrans();
        try {
            for ($i = 0; $i < count($list); $i++) {
                $obj = $list[$i];
                $obj["publicBatch"] = $batch;
                $obj["isPublic"] = 3;
                Db::table("md_living_allowance_info")->save($obj);
                //添加日志
                $newLog["id"] = getStringId();
                $newLog["type"] = ProjectState::LIVINGALLOWANCE;
                $newLog["mainId"] = $obj["id"];
                $newLog["active"] = 1;
                $newLog["state"] = 3;
                $newLog["step"] = 5;
                $newLog["stateChange"] = "<span class='label label-success'>待公示</span>-><span class='label label-primary'>公示中</span>";
                $newLog["createTime"] = date("Y-m-d H:i:s");
                $newLog["createUser"] = sprintf("%s(%s)", $this->user["account"], $this->user["companyName"]);

                $newLogs[] = $newLog;
                //sb . append(obj . getPhone() + "," + typeName + "," + address + "," + publicStartTime + "," + publicEndTime + "," + dep + "," + phone + "," + email + ";");
                /*                 * 短信参数 */
                //String param = obj . getPhone() + "," + typeName + "," + address + "," + publicStartTime + "," + publicEndTime + "," + dep + "," + phone + "," + email + ";";
                //sb . append(param);
                //MessageRecord record = new MessageRecord(null, 2, 2, obj . getName(), obj . getPhone(), param . substring(0, param . length() - 1), SmsProperties . CHECK_PUBLIC);
                //record . setState(1);
                //record . setBizId(sendRecord . getId());
                //record . setSendingDate(DateUtil . getTime());
                //record . setCreateTime(DateUtil . getTime());
                //recordList . add(record);
            }
            /* if (isMessage != null && isMessage == 1) {
              if (list.size() > 1000) {
              return new ResponseObj(ResponseObj . FAILD, "需要发送短信时公示量不能超过1000个");
              }
              //发送短信
              Map map = new HashMap();
              map . put("account", smsProperties . getAccount());
              map . put("password", smsProperties . getPassword());
              map . put("msg", sendRecord . getTemplateCode());
              map . put("params", sb . substring(0, sb . length() - 1));
              map . put("report", "true");
              map . put("uid", sendRecord . getId());
              String sendUrl = smsProperties . getBaseUrl() + "variable/json";
              JSONObject js = (JSONObject) JSONObject . toJSON(map);
              String res = HttpUtil . sendSmsByPost(sendUrl, js . toString());
              JSONObject jsonObject = JSONObject . parseObject(res);
              String code = jsonObject . getString("code");
              String errorMsg = jsonObject . getString("errorMsg");
              if (!"0" . equals(code)) {
              return new ResponseObj(ResponseObj . FAILD, "短信发送失败，原因为：" + errorMsg);
              }
              this . messageRecordService . insertBatch(recordList);
              } */
            Db::table("new_talent_checklog")->insertAll($newLogs);
            Db::commit();
            $response->msg = "公示成功";
            $response->code = 200;
            return json($response);
        } catch (\Exception $e) {
            Db::rollback();
            $response->msg = $e->getMessage();
            return json($response);
        }
    }

    public function afterCheck() {
        $response = new \stdClass();
        $response->code = 500;

        $id = $this->request->param("id");
        $checkState = $this->request->param("checkState");
        $checkMsg = \StrUtil::getRequestDecodeParam($this->request, "checkMsg");
        if (!$id) {
            $response->msg = "系统错误，请联系管理员";
            return json($response);
        }
        $old = LivingAllowanceApi::getInfoById($id);
        if ($old["isPublic"] != 3) {
            $response->msg = "当前记录不是公示中状态，无法审核";
            return json($response);
        }
        $desc = "";
        $data = [];
        $data["id"] = $id;
        if ($checkState == 2) {
            $data["checkState"] = LaState::LA_DEP_REJECT;
            $data["isPublic"] = 1;
            $data["outMsg"] = "";
            $data["creditStatus"] = 1;
            $data["recommendAmount"] = null;
            $data["recommendIsPay"] = 0;
            $data["recommendAmountDesc"] = "";
            $data["recommendJudgmentDetails"] = "";
            $desc = "（公示再审核驳回）审核状态：" . LaState::getStateDesc($old["checkState"]) . "->" . LaState::getStateDesc($data["checkState"]) .
                    ";公示状态：<span class='label label-success'>公示中</span>-><span class='label label-primary'>待核查征信</span>";
        } else if (obj . getCheckState() == StateConst . RCRD_NOTPASS) {
            $data["isPublic"] = 4;
            $data["recommendIsPay"] = -1;
            $data["recommendAmount"] = 0;
            $data["recommendAmountDesc"] = $old["recommendAmountDesc"] . ";公示再审核不通过,不予兑现;";
            $data["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . ";公示再审核不通过,不予兑现;";
            $desc = "（公示再审核通过）审核状态：" . LaState::getStateDesc($old["checkState"]) . "->" . LaState::getStateDesc($data["checkState"]) .
                    ";公示状态：<span class='label label-success'>公示中</span>-><span class='label label-primary'>待兑现</span>";
        } else {
            $data["isPublic"] = 4;
            $desc = "（公示再审核通过）审核状态：" . LaState::getStateDesc($old["checkState"]) . "->" . LaState::getStateDesc($data["checkState"]) .
                    ";公示状态：<span class='label label-success'>公示中</span>-><span class='label label-primary'>待兑现</span>";
        }
        $data["amount"] = $data["recommendAmount"];
        $data["isPay"] = $data["recommendIsPay"];
        $data["amountDesc"] = $data["recommendAmountDesc"];
        $data["judgmentDetails"] = $data["recommendJudgmentDetails"];
        //添加日志

        $newLog["id"] = getStringId();
        $newLog["type"] = ProjectState::LIVINGALLOWANCE;
        $newLog["mainId"] = $id;
        $newLog["active"] = 1;
        $newLog["state"] = $checkState;
        $newLog["step"] = 6;
        $newLog["stateChange"] = $desc;
        $newLog["description"] = $checkMsg;
        $newLog["createTime"] = date("Y-m-d H:i:s");
        $newLog["createUser"] = sprintf("%s(%s)", $this->user["account"], $this->user["companyName"]);
        Db::startTrans();
        try {
            Db::table("new_talent_checklog")->insert($newLog);
            Db::table("new_talent_checklog")->save($data);
            Db::commit();
            $response->code = 200;
            $response->msg = "审核成功";
            return json($response);
        } catch (\Exception $e) {
            Db::callback();
            $response->msg = $e->getMessage();
            return json($response);
        }
    }

    /**
     * 计算兑现额度
     * @param type $oldInfo
     * @return string
     */
    private function calculateAmount($oldInfo) {
        $return = [];
        /*         * 硕士研究生补贴 */
        if ($oldInfo["declareType"] == 1) {
            //硕士 master_living_allowance_ss_money
            $moneyInfo = DictApi::findByParentCodeAndCode("master_living_allowance_ss_money", $oldInfo["applyCount"]);
        } else {
            //博士 master_living_allowance_bs_money
            $moneyInfo = DictApi::findByParentCodeAndCode("master_living_allowance_bs_money", $oldInfo["applyCount"]);
        }

        $moneyStanard = $moneyInfo ? $moneyInfo["name"] : 0;
        $return["recommendAmount"] = $moneyStanard;
        $where = [];
        $where[] = ["cardType", "=", $oldInfo["cardType"]];
        $where[] = ["idCard", "=", $oldInfo["idCard"]];
        $where[] = ["year", "=", substr($oldInfo["year"], 0, 4)];
        $where[] = ["checkState", "=", 30];
        $where[] = ["publicState", ">=", 4];
        $talentAllowanceInfo = \app\common\model\TalentAllowance::where($where)->findOrEmpty()->toArray();
        if ($talentAllowanceInfo) {
            $balanceMoney = $oldInfo["amount"] - $talentAllowanceInfo["money"];
            if (round($balanceMoney, 2) == round(0, 2)) {
                $return["recommendAmountDesc"] = "当年度存在享受津补贴的记录,津补贴额度为：" . $talentAllowanceInfo["money"] . ",生活补贴额度为：" . $oldInfo["amount"] . ",根据就高原则生活补贴享受额度为0元,因此不予兑现;\n";
                $return["recommendAmount"] = 0;
                $return["recommendIsPay"] = -1;
            } else {
                $return["recommendAmountDesc"] = "当年度存在享受津补贴的记录,津补贴额度为：" . $talentAllowanceInfo["money"] . ",生活补贴额度为：" . $oldInfo["amount"] . ",需要补充生活补贴额度为：" . round($balanceMoney, 2) . "元,予以兑现;\n";
                $return["recommendAmount"] = $balanceMoney;
            }
        } else {
            $return["recommendAmountDesc"] = "当年度无享受津补贴的记录,可全额享受,予以兑现;\n";
        }
        return $return;
    }

    /**
     * 判断申报人是否满足兑现条件
     */
    private function vailIsCash($old) {
        /*         * 对申报人的信息进行校验是否满足补贴条件：
         * 第一年：合同需要在3年以上、缴纳社保3个月及以上
         * 第二、三年：社保和个税均在9个月以上
         * */
        if ($old["outMsg"] != "无") {
            $old["recommendJudgmentDetails"] = "征信情况:" . $old["outMsg"] . ",征信失信,不予兑现;";
            $old["recommendIsPay"] = -1;
            $old["recommendAmount"] = 0;
            return $old;
        }
        $old["recommendJudgmentDetails"] = "征信情况:" . $old["outMsg"] . ";";
        if ($old["introductionMethod"] == 2) {
            $backJJBusinessStartTime = strtotime("2021-11-16 00:00:00");
            $backJJBusinessEndTime = strtotime("2022-11-16 00:00:00");
            $backJJBusinessTime = strtotime($old["backJJBusinessTime"]);
            if ($backJJBusinessTime < $backJJBusinessStartTime || $backJJBusinessTime > $backJJBusinessEndTime) {
                $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "引进方式(其他):返晋创业时间不在2021-11-16至2022-11-15之间;\n";
                $old["recommendIsPay"] = -1;
                $old["recommendAmount"] = 0;
                return $old;
            }
            $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "引进方式(其他):返晋创业时间在2021-11-16至2022-11-15之间;\n";
        }
        if ($old["applyCount"] == 1) {
            $endTime = strtotime($old["endTime"]);
            $after3YearsTime = strtotime("+3 years -1 days {$old['startTime']}");
            if ($endTime < $after3YearsTime) {
                $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "首年申报:合同不足3年,不予兑现;";
                $old["recommendIsPay"] = -1;
                $old["recommendAmount"] = 0;
                return $old;
            }
            if (!$old["actualSocialSecurity"] || $this->countByDates($old["actualSocialSecurity"]) < 3) {
                $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "首年申报:社保缴纳时间不足3个月,不予兑现;";
                $old["recommendIsPay"] = -1;
                $old["recommendAmount"] = 0;
                return $old;
            }
            $old["recommendIsPay"] = 1;
            $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "首年申报:合同满足3年及以上,社保缴纳时间满足3个月及以上,予以兑现;\n";
            $_old = $this->calculateAmount($old);
            $old = array_merge($old, $_old);
        } else {
            if (!$old["actualSocialSecurity"] || $this->countByDates($old["actualSocialSecurity"]) < 9) {
                $old["recommendJudgmentDetails"] = $old["recommendAmountDesc"] . "非首年申报:社保缴纳时间不足9个月,不予兑现";
                $old["recommendIsPay"] = -1;
                $old["recommendAmount"] = 0;
                return $old;
            }
            if (!$old["actualTax"] || $this->countByDates($old["actualTax"]) < 9) {
                $old["recommendJudgmentDetails"] = $old["recommendJudgmentDetails"] . "非首年申报:个税缴纳时间不足9个月,不予兑现";
                $old["recommendIsPay"] = -1;
                $old["recommendAmount"] = 0;
                return $old;
            }
            $old["recommendIsPay"] = 1;
            $old["recommendJudgmentDetails"] = "非首年申报:社保缴纳时间满足9个月及以上,个税缴纳时间满足9个月及以上,予以兑现;\n";
            $_old = $this->calculateAmount($old);
            $old = array_merge($old, $_old);
        }
        return $old;
    }

    /**
     * 计算月份数
     * @param type $dates
     * @return type
     */
    private function countByDates($dates) {
        $dateArr = explode(",", $dates);
        $count = 0;
        for ($i = 0; $i < count($dateArr); $i++) {
            $date = $dateArr[$i];
            if ($date) {
                if (strpos($date, "-") !== false) {
                    $cDateArr = explode("-", $date);
                    $_date1 = date("Y-m-d", strtotime($cDateArr[0] . "01"));
                    $month1 = date("n", strtotime($cDateArr[0] . "01"));
                    $_date2 = date("Y-m-d", strtotime($cDateArr[1] . "01"));
                    $month2 = date("n", strtotime($cDateArr[1] . "01"));
                    // 方法返回为相差月份                    
                    $date1 = date_create($_date1);
                    $date2 = date_create($_date2);
                    $diff = date_diff($date1, $date2);
                    if ($diff->invert != 1) {
                        $count += $diff->y * 12 + ($month2 - $month1) + 1;
                    }
                } else {
                    $count++;
                }
            }
        }
        return $count;
    }

}