diff --git a/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java b/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java index 13af4519..5f2873d0 100644 --- a/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java +++ b/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java @@ -3,7 +3,6 @@ package com.qs.serve.modules.bir.mapper; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.annotation.InterceptorIgnore; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.qs.serve.common.model.consts.DSName; import com.qs.serve.modules.bir.entity.BirActivityCenterGoods; import com.qs.serve.modules.bir.entity.so.BirMonthCusCenterSo; import com.qs.serve.modules.bir.entity.vo.BirActivityCenterGoodsMonthVo; @@ -20,7 +19,7 @@ import java.util.List; * @author YenHex * @date 2023-07-06 */ -@DS(DSName.QiSheng) +@DS("erp_stand_ds") public interface BirActivityCenterGoodsMapper extends BaseMapper { //List selectErrorBir(); diff --git a/src/main/java/com/qs/serve/modules/bir/mapper/BirBaseActivityMapper.java b/src/main/java/com/qs/serve/modules/bir/mapper/BirBaseActivityMapper.java index d107cce7..5fad4d28 100644 --- a/src/main/java/com/qs/serve/modules/bir/mapper/BirBaseActivityMapper.java +++ b/src/main/java/com/qs/serve/modules/bir/mapper/BirBaseActivityMapper.java @@ -3,7 +3,6 @@ package com.qs.serve.modules.bir.mapper; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.annotation.InterceptorIgnore; import com.baomidou.mybatisplus.core.mapper.BaseMapper; -import com.qs.serve.common.model.consts.DSName; import com.qs.serve.modules.bir.entity.BirBaseActivity; import com.qs.serve.modules.bir.entity.dto.UnMatchBirRecord; import com.qs.serve.modules.tbs.entity.TbsActivity; @@ -18,7 +17,7 @@ import java.util.List; * @author YenHex * @date 2023-06-05 */ -@DS(DSName.QiSheng) +@DS("erp_stand_ds") public interface BirBaseActivityMapper extends BaseMapper { //List selectByBirActivity(@Param("startDate") LocalDate startDate, @Param("endDate")LocalDate endDate); diff --git a/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java b/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java index 8dd77066..63badd5d 100644 --- a/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java @@ -4,7 +4,10 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.qs.serve.common.model.dto.DateSplitDTO; -import com.qs.serve.common.util.*; +import com.qs.serve.common.util.Assert; +import com.qs.serve.common.util.CollectionUtil; +import com.qs.serve.common.util.DateSplitUtil; +import com.qs.serve.common.util.PageUtil; import com.qs.serve.modules.bir.entity.BirBaseActivity; import com.qs.serve.modules.bir.entity.BirRemoveId; import com.qs.serve.modules.bir.entity.dto.BirCenterGoodSplitDTO; @@ -23,7 +26,6 @@ import com.qs.serve.modules.bms.mapper.BmsRegion2Mapper; import com.qs.serve.modules.bms.mapper.BmsRegionMapper; import com.qs.serve.modules.bms.mapper.BmsSupplierMapper; import com.qs.serve.modules.tbs.common.TbsActivityState; -import com.qs.serve.modules.tbs.common.TbsCostApplyState; import com.qs.serve.modules.tbs.entity.TbsActivity; import com.qs.serve.modules.tbs.entity.TbsActivityCenter; import com.qs.serve.modules.tbs.entity.TbsActivityCenterGoods; @@ -83,37 +85,6 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl costApplyIds) { - //不占预算的状态,进行清理 - List tbsCostApplyList = tbsCostApplyMapper.selectBatchIds(costApplyIds); - List rmIds = new ArrayList<>(); - List buildIds = new ArrayList<>(); - for (TbsCostApply costApply : tbsCostApplyList) { - if(costApply.getCancelFlag().equals(1)){ - rmIds.add(costApply.getId()); - continue; - } - Boolean useBudget = TbsCostApplyState.checkUseBudget(costApply.getChargeState()); - if(useBudget!=null){ - if(useBudget){ - buildIds.add(costApply.getId()); - }else { - rmIds.add(costApply.getId()); - } - } - } - //移除历史记录 - if(rmIds.size()>0){ - LambdaQueryWrapper rmCostId = new LambdaQueryWrapper<>(); - rmCostId.in(BirActivityCenterGoods::getCostApplyId,rmIds); - this.remove(rmCostId); - } - - - //过滤需要移除的ID - costApplyIds = buildIds; - if(CollectionUtil.isEmpty(costApplyIds)){ - return; - } //刷新BirBaseActivity for (Long costApplyId : costApplyIds) { @@ -162,11 +133,6 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl rmActId = new LambdaQueryWrapper<>(); - rmActId.eq(BirActivityCenterGoods::getActivityId,activityId); - this.remove(rmActId); - TbsActivity activity = activityMapper.selectById(activityId); if(activity==null||activity.getCancelFlag().equals(1)){ continue; @@ -208,12 +174,8 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl0){ -// this.saveBatch(bacgList); -// } - for (BirActivityCenterGoods bir : bacgList) { - bir.setId(IdUtil.getSnowFlakeId()); - super.getBaseMapper().insert(bir); + if(bacgList.size()>0){ + this.saveBatch(bacgList); } } } diff --git a/src/main/java/com/qs/serve/modules/bir/service/impl/BirBaseActivityServiceImpl.java b/src/main/java/com/qs/serve/modules/bir/service/impl/BirBaseActivityServiceImpl.java index c64a4fa4..8900f35d 100644 --- a/src/main/java/com/qs/serve/modules/bir/service/impl/BirBaseActivityServiceImpl.java +++ b/src/main/java/com/qs/serve/modules/bir/service/impl/BirBaseActivityServiceImpl.java @@ -6,7 +6,6 @@ import com.qs.serve.common.model.dto.DateSplitDTO; import com.qs.serve.common.util.Assert; import com.qs.serve.common.util.CollectionUtil; import com.qs.serve.common.util.DateSplitUtil; -import com.qs.serve.common.util.IdUtil; import com.qs.serve.modules.bir.entity.dto.UnMatchBirRecord; import com.qs.serve.modules.sys.mapper.SysUserMapper; import com.qs.serve.modules.tbs.entity.TbsActivity; @@ -174,11 +173,7 @@ public class BirBaseActivityServiceImpl extends ServiceImpl