ViolationProduct.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594
  1. <?php
  2. namespace App\Http\Controllers\Manager\Process;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\Manager\Process\ViolationProduct as Request;
  5. use App\Models\Manager\Process\ViolationProduct as ViolationProductModel;
  6. use App\Jobs\Manager\Process\ViolationProductJobs;
  7. use App\Models\Manager\Personnel\Employee as EmployeeModel;
  8. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  9. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  10. use PhpOffice\PhpSpreadsheet\Style\Alignment;
  11. use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberModel;
  12. /**
  13. * 违规处理-违规商品
  14. * @author 唐远望
  15. * @version 1.0
  16. * @date 2025-12-08
  17. */
  18. class ViolationProduct extends Controller
  19. {
  20. /**
  21. * 列表
  22. * @author 唐远望
  23. * @version 1.0
  24. * @date 2025-12-08
  25. *
  26. */
  27. public function list(Request $request, ViolationProductModel $ViolationProductModel, EmployeeModel $EmployeeModel, ViolationProductMemberModel $ViolationProductMemberModel)
  28. {
  29. $request->scene('list')->validate();
  30. // 查询条件
  31. $map = [];
  32. $limit = request('limit', config('page_num', 10));
  33. $status = request('status', '');
  34. $start_time = request('start_time', '');
  35. $end_time = request('end_time', '');
  36. $product_name = request('product_name', '');
  37. $product_names = request('product_names', '');
  38. $first_responsible_person = request('first_responsible_person', '');
  39. $responsible_person = request('responsible_person', '');
  40. $platform = request('platform', '');
  41. $company_name = request('company_name', '');
  42. $store_name = request('store_name', '');
  43. $store_names = request('store_names', '');
  44. $source_responsible_person = request('source_responsible_person', '');
  45. $processing_status = request('processing_status', '');
  46. $product_specs = request('product_specs', '');
  47. $online_posting_cunt = request('online_posting_cunt', '');
  48. $category_name = request('category_name', '');
  49. // 时间条件
  50. if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
  51. if ($end_time) $map[] = ['insert_time', '<=', strtotime($end_time)];
  52. // 其他条件
  53. if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
  54. if ($store_name) $map[] = ['store_name', 'like', "%$store_name%"];
  55. if ($category_name) $map[] = ['category_name', 'like', "%$category_name%"];
  56. //多选平台查询
  57. if ($platform && is_string($platform)) {
  58. $platform = explode(',', $platform);
  59. $ViolationProductModel = $ViolationProductModel->whereIn('platform', $platform);
  60. }
  61. //多选处理状态查询
  62. if ($processing_status && is_string($processing_status)) {
  63. $processing_status = explode(',', $processing_status);
  64. $ViolationProductModel = $ViolationProductModel->whereIn('processing_status', $processing_status);
  65. }
  66. //多选状态查询
  67. if ($status && is_string($status)) {
  68. $status = explode(',', $status);
  69. $ViolationProductModel = $ViolationProductModel->whereIn('status', $status);
  70. }
  71. //多选店铺名称查询
  72. if ($store_names && is_string($store_names)) {
  73. $store_names = explode(',', $store_names);
  74. $ViolationProductModel = $ViolationProductModel->whereIn('store_name', $store_names);
  75. }
  76. //多选违规挂网次数查询
  77. if ($online_posting_cunt && is_string($online_posting_cunt)) {
  78. $online_posting_cunt = explode(',', $online_posting_cunt);
  79. $ViolationProductModel = $ViolationProductModel->whereIn('online_posting_cunt', $online_posting_cunt);
  80. }
  81. //多选规格查询
  82. if ($product_specs && is_string($product_specs)) {
  83. $product_specs = explode(',', $product_specs);
  84. $ViolationProductModel = $ViolationProductModel->whereIn('product_specs', $product_specs);
  85. }
  86. //多选商品查询
  87. if ($product_names && is_string($product_names)) {
  88. $product_names = explode(',', $product_names);
  89. $ViolationProductModel = $ViolationProductModel->whereIn('product_name', $product_names);
  90. }
  91. //多选公司查询
  92. if ($company_name && is_string($company_name)) {
  93. $company_name = explode(',', $company_name);
  94. $ViolationProductModel = $ViolationProductModel->whereIn('company_name', $company_name);
  95. }
  96. //多选第一责任人
  97. if ($first_responsible_person && is_string($first_responsible_person)) {
  98. $first_responsible_person = explode(',', $first_responsible_person);
  99. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $first_responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  100. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  101. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  102. });
  103. }
  104. //多选责任人
  105. if ($responsible_person && is_string($responsible_person)) {
  106. $responsible_person = explode(',', $responsible_person);
  107. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  108. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  109. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  110. });
  111. }
  112. //多选溯源责任人
  113. if ($source_responsible_person && is_string($source_responsible_person)) {
  114. $source_responsible_person = explode(',', $source_responsible_person);
  115. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $source_responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  116. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  117. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  118. });
  119. }
  120. $result = $ViolationProductModel
  121. ->where($map)
  122. ->orderByDesc('id')
  123. ->paginate($limit)->toarray();
  124. // 分配数据
  125. if (!$result) json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
  126. if (isset($result['data']) && count($result['data']) > 0) {
  127. foreach ($result['data'] as $key => $value) {
  128. //查询第一责任人名称
  129. $first_responsible_person = explode(',', $value['first_responsible_person']);
  130. $first_responsible_person_name = $EmployeeModel->whereIn('id', $first_responsible_person)->pluck('name')->toarray();
  131. $result['data'][$key]['first_responsible_person_name'] = $first_responsible_person_name;
  132. //查询责任人名称
  133. $responsible_person = explode(',', $value['responsible_person']);
  134. $responsible_person_name = $EmployeeModel->whereIn('id', $responsible_person)->pluck('name')->toarray();
  135. $result['data'][$key]['responsible_person_name'] = $responsible_person_name;
  136. //查询来源责任人名称
  137. $source_responsible_person = explode(',', $value['source_responsible_person']);
  138. $source_responsible_person_name = $EmployeeModel->whereIn('id', $source_responsible_person)->pluck('name')->toarray();
  139. $result['data'][$key]['source_responsible_person_name'] = $source_responsible_person_name;
  140. }
  141. }
  142. // 加载模板
  143. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  144. }
  145. /**
  146. * 列表导出
  147. * @author 唐远望
  148. * @version 1.0
  149. * @date 2025-06-17
  150. */
  151. public function export_excel(Request $request, ViolationProductModel $ViolationProductModel, EmployeeModel $EmployeeModel, ViolationProductMemberModel $ViolationProductMemberModel)
  152. {
  153. $request->scene('export_excel')->validate();
  154. // 查询条件
  155. $map = [];
  156. $limit = request('limit', config('page_num', 10));
  157. $status = request('status', '');
  158. $start_time = request('start_time', '');
  159. $end_time = request('end_time', '');
  160. $product_name = request('product_name', '');
  161. $product_names = request('product_names', '');
  162. $first_responsible_person = request('first_responsible_person', '');
  163. $responsible_person = request('responsible_person', '');
  164. $platform = request('platform', '');
  165. $company_name = request('company_name', '');
  166. $store_name = request('store_name', '');
  167. $store_names = request('store_names', '');
  168. $source_responsible_person = request('source_responsible_person', '');
  169. $processing_status = request('processing_status', '');
  170. $product_specs = request('product_specs', '');
  171. $online_posting_cunt = request('online_posting_cunt', '');
  172. $category_name = request('category_name', '');
  173. // 时间条件
  174. if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
  175. if ($end_time) $map[] = ['insert_time', '<=', strtotime($end_time)];
  176. // 其他条件
  177. if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
  178. if ($store_name) $map[] = ['store_name', 'like', "%$store_name%"];
  179. if ($category_name) $map[] = ['category_name', 'like', "%$category_name%"];
  180. //多选平台查询
  181. if ($platform && is_string($platform)) {
  182. $platform = explode(',', $platform);
  183. $ViolationProductModel = $ViolationProductModel->whereIn('platform', $platform);
  184. }
  185. //多选处理状态查询
  186. if ($processing_status && is_string($processing_status)) {
  187. $processing_status = explode(',', $processing_status);
  188. $ViolationProductModel = $ViolationProductModel->whereIn('processing_status', $processing_status);
  189. }
  190. //多选状态查询
  191. if ($status && is_string($status)) {
  192. $status = explode(',', $status);
  193. $ViolationProductModel = $ViolationProductModel->whereIn('status', $status);
  194. }
  195. //多选店铺名称查询
  196. if ($store_names && is_string($store_names)) {
  197. $store_names = explode(',', $store_names);
  198. $ViolationProductModel = $ViolationProductModel->whereIn('store_name', $store_names);
  199. }
  200. //多选违规挂网次数查询
  201. if ($online_posting_cunt && is_string($online_posting_cunt)) {
  202. $online_posting_cunt = explode(',', $online_posting_cunt);
  203. $ViolationProductModel = $ViolationProductModel->whereIn('online_posting_cunt', $online_posting_cunt);
  204. }
  205. //多选规格查询
  206. if ($product_specs && is_string($product_specs)) {
  207. $product_specs = explode(',', $product_specs);
  208. $ViolationProductModel = $ViolationProductModel->whereIn('product_specs', $product_specs);
  209. }
  210. //多选商品查询
  211. if ($product_names && is_string($product_names)) {
  212. $product_names = explode(',', $product_names);
  213. $ViolationProductModel = $ViolationProductModel->whereIn('product_name', $product_names);
  214. }
  215. //多选公司查询
  216. if ($company_name && is_string($company_name)) {
  217. $company_name = explode(',', $company_name);
  218. $ViolationProductModel = $ViolationProductModel->whereIn('company_name', $company_name);
  219. }
  220. //多选第一责任人
  221. if ($first_responsible_person && is_string($first_responsible_person)) {
  222. $first_responsible_person = explode(',', $first_responsible_person);
  223. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $first_responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  224. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  225. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  226. });
  227. }
  228. //多选责任人
  229. if ($responsible_person && is_string($responsible_person)) {
  230. $responsible_person = explode(',', $responsible_person);
  231. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  232. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  233. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  234. });
  235. }
  236. //多选溯源责任人
  237. if ($source_responsible_person && is_string($source_responsible_person)) {
  238. $source_responsible_person = explode(',', $source_responsible_person);
  239. $subQuery = $ViolationProductMemberModel->whereIn('employee_id', $source_responsible_person)->distinct('violation_product_logid')->select('violation_product_logid');
  240. $ViolationProductModel = $ViolationProductModel->whereIn('id', function ($query1) use ($subQuery) {
  241. $query1->select('violation_product_logid')->fromSub($subQuery, 'sub1');
  242. });
  243. }
  244. $result = $ViolationProductModel
  245. ->where($map)
  246. ->orderByDesc('id')
  247. ->get()->toarray();
  248. // 分配数据
  249. if (!$result) return json_send(['code' => 'error', 'msg' => '暂无数据']);
  250. // 处理责任人展示信息
  251. $list_data = $this->processing_responsible_person($result);
  252. // 导出数据
  253. $this->export_download($list_data);
  254. }
  255. /**
  256. * 处理责任人展示信息
  257. * @author 唐远望
  258. * @version 1.0
  259. * @date 2025-12-17
  260. */
  261. public function processing_responsible_person($result)
  262. {
  263. $EmployeeModel = new EmployeeModel();
  264. //获取所有员工
  265. $employeee_data = $EmployeeModel->select(['id', 'name'])->get()->toarray();
  266. $employeee_list = [];
  267. if (!empty($employeee_data)) {
  268. foreach ($employeee_data as $key => $value) {
  269. $employeee_list[$value['id']] = $value['name'];
  270. }
  271. }
  272. if (isset($result) && count($result) > 0) {
  273. foreach ($result as $key => $value) {
  274. //查询第一责任人名称
  275. $first_responsible_person = $value['first_responsible_person'] != '' ? explode(',', $value['first_responsible_person']) : [];
  276. $first_responsible_person_name = [];
  277. if (!empty($first_responsible_person)) {
  278. foreach ($first_responsible_person as $k => $v) {
  279. if (isset($employeee_list[$v])) {
  280. $first_responsible_person_name[] = $employeee_list[$v];
  281. }
  282. }
  283. }
  284. $result[$key]['first_responsible_person_name'] = $first_responsible_person_name;
  285. //查询责任人名称
  286. $responsible_person = $value['responsible_person'] != '' ? explode(',', $value['responsible_person']) : [];
  287. $responsible_person_name = [];
  288. if (!empty($responsible_person)) {
  289. foreach ($responsible_person as $k => $v) {
  290. if (isset($employeee_list[$v])) {
  291. $responsible_person_name[] = $employeee_list[$v];
  292. }
  293. }
  294. }
  295. $result[$key]['responsible_person_name'] = $responsible_person_name;
  296. //查询来源责任人名称
  297. $source_responsible_person = $value['source_responsible_person'] != '' ? explode(',', $value['source_responsible_person']) : [];
  298. $source_responsible_person_name = [];
  299. if (!empty($source_responsible_person)) {
  300. foreach ($source_responsible_person as $k => $v) {
  301. if (isset($employeee_list[$v])) {
  302. $source_responsible_person_name[] = $employeee_list[$v];
  303. }
  304. }
  305. }
  306. $result[$key]['source_responsible_person_name'] = $source_responsible_person_name;
  307. }
  308. }
  309. return $result;
  310. }
  311. /**
  312. * 导出下载
  313. * @author 唐远望
  314. * @version 1.0
  315. * @date 2025-06-17
  316. */
  317. public function export_download($data)
  318. {
  319. // 创建一个新的 Spreadsheet 对象
  320. $spreadsheet = new Spreadsheet();
  321. $sheet = $spreadsheet->getActiveSheet();
  322. //合并单元格
  323. $sheet->mergeCells('A1:Q1');
  324. $sheet->setCellValue('A1', '违规挂网商品导出(导出时间:' . date('Y-m-d H:i:s', time()) . ')'); // 设置合并后的单元格内容
  325. // 获取合并后的单元格样式对象
  326. $style = $sheet->getStyle('A1');
  327. // 设置水平居中和垂直居中
  328. $style->getAlignment()->setHorizontal(Alignment::HORIZONTAL_CENTER)->setVertical(Alignment::VERTICAL_CENTER);
  329. // 然后设置行高以适应两行文本
  330. $sheet->getRowDimension(1)->setRowHeight(40); // 设置行高,单位是磅(point)
  331. // 设置表头
  332. $sheet->setCellValue('A2', '第一责任人');
  333. $sheet->setCellValue('B2', '责任人');
  334. $sheet->setCellValue('C2', '平台');
  335. $sheet->setCellValue('D2', '商品分类');
  336. $sheet->setCellValue('E2', '商品名称');
  337. $sheet->setCellValue('F2', '商品规格');
  338. $sheet->setCellValue('G2', '挂网次数');
  339. $sheet->setCellValue('H2', '链接地址');
  340. $sheet->setCellValue('I2', '店铺名称');
  341. $sheet->setCellValue('J2', '公司名称');
  342. $sheet->setCellValue('K2', '信用代码');
  343. $sheet->setCellValue('L2', '省份');
  344. $sheet->setCellValue('M2', '城市');
  345. $sheet->setCellValue('N2', '溯源责任人');
  346. $sheet->setCellValue('O2', '处理状态');
  347. $sheet->setCellValue('P2', '任务状态');
  348. $sheet->setCellValue('Q2', '记录时间');
  349. $platform_data = [
  350. '0' => '全部',
  351. '1' => '淘宝',
  352. '2' => '京东',
  353. '3' => '拼多多',
  354. '4' => '美团',
  355. '5' => '药师帮',
  356. '6' => '1药城',
  357. '7' => '药久久',
  358. ];
  359. $processing_status_text = [
  360. '1' => '待处理',
  361. ];
  362. $status_text = [
  363. '0' => '有效',
  364. '1' => '无效',
  365. ];
  366. // 填充数据
  367. $row = 3; // 从第2行开始
  368. foreach ($data as $item) {
  369. $first_responsible_person_name = !empty($item['first_responsible_person_name']) ? implode(',', $item['first_responsible_person_name']) : '';
  370. $responsible_person_name = !empty($item['responsible_person_name']) ? implode(',', $item['responsible_person_name']) : '';
  371. $source_responsible_person_name = !empty($item['source_responsible_person_name']) ? implode(',', $item['source_responsible_person_name']) : '';
  372. $sheet->setCellValue('A' . $row, $first_responsible_person_name);
  373. $sheet->setCellValue('B' . $row, $responsible_person_name);
  374. $sheet->setCellValue('C' . $row, isset($platform_data[$item['platform']]) ? $platform_data[$item['platform']] : '');
  375. $sheet->setCellValue('D' . $row, $item['category_name']);
  376. $sheet->setCellValue('E' . $row, $item['product_name']);
  377. $sheet->setCellValue('F' . $row, $item['product_specs']);
  378. $sheet->setCellValue('G' . $row, $item['online_posting_cunt']);
  379. $sheet->setCellValue('H' . $row, $item['link_url']);
  380. $sheet->setCellValue('I' . $row, $item['store_name']);
  381. $sheet->setCellValue('J' . $row, $item['company_name']);
  382. $sheet->setCellValue('K' . $row, $item['social_credit_code']);
  383. $sheet->setCellValue('L' . $row, $item['province_name']);
  384. $sheet->setCellValue('M' . $row, $item['city_name']);
  385. $sheet->setCellValue('N' . $row, $source_responsible_person_name);
  386. $sheet->setCellValue('O' . $row, isset($processing_status_text[$item['processing_status']]) ? $processing_status_text[$item['processing_status']] : '');
  387. $sheet->setCellValue('P' . $row, isset($status_text[$item['status']]) ? $status_text[$item['status']] : '');
  388. $sheet->setCellValue('Q' . $row, date('Y-m-d H:i:s', $item['insert_time']));
  389. $row++;
  390. }
  391. foreach (range('A', 'P') as $column) {
  392. $sheet->getColumnDimension($column)->setAutoSize(true);
  393. }
  394. // 生成 Excel 文件
  395. $writer = new Xlsx($spreadsheet);
  396. // 直接输出到浏览器(下载)
  397. $filename = '违规挂网商品数据' . date('YmdHis') . '.xlsx';
  398. header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
  399. header('Content-Disposition: attachment;filename="' . $filename . '"');
  400. header('Cache-Control: max-age=0');
  401. $writer->save('php://output');
  402. exit;
  403. }
  404. /**
  405. * 详情
  406. * @author 唐远望
  407. * @version 1.0
  408. * @date 2025-12-08
  409. */
  410. public function detail(Request $request, ViolationProductModel $ViolationProductModel, EmployeeModel $EmployeeModel)
  411. {
  412. $request->scene('detail')->validate();
  413. // 接收参数
  414. $id = request('id', 0);
  415. $map = ['id' => $id];
  416. $data = $ViolationProductModel->where($map)->first();
  417. if (!$data) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  418. //查询第一责任人名称
  419. $first_responsible_person = explode(',', $data->first_responsible_person);
  420. $first_responsible_person_name = $EmployeeModel->whereIn('id', $first_responsible_person)->pluck('name')->toarray();
  421. $data->first_responsible_person_name = $first_responsible_person_name;
  422. //查询责任人名称
  423. $responsible_person = explode(',', $data->responsible_person);
  424. $responsible_person_name = $EmployeeModel->whereIn('id', $responsible_person)->pluck('name')->toarray();
  425. $data->responsible_person_name = $responsible_person_name;
  426. //查询来源责任人名称
  427. $source_responsible_person = explode(',', $data->source_responsible_person);
  428. $source_responsible_person_name = $EmployeeModel->whereIn('id', $source_responsible_person)->pluck('name')->toarray();
  429. $data->source_responsible_person_name = $source_responsible_person_name;
  430. // 加载模板
  431. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
  432. }
  433. /**
  434. * 添加
  435. * @author 唐远望
  436. * @version 1.0
  437. * @date 2025-12-08
  438. *
  439. */
  440. public function add(Request $request, ViolationProductModel $ViolationProductModel)
  441. {
  442. $request->scene('add')->validate();
  443. // 接收数据
  444. $all_data = request()->all();
  445. $store_scope = request('store_scope', '');
  446. $all_data['store_scope'] = $store_scope;
  447. //查询是否存在
  448. $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs']];
  449. $data = $ViolationProductModel->where($map)->first();
  450. if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']);
  451. // 写入数据表
  452. $result = $ViolationProductModel->addLowPriceGoods($all_data);
  453. // 如果操作失败
  454. if (!$result) return json_send(['code' => 'error', 'msg' => '新增失败']);
  455. // 告知结果
  456. return json_send(['code' => 'success', 'msg' => '新增成功']);
  457. }
  458. /**
  459. * 修改
  460. * @author 唐远望
  461. * @version 1.0
  462. * @date 2025-12-08
  463. *
  464. */
  465. public function edit(Request $request, ViolationProductModel $ViolationProductModel)
  466. {
  467. $request->scene('edit')->validate();
  468. // 接收参数
  469. $id = request('id', 0);
  470. // 接收数据
  471. $all_data = request()->all();
  472. $store_scope = request('store_scope', '');
  473. $all_data['store_scope'] = $store_scope;
  474. //查询是否存在
  475. $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs']];
  476. $data = $ViolationProductModel->where($map)->where('id', '!=', $id)->first();
  477. if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']);
  478. // 更新数据表
  479. $where = ['id' => $id];
  480. $result = $ViolationProductModel->updateLowPriceGoods($where, $all_data);
  481. // 如果操作失败
  482. if (!$result) return json_send(['code' => 'error', 'msg' => '修改失败']);
  483. // 告知结果
  484. return json_send(['code' => 'success', 'msg' => '修改成功']);
  485. }
  486. /**
  487. * 修改状态
  488. * @author 唐远望
  489. * @version 1.0
  490. * @date 2025-12-08
  491. *
  492. */
  493. public function set_status(Request $request, ViolationProductModel $ViolationProductModel)
  494. {
  495. // 验证参数
  496. $request->scene('set_status')->validate();
  497. // 接收数据
  498. $id = request('id', 0);
  499. $status = request('status', 0);
  500. // 查询用户
  501. $where = ['id' => $id];
  502. // 执行修改
  503. $result = $ViolationProductModel->changeStatus($where, $status);
  504. // 提示新增失败
  505. if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']);
  506. // 告知结果
  507. return json_send(['code' => 'success', 'msg' => '设置成功']);
  508. }
  509. /**
  510. * 修改处理状态
  511. * @author 唐远望
  512. * @version 1.0
  513. * @date 2025-12-08
  514. *
  515. */
  516. public function set_processing_status(Request $request, ViolationProductModel $ViolationProductModel)
  517. {
  518. // 验证参数
  519. $request->scene('set_processing_status')->validate();
  520. // 接收数据
  521. $id = request('id', 0);
  522. $processing_status = request('processing_status', 0);
  523. // 查询用户
  524. $where = ['id' => $id];
  525. // 执行修改
  526. $result = $ViolationProductModel->changeProcessingStatus($where, $processing_status);
  527. // 提示新增失败
  528. if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']);
  529. // 告知结果
  530. return json_send(['code' => 'success', 'msg' => '设置成功']);
  531. }
  532. /**
  533. * 删除
  534. * @author 唐远望
  535. * @version 1.0
  536. * @date 2025-12-08
  537. *
  538. */
  539. public function delete(Request $request, ViolationProductModel $ViolationProductModel)
  540. {
  541. // 验证参数
  542. $request->scene('delete')->validate();
  543. // 接收数据
  544. $id = request('id', 0);
  545. // 查询用户
  546. $where = ['id' => $id];
  547. // 执行删除
  548. $result = $ViolationProductModel->deleteLowPriceGoods($where);
  549. // 提示删除失败
  550. if (!$result) return json_send(['code' => 'error', 'msg' => '删除失败']);
  551. // 告知结果
  552. return json_send(['code' => 'success', 'msg' => '删除成功']);
  553. }
  554. /**
  555. * 执行数据清洗
  556. * @author 唐远望
  557. * @version 1.0
  558. * @date 2025-12-11
  559. *
  560. */
  561. public function data_cleaning(Request $request)
  562. {
  563. // 验证参数
  564. $request->scene('data_cleaning')->validate();
  565. $access_token = request('access_token', '');
  566. $admin_id = $access_token['uid'];
  567. $message_data = ['page' => '1', 'limit' => 50, 'admin_id' => $admin_id];
  568. ViolationProductJobs::dispatch($message_data);
  569. // ViolationProductJobs::dispatchSync($message_data);
  570. // 告知结果
  571. return json_send(['code' => 'success', 'msg' => '执行成功']);
  572. }
  573. }