CardGoods.php 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com
  8. * =========================================================
  9. */
  10. namespace addon\cardservice\model;
  11. use addon\discount\model\Discount;
  12. use app\model\BaseModel;
  13. use app\model\storegoods\StoreGoods;
  14. use app\model\system\Cron;
  15. use app\model\system\Stat;
  16. /**
  17. * 虚拟商品
  18. */
  19. class CardGoods extends BaseModel
  20. {
  21. private $goods_class = array ( 'id' => 5, 'name' => '卡项套餐' );
  22. private $goods_state = array (
  23. 1 => '销售中',
  24. 0 => '仓库中'
  25. );
  26. public $card_type = [
  27. 'oncecard' => [
  28. 'title' => '限次卡',
  29. 'desc' => '支持创建多个项目/商品集合有限次数卡',
  30. 'type' => 'oncecard'
  31. ],
  32. 'timecard' => [
  33. 'title' => '限时卡',
  34. 'type' => 'timecard',
  35. 'desc' => '支持创建多个项目/商品集合不限次数卡'
  36. ],
  37. 'commoncard' => [
  38. 'title' => '通用卡',
  39. 'type' => 'commoncard',
  40. 'desc' => '会员可在设定次数内任意使用卡内项目/商品'
  41. ],
  42. ];
  43. public function getCardType($type = '')
  44. {
  45. if (empty($type)) {
  46. return $this->card_type;
  47. } else {
  48. return $this->card_type[ $type ];
  49. }
  50. }
  51. public function getGoodsState()
  52. {
  53. return $this->goods_state;
  54. }
  55. public function getGoodsClass()
  56. {
  57. return $this->goods_class;
  58. }
  59. /**
  60. * 商品添加
  61. * @param $data
  62. */
  63. public function addGoods($data)
  64. {
  65. model('goods')->startTrans();
  66. try {
  67. if (!empty($data[ 'goods_attr_format' ])) {
  68. $goods_attr_format = json_decode($data[ 'goods_attr_format' ], true);
  69. $keys = array_column($goods_attr_format, 'sort');
  70. if (!empty($keys)) {
  71. array_multisort($keys, SORT_ASC, SORT_NUMERIC, $goods_attr_format);
  72. $data[ 'goods_attr_format' ] = json_encode($goods_attr_format);
  73. }
  74. }
  75. $goods_image = $data[ 'goods_image' ];
  76. $first_image = explode(",", $goods_image)[ 0 ];
  77. //SKU商品数据
  78. if (!empty($data[ 'goods_sku_data' ])) {
  79. $data[ 'goods_sku_data' ] = json_decode($data[ 'goods_sku_data' ], true);
  80. }
  81. //获取标签名称
  82. $label_name = '';
  83. if ($data[ 'label_id' ]) {
  84. $label_info = model('goods_label')->getInfo([ [ 'id', '=', $data[ 'label_id' ] ] ], 'label_name');
  85. $label_name = $label_info[ 'label_name' ] ?? '';
  86. }
  87. $brand_name = '';
  88. if ($data[ 'brand_id' ]) {
  89. $brand_info = model('goods_brand')->getInfo([ [ 'brand_id', '=', $data[ 'brand_id' ] ] ], 'brand_name');
  90. $brand_name = $brand_info[ 'brand_name' ] ?? '';
  91. }
  92. $goods_data = array (
  93. 'goods_image' => $goods_image,
  94. 'price' => $data[ 'goods_sku_data' ][ 0 ][ 'price' ],
  95. 'market_price' => $data[ 'goods_sku_data' ][ 0 ][ 'market_price' ],
  96. 'cost_price' => $data[ 'goods_sku_data' ][ 0 ][ 'cost_price' ],
  97. 'goods_spec_format' => $data[ 'goods_spec_format' ],
  98. 'category_id' => $data[ 'category_id' ],
  99. 'category_json' => $data[ 'category_json' ],
  100. 'label_id' => $data[ 'label_id' ],
  101. 'label_name' => $label_name,
  102. 'timer_on' => $data[ 'timer_on' ],
  103. 'timer_off' => $data[ 'timer_off' ],
  104. 'sale_show' => $data[ 'sale_show' ] ?? 1,
  105. 'stock_show' => $data[ 'stock_show' ] ?? 1,
  106. 'market_price_show' => $data[ 'market_price_show' ] ?? 1,
  107. 'barrage_show' => $data[ 'barrage_show' ] ?? 1,
  108. 'is_consume_discount' => $data[ 'is_consume_discount' ],
  109. );
  110. $common_data = array (
  111. 'goods_name' => $data[ 'goods_name' ],
  112. 'goods_class' => $this->goods_class[ 'id' ],
  113. 'goods_class_name' => $this->goods_class[ 'name' ],
  114. 'goods_attr_class' => $data[ 'goods_attr_class' ],
  115. 'goods_attr_name' => $data[ 'goods_attr_name' ],
  116. 'is_limit' => isset($data[ 'is_limit' ]) ? $data[ 'is_limit' ] : 0,
  117. 'limit_type' => isset($data[ 'limit_type' ]) ? $data[ 'limit_type' ] : 1,
  118. 'site_id' => $data[ 'site_id' ],
  119. 'goods_content' => $data[ 'goods_content' ],
  120. 'goods_state' => $data[ 'goods_state' ],
  121. 'goods_stock_alarm' => $data[ 'goods_stock_alarm' ],
  122. 'is_virtual' => 1,
  123. 'virtual_indate' => 0,
  124. 'goods_attr_format' => $data[ 'goods_attr_format' ],
  125. 'introduction' => $data[ 'introduction' ],
  126. 'keywords' => $data[ 'keywords' ],
  127. 'unit' => $data[ 'unit' ],
  128. 'brand_id' => $data[ 'brand_id' ],//品牌id
  129. 'brand_name' => $brand_name,//品牌名称
  130. 'video_url' => $data[ 'video_url' ],
  131. 'sort' => $data[ 'sort' ],
  132. 'goods_service_ids' => $data[ 'goods_service_ids' ],
  133. 'create_time' => time(),
  134. 'virtual_sale' => $data[ 'virtual_sale' ],
  135. 'max_buy' => $data[ 'max_buy' ],
  136. 'min_buy' => $data[ 'min_buy' ],
  137. 'recommend_way' => $data[ 'recommend_way' ],
  138. 'qr_id' => isset($data[ 'qr_id' ]) ? $data[ 'qr_id' ] : 0,
  139. 'template_id' => isset($data[ 'template_id' ]) ? $data[ 'template_id' ] : 0,
  140. 'form_id' => $data[ 'form_id' ] ?? 0,
  141. 'sale_channel' => $data[ 'sale_channel' ] ?? 'all',
  142. 'sale_store' => $data[ 'sale_store' ] ?? 'all',
  143. 'is_unify_price' => $data[ 'is_unify_price' ] ?? 1,
  144. );
  145. $goods_id = model('goods')->add(array_merge($goods_data, $common_data));
  146. $goods_stock = 0;
  147. $sku_arr = array ();
  148. $sku_stock_list = [];
  149. //添加sku商品
  150. foreach ($data[ 'goods_sku_data' ] as $item) {
  151. $goods_stock += $item[ 'stock' ];
  152. $sku_data = array (
  153. 'sku_name' => $data[ 'goods_name' ] . ' ' . $item[ 'spec_name' ],
  154. 'spec_name' => $item[ 'spec_name' ],
  155. 'sku_no' => $item[ 'sku_no' ],
  156. 'sku_spec_format' => !empty($item[ 'sku_spec_format' ]) ? json_encode($item[ 'sku_spec_format' ]) : "",
  157. 'price' => $item[ 'price' ],
  158. 'market_price' => $item[ 'market_price' ],
  159. 'cost_price' => $item[ 'cost_price' ],
  160. 'discount_price' => $item[ 'price' ],//sku折扣价(默认等于单价)
  161. 'stock' => $item[ 'stock' ],
  162. 'stock_alarm' => $item[ 'stock_alarm' ],
  163. 'sku_image' => !empty($item[ 'sku_image' ]) ? $item[ 'sku_image' ] : $first_image,
  164. 'sku_images' => $item[ 'sku_images' ],
  165. 'goods_id' => $goods_id,
  166. 'is_default' => $item[ 'is_default' ] ?? 0,
  167. 'is_consume_discount' => $data[ 'is_consume_discount' ],
  168. 'site_id' => $data[ 'site_id' ]
  169. );
  170. $sku_arr[] = array_merge($sku_data, $common_data);
  171. $sku_stock_list[] = [ 'stock' => $item[ 'stock' ], 'site_id' => $data[ 'site_id' ], 'goods_class' => $common_data[ 'goods_class' ] ];
  172. }
  173. model('goods_sku')->addList($sku_arr);
  174. // 赋值第一个商品sku_id
  175. $first_info = model('goods_sku')->getFirstData([ 'goods_id' => $goods_id ], 'sku_id', 'is_default desc,sku_id asc');
  176. model('goods')->update([ 'sku_id' => $first_info[ 'sku_id' ] ], [ [ 'goods_id', '=', $goods_id ] ]);
  177. if (!empty($data[ 'goods_spec_format' ])) {
  178. // 刷新SKU商品规格项 / 规格值JSON字符串
  179. $this->dealGoodsSkuSpecFormat($goods_id, $data[ 'goods_spec_format' ]);
  180. }
  181. // 添加商品卡项表
  182. model('goods_card')->add([
  183. 'site_id' => $data[ 'site_id' ],
  184. 'goods_id' => $goods_id,
  185. 'card_type' => $data[ 'card_type' ],
  186. 'card_type_name' => $this->card_type[ $data[ 'card_type' ] ][ 'title' ],
  187. 'renew_price' => $data[ 'renew_price' ],
  188. 'recharge_money' => $data[ 'recharge_money' ] ?? 0,
  189. 'common_num' => $data[ 'common_num' ],
  190. 'discount_goods_type' => $data[ 'discount_goods_type' ],
  191. 'discount' => $data[ 'discount' ],
  192. 'validity_type' => $data[ 'validity_type' ],
  193. 'validity_day' => $data[ 'validity_day' ] ?? 0,
  194. 'validity_time' => $data[ 'validity_time' ] ?? 0,
  195. ]);
  196. // 添加商品卡项项目表
  197. $relation_goods = json_decode($data[ 'relation_goods' ], true);
  198. if (!empty($relation_goods)) {
  199. $goods_card_item = [];
  200. foreach ($relation_goods as $item) {
  201. array_push($goods_card_item, [
  202. 'site_id' => $data[ 'site_id' ],
  203. 'card_goods_id' => $goods_id,
  204. 'goods_id' => $item[ 'goods_id' ],
  205. 'sku_id' => $item[ 'sku_id' ],
  206. 'num' => $item[ 'num' ] ?? 0,
  207. 'discount' => $item[ 'discount' ] ?? 0,
  208. ]);
  209. }
  210. model('goods_card_item')->addList($goods_card_item);
  211. }
  212. $cron = new Cron();
  213. //定时上下架
  214. if ($goods_data[ 'timer_on' ] > 0) {
  215. $cron->addCron(1, 0, "商品定时上架", "CronGoodsTimerOn", $goods_data[ 'timer_on' ], $goods_id);
  216. }
  217. if ($goods_data[ 'timer_off' ] > 0) {
  218. $cron->addCron(1, 0, "商品定时下架", "CronGoodsTimerOff", $goods_data[ 'timer_off' ], $goods_id);
  219. }
  220. //添加统计
  221. $stat = new Stat();
  222. $stat->switchStat([ 'type' => 'add_goods', 'data' => [ 'add_goods_count' => 1, 'site_id' => $data[ 'site_id' ] ] ]);
  223. // 商品设置库存
  224. $goods_stock_model = new \app\model\stock\GoodsStock();
  225. $sku_list = model('goods_sku')->getList([ 'goods_id' => $goods_id ], 'sku_id');
  226. foreach ($sku_stock_list as $k => $v) {
  227. $v[ 'sku_id' ] = $sku_list[ $k ][ 'sku_id' ];
  228. $goods_stock_model->changeGoodsStock($v);
  229. }
  230. //同步商品成本价
  231. ( new StoreGoods() )->setSkuPrice([ 'goods_id' => $goods_id, 'site_id' => $data[ 'site_id' ] ]);
  232. model('goods')->commit();
  233. return $this->success($goods_id);
  234. } catch (\Exception $e) {
  235. model('goods')->rollback();
  236. return $this->error($e->getMessage() . $e->getFile() . $e->getLine());
  237. }
  238. }
  239. /**
  240. * 商品编辑
  241. * @param $data
  242. */
  243. public function editGoods($data)
  244. {
  245. model('goods')->startTrans();
  246. try {
  247. if (!empty($data[ 'goods_attr_format' ])) {
  248. $goods_attr_format = json_decode($data[ 'goods_attr_format' ], true);
  249. $keys = array_column($goods_attr_format, 'sort');
  250. if (!empty($keys)) {
  251. array_multisort($keys, SORT_ASC, SORT_NUMERIC, $goods_attr_format);
  252. $data[ 'goods_attr_format' ] = json_encode($goods_attr_format);
  253. }
  254. }
  255. $goods_id = $data[ 'goods_id' ];
  256. $goods_image = $data[ 'goods_image' ];
  257. $first_image = explode(",", $goods_image)[ 0 ];
  258. //SKU商品数据
  259. if (!empty($data[ 'goods_sku_data' ])) {
  260. $data[ 'goods_sku_data' ] = json_decode($data[ 'goods_sku_data' ], true);
  261. }
  262. //获取标签名称
  263. $label_name = '';
  264. if ($data[ 'label_id' ]) {
  265. $label_info = model('goods_label')->getInfo([ [ 'id', '=', $data[ 'label_id' ] ] ], 'label_name');
  266. $label_name = $label_info[ 'label_name' ] ?? '';
  267. }
  268. $brand_name = '';
  269. if ($data[ 'brand_id' ]) {
  270. $brand_info = model('goods_brand')->getInfo([ [ 'brand_id', '=', $data[ 'brand_id' ] ] ], 'brand_name');
  271. $brand_name = $brand_info[ 'brand_name' ] ?? '';
  272. }
  273. $goods_data = array (
  274. 'goods_image' => $goods_image,
  275. 'price' => $data[ 'goods_sku_data' ][ 0 ][ 'price' ],
  276. 'market_price' => $data[ 'goods_sku_data' ][ 0 ][ 'market_price' ],
  277. 'cost_price' => $data[ 'goods_sku_data' ][ 0 ][ 'cost_price' ],
  278. 'goods_spec_format' => $data[ 'goods_spec_format' ],
  279. 'category_id' => $data[ 'category_id' ],
  280. 'category_json' => $data[ 'category_json' ],
  281. 'label_id' => $data[ 'label_id' ],
  282. 'label_name' => $label_name,
  283. 'timer_on' => $data[ 'timer_on' ],
  284. 'timer_off' => $data[ 'timer_off' ],
  285. 'sale_show' => $data[ 'sale_show' ],
  286. 'stock_show' => $data[ 'stock_show' ],
  287. 'market_price_show' => $data[ 'market_price_show' ],
  288. 'barrage_show' => $data[ 'barrage_show' ],
  289. 'is_consume_discount' => $data[ 'is_consume_discount' ],
  290. );
  291. $common_data = array (
  292. 'goods_name' => $data[ 'goods_name' ],
  293. 'goods_class' => $this->goods_class[ 'id' ],
  294. 'goods_class_name' => $this->goods_class[ 'name' ],
  295. 'goods_attr_class' => $data[ 'goods_attr_class' ],
  296. 'goods_attr_name' => $data[ 'goods_attr_name' ],
  297. 'is_limit' => isset($data[ 'is_limit' ]) ? $data[ 'is_limit' ] : 0,
  298. 'limit_type' => isset($data[ 'limit_type' ]) ? $data[ 'limit_type' ] : 1,
  299. 'site_id' => $data[ 'site_id' ],
  300. 'goods_content' => $data[ 'goods_content' ],
  301. 'goods_state' => $data[ 'goods_state' ],
  302. 'goods_stock_alarm' => $data[ 'goods_stock_alarm' ],
  303. 'is_virtual' => 1,
  304. 'virtual_indate' => 0,
  305. 'goods_attr_format' => $data[ 'goods_attr_format' ],
  306. 'introduction' => $data[ 'introduction' ],
  307. 'keywords' => $data[ 'keywords' ],
  308. 'unit' => $data[ 'unit' ],
  309. 'video_url' => $data[ 'video_url' ],
  310. 'sort' => $data[ 'sort' ],
  311. 'goods_service_ids' => $data[ 'goods_service_ids' ],
  312. 'brand_id' => $data[ 'brand_id' ],//品牌id
  313. 'brand_name' => $brand_name,//品牌名称
  314. 'modify_time' => time(),
  315. 'virtual_sale' => $data[ 'virtual_sale' ],
  316. 'max_buy' => $data[ 'max_buy' ],
  317. 'min_buy' => $data[ 'min_buy' ],
  318. 'recommend_way' => $data[ 'recommend_way' ],
  319. 'qr_id' => isset($data[ 'qr_id' ]) ? $data[ 'qr_id' ] : 0,
  320. 'template_id' => isset($data[ 'template_id' ]) ? $data[ 'template_id' ] : 0,
  321. 'form_id' => $data[ 'form_id' ] ?? 0,
  322. 'sale_channel' => $data[ 'sale_channel' ] ?? 'all',
  323. 'sale_store' => $data[ 'sale_store' ] ?? 'all',
  324. 'is_unify_price' => $data[ 'is_unify_price' ] ?? 1,
  325. );
  326. model('goods')->update(array_merge($goods_data, $common_data), [ [ 'goods_id', '=', $goods_id ], [ 'goods_class', '=', $this->goods_class[ 'id' ] ] ]);
  327. $goods_stock = 0;
  328. $goods_stock_model = new \app\model\stock\GoodsStock();
  329. $sku_stock_list = [];
  330. if (!empty($data[ 'goods_sku_data' ][ 0 ][ 'sku_id' ])) {
  331. if ($data[ 'spec_type_status' ] == 1) {
  332. model('goods_sku')->delete([ [ 'goods_id', '=', $goods_id ] ]);
  333. $sku_arr = array ();
  334. //添加sku商品
  335. foreach ($data[ 'goods_sku_data' ] as $item) {
  336. $goods_stock += $item[ 'stock' ];
  337. $sku_data = array (
  338. 'sku_name' => $data[ 'goods_name' ] . ' ' . $item[ 'spec_name' ],
  339. 'spec_name' => $item[ 'spec_name' ],
  340. 'sku_no' => $item[ 'sku_no' ],
  341. 'sku_spec_format' => !empty($item[ 'sku_spec_format' ]) ? json_encode($item[ 'sku_spec_format' ]) : "",
  342. 'price' => $item[ 'price' ],
  343. 'market_price' => $item[ 'market_price' ],
  344. 'cost_price' => $item[ 'cost_price' ],
  345. 'discount_price' => $item[ 'price' ],//sku折扣价(默认等于单价)
  346. // 'stock' => $item[ 'stock' ],
  347. 'stock_alarm' => $item[ 'stock_alarm' ],
  348. 'sku_image' => !empty($item[ 'sku_image' ]) ? $item[ 'sku_image' ] : $first_image,
  349. 'sku_images' => $item[ 'sku_images' ],
  350. 'goods_id' => $goods_id,
  351. 'is_default' => $item[ 'is_default' ] ?? 0,
  352. 'is_consume_discount' => $data[ 'is_consume_discount' ],
  353. );
  354. $sku_arr[] = array_merge($sku_data, $common_data);
  355. $sku_stock_list[] = [ 'stock' => $item[ 'stock' ], 'site_id' => $data[ 'site_id' ], 'goods_class' => $common_data[ 'goods_class' ] ];
  356. }
  357. model('goods_sku')->addList($sku_arr);
  358. $sku_list = model('goods_sku')->getList([ 'goods_id' => $goods_id ], 'sku_id');
  359. foreach ($sku_stock_list as $k => $v) {
  360. $sku_stock_list[ $k ][ 'sku_id' ] = $sku_list[ $k ][ 'sku_id' ];
  361. }
  362. } else {
  363. $discount_model = new Discount();
  364. $sku_id_arr = [];
  365. foreach ($data[ 'goods_sku_data' ] as $item) {
  366. $discount_info = [];
  367. if (!empty($item[ 'sku_id' ])) {
  368. $discount_info_result = $discount_model->getDiscountGoodsInfo([ [ 'pdg.sku_id', '=', $item[ 'sku_id' ] ], [ 'pd.status', '=', 1 ] ], 'id');
  369. $discount_info = $discount_info_result[ 'data' ];
  370. }
  371. $goods_stock += $item[ 'stock' ];
  372. $sku_data = array (
  373. 'sku_name' => $data[ 'goods_name' ] . ' ' . $item[ 'spec_name' ],
  374. 'spec_name' => $item[ 'spec_name' ],
  375. 'sku_no' => $item[ 'sku_no' ],
  376. 'sku_spec_format' => !empty($item[ 'sku_spec_format' ]) ? json_encode($item[ 'sku_spec_format' ]) : "",
  377. 'price' => $item[ 'price' ],
  378. 'market_price' => $item[ 'market_price' ],
  379. 'cost_price' => $item[ 'cost_price' ],
  380. // 'stock' => $item[ 'stock' ],
  381. 'stock_alarm' => $item[ 'stock_alarm' ],
  382. 'sku_image' => !empty($item[ 'sku_image' ]) ? $item[ 'sku_image' ] : $first_image,
  383. 'sku_images' => $item[ 'sku_images' ],
  384. 'goods_id' => $goods_id,
  385. 'is_default' => $item[ 'is_default' ] ?? 0,
  386. 'is_consume_discount' => $data[ 'is_consume_discount' ]
  387. );
  388. if (empty($discount_info)) {
  389. $sku_data[ 'discount_price' ] = $item[ 'price' ];
  390. }
  391. if (!empty($item[ 'sku_id' ])) {
  392. $sku_id_arr[] = $item[ 'sku_id' ];
  393. model('goods_sku')->update(array_merge($sku_data, $common_data), [ [ 'sku_id', '=', $item[ 'sku_id' ] ], [ 'goods_class', '=', $this->goods_class[ 'id' ] ] ]);
  394. } else {
  395. $sku_id = model('goods_sku')->add(array_merge($sku_data, $common_data));
  396. $item[ 'sku_id' ] = $sku_id;
  397. $sku_id_arr[] = $sku_id;
  398. }
  399. $sku_stock_list[] = [ 'stock' => $item[ 'stock' ], 'sku_id' => $item[ 'sku_id' ], 'site_id' => $data[ 'site_id' ], 'goods_class' => $common_data[ 'goods_class' ] ];
  400. }
  401. // 移除不存在的商品SKU
  402. $sku_id_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ] ], 'sku_id');
  403. $sku_id_list = array_column($sku_id_list, 'sku_id');
  404. foreach ($sku_id_list as $k => $v) {
  405. foreach ($sku_id_arr as $ck => $cv) {
  406. if ($v == $cv) {
  407. unset($sku_id_list[ $k ]);
  408. }
  409. }
  410. }
  411. $sku_id_list = array_values($sku_id_list);
  412. if (!empty($sku_id_list)) {
  413. model('goods_sku')->delete([ [ 'sku_id', 'in', implode(",", $sku_id_list) ] ]);
  414. }
  415. }
  416. } else {
  417. model('goods_sku')->delete([ [ 'goods_id', '=', $goods_id ] ]);
  418. $sku_arr = array ();
  419. //添加sku商品
  420. foreach ($data[ 'goods_sku_data' ] as $item) {
  421. $goods_stock += $item[ 'stock' ];
  422. $sku_data = array (
  423. 'sku_name' => $data[ 'goods_name' ] . ' ' . $item[ 'spec_name' ],
  424. 'spec_name' => $item[ 'spec_name' ],
  425. 'sku_no' => $item[ 'sku_no' ],
  426. 'sku_spec_format' => !empty($item[ 'sku_spec_format' ]) ? json_encode($item[ 'sku_spec_format' ]) : "",
  427. 'price' => $item[ 'price' ],
  428. 'market_price' => $item[ 'market_price' ],
  429. 'cost_price' => $item[ 'cost_price' ],
  430. 'discount_price' => $item[ 'price' ],//sku折扣价(默认等于单价)
  431. // 'stock' => $item[ 'stock' ],
  432. 'stock_alarm' => $item[ 'stock_alarm' ],
  433. 'sku_image' => !empty($item[ 'sku_image' ]) ? $item[ 'sku_image' ] : $first_image,
  434. 'sku_images' => $item[ 'sku_images' ],
  435. 'goods_id' => $goods_id,
  436. 'is_default' => $item[ 'is_default' ] ?? 0,
  437. 'is_consume_discount' => $data[ 'is_consume_discount' ]
  438. );
  439. $sku_arr[] = array_merge($sku_data, $common_data);
  440. $sku_stock_list[] = [ 'stock' => $item[ 'stock' ], 'site_id' => $data[ 'site_id' ], 'goods_class' => $common_data[ 'goods_class' ] ];
  441. }
  442. model('goods_sku')->addList($sku_arr);
  443. $sku_list = model('goods_sku')->getList([ 'goods_id' => $goods_id ], 'sku_id');
  444. foreach ($sku_stock_list as $k => $v) {
  445. $sku_stock_list[ $k ][ 'sku_id' ] = $sku_list[ $k ][ 'sku_id' ];
  446. }
  447. }
  448. // 赋值第一个商品sku_id
  449. $first_info = model('goods_sku')->getFirstData([ 'goods_id' => $goods_id ], 'sku_id', 'is_default desc,sku_id asc');
  450. model('goods')->update([ 'sku_id' => $first_info[ 'sku_id' ] ], [ [ 'goods_id', '=', $goods_id ] ]);
  451. if (!empty($data[ 'goods_spec_format' ])) {
  452. // 刷新SKU商品规格项 / 规格值JSON字符串
  453. $this->dealGoodsSkuSpecFormat($goods_id, $data[ 'goods_spec_format' ]);
  454. }
  455. // 编辑商品卡项表
  456. model('goods_card')->update([
  457. 'renew_price' => $data[ 'renew_price' ],
  458. 'recharge_money' => $data[ 'recharge_money' ] ?? 0,
  459. 'common_num' => $data[ 'common_num' ],
  460. 'discount_goods_type' => $data[ 'discount_goods_type' ],
  461. 'discount' => $data[ 'discount' ],
  462. 'validity_type' => $data[ 'validity_type' ],
  463. 'validity_day' => $data[ 'validity_day' ] ?? 0,
  464. 'validity_time' => $data[ 'validity_time' ] ?? 0,
  465. ], [ [ 'goods_id', '=', $goods_id ] ]);
  466. // 添加商品卡项项目表
  467. model('goods_card_item')->delete([ [ 'card_goods_id', '=', $goods_id ] ]);
  468. $relation_goods = json_decode($data[ 'relation_goods' ], true);
  469. if (!empty($relation_goods)) {
  470. $goods_card_item = [];
  471. foreach ($relation_goods as $item) {
  472. array_push($goods_card_item, [
  473. 'site_id' => $data[ 'site_id' ],
  474. 'card_goods_id' => $goods_id,
  475. 'goods_id' => $item[ 'goods_id' ],
  476. 'sku_id' => $item[ 'sku_id' ],
  477. 'num' => $item[ 'num' ] ?? 0,
  478. 'discount' => $item[ 'discount' ] ?? 0,
  479. ]);
  480. }
  481. model('goods_card_item')->addList($goods_card_item);
  482. }
  483. $cron = new Cron();
  484. $cron->deleteCron([ [ 'event', '=', 'CronGoodsTimerOn' ], [ 'relate_id', '=', $goods_id ] ]);
  485. $cron->deleteCron([ [ 'event', '=', 'CronGoodsTimerOff' ], [ 'relate_id', '=', $goods_id ] ]);
  486. //定时上下架
  487. if ($goods_data[ 'timer_on' ] > 0) {
  488. $cron->addCron(1, 0, "商品定时上架", "CronGoodsTimerOn", $goods_data[ 'timer_on' ], $goods_id);
  489. }
  490. if ($goods_data[ 'timer_off' ] > 0) {
  491. $cron->addCron(1, 0, "商品定时下架", "CronGoodsTimerOff", $goods_data[ 'timer_off' ], $goods_id);
  492. }
  493. // 商品设置库存
  494. foreach ($sku_stock_list as $k => $v) {
  495. $goods_stock_model->changeGoodsStock($v);
  496. }
  497. //同步商品成本价
  498. ( new StoreGoods() )->setSkuPrice([ 'goods_id' => $goods_id, 'site_id' => $data[ 'site_id' ] ]);
  499. model('goods')->commit();
  500. return $this->success($goods_id);
  501. } catch (\Exception $e) {
  502. model('goods')->rollback();
  503. return $this->error($e->getMessage() . $e->getFile() . $e->getLine());
  504. }
  505. }
  506. /**
  507. * 获取商品信息
  508. * @param array $condition
  509. * @param string $field
  510. */
  511. public function getGoodsInfo($condition, $field = 'goods_id,goods_name,goods_class,goods_class_name,goods_attr_class,goods_attr_name,goods_image,goods_content,goods_state,price,market_price,cost_price,goods_stock,goods_stock_alarm,goods_spec_format,goods_attr_format,introduction,keywords,unit,sort,video_url,evaluate,virtual_indate')
  512. {
  513. $info = model('goods')->getInfo($condition, $field);
  514. if (!empty($info)) {
  515. if (isset($info[ 'goods_stock' ])) {
  516. $info[ 'goods_stock' ] = numberFormat($info[ 'goods_stock' ]);
  517. }
  518. if (isset($info[ 'sale_num' ])) {
  519. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  520. }
  521. if (isset($info[ 'virtual_sale' ])) {
  522. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  523. }
  524. if (isset($info[ 'real_stock' ])) {
  525. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  526. }
  527. }
  528. return $this->success($info);
  529. }
  530. /**
  531. * 获取商品信息
  532. * @param array $condition
  533. * @param string $field
  534. */
  535. public function editGetGoodsInfo($data)
  536. {
  537. $condition = [
  538. [ 'g.goods_id', '=', $data[ 'goods_id' ] ],
  539. [ 'g.site_id', '=', $data[ 'site_id' ] ]
  540. ];
  541. $join = [
  542. [ 'goods_card gc', 'g.goods_id = gc.goods_id', 'inner' ]
  543. ];
  544. $field = 'g.*,gc.card_type,gc.renew_price,gc.recharge_money,gc.common_num,gc.discount_goods_type,gc.discount,gc.validity_type,gc.validity_day,gc.validity_time';
  545. $info = model('goods')->getInfo($condition, $field, 'g', $join);
  546. if (!empty($info)) {
  547. if (isset($info[ 'goods_stock' ])) {
  548. $info[ 'goods_stock' ] = numberFormat($info[ 'goods_stock' ]);
  549. }
  550. if (isset($info[ 'sale_num' ])) {
  551. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  552. }
  553. if (isset($info[ 'virtual_sale' ])) {
  554. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  555. }
  556. if (isset($info[ 'real_stock' ])) {
  557. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  558. }
  559. $info[ 'relation_goods' ] = model('goods_card_item')->getList([
  560. [ 'gci.card_goods_id', '=', $data[ 'goods_id' ] ]
  561. ], 'gci.goods_id,gci.sku_id,gci.num,gci.discount,gs.sku_name,gs.price,gs.sku_image,gs.goods_class_name', 'id asc', 'gci', [
  562. [ 'goods_sku gs', 'gs.sku_id = gci.sku_id', 'inner' ]
  563. ]);
  564. return $this->success($info);
  565. }
  566. return $this->error();
  567. }
  568. /**
  569. * 获取商品详情
  570. * @param $goods_id
  571. * @return array
  572. */
  573. public function getGoodsDetail($goods_id, $site_id)
  574. {
  575. $info = model('goods')->getInfo([ [ 'is_delete', '=', 0 ], [ 'goods_id', '=', $goods_id ], [ 'site_id', '=', $site_id ], [ 'goods_class', '=', 3 ] ], "*");
  576. $field = 'sku_id, sku_name,spec_name, sku_no, sku_spec_format, price, market_price, cost_price, discount_price, stock,
  577. weight, volume, sku_image, sku_images, sort,member_price,fenxiao_price';
  578. $sku_data = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ] ], $field);
  579. if (!empty($sku_data)) {
  580. foreach ($sku_data as $k => $v) {
  581. $sku_data[ $k ][ 'member_price' ] = $v[ 'member_price' ] == '' ? '' : json_decode($v[ 'member_price' ], true);
  582. if (isset($v[ 'stock' ])) {
  583. $sku_data[ $k ][ 'stock' ] = numberFormat($sku_data[ $k ][ 'stock' ]);
  584. }
  585. }
  586. }
  587. if (!empty($info)) {
  588. if (isset($info[ 'goods_stock' ])) {
  589. $info[ 'goods_stock' ] = numberFormat($info[ 'goods_stock' ]);
  590. }
  591. if (isset($info[ 'sale_num' ])) {
  592. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  593. }
  594. if (isset($info[ 'virtual_sale' ])) {
  595. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  596. }
  597. if (isset($info[ 'real_stock' ])) {
  598. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  599. }
  600. $info[ 'sku_data' ] = $sku_data;
  601. }
  602. return $this->success($info);
  603. }
  604. /**
  605. * 获取商品列表
  606. * @param array $condition
  607. * @param string $field
  608. * @param string $order
  609. * @param string $limit
  610. */
  611. public function getGoodsList($condition = [], $field = 'goods_id,goods_class,goods_class_name,goods_attr_name,goods_name,site_id,,sort,goods_image,goods_content,goods_state,price,market_price,cost_price,goods_stock,goods_stock_alarm,is_virtual,goods_spec_format,goods_attr_format,create_time', $order = 'create_time desc', $alias = '', $join = [], $limit = null)
  612. {
  613. $list = model('goods')->getList($condition, $field, $order, $alias, $join, '', $limit);
  614. if (!empty($list)) {
  615. foreach ($list as $k => $v) {
  616. if (isset($v[ 'goods_stock' ])) {
  617. $list[ $k ][ 'goods_stock' ] = numberFormat($list[ $k ][ 'goods_stock' ]);
  618. }
  619. if (isset($v[ 'sale_num' ])) {
  620. $list[ $k ][ 'sale_num' ] = numberFormat($list[ $k ][ 'sale_num' ]);
  621. }
  622. if (isset($v[ 'virtual_sale' ])) {
  623. $list[ $k ][ 'virtual_sale' ] = numberFormat($list[ $k ][ 'virtual_sale' ]);
  624. }
  625. if (isset($v[ 'real_stock' ])) {
  626. $list[ $k ][ 'real_stock' ] = numberFormat($list[ $k ][ 'real_stock' ]);
  627. }
  628. }
  629. }
  630. return $this->success($list);
  631. }
  632. /**
  633. * 刷新SKU商品规格项/规格值JSON字符串
  634. * @param int $goods_id 商品id
  635. * @param string $goods_spec_format 商品完整规格项/规格值json
  636. */
  637. private function dealGoodsSkuSpecFormat($goods_id, $goods_spec_format)
  638. {
  639. if (empty($goods_spec_format)) return;
  640. $goods_spec_format = json_decode($goods_spec_format, true);
  641. //根据goods_id查询sku商品列表,查询:sku_id、sku_spec_format 列
  642. $sku_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ], [ 'sku_spec_format', '<>', '' ] ], 'sku_id,sku_spec_format', 'sku_id asc');
  643. if (!empty($sku_list)) {
  644. // $temp = 0;//测试性能,勿删
  645. //循环SKU商品列表
  646. foreach ($sku_list as $k => $v) {
  647. // $temp++;
  648. $sku_format = $goods_spec_format;//最终要存储的值
  649. $current_format = json_decode($v[ 'sku_spec_format' ], true);//当前SKU商品规格值json
  650. $selected_data = [];//已选规格/规格值json
  651. //1、找出已选规格/规格值json
  652. //循环完整商品规格json
  653. foreach ($sku_format as $sku_k => $sku_v) {
  654. // $temp++;
  655. //循环当前SKU商品规格json
  656. foreach ($current_format as $current_k => $current_v) {
  657. // $temp++;
  658. //匹配规格项
  659. if ($current_v[ 'spec_id' ] == $sku_v[ 'spec_id' ]) {
  660. //循环规格值
  661. foreach ($sku_v[ 'value' ] as $sku_value_k => $sku_value_v) {
  662. // $temp++;
  663. //匹配规格值id
  664. if ($current_v[ 'spec_value_id' ] == $sku_value_v[ 'spec_value_id' ]) {
  665. $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'selected' ] = true;
  666. $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'sku_id' ] = $v[ 'sku_id' ];
  667. $selected_data[] = $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ];
  668. break;
  669. }
  670. }
  671. }
  672. }
  673. }
  674. //2、找出未选中的规格/规格值json
  675. foreach ($sku_format as $sku_k => $sku_v) {
  676. // $temp++;
  677. foreach ($sku_v[ 'value' ] as $sku_value_k => $sku_value_v) {
  678. // $temp++;
  679. if (!isset($sku_value_v[ 'selected' ])) {
  680. $refer_data = [];//参考已选中的规格/规格值json
  681. $refer_data[] = $sku_value_v;
  682. // 根据已选中的规格值进行参考
  683. foreach ($selected_data as $selected_k => $selected_v) {
  684. // $temp++;
  685. // 排除自身,然后进行参考
  686. if ($selected_v[ 'spec_id' ] != $sku_value_v[ 'spec_id' ]) {
  687. $refer_data[] = $selected_v;
  688. }
  689. }
  690. foreach ($sku_list as $again_k => $again_v) {
  691. // $temp++;
  692. //排除当前SKU商品
  693. if ($again_v[ 'sku_id' ] != $v[ 'sku_id' ]) {
  694. $current_format_again = json_decode($again_v[ 'sku_spec_format' ], true);
  695. $count = count($current_format_again);//规格总数量
  696. $curr_count = 0;//当前匹配规格数量
  697. //循环当前SKU商品规格json
  698. foreach ($current_format_again as $current_again_k => $current_again_v) {
  699. // $temp++;
  700. foreach ($refer_data as $fan_k => $fan_v) {
  701. // $temp++;
  702. if ($current_again_v[ 'spec_value_id' ] == $fan_v[ 'spec_value_id' ]) {
  703. $curr_count++;
  704. }
  705. }
  706. }
  707. // 匹配数量跟规格总数一致表示匹配成功
  708. if ($curr_count == $count) {
  709. $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'selected' ] = false;
  710. $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'sku_id' ] = $again_v[ 'sku_id' ];
  711. break;
  712. }
  713. }
  714. }
  715. //没有匹配到规格值,则禁用
  716. if (!isset($sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'selected' ])) {
  717. $sku_format[ $sku_k ][ 'value' ][ $sku_value_k ][ 'disabled' ] = false;
  718. }
  719. }
  720. }
  721. }
  722. // var_dump($sku_format);
  723. // var_dump("=========");
  724. //修改ns_goods_sku表表中的goods_spec_format字段,将$sku_format值传入
  725. model('goods_sku')->update([ 'goods_spec_format' => json_encode($sku_format) ], [ [ 'sku_id', '=', $v[ 'sku_id' ] ] ]);
  726. }
  727. // var_dump("性能:" . $temp);
  728. }
  729. }
  730. /************************************************************************* 购买的虚拟产品 start *******************************************************************/
  731. /**
  732. * 生成购买的虚拟产品
  733. * @param $site_id
  734. * @param $order_id
  735. * @param $order_no
  736. * @param $sku_id
  737. * @param $sku_name
  738. * @param $code
  739. * @param $member_id
  740. * @param $sku_image
  741. */
  742. public function addGoodsVirtual($site_id, $goods_id, $sku_id, $data)
  743. {
  744. if (is_array($data) && count($data)) {
  745. $virtual_goods = [];
  746. foreach ($data as $carmichael_item) {
  747. $carmichael_item = htmlspecialchars(addslashes($carmichael_item));
  748. $card = explode(' ', $carmichael_item);
  749. $card_arr = [
  750. 'cardno' => $card[ 0 ] ?? '',
  751. 'password' => $card[ 1 ] ?? ''
  752. ];
  753. array_push($virtual_goods, [
  754. 'site_id' => $site_id,
  755. 'sku_id' => $sku_id,
  756. 'card_info' => json_encode($card_arr),
  757. 'goods_id' => $goods_id
  758. ]);
  759. }
  760. model("goods_virtual")->startTrans();
  761. try {
  762. $res = model("goods_virtual")->addList($virtual_goods);
  763. model('goods')->setInc([ [ 'goods_id', '=', $goods_id ], [ 'site_id', '=', $site_id ] ], 'goods_stock', count($virtual_goods)); // 增加商品总库存
  764. model('goods_sku')->setInc([ [ 'sku_id', '=', $sku_id ], [ 'site_id', '=', $site_id ] ], 'stock', count($virtual_goods)); // 增加sku库存
  765. model("goods_virtual")->commit();
  766. return $this->success($res);
  767. } catch (\Exception $e) {
  768. model("goods_virtual")->rollback();
  769. return $this->error('', $e->getMessage());
  770. }
  771. } else {
  772. return $this->error('', '请输入要添加的卡密数据');
  773. }
  774. }
  775. /************************************************************************* 购买的虚拟产品 end *******************************************************************/
  776. /**
  777. * 从excel中读取卡密数据
  778. * @param $path
  779. */
  780. public function importData($path)
  781. {
  782. $PHPReader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx');
  783. //载入文件
  784. $PHPExcel = $PHPReader->load($path);
  785. //获取表中的第一个工作表,如果要获取第二个,把0改为1,依次类推
  786. $currentSheet = $PHPExcel->getSheet(0);
  787. //获取总行数
  788. $allRow = $currentSheet->getHighestRow();
  789. if ($allRow < 2) {
  790. return $this->error('', '导入了一个空文件');
  791. }
  792. $data = [];
  793. for ($i = 2; $i <= $allRow; $i++) {
  794. //卡号
  795. $cardno = $PHPExcel->getActiveSheet()->getCell('A' . $i)->getValue();
  796. //卡号
  797. $password = $PHPExcel->getActiveSheet()->getCell('B' . $i)->getValue();
  798. array_push($data, $cardno . ' ' . $password);
  799. }
  800. return $this->success(implode("\n", $data));
  801. }
  802. /**
  803. * 商品导入
  804. * @param $goods_data
  805. * @param $site_id
  806. * @return array
  807. */
  808. public function importGoods($goods_data, $site_id)
  809. {
  810. try {
  811. if (empty($goods_data[ 'goods_name' ])) return $this->error('', '商品名称不能为空');
  812. if (empty($goods_data[ 'goods_image' ])) return $this->error('', '商品主图不能为空');
  813. if (empty($goods_data[ 'category_1' ]) && empty($goods_data[ 'category_2' ]) && empty($goods_data[ 'category_3' ])) return $this->error('', '商品分类不能为空');
  814. // 处理商品分类
  815. $category_id = '';
  816. $category_json = [];
  817. if (!empty($goods_data[ 'category_3' ])) {
  818. $category_info = model('goods_category')->getInfo([ [ 'level', '=', 3 ], [ 'site_id', '=', $site_id ], [ 'category_full_name', '=', "{$goods_data['category_1']}/{$goods_data['category_2']}/{$goods_data['category_3']}" ] ], 'category_id_1,category_id_2,category_id_3');
  819. if (!empty($category_info)) {
  820. $category_id = "{$category_info['category_id_1']},{$category_info['category_id_2']},{$category_info['category_id_3']}";
  821. }
  822. }
  823. if (!empty($goods_data[ 'category_2' ]) && empty($category_id)) {
  824. $category_info = model('goods_category')->getInfo([ [ 'level', '=', 2 ], [ 'site_id', '=', $site_id ], [ 'category_full_name', '=', "{$goods_data['category_1']}/{$goods_data['category_2']}" ] ], 'category_id_1,category_id_2');
  825. if (!empty($category_info)) {
  826. $category_id = "{$category_info['category_id_1']},{$category_info['category_id_2']}";
  827. }
  828. }
  829. if (!empty($goods_data[ 'category_1' ]) && empty($category_id)) {
  830. $category_info = model('goods_category')->getInfo([ [ 'level', '=', 1 ], [ 'site_id', '=', $site_id ], [ 'category_name', '=', "{$goods_data['category_1']}" ] ], 'category_id_1');
  831. if (!empty($category_info)) {
  832. $category_id = "{$category_info['category_id_1']}";
  833. }
  834. }
  835. if (empty($category_id)) return $this->error('', '未找到所填商品分类');
  836. $category_json = [ $category_id ];
  837. $sku_data = [];
  838. $goods_spec_format = [];
  839. $tag = 0;
  840. // 处理sku数据
  841. if (isset($goods_data[ 'sku' ])) {
  842. foreach ($goods_data[ 'sku' ] as $sku_item) {
  843. if (empty($sku_item[ 'sku_data' ])) return $this->error('', '规格数据不能为空');
  844. $spec_name = '';
  845. $spec_data = explode(';', $sku_item[ 'sku_data' ]);
  846. $sku_spec_format = [];
  847. foreach ($spec_data as $item) {
  848. $spec_item = explode(':', $item);
  849. $spec_name .= ' ' . $spec_item[ 1 ];
  850. // 规格项
  851. $spec_index = array_search($spec_item[ 0 ], array_column($goods_spec_format, 'spec_name'));
  852. if (empty($goods_spec_format) || $spec_index === false) {
  853. $spec = [
  854. 'spec_id' => -( $tag + getMillisecond() ),
  855. 'spec_name' => $spec_item[ 0 ],
  856. 'value' => []
  857. ];
  858. array_push($goods_spec_format, $spec);
  859. $tag++;
  860. } else {
  861. $spec = $goods_spec_format[ $spec_index ];
  862. }
  863. // 规格值
  864. $spec_index = array_search($spec_item[ 0 ], array_column($goods_spec_format, 'spec_name'));
  865. $spec_value_index = array_search($spec_item[ 1 ], array_column($spec[ 'value' ], 'spec_value_name'));
  866. if (empty($spec[ 'value' ]) || $spec_value_index === false) {
  867. $spec_value = [
  868. 'spec_id' => $spec[ 'spec_id' ],
  869. 'spec_name' => $spec[ 'spec_name' ],
  870. 'spec_value_id' => -( $tag + getMillisecond() ),
  871. 'spec_value_name' => $spec_item[ 1 ],
  872. 'image' => '',
  873. ];
  874. array_push($goods_spec_format[ $spec_index ][ 'value' ], $spec_value);
  875. $tag++;
  876. } else {
  877. $spec_value = $spec[ 'value' ][ $spec_value_index ];
  878. }
  879. array_push($sku_spec_format, [
  880. 'spec_id' => $spec[ 'spec_id' ],
  881. 'spec_name' => $spec[ 'spec_name' ],
  882. 'spec_value_id' => $spec_value[ 'spec_value_id' ],
  883. 'spec_value_name' => $spec_value[ 'spec_value_name' ],
  884. 'image' => '',
  885. ]);
  886. }
  887. $sku_images_arr = explode(',', $sku_item[ 'sku_image' ]);
  888. $sku_temp = [
  889. 'spec_name' => trim($spec_name),
  890. 'sku_no' => $sku_item[ 'sku_code' ],
  891. 'sku_spec_format' => $sku_spec_format,
  892. 'price' => $sku_item[ 'price' ],
  893. 'market_price' => $sku_item[ 'market_price' ],
  894. 'cost_price' => $sku_item[ 'cost_price' ],
  895. 'stock_alarm' => $sku_item[ 'stock_alarm' ],
  896. 'sku_image' => empty($sku_item[ 'sku_image' ]) ? '' : $sku_images_arr[ 0 ],
  897. 'sku_images' => empty($sku_item[ 'sku_image' ]) ? '' : $sku_item[ 'sku_image' ],
  898. 'sku_images_arr' => empty($sku_item[ 'sku_image' ]) ? [] : $sku_images_arr,
  899. 'is_default' => 0,
  900. 'carmichael' => empty($sku_item[ 'carmichael' ]) ? [] : explode("\n", $sku_item[ 'carmichael' ])
  901. ];
  902. array_push($sku_data, $sku_temp);
  903. }
  904. } else {
  905. $goods_img = explode(',', $goods_data[ 'goods_image' ]);
  906. $sku_data = [
  907. [
  908. 'sku_id' => 0,
  909. 'sku_name' => $goods_data[ 'goods_name' ],
  910. 'spec_name' => '',
  911. 'sku_spec_format' => '',
  912. 'price' => empty($goods_data[ 'price' ]) ? 0 : $goods_data[ 'price' ],
  913. 'market_price' => empty($goods_data[ 'market_price' ]) ? 0 : $goods_data[ 'market_price' ],
  914. 'cost_price' => empty($goods_data[ 'cost_price' ]) ? 0 : $goods_data[ 'cost_price' ],
  915. 'sku_no' => $goods_data[ 'goods_code' ],
  916. 'stock_alarm' => empty($goods_data[ 'stock_alarm' ]) ? 0 : $goods_data[ 'stock_alarm' ],
  917. 'sku_image' => $goods_img[ 0 ],
  918. 'sku_images' => $goods_data[ 'goods_image' ],
  919. 'carmichael' => empty($goods_data[ 'carmichael' ]) ? [] : explode("\n", $goods_data[ 'carmichael' ])
  920. ]
  921. ];
  922. }
  923. if (count($goods_spec_format) > 4) return $this->error('', '最多支持四种规格项');
  924. $data = [
  925. 'goods_name' => $goods_data[ 'goods_name' ],// 商品名称,
  926. 'goods_attr_class' => '',// 商品类型id,
  927. 'goods_attr_name' => '',// 商品类型名称,
  928. 'site_id' => $site_id,
  929. 'category_id' => ',' . $category_id . ',',
  930. 'category_json' => json_encode($category_json),
  931. 'goods_image' => $goods_data[ 'goods_image' ],// 商品主图路径
  932. 'goods_content' => '',// 商品详情
  933. 'goods_state' => 0, //$goods_data['goods_state'] == 1 || $goods_data['goods_state'] == '是' ? 1 : 0,// 商品状态(1.正常0下架)
  934. 'price' => empty($goods_data[ 'price' ]) ? 0 : $goods_data[ 'price' ],// 商品价格(取第一个sku)
  935. 'market_price' => empty($goods_data[ 'market_price' ]) ? 0 : $goods_data[ 'market_price' ],// 市场价格(取第一个sku)
  936. 'cost_price' => empty($goods_data[ 'cost_price' ]) ? 0 : $goods_data[ 'cost_price' ],// 成本价(取第一个sku)
  937. 'sku_no' => $goods_data[ 'goods_code' ],// 商品sku编码
  938. 'goods_stock_alarm' => empty($goods_data[ 'goods_stock_alarm' ]) ? 0 : $goods_data[ 'goods_stock_alarm' ],// 库存预警
  939. 'goods_spec_format' => empty($goods_spec_format) ? '' : json_encode($goods_spec_format, JSON_UNESCAPED_UNICODE),// 商品规格格式
  940. 'goods_attr_format' => '',// 商品参数格式
  941. 'introduction' => $goods_data[ 'introduction' ],// 促销语
  942. 'keywords' => $goods_data[ 'keywords' ],// 关键词
  943. 'unit' => $goods_data[ 'unit' ],// 单位
  944. 'sort' => '',// 排序,
  945. 'qr_id' => empty($goods_data[ 'qr_id' ]) ? 0 : $goods_data[ 'qr_id' ],// 社群二维码id
  946. 'template_id' => empty($goods_data[ 'template_id' ]) ? 0 : $goods_data[ 'template_id' ],// 海报id
  947. 'is_limit' => empty($goods_data[ 'is_limit' ]) ? 0 : $goods_data[ 'is_limit' ],// 是否限购
  948. 'limit_type' => empty($goods_data[ 'limit_type' ]) ? 0 : $goods_data[ 'limit_type' ],// 限购类型
  949. 'video_url' => '',// 视频
  950. 'goods_sku_data' => json_encode($sku_data, JSON_UNESCAPED_UNICODE),// SKU商品数据
  951. 'goods_service_ids' => '',// 商品服务id集合
  952. 'label_id' => '',// 商品分组id
  953. 'virtual_sale' => 0,// 虚拟销量
  954. 'max_buy' => 0,// 限购
  955. 'min_buy' => 0,// 起售
  956. 'recommend_way' => 0, // 推荐方式,1:新品,2:精品,3;推荐
  957. 'timer_on' => 0,//定时上架
  958. 'timer_off' => 0,//定时下架
  959. 'brand_id' => 0,
  960. 'is_consume_discount' => $goods_data[ 'is_consume_discount' ] == 1 || $goods_data[ 'is_consume_discount' ] == '是' ? 1 : 0, //是否参与会员折扣
  961. ];
  962. $res = $this->addGoods($data);
  963. return $res;
  964. } catch (\Exception $e) {
  965. return $this->error('', $e->getMessage());
  966. }
  967. }
  968. /**
  969. * 卡 详情
  970. * @param $sku_id
  971. * @param $site_id
  972. * @param string $field
  973. * @return array
  974. */
  975. public function getGoodsSkuDetail($sku_id, $site_id, $field = '')
  976. {
  977. $condition = [ [ 'gs.sku_id', '=', $sku_id ], [ 'gs.site_id', '=', $site_id ], [ 'gs.is_delete', '=', 0 ], [ 'g.goods_class', '=', $this->getGoodsClass()[ 'id' ] ] ];
  978. if (empty($field)) {
  979. $field = 'gs.goods_id,gs.sku_id,gs.qr_id,gs.goods_name,gs.sku_name,gs.sku_spec_format,gs.price,gs.market_price,gs.discount_price,gs.promotion_type,gs.start_time
  980. ,gs.end_time,gs.stock,gs.click_num,(g.sale_num + g.virtual_sale) as sale_num,gs.collect_num,gs.sku_image,gs.sku_images
  981. ,gc.card_type,gc.card_type_name,gc.renew_price,gc.recharge_money,gc.common_num,gc.discount_goods_type,gc.discount,gc.validity_type,gc.validity_day,gc.validity_time
  982. ,gs.goods_content,gs.goods_state,gs.is_free_shipping,gs.goods_spec_format,gs.goods_attr_format,gs.introduction,gs.unit,gs.video_url
  983. ,gs.is_virtual,gs.goods_service_ids,gs.max_buy,gs.min_buy,gs.is_limit,gs.limit_type,gs.support_trade_type,g.goods_image,g.keywords,g.stock_show,g.sale_show,g.market_price_show,g.barrage_show,g.evaluate';
  984. }
  985. $join = [
  986. [ 'goods g', 'g.goods_id = gs.goods_id', 'inner' ],
  987. [ 'goods_card gc', 'gc.goods_id=gs.goods_id', 'left' ],
  988. ];
  989. $info = model('goods_sku')->getInfo($condition, $field, 'gs', $join);
  990. if (!empty($info)) {
  991. if (isset($info[ 'stock' ])) {
  992. $info[ 'stock' ] = numberFormat($info[ 'stock' ]);
  993. }
  994. if (isset($info[ 'sale_num' ])) {
  995. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  996. }
  997. if (isset($info[ 'virtual_sale' ])) {
  998. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  999. }
  1000. if (isset($info[ 'real_stock' ])) {
  1001. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  1002. }
  1003. $info[ 'relation_goods' ] = model('goods_card_item')->getList([
  1004. [ 'gci.card_goods_id', '=', $info[ 'goods_id' ] ]
  1005. ], 'gci.goods_id,gci.sku_id,gci.num,gci.discount,gs.sku_name,gs.price,gs.sku_image,gs.goods_class_name', 'id asc', 'gci', [
  1006. [ 'goods_sku gs', 'gs.sku_id = gci.sku_id', 'inner' ]
  1007. ]);
  1008. }
  1009. return $this->success($info);
  1010. }
  1011. /**
  1012. * 查询规格信息
  1013. * @param $condition
  1014. * @param string $field
  1015. * @param string $alias
  1016. * @param array $join
  1017. * @return array
  1018. */
  1019. public function getGoodsSkuInfo($condition, $field = '*', $alias = 'a', $join = [])
  1020. {
  1021. $info = model('goods_sku')->getInfo($condition, $field, $alias, $join);
  1022. if (!empty($info)) {
  1023. if (isset($info[ 'stock' ])) {
  1024. $info[ 'stock' ] = numberFormat($info[ 'stock' ]);
  1025. }
  1026. if (isset($info[ 'sale_num' ])) {
  1027. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  1028. }
  1029. if (isset($info[ 'virtual_sale' ])) {
  1030. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  1031. }
  1032. if (isset($info[ 'real_stock' ])) {
  1033. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  1034. }
  1035. $info[ 'relation_goods' ] = model('goods_card_item')->getList([
  1036. [ 'gci.card_goods_id', '=', $info[ 'goods_id' ] ]
  1037. ], 'gci.goods_id,gci.sku_id,gci.num,gci.discount,gs.sku_name,gs.price,gs.sku_image,gs.goods_class_name', 'id asc', 'gci', [
  1038. [ 'goods_sku gs', 'gs.sku_id = gci.sku_id', 'inner' ]
  1039. ]);
  1040. return $this->success($info);
  1041. }
  1042. return $this->error();
  1043. }
  1044. /**
  1045. * 获取商品信息
  1046. * @param array $condition
  1047. * @param string $field
  1048. */
  1049. public function getGoodsCardDetail($goods_id, $site_id, $store_data = [])
  1050. {
  1051. $condition = [
  1052. [ 'g.goods_id', '=', $goods_id ],
  1053. [ 'g.site_id', '=', $site_id ]
  1054. ];
  1055. $join = [
  1056. [ 'goods_card gc', 'g.goods_id = gc.goods_id', 'inner' ]
  1057. ];
  1058. $field = 'g.*,gc.card_type,gc.renew_price,gc.recharge_money,gc.common_num,gc.discount_goods_type,gc.discount,gc.validity_type,gc.validity_day,gc.validity_time';
  1059. $info = model('goods')->getInfo($condition, $field, 'g', $join);
  1060. if (!empty($info)) {
  1061. if (isset($info[ 'goods_stock' ])) {
  1062. $info[ 'goods_stock' ] = numberFormat($info[ 'goods_stock' ]);
  1063. }
  1064. if (isset($info[ 'sale_num' ])) {
  1065. $info[ 'sale_num' ] = numberFormat($info[ 'sale_num' ]);
  1066. }
  1067. if (isset($info[ 'virtual_sale' ])) {
  1068. $info[ 'virtual_sale' ] = numberFormat($info[ 'virtual_sale' ]);
  1069. }
  1070. if (isset($info[ 'real_stock' ])) {
  1071. $info[ 'real_stock' ] = numberFormat($info[ 'real_stock' ]);
  1072. }
  1073. $sku_condition = [
  1074. [ 'gci.card_goods_id', '=', $goods_id ],
  1075. ];
  1076. $sku_field = 'gci.goods_id,gci.sku_id,gci.num,gci.discount,gs.sku_name,gs.price,gs.sku_image,gs.goods_class_name';
  1077. $sku_join = [ [ 'goods_sku gs', 'gs.sku_id = gci.sku_id', 'inner' ] ];
  1078. if (!empty($store_data) && $store_data[ 'config' ][ 'store_business' ] == 'store') {
  1079. $sku_join[] = [ 'store_goods_sku sgs', 'gs.sku_id = sgs.sku_id and sgs.store_id=' . $store_data[ 'store_info' ][ 'store_id' ], 'left' ];
  1080. $sku_field = str_replace('gs.price', 'IFNULL(IF(gs.is_unify_price = 1,gs.price,sgs.price), gs.price) as price', $sku_field);
  1081. }
  1082. $info[ 'relation_goods' ] = model('goods_card_item')->getList($sku_condition, $sku_field, 'gci.id asc', 'gci', $sku_join);
  1083. return $this->success($info);
  1084. }
  1085. return $this->error();
  1086. }
  1087. }