ball/app/adminapi/controller/works/ServiceWorkController.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\controller\works;


use app\adminapi\controller\BaseAdminController;
use app\adminapi\lists\works\ServiceWorkLists;
use app\adminapi\logic\equity\UserEquityLogic;
use app\adminapi\logic\master_worker\MasterWorkerLogic;
use app\adminapi\logic\works\ServiceWorkLogic;
use app\adminapi\validate\works\ServiceWorkValidate;
use app\api\logic\ServiceOrderLogic;
use app\common\logic\ThirdOrderLogic;
use app\common\model\works\ServiceWork;
use app\adminapi\lists\works\ServiceWorkAppointmentLists;
use Exception;


/**
 * ServiceWork控制器
 * Class WorksController
 * @package app\adminapi\controller\works
 */
class ServiceWorkController extends BaseAdminController
{


    /**
     * @notes 获取列表
     * @return \think\response\Json
     * @author likeadmin
     * @date 2024/07/10 15:06
     */
    public function lists()
    {
        return $this->dataLists(new ServiceWorkLists());
    }

    /**
     * @notes 编辑
     * @return \think\response\Json
     * @author likeadmin
     * @date 2024/07/10 15:06
     */
    public function edit()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('edit');
        $workDetail = ServiceWorkLogic::detail($params);
        //预约时间修改时，同步更新预计完成时间
        if ($workDetail['estimated_finish_time'] && $workDetail['appointment_time'] != $params['appointment_time']) {
            $params['estimated_finish_time'] = strtotime($params['appointment_time']) + (strtotime($workDetail['estimated_finish_time']) - strtotime($workDetail['appointment_time']));
        } else {
            $params['estimated_finish_time'] = strtotime($workDetail['estimated_finish_time']);
        }
        $result = ServiceWorkLogic::edit($params);
        if (true === $result) {
            if(strtotime($workDetail['appointment_time']) !== strtotime($params['appointment_time']) && !empty($workDetail['master_worker_id'])){
                $masterDetail = MasterWorkerLogic::detail(['id'=>$workDetail['master_worker_id']]);
                // 商家改约通知外部平台 即改约
                if($workDetail['external_platform_id'] > 0){
                    event('ExternalPlatform',  [
                        'send_code' => 1002,
                        'params' => [
                            'work_id' => $workDetail['id'],
                        ]
                    ]);
                }

                // 修改预约时间通知【给用户的通知】
                $res = event('Notice',  [
                    'scene_id' => 117,
                    'params' => [
                        'user_id' => $workDetail['user_id'],
                        'date' => $params['appointment_time'],
                        'tel' => asteriskString($masterDetail['mobile']),
                    ]
                ]);
                // 修改预约时间通知【给工程师的通知，仅限公众号】
                $res = event('Notice',  [
                    'scene_id' => 118,
                    'params' => [
                        'user_id' => $workDetail['master_worker_id'],
                        'order_id' => $workDetail['id'],
                        'thing4' => $workDetail['title'],
                        'time5' => $workDetail['appointment_time'],
                        'time6' => $params['appointment_time'],
                        'thing11' => (iconv_strlen($workDetail['address'])>15)?(mb_substr($workDetail['address'],0,15,'UTF-8').'...'):$workDetail['address'],
                        'phone_number8' => asteriskString($workDetail['mobile']),
                    ]
                ]);
            }
            return $this->success('编辑成功', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }


    /**
     * @notes 删除
     * @return \think\response\Json
     * @author likeadmin
     * @date 2024/07/10 15:06
     */
    public function delete()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('delete');
        $result = ServiceWorkLogic::edit($params);
        if (true === $result) {
            return $this->success('编辑成功', [], 1, 1);
        }
        return $this->success('分配成功', [], 1, 1);
    }


    /**
     * @notes 获取详情
     * @return \think\response\Json
     * @author likeadmin
     * @date 2024/07/10 15:06
     */
    public function detail()
    {
        $params = (new ServiceWorkValidate())->goCheck('detail');
        $result = ServiceWorkLogic::detail($params);
        return $this->data($result);
    }


