| | |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.dy.common.mw.protocol.Data; |
|---|
| | | import com.dy.pipIrrGlobal.command.ComResultWait; |
|---|
| | | import com.dy.pipIrrGlobal.command.ComSupport; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.http.MediaType; |
|---|
| | |
|---|
| | | job_response.put("commandCode", job_data.getString("code")); |
|---|
| | | job_response.put("commandId", job_data.getString("commandId")); |
|---|
| | | |
|---|
| | | CompletableFuture<JSONObject> feature = (CompletableFuture<JSONObject>) features.get(job_data.getLong("commandId")); |
|---|
| | | CompletableFuture<JSONObject> feature = (CompletableFuture<JSONObject>) ComResultWait.get(job_data.getLong("commandId")); |
|---|
| | | if(feature != null) { |
|---|
| | | feature.complete(job_response); |
|---|
| | | }else{ |
|---|
| | | feature.complete(new JSONObject()); |
|---|
| | | } |
|---|
| | | }//else{ |
|---|
| | | // feature.complete(new JSONObject()); |
|---|
| | | //} |
|---|
| | | } |
|---|
| | | } |
|---|
