ball/app/adminapi/logic/master_worker/MasterWorkerLogic.php

<?php
// +----------------------------------------------------------------------
// | likeadmin快速开发前后端分离管理后台（PHP版）
// +----------------------------------------------------------------------
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
// | 开源版本可自由商用，可去除界面版权logo
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
// | github下载：https://github.com/likeshop-github/likeadmin
// | 访问官网：https://www.likeadmin.cn
// | likeadmin团队 版权所有 拥有最终解释权
// +----------------------------------------------------------------------
// | author: likeadminTeam
// +----------------------------------------------------------------------

namespace app\adminapi\logic\master_worker;


use app\common\model\master_worker\MasterWorker;
use app\common\logic\BaseLogic;
use app\common\model\master_worker\MasterWorkerScore;
use app\common\model\master_worker\MasterWorkerRetentionMoneyLog;
use app\common\model\master_worker_credential\MasterWorkerCredentialImages;
use app\common\model\service_area\ServiceArea;
use app\common\model\master_worker\MasterWorkerStop;
use app\common\model\master_worker\MasterWorkerRetentionMoneyOrder;
use app\common\model\dict\DictConfig;
use think\db\Query;
use think\facade\Config;
use think\facade\Db;


/**
 * MasterWorker逻辑
 * Class MasterWorkerLogic
 * @package app\adminapi\logic\master_worker
 */
class MasterWorkerLogic extends BaseLogic
{


