SeckillOrderCreate.php 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783
  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 addon\store\model\StoreGoodsSku;
  12. use app\model\order\Order;
  13. use app\model\order\OrderCreate;
  14. use app\model\order\OrderCreateTool;
  15. use app\model\order\OrderRefund;
  16. use app\model\store\Store;
  17. use think\facade\Cache;
  18. use app\model\express\Express;
  19. use app\model\system\Pay;
  20. use app\model\express\Config as ExpressConfig;
  21. use app\model\order\Config;
  22. use app\model\express\Local;
  23. /**
  24. * 订单创建(秒杀)
  25. *
  26. * @author Administrator
  27. *
  28. */
  29. class SeckillOrderCreate extends OrderCreate
  30. {
  31. use OrderCreateTool;
  32. private $goods_money = 0;//商品金额
  33. private $balance_money = 0;//余额
  34. private $delivery_money = 0;//配送费用
  35. private $coupon_money = 0;//优惠券金额
  36. private $adjust_money = 0;//调整金额
  37. private $invoice_money = 0;//发票费用
  38. private $promotion_money = 0;//优惠金额
  39. private $order_money = 0;//订单金额
  40. private $pay_money = 0;//支付总价
  41. private $is_virtual = 0; //是否是虚拟类订单
  42. private $order_name = ''; //订单详情
  43. private $goods_num = 0; //商品种数
  44. private $member_balance_money = 0;//会员账户余额(计算过程中会逐次减少)
  45. private $pay_type = 'ONLINE_PAY';//支付方式
  46. private $invoice_delivery_money = 0;
  47. private $error = 0; //是否有错误
  48. private $error_msg = ''; //错误描述
  49. /**
  50. * 订单创建
  51. * @param unknown $data
  52. */
  53. public function create($data)
  54. {
  55. //查询出会员相关信息
  56. $calculate_data = $this->calculate($data);
  57. if (isset($calculate_data[ 'code' ]) && $calculate_data[ 'code' ] < 0)
  58. return $calculate_data;
  59. if ($this->error > 0) {
  60. return $this->error([ 'error_code' => $this->error ], $this->error_msg);
  61. }
  62. if (!empty($calculate_data[ 'invoice_type' ])) {
  63. if ($calculate_data[ 'invoice_type' ] == 1 && $calculate_data[ 'invoice_full_address' ] == "") {
  64. //物流,同城
  65. if ($calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "express" || $calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "local") {
  66. $calculate_data[ 'invoice_full_address' ] = $calculate_data[ 'member_address' ][ 'full_address' ] . $calculate_data[ 'member_address' ][ 'address' ];
  67. $calculate_data[ 'shop_goods_list' ][ 'invoice_full_address' ] = $calculate_data[ 'member_address' ][ 'full_address' ] . $calculate_data[ 'member_address' ][ 'address' ];
  68. }
  69. //门店
  70. if ($calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "store") {
  71. $delivery_store_info = json_decode($calculate_data[ 'shop_goods_list' ][ 'delivery_store_info' ], true);
  72. $calculate_data[ 'invoice_full_address' ] = $delivery_store_info[ 'full_address' ];
  73. $calculate_data[ 'shop_goods_list' ][ 'invoice_full_address' ] = $delivery_store_info[ 'full_address' ];
  74. }
  75. }
  76. }
  77. $pay = new Pay();
  78. $out_trade_no = $pay->createOutTradeNo($data[ 'member_id' ]);
  79. model('order')->startTrans();
  80. //循环生成多个订单
  81. try {
  82. $pay_money = 0;
  83. $shop_goods_list = $calculate_data[ 'shop_goods_list' ];
  84. $item_delivery = $shop_goods_list[ 'delivery' ] ?? [];
  85. $delivery_type = $item_delivery[ 'delivery_type' ] ?? '';
  86. $site_id = $data[ 'site_id' ];
  87. $delivery_type = $item_delivery[ 'delivery_type' ] ?? '';
  88. $express_type_list = ( new \app\model\express\Config() )->getExpressTypeList($site_id);
  89. // $delivery_type_name = Express::express_type[$delivery_type]['title'] ?? '';
  90. $delivery_type_name = $express_type_list[ $delivery_type ] ?? '';
  91. //订单主表
  92. $order_type = $this->orderType($shop_goods_list, $calculate_data);
  93. $order_no = $this->createOrderNo($shop_goods_list[ 'site_id' ], $data[ 'member_id' ]);
  94. $data_order = [
  95. 'order_no' => $order_no,
  96. 'site_id' => $shop_goods_list[ 'site_id' ],
  97. 'site_name' => $shop_goods_list[ 'site_name' ],
  98. 'order_from' => $data[ 'order_from' ],
  99. 'order_from_name' => $data[ 'order_from_name' ],
  100. 'order_type' => $order_type[ 'order_type_id' ],
  101. 'order_type_name' => $order_type[ 'order_type_name' ],
  102. 'order_status_name' => $order_type[ 'order_status' ][ 'name' ],
  103. 'order_status_action' => json_encode($order_type[ 'order_status' ], JSON_UNESCAPED_UNICODE),
  104. 'out_trade_no' => $out_trade_no,
  105. 'member_id' => $data[ 'member_id' ],
  106. 'name' => $calculate_data[ 'member_address' ][ 'name' ] ?? '',
  107. 'mobile' => $calculate_data[ 'member_address' ][ 'mobile' ] ?? '',
  108. 'telephone' => $calculate_data[ 'member_address' ][ 'telephone' ] ?? '',
  109. 'province_id' => $calculate_data[ 'member_address' ][ 'province_id' ] ?? '',
  110. 'city_id' => $calculate_data[ 'member_address' ][ 'city_id' ] ?? '',
  111. 'district_id' => $calculate_data[ 'member_address' ][ 'district_id' ] ?? '',
  112. 'community_id' => $calculate_data[ 'member_address' ][ 'community_id' ] ?? '',
  113. 'address' => $calculate_data[ 'member_address' ][ 'address' ] ?? '',
  114. 'full_address' => $calculate_data[ 'member_address' ][ 'full_address' ] ?? '',
  115. 'longitude' => $calculate_data[ 'member_address' ][ 'longitude' ] ?? '',
  116. 'latitude' => $calculate_data[ 'member_address' ][ 'latitude' ] ?? '',
  117. 'buyer_ip' => request()->ip(),
  118. 'goods_money' => $shop_goods_list[ 'goods_money' ],
  119. 'delivery_money' => $shop_goods_list[ 'delivery_money' ],
  120. 'coupon_id' => isset($shop_goods_list[ 'coupon_id' ]) ? $shop_goods_list[ 'coupon_id' ] : 0,
  121. 'coupon_money' => $shop_goods_list[ 'coupon_money' ] ?? 0,
  122. 'adjust_money' => $shop_goods_list[ 'adjust_money' ],
  123. 'invoice_money' => $shop_goods_list[ 'invoice_money' ],
  124. 'promotion_money' => $shop_goods_list[ 'promotion_money' ],
  125. 'order_money' => $shop_goods_list[ 'order_money' ],
  126. 'balance_money' => $shop_goods_list[ 'balance_money' ],
  127. 'pay_money' => $shop_goods_list[ 'pay_money' ],
  128. 'create_time' => time(),
  129. 'is_enable_refund' => 0,
  130. 'order_name' => $shop_goods_list[ "order_name" ],
  131. 'goods_num' => $shop_goods_list[ 'goods_num' ],
  132. 'delivery_type' => $delivery_type,
  133. 'delivery_type_name' => $delivery_type_name,
  134. 'delivery_store_id' => $shop_goods_list[ "delivery_store_id" ] ?? 0,
  135. "delivery_store_name" => $shop_goods_list[ "delivery_store_name" ] ?? '',
  136. "delivery_store_info" => $shop_goods_list[ "delivery_store_info" ] ?? '',
  137. "buyer_message" => $data[ "buyer_message" ],
  138. "promotion_type" => "seckill",
  139. "promotion_type_name" => "秒杀",
  140. "promotion_status_name" => "",
  141. "promotion_id" => $calculate_data[ "seckill_info" ][ "id" ],
  142. "invoice_delivery_money" => $shop_goods_list[ "invoice_delivery_money" ] ?? 0,
  143. "taxpayer_number" => $shop_goods_list[ "taxpayer_number" ] ?? '',
  144. "invoice_rate" => $shop_goods_list[ "invoice_rate" ] ?? 0,
  145. "invoice_content" => $shop_goods_list[ "invoice_content" ] ?? '',
  146. "invoice_full_address" => $shop_goods_list[ "invoice_full_address" ] ?? '',
  147. "is_invoice" => $shop_goods_list[ "is_invoice" ] ?? 0,
  148. "invoice_type" => $shop_goods_list[ "invoice_type" ] ?? 0,
  149. "invoice_title" => $shop_goods_list[ "invoice_title" ] ?? '',
  150. 'is_tax_invoice' => $shop_goods_list[ "is_tax_invoice" ] ?? '',
  151. 'invoice_email' => $shop_goods_list[ "invoice_email" ] ?? '',
  152. 'invoice_title_type' => $shop_goods_list[ "invoice_title_type" ] ?? 0,
  153. 'buyer_ask_delivery_time' => $shop_goods_list[ 'buyer_ask_delivery_time' ] ?? '',
  154. 'store_id' => $shop_goods_list[ 'store_id' ]
  155. ];
  156. $order_id = model('order')->add($data_order);
  157. $pay_money += $shop_goods_list[ 'pay_money' ];
  158. //订单项目表
  159. foreach ($shop_goods_list[ 'goods_list' ] as $k_order_goods => $order_goods) {
  160. $data_order_goods = array (
  161. 'order_id' => $order_id,
  162. 'site_id' => $shop_goods_list[ 'site_id' ],
  163. 'order_no' => $order_no,
  164. 'member_id' => $data[ 'member_id' ],
  165. 'sku_id' => $order_goods[ 'sku_id' ],
  166. 'sku_name' => $order_goods[ 'sku_name' ],
  167. 'sku_image' => $order_goods[ 'sku_image' ],
  168. 'sku_no' => $order_goods[ 'sku_no' ],
  169. 'is_virtual' => $order_goods[ 'is_virtual' ],
  170. 'goods_class' => $order_goods[ 'goods_class' ],
  171. 'goods_class_name' => $order_goods[ 'goods_class_name' ],
  172. 'price' => $order_goods[ 'price' ],
  173. 'cost_price' => $order_goods[ 'cost_price' ],
  174. 'num' => $order_goods[ 'num' ],
  175. 'goods_money' => $order_goods[ 'goods_money' ],
  176. 'cost_money' => $order_goods[ 'cost_price' ] * $order_goods[ 'num' ],
  177. 'goods_id' => $order_goods[ 'goods_id' ],
  178. 'delivery_status' => 0,
  179. 'delivery_status_name' => "未发货",
  180. "real_goods_money" => $order_goods[ "real_goods_money" ],
  181. 'coupon_money' => $order_goods[ "coupon_money" ] ?? 0,
  182. 'promotion_money' => $order_goods[ "promotion_money" ],
  183. 'goods_name' => $order_goods[ 'goods_name' ],
  184. 'sku_spec_format' => $order_goods[ 'sku_spec_format' ],
  185. 'store_id' => $shop_goods_list[ 'store_id' ]
  186. );
  187. $order_goods_id = model('order_goods')->add($data_order_goods);
  188. $calculate_data[ 'shop_goods_list' ][ 'goods_list' ][ $k_order_goods ][ 'order_goods_id' ] = $order_goods_id;
  189. //库存变化
  190. $stock_result = $this->skuDecStock($order_goods, $shop_goods_list[ 'store_id' ]);
  191. if ($stock_result[ "code" ] != 0) {
  192. model('order')->rollback();
  193. return $stock_result;
  194. }
  195. model("promotion_seckill_goods")->setDec([ [ 'sku_id', '=', $order_goods[ 'sku_id' ] ], [ 'seckill_id', '=', $calculate_data[ "seckill_info" ][ "id" ] ] ], "stock", $order_goods[ 'num' ]);
  196. model("promotion_seckill")->setDec([ [ 'id', '=', $calculate_data[ "seckill_info" ][ "id" ] ] ], "goods_stock", $order_goods[ 'num' ]);
  197. // 增加销量
  198. model("promotion_seckill")->setInc([ [ 'id', '=', $calculate_data[ "seckill_info" ][ "id" ] ] ], "sale_num", $order_goods[ 'num' ]);
  199. }
  200. $result_list = event("OrderCreate", [ 'order_id' => $order_id, 'site_id' => $shop_goods_list[ 'site_id' ], 'create_data' => $calculate_data ]);
  201. if (!empty($result_list)) {
  202. foreach ($result_list as $k => $v) {
  203. if (!empty($v) && $v[ "code" ] < 0) {
  204. model('order')->rollback();
  205. return $v;
  206. }
  207. }
  208. }
  209. //扣除余额(统一扣除)
  210. if ($calculate_data[ "balance_money" ] > 0) {
  211. $this->pay_type = "BALANCE";
  212. $calculate_data[ 'order_id' ] = $order_id;
  213. $balance_result = $this->useBalance($calculate_data, $data[ 'site_id' ]);
  214. if ($balance_result[ "code" ] < 0) {
  215. model('order')->rollback();
  216. return $balance_result;
  217. }
  218. }
  219. //生成整体支付单据
  220. $pay->addPay($shop_goods_list[ 'site_id' ], $out_trade_no, $this->pay_type, $this->order_name, $this->order_name, $this->pay_money, '', 'OrderPayNotify', '');
  221. $this->addOrderCronClose($order_id, $shop_goods_list[ 'site_id' ]);//增加关闭订单自动事件
  222. Cache::tag("order_create_seckill_" . $data[ 'member_id' ])->clear();
  223. model('order')->commit();
  224. return $this->success($out_trade_no);
  225. } catch (\Exception $e) {
  226. model('order')->rollback();
  227. return $this->error('', $e->getMessage());
  228. }
  229. }
  230. public function verifyAreaOrStock($data)
  231. {
  232. //查询出会员相关信息
  233. $calculate_data = $this->calculate($data);
  234. if (isset($calculate_data[ 'code' ]) && $calculate_data[ 'code' ] < 0)
  235. return $calculate_data;
  236. if ($this->error > 0) {
  237. return $this->error([ 'error_code' => $this->error ], $this->error_msg);
  238. }
  239. if (!empty($data[ 'delivery' ][ 'delivery_type' ]) && $data[ 'delivery' ][ 'delivery_type' ] == 'store') {
  240. //商品列表信息
  241. $shop_goods_list = $this->getOrderGoodsCalculate($data);
  242. $goods_lists = $shop_goods_list[ 'goods_list' ];
  243. if (addon_is_exit('store')) {
  244. $store_goods_sku_model = new StoreGoodsSku();
  245. foreach ($goods_lists as $k => $v) {
  246. $condition = array (
  247. [ 'store_id', '=', $data[ 'delivery' ][ 'store_id' ] ],
  248. [ 'sku_id', '=', $v[ 'sku_id' ] ]
  249. );
  250. $store_sku_info = model('store_goods_sku')->getInfo($condition, 'id, goods_id, stock');
  251. if (empty($store_sku_info)) {
  252. return $store_goods_sku_model->error([ 'error_code' => 11 ], '当前门店库存不足,请选择其他门店');
  253. }
  254. $store_sku_info[ 'stock' ] = numberFormat($store_sku_info[ 'stock' ]);
  255. if (( $store_sku_info[ 'stock' ] - $v[ 'num' ] ) < 0) {
  256. return $store_goods_sku_model->error([ 'error_code' => 11 ], '当前门店库存不足,请选择其他门店');
  257. }
  258. }
  259. }
  260. }
  261. return $this->success(1);
  262. }
  263. /**
  264. * 订单计算
  265. * @param unknown $data
  266. */
  267. public function calculate($data)
  268. {
  269. $data = $this->initMemberAddress($data);
  270. $data = $this->initMemberAccount($data);//初始化会员账户
  271. //余额付款
  272. if ($data[ 'is_balance' ] > 0) {
  273. $this->member_balance_money = $data[ "member_account" ][ "balance_total" ] ?? 0;
  274. }
  275. //商品列表信息
  276. $shop_goods_list = $this->getOrderGoodsCalculate($data);
  277. //查询秒杀信息
  278. $seckill_model = new Seckill();
  279. $seckill_id = $shop_goods_list[ "goods_list" ][ 0 ][ "seckill_id" ];
  280. $seckill_info_result = $seckill_model->getSeckillInfo($seckill_id);
  281. $seckill_info = $seckill_info_result[ "data" ];
  282. if (empty($seckill_info)) {
  283. return $this->error([], "找不到可用的秒杀活动");
  284. }
  285. $data[ "seckill_info" ] = $seckill_info;
  286. //判断秒杀时间段是否符合
  287. $today_time = strtotime(date("Y-m-d"), time());
  288. $time = time() - $today_time;//当日时间戳
  289. if ($time < $seckill_info[ "seckill_start_time" ] || $time > $seckill_info[ "seckill_end_time" ]) {
  290. $this->error = 1;
  291. $this->error_msg = "当前商品秒杀活动未开启或已过期!";
  292. }
  293. //秒杀库存
  294. if ($shop_goods_list[ "goods_list" ][ 0 ]) {
  295. $seckill_goods = $seckill_model->getSeckillGoodsInfo([ [ 'psg.seckill_id', '=', $seckill_id ], [ 'psg.sku_id', '=', $shop_goods_list[ "goods_list" ][ 0 ][ 'sku_id' ] ] ], 'psg.stock');
  296. $seckill_goods_stock = $seckill_goods[ 'data' ][ 'stock' ];
  297. if ($shop_goods_list[ "goods_list" ][ 0 ][ 'num' ] > $seckill_goods_stock) {
  298. $this->error = 1;
  299. $this->error_msg = "该商品库存不足";
  300. }
  301. }
  302. // 秒杀商品限购 按每日某时段限购
  303. if ($shop_goods_list[ "goods_list" ][ 0 ][ 'limit_num' ] > 0) {
  304. $purchased_num = $this->getGoodsPurchasedNum($shop_goods_list[ "goods_list" ][ 0 ][ 'sku_id' ], $data[ 'member_id' ], $seckill_info[ 'id' ]);
  305. if (( $purchased_num + $shop_goods_list[ "goods_list" ][ 0 ][ 'num' ] ) > $shop_goods_list[ "goods_list" ][ 0 ][ 'limit_num' ]) {
  306. $this->error = 1;
  307. $this->error_msg = "该商品每人限购{$shop_goods_list[ "goods_list" ][ 0 ]['limit_num']}件,您已购买{$purchased_num}件";
  308. }
  309. }
  310. $data[ 'shop_goods_list' ] = $this->shopOrderCalculate($shop_goods_list, $data);
  311. //总结计算
  312. $data[ 'delivery_money' ] = $this->delivery_money;
  313. $data[ 'coupon_money' ] = $this->coupon_money;
  314. $data[ 'adjust_money' ] = $this->adjust_money;
  315. $data[ 'invoice_money' ] = $this->invoice_money;
  316. $data[ 'invoice_delivery_money' ] = $this->invoice_delivery_money;
  317. $data[ 'promotion_money' ] = $this->promotion_money;
  318. $data[ 'order_money' ] = $this->order_money;
  319. $data[ 'balance_money' ] = $this->balance_money;
  320. $data[ 'pay_money' ] = $this->pay_money;
  321. $data[ 'goods_money' ] = $this->goods_money;
  322. $data[ 'goods_num' ] = $this->goods_num;
  323. $data[ 'is_virtual' ] = $this->is_virtual;
  324. return $data;
  325. }
  326. /**
  327. * 待付款订单
  328. * @param unknown $data
  329. */
  330. public function orderPayment($data)
  331. {
  332. $calculate_data = $this->calculate($data);
  333. if (isset($calculate_data[ 'code' ]) && $calculate_data[ 'code' ] < 0)
  334. return $calculate_data;
  335. $shop_goods_list = $calculate_data[ 'shop_goods_list' ];
  336. $calculate_data[ 'shop_goods_list' ][ "coupon_list" ] = [];
  337. $express_type = [];
  338. if ($this->is_virtual == 0) {
  339. foreach ($calculate_data[ 'shop_goods_list' ][ 'deliver_sort' ] as $type) {
  340. // 物流
  341. if ($type == 'express' && $calculate_data[ 'shop_goods_list' ][ "express_config" ][ "is_use" ] == 1) {
  342. $title = $calculate_data[ 'shop_goods_list' ][ "express_config" ][ 'value' ][ 'express_name' ];
  343. if ($title == "") {
  344. $title = Express::express_type[ "express" ][ "title" ];
  345. }
  346. $express_type[] = [ "title" => $title, "name" => "express" ];
  347. }
  348. // 自提
  349. if ($type == 'store' && $calculate_data[ 'shop_goods_list' ][ "store_config" ][ "is_use" ] == 1) {
  350. //根据坐标查询门店
  351. $store_model = new Store();
  352. $store_condition = array (
  353. [ 'site_id', '=', $data[ 'site_id' ] ],
  354. [ 'is_pickup', '=', 1 ],
  355. [ 'status', '=', 1 ],
  356. [ 'is_frozen', '=', 0 ],
  357. );
  358. $latlng = array (
  359. 'lat' => $data[ 'latitude' ],
  360. 'lng' => $data[ 'longitude' ],
  361. );
  362. $store_list_result = $store_model->getLocationStoreList($store_condition, '*', $latlng);
  363. $store_list = $store_list_result[ "data" ];
  364. $title = $calculate_data[ 'shop_goods_list' ][ "store_config" ][ 'value' ][ 'store_name' ];
  365. if ($title == "") {
  366. $title = Express::express_type[ "store" ][ "title" ];
  367. }
  368. $express_type[] = [ "title" => $title, "name" => "store", "store_list" => $store_list ];
  369. }
  370. // 外卖
  371. if ($type == 'local' && $calculate_data[ 'shop_goods_list' ][ "local_config" ][ "is_use" ] == 1) {
  372. //查询本店的通讯地址
  373. $title = $calculate_data[ 'shop_goods_list' ][ "local_config" ][ 'value' ][ 'local_name' ];
  374. if ($title == "") {
  375. $title = '外卖配送';
  376. }
  377. $store_model = new Store();
  378. $store_condition = array (
  379. [ 'site_id', '=', $data[ 'site_id' ] ],
  380. );
  381. if (addon_is_exit('store', $data[ 'site_id' ])) {
  382. $store_condition[] = [ 'is_o2o', '=', 1 ];
  383. $store_condition[] = [ 'status', '=', 1 ];
  384. $store_condition[] = [ 'is_frozen', '=', 0 ];
  385. } else {
  386. $store_condition[] = [ 'is_default', '=', 1 ];
  387. }
  388. $latlng = array (
  389. 'lat' => $data[ 'latitude' ],
  390. 'lng' => $data[ 'longitude' ],
  391. );
  392. $store_list_result = $store_model->getLocationStoreList($store_condition, '*', $latlng);
  393. $store_list = $store_list_result[ 'data' ];
  394. $express_type[] = [ "title" => $title, "name" => "local", 'store_list' => $store_list ];
  395. }
  396. }
  397. }
  398. $calculate_data[ 'shop_goods_list' ][ "express_type" ] = $express_type;
  399. $payment_event_data = event('OrderPayment', $calculate_data);
  400. if (!empty($payment_event_data)) {
  401. $calculate_data = array_merge($calculate_data, ...$payment_event_data);
  402. }
  403. return $this->success($calculate_data);
  404. }
  405. /**
  406. * 获取商品的计算信息
  407. * @param unknown $data
  408. */
  409. public function getOrderGoodsCalculate($data)
  410. {
  411. $goods_list = $this->getSeckillGoodsInfo($data[ "id" ], $data[ 'num' ], $data);
  412. $goods_list[ 'promotion_money' ] = 0;
  413. $shop_goods_list = $goods_list;
  414. return $shop_goods_list;
  415. }
  416. /**
  417. * 获取秒杀商品列表信息
  418. * @param unknown $bl_id
  419. */
  420. public function getSeckillGoodsInfo($id, $num, $data)
  421. {
  422. //组装商品列表
  423. $field = 'npsg.sku_id,npsg.seckill_id,npsg.seckill_price,npsg.max_buy as limit_num,ngs.sku_name, ngs.sku_no,
  424. ngs.price, ngs.discount_price, ngs.cost_price, ngs.stock, ngs.weight, ngs.volume, ngs.sku_image,
  425. ngs.site_id, ns.site_name, ngs.goods_state, ngs.is_virtual,
  426. ngs.is_free_shipping, ngs.shipping_template, ngs.goods_class, ngs.goods_class_name,ngs.goods_id,ngs.sku_spec_format,ngs.goods_name,ngs.support_trade_type';
  427. $alias = 'npsg';
  428. $join = [
  429. [
  430. 'goods_sku ngs',
  431. 'npsg.sku_id = ngs.sku_id',
  432. 'inner'
  433. ],
  434. [
  435. 'site ns',
  436. 'ngs.site_id = ns.site_id',
  437. 'inner'
  438. ]
  439. ];
  440. $condition = [
  441. [ 'npsg.sku_id', '=', $data[ 'sku_id' ] ],
  442. [ 'npsg.seckill_id', '=', $id ],
  443. [ 'npsg.site_id', '=', $data[ 'site_id' ] ]
  444. ];
  445. $info = model("promotion_seckill_goods")->getInfo($condition, $field, $alias, $join);
  446. $shop_goods_list = [];
  447. if (!empty($info)) {
  448. //判断是否是虚拟订单
  449. if ($info[ 'is_virtual' ]) {
  450. $this->is_virtual = 1;
  451. } else {
  452. $this->is_virtual = 0;
  453. }
  454. $info[ "num" ] = $num;
  455. $site_id = $info[ 'site_id' ];
  456. $price = $info[ "seckill_price" ];//订单项商品单价
  457. $goods_money = $price * $info[ 'num' ];
  458. $info[ "price" ] = $price;
  459. $info[ 'goods_money' ] = $goods_money;//订单项商品总价
  460. $info[ 'real_goods_money' ] = $goods_money;//真实商品金额
  461. $info[ 'coupon_money' ] = 0;//优惠券金额
  462. $info[ 'promotion_money' ] = 0;//优惠金额
  463. $shop_goods_list[ 'site_id' ] = $site_id;
  464. $shop_goods_list[ 'site_name' ] = $info[ 'site_name' ];
  465. $shop_goods_list[ 'goods_money' ] = $goods_money;
  466. $shop_goods_list[ 'goods_list_str' ] = $info[ 'sku_id' ] . ':' . $info[ 'num' ];
  467. $shop_goods_list[ 'order_name' ] = string_split("", ",", $info[ 'sku_name' ]);
  468. $shop_goods_list[ 'goods_num' ] = $info[ 'num' ];
  469. $shop_goods_list[ 'goods_list' ][] = $info;
  470. if (isset($data[ 'delivery' ][ 'delivery_type' ]) && !empty($data[ 'delivery' ][ 'delivery_type' ]) && strpos($info[ 'support_trade_type' ], $data[ 'delivery' ][ 'delivery_type' ]) === false) {
  471. $express_type_list = ( new \app\model\express\Config() )->getExpressTypeList($data[ 'site_id' ]);
  472. $delivery_type_name = $express_type_list[ $data[ 'delivery' ][ 'delivery_type' ] ] ?? '';
  473. $this->error = 1;
  474. $this->error_msg = '有商品不支持' . $delivery_type_name;
  475. }
  476. }
  477. return $shop_goods_list;
  478. }
  479. /**
  480. * 获取店铺订单计算
  481. * @param unknown $site_id 店铺id
  482. * @param unknown $goods_money 商品总价
  483. * @param unknown $goods_list 店铺商品列表
  484. * @param unknown $data 传输生成订单数据
  485. */
  486. public function shopOrderCalculate($shop_goods, $data)
  487. {
  488. $site_id = $shop_goods[ 'site_id' ];
  489. //交易配置
  490. $config_model = new Config();
  491. $order_config_result = $config_model->getOrderEventTimeConfig($site_id);
  492. $order_config = $order_config_result[ "data" ];
  493. $shop_goods[ 'order_config' ] = $order_config[ 'value' ] ?? [];
  494. //定义计算金额
  495. $goods_money = $shop_goods[ 'goods_money' ]; //商品金额
  496. $delivery_money = 0; //配送费用
  497. $promotion_money = $shop_goods[ 'promotion_money' ]; //优惠费用(满减)
  498. $coupon_money = 0; //优惠券费用
  499. $adjust_money = 0; //调整金额
  500. $invoice_money = 0; //发票金额
  501. $order_money = 0; //订单金额
  502. $balance_money = 0; //会员余额
  503. $pay_money = 0; //应付金额
  504. $store_id = 0;
  505. //计算邮费
  506. if ($this->is_virtual == 1) {
  507. //虚拟订单 运费为0
  508. $delivery_money = 0;
  509. $shop_goods[ 'delivery' ][ 'delivery_type' ] = '';
  510. } else {
  511. $express_config_model = new ExpressConfig();
  512. $deliver_type = $express_config_model->getDeliverTypeSort($site_id);
  513. $deliver_type = $deliver_type[ "data" ];
  514. $shop_goods[ "deliver_sort" ] = explode(',', $deliver_type[ 'value' ][ 'deliver_type' ]);
  515. //查询店铺是否开启快递配送
  516. $express_config_result = $express_config_model->getExpressConfig($site_id);
  517. $express_config = $express_config_result[ "data" ];
  518. $shop_goods[ "express_config" ] = $express_config;
  519. //查询店铺是否开启门店自提
  520. $store_config_result = $express_config_model->getStoreConfig($site_id);
  521. $store_config = $store_config_result[ "data" ];
  522. $shop_goods[ "store_config" ] = $store_config;
  523. //查询店铺是否开启外卖配送
  524. $local_config_result = $express_config_model->getLocalDeliveryConfig($site_id);
  525. $local_config = $local_config_result[ "data" ];
  526. $shop_goods[ "local_config" ] = $local_config;
  527. //如果本地配送开启, 则查询出本地配送的配置
  528. if ($shop_goods[ "local_config" ][ 'is_use' ] == 1 && isset($data[ 'delivery' ][ 'store_id' ])) {
  529. $local_model = new Local();
  530. $local_info_result = $local_model->getLocalInfo([ [ 'site_id', '=', $site_id ], [ 'store_id', '=', $data[ 'delivery' ][ 'store_id' ] ] ]);
  531. $local_info = $local_info_result[ 'data' ];
  532. $shop_goods[ "local_config" ][ 'info' ] = $local_info;
  533. } else {
  534. $shop_goods[ 'local_config' ][ 'info' ] = [];
  535. }
  536. $delivery_array = $data[ 'delivery' ] ?? [];
  537. $delivery_type = $delivery_array[ "delivery_type" ] ?? 'express';
  538. if ($delivery_type == "store") {
  539. if (isset($data[ 'delivery' ][ "delivery_type" ]) && $data[ 'delivery' ][ "delivery_type" ] == "store") {
  540. //门店自提
  541. $delivery_money = 0;
  542. $shop_goods[ 'delivery' ][ 'delivery_type' ] = 'store';
  543. if ($shop_goods[ "store_config" ][ "is_use" ] == 0) {
  544. $this->error = 1;
  545. $this->error_msg = "门店自提方式未开启!";
  546. }
  547. if (empty($data[ 'delivery' ][ "store_id" ])) {
  548. $this->error = 1;
  549. $this->error_msg = "门店未选择!";
  550. }
  551. $shop_goods[ 'delivery' ][ 'store_id' ] = $data[ 'delivery' ][ "store_id" ];
  552. $shop_goods[ 'buyer_ask_delivery_time' ] = $data[ 'buyer_ask_delivery_time' ];
  553. $shop_goods = $this->storeOrderData($shop_goods, $data);
  554. $store_id = $data[ 'delivery' ][ 'store_id' ] ?? 0;
  555. }
  556. } else {
  557. if (empty($data[ 'member_address' ])) {
  558. $delivery_money = 0;
  559. $shop_goods[ 'delivery' ][ 'delivery_type' ] = 'express';
  560. $this->error = 1;
  561. $this->error_msg = "未配置默认收货地址!";
  562. } else {
  563. if (!isset($data[ 'delivery' ][ "delivery_type" ]) || $data[ 'delivery' ][ "delivery_type" ] == "express") {
  564. if ($shop_goods[ "express_config" ][ "is_use" ] == 1) {
  565. //物流配送
  566. $express = new Express();
  567. $express_fee_result = $express->calculate($shop_goods, $data);
  568. if ($express_fee_result[ "code" ] < 0) {
  569. $this->error = 1;
  570. $this->error_msg = $express_fee_result[ "message" ];
  571. $delivery_fee = 0;
  572. } else {
  573. $delivery_fee = $express_fee_result[ 'data' ][ 'delivery_fee' ];
  574. }
  575. } else {
  576. $this->error = 1;
  577. $this->error_msg = "物流配送方式未开启!";
  578. $delivery_fee = 0;
  579. }
  580. $delivery_money = $delivery_fee;
  581. $shop_goods[ 'delivery' ][ 'delivery_type' ] = 'express';
  582. } else if ($data[ 'delivery' ][ "delivery_type" ] == "local") {
  583. if (empty($data[ 'delivery' ][ 'store_id' ])) {
  584. $this->setError(1, '门店未选择!');
  585. }
  586. //外卖配送
  587. $delivery_money = 0;
  588. $shop_goods[ 'delivery' ][ 'delivery_type' ] = 'local';
  589. if ($shop_goods[ "local_config" ][ "is_use" ] == 0) {
  590. $this->error = 1;
  591. $this->error_msg = "外卖配送方式未开启!";
  592. } else {
  593. $local_delivery_time = 0;
  594. if (!empty($data[ 'buyer_ask_delivery_time' ])) {
  595. $local_delivery_time = $data[ 'buyer_ask_delivery_time' ];
  596. }
  597. $shop_goods[ 'buyer_ask_delivery_time' ] = $local_delivery_time;
  598. $local_model = new Local();
  599. $local_result = $local_model->calculate($shop_goods, $data);
  600. $shop_goods[ 'delivery' ][ 'start_money' ] = 0;
  601. if ($local_result[ 'code' ] < 0) {
  602. $this->error = $local_result[ 'data' ][ 'code' ];
  603. $this->error_msg = $local_result[ 'message' ];
  604. $shop_goods[ 'delivery' ][ 'start_money' ] = $local_result[ 'data' ][ 'start_money_array' ][ 0 ] ?? 0;
  605. } else {
  606. $delivery_money = $local_result[ 'data' ][ 'delivery_money' ];
  607. if (!empty($local_result[ 'data' ][ 'error_code' ])) {
  608. $this->error = $local_result[ 'data' ][ 'code' ];
  609. $this->error_msg = $local_result[ 'data' ][ 'error' ];
  610. }
  611. }
  612. }
  613. $shop_goods[ 'delivery' ][ 'error' ] = $this->error;
  614. $shop_goods[ 'delivery' ][ 'error_msg' ] = $this->error_msg;
  615. $store_id = $data[ 'delivery' ][ 'store_id' ] ?? 0;
  616. }
  617. }
  618. }
  619. }
  620. //发票相关
  621. $shop_goods = $this->invoice($shop_goods, $data);
  622. $order_money = $goods_money + $delivery_money - $promotion_money - $coupon_money + $shop_goods[ 'invoice_money' ] + $shop_goods[ 'invoice_delivery_money' ];
  623. if ($order_money < 0) {
  624. $order_money = 0;
  625. }
  626. //余额抵扣(判断是否使用余额)
  627. if ($this->member_balance_money > 0) {
  628. if ($order_money <= $this->member_balance_money) {
  629. $balance_money = $order_money;
  630. } else {
  631. $balance_money = $this->member_balance_money;
  632. }
  633. } else {
  634. $balance_money = 0;
  635. }
  636. $pay_money = $order_money - $balance_money;//计算出实际支付金额
  637. $this->member_balance_money -= $balance_money;//预减少账户余额
  638. $this->balance_money += $balance_money;//累计余额
  639. //总结计算
  640. $shop_goods[ 'store_id' ] = $store_id;
  641. $shop_goods[ 'goods_money' ] = $goods_money;
  642. $shop_goods[ 'delivery_money' ] = $delivery_money;
  643. $shop_goods[ 'coupon_money' ] = $coupon_money;
  644. $shop_goods[ 'adjust_money' ] = $adjust_money;
  645. $shop_goods[ 'promotion_money' ] = $promotion_money;
  646. $shop_goods[ 'order_money' ] = $order_money;
  647. $shop_goods[ 'balance_money' ] = $balance_money;
  648. $shop_goods[ 'pay_money' ] = $pay_money;
  649. $this->goods_money += $goods_money;
  650. $this->delivery_money += $delivery_money;
  651. $this->coupon_money += $coupon_money;
  652. $this->adjust_money += $adjust_money;
  653. $this->invoice_money += $shop_goods[ 'invoice_money' ];
  654. $this->invoice_delivery_money += $shop_goods[ 'invoice_delivery_money' ];
  655. $this->promotion_money += $promotion_money;
  656. $this->order_money += $order_money;
  657. $this->pay_money += $pay_money;
  658. $this->goods_num += $shop_goods[ "goods_num" ];
  659. $this->order_name = string_split($this->order_name, ",", $shop_goods[ "order_name" ]);
  660. return $shop_goods;
  661. }
  662. /**
  663. * 订单关闭
  664. * @param $order_id
  665. */
  666. public function CronOrderClose($order_id)
  667. {
  668. $order_info = model('order')->getInfo([ [ 'order_id', '=', $order_id ], [ 'promotion_type', '=', 'seckill' ], [ 'order_status', '=', -1 ] ], 'promotion_id');
  669. if (!empty($order_info)) {
  670. $condition = array (
  671. [ "order_id", "=", $order_id ]
  672. );
  673. $order_goods_list = model('order_goods')->getList($condition, "order_goods_id,sku_id,num,refund_status,use_point");
  674. foreach ($order_goods_list as $k => $v) {
  675. // 返还库存
  676. model("promotion_seckill")->setInc([ [ 'id', '=', $order_info[ "promotion_id" ] ] ], "goods_stock", $v[ "num" ]);
  677. model("promotion_seckill_goods")->setInc([ [ "sku_id", '=', $v[ "sku_id" ] ], [ "seckill_id", '=', $order_info[ "promotion_id" ] ] ], "stock", $v[ "num" ]);
  678. // 减少销量
  679. model("promotion_seckill")->setDec([ [ 'id', '=', $order_info[ "promotion_id" ] ] ], "sale_num", $v[ "num" ]);
  680. }
  681. }
  682. return $this->success();
  683. }
  684. /**
  685. * 获取会员该秒杀时段已购该商品数
  686. * @param $goods_id
  687. * @param $member_id
  688. * @return float
  689. */
  690. public function getGoodsPurchasedNum($sku_id, $member_id, $seckill_id)
  691. {
  692. $join = [
  693. [ 'order o', 'o.order_id = og.order_id', 'left' ]
  694. ];
  695. $num = model('order_goods')->getSum([
  696. [ 'og.member_id', '=', $member_id ],
  697. [ 'og.sku_id', '=', $sku_id ],
  698. [ 'o.order_status', '<>', Order::ORDER_CLOSE ],
  699. [ 'o.promotion_type', '=', 'seckill' ],
  700. [ 'o.promotion_id', '=', $seckill_id ],
  701. [ 'og.refund_status', '<>', OrderRefund::REFUND_COMPLETE ],
  702. [ 'o.create_time', 'between', [ date_to_time(date('Y-m-d 00:00:00')), time() ] ]
  703. ], 'og.num', 'og', $join);
  704. return $num;
  705. }
  706. /**
  707. * 获取商品已秒杀数
  708. * @param $goods_id
  709. * @param $member_id
  710. * @return float
  711. */
  712. public function getGoodsSeckillNum($seckill_id)
  713. {
  714. $join = [
  715. [ 'order o', 'o.order_id = og.order_id', 'left' ]
  716. ];
  717. $num = model('order_goods')->getSum([
  718. [ 'o.order_status', '<>', Order::ORDER_CLOSE ],
  719. [ 'o.promotion_type', '=', 'seckill' ],
  720. [ 'o.promotion_id', '=', $seckill_id ],
  721. [ 'og.refund_status', '<>', OrderRefund::REFUND_COMPLETE ],
  722. ], 'og.num', 'og', $join);
  723. return $num;
  724. }
  725. }