zhijiayun/app/Models/Manager/Process/ViolationProduct.php

<?php

namespace App\Models\Manager\Process;

use Illuminate\Database\Eloquent\Factories\HasFactory;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\DB;
use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberModel;
use App\Facades\Servers\Logs\Log;
use App\Models\Manager\Process\Notices as NoticesModel;
use App\Models\Manager\Personnel\Employee as EmployeeModel;

/**
 * 违规处理-违规商品模型
 * @author: 唐远望
 * @version: 1.0
 * @date: 2025-12-08
 */
class ViolationProduct extends Model
{
    use HasFactory;
    // 与模型关联的表名
    protected $table = 'process_violation_product';
    // 是否主动维护时间戳
    public $timestamps = false;
    // 定义时间戳字段名
    // const CREATED_AT = 'insert_time';
    // const UPDATED_AT = 'update_time';

    /**
     * 平台定义
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-31
     */
    public function platform_data()
    {
        //平台0=全部，1=淘宝，2=京东，3=拼多多，4=美团，5=药师帮，6=1药城，7=药九九,8=药易购，9=药帮忙，10=熊猫药药11=药房网
        $platform_data = [
            '全部' => '0',
            '淘宝' => '1',
            '京东' => '2',
            '拼多多' => '3',
            '美团' => '4',
            '药师帮' => '5',
            '1药城' => '6',
            '药九九' => '7',
            '药易购' => '8',
            '药帮忙' => '9',
            '熊猫药药' => '10',
            '药房网' => '11'
        ];
        return $platform_data;
    }

    /**
     * 添加
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     */
    public function addViolationProduct_content($data)
    {
        $insert_data = [
            'company_id' => $data['company_id'],
            'source_id' => $data['source_id'],
            'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
            'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
            'platform'    => $data['platform'],
            'company_name'    => $data['company_name'],
            'product_brand'   => isset($data['product_brand']) ? $data['product_brand'] : '',
            'product_name'    => $data['product_name'],
            'product_specs'    => $data['product_specs'],
            'online_posting_count'    => isset($data['online_posting_count']) && is_numeric($data['online_posting_count']) ? $data['online_posting_count'] : 1,
            'continuous_listing_count'    => isset($data['continuous_listing_count']) && is_numeric($data['continuous_listing_count']) ? $data['continuous_listing_count'] : 1,
            'social_credit_code'    => $data['social_credit_code'],
            'province_id'    => $data['province_id'],
            'province_name'    => isset($data['province_name']) ? $data['province_name'] : '',
            'city_id'    => $data['city_id'],
            'city_name'    => isset($data['city_name']) ? $data['city_name'] : '',
            'area_info' => $data['area_info'],
            'link_url'    => $data['link_url'],
            'store_name'    => $data['store_name'],
            'anonymous_store_name' => isset($data['anonymous_store_name']) ? $data['anonymous_store_name'] : '',
            'source_responsible_person'    => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
            'category_name' => $data['category_name'],
            'company_category_name' => $data['company_category_name'],
            'processing_status' => '1',
            'insert_time' => time(),
            'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
            'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
            'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
            'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
            'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
            'shipment_city_name' => isset($data['shipment_city_name']) ? $data['shipment_city_name'] : '', // 发货城市
            'merge_city_id' => $data['merge_city_id'],
            'merge_province_id' => $data['merge_province_id'],
            'merge_city_name' => $data['merge_city_name'],
            'merge_province_name' => $data['merge_province_name'],
            'snapshot_url' => isset($data['snapshot_url']) ? $data['snapshot_url'] : '', // 商品快照地址
            'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
        ];
        $ViolationProduct_id = $this->insertGetId($insert_data);
        return $ViolationProduct_id;
    }


