|
@ -141,6 +141,92 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取市签约量
|
|
|
* @return
|
|
|
*/
|
|
|
public Map<String,Object> getCityRenewTotals(){
|
|
|
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.apply_date<'"+ tomorrow+"' and " +
|
|
|
" fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
" LENGTH(fr.hospital)=10 and " +
|
|
|
" LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
|
|
|
Map<String,Object> map = new HashedMap();
|
|
|
map.put("signFamilies",signFamilies);
|
|
|
map.put("sql",sql);
|
|
|
return map;
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取城镇签约量
|
|
|
* @return
|
|
|
*/
|
|
|
public Map<String,Object> getTowmRenewTotals(){
|
|
|
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.apply_date<'"+ tomorrow+"' and " +
|
|
|
" fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
" LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6) and " +
|
|
|
" LENGTH(fr.hospital)=10 and " +
|
|
|
" LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
Map<String,Object> map = new HashedMap();
|
|
|
map.put("signFamilies",signFamilies);
|
|
|
map.put("sql",sql);
|
|
|
return map;
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取机构签约量
|
|
|
* @return
|
|
|
*/
|
|
|
public Map<String,Object> getOrgRenewTotals(){
|
|
|
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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "'and fr.hospital=fr.old_hospital and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
Map<String,Object> map = new HashedMap();
|
|
|
map.put("signFamilies",signFamilies);
|
|
|
map.put("sql",sql);
|
|
|
return map;
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取团队机构签约量
|
|
|
* @return
|
|
|
*/
|
|
|
public Map<String,Object> getTeamRenewTotals(){
|
|
|
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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and fr.admin_team_id=fr.old_admin_team_id and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
Map<String,Object> map = new HashedMap();
|
|
|
map.put("signFamilies",signFamilies);
|
|
|
map.put("sql",sql);
|
|
|
return map;
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
//统计
|
|
|
private void computequota() throws Exception {
|
|
|
|
|
@ -165,6 +251,13 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
|
|
|
//抽取數據
|
|
|
List<SignFamily> signFamilies = SpringUtil.getBean(DBExtract.class).extractByPage(SignFamily.class, sql, sqlCount, true);
|
|
|
//抽取數據市级签约
|
|
|
Map<String,Object> citySignFamilies =getCityRenewTotals();
|
|
|
Map<String,Object> townSignFamilies =getTowmRenewTotals();
|
|
|
Map<String,Object> orgSignFamilies =getOrgRenewTotals();
|
|
|
Map<String,Object> teamSignFamilies =getTeamRenewTotals();
|
|
|
|
|
|
|
|
|
computequota_1(sql, signFamilies, null); //统计今天的签约
|
|
|
computequota_2(); //统计今天的解约
|
|
|
computequota_3(); //统计今天的健康咨询量
|
|
@ -202,17 +295,21 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
computequota_39(); //统计机构签出
|
|
|
computequota_40(); //续签区签入
|
|
|
computequota_41(); //统计区签出
|
|
|
computequota_42(); //统计团队续签
|
|
|
computequota_43(); //统计社区续签
|
|
|
computequota_44(); //统计区续签
|
|
|
computequota_29(); //统计市级续签
|
|
|
computequota_42(teamSignFamilies); //统计团队续签
|
|
|
computequota_43(townSignFamilies); //统计社区续签
|
|
|
computequota_44(orgSignFamilies); //统计区续签
|
|
|
computequota_29(citySignFamilies); //统计市级续签
|
|
|
//computequota_45(); //统计社区转签 没用指标
|
|
|
//computequota_46(); //统计区转签 没用指标
|
|
|
computequota_30(); //统计团队续签原因
|
|
|
// computequota_47(); //统计社区续签原因 没用指标
|
|
|
// computequota_48(); //统计区续签原因 没用指标
|
|
|
|
|
|
//1.3.8
|
|
|
//1.3.8需求开发
|
|
|
computequota_51(citySignFamilies);//统计市级续签服务类型维度
|
|
|
computequota_52(teamSignFamilies);//统计团队续签人数服务类型维度
|
|
|
computequota_53(orgSignFamilies);//统计社区续签人数服务类型维度
|
|
|
computequota_54(townSignFamilies);//统计区续签人数服务类型维度
|
|
|
|
|
|
|
|
|
quartzJobLog.setJobContent(allContent.toString());
|
|
@ -1237,15 +1334,11 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private void computequota_29() {
|
|
|
private void computequota_29(Map<String,Object> sign) {
|
|
|
String quotaId = "29";
|
|
|
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.apply_date<'"+ tomorrow+"' and " +
|
|
|
" fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
" LENGTH(fr.hospital)=10 and " +
|
|
|
" LENGTH(fr.old_hospital)=10 "; //抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
@ -1260,6 +1353,27 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
allContent.append("-----------29----------");
|
|
|
}
|
|
|
|
|
|
private void computequota_51(Map<String,Object> sign) {
|
|
|
String quotaId = "51";
|
|
|
try {
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
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());
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
allContent.append("统计失败:" + e.getMessage());
|
|
|
}
|
|
|
allContent.append("-----------51----------");
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private void computequota_30() {
|
|
|
String quotaId = "30";
|
|
|
try {
|
|
@ -1533,12 +1647,11 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
allContent.append("-----------41----------");
|
|
|
}
|
|
|
|
|
|
private void computequota_42() {
|
|
|
private void computequota_42(Map<String,Object> sign) {
|
|
|
String quotaId = "42";
|
|
|
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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and fr.admin_team_id=fr.old_admin_team_id and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
@ -1552,12 +1665,14 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
}
|
|
|
allContent.append("-----------42----------");
|
|
|
}
|
|
|
private void computequota_43() {
|
|
|
private void computequota_43(Map<String,Object> sign) {
|
|
|
String quotaId = "43";
|
|
|
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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "'and fr.hospital=fr.old_hospital and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
String sql = (String)sign.get("sql");
|
|
|
// 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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "'and fr.hospital=fr.old_hospital and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
// //抽取數據
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
@ -1571,17 +1686,60 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
}
|
|
|
allContent.append("-----------43----------");
|
|
|
}
|
|
|
private void computequota_44() {
|
|
|
|
|
|
private void computequota_52(Map<String,Object> sign) {
|
|
|
String quotaId = "52";
|
|
|
try {
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
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());
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
allContent.append("统计失败:" + e.getMessage());
|
|
|
}
|
|
|
allContent.append("-----------52----------");
|
|
|
}
|
|
|
private void computequota_53(Map<String,Object> sign) {
|
|
|
String quotaId = "53";
|
|
|
try {
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
String sql = (String)sign.get("sql");
|
|
|
// 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.apply_date<'"+ tomorrow+"' and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "'and fr.hospital=fr.old_hospital and LENGTH(fr.hospital)=10 and LENGTH(fr.old_hospital)=10 ";
|
|
|
// //抽取數據
|
|
|
// 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());
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
allContent.append("统计失败:" + e.getMessage());
|
|
|
}
|
|
|
allContent.append("-----------53----------");
|
|
|
}
|
|
|
|
|
|
private void computequota_44(Map<String,Object> sign) {
|
|
|
String quotaId = "44";
|
|
|
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.apply_date<'"+ tomorrow+"' and " +
|
|
|
" fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
" LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6) and " +
|
|
|
" LENGTH(fr.hospital)=10 and " +
|
|
|
" LENGTH(fr.old_hospital)=10 ";
|
|
|
//抽取數據
|
|
|
List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
// 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.apply_date<'"+ tomorrow+"' and " +
|
|
|
// " fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
// " LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6) and " +
|
|
|
// " LENGTH(fr.hospital)=10 and " +
|
|
|
// " LENGTH(fr.old_hospital)=10 ";
|
|
|
// //抽取數據
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
String sql = (String)sign.get("sql");
|
|
|
//清洗數據
|
|
|
FilterModel etlModels = SpringUtil.getBean(RenewSignDataFilter.class).filter(signFamilies, sql, "now");
|
|
|
//统计数据
|
|
@ -1595,6 +1753,34 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
}
|
|
|
allContent.append("-----------44----------");
|
|
|
}
|
|
|
|
|
|
private void computequota_54(Map<String,Object> sign) {
|
|
|
String quotaId = "54";
|
|
|
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.apply_date<'"+ tomorrow+"' and " +
|
|
|
// " fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "' and " +
|
|
|
// " LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6) and " +
|
|
|
// " LENGTH(fr.hospital)=10 and " +
|
|
|
// " LENGTH(fr.old_hospital)=10 ";
|
|
|
// //抽取數據
|
|
|
// List<SignFamilyRenew> signFamilies = SpringUtil.getBean(DBExtract.class).extract(SignFamilyRenew.class, sql);
|
|
|
List<SignFamilyRenew> signFamilies = (List<SignFamilyRenew>)sign.get("signFamilies");
|
|
|
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());
|
|
|
//保存数据
|
|
|
SpringUtil.getBean(RedisStorage.class).saveByLevel1(returnDatas, null, quotaId);
|
|
|
allContent.append(JsonUtil.objToStr(etlModels.getLogModel()));
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
allContent.append("统计失败:" + e.getMessage());
|
|
|
}
|
|
|
allContent.append("-----------54----------");
|
|
|
}
|
|
|
|
|
|
private void computequota_45() {
|
|
|
String quotaId = "45";
|
|
|
try {
|