|
|
@ -3,6 +3,8 @@ package com.yihu.jw.care.service.statistics;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.yihu.jw.care.dao.device.PatientDeviceDao;
|
|
|
import com.yihu.jw.care.util.CommonUtil;
|
|
|
import com.yihu.jw.care.util.ConstantUtil;
|
|
|
import com.yihu.jw.care.vo.NumVo;
|
|
|
import com.yihu.jw.dict.dao.DictHospitalDeptDao;
|
|
|
@ -11,23 +13,35 @@ import com.yihu.jw.doctor.dao.BaseDoctorHospitalDao;
|
|
|
import com.yihu.jw.entity.base.doctor.BaseDoctorDO;
|
|
|
import com.yihu.jw.entity.base.login.BaseLoginLogDO;
|
|
|
import com.yihu.jw.entity.base.patient.BasePatientDO;
|
|
|
import com.yihu.jw.entity.care.device.DevicePatientDevice;
|
|
|
import com.yihu.jw.entity.hospital.message.SystemMessageDO;
|
|
|
import com.yihu.jw.es.util.ElasticsearchUtil;
|
|
|
import com.yihu.jw.es.util.SaveModel;
|
|
|
import com.yihu.jw.hospital.message.dao.SystemMessageDao;
|
|
|
import com.yihu.jw.im.util.ImUtil;
|
|
|
import com.yihu.jw.message.dao.MessageDao;
|
|
|
import com.yihu.jw.org.dao.BaseOrgDao;
|
|
|
import com.yihu.jw.patient.dao.BasePatientDao;
|
|
|
import com.yihu.jw.restmodel.web.PageEnvelop;
|
|
|
import com.yihu.jw.util.common.IdCardUtil;
|
|
|
import com.yihu.jw.util.date.DateUtil;
|
|
|
import org.apache.commons.collections.map.HashedMap;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.data.domain.Page;
|
|
|
import org.springframework.data.domain.PageRequest;
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
import javax.persistence.Transient;
|
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
|
|
import java.awt.print.Pageable;
|
|
|
import java.text.DecimalFormat;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
@ -56,6 +70,14 @@ public class StatisticsService {
|
|
|
private StatisticsUtilService statisticsUtilService;
|
|
|
@Autowired
|
|
|
private BasePatientDao patientDao;
|
|
|
@Autowired
|
|
|
private CommonUtil commonUtil;
|
|
|
@Autowired
|
|
|
private SystemMessageDao messageDao;
|
|
|
@Autowired
|
|
|
private PatientDeviceDao patientDeviceDao;
|
|
|
@Autowired
|
|
|
private SystemMessageDao systemMessageDao;
|
|
|
|
|
|
private static final String defalutArea = "330100";
|
|
|
|
|
|
@ -454,8 +476,8 @@ public class StatisticsService {
|
|
|
}
|
|
|
|
|
|
|
|
|
String sql1 = "SELECT COUNT(*) c,IFNULL(on_line,0) online from base_patient a WHERE archive_type = 1" +
|
|
|
" and del='1' "+oldFilter+" GROUP BY on_line";
|
|
|
String sql1 = "SELECT COUNT(*) c,case 1 WHEN openid is not null then 1 WHEN a.on_line = '1' then 1 ELSE 0 end as online from base_patient a WHERE archive_type = 1" +
|
|
|
" and del='1' "+oldFilter+" GROUP BY online";
|
|
|
List<Map<String,Object>> list1 = jdbcTemplate.queryForList(sql1);
|
|
|
for(Map<String,Object> map:list1){
|
|
|
Integer num = Integer.valueOf(map.get("c").toString());
|
|
|
@ -528,14 +550,21 @@ public class StatisticsService {
|
|
|
public JSONObject statisticsTotalAmount( String endDate, String area, int level, String index, String type) throws Exception {
|
|
|
JSONObject res = new JSONObject();
|
|
|
String[] indexes = index.split(",");
|
|
|
String areaLevel = null;
|
|
|
for(String ind:indexes){
|
|
|
//总量
|
|
|
SaveModel saveModel = elasticsearchUtil.findOneDateQuotaLevel0(endDate, endDate, area, level, ind, SaveModel.timeLevel_DDL);
|
|
|
if (ind.equals("41")||ind.equals("46")){//指标统计最小单位
|
|
|
areaLevel="4";
|
|
|
}
|
|
|
if (ind.equals("45")){
|
|
|
areaLevel="2";
|
|
|
}
|
|
|
SaveModel saveModel = elasticsearchUtil.findOneDateQuotaLevel0(endDate, endDate, area, level, ind, SaveModel.timeLevel_DDL,areaLevel);
|
|
|
res.put("index_"+ind+"_total",saveModel.getResult2().longValue());
|
|
|
if(StringUtils.isNotBlank(type)){
|
|
|
//周/月 增量
|
|
|
String start = statisticsUtilService.calStart(endDate,type);
|
|
|
SaveModel saveModelAdd = elasticsearchUtil.findOneDateQuotaLevel0(start, endDate, area, level, ind, SaveModel.timeLevel_ZL);
|
|
|
SaveModel saveModelAdd = elasticsearchUtil.findOneDateQuotaLevel0(start, endDate, area, level, ind, SaveModel.timeLevel_ZL,areaLevel);
|
|
|
|
|
|
res.put("index_"+ind+"_add",saveModelAdd.getResult2().longValue());
|
|
|
}
|
|
|
@ -647,7 +676,6 @@ public class StatisticsService {
|
|
|
*/
|
|
|
public JSONObject patientAnalysis(String endDate, String area, int level,String index) throws Exception{
|
|
|
JSONObject res = new JSONObject();
|
|
|
|
|
|
String areaLevel = "6";
|
|
|
if("42".equals(index)){
|
|
|
areaLevel = "4";
|
|
|
@ -667,26 +695,31 @@ public class StatisticsService {
|
|
|
}else{
|
|
|
//老人
|
|
|
//能力评估 从签约时服务标签取
|
|
|
JSONArray levelArray = new JSONArray();
|
|
|
String sql = " select dict.dict_code,dict_value,count(DISTINCT lab.patient) total from wlyy_hospital_sys_dict dict \n" +
|
|
|
"LEFT JOIN wlyy_patient_label lab on dict.dict_code = lab.label_code AND lab.label_type='1' " +
|
|
|
"where dict.dict_name='service_type' and dict.dict_code is not null and dict_code<>5 \n" +
|
|
|
" GROUP BY dict.dict_code; ";
|
|
|
List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
|
|
|
|
|
|
String older = " select count(DISTINCT patient) from wlyy_patient_label where label_type='1' ";
|
|
|
Integer count = jdbcTemplate.queryForObject(older,Integer.class);
|
|
|
res.put("levelList",capacityAssessment(null,null,null));
|
|
|
|
|
|
for(Map<String,Object> map:list){
|
|
|
//居民健康标签
|
|
|
List<SaveModel> list = elasticsearchUtil.findDateAllQuotaLevel1(endDate,endDate,area,level,"47",SaveModel.timeLevel_DDL,null,null,"2");
|
|
|
JSONArray labelArr = new JSONArray();
|
|
|
Long total = 0l;
|
|
|
for(int i=0;i<list.size();i++){
|
|
|
SaveModel saveModel = list.get(i);
|
|
|
JSONObject json = new JSONObject();
|
|
|
DecimalFormat df = new DecimalFormat("0.00");
|
|
|
json.put("rate", df.format((Integer.parseInt(map.get("total").toString())*1.00) / count * 100));
|
|
|
json.put("num", map.get("total"));
|
|
|
json.put("code",map.get("dict_code").toString());
|
|
|
json.put("name",map.get("dict_value").toString());
|
|
|
levelArray.add(json);
|
|
|
if (saveModel.getResult2().longValue()==0&&StringUtils.isBlank(saveModel.getSlaveKey1())){
|
|
|
continue;
|
|
|
}
|
|
|
if ("0".equals(saveModel.getSlaveKey1())){//去除60岁以下老人
|
|
|
continue;
|
|
|
}
|
|
|
json.put("num",saveModel.getResult2().longValue());
|
|
|
json.put("code",saveModel.getSlaveKey1());
|
|
|
json.put("name",saveModel.getSlaveKey1Name());
|
|
|
total+=saveModel.getResult2().longValue();
|
|
|
labelArr.add(json);
|
|
|
}
|
|
|
res.put("levelList",levelArray);
|
|
|
JSONObject arrTmp = new JSONObject();
|
|
|
arrTmp.put("patientLabelTotal",total);
|
|
|
arrTmp.put("patientLabelList",labelArr);
|
|
|
res.put("patientLabelStatistic",arrTmp);
|
|
|
|
|
|
//年龄分布 50
|
|
|
// ageList = elasticsearchUtil.findDateAllQuotaLevel1(endDate, endDate, area, level, "50", SaveModel.timeLevel_DDL,null,null,"2");
|
|
|
@ -704,17 +737,47 @@ public class StatisticsService {
|
|
|
ageArray.add(json);
|
|
|
}
|
|
|
res.put("ageList",ageArray);
|
|
|
}
|
|
|
|
|
|
//性别
|
|
|
List<SaveModel> sexList = elasticsearchUtil.findDateAllQuotaLevel2(endDate, endDate, area, level, index, SaveModel.timeLevel_DDL,null,null,areaLevel);
|
|
|
//居住小区分布
|
|
|
String filter = "";
|
|
|
String sqltmp = "SELECT GROUP_CONCAT(dict_code) orgCodes from wlyy_hospital_sys_dict WHERE dict_name = 'jkzl_child' or dict_name = 'jkzl_older' ";
|
|
|
List<Map<String,Object>> listtmp = jdbcTemplate.queryForList(sqltmp);
|
|
|
if(listtmp.size()>0){
|
|
|
String orgCodes = String.valueOf(listtmp.get(0).get("orgCodes"));
|
|
|
orgCodes = orgCodes.replaceAll(",","','");
|
|
|
filter = " not in ('"+orgCodes+"')";
|
|
|
}
|
|
|
String sql = "select count(id) total,residential_area residentialArea from base_patient where del=1 and id "+filter+" and archive_type=1 " +
|
|
|
"GROUP BY residential_area ORDER BY total desc";
|
|
|
List<Map<String,Object>> result = jdbcTemplate.queryForList(sql);
|
|
|
Iterator<Map<String, Object>> iterator = result.iterator();
|
|
|
Map<String, Object> tmp = new HashMap<>();
|
|
|
while (iterator.hasNext()){
|
|
|
tmp = iterator.next();
|
|
|
if (null==tmp.get("residentialArea")){
|
|
|
iterator.remove();
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
result.add(tmp);
|
|
|
res.put("residentialArea",result);
|
|
|
}
|
|
|
//性别分析
|
|
|
String archiType="";
|
|
|
if("42".equals(index)){
|
|
|
archiType="2";
|
|
|
}
|
|
|
if("37".equals(index)){
|
|
|
archiType="1";
|
|
|
}
|
|
|
List<SaveModel> sexList = elasticsearchUtil.findDateQuotaLevel2ByKeyGroup(endDate, endDate,defalutArea, level, "51",SaveModel.timeLevel_DDL,null,archiType,null,null,"2","1");
|
|
|
JSONArray sexArray = new JSONArray();
|
|
|
for(int i=0;i<sexList.size();i++){
|
|
|
SaveModel saveModel = sexList.get(i);
|
|
|
JSONObject json = new JSONObject();
|
|
|
json.put("num",saveModel.getResult2().longValue());
|
|
|
json.put("code",saveModel.getSlaveKey2());
|
|
|
json.put("name",saveModel.getSlaveKey2Name());
|
|
|
json.put("code",saveModel.getSlaveKey1());
|
|
|
json.put("name",saveModel.getSlaveKey1Name());
|
|
|
sexArray.add(json);
|
|
|
}
|
|
|
res.put("sexList",sexArray);
|
|
|
@ -778,16 +841,24 @@ public class StatisticsService {
|
|
|
/**
|
|
|
* 能力评估评估类型
|
|
|
*/
|
|
|
public JSONArray capacityAssessment(String endDate, String area, int level) throws Exception{
|
|
|
public JSONArray capacityAssessment(String endDate, String area, Integer level) throws Exception{
|
|
|
//评估类型
|
|
|
String filter = "";
|
|
|
String sqltmp = "SELECT GROUP_CONCAT(dict_code) orgCodes from wlyy_hospital_sys_dict WHERE dict_name = 'jkzl_child' or dict_name = 'jkzl_older' ";
|
|
|
List<Map<String,Object>> listtmp = jdbcTemplate.queryForList(sqltmp);
|
|
|
if(listtmp.size()>0){
|
|
|
String orgCodes = String.valueOf(listtmp.get(0).get("orgCodes"));
|
|
|
orgCodes = orgCodes.replaceAll(",","','");
|
|
|
filter = " not in ('"+orgCodes+"')";
|
|
|
}
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
String sql = " select dict.dict_code,dict_value,count(DISTINCT lab.patient) total from wlyy_hospital_sys_dict dict \n" +
|
|
|
"LEFT JOIN wlyy_patient_label lab on dict.dict_code = lab.label_code AND lab.label_type='1' " +
|
|
|
"where dict.dict_name='service_type' and dict.dict_code is not null and dict_code<>5 \n" +
|
|
|
"where dict.dict_name='service_type' and lab.patient "+filter+" and dict.dict_code is not null and dict_code<>5 \n" +
|
|
|
" GROUP BY dict.dict_code; ";
|
|
|
List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
|
|
|
|
|
|
String older = " select count(DISTINCT patient) from wlyy_patient_label where label_type='1' ";
|
|
|
String older = " select count(DISTINCT patient) from wlyy_patient_label where label_type='1' and patient "+filter;
|
|
|
Integer count = jdbcTemplate.queryForObject(older,Integer.class);
|
|
|
|
|
|
for(Map<String,Object> map:list){
|
|
|
@ -956,6 +1027,328 @@ public class StatisticsService {
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 管理端首页老人接入情况
|
|
|
* @return
|
|
|
*/
|
|
|
public JSONObject olderBindingDeviceStatus(String area){
|
|
|
JSONObject result = new JSONObject();
|
|
|
String filter = "";
|
|
|
String sqltmp = "SELECT GROUP_CONCAT(dict_code) orgCodes from wlyy_hospital_sys_dict WHERE dict_name = 'jkzl_child' or dict_name = 'jkzl_older' ";
|
|
|
List<Map<String,Object>> listtmp = jdbcTemplate.queryForList(sqltmp);
|
|
|
if(listtmp.size()>0){
|
|
|
String orgCodes = String.valueOf(listtmp.get(0).get("orgCodes"));
|
|
|
orgCodes = orgCodes.replaceAll(",","','");
|
|
|
filter = " not in ('"+orgCodes+"')";
|
|
|
}
|
|
|
String sql =" select count(id) from base_patient where del=1 and id "+filter;
|
|
|
Integer olderCount = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
|
|
|
sql = " select count(DISTINCT pd.id) from base_patient p INNER JOIN wlyy_patient_device pd on p.id = pd.user and pd.del=0 where p.del=1 and p.id "+filter;
|
|
|
Integer bindingCount = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
result.put("olderCount",olderCount);
|
|
|
result.put("bindingCount",bindingCount);
|
|
|
result.put("range",commonUtil.getRange(bindingCount,olderCount));
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 管理端安防监护新增分析
|
|
|
*/
|
|
|
public JSONObject statisticsSecurityOlder( String endDate, String area, int level, String type) throws Exception {
|
|
|
JSONObject res = new JSONObject();
|
|
|
String areaLevel = "4";
|
|
|
areaLevel="4";
|
|
|
SaveModel saveModel = elasticsearchUtil.findOneDateQuotaLevel0(endDate, endDate, area, level, "46", SaveModel.timeLevel_DDL,areaLevel);
|
|
|
res.put("index_"+46+"_total",saveModel.getResult2().longValue());
|
|
|
if(StringUtils.isNotBlank(type)){
|
|
|
//周/月 增量
|
|
|
String start = statisticsUtilService.calStart(endDate,type);
|
|
|
SaveModel saveModelAdd = elasticsearchUtil.findOneDateQuotaLevel0(start, endDate, area, level, "46", SaveModel.timeLevel_ZL,areaLevel);
|
|
|
res.put("index_"+46+"_add",saveModelAdd.getResult2().longValue());
|
|
|
}
|
|
|
JSONArray addDetail = new JSONArray();
|
|
|
if(StringUtils.isNotBlank(type)){
|
|
|
//周/月 增量
|
|
|
String start = statisticsUtilService.calStart(endDate,type);
|
|
|
|
|
|
List<SaveModel> saveModelAdds = elasticsearchUtil.findDateQuotaLevelList(start,endDate, area,level, "46", SaveModel.timeLevel_ZL, "3",null,null,null);
|
|
|
for (SaveModel saveModelTmp:saveModelAdds){
|
|
|
JSONObject json = new JSONObject();
|
|
|
SaveModel saveMode2 = elasticsearchUtil.findOneDateQuotaLevels(endDate,endDate, area,level, "46", SaveModel.timeLevel_DDL, "3",null,null,saveModelTmp.getSlaveKey3());
|
|
|
json.put("total",saveMode2.getResult2().longValue());
|
|
|
json.put("num",saveModelTmp.getResult2().longValue());
|
|
|
json.put("code",saveModelTmp.getSlaveKey3());
|
|
|
json.put("name",saveModelTmp.getSlaveKey3Name());
|
|
|
addDetail.add(json);
|
|
|
}
|
|
|
}
|
|
|
res.put("index_add_detail",addDetail);
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
public JSONObject deviceGrantAndService(){
|
|
|
JSONObject result = new JSONObject();
|
|
|
String filter = "";
|
|
|
String sqltmp = "SELECT GROUP_CONCAT(dict_code) orgCodes from wlyy_hospital_sys_dict WHERE dict_name = 'jkzl_child' or dict_name = 'jkzl_older' ";
|
|
|
List<Map<String,Object>> listtmp = jdbcTemplate.queryForList(sqltmp);
|
|
|
if(listtmp.size()>0){
|
|
|
String orgCodes = String.valueOf(listtmp.get(0).get("orgCodes"));
|
|
|
orgCodes = orgCodes.replaceAll(",","','");
|
|
|
filter = " not in ('"+orgCodes+"')";
|
|
|
}
|
|
|
String sql =" select count(DISTINCT device_code) from wlyy_devices ";
|
|
|
Integer deviceTotal = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
|
|
|
sql = " select count(DISTINCT wd.device_code) from wlyy_devices wd INNER JOIN wlyy_patient_device pd " +
|
|
|
" ON pd.device_sn = wd.device_code AND pd.del=0 and pd.user "+filter;
|
|
|
Integer bindingCount = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
jsonObject.put("deviceTotal",deviceTotal);
|
|
|
jsonObject.put("bindingCount",bindingCount);
|
|
|
jsonObject.put("range",commonUtil.getRange(bindingCount,deviceTotal));
|
|
|
result.put("deviceGrant",jsonObject);
|
|
|
sql =" SELECT sde.`value`,COUNT(d.id) count,GROUP_CONCAT(DISTINCT d.category_code SEPARATOR ',') AS category_code," +
|
|
|
" GROUP_CONCAT(DISTINCT d.model SEPARATOR ',') AS model FROM base_system_dict_entry sde LEFT JOIN dm_device d " +
|
|
|
" ON FIND_IN_SET(sde.`code`,d.service_topic) WHERE sde.remark = 'security' GROUP BY sde.`value` ";
|
|
|
List<Map<String,Object>> deviceService = jdbcTemplate.queryForList(sql);
|
|
|
result.put("deviceService",deviceService);
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
public PageEnvelop getAllDeviceLostMessage(String area,Integer page,Integer size){
|
|
|
page = page>0?page-1:0;
|
|
|
String sql ="select GROUP_CONCAT(id) id,type,title,sender,sender_name senderName,\n" +
|
|
|
"receiver,receiver_name receiverName,relation_code relationCode,\n" +
|
|
|
"data,is_read isRead,create_time createTime,sender_photo\n" +
|
|
|
"from base_system_message where type=43 and del=1 GROUP BY relation_code order by createTime desc ";
|
|
|
|
|
|
Long count = jdbcTemplate.queryForObject(" select count(id) from ("+sql+")A ",Long.class);
|
|
|
sql +=" limit "+page*size+","+size ;
|
|
|
List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
|
|
|
|
|
|
return PageEnvelop.getSuccessListWithPage("查询成功",list,page++,size,count);
|
|
|
|
|
|
}
|
|
|
|
|
|
@Transactional
|
|
|
public void delMessageRead(String msgId){
|
|
|
if (StringUtils.isNotBlank(msgId)){
|
|
|
String[] ids = msgId.split(",");
|
|
|
if (ids.length>0){
|
|
|
systemMessageDao.delMessage(ids);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public JSONObject deviceUsingInfo(String area){
|
|
|
JSONObject result = new JSONObject();
|
|
|
String sql = "SELECT COUNT(DISTINCT device_sn) FROM wlyy_patient_device WHERE del = 0";
|
|
|
Integer use = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
sql = "SELECT COUNT(DISTINCT device_code) FROM wlyy_devices ";
|
|
|
Integer total = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
result.put("use",use);//使用中
|
|
|
result.put("putOnFile",total);//采购
|
|
|
result.put("stock",total-use);//库存
|
|
|
|
|
|
sql = "SELECT DISTINCT count(wd.device_code) FROM wlyy_devices wd INNER JOIN wlyy_patient_device pd on " +
|
|
|
"wd.device_code =pd.device_sn WHERE contact_status = 0";//contact_status = 0 失联
|
|
|
Integer lost = jdbcTemplate.queryForObject(sql,Integer.class);
|
|
|
//物联率 失联率
|
|
|
result.put("deviceAll",total);//物联率分母总数 设备总数（包括库存）
|
|
|
result.put("lost",lost);//失联数
|
|
|
result.put("notLost",use);//物联数 被人绑定了就是物联
|
|
|
result.put("deviceAll2",use);//失联数分母总数 发出的设备数
|
|
|
result.put("iotRange",commonUtil.getRange(use,total));
|
|
|
result.put("LostRange",commonUtil.getRange(lost,use));
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
public PageEnvelop getSecurityOrderList(String area,String status, String svrDesc,String topicItem, Integer page, Integer pageSize){
|
|
|
page = page>1?page-1:0;
|
|
|
JSONArray result = new JSONArray();
|
|
|
|
|
|
String sqlCount = "select count(ord.id) from base_security_monitoring_order ord INNER JOIN base_patient p on p.id = ord.patient " +
|
|
|
"where 1=1 ";
|
|
|
String fliter = " ";
|
|
|
String sql = " select p.id patientCode,p.name,p.sex,p.photo,p.idcard,ord.id orderId,ord.number,ord.serve_desc,ord.create_time,ord.`status`,ord.doctor," +
|
|
|
"ord.doctor_name,ord.update_user,ord.update_user_name,ord.patient_phone,ord.conclusion_status from base_security_monitoring_order ord INNER JOIN base_patient p on p.id = ord.patient " +
|
|
|
"where 1=1 ";
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(status)){
|
|
|
fliter+=" and ord.status='"+Integer.parseInt(status)+"' ";
|
|
|
}
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(svrDesc)){
|
|
|
fliter+=" and ord.serve_desc='"+svrDesc+"' ";
|
|
|
}
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(topicItem)){
|
|
|
fliter+=" and ord.topic_item='"+topicItem+"' ";
|
|
|
}
|
|
|
Long count = jdbcTemplate.queryForObject(sqlCount+fliter,Long.class);
|
|
|
fliter+=" order by ord.create_time desc limit " + (page*pageSize) + "," + pageSize;
|
|
|
List<Map<String,Object>> sqlResult = jdbcTemplate.queryForList(sql+fliter);
|
|
|
|
|
|
for (Map<String,Object>one:sqlResult){
|
|
|
JSONObject tmp = new JSONObject();
|
|
|
tmp.put("patientCode",one.get("patientCode"));
|
|
|
tmp.put("patientName",one.get("name"));
|
|
|
tmp.put("sex",one.get("sex"));
|
|
|
tmp.put("photo",one.get("photo"));
|
|
|
tmp.put("idcard",one.get("idcard"));
|
|
|
tmp.put("number",one.get("number"));
|
|
|
tmp.put("id",one.get("orderId"));
|
|
|
tmp.put("serveDesc",one.get("serve_desc"));
|
|
|
Date date = (Date)one.get("create_time");
|
|
|
tmp.put("createTime", DateUtil.dateToStrLong(date));
|
|
|
tmp.put("status",one.get("status"));
|
|
|
tmp.put("doctor",one.get("doctor"));
|
|
|
tmp.put("doctorName",one.get("doctor_name"));
|
|
|
tmp.put("patientPhone",one.get("patient_phone"));
|
|
|
tmp.put("conclusionStatus",one.get("conclusion_status"));
|
|
|
Integer conclusionStatus = Integer.valueOf(one.get("conclusion_status")==null?"0":(one.get("conclusion_status")+""));
|
|
|
String conclusionStatusName = "";
|
|
|
switch (conclusionStatus){
|
|
|
case 1:conclusionStatusName="待补录";break;
|
|
|
case 2:conclusionStatusName="已登记";break;
|
|
|
}
|
|
|
tmp.put("conclusionStatusName",conclusionStatusName);
|
|
|
Integer statustemp = Integer.valueOf(one.get("status")+"");
|
|
|
if (-2==statustemp||-1==statustemp){
|
|
|
tmp.put("doctor",one.get("update_user"));
|
|
|
tmp.put("doctorName",one.get("update_user_name"));
|
|
|
}
|
|
|
String statusName = "";
|
|
|
switch (statustemp){
|
|
|
case -2:statusName="误警报";break;
|
|
|
case -1:statusName="已取消";break;
|
|
|
case 0:statusName="已完成";break;
|
|
|
case 1:statusName="预警中";break;
|
|
|
}
|
|
|
tmp.put("statusName",statusName);
|
|
|
Integer age = IdCardUtil.getAgeForIdcard(tmp.getString("idcard"));
|
|
|
tmp.put("age",age);
|
|
|
//患者设备
|
|
|
List<DevicePatientDevice> devices = patientDeviceDao.findAllByUser(tmp.get("patientCode").toString());
|
|
|
if (devices.size()>0){
|
|
|
tmp.put("deviceFlag","1");
|
|
|
}
|
|
|
else {
|
|
|
tmp.put("deviceFlag","0");
|
|
|
}
|
|
|
result.add(tmp);
|
|
|
}
|
|
|
return PageEnvelop.getSuccessListWithPage("success",result,page,pageSize,count);
|
|
|
}
|
|
|
|
|
|
public JSONObject getSecurityTab(String area,String status,String svrDesc,String topicItem){
|
|
|
|
|
|
if (StringUtils.isNotBlank(area)){
|
|
|
|
|
|
}
|
|
|
|
|
|
JSONObject result = new JSONObject();
|
|
|
result.put("status_-2",0);//误报警
|
|
|
result.put("status_-1",0);//已取消
|
|
|
result.put("status_0",0);//已完成
|
|
|
result.put("status_1",0);//预警中
|
|
|
result.put("status_all",0);//
|
|
|
result.put("svr_all",0);//
|
|
|
|
|
|
Map<String,String> serverTmp = new HashMap<>();
|
|
|
|
|
|
String sql = " select py_code,dict_value from wlyy_hospital_sys_dict where dict_name='security_server_dict' ";
|
|
|
List<Map<String,Object>> servers = jdbcTemplate.queryForList(sql);
|
|
|
for (Map<String,Object> server:servers){
|
|
|
result.put("svr_"+server.get("py_code").toString(),0);
|
|
|
serverTmp.put(server.get("dict_value").toString(),server.get("py_code").toString());
|
|
|
}
|
|
|
sql = "select ord.status,ord.serve_desc,count(ord.id) count from base_security_monitoring_order ord INNER JOIN base_patient p on p.id = ord.patient " +
|
|
|
"where 1=1 ";
|
|
|
String fliter = " ";
|
|
|
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(status)){
|
|
|
fliter+=" and ord.status='"+Integer.parseInt(status)+"' ";
|
|
|
}
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(svrDesc)){
|
|
|
fliter+=" and ord.serve_desc='"+svrDesc+"' ";
|
|
|
}
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(topicItem)){
|
|
|
fliter+=" and ord.topic_item='"+topicItem+"' ";
|
|
|
}
|
|
|
fliter+=" group by ord.status,ord.serve_desc ";
|
|
|
List<Map<String,Object>> sqlResult = jdbcTemplate.queryForList(sql+fliter);
|
|
|
String pyCode = "";
|
|
|
for (Map<String,Object> map:sqlResult){
|
|
|
result.put("status_"+map.get("status"),result.getInteger("status_"+map.get("status"))+Integer.parseInt(map.get("count").toString()));
|
|
|
pyCode = serverTmp.get(map.get("serve_desc"))==null?null:serverTmp.get(map.get("serve_desc")).toString();
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(pyCode)){
|
|
|
result.put("svr_"+pyCode,result.getInteger("svr_"+pyCode)+Integer.parseInt(map.get("count").toString()));
|
|
|
result.put("status_all",result.getInteger("status_all")+Integer.parseInt(map.get("count").toString()));
|
|
|
result.put("svr_all",result.getInteger("svr_all")+Integer.parseInt(map.get("count").toString()));
|
|
|
}
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
public JSONObject statisticsSecurityWarnInfo(String endDate,String area,Integer level,String index) throws Exception {
|
|
|
JSONObject res = new JSONObject();
|
|
|
String[] indexes = index.split(",");
|
|
|
for(String ind:indexes){
|
|
|
String areaLevel="6";
|
|
|
String sql = " select area_level from wlyy_job_config_new where id='"+ind+"' ";
|
|
|
List<String> areaLevels = jdbcTemplate.queryForList(sql,String.class);
|
|
|
if (areaLevels.size()>0){
|
|
|
areaLevel = areaLevels.get(0);
|
|
|
}
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
long total = 0l;
|
|
|
//总量
|
|
|
List<SaveModel> list = elasticsearchUtil.findDateAllQuotaLevel1(endDate,endDate,area,level,ind,SaveModel.timeLevel_DDL,null,null,areaLevel);
|
|
|
for(int i=0;i<list.size();i++){
|
|
|
SaveModel saveModel = list.get(i);
|
|
|
JSONObject json = new JSONObject();
|
|
|
if (saveModel.getResult2().longValue()==0&&StringUtils.isBlank(saveModel.getSlaveKey1())){
|
|
|
continue;
|
|
|
}
|
|
|
if ("0".equals(saveModel.getSlaveKey1())){
|
|
|
continue;
|
|
|
}
|
|
|
json.put("num",saveModel.getResult2().longValue());
|
|
|
json.put("code",saveModel.getSlaveKey1());
|
|
|
json.put("name",saveModel.getSlaveKey1Name());
|
|
|
total+=saveModel.getResult2().longValue();
|
|
|
jsonArray.add(json);
|
|
|
}
|
|
|
res.put("index_"+ind+"_total",total);
|
|
|
res.put("index_"+ind,jsonArray);
|
|
|
if("46".equals(ind)){
|
|
|
//安防响应 误报警+完成
|
|
|
SaveModel saveModel = elasticsearchUtil.findOneDateQuotaLevel2NoSlaveKey1(endDate,area,level,"46","2","-2",areaLevel);
|
|
|
long finish = saveModel.getResult2().longValue();
|
|
|
saveModel = elasticsearchUtil.findOneDateQuotaLevel2NoSlaveKey1(endDate,area,level,"46","2","0",areaLevel);
|
|
|
finish += saveModel.getResult2().longValue();
|
|
|
res.put("index_"+46+"_finish",finish);
|
|
|
//安防误报警
|
|
|
saveModel = elasticsearchUtil.findOneDateQuotaLevel2NoSlaveKey1(endDate,area,level,"46","2","-2",areaLevel);
|
|
|
res.put("index_"+46+"_error",saveModel.getResult2().longValue());
|
|
|
}
|
|
|
}
|
|
|
//误报警率分析
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
public JSONArray statisticsSecurityTrend(String startDate,String endDate,String area,Integer level,String index) throws Exception {
|
|
|
//安防总数
|
|
|
List<SaveModel> saveModels = elasticsearchUtil.findDateQuotaLevel0(startDate,endDate,area,level,index,SaveModel.timeLevel_DDL,SaveModel.interval_day,null);
|
|
|
JSONArray jsonArray = new JSONArray();
|
|
|
for (SaveModel tmp:saveModels){
|
|
|
JSONObject jsonTmp = new JSONObject();
|
|
|
jsonTmp.put("count",tmp.getResult2().longValue());
|
|
|
jsonTmp.put("timeDay",DateUtil.dateToStr(tmp.getQuotaDate(),DateUtil.YYYY_MM_DD));
|
|
|
jsonTmp.put("time",DateUtil.dateToStr(tmp.getQuotaDate(),DateUtil.yyyy_MM_dd_HH_mm_ss));
|
|
|
jsonArray.add(jsonTmp);
|
|
|
}
|
|
|
return jsonArray;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 计算开始时间
|
|
|
@ -979,4 +1372,11 @@ public class StatisticsService {
|
|
|
}
|
|
|
return DateUtil.dateToStrShort(cal.getTime());
|
|
|
}
|
|
|
|
|
|
public List searchBySql(String sql){
|
|
|
if (sql.startsWith("select")||sql.startsWith("SELECT")){
|
|
|
return elasticsearchUtil.searchBySql(sql);
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
}
|
