|
|
|
@ -289,10 +289,10 @@ public class ABDownTask {
|
|
|
|
|
@Async(value = "abTaskExecutor")
|
|
|
|
|
public void doRunMohangTask(List<ABMessageDTO> messageDTOList){
|
|
|
|
|
Long satrtMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
|
|
|
|
|
log.info("====== [ task start running, task name is {} ] ======", "ABDownTask");
|
|
|
|
|
log.info("====== [ RunMohang task start running, task name is {} ] ======", "ABDownTask");
|
|
|
|
|
runMohangTask(messageDTOList);
|
|
|
|
|
Long endMilliSecond = LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli();
|
|
|
|
|
log.info("====== [ task start end, task name is {},cost milliSecond is {} ] ======", "ABDownTask", (endMilliSecond-satrtMilliSecond));
|
|
|
|
|
log.info("====== [ RunMohang task start end, task name is {},cost milliSecond is {} ] ======", "ABDownTask", (endMilliSecond-satrtMilliSecond));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
@ -346,7 +346,7 @@ public class ABDownTask {
|
|
|
|
|
mohangMessageCovDTO.setSignature(SecureUtil.sha1("app_id="+ mohangAppId +"×tamp="+ time + "&secret=" + mohangSecretKey));
|
|
|
|
|
// 数据实体转成Json 不忽略空kv 有序
|
|
|
|
|
String jsonStr = JSON.toJSONString(mohangMessageCovDTO);
|
|
|
|
|
log.info("========== [ready send json is {} ] =============", jsonStr);
|
|
|
|
|
log.info("========== [RunMohang ready send json is {} ] =============", jsonStr);
|
|
|
|
|
// 请求的响应处理
|
|
|
|
|
// todo 失败重发请求3次
|
|
|
|
|
while (count <= 3){
|
|
|
|
|