| | |
| | | return true; |
| | | } |
| | | |
| | | private HttpResult<List<ConveyorStaDto>> postForResult(String url |
| | | , Map<String, String> headers, Map<String, Object> params) throws Exception { |
| | | private HttpResult<List<ConveyorStaDto>> postForResult(String url, Map<String, String> headers, Map<String, Object> params) throws Exception { |
| | | String json = JSON.toJSONString(params); |
| | | HttpGo.HttpResponse response = this.http.postJson(url, headers, json); |
| | | |
| | |
| | | } |
| | | |
| | | public boolean reportFinished(Task task) { |
| | | if (Cools.isEmpty(task)) { |
| | | return false; |
| | | } |
| | | if (!uplinkProperties.getEnabled()) { |
| | | return false; |
| | | } |
| | | // block |
| | | // Future<R> future = threadPoolRegulator.getInstance().submit(() -> { |
| | | // mapDataDispatcher.modifyDynamicMatrix(null, null, param.getAgvNo(), true); |
| | |
| | | return false; |
| | | } |
| | | } catch (Exception e) { |
| | | log.error(""); |
| | | log.error("Uplink report failed, taskId={}", |
| | | JSON.toJSONString(task), |
| | | e); |
| | | return false; |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | private HttpResult<?> postForResult(String url |
| | | , Map<String, String> headers, Map<String, Object> params) throws Exception { |
| | | private HttpResult<?> postForResult(String url, Map<String, String> headers, Map<String, Object> params) throws Exception { |
| | | String json = JSON.toJSONString(params); |
| | | HttpGo.HttpResponse response = this.http.postJson(url, headers, json); |
| | | |