Commit 1b724ae2 by huluobin

# 更新

parent fbdd9c70
package com.bailuntec.job.service; package com.bailuntec.job.service;
import com.bailuntec.application.IDcBaseFinanceManagecostService;
import com.bailuntec.common.BeanUtils; import com.bailuntec.common.BeanUtils;
import com.bailuntec.common.ListUtil; import com.bailuntec.common.ListUtil;
import com.bailuntec.cost.api.CostApi; import com.bailuntec.cost.api.CostApi;
...@@ -52,6 +53,8 @@ public class SyncFeeService { ...@@ -52,6 +53,8 @@ public class SyncFeeService {
CostApi costApi; CostApi costApi;
@Resource @Resource
DcBaseFinanceManagecostMapper dcBaseFinanceManagecostMapper; DcBaseFinanceManagecostMapper dcBaseFinanceManagecostMapper;
@Resource
IDcBaseFinanceManagecostService dcBaseFinanceManagecostService;
@Transactional @Transactional
...@@ -117,19 +120,16 @@ public class SyncFeeService { ...@@ -117,19 +120,16 @@ public class SyncFeeService {
//同步 //同步
result.getData().forEach(manageCostDto -> { result.getData().forEach(manageCostDto -> {
DcBaseFinanceManagecost dcBaseFinanceManagecost = new DcBaseFinanceManagecost();
DcBaseFinanceManagecost dcBaseFinanceManagecost = dcBaseFinanceManagecostMapper.selectOne(new LambdaQueryWrapper<DcBaseFinanceManagecost>()
.eq(DcBaseFinanceManagecost::getNo, manageCostDto.getNo()));
if (dcBaseFinanceManagecost == null) {
dcBaseFinanceManagecost = new DcBaseFinanceManagecost();
}
BeanUtils.copyProperties(manageCostDto, dcBaseFinanceManagecost, "id"); BeanUtils.copyProperties(manageCostDto, dcBaseFinanceManagecost, "id");
dcBaseFinanceManagecost.setGmtModifyTime(LocalDateTime.now()); dcBaseFinanceManagecost.setGmtModifyTime(LocalDateTime.now());
dcBaseFinanceManagecost.setPayTime(manageCostDto.getPayTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); dcBaseFinanceManagecost.setPayTime(manageCostDto.getPayTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
dcBaseFinanceManagecostService.saveOrUpdate(dcBaseFinanceManagecost);
int update = dcBaseFinanceManagecostMapper.update(dcBaseFinanceManagecost, new LambdaQueryWrapper<DcBaseFinanceManagecost>()
.eq(DcBaseFinanceManagecost::getNo, dcBaseFinanceManagecost.getNo())
.eq(DcBaseFinanceManagecost::getCostId1, dcBaseFinanceManagecost.getCostId1())
.eq(DcBaseFinanceManagecost::getCostId, dcBaseFinanceManagecost.getCostId()));
if (update == 0) {
dcBaseFinanceManagecostMapper.insert(dcBaseFinanceManagecost);
}
log.info("同步一条管理成本,costNo:{}", manageCostDto.getCostId()); log.info("同步一条管理成本,costNo:{}", manageCostDto.getCostId());
}); });
......
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