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

<?php

namespace App\Http\Controllers\Manager\Process;

use App\Http\Controllers\Controller;
use App\Http\Requests\Manager\Process\LowPriceGoods as Request;
use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
use App\Jobs\Manager\Process\LowPriceGoodsJobs;
use App\Models\Manager\Personnel\Employee as EmployeeModel;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use PhpOffice\PhpSpreadsheet\Style\Alignment;
use PhpOffice\PhpSpreadsheet\IOFactory;
use App\Models\Manager\Process\LowPriceGoodsMember as LowPriceGoodsMemberModel;
use App\Models\manager\Process\LowPriceGoodsRecord as LowPriceGoodsRecordModel;
use Illuminate\Support\Facades\DB;
use App\Models\Manager\Citys as CitysModel;
use App\Servers\Aliyun\Oss;
use App\Jobs\Manager\Other\ExportLowPriceGoodsJobs;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Carbon;
use App\Jobs\Manager\Process\ScrapeDataProductJobs;

/**
 * 违规处理-低价商品
 * @author    唐远望
 * @version   1.0
 * @date      2025-12-08
 */
class LowPriceGoods extends Controller
{

    /**
     * 列表
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     * 
     */
    public function list(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, EmployeeModel $EmployeeModel, LowPriceGoodsMemberModel $LowPriceGoodsMemberModel)
    {
        $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', '');
        $product_name = request('product_name', '');
        $product_names = request('product_names', '');
        $first_responsible_person = request('first_responsible_person', '');
        $responsible_person = request('responsible_person', '');
        $platform = request('platform', '');
        $company_name = request('company_name', '');
        $company_names = request('company_names', '');
        $store_name = request('store_name', '');
        $anonymous_store_name = request('anonymous_store_name', '');
        $store_names = request('store_names', '');
        $source_responsible_person = request('source_responsible_person', '');
        $processing_status = request('processing_status', '');
        $product_specs = request('product_specs', '');
        $online_posting_count = request('online_posting_count', '');
        $category_name = request('category_name', '');
        $id    = request('id', '');
        $online_posting_cunt = request('online_posting_cunt', '');
        $continuous_listing_count = request('continuous_listing_count', '');
        $province_ids = request('province_ids', '');
        $city_ids = request('city_ids', '');
        $shipment_province_ids = request('shipment_province_ids', '');
        $shipment_city_ids = request('shipment_city_ids', '');
        $product_brand = request('product_brand', '');
        $collection_time_start_time = request('collection_time_start_time', '');
        $collection_time_end_time = request('collection_time_end_time', '');
        $online_posting_min_price = request('online_posting_min_price', '');
        $online_posting_max_price = request('online_posting_max_price', '');
        $is_ultra_low_price = request('is_ultra_low_price', '');
        $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 ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
        if ($store_name) $map[]   = ['store_name', 'like', "%$store_name%"];
        if ($anonymous_store_name) $map[]   = ['anonymous_store_name', 'like', "%$anonymous_store_name%"];
        if ($category_name) $map[] = ['category_name', 'like', "%$category_name%"];
        if ($company_name) $map[] = ['company_name', 'like', "%$company_name%"];
        if ($id) $map[] = ['id', '=', $id];
        if ($online_posting_cunt) $map[] = ['online_posting_count', '=', $online_posting_cunt];
        if ($continuous_listing_count) $map[] = ['continuous_listing_count', '=', $continuous_listing_count];
        if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
        if ($online_posting_min_price) $map[] = ['online_posting_price', '>=', $online_posting_min_price];
        if ($online_posting_max_price) $map[] = ['online_posting_price', '<=', $online_posting_max_price];
        if ($is_ultra_low_price) $map[] = ['is_ultra_low_price', '=', $is_ultra_low_price];

        $low_price_goods_where = [];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $low_price_goods_where['company_id'] = $company_id;
        } else {
            $low_price_goods_where['company_id']  = $admin_company_id;
        }
        $LowPriceGoodsModel = $LowPriceGoodsModel->where($low_price_goods_where);
        //多选平台查询
        if ($platform && is_string($platform)) {
            $platform = explode(',', $platform);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
        }
        //多选处理状态查询
        if ($processing_status && is_string($processing_status)) {
            $processing_status = explode(',', $processing_status);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('processing_status', $processing_status);
        }
        //多选状态查询
        if ($status && is_string($status)) {
            $status = explode(',', $status);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('status', $status);
        }
        //多选店铺名称查询
        if ($store_names && is_string($store_names)) {
            $store_names = explode(',', $store_names);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('store_name', $store_names);
        }
        //多选违规挂网次数查询
        if ($online_posting_count && is_string($online_posting_count)) {
            $online_posting_count = explode(',', $online_posting_count);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('online_posting_count', $online_posting_count);
        }
        //多选规格查询
        if ($product_specs && is_string($product_specs)) {
            $product_specs = explode(',', $product_specs);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('product_specs', $product_specs);
        }
        //多选商品查询
        if ($product_names && is_string($product_names)) {
            $product_names = explode(',', $product_names);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('product_name', $product_names);
        }
        //多选公司查询
        if ($company_names && is_string($company_names)) {
            $company_names = explode(',', $company_names);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('company_name', $company_names);
        }
        //多选第一责任人
        if ($first_responsible_person && is_string($first_responsible_person)) {
            $first_responsible_person = explode(',', $first_responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $first_responsible_person)->where('duty_type', 1)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选责任人
        if ($responsible_person && is_string($responsible_person)) {
            $responsible_person = explode(',', $responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $responsible_person)->where('duty_type', 2)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选溯源责任人
        if ($source_responsible_person && is_string($source_responsible_person)) {
            $source_responsible_person = explode(',', $source_responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $source_responsible_person)->where('duty_type', 3)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选省份
        if ($province_ids && is_string($province_ids)) {
            $province_ids = explode(',', $province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('province_id', $province_ids);
        }
        //多选城市
        if ($city_ids && is_string($city_ids)) {
            $city_ids = explode(',', $city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('city_id', $city_ids);
        }
        //多选店铺省
        if ($shipment_province_ids && is_string($shipment_province_ids)) {
            $shipment_province_ids = explode(',', $shipment_province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('shipment_province_id', $shipment_province_ids);
        }
        //多选店铺市
        if ($shipment_city_ids && is_string($shipment_city_ids)) {
            $shipment_city_ids = explode(',', $shipment_city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('shipment_city_id', $shipment_city_ids);
        }
        //多合并省份
        if ($merge_province_ids && is_string($merge_province_ids)) {
            $merge_province_ids = explode(',', $merge_province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('merge_province_id', $merge_province_ids);
        }
        //多合并市
        if ($merge_city_ids && is_string($merge_city_ids)) {
            $merge_city_ids = explode(',', $merge_city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->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 = $LowPriceGoodsModel->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 = $LowPriceGoodsModel->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 = $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-06-17
     */
    public function export_excel(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, EmployeeModel $EmployeeModel,  LowPriceGoodsMemberModel $LowPriceGoodsMemberModel)
    {
        $request->scene('export_excel')->validate();
        $message_data['admin_company_id'] = request('admin_company_id', '0');
        $message_data['company_id'] = request('access_token.company_id', '0');
        $message_data['is_admin'] = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
        $message_data['user_id'] = request('access_token.uid', 0);
        // 查询条件
        $message_data['status'] = request('status', '');
        $message_data['start_time'] = request('start_time', '');
        $message_data['end_time'] = request('end_time', '');
        $message_data['product_name'] = request('product_name', '');
        $message_data['product_names'] = request('product_names', '');
        $message_data['first_responsible_person'] = request('first_responsible_person', '');
        $message_data['responsible_person'] = request('responsible_person', '');
        $message_data['platform'] = request('platform', '');
        $message_data['company_name'] = request('company_name', '');
        $message_data['company_names'] = request('company_names', '');
        $message_data['store_name'] = request('store_name', '');
        $message_data['anonymous_store_name']  = request('anonymous_store_name', '');
        $message_data['store_names'] = request('store_names', '');
        $message_data['source_responsible_person'] = request('source_responsible_person', '');
        $message_data['processing_status'] = request('processing_status', '');
        $message_data['product_specs'] = request('product_specs', '');
        $message_data['online_posting_count'] = request('online_posting_count', '');
        $message_data['category_name'] = request('category_name', '');
        $message_data['id'] = request('id', '');
        $message_data['online_posting_cunt'] = request('online_posting_cunt', '');
        $message_data['continuous_listing_count'] = request('continuous_listing_count', '');
        $message_data['province_ids'] = request('province_ids', '');
        $message_data['city_ids'] = request('city_ids', '');
        $message_data['shipment_province_ids'] = request('shipment_province_ids', '');
        $message_data['shipment_city_ids'] = request('shipment_city_ids', '');
        $message_data['product_brand'] = request('product_brand', '');
        $message_data['collection_time_start_time'] = request('collection_time_start_time', '');
        $message_data['collection_time_end_time'] = request('collection_time_end_time', '');
        $message_data['online_posting_min_price'] = request('online_posting_min_price', '');
        $message_data['online_posting_max_price'] = request('online_posting_max_price', '');
        $message_data['is_ultra_low_price'] = request('is_ultra_low_price', '');
        $message_data['merge_city_ids'] = request('merge_city_ids', '');
        $message_data['merge_province_ids'] = request('merge_province_ids', 1);

        $low_price_goods_where = [];
        // 权限判断
        if ($message_data['is_admin'] != 1 && $message_data['company_id'] != 0) {
            $low_price_goods_where['company_id'] = $message_data['company_id'];
        } else {
            $low_price_goods_where['company_id']  = $message_data['admin_company_id'];
        }
        // 查询条件
        $map  = [];
        $job_page = isset($message_data['job_page']) ? $message_data['job_page'] : 1;
        $limit = 1000; //每次处理1000条
        $status    = $message_data['status'] ?? '';
        $start_time = $message_data['start_time'] ?? '';
        $end_time = $message_data['end_time'] ?? '';
        $product_name = $message_data['product_name'] ?? '';
        $product_names = $message_data['product_names'] ?? '';
        $first_responsible_person = $message_data['first_responsible_person'] ?? '';
        $responsible_person = $message_data['responsible_person'] ?? '';
        $platform = $message_data['platform'] ?? '';
        $company_name = $message_data['company_name'] ?? '';
        $store_name = $message_data['store_name'] ?? '';
        $anonymous_store_name  = request('anonymous_store_name', '');
        $store_names = $message_data['store_names'] ?? '';
        $source_responsible_person = $message_data['source_responsible_person'] ?? '';
        $processing_status = $message_data['processing_status'] ?? '';
        $product_specs = $message_data['product_specs'] ?? '';
        $online_posting_count = $message_data['online_posting_count'] ?? '';
        $category_name = $message_data['category_name'] ?? '';
        $province_ids = $message_data['province_ids'] ?? '';
        $city_ids = $message_data['city_ids'] ?? '';
        $shipment_province_ids = $message_data['shipment_province_ids'] ?? '';
        $shipment_city_ids = $message_data['shipment_city_ids'] ?? '';
        $product_brand = $message_data['product_brand'] ?? '';
        $is_ultra_low_price = $message_data['is_ultra_low_price'] ?? '';
        $online_posting_min_price = $message_data['online_posting_min_price'] ?? '';
        $online_posting_max_price = $message_data['online_posting_max_price'] ?? '';
        $collection_time_start_time = $message_data['collection_time_start_time'] ?? '';
        $collection_time_end_time = $message_data['collection_time_end_time'] ?? '';
        $merge_city_ids = $message_data['merge_city_ids'] ?? '';
        $merge_province_ids = $message_data['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 ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
        if ($store_name) $map[]   = ['store_name', 'like', "%$store_name%"];
        if ($anonymous_store_name) $map[]   = ['anonymous_store_name', 'like', "%$anonymous_store_name%"];
        if ($category_name) $map[] = ['category_name', 'like', "%$category_name%"];
        if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
        if ($online_posting_min_price) $map[] = ['online_posting_price', '>=', $online_posting_min_price];
        if ($online_posting_max_price) $map[] = ['online_posting_price', '<=', $online_posting_max_price];
        if ($is_ultra_low_price) $map[] = ['is_ultra_low_price', '=', $is_ultra_low_price];

        $admin_company_id = $message_data['admin_company_id'];
        $company_id = $message_data['company_id'];
        $is_admin = $message_data['is_admin']; //是否管理员操作 0=是1=否
        $user_id = $message_data['user_id'];

        $low_price_goods_where = [];
        // 权限判断
        if ($is_admin != 1 && $company_id != 0) {
            $low_price_goods_where['company_id'] = $company_id;
        } else {
            $low_price_goods_where['company_id']  = $admin_company_id;
        }
        $LowPriceGoodsModel = $LowPriceGoodsModel->where($low_price_goods_where);
        //多选平台查询
        if ($platform && is_string($platform)) {
            $platform = explode(',', $platform);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('platform', $platform);
        }
        //多选处理状态查询
        if ($processing_status && is_string($processing_status)) {
            $processing_status = explode(',', $processing_status);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('processing_status', $processing_status);
        }
        //多选状态查询
        if ($status && is_string($status)) {
            $status = explode(',', $status);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('status', $status);
        }
        //多选店铺名称查询
        if ($store_names && is_string($store_names)) {
            $store_names = explode(',', $store_names);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('store_name', $store_names);
        }
        //多选违规挂网次数查询
        if ($online_posting_count && is_string($online_posting_count)) {
            $online_posting_count = explode(',', $online_posting_count);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('online_posting_count', $online_posting_count);
        }
        //多选规格查询
        if ($product_specs && is_string($product_specs)) {
            $product_specs = explode(',', $product_specs);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('product_specs', $product_specs);
        }
        //多选商品查询
        if ($product_names && is_string($product_names)) {
            $product_names = explode(',', $product_names);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('product_name', $product_names);
        }
        //多选公司查询
        if ($company_name && is_string($company_name)) {
            $company_name = explode(',', $company_name);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('company_name', $company_name);
        }
        //多选第一责任人
        if ($first_responsible_person && is_string($first_responsible_person)) {
            $first_responsible_person = explode(',', $first_responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $first_responsible_person)->where('duty_type', 1)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选责任人
        if ($responsible_person && is_string($responsible_person)) {
            $responsible_person = explode(',', $responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $responsible_person)->where('duty_type', 2)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选溯源责任人
        if ($source_responsible_person && is_string($source_responsible_person)) {
            $source_responsible_person = explode(',', $source_responsible_person);
            $subQuery = $LowPriceGoodsMemberModel->whereIn('employee_id', $source_responsible_person)->where('duty_type', 3)->distinct('lowprice_product_logid')->select('lowprice_product_logid');
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query1) use ($subQuery) {
                $query1->select('lowprice_product_logid')->fromSub($subQuery, 'sub1');
            });
        }
        //多选省份
        if ($province_ids && is_string($province_ids)) {
            $province_ids = explode(',', $province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('province_id', $province_ids);
        }
        //多选城市
        if ($city_ids && is_string($city_ids)) {
            $city_ids = explode(',', $city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('city_id', $city_ids);
        }
        //多选店铺省
        if ($shipment_province_ids && is_string($shipment_province_ids)) {
            $shipment_province_ids = explode(',', $shipment_province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('shipment_province_id', $shipment_province_ids);
        }
        //多选店铺市
        if ($shipment_city_ids && is_string($shipment_city_ids)) {
            $shipment_city_ids = explode(',', $shipment_city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('shipment_city_id', $shipment_city_ids);
        }
        //多合并省份
        if ($merge_province_ids && is_string($merge_province_ids)) {
            $merge_province_ids = explode(',', $merge_province_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('merge_province_id', $merge_province_ids);
        }
        //多合并市
        if ($merge_city_ids && is_string($merge_city_ids)) {
            $merge_city_ids = explode(',', $merge_city_ids);
            $LowPriceGoodsModel = $LowPriceGoodsModel->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;
        }
        $result_count = 0;
        if ($is_admin != 1 && $company_id != 0) {
            $result_count = $LowPriceGoodsModel->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)
                ->count();
        } else {
            $result_count = $LowPriceGoodsModel->where($map)
                ->count();
        }

        if ($result_count == 0) return json_send(['code' => 'fail', 'msg' => '没有查询到数据', 'data' => '']);
        if ($result_count > 150000) return json_send(['code' => 'fail', 'msg' => '导出数据超过15万条，请缩小导出范围后再试', 'data' => '']);

        $key_name = 'ExportLowPriceGoodsJobs_' . $low_price_goods_where['company_id'];
        $export_data_info = Cache::get($key_name);
        if ($export_data_info) return json_send(['code' => 'fail', 'msg' => '导出任务正在执行中，请稍后再试', 'data' => '']);
        //创建缓存
        Cache::put($key_name, '1', 60 * 60 * 3);

        // 生成唯一文件ID
        $fileId                     = make_snow_flake();
        $message_data['file_id']    = $fileId;
        $fileName = '低价挂网商品数据' . $fileId . '.xlsx';
        $message_data['company_id']    = $low_price_goods_where['company_id'];
        $message_data['user_id']    = $message_data['user_id'];
        // ExportLowPriceGoodsJobs::dispatch($message_data);
        ExportLowPriceGoodsJobs::dispatchSync($message_data);
        return json_send(['code' => 'success', 'msg' => '导出任务添加成功', 'data' => ['file_id' => $fileId, 'file_name' => $fileName]]);
    }


    /**
     * 详情
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-08
     */
    public function detail(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, 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 = $LowPriceGoodsModel->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, LowPriceGoodsModel $LowPriceGoodsModel)
    {
        $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 = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs']];
        // 权限判断
        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 = $LowPriceGoodsModel->where($map)->first();
        if ($data)     return json_send(['code' => 'error', 'msg' => '记录已存在']);
        // 写入数据表

        $result     =  $LowPriceGoodsModel->addLowPriceGoods($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, LowPriceGoodsModel $LowPriceGoodsModel)
    {
        $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 = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs']];
        // 权限判断
        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 = $LowPriceGoodsModel->where($map)->where('id', '!=', $id)->first();
        if ($data)     return json_send(['code' => 'error', 'msg' => '记录已存在']);
        // 更新数据表
        $where = ['id' => $id];
        $result =  $LowPriceGoodsModel->updateLowPriceGoods($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, LowPriceGoodsModel $LowPriceGoodsModel)
    {
        // 验证参数
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '记录不存在']);
        $LowPriceGoods->status = $status;
        $LowPriceGoods->update_time = time();
        // 执行修改
        $result            =  $LowPriceGoods->save();
        // 提示新增失败
        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, LowPriceGoodsModel $LowPriceGoodsModel)
    {
        // 验证参数
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '记录不存在']);
        $LowPriceGoods->processing_status = $processing_status;
        $LowPriceGoods->update_time = time();
        // 执行修改
        $result            =  $LowPriceGoods->save();
        // 提示新增失败
        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, LowPriceGoodsModel $LowPriceGoodsModel)
    {
        // 验证参数
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '记录不存在']);
        // 执行删除
        $result =  $LowPriceGoods->delete();
        // 提示删除失败
        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;
        }
        $start_time =  Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
        $end_time = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
        $message_data = ['company_id' => $company_id, 'page' => '1', 'limit' => '10000', 'start_time' => $start_time, 'end_time' => $end_time];
        //执行低价挂网商品数据清洗任务
        ScrapeDataProductJobs::dispatch($message_data);
        // ScrapeDataProductJobs::dispatchSync($message_data);
        // 告知结果
        return             json_send(['code' => 'success', 'msg' => '执行成功']);
    }

    /**
     * 处理买药中的业务
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-23
     * 
     */
    public function buying_business(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsRecordModel $LowPriceGoodsRecordModel)
    {
        // 验证参数
        $request->scene('buying_business')->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=否
        $access_token = request('access_token', '');
        $admin_id = $access_token['uid'];
        // 接收数据
        $all_data = request()->all();
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '违规记录不存在']);
        if ($LowPriceGoods->processing_status != '1') return json_send(['code' => 'error', 'msg' => '当前状态不是待处理，流程调用错误']);
        if ($all_data['processing_status'] != '2') return json_send(['code' => 'error', 'msg' => '流程状态参数值错误']);
        // 查询是否存在流程中的记录
        $map = ['lowprice_product_logid' => $id, 'processing_status' => $all_data['processing_status']];
        $record = $LowPriceGoodsRecordModel->where($map)->first();
        if ($record) return json_send(['code' => 'error', 'msg' => '当前状态已存在流程中，请勿重复提交']);
        $record_content = [
            'purchase_quantity' => $all_data['purchase_quantity'], //购买数量
            'totle_amount' => $all_data['totle_amount'], //总金额
            'buy_date' => $all_data['buy_date'], //购买日期
            'screenshot_images' => $all_data['screenshot_images'], // 截图图片
        ];
        // 写入流程记录
        $insert_data = [
            'lowprice_product_logid' => $id,
            'admin_id' => $admin_id,
            'record_content' => json_encode($record_content),
            'processing_status' => $all_data['processing_status'], //处理状态1=待处理2=购买中3=已溯源4=回收凭据已上传5=已回收6=拒绝回收7=已下架8=无法处理
        ];
        DB::beginTransaction();
        try {
            $LowPriceGoodsRecordModel->addLowPriceGoodsRecord_content($insert_data);
            //更新违规记录状态
            $LowPriceGoods->processing_status = $all_data['processing_status'];
            $LowPriceGoods->update_time = time();
            $LowPriceGoods->save();
            DB::commit();
            return json_send(['code' => 'success', 'msg' => '流转成功']);
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return json_send(['code' => 'error', 'msg' => '流转失败', 'data' => $e->getMessage()]);
        }
    }


    /**
     * 处理已下架/无法处理中的业务
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-23
     * 
     */
    public function unprocessed_business(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsRecordModel $LowPriceGoodsRecordModel)
    {
        // 验证参数
        $request->scene('unprocessed_business')->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=否
        $access_token = request('access_token', '');
        $admin_id = $access_token['uid'];
        // 接收数据
        $all_data = request()->all();
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '违规记录不存在']);
        if ($LowPriceGoods->processing_status != '1') return json_send(['code' => 'error', 'msg' => '当前状态不是待处理，流程调用错误']);
        if (!in_array($all_data['processing_status'], [7, 8])) return json_send(['code' => 'error', 'msg' => '流程状态参数值错误']);
        // 查询是否存在流程中的记录
        $map = ['lowprice_product_logid' => $id, 'processing_status' => $all_data['processing_status']];
        $record = $LowPriceGoodsRecordModel->where($map)->first();
        if ($record) return json_send(['code' => 'error', 'msg' => '当前状态已存在流程中，请勿重复提交']);
        $record_content = [
            'description' => $all_data['description'], //情况描述
            'screenshot_images' => $all_data['screenshot_images'], // 截图图片
        ];
        // 写入流程记录
        $insert_data = [
            'lowprice_product_logid' => $id,
            'admin_id' => $admin_id,
            'record_content' => json_encode($record_content),
            'processing_status' => $all_data['processing_status'], //处理状态1=待处理2=购买中3=已溯源4=回收凭据已上传5=已回收6=拒绝回收7=已下架8=无法处理
        ];
        DB::beginTransaction();
        try {
            $LowPriceGoodsRecordModel->addLowPriceGoodsRecord_content($insert_data);
            //更新违规记录状态
            $LowPriceGoods->processing_status = $all_data['processing_status'];
            $LowPriceGoods->update_time = time();
            $LowPriceGoods->save();
            DB::commit();
            return json_send(['code' => 'success', 'msg' => '流转成功']);
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return json_send(['code' => 'error', 'msg' => '流转失败', 'data' => $e->getMessage()]);
        }
    }

    /**
     * 处理已溯源中的业务
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-23
     * 
     */
    public function trace_business(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsRecordModel $LowPriceGoodsRecordModel)
    {
        // 验证参数
        $request->scene('trace_business')->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=否
        $access_token = request('access_token', '');
        $admin_id = $access_token['uid'];
        // 接收数据
        $all_data = request()->all();
        $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;
        }
        $LowPriceGoods = $LowPriceGoodsModel->where($where)->first();
        if (!$LowPriceGoods) return json_send(['code' => 'error', 'msg' => '违规记录不存在']);
        if ($LowPriceGoods->processing_status != '2') return json_send(['code' => 'error', 'msg' => '当前状态不是购买中，流程调用错误']);
        if ($all_data['processing_status'] != '3') return json_send(['code' => 'error', 'msg' => '流程状态参数值错误']);
        // 查询是否存在流程中的记录
        $map = ['lowprice_product_logid' => $id, 'processing_status' => $all_data['processing_status']];
        $record = $LowPriceGoodsRecordModel->where($map)->first();
        if ($record) return json_send(['code' => 'error', 'msg' => '当前状态已存在流程中，请勿重复提交']);
        $record_content = [
            'trace_company_name' => $all_data['trace_company_name'], //溯源公司名称
            'trace_description' => $all_data['trace_description'], //溯源情况描述
            'screenshot_images' => $all_data['screenshot_images'], // 截图图片
        ];
        // 写入流程记录
        $insert_data = [
            'lowprice_product_logid' => $id,
            'admin_id' => $admin_id,
            'record_content' => json_encode($record_content),
            'processing_status' => $all_data['processing_status'], //处理状态1=待处理2=购买中3=已溯源4=回收凭据已上传5=已回收6=拒绝回收7=已下架8=无法处理
        ];
        DB::beginTransaction();
        try {
            $LowPriceGoodsRecordModel->addLowPriceGoodsRecord_content($insert_data);
            //更新违规记录状态
            $LowPriceGoods->processing_status = $all_data['processing_status'];
            $LowPriceGoods->update_time = time();
            $LowPriceGoods->save();
            DB::commit();
            return json_send(['code' => 'success', 'msg' => '流转成功']);
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return json_send(['code' => 'error', 'msg' => '流转失败', 'data' => $e->getMessage()]);
        }
    }


    /**
     * 下载导入模板
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-31
     * 
     */
    public function download_template()
    {
        // 创建一个新的 Spreadsheet 对象
        $spreadsheet = new Spreadsheet();
        $sheet = $spreadsheet->getActiveSheet();

        //合并单元格
        $sheet->mergeCells('A1:Y1');
        $sheet->setCellValue('A1', '低价挂网商品导入模板'); // 设置合并后的单元格内容
        // 获取合并后的单元格样式对象
        $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', '快照URL');
        $sheet->setCellValue('M2', '累计挂网次数');
        $sheet->setCellValue('N2', '连续挂网次数');
        $sheet->setCellValue('O2', '超低监控价格');
        $sheet->setCellValue('P2', '链接地址*');
        $sheet->setCellValue('Q2', '店铺名称*');
        $sheet->setCellValue('R2', '匿名店铺');
        $sheet->setCellValue('S2', '公司名称*');
        $sheet->setCellValue('T2', '商业类型');
        $sheet->setCellValue('U2', '信用代码');
        $sheet->setCellValue('V2', '公司省');
        $sheet->setCellValue('W2', '公司市');
        $sheet->setCellValue('X2', '店铺省');
        $sheet->setCellValue('Y2', '店铺市');
        $sheet->setCellValue('Z2', '采集时间(Y-m-d H:i:s)*');
        // 生成 Excel 文件
        $writer = new Xlsx($spreadsheet);

        // 直接输出到浏览器（下载）
        $filename = '低价挂网商品导入模板.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;
    }

    /**
     * 导入Excel数据
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-31
     * 
     */
    public function import_data(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, EmployeeModel $EmployeeModel, CitysModel $CitysModel)
    {
        $request->scene('import_data')->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=否
        $file = $request->file('file');
        // 加载Excel文件
        $spreadsheet = IOFactory::load($file->getPathname());
        $sheet = $spreadsheet->getActiveSheet();
        // 获取所有数据
        $data = $sheet->toArray();
        if (empty($data) || count($data) < 2) return json_send(['code' => 'error', 'msg' => '导入数据为空']);
        $result = $EmployeeModel->select(['id', 'name'])->get()->keyBy('name')->toarray();
        $platform_data = $LowPriceGoodsModel->platform_data();
        $province_id_data = $CitysModel->get_province_id_list();
        $city_id_data = $CitysModel->get_city_id_list();

        // 过滤空行
        $data = array_filter($data, function ($row) {
            // 过滤掉所有值都为空的行
            return !empty(array_filter($row, function ($value) {
                return !is_null($value) && $value !== '';
            }));
        });

        DB::beginTransaction();
        try {

            foreach ($data as $key => $item) {
                $key_num = $key + 1;
                if ($key < 2) continue;
                //强制必传参数校验
                $res_data = $this->import_data_check($key, $item);
                if ($res_data) return json_send($res_data);
                $first_responsible_person_id = [];
                $first_responsible_person_name =   $item[0];
                if ($first_responsible_person_name) {
                    $first_responsible_person_name = explode(',', $first_responsible_person_name);
                    foreach ($first_responsible_person_name as $k => $v) {
                        $v = trim($v);
                        if (isset($result[$v])) {
                            $first_responsible_person_id[] = $result[$v]['id'];
                        }
                    }
                }
                $responsible_person_id = [];
                $responsible_person_name =   $item[1];
                if ($responsible_person_name) {
                    $responsible_person_name = explode(',', $responsible_person_name);
                    foreach ($responsible_person_name as $k => $v) {
                        $v = trim($v);
                        if (isset($result[$v])) {
                            $responsible_person_id[] = $result[$v]['id'];
                        }
                    }
                }
                $source_responsible_person_id = [];
                $source_responsible_person_name = $item[23];
                // if ($source_responsible_person_name) {
                //     $source_responsible_person_name = explode(',', $source_responsible_person_name);
                //     foreach ($source_responsible_person_name as $k => $v) {
                //         $v = trim($v);
                //         if (isset($result[$v])) {
                //             $source_responsible_person_id[] = $result[$v]['id'];
                //         }
                //     }
                // }
                $province_name = $item[21];
                //特殊地区1级移除市
                if ($province_name && in_array($province_name, ['北京市', '天津市', '上海市', '重庆市'])) {
                    //移除市这个字符
                    $province_name = trim(str_replace('市', '', $province_name));
                } else if ($province_name && in_array($province_name, ['北京', '天津', '上海', '重庆'])) {
                } else if ($province_name && in_array($province_name, ['内蒙古', '广西', '西藏', '新疆', '宁夏'])) {
                    switch ($province_name) {
                        case '内蒙古':
                            $province_name = '内蒙古自治区';
                            break;
                        case '广西':
                            $province_name = '广西壮族自治区';
                            break;
                        case '西藏':
                            $province_name = '西藏自治区';
                            break;
                        case '新疆':
                            $province_name = '新疆维吾尔自治区';
                            break;
                        case '宁夏':
                            $province_name = '宁夏回族自治区';
                            break;
                    }
                } else if ($province_name && in_array($province_name, ['内蒙古自治区', '广西壮族自治区', '西藏自治区', '新疆维吾尔自治区', '宁夏回族自治区'])) {
                } else if (strpos($province_name, '省') === false) {
                    //是否存在市省，如果不存在则补全
                    if (!empty($province_name) && strpos($province_name, '省') === false) {
                        $province_name = $province_name . '省';
                    }
                }

                if (!empty($province_name) && !isset($province_id_data[$province_name])) return json_send(['code' => 'error', 'msg' => "第{$key_num}行省份信息不完整", 'data' => $item]);
                $city_name = $item[22];
                if (!empty($city_name)  && !isset($city_id_data[$city_name])) return json_send(['code' => 'error', 'msg' => "第{$key_num}行城市信息不完整", 'data' => $item]);


                $shipment_province_name = isset($item[23]) ? $item[23] : '';
                //特殊地区1级移除市
                if ($shipment_province_name && in_array($province_name, ['北京市', '天津市', '上海市', '重庆市'])) {
                    //移除市这个字符
                    $shipment_province_name = trim(str_replace('市', '', $shipment_province_name));
                } else if ($shipment_province_name && in_array($shipment_province_name, ['北京', '天津', '上海', '重庆'])) {
                } else if ($shipment_province_name && in_array($shipment_province_name, ['内蒙古', '广西', '西藏', '新疆', '宁夏'])) {
                    switch ($shipment_province_name) {
                        case '内蒙古':
                            $shipment_province_name = '内蒙古自治区';
                            break;
                        case '广西':
                            $shipment_province_name = '广西壮族自治区';
                            break;
                        case '西藏':
                            $shipment_province_name = '西藏自治区';
                            break;
                        case '新疆':
                            $shipment_province_name = '新疆维吾尔自治区';
                            break;
                        case '宁夏':
                            $shipment_province_name = '宁夏回族自治区';
                            break;
                    }
                } else if ($shipment_province_name && in_array($shipment_province_name, ['内蒙古自治区', '广西壮族自治区', '西藏自治区', '新疆维吾尔自治区', '宁夏回族自治区'])) {
                } else if (strpos($shipment_province_name, '省') === false) {
                    //是否存在市省，如果不存在则补全
                    if (strpos($shipment_province_name, '省') === false) {
                        $shipment_province_name = $shipment_province_name . '省';
                    }
                }
                $shipment_province_id = '0';
                if (!isset($province_id_data[$shipment_province_name])) {
                    $shipment_province_name = '';
                } else {
                    $shipment_province_id = $province_id_data[$shipment_province_name]['id'];
                }
                $shipment_city_id = '0';
                $shipment_city_name = isset($item[24]) ? $item[24] : '';
                if (!isset($city_id_data[$shipment_city_name])) {
                    $shipment_city_name = '';
                } else {
                    $shipment_city_id = $city_id_data[$shipment_city_name]['id'];
                }

                // 权限判断
                if ($is_admin != 1 && $company_id != 0) {
                    $insert_product_data['company_id'] = $company_id;
                } else {
                    $insert_product_data['company_id']  = $admin_company_id;
                }
                $platform_id = isset($platform_data[$item[2]]) ? $platform_data[$item[2]] : '0'; // 平台ID
                if ($platform_id == 0) return json_send(['code' => 'error', 'msg' => "第{$key_num}行平台信息不正确", 'data' => $item]);

                $insert_product_data['first_responsible_person'] = !empty($first_responsible_person_id) ? implode(',', $first_responsible_person_id) : ''; //第一责任人ID集合
                $insert_product_data['responsible_person'] = !empty($responsible_person_id) ? implode(',', $responsible_person_id) : ''; //责任人ID集合
                $insert_product_data['platform'] = isset($platform_data[$item[2]]) ? $platform_data[$item[2]] : '0'; // 平台
                $insert_product_data['category_name'] = $item[3] ? $item[3] : ''; // 商品分类
                $insert_product_data['product_brand'] = isset($item[4]) ? $item[4] : ''; // 品牌名称
                $insert_product_data['product_name'] = $item[5]; // 商品名称
                $insert_product_data['product_specs'] = $item[6]; // 商品规格
                $insert_product_data['suggested_price'] = $item[7]; // 监控价格
                $insert_product_data['online_posting_price'] = $item[8]; // 挂网价格
                $insert_product_data['sales'] = isset($item[9]) ? $item[9] : 0; // 销量
                $insert_product_data['inventory'] = isset($item[10]) ? $item[10] : 0; // 库存
                $insert_product_data['snapshot_url'] = isset($item[11]) ? $item[11] : ''; // 快照URL
                $insert_product_data['online_posting_count'] = isset($item[12]) ? $item[12] : 1; // 累计挂网次数
                $insert_product_data['continuous_listing_count'] = isset($item[13]) ? $item[13] : 1; // 连续挂网次数
                $insert_product_data['ultra_low_price'] = isset($item[14]) && is_numeric($item[14]) ? $item[14] : '0'; // 超低监控价格
                $insert_product_data['is_ultra_low_price'] = isset($item[14]) && is_numeric($item[14]) && $item[14] < $item[8] ? 1 : 0; // 是否超低价0=否1=是
                $insert_product_data['link_url'] = $item[15]; // 链接地址
                $insert_product_data['store_name'] = $item[16]; // 店铺名称
                $insert_product_data['anonymous_store_name'] = isset($item[17]) ? $item[17] : ''; // 匿名店铺名称
                $insert_product_data['company_name'] = $item[18]; // 公司名称
                $insert_product_data['company_category_name'] = isset($item[19]) ? $item[19] : ''; // 公司分类
                $insert_product_data['social_credit_code'] = isset($item[20]) ? $item[20] : ''; // 信用代码
                $insert_product_data['province_name'] = isset($item[21]) ? $item[21] : ''; // 省份
                $insert_product_data['province_id'] = isset($province_id_data[$province_name]) ? $province_id_data[$province_name]['id'] : 0; // 省份ID
                $insert_product_data['city_name'] = isset($item[22]) ? $item[22] : ''; // 城市
                $insert_product_data['city_id'] = isset($city_id_data[$city_name]) ? $city_id_data[$city_name]['id'] : 0; // 城市ID
                $insert_product_data['area_info'] = ''; // 详细地址
                $insert_product_data['source_responsible_person'] = !empty($source_responsible_person_id) ? implode(',', $source_responsible_person_id) : ''; //溯源责任人ID集合
                $insert_product_data['processing_status'] = 1; //处理状态1=待处理2=购买中3=已溯源4=回收凭据已上传5=已回收6=拒绝回收7=已下架8=无法处理
                $insert_product_data['status'] = 0; //状态0=有效=无效
                $insert_product_data['insert_time'] = time();
                $insert_product_data['source_id'] = 0; // 原始数据ID
                $insert_product_data['shipment_province_id'] = $shipment_province_id; // 店铺省id
                $insert_product_data['shipment_province_name'] = $shipment_province_name; // 店铺省
                $insert_product_data['shipment_city_id'] = $shipment_city_id; // 店铺市id
                $insert_product_data['shipment_city_name'] = $shipment_city_name; // 店铺市
                $insert_product_data['collection_time'] = strtotime($item[25]); // 采集时间
                $insert_product_data['scrape_date'] = date('Y-m-d', strtotime($item[25])); // 检索采集日期
                //插入数据
                $LowPriceGoodsModel->addLowPriceGoods($insert_product_data, true);
            }
            DB::commit();
            return json_send(['code' => 'success', 'msg' => '导入成功']);
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return json_send(['code' => 'error', 'msg' => '导入失败', 'data' => $e->getMessage()]);
        }
    }

    /**
     * 导入Excel数据必传参数校验
     * @author    唐远望
     * @version   1.0
     * @date      2025-12-31
     * 
     */
    private function import_data_check($key, $item)
    {
        $key = $key + 1;
        if (!$item[2]) {
            return ['code' => 'error', 'msg' => "第{$key}行平台不能为空", 'data' => $item];
        }
        if (!$item[5]) {
            return ['code' => 'error', 'msg' => "第{$key}行商品名称不能为空", 'data' => $item];
        }
        if (!$item[6]) {
            return ['code' => 'error', 'msg' => "第{$key}行商品规格不能为空", 'data' => $item];
        }
        if (!$item[7]) {
            return ['code' => 'error', 'msg' => "第{$key}行监控价格不能为空", 'data' => $item];
        }
        if (!$item[8]) {
            return ['code' => 'error', 'msg' => "第{$key}行挂网价格不能为空", 'data' => $item];
        }
        if (!$item[15]) {
            return ['code' => 'error', 'msg' => "第{$key}行链接地址不能为空", 'data' => $item];
        }
        if (!$item[16]) {
            return ['code' => 'error', 'msg' => "第{$key}行店铺名称不能为空", 'data' => $item];
        }
        if (!$item[18]) {
            return ['code' => 'error', 'msg' => "第{$key}行公司名称不能为空", 'data' => $item];
        }
        // if (!$item[20]) {
        //     return ['code' => 'error', 'msg' => "第{$key}行信用代码不能为空", 'data' => $item];
        // }
        // if (!$item[21]) {
        //     return ['code' => 'error', 'msg' => "第{$key}行省份不能为空", 'data' => $item];
        // }
        // if (!$item[22]) {
        //     return ['code' => 'error', 'msg' => "第{$key}行城市不能为空", 'data' => $item];
        // }
        if (!$item[25]) {
            return ['code' => 'error', 'msg' => "第{$key}行采集时间不能为空", 'data' => $item];
        } else {
            //校验格式是否为Y-m-d H:i:s
            if (!preg_match('/^[0-9]{4}-[0-9]{2}-[0-9]{2} [0-9]{2}:[0-9]{2}:[0-9]{2}$/', $item[25])) {
                return ['code' => 'error', 'msg' => "第{$key}行采集时间格式不正确", 'data' => $item];
            }
            if (strtotime($item[25]) > time()) {
                return ['code' => 'error', 'msg' => "第{$key}行采集时间不能大于当前日期", 'data' => $item];
            }
        }
    }
}