StoreOrder.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736
  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\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. try{
  346. $adminIds = SystemConfigService::get('site_store_admin_uids');
  347. if(!$adminIds || !($adminList = array_unique(array_filter(explode(',',trim($adminIds)))))) return false;
  348. RoutineTemplate::sendOrderRefundStatus($order,$refundReasonWap,$adminList);//小程序 发送模板消息
  349. }catch (\Exception $e){}
  350. return true;
  351. }
  352. }
  353. /**
  354. * //TODO 支付成功后
  355. * @param $orderId
  356. * @param $notify
  357. * @return bool
  358. */
  359. public static function paySuccess($orderId,$formId = '')
  360. {
  361. $order = self::where('order_id',$orderId)->find();
  362. $resPink = true;
  363. $res1 = self::where('order_id',$orderId)->update(['paid'=>1,'pay_time'=>time()]);
  364. User::bcInc($order['uid'],'pay_count',1,'uid');
  365. if($order->combination_id && $res1 && !$order->refund_status) $resPink = StorePink::createPink($order);//创建拼团
  366. $oid = self::where('order_id',$orderId)->value('id');
  367. StoreOrderStatus::status($oid,'pay_success','用户付款成功');
  368. RoutineTemplate::sendOrderSuccess($formId,$orderId);
  369. $res = $res1 && $resPink;
  370. return false !== $res;
  371. }
  372. public static function createOrderTemplate($order)
  373. {
  374. $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
  375. WechatTemplateService::sendTemplate(WechatUser::getOpenId($order['uid']),WechatTemplateService::ORDER_CREATE, [
  376. 'first'=>'亲,您购买的商品已支付成功',
  377. 'keyword1'=>date('Y/m/d H:i',$order['add_time']),
  378. 'keyword2'=>implode(',',$goodsName),
  379. 'keyword3'=>$order['order_id'],
  380. 'remark'=>'点击查看订单详情'
  381. ],Url::build('/wap/My/order',['uni'=>$order['order_id']],true,true));
  382. WechatTemplateService::sendAdminNoticeTemplate([
  383. 'first'=>"亲,您有一个新订单 \n订单号:{$order['order_id']}",
  384. 'keyword1'=>'新订单',
  385. 'keyword2'=>'线下支付',
  386. 'keyword3'=>date('Y/m/d H:i',time()),
  387. 'remark'=>'请及时处理'
  388. ]);
  389. }
  390. public static function getUserOrderDetail($uid,$key)
  391. {
  392. return self::where('order_id|unique',$key)->where('uid',$uid)->where('is_del',0)->find();
  393. }
  394. /**
  395. * TODO 订单发货
  396. * @param array $postageData 发货信息
  397. * @param string $oid orderID
  398. */
  399. public static function orderPostageAfter($postageData, $oid)
  400. {
  401. $order = self::where('id',$oid)->find();
  402. $openid = WechatUser::getOpenId($order['uid']);
  403. $url = Url::build('wap/My/order',['uni'=>$order['order_id']],true,true);
  404. $group = [
  405. 'first'=>'亲,您的订单已发货,请注意查收',
  406. 'remark'=>'点击查看订单详情'
  407. ];
  408. if($postageData['delivery_type'] == 'send'){//送货
  409. $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
  410. $group = array_merge($group,[
  411. 'keyword1'=>$goodsName,
  412. 'keyword2'=>$order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i',$order['pay_time']),
  413. 'keyword3'=>$order['user_address'],
  414. 'keyword4'=>$postageData['delivery_name'],
  415. 'keyword5'=>$postageData['delivery_id']
  416. ]);
  417. WechatTemplateService::sendTemplate($openid,WechatTemplateService::ORDER_DELIVER_SUCCESS,$group,$url);
  418. }else if($postageData['delivery_type'] == 'express'){//发货
  419. $group = array_merge($group,[
  420. 'keyword1'=>$order['order_id'],
  421. 'keyword2'=>$postageData['delivery_name'],
  422. 'keyword3'=>$postageData['delivery_id']
  423. ]);
  424. WechatTemplateService::sendTemplate($openid,WechatTemplateService::ORDER_POSTAGE_SUCCESS,$group,$url);
  425. }
  426. }
  427. public static function orderTakeAfter($order)
  428. {
  429. $openid = WechatUser::getOpenId($order['uid']);
  430. WechatTemplateService::sendTemplate($openid,WechatTemplateService::ORDER_TAKE_SUCCESS,[
  431. 'first'=>'亲,您的订单以成功签收,快去评价一下吧',
  432. 'keyword1'=>$order['order_id'],
  433. 'keyword2'=>'已收货',
  434. 'keyword3'=>date('Y/m/d H:i',time()),
  435. 'keyword4'=>implode(',',StoreOrderCartInfo::getProductNameList($order['id'])),
  436. 'remark'=>'点击查看订单详情'
  437. ],Url::build('My/order',['uni'=>$order['order_id']],true,true));
  438. }
  439. /**
  440. * 删除订单
  441. * @param $uni
  442. * @param $uid
  443. * @return bool
  444. */
  445. public static function removeOrder($uni, $uid)
  446. {
  447. $order = self::getUserOrderDetail($uid,$uni);
  448. if(!$order) return self::setErrorInfo('订单不存在!');
  449. $order = self::tidyOrder($order);
  450. if($order['_status']['_type'] != 0 && $order['_status']['_type']!= -2 && $order['_status']['_type'] != 4)
  451. return self::setErrorInfo('该订单无法删除!');
  452. if(false !== self::edit(['is_del'=>1],$order['id'],'id') &&
  453. false !==StoreOrderStatus::status($order['id'],'remove_order','删除订单'))
  454. return true;
  455. else
  456. return self::setErrorInfo('订单删除失败!');
  457. }
  458. /**
  459. * //TODO 用户确认收货
  460. * @param $uni
  461. * @param $uid
  462. */
  463. public static function takeOrder($uni, $uid)
  464. {
  465. $order = self::getUserOrderDetail($uid,$uni);
  466. if(!$order) return self::setErrorInfo('订单不存在!');
  467. $order = self::tidyOrder($order);
  468. if($order['_status']['_type'] != 2) return self::setErrorInfo('订单状态错误!');
  469. self::beginTrans();
  470. if(false !== self::edit(['status'=>2],$order['id'],'id') &&
  471. false !== StoreOrderStatus::status($order['id'],'user_take_delivery','用户已收货')){
  472. try{
  473. HookService::listen('store_product_order_user_take_delivery',$order,$uid,false,StoreProductBehavior::class);
  474. }catch (\Exception $e){
  475. return self::setErrorInfo($e->getMessage());
  476. }
  477. self::commitTrans();
  478. return true;
  479. }else{
  480. self::rollbackTrans();
  481. return false;
  482. }
  483. }
  484. public static function tidyOrder($order,$detail = false)
  485. {
  486. if($detail == true && isset($order['id'])){
  487. $cartInfo = self::getDb('StoreOrderCartInfo')->where('oid',$order['id'])->column('cart_info','unique')?:[];
  488. foreach ($cartInfo as $k=>$cart){
  489. $cartInfo[$k] = json_decode($cart, true);
  490. $cartInfo[$k]['unique'] = $k;
  491. }
  492. $order['cartInfo'] = $cartInfo;
  493. }
  494. $status = [];
  495. if(!$order['paid'] && $order['pay_type'] == 'offline' && !$order['status'] >= 2){
  496. $status['_type'] = 9;
  497. $status['_title'] = '线下付款';
  498. $status['_msg'] = '等待商家处理,请耐心等待';
  499. $status['_class'] = 'nobuy';
  500. }else if(!$order['paid']){
  501. $status['_type'] = 0;
  502. $status['_title'] = '未支付';
  503. $status['_msg'] = '立即支付订单吧';
  504. $status['_class'] = 'nobuy';
  505. }else if($order['refund_status'] == 1){
  506. $status['_type'] = -1;
  507. $status['_title'] = '申请退款中';
  508. $status['_msg'] = '商家审核中,请耐心等待';
  509. $status['_class'] = 'state-sqtk';
  510. }else if($order['refund_status'] == 2){
  511. $status['_type'] = -2;
  512. $status['_title'] = '已退款';
  513. $status['_msg'] = '已为您退款,感谢您的支持';
  514. $status['_class'] = 'state-sqtk';
  515. }else if(!$order['status']){
  516. if($order['pink_id']){
  517. if(StorePink::where('id',$order['pink_id'])->where('status',1)->count()){
  518. $status['_type'] = 1;
  519. $status['_title'] = '拼团中';
  520. $status['_msg'] = '等待其他人参加拼团';
  521. $status['_class'] = 'state-nfh';
  522. }else{
  523. $status['_type'] = 1;
  524. $status['_title'] = '未发货';
  525. $status['_msg'] = '商家未发货,请耐心等待';
  526. $status['_class'] = 'state-nfh';
  527. }
  528. }else{
  529. $status['_type'] = 1;
  530. $status['_title'] = '未发货';
  531. $status['_msg'] = '商家未发货,请耐心等待';
  532. $status['_class'] = 'state-nfh';
  533. }
  534. }else if($order['status'] == 1){
  535. $status['_type'] = 2;
  536. $status['_title'] = '待收货';
  537. $status['_msg'] = date('m月d日H时i分',StoreOrderStatus::getTime($order['id'],'delivery_goods')).'服务商已发货';
  538. $status['_class'] = 'state-ysh';
  539. }else if($order['status'] == 2){
  540. $status['_type'] = 3;
  541. $status['_title'] = '待评价';
  542. $status['_msg'] = '已收货,快去评价一下吧';
  543. $status['_class'] = 'state-ypj';
  544. }else if($order['status'] == 3){
  545. $status['_type'] = 4;
  546. $status['_title'] = '交易完成';
  547. $status['_msg'] = '交易完成,感谢您的支持';
  548. $status['_class'] = 'state-ytk';
  549. }
  550. if(isset($order['pay_type']))
  551. $status['_payType'] = isset(self::$payType[$order['pay_type']]) ? self::$payType[$order['pay_type']] : '其他方式';
  552. if(isset($order['delivery_type']))
  553. $status['_deliveryType'] = isset(self::$deliveryType[$order['delivery_type']]) ? self::$deliveryType[$order['delivery_type']] : '其他方式';
  554. $order['_status'] = $status;
  555. return $order;
  556. }
  557. public static function statusByWhere($status,$model = null)
  558. {
  559. $orderId = StorePink::where('uid',User::getActiveUid())->where('status',1)->column('order_id','id');//获取正在拼团的订单编号
  560. if($model == null) $model = new self;
  561. if('' === $status)
  562. return $model;
  563. else if($status == 0)
  564. return $model->where('paid',0)->where('status',0)->where('refund_status',0);
  565. else if($status == 1)//待发货
  566. return $model->where('paid',1)->where('order_id','NOT IN',implode(',',$orderId))->where('status',0)->where('refund_status',0);
  567. else if($status == 2)
  568. return $model->where('paid',1)->where('status',1)->where('refund_status',0);
  569. else if($status == 3)
  570. return $model->where('paid',1)->where('status',2)->where('refund_status',0);
  571. else if($status == 4)
  572. return $model->where('paid',1)->where('status',3)->where('refund_status',0);
  573. else if($status == -1)
  574. return $model->where('paid',1)->where('refund_status',1);
  575. else if($status == -2)
  576. return $model->where('paid',1)->where('refund_status',2);
  577. else if($status == -3)
  578. return $model->where('paid',1)->where('refund_status','IN','1,2');
  579. else if($status == 11){
  580. return $model->where('order_id','IN',implode(',',$orderId));
  581. }
  582. else
  583. return $model;
  584. }
  585. public static function getUserOrderList($uid,$status = '',$first = 0,$limit = 8)
  586. {
  587. $list = self::statusByWhere($status)->where('is_del',0)->where('uid',$uid)
  588. ->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')
  589. ->order('add_time DESC')->limit($first,$limit)->select()->toArray();
  590. foreach ($list as $k=>$order){
  591. $list[$k] = self::tidyOrder($order,true);
  592. }
  593. return $list;
  594. }
  595. public static function searchUserOrder($uid,$order_id)
  596. {
  597. $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')
  598. ->order('add_time DESC')->find();
  599. if(!$order)
  600. return false;
  601. else
  602. return self::tidyOrder($order->toArray(),true);
  603. }
  604. public static function orderOver($oid)
  605. {
  606. $res = self::edit(['status'=>'3'],$oid,'id');
  607. if(!$res) exception('评价后置操作失败!');
  608. StoreOrderStatus::status($oid,'check_order_over','用户评价');
  609. }
  610. public static function checkOrderOver($oid)
  611. {
  612. $uniqueList = StoreOrderCartInfo::where('oid',$oid)->column('unique');
  613. if(StoreProductReply::where('unique','IN',$uniqueList)->where('oid',$oid)->count() == count($uniqueList)){
  614. HookService::listen('store_product_order_over',$oid,null,false,StoreProductBehavior::class);
  615. self::orderOver($oid);
  616. }
  617. }
  618. public static function getOrderStatusNum($uid)
  619. {
  620. $noBuy = self::where('uid',$uid)->where('paid',0)->where('is_del',0)->where('pay_type','<>','offline')->count();
  621. $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();
  622. $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();
  623. $noPostage = bcadd($noPostageNoPink,$noPostageYesPink);
  624. $noTake = self::where('uid',$uid)->where('paid',1)->where('is_del',0)->where('status',1)->where('pay_type','<>','offline')->count();
  625. $noReply = self::where('uid',$uid)->where('paid',1)->where('is_del',0)->where('status',2)->count();
  626. $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();
  627. return compact('noBuy','noPostage','noTake','noReply','noPink');
  628. }
  629. public static function gainUserIntegral($order)
  630. {
  631. if($order['gain_integral'] > 0){
  632. $userInfo = User::getUserInfo($order['uid']);
  633. ModelBasic::beginTrans();
  634. $res1 = false != User::where('uid',$userInfo['uid'])->update(['integral'=>bcadd($userInfo['integral'],$order['gain_integral'],2)]);
  635. $res2 = false != UserBill::income('购买商品赠送积分',$order['uid'],'integral','gain',$order['gain_integral'],$order['id'],$userInfo['integral'],'购买商品赠送'.floatval($order['gain_integral']).'积分');
  636. $res = $res1 && $res2;
  637. ModelBasic::checkTrans($res);
  638. return $res;
  639. }
  640. return true;
  641. }
  642. /**
  643. * 获取当前订单中有没有拼团存在
  644. * @param $pid
  645. * @return int|string
  646. */
  647. public static function getIsOrderPink($pid = 0 ,$uid = 0){
  648. return self::where('uid',$uid)->where('pink_id',$pid)->where('refund_status',0)->where('is_del',0)->count();
  649. }
  650. /**
  651. * 获取order_id
  652. * @param $pid
  653. * @return mixed
  654. */
  655. public static function getStoreIdPink($pid = 0 ,$uid = 0){
  656. return self::where('uid',$uid)->where('pink_id',$pid)->where('is_del',0)->value('order_id');
  657. }
  658. /**
  659. * 删除当前用户拼团未支付的订单
  660. */
  661. public static function delCombination(){
  662. self::where('combination','GT',0)->where('paid',0)->where('uid',User::getActiveUid())->delete();
  663. }
  664. public static function getUserPrice($uid =0){
  665. if(!$uid) return 0;
  666. $price = self::where('paid',1)->where('uid',$uid)->where('status',2)->where('refund_status',0)->column('pay_price','id');
  667. $count = 0;
  668. if($price){
  669. foreach ($price as $v){
  670. $count = bcadd($count,$v,2);
  671. }
  672. }
  673. return $count;
  674. }
  675. }