diff --git a/shuili-system/src/main/java/com/kms/yg/xgxd/domain/AttDpdsBase.java b/shuili-system/src/main/java/com/kms/yg/xgxd/domain/AttDpdsBase.java index 675fc58d..c955613a 100644 --- a/shuili-system/src/main/java/com/kms/yg/xgxd/domain/AttDpdsBase.java +++ b/shuili-system/src/main/java/com/kms/yg/xgxd/domain/AttDpdsBase.java @@ -58,22 +58,22 @@ public class AttDpdsBase extends BaseEntity /** 出险数量 */ @Excel(name = "出险数量") @ApiModelProperty("出险数量") - private String dangNum; + private Integer dangNum; /** $column.columnComment */ @Excel(name = "出险数量") @ApiModelProperty("出险数量") - private String dpdsStarNum; + private Integer dpdsStarNum; /** 桩号 */ @Excel(name = "桩号") @ApiModelProperty("桩号") - private String dpdsEndNum; + private Integer dpdsEndNum; /** 长度 */ @Excel(name = "长度") @ApiModelProperty("长度") - private String dpdsLen; + private Integer dpdsLen; /** $column.columnComment */ @Excel(name = "长度") diff --git a/shuili-system/src/main/java/com/kms/yxgh/common/controller/JobController.java b/shuili-system/src/main/java/com/kms/yxgh/common/controller/JobController.java index 4c7203ce..4df43209 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/common/controller/JobController.java +++ b/shuili-system/src/main/java/com/kms/yxgh/common/controller/JobController.java @@ -20,7 +20,7 @@ public class JobController { /** * 同步基础数据 */ - @GetMapping("/") + @GetMapping("/base") public void syncBasicData() { CompletableFuture.runAsync(dataSyncJob::run); } diff --git a/shuili-system/src/main/java/com/kms/yxgh/common/job/DataSyncJob.java b/shuili-system/src/main/java/com/kms/yxgh/common/job/DataSyncJob.java index 62d4a7f6..af7540c3 100644 --- a/shuili-system/src/main/java/com/kms/yxgh/common/job/DataSyncJob.java +++ b/shuili-system/src/main/java/com/kms/yxgh/common/job/DataSyncJob.java @@ -22,9 +22,7 @@ import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; -import java.util.concurrent.CompletableFuture; import java.util.concurrent.Executor; -import java.util.concurrent.Future; import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -66,12 +64,8 @@ public class DataSyncJob { for (RelCacheEnum relCacheEnum : RelCacheEnum.values()) { relCache(relCacheEnum); } - List> allFuture = new ArrayList<>(); for (DataSyncBasicEnum dataSyncStatusEnum : DataSyncBasicEnum.values()) { - allFuture.add(CompletableFuture.runAsync(() -> syncData(dataSyncStatusEnum), syncDataPool)); - } - if (!allFuture.isEmpty()) { - CompletableFuture.allOf(allFuture.toArray(new CompletableFuture[0])).join(); + syncData(dataSyncStatusEnum); } } } @@ -244,6 +238,11 @@ public class DataSyncJob { } } + public static void main(String[] args) { + String a = ""; + System.out.printf("" + Optional.ofNullable(a).filter(StringUtils::isNotBlank).map(Integer::valueOf).orElse(2)); + } + private BigDecimal convertToBigDecimal(JSONObject obj, String fieldName) { try { return StringUtils.isNotBlank(obj.getString(fieldName)) ? new BigDecimal(obj.getString(fieldName)) : new BigDecimal(0);