提交 d7f918bd authored 作者: 刘海泉's avatar 刘海泉

增加同步最后一车定时任务

上级 1a455c59
package com.clx.performance.job;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.clx.performance.constant.RedisConstants;
import com.clx.performance.dto.zjxl.TruckTraceDTO;
import com.clx.performance.service.LastTruckService;
import com.clx.performance.utils.LocalDateTimeUtils;
import com.clx.performance.utils.zjxl.ZjxlGpsService;
import com.clx.user.feign.UserClxFeign;
import com.msl.common.enums.ResultCodeEnum;
import com.msl.common.job.JobLog;
import com.msl.common.result.Result;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
@Slf4j
@Component
@AllArgsConstructor
public class SyncLastTruckJob {
private final LastTruckService lastTruckService;
/**
* 手动触发最后一车推送第三方平台
*/
@XxlJob("handExecSyncSmbLastTruck")
public void handExecSyncSmbLastTruck() {
try {
String jobParam= XxlJobHelper.getJobParam();
JSONObject jsonObject = JSON.parseObject(jobParam);
String orderNo = jsonObject.getString("orderNo");
String childNo = jsonObject.getString("childNo");
log.info("开始手动执行同步最后一车,订单号:{}.运单号:{}",orderNo,childNo);
Result<?> result = lastTruckService.handExecSyncSmbLastTruck(orderNo,childNo);
log.info("结束手动执行同步最后一车,订单号:{}.运单号:{},响应结果:{}",orderNo,childNo,result);
} catch (Exception e) {
log.warn("同步最后一车到第三方平台发生异常,异常原因:{}", ExceptionUtils.getStackTrace(e));
JobLog.error("同步最后一车到第三方平台发生异常,异常原因=====================", e);
}
}
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论