WaitSignJob.java 9.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229
  1. package com.yihu.wlyy.job;
  2. import com.yihu.wlyy.entity.doctor.team.admin.AdminTeam;
  3. import com.yihu.wlyy.entity.organization.Hospital;
  4. import com.yihu.wlyy.entity.address.Town;
  5. import com.yihu.wlyy.entity.doctor.profile.Doctor;
  6. import com.yihu.wlyy.entity.job.QuartzJobLog;
  7. import com.yihu.wlyy.entity.patient.SignFamily;
  8. import com.yihu.wlyy.entity.statistics.WlyyQuotaResult;
  9. import com.yihu.wlyy.job.elt.base.ETLModel;
  10. import com.yihu.wlyy.job.elt.role.LevelRole;
  11. import com.yihu.wlyy.job.elt.storage.DBStorage;
  12. import com.yihu.wlyy.repository.address.TownDao;
  13. import com.yihu.wlyy.repository.doctor.DoctorAdminTeamDao;
  14. import com.yihu.wlyy.repository.doctor.DoctorDao;
  15. import com.yihu.wlyy.repository.job.QuartzJobLogDao;
  16. import com.yihu.wlyy.repository.organization.HospitalDao;
  17. import com.yihu.wlyy.repository.patient.SignFamilyDao;
  18. import com.yihu.wlyy.repository.statistics.WlyyQuotaResultDao;
  19. import com.yihu.wlyy.web.quota.WlyyJobConfigVO;
  20. import com.yihu.wlyy.web.quota.WlyyQuotaVO;
  21. import org.quartz.Job;
  22. import org.quartz.JobDataMap;
  23. import org.quartz.JobExecutionContext;
  24. import org.quartz.JobExecutionException;
  25. import org.springframework.beans.factory.annotation.Autowired;
  26. import org.springframework.jdbc.core.JdbcTemplate;
  27. import org.springframework.stereotype.Component;
  28. import org.springframework.transaction.annotation.Transactional;
  29. import org.springframework.util.StringUtils;
  30. import org.springframework.web.context.support.SpringBeanAutowiringSupport;
  31. import java.text.SimpleDateFormat;
  32. import java.util.*;
  33. /**
  34. * 待签约的指标执行类
  35. */
  36. @Component
  37. public class WaitSignJob implements Job {
  38. private WlyyQuotaVO wlyyQuota;//指标对象
  39. private WlyyJobConfigVO wlyyJobConfig;//配置对象
  40. @Autowired
  41. private QuartzJobLogDao quartzJobLogDao;//执行日志Dao
  42. @Autowired
  43. private SignFamilyDao signFamilyDao;
  44. @Autowired
  45. private HospitalDao hospitalDao;
  46. @Autowired
  47. private TownDao townDao;
  48. @Autowired
  49. private JdbcTemplate jdbcTemplate;
  50. @Autowired
  51. private LevelRole levelRole;
  52. @Autowired
  53. private DBStorage dbStorage;
  54. String yesterday;
  55. String now;
  56. @Autowired
  57. private DoctorAdminTeamDao doctorAdminTeamDao;
  58. @Override
  59. public void execute(JobExecutionContext context)
  60. throws JobExecutionException {
  61. SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
  62. //初始化参数
  63. JobDataMap map = context.getJobDetail().getJobDataMap();
  64. wlyyQuota = (WlyyQuotaVO) map.get("quota");
  65. wlyyJobConfig = (WlyyJobConfigVO) map.get("jobConfig");
  66. now= StringUtils.isEmpty(map.get("now"))?SignJob.getDayString(0):map.get("now").toString();
  67. yesterday= StringUtils.isEmpty(map.get("yesterday"))?SignJob.getDayString(-1):map.get("yesterday").toString();
  68. //计算指标
  69. computequota();
  70. }
  71. /**
  72. * 计算指标
  73. */
  74. @Transactional
  75. private void computequota() {
  76. jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='"+yesterday+"' and quato_code='"+9+"'");
  77. //新建任务日志对象
  78. QuartzJobLog quartzJobLog = new QuartzJobLog();
  79. quartzJobLog.setJobStartTime(new Date());
  80. quartzJobLog.setJobId(wlyyJobConfig.getId());
  81. quartzJobLog.setJobName(wlyyJobConfig.getJobName());
  82. //查找出系统全部的全科医生
  83. List<AdminTeam> adminTeams=doctorAdminTeamDao.findAllTeam();
  84. Map<String, AdminTeam> adminTeamMap = new HashMap<String, AdminTeam>();
  85. for (AdminTeam adminTeam : adminTeams) {
  86. adminTeamMap.put(adminTeam.getId()+"", adminTeam);
  87. }
  88. //查找出系统全部的机构
  89. List<Hospital> hospitals = hospitalDao.findHospital2();
  90. Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
  91. for (Hospital hospital : hospitals) {
  92. hospitalsMap.put(hospital.getCode(), hospital);
  93. }
  94. //查找出厦门市全部的区
  95. List<Town> towns = townDao.findByCityCode(Constant.city);
  96. Map<String, Town> townsMap = new HashMap<String, Town>();
  97. for (Town town : towns) {
  98. townsMap.put(town.getCode(), town);
  99. }
  100. //找出今天的待签约信息
  101. List<SignFamily> signFamilys = signFamilyDao.findByJiatingWaitSignYesterday(yesterday,now);
  102. Long cityCount = new Long(0L); //统计到市的数目
  103. Long townCount = new Long(0L); //统计到所有区的数目
  104. Long orgCount =new Long(0L);//统计到所有机构的数目
  105. Long adminCount = new Long(0L);//统计到所有团队的数目
  106. Long errorCount=new Long(0L);//脏数据
  107. Boolean isAll=true;//是否统计失败
  108. StringBuffer errorContent=new StringBuffer();
  109. //统计有已改簽的
  110. List<ETLModel> etlModels=new ArrayList<ETLModel>();
  111. //数据过滤清洗出脏数据 -----------start
  112. for(SignFamily signFamily:signFamilys){
  113. ETLModel etlModel=new ETLModel();
  114. String orgCode = signFamily.getHospital();
  115. if(StringUtils.isEmpty(orgCode)) {
  116. errorContent.append("签约code:"+signFamily.getCode()+",签约表中(wlyy_sign_family)中的hospital数据为空");
  117. isAll=false;
  118. errorCount++;
  119. continue;
  120. }
  121. String orgCodeTemp="";
  122. if(!"00".equals(orgCode.substring(orgCode.length()-2,orgCode.length()))){
  123. //站
  124. orgCodeTemp=orgCode.substring(0,orgCode.length()-2)+"00";
  125. }else{
  126. //社区
  127. orgCodeTemp=orgCode;
  128. }
  129. //判断社区有没有值
  130. Hospital hospital=hospitalsMap.get(orgCodeTemp);
  131. if(hospital == null) {
  132. errorContent.append("签约code:"+signFamily.getCode()+",签约表中(wlyy_sign_family)中的hospital数据不存在");
  133. isAll=false;
  134. errorCount++;
  135. continue;
  136. }
  137. Long adminId=signFamily.getAdminTeamId();
  138. if(adminId == null||adminId<=0) {
  139. errorContent.append("签约code:"+signFamily.getCode()+",签约表中(wlyy_sign_family)中的Admin_Team_Id数据为空");
  140. isAll=false;
  141. errorCount++;
  142. continue;
  143. }
  144. AdminTeam adminTeam=adminTeamMap.get(signFamily.getAdminTeamId()+"");
  145. if(adminTeam == null) {
  146. errorContent.append("签约code:"+signFamily.getCode()+",签约表中(wlyy_sign_family)中的Admin_Team_Id数据不存在");
  147. isAll=false;
  148. errorCount++;
  149. continue;
  150. }
  151. String idCard=signFamily.getIdcard();
  152. if(idCard == null||((idCard.length()!=18&&idCard.length()!=15))) {
  153. errorContent.append("签约code:"+signFamily.getCode()+",签约表中(wlyy_sign_family)中的idCard数据异常");
  154. isAll=false;
  155. errorCount++;
  156. continue;
  157. }
  158. String town =hospital.getTown();
  159. if(StringUtils.isEmpty(town)) {
  160. errorContent.append("签约code:"+signFamily.getCode()+",机构表的中的town为空");
  161. isAll=false;
  162. errorCount++;
  163. continue;
  164. }
  165. Town townObj =townsMap.get(town);
  166. if(townObj==null) {
  167. errorContent.append("签约code:"+signFamily.getCode()+",机构表的中的town不存在");
  168. isAll=false;
  169. errorCount++;
  170. continue;
  171. }
  172. etlModel.setAdminTeam(adminTeam.getId()+"");
  173. etlModel.setHospital(orgCodeTemp);
  174. etlModel.setTown(hospital.getTown());
  175. etlModel.setCity(Constant.city);
  176. etlModel.setIdcard(signFamily.getIdcard());
  177. etlModels.add(etlModel);
  178. //统计数目+1
  179. cityCount++;
  180. townCount++;
  181. orgCount++;
  182. adminCount++;
  183. }
  184. //数据过滤清洗出脏数据 -----------end
  185. try{
  186. //统计数据
  187. List<Map<String, List<ETLModel>>> returnDatas= levelRole.elt(etlModels);
  188. //保存数据
  189. dbStorage.saveByLevel1(returnDatas,yesterday,wlyyQuota);
  190. }catch (Exception e){
  191. e.printStackTrace();
  192. errorContent.append("统计失败:"+e.getMessage());
  193. }
  194. //保存日志
  195. quartzJobLog.setJobEndTime(new Date());
  196. quartzJobLog.setJobContent(saveContent(signFamilys,adminCount,orgCount,townCount,cityCount,isAll,errorContent,errorCount));
  197. quartzJobLog.setJobType(isAll?"1":"0");
  198. quartzJobLogDao.save(quartzJobLog);
  199. }
  200. private String saveContent(List<SignFamily> signFamilys, Long qkCount, Long orgCount, Long townCount, Long cityCount, boolean isAll, StringBuffer errorContent,Long errorCount) {
  201. StringBuffer string=new StringBuffer("统计"+yesterday+" 的待签约数据完成 ,数据库查询到待签约数目:"+signFamilys.size());
  202. string.append(",过滤的脏数据数目:"+errorCount);
  203. string.append(",统计到市的数据总数:"+cityCount);
  204. string.append(",统计到区的数据总数:"+townCount);
  205. string.append(",统计到机构的数据总数:"+orgCount);
  206. string.append(",统计到团队的数据总数:"+qkCount);
  207. string.append(",是否统计成功:"+isAll);
  208. if(!isAll){
  209. string.append(",失败原因:"+errorContent);
  210. }
  211. return string.toString();
  212. }
  213. public String getYesterday() {
  214. Calendar cal = Calendar.getInstance();
  215. cal.add(Calendar.DATE, -1);
  216. String yesterday = new SimpleDateFormat("yyyy-MM-dd").format(cal.getTime());
  217. return yesterday;
  218. }
  219. }