    /**
     * @notes 添加
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2024/07/10 18:17
     */
    public static function add(array $params): bool
    {
        Db::startTrans();
        try {
            $service_area_id = ServiceArea::serviceAreaId(['lon' => $params['lon'], 'lat' => $params['lat']]);
            if (!empty($params['lon']) && !empty($params['lat']) && !$service_area_id) {
                self::setError('您所选的位置已超出服务区域！');
                return false;
            }
            $data = [
                'sn' => $params['sn'],
                'avatar' => $params['avatar'],
                'real_avatar' => $params['real_avatar'],
                'real_name' => $params['real_name'],
                'nickname' => $params['nickname'],
                'account' => $params['account'],
                'password' => $params['password'],
                'mobile' => $params['mobile'],
                'sex' => $params['sex'],
                'channel' => $params['channel'],
                'is_disable' => $params['is_disable'],
                'login_ip' => $params['login_ip'],
                'login_time' => $params['login_time'],
                'is_new_user' => $params['is_new_user'],
                'estimate_money' => $params['estimate_money'],
                'user_money' => $params['user_money'],
                'earnest_money' => $params['earnest_money'],
                'exp' => $params['exp'],
                'lon' => $params['lon'],
                'lat' => $params['lat'],
                'distance' => $params['distance'],
                'province' => $params['province'],
                'city' => $params['city'],
                'service_area_id' => $service_area_id,
                'area_name' => $params['area_name'],
                'cooperation' => $params['cooperation']??0,
                'time_period' => $params['time_period']??'',
                'work_status' => $params['work_status']??0,
                'recruiting_behalf' => $params['recruiting_behalf']??'',
                'settlement_type' => $params['settlement_type']??2,
                'labels' => (isset($params['labels']) && $params['labels'])?implode(',',$params['labels']):'',
                'remark' => $params['remark']??'',
                'is_wecall' => $params['is_wecall']??0,
            ];
            if (isset($params['type']) && $params['type'] == 2) {
                $data['type'] = 2;
                $data['promotion_level'] = 6;   //A1级工程师
                $data['title_promotion'] = 1;   //普通工程师
            }
            $masterWorker = MasterWorker::create($data);
            
            //添加工程师汇总评分数据
            MasterWorkerScore::create([
                'worker_id' => $masterWorker->id
            ]);

            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 编辑
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2024/07/10 18:17
     */
    public static function edit(array $params): bool
    {
        if($params['category_ids']){
            foreach ($params['category_ids'] as $val){
                is_array($val)?($ids[] = end($val)):($ids[] = $val);
            }
            //$params['category_ids'] = ["goods_category_ids"=>$params['category_ids'],"ids"=>$ids];
            $params['category_ids'] = implode(',',$ids);
        }
        /*if($params['tenant_id']){
            // 绑定租户 绑定团队-组员
            $team_id = MasterWorkerTeam::where('tenant_id',$params['tenant_id'])->value('id');
        }*/
        Db::startTrans();
        try {
            $detail = MasterWorker::where('id', $params['id'])->field('id,lon,lat,address,service_area_id,type')->findOrEmpty()->toArray();
            $address = $params['address']??'';
            if ($detail['address'] != $address && !empty($address)) {
                $lon_lat = get_address_lat_lng($address);
                $params['lon'] = $lon_lat['lon'];
                $params['lat'] = $lon_lat['lat'];
                $service_area_id = ServiceArea::serviceAreaId(['lon' => $params['lon'], 'lat' => $params['lat']]);
                if (!empty($params['lon']) && !empty($params['lat']) && !$service_area_id) {
                    self::setError('您所选的位置已超出服务区域！');
                    return false;
                }
            } else {
                $params['lon'] = $detail['lon'];
                $params['lat'] = $detail['lat'];
                $service_area_id = $detail['service_area_id'];
                if (empty($address)) {
                    $address = getAddressByLatLng($params['lon'], $params['lat']);
                }
            }
            $update = [
                'sn' => $params['sn'],
                'avatar' => $params['avatar'],
                'real_avatar' => $params['real_avatar'],
                'real_name' => $params['real_name'],
                'nickname' => $params['nickname'],
                'account' => $params['account'],
                'password' => $params['password'],
                'mobile' => $params['mobile'],
                'sex' => $params['sex'],
                'channel' => $params['channel'],
                'is_disable' => $params['is_disable'],
                'login_ip' => $params['login_ip'],
                'login_time' => $params['login_time'],
                'is_new_user' => $params['is_new_user'],
                'estimate_money' => $params['estimate_money'],
                'user_money' => $params['user_money'],
                'exp' => $params['exp'],
                'address' => $address,
                'lon' => $params['lon'],
                'lat' => $params['lat'],
                'distance' => $params['distance'],
                'province' => $params['province'],
                'city' => $params['city'],
                'service_area_id' => $service_area_id,
                'area_name' => $params['area_name'],
                'earnest_money' => $params['earnest_money'],
                'earnest_money_usable' => $params['earnest_money_usable'],
                'earnest_money_freeze' => $params['earnest_money_freeze'],
                'installment_ratio' => $params['installment_ratio'],
                'retention_pay_status' => $params['retention_pay_status'],
                'retention_money_status' => $params['retention_money_status'],
                'category_ids' => $params['category_ids']??'',
                'cooperation' => $params['cooperation']??0,
                'time_period' => $params['time_period']?implode(',',$params['time_period']):'',
                'work_status' => $params['work_status']??0,
                'recruiting_behalf' => $params['recruiting_behalf']??'',
                'settlement_type' => $params['settlement_type']??2,
                'labels' => (isset($params['labels']) && $params['labels'])?implode(',',$params['labels']):'',
                'remark' => $params['remark']??'',
                'is_wecall' => $params['is_wecall']??0,
                'type'  => $params['type']??1,
                'title_promotion'  => $params['title_promotion']??0,
            ];
            
            if (isset($params['type']) && $detail['type'] != $params['type']) {
                if ($params['type'] == 2) {
                    $update['promotion_level'] = 6;   //A1级工程师
                    $update['title_promotion'] = 1;   //普通工程师
                } else {
                    $update['promotion_level'] = 0;   
                    $update['title_promotion'] = 0;   
                }
            }

            //'tenant_id' => $params['tenant_id']??0,
            MasterWorker::where('id', $params['id'])->update($update);
            
            if (is_numeric($params['score']['weight_score'])) {
                $exists = MasterWorkerScore::where('worker_id', $params['id'])->value('id');
                if ($exists) {
                    MasterWorkerScore::where('worker_id',$params['id'])->update(['weight_score' => $params['score']['weight_score']]);
                } else {
                    MasterWorkerScore::create([
                        'worker_id' => $params['id'],
                    'weight_score' => $params['score']['weight_score'],
                    ]);
                }
            }

            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 删除
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2024/07/10 18:17
     */
    public static function delete(array $params): bool
    {
        return MasterWorker::destroy($params['id']);
    }


    /**
     * @notes 获取详情
     * @param $params
     * @return array
     * @author likeadmin
     * @date 2024/07/10 18:17
     */
    public static function detail($params): array
    {
        $info = MasterWorker::with(['workerInfo'=>function(Query $query){
            $query->field('worker_id,real_name,id_card,id_card_front_img,id_card_opposite_img,mobile,address');
        },'workerRegister'=>function(Query $query){
            $query->field('id as worker_register_id,worker_id,maintain_exp_type,other_exp_type,city,vehicle_type,name,age,mobile')->append(['maintain_exp_type_text','other_exp_type_text','vehicle_type_text','city_text']);
        }])
            ->append(['time_period'])
            ->findOrEmpty($params['id'])->toArray();
        if(!empty($info['category_ids'])){
            $info['category_ids'] = explode(',',$info['category_ids']);
            $info['category_ids'] = array_map('intval', $info['category_ids']);
        }
        $info['is_up_retention_pay'] = 0;
        if(MasterWorkerRetentionMoneyLog::where(['worker_id' => $params['id'],'action' => 1])->count('id') > 0){
            $info['is_up_retention_pay'] = 1;
        }
        $info['score'] = MasterWorkerScore::where(['worker_id' => $params['id']])->field('comprehensive_score,weight_score')->findOrEmpty()->toArray();
        $images = MasterWorkerCredentialImages::where(['worker_register_id' => $info['workerRegister']['worker_register_id']??-1])->select()->toArray();
        $info['credential_info'] = $images;
        return $info;
    }

    /**
     * 获取加盐密码
     * @param $params
     * @return false|string
     */
    public static function saltToPassword($params){
        try{
            $passwordSalt = Config::get('project.unique_identification');
            $password = create_password($params['password'], $passwordSalt);
            return ['password' => $password];
        } catch (\Exception $e){
            self::setError($e->getMessage());
            return false;
        }

    }

    /**
     * 获取所有工程师选项列表
     * @param $params
     * @return array
     */
    public static function getAllWorkers($params){
        try{
            return MasterWorker::where(['is_disable'=>0])->column('id,id as value,worker_number as name,real_name,account,mobile');
        } catch (\Exception $e){
            self::setError($e->getMessage());
            return [];
        }

    }

    /**
     * 长期合作工程师停单
     * @param $params
     * @return bool
     */
    public static function stop($params, $userInfo){
        try{
            Db::startTrans();
            $worker = MasterWorker::where(['id' => $params['id']])->findOrEmpty();
            if($worker->isEmpty()){
                self::setError('工程师不存在');
                return false;
            }
            $start_time = strtotime($params['start_time']. " 00:00:00");
            $end_time = strtotime($params['end_time']. " 23:59:59");
            //校验停单日期是否重复
            $exists = MasterWorkerStop::where(['worker_id' => $params['id'] ])
                        ->where(function($query) use ($start_time, $end_time) {
                            $query->where('start_time', 'between', [$start_time, $end_time])
                            ->whereOr('end_time', 'between', [$start_time, $end_time]);
                        })
                        ->count('id');
            if($exists > 0){
                self::setError('该日期已存在停单记录');
                return false;
            }
            if ($params['start_time'] == date('Y-m-d')) {
                $worker->accept_order_status = 0;
            }
            $worker->save();

            MasterWorkerStop::create([
                'worker_id' => $params['id'],
                'start_time' => $start_time,
                'end_time' => $end_time,
                'admin_id' => $userInfo['admin_id'],
            ]);
            Db::commit();
            return true;

        } catch (\Exception $e){
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }

    /** 
     * 设置工程师备注
     * @param $params
     * @return false|string
     */
    public static function setRemark($params){
        try{
            MasterWorker::where('id', $params['id'])->update(['remark' => $params['remark']]);
            return true;
        } catch (\Exception $e){
            self::setError($e->getMessage());
            return false;
        }
    }

    /** 
     * 设置工程师特殊技能
     * @param $params
     * @return false|string
     */
    public static function setSkill($params){
        try{
            MasterWorker::where('id', $params['id'])->update(['skill' => $params['skill']]);
            return true;
        } catch (\Exception $e){
            self::setError($e->getMessage());
            return false;
        }
    }

    /**
     * 工程师质保金缴费二维码
     * @param $params
     * @return array|false|string
     * @throws \Exception
     */
    public static function retentionMoneyOrder($params, $is_reg = 0){
        // 创建分享单Id
        $is_share = true;

        //系统配置的质保金缴费金额
        if ($is_reg == 1 && empty($params['amount']) ) {
            $content = DictConfig::where('value', 'retention_money')->value('content');
            $content = json_decode($content,true);
            $order_amount = $content[0]['value'];
        } else {
            $order_amount = (float)$params['amount'] ?? 0;
        }
        $order = $is_reg == 0 ? 'desc' : 'asc';
        $order = MasterWorkerRetentionMoneyOrder::where(['worker_id'=>$params['worker_id']])->order('id',$order)->findOrEmpty();

        if($order->isEmpty() || ($is_reg == 0 && $order->order_status === 2)){
            $sn = generate_sn(MasterWorkerRetentionMoneyOrder::class, 'sn');
            $order = MasterWorkerRetentionMoneyOrder::create(['sn' => $sn, 'order_status'=>1,'worker_id'=>$params['worker_id'],'order_amount'=>$order_amount]);
        }else{
            if($order->order_status === 1 && empty($order->openid) && $order_amount > 0){ // 可以改价
                $order->order_amount = $order_amount;
                $order->save();
                $is_share = $order->order_amount > 0 ? true : false;
            }else{ // 已结束 - 不用分享二维码
                if((float)$order->order_amount>0 && empty($params['amount'])) $is_share = true;
                else $is_share = false;
            }
        }
        $masterWorker = MasterWorker::where(['id' => $params['worker_id']])->field('id,real_name,mobile')->findOrEmpty()->toArray();
        $order->real_name = $masterWorker['real_name'];
        $order->mobile = $masterWorker['mobile'];
        $share_url = $is_share?(env('project.share_retention_money_host','').'?id='.$order->id):'';
        return ['info' => $order->toArray(),'share_url' => $share_url];
    }

    /**
     * 工程师质保金缴费订单详情
     * @param $params
     * @return array|false|string
     * @throws \Exception
     */
    public static function retentionMoneyOrderDetail($order_id){
        
        $order = MasterWorkerRetentionMoneyOrder::where(['id'=>$order_id])->field('id,worker_id,sn,order_status,order_amount,paid_amount')->findOrEmpty()->toArray();
        if($order){
            $masterWorker = MasterWorker::where(['id' => $order['worker_id']])->field('id,real_name,mobile')->findOrEmpty()->toArray();
            $order['real_name'] = $masterWorker['real_name'];
            $order['mobile'] = $masterWorker['mobile'];
        }
        return $order;
    }

    /**
     * 工程师质保金退费申请
     * @param $params
     * @return array|false|string
     * @throws \Exception
     */
    public static function retentionMoneyRefund($params){
        
        $params['amount'] = (float)$params['amount']??0;
        $log = MasterWorkerRetentionMoneyLog::where(['worker_id'=>$params['worker_id'], 'action' => 2, 'source' => 2])->where('status',0)->order('id','desc')->findOrEmpty();
        if($log->isEmpty()){
            $sn = generate_sn(MasterWorkerRetentionMoneyLog::class, 'sn');
            $log = MasterWorkerRetentionMoneyLog::create([
                'sn' => $sn, 
                'status'=>0,
                'worker_id'=>$params['worker_id'],
                'amount'=>$params['amount']??0,
                'action' => 2, // 退款
                'remark' => $params['remark']??'',
                'source' => 2, // 后台
            ]);
        } elseif($params['amount']>0){ // 可以改价
                $log->amount= $params['amount']??0;
                $log->remark= $params['remark']??0;
                $log->save();
        }
        return $log->toArray();
    }

    /**
     * 工程师质保金退费申请
     * @param $params
     * @return array|false|string
     * @throws \Exception
     */
    public static function retentionMoneyAudit($params){
        
        $status = $params['status']??0;
        Db::startTrans();
        try {
            $log = MasterWorkerRetentionMoneyLog::where('id',$params['id'])->findOrEmpty();
            if($log->isEmpty()){
                self::setError('退费记录不存在');
                return false;
            } else{ 
                if ($status == 1) {
                    //审核通过
                    $earnest_money_usable = MasterWorker::where('id', $log->worker_id)->value('earnest_money_usable');
                    MasterWorker::where('id', $log->worker_id)->dec('earnest_money_usable', $log->amount)->save();
                    $log->remark .= ' 退费前余额：'.$earnest_money_usable.'元，退费后余额：'.($earnest_money_usable-$log->amount).'元';
                } 
                $log->status = $status;
                $log->save();
            }
            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }
    
}