zhijiayun/app/Http/Controllers/Api/Process/ControlGoods.php

<?php

namespace App\Http\Controllers\Api\Process;

use App\Http\Controllers\Api\Api;
use App\Http\Requests\Api\Process\ControlGoods as Request;
use App\Models\Api\Process\ControlGoods as ControlGoodsModel;
use App\Models\Api\Personnel\Employee as EmployeeModel;

/**
 * 违规处理-强管控商品
 * @author    唐远望
 * @version   1.0
 * @date      2025-12-09
 */
class ControlGoods extends Api
{
    /**
     * 列表
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-09
     * 
     */
    public function list(Request $request, ControlGoodsModel $ControlGoodsModel, EmployeeModel $EmployeeModel)
    {
        $user_info = $this->checkLogin();
        if (!$user_info) return json_send(['code' => 'error', 'msg' => '请先登录']);
        $user_id = $user_info['uid'];
        $request->scene('list')->validate();
        // 查询条件
        $map  = [];
        $limit = request('limit', config('page_num', 10));
        $status    = request('status', '');
        $start_time = request('start_time', '');
        $end_time = request('end_time', '');
        $product_name = request('product_name', '');
        $first_responsible_person = request('first_responsible_person', '');
        $responsible_person = request('responsible_person', '');
        $platform = request('platform', '');
        $company_name = request('company_name', '');
        $store_name = request('store_name', '');
        $source_responsible_person = request('source_responsible_person', '');
        $processing_status = request('processing_status', '');
        // 时间条件
        if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
        if ($end_time) $map[]   = ['insert_time', '<=', strtotime($end_time)];
        // 其他条件
        if ($status) $map[] = ['status', '=', $status];
        if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];

        if ($first_responsible_person) $map[] = ['first_responsible_person', 'like', "%$first_responsible_person%"];
        if ($responsible_person) $map[] = ['responsible_person', 'like', "%$responsible_person%"];
        if ($platform) $map[] = ['platform', 'like', "%$platform%"];
        if ($company_name) $map[] = ['company_name', 'like', "%$company_name%"];
        if ($store_name) $map[] = ['store_name', 'like', "%$store_name%"];
        if ($source_responsible_person) $map[] = ['source_responsible_person', 'like', "%$source_responsible_person%"];
        if ($processing_status) $map[] = ['processing_status', '=', $processing_status];
        // 查询数据
        $map1 = array_merge($map, [['first_responsible_person', 'like', "%,$user_id,%"]]);
        $map2 = array_merge($map, [['responsible_person', 'like', "%,$user_id,%"]]);
        $map3 = array_merge($map, [['source_responsible_person', 'like', "%,$user_id,%"]]);
        $result = $ControlGoodsModel->query()
            ->where($map1)
            ->orWhere($map2)
            ->orWhere($map3)
            ->orderByDesc('id')
            ->paginate($limit)->toarray();
        // 分配数据
        if (!$result)  return json_send(['code' => 'error', 'msg' => '暂无数据']);
        if (isset($result['data']) && count($result['data']) > 0) {
            foreach ($result['data'] as $key => $value) {
                //查询第一责任人名称
                $first_responsible_person = explode(',', $value['first_responsible_person']);
                $first_responsible_person_name = $EmployeeModel->whereIn('id', $first_responsible_person)->pluck('name')->toarray();
                $result['data'][$key]['first_responsible_person_name'] = $first_responsible_person_name;
                //查询责任人名称
                $responsible_person = explode(',', $value['responsible_person']);
                $responsible_person_name = $EmployeeModel->whereIn('id', $responsible_person)->pluck('name')->toarray();
                $result['data'][$key]['responsible_person_name'] = $responsible_person_name;
                //查询来源责任人名称
                $source_responsible_person = explode(',', $value['source_responsible_person']);
                $source_responsible_person_name = $EmployeeModel->whereIn('id', $source_responsible_person)->pluck('name')->toarray();
                $result['data'][$key]['source_responsible_person_name'] = $source_responsible_person_name;
            }
        }
        // 加载模板
        return        json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
    }

    /**
     * 详情
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-09
     */
    public function detail(Request $request, ControlGoodsModel $ControlGoodsModel, EmployeeModel $EmployeeModel)
    {
        $user_info = $this->checkLogin();
        if (!$user_info) return json_send(['code' => 'error', 'msg' => '请先登录']);
        $request->scene('detail')->validate();
        // 接收参数
        $id = request('id', 0);
        $map = ['id' => $id];
        $data = $ControlGoodsModel->where($map)->first();
        if (!$data)     return json_send(['code' => 'error', 'msg' => '记录不存在']);
        //查询第一责任人名称
        $first_responsible_person = explode(',', $data->first_responsible_person);
        $first_responsible_person_name = $EmployeeModel->whereIn('id', $first_responsible_person)->pluck('name')->toarray();
        $data->first_responsible_person_name = $first_responsible_person_name;
        //查询责任人名称
        $responsible_person = explode(',', $data->responsible_person);
        $responsible_person_name = $EmployeeModel->whereIn('id', $responsible_person)->pluck('name')->toarray();
        $data->responsible_person_name = $responsible_person_name;
        //查询来源责任人名称
        $source_responsible_person = explode(',', $data->source_responsible_person);
        $source_responsible_person_name = $EmployeeModel->whereIn('id', $source_responsible_person)->pluck('name')->toarray();
        $data->source_responsible_person_name = $source_responsible_person_name;
        // 加载模板
        return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
    }

    /**
     * 修改状态
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-09
     * 
     */
    public function set_status(Request $request, ControlGoodsModel $ControlGoodsModel)
    {
        // 验证参数
        $request->scene('set_status')->validate();
        // 接收数据
        $id                = request('id', 0);
        $status            = request('status', 0);
        // 查询用户
        $where = ['id' => $id];
        // 执行修改
        $result            =  $ControlGoodsModel->changeStatus($where, $status);
        // 提示新增失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '设置失败']);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '设置成功']);
    }

    /**
     * 修改处理状态
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-09
     * 
     */
    public function set_processing_status(Request $request, ControlGoodsModel $ControlGoodsModel)
    {
        // 验证参数
        $request->scene('set_processing_status')->validate();
        // 接收数据
        $id                = request('id', 0);
        $processing_status = request('processing_status', 0);
        // 查询用户
        $where = ['id' => $id];
        // 执行修改
        $result            =  $ControlGoodsModel->changeProcessingStatus($where, $processing_status);
        // 提示新增失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '设置失败']);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '设置成功']);
    }
}