添加mqtt

liulin

2025-07-03 fb2f11d7d502ceacbe7fbed176bea4ab0f152f69

 src/main/java/com/lunhan/water/repository/impl/UserLoginMapperImpl.java

@@ -1,25 +1,25 @@
/**
#                                                    __----~~~~~~~~~~~------___
#                                   .  .   ~~//====......          __--~ ~~
#                   -.            \_|//     |||\\  ~~~~~~::::... /~
#                ___-==_       _-~o~  \/    |||  \\            _/~~-
#        __---~~~.==~||\=_    -_--~/_-~|-   |\\   \\        _/~
#    _-~~     .=~    |  \\-_    '-~7  /-   /  ||    \      /
#  .~       .~       |   \\ -_    /  /-   /   ||      \   /
# /  ____  /         |     \\ ~-_/  /|- _/   .||       \ /
# |~~    ~~|--~~~~--_ \     ~==-/   | \~--===~~        .\
#          '         ~-|      /|    |-~\~~       __--~~
#                      |-~~-_/ |    |   ~\_   _-~            /\
#                           /  \     \__   \/~                \__
#                       _--~ _/ | .-~~____--~-/                  ~~==.
#                      ((->/~   '.|||' -_|    ~~-/ ,              . _||
#                                 -_     ~\      ~~---l__i__i__i--~~_/
#                                 _-~-__   ~)  \--______________--~~
#                               //.-~~~-~_--~- |-------~~~~~~~~
#                                      //.-~~~--\
#                  神兽保佑
#                  永无BUG！
*/
 #                                                    __----~~~~~~~~~~~------___
 #                                   .  .   ~~//====......          __--~ ~~
 #                   -.            \_|//     |||\\  ~~~~~~::::... /~
 #                ___-==_       _-~o~  \/    |||  \\            _/~~-
 #        __---~~~.==~||\=_    -_--~/_-~|-   |\\   \\        _/~
 #    _-~~     .=~    |  \\-_    '-~7  /-   /  ||    \      /
 #  .~       .~       |   \\ -_    /  /-   /   ||      \   /
 # /  ____  /         |     \\ ~-_/  /|- _/   .||       \ /
 # |~~    ~~|--~~~~--_ \     ~==-/   | \~--===~~        .\
 #          '         ~-|      /|    |-~\~~       __--~~
 #                      |-~~-_/ |    |   ~\_   _-~            /\
 #                           /  \     \__   \/~                \__
 #                       _--~ _/ | .-~~____--~-/                  ~~==.
 #                      ((->/~   '.|||' -_|    ~~-/ ,              . _||
 #                                 -_     ~\      ~~---l__i__i__i--~~_/
 #                                 _-~-__   ~)  \--______________--~~
 #                               //.-~~~-~_--~- |-------~~~~~~~~
 #                                      //.-~~~--\
 #                  神兽保佑
 #                  永无BUG！
 */
package com.lunhan.water.repository.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -33,6 +33,7 @@
import org.springframework.stereotype.Repository;

import java.util.List;

import com.lunhan.water.entity.search.SearchUserLogin;
import com.lunhan.water.repository.mapper.UserLoginMapper;
import com.lunhan.water.repository.po.UserLoginPO;
@@ -43,104 +44,118 @@
 */
@Repository
public class UserLoginMapperImpl extends BasicMapperImpl<UserLoginPO, UserLoginMapper> {
   UserLoginMapperImpl(UserLoginMapper mapper) {
      super(mapper);
   }
    UserLoginMapperImpl(UserLoginMapper mapper) {
        super(mapper);
    }

