LowPriceGoods.php 8.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246
  1. <?php
  2. namespace App\Models\Manager\Process;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Models\Manager\Process\LowPriceGoodsMember as LowPriceGoodsMemberModel;
  7. /**
  8. * 违规处理-低价商品模型
  9. * @author: 唐远望
  10. * @version: 1.0
  11. * @date: 2025-12-08
  12. */
  13. class LowPriceGoods extends Model
  14. {
  15. use HasFactory;
  16. // 与模型关联的表名
  17. protected $table = 'process_lowprice_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-08
  28. */
  29. public function addLowPriceGoods_content($data)
  30. {
  31. $insert_data = [
  32. 'first_responsible_person' => $data['first_responsible_person'],
  33. 'responsible_person' => $data['responsible_person'],
  34. 'platform' => $data['platform'],
  35. 'company_name' => $data['company_name'],
  36. 'product_name' => $data['product_name'],
  37. 'product_specs' => $data['product_specs'],
  38. 'suggested_price' => $data['suggested_price'],
  39. 'online_posting_price' => $data['online_posting_price'],
  40. 'online_posting_cunt' => $data['online_posting_cunt'],
  41. 'link_url' => $data['link_url'],
  42. 'store_name' => $data['store_name'],
  43. 'source_responsible_person' => $data['source_responsible_person'],
  44. 'processing_status' => '1',
  45. 'insert_time' => time(),
  46. ];
  47. $LowPriceGoods_id = $this->insertGetId($insert_data);
  48. return $LowPriceGoods_id;
  49. }
  50. /**
  51. * 写入数据
  52. * @author 唐远望
  53. * @version 1.0
  54. * @date 2025-12-08
  55. * @param $data
  56. * @return bool
  57. */
  58. public function addLowPriceGoods($data)
  59. {
  60. DB::beginTransaction();
  61. try {
  62. $LowPriceGoodsMemberModel = new LowPriceGoodsMemberModel();
  63. $insert_data = [
  64. 'platform' => $data['platform'],
  65. 'company_name' => $data['company_name'],
  66. 'product_name' => $data['product_name'],
  67. 'product_specs' => $data['product_specs'],
  68. 'suggested_price' => $data['suggested_price'],
  69. 'online_posting_price' => $data['online_posting_price'],
  70. 'online_posting_cunt' => $data['online_posting_cunt'],
  71. 'link_url' => $data['link_url'],
  72. 'store_name' => $data['store_name'],
  73. 'processing_status' => '1',
  74. 'insert_time' => time(),
  75. ];
  76. $LowPriceGoods_id = $this->insertGetId($insert_data);
  77. $first_responsible_persons = explode(',', $data['first_responsible_person']);
  78. $first_responsible_person_data=[];
  79. if (count($first_responsible_persons) > 0) {
  80. foreach ($first_responsible_persons as $key => $employee_id) {
  81. $first_responsible_person_data[] = [
  82. 'lowprice_product_logid' => $LowPriceGoods_id,
  83. 'employee_id' => $employee_id,
  84. 'duty_type' => 1,//责任类型1=第一责任人,2=责任人,3=溯源责任人
  85. ];
  86. }
  87. }
  88. $LowPriceGoodsMemberModel->inser($first_responsible_person_data);
  89. $responsible_persons = explode(',', $data['responsible_person']);
  90. $responsible_person_data=[];
  91. if (count($responsible_persons) > 0) {
  92. foreach ($responsible_persons as $key => $employee_id) {
  93. $responsible_person_data[] = [
  94. 'lowprice_product_logid' => $LowPriceGoods_id,
  95. 'employee_id' => $employee_id,
  96. 'duty_type' => 2,//责任类型1=第一责任人,2=责任人,3=溯源责任人
  97. ];
  98. }
  99. }
  100. $LowPriceGoodsMemberModel->inser($responsible_person_data);
  101. $source_responsible_persons = explode(',', $data['source_responsible_person']);
  102. $source_responsible_person_data=[];
  103. if (count($source_responsible_persons) > 0) {
  104. foreach ($source_responsible_persons as $key => $employee_id) {
  105. $source_responsible_person_data[] = [
  106. 'lowprice_product_logid' => $LowPriceGoods_id,
  107. 'employee_id' => $employee_id,
  108. 'duty_type' => 3,//责任类型1=第一责任人,2=责任人,3=溯源责任人
  109. ];
  110. }
  111. }
  112. $LowPriceGoodsMemberModel->inser($source_responsible_person_data);
  113. DB::commit();
  114. return true;
  115. // 成功处理...
  116. } catch (\Exception $e) {
  117. DB::rollBack();
  118. // 错误处理...
  119. return false;
  120. }
  121. }
  122. /**
  123. * 编辑内容
  124. * @author 唐远望
  125. * @version 1.0
  126. * @date 2025-12-08
  127. * @param $data
  128. * @return bool
  129. */
  130. public function editLowPriceGoods_content($where, $data)
  131. {
  132. $LowPriceGoods = $this->where($where)->first();
  133. if (!$LowPriceGoods) {
  134. return false;
  135. }
  136. $LowPriceGoods->first_responsible_person = $data['first_responsible_person'];
  137. $LowPriceGoods->responsible_person = $data['responsible_person'];
  138. $LowPriceGoods->platform = $data['platform'];
  139. $LowPriceGoods->company_name = $data['company_name'];
  140. $LowPriceGoods->product_name = $data['product_name'];
  141. $LowPriceGoods->product_specs = $data['product_specs'];
  142. $LowPriceGoods->suggested_price = $data['suggested_price'];
  143. $LowPriceGoods->online_posting_price = $data['online_posting_price'];
  144. $LowPriceGoods->online_posting_cunt = $data['online_posting_cunt'];
  145. $LowPriceGoods->link_url = $data['link_url'];
  146. $LowPriceGoods->store_name = $data['store_name'];
  147. $LowPriceGoods->source_responsible_person = $data['source_responsible_person'];
  148. $LowPriceGoods->update_time = time();
  149. $LowPriceGoods->save();
  150. return true;
  151. }
  152. /**
  153. * 更新数据
  154. * @author 唐远望
  155. * @version 1.0
  156. * @date 2025-12-08
  157. * @param $data
  158. * @return bool
  159. */
  160. public function updateLowPriceGoods($where, $data)
  161. {
  162. DB::beginTransaction();
  163. try {
  164. $this->editLowPriceGoods_content($where, $data);
  165. DB::commit();
  166. return true;
  167. // 成功处理...
  168. } catch (\Exception $e) {
  169. DB::rollBack();
  170. // 错误处理...
  171. return false;
  172. }
  173. }
  174. /**
  175. * 修改状态
  176. * @author 唐远望
  177. * @version 1.0
  178. * @date 2025-12-08
  179. * @param $id
  180. * @param $status
  181. * @return bool
  182. */
  183. public function changeStatus($where, $status)
  184. {
  185. $LowPriceGoods = $this->where($where)->first();
  186. if (!$LowPriceGoods) {
  187. return false;
  188. }
  189. $LowPriceGoods->status = $status;
  190. $LowPriceGoods->update_time = time();
  191. $LowPriceGoods->save();
  192. return true;
  193. }
  194. /**
  195. * 修改处理状态
  196. * @author 唐远望
  197. * @version 1.0
  198. * @date 2025-12-08
  199. * @param $id
  200. * @param $processing_status
  201. * @return bool
  202. */
  203. public function changeProcessingStatus($where, $processing_status)
  204. {
  205. $LowPriceGoods = $this->where($where)->first();
  206. if (!$LowPriceGoods) {
  207. return false;
  208. }
  209. $LowPriceGoods->processing_status = $processing_status;
  210. $LowPriceGoods->update_time = time();
  211. $LowPriceGoods->save();
  212. return true;
  213. }
  214. /**
  215. * 删除数据
  216. * @author 唐远望
  217. * @version 1.0
  218. * @date 2025-12-08
  219. * @param $id
  220. * @return bool
  221. */
  222. public function deleteLowPriceGoods($where)
  223. {
  224. $LowPriceGoods = $this->where($where)->first();
  225. if (!$LowPriceGoods) {
  226. return false;
  227. }
  228. $LowPriceGoods->delete();
  229. return true;
  230. }
  231. }