    /**
     * 写入数据
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $data
     * @return bool
     */
    public function addViolationProduct($data, $is_import = false)
    {
        if ($is_import == false) {
            //检查是否重复清洗
            $source_data_log = $this->where([['company_id','=', $data['company_id']],['source_id','=', $data['source_id']]])->count();
            if(!empty($source_data_log) && $source_data_log > 0) return true;
            // 如果是美团跟拼多多链接为动态
            if (in_array($data['platform'], ['3', '4'])) {
                //去重规则：品牌方公司ID+平台ID+公司名称+店铺名称+品牌名称+商品名称+规格+采集日期(针对采集)
                $source_where[] = ['company_id', '=', $data['company_id']]; //品牌方公司ID
                $source_where[] = ['platform', '=', $data['platform']]; //平台ID
                $source_where[] = ['company_name', '=', $data['company_name']]; //公司名称
                $source_where[] = ['store_name', '=', $data['store_name']]; //店铺名称
                $source_where[] = ['product_brand', '=', $data['product_brand']]; //品牌名称
                $source_where[] = ['product_name', '=', $data['product_name']]; //商品名称
                $source_where[] = ['product_specs', '=', $data['product_specs']]; //规格
                $source_where[] = ['scrape_date', '=', $data['scrape_date']]; //采集日期
            } else {
                $source_where[] = ['company_id', '=', $data['company_id']]; //品牌方公司ID
                $source_where[] = ['link_url', '=', $data['link_url']]; //链接地址
                $source_where[] = ['scrape_date', '=', $data['scrape_date']]; //采集日期
            }
            $source_id_log = $this->where($source_where)->count();
            if ($source_id_log > 0) {
                return true;
            }
        }
        DB::beginTransaction();
        try {
            //执行挂网数据统计
            $data = $this->handleCountData($data);
            $insert_data = [
                'company_id' => $data['company_id'],
                'source_id' => $data['source_id'],
                'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
                'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
                'platform'    => $data['platform'],
                'company_name'    => $data['company_name'],
                'product_brand'   => isset($data['product_brand']) ? $data['product_brand'] : '',
                'product_name'    => $data['product_name'],
                'product_specs'    => $data['product_specs'],
                'online_posting_count'    => isset($data['online_posting_count']) && is_numeric($data['online_posting_count']) ? $data['online_posting_count'] : 1,
                'continuous_listing_count'    => isset($data['continuous_listing_count']) && is_numeric($data['continuous_listing_count']) ? $data['continuous_listing_count'] : 1,
                'social_credit_code'    => $data['social_credit_code'],
                'province_id'    => $data['province_id'],
                'province_name'    => isset($data['province_name']) ? $data['province_name'] : '',
                'city_id'    => $data['city_id'],
                'city_name'    => isset($data['city_name']) ? $data['city_name'] : '',
                'area_info' => $data['area_info'],
                'link_url'    => $data['link_url'],
                'store_name'    => $data['store_name'],
                'anonymous_store_name' => isset($data['anonymous_store_name']) ? $data['anonymous_store_name'] : '',
                'source_responsible_person'    => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
                'category_name' => $data['category_name'],
                'company_category_name' => $data['company_category_name'],
                'processing_status' => '1',
                'insert_time' => time(),
                'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
                'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
                'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
                'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
                'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
                'shipment_city_name' => isset($data['shipment_city_name']) ? $data['shipment_city_name'] : '', // 发货城市
                'merge_city_id' => $data['merge_city_id'],
                'merge_province_id' => $data['merge_province_id'],
                'merge_city_name' => $data['merge_city_name'],
                'merge_province_name' => $data['merge_province_name'],
                'snapshot_url' => isset($data['snapshot_url']) ? $data['snapshot_url'] : '', // 商品快照地址
                'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
            ];
            $ViolationProduct_id = $this->insertGetId($insert_data);
            $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];
            $first_responsible_person_data = [];
            if (count($first_responsible_persons) > 0) {
                //去除重复的责任人
                $first_responsible_persons = array_unique($first_responsible_persons);
                //移除数组内的空值
                $first_responsible_persons = array_filter($first_responsible_persons);
                $EmployeeModel = new EmployeeModel();
                $employee_user_list = $EmployeeModel->whereIn('id', $first_responsible_persons)->select(['id', 'name'])->get()->toarray();
                $employee_user_list_name = [];
                if (!empty($employee_user_list)) {
                    foreach ($employee_user_list as $key => $employee_user_info) {
                        $employee_id = $employee_user_info['id'];
                        $employee_user_list_name[$employee_id] = $employee_user_info['name'];
                    }
                }
                foreach ($first_responsible_persons as $key => $employee_id) {
                    //如果不是数字或者为空，则跳过
                    if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id))  continue;
                    $first_responsible_person_data[] = [
                        'violation_product_logid' => $ViolationProduct_id,
                        'employee_id' => $employee_id,
                        'employee_name' => isset($employee_user_list_name[$employee_id]) ? $employee_user_list_name[$employee_id] : '',
                        'duty_type'    => 1, //责任类型1=第一责任人,2=责任人,3=溯源责任人
                    ];
                }
            }
            $ViolationProductMemberModel = new ViolationProductMemberModel();
            $ViolationProductMemberModel->insert($first_responsible_person_data);
            $responsible_persons = $data['responsible_person'] != '' ? explode(',', $data['responsible_person']) : [];
            $responsible_person_data = [];
            if (count($responsible_persons) > 0) {
                //去除重复的责任人
                $responsible_persons = array_unique($responsible_persons);
                //移除数组内的空值
                $responsible_persons = array_filter($responsible_persons);
                $EmployeeModel = new EmployeeModel();
                $employee_user_list = $EmployeeModel->whereIn('id', $responsible_persons)->select(['id', 'name'])->get()->toarray();
                $employee_user_list_name = [];
                if (!empty($employee_user_list)) {
                    foreach ($employee_user_list as $key => $employee_user_info) {
                        $employee_id = $employee_user_info['id'];
                        $employee_user_list_name[$employee_id] = $employee_user_info['name'];
                    }
                }
                foreach ($responsible_persons as $key => $employee_id) {
                    //如果不是数字或者为空，则跳过
                    if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id))  continue;
                    $responsible_person_data[] = [
                        'violation_product_logid' => $ViolationProduct_id,
                        'employee_id' => $employee_id,
                        'employee_name' => isset($employee_user_list_name[$employee_id]) ? $employee_user_list_name[$employee_id] : '',
                        'duty_type'    => 2, //责任类型1=第一责任人,2=责任人,3=溯源责任人
                    ];
                }
            }
            $ViolationProductMemberModel = new ViolationProductMemberModel();
            $ViolationProductMemberModel->insert($responsible_person_data);
            $source_responsible_persons = $data['source_responsible_person'] != '' ? explode(',', $data['source_responsible_person']) : [];
            $source_responsible_person_data = [];
            if (count($source_responsible_persons) > 0) {
                //去除重复的责任人
                $source_responsible_persons = array_unique($source_responsible_persons);
                //移除数组内的空值
                $source_responsible_persons = array_filter($source_responsible_persons);
                $EmployeeModel = new EmployeeModel();
                $employee_user_list = $EmployeeModel->whereIn('id', $source_responsible_persons)->select(['id', 'name'])->get()->toarray();
                $employee_user_list_name = [];
                if (!empty($employee_user_list)) {
                    foreach ($employee_user_list as $key => $employee_user_info) {
                        $employee_id = $employee_user_info['id'];
                        $employee_user_list_name[$employee_id] = $employee_user_info['name'];
                    }
                }
                foreach ($source_responsible_persons as $key => $employee_id) {
                    //如果不是数字或者为空，则跳过
                    if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id))  continue;
                    $source_responsible_person_data[] = [
                        'violation_product_logid' => $ViolationProduct_id,
                        'employee_id' => $employee_id,
                        'employee_name' => isset($employee_user_list_name[$employee_id]) ? $employee_user_list_name[$employee_id] : '',
                        'duty_type'    => 3, //责任类型1=第一责任人,2=责任人,3=溯源责任人
                    ];
                }
            }
            $ViolationProductMemberModel = new ViolationProductMemberModel();
            $ViolationProductMemberModel->insert($source_responsible_person_data);
            //添加通知
            // $this->addNotices($insert_data, $ViolationProduct_id);
            DB::commit();
            return true;
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            Log::info('job_error', '数据清洗-新增违规商品处理记录失败', ['data' => $data, 'error' => $e->getMessage()]);
            return false;
        }
    }


        function getLastSamplingInfo($currentWeek, $samplingCycle)
    {
        // 获取所有小于当前星期的配置
        $previousWeeks = array_filter($samplingCycle, function ($week) use ($currentWeek) {
            return $week < $currentWeek;
        });

        if (!empty($previousWeeks)) {
            // 存在小于当前星期的配置，取最大值
            $lastWeek = max($previousWeeks);
            $daysToSubtract = $currentWeek - $lastWeek;
        } else {
            // 不存在（当前是最小的），取最大的配置星期（跨周）
            $lastWeek = max($samplingCycle);
            $daysToSubtract = $currentWeek + (7 - $lastWeek);
        }

        return [
            'last_week' => $lastWeek,
            'days_to_subtract' => $daysToSubtract
        ];
    }



    /**
     * 处理连续挂网&累计挂网数据统计
     * @author  唐远望
     * @version 1.0
     * @date    2026-05-07
     * 
     */
    public function handleCountData($product_data_info)
    {
        //查询当前商品上次连续挂网次数
        if (in_array($product_data_info['platform'], ['3', '4'])) {
            $source_last_time_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
            $source_last_time_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
            $source_last_time_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
            $source_last_time_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
            $source_last_time_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
            $source_last_time_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
            $source_last_time_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
            $source_last_time_where[] = ['scrape_date', '<', $product_data_info['scrape_date']]; //采集日期
        } else {
            $source_last_time_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
            $source_last_time_where[] = ['link_url', '=', $product_data_info['link_url']]; //链接地址
            $source_last_time_where[] = ['scrape_date', '<', $product_data_info['scrape_date']]; //采集日期
        }
        $online_posting_count = $this->where($source_last_time_where)->count();
        $product_data_info['online_posting_count'] = $online_posting_count + 1; //累计挂网次数+1
        //连续挂网默认值为1
        $product_data_info['continuous_listing_count'] = 1;
        $collect_config_info = isset($product_data_info['collect_config_info']) ? $product_data_info['collect_config_info'] : ''; //采集配置信息
        if (trim($collect_config_info) == '') return $product_data_info;
        $collect_config_info = json_decode($collect_config_info, true);
        //采集周期
        $sampling_cycle = isset($collect_config_info['sampling_cycle']) ? explode(',', $collect_config_info['sampling_cycle']) : '';
        //采集开始时间
        $sampling_start_time = isset($collect_config_info['sampling_start_time']) ? $collect_config_info['sampling_start_time'] : '';
        //采集结束时间
        $sampling_end_time = isset($collect_config_info['sampling_end_time']) ? $collect_config_info['sampling_end_time'] : '';
        if (!is_array($sampling_cycle)) return $product_data_info;
        $current_time = $product_data_info['collection_time'];
        //如果当前时间在采集开始时间结束时间范围内，则进行连续挂网和累计挂网统计
        if ($sampling_start_time != '' && $sampling_end_time != '' && $current_time >= $sampling_start_time && $current_time <= $sampling_end_time) {
            // 获取采集时间是星期几
            $now_week = date('w', $current_time);
            if ($now_week == 0) {
                $now_week = 7;
            }
            if (!in_array($now_week, $sampling_cycle)) {
                return $product_data_info;
            }
            //排序$sampling_cycle从小到大
            sort($sampling_cycle);
            // 使用
            $result = $this->getLastSamplingInfo($now_week, $sampling_cycle);
            $days_to_subtract = isset($result['days_to_subtract']) ? $result['days_to_subtract'] : 0;
            // echo "往前推 {$result['days_to_subtract']} 天";
            //查询当前商品是否在上一个周期采集中过
            $up_scrape_date_time = $current_time -  $days_to_subtract * 24 * 3600; //查询上周这个时间点
            $up_scrape_date = date('Y-m-d', $up_scrape_date_time);
            if (in_array($product_data_info['platform'], ['3', '4'])) {
                $source_last_week_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
                $source_last_week_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
                $source_last_week_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
                $source_last_week_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
                $source_last_week_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
                $source_last_week_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
                $source_last_week_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
                $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
            } else {
                $source_last_week_where[] = ['link_url', '=', $product_data_info['link_url']]; //链接地址
                $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
            }
            $source_last_week_log = $this->where($source_last_week_where)->count();
            if ($source_last_week_log > 0) {
                $product_data_info['continuous_listing_count'] = $product_data_info['continuous_listing_count'] + 1; //连续挂网次数+1
            }
        } else if ($sampling_start_time != '' && $sampling_end_time == '0' && $current_time >= $sampling_start_time) {
            //如果当前时间在采集开始时间结束时间未设置，则进行连续挂网和累计挂网统计
            // 获取采集时间是星期几
            $collection_time = strtotime($product_data_info['collection_time']);
            $now_week = date('w', $collection_time);
            if ($now_week == 0) {
                $now_week = 7;
            }
            if (!in_array($now_week, $sampling_cycle)) {
                return $product_data_info;
            }
            //排序$sampling_cycle从小到大
            sort($sampling_cycle);
            // 使用
            $result = $this->getLastSamplingInfo($now_week, $sampling_cycle);
            $days_to_subtract = isset($result['days_to_subtract']) ? $result['days_to_subtract'] : 0;

            $up_scrape_date_time = $collection_time - $days_to_subtract * 24 * 3600; //查询上周这个时间点
            //查询当前商品上次采集记录
            $up_scrape_date = date('Y-m-d', $up_scrape_date_time);
            if (in_array($product_data_info['platform'], ['3', '4'])) {
                $source_last_week_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
                $source_last_week_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
                $source_last_week_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
                $source_last_week_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
                $source_last_week_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
                $source_last_week_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
                $source_last_week_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
                $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
            }else{
                $source_last_week_where[] = ['link_url', '=', $product_data_info['link_url']]; //链接地址
                $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
            }
            $source_last_week_log = $this->where($source_last_week_where)->count();
            if ($source_last_week_log > 0) {
                $product_data_info['continuous_listing_count'] = $product_data_info['continuous_listing_count'] + 1; //连续挂网次数+1
            }
        }
        return $product_data_info;
    }


    /**
     * 处理通知消息
     * @author 唐远望
     * @version 1.0
     * @date 2026-03-21
     * @param $data
     * @return bool
     */
    public function addNotices($low_price_data, $data_logid)
    {
        //添加通知
        $NoticesModel = new NoticesModel();
        $EmployeeModel = new EmployeeModel();
        $notices_data = [];
        if ($low_price_data['first_responsible_person'] != '' &&  $low_price_data['responsible_person'] != '') {
            //合并数据并去重
            $first_responsible_persons = array_unique(explode(',', $low_price_data['first_responsible_person']));
            $responsible_persons = array_unique(explode(',', $low_price_data['responsible_person']));
            $all_persons = array_merge($first_responsible_persons, $responsible_persons);
            //查询已已经开启通知设置的用户
            $employee_ids = $EmployeeModel->whereIn('id', $all_persons)->where('open_notice', 0)->pluck('id')->toArray();
            if (count($employee_ids) == 0)  return true;
            foreach ($employee_ids as $key => $employee_id) {
                if ($employee_id == '' || is_null($employee_id))  continue;
                $notices_data[] = [
                    'company_id' => $low_price_data['company_id'],
                    'custom_uid' => $employee_id,
                    'title' => '您有一条新的禁止商品待处理，请及时查看。',
                    'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
                    'data_logid' => $data_logid,
                    'insert_time' => time()
                ];
            }
            $NoticesModel->insert($notices_data);
        } else if ($low_price_data['first_responsible_person'] != '') {
            $first_responsible_persons = array_unique(explode(',', $low_price_data['first_responsible_person']));
            //查询已已经开启通知设置的用户
            $employee_ids = $EmployeeModel->whereIn('id', $first_responsible_persons)->where('open_notice', 0)->pluck('id')->toArray();
            if (count($employee_ids) == 0)  return true;
            foreach ($employee_ids as $key => $employee_id) {
                if ($employee_id == '' || is_null($employee_id))  continue;
                $notices_data[] = [
                    'company_id' => $low_price_data['company_id'],
                    'custom_uid' => $employee_id,
                    'title' => '您有一条新的禁止商品待处理，请及时查看。',
                    'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
                    'data_logid' => $data_logid,
                    'insert_time' => time()
                ];
            }
            $NoticesModel->insert($notices_data);
        } else if ($low_price_data['responsible_person'] != '') {
            $responsible_persons = array_unique(explode(',', $low_price_data['responsible_person']));
            //查询已已经开启通知设置的用户
            $employee_ids = $EmployeeModel->whereIn('id', $responsible_persons)->where('open_notice', 0)->pluck('id')->toArray();
            if (count($employee_ids) == 0)  return true;
            foreach ($employee_ids as $key => $employee_id) {
                if ($employee_id == '' || is_null($employee_id))  continue;
                $notices_data[] = [
                    'company_id' => $low_price_data['company_id'],
                    'custom_uid' => $employee_id,
                    'title' => '您有一条新的禁止商品待处理，请及时查看。',
                    'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
                    'data_logid' => $data_logid,
                    'insert_time' => time()
                ];
            }
            $NoticesModel->insert($notices_data);
        }
        return true;
    }


    /**
     * 编辑内容
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $data
     * @return bool
     */
    public function editViolationProduct_content($where, $data)
    {
        $ViolationProduct = $this->where($where)->first();
        if (!$ViolationProduct) {
            return false;
        }
        $ViolationProduct->company_id = $data['company_id'];
        $ViolationProduct->first_responsible_person = $data['first_responsible_person'];
        $ViolationProduct->responsible_person = $data['responsible_person'];
        $ViolationProduct->platform = $data['platform'];
        $ViolationProduct->company_name = $data['company_name'];
        $ViolationProduct->product_name = $data['product_name'];
        $ViolationProduct->product_specs = $data['product_specs'];
        $ViolationProduct->online_posting_count = $data['online_posting_count'];
        $ViolationProduct->link_url = $data['link_url'];
        $ViolationProduct->store_name = $data['store_name'];
        $ViolationProduct->source_responsible_person = $data['source_responsible_person'];
        $ViolationProduct->update_time = time();
        $ViolationProduct->save();
        return true;
    }



    /**
     * 更新数据
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $data
     * @return bool
     */
    public function updateViolationProduct($where, $data)
    {
        DB::beginTransaction();
        try {
            $this->editViolationProduct_content($where, $data);
            DB::commit();
            return true;
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            // 错误处理...
            return false;
        }
    }

    /**
     * 修改状态
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $id
     * @param $status
     * @return bool
     */
    public function changeStatus($where, $status)
    {
        $ViolationProduct = $this->where($where)->first();
        if (!$ViolationProduct) {
            return false;
        }
        $ViolationProduct->status = $status;
        $ViolationProduct->update_time = time();
        $ViolationProduct->save();
        return true;
    }

    /**
     * 修改处理状态
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $id
     * @param $processing_status
     * @return bool
     */
    public function changeProcessingStatus($where, $processing_status)
    {
        $ViolationProduct = $this->where($where)->first();
        if (!$ViolationProduct) {
            return false;
        }
        $ViolationProduct->processing_status = $processing_status;
        $ViolationProduct->update_time = time();
        $ViolationProduct->save();
        return true;
    }

    /**
     * 删除数据
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $id
     * @return bool
     */
    public function deleteViolationProduct($where)
    {
        $ViolationProduct = $this->where($where)->first();
        if (!$ViolationProduct) {
            return false;
        }
        $ViolationProduct->delete();
        return true;
    }
}