Goods.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 山西牛酷信息科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com.cn
  8. * 这不是一个自由软件!您只能在不用于商业目的的前提下对程序代码进行修改和使用。
  9. * 任何企业和个人不允许对程序代码以任何形式任何目的再发布。
  10. * =========================================================
  11. */
  12. namespace app\model\goods;
  13. use app\model\BaseModel;
  14. use app\model\system\Config as ConfigModel;
  15. use app\model\web\WebSite as WebsiteModel;
  16. use app\model\system\Stat;
  17. /**
  18. * 商品
  19. */
  20. class Goods extends BaseModel
  21. {
  22. private $goods_class = array( 'id' => 1, 'name' => '实物商品' );
  23. private $goods_state = array(
  24. 1 => '正常',
  25. 0 => '下架'
  26. );
  27. private $verify_state = array(
  28. 1 => '已审核',
  29. 0 => '待审核',
  30. -2 => '审核失败',
  31. 10 => '违规下架'
  32. );
  33. public function getGoodsState()
  34. {
  35. return $this->goods_state;
  36. }
  37. public function getVerifyState()
  38. {
  39. return $this->verify_state;
  40. }
  41. /**
  42. * 商品添加
  43. * @param $data
  44. */
  45. public function addGoods($data)
  46. {
  47. model('goods')->startTrans();
  48. try {
  49. //店铺信息
  50. $shop_info = model('shop')->getInfo([ [ 'site_id', '=', $data['site_id'] ] ], 'site_name, website_id, is_own,cert_id,shop_status');
  51. $goods_config = new Config();
  52. $goods_verify_config = $goods_config->getVerifyConfig();
  53. $goods_verify_config = $goods_verify_config['data']['value'];
  54. $verify_state = 0;
  55. if (!empty($goods_verify_config['is_open'])) {
  56. if($data['site_id']==1) {
  57. $verify_state = 1;//开启商品审核后,审核状态为:待审核
  58. }
  59. else{
  60. $verify_state = 0;
  61. }
  62. }
  63. // 店铺未认证、审核中的状态下,商品需要审核
  64. if (empty($shop_info['cert_id']) || $shop_info['shop_status'] == 0 || $shop_info['shop_status'] == 2) {
  65. $verify_state = 0;//开启商品审核后,审核状态为:待审核
  66. }
  67. $goods_image = $data['goods_image'];
  68. //SKU商品数据
  69. if (!empty($data['goods_sku_data'])) {
  70. $data['goods_sku_data'] = json_decode($data['goods_sku_data'], true);
  71. if (empty($goods_image)) {
  72. $goods_image = $data['goods_sku_data'][0]['sku_image'];
  73. }
  74. }
  75. $goods_data = array(
  76. 'goods_image' => $goods_image,
  77. 'goods_stock' => $data['goods_stock'],
  78. 'price' => $data['goods_sku_data'][0]['price'],
  79. 'market_price' => $data['goods_sku_data'][0]['market_price'],
  80. 'cost_price' => $data['goods_sku_data'][0]['cost_price'],
  81. 'goods_spec_format' => $data['goods_spec_format'],
  82. );
  83. $common_data = array(
  84. 'goods_name' => $data['goods_name'],
  85. 'goods_class' => $this->goods_class['id'],
  86. 'goods_class_name' => $this->goods_class['name'],
  87. 'goods_attr_class' => $data['goods_attr_class'],
  88. 'goods_attr_name' => $data['goods_attr_name'],
  89. 'site_id' => $data['site_id'],
  90. 'site_name' => $shop_info['site_name'],
  91. 'website_id' => $shop_info['website_id'],
  92. 'category_id' => $data['category_id'],
  93. 'category_id_1' => $data['category_id_1'],
  94. 'category_id_2' => $data['category_id_2'],
  95. 'category_id_3' => $data['category_id_3'],
  96. 'category_name' => $data['category_name'],
  97. 'brand_id' => $data['brand_id'],
  98. 'brand_name' => $data['brand_name'],
  99. 'goods_content' => $data['goods_content'],
  100. 'is_own' => $shop_info['is_own'],
  101. 'goods_state' => $data['goods_state'],
  102. 'goods_stock_alarm' => $data['goods_stock_alarm'],
  103. 'is_free_shipping' => $data['is_free_shipping'],
  104. 'shipping_template' => $data['shipping_template'],
  105. 'goods_attr_format' => $data['goods_attr_format'],
  106. 'introduction' => $data['introduction'],
  107. 'keywords' => $data['keywords'],
  108. 'unit' => $data['unit'],
  109. 'commission_rate' => $data['commission_rate'],
  110. 'video_url' => $data['video_url'],
  111. 'sort' => $data['sort'],
  112. 'verify_state' => $verify_state,
  113. 'goods_shop_category_ids' => $data['goods_shop_category_ids'],
  114. 'supplier_id' => $data['supplier_id'],
  115. 'pay_num1' => $data['pay_num1'],
  116. 'price1' => $data['price1'],
  117. 'pay_num2' => $data['pay_num2'],
  118. 'price2' => $data['price2'],
  119. 'pay_num3' => $data['pay_num3'],
  120. 'price3' => $data['price3'],
  121. 'province' => $data["province"],
  122. 'city' => $data["city"],
  123. 'create_time' => time()
  124. );
  125. $goods_id = model('goods')->add(array_merge($goods_data, $common_data));
  126. $sku_arr = array();
  127. //添加sku商品
  128. foreach ($data['goods_sku_data'] as $item) {
  129. $sku_data = array(
  130. 'sku_name' => $data['goods_name'] . ' ' . $item['spec_name'],
  131. 'spec_name' => $item['spec_name'],
  132. 'sku_no' => $item['sku_no'],
  133. 'sku_spec_format' => !empty($item['sku_spec_format']) ? json_encode($item['sku_spec_format']) : "",
  134. 'price' => $item['price'],
  135. 'market_price' => $item['market_price'],
  136. 'cost_price' => $item['cost_price'],
  137. 'discount_price' => $item['price'],//sku折扣价(默认等于单价)
  138. 'stock' => $item['stock'],
  139. 'weight' => $item['weight'],
  140. 'volume' => $item['volume'],
  141. 'sku_image' => $item['sku_image'],
  142. 'sku_images' => $item['sku_images'],
  143. 'goods_id' => $goods_id
  144. );
  145. $sku_arr[] = array_merge($sku_data, $common_data);
  146. }
  147. model('goods_sku')->addList($sku_arr);
  148. // 赋值第一个商品sku_id
  149. $first_info = model('goods_sku')->getFirstData([ 'goods_id' => $goods_id ], 'sku_id', 'sku_id asc');
  150. model('goods')->update([ 'sku_id' => $first_info['sku_id'] ], [ [ 'goods_id', '=', $goods_id ] ]);
  151. // 添加商品属性关联关系
  152. $this->refreshGoodsAttribute($goods_id, $data['goods_attr_format']);
  153. if (!empty($data['goods_spec_format'])) {
  154. // 刷新SKU商品规格项/规格值JSON字符串
  155. $this->dealGoodsSkuSpecFormat($goods_id, $data['goods_spec_format']);
  156. }
  157. // 添加店铺添加统计
  158. // 添加统计
  159. $stat = new Stat();
  160. $stat->addShopStat([ 'add_goods_count' => 1, 'site_id' => $data['site_id'] ]);
  161. model('goods')->commit();
  162. return $this->success($goods_id);
  163. } catch (\Exception $e) {
  164. model('goods')->rollback();
  165. return $this->error($e->getMessage());
  166. }
  167. }
  168. /**
  169. * 商品编辑
  170. * @param $data
  171. */
  172. public function editGoods($data)
  173. {
  174. model('goods')->startTrans();
  175. try {
  176. $goods_id = $data['goods_id'];
  177. //店铺信息
  178. $shop_info = model('shop')->getInfo([ [ 'site_id', '=', $data['site_id'] ] ], 'site_name, website_id, is_own,cert_id,shop_status');
  179. $goods_config = new Config();
  180. $goods_verify_config = $goods_config->getVerifyConfig();
  181. $goods_verify_config = $goods_verify_config['data']['value'];
  182. $verify_state = 1;
  183. $verify_state_remark = '';
  184. if (!empty($goods_verify_config['is_open'])) {
  185. if($data['site_id']==1) {
  186. $verify_state = 1;//开启商品审核后,审核状态为:待审核
  187. }
  188. else{
  189. $verify_state = 0;
  190. }
  191. }
  192. // 店铺未认证、审核中的状态下,商品需要审核
  193. if (empty($shop_info['cert_id']) || $shop_info['shop_status'] == 0 || $shop_info['shop_status'] == 2) {
  194. $verify_state = 0;//开启商品审核后,审核状态为:待审核
  195. }
  196. $goods_image = $data['goods_image'];
  197. //SKU商品数据
  198. if (!empty($data['goods_sku_data'])) {
  199. $data['goods_sku_data'] = json_decode($data['goods_sku_data'], true);
  200. if (empty($goods_image)) {
  201. $goods_image = $data['goods_sku_data'][0]['sku_image'];
  202. }
  203. }
  204. $goods_data = array(
  205. 'goods_image' => $goods_image,
  206. 'goods_stock' => $data['goods_stock'],
  207. 'price' => $data['goods_sku_data'][0]['price'],
  208. 'market_price' => $data['goods_sku_data'][0]['market_price'],
  209. 'cost_price' => $data['goods_sku_data'][0]['cost_price'],
  210. 'goods_spec_format' => $data['goods_spec_format'],
  211. );
  212. $common_data = array(
  213. 'goods_name' => $data['goods_name'],
  214. 'goods_class' => $this->goods_class['id'],
  215. 'goods_class_name' => $this->goods_class['name'],
  216. 'goods_attr_class' => $data['goods_attr_class'],
  217. 'goods_attr_name' => $data['goods_attr_name'],
  218. 'site_id' => $data['site_id'],
  219. 'site_name' => $shop_info['site_name'],
  220. 'website_id' => $shop_info['website_id'],
  221. 'category_id' => $data['category_id'],
  222. 'category_id_1' => $data['category_id_1'],
  223. 'category_id_2' => $data['category_id_2'],
  224. 'category_id_3' => $data['category_id_3'],
  225. 'category_name' => $data['category_name'],
  226. 'brand_id' => $data['brand_id'],
  227. 'brand_name' => $data['brand_name'],
  228. 'goods_content' => $data['goods_content'],
  229. 'is_own' => $shop_info['is_own'],
  230. 'goods_state' => $data['goods_state'],
  231. 'goods_stock_alarm' => $data['goods_stock_alarm'],
  232. 'is_free_shipping' => $data['is_free_shipping'],
  233. 'shipping_template' => $data['shipping_template'],
  234. 'goods_attr_format' => $data['goods_attr_format'],
  235. 'introduction' => $data['introduction'],
  236. 'keywords' => $data['keywords'],
  237. 'unit' => $data['unit'],
  238. 'commission_rate' => $data['commission_rate'],
  239. 'video_url' => $data['video_url'],
  240. 'sort' => $data['sort'],
  241. 'verify_state' => $verify_state,
  242. 'verify_state_remark' => $verify_state_remark,
  243. 'goods_shop_category_ids' => $data['goods_shop_category_ids'],
  244. 'supplier_id' => $data['supplier_id'],
  245. 'pay_num1' => $data['pay_num1'],
  246. 'price1' => $data['price1'],
  247. 'pay_num2' => $data['pay_num2'],
  248. 'price2' => $data['price2'],
  249. 'pay_num3' => $data['pay_num3'],
  250. 'price3' => $data['price3'],
  251. 'modify_time' => time()
  252. );
  253. model('goods')->update(array_merge($goods_data, $common_data), [ [ 'goods_id', '=', $goods_id ], [ 'goods_class', '=', $this->goods_class['id'] ] ]);
  254. //修改sku商品
  255. foreach ($data['goods_sku_data'] as $item) {
  256. $sku_data = array(
  257. 'sku_name' => $data['goods_name'] . ' ' . $item['spec_name'],
  258. 'spec_name' => $item['spec_name'],
  259. 'sku_no' => $item['sku_no'],
  260. 'sku_spec_format' => !empty($item['sku_spec_format']) ? json_encode($item['sku_spec_format']) : "",
  261. 'price' => $item['price'],
  262. 'market_price' => $item['market_price'],
  263. 'cost_price' => $item['cost_price'],
  264. // 'discount_price' => $item['price'],//sku折扣价(默认等于单价)
  265. 'stock' => $item['stock'],
  266. 'weight' => $item['weight'],
  267. 'volume' => $item['volume'],
  268. 'sku_image' => $item['sku_image'],
  269. 'sku_images' => $item['sku_images'],
  270. 'goods_id' => $goods_id
  271. );
  272. model('goods_sku')->update(array_merge($sku_data, $common_data), [ [ 'sku_id', '=', $item['sku_id'] ], [ 'goods_class', '=', $this->goods_class['id'] ] ]);
  273. }
  274. // 赋值第一个商品sku_id
  275. $first_info = model('goods_sku')->getFirstData([ 'goods_id' => $goods_id ], 'sku_id', 'sku_id asc');
  276. model('goods')->update([ 'sku_id' => $first_info['sku_id'] ], [ [ 'goods_id', '=', $goods_id ] ]);
  277. // 添加商品属性关联关系
  278. $this->refreshGoodsAttribute($goods_id, $data['goods_attr_format']);
  279. if (!empty($data['goods_spec_format'])) {
  280. // 刷新SKU商品规格项/规格值JSON字符串
  281. $this->dealGoodsSkuSpecFormat($goods_id, $data['goods_spec_format']);
  282. }
  283. model('goods')->commit();
  284. return $this->success($goods_id);
  285. } catch (\Exception $e) {
  286. model('goods')->rollback();
  287. return $this->error($e->getMessage());
  288. }
  289. }
  290. /**
  291. * 修改商品状态
  292. * @param $goods_ids
  293. * @param $goods_state
  294. * @param $site_id
  295. * @return \multitype
  296. */
  297. public function modifyGoodsState($goods_ids, $goods_state, $site_id)
  298. {
  299. model('goods')->update([ 'goods_state' => $goods_state ], [ [ 'goods_id', 'in', $goods_ids ], [ 'site_id', '=', $site_id ] ]);
  300. if($goods_state==1) {
  301. model('goods_sku')->update(['is_delete' => 0, 'goods_state' => $goods_state], [['goods_id', 'in', $goods_ids], ['site_id', '=', $site_id]]);
  302. }
  303. else{
  304. model('goods_sku')->update(['is_delete' => 1, 'goods_state' => $goods_state], [['goods_id', 'in', $goods_ids], ['site_id', '=', $site_id]]);
  305. model('recommend')->delete([ 'goods_id' => $goods_ids ]);
  306. }
  307. return $this->success(1);
  308. }
  309. /**
  310. * 修改审核状态
  311. * @param $goods_ids
  312. * @param $verify_state
  313. * @param $verify_state_remark
  314. * @return \multitype
  315. */
  316. public function modifyVerifyState($goods_ids, $verify_state, $verify_state_remark)
  317. {
  318. model('goods')->update([ 'verify_state' => $verify_state, 'verify_state_remark' => $verify_state_remark ], [ [ 'goods_id', 'in', $goods_ids ] ]);
  319. model('goods_sku')->update([ 'verify_state' => $verify_state, 'verify_state_remark' => $verify_state_remark ], [ [ 'goods_id', 'in', $goods_ids ] ]);
  320. return $this->success(1);
  321. }
  322. /**
  323. * 修改删除状态
  324. * @param $goods_ids
  325. * @param $is_delete
  326. * @param $site_id
  327. */
  328. public function modifyIsDelete($goods_ids, $is_delete, $site_id)
  329. {
  330. model('goods')->update([ 'is_delete' => $is_delete ], [ [ 'goods_id', 'in', $goods_ids ], [ 'site_id', '=', $site_id ] ]);
  331. model('goods_sku')->update([ 'is_delete' => $is_delete ], [ [ 'goods_id', 'in', $goods_ids ], [ 'site_id', '=', $site_id ] ]);
  332. model('recommend')->delete([ 'goods_id' => $goods_ids ]);
  333. return $this->success(1);
  334. }
  335. /**
  336. * 违规下架商品
  337. * @param $condition
  338. * @param $verify_state_remark
  339. * @return array
  340. */
  341. public function lockup($condition, $verify_state_remark,$goods_ids)
  342. {
  343. model('goods')->update([ 'verify_state_remark' => $verify_state_remark, 'verify_state' => 10, 'goods_state' => 0 ], $condition);
  344. model('goods_sku')->update([ 'is_delete' => 1,'verify_state_remark' => $verify_state_remark, 'verify_state' => 10, 'goods_state' => 0 ], $condition);
  345. model('recommend')->delete([ 'goods_id' => $goods_ids ]);
  346. return $this->success(1);
  347. }
  348. /**
  349. * 修改商品点击量
  350. * @param $sku_id
  351. * @param $site_id
  352. */
  353. public function modifyClick($sku_id, $site_id)
  354. {
  355. model("goods_sku")->setInc([ [ 'sku_id', '=', $sku_id ], [ 'site_id', '=', $site_id ] ], 'click_num', 1);
  356. return $this->success(1);
  357. }
  358. /**
  359. * 删除回收站商品
  360. * @param $goods_ids
  361. * @param $site_id
  362. */
  363. public function deleteRecycleGoods($goods_ids, $site_id)
  364. {
  365. model('goods')->delete([ [ 'goods_id', 'in', $goods_ids ], [ 'site_id', '=', $site_id ] ]);
  366. model('goods_sku')->delete([ [ 'goods_id', 'in', $goods_ids ], [ 'site_id', '=', $site_id ] ]);
  367. return $this->success(1);
  368. }
  369. /**
  370. * 获取商品信息
  371. * @param array $condition
  372. * @param string $field
  373. */
  374. public function getGoodsInfo($condition, $field = 'goods_id,goods_name,goods_class,goods_class_name,goods_attr_class,goods_attr_name,category_id,category_id_1,category_id_2,category_id_3,category_name,brand_id,brand_name,goods_image,goods_content,goods_state,verify_state,price,market_price,cost_price,goods_stock,goods_stock_alarm,is_free_shipping,shipping_template,goods_spec_format,goods_attr_format,introduction,keywords,unit,sort,commission_rate,video_url,goods_shop_category_ids,supplier_id,pay_num1,price1,pay_num2,price2,pay_num3,price3,province,city')
  375. {
  376. $info = model('goods')->getInfo($condition, $field);
  377. return $this->success($info);
  378. }
  379. public function count_image($image){
  380. $num = count($image);
  381. if($num>5){
  382. return $this->error('上传图片上限为五张','上传图片上限为五张');
  383. }
  384. }
  385. /**
  386. * 获取商品详情
  387. * @param $goods_id
  388. * @return \multitype
  389. */
  390. public function getGoodsDetail($goods_id)
  391. {
  392. $info = model('goods')->getInfo([ [ 'goods_id', '=', $goods_id ] ], "*");
  393. $info['sku_data'] = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ] ], 'sku_id, sku_name, sku_no, sku_spec_format, price, market_price, cost_price, discount_price, stock, weight, volume, sku_image, sku_images, sort,spec_name');
  394. return $this->success($info);
  395. }
  396. /**
  397. * 商品sku 基础信息
  398. * @param $condition
  399. * @param string $field
  400. * @return array
  401. */
  402. public function getGoodsSkuInfo($condition, $field = "sku_id,sku_name,sku_no,goods_class,goods_class_name,commission_rate,site_id,site_name,sku_spec_format,price,market_price,discount_price,promotion_type,start_time,end_time,stock,click_num,sale_num,collect_num,sku_image,sku_images,goods_id,site_id,goods_content,goods_state,verify_state,is_virtual,is_free_shipping,goods_spec_format,goods_attr_format,introduction,unit,video_url")
  403. {
  404. $info = model('goods_sku')->getInfo($condition, $field);
  405. return $this->success($info);
  406. }
  407. /**
  408. * 商品SKU 详情
  409. * @param $sku_id
  410. * @return mixed
  411. */
  412. public function getGoodsSkuDetail($sku_id)
  413. {
  414. $info = model('goods_sku')->getInfo([ [ 'sku_id', '=', $sku_id ], [ 'is_delete', '=', 0 ] ], "goods_id,sku_id,sku_name,sku_spec_format,price,market_price,discount_price,promotion_type,start_time,end_time,stock,click_num,sale_num,collect_num,sku_image,sku_images,goods_id,site_id,goods_content,goods_state,verify_state,is_virtual,is_free_shipping,goods_spec_format,goods_attr_format,introduction,unit,video_url,evaluate,category_id,category_id_1,category_id_2,category_id_3,category_name");
  415. return $this->success($info);
  416. }
  417. /**
  418. * 获取商品列表
  419. * @param array $condition
  420. * @param string $field
  421. * @param string $order
  422. * @param string $limit
  423. */
  424. public function getGoodsList($condition = [], $field = 'goods_id,goods_class,goods_class_name,goods_attr_name,goods_name,site_id,site_name,website_id,sort,category_name,brand_name,goods_image,goods_content,is_own,goods_state,verify_state,price,market_price,cost_price,goods_stock,goods_stock_alarm,is_virtual,is_free_shipping,shipping_template,goods_spec_format,goods_attr_format,create_time', $order = 'create_time desc', $limit = null)
  425. {
  426. $list = model('goods')->getList($condition, $field, $order, '', '', '', $limit);
  427. return $this->success($list);
  428. }
  429. /**
  430. * 获取商品分页列表
  431. * @param array $condition
  432. * @param number $page
  433. * @param string $page_size
  434. * @param string $order
  435. * @param string $field
  436. */
  437. public function getGoodsPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'create_time desc', $field = 'goods_id,goods_name,site_id,site_name,goods_image,is_own,goods_state,verify_state,price,goods_stock,create_time,sale_num,is_virtual,goods_class,is_fenxiao,fenxiao_type,sku_id')
  438. {
  439. $list = model('goods')->pageList($condition, $field, $order, $page, $page_size);
  440. return $this->success($list);
  441. }
  442. /**
  443. * 编辑商品库存价格等信息
  444. * @param $goods_sku_array
  445. * @return array|\multitype
  446. */
  447. public function editGoodsStock($goods_sku_array)
  448. {
  449. $goods_sku_model = new GoodsStock();
  450. model('goods')->startTrans();
  451. try {
  452. foreach ($goods_sku_array as $k => $v) {
  453. $sku_info = model("goods_sku")->getInfo([ [ 'sku_id', '=', $v['sku_id'] ] ], "goods_id,stock");
  454. if ($k == 0) {//修改商品中的价格等信息
  455. $goods_data = [
  456. 'price' => $v['price'],
  457. 'market_price' => $v['market_price'],
  458. 'cost_price' => $v['cost_price']
  459. ];
  460. model('goods')->update($goods_data, [ [ 'goods_id', '=', $sku_info['goods_id'] ] ]);
  461. }
  462. if ($v['stock'] > $sku_info['stock']) {
  463. $sku_stock_data = [
  464. 'sku_id' => $v['sku_id'],
  465. 'num' => $v['stock'] - $sku_info['stock']
  466. ];
  467. $goods_sku_model->incStock($sku_stock_data);
  468. }
  469. if ($v['stock'] < $sku_info['stock']) {
  470. $sku_stock_data = [
  471. 'sku_id' => $v['sku_id'],
  472. 'num' => $sku_info['stock'] - $v['stock']
  473. ];
  474. $goods_sku_model->decStock($sku_stock_data);
  475. }
  476. unset($v['stock']);
  477. model('goods_sku')->update($v, [ [ 'sku_id', '=', $v['sku_id'] ] ]);
  478. }
  479. model('goods')->commit();
  480. return $this->success();
  481. } catch (\Exception $e) {
  482. model('goods')->rollback();
  483. return $this->error($e->getMessage());
  484. }
  485. }
  486. /**
  487. * 获取商品sku列表
  488. * @param array $condition
  489. * @param string $field
  490. * @param string $order
  491. * @param string $limit
  492. */
  493. public function getGoodsSkuList($condition = [], $field = 'sku_id,sku_name,price,stock,sale_num,sku_image,goods_id,goods_name,site_id,site_name,spec_name', $order = 'create_time desc', $limit = null)
  494. {
  495. $list = model('goods_sku')->getList($condition, $field, $order, '', '', '', $limit);
  496. return $this->success($list);
  497. }
  498. /**
  499. * 获取商品sku分页列表
  500. * @param array $condition
  501. * @param number $page
  502. * @param string $page_size
  503. * @param string $order
  504. * @param string $field
  505. * @param string $alias
  506. * @param string $join
  507. */
  508. public function getGoodsSkuPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = '', $field = 'sku_id,sku_name,price,sku_image,create_time,stock,goods_state,goods_class,goods_class_name', $alias = '', $join = '')
  509. {
  510. $list = model('goods_sku')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
  511. return $this->success($list);
  512. }
  513. /**
  514. * 刷新商品关联属性关系
  515. * @param $goods_id
  516. * @param $goods_attr_format
  517. */
  518. private function refreshGoodsAttribute($goods_id, $goods_attr_format)
  519. {
  520. model('goods_attr_index')->delete([ [ 'goods_id', '=', $goods_id ] ]);
  521. if (!empty($goods_attr_format)) {
  522. $list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ] ], 'sku_id');
  523. $goods_attr_format = json_decode($goods_attr_format, true);
  524. $attr_data = [];
  525. foreach ($goods_attr_format as $k => $v) {
  526. foreach ($list as $ck => $cv) {
  527. $item = [
  528. 'goods_id' => $goods_id,
  529. 'sku_id' => $cv['sku_id'],
  530. 'attr_id' => $v['attr_id'],
  531. 'attr_value_id' => $v['attr_value_id'],
  532. 'attr_class_id' => $v['attr_class_id'],
  533. ];
  534. $attr_data[] = $item;
  535. }
  536. }
  537. model('goods_attr_index')->addList($attr_data);
  538. }
  539. }
  540. /**
  541. * 刷新SKU商品规格项/规格值JSON字符串
  542. * @param int $goods_id 商品id
  543. * @param string $goods_spec_format 商品完整规格项/规格值json
  544. */
  545. private function dealGoodsSkuSpecFormat($goods_id, $goods_spec_format)
  546. {
  547. if (empty($goods_spec_format)) return;
  548. $goods_spec_format = json_decode($goods_spec_format, true);
  549. //根据goods_id查询sku商品列表,查询:sku_id、sku_spec_format 列
  550. $sku_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ], [ 'sku_spec_format', '<>', '' ] ], 'sku_id,sku_spec_format', 'sku_id asc');
  551. if (!empty($sku_list)) {
  552. // $temp = 0;//测试性能,勿删
  553. //循环SKU商品列表
  554. foreach ($sku_list as $k => $v) {
  555. // $temp++;
  556. $sku_format = $goods_spec_format;//最终要存储的值
  557. $current_format = json_decode($v['sku_spec_format'], true);//当前SKU商品规格值json
  558. $selected_data = [];//已选规格/规格值json
  559. //1、找出已选规格/规格值json
  560. //循环完整商品规格json
  561. foreach ($sku_format as $sku_k => $sku_v) {
  562. // $temp++;
  563. //循环当前SKU商品规格json
  564. foreach ($current_format as $current_k => $current_v) {
  565. // $temp++;
  566. //匹配规格项
  567. if ($current_v['spec_id'] == $sku_v['spec_id']) {
  568. //循环规格值
  569. foreach ($sku_v['value'] as $sku_value_k => $sku_value_v) {
  570. // $temp++;
  571. //匹配规格值id
  572. if ($current_v['spec_value_id'] == $sku_value_v['spec_value_id']) {
  573. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'] = true;
  574. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['sku_id'] = $v['sku_id'];
  575. $selected_data[] = $sku_format[ $sku_k ]['value'][ $sku_value_k ];
  576. break;
  577. }
  578. }
  579. }
  580. }
  581. }
  582. //2、找出未选中的规格/规格值json
  583. foreach ($sku_format as $sku_k => $sku_v) {
  584. // $temp++;
  585. foreach ($sku_v['value'] as $sku_value_k => $sku_value_v) {
  586. // $temp++;
  587. if (!isset($sku_value_v['selected'])) {
  588. $refer_data = [];//参考已选中的规格/规格值json
  589. $refer_data[] = $sku_value_v;
  590. // 根据已选中的规格值进行参考
  591. foreach ($selected_data as $selected_k => $selected_v) {
  592. // $temp++;
  593. // 排除自身,然后进行参考
  594. if ($selected_v['spec_id'] != $sku_value_v['spec_id']) {
  595. $refer_data[] = $selected_v;
  596. }
  597. }
  598. foreach ($sku_list as $again_k => $again_v) {
  599. // $temp++;
  600. //排除当前SKU商品
  601. if ($again_v['sku_id'] != $v['sku_id']) {
  602. $current_format_again = json_decode($again_v['sku_spec_format'], true);
  603. $count = count($current_format_again);//规格总数量
  604. $curr_count = 0;//当前匹配规格数量
  605. //循环当前SKU商品规格json
  606. foreach ($current_format_again as $current_again_k => $current_again_v) {
  607. // $temp++;
  608. foreach ($refer_data as $fan_k => $fan_v) {
  609. // $temp++;
  610. if ($current_again_v['spec_value_id'] == $fan_v['spec_value_id']) {
  611. $curr_count++;
  612. }
  613. }
  614. }
  615. // 匹配数量跟规格总数一致表示匹配成功
  616. if ($curr_count == $count) {
  617. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'] = false;
  618. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['sku_id'] = $again_v['sku_id'];
  619. break;
  620. }
  621. }
  622. }
  623. //没有匹配到规格值,则禁用
  624. if (!isset($sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'])) {
  625. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['disabled'] = false;
  626. }
  627. }
  628. }
  629. }
  630. // var_dump($sku_format);
  631. // var_dump("=========");
  632. //修改goods_sku表表中的goods_spec_format字段,将$sku_format值传入
  633. model('goods_sku')->update([ 'goods_spec_format' => json_encode($sku_format) ], [ [ 'sku_id', '=', $v['sku_id'] ] ]);
  634. }
  635. // var_dump("性能:" . $temp);
  636. }
  637. }
  638. /**
  639. * 商品推广二维码
  640. * @param $sku_id
  641. * @param $goods_name
  642. * @param string $type
  643. * @return array
  644. */
  645. public function qrcode($sku_id, $goods_name, $type = "create")
  646. {
  647. $data = [
  648. 'app_type' => "all", // all为全部
  649. 'type' => $type, // 类型 create创建 get获取
  650. 'data' => [
  651. "sku_id" => $sku_id
  652. ],
  653. 'page' => '/pages/goods/detail/detail',
  654. 'qrcode_path' => 'upload/qrcode/goods',
  655. 'qrcode_name' => "goods_qrcode_" . $sku_id,
  656. ];
  657. event('Qrcode', $data, true);
  658. $app_type_list = config('app_type');
  659. $path = [];
  660. //获取站点信息
  661. $website_model = new WebsiteModel();
  662. $website_info = $website_model->getWebSite([ [ 'site_id', '=', 0 ] ], 'wap_domain');
  663. foreach ($app_type_list as $k => $v) {
  664. switch ($k) {
  665. case 'h5':
  666. if (!empty($website_info['data']['wap_domain'])) {
  667. $path[ $k ]['status'] = 1;
  668. $path[ $k ]['url'] = $website_info['data']['wap_domain'] . $data['page'] . '?sku_id=' . $sku_id;
  669. $path[ $k ]['img'] = "upload/qrcode/goods/goods_qrcode_" . $sku_id . "_" . $k . ".png";
  670. } else {
  671. $path[ $k ]['status'] = 2;
  672. $path[ $k ]['message'] = '未配置手机端域名';
  673. }
  674. break;
  675. case 'weapp' :
  676. $config = new ConfigModel();
  677. $res = $config->getConfig([ [ 'site_id', '=', 0 ], [ 'app_module', '=', 'admin' ], [ 'config_key', '=', 'WEAPP_CONFIG' ] ]);
  678. if (!empty($res['data'])) {
  679. if (empty($res['data']['value']['qrcode'])) {
  680. $path[ $k ]['status'] = 2;
  681. $path[ $k ]['message'] = '未配置微信小程序';
  682. } else {
  683. $path[ $k ]['status'] = 1;
  684. $path[ $k ]['img'] = $res['data']['value']['qrcode'];
  685. }
  686. } else {
  687. $path[ $k ]['status'] = 2;
  688. $path[ $k ]['message'] = '未配置微信小程序';
  689. }
  690. break;
  691. case 'wechat' :
  692. $config = new ConfigModel();
  693. $res = $config->getConfig([ [ 'site_id', '=', 0 ], [ 'app_module', '=', 'admin' ], [ 'config_key', '=', 'WECHAT_CONFIG' ] ]);
  694. if (!empty($res['data'])) {
  695. if (empty($res['data']['value']['qrcode'])) {
  696. $path[ $k ]['status'] = 2;
  697. $path[ $k ]['message'] = '未配置微信公众号';
  698. } else {
  699. $path[ $k ]['status'] = 1;
  700. $path[ $k ]['img'] = $res['data']['value']['qrcode'];
  701. }
  702. } else {
  703. $path[ $k ]['status'] = 2;
  704. $path[ $k ]['message'] = '未配置微信公众号';
  705. }
  706. break;
  707. }
  708. }
  709. $return = [
  710. 'path' => $path,
  711. 'goods_name' => $goods_name,
  712. ];
  713. return $this->success($return);
  714. }
  715. /**
  716. * 增加商品销量
  717. * @param $sku_id
  718. * @param $num
  719. */
  720. public function incGoodsSaleNum($sku_id, $num)
  721. {
  722. $condition = array(
  723. [ "sku_id", "=", $sku_id ]
  724. );
  725. //增加sku销量
  726. $res = model("goods_sku")->setInc($condition, "sale_num", $num);
  727. if ($res !== false) {
  728. $sku_info = model("goods_sku")->getInfo($condition, "goods_id");
  729. $res = model("goods")->setInc([ [ "goods_id", "=", $sku_info["goods_id"] ] ], "sale_num", $num);
  730. return $this->success($res);
  731. }
  732. return $this->error($res);
  733. }
  734. /**
  735. * 减少商品销量
  736. * @param $sku_id
  737. * @param $num
  738. */
  739. public function decGoodsSaleNum($sku_id, $num)
  740. {
  741. $condition = array(
  742. [ "sku_id", "=", $sku_id ]
  743. );
  744. //增加sku销量
  745. $res = model("goods_sku")->setDec($condition, "sale_num", $num);
  746. if ($res !== false) {
  747. $sku_info = model("goods_sku")->getInfo($condition, "goods_id");
  748. $res = model("goods")->setDec([ [ "goods_id", "=", $sku_info["goods_id"] ] ], "sale_num", $num);
  749. return $this->success($res);
  750. }
  751. return $this->error($res);
  752. }
  753. /**
  754. * 获取商品总数
  755. * @param array $condition
  756. * @return array
  757. */
  758. public function getGoodsTotalCount($condition = [])
  759. {
  760. $res = model('goods')->getCount($condition);
  761. return $this->success($res);
  762. }
  763. }