添加mqtt

liulin

2025-07-03 fb2f11d7d502ceacbe7fbed176bea4ab0f152f69

 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);
    }
}