|
@@ -6,10 +6,13 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
6
|
6
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
7
|
7
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
8
|
8
|
import com.huiju.estateagents.base.ResponseBean;
|
|
9
|
+import com.huiju.estateagents.center.sysUser.entity.SysUser;
|
|
10
|
+import com.huiju.estateagents.center.sysUser.mapper.SysUserMapper;
|
9
|
11
|
import com.huiju.estateagents.center.taUser.entity.TaUser;
|
10
|
12
|
import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
|
11
|
13
|
import com.huiju.estateagents.common.CommConstant;
|
12
|
14
|
import com.huiju.estateagents.common.CommonUtils;
|
|
15
|
+import com.huiju.estateagents.common.StringUtils;
|
13
|
16
|
import com.huiju.estateagents.common.wxpay.WXPay;
|
14
|
17
|
import com.huiju.estateagents.common.wxpay.WXPayConstants;
|
15
|
18
|
import com.huiju.estateagents.common.wxpay.WxConfig;
|
|
@@ -37,6 +40,7 @@ import java.net.URLEncoder;
|
37
|
40
|
import java.time.LocalDate;
|
38
|
41
|
import java.time.LocalDateTime;
|
39
|
42
|
import java.util.ArrayList;
|
|
43
|
+import java.util.Arrays;
|
40
|
44
|
import java.util.HashMap;
|
41
|
45
|
import java.util.List;
|
42
|
46
|
import java.util.Map;
|
|
@@ -78,7 +82,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
78
|
82
|
private TaOrgAccountCertificateMapper taOrgAccountCertificateMapper;
|
79
|
83
|
|
80
|
84
|
@Autowired
|
81
|
|
- private TaUserMapper taUserMapper;
|
|
85
|
+ private SysUserMapper sysUserMapper;
|
82
|
86
|
|
83
|
87
|
@Autowired
|
84
|
88
|
private TaWxPayConfigMapper taWxPayConfigMapper;
|
|
@@ -89,6 +93,11 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
89
|
93
|
|
90
|
94
|
if (CommConstant.ITEM_TYPE_RECHARGE.equals(orderType) || CommConstant.ITEM_TYPE_REFUND.equals(orderType)) {
|
91
|
95
|
result = taOrgOrderMapper.orderListByRechargeOrRefund(pg, orderType, orgId, tradeNo, isOffline, tradingStatus, startDate, endDate, miniAppName);
|
|
96
|
+ result.getRecords().forEach(e -> {
|
|
97
|
+ if (!StringUtils.isEmpty(e.getCertificateUrl())){
|
|
98
|
+ e.setCertificateUrlList(Arrays.asList(e.getCertificateUrl().split(",")));
|
|
99
|
+ }
|
|
100
|
+ });
|
92
|
101
|
return result;
|
93
|
102
|
} else if (CommConstant.ITEM_TYPE_REDPACKAGE.equals(orderType)) {
|
94
|
103
|
result = taOrgOrderMapper.orderListByConsume(pg, orderType, orgId, tradeNo, tradingStatus, receivePhone, itemType, startDate, endDate, miniAppName);
|
|
@@ -162,7 +171,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
162
|
171
|
ResponseBean responseBean = new ResponseBean();
|
163
|
172
|
|
164
|
173
|
// 获取下单人名称
|
165
|
|
- TaUser taUser = taUserMapper.selectById(userId);
|
|
174
|
+ SysUser taUser = sysUserMapper.selectById(userId);
|
166
|
175
|
if (taUser == null) {
|
167
|
176
|
responseBean.addError("fail");
|
168
|
177
|
return responseBean;
|
|
@@ -208,7 +217,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
208
|
217
|
ResponseBean responseBean = new ResponseBean();
|
209
|
218
|
|
210
|
219
|
// 获取下单人名称
|
211
|
|
- TaUser taUser = taUserMapper.selectById(userId);
|
|
220
|
+ SysUser taUser = sysUserMapper.selectById(userId);
|
212
|
221
|
if (taUser == null) {
|
213
|
222
|
responseBean.addError("fail");
|
214
|
223
|
return responseBean;
|
|
@@ -396,26 +405,26 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
396
|
405
|
TaOrgAccount taOrgAccount = assembleRefundAccount(refundApplication.getOrgId(), refundApplication, CommConstant.ITEM_TYPE_REFUND);
|
397
|
406
|
taOrgAccountMapper.updateById(taOrgAccount);
|
398
|
407
|
|
399
|
|
- //新增订单记录
|
400
|
|
- TaOrgOrder taOrgOrder = assembleTaOrgOrder(refundApplication.getOrgId(), taOrgAccount.getRechargeAmount(), userId);
|
401
|
|
- int taOrgOrderInsertResult = taOrgOrderMapper.insert(taOrgOrder);
|
|
408
|
+ //更新订单记录
|
|
409
|
+ TaOrgOrder taOrgOrder = assembleTaOrgOrder(id);
|
|
410
|
+ taOrgOrderMapper.updateById(taOrgOrder);
|
402
|
411
|
|
403
|
|
- //新增关联订单明细
|
404
|
|
- TaOrgOrderDetail taOrgOrderDetail = assembleTaOrgOrderDetail(taOrgOrder.getOrderId(), refundApplication.getOrgId(), taOrgAccount.getRechargeAmount());
|
405
|
|
- int taOrgOrderDetailInsertResult = taOrgOrderDetailMapper.insert(taOrgOrderDetail);
|
|
412
|
+// //更新关联订单明细
|
|
413
|
+// TaOrgOrderDetail taOrgOrderDetail = assembleTaOrgOrderDetail(taOrgOrder.getOrderId(), refundApplication.getOrgId(), taOrgAccount.getRechargeAmount());
|
|
414
|
+// int taOrgOrderDetailInsertResult = taOrgOrderDetailMapper.insert(taOrgOrderDetail);
|
406
|
415
|
|
407
|
416
|
//新建账户消费流水
|
408
|
|
- TaOrgAccountDetailedList taOrgAccountDetailedList = assembleAccountDetailList(refundApplication, userId);
|
409
|
|
- int taOrgAccountDetailedListInsertResult = taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
|
|
417
|
+ TaOrgAccountDetailedList taOrgAccountDetailedList = assembleAccountDetailList(id, refundApplication, userId);
|
|
418
|
+ taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
|
410
|
419
|
|
411
|
420
|
//更新账户退款申请
|
412
|
421
|
TaOrgRefundApplication updateRefundApplication = assembleRefundApplication(userId, CommConstant.ITEM_TYPE_REJECT, refundApplication);
|
413
|
422
|
QueryWrapper<TaOrgRefundApplication> taOrgRefundApplicationQueryWrapper = new QueryWrapper<>();
|
414
|
423
|
taOrgRefundApplicationQueryWrapper.eq("org_id", refundApplication.getOrgId());
|
415
|
|
- int taOrgRefundApplicationUpdateResult = taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
|
424
|
+ taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
416
|
425
|
|
417
|
426
|
//更新账户冻结记录
|
418
|
|
- int taOrgAccountBlockedUpdateResult = updateOrgAccountBlock(refundApplication);
|
|
427
|
+ updateOrgAccountBlock(refundApplication);
|
419
|
428
|
|
420
|
429
|
//插入凭证记录
|
421
|
430
|
if (CollectionUtils.isNotEmpty(refundApplication.getCertificateList())) {
|
|
@@ -425,14 +434,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
425
|
434
|
});
|
426
|
435
|
}
|
427
|
436
|
|
428
|
|
- if (taOrgOrderInsertResult < 1 ||
|
429
|
|
- taOrgOrderDetailInsertResult < 1 ||
|
430
|
|
- taOrgAccountDetailedListInsertResult < 1 ||
|
431
|
|
- taOrgRefundApplicationUpdateResult < 1 ||
|
432
|
|
- taOrgAccountBlockedUpdateResult < 1) {
|
433
|
|
- responseBean.addError("订单退款失败");
|
434
|
|
- return responseBean;
|
435
|
|
- }
|
|
437
|
+// if (taOrgOrderInsertResult < 1 ||
|
|
438
|
+// taOrgAccountDetailedListInsertResult < 1 ||
|
|
439
|
+// taOrgRefundApplicationUpdateResult < 1 ||
|
|
440
|
+// taOrgAccountBlockedUpdateResult < 1) {
|
|
441
|
+// responseBean.addError("订单退款失败");
|
|
442
|
+// return responseBean;
|
|
443
|
+// }
|
436
|
444
|
|
437
|
445
|
return responseBean;
|
438
|
446
|
}
|
|
@@ -455,8 +463,15 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
455
|
463
|
taOrgRefundApplicationQueryWrapper.eq("org_id", refundApplication.getOrgId());
|
456
|
464
|
int taOrgRefundApplicationUpdateResult = taOrgRefundApplicationMapper.update(updateRefundApplication, taOrgRefundApplicationQueryWrapper);
|
457
|
465
|
|
|
466
|
+ //更新订单状态
|
|
467
|
+ TaOrgOrder taOrgOrder = new TaOrgOrder();
|
|
468
|
+ taOrgOrder.setOrderId(id);
|
|
469
|
+ taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_FAIL);
|
|
470
|
+ int taOrgOrderUpdateResult = taOrgOrderMapper.updateById(taOrgOrder);
|
|
471
|
+
|
458
|
472
|
if (taOrgAccountBlockedUpdateResult < 1 ||
|
459
|
|
- taOrgRefundApplicationUpdateResult < 1) {
|
|
473
|
+ taOrgRefundApplicationUpdateResult < 1 ||
|
|
474
|
+ taOrgOrderUpdateResult < 1) {
|
460
|
475
|
responseBean.addError("驳回失败");
|
461
|
476
|
return responseBean;
|
462
|
477
|
}
|
|
@@ -495,25 +510,13 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
495
|
510
|
/**
|
496
|
511
|
* 构造订单
|
497
|
512
|
*
|
498
|
|
- * @param orgId
|
499
|
|
- * @param amount
|
500
|
|
- * @param userId
|
501
|
513
|
* @return
|
502
|
514
|
*/
|
503
|
|
- private TaOrgOrder assembleTaOrgOrder(Integer orgId, Integer amount, Integer userId) {
|
|
515
|
+ private TaOrgOrder assembleTaOrgOrder(String orderId) {
|
504
|
516
|
|
505
|
|
- TaUser taUser = selectUserById(userId);
|
506
|
517
|
TaOrgOrder taOrgOrder = new TaOrgOrder();
|
507
|
|
- taOrgOrder.setOrgId(orgId);
|
508
|
|
- taOrgOrder.setTradeNo(CommonUtils.generateTradeNo(CommConstant.RECHARGE));
|
509
|
|
- taOrgOrder.setAmount(amount);
|
510
|
|
- taOrgOrder.setCreateDate(LocalDateTime.now());
|
511
|
|
- taOrgOrder.setExpiryDate(LocalDateTime.now());
|
512
|
|
- taOrgOrder.setRemark("线下订单退费");
|
513
|
|
- taOrgOrder.setTradingStatus(String.valueOf(CommConstant.STATUS_NORMAL));
|
514
|
|
- taOrgOrder.setIsOffline(true);
|
515
|
|
- taOrgOrder.setUserId(userId);
|
516
|
|
- taOrgOrder.setUserName(taUser.getUserName());
|
|
518
|
+ taOrgOrder.setOrderId(orderId);
|
|
519
|
+ taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_SUCCESS);
|
517
|
520
|
|
518
|
521
|
return taOrgOrder;
|
519
|
522
|
}
|
|
@@ -544,9 +547,9 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
544
|
547
|
* @param userId
|
545
|
548
|
* @return
|
546
|
549
|
*/
|
547
|
|
- private TaOrgAccountDetailedList assembleAccountDetailList(TaOrgRefundApplication refundApplication, Integer userId) {
|
|
550
|
+ private TaOrgAccountDetailedList assembleAccountDetailList(String orderId, TaOrgRefundApplication refundApplication, Integer userId) {
|
548
|
551
|
|
549
|
|
- TaUser taUser = selectUserById(userId);
|
|
552
|
+ SysUser taUser = selectUserById(userId);
|
550
|
553
|
TaOrgAccount taOrgAccount = selectTaOrgAccountById(refundApplication.getOrgId());
|
551
|
554
|
|
552
|
555
|
TaOrgAccountDetailedList taOrgAccountDetailed = new TaOrgAccountDetailedList();
|
|
@@ -556,7 +559,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
556
|
559
|
//1收入,-1支出
|
557
|
560
|
taOrgAccountDetailed.setSignType(CommConstant.STATUS_DELETE);
|
558
|
561
|
taOrgAccountDetailed.setRemark("线下订单退费");
|
559
|
|
- taOrgAccountDetailed.setOrderId(refundApplication.getOrderId());
|
|
562
|
+ taOrgAccountDetailed.setOrderId(orderId);
|
560
|
563
|
taOrgAccountDetailed.setUserId(userId);
|
561
|
564
|
taOrgAccountDetailed.setUserName(taUser.getUserName());
|
562
|
565
|
|
|
@@ -574,7 +577,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
574
|
577
|
* @return
|
575
|
578
|
*/
|
576
|
579
|
public List<TaOrgAccountCertificate> assembleAccountCertificate(Integer orgId, TaOrgAccount taOrgAccount, Integer accountSerialNo, String orderId, Integer userId, String consumeType) {
|
577
|
|
- TaUser taUser = selectUserById(userId);
|
|
580
|
+ SysUser taUser = selectUserById(userId);
|
578
|
581
|
List<TaOrgAccountCertificate> taOrgAccountCertificateList = new ArrayList<>();
|
579
|
582
|
|
580
|
583
|
taOrgAccount.getCertificateList().forEach(e -> {
|
|
@@ -602,7 +605,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
602
|
605
|
* @return
|
603
|
606
|
*/
|
604
|
607
|
private TaOrgRefundApplication assembleRefundApplication(Integer userId, String operateType, TaOrgRefundApplication refundApplication) {
|
605
|
|
- TaUser taUser = selectUserById(userId);
|
|
608
|
+ SysUser taUser = selectUserById(userId);
|
606
|
609
|
TaOrgRefundApplication taOrgRefundApplication = new TaOrgRefundApplication();
|
607
|
610
|
taOrgRefundApplication.setAuditorId(userId);
|
608
|
611
|
taOrgRefundApplication.setAuditorName(taUser.getUserName());
|
|
@@ -634,12 +637,12 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
634
|
637
|
* @param userId
|
635
|
638
|
* @return
|
636
|
639
|
*/
|
637
|
|
- public TaUser selectUserById(Integer userId) {
|
|
640
|
+ public SysUser selectUserById(Integer userId) {
|
638
|
641
|
//获取操作人
|
639
|
|
- QueryWrapper<TaUser> taUserQueryWrapper = new QueryWrapper<>();
|
640
|
|
- taUserQueryWrapper.eq("user_id", userId);
|
641
|
|
- TaUser taUser = taUserMapper.selectOne(taUserQueryWrapper);
|
642
|
|
- return taUser;
|
|
642
|
+ QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
|
|
643
|
+ sysUserQueryWrapper.eq("user_id", userId);
|
|
644
|
+ SysUser sysUser = sysUserMapper.selectOne(sysUserQueryWrapper);
|
|
645
|
+ return sysUser;
|
643
|
646
|
}
|
644
|
647
|
|
645
|
648
|
}
|