master
Guo YuKun 2024-03-24 19:45:48 +08:00
parent 0d0f85d11e
commit d60038ed56
12 changed files with 21 additions and 31 deletions

View File

@ -22,4 +22,7 @@ public class AskBuyRequest {
@TableField("addr_id") @TableField("addr_id")
private Long addrId; //三级联动 private Long addrId; //三级联动
private Integer pageNum=1;
private Integer pageSize=3;
} }

View File

@ -20,5 +20,8 @@ public class AskRentRequest {
private Long dictionaryTypeId; //求租类型 private Long dictionaryTypeId; //求租类型
@TableField("addr_id") @TableField("addr_id")
private Long addrId; //三级联动 private Long addrId; //三级联动
private Integer pageNum=1;
private Integer pageSize=3;
} }

View File

@ -46,4 +46,7 @@ public class GroupRequest {
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime; //修改时间 private Date updateTime; //修改时间
private Long isDelete; private Long isDelete;
private Integer pageNum=1;
private Integer pageSize=5;
} }

View File

@ -3,6 +3,7 @@ package com.bwie.gateway.config;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.Data; import lombok.Data;
import lombok.extern.log4j.Log4j2;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;

View File

@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
import com.bwie.common.result.Result; import com.bwie.common.result.Result;
import com.bwie.common.utils.StringUtils; import com.bwie.common.utils.StringUtils;
import lombok.extern.log4j.Log4j2;
import org.springframework.core.io.buffer.DataBuffer; import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;

View File

@ -10,4 +10,6 @@ import org.apache.ibatis.annotations.Mapper;
public interface BackGroundMapper{ public interface BackGroundMapper{
} }

View File

@ -10,4 +10,7 @@ import org.springframework.stereotype.Service;
*/ */
@Service @Service
public class BackGroundServiceImpl implements BackGroundService { public class BackGroundServiceImpl implements BackGroundService {
} }

View File

@ -1,5 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bwie.background.mapper.AskBuyMapper">
</mapper>

View File

@ -1,6 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bwie.background.mapper.AskRentMapper">
<select id="shouList" resultType="com.bwie.common.domain.AskRent"></select>
</mapper>

View File

@ -68,6 +68,8 @@ public class EsAskBuyServiceImpl extends ServiceImpl<EsAskBuyMapper, AskBuy> imp
SearchRequest searchRequest = new SearchRequest("askbuy"); SearchRequest searchRequest = new SearchRequest("askbuy");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
sourceBuilder.from((askBuyRequest.getPageNum()-1)*askBuyRequest.getPageSize());
sourceBuilder.size(arrayList.size());
sourceBuilder.query(boolQueryBuilder); sourceBuilder.query(boolQueryBuilder);
searchRequest.source(sourceBuilder); searchRequest.source(sourceBuilder);
try { try {
@ -86,5 +88,4 @@ public class EsAskBuyServiceImpl extends ServiceImpl<EsAskBuyMapper, AskBuy> imp
} }
return Result.success(arrayList); return Result.success(arrayList);
} }
} }

View File

@ -31,19 +31,12 @@ import java.util.List;
*/ */
@Service @Service
public class EsAskRentServiceImpl extends ServiceImpl<EsAskRentMapper, AskRent> implements EsAskRentService { public class EsAskRentServiceImpl extends ServiceImpl<EsAskRentMapper, AskRent> implements EsAskRentService {
private final RedisCache redisCache; private final RedisCache redisCache;
private final RestHighLevelClient client; private final RestHighLevelClient client;
public EsAskRentServiceImpl(RedisCache redisCache, RestHighLevelClient client) { public EsAskRentServiceImpl(RedisCache redisCache, RestHighLevelClient client) {
this.redisCache = redisCache; this.redisCache = redisCache;
this.client = client; this.client = client;
} }
@Override @Override
public void shouListt(List<AskRent> list) { public void shouListt(List<AskRent> list) {
try { try {
@ -60,7 +53,6 @@ public class EsAskRentServiceImpl extends ServiceImpl<EsAskRentMapper, AskRent>
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
//求购的链表 //求购的链表
@Override @Override
public Result shouRentList(AskRentRequest askRentRequest){ public Result shouRentList(AskRentRequest askRentRequest){
@ -68,6 +60,8 @@ public class EsAskRentServiceImpl extends ServiceImpl<EsAskRentMapper, AskRent>
SearchRequest searchRequest = new SearchRequest("askrent"); SearchRequest searchRequest = new SearchRequest("askrent");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder(); SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery(); BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
sourceBuilder.from((askRentRequest.getPageNum()-1)*askRentRequest.getPageSize());
sourceBuilder.size(askRentRequest.getPageSize());
sourceBuilder.query(boolQueryBuilder); sourceBuilder.query(boolQueryBuilder);
searchRequest.source(sourceBuilder); searchRequest.source(sourceBuilder);
try { try {
@ -85,6 +79,4 @@ public class EsAskRentServiceImpl extends ServiceImpl<EsAskRentMapper, AskRent>
} }
return Result.success(arrayList); return Result.success(arrayList);
} }
} }

View File

@ -1,8 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bwie.group.mapper.GroupMapper">
<select id="groupList" resultType="com.bwie.common.domain.Group" parameterType="java.lang.Integer">
select * from t_group
</select>
</mapper>