Commit 1e8a0e77 by liyanlin

fix

parent b17fbc15
...@@ -18,7 +18,6 @@ import lombok.extern.slf4j.Slf4j; ...@@ -18,7 +18,6 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
...@@ -58,13 +57,13 @@ public class SyncEbayFeeServiceImpl implements SyncEbayFeeService { ...@@ -58,13 +57,13 @@ public class SyncEbayFeeServiceImpl implements SyncEbayFeeService {
@Override @Override
public void SyncEbayTransaction() { public void SyncEbayTransaction() {
//获取未跑或失败的任务 //获取未跑或失败的任务
/*List<EbayAccountReportTask> ebayAccountReportTaskList = ebayAccountReportTaskService.list( List<EbayAccountReportTask> ebayAccountReportTaskList = ebayAccountReportTaskService.list(
new LambdaQueryWrapper<EbayAccountReportTask>() new LambdaQueryWrapper<EbayAccountReportTask>()
.ne(EbayAccountReportTask::getStatus, 1) .ne(EbayAccountReportTask::getStatus, 1)
);*/ );
List<EbayAccountReportTask> ebayAccountReportTaskList = ebayAccountReportTaskService.list(new LambdaQueryWrapper<EbayAccountReportTask>() /*List<EbayAccountReportTask> ebayAccountReportTaskList = ebayAccountReportTaskService.list(new LambdaQueryWrapper<EbayAccountReportTask>()
.ge(EbayAccountReportTask::getStartTime, LocalDateTime.of(2021, 6, 28, 0, 0, 0)) .ge(EbayAccountReportTask::getStartTime, LocalDateTime.of(2021, 7, 7, 0, 0, 0))
.lt(EbayAccountReportTask::getStartTime, LocalDateTime.of(2021, 7, 8, 0, 0, 0))); .lt(EbayAccountReportTask::getStartTime, LocalDateTime.of(2021, 7, 13, 0, 0, 0)));*/
//获取账号信息 //获取账号信息
List<Integer> accountIdList = ebayAccountReportTaskList.stream().map(x -> x.getAccountId()).distinct().collect(Collectors.toList()); List<Integer> accountIdList = ebayAccountReportTaskList.stream().map(x -> x.getAccountId()).distinct().collect(Collectors.toList());
List<DcBaseCompanyAccount> accountList = dcBaseCompanyAccountService.list( List<DcBaseCompanyAccount> accountList = dcBaseCompanyAccountService.list(
......
...@@ -119,7 +119,7 @@ public class BalanceSheetJob { ...@@ -119,7 +119,7 @@ public class BalanceSheetJob {
/** /**
* 每周六日获取物流供应商往来数据 * 每周六日获取物流供应商往来数据
*/ */
@Scheduled(cron = "0 0 2 ? 1-12 1,7 *") @Scheduled(cron = "0 0 2 ? 1-12 1,7")
public void syncLogisticsSupplierTransaction() { public void syncLogisticsSupplierTransaction() {
try { try {
log.info("每周六日 获取物流供应商往来数据 开始"); log.info("每周六日 获取物流供应商往来数据 开始");
......
...@@ -498,6 +498,9 @@ public class BalanceSheetService { ...@@ -498,6 +498,9 @@ public class BalanceSheetService {
//取供应商往来数据:应付账款和预付账款 //取供应商往来数据:应付账款和预付账款
getSupplierTransaction(date); getSupplierTransaction(date);
//获取半成品在途
getSemiTransferAmount(date);
//货品库存 //货品库存
dcInventoryBalanceMapper.insertInventoryBalance(date); dcInventoryBalanceMapper.insertInventoryBalance(date);
//货品调拨在途 //货品调拨在途
...@@ -1017,9 +1020,7 @@ public class BalanceSheetService { ...@@ -1017,9 +1020,7 @@ public class BalanceSheetService {
* 获取半成品在途 * 获取半成品在途
*/ */
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void getSemiTransferAmount(){ public void getSemiTransferAmount(LocalDate start){
DcJobConfig dcJobConfig = dcJobConfigMapper.selectByName(baseSyncSemiTransfer);
LocalDate start = dcJobConfig.getStartTime().toLocalDate();
boolean isOk = true; boolean isOk = true;
int page = 1; int page = 1;
int row = 4000; int row = 4000;
......
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