Commit fff5b9a9 by yong

update

parent 8b30b3fb
...@@ -5,6 +5,7 @@ import com.bailuntec.domain.constant.EbaySkuMappingRoot; ...@@ -5,6 +5,7 @@ import com.bailuntec.domain.constant.EbaySkuMappingRoot;
import com.bailuntec.domain.dto.DcBaseFinanceEbayItemDto; import com.bailuntec.domain.dto.DcBaseFinanceEbayItemDto;
import com.bailuntec.domain.entity.*; import com.bailuntec.domain.entity.*;
import com.bailuntec.domain.example.DcBaseFinanceEbayExample; import com.bailuntec.domain.example.DcBaseFinanceEbayExample;
import com.bailuntec.domain.example.DcBaseFinanceEbayItemExample;
import com.bailuntec.mapper.DcBaseFinanceEbayItemMapper; import com.bailuntec.mapper.DcBaseFinanceEbayItemMapper;
import com.bailuntec.mapper.DcBaseFinanceEbayMapper; import com.bailuntec.mapper.DcBaseFinanceEbayMapper;
import com.bailuntec.support.PointJob; import com.bailuntec.support.PointJob;
...@@ -34,6 +35,8 @@ public class CalculateEbayItemJob extends PointJob { ...@@ -34,6 +35,8 @@ public class CalculateEbayItemJob extends PointJob {
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) { public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
long countEbayFee; long countEbayFee;
try{ try{
DcBaseFinanceEbayItemMapper dcBaseFinanceEbayItemMapper = SessionUtil.getSession().getMapper(DcBaseFinanceEbayItemMapper.class);
dcBaseFinanceEbayItemMapper.deleteByExample(DcBaseFinanceEbayItemExample.newAndCreateCriteria().andBjDateGreaterThanOrEqualTo(jobPointLog.getStartTime()).andBjDateLessThan(jobPointLog.getEndTime()).example());
DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper = SessionUtil.getSession().getMapper(DcBaseFinanceEbayMapper.class); DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper = SessionUtil.getSession().getMapper(DcBaseFinanceEbayMapper.class);
if (StringUtils.isBlank(shardingContext.getJobParameter())) { if (StringUtils.isBlank(shardingContext.getJobParameter())) {
countEbayFee = dcBaseFinanceEbayMapper.countByExample(DcBaseFinanceEbayExample.newAndCreateCriteria().andBjDateGreaterThanOrEqualTo(jobPointLog.getStartTime()).andBjDateLessThan(jobPointLog.getEndTime()).example()); countEbayFee = dcBaseFinanceEbayMapper.countByExample(DcBaseFinanceEbayExample.newAndCreateCriteria().andBjDateGreaterThanOrEqualTo(jobPointLog.getStartTime()).andBjDateLessThan(jobPointLog.getEndTime()).example());
...@@ -58,9 +61,11 @@ public class CalculateEbayItemJob extends PointJob { ...@@ -58,9 +61,11 @@ public class CalculateEbayItemJob extends PointJob {
if(StringUtils.isBlank(shardingContext.getJobParameter())){ if(StringUtils.isBlank(shardingContext.getJobParameter())){
dcBaseFinanceEbayItemDtoList = dcBaseFinanceEbayMapper.selectEbayList(jobPointLog); dcBaseFinanceEbayItemDtoList = dcBaseFinanceEbayMapper.selectEbayList(jobPointLog);
}else{ }else{
if(jobPointLog.getType() != 0) {
}
jobPointLog.setType(Integer.parseInt(shardingContext.getJobParameter())); jobPointLog.setType(Integer.parseInt(shardingContext.getJobParameter()));
dcBaseFinanceEbayItemDtoList = dcBaseFinanceEbayMapper.selectEbayList1(jobPointLog); dcBaseFinanceEbayItemDtoList = dcBaseFinanceEbayMapper.selectEbayList1(jobPointLog);
jobPointLog.setType(0);
} }
for(DcBaseFinanceEbayItemDto dcBaseFinanceEbayItemDto : dcBaseFinanceEbayItemDtoList) { for(DcBaseFinanceEbayItemDto dcBaseFinanceEbayItemDto : dcBaseFinanceEbayItemDtoList) {
......
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