    public function allocateWorker()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('allocateWorker');
        $result = ServiceWorkLogic::allocateWorker($params,$this->adminInfo);
        if (true === $result) {
            return $this->success('分配工程师成功', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }
    public function cancelWorker()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail');
        $result = ServiceWorkLogic::cancel($params);
        if (true === $result) {
            UserEquityLogic::cancelServiceWorkRestoredNumber($params);
            $serviceWorkInfo = ServiceWork::find($params['id']);
            // 商家取消通知外部平台 即取消
            if($serviceWorkInfo['external_platform_id'] > 0){
                event('ExternalPlatform',  [
                    'send_code' => 1005,
                    'params' => [
                        'work_id' => $serviceWorkInfo['id'],
                    ]
                ]);
            }
            return $this->success('取消工单成功！', [], 1, 1);
        }

        return $this->fail(ServiceWorkLogic::getError());
    }
    public function settlementMaster()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail');
        $result = ServiceWorkLogic::settlement($params);
        if (true === $result) {
            return $this->success('操作成功！', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }

    /**
     * 配件审核
     * @return \think\response\Json
     * @author liugc <466014217@qq.com>
     * @date 2025/5/9 9:18
     */
    public function settlementSpare()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail');
        $result = ServiceWorkLogic::settlementSpare($params);
        if (true === $result) {
            return $this->success('操作成功！', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }



    public function notApproved()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail');
        $result = ServiceWorkLogic::notApproved($params);
        if (true === $result) {
            return $this->success('操作成功！', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }

    public function cancelAllocation()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('allocateWorker');
        $result = ServiceWorkLogic::cancelAllocation($params,$this->adminInfo);
        if (true === $result) {
            return $this->success('操作成功！', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }


    public function addCustomerLog()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail',[
            'admin_id' => $this->adminId,
        ]);
        $result = ServiceWorkLogic::addCustomerLog($params);
        if (true === $result) {
            return $this->success('操作成功！', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }


    public function confirmServiceFinish()
    {
        $params = request()->post();
        $params['admin_id'] = $this->adminId;
        $result = ServiceOrderLogic::confirmServiceFinish($params);
        if (false === $result) {
            return $this->fail(ServiceOrderLogic::getError());
        }
        // 订单完成通知【给用户】 - 全款 -通知
        ServiceOrderLogic::serviceFinishNotice($params);
        // 工程师完单的时候设置该规则关闭，以及短信通知工程师
        ServiceOrderLogic::orderQuantityRule($params);
        return $this->success('操作成功！', [], 1, 1);
    }


    /**
     * 工单分配给租户
     * @return \think\response\Json
     */
    public function distributeTenants()
    {
        $params = request()->post();
        $params['admin_id'] = $this->adminId;
        $result = ServiceWorkLogic::distributeTenants($params,$this->adminInfo);
        if (true === $result) {
            return $this->success('分配成功', [], 1, 1);
        }
        return $this->fail(ServiceWorkLogic::getError());
    }
    /**
     * 手动添加工单到第三方平台 (暂时只有美团)
     * @return \think\response\Json
     */
    public function addThirdPlatformsOrders()
    {
        $params = request()->post();
        $result = ServiceWorkLogic::addThirdPlatformsOrders($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('添加成功', [], 1, 1);
    }
    /**
     * 终止服务
     */
    public function terminateService()
    {
        $params = request()->post();
        $result = ServiceWorkLogic::terminateService($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('操作成功', [], 1, 1);
    }

    /**
     * 给用户发券
     */
    public function userAddVoucher()
    {
        $params = request()->post();
        $result = ServiceWorkLogic::userAddVoucher($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('发券成功', [], 1, 1);
    }

    /**
     * 给用户加单
     */
    public function userExtendOrder()
    {
        $params = request()->post();
        $result = ServiceWorkLogic::userExtendOrder($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('加单成功', [], 1, 1);
    }

    /**
     * 代用户上门
     */
    public function confirmDoor()
    {
        $params = request()->post(); // work_sn user_id=master_worker_id  user_info .worker_number .real_name
        $params['user_id'] = $params['master_worker_id'];
        $params['user_info']['worker_number'] = $this->adminId;
        $params['user_info']['real_name'] = $this->adminInfo['name'];
        $result = ServiceWorkLogic::confirmDoor($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('操作成功', [], 1, 1);
    }

    public function appointmentLists()
    {
        return $this->dataLists(new ServiceWorkAppointmentLists());
    }

    public function appointmentAudit()
    {
        $params = (new ServiceWorkValidate())->post()->goCheck('detail');
        $result = ServiceWorkLogic::appointmentAudit($params);
        if (false === $result) {
            return $this->fail(ServiceWorkLogic::getError());
        }
        return $this->success('操作成功', [], 1, 1);
    }

    public function shareOrder()
    {
        $params = request()->post();
        $result = ServiceWorkLogic::shareOrderToNative($params);
        return $this->success('', $result, 1, 1);
    }
    public function shareFirstAmountToNative()
    {
        try {
            $params = request()->post();
            $result = ServiceWorkLogic::shareFirstAmountToNative($params);
            if (false === $result) {
                return $this->fail(ServiceWorkLogic::getError());
            }
            return $this->success('', $result, 1, 1);
        } catch (Exception $e) {
            return $this->fail($e->getMessage());
        }
    }
    public function shareFixedAmountToNative()
    {
        try {
            $params = request()->post();
            $result = ServiceWorkLogic::shareFixedAmountToNative($params);
            if (false === $result) {
                return $this->fail(ServiceWorkLogic::getError());
            }
            return $this->success('', $result, 1, 1);
        } catch (Exception $e) {
            return $this->fail($e->getMessage());
        }
    }


}