Buy.php 73 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520
  1. <?php
  2. namespace app\common\logic;
  3. use think\facade\Db;
  4. /**
  5. * ============================================================================
  6. * DSMall多用户商城
  7. * ============================================================================
  8. * 版权所有 2014-2028 长沙德尚网络科技有限公司,并保留所有权利。
  9. * 网站地址: http://www.csdeshang.com
  10. * ----------------------------------------------------------------------------
  11. * 这不是一个自由软件!您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
  12. * 不允许对程序代码以任何形式任何目的的再发布。
  13. * ============================================================================
  14. * 逻辑层模型
  15. */
  16. class Buy
  17. {
  18. /**
  19. * 会员信息
  20. * @var array
  21. */
  22. private $_member_info = [];
  23. /**
  24. * 下单数据
  25. * @var array
  26. */
  27. private $_order_data = [];
  28. /**
  29. * 表单数据
  30. * @var array
  31. */
  32. private $_post_data = [];
  33. /**
  34. * buy_1.logic 对象
  35. * @var obj
  36. */
  37. private $_logic_buy_1;
  38. public function __construct()
  39. {
  40. $this->_logic_buy_1 = model('buy_1', 'logic');
  41. }
  42. /**
  43. * 购买第一步
  44. * @param type $cart_id
  45. * @param type $ifcart
  46. * @param type $member_id
  47. * @param type $store_id
  48. * @param type $extra 额外特殊判断处理数据,比如拼团功能
  49. * @return type
  50. */
  51. public function buyStep1($cart_id, $ifcart, $member_id, $store_id, $extra = [])
  52. {
  53. //得到购买商品信息
  54. if ($ifcart) {
  55. $result = $this->getCartList($cart_id, $member_id);
  56. } else {
  57. $result = $this->getGoodsList($cart_id, $member_id, $store_id, $extra);
  58. }
  59. if (!$result['code']) {
  60. return $result;
  61. }
  62. //得到页面所需要数据:收货地址、发票、代金券、预存款、商品列表等信息
  63. $result = $this->getBuyStep1Data($member_id, $result['data']);
  64. return $result;
  65. }
  66. /**
  67. * 第一步:处理购物车
  68. * @param type $cart_id 购物车
  69. * @param type $member_id 会员编号
  70. * @param type $extra 额外特殊判断处理数据,比如拼团功能
  71. * @return type
  72. */
  73. public function getCartList($cart_id, $member_id, $extra = [])
  74. {
  75. $cart_model = model('cart');
  76. //取得POST ID和购买数量
  77. $buy_items = $this->_parseItems($cart_id);
  78. if (empty($buy_items)) {
  79. return ds_callback(false, '所购商品无效');
  80. }
  81. if (count($buy_items) > 50) {
  82. return ds_callback(false, '一次最多只可购买50种商品');
  83. }
  84. //购物车列表
  85. $condition = [];
  86. $condition[] = ['cart_id', 'in', array_keys($buy_items)];
  87. $condition[] = ['buyer_id', '=', $member_id];
  88. $cart_list = $cart_model->getCartList('db', $condition);
  89. //购物车列表 [得到最新商品属性及促销信息]
  90. $cart_list = $this->_logic_buy_1->getGoodsCartList($cart_list);
  91. //商品列表 [优惠套装子商品与普通商品同级罗列]
  92. $goods_list = $this->_getGoodsList($cart_list);
  93. //以店铺下标归类
  94. $store_cart_list = $this->_getStoreCartList($cart_list);
  95. return ds_callback(true, '', ['goods_list' => $goods_list, 'store_cart_list' => $store_cart_list]);
  96. }
  97. /**
  98. * 第一步:处理立即购买
  99. * @param type $cart_id 购物车
  100. * @param type $member_id 会员编号
  101. * @param type $store_id 店铺编号
  102. * @param type $extra 额外特殊判断处理数据,比如拼团功能
  103. * @return type
  104. */
  105. public function getGoodsList($cart_id, $member_id, $store_id, $extra = [])
  106. {
  107. //取得POST ID和购买数量
  108. $buy_items = $this->_parseItems($cart_id);
  109. if (empty($buy_items)) {
  110. return ds_callback(false, '所购商品无效');
  111. }
  112. $goods_id = key($buy_items);
  113. $quantity = current($buy_items);
  114. //商品信息[得到最新商品属性及促销信息]
  115. $goods_info = $this->_logic_buy_1->getGoodsOnlineInfo($goods_id, intval($quantity), $extra, $member_id);
  116. if (empty($goods_info)) {
  117. return ds_callback(false, '商品已下架或不存在');
  118. }
  119. //不能购买自己店铺的商品
  120. if ($goods_info['store_id'] == $store_id) {
  121. return ds_callback(false, '不能购买自己店铺的商品');
  122. }
  123. //进一步处理数组
  124. $store_cart_list = [];
  125. $goods_list = [];
  126. $goods_info['chain_id'] = 0;
  127. $goods_list[0] = $store_cart_list[$goods_info['store_id']][0] = $goods_info;
  128. return ds_callback(true, '', ['goods_list' => $goods_list, 'store_cart_list' => $store_cart_list]);
  129. }
  130. /**
  131. * 购买第一步:返回商品、促销、地址、发票等信息,然后交前台抛出
  132. * @param unknown $member_id
  133. * @param unknown $data 商品信息
  134. * @return
  135. */
  136. public function getBuyStep1Data($member_id, $data)
  137. {
  138. //list($goods_list, $store_cart_list) = $data;
  139. $goods_list = $data['goods_list'];
  140. $store_cart_list = $data['store_cart_list'];
  141. //定义返回数组
  142. $result = [];
  143. //商品金额计算(分别对每个商品/优惠套装小计、每个店铺小计)
  144. list($store_cart_list, $store_goods_total, $store_goods_original_total, $store_goods_discount_total) = $this->_logic_buy_1->calcCartList($store_cart_list);
  145. $result['store_cart_list'] = $store_cart_list;
  146. $result['store_goods_total'] = $store_goods_total;
  147. $result['store_goods_original_total'] = $store_goods_original_total;
  148. $result['store_goods_discount_total'] = $store_goods_discount_total;
  149. //取得店铺优惠 - 满即送(赠品列表,店铺满送规则列表)
  150. list($store_premiums_list, $store_mansong_rule_list) = $this->_logic_buy_1->getMansongruleCartListByTotal($store_goods_total);
  151. $result['store_premiums_list'] = $store_premiums_list;
  152. $result['store_mansong_rule_list'] = $store_mansong_rule_list;
  153. //重新计算优惠后(满即送)的店铺实际商品总金额
  154. $store_goods_total = $this->_logic_buy_1->reCalcGoodsTotal($store_goods_total, $store_mansong_rule_list, 'mansong');
  155. //返回店铺可用的代金券
  156. $store_voucher_list = $this->_logic_buy_1->getStoreAvailableVoucherList($store_goods_total, $member_id);
  157. $result['store_voucher_list'] = $store_voucher_list;
  158. //返回需要计算运费的店铺ID数组 和 不需要计算运费(满免运费活动的)店铺ID及描述
  159. list($need_calc_sid_list, $cancel_calc_sid_list) = $this->_logic_buy_1->getStoreFreightDescList($store_goods_total);
  160. $result['need_calc_sid_list'] = $need_calc_sid_list;
  161. $result['cancel_calc_sid_list'] = $cancel_calc_sid_list;
  162. //将商品ID、数量、售卖区域、运费序列化,加密,输出到模板,选择地区AJAX计算运费时作为参数使用
  163. $freight_list = $this->_logic_buy_1->getStoreFreightList($goods_list, array_keys($cancel_calc_sid_list));
  164. $result['freight_list'] = $this->buyEncrypt($freight_list, $member_id);
  165. //输出用户默认收货地址
  166. $result['address_info'] = model('address')->getDefaultAddressInfo(['member_id' => $member_id]);
  167. //输出有货到付款时,在线支付和货到付款及每种支付下商品数量和详细列表
  168. $pay_goods_list = $this->_logic_buy_1->getOfflineGoodsPay($goods_list);
  169. if (!empty($pay_goods_list['offline'])) {
  170. $result['pay_goods_list'] = $pay_goods_list;
  171. $result['ifshow_offpay'] = true;
  172. } else {
  173. //如果所购商品只支持线上支付,支付方式不允许修改
  174. $result['deny_edit_payment'] = true;
  175. $result['pay_goods_list'] = $pay_goods_list;
  176. $result['ifshow_offpay'] = FALSE;
  177. }
  178. //是否是预售订单
  179. $if_presell = 0;
  180. $presell_deposit_amount = 0;
  181. if (count($goods_list) == 1) {
  182. $current_goods = current($goods_list);
  183. if (!empty($current_goods['presell_info']) && $current_goods['presell_info']['presell_type'] == 2) {
  184. $if_presell = 1;
  185. $presell_deposit_amount = $current_goods['presell_info']['presell_deposit_amount'];
  186. $result['deny_edit_payment'] = true;
  187. $result['ifshow_offpay'] = FALSE;
  188. }
  189. }
  190. $result['if_presell'] = $if_presell;
  191. $result['presell_deposit_amount'] = $presell_deposit_amount;
  192. //发票 :只有所有商品都支持增值税发票才提供增值税发票
  193. $vat_deny = false;
  194. foreach ($goods_list as $goods) {
  195. if (!intval($goods['goods_vat'])) {
  196. $vat_deny = true;
  197. break;
  198. }
  199. }
  200. //不提供增值税发票时抛出true(模板使用)
  201. $result['vat_deny'] = $vat_deny;
  202. $result['vat_hash'] = $this->buyEncrypt($result['vat_deny'] ? 'deny_vat' : 'allow_vat', $member_id);
  203. //输出默认使用的发票信息
  204. $inv_info = model('invoice')->getDefaultInvoiceInfo(['member_id' => $member_id]);
  205. if ($inv_info['invoice_state'] == '2' && !$vat_deny) {
  206. $inv_info['content'] = '增值税发票 ' . $inv_info['invoice_company'] . ' ' . $inv_info['invoice_company_code'] . ' ' . $inv_info['invoice_reg_addr'];
  207. } elseif ($inv_info['invoice_state'] == '2' && $vat_deny) {
  208. $inv_info = [];
  209. $inv_info['content'] = '不需要发票';
  210. } elseif (!empty($inv_info)) {
  211. $inv_info['content'] = '普通发票 ' . $inv_info['invoice_title'] . ' ' . $inv_info['invoice_code'] . ' ' . $inv_info['invoice_content'];
  212. } else {
  213. $inv_info = [];
  214. $inv_info['content'] = '不需要发票';
  215. }
  216. $result['inv_info'] = $inv_info;
  217. $buyer_info = model('member')->getMemberInfoByID($member_id);
  218. if (floatval($buyer_info['available_predeposit']) > 0) {
  219. $result['available_predeposit'] = $buyer_info['available_predeposit'];
  220. }
  221. if (floatval($buyer_info['available_rc_balance']) > 0) {
  222. $result['available_rc_balance'] = $buyer_info['available_rc_balance'];
  223. }
  224. $result['member_paypwd'] = $buyer_info['member_paypwd'] ? true : false;
  225. return ds_callback(true, '', $result);
  226. }
  227. /**
  228. * 购买第二步
  229. * @param array $post
  230. * @param int $member_id
  231. * @param string $member_name
  232. * @param string $member_email
  233. * @return array
  234. */
  235. public function buyStep2($post, $member_id, $member_name, $member_email)
  236. {
  237. $this->_member_info['member_id'] = $member_id;
  238. $this->_member_info['member_name'] = $member_name;
  239. $this->_member_info['member_email'] = $member_email;
  240. $this->_post_data = $post;
  241. try {
  242. $order_model = model('order');
  243. Db::startTrans();
  244. $this->_logic_buy_1->lock = true;
  245. //第1步 表单验证
  246. $this->_createOrderStep1();
  247. //第2步 得到购买商品信息
  248. $this->_createOrderStep2();
  249. //第3步 得到购买相关金额计算等信息
  250. $this->_createOrderStep3();
  251. //第4步 生成订单
  252. $this->_createOrderStep4();
  253. //第6步 订单后续处理
  254. $this->_createOrderStep6();
  255. Db::commit();
  256. return ds_callback(true, '', $this->_order_data);
  257. } catch (\Exception $e) {
  258. Db::rollback();
  259. return ds_callback(false, $e->getMessage());
  260. }
  261. }
  262. /**
  263. * 生成推广记录
  264. * @param array $order_list
  265. */
  266. public function addOrderInviter($order_list = [])
  267. {
  268. if (!config('ds_config.inviter_open')) {
  269. return;
  270. }
  271. if (empty($order_list) || !is_array($order_list))
  272. return;
  273. $inviter_ratio_1 = config('ds_config.inviter_ratio_1');
  274. $inviter_ratio_2 = config('ds_config.inviter_ratio_2');
  275. $inviter_ratio_3 = config('ds_config.inviter_ratio_3');
  276. $orderinviter_model = model('orderinviter');
  277. foreach ($order_list as $order_id => $order) {
  278. foreach ($order['order_goods'] as $goods) {
  279. //查询商品的分销信息
  280. $goods_common_info = Db::name('goodscommon')->alias('gc')->join('goods g', 'g.goods_commonid=gc.goods_commonid')->where('g.goods_id=' . $goods['goods_id'])->field('gc.goods_commonid,gc.inviter_open,gc.inviter_ratio')->find();
  281. if (!$goods_common_info['inviter_open']) {
  282. continue;
  283. }
  284. $goods_amount = $goods['goods_price'] * $goods['goods_num'] * $goods_common_info['inviter_ratio'] / 100;
  285. $inviter_ratios = [
  286. $inviter_ratio_1,
  287. $inviter_ratio_2,
  288. $inviter_ratio_3,
  289. ];
  290. //判断买家是否是分销员
  291. if (config('ds_config.inviter_return')) {
  292. if (Db::name('inviter')->where('inviter_state=1 AND inviter_id=' . $order['buyer_id'])->value('inviter_id')) {
  293. if (isset($inviter_ratios[0]) && floatval($inviter_ratios[0]) > 0) {
  294. $money_1 = round($inviter_ratios[0] / 100 * $goods_amount, 2);
  295. if ($money_1 > 0) {
  296. //生成推广记录
  297. Db::name('orderinviter')->insert([
  298. 'orderinviter_addtime' => TIMESTAMP,
  299. 'orderinviter_store_name' => $order['store_name'],
  300. 'orderinviter_goods_amount' => $goods_amount,
  301. 'orderinviter_goods_quantity' => $goods['goods_num'],
  302. 'orderinviter_order_type' => 0,
  303. 'orderinviter_store_id' => $goods['store_id'],
  304. 'orderinviter_goods_commonid' => $goods_common_info['goods_commonid'],
  305. 'orderinviter_goods_id' => $goods['goods_id'],
  306. 'orderinviter_level' => 1,
  307. 'orderinviter_goods_name' => $goods['goods_name'],
  308. 'orderinviter_order_id' => $order_id,
  309. 'orderinviter_order_sn' => $order['order_sn'],
  310. 'orderinviter_member_id' => $order['buyer_id'],
  311. 'orderinviter_member_name' => $order['buyer_name'],
  312. 'orderinviter_money' => $money_1,
  313. 'orderinviter_remark' => '获得分销员返佣,佣金比例' . $inviter_ratios[0] . '%,订单号' . $order['order_sn'],
  314. ]);
  315. }
  316. }
  317. }
  318. }
  319. //一级推荐人
  320. $inviter_1_id = Db::name('member')->where('member_id', $order['buyer_id'])->value('inviter_id');
  321. if (!$inviter_1_id || !Db::name('inviter')->where('inviter_state=1 AND inviter_id=' . $inviter_1_id)->value('inviter_id')) {
  322. continue;
  323. }
  324. $inviter_1 = Db::name('member')->where('member_id', $inviter_1_id)->field('inviter_id,member_id,member_name')->find();
  325. if ($inviter_1 && isset($inviter_ratios[0]) && floatval($inviter_ratios[0]) > 0) {
  326. $money_1 = round($inviter_ratios[0] / 100 * $goods_amount, 2);
  327. if ($money_1 > 0) {
  328. //生成推广记录
  329. Db::name('orderinviter')->insert([
  330. 'orderinviter_addtime' => TIMESTAMP,
  331. 'orderinviter_store_name' => $order['store_name'],
  332. 'orderinviter_goods_amount' => $goods_amount,
  333. 'orderinviter_goods_quantity' => $goods['goods_num'],
  334. 'orderinviter_order_type' => 0,
  335. 'orderinviter_store_id' => $goods['store_id'],
  336. 'orderinviter_goods_commonid' => $goods_common_info['goods_commonid'],
  337. 'orderinviter_goods_id' => $goods['goods_id'],
  338. 'orderinviter_level' => 1,
  339. 'orderinviter_goods_name' => $goods['goods_name'],
  340. 'orderinviter_order_id' => $order_id,
  341. 'orderinviter_order_sn' => $order['order_sn'],
  342. 'orderinviter_member_id' => $inviter_1['member_id'],
  343. 'orderinviter_member_name' => $inviter_1['member_name'],
  344. 'orderinviter_money' => $money_1,
  345. 'orderinviter_remark' => '获得一级推荐佣金,佣金比例' . $inviter_ratios[0] . '%,推荐关系' . $inviter_1['member_name'] . '->' . $order['buyer_name'] . ',订单号' . $order['order_sn'],
  346. ]);
  347. }
  348. }
  349. if (config('ds_config.inviter_level') <= 1) {
  350. continue;
  351. }
  352. //二级推荐人
  353. $inviter_2_id = Db::name('member')->where('member_id', $inviter_1_id)->value('inviter_id');
  354. if (!$inviter_2_id || !Db::name('inviter')->where('inviter_state=1 AND inviter_id=' . $inviter_2_id)->value('inviter_id')) {
  355. continue;
  356. }
  357. $inviter_2 = Db::name('member')->where('member_id', $inviter_2_id)->field('inviter_id,member_id,member_name')->find();
  358. if ($inviter_2 && isset($inviter_ratios[1]) && floatval($inviter_ratios[1]) > 0) {
  359. $money_2 = round($inviter_ratios[1] / 100 * $goods_amount, 2);
  360. if ($money_2 > 0) {
  361. //生成推广记录
  362. Db::name('orderinviter')->insert([
  363. 'orderinviter_addtime' => TIMESTAMP,
  364. 'orderinviter_store_name' => $order['store_name'],
  365. 'orderinviter_goods_amount' => $goods_amount,
  366. 'orderinviter_goods_quantity' => $goods['goods_num'],
  367. 'orderinviter_order_type' => 0,
  368. 'orderinviter_store_id' => $goods['store_id'],
  369. 'orderinviter_goods_commonid' => $goods_common_info['goods_commonid'],
  370. 'orderinviter_goods_id' => $goods['goods_id'],
  371. 'orderinviter_level' => 2,
  372. 'orderinviter_goods_name' => $goods['goods_name'],
  373. 'orderinviter_order_id' => $order_id,
  374. 'orderinviter_order_sn' => $order['order_sn'],
  375. 'orderinviter_member_id' => $inviter_2['member_id'],
  376. 'orderinviter_member_name' => $inviter_2['member_name'],
  377. 'orderinviter_money' => $money_2,
  378. 'orderinviter_remark' => '获得二级推荐佣金,佣金比例' . $inviter_ratios[1] . '%,推荐关系' . $inviter_2['member_name'] . '->' . $inviter_1['member_name'] . '->' . $order['buyer_name'] . ',订单号' . $order['order_sn'],
  379. ]);
  380. }
  381. }
  382. if (config('ds_config.inviter_level') <= 2) {
  383. continue;
  384. }
  385. //三级推荐人
  386. $inviter_3_id = Db::name('member')->where('member_id', $inviter_2_id)->value('inviter_id');
  387. if (!$inviter_3_id || !Db::name('inviter')->where('inviter_state=1 AND inviter_id=' . $inviter_3_id)->value('inviter_id')) {
  388. continue;
  389. }
  390. $inviter_3 = Db::name('member')->where('member_id', $inviter_3_id)->field('inviter_id,member_id,member_name')->find();
  391. if ($inviter_3 && isset($inviter_ratios[2]) && floatval($inviter_ratios[2]) > 0) {
  392. $money_3 = round($inviter_ratios[2] / 100 * $goods_amount, 2);
  393. if ($money_3 > 0) {
  394. //生成推广记录
  395. Db::name('orderinviter')->insert([
  396. 'orderinviter_addtime' => TIMESTAMP,
  397. 'orderinviter_store_name' => $order['store_name'],
  398. 'orderinviter_goods_amount' => $goods_amount,
  399. 'orderinviter_goods_quantity' => $goods['goods_num'],
  400. 'orderinviter_order_type' => 0,
  401. 'orderinviter_store_id' => $goods['store_id'],
  402. 'orderinviter_goods_commonid' => $goods_common_info['goods_commonid'],
  403. 'orderinviter_goods_id' => $goods['goods_id'],
  404. 'orderinviter_level' => 3,
  405. 'orderinviter_goods_name' => $goods['goods_name'],
  406. 'orderinviter_order_id' => $order_id,
  407. 'orderinviter_order_sn' => $order['order_sn'],
  408. 'orderinviter_member_id' => $inviter_3['member_id'],
  409. 'orderinviter_member_name' => $inviter_3['member_name'],
  410. 'orderinviter_money' => $money_3,
  411. 'orderinviter_remark' => '获得三级推荐佣金,佣金比例' . $inviter_ratios[2] . '%,推荐关系' . $inviter_3['member_name'] . '->' . $inviter_2['member_name'] . '->' . $inviter_1['member_name'] . '->' . $order['buyer_name'] . ',订单号' . $order['order_sn'],
  412. ]);
  413. }
  414. }
  415. }
  416. }
  417. }
  418. /**
  419. * 删除购物车商品
  420. * @param unknown $ifcart
  421. * @param unknown $cart_ids
  422. */
  423. public function delCart($ifcart, $member_id, $cart_ids)
  424. {
  425. if (!$ifcart || !is_array($cart_ids))
  426. return;
  427. $cart_id_str = implode(',', $cart_ids);
  428. if (preg_match('/^[\d,]+$/', $cart_id_str)) {
  429. \mall\queue\QueueClient::push('delCart', ['buyer_id' => $member_id, 'cart_ids' => $cart_ids]);
  430. }
  431. }
  432. /**
  433. * 选择不同地区时,异步处理并返回每个店铺总运费以及本地区是否能使用货到付款
  434. * 如果店铺统一设置了满免运费规则,则售卖区域无效
  435. * 如果店铺未设置满免规则,且使用售卖区域,按售卖区域计算,如果其中有商品使用相同的售卖区域,则两种商品数量相加后再应用该售卖区域计算(即作为一种商品算运费)
  436. * 如果未找到售卖区域,按免运费处理
  437. * 如果没有使用售卖区域,商品运费按快递价格计算,运费不随购买数量增加
  438. */
  439. public function changeAddr($freight_hash, $city_id, $area_id, $member_id)
  440. {
  441. //$city_id计算售卖区域,$area_id计算货到付款
  442. $city_id = intval($city_id);
  443. $area_id = intval($area_id);
  444. if ($city_id <= 0 || $area_id <= 0)
  445. return null;
  446. //将hash解密,得到运费信息(店铺ID,运费,售卖区域ID,购买数量),hash内容有效期为1小时
  447. $freight_list = $this->buyDecrypt($freight_hash, $member_id);
  448. //算运费
  449. $store_freight_list = $this->_logic_buy_1->calcStoreFreight($freight_list, $city_id);
  450. $data = [];
  451. $data['state'] = empty($store_freight_list) ? 'fail' : 'success';
  452. $data['content'] = $store_freight_list;
  453. //是否能使用货到付款(只有包含平台店铺的商品才会判断)
  454. //$if_include_platform_store = array_key_exists(DEFAULT_PLATFORM_STORE_ID,$freight_list['iscalced']) || array_key_exists(DEFAULT_PLATFORM_STORE_ID,$freight_list['nocalced']);
  455. //$offline_store_id_array = model('store')->getOwnShopIds();
  456. $order_platform_store_ids = [];
  457. if (!empty($freight_list['iscalced']) && is_array($freight_list['iscalced']))
  458. foreach (array_keys($freight_list['iscalced']) as $k)
  459. $order_platform_store_ids[$k] = null;
  460. if (!empty($freight_list['nocalced']) && is_array($freight_list['nocalced']))
  461. foreach (array_keys($freight_list['nocalced']) as $k)
  462. //if (in_array($k, $offline_store_id_array))
  463. $order_platform_store_ids[$k] = null;
  464. //if ($order_platform_store_ids) {
  465. $allow_offpay_batch = model('offpayarea')->checkSupportOffpayBatch($area_id, array_keys($order_platform_store_ids));
  466. /*
  467. //JS验证使用
  468. $data['allow_offpay'] = array_filter($allow_offpay_batch) ? '1' : '0';
  469. $data['allow_offpay_batch'] = $allow_offpay_batch;
  470. } else {*/
  471. //JS验证使用
  472. $data['allow_offpay'] = array_filter($allow_offpay_batch) ? '1' : '0';
  473. $data['allow_offpay_batch'] = $allow_offpay_batch;
  474. //}
  475. //PHP验证使用
  476. $data['offpay_hash'] = $this->buyEncrypt($data['allow_offpay'] ? 'allow_offpay' : 'deny_offpay', $member_id);
  477. $data['offpay_hash_batch'] = $this->buyEncrypt($data['allow_offpay_batch'], $member_id);
  478. return $data;
  479. }
  480. /**
  481. * 验证F码
  482. * @param int $goods_commonid
  483. * @param string $fcode
  484. * @return array
  485. */
  486. public function checkFcode($goods_goodid, $fcode)
  487. {
  488. $fcode_info = model('goodsfcode')->getGoodsfcode([
  489. 'goods_commonid' => $goods_goodid, 'goodsfcode_code' => $fcode,
  490. 'goodsfcode_state' => 0,
  491. ]);
  492. if ($fcode_info) {
  493. return ds_callback(true, '', $fcode_info);
  494. } else {
  495. return ds_callback(false, 'F码错误');
  496. }
  497. }
  498. /**
  499. * 订单生成前的表单验证与处理
  500. *
  501. */
  502. private function _createOrderStep1()
  503. {
  504. $post = $this->_post_data;
  505. //取得商品ID和购买数量
  506. $input_buy_items = $this->_parseItems($post['cart_id']);
  507. if (empty($input_buy_items)) {
  508. throw new \think\Exception('所购商品无效', 10006);
  509. }
  510. //验证收货地址
  511. $input_address_id = intval($post['address_id']);
  512. if ($input_address_id <= 0) {
  513. throw new \think\Exception('请选择收货地址', 10006);
  514. } else {
  515. $input_address_info = model('address')->getAddressInfo(['address_id' => $input_address_id]);
  516. if ($input_address_info['member_id'] != $this->_member_info['member_id']) {
  517. throw new \think\Exception('请选择收货地址', 10006);
  518. }
  519. if ($input_address_info['chain_id']) {
  520. //门店是否开启了代收
  521. if (!isset($input_address_info['chain_if_collect']) || $input_address_info['chain_if_collect'] != 1) {
  522. throw new \think\Exception('代收点已关闭代收', 10006);
  523. }
  524. }
  525. }
  526. //收货地址城市编号
  527. $input_city_id = intval($input_address_info['city_id']);
  528. //是否开增值税发票
  529. $input_if_vat = $this->buyDecrypt($post['vat_hash'], $this->_member_info['member_id']);
  530. if (!in_array($input_if_vat, ['allow_vat', 'deny_vat'])) {
  531. throw new \think\Exception('订单保存出现异常[值税发票出现错误],请重试', 10006);
  532. }
  533. $input_if_vat = ($input_if_vat == 'allow_vat') ? true : false;
  534. //是否支持货到付款
  535. $input_if_offpay = $this->buyDecrypt($post['offpay_hash'], $this->_member_info['member_id']);
  536. if (!in_array($input_if_offpay, ['allow_offpay', 'deny_offpay'])) {
  537. throw new \think\Exception('订单保存出现异常[货到付款验证错误],请重试', 10006);
  538. }
  539. $input_if_offpay = ($input_if_offpay == 'allow_offpay') ? true : false;
  540. // 是否支持货到付款 具体到各个店铺
  541. $input_if_offpay_batch = $this->buyDecrypt($post['offpay_hash_batch'], $this->_member_info['member_id']);
  542. if (!is_array($input_if_offpay_batch)) {
  543. throw new \think\Exception('订单保存出现异常[部分店铺付款方式出现异常],请重试', 10006);
  544. }
  545. //付款方式:在线支付/货到付款(online/offline)
  546. if (!in_array($post['pay_name'], ['online', 'offline'])) {
  547. throw new \think\Exception('付款方式错误,请重新选择', 10006);
  548. }
  549. $input_pay_name = $post['pay_name'];
  550. //验证发票信息
  551. $input_invoice_info = [];
  552. if (!empty($post['invoice_id'])) {
  553. $input_invoice_id = intval($post['invoice_id']);
  554. if ($input_invoice_id > 0) {
  555. $input_invoice_info = model('invoice')->getInvoiceInfo(['invoice_id' => $input_invoice_id]);
  556. if ($input_invoice_info['member_id'] != $this->_member_info['member_id']) {
  557. throw new \think\Exception('请正确填写发票信息', 10006);
  558. }
  559. }
  560. }
  561. //验证代金券
  562. $input_voucher_list = [];
  563. if (!empty($post['voucher']) && is_array($post['voucher'])) {
  564. foreach ($post['voucher'] as $store_id => $voucher) {
  565. if (preg_match_all('/^(\d+)\|(\d+)\|([\d.]+)$/', $voucher, $matchs)) {
  566. if (floatval($matchs[3][0]) > 0) {
  567. $input_voucher_list[$store_id]['vouchertemplate_id'] = $matchs[1][0];
  568. $input_voucher_list[$store_id]['voucher_price'] = $matchs[3][0];
  569. }
  570. }
  571. }
  572. }
  573. //保存数据
  574. $this->_order_data['input_buy_items'] = $input_buy_items;
  575. $this->_order_data['input_city_id'] = $input_city_id;
  576. $this->_order_data['input_pay_name'] = $input_pay_name;
  577. $this->_order_data['input_if_offpay'] = $input_if_offpay;
  578. $this->_order_data['input_if_offpay_batch'] = $input_if_offpay_batch;
  579. $this->_order_data['input_pay_message'] = $post['pay_message'];
  580. $this->_order_data['input_address_info'] = $input_address_info;
  581. $this->_order_data['input_invoice_info'] = $input_invoice_info;
  582. $this->_order_data['input_voucher_list'] = $input_voucher_list;
  583. $this->_order_data['order_from'] = $post['order_from'] == 2 ? 2 : 1;
  584. }
  585. /**
  586. * 得到购买商品信息
  587. *
  588. */
  589. private function _createOrderStep2()
  590. {
  591. $post = $this->_post_data;
  592. $input_buy_items = $this->_order_data['input_buy_items'];
  593. if ($post['ifcart']) {
  594. //购物车列表
  595. $cart_model = model('cart');
  596. $condition = [];
  597. $condition[] = ['cart_id', 'in', array_keys($input_buy_items)];
  598. $condition[] = ['buyer_id', '=', $this->_member_info['member_id']];
  599. $cart_list = $cart_model->getCartList('db', $condition);
  600. //购物车列表 [得到最新商品属性及促销信息]
  601. $cart_list = $this->_logic_buy_1->getGoodsCartList($cart_list);
  602. //商品列表 [优惠套装子商品与普通商品同级罗列]
  603. $goods_list = $this->_getGoodsList($cart_list);
  604. //以店铺下标归类
  605. $store_cart_list = $this->_getStoreCartList($cart_list);
  606. } else {
  607. //来源于直接购买
  608. $goods_id = key($input_buy_items);
  609. $quantity = current($input_buy_items);
  610. //额外数据用来处理拼团等其他活动
  611. $pintuan_id = isset($post['pintuan_id']) ? intval($post['pintuan_id']) : 0;
  612. $extra = [];
  613. if ($pintuan_id > 0) {
  614. $extra['pintuan_id'] = $pintuan_id; #拼团ID
  615. #是否为开团订单
  616. $extra['pintuangroup_id'] = empty(input('param.pintuangroup_id')) ? 0 : intval(input('param.pintuangroup_id'));
  617. }
  618. $bargainorder_id = isset($post['bargainorder_id']) ? intval($post['bargainorder_id']) : 0;
  619. if ($bargainorder_id > 0) {
  620. $extra['bargainorder_id'] = $bargainorder_id; #砍价ID
  621. }
  622. //商品信息[得到最新商品属性及促销信息]
  623. $goods_info = $this->_logic_buy_1->getGoodsOnlineInfo($goods_id, intval($quantity), $extra, $this->_member_info['member_id']);
  624. if (empty($goods_info)) {
  625. throw new \think\Exception('商品已下架或不存在', 10006);
  626. }
  627. //进一步处理数组
  628. $store_cart_list = [];
  629. $goods_list = [];
  630. $goods_info['chain_id'] = isset($this->_post_data['chain_goods']['0_' . $goods_info['goods_id']]) ? $this->_post_data['chain_goods']['0_' . $goods_info['goods_id']] : 0;
  631. $goods_list[0] = $store_cart_list[$goods_info['store_id']][0] = $goods_info;
  632. }
  633. //F码验证
  634. $goodsfcode_id = '';
  635. if (!empty($post['fcode'])) {
  636. $goodsfcode_id = $this->_checkFcode($goods_list, $post['fcode']);
  637. if (!$goodsfcode_id) {
  638. throw new \think\Exception('F码商品验证错误', 10006);
  639. }
  640. }
  641. $this->_order_data['goodsfcode_id'] = $goodsfcode_id;
  642. //保存数据
  643. $this->_order_data['goods_list'] = $goods_list;
  644. $this->_order_data['store_cart_list'] = $store_cart_list;
  645. }
  646. /**
  647. * 得到购买相关金额计算等信息
  648. *
  649. */
  650. private function _createOrderStep3()
  651. {
  652. $goods_list = $this->_order_data['goods_list'];
  653. $store_cart_list = $this->_order_data['store_cart_list'];
  654. $input_voucher_list = $this->_order_data['input_voucher_list'];
  655. $input_city_id = $this->_order_data['input_city_id'];
  656. //商品金额计算(分别对每个商品/优惠套装小计、每个店铺小计)
  657. list($store_cart_list, $store_goods_total, $store_goods_original_total, $store_goods_discount_total) = $this->_logic_buy_1->calcCartList($store_cart_list);
  658. // $abc = $this->_logic_buy_1->calcCartList($store_cart_list);
  659. //取得店铺优惠 - 满即送(赠品列表,店铺满送规则列表)
  660. list($store_premiums_list, $store_mansong_rule_list) = $this->_logic_buy_1->getMansongruleCartListByTotal($store_goods_total);
  661. //重新计算店铺扣除满即送后商品实际支付金额
  662. $store_final_goods_total = $this->_logic_buy_1->reCalcGoodsTotal($store_goods_total, $store_mansong_rule_list, 'mansong');
  663. //得到有效的代金券
  664. $input_voucher_list = $this->_logic_buy_1->reParseVoucherList($input_voucher_list, $store_goods_total, $this->_member_info['member_id']);
  665. //重新计算店铺扣除优惠券送商品实际支付金额
  666. $store_final_goods_total = $this->_logic_buy_1->reCalcGoodsTotal($store_final_goods_total, $input_voucher_list, 'voucher');
  667. //计算每个店铺(所有店铺级优惠活动)总共优惠多少
  668. $store_promotion_total = $this->_logic_buy_1->getStorePromotionTotal($store_goods_total, $store_final_goods_total);
  669. //计算每个店铺运费
  670. list($need_calc_sid_list, $cancel_calc_sid_list) = $this->_logic_buy_1->getStoreFreightDescList($store_final_goods_total);
  671. $freight_list = $this->_logic_buy_1->getStoreFreightList($goods_list, array_keys($cancel_calc_sid_list));
  672. $store_freight_total = $this->_logic_buy_1->calcStoreFreight($freight_list, $input_city_id);
  673. if (empty($store_freight_total)) {
  674. throw new \think\Exception('抱歉,商品在所在地区无货', 10006);
  675. }
  676. //计算店铺最终订单实际支付金额(加上运费)
  677. $store_final_order_total = $this->_logic_buy_1->reCalcGoodsTotal($store_final_goods_total, $store_freight_total, 'freight');
  678. //计算店铺分类佣金[改由任务计划]
  679. $store_gc_id_commis_rate_list = model('storebindclass')->getStoreGcidCommisRateList($goods_list);
  680. //将赠品追加到购买列表(如果库存0,则不送赠品)
  681. $append_premiums_to_cart_list = $this->_logic_buy_1->appendPremiumsToCartList($store_cart_list, $store_premiums_list, $store_mansong_rule_list, $this->_member_info['member_id']);
  682. if ($append_premiums_to_cart_list === false) {
  683. throw new \think\Exception('抱歉,您购买的商品库存不足,请重购买', 10006);
  684. } else {
  685. list($store_cart_list, $goods_buy_quantity, $store_mansong_rule_list) = $append_premiums_to_cart_list;
  686. }
  687. //保存数据
  688. $this->_order_data['store_goods_total'] = $store_goods_total;
  689. $this->_order_data['store_final_order_total'] = $store_final_order_total;
  690. $this->_order_data['store_freight_total'] = $store_freight_total;
  691. $this->_order_data['store_promotion_total'] = $store_promotion_total;
  692. $this->_order_data['store_gc_id_commis_rate_list'] = $store_gc_id_commis_rate_list;
  693. $this->_order_data['store_mansong_rule_list'] = $store_mansong_rule_list;
  694. $this->_order_data['store_cart_list'] = $store_cart_list;
  695. $this->_order_data['goods_buy_quantity'] = $goods_buy_quantity;
  696. $this->_order_data['input_voucher_list'] = $input_voucher_list;
  697. }
  698. /**
  699. * 生成订单
  700. * @param array $input
  701. * @throws Exception
  702. * @return array array(支付单sn,订单列表)
  703. */
  704. private function _createOrderStep4()
  705. {
  706. extract($this->_order_data);
  707. $member_id = $this->_member_info['member_id'];
  708. $member_name = $this->_member_info['member_name'];
  709. $member_email = $this->_member_info['member_email'];
  710. $order_model = model('order');
  711. //存储生成的订单数据
  712. $order_list = [];
  713. //存储通知信息
  714. $notice_list = [];
  715. //每个店铺订单是货到付款还是线上支付,店铺ID=>付款方式[在线支付/货到付款]
  716. $store_pay_type_list = $this->_logic_buy_1->getStorePayTypeList(array_keys($store_cart_list), $input_if_offpay, $input_pay_name);
  717. foreach ($store_pay_type_list as $k => & $v) {
  718. if (empty($input_if_offpay_batch[$k]))
  719. $v = 'online';
  720. }
  721. $cardId = $cardId = input('post.card_id'); //抵扣卡的Id
  722. if (!empty($cardId) || $cardId != 0) {
  723. // $goods_list
  724. $gcIds = [];
  725. foreach ($store_cart_list as $goods_list) {
  726. foreach ($goods_list as $good) {
  727. $gcIds[] = $good['gc_id'];
  728. }
  729. }
  730. $cardInfo = Db::name('sub_card')->where([
  731. ['id', '=', $cardId],
  732. ['member_id', '=', $member_id],
  733. ])->find();
  734. if (empty($cardInfo)) {
  735. ds_json_encode(10001, '当前支付出现异常,请联系管理员处理.');
  736. }
  737. if (!empty($cardInfo['bind_cate'])) {
  738. $cateLimits = explode(',', $cardInfo['bind_cate']);
  739. $diff = array_values(array_diff($gcIds, $cateLimits));
  740. if (!empty($diff)) {
  741. ds_json_encode(10001, '订单中存在无法使用卡券商品.');
  742. }
  743. }
  744. }
  745. $pay_sn = makePaySn($member_id);
  746. $order_pay = [];
  747. $order_pay['pay_sn'] = $pay_sn;
  748. $order_pay['buyer_id'] = $member_id;
  749. $order_pay_id = $order_model->addOrderpay($order_pay);
  750. if (!$order_pay_id) {
  751. throw new \think\Exception('订单保存失败[未生成支付单]', 10006);
  752. }
  753. //收货人信息
  754. list($reciver_info, $reciver_name) = $this->_logic_buy_1->getReciverAddr($input_address_info);
  755. foreach ($store_cart_list as $store_id => $goods_list) {
  756. //取得本店优惠额度(后面用来计算每件商品实际支付金额,结算需要)
  757. $promotion_total = !empty($store_promotion_total[$store_id]) ? $store_promotion_total[$store_id] : 0;
  758. //本店总的优惠比例,保留3位小数
  759. $should_goods_total = $store_final_order_total[$store_id] - $store_freight_total[$store_id] + $promotion_total;
  760. $promotion_rate = abs(number_format($promotion_total / $should_goods_total, 5, '.', ''));
  761. if ($promotion_rate <= 1) {
  762. $promotion_rate = floatval(substr($promotion_rate, 0, 5));
  763. } else {
  764. $promotion_rate = 0;
  765. }
  766. //每种商品的优惠金额累加保存入 $promotion_sum
  767. $promotion_sum = 0;
  768. $order = [];
  769. $order_common = [];
  770. $order_goods = [];
  771. $order['order_sn'] = $this->_logic_buy_1->makeOrderSn($order_pay_id);
  772. $order['pay_sn'] = $pay_sn;
  773. $order['store_id'] = $store_id;
  774. $order['store_name'] = $goods_list[0]['store_name'];
  775. $order['buyer_id'] = $member_id;
  776. $order['buyer_name'] = $member_name;
  777. $order['buyer_email'] = $member_email;
  778. $order['add_time'] = TIMESTAMP;
  779. $order['payment_code'] = $store_pay_type_list[$store_id];
  780. if (!empty($goods_list[0]['presell_info']) && $goods_list[0]['presell_info']['presell_type'] == 2) {
  781. $order['presell_deposit_amount'] = round($goods_list[0]['presell_info']['presell_deposit_amount'] * $goods_list[0]['goods_num'], 2);
  782. $order['presell_end_time'] = $goods_list[0]['presell_info']['presell_end_time'];
  783. }
  784. $order['order_state'] = $store_pay_type_list[$store_id] == 'online' ? (isset($this->_post_data['presell_pay']) && $this->_post_data['presell_pay'] == 2 ? ORDER_STATE_DEPOSIT : ORDER_STATE_NEW) : ORDER_STATE_PAY;
  785. $order['deduction_amount'] = 0;
  786. //新增内容
  787. $orderAmount = $store_final_order_total[$store_id]; //初始订单金额
  788. if (!empty($cardId) || $cardId != 0) {
  789. if (strpos($cardId, ',') !== false) {
  790. $card_ids = explode(',', $cardId);
  791. } else {
  792. $card_ids[] = $cardId;
  793. }
  794. $SubCard = model('Subcard');
  795. $unpaid_amount = $orderAmount;
  796. foreach ($card_ids as $key => $value) {
  797. $where = [];
  798. $where['id'] = $value;
  799. $where['member_id'] = $member_id;
  800. $cardInfo = $SubCard->where($where)->find();
  801. if (!$cardInfo && $cardInfo['card_status'] != 3 && $cardInfo['balance'] != 0) {
  802. continue;
  803. }
  804. $balance = $cardInfo['balance'];
  805. //1.卡的余额要变, 订单金额也要变
  806. if ($balance < $orderAmount - $order['deduction_amount']) {
  807. //余额小于 先冻结起来
  808. $pay_amount = $balance;
  809. $order['deduction_amount'] += $pay_amount;
  810. $unpaid_amount =
  811. $order['card_id'] = $value;
  812. $updateInfo = [
  813. 'balance' => 0,
  814. 'card_status' => 3,//用完了
  815. 'freeze' => $cardInfo['freeze'] + $pay_amount, //余额冻结
  816. 'used_count' => $cardInfo['used_count'] + 1,
  817. 'update_time' => time(),
  818. ];
  819. } else {
  820. //余额大于等于订单金额
  821. $pay_amount = $orderAmount - $order['deduction_amount'];
  822. $order['deduction_amount'] += $pay_amount;
  823. $order['card_id'] = $cardId;
  824. $order['payment_code'] = 'card';
  825. $order['payment_time'] = time();
  826. $updateInfo = [
  827. 'balance' => $balance - $pay_amount,
  828. 'card_status' => 2, //状态为使用中
  829. 'freeze' => $cardInfo['freeze'] + $pay_amount, //余额冻结
  830. 'used_count' => $cardInfo['used_count'] + 1,
  831. 'update_time' => time(),
  832. ];
  833. $order['order_state'] = 20; //直接就到了待发货阶段
  834. $logic_payment = model('payment', 'logic'); //推送消息记录
  835. $info = [
  836. 'cardNo' => $cardInfo['card_no'],
  837. 'memberId' => $member_id,
  838. 'amount' => $orderAmount,
  839. 'orderNo' => $order['order_sn'],
  840. ];
  841. $logic_payment->payRecordPushNoAmount($info, 0);
  842. }
  843. $res = Db::name('sub_card')->where([
  844. ['id', '=', $value],
  845. ])->update($updateInfo);
  846. $expenseData[$key] = [
  847. 'member_id' => $member_id,
  848. 'card_id' => $value,
  849. 'expense_amount' => $pay_amount, //抵消金额
  850. 'order_amount' => $orderAmount,
  851. 'expense_time' => time(),
  852. ];
  853. }
  854. }
  855. $order['order_amount'] = $orderAmount;
  856. $order['shipping_fee'] = $store_freight_total[$store_id];
  857. $order['goods_amount'] = $order['order_amount'] - $order['shipping_fee'];
  858. $order['order_from'] = $order_from;
  859. $order['pd_amount'] = 0;
  860. //如果支持方式为空时,默认为货到付款
  861. if ($order['payment_code'] == "") {
  862. $order['payment_code'] = "offline";
  863. }
  864. if ($order['payment_code'] == "offline" && $input_address_info['chain_id']) {
  865. throw new \think\Exception('代收点不可以使用货到付款[未生成订单数据]', 10006);
  866. }
  867. // var_dump($order);exit();
  868. $order_id = $order_model->addOrder($order);
  869. if (!$order_id) {
  870. throw new \think\Exception('订单保存失败[未生成订单数据]', 10006);
  871. }
  872. // var_dump(111);exit();
  873. $order['order_id'] = $order_id;
  874. if (!empty($expenseData)) {
  875. foreach ($expenseData as $key => $value) {
  876. //插入消费记录
  877. $value['order_id'] = $order_id;
  878. $addExpense = Db::name('sub_card_expense')->insert($value);
  879. }
  880. if ($order['deduction_amount'] == $order['order_amount']) {
  881. $logic_payment->paysuccesspush($order, 0);
  882. }
  883. }
  884. $order_list[$order_id] = $order;
  885. $order_common['order_id'] = $order_id;
  886. $order_common['store_id'] = $store_id;
  887. $order_common['order_message'] = $input_pay_message[$store_id];
  888. //代金券
  889. if (isset($input_voucher_list[$store_id])) {
  890. $order_common['voucher_price'] = $input_voucher_list[$store_id]['voucher_price'];
  891. $order_common['voucher_code'] = $input_voucher_list[$store_id]['voucher_code'];
  892. }
  893. $order_common['reciver_info'] = $reciver_info;
  894. $order_common['reciver_name'] = $reciver_name;
  895. $order_common['reciver_city_id'] = $input_city_id;
  896. //发票信息
  897. $order_common['invoice_info'] = $this->_logic_buy_1->createInvoiceData($input_invoice_info);
  898. //保存促销信息
  899. if (isset($store_mansong_rule_list[$store_id])) {
  900. $order_common['promotion_info'] = addslashes($store_mansong_rule_list[$store_id]['desc']);
  901. }
  902. $order_id = $order_model->addOrdercommon($order_common);
  903. if (!$order_id) {
  904. throw new \think\Exception('订单保存失败[未生成订单扩展数据]', 10006);
  905. }
  906. $order_list[$order_id]['order_common'] = $order_common;
  907. //生成order_goods订单商品数据
  908. $i = 0;
  909. foreach ($goods_list as $goods_info) {
  910. if (!$goods_info['state'] || !$goods_info['storage_state']) {
  911. throw new \think\Exception('部分商品已经下架或库存不足,请重新选择', 10006);
  912. }
  913. if (!intval($goods_info['bl_id'])) {
  914. //如果不是优惠套装
  915. $order_goods[$i]['chain_id'] = $goods_info['chain_id'];
  916. $order_goods[$i]['order_id'] = $order_id;
  917. $order_goods[$i]['goods_id'] = $goods_info['goods_id'];
  918. $order_goods[$i]['store_id'] = $store_id;
  919. $order_goods[$i]['goods_name'] = $goods_info['goods_name'];
  920. $order_goods[$i]['goods_price'] = $goods_info['goods_price'];
  921. $order_goods[$i]['goods_num'] = $goods_info['goods_num'];
  922. $order_goods[$i]['goods_image'] = $goods_info['goods_image'];
  923. $order_goods[$i]['buyer_id'] = $member_id;
  924. $ifgroupbuy = false;
  925. if (isset($goods_info['ifgroupbuy'])) {
  926. $ifgroupbuy = true;
  927. $order_goods[$i]['goods_type'] = 2;
  928. } elseif (isset($goods_info['ifxianshi'])) {
  929. $order_goods[$i]['goods_type'] = 3;
  930. } elseif (isset($goods_info['ifpresell'])) {
  931. $order_goods[$i]['goods_type'] = 10;
  932. } elseif (isset($goods_info['ifwholesale'])) {
  933. $order_goods[$i]['goods_type'] = 9;
  934. } elseif (isset($goods_info['ifzengpin'])) {
  935. $order_goods[$i]['goods_type'] = 5;
  936. } elseif (isset($goods_info['ifpintuan']) && intval($this->_post_data['pintuan_id']) > 0) {
  937. //拼团订单
  938. /**
  939. * $goods_info['ifpintuan'] , $goods_info['pintuan_id'] 此数据是通过商品ID 获取到是否为拼团订单
  940. * $this->_post_data['pintuan_id'] $this->_post_data['pintuangroup_id'] 此数据是通过post 过来的数据,用来判断是否为首个拼团订单:0首个订单 其他为所属订单
  941. */
  942. $order_goods[$i]['goods_type'] = 6;
  943. $res = $this->_logic_buy_1->updatePintuan($this->_post_data, $goods_info, $order, 0, $member_id);
  944. $goods_info['promotions_id'] = $res['pintuangroup_id'];
  945. } elseif (isset($goods_info['ifbargain']) && $goods_info['ifbargain']) {
  946. //砍价订单
  947. $order_goods[$i]['goods_type'] = 8;
  948. if (!model('pbargainorder')->editPbargainorder(['bargainorder_id' => $goods_info['promotions_id']], ['order_id' => $order_id])) {
  949. throw new \think\Exception('砍价活动更新失败', 10006);
  950. }
  951. } elseif (isset($goods_info['ifmgdiscount'])) {
  952. $order_goods[$i]['goods_type'] = 7;
  953. } else {
  954. $order_goods[$i]['goods_type'] = 1;
  955. }
  956. $order_goods[$i]['promotions_id'] = isset($goods_info['promotions_id']) ? $goods_info['promotions_id'] : 0;
  957. $order_goods[$i]['commis_rate'] = floatval(@$store_gc_id_commis_rate_list[$store_id][$goods_info['gc_id']]);
  958. $order_goods[$i]['gc_id'] = $goods_info['gc_id'];
  959. //计算商品金额
  960. $goods_total = $goods_info['goods_price'] * $goods_info['goods_num'];
  961. //计算本件商品优惠金额
  962. $promotion_value = floor($goods_total * ($promotion_rate));
  963. $order_goods[$i]['goods_pay_price'] = $goods_total - $promotion_value;
  964. $promotion_sum += $promotion_value;
  965. $i++;
  966. //存储库存报警数据
  967. if (isset($goods_info['goods_storage_alarm']) && $goods_info['goods_storage_alarm'] >= ($goods_info['goods_storage'] - $goods_info['goods_num'])) {
  968. $param = [];
  969. $param['common_id'] = $goods_info['goods_commonid'];
  970. $param['sku_id'] = $goods_info['goods_id'];
  971. $ten_param = [$param['common_id'], $param['sku_id']];
  972. $weixin_param = [
  973. 'url' => config('ds_config.h5_site_url') . '/seller/goods_form_2?commonid=' . $goods_info['goods_commonid'] . '&class_id=' . $goods_info['gc_id'],
  974. 'data' => [
  975. "keyword1" => [
  976. "value" => $goods_info['goods_storage'] - $goods_info['goods_num'],
  977. "color" => "#333",
  978. ],
  979. "keyword2" => [
  980. "value" => date('Y-m-d H:i'),
  981. "color" => "#333",
  982. ],
  983. ],
  984. ];
  985. $notice_list['goods_storage_alarm'][$goods_info['store_id']] = ['param' => $param, 'ali_param' => $param, 'ten_param' => $ten_param, 'weixin_param' => $weixin_param];
  986. }
  987. } elseif (!empty($goods_info['bl_goods_list']) && is_array($goods_info['bl_goods_list'])) {
  988. $ifgroupbuy = false;
  989. //优惠套装
  990. foreach ($goods_info['bl_goods_list'] as $bl_goods_info) {
  991. $order_goods[$i]['chain_id'] = $bl_goods_info['chain_id'];
  992. $order_goods[$i]['order_id'] = $order_id;
  993. $order_goods[$i]['goods_id'] = $bl_goods_info['goods_id'];
  994. $order_goods[$i]['store_id'] = $store_id;
  995. $order_goods[$i]['goods_name'] = $bl_goods_info['goods_name'];
  996. $order_goods[$i]['goods_price'] = $bl_goods_info['blgoods_price'];
  997. $order_goods[$i]['goods_num'] = $goods_info['goods_num'];
  998. $order_goods[$i]['goods_image'] = $bl_goods_info['goods_image'];
  999. $order_goods[$i]['buyer_id'] = $member_id;
  1000. $order_goods[$i]['goods_type'] = 4;
  1001. $order_goods[$i]['promotions_id'] = $bl_goods_info['bl_id'];
  1002. $order_goods[$i]['commis_rate'] = floatval(@$store_gc_id_commis_rate_list[$store_id][$goods_info['gc_id']]);
  1003. $order_goods[$i]['gc_id'] = $bl_goods_info['gc_id'];
  1004. //计算商品实际支付金额(goods_price减去分摊优惠金额后的值)
  1005. $goods_total = $bl_goods_info['blgoods_price'] * $goods_info['goods_num'];
  1006. //计算本件商品优惠金额
  1007. $promotion_value = floor($goods_total * ($promotion_rate));
  1008. $order_goods[$i]['goods_pay_price'] = $goods_total - $promotion_value;
  1009. $promotion_sum += $promotion_value;
  1010. $i++;
  1011. //存储库存报警数据
  1012. if ($bl_goods_info['goods_storage_alarm'] >= ($bl_goods_info['goods_storage'] - $goods_info['goods_num'])) {
  1013. $param = [];
  1014. $param['common_id'] = $bl_goods_info['goods_commonid'];
  1015. $param['sku_id'] = $bl_goods_info['goods_id'];
  1016. $ten_param = [$param['common_id'], $param['sku_id']];
  1017. $weixin_param = [
  1018. 'url' => config('ds_config.h5_site_url') . '/seller/goods_form_2?commonid=' . $goods_info['goods_commonid'] . '&class_id=' . $goods_info['gc_id'],
  1019. 'data' => [
  1020. "keyword1" => [
  1021. "value" => $goods_info['goods_storage'] - $goods_info['goods_num'],
  1022. "color" => "#333",
  1023. ],
  1024. "keyword2" => [
  1025. "value" => date('Y-m-d H:i'),
  1026. "color" => "#333",
  1027. ],
  1028. ],
  1029. ];
  1030. $notice_list['goods_storage_alarm'][$bl_goods_info['store_id']] = ['param' => $param, 'ali_param' => $param, 'ten_param' => $ten_param, 'weixin_param' => $weixin_param];
  1031. }
  1032. }
  1033. }
  1034. }
  1035. //将因舍出小数部分出现的差值补到最后一个商品的实际成交价中(商品goods_price=0时不给补,可能是赠品)
  1036. if ($promotion_total > $promotion_sum) {
  1037. $i--;
  1038. for ($i; $i >= 0; $i--) {
  1039. if (floatval($order_goods[$i]['goods_price']) > 0) {
  1040. $order_goods[$i]['goods_pay_price'] -= $promotion_total - $promotion_sum;
  1041. break;
  1042. }
  1043. }
  1044. }
  1045. $insert = $order_model->addOrdergoods($order_goods);
  1046. if (!$insert) {
  1047. throw new \think\Exception('订单保存失败[未生成商品数据]', 10006);
  1048. }
  1049. //自提订单
  1050. $chain_order_data = $order_model->getOrdergoodsList([['order_id', '=', $order_id], ['chain_id', '>', 0]]);
  1051. $chain_list = [];
  1052. $chain_model = model('chain');
  1053. $chain_order_model = model('chain_order');
  1054. if (count($chain_order_data) > 1) {//单商品自提
  1055. throw new \think\Exception('自提订单错误[未生成自提数据]', 10006);
  1056. }
  1057. foreach ($chain_order_data as $v) {
  1058. if (!isset($chain_list[$v['chain_id']])) {
  1059. $chain_list[$v['chain_id']] = $chain_model->getChainOpenInfo([['chain_id', '=', $v['chain_id']]]);
  1060. }
  1061. if (!$chain_list[$v['chain_id']]) {
  1062. throw new \think\Exception('自提点不存在[未生成自提数据]', 10006);
  1063. }
  1064. if ($chain_list[$v['chain_id']]['chain_if_pickup'] != 1) {
  1065. throw new \think\Exception('自提点已关闭自提[未生成自提数据]', 10006);
  1066. }
  1067. $chain_order_model->addChainOrder([
  1068. 'order_id' => $v['order_id'],
  1069. 'order_goods_id' => $v['rec_id'],
  1070. 'chain_order_type' => 2,
  1071. 'chain_order_pickup_code' => rand(1, 9) . rand(0, 9) . rand(0, 9) . rand(0, 9),
  1072. 'payment_code' => $order_list[$order_id]['payment_code'],
  1073. 'chain_order_add_time' => TIMESTAMP,
  1074. 'order_sn' => $order_list[$order_id]['order_sn'],
  1075. 'chain_id' => $v['chain_id'],
  1076. 'store_id' => $v['store_id'],
  1077. ]);
  1078. //减库存
  1079. Db::name('chain_goods')->where([['chain_id', '=', $v['chain_id']], ['goods_id', '=', $v['goods_id']]])->dec('goods_storage', $v['goods_num'])->update();
  1080. }
  1081. $order_list[$order_id]['order_goods'] = $order_goods;
  1082. //存储商家发货提醒数据
  1083. if ($order['order_state'] == ORDER_STATE_PAY) {
  1084. //更改自提点的订单状态
  1085. $chain_order_model->editChainOrderPay($order_id);
  1086. $weixin_param = [
  1087. 'url' => config('ds_config.h5_site_url') . '/seller/order_detail?order_id=' . $order_id,
  1088. 'data' => [
  1089. "keyword1" => [
  1090. "value" => $order['order_sn'],
  1091. "color" => "#333",
  1092. ],
  1093. "keyword2" => [
  1094. "value" => $order_goods[0]['goods_name'] . (count($order_goods) > 1 ? sprintf(lang('order_goods_more_than_one'), count($order_goods)) : ''),
  1095. "color" => "#333",
  1096. ],
  1097. "keyword3" => [
  1098. "value" => $order['order_amount'],
  1099. "color" => "#333",
  1100. ],
  1101. "keyword4" => [
  1102. "value" => date('Y-m-d H:i', $order['add_time']),
  1103. "color" => "#333",
  1104. ],
  1105. ],
  1106. ];
  1107. $notice_list['new_order'][$order['store_id']] = ['param' => ['order_sn' => $order['order_sn']], 'ali_param' => ['order_sn' => $order['order_sn']], 'ten_param' => [$order['order_sn']], 'weixin_param' => $weixin_param];
  1108. //蛋糕订单
  1109. $logic_payment = model('payment', 'logic');
  1110. $logic_payment->payPhoneMessage($order, 0);
  1111. }
  1112. }
  1113. //保存数据
  1114. $this->_order_data['pay_sn'] = $pay_sn;
  1115. $this->_order_data['order_list'] = $order_list;
  1116. $this->_order_data['notice_list'] = $notice_list;
  1117. $this->_order_data['ifgroupbuy'] = $ifgroupbuy;
  1118. }
  1119. /**
  1120. * 订单后续其它处理
  1121. */
  1122. private function _createOrderStep6()
  1123. {
  1124. $ifcart = $this->_post_data['ifcart'];
  1125. $goods_buy_quantity = $this->_order_data['goods_buy_quantity'];
  1126. $input_voucher_list = $this->_order_data['input_voucher_list'];
  1127. $store_cart_list = $this->_order_data['store_cart_list'];
  1128. $input_buy_items = $this->_order_data['input_buy_items'];
  1129. $order_list = $this->_order_data['order_list'];
  1130. $input_address_info = $this->_order_data['input_address_info'];
  1131. $notice_list = $this->_order_data['notice_list'];
  1132. $goodsfcode_id = $this->_order_data['goodsfcode_id'];
  1133. $ifgroupbuy = $this->_order_data['ifgroupbuy'];
  1134. //变更库存和销量
  1135. //\mall\queue\QueueClient::push('createOrderUpdateStorage', $goods_buy_quantity);
  1136. $res = model('queue', 'logic')->createOrderUpdateStorage($goods_buy_quantity);
  1137. if (!$res['code']) {
  1138. throw new \think\Exception($res['msg'], 10006);
  1139. }
  1140. //更新使用的代金券状态
  1141. if (!empty($input_voucher_list) && is_array($input_voucher_list)) {
  1142. \mall\queue\QueueClient::push('editVoucherState', $input_voucher_list);
  1143. }
  1144. //更新F码使用状态
  1145. if ($goodsfcode_id) {
  1146. \mall\queue\QueueClient::push('updateGoodsfcode', $goodsfcode_id);
  1147. }
  1148. //更新抢购购买人数和数量
  1149. if ($ifgroupbuy) {
  1150. foreach ($store_cart_list as $goods_list) {
  1151. foreach ($goods_list as $goods_info) {
  1152. if (isset($goods_info['ifgroupbuy']) && isset($goods_info['groupbuy_id'])) {
  1153. $groupbuy_info = [];
  1154. $groupbuy_info['groupbuy_id'] = $goods_info['groupbuy_id'];
  1155. $groupbuy_info['quantity'] = $goods_info['goods_num'];
  1156. \mall\queue\QueueClient::push('editGroupbuySaleCount', $groupbuy_info);
  1157. }
  1158. }
  1159. }
  1160. }
  1161. //删除购物车中的商品
  1162. $this->delCart($ifcart, $this->_member_info['member_id'], array_keys($input_buy_items));
  1163. cookie('cart_goods_num', '', -3600);
  1164. //保存订单代收信息
  1165. if (config('ds_config.chain_isuse') && intval($input_address_info['chain_id'])) {
  1166. $data = [];
  1167. $data['chain_id'] = $input_address_info['chain_id'];
  1168. foreach ($order_list as $v) {
  1169. if (!$v['order_goods'][0]['chain_id']) {
  1170. $data['order_sn_list'][$v['order_id']]['store_id'] = $v['store_id'];
  1171. $data['order_sn_list'][$v['order_id']]['order_sn'] = $v['order_sn'];
  1172. $data['order_sn_list'][$v['order_id']]['add_time'] = $v['add_time'];
  1173. }
  1174. }
  1175. if (isset($data['order_sn_list'])) {
  1176. \mall\queue\QueueClient::push('saveChainOrder', $data);
  1177. }
  1178. }
  1179. //生成推广记录
  1180. $this->addOrderInviter($order_list);
  1181. //发送提醒类信息
  1182. if (!empty($notice_list)) {
  1183. foreach ($notice_list as $code => $value) {
  1184. $temp = current($value);
  1185. \mall\queue\QueueClient::push('sendStoremsg', [
  1186. 'code' => $code, 'store_id' => key($value), 'param' => $temp['param'], 'weixin_param' => $temp['weixin_param'], 'ali_param' => $temp['ali_param'], 'ten_param' => $temp['ten_param'],
  1187. ]);
  1188. }
  1189. }
  1190. }
  1191. /**
  1192. * 加密
  1193. * @param array /string $string
  1194. * @param int $member_id
  1195. * @return mixed arrray/string
  1196. */
  1197. public function buyEncrypt($string, $member_id)
  1198. {
  1199. $buy_key = sha1(md5($member_id . '&' . md5(config('ds_config.setup_date'))));
  1200. if (is_array($string)) {
  1201. $string = serialize($string);
  1202. } else {
  1203. $string = strval($string);
  1204. }
  1205. return ds_encrypt(base64_encode($string), $buy_key);
  1206. }
  1207. /**
  1208. * 解密
  1209. * @param string $string
  1210. * @param int $member_id
  1211. * @param number $ttl
  1212. */
  1213. public function buyDecrypt($string, $member_id, $ttl = 0)
  1214. {
  1215. $buy_key = sha1(md5($member_id . '&' . md5(config('ds_config.setup_date'))));
  1216. if (empty($string))
  1217. return;
  1218. $string = base64_decode(ds_decrypt(strval($string), $buy_key, $ttl));
  1219. return ($tmp = @unserialize($string)) !== false ? $tmp : $string;
  1220. }
  1221. /**
  1222. * 得到所购买的id和数量
  1223. *
  1224. */
  1225. private function _parseItems($cart_id)
  1226. {
  1227. //存放所购商品ID和数量组成的键值对
  1228. $buy_items = [];
  1229. if (is_array($cart_id)) {
  1230. foreach ($cart_id as $value) {
  1231. if (preg_match_all('/^(\d{1,10})\|(\d{1,6})$/', $value, $match)) {
  1232. if (intval($match[2][0]) > 0) {
  1233. $buy_items[$match[1][0]] = $match[2][0];
  1234. }
  1235. }
  1236. }
  1237. }
  1238. return $buy_items;
  1239. }
  1240. /**
  1241. * 从购物车数组中得到商品列表
  1242. * @param unknown $cart_list
  1243. */
  1244. private function _getGoodsList($cart_list)
  1245. {
  1246. if (empty($cart_list) || !is_array($cart_list))
  1247. return $cart_list;
  1248. $goods_list = [];
  1249. $i = 0;
  1250. foreach ($cart_list as $key => $cart) {
  1251. if (!$cart['state'] || !$cart['storage_state'])
  1252. continue;
  1253. //购买数量
  1254. $quantity = $cart['goods_num'];
  1255. if (!intval($cart['bl_id'])) {
  1256. //如果是普通商品
  1257. $goods_list[$i]['chain_id'] = isset($this->_post_data['chain_goods']['0_' . $cart['goods_id']]) ? $this->_post_data['chain_goods']['0_' . $cart['goods_id']] : 0;
  1258. $goods_list[$i]['goods_num'] = $quantity;
  1259. $goods_list[$i]['goods_id'] = $cart['goods_id'];
  1260. $goods_list[$i]['store_id'] = $cart['store_id'];
  1261. $goods_list[$i]['gc_id'] = $cart['gc_id'];
  1262. $goods_list[$i]['goods_weight'] = $cart['goods_weight'];
  1263. $goods_list[$i]['gc_id_1'] = $cart['gc_id_1'];
  1264. $goods_list[$i]['gc_id_2'] = $cart['gc_id_2'];
  1265. $goods_list[$i]['gc_id_3'] = $cart['gc_id_3'];
  1266. $goods_list[$i]['goods_name'] = $cart['goods_name'];
  1267. $goods_list[$i]['goods_price'] = $cart['goods_price'];
  1268. $goods_list[$i]['goods_original_price'] = $cart['goods_original_price'];
  1269. $goods_list[$i]['store_name'] = $cart['store_name'];
  1270. $goods_list[$i]['goods_image'] = $cart['goods_image'];
  1271. $goods_list[$i]['transport_id'] = $cart['transport_id'];
  1272. $goods_list[$i]['goods_freight'] = $cart['goods_freight'];
  1273. $goods_list[$i]['goods_vat'] = $cart['goods_vat'];
  1274. $goods_list[$i]['is_goodsfcode'] = $cart['is_goodsfcode'];
  1275. $goods_list[$i]['bl_id'] = 0;
  1276. $i++;
  1277. } else {
  1278. //如果是优惠套装商品
  1279. foreach ($cart['bl_goods_list'] as $bl_goods) {
  1280. $goods_list[$i]['chain_id'] = isset($this->_post_data['chain_goods'][$cart['bl_id'] . '_' . $bl_goods['goods_id']]) ? $this->_post_data['chain_goods'][$cart['bl_id'] . '_' . $bl_goods['goods_id']] : 0;
  1281. $goods_list[$i]['goods_num'] = $quantity;
  1282. $goods_list[$i]['goods_id'] = $bl_goods['goods_id'];
  1283. $goods_list[$i]['store_id'] = $cart['store_id'];
  1284. $goods_list[$i]['gc_id'] = $bl_goods['gc_id'];
  1285. $goods_list[$i]['goods_weight'] = $bl_goods['goods_weight'];
  1286. $goods_list[$i]['gc_id_1'] = $bl_goods['gc_id_1'];
  1287. $goods_list[$i]['gc_id_2'] = $bl_goods['gc_id_2'];
  1288. $goods_list[$i]['gc_id_3'] = $bl_goods['gc_id_3'];
  1289. $goods_list[$i]['goods_name'] = $bl_goods['goods_name'];
  1290. $goods_list[$i]['goods_price'] = $bl_goods['blgoods_price'];
  1291. $goods_list[$i]['goods_original_price'] = $bl_goods['goods_original_price'];
  1292. $goods_list[$i]['store_name'] = $bl_goods['store_name'];
  1293. $goods_list[$i]['goods_image'] = $bl_goods['goods_image'];
  1294. $goods_list[$i]['transport_id'] = $bl_goods['transport_id'];
  1295. $goods_list[$i]['goods_freight'] = $bl_goods['goods_freight'];
  1296. $goods_list[$i]['goods_vat'] = $bl_goods['goods_vat'];
  1297. $goods_list[$i]['bl_id'] = $cart['bl_id'];
  1298. $i++;
  1299. }
  1300. }
  1301. }
  1302. return $goods_list;
  1303. }
  1304. /**
  1305. * 将下单商品列表转换为以店铺ID为下标的数组
  1306. *
  1307. * @param array $cart_list
  1308. * @return array
  1309. */
  1310. private function _getStoreCartList($cart_list)
  1311. {
  1312. if (empty($cart_list) || !is_array($cart_list))
  1313. return $cart_list;
  1314. $new_array = [];
  1315. foreach ($cart_list as $cart) {
  1316. $new_array[$cart['store_id']][] = $cart;
  1317. }
  1318. return $new_array;
  1319. }
  1320. /**
  1321. * 本次下单是否需要码及F码合法性
  1322. * 无需使用F码,返回 true
  1323. * 需要使用F码,返回($goodsfcode_id/false)
  1324. */
  1325. private function _checkFcode($goods_list, $fcode)
  1326. {
  1327. $is_goodsfcode = false;
  1328. foreach ($goods_list as $k => $v) {
  1329. if ($v['is_goodsfcode'] == 1) {
  1330. $is_goodsfcode = true;
  1331. break;
  1332. }
  1333. }
  1334. if (!$is_goodsfcode)
  1335. return true;
  1336. if (empty($fcode) || count($goods_list) > 1) {
  1337. return false;
  1338. }
  1339. $goods_info = $goods_list[0];
  1340. $fcode_info = $this->checkFcode($goods_info['goods_commonid'], $fcode);
  1341. if ($fcode_info['code'] && !$fcode_info['data']['goodsfcode_state']) {
  1342. return intval($fcode_info['data']['goodsfcode_id']);
  1343. } else {
  1344. return false;
  1345. }
  1346. }
  1347. }