Commit 180a01f4 by huluobin

# update

parent 83534c5d
......@@ -58,6 +58,11 @@
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-batch</artifactId>
</dependency>
<!--mysql-->
<dependency>
<groupId>mysql</groupId>
......
package com.bailuntec.job;
import com.bailuntec.job.service.EbayService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@Slf4j
@Component
public class EbayJob {
@Resource
EbayService ebayService;
@Scheduled(cron = "0 0/1 * * * ?")
public void baseSyncFinanceFee() {
try {
log.info("每分钟同步费用单 开始");
ebayService.sync();
log.info("每分钟同步费用单 结束");
} catch (Exception ex) {
log.error("每分钟同步费用单 异常:", ex);
}
}
}
package com.bailuntec.job.service;
import com.bailuntec.domain.DcJobConfig;
import com.bailuntec.domain.JobAmazonAdLog;
import com.bailuntec.infrastructure.mapper.DcJobConfigMapper;
import com.bailuntec.infrastructure.mapper.JobAmazonAdLogMapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import feign.FeignException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* <p>
*
* </p>
*
* @author robbendev
* @since 2020/10/7 11:38 上午
*/
@Slf4j
@Service
public class EbayService {
private final static String baseSyncFinanceEbayAd = "base-sync-finance-ebay-ad";
@Resource
DcJobConfigMapper dcJobConfigMapper;
@Resource
JobAmazonAdLogMapper jobAmazonAdLogMapper;
public void sync() {
DcJobConfig dcJobConfig = dcJobConfigMapper.selectByName(baseSyncFinanceEbayAd);
List<JobAmazonAdLog> jobAmazonAdLogList = jobAmazonAdLogMapper.selectList(new LambdaQueryWrapper<JobAmazonAdLog>()
.eq(JobAmazonAdLog::getStatus, false));
dcJobConfigMapper.updateById(dcJobConfig.refresh());
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment