|
@@ -7,10 +7,13 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
7
|
7
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
8
|
8
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
9
|
9
|
import com.huiju.estateagents.base.ResponseBean;
|
|
10
|
+import com.huiju.estateagents.center.sysUser.entity.SysUser;
|
|
11
|
+import com.huiju.estateagents.center.sysUser.mapper.SysUserMapper;
|
10
|
12
|
import com.huiju.estateagents.center.taUser.entity.TaUser;
|
11
|
13
|
import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
|
12
|
14
|
import com.huiju.estateagents.common.CommConstant;
|
13
|
15
|
import com.huiju.estateagents.common.CommonUtils;
|
|
16
|
+import com.huiju.estateagents.common.StringUtils;
|
14
|
17
|
import com.huiju.estateagents.common.wxpay.WXPay;
|
15
|
18
|
import com.huiju.estateagents.common.wxpay.WXPayConstants;
|
16
|
19
|
import com.huiju.estateagents.common.wxpay.WxConfig;
|
|
@@ -38,6 +41,7 @@ import java.net.URLEncoder;
|
38
|
41
|
import java.time.LocalDate;
|
39
|
42
|
import java.time.LocalDateTime;
|
40
|
43
|
import java.util.ArrayList;
|
|
44
|
+import java.util.Arrays;
|
41
|
45
|
import java.util.HashMap;
|
42
|
46
|
import java.util.List;
|
43
|
47
|
import java.util.Map;
|
|
@@ -79,7 +83,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
79
|
83
|
private TaOrgAccountCertificateMapper taOrgAccountCertificateMapper;
|
80
|
84
|
|
81
|
85
|
@Autowired
|
82
|
|
- private TaUserMapper taUserMapper;
|
|
86
|
+ private SysUserMapper sysUserMapper;
|
83
|
87
|
|
84
|
88
|
@Autowired
|
85
|
89
|
private TaWxPayConfigMapper taWxPayConfigMapper;
|
|
@@ -90,6 +94,11 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
90
|
94
|
|
91
|
95
|
if (CommConstant.ITEM_TYPE_RECHARGE.equals(orderType) || CommConstant.ITEM_TYPE_REFUND.equals(orderType)) {
|
92
|
96
|
result = taOrgOrderMapper.orderListByRechargeOrRefund(pg, orderType, orgId, tradeNo, isOffline, tradingStatus, startDate, endDate, miniAppName);
|
|
97
|
+ result.getRecords().forEach(e -> {
|
|
98
|
+ if (!StringUtils.isEmpty(e.getCertificateUrl())){
|
|
99
|
+ e.setCertificateUrlList(Arrays.asList(e.getCertificateUrl().split(",")));
|
|
100
|
+ }
|
|
101
|
+ });
|
93
|
102
|
return result;
|
94
|
103
|
} else if (CommConstant.ITEM_TYPE_REDPACKAGE.equals(orderType)) {
|
95
|
104
|
result = taOrgOrderMapper.orderListByConsume(pg, orderType, orgId, tradeNo, tradingStatus, receivePhone, itemType, startDate, endDate, miniAppName);
|
|
@@ -164,7 +173,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
164
|
173
|
ResponseBean responseBean = new ResponseBean();
|
165
|
174
|
|
166
|
175
|
// 获取下单人名称
|
167
|
|
- TaUser taUser = taUserMapper.selectById(userId);
|
|
176
|
+ SysUser taUser = sysUserMapper.selectById(userId);
|
168
|
177
|
if (taUser == null) {
|
169
|
178
|
responseBean.addError("fail");
|
170
|
179
|
return responseBean;
|
|
@@ -228,7 +237,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
228
|
237
|
ResponseBean responseBean = new ResponseBean();
|
229
|
238
|
|
230
|
239
|
// 获取下单人名称
|
231
|
|
- TaUser taUser = taUserMapper.selectById(userId);
|
|
240
|
+ SysUser taUser = sysUserMapper.selectById(userId);
|
232
|
241
|
if (taUser == null) {
|
233
|
242
|
responseBean.addError("fail");
|
234
|
243
|
return responseBean;
|
|
@@ -418,26 +427,26 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
418
|
427
|
TaOrgAccount taOrgAccount = assembleRefundAccount(refundApplication.getOrgId(), refundApplication, CommConstant.ITEM_TYPE_REFUND);
|
419
|
428
|
taOrgAccountMapper.updateById(taOrgAccount);
|
420
|
429
|
|
421
|
|
- //新增订单记录
|
422
|
|
- TaOrgOrder taOrgOrder = assembleTaOrgOrder(refundApplication.getOrgId(), taOrgAccount.getRechargeAmount(), userId);
|
423
|
|
- int taOrgOrderInsertResult = taOrgOrderMapper.insert(taOrgOrder);
|
|
430
|
+ //更新订单记录
|
|
431
|
+ TaOrgOrder taOrgOrder = assembleTaOrgOrder(id);
|
|
432
|
+ taOrgOrderMapper.updateById(taOrgOrder);
|
424
|
433
|
|
425
|
|
- //新增关联订单明细
|
426
|
|
- TaOrgOrderDetail taOrgOrderDetail = assembleTaOrgOrderDetail(taOrgOrder.getOrderId(), refundApplication.getOrgId(), taOrgAccount.getRechargeAmount());
|
427
|
|
- int taOrgOrderDetailInsertResult = taOrgOrderDetailMapper.insert(taOrgOrderDetail);
|
|
434
|
+// //更新关联订单明细
|
|
435
|
+// TaOrgOrderDetail taOrgOrderDetail = assembleTaOrgOrderDetail(taOrgOrder.getOrderId(), refundApplication.getOrgId(), taOrgAccount.getRechargeAmount());
|
|
436
|
+// int taOrgOrderDetailInsertResult = taOrgOrderDetailMapper.insert(taOrgOrderDetail);
|
428
|
437
|
|
429
|
438
|
//新建账户消费流水
|
430
|
|
- TaOrgAccountDetailedList taOrgAccountDetailedList = assembleAccountDetailList(refundApplication, userId);
|
431
|
|
- int taOrgAccountDetailedListInsertResult = taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
|
|
439
|
+ TaOrgAccountDetailedList taOrgAccountDetailedList = assembleAccountDetailList(id, refundApplication, userId);
|
|
440
|
+ taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
|
432
|
441
|
|
433
|
442
|
//更新账户退款申请
|
434
|
443
|
TaOrgRefundApplication updateRefundApplication = assembleRefundApplication(userId, CommConstant.ITEM_TYPE_REJECT, refundApplication);
|
435
|
444
|
QueryWrapper<TaOrgRefundApplication> taOrgRefundApplicationQueryWrapper = new QueryWrapper<>();
|
436
|
445
|
taOrgRefundApplicationQueryWrapper.eq("org_id", refundApplication.getOrgId());
|
437
|
|
- int taOrgRefundApplicationUpdateResult = taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
|
446
|
+ taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
438
|
447
|
|
439
|
448
|
//更新账户冻结记录
|
440
|
|
- int taOrgAccountBlockedUpdateResult = updateOrgAccountBlock(refundApplication);
|
|
449
|
+ updateOrgAccountBlock(refundApplication);
|
441
|
450
|
|
442
|
451
|
//插入凭证记录
|
443
|
452
|
if (CollectionUtils.isNotEmpty(refundApplication.getCertificateList())) {
|
|
@@ -447,14 +456,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
447
|
456
|
});
|
448
|
457
|
}
|
449
|
458
|
|
450
|
|
- if (taOrgOrderInsertResult < 1 ||
|
451
|
|
- taOrgOrderDetailInsertResult < 1 ||
|
452
|
|
- taOrgAccountDetailedListInsertResult < 1 ||
|
453
|
|
- taOrgRefundApplicationUpdateResult < 1 ||
|
454
|
|
- taOrgAccountBlockedUpdateResult < 1) {
|
455
|
|
- responseBean.addError("订单退款失败");
|
456
|
|
- return responseBean;
|
457
|
|
- }
|
|
459
|
+// if (taOrgOrderInsertResult < 1 ||
|
|
460
|
+// taOrgAccountDetailedListInsertResult < 1 ||
|
|
461
|
+// taOrgRefundApplicationUpdateResult < 1 ||
|
|
462
|
+// taOrgAccountBlockedUpdateResult < 1) {
|
|
463
|
+// responseBean.addError("订单退款失败");
|
|
464
|
+// return responseBean;
|
|
465
|
+// }
|
458
|
466
|
|
459
|
467
|
return responseBean;
|
460
|
468
|
}
|
|
@@ -477,8 +485,15 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
477
|
485
|
taOrgRefundApplicationQueryWrapper.eq("org_id", refundApplication.getOrgId());
|
478
|
486
|
int taOrgRefundApplicationUpdateResult = taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
479
|
487
|
|
|
488
|
+ //更新订单状态
|
|
489
|
+ TaOrgOrder taOrgOrder = new TaOrgOrder();
|
|
490
|
+ taOrgOrder.setOrderId(id);
|
|
491
|
+ taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_FAIL);
|
|
492
|
+ int taOrgOrderUpdateResult = taOrgOrderMapper.updateById(taOrgOrder);
|
|
493
|
+
|
480
|
494
|
if (taOrgAccountBlockedUpdateResult < 1 ||
|
481
|
|
- taOrgRefundApplicationUpdateResult < 1) {
|
|
495
|
+ taOrgRefundApplicationUpdateResult < 1 ||
|
|
496
|
+ taOrgOrderUpdateResult < 1) {
|
482
|
497
|
responseBean.addError("驳回失败");
|
483
|
498
|
return responseBean;
|
484
|
499
|
}
|
|
@@ -517,25 +532,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
517
|
532
|
/**
|
518
|
533
|
* 构造订单
|
519
|
534
|
*
|
520
|
|
- * @param orgId
|
521
|
|
- * @param amount
|
522
|
|
- * @param userId
|
523
|
535
|
* @return
|
524
|
536
|
*/
|
525
|
|
- private TaOrgOrder assembleTaOrgOrder(Integer orgId, Integer amount, Integer userId) {
|
|
537
|
+ private TaOrgOrder assembleTaOrgOrder(String orderId) {
|
526
|
538
|
|
527
|
|
- TaUser taUser = selectUserById(userId);
|
528
|
539
|
TaOrgOrder taOrgOrder = new TaOrgOrder();
|
529
|
|
- taOrgOrder.setOrgId(orgId);
|
530
|
|
- taOrgOrder.setTradeNo(CommonUtils.generateTradeNo(CommConstant.RECHARGE));
|
531
|
|
- taOrgOrder.setAmount(amount);
|
532
|
|
- taOrgOrder.setCreateDate(LocalDateTime.now());
|
533
|
|
- taOrgOrder.setExpiryDate(LocalDateTime.now());
|
534
|
|
- taOrgOrder.setRemark("线下订单退费");
|
535
|
|
- taOrgOrder.setTradingStatus(String.valueOf(CommConstant.STATUS_NORMAL));
|
536
|
|
- taOrgOrder.setIsOffline(true);
|
537
|
|
- taOrgOrder.setUserId(userId);
|
538
|
|
- taOrgOrder.setUserName(taUser.getUserName());
|
|
540
|
+ taOrgOrder.setOrderId(orderId);
|
|
541
|
+ taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_SUCCESS);
|
539
|
542
|
|
540
|
543
|
return taOrgOrder;
|
541
|
544
|
}
|
|
@@ -566,9 +569,9 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
566
|
569
|
* @param userId
|
567
|
570
|
* @return
|
568
|
571
|
*/
|
569
|
|
- private TaOrgAccountDetailedList assembleAccountDetailList(TaOrgRefundApplication refundApplication, Integer userId) {
|
|
572
|
+ private TaOrgAccountDetailedList assembleAccountDetailList(String orderId, TaOrgRefundApplication refundApplication, Integer userId) {
|
570
|
573
|
|
571
|
|
- TaUser taUser = selectUserById(userId);
|
|
574
|
+ SysUser taUser = selectUserById(userId);
|
572
|
575
|
TaOrgAccount taOrgAccount = selectTaOrgAccountById(refundApplication.getOrgId());
|
573
|
576
|
|
574
|
577
|
TaOrgAccountDetailedList taOrgAccountDetailed = new TaOrgAccountDetailedList();
|
|
@@ -578,7 +581,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
578
|
581
|
//1收入,-1支出
|
579
|
582
|
taOrgAccountDetailed.setSignType(CommConstant.STATUS_DELETE);
|
580
|
583
|
taOrgAccountDetailed.setRemark("线下订单退费");
|
581
|
|
- taOrgAccountDetailed.setOrderId(refundApplication.getOrderId());
|
|
584
|
+ taOrgAccountDetailed.setOrderId(orderId);
|
582
|
585
|
taOrgAccountDetailed.setUserId(userId);
|
583
|
586
|
taOrgAccountDetailed.setUserName(taUser.getUserName());
|
584
|
587
|
|
|
@@ -596,7 +599,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
596
|
599
|
* @return
|
597
|
600
|
*/
|
598
|
601
|
public List<TaOrgAccountCertificate> assembleAccountCertificate(Integer orgId, TaOrgAccount taOrgAccount, Integer accountSerialNo, String orderId, Integer userId, String consumeType) {
|
599
|
|
- TaUser taUser = selectUserById(userId);
|
|
602
|
+ SysUser taUser = selectUserById(userId);
|
600
|
603
|
List<TaOrgAccountCertificate> taOrgAccountCertificateList = new ArrayList<>();
|
601
|
604
|
|
602
|
605
|
taOrgAccount.getCertificateList().forEach(e -> {
|
|
@@ -624,7 +627,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
624
|
627
|
* @return
|
625
|
628
|
*/
|
626
|
629
|
private TaOrgRefundApplication assembleRefundApplication(Integer userId, String operateType, TaOrgRefundApplication refundApplication) {
|
627
|
|
- TaUser taUser = selectUserById(userId);
|
|
630
|
+ SysUser taUser = selectUserById(userId);
|
628
|
631
|
TaOrgRefundApplication taOrgRefundApplication = new TaOrgRefundApplication();
|
629
|
632
|
taOrgRefundApplication.setAuditorId(userId);
|
630
|
633
|
taOrgRefundApplication.setAuditorName(taUser.getUserName());
|
|
@@ -656,12 +659,12 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
656
|
659
|
* @param userId
|
657
|
660
|
* @return
|
658
|
661
|
*/
|
659
|
|
- public TaUser selectUserById(Integer userId) {
|
|
662
|
+ public SysUser selectUserById(Integer userId) {
|
660
|
663
|
//获取操作人
|
661
|
|
- QueryWrapper<TaUser> taUserQueryWrapper = new QueryWrapper<>();
|
662
|
|
- taUserQueryWrapper.eq("user_id", userId);
|
663
|
|
- TaUser taUser = taUserMapper.selectOne(taUserQueryWrapper);
|
664
|
|
- return taUser;
|
|
664
|
+ QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
|
|
665
|
+ sysUserQueryWrapper.eq("user_id", userId);
|
|
666
|
+ SysUser sysUser = sysUserMapper.selectOne(sysUserQueryWrapper);
|
|
667
|
+ return sysUser;
|
665
|
668
|
}
|
666
|
669
|
|
667
|
670
|
}
|