zhijiayun/app/Models/Manager/Process/ViolationStore.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\ViolationStoreMember as ViolationStoreMemberModel;
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 ViolationStore extends Model
{
    use HasFactory;
    // 与模型关联的表名
    protected $table = 'process_violation_store';
    // 是否主动维护时间戳
    public $timestamps = false;
    // 定义时间戳字段名
    // const CREATED_AT = 'insert_time';
    // const UPDATED_AT = 'update_time';



    /**
     * 添加
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     */
    public function addViolationStore_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'],
            'social_credit_code'    => $data['social_credit_code'],
            'province_id'    => $data['province_id'],
            'province_name'    => $data['province_name'],
            'city_id'    => $data['city_id'],
            'city_name'    => $data['city_name'],
            'area_info' => $data['area_info'],
            'link_url'    => $data['link_url'],
            'store_name'    => $data['store_name'],
            'source_responsible_person'    => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
            'company_category_name' => $data['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'] : '',
            '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'],
            'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
        ];
        $ViolationStore_id = $this->insertGetId($insert_data);
        return $ViolationStore_id;
    }


    /**
     * 写入数据
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $data
     * @return bool
     */
    public function addViolationStore($data)
    {
        //检查是否重复清洗
        $source_data_log = $this->where('source_id', $data['source_id'])->count();
        if (!empty($source_data_log) && $source_data_log > 0) return true;
        $source_where[] = ['company_id', '=', $data['company_id']];
        $source_where[] = ['store_name', '=', $data['store_name']];
        $source_where[] = ['social_credit_code', '=', $data['social_credit_code']];
        $source_id_log = $this->where($source_where)->count();
        if ($source_id_log > 0) {
            return true;
        }
        DB::beginTransaction();
        try {

            $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'],
                'social_credit_code'    => $data['social_credit_code'],
                'province_id'    => $data['province_id'],
                'province_name'    => $data['province_name'],
                'city_id'    => $data['city_id'],
                'city_name'    => $data['city_name'],
                'area_info' => $data['area_info'],
                'link_url'    => $data['link_url'],
                'store_name'    => $data['store_name'],
                'source_responsible_person'    => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
                'company_category_name' => $data['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'] : '',
                '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'],
                'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
            ];
            $ViolationStore_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_store_logid' => $ViolationStore_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=溯源责任人
                    ];
                }
            }
            $ViolationStoreMemberModel = new ViolationStoreMemberModel();
            $ViolationStoreMemberModel->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_store_logid' => $ViolationStore_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=溯源责任人
                    ];
                }
            }
            $ViolationStoreMemberModel = new ViolationStoreMemberModel();
            $ViolationStoreMemberModel->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_store_logid' => $ViolationStore_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=溯源责任人
                    ];
                }
            }
            $ViolationStoreMemberModel = new ViolationStoreMemberModel();
            $ViolationStoreMemberModel->insert($source_responsible_person_data);
            //添加通知
            // $this->addNotices($insert_data, $ViolationStore_id);
            DB::commit();
            return true;
            // 成功处理...
        } catch (\Exception $e) {
            DB::rollBack();
            Log::info('job_error', '数据清洗-新增违规店铺处理记录失败', ['data' => $data, 'error' => $e->getMessage()]);
            // 错误处理...
            return false;
        }
    }


    /**
     * 处理通知消息
     * @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' => '3', //内容类型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' => '3', //内容类型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' => '3', //内容类型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 editViolationStore_content($where, $data)
    {
        $ViolationStore = $this->where($where)->first();
        if (!$ViolationStore) {
            return false;
        }
        $ViolationStore->company_id = $data['company_id'];
        $ViolationStore->first_responsible_person = $data['first_responsible_person'];
        $ViolationStore->responsible_person = $data['responsible_person'];
        $ViolationStore->platform = $data['platform'];
        $ViolationStore->company_name = $data['company_name'];
        $ViolationStore->social_credit_code = $data['social_credit_code'];
        $ViolationStore->link_url = $data['link_url'];
        $ViolationStore->store_name = $data['store_name'];
        $ViolationStore->source_responsible_person = $data['source_responsible_person'];
        $ViolationStore->update_time = time();
        $ViolationStore->save();
        return true;
    }



    /**
     * 更新数据
     * @author 唐远望
     * @version 1.0
     * @date 2025-12-08
     * @param $data
     * @return bool
     */
    public function updateViolationStore($where, $data)
    {
        DB::beginTransaction();
        try {
            $this->editViolationStore_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)
    {
        $ViolationStore = $this->where($where)->first();
        if (!$ViolationStore) {
            return false;
        }
        $ViolationStore->status = $status;
        $ViolationStore->update_time = time();
        $ViolationStore->save();
        return true;
    }

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

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