modify some codes

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<List<TianQingFileVO>> request(String timeRang, Map<String, Object> params) throws JsonProcessingException {
+    public TianQingResponse<List<TianQingFileVO>> request(String timeRang, Map<String, Object> 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<List<TianQingFileVO>> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {});
             if (tianQingResponse.getReturnCode() == 0){
-                results.put(timeRang, tianQingResponse);
+                synchronized (this){
+                    results.putIfAbsent(timeRang, tianQingResponse);
+                }
                 return tianQingResponse;
             }
 

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<List<TianQingFileVO>> request(String timeRang, Map<String, Object> params) throws JsonProcessingException {
+    public TianQingResponse<List<TianQingFileVO>> request(String timeRang, Map<String, Object> 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<List<TianQingFileVO>> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {});
             if (tianQingResponse.getReturnCode() == 0){
-                results.put(timeRang, tianQingResponse);
+                synchronized (this){
+                    results.putIfAbsent(timeRang, tianQingResponse);
+                }
                 return tianQingResponse;
             }
 

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<List<TianQingFileVO>> request(String timeRang, Map<String, Object> params) throws JsonProcessingException {
+    public TianQingResponse<List<TianQingFileVO>> request(String timeRang, Map<String, Object> 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<List<TianQingFileVO>> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {});
             if (tianQingResponse.getReturnCode() == 0){
-                results.put(timeRang, tianQingResponse);
+                synchronized (this){
+                    results.putIfAbsent(timeRang, tianQingResponse);
+                }
                 return tianQingResponse;
             }
 

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<List<TianQingFileVO>> request(String timeRang, Map<String, Object> params) throws JsonProcessingException {
+    public TianQingResponse<List<TianQingFileVO>> request(String timeRang, Map<String, Object> 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<List<TianQingFileVO>> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {});
             if (tianQingResponse.getReturnCode() == 0){
-                results.put(timeRang, tianQingResponse);
+                synchronized (this){
+                    results.putIfAbsent(timeRang, tianQingResponse);
+                }
                 return tianQingResponse;
             }
 

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<List<TianQingFileVO>> request(String timeRang, Map<String, Object> params) throws JsonProcessingException {
+    public TianQingResponse<List<TianQingFileVO>> request(String timeRang, Map<String, Object> 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<List<TianQingFileVO>> tianQingResponse = objectMapper.readValue(result, new TypeReference<>() {});
             if (tianQingResponse.getReturnCode() == 0){
-                results.put(timeRang, tianQingResponse);
+                synchronized (this){
+                    results.putIfAbsent(timeRang, tianQingResponse);
+                }
                 return tianQingResponse;
             }