|
@@ -11,6 +11,7 @@ import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
import com.zhongzheng.common.core.redis.RedisCache;
|
|
|
import com.zhongzheng.common.exception.CustomException;
|
|
|
+import com.zhongzheng.common.type.EncryptHandler;
|
|
|
import com.zhongzheng.common.utils.DateUtils;
|
|
|
import com.zhongzheng.common.utils.ServletUtils;
|
|
|
import com.zhongzheng.modules.course.domain.CourseBusiness;
|
|
@@ -28,11 +29,15 @@ import com.zhongzheng.modules.system.domain.SysTenant;
|
|
|
import com.zhongzheng.modules.system.service.ISysTenantService;
|
|
|
import com.zhongzheng.modules.system.vo.SysTenantHandleAccountVo;
|
|
|
import com.zhongzheng.modules.user.bo.SubjectStudyRecordQueryBo;
|
|
|
+import com.zhongzheng.modules.user.domain.User;
|
|
|
+import com.zhongzheng.modules.user.service.IUserHandleService;
|
|
|
import com.zhongzheng.modules.user.service.IUserService;
|
|
|
import com.zhongzheng.modules.user.service.IUserStudyRecordService;
|
|
|
import com.zhongzheng.modules.user.vo.SubjectStudyRecordVo;
|
|
|
+import com.zhongzheng.modules.user.vo.UserHandleVo;
|
|
|
import com.zhongzheng.modules.user.vo.UserVo;
|
|
|
import com.zhongzheng.modules.wx.service.IWxPayService;
|
|
|
+import org.hibernate.validator.internal.util.StringHelper;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -95,7 +100,12 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
@Override
|
|
|
public OrderHandleVo queryById(Long id) {
|
|
|
OrderHandle db = this.baseMapper.selectById(id);
|
|
|
- return BeanUtil.toBean(db, OrderHandleVo.class);
|
|
|
+ OrderHandleVo orderHandleVo = BeanUtil.toBean(db, OrderHandleVo.class);
|
|
|
+ User byIdNoTenant = iUserService.getByIdNoTenant(db.getCreateUserId());
|
|
|
+ orderHandleVo.setCreateUsername(byIdNoTenant.getRealname());
|
|
|
+ orderHandleVo.setIdCard(byIdNoTenant.getIdCard());
|
|
|
+ orderHandleVo.setTelphone(byIdNoTenant.getTelphone());
|
|
|
+ return orderHandleVo;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -116,6 +126,7 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
lqw.eq(bo.getInputFrom() != null, OrderHandle::getInputFrom, bo.getInputFrom());
|
|
|
lqw.eq(bo.getPayStatus() != null, OrderHandle::getPayStatus, bo.getPayStatus());
|
|
|
lqw.eq(bo.getGoodsType() != null, OrderHandle::getGoodsType, bo.getGoodsType());
|
|
|
+ lqw.eq(bo.getCreateUsername() != null, OrderHandle::getCreateUsername, bo.getCreateUsername());
|
|
|
return entity2Vo(this.list(lqw));
|
|
|
}
|
|
|
|
|
@@ -126,6 +137,8 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
return new ArrayList<>();
|
|
|
}
|
|
|
orderHandleVos.forEach(item -> {
|
|
|
+ item.setIdCard(EncryptHandler.decrypt(item.getIdCard()));
|
|
|
+ item.setTelphone(EncryptHandler.decrypt(item.getTelphone()));
|
|
|
//实际价格
|
|
|
item.setRealPrice(item.getPayPrice().subtract(item.getGoodsRefund()));
|
|
|
//发票
|
|
@@ -146,7 +159,7 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
item.setInvoiceStatus(invoice.getPeriodStatus());
|
|
|
} else if (invoice.getPeriodStatus() == 2) {
|
|
|
item.setInvoiceStatus(3);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
item.setInvoiceStatus(invoice.getInvoiceStatus());
|
|
|
}
|
|
|
item.setHandleRemark(invoice.getHandleRemark());
|
|
@@ -269,32 +282,32 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public String createOrder(OrderHandleAddBo bo) {
|
|
|
- String key = "SUBMIT_HANDLE:"+bo.getCreateUserId()+"-"+bo.getUserGoodsList().size();
|
|
|
+ String key = "SUBMIT_HANDLE:" + bo.getCreateUserId() + "-" + bo.getUserGoodsList().size();
|
|
|
Long keyStatus = redisCache.getCacheObject(key);
|
|
|
- if(Validator.isNotEmpty(keyStatus)&&keyStatus==100L){
|
|
|
- throw new CustomException("禁止频繁提交",667);
|
|
|
+ if (Validator.isNotEmpty(keyStatus) && keyStatus == 100L) {
|
|
|
+ throw new CustomException("禁止频繁提交", 667);
|
|
|
}
|
|
|
- redisCache.setCacheObject(key, 100L,60, TimeUnit.SECONDS);
|
|
|
+ redisCache.setCacheObject(key, 100L, 60, TimeUnit.SECONDS);
|
|
|
|
|
|
String handleOrderSn = insertByAddBo(bo);
|
|
|
String importNo = ServletUtils.getEncoded("IMPORT");
|
|
|
- Map<String,String> telMap = new HashMap<>();
|
|
|
- Map<String,String> idMap = new HashMap<>();
|
|
|
+ Map<String, String> telMap = new HashMap<>();
|
|
|
+ Map<String, String> idMap = new HashMap<>();
|
|
|
for (OrderHandleItemAddBo itemAddBo : bo.getUserGoodsList()) {
|
|
|
- if(Validator.isNotEmpty(itemAddBo.getUser().getTelphone())){
|
|
|
- if(!telMap.containsKey(itemAddBo.getUser().getTelphone())){
|
|
|
- telMap.put(itemAddBo.getUser().getTelphone(),itemAddBo.getUser().getIdCard());
|
|
|
- }else{
|
|
|
+ if (Validator.isNotEmpty(itemAddBo.getUser().getTelphone())) {
|
|
|
+ if (!telMap.containsKey(itemAddBo.getUser().getTelphone())) {
|
|
|
+ telMap.put(itemAddBo.getUser().getTelphone(), itemAddBo.getUser().getIdCard());
|
|
|
+ } else {
|
|
|
redisCache.deleteObject(key);
|
|
|
- throw new CustomException("本次名单存在手机号码"+itemAddBo.getUser().getTelphone()+"重复用户");
|
|
|
+ throw new CustomException("本次名单存在手机号码" + itemAddBo.getUser().getTelphone() + "重复用户");
|
|
|
}
|
|
|
}
|
|
|
- if(Validator.isNotEmpty(itemAddBo.getUser().getIdCard())){
|
|
|
- if(!idMap.containsKey(itemAddBo.getUser().getIdCard())){
|
|
|
- idMap.put(itemAddBo.getUser().getIdCard(),itemAddBo.getUser().getTelphone());
|
|
|
- }else{
|
|
|
+ if (Validator.isNotEmpty(itemAddBo.getUser().getIdCard())) {
|
|
|
+ if (!idMap.containsKey(itemAddBo.getUser().getIdCard())) {
|
|
|
+ idMap.put(itemAddBo.getUser().getIdCard(), itemAddBo.getUser().getTelphone());
|
|
|
+ } else {
|
|
|
redisCache.deleteObject(key);
|
|
|
- throw new CustomException("本次名单存在身份证号码"+itemAddBo.getUser().getIdCard ()+"重复用户");
|
|
|
+ throw new CustomException("本次名单存在身份证号码" + itemAddBo.getUser().getIdCard() + "重复用户");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -416,7 +429,7 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
OrderHandleQueryBo bo = new OrderHandleQueryBo();
|
|
|
bo.setOverTime(DateUtils.getNowTime());
|
|
|
List<OrderHandleOverVo> list = this.baseMapper.selectOverTimeOrderList(bo);
|
|
|
- for(OrderHandleOverVo orderHandle : list){
|
|
|
+ for (OrderHandleOverVo orderHandle : list) {
|
|
|
ServletUtils.getRequestAttributes().getResponse().setHeader("TenantId", orderHandle.getTenantId());
|
|
|
OrderHandleAddBo addBo = new OrderHandleAddBo();
|
|
|
addBo.setHandleOrderSn(orderHandle.getHandleOrderSn());
|
|
@@ -439,7 +452,7 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
if (Validator.isEmpty(orderHandle)) {
|
|
|
throw new CustomException("录单单号不存在");
|
|
|
}
|
|
|
- if (orderHandle.getPayStatus()!=-2) {
|
|
|
+ if (orderHandle.getPayStatus() != -2) {
|
|
|
throw new CustomException("非拒绝状态");
|
|
|
}
|
|
|
OrderHandle update = new OrderHandle();
|
|
@@ -640,9 +653,9 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
}
|
|
|
//退款金额
|
|
|
BigDecimal reduce = goodsRefundList.stream().map(OrderGoodsRefund::getRealRefundFee).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
- if (ObjectUtils.isNotNull(orderHandle.getRefundedPrice())){
|
|
|
+ if (ObjectUtils.isNotNull(orderHandle.getRefundedPrice())) {
|
|
|
orderHandle.setRefundedPrice(orderHandle.getRefundedPrice().add(reduce));
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
orderHandle.setRefundedPrice(reduce);
|
|
|
}
|
|
|
orderHandle.setRefundStatus(1);//已退款
|
|
@@ -655,11 +668,11 @@ public class OrderHandleServiceImpl extends ServiceImpl<OrderHandleMapper, Order
|
|
|
//是否存在发票
|
|
|
List<OrderInvoiceOrder> list = iOrderInvoiceOrderService
|
|
|
.list(new LambdaQueryWrapper<OrderInvoiceOrder>().eq(OrderInvoiceOrder::getOrderSn, orderHandle.getHandleOrderSn()));
|
|
|
- if (CollectionUtils.isNotEmpty(list)){
|
|
|
- iOrderInvoiceService.update(new LambdaUpdateWrapper<OrderInvoice>()
|
|
|
- .set(OrderInvoice::getWashStatus,1)//带冲红
|
|
|
- .set(OrderInvoice::getInvoiceStatus,4)//失效
|
|
|
- .in(OrderInvoice::getInvoiceId,list.stream().map(OrderInvoiceOrder::getInvoiceId).collect(Collectors.toList())));
|
|
|
+ if (CollectionUtils.isNotEmpty(list)) {
|
|
|
+ iOrderInvoiceService.update(new LambdaUpdateWrapper<OrderInvoice>()
|
|
|
+ .set(OrderInvoice::getWashStatus, 1)//带冲红
|
|
|
+ .set(OrderInvoice::getInvoiceStatus, 4)//失效
|
|
|
+ .in(OrderInvoice::getInvoiceId, list.stream().map(OrderInvoiceOrder::getInvoiceId).collect(Collectors.toList())));
|
|
|
}
|
|
|
break;
|
|
|
case 2://不通过
|