|
@@ -10,17 +10,17 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.github.pagehelper.Page;
|
|
import com.github.pagehelper.Page;
|
|
|
import com.zhongzheng.common.exception.CustomException;
|
|
import com.zhongzheng.common.exception.CustomException;
|
|
|
import com.zhongzheng.common.utils.DateUtils;
|
|
import com.zhongzheng.common.utils.DateUtils;
|
|
|
-import com.zhongzheng.modules.distribution.bo.DistributionActivityTempAddBo;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.bo.DistributionActivityTempEditBo;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.bo.DistributionActivityTempQueryBo;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.domain.DistributionActivityTemp;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.domain.DistributionActivityTempGoods;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.domain.DistributionActivityTempRelation;
|
|
|
|
|
|
|
+import com.zhongzheng.modules.distribution.bo.DistributionActivityTemplateAddBo;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.bo.DistributionActivityTemplateEditBo;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.bo.DistributionActivityTemplateQueryBo;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.domain.DistributionActivityTemplate;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.domain.DistributionActivityTemplateGoods;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.domain.DistributionActivityTemplateRelation;
|
|
|
import com.zhongzheng.modules.distribution.mapper.DistributionActivityTempMapper;
|
|
import com.zhongzheng.modules.distribution.mapper.DistributionActivityTempMapper;
|
|
|
-import com.zhongzheng.modules.distribution.service.IDistributionActivityTempGoodsService;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.service.IDistributionActivityTempRelationService;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.service.IDistributionActivityTempService;
|
|
|
|
|
-import com.zhongzheng.modules.distribution.vo.DistributionActivityTempVo;
|
|
|
|
|
|
|
+import com.zhongzheng.modules.distribution.service.IDistributionActivityTemplateGoodsService;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.service.IDistributionActivityTemplateRelationService;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.service.IDistributionActivityTemplateService;
|
|
|
|
|
+import com.zhongzheng.modules.distribution.vo.DistributionActivityTemplateVo;
|
|
|
import com.zhongzheng.modules.system.service.ISysOldOrgService;
|
|
import com.zhongzheng.modules.system.service.ISysOldOrgService;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -37,23 +37,23 @@ import java.util.stream.Collectors;
|
|
|
* @date 2023-03-06
|
|
* @date 2023-03-06
|
|
|
*/
|
|
*/
|
|
|
@Service
|
|
@Service
|
|
|
-public class DistributionActivityTempServiceImpl extends ServiceImpl<DistributionActivityTempMapper, DistributionActivityTemp> implements IDistributionActivityTempService {
|
|
|
|
|
|
|
+public class DistributionActivityTemplateServiceImpl extends ServiceImpl<DistributionActivityTempMapper, DistributionActivityTemplate> implements IDistributionActivityTemplateService {
|
|
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
|
- private IDistributionActivityTempRelationService iDistributionActivityTempRelationService;
|
|
|
|
|
|
|
+ private IDistributionActivityTemplateRelationService iDistributionActivityTemplateRelationService;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
- private IDistributionActivityTempGoodsService iDistributionActivityTempGoodsService;
|
|
|
|
|
|
|
+ private IDistributionActivityTemplateGoodsService iDistributionActivityTemplateGoodsService;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private ISysOldOrgService iSysOldOrgService;
|
|
private ISysOldOrgService iSysOldOrgService;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public DistributionActivityTempVo queryById(Long id){
|
|
|
|
|
- DistributionActivityTemp db = this.baseMapper.selectById(id);
|
|
|
|
|
- DistributionActivityTempVo vo = BeanUtil.toBean(db, DistributionActivityTempVo.class);
|
|
|
|
|
|
|
+ public DistributionActivityTemplateVo queryById(Long id){
|
|
|
|
|
+ DistributionActivityTemplate db = this.baseMapper.selectById(id);
|
|
|
|
|
+ DistributionActivityTemplateVo vo = BeanUtil.toBean(db, DistributionActivityTemplateVo.class);
|
|
|
//获取商品和机构信息
|
|
//获取商品和机构信息
|
|
|
- List<DistributionActivityTempRelation> relationList = iDistributionActivityTempRelationService
|
|
|
|
|
- .list(new LambdaQueryWrapper<DistributionActivityTempRelation>()
|
|
|
|
|
- .eq(DistributionActivityTempRelation::getDistributionTempId, vo.getId()));
|
|
|
|
|
|
|
+ List<DistributionActivityTemplateRelation> relationList = iDistributionActivityTemplateRelationService
|
|
|
|
|
+ .list(new LambdaQueryWrapper<DistributionActivityTemplateRelation>()
|
|
|
|
|
+ .eq(DistributionActivityTemplateRelation::getDistributionTempId, vo.getId()));
|
|
|
// if (CollectionUtils.isNotEmpty(relationList)){
|
|
// if (CollectionUtils.isNotEmpty(relationList)){
|
|
|
// relationList.stream().map(item -> {
|
|
// relationList.stream().map(item -> {
|
|
|
// DistributionActivityTenantVo tenantVo = new DistributionActivityTenantVo();
|
|
// DistributionActivityTenantVo tenantVo = new DistributionActivityTenantVo();
|
|
@@ -65,15 +65,15 @@ public class DistributionActivityTempServiceImpl extends ServiceImpl<Distributio
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public List<DistributionActivityTempVo> queryList(DistributionActivityTempQueryBo bo) {
|
|
|
|
|
- LambdaQueryWrapper<DistributionActivityTemp> lqw = Wrappers.lambdaQuery();
|
|
|
|
|
- lqw.eq(StrUtil.isNotBlank(bo.getCode()), DistributionActivityTemp::getCode, bo.getCode());
|
|
|
|
|
- lqw.eq(bo.getType() != null, DistributionActivityTemp::getType, bo.getType());
|
|
|
|
|
- lqw.like(StrUtil.isNotBlank(bo.getName()), DistributionActivityTemp::getName, bo.getName());
|
|
|
|
|
- lqw.eq(bo.getStatus() != null, DistributionActivityTemp::getStatus, bo.getStatus());
|
|
|
|
|
- lqw.eq(bo.getPosterTempId() != null, DistributionActivityTemp::getPosterTempId, bo.getPosterTempId());
|
|
|
|
|
- lqw.eq(bo.getStartTime() != null, DistributionActivityTemp::getStartTime, bo.getStartTime());
|
|
|
|
|
- lqw.eq(bo.getEndTime() != null, DistributionActivityTemp::getEndTime, bo.getEndTime());
|
|
|
|
|
|
|
+ public List<DistributionActivityTemplateVo> queryList(DistributionActivityTemplateQueryBo bo) {
|
|
|
|
|
+ LambdaQueryWrapper<DistributionActivityTemplate> lqw = Wrappers.lambdaQuery();
|
|
|
|
|
+ lqw.eq(StrUtil.isNotBlank(bo.getCode()), DistributionActivityTemplate::getCode, bo.getCode());
|
|
|
|
|
+ lqw.eq(bo.getType() != null, DistributionActivityTemplate::getType, bo.getType());
|
|
|
|
|
+ lqw.like(StrUtil.isNotBlank(bo.getName()), DistributionActivityTemplate::getName, bo.getName());
|
|
|
|
|
+ lqw.eq(bo.getStatus() != null, DistributionActivityTemplate::getStatus, bo.getStatus());
|
|
|
|
|
+ lqw.eq(bo.getPosterTempId() != null, DistributionActivityTemplate::getPosterTempId, bo.getPosterTempId());
|
|
|
|
|
+ lqw.eq(bo.getStartTime() != null, DistributionActivityTemplate::getStartTime, bo.getStartTime());
|
|
|
|
|
+ lqw.eq(bo.getEndTime() != null, DistributionActivityTemplate::getEndTime, bo.getEndTime());
|
|
|
return entity2Vo(this.list(lqw));
|
|
return entity2Vo(this.list(lqw));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -83,13 +83,13 @@ public class DistributionActivityTempServiceImpl extends ServiceImpl<Distributio
|
|
|
* @param collection 实体类集合
|
|
* @param collection 实体类集合
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
- private List<DistributionActivityTempVo> entity2Vo(Collection<DistributionActivityTemp> collection) {
|
|
|
|
|
- List<DistributionActivityTempVo> voList = collection.stream()
|
|
|
|
|
- .map(any -> BeanUtil.toBean(any, DistributionActivityTempVo.class))
|
|
|
|
|
|
|
+ private List<DistributionActivityTemplateVo> entity2Vo(Collection<DistributionActivityTemplate> collection) {
|
|
|
|
|
+ List<DistributionActivityTemplateVo> voList = collection.stream()
|
|
|
|
|
+ .map(any -> BeanUtil.toBean(any, DistributionActivityTemplateVo.class))
|
|
|
.collect(Collectors.toList());
|
|
.collect(Collectors.toList());
|
|
|
if (collection instanceof Page) {
|
|
if (collection instanceof Page) {
|
|
|
- Page<DistributionActivityTemp> page = (Page<DistributionActivityTemp>)collection;
|
|
|
|
|
- Page<DistributionActivityTempVo> pageVo = new Page<>();
|
|
|
|
|
|
|
+ Page<DistributionActivityTemplate> page = (Page<DistributionActivityTemplate>)collection;
|
|
|
|
|
+ Page<DistributionActivityTemplateVo> pageVo = new Page<>();
|
|
|
BeanUtil.copyProperties(page,pageVo);
|
|
BeanUtil.copyProperties(page,pageVo);
|
|
|
pageVo.addAll(voList);
|
|
pageVo.addAll(voList);
|
|
|
voList = pageVo;
|
|
voList = pageVo;
|
|
@@ -99,9 +99,9 @@ public class DistributionActivityTempServiceImpl extends ServiceImpl<Distributio
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public Boolean insertByAddBo(DistributionActivityTempAddBo bo) {
|
|
|
|
|
|
|
+ public Boolean insertByAddBo(DistributionActivityTemplateAddBo bo) {
|
|
|
//活动模板基本信息
|
|
//活动模板基本信息
|
|
|
- DistributionActivityTemp add = BeanUtil.toBean(bo, DistributionActivityTemp.class);
|
|
|
|
|
|
|
+ DistributionActivityTemplate add = BeanUtil.toBean(bo, DistributionActivityTemplate.class);
|
|
|
validEntityBeforeSave(add);
|
|
validEntityBeforeSave(add);
|
|
|
add.setCreateTime(DateUtils.getNowTime());
|
|
add.setCreateTime(DateUtils.getNowTime());
|
|
|
add.setUpdateTime(DateUtils.getNowTime());
|
|
add.setUpdateTime(DateUtils.getNowTime());
|
|
@@ -111,60 +111,60 @@ public class DistributionActivityTempServiceImpl extends ServiceImpl<Distributio
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//添加关联信息
|
|
//添加关联信息
|
|
|
- private void saveRelation(DistributionActivityTempAddBo bo,Long tempId){
|
|
|
|
|
|
|
+ private void saveRelation(DistributionActivityTemplateAddBo bo, Long tempId){
|
|
|
//机构信息
|
|
//机构信息
|
|
|
if (ObjectUtils.isNotNull(bo.getIsAllOrg()) && bo.getIsAllOrg() == 1){
|
|
if (ObjectUtils.isNotNull(bo.getIsAllOrg()) && bo.getIsAllOrg() == 1){
|
|
|
//发布所有机构
|
|
//发布所有机构
|
|
|
- DistributionActivityTempRelation entity = new DistributionActivityTempRelation();
|
|
|
|
|
|
|
+ DistributionActivityTemplateRelation entity = new DistributionActivityTemplateRelation();
|
|
|
entity.setDistributionTempId(tempId);
|
|
entity.setDistributionTempId(tempId);
|
|
|
entity.setTenantId(0L);
|
|
entity.setTenantId(0L);
|
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
- iDistributionActivityTempRelationService.save(entity);
|
|
|
|
|
|
|
+ iDistributionActivityTemplateRelationService.save(entity);
|
|
|
}
|
|
}
|
|
|
if (CollectionUtils.isNotEmpty(bo.getTenantIds())){
|
|
if (CollectionUtils.isNotEmpty(bo.getTenantIds())){
|
|
|
- List<DistributionActivityTempRelation> entitys = bo.getTenantIds().stream().map(id -> {
|
|
|
|
|
- DistributionActivityTempRelation entity = new DistributionActivityTempRelation();
|
|
|
|
|
|
|
+ List<DistributionActivityTemplateRelation> entitys = bo.getTenantIds().stream().map(id -> {
|
|
|
|
|
+ DistributionActivityTemplateRelation entity = new DistributionActivityTemplateRelation();
|
|
|
entity.setDistributionTempId(tempId);
|
|
entity.setDistributionTempId(tempId);
|
|
|
entity.setTenantId(id);
|
|
entity.setTenantId(id);
|
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
return entity;
|
|
return entity;
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
- iDistributionActivityTempRelationService.saveBatch(entitys);
|
|
|
|
|
|
|
+ iDistributionActivityTemplateRelationService.saveBatch(entitys);
|
|
|
}
|
|
}
|
|
|
//活动商品
|
|
//活动商品
|
|
|
if (CollectionUtils.isNotEmpty(bo.getGoodsList())){
|
|
if (CollectionUtils.isNotEmpty(bo.getGoodsList())){
|
|
|
- List<DistributionActivityTempGoods> collect = bo.getGoodsList().stream().map(item -> {
|
|
|
|
|
- DistributionActivityTempGoods entity = BeanUtil.toBean(item, DistributionActivityTempGoods.class);
|
|
|
|
|
|
|
+ List<DistributionActivityTemplateGoods> collect = bo.getGoodsList().stream().map(item -> {
|
|
|
|
|
+ DistributionActivityTemplateGoods entity = BeanUtil.toBean(item, DistributionActivityTemplateGoods.class);
|
|
|
entity.setDistributionTempId(tempId);
|
|
entity.setDistributionTempId(tempId);
|
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
entity.setCreateTime(DateUtils.getNowTime());
|
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
return entity;
|
|
return entity;
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
- iDistributionActivityTempGoodsService.saveBatch(collect);
|
|
|
|
|
|
|
+ iDistributionActivityTemplateGoodsService.saveBatch(collect);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public Boolean updateByEditBo(DistributionActivityTempEditBo bo) {
|
|
|
|
|
|
|
+ public Boolean updateByEditBo(DistributionActivityTemplateEditBo bo) {
|
|
|
//校验
|
|
//校验
|
|
|
- DistributionActivityTemp activityTemp = getById(bo.getId());
|
|
|
|
|
|
|
+ DistributionActivityTemplate activityTemp = getById(bo.getId());
|
|
|
if (activityTemp.getPublishStatus() == 1){
|
|
if (activityTemp.getPublishStatus() == 1){
|
|
|
throw new CustomException("活动已发布,不能修改!");
|
|
throw new CustomException("活动已发布,不能修改!");
|
|
|
}
|
|
}
|
|
|
- DistributionActivityTemp update = BeanUtil.toBean(bo, DistributionActivityTemp.class);
|
|
|
|
|
|
|
+ DistributionActivityTemplate update = BeanUtil.toBean(bo, DistributionActivityTemplate.class);
|
|
|
validEntityBeforeSave(update);
|
|
validEntityBeforeSave(update);
|
|
|
update.setUpdateTime(DateUtils.getNowTime());
|
|
update.setUpdateTime(DateUtils.getNowTime());
|
|
|
this.updateById(update);
|
|
this.updateById(update);
|
|
|
//删除活动商品和下发机构重新绑定
|
|
//删除活动商品和下发机构重新绑定
|
|
|
- iDistributionActivityTempGoodsService.remove(new LambdaQueryWrapper<DistributionActivityTempGoods>()
|
|
|
|
|
- .eq(DistributionActivityTempGoods::getDistributionTempId,bo.getId()));
|
|
|
|
|
- iDistributionActivityTempRelationService.remove(new LambdaQueryWrapper<DistributionActivityTempRelation>()
|
|
|
|
|
- .eq(DistributionActivityTempRelation::getDistributionTempId,bo.getId()));
|
|
|
|
|
- DistributionActivityTempAddBo addBo = new DistributionActivityTempAddBo();
|
|
|
|
|
|
|
+ iDistributionActivityTemplateGoodsService.remove(new LambdaQueryWrapper<DistributionActivityTemplateGoods>()
|
|
|
|
|
+ .eq(DistributionActivityTemplateGoods::getDistributionTempId,bo.getId()));
|
|
|
|
|
+ iDistributionActivityTemplateRelationService.remove(new LambdaQueryWrapper<DistributionActivityTemplateRelation>()
|
|
|
|
|
+ .eq(DistributionActivityTemplateRelation::getDistributionTempId,bo.getId()));
|
|
|
|
|
+ DistributionActivityTemplateAddBo addBo = new DistributionActivityTemplateAddBo();
|
|
|
addBo.setIsAllOrg(bo.getIsAllOrg());
|
|
addBo.setIsAllOrg(bo.getIsAllOrg());
|
|
|
addBo.setGoodsList(bo.getGoodsList());
|
|
addBo.setGoodsList(bo.getGoodsList());
|
|
|
addBo.setTenantIds(bo.getTenantIds());
|
|
addBo.setTenantIds(bo.getTenantIds());
|
|
@@ -177,7 +177,7 @@ public class DistributionActivityTempServiceImpl extends ServiceImpl<Distributio
|
|
|
*
|
|
*
|
|
|
* @param entity 实体类数据
|
|
* @param entity 实体类数据
|
|
|
*/
|
|
*/
|
|
|
- private void validEntityBeforeSave(DistributionActivityTemp entity){
|
|
|
|
|
|
|
+ private void validEntityBeforeSave(DistributionActivityTemplate entity){
|
|
|
//TODO 做一些数据校验,如唯一约束
|
|
//TODO 做一些数据校验,如唯一约束
|
|
|
}
|
|
}
|
|
|
|
|
|