diff --git a/intc-common/intc-common-message/pom.xml b/intc-common/intc-common-message/pom.xml
new file mode 100644
index 0000000..08b95d8
--- /dev/null
+++ b/intc-common/intc-common-message/pom.xml
@@ -0,0 +1,65 @@
+
+
+
+ com.intc
+ intc-common
+ 3.6.3
+
+ 4.0.0
+
+ intc-common-message
+
+
+ intc-common-message 消息通知服务（短信、语音等）
+
+
+
+
+
+ com.aliyun
+ dysmsapi20170525
+ 2.0.24
+
+
+
+
+ com.aliyun
+ dyvmsapi20170525
+ 3.2.2
+
+
+
+
+ com.aliyun
+ tea-openapi
+ 0.3.4
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter
+
+
+
+
+ org.projectlombok
+ lombok
+
+
+
+
+ com.alibaba.fastjson2
+ fastjson2
+
+
+
+
+ com.intc
+ intc-common-core
+
+
+
+
\ No newline at end of file
diff --git a/intc-common/intc-common-message/src/main/java/com/intc/common/message/config/AliyunMessageProperties.java b/intc-common/intc-common-message/src/main/java/com/intc/common/message/config/AliyunMessageProperties.java
new file mode 100644
index 0000000..443b7c0
--- /dev/null
+++ b/intc-common/intc-common-message/src/main/java/com/intc/common/message/config/AliyunMessageProperties.java
@@ -0,0 +1,77 @@
+package com.intc.common.message.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 阿里云消息服务配置
+ *
+ * @author bot5
+ * @date 2026-03-29
+ */
+@Data
+@ConfigurationProperties(prefix = "aliyun.message")
+public class AliyunMessageProperties {
+
+ /**
+ * 阿里云 AccessKey ID
+ */
+ private String accessKeyId;
+
+ /**
+ * 阿里云 AccessKey Secret
+ */
+ private String accessKeySecret;
+
+ /**
+ * 短信服务配置
+ */
+ private SmsConfig sms = new SmsConfig();
+
+ /**
+ * 语音服务配置
+ */
+ private VoiceConfig voice = new VoiceConfig();
+
+ @Data
+ public static class SmsConfig {
+ /**
+ * 短信签名名称
+ */
+ private String signName;
+
+ /**
+ * 短信模板CODE（用药提醒）
+ */
+ private String medicationRemindTemplateCode;
+
+ /**
+ * 短信模板CODE（漏服提醒）
+ */
+ private String missedRemindTemplateCode;
+
+ /**
+ * 短信模板CODE（家属通知）
+ */
+ private String familyNotifyTemplateCode;
+ }
+
+ @Data
+ public static class VoiceConfig {
+ /**
+ * 语音通知模板CODE（用药提醒）
+ */
+ private String medicationRemindTtsCode;
+
+ /**
+ * 语音通知模板CODE（漏服提醒）
+ */
+ private String missedRemindTtsCode;
+
+ /**
+ * 被叫号码显示的呼入号码
+ */
+ private String calledShowNumber;
+ }
+}
\ No newline at end of file
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/controller/ChronicDiseaseManageController.java b/intc-modules/intc-health/src/main/java/com/intc/health/controller/ChronicDiseaseManageController.java
new file mode 100644
index 0000000..0903973
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/controller/ChronicDiseaseManageController.java
@@ -0,0 +1,116 @@
+package com.intc.health.controller;
+
+import com.intc.common.core.web.controller.BaseController;
+import com.intc.common.core.web.domain.AjaxResult;
+import com.intc.common.core.web.page.TableDataInfo;
+import com.intc.common.log.annotation.Log;
+import com.intc.common.log.enums.BusinessType;
+import com.intc.common.security.annotation.RequiresPermissions;
+import com.intc.health.domain.ChronicDiseaseFollowUpRecord;
+import com.intc.health.domain.ChronicDiseaseIndicatorRecord;
+import com.intc.health.domain.ChronicDiseaseStatusHistory;
+import com.intc.health.service.IChronicDiseaseManageService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Api(tags = "慢性疾病管理扩展")
+@RestController
+@RequestMapping("/chronicDiseaseManage")
+public class ChronicDiseaseManageController extends BaseController {
+ @Resource
+ private IChronicDiseaseManageService chronicDiseaseManageService;
+
+ @ApiOperation("查询慢病指标记录")
+ @RequiresPermissions("health:chronicDisease:list")
+ @GetMapping("/indicator/list")
+ public TableDataInfo indicatorList(ChronicDiseaseIndicatorRecord query) {
+ startPage();
+ List list = chronicDiseaseManageService.selectIndicatorList(query);
+ return getDataTable(list);
+ }
+
+ @ApiOperation("查询慢病指标详情")
+ @RequiresPermissions("health:chronicDisease:query")
+ @GetMapping("/indicator/{id}")
+ public AjaxResult indicatorInfo(@PathVariable Long id) {
+ return success(chronicDiseaseManageService.selectIndicatorById(id));
+ }
+
+ @ApiOperation("新增慢病指标记录")
+ @RequiresPermissions("health:chronicDisease:add")
+ @Log(title = "慢性疾病指标记录", businessType = BusinessType.INSERT)
+ @PostMapping("/indicator")
+ public AjaxResult indicatorAdd(@RequestBody ChronicDiseaseIndicatorRecord record) {
+ return toAjax(chronicDiseaseManageService.insertIndicator(record));
+ }
+
+ @ApiOperation("修改慢病指标记录")
+ @RequiresPermissions("health:chronicDisease:edit")
+ @Log(title = "慢性疾病指标记录", businessType = BusinessType.UPDATE)
+ @PutMapping("/indicator")
+ public AjaxResult indicatorEdit(@RequestBody ChronicDiseaseIndicatorRecord record) {
+ return toAjax(chronicDiseaseManageService.updateIndicator(record));
+ }
+
+ @ApiOperation("删除慢病指标记录")
+ @RequiresPermissions("health:chronicDisease:remove")
+ @Log(title = "慢性疾病指标记录", businessType = BusinessType.DELETE)
+ @DeleteMapping("/indicator/{ids}")
+ public AjaxResult indicatorRemove(@PathVariable Long[] ids) {
+ return toAjax(chronicDiseaseManageService.deleteIndicatorByIds(ids));
+ }
+
+ @ApiOperation("查询复诊随访记录")
+ @RequiresPermissions("health:chronicDisease:list")
+ @GetMapping("/followUp/list")
+ public TableDataInfo followUpList(ChronicDiseaseFollowUpRecord query) {
+ startPage();
+ List list = chronicDiseaseManageService.selectFollowUpList(query);
+ return getDataTable(list);
+ }
+
+ @ApiOperation("新增复诊随访记录")
+ @RequiresPermissions("health:chronicDisease:add")
+ @Log(title = "慢性疾病复诊随访", businessType = BusinessType.INSERT)
+ @PostMapping("/followUp")
+ public AjaxResult followUpAdd(@RequestBody ChronicDiseaseFollowUpRecord record) {
+ return toAjax(chronicDiseaseManageService.insertFollowUp(record));
+ }
+
+ @ApiOperation("修改复诊随访记录")
+ @RequiresPermissions("health:chronicDisease:edit")
+ @Log(title = "慢性疾病复诊随访", businessType = BusinessType.UPDATE)
+ @PutMapping("/followUp")
+ public AjaxResult followUpEdit(@RequestBody ChronicDiseaseFollowUpRecord record) {
+ return toAjax(chronicDiseaseManageService.updateFollowUp(record));
+ }
+
+ @ApiOperation("删除复诊随访记录")
+ @RequiresPermissions("health:chronicDisease:remove")
+ @Log(title = "慢性疾病复诊随访", businessType = BusinessType.DELETE)
+ @DeleteMapping("/followUp/{ids}")
+ public AjaxResult followUpRemove(@PathVariable Long[] ids) {
+ return toAjax(chronicDiseaseManageService.deleteFollowUpByIds(ids));
+ }
+
+ @ApiOperation("查询状态变更历史")
+ @RequiresPermissions("health:chronicDisease:list")
+ @GetMapping("/statusHistory/list")
+ public TableDataInfo statusHistoryList(ChronicDiseaseStatusHistory query) {
+ startPage();
+ List list = chronicDiseaseManageService.selectStatusHistoryList(query);
+ return getDataTable(list);
+ }
+
+ @ApiOperation("新增状态变更历史")
+ @RequiresPermissions("health:chronicDisease:edit")
+ @Log(title = "慢性疾病状态变更", businessType = BusinessType.INSERT)
+ @PostMapping("/statusHistory")
+ public AjaxResult statusHistoryAdd(@RequestBody ChronicDiseaseStatusHistory record) {
+ return toAjax(chronicDiseaseManageService.insertStatusHistory(record));
+ }
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/controller/StatisticAnalysisController.java b/intc-modules/intc-health/src/main/java/com/intc/health/controller/StatisticAnalysisController.java
index 6e58e80..8efe3e6 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/controller/StatisticAnalysisController.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/controller/StatisticAnalysisController.java
@@ -8,9 +8,12 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
import java.util.Map;
/**
@@ -46,6 +49,20 @@ public class StatisticAnalysisController extends BaseController {
return AjaxResult.success(resultMap);
}
+ @ApiOperation("活动统计分析")
+ @GetMapping("/activityAnalysis")
+ public Map getActivityAnalysis(AnalysisDto analysisDto){
+ Map resultMap = iStatisticAnalysisService.getActivityAnalysis(analysisDto);
+ return AjaxResult.success(resultMap);
+ }
+
+ @ApiOperation("健康总览大屏")
+ @GetMapping("/healthScreen")
+ public Map getHealthScreen(AnalysisDto analysisDto){
+ Map resultMap = iStatisticAnalysisService.getHealthScreen(analysisDto);
+ return AjaxResult.success(resultMap);
+ }
+
@ApiOperation("档案统计分析")
@GetMapping("/recordAnalysis")
public Map getRecordAnalysis(AnalysisDto analysisDto){
@@ -53,6 +70,19 @@ public class StatisticAnalysisController extends BaseController {
return AjaxResult.success(resultMap);
}
+ @ApiOperation("健康档案大屏")
+ @GetMapping("/recordScreen")
+ public Map getRecordScreen(AnalysisDto analysisDto){
+ Map resultMap = iStatisticAnalysisService.getRecordScreen(analysisDto);
+ return AjaxResult.success(resultMap);
+ }
+
+ @ApiOperation("导出健康档案完整信息")
+ @PostMapping("/recordFullExport")
+ public void exportRecordFull(HttpServletResponse response, AnalysisDto analysisDto) throws IOException {
+ iStatisticAnalysisService.exportRecordFull(response, analysisDto);
+ }
+
@ApiOperation("就医统计分析")
@GetMapping("/doctorAnalysis")
public Map getDoctorAnalysis(AnalysisDto analysisDto){
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseFollowUpRecord.java b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseFollowUpRecord.java
new file mode 100644
index 0000000..a28a10e
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseFollowUpRecord.java
@@ -0,0 +1,58 @@
+package com.intc.health.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.intc.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel("慢性疾病复诊随访记录")
+public class ChronicDiseaseFollowUpRecord extends BaseEntity {
+ private Long id;
+
+ @ApiModelProperty("慢性疾病档案ID")
+ private Long chronicDiseaseId;
+
+ @ApiModelProperty("成员ID")
+ private Long personId;
+
+ @ApiModelProperty("类型：1-复诊 2-复查 3-随访")
+ private Integer followUpType;
+
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ @ApiModelProperty("复诊/随访日期")
+ private Date followUpDate;
+
+ private String hospital;
+
+ private String department;
+
+ private String doctor;
+
+ @ApiModelProperty("复查项目")
+ private String checkItems;
+
+ @ApiModelProperty("结果")
+ private String result;
+
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ @ApiModelProperty("下次复诊日期")
+ private Date nextFollowUpDate;
+
+ @ApiModelProperty("状态：1-待完成 2-已完成 3-已过期")
+ private Integer status;
+
+ @ApiModelProperty("说明")
+ private String notes;
+
+ private Integer delFlag;
+
+ private String startTime;
+
+ private String endTime;
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseIndicatorRecord.java b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseIndicatorRecord.java
new file mode 100644
index 0000000..449c6e7
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseIndicatorRecord.java
@@ -0,0 +1,58 @@
+package com.intc.health.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.intc.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel("慢性疾病指标记录")
+public class ChronicDiseaseIndicatorRecord extends BaseEntity {
+ private Long id;
+
+ @ApiModelProperty("慢性疾病档案ID")
+ private Long chronicDiseaseId;
+
+ @ApiModelProperty("成员ID")
+ private Long personId;
+
+ @ApiModelProperty("指标类型")
+ private String indicatorType;
+
+ @ApiModelProperty("指标名称")
+ private String indicatorName;
+
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ @ApiModelProperty("测量时间")
+ private Date measureTime;
+
+ @ApiModelProperty("指标值")
+ private BigDecimal indicatorValue;
+
+ @ApiModelProperty("指标单位")
+ private String indicatorUnit;
+
+ @ApiModelProperty("目标下限")
+ private BigDecimal targetMin;
+
+ @ApiModelProperty("目标上限")
+ private BigDecimal targetMax;
+
+ @ApiModelProperty("状态：1-正常 2-偏高 3-偏低 4-需关注")
+ private Integer status;
+
+ @ApiModelProperty("记录说明")
+ private String notes;
+
+ private Integer delFlag;
+
+ private String startTime;
+
+ private String endTime;
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseStatusHistory.java b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseStatusHistory.java
new file mode 100644
index 0000000..bb56741
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/domain/ChronicDiseaseStatusHistory.java
@@ -0,0 +1,41 @@
+package com.intc.health.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.intc.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel("慢性疾病状态变更历史")
+public class ChronicDiseaseStatusHistory extends BaseEntity {
+ private Long id;
+
+ @ApiModelProperty("慢性疾病档案ID")
+ private Long chronicDiseaseId;
+
+ @ApiModelProperty("成员ID")
+ private Long personId;
+
+ @ApiModelProperty("原状态")
+ private Integer oldStatus;
+
+ @ApiModelProperty("新状态")
+ private Integer newStatus;
+
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+ @ApiModelProperty("变更时间")
+ private Date changeTime;
+
+ @ApiModelProperty("变更原因")
+ private String reason;
+
+ @ApiModelProperty("处理建议")
+ private String treatmentAdvice;
+
+ private Integer delFlag;
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/domain/dto/AnalysisDto.java b/intc-modules/intc-health/src/main/java/com/intc/health/domain/dto/AnalysisDto.java
index 1759fa0..f53d0d6 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/domain/dto/AnalysisDto.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/domain/dto/AnalysisDto.java
@@ -43,5 +43,20 @@ public class AnalysisDto extends BaseEntity implements Serializable
@ApiModelProperty(value="档案id")
private Long recordId;
+ /** 活动名称 */
+ @ApiModelProperty(value="活动名称")
+ private String name;
+
+ /** 活动类型 */
+ @ApiModelProperty(value="活动类型")
+ private String activityType;
+
+ /** 活动地点 */
+ @ApiModelProperty(value="活动地点")
+ private String place;
+
+ /** 活动量 */
+ @ApiModelProperty(value="活动量")
+ private String activityVolume;
}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/mapper/ChronicDiseaseManageMapper.java b/intc-modules/intc-health/src/main/java/com/intc/health/mapper/ChronicDiseaseManageMapper.java
new file mode 100644
index 0000000..21d1f5a
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/mapper/ChronicDiseaseManageMapper.java
@@ -0,0 +1,37 @@
+package com.intc.health.mapper;
+
+import com.intc.common.datascope.annotation.DataScope;
+import com.intc.health.domain.ChronicDiseaseFollowUpRecord;
+import com.intc.health.domain.ChronicDiseaseIndicatorRecord;
+import com.intc.health.domain.ChronicDiseaseStatusHistory;
+
+import java.util.List;
+
+public interface ChronicDiseaseManageMapper {
+ @DataScope(businessAlias = "a")
+ List selectIndicatorList(ChronicDiseaseIndicatorRecord query);
+
+ ChronicDiseaseIndicatorRecord selectIndicatorById(Long id);
+
+ int insertIndicator(ChronicDiseaseIndicatorRecord record);
+
+ int updateIndicator(ChronicDiseaseIndicatorRecord record);
+
+ int removeIndicatorByIds(Long[] ids);
+
+ @DataScope(businessAlias = "a")
+ List selectFollowUpList(ChronicDiseaseFollowUpRecord query);
+
+ ChronicDiseaseFollowUpRecord selectFollowUpById(Long id);
+
+ int insertFollowUp(ChronicDiseaseFollowUpRecord record);
+
+ int updateFollowUp(ChronicDiseaseFollowUpRecord record);
+
+ int removeFollowUpByIds(Long[] ids);
+
+ @DataScope(businessAlias = "a")
+ List selectStatusHistoryList(ChronicDiseaseStatusHistory query);
+
+ int insertStatusHistory(ChronicDiseaseStatusHistory record);
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/mapper/StatisticAnalysisMapper.java b/intc-modules/intc-health/src/main/java/com/intc/health/mapper/StatisticAnalysisMapper.java
index 830a5a0..1e46362 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/mapper/StatisticAnalysisMapper.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/mapper/StatisticAnalysisMapper.java
@@ -2,13 +2,16 @@ package com.intc.health.mapper;
import com.intc.common.datascope.annotation.DataScope;
import com.intc.health.domain.dto.HealthDoctorRecordDto;
+import com.intc.health.domain.dto.HealthActivityDto;
import com.intc.health.domain.dto.HealthMarRecordDto;
import com.intc.health.domain.dto.HealthMilkPowderRecordDto;
import com.intc.health.domain.dto.HealthRecordDto;
+import com.intc.health.domain.dto.HealthTemperatureRecordDto;
import com.intc.health.domain.vo.*;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
+import java.util.Map;
@Mapper
public interface StatisticAnalysisMapper {
@@ -98,6 +101,60 @@ public interface StatisticAnalysisMapper {
@DataScope(businessAlias = "hp")
public List selectStaticPersonList (HealthRecordDto dto);
+ /**
+ * 查询健康总览大屏成员风险排行
+ */
+ @DataScope(businessAlias = "hp")
+ public List selectHealthScreenPersonRankList(HealthRecordDto dto);
+
+ /**
+ * 查询健康总览大屏就医汇总
+ */
+ @DataScope(businessAlias = "a")
+ public Map selectHealthScreenDoctorSummary(HealthDoctorRecordDto dto);
+
+ /**
+ * 查询健康总览大屏用药汇总
+ */
+ @DataScope(businessAlias = "a")
+ public Map selectHealthScreenMedicineSummary(HealthMarRecordDto dto);
+
+ /**
+ * 查询健康总览大屏体温汇总
+ */
+ @DataScope(businessAlias = "a")
+ public Map selectHealthScreenTemperatureSummary(HealthTemperatureRecordDto dto);
+
+ /**
+ * 查询健康总览大屏活动汇总
+ */
+ @DataScope(businessAlias = "a")
+ public Map selectHealthScreenActivitySummary(HealthActivityDto dto);
+
+ /**
+ * 查询健康总览大屏近期活动明细
+ */
+ @DataScope(businessAlias = "a")
+ public List selectHealthScreenActivityList(HealthActivityDto dto);
+
+ /**
+ * 查询健康总览大屏近期就医明细
+ */
+ @DataScope(businessAlias = "a")
+ public List selectHealthScreenDoctorList(HealthDoctorRecordDto dto);
+
+ /**
+ * 查询健康总览大屏近期用药明细
+ */
+ @DataScope(businessAlias = "a")
+ public List selectHealthScreenMedicineList(HealthMarRecordDto dto);
+
+ /**
+ * 查询健康总览大屏近期体温明细
+ */
+ @DataScope(businessAlias = "a")
+ public List selectHealthScreenTemperatureList(HealthTemperatureRecordDto dto);
+
/**
* 查询用药记录
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/service/IChronicDiseaseManageService.java b/intc-modules/intc-health/src/main/java/com/intc/health/service/IChronicDiseaseManageService.java
new file mode 100644
index 0000000..335e9f7
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/service/IChronicDiseaseManageService.java
@@ -0,0 +1,33 @@
+package com.intc.health.service;
+
+import com.intc.health.domain.ChronicDiseaseFollowUpRecord;
+import com.intc.health.domain.ChronicDiseaseIndicatorRecord;
+import com.intc.health.domain.ChronicDiseaseStatusHistory;
+
+import java.util.List;
+
+public interface IChronicDiseaseManageService {
+ List selectIndicatorList(ChronicDiseaseIndicatorRecord query);
+
+ ChronicDiseaseIndicatorRecord selectIndicatorById(Long id);
+
+ int insertIndicator(ChronicDiseaseIndicatorRecord record);
+
+ int updateIndicator(ChronicDiseaseIndicatorRecord record);
+
+ int deleteIndicatorByIds(Long[] ids);
+
+ List selectFollowUpList(ChronicDiseaseFollowUpRecord query);
+
+ ChronicDiseaseFollowUpRecord selectFollowUpById(Long id);
+
+ int insertFollowUp(ChronicDiseaseFollowUpRecord record);
+
+ int updateFollowUp(ChronicDiseaseFollowUpRecord record);
+
+ int deleteFollowUpByIds(Long[] ids);
+
+ List selectStatusHistoryList(ChronicDiseaseStatusHistory query);
+
+ int insertStatusHistory(ChronicDiseaseStatusHistory record);
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/service/IStatisticAnalysisService.java b/intc-modules/intc-health/src/main/java/com/intc/health/service/IStatisticAnalysisService.java
index 1cb9763..aec658b 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/service/IStatisticAnalysisService.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/service/IStatisticAnalysisService.java
@@ -2,6 +2,8 @@ package com.intc.health.service;
import com.intc.health.domain.dto.AnalysisDto;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
import java.util.Map;
/**
@@ -17,9 +19,17 @@ public interface IStatisticAnalysisService {
public Map getHealthAnalysisInfo();
+ public Map getActivityAnalysis(AnalysisDto analysisDto);
+
+ public Map getHealthScreen(AnalysisDto analysisDto);
+
public Map getRecordAnalysis(AnalysisDto analysisDto);
+ public Map getRecordScreen(AnalysisDto analysisDto);
+
+ public void exportRecordFull(HttpServletResponse response, AnalysisDto analysisDto) throws IOException;
+
public Map getDoctorAnalysis(AnalysisDto analysisDto);
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseManageServiceImpl.java b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseManageServiceImpl.java
new file mode 100644
index 0000000..42bce07
--- /dev/null
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseManageServiceImpl.java
@@ -0,0 +1,109 @@
+package com.intc.health.service.impl;
+
+import com.intc.common.core.utils.DateUtils;
+import com.intc.common.core.utils.IdWorker;
+import com.intc.common.security.utils.SecurityUtils;
+import com.intc.health.domain.ChronicDiseaseFollowUpRecord;
+import com.intc.health.domain.ChronicDiseaseIndicatorRecord;
+import com.intc.health.domain.ChronicDiseaseStatusHistory;
+import com.intc.health.mapper.ChronicDiseaseManageMapper;
+import com.intc.health.service.IChronicDiseaseManageService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class ChronicDiseaseManageServiceImpl implements IChronicDiseaseManageService {
+ @Resource
+ private ChronicDiseaseManageMapper chronicDiseaseManageMapper;
+
+ @Override
+ public List selectIndicatorList(ChronicDiseaseIndicatorRecord query) {
+ return chronicDiseaseManageMapper.selectIndicatorList(query);
+ }
+
+ @Override
+ public ChronicDiseaseIndicatorRecord selectIndicatorById(Long id) {
+ return chronicDiseaseManageMapper.selectIndicatorById(id);
+ }
+
+ @Override
+ public int insertIndicator(ChronicDiseaseIndicatorRecord record) {
+ record.setId(IdWorker.getId());
+ record.setCreateBy(SecurityUtils.getUsername());
+ record.setCreateTime(DateUtils.getNowDate());
+ if (record.getMeasureTime() == null) {
+ record.setMeasureTime(new Date());
+ }
+ if (record.getStatus() == null) {
+ record.setStatus(1);
+ }
+ return chronicDiseaseManageMapper.insertIndicator(record);
+ }
+
+ @Override
+ public int updateIndicator(ChronicDiseaseIndicatorRecord record) {
+ record.setUpdateBy(SecurityUtils.getUsername());
+ record.setUpdateTime(DateUtils.getNowDate());
+ return chronicDiseaseManageMapper.updateIndicator(record);
+ }
+
+ @Override
+ public int deleteIndicatorByIds(Long[] ids) {
+ return chronicDiseaseManageMapper.removeIndicatorByIds(ids);
+ }
+
+ @Override
+ public List selectFollowUpList(ChronicDiseaseFollowUpRecord query) {
+ return chronicDiseaseManageMapper.selectFollowUpList(query);
+ }
+
+ @Override
+ public ChronicDiseaseFollowUpRecord selectFollowUpById(Long id) {
+ return chronicDiseaseManageMapper.selectFollowUpById(id);
+ }
+
+ @Override
+ public int insertFollowUp(ChronicDiseaseFollowUpRecord record) {
+ record.setId(IdWorker.getId());
+ record.setCreateBy(SecurityUtils.getUsername());
+ record.setCreateTime(DateUtils.getNowDate());
+ if (record.getFollowUpType() == null) {
+ record.setFollowUpType(1);
+ }
+ if (record.getStatus() == null) {
+ record.setStatus(1);
+ }
+ return chronicDiseaseManageMapper.insertFollowUp(record);
+ }
+
+ @Override
+ public int updateFollowUp(ChronicDiseaseFollowUpRecord record) {
+ record.setUpdateBy(SecurityUtils.getUsername());
+ record.setUpdateTime(DateUtils.getNowDate());
+ return chronicDiseaseManageMapper.updateFollowUp(record);
+ }
+
+ @Override
+ public int deleteFollowUpByIds(Long[] ids) {
+ return chronicDiseaseManageMapper.removeFollowUpByIds(ids);
+ }
+
+ @Override
+ public List selectStatusHistoryList(ChronicDiseaseStatusHistory query) {
+ return chronicDiseaseManageMapper.selectStatusHistoryList(query);
+ }
+
+ @Override
+ public int insertStatusHistory(ChronicDiseaseStatusHistory record) {
+ record.setId(IdWorker.getId());
+ record.setCreateBy(SecurityUtils.getUsername());
+ record.setCreateTime(DateUtils.getNowDate());
+ if (record.getChangeTime() == null) {
+ record.setChangeTime(new Date());
+ }
+ return chronicDiseaseManageMapper.insertStatusHistory(record);
+ }
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseRecordServiceImpl.java b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseRecordServiceImpl.java
index 8c6de32..7f8413a 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseRecordServiceImpl.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/ChronicDiseaseRecordServiceImpl.java
@@ -4,8 +4,10 @@ import com.intc.common.core.utils.DateUtils;
import com.intc.common.core.utils.IdWorker;
import com.intc.common.security.utils.SecurityUtils;
import com.intc.health.domain.ChronicDiseaseRecord;
+import com.intc.health.domain.ChronicDiseaseStatusHistory;
import com.intc.health.domain.dto.ChronicDiseaseRecordDto;
import com.intc.health.domain.vo.ChronicDiseaseRecordVo;
+import com.intc.health.mapper.ChronicDiseaseManageMapper;
import com.intc.health.mapper.ChronicDiseaseRecordMapper;
import com.intc.health.service.IChronicDiseaseRecordService;
import org.springframework.stereotype.Service;
@@ -25,6 +27,9 @@ public class ChronicDiseaseRecordServiceImpl implements IChronicDiseaseRecordSer
@Resource
private ChronicDiseaseRecordMapper chronicDiseaseRecordMapper;
+ @Resource
+ private ChronicDiseaseManageMapper chronicDiseaseManageMapper;
+
/**
* 查询慢性疾病档案
*
@@ -93,9 +98,29 @@ public class ChronicDiseaseRecordServiceImpl implements IChronicDiseaseRecordSer
@Override
public int updateChronicDiseaseRecord(ChronicDiseaseRecord chronicDiseaseRecord)
{
+ ChronicDiseaseRecordVo oldRecord = null;
+ if (chronicDiseaseRecord.getId() != null && chronicDiseaseRecord.getDiseaseStatus() != null) {
+ oldRecord = chronicDiseaseRecordMapper.selectChronicDiseaseRecordById(chronicDiseaseRecord.getId());
+ }
chronicDiseaseRecord.setUpdateBy(SecurityUtils.getUsername());
chronicDiseaseRecord.setUpdateTime(DateUtils.getNowDate());
- return chronicDiseaseRecordMapper.updateChronicDiseaseRecord(chronicDiseaseRecord);
+ int rows = chronicDiseaseRecordMapper.updateChronicDiseaseRecord(chronicDiseaseRecord);
+ if (rows > 0 && oldRecord != null && oldRecord.getDiseaseStatus() != null
+ && !oldRecord.getDiseaseStatus().equals(chronicDiseaseRecord.getDiseaseStatus())) {
+ ChronicDiseaseStatusHistory history = new ChronicDiseaseStatusHistory();
+ history.setId(IdWorker.getId());
+ history.setChronicDiseaseId(chronicDiseaseRecord.getId());
+ history.setPersonId(oldRecord.getPersonId());
+ history.setOldStatus(oldRecord.getDiseaseStatus());
+ history.setNewStatus(chronicDiseaseRecord.getDiseaseStatus());
+ history.setChangeTime(DateUtils.getNowDate());
+ history.setReason(chronicDiseaseRecord.getRemark() != null ? chronicDiseaseRecord.getRemark() : "档案状态调整");
+ history.setTreatmentAdvice(chronicDiseaseRecord.getNotes());
+ history.setCreateBy(SecurityUtils.getUsername());
+ history.setCreateTime(DateUtils.getNowDate());
+ chronicDiseaseManageMapper.insertStatusHistory(history);
+ }
+ return rows;
}
/**
@@ -121,4 +146,4 @@ public class ChronicDiseaseRecordServiceImpl implements IChronicDiseaseRecordSer
{
return chronicDiseaseRecordMapper.removeChronicDiseaseRecordById(id);
}
-}
\ No newline at end of file
+}
diff --git a/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/StatisticAnalysisImpl.java b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/StatisticAnalysisImpl.java
index 127e2e3..b9e01a9 100644
--- a/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/StatisticAnalysisImpl.java
+++ b/intc-modules/intc-health/src/main/java/com/intc/health/service/impl/StatisticAnalysisImpl.java
@@ -8,14 +8,33 @@ import com.intc.health.domain.dto.*;
import com.intc.health.domain.vo.*;
import com.intc.health.mapper.*;
import com.intc.health.service.IStatisticAnalysisService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.ss.usermodel.BorderStyle;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.CellStyle;
+import org.apache.poi.ss.usermodel.FillPatternType;
+import org.apache.poi.ss.usermodel.Font;
+import org.apache.poi.ss.usermodel.HorizontalAlignment;
+import org.apache.poi.ss.usermodel.IndexedColors;
+import org.apache.poi.ss.usermodel.PrintSetup;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.ss.usermodel.VerticalAlignment;
+import org.apache.poi.ss.util.CellRangeAddress;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
@Service
+@Slf4j
public class StatisticAnalysisImpl implements IStatisticAnalysisService {
@Resource
@@ -42,6 +61,9 @@ public class StatisticAnalysisImpl implements IStatisticAnalysisService {
@Resource
private HealthProcessRecordMapper healthProcessRecordMapper;
+ @Resource
+ private HealthDoctorRecordCostMapper healthDoctorRecordCostMapper;
+
@Override
public Map getMarAnalysis(AnalysisDto analysisDto) {
//返回数据
@@ -441,6 +463,140 @@ public class StatisticAnalysisImpl implements IStatisticAnalysisService {
return map;
}
+
+ @Override
+ public Map getHealthScreen(AnalysisDto analysisDto) {
+ long begin = System.currentTimeMillis();
+ DecimalFormat decimalFormat = new DecimalFormat("#.##");
+ HashMap map = new HashMap<>();
+ Long personId = analysisDto == null ? null : analysisDto.getId();
+
+ List allPersonList = healthPersonMapper.selectHealthPersonList(new HealthPersonDto());
+ List personList = filterHealthScreenPersonList(allPersonList, personId);
+ HealthRecordDto screenRecordDto = new HealthRecordDto();
+ screenRecordDto.setPersonId(personId);
+ List recordList = healthRecordMapper.selectHealthRecordList(screenRecordDto);
+ long baseLoaded = System.currentTimeMillis();
+ log.info("健康总览大屏-基础数据耗时: {}ms, personCount={}, recordCount={}", baseLoaded - begin, emptyList(personList).size(), emptyList(recordList).size());
+
+ String screenStartTime = new SimpleDateFormat("yyyy-MM-dd").format(DateUtils.addYears(new Date(), -1));
+ HealthRecordDto screenTrendRecordDto = new HealthRecordDto();
+ screenTrendRecordDto.setPersonId(personId);
+ screenTrendRecordDto.setStartTime(screenStartTime);
+ HealthDoctorRecordDto screenDoctorDto = new HealthDoctorRecordDto();
+ screenDoctorDto.setStartTime(screenStartTime);
+ screenDoctorDto.setPersonId(personId);
+ HealthMarRecordDto screenMarDto = new HealthMarRecordDto();
+ screenMarDto.setStartTime(screenStartTime);
+ screenMarDto.setPersonId(personId);
+ HealthTemperatureRecordDto screenTemperatureDto = new HealthTemperatureRecordDto();
+ screenTemperatureDto.setStartTime(screenStartTime);
+ screenTemperatureDto.setPersonId(personId);
+ HealthActivityDto screenActivityDto = new HealthActivityDto();
+
+ List trendRecordList = healthRecordMapper.selectHealthRecordList(screenTrendRecordDto);
+ List activityList = statisticAnalysisMapper.selectHealthScreenActivityList(screenActivityDto);
+ List doctorRecordList = statisticAnalysisMapper.selectHealthScreenDoctorList(screenDoctorDto);
+ List marRecordList = statisticAnalysisMapper.selectHealthScreenMedicineList(screenMarDto);
+ List temperatureRecordList = statisticAnalysisMapper.selectHealthScreenTemperatureList(screenTemperatureDto);
+ HealthDoctorRecordDto eventDoctorDto = new HealthDoctorRecordDto();
+ eventDoctorDto.setPersonId(personId);
+ HealthMarRecordDto eventMarDto = new HealthMarRecordDto();
+ eventMarDto.setPersonId(personId);
+ HealthTemperatureRecordDto eventTemperatureDto = new HealthTemperatureRecordDto();
+ eventTemperatureDto.setPersonId(personId);
+ List eventDoctorRecordList = statisticAnalysisMapper.selectHealthScreenDoctorList(eventDoctorDto);
+ List eventMarRecordList = statisticAnalysisMapper.selectHealthScreenMedicineList(eventMarDto);
+ List eventTemperatureRecordList = statisticAnalysisMapper.selectHealthScreenTemperatureList(eventTemperatureDto);
+ long detailLoaded = System.currentTimeMillis();
+ log.info("健康总览大屏-展示明细耗时: {}ms, activity={}, yearDoctor={}, yearMedicine={}, recentTemperature={}",
+ detailLoaded - baseLoaded,
+ emptyList(activityList).size(),
+ emptyList(doctorRecordList).size(),
+ emptyList(marRecordList).size(),
+ emptyList(temperatureRecordList).size());
+
+ HealthRecordDto rankDto = new HealthRecordDto();
+ rankDto.setPersonId(personId);
+ List staticPersonList = statisticAnalysisMapper.selectHealthScreenPersonRankList(rankDto);
+ long rankLoaded = System.currentTimeMillis();
+ log.info("健康总览大屏-成员排行耗时: {}ms, rankCount={}", rankLoaded - detailLoaded, emptyList(staticPersonList).size());
+
+ HealthDoctorRecordDto doctorSummaryDto = new HealthDoctorRecordDto();
+ doctorSummaryDto.setPersonId(personId);
+ HealthMarRecordDto medicineSummaryDto = new HealthMarRecordDto();
+ medicineSummaryDto.setPersonId(personId);
+ HealthTemperatureRecordDto temperatureSummaryDto = new HealthTemperatureRecordDto();
+ temperatureSummaryDto.setPersonId(personId);
+ Map doctorSummary = statisticAnalysisMapper.selectHealthScreenDoctorSummary(doctorSummaryDto);
+ Map medicineSummary = statisticAnalysisMapper.selectHealthScreenMedicineSummary(medicineSummaryDto);
+ Map temperatureSummary = statisticAnalysisMapper.selectHealthScreenTemperatureSummary(temperatureSummaryDto);
+ Map activitySummary = statisticAnalysisMapper.selectHealthScreenActivitySummary(new HealthActivityDto());
+ long summaryLoaded = System.currentTimeMillis();
+ log.info("健康总览大屏-汇总聚合耗时: {}ms", summaryLoaded - rankLoaded);
+
+ double doctorCost = numberValue(doctorSummary, "doctorCost");
+ double activityCost = numberValue(activitySummary, "activityCost");
+ long doctorCount = longValue(doctorSummary, "doctorCount");
+ long activityCount = longValue(activitySummary, "activityCount");
+ long marCount = longValue(medicineSummary, "marCount");
+ long temperatureTotalCount = longValue(temperatureSummary, "temperatureTotalCount");
+ long feverDayCount = longValue(temperatureSummary, "feverDayCount");
+
+ HashMap summary = new HashMap<>();
+ summary.put("selectedPersonId", personId);
+ summary.put("selectedPersonName", findHealthScreenPersonName(allPersonList, personId));
+ summary.put("personCount", emptyList(personList).size());
+ summary.put("healthRecordCount", emptyList(recordList).size());
+ summary.put("activityCount", activityCount);
+ summary.put("activityCost", decimalFormat.format(activityCost));
+ summary.put("doctorCount", doctorCount);
+ summary.put("doctorCost", decimalFormat.format(doctorCost));
+ summary.put("hospitalCount", longValue(doctorSummary, "hospitalCount"));
+ summary.put("doctorTotalCount", longValue(doctorSummary, "doctorTotalCount"));
+ summary.put("marCount", marCount);
+ summary.put("marDayCount", longValue(medicineSummary, "marDayCount"));
+ summary.put("medicalTypeCount", longValue(medicineSummary, "medicalTypeCount"));
+ summary.put("temperatureTotalCount", temperatureTotalCount);
+ summary.put("feverDayCount", feverDayCount);
+ summary.put("avgDoctorCost", decimalFormat.format(doctorCount == 0 ? 0D : doctorCost / doctorCount));
+ summary.put("avgActivityCost", decimalFormat.format(activityCount == 0 ? 0D : activityCost / activityCount));
+ summary.put("avgRecordPerPerson", decimalFormat.format(emptyList(personList).isEmpty() ? 0D : (double) emptyList(recordList).size() / personList.size()));
+ summary.put("healthIndex", buildHealthScreenIndex(personList, recordList, doctorCount, marCount, feverDayCount, longValue(temperatureSummary, "higherTempCount")));
+
+ map.put("summary", summary);
+ Map dictCache = new HashMap<>();
+ long buildStart = System.currentTimeMillis();
+ Map temperature = buildScreenTemperature(eventTemperatureRecordList);
+ map.put("temperature", temperature);
+ long temperatureBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-体温组装耗时: {}ms", temperatureBuilt - buildStart);
+ map.put("medicine", buildScreenMedicine(marRecordList, dictCache));
+ long medicineBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-用药组装耗时: {}ms", medicineBuilt - temperatureBuilt);
+ map.put("doctor", buildScreenDoctor(doctorRecordList));
+ long doctorBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-就医组装耗时: {}ms", doctorBuilt - medicineBuilt);
+ map.put("activity", buildHealthScreenActivity(activityList));
+ long activityBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-活动组装耗时: {}ms", activityBuilt - doctorBuilt);
+ Map record = buildHealthScreenRecord(recordList, personList, dictCache);
+ record.put("monthList", buildHealthScreenRecordMonthList(trendRecordList));
+ map.put("record", record);
+ long recordBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-档案组装耗时: {}ms", recordBuilt - activityBuilt);
+ map.put("personRankList", buildHealthScreenPersonRank(staticPersonList));
+ long rankBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-成员排行组装耗时: {}ms", rankBuilt - recordBuilt);
+ map.put("eventList", buildHealthScreenEvents(recordList, eventDoctorRecordList, eventMarRecordList, eventTemperatureRecordList, activityList, dictCache));
+ long eventBuilt = System.currentTimeMillis();
+ log.info("健康总览大屏-事件组装耗时: {}ms", eventBuilt - rankBuilt);
+ map.put("suggestionList", buildHealthScreenSuggestions(summary, temperatureRecordList, doctorRecordList, marRecordList));
+ log.info("健康总览大屏-建议组装耗时: {}ms", System.currentTimeMillis() - eventBuilt);
+ log.info("健康总览大屏-总耗时: {}ms", System.currentTimeMillis() - begin);
+ return map;
+ }
+
@Override
public Map getRecordAnalysis(AnalysisDto analysisDto) {
//返回数据
@@ -598,6 +754,1979 @@ public class StatisticAnalysisImpl implements IStatisticAnalysisService {
return map;
}
+ @Override
+ public Map getRecordScreen(AnalysisDto analysisDto) {
+ HashMap map = new HashMap<>();
+ Long recordId = analysisDto.getRecordId();
+ analysisDto.setRecordId(recordId);
+ analysisDto.setType(StringUtils.isEmpty(analysisDto.getType()) ? "1" : analysisDto.getType());
+
+ if (recordId == null) {
+ fillEmptyRecordScreen(map);
+ return map;
+ }
+
+ HealthRecordVo record = healthRecordMapper.selectHealthRecordById(recordId);
+ if (record == null) {
+ fillEmptyRecordScreen(map);
+ return map;
+ }
+ if (record.getRehabilitationTime() != null) {
+ record.setDuration(DateUtils.timeDistance(record.getRehabilitationTime(), record.getOccurTime()));
+ } else if (record.getOccurTime() != null) {
+ record.setDuration(DateUtils.timeDistance(new Date(), record.getOccurTime()));
+ }
+
+ HealthDoctorRecordDto doctorRecordDto = new HealthDoctorRecordDto();
+ doctorRecordDto.setHealthRecordId(recordId);
+ doctorRecordDto.setPersonId(analysisDto.getId());
+ doctorRecordDto.setStartTime(analysisDto.getStartTime());
+ doctorRecordDto.setEndTime(analysisDto.getEndTime());
+
+ HealthProcessRecordDto processRecordDto = new HealthProcessRecordDto();
+ processRecordDto.setHealthRecordId(recordId);
+ processRecordDto.setPersonId(analysisDto.getId());
+ processRecordDto.setStartTime(analysisDto.getStartTime());
+ processRecordDto.setEndTime(analysisDto.getEndTime());
+
+ HealthTemperatureRecordDto temperatureRecordDto = new HealthTemperatureRecordDto();
+ temperatureRecordDto.setHealthRecordId(recordId);
+ temperatureRecordDto.setPersonId(analysisDto.getId());
+ temperatureRecordDto.setStartTime(analysisDto.getStartTime());
+ temperatureRecordDto.setEndTime(analysisDto.getEndTime());
+
+ HealthMarRecordDto marRecordDto = new HealthMarRecordDto();
+ marRecordDto.setHealthRecordId(recordId);
+ marRecordDto.setPersonId(analysisDto.getId());
+ marRecordDto.setStartTime(analysisDto.getStartTime());
+ marRecordDto.setEndTime(analysisDto.getEndTime());
+
+ List doctorRecordList = healthDoctorRecordMapper.selectHealthDoctorRecordList(doctorRecordDto);
+ List processRecordList = healthProcessRecordMapper.selectHealthProcessRecordList(processRecordDto);
+ List temperatureRecordList = temperatureRecordMapper.selectHealthTemperatureRecordList(temperatureRecordDto);
+ List marRecordList = marRecordMapper.selectHealthMarRecordList(marRecordDto);
+
+ map.put("record", record);
+ map.put("summary", buildScreenSummary(record, doctorRecordList, processRecordList, temperatureRecordList, marRecordList));
+ map.put("doctor", buildScreenDoctor(doctorRecordList));
+ map.put("temperature", buildScreenTemperature(temperatureRecordList));
+ map.put("medicine", buildScreenMedicine(marRecordList));
+ map.put("doctorRecordList", doctorRecordList);
+ map.put("processRecordList", processRecordList);
+ map.put("temperatureRecordList", temperatureRecordList);
+ map.put("marRecordList", marRecordList);
+
+ return map;
+ }
+
+ private Map buildScreenSummary(HealthRecordVo record, List doctorRecordList,
+ List processRecordList,
+ List temperatureRecordList,
+ List marRecordList) {
+ DecimalFormat decimalFormat = new DecimalFormat("#.##");
+ HashMap summary = new HashMap<>();
+ summary.put("healthRecordCount", record == null ? 0 : 1);
+ summary.put("processRecordCount", emptyList(processRecordList).size());
+ summary.put("doctorCount", emptyList(doctorRecordList).size());
+ summary.put("doctorCost", decimalFormat.format(emptyList(doctorRecordList).stream().mapToDouble(this::safeTotalCost).sum()));
+ summary.put("hospitalCount", emptyList(doctorRecordList).stream().map(HealthDoctorRecordVo::getHospitalName).filter(StringUtils::isNotEmpty).distinct().count());
+ summary.put("doctorTotalCount", emptyList(doctorRecordList).stream().map(HealthDoctorRecordVo::getDoctor).filter(StringUtils::isNotEmpty).distinct().count());
+ summary.put("marDayCount", distinctDosingDateCount(emptyList(marRecordList)));
+ summary.put("marCount", emptyList(marRecordList).size());
+ summary.put("feverDayCount", emptyList(temperatureRecordList).stream()
+ .filter(item -> item.getTemperature() != null && item.getTemperature() >= 37)
+ .map(item -> formatDay(item.getMeasureTime()))
+ .filter(StringUtils::isNotEmpty)
+ .distinct()
+ .count());
+ summary.put("recordList", record == null ? new ArrayList<>() : Collections.singletonList(record));
+
+ ArrayList> recordCostList = new ArrayList<>();
+ if (record != null) {
+ Map costMap = new HashMap<>();
+ costMap.put("time", record.getName());
+ costMap.put("value", decimalFormat.format(emptyList(doctorRecordList).stream().mapToDouble(this::safeTotalCost).sum()));
+ recordCostList.add(costMap);
+ }
+ summary.put("recordCostList", recordCostList);
+ return summary;
+ }
+
+ private Map buildScreenDoctor(List doctorRecordList) {
+ DecimalFormat decimalFormat = new DecimalFormat("#.##");
+ HashMap doctor = new HashMap<>();
+ List list = emptyList(doctorRecordList);
+ doctor.put("doctorCount", list.size());
+ double doctorCost = list.stream().mapToDouble(this::safeTotalCost).sum();
+ doctor.put("doctorCost", decimalFormat.format(doctorCost));
+ doctor.put("avgDoctorCost", decimalFormat.format(list.isEmpty() ? 0D : doctorCost / list.size()));
+ doctor.put("hospitalCount", list.stream().map(HealthDoctorRecordVo::getHospitalName).filter(StringUtils::isNotEmpty).distinct().count());
+ doctor.put("doctorTotalCount", list.stream().map(HealthDoctorRecordVo::getDoctor).filter(StringUtils::isNotEmpty).distinct().count());
+ doctor.put("clinicCount", list.stream().filter(item -> "1".equals(item.getType())).count());
+ doctor.put("emergencyCount", list.stream().filter(item -> "2".equals(item.getType())).count());
+ doctor.put("hospitalizedCount", list.stream().filter(item -> "3".equals(item.getType())).count());
+ doctor.put("infusionCount", list.stream().filter(item -> "4".equals(item.getType())).count());
+ doctor.put("onlineCount", list.stream().filter(item -> "5".equals(item.getType())).count());
+
+ TreeMap costByDay = new TreeMap<>();
+ TreeMap countByDay = new TreeMap<>();
+ for (HealthDoctorRecordVo item : list) {
+ String day = formatDay(item.getVisitingTime());
+ if (StringUtils.isEmpty(day)) {
+ continue;
+ }
+ countByDay.put(day, countByDay.getOrDefault(day, 0) + 1);
+ costByDay.put(day, costByDay.getOrDefault(day, 0D) + safeTotalCost(item));
+ }
+ ArrayList> doctorCountList = new ArrayList<>();
+ for (Map.Entry entry : countByDay.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", entry.getKey());
+ dataMap.put("value", entry.getValue());
+ doctorCountList.add(dataMap);
+ }
+ ArrayList> doctorCostList = new ArrayList<>();
+ for (Map.Entry entry : costByDay.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", entry.getKey());
+ dataMap.put("value", decimalFormat.format(entry.getValue()));
+ doctorCostList.add(dataMap);
+ }
+ doctor.put("doctorCountList", doctorCountList);
+ doctor.put("doctorCostList", doctorCostList);
+ return doctor;
+ }
+
+ private Map buildScreenTemperature(List temperatureRecordList) {
+ DecimalFormat decimalFormat = new DecimalFormat("#.###");
+ SimpleDateFormat dateFormatSecond = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ HashMap temperature = new HashMap<>();
+ List list = new ArrayList<>(emptyList(temperatureRecordList));
+ list.sort(Comparator.comparing(HealthTemperatureRecordVo::getMeasureTime, Comparator.nullsLast(Date::compareTo)));
+
+ int normalTempCount = 0;
+ int lowerTempCount = 0;
+ int middleTempCount = 0;
+ int higherTempCount = 0;
+ double total = 0D;
+ double maxTemp = 0D;
+ double minTemp = 0D;
+ int validCount = 0;
+
+ ArrayList> temperatureList = new ArrayList<>();
+ TreeMap dayMap = new TreeMap<>();
+ for (HealthTemperatureRecordVo item : list) {
+ if (item.getTemperature() == null) {
+ continue;
+ }
+ double temp = item.getTemperature();
+ validCount++;
+ total += temp;
+ maxTemp = validCount == 1 ? temp : Math.max(maxTemp, temp);
+ minTemp = validCount == 1 ? temp : Math.min(minTemp, temp);
+ if (temp < 36.9) {
+ normalTempCount++;
+ } else if (temp <= 37.5) {
+ lowerTempCount++;
+ } else if (temp < 38.5) {
+ middleTempCount++;
+ } else {
+ higherTempCount++;
+ }
+
+ if (item.getMeasureTime() != null) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", dateFormatSecond.format(item.getMeasureTime()));
+ dataMap.put("value", decimalFormat.format(temp));
+ temperatureList.add(dataMap);
+ }
+
+ String day = formatDay(item.getMeasureTime());
+ if (StringUtils.isNotEmpty(day)) {
+ HealthStaticAnalysisVo analysisVo = dayMap.computeIfAbsent(day, key -> {
+ HealthStaticAnalysisVo vo = new HealthStaticAnalysisVo();
+ vo.setTime(key);
+ vo.setMax(0D);
+ vo.setMin(45D);
+ vo.setAverage(0D);
+ vo.setDetails("");
+ return vo;
+ });
+ analysisVo.setCount(analysisVo.getCount() + 1);
+ analysisVo.setMax(Math.max(analysisVo.getMax(), temp));
+ analysisVo.setMin(Math.min(analysisVo.getMin(), temp));
+ analysisVo.setAverage(analysisVo.getAverage() + temp);
+ analysisVo.setName(item.getPersonName());
+ }
+ }
+
+ ArrayList> tableList = new ArrayList<>();
+ int feverDay = 0;
+ for (HealthStaticAnalysisVo item : dayMap.values()) {
+ if (item.getMax() > 37) {
+ feverDay++;
+ }
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", item.getTime());
+ dataMap.put("count", item.getCount());
+ dataMap.put("name", item.getName());
+ dataMap.put("detail", item.getDetails());
+ dataMap.put("max", item.getMax());
+ dataMap.put("min", item.getMin() == 45D ? 0 : item.getMin());
+ dataMap.put("average", item.getCount() == 0 ? "0" : decimalFormat.format(item.getAverage() / item.getCount()));
+ tableList.add(dataMap);
+ }
+
+ temperature.put("averageTemp", validCount == 0 ? 0 : decimalFormat.format(total / validCount));
+ temperature.put("totalCount", validCount);
+ temperature.put("normalTempCount", normalTempCount);
+ temperature.put("lowerTempCount", lowerTempCount);
+ temperature.put("middleTempCount", middleTempCount);
+ temperature.put("higherTempCount", higherTempCount);
+ temperature.put("maxTemp", maxTemp);
+ temperature.put("minTemp", minTemp);
+ temperature.put("feverDay", feverDay);
+ temperature.put("temperatureList", temperatureList);
+ temperature.put("tableList", tableList);
+ return temperature;
+ }
+
+ private Map buildScreenMedicine(List marRecordList) {
+ return buildScreenMedicine(marRecordList, new HashMap<>());
+ }
+
+ private Map buildScreenMedicine(List marRecordList, Map dictCache) {
+ HashMap medicine = new HashMap<>();
+ List list = emptyList(marRecordList);
+ LinkedHashMap> rankMap = new LinkedHashMap<>();
+ TreeMap dayMap = new TreeMap<>();
+
+ for (HealthMarRecordVo item : list) {
+ String medicineName = StringUtils.isNotEmpty(item.getName()) ? item.getName() : "未命名药品";
+ String unitName = StringUtils.isNotEmpty(item.getUnitName()) ? item.getUnitName() : cachedDictLabel(dictCache, "medical_unit", item.getUnit());
+ String key = item.getMedicineId() + "|" + medicineName + "|" + item.getUnit() + "|" + item.getDosage();
+ Map rank = rankMap.computeIfAbsent(key, value -> {
+ Map dataMap = new HashMap<>();
+ dataMap.put("medicalName", medicineName);
+ dataMap.put("count", 0);
+ dataMap.put("unit", unitName);
+ dataMap.put("dosage", item.getDosage());
+ dataMap.put("useDays", new HashSet());
+ return dataMap;
+ });
+ rank.put("count", ((Integer) rank.get("count")) + 1);
+ String day = formatDay(item.getDosingTime());
+ if (StringUtils.isNotEmpty(day)) {
+ ((Set) rank.get("useDays")).add(day);
+ dayMap.put(day, dayMap.getOrDefault(day, 0) + 1);
+ }
+ }
+
+ ArrayList> marMapList = new ArrayList<>();
+ for (Map item : rankMap.values()) {
+ Set useDays = (Set) item.get("useDays");
+ item.put("useDays", useDays.size());
+ marMapList.add(item);
+ }
+ marMapList.sort((a, b) -> Integer.compare((Integer) b.get("count"), (Integer) a.get("count")));
+
+ ArrayList> marList = new ArrayList<>();
+ for (Map.Entry entry : dayMap.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", entry.getKey());
+ dataMap.put("value", entry.getValue());
+ marList.add(dataMap);
+ }
+
+ medicine.put("marCount", list.size());
+ medicine.put("marCategoryCount", marMapList.size());
+ medicine.put("marMapList", marMapList);
+ medicine.put("marDays", dayMap.size());
+ medicine.put("marList", marList);
+ return medicine;
+ }
+
+ private Map buildHealthScreenRecord(List recordList,
+ List personList,
+ Map dictCache) {
+ HashMap record = new HashMap<>();
+ List list = new ArrayList<>(emptyList(recordList));
+ int activeCount = 0;
+ int recoveredCount = 0;
+ int unknownStateCount = 0;
+ LinkedHashMap stateMap = new LinkedHashMap<>();
+ LinkedHashMap typeMap = new LinkedHashMap<>();
+ HashMap personRecordCountMap = new HashMap<>();
+ TreeMap monthMap = new TreeMap<>();
+
+ for (HealthRecordVo item : list) {
+ if (item.getPersonId() != null) {
+ personRecordCountMap.put(item.getPersonId(), personRecordCountMap.getOrDefault(item.getPersonId(), 0) + 1);
+ }
+
+ String state = StringUtils.isNotEmpty(item.getState()) ? item.getState() : "unknown";
+ if ("1".equals(state)) {
+ activeCount++;
+ } else if ("2".equals(state) || item.getRehabilitationTime() != null) {
+ recoveredCount++;
+ } else {
+ unknownStateCount++;
+ }
+ String stateName = "unknown".equals(state) ? "未设置" : cachedDictLabel(dictCache, "health_record_state", state);
+ stateMap.put(stateName, stateMap.getOrDefault(stateName, 0) + 1);
+
+ String type = StringUtils.isNotEmpty(item.getType()) ? item.getType() : "unknown";
+ String typeName = "unknown".equals(type) ? "未设置" : cachedDictLabel(dictCache, "record_type", type);
+ typeMap.put(typeName, typeMap.getOrDefault(typeName, 0) + 1);
+
+ String month = formatMonth(item.getOccurTime());
+ if (StringUtils.isNotEmpty(month)) {
+ monthMap.put(month, monthMap.getOrDefault(month, 0) + 1);
+ }
+ }
+
+ list.sort(Comparator.comparing(HealthRecordVo::getOccurTime, Comparator.nullsLast(Date::compareTo)).reversed());
+ record.put("activeCount", activeCount);
+ record.put("recoveredCount", recoveredCount);
+ record.put("unknownStateCount", unknownStateCount);
+ record.put("stateList", toNameValueList(stateMap));
+ record.put("typeList", toNameValueList(typeMap));
+ record.put("personRecordList", buildPersonRecordRank(personRecordCountMap, personList));
+ record.put("monthList", toTimeValueList(monthMap, 12));
+ record.put("recentList", limitList(list, 8));
+ return record;
+ }
+
+ private List> buildHealthScreenRecordMonthList(List recordList) {
+ TreeMap monthMap = new TreeMap<>();
+ for (HealthRecordVo item : emptyList(recordList)) {
+ String month = formatMonth(item.getOccurTime());
+ if (StringUtils.isNotEmpty(month)) {
+ monthMap.put(month, monthMap.getOrDefault(month, 0) + 1);
+ }
+ }
+ return toTimeValueList(monthMap, 12);
+ }
+
+ private List> buildPersonRecordRank(Map personRecordCountMap,
+ List personList) {
+ ArrayList> list = new ArrayList<>();
+ for (HealthPersonVo person : emptyList(personList)) {
+ if (person.getId() == null) {
+ continue;
+ }
+ int count = personRecordCountMap.getOrDefault(person.getId(), 0);
+ Map dataMap = new HashMap<>();
+ dataMap.put("name", StringUtils.isNotEmpty(person.getName()) ? person.getName() : "未命名成员");
+ dataMap.put("value", count);
+ list.add(dataMap);
+ }
+ list.sort((a, b) -> Integer.compare((Integer) b.get("value"), (Integer) a.get("value")));
+ return limitList(list, 12);
+ }
+
+ private List filterHealthScreenPersonList(List personList, Long personId) {
+ if (personId == null) {
+ return emptyList(personList);
+ }
+ ArrayList list = new ArrayList<>();
+ for (HealthPersonVo item : emptyList(personList)) {
+ if (Objects.equals(item.getId(), personId)) {
+ list.add(item);
+ break;
+ }
+ }
+ return list;
+ }
+
+ private String findHealthScreenPersonName(List personList, Long personId) {
+ if (personId == null) {
+ return "";
+ }
+ for (HealthPersonVo item : emptyList(personList)) {
+ if (Objects.equals(item.getId(), personId)) {
+ return item.getName();
+ }
+ }
+ return "";
+ }
+
+ private Map buildHealthScreenActivity(List activityList) {
+ DecimalFormat decimalFormat = new DecimalFormat("#.##");
+ HashMap activity = new HashMap<>();
+ TreeMap countMap = new TreeMap<>();
+ TreeMap costMap = new TreeMap<>();
+ LinkedHashMap typeMap = new LinkedHashMap<>();
+ List list = new ArrayList<>(emptyList(activityList));
+
+ for (HealthActivityVo item : list) {
+ String day = formatDay(item.getStartTime());
+ if (StringUtils.isNotEmpty(day)) {
+ countMap.put(day, countMap.getOrDefault(day, 0) + 1);
+ costMap.put(day, costMap.getOrDefault(day, 0D) + (item.getTotalCost() == null ? 0D : item.getTotalCost()));
+ }
+ String type = StringUtils.isNotEmpty(item.getType()) ? item.getType() : "未设置";
+ typeMap.put(type, typeMap.getOrDefault(type, 0) + 1);
+ }
+
+ list.sort(Comparator.comparing(HealthActivityVo::getStartTime, Comparator.nullsLast(Date::compareTo)).reversed());
+ activity.put("countTrend", toTimeValueList(countMap, 14));
+ activity.put("costTrend", toTimeValueList(costMap, 14, decimalFormat));
+ activity.put("typeList", toNameValueList(typeMap));
+ activity.put("recentList", limitList(list, 10));
+ return activity;
+ }
+
+ private List> buildHealthScreenPersonRank(List personList) {
+ ArrayList> list = new ArrayList<>();
+ for (HealthStaticPersonVo item : emptyList(personList)) {
+ int doctorCount = parseInt(item.getDoctorCount());
+ int feverDayCount = item.getFeverDayCount();
+ int marCount = parseInt(item.getMarCount());
+ int healthRecordCount = parseInt(item.getHealthRecordCount());
+ double doctorCost = parseDouble(item.getDoctorCost());
+ int riskScore = Math.min(100,
+ Math.min((int) Math.round(feverDayCount * 1.2), 35)
+ + Math.min((int) Math.round(doctorCount * 2.5), 30)
+ + Math.min((int) Math.round(marCount * 0.15), 12)
+ + Math.min(healthRecordCount * 2, 10)
+ + Math.min((int) Math.round(doctorCost / 1000), 13));
+ Map dataMap = new HashMap<>();
+ dataMap.put("personName", item.getPersonName());
+ dataMap.put("healthRecordCount", healthRecordCount);
+ dataMap.put("doctorCount", doctorCount);
+ dataMap.put("doctorCost", item.getDoctorCost());
+ dataMap.put("marCount", marCount);
+ dataMap.put("marDayCount", item.getMarDayCount());
+ dataMap.put("feverDayCount", feverDayCount);
+ dataMap.put("riskScore", riskScore);
+ dataMap.put("riskLevel", riskScore >= 75 ? "重点关注" : riskScore >= 45 ? "持续观察" : "整体平稳");
+ list.add(dataMap);
+ }
+ list.sort((a, b) -> Integer.compare((Integer) b.get("riskScore"), (Integer) a.get("riskScore")));
+ return limitList(list, 8);
+ }
+
+ private List> buildHealthScreenEvents(List recordList,
+ List doctorRecordList,
+ List marRecordList,
+ List temperatureRecordList,
+ List activityList,
+ Map dictCache) {
+ ArrayList> events = new ArrayList<>();
+ for (HealthRecordVo item : emptyList(recordList)) {
+ addHealthScreenEvent(events, "档案", item.getName(), item.getPersonName(), item.getOccurTime(), cachedDictLabel(dictCache, "record_type", item.getType()));
+ }
+ for (HealthDoctorRecordVo item : emptyList(doctorRecordList)) {
+ addHealthScreenEvent(events, "就医", item.getHospitalName(), item.getPersonName(), item.getVisitingTime(), item.getDiagnosis());
+ }
+ for (HealthMarRecordVo item : emptyList(marRecordList)) {
+ addHealthScreenEvent(events, "用药", StringUtils.isNotEmpty(item.getName()) ? item.getName() : "用药记录", item.getPersonName(), item.getDosingTime(), cachedDictLabel(dictCache, "mar_type", item.getType()));
+ }
+ for (HealthTemperatureRecordVo item : emptyList(temperatureRecordList)) {
+ addHealthScreenEvent(events, "体温", item.getTemperature() == null ? "--" : item.getTemperature() + "℃", item.getPersonName(), item.getMeasureTime(), item.getTemperature() != null && item.getTemperature() >= 37 ? "发热" : "正常");
+ }
+ for (HealthActivityVo item : emptyList(activityList)) {
+ addHealthScreenEvent(events, "活动", item.getName(), item.getPartner(), item.getStartTime(), item.getPlace());
+ }
+ events.sort((a, b) -> Long.compare((Long) b.get("sortTime"), (Long) a.get("sortTime")));
+ return limitList(events, 50);
+ }
+
+ private List> buildHealthScreenSuggestions(Map summary,
+ List temperatureRecordList,
+ List doctorRecordList,
+ List marRecordList) {
+ ArrayList> list = new ArrayList<>();
+ int feverDayCount = parseInt(String.valueOf(summary.get("feverDayCount")));
+ int doctorCount = parseInt(String.valueOf(summary.get("doctorCount")));
+ int marCount = parseInt(String.valueOf(summary.get("marCount")));
+ int temperatureCount = parseInt(String.valueOf(summary.get("temperatureTotalCount")));
+ if (feverDayCount > 0) {
+ list.add(buildSuggestion("体温关注", "累计发热天数 " + feverDayCount + " 天，建议关注高温记录与就医结果。", "warning"));
+ }
+ if (doctorCount > 0) {
+ list.add(buildSuggestion("就医追踪", "已有 " + doctorCount + " 次就医记录，建议定期复盘诊断结果和费用结构。", "normal"));
+ }
+ if (marCount > 0) {
+ list.add(buildSuggestion("用药管理", "累计 " + marCount + " 次用药记录，建议结合用药计划检查执行稳定性。", "normal"));
+ }
+ if (temperatureCount == 0) {
+ list.add(buildSuggestion("体温数据", "暂无体温记录，建议补充日常监测数据。", "info"));
+ }
+ if (emptyList(doctorRecordList).isEmpty() && emptyList(marRecordList).isEmpty()) {
+ list.add(buildSuggestion("数据完整度", "就医和用药记录较少，可继续完善健康过程数据。", "info"));
+ }
+ return limitList(list, 5);
+ }
+
+ private int buildHealthScreenIndex(List personList,
+ List recordList,
+ long doctorCount,
+ long marCount,
+ long feverDays,
+ long highTempCount) {
+ int score = 100;
+ int activeRecordCount = (int) emptyList(recordList).stream().filter(item -> "1".equals(item.getState()) || item.getRehabilitationTime() == null).count();
+ score -= Math.min((int) feverDays * 5, 25);
+ score -= Math.min((int) highTempCount * 5, 20);
+ score -= Math.min((int) doctorCount * 2, 20);
+ score -= Math.min(activeRecordCount * 2, 12);
+ if (emptyList(personList).size() > 0 && emptyList(recordList).isEmpty()) {
+ score -= 10;
+ }
+ if (!emptyList(recordList).isEmpty() && marCount == 0 && doctorCount == 0) {
+ score -= 8;
+ }
+ return Math.max(score, 35);
+ }
+
+ private double safeTotalCost(HealthDoctorRecordVo item) {
+ return item.getTotalCost() == null ? 0D : item.getTotalCost();
+ }
+
+ private int distinctDosingDateCount(List marRecordList) {
+ HashSet dateSet = new HashSet<>();
+ for (HealthMarRecordVo item : marRecordList) {
+ String day = formatDay(item.getDosingTime());
+ if (StringUtils.isNotEmpty(day)) {
+ dateSet.add(day);
+ }
+ }
+ return dateSet.size();
+ }
+
+ private String formatDay(Date date) {
+ if (date == null) {
+ return "";
+ }
+ return new SimpleDateFormat("yyyy-MM-dd").format(date);
+ }
+
+ private String formatMonth(Date date) {
+ if (date == null) {
+ return "";
+ }
+ return new SimpleDateFormat("yyyy-MM").format(date);
+ }
+
+ private void addHealthScreenEvent(List> events, String type, String title, String personName, Date time, String value) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("type", type);
+ dataMap.put("title", StringUtils.isNotEmpty(title) ? title : "--");
+ dataMap.put("personName", StringUtils.isNotEmpty(personName) ? personName : "--");
+ dataMap.put("time", formatDate(time));
+ dataMap.put("value", StringUtils.isNotEmpty(value) ? value : "--");
+ dataMap.put("sortTime", time == null ? 0L : time.getTime());
+ events.add(dataMap);
+ }
+
+ private Map buildSuggestion(String title, String content, String level) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("title", title);
+ dataMap.put("content", content);
+ dataMap.put("level", level);
+ return dataMap;
+ }
+
+ private List> toNameValueList(Map source) {
+ ArrayList> list = new ArrayList<>();
+ for (Map.Entry entry : source.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("name", entry.getKey());
+ dataMap.put("value", entry.getValue());
+ list.add(dataMap);
+ }
+ return list;
+ }
+
+ private List> toTimeValueList(Map source, int limit) {
+ ArrayList> list = new ArrayList<>();
+ for (Map.Entry entry : source.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", entry.getKey());
+ dataMap.put("value", entry.getValue());
+ list.add(dataMap);
+ }
+ return tailList(list, limit);
+ }
+
+ private List> toTimeValueList(Map source, int limit, DecimalFormat decimalFormat) {
+ ArrayList> list = new ArrayList<>();
+ for (Map.Entry entry : source.entrySet()) {
+ Map dataMap = new HashMap<>();
+ dataMap.put("time", entry.getKey());
+ dataMap.put("value", decimalFormat.format(entry.getValue()));
+ list.add(dataMap);
+ }
+ return tailList(list, limit);
+ }
+
+ private List limitList(List source, int limit) {
+ if (source == null || source.size() <= limit) {
+ return source == null ? new ArrayList<>() : source;
+ }
+ return new ArrayList<>(source.subList(0, limit));
+ }
+
+ private List tailList(List source, int limit) {
+ if (source == null || source.size() <= limit) {
+ return source == null ? new ArrayList<>() : source;
+ }
+ return new ArrayList<>(source.subList(source.size() - limit, source.size()));
+ }
+
+ private int parseInt(String value) {
+ if (StringUtils.isEmpty(value)) {
+ return 0;
+ }
+ try {
+ return Double.valueOf(value).intValue();
+ } catch (NumberFormatException e) {
+ return 0;
+ }
+ }
+
+ private double parseDouble(String value) {
+ if (StringUtils.isEmpty(value)) {
+ return 0D;
+ }
+ try {
+ return Double.parseDouble(value);
+ } catch (NumberFormatException e) {
+ return 0D;
+ }
+ }
+
+ private long longValue(Map map, String key) {
+ if (map == null || !map.containsKey(key) || map.get(key) == null) {
+ return 0L;
+ }
+ Object value = map.get(key);
+ if (value instanceof Number) {
+ return ((Number) value).longValue();
+ }
+ try {
+ return Double.valueOf(String.valueOf(value)).longValue();
+ } catch (NumberFormatException e) {
+ return 0L;
+ }
+ }
+
+ private double numberValue(Map map, String key) {
+ if (map == null || !map.containsKey(key) || map.get(key) == null) {
+ return 0D;
+ }
+ Object value = map.get(key);
+ if (value instanceof Number) {
+ return ((Number) value).doubleValue();
+ }
+ try {
+ return Double.parseDouble(String.valueOf(value));
+ } catch (NumberFormatException e) {
+ return 0D;
+ }
+ }
+
+ private void fillEmptyRecordScreen(Map map) {
+ HashMap summary = new HashMap<>();
+ summary.put("processRecordCount", 0);
+ summary.put("doctorCount", 0);
+ summary.put("doctorCost", 0);
+ summary.put("marDayCount", 0);
+ summary.put("marCount", 0);
+ summary.put("feverDayCount", 0);
+ summary.put("recordList", new ArrayList<>());
+ summary.put("recordCostList", new ArrayList<>());
+
+ HashMap doctor = new HashMap<>();
+ doctor.put("doctorCostList", new ArrayList<>());
+
+ HashMap temperature = new HashMap<>();
+ temperature.put("temperatureList", new ArrayList<>());
+ temperature.put("averageTemp", 0);
+ temperature.put("maxTemp", 0);
+ temperature.put("minTemp", 0);
+ temperature.put("totalCount", 0);
+
+ HashMap medicine = new HashMap<>();
+ medicine.put("marMapList", new ArrayList<>());
+ medicine.put("marList", new ArrayList<>());
+ medicine.put("marDays", 0);
+ medicine.put("marCategoryCount", 0);
+
+ map.put("record", null);
+ map.put("summary", summary);
+ map.put("doctor", doctor);
+ map.put("temperature", temperature);
+ map.put("medicine", medicine);
+ map.put("doctorRecordList", new ArrayList<>());
+ map.put("processRecordList", new ArrayList<>());
+ map.put("temperatureRecordList", new ArrayList<>());
+ map.put("marRecordList", new ArrayList<>());
+ }
+
+ @Override
+ public void exportRecordFull(HttpServletResponse response, AnalysisDto analysisDto) throws IOException {
+ Long recordId = analysisDto.getRecordId();
+ if (recordId == null) {
+ recordId = analysisDto.getId();
+ }
+ if (recordId == null) {
+ throw new IllegalArgumentException("健康档案id不能为空");
+ }
+ analysisDto.setRecordId(recordId);
+ analysisDto.setType(StringUtils.isEmpty(analysisDto.getType()) ? "1" : analysisDto.getType());
+
+ Map recordScreen = getRecordScreen(analysisDto);
+ HealthRecordVo record = (HealthRecordVo) recordScreen.get("record");
+ String fileName = (record != null && StringUtils.isNotEmpty(record.getName()) ? record.getName() : "健康档案") + "健康档案报告.xlsx";
+
+ HealthDoctorRecordCostDto costDto = new HealthDoctorRecordCostDto();
+ costDto.setHealthRecordId(recordId);
+ costDto.setPersonId(analysisDto.getId());
+ List doctorRecordCostList = healthDoctorRecordCostMapper.selectHealthDoctorRecordCostList(costDto);
+
+ try (Workbook workbook = new XSSFWorkbook()) {
+ createRecordReportSheet(workbook, recordScreen, doctorRecordCostList);
+
+ response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
+ response.setCharacterEncoding("utf-8");
+ response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
+ response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(fileName, "UTF-8"));
+ workbook.write(response.getOutputStream());
+ }
+ }
+
+ private AnalysisDto copyAnalysis(AnalysisDto source) {
+ AnalysisDto target = new AnalysisDto();
+ target.setId(source.getId());
+ target.setType(source.getType());
+ target.setStartTime(source.getStartTime());
+ target.setEndTime(source.getEndTime());
+ target.setDataType(source.getDataType());
+ target.setRecordId(source.getRecordId());
+ return target;
+ }
+
+ private List> buildRecordRows(HealthRecordVo record) {
+ List> rows = new ArrayList<>();
+ if (record == null) {
+ return rows;
+ }
+ rows.add(Arrays.asList("档案名称", record.getName()));
+ rows.add(Arrays.asList("人员姓名", record.getPersonName()));
+ rows.add(Arrays.asList("档案类型", dictLabel("record_type", record.getType())));
+ rows.add(Arrays.asList("档案状态", dictLabel("health_record_state", record.getState())));
+ rows.add(Arrays.asList("发生原因", dictLabel("etiology", record.getEtiology())));
+ rows.add(Arrays.asList("发生时间", formatReportDate(record.getOccurTime())));
+ rows.add(Arrays.asList("康复时间", formatReportDate(record.getRehabilitationTime())));
+ rows.add(Arrays.asList("康复周期", record.getDuration()));
+ rows.add(Arrays.asList("初期症状", record.getInitialSymptoms()));
+ rows.add(Arrays.asList("中期症状", record.getMediumTermSymptoms()));
+ rows.add(Arrays.asList("后期症状", record.getLaterStageSymptoms()));
+ rows.add(Arrays.asList("备注", record.getRemark()));
+ return rows;
+ }
+
+ private List> buildSummaryRows(Map recordScreen) {
+ Map summary = (Map) recordScreen.get("summary");
+ Map temperature = (Map) recordScreen.get("temperature");
+ List> rows = new ArrayList<>();
+ rows.add(Arrays.asList("过程记录", value(summary, "processRecordCount")));
+ rows.add(Arrays.asList("就医次数", value(summary, "doctorCount")));
+ rows.add(Arrays.asList("就医费用", value(summary, "doctorCost")));
+ rows.add(Arrays.asList("就医医院", value(summary, "hospitalCount")));
+ rows.add(Arrays.asList("医生数量", value(summary, "doctorTotalCount")));
+ rows.add(Arrays.asList("用药天数", value(summary, "marDayCount")));
+ rows.add(Arrays.asList("用药次数", value(summary, "marCount")));
+ rows.add(Arrays.asList("发烧天数", value(summary, "feverDayCount")));
+ rows.add(Arrays.asList("最高体温", value(temperature, "maxTemp")));
+ rows.add(Arrays.asList("最低体温", value(temperature, "minTemp")));
+ rows.add(Arrays.asList("平均体温", value(temperature, "averageTemp")));
+ rows.add(Arrays.asList("测温次数", value(temperature, "totalCount")));
+ return rows;
+ }
+
+ private List> buildProcessRows(List list) {
+ List> rows = new ArrayList<>();
+ for (HealthProcessRecordVo item : emptyList(list)) {
+ rows.add(Arrays.asList(formatDate(item.getRecordingTime()), item.getPersonName(), item.getHealthRecordName(), item.getContent(), item.getRemark()));
+ }
+ return rows;
+ }
+
+ private List> buildDoctorRows(List list) {
+ List> rows = new ArrayList<>();
+ for (HealthDoctorRecordVo item : emptyList(list)) {
+ rows.add(Arrays.asList(formatDate(item.getVisitingTime()), item.getPersonName(), item.getHealthRecordName(), item.getHospitalName(), item.getDepartments(),
+ item.getDoctor(), dictLabel("doctor_type", item.getType()), item.getTotalCost(), item.getDiagnosis(), item.getPrescribe(), item.getPartner(), item.getRemark()));
+ }
+ return rows;
+ }
+
+ private List> buildDoctorCostRows(List list) {
+ List> rows = new ArrayList<>();
+ for (HealthDoctorRecordCostVo item : emptyList(list)) {
+ rows.add(Arrays.asList(formatDate(item.getCostTime()), item.getCostName(), dictLabel("cost_type", item.getType()), dictLabel("check_type", item.getCheckType()),
+ item.getPrice(), item.getCount(), item.getUnit(), item.getTotalCost(), item.getRemark()));
+ }
+ return rows;
+ }
+
+ private List> buildTemperatureRows(List list) {
+ List> rows = new ArrayList<>();
+ for (HealthTemperatureRecordVo item : emptyList(list)) {
+ rows.add(Arrays.asList(formatDate(item.getMeasureTime()), item.getPersonName(), item.getHealthRecordName(), item.getTemperature(), item.getRemark()));
+ }
+ return rows;
+ }
+
+ private List> buildMarRows(List list) {
+ List> rows = new ArrayList<>();
+ for (HealthMarRecordVo item : emptyList(list)) {
+ rows.add(Arrays.asList(formatDate(item.getDosingTime()), item.getPersonName(), item.getHealthRecordName(), item.getName(), dictLabel("mar_type", item.getType()),
+ item.getDosage(), dictLabel("medical_unit", item.getUnit()), dictLabel("mar_resource", item.getResource()), dictLabel("mar_place", item.getPlace()),
+ item.getContent(), dictLabel("content_unit", item.getContentUnit()), item.getRemark()));
+ }
+ return rows;
+ }
+
+ private void createRecordReportSheet(Workbook workbook, Map recordScreen, List doctorRecordCostList) {
+ Sheet sheet = workbook.createSheet("健康档案报告");
+ setupRecordReportSheet(sheet);
+
+ CellStyle titleStyle = createReportTitleStyle(workbook);
+ CellStyle subtitleStyle = createReportSubtitleStyle(workbook);
+ CellStyle sectionStyle = createReportSectionStyle(workbook);
+ CellStyle subSectionStyle = createReportSubSectionStyle(workbook);
+ CellStyle labelStyle = createReportLabelStyle(workbook);
+ CellStyle valueStyle = createReportValueStyle(workbook);
+ CellStyle tableHeaderStyle = createReportTableHeaderStyle(workbook);
+ CellStyle tableBodyStyle = createReportTableBodyStyle(workbook);
+ CellStyle tableNoWrapBodyStyle = createReportTableNoWrapBodyStyle(workbook);
+
+ HealthRecordVo record = (HealthRecordVo) recordScreen.get("record");
+ int rowIndex = 0;
+
+ Row titleRow = sheet.createRow(rowIndex);
+ titleRow.setHeightInPoints(34);
+ String recordName = record == null || StringUtils.isEmpty(record.getName()) ? "健康档案" : record.getName();
+ setMergedCell(sheet, rowIndex, rowIndex, 0, 7,
+ "健康档案报告 - " + recordName + " 导出时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()),
+ titleStyle);
+ rowIndex++;
+ rowIndex++;
+
+ rowIndex = writeSectionTitle(sheet, rowIndex, "一、档案基础信息", sectionStyle);
+ rowIndex = writeKeyValueGrid(sheet, rowIndex, buildRecordReportRows(record), labelStyle, valueStyle);
+ rowIndex = writeWideKeyRows(sheet, rowIndex, buildRecordReportLongRows(record), labelStyle, valueStyle);
+ rowIndex++;
+
+ rowIndex = writeSectionTitle(sheet, rowIndex, "二、核心统计概览", sectionStyle);
+ rowIndex = writeKeyValueGrid(sheet, rowIndex, buildReportSummaryRows(recordScreen), labelStyle, valueStyle);
+ rowIndex++;
+
+ rowIndex = writeSectionTitle(sheet, rowIndex, "三、统计分析", sectionStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "每日体温用药明细", subSectionStyle);
+ rowIndex = writeDailyHealthDetailTable(sheet, rowIndex, buildDailyHealthDetailRows(recordScreen), tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "体温统计", subSectionStyle);
+ rowIndex = writeReportTable(sheet, rowIndex, Arrays.asList("统计项", "数值", "统计项", "数值", "统计项", "数值", "统计项", "数值"),
+ buildTemperatureReportRows(recordScreen), 0, tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "用药频次", subSectionStyle);
+ rowIndex = writeMedicineRankTable(sheet, rowIndex, buildMedicineRankReportRows(recordScreen), tableHeaderStyle, tableBodyStyle, tableNoWrapBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "就医费用统计", subSectionStyle);
+ rowIndex = writeCostSummaryTable(sheet, rowIndex, buildCostSummaryReportRows(doctorRecordCostList), tableHeaderStyle, tableBodyStyle);
+ rowIndex++;
+
+ rowIndex = writeSectionTitle(sheet, rowIndex, "四、档案全量明细", sectionStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "过程记录（共 " + emptyList((List) recordScreen.get("processRecordList")).size() + " 条）", subSectionStyle);
+ rowIndex = writeProcessReportTable(sheet, rowIndex,
+ buildProcessReportRows((List) recordScreen.get("processRecordList")), tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "就医记录（共 " + emptyList((List) recordScreen.get("doctorRecordList")).size() + " 条）", subSectionStyle);
+ rowIndex = writeReportTable(sheet, rowIndex, Arrays.asList("就诊时间", "医院", "科室", "医生", "类型", "费用", "诊断", "处理及医嘱/备注"),
+ buildDoctorReportRows((List) recordScreen.get("doctorRecordList")), 0, tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "就医费用明细（共 " + emptyList(doctorRecordCostList).size() + " 条）", subSectionStyle);
+ rowIndex = writeDoctorCostDetailTable(sheet, rowIndex, buildDoctorCostReportRows(doctorRecordCostList), tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "体温记录（共 " + emptyList((List) recordScreen.get("temperatureRecordList")).size() + " 条）", subSectionStyle);
+ rowIndex = writeTemperatureDetailTable(sheet, rowIndex, buildTemperatureReportDetailRows((List) recordScreen.get("temperatureRecordList")), tableHeaderStyle, tableBodyStyle);
+ rowIndex = writeSubSectionTitle(sheet, rowIndex, "用药记录（共 " + emptyList((List) recordScreen.get("marRecordList")).size() + " 条）", subSectionStyle);
+ rowIndex = writeMarReportTable(sheet, rowIndex, buildMarReportRows((List) recordScreen.get("marRecordList")), tableHeaderStyle, tableBodyStyle, tableNoWrapBodyStyle);
+
+ sheet.setRepeatingRows(CellRangeAddress.valueOf("1:1"));
+ workbook.setPrintArea(workbook.getSheetIndex(sheet), 0, 7, 0, Math.max(rowIndex, 1));
+ }
+
+ private void setupRecordReportSheet(Sheet sheet) {
+ int[] widths = {18, 14, 14, 18, 14, 18, 14, 22};
+ for (int i = 0; i < widths.length; i++) {
+ sheet.setColumnWidth(i, widths[i] * 256);
+ }
+ sheet.setDisplayGridlines(false);
+ sheet.setFitToPage(true);
+ sheet.setAutobreaks(true);
+ sheet.createFreezePane(0, 2);
+ sheet.setMargin(Sheet.LeftMargin, 0.35D);
+ sheet.setMargin(Sheet.RightMargin, 0.35D);
+ sheet.setMargin(Sheet.TopMargin, 0.5D);
+ sheet.setMargin(Sheet.BottomMargin, 0.5D);
+ PrintSetup printSetup = sheet.getPrintSetup();
+ printSetup.setPaperSize(PrintSetup.A4_PAPERSIZE);
+ printSetup.setFitWidth((short) 1);
+ printSetup.setFitHeight((short) 0);
+ printSetup.setLandscape(false);
+ sheet.setHorizontallyCenter(true);
+ }
+
+ private List> buildRecordReportRows(HealthRecordVo record) {
+ List> rows = new ArrayList<>();
+ if (record == null) {
+ rows.add(Arrays.asList("档案名称", "", "人员姓名", "", "档案类型", "", "档案状态", ""));
+ return rows;
+ }
+ rows.add(Arrays.asList("档案名称", record.getName(), "人员姓名", record.getPersonName(), "档案类型", dictLabel("record_type", record.getType()), "档案状态", dictLabel("health_record_state", record.getState())));
+ rows.add(Arrays.asList("发生原因", dictLabel("etiology", record.getEtiology()), "发生时间", formatReportDate(record.getOccurTime()), "康复时间", formatReportDate(record.getRehabilitationTime()), "康复周期", record.getDuration()));
+ return rows;
+ }
+
+ private List> buildRecordReportLongRows(HealthRecordVo record) {
+ List> rows = new ArrayList<>();
+ if (record == null) {
+ return rows;
+ }
+ rows.add(Arrays.asList("初期症状", record.getInitialSymptoms()));
+ rows.add(Arrays.asList("中期症状", record.getMediumTermSymptoms()));
+ rows.add(Arrays.asList("后期症状", record.getLaterStageSymptoms()));
+ rows.add(Arrays.asList("备注", record.getRemark()));
+ return rows;
+ }
+
+ private List> buildReportSummaryRows(Map recordScreen) {
+ Map summary = (Map) recordScreen.get("summary");
+ Map temperature = (Map) recordScreen.get("temperature");
+ List> rows = new ArrayList<>();
+ rows.add(Arrays.asList("过程记录", value(summary, "processRecordCount"), "就医次数", value(summary, "doctorCount"), "就医费用", value(summary, "doctorCost"), "就医医院", value(summary, "hospitalCount")));
+ rows.add(Arrays.asList("医生数量", value(summary, "doctorTotalCount"), "用药天数", value(summary, "marDayCount"), "用药次数", value(summary, "marCount"), "发热天数", value(summary, "feverDayCount")));
+ rows.add(Arrays.asList("测温次数", value(temperature, "totalCount"), "平均体温", appendUnit(value(temperature, "averageTemp"), "℃"), "最高体温", appendUnit(value(temperature, "maxTemp"), "℃"), "最低体温", appendUnit(value(temperature, "minTemp"), "℃")));
+ return rows;
+ }
+
+ private List> buildDailyHealthDetailRows(Map recordScreen) {
+ TreeMap>> dayMap = new TreeMap<>();
+ List processList = (List) recordScreen.get("processRecordList");
+ List marList = (List) recordScreen.get("marRecordList");
+ List temperatureList = (List