Product.php 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288
  1. <?php
  2. namespace App\Models\manager\Collect;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Models\Manager\Collect\ProductKeyword as ProductKeywordModel;
  7. /**
  8. * 采集配置-商品管理
  9. * @author: 唐远望
  10. * @version: 1.0
  11. * @date: 2025-12-30
  12. */
  13. class Product extends Model
  14. {
  15. use HasFactory;
  16. // 与模型关联的表名
  17. protected $table = 'collect_product';
  18. // 是否主动维护时间戳
  19. public $timestamps = false;
  20. // 定义时间戳字段名
  21. // const CREATED_AT = 'insert_time';
  22. // const UPDATED_AT = 'update_time';
  23. /**
  24. * 平台定义
  25. * @author 唐远望
  26. * @version 1.0
  27. * @date 2025-12-31
  28. */
  29. public function platform_index_data()
  30. {
  31. //平台0=全部,1=淘宝,2=京东,3=拼多多,4=美团,5=药师帮,6=1药城,7=药九九,8=药易购,9=药帮忙,10=熊猫药药11=药房网
  32. $platform_data = [
  33. '1' => '淘宝',
  34. '2' => '京东',
  35. '3' => '拼多多',
  36. '4' => '美团',
  37. '5' => '药师帮',
  38. '6' => '1药城',
  39. '7' => '药九九',
  40. '8' => '药易购',
  41. '9' => '药帮忙',
  42. '10' => '熊猫药药',
  43. '11' => '药房网',
  44. ];
  45. return $platform_data;
  46. }
  47. /**
  48. * 添加
  49. * @author 唐远望
  50. * @version 1.0
  51. * @date 2025-12-30
  52. */
  53. public function addProduct_content($data)
  54. {
  55. // 计算品规数量
  56. $product_specs_data = isset($data['product_specs']) && $data['product_specs'] != '' ? explode(',', $data['product_specs']) : '';
  57. //移除数组内空值
  58. $product_specs_data = !empty($product_specs_data) ? array_filter($product_specs_data) : '';
  59. $insert_data = [
  60. 'enable_full_quantity' => isset($data['enable_full_quantity']) ? $data['enable_full_quantity'] : 0,
  61. 'platform' => $data['platform'],
  62. 'product_brand' => $data['product_brand'],
  63. 'product_name' => $data['product_name'],
  64. 'product_specs' => $data['product_specs'],
  65. 'product_specs_number' => $data['product_specs'] ? count($product_specs_data) : 1,
  66. 'minimum_order_quantity' => $data['minimum_order_quantity'],
  67. 'sampling_cycle' => $data['sampling_cycle'],
  68. 'round_number' => $data['round_number'],
  69. 'is_multiple_accounts' => isset($data['is_multiple_accounts']) ? $data['is_multiple_accounts'] : 0,
  70. 'sampling_start_time' => $data['sampling_start_time'],
  71. 'sampling_end_time' => $data['sampling_end_time'],
  72. 'company_id' => $data['company_id'],
  73. 'insert_time' => time(),
  74. ];
  75. $Product_id = $this->insertGetId($insert_data);
  76. return $Product_id;
  77. }
  78. /**
  79. * 连表查询商品关键字
  80. * @author 唐远望
  81. * @version 1.0
  82. * @date 2026-03-31
  83. */
  84. public function product_keyword(){
  85. return $this->hasMany(ProductKeywordModel::class,'collect_product_id','id')->orderBy('id','asc');;
  86. }
  87. /**
  88. * 写入数据
  89. * @author 唐远望
  90. * @version 1.0
  91. * @date 2025-12-30
  92. * @param $data
  93. * @return bool
  94. */
  95. public function addProduct($data)
  96. {
  97. DB::beginTransaction();
  98. try {
  99. // 计算品规数量
  100. $product_specs_data = isset($data['product_specs']) && $data['product_specs'] != '' ? explode(',', $data['product_specs']) : '';
  101. //移除数组内空值
  102. $product_specs_data = !empty($product_specs_data) ? array_filter($product_specs_data) : '';
  103. $insert_data = [
  104. 'enable_full_quantity' => isset($data['enable_full_quantity']) ? $data['enable_full_quantity'] : 0,
  105. 'platform' => $data['platform'],
  106. 'product_brand' => $data['product_brand'],
  107. 'product_name' => $data['product_name'],
  108. 'product_specs' => $data['product_specs'],
  109. 'product_specs_number' => $data['product_specs'] ? count($product_specs_data) : 1,
  110. 'minimum_order_quantity' => $data['minimum_order_quantity'],
  111. 'sampling_cycle' => $data['sampling_cycle'],
  112. 'round_number' => $data['round_number'],
  113. 'round_number_config' => $data['round_number_config'],
  114. 'is_multiple_accounts' => isset($data['is_multiple_accounts']) ? $data['is_multiple_accounts'] : 0,
  115. 'sampling_start_time' => $data['sampling_start_time'],
  116. 'sampling_end_time' => $data['sampling_end_time'],
  117. 'company_id' => $data['company_id'],
  118. 'insert_time' => time(),
  119. ];
  120. $Product_id = $this->insertGetId($insert_data);
  121. // 如果存在采集配置的关键字
  122. $product_keyword = $data['product_keyword'];
  123. if (trim($product_keyword) != '') {
  124. $ProductKeywordModel = new ProductKeywordModel();
  125. $product_keyword_data = explode(',', $product_keyword);
  126. $keyword_data = [];
  127. foreach ($product_keyword_data as $key => $value) {
  128. if (trim($value) == '') continue;
  129. $keyword_data[] = [
  130. 'collect_product_id' => $Product_id,
  131. 'keyword' => $value,
  132. ];
  133. }
  134. $ProductKeywordModel->insert($keyword_data);
  135. }
  136. DB::commit();
  137. return $Product_id;
  138. // 成功处理...
  139. } catch (\Exception $e) {
  140. DB::rollBack();
  141. // 错误处理...
  142. return false;
  143. }
  144. }
  145. /**
  146. * 编辑内容
  147. * @author 唐远望
  148. * @version 1.0
  149. * @date 2025-12-30
  150. * @param $data
  151. * @return bool
  152. */
  153. public function editProduct_content($Product, $data)
  154. {
  155. DB::beginTransaction();
  156. try {
  157. // 计算品规数量
  158. $product_specs_data = isset($data['product_specs']) && $data['product_specs'] != '' ? explode(',', $data['product_specs']) : '';
  159. //移除数组内空值
  160. $product_specs_data = !empty($product_specs_data) ? array_filter($product_specs_data) : '';
  161. $Product->enable_full_quantity = isset($data['enable_full_quantity']) ? $data['enable_full_quantity'] : 0;
  162. $Product->platform = $data['platform'];
  163. $Product->product_brand = $data['product_brand'];
  164. $Product->product_name = $data['product_name'];
  165. $Product->product_specs = $data['product_specs'];
  166. $Product->product_specs_number = $product_specs_data ? count($product_specs_data) : 1;
  167. $Product->minimum_order_quantity = $data['minimum_order_quantity'];
  168. $Product->sampling_cycle = $data['sampling_cycle'];
  169. $Product->round_number = $data['round_number'];
  170. $Product->round_number_config = $data['round_number_config'];
  171. $Product->is_multiple_accounts = isset($data['is_multiple_accounts']) ? $data['is_multiple_accounts'] : 0;
  172. $Product->sampling_start_time = $data['sampling_start_time'];
  173. $Product->sampling_end_time = $data['sampling_end_time'];
  174. $Product->update_time = time();
  175. $Product->save();
  176. $ProductKeywordModel = new ProductKeywordModel();
  177. //查询是否配置了关键字,如果有则删除重新添加
  178. $keyword_count = $ProductKeywordModel->where('collect_product_id', $Product->id)->count();
  179. if ($keyword_count > 0) {
  180. $ProductKeywordModel->where('collect_product_id', $Product->id)->delete();
  181. }
  182. // 如果存在采集配置的关键字
  183. $product_keyword = $data['product_keyword'];
  184. if (trim($product_keyword) != '') {
  185. $product_keyword_data = explode(',', $product_keyword);
  186. $keyword_data = [];
  187. foreach ($product_keyword_data as $key => $value) {
  188. if (trim($value) == '') continue;
  189. $keyword_data[] = [
  190. 'collect_product_id' => $Product->id,
  191. 'keyword' => $value,
  192. ];
  193. }
  194. $ProductKeywordModel->insert($keyword_data);
  195. }
  196. DB::commit();
  197. return true;
  198. // 成功处理...
  199. } catch (\Exception $e) {
  200. DB::rollBack();
  201. // 错误处理...
  202. return false;
  203. }
  204. }
  205. /**
  206. * 更新数据
  207. * @author 唐远望
  208. * @version 1.0
  209. * @date 2025-12-30
  210. * @param $data
  211. * @return bool
  212. */
  213. public function updateProduct($where, $data)
  214. {
  215. DB::beginTransaction();
  216. try {
  217. $this->editProduct_content($where, $data);
  218. DB::commit();
  219. return true;
  220. // 成功处理...
  221. } catch (\Exception $e) {
  222. DB::rollBack();
  223. // 错误处理...
  224. return false;
  225. }
  226. }
  227. /**
  228. * 修改状态
  229. * @author 唐远望
  230. * @version 1.0
  231. * @date 2025-12-30
  232. * @param $id
  233. * @param $status
  234. * @return bool
  235. */
  236. public function changeStatus($Product, $status)
  237. {
  238. $Product->status = $status;
  239. $Product->update_time = time();
  240. $Product->save();
  241. return true;
  242. }
  243. /**
  244. * 删除数据
  245. * @author 唐远望
  246. * @version 1.0
  247. * @date 2025-12-30
  248. * @param $id
  249. * @return bool
  250. */
  251. public function deleteProduct($where)
  252. {
  253. $Product = $this->where($where)->first();
  254. if (!$Product) {
  255. return false;
  256. }
  257. DB::beginTransaction();
  258. try {
  259. $Product->delete();
  260. DB::commit();
  261. return true;
  262. // 成功处理...
  263. } catch (\Exception $e) {
  264. DB::rollBack();
  265. // 错误处理...
  266. return false;
  267. }
  268. }
  269. }