zhijiayun/app/Http/Controllers/Manager/Process/ViolationStore.php

<?php

namespace App\Http\Controllers\Manager\Process;

use App\Http\Controllers\Controller;
use App\Http\Requests\Manager\Process\ViolationStore as Request;
use App\Models\Manager\Process\ViolationStore as ViolationStoreModel;
use App\Jobs\Manager\Process\ViolationStoreJobs;
use App\Models\Manager\Personnel\Employee as EmployeeModel;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use PhpOffice\PhpSpreadsheet\Style\Alignment;
use App\Models\Api\Process\ViolationStoreMember as ViolationStoreMemberModel;
use App\Jobs\Manager\Process\ViolationCompanyJobs;

/**
 * 违规处理-违规店铺
 * @author    唐远望
 * @version   1.0
 * @date      2025-12-08
 */
class ViolationStore extends Controller
{
    /**
     * 列表
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function list(Request $request, ViolationStoreModel $ViolationStoreModel, EmployeeModel $EmployeeModel, ViolationStoreMemberModel $ViolationStoreMemberModel)
    {
        $request->scene('list')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $user_id = request('access_token.uid', 0);
        // 查询条件
        $map  = [];
        $limit = request('limit', config('page_num', 10));
        $status    = request('status', '');
        $start_time = request('start_time', '');
        $end_time = request('end_time', '');
        $first_responsible_person = request('first_responsible_person', '');
        $first_responsible_person_name = request('first_responsible_person_name', '');
        $responsible_person = request('responsible_person', '');
        $responsible_person_name = request('responsible_person_name', '');
        $platform = request('platform', '');
        $company_name = request('company_name', '');
        $company_names = request('company_names', '');
        $store_name = request('store_name', '');
        $store_names = request('store_names', '');
        $source_responsible_person = request('source_responsible_person', '');
        $source_responsible_person_name = request('source_responsible_person_name', '');
        $processing_status = request('processing_status', '');
        $product_specs = request('product_specs', '');
        $online_posting_count = request('online_posting_count', '');
        $id    = request('id', '');
        $province_ids = request('province_ids', '');
        $city_ids = request('city_ids', '');
        $collection_time_start_time = request('collection_time_start_time', '');
        $collection_time_end_time = request('collection_time_end_time', '');
        $merge_city_ids = request('merge_city_ids', '');
        $merge_province_ids = request('merge_province_ids', '');
        // 时间条件
        if ($collection_time_start_time) $map[] = ['collection_time', '>=', strtotime($collection_time_start_time)];
        if ($collection_time_end_time) $map[] = ['collection_time', '<=', strtotime($collection_time_end_time)];
        if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
        if ($end_time) $map[]   = ['insert_time', '<=', strtotime($end_time)];
        //其它条件
        if ($store_name) $map[]   = ['store_name', 'like', "%$store_name%"];
        if ($company_name) $map[]   = ['company_name', 'like', "%$company_name%"];
        if ($id) $map[]   = ['id', '=', $id];

        $violation_store_where = [];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $violation_store_where['company_id'] = $company_id;
        } else {
            $violation_store_where['company_id']  = $admin_company_id;
        }
        $ViolationStoreModel = $ViolationStoreModel->where($violation_store_where);
        //多选平台查询
        if ($platform && is_string($platform)) {
            $platform = explode(',', $platform);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
        }
        //多选处理状态查询
        if ($processing_status && is_string($processing_status)) {
            $processing_status = explode(',', $processing_status);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('processing_status', $processing_status);
        }
        //多选状态查询
        if ($status && is_string($status)) {
            $status = explode(',', $status);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('status', $status);
        }
        //多选店铺名称查询
        if ($store_names && is_string($store_names)) {
            $store_names = explode(',', $store_names);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('store_name', $store_names);
        }
        //多选违规挂网次数查询
        if ($online_posting_count && is_string($online_posting_count)) {
            $online_posting_count = explode(',', $online_posting_count);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('online_posting_count', $online_posting_count);
        }
        //多选规格查询
        if ($product_specs && is_string($product_specs)) {
            $product_specs = explode(',', $product_specs);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('product_specs', $product_specs);
        }
        //多选公司查询
        if ($company_names && is_string($company_names)) {
            $company_names = explode(',', $company_names);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('company_name', $company_names);
        }
        //多选第一责任人
        if ($first_responsible_person && is_string($first_responsible_person)) {
            $first_responsible_person = explode(',', $first_responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $first_responsible_person)->where('duty_type', 1)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //第一责任人模糊查询
        if ($first_responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$first_responsible_person_name%"]])->where('duty_type', 1)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选责任人
        if ($responsible_person && is_string($responsible_person)) {
            $responsible_person = explode(',', $responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $responsible_person)->where('duty_type', 2)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //责任人模糊查询
        if ($responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$responsible_person_name%"]])->where('duty_type', 2)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选溯源责任人
        if ($source_responsible_person && is_string($source_responsible_person)) {
            $source_responsible_person = explode(',', $source_responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $source_responsible_person)->where('duty_type', 3)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //溯源责任人模糊查询
        if ($source_responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$source_responsible_person_name%"]])->where('duty_type', 3)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选省份
        if ($province_ids && is_string($province_ids)) {
            $province_ids = explode(',', $province_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('province_id', $province_ids);
        }
        //多选城市
        if ($city_ids && is_string($city_ids)) {
            $city_ids = explode(',', $city_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('city_id', $city_ids);
        }
        //多选合并省份
        if ($merge_province_ids && is_string($merge_province_ids)) {
            $merge_province_ids = explode(',', $merge_province_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('merge_province_id', $merge_province_ids);
        }
        //多选合并城市
        if ($merge_city_ids && is_string($merge_city_ids)) {
            $merge_city_ids = explode(',', $merge_city_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('merge_city_id', $merge_city_ids);
        }
        $personnel_roles_info = $EmployeeModel->leftjoin('personnel_roles', 'personnel_roles.id', '=', 'personnel_employee.role_id')
            ->where('personnel_employee.id', $user_id)->select(['personnel_employee.id', 'personnel_roles.identity'])
            ->first();
        //角色身份1=普通2=管理员
        if (!empty($personnel_roles_info) && $personnel_roles_info->identity == 2) {
            $is_admin = 1;
        }
        // 查询数据
        if ($is_admin != 1 && $company_id != 0) {
            $result = $ViolationStoreModel->where(function ($q) use ($user_id) {
                $q->where('first_responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('source_responsible_person', 'like', "%,$user_id,%");
            })
                ->where($map)
                ->orderByDesc('insert_time')
                ->orderByDesc('collection_time')
                ->paginate($limit)->toarray();
        } else {
            $result = $ViolationStoreModel
                ->where($map)
                ->orderByDesc('insert_time')
                ->orderByDesc('collection_time')
                ->paginate($limit)->toarray();
        }
        // 分配数据
        if (!$result)  json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
        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_string = $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->whereIn('employee_id', $first_responsible_person)->pluck('employee_name')->toarray();
                $result['data'][$key]['first_responsible_person_name'] = $first_responsible_person_name_string;
                //查询责任人名称
                $responsible_person = explode(',', $value['responsible_person']);
                $responsible_person_name_string =  $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->whereIn('employee_id', $responsible_person)->pluck('employee_name')->toarray();
                $result['data'][$key]['responsible_person_name'] = $responsible_person_name_string;
                //查询来源责任人名称
                $source_responsible_person = explode(',', $value['source_responsible_person']);
                $source_responsible_person_name_string = $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->whereIn('employee_id', $source_responsible_person)->pluck('employee_name')->toarray();
                $result['data'][$key]['source_responsible_person_name'] = $source_responsible_person_name_string;
            }
        }
        // 加载模板
        return        json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
    }

    /**
     * 列表导出
     * @author 唐远望
     * @version 1.0
     * @date 2025-06-17
     */
    public function export_excel(Request $request,  ViolationStoreModel $ViolationStoreModel, EmployeeModel $EmployeeModel, ViolationStoreMemberModel $ViolationStoreMemberModel)
    {
        $request->scene('export_excel')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $user_id = request('access_token.uid', 0);
        // 查询条件
        $map  = [];
        $status    = request('status', '');
        $start_time = request('start_time', '');
        $end_time = request('end_time', '');
        $first_responsible_person = request('first_responsible_person', '');
        $first_responsible_person_name = request('first_responsible_person_name', '');
        $responsible_person = request('responsible_person', '');
        $responsible_person_name = request('responsible_person_name', '');
        $platform = request('platform', '');
        $company_name = request('company_name', '');
        $store_name = request('store_name', '');
        $store_names = request('store_names', '');
        $source_responsible_person = request('source_responsible_person', '');
        $source_responsible_person_name = request('source_responsible_person_name', '');
        $processing_status = request('processing_status', '');
        $product_specs = request('product_specs', '');
        $online_posting_count = request('online_posting_count', '');
        $province_ids = request('province_ids', '');
        $city_ids = request('city_ids', '');
        $collection_time_start_time = request('collection_time_start_time', '');
        $collection_time_end_time = request('collection_time_end_time', '');
        // 时间条件
        if ($collection_time_start_time) $map[] = ['collection_time', '>=', strtotime($collection_time_start_time)];
        if ($collection_time_end_time) $map[] = ['collection_time', '<=', strtotime($collection_time_end_time)];
        if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
        if ($end_time) $map[]   = ['insert_time', '<=', strtotime($end_time)];
        //其它条件
        if ($store_name) $map[]   = ['store_name', 'like', "%$store_name%"];

        $violation_store_where = [];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $violation_store_where['company_id'] = $company_id;
        } else {
            $violation_store_where['company_id']  = $admin_company_id;
        }
        $ViolationStoreModel = $ViolationStoreModel->where($violation_store_where);
        //多选平台查询
        if ($platform && is_string($platform)) {
            $platform = explode(',', $platform);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('platform', $platform);
        }
        //多选处理状态查询
        if ($processing_status && is_string($processing_status)) {
            $processing_status = explode(',', $processing_status);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('processing_status', $processing_status);
        }
        //多选状态查询
        if ($status && is_string($status)) {
            $status = explode(',', $status);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('status', $status);
        }
        //多选店铺名称查询
        if ($store_names && is_string($store_names)) {
            $store_names = explode(',', $store_names);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('store_name', $store_names);
        }
        //多选违规挂网次数查询
        if ($online_posting_count && is_string($online_posting_count)) {
            $online_posting_count = explode(',', $online_posting_count);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('online_posting_count', $online_posting_count);
        }
        //多选规格查询
        if ($product_specs && is_string($product_specs)) {
            $product_specs = explode(',', $product_specs);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('product_specs', $product_specs);
        }
        //多选公司查询
        if ($company_name && is_string($company_name)) {
            $company_name = explode(',', $company_name);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('company_name', $company_name);
        }
        //多选第一责任人
        if ($first_responsible_person && is_string($first_responsible_person)) {
            $first_responsible_person = explode(',', $first_responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $first_responsible_person)->where('duty_type', 1)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //第一责任人模糊查询
        if ($first_responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$first_responsible_person_name%"]])->where('duty_type', 1)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选责任人
        if ($responsible_person && is_string($responsible_person)) {
            $responsible_person = explode(',', $responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $responsible_person)->where('duty_type', 2)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //责任人模糊查询
        if ($responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$responsible_person_name%"]])->where('duty_type', 2)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选溯源责任人
        if ($source_responsible_person && is_string($source_responsible_person)) {
            $source_responsible_person = explode(',', $source_responsible_person);
            $subQuery = $ViolationStoreMemberModel->whereIn('employee_id', $source_responsible_person)->where('duty_type', 3)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //溯源责任人模糊查询
        if ($source_responsible_person_name != '') {
            $subQuery = $ViolationStoreMemberModel->where([['employee_name', 'like', "%$source_responsible_person_name%"]])->where('duty_type', 3)->distinct('violation_store_logid')->select('violation_store_logid');
            $ViolationStoreModel = $ViolationStoreModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('violation_store_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选省份
        if ($province_ids && is_string($province_ids)) {
            $province_ids = explode(',', $province_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('province_id', $province_ids);
        }
        //多选城市
        if ($city_ids && is_string($city_ids)) {
            $city_ids = explode(',', $city_ids);
            $ViolationStoreModel = $ViolationStoreModel->whereIn('city_id', $city_ids);
        }

        if ($is_admin != 1 && $company_id != 0) {
            $result_totle = $ViolationStoreModel->where(function ($q) use ($user_id) {
                $q->where('first_responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('source_responsible_person', 'like', "%,$user_id,%");
            })
                ->where($map)
                ->orderByDesc('id')
                ->count();
        } else {
            $result_totle = $ViolationStoreModel->where($map)
                ->orderByDesc('id')
                ->count();
        }
        // 数量过多时，限制导出
        if ($result_totle > 100000) {
            return json_send(['code' => 'error', 'msg' => '导出数据过多，请缩小查询条件']);
        }
        if ($is_admin != 1 && $company_id != 0) {
            $result = $ViolationStoreModel->where(function ($q) use ($user_id) {
                $q->where('first_responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('responsible_person', 'like', "%,$user_id,%")
                    ->orWhere('source_responsible_person', 'like', "%,$user_id,%");
            })
                ->where($map)
                ->orderByDesc('id')
                ->get()->toarray();
        } else {
            $result = $ViolationStoreModel->where($map)
                ->orderByDesc('id')
                ->get()->toarray();
        }
        // 分配数据
        if (!$result)  return json_send(['code' => 'error', 'msg' => '暂无数据']);
        // 处理责任人展示信息
        $list_data = $this->processing_responsible_person($result);
        // 导出数据
        $this->export_download($list_data);
    }


    /**
     * 处理责任人展示信息
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-17
     */
    public function processing_responsible_person($result)
    {
        $ViolationStoreMemberModel = new ViolationStoreMemberModel();
        if (isset($result) && count($result) > 0) {
            foreach ($result as $key => $value) {
                //查询第一责任人名称
                $first_responsible_person = explode(',', $value['first_responsible_person']);
                $first_responsible_person_name = $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->where('duty_type', '1')->whereIn('employee_id', $first_responsible_person)->pluck('employee_name')->toarray();
                $result[$key]['first_responsible_person_name'] = $first_responsible_person_name;
                //查询责任人名称
                $responsible_person = explode(',', $value['responsible_person']);
                $responsible_person_name =  $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->where('duty_type', '2')->whereIn('employee_id', $responsible_person)->pluck('employee_name')->toarray();
                $result[$key]['responsible_person_name'] = $responsible_person_name;
                //查询来源责任人名称
                $source_responsible_person = explode(',', $value['source_responsible_person']);
                $source_responsible_person_name = $ViolationStoreMemberModel->where('violation_store_logid', $value['id'])->where('duty_type', '3')->whereIn('employee_id', $source_responsible_person)->pluck('employee_name')->toarray();
                $result[$key]['source_responsible_person_name'] = $source_responsible_person_name;
            }
        }
        return $result;
    }

    /**
     * 导出下载
     * @author 唐远望
     * @version 1.0
     * @date 2025-06-17
     */
    public function export_download($data)
    {
        // 创建一个新的 Spreadsheet 对象
        $spreadsheet = new Spreadsheet();
        $sheet = $spreadsheet->getActiveSheet();

        //合并单元格
        $sheet->mergeCells('A1:P1');
        $sheet->setCellValue('A1', '违规店铺导出（导出时间：' . date('Y-m-d H:i:s', time()) . ')'); // 设置合并后的单元格内容
        // 获取合并后的单元格样式对象
        $style = $sheet->getStyle('A1');
        // 设置水平居中和垂直居中
        $style->getAlignment()->setHorizontal(Alignment::HORIZONTAL_CENTER)->setVertical(Alignment::VERTICAL_CENTER);
        // 然后设置行高以适应两行文本
        $sheet->getRowDimension(1)->setRowHeight(40); // 设置行高，单位是磅(point)
        // 设置表头
        $sheet->setCellValue('A2', '第一责任人');
        $sheet->setCellValue('B2', '责任人');
        $sheet->setCellValue('C2', '平台');
        $sheet->setCellValue('D2', '链接地址');
        $sheet->setCellValue('E2', '店铺名称');
        $sheet->setCellValue('F2', '公司名称');
        $sheet->setCellValue('G2', '公司分类');
        $sheet->setCellValue('H2', '信用代码');
        $sheet->setCellValue('I2', '省份');
        $sheet->setCellValue('J2', '城市');
        $sheet->setCellValue('K2', '溯源责任人');
        $sheet->setCellValue('L2', '处理状态');
        $sheet->setCellValue('M2', '任务状态');
        $sheet->setCellValue('N2', '记录时间');

        //平台0=全部，1=淘宝，2=京东，3=拼多多，4=美团，5=药师帮，6=1药城，7=药九九,8=药易购，9=药帮忙，10=熊猫药药11=药房网
        $platform_data = [
            '0' => '全部',
            '1' => '淘宝',
            '2' => '京东',
            '3' => '拼多多',
            '4' => '美团',
            '5' => '药师帮',
            '6' => '1药城',
            '7' => '药九九',
            '8' => '药易购',
            '9' => '药帮忙',
            '10' => '熊猫药药',
            '11' => '药房网',
        ];
        $processing_status_text = [
            '1' => '待处理',
        ];
        $status_text = [
            '0' => '有效',
            '1' => '无效',
        ];
        // 填充数据
        $row = 3; // 从第2行开始
        foreach ($data as $item) {
            $first_responsible_person_name = !empty($item['first_responsible_person_name']) ? implode(',', $item['first_responsible_person_name']) : '';
            $responsible_person_name = !empty($item['responsible_person_name']) ? implode(',', $item['responsible_person_name']) : '';
            $source_responsible_person_name = !empty($item['source_responsible_person_name']) ? implode(',', $item['source_responsible_person_name']) : '';
            $sheet->setCellValue('A' . $row, $first_responsible_person_name);
            $sheet->setCellValue('B' . $row, $responsible_person_name);
            $sheet->setCellValue('C' . $row, isset($platform_data[$item['platform']]) ? $platform_data[$item['platform']] : '');
            $sheet->setCellValue('D' . $row, $item['link_url']);
            $sheet->setCellValue('E' . $row, $item['store_name']);
            $sheet->setCellValue('F' . $row, $item['company_name']);
            $sheet->setCellValue('G' . $row, $item['company_category_name']);
            $sheet->setCellValue('H' . $row, $item['social_credit_code']);
            $sheet->setCellValue('I' . $row, $item['province_name']);
            $sheet->setCellValue('J' . $row, $item['city_name']);
            $sheet->setCellValue('K' . $row, $source_responsible_person_name);
            $sheet->setCellValue('L' . $row, isset($processing_status_text[$item['processing_status']]) ? $processing_status_text[$item['processing_status']] : '');
            $sheet->setCellValue('M' . $row, isset($status_text[$item['status']]) ? $status_text[$item['status']] : '');
            $sheet->setCellValue('N' . $row, date('Y-m-d H:i:s', $item['insert_time']));
            $row++;
        }
        foreach (range('A', 'P') as $column) {
            $sheet->getColumnDimension($column)->setAutoSize(true);
        }
        // 生成 Excel 文件
        $writer = new Xlsx($spreadsheet);

        // 直接输出到浏览器（下载）
        $filename = '违规店铺数据' . date('YmdHis') . '.xlsx';
        header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
        header('Content-Disposition: attachment;filename="' . $filename . '"');
        header('Cache-Control: max-age=0');
        $writer->save('php://output');
        exit;
    }

    /**
     * 详情
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     */
    public function detail(Request $request, ViolationStoreModel $ViolationStoreModel, EmployeeModel $EmployeeModel)
    {
        $request->scene('detail')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收参数
        $id = request('id', 0);
        $map = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
        } else {
            $map['company_id']  = $admin_company_id;
        }
        $data = $ViolationStoreModel->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-08
     * 
     */
    public function add(Request $request, ViolationStoreModel $ViolationStoreModel)
    {
        $request->scene('add')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $all_data = request()->all();
        $store_scope = request('store_scope', '');
        $all_data['store_scope'] = $store_scope;
        //查询是否存在
        $map = ['store_name' => $all_data['store_name'], 'company_name' => $all_data['company_name']];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
            $all_data['company_id'] = $company_id;
        } else {
            $map['company_id']  = $admin_company_id;
            $all_data['company_id'] = $admin_company_id;
        }
        $data = $ViolationStoreModel->where($map)->first();
        if ($data)     return json_send(['code' => 'error', 'msg' => '记录已存在']);
        // 写入数据表
        $result     =  $ViolationStoreModel->addViolationStore($all_data);
        // 如果操作失败
        if (!$result)     return json_send(['code' => 'error', 'msg' => '新增失败']);
        // 告知结果
        return json_send(['code' => 'success', 'msg' => '新增成功']);
    }

    /**
     * 修改
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function edit(Request $request, ViolationStoreModel $ViolationStoreModel)
    {
        $request->scene('edit')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收参数
        $id         = request('id', 0);
        // 接收数据
        $all_data = request()->all();
        $store_scope = request('store_scope', '');
        $all_data['store_scope'] = $store_scope;
        //查询是否存在
        $map = ['store_name' => $all_data['store_name'], 'company_name' => $all_data['company_name']];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $map['company_id'] = $company_id;
            $all_data['company_id'] = $company_id;
        } else {
            $map['company_id']  = $admin_company_id;
            $all_data['company_id'] = $admin_company_id;
        }
        $data = $ViolationStoreModel->where($map)->where('id', '!=', $id)->first();
        if ($data)     return json_send(['code' => 'error', 'msg' => '记录已存在']);
        // 更新数据表
        $where = ['id' => $id];
        $result =  $ViolationStoreModel->updateViolationStore($where, $all_data);
        // 如果操作失败
        if (!$result)     return json_send(['code' => 'error', 'msg' => '修改失败']);
        // 告知结果
        return json_send(['code' => 'success', 'msg' => '修改成功']);
    }

    /**
     * 修改状态
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function set_status(Request $request, ViolationStoreModel $ViolationStoreModel)
    {
        // 验证参数
        $request->scene('set_status')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $id                = request('id', 0);
        $status            = request('status', 0);
        // 查询用户
        $where = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id']  = $admin_company_id;
        }
        // 执行修改
        $result            =  $ViolationStoreModel->changeStatus($where, $status);
        // 提示新增失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '设置失败']);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '设置成功']);
    }

    /**
     * 修改处理状态
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function set_processing_status(Request $request, ViolationStoreModel $ViolationStoreModel)
    {
        // 验证参数
        $request->scene('set_processing_status')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $id                = request('id', 0);
        $processing_status = request('processing_status', 0);
        // 查询用户
        $where = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id']  = $admin_company_id;
        }
        // 执行修改
        $result            =  $ViolationStoreModel->changeProcessingStatus($where, $processing_status);
        // 提示新增失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '设置失败']);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '设置成功']);
    }


    /**
     * 删除
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function delete(Request $request, ViolationStoreModel $ViolationStoreModel)
    {
        // 验证参数
        $request->scene('delete')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        // 接收数据
        $id = request('id', 0);
        // 查询用户
        $where = ['id' => $id];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $where['company_id'] = $company_id;
        } else {
            $where['company_id']  = $admin_company_id;
        }
        // 执行删除
        $result =  $ViolationStoreModel->deleteViolationStore($where);
        // 提示删除失败
        if (!$result)    return json_send(['code' => 'error', 'msg' => '删除失败']);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '删除成功']);
    }

    /**
     * 执行数据清洗
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-11
     * 
     */
    public function data_cleaning(Request $request)
    {
        // 验证参数
        $request->scene('data_cleaning')->validate();
        $admin_company_id = request('admin_company_id', '0');
        $company_id = request('access_token.company_id', '0');
        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $admin_id   = request('access_token.uid', 0); //用户ID
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
        } else {
            $company_id = $admin_company_id;
        }
        $message_data = ['page' => '1', 'limit' => 50, 'admin_id' => $admin_id, 'is_admin' => $is_admin, 'company_id' => $company_id];
        // ViolationStoreJobs::dispatchSync($message_data);
        ViolationCompanyJobs::dispatch($message_data);
        // ViolationCompanyJobs::dispatchSync($message_data);

        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '执行成功']);
    }
}