|
@@ -216,6 +216,16 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
216
|
216
|
return responseBean;
|
217
|
217
|
}
|
218
|
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
|
+
|
219
|
229
|
// 计算实付金额
|
220
|
230
|
Integer realAmount = calculateRealAmount(amount);
|
221
|
231
|
|
|
@@ -254,13 +264,32 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
254
|
264
|
return responseBean;
|
255
|
265
|
}
|
256
|
266
|
|
257
|
|
- // 3.请求微信接口获取支付二维码
|
|
267
|
+ // 3.创建账户消费流水表信息
|
|
268
|
+ TaOrgAccountDetailedList taOrgAccountDetailedList = new TaOrgAccountDetailedList();
|
|
269
|
+ taOrgAccountDetailedList.setAccountId(taOrgAccount.getAccountId());
|
|
270
|
+ taOrgAccountDetailedList.setOrgId(orgId);
|
|
271
|
+ taOrgAccountDetailedList.setAmount(amount);
|
|
272
|
+ taOrgAccountDetailedList.setSignType(1);
|
|
273
|
+ taOrgAccountDetailedList.setOrderId(taOrgOrder.getOrderId());
|
|
274
|
+ taOrgAccountDetailedList.setRemark("线上充值");
|
|
275
|
+ taOrgAccountDetailedList.setStatus(CommConstant.STATUS_NORMAL);
|
|
276
|
+ taOrgAccountDetailedList.setUserId(userId);
|
|
277
|
+ taOrgAccountDetailedList.setUserName(taUser.getUserName());
|
|
278
|
+ taOrgAccountDetailedList.setCreateDate(LocalDateTime.now());
|
|
279
|
+ if (taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList) < 1) {
|
|
280
|
+ taOrgOrderMapper.deleteById(taOrgOrder.getOrderId());
|
|
281
|
+ taOrgOrderDetailMapper.deleteById(taOrgOrderDetail.getSerialNo());
|
|
282
|
+ responseBean.addError("fail");
|
|
283
|
+ return responseBean;
|
|
284
|
+ }
|
|
285
|
+
|
|
286
|
+ // 4.请求微信接口获取支付二维码
|
258
|
287
|
ResponseBean payResult = payUnifiedOrder(taOrgOrder, ip);
|
259
|
288
|
if (ResponseBean.CODE_SUCCESS != payResult.getCode()) {
|
260
|
289
|
return payResult;
|
261
|
290
|
}
|
262
|
291
|
|
263
|
|
- // 4.发送短信
|
|
292
|
+ // 5.发送短信
|
264
|
293
|
ExecutorService threadPool = Executors.newCachedThreadPool();
|
265
|
294
|
threadPool.execute(() -> {
|
266
|
295
|
List<TaContact> taContacts = taOrgAccountService.selectSmsContactUser();
|
|
@@ -374,12 +403,30 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
374
|
403
|
return responseBean;
|
375
|
404
|
}
|
376
|
405
|
|
|
406
|
+ // 6.创建账户消费流水表信息
|
|
407
|
+ TaOrgAccountDetailedList taOrgAccountDetailedList = new TaOrgAccountDetailedList();
|
|
408
|
+ taOrgAccountDetailedList.setAccountId(taOrgAccount.getAccountId());
|
|
409
|
+ taOrgAccountDetailedList.setOrgId(orgId);
|
|
410
|
+ taOrgAccountDetailedList.setAmount(amount);
|
|
411
|
+ taOrgAccountDetailedList.setSignType(-1);
|
|
412
|
+ taOrgAccountDetailedList.setOrderId(taOrgOrder.getOrderId());
|
|
413
|
+ taOrgAccountDetailedList.setRemark("线上申请退款");
|
|
414
|
+ taOrgAccountDetailedList.setStatus(CommConstant.STATUS_NORMAL);
|
|
415
|
+ taOrgAccountDetailedList.setUserId(userId);
|
|
416
|
+ taOrgAccountDetailedList.setUserName(taUser.getUserName());
|
|
417
|
+ taOrgAccountDetailedList.setCreateDate(LocalDateTime.now());
|
|
418
|
+ if (taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList) < 1) {
|
|
419
|
+ taOrgOrderMapper.deleteById(taOrgOrder.getOrderId());
|
|
420
|
+ taOrgOrderDetailMapper.deleteById(taOrgOrderDetail.getSerialNo());
|
|
421
|
+ taOrgAccountBlockedMapper.deleteById(taOrgAccountBlocked.getSerialNo());
|
|
422
|
+ responseBean.addError("fail");
|
|
423
|
+ return responseBean;
|
|
424
|
+ }
|
377
|
425
|
|
378
|
|
-
|
379
|
|
- // 6.更新账户新金额
|
|
426
|
+ // 7.更新账户新金额
|
380
|
427
|
taOrgAccountMapper.updateAvailableBalanceById(taOrgAccount.getAccountId(), amount);
|
381
|
428
|
|
382
|
|
- // 7.发送短信
|
|
429
|
+ // 8.发送短信
|
383
|
430
|
ExecutorService threadPool = Executors.newCachedThreadPool();
|
384
|
431
|
threadPool.execute(() -> {
|
385
|
432
|
List<TaContact> taContacts = taOrgAccountService.selectSmsContactUser();
|
|
@@ -395,7 +442,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
395
|
442
|
}
|
396
|
443
|
|
397
|
444
|
@Override
|
398
|
|
- public ResponseBean listCzOrderByCondition(Integer pageNum, Integer pageSize, LocalDate payStartTime, LocalDate payEndTime,
|
|
445
|
+ public ResponseBean listCzOrderByCondition(Integer pageNum, Integer pageSize, LocalDateTime payStartTime, LocalDateTime payEndTime,
|
399
|
446
|
String orderId, String tradeNo, String wxOrderId, Boolean isOffline, String tradingStatus, Integer orgId) {
|
400
|
447
|
ResponseBean responseBean = new ResponseBean();
|
401
|
448
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
|
@@ -420,7 +467,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
420
|
467
|
}
|
421
|
468
|
|
422
|
469
|
@Override
|
423
|
|
- public void exportCzOrderByCondition(LocalDate payStartTime, LocalDate payEndTime, String orderId, String tradeNo,
|
|
470
|
+ public void exportCzOrderByCondition(LocalDateTime payStartTime, LocalDateTime payEndTime, String orderId, String tradeNo,
|
424
|
471
|
String wxOrderId, Boolean isOffline, String tradingStatus, Integer orgId, HttpServletResponse response) throws Exception {
|
425
|
472
|
response.setContentType("application/octet-stream");
|
426
|
473
|
response.setCharacterEncoding("utf-8");
|
|
@@ -431,7 +478,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
431
|
478
|
}
|
432
|
479
|
|
433
|
480
|
@Override
|
434
|
|
- public ResponseBean listRefundOrderByCondition(Integer pageNum, Integer pageSize, LocalDate refundStartTime, LocalDate refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId) {
|
|
481
|
+ public ResponseBean listRefundOrderByCondition(Integer pageNum, Integer pageSize, LocalDateTime refundStartTime, LocalDateTime refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId) {
|
435
|
482
|
ResponseBean responseBean = new ResponseBean();
|
436
|
483
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
437
|
484
|
pg = taOrgOrderMapper.listRefundOrderByCondition(pg, refundStartTime, refundEndTime, orderId, wxOrderId, tradeNo, auditStatus, orgId);
|
|
@@ -456,7 +503,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
456
|
503
|
}
|
457
|
504
|
|
458
|
505
|
@Override
|
459
|
|
- public void exportRefundOrderByCondition(LocalDate refundStartTime, LocalDate refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
|
506
|
+ public void exportRefundOrderByCondition(LocalDateTime refundStartTime, LocalDateTime refundEndTime, String orderId, String auditStatus, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
460
|
507
|
response.setContentType("application/octet-stream");
|
461
|
508
|
response.setCharacterEncoding("utf-8");
|
462
|
509
|
List<AccountRefundRecordExport> records = taOrgOrderMapper.exportRefundOrderByCondition(refundStartTime, refundEndTime, orderId, wxOrderId, tradeNo, auditStatus, orgId);
|
|
@@ -474,7 +521,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
474
|
521
|
}
|
475
|
522
|
|
476
|
523
|
@Override
|
477
|
|
- 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) {
|
|
524
|
+ 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) {
|
478
|
525
|
ResponseBean responseBean = new ResponseBean();
|
479
|
526
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
480
|
527
|
responseBean.addSuccess(taOrgOrderMapper.listConsumeOrderByCondition(pg, startTime, endTime, orderId, tradingStatus, consumeType, phone, wxOrderId, tradeNo, orgId));
|
|
@@ -482,7 +529,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
482
|
529
|
}
|
483
|
530
|
|
484
|
531
|
@Override
|
485
|
|
- 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 {
|
|
532
|
+ 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 {
|
486
|
533
|
response.setContentType("application/octet-stream");
|
487
|
534
|
response.setCharacterEncoding("utf-8");
|
488
|
535
|
List<AccountConsumeRecordExport> records = taOrgOrderMapper.exportConsumeOrderByCondition(startTime, endTime, orderId, tradingStatus, consumeType, wxOrderId, tradeNo, phone, orgId);
|