StoreOrder.php 32 KB

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