   @Override
   public PagerResult<UserLoginPO> search(SearchBasicDTO request) {
      // 还原查询条件真实类型
      SearchUserLogin search = (SearchUserLogin)request;
      // 查询条件
      LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
      // 非逻辑删除
      queryWrapper.eq(UserLoginPO::getIsDelete, EYesOrNo.NO.getValue());
      // 状态
      //queryWrapper.eq(NumericUtil.tryParseInt(search.getStatus()).compareTo(0) > 0, UserLoginPO::getStatus, search.getStatus());
      // 状态列表
      //queryWrapper.in(ListUtil.isNotNullOrEmpty(search.getListStatus()), UserLoginPO::getStatus, search.getListStatus());
    @Override
    public PagerResult<UserLoginPO> search(SearchBasicDTO request) {
        // 还原查询条件真实类型
        SearchUserLogin search = (SearchUserLogin) request;
        // 查询条件
        LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
        // 非逻辑删除
        queryWrapper.eq(UserLoginPO::getIsDelete, EYesOrNo.NO.getValue());
        // 状态
        //queryWrapper.eq(NumericUtil.tryParseInt(search.getStatus()).compareTo(0) > 0, UserLoginPO::getStatus, search.getStatus());
        // 状态列表
        //queryWrapper.in(ListUtil.isNotNullOrEmpty(search.getListStatus()), UserLoginPO::getStatus, search.getListStatus());

      // 数据创建时间-起始
      queryWrapper.ge(NumericUtil.tryParseLong(search.getCreateTimeStart()).compareTo(0L) > 0, UserLoginPO::getCreateTime, search.getCreateTimeStart());
      // 数据创建时间-截止
      queryWrapper.le(NumericUtil.tryParseLong(search.getCreateTimeEnd()).compareTo(0L) > 0, UserLoginPO::getCreateTime, search.getCreateTimeEnd());
      // 关键字
      //if (StringUtil.isNotNullOrEmpty(search.getKeywords())) {
      //   queryWrapper.and(q ->
      //      q.like(UserLoginPO::getName, search.getKeywords())
      //      .or().like(UserLoginPO::getPhone, search.getKeywords())
      //   );
      //}
        // 数据创建时间-起始
        queryWrapper.ge(NumericUtil.tryParseLong(search.getCreateTimeStart()).compareTo(0L) > 0, UserLoginPO::getCreateTime, search.getCreateTimeStart());
        // 数据创建时间-截止
        queryWrapper.le(NumericUtil.tryParseLong(search.getCreateTimeEnd()).compareTo(0L) > 0, UserLoginPO::getCreateTime, search.getCreateTimeEnd());
        // 关键字
        //if (StringUtil.isNotNullOrEmpty(search.getKeywords())) {
        //   queryWrapper.and(q ->
        //      q.like(UserLoginPO::getName, search.getKeywords())
        //      .or().like(UserLoginPO::getPhone, search.getKeywords())
        //   );
        //}

      // 排序处理
      if (ListUtil.isNotNullOrEmpty(search.getOrderBy())) {
         for (OrderByDTO item : search.getOrderBy()) {
            EOrderBy orderBy = EOrderBy.getByValue(item.getOrderBy());
            // 顺序排序
            if (item.getIsAsc()) {
               switch (orderBy) {
                  // 主键
                  case ID:
                     queryWrapper.orderByAsc(UserLoginPO::getId);
                     break;
                  // 数据创建时间
                  case CREATE_TIME:
                     queryWrapper.orderByAsc(UserLoginPO::getCreateTime);
                     break;
                  // 最后更新时间
                  case UPDATE_TIME:
                     queryWrapper.orderByAsc(UserLoginPO::getUpdateTime);
                     break;
               }
            } else {
               // 倒叙排序
               switch (orderBy) {
                  // 主键
                  case ID:
                     queryWrapper.orderByDesc(UserLoginPO::getId);
                     break;
                  // 数据创建时间
                  case CREATE_TIME:
                     queryWrapper.orderByDesc(UserLoginPO::getCreateTime);
                     break;
                  // 最后更新时间
                  case UPDATE_TIME:
                     queryWrapper.orderByDesc(UserLoginPO::getUpdateTime);
                     break;
               }
            }
         }
      } else {
         queryWrapper.orderByDesc(UserLoginPO::getId);
      }
      Page<UserLoginPO> pageResult = super.selectPage(new Page<>(search.getPage(), search.getLimit()), queryWrapper);
      return new PagerResult<>(pageResult.getSize(), pageResult.getCurrent(), pageResult.getTotal(), pageResult.getRecords());
   }
        // 排序处理
        if (ListUtil.isNotNullOrEmpty(search.getOrderBy())) {
            for (OrderByDTO item : search.getOrderBy()) {
                EOrderBy orderBy = EOrderBy.getByValue(item.getOrderBy());
                // 顺序排序
                if (item.getIsAsc()) {
                    switch (orderBy) {
                        // 主键
                        case ID:
                            queryWrapper.orderByAsc(UserLoginPO::getId);
                            break;
                        // 数据创建时间
                        case CREATE_TIME:
                            queryWrapper.orderByAsc(UserLoginPO::getCreateTime);
                            break;
                        // 最后更新时间
                        case UPDATE_TIME:
                            queryWrapper.orderByAsc(UserLoginPO::getUpdateTime);
                            break;
                    }
                } else {
                    // 倒叙排序
                    switch (orderBy) {
                        // 主键
                        case ID:
                            queryWrapper.orderByDesc(UserLoginPO::getId);
                            break;
                        // 数据创建时间
                        case CREATE_TIME:
                            queryWrapper.orderByDesc(UserLoginPO::getCreateTime);
                            break;
                        // 最后更新时间
                        case UPDATE_TIME:
                            queryWrapper.orderByDesc(UserLoginPO::getUpdateTime);
                            break;
                    }
                }
            }
        } else {
            queryWrapper.orderByDesc(UserLoginPO::getId);
        }
        Page<UserLoginPO> pageResult = super.selectPage(new Page<>(search.getPage(), search.getLimit()), queryWrapper);
        return new PagerResult<>(pageResult.getSize(), pageResult.getCurrent(), pageResult.getTotal(), pageResult.getRecords());
    }

