Skip to content

B
baihang-report
Commit 7354feb8 authored by 郝彦辉's avatar 郝彦辉
Browse files
Options

修改优化

parent db93dad1
Hide whitespace changes
Inline Side-by-side
Showing with 8 additions and 8 deletions
src/main/java/cn/quantgroup/report/job/SynLoanInfoHistoryTask.java
View file @ 7354feb8
......@@ -152,7 +152,7 @@ public class SynLoanInfoHistoryTask {
Integer count = xyqbHistoryJdbcTemplate.queryForObject(count_sql,Integer.class);
if(count==null){
log.error("表xyqb_i_loan_application_manifest_history查询增量count为Null.");
dingTalk.talk("Warn","同步[借款清单]数据失败","查询增量count为Null,请尽快处理!"+" bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Warn","同步[借款清单]数据失败","查询增量count为Null,请尽快处理!"+" bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
dingTalk.talk_ToUser("同步[借款清单]表查询增量count为Null,停止T+1报送！发现问题，请及时处理！");
return false;
}
......@@ -165,7 +165,7 @@ public class SynLoanInfoHistoryTask {
int update = xyqbHistoryJdbcTemplate.update(inset_sql);
log.info("增量同步xyqb_i_loan_application_manifest_history表结束, bakMaxId: {} , count: {} , 插入条数: {} , 耗时: {} ", bakMaxId, count, update, startwatch.stop().elapsed(TimeUnit.MILLISECONDS)+".ms");
dingTalk.talk("Info","同步[借款清单]数据成功","实际条数:"+update +", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Info","同步[借款清单]数据成功","实际条数: "+update +", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
return true;
}else{
//大于2万条会报事务太长，需要分页插入
......@@ -196,10 +196,10 @@ public class SynLoanInfoHistoryTask {
log.info("增量同步xyqb_i_loan_application_manifest_history表结束, bakMaxId: {} , newMaxId: {} , ID差: {} , count: {} , totalUpdate: {} , page: {} , mode: {} ", bakMaxId, newMaxId, (newMaxId-bakMaxId), count, totalUpdate, page, mode);
if(totalUpdate==count){
dingTalk.talk("Info","同步[借款清单]数据成功","实际条数(分页):"+totalUpdate+", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Info","同步[借款清单]数据成功","实际条数(分页): "+totalUpdate+", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
return true;
}else{
dingTalk.talk("Warn","同步[借款清单]数据失败","查询条数:"+count+",实际条数="+totalUpdate+", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Warn","同步[借款清单]数据失败","查询条数: "+count+",实际条数="+totalUpdate+", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
dingTalk.talk_ToUser("同步[借款清单]数据失败,停止T+1报送！发现问题，请及时处理！");
return false;
}
......@@ -214,7 +214,7 @@ public class SynLoanInfoHistoryTask {
Integer count = xyqbHistoryJdbcTemplate.queryForObject(count_sql,Integer.class);
if(count==null){
log.error("表xyqb_i_repayment_plan查询增量count为Null.");
dingTalk.talk("Warn","同步[还款计划]数据失败","查询增量count为Null,请尽快处理!" + ", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Warn","同步[还款计划]数据失败","查询增量count为Null,请尽快处理!" + ", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
dingTalk.talk_ToUser("同步[还款计划]表查询增量count为Null,停止T+1报送！发现问题，请及时处理！");
return false;
}
......@@ -227,7 +227,7 @@ public class SynLoanInfoHistoryTask {
int update = xyqbHistoryJdbcTemplate.update(inset_sql);
log.info("增量同步xyqb_i_repayment_plan表结束, bakMaxId: {} , count: {} , 插入条数: {} , 耗时: {} ", bakMaxId, count, update, startwatch.stop().elapsed(TimeUnit.MILLISECONDS)+".ms");
dingTalk.talk("Info","同步[还款计划]数据成功","实际条数:"+update +", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Info","同步[还款计划]数据成功","实际条数: "+update +", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
return true;
}else{
//大于2万条会报事务太长，需要分页插入
......@@ -261,10 +261,10 @@ public class SynLoanInfoHistoryTask {
log.info("增量同步xyqb_i_repayment_plan表结束, bakMaxId: {} , newMaxId: {} , ID差: {} , count: {} , totalUpdate: {} , page: {} , mode: {} ", bakMaxId, newMaxId, (newMaxId-bakMaxId), count, totalUpdate, page, mode);
if(totalUpdate==count){
dingTalk.talk("Info","同步[还款计划]数据成功","实际条数(分页):"+totalUpdate + ", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Info","同步[还款计划]数据成功","实际条数(分页): "+totalUpdate + ", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
return true;
}else{
dingTalk.talk("Warn","同步[还款计划]数据失败","查询条数:"+count+",实际条数="+totalUpdate + ", bakMaxId:"+bakMaxId+", newMaxId:"+newMaxId);
dingTalk.talk("Warn","同步[还款计划]数据失败","查询条数: "+count+",实际条数="+totalUpdate + ", bakMaxId: "+bakMaxId+", newMaxId: "+newMaxId);
dingTalk.talk_ToUser("同步[还款计划]数据失败,停止T+1报送！发现问题，请及时处理！");
return false;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment