Goods.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934
  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. print_r($sku);die;
  420. foreach ($sku as $item){
  421. if(empty($item['price'])||$item['price']<1) {
  422. return $this->error('请正确填写规格信息');
  423. }
  424. }
  425. }
  426. /**
  427. * 获取商品详情
  428. * @param $goods_id
  429. * @return \multitype
  430. */
  431. public function getGoodsDetail($goods_id)
  432. {
  433. $info = model('goods')->getInfo([ [ 'goods_id', '=', $goods_id ] ], "*");
  434. $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');
  435. return $this->success($info);
  436. }
  437. /**
  438. * 商品sku 基础信息
  439. * @param $condition
  440. * @param string $field
  441. * @return array
  442. */
  443. 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")
  444. {
  445. $info = model('goods_sku')->getInfo($condition, $field);
  446. return $this->success($info);
  447. }
  448. /**
  449. * 商品SKU 详情
  450. * @param $sku_id
  451. * @return mixed
  452. */
  453. public function getGoodsSkuDetail($sku_id)
  454. {
  455. $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");
  456. return $this->success($info);
  457. }
  458. /**
  459. * 获取商品列表
  460. * @param array $condition
  461. * @param string $field
  462. * @param string $order
  463. * @param string $limit
  464. */
  465. 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)
  466. {
  467. $list = model('goods')->getList($condition, $field, $order, '', '', '', $limit);
  468. return $this->success($list);
  469. }
  470. /**
  471. * 获取商品分页列表
  472. * @param array $condition
  473. * @param number $page
  474. * @param string $page_size
  475. * @param string $order
  476. * @param string $field
  477. */
  478. 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')
  479. {
  480. $list = model('goods')->pageList($condition, $field, $order, $page, $page_size);
  481. return $this->success($list);
  482. }
  483. /**
  484. * 编辑商品库存价格等信息
  485. * @param $goods_sku_array
  486. * @return array|\multitype
  487. */
  488. public function editGoodsStock($goods_sku_array)
  489. {
  490. $goods_sku_model = new GoodsStock();
  491. model('goods')->startTrans();
  492. try {
  493. foreach ($goods_sku_array as $k => $v) {
  494. $sku_info = model("goods_sku")->getInfo([ [ 'sku_id', '=', $v['sku_id'] ] ], "goods_id,stock");
  495. if ($k == 0) {//修改商品中的价格等信息
  496. $goods_data = [
  497. 'price' => $v['price'],
  498. 'market_price' => $v['market_price'],
  499. 'cost_price' => $v['cost_price']
  500. ];
  501. model('goods')->update($goods_data, [ [ 'goods_id', '=', $sku_info['goods_id'] ] ]);
  502. }
  503. if ($v['stock'] > $sku_info['stock']) {
  504. $sku_stock_data = [
  505. 'sku_id' => $v['sku_id'],
  506. 'num' => $v['stock'] - $sku_info['stock']
  507. ];
  508. $goods_sku_model->incStock($sku_stock_data);
  509. }
  510. if ($v['stock'] < $sku_info['stock']) {
  511. $sku_stock_data = [
  512. 'sku_id' => $v['sku_id'],
  513. 'num' => $sku_info['stock'] - $v['stock']
  514. ];
  515. $goods_sku_model->decStock($sku_stock_data);
  516. }
  517. unset($v['stock']);
  518. model('goods_sku')->update($v, [ [ 'sku_id', '=', $v['sku_id'] ] ]);
  519. }
  520. model('goods')->commit();
  521. return $this->success();
  522. } catch (\Exception $e) {
  523. model('goods')->rollback();
  524. return $this->error($e->getMessage());
  525. }
  526. }
  527. /**
  528. * 获取商品sku列表
  529. * @param array $condition
  530. * @param string $field
  531. * @param string $order
  532. * @param string $limit
  533. */
  534. 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)
  535. {
  536. $list = model('goods_sku')->getList($condition, $field, $order, '', '', '', $limit);
  537. return $this->success($list);
  538. }
  539. /**
  540. * 获取商品sku分页列表
  541. * @param array $condition
  542. * @param number $page
  543. * @param string $page_size
  544. * @param string $order
  545. * @param string $field
  546. * @param string $alias
  547. * @param string $join
  548. */
  549. 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 = '')
  550. {
  551. $list = model('goods_sku')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
  552. return $this->success($list);
  553. }
  554. /**
  555. * 刷新商品关联属性关系
  556. * @param $goods_id
  557. * @param $goods_attr_format
  558. */
  559. private function refreshGoodsAttribute($goods_id, $goods_attr_format)
  560. {
  561. model('goods_attr_index')->delete([ [ 'goods_id', '=', $goods_id ] ]);
  562. if (!empty($goods_attr_format)) {
  563. $list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ] ], 'sku_id');
  564. $goods_attr_format = json_decode($goods_attr_format, true);
  565. $attr_data = [];
  566. foreach ($goods_attr_format as $k => $v) {
  567. foreach ($list as $ck => $cv) {
  568. $item = [
  569. 'goods_id' => $goods_id,
  570. 'sku_id' => $cv['sku_id'],
  571. 'attr_id' => $v['attr_id'],
  572. 'attr_value_id' => $v['attr_value_id'],
  573. 'attr_class_id' => $v['attr_class_id'],
  574. ];
  575. $attr_data[] = $item;
  576. }
  577. }
  578. model('goods_attr_index')->addList($attr_data);
  579. }
  580. }
  581. /**
  582. * 刷新SKU商品规格项/规格值JSON字符串
  583. * @param int $goods_id 商品id
  584. * @param string $goods_spec_format 商品完整规格项/规格值json
  585. */
  586. private function dealGoodsSkuSpecFormat($goods_id, $goods_spec_format)
  587. {
  588. if (empty($goods_spec_format)) return;
  589. $goods_spec_format = json_decode($goods_spec_format, true);
  590. //根据goods_id查询sku商品列表,查询:sku_id、sku_spec_format 列
  591. $sku_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_id ], [ 'sku_spec_format', '<>', '' ] ], 'sku_id,sku_spec_format', 'sku_id asc');
  592. if (!empty($sku_list)) {
  593. // $temp = 0;//测试性能,勿删
  594. //循环SKU商品列表
  595. foreach ($sku_list as $k => $v) {
  596. // $temp++;
  597. $sku_format = $goods_spec_format;//最终要存储的值
  598. $current_format = json_decode($v['sku_spec_format'], true);//当前SKU商品规格值json
  599. $selected_data = [];//已选规格/规格值json
  600. //1、找出已选规格/规格值json
  601. //循环完整商品规格json
  602. foreach ($sku_format as $sku_k => $sku_v) {
  603. // $temp++;
  604. //循环当前SKU商品规格json
  605. foreach ($current_format as $current_k => $current_v) {
  606. // $temp++;
  607. //匹配规格项
  608. if ($current_v['spec_id'] == $sku_v['spec_id']) {
  609. //循环规格值
  610. foreach ($sku_v['value'] as $sku_value_k => $sku_value_v) {
  611. // $temp++;
  612. //匹配规格值id
  613. if ($current_v['spec_value_id'] == $sku_value_v['spec_value_id']) {
  614. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'] = true;
  615. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['sku_id'] = $v['sku_id'];
  616. $selected_data[] = $sku_format[ $sku_k ]['value'][ $sku_value_k ];
  617. break;
  618. }
  619. }
  620. }
  621. }
  622. }
  623. //2、找出未选中的规格/规格值json
  624. foreach ($sku_format as $sku_k => $sku_v) {
  625. // $temp++;
  626. foreach ($sku_v['value'] as $sku_value_k => $sku_value_v) {
  627. // $temp++;
  628. if (!isset($sku_value_v['selected'])) {
  629. $refer_data = [];//参考已选中的规格/规格值json
  630. $refer_data[] = $sku_value_v;
  631. // 根据已选中的规格值进行参考
  632. foreach ($selected_data as $selected_k => $selected_v) {
  633. // $temp++;
  634. // 排除自身,然后进行参考
  635. if ($selected_v['spec_id'] != $sku_value_v['spec_id']) {
  636. $refer_data[] = $selected_v;
  637. }
  638. }
  639. foreach ($sku_list as $again_k => $again_v) {
  640. // $temp++;
  641. //排除当前SKU商品
  642. if ($again_v['sku_id'] != $v['sku_id']) {
  643. $current_format_again = json_decode($again_v['sku_spec_format'], true);
  644. $count = count($current_format_again);//规格总数量
  645. $curr_count = 0;//当前匹配规格数量
  646. //循环当前SKU商品规格json
  647. foreach ($current_format_again as $current_again_k => $current_again_v) {
  648. // $temp++;
  649. foreach ($refer_data as $fan_k => $fan_v) {
  650. // $temp++;
  651. if ($current_again_v['spec_value_id'] == $fan_v['spec_value_id']) {
  652. $curr_count++;
  653. }
  654. }
  655. }
  656. // 匹配数量跟规格总数一致表示匹配成功
  657. if ($curr_count == $count) {
  658. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'] = false;
  659. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['sku_id'] = $again_v['sku_id'];
  660. break;
  661. }
  662. }
  663. }
  664. //没有匹配到规格值,则禁用
  665. if (!isset($sku_format[ $sku_k ]['value'][ $sku_value_k ]['selected'])) {
  666. $sku_format[ $sku_k ]['value'][ $sku_value_k ]['disabled'] = false;
  667. }
  668. }
  669. }
  670. }
  671. // var_dump($sku_format);
  672. // var_dump("=========");
  673. //修改goods_sku表表中的goods_spec_format字段,将$sku_format值传入
  674. model('goods_sku')->update([ 'goods_spec_format' => json_encode($sku_format) ], [ [ 'sku_id', '=', $v['sku_id'] ] ]);
  675. }
  676. // var_dump("性能:" . $temp);
  677. }
  678. }
  679. /**
  680. * 商品推广二维码
  681. * @param $sku_id
  682. * @param $goods_name
  683. * @param string $type
  684. * @return array
  685. */
  686. public function qrcode($sku_id, $goods_name, $type = "create")
  687. {
  688. $data = [
  689. 'app_type' => "all", // all为全部
  690. 'type' => $type, // 类型 create创建 get获取
  691. 'data' => [
  692. "sku_id" => $sku_id
  693. ],
  694. 'page' => '/pages/goods/detail/detail',
  695. 'qrcode_path' => 'upload/qrcode/goods',
  696. 'qrcode_name' => "goods_qrcode_" . $sku_id,
  697. ];
  698. event('Qrcode', $data, true);
  699. $app_type_list = config('app_type');
  700. $path = [];
  701. //获取站点信息
  702. $website_model = new WebsiteModel();
  703. $website_info = $website_model->getWebSite([ [ 'site_id', '=', 0 ] ], 'wap_domain');
  704. foreach ($app_type_list as $k => $v) {
  705. switch ($k) {
  706. case 'h5':
  707. if (!empty($website_info['data']['wap_domain'])) {
  708. $path[ $k ]['status'] = 1;
  709. $path[ $k ]['url'] = $website_info['data']['wap_domain'] . $data['page'] . '?sku_id=' . $sku_id;
  710. $path[ $k ]['img'] = "upload/qrcode/goods/goods_qrcode_" . $sku_id . "_" . $k . ".png";
  711. } else {
  712. $path[ $k ]['status'] = 2;
  713. $path[ $k ]['message'] = '未配置手机端域名';
  714. }
  715. break;
  716. case 'weapp' :
  717. $config = new ConfigModel();
  718. $res = $config->getConfig([ [ 'site_id', '=', 0 ], [ 'app_module', '=', 'admin' ], [ 'config_key', '=', 'WEAPP_CONFIG' ] ]);
  719. if (!empty($res['data'])) {
  720. if (empty($res['data']['value']['qrcode'])) {
  721. $path[ $k ]['status'] = 2;
  722. $path[ $k ]['message'] = '未配置微信小程序';
  723. } else {
  724. $path[ $k ]['status'] = 1;
  725. $path[ $k ]['img'] = $res['data']['value']['qrcode'];
  726. }
  727. } else {
  728. $path[ $k ]['status'] = 2;
  729. $path[ $k ]['message'] = '未配置微信小程序';
  730. }
  731. break;
  732. case 'wechat' :
  733. $config = new ConfigModel();
  734. $res = $config->getConfig([ [ 'site_id', '=', 0 ], [ 'app_module', '=', 'admin' ], [ 'config_key', '=', 'WECHAT_CONFIG' ] ]);
  735. if (!empty($res['data'])) {
  736. if (empty($res['data']['value']['qrcode'])) {
  737. $path[ $k ]['status'] = 2;
  738. $path[ $k ]['message'] = '未配置微信公众号';
  739. } else {
  740. $path[ $k ]['status'] = 1;
  741. $path[ $k ]['img'] = $res['data']['value']['qrcode'];
  742. }
  743. } else {
  744. $path[ $k ]['status'] = 2;
  745. $path[ $k ]['message'] = '未配置微信公众号';
  746. }
  747. break;
  748. }
  749. }
  750. $return = [
  751. 'path' => $path,
  752. 'goods_name' => $goods_name,
  753. ];
  754. return $this->success($return);
  755. }
  756. /**
  757. * 增加商品销量
  758. * @param $sku_id
  759. * @param $num
  760. */
  761. public function incGoodsSaleNum($sku_id, $num)
  762. {
  763. $condition = array(
  764. [ "sku_id", "=", $sku_id ]
  765. );
  766. //增加sku销量
  767. $res = model("goods_sku")->setInc($condition, "sale_num", $num);
  768. if ($res !== false) {
  769. $sku_info = model("goods_sku")->getInfo($condition, "goods_id");
  770. $res = model("goods")->setInc([ [ "goods_id", "=", $sku_info["goods_id"] ] ], "sale_num", $num);
  771. return $this->success($res);
  772. }
  773. return $this->error($res);
  774. }
  775. /**
  776. * 减少商品销量
  777. * @param $sku_id
  778. * @param $num
  779. */
  780. public function decGoodsSaleNum($sku_id, $num)
  781. {
  782. $condition = array(
  783. [ "sku_id", "=", $sku_id ]
  784. );
  785. //增加sku销量
  786. $res = model("goods_sku")->setDec($condition, "sale_num", $num);
  787. if ($res !== false) {
  788. $sku_info = model("goods_sku")->getInfo($condition, "goods_id");
  789. $res = model("goods")->setDec([ [ "goods_id", "=", $sku_info["goods_id"] ] ], "sale_num", $num);
  790. return $this->success($res);
  791. }
  792. return $this->error($res);
  793. }
  794. /**
  795. * 获取商品总数
  796. * @param array $condition
  797. * @return array
  798. */
  799. public function getGoodsTotalCount($condition = [])
  800. {
  801. $res = model('goods')->getCount($condition);
  802. return $this->success($res);
  803. }
  804. }