report/app/common/controller/Api.php

<?php

namespace app\common\controller;

use app\BaseController;
use app\common\middleware\Auth;
use think\facade\Db;
use app\enterprise\api\TalentApi;
use app\common\api\TalentLogApi;
use app\common\api\DictApi;
use app\common\model\CurrentcyFileType;
use app\common\model\TalentCommonFile;
use app\common\api\UploadApi;

/**
 * 需要权限的公共方法放这
 * Description of Tool
 *
 * @author sgq
 */
class Api extends BaseController {

    protected $middleware = [Auth::class];
    protected $user;

    public function __construct(\think\App $app) {
        parent::__construct($app);
        $this->user = session("user");
    }

    public function findIdentifyConditionByLevel() {
        $params = $this->request->param();
        $id = $params["id"];
        if ($this->user["usertype"] == 2) {
            $type = $this->user["type"];
        } else {
            $talentInfo = TalentApi::getOne($id);
            $enterprise = \app\common\model\Enterprise::findOrEmpty($talentInfo["enterprise_id"]);
            $type = $enterprise["type"];
        }
        $list = \app\common\api\TalentConditionApi::getList($params["level"], $type);
        return json($list, 200);
    }

    public function getCheckLog() {
        $params = $this->request->param();
        $mainId = $params["mainId"];
        $type = $params["type"];
        $list = TalentLogApi::getList($type, $mainId);
        $new_list = [];
        foreach ($list as $item) {
            $new_item["stepName"] = DictApi::getTalentInfoStepByState($item["state"]);
            if ($item["state"] == 13) {
                $new_item["stateName"] = '<span class="label label-success">审核不通过</span>';
            } else if (in_array($item["state"], [3, 7, 9, 11])) {
                $new_item["stateName"] = '<span class="label label-primary">审核通过</span>';
            } else if (in_array($item["state"], [4, 8, 10, 12])) {
                $new_item["stateName"] = '<span class="label label-danger">审核驳回</span>';
            } else {
                $new_item["stateName"] = '<span class="label label-success">待审核</span>';
            }
            if ($item["last_state"] && $item["state"]) {
                $new_item["stateChange"] = sprintf("%s -> %s", DictApi::getTalentInfoStateName($item["last_state"]), DictApi::getTalentInfoStateName($item["state"]));
            } else {
                $new_item["stateChange"] = "";
            }
            $new_item["description"] = $item["description"];
            $new_item["createUser"] = $item["createUser"];
            $new_item["createTime"] = $item["createTime"];
            $new_list[] = $new_item;
        }
        return json(["rows" => $new_list]);
    }

    public function findCommonFileType() {
        $param = $this->request->param();
        $order = $param["order"];
        $project = $param["project"];
        $type = $param["type"];
        $checkState = $param["checkState"];
        $talent_condition = $param["talent_condition"];
        if (in_array($checkState, [0, 1, 2])) {
            $where[] = ["step", "=", 1]; //只查找人才第一步所需文件
        } else {
            $where[] = ["isConditionFile", "=", 0]; //排除人才条件上传文件
        }
        $where[] = ["project", "=", $project];
        $where[] = ["type", "=", $type];
        if ($talent_condition) {
            $condition_info = Db::table("new_talent_condition")->findOrEmpty($talent_condition);
            if ($condition_info["bindFileTypes"]) {
                $whr[] = ["id", "in", $condition_info["bindFileTypes"]];
            }
        }
        if ($whr) {
            $rows = Db::table("new_common_filetype")->whereOr([$where, $whr])->order("sn " . $order)->select();
        } else {
            $rows = Db::table("new_common_filetype")->where($where)->order("sn " . $order)->select();
        }
        return json(["rows" => $rows]);
    }

    public function listTalentFile() {
        $param = $this->request->param();
        $mainId = $param["mainId"];
        $typeId = $param["fileTypeId"];
        $where = [["mainId", "=", $mainId], ["typeId", "=", $typeId]];
        $list = Db::table("new_talent_file")->where($where)->select()->toArray();
        foreach ($list as $key => $item) {
            $list[$key]["url"] = "/storage/" . $item["url"]; //获取系统配置无效，暂时这样
        }
        return json($list);
    }

