|
@ -1,15 +1,22 @@
|
|
package com.yihu.wlyy.job;
|
|
package com.yihu.wlyy.job;
|
|
|
|
|
|
import com.yihu.wlyy.entity.*;
|
|
|
|
import com.yihu.wlyy.entity.address.Hospital;
|
|
import com.yihu.wlyy.entity.address.Hospital;
|
|
import com.yihu.wlyy.entity.address.Town;
|
|
import com.yihu.wlyy.entity.address.Town;
|
|
import com.yihu.wlyy.entity.doctor.Doctor;
|
|
|
|
import com.yihu.wlyy.entity.doctor.DoctorPatientGroupInfo;
|
|
|
|
|
|
import com.yihu.wlyy.entity.doctor.profile.Doctor;
|
|
|
|
import com.yihu.wlyy.entity.doctor.team.sign.DoctorPatientGroupInfo;
|
|
|
|
import com.yihu.wlyy.entity.job.QuartzJobLog;
|
|
import com.yihu.wlyy.entity.patient.Patient;
|
|
import com.yihu.wlyy.entity.patient.Patient;
|
|
import com.yihu.wlyy.entity.patient.PatientDisease;
|
|
|
|
import com.yihu.wlyy.repository.*;
|
|
|
|
|
|
import com.yihu.wlyy.entity.patient.SignFamily;
|
|
|
|
import com.yihu.wlyy.entity.statistics.WlyyQuotaResult;
|
|
|
|
import com.yihu.wlyy.repository.address.TownDao;
|
|
|
|
import com.yihu.wlyy.repository.doctor.DoctorDao;
|
|
|
|
import com.yihu.wlyy.repository.doctor.DoctorPatientGroupInfoDao;
|
|
|
|
import com.yihu.wlyy.repository.job.QuartzJobLogDao;
|
|
|
|
import com.yihu.wlyy.repository.organization.HospitalDao;
|
|
|
|
import com.yihu.wlyy.repository.patient.PatientDao;
|
|
|
|
import com.yihu.wlyy.repository.patient.SignFamilyDao;
|
|
|
|
import com.yihu.wlyy.repository.statistics.WlyyQuotaResultDao;
|
|
import com.yihu.wlyy.service.app.disease.PatientDiseaseService;
|
|
import com.yihu.wlyy.service.app.disease.PatientDiseaseService;
|
|
import com.yihu.wlyy.service.common.account.PatientService;
|
|
|
|
import com.yihu.wlyy.util.IdCardUtil;
|
|
import com.yihu.wlyy.util.IdCardUtil;
|
|
import com.yihu.wlyy.web.quota.WlyyJobConfigVO;
|
|
import com.yihu.wlyy.web.quota.WlyyJobConfigVO;
|
|
import com.yihu.wlyy.web.quota.WlyyQuotaVO;
|
|
import com.yihu.wlyy.web.quota.WlyyQuotaVO;
|
|
@ -27,7 +34,6 @@ import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.util.StringUtils;
|
|
import org.springframework.util.StringUtils;
|
|
import org.springframework.web.context.support.SpringBeanAutowiringSupport;
|
|
import org.springframework.web.context.support.SpringBeanAutowiringSupport;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
import java.text.SimpleDateFormat;
|
|
import java.text.SimpleDateFormat;
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
|
|
@ -41,7 +47,7 @@ public class SignJob implements Job {
|
|
@Autowired
|
|
@Autowired
|
|
private WlyyQuotaResultDao wlyyQuotaResultDao;//指标结果Dao
|
|
private WlyyQuotaResultDao wlyyQuotaResultDao;//指标结果Dao
|
|
@Autowired
|
|
@Autowired
|
|
private WlyyJobLogDao wlyyJobLogDao;//执行日志Dao
|
|
|
|
|
|
private QuartzJobLogDao quartzJobLogDao;//执行日志Dao
|
|
@Autowired
|
|
@Autowired
|
|
private SignFamilyDao signFamilyDao;
|
|
private SignFamilyDao signFamilyDao;
|
|
@Autowired
|
|
@Autowired
|
|
@ -115,10 +121,10 @@ public class SignJob implements Job {
|
|
|
|
|
|
try {
|
|
try {
|
|
//新建任务日志对象
|
|
//新建任务日志对象
|
|
WlyyJobLog wlyyJobLog = new WlyyJobLog();
|
|
|
|
wlyyJobLog.setJobStartTime(new Date());
|
|
|
|
wlyyJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
wlyyJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
QuartzJobLog quartzJobLog = new QuartzJobLog();
|
|
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
//查找出系统全部的机构
|
|
//查找出系统全部的机构
|
|
List<Hospital> hospitals = hospitalDao.findHospitalzxFWZ();
|
|
List<Hospital> hospitals = hospitalDao.findHospitalzxFWZ();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
@ -390,10 +396,10 @@ public class SignJob implements Job {
|
|
}
|
|
}
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
}
|
|
}
|
|
wlyyJobLog.setJobEndTime(new Date());
|
|
|
|
wlyyJobLog.setJobContent("统计" + getYesterday() + " 的签约性别数据完成 ");
|
|
|
|
wlyyJobLog.setJobType("1");
|
|
|
|
wlyyJobLogDao.save(wlyyJobLog);
|
|
|
|
|
|
quartzJobLog.setJobEndTime(new Date());
|
|
|
|
quartzJobLog.setJobContent("统计" + getYesterday() + " 的签约性别数据完成 ");
|
|
|
|
quartzJobLog.setJobType("1");
|
|
|
|
quartzJobLogDao.save(quartzJobLog);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
@ -413,10 +419,10 @@ public class SignJob implements Job {
|
|
Map<String, Map<String, Long>> townGroupMap = new HashMap<String, Map<String, Long>>();//key是区行政代码
|
|
Map<String, Map<String, Long>> townGroupMap = new HashMap<String, Map<String, Long>>();//key是区行政代码
|
|
Map<String, Map<String, Long>> orgGroupMap = new HashMap<String, Map<String, Long>>();//key是机构代码
|
|
Map<String, Map<String, Long>> orgGroupMap = new HashMap<String, Map<String, Long>>();//key是机构代码
|
|
//新建任务日志对象
|
|
//新建任务日志对象
|
|
WlyyJobLog wlyyJobLog = new WlyyJobLog();
|
|
|
|
wlyyJobLog.setJobStartTime(new Date());
|
|
|
|
wlyyJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
wlyyJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
QuartzJobLog quartzJobLog = new QuartzJobLog();
|
|
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
//查找出系统全部的机构
|
|
//查找出系统全部的机构
|
|
List<Hospital> hospitals = hospitalDao.findHospital2();
|
|
List<Hospital> hospitals = hospitalDao.findHospital2();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
@ -978,10 +984,10 @@ public class SignJob implements Job {
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
}
|
|
}
|
|
|
|
|
|
wlyyJobLog.setJobEndTime(new Date());
|
|
|
|
wlyyJobLog.setJobContent("统计" + getYesterday() + " 的签约病人分组数据完成 ");
|
|
|
|
wlyyJobLog.setJobType("1");
|
|
|
|
wlyyJobLogDao.save(wlyyJobLog);
|
|
|
|
|
|
quartzJobLog.setJobEndTime(new Date());
|
|
|
|
quartzJobLog.setJobContent("统计" + getYesterday() + " 的签约病人分组数据完成 ");
|
|
|
|
quartzJobLog.setJobType("1");
|
|
|
|
quartzJobLogDao.save(quartzJobLog);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
@ -995,10 +1001,10 @@ public class SignJob implements Job {
|
|
try {
|
|
try {
|
|
jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 8 + "'");
|
|
jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 8 + "'");
|
|
//新建任务日志对象
|
|
//新建任务日志对象
|
|
WlyyJobLog wlyyJobLog = new WlyyJobLog();
|
|
|
|
wlyyJobLog.setJobStartTime(new Date());
|
|
|
|
wlyyJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
wlyyJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
QuartzJobLog quartzJobLog = new QuartzJobLog();
|
|
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
//查找出系统全部的机构
|
|
//查找出系统全部的机构
|
|
List<Hospital> hospitals = hospitalDao.findHospital2();
|
|
List<Hospital> hospitals = hospitalDao.findHospital2();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
Map<String, Hospital> hospitalsMap = new HashMap<String, Hospital>();
|
|
@ -1451,10 +1457,10 @@ public class SignJob implements Job {
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
}
|
|
}
|
|
|
|
|
|
wlyyJobLog.setJobEndTime(new Date());
|
|
|
|
wlyyJobLog.setJobContent("统计" + getYesterday() + " 的签约患者年龄数据完成 ");
|
|
|
|
wlyyJobLog.setJobType("1");
|
|
|
|
wlyyJobLogDao.save(wlyyJobLog);
|
|
|
|
|
|
quartzJobLog.setJobEndTime(new Date());
|
|
|
|
quartzJobLog.setJobContent("统计" + getYesterday() + " 的签约患者年龄数据完成 ");
|
|
|
|
quartzJobLog.setJobType("1");
|
|
|
|
quartzJobLogDao.save(quartzJobLog);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
@ -1468,10 +1474,10 @@ public class SignJob implements Job {
|
|
|
|
|
|
jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 1 + "'");
|
|
jdbcTemplate.execute("delete from wlyy_quota_result where quota_date='" + yesterday + "' and quato_code='" + 1 + "'");
|
|
//新建任务日志对象
|
|
//新建任务日志对象
|
|
WlyyJobLog wlyyJobLog = new WlyyJobLog();
|
|
|
|
wlyyJobLog.setJobStartTime(new Date());
|
|
|
|
wlyyJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
wlyyJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
QuartzJobLog quartzJobLog = new QuartzJobLog();
|
|
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
//查找出系统全部的全科医生
|
|
//查找出系统全部的全科医生
|
|
List<Doctor> doctors = doctorDao.findAllQKDoctot();
|
|
List<Doctor> doctors = doctorDao.findAllQKDoctot();
|
|
@ -1636,10 +1642,10 @@ public class SignJob implements Job {
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
wlyyQuotaResultDao.save(wlyyQuotaResult);
|
|
}
|
|
}
|
|
|
|
|
|
wlyyJobLog.setJobEndTime(new Date());
|
|
|
|
wlyyJobLog.setJobContent("统计" + getYesterday() + " 的签约数据完成 ");
|
|
|
|
wlyyJobLog.setJobType("1");
|
|
|
|
wlyyJobLogDao.save(wlyyJobLog);
|
|
|
|
|
|
quartzJobLog.setJobEndTime(new Date());
|
|
|
|
quartzJobLog.setJobContent("统计" + getYesterday() + " 的签约数据完成 ");
|
|
|
|
quartzJobLog.setJobType("1");
|
|
|
|
quartzJobLogDao.save(quartzJobLog);
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
/*
|