|
@@ -26,11 +26,12 @@ import com.chelvc.cloud.vehicle.server.service.DynamicContentService;
|
|
import com.chelvc.cloud.vehicle.server.service.DynamicEvaluateRecordService;
|
|
import com.chelvc.cloud.vehicle.server.service.DynamicEvaluateRecordService;
|
|
import com.chelvc.cloud.vehicle.server.service.DynamicResourceService;
|
|
import com.chelvc.cloud.vehicle.server.service.DynamicResourceService;
|
|
import com.chelvc.framework.base.exception.ResourceUnavailableException;
|
|
import com.chelvc.framework.base.exception.ResourceUnavailableException;
|
|
-import com.chelvc.framework.common.model.PagedVO;
|
|
|
|
|
|
+import com.chelvc.framework.common.model.Pagination;
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
|
+import org.apache.dubbo.config.annotation.DubboService;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -51,6 +52,7 @@ import java.util.stream.Collectors;
|
|
@Service
|
|
@Service
|
|
@Slf4j
|
|
@Slf4j
|
|
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
|
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
|
|
|
+@DubboService(interfaceClass = com.chelvc.cloud.vehicle.api.service.DynamicContentService.class)
|
|
public class DynamicContentServiceImpl implements DynamicContentService, com.chelvc.cloud.vehicle.api.service.DynamicContentService {
|
|
public class DynamicContentServiceImpl implements DynamicContentService, com.chelvc.cloud.vehicle.api.service.DynamicContentService {
|
|
private final DynamicContentMapper baseMapper;
|
|
private final DynamicContentMapper baseMapper;
|
|
@DubboReference
|
|
@DubboReference
|
|
@@ -91,8 +93,8 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public IPage<DynamicContentDTO> queryPageList(QueryDynamicContentParam param, Integer pageNum,
|
|
|
|
- Integer pageSize, Long userId) {
|
|
|
|
|
|
+ public Pagination<DynamicContentDTO> queryPageList(QueryDynamicContentParam param, Integer pageNum,
|
|
|
|
+ Integer pageSize, Long userId) {
|
|
String keyWord = param.getKeyWord();
|
|
String keyWord = param.getKeyWord();
|
|
Integer type = param.getType().getValue();
|
|
Integer type = param.getType().getValue();
|
|
Page<DynamicContentDTO> page = new Page<>(pageNum, pageSize);
|
|
Page<DynamicContentDTO> page = new Page<>(pageNum, pageSize);
|
|
@@ -109,7 +111,9 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
result = baseMapper
|
|
result = baseMapper
|
|
.queryRandom(page, queryRandomWrapper(keyWord, userId));
|
|
.queryRandom(page, queryRandomWrapper(keyWord, userId));
|
|
}
|
|
}
|
|
- return getResult(result, true, userId);
|
|
|
|
|
|
+ result = getResult(result, true, userId);
|
|
|
|
+ return Pagination.<DynamicContentDTO>builder().total(result.getTotal()).pages(result.getPages())
|
|
|
|
+ .records(result.getRecords()).build();
|
|
}
|
|
}
|
|
|
|
|
|
public IPage<DynamicContentDTO> getResult(IPage<DynamicContentDTO> result, boolean b, Long selfUserId) {
|
|
public IPage<DynamicContentDTO> getResult(IPage<DynamicContentDTO> result, boolean b, Long selfUserId) {
|
|
@@ -151,23 +155,20 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
}
|
|
}
|
|
|
|
|
|
public QueryWrapper<DynamicContent> queryAttentionWrapper(String keyWord) {
|
|
public QueryWrapper<DynamicContent> queryAttentionWrapper(String keyWord) {
|
|
- List<String> list = new ArrayList<>();
|
|
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
- lqw.eq("t1.is_deleted", 0);
|
|
|
|
|
|
+ lqw.eq("t1.deleted", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
lqw.eq("t1.status", 0);
|
|
lqw.eq("t1.status", 0);
|
|
lqw.inSql("t1.user_id",
|
|
lqw.inSql("t1.user_id",
|
|
"SELECT t2.target FROM collision_user.user_attention t2 WHERE t2.user_id = #{userId}");
|
|
"SELECT t2.target FROM collision_user.user_attention t2 WHERE t2.user_id = #{userId}");
|
|
- list.add("t1.create_time");
|
|
|
|
- list.add("t1.id");
|
|
|
|
- lqw.orderByDesc(list.toString());
|
|
|
|
|
|
+ lqw.orderByDesc("t1.create_time","t1.id");
|
|
return lqw;
|
|
return lqw;
|
|
}
|
|
}
|
|
|
|
|
|
public QueryWrapper<DynamicContent> queryRandomWrapper(String keyWord, Long userId) {
|
|
public QueryWrapper<DynamicContent> queryRandomWrapper(String keyWord, Long userId) {
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
- lqw.eq("t1.is_deleted", 0);
|
|
|
|
|
|
+ lqw.eq("t1.deleted", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
lqw.and(wq -> wq
|
|
lqw.and(wq -> wq
|
|
@@ -186,7 +187,7 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
|
|
|
|
public QueryWrapper<DynamicContent> format(QueryWrapper<DynamicContent> lqw,
|
|
public QueryWrapper<DynamicContent> format(QueryWrapper<DynamicContent> lqw,
|
|
String keyWord, Long userId) {
|
|
String keyWord, Long userId) {
|
|
- lqw.eq("t1.is_deleted", 0);
|
|
|
|
|
|
+ lqw.eq("t1.deleted", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.and(wq -> wq
|
|
lqw.and(wq -> wq
|
|
.eq("t1.examine_status", 1)
|
|
.eq("t1.examine_status", 1)
|
|
@@ -199,51 +200,41 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
.eq("t1.status", 1)
|
|
.eq("t1.status", 1)
|
|
.eq("t1.user_id", userId)));
|
|
.eq("t1.user_id", userId)));
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
lqw.like(StringUtils.isNotBlank(keyWord), "t1.text_content", keyWord);
|
|
- List<String> list = new ArrayList<>();
|
|
|
|
- list.add("t1.create_time");
|
|
|
|
- list.add("t1.id");
|
|
|
|
- lqw.orderByDesc(list.toString());
|
|
|
|
|
|
+ lqw.orderByDesc("t1.create_time","t1.id");
|
|
return lqw;
|
|
return lqw;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public PagedVO<DynamicContentDTO> queryAdminPageList(QueryAdminDynamicParam param,
|
|
|
|
|
|
+ public Pagination<DynamicContentDTO> queryAdminPageList(QueryAdminDynamicParam param,
|
|
Long pageNum, Long pageSize) {
|
|
Long pageNum, Long pageSize) {
|
|
Page<DynamicContentDTO> page = new Page<>(pageNum, pageSize);
|
|
Page<DynamicContentDTO> page = new Page<>(pageNum, pageSize);
|
|
IPage<DynamicContentDTO> result = null;
|
|
IPage<DynamicContentDTO> result = null;
|
|
if (param == null) {
|
|
if (param == null) {
|
|
- return PagedVO.build(page, DynamicContentDTO.class);
|
|
|
|
|
|
+ return new Pagination<>();
|
|
}
|
|
}
|
|
result = baseMapper
|
|
result = baseMapper
|
|
.queryAll(page, queryManagerWrapper(param));
|
|
.queryAll(page, queryManagerWrapper(param));
|
|
IPage<DynamicContentDTO> resultDto = getResult(result, false, null);
|
|
IPage<DynamicContentDTO> resultDto = getResult(result, false, null);
|
|
- PagedVO<DynamicContentDTO> vo = new PagedVO<>();
|
|
|
|
- vo.setPageSize(pageSize);
|
|
|
|
- vo.setPageNumber(pageNum);
|
|
|
|
- vo.setRecords(resultDto.getRecords());
|
|
|
|
- vo.setTotalNumber(result.getTotal());
|
|
|
|
- return vo;
|
|
|
|
|
|
+ return Pagination.<DynamicContentDTO>builder().total(result.getTotal()).pages(result.getPages())
|
|
|
|
+ .records(resultDto.getRecords()).build();
|
|
}
|
|
}
|
|
|
|
|
|
private QueryWrapper<DynamicContent> queryManagerWrapper(
|
|
private QueryWrapper<DynamicContent> queryManagerWrapper(
|
|
QueryAdminDynamicParam param) {
|
|
QueryAdminDynamicParam param) {
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
- lqw.eq("t1.is_deleted", 0);
|
|
|
|
|
|
+ lqw.eq("t1.deleted", 0);
|
|
lqw.like(StringUtils.isNotBlank(param.getKeyWord()), "t1.text_content", param.getKeyWord());
|
|
lqw.like(StringUtils.isNotBlank(param.getKeyWord()), "t1.text_content", param.getKeyWord());
|
|
lqw.ge(StringUtils.isNotBlank(param.getStartTime()), "t1.create_time", param.getStartTime());
|
|
lqw.ge(StringUtils.isNotBlank(param.getStartTime()), "t1.create_time", param.getStartTime());
|
|
lqw.le(StringUtils.isNotBlank(param.getEndTime()), "t1.create_time", param.getEndTime());
|
|
lqw.le(StringUtils.isNotBlank(param.getEndTime()), "t1.create_time", param.getEndTime());
|
|
lqw.eq(param.getExamineStatus() != null, "t1.examine_status", param.getExamineStatus());
|
|
lqw.eq(param.getExamineStatus() != null, "t1.examine_status", param.getExamineStatus());
|
|
lqw.eq(param.getExamineResult() != null, "t1.examine_result", param.getExamineResult());
|
|
lqw.eq(param.getExamineResult() != null, "t1.examine_result", param.getExamineResult());
|
|
lqw.eq(param.getPlatformStatus() != null, "t1.platform_status", param.getPlatformStatus());
|
|
lqw.eq(param.getPlatformStatus() != null, "t1.platform_status", param.getPlatformStatus());
|
|
- List<String> list = new ArrayList<>();
|
|
|
|
- list.add("t1.create_time");
|
|
|
|
- list.add("t1.id");
|
|
|
|
- lqw.orderByDesc(list.toString());
|
|
|
|
|
|
+ lqw.orderByDesc("t1.create_time","t1.id");
|
|
return lqw;
|
|
return lqw;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public IPage<DynamicContentDTO> queryUserById(Long selfUserId, Long userId, Integer pageNum, Integer pageSize) {
|
|
|
|
|
|
+ public Pagination<DynamicContentDTO> queryUserById(Long selfUserId, Long userId, Integer pageNum, Integer pageSize) {
|
|
if (userId == null) {
|
|
if (userId == null) {
|
|
return null;
|
|
return null;
|
|
}
|
|
}
|
|
@@ -255,20 +246,19 @@ public class DynamicContentServiceImpl implements DynamicContentService, com.che
|
|
//flag: 1-查看其他人;2-查看自己
|
|
//flag: 1-查看其他人;2-查看自己
|
|
IPage<DynamicContentDTO> iPage = baseMapper
|
|
IPage<DynamicContentDTO> iPage = baseMapper
|
|
.queryBySelf(page, querySelfWrapper(flag, userId));
|
|
.queryBySelf(page, querySelfWrapper(flag, userId));
|
|
- return getResult(iPage, true, userId);
|
|
|
|
|
|
+ IPage<DynamicContentDTO> result = getResult(iPage, true, userId);
|
|
|
|
+ return Pagination.<DynamicContentDTO>builder().total(result.getTotal()).pages(result.getPages())
|
|
|
|
+ .records(result.getRecords()).build();
|
|
}
|
|
}
|
|
|
|
|
|
public QueryWrapper<DynamicContent> querySelfWrapper(int flag, Long userId) {
|
|
public QueryWrapper<DynamicContent> querySelfWrapper(int flag, Long userId) {
|
|
- List<String> list = new ArrayList<>();
|
|
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
QueryWrapper<DynamicContent> lqw = Wrappers.query();
|
|
- lqw.eq("t1.is_deleted", 0);
|
|
|
|
|
|
+ lqw.eq("t1.deleted", 0);
|
|
lqw.eq("t1.user_id", userId);
|
|
lqw.eq("t1.user_id", userId);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.eq("t1.platform_status", 0);
|
|
lqw.eq(flag == 1, "t1.status", 0);
|
|
lqw.eq(flag == 1, "t1.status", 0);
|
|
lqw.eq(flag == 1, "t1.examine_status", 1);
|
|
lqw.eq(flag == 1, "t1.examine_status", 1);
|
|
- list.add("t1.create_time");
|
|
|
|
- list.add("t1.id");
|
|
|
|
- lqw.orderByDesc(list.toString());
|
|
|
|
|
|
+ lqw.orderByDesc("t1.create_time","t1.id");
|
|
return lqw;
|
|
return lqw;
|
|
}
|
|
}
|
|
|
|
|