zt/canteen
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug 修改

Browse Source
This commit is contained in:
qjq
2024-11-05 15:04:37 +08:00
parent 5cd95b77c2
commit 5ff25b9b8f
2 changed files with 25 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/job/OrderSpaceCapsuleJob.java
View File

@ -1,6 +1,7 @@
package cn.iocoder.yudao.module.member.job; package cn.iocoder.yudao.module.member.job;
import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.util.ObjUtil;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX; import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler; import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
@ -17,6 +18,7 @@ import javax.annotation.Resource;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit; import java.time.temporal.ChronoUnit;
import java.util.List; import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@ -36,12 +38,13 @@ public class OrderSpaceCapsuleJob implements JobHandler {
public String execute(String param) throws Exception { public String execute(String param) throws Exception {
List<OrderSpaceCapsuleDO> orderSpaceCapsuleDOS = orderSpaceCapsuleMapper.selectList(new LambdaQueryWrapperX<OrderSpaceCapsuleDO>() List<OrderSpaceCapsuleDO> orderSpaceCapsuleDOS = orderSpaceCapsuleMapper.selectList(new LambdaQueryWrapperX<OrderSpaceCapsuleDO>()
.eq(OrderSpaceCapsuleDO::getStatus, SpaceCapsuleOrderEnum.SPACE_CAPSULE_ORDER_ENUM_IN_USE.getCode())); .eq(OrderSpaceCapsuleDO::getStatus, SpaceCapsuleOrderEnum.SPACE_CAPSULE_ORDER_ENUM_IN_USE.getCode()));
if(orderSpaceCapsuleDOS==null){ if(ObjUtil.isEmpty(orderSpaceCapsuleDOS)){
log.info("订单还在有效期内"); log.info("订单还在有效期内");
return "太空舱订单扣款,订单还在有效期内"; return "太空舱订单扣款,订单还在有效期内";
} }else{
//获得到需要扣款的数据 //获得到需要扣款的数据
List<OrderSpaceCapsuleDO> collect = orderSpaceCapsuleDOS.stream().map(m -> { List<OrderSpaceCapsuleDO> collect = orderSpaceCapsuleDOS.stream()
.map(m -> {
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
LocalDateTime orderStartTime = m.getOrderStartTime(); LocalDateTime orderStartTime = m.getOrderStartTime();
int t = m.getComboNum() * m.getComboMinutes(); int t = m.getComboNum() * m.getComboMinutes();
@ -50,7 +53,9 @@ public class OrderSpaceCapsuleJob implements JobHandler {
return m; return m;
} }
return null; return null;
}).collect(Collectors.toList()); })
.filter(Objects::nonNull)
.collect(Collectors.toList());
log.info("太空舱订单扣款数量为{}",collect.size()); log.info("太空舱订单扣款数量为{}",collect.size());
for (OrderSpaceCapsuleDO aDo : collect) { for (OrderSpaceCapsuleDO aDo : collect) {
aDo.setStatus(SpaceCapsuleOrderEnum.SPACE_CAPSULE_ORDER_ENUM_DONE.getCode()); aDo.setStatus(SpaceCapsuleOrderEnum.SPACE_CAPSULE_ORDER_ENUM_DONE.getCode());
@ -59,3 +64,4 @@ public class OrderSpaceCapsuleJob implements JobHandler {
return "太空舱订单扣款数量为："+collect.size(); return "太空舱订单扣款数量为："+collect.size();
} }
} }
}

2
yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/orderspacecapsule/OrderSpaceCapsuleServiceImpl.java
View File

@ -409,7 +409,7 @@ public class OrderSpaceCapsuleServiceImpl implements OrderSpaceCapsuleService {
try { try {
ImageIO.write(qrImage, "png", baos); ImageIO.write(qrImage, "png", baos);
byte[] imageBytes = baos.toByteArray(); byte[] imageBytes = baos.toByteArray();
return Base64.getEncoder().encodeToString(imageBytes); return "data:image/png;base64,"+Base64.getEncoder().encodeToString(imageBytes);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
} }