50 changed files with 1217 additions and 83 deletions
@ -0,0 +1,17 @@
|
||||
package com.logpm.trunkline.vo; |
||||
|
||||
import lombok.Data; |
||||
|
||||
import java.io.Serializable; |
||||
|
||||
@Data |
||||
public class ZeroSuppleVO implements Serializable { |
||||
|
||||
|
||||
private String waybillNo; |
||||
private String orderCode; |
||||
private Integer enterNum;//输入数量
|
||||
private Long finalNodeId;//目的仓id
|
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,74 @@
|
||||
package com.logpm.aftersales.config; |
||||
|
||||
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.beans.factory.annotation.Value; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
/** |
||||
* xxl-job config |
||||
* |
||||
* @author xuxueli 2017-04-28 |
||||
*/ |
||||
@Configuration(proxyBeanMethods = false) |
||||
public class XxlJobConfig { |
||||
private final Logger logger = LoggerFactory.getLogger(XxlJobConfig.class); |
||||
|
||||
@Value("${xxl.job.admin.addresses}") |
||||
private String adminAddresses; |
||||
|
||||
@Value("${xxl.job.executor.appname}") |
||||
private String appName; |
||||
|
||||
@Value("${xxl.job.executor.ip}") |
||||
private String ip; |
||||
|
||||
@Value("${xxl.job.executor.port}") |
||||
private int port; |
||||
|
||||
@Value("${xxl.job.accessToken}") |
||||
private String accessToken; |
||||
|
||||
@Value("${xxl.job.executor.logpath}") |
||||
private String logPath; |
||||
|
||||
@Value("${xxl.job.executor.logretentiondays}") |
||||
private int logRetentionDays; |
||||
|
||||
|
||||
@Bean |
||||
public XxlJobSpringExecutor xxlJobExecutor() { |
||||
logger.info(">>>>>>>>>>> xxl-job config init."); |
||||
XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); |
||||
xxlJobSpringExecutor.setAdminAddresses(adminAddresses); |
||||
xxlJobSpringExecutor.setAppName(appName); |
||||
xxlJobSpringExecutor.setIp(ip); |
||||
xxlJobSpringExecutor.setPort(port); |
||||
xxlJobSpringExecutor.setAccessToken(accessToken); |
||||
xxlJobSpringExecutor.setLogPath(logPath); |
||||
xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); |
||||
|
||||
return xxlJobSpringExecutor; |
||||
} |
||||
|
||||
/** |
||||
* 针对多网卡、容器内部署等情况，可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP； |
||||
* |
||||
* 1、引入依赖： |
||||
* <dependency> |
||||
* <groupId>org.springframework.cloud</groupId> |
||||
* <artifactId>spring-cloud-commons</artifactId> |
||||
* <version>${version}</version> |
||||
* </dependency> |
||||
* |
||||
* 2、配置文件，或者容器启动变量 |
||||
* spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.' |
||||
* |
||||
* 3、获取IP |
||||
* String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress(); |
||||
*/ |
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,36 @@
|
||||
package com.logpm.aftersales.jobhandler; |
||||
|
||||
import com.logpm.aftersales.service.IAftersalesWorkOrderService; |
||||
import com.xxl.job.core.biz.model.ReturnT; |
||||
import com.xxl.job.core.handler.annotation.XxlJob; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
/** |
||||
* @author 12702 |
||||
*/ |
||||
@AllArgsConstructor |
||||
@Component |
||||
public class AftersalesXxlJob { |
||||
private static final Logger logger = LoggerFactory.getLogger(AftersalesXxlJob.class); |
||||
|
||||
private final IAftersalesWorkOrderService aftersalesWorkOrderService; |
||||
|
||||
@XxlJob("syncWarehouseToNew") |
||||
public ReturnT<String> getIsItTimeout(String param) throws Exception { |
||||
logger.info("查询处理超时的数据>>>>>>>>{}",param); |
||||
aftersalesWorkOrderService.getIsItTimeout(); |
||||
return ReturnT.SUCCESS; |
||||
} |
||||
|
||||
@XxlJob("modifyClaimStatus") |
||||
public ReturnT<String> updateModifyClaimStatus(String param) throws Exception { |
||||
logger.info("修改理赔工单是否可以申述>>>>>>>>{}",param); |
||||
aftersalesWorkOrderService.updateModifyClaimStatus(); |
||||
return ReturnT.SUCCESS; |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue