Product.php 8.7 KB

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