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/host/controller/user/UserLoginController.java | 21 +++++++++++++++++++++
1 files changed, 21 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/lunhan/water/host/controller/user/UserLoginController.java b/src/main/java/com/lunhan/water/host/controller/user/UserLoginController.java
index e16f758..a640838 100644
--- a/src/main/java/com/lunhan/water/host/controller/user/UserLoginController.java
+++ b/src/main/java/com/lunhan/water/host/controller/user/UserLoginController.java
@@ -22,6 +22,7 @@
*/
package com.lunhan.water.host.controller.user;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.lunhan.water.common.ConstantFactory;
@@ -44,10 +45,13 @@
import com.lunhan.water.entity.request.ReqListId;
import com.lunhan.water.entity.request.ReqNeedCode;
import com.lunhan.water.entity.request.ReqUserLogin;
+import com.lunhan.water.entity.search.SearchRechargeOrder;
import com.lunhan.water.entity.weixin.WeiXinUserDto;
import com.lunhan.water.host.BasicController;
import com.lunhan.water.host.api.NonLogin;
+import com.lunhan.water.repository.impl.UserLoginMapperImpl;
import com.lunhan.water.repository.po.UserLoginPO;
+import com.lunhan.water.repository.vo.RechargeOrderVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@@ -69,6 +73,8 @@
public class UserLoginController extends BasicController {
@Autowired
private UserLoginService userLoginService;
+ @Autowired
+ private UserLoginMapperImpl userLoginMapper;
/**
* 微信小程序授权
* @param request 请求参数
@@ -101,6 +107,13 @@
reqCreateUser.setHeadImg(userInfo.getHeadImgUrl());
reqCreateUser.setPhone("");
reqCreateUser.setComment("");
+ UserLoginPO userLoginPO = userLoginMapper.getOrderByDesc();
+ if(Objects.nonNull(userLoginPO)){
+ int userCode = Integer.parseInt(userLoginPO.getUserCode()) + 1;
+ reqCreateUser.setUserCode(String.valueOf(userCode));
+ }else {
+ reqCreateUser.setUserCode("10001");
+ }
ExecutedResult<Long> createAdmin = userLoginService.create(reqCreateUser);
if (createAdmin.isFailed()) {
return ExecutedResult.failed(createAdmin.getMsg());
@@ -190,4 +203,12 @@
//#endregion
return userLoginService.login(request);
}
+ /**
+ * 查询[用户]
+ * @author lin.liu
+ */
+ @PostMapping(value = "search")
+ public ExecutedResult<PagerResult<UserLoginVO>> search(@RequestBody SearchUserLogin request) {
+ return userLoginService.search(request);
+ }
}
--
Gitblit v1.9.3