日志追加

src/main/java/com/sundata/internalevaluation/calc/calcUnit/DataSetCalcUnit.java

@@ -125,6 +125,7 @@ public class DataSetCalcUnit extends CalcUnit {
     @Override
     public void calc(final CalcResult<String, Object> thisResult, String calculateInstanceNumber,Map<String, Object> context, Map<CalcUnit, CalcResult<String, Object>> sourceResults) {
 
+        log.info("当前计算节点为：[{}-{}-{}]，计算流水号为：{}", this.getCalcType(), this.getCalcCode(), this.getCalcName(), calculateInstanceNumber);
         // TODO 实际的计算过程
         // 合并后结果集
         Map<String,Object> resultMap = new HashMap<>();

src/main/java/com/sundata/internalevaluation/calc/calcUnit/DataSourcesCalcUnit.java

@@ -11,6 +11,8 @@ import com.sundata.internalevaluation.configuration.model.SysInterface;
 import com.sundata.internalevaluation.configuration.service.DataSourcesService;
 import com.sundata.internalevaluation.configuration.service.SysInterfaceService;
 import com.sundata.internalevaluation.script.TemplateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -28,6 +30,8 @@ import java.util.stream.Collectors;
 
 public class DataSourcesCalcUnit extends CalcUnit {
 
+    private static final Logger log = LoggerFactory.getLogger(DataSourcesCalcUnit.class);
+
     final DataSourcesModel dataSourcesModel;
 
     /**
@@ -135,7 +139,7 @@ public class DataSourcesCalcUnit extends CalcUnit {
      */
     @Override
     public  void calc(CalcResult<String, Object> thisResult, String calculateInstanceNumber, Map<String, Object> context, Map<CalcUnit, CalcResult<String, Object>> sourceResults) {
-
+        log.info("当前计算节点为：[{}-{}-{}]，计算流水号为：{}", this.getCalcType(), this.getCalcCode(), this.getCalcName(), calculateInstanceNumber);
         sourceResults.forEach((calcUnit,result)->{
 
             if ("INTERFACE".equals(dataSourcesModel.getDataSourcesType())) {

src/main/java/com/sundata/internalevaluation/calc/calcUnit/IndexCalcUnit.java

@@ -163,6 +163,8 @@ public class IndexCalcUnit extends CalcUnit {
     @Override
     public void calc(final CalcResult<String, Object> thisResult, String calculateInstanceNumber, Map<String, Object> context, Map<CalcUnit, CalcResult<String, Object>> sourceResults) {
 
+        //
+        log.info("当前计算节点为：[{}-{}-{}]，计算流水号为：{}", this.getCalcType(), this.getCalcCode(), this.getCalcName(), calculateInstanceNumber);
         // TODO 实际的计算过程
         // 记录数据集出现次数
         AtomicInteger dataSetNumber = new AtomicInteger();

src/main/java/com/sundata/internalevaluation/calc/calcUnit/QueryLogicCalcUnit.java

@@ -99,6 +99,7 @@ public class QueryLogicCalcUnit extends CalcUnit {
      */
     @Override
     public void calc(CalcResult<String, Object> thisResult, String calculateInstanceNumber, Map<String, Object> context, Map<CalcUnit, CalcResult<String, Object>> sourceResults) {
+        log.info("当前计算节点为：[{}-{}-{}]，计算流水号为：{}", this.getCalcType(), this.getCalcCode(), this.getCalcName(), calculateInstanceNumber);
         // 取得查询逻辑脚本
         String sqlTemplate = this.queryLogicModel.getSelectSqlScript();
         // 执行模板