OrderRepository.php 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192
  1. <?php
  2. namespace crmeb\repositories;
  3. use app\models\store\StoreOrder;
  4. use app\models\user\User;
  5. use app\models\user\WechatUser;
  6. use app\admin\model\order\StoreOrder as AdminStoreOrder;
  7. use crmeb\services\MiniProgramService;
  8. use crmeb\services\WechatService;
  9. /**
  10. * Class OrderRepository
  11. * @package crmeb\repositories
  12. */
  13. class OrderRepository
  14. {
  15. /**
  16. * TODO 小程序JS支付
  17. * @param $orderId
  18. * @param string $field
  19. * @return array|string
  20. * @throws \think\db\exception\DataNotFoundException
  21. * @throws \think\db\exception\ModelNotFoundException
  22. * @throws \think\exception\DbException
  23. */
  24. public static function jsPay($orderId, $field = 'order_id')
  25. {
  26. if (is_string($orderId))
  27. $orderInfo = StoreOrder::where($field, $orderId)->find();
  28. else
  29. $orderInfo = $orderId;
  30. if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
  31. if ($orderInfo['paid']) exception('支付已支付!');
  32. if (bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2) <= 0) exception('该支付无需支付!');
  33. $openid = WechatUser::getOpenId($orderInfo['uid']);
  34. $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
  35. $site_name = sys_config('site_name');
  36. if (!$bodyContent && !$site_name) exception('支付参数缺少:请前往后台设置->系统设置-> 填写 网站名称');
  37. return MiniProgramService::jsPay($openid, $orderInfo['order_id'], bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2), 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
  38. }
  39. /**
  40. * 微信公众号JS支付
  41. * @param $orderId
  42. * @param string $field
  43. * @return array|string
  44. * @throws \think\db\exception\DataNotFoundException
  45. * @throws \think\db\exception\ModelNotFoundException
  46. * @throws \think\exception\DbException
  47. */
  48. public static function wxPay($orderId, $field = 'order_id')
  49. {
  50. if (is_string($orderId))
  51. $orderInfo = StoreOrder::where($field, $orderId)->find();
  52. else
  53. $orderInfo = $orderId;
  54. if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
  55. if ($orderInfo['paid']) exception('支付已支付!');
  56. if (bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2) <= 0) exception('该支付无需支付!');
  57. $openid = WechatUser::uidToOpenid($orderInfo['uid'], 'openid');
  58. $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
  59. $site_name = sys_config('site_name');
  60. if (!$bodyContent && !$site_name) exception('支付参数缺少:请前往后台设置->系统设置-> 填写 网站名称');
  61. return WechatService::jsPay($openid, $orderInfo['order_id'], bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2), 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30));
  62. }
  63. /**
  64. * 微信h5支付
  65. * @param $orderId
  66. * @param string $field
  67. * @return array|string
  68. * @throws \think\db\exception\DataNotFoundException
  69. * @throws \think\db\exception\ModelNotFoundException
  70. * @throws \think\exception\DbException
  71. */
  72. public static function h5Pay($orderId, $field = 'order_id')
  73. {
  74. if (is_string($orderId))
  75. $orderInfo = StoreOrder::where($field, $orderId)->find();
  76. else
  77. $orderInfo = $orderId;
  78. if (!$orderInfo || !isset($orderInfo['paid'])) exception('支付订单不存在!');
  79. if ($orderInfo['paid']) exception('支付已支付!');
  80. if (bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2) <= 0) exception('该支付无需支付!');
  81. $bodyContent = StoreOrder::getProductTitle($orderInfo['cart_id']);
  82. $site_name = sys_config('site_name');
  83. if (!$bodyContent && !$site_name) exception('支付参数缺少:请前往后台设置->系统设置-> 填写 网站名称');
  84. return WechatService::paymentPrepare(null, $orderInfo['order_id'], bcadd($orderInfo['pay_price'], $orderInfo['deposit'], 2), 'product', StoreOrder::getSubstrUTf8($site_name . ' - ' . $bodyContent, 30), '', 'MWEB');
  85. }
  86. /**
  87. * 用户确认收货
  88. * @param $order
  89. * @param $uid
  90. * @throws \think\Exception
  91. * @throws \think\db\exception\DataNotFoundException
  92. * @throws \think\db\exception\ModelNotFoundException
  93. * @throws \think\exception\DbException
  94. * @throws \think\db\exception\DbException
  95. * @throws \Exception
  96. */
  97. public static function storeProductOrderUserTakeDelivery($order, $uid)
  98. {
  99. $res1 = StoreOrder::gainUserIntegral($order);
  100. // $res2 = User::backOrderBrokerage($order);
  101. $res2 = User::sendBackOrderBrokerage($order);
  102. $res3 = StoreOrder::treatmentAward($order['id']);
  103. StoreOrder::orderTakeAfter($order);
  104. StoreOrder::where('id', $order['id'])->update(['arrive_time' => time()]);
  105. //满赠优惠券
  106. WechatUser::userTakeOrderGiveCoupon($uid, $order['total_price']);
  107. if (!($res1 && $res2 && $res3)) exception('收货失败!');
  108. }
  109. /**
  110. * 修改状态 为已收货 admin模块
  111. * @param $order
  112. * @throws \Exception
  113. */
  114. public static function storeProductOrderTakeDeliveryAdmin($order)
  115. {
  116. $res1 = AdminStoreOrder::gainUserIntegral($order);
  117. // $res2 = User::backOrderBrokerage($order);
  118. $res2 = User::sendBackOrderBrokerage($order);
  119. $res3 = StoreOrder::treatmentAward($order['id']);
  120. AdminStoreOrder::orderTakeAfter($order);
  121. StoreOrder::where('id', $order['id'])->update(['arrive_time' => time()]);
  122. if (!($res1 && $res2 && $res3)) exception('收货失败!');
  123. }
  124. /**
  125. * 修改状态 为已收货 定时任务使用
  126. * @param $order
  127. * @throws \Exception
  128. */
  129. public static function storeProductOrderTakeDeliveryTimer($order)
  130. {
  131. $res1 = AdminStoreOrder::gainUserIntegral($order, false);
  132. $res2 = User::sendBackOrderBrokerage($order);
  133. $res3 = StoreOrder::treatmentAward($order['id']);
  134. AdminStoreOrder::orderTakeAfter($order);
  135. StoreOrder::where('id', $order['id'])->update(['arrive_time' => time()]);
  136. if (!($res1 && $res2 && $res3)) exception('收货失败!');
  137. }
  138. /**
  139. * 修改状态为 已退款 admin模块
  140. * @param $data
  141. * @param $oid
  142. * @return bool|mixed
  143. * @throws \think\db\exception\DataNotFoundException
  144. * @throws \think\db\exception\ModelNotFoundException
  145. * @throws \think\exception\DbException
  146. */
  147. public static function storeProductOrderRefundY($data, $oid)
  148. {
  149. $order = AdminStoreOrder::where('id', $oid)->find();
  150. if ($order['is_channel'] == 1)
  151. return AdminStoreOrder::refundRoutineTemplate($oid); //TODO 小程序余额退款模板消息
  152. else
  153. return AdminStoreOrder::refundTemplate($data, $oid);//TODO 公众号余额退款模板消息
  154. }
  155. /**
  156. * TODO 后台余额退款
  157. * @param $product
  158. * @param $refund_data
  159. * @throws \Exception
  160. */
  161. public static function storeOrderYueRefund($product, $refund_data)
  162. {
  163. $res = AdminStoreOrder::integralBack($product['id']);
  164. if (!$res) exception('退积分失败!');
  165. }
  166. /**
  167. * 订单退积分
  168. * @param $product $product 商品信息
  169. * @param $back_integral $back_integral 退多少积分
  170. */
  171. public static function storeOrderIntegralBack($product, $back_integral)
  172. {
  173. }
  174. }