|
@ -214,9 +214,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.old_admin_team_id!=fr.admin_team_id and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "'";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1135,9 +1135,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "'";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1155,9 +1155,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "'";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
@ -1177,9 +1177,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "' and fr.admin_team_id!=fr.old_admin_team_id and fr.hospital=fr.old_hospital and LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6)" ;
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1197,9 +1197,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "'and fr.admin_team_id!=fr.old_admin_team_id and fr.hospital!=fr.old_hospital and LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6)";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1217,9 +1217,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "' and fr.admin_team_id!=fr.old_admin_team_id and fr.hospital!=fr.old_hospital and LEFT(fr.hospital,6)!=LEFT(fr.old_hospital,6) ";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1237,9 +1237,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "' and fr.admin_team_id!=fr.old_admin_team_id and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|
|
@ -1257,9 +1257,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
try {
|
|
|
String sql=" select fr.sign_code code,fr.old_hospital hospital,fr.old_admin_team_id admin_team_id from wlyy_sign_family_renew_log fr where fr.`status`>0 and fr.apply_date<'"+ tomorrow+"' and fr.apply_date> '" + Constant.getStartTime() + "' and fr.admin_team_id!=fr.old_admin_team_id and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamily.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(SignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//保存数据
|