StoreOrder.php 32 KB

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