From 90c90397114a802010cff19b5704abaf078e829e Mon Sep 17 00:00:00 2001 From: xiaowuler Date: Tue, 22 Mar 2022 10:16:22 +0800 Subject: [PATCH] modify some codes --- .../xxljobexecutor/jobhandler/TianQingCLDASDataHandler.java | 6 ++++-- .../xxljobexecutor/jobhandler/TianQingCMPADataHandler.java | 6 ++++-- .../xxljobexecutor/jobhandler/TianQingRadarDataHandler.java | 6 ++++-- .../xxljobexecutor/jobhandler/TianQingSCMOCDataHandler.java | 6 ++++-- .../xxljobexecutor/jobhandler/TianQingSPCCDataHandler.java | 6 ++++-- 5 files changed, 20 insertions(+), 10 deletions(-) diff --git a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCLDASDataHandler.java b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCLDASDataHandler.java index 4f5e798..d670278 100644 --- a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCLDASDataHandler.java +++ b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCLDASDataHandler.java @@ -96,7 +96,7 @@ public class TianQingCLDASDataHandler { XxlJobHelper.log("read job end"); } - public synchronized TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { + public TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { if (results.containsKey(timeRang)){ return results.get(timeRang); } @@ -108,7 +108,9 @@ public class TianQingCLDASDataHandler { String result = WebUtil.get(applicationCommon.getUrl(), params); TianQingResponse> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {}); if (tianQingResponse.getReturnCode() == 0){ - results.put(timeRang, tianQingResponse); + synchronized (this){ + results.putIfAbsent(timeRang, tianQingResponse); + } return tianQingResponse; } diff --git a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCMPADataHandler.java b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCMPADataHandler.java index 211eb03..a557801 100644 --- a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCMPADataHandler.java +++ b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingCMPADataHandler.java @@ -91,7 +91,7 @@ public class TianQingCMPADataHandler { XxlJobHelper.log("read job end"); } - public synchronized TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { + public TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { if (results.containsKey(timeRang)){ return results.get(timeRang); } @@ -103,7 +103,9 @@ public class TianQingCMPADataHandler { String result = WebUtil.get(applicationCommon.getUrl(), params); TianQingResponse> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {}); if (tianQingResponse.getReturnCode() == 0){ - results.put(timeRang, tianQingResponse); + synchronized (this){ + results.putIfAbsent(timeRang, tianQingResponse); + } return tianQingResponse; } diff --git a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingRadarDataHandler.java b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingRadarDataHandler.java index 939c565..0e84043 100644 --- a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingRadarDataHandler.java +++ b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingRadarDataHandler.java @@ -94,7 +94,7 @@ public class TianQingRadarDataHandler { XxlJobHelper.log("read job end"); } - public synchronized TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { + public TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { if (results.containsKey(timeRang)){ return results.get(timeRang); } @@ -106,7 +106,9 @@ public class TianQingRadarDataHandler { String result = WebUtil.get(applicationCommon.getUrl(), params); TianQingResponse> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {}); if (tianQingResponse.getReturnCode() == 0){ - results.put(timeRang, tianQingResponse); + synchronized (this){ + results.putIfAbsent(timeRang, tianQingResponse); + } return tianQingResponse; } diff --git a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSCMOCDataHandler.java b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSCMOCDataHandler.java index 7bbc34c..29dcaf6 100644 --- a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSCMOCDataHandler.java +++ b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSCMOCDataHandler.java @@ -96,7 +96,7 @@ public class TianQingSCMOCDataHandler { XxlJobHelper.log("read job end"); } - public synchronized TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { + public TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { if (results.containsKey(timeRang)){ return results.get(timeRang); } @@ -108,7 +108,9 @@ public class TianQingSCMOCDataHandler { String result = WebUtil.get(applicationCommon.getUrl(), params); TianQingResponse> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {}); if (tianQingResponse.getReturnCode() == 0){ - results.put(timeRang, tianQingResponse); + synchronized (this){ + results.putIfAbsent(timeRang, tianQingResponse); + } return tianQingResponse; } diff --git a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSPCCDataHandler.java b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSPCCDataHandler.java index 2f54d8c..0fe7a72 100644 --- a/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSPCCDataHandler.java +++ b/04.系统编码/01.xxl-job/xxl-job-executor/src/main/java/com/ping/chuan/ahpmsdp/xxljobexecutor/jobhandler/TianQingSPCCDataHandler.java @@ -96,7 +96,7 @@ public class TianQingSPCCDataHandler { XxlJobHelper.log("read job end"); } - public synchronized TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { + public TianQingResponse> request(String timeRang, Map params) throws JsonProcessingException { if (results.containsKey(timeRang)){ return results.get(timeRang); } @@ -108,7 +108,9 @@ public class TianQingSPCCDataHandler { String result = WebUtil.get(applicationCommon.getUrl(), params); TianQingResponse> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {}); if (tianQingResponse.getReturnCode() == 0){ - results.put(timeRang, tianQingResponse); + synchronized (this){ + results.putIfAbsent(timeRang, tianQingResponse); + } return tianQingResponse; }