|
@ -424,7 +424,7 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 13, 10, 0);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1414,10 +1414,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies,"2",null,sql,"now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1627,10 +1629,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies,"2",null ,sql, "now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1696,10 +1700,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies,"2",null,sql, "now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1765,10 +1771,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies,"2",null, sql, "now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1824,10 +1832,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, "2",null,sql, "now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1845,10 +1855,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, "2",null,sql, "now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@ -1899,10 +1911,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies,"2",null,sql,"now");
|
|
|
//统计数据
|
|
|
//统计数据 一级维度
|
|
|
List<Map<String, List<ETLModel>>> returnDatas = SpringUtil.getBean(Level1Role.class).elt(etlModels.getEtlModelList());
|
|
|
//统计数据 二级维度
|
|
|
List<Map<String, Map<String, List<ETLModel>>>> patientSexRoleData = SpringUtil.getBean(Level2Role.class).elt(returnDatas);
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel2(patientSexRoleData, null, quotaId, 12, 10, 0);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|