LowPriceGoods.php 29 KB

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