PartnerController.php 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211
  1. <?php
  2. namespace app\admin\controller\order;
  3. use app\admin\service\coupon\CouponService;
  4. use app\admin\service\member\MemberService;
  5. use app\admin\service\order\OrderService;
  6. use app\admin\validate\order\OrderValidate;
  7. use app\controller\Curd;
  8. use app\model\Appointment;
  9. use app\model\ClientConfig;
  10. use app\model\Coupon;
  11. use app\model\Goods;
  12. use app\model\GoodsComponent;
  13. use app\model\GoodsRunning;
  14. use app\model\GoodsSku;
  15. use app\model\Member;
  16. use app\model\MemberAccount;
  17. use app\model\MemberBenefit;
  18. use app\model\MemberRole;
  19. use app\model\Order;
  20. use app\model\OrderExpress;
  21. use app\model\OrderReturn;
  22. use app\model\OrderSheet;
  23. use app\model\PayDetail;
  24. use app\model\Supplier;
  25. use app\model\SysDept;
  26. use app\model\SysUser;
  27. use support\Db;
  28. use support\exception\BusinessException;
  29. use support\Redis;
  30. use support\Request;
  31. use support\Response;
  32. use Webman\Event\Event;
  33. use Yansongda\Pay\Pay;
  34. class PartnerController extends Curd
  35. {
  36. public function __construct()
  37. {
  38. $this->model = new Order();
  39. $this->validate = true;
  40. $this->validateClass = new OrderValidate();
  41. }
  42. /**
  43. * @Desc 列表
  44. * @Author Gorden
  45. * @Date 2024/3/28 15:01
  46. *
  47. * @param Request $request
  48. * @return Response
  49. * @throws \support\exception\BusinessException
  50. */
  51. public function select(Request $request): Response
  52. {
  53. [$where, $format, $limit, $field, $order] = $this->selectInput($request);
  54. $where['order_classify'] = 'PARTNER';
  55. if (!empty($where['order_addtimes'])) {
  56. $where['order_addtimes'][0] = strtotime($where['order_addtimes'][0]);
  57. $where['order_addtimes'][1] = strtotime($where['order_addtimes'][1]);
  58. }
  59. $order = $request->get('order', 'desc');
  60. $field = $field ?? 'order_addtimes';
  61. $orderIds = [];
  62. if (!empty($orderId)) {
  63. $orderIds = Order::where('order_id', 'like', '%' . $orderId . '%')
  64. ->where('order_classify', 'PARTNER')
  65. ->pluck('order_id')
  66. ->toArray();
  67. }
  68. $goodsName = trim($request->get('goods_name', ''));
  69. if (!empty($goodsName)) {
  70. $goodsIds = Goods::where('goods_classify', 'PARTNER')
  71. ->where('goods_name', 'like', '%' . $goodsName . '%')
  72. ->pluck('goods_id')
  73. ->toArray();
  74. $goodsOrderIds = OrderSheet::whereIn('join_sheet_goods_id', $goodsIds)->pluck('join_sheet_order_id')->toArray();
  75. if (!empty($where['order_id'])) {
  76. $orderIds = array_intersect($orderIds, $goodsOrderIds);
  77. } else {
  78. $orderIds = $goodsOrderIds;
  79. }
  80. }
  81. if (!empty($orderId) || !empty($goodsName)) {
  82. $where['order_id'] = ['in', implode(',', $orderIds)];
  83. }
  84. $query = $this->doSelect($where, $field, $order);
  85. return $this->doFormat($query, $format, $limit);
  86. }
  87. protected function doSelect(array $where, string $field = null, string $order = 'desc')
  88. {
  89. $model = $this->model->with([
  90. 'sheets' => function ($query) {
  91. $query->select('join_sheet_order_id', 'order_sheet_id', 'join_sheet_goods_id', 'order_sheet_num', 'order_sheet_price');
  92. },
  93. 'member' => function ($query) {
  94. $query->select('member_id', 'member_mobile');
  95. },
  96. 'cert' => function ($query) {
  97. $query->select('join_cert_member_id', 'member_cert_name');
  98. },
  99. // 'return' => function ($query) use ($where){
  100. // if (isset($where['return'])){
  101. // dump($where['return']);
  102. // $query = $query->where('order_return_status',$where['return']);
  103. // }
  104. // $query->select('orders_return_id', 'join_return_order_id', 'order_return_status');
  105. // },
  106. // 'express' => function ($query) {
  107. // $query->select('join_express_order_id', 'order_express_type');
  108. // }
  109. ])->leftJoin('order_return', 'order_return.join_return_order_id', '=', 'order.order_id')
  110. ->leftJoin('order_express', 'order_express.join_express_order_id', '=', 'order.order_id');
  111. // ->leftJoin('order_sheet','join_sheet_order_id','=','order.order_id');
  112. foreach ($where as $column => $value) {
  113. if (is_array($value)) {
  114. if ($value[0] === 'like' || $value[0] === 'not like') {
  115. $model = $model->where($column, $value[0], "%$value[1]%");
  116. } elseif (in_array($value[0], ['>', '=', '<', '<>'])) {
  117. $model = $model->where($column, $value[0], $value[1]);
  118. } elseif ($value[0] == 'in' && !empty($value[1])) {
  119. $valArr = $value[1];
  120. if (is_string($value[1])) {
  121. $valArr = explode(",", trim($value[1]));
  122. }
  123. $model = $model->whereIn($column, $valArr);
  124. } elseif ($value[0] == 'not in' && !empty($value[1])) {
  125. $valArr = $value[1];
  126. if (is_string($value[1])) {
  127. $valArr = explode(",", trim($value[1]));
  128. }
  129. $model = $model->whereNotIn($column, $valArr);
  130. } elseif ($value[0] == 'null') {
  131. $model = $model->whereNull($column);
  132. } elseif ($value[0] == 'not null') {
  133. $model = $model->whereNotNull($column);
  134. } elseif ($value[0] !== '' || $value[1] !== '') {
  135. $model = $model->whereBetween($column, $value);
  136. }
  137. } else {
  138. $model = $model->where($column, $value);
  139. }
  140. }
  141. if ($field) {
  142. $model = $model->orderBy($field, $order);
  143. }
  144. $model = $model->select('order.*', 'order_express.join_express_order_id', 'order_express.order_express_type', 'order_return.orders_return_id', 'order_return.join_return_order_id', 'order_return.order_return_status', 'order_return.order_return_apply_json', 'order_return.order_return_remark');
  145. return $model;
  146. }
  147. public function afterQuery($items)
  148. {
  149. foreach ($items as &$item) {
  150. $sheetDeng = '';
  151. $item['sheet'] = $item['sheets'][0] ?? [];
  152. if (!empty($item['sheet'])) {
  153. $goods = Goods::where('goods_id', $item['sheet']['join_sheet_goods_id'])->first();
  154. if (count($item['sheets']) > 1 && $goods->goods_classify == 'MEALS') {
  155. $sheetDeng = ' 等餐品';
  156. }
  157. $item['sheet']['goods_name'] = ($goods && $goods->goods_name) ? $goods->goods_name . $sheetDeng : '';
  158. $item['sheet']['goods_classify'] = $goods->goods_classify ?? '';
  159. $item['sheet']['order_sheet_num'] = intval($item['sheet']['order_sheet_num']);
  160. }
  161. unset($item['sheets']);
  162. if (isset($item['orders_return_id'])) {
  163. $item['return'] = [
  164. 'orders_return_id' => $item['orders_return_id'],
  165. 'join_return_order_id' => $item['join_return_order_id'],
  166. 'order_return_status' => $item['order_return_status'],
  167. 'order_return_apply_json' => $item['order_return_apply_json'],
  168. 'order_return_remark' => $item['order_return_remark']
  169. ];
  170. }
  171. if (isset($item['join_express_order_id'])) {
  172. $item['express'] = [
  173. 'join_express_order_id' => $item['join_express_order_id'],
  174. 'order_express_type' => $item['order_express_type']
  175. ];
  176. unset($item['join_express_order_id'], $item['order_express_type']);
  177. }
  178. // if (!empty($item['order_extend_json'])){
  179. // $orderExtendJson = json_decode($item['order_extend_json'],true);
  180. // $item['referee'] = $orderExtendJson['referee'] ?? '';
  181. // }
  182. }
  183. return $items;
  184. }
  185. /**
  186. * @Desc 下单+支付
  187. * @Author Gorden
  188. * @Date 2024/9/5 13:13
  189. *
  190. * @param Request $request
  191. * @return Response
  192. */
  193. public function insert(Request $request): Response
  194. {
  195. $params = $request->post();
  196. // 判断餐品是否连带着服务或实体
  197. $goodsClassifys = array_unique(array_column($params['goodsContentList'], 'goods_classify'));
  198. $params['goods_classify'] = $goodsClassifys[0];
  199. Db::beginTransaction();
  200. try {
  201. // 验证线下付款密码
  202. if ($params['settlement_now'] == 'Y' && $params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['OFFLINE', 'MONEY'])) {
  203. $password = $params['offline_password'];
  204. if ($password != '666888') {
  205. throw new BusinessException('密码错误,请重新输入');
  206. }
  207. }
  208. // 下单账户
  209. if (empty($params['join_order_member_id']) && !empty($params['mobile'])) {
  210. if (Member::where('member_mobile', $params['mobile'])->exists()) {
  211. throw new BusinessException('会员已存在');
  212. }
  213. $params['join_order_member_id'] = $params['member_id'] = 'MR' . date('ymdHi') . random_string(4, 'up');
  214. // 创建会员
  215. MemberService::createMember($params);
  216. } else if (empty($params['join_order_member_id']) && empty($params['mobile'])) {
  217. $params['join_order_member_id'] = Member::where('member_mobile', '0000')->value('member_id');
  218. }
  219. if (empty($params['join_order_member_id'])) {
  220. throw new BusinessException('检查下单账户');
  221. }
  222. $qrcodePayAmount = 0;
  223. $params['orderId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  224. $params['orderGroupId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  225. // 查询是否有未完全支付订单
  226. $paidOrder = Order::where('join_order_member_id', $params['join_order_member_id'])
  227. ->where('order_category', 'PARTNER')
  228. ->where('order_status_system', 'PAYING')
  229. ->first();
  230. if (!empty($paidOrder)) {
  231. $paidOrder->order_groupby = $params['orderGroupId'];
  232. $params['orderId'] = $paidOrder->order_id;
  233. }
  234. $systemStatus = 'PAYING';
  235. // 立即结算
  236. if ($params['settlement_now'] == 'Y') {
  237. if ($params['goods_classify'] == 'PARTNER') {
  238. $params['order_is_complete'] = 'Y';
  239. $systemStatus = 'DONE';
  240. }
  241. }
  242. if ($params['settlement_now'] == 'Y' && ($params['pay_category'] == 'OFFLINE' || $params['pay_category'] == 'MONEY')) {
  243. if ($params['pay_category'] == 'OFFLINE' && !empty($params['pay_category_sub'])) {
  244. $params['pay_category'] = $params['pay_category_sub'];
  245. }
  246. $params['order_status_system'] = $systemStatus;
  247. $params['order_status_payment'] = 'SUCCESS';
  248. }
  249. if ($params['pay_category'] == 'QRCODE' && $params['settlement_now'] == 'Y' && !empty($params['qrcode_nbr'])) { // 付款码
  250. $result = OrderService::qrcodePay($params);
  251. $result = json_encode($result);
  252. $params['pay_json_response'] = $result;
  253. $result = json_decode($result, true);
  254. $prefix = substr($params['qrcode_nbr'], 0, 2);
  255. if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
  256. $params['pay_category'] = 'WXPAY';
  257. if ((!isset($result['return_code']) || $result['return_code'] != 'SUCCESS') || (!isset($result['result_code']) || $result['result_code'] != 'SUCCESS') || (empty($result['trade_state']) || $result['trade_state'] != 'SUCCESS')) {
  258. $params['order_status_system'] = 'PAYING';
  259. $params['order_status_payment'] = 'PENDING';
  260. $params['order_is_complete'] = 'N';
  261. } else {
  262. $params['order_status_system'] = $systemStatus;
  263. $params['order_status_payment'] = 'SUCCESS';
  264. }
  265. } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
  266. $params['pay_category'] = 'ALIPAY';
  267. if ((!isset($result['code']) || $result['code'] != '10000') || (empty($result['trade_status']) || $result['trade_status'] != 'TRADE_SUCCESS')) {
  268. $params['order_status_system'] = 'PAYING';
  269. $params['order_status_payment'] = 'PENDING';
  270. $params['order_is_complete'] = 'N';
  271. } else {
  272. $params['order_status_system'] = $systemStatus;
  273. $params['order_status_payment'] = 'SUCCESS';
  274. }
  275. } else {
  276. throw new BusinessException('付款码无效');
  277. }
  278. }
  279. if (empty($paidOrder)) {
  280. // 写入主订单
  281. $this->insertMain($params);
  282. // 订单详情
  283. $this->insertSheet($params);
  284. } else {
  285. $params['orderGroupId'] = $paidOrder->order_groupby;
  286. if ($params['order_status_payment'] == 'SUCCESS') {
  287. $params['order_amount_paid'] = $paidOrder->order_amount_paid;
  288. $paidOrder->order_amount_paid = $paidOrder->order_amount_paid + $params['order_amount_pay'];
  289. $paidOrder->order_amount_pay = $paidOrder->order_amount_paid;
  290. if (floatval($paidOrder->order_amount_paid) >= $paidOrder->order_amount_total) {
  291. $paidOrder->order_is_complete = 'Y';
  292. $paidOrder->order_status_system = 'DONE';
  293. $paidOrder->order_status_payment = 'SUCCESS';
  294. // 更新sheet
  295. OrderSheet::where('join_sheet_order_id', $paidOrder->order_id)->update(['order_sheet_status' => 'DONE']);
  296. }
  297. }
  298. $paidOrder->save();
  299. // 清除此订单的未支付记录
  300. PayDetail::whereJsonContains('join_pay_object_json->order_id', $paidOrder->order_id)->where('pay_status', 'WAITING')->delete();
  301. }
  302. // 支付记录
  303. $this->insertPayDetail($params);
  304. Db::commit();
  305. // 分期付完
  306. if ($params['goods_classify'] == 'PARTNER' && $params['order_status_payment'] == 'SUCCESS' && (!empty($paidOrder) && floatval($paidOrder->order_amount_paid) >= $paidOrder->order_amount_total || floatval($params['order_amount_pay']) >= $params['order_amount_total'])) {
  307. $params['member_id'] = $params['join_order_member_id'];
  308. Event::dispatch('order.partner.grant', $params);
  309. }
  310. if ($params['settlement_now'] == 'Y' && $params['order_status_payment'] != 'SUCCESS') {
  311. _syslog("订单", "支付异常,检查是否有轮询");
  312. return json_throw(2001, '支付异常', ['order_id' => $params['orderId'], 'group_id' => $params['orderGroupId']]);
  313. }
  314. _syslog("订单", "创建订单成功");
  315. return json_success('创建订单成功');
  316. } catch (BusinessException $e) {
  317. Db::rollBack();
  318. dump($e->getMessage());
  319. dump($e->getTrace());
  320. _syslog("订单", $e->getMessage());
  321. return json_fail($e->getMessage());
  322. } catch (\Exception $e) {
  323. Db::rollBack();
  324. dump($e->getMessage());
  325. dump($e->getTrace());
  326. _syslog("订单", "创建订单失败");
  327. return json_fail('创建订单失败');
  328. }
  329. }
  330. /**
  331. * @Desc 支付
  332. * @Author Gorden
  333. * @Date 2024/9/5 13:12
  334. *
  335. * @param Request $request
  336. * @return Response
  337. */
  338. public function pay(Request $request)
  339. {
  340. $params = $request->post();
  341. // 验证线下付款密码
  342. if ($params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['OFFLINE', 'MONEY'])) {
  343. $password = $params['offline_password'];
  344. if ($password != '666888') {
  345. return json_fail("密码错误,请重新输入");
  346. }
  347. }
  348. $order = Order::where('order_id', $params['order_id'])->first();
  349. if (!$order) {
  350. return json_fail('订单异常');
  351. }
  352. if ($order->order_status_system != 'PAYING') {
  353. return json_fail('订单不是可支付状态');
  354. }
  355. $params['orderId'] = $params['order_id'];
  356. $params['orderGroupId'] = 'OD' . date('ymdHi') . random_string(4, 'up');
  357. $order->order_groupby = $params['orderGroupId'];
  358. $goods = Goods::where('goods_id', $params['join_sheet_goods_id'])
  359. ->select('goods_id', 'goods_name', 'goods_classify')
  360. ->first();
  361. if (!$goods) {
  362. return json_fail('产品数据异常');
  363. }
  364. $goods = $goods->toArray();
  365. $params['goods_classify'] = $goods['goods_classify'] ?? '';
  366. // 立即结算
  367. if ($params['goods_classify'] == 'PARTNER') {
  368. $order->order_is_complete = 'Y';
  369. $systemStatus = 'DONE';
  370. }
  371. $paymentStatus = 'PENDING';
  372. Db::beginTransaction();
  373. try {
  374. // 组合支付时,付款码应收金额
  375. $qrcodePayAmount = 0;
  376. if ($params['pay_category'] == 'OFFLINE' || $params['pay_category'] == 'MONEY') {
  377. $order->order_status_system = $systemStatus;
  378. $order->order_status_payment = 'SUCCESS';
  379. $paymentStatus = 'SUCCESS';
  380. if ($params['pay_category'] == 'OFFLINE' && !empty($params['pay_category_sub'])) {
  381. $params['pay_category'] = $params['pay_category_sub'];
  382. }
  383. }
  384. if (($params['pay_constitute'] == 'Y' || $params['pay_category'] == 'QRCODE') && !empty($params['qrcode_nbr'])) { // 付款码
  385. // 提交过来的支付分类
  386. $submitPayCategory = $params['pay_category'];
  387. // 账户支付的金额
  388. $accountAmount = $params['order_amount_pay'];
  389. if ($params['pay_constitute'] == 'Y' && $qrcodePayAmount > 0) {
  390. // 组合支付,改成需要付款码需要支付的金额
  391. $params['order_amount_pay'] = $qrcodePayAmount;
  392. }
  393. // 去支付
  394. $result = OrderService::qrcodePay($params);
  395. $result = json_encode($result);
  396. $params['pay_json_response'] = $result;
  397. $result = json_decode($result, true);
  398. $prefix = substr($params['qrcode_nbr'], 0, 2);
  399. if (in_array($prefix, [10, 11, 12, 13, 14, 15])) {
  400. $params['pay_category'] = 'WXPAY';
  401. if ((!isset($result['return_code']) || $result['return_code'] != 'SUCCESS') || (!isset($result['result_code']) || $result['result_code'] != 'SUCCESS') || (empty($result['trade_state']) || $result['trade_state'] != 'SUCCESS')) {
  402. $order->order_status_system = 'PAYING';
  403. $order->order_status_payment = 'PENDING';
  404. $order->order_is_complete = 'N';
  405. // Db::rollBack();
  406. // return json_fail('支付失败');
  407. } else {
  408. $order->order_status_system = $systemStatus;
  409. $order->order_status_payment = 'SUCCESS';
  410. $paymentStatus = 'SUCCESS';
  411. }
  412. } else if (in_array($prefix, [25, 26, 27, 28, 29, 30])) {
  413. $params['pay_category'] = 'ALIPAY';
  414. if ((!isset($result['code']) || $result['code'] != '10000') || (empty($result['trade_status']) || $result['trade_status'] != 'TRADE_SUCCESS')) {
  415. $order->order_status_system = 'PAYING';
  416. $order->order_status_payment = 'PENDING';
  417. $order->order_is_complete = 'N';
  418. // Db::rollBack();
  419. // return json_fail('支付失败');
  420. } else {
  421. $order->order_status_system = $systemStatus;
  422. $order->order_status_payment = 'SUCCESS';
  423. $paymentStatus = 'SUCCESS';
  424. }
  425. } else {
  426. throw new BusinessException('付款码无效');
  427. }
  428. // 账户支付的金额
  429. $params['order_amount_pay'] = $accountAmount;
  430. }
  431. if ($order->order_status_payment == 'SUCCESS') {
  432. $order->order_amount_paid = $order->order_amount_paid + $params['order_amount_pay'];
  433. $order->order_amount_pay = $order->order_amount_paid;
  434. }
  435. // 分期,支付完就结束了
  436. if ($order->order_status_payment == 'SUCCESS' && $params['goods_classify'] == 'PARTNER' && floatval($order->order_amount_paid) >= $order->order_amount_total) {
  437. $order->order_is_complete = 'Y';
  438. }
  439. if (floatval($order->order_amount_paid) < $order->order_amount_total) {
  440. $order->order_status_system = 'PAYING';
  441. $order->order_status_payment = 'PENDING';
  442. $order->order_is_complete = 'N';
  443. }
  444. // 主订单
  445. $order->save();
  446. // sheet
  447. if ($order->order_status_payment == 'SUCCESS') {
  448. $data = [
  449. 'order_sheet_status' => $systemStatus
  450. ];
  451. if (floatval($order->order_amount_paid) < $order->order_amount_total) {
  452. $data['order_sheet_status'] = 'BEING';
  453. }
  454. OrderSheet::where('join_sheet_order_id', $params['order_id'])->update($data);
  455. }
  456. // payDetail
  457. $payData = [
  458. 'pay_amount' => $params['order_amount_pay']
  459. ];
  460. if ($paymentStatus == 'SUCCESS') {
  461. $payData['pay_paytimes'] = date('Y-m-d H:i:s');
  462. $payData['pay_status'] = 'SUCCESS';
  463. }
  464. if ($params['pay_constitute'] == 'N' && in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
  465. $payData['pay_prepayid'] = $params['pay_category'];
  466. $payData['pay_json_response'] = $params['pay_json_response'];
  467. } else if ($params['pay_category'] == 'CASH') {
  468. $payData['pay_prepayid'] = $params['join_order_member_id'] . '-CASH';
  469. } else if ($params['pay_category'] == 'WELFARE') {
  470. $payData['pay_prepayid'] = $params['join_order_member_id'] . '-WELFARE';
  471. } else if ($params['pay_category'] == 'CARD') {
  472. $payData['pay_prepayid'] = $params['card_nbr'];
  473. } else if ($params['pay_category'] == 'OFFLINE') {
  474. $payData['pay_prepayid'] = 'OFFLINE';
  475. } else if ($params['pay_category'] == 'OFFLINE_ALIPAY') {
  476. $payData['pay_prepayid'] = 'OFFLINE_ALIPAY';
  477. } else if ($params['pay_category'] == 'OFFLINE_WXPAY') {
  478. $payData['pay_prepayid'] = 'OFFLINE_WXPAY';
  479. } else if ($params['pay_category'] == 'MONEY') {
  480. $payData['pay_prepayid'] = 'MONEY';
  481. }
  482. // 清除此订单的未支付记录
  483. PayDetail::whereJsonContains('join_pay_object_json->order_id', $order->order_id)->where('pay_status', 'WAITING')->delete();
  484. $payData['join_pay_member_id'] = $params['join_order_member_id'];
  485. $payData['join_pay_order_id'] = $order->order_groupby;
  486. $payData['pay_status'] = !empty($payData['pay_status']) && $payData['pay_status'] == 'SUCCESS' ? $payData['pay_status'] : 'WAITING';
  487. $payData['pay_category'] = $params['goods_classify'] ?? '';
  488. $payData['pay_paytimes'] = date('Y-m-d H:i:s');
  489. $payData['pay_json_request'] = json_encode($params); // {"pay-result": "支付成功", "result-datetime": "2024-07-29 18:38:21"}
  490. $payData['pay_json_response'] = !empty($payData['pay_status']) && $payData['pay_status'] == 'SUCCESS' ? json_encode([
  491. 'pay-result' => '支付成功', 'result-datetime' => date('Y-m-d H:i:s')
  492. ]) : '[]';
  493. $payData['join_pay_object_json'] = !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]';
  494. $payData['pay_addtimes'] = time();
  495. PayDetail::insert($payData);
  496. Db::commit();
  497. // 分期付款完成
  498. if ($params['goods_classify'] == 'PARTNER' && $order->order_status_payment == 'SUCCESS' && floatval($order->order_amount_paid) >= $order->order_amount_total) {
  499. $params['member_id'] = $params['join_order_member_id'];
  500. Event::dispatch('order.complete', $params);
  501. Event::dispatch('order.partner.grant', $params);
  502. }
  503. if ($order->order_status_payment != 'SUCCESS' && $paymentStatus != 'SUCCESS') {
  504. _syslog("订单", "支付异常,检查是否有轮询");
  505. return json_throw(2001, '支付异常', ['order_id' => $params['orderId'], 'group_id' => $params['orderGroupId']]);
  506. }
  507. _syslog("订单", "订单支付成功");
  508. return json_success('支付成功');
  509. } catch (BusinessException $e) {
  510. dump($e->getMessage());
  511. Db::rollBack();
  512. _syslog("订单", "订单支付失败:" . $e->getMessage());
  513. return json_fail("支付失败:" . $e->getMessage());
  514. } catch (\Exception $e) {
  515. dump($e->getMessage());
  516. Db::rollBack();
  517. _syslog("订单", "订单支付失败");
  518. return json_fail('支付失败');
  519. }
  520. }
  521. /**
  522. * @Desc
  523. * @Author Gorden
  524. * @Date 2024/6/7 10:30
  525. *
  526. * @param $params
  527. * @return void
  528. * @throws BusinessException
  529. */
  530. public function insertMain($params)
  531. {
  532. try {
  533. $orderCategory = 'NORMAL';
  534. if (!empty($params['order_category'])) {
  535. $orderCategory = $params['order_category'];
  536. } else if (isset($params['submit_goods_classify']) && $params['submit_goods_classify'] == 'MEALS') {
  537. $orderCategory = 'DISHES';
  538. } else if (isset($params['goods_classify'])) {
  539. $orderCategory = $params['goods_classify'];
  540. }
  541. if (empty($params['order_extend_json'])) {
  542. $params['order_extend_json'] = [];
  543. } else {
  544. if (is_json($params['order_extend_json'])) {
  545. $params['order_extend_json'] = json_decode($params['order_extend_json'], true);
  546. }
  547. }
  548. // 推荐人
  549. $params['order_extend_json']['referee'] = $params['referee'] ?? '';
  550. $data = [
  551. 'order_id' => $params['orderId'],
  552. 'order_groupby' => $params['orderGroupId'],
  553. 'join_order_member_id' => $params['join_order_member_id'],
  554. 'order_name' => date('Y-m-d H:i:s') . '-订单',
  555. 'order_amount_total' => $params['order_amount_total'],
  556. 'order_amount_pay' => $params['order_status_payment'] == 'SUCCESS' ? $params['order_amount_pay'] : 0,
  557. 'order_amount_paid' => $params['order_status_payment'] == 'SUCCESS' ? $params['order_amount_pay'] : 0,
  558. 'order_category' => $orderCategory,
  559. 'order_classify' => $orderCategory,
  560. 'order_is_complete' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'Y' : 'N',
  561. 'order_status_system' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'DONE' : 'PAYING',
  562. 'order_status_payment' => floatval($params['order_amount_pay']) >= floatval($params['order_amount_total']) && $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'PENDING',
  563. 'order_status_storage' => $params['order_status_storage'],
  564. 'order_platform' => $params['order_platform'],
  565. 'order_remark' => $params['order_remark'] ?? '',
  566. 'order_discount_json' => $params['order_discount_json'] ?? '[]',
  567. 'order_config_json' => $params['order_config_json'] ?? '[]',
  568. 'order_express_json' => $params['order_express_json'] ?? '[]',
  569. 'order_extend_json' => $params['order_extend_json'] ? json_encode($params['order_extend_json']) : '[]',
  570. 'order_addtimes' => time()
  571. ];
  572. Order::insert($data);
  573. } catch (\Exception $e) {
  574. dump($e->getMessage());
  575. throw new BusinessException('订单创建信息失败');
  576. }
  577. }
  578. /**
  579. * @Desc
  580. * @Author Gorden
  581. * @Date 2024/6/7 10:25
  582. *
  583. * @param $params
  584. * @return void
  585. * @throws BusinessException
  586. */
  587. public function insertSheet($params)
  588. {
  589. try {
  590. $orderSheetIds = [];
  591. foreach ($params['goodsContentList'] as $goods) {
  592. //{"unit": "份", "table": null, "premises": "15"}
  593. $price = floatval($goods['goods_sales_price']);
  594. $extendJson['unit'] = $goods['sku_name'];
  595. if (isset($params['submit_premises_id'])) {
  596. $extendJson['premises'] = $params['submit_premises_id'];
  597. }
  598. if (isset($params['submit_goods_classify']) && $params['submit_goods_classify'] == 'MEALS') {
  599. $extendJson['table'] = null;
  600. }
  601. $orderSheetStatus = 'PAYING';
  602. if ($params['settlement_now'] == 'Y' && $params['order_status_payment'] == 'SUCCESS') {
  603. if (floatval($params['order_amount_pay']) >= floatval($params['order_amount_total'])) {
  604. $orderSheetStatus = 'DONE';
  605. } else {
  606. $orderSheetStatus = 'BEING';
  607. }
  608. }
  609. $data = [
  610. 'join_sheet_member_id' => $params['join_order_member_id'],
  611. 'join_sheet_order_id' => $params['orderId'],
  612. 'join_sheet_goods_id' => $goods['goods_id'],
  613. 'join_sheet_goods_sku_id' => $goods['sku_id'],
  614. 'order_sheet_status' => $orderSheetStatus,
  615. 'order_sheet_category' => 'PARTNER',
  616. 'order_sheet_num' => $goods['nbr'],
  617. 'order_sheet_price' => $goods['goods_sales_price'],
  618. 'order_sheet_amount' => $price * $goods['nbr'],
  619. 'order_sheet_pay' => $price * $goods['nbr'],
  620. 'order_sheet_task_status' => 'NONE',
  621. 'order_sheet_remark' => $params['order_remark'] ?? '',
  622. 'order_sheet_addtimes' => time(),
  623. 'order_sheet_extend_json' => json_encode($extendJson)
  624. ];
  625. $orderSheetId = OrderSheet::insertGetId($data);
  626. $orderSheetIds[] = $orderSheetId;
  627. // 减库存,规格和总库存
  628. if (!isset($params['submit_goods_classify']) || !in_array($params['submit_goods_classify'], ['MEALS', 'PACKAGE'])) {
  629. $goodsSku = GoodsSku::where('goods_sku_id', $goods['sku_id'])->first();
  630. $skuStorageJson = json_decode($goodsSku->goods_sku_storage_json, true);
  631. if (isset($skuStorageJson['storage']) && !empty($skuStorageJson['storage'])) {
  632. $skuStorageJson['storage'] = $skuStorageJson['storage'] - $goods['nbr'];
  633. }
  634. if (!isset($skuStorageJson['storage']) || (!empty($skuStorageJson['storage']) && $skuStorageJson['storage'] < 0)) {
  635. throw new BusinessException('库存不足');
  636. }
  637. $goodsSku->goods_sku_storage_json = json_encode($skuStorageJson);
  638. $goodsSku->save();
  639. }
  640. $goodsRunning = GoodsRunning::where('join_running_goods_id', $goods['goods_id'])->first();
  641. $goodsRunning->goods_running_storage = $goodsRunning->goods_running_storage - $goods['nbr'];
  642. if ($goodsRunning->goods_running_storage < 0) {
  643. throw new BusinessException('库存不足');
  644. }
  645. $goodsRunning->goods_running_sale = $goodsRunning->goods_running_sale + $goods['nbr'];
  646. $goodsRunning->save();
  647. }
  648. return $orderSheetIds;
  649. } catch (\support\exception\BusinessException $e) {
  650. dump($e->getMessage() . '||' . $e->getLine());
  651. throw new BusinessException($e->getMessage());
  652. } catch (\Exception $e) {
  653. dump($e->getMessage() . '||' . $e->getLine());
  654. throw new BusinessException('订单创建失败');
  655. }
  656. }
  657. /**
  658. * @Desc
  659. * @Author Gorden
  660. * @Date 2024/6/7 10:35
  661. *
  662. * @param $params
  663. * @return void
  664. * @throws BusinessException
  665. */
  666. public function insertPayDetail($params)
  667. {
  668. try {
  669. if (in_array($params['pay_category'], ['WXPAY', 'ALIPAY'])) {
  670. $payPrepayid = $params['pay_category'];
  671. } else if ($params['pay_category'] == 'OFFLINE') {
  672. $payPrepayid = 'OFFLINE';
  673. } else if ($params['pay_category'] == 'OFFLINE_ALIPAY') {
  674. $payPrepayid = 'OFFLINE_ALIPAY';
  675. } else if ($params['pay_category'] == 'OFFLINE_WXPAY') {
  676. $payPrepayid = 'OFFLINE_WXPAY';
  677. } else if ($params['pay_category'] == 'MONEY') {
  678. $payPrepayid = 'MONEY';
  679. } else {
  680. $payPrepayid = $params['join_order_member_id'] . '-' . $params['pay_category'];
  681. }
  682. $data = [
  683. 'join_pay_member_id' => $params['join_order_member_id'],
  684. 'join_pay_order_id' => $params['orderGroupId'],
  685. 'pay_status' => $params['settlement_now'] == 'Y' && $params['order_status_payment'] == 'SUCCESS' ? 'SUCCESS' : 'WAITING',
  686. 'pay_category' => $params['goods_classify'],
  687. 'pay_amount' => $params['order_amount_pay'],
  688. 'pay_prepayid' => $payPrepayid,
  689. 'pay_paytimes' => date('Y-m-d H:i:s'),
  690. 'join_pay_object_json' => !empty($params['orderId']) ? json_encode(['order_id' => $params['orderId']]) : '[]',
  691. 'pay_json_request' => json_encode($params),
  692. 'pay_json_response' => $params['pay_json_response'] ?? '[]',
  693. 'pay_remark' => $params['order_remark'] ?? '',
  694. 'pay_addtimes' => time(),
  695. ];
  696. PayDetail::insert($data);
  697. } catch (\Exception $e) {
  698. dump($e->getMessage());
  699. throw new BusinessException('创建支付记录失败');
  700. }
  701. }
  702. /**
  703. * @Desc 订单商品详情
  704. * @Author Gorden
  705. * @Date 2024/3/29 8:50
  706. *
  707. * @param Request $request
  708. * @return Response
  709. */
  710. public function sheet(Request $request)
  711. {
  712. try {
  713. $orderId = $request->get('order_id');
  714. $orderSheet = OrderSheet::with([
  715. 'member' => function ($query) {
  716. $query->select('member_id', 'member_mobile', 'member_is_owner', 'join_member_role_id');
  717. },
  718. 'goods' => function ($query) {
  719. $query->select('goods_id', 'goods_name', 'goods_cover', 'goods_market_price', 'goods_sales_price', 'goods_classify', 'goods_if_express');
  720. },
  721. 'memberInfo',
  722. 'cert',
  723. 'sku' => function ($query) {
  724. $query->where('goods_sku_status', 'ON')
  725. ->select('goods_sku_id', 'join_sku_goods_id', 'goods_sku_specs_json', 'goods_sku_sales_price');
  726. },
  727. 'skus',
  728. 'refund' => function ($query) {
  729. $query->select('join_return_order_id', 'order_return_status');
  730. }
  731. ])->where('join_sheet_order_id', $orderId)
  732. ->orderBy('order_sheet_id', 'DESC')
  733. ->get()
  734. ->toArray();
  735. $order = Order::where('order_id', $orderId)->first();
  736. $express = OrderExpress::where('join_express_order_id', $orderId)->first();
  737. $premises = '';
  738. if ($express && $express->order_express_type == '自提') {
  739. $premises = $express->order_express_company;
  740. }
  741. $sheetAmount = 0;
  742. foreach ($orderSheet as &$item) {
  743. $sheetAmount += $item['order_sheet_amount'];
  744. $item['goods']['goods_cover'] = getenv('STORAGE_DOMAIN') . $item['goods']['goods_cover'];
  745. if (!empty($item['goods']) && $item['goods']['goods_classify'] == 'PACKAGE') {
  746. $components = GoodsComponent::with('goods')
  747. ->where('join_component_master_goods_id', $item['goods']['goods_id'])
  748. ->select('join_component_master_goods_id', 'join_component_goods_id', 'goods_component_price',
  749. 'goods_component_price', 'goods_component_json')
  750. ->get()
  751. ->toArray();
  752. $goodsArr = [];
  753. foreach ($components as $component) {
  754. $configJson = !empty($component['goods_component_json']) ? json_decode($component['goods_component_json'], true) : [];
  755. if (!empty($component['goods'])) {
  756. $supplierName = Supplier::where('supplier_id', $component['goods']['join_goods_supplier_id'])->value('supplier_name');
  757. $benefit = MemberBenefit::where('join_benefit_member_id', $item['join_sheet_member_id'])
  758. ->where('join_benefit_goods_id', $component['goods']['goods_id'])
  759. ->where('join_benefit_order_id', $orderId)
  760. ->first();
  761. $goodsArr[] = [
  762. 'goods_name' => $component['goods']['goods_name'],
  763. 'goods_cover' => getenv('STORAGE_DOMAIN') . $component['goods']['goods_cover'],
  764. 'supplier_name' => $supplierName,
  765. 'nbr' => $configJson['nbr'] ?? 0,
  766. 'used' => !empty($benefit->member_benefit_used_count) ? intval($benefit->member_benefit_used_count) : ''
  767. ];
  768. }
  769. }
  770. $item['goods']['components'] = $goodsArr;
  771. }
  772. if (!empty($item['sku'])) {
  773. if (!empty($item['sku']['goods_sku_specs_json'])) {
  774. $specsJson = json_decode($item['sku']['goods_sku_specs_json'], true);
  775. $skuName = '';
  776. foreach ($specsJson as $specsKey => $skuSpecs) {
  777. if (is_array($skuSpecs)) {
  778. $skuName = $skuName . ' ' . implode(' ', $skuSpecs) . ';';
  779. } else {
  780. $skuName = $skuName . ' ' . $skuSpecs . ';';
  781. }
  782. }
  783. $item['sku']['goods_sku_title'] = rtrim($skuName, ';');
  784. }
  785. }
  786. if (!empty($item['skus'])) {
  787. foreach ($item['skus'] as $key => $skus) {
  788. if (!empty($skus['goods_sku_specs_json'])) {
  789. $item['skus'][$key]['goods_sku_specs_json'] = json_decode($skus['goods_sku_specs_json']);
  790. $skuName = '';
  791. foreach ($item['skus'][$key]['goods_sku_specs_json'] as $specsKey => $skuSpecs) {
  792. $keyStr = ($specsKey == '规格') ? '' : ($specsKey . ':');
  793. if (is_array($skuSpecs)) {
  794. $skuName = $skuName . $keyStr . ' ' . implode(' ', $skuSpecs) . '; ';
  795. } else {
  796. $skuName = $skuName . $keyStr . ' ' . $skuSpecs . '; ';
  797. }
  798. }
  799. $item['skus'][$key]['sku_name'] = rtrim($skuName, '; ');
  800. }
  801. }
  802. } else {
  803. $item['skus'] = [];
  804. }
  805. if (in_array($item['goods']['goods_classify'], ['SERVICE', 'CHNMED', 'CHNNCD', 'PACKAGE']) && $order->order_status_system == 'DONE') {
  806. $item['appontment'] = [];
  807. $appontments = Appointment::where('join_appointment_order_id', $orderId)
  808. ->where('appointment_status', 'DONE')
  809. ->select('appointment_status', 'appointment_id', 'appointment_done_datetime', 'appointment_done_json', 'appointment_apply_json')
  810. ->get()
  811. ->toArray();
  812. foreach ($appontments as $appontment) {
  813. $doneJson = [];
  814. $username = '';
  815. if (!empty($appontment['appointment_done_json'])) {
  816. $doneJson = json_decode($appontment['appointment_done_json'], true);
  817. if (isset($doneJson['charge'])) {
  818. $username = SysUser::where('user_id', $doneJson['charge']['charge_user_id'])->value('user_name');
  819. }
  820. }
  821. $person = 1;
  822. if (!empty($appontment->appointment_apply_json)) {
  823. $applyJson = json_decode($appontment->appointment_apply_json, true);
  824. if (isset($applyJson['person'])) {
  825. $person = $applyJson['person'];
  826. }
  827. }
  828. $item['appontment'][] = [
  829. 'member' => ($item['cert'] ? $item['cert']['member_cert_name'] . '-' : '') . ($item['member'] ? $item['member']['member_mobile'] : ''),
  830. 'goods_name' => $item['goods']['goods_name'],
  831. 'premisses' => isset($doneJson['charge']) ? $doneJson['charge']['charge_premises'] : '',
  832. 'username' => $username,
  833. 'nbr' => $person,
  834. 'done_time' => $appontment['appointment_done_datetime'],
  835. 'appointment_status' => $appontment['appointment_status'],
  836. ];
  837. }
  838. }
  839. if (!empty($item['order_sheet_extend_json']) && !$express) {
  840. $extendJson = json_decode($item['order_sheet_extend_json'], true);
  841. if (isset($extendJson['address_id'])) {
  842. $address = ClientConfig::where('client_config_id', $extendJson['address_id'])->first();
  843. if (!empty($address)) {
  844. $valJson = json_decode($address->client_config_val_json, true);
  845. $express = [
  846. 'order_express_address' => $valJson['address'] . ($valJson['numbers'] ?? ''),
  847. 'order_express_city' => $valJson['city'],
  848. 'order_express_mobile' => $valJson['mobile'],
  849. 'order_express_person' => $valJson['person']
  850. ];
  851. }
  852. }
  853. }
  854. $item['member']['level'] = '普通会员';
  855. if (!empty($item['member']['join_member_role_id'])) {
  856. $item['member']['level'] = MemberRole::where('member_role_id', $item['member']['join_member_role_id'])->value('member_role_name');
  857. }
  858. if (!empty($item['member_info'])) {
  859. if (empty($item['member_info']['member_info_headimg']) || substr($item['member_info']['member_info_headimg'], 0, 1) == '.') {
  860. $item['member_info']['member_info_headimg'] = "https://img.wanyuewellness.com.cn/images/avatar_default.png";
  861. }
  862. }
  863. }
  864. $order->sheet_amount = number_format($sheetAmount, 2);
  865. $payDetails = PayDetail::whereJsonContains('join_pay_object_json->order_id', $order->order_id)
  866. ->where('pay_category', 'PARTNER')
  867. ->where('pay_status', 'SUCCESS')
  868. ->select('pay_id', 'pay_category', 'pay_prepayid', 'pay_paytimes', 'pay_status', 'pay_amount', 'pay_extend_json')
  869. ->orderBy('pay_addtimes', 'DESC')
  870. ->get();
  871. $order->pay_amount_total = 0;
  872. foreach ($payDetails as &$payDetail) {
  873. $categoryArray = explode('-', $payDetail->pay_prepayid);
  874. if (isset($categoryArray[1])) {
  875. $payDetail->pay_category = $categoryArray[1];
  876. } else if (in_array($categoryArray[0], ['WXPAY', 'ALIPAY', 'OFFLINE', 'OFFLINE_ALIPAY', 'OFFLINE_WXPAY', 'MONEY'])) {
  877. $payDetail->pay_category = $categoryArray[0];
  878. }
  879. if (!empty($payDetail->pay_extend_json)) {
  880. $payExtendJson = json_decode($payDetail->pay_extend_json, true);
  881. $order->cancel_times = $payExtendJson['cancel_times'] ?? '';
  882. if (isset($payExtendJson['ticket'])) {
  883. $payDetail->ticket = str_replace('/thumb', '', getenv("STORAGE_DOMAIN") . $payExtendJson['ticket']);
  884. }
  885. }
  886. $order->pay_amount_total += $payDetail->pay_amount;
  887. }
  888. $refund = OrderReturn::where('join_return_order_id', $orderId)
  889. ->select('order_return_status', 'order_return_apply_datetime', 'order_return_apply_json', 'order_return_accept_datetime', 'order_return_refund_json', 'order_return_extend_json')
  890. ->first();
  891. if (!empty($refund->order_return_refund_json)) {
  892. $returnRefundJson = json_decode($refund->order_return_refund_json, true);
  893. if (isset($returnRefundJson['user_id'])) {
  894. $userName = SysUser::where('user_id', $returnRefundJson['user_id'])->value('user_name');
  895. $returnRefundJson['person'] = $userName;
  896. unset($returnRefundJson['user_id']);
  897. }
  898. $refund->order_return_refund_json = json_encode($returnRefundJson);
  899. }
  900. if (!empty($order->order_config_json)) {
  901. $orderConfigJson = json_decode($order->order_config_json, true);
  902. if (isset($orderConfigJson['reach'])) {
  903. $order->reach = $orderConfigJson['reach'];
  904. }
  905. if (isset($orderConfigJson['table'])) {
  906. $order->table = $orderConfigJson['table'];
  907. }
  908. if (isset($orderConfigJson['eat'])) {
  909. $order->eat = $orderConfigJson['eat'];
  910. }
  911. if (isset($orderConfigJson['express'])) {
  912. $order->express = $orderConfigJson['express'];
  913. }
  914. if (isset($orderConfigJson['premises'])) {
  915. $order->premises = $orderConfigJson['premises'];
  916. }
  917. if (isset($orderConfigJson['tableid'])) {
  918. $order->dept_table_id = $orderConfigJson['tableid'];
  919. }
  920. }
  921. if (!empty($order->order_extend_json)) {
  922. $orderExtendJson = json_decode($order->order_extend_json, true);
  923. $order->referee = $orderExtendJson['referee'] ?? '';
  924. if (isset($orderExtendJson['cancel_times'])) {
  925. $order->cancel_times = $orderExtendJson['cancel_times'];
  926. }
  927. if (isset($orderExtendJson['free_remark'])) {
  928. $order->free_remark = $orderExtendJson['free_remark'];
  929. }
  930. }
  931. $discount = ['coupon_name' => '', 'classify' => '', 'value' => 0];
  932. if (!empty($order->order_discount_json)) {
  933. $orderDiscountJson = json_decode($order->order_discount_json, true);
  934. foreach ($orderDiscountJson as $discountItem) {
  935. if (!empty($discountItem['coupon_id'])) {
  936. $coupon = Coupon::where('coupon_id', $discountItem['coupon_id'])
  937. ->select('coupon_name', 'coupon_classify', 'coupon_category', 'coupon_value', 'coupon_minimum_limit')
  938. ->first();
  939. if (!$coupon) {
  940. continue;
  941. }
  942. $classify = CouponService::couponClassifyInfo($coupon->coupon_classify, $coupon->coupon_category, $coupon->coupon_value, $coupon->coupon_minimum_limit);
  943. $discount['coupon_name'] .= $coupon->coupon_classify . ':' . $coupon->coupon_name . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  944. }
  945. if ($discountItem['coupon_classify'] == '退款') {
  946. continue;
  947. }
  948. if (empty($discountItem['coupon_id']) && !empty($discountItem['coupon_classify'])) {
  949. if (!empty($discountItem['coupon_detail_id'])) {
  950. $discount['classify'] .= $discountItem['coupon_detail_id'][0] . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  951. } else {
  952. $discount['classify'] .= $discountItem['coupon_classify'] . '(优惠¥' . sprintf("%.2f", $discountItem['coupon_value']) . '), ';
  953. }
  954. }
  955. if (!empty($discountItem['coupon_value'])) {
  956. $discount['value'] += $discountItem['coupon_value'];
  957. }
  958. }
  959. if (!empty($discount['coupon_name'])) {
  960. $discount['coupon_name'] = rtrim($discount['coupon_name'], ', ');
  961. }
  962. if (!empty($discount['classify'])) {
  963. $discount['classify'] = rtrim($discount['classify'], ', ');
  964. }
  965. }
  966. $discount['value'] = sprintf("%.2f", $discount['value']);
  967. $order->discount = $discount;
  968. $order->premises = $order->premises ?? $premises;
  969. $data = [
  970. 'order' => $order,
  971. 'refund' => json_decode(json_encode($refund)),
  972. 'sheet' => json_decode(json_encode($orderSheet)),
  973. 'express' => json_decode(json_encode($express)),
  974. 'payDetails' => json_decode(json_encode($payDetails))
  975. ];
  976. return json_success('', $data);
  977. } catch (\Exception $e) {
  978. dump($e->getMessage());
  979. }
  980. }
  981. /**
  982. * @Desc 获取分期的订单
  983. * @Author Gorden
  984. * @Date 2024/9/10 15:14
  985. *
  986. * @param Request $request
  987. * @return Response
  988. */
  989. public function getPaidOrder(Request $request)
  990. {
  991. $memberId = $request->get('member_id');
  992. if (!$memberId) {
  993. return json_fail('参数异常');
  994. }
  995. $order = Order::where('join_order_member_id', $memberId)
  996. ->where('order_category', 'PARTNER')
  997. ->where('order_status_system', 'PAYING')
  998. ->select('order_id', 'order_amount_total', 'order_amount_paid', 'order_amount_pay')
  999. ->first();
  1000. return json_success('', $order);
  1001. }
  1002. /**
  1003. * @Desc 上传支付凭证
  1004. * @Author Gorden
  1005. * @Date 2024/9/12 10:14
  1006. *
  1007. * @param Request $request
  1008. * @return Response
  1009. */
  1010. public function uploadTicket(Request $request)
  1011. {
  1012. $payId = $request->post('pay_id');
  1013. $url = $request->post('url');
  1014. if (!$payId || !$url) {
  1015. return json_fail("参数异常");
  1016. }
  1017. $url = str_replace(getenv("STORAGE_DOMAIN"), '', $url);
  1018. try {
  1019. $payDetail = PayDetail::where('pay_id', $payId)->first();
  1020. if (!$payDetail) {
  1021. return json_fail('数据异常');
  1022. }
  1023. $extendJson = [];
  1024. if (!empty($payDetail->pay_extend_json)) {
  1025. $extendJson = json_decode($payDetail->pay_extend_json, true);
  1026. }
  1027. $extendJson['ticket'] = $url;
  1028. $payDetail->pay_extend_json = json_encode($extendJson);
  1029. dump($payDetail->save());
  1030. return json_success('success');
  1031. } catch (\Exception $e) {
  1032. return json_fail("上传附件失败");
  1033. }
  1034. }
  1035. /**
  1036. * @Desc 查询订单状态
  1037. * @Author Gorden
  1038. * @Date 2024/8/19 11:55
  1039. *
  1040. * @param Request $request
  1041. * @return Response|void
  1042. */
  1043. public function getOrderPayStatus(Request $request)
  1044. {
  1045. $orderId = $request->get('order_id', '');
  1046. if (!$orderId) {
  1047. return json_fail('订单不存在');
  1048. }
  1049. $order = Order::where('order_id', $orderId)->first();
  1050. if (!$order) {
  1051. return json_fail('订单不存在');
  1052. }
  1053. $discountJson = [];
  1054. if (!empty($order->order_discount_json)) {
  1055. $discountJson = json_decode($order->order_discount_json, true);
  1056. }
  1057. if ($order->order_status_payment == 'SUCCESS') {
  1058. return json_success('success');
  1059. }
  1060. $payDetailType = PayDetail::where('join_pay_order_id', $order->order_groupby)->pluck('pay_prepayid')->toArray();
  1061. try {
  1062. Db::beginTransaction();
  1063. if (in_array('WXPAY', $payDetailType)) {
  1064. $result = Pay::wechat(config('payment.wxpay'))->find($order->order_groupby, 'pos');
  1065. $result = json_decode(json_encode($result), true);
  1066. // $result = '{"return_code":"SUCCESS","return_msg":"OK","result_code":"SUCCESS","mch_id":"1680393367","appid":"wxc6274da7198e3eb4","openid":"o3JAn6Ii_bAlxS-jbNEC4WnPhdwM","is_subscribe":"N","trade_type":"MICROPAY","trade_state":"SUCCESS","bank_type":"OTHERS","total_fee":"1000","fee_type":"CNY","cash_fee":"1000","cash_fee_type":"CNY","transaction_id":"4200067718202409250802875650","out_trade_no":"OD24092518408RV7","attach":[],"time_end":"20240925184009","trade_state_desc":"支付成功","nonce_str":"OeGOkjch4eaV5qIt","sign":"6DCB3BFC594EBC018A2BEE2C3DFEA4E3"}';
  1067. // $result = json_decode($result, true);
  1068. if (!empty($result['return_code']) && $result['return_code'] == 'SUCCESS' && !empty($result['result_code']) && $result['result_code'] == 'SUCCESS' && !empty($result['trade_state']) && $result['trade_state'] == 'SUCCESS') {
  1069. $order->order_status_payment = 'SUCCESS';
  1070. if (in_array($order->order_category, ['SERVICE', 'CHNMED', 'CHNNCD', 'PACKAGE'])) {
  1071. $order->order_status_system = 'WAITING';
  1072. } else if (in_array($order->order_category, ['DISHES', 'MEALS'])) {
  1073. $order->order_is_complete = 'Y';
  1074. $order->order_status_system = 'DONE';
  1075. } else if (in_array($order->order_category, ['VIP', 'PARTNER'])) {
  1076. $order->order_status_payment = 'PENDING';
  1077. $totalFee = $result['total_fee'] / 100;
  1078. if ($order->order_amount_paid + $totalFee >= $order->order_amount_total) {
  1079. $order->order_amount_paid = $order->order_amount_paid + $totalFee;
  1080. $order->order_status_payment = 'SUCCESS';
  1081. $order->order_status_system = 'DONE';
  1082. $order->order_is_complete = 'Y';
  1083. }
  1084. } else {
  1085. $order->order_status_system = 'SENDING';
  1086. }
  1087. $order->save();
  1088. // Sheet
  1089. if ($order->order_status_payment == 'SUCCESS') {
  1090. OrderSheet::where('join_sheet_order_id', $orderId)->where('order_sheet_status', 'PAYING')->update(['order_sheet_status' => 'DONE']);
  1091. }
  1092. // 支付记录
  1093. PayDetail::where('join_pay_order_id', $order->order_groupby)->where('pay_prepayid', 'WXPAY')->update(['pay_status' => 'SUCCESS']);
  1094. // 优惠券标记使用
  1095. $this->changeOrderCouponStatus($discountJson, 'USED');
  1096. Db::commit();
  1097. return json_success('success');
  1098. }
  1099. } else if (in_array('ALIPAY', $payDetailType)) {
  1100. $result = Pay::alipay(config('payment.alipay'))->find($order->order_groupby);
  1101. $result = json_decode(json_encode($result), true);
  1102. // $result = '{"code":"10000","msg":"Success","buyer_logon_id":"138******93","buyer_pay_amount":"5.87","fund_bill_list":[{"amount":"5.69","fund_channel":"ALIPAYACCOUNT"},{"amount":"0.18","fund_channel":"COUPON"},{"amount":"0.13","fund_channel":"DISCOUNT"}],"invoice_amount":"5.69","out_trade_no":"OD2409251550Q07A","point_amount":"0.00","receipt_amount":"6.00","send_pay_date":"2024-09-25 15:50:22","total_amount":"6.00","trade_no":"2024092523001439431419750998","trade_status":"TRADE_SUCCESS","buyer_open_id":"04309N2aVhSZz4cKwN_DN2DQa7ekM3z5n8kscQHsmIZOJsf"}';
  1103. // $result = json_decode($result, true);
  1104. if (!empty($result['code']) && $result['code'] == '10000' && !empty($result['trade_status']) && $result['trade_status'] == 'TRADE_SUCCESS') {
  1105. $order->order_status_payment = 'SUCCESS';
  1106. if (in_array($order->order_category, ['SERVICE', 'CHNMED', 'CHNNCD', 'PACKAGE'])) {
  1107. $order->order_status_system = 'WAITING';
  1108. } elseif (in_array($order->order_category, ['DISHES', 'MEALS'])) {
  1109. $order->order_is_complete = 'Y';
  1110. $order->order_status_system = 'DONE';
  1111. } else if (in_array($order->order_category, ['VIP', 'PARTNER'])) {
  1112. $order->order_status_payment = 'PENDING';
  1113. if ($order->order_amount_paid + $result['total_amount'] >= $order->order_amount_total) {
  1114. $order->order_amount_paid = $order->order_amount_paid + $result['total_amount'];
  1115. $order->order_status_system = 'DONE';
  1116. $order->order_status_payment = 'SUCCESS';
  1117. $order->order_is_complete = 'Y';
  1118. }
  1119. } else {
  1120. $order->order_status_system = 'SENDING';
  1121. }
  1122. $order->save();
  1123. // Sheet
  1124. if ($order->order_status_payment == 'SUCCESS') {
  1125. OrderSheet::where('join_sheet_order_id', $orderId)->where('order_sheet_status', 'PAYING')->update(['order_sheet_status' => 'DONE']);
  1126. }
  1127. // 支付记录
  1128. PayDetail::where('join_pay_order_id', $order->order_groupby)->where('pay_prepayid', 'ALIPAY')->update(['pay_status' => 'SUCCESS']);
  1129. // 其他支付方式 扣
  1130. // $this->deductAccount($order->order_groupby, 'ALIPAY');
  1131. // 优惠券标记使用
  1132. $this->changeOrderCouponStatus($discountJson, 'USED');
  1133. Db::commit();
  1134. return json_success('success');
  1135. }
  1136. }
  1137. Db::rollBack();
  1138. return json_fail('没有查询到记录');
  1139. } catch (\Exception $e) {
  1140. dump($e->getMessage());
  1141. Db::rollBack();
  1142. return json_fail('查询失败');
  1143. }
  1144. }
  1145. }