LowPriceGoods.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709
  1. <?php
  2. namespace App\Http\Controllers\Manager\WashConfig;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\Manager\WashConfig\LowPriceGoods as Request;
  5. use App\Models\Manager\WashConfig\LowPriceGoods as LowPriceGoodsModel;
  6. use App\Models\Manager\WashConfig\ViolationStore as ViolationStoreModel;
  7. use App\Models\Manager\WashConfig\LowPriceGoodsCompany as LowPriceGoodsCompanyModel;
  8. use App\Models\Manager\WashConfig\ProductCategory as ProductCategoryModel;
  9. use Illuminate\Support\Facades\DB;
  10. use App\Models\Manager\WashConfig\ViolationProduct as ViolationProductModel;
  11. use Illuminate\Support\Carbon;
  12. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  13. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  14. use PhpOffice\PhpSpreadsheet\Style\Alignment;
  15. use PhpOffice\PhpSpreadsheet\IOFactory;
  16. /**
  17. * 数据清洗-低价产品配置
  18. * @author 唐远望
  19. * @version 1.0
  20. * @date 2025-12-02
  21. */
  22. class LowPriceGoods extends Controller
  23. {
  24. /**
  25. * 列表
  26. * @author 唐远望
  27. * @version 1.0
  28. * @date 2025-12-02
  29. *
  30. */
  31. public function list(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsCompanyModel $LowPriceGoodsCompanyModel, ProductCategoryModel $ProductCategoryModel)
  32. {
  33. $request->scene('list')->validate();
  34. $admin_company_id = request('admin_company_id', '0');
  35. $company_id = request('access_token.company_id', '0');
  36. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  37. // 查询条件
  38. $map = [];
  39. $limit = request('limit', config('page_num', 10));
  40. $status = request('status', '');
  41. $start_time = request('start_time', '');
  42. $end_time = request('end_time', '');
  43. $product_name = request('product_name', '');
  44. $platform = request('platform', '');
  45. $store_scope = request('store_scope', '');
  46. $company_scope = request('company_scope', '');
  47. $category_id = request('category_id', '');
  48. $product_brand = request('product_brand', '');
  49. $company_name = request('company_name', '');
  50. // 时间条件
  51. if ($start_time) $map[] = ['insert_time', '>=', strtotime($start_time)];
  52. if ($end_time) $map[] = ['insert_time', '<=', strtotime($end_time)];
  53. // 其他条件
  54. if (is_numeric($status)) $map[] = ['status', '=', $status];
  55. if ($product_name) $map[] = ['product_name', 'like', "%$product_name%"];
  56. if ($store_scope) $map[] = ['store_scope', '=', $store_scope];
  57. if ($company_scope) $map[] = ['company_scope', '=', $company_scope];
  58. if ($category_id) $map[] = ['category_id', '=', $category_id];
  59. if ($product_brand) $map[] = ['product_brand', 'like', "%$product_brand%"];
  60. // 查询数据
  61. if ($is_admin != 1 && $company_id != 0) {
  62. $map[] = ['company_id', '=', $company_id];
  63. } else {
  64. $map[] = ['company_id', '=', $admin_company_id];
  65. }
  66. if ($platform != '') {
  67. $platform_ids = explode(',', $platform);
  68. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query) use ($platform_ids) {
  69. $query->select('product_id')
  70. ->from('washconfig_lowprice_product_platform')
  71. ->whereIn('platform_id', $platform_ids)
  72. ->distinct('product_id');
  73. });
  74. }
  75. if ($company_name) {
  76. $LowPriceGoodsModel = $LowPriceGoodsModel->whereIn('id', function ($query) use ($company_name) {
  77. $query->select('washconfig_lowprice_product_company.lowprice_product_logid')
  78. ->from('washconfig_lowprice_product_company')
  79. ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_lowprice_product_company.company_id')
  80. ->where('washconfig_violation_store.company_name', 'like', "%$company_name%")
  81. ->distinct('washconfig_lowprice_product_company.company_id');
  82. });
  83. }
  84. $result = $LowPriceGoodsModel
  85. ->where($map)
  86. ->with(['product_keyword'])
  87. ->orderByDesc('id')
  88. ->paginate($limit)->toarray();
  89. // 分配数据
  90. if (!$result) return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => []]);
  91. if (isset($result['data']) && count($result['data']) > 0) {
  92. foreach ($result['data'] as $key => $value) {
  93. $result['data'][$key]['platform'] = isset($value['platform']) ? explode(',', $value['platform']) : '';
  94. $category_name = $value['category_id'] > 0 ? $ProductCategoryModel->where('id', $value['category_id'])->value('name') : '';
  95. $result['data'][$key]['category_name'] = $category_name;
  96. //查询店铺名称
  97. if ($value['store_scope'] == '1') {
  98. $result['data'][$key]['store_name'] = ['全部店铺'];
  99. } else {
  100. $result['data'][$key]['store_name'] = '';
  101. }
  102. //查询公司名称
  103. if ($value['company_scope'] == '1') {
  104. $result['data'][$key]['company_name'] = ['全部公司'];
  105. } else {
  106. $company_data = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $value['id'])
  107. ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_lowprice_product_company.company_id')
  108. ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_lowprice_product_company.company_id'])->get()->toArray();
  109. $result['data'][$key]['company_name'] = !empty($company_data) ? array_column($company_data, 'company_name') : '';
  110. }
  111. }
  112. }
  113. // 加载模板
  114. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $result]);
  115. }
  116. /**
  117. * 详情
  118. * @author 唐远望
  119. * @version 1.0
  120. * @date 2025-12-02
  121. */
  122. public function detail(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, LowPriceGoodsCompanyModel $LowPriceGoodsCompanyModel, ProductCategoryModel $ProductCategoryModel)
  123. {
  124. $request->scene('detail')->validate();
  125. $admin_company_id = request('admin_company_id', '0');
  126. $company_id = request('access_token.company_id', '0');
  127. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  128. // 接收参数
  129. $id = request('id', 0);
  130. $map = ['id' => $id];
  131. if ($is_admin != 1 && $company_id != 0) {
  132. $map['company_id'] = $company_id;
  133. } else {
  134. $map['company_id'] = $admin_company_id;
  135. }
  136. $data = $LowPriceGoodsModel->where($map)->with(['product_keyword'])->first();
  137. if (!$data) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  138. //查询店铺名称
  139. if (trim($data['store_scope']) == '') {
  140. $data['store_name'] = ['全部店铺'];
  141. } else {
  142. $data['store_name'] = '';
  143. }
  144. //查询公司名称
  145. if ($data->company_scope == '1') {
  146. $data->company_name = ['全部公司'];
  147. $data->company_ids = '';
  148. } else {
  149. $company_data = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $data->id)
  150. ->join('washconfig_violation_store', 'washconfig_violation_store.id', '=', 'washconfig_lowprice_product_company.company_id')
  151. ->select(['washconfig_violation_store.id', 'washconfig_violation_store.company_name', 'washconfig_lowprice_product_company.company_id'])->get()->toArray();
  152. $data->company_name = !empty($company_data) ? array_column($company_data, 'company_name') : '';
  153. $data->company_ids = !empty($company_data) ? array_column($company_data, 'company_id') : '';
  154. }
  155. $data->platform = isset($data->platform) ? explode(',', $data->platform) : '';
  156. $data->category_name = $data->category_id > 0 ? $ProductCategoryModel->where('id', $data->category_id)->value('name') : '';
  157. // 加载模板
  158. return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
  159. }
  160. /**
  161. * 添加
  162. * @author 唐远望
  163. * @version 1.0
  164. * @date 2025-12-02
  165. *
  166. */
  167. public function add(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, ViolationProductModel $ViolationProductModel)
  168. {
  169. $request->scene('add')->validate();
  170. $admin_company_id = request('admin_company_id', '0');
  171. $company_id = request('access_token.company_id', '0');
  172. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  173. //获取禁止商品启动数量
  174. $violation_product_count = $ViolationProductModel->where('status', 0)->count();
  175. //获取低价挂网商品启用数量
  176. $lowprice_product_count = $LowPriceGoodsModel->where('status', 0)->count();
  177. //计算总数量
  178. $product_totle = $violation_product_count + $lowprice_product_count;
  179. // 接收数据
  180. $all_data = request()->all();
  181. $product_brand = request('product_brand', '');
  182. $product_keyword = request('product_keyword', '');
  183. $product_specs = request('product_specs', '');
  184. $all_data['product_specs'] = $product_specs;
  185. $all_data['product_brand'] = $product_brand;
  186. $all_data['product_keyword'] = $product_keyword;
  187. $enable_full_quantity = request('enable_full_quantity', 1); //全量,0启用,1禁用
  188. $all_data['enable_full_quantity'] = $enable_full_quantity;
  189. if ($enable_full_quantity == 1 && !isset($all_data['product_specs'])) {
  190. return json_send(['code' => 'error', 'msg' => '非全量清洗时,商品规格不能为空']);
  191. }
  192. if (trim($product_keyword) != '') {
  193. $product_keyword_count = count(explode(',', $product_keyword));
  194. if ($product_keyword_count > 5) {
  195. return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
  196. }
  197. }
  198. $store_scope = request('store_scope', '');
  199. $all_data['store_scope'] = $store_scope;
  200. $platform_string = $all_data['platform'];
  201. $company_scope = request('company_scope', '');
  202. $all_data['company_scope'] = $company_scope;
  203. $category_id = request('category_id', '0');
  204. $all_data['category_id'] = $category_id;
  205. $specify_responsible_person = request('specify_responsible_person', '0');
  206. $all_data['specify_responsible_person'] = $specify_responsible_person;
  207. //查询是否存在
  208. $map = ['product_brand' => $all_data['product_brand'], 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price']];
  209. if (isset($all_data['product_specs']) && $all_data['product_specs'] != '') {
  210. $map['product_specs'] = $all_data['product_specs'];
  211. }
  212. if ($is_admin != 1 && $company_id != 0) {
  213. $map['company_id'] = $company_id;
  214. $all_data['company_id'] = $company_id;
  215. } else {
  216. $map['company_id'] = $admin_company_id;
  217. $all_data['company_id'] = $admin_company_id;
  218. }
  219. $data = $LowPriceGoodsModel->where($map)->first();
  220. if (!empty($data) && $enable_full_quantity == 1) {
  221. //继续校验规格是否存在
  222. $product_specs_tring = $all_data['product_specs'];
  223. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  224. $product_specs = $product_specs ? array_unique($product_specs) : '';
  225. //继续校平台是否存在
  226. $platforms = $platform_string ? explode(',', $platform_string) : '';
  227. $platforms = $platforms ? array_unique($platforms) : '';
  228. $platform_data = $LowPriceGoodsModel->platform_index_data();
  229. foreach ($platforms as $platform) {
  230. $product_specs_log = $LowPriceGoodsModel
  231. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  232. ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price'], 'status' => '0'])
  233. ->where(function ($query) use ($product_specs) {
  234. // 平台条件(固定)
  235. $query->where(function ($query_li) use ($product_specs) {
  236. foreach ($product_specs as $product_spec) {
  237. if (empty($product_specs)) continue;
  238. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  239. }
  240. });
  241. })->first();
  242. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  243. if (!empty($product_specs_log)) {
  244. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格记录']);
  245. }
  246. }
  247. } else if (!empty($data) && $enable_full_quantity == 0) {
  248. $platforms = $platform_string ? explode(',', $platform_string) : '';
  249. $platforms = $platforms ? array_unique($platforms) : '';
  250. $platform_data = $LowPriceGoodsModel->platform_index_data();
  251. foreach ($platforms as $platform) {
  252. $product_specs_log = $LowPriceGoodsModel
  253. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  254. ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price'], 'status' => '0'])
  255. ->first();
  256. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  257. if (!empty($product_specs_log)) {
  258. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品记录']);
  259. }
  260. }
  261. }
  262. // 写入数据表
  263. $result = $LowPriceGoodsModel->addLowProduct($all_data);
  264. // 如果操作失败
  265. if (!$result) return json_send(['code' => 'error', 'msg' => '新增失败']);
  266. // 记录行为
  267. $admin_id = request('access_token.uid', 0); //用户ID
  268. $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否
  269. $table_name = $LowPriceGoodsModel->getTable();
  270. $notes_type = 1; //操作类型,1添加,2修改,3=删除
  271. $this->addAdminHistory('清洗配置-低价商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], $all_data, '新增了低价商品' . $all_data['product_name'] . '信息');
  272. // 告知结果
  273. return json_send(['code' => 'success', 'msg' => '新增成功']);
  274. }
  275. /**
  276. * 修改
  277. * @author 唐远望
  278. * @version 1.0
  279. * @date 2025-12-02
  280. *
  281. */
  282. public function edit(Request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  283. {
  284. $request->scene('edit')->validate();
  285. $admin_company_id = request('admin_company_id', '0');
  286. $company_id = request('access_token.company_id', '0');
  287. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  288. // 接收参数
  289. $id = request('id', 0);
  290. // 接收数据
  291. $all_data = request()->all();
  292. $product_brand = request('product_brand', '');
  293. $product_keyword = request('product_keyword', '');
  294. $product_specs = request('product_specs', '');
  295. $all_data['product_specs'] = $product_specs;
  296. $all_data['product_brand'] = $product_brand;
  297. $all_data['product_keyword'] = $product_keyword;
  298. $enable_full_quantity = request('enable_full_quantity', 1); //全量,0启用,1禁用
  299. $all_data['enable_full_quantity'] = $enable_full_quantity;
  300. if ($enable_full_quantity == 1 && !isset($all_data['product_specs'])) {
  301. return json_send(['code' => 'error', 'msg' => '非全量清洗时,商品规格不能为空']);
  302. }
  303. if (trim($product_keyword) != '') {
  304. $product_keyword_count = count(explode(',', $product_keyword));
  305. if ($product_keyword_count > 5) {
  306. return json_send(['code' => 'error', 'msg' => '商品关键词不能超过5个']);
  307. }
  308. }
  309. $store_scope = request('store_scope', '');
  310. $all_data['store_scope'] = $store_scope;
  311. $platform_string = $all_data['platform'];
  312. $company_scope = request('company_scope', '');
  313. $all_data['company_scope'] = $company_scope;
  314. $category_id = request('category_id', '0');
  315. $all_data['category_id'] = $category_id;
  316. $specify_responsible_person = request('specify_responsible_person', '0');
  317. $all_data['specify_responsible_person'] = $specify_responsible_person;
  318. //查询是否存在
  319. $map = ['product_brand' => $all_data['product_brand'], 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price']];
  320. if (isset($all_data['product_specs']) && $all_data['product_specs'] != '') {
  321. $map['product_specs'] = $all_data['product_specs'];
  322. }
  323. if ($is_admin != 1 && $company_id != 0) {
  324. $map['company_id'] = $company_id;
  325. } else {
  326. $map['company_id'] = $admin_company_id;
  327. }
  328. $data = $LowPriceGoodsModel->where($map)->first();
  329. if (!empty($data) && $enable_full_quantity == 1) {
  330. //继续校验规格是否存在
  331. $product_specs_tring = $all_data['product_specs'];
  332. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  333. $product_specs = $product_specs ? array_unique($product_specs) : '';
  334. //继续校平台是否存在
  335. $platforms = $platform_string ? explode(',', $platform_string) : '';
  336. $platforms = $platforms ? array_unique($platforms) : '';
  337. $platform_data = $LowPriceGoodsModel->platform_index_data();
  338. foreach ($platforms as $platform) {
  339. $product_specs_log = $LowPriceGoodsModel
  340. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  341. ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price'], 'status' => '0'])
  342. ->where('id', '!=', $id)
  343. ->where(function ($query) use ($product_specs) {
  344. // 平台条件(固定)
  345. $query->where(function ($query_li) use ($product_specs) {
  346. foreach ($product_specs as $product_spec) {
  347. if (empty($product_specs)) continue;
  348. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  349. }
  350. });
  351. })->first();
  352. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  353. if (!empty($product_specs_log)) {
  354. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格记录']);
  355. }
  356. }
  357. } else if (!empty($data) && $enable_full_quantity == 0) {
  358. $platforms = $platform_string ? explode(',', $platform_string) : '';
  359. $platforms = $platforms ? array_unique($platforms) : '';
  360. $platform_data = $LowPriceGoodsModel->platform_index_data();
  361. foreach ($platforms as $platform) {
  362. $product_specs_log = $LowPriceGoodsModel
  363. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  364. ->where(['product_brand' => $product_brand, 'product_name' => $all_data['product_name'],'suggested_price'=> $all_data['suggested_price'], 'status' => '0'])
  365. ->first();
  366. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  367. if (!empty($product_specs_log)) {
  368. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品记录']);
  369. }
  370. }
  371. }
  372. // 更新数据表
  373. $where = ['id' => $id];
  374. if ($is_admin != 1 && $company_id != 0) {
  375. $where['company_id'] = $company_id;
  376. $all_data['company_id'] = $company_id;
  377. } else {
  378. $where['company_id'] = $admin_company_id;
  379. $all_data['company_id'] = $admin_company_id;
  380. }
  381. $LowProduct = $LowPriceGoodsModel->where($where)->first();
  382. if (!$LowProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  383. $oldData = $LowProduct->toarray();
  384. $result = $LowPriceGoodsModel->editLowProduct_content($LowProduct, $all_data);
  385. // 如果操作失败
  386. if (!$result) return json_send(['code' => 'error', 'msg' => '修改失败']);
  387. // 记录行为
  388. $admin_id = request('access_token.uid', 0); //用户ID
  389. $table_name = $LowPriceGoodsModel->getTable();
  390. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  391. $this->addAdminHistory('清洗配置-低价商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $oldData, $all_data, '修改了低价商品' . $oldData['product_name'] . '信息');
  392. // 告知结果
  393. return json_send(['code' => 'success', 'msg' => '修改成功']);
  394. }
  395. /**
  396. * 修改状态
  397. * @author 唐远望
  398. * @version 1.0
  399. * @date 2025-12-02
  400. *
  401. */
  402. public function set_status(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, ViolationProductModel $ViolationProductModel)
  403. {
  404. // 验证参数
  405. $request->scene('set_status')->validate();
  406. $admin_company_id = request('admin_company_id', '0');
  407. $company_id = request('access_token.company_id', '0');
  408. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  409. // 接收数据
  410. $id = request('id', 0);
  411. $status = request('status', 0);
  412. if ($status == 0) {
  413. //获取禁止商品启动数量
  414. $status_where = ['status' => 0];
  415. if ($is_admin != 1 && $company_id != 0) {
  416. $status_where['company_id'] = $company_id;
  417. } else {
  418. $status_where['company_id'] = $admin_company_id;
  419. }
  420. $violation_product_count = $ViolationProductModel->where($status_where)->count();
  421. //获取低价挂网商品启用数量
  422. $lowprice_product_count = $LowPriceGoodsModel->where($status_where)->count();
  423. //计算总数量
  424. $product_totle = $violation_product_count + $lowprice_product_count;
  425. }
  426. // 查询用户
  427. $where = ['id' => $id];
  428. if ($is_admin != 1 && $company_id != 0) {
  429. $where['company_id'] = $company_id;
  430. } else {
  431. $where['company_id'] = $admin_company_id;
  432. }
  433. $LowProduct = $LowPriceGoodsModel->where($where)->first();
  434. if (!$LowProduct) return json_send(['code' => 'error', 'msg' => '记录不存在']);
  435. if (!empty($LowProduct) && $LowProduct->enable_full_quantity == 1) {
  436. //继续校验规格是否存在
  437. $product_specs_tring = $LowProduct->product_specs;
  438. $product_specs = $product_specs_tring ? explode(',', $product_specs_tring) : '';
  439. $product_specs = $product_specs ? array_unique($product_specs) : '';
  440. //继续校平台是否存在
  441. $platform_string = $LowProduct->platform;
  442. $platforms = $platform_string ? explode(',', $platform_string) : '';
  443. $platforms = $platforms ? array_unique($platforms) : '';
  444. $platform_data = $LowPriceGoodsModel->platform_index_data();
  445. foreach ($platforms as $platform) {
  446. $product_specs_log = $LowPriceGoodsModel
  447. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  448. ->where(['product_brand' => $LowProduct->product_brand, 'product_name' => $LowProduct->product_name,'suggested_price'=> $LowProduct->suggested_price, 'status' => '0'])
  449. ->where('id', '!=', $id)
  450. ->where(function ($query) use ($product_specs) {
  451. // 平台条件(固定)
  452. $query->where(function ($query_li) use ($product_specs) {
  453. foreach ($product_specs as $product_spec) {
  454. if (empty($product_specs)) continue;
  455. $query_li->orWhereRaw("FIND_IN_SET(?, product_specs)", [$product_spec]);
  456. }
  457. });
  458. })->first();
  459. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  460. if (!empty($product_specs_log)) {
  461. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品规格启用记录']);
  462. }
  463. }
  464. } else if (!empty($data) && $LowProduct->enable_full_quantity == 0) {
  465. $platform_string = $LowProduct->platform;
  466. $platforms = $platform_string ? explode(',', $platform_string) : '';
  467. $platforms = $platforms ? array_unique($platforms) : '';
  468. $platform_data = $LowPriceGoodsModel->platform_index_data();
  469. foreach ($platforms as $platform) {
  470. $product_specs_log = $LowPriceGoodsModel
  471. ->whereRaw("FIND_IN_SET(?, platform)", [$platform])
  472. ->where(['product_brand' => $LowProduct->product_brand, 'product_name' => $LowProduct->product_name,'suggested_price'=> $LowProduct->suggested_price, 'status' => '0'])
  473. ->where('id', '!=', $id)->first();
  474. $platform_name = isset($platform_data[$platform]) ? $platform_data[$platform] : '';
  475. if (!empty($product_specs_log)) {
  476. return json_send(['code' => 'error', 'msg' => $platform_name . '存在重复的商品启用记录']);
  477. }
  478. }
  479. }
  480. // 执行修改
  481. $result = $LowPriceGoodsModel->changeStatus($LowProduct, $status);
  482. // 提示新增失败
  483. if (!$result) return json_send(['code' => 'error', 'msg' => '设置失败']);
  484. // 记录行为
  485. $admin_id = request('access_token.uid', 0); //用户ID
  486. $table_name = $LowPriceGoodsModel->getTable();
  487. $notes_type = 2; //操作类型,1添加,2修改,3=删除
  488. $this->addAdminHistory('清洗配置-低价商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, [], ['status' => $status], '修改了低价商品' . $LowProduct->product_name . '状态');
  489. // 告知结果
  490. return json_send(['code' => 'success', 'msg' => '设置成功']);
  491. }
  492. /**
  493. * 删除
  494. * @author 唐远望
  495. * @version 1.0
  496. * @date 2025-12-02
  497. *
  498. */
  499. public function delete(Request $request, LowPriceGoodsModel $LowPriceGoodsModel)
  500. {
  501. // 验证参数
  502. $request->scene('delete')->validate();
  503. $admin_company_id = request('admin_company_id', '0');
  504. $company_id = request('access_token.company_id', '0');
  505. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  506. // 接收数据
  507. $id = request('id', 0);
  508. // 查询用户
  509. $where = ['id' => $id];
  510. if ($is_admin != 1 && $company_id != 0) {
  511. $where['company_id'] = $company_id;
  512. } else {
  513. $where['company_id'] = $admin_company_id;
  514. }
  515. // 执行删除
  516. $LowProduct = $LowPriceGoodsModel->where($where)->first();
  517. if (!$LowProduct) {
  518. return json_send(['code' => 'error', 'msg' => '记录不存在']);
  519. }
  520. DB::beginTransaction();
  521. try {
  522. $LowPriceGoodsCompanyModel = new LowPriceGoodsCompanyModel();
  523. $company_id_log = $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $LowProduct->id)->get();
  524. if (!empty($company_id_log)) {
  525. $LowPriceGoodsCompanyModel->where('lowprice_product_logid', $LowProduct->id)->delete();
  526. }
  527. $LowProduct->delete();
  528. // 记录行为
  529. $admin_id = request('access_token.uid', 0); //用户ID
  530. $is_admin = request('access_token.is_admin'); //是否管理员操作 0=是1=否
  531. $table_name = $LowPriceGoodsModel->getTable();
  532. $notes_type = 3; //操作类型,1添加,2修改,3=删除
  533. $this->addAdminHistory('清洗配置-低价商品管理', $company_id, $admin_id, $is_admin, $table_name, $notes_type, $LowProduct->toarray(), [], '删除了低价商品' . $LowProduct->product_name . '信息');
  534. DB::commit();
  535. // 告知结果
  536. return json_send(['code' => 'success', 'msg' => '删除成功']);
  537. // 成功处理...
  538. } catch (\Exception $e) {
  539. DB::rollBack();
  540. // 错误处理...
  541. return json_send(['code' => 'error', 'msg' => '删除失败']);
  542. }
  543. }
  544. /**
  545. * 下载导入模板
  546. * @author 唐远望
  547. * @version 1.0
  548. * @date 2026-02-28
  549. *
  550. */
  551. public function download_template()
  552. {
  553. // 创建一个新的 Spreadsheet 对象
  554. $spreadsheet = new Spreadsheet();
  555. $sheet = $spreadsheet->getActiveSheet();
  556. //合并单元格
  557. $sheet->mergeCells('A1:R1');
  558. $sheet->setCellValue('A1', '低价挂网商品清洗导入模板'); // 设置合并后的单元格内容
  559. // 获取合并后的单元格样式对象
  560. $style = $sheet->getStyle('A1');
  561. // 设置水平居中和垂直居中
  562. $style->getAlignment()->setHorizontal(Alignment::HORIZONTAL_CENTER)->setVertical(Alignment::VERTICAL_CENTER);
  563. // 然后设置行高以适应两行文本
  564. $sheet->getRowDimension(1)->setRowHeight(40); // 设置行高,单位是磅(point)
  565. // 设置表头
  566. $sheet->setCellValue('A2', '商品名称*');
  567. $sheet->setCellValue('B2', '商品分类名称');
  568. $sheet->setCellValue('C2', '商品规格*');
  569. $sheet->setCellValue('D2', '监控价格*');
  570. $sheet->setCellValue('E2', '平台名称(多个逗号隔开,为空全部)');
  571. $sheet->setCellValue('F2', '指定公司(多个逗号隔开,为空全部)');
  572. $sheet->setCellValue('G2', '指派责任人(是/否)*');
  573. // 生成 Excel 文件
  574. $writer = new Xlsx($spreadsheet);
  575. // 直接输出到浏览器(下载)
  576. $filename = '低价挂网商品清洗导入模板.xlsx';
  577. header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
  578. header('Content-Disposition: attachment;filename="' . $filename . '"');
  579. header('Cache-Control: max-age=0');
  580. $writer->save('php://output');
  581. exit;
  582. }
  583. /**
  584. * 导入Excel数据
  585. * @author 唐远望
  586. * @version 1.0
  587. * @date 2026-02-28
  588. *
  589. */
  590. public function import_data(Request $request, LowPriceGoodsModel $LowPriceGoodsModel, ViolationStoreModel $ViolationStoreModel, ProductCategoryModel $ProductCategoryModel)
  591. {
  592. $request->scene('import_data')->validate();
  593. $admin_company_id = request('admin_company_id', '0');
  594. $company_id = request('access_token.company_id', '0');
  595. $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
  596. $file = $request->file('file');
  597. // 加载Excel文件
  598. $spreadsheet = IOFactory::load($file->getPathname());
  599. $sheet = $spreadsheet->getActiveSheet();
  600. // 获取所有数据
  601. $data = $sheet->toArray();
  602. if (empty($data) || count($data) < 2) return json_send(['code' => 'error', 'msg' => '导入数据为空']);
  603. $platform_data = $LowPriceGoodsModel->platform_data();
  604. DB::beginTransaction();
  605. try {
  606. foreach ($data as $key => $item) {
  607. if ($key < 2) continue;
  608. //强制必传参数校验
  609. $res_data = $this->import_data_check($key, $item);
  610. if ($res_data) return json_send($res_data);
  611. $category_id = '0';
  612. if (isset($item[1])) {
  613. $category_data = $ProductCategoryModel->where('name', $item[1])->first();
  614. $category_id = $category_data ? $category_data->id : '0';
  615. }
  616. $platform_text = isset($item[4]) ? explode(',', $item[4]) : '0'; // 平台
  617. $platform_id_text = '';
  618. if (!empty($platform_text)) {
  619. foreach ($platform_text as $key => $value) {
  620. if (isset($platform_data[$value])) {
  621. $platform_id_text = $platform_data[$value] . ',' . $platform_id_text;
  622. }
  623. }
  624. }
  625. $company_scope = isset($item[5]) ? explode(',', $item[5]) : '0'; // 公司范围
  626. $company_id_text = '';
  627. if (!empty($company_scope)) {
  628. //查询所有公司ID逗号隔开
  629. $company_id_text = $ViolationStoreModel->whereIn('company_name', $company_scope)->pluck('id')->implode(',');
  630. }
  631. // 权限判断
  632. if ($is_admin != 1 && $company_id != 0) {
  633. $insert_product_data['company_id'] = $company_id;
  634. } else {
  635. $insert_product_data['company_id'] = $admin_company_id;
  636. }
  637. $insert_product_data['product_name'] = $item[0]; // 商品名称
  638. $insert_product_data['category_id'] = $category_id; // 商品分类
  639. $insert_product_data['product_specs'] = $item[2]; // 商品规格
  640. $insert_product_data['suggested_price'] = $item[3]; // 指导价格
  641. $insert_product_data['platform'] = $platform_id_text != '' ? substr($platform_id_text, 0, -1) : '0'; // 平台:0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药久久
  642. $insert_product_data['store_scope'] = ''; // 店铺范围(为空时全部,指定时为店铺ID多个逗号隔开)
  643. $insert_product_data['company_scope'] = $company_id_text; // 公司范围(为空时全部,指定时为公司ID多个逗号隔开)
  644. $insert_product_data['specify_responsible_person'] = trim($item[6]) == '是' ? 0 : 1; // 指派责任人 0=开启 1=关闭
  645. //插入数据
  646. $LowPriceGoodsModel->addLowProduct($insert_product_data);
  647. }
  648. DB::commit();
  649. return json_send(['code' => 'success', 'msg' => '导入成功']);
  650. // 成功处理...
  651. } catch (\Exception $e) {
  652. DB::rollBack();
  653. // 错误处理...
  654. return json_send(['code' => 'error', 'msg' => '导入失败', 'data' => $e->getMessage()]);
  655. }
  656. }
  657. /**
  658. * 导入Excel数据必传参数校验
  659. * @author 唐远望
  660. * @version 1.0
  661. * @date 2025-12-31
  662. *
  663. */
  664. private function import_data_check($key, $item)
  665. {
  666. $key = $key + 1;
  667. if (!$item[0]) {
  668. return ['code' => 'error', 'msg' => "第{$key}行商品名称不能为空", 'data' => $item];
  669. }
  670. if (!$item[2]) {
  671. return ['code' => 'error', 'msg' => "第{$key}行商品规格不能为空", 'data' => $item];
  672. }
  673. if (!$item[3]) {
  674. return ['code' => 'error', 'msg' => "第{$key}行监控价格不能为空", 'data' => $item];
  675. }
  676. if (!$item[6]) {
  677. return ['code' => 'error', 'msg' => "第{$key}行指派责任人不能为空", 'data' => $item];
  678. }
  679. }
  680. }