ViolationProduct.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290
  1. <?php
  2. namespace App\Http\Controllers\Manager\WashConfig;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\Manager\WashConfig\ViolationProduct as Request;
  5. use App\Models\Manager\WashConfig\ViolationProduct as ViolationProductModel;
  6. use App\Models\Manager\WashConfig\ViolationStore as ViolationStoreModel;
  7. use App\Models\Manager\WashConfig\ViolationProductCompany as ViolationProductCompanyModel;
  8. use App\Models\Manager\WashConfig\ProductCategory as ProductCategoryModel;
  9. use Illuminate\Support\Facades\DB;
  10. /**
  11. * 数据清洗-违规产品配置
  12. * @author 唐远望
  13. * @version 1.0
  14. * @date 2025-12-03
  15. */
  16. class ViolationProduct extends Controller
  17. {
  18. /**
  19. * 列表
  20. * @author 唐远望
  21. * @version 1.0
  22. * @date 2025-12-03
  23. *
  24. */
  25. public function list(Request $request, ViolationProductModel $ViolationProductModel, ViolationStoreModel $ViolationStoreModel, ViolationProductCompanyModel $ViolationProductCompanyModel, ProductCategoryModel $ProductCategoryModel)
  26. {
  27. $request->scene('list')->validate();
  28. // 查询条件
  29. $map = [];
  30. $limit = request('limit', config('page_num', 10));
  31. $status = request('status', '');
  32. $start_time = request('start_time', '');
  33. $end_time = request('end_time', '');
  34. $product_name = request('product_name', '');
  35. $platform = request('platform', '');
  36. $store_scope = request('store_scope', '');
  37. $company_scope = request('company_scope', '');
  38. $category_id = request('category_id', '');
  39. // 时间条件
  40. if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
  41. if ($end_time) $map[] = ['insert_time', '<=', strtotime($end_time)];
  42. // 其他条件
  43. if (is_numeric($status)) $map[] = ['status', '=', $status];
  44. if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
  45. if ($platform) $map[] = ['platform', 'like', "%$platform%"];
  46. if ($store_scope) $map[] = ['store_scope', '=', $store_scope];
  47. if ($company_scope) $map[] = ['company_scope', '=', $company_scope];
  48. if ($category_id) $map[] = ['category_id', '=', $category_id];
  49. // 查询数据
  50. $result = $ViolationProductModel->query()
  51. ->where($map)
  52. ->orderByDesc('id')
  53. ->paginate($limit)->toarray();
  54. // 分配数据
  55. if (!$result) return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
  56. if (isset($result['data']) && count($result['data']) > 0) {
  57. foreach ($result['data'] as $key => $value) {
  58. $result['data'][$key]['platform'] = isset($value['platform']) ? explode(',', $value['platform']) : '';
  59. $category_name = $value['category_id'] > 0 ? $ProductCategoryModel->where('id', $value['category_id'])->value('name') : '';
  60. $result['data'][$key]['category_name'] = $category_name;
  61. //查询店铺名称
  62. if (trim($value['store_scope']) == '') {
  63. $result['data'][$key]['store_name'] = ['全部店铺'];
  64. } else {
  65. $result['data'][$key]['store_name'] = '';
  66. }
  67. //查询公司名称
  68. if ($value['company_scope'] == '1') {
  69. $result['data'][$key]['company_name'] = ['全部公司'];
  70. } else {
  71. $company_data = $ViolationProductCompanyModel->where('violation_product_logid', $value['id'])
  72. ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_violation_product_company.company_id')
  73. ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_violation_product_company.company_id'])->get()->toArray();
  74. $result['data'][$key]['company_name'] = !empty($company_data) ? array_column($company_data, 'company_name') : '';
  75. }
  76. }
  77. }
  78. // 加载模板
  79. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  80. }
  81. /**
  82. * 详情
  83. * @author 唐远望
  84. * @version 1.0
  85. * @date 2025-12-03
  86. */
  87. public function detail(Request $request, ViolationProductModel $ViolationProductModel, ViolationProductCompanyModel $ViolationProductCompanyModel, ProductCategoryModel $ProductCategoryModel)
  88. {
  89. $request->scene('detail')->validate();
  90. // 接收参数
  91. $id = request('id', 0);
  92. $map = ['id' => $id];
  93. $data = $ViolationProductModel->where($map)->first();
  94. if (!$data) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  95. //查询店铺名称
  96. if (trim($data['store_scope']) == '') {
  97. $data['store_name'] = ['全部店铺'];
  98. } else {
  99. $data['store_name'] = '';
  100. }
  101. //查询公司名称
  102. if ($data->company_scope == '1') {
  103. $data->company_name = ['全部公司'];
  104. $data->company_ids = '';
  105. } else {
  106. $company_data = $ViolationProductCompanyModel->where('violation_product_logid', $data->id)
  107. ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_violation_product_company.company_id')
  108. ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_violation_product_company.company_id'])->get()->toArray();
  109. $data->company_name = !empty($company_data) ? array_column($company_data, 'company_name') : '';
  110. $data->company_ids = !empty($company_data) ? array_column($company_data, 'company_id') : '';
  111. }
  112. $data->platform = isset($data->platform) ? explode(',', $data->platform) : '';
  113. $data->category_name = $data->category_id > 0 ? $ProductCategoryModel->where('id', $data->category_id)->value('name') : '';
  114. // 加载模板
  115. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
  116. }
  117. /**
  118. * 添加
  119. * @author 唐远望
  120. * @version 1.0
  121. * @date 2025-12-03
  122. *
  123. */
  124. public function add(Request $request, ViolationProductModel $ViolationProductModel)
  125. {
  126. $request->scene('add')->validate();
  127. // 接收数据
  128. $all_data = request()->all();
  129. $store_scope = request('store_scope', '');
  130. $all_data['store_scope'] = $store_scope;
  131. $company_scope = request('company_scope', '');
  132. $all_data['company_scope'] = $company_scope;
  133. $category_id = request('category_id', '');
  134. $all_data['category_id'] = $category_id;
  135. $specify_responsible_person = request('specify_responsible_person', '0');
  136. $all_data['specify_responsible_person'] = $specify_responsible_person;
  137. //采集信息配置
  138. $sampling_cycle = request('sampling_cycle', '0');
  139. $sampling_start_time = request('sampling_start_time', '');
  140. $sampling_end_time = request('sampling_end_time', '');
  141. $all_data['sampling_cycle'] = $sampling_cycle;
  142. $all_data['sampling_start_time'] = strtotime($sampling_start_time . '00:00:00');
  143. $all_data['sampling_end_time'] = strtotime($sampling_end_time . '23:59:59');
  144. //查询是否存在
  145. $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs'], 'platform' => $all_data['platform']];
  146. $data = $ViolationProductModel->where($map)->first();
  147. if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']);
  148. // 写入数据表
  149. $result = $ViolationProductModel->addViolationProduct($all_data);
  150. // 如果操作失败
  151. if (!$result) return json_send(['code' => 'error', 'msg' => '新增失败']);
  152. // 记录行为
  153. $admin_id = request('access_token.uid', 0); //用户ID
  154. $table_name = $ViolationProductModel->getTable();
  155. $notes_type = 1; //操作类型,1添加,2修改,3=删除
  156. $this->addAdminHistory('清洗配置-禁止商品管理', $admin_id, $table_name, $notes_type, [], $all_data, '新增了违规商品' . $all_data['product_name'] . '信息');
  157. // 告知结果
  158. return json_send(['code' => 'success', 'msg' => '新增成功']);
  159. }
  160. /**
  161. * 修改
  162. * @author 唐远望
  163. * @version 1.0
  164. * @date 2025-12-03
  165. *
  166. */
  167. public function edit(Request $request, ViolationProductModel $ViolationProductModel)
  168. {
  169. $request->scene('edit')->validate();
  170. // 接收参数
  171. $id = request('id', 0);
  172. // 接收数据
  173. $all_data = request()->all();
  174. $store_scope = request('store_scope', '');
  175. $all_data['store_scope'] = $store_scope;
  176. $company_scope = request('company_scope', '');
  177. $all_data['company_scope'] = $company_scope;
  178. $category_id = request('category_id', '');
  179. $all_data['category_id'] = $category_id;
  180. $specify_responsible_person = request('specify_responsible_person', '0');
  181. $all_data['specify_responsible_person'] = $specify_responsible_person;
  182. //采集信息配置
  183. $sampling_cycle = request('sampling_cycle', '0');
  184. $sampling_start_time = request('sampling_start_time', '');
  185. $sampling_end_time = request('sampling_end_time', '');
  186. $all_data['sampling_cycle'] = $sampling_cycle;
  187. $all_data['sampling_start_time'] = strtotime($sampling_start_time . '00:00:00');
  188. $all_data['sampling_end_time'] = strtotime($sampling_end_time . '23:59:59');
  189. //查询是否存在
  190. $map = ['product_name' => $all_data['product_name'], 'product_specs' => $all_data['product_specs'], 'platform' => $all_data['platform']];
  191. $data = $ViolationProductModel->where($map)->where('id', '!=', $id)->first();
  192. if ($data) return json_send(['code' => 'error', 'msg' => '记录已存在']);
  193. // 更新数据表
  194. $where = ['id' => $id];
  195. $ViolationProduct = $ViolationProductModel->where($where)->first();
  196. if (!$ViolationProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  197. $result = $ViolationProductModel->editViolationProduct_content($ViolationProduct, $all_data);
  198. // 如果操作失败
  199. if (!$result) return json_send(['code' => 'error', 'msg' => '修改失败']);
  200. // 记录行为
  201. $admin_id = request('access_token.uid', 0); //用户ID
  202. $table_name = $ViolationProductModel->getTable();
  203. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  204. $this->addAdminHistory('清洗配置-禁止商品管理', $admin_id, $table_name, $notes_type, $ViolationProduct->toarray(), $all_data, '修改了违规商品' . $ViolationProduct->product_name . '信息');
  205. // 告知结果
  206. return json_send(['code' => 'success', 'msg' => '修改成功']);
  207. }
  208. /**
  209. * 修改状态
  210. * @author 唐远望
  211. * @version 1.0
  212. * @date 2025-12-03
  213. *
  214. */
  215. public function set_status(Request $request, ViolationProductModel $ViolationProductModel)
  216. {
  217. // 验证参数
  218. $request->scene('set_status')->validate();
  219. // 接收数据
  220. $id = request('id', 0);
  221. $status = request('status', 0);
  222. // 查询用户
  223. $where = ['id' => $id];
  224. $ViolationProduct = $ViolationProductModel->where($where)->first();
  225. if (!$ViolationProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  226. // 执行修改
  227. $result = $ViolationProductModel->changeStatus($ViolationProduct, $status);
  228. // 提示新增失败
  229. if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']);
  230. // 记录行为
  231. $admin_id = request('access_token.uid', 0); //用户ID
  232. $table_name = $ViolationProductModel->getTable();
  233. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  234. $this->addAdminHistory('清洗配置-禁止商品管理', $admin_id, $table_name, $notes_type,[],['status'=> $status], '修改了违规商品' . $ViolationProduct->product_name . '状态');
  235. // 告知结果
  236. return json_send(['code' => 'success', 'msg' => '设置成功']);
  237. }
  238. /**
  239. * 删除
  240. * @author 唐远望
  241. * @version 1.0
  242. * @date 2025-12-03
  243. *
  244. */
  245. public function delete(Request $request, ViolationProductModel $ViolationProductModel)
  246. {
  247. // 验证参数
  248. $request->scene('delete')->validate();
  249. // 接收数据
  250. $id = request('id', 0);
  251. // 查询用户
  252. $where = ['id' => $id];
  253. // 执行删除
  254. $ViolationProduct = $ViolationProductModel->where($where)->first();
  255. if (!$ViolationProduct) {
  256. return false;
  257. }
  258. DB::beginTransaction();
  259. try {
  260. $ViolationProductCompanyModel = new ViolationProductCompanyModel();
  261. $company_id_log = $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->get();
  262. if (!empty($company_id_log)) {
  263. $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->delete();
  264. }
  265. $ViolationProduct->delete();
  266. // 记录行为
  267. $admin_id = request('access_token.uid', 0); //用户ID
  268. $table_name = $ViolationProductModel->getTable();
  269. $notes_type = 3; //操作类型,1添加,2修改,3=删除
  270. $this->addAdminHistory('清洗配置-禁止商品管理', $admin_id, $table_name, $notes_type, $ViolationProduct->toarray(), [], '删除了违规商品' . $ViolationProduct->product_name . '信息');
  271. // 告知结果
  272. DB::commit();
  273. return json_send(['code' => 'success', 'msg' => '删除成功']);
  274. // 成功处理...
  275. } catch (\Exception $e) {
  276. DB::rollBack();
  277. // 错误处理...
  278. return json_send(['code' => 'error', 'msg' => '删除失败']);
  279. }
  280. }
  281. }