package com.vincent.rsf.server.api.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.cfg.CoercionAction;
|
import com.fasterxml.jackson.databind.cfg.CoercionInputShape;
|
import com.vincent.rsf.server.api.config.RemotesInfoProperties;
|
import com.vincent.rsf.server.api.entity.CommonResponse;
|
import com.vincent.rsf.server.api.entity.constant.RcsConstant;
|
import com.vincent.rsf.server.api.service.RcsBusTaskNoticeService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/** 管理后台工作档完成/取消时通知 RCS */
|
@Slf4j
|
@Service
|
public class RcsBusTaskNoticeServiceImpl implements RcsBusTaskNoticeService {
|
|
@Autowired(required = false)
|
private RemotesInfoProperties.RcsApi rcsApi;
|
@Autowired(required = false)
|
private RestTemplate restTemplate;
|
|
@Override
|
public void notifyTaskStatus(String taskNo, Integer status) {
|
if (StringUtils.isBlank(taskNo) || status == null) {
|
return;
|
}
|
if (rcsApi == null || StringUtils.isBlank(rcsApi.getHost()) || StringUtils.isBlank(rcsApi.getPort())) {
|
log.debug("跳过 RCS 任务状态通知：未配置 platform.rcs");
|
return;
|
}
|
if (restTemplate == null) {
|
log.warn("跳过 RCS 任务状态通知：RestTemplate 未注入");
|
return;
|
}
|
String url = rcsApi.getHost() + ":" + rcsApi.getPort() + RcsConstant.TASK_STATUS_NOTICE;
|
Map<String, String> body = new HashMap<>(2);
|
body.put("taskNo", taskNo);
|
body.put("status", String.valueOf(status));
|
try {
|
HttpHeaders headers = new HttpHeaders();
|
headers.add("Content-Type", "application/json");
|
headers.add("api-version", "v2.0");
|
HttpEntity<Map<String, String>> entity = new HttpEntity<>(body, headers);
|
log.info("RCS 任务状态通知 POST {} body={}", url, JSONObject.toJSONString(body));
|
ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.POST, entity, String.class);
|
if (exchange.getBody() == null) {
|
log.warn("RCS 任务状态通知响应体为空 taskNo={}", taskNo);
|
return;
|
}
|
ObjectMapper om = new ObjectMapper();
|
om.coercionConfigDefaults().setCoercion(CoercionInputShape.EmptyString, CoercionAction.AsEmpty);
|
CommonResponse res = om.readValue(exchange.getBody(), CommonResponse.class);
|
if (res.getCode() != null && res.getCode() == 200) {
|
log.info("RCS 任务状态通知成功 taskNo={} status={}", taskNo, status);
|
} else {
|
log.warn("RCS 任务状态通知非成功 taskNo={} status={} code={} msg={}",
|
taskNo, status, res.getCode(), res.getMsg());
|
}
|
} catch (Exception e) {
|
log.warn("RCS 任务状态通知异常 taskNo={} status={}：{}", taskNo, status, e.getMessage());
|
}
|
}
|
}
|