   public Boolean add(UserLoginPO item) {
      int rowCount = super.insert(item);
      return rowCount == 1;
   }
    public Boolean add(UserLoginPO item) {
        int rowCount = super.insert(item);
        return rowCount == 1;
    }

   public Boolean addNotIncrement(UserLoginPO item) {
      int rowCount = super.insert(item);
      return rowCount == 1;
   }
    public Boolean addNotIncrement(UserLoginPO item) {
        int rowCount = super.insert(item);
        return rowCount == 1;
    }

   public UserLoginPO getById(Long id) {
      return super.get(id);
   }
   public UserLoginPO get4Openid(String openId) {
      LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
      queryWrapper.eq(UserLoginPO::getWxOpenId, openId);
      return DB.selectOne(queryWrapper);
   }
   public UserLoginPO get4UserName(String userName) {
      LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
      queryWrapper.eq(UserLoginPO::getUserName, userName);
      return DB.selectOne(queryWrapper);
   }
   public List<UserLoginPO> getListById(List<Long> listId) {
      return super.getList(listId);
   }
    public UserLoginPO getById(Long id) {
        return super.get(id);
    }

    public UserLoginPO get4Openid(String openId) {
        LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
        queryWrapper.eq(UserLoginPO::getWxOpenId, openId);
        return DB.selectOne(queryWrapper);
    }

    public UserLoginPO get4UserName(String userName) {
        LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
        queryWrapper.eq(UserLoginPO::getUserName, userName);
        return DB.selectOne(queryWrapper);
    }
    public UserLoginPO get4UserCode(String userCode) {
        LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
        queryWrapper.eq(UserLoginPO::getUserCode, userCode);
        return DB.selectOne(queryWrapper);
    }
    public UserLoginPO getOrderByDesc() {
        LambdaQueryWrapper<UserLoginPO> queryWrapper = this.query();
        queryWrapper.orderByDesc(UserLoginPO::getUserCode);
        queryWrapper.last("limit 1");
        return DB.selectOne(queryWrapper);
    }

    public List<UserLoginPO> getListById(List<Long> listId) {
        return super.getList(listId);
    }
}