StoreOrder.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/12/20
  6. */
  7. namespace app\routine\model\store;
  8. use app\routine\model\store\StoreCombination;
  9. use app\routine\model\routine\RoutineFormId;
  10. use app\routine\model\routine\RoutineTemplate;
  11. use app\routine\model\store\StoreOrderCartInfo;
  12. use app\routine\model\store\StoreOrderStatus;
  13. use app\routine\model\store\StoreCart;
  14. use app\routine\model\store\StoreProductReply;
  15. use app\routine\model\user\User;
  16. use app\routine\model\user\UserAddress;
  17. use app\routine\model\user\UserBill;
  18. use app\routine\model\user\WechatUser;
  19. use basic\ModelBasic;
  20. use behavior\routine\StoreProductBehavior;
  21. use behavior\wechat\PaymentBehavior;
  22. use service\HookService;
  23. use service\RoutineService;
  24. use service\SystemConfigService;
  25. use service\WechatService;
  26. use service\RoutineTemplateService;
  27. use think\Cache;
  28. use think\Url;
  29. use traits\ModelTrait;
  30. class StoreOrder extends ModelBasic
  31. {
  32. use ModelTrait;
  33. protected $insert = ['add_time'];
  34. protected static $payType = ['weixin'=>'微信支付','yue'=>'余额支付','offline'=>'线下支付'];
  35. protected static $deliveryType = ['send'=>'商家配送','express'=>'快递配送'];
  36. protected function setAddTimeAttr()
  37. {
  38. return time();
  39. }
  40. protected function setCartIdAttr($value)
  41. {
  42. return is_array($value) ? json_encode($value) : $value;
  43. }
  44. protected function getCartIdAttr($value)
  45. {
  46. return json_decode($value,true);
  47. }
  48. /**获取订单组信息
  49. * @param $cartInfo
  50. * @return array
  51. */
  52. public static function getOrderPriceGroup($cartInfo)
  53. {
  54. $storePostage = floatval(SystemConfigService::get('store_postage'))?:0;//邮费基础价
  55. $storeFreePostage = floatval(SystemConfigService::get('store_free_postage'))?:0;//满额包邮
  56. $totalPrice = self::getOrderTotalPrice($cartInfo);//获取订单总金额
  57. $costPrice = self::getOrderCostPrice($cartInfo);//获取订单成本价
  58. //如果满额包邮等于0
  59. if(!$storeFreePostage) {
  60. $storePostage = 0;
  61. }else{
  62. foreach ($cartInfo as $cart){
  63. if(!$cart['productInfo']['is_postage'])//若果产品不包邮
  64. $storePostage = bcadd($storePostage,$cart['productInfo']['postage'],2);
  65. }
  66. if($storeFreePostage <= $totalPrice) $storePostage = 0;//如果总价大于等于满额包邮 邮费等于0
  67. }
  68. // $totalPrice = bcadd($totalPrice,$storePostage,2);
  69. return compact('storePostage','storeFreePostage','totalPrice','costPrice');
  70. }
  71. /**获取订单总金额
  72. * @param $cartInfo
  73. * @return int|string
  74. */
  75. public static function getOrderTotalPrice($cartInfo)
  76. {
  77. $totalPrice = 0;
  78. foreach ($cartInfo as $cart){
  79. $totalPrice = bcadd($totalPrice,bcmul($cart['cart_num'],$cart['truePrice'],2),2);
  80. }
  81. return $totalPrice;
  82. }
  83. /**获取订单成本价
  84. * @param $cartInfo
  85. * @return int|string
  86. */
  87. public static function getOrderCostPrice($cartInfo)
  88. {
  89. $costPrice=0;
  90. foreach ($cartInfo as $cart){
  91. $costPrice = bcadd($costPrice,bcmul($cart['cart_num'],$cart['costPrice'],2),2);
  92. }
  93. return $costPrice;
  94. }
  95. /**
  96. * 拼团
  97. * @param $cartInfo
  98. * @return array
  99. */
  100. public static function getCombinationOrderPriceGroup($cartInfo)
  101. {
  102. $storePostage = floatval(SystemConfigService::get('store_postage'))?:0;
  103. $storeFreePostage = floatval(SystemConfigService::get('store_free_postage'))?:0;
  104. $totalPrice = self::getCombinationOrderTotalPrice($cartInfo);
  105. $costPrice = self::getCombinationOrderCostPrice($cartInfo);
  106. if(!$storeFreePostage) {
  107. $storePostage = 0;
  108. }else{
  109. foreach ($cartInfo as $cart){
  110. if(!StoreCombination::where('id',$cart['combination_id'])->value('is_postage'))
  111. $storePostage = bcadd($storePostage,StoreCombination::where('id',$cart['combination_id'])->value('postage'),2);
  112. }
  113. if($storeFreePostage <= $totalPrice) $storePostage = 0;
  114. }
  115. return compact('storePostage','storeFreePostage','totalPrice','costPrice');
  116. }
  117. /**
  118. * 拼团价格
  119. * @param $cartInfo
  120. * @return float
  121. */
  122. public static function getCombinationOrderTotalPrice($cartInfo)
  123. {
  124. $totalPrice = 0;
  125. foreach ($cartInfo as $cart){
  126. if($cart['combination_id']){
  127. $totalPrice = bcadd($totalPrice,bcmul($cart['cart_num'],StoreCombination::where('id',$cart['combination_id'])->value('price'),2),2);
  128. }
  129. }
  130. return (float)$totalPrice;
  131. }
  132. public static function getCombinationOrderCostPrice($cartInfo)
  133. {
  134. $costPrice = 0;
  135. foreach ($cartInfo as $cart){
  136. if($cart['combination_id']){
  137. $totalPrice = bcadd($costPrice,bcmul($cart['cart_num'],StoreCombination::where('id',$cart['combination_id'])->value('price'),2),2);
  138. }
  139. }
  140. return (float)$costPrice;
  141. }
  142. public static function cacheOrderInfo($uid,$cartInfo,$priceGroup,$other = [],$cacheTime = 600)
  143. {
  144. $key = md5(time());
  145. Cache::set('user_order_'.$uid.$key,compact('cartInfo','priceGroup','other'),$cacheTime);
  146. return $key;
  147. }
  148. public static function getCacheOrderInfo($uid,$key)
  149. {
  150. $cacheName = 'user_order_'.$uid.$key;
  151. if(!Cache::has($cacheName)) return null;
  152. return Cache::get($cacheName);
  153. }
  154. public static function clearCacheOrderInfo($uid,$key)
  155. {
  156. Cache::clear('user_order_'.$uid.$key);
  157. }
  158. /**生成订单
  159. * @param $uid
  160. * @param $key
  161. * @param $addressId
  162. * @param $payType
  163. * @param bool $useIntegral
  164. * @param int $couponId
  165. * @param string $mark
  166. * @param int $combinationId
  167. * @param int $pinkId
  168. * @param int $seckill_id
  169. * @param int $bargain_id
  170. * @return bool|object
  171. */
  172. public static function cacheKeyCreateOrder($uid,$key,$addressId,$payType,$useIntegral = false,$couponId = 0,$mark = '',$combinationId = 0,$pinkId = 0,$seckill_id=0,$bargain_id=0)
  173. {
  174. if(!array_key_exists($payType,self::$payType)) return self::setErrorInfo('选择支付方式有误!');
  175. if(self::be(['unique'=>$key,'uid'=>$uid])) return self::setErrorInfo('请勿重复提交订单');
  176. $userInfo = User::getUserInfo($uid);
  177. if(!$userInfo) return self::setErrorInfo('用户不存在!');
  178. $cartGroup = self::getCacheOrderInfo($uid,$key);
  179. if(!$cartGroup) return self::setErrorInfo('订单已过期,请刷新当前页面!');
  180. $cartInfo = $cartGroup['cartInfo'];
  181. $priceGroup = $cartGroup['priceGroup'];
  182. $other = $cartGroup['other'];
  183. $payPrice = $priceGroup['totalPrice'];
  184. $payPostage = $priceGroup['storePostage'];
  185. if(!$addressId) return self::setErrorInfo('请选择收货地址!');
  186. if(!UserAddress::be(['uid'=>$uid,'id'=>$addressId,'is_del'=>0]) || !($addressInfo = UserAddress::find($addressId)))
  187. return self::setErrorInfo('地址选择有误!');
  188. //使用优惠劵
  189. $res1 = true;
  190. if($couponId){
  191. $couponInfo = StoreCouponUser::validAddressWhere()->where('id',$couponId)->where('uid',$uid)->find();
  192. if(!$couponInfo) return self::setErrorInfo('选择的优惠劵无效!');
  193. if($couponInfo['use_min_price'] > $payPrice)
  194. return self::setErrorInfo('不满足优惠劵的使用条件!');
  195. $payPrice = bcsub($payPrice,$couponInfo['coupon_price'],2);
  196. $res1 = StoreCouponUser::useCoupon($couponId);
  197. $couponPrice = $couponInfo['coupon_price'];
  198. }else{
  199. $couponId = 0;
  200. $couponPrice = 0;
  201. }
  202. if(!$res1) return self::setErrorInfo('使用优惠劵失败!');
  203. //是否包邮
  204. if((isset($other['offlinePostage']) && $other['offlinePostage'] && $payType == 'offline')) $payPostage = 0;
  205. $payPrice = bcadd($payPrice,$payPostage,2);
  206. //积分抵扣
  207. $res2 = true;
  208. if($useIntegral && $userInfo['integral'] > 0){
  209. $deductionPrice = bcmul($userInfo['integral'],$other['integralRatio'],2);
  210. if($deductionPrice < $payPrice){
  211. $payPrice = bcsub($payPrice,$deductionPrice,2);
  212. $usedIntegral = $userInfo['integral'];
  213. $res2 = false !== User::edit(['integral'=>0],$userInfo['uid'],'uid');
  214. }else{
  215. $deductionPrice = $payPrice;
  216. $usedIntegral = bcdiv($payPrice,$other['integralRatio'],2);
  217. $res2 = false !== User::bcDec($userInfo['uid'],'integral',$usedIntegral,'uid');
  218. $payPrice = 0;
  219. }
  220. $res2 = $res2 && false != UserBill::expend('积分抵扣',$uid,'integral','deduction',$usedIntegral,$key,$userInfo['integral'],'购买商品使用'.floatval($usedIntegral).'积分抵扣'.floatval($deductionPrice).'元');
  221. }else{
  222. $deductionPrice = 0;
  223. $usedIntegral = 0;
  224. }
  225. if(!$res2) return self::setErrorInfo('使用积分抵扣失败!');
  226. $cartIds = [];
  227. $totalNum = 0;
  228. $gainIntegral = 0;
  229. foreach ($cartInfo as $cart){
  230. $cartIds[] = $cart['id'];
  231. $totalNum += $cart['cart_num'];
  232. $gainIntegral = bcadd($gainIntegral,isset($cart['productInfo']['give_integral']) ? : 0,2);
  233. }
  234. $orderInfo = [
  235. 'uid'=>$uid,
  236. 'order_id'=>self::getNewOrderId(),
  237. 'real_name'=>$addressInfo['real_name'],
  238. 'user_phone'=>$addressInfo['phone'],
  239. 'user_address'=>$addressInfo['province'].' '.$addressInfo['city'].' '.$addressInfo['district'].' '.$addressInfo['detail'],
  240. 'cart_id'=>$cartIds,
  241. 'total_num'=>$totalNum,
  242. 'total_price'=>$priceGroup['totalPrice'],
  243. 'total_postage'=>$priceGroup['storePostage'],
  244. 'coupon_id'=>$couponId,
  245. 'coupon_price'=>$couponPrice,
  246. 'pay_price'=>$payPrice,
  247. 'pay_postage'=>$payPostage,
  248. 'deduction_price'=>$deductionPrice,
  249. 'paid'=>0,
  250. 'pay_type'=>$payType,
  251. 'use_integral'=>$usedIntegral,
  252. 'gain_integral'=>$gainIntegral,
  253. 'mark'=>htmlspecialchars($mark),
  254. 'combination_id'=>$combinationId,
  255. 'pink_id'=>$pinkId,
  256. 'seckill_id'=>$seckill_id,
  257. 'bargain_id'=>$bargain_id,
  258. 'cost'=>$priceGroup['costPrice'],
  259. 'is_channel'=>1,
  260. 'unique'=>$key
  261. ];
  262. $order = self::set($orderInfo);
  263. if(!$order)return self::setErrorInfo('订单生成失败!');
  264. $res5 = true;
  265. foreach ($cartInfo as $cart){
  266. //减库存加销量
  267. if($combinationId) $res5 = $res5 && StoreCombination::decCombinationStock($cart['cart_num'],$combinationId);
  268. else if($seckill_id) $res5 = $res5 && StoreSeckill::decSeckillStock($cart['cart_num'],$seckill_id);
  269. else if($bargain_id) $res5 = $res5 && StoreBargain::decBargainStock($cart['cart_num'],$bargain_id);
  270. else $res5 = $res5 && StoreProduct::decProductStock($cart['cart_num'],$cart['productInfo']['id'],isset($cart['productInfo']['attrInfo']) ? $cart['productInfo']['attrInfo']['unique']:'');
  271. }
  272. //保存购物车商品信息
  273. $res4 = false !== StoreOrderCartInfo::setCartInfo($order['id'],$cartInfo);
  274. //购物车状态修改
  275. $res6 = false !== StoreCart::where('id','IN',$cartIds)->update(['is_pay'=>1]);
  276. if(!$res4 || !$res5 || !$res6) return self::setErrorInfo('订单生成失败!');
  277. try{
  278. HookService::listen('store_product_order_create',$order,compact('cartInfo','addressId'),false,StoreProductBehavior::class);
  279. }catch (\Exception $e){
  280. return self::setErrorInfo($e->getMessage());
  281. }
  282. self::clearCacheOrderInfo($uid,$key);
  283. self::commitTrans();
  284. StoreOrderStatus::status($order['id'],'cache_key_create_order','订单生成');
  285. return $order;
  286. }
  287. public static function getNewOrderId()
  288. {
  289. $count = (int) self::where('add_time',['>=',strtotime(date("Y-m-d"))],['<',strtotime(date("Y-m-d",strtotime('+1 day')))])->count();
  290. return 'wx'.date('YmdHis',time()).(10000+$count+1);
  291. }
  292. public static function changeOrderId($orderId)
  293. {
  294. $ymd = substr($orderId,2,8);
  295. $key = substr($orderId,16);
  296. return 'wx'.$ymd.date('His').$key;
  297. }
  298. //TODO JS支付
  299. public static function jsPay($orderId,$field = 'order_id')
  300. {
  301. if(is_string($orderId))
  302. $orderInfo = self::where($field,$orderId)->find();
  303. else
  304. $orderInfo = $orderId;
  305. if(!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
  306. if($orderInfo['paid']) exception('支付已支付!');
  307. if($orderInfo['pay_price'] <= 0) exception('该支付无需支付!');
  308. $openid = WechatUser::getOpenId($orderInfo['uid']);
  309. return RoutineService::payRoutine($openid,$orderInfo['order_id'],$orderInfo['pay_price'],'productr',SystemConfigService::get('site_name'));
  310. }
  311. //TODO 余额支付
  312. public static function yuePay($order_id,$uid,$formId = '')
  313. {
  314. $orderInfo = self::where('uid',$uid)->where('order_id',$order_id)->where('is_del',0)->find();
  315. if(!$orderInfo) return self::setErrorInfo('订单不存在!');
  316. if($orderInfo['paid']) return self::setErrorInfo('该订单已支付!');
  317. // if($orderInfo['pay_type'] != 'yue') return self::setErrorInfo('该订单不能使用余额支付!');
  318. $userInfo = User::getUserInfo($uid);
  319. if($userInfo['now_money'] < $orderInfo['pay_price'])
  320. return self::setErrorInfo('余额不足'.floatval($orderInfo['pay_price']));
  321. self::beginTrans();
  322. $res1 = false !== User::bcDec($uid,'now_money',$orderInfo['pay_price'],'uid');
  323. $res2 = UserBill::expend('购买商品',$uid,'now_money','pay_product',$orderInfo['pay_price'],$orderInfo['id'],$userInfo['now_money'],'余额支付'.floatval($orderInfo['pay_price']).'元购买商品');
  324. $res3 = self::paySuccess($order_id,'yue',$formId);//余额支付成功
  325. try{
  326. // HookService::listen('yue_pay_product',$userInfo,$orderInfo,false,PaymentBehavior::class);
  327. }catch (\Exception $e){
  328. self::rollbackTrans();
  329. return self::setErrorInfo($e->getMessage());
  330. }
  331. $res = $res1 && $res2 && $res3;
  332. self::checkTrans($res);
  333. return $res;
  334. }
  335. /**
  336. * 微信支付 为 0元时
  337. * @param $order_id
  338. * @param $uid
  339. * @return bool
  340. */
  341. public static function jsPayPrice($order_id,$uid,$formId = ''){
  342. $orderInfo = self::where('uid',$uid)->where('order_id',$order_id)->where('is_del',0)->find();
  343. if(!$orderInfo) return self::setErrorInfo('订单不存在!');
  344. if($orderInfo['paid']) return self::setErrorInfo('该订单已支付!');
  345. $userInfo = User::getUserInfo($uid);
  346. self::beginTrans();
  347. $res1 = UserBill::expend('购买商品',$uid,'now_money','pay_product',$orderInfo['pay_price'],$orderInfo['id'],$userInfo['now_money'],'微信支付'.floatval($orderInfo['pay_price']).'元购买商品');
  348. $res2 = self::paySuccess($order_id,'weixin',$formId);//微信支付为0时
  349. $res = $res1 && $res2;
  350. self::checkTrans($res);
  351. return $res;
  352. }
  353. /**
  354. * 用户申请退款
  355. * @param $uni
  356. * @param $uid
  357. * @param string $refundReasonWap
  358. * @return bool
  359. */
  360. public static function orderApplyRefund($uni, $uid,$refundReasonWap = '',$refundReasonWapExplain = '',$refundReasonWapImg = array())
  361. {
  362. $order = self::getUserOrderDetail($uid,$uni);
  363. if(!$order) return self::setErrorInfo('支付订单不存在!');
  364. if($order['refund_status'] == 2) return self::setErrorInfo('订单已退款!');
  365. if($order['refund_status'] == 1) return self::setErrorInfo('正在申请退款中!');
  366. if($order['status'] == 1) return self::setErrorInfo('订单当前无法退款!');
  367. self::beginTrans();
  368. $res1 = false !== StoreOrderStatus::status($order['id'],'apply_refund','用户申请退款,原因:'.$refundReasonWap);
  369. $res2 = false !== self::edit(['refund_status'=>1,'refund_reason_time'=>time(),'refund_reason_wap'=>$refundReasonWap,'refund_reason_wap_explain'=>$refundReasonWapExplain,'refund_reason_wap_img'=>json_encode($refundReasonWapImg)],$order['id'],'id');
  370. $res = $res1 && $res2;
  371. self::checkTrans($res);
  372. if(!$res)
  373. return self::setErrorInfo('申请退款失败!');
  374. else{
  375. $adminIds = SystemConfigService::get('site_store_admin_uids');
  376. if(!empty($adminIds)){
  377. try{
  378. if(!($adminList = array_unique(array_filter(explode(',',trim($adminIds)))))){
  379. self::setErrorInfo('申请退款成功,');
  380. return false;
  381. }
  382. RoutineTemplate::sendOrderRefundStatus($order,$refundReasonWap,$adminList);//小程序 发送模板消息
  383. }catch (\Exception $e){}
  384. }
  385. return true;
  386. }
  387. }
  388. /**
  389. * //TODO 支付成功后
  390. * @param $orderId
  391. * @param $paytype
  392. * @param $notify
  393. * @return bool
  394. */
  395. public static function paySuccess($orderId,$paytype='weixin',$formId = '')
  396. {
  397. $order = self::where('order_id',$orderId)->find();
  398. $resPink = true;
  399. $res1 = self::where('order_id',$orderId)->update(['paid'=>1,'pay_type'=>$paytype,'pay_time'=>time()]);//订单改为支付
  400. User::bcInc($order['uid'],'pay_count',1,'uid');
  401. if($order->combination_id && $res1 && !$order->refund_status) $resPink = StorePink::createPink($order);//创建拼团
  402. $oid = self::where('order_id',$orderId)->value('id');
  403. StoreOrderStatus::status($oid,'pay_success','用户付款成功');
  404. RoutineTemplate::sendOrderSuccess($formId,$orderId);
  405. $res = $res1 && $resPink;
  406. return false !== $res;
  407. }
  408. public static function createOrderTemplate($order)
  409. {
  410. $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
  411. RoutineTemplateService::sendTemplate(WechatUser::getOpenId($order['uid']),RoutineTemplateService::ORDER_CREATE, [
  412. 'first'=>'亲,您购买的商品已支付成功',
  413. 'keyword1'=>date('Y/m/d H:i',$order['add_time']),
  414. 'keyword2'=>implode(',',$goodsName),
  415. 'keyword3'=>$order['order_id'],
  416. 'remark'=>'点击查看订单详情'
  417. ],Url::build('/wap/My/order',['uni'=>$order['order_id']],true,true));
  418. // RoutineTemplateService::sendAdminNoticeTemplate([
  419. // 'first'=>"亲,您有一个新订单 \n订单号:{$order['order_id']}",
  420. // 'keyword1'=>'新订单',
  421. // 'keyword2'=>'线下支付',
  422. // 'keyword3'=>date('Y/m/d H:i',time()),
  423. // 'remark'=>'请及时处理'
  424. // ]);
  425. }
  426. public static function getUserOrderDetail($uid,$key)
  427. {
  428. return self::where('order_id|unique',$key)->where('uid',$uid)->where('is_del',0)->find();
  429. }
  430. /**
  431. * TODO 订单发货
  432. * @param array $postageData 发货信息
  433. * @param string $oid orderID
  434. */
  435. public static function orderPostageAfter($postageData, $oid)
  436. {
  437. $order = self::where('id',$oid)->find();
  438. $openid = WechatUser::getOpenId($order['uid']);
  439. $url = Url::build('wap/My/order',['uni'=>$order['order_id']],true,true);
  440. $group = [
  441. 'first'=>'亲,您的订单已发货,请注意查收',
  442. 'remark'=>'点击查看订单详情'
  443. ];
  444. if($postageData['delivery_type'] == 'send'){//送货
  445. $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
  446. $group = array_merge($group,[
  447. 'keyword1'=>$goodsName,
  448. 'keyword2'=>$order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i',$order['pay_time']),
  449. 'keyword3'=>$order['user_address'],
  450. 'keyword4'=>$postageData['delivery_name'],
  451. 'keyword5'=>$postageData['delivery_id']
  452. ]);
  453. RoutineTemplateService::sendTemplate($openid,RoutineTemplateService::ORDER_DELIVER_SUCCESS,$group,$url);
  454. }else if($postageData['delivery_type'] == 'express'){//发货
  455. $group = array_merge($group,[
  456. 'keyword1'=>$order['order_id'],
  457. 'keyword2'=>$postageData['delivery_name'],
  458. 'keyword3'=>$postageData['delivery_id']
  459. ]);
  460. RoutineTemplateService::sendTemplate($openid,RoutineTemplateService::ORDER_POSTAGE_SUCCESS,$group,$url);
  461. }
  462. }
  463. public static function orderTakeAfter($order)
  464. {
  465. // $openid = WechatUser::getOpenId($order['uid']);
  466. // RoutineTemplateService::sendTemplate($openid,RoutineTemplateService::ORDER_TAKE_SUCCESS,[
  467. // 'first'=>'亲,您的订单已成功签收,快去评价一下吧',
  468. // 'keyword1'=>$order['order_id'],
  469. // 'keyword2'=>'已收货',
  470. // 'keyword3'=>date('Y/m/d H:i',time()),
  471. // 'keyword4'=>implode(',',StoreOrderCartInfo::getProductNameList($order['id'])),
  472. // 'remark'=>'点击查看订单详情'
  473. // ],Url::build('My/order',['uni'=>$order['order_id']],true,true));
  474. }
  475. /**
  476. * 删除订单
  477. * @param $uni
  478. * @param $uid
  479. * @return bool
  480. */
  481. public static function removeOrder($uni, $uid)
  482. {
  483. $order = self::getUserOrderDetail($uid,$uni);
  484. if(!$order) return self::setErrorInfo('订单不存在!');
  485. $order = self::tidyOrder($order);
  486. if($order['_status']['_type'] != 0 && $order['_status']['_type']!= -2 && $order['_status']['_type'] != 4)
  487. return self::setErrorInfo('该订单无法删除!');
  488. if(false !== self::edit(['is_del'=>1],$order['id'],'id') &&
  489. false !==StoreOrderStatus::status($order['id'],'remove_order','删除订单'))
  490. return true;
  491. else
  492. return self::setErrorInfo('订单删除失败!');
  493. }
  494. /**
  495. * //TODO 用户确认收货
  496. * @param $uni
  497. * @param $uid
  498. */
  499. public static function takeOrder($uni, $uid)
  500. {
  501. $order = self::getUserOrderDetail($uid,$uni);
  502. if(!$order) return self::setErrorInfo('订单不存在!');
  503. $order = self::tidyOrder($order);
  504. if($order['_status']['_type'] != 2) return self::setErrorInfo('订单状态错误!');
  505. self::beginTrans();
  506. if(false !== self::edit(['status'=>2],$order['id'],'id') &&
  507. false !== StoreOrderStatus::status($order['id'],'user_take_delivery','用户已收货')){
  508. try{
  509. HookService::listen('store_product_order_user_take_delivery',$order,$uid,false,StoreProductBehavior::class);
  510. }catch (\Exception $e){
  511. return self::setErrorInfo($e->getMessage());
  512. }
  513. self::commitTrans();
  514. return true;
  515. }else{
  516. self::rollbackTrans();
  517. return false;
  518. }
  519. }
  520. public static function tidyOrder($order,$detail = false)
  521. {
  522. if($detail == true && isset($order['id'])){
  523. $cartInfo = self::getDb('StoreOrderCartInfo')->where('oid',$order['id'])->column('cart_info','unique')?:[];
  524. foreach ($cartInfo as $k=>$cart){
  525. $cartInfo[$k] = json_decode($cart, true);
  526. $cartInfo[$k]['unique'] = $k;
  527. }
  528. $order['cartInfo'] = $cartInfo;
  529. }
  530. $status = [];
  531. if(!$order['paid'] && $order['pay_type'] == 'offline' && !$order['status'] >= 2){
  532. $status['_type'] = 9;
  533. $status['_title'] = '线下付款';
  534. $status['_msg'] = '等待商家处理,请耐心等待';
  535. $status['_class'] = 'nobuy';
  536. }else if(!$order['paid']){
  537. $status['_type'] = 0;
  538. $status['_title'] = '未支付';
  539. $status['_msg'] = '立即支付订单吧';
  540. $status['_class'] = 'nobuy';
  541. }else if($order['refund_status'] == 1){
  542. $status['_type'] = -1;
  543. $status['_title'] = '申请退款中';
  544. $status['_msg'] = '商家审核中,请耐心等待';
  545. $status['_class'] = 'state-sqtk';
  546. }else if($order['refund_status'] == 2){
  547. $status['_type'] = -2;
  548. $status['_title'] = '已退款';
  549. $status['_msg'] = '已为您退款,感谢您的支持';
  550. $status['_class'] = 'state-sqtk';
  551. }else if(!$order['status']){
  552. if($order['pink_id']){
  553. if(StorePink::where('id',$order['pink_id'])->where('status',1)->count()){
  554. $status['_type'] = 1;
  555. $status['_title'] = '拼团中';
  556. $status['_msg'] = '等待其他人参加拼团';
  557. $status['_class'] = 'state-nfh';
  558. }else{
  559. $status['_type'] = 1;
  560. $status['_title'] = '未发货';
  561. $status['_msg'] = '商家未发货,请耐心等待';
  562. $status['_class'] = 'state-nfh';
  563. }
  564. }else{
  565. $status['_type'] = 1;
  566. $status['_title'] = '未发货';
  567. $status['_msg'] = '商家未发货,请耐心等待';
  568. $status['_class'] = 'state-nfh';
  569. }
  570. }else if($order['status'] == 1){
  571. $status['_type'] = 2;
  572. $status['_title'] = '待收货';
  573. $status['_msg'] = date('m月d日H时i分',StoreOrderStatus::getTime($order['id'],'delivery_goods')).'服务商已发货';
  574. $status['_class'] = 'state-ysh';
  575. }else if($order['status'] == 2){
  576. $status['_type'] = 3;
  577. $status['_title'] = '待评价';
  578. $status['_msg'] = '已收货,快去评价一下吧';
  579. $status['_class'] = 'state-ypj';
  580. }else if($order['status'] == 3){
  581. $status['_type'] = 4;
  582. $status['_title'] = '交易完成';
  583. $status['_msg'] = '交易完成,感谢您的支持';
  584. $status['_class'] = 'state-ytk';
  585. }
  586. if(isset($order['pay_type']))
  587. $status['_payType'] = isset(self::$payType[$order['pay_type']]) ? self::$payType[$order['pay_type']] : '其他方式';
  588. if(isset($order['delivery_type']))
  589. $status['_deliveryType'] = isset(self::$deliveryType[$order['delivery_type']]) ? self::$deliveryType[$order['delivery_type']] : '其他方式';
  590. $order['_status'] = $status;
  591. return $order;
  592. }
  593. public static function statusByWhere($status,$model = null)
  594. {
  595. $orderId = StorePink::where('uid',User::getActiveUid())->where('status',1)->column('order_id','id');//获取正在拼团的订单编号
  596. if($model == null) $model = new self;
  597. if('' === $status)
  598. return $model;
  599. else if($status == 0)
  600. return $model->where('paid',0)->where('status',0)->where('refund_status',0);
  601. else if($status == 1)//待发货
  602. return $model->where('paid',1)->where('order_id','NOT IN',implode(',',$orderId))->where('status',0)->where('refund_status',0);
  603. else if($status == 2)
  604. return $model->where('paid',1)->where('status',1)->where('refund_status',0);
  605. else if($status == 3)
  606. return $model->where('paid',1)->where('status',2)->where('refund_status',0);
  607. else if($status == 4)
  608. return $model->where('paid',1)->where('status',3)->where('refund_status',0);
  609. else if($status == -1)
  610. return $model->where('paid',1)->where('refund_status',1);
  611. else if($status == -2)
  612. return $model->where('paid',1)->where('refund_status',2);
  613. else if($status == -3)
  614. return $model->where('paid',1)->where('refund_status','IN','1,2');
  615. else if($status == 11){
  616. return $model->where('order_id','IN',implode(',',$orderId));
  617. }
  618. else
  619. return $model;
  620. }
  621. public static function getUserOrderList($uid,$status = '',$first = 0,$limit = 8)
  622. {
  623. $list = self::statusByWhere($status)->where('is_del',0)->where('uid',$uid)
  624. ->field('seckill_id,bargain_id,combination_id,id,order_id,pay_price,total_num,total_price,pay_postage,total_postage,paid,status,refund_status,pay_type,coupon_price,deduction_price,pink_id,delivery_type')
  625. ->order('add_time DESC')->limit($first,$limit)->select()->toArray();
  626. foreach ($list as $k=>$order){
  627. $list[$k] = self::tidyOrder($order,true);
  628. }
  629. return $list;
  630. }
  631. /**
  632. * 获取推广人地下用户的订单金额
  633. * @param string $uid
  634. * @param string $status
  635. * @return array
  636. */
  637. public static function getUserOrderCount($uid = '',$status = ''){
  638. $res = self::statusByWhere($status)->where('uid','IN',$uid)->column('pay_price');
  639. return $res;
  640. }
  641. public static function searchUserOrder($uid,$order_id)
  642. {
  643. $order = self::where('uid',$uid)->where('order_id',$order_id)->where('is_del',0)->field('seckill_id,bargain_id,combination_id,id,order_id,pay_price,total_num,total_price,pay_postage,total_postage,paid,status,refund_status,pay_type,coupon_price,deduction_price,delivery_type')
  644. ->order('add_time DESC')->find();
  645. if(!$order)
  646. return false;
  647. else
  648. return self::tidyOrder($order->toArray(),true);
  649. }
  650. public static function orderOver($oid)
  651. {
  652. $res = self::edit(['status'=>'3'],$oid,'id');
  653. if(!$res) exception('评价后置操作失败!');
  654. StoreOrderStatus::status($oid,'check_order_over','用户评价');
  655. }
  656. public static function checkOrderOver($oid)
  657. {
  658. $uniqueList = StoreOrderCartInfo::where('oid',$oid)->column('unique');
  659. if(StoreProductReply::where('unique','IN',$uniqueList)->where('oid',$oid)->count() == count($uniqueList)){
  660. HookService::listen('store_product_order_over',$oid,null,false,StoreProductBehavior::class);
  661. self::orderOver($oid);
  662. }
  663. }
  664. public static function getOrderStatusNum($uid)
  665. {
  666. $noBuy = self::where('uid',$uid)->where('paid',0)->where('is_del',0)->where('pay_type','<>','offline')->count();
  667. $noPostageNoPink = self::where('o.uid',$uid)->alias('o')->where('o.paid',1)->where('o.pink_id',0)->where('o.is_del',0)->where('o.status',0)->where('o.pay_type','<>','offline')->count();
  668. $noPostageYesPink = self::where('o.uid',$uid)->alias('o')->join('StorePink p','o.pink_id = p.id')->where('p.status',2)->where('o.paid',1)->where('o.is_del',0)->where('o.status',0)->where('o.pay_type','<>','offline')->count();
  669. $noPostage = bcadd($noPostageNoPink,$noPostageYesPink);
  670. $noTake = self::where('uid',$uid)->where('paid',1)->where('is_del',0)->where('status',1)->where('pay_type','<>','offline')->count();
  671. $noReply = self::where('uid',$uid)->where('paid',1)->where('is_del',0)->where('status',2)->count();
  672. $noPink = self::where('o.uid',$uid)->alias('o')->join('StorePink p','o.pink_id = p.id')->where('p.status',1)->where('o.paid',1)->where('o.is_del',0)->where('o.status',0)->where('o.pay_type','<>','offline')->count();
  673. $noRefund = self::where('uid',$uid)->where('paid',1)->where('is_del',0)->where('refund_status','IN','1,2')->count();
  674. return compact('noBuy','noPostage','noTake','noReply','noPink','noRefund');
  675. }
  676. public static function gainUserIntegral($order)
  677. {
  678. if($order['gain_integral'] > 0){
  679. $userInfo = User::getUserInfo($order['uid']);
  680. ModelBasic::beginTrans();
  681. $res1 = false != User::where('uid',$userInfo['uid'])->update(['integral'=>bcadd($userInfo['integral'],$order['gain_integral'],2)]);
  682. $res2 = false != UserBill::income('购买商品赠送积分',$order['uid'],'integral','gain',$order['gain_integral'],$order['id'],$userInfo['integral'],'购买商品赠送'.floatval($order['gain_integral']).'积分');
  683. $res = $res1 && $res2;
  684. ModelBasic::checkTrans($res);
  685. return $res;
  686. }
  687. return true;
  688. }
  689. /**
  690. * 获取当前订单中有没有拼团存在
  691. * @param $pid
  692. * @return int|string
  693. */
  694. public static function getIsOrderPink($pid = 0 ,$uid = 0){
  695. return self::where('uid',$uid)->where('pink_id',$pid)->where('refund_status',0)->where('is_del',0)->count();
  696. }
  697. /**
  698. * 获取order_id
  699. * @param $pid
  700. * @return mixed
  701. */
  702. public static function getStoreIdPink($pid = 0 ,$uid = 0){
  703. return self::where('uid',$uid)->where('pink_id',$pid)->where('is_del',0)->value('order_id');
  704. }
  705. /**
  706. * 删除当前用户拼团未支付的订单
  707. */
  708. public static function delCombination(){
  709. self::where('combination','GT',0)->where('paid',0)->where('uid',User::getActiveUid())->delete();
  710. }
  711. public static function getUserPrice($uid =0){
  712. if(!$uid) return 0;
  713. $price = self::where('paid',1)->where('uid',$uid)->where('status',2)->where('refund_status',0)->column('pay_price','id');
  714. $count = 0;
  715. if($price){
  716. foreach ($price as $v){
  717. $count = bcadd($count,$v,2);
  718. }
  719. }
  720. return $count;
  721. }
  722. }