Product.php 8.0 KB

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