CurrentDayAllQuotaJob.java 81 KB

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