Skip to content

I
indicators
Commit 2895233b by hzc
Options

修改对标运算时出现null异常（日志id没传，导致null

parent daea8d23
Showing with 18 additions and 14 deletions
src/main/java/com/keymobile/indicators/akka/actor/indicators/BeforeCompareUnitCalActor.java
...@@ -97,6 +97,8 @@ public class BeforeCompareUnitCalActor extends AbstractActor{ ...@@ -97,6 +97,8 @@ public class BeforeCompareUnitCalActor extends AbstractActor{
//计算同期对标单元 //计算同期对标单元
StartCompareUnitCalMsg startCompareUnitCalMsg = new StartCompareUnitCalMsg( StartCompareUnitCalMsg startCompareUnitCalMsg = new StartCompareUnitCalMsg(
currentCompareUnitDef,code,isTest); currentCompareUnitDef,code,isTest);
startCompareUnitCalMsg.setCompCalLogId(compCalLogId);
ActorRef startCompareUnitCalActor = this.getContext().actorOf(Props.create( ActorRef startCompareUnitCalActor = this.getContext().actorOf(Props.create(
StartCompareUnitCalActor.class,()-> new StartCompareUnitCalActor(getSelf()))); StartCompareUnitCalActor.class,()-> new StartCompareUnitCalActor(getSelf())));
startCompareUnitCalActor.tell(startCompareUnitCalMsg, getSelf()); startCompareUnitCalActor.tell(startCompareUnitCalMsg, getSelf());
......
src/main/java/com/keymobile/indicators/akka/actor/indicators/DriveIndIdObjCalActor.java
...@@ -182,22 +182,24 @@ public class DriveIndIdObjCalActor extends AbstractActor{ ...@@ -182,22 +182,24 @@ public class DriveIndIdObjCalActor extends AbstractActor{
"errorValue:"+indValue+";"+"paramEnv:"+env); "errorValue:"+indValue+";"+"paramEnv:"+env);
//日志记录 //日志记录
//运算失败 //运算失败
compCalLog.setStatus(0); if(compCalLog!=null){
String logInfo = compCalLog.getLogInfo(); compCalLog.setStatus(0);
if(StringUtils.isNotBlank(logInfo)) { String logInfo = compCalLog.getLogInfo();
logInfo+="替换公式值出错：driveIndId:"+driveIndId+";"+ if(StringUtils.isNotBlank(logInfo)) {
"formula:"+driveIndFormula+";"+ logInfo+="替换公式值出错：driveIndId:"+driveIndId+";"+
"errorValue:"+indValue+";"+"paramEnv:"+env+"</n>"; "formula:"+driveIndFormula+";"+
compCalLog.setLogInfo(logInfo); "errorValue:"+indValue+";"+"paramEnv:"+env+"</n>";
}else { compCalLog.setLogInfo(logInfo);
compCalLog.setLogInfo("替换公式值出错：driveIndId:"+driveIndId+";"+ }else {
"formula:"+driveIndFormula+";"+ compCalLog.setLogInfo("替换公式值出错：driveIndId:"+driveIndId+";"+
"errorValue:"+indValue+";"+"paramEnv:"+env+"</n>"); "formula:"+driveIndFormula+";"+
} "errorValue:"+indValue+";"+"paramEnv:"+env+"</n>");
//保存日志 }
if(compCalLog!=null) { //保存日志
compareUnitCalLogService.saveOrUndate(compCalLog); compareUnitCalLogService.saveOrUndate(compCalLog);
} }
} }
confirmList.add(baseIndValueMsg.getIsFinish()); confirmList.add(baseIndValueMsg.getIsFinish());
if (++numberOfConfirm >= indIdSize) {//子actor全部返回 if (++numberOfConfirm >= indIdSize) {//子actor全部返回
......
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