Goods.php 30 KB

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