WokerTask/app/adminapi/controller/approve/ApproveController.php

<?php

namespace app\adminapi\controller\approve;

use app\adminapi\controller\BaseAdminController;
use app\adminapi\lists\approve\ApproveLists;
use app\common\enum\user\AccountLogEnum;
use app\common\logic\AccountLogLogic;
use app\common\logic\task\TaskLogic;
use app\common\model\Approve;
use app\common\model\Company;
use app\common\model\company\CompanyAccountLog;
use app\common\model\task\Task;
use app\common\model\task_scheduling_plan\TaskSchedulingPlan;
use app\common\model\task_template\TaskTemplate;
use app\common\model\user\User;
use app\common\model\user\UserAccountLog;
use think\facade\Db;

class ApproveController extends BaseAdminController
{
    public function lists()
    {
        return $this->dataLists(new ApproveLists());
    }

    public function lists2()
    {
        return $this->success('成功',(new ApproveLists())->lists2());
    }

    public function lists3()
    {
        return $this->success('成功',(new ApproveLists())->lists3());
    }
    public function audit()
    {
        try {
            $params = $this->request->param(); // id check_status remark amount
            $approve = Approve::find($params['id']);
            if (!$approve) {
                $this->fail('数据不存在');
            }

            Db::startTrans();
            // 拒绝通过 要让用户今天可以继续做任务
            if ($params['check_status'] == 3) {
                $this->refuse($params, $approve);
            }
            // 修改任务完成状态
            if ($params['check_status'] == 2) {
                if ($approve->type == Approve::APPROVE_TYPE_7) {
                    $taskTemplate = TaskTemplate::where(['id'=>$approve->business_id])->find();
                    // 提前完成
                    if ($taskTemplate['day_count'] < $taskTemplate['stage_day_one']) {
                        if (bccomp($params['amount'], 300000, 2) == -1) {
                            return $this->fail('该任务提前完成条件：销售总额必须达到30万元及以上');
                        } else {
                            // 提前完成标识
                            $extend = $taskTemplate['extend'];
                            $extend['early_finish'] = 1;
                            $taskTemplate->extend = json_encode($extend);
                            $taskTemplate->save();
                            $this->pass($approve, $params);
                        }
                    } else {
                        $this->pass($approve, $params);
                    }
                } else {
                    $this->pass($approve, $params);
                }

            }
            Db::commit();
            return $this->success('审核成功');
        } catch (\Exception $e) {
            Db::rollback();
            return $this->fail($e->getFile().$e->getLine().$e->getMessage());
        }
    }
    // 通过
    private function pass($approve, $params=[])
    {
        Db::startTrans();
        $approve->check_status = 2;
        $approve->update_time = time();
        $approve->save();
        // 任务
        $task = Task::find($approve['task_id']);
        if ($task['status'] == 2) {
            $task->status = 3;
            $task->save();
        }
        Db::commit();

        //  镇合伙人公司任务-数字农贸宣传业务、加工业务的建设和招商工作任务 结算
        if ($approve->type == Approve::APPROVE_TYPE_4) {
            $taskSchedulePlan = TaskSchedulingPlan::where('la_task_scheduling_plan.id', $task['scheduling_plan_id'])
                ->where('is_pay',0)
                ->with(['template_info'])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 16)
                ->find()
                ->toArray();
            TaskLogic::dealTaskMarketingDirector10($taskSchedulePlan, $approve);
        }

