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/repository/impl/UserLoginMapperImpl.java | 245 ++++++++++++++++++++++++++-----------------------
1 files changed, 130 insertions(+), 115 deletions(-)
diff --git a/src/main/java/com/lunhan/water/repository/impl/UserLoginMapperImpl.java b/src/main/java/com/lunhan/water/repository/impl/UserLoginMapperImpl.java
index 7d5c29b..4e16da9 100644
--- a/src/main/java/com/lunhan/water/repository/impl/UserLoginMapperImpl.java
+++ b/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);
+ }
}
--
Gitblit v1.9.3