|
@@ -119,7 +119,6 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
119
|
119
|
IPage<TaOrgOrder> result = pg;
|
120
|
120
|
|
121
|
121
|
if (CommConstant.ITEM_TYPE_RECHARGE.equals(orderType) || CommConstant.ITEM_TYPE_REFUND.equals(orderType)) {
|
122
|
|
- List<String> urlList = new ArrayList<>();
|
123
|
122
|
result = taOrgOrderMapper.orderListByRechargeOrRefund(pg, orderType, orgId, tradeNo, isOffline, tradingStatus, startDate, endDate, miniAppName, auditStatus, payStartDate, payEndDate);
|
124
|
123
|
result.getRecords().forEach(e -> {
|
125
|
124
|
e.setCertificateUrlList(getCertificateByOrderId(e.getOrderId()));
|
|
@@ -217,6 +216,16 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
217
|
216
|
return responseBean;
|
218
|
217
|
}
|
219
|
218
|
|
|
219
|
+ // 查询账户信息
|
|
220
|
+ QueryWrapper<TaOrgAccount> orgAccountQueryWrapper = new QueryWrapper<>();
|
|
221
|
+ orgAccountQueryWrapper.eq("org_id", orgId);
|
|
222
|
+ orgAccountQueryWrapper.eq("status", CommConstant.STATUS_NORMAL);
|
|
223
|
+ TaOrgAccount taOrgAccount = taOrgAccountMapper.selectOne(orgAccountQueryWrapper);
|
|
224
|
+ if (taOrgAccount == null) {
|
|
225
|
+ responseBean.addError("账户不存在");
|
|
226
|
+ return responseBean;
|
|
227
|
+ }
|
|
228
|
+
|
220
|
229
|
// 计算实付金额
|
221
|
230
|
Integer realAmount = calculateRealAmount(amount);
|
222
|
231
|
|
|
@@ -346,7 +355,17 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
346
|
355
|
return responseBean;
|
347
|
356
|
}
|
348
|
357
|
|
349
|
|
- // 4.创建账户退款申请表信息
|
|
358
|
+ // 4.创建冻结表数据
|
|
359
|
+ TaOrgAccountBlocked taOrgAccountBlocked = new TaOrgAccountBlocked();
|
|
360
|
+ taOrgAccountBlocked.setAccountId(taOrgAccount.getAccountId());
|
|
361
|
+ taOrgAccountBlocked.setBlockedBalance(amount);
|
|
362
|
+ taOrgAccountBlocked.setBlockedReason("线上退款申请");
|
|
363
|
+ taOrgAccountBlocked.setCreateDate(LocalDateTime.now());
|
|
364
|
+ taOrgAccountBlocked.setStatus(CommConstant.STATUS_NORMAL);
|
|
365
|
+ taOrgAccountBlocked.setOrgId(orgId);
|
|
366
|
+ taOrgAccountBlockedMapper.insert(taOrgAccountBlocked);
|
|
367
|
+
|
|
368
|
+ // 5.创建账户退款申请表信息
|
350
|
369
|
TaOrgRefundApplication taOrgRefundApplication = new TaOrgRefundApplication();
|
351
|
370
|
taOrgRefundApplication.setOrgId(orgId);
|
352
|
371
|
taOrgRefundApplication.setUserId(userId);
|
|
@@ -355,6 +374,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
355
|
374
|
taOrgRefundApplication.setAuditStatus(CommConstant.CHECK_STATUS_CHECKING);
|
356
|
375
|
taOrgRefundApplication.setOrderId(taOrgOrder.getOrderId());
|
357
|
376
|
taOrgRefundApplication.setStatus(CommConstant.STATUS_NORMAL);
|
|
377
|
+ taOrgRefundApplication.setBlockedId(taOrgAccountBlocked.getSerialNo());
|
358
|
378
|
taOrgRefundApplication.setCreateDate(LocalDateTime.now());
|
359
|
379
|
taOrgRefundApplication.setReason("线上申请退款");
|
360
|
380
|
if (taOrgRefundApplicationMapper.insert(taOrgRefundApplication) < 1) {
|
|
@@ -364,16 +384,6 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
364
|
384
|
return responseBean;
|
365
|
385
|
}
|
366
|
386
|
|
367
|
|
- // 5.创建冻结表数据
|
368
|
|
- TaOrgAccountBlocked taOrgAccountBlocked = new TaOrgAccountBlocked();
|
369
|
|
- taOrgAccountBlocked.setAccountId(taOrgAccount.getAccountId());
|
370
|
|
- taOrgAccountBlocked.setBlockedBalance(amount);
|
371
|
|
- taOrgAccountBlocked.setBlockedReason("线上退款申请");
|
372
|
|
- taOrgAccountBlocked.setCreateDate(LocalDateTime.now());
|
373
|
|
- taOrgAccountBlocked.setStatus(CommConstant.STATUS_NORMAL);
|
374
|
|
- taOrgAccountBlocked.setOrgId(orgId);
|
375
|
|
- taOrgAccountBlockedMapper.insert(taOrgAccountBlocked);
|
376
|
|
-
|
377
|
387
|
// 6.更新账户新金额
|
378
|
388
|
taOrgAccountMapper.updateAvailableBalanceById(taOrgAccount.getAccountId(), amount);
|
379
|
389
|
|
|
@@ -393,7 +403,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
393
|
403
|
}
|
394
|
404
|
|
395
|
405
|
@Override
|
396
|
|
- public ResponseBean listCzOrderByCondition(Integer pageNum, Integer pageSize, LocalDate payStartTime, LocalDate payEndTime,
|
|
406
|
+ public ResponseBean listCzOrderByCondition(Integer pageNum, Integer pageSize, LocalDateTime payStartTime, LocalDateTime payEndTime,
|
397
|
407
|
String orderId, String tradeNo, String wxOrderId, Boolean isOffline, String tradingStatus, Integer orgId) {
|
398
|
408
|
ResponseBean responseBean = new ResponseBean();
|
399
|
409
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
|
@@ -418,7 +428,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
418
|
428
|
}
|
419
|
429
|
|
420
|
430
|
@Override
|
421
|
|
- public void exportCzOrderByCondition(LocalDate payStartTime, LocalDate payEndTime, String orderId, String tradeNo,
|
|
431
|
+ public void exportCzOrderByCondition(LocalDateTime payStartTime, LocalDateTime payEndTime, String orderId, String tradeNo,
|
422
|
432
|
String wxOrderId, Boolean isOffline, String tradingStatus, Integer orgId, HttpServletResponse response) throws Exception {
|
423
|
433
|
response.setContentType("application/octet-stream");
|
424
|
434
|
response.setCharacterEncoding("utf-8");
|
|
@@ -429,7 +439,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
429
|
439
|
}
|
430
|
440
|
|
431
|
441
|
@Override
|
432
|
|
- public ResponseBean listRefundOrderByCondition(Integer pageNum, Integer pageSize, LocalDate refundStartTime, LocalDate refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId) {
|
|
442
|
+ public ResponseBean listRefundOrderByCondition(Integer pageNum, Integer pageSize, LocalDateTime refundStartTime, LocalDateTime refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId) {
|
433
|
443
|
ResponseBean responseBean = new ResponseBean();
|
434
|
444
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
435
|
445
|
pg = taOrgOrderMapper.listRefundOrderByCondition(pg, refundStartTime, refundEndTime, orderId, wxOrderId, tradeNo, auditStatus, orgId);
|
|
@@ -454,7 +464,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
454
|
464
|
}
|
455
|
465
|
|
456
|
466
|
@Override
|
457
|
|
- public void exportRefundOrderByCondition(LocalDate refundStartTime, LocalDate refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
|
467
|
+ public void exportRefundOrderByCondition(LocalDateTime refundStartTime, LocalDateTime refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
458
|
468
|
response.setContentType("application/octet-stream");
|
459
|
469
|
response.setCharacterEncoding("utf-8");
|
460
|
470
|
List<AccountRefundRecordExport> records = taOrgOrderMapper.exportRefundOrderByCondition(refundStartTime, refundEndTime, orderId, wxOrderId, tradeNo, auditStatus, orgId);
|
|
@@ -472,7 +482,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
472
|
482
|
}
|
473
|
483
|
|
474
|
484
|
@Override
|
475
|
|
- public ResponseBean listConsumeOrderByCondition(Integer pageNum, Integer pageSize, LocalDate startTime, LocalDate endTime, String orderId, String tradingStatus, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId) {
|
|
485
|
+ public ResponseBean listConsumeOrderByCondition(Integer pageNum, Integer pageSize, LocalDateTime startTime, LocalDateTime endTime, String orderId, String tradingStatus, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId) {
|
476
|
486
|
ResponseBean responseBean = new ResponseBean();
|
477
|
487
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
478
|
488
|
responseBean.addSuccess(taOrgOrderMapper.listConsumeOrderByCondition(pg, startTime, endTime, orderId, tradingStatus, consumeType, phone, wxOrderId, tradeNo, orgId));
|
|
@@ -480,7 +490,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
480
|
490
|
}
|
481
|
491
|
|
482
|
492
|
@Override
|
483
|
|
- public void exportConsumeOrderByCondition(LocalDate startTime, LocalDate endTime, String orderId, String tradingStatus, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
|
493
|
+ public void exportConsumeOrderByCondition(LocalDateTime startTime, LocalDateTime endTime, String orderId, String tradingStatus, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
484
|
494
|
response.setContentType("application/octet-stream");
|
485
|
495
|
response.setCharacterEncoding("utf-8");
|
486
|
496
|
List<AccountConsumeRecordExport> records = taOrgOrderMapper.exportConsumeOrderByCondition(startTime, endTime, orderId, tradingStatus, consumeType, wxOrderId, tradeNo, phone, orgId);
|
|
@@ -545,13 +555,16 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
545
|
555
|
taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
|
546
|
556
|
|
547
|
557
|
//更新账户退款申请
|
|
558
|
+ TaOrgRefundApplication selectRefundApplication = selectRefundApplication(id);
|
|
559
|
+
|
548
|
560
|
TaOrgRefundApplication updateRefundApplication = assembleRefundApplication(userId, CommConstant.ITEM_TYPE_REFUND, refundApplication);
|
549
|
561
|
QueryWrapper<TaOrgRefundApplication> taOrgRefundApplicationQueryWrapper = new QueryWrapper<>();
|
550
|
562
|
taOrgRefundApplicationQueryWrapper.eq("order_id", id);
|
|
563
|
+ taOrgRefundApplicationQueryWrapper.eq("blocked_id", selectRefundApplication.getBlockedId());
|
551
|
564
|
taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
552
|
565
|
|
553
|
566
|
//更新账户冻结记录
|
554
|
|
- updateOrgAccountBlock(refundApplication);
|
|
567
|
+ updateOrgAccountBlock(refundApplication, selectRefundApplication.getBlockedId());
|
555
|
568
|
|
556
|
569
|
//插入凭证记录
|
557
|
570
|
if (CollectionUtils.isNotEmpty(refundApplication.getCertificateList())) {
|
|
@@ -574,15 +587,17 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
574
|
587
|
TaOrgAccount taOrgAccount = assembleRefundAccount(refundApplication.getOrgId(), refundApplication, CommConstant.ITEM_TYPE_REJECT);
|
575
|
588
|
taOrgAccountMapper.updateById(taOrgAccount);
|
576
|
589
|
|
577
|
|
- //更新账户冻结记录
|
578
|
|
- int taOrgAccountBlockedUpdateResult = updateOrgAccountBlock(refundApplication);
|
579
|
|
-
|
580
|
590
|
//更新退款申请记录
|
|
591
|
+ TaOrgRefundApplication selectRefundApplication = selectRefundApplication(id);
|
|
592
|
+
|
581
|
593
|
TaOrgRefundApplication updateRefundApplication = assembleRefundApplication(userId, CommConstant.ITEM_TYPE_REJECT, refundApplication);
|
582
|
594
|
QueryWrapper<TaOrgRefundApplication> taOrgRefundApplicationQueryWrapper = new QueryWrapper<>();
|
583
|
595
|
taOrgRefundApplicationQueryWrapper.eq("order_id", id);
|
584
|
596
|
int taOrgRefundApplicationUpdateResult = taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
585
|
597
|
|
|
598
|
+ //更新账户冻结记录
|
|
599
|
+ int taOrgAccountBlockedUpdateResult = updateOrgAccountBlock(refundApplication, selectRefundApplication.getBlockedId());
|
|
600
|
+
|
586
|
601
|
//更新订单状态
|
587
|
602
|
TaOrgOrder taOrgOrder = new TaOrgOrder();
|
588
|
603
|
taOrgOrder.setOrderId(id);
|
|
@@ -614,13 +629,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
614
|
629
|
rechargeAccount.setAccountId(selectOneAccount.getAccountId());
|
615
|
630
|
|
616
|
631
|
if (CommConstant.ITEM_TYPE_REFUND.equals(operateType)) {
|
617
|
|
- TaOrgRefundApplication taOrgRefundApplication = selectRefundApplication(refundApplication);
|
|
632
|
+ TaOrgRefundApplication taOrgRefundApplication = selectRefundApplication(refundApplication.getOrderId());
|
618
|
633
|
rechargeAccount.setRealBalance(selectOneAccount.getRealBalance() - taOrgRefundApplication.getAmount());
|
619
|
634
|
rechargeAccount.setTotalRefund(selectOneAccount.getTotalRefund() + taOrgRefundApplication.getAmount());
|
620
|
635
|
}
|
621
|
636
|
|
622
|
637
|
if (CommConstant.ITEM_TYPE_REJECT.equals(operateType)) {
|
623
|
|
- TaOrgRefundApplication taOrgRefundApplication = selectRefundApplication(refundApplication);
|
|
638
|
+ TaOrgRefundApplication taOrgRefundApplication = selectRefundApplication(refundApplication.getOrderId());
|
624
|
639
|
rechargeAccount.setAvailableBalance(selectOneAccount.getAvailableBalance() + taOrgRefundApplication.getAmount());
|
625
|
640
|
}
|
626
|
641
|
|
|
@@ -737,12 +752,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
737
|
752
|
return taOrgRefundApplication;
|
738
|
753
|
}
|
739
|
754
|
|
740
|
|
- private Integer updateOrgAccountBlock(TaOrgRefundApplication refundApplication) {
|
|
755
|
+ private Integer updateOrgAccountBlock(TaOrgRefundApplication refundApplication, Integer blockedId) {
|
741
|
756
|
//更新账户冻结记录
|
742
|
757
|
TaOrgAccountBlocked taOrgAccountBlocked = new TaOrgAccountBlocked();
|
743
|
758
|
taOrgAccountBlocked.setStatus(CommConstant.STATUS_UNACCALIMED);
|
744
|
759
|
QueryWrapper<TaOrgAccountBlocked> taOrgAccountBlockedQueryWrapper = new QueryWrapper<>();
|
745
|
760
|
taOrgAccountBlockedQueryWrapper.eq("org_id", refundApplication.getOrgId());
|
|
761
|
+ taOrgAccountBlockedQueryWrapper.eq("serial_no", blockedId);
|
746
|
762
|
return taOrgAccountBlockedMapper.update(taOrgAccountBlocked, taOrgAccountBlockedQueryWrapper);
|
747
|
763
|
}
|
748
|
764
|
|
|
@@ -767,9 +783,9 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
767
|
783
|
return sysUser;
|
768
|
784
|
}
|
769
|
785
|
|
770
|
|
- public TaOrgRefundApplication selectRefundApplication(TaOrgRefundApplication refundApplication) {
|
|
786
|
+ public TaOrgRefundApplication selectRefundApplication(String orderId) {
|
771
|
787
|
QueryWrapper<TaOrgRefundApplication> taOrgRefundApplicationQueryWrapper = new QueryWrapper<>();
|
772
|
|
- taOrgRefundApplicationQueryWrapper.eq("order_id", refundApplication.getOrderId());
|
|
788
|
+ taOrgRefundApplicationQueryWrapper.eq("order_id", orderId);
|
773
|
789
|
return taOrgRefundApplicationMapper.selectOne(taOrgRefundApplicationQueryWrapper);
|
774
|
790
|
}
|
775
|
791
|
|