From fb2f11d7d502ceacbe7fbed176bea4ab0f152f69 Mon Sep 17 00:00:00 2001
From: liulin <lin.liu@88.com>
Date: 星期四, 03 七月 2025 18:17:59 +0800
Subject: [PATCH] 添加mqtt
---
src/main/java/com/lunhan/water/service/RechargeOrderService.java | 19 +++++++++++++++++--
1 files changed, 17 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/lunhan/water/service/RechargeOrderService.java b/src/main/java/com/lunhan/water/service/RechargeOrderService.java
index 7f57680..f268740 100644
--- a/src/main/java/com/lunhan/water/service/RechargeOrderService.java
+++ b/src/main/java/com/lunhan/water/service/RechargeOrderService.java
@@ -24,11 +24,18 @@
import com.lunhan.water.common.*;
import com.lunhan.water.common.enums.*;
+import com.lunhan.water.common.jwt.LoginUserDTO;
import com.lunhan.water.common.model.Tuple;
import com.lunhan.water.common.util.*;
+import com.lunhan.water.entity.enums.EPayState;
+import com.lunhan.water.entity.enums.EPayType;
+import com.lunhan.water.repository.impl.UserLoginMapperImpl;
+import com.lunhan.water.repository.po.UserLoginPO;
import org.apache.commons.lang3.BooleanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
import com.lunhan.water.repository.impl.RechargeOrderMapperImpl;
@@ -47,12 +54,20 @@
public class RechargeOrderService extends BaseService {
@Autowired
private RechargeOrderMapperImpl mapper;
+ @Autowired
+ private UserLoginMapperImpl userLoginMapper;
- public ExecutedResult<Long> create(ReqCreateRechargeOrder request) {
+ public ExecutedResult<Long> create(LoginUserDTO loginUser,ReqCreateRechargeOrder request) {
// 转换po
+ UserLoginPO user = userLoginMapper.get4Openid(loginUser.getUserId());
+ if(Objects.isNull(user)){
+ return ExecutedResult.failed("用户信息不存在!");
+ }
RechargeOrderPO item = RechargeOrderConvert.INSTANCE.toCreate(request);
// 设置状态
- //item.setStatus(EState.NORMAL.getValue());
+ item.setOrderNo("CZ"+SnowFlakeUtil.getId());
+ item.setPayState(EPayState.WAITING.getValue());
+ item.setPayType(EPayType.WX_PAY.getValue());
// 设置记录创建时间
item.setCreateTime(LocalDateTimeUtil.nowTimeStamp());
// 是否删除(逻辑删除)初始值
--
Gitblit v1.9.3