WxShopGoodsRepositories.php 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  1. <?php
  2. namespace App\Http\Controllers\Api\Repositories;
  3. use App\Models\Shop\WxShopGoods;
  4. use App\Models\Shop\WxShopGoods as Model;
  5. use App\Models\WxSyncRelation;
  6. use Illuminate\Support\Facades\DB;
  7. use Illuminate\Support\Facades\Log;
  8. class WxShopGoodsRepositories{
  9. protected $eloquentClass = Model::class;
  10. /**
  11. * @param $domain
  12. * @param $external_id
  13. * @param $name
  14. * @param $pic
  15. * @param array $tag
  16. * @param $intro
  17. * @param $vip_price
  18. * @param $price
  19. * @param $content
  20. * @param $buys
  21. * @param $sku
  22. * @param $url
  23. * @param $classify_id
  24. * @param array $service_id
  25. * @param int $is_inspiration
  26. * @param int $state
  27. * @return bool
  28. */
  29. public static function admin_add($domain, $external_id, $name, $pic, array $tag, $intro, $vip_price, $price,
  30. $content, $buys, $sku, $url, $classify_id,array $service_id, $is_inspiration = 0, $state = 1){
  31. DB::beginTransaction();
  32. try {
  33. $goods_id = WxSyncRelationRepositories::wx_good_id($domain, $external_id);
  34. if($goods_id){
  35. return true;
  36. }
  37. $goods = new Model();
  38. $goods->type = $url ? 1 : 0;
  39. $goods->name = $name ?: '';
  40. $goods->pic = $pic ?: '';
  41. $goods->tag = $tag ? json_encode($tag) : '[]';
  42. $goods->intro = $intro ?: '';
  43. $goods->vip_price = $vip_price;
  44. $goods->price = $price;
  45. $goods->content = $content ?: '';
  46. $goods->buys = $buys ?: 0;
  47. $goods->sku = $sku ?: '';
  48. $goods->url = $url ?: '';
  49. $goods->classify_id = $classify_id;
  50. if(_empty_($service_id)){
  51. $service_id = [];
  52. }
  53. if($url){
  54. if(!in_array(5, $service_id)){
  55. $service_id[] = 5;
  56. }
  57. $goods->service_id = json_encode($service_id);
  58. }else{
  59. $goods->service_id = json_encode($service_id);
  60. }
  61. $goods->is_inspiration = 0;
  62. $goods->state = $state;
  63. $goods->save();
  64. $goodsId = $goods->id;
  65. if($external_id){
  66. $sync = new WxSyncRelation();
  67. $sync->domain = $domain;
  68. $sync->type = 'good';
  69. $sync->inner_id = $goodsId;
  70. $sync->external_id = $external_id;
  71. $sync->status = 1;
  72. $sync->save();
  73. }
  74. DB::commit();
  75. return true;
  76. } catch (\Exception $e) {
  77. DB::rollBack();
  78. _logger_(__file__, __line__, $e->getMessage());
  79. return false;
  80. }
  81. }
  82. /**
  83. * @param $dtk_id
  84. * @param $tk_platform_id
  85. * @param $name
  86. * @param $pic
  87. * @param $tag 数组
  88. * @param $intro
  89. * @param $vip_price
  90. * @param $price
  91. * @param $content
  92. * @param $buys
  93. * @param $sku
  94. * @param $url
  95. * @param $classify_id
  96. * @param $service_id 数组
  97. * @return int|mixed
  98. */
  99. public static function taoke_add($dtk_id, $tk_platform_id, $name, $pic, $tag, $intro, $vip_price, $price, $content, $buys, $sku, $url, $classify_id, $service_id, $url_word){
  100. DB::beginTransaction();
  101. try {
  102. if($dtk_id == -1 || strlen($dtk_id) <= 4){
  103. $dtk_id = null;
  104. }
  105. if($dtk_id){
  106. $id = WxShopGoods::where('dtk_id', $dtk_id)->value('id');
  107. if($id){
  108. return $id;
  109. }
  110. }
  111. $id = WxShopGoods::where('tk_platform_id', $tk_platform_id)->value('id');
  112. if($id){
  113. return $id;
  114. }
  115. $goods = new Model();
  116. $goods->dtk_id = $dtk_id;
  117. $goods->tk_platform_id = $tk_platform_id;
  118. $goods->type = 1;
  119. $goods->name = $name ?: '';
  120. $goods->pic = $pic ?: '';
  121. $goods->tag = $tag ? json_encode($tag) : '[]';
  122. $goods->intro = $intro ?: '';
  123. $goods->vip_price = $vip_price;
  124. $goods->price = $price;
  125. $goods->content = $content ?: '';
  126. $goods->buys = $buys ?: 0;
  127. $goods->sku = $sku ?: '';
  128. $goods->url = $url ?: '';
  129. $goods->classify_id = $classify_id;
  130. if(_empty_($service_id)){
  131. $service_id = [];
  132. }
  133. if(!_empty_($url_word)){
  134. $goods->url_word = $url_word;
  135. }
  136. if($url){
  137. if(!in_array(5, $service_id)){
  138. $service_id[] = 5;
  139. }
  140. $goods->service_id = json_encode($service_id);
  141. }else{
  142. $goods->service_id = json_encode($service_id);
  143. }
  144. $goods->is_inspiration = 0;
  145. $goods->state = 1;
  146. $goods->save();
  147. $goodsId = $goods->id;
  148. DB::commit();
  149. return $goodsId;
  150. } catch (\Exception $e) {
  151. DB::rollBack();
  152. _logger_(__file__, __line__, $e->getMessage());
  153. return 0;
  154. }
  155. }
  156. /**
  157. * 搜索
  158. * @param $keyword
  159. * @return mixed
  160. */
  161. public static function searchGoods($keyword, $uid = 0, $limit = 10)
  162. {
  163. $data = (new Model())
  164. ->where('state', 1)
  165. ->where(function ($query) use ($keyword) {
  166. $query->orWhere('name ', 'like', '%' . $keyword . '%')
  167. ->orWhere('intro', 'like', '%' . $keyword . '%')
  168. ->orWhere('id', $keyword);
  169. })
  170. ->simplePaginate($limit);
  171. if($data){
  172. return $data;
  173. }
  174. return null;
  175. }
  176. }