NN2022081301/application/admin/controller/store/Rescue.php

<?php


namespace app\admin\controller\store;


use app\common\controller\AdminController;
use app\http\IResponse;

class Rescue extends AdminController
{

    /**
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/7/15 18:20
     *
     * @return mixed
     * @throws \think\exception\DbException
     */
    public function index()
    {
        $where = [];
        //组合搜索
        $rescue = model('common/Rescue');

        return IResponse::paginate($rescue->where($where)
            ->paginate(input('limit'),false));
    }

    /**
     * 新增
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/06/07 23:59
     *
     * @return mixed
     */
    public function save()
    {
        // 接收数据
        $params = $this->request->param();
        // 数据校验
        $valid = $this->validate($params, [
            'name|救援名称' => 'require',
            'cover_img|展示图片' => 'require',
            'content|服务内容' => 'require',
            'price|服务价格' => 'require',
            'time_slot|服务时段' => 'require'
        ]);
        // 错误返回
        (true !== $valid) && IResponse::failure($valid);
        // 保存数据
        $skillId = model("common/Rescue")->storeBy($params);

        return $skillId ? IResponse::success([],'新增救援信息成功'):
            IResponse::failure('新增救援信息异常');
    }

    /**
     * 更新数据
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/06/07 14:24
     *
     * @param $id
     * @return \think\response\Json
     */
    public function update($id)
    {
        // 接收数据
        $params = $this->request->param();
        // 查询用户
        $rescue = model('common/Rescue')->findBy($id);

        // 是否更改状态操作
        if (isset($params['status']) && $params['status'] != '') {
            $valid = $this->validate($params, [
                'status|配置状态' => 'require|integer'
            ]);
        }else {
            // 数据校验
            $valid = $this->validate($params, [
                'name|救援名称' => 'require',
                'cover_img|展示图片' => 'require',
                'content|服务内容' => 'require',
                'price|服务价格' => 'require',
                'time_slot|服务时段' => 'require'
            ]);
        }
        // 错误返回
        (true !== $valid) && IResponse::failure($valid);

        // 更新信息
        $rescue->updateBy($id, $params);

        return IResponse::success('更新救援信息成功');
    }

    /**
     * 删除
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/3/16 14:22
     *
     * @param $id
     * @return \think\response\Json
     */
    public function delete($id)
    {
        model('common/Rescue')->deleteBy($id);
        return IResponse::success([],'删除救援成功');
    }

    /**
     * 批量操作
     *
     * @return mixed
     */
    public function plectron(){
        // 收参数
        $params = $this->request->param();

        foreach (str2arr($params['ids']) as $id){
            $skills = model('common/Rescue')->getBy($id);
            if ($this->request->isDelete()){
                $skills->deleteBy($id);
                return IResponse::success([],'删除救援服务成功');
            }
            $skills->allowField(true)->updateBy($id, $params);
        }
        return IResponse::success([],'操作成功');
    }

  
    /******************** 订单 *********************/

    /**
     * @return mixed
     * @throws \think\exception\DbException
     */
    public function orders()
    {
        /*1 . 下单未支付 unpay
        2 . 支付待服务 wait
        3 . 服务中 serve
        4 . 服务结束 */
        $where = [];
        //组合搜索
        $user = model('common/RescueOrder');

        return IResponse::paginate($user->where($where)->with(['rescue','user'])
            ->order(['created_at' => 'desc'])
            ->paginate(input('limit'),false));
    }

    /**
     * @return mixed
     */
    public function exportOrder()
    {
        return IResponse::success([],'等待开发...');
    }

    /**
     * @param $id
     *
     * @return mixed
     */
    public function deleteOrder($id)
    {
        model('common/RescueOrder')->deleteBy($id);
        return IResponse::success([],'删除订单成功');
    }

    /**
     * 订单操作
     *
     * @param $id
     * @return \think\response\Json
     */
    public function actionOrder($id)
    {
        $param = $this->request->param();
        $valid = $this->validate($param, [
            'action|操作状态' => 'require'
        ]);
        // 错误返回
        (true !== $valid) && IResponse::failure($valid);
        $model = model('common/RescueOrder');
        $msg = "操作";
        /*1 . 下单未支付 unpay
       2 . 支付待服务 wait
       3 . 服务中 serve
       4 . 服务结束 */
       $serve = $model->findBy($id);
        switch ($param['action']){
            case "dispense":
                $msg = "指派师傅";
                // 状态以及时间
                $model->updateBy($id,[
                    'status' => 3
                ]);
                break;
            case "complete":
                $msg = "结束服务";
                // 系统帮助用户自主确认订单
                $model->updateBy($id,[
                    'status' => 4
                ]);
                break;
            case "closed":
                $msg = "关闭服务";
                $model->updateBy($id,[
                    'status' => 0
                ]);
                // 已支付的数据要返还金额
                if($serve['status'] == 2){
                    // 先返款
                    model('common/Users')->changeBalance(
                        $serve['user_id'],
                        round($serve['price'], 2),
                        '救援服务关闭，退还【' . $serve['price'] . '】',
                        true
                    );
                }
                break;
        }

        return IResponse::success([],$msg . '成功');
    }
}