report/app/admin/controller/Policy.php

<?php

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

namespace app\admin\controller;

use app\admin\common\AdminController;
use think\facade\Db;

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

    protected $companyId;

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

    public function index() {
        $company = \app\common\api\CompanyApi::getOne($this->companyId);
        $tmps = Db::table("new_policy_tmp")->where("companyId", "=", $this->companyId)->select()->toArray();
        $policyIds = array_column($tmps, "policyId");
        $policys = Db::table("new_policy")->order("level asc")->select()->toArray();
        foreach ($policys as $key => $policy) {
            if (in_array($policy["id"], $policyIds)) {
                $policys[$key]["checked"] = true;
            }
        }
        return view("", ["company" => $company, "policys" => $policys]);
    }

    public function checked() {
        if ($this->request->isPost()) {
            $policyId = $this->request->param("id");
            $uniqueId = sprintf("%s_%s", $policyId, $this->companyId);
            $checked = $this->request->param("checked") ?: 1;
            $lockFileName = sprintf("storage/policy_logs/%s.lock", $uniqueId);
            if (!file_exists("storage/policy_logs")) {
                mkdir("storage/policy_logs");
            }
            $lockFile = fopen($lockFileName, "a");
            if (flock($lockFile, LOCK_EX | LOCK_NB)) {//文件锁（独占）
                try {
                    $record = Db::table("new_policy_tmp")->where("id", "=", $uniqueId)->findOrEmpty();
                    if ($checked == 1) {
                        //需要本单位审核
                        if ($record) {
                            $log = sprintf("[%s][account:%s][ERR]Already checked!", date("Y-m-d H:i:s"), $this->user["account"]);
                            fwrite($lockFile, $log . "\n");
                            return json(["msg" => "已经添加审核，不需要重复添加"]);
                        } else {
                            $data["id"] = $uniqueId;
                            $data["companyId"] = $this->companyId;
                            $data["policyId"] = $policyId;
                            $data["createUser"] = $this->user["uid"];
                            $data["createTime"] = date("Y-m-d H:i:s");
                            if (Db::table("new_policy_tmp")->insert($data)) {
                                $log = sprintf("[%s][account:%s][INFO]Checked!", date("Y-m-d H:i:s"), $this->user["account"]);
                                fwrite($lockFile, $log . "\n");
                                return json(["msg" => "添加审核成功", "code" => 200]);
                            } else {
                                $log = sprintf("[%s][account:%s][ERR]Check failure!", date("Y-m-d H:i:s"), $this->user["account"]);
                                fwrite($lockFile, $log . "\n");
                                return json(["msg" => "添加审核失败"]);
                            }
                        }
                    } else {
                        //取消本单位审核
                        if ($record) {
                            if (Db::table("new_policy_tmp")->delete($uniqueId)) {
                                $log = sprintf("[%s][account:%s][INFO]Deleted!", date("Y-m-d H:i:s"), $this->user["account"]);
                                fwrite($lockFile, $log . "\n");
                                return json(["msg" => "取消审核成功", "code" => 200]);
                            } else {
                                $log = sprintf("[%s][account:%s][ERR]Delete failure!", date("Y-m-d H:i:s"), $this->user["account"]);
                                fwrite($lockFile, $log . "\n");
                                return json(["msg" => "取消审核失败"]);
                            }
                        } else {
                            $log = sprintf("[%s][account:%s][ERR]Already deleted!", date("Y-m-d H:i:s"), $this->user["account"]);
                            fwrite($lockFile, $log . "\n");
                            return json(["msg" => "已经取消审核，不需要重复取消"]);
                        }
                    }
                } catch (\Exception $e) {
                    $log = sprintf("[%s][account:%s][ERR]%s", date("Y-m-d H:i:s"), $this->user["account"], $e->getMessage());
                    fwrite($lockFile, $log . "\n");
                    return json(["msg" => $e->getMessage()]);
                } finally {
                    flock($lockFile, LOCK_UN);
                }
            } else {
                return json(["msg" => "已经有同单位的人员在操作同一条记录，请稍候片刻"]);
            }
        }
    }

}