        if ($approve->type == Approve::APPROVE_TYPE_5) {
            $taskSchedulePlan = TaskSchedulingPlan::where('la_task_scheduling_plan.id', $task['scheduling_plan_id'])
                ->where('is_pay',0)
                ->with(['template_info'])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 17)
                ->find()
                ->toArray();
            TaskLogic::dealVillageTask6($taskSchedulePlan);
        }

        if ($approve->type == Approve::APPROVE_TYPE_6) {
            $taskSchedulePlan = TaskSchedulingPlan::where('la_task_scheduling_plan.id', $task['scheduling_plan_id'])
                ->where('is_pay',0)
                ->with(['template_info'])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 17)
                ->find()
                ->toArray();
            TaskLogic::dealVillageTask8($taskSchedulePlan);
        }
        if ($approve->type == Approve::APPROVE_TYPE_7) {
            // 需要手动输入销售总额
            $approve->amount = $params['amount'];
            $approve->save();
        }
        if ($approve->type == Approve::APPROVE_TYPE_8) {
            // 需要手动输入申请的政策补贴金额
            $approve->amount = $params['amount'];
            $approve->save();
            $taskSchedulePlan = TaskSchedulingPlan::where('la_task_scheduling_plan.id', $task['scheduling_plan_id'])
                ->where('is_pay',0)
                ->with(['template_info'])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 16)
                ->find()
                ->toArray();
            TaskLogic::masterTask7Settlement($taskSchedulePlan);
        }
        if ($approve->type == Approve::APPROVE_TYPE_9) {
            $taskSchedulePlan = TaskSchedulingPlan::where('la_task_scheduling_plan.id', $task['scheduling_plan_id'])
                ->where('is_pay',0)
                ->with(['template_info'])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 16)
                ->find()
                ->toArray();
            TaskLogic::masterTask8Settlement($taskSchedulePlan);
        }
    }

    // 拒绝
    private function refuse($params, $approve)
    {
        $approve->check_status = $params['check_status'];
        $approve->remark = $params['remark'];
        $approve->update_time = time();
        $approve->save();

        // 更新schedule_plan时间和task的时间为今天依旧可提交
        $schedulePlan = TaskSchedulingPlan::find(['tast_id' => $approve['task_id']]);
        if (empty($schedule_plan)) {
            return $this->fail('数据异常，任务计划不存在');
        }
        $time = strtotime(date('Y-m-d'));
        TaskSchedulingPlan::where(['id' => $schedulePlan['id']])->update([
            'start_time'=>$time,
            'end_time'=>$time + 86399
        ]);
        Task::where('id', $approve['task_id'])->update([
            'start_time'=>$time,
            'end_time'=>$time + 86399
        ]);
    }

    /**
     * 股金任务审批
     */
    public function shareholderMoneyTaskAudit()
    {
//        try {
            $params = $this->request->param(); // id check_status remark
            $approve = Approve::find($params['id']);
            if (!empty($approve)) {
                $this->fail('数据不存在');
            }
            // 拒绝通过 要让用户今天可以继续做任务
            if ($params['check_status'] == 3) {
                $this->refuse1($params, $approve);
            }
            if ($params['check_status'] == 2) {
                $this->pass1($approve, $params);
            }
//        } catch (\Exception $e) {
//            return $this->fail($e->getMessage());
//        }
    }

    private function refuse1($params, $approve)
    {
        $approve->check_status = $params['check_status'];
        $approve->remark = $params['remark'];
        $approve->update_time = time();
        $approve->save();
    }

    private function pass1($approve, $params)
    {
        Db::startTrans();

        // 审批
        $approve->check_status = 2;
        $approve->update_time = time();
        $approve->remark = $params['remark'];
        $approve->save();

        // 任务
        $task = Task::find($approve['task_id']);
        if ($task['status'] == 2) {
            $task->status = 3;
            $task->save();
        }
        Db::commit();
        // 小组服务公司股金上交 小组服务团队-入股任务
//        if ($approve->type == Approve::APPROVE_TYPE_10) {
//            // 小组服务公司
//            $subordinateCompany = Company::where(['id'=>$approve->department_id])->find();
//            // 村公司
//            $parentCompany = Company::where(['village'=>$subordinateCompany['village'], 'company_type'=>17])->find();
//        }
//
//        // 村联络员-督促小组服务团队入股任务
//        if ( $approve->type == Approve::APPROVE_TYPE_11) {
//            $parentCompany = Company::where(['id'=>$approve->department_id])->find();
//        }
//
//        // 村管理公司股金上交   村联络员任务-入股甲方公司
//        if ($approve->type == Approve::APPROVE_TYPE_12) {
//            // 村公司
//            $subordinateCompany = Company::where(['id'=>$approve->department_id])->find();
//            // 镇农科公司 负责区域包含有村公司的street码
//            $parentCompany = Db::query("select * from la_company where company_type=:company_type and FIND_IN_SET(:street,responsible_area)", ['company_type' => 41,'street'=>$subordinateCompany['street']], true)[0];
//        }
//
//        //  镇农科服务部长-督促小组服务团队入股村管理公司任务
//        if ($approve->type == Approve::APPROVE_TYPE_13) {
//            $parentCompany = Company::where(['id'=>$approve->department_id])->find(); //无法确定那个小组服务公司入股到哪个村管理公司
//        }
//
//        // 镇农科负责人任务-促成村联络员入股甲方
//        if ($approve->type == Approve::APPROVE_TYPE_14) {
//            // 镇农科公司
//            $parentCompany = Company::where(['id'=>$approve->department_id])->find();
//        }
//
//        $amount = $approve->amount; // 上交股金金额
//
//        $subordinateCompany->shareholder_money = $amount;
//        $subordinateCompany->save();
//
//        // 添加入股记录
//        $this->addConpanyAccountLog($parentCompany, $amount, $task);


        // 小组服务团队-入股任务结算
        if ($approve->type == Approve::APPROVE_TYPE_10) {
            $taskSchedulingPaln = TaskSchedulingPlan::where(['task_id' => $task->id])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 18)
                ->where('is_pay',0)
                ->with(['template_info'])
                ->select()
                ->toArray()[0];
            $taskInfo = $task->toArray();
            $company = Company::where(['id' => $taskInfo['company_id']])->find();
            $this->taskSettlement($taskInfo, $company, $taskSchedulingPaln);
        }
        // 村联络员-督促小组服务团队入股
        if ($approve->type == Approve::APPROVE_TYPE_11) {
            $taskSchedulingPaln = TaskSchedulingPlan::where(['task_id' => $task->id])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 17)
                ->where('is_pay',0)
                ->with(['template_info'])
                ->select()
                ->toArray()[0];
            TaskLogic::dealVillageTask4($taskSchedulingPaln, $approve);
        }
        // 村联络员-入股甲方公司
        if ($approve->type == Approve::APPROVE_TYPE_12) {
            $taskSchedulingPaln = TaskSchedulingPlan::where(['task_id' => $task->id])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 17)
                ->where('is_pay',0)
                ->with(['template_info'])
                ->select()
                ->toArray()[0];
            TaskLogic::dealVillageTask5($taskSchedulingPaln, $approve);
        }
        // 镇合伙人服务部长-督促小组服务团队入股村管理公司任务
        if ($approve->type == Approve::APPROVE_TYPE_13) {
            $taskSchedulingPaln = TaskSchedulingPlan::where(['task_id' => $task->id])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 16)
                ->where('is_pay',0)
                ->with(['template_info'])
                ->select()
                ->toArray()[0];
            TaskLogic::dealTownTask6($taskSchedulingPaln, $approve);
        }
        // 镇合伙人负责人-促成村联络员入股甲方
        if ($approve->type == Approve::APPROVE_TYPE_14) {
            $taskSchedulingPaln = TaskSchedulingPlan::where(['task_id' => $task->id])
                ->withJoin(['scheduling'], 'left')
                ->where('scheduling.company_type', 16)
                ->where('is_pay',0)
                ->with(['template_info'])
                ->select()
                ->toArray()[0];
            TaskLogic::masterTask6Settlement($taskSchedulingPaln, $approve);
        }
        return $this->success('成功');
    }

    private function addConpanyAccountLog($parentCompany, $amount, $task)
    {
        // 接收股金公司股金变更 + 公司股金增加记录
        $addAmount = bcadd($parentCompany['shareholder_money'], $amount, 2);
        Company::where('id', $parentCompany['id'])->save(['shareholder_money'=>$addAmount]);

        // 公司账户变动记录
        $company_log2 = [
            'sn' => generate_sn(UserAccountLog::class, 'sn', 20),
            'company_id' => $parentCompany['id'],
            'change_object' => CompanyAccountLog::SHAREHOLDER, // 变动对象 1余额 2股金
            'change_type' => CompanyAccountLog::TASK_INC_SHAREHOLDER_MONEY, //变动类型
            'action' => CompanyAccountLog::INC, //1-增加 2-减少
            'left_amount' => $addAmount, //变动后数量
            'change_amount' => $amount, //变动数量
            'extend' => json_encode(['task_id' => $task->id]),
            'status' => 1,
        ];
        CompanyAccountLog::create($company_log2);
    }

    public function taskSettlement($data, $company, $datas = [])
    {
        $proportion = 0;
        $remark =  '来自任务【' . $datas['template_info']['title'] . '】，';
        //总金额除以2等于不可提现账号金额和收益
        $master_money = bcdiv($data['money'], 2, 2);
        //收益的百分之25为负责人的收益其余为成员的平分收益
        $master_money_user = bcdiv($master_money, 2, 2);

        //成员数量
        $userAll = User::where('company_id', $data['company_id'])->where('admin_id', 0)->field('id,user_money')->select();
        $yser_all_count = count($userAll);
        $member_money_user = bcdiv($master_money_user, $yser_all_count, 2);

        //负责人
        $arr = [$company['user_id'], AccountLogEnum::UM_INC_TASK, AccountLogEnum::INC, $master_money_user, $datas['sn'], $remark . '获得收益' . $master_money_user . '元', ['company_id' => $data['company_id'], 'proportion' => $proportion], $data['status']];
        $this->master($arr);
        $arr_two = [$company['user_id'], AccountLogEnum::UM_INC_TASKUSER, AccountLogEnum::INC, $master_money_user, $datas['sn'], $remark. '获得账户余额' . $master_money_user . '元', ['company_id' => $data['company_id'], 'proportion' => $proportion], $data['status']];
        $this->Account($arr_two);

        //成员
        foreach ($userAll as $value) {
            $arr = [$value['id'], AccountLogEnum::UM_INC_TASK, AccountLogEnum::INC, $member_money_user, $datas['sn'], $remark . '获得收益' . $member_money_user . '元', ['company_id' => $data['company_id'], 'proportion' => $proportion], $data['status']];
            $this->member($arr);
            $arr_two = [$value['id'], AccountLogEnum::UM_INC_TASKUSER, AccountLogEnum::INC, $member_money_user, $datas['sn'], $remark. '获得账户余额' . $member_money_user . '元', ['company_id' => $data['company_id'], 'proportion' => $proportion], $data['status']];
            $this->Account($arr_two);
        }

        //公司
        $deposit_count = bcadd($company['deposit'], $master_money, 2);
        $this->AccountLog($data['company_id'], $deposit_count, $master_money);

        $company_money_count = bcadd($company['company_money'], $master_money, 2);
        $this->AccountLog($data['company_id'], $company_money_count, $master_money);
        Company::where('id', $data['company_id'])->update(['deposit' => Db::raw('deposit+' . $master_money), 'company_money' => Db::raw('company_money+' . $master_money)]);
    }

    public function AccountLog($companyId, $left_amount, $changeAmount, $change_object = 1, $change_type = 1, $action = 1)
    {
        $company_log = [
            'sn' => generate_sn(UserAccountLog::class, 'sn', 20),
            'company_id' => $companyId,
            'change_object' => $change_object, //变动对象
            'change_type' => $change_type, //变动类型
            'action' => $action, //1-增加 2-减少
            'left_amount' => $left_amount, //变动后数量
            'change_amount' => $changeAmount, //变动数量
            'status' => 1,
        ];
        CompanyAccountLog::create($company_log);
    }

    /**负责人的分润
     * @param $data
     */
    private function master($data)
    {
        User::where('id', $data[0])->update(['deposit'=>Db::raw('deposit+' . $data[3]),'user_money'=>Db::raw('user_money+' . $data[3])]);
        return AccountLogLogic::add($data[0], $data[1], $data[2], $data[3], $data[4], $data[5], $data[6], $data[7]);
    }

    /**成员分润
     * @param $data
     */
    private function member($data)
    {
        User::where('id', $data[0])->update(['deposit'=>Db::raw('deposit+' . $data[3]),'user_money'=>Db::raw('user_money+' . $data[3])]);
        return AccountLogLogic::add($data[0], $data[1], $data[2], $data[3], $data[4], $data[5], $data[6], $data[7]);
    }

    private function Account($data)
    {
        return AccountLogLogic::add($data[0], $data[1], $data[2], $data[3], $data[4], $data[5], $data[6], $data[7]);
    }
}