Seckill.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com
  8. * =========================================================
  9. */
  10. namespace addon\seckill\model;
  11. use app\model\BaseModel;
  12. use app\model\goods\Goods;
  13. use app\model\system\Config as ConfigModel;
  14. use app\model\system\Cron;
  15. use think\facade\Cache;
  16. use think\facade\Db;
  17. /**
  18. * 限时秒杀(时段)
  19. */
  20. class Seckill extends BaseModel
  21. {
  22. /**
  23. * 添加秒杀时段
  24. * @param unknown $data
  25. */
  26. public function addSeckillTime($data)
  27. {
  28. if ($data[ 'seckill_start_time' ] > $data[ 'seckill_end_time' ]) {
  29. return $this->error('', '秒杀时间段设置错误');
  30. }
  31. //时间段检测
  32. $seckill_count = model('promotion_seckill_time')->getCount([
  33. [ 'seckill_start_time|seckill_end_time', 'between', [ $data[ 'seckill_start_time' ], $data[ 'seckill_end_time' ] ] ],
  34. [ 'site_id', '=', $data[ 'site_id' ] ]
  35. ]);
  36. if ($seckill_count > 0) {
  37. return $this->error('', '秒杀场次设置冲突');
  38. }
  39. $seckill_count = model('promotion_seckill_time')->getCount([
  40. [ 'seckill_start_time', '<=', $data[ 'seckill_start_time' ] ],
  41. [ 'seckill_end_time', '>=', $data[ 'seckill_end_time' ] ],
  42. [ 'site_id', '=', $data[ 'site_id' ] ]
  43. ]);
  44. if ($seckill_count > 0) {
  45. return $this->error('', '秒杀场次设置冲突');
  46. }
  47. //添加数据
  48. $data[ 'create_time' ] = time();
  49. $seckill_id = model('promotion_seckill_time')->add($data);
  50. Cache::tag("promotion_seckill_time")->clear();
  51. return $this->success($seckill_id);
  52. }
  53. /**
  54. * 修改秒杀时段
  55. * @param unknown $data
  56. * @return multitype:string
  57. */
  58. public function editSeckillTime($data, $site_id)
  59. {
  60. if ($data[ 'seckill_start_time' ] > $data[ 'seckill_end_time' ]) {
  61. return $this->error('', '秒杀时间段设置错误');
  62. }
  63. //时间段检测
  64. $seckill_count = model('promotion_seckill_time')->getCount([
  65. [ 'seckill_start_time|seckill_end_time', 'between', [ $data[ 'seckill_start_time' ], $data[ 'seckill_end_time' ] ] ],
  66. [ 'site_id', '=', $site_id ],
  67. [ 'id', '<>', $data[ 'id' ] ]
  68. ]);
  69. if ($seckill_count > 0) {
  70. return $this->error('', '秒杀场次设置冲突');
  71. }
  72. $seckill_count = model('promotion_seckill_time')->getCount([
  73. [ 'seckill_start_time', '<=', $data[ 'seckill_start_time' ] ],
  74. [ 'seckill_end_time', '>=', $data[ 'seckill_end_time' ] ],
  75. [ 'site_id', '=', $site_id ],
  76. [ 'id', '<>', $data[ 'id' ] ]
  77. ]);
  78. if ($seckill_count > 0) {
  79. return $this->error('', '秒杀场次设置冲突');
  80. }
  81. //更新数据
  82. $data[ 'modify_time' ] = time();
  83. $res = model('promotion_seckill_time')->update($data, [ [ 'id', '=', $data[ 'id' ] ] ]);
  84. Cache::tag("promotion_seckill_time")->clear();
  85. return $this->success($res);
  86. }
  87. /**
  88. * 删除秒杀时段
  89. * @param unknown $seckill_time_id
  90. */
  91. public function deleteSeckillTime($seckill_time_id)
  92. {
  93. $res = model('promotion_seckill_time')->delete([ [ 'id', '=', $seckill_time_id ] ]);
  94. if ($res) {
  95. $goods = new Goods();
  96. $condition = [
  97. [ 'seckill_time_id', 'like', '%,' . $seckill_time_id . ',%' ]
  98. ];
  99. $seckill_list = model('promotion_seckill')->getList($condition, 'id,seckill_time_id,goods_id');
  100. foreach ($seckill_list as $k => $v) {
  101. $time_ids = explode(',', trim($v[ 'seckill_time_id' ], ','));
  102. unset($time_ids[ array_search($seckill_time_id, $time_ids) ]);
  103. if (empty($time_ids)) {
  104. $goods->modifyPromotionAddon($v[ 'goods_id' ], [ 'seckill' => $v[ 'id' ] ], true);
  105. model('promotion_seckill_goods')->delete([ [ 'seckill_id', '=', $v[ 'id' ] ] ]);
  106. model('promotion_seckill')->delete([ [ 'id', '=', $v[ 'id' ] ] ]);
  107. } else {
  108. $time_id = ',' . implode(',', $time_ids) . ',';
  109. model('promotion_seckill')->update([ 'seckill_time_id' => $time_id ], [ [ 'id', '=', $v[ 'id' ] ] ]);
  110. model('promotion_seckill_goods')->update([ 'seckill_time_id' => $time_id ], [ [ 'seckill_id', '=', $v[ 'id' ] ] ]);
  111. }
  112. }
  113. }
  114. Cache::tag("promotion_seckill_time")->clear();
  115. return $this->success($res);
  116. }
  117. /**
  118. * 获取秒杀时段信息
  119. * @param array $condition
  120. * @param string $field
  121. */
  122. public function getSeckillTimeInfo($condition, $field = '*')
  123. {
  124. $data = json_encode([ $condition, $field ]);
  125. $cache = Cache::get("promotion_seckill_time_getSeckillInfo_" . $data);
  126. if (!empty($cache)) {
  127. return $this->success($cache);
  128. }
  129. $res = model('promotion_seckill_time')->getInfo($condition, $field);
  130. Cache::tag("promotion_seckill_time")->set("promotion_seckill_time_getSeckillInfo_" . $data, $res);
  131. return $this->success($res);
  132. }
  133. /**
  134. * 获取秒杀时段列表
  135. * @param array $condition
  136. * @param string $field
  137. * @param string $order
  138. * @param string $limit
  139. */
  140. public function getSeckillTimeList($condition = [], $field = '*', $order = '', $limit = null)
  141. {
  142. $list = model('promotion_seckill_time')->getList($condition, $field, $order, '', '', '', $limit);
  143. return $this->success($list);
  144. }
  145. /**
  146. * 获取有商品的秒杀时段列表
  147. * @param $condition
  148. * @param $field
  149. * @param string $order
  150. * @return array
  151. */
  152. public function getGoodsSeckillTimeList($condition, $field, $order = 'seckill_start_time asc')
  153. {
  154. if (empty($field)) {
  155. $field = 'id, site_id, name, seckill_start_time, seckill_end_time';
  156. }
  157. $seckill_time = model('promotion_seckill_time')->getList($condition, $field, $order);
  158. foreach ($seckill_time as $k => $v) {
  159. $condition = [
  160. [ 'seckill_time_id', 'like', '%,' . $v[ 'id' ] . ',%' ],
  161. [ 'status', '=', 1 ],
  162. [ 'g.goods_state', '=', 1 ],
  163. [ 'g.is_delete', '=', 0 ]
  164. ];
  165. $join = [
  166. [ 'goods g', 'g.goods_id = psg.goods_id', 'inner' ]
  167. ];
  168. $goods = model('promotion_seckill_goods')->getInfo($condition, 'id', 'psg', $join);
  169. if (empty($goods)) unset($seckill_time[ $k ]);
  170. }
  171. return $this->success($seckill_time);
  172. }
  173. /**
  174. * 转换秒杀时间
  175. * @param $info
  176. * @return mixed
  177. */
  178. public function transformSeckillTime($info)
  179. {
  180. $info[ 'start_hour' ] = floor($info[ 'seckill_start_time' ] / 3600);
  181. $info[ 'start_minute' ] = floor(( $info[ 'seckill_start_time' ] % 3600 ) / 60);
  182. $info[ 'start_second' ] = $info[ 'seckill_start_time' ] % 60;
  183. $info[ 'end_hour' ] = floor($info[ 'seckill_end_time' ] / 3600);
  184. $info[ 'end_minute' ] = floor(( $info[ 'seckill_end_time' ] % 3600 ) / 60);
  185. $info[ 'end_second' ] = $info[ 'seckill_end_time' ] % 60;
  186. if ($info[ 'start_hour' ] < 10) $info[ 'start_hour' ] = '0' . $info[ 'start_hour' ];
  187. if ($info[ 'start_minute' ] < 10) $info[ 'start_minute' ] = '0' . $info[ 'start_minute' ];
  188. if ($info[ 'start_second' ] < 10) $info[ 'start_second' ] = '0' . $info[ 'start_second' ];
  189. if ($info[ 'end_hour' ] < 10) $info[ 'end_hour' ] = '0' . $info[ 'end_hour' ];
  190. if ($info[ 'end_minute' ] < 10) $info[ 'end_minute' ] = '0' . $info[ 'end_minute' ];
  191. if ($info[ 'end_second' ] < 10) $info[ 'end_second' ] = '0' . $info[ 'end_second' ];
  192. return $info;
  193. }
  194. /******************************************************秒杀商品*********************************************************************/
  195. /**
  196. * 添加秒杀商品
  197. * @param unknown $seckill_id
  198. * @param unknown $site_id
  199. * @param unknown $sku_ids
  200. * @return multitype:string
  201. */
  202. public function addSeckillGoods($data)
  203. {
  204. $cron = new Cron();
  205. $goods_data = $data[ 'goods_data' ];
  206. if (empty($data[ 'seckill_time_id' ])) {
  207. return $this->error('', '请选择秒杀时段');
  208. }
  209. $seckill_time_id = explode(',', $data[ 'seckill_time_id' ]);
  210. //时间段检测
  211. foreach ($seckill_time_id as $v) {
  212. $seckill_count = model('promotion_seckill')->getCount([
  213. [ 'goods_id', 'in', $data[ 'goods_ids' ] ],
  214. [ 'status', 'in', '0,1' ],
  215. [ 'seckill_time_id', 'like', '%,' . $v . ',%' ],
  216. [ 'site_id', '=', $data[ 'site_id' ] ],
  217. [ '', 'exp', Db::raw('not ( (`start_time` > ' . $data[ 'end_time' ] . ' and `start_time` > ' . $data[ 'start_time' ] . ' ) or (`end_time` < ' . $data[ 'start_time' ] . ' and `end_time` < ' . $data[ 'end_time' ] . '))') ]//todo 修正 所有的优惠都要一样
  218. ]);
  219. if ($seckill_count > 0) {
  220. return $this->error('', '有商品已设置秒杀,请不要重复设置');
  221. }
  222. }
  223. model('promotion_seckill')->startTrans();
  224. try {
  225. $seckill_data = [
  226. 'site_id' => $data[ 'site_id' ],
  227. 'seckill_name' => $data[ 'seckill_name' ],
  228. 'remark' => $data[ 'remark' ],
  229. 'seckill_time_id' => ',' . $data[ 'seckill_time_id' ] . ',',
  230. 'start_time' => $data[ 'start_time' ],
  231. 'end_time' => $data[ 'end_time' ],
  232. 'create_time' => time(),
  233. 'sort' => $data[ 'sort' ],
  234. ];
  235. $goods = new Goods();
  236. $add_goods_data = [];
  237. foreach ($goods_data as $k => $v) {
  238. $seckill_data[ 'goods_id' ] = $v[ 'goods_id' ];
  239. $seckill_data[ 'goods_name' ] = $v[ 'sku_list' ][ 0 ][ 'sku_name' ];
  240. $seckill_data[ 'goods_image' ] = $v[ 'sku_list' ][ 0 ][ 'sku_image' ];
  241. $seckill_data[ 'seckill_price' ] = $v[ 'sku_list' ][ 0 ][ 'seckill_price' ];
  242. if ($data[ 'start_time' ] <= time()) {
  243. $seckill_data[ 'status' ] = 1;//直接启动
  244. $seckill_id = model('promotion_seckill')->add($seckill_data);
  245. $goods->modifyPromotionAddon($v[ 'goods_id' ], [ 'seckill' => $seckill_id ]);
  246. $cron->addCron(1, 0, "秒杀关闭", "CloseSeckill", $data[ 'end_time' ], $seckill_id);
  247. } else {
  248. $seckill_data[ 'status' ] = 0;
  249. $seckill_id = model('promotion_seckill')->add($seckill_data);
  250. $cron->addCron(1, 0, "秒杀开启", "OpenSeckill", $data[ 'start_time' ], $seckill_id);
  251. $cron->addCron(1, 0, "秒杀关闭", "CloseSeckill", $data[ 'end_time' ], $seckill_id);
  252. }
  253. $goods_stock = 0; // 秒杀商品总库存
  254. foreach ($v[ 'sku_list' ] as $key => $item) {
  255. $sku_info = model('goods_sku')->getInfo([ [ 'sku_id', '=', $item[ 'sku_id' ] ] ], 'goods_id, sku_id, sku_name,price,sku_image');
  256. $add_goods_data[] = [
  257. 'site_id' => $data[ 'site_id' ],
  258. 'seckill_id' => $seckill_id,
  259. 'seckill_time_id' => ',' . $data[ 'seckill_time_id' ] . ',',
  260. 'sku_id' => $item[ 'sku_id' ],
  261. 'goods_id' => $item[ 'goods_id' ],
  262. 'sku_image' => $sku_info[ 'sku_image' ],
  263. 'sku_name' => $sku_info[ 'sku_name' ],
  264. 'seckill_price' => $item[ 'seckill_price' ],
  265. 'price' => $sku_info[ 'price' ],
  266. 'stock' => $item[ 'seckill_stock' ],
  267. 'max_buy' => $item[ 'max_buy' ],
  268. 'status' => $seckill_data[ 'status' ]
  269. ];
  270. $goods_stock += $item[ 'seckill_stock' ];
  271. }
  272. model('promotion_seckill')->update([ 'goods_stock' => $goods_stock ], [ [ 'id', '=', $seckill_id ] ]);
  273. }
  274. model('promotion_seckill_goods')->addList($add_goods_data);
  275. foreach ($seckill_time_id as $v) {
  276. $count = model('promotion_seckill_goods')->getCount([ [ 'seckill_time_id', 'like', '%,' . $v . ',%' ] ], '*', 'a', '', 'goods_id');
  277. model('promotion_seckill_time')->update([ 'goods_num' => $count ], [ [ 'id', '=', $v ] ]);
  278. }
  279. model('promotion_seckill')->commit();
  280. return $this->success();
  281. } catch (\Exception $e) {
  282. model('promotion_seckill')->rollback();
  283. return $this->error('', $e->getMessage());
  284. }
  285. }
  286. /**
  287. * 修改秒杀商品
  288. * @param unknown $seckill_id
  289. * @param unknown $site_id
  290. * @param unknown $sku_id
  291. * @param unknown $price
  292. * @return multitype:string
  293. */
  294. public function editSeckillGoods($data)
  295. {
  296. $cron = new Cron();
  297. if (empty($data[ 'seckill_time_id' ])) {
  298. return $this->error('', '请选择秒杀时段');
  299. }
  300. $seckill_time_id = explode(',', $data[ 'seckill_time_id' ]);
  301. //时间段检测
  302. foreach ($seckill_time_id as $v) {
  303. $seckill_count = model('promotion_seckill')->getInfo([
  304. [ 'goods_id', 'in', $data[ 'goods_ids' ] ],
  305. [ 'status', 'in', '0,1' ],
  306. [ 'site_id', '=', $data[ 'site_id' ] ],
  307. [ 'seckill_time_id', 'like', '%,' . $v . ',%' ],
  308. [ 'id', '<>', $data[ 'id' ] ],
  309. [ '', 'exp', Db::raw('not ( (`start_time` > ' . $data[ 'end_time' ] . ' and `start_time` > ' . $data[ 'start_time' ] . ' ) or (`end_time` < ' . $data[ 'start_time' ] . ' and `end_time` < ' . $data[ 'end_time' ] . '))') ]//todo 修正 所有的优惠都要一样
  310. ]);
  311. if ($seckill_count > 0) {
  312. return $this->error('', '有商品已设置秒杀,请不要重复设置');
  313. }
  314. }
  315. model('promotion_seckill')->startTrans();
  316. try {
  317. $seckill_data = [
  318. 'site_id' => $data[ 'site_id' ],
  319. 'seckill_name' => $data[ 'seckill_name' ],
  320. 'remark' => $data[ 'remark' ],
  321. 'seckill_time_id' => ',' . $data[ 'seckill_time_id' ] . ',',
  322. 'start_time' => $data[ 'start_time' ],
  323. 'end_time' => $data[ 'end_time' ],
  324. 'modify_time' => time(),
  325. 'sort' => $data[ 'sort' ],
  326. ];
  327. $seckill_data[ 'goods_id' ] = $data[ 'sku_list' ][ 0 ][ 'goods_id' ];
  328. $seckill_data[ 'goods_name' ] = $data[ 'sku_list' ][ 0 ][ 'sku_name' ];
  329. $seckill_data[ 'goods_image' ] = $data[ 'sku_list' ][ 0 ][ 'sku_image' ];
  330. $seckill_data[ 'seckill_price' ] = $data[ 'sku_list' ][ 0 ][ 'seckill_price' ];
  331. $goods = new Goods();
  332. if ($data[ 'start_time' ] <= time()) {
  333. $seckill_data[ 'status' ] = 1;//直接启动
  334. model('promotion_seckill')->update($seckill_data, [ [ 'id', '=', $data[ 'id' ] ] ]);
  335. $goods->modifyPromotionAddon($data[ 'sku_list' ][ 0 ][ 'goods_id' ], [ 'seckill' => $data[ 'id' ] ]);
  336. $cron->addCron(1, 0, "秒杀关闭", "CloseSeckill", $data[ 'end_time' ], $data[ 'id' ]);
  337. } else {
  338. $seckill_data[ 'status' ] = 0;
  339. model('promotion_seckill')->update($seckill_data, [ [ 'id', '=', $data[ 'id' ] ] ]);
  340. $cron->addCron(1, 0, "秒杀开启", "OpenSeckill", $data[ 'start_time' ], $data[ 'id' ]);
  341. $cron->addCron(1, 0, "秒杀关闭", "CloseSeckill", $data[ 'end_time' ], $data[ 'id' ]);
  342. }
  343. model('promotion_seckill_goods')->delete([ [ 'seckill_id', '=', $data[ 'id' ] ] ]);
  344. $goods_stock = 0; // 秒杀商品总库存
  345. foreach ($data[ 'sku_list' ] as $key => $item) {
  346. $sku_info = model('goods_sku')->getInfo([ [ 'sku_id', '=', $item[ 'sku_id' ] ] ], 'goods_id, sku_id, sku_name,price,sku_image');
  347. $add_goods_data[] = [
  348. 'site_id' => $data[ 'site_id' ],
  349. 'seckill_id' => $data[ 'id' ],
  350. 'seckill_time_id' => ',' . $data[ 'seckill_time_id' ] . ',',
  351. 'sku_id' => $item[ 'sku_id' ],
  352. 'goods_id' => $item[ 'goods_id' ],
  353. 'sku_image' => $sku_info[ 'sku_image' ],
  354. 'sku_name' => $sku_info[ 'sku_name' ],
  355. 'seckill_price' => $item[ 'seckill_price' ],
  356. 'price' => $sku_info[ 'price' ],
  357. 'stock' => $item[ 'seckill_stock' ],
  358. 'max_buy' => $item[ 'max_buy' ],
  359. 'status' => $seckill_data[ 'status' ]
  360. ];
  361. $goods_stock += $item[ 'seckill_stock' ];
  362. }
  363. model('promotion_seckill')->update([ 'goods_stock' => $goods_stock ], [ [ 'id', '=', $data[ 'id' ] ] ]);
  364. model('promotion_seckill_goods')->addList($add_goods_data);
  365. foreach ($seckill_time_id as $v) {
  366. $count = model('promotion_seckill_goods')->getCount([ [ 'seckill_time_id', 'like', '%,' . $v . ',%' ] ], '*', 'a', '', 'goods_id');
  367. model('promotion_seckill_time')->update([ 'goods_num' => $count ], [ [ 'id', '=', $v ] ]);
  368. }
  369. model('promotion_seckill')->commit();
  370. return $this->success();
  371. } catch (\Exception $e) {
  372. model('promotion_seckill')->rollback();
  373. return $this->error('', $e->getMessage());
  374. }
  375. }
  376. public function seckillSort($id, $sort)
  377. {
  378. $res = model('promotion_seckill')->update([ 'sort' => $sort ], [ [ 'id', '=', $id ] ]);
  379. return $this->success($res);
  380. }
  381. /**
  382. * 秒杀商品详情
  383. * @param unknown $seckill_id
  384. * @param unknown $site_id
  385. * @param unknown $sku_id
  386. * @param unknown $price
  387. * @return multitype:string
  388. */
  389. public function getSeckillDetail($condition = [], $field = '*', $alias = '', $join = [])
  390. {
  391. $info = model("promotion_seckill")->getInfo($condition, $field, $alias, $join);
  392. $goods_sku = model('goods_sku')->getList([ [ 'goods_id', '=', $info[ 'goods_id' ] ], [ 'is_delete', '=', 0 ], [ 'goods_state', '=', 1 ] ], 'stock as goods_stock, goods_id, sku_id, sku_name,price,sku_image,stock,sort');
  393. $discount_goods = model("promotion_seckill_goods")->getList([ [ 'goods_id', '=', $info[ 'goods_id' ] ], [ 'seckill_id', '=', $info[ 'id' ] ] ], '*');
  394. foreach ($goods_sku as $k => $v) {
  395. $goods_sku[ $k ][ 'is_select' ] = 0;
  396. $goods_sku[ $k ][ 'seckill_price' ] = $v[ 'price' ];
  397. $goods_sku[ $k ][ 'seckill_stock' ] = 0;
  398. $goods_sku[ $k ][ 'max_buy' ] = 0;
  399. $goods_sku[ $k ][ 'stock' ] = numberFormat($goods_sku[ $k ][ 'stock' ]);
  400. $goods_sku[ $k ][ 'goods_stock' ] = numberFormat($goods_sku[ $k ][ 'goods_stock' ]);
  401. foreach ($discount_goods as $key => $val) {
  402. if ($val[ 'sku_id' ] == $v[ 'sku_id' ]) {
  403. $goods_sku[ $k ][ 'is_select' ] = 1;
  404. $goods_sku[ $k ][ 'seckill_price' ] = $val[ 'seckill_price' ];
  405. $goods_sku[ $k ][ 'seckill_stock' ] = $val[ 'stock' ];
  406. $goods_sku[ $k ][ 'max_buy' ] = $val[ 'max_buy' ];
  407. }
  408. }
  409. }
  410. $info[ 'goods_sku' ] = $goods_sku;
  411. $info[ 'seckill_goods' ] = $discount_goods;
  412. return $this->success($info);
  413. }
  414. /**
  415. * 修改秒杀商品限购数量
  416. * @param unknown $seckill_id
  417. * @param unknown $site_id
  418. * @param unknown $sku_id
  419. * @param unknown $price
  420. * @return multitype:string
  421. */
  422. public function editSeckillGoodsNum($seckill_id, $site_id, $sku_id, $max_buy)
  423. {
  424. $data = [
  425. 'seckill_id' => $seckill_id,
  426. 'site_id' => $site_id,
  427. 'sku_id' => $sku_id,
  428. 'max_buy' => $max_buy
  429. ];
  430. model("promotion_seckill_goods")->update($data, [ [ 'seckill_id', '=', $seckill_id ], [ 'sku_id', '=', $sku_id ], [ 'site_id', '=', $site_id ] ]);
  431. return $this->success();
  432. }
  433. /**
  434. * 删除秒杀商品
  435. * @param unknown $seckill_id
  436. * @param int $site_id
  437. * @param unknown $sku_id
  438. * @return multitype:string
  439. */
  440. public function deleteSeckillGoods($seckill_id, $site_id)
  441. {
  442. $info = model("promotion_seckill")->getInfo([ [ 'id', '=', $seckill_id ] ], 'goods_id,seckill_time_id');
  443. $goods = new Goods();
  444. $goods->modifyPromotionAddon($info[ 'goods_id' ], [ 'seckill' => $seckill_id ], true);
  445. model("promotion_seckill")->delete([ [ 'id', '=', $seckill_id ], [ 'site_id', '=', $site_id ] ]);
  446. $goods_num = model("promotion_seckill_goods")->delete([ [ 'seckill_id', '=', $seckill_id ], [ 'site_id', '=', $site_id ] ]);
  447. $seckill_time_id = explode(',', $info[ 'seckill_time_id' ]);
  448. foreach ($seckill_time_id as $v) {
  449. $count = model('promotion_seckill_goods')->getCount([ [ 'seckill_time_id', 'like', '%,' . $v . ',%' ] ], '*', 'a', '', 'goods_id');
  450. model('promotion_seckill_time')->update([ 'goods_num' => $count ], [ [ 'id', '=', $v ] ]);
  451. }
  452. return $this->success();
  453. }
  454. /**
  455. * 获取秒杀详情
  456. * @param array $condition
  457. * @param string $field
  458. * @return mixed
  459. */
  460. public function getSeckillInfo($seckill_id)
  461. {
  462. $seckill_info = model('promotion_seckill')->getInfo([ [ 'id', '=', $seckill_id ] ]);
  463. if (empty($seckill_info)) {
  464. return $this->success([]);
  465. }
  466. $seckill_info[ 'seckill_start_time' ] = 0;
  467. $seckill_info[ 'seckill_end_time' ] = 0;
  468. $today_time = strtotime(date("Y-m-d"), time());
  469. $time = time() - $today_time;//当日时间戳
  470. $seckill_time_id = trim($seckill_info[ 'seckill_time_id' ], ',');
  471. $condition = [
  472. [ 'id', 'in', $seckill_time_id ],
  473. [ 'seckill_start_time', '<=', $time ],
  474. [ 'seckill_end_time', '>', $time ],
  475. ];
  476. $time_list = model('promotion_seckill_time')->getList($condition, 'seckill_start_time, seckill_end_time', 'seckill_start_time asc', '', '', '', 1);
  477. if (count($time_list) > 0) {
  478. $seckill_info[ 'seckill_start_time' ] = $time_list[ 0 ][ 'seckill_start_time' ];
  479. $seckill_info[ 'seckill_end_time' ] = $time_list[ 0 ][ 'seckill_end_time' ];
  480. }
  481. return $this->success($seckill_info);
  482. }
  483. /**
  484. * 获取秒杀列表
  485. * @param array $condition
  486. * @param int $page
  487. * @param int $page_size
  488. * @param string $order
  489. * @param string $field
  490. * @return mixed
  491. */
  492. public function getSeckillPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = '', $field = '', $alias = '', $join = [])
  493. {
  494. $list = model('promotion_seckill')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
  495. return $this->success($list);
  496. }
  497. /**
  498. * 获取秒杀商品列表
  499. * @param array $condition
  500. * @param int $page
  501. * @param int $page_size
  502. * @param string $order
  503. * @param string $field
  504. * @return mixed
  505. */
  506. public function getSeckillGoodsPageList($seckill_time_id, $site_id, $page = 1, $page_size = PAGE_LIST_ROWS)
  507. {
  508. $order = 'nps.sort asc';
  509. $alias = 'nps';
  510. // [ 'nps.goods_stock', '>', 0 ],
  511. $condition = [
  512. [ 'nps.seckill_time_id', 'like', '%,' . $seckill_time_id . ',%' ],
  513. [ 'nps.status', '=', 1 ],
  514. [ 'g.goods_state', '=', 1 ],
  515. [ 'g.is_delete', '=', 0 ],
  516. [ 'nps.site_id', '=', $site_id ]
  517. ];
  518. $field = 'nps.id,nps.site_id,nps.seckill_name,nps.status,nps.remark,nps.start_time,nps.end_time,
  519. nps.goods_id,nps.seckill_time_id,nps.seckill_price,nps.sale_num,nps.goods_stock,
  520. g.goods_name,g.goods_image,g.price';
  521. $join = [
  522. [ 'goods g', 'nps.goods_id = g.goods_id', 'inner' ]
  523. ];
  524. $res = model('promotion_seckill')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
  525. foreach ($res[ 'list' ] as $k => $v) {
  526. $res[ 'list' ][ $k ][ 'goods_stock' ] = numberFormat($res[ 'list' ][ $k ][ 'goods_stock' ]);
  527. }
  528. return $this->success($res);
  529. }
  530. /**
  531. * 获取秒杀商品列表
  532. * @param array $condition
  533. * @param string $order
  534. * @param string $field
  535. * @return mixed
  536. */
  537. public function getSeckillList($seckill_time_id, $site_id, $limit = null)
  538. {
  539. $order = 'nps.sort asc';
  540. $alias = 'nps';
  541. // [ 'nps.goods_stock', '>', 0 ],
  542. $condition = [
  543. [ 'nps.seckill_time_id', 'like', '%,' . $seckill_time_id . ',%' ],
  544. [ 'nps.status', '=', 1 ],
  545. [ 'g.goods_state', '=', 1 ],
  546. [ 'g.is_delete', '=', 0 ],
  547. [ 'nps.site_id', '=', $site_id ]
  548. ];
  549. $field = 'nps.id,nps.site_id,nps.seckill_name,nps.status,nps.remark,nps.start_time,nps.end_time,
  550. nps.goods_id,nps.seckill_time_id,nps.seckill_price,nps.sale_num,nps.goods_stock,
  551. g.goods_name,g.goods_image,g.price';
  552. $join = [
  553. [ 'goods g', 'nps.goods_id = g.goods_id', 'inner' ]
  554. ];
  555. $list = model('promotion_seckill')->getList($condition, $field, $order, $alias, $join, '', $limit);
  556. foreach ($list as $k => $v) {
  557. $list[ $k ][ 'goods_stock' ] = numberFormat($list[ $k ][ 'goods_stock' ]);
  558. }
  559. return $this->success($list);
  560. }
  561. /**
  562. * 启动秒杀事件
  563. * @param unknown $seckill_id
  564. */
  565. public function cronOpenSeckill($seckill_id)
  566. {
  567. $seckill_info = model('promotion_seckill')->getInfo([ [ 'id', '=', $seckill_id ] ], 'start_time,status, goods_id');
  568. if (!empty($seckill_info)) {
  569. if ($seckill_info[ 'start_time' ] <= time() && $seckill_info[ 'status' ] == 0) {
  570. model('promotion_seckill')->update([ 'status' => 1 ], [ [ 'id', '=', $seckill_id ] ]);
  571. model('promotion_seckill_goods')->update([ 'status' => 1 ], [ [ 'seckill_id', '=', $seckill_id ] ]);
  572. $goods = new Goods();
  573. $goods->modifyPromotionAddon($seckill_info[ 'goods_id' ], [ 'seckill' => $seckill_id ]);
  574. return $this->success(1);
  575. } else {
  576. return $this->error("", "秒杀已开启或者关闭");
  577. }
  578. } else {
  579. return $this->error("", "秒杀不存在");
  580. }
  581. }
  582. /**
  583. * 结束秒杀事件
  584. * @param unknown $seckill_id
  585. */
  586. public function cronCloseSeckill($seckill_id)
  587. {
  588. $seckill_info = model('promotion_seckill')->getInfo([ [ 'id', '=', $seckill_id ] ], 'start_time,status, goods_id');
  589. if (!empty($seckill_info)) {
  590. //针对正在进行的活动
  591. if ($seckill_info[ 'status' ] == 1) {
  592. model('promotion_seckill')->update([ 'status' => 2 ], [ [ 'id', '=', $seckill_id ] ]);
  593. model('promotion_seckill_goods')->update([ 'status' => 2 ], [ [ 'seckill_id', '=', $seckill_id ] ]);
  594. $goods = new Goods();
  595. $goods->modifyPromotionAddon($seckill_info[ 'goods_id' ], [ 'seckill' => $seckill_id ], true);
  596. return $this->success();
  597. } else {
  598. return $this->error("", "正在进行的秒杀才能进行关闭操作");
  599. }
  600. } else {
  601. return $this->error("", "活动不存在");
  602. }
  603. }
  604. /**
  605. * 手动结束秒杀事件
  606. * @param unknown $seckill_id
  607. */
  608. public function closeSeckill($seckill_id)
  609. {
  610. $seckill_info = model('promotion_seckill')->getInfo([ [ 'id', '=', $seckill_id ] ], 'start_time,status, goods_id');
  611. if (!empty($seckill_info)) {
  612. //针对正在进行的活动
  613. if ($seckill_info[ 'status' ] == 1) {
  614. model('promotion_seckill')->update([ 'status' => -1 ], [ [ 'id', '=', $seckill_id ] ]);
  615. model('promotion_seckill_goods')->update([ 'status' => -1 ], [ [ 'seckill_id', '=', $seckill_id ] ]);
  616. $goods = new Goods();
  617. $goods->modifyPromotionAddon($seckill_info[ 'goods_id' ], [ 'seckill' => $seckill_id ], true);
  618. return $this->success();
  619. } else {
  620. return $this->error("", "正在进行的秒杀才能进行关闭操作");
  621. }
  622. } else {
  623. return $this->error("", "活动不存在");
  624. }
  625. }
  626. /**
  627. * 获取商品列表
  628. * @param $discount_id
  629. * @param $site_id
  630. * @return array
  631. */
  632. public function getSeckillGoodsList($seckill_id)
  633. {
  634. $field = 'psg.*,sku.sku_name,sku.price,sku.sku_image';
  635. $alias = 'psg';
  636. $join = [
  637. [
  638. 'goods g',
  639. 'g.goods_id = psg.goods_id',
  640. 'inner'
  641. ],
  642. [
  643. 'goods_sku sku',
  644. 'sku.sku_id = psg.sku_id',
  645. 'inner'
  646. ]
  647. ];
  648. $condition = [
  649. [ 'psg.seckill_id', '=', $seckill_id ],
  650. [ 'g.is_delete', '=', 0 ], [ 'g.goods_state', '=', 1 ]
  651. ];
  652. $list = model('promotion_seckill_goods')->getList($condition, $field, '', $alias, $join);
  653. return $this->success($list);
  654. }
  655. /**
  656. * 获取秒杀商品信息
  657. * @param array $condition
  658. * @param string $field
  659. * @return array
  660. */
  661. public function getSeckillGoodsInfo($condition = [], $field = '')
  662. {
  663. if (empty($field)) {
  664. $field = 'psg.id,psg.seckill_id,ps.goods_id,psg.sku_id,psg.seckill_price,psg.max_buy,psg.stock,
  665. ps.status,ps.start_time,ps.end_time,(ps.sale_num + g.virtual_sale) as sale_num,ps.remark,
  666. sku.site_id,sku.sku_name,sku.sku_spec_format,sku.price,sku.promotion_type,
  667. sku.click_num,sku.collect_num,sku.sku_image,sku.sku_images,
  668. sku.goods_content,sku.goods_state,sku.is_virtual,sku.is_free_shipping,
  669. sku.goods_spec_format,sku.goods_attr_format,sku.introduction,sku.unit,
  670. sku.video_url,g.evaluate,sku.goods_service_ids,sku.support_trade_type,g.goods_image,
  671. ps.goods_stock,g.goods_name,sku.qr_id,g.stock_show,g.sale_show,g.label_name,g.category_id';
  672. }
  673. $join = [
  674. [ 'goods_sku sku', 'psg.sku_id = sku.sku_id', 'inner' ],
  675. [ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
  676. [ 'promotion_seckill ps', 'ps.id = psg.seckill_id', 'inner' ],
  677. ];
  678. $seckill_goods_info = model('promotion_seckill_goods')->getInfo($condition, $field, 'psg', $join);
  679. if (!empty($seckill_goods_info)) {
  680. if (isset($seckill_goods_info[ 'sale_num' ])) {
  681. $seckill_goods_info[ 'sale_num' ] = numberFormat($seckill_goods_info[ 'sale_num' ]);
  682. }
  683. if (isset($seckill_goods_info[ 'goods_stock' ])) {
  684. $seckill_goods_info[ 'goods_stock' ] = numberFormat($seckill_goods_info[ 'goods_stock' ]);
  685. }
  686. }
  687. return $this->success($seckill_goods_info);
  688. }
  689. /**
  690. * 获取秒杀商品信息
  691. * @param array $condition
  692. * @param string $field
  693. * @return array
  694. */
  695. public function getSeckillGoodsSkuList($condition = [])
  696. {
  697. $field = 'psg.id,psg.seckill_id,ps.goods_id,psg.sku_id,psg.seckill_price,psg.max_buy,psg.stock,
  698. ps.status,ps.start_time,ps.end_time,ps.sale_num,sku.sku_name,sku.sku_spec_format,sku.price,sku.sku_image,sku.sku_images,sku.goods_spec_format,g.goods_image,ps.goods_stock';
  699. $join = [
  700. [ 'goods_sku sku', 'psg.sku_id = sku.sku_id', 'inner' ],
  701. [ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
  702. [ 'promotion_seckill ps', 'ps.id = psg.seckill_id', 'inner' ],
  703. ];
  704. $list = model('promotion_seckill_goods')->getList($condition, $field, 'psg.id asc', 'psg', $join);
  705. foreach ($list as $k => $v) {
  706. $list[ $k ][ 'goods_stock' ] = numberFormat($list[ $k ][ 'goods_stock' ]);
  707. }
  708. return $this->success($list);
  709. }
  710. /**
  711. * 判断规格值是否禁用
  712. * @param $seckill_id
  713. * @param $site_id
  714. * @param $goods
  715. * @return false|string
  716. */
  717. public function getGoodsSpecFormat($seckill_id, $site_id, $goods_spec_format = '', $sku_id = 0)
  718. {
  719. //获取活动参与的商品sku_ids
  720. $sku_ids = model('promotion_seckill_goods')->getColumn([ [ 'seckill_id', '=', $seckill_id ], [ 'site_id', '=', $site_id ] ], 'sku_id');
  721. $goods_model = new Goods();
  722. if ($sku_id == 0) {
  723. $res = $goods_model->getGoodsSpecFormat($sku_ids, $goods_spec_format);
  724. } else {
  725. $res = $goods_model->getEmptyGoodsSpecFormat($sku_ids, $sku_id);
  726. }
  727. return $res;
  728. }
  729. /**
  730. * 生成砍价二维码
  731. * @param $seckill_id
  732. * @param string $name
  733. * @param string $type 类型 create创建 get获取
  734. * @return mixed|array
  735. */
  736. public function qrcode($seckill_id, $name, $site_id, $type = 'create')
  737. {
  738. $data = [
  739. 'site_id' => $site_id,
  740. 'app_type' => "all", // all为全部
  741. 'type' => $type, // 类型 create创建 get获取
  742. 'data' => [
  743. "seckill_id" => $seckill_id
  744. ],
  745. 'page' => '/pages_promotion/seckill/detail',
  746. 'qrcode_path' => 'upload/qrcode/seckill',
  747. 'qrcode_name' => "seckill_qrcode_" . $seckill_id
  748. ];
  749. event('Qrcode', $data, true);
  750. $app_type_list = config('app_type');
  751. $path = [];
  752. foreach ($app_type_list as $k => $v) {
  753. switch ( $k ) {
  754. case 'h5':
  755. $wap_domain = getH5Domain();
  756. $path[ $k ][ 'status' ] = 1;
  757. $path[ $k ][ 'url' ] = $wap_domain . $data[ 'page' ] . '?id=' . $seckill_id;
  758. $path[ $k ][ 'img' ] = "upload/qrcode/seckill/seckill_qrcode_" . $seckill_id . "_" . $k . ".png";
  759. break;
  760. case 'weapp' :
  761. $config = new ConfigModel();
  762. $res = $config->getConfig([ [ 'site_id', '=', $site_id ], [ 'app_module', '=', 'shop' ], [ 'config_key', '=', 'WEAPP_CONFIG' ] ]);
  763. if (!empty($res[ 'data' ])) {
  764. if (empty($res[ 'data' ][ 'value' ][ 'qrcode' ])) {
  765. $path[ $k ][ 'status' ] = 2;
  766. $path[ $k ][ 'message' ] = '未配置微信小程序';
  767. } else {
  768. $path[ $k ][ 'status' ] = 1;
  769. $path[ $k ][ 'img' ] = $res[ 'data' ][ 'value' ][ 'qrcode' ];
  770. }
  771. } else {
  772. $path[ $k ][ 'status' ] = 2;
  773. $path[ $k ][ 'message' ] = '未配置微信小程序';
  774. }
  775. break;
  776. case 'wechat' :
  777. $config = new ConfigModel();
  778. $res = $config->getConfig([ [ 'site_id', '=', $site_id ], [ 'app_module', '=', 'shop' ], [ 'config_key', '=', 'WECHAT_CONFIG' ] ]);
  779. if (!empty($res[ 'data' ])) {
  780. if (empty($res[ 'data' ][ 'value' ][ 'qrcode' ])) {
  781. $path[ $k ][ 'status' ] = 2;
  782. $path[ $k ][ 'message' ] = '未配置微信公众号';
  783. } else {
  784. $path[ $k ][ 'status' ] = 1;
  785. $path[ $k ][ 'img' ] = $res[ 'data' ][ 'value' ][ 'qrcode' ];
  786. }
  787. } else {
  788. $path[ $k ][ 'status' ] = 2;
  789. $path[ $k ][ 'message' ] = '未配置微信公众号';
  790. }
  791. break;
  792. }
  793. }
  794. $return = [
  795. 'path' => $path,
  796. 'name' => $name,
  797. ];
  798. return $this->success($return);
  799. }
  800. public function urlQrcode($page, $qrcode_param, $promotion_type, $site_id)
  801. {
  802. $params = [
  803. 'site_id' => $site_id,
  804. 'data' => $qrcode_param,
  805. 'page' => $page,
  806. 'promotion_type' => $promotion_type,
  807. 'h5_path' => $page . '?id=' . $qrcode_param[ 'id' ],
  808. 'qrcode_path' => 'upload/qrcode/seckill',
  809. 'qrcode_name' => 'seckill_qrcode_' . $promotion_type . '_' . $qrcode_param[ 'id' ] . '_' . $site_id,
  810. ];
  811. $solitaire = event('ExtensionInformation', $params, true);
  812. return $this->success($solitaire);
  813. }
  814. }