|
@ -95,16 +95,17 @@ public class AllSignExpenseStatusJob implements Job{
|
|
|
quartzJobLog.setJobStartTime(new Date());
|
|
|
quartzJobLog.setJobId(wlyyJobConfig.getId());
|
|
|
quartzJobLog.setJobName(wlyyJobConfig.getJobName());
|
|
|
|
|
|
//抽取第一种条件的语句
|
|
|
String sql=" select code,idcard,hospital,admin_team_code,expenses_status from wlyy_sign_family a where a.type =2 and a.apply_date< '"+date+ Constant.quota_date_last+"' and expenses_status=1";
|
|
|
String sqlCount=" select count(id) from wlyy_sign_family a where a.type =2 and a.apply_date< '"+date+ Constant.quota_date_last+"'and expenses_status=1 ";
|
|
|
//抽取數據 expensesStatus=1
|
|
|
List<SignFamily> signFamilies_1= dbExtract.extractByPage(SignFamily.class,sql,sqlCount,true);
|
|
|
|
|
|
//抽取第二种条件的语句
|
|
|
sql=" select code,idcard,hospital,admin_team_code,expenses_status from wlyy_sign_family a where a.type =2 and a.apply_date< '"+date+ Constant.quota_date_last+"' and (expenses_status !=1 or expenses_status is null)";
|
|
|
sqlCount=" select count(id) from wlyy_sign_family a where a.type =2 and a.apply_date< '"+date+ Constant.quota_date_last+"'and (expenses_status !=1 or expenses_status is null) ";
|
|
|
List<SignFamily> signFamilies_2= dbExtract.extractByPage(SignFamily.class,sql,sqlCount,true);
|
|
|
|
|
|
//抽取的语句
|
|
|
sql="select code,idcard,hospital,admin_team_code,expenses_status from wlyy_sign_family a where a.type =2 and a.apply_date< '"+date+ Constant.quota_date_last+"'";
|
|
|
//清洗數據
|
|
|
FilterModel etlModels= signDataFilter.filter(signFamilies_1, SignDataFilter.level2Expenses,sql,date);
|
|
|
//统计数据
|