|
@@ -82,6 +82,9 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
82
|
82
|
@Autowired
|
83
|
83
|
private TaOrgAccountCertificateMapper taOrgAccountCertificateMapper;
|
84
|
84
|
|
|
85
|
+ @Autowired
|
|
86
|
+ private TaUserMapper taUserMapper;
|
|
87
|
+
|
85
|
88
|
@Autowired
|
86
|
89
|
private SysUserMapper sysUserMapper;
|
87
|
90
|
|
|
@@ -173,7 +176,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
173
|
176
|
ResponseBean responseBean = new ResponseBean();
|
174
|
177
|
|
175
|
178
|
// 获取下单人名称
|
176
|
|
- SysUser taUser = sysUserMapper.selectById(userId);
|
|
179
|
+ TaUser taUser = taUserMapper.selectById(userId);
|
177
|
180
|
if (taUser == null) {
|
178
|
181
|
responseBean.addError("fail");
|
179
|
182
|
return responseBean;
|
|
@@ -237,13 +240,29 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
237
|
240
|
ResponseBean responseBean = new ResponseBean();
|
238
|
241
|
|
239
|
242
|
// 获取下单人名称
|
240
|
|
- SysUser taUser = sysUserMapper.selectById(userId);
|
|
243
|
+ TaUser taUser = taUserMapper.selectById(userId);
|
241
|
244
|
if (taUser == null) {
|
242
|
245
|
responseBean.addError("fail");
|
243
|
246
|
return responseBean;
|
244
|
247
|
}
|
245
|
248
|
|
246
|
|
- // 1.创建订单主表信息
|
|
249
|
+ // 查询账户信息
|
|
250
|
+ QueryWrapper<TaOrgAccount> orgAccountQueryWrapper = new QueryWrapper<>();
|
|
251
|
+ orgAccountQueryWrapper.eq("org_id",orgId);
|
|
252
|
+ orgAccountQueryWrapper.eq("status",CommConstant.STATUS_NORMAL);
|
|
253
|
+ TaOrgAccount taOrgAccount = taOrgAccountMapper.selectOne(orgAccountQueryWrapper);
|
|
254
|
+ if(taOrgAccount == null){
|
|
255
|
+ responseBean.addError("账户不存在");
|
|
256
|
+ return responseBean;
|
|
257
|
+ }
|
|
258
|
+
|
|
259
|
+ // 1.校验账户金额
|
|
260
|
+ if(amount > CommonUtils.fenToYuan(taOrgAccount.getAvailableBalance())){
|
|
261
|
+ responseBean.addError("账户可用余额不足,请稍后再试");
|
|
262
|
+ return responseBean;
|
|
263
|
+ }
|
|
264
|
+
|
|
265
|
+ // 2.创建订单主表信息
|
247
|
266
|
TaOrgOrder taOrgOrder = new TaOrgOrder();
|
248
|
267
|
taOrgOrder.setOrgId(orgId);
|
249
|
268
|
taOrgOrder.setTradeNo(CommonUtils.generateTradeNo(CommConstant.REFUND));
|
|
@@ -261,7 +280,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
261
|
280
|
return responseBean;
|
262
|
281
|
}
|
263
|
282
|
|
264
|
|
- // 2.创建订单详情表信息
|
|
283
|
+ // 3.创建订单详情表信息
|
265
|
284
|
TaOrgOrderDetail taOrgOrderDetail = new TaOrgOrderDetail();
|
266
|
285
|
taOrgOrderDetail.setOrderId(taOrgOrder.getOrderId());
|
267
|
286
|
taOrgOrderDetail.setOrgId(orgId);
|
|
@@ -276,7 +295,7 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
276
|
295
|
return responseBean;
|
277
|
296
|
}
|
278
|
297
|
|
279
|
|
- // 3.创建账户退款申请表信息
|
|
298
|
+ // 4.创建账户退款申请表信息
|
280
|
299
|
TaOrgRefundApplication taOrgRefundApplication = new TaOrgRefundApplication();
|
281
|
300
|
taOrgRefundApplication.setOrgId(orgId);
|
282
|
301
|
taOrgRefundApplication.setUserId(userId);
|
|
@@ -356,26 +375,26 @@ public class TaOrgOrderServiceImpl extends ServiceImpl<TaOrgOrderMapper, TaOrgOr
|
356
|
375
|
}
|
357
|
376
|
|
358
|
377
|
@Override
|
359
|
|
- public ResponseBean listRedPacketRecords(Integer pageNum, Integer pageSize, String phone, String activityId, String orderId, String wxOrderId, String tradeNo, Integer status, Integer orgId) {
|
|
378
|
+ public ResponseBean listRedPacketRecords(Integer pageNum, Integer pageSize, String phone, String activityId, String orderId, String wxOrderId, String tradeNo, String tradingStatus, Integer orgId) {
|
360
|
379
|
ResponseBean responseBean = new ResponseBean();
|
361
|
380
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
362
|
|
- responseBean.addSuccess(taOrgOrderMapper.listRedPacketRecords(pg, phone, activityId, orderId, wxOrderId, tradeNo, status, orgId));
|
|
381
|
+ responseBean.addSuccess(taOrgOrderMapper.listRedPacketRecords(pg, phone, activityId, orderId, wxOrderId, tradeNo, tradingStatus, orgId));
|
363
|
382
|
return responseBean;
|
364
|
383
|
}
|
365
|
384
|
|
366
|
385
|
@Override
|
367
|
|
- public ResponseBean listConsumeOrderByCondition(Integer pageNum, Integer pageSize, LocalDate startTime, LocalDate endTime, String orderId, Integer status, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId) {
|
|
386
|
+ 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) {
|
368
|
387
|
ResponseBean responseBean = new ResponseBean();
|
369
|
388
|
IPage<TaOrgOrder> pg = new Page<>(pageNum, pageSize);
|
370
|
|
- responseBean.addSuccess(taOrgOrderMapper.listConsumeOrderByCondition(pg, startTime, endTime, orderId, status, consumeType, phone, wxOrderId, tradeNo, orgId));
|
|
389
|
+ responseBean.addSuccess(taOrgOrderMapper.listConsumeOrderByCondition(pg, startTime, endTime, orderId, tradingStatus, consumeType, phone, wxOrderId, tradeNo, orgId));
|
371
|
390
|
return responseBean;
|
372
|
391
|
}
|
373
|
392
|
|
374
|
393
|
@Override
|
375
|
|
- public void exportConsumeOrderByCondition(LocalDate startTime, LocalDate endTime, String orderId, Integer status, String consumeType, String phone, String wxOrderId, String tradeNo, Integer orgId, HttpServletResponse response) throws Exception {
|
|
394
|
+ 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 {
|
376
|
395
|
response.setContentType("application/octet-stream");
|
377
|
396
|
response.setCharacterEncoding("utf-8");
|
378
|
|
- List<AccountConsumeRecordExport> records = taOrgOrderMapper.exportConsumeOrderByCondition(startTime, endTime, orderId, status, consumeType, wxOrderId, tradeNo, phone, orgId);
|
|
397
|
+ List<AccountConsumeRecordExport> records = taOrgOrderMapper.exportConsumeOrderByCondition(startTime, endTime, orderId, tradingStatus, consumeType, wxOrderId, tradeNo, phone, orgId);
|
379
|
398
|
String fileName = URLEncoder.encode("消费订单", "UTF-8");
|
380
|
399
|
response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx");
|
381
|
400
|
EasyExcel.write(response.getOutputStream(), AccountConsumeRecordExport.class).sheet("消费订单").doWrite(records);
|