Product.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598
  1. <?php
  2. namespace App\Http\Controllers\Manager\Collect;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\Manager\Collect\Product as Request;
  5. use App\Models\Manager\Collect\Product as ProductModel;
  6. use Illuminate\Support\Facades\DB;
  7. use App\Models\Manager\Collect\ProductKeyword as ProductKeywordModel;
  8. /**
  9. * 采集配置-商品管理
  10. * @author 唐远望
  11. * @version 1.0
  12. * @date 2025-12-30
  13. */
  14. class Product extends Controller
  15. {
  16. /**
  17. * 列表
  18. * @author 唐远望
  19. * @version 1.0
  20. * @date 2025-12-30
  21. *
  22. */
  23. public function list(Request $request, ProductModel $ProductModel)
  24. {
  25. $request->scene('list')->validate();
  26. $admin_company_id = request('admin_company_id', '0');
  27. $company_id = request('access_token.company_id', '0');
  28. $is_admin = request('access_token.is_admin', '0');
  29. // 查询条件
  30. $map = [];
  31. $limit = request('limit', config('page_num', 10));
  32. $status = request('status', '');
  33. $start_time = request('start_time', '');
  34. $end_time = request('end_time', '');
  35. $product_name = request('product_name', '');
  36. $platforms = request('platform', '');
  37. $product_brand = request('product_brand', '');
  38. $is_multiple_accounts = request('is_multiple_accounts', '');
  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 (is_numeric($is_multiple_accounts)) $map[] = ['is_multiple_accounts', '=', $is_multiple_accounts];
  46. if (is_numeric($platforms) || $platforms) {
  47. $ProductModel = $ProductModel
  48. ->where(function ($query) use ($platforms) {
  49. $platforms = explode(',', $platforms);
  50. foreach ($platforms as $platform) {
  51. $query->orWhereRaw("FIND_IN_SET(?, platform)", [$platform]);
  52. }
  53. });
  54. }
  55. if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
  56. // 权限判断
  57. if ($is_admin != 1 && $company_id != 0) {
  58. $map[] = ['company_id', '=', $company_id];
  59. } else {
  60. $map[] = ['company_id', '=', $admin_company_id];
  61. }
  62. // 查询数据
  63. $result = $ProductModel
  64. ->where($map)
  65. ->with(['product_keyword'])
  66. ->orderByDesc('id')
  67. ->paginate($limit)->toarray();
  68. // 分配数据
  69. if (!$result) return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
  70. if (isset($result['data']) && count($result['data']) > 0) {
  71. foreach ($result['data'] as $key => $value) {
  72. $result['data'][$key]['platform'] = isset($value['platform']) ? explode(',', $value['platform']) : '';
  73. $product_specs = isset($value['product_specs']) ? explode(',', $value['product_specs']) : '';
  74. //移除空数组
  75. $result['data'][$key]['product_specs'] = $product_specs ? array_filter($product_specs) : '';
  76. $sampling_cycle = isset($value['sampling_cycle']) ? explode(',', $value['sampling_cycle']) : '';
  77. $result['data'][$key]['sampling_cycle'] = $sampling_cycle ? array_filter($sampling_cycle) : '';
  78. $round_number_config = isset($value['round_number_config']) ? json_decode($value['round_number_config'],true) : '';
  79. $result['data'][$key]['round_number_config'] = $round_number_config ? array_filter($round_number_config) : '';
  80. }
  81. }
  82. // 加载模板
  83. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  84. }
  85. /**
  86. * 商品名称规格列表
  87. * @author 唐远望
  88. * @version 1.0
  89. * @date 2026-03-25
  90. *
  91. */
  92. public function product_name_specs_list(Request $request, ProductModel $ProductModel, ProductKeywordModel $ProductKeywordModel)
  93. {
  94. $request->scene('product_name_specs_list')->validate();
  95. $admin_company_id = request('admin_company_id', '0');
  96. $company_id = request('access_token.company_id', '0');
  97. $is_admin = request('access_token.is_admin', '0');
  98. // 查询条件
  99. $map = [];
  100. $map2 = [];
  101. $map3 = [];
  102. $start_time = request('start_time', '');
  103. $end_time = request('end_time', '');
  104. $product_name = request('product_name', '');
  105. $product_brand = request('product_brand', '');
  106. // 时间条件
  107. if ($start_time) {
  108. $map[] = ['insert_time', '>=', strtotime($start_time)];
  109. $map2[] = ['insert_time', '>=', strtotime($start_time)];
  110. $map3[] = ['insert_time', '>=', strtotime($start_time)];
  111. }
  112. if ($end_time) {
  113. $map[] = ['insert_time', '<=', strtotime($end_time)];
  114. $map2[] = ['insert_time', '<=', strtotime($end_time)];
  115. $map3[] = ['insert_time', '<=', strtotime($end_time)];
  116. }
  117. // 其他条件
  118. $map[] = ['status', '=', 0];
  119. if ($product_name) $map2[] = ['product_name', 'like', "%$product_name%"];
  120. if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
  121. // 权限判断
  122. if ($is_admin != 1 && $company_id != 0) {
  123. $map[] = ['company_id', '=', $company_id];
  124. $map2[] = ['company_id', '=', $company_id];
  125. $map3[] = ['company_id', '=', $company_id];
  126. } else {
  127. $map[] = ['company_id', '=', $admin_company_id];
  128. $map2[] = ['company_id', '=', $admin_company_id];
  129. $map3[] = ['company_id', '=', $admin_company_id];
  130. }
  131. // 查询数据
  132. $result = $ProductModel->query()
  133. ->where($map)
  134. ->where([['product_brand', '!=', ''], ['product_brand', '!=', null]])
  135. ->select([DB::raw('MAX(id) as id'), 'product_brand'])
  136. ->groupBy(['product_brand'])
  137. ->orderByDesc('id')->get()->toarray();
  138. if (!$result) return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
  139. foreach ($result as $key => $value) {
  140. $product_list = $ProductModel->query()
  141. ->where($map2)
  142. ->where([['product_name', '!=', ''], ['product_name', '!=', null]])
  143. ->where(['product_brand' => $value['product_brand']])
  144. ->select([DB::raw('MAX(id) as id'), 'product_name'])
  145. ->groupBy(['product_name'])
  146. ->orderByDesc('id')->get()->toarray();
  147. if (!empty($product_list)) {
  148. foreach ($product_list as $key2 => $value2) {
  149. $product_keyword = $ProductKeywordModel->query()
  150. ->where(['collect_product_id' => $value2['id']])
  151. ->select('keyword')
  152. ->groupBy(['keyword'])
  153. ->get()->toarray();
  154. $product_list[$key2]['product_keyword'] = $product_keyword ? array_column($product_keyword, 'keyword') : [];
  155. $product_specs = $ProductModel->query()
  156. ->where($map3)
  157. ->where([['product_specs', '!=', ''], ['product_specs', '!=', null]])
  158. ->where(['product_name' => $value2['product_name']])
  159. ->where(['product_brand' => $value['product_brand']])
  160. ->select([DB::raw('MAX(id) as id'), 'product_specs'])
  161. ->groupBy(['product_specs'])
  162. ->orderByDesc('id')->get()->toarray();
  163. $product_specs_tring = [];
  164. if (count($product_specs) > 0) {
  165. foreach ($product_specs as $key3 => $value3) {
  166. $product_specs_item = isset($value3['product_specs']) ? explode(',', $value3['product_specs']) : '';
  167. //合并数组
  168. if (!empty($product_specs_item)) {
  169. $product_specs_tring = array_merge($product_specs_tring, $product_specs_item);
  170. }
  171. }
  172. //去重
  173. $product_specs_tring = array_unique($product_specs_tring);
  174. }
  175. //移除空数组
  176. $product_list[$key2]['product_specs'] = $product_specs_tring ? array_filter($product_specs_tring) : '';
  177. }
  178. }
  179. $result[$key]['product_list'] = !empty($product_list) ? $product_list : [];
  180. }
  181. // 加载模板
  182. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  183. }
  184. /**
  185. * 详情
  186. * @author 唐远望
  187. * @version 1.0
  188. * @date 2025-12-30
  189. */
  190. public function detail(Request $request, ProductModel $ProductModel)
  191. {
  192. $request->scene('detail')->validate();
  193. $admin_company_id = request('admin_company_id', '0');
  194. $company_id = request('access_token.company_id', '0');
  195. $is_admin = request('access_token.is_admin', '0');
  196. // 接收参数
  197. $id = request('id', 0);
  198. $map = ['id' => $id];
  199. // 权限判断
  200. if ($is_admin != 1 && $company_id != 0) {
  201. $map['company_id'] = $company_id;
  202. } else {
  203. $map['company_id'] = $admin_company_id;
  204. }
  205. $data = $ProductModel->where($map)->with(['product_keyword'])->first();
  206. if (!$data) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  207. $data->platform = isset($data->platform) ? explode(',', $data->platform) : '';
  208. $product_specs = isset($data->product_specs) ? explode(',', $data->product_specs) : '';
  209. //移除空数组
  210. $data->product_specs = $product_specs ? array_filter($product_specs) : '';
  211. $sampling_cycle = isset($data->sampling_cycle) ? explode(',', $data->sampling_cycle) : '';
  212. $data->sampling_cycle = $sampling_cycle ? array_filter($sampling_cycle) : '';
  213. $round_number_config = isset($data->round_number_config) ? json_decode($data->round_number_config,true) : '';
  214. $data->round_number_config = $round_number_config ? array_filter($round_number_config) : '';
  215. // 加载模板
  216. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
  217. }
  218. /**
  219. * 添加
  220. * @author 唐远望
  221. * @version 1.0
  222. * @date 2025-12-30
  223. *
  224. */
  225. public function add(Request $request, ProductModel $ProductModel)
  226. {
  227. $request->scene('add')->validate();
  228. $admin_company_id = request('admin_company_id', '0');
  229. $company_id = request('access_token.company_id', '0');
  230. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  231. //商品启用数量
  232. // $product_count = $ProductModel->where('status', 0)->count();
  233. //判断是否超过限制
  234. // if ($product_count >= 50) {
  235. // return json_send(['code' => 'error', 'msg' => '启用数量超过限制,不能超过50条']);
  236. // }
  237. // 接收数据
  238. $all_data = request()->all();
  239. $product_brand = request('product_brand', '');
  240. $product_keyword = request('product_keyword', '');
  241. $minimum_order_quantity = request('minimum_order_quantity', 1);
  242. $all_data['platform'] = request('platform', '');
  243. $all_data['product_specs'] = request('product_specs', '');
  244. $all_data['product_brand'] = $product_brand;
  245. $all_data['product_keyword'] = $product_keyword;
  246. $minimum_order_quantity = request('minimum_order_quantity', 1);
  247. $sampling_cycle = request('sampling_cycle', '');
  248. $sampling_start_time = request('sampling_start_time', '');
  249. $sampling_end_time = request('sampling_end_time', '');
  250. $round_number = request('round_number', 1);
  251. $is_multiple_accounts = request('is_multiple_accounts', 0);
  252. $round_number_config = request('round_number_config', '');
  253. $all_data['round_number_config'] = !empty($round_number_config) ? json_encode($round_number_config):'';
  254. $all_data['is_multiple_accounts'] = $is_multiple_accounts;
  255. $all_data['round_number'] = $round_number;
  256. $all_data['sampling_cycle'] = $sampling_cycle;
  257. $all_data['sampling_start_time'] = $sampling_start_time ? strtotime($sampling_start_time . '00:00:00') : '0';
  258. $all_data['sampling_end_time'] = $sampling_end_time ? strtotime($sampling_end_time . '23:59:59') : '0';
  259. $all_data['minimum_order_quantity'] = $minimum_order_quantity;
  260. if(is_numeric($round_number) && $round_number > 2) return json_send(['code' => 'error', 'msg' => '轮次数量不能超过2']);
  261. if ($all_data['sampling_start_time'] && strtotime(date('Y-m-d', $all_data['sampling_start_time']) . '23:59:59') < time()) return json_send(['code' => 'error', 'msg' => '采集开始时间必须大于当前时间']);
  262. if ($all_data['sampling_end_time'] && $all_data['sampling_end_time'] < time()) return json_send(['code' => 'error', 'msg' => '采集结束时间必须大于当前时间']);
  263. $platform_string = $all_data['platform'];
  264. if (empty($platform_string)) return json_send(['code' => 'error', 'msg' => '平台不能为空']);
  265. $enable_full_quantity = request('enable_full_quantity', 0); //全量,0启用,1禁用
  266. $all_data['enable_full_quantity'] = $enable_full_quantity;
  267. if (trim($product_keyword) != '') {
  268. $product_keyword_count = count(explode(',', $product_keyword));
  269. if ($product_keyword_count > 5) {
  270. return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
  271. }
  272. }
  273. if ($enable_full_quantity == 1 && $all_data['product_specs'] == '') {
  274. return json_send(['code' => 'error', 'msg' => '非全量采集,商品规格不能为空']);
  275. }
  276. //查询是否存在
  277. $map = ['product_name' => $all_data['product_name']];
  278. if ($product_brand != '') $map['product_brand'] = $product_brand;
  279. if ($is_admin != 1 && $company_id != 0) {
  280. $map['company_id'] = $company_id;
  281. $all_data['company_id'] = $company_id;
  282. } else {
  283. $map['company_id'] = $admin_company_id;
  284. $all_data['company_id'] = $admin_company_id;
  285. }
  286. $data = $ProductModel->where($map)->first();
  287. if (!empty($data)) {
  288. //继续校验规格是否存在
  289. $product_specs_tring = $all_data['product_specs'];
  290. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  291. $product_specs = $product_specs ? array_unique($product_specs) : '';
  292. //继续校平台是否存在
  293. $platforms = $platform_string ? explode(',', $platform_string) : '';
  294. $platforms = $platforms ? array_unique($platforms) : '';
  295. $platform_data = $ProductModel->platform_index_data();
  296. $map_where = ['product_name' => $all_data['product_name'], 'status' => '0', 'company_id' => $all_data['company_id']];
  297. if ($product_brand != '') $map_where['product_brand'] = $product_brand;
  298. if (!empty($platforms) && $platforms != '') {
  299. foreach ($platforms as $platform) {
  300. $product_specs_log = $ProductModel
  301. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  302. ->where($map_where)
  303. ->where(function ($query) use ($product_specs) {
  304. // 平台条件(固定)
  305. $query->where(function ($query_li) use ($product_specs) {
  306. if (!empty($product_specs)) {
  307. foreach ($product_specs as $product_spec) {
  308. if (empty($product_specs)) continue;
  309. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  310. }
  311. }
  312. });
  313. })->first();
  314. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  315. if (!empty($product_specs_log)) {
  316. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格记录']);
  317. }
  318. }
  319. }
  320. }
  321. // 写入数据表
  322. $result = $ProductModel->addProduct($all_data);
  323. // 如果操作失败
  324. if (!$result) return json_send(['code' => 'error', 'msg' => '新增失败']);
  325. // 记录行为
  326. $admin_id = request('access_token.uid', 0); //用户ID
  327. $table_name = $ProductModel->getTable();
  328. $notes_type = 1; //操作类型,1添加,2修改,3=删除
  329. $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], $all_data, '新增了商品' . $all_data['product_name'] . '信息');
  330. // 告知结果
  331. return json_send(['code' => 'success', 'msg' => '新增成功']);
  332. }
  333. /**
  334. * 修改
  335. * @author 唐远望
  336. * @version 1.0
  337. * @date 2025-12-30
  338. *
  339. */
  340. public function edit(Request $request, ProductModel $ProductModel)
  341. {
  342. $request->scene('edit')->validate();
  343. $admin_company_id = request('admin_company_id', '0');
  344. $company_id = request('access_token.company_id', '0');
  345. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  346. // 接收参数
  347. $id = request('id', 0);
  348. // 接收数据
  349. $all_data = request()->all();
  350. $product_brand = request('product_brand', '');
  351. $product_keyword = request('product_keyword', '');
  352. $minimum_order_quantity = request('minimum_order_quantity', 1);
  353. $all_data['platform'] = request('platform', '');
  354. $all_data['product_specs'] = request('product_specs', '');
  355. $all_data['product_brand'] = $product_brand;
  356. $all_data['product_keyword'] = $product_keyword;
  357. $minimum_order_quantity = request('minimum_order_quantity', 1);
  358. $sampling_cycle = request('sampling_cycle', '');
  359. $sampling_start_time = request('sampling_start_time', '');
  360. $sampling_end_time = request('sampling_end_time', '');
  361. $round_number = request('round_number', 1);
  362. $is_multiple_accounts = request('is_multiple_accounts', 0);
  363. $round_number_config = request('round_number_config', '');
  364. $all_data['round_number_config'] = !empty($round_number_config) ? json_encode($round_number_config):'';
  365. $all_data['is_multiple_accounts'] = $is_multiple_accounts;
  366. $all_data['round_number'] = $round_number;
  367. $all_data['sampling_cycle'] = $sampling_cycle;
  368. $all_data['sampling_start_time'] = $sampling_start_time ? strtotime($sampling_start_time . '00:00:00') : '0';
  369. $all_data['sampling_end_time'] = $sampling_end_time ? strtotime($sampling_end_time . '23:59:59') : '0';
  370. $all_data['minimum_order_quantity'] = $minimum_order_quantity;
  371. if(is_numeric($round_number) && $round_number > 2) return json_send(['code' => 'error', 'msg' => '轮次数量不能超过2']);
  372. if ($all_data['sampling_start_time'] && strtotime(date('Y-m-d', $all_data['sampling_start_time']) . '23:59:59') < time()) return json_send(['code' => 'error', 'msg' => '采集开始时间必须大于当前时间']);
  373. if ($all_data['sampling_end_time'] && $all_data['sampling_end_time'] < time()) return json_send(['code' => 'error', 'msg' => '采集结束时间必须大于当前时间']);
  374. $platform_string = $all_data['platform'];
  375. if (empty($platform_string)) return json_send(['code' => 'error', 'msg' => '平台不能为空']);
  376. $enable_full_quantity = request('enable_full_quantity', 0); //全量,0启用,1禁用
  377. $all_data['enable_full_quantity'] = $enable_full_quantity;
  378. if (trim($product_keyword) != '') {
  379. $product_keyword_count = count(explode(',', $product_keyword));
  380. if ($product_keyword_count > 5) {
  381. return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
  382. }
  383. }
  384. if ($enable_full_quantity == 1 && $all_data['product_specs'] == '') {
  385. return json_send(['code' => 'error', 'msg' => '非全量采集,商品规格不能为空']);
  386. }
  387. //查询是否存在
  388. $map = ['product_brand' => $product_brand, 'product_name' => $all_data['product_name']];
  389. if ($is_admin != 1 && $company_id != 0) {
  390. $map['company_id'] = $company_id;
  391. } else {
  392. $map['company_id'] = $admin_company_id;
  393. }
  394. $all_data['company_id'] = $map['company_id'];
  395. $data = $ProductModel->where($map)->where('id', '!=', $id)->first();
  396. if (!empty($data)) {
  397. //继续校验规格是否存在
  398. $product_specs_tring = $all_data['product_specs'];
  399. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  400. $product_specs = $product_specs ? array_unique($product_specs) : '';
  401. //继续校平台是否存在
  402. $platforms = $platform_string ? explode(',', $platform_string) : '';
  403. $platforms = $platforms ? array_unique($platforms) : '';
  404. $platform_data = $ProductModel->platform_index_data();
  405. $map_where = ['product_name' => $all_data['product_name'], 'status' => '0', 'company_id' => $all_data['company_id']];
  406. if ($product_brand != '') $map_where['product_brand'] = $product_brand;
  407. foreach ($platforms as $platform) {
  408. $product_specs_log = $ProductModel
  409. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  410. ->where($map_where)
  411. ->where('id', '!=', $id)
  412. ->where(function ($query) use ($product_specs) {
  413. // 平台条件(固定)
  414. $query->where(function ($query_li) use ($product_specs) {
  415. if (!empty($product_specs)) {
  416. foreach ($product_specs as $product_spec) {
  417. if (empty($product_specs)) continue;
  418. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  419. }
  420. }
  421. });
  422. })->first();
  423. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  424. if (!empty($product_specs_log)) {
  425. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格记录']);
  426. }
  427. }
  428. }
  429. // 更新数据表
  430. $where = ['id' => $id];
  431. // 权限判断
  432. if ($is_admin != 1 && $company_id != 0) {
  433. $where['company_id'] = $company_id;
  434. } else {
  435. $where['company_id'] = $admin_company_id;
  436. }
  437. $Product = $ProductModel->where($where)->first();
  438. if (!$Product) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  439. $oldData = $Product->toarray();
  440. $result = $ProductModel->editProduct_content($Product, $all_data);
  441. // 如果操作失败
  442. if (!$result) return json_send(['code' => 'error', 'msg' => '修改失败']);
  443. // 记录行为
  444. $admin_id = request('access_token.uid', 0); //用户ID
  445. $table_name = $ProductModel->getTable();
  446. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  447. $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $oldData, $all_data, '修改了商品' . $oldData['product_name'] . '信息');
  448. // 告知结果
  449. return json_send(['code' => 'success', 'msg' => '修改成功']);
  450. }
  451. /**
  452. * 修改状态
  453. * @author 唐远望
  454. * @version 1.0
  455. * @date 2025-12-30
  456. *
  457. */
  458. public function set_status(Request $request, ProductModel $ProductModel)
  459. {
  460. // 验证参数
  461. $request->scene('set_status')->validate();
  462. $admin_company_id = request('admin_company_id', '0');
  463. $company_id = request('access_token.company_id', '0');
  464. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  465. // 接收数据
  466. $id = request('id', 0);
  467. $status = request('status', 0);
  468. if ($status == 0) {
  469. //获取商品启用数量
  470. // $product_count = $ProductModel->where('status', 0)->count();
  471. //判断是否超过限制
  472. // if ($product_count >= 50) {
  473. // return json_send(['code' => 'error', 'msg' => '启用数量超过限制,不能超过50条']);
  474. // }
  475. }
  476. // 查询用户
  477. $where = ['id' => $id];
  478. if ($is_admin != 1 && $company_id != 0) {
  479. $where['company_id'] = $company_id;
  480. } else {
  481. $where['company_id'] = $admin_company_id;
  482. }
  483. $Product = $ProductModel->where($where)->first();
  484. if (!$Product) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  485. if (!empty($Product)) {
  486. //继续校验规格是否存在
  487. $product_specs_tring = $Product->product_specs;
  488. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  489. $product_specs = $product_specs ? array_unique($product_specs) : '';
  490. //继续校平台是否存在
  491. $platform_string = $Product->platform;
  492. $platforms = $platform_string ? explode(',', $platform_string) : '';
  493. $platforms = $platforms ? array_unique($platforms) : '';
  494. $platform_data = $ProductModel->platform_index_data();
  495. foreach ($platforms as $platform) {
  496. $product_specs_log = $ProductModel
  497. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  498. ->where(['product_brand' => $Product->product_brand, 'product_name' => $Product->product_name, 'status' => '0', 'company_id' => $Product->company_id])
  499. ->where('id', '!=', $id)
  500. ->where(function ($query) use ($product_specs) {
  501. // 平台条件(固定)
  502. $query->where(function ($query_li) use ($product_specs) {
  503. if (!empty($product_specs)) {
  504. foreach ($product_specs as $product_spec) {
  505. if (empty($product_specs)) continue;
  506. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  507. }
  508. }
  509. });
  510. })->first();
  511. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  512. if (!empty($product_specs_log) && $status == 0) {
  513. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格启用记录']);
  514. }
  515. }
  516. }
  517. // 执行修改
  518. $result = $ProductModel->changeStatus($Product, $status);
  519. // 提示新增失败
  520. if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']);
  521. // 记录行为
  522. $admin_id = request('access_token.uid', 0); //用户ID
  523. $table_name = $ProductModel->getTable();
  524. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  525. $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], ['status' => $status], '修改了商品' . $Product->product_name . '状态');
  526. // 告知结果
  527. return json_send(['code' => 'success', 'msg' => '设置成功']);
  528. }
  529. /**
  530. * 删除
  531. * @author 唐远望
  532. * @version 1.0
  533. * @date 2025-12-30
  534. *
  535. */
  536. public function delete(Request $request, ProductModel $ProductModel)
  537. {
  538. // 验证参数
  539. $request->scene('delete')->validate();
  540. $admin_company_id = request('admin_company_id', '0');
  541. $company_id = request('access_token.company_id', '0');
  542. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  543. // 接收数据
  544. $id = request('id', 0);
  545. // 查询用户
  546. $where = ['id' => $id];
  547. if ($is_admin != 1 && $company_id != 0) {
  548. $where['company_id'] = $company_id;
  549. } else {
  550. $where['company_id'] = $admin_company_id;
  551. }
  552. // 执行删除
  553. $Product = $ProductModel->where($where)->first();
  554. if (!$Product) {
  555. return json_send(['code' => 'error', 'msg' => '删除失败,记录不存在']);
  556. }
  557. DB::beginTransaction();
  558. try {
  559. $Product->delete();
  560. // 记录行为
  561. $admin_id = request('access_token.uid', 0); //用户ID
  562. $table_name = $ProductModel->getTable();
  563. $notes_type = 3; //操作类型,1添加,2修改,3=删除
  564. $this->addAdminHistory('采集配置-商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $Product->toarray(), [], '删除了商品' . $Product->product_name . '信息');
  565. // 告知结果
  566. DB::commit();
  567. return json_send(['code' => 'success', 'msg' => '删除成功']);
  568. // 成功处理...
  569. } catch (\Exception $e) {
  570. DB::rollBack();
  571. // 错误处理...
  572. return json_send(['code' => 'error', 'msg' => '删除失败']);
  573. }
  574. }
  575. }