diff --git a/health/src/main/java/com/ccsens/health/bean/dto/MemberDto.java b/health/src/main/java/com/ccsens/health/bean/dto/MemberDto.java index f28c3a8a..5b0364d9 100644 --- a/health/src/main/java/com/ccsens/health/bean/dto/MemberDto.java +++ b/health/src/main/java/com/ccsens/health/bean/dto/MemberDto.java @@ -19,9 +19,9 @@ public class MemberDto { @ApiModelProperty("班级(所在机构)") private String department; @ApiModelProperty("开始时间") - private String startTime; + private Long startTime; @ApiModelProperty("结束时间") - private String endTime; + private Long endTime; @ApiModelProperty("健康状态 0发烧 1其他") private int type; } diff --git a/health/src/main/java/com/ccsens/health/bean/vo/AbnormalVo.java b/health/src/main/java/com/ccsens/health/bean/vo/AbnormalVo.java index 4d1a0588..e52f035a 100644 --- a/health/src/main/java/com/ccsens/health/bean/vo/AbnormalVo.java +++ b/health/src/main/java/com/ccsens/health/bean/vo/AbnormalVo.java @@ -1,12 +1,10 @@ package com.ccsens.health.bean.vo; -import cn.hutool.core.util.ObjectUtil; import com.fasterxml.jackson.annotation.JsonIgnore; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; -import javax.validation.constraints.NotNull; import java.math.BigDecimal; @Data @@ -24,14 +22,19 @@ public class AbnormalVo { @ApiModelProperty("异常状态code") private Integer code; @ApiModelProperty("数量") - private Long number; + private int number; public String getAbnormalName(){ + if(code == null){ + return null; + } switch (code){ case 0: return "健康"; case 1: return "治愈"; case 2: return "隔离"; case 3: return "疑似"; case 4: return "确诊"; + case 5: return "出行异常"; + case 6: return "未上报"; default:return null; } } diff --git a/health/src/main/java/com/ccsens/health/persist/dao/HealthAbnormalDao.java b/health/src/main/java/com/ccsens/health/persist/dao/HealthAbnormalDao.java index 56d1f18b..c7cb0e24 100644 --- a/health/src/main/java/com/ccsens/health/persist/dao/HealthAbnormalDao.java +++ b/health/src/main/java/com/ccsens/health/persist/dao/HealthAbnormalDao.java @@ -14,4 +14,6 @@ public interface HealthAbnormalDao extends HealthAbnormalMapper { List getAbnormalList(@Param("post") Integer post, @Param("department")String department, @Param("healthType")Integer healthType); List abnormalOverview(@Param("department")String department, @Param("startTime")Long startTime, @Param("endTime")Long endTime); + + int selectJourneyNumber(@Param("department")String department, @Param("startTime")Long startTime, @Param("endTime")Long endTime); } diff --git a/health/src/main/java/com/ccsens/health/persist/dao/MemberDao.java b/health/src/main/java/com/ccsens/health/persist/dao/MemberDao.java index ee7e7abe..3cc5f31f 100644 --- a/health/src/main/java/com/ccsens/health/persist/dao/MemberDao.java +++ b/health/src/main/java/com/ccsens/health/persist/dao/MemberDao.java @@ -1,6 +1,7 @@ package com.ccsens.health.persist.dao; import com.ccsens.health.bean.po.Member; +import com.ccsens.health.bean.vo.MemberVo; import com.ccsens.health.persist.mapper.MemberMapper; import org.apache.ibatis.annotations.Param; @@ -20,4 +21,18 @@ public interface MemberDao extends MemberMapper { * @return */ Member selectByRandom(@Param("randomNumber") int randomNumber); + + /** + * 学生健康列表 + * @param name + * @param wkno + * @param department + * @param startTime + * @param endTime + * @param type + * @return + */ + List selectHealthInfo(@Param("name")String name, @Param("wkno")String wkno, + @Param("department")String department,@Param("startTime")Long startTime, + @Param("endTime")Long endTime, @Param("type")int type); } diff --git a/health/src/main/java/com/ccsens/health/service/AbnormalService.java b/health/src/main/java/com/ccsens/health/service/AbnormalService.java index a99a101b..1165e588 100644 --- a/health/src/main/java/com/ccsens/health/service/AbnormalService.java +++ b/health/src/main/java/com/ccsens/health/service/AbnormalService.java @@ -1,16 +1,15 @@ package com.ccsens.health.service; import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Snowflake; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.ccsens.health.bean.dto.AbnormalDto; -import com.ccsens.health.bean.dto.JourneyDto; import com.ccsens.health.bean.po.HealthAbnormal; import com.ccsens.health.bean.vo.AbnormalVo; import com.ccsens.health.persist.dao.HealthAbnormalDao; import com.ccsens.util.CodeEnum; -import com.ccsens.util.DateUtil; import com.ccsens.util.bean.dto.QueryDto; import com.ccsens.util.exception.BaseException; import com.github.pagehelper.PageHelper; @@ -20,7 +19,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; -import java.util.Date; +import java.util.ArrayList; import java.util.List; @Slf4j @@ -40,11 +39,22 @@ public class AbnormalService implements IAbnormalService{ @Override public List abnormalOverview(QueryDto params) throws Exception { AbnormalDto.SelectAbnormal selectAbnormal = params.getParam(); -// Long startTime = selectAbnormal.getStartTime() == null ? DateUtil.getZeroTime(new Date()) : selectAbnormal.getStartTime(); -// Long endTime = selectAbnormal.getEndTime() == null ? System.currentTimeMillis() : selectAbnormal.getEndTime(); - - List abnormalOverviewList = + List abnormalOverviewList = new ArrayList<>(); + //人员异常 + abnormalOverviewList = healthAbnormalDao.abnormalOverview(selectAbnormal.getDepartment(),selectAbnormal.getStartTime(),selectAbnormal.getEndTime()); + if(CollectionUtil.isNotEmpty(abnormalOverviewList)){ + for(AbnormalVo.AbnormalOverview abnormalOverview : abnormalOverviewList){ + abnormalOverview.setAbnormalType(1); + } + } + //行程异常 + int journeyNumber = healthAbnormalDao.selectJourneyNumber(selectAbnormal.getDepartment(),selectAbnormal.getStartTime(),selectAbnormal.getEndTime()); + AbnormalVo.AbnormalOverview abnormalOverview = new AbnormalVo.AbnormalOverview(); + abnormalOverview.setAbnormalType(2); + abnormalOverview.setCode(5); + abnormalOverview.setNumber(journeyNumber); + abnormalOverviewList.add(abnormalOverview); return abnormalOverviewList; } diff --git a/health/src/main/java/com/ccsens/health/service/StudentService.java b/health/src/main/java/com/ccsens/health/service/StudentService.java index ab129cfb..ef5b62fb 100644 --- a/health/src/main/java/com/ccsens/health/service/StudentService.java +++ b/health/src/main/java/com/ccsens/health/service/StudentService.java @@ -65,7 +65,11 @@ public class StudentService implements IStudentService{ */ @Override public List getStudentHealthList(QueryDto params) { - return null; + MemberDto.StudentHealth studentHealth = params.getParam(); + List studentHealthVoList = + memberDao.selectHealthInfo(studentHealth.getName(),studentHealth.getWkno(),studentHealth.getDepartment(), + studentHealth.getStartTime(),studentHealth.getEndTime(),studentHealth.getType()); + return studentHealthVoList; } @Override diff --git a/health/src/main/resources/mapper_dao/HealthAbnormalDao.xml b/health/src/main/resources/mapper_dao/HealthAbnormalDao.xml index 5605aac3..bcd192e3 100644 --- a/health/src/main/resources/mapper_dao/HealthAbnormalDao.xml +++ b/health/src/main/resources/mapper_dao/HealthAbnormalDao.xml @@ -81,4 +81,35 @@ GROUP BY a.health_status + + \ No newline at end of file diff --git a/health/src/main/resources/mapper_dao/MemberDao.xml b/health/src/main/resources/mapper_dao/MemberDao.xml index addaf7a5..81a33f78 100644 --- a/health/src/main/resources/mapper_dao/MemberDao.xml +++ b/health/src/main/resources/mapper_dao/MemberDao.xml @@ -2,6 +2,19 @@ + + + + + + + + + + + + + insert into t_member (id, wkno, `name`, @@ -25,4 +38,53 @@ t_member limit #{randomNumber},1; + + + + \ No newline at end of file diff --git a/tall/src/main/java/com/ccsens/tall/service/UserService.java b/tall/src/main/java/com/ccsens/tall/service/UserService.java index fee0e14e..9fa2e1c8 100644 --- a/tall/src/main/java/com/ccsens/tall/service/UserService.java +++ b/tall/src/main/java/com/ccsens/tall/service/UserService.java @@ -1254,18 +1254,18 @@ public class UserService implements IUserService { if(ObjectUtil.isNull(user) || ObjectUtil.isNull(uselessUser)){ throw new BaseException(CodeEnum.NOT_MEMBER); } - userDao.replaceAuth(userId, uselessId); + userDao.replaceAuth(uselessId,userId); //查询所有关联userId的数据库表 auth表 attention表 balance表 project表 member表 DeliverPostLog表 proLog表 //依次将查出的数据的旧userId 替换成新的userId - userDao.replaceAttention(userId, uselessId); - userDao.replaceBalance(userId, uselessId); - userDao.replaceProject(userId, uselessId); - userDao.replaceMember(userId, uselessId); - userDao.replaceDeliverPostLog(userId, uselessId); - userDao.replaceProLog(userId, uselessId); + userDao.replaceAttention(uselessId,userId); + userDao.replaceBalance(uselessId,userId); + userDao.replaceProject(uselessId,userId); + userDao.replaceMember(uselessId,userId); + userDao.replaceDeliverPostLog(uselessId,userId); + userDao.replaceProLog(uselessId,userId); //将以前的余额添加至此账号 - SysUser oldUser = userDao.selectByPrimaryKey(userId); - SysUser newUser = userDao.selectByPrimaryKey(uselessId); + SysUser oldUser = userDao.selectByPrimaryKey(uselessId); + SysUser newUser = userDao.selectByPrimaryKey(userId); updateBalance(oldUser, newUser); //将以前的user删除 oldUser.setRecStatus((byte) 2);