修改干预以人为维度

This commit is contained in:
cjw 2024-04-19 10:55:57 +08:00
parent 07d2b5657e
commit 1d59a5caf7
15 changed files with 75 additions and 57 deletions

View File

@ -39,9 +39,8 @@ public class SysWarnRecordController extends BaseController {
/** /**
* 查询预警记录列表 * 查询预警记录列表
*/ */
// @GetMapping("/pageList")
@SaCheckPermission("scale:warn:list") @SaCheckPermission("scale:warn:list")
@GetMapping("/list") @GetMapping("/pageList")
public TableDataInfo<SysWarnRecordVo> list(SysWarnRecordBo bo, PageQuery pageQuery) { public TableDataInfo<SysWarnRecordVo> list(SysWarnRecordBo bo, PageQuery pageQuery) {
return sysWarnRecordService.queryPageList(bo, pageQuery); return sysWarnRecordService.queryPageList(bo, pageQuery);
} }

View File

@ -27,9 +27,9 @@ public class SysInterveneRecord {
private Long interveneId; private Long interveneId;
/** /**
* 预警记录id * 用户id
*/ */
private Long warnId; private Long userId;
/** /**
* 诊断 * 诊断
@ -41,6 +41,12 @@ public class SysInterveneRecord {
*/ */
private Long annex; private Long annex;
/**
* 咨询师id
*/
private Long counselorId;
private Date createTime; private Date createTime;

View File

@ -36,11 +36,6 @@ public class SysWarnRecord {
*/ */
private Long userId; private Long userId;
/**
* 状态 0 未处理1 分配咨询师2 咨询师拒绝干预3 干预中 4 干预结束
*/
private Integer status;
/** /**
* 补充说明 * 补充说明
*/ */

View File

@ -27,10 +27,10 @@ public class SysInterveneRecordBo extends BaseEntity {
private Long interveneId; private Long interveneId;
/** /**
* 预警记录id * 用户id
*/ */
@NotNull(message = "预警记录id不能为空", groups = { AddGroup.class, EditGroup.class }) @NotNull(message = "用户id不能为空", groups = { AddGroup.class, EditGroup.class })
private Long warnId; private Long userId;
/** /**
* 诊断 * 诊断
@ -44,6 +44,11 @@ public class SysInterveneRecordBo extends BaseEntity {
//@NotNull(message = "诊断附件不能为空", groups = { AddGroup.class, EditGroup.class }) //@NotNull(message = "诊断附件不能为空", groups = { AddGroup.class, EditGroup.class })
private Long annex; private Long annex;
/**
* 咨询师id
*/
private Long counselorId;
/** /**
* 状态是暂存还是完成 * 状态是暂存还是完成
*/ */

View File

@ -1,15 +1,16 @@
package org.dromara.scale.domain.bo; package org.dromara.scale.domain.bo;
import org.dromara.scale.domain.SysWarnRecord;
import org.dromara.common.mybatis.core.domain.BaseEntity;
import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import io.github.linpeilie.annotations.AutoMapper; import io.github.linpeilie.annotations.AutoMapper;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import jakarta.validation.constraints.*; import org.dromara.common.core.validate.AddGroup;
import org.dromara.common.core.validate.EditGroup;
import org.dromara.common.mybatis.core.domain.BaseEntity;
import org.dromara.scale.domain.SysWarnRecord;
import java.util.Date; import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
/** /**
* 预警记录业务对象 sys_warn_record * 预警记录业务对象 sys_warn_record
@ -40,12 +41,6 @@ public class SysWarnRecordBo extends BaseEntity {
@NotNull(message = "测评人id不能为空", groups = { AddGroup.class, EditGroup.class }) @NotNull(message = "测评人id不能为空", groups = { AddGroup.class, EditGroup.class })
private Long userId; private Long userId;
/**
* 状态 0 未处理1 分配咨询师2 咨询师拒绝干预3 干预中 4 干预结束
*/
@NotNull(message = "状态 0 未处理1 分配咨询师2 咨询师拒绝干预3 干预中 4 干预结束不能为空", groups = { AddGroup.class, EditGroup.class })
private Integer status;
/** /**
* 补充说明 * 补充说明
*/ */

View File

@ -1,16 +1,13 @@
package org.dromara.scale.domain.vo; package org.dromara.scale.domain.vo;
import org.dromara.scale.domain.SysInterveneRecord;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty; import com.alibaba.excel.annotation.ExcelProperty;
import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper; import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data; import lombok.Data;
import org.dromara.scale.domain.SysInterveneRecord;
import java.io.Serial; import java.io.Serial;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
@ -37,8 +34,8 @@ public class SysInterveneRecordVo implements Serializable {
/** /**
* 预警记录id * 预警记录id
*/ */
@ExcelProperty(value = "预警记录id") @ExcelProperty(value = "用户id")
private Long warnId; private Long userId;
/** /**
* 诊断 * 诊断
@ -52,5 +49,10 @@ public class SysInterveneRecordVo implements Serializable {
@ExcelProperty(value = "诊断附件") @ExcelProperty(value = "诊断附件")
private Long annex; private Long annex;
/**
* 咨询师id
*/
private Long counselorId;
} }

View File

@ -1,14 +1,10 @@
package org.dromara.scale.domain.vo; package org.dromara.scale.domain.vo;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.dromara.scale.domain.SysWarnRecord;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty; import com.alibaba.excel.annotation.ExcelProperty;
import org.dromara.common.excel.annotation.ExcelDictFormat;
import org.dromara.common.excel.convert.ExcelDictConvert;
import io.github.linpeilie.annotations.AutoMapper; import io.github.linpeilie.annotations.AutoMapper;
import lombok.Data; import lombok.Data;
import org.dromara.scale.domain.SysWarnRecord;
import java.io.Serial; import java.io.Serial;
import java.io.Serializable; import java.io.Serializable;
@ -48,12 +44,6 @@ public class SysWarnRecordVo implements Serializable {
@ExcelProperty(value = "测评人id") @ExcelProperty(value = "测评人id")
private Long userId; private Long userId;
/**
* 状态 0 未处理1 分配咨询师2 咨询师拒绝干预3 干预中 4 干预结束
*/
@ExcelProperty(value = "状态 0 未处理1 分配咨询师2 咨询师拒绝干预3 干预中 4 干预结束")
private Integer status;
/** /**
* 补充说明 * 补充说明
*/ */

View File

@ -2,9 +2,12 @@ package org.dromara.scale.mapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.dromara.scale.domain.SysEvaluationConclusion; import org.dromara.scale.domain.SysEvaluationConclusion;
import org.dromara.scale.domain.bo.SysEvaluationConclusionBo;
import org.dromara.scale.domain.vo.SysEvaluationConclusionVo; import org.dromara.scale.domain.vo.SysEvaluationConclusionVo;
import org.dromara.common.mybatis.core.mapper.BaseMapperPlus; import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
import java.util.List;
/** /**
* 量测结果Mapper接口 * 量测结果Mapper接口
* *
@ -14,4 +17,6 @@ import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
@Mapper @Mapper
public interface SysEvaluationConclusionMapper extends BaseMapperPlus<SysEvaluationConclusion, SysEvaluationConclusionVo> { public interface SysEvaluationConclusionMapper extends BaseMapperPlus<SysEvaluationConclusion, SysEvaluationConclusionVo> {
List<SysEvaluationConclusionVo> selectVoList(SysEvaluationConclusionBo bo);
} }

View File

@ -50,8 +50,7 @@ public class SysEvaluationConclusionServiceImpl implements ISysEvaluationConclus
*/ */
@Override @Override
public List<SysEvaluationConclusionVo> queryList(SysEvaluationConclusionBo bo) { public List<SysEvaluationConclusionVo> queryList(SysEvaluationConclusionBo bo) {
LambdaQueryWrapper<SysEvaluationConclusion> lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(bo);
return baseMapper.selectVoList(lqw);
} }
private LambdaQueryWrapper<SysEvaluationConclusion> buildQueryWrapper(SysEvaluationConclusionBo bo) { private LambdaQueryWrapper<SysEvaluationConclusion> buildQueryWrapper(SysEvaluationConclusionBo bo) {

View File

@ -4,17 +4,19 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.dromara.common.core.domain.model.LoginUser;
import org.dromara.common.core.utils.MapstructUtils; import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.scale.constant.StatusEnum;
import org.dromara.scale.domain.SysInterveneRecord; import org.dromara.scale.domain.SysInterveneRecord;
import org.dromara.scale.domain.SysWarnRecord;
import org.dromara.scale.domain.bo.SysInterveneRecordBo; import org.dromara.scale.domain.bo.SysInterveneRecordBo;
import org.dromara.scale.domain.vo.SysInterveneRecordVo; import org.dromara.scale.domain.vo.SysInterveneRecordVo;
import org.dromara.scale.mapper.SysInterveneRecordMapper; import org.dromara.scale.mapper.SysInterveneRecordMapper;
import org.dromara.scale.mapper.SysWarnRecordMapper;
import org.dromara.scale.service.ISysInterveneRecordService; import org.dromara.scale.service.ISysInterveneRecordService;
import org.dromara.system.domain.SysUser;
import org.dromara.system.mapper.SysUserMapper;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.Collection; import java.util.Collection;
@ -22,6 +24,8 @@ import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import static org.dromara.common.satoken.utils.LoginHelper.getLoginUser;
/** /**
* 干预记录Service业务层处理 * 干预记录Service业务层处理
* *
@ -34,7 +38,7 @@ public class SysInterveneRecordServiceImpl implements ISysInterveneRecordService
private final SysInterveneRecordMapper baseMapper; private final SysInterveneRecordMapper baseMapper;
private final SysWarnRecordMapper warnMapper; private final SysUserMapper userMapper;
/** /**
* 查询干预记录 * 查询干预记录
@ -66,7 +70,7 @@ public class SysInterveneRecordServiceImpl implements ISysInterveneRecordService
private LambdaQueryWrapper<SysInterveneRecord> buildQueryWrapper(SysInterveneRecordBo bo) { private LambdaQueryWrapper<SysInterveneRecord> buildQueryWrapper(SysInterveneRecordBo bo) {
Map<String, Object> params = bo.getParams(); Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<SysInterveneRecord> lqw = Wrappers.lambdaQuery(); LambdaQueryWrapper<SysInterveneRecord> lqw = Wrappers.lambdaQuery();
lqw.eq(bo.getWarnId() != null, SysInterveneRecord::getWarnId, bo.getWarnId()); //lqw.eq(bo.getWarnId() != null, SysInterveneRecord::getWarnId, bo.getWarnId());
lqw.eq(StringUtils.isNotBlank(bo.getDiagnose()), SysInterveneRecord::getDiagnose, bo.getDiagnose()); lqw.eq(StringUtils.isNotBlank(bo.getDiagnose()), SysInterveneRecord::getDiagnose, bo.getDiagnose());
lqw.eq(bo.getAnnex() != null, SysInterveneRecord::getAnnex, bo.getAnnex()); lqw.eq(bo.getAnnex() != null, SysInterveneRecord::getAnnex, bo.getAnnex());
return lqw; return lqw;
@ -77,9 +81,10 @@ public class SysInterveneRecordServiceImpl implements ISysInterveneRecordService
*/ */
@Override @Override
public Boolean insertByBo(SysInterveneRecordBo bo) { public Boolean insertByBo(SysInterveneRecordBo bo) {
LoginUser loginUser = getLoginUser();
SysInterveneRecord add = MapstructUtils.convert(bo, SysInterveneRecord.class); SysInterveneRecord add = MapstructUtils.convert(bo, SysInterveneRecord.class);
add.setCreateTime(new Date()); add.setCreateTime(new Date());
add.setInterveneId(loginUser.getUserId());
validEntityBeforeSave(add); validEntityBeforeSave(add);
boolean flag = baseMapper.insert(add) > 0; boolean flag = baseMapper.insert(add) > 0;
if (flag) { if (flag) {
@ -87,10 +92,10 @@ public class SysInterveneRecordServiceImpl implements ISysInterveneRecordService
} }
Integer status = bo.getStatus(); Integer status = bo.getStatus();
if (status.equals(1)) { if (status.equals(1)) {
SysWarnRecord warnRecord = new SysWarnRecord(); SysUser record = new SysUser();
warnRecord.setWarnId(add.getWarnId()); record.setUserId(bo.getUserId());
warnRecord.setStatus(4); record.setInterveneStatus(StatusEnum.DISABLED.getValue());
warnMapper.updateById(warnRecord); userMapper.updateById(record);
} }
return flag; return flag;
} }

View File

@ -63,7 +63,7 @@ public class SysWarnRecordServiceImpl implements ISysWarnRecordService {
LambdaQueryWrapper<SysWarnRecord> lqw = Wrappers.lambdaQuery(); LambdaQueryWrapper<SysWarnRecord> lqw = Wrappers.lambdaQuery();
lqw.eq(bo.getBatchNo() != null, SysWarnRecord::getBatchNo, bo.getBatchNo()); lqw.eq(bo.getBatchNo() != null, SysWarnRecord::getBatchNo, bo.getBatchNo());
lqw.eq(bo.getUserId() != null, SysWarnRecord::getUserId, bo.getUserId()); lqw.eq(bo.getUserId() != null, SysWarnRecord::getUserId, bo.getUserId());
lqw.eq(bo.getStatus() != null, SysWarnRecord::getStatus, bo.getStatus()); //lqw.eq(bo.getStatus() != null, SysWarnRecord::getStatus, bo.getStatus());
lqw.eq(StringUtils.isNotBlank(bo.getNote()), SysWarnRecord::getNote, bo.getNote()); lqw.eq(StringUtils.isNotBlank(bo.getNote()), SysWarnRecord::getNote, bo.getNote());
lqw.eq(bo.getWarnTime() != null, SysWarnRecord::getWarnTime, bo.getWarnTime()); lqw.eq(bo.getWarnTime() != null, SysWarnRecord::getWarnTime, bo.getWarnTime());
return lqw; return lqw;

View File

@ -147,7 +147,6 @@ public class WebServiceImpl implements IWebService {
public Map<String, Object> submitAnswer(SubmitAnswerBo bo) { public Map<String, Object> submitAnswer(SubmitAnswerBo bo) {
boolean allowQueryResult = true; boolean allowQueryResult = true;
Long scaleId = bo.getScaleId(); Long scaleId = bo.getScaleId();
Map<Long, List<SysScaleAnswerVo>> answerMapByQuestion = scaleAnswerService.getScaleAnswerMap(scaleId); Map<Long, List<SysScaleAnswerVo>> answerMapByQuestion = scaleAnswerService.getScaleAnswerMap(scaleId);
int keySize = answerMapByQuestion.keySet().size(); int keySize = answerMapByQuestion.keySet().size();
List<SysEvaluationAnswerBo> answerList = bo.getAnswerList(); List<SysEvaluationAnswerBo> answerList = bo.getAnswerList();
@ -183,7 +182,7 @@ public class WebServiceImpl implements IWebService {
SysWarnRecord wre = new SysWarnRecord(); SysWarnRecord wre = new SysWarnRecord();
wre.setBatchNo(scalePublishVo.getBatchNo()); wre.setBatchNo(scalePublishVo.getBatchNo());
wre.setUserId(getLoginUser().getUserId()); wre.setUserId(getLoginUser().getUserId());
wre.setStatus(0); //wre.setStatus(0);
wre.setWarnTime(new Date()); wre.setWarnTime(new Date());
warnRecordService.insertByBo(wre); warnRecordService.insertByBo(wre);
} }

View File

@ -4,4 +4,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"> "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.dromara.scale.mapper.SysEvaluationConclusionMapper"> <mapper namespace="org.dromara.scale.mapper.SysEvaluationConclusionMapper">
<select id="selectVoList" parameterType="org.dromara.scale.domain.bo.SysEvaluationConclusionBo"
resultType="org.dromara.scale.domain.vo.SysEvaluationConclusionVo">
select ec.*, sfr.eval_desc, sfr.eval_propose, sfr.situation
from sys_evaluation_conclusion ec
left join sys_scale_factor_range sfr on sfr.range_id = ec.factor_range_id
where ec.record_id = #{recordId}
and ec.status = 1
</select>
</mapper> </mapper>

View File

@ -103,6 +103,11 @@ public class SysUser extends BaseEntity {
*/ */
private String remark; private String remark;
/**
* 干预状态
*/
private Integer interveneStatus;
public SysUser(Long userId) { public SysUser(Long userId) {
this.userId = userId; this.userId = userId;

View File

@ -103,6 +103,11 @@ public class SysUserVo implements Serializable {
*/ */
private String remark; private String remark;
/**
* 干预状态
*/
private Integer interveneStatus;
/** /**
* 创建时间 * 创建时间
*/ */