report/app/common/api/IntegralRecordApi.php

<?php

namespace app\common\api;

use app\common\api\DictApi;
use app\admin\model\Enterprise;
use think\facade\Db;
use app\common\model\IntegralRecord;
use app\common\state\IntegralState;

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

    public static function getOne($id) {
        $result = IntegralRecord::where("id", "=", $id)->find();
        $result["enterprise"] = EnterpriseApi::getOne($result["enterprise_id"]);
        $result["apply_year"] = BatchApi::getOne($result["batch_id"])["batch"];
        $result["enterprise"]["streetName"] = DictApi::findDictByCode($result["enterprise"]["street"])["name"];
        if ($result) {
            $result["items"] = $result->detail;
        }
        return $result;
    }

    public static function getList($params) {
        $order = $params["order"] ?: "desc";
        $offset = $params["offset"] ?: 0;
        $limit = $params["limit"] ?: 10;

        $where = [];
        $where[] = ["e.type", "=", session("user")["type"]];

        if (session("user")["usertype"] == 2) {
            $where[] = ["enterprise_id", "=", session("user")["uid"]];
        }
        $where[] = ["ir.delete", "=", 0];
        if ($params["apply_year"]) {
            $where[] = ["b.batch", "like", "%{$params['apply_year']}%"];
        }
        if ($params["name"]) {
            $where[] = ["ir.name", "like", "%{$params['name']}%"];
        }
        if ($params["card_number"]) {
            $where[] = ["ir.card_number", "like", "%{$params['card_number']}%"];
        }
        if ($params["phone"]) {
            $where[] = ["ir.phone", "like", "%{$params['phone']}%"];
        }
        if ($params["email"]) {
            $where[] = ["ir.email", "like", "%{$params['email']}%"];
        }
        if ($params["shareholder"]) {
            $where[] = ["ir.shareholder", "=", $params['shareholder']];
        }
        switch ($params["checkState"]) {
            case -1:
                $where[] = ["tl.state", "in", [IntegralState::VERIFY_FAIL, IntegralState::REVERIFY_FAIL, IntegralState::ZX_FAIL, IntegralState::ANNOUNCED_REVERIFY_FAIL, IntegralState::PUBLISH_FAIL]];
                break;
            case 1:
                $where[] = ["tl.state", "=", IntegralState::SAVE];
                break;
            case 2:
                $where[] = ["tl.state", "in", [IntegralState::VERIFY_REJECT, IntegralState::REVERIFY_REJECT]];
                break;
            case 3:
                $where[] = ["tl.state", "in", [IntegralState::SUBMIT, IntegralState::VERIFY_PASS]];
                break;
            case 4:
                $where[] = ["tl.state", ">=", IntegralState::REVERIFY_PASS];
                $where[] = ["tl.state", "not in", [IntegralState::REVERIFY_REJECT, IntegralState::REVERIFY_FAIL]];
                break;
            case 5:
                $where[] = ["tl.state", "=", IntegralState::SUCCESS];
                break;
        }
        $count = IntegralRecord::alias("ir")
                        ->leftJoin("sys_batch b", "b.id=ir.batch_id")
                        ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where createTime in (select max(createTime) from `new_talent_checklog` where `type`=20 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ir.id")
                        ->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")->where($where)->count();
        $list = IntegralRecord::alias("ir")
                ->leftJoin("sys_batch b", "b.id=ir.batch_id")
                ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where createTime in (select max(createTime) from `new_talent_checklog` where `type`=20 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ir.id")
                ->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")->where($where)->field("ir.*,b.batch as apply_year,tl.state,tl.new_state,if(ir.updateTime is not null,ir.updateTime,ir.createTime) as orderTime")
                ->limit($offset, $limit)
                ->order("orderTime " . $order)
                ->select();
        foreach ($list as $key => $item) {
            $tmp_items = [];
            foreach ($item["detail"] as $_item) {
                $integral_item_info = getCacheById("IntegralItem", $_item["item_id"]);
                $tmp_items[] = sprintf("%s（%s%s）", $integral_item_info["name"], $_item["amount"], $integral_item_info["unit"]);
            }
            $list[$key]["details"] = implode("，", $tmp_items);
            $list[$key]["type"] = session("user")["type"];
            $last_log = TalentLogApi::getLastLog($item["id"], \app\common\state\ProjectState::INTEGRAL);
            $list[$key]["real_state"] = $last_log["state"];
            $list[$key]["last_state"] = $last_log["last_state"];
        }
        return ["total" => $count, "rows" => $list];
    }

    public static function getPublicList($params) {
        $order = $params["order"];
        $offset = $params["offset"];
        $limit = $params["limit"];
        $where = [];
        $where[] = ["e.type", "=", session("user")["type"]];
        if ($params["name"]) {
            $where[] = ["ir.name", "like", "%" . $params["name"] . "%"];
        }
        switch ($params["checkState"]) {
            case 1:
                $where[] = ["ir.checkState", "in", [IntegralState::REVERIFY_PASS, IntegralState::ZX_PASS, IntegralState::ANNOUNCED, IntegralState::ANNOUNCED_REVERIFY_PASS, IntegralState::PUBLISH_PASS]];
                break;
            case 2:
                $where[] = ["ir.checkState", "in", [IntegralState::REVERIFY_FAIL, IntegralState::ZX_FAIL, IntegralState::ANNOUNCED_REVERIFY_FAIL, IntegralState::PUBLISH_FAIL]];
                break;
        }
        $type = $params["type"];
        switch ($type) {
            case 1:
            case 2:
                $where[] = ["ir.checkState", "=", IntegralState::REVERIFY_PASS];
                break;
            case 3:             //公示
            case 7:             //公示预览
                $where[] = ["ir.checkState", "=", IntegralState::ZX_PASS];
                break;
            case 4:             //公示通过
                $where[] = ["ir.checkState", "=", IntegralState::ANNOUNCED];
                break;
            case 5:
            case 8:             //公布预览
                $where[] = ["ir.checkState", "=", IntegralState::ANNOUNCED_REVERIFY_PASS];
                break;
            case 6:
                $where[] = ["ir.checkState", "=", IntegralState::PUBLISH_PASS];
                break;
        }
        $count = IntegralRecord::alias("ir")->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")->where($where)->count();
        $list = IntegralRecord::alias("ir")->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")
                        ->where($where)
                        ->limit($offset, $limit)
                        ->order("ir.createTime " . $order)->field("ir.*,e.name as enterpriseName,e.type as enterprise_type,enterpriseTag")->select()->toArray();
        foreach ($list as &$item) {
            $item["talent_type"] = $item["enterprise_type"] == 1 ? "晋江市现代产业体系人才" : "集成电路优秀人才";
        }unset($item);
        return ["total" => $count, "rows" => $list];
    }

    public static function getListByProcess($params) {
        $order = $params["order"] ?: "desc";
        $offset = $params["offset"] ?: 0;
        $limit = $params["limit"] ?: 10;
        $process = $params["process"] ?: 1;

        $where = [];
        $where[] = ["e.type", "=", session("user")["type"]];
        switch ($process) {
            case 1://初审阶段
                switch ($params["checkState"]) {
                    case 1://待审核
                        $where[] = ["ir.checkState", "=", IntegralState::SUBMIT];
                        $where[] = ["tl.state", "=", IntegralState::SUBMIT];
                        break;
                    case 2://驳回
                        $where[] = ["tl.new_state", "in", [IntegralState::SAVE]];
                        $where[] = ["tl.state", "in", [IntegralState::VERIFY_REJECT]];
                        break;
                    case 3:
                        //审核失败
                        $where[] = ["ir.checkState", "in", [IntegralState::VERIFY_FAIL]];
                        break;
                    default:
                        $where[] = ["tl.state", "in", [IntegralState::SUBMIT, IntegralState::VERIFY_REJECT, IntegralState::VERIFY_FAIL]];
                }
                break;
            case 2://复审阶段
                switch ($params["checkState"]) {
                    case 1://待审核
                        $where[] = ["tl.state", "=", IntegralState::VERIFY_PASS];
                        break;
                    case 3:
                        //审核失败
                        $where[] = ["tl.state", "in", [IntegralState::VERIFY_FAIL]];
                        break;
                    default:
                        $where[] = ["tl.state", "in", [IntegralState::VERIFY_PASS, IntegralState::REVERIFY_FAIL]];
                }
                break;
            case 3://复审后征信公示等状态
                if ($params["checkState"]) {
                    $where[] = ["ir.checkState", "=", $params["checkState"]];
                } else {
                    $where[] = ["ir.checkState", "in", [IntegralState::REVERIFY_PASS, IntegralState::ZX_PASS, IntegralState::ZX_FAIL, IntegralState::ANNOUNCED, IntegralState::ANNOUNCED_REVERIFY_PASS, IntegralState::ANNOUNCED_REVERIFY_FAIL, IntegralState::PUBLISH_PASS, IntegralState::PUBLISH_FAIL, IntegralState::SUCCESS]];
                }
                break;
        }
        $where[] = ["ir.delete", "=", 0];
        if ($params["apply_year"]) {
            $where[] = ["b.batch", "like", "%{$params['apply_year']}%"];
        }
        if ($params["name"]) {
            $where[] = ["ir.name", "like", "%{$params['name']}%"];
        }
        if ($params["card_number"]) {
            $where[] = ["ir.card_number", "like", "%{$params['card_number']}%"];
        }
        if ($params["phone"]) {
            $where[] = ["ir.phone", "like", "%{$params['phone']}%"];
        }
        if ($params["email"]) {
            $where[] = ["ir.email", "like", "%{$params['email']}%"];
        }
        if ($params["shareholder"]) {
            $where[] = ["ir.shareholder", "=", $params['shareholder']];
        }
        $count = IntegralRecord::alias("ir")->where($where)
                ->leftJoin("sys_batch b", "b.id=ir.batch_id")
                ->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")
                ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where createTime in (select max(createTime) from `new_talent_checklog` where `type`=20 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ir.id")
                ->count();
        $list = IntegralRecord::alias("ir")->where($where)
                        ->leftJoin("sys_batch b", "b.id=ir.batch_id")
                        ->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")
                        ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where createTime in (select max(createTime) from `new_talent_checklog` where `type`=20 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ir.id")
                        ->field("ir.*,e.name as enterpriseName,b.batch as apply_year,tl.state as real_state,tl.last_state,if(ir.updateTime is not null,ir.updateTime,ir.createTime) as orderTime")->limit($offset, $limit)->order("orderTime " . $order)->select();
        foreach ($list as $key => $item) {
            $tmp_items = [];
            foreach ($item["detail"] as $_item) {
                $integral_item_info = getCacheById("IntegralItem", $_item["item_id"]);
                $tmp_items[] = sprintf("%s（%s%s）", $integral_item_info["name"], $_item["amount"], $integral_item_info["unit"]);
            }
            $list[$key]["details"] = implode("；", $tmp_items);
            $list[$key]["type"] = session("user")["type"];
            //$last_log = TalentLogApi::getLastLog($item["id"], \app\common\state\ProjectState::INTEGRAL);
            //$list[$key]["real_state"] = $last_log["state"];
            //$list[$key]["last_state"] = $last_log["last_state"];
        }
        return ["total" => $count, "rows" => $list];
    }

    public static function checkIsEditable($id) {
        $info = self::getOne($id);
        if (!$info || !in_array($info["checkState"], [0, IntegralState::SAVE]))
            return false;
        return true;
    }

    static public function chkIsOwner($id, $uid) {
        $info = self::getOne($id);
        if ($info["enterprise_id"] != $uid)
            return null;
        return $info;
    }

    /**
     * 导出
     * @param type $process
     * @param type $params
     * @return type
     */
    public static function getExportDatas($process, $params) {
        $where[] = [];
        //特殊字段处理
        $fields = [];
        $fields[] = "ir.id";
        foreach ($params as $param) {
            if (!in_array($param, ["enterpriseName", "street", "checkMsg", "project", "year"])) {
                $fields[] = "ir." . $param;
            }
        }
        $fields[] = "e.name as enterpriseName";
        $fields[] = "e.street";
        $fields[] = "tl.description as checkMsg";
        $fields[] = "b.batch as year";
        if (in_array("card_type", $params)) {
            $cardTypes = DictApi::selectByParentCode("card_type");
        }
        if (in_array("street", $params)) {
            $streets = DictApi::selectByParentCode("street");
        }
        $sex = [1 => "男", 2 => "女"];

        $where = [];
        $where[] = ["e.type", "=", session("user")["type"]];
        switch ($process) {
            case 1:
                $where = "ir.checkState in (" . IntegralState::SUBMIT . "," . IntegralState::VERIFY_FAIL . ")";
                break;
            case 2:
                $where = "ir.checkState in (" . IntegralState::VERIFY_PASS . "," . IntegralState::REVERIFY_FAIL . ")";
                break;
            case 3:
                $where = "ir.checkState >= " . IntegralState::REVERIFY_PASS;
                break;
        }
        $list = IntegralRecord::alias("ir")
                        ->field($fields)
                        ->leftJoin("un_enterprise e", "e.id=ir.enterprise_id")
                        ->leftJoin("sys_batch b", "b.id=ir.batch_id")
                        ->leftJoin("(select description,mainId,last_state,new_state,state,createTime from new_talent_checklog where createTime in (select max(createTime) from `new_talent_checklog` where `type`=20 and `step` is null and active=1 and typeFileId is null group by mainId,`type`)) tl", "`tl`.`mainId`=ir.id")
                        //->leftJoin("new_talent_checklog tl", "tl.mainId=ti.id and tl.id=(select id from new_talent_checklog where mainId=ti.id and `step` is null and active=1 and typeFileId is null order by createTime desc limit 1)")
                        ->whereRaw($where)
                        ->select()->toArray();
        foreach ($list as &$item) {
            $item["card_type"] = $cardTypes[$item["card_type"]];
            $item["street"] = $streets[$item["street"]];
            $item["sex"] = $sex[$item["sex"]];
            $item["checkState"] = IntegralState::getStateName($item["checkState"]);
            $detail = \app\common\model\IntegralDetail::where("record_id", $item["id"])->select();
            $tmp_items = [];
            foreach ($detail as $_item) {
                $integral_item_info = getCacheById("IntegralItem", $_item["item_id"]);
                $tmp_items[] = sprintf("%s（%s%s）", $integral_item_info["name"], $_item["amount"], $integral_item_info["unit"]);
            }
            $item["project"] = implode("；", $tmp_items);
        }unset($item);
        return $list;
    }

    public static function getListByIds($ids) {
        $where[] = ["id", "in", $ids];
        return IntegralRecord::where($where)->select()->toArray();
    }

    /**
     * 计算积分
     * @param type $enterpriseId 企业id
     * @param type $cardType 证件类型
     * @param type $cardNumber 证件号码
     * @param type $itemId 标准id
     * @param type $amount 达成数额
     * @return \stdClass 完整积分记录对象
     */
    public static function calIntegral($enterprise_id, $cardType, $cardNumber, $itemId, $amount) {
        $returnObj = new \stdClass();
        $returnObj->amount = $amount;
        $item = getCacheById("IntegralItem", $itemId);
        $projectRemainderPoints = 0; //项目剩余总上限
        $itemRemainderPoints = 0; //标准剩余总上限
        $points = 0; //当前可获得积分
        if ($item) {
            $project = getCacheById("IntegralProject", $item["projectId"]);
            $projectRemainderPoints = $project["max"]; //初始化项目可获得剩余积分
            $itemRemainderPoints = $item["max"]; //初始化标准可获得剩余积分
            if ($project["limit"] == 1) {
                //项目下所有规则总上限
                $where = [];
                $where[] = ["r.enterprise_id", "=", $enterprise_id];
                $where[] = ["r.card_type", "=", $cardType];
                $where[] = ["r.card_number", "=", $cardNumber];
                $where[] = ["r.checkState", ">=", IntegralState::SUCCESS];
                $where[] = ["i.projectId", "=", $project["id"]];
                if ($project["yearly"] == 1) {
                    //年度重置只算当年度
                    $startTime = date("Y-01-01 00:00:00");
                    $endTime = date("Y-12-31 23:59:59");
                    $where[] = ["r.createTime", "between", [$startTime, $endTime]];
                    $returnObj->projectYearly = 1;
                }
                $totalPoints = Db::table("new_integral_detail")->alias("d")->leftJoin("new_integral_record r", "r.id=d.record_id")->leftJoin("new_integral_item i", "i.id=d.item_id")->where($where)->sum("d.point");
                $projectRemainderPoints -= $totalPoints;
                $returnObj->projectMaxPoints = $project["max"];
                $returnObj->projectRemainderPoints = $projectRemainderPoints;
            }
            if ($item["limit"] == 1) {
                //规则上限
                $where = [];
                $where[] = ["r.enterprise_id", "=", $enterprise_id];
                $where[] = ["r.card_type", "=", $cardType];
                $where[] = ["r.card_number", "=", $cardNumber];
                $where[] = ["r.checkState", ">=", IntegralState::SUCCESS];
                $where[] = ["d.item_id", "=", $itemId];
                if ($item["yearly"] == 1) {
                    //年度重置只算当年度
                    $startTime = date("Y-01-01 00:00:00");
                    $endTime = date("Y-12-31 23:59:59");
                    $where[] = ["r.createTime", "between", [$startTime, $endTime]];
                    $returnObj->itemYearly = 1;
                }
                $totalPoints = Db::table("new_integral_detail")->alias("d")->leftJoin("new_integral_record r", "r.id=d.record_id")->where($where)->sum("d.point");
                $itemRemainderPoints -= $totalPoints;
                $returnObj->itemMaxPoints = $item["max"];
                $returnObj->itemRemainderPoints = $itemRemainderPoints;
            }
            $where = [];
            $where[] = ["r.enterprise_id", "=", $enterprise_id];
            $where[] = ["r.card_type", "=", $cardType];
            $where[] = ["r.card_number", "=", $cardNumber];
            $where[] = ["r.checkState", ">=", IntegralState::SUCCESS];
            $where[] = ["d.item_id", "=", $itemId];
            $fstGain = Db::table("new_integral_detail")->alias("d")->leftJoin("new_integral_record r", "r.id=d.record_id")->where($where)->field("d.*")->order("createTime asc")->find();
            if ($item["stepNeedAmount"] && $item["stepGainPoints"]) {
                $returnObj->stepNeedAmount = $item["stepNeedAmount"];
                $returnObj->stepGainPoints = $item["stepGainPoints"];
                if ($fstGain) {
                    $returnObj->fstGainRecordId = $fstGain["record_id"];
                    $returnObj->fstGainDetailId = $fstGain["id"];
                    //有配置增量积分
                    if ($item["stepIsYear"] == 1) {
                        //较上年度增量
                        $where = [];
                        $where[] = ["r.enterprise_id", "=", $enterprise_id];
                        $where[] = ["r.card_type", "=", $cardType];
                        $where[] = ["r.card_number", "=", $cardNumber];
                        $where[] = ["r.checkState", ">=", IntegralState::SUCCESS];
                        $where[] = ["d.item_id", "=", $itemId];
                        $startTime = date("Y-m-d 00:00:00", strtotime("first day of last year"));
                        $endTime = date("Y-12-31 23:59:59", strtotime("last day of last year"));
                        $where[] = ["r.createTime", "between", [$startTime, $endTime]];
                        $lastYearTotalAmount = Db::table("new_integral_detail")->alias("d")->leftJoin("new_integral_record r", "r.id=d.record_id")->where($where)->sum("d.amount");
                        $newGainAmount = $amount - $lastYearTotalAmount;
                        $times = floor($newGainAmount / $item["stepNeedAmount"]);
                        $returnObj->stepIsYear = 1;
                        $returnObj->lastYearTotalAmount = $lastYearTotalAmount;
                        $returnObj->newGainAmount = $newGainAmount;
                    } else {
                        $times = floor($amount / $item["stepNeedAmount"]);
                        $returnObj->stepAmount = $amount;
                    }
                    $points = $item["stepGainPoints"] * $times;
                    $returnObj->times = $times;
                    $returnObj->points = $returnObj->stepPoints = $points;
                } else {
                    //首次
                    $returnObj->fstNeedAmount = $item["fstNeedAmount"];
                    $returnObj->fstGainPoints = $item["fstGainPoints"];
                    $returnObj->fstAmount = $amount >= $item["fstNeedAmount"] ? $item["fstNeedAmount"] : $amount;
                    $returnObj->fstPoints = $amount >= $item["fstNeedAmount"] ? $item["fstGainPoints"] : 0;
                    if ($item["stepIsYear"] != 1) {
                        //未设置较上年度增量时，首次还需计算增量部分
                        $stepAmount = $amount - $item["fstNeedAmount"];
                        if ($stepAmount > 0) {
                            $times = floor($stepAmount / $item["stepNeedAmount"]);
                            $returnObj->stepAmount = $stepAmount;
                            $returnObj->times = $times;
                            $returnObj->stepPoints = $item["stepGainPoints"] * $times;
                        }
                    } else {
                        $returnObj->stepIsYear = 1;
                    }
                    $returnObj->points = $returnObj->stepPoints ? $returnObj->fstPoints + $returnObj->stepPoints : $returnObj->fstPoints;
                }
            } else {
                //仅首次可得积分
                if ($fstGain) {
                    $returnObj->points = 0;
                    $returnObj->msg = "仅首次能获得积分";
                } else {
                    $returnObj->fstNeedAmount = $item["fstNeedAmount"];
                    $returnObj->fstGainPoints = $item["fstGainPoints"];
                    $returnObj->fstAmount = $amount >= $item["fstNeedAmount"] ? $item["fstNeedAmount"] : $amount;
                    $returnObj->points = $returnObj->fstPoints = $amount >= $item["fstNeedAmount"] ? $item["fstGainPoints"] : 0;
                }
            }
            $point1 = $project["limit"] == 1 ? ($returnObj->projectRemainderPoints > $returnObj->points ? $returnObj->points : $returnObj->projectRemainderPoints) : $returnObj->points;
            $point2 = $item["limit"] == 1 ? ($returnObj->itemRemainderPoints > $returnObj->points ? $returnObj->points : $returnObj->itemRemainderPoints) : $returnObj->points;
            $returnObj->theoretical = $returnObj->points; //理论值
            $returnObj->points = $point1 > $point2 ? $point2 : $point1; //实际值，当有限额时，会与理论值有偏差
        }
        return $returnObj;
    }

    public static function setPublic($mainId, $state, $msg, $batch = null) {
        $data["id"] = $mainId;
        $data["checkState"] = $state;
        switch ($state) {
            case IntegralState::ZX_PASS:
            case IntegralState::ZX_FAIL:
                $data["isPublic"] = 2;
                break;
            case IntegralState::ANNOUNCED:
                $data["isPublic"] = 3;
                $data["publicBatch"] = $batch;
                break;
            case IntegralState::ANNOUNCED_REVERIFY_PASS:
            case IntegralState::ANNOUNCED_REVERIFY_FAIL:
                $data["isPublic"] = 3;
                break;
            case IntegralState::PUBLISH_PASS:
                $data["getTime"] = $batch;
                $data["isPublic"] = 4;
                break;
            case IntegralState::PUBLISH_FAIL:
                $data["isPublic"] = 4;
                break;
        }
        if (IntegralRecord::update($data)) {
            TalentLogApi::write(\app\common\state\ProjectState::INTEGRAL, $mainId, $state, $msg, 1);
            return true;
        }
        return false;
    }

}