Product.php 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283
  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. 'sampling_start_time' => $data['sampling_start_time'],
  70. 'sampling_end_time' => $data['sampling_end_time'],
  71. 'company_id' => $data['company_id'],
  72. 'insert_time' => time(),
  73. ];
  74. $Product_id = $this->insertGetId($insert_data);
  75. return $Product_id;
  76. }
  77. /**
  78. * 连表查询商品关键字
  79. * @author 唐远望
  80. * @version 1.0
  81. * @date 2026-03-31
  82. */
  83. public function product_keyword(){
  84. return $this->hasMany(ProductKeywordModel::class,'collect_product_id','id')->orderBy('id','asc');;
  85. }
  86. /**
  87. * 写入数据
  88. * @author 唐远望
  89. * @version 1.0
  90. * @date 2025-12-30
  91. * @param $data
  92. * @return bool
  93. */
  94. public function addProduct($data)
  95. {
  96. DB::beginTransaction();
  97. try {
  98. // 计算品规数量
  99. $product_specs_data = isset($data['product_specs']) && $data['product_specs'] != '' ? explode(',', $data['product_specs']) : '';
  100. //移除数组内空值
  101. $product_specs_data = !empty($product_specs_data) ? array_filter($product_specs_data) : '';
  102. $insert_data = [
  103. 'enable_full_quantity' => isset($data['enable_full_quantity']) ? $data['enable_full_quantity'] : 0,
  104. 'platform' => $data['platform'],
  105. 'product_brand' => $data['product_brand'],
  106. 'product_name' => $data['product_name'],
  107. 'product_specs' => $data['product_specs'],
  108. 'product_specs_number' => $data['product_specs'] ? count($product_specs_data) : 1,
  109. 'minimum_order_quantity' => $data['minimum_order_quantity'],
  110. 'sampling_cycle' => $data['sampling_cycle'],
  111. 'round_number' => $data['round_number'],
  112. 'sampling_start_time' => $data['sampling_start_time'],
  113. 'sampling_end_time' => $data['sampling_end_time'],
  114. 'company_id' => $data['company_id'],
  115. 'insert_time' => time(),
  116. ];
  117. $Product_id = $this->insertGetId($insert_data);
  118. // 如果存在采集配置的关键字
  119. $product_keyword = $data['product_keyword'];
  120. if (trim($product_keyword) != '') {
  121. $ProductKeywordModel = new ProductKeywordModel();
  122. $product_keyword_data = explode(',', $product_keyword);
  123. $keyword_data = [];
  124. foreach ($product_keyword_data as $key => $value) {
  125. if (trim($value) == '') continue;
  126. $keyword_data[] = [
  127. 'collect_product_id' => $Product_id,
  128. 'keyword' => $value,
  129. ];
  130. }
  131. $ProductKeywordModel->insert($keyword_data);
  132. }
  133. DB::commit();
  134. return $Product_id;
  135. // 成功处理...
  136. } catch (\Exception $e) {
  137. DB::rollBack();
  138. // 错误处理...
  139. return false;
  140. }
  141. }
  142. /**
  143. * 编辑内容
  144. * @author 唐远望
  145. * @version 1.0
  146. * @date 2025-12-30
  147. * @param $data
  148. * @return bool
  149. */
  150. public function editProduct_content($Product, $data)
  151. {
  152. DB::beginTransaction();
  153. try {
  154. // 计算品规数量
  155. $product_specs_data = isset($data['product_specs']) && $data['product_specs'] != '' ? explode(',', $data['product_specs']) : '';
  156. //移除数组内空值
  157. $product_specs_data = !empty($product_specs_data) ? array_filter($product_specs_data) : '';
  158. $Product->enable_full_quantity = isset($data['enable_full_quantity']) ? $data['enable_full_quantity'] : 0;
  159. $Product->platform = $data['platform'];
  160. $Product->product_brand = $data['product_brand'];
  161. $Product->product_name = $data['product_name'];
  162. $Product->product_specs = $data['product_specs'];
  163. $Product->product_specs_number = $product_specs_data ? count($product_specs_data) : 1;
  164. $Product->minimum_order_quantity = $data['minimum_order_quantity'];
  165. $Product->sampling_cycle = $data['sampling_cycle'];
  166. $Product->round_number = $data['round_number'];
  167. $Product->sampling_start_time = $data['sampling_start_time'];
  168. $Product->sampling_end_time = $data['sampling_end_time'];
  169. $Product->update_time = time();
  170. $Product->save();
  171. $ProductKeywordModel = new ProductKeywordModel();
  172. //查询是否配置了关键字,如果有则删除重新添加
  173. $keyword_count = $ProductKeywordModel->where('collect_product_id', $Product->id)->count();
  174. if ($keyword_count > 0) {
  175. $ProductKeywordModel->where('collect_product_id', $Product->id)->delete();
  176. }
  177. // 如果存在采集配置的关键字
  178. $product_keyword = $data['product_keyword'];
  179. if (trim($product_keyword) != '') {
  180. $product_keyword_data = explode(',', $product_keyword);
  181. $keyword_data = [];
  182. foreach ($product_keyword_data as $key => $value) {
  183. if (trim($value) == '') continue;
  184. $keyword_data[] = [
  185. 'collect_product_id' => $Product->id,
  186. 'keyword' => $value,
  187. ];
  188. }
  189. $ProductKeywordModel->insert($keyword_data);
  190. }
  191. DB::commit();
  192. return true;
  193. // 成功处理...
  194. } catch (\Exception $e) {
  195. DB::rollBack();
  196. // 错误处理...
  197. return false;
  198. }
  199. }
  200. /**
  201. * 更新数据
  202. * @author 唐远望
  203. * @version 1.0
  204. * @date 2025-12-30
  205. * @param $data
  206. * @return bool
  207. */
  208. public function updateProduct($where, $data)
  209. {
  210. DB::beginTransaction();
  211. try {
  212. $this->editProduct_content($where, $data);
  213. DB::commit();
  214. return true;
  215. // 成功处理...
  216. } catch (\Exception $e) {
  217. DB::rollBack();
  218. // 错误处理...
  219. return false;
  220. }
  221. }
  222. /**
  223. * 修改状态
  224. * @author 唐远望
  225. * @version 1.0
  226. * @date 2025-12-30
  227. * @param $id
  228. * @param $status
  229. * @return bool
  230. */
  231. public function changeStatus($Product, $status)
  232. {
  233. $Product->status = $status;
  234. $Product->update_time = time();
  235. $Product->save();
  236. return true;
  237. }
  238. /**
  239. * 删除数据
  240. * @author 唐远望
  241. * @version 1.0
  242. * @date 2025-12-30
  243. * @param $id
  244. * @return bool
  245. */
  246. public function deleteProduct($where)
  247. {
  248. $Product = $this->where($where)->first();
  249. if (!$Product) {
  250. return false;
  251. }
  252. DB::beginTransaction();
  253. try {
  254. $Product->delete();
  255. DB::commit();
  256. return true;
  257. // 成功处理...
  258. } catch (\Exception $e) {
  259. DB::rollBack();
  260. // 错误处理...
  261. return false;
  262. }
  263. }
  264. }