Browse Source

涉访涉诉+综合查询--查询条件调整

master
buaixuexideshitongxue 2 weeks ago
parent
commit
ad87ece930
  1. 3
      src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java
  2. 1
      src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java
  3. 19
      src/main/java/com/biutag/supervision/service/NegativeQueryService.java

3
src/main/java/com/biutag/supervision/pojo/request/complaintCollection/ComplaintCollectionPageRequest.java

@ -69,6 +69,9 @@ public class ComplaintCollectionPageRequest extends BasePage implements ParamChe
@Schema(description = "信件状态(局)") @Schema(description = "信件状态(局)")
private String processingStatus; private String processingStatus;
@Schema(description = "状态")
private String status;
@Override @Override
public void check() { public void check() {
if (CollectionUtil.isNotEmpty(discoveryTimeList)){ if (CollectionUtil.isNotEmpty(discoveryTimeList)){

1
src/main/java/com/biutag/supervision/repository/complaintCollection/ComplaintCollectionResourceService.java

@ -74,6 +74,7 @@ public class ComplaintCollectionResourceService extends BaseDAO {
qw.eq(StrUtil.isNotBlank(param.getRepeatt()), ComplaintCollection::getRepeatt, param.getRepeatt()); qw.eq(StrUtil.isNotBlank(param.getRepeatt()), ComplaintCollection::getRepeatt, param.getRepeatt());
qw.eq(StrUtil.isNotBlank(param.getLeadApproval()), ComplaintCollection::getLeadApproval, param.getLeadApproval()); qw.eq(StrUtil.isNotBlank(param.getLeadApproval()), ComplaintCollection::getLeadApproval, param.getLeadApproval());
qw.eq(StrUtil.isNotBlank(param.getProcessingStatus()), ComplaintCollection::getProcessingStatus, param.getProcessingStatus()); qw.eq(StrUtil.isNotBlank(param.getProcessingStatus()), ComplaintCollection::getProcessingStatus, param.getProcessingStatus());
qw.eq(StrUtil.isNotBlank(param.getStatus()), ComplaintCollection::getStatus, param.getStatus());
// 来件内容 // 来件内容
// 标签(表里如果是逗号字符串 tag="URGENT,NORMAL") // 标签(表里如果是逗号字符串 tag="URGENT,NORMAL")
// 语义:命中任意一个标签即可(OR) // 语义:命中任意一个标签即可(OR)

19
src/main/java/com/biutag/supervision/service/NegativeQueryService.java

@ -182,11 +182,18 @@ public class NegativeQueryService {
); );
} }
if (CollectionUtil.isNotEmpty(param.getHandleResultCode())){ if (CollectionUtil.isNotEmpty(param.getHandleResultCode())){
String codes = param.getHandleResultCode().stream() String likeOr = param.getHandleResultCode().stream()
.map(code -> "'" + code + "'") .map(code ->
.collect(Collectors.joining(",")); "("
queryWrapper.inSql( Negative::getId, + "CONCAT(',', handleResultCode, ',') LIKE CONCAT('%,','" + code + "',',%')"
"SELECT DISTINCT negativeId FROM negative_blame WHERE handleResultCode IN (" + codes + ")" + " OR "
+ "CONCAT(',', leadHandleResultCode, ',') LIKE CONCAT('%,','" + code + "',',%')"
+ ")"
)
.collect(Collectors.joining(" OR "));
queryWrapper.inSql(
Negative::getId,
"SELECT DISTINCT negativeId FROM negative_blame WHERE " + likeOr
); );
queryWrapper.in(Negative::getProcessingStatus,List.of("completed", "approval")); queryWrapper.in(Negative::getProcessingStatus,List.of("completed", "approval"));
} }
@ -201,7 +208,7 @@ public class NegativeQueryService {
NegativeQueryVo vo = new NegativeQueryVo(); NegativeQueryVo vo = new NegativeQueryVo();
BeanUtils.copyProperties(item, vo); BeanUtils.copyProperties(item, vo);
if (Objects.nonNull(item.getFirstDistributeTime()) && !ProcessingStatusEnum.completed.name().equals(item.getProcessingStatus())) { if (Objects.nonNull(item.getFirstDistributeTime()) && !ProcessingStatusEnum.completed.name().equals(item.getProcessingStatus())) {
vo.setRemainingDuration(TimeUtil.getRemainingDuration(item.getFirstDistributeTime(), item.getMaxSignDuration(), item.getMaxHandleDuration(), item.getExtensionDays(), item.getFlowKey())); // vo.setRemainingDuration(TimeUtil.getRemainingDuration(item.getFirstDistributeTime(), item.getMaxSignDuration(), item.getMaxHandleDuration(), item.getExtensionDays(), item.getFlowKey()));
} }
return vo; return vo;
}).toList(); }).toList();

Loading…
Cancel
Save