OrderService.php 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228
  1. <?php
  2. namespace app\admin\service\order;
  3. use app\model\GoodsRunning;
  4. use app\model\GoodsSku;
  5. use app\model\Member;
  6. use app\model\Order;
  7. use app\model\OrderSheet;
  8. use app\model\PayDetail;
  9. use app\model\SysDept;
  10. use support\Db;
  11. use support\exception\BusinessException;
  12. use support\Redis;
  13. use Yansongda\Pay\Log;
  14. use Yansongda\Pay\Pay;
  15. class OrderService
  16. {
  17. /**
  18. * @Desc 自动确认收货
  19. * @Author Gorden
  20. * @Date 2024/4/11 16:09
  21. *
  22. * @return void
  23. */
  24. public static function AutomaticReceipt()
  25. {
  26. try {
  27. Db::beginTransaction();
  28. $timeUnix = strtotime("-7 days");
  29. $orders = Order::where('order_status_system', 'SIGNED')
  30. ->where('order_addtimes', '<', $timeUnix)
  31. ->get();
  32. foreach ($orders as $order) {
  33. // 订单主表
  34. Order::where('order_id', $order->order_id)->update([
  35. 'order_is_complete' => 'Y',
  36. 'order_status_system' => 'CONFIRM',
  37. 'order_status_storage'=> 'DONE'
  38. ]);
  39. // 订单详情表
  40. OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'DONE']);
  41. // 7天后自动完成 order_is_complete=Y
  42. // $redis = Redis::connection();
  43. // $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd', strtotime("+7 days"));
  44. // $redis->sadd($key, $order->order_id);
  45. }
  46. Db::commit();
  47. } catch (\Exception $e) {
  48. Db::rollBack();
  49. }
  50. }
  51. /**
  52. * @Desc 自动完成订单
  53. * @Author Gorden
  54. * @Date 2024/7/16 9:37
  55. *
  56. * @return void
  57. */
  58. public static function AutomaticComplete()
  59. {
  60. Db::beginTransaction();
  61. try {
  62. $redis = Redis::connection();
  63. $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd');
  64. $orderIds = $redis->smembers($key);
  65. foreach ($orderIds as $orderId){
  66. $order = Order::where('order_id',$orderId)
  67. ->select('order_is_complete','order_category','order_status_system')
  68. ->first();
  69. if ($order && $order->order_is_complete != 'Y' && $order->order_category != 'RETURN' && in_array($order->order_status_system,['RECVING','SIGNED','CONFIRM'])){
  70. // 更新主表
  71. Order::where('order_id',$orderId)->update(['order_is_complete'=>'Y','order_status_system'=>'CONFIRM','order_status_storage'=>'DONE']);
  72. // sheet表
  73. OrderSheet::where('join_sheet_order_id',$orderId)->update(['order_sheet_status'=>'DONE']);
  74. }
  75. }
  76. $redis->del($key);
  77. Db::commit();
  78. } catch (\Exception $e) {
  79. dump($e->getMessage());
  80. Db::rollBack();
  81. }
  82. }
  83. public static function checkPayingOrder()
  84. {
  85. try {
  86. Db::beginTransaction();
  87. $timeUnix = strtotime("-30 minutes");
  88. $orders = Order::where('order_status_system', 'PAYING')
  89. ->where('order_category','<>','DISHES')
  90. ->where('order_platform','<>','SYSTEM') // 后台产生的订单不自动取消
  91. ->where('order_addtimes', '<', $timeUnix)
  92. ->get();
  93. foreach ($orders as $order) {
  94. // 订单主表
  95. Order::where('order_id', $order->order_id)->update([
  96. 'order_is_complete' => 'Y',
  97. 'order_status_system' => 'CANCEL',
  98. 'order_status_payment' => 'CANCEL'
  99. ]);
  100. $sheets = OrderSheet::where('join_sheet_order_id', $order->order_id)->get();
  101. foreach ($sheets as $sheet){
  102. // 还原库存
  103. $goodsSku = GoodsSku::where('goods_sku_id',$sheet->join_sheet_goods_sku_id)->first();
  104. if (!empty($goodsSku) && !empty($goodsSku->goods_sku_storage_json)){
  105. $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json,true);
  106. if (isset($skuStorageJson['storage'])){
  107. $skuStorageJson['storage'] = $skuStorageJson['storage'] + $sheet->order_sheet_num;
  108. $goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
  109. $goodsSku->save();
  110. }
  111. }
  112. $goodsRunning = GoodsRunning::where('join_running_goods_id',$sheet->join_sheet_goods_id)->first();
  113. if(!empty($goodsRunning)){
  114. $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage + $sheet->order_sheet_num;
  115. $goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale - $sheet->order_sheet_num;
  116. $goodsRunning->save();
  117. }
  118. }
  119. // 订单详情表
  120. OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'CANCEL']);
  121. // 支付表
  122. PayDetail::where('pay_id', $order->order_groupby)->update([
  123. 'pay_status' => 'CANCEL',
  124. ]);
  125. }
  126. Db::commit();
  127. } catch (\Exception $e) {
  128. Db::rollBack();
  129. }
  130. }
  131. public static function generateWriteOffData($params)
  132. {
  133. return [
  134. 'charge' => [
  135. 'charge_amount' => 1,
  136. 'charge_content' => $params['order_remark'] ?? '',
  137. 'charge_user_id' => $params['write_off_member_id'],
  138. 'charge_premises' => $params['dept_premises_id'],
  139. ],
  140. 'member_id' => $params['join_order_member_id']
  141. ];
  142. }
  143. public static function generateAppointmentApplyData($params)
  144. {
  145. $member = Member::with('cert','info')
  146. ->where('member_id',$params['join_order_member_id'])
  147. ->first();
  148. $name = '';
  149. if (!empty($member) && !empty($member->cert) && !empty($member->cert->member_cert_name)){
  150. $name = $member->cert->member_cert_name;
  151. }else if (!empty($member) && !empty($member->info) && !empty($member->info->member_info_nickname)){
  152. $name = $member->info->member_info_nickname;
  153. }
  154. return [
  155. 'name' => $name,
  156. 'times' => '',
  157. 'mobile' => !empty($member) ? $member->member_mobile : '',
  158. 'person' => $params['order_sheet_num'] ?? '',
  159. 'premises' => $params['dept_premises_id'] ?? ''
  160. ];
  161. }
  162. /**
  163. * 微信支付宝扫码支付
  164. */
  165. public static function qrcodePay($params)
  166. {
  167. $params['order_amount_pay'] = floatval($params['order_amount_pay']);
  168. $qrcodeNbr = $params['qrcode_nbr'];
  169. $prefix = substr($qrcodeNbr,0,2);
  170. // 微信支付
  171. if(in_array($prefix,[10,11,12,13,14,15])){
  172. $payData = [
  173. 'out_trade_no' => $params['orderGroupId'],
  174. 'body' => '万悦康养订单',
  175. 'total_fee' => $params['order_amount_pay']*100,
  176. 'auth_code' => $params['qrcode_nbr'],
  177. ];
  178. try{
  179. $result = Pay::wechat(config('payment.wxpay'))->pos($payData);
  180. }catch(\Exception $e){
  181. Log::error("WXPAY",['msg'=>$e->getMessage()]);
  182. throw new BusinessException("支付失败");
  183. }
  184. Log::info("WXPAY_RETURN",json_decode(json_encode($result),true));
  185. }else if(in_array($prefix,[25,26,27,28,29,30])){
  186. $payData = [
  187. 'out_trade_no' => $params['orderGroupId'],
  188. 'total_amount' => $params['order_amount_pay'],
  189. 'subject' => '万悦康养订单',
  190. 'auth_code' => $params['qrcode_nbr'],
  191. ];
  192. try{
  193. $result = Pay::alipay(config('payment.alipay'))->pos($payData);
  194. }catch(\Exception $e){
  195. Log::error("ALIPAY",['msg'=>$e->getMessage()]);
  196. throw new BusinessException("支付失败");
  197. }
  198. Log::info("ALIPAY_RETURN",json_decode(json_encode($result),true));
  199. }else{
  200. throw new BusinessException("二维码无效");
  201. }
  202. return $result;
  203. }
  204. }