OrderService.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396
  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\Log as SupportLog;
  13. use support\Redis;
  14. use Yansongda\Pay\Log;
  15. use Yansongda\Pay\Pay;
  16. class OrderService
  17. {
  18. /**
  19. * @Desc 自动确认收货
  20. * @Author Gorden
  21. * @Date 2024/4/11 16:09
  22. *
  23. * @return void
  24. */
  25. public static function AutomaticReceipt()
  26. {
  27. try {
  28. Db::beginTransaction();
  29. $timeUnix = strtotime("-7 days");
  30. $orders = Order::where('order_status_system', 'SIGNED')
  31. ->where('order_addtimes', '<', $timeUnix)
  32. ->get();
  33. foreach ($orders as $order) {
  34. // 订单主表
  35. Order::where('order_id', $order->order_id)->update([
  36. 'order_is_complete' => 'Y',
  37. 'order_status_system' => 'CONFIRM',
  38. 'order_status_storage' => 'DONE'
  39. ]);
  40. // 订单详情表
  41. OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'DONE']);
  42. // 7天后自动完成 order_is_complete=Y
  43. // $redis = Redis::connection();
  44. // $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd', strtotime("+7 days"));
  45. // $redis->sadd($key, $order->order_id);
  46. }
  47. Db::commit();
  48. } catch (\Exception $e) {
  49. Db::rollBack();
  50. }
  51. }
  52. /**
  53. * @Desc 自动完成订单
  54. * @Author Gorden
  55. * @Date 2024/7/16 9:37
  56. *
  57. * @return void
  58. */
  59. public static function AutomaticComplete()
  60. {
  61. Db::beginTransaction();
  62. try {
  63. $redis = Redis::connection();
  64. $key = Order::AUTOMATIC_COMPLETE_PREFIX . date('Ymd');
  65. $orderIds = $redis->smembers($key);
  66. foreach ($orderIds as $orderId) {
  67. $order = Order::where('order_id', $orderId)
  68. ->select('order_is_complete', 'order_category', 'order_status_system')
  69. ->first();
  70. if ($order && $order->order_is_complete != 'Y' && $order->order_category != 'RETURN' && in_array($order->order_status_system, ['RECVING', 'SIGNED', 'CONFIRM'])) {
  71. // 更新主表
  72. Order::where('order_id', $orderId)->update(['order_is_complete' => 'Y', 'order_status_system' => 'CONFIRM', 'order_status_storage' => 'DONE']);
  73. // sheet表
  74. OrderSheet::where('join_sheet_order_id', $orderId)->update(['order_sheet_status' => 'DONE']);
  75. }
  76. }
  77. $redis->del($key);
  78. Db::commit();
  79. } catch (\Exception $e) {
  80. dump($e->getMessage());
  81. Db::rollBack();
  82. }
  83. }
  84. public static function checkPayingOrder()
  85. {
  86. try {
  87. Db::beginTransaction();
  88. $timeUnix = strtotime("-30 minutes");
  89. $orders = Order::where('order_status_system', 'PAYING')
  90. ->where('order_category', '<>', 'DISHES') // 点餐不自动取消
  91. // ->where('order_platform','<>','SYSTEM') // 后台产生的订单不自动取消
  92. ->where(function ($query) {
  93. $query->where('order_platform', '<>', 'SYSTEM')->orWhereNull('order_platform');
  94. })
  95. ->where('order_addtimes', '<', $timeUnix)
  96. ->get();
  97. foreach ($orders as $order) {
  98. // 订单主表
  99. Order::where('order_id', $order->order_id)->update([
  100. 'order_is_complete' => 'Y',
  101. 'order_status_system' => 'CANCEL',
  102. 'order_status_payment' => 'CANCEL'
  103. ]);
  104. $sheets = OrderSheet::where('join_sheet_order_id', $order->order_id)->get();
  105. foreach ($sheets as $sheet) {
  106. // 还原库存
  107. $goodsSku = GoodsSku::where('goods_sku_id', $sheet->join_sheet_goods_sku_id)->first();
  108. if (!empty($goodsSku) && !empty($goodsSku->goods_sku_storage_json)) {
  109. $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
  110. if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
  111. $skuStorageJson['storage'] = $skuStorageJson['storage'] + $sheet->order_sheet_num;
  112. $goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
  113. $goodsSku->save();
  114. }
  115. }
  116. $goodsRunning = GoodsRunning::where('join_running_goods_id', $sheet->join_sheet_goods_id)->first();
  117. if (!empty($goodsRunning)) {
  118. $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage + $sheet->order_sheet_num;
  119. $goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale - $sheet->order_sheet_num;
  120. $goodsRunning->save();
  121. }
  122. }
  123. // 订单详情表
  124. OrderSheet::where('join_sheet_order_id', $order->order_id)->update(['order_sheet_status' => 'CANCEL']);
  125. // 支付表
  126. $payDetail = PayDetail::where('join_pay_order_id', $order->order_groupby)->first();
  127. if (!empty($payDetail)) {
  128. $payExtendJson = [];
  129. if (!empty($payDetail->pay_extend_json)) {
  130. $payExtendJson = json_decode($payDetail->pay_extend_json, true);
  131. }
  132. $payExtendJson['cancel_times'] = date('Y-m-d H:i:s');
  133. PayDetail::where('join_pay_order_id', $order->order_groupby)->update([
  134. 'pay_status' => 'CANCEL',
  135. 'pay_extend_json' => json_encode($payExtendJson)
  136. ]);
  137. }
  138. }
  139. Db::commit();
  140. } catch (\Exception $e) {
  141. Db::rollBack();
  142. }
  143. }
  144. public static function generateWriteOffData($params)
  145. {
  146. return [
  147. 'charge' => [
  148. 'charge_amount' => 1,
  149. 'charge_content' => $params['order_remark'] ?? '',
  150. 'charge_user_id' => $params['write_off_member_id'],
  151. 'charge_premises' => $params['dept_premises_id'],
  152. ],
  153. 'member_id' => $params['join_order_member_id']
  154. ];
  155. }
  156. public static function generateAppointmentApplyData($params)
  157. {
  158. $member = Member::with('cert', 'info')
  159. ->where('member_id', $params['join_order_member_id'])
  160. ->first();
  161. $name = '';
  162. if (!empty($member) && !empty($member->cert) && !empty($member->cert->member_cert_name)) {
  163. $name = $member->cert->member_cert_name;
  164. } else if (!empty($member) && !empty($member->info) && !empty($member->info->member_info_nickname)) {
  165. $name = $member->info->member_info_nickname;
  166. }
  167. return [
  168. 'name' => $name,
  169. 'times' => '',
  170. 'mobile' => !empty($member) ? $member->member_mobile : '',
  171. 'person' => $params['order_sheet_num'] ?? '',
  172. 'premises' => $params['dept_premises_id'] ?? ''
  173. ];
  174. }
  175. /**
  176. * 微信支付宝扫码支付
  177. */
  178. public static function qrcodePay($params)
  179. {
  180. $log = SupportLog::channel('pay');
  181. $log->info("PAY_PARAMS", json_decode(json_encode($params), true));
  182. $params['order_amount_pay'] = floatval($params['order_amount_pay']);
  183. $qrcodeNbr = $params['qrcode_nbr'];
  184. $prefix = substr($qrcodeNbr, 0, 2);
  185. // 模拟数据
  186. // $result = [
  187. // 'return_code'=>'SUCCESS',
  188. // 'result_code' => 'SUCCESS'
  189. // ];
  190. // return $result;
  191. // 微信支付
  192. if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
  193. $payData = [
  194. 'out_trade_no' => $params['orderGroupId'],
  195. 'body' => '万悦康养订单',
  196. 'total_fee' => $params['order_amount_pay'] * 100,
  197. 'auth_code' => $params['qrcode_nbr'],
  198. ];
  199. try {
  200. // Pay::wechat(config('payment.wxpay'))->pos($payData);
  201. $result = self::findWxpay('OD2024081615233851FJON', 0);
  202. } catch (\Exception $e) {
  203. $log->error("WXPAY", ['msg' => $e->getMessage()]);
  204. throw new BusinessException("支付失败");
  205. }
  206. $log->info("WXPAY_RETURN", json_decode(json_encode($result), true));
  207. } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
  208. $payData = [
  209. 'out_trade_no' => $params['orderGroupId'],
  210. 'total_amount' => $params['order_amount_pay'],
  211. 'subject' => '万悦康养订单',
  212. 'auth_code' => $params['qrcode_nbr'],
  213. ];
  214. try {
  215. Pay::alipay(config('payment.alipay'))->pos($payData);
  216. $result = self::findAlipay($params['orderGroupId'], 0);
  217. } catch (\Exception $e) {
  218. $log->error("ALIPAY", ['msg' => $e->getMessage()]);
  219. throw new BusinessException("支付失败");
  220. }
  221. $log->info("ALIPAY_RETURN", json_decode(json_encode($result), true));
  222. } else {
  223. throw new BusinessException("二维码无效");
  224. }
  225. return $result;
  226. }
  227. /**
  228. * @Desc 查询微信支付
  229. * @Author Gorden
  230. * @Date 2024/8/16 14:55
  231. *
  232. * @param $orderId
  233. * @param $nbr 循环次数
  234. * @return mixed|void
  235. * @throws BusinessException
  236. */
  237. public static function findWxpay($orderId, $nbr = 0)
  238. {
  239. if ($nbr >= 6) {
  240. throw new BusinessException("订单查询失败");
  241. }
  242. try {
  243. if($nbr > 2) {
  244. $result = Pay::wechat(config('payment.wxpay'))->find($orderId, 'pos');
  245. $result = json_decode(json_encode($result), true);
  246. }
  247. } catch (\Exception $e) {
  248. throw new BusinessException("订单查询失败");
  249. }
  250. if (!empty($result['return_code']) && $result['return_code'] == 'SUCCESS' && !empty($result['result_code']) && $result['result_code'] == 'SUCCESS') {
  251. return $result;
  252. } else {
  253. dump("睡:".$nbr);
  254. sleep(5);
  255. self::findWxpay($orderId, $nbr + 1);
  256. }
  257. }
  258. /**
  259. * @Desc 查询支付宝订单
  260. * @Author Gorden
  261. * @Date 2024/8/16 15:16
  262. *
  263. * @param $orderId
  264. * @param $nbr 循环次数
  265. * @return mixed|void
  266. * @throws BusinessException
  267. */
  268. public static function findAlipay($orderId, $nbr = 0)
  269. {
  270. if ($nbr >= 6) {
  271. throw new BusinessException("订单查询失败");
  272. }
  273. try {
  274. if($nbr > 2){
  275. $result = Pay::alipay(config('payment.alipay'))->find($orderId);
  276. $result = json_decode(json_encode($result), true);
  277. }
  278. } catch (\Exception $e) {
  279. throw new BusinessException("订单查询失败");
  280. }
  281. if (!empty($result['code']) && $result['code'] == '10000' && !empty($result['trade_status']) && $result['trade_status'] == 'TRADE_SUCCESS') {
  282. return $result;
  283. } else {
  284. dump("睡:".$nbr);
  285. sleep(5);
  286. self::findAlipay($orderId, $nbr + 1);
  287. }
  288. }
  289. /**
  290. * 验证产品库存
  291. */
  292. public static function checkGoodsStorage($params)
  293. {
  294. foreach ($params['goodsContentList'] as $goods) {
  295. // 减库存,规格和总库存
  296. if (!isset($params['submit_goods_classify']) || $params['submit_goods_classify'] != 'MEALS') {
  297. $goodsSku = GoodsSku::where('goods_sku_id', $goods['sku_id'])->first();
  298. $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
  299. if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
  300. $skuStorageJson['storage'] = $skuStorageJson['storage'] - $goods['nbr'];
  301. }
  302. if (!isset($skuStorageJson['storage']) || (!empty($skuStorageJson['storage']) && $skuStorageJson['storage'] < 0)) {
  303. throw new BusinessException('库存不足');
  304. }
  305. }
  306. $goodsRunning = GoodsRunning::where('join_running_goods_id', $goods['goods_id'])->first();
  307. $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage - $goods['nbr'];
  308. if ($goodsRunning->goods_running_storage < 0) {
  309. throw new BusinessException('库存不足');
  310. }
  311. }
  312. }
  313. /**
  314. * 下单时结算的组合支付payDetail
  315. */
  316. public static function createPayDetail($params)
  317. {
  318. $insertPayDetailData = [
  319. 'join_pay_member_id' => $params['join_order_member_id'],
  320. 'join_pay_order_id' => $params['orderGroupId'],
  321. 'pay_status' => 'SUCCESS',
  322. 'pay_category' => !empty($params['submit_goods_classify']) ? $params['submit_goods_classify'] : $params['goods_classify'],
  323. 'pay_amount' => $params['order_amount_pay'],
  324. 'pay_paytimes' => date('Y-m-d H:i:s'),
  325. 'pay_prepayid' => $params['pay_category'],
  326. 'pay_json_request' => json_encode($params),
  327. 'pay_json_response' => $params['pay_json_response'] ?? '[]',
  328. 'pay_addtimes' => time()
  329. ];
  330. PayDetail::insert($insertPayDetailData);
  331. }
  332. /**
  333. * 组合支付,PayDetail
  334. */
  335. public static function createPayConstituteDetail($params, $payDetail)
  336. {
  337. $qrcodePrepayId = '';
  338. if (in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
  339. $qrcodePrepayId = $params['join_order_member_id'] . '-QRCODE';
  340. }
  341. if (!$payDetail || ($payDetail->pay_prepayid != $params['pay_category'] && $payDetail->pay_prepayid != $qrcodePrepayId)) {
  342. $payDetail = new PayDetail();
  343. $payDetail->join_pay_member_id = $params['join_order_member_id'];
  344. $payDetail->join_pay_order_id = $params['orderGroupId'];
  345. $payDetail->pay_category = $params['goods_classify'] ?? '';
  346. $payDetail->pay_prepayid = $params['pay_category'];
  347. $payDetail->pay_json_request = json_encode($params);
  348. $payDetail->pay_json_response = $params['pay_json_response'] ?? json_encode([
  349. 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
  350. ]);
  351. $payDetail->pay_addtimes = time();
  352. }
  353. if ($payDetail->pay_prepayid == $qrcodePrepayId) {
  354. $payDetail->pay_prepayid = $params['pay_category'];
  355. }
  356. $payDetail->pay_json_response = $params['pay_json_response'] ?? json_encode([
  357. 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
  358. ]);
  359. $payDetail->pay_amount = $params['order_amount_pay'];
  360. $payDetail->pay_paytimes = date('Y-m-d H:i:s');
  361. $payDetail->pay_status = 'SUCCESS';
  362. $payDetail->save();
  363. }
  364. }