ViolationProduct.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552
  1. <?php
  2. namespace App\Models\Manager\Process;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberModel;
  7. use App\Facades\Servers\Logs\Log;
  8. use App\Models\Manager\Process\Notices as NoticesModel;
  9. use App\Models\Manager\Personnel\Employee as EmployeeModel;
  10. /**
  11. * 违规处理-违规商品模型
  12. * @author: 唐远望
  13. * @version: 1.0
  14. * @date: 2025-12-08
  15. */
  16. class ViolationProduct extends Model
  17. {
  18. use HasFactory;
  19. // 与模型关联的表名
  20. protected $table = 'process_violation_product';
  21. // 是否主动维护时间戳
  22. public $timestamps = false;
  23. // 定义时间戳字段名
  24. // const CREATED_AT = 'insert_time';
  25. // const UPDATED_AT = 'update_time';
  26. /**
  27. * 平台定义
  28. * @author 唐远望
  29. * @version 1.0
  30. * @date 2025-12-31
  31. */
  32. public function platform_data()
  33. {
  34. //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  35. $platform_data = [
  36. '全部' => '0',
  37. '淘宝' => '1',
  38. '京东' => '2',
  39. '拼多多' => '3',
  40. '美团' => '4',
  41. '药师帮' => '5',
  42. '1药城' => '6',
  43. '药九九' => '7',
  44. '药易购' => '8',
  45. '药帮忙' => '9',
  46. '熊猫药药' => '10',
  47. '药房网' => '11'
  48. ];
  49. return $platform_data;
  50. }
  51. /**
  52. * 添加
  53. * @author 唐远望
  54. * @version 1.0
  55. * @date 2025-12-08
  56. */
  57. public function addViolationProduct_content($data)
  58. {
  59. $insert_data = [
  60. 'company_id' => $data['company_id'],
  61. 'source_id' => $data['source_id'],
  62. 'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
  63. 'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
  64. 'platform' => $data['platform'],
  65. 'company_name' => $data['company_name'],
  66. 'product_brand' => isset($data['product_brand']) ? $data['product_brand'] : '',
  67. 'product_name' => $data['product_name'],
  68. 'product_specs' => $data['product_specs'],
  69. 'online_posting_count' => isset($data['online_posting_count']) && is_numeric($data['online_posting_count']) ? $data['online_posting_count'] : 1,
  70. 'continuous_listing_count' => isset($data['continuous_listing_count']) && is_numeric($data['continuous_listing_count']) ? $data['continuous_listing_count'] : 1,
  71. 'social_credit_code' => $data['social_credit_code'],
  72. 'province_id' => $data['province_id'],
  73. 'province_name' => isset($data['province_name']) ? $data['province_name'] : '',
  74. 'city_id' => $data['city_id'],
  75. 'city_name' => isset($data['city_name']) ? $data['city_name'] : '',
  76. 'area_info' => $data['area_info'],
  77. 'link_url' => $data['link_url'],
  78. 'store_name' => $data['store_name'],
  79. 'anonymous_store_name' => isset($data['anonymous_store_name']) ? $data['anonymous_store_name'] : '',
  80. 'source_responsible_person' => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
  81. 'category_name' => $data['category_name'],
  82. 'company_category_name' => $data['company_category_name'],
  83. 'processing_status' => '1',
  84. 'insert_time' => time(),
  85. 'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
  86. 'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
  87. 'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
  88. 'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
  89. 'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
  90. 'shipment_city_name' => isset($data['shipment_city_name']) ? $data['shipment_city_name'] : '', // 发货城市
  91. 'merge_city_id' => $data['merge_city_id'],
  92. 'merge_province_id' => $data['merge_province_id'],
  93. 'merge_city_name' => $data['merge_city_name'],
  94. 'merge_province_name' => $data['merge_province_name'],
  95. 'snapshot_url' => isset($data['snapshot_url']) ? $data['snapshot_url'] : '', // 商品快照地址
  96. 'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
  97. ];
  98. $ViolationProduct_id = $this->insertGetId($insert_data);
  99. return $ViolationProduct_id;
  100. }
  101. /**
  102. * 写入数据
  103. * @author 唐远望
  104. * @version 1.0
  105. * @date 2025-12-08
  106. * @param $data
  107. * @return bool
  108. */
  109. public function addViolationProduct($data, $is_import = false)
  110. {
  111. if ($is_import == false) {
  112. //去重规则:品牌方公司ID+店铺公司名称+店铺名称+品牌名称+商品名称+规格+盒数(针对采集)
  113. $source_where[] = ['company_id', '=', $data['company_id']]; //品牌方公司ID
  114. $source_where[] = ['company_name', '=', $data['company_name']]; //店铺公司名称
  115. $source_where[] = ['store_name', '=', $data['store_name']]; //店铺名称
  116. $source_where[] = ['product_brand', '=', $data['product_brand']]; //品牌名称
  117. $source_where[] = ['product_name', '=', $data['product_name']]; //商品名称
  118. $source_where[] = ['product_specs', '=', $data['product_specs']]; //规格
  119. $source_where[] = ['scrape_date', '=', $data['scrape_date']]; //采集日期
  120. $source_id_log = $this->where($source_where)->count();
  121. if ($source_id_log > 0) {
  122. return true;
  123. }
  124. }
  125. DB::beginTransaction();
  126. try {
  127. //执行挂网数据统计
  128. $data = $this->handleCountData($data);
  129. $ViolationProductMemberModel = new ViolationProductMemberModel();
  130. $insert_data = [
  131. 'company_id' => $data['company_id'],
  132. 'source_id' => $data['source_id'],
  133. 'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
  134. 'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
  135. 'platform' => $data['platform'],
  136. 'company_name' => $data['company_name'],
  137. 'product_brand' => isset($data['product_brand']) ? $data['product_brand'] : '',
  138. 'product_name' => $data['product_name'],
  139. 'product_specs' => $data['product_specs'],
  140. 'online_posting_count' => isset($data['online_posting_count']) && is_numeric($data['online_posting_count']) ? $data['online_posting_count'] : 1,
  141. 'continuous_listing_count' => isset($data['continuous_listing_count']) && is_numeric($data['continuous_listing_count']) ? $data['continuous_listing_count'] : 1,
  142. 'social_credit_code' => $data['social_credit_code'],
  143. 'province_id' => $data['province_id'],
  144. 'province_name' => isset($data['province_name']) ? $data['province_name'] : '',
  145. 'city_id' => $data['city_id'],
  146. 'city_name' => isset($data['city_name']) ? $data['city_name'] : '',
  147. 'area_info' => $data['area_info'],
  148. 'link_url' => $data['link_url'],
  149. 'store_name' => $data['store_name'],
  150. 'anonymous_store_name' => isset($data['anonymous_store_name']) ? $data['anonymous_store_name'] : '',
  151. 'source_responsible_person' => $data['source_responsible_person'] ? ',' . $data['source_responsible_person'] . ',' : '',
  152. 'category_name' => $data['category_name'],
  153. 'company_category_name' => $data['company_category_name'],
  154. 'processing_status' => '1',
  155. 'insert_time' => time(),
  156. 'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
  157. 'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
  158. 'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
  159. 'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
  160. 'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
  161. 'shipment_city_name' => isset($data['shipment_city_name']) ? $data['shipment_city_name'] : '', // 发货城市
  162. 'merge_city_id' => $data['merge_city_id'],
  163. 'merge_province_id' => $data['merge_province_id'],
  164. 'merge_city_name' => $data['merge_city_name'],
  165. 'merge_province_name' => $data['merge_province_name'],
  166. 'snapshot_url' => isset($data['snapshot_url']) ? $data['snapshot_url'] : '', // 商品快照地址
  167. 'specify_responsible_person' => isset($data['specify_responsible_person']) ? $data['specify_responsible_person'] : '1', // 指派责任人 0=开启 1=关闭
  168. ];
  169. $ViolationProduct_id = $this->insertGetId($insert_data);
  170. $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];
  171. $first_responsible_person_data = [];
  172. if (count($first_responsible_persons) > 0) {
  173. foreach ($first_responsible_persons as $key => $employee_id) {
  174. //如果不是数字或者为空,则跳过
  175. if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id)) continue;
  176. $first_responsible_person_data[] = [
  177. 'violation_product_logid' => $ViolationProduct_id,
  178. 'employee_id' => $employee_id,
  179. 'duty_type' => 1, //责任类型1=第一责任人,2=责任人,3=溯源责任人
  180. ];
  181. }
  182. }
  183. $ViolationProductMemberModel->insert($first_responsible_person_data);
  184. $responsible_persons = $data['responsible_person'] != '' ? explode(',', $data['responsible_person']) : [];
  185. $responsible_person_data = [];
  186. if (count($responsible_persons) > 0) {
  187. foreach ($responsible_persons as $key => $employee_id) {
  188. //如果不是数字或者为空,则跳过
  189. if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id)) continue;
  190. $responsible_person_data[] = [
  191. 'violation_product_logid' => $ViolationProduct_id,
  192. 'employee_id' => $employee_id,
  193. 'duty_type' => 2, //责任类型1=第一责任人,2=责任人,3=溯源责任人
  194. ];
  195. }
  196. }
  197. $ViolationProductMemberModel->insert($responsible_person_data);
  198. $source_responsible_persons = $data['source_responsible_person'] != '' ? explode(',', $data['source_responsible_person']) : [];
  199. $source_responsible_person_data = [];
  200. if (count($source_responsible_persons) > 0) {
  201. foreach ($source_responsible_persons as $key => $employee_id) {
  202. //如果不是数字或者为空,则跳过
  203. if ($employee_id == '' || is_null($employee_id) || !is_numeric($employee_id)) continue;
  204. $source_responsible_person_data[] = [
  205. 'violation_product_logid' => $ViolationProduct_id,
  206. 'employee_id' => $employee_id,
  207. 'duty_type' => 3, //责任类型1=第一责任人,2=责任人,3=溯源责任人
  208. ];
  209. }
  210. }
  211. $ViolationProductMemberModel->insert($source_responsible_person_data);
  212. //添加通知
  213. // $this->addNotices($insert_data, $ViolationProduct_id);
  214. DB::commit();
  215. return true;
  216. // 成功处理...
  217. } catch (\Exception $e) {
  218. DB::rollBack();
  219. // 错误处理...
  220. Log::info('job_error', '数据清洗-新增违规商品处理记录失败', ['data' => $data, 'error' => $e->getMessage()]);
  221. return false;
  222. }
  223. }
  224. function getLastSamplingInfo($currentWeek, $samplingCycle)
  225. {
  226. // 获取所有小于当前星期的配置
  227. $previousWeeks = array_filter($samplingCycle, function ($week) use ($currentWeek) {
  228. return $week < $currentWeek;
  229. });
  230. if (!empty($previousWeeks)) {
  231. // 存在小于当前星期的配置,取最大值
  232. $lastWeek = max($previousWeeks);
  233. $daysToSubtract = $currentWeek - $lastWeek;
  234. } else {
  235. // 不存在(当前是最小的),取最大的配置星期(跨周)
  236. $lastWeek = max($samplingCycle);
  237. $daysToSubtract = $currentWeek + (7 - $lastWeek);
  238. }
  239. return [
  240. 'last_week' => $lastWeek,
  241. 'days_to_subtract' => $daysToSubtract
  242. ];
  243. }
  244. /**
  245. * 处理连续挂网&累计挂网数据统计
  246. * @author 唐远望
  247. * @version 1.0
  248. * @date 2026-05-07
  249. *
  250. */
  251. public function handleCountData($product_data_info)
  252. {
  253. $collect_config_info = isset($product_data_info['collect_config_info']) ? $product_data_info['collect_config_info'] : ''; //采集配置信息
  254. if (trim($collect_config_info) == '') return $product_data_info;
  255. $collect_config_info = json_decode($collect_config_info, true); //{"sampling_cycle": "", "sampling_start_time": "", "sampling_end_time": ""}
  256. //采集周期
  257. $sampling_cycle = isset($collect_config_info['sampling_cycle']) ? explode(',', $collect_config_info['sampling_cycle']) : '';
  258. //采集开始时间
  259. $sampling_start_time = isset($collect_config_info['sampling_start_time']) ? $collect_config_info['sampling_start_time'] : '';
  260. //采集结束时间
  261. $sampling_end_time = isset($collect_config_info['sampling_end_time']) ? $collect_config_info['sampling_end_time'] : '';
  262. if (!is_array($sampling_cycle)) return $product_data_info;
  263. $current_time = time();
  264. //如果当前时间在采集开始时间结束时间范围内,则进行连续挂网和累计挂网统计
  265. if ($sampling_start_time != '' && $sampling_end_time != '' && $current_time >= $sampling_start_time && $current_time <= $sampling_end_time) {
  266. // 获取采集时间是星期几
  267. $collection_time = strtotime($product_data_info['collection_time']);
  268. $now_week = date('w', $collection_time);
  269. if ($now_week == 0) {
  270. $now_week = 7;
  271. }
  272. if (!in_array($now_week, $sampling_cycle)) {
  273. return $product_data_info;
  274. }
  275. //排序$sampling_cycle从小到大
  276. sort($sampling_cycle);
  277. // 使用
  278. $result = $this->getLastSamplingInfo($now_week, $sampling_cycle);
  279. $days_to_subtract = isset($result['days_to_subtract']) ? $result['days_to_subtract'] : 0;
  280. //查询当前商品是否在上一个周期采集中过
  281. $up_scrape_date_time = $collection_time - $days_to_subtract * 24 * 3600; //查询上周这个时间点
  282. $up_scrape_date = date('Y-m-d', $up_scrape_date_time);
  283. $source_last_week_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
  284. $source_last_week_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
  285. $source_last_week_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
  286. $source_last_week_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
  287. $source_last_week_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
  288. $source_last_week_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
  289. $source_last_week_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
  290. $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
  291. $source_last_week_log = $this->where($source_last_week_where)->count();
  292. if ($source_last_week_log > 0) {
  293. $product_data_info['continuous_listing_count'] = $product_data_info['continuous_listing_count'] + 1; //连续挂网次数+1
  294. }
  295. //查询当前商品上次连续挂网次数
  296. $source_last_time_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
  297. $source_last_time_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
  298. $source_last_time_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
  299. $source_last_time_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
  300. $source_last_time_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
  301. $source_last_time_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
  302. $source_last_time_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
  303. $source_last_time_log = $this->where($source_last_time_where)->orderbyDesc('scrape_date')->first();
  304. if (!empty($source_last_time_log)) {
  305. $product_data_info['online_posting_count'] = $source_last_time_log->online_posting_count + 1; //累计挂网次数+1
  306. }
  307. } else if ($sampling_start_time != '' && $sampling_end_time == '' && $current_time >= $sampling_start_time) {
  308. //如果当前时间在采集开始时间结束时间未设置,则进行连续挂网和累计挂网统计
  309. // 获取采集时间是星期几
  310. $collection_time = strtotime($product_data_info['collection_time']);
  311. $now_week = date('w', $collection_time);
  312. if ($now_week == 0) {
  313. $now_week = 7;
  314. }
  315. if (!in_array($now_week, $sampling_cycle)) {
  316. return $product_data_info;
  317. }
  318. //查询当前商品是否在上一个周期采集中过
  319. $up_scrape_date_time = $collection_time - 7 * 24 * 3600; //查询上周这个时间点
  320. //查询当前商品上次采集记录
  321. $up_scrape_date = date('Y-m-d', $up_scrape_date_time);
  322. $source_last_week_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
  323. $source_last_week_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
  324. $source_last_week_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
  325. $source_last_week_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
  326. $source_last_week_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
  327. $source_last_week_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
  328. $source_last_week_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
  329. $source_last_week_where[] = ['scrape_date', '=', $up_scrape_date]; //上个周期采集日期
  330. $source_last_week_log = $this->where($source_last_week_where)->count();
  331. if ($source_last_week_log > 0) {
  332. $product_data_info['continuous_listing_count'] = $product_data_info['continuous_listing_count'] + 1; //连续挂网次数+1
  333. }
  334. //查询当前商品上次连续挂网次数
  335. $source_last_time_where[] = ['company_id', '=', $product_data_info['company_id']]; //品牌方公司ID
  336. $source_last_time_where[] = ['platform', '=', $product_data_info['platform']]; //挂网平台ID
  337. $source_last_time_where[] = ['company_name', '=', $product_data_info['company_name']]; //店铺公司名称
  338. $source_last_time_where[] = ['store_name', '=', $product_data_info['store_name']]; //店铺名称
  339. $source_last_time_where[] = ['product_brand', '=', $product_data_info['product_brand']]; //品牌名称
  340. $source_last_time_where[] = ['product_name', '=', $product_data_info['product_name']]; //商品名称
  341. $source_last_time_where[] = ['product_specs', '=', $product_data_info['product_specs']]; //规格
  342. $source_last_time_log = $this->where($source_last_time_where)->orderbyDesc('scrape_date')->first();
  343. if (!empty($source_last_time_log)) {
  344. $product_data_info['online_posting_count'] = $source_last_time_log->online_posting_count + 1; //累计挂网次数+1
  345. }
  346. }
  347. return $product_data_info;
  348. }
  349. /**
  350. * 处理通知消息
  351. * @author 唐远望
  352. * @version 1.0
  353. * @date 2026-03-21
  354. * @param $data
  355. * @return bool
  356. */
  357. public function addNotices($low_price_data, $data_logid)
  358. {
  359. //添加通知
  360. $NoticesModel = new NoticesModel();
  361. $EmployeeModel = new EmployeeModel();
  362. $notices_data = [];
  363. if ($low_price_data['first_responsible_person'] != '' && $low_price_data['responsible_person'] != '') {
  364. //合并数据并去重
  365. $first_responsible_persons = array_unique(explode(',', $low_price_data['first_responsible_person']));
  366. $responsible_persons = array_unique(explode(',', $low_price_data['responsible_person']));
  367. $all_persons = array_merge($first_responsible_persons, $responsible_persons);
  368. //查询已已经开启通知设置的用户
  369. $employee_ids = $EmployeeModel->whereIn('id', $all_persons)->where('open_notice', 0)->pluck('id')->toArray();
  370. if (count($employee_ids) == 0) return true;
  371. foreach ($employee_ids as $key => $employee_id) {
  372. if ($employee_id == '' || is_null($employee_id)) continue;
  373. $notices_data[] = [
  374. 'company_id' => $low_price_data['company_id'],
  375. 'custom_uid' => $employee_id,
  376. 'title' => '您有一条新的禁止商品待处理,请及时查看。',
  377. 'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
  378. 'data_logid' => $data_logid,
  379. 'insert_time' => time()
  380. ];
  381. }
  382. $NoticesModel->insert($notices_data);
  383. } else if ($low_price_data['first_responsible_person'] != '') {
  384. $first_responsible_persons = array_unique(explode(',', $low_price_data['first_responsible_person']));
  385. //查询已已经开启通知设置的用户
  386. $employee_ids = $EmployeeModel->whereIn('id', $first_responsible_persons)->where('open_notice', 0)->pluck('id')->toArray();
  387. if (count($employee_ids) == 0) return true;
  388. foreach ($employee_ids as $key => $employee_id) {
  389. if ($employee_id == '' || is_null($employee_id)) continue;
  390. $notices_data[] = [
  391. 'company_id' => $low_price_data['company_id'],
  392. 'custom_uid' => $employee_id,
  393. 'title' => '您有一条新的禁止商品待处理,请及时查看。',
  394. 'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
  395. 'data_logid' => $data_logid,
  396. 'insert_time' => time()
  397. ];
  398. }
  399. $NoticesModel->insert($notices_data);
  400. } else if ($low_price_data['responsible_person'] != '') {
  401. $responsible_persons = array_unique(explode(',', $low_price_data['responsible_person']));
  402. //查询已已经开启通知设置的用户
  403. $employee_ids = $EmployeeModel->whereIn('id', $responsible_persons)->where('open_notice', 0)->pluck('id')->toArray();
  404. if (count($employee_ids) == 0) return true;
  405. foreach ($employee_ids as $key => $employee_id) {
  406. if ($employee_id == '' || is_null($employee_id)) continue;
  407. $notices_data[] = [
  408. 'company_id' => $low_price_data['company_id'],
  409. 'custom_uid' => $employee_id,
  410. 'title' => '您有一条新的禁止商品待处理,请及时查看。',
  411. 'content_type' => '2', //内容类型1=低价挂网2=禁止挂网3=违规店铺
  412. 'data_logid' => $data_logid,
  413. 'insert_time' => time()
  414. ];
  415. }
  416. $NoticesModel->insert($notices_data);
  417. }
  418. return true;
  419. }
  420. /**
  421. * 编辑内容
  422. * @author 唐远望
  423. * @version 1.0
  424. * @date 2025-12-08
  425. * @param $data
  426. * @return bool
  427. */
  428. public function editViolationProduct_content($where, $data)
  429. {
  430. $ViolationProduct = $this->where($where)->first();
  431. if (!$ViolationProduct) {
  432. return false;
  433. }
  434. $ViolationProduct->company_id = $data['company_id'];
  435. $ViolationProduct->first_responsible_person = $data['first_responsible_person'];
  436. $ViolationProduct->responsible_person = $data['responsible_person'];
  437. $ViolationProduct->platform = $data['platform'];
  438. $ViolationProduct->company_name = $data['company_name'];
  439. $ViolationProduct->product_name = $data['product_name'];
  440. $ViolationProduct->product_specs = $data['product_specs'];
  441. $ViolationProduct->online_posting_count = $data['online_posting_count'];
  442. $ViolationProduct->link_url = $data['link_url'];
  443. $ViolationProduct->store_name = $data['store_name'];
  444. $ViolationProduct->source_responsible_person = $data['source_responsible_person'];
  445. $ViolationProduct->update_time = time();
  446. $ViolationProduct->save();
  447. return true;
  448. }
  449. /**
  450. * 更新数据
  451. * @author 唐远望
  452. * @version 1.0
  453. * @date 2025-12-08
  454. * @param $data
  455. * @return bool
  456. */
  457. public function updateViolationProduct($where, $data)
  458. {
  459. DB::beginTransaction();
  460. try {
  461. $this->editViolationProduct_content($where, $data);
  462. DB::commit();
  463. return true;
  464. // 成功处理...
  465. } catch (\Exception $e) {
  466. DB::rollBack();
  467. // 错误处理...
  468. return false;
  469. }
  470. }
  471. /**
  472. * 修改状态
  473. * @author 唐远望
  474. * @version 1.0
  475. * @date 2025-12-08
  476. * @param $id
  477. * @param $status
  478. * @return bool
  479. */
  480. public function changeStatus($where, $status)
  481. {
  482. $ViolationProduct = $this->where($where)->first();
  483. if (!$ViolationProduct) {
  484. return false;
  485. }
  486. $ViolationProduct->status = $status;
  487. $ViolationProduct->update_time = time();
  488. $ViolationProduct->save();
  489. return true;
  490. }
  491. /**
  492. * 修改处理状态
  493. * @author 唐远望
  494. * @version 1.0
  495. * @date 2025-12-08
  496. * @param $id
  497. * @param $processing_status
  498. * @return bool
  499. */
  500. public function changeProcessingStatus($where, $processing_status)
  501. {
  502. $ViolationProduct = $this->where($where)->first();
  503. if (!$ViolationProduct) {
  504. return false;
  505. }
  506. $ViolationProduct->processing_status = $processing_status;
  507. $ViolationProduct->update_time = time();
  508. $ViolationProduct->save();
  509. return true;
  510. }
  511. /**
  512. * 删除数据
  513. * @author 唐远望
  514. * @version 1.0
  515. * @date 2025-12-08
  516. * @param $id
  517. * @return bool
  518. */
  519. public function deleteViolationProduct($where)
  520. {
  521. $ViolationProduct = $this->where($where)->first();
  522. if (!$ViolationProduct) {
  523. return false;
  524. }
  525. $ViolationProduct->delete();
  526. return true;
  527. }
  528. }