ViolationProduct.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331
  1. <?php
  2. namespace App\Models\Manager\WashConfig;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Models\Manager\WashConfig\ViolationProductCompany as ViolationProductCompanyModel;
  7. use App\Models\Manager\WashConfig\ViolationProductPlatform as ViolationProductPlatformModel;
  8. use App\Models\Manager\WashConfig\ViolationProductKeyword as ViolationProductKeywordModel;
  9. /**
  10. * 清洗配置-违规商品
  11. * @author: 唐远望
  12. * @version: 1.0
  13. * @date: 2025-12-03
  14. */
  15. class ViolationProduct extends Model
  16. {
  17. use HasFactory;
  18. // 与模型关联的表名
  19. protected $table = 'washconfig_violation_product';
  20. // 是否主动维护时间戳
  21. public $timestamps = false;
  22. // 定义时间戳字段名
  23. // const CREATED_AT = 'insert_time';
  24. // const UPDATED_AT = 'update_time';
  25. /**
  26. * 添加
  27. * @author 唐远望
  28. * @version 1.0
  29. * @date 2025-12-03
  30. */
  31. public function addViolationProduct_content($data)
  32. {
  33. $insert_data = [
  34. 'company_id' => $data['company_id'],
  35. 'platform' => $data['platform'],
  36. 'product_brand' => $data['product_brand'],
  37. 'product_name' => $data['product_name'],
  38. 'product_specs' => $data['product_specs'],
  39. 'store_scope' => $data['store_scope'] != '' ? 2 : 1, //店铺范围1=全部店铺 2=指定店铺
  40. 'company_scope' => $data['company_scope'] != '' ? 2 : 1, //公司范围1=全部公司 2=指定公司
  41. 'category_id' => $data['category_id'],
  42. 'specify_responsible_person' => $data['specify_responsible_person'],
  43. 'product_brand' => $data['product_brand'],
  44. 'insert_time' => time(),
  45. ];
  46. $ViolationProduct_id = $this->insertGetId($insert_data);
  47. return $ViolationProduct_id;
  48. }
  49. /**
  50. * 连表查询商品关键字
  51. * @author 唐远望
  52. * @version 1.0
  53. * @date 2026-03-31
  54. */
  55. public function product_keyword(){
  56. return $this->hasMany(ViolationProductKeywordModel::class,'violation_product_id','id');
  57. }
  58. /**
  59. * 写入数据
  60. * @author 唐远望
  61. * @version 1.0
  62. * @date 2025-12-03
  63. * @param $data
  64. * @return bool
  65. */
  66. public function addViolationProduct($data)
  67. {
  68. DB::beginTransaction();
  69. try {
  70. $insert_data = [
  71. 'company_id' => $data['company_id'],
  72. 'platform' => $data['platform'],
  73. 'product_name' => $data['product_name'],
  74. 'product_specs' => $data['product_specs'],
  75. 'store_scope' => $data['store_scope'] != '' ? 2 : 1, //店铺范围1=全部店铺 2=指定店铺
  76. 'company_scope' => $data['company_scope'] != '' ? 2 : 1, //公司范围1=全部公司 2=指定公司
  77. 'category_id' => $data['category_id'],
  78. 'specify_responsible_person' => $data['specify_responsible_person'],
  79. 'insert_time' => time(),
  80. ];
  81. $ViolationProduct_id = $this->insertGetId($insert_data);
  82. if ($insert_data['company_scope'] == 2) {
  83. $ViolationProductCompanyModel = new ViolationProductCompanyModel();
  84. $insert_company_data = [];
  85. $company_scope = explode(',', $data['company_scope']);
  86. foreach ($company_scope as $company_id) {
  87. $insert_company_data[] = [
  88. 'violation_product_logid' => $ViolationProduct_id,
  89. 'company_id' => $company_id,
  90. ];
  91. }
  92. $ViolationProductCompanyModel->insert($insert_company_data);
  93. }
  94. if ($data['platform'] != 0) {
  95. $ViolationProductPlatformModel = new ViolationProductPlatformModel();
  96. $insert_platform_data = [];
  97. $platform_scope = explode(',', $data['platform']);
  98. foreach ($platform_scope as $platform_id) {
  99. $insert_platform_data[] = [
  100. 'company_id' => $data['company_id'],
  101. 'product_id' => $ViolationProduct_id,
  102. 'platform_id' => $platform_id,
  103. ];
  104. }
  105. $ViolationProductPlatformModel->insert($insert_platform_data);
  106. }
  107. // 如果存在采集配置的关键字
  108. $product_keyword = $data['product_keyword'];
  109. if (trim($product_keyword) != '') {
  110. $ProductKeywordModel = new ViolationProductKeywordModel();
  111. $product_keyword_data = explode(',', $product_keyword);
  112. $keyword_data = [];
  113. foreach ($product_keyword_data as $key => $value) {
  114. if (trim($value) == '') continue;
  115. $keyword_data[] = [
  116. 'violation_product_id' => $ViolationProduct_id,
  117. 'keyword' => $value,
  118. ];
  119. }
  120. $ProductKeywordModel->insert($keyword_data);
  121. }
  122. DB::commit();
  123. return true;
  124. // 成功处理...
  125. } catch (\Exception $e) {
  126. DB::rollBack();
  127. // 错误处理...
  128. return false;
  129. }
  130. }
  131. /**
  132. * 编辑内容
  133. * @author 唐远望
  134. * @version 1.0
  135. * @date 2025-12-03
  136. * @param $data
  137. * @return bool
  138. */
  139. public function editViolationProduct_content($ViolationProduct, $data)
  140. {
  141. DB::beginTransaction();
  142. try {
  143. $ViolationProductCompanyModel = new ViolationProductCompanyModel();
  144. $ViolationProductPlatformModel = new ViolationProductPlatformModel();
  145. $store_scope = $data['store_scope'] != '' ? 2 : 1; //店铺范围1=全部店铺 2=指定店铺
  146. $company_scope = $data['company_scope'] != '' ? 2 : 1; //公司范围1=全部公司 2=指定公司
  147. $ViolationProduct->company_id = $data['company_id'];
  148. $ViolationProduct->platform = $data['platform'];
  149. $ViolationProduct->product_brand = $data['product_brand'];
  150. $ViolationProduct->product_name = $data['product_name'];
  151. $ViolationProduct->product_specs = $data['product_specs'];
  152. $ViolationProduct->store_scope = $store_scope;
  153. $ViolationProduct->company_scope = $company_scope;
  154. $ViolationProduct->category_id = $data['category_id'];
  155. $ViolationProduct->specify_responsible_person = $data['specify_responsible_person'];
  156. $ViolationProduct->update_time = time();
  157. $ViolationProduct->save();
  158. $violation_product_companycount = $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->count();
  159. if ($violation_product_companycount > 0) {
  160. $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->delete();
  161. }
  162. if ($company_scope == 2) {
  163. $insert_company_data = [];
  164. $company_scope = explode(',', $data['company_scope']);
  165. foreach ($company_scope as $company_id) {
  166. $insert_company_data[] = [
  167. 'violation_product_logid' => $ViolationProduct->id,
  168. 'company_id' => $company_id,
  169. ];
  170. }
  171. $ViolationProductCompanyModel->insert($insert_company_data);
  172. }
  173. $violation_product_platformcount = $ViolationProductPlatformModel->where('product_id', $ViolationProduct->id)->count();
  174. if ($violation_product_platformcount > 0) {
  175. $ViolationProductPlatformModel->where('product_id', $ViolationProduct->id)->delete();
  176. }
  177. if ($data['platform'] != 0) {
  178. $insert_platform_data = [];
  179. $platform_scope = explode(',', $data['platform']);
  180. foreach ($platform_scope as $platform_id) {
  181. $insert_platform_data[] = [
  182. 'company_id' => $data['company_id'],
  183. 'product_id' => $ViolationProduct->id,
  184. 'platform_id' => $platform_id,
  185. ];
  186. }
  187. $ViolationProductPlatformModel->insert($insert_platform_data);
  188. }
  189. // 如果存在采集配置的关键字
  190. $product_keyword = $data['product_keyword'];
  191. if (trim($product_keyword) != '') {
  192. $ProductKeywordModel = new ViolationProductKeywordModel();
  193. //查询是否配置了关键字,如果有则删除重新添加
  194. $keyword_count = $ProductKeywordModel->where('violation_product_id', $ViolationProduct->id)->count();
  195. if ($keyword_count > 0) {
  196. $ProductKeywordModel->where('violation_product_id', $ViolationProduct->id)->delete();
  197. }
  198. $product_keyword_data = explode(',', $product_keyword);
  199. $keyword_data = [];
  200. foreach ($product_keyword_data as $key => $value) {
  201. if (trim($value) == '') continue;
  202. $keyword_data[] = [
  203. 'violation_product_id' => $ViolationProduct->id,
  204. 'keyword' => $value,
  205. ];
  206. }
  207. $ProductKeywordModel->insert($keyword_data);
  208. }
  209. DB::commit();
  210. return true;
  211. // 成功处理...
  212. } catch (\Exception $e) {
  213. DB::rollBack();
  214. // 错误处理...
  215. return false;
  216. }
  217. }
  218. /**
  219. * 更新数据
  220. * @author 唐远望
  221. * @version 1.0
  222. * @date 2025-12-03
  223. * @param $data
  224. * @return bool
  225. */
  226. public function updateViolationProduct($where, $data)
  227. {
  228. DB::beginTransaction();
  229. try {
  230. $this->editViolationProduct_content($where, $data);
  231. DB::commit();
  232. return true;
  233. // 成功处理...
  234. } catch (\Exception $e) {
  235. DB::rollBack();
  236. // 错误处理...
  237. return false;
  238. }
  239. }
  240. /**
  241. * 修改状态
  242. * @author 唐远望
  243. * @version 1.0
  244. * @date 2025-12-03
  245. * @param $id
  246. * @param $status
  247. * @return bool
  248. */
  249. public function changeStatus($ViolationProduct, $status)
  250. {
  251. $ViolationProduct->status = $status;
  252. $ViolationProduct->update_time = time();
  253. $ViolationProduct->save();
  254. return true;
  255. }
  256. /**
  257. * 删除数据
  258. * @author 唐远望
  259. * @version 1.0
  260. * @date 2025-12-03
  261. * @param $id
  262. * @return bool
  263. */
  264. public function deleteViolationProduct($where)
  265. {
  266. $ViolationProduct = $this->where($where)->first();
  267. if (!$ViolationProduct) {
  268. return false;
  269. }
  270. DB::beginTransaction();
  271. try {
  272. $ViolationProductCompanyModel = new ViolationProductCompanyModel();
  273. $company_id_log = $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->get();
  274. if (!empty($company_id_log)) {
  275. $ViolationProductCompanyModel->where('violation_product_logid', $ViolationProduct->id)->delete();
  276. }
  277. $ViolationProduct->delete();
  278. DB::commit();
  279. return true;
  280. // 成功处理...
  281. } catch (\Exception $e) {
  282. DB::rollBack();
  283. // 错误处理...
  284. return false;
  285. }
  286. }
  287. /**
  288. * 平台定义
  289. * @author 唐远望
  290. * @version 1.0
  291. * @date 2025-12-31
  292. */
  293. public function platform_data()
  294. {
  295. $platform_data = [
  296. '全部' => '0',
  297. '淘宝' => '1',
  298. '京东' => '2',
  299. '拼多多' => '3',
  300. '美团' => '4',
  301. '药师帮' => '5',
  302. '1药城' => '6',
  303. '药九九' => '7',
  304. '药易购' => '8',
  305. '药帮忙' => '9',
  306. '熊猫药药' => '10'
  307. ];
  308. return $platform_data;
  309. }
  310. }