package com.yihu.wlyy.job; import com.yihu.wlyy.entity.organization.Hospital; import com.yihu.wlyy.entity.address.Town; import com.yihu.wlyy.entity.doctor.profile.Doctor; import com.yihu.wlyy.entity.doctor.team.sign.DoctorPatientGroupInfo; import com.yihu.wlyy.entity.job.QuartzJobLog; import com.yihu.wlyy.entity.patient.SignFamily; import com.yihu.wlyy.entity.statistics.WlyyQuotaResult; import com.yihu.wlyy.repository.address.TownDao; import com.yihu.wlyy.repository.doctor.DoctorDao; import com.yihu.wlyy.repository.doctor.DoctorPatientGroupInfoDao; import com.yihu.wlyy.repository.job.QuartzJobLogDao; import com.yihu.wlyy.repository.organization.HospitalDao; import com.yihu.wlyy.repository.patient.SignFamilyDao; import com.yihu.wlyy.repository.statistics.WlyyQuotaResultDao; import com.yihu.wlyy.util.IdCardUtil; import com.yihu.wlyy.web.quota.WlyyJobConfigVO; import com.yihu.wlyy.web.quota.WlyyQuotaVO; import org.json.JSONArray; import org.json.JSONObject; import org.quartz.Job; import org.quartz.JobDataMap; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.springframework.web.context.support.SpringBeanAutowiringSupport; import java.text.SimpleDateFormat; import java.util.*; /** * 签约的指标执行类 */ @Component public class SignJob implements Job { private WlyyQuotaVO wlyyQuota;//指标对象 private WlyyJobConfigVO wlyyJobConfig;//配置对象 @Autowired private WlyyQuotaResultDao wlyyQuotaResultDao;//指标结果Dao @Autowired private QuartzJobLogDao quartzJobLogDao;//执行日志Dao @Autowired private SignFamilyDao signFamilyDao; @Autowired private DoctorDao doctorDao; @Autowired private HospitalDao hospitalDao; @Autowired private TownDao townDao; @Autowired private DoctorPatientGroupInfoDao doctorPatientGroupInfoDao; @Autowired private JdbcTemplate jdbcTemplate; @Autowired private StringRedisTemplate redisTemplate; String yesterday; String now; @Override public void execute(JobExecutionContext context) throws JobExecutionException { SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this); //初始化参数 JobDataMap map = context.getJobDetail().getJobDataMap(); wlyyQuota = (WlyyQuotaVO) map.get("quota"); wlyyJobConfig = (WlyyJobConfigVO) map.get("jobConfig"); now = StringUtils.isEmpty(map.get("now")) ? SignJob.getDayString(0) : map.get("now").toString(); yesterday = StringUtils.isEmpty(map.get("yesterday")) ? SignJob.getDayString(-1) : map.get("yesterday").toString(); String level1 = wlyyQuota.getLevel1();//得到一级维度 String level2 = wlyyQuota.getLevel2();//得到二级维度 //如果一级维度为空 不进行统计 if (!StringUtils.isEmpty(level1)) { if (StringUtils.isEmpty(level2)) { //線刪除今天的数据 //2级维度是空按照一级的机构唯独计算指标 computequota(); } else { switch (level2) { case "1": { //線刪除今天的数据 //患者性别 computequotaByPatientSex(); break; } case "2": { //患者分组 computequotaByPatientGroup(); break; } case "3": { //患者年龄 computequotaByPatientAge(); break; } } } } } /** * 机构维度下患者性别维度计算指标 */ @Transactional private void computequotaByPatientSex() { jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 6 + "'"); try { //新建任务日志对象 QuartzJobLog QuartzJobLog = new QuartzJobLog(); QuartzJobLog.setJobStartTime(new Date()); QuartzJobLog.setJobId(wlyyJobConfig.getId()); QuartzJobLog.setJobName(wlyyJobConfig.getJobName()); //查找出系统全部的机构 List hospitals = hospitalDao.findHospitalzxFWZ(); Map hospitalsMap = new HashMap(); for (Hospital hospital : hospitals) { hospitalsMap.put(hospital.getCode(), hospital); } //查找出厦门市全部的区 List towns = townDao.findByCityCode(Constant.city); Map townsMap = new HashMap(); for (Town town : towns) { townsMap.put(town.getCode(), town); } //找出今天的签约信息 List signFamilys = signFamilyDao.findByJiatingSignYesterday(yesterday, now); //数组里面第一个是女 第二个是男 第三个是未知 Map> citySexMap = new HashMap>();//key是市行政代码 目前只有厦门市 citySexMap.put(Constant.city, new HashMap()); Map> townSexMap = new HashMap>();//key是区行政代码 Map> orgSexMap = new HashMap>();//key是机构代码 //统计有签约的 for (SignFamily signFamily : signFamilys) { String idcard = signFamily.getIdcard();//得到签约中患者的身份证号 String orgCodeTemp=getOrg(signFamily.getHospital()); Hospital hospital = hospitalsMap.get(orgCodeTemp);//得到患者签约的机构 String town = hospital.getTown();//得到患者签约的机构的区号 String hospitalCode = hospital.getCode();//得到患者签约的机构号 String sex = IdCardUtil.getSexForIdcard(idcard);//根据身份证得到性别 //统计市 目前只统计厦门市 所以先写死 后期再改造 compute_level2_1(citySexMap,Constant.city, sex); //统计区 compute_level2_1(townSexMap,town, sex); //统计机构 //统计站 String orgCode=hospital.getCode(); if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){ //统计站 orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00"; compute_level2_1(orgSexMap,orgCodeTemp, sex); } else { //统计社区 compute_level2_1(orgSexMap,hospitalCode, sex); } } //保存统计数据 //保存市统计数据 for (Map.Entry> entry : citySexMap.entrySet()) { for(int i=1;i<4;i++){ String key=i+""; String city=Constant.city; String cityName=Constant.cityName; String town=""; String townName=""; String org=""; String orgName=""; // modifid by lyr 2016-09-29 //String level="3"; String level="4"; // modifid by lyr 2016-09-29 save_level2_1(entry.getValue(), key, city, cityName, town, townName, org, orgName, level); } } //保存区的统计数据 for (Map.Entry townEntry : townsMap.entrySet()) { //判断该区是否有统计数据 Map oneTownSexMap = townSexMap.get(townEntry.getKey());//得到当个区的统计数据 Town townObj = townEntry.getValue();//得到区级信息 for(int i=1;i<4;i++){ String key=i+""; String city=Constant.city; String cityName=Constant.cityName; String town=townObj.getCode(); String townName=townObj.getName(); String org=""; String orgName=""; String level="3"; save_level2_1(oneTownSexMap, key, city, cityName, town, townName, org, orgName, level); } } //统计机构 for (Map.Entry hospitalEntry : hospitalsMap.entrySet()) { //判断该机构是否有统计数据 Map oneorgSexMap = orgSexMap.get(hospitalEntry.getKey());//得到当个机构的统计数据 Hospital hospital = hospitalEntry.getValue();//得到区级信息 for(int i=1;i<4;i++){ String key=i+""; String city=Constant.city; String cityName=Constant.cityName; String town=hospital.getTown(); String townName=hospital.getTownName(); String org=hospital.getCode(); String orgName=hospital.getName(); String level="2"; save_level2_1(oneorgSexMap, key, city, cityName, town, townName, org, orgName, level); } } QuartzJobLog.setJobEndTime(new Date()); QuartzJobLog.setJobContent("统计" + getYesterday() + " 的签约性别数据完成 ,得到签约数目:"+signFamilys.size()); QuartzJobLog.setJobType("1"); quartzJobLogDao.save(QuartzJobLog); } catch (Exception e) { e.printStackTrace(); } } /** * 机构维度下患者性别维度计算指标 公用保存方法 * @param oneorgSexMap * @param key * @param city * @param cityName * @param town * @param townName * @param org * @param orgName * @param level */ private void save_level2_1(Map oneorgSexMap, String key, String city, String cityName, String town, String townName, String org, String orgName, String level) { WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(city); wlyyQuotaResult.setCityName(cityName); wlyyQuotaResult.setTown(town); wlyyQuotaResult.setTownName(townName); wlyyQuotaResult.setOrgCode(org); wlyyQuotaResult.setOrgName(orgName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type(level);//机构级 wlyyQuotaResult.setLevel2Type(key); wlyyQuotaResult.setLevel2TypeName(Constant.getLevelSexName(key)); if (oneorgSexMap != null && oneorgSexMap.containsKey(key)) { wlyyQuotaResult.setResult(oneorgSexMap.get(key) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } private void compute_level2_1(Map> citySexMap,String key, String sex) { if (citySexMap.containsKey(key)) { Map sexMap = citySexMap.get(key); sexMap.put(sex, (sexMap.get(sex) == null ? 0l : sexMap.get(sex)) + 1); citySexMap.put(key, sexMap); } else { Map sexMap = new HashMap(); sexMap.put(sex, 1L); citySexMap.put(key, sexMap); } } /** * 机构维度患者分组维度计算指标 */ @Transactional private void computequotaByPatientGroup() { jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 7 + "'"); try { //数组里面第一个是健康人群 第二个是慢病人群 第三个是65岁以上人群 Map> cityGroupMap = new HashMap>();//key是市行政代码 目前只有厦门市 cityGroupMap.put(Constant.city, new HashMap()); Map> townGroupMap = new HashMap>();//key是区行政代码 Map> orgGroupMap = new HashMap>();//key是机构代码 //新建任务日志对象 QuartzJobLog QuartzJobLog = new QuartzJobLog(); QuartzJobLog.setJobStartTime(new Date()); QuartzJobLog.setJobId(wlyyJobConfig.getId()); QuartzJobLog.setJobName(wlyyJobConfig.getJobName()); //查找出系统全部的机构 List hospitals = hospitalDao.findHospital2(); Map hospitalsMap = new HashMap(); for (Hospital hospital : hospitals) { hospitalsMap.put(hospital.getCode(), hospital); Map one = new HashMap(); one.put("1", 0L); one.put("2", 0L); one.put("3", 0L); one.put("4", 0L); one.put("5", 0L); one.put("100", 0L); orgGroupMap.put(hospital.getCode(), one); } //查找出厦门市全部的区 List towns = townDao.findByCityCode(Constant.city); Map townsMap = new HashMap(); for (Town town : towns) { townsMap.put(town.getCode(), town); Map one = new HashMap(); one.put("1", 0L); one.put("2", 0L); one.put("3", 0L); one.put("4", 0L); one.put("5", 0L); one.put("100", 0L); townGroupMap.put(town.getCode(), one); } //找出今天的签约信息 List signFamilys = signFamilyDao.findByJiatingSignYesterday(yesterday, now); //统计有签约的 for (SignFamily signFamily : signFamilys) { String patient = signFamily.getPatient(); //设置查看病人所在分组 List dctorPatientGroupInfo = doctorPatientGroupInfoDao.findByMorenPatient(patient); String group ="";//得到该签约病人的所在分组 1 普通 2 慢病 3是 65岁以上人群 4是 高血压 5是糖尿病 100是高血压和糖尿病 if (dctorPatientGroupInfo != null && dctorPatientGroupInfo.size() > 0) { group=dctorPatientGroupInfo.get(0).getGroup(); } else { group="1"; } Hospital hospital = hospitalsMap.get(signFamily.getHospital());//得到患者签约的机构 if (hospital == null) { continue; } String town = hospital.getTown(); //统计市 现在只有厦门市 默认先写死 后面再改 if (cityGroupMap.containsKey(Constant.city)) { Map groupMapTemp = cityGroupMap.get(Constant.city); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); cityGroupMap.put(Constant.city, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); cityGroupMap.put(Constant.city, groupMapTemp); } //统计区 if (townGroupMap.containsKey(town)) { Map groupMapTemp = townGroupMap.get(town); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); townGroupMap.put(town, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); townGroupMap.put(town, groupMapTemp); } //统计站 String orgCode=hospital.getCode(); if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){ //统计站 String orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00"; //统计机构 if (orgGroupMap.containsKey(orgCodeTemp)) { Map groupMapTemp = orgGroupMap.get(orgCodeTemp); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); orgGroupMap.put(orgCodeTemp, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); orgGroupMap.put(orgCodeTemp, groupMapTemp); } } else { //统计机构 if (orgGroupMap.containsKey(hospital.getCode())) { Map groupMapTemp = orgGroupMap.get(hospital.getCode()); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); orgGroupMap.put(hospital.getCode(), groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); orgGroupMap.put(hospital.getCode(), groupMapTemp); } } boolean hasGXY = false;//有高血压 boolean hasTNB = false;//有糖尿病 if ("2".equals(group)) { //如果是慢病的 统计高血压的 糖尿病 1高血压,2糖尿病 String jsonString = redisTemplate.opsForValue().get("disease:" + patient); if (StringUtils.isEmpty(jsonString)) { continue; } //排除数据 只留下高血压和糖尿病 List jsonObjects = new ArrayList(); JSONArray redisValues = new JSONArray(jsonString); for (Object obj : redisValues) { JSONObject redisValue = (JSONObject)(obj); if(!redisValue.has("signType")){ continue; } //排除掉三师签约 if ("1".equals(redisValue.get("signType").toString())) { continue; } String disease = redisValue.getString("disease"); if ("1".equals(disease)) { jsonObjects.add(redisValue); hasGXY = true;//设置有高血压 } if ("2".equals(disease)) { jsonObjects.add(redisValue); hasTNB = true;//设置有糖尿病 } } if(jsonObjects.size()==0){ continue;//如果没有高血压和糖尿病 不统计 } if (hasGXY && hasTNB) { group = "100";//有高血压又有糖尿病 } else if(hasGXY){ group = 4 + "";//4高血压,5糖尿病 }else if(hasTNB){ group = 5 + "";//4高血压,5糖尿病 } if (cityGroupMap.containsKey(Constant.city)) { Map groupMapTemp = cityGroupMap.get(Constant.city); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); cityGroupMap.put(Constant.city, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); cityGroupMap.put(Constant.city, groupMapTemp); } //统计区 if (townGroupMap.containsKey(town)) { Map groupMapTemp = townGroupMap.get(town); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); townGroupMap.put(town, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); townGroupMap.put(town, groupMapTemp); } //统计机构 //统计站 if (!"00".equals(hospital.getCode().substring(8))) { String orgCodeTemp = hospital.getCode().substring(0, 8) + "00"; //统计机构 if (orgGroupMap.containsKey(orgCodeTemp)) { Map groupMapTemp = orgGroupMap.get(orgCodeTemp); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); orgGroupMap.put(orgCodeTemp, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); orgGroupMap.put(orgCodeTemp, groupMapTemp); } } else { //统计机构 if (orgGroupMap.containsKey(hospital.getCode())) { Map groupMapTemp = orgGroupMap.get(hospital.getCode()); groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1); orgGroupMap.put(hospital.getCode(), groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(group, 1L); orgGroupMap.put(hospital.getCode(), groupMapTemp); } } } } //保存统计数据 //保存市的统计数据 for (Map.Entry> entry : cityGroupMap.entrySet()) { //保存健康人群 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_1_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_1)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存慢病人群 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_2_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_2)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存65岁以上人群 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_3_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_3)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存高血压 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_4_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_4)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_5_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_5)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病和高血压 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_group_100); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_100_name); if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_100)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_group_100) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } //保存区级 //保存区的统计数据 for (Map.Entry townEntry : townsMap.entrySet()) { //判断该区是否有统计数据 Map oneTownGroupMap = townGroupMap.get(townEntry.getKey());//得到当个区的统计数据 Town town = townEntry.getValue();//得到区级信息 //保存健康人群 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_1_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_1)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存慢病人群 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_2_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_2)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存65岁以上人群 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_3_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_3)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存高血压 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_4_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_4)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_5_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_5)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_group_100); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_100_name); if (oneTownGroupMap != null && oneTownGroupMap.containsKey(Constant.level_group_100)) { wlyyQuotaResult.setResult(oneTownGroupMap.get(Constant.level_group_100) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } //保存机构 for (Map.Entry hospitalEntry : hospitalsMap.entrySet()) { //判断该机构是否有统计数据 Map oneOrgGroupMap = orgGroupMap.get(hospitalEntry.getKey());//得到当个机构的统计数据 Hospital hospital = hospitalEntry.getValue();//得到区级信息 //保存健康人群 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_1_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_1)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存慢病 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_2_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_2)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存65岁以上人群 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_3_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_3)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存高血压 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_4_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_4)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_5_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_5)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存糖尿病和高血压 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_group_100); wlyyQuotaResult.setLevel2TypeName(Constant.level_group_100_name); if (oneOrgGroupMap != null && oneOrgGroupMap.containsKey(Constant.level_group_100)) { wlyyQuotaResult.setResult(oneOrgGroupMap.get(Constant.level_group_100) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } QuartzJobLog.setJobEndTime(new Date()); QuartzJobLog.setJobContent("统计" + getYesterday() + " 的签约病人分组数据完成 ,得到签约数目:"+signFamilys.size()); QuartzJobLog.setJobType("1"); quartzJobLogDao.save(QuartzJobLog); } catch (Exception e) { e.printStackTrace(); } } /** * 机构维度患者年龄维度计算指标 */ @Transactional private void computequotaByPatientAge() { try { jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 8 + "'"); //新建任务日志对象 QuartzJobLog QuartzJobLog = new QuartzJobLog(); QuartzJobLog.setJobStartTime(new Date()); QuartzJobLog.setJobId(wlyyJobConfig.getId()); QuartzJobLog.setJobName(wlyyJobConfig.getJobName()); //查找出系统全部的机构 List hospitals = hospitalDao.findHospital2(); Map hospitalsMap = new HashMap(); for (Hospital hospital : hospitals) { hospitalsMap.put(hospital.getCode(), hospital); } //查找出厦门市全部的区 List towns = townDao.findByCityCode(Constant.city); Map townsMap = new HashMap(); for (Town town : towns) { townsMap.put(town.getCode(), town); } //找出今天的签约信息 List signFamilys = signFamilyDao.findByJiatingSignYesterday(yesterday, now); //数组里面第一个是健康人群 第二个是慢病人群 第三个是65岁以上人群 Map> cityAgeMap = new HashMap>();//key是市行政代码 目前只有厦门市 cityAgeMap.put(Constant.city, new HashMap()); Map> townAgeMap = new HashMap>();//key是区行政代码 Map> orgAgeMap = new HashMap>();//key是机构代码 //统计有签约的 for (SignFamily signFamily : signFamilys) { String orgCodeTemp=getOrg(signFamily.getHospital()); Hospital hospital = hospitalsMap.get(orgCodeTemp);//得到患者签约的机构 String town = hospital.getTown(); int age = IdCardUtil.getAgeForIdcard(signFamily.getIdcard());//根据card解析年龄 String ageCode = getAgeCode(age);//得到年龄的code //统计市 if (cityAgeMap.containsKey(Constant.city)) { Map groupMapTemp = cityAgeMap.get(Constant.city); groupMapTemp.put(ageCode, (groupMapTemp.get(ageCode) == null ? 0l : groupMapTemp.get(ageCode)) + 1); cityAgeMap.put(Constant.city, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(ageCode, 1L); cityAgeMap.put(Constant.city, groupMapTemp); } //统计区 if (townAgeMap.containsKey(town)) { Map groupMapTemp = townAgeMap.get(town); groupMapTemp.put(ageCode, (groupMapTemp.get(ageCode) == null ? 0l : groupMapTemp.get(ageCode)) + 1); townAgeMap.put(town, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(ageCode, 1L); townAgeMap.put(town, groupMapTemp); } //统计机构 //统计站 String orgCode=hospital.getCode(); if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){ //统计站 orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00"; //统计机构 if (orgAgeMap.containsKey(orgCodeTemp)) { Map groupMapTemp = orgAgeMap.get(orgCodeTemp); groupMapTemp.put(ageCode, (groupMapTemp.get(ageCode) == null ? 0l : groupMapTemp.get(ageCode)) + 1); orgAgeMap.put(orgCodeTemp, groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(ageCode, 1L); orgAgeMap.put(orgCodeTemp, groupMapTemp); } } else { //统计机构 if (orgAgeMap.containsKey(hospital.getCode())) { Map groupMapTemp = orgAgeMap.get(hospital.getCode()); groupMapTemp.put(ageCode, (groupMapTemp.get(ageCode) == null ? 0l : groupMapTemp.get(ageCode)) + 1); orgAgeMap.put(hospital.getCode(), groupMapTemp); } else { Map groupMapTemp = new HashMap(); groupMapTemp.put(ageCode, 1L); orgAgeMap.put(hospital.getCode(), groupMapTemp); } } } //保存统计数据 // 保存市的统计数据 for (Map.Entry> entry : cityAgeMap.entrySet()) { Map oneAgeMap = entry.getValue(); //保存0~6 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_1_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_1)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存7~18 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_2_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_2)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_3_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_3)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存30~50 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_4_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_4)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存50~65 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_5_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_5)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4");//市级 wlyyQuotaResult.setLevel2Type(Constant.level_age_6); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_6_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_6)) { wlyyQuotaResult.setResult(entry.getValue().get(Constant.level_age_6) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } //保存区级 for (Map.Entry entry : townsMap.entrySet()) { //判断该区是否有统计数据 Map oneAgeMap = townAgeMap.get(entry.getKey());//得到当个区的统计数据 Town town = entry.getValue();//得到区级信息 //保存0~6 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_1_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_1)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存7~18 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_2_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_2)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_3_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_3)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存30~50 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_4_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_4)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存50~65 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_5_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_5)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(entry.getKey()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(town.getCode()); wlyyQuotaResult.setTownName(town.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("3");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_6); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_6_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_6)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_6) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } for (Map.Entry hospitalEntry : hospitalsMap.entrySet()) { //判断该机构是否有统计数据 Map oneAgeMap = orgAgeMap.get(hospitalEntry.getKey());//得到当个机构的统计数据 Hospital hospital = hospitalEntry.getValue();//得到区级信息 //保存0~6 WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//区级 wlyyQuotaResult.setLevel2Type(Constant.level_age_1); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_1_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_1)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_1) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存7~18 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_age_2); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_2_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_2)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_2) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_age_3); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_3_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_3)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_3) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存30~50 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_age_4); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_4_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_4)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_4) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存50~65 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_age_5); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_5_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_5)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_5) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); //保存18~30 wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(hospital.getCity()); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setTown(hospital.getTown()); wlyyQuotaResult.setTownName(hospital.getTownName()); wlyyQuotaResult.setOrgCode(hospital.getCode()); wlyyQuotaResult.setOrgName(hospital.getName()); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("2");//机构级 wlyyQuotaResult.setLevel2Type(Constant.level_age_6); wlyyQuotaResult.setLevel2TypeName(Constant.level_age_6_name); if (oneAgeMap != null && oneAgeMap.containsKey(Constant.level_age_6)) { wlyyQuotaResult.setResult(oneAgeMap.get(Constant.level_age_6) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } QuartzJobLog.setJobEndTime(new Date()); QuartzJobLog.setJobContent("统计" + getYesterday() + " 的签约患者年龄数据完成 ,得到签约数目:"+signFamilys.size()); QuartzJobLog.setJobType("1"); quartzJobLogDao.save(QuartzJobLog); } catch (Exception e) { e.printStackTrace(); } } /** * 机构维度计算指标 */ @Transactional private void computequota() { jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 1 + "'"); //新建任务日志对象 QuartzJobLog QuartzJobLog = new QuartzJobLog(); QuartzJobLog.setJobStartTime(new Date()); QuartzJobLog.setJobId(wlyyJobConfig.getId()); QuartzJobLog.setJobName(wlyyJobConfig.getJobName()); //查找出系统全部的全科医生 List doctors = doctorDao.findAllQKDoctot(); Map doctorsMap = new HashMap(); for (Doctor doctor : doctors) { doctorsMap.put(doctor.getCode(), doctor); } //查找出系统全部的机构 List hospitals = hospitalDao.findHospitalzxFWZ(); Map hospitalsMap = new HashMap(); for (Hospital hospital : hospitals) { hospitalsMap.put(hospital.getCode(), hospital); } //查找出厦门市全部的区 List towns = townDao.findByCityCode(Constant.city); Map townsMap = new HashMap(); for (Town town : towns) { townsMap.put(town.getCode(), town); } //找出今天的签约信息 yesterday,now List signFamilys = signFamilyDao.findByJiatingSignYesterday(yesterday, now); Map tjTownMap = new HashMap();//区级的统计map key 是区行政区划350200 Map tjOrgMap = new HashMap();//机构的统计map key 是机构的code Map tjQkdoctorMap = new HashMap();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode Long cityCount = 0L; //统计有签约的 String orgCodeTemp=""; for (SignFamily signFamily : signFamilys) { String doctorCode = signFamily.getDoctor();//得到签约中全科医生的code //统计团队 compute_level1(tjQkdoctorMap, doctorCode); //判断医生属于哪个机构 Doctor doctor = doctorsMap.get(doctorCode); if (doctor == null) { continue; } String orgCode = doctor.getHospital(); //统计机构 //统计站 if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){ //统计站 orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00"; compute_level1(tjOrgMap, orgCodeTemp); } else { //统计社区 compute_level1(tjOrgMap, orgCode); orgCodeTemp=orgCode; } Hospital hospital=hospitalsMap.get(orgCodeTemp); String townCode = hospital.getTown(); //统计区 compute_level1(tjTownMap, townCode); //统计市 cityCount++; } //保存统计的结果 //保存全科医生的签约统计 for (Map.Entry entry : doctorsMap.entrySet()) { Doctor doctor = doctorsMap.get(entry.getKey());//得到全科医生 orgCodeTemp=getOrg(doctor.getHospital()); Hospital hospital = hospitalsMap.get(orgCodeTemp);//得到全科医生的机构 String city=Constant.city; String cityName=Constant.cityName; String town=hospital.getTown(); String townName=hospital.getTownName(); String org=hospital.getCode(); if(!"00".equals(hospital.getCode().substring(hospital.getCode().length()-2,hospital.getCode().length()))){ //统计站 org=hospital.getCode().substring(0,hospital.getCode().length()-2)+"00"; } String orgName=hospital.getName(); String doctorCode=doctor.getCode(); String doctorName=doctor.getName(); String doctorJob=doctor.getJob(); String level="1"; String key=doctor.getCode(); save_level1(tjQkdoctorMap, key, city, cityName, town, townName, org, orgName, doctorCode, doctorName, doctorJob, level); } //保存机构的签约统计 for (Map.Entry entry : hospitalsMap.entrySet()) { Hospital hospital = hospitalsMap.get(entry.getKey());//得到全科医生 String city=Constant.city; String cityName=Constant.cityName; String town=hospital.getTown(); String townName=hospital.getTownName(); String org=hospital.getCode(); String orgName=hospital.getName(); String doctorCode=""; String doctorName=""; String doctorJob=""; String level="2"; String key=hospital.getCode(); save_level1(tjOrgMap, key, city, cityName, town, townName, org, orgName, doctorCode, doctorName, doctorJob, level); } //保存区级的签约统计 for (Map.Entry entry : townsMap.entrySet()) { Town townObj = townsMap.get(entry.getKey());//得到全科医生 String city=Constant.city; String cityName=Constant.cityName; String town=townObj.getCode(); String townName=townObj.getName(); String org=""; String orgName=""; String doctorCode=""; String doctorName=""; String doctorJob=""; String level="3"; String key=townObj.getCode(); save_level1(tjTownMap, key, city, cityName, town, townName, org, orgName, doctorCode, doctorName, doctorJob, level); } //保存市级的统计 { WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setCity(Constant.city); wlyyQuotaResult.setCityName(Constant.cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setLevel1Type("4"); //判断全科医生是否有签约量 if (cityCount > 0) { wlyyQuotaResult.setResult(cityCount + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } QuartzJobLog.setJobEndTime(new Date()); QuartzJobLog.setJobContent("统计" + getYesterday() + " 的签约数据完成 ,得到签约数目:"+signFamilys.size()); QuartzJobLog.setJobType("1"); quartzJobLogDao.save(QuartzJobLog); } /** * 统计签约的公用保存方案 * */ private void save_level1(Map countMap, String key, String city, String cityName, String town, String townName, String org, String orgName, String doctorCode, String doctorName, String doctorJob, String level) { WlyyQuotaResult wlyyQuotaResult = new WlyyQuotaResult(); wlyyQuotaResult.setDel("1"); wlyyQuotaResult.setOrgCode(org); wlyyQuotaResult.setOrgName(orgName); wlyyQuotaResult.setCity(city); wlyyQuotaResult.setCityName(cityName); wlyyQuotaResult.setQuatoCode(wlyyQuota.getId()); wlyyQuotaResult.setQuatoName(wlyyQuota.getName()); wlyyQuotaResult.setQuotaDate(getYesterday()); wlyyQuotaResult.setCreateTime(new Date()); wlyyQuotaResult.setQkdoctorJobName(doctorJob); wlyyQuotaResult.setQkdoctorName(doctorName); wlyyQuotaResult.setQkdoctorCode(doctorCode); wlyyQuotaResult.setTown(town); wlyyQuotaResult.setTownName(townName); wlyyQuotaResult.setLevel1Type(level); //判断全科医生是否有解约量 if (countMap.containsKey(key)) { wlyyQuotaResult.setResult(countMap.get(key) + ""); } else { wlyyQuotaResult.setResult("0"); } wlyyQuotaResultDao.save(wlyyQuotaResult); } /** * 统计签约的公用统计方案 * @param tjQkdoctorMap * @param doctorCode */ private void compute_level1(Map tjQkdoctorMap, String doctorCode) { if (tjQkdoctorMap.containsKey(doctorCode)) { tjQkdoctorMap.put(doctorCode, tjQkdoctorMap.get(doctorCode) + 1); } else { tjQkdoctorMap.put(doctorCode, 1L); } } /* 得到昨天的日期字符串 yyyy-MM-dd */ public String getYesterday() { return yesterday; } /** * 根据年龄得到对应的code * * @param age * @return */ public String getAgeCode(int age) { if (age < 7) { return Constant.level_age_1; } else if (age >= 7 && age < 18) { return Constant.level_age_2; } else if (age >= 18 && age < 30) { return Constant.level_age_3; } else if (age >= 30 && age < 50) { return Constant.level_age_4; } else if (age >= 50 && age < 65) { return Constant.level_age_5; } else { return Constant.level_age_6; } } public static String getDayString(Integer size) { Date date = new Date();//取时间 Calendar calendar = new GregorianCalendar(); calendar.setTime(date); calendar.add(calendar.DATE, size);//把日期往后增加一天.整数往后推,负数往前移动 date = calendar.getTime(); //这个时间就是日期往后推一天的结果 SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); String dateString = formatter.format(date); return dateString; } private String getOrg(String org){ if(!"00".equals(org.substring(org.length()-2,org.length()))){ return org.substring(0,org.length()-2)+"00"; }else{ return org; } } public static void main(String[] args) { getDayString(0); } }