    public function addTalentFile() {
        $backName = $this->request->param("backName");
        $fileId = $this->request->param("fileId");
        $mainId = $this->request->param("mainId");
        $fileTypeId = $this->request->param("fileTypeId");
        $index = $this->request->param("index");
        $type = $this->request->param("type");
        $upload = new \app\common\api\UploadApi();
        $file = $this->request->file("fileUrl");
        if (!TalentApi::checkIsEditable($mainId)) {
            $res = ["msg" => "当前状态不能修改附件", "obj" => $index];
            echo sprintf("<script>parent.%s(%s);</script>", $backName, json_encode($res));
            exit();
        }
        $filestd = $upload->uploadOne($file, "image", "talent_files");
        if ($fileId) {
            if (!$this->chkIsFileOwner($mainId, $type)) {
                $res = ["msg" => "删除失败", "obj" => $index];
                echo sprintf("<script>parent.%s(%s);</script>", $backName, json_encode($res));
                exit();
            }
            $old = Db::table("new_talent_file")->findOrEmpty($fileId);
            $old_filepath = "storage/" . $old["url"];
            if (file_exists($old_filepath))
                unlink($old_filepath);
            $data["id"] = $fileId;
        }
        $data["mainId"] = $mainId;
        $data["type"] = $type;
        $data["typeId"] = $fileTypeId;
        $data["orignName"] = $file->getOriginalName();
        $data["url"] = $filestd->filepath;
        $data["sn"] = $index;
        $data["createTime"] = time();
        Db::table("new_talent_file")->save($data);
        TalentLogApi::write($type, $mainId, 0, sprintf("添加附件，附件名为：%s", $data["orignName"]), 1, $fileTypeId);
        $res = ["code" => 200, "msg" => "上传附件成功", "obj" => $index, "info" => $url];
        echo sprintf("<script>parent.%s(%s);</script>", $backName, json_encode($res));
    }

    public function deleteFile() {
        $param = $this->request->param();
        $where = [["id", "=", $param["id"]]];
        $file = Db::table("new_talent_file")->where($where)->findOrEmpty();

        if (!TalentApi::checkIsEditable($file["mainId"]))
            return json(["msg" => "当前状态不能删除"]);
        if ($this->chkIsFileOwner($file["mainId"], $file["type"])) {
            $filepath = "storage/" . $file["url"];
            if (file_exists($filepath)) {
                unlink($filepath);
            }
            Db::table("new_talent_file")->delete($file["id"]);
            TalentLogApi::write($file["type"], $file["mainId"], 0, sprintf("删除附件，附件名为：%s", $file["orignName"]), 1, $file["typeId"]);
            return json(["code" => 200, "msg" => "删除成功"]);
        }
        return json(["msg" => "不能删除"]);
    }

    /**
     * 下载文件
     */
    public function downloadFile() {
        $param = $this->request->param();
        $type = $param["type"];
        $id = $param["id"];
        $where = [];
        $where[] = ["id", "=", $id];
        $where[] = ["type", "=", $type];
        $fileinfo = Db::table("new_talent_file")->where($where)->findOrEmpty();
        $filename = $fileinfo["orignName"];
        $filepath = "storage/" . $fileinfo["url"];     // 下载文件名
        if (!file_exists($filepath)) {
            header('HTTP/1.1 404 NOT FOUND');
        } else {
            $file = fopen($filepath, "rb");

            Header("Content-type: application/octet-stream");
            Header("Accept-Ranges: bytes");
            Header("Accept-Length: " . filesize($filepath));
            Header("Content-Disposition: attachment; filename=" . $filename);

            echo fread($file, filesize($filepath));
            fclose($file);

            exit();
        }
    }

    /**
     * 打包下载人才申请附件
     */
    public function downloadZip() {
        $param = $this->request->param();
        $type = $param["type"];
        $id = $param["id"];
        $where = [];
        $where[] = ["mainId", "=", $id];
        $where[] = ["type", "=", $type];
        $files = Db::table("new_talent_file")->where($where)->select()->toArray();
        if (!$files)
            die("没有附件不能打包下载");

        $talent_info = \app\enterprise\model\Talent::findOrEmpty($id);
        $enterprise_info = \app\common\model\Enterprise::findOrEmpty($talent_info["enterprise_id"]);
        $zip_filename = sprintf("%s(%s)人才申报材料.zip", $talent_info["name"], $enterprise_info["name"]);

        $tmp_path = "storage/temp/";
        $tmp_file_path = $tmp_path . $zip_filename;
        if (!file_exists($tmp_path)) {
            mkdir($tmp_path);
        }
        $zip = new \ZipArchive();
        if (!$zip->open($tmp_file_path, \ZipArchive::CREATE | \ZipArchive::OVERWRITE)) {
            header('HTTP/1.1 404 NOT FOUND');
        }
        foreach ($files as $file) {
            $filepath = "storage/" . $file["url"];
            $filename = $file["orignName"];
            $zip->addFile($filepath, $filename);
        }
        $zip->close();
        if (file_exists($tmp_file_path)) {
            header("Cache-Control: public");
            header("Content-Description: File Transfer");
            header('Content-disposition: attachment; filename=' . $zip_filename); //文件名
            header("Content-Type: application/octet-stream;charset=utf-8"); //zip格式的
            header("Content-Transfer-Encoding: binary"); //告诉浏览器，这是二进制文件
            header('Content-Length: ' . filesize($tmp_file_path)); //告诉浏览器，文件大小
            @readfile($tmp_file_path);
        }
        //删除临时文件
        @unlink($tmp_file_path);
    }

