|
@ -116,9 +116,6 @@ public class SignJob implements Job {
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
//String sql=" select code,idcard,hospital,admin_team_code from wlyy_sign_family a where a.type =2 and a.expenses_time< '"+yesterday+ Constant.quota_date_last+"' and a.expenses_status=1 ";
|
|
|
|
//抽取數據
|
|
|
|
// List<SignFamily> signFamilies= dbExtract.extract(SignFamily.class,sql);
|
|
|
|
//从缓存取数据
|
|
//从缓存取数据
|
|
CacheModel cacheModel=cachePool.getSignFamilysWithExpenseStatus1ByDate(yesterday);
|
|
CacheModel cacheModel=cachePool.getSignFamilysWithExpenseStatus1ByDate(yesterday);
|
|
//清洗數據
|
|
//清洗數據
|
|
@ -190,9 +187,7 @@ public class SignJob implements Job {
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
//找出今天的签约信息
|
|
|
|
// String sql=" select code,idcard,hospital,admin_team_code from wlyy_sign_family a where a.type =2 and a.expenses_time< '"+yesterday+ Constant.quota_date_last+"' and a.expenses_status=1 ";
|
|
|
|
//抽取數據
|
|
|
|
|
|
//从缓存取数据
|
|
CacheModel cacheModel=cachePool.getSignFamilysWithExpenseStatus1ByDate(yesterday);
|
|
CacheModel cacheModel=cachePool.getSignFamilysWithExpenseStatus1ByDate(yesterday);
|
|
//清洗數據
|
|
//清洗數據
|
|
FilterModel etlModels= signDataFilter.filter(cacheModel.getSignFamilies(),SignDataFilter.level2Age,cacheModel.getSql(),yesterday);
|
|
FilterModel etlModels= signDataFilter.filter(cacheModel.getSignFamilies(),SignDataFilter.level2Age,cacheModel.getSql(),yesterday);
|