CurrentDayAllQuotaJob.java 80 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590
  1. package com.yihu.wlyy.job;
  2. import com.yihu.wlyy.entity.address.Hospital;
  3. import com.yihu.wlyy.entity.address.Town;
  4. import com.yihu.wlyy.entity.consult.ConsultTeam;
  5. import com.yihu.wlyy.entity.doctor.profile.Doctor;
  6. import com.yihu.wlyy.entity.doctor.team.sign.DoctorPatientGroupInfo;
  7. import com.yihu.wlyy.entity.job.QuartzJobLog;
  8. import com.yihu.wlyy.entity.patient.Patient;
  9. import com.yihu.wlyy.entity.patient.PatientHealthGuidance;
  10. import com.yihu.wlyy.entity.patient.SignFamily;
  11. import com.yihu.wlyy.repository.address.TownDao;
  12. import com.yihu.wlyy.repository.consult.ConsultTeamDao;
  13. import com.yihu.wlyy.repository.doctor.DoctorDao;
  14. import com.yihu.wlyy.repository.doctor.DoctorPatientGroupInfoDao;
  15. import com.yihu.wlyy.repository.job.QuartzJobLogDao;
  16. import com.yihu.wlyy.repository.organization.HospitalDao;
  17. import com.yihu.wlyy.repository.patient.PatientDao;
  18. import com.yihu.wlyy.repository.patient.PatientHealthGuidanceDao;
  19. import com.yihu.wlyy.repository.patient.SignFamilyDao;
  20. import com.yihu.wlyy.util.DateUtil;
  21. import com.yihu.wlyy.util.IdCardUtil;
  22. import org.json.JSONArray;
  23. import org.json.JSONObject;
  24. import org.quartz.Job;
  25. import org.quartz.JobExecutionContext;
  26. import org.quartz.JobExecutionException;
  27. import org.springframework.beans.factory.annotation.Autowired;
  28. import org.springframework.data.redis.core.StringRedisTemplate;
  29. import org.springframework.jdbc.core.JdbcTemplate;
  30. import org.springframework.stereotype.Component;
  31. import org.springframework.util.StringUtils;
  32. import org.springframework.web.context.support.SpringBeanAutowiringSupport;
  33. import java.io.IOException;
  34. import java.io.InputStream;
  35. import java.text.SimpleDateFormat;
  36. import java.util.*;
  37. /**
  38. * 实时统计今天的数据
  39. */
  40. @Component
  41. public class CurrentDayAllQuotaJob implements Job {
  42. @Autowired
  43. private SignFamilyDao signFamilyDao;
  44. @Autowired
  45. private DoctorDao doctorDao;
  46. @Autowired
  47. private HospitalDao hospitalDao;
  48. @Autowired
  49. private TownDao townDao;
  50. @Autowired
  51. private StringRedisTemplate redisTemplate;
  52. @Autowired
  53. private ConsultTeamDao consultTeamDao;
  54. @Autowired
  55. private PatientHealthGuidanceDao patientHealthGuidanceDao;
  56. @Autowired
  57. private DoctorPatientGroupInfoDao doctorPatientGroupInfoDao;
  58. @Autowired
  59. private PatientDao patientDao;
  60. @Autowired
  61. private QuartzJobLogDao quartzJobLogDao;//执行日志Dao
  62. private org.apache.tomcat.jdbc.pool.DataSource fvdataSource = new org.apache.tomcat.jdbc.pool.DataSource();//随访数据源
  63. private JdbcTemplate jdbcTemplate = new JdbcTemplate();
  64. private Properties systemProperties;
  65. List<Town> towns = null;//厦门市全部的区
  66. List<Hospital> hospitals = null;//系统全部的机构
  67. List<Doctor> qkdoctors = null;//系统全部的全科医生
  68. List<Doctor> jkglsdoctors = null;//系统全部的健康管理师
  69. Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
  70. Map<String, Doctor> jkglsdoctorsMap = new HashMap<String, Doctor>();
  71. Map<String, Doctor> qkdoctorsMap = new HashMap<String, Doctor>();
  72. Map<String, Town> townsMap = new HashMap<String, Town>();
  73. @Override
  74. public void execute(JobExecutionContext context)
  75. throws JobExecutionException {
  76. try {
  77. SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
  78. getSystemProperties();
  79. fvdataSource.setDriverClassName(systemProperties.get("fv.jdbc.driver").toString());
  80. fvdataSource.setUrl(systemProperties.get("fv.jdbc.url").toString());
  81. fvdataSource.setUsername(systemProperties.get("fv.jdbc.username").toString());
  82. fvdataSource.setPassword(systemProperties.get("fv.jdbc.password").toString());
  83. jdbcTemplate.setDataSource(fvdataSource);//初始化随访的数据源
  84. towns = townDao.findByCityCode(Constant.city); //查找出厦门市全部的区
  85. hospitals = hospitalDao.findHospitalzxFWZ(); //查找出系统全部的机构
  86. for (Hospital hospital : hospitals) {
  87. hospitalsMap.put(hospital.getCode(), hospital);
  88. }
  89. qkdoctors = doctorDao.findAllQKDoctot();//查找出系统全部的全科医生
  90. for (Doctor doctor : qkdoctors) {
  91. qkdoctorsMap.put(doctor.getCode(), doctor);
  92. }
  93. jkglsdoctors = doctorDao.findAllZKDoctot();//查找出系统全部的全科医生
  94. for (Doctor doctor : jkglsdoctors) {
  95. jkglsdoctorsMap.put(doctor.getCode(), doctor);
  96. }
  97. for (Town town : towns) {
  98. townsMap.put(town.getCode(), town);
  99. }
  100. //计算指标
  101. computequota();
  102. }catch (Exception e){
  103. e.printStackTrace();
  104. }
  105. }
  106. //统计
  107. private void computequota() throws Exception {
  108. QuartzJobLog quartzJobLog =new QuartzJobLog();
  109. quartzJobLog.setJobStartTime(new Date());
  110. computequota_1(); //统计今天的签约
  111. computequota_2(); //统计今天的解约
  112. computequota_3(); //统计今天的健康咨询量
  113. computequota_4(); //统计今天的随访量
  114. computequota_5(); //统计今天的健康指导
  115. computequota_6(); //统计今天的签约患者性别
  116. computequota_7();//统计今天的签约患者分组
  117. computequota_8();//统计今天的签约患者年龄
  118. computequota_9();//统计今天的待签约
  119. computequota_10();//统计今天的改签
  120. computequota_12();//统计今天的签约下按年龄分组后再
  121. quartzJobLog.setJobContent("开始实时统计查询");
  122. quartzJobLog.setJobName("实时统计");
  123. quartzJobLog.setJobId("11");
  124. quartzJobLog.setJobType("1");
  125. quartzJobLog.setJobEndTime(new Date());
  126. quartzJobLogDao.save(quartzJobLog);
  127. }
  128. private void computequota_12() throws Exception{
  129. String now = getDayString(0);
  130. String tomorrow = getDayString(1);
  131. //找出今天的签约信息 yesterday,now
  132. //查找出系统全部的机构
  133. List<Hospital> hospitals = hospitalDao.findHospital2();
  134. Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
  135. for (Hospital hospital : hospitals) {
  136. hospitalsMap.put(hospital.getCode(), hospital);
  137. }
  138. //查找出厦门市全部的区
  139. List<Town> towns = townDao.findByCityCode(Constant.city);
  140. Map<String, Town> townsMap = new HashMap<String, Town>();
  141. for (Town town : towns) {
  142. townsMap.put(town.getCode(), town);
  143. }
  144. //找出今天的签约信息
  145. List<SignFamily> signFamilys = signFamilyDao.findByJiatingSignYesterday(now, tomorrow);
  146. //数组里面第一个是健康人群 第二个是慢病人群 第三个是65岁以上人群
  147. Map<String, Map<String, Map>> cityAgeMap = new HashMap<String, Map<String, Map>>();//key是市行政代码 目前只有厦门市
  148. Map<String,Map> temp =new HashMap<String,Map>();
  149. cityAgeMap.put(Constant.city, temp);
  150. Map<String, Map<String, Map>> townAgeMap = new HashMap<String, Map<String, Map>>();//key是区行政代码
  151. Map<String, Map<String, Map>> orgAgeMap = new HashMap<String, Map<String, Map>>();//key是机构代码
  152. //统计有签约的
  153. for (SignFamily signFamily : signFamilys) {
  154. Hospital hospital = hospitalsMap.get(signFamily.getHospital());//得到患者签约的机构
  155. String town = hospital.getTown();
  156. int age = IdCardUtil.getAgeForIdcard(signFamily.getIdcard());//根据card解析年龄
  157. String ageCode = getAgeCode(age);//得到年龄的code
  158. boolean hasGXY = false;//有高血压
  159. boolean hasTNB = false;//有糖尿病
  160. //如果是慢病的 统计高血压的 糖尿病 1高血压,2糖尿病 糖尿病和高血压是100
  161. String diseaseType="";
  162. String jsonString = redisTemplate.opsForValue().get("disease:" + signFamily.getPatient());
  163. if (StringUtils.isEmpty(jsonString)) {
  164. continue;
  165. }
  166. //排除数据 只留下高血压和糖尿病
  167. List<JSONObject> jsonObjects = new ArrayList<JSONObject>();
  168. JSONArray redisValues = new JSONArray(jsonString);
  169. for (Object obj : redisValues) {
  170. JSONObject redisValue = new JSONObject(obj);
  171. if(!redisValue.has("signType")){
  172. continue;
  173. }
  174. //排除掉三师签约
  175. if ("1".equals(redisValue.get("signType").toString())) {
  176. continue;
  177. }
  178. String disease = redisValue.get("disease").toString();
  179. if (Integer.valueOf(disease).equals("1")) {
  180. jsonObjects.add(redisValue);
  181. hasGXY = true;//设置有高血压
  182. diseaseType="1";
  183. }
  184. if (Integer.valueOf(disease).equals("2")) {
  185. jsonObjects.add(redisValue);
  186. hasTNB = true;//设置有糖尿病
  187. diseaseType="2";
  188. }
  189. }
  190. if(hasGXY&&hasTNB){
  191. diseaseType="100";
  192. }
  193. //统计市
  194. compute(cityAgeMap, Constant.city, ageCode, diseaseType);
  195. //统计区
  196. compute(townAgeMap, town, ageCode, diseaseType);
  197. //统计机构
  198. //统计站
  199. String orgCode=hospital.getCode();
  200. if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){
  201. //统计站
  202. String orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00";
  203. //统计机构
  204. compute(orgAgeMap, orgCodeTemp, ageCode, diseaseType);
  205. } else {
  206. compute(orgAgeMap, hospital.getCode(), ageCode, diseaseType);
  207. }
  208. }
  209. //保存市级数据
  210. for (Map.Entry<String, Map<String, Map>> entry : cityAgeMap.entrySet()) {
  211. Map<String, Map> oneAgeMap = entry.getValue();
  212. for(int i=1;i<7;i++){
  213. for(int j=1;j<4;j++){
  214. String key_2=i+"";
  215. String key_3=j+"";
  216. String name=Constant.cityName;
  217. JSONObject jsonObject=new JSONObject();
  218. if (oneAgeMap != null && oneAgeMap.containsKey(key_2)) {
  219. Map<String,Long> key3Map=oneAgeMap.get(key_2);
  220. if(key3Map!=null&&key3Map.containsKey(key_3)){
  221. jsonObject.put("num",entry.getValue().get((key3Map.get(key_3) + "")));
  222. }else{
  223. jsonObject.put("num",0);
  224. }
  225. } else {
  226. jsonObject.put("num",0);
  227. }
  228. jsonObject.put("name",name);
  229. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  230. redisTemplate.opsForValue().set(new StringBuffer("quota:12:4:"+i+":"+j+":"+entry.getKey()).toString(),jsonObject.toString());
  231. }
  232. }
  233. }
  234. //保存区级
  235. for (Map.Entry<String, Town> entry : townsMap.entrySet()) {
  236. //判断该区是否有统计数据
  237. Map<String, Map> oneAgeMap = townAgeMap.get(entry.getKey());//得到当个区的统计数据
  238. Town townObj = entry.getValue();//得到区级信息
  239. for(int i=1;i<7;i++){
  240. for(int j=1;j<4;j++){
  241. String key_2=i+"";
  242. String key_3=j+"";
  243. String name=townObj.getName();
  244. JSONObject jsonObject=new JSONObject();
  245. if (oneAgeMap != null && oneAgeMap.containsKey(key_2)) {
  246. Map<String,Long> key3Map=oneAgeMap.get(key_2);
  247. if(key3Map!=null&&key3Map.containsKey(key_3)){
  248. jsonObject.put("num",(key3Map.get(key_3) + ""));
  249. }else{
  250. jsonObject.put("num",0);
  251. }
  252. } else {
  253. jsonObject.put("num",0);
  254. }
  255. jsonObject.put("name",townObj.getName());
  256. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));//quota:12:2:6:1:350200
  257. redisTemplate.opsForValue().set(new StringBuffer("quota:12:3:"+i+":"+j+":"+entry.getKey()).toString(),jsonObject.toString());
  258. }
  259. }
  260. }
  261. //保存机构级
  262. for (Map.Entry<String, Hospital> entry : hospitalsMap.entrySet()) {
  263. //判断该机构是否有统计数据
  264. Map<String, Map> oneAgeMap = orgAgeMap.get(entry.getKey());//得到当个机构的统计数据
  265. Hospital hospital = entry.getValue();//得到机构信息
  266. for(int i=1;i<7;i++){
  267. for(int j=1;j<4;j++){
  268. String key_2=i+"";
  269. String key_3=j+"";
  270. String name=hospital.getName();
  271. JSONObject jsonObject=new JSONObject();
  272. if (oneAgeMap != null && oneAgeMap.containsKey(key_2)) {
  273. Map<String,Long> key3Map=oneAgeMap.get(key_2);
  274. if(key3Map!=null&&key3Map.containsKey(key_3)){
  275. jsonObject.put("num",(key3Map.get(key_3) + ""));
  276. }else{
  277. jsonObject.put("num",0);
  278. }
  279. } else {
  280. jsonObject.put("num",0);
  281. }
  282. jsonObject.put("name",name);
  283. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  284. redisTemplate.opsForValue().set(new StringBuffer("quota:12:2:"+i+":"+j+":"+entry.getKey()).toString(),jsonObject.toString());
  285. }
  286. }
  287. }
  288. }
  289. private void compute(Map<String, Map<String, Map>> rootMap, String rootKey, String ageCode, String diseaseType) {
  290. if (rootMap.containsKey(rootKey)) {
  291. //得到市下面的所有的年龄map
  292. Map<String, Map> groupMapTemp = rootMap.get(rootKey);
  293. if(groupMapTemp.containsKey(ageCode)){
  294. //得到这个年龄下的患者map
  295. Map<String,Long> mape= groupMapTemp.get(ageCode);
  296. if(mape.containsKey(diseaseType)){
  297. mape.put(diseaseType,mape.get(diseaseType)+1L);
  298. }else{
  299. mape.put(diseaseType,1L);
  300. }
  301. }else{
  302. //新增疾病的统计map
  303. Map<String, Long> groupMapTemp1 = new HashMap<String, Long>();
  304. groupMapTemp1.put(diseaseType, 1L);
  305. groupMapTemp.put(ageCode,groupMapTemp1);
  306. }
  307. } else {
  308. //没有就新建统计数据 新增疾病的统计map
  309. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  310. groupMapTemp.put(diseaseType, 1L);
  311. //把统计疾病的map放入对应的年龄组map中
  312. Map<String, Map> groupMapTemp2 = new HashMap<String, Map>();
  313. groupMapTemp2.put(ageCode,groupMapTemp);
  314. //把年龄组map放入市的map里面
  315. rootMap.put(rootKey, groupMapTemp2);
  316. }
  317. }
  318. private void computequota_1() {
  319. //签约需要的统计map
  320. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  321. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  322. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  323. Map<String, JSONObject> tjQkdoctorMap = new HashMap<String, JSONObject>();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode
  324. initMap(tjCityMap, tjTownMap, tjOrgMap, tjQkdoctorMap, null);
  325. //找出今天的签约信息 yesterday,now
  326. String now = getDayString(0);
  327. String tomorrow = getDayString(1);
  328. List<SignFamily> signFamilys = signFamilyDao.findByJiatingSignYesterday(now, tomorrow);
  329. //统计有签约的
  330. for (SignFamily signFamily : signFamilys) {
  331. String hospitalCode=signFamily.getHospital();
  332. Hospital hospital=hospitalsMap.get(hospitalCode);
  333. //统计市
  334. JSONObject cityjo=tjCityMap.get(Constant.city);
  335. cityjo.put("num",((int)cityjo.get("num"))+1);
  336. //统计区
  337. JSONObject townjo=tjTownMap.get(hospital.getTown());
  338. townjo.put("num",((int)townjo.get("num"))+1);
  339. //统计机构
  340. //判断是中心还是服务站 服务站的话添加到中心去
  341. if(!"00".equals(hospital.getCode().substring(8))){
  342. String orgCodeTemp=hospital.getCode().substring(0,8)+"00";
  343. JSONObject orgjo=tjOrgMap.get(orgCodeTemp);
  344. orgjo.put("num",((int)orgjo.get("num"))+1);
  345. }else{
  346. JSONObject orgjo=tjOrgMap.get(hospital.getCode());
  347. orgjo.put("num",((int)orgjo.get("num"))+1);
  348. }
  349. //统计全科医生
  350. JSONObject qkjo=tjQkdoctorMap.get(signFamily.getDoctor());
  351. if(qkjo!=null){
  352. qkjo.put("num",((int)qkjo.get("num"))+1);
  353. }
  354. }
  355. //数据保存到redis
  356. //统计市
  357. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  358. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  359. redisTemplate.opsForValue().set(new StringBuffer("quota:1:4:"+entry.getKey()).toString(), entry.getValue().toString());
  360. }
  361. //保存区
  362. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  363. redisTemplate.opsForValue().set(new StringBuffer("quota:1:3:"+entry.getKey()).toString(), entry.getValue().toString());
  364. }
  365. //保存机构
  366. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  367. redisTemplate.opsForValue().set(new StringBuffer("quota:1:2:"+entry.getKey()).toString(), entry.getValue().toString());
  368. }
  369. //保存全科医生
  370. for(Map.Entry<String,JSONObject> entry:tjQkdoctorMap.entrySet()){
  371. redisTemplate.opsForValue().set(new StringBuffer("quota:1:1:"+entry.getKey()).toString(), entry.getValue().toString());
  372. }
  373. }
  374. private void initMap(Map<String, JSONObject> tjCityMap, Map<String, JSONObject> tjTownMap, Map<String, JSONObject> tjOrgMap, Map<String, JSONObject> tjQkdoctorMap, Map<String, JSONObject> tjJKdoctorMap) {
  375. JSONObject jo=new JSONObject();
  376. jo.put("name", Constant.cityName);
  377. jo.put("num",0);
  378. tjCityMap.put(Constant.city,jo);
  379. for(Town town:towns){
  380. jo=new JSONObject();
  381. jo.put("name",town.getName());
  382. jo.put("num",0);
  383. jo.put("date", DateUtil.dateToStrLong(new Date()));
  384. tjTownMap.put(town.getCode(),jo);
  385. }
  386. for(Hospital hospital:hospitals){
  387. jo=new JSONObject();
  388. jo.put("name",hospital.getName());
  389. jo.put("num",0);
  390. jo.put("date", DateUtil.dateToStrLong(new Date()));
  391. tjOrgMap.put(hospital.getCode(),jo);
  392. }
  393. if (tjQkdoctorMap!=null){
  394. for(Doctor doctor:qkdoctors){
  395. jo=new JSONObject();
  396. jo.put("name",doctor.getName());
  397. jo.put("num",0);
  398. jo.put("date", DateUtil.dateToStrLong(new Date()));
  399. tjQkdoctorMap.put(doctor.getCode(),jo);
  400. }
  401. }
  402. if(tjJKdoctorMap!=null){
  403. for(Doctor doctor:jkglsdoctors){
  404. jo=new JSONObject();
  405. jo.put("name",doctor.getName());
  406. jo.put("num",0);
  407. jo.put("date", DateUtil.dateToStrLong(new Date()));
  408. tjJKdoctorMap.put(doctor.getCode(),jo);
  409. }
  410. }
  411. }
  412. private void computequota_2() {
  413. //签约需要的统计map
  414. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  415. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  416. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  417. Map<String, JSONObject> tjQkdoctorMap = new HashMap<String, JSONObject>();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode
  418. initMap(tjCityMap, tjTownMap, tjOrgMap, tjQkdoctorMap, null);
  419. String now = getDayString(0);
  420. String tomorrow = getDayString(1);
  421. List<SignFamily> signFamilys = signFamilyDao.findByJiatingUnSignYesterday(now, tomorrow);
  422. //统计有签约的
  423. for (SignFamily signFamily : signFamilys) {
  424. String hospitalCode=signFamily.getHospital();
  425. Hospital hospital=hospitalsMap.get(hospitalCode);
  426. //统计市
  427. JSONObject cityjo=tjCityMap.get(Constant.city);
  428. cityjo.put("num",((int)cityjo.get("num"))+1);
  429. //统计区
  430. JSONObject townjo=tjTownMap.get(hospital.getTown());
  431. townjo.put("num",((int)townjo.get("num"))+1);
  432. //统计机构
  433. //判断是中心还是服务站 服务站的话添加到中心去
  434. if(!"00".equals(hospital.getCode().substring(8))){
  435. String orgCodeTemp=hospital.getCode().substring(0,8)+"00";
  436. JSONObject orgjo=tjOrgMap.get(orgCodeTemp);
  437. orgjo.put("num",((int)orgjo.get("num"))+1);
  438. }else{
  439. JSONObject orgjo=tjOrgMap.get(hospital.getCode());
  440. orgjo.put("num",((int)orgjo.get("num"))+1);
  441. }
  442. //统计全科医生
  443. JSONObject qkjo=tjQkdoctorMap.get(signFamily.getDoctor());
  444. if(qkjo!=null){
  445. qkjo.put("num",((int)qkjo.get("num"))+1);
  446. }
  447. }
  448. //数据保存到redis
  449. //统计市
  450. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  451. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  452. redisTemplate.opsForValue().set(new StringBuffer("quota:2:4:"+entry.getKey()).toString(), entry.getValue().toString());
  453. }
  454. //保存区
  455. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  456. redisTemplate.opsForValue().set(new StringBuffer("quota:2:3:"+entry.getKey()).toString(), entry.getValue().toString());
  457. }
  458. //保存机构
  459. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  460. redisTemplate.opsForValue().set(new StringBuffer("quota:2:2:"+entry.getKey()).toString(), entry.getValue().toString());
  461. }
  462. //保存全科医生
  463. for(Map.Entry<String,JSONObject> entry:tjQkdoctorMap.entrySet()){
  464. redisTemplate.opsForValue().set(new StringBuffer("quota:2:1:"+entry.getKey()).toString(), entry.getValue().toString());
  465. }
  466. }
  467. private void computequota_3() {
  468. //签约需要的统计map
  469. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  470. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  471. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  472. Map<String, JSONObject> tjJkdoctorMap = new HashMap<String, JSONObject>();//全部的健康管理师
  473. initMap(tjCityMap, tjTownMap, tjOrgMap, null, tjJkdoctorMap);
  474. String now = getDayString(0);
  475. String tomorrow = getDayString(1);
  476. List<ConsultTeam> consultTeams = consultTeamDao.findByCzrqyYesterday(now,tomorrow);
  477. //统计
  478. for (ConsultTeam consultTeam : consultTeams) {
  479. String doctorCode=consultTeam.getDoctor();
  480. Doctor doctor=jkglsdoctorsMap.get(doctorCode);//得到健康管理师
  481. if(doctor==null){
  482. continue;
  483. }
  484. //统计市
  485. JSONObject cityjo=tjCityMap.get(Constant.city);
  486. cityjo.put("num",((int)cityjo.get("num"))+1);
  487. //统计区
  488. JSONObject townjo=tjTownMap.get(doctor.getTown());
  489. townjo.put("num",((int)townjo.get("num"))+1);
  490. //统计机构
  491. JSONObject orgjo=tjOrgMap.get(doctor.getHospital());
  492. orgjo.put("num",((int)orgjo.get("num"))+1);
  493. //统计全科医生
  494. JSONObject qkjo=tjJkdoctorMap.get(doctor.getCode());
  495. if(qkjo!=null){
  496. qkjo.put("num",((int)qkjo.get("num"))+1);
  497. }
  498. }
  499. //数据保存到redis
  500. //统计市
  501. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  502. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  503. redisTemplate.opsForValue().set(new StringBuffer("quota:3:4:"+entry.getKey()).toString(), entry.getValue().toString());
  504. }
  505. //保存区
  506. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  507. redisTemplate.opsForValue().set(new StringBuffer("quota:3:3:"+entry.getKey()).toString(), entry.getValue().toString());
  508. }
  509. //保存机构
  510. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  511. redisTemplate.opsForValue().set(new StringBuffer("quota:3:2:"+entry.getKey()).toString(), entry.getValue().toString());
  512. }
  513. //保存全科医生
  514. for(Map.Entry<String,JSONObject> entry:tjJkdoctorMap.entrySet()){
  515. redisTemplate.opsForValue().set(new StringBuffer("quota:3:1:"+entry.getKey()).toString(), entry.getValue().toString());
  516. }
  517. }
  518. private void computequota_4() {
  519. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  520. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  521. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  522. Map<String, JSONObject> tjJkdoctorMap = new HashMap<String, JSONObject>();//全部的健康管理师
  523. initMap(tjCityMap, tjTownMap, tjOrgMap, null, tjJkdoctorMap);
  524. //找出今天的随访信息
  525. List<Map<String,Object>> plans = getFvYesterday();
  526. //统计有随访的
  527. for (Map<String,Object> plan : plans) {
  528. String doctorCode = (String) plan.get("doctor_uid");//得到随访中健康医生的code
  529. Doctor doctor=jkglsdoctorsMap.get(doctorCode);//得到健康管理师
  530. if(doctor==null){
  531. continue;
  532. }
  533. //统计市
  534. JSONObject cityjo=tjCityMap.get(Constant.city);
  535. cityjo.put("num",((int)cityjo.get("num"))+1);
  536. //统计区
  537. JSONObject townjo=tjTownMap.get(doctor.getTown());
  538. townjo.put("num",((int)townjo.get("num"))+1);
  539. //统计机构
  540. JSONObject orgjo=tjOrgMap.get(doctor.getHospital());
  541. orgjo.put("num",((int)orgjo.get("num"))+1);
  542. //统计全科医生
  543. JSONObject qkjo=tjJkdoctorMap.get(doctor.getCode());
  544. if(qkjo!=null){
  545. qkjo.put("num",((int)qkjo.get("num"))+1);
  546. }
  547. }
  548. //统计市
  549. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  550. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  551. redisTemplate.opsForValue().set(new StringBuffer("quota:4:4:"+entry.getKey()).toString(), entry.getValue().toString());
  552. }
  553. //保存区
  554. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  555. redisTemplate.opsForValue().set(new StringBuffer("quota:4:3:"+entry.getKey()).toString(), entry.getValue().toString());
  556. }
  557. //保存机构
  558. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  559. redisTemplate.opsForValue().set(new StringBuffer("quota:4:2:"+entry.getKey()).toString(), entry.getValue().toString());
  560. }
  561. //保存全科医生
  562. for(Map.Entry<String,JSONObject> entry:tjJkdoctorMap.entrySet()){
  563. redisTemplate.opsForValue().set(new StringBuffer("quota:4:1:"+entry.getKey()).toString(), entry.getValue().toString());
  564. }
  565. }
  566. private void computequota_5() {
  567. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  568. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  569. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  570. Map<String, JSONObject> tjQkdoctorMap = new HashMap<String, JSONObject>();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode
  571. Map<String, JSONObject> tjJkdoctorMap = new HashMap<String, JSONObject>();//全部的健康管理师
  572. initMap(tjCityMap, tjTownMap, tjOrgMap, tjQkdoctorMap, tjJkdoctorMap);
  573. //找出今天的健康指导信息
  574. String now = getDayString(0);
  575. String tomorrow = getDayString(1);
  576. List<PatientHealthGuidance> patientHealthGuidances = patientHealthGuidanceDao.findByCzrqyYesterday(now,tomorrow);
  577. for (PatientHealthGuidance patientHealthGuidance: patientHealthGuidances) {
  578. String doctorCode =patientHealthGuidance.getDoctor();
  579. Doctor doctor=jkglsdoctorsMap.get(doctorCode);//得到健康管理师
  580. if(doctor==null){
  581. doctor=qkdoctorsMap.get(doctorCode);//得到全科医生
  582. if(doctor==null){
  583. continue;
  584. }
  585. }
  586. //统计市
  587. JSONObject cityjo=tjCityMap.get(Constant.city);
  588. cityjo.put("num",((int)cityjo.get("num"))+1);
  589. //统计区
  590. JSONObject townjo=tjTownMap.get(doctor.getTown());
  591. townjo.put("num",((int)townjo.get("num"))+1);
  592. //统计机构
  593. JSONObject orgjo=tjOrgMap.get(doctor.getHospital());
  594. orgjo.put("num",((int)orgjo.get("num"))+1);
  595. //统计全科医生
  596. JSONObject qkjo=tjQkdoctorMap.get(doctor.getCode());
  597. if(qkjo!=null){
  598. qkjo.put("num",((int)qkjo.get("num"))+1);
  599. }
  600. }
  601. //统计市
  602. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  603. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  604. redisTemplate.opsForValue().set(new StringBuffer("quota:5:4:"+entry.getKey()).toString(), entry.getValue().toString());
  605. }
  606. //保存区
  607. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  608. redisTemplate.opsForValue().set(new StringBuffer("quota:5:3:"+entry.getKey()).toString(), entry.getValue().toString());
  609. }
  610. //保存机构
  611. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  612. redisTemplate.opsForValue().set(new StringBuffer("quota:5:2:"+entry.getKey()).toString(), entry.getValue().toString());
  613. }
  614. //保存全科医生
  615. for(Map.Entry<String,JSONObject> entry:tjQkdoctorMap.entrySet()){
  616. redisTemplate.opsForValue().set(new StringBuffer("quota:5:1:"+entry.getKey()).toString(), entry.getValue().toString());
  617. }
  618. }
  619. private void computequota_6() throws Exception {
  620. String now = getDayString(0);
  621. String tomorrow = getDayString(1);
  622. List<SignFamily> signFamilys = signFamilyDao.findByJiatingSignYesterday(now, tomorrow);
  623. //统计有签约的
  624. Map<String, Map<String, Long>> citySexMap = new HashMap<String, Map<String, Long>>();//key是市行政代码 目前只有厦门市
  625. citySexMap.put(Constant.city,new HashMap<String, Long>());
  626. Map<String, Map<String, Long>> townSexMap = new HashMap<String, Map<String, Long>>();//key是区行政代码
  627. Map<String, Map<String, Long>> orgSexMap = new HashMap<String, Map<String, Long>>();//key是机构代码
  628. for (SignFamily signFamily : signFamilys) {
  629. String idcard = signFamily.getIdcard();//得到签约中患者的身份证号
  630. Hospital hospital = hospitalsMap.get(signFamily.getHospital());//得到患者签约的机构
  631. if(hospital==null){
  632. continue;
  633. }
  634. String town = hospital.getTown();//得到患者签约的机构的区号
  635. String hospitalCode = hospital.getCode();//得到患者签约的机构号
  636. String sex = IdCardUtil.getSexForIdcard(idcard);//根据身份证得到性别
  637. //统计市 目前只统计厦门市 所以先写死 后期再改造
  638. if (citySexMap.containsKey(Constant.city)) {
  639. Map<String, Long> sexMap = citySexMap.get(Constant.city);
  640. sexMap.put(sex, (sexMap.get(sex)==null?0l:sexMap.get(sex)) + 1);
  641. citySexMap.put(Constant.city, sexMap);
  642. } else {
  643. Map<String, Long> sexMap = new HashMap<String, Long>();
  644. sexMap.put(sex, 1L);
  645. citySexMap.put(Constant.city, sexMap);
  646. }
  647. //统计区
  648. if (townSexMap.containsKey(town)) {
  649. Map<String, Long> sexMap = townSexMap.get(town);
  650. sexMap.put(sex, (sexMap.get(sex)==null?0l:sexMap.get(sex)) + 1);
  651. townSexMap.put(town, sexMap);
  652. } else {
  653. Map<String, Long> sexMap = new HashMap<String, Long>();
  654. sexMap.put(sex, 1L);
  655. townSexMap.put(town, sexMap);
  656. }
  657. //统计机构
  658. if (orgSexMap.containsKey(hospitalCode)) {
  659. Map<String, Long> sexMap = orgSexMap.get(hospitalCode);
  660. sexMap.put(sex, (sexMap.get(sex)==null?0l:sexMap.get(sex)) + 1);
  661. orgSexMap.put(hospitalCode, sexMap);
  662. } else {
  663. Map<String, Long> sexMap = new HashMap<String, Long>();
  664. sexMap.put(sex, 1L);
  665. orgSexMap.put(hospitalCode, sexMap);
  666. }
  667. }
  668. //保存统计数据
  669. //保存市统计数据
  670. for (Map.Entry<String, Map<String, Long>> entry : citySexMap.entrySet()) {
  671. //保存女
  672. JSONObject jsonObject=new JSONObject();
  673. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_sex_1)) {
  674. jsonObject.put("num",entry.getValue().get(Constant.level_sex_1));
  675. } else {
  676. jsonObject.put("num",0);
  677. }
  678. jsonObject.put("name",Constant.cityName);
  679. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  680. redisTemplate.opsForValue().set(new StringBuffer("quota:6:4:1:"+entry.getKey()).toString(),jsonObject.toString());
  681. //保存男
  682. jsonObject=new JSONObject();
  683. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_sex_2)) {
  684. jsonObject.put("num",entry.getValue().get(Constant.level_sex_2));
  685. } else {
  686. jsonObject.put("num",0);
  687. }
  688. jsonObject.put("name",Constant.cityName);
  689. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  690. redisTemplate.opsForValue().set(new StringBuffer("quota:6:4:2:"+entry.getKey()).toString(),jsonObject.toString());
  691. //保存未知
  692. jsonObject=new JSONObject();
  693. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_sex_3)) {
  694. jsonObject.put("num",entry.getValue().get(Constant.level_sex_3));
  695. } else {
  696. jsonObject.put("num",0);
  697. }
  698. jsonObject.put("name",Constant.cityName);
  699. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  700. redisTemplate.opsForValue().set(new StringBuffer("quota:6:4:3:"+entry.getKey()).toString(),jsonObject.toString());
  701. }
  702. //保存区的统计数据
  703. for (Map.Entry<String, Town> townEntry : townsMap.entrySet()) {
  704. //判断该区是否有统计数据
  705. Map<String, Long> oneTownSexMap = townSexMap.get(townEntry.getKey());//得到当个区的统计数据
  706. Town town = townEntry.getValue();//得到区级信息
  707. //保存女
  708. JSONObject jsonObject=new JSONObject();
  709. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_1)) {
  710. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_1));
  711. } else {
  712. jsonObject.put("num",0);
  713. }
  714. jsonObject.put("name",town.getName());
  715. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  716. redisTemplate.opsForValue().set(new StringBuffer("quota:6:3:1:"+townEntry.getKey()).toString(),jsonObject.toString());
  717. //保存男
  718. jsonObject=new JSONObject();
  719. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_2)) {
  720. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_2));
  721. } else {
  722. jsonObject.put("num",0);
  723. }
  724. jsonObject.put("name",town.getName());
  725. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  726. redisTemplate.opsForValue().set(new StringBuffer("quota:6:3:2:"+townEntry.getKey()).toString(),jsonObject.toString());
  727. //保存未知
  728. jsonObject=new JSONObject();
  729. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_3)) {
  730. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_3));
  731. } else {
  732. jsonObject.put("num",0);
  733. }
  734. jsonObject.put("name",town.getName());
  735. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  736. redisTemplate.opsForValue().set(new StringBuffer("quota:6:3:3:"+townEntry.getKey()).toString(),jsonObject.toString());
  737. }
  738. //统计机构
  739. for (Map.Entry<String, Hospital> hospitalEntry : hospitalsMap.entrySet()) {
  740. //判断该区是否有统计数据
  741. Map<String, Long> oneTownSexMap = orgSexMap.get(hospitalEntry.getKey());//得到当个区的统计数据
  742. Hospital town = hospitalEntry.getValue();//得到区级信息
  743. //保存女
  744. JSONObject jsonObject=new JSONObject();
  745. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_1)) {
  746. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_1));
  747. } else {
  748. jsonObject.put("num",0);
  749. }
  750. jsonObject.put("name",town.getName());
  751. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  752. redisTemplate.opsForValue().set(new StringBuffer("quota:6:2:1:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  753. //保存男
  754. jsonObject=new JSONObject();
  755. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_2)) {
  756. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_2));
  757. } else {
  758. jsonObject.put("num",0);
  759. }
  760. jsonObject.put("name",town.getName());
  761. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  762. redisTemplate.opsForValue().set(new StringBuffer("quota:6:2:2:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  763. //保存未知
  764. jsonObject=new JSONObject();
  765. if (oneTownSexMap != null && oneTownSexMap.containsKey(Constant.level_sex_3)) {
  766. jsonObject.put("num",oneTownSexMap.get(Constant.level_sex_3));
  767. } else {
  768. jsonObject.put("num",0);
  769. }
  770. jsonObject.put("name",town.getName());
  771. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  772. redisTemplate.opsForValue().set(new StringBuffer("quota:6:2:3:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  773. }
  774. }
  775. private void computequota_7() {
  776. String now = getDayString(0);
  777. String tomorrow = getDayString(1);
  778. List<SignFamily> signFamilys = signFamilyDao.findByJiatingSignYesterday(now, tomorrow);
  779. //查找出系统全部的患者
  780. List<Patient> patients = patientDao.findAllSignPatient();
  781. Map<String, Patient> patientsMap = new HashMap<String, Patient>();
  782. for (Patient patient : patients) {
  783. patientsMap.put(patient.getCode(), patient);
  784. }
  785. Map<String, Map<String, Long>> cityGroupMap = new HashMap<String, Map<String, Long>>();//key是市行政代码 目前只有厦门市
  786. cityGroupMap.put(Constant.city,new HashMap<String, Long>());
  787. Map<String, Map<String, Long>> townGroupMap = new HashMap<String, Map<String, Long>>();//key是区行政代码
  788. Map<String, Map<String, Long>> orgGroupMap = new HashMap<String, Map<String, Long>>();//key是机构代码
  789. //得到所有的签约病人的分组信息
  790. List<DoctorPatientGroupInfo> doctorPatientGroupInfos = doctorPatientGroupInfoDao.findAllPatient();
  791. Map<String, String> groupMap = new HashMap<String, String>();
  792. for (DoctorPatientGroupInfo doctorPatientGroupInfo : doctorPatientGroupInfos) {
  793. groupMap.put(doctorPatientGroupInfo.getPatient(), doctorPatientGroupInfo.getGroup());
  794. }
  795. //统计有签约的
  796. for (SignFamily signFamily : signFamilys) {
  797. String patient=signFamily.getPatient();
  798. String group = groupMap.get(patient);//得到该签约病人的所在分组 1 普通 2 慢病 3是 65岁以上人群
  799. Hospital hospital = hospitalsMap.get(signFamily.getHospital());//得到患者签约的机构
  800. if(hospital==null){
  801. continue;
  802. }
  803. String town = hospital.getTown();
  804. //统计市 现在只有厦门市 默认先写死 后面再改
  805. if (cityGroupMap.containsKey(Constant.city)) {
  806. Map<String, Long> groupMapTemp = cityGroupMap.get(Constant.city);
  807. groupMapTemp.put(group,(groupMapTemp.get(group)==null?0l:groupMapTemp.get(group)) + 1);
  808. cityGroupMap.put(Constant.city, groupMapTemp);
  809. } else {
  810. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  811. groupMapTemp.put(group, 1L);
  812. cityGroupMap.put(Constant.city, groupMapTemp);
  813. }
  814. //统计区
  815. if (townGroupMap.containsKey(town)) {
  816. Map<String, Long> groupMapTemp = townGroupMap.get(town);
  817. groupMapTemp.put(group, (groupMapTemp.get(group)==null?0l:groupMapTemp.get(group))+ 1);
  818. townGroupMap.put(town, groupMapTemp);
  819. } else {
  820. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  821. groupMapTemp.put(group, 1L);
  822. townGroupMap.put(town, groupMapTemp);
  823. }
  824. //统计机构
  825. if (orgGroupMap.containsKey(hospital.getCode())) {
  826. Map<String, Long> groupMapTemp = orgGroupMap.get(hospital.getCode());
  827. groupMapTemp.put(group, (groupMapTemp.get(group)==null?0l:groupMapTemp.get(group)) + 1);
  828. orgGroupMap.put(hospital.getCode(), groupMapTemp);
  829. } else {
  830. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  831. groupMapTemp.put(group, 1L);
  832. orgGroupMap.put(hospital.getCode(), groupMapTemp);
  833. }
  834. boolean hasGXY = false;//有高血压
  835. boolean hasTNB = false;//有糖尿病
  836. if ("2".equals(group)) {
  837. //如果是慢病的 统计高血压的 糖尿病 1高血压,2糖尿病
  838. String jsonString = redisTemplate.opsForValue().get("disease:" + patient);
  839. if (StringUtils.isEmpty(jsonString)) {
  840. continue;
  841. }
  842. //排除数据 只留下高血压和糖尿病
  843. List<JSONObject> jsonObjects = new ArrayList<JSONObject>();
  844. JSONArray redisValues = new JSONArray(jsonString);
  845. for (Object obj : redisValues) {
  846. JSONObject redisValue = new JSONObject(obj);
  847. if(!redisValue.has("signType")){
  848. continue;
  849. }
  850. //排除掉三师签约
  851. if ("1".equals(redisValue.get("signType").toString())) {
  852. continue;
  853. }
  854. String disease = redisValue.get("disease").toString();
  855. if (Integer.valueOf(disease).equals("1")) {
  856. jsonObjects.add(redisValue);
  857. hasGXY = true;//设置有高血压
  858. }
  859. if (Integer.valueOf(disease).equals("2")) {
  860. jsonObjects.add(redisValue);
  861. hasTNB = true;//设置有糖尿病
  862. }
  863. }
  864. if(jsonObjects.size()==0){
  865. continue;//如果没有高血压和糖尿病 不统计
  866. }
  867. if (hasGXY && hasTNB) {
  868. group = "100";//有高血压又有糖尿病
  869. } else {
  870. group = Integer.valueOf(jsonObjects.get(0).get("disease").toString()) + 3 + "";//4高血压,5糖尿病
  871. }
  872. if (cityGroupMap.containsKey(Constant.city)) {
  873. Map<String, Long> groupMapTemp = cityGroupMap.get(Constant.city);
  874. groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1);
  875. cityGroupMap.put(Constant.city, groupMapTemp);
  876. } else {
  877. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  878. groupMapTemp.put(group, 1L);
  879. cityGroupMap.put(Constant.city, groupMapTemp);
  880. }
  881. //统计区
  882. if (townGroupMap.containsKey(town)) {
  883. Map<String, Long> groupMapTemp = townGroupMap.get(town);
  884. groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1);
  885. townGroupMap.put(town, groupMapTemp);
  886. } else {
  887. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  888. groupMapTemp.put(group, 1L);
  889. townGroupMap.put(town, groupMapTemp);
  890. }
  891. //统计机构
  892. //统计站
  893. if (!"00".equals(hospital.getCode().substring(8))) {
  894. String orgCodeTemp = hospital.getCode().substring(0, 8) + "00";
  895. //统计机构
  896. if (orgGroupMap.containsKey(orgCodeTemp)) {
  897. Map<String, Long> groupMapTemp = orgGroupMap.get(orgCodeTemp);
  898. groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1);
  899. orgGroupMap.put(orgCodeTemp, groupMapTemp);
  900. } else {
  901. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  902. groupMapTemp.put(group, 1L);
  903. orgGroupMap.put(orgCodeTemp, groupMapTemp);
  904. }
  905. } else {
  906. //统计机构
  907. if (orgGroupMap.containsKey(hospital.getCode())) {
  908. Map<String, Long> groupMapTemp = orgGroupMap.get(hospital.getCode());
  909. groupMapTemp.put(group, (groupMapTemp.get(group) == null ? 0l : groupMapTemp.get(group)) + 1);
  910. orgGroupMap.put(hospital.getCode(), groupMapTemp);
  911. } else {
  912. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  913. groupMapTemp.put(group, 1L);
  914. orgGroupMap.put(hospital.getCode(), groupMapTemp);
  915. }
  916. }
  917. }
  918. }
  919. //保存统计数据
  920. //保存市的统计数据
  921. for (Map.Entry<String, Map<String, Long>> entry : cityGroupMap.entrySet()) {
  922. //保存健康人群
  923. JSONObject jsonObject=new JSONObject();
  924. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_1)) {
  925. jsonObject.put("num",entry.getValue().get(Constant.level_group_1));
  926. } else {
  927. jsonObject.put("num",0);
  928. }
  929. jsonObject.put("name",Constant.cityName);
  930. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  931. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:1:"+entry.getKey()).toString(),jsonObject.toString());
  932. //保存慢病人群
  933. jsonObject=new JSONObject();
  934. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_2)) {
  935. jsonObject.put("num",entry.getValue().get(Constant.level_group_2));
  936. } else {
  937. jsonObject.put("num",0);
  938. }
  939. jsonObject.put("name",Constant.cityName);
  940. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  941. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:2:"+entry.getKey()).toString(),jsonObject.toString());
  942. //保存65岁以上人群
  943. jsonObject=new JSONObject();
  944. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_3)) {
  945. jsonObject.put("num",entry.getValue().get(Constant.level_group_3));
  946. } else {
  947. jsonObject.put("num",0);
  948. }
  949. jsonObject.put("name",Constant.cityName);
  950. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  951. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:3:"+entry.getKey()).toString(),jsonObject.toString());
  952. //保存高血压
  953. jsonObject=new JSONObject();
  954. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_4)) {
  955. jsonObject.put("num",entry.getValue().get(Constant.level_group_4));
  956. } else {
  957. jsonObject.put("num",0);
  958. }
  959. jsonObject.put("name",Constant.cityName);
  960. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  961. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:4:"+entry.getKey()).toString(),jsonObject.toString());
  962. //保存糖尿病
  963. jsonObject=new JSONObject();
  964. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_5)) {
  965. jsonObject.put("num",entry.getValue().get(Constant.level_group_5));
  966. } else {
  967. jsonObject.put("num",0);
  968. }
  969. jsonObject.put("name",Constant.cityName);
  970. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  971. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:5:"+entry.getKey()).toString(),jsonObject.toString());
  972. //保存糖尿病和高血压
  973. jsonObject=new JSONObject();
  974. if (entry.getValue() != null && entry.getValue().containsKey(Constant.level_group_100)) {
  975. jsonObject.put("num",entry.getValue().get(Constant.level_group_100));
  976. } else {
  977. jsonObject.put("num",0);
  978. }
  979. jsonObject.put("name",Constant.cityName);
  980. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  981. redisTemplate.opsForValue().set(new StringBuffer("quota:7:4:100:"+entry.getKey()).toString(),jsonObject.toString());
  982. }
  983. //保存区级
  984. //保存区的统计数据
  985. for (Map.Entry<String, Town> townEntry : townsMap.entrySet()) {//保存健康人群
  986. JSONObject jsonObject=new JSONObject();
  987. Town town=townsMap.get(townEntry.getKey());
  988. Map<String, Long> oneTown= townGroupMap.get(townEntry.getKey());
  989. if (oneTown != null && oneTown.containsKey(Constant.level_group_1)) {
  990. jsonObject.put("num",oneTown.get(Constant.level_group_1));
  991. } else {
  992. jsonObject.put("num",0);
  993. }
  994. jsonObject.put("name",town.getName());
  995. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  996. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:1:"+townEntry.getKey()).toString(),jsonObject.toString());
  997. //保存慢病人群
  998. jsonObject=new JSONObject();
  999. if (oneTown != null && oneTown.containsKey(Constant.level_group_2)) {
  1000. jsonObject.put("num",oneTown.get(Constant.level_group_2));
  1001. } else {
  1002. jsonObject.put("num",0);
  1003. }
  1004. jsonObject.put("name",town.getName());
  1005. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1006. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:2:"+townEntry.getKey()).toString(),jsonObject.toString());
  1007. //保存65岁以上人群
  1008. jsonObject=new JSONObject();
  1009. if (oneTown != null && oneTown.containsKey(Constant.level_group_3)) {
  1010. jsonObject.put("num",oneTown.get(Constant.level_group_3));
  1011. } else {
  1012. jsonObject.put("num",0);
  1013. }
  1014. jsonObject.put("name",town.getName());
  1015. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1016. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:3:"+townEntry.getKey()).toString(),jsonObject.toString());
  1017. //保存高血压
  1018. jsonObject=new JSONObject();
  1019. if (oneTown != null && oneTown.containsKey(Constant.level_group_4)) {
  1020. jsonObject.put("num",oneTown.get(Constant.level_group_4));
  1021. } else {
  1022. jsonObject.put("num",0);
  1023. }
  1024. jsonObject.put("name",town.getName());
  1025. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1026. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:4:"+townEntry.getKey()).toString(),jsonObject.toString());
  1027. //保存糖尿病
  1028. jsonObject=new JSONObject();
  1029. if (oneTown != null && oneTown.containsKey(Constant.level_group_5)) {
  1030. jsonObject.put("num",oneTown.get(Constant.level_group_5));
  1031. } else {
  1032. jsonObject.put("num",0);
  1033. }
  1034. jsonObject.put("name",town.getName());
  1035. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1036. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:5:"+townEntry.getKey()).toString(),jsonObject.toString());
  1037. //保存糖尿病和高血压
  1038. jsonObject=new JSONObject();
  1039. if (oneTown != null && oneTown.containsKey(Constant.level_group_100)) {
  1040. jsonObject.put("num",oneTown.get(Constant.level_group_100));
  1041. } else {
  1042. jsonObject.put("num",0);
  1043. }
  1044. jsonObject.put("name",town.getName());
  1045. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1046. redisTemplate.opsForValue().set(new StringBuffer("quota:7:3:100:"+townEntry.getKey()).toString(),jsonObject.toString());
  1047. }
  1048. //保存机构
  1049. for (Map.Entry<String, Hospital> hospitalEntry : hospitalsMap.entrySet()) {
  1050. //保存健康人群
  1051. Hospital hospital=hospitalsMap.get(hospitalEntry.getKey());
  1052. JSONObject jsonObject=new JSONObject();
  1053. Map<String, Long> oneOrg= orgGroupMap.get(hospitalEntry.getKey());
  1054. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_1)) {
  1055. jsonObject.put("num",oneOrg.get(Constant.level_group_1));
  1056. } else {
  1057. jsonObject.put("num",0);
  1058. }
  1059. jsonObject.put("name",hospital.getName());
  1060. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1061. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:1:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1062. //保存慢病人群
  1063. jsonObject=new JSONObject();
  1064. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_2)) {
  1065. jsonObject.put("num",oneOrg.get(Constant.level_group_2));
  1066. } else {
  1067. jsonObject.put("num",0);
  1068. }
  1069. jsonObject.put("name",hospital.getName());
  1070. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1071. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:2:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1072. //保存65岁以上人群
  1073. jsonObject=new JSONObject();
  1074. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_3)) {
  1075. jsonObject.put("num",oneOrg.get(Constant.level_group_3));
  1076. } else {
  1077. jsonObject.put("num",0);
  1078. }
  1079. jsonObject.put("name",hospital.getName());
  1080. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1081. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:3:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1082. //保存高血压
  1083. jsonObject=new JSONObject();
  1084. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_4)) {
  1085. jsonObject.put("num",oneOrg.get(Constant.level_group_4));
  1086. } else {
  1087. jsonObject.put("num",0);
  1088. }
  1089. jsonObject.put("name",hospital.getName());
  1090. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1091. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:4:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1092. //保存糖尿病
  1093. jsonObject=new JSONObject();
  1094. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_5)) {
  1095. jsonObject.put("num",oneOrg.get(Constant.level_group_5));
  1096. } else {
  1097. jsonObject.put("num",0);
  1098. }
  1099. jsonObject.put("name",hospital.getName());
  1100. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1101. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:5:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1102. //保存糖尿病和高血压
  1103. jsonObject=new JSONObject();
  1104. if (oneOrg != null && oneOrg.containsKey(Constant.level_group_100)) {
  1105. jsonObject.put("num",oneOrg.get(Constant.level_group_100));
  1106. } else {
  1107. jsonObject.put("num",0);
  1108. }
  1109. jsonObject.put("name",hospital.getName());
  1110. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1111. redisTemplate.opsForValue().set(new StringBuffer("quota:7:2:100:"+hospitalEntry.getKey()).toString(),jsonObject.toString());
  1112. }
  1113. }
  1114. private void computequota_8()throws Exception {
  1115. //查找出系统全部的机构
  1116. List<Hospital> hospitals = hospitalDao.findHospital2();
  1117. Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
  1118. for (Hospital hospital : hospitals) {
  1119. hospitalsMap.put(hospital.getCode(), hospital);
  1120. }
  1121. //查找出厦门市全部的区
  1122. List<Town> towns = townDao.findByCityCode(Constant.city);
  1123. Map<String, Town> townsMap = new HashMap<String, Town>();
  1124. for (Town town : towns) {
  1125. townsMap.put(town.getCode(), town);
  1126. }
  1127. //找出今天的签约信息
  1128. String now = getDayString(0);
  1129. String tomorrow = getDayString(1);
  1130. List<SignFamily> signFamilys = signFamilyDao.findByJiatingSignYesterday(now,tomorrow);
  1131. //数组里面第一个是健康人群 第二个是慢病人群 第三个是65岁以上人群
  1132. Map<String, Map<String, Long>> cityAgeMap = new HashMap<String, Map<String, Long>>();//key是市行政代码 目前只有厦门市
  1133. cityAgeMap.put(Constant.city,new HashMap<String, Long>());
  1134. Map<String, Map<String, Long>> townAgeMap = new HashMap<String, Map<String, Long>>();//key是区行政代码
  1135. Map<String, Map<String, Long>> orgAgeMap = new HashMap<String, Map<String, Long>>();//key是机构代码
  1136. //统计有签约的
  1137. for (SignFamily signFamily : signFamilys) {
  1138. Hospital hospital = hospitalsMap.get(signFamily.getHospital());//得到患者签约的机构
  1139. if(hospital==null){
  1140. continue;
  1141. }
  1142. String town = hospital.getTown();
  1143. int age = IdCardUtil.getAgeForIdcard(signFamily.getIdcard());//根据card解析年龄
  1144. String ageCode =getAgeCode(age);//得到年龄的code
  1145. //统计市
  1146. if (cityAgeMap.containsKey(Constant.city)) {
  1147. Map<String, Long> groupMapTemp = cityAgeMap.get(Constant.city);
  1148. groupMapTemp.put(ageCode,(groupMapTemp.get(ageCode)==null?0l:groupMapTemp.get(ageCode)) + 1);
  1149. cityAgeMap.put(Constant.city, groupMapTemp);
  1150. } else {
  1151. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  1152. groupMapTemp.put(ageCode, 1L);
  1153. cityAgeMap.put(Constant.city, groupMapTemp);
  1154. }
  1155. //统计区
  1156. if (townAgeMap.containsKey(town)) {
  1157. Map<String, Long> groupMapTemp = townAgeMap.get(town);
  1158. groupMapTemp.put(ageCode,(groupMapTemp.get(ageCode)==null?0l:groupMapTemp.get(ageCode)) + 1);
  1159. townAgeMap.put(town, groupMapTemp);
  1160. } else {
  1161. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  1162. groupMapTemp.put(ageCode, 1L);
  1163. townAgeMap.put(town, groupMapTemp);
  1164. }
  1165. //统计机构
  1166. if (orgAgeMap.containsKey(hospital.getCode())) {
  1167. Map<String, Long> groupMapTemp = orgAgeMap.get(hospital.getCode());
  1168. groupMapTemp.put(ageCode,(groupMapTemp.get(ageCode)==null?0l:groupMapTemp.get(ageCode))+ 1);
  1169. orgAgeMap.put(hospital.getCode(), groupMapTemp);
  1170. } else {
  1171. Map<String, Long> groupMapTemp = new HashMap<String, Long>();
  1172. groupMapTemp.put(ageCode, 1L);
  1173. orgAgeMap.put(hospital.getCode(), groupMapTemp);
  1174. }
  1175. }
  1176. // 保存市的统计数据
  1177. for (Map.Entry<String, Map<String, Long>> entry : cityAgeMap.entrySet()) {
  1178. Map<String,Long> oneAgeMap=entry.getValue();
  1179. //保存0~6
  1180. JSONObject jsonObject=new JSONObject();
  1181. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_1)) {
  1182. jsonObject.put("num",oneAgeMap.get(Constant.level_age_1));
  1183. } else {
  1184. jsonObject.put("num",0);
  1185. }
  1186. jsonObject.put("name",Constant.cityName);
  1187. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1188. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:1:"+entry.getKey()).toString(),jsonObject.toString());
  1189. //保存7~18
  1190. jsonObject=new JSONObject();
  1191. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_2)) {
  1192. jsonObject.put("num",oneAgeMap.get(Constant.level_age_2));
  1193. } else {
  1194. jsonObject.put("num",0);
  1195. }
  1196. jsonObject.put("name",Constant.cityName);
  1197. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1198. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:2:"+entry.getKey()).toString(),jsonObject.toString());
  1199. //保存18~30
  1200. jsonObject=new JSONObject();
  1201. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_3)) {
  1202. jsonObject.put("num",oneAgeMap.get(Constant.level_age_3));
  1203. } else {
  1204. jsonObject.put("num",0);
  1205. }
  1206. jsonObject.put("name",Constant.cityName);
  1207. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1208. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:3:"+entry.getKey()).toString(),jsonObject.toString());
  1209. //保存30~50
  1210. jsonObject=new JSONObject();
  1211. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_4)) {
  1212. jsonObject.put("num",oneAgeMap.get(Constant.level_age_4));
  1213. } else {
  1214. jsonObject.put("num",0);
  1215. }
  1216. jsonObject.put("name",Constant.cityName);
  1217. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1218. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:4:"+entry.getKey()).toString(),jsonObject.toString());
  1219. //保存50~65
  1220. jsonObject=new JSONObject();
  1221. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_5)) {
  1222. jsonObject.put("num",oneAgeMap.get(Constant.level_age_5));
  1223. } else {
  1224. jsonObject.put("num",0);
  1225. }
  1226. jsonObject.put("name",Constant.cityName);
  1227. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1228. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:5:"+entry.getKey()).toString(),jsonObject.toString());
  1229. //保存18~30
  1230. jsonObject=new JSONObject();
  1231. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_6)) {
  1232. jsonObject.put("num",oneAgeMap.get(Constant.level_age_6));
  1233. } else {
  1234. jsonObject.put("num",0);
  1235. }
  1236. jsonObject.put("name",Constant.cityName);
  1237. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1238. redisTemplate.opsForValue().set(new StringBuffer("quota:8:4:6:"+entry.getKey()).toString(),jsonObject.toString());
  1239. }
  1240. //保存区级
  1241. for (Map.Entry<String, Town> entry : townsMap.entrySet()) {
  1242. //判断该区是否有统计数据
  1243. Map<String, Long> oneAgeMap = townAgeMap.get(entry.getKey());//得到当个区的统计数据
  1244. Town town = entry.getValue();//得到区级信息
  1245. JSONObject jsonObject=new JSONObject();
  1246. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_1)) {
  1247. jsonObject.put("num",oneAgeMap.get(Constant.level_age_1));
  1248. } else {
  1249. jsonObject.put("num",0);
  1250. }
  1251. jsonObject.put("name",town.getName());
  1252. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1253. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:1:"+entry.getKey()).toString(),jsonObject.toString());
  1254. //保存7~18
  1255. jsonObject=new JSONObject();
  1256. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_2)) {
  1257. jsonObject.put("num",oneAgeMap.get(Constant.level_age_2));
  1258. } else {
  1259. jsonObject.put("num",0);
  1260. }
  1261. jsonObject.put("name",town.getName());
  1262. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1263. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:2:"+entry.getKey()).toString(),jsonObject.toString());
  1264. //保存18~30
  1265. jsonObject=new JSONObject();
  1266. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_3)) {
  1267. jsonObject.put("num",oneAgeMap.get(Constant.level_age_3));
  1268. } else {
  1269. jsonObject.put("num",0);
  1270. }
  1271. jsonObject.put("name",town.getName());
  1272. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1273. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:3:"+entry.getKey()).toString(),jsonObject.toString());
  1274. //保存30~50
  1275. jsonObject=new JSONObject();
  1276. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_4)) {
  1277. jsonObject.put("num",oneAgeMap.get(Constant.level_age_4));
  1278. } else {
  1279. jsonObject.put("num",0);
  1280. }
  1281. jsonObject.put("name",town.getName());
  1282. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1283. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:4:"+entry.getKey()).toString(),jsonObject.toString());
  1284. //保存50~65
  1285. jsonObject=new JSONObject();
  1286. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_5)) {
  1287. jsonObject.put("num",oneAgeMap.get(Constant.level_age_5));
  1288. } else {
  1289. jsonObject.put("num",0);
  1290. }
  1291. jsonObject.put("name",town.getName());
  1292. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1293. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:5:"+entry.getKey()).toString(),jsonObject.toString());
  1294. //保存18~30
  1295. jsonObject=new JSONObject();
  1296. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_6)) {
  1297. jsonObject.put("num",oneAgeMap.get(Constant.level_age_6));
  1298. } else {
  1299. jsonObject.put("num",0);
  1300. }
  1301. jsonObject.put("name",town.getName());
  1302. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1303. redisTemplate.opsForValue().set(new StringBuffer("quota:8:3:6:"+entry.getKey()).toString(),jsonObject.toString());
  1304. }
  1305. for (Map.Entry<String, Hospital> entry : hospitalsMap.entrySet()) {
  1306. //判断该机构是否有统计数据
  1307. Map<String, Long> oneAgeMap = orgAgeMap.get(entry.getKey());//得到当个机构的统计数据
  1308. Hospital hospital = entry.getValue();//得到区级信息
  1309. //保存0~6
  1310. JSONObject jsonObject=new JSONObject();
  1311. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_1)) {
  1312. jsonObject.put("num",oneAgeMap.get(Constant.level_age_1));
  1313. } else {
  1314. jsonObject.put("num",0);
  1315. }
  1316. jsonObject.put("name",hospital.getName());
  1317. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1318. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:1:"+entry.getKey()).toString(),jsonObject.toString());
  1319. //保存7~18
  1320. jsonObject=new JSONObject();
  1321. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_2)) {
  1322. jsonObject.put("num",oneAgeMap.get(Constant.level_age_2));
  1323. } else {
  1324. jsonObject.put("num",0);
  1325. }
  1326. jsonObject.put("name",hospital.getName());
  1327. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1328. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:2:"+entry.getKey()).toString(),jsonObject.toString());
  1329. //保存18~30
  1330. jsonObject=new JSONObject();
  1331. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_3)) {
  1332. jsonObject.put("num",oneAgeMap.get(Constant.level_age_3));
  1333. } else {
  1334. jsonObject.put("num",0);
  1335. }
  1336. jsonObject.put("name",hospital.getName());
  1337. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1338. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:3:"+entry.getKey()).toString(),jsonObject.toString());
  1339. //保存30~50
  1340. jsonObject=new JSONObject();
  1341. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_4)) {
  1342. jsonObject.put("num",oneAgeMap.get(Constant.level_age_4));
  1343. } else {
  1344. jsonObject.put("num",0);
  1345. }
  1346. jsonObject.put("name",hospital.getName());
  1347. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1348. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:4"+entry.getKey()).toString(),jsonObject.toString());
  1349. //保存50~65
  1350. jsonObject=new JSONObject();
  1351. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_5)) {
  1352. jsonObject.put("num",oneAgeMap.get(Constant.level_age_5));
  1353. } else {
  1354. jsonObject.put("num",0);
  1355. }
  1356. jsonObject.put("name",hospital.getName());
  1357. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1358. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:5:"+entry.getKey()).toString(),jsonObject.toString());
  1359. //保存18~30
  1360. jsonObject=new JSONObject();
  1361. if (oneAgeMap!=null&&oneAgeMap.containsKey(Constant.level_age_6)) {
  1362. jsonObject.put("num",oneAgeMap.get(Constant.level_age_6));
  1363. } else {
  1364. jsonObject.put("num",0);
  1365. }
  1366. jsonObject.put("name",hospital.getName());
  1367. jsonObject.put("date", DateUtil.dateToStrLong(new Date()));
  1368. redisTemplate.opsForValue().set(new StringBuffer("quota:8:2:6:"+entry.getKey()).toString(),jsonObject.toString());
  1369. }
  1370. }
  1371. private void computequota_9() {
  1372. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  1373. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  1374. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  1375. Map<String, JSONObject> tjQkdoctorMap = new HashMap<String, JSONObject>();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode
  1376. initMap(tjCityMap, tjTownMap, tjOrgMap, tjQkdoctorMap, null);
  1377. String now = getDayString(0);
  1378. String tomorrow = getDayString(1);
  1379. List<SignFamily> signFamilys = signFamilyDao.findByJiatingWaitSignYesterday(now, tomorrow);
  1380. //统计有签约的
  1381. for (SignFamily signFamily : signFamilys) {
  1382. String hospitalCode=signFamily.getHospital();
  1383. Hospital hospital=hospitalsMap.get(hospitalCode);
  1384. //统计市
  1385. JSONObject cityjo=tjCityMap.get(Constant.city);
  1386. cityjo.put("num",((int)cityjo.get("num"))+1);
  1387. //统计区
  1388. JSONObject townjo=tjTownMap.get(hospital.getTown());
  1389. townjo.put("num",((int)townjo.get("num"))+1);
  1390. //统计机构
  1391. //判断是中心还是服务站 服务站的话添加到中心去
  1392. if(!"00".equals(hospital.getCode().substring(8))){
  1393. String orgCodeTemp=hospital.getCode().substring(0,8)+"00";
  1394. JSONObject orgjo=tjOrgMap.get(orgCodeTemp);
  1395. orgjo.put("num",((int)orgjo.get("num"))+1);
  1396. }else{
  1397. JSONObject orgjo=tjOrgMap.get(hospital.getCode());
  1398. orgjo.put("num",((int)orgjo.get("num"))+1);
  1399. }
  1400. //统计全科医生
  1401. JSONObject qkjo=tjQkdoctorMap.get(signFamily.getDoctor());
  1402. if(qkjo!=null){
  1403. qkjo.put("num",((int)qkjo.get("num"))+1);
  1404. }
  1405. }
  1406. //统计市
  1407. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  1408. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  1409. redisTemplate.opsForValue().set(new StringBuffer("quota:9:4:"+entry.getKey()).toString(), entry.getValue().toString());
  1410. }
  1411. //保存区
  1412. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  1413. redisTemplate.opsForValue().set(new StringBuffer("quota:9:3:"+entry.getKey()).toString(), entry.getValue().toString());
  1414. }
  1415. //保存机构
  1416. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  1417. redisTemplate.opsForValue().set(new StringBuffer("quota:9:2:"+entry.getKey()).toString(), entry.getValue().toString());
  1418. }
  1419. //保存全科医生
  1420. for(Map.Entry<String,JSONObject> entry:tjQkdoctorMap.entrySet()){
  1421. redisTemplate.opsForValue().set(new StringBuffer("quota:9:1:"+entry.getKey()).toString(), entry.getValue().toString());
  1422. }
  1423. }
  1424. private void computequota_10() {
  1425. Map<String, JSONObject> tjCityMap = new HashMap<>();//区级的统计map key 是区行政区划350200
  1426. Map<String, JSONObject> tjTownMap = new HashMap<String, JSONObject>();//区级的统计map key 是区行政区划350200
  1427. Map<String, JSONObject> tjOrgMap = new HashMap<String, JSONObject>();//机构的统计map key 是机构的code
  1428. Map<String, JSONObject> tjQkdoctorMap = new HashMap<String, JSONObject>();//团队级的统计map 目前没有团队 先用全科医生统一 key doctorCode
  1429. initMap(tjCityMap, tjTownMap, tjOrgMap, tjQkdoctorMap, null);
  1430. String now = getDayString(0);
  1431. String tomorrow = getDayString(1);
  1432. List<SignFamily> signFamilys = signFamilyDao.findByJiatingChaangeSignYesterday(now, tomorrow);
  1433. //统计有签约的
  1434. for (SignFamily signFamily : signFamilys) {
  1435. String hospitalCode=signFamily.getHospital();
  1436. Hospital hospital=hospitalsMap.get(hospitalCode);
  1437. //统计市
  1438. JSONObject cityjo=tjCityMap.get(Constant.city);
  1439. cityjo.put("num",((int)cityjo.get("num"))+1);
  1440. //统计区
  1441. JSONObject townjo=tjTownMap.get(hospital.getTown());
  1442. townjo.put("num",((int)townjo.get("num"))+1);
  1443. //统计机构
  1444. JSONObject orgjo=tjOrgMap.get(hospital.getCode());
  1445. orgjo.put("num",((int)orgjo.get("num"))+1);
  1446. //统计全科医生
  1447. JSONObject qkjo=tjQkdoctorMap.get(signFamily.getDoctor());
  1448. if(qkjo!=null){
  1449. qkjo.put("num",((int)qkjo.get("num"))+1);
  1450. }
  1451. }
  1452. //统计市
  1453. for(Map.Entry<String,JSONObject> entry:tjCityMap.entrySet()){
  1454. entry.getValue().put("date", DateUtil.dateToStrLong(new Date()));
  1455. redisTemplate.opsForValue().set(new StringBuffer("quota:10:4:"+entry.getKey()).toString(), entry.getValue().toString());
  1456. }
  1457. //保存区
  1458. for(Map.Entry<String,JSONObject> entry:tjTownMap.entrySet()){
  1459. redisTemplate.opsForValue().set(new StringBuffer("quota:10:3:"+entry.getKey()).toString(), entry.getValue().toString());
  1460. }
  1461. //保存机构
  1462. for(Map.Entry<String,JSONObject> entry:tjOrgMap.entrySet()){
  1463. redisTemplate.opsForValue().set(new StringBuffer("quota:10:2:"+entry.getKey()).toString(), entry.getValue().toString());
  1464. }
  1465. //保存全科医生
  1466. for(Map.Entry<String,JSONObject> entry:tjQkdoctorMap.entrySet()){
  1467. redisTemplate.opsForValue().set(new StringBuffer("quota:10:1:"+entry.getKey()).toString(), entry.getValue().toString());
  1468. }
  1469. }
  1470. public Properties getSystemProperties() {
  1471. if (systemProperties == null) {
  1472. InputStream is = null;
  1473. try {
  1474. is = this.getClass().getResourceAsStream("/application.properties");
  1475. systemProperties = new Properties();
  1476. systemProperties.load(is);
  1477. } catch (IOException e1) {
  1478. e1.printStackTrace();
  1479. } finally {
  1480. if (is != null) {
  1481. try {
  1482. is.close();
  1483. } catch (IOException e) {
  1484. e.printStackTrace();
  1485. }
  1486. }
  1487. }
  1488. }
  1489. return systemProperties;
  1490. }
  1491. public static String getDayString(Integer size) {
  1492. Date date = new Date();//取时间
  1493. Calendar calendar = new GregorianCalendar();
  1494. calendar.setTime(date);
  1495. calendar.add(calendar.DATE, size);//把日期往后增加一天.整数往后推,负数往前移动
  1496. date = calendar.getTime(); //这个时间就是日期往后推一天的结果
  1497. SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
  1498. String dateString = formatter.format(date);
  1499. return dateString;
  1500. }
  1501. public List<Map<String,Object>> getFvYesterday() {
  1502. String now = getDayString(0);
  1503. String tomorrow = getDayString(1);
  1504. String sql=" select * from fv_plan a where unix_timestamp(a.update_time)>=unix_timestamp('"+now+"') and unix_timestamp(a.update_time)< unix_timestamp('"+tomorrow+"') ";
  1505. return jdbcTemplate.queryForList(sql);
  1506. }
  1507. /**
  1508. * 根据年龄得到对应的code
  1509. * @param age
  1510. * @return
  1511. */
  1512. public String getAgeCode(int age) {
  1513. if (age < 7) {
  1514. return Constant.level_age_1;
  1515. } else if (age >= 7 && age < 18) {
  1516. return Constant.level_age_2;
  1517. } else if (age >= 18 && age < 30) {
  1518. return Constant.level_age_3;
  1519. } else if (age >= 30 && age < 50) {
  1520. return Constant.level_age_4;
  1521. } else if (age >= 50 && age < 65) {
  1522. return Constant.level_age_5;
  1523. } else {
  1524. return Constant.level_age_6;
  1525. }
  1526. }
  1527. }