    private function chkIsFileOwner($mainId, $type) {
        switch ($type) {
            case 1:
                if ($this->user["usertype"] == 2) {
                    $user_id = $this->user["uid"];
                    $talent_info = Db::table("new_talent_info")->findOrEmpty($mainId);
                    if ($user_id == $talent_info["enterprise_id"])
                        return true;
                }
                break;
        }
        return false;
    }

    public function getCompanyKvs() {
        $companys = \app\common\model\Company::field("name,id")->select();
        return json($companys);
    }

    /**
     * 通过人才类别查找人才认定第二步骤支持的所有文件类型
     * 默认人才认定第二步骤，当前只有人才认定分了两步，所以此方法目前默认参数高度匹配人才认定第二阶段附件的查找
     */
    public function getConditionFileTypesByType() {
        $params = $this->request->param();
        $type = $params["type"]; //人才类型不默认，需要传
        $declare_type = $params["project"] ?: 1; //默认人才认定
        $active = $params["active"] ?: 1; //默认查找启用的附件
        $where[] = ["type", "=", $type];
        $where[] = ["project", "=", $declare_type];
        $where[] = ["active", "=", $active];
        $where[] = ["isConditionFile", "=", 1];
        $list = Db::table("new_common_filetype")->where($where)->order("sn " . $order)->select()->toArray();
        return json($list);
    }

    public function listCurrencyFileType(){
        $where = [
            'type' => $this->request['type'],
            'active' => 1
        ];
        $rows = CurrentcyFileType::where($where)->select();
        return json(["rows" => $rows, 'total' => count($rows)]);
    }

    public function listTalentCommonFile(){
        $where = [];
        if(\StrUtil::isNotEmpAndNull($this->request['mainId'])){
            $where[] = ['mainId','=',$this->request['mainId']];
        }
        if(\StrUtil::isNotEmpAndNull($this->request['typeId'])){
            $where[] = ['typeId','=',$this->request['typeId']];
        }
        $res = TalentCommonFile::where($where)->order('sn')->select();
        if($res){
            foreach ($res as $k => &$v){
                $v['url'] = "/storage/" . $v['url'];
            }
        }
        return json($res);
    }

    public function addTalentCommonFile(){
        $backName = \StrUtil::getRequestDecodeParam($this->request,'backName');
        $id = \StrUtil::getRequestDecodeParam($this->request, "fileId");
        $mainId = \StrUtil::getRequestDecodeParam($this->request, "mainId");
        $typeId = \StrUtil::getRequestDecodeParam($this->request, "typeId");
        $index = \StrUtil::getRequestDecodeParam($this->request, "index");

        if($backName == "EpChangeEdit.callBack"){
            $type = 1;
            $error = "文件格式不正确，只能上传图片";
        } else {
            $type = 4;
            $error = "文件格式不正确，只能上传pdf和图片";
        }
        $uploadapi = new UploadApi();
        $file_check_res = $uploadapi->uploadOne($this->request->file('fileUrl'),'system');
        if($file_check_res->code == 500){
            return \StrUtil::back($file_check_res,"Register.epCallBack");
        }

        $file_data = [
            'id' => getStringId(),
            'mainId' => $mainId,
            'typeId' => $typeId,
            'orignName' => $this->request->file('fileUrl')->getOriginalName(),
            'url' => $file_check_res->filepath
        ];

        if(\StrUtil::isEmpOrNull($id)){
            $tc = TalentCommonFile::where('mainId',$mainId)->where('typeId',$typeId)->order('sn','desc')->findOrEmpty();
            if($tc){
                $file_data['sn'] = $tc['sn'] + 1;
            }else{
                $file_data['sn'] = 1;
            }
            $file_data['createTime'] = date("y-m-d H:i:s");
            TalentCommonFile::create($file_data);
            $response_object = new \StdClass();
            $response_object->code = 200;
            $response_object->msg = "附件上传成功!";
            $response_object->obj = $index;
            return \StrUtil::back($response_object, $backName);
        } else {
            $tf = TalentCommonFile::findOrEmpty($id);
            $tf->originalName = $file_data['orignName'];
            $tf->updateTime = date("y-m-d H:i:s");
            $tf->url = $file_check_res->filepath;
            $tf->save();
            $response_object = new \StdClass();
            $response_object->code = 200;
            $response_object->msg = "附件修改成功!";
            $response_object->obj = $index;
            return \StrUtil::back($response_object, $backName);
        }
    }


}