Skip to content

I
indicators
Commit 3fb0df06 by zhangkb
Options

计算报表3数据添加同步锁

parent 7d2301bf
Showing with 5 additions and 3 deletions
src/main/java/com/keymobile/indicators/akka/actor/indicators/BeforeCompareUnitCalActor.java
...@@ -130,9 +130,11 @@ public class BeforeCompareUnitCalActor extends AbstractActor{ ...@@ -130,9 +130,11 @@ public class BeforeCompareUnitCalActor extends AbstractActor{
indicatorsReportService.deleteReportThreeDataByParam(currentDate, indicatorsReportService.deleteReportThreeDataByParam(currentDate,
new ArrayList<String>(compareObjMap.keySet()),code); new ArrayList<String>(compareObjMap.keySet()),code);
for(CompareUnitDef unitDef : currentCompareUnitDef) { for(CompareUnitDef unitDef : currentCompareUnitDef) {
indicatorsReportService.dealDriveIndReportThreeData( synchronized(this){
unitDef.getCompareId(), Arrays.asList(unitDef.getIndIds().split(",")), indicatorsReportService.dealDriveIndReportThreeData(
unitDef.getDate(),code); unitDef.getCompareId(), Arrays.asList(unitDef.getIndIds().split(",")),
unitDef.getDate(),code);
}
} }
} }
if("0".equals(isTest)) { if("0".equals(isTest)) {
......
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