package com.zy.acs.manager.core.integrate.wms;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.TypeReference;
|
import com.zy.acs.framework.common.Cools;
|
import com.zy.acs.framework.common.R;
|
import com.zy.acs.framework.common.SnowflakeIdWorker;
|
import com.zy.acs.manager.common.config.UplinkProperties;
|
import com.zy.acs.manager.common.constant.Constants;
|
import com.zy.acs.manager.common.utils.HttpGo;
|
import com.zy.acs.manager.core.domain.type.NamespaceType;
|
import com.zy.acs.manager.core.integrate.dto.HttpResult;
|
import com.zy.acs.manager.core.integrate.dto.TaskUplinkParam;
|
import com.zy.acs.manager.core.service.ThreadPoolRegulator;
|
import com.zy.acs.manager.manager.entity.Bus;
|
import com.zy.acs.manager.manager.entity.IntegrationRecord;
|
import com.zy.acs.manager.manager.entity.Task;
|
import com.zy.acs.manager.manager.enums.IntegrationDirectionType;
|
import com.zy.acs.manager.manager.enums.StatusType;
|
import com.zy.acs.manager.manager.enums.TaskStsType;
|
import com.zy.acs.manager.manager.enums.TaskUplinkStateType;
|
import com.zy.acs.manager.manager.service.BusService;
|
import com.zy.acs.manager.manager.service.IntegrationRecordService;
|
import com.zy.acs.manager.manager.service.TaskService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import java.time.Duration;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.concurrent.CompletableFuture;
|
|
@Slf4j
|
@Service
|
public class TaskReportService {
|
|
@Autowired
|
private UplinkProperties uplinkProperties;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private ThreadPoolRegulator threadPoolRegulator;
|
@Autowired
|
private BusService busService;
|
@Autowired
|
private SnowflakeIdWorker snowflakeIdWorker;
|
@Autowired
|
private IntegrationRecordService integrationRecordService;
|
|
private HttpGo http;
|
|
@PostConstruct
|
public void init() {
|
int timeoutSeconds = uplinkProperties.getTimeout() / 1000;
|
this.http = HttpGo.builder()
|
.connectTimeout(Duration.ofSeconds(timeoutSeconds))
|
.readTimeout(Duration.ofSeconds(timeoutSeconds))
|
// .defaultHeader("User-Agent", "HttpGo/1.0")
|
// .trustAllSsl(true) // ONLY if you really need it (self-signed internal)
|
.build();
|
}
|
|
public boolean reportFinished(Task task) {
|
if (Cools.isEmpty(task)) {
|
return false;
|
}
|
if (!uplinkProperties.getEnabled()) {
|
return false;
|
}
|
if (!task.getTaskSts().equals(TaskStsType.COMPLETE.val())) {
|
return false;
|
}
|
TaskUplinkStateType uplinkStateType = TaskUplinkStateType.of(task.getUplinkSts());
|
if (!uplinkStateType.equals(TaskUplinkStateType.PENDING)
|
&& !uplinkStateType.equals(TaskUplinkStateType.SENDING)
|
&& !uplinkStateType.equals(TaskUplinkStateType.FAILED)
|
) {
|
return false;
|
}
|
Date now = new Date();
|
// block
|
// Future<R> future = threadPoolRegulator.getInstance().submit(() -> {
|
// mapDataDispatcher.modifyDynamicMatrix(null, null, param.getAgvNo(), true);
|
// return success();
|
// });
|
// System.out.println(JSON.toJSONString(future.get()));
|
|
// non-block
|
CompletableFuture<?> completableFuture = CompletableFuture.supplyAsync(() -> {
|
// mapDataDispatcher.modifyDynamicMatrix(null, null, param.getAgvNo(), true);
|
// avoidWaveCalculator.calcDynamicNodeByVehicle(agv, null);
|
return R.ok();
|
}, threadPoolRegulator.getInstance());
|
|
// url
|
String url = this.http.buildUrl(uplinkProperties.getHost(), uplinkProperties.getPort(), uplinkProperties.getUrl());
|
// headers
|
Map<String, String> headers = new HashMap<>();
|
// params
|
TaskUplinkParam param = new TaskUplinkParam();
|
if (null != task.getBusId()) {
|
Bus bus = busService.getById(task);
|
param.setBatchNo(bus.getBusNo());
|
}
|
param.setTaskNo(task.getSeqNum());
|
param.setTimestamp(null == task.getEndTime() ? System.currentTimeMillis() : task.getEndTime().getTime());
|
|
IntegrationRecord integrationRecord = new IntegrationRecord(
|
String.valueOf(snowflakeIdWorker.nextId()).substring(3), // 编号
|
NamespaceType.RCS_TASK_REPORT.name, // 名称空间
|
uplinkProperties.getUrl(), // 接口地址
|
null, // 平台密钥
|
Constants.RCS, // 调用方标识
|
IntegrationDirectionType.OUTBOUND.value, // 方向[非空]
|
String.valueOf(now.getTime()), // 时间戳
|
uplinkProperties.getHost(), // 客户端IP
|
JSON.toJSONString(param), // 请求内容
|
null, // 响应内容
|
null, // 异常内容
|
0, // 结果
|
null, // 耗时
|
StatusType.ENABLE.val, // 状态
|
now, // 添加时间[非空]
|
now, // 修改时间[非空]
|
null // 备注
|
);
|
HttpResult<?> result;
|
try {
|
result = postForResult(url, headers, param);
|
integrationRecord.setResponse(JSON.toJSONString(result));
|
|
Integer code = result.getCode();
|
if (null == code || 200 != code) {
|
return false;
|
}
|
// Object data = result.getData();
|
// if (Cools.isEmpty(data)) {
|
// return false;
|
// }
|
|
integrationRecord.setResult(1);
|
} catch (Exception e) {
|
log.error("Uplink report failed, taskId={}",
|
JSON.toJSONString(task),
|
e);
|
integrationRecord.setErr(e.getMessage());
|
return false;
|
} finally {
|
integrationRecord.setCostMs((int) (System.currentTimeMillis() - now.getTime()));
|
integrationRecordService.syncRecord(integrationRecord);
|
}
|
return true;
|
}
|
|
private HttpResult<?> postForResult(String url, Map<String, String> headers, TaskUplinkParam param) throws Exception {
|
String json = JSON.toJSONString(param);
|
HttpGo.HttpResponse response = this.http.postJson(url, headers, json);
|
|
int status = response.statusCode();
|
if (status != 200) {
|
throw new RuntimeException("Uplink HTTP error: status=" + status + ", body=" + response.body());
|
}
|
|
String body = response.body();
|
if (Cools.isEmpty(body)) {
|
throw new RuntimeException("Uplink empty response body.");
|
}
|
|
HttpResult<?> result = JSON.parseObject(body, new TypeReference<HttpResult<?>>() {});
|
if (result == null) {
|
throw new RuntimeException("Uplink parse HttpResult failed: body=" + body);
|
}
|
return result;
|
}
|
|
|
}
|
