From 21f45258cfcdc79127f85ad6e45736cff5acd345 Mon Sep 17 00:00:00 2001
From: liyj <15602261488@163.com>
Date: Mon, 21 Oct 2024 20:58:05 +0800
Subject: [PATCH] 1、数据割接程序，白云区矛盾纠纷多元化解平台 2、纠纷态势报错修改
---
dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseUrgingService.java | 40 +++++++++++++++++++++++++++++++++++++++-
1 files changed, 39 insertions(+), 1 deletions(-)
diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseUrgingService.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseUrgingService.java
index 973c63c..bc54b3a 100644
--- a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseUrgingService.java
+++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseUrgingService.java
@@ -3,11 +3,13 @@
import cn.huge.base.common.exception.ServiceException;
import cn.huge.base.common.utils.DateUtils;
import cn.huge.base.common.utils.IdUtils;
+import cn.huge.base.common.utils.ObjectUtils;
import cn.huge.module.client.api.impl.CustClientImpl;
import cn.huge.module.client.api.impl.UtilsClientImpl;
import cn.huge.module.cases.dao.mapper.CaseUrgingMapper;
import cn.huge.module.cases.domain.po.CaseUrging;
import cn.huge.module.cust.dto.PaUserDTO;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -139,8 +141,22 @@
* 新增或更新对象
* @param caseUrging 实体对象
*/
- public void saveCaseUrgingWechat(String userId,CaseUrging caseUrging){
+ public String saveCaseUrgingWechat(String userId,CaseUrging caseUrging){
try{
+ //查询是否已经有催办
+ QueryWrapper<CaseUrging> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("case_id", caseUrging.getCaseId());
+ queryWrapper.orderByDesc("create_time");
+ queryWrapper.last("limit 1");
+ CaseUrging caseUrgingOld = mapper.selectOne(queryWrapper);
+ if(ObjectUtils.isNotEmpty(caseUrgingOld)){
+ //计算创建时间和当前时间是否超过24小时
+ Integer differHour = DateUtils.getDifferHour(new Date(), caseUrgingOld.getCreateTime());
+ if(differHour < 24){
+ return "催办间隔时间不能小于24小时";
+ }
+ }
+
// 获取当前登录用户
PaUserDTO loginUser = custClient.paclientGetUser(userId);
Date nowDate = DateUtils.getNowDate();
@@ -159,6 +175,28 @@
log.error("[CaseUrgingService.saveCaseUrging]调用失败，异常信息："+e, e);
throw new ServiceException("CaseUrgingService.saveCaseUrging", e);
}
+ return null;
+ }
+
+ public Integer countByCaseId(String caseId){
+ Integer count = 0;
+ QueryWrapper<CaseUrging> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("case_id", caseId);
+ queryWrapper.isNotNull("reply_user_id");
+ Integer number = mapper.selectCount(queryWrapper);
+ if(ObjectUtils.isNotEmpty(number)){
+ count = number;
+ }
+ return count;
+ }
+
+ public List<CaseUrging> listByCaseId(String caseId){
+ QueryWrapper<CaseUrging> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("case_id", caseId);
+ queryWrapper.isNotNull("reply_user_id");
+ queryWrapper.orderByDesc("reply_time");
+ List<CaseUrging> caseUrgings = mapper.selectList(queryWrapper);
+ return caseUrgings;
}
}
--
Gitblit v1.8.0