|
@ -129,7 +129,9 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
//延迟上一次key的生命周期
|
|
|
if (CachePool.getKeys() != null && CachePool.getKeys().size() > 0) {
|
|
|
for (String key : CachePool.getKeys()) {
|
|
|
redisTemplate.expire(key, Integer.valueOf(currentExpire), TimeUnit.HOURS);//2小时过期
|
|
|
if (!StringUtils.isEmpty(key)) {
|
|
|
redisTemplate.expire(key, Integer.valueOf(currentExpire), TimeUnit.HOURS);//2小时过期}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//如果出錯立即重新執行
|
|
@ -1165,9 +1167,10 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
private void computequota_30() {
|
|
|
String quotaId = "30";
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.admin_team_id,fr.renew_change_reason from wlyy_sign_family_renew_log fr where " +
|
|
|
String sql="select fr.sign_code code,fr.old_hospital ,fr.old_admin_team_id admin_team_id,fr.renew_change_reason from wlyy_sign_family_renew_log fr where " +
|
|
|
" fr.old_admin_team_id!=fr.admin_team_id " +
|
|
|
" and LEFT(fr.hospital,6)=LEFT(fr.old_hospital,6) " +
|
|
|
" and LENGTH(fr.hospital)=10 " +
|
|
|
" and LENGTH(fr.old_hospital)=10 "+
|
|
|
" and fr.apply_date<'"+tomorrow+"' " +
|
|
|
" and fr.sign_year= '" + Constant.getNowYearByDate(tomorrow) + "'";
|
|
|
//抽取數據
|
|
@ -1309,7 +1312,12 @@ public class CurrentDayAllQuotaJob implements Job {
|
|
|
private void computequota_34() {
|
|
|
String quotaId = "34";
|
|
|
try {
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.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";
|
|
|
String sql="select fr.sign_code code,fr.hospital,fr.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);
|
|
|
//清洗數據
|