Goods.php 31 KB

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