Order.php 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. <?php
  2. namespace app\controller\wap;
  3. use app\extra\basic\Base;
  4. use app\extra\jhfPay\Pay;
  5. use app\extra\service\saas\OrderService;
  6. use app\middleware\WxMiddleware;
  7. use app\model\saas\SaasOrder;
  8. use app\model\saas\SaasOrderDetail;
  9. use app\model\saas\SaasUser;
  10. use app\model\saas\SaasUserLog;
  11. use DI\Attribute\Inject;
  12. use LinFly\Annotation\Route\Controller;
  13. use LinFly\Annotation\Route\Middleware;
  14. use LinFly\Annotation\Route\Route;
  15. use support\Request;
  16. use support\Response;
  17. #[Controller(prefix: "/wap/order"),Middleware(WxMiddleware::class)]
  18. class Order extends Base
  19. {
  20. #[Inject]
  21. protected OrderService $service;
  22. #[Inject]
  23. protected SaasOrder $model;
  24. #[Route(path: "list",methods: "get")]
  25. public function getPriceList(Request $request): Response
  26. {
  27. try {
  28. $param = $request->get();
  29. if (empty($param['shop'])) {
  30. $param['shop'] = $request->user['shop_id'];
  31. }
  32. if (!empty($param['order'])) {
  33. $orderType = explode("-",$param['order']);
  34. if (count($orderType)>1) { // 搜索取件码
  35. $param['sn'] = $param['order'];
  36. } else {
  37. $param['orderid'] = $param['order'];
  38. }
  39. }
  40. if (empty($param['status'])) $param['statusGt'] = 1;
  41. $list = $this->service->getList($param);
  42. return successTrans("success.data",pageFormat($list),200);
  43. } catch (\Throwable $throwable) {
  44. return error($throwable->getMessage());
  45. }
  46. }
  47. #[Route(path: "detail",methods: "get")]
  48. public function getOrderDetail(Request $request): Response
  49. {
  50. try {
  51. $param = $this->_valid([
  52. "id.require" => trans("empty.require")
  53. ],$request->method());
  54. if (!is_array($param)) return error($param);
  55. $detail = $this->model->where("id",$param['id'])->with(['detail','shop' => function($query){
  56. $query->field("shop_id,shop_name");
  57. }])->findOrEmpty();
  58. if ($detail->isEmpty()) return errorTrans("error.data");
  59. if ($detail['shop_id'] <> $request->user['shop_id']) return errorTrans("error.data");
  60. $startTime = strtotime(date('Y-m-d 00:00:00'));
  61. $endTime = strtotime(date('Y-m-d 23:59:58'));
  62. $orderTime = strtotime($detail['create_at']);
  63. $detail['today'] = (($orderTime > $startTime && $orderTime < $endTime) ? 1 : 0);
  64. return success("ok",$detail->toArray());
  65. } catch (\Throwable $throwable) {
  66. return error($throwable->getMessage());
  67. }
  68. }
  69. #[Route(path: "refund",methods: "post")]
  70. public function orderRefund(Request $request): Response
  71. {
  72. try {
  73. $param = $this->_valid([
  74. "id.require" => trans("empty.require")
  75. ],$request->method());
  76. if (!is_array($param)) return error($param);
  77. $detail = $this->model->where("id",$param['id'])->findOrEmpty();
  78. if ($detail->isEmpty()) return errorTrans("error.data");
  79. if ($detail['shop_id'] <> $request->user['shop_id']) return errorTrans("error.data");
  80. if (!in_array($detail['status'],[1,2,3])) return error("该订单不支持退款");
  81. if ($detail['pay_type'] == 2) {
  82. $card = (new SaasUser)->where("openid",$detail['openid'])->where("shop_id",$detail['shop_id'])->findOrEmpty();
  83. if ($card->isEmpty()) return error("会员卡失效");
  84. $card->balance = ($card['balance'] + $detail['money']);
  85. $card->total_consume = ($card['total_consume'] - $detail['money']);
  86. $card->save();
  87. (new SaasUserLog)->insertGetId([
  88. "openid" => $detail['openid'],
  89. "shop_id" => $detail['shop_id'],
  90. "order_sn" => $detail['order_sn'],
  91. "money" => $detail['money'],
  92. "card_no" => strtoupper(md5($detail['openid'].$detail['shop_id'])),
  93. "type" => 2,
  94. "remark" => "订单退款",
  95. "balance" => $card['balance'] - $detail['money'],
  96. ]);
  97. $detail->status = 6;
  98. $detail->refund_at = getDateFull();
  99. $detail->save();
  100. (new SaasOrderDetail)->where("order_sn",$detail['order_sn'])->update(['status' => 6]);
  101. return success("退款成功");
  102. }
  103. $respJhf = (new Pay)->config([
  104. "appid" => sConf("wechat.jhf_appid"),
  105. "mch_id" => sConf("wechat.jhf_mch_id"),
  106. "aeskey" => sConf("wechat.jhf_aeskey"),
  107. "pubkey" => sConf("wechat.jhf_pubkey"),
  108. "prikey" => sConf("wechat.jhf_prikey"),
  109. ])->createRefund([
  110. "payment_id" => $detail['payment_id'],
  111. "order_no" => $detail['order_sn'],
  112. "notify_url" => "https://panel.huiyinduo.cn/notify/refund",
  113. "refund_amt" => format_money($detail['money']/100,2)
  114. ]);
  115. if (isset($respJhf['code'])) {
  116. return error("发起退款失败");
  117. }
  118. $detail->status = 4;
  119. $state = $detail->save();
  120. if (!$state) return errorTrans("error.data");
  121. (new SaasOrderDetail)->where("order_sn",$detail['order_sn'])->update(['status' => 4]);
  122. return successTrans("success.data");
  123. } catch (\Throwable $throwable) {
  124. return error($throwable->getMessage());
  125. }
  126. }
  127. }