|
|
@@ -0,0 +1,392 @@
|
|
|
+package com.zhongzheng.modules.top.distribution.service.impl;
|
|
|
+
|
|
|
+import cn.hutool.core.bean.BeanUtil;
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.github.pagehelper.Page;
|
|
|
+import com.zhongzheng.common.core.domain.entity.SysRole;
|
|
|
+import com.zhongzheng.common.core.domain.entity.TopSysUser;
|
|
|
+import com.zhongzheng.common.exception.CustomException;
|
|
|
+import com.zhongzheng.common.utils.DateUtils;
|
|
|
+import com.zhongzheng.modules.distribution.vo.DistributionSellerVo;
|
|
|
+import com.zhongzheng.modules.top.distribution.bo.DistributionActivityTemplateAddBo;
|
|
|
+import com.zhongzheng.modules.top.distribution.bo.DistributionActivityTemplateEditBo;
|
|
|
+import com.zhongzheng.modules.top.distribution.bo.DistributionActivityTemplateQueryBo;
|
|
|
+import com.zhongzheng.modules.distribution.bo.DistributionStatusEditBo;
|
|
|
+import com.zhongzheng.modules.distribution.domain.*;
|
|
|
+import com.zhongzheng.modules.top.distribution.bo.DistributionSellerQuery;
|
|
|
+import com.zhongzheng.modules.top.distribution.mapper.DistributionActivityTempMapper;
|
|
|
+import com.zhongzheng.modules.distribution.service.*;
|
|
|
+import com.zhongzheng.modules.top.distribution.vo.DistributionActivityTemplateGoodsVo;
|
|
|
+import com.zhongzheng.modules.top.distribution.vo.DistributionActivityTemplateVo;
|
|
|
+import com.zhongzheng.modules.top.distribution.vo.DistributionActivityTenantVo;
|
|
|
+import com.zhongzheng.modules.goods.domain.Goods;
|
|
|
+import com.zhongzheng.modules.goods.service.IGoodsService;
|
|
|
+import com.zhongzheng.modules.inform.bo.InformSysUserAddBo;
|
|
|
+import com.zhongzheng.modules.inform.service.IInformRemindService;
|
|
|
+import com.zhongzheng.modules.inform.service.IInformSysUserService;
|
|
|
+import com.zhongzheng.modules.inform.vo.InformRemindVo;
|
|
|
+import com.zhongzheng.modules.system.domain.SysTenant;
|
|
|
+import com.zhongzheng.modules.system.domain.SysUserRole;
|
|
|
+import com.zhongzheng.modules.system.service.ISysRoleService;
|
|
|
+import com.zhongzheng.modules.system.service.ISysTenantService;
|
|
|
+import com.zhongzheng.modules.system.service.ISysUserRoleService;
|
|
|
+import com.zhongzheng.modules.top.distribution.domain.DistributionActivityTemplate;
|
|
|
+import com.zhongzheng.modules.top.distribution.domain.DistributionActivityTemplateGoods;
|
|
|
+import com.zhongzheng.modules.top.distribution.domain.DistributionActivityTemplatePoster;
|
|
|
+import com.zhongzheng.modules.top.distribution.domain.DistributionActivityTemplateRelation;
|
|
|
+import com.zhongzheng.modules.top.distribution.service.IDistributionActivityTemplateGoodsService;
|
|
|
+import com.zhongzheng.modules.top.distribution.service.IDistributionActivityTemplatePosterService;
|
|
|
+import com.zhongzheng.modules.top.distribution.service.IDistributionActivityTemplateRelationService;
|
|
|
+import com.zhongzheng.modules.top.distribution.service.IDistributionActivityTemplateService;
|
|
|
+import com.zhongzheng.modules.top.goods.domain.TopGoods;
|
|
|
+import com.zhongzheng.modules.top.goods.service.ITopGoodsService;
|
|
|
+import com.zhongzheng.modules.top.user.service.ITopSysUserService;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.Collection;
|
|
|
+import java.util.List;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 【请填写功能名称】Service业务层处理
|
|
|
+ *
|
|
|
+ * @author ruoyi
|
|
|
+ * @date 2023-03-06
|
|
|
+ */
|
|
|
+@Service
|
|
|
+public class DistributionActivityTemplateServiceImpl extends ServiceImpl<DistributionActivityTempMapper, DistributionActivityTemplate> implements IDistributionActivityTemplateService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityTemplateRelationService iDistributionActivityTemplateRelationService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityTemplateGoodsService iDistributionActivityTemplateGoodsService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityTemplatePosterService iDistributionActivityTemplatePosterService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityService iDistributionActivityService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityPosterService iDistributionActivityPosterService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionActivityGoodsService iDistributionActivityGoodsService;
|
|
|
+ @Autowired
|
|
|
+ private ISysTenantService iSysTenantService;
|
|
|
+ @Autowired
|
|
|
+ private ITopGoodsService iTopGoodsService;
|
|
|
+ @Autowired
|
|
|
+ private IGoodsService iGoodsService;
|
|
|
+ @Autowired
|
|
|
+ private ISysRoleService iSysRoleService;
|
|
|
+ @Autowired
|
|
|
+ private ISysUserRoleService iSysUserRoleService;
|
|
|
+ @Autowired
|
|
|
+ private IInformSysUserService iInformSysUserService;
|
|
|
+ @Autowired
|
|
|
+ private IInformRemindService informRemindService;
|
|
|
+ @Autowired
|
|
|
+ private ITopSysUserService iTopSysUserService;
|
|
|
+ @Autowired
|
|
|
+ private IDistributionSellerService iDistributionSellerService;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public DistributionActivityTemplateVo queryById(Long id){
|
|
|
+ DistributionActivityTemplate db = this.baseMapper.selectById(id);
|
|
|
+ DistributionActivityTemplateVo vo = BeanUtil.toBean(db, DistributionActivityTemplateVo.class);
|
|
|
+ //获取商品和机构信息
|
|
|
+ List<DistributionActivityTemplateRelation> relationList = iDistributionActivityTemplateRelationService
|
|
|
+ .list(new LambdaQueryWrapper<DistributionActivityTemplateRelation>()
|
|
|
+ .eq(DistributionActivityTemplateRelation::getStatus,1)
|
|
|
+ .eq(DistributionActivityTemplateRelation::getDistributionTempId, vo.getId()));
|
|
|
+ if (CollectionUtils.isNotEmpty(relationList)){
|
|
|
+ if (relationList.size() == 1 && relationList.get(0).getTenantId() == 0){
|
|
|
+ //全部企业
|
|
|
+ vo.setIsAllOrg(1);
|
|
|
+ }else {
|
|
|
+ //切数据源
|
|
|
+ List<DistributionActivityTenantVo> activityTenantVos = relationList.stream().map(item -> {
|
|
|
+ SysTenant tenant = iSysTenantService.getById(item.getTenantId());
|
|
|
+ DistributionActivityTenantVo tenantVo = new DistributionActivityTenantVo();
|
|
|
+ tenantVo.setTenantId(tenant.getTenantId());
|
|
|
+ tenantVo.setTenantName(tenant.getTenantName());
|
|
|
+ tenantVo.setAddress(tenant.getAddress());
|
|
|
+ tenantVo.setStatus(tenant.getStatus());
|
|
|
+ return tenantVo;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ vo.setTenantList(activityTenantVos);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ List<DistributionActivityTemplateGoods> templateGoodsList = iDistributionActivityTemplateGoodsService
|
|
|
+ .list(new LambdaQueryWrapper<DistributionActivityTemplateGoods>()
|
|
|
+ .eq(DistributionActivityTemplateGoods::getStatus, 1)
|
|
|
+ .eq(DistributionActivityTemplateGoods::getDistributionTempId, vo.getId()));
|
|
|
+ if (CollectionUtils.isNotEmpty(templateGoodsList)){
|
|
|
+ List<DistributionActivityTemplateGoodsVo> templateGoodsVos = templateGoodsList.stream().map(item -> {
|
|
|
+ DistributionActivityTemplateGoodsVo goodsVo = BeanUtil.toBean(item, DistributionActivityTemplateGoodsVo.class);
|
|
|
+ TopGoods topGoods = iTopGoodsService.getById(goodsVo.getGoodsId());
|
|
|
+ goodsVo.setGoodsName(topGoods.getGoodsName());
|
|
|
+ goodsVo.setGoodsPrice(topGoods.getStandPrice());
|
|
|
+ return goodsVo;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ vo.setGoodsList(templateGoodsVos);
|
|
|
+ }
|
|
|
+ return vo;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ 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());
|
|
|
+ List<DistributionActivityTemplateVo> voList = entity2Vo(this.list(lqw));
|
|
|
+ if (CollectionUtils.isEmpty(voList)){
|
|
|
+ return new ArrayList<>();
|
|
|
+ }
|
|
|
+ voList.forEach(item -> {
|
|
|
+ DistributionActivityTemplatePoster templatePoster = iDistributionActivityTemplatePosterService.getById(item.getPosterTempId());
|
|
|
+ item.setPosterTempName(templatePoster.getName());
|
|
|
+ });
|
|
|
+ return voList;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 实体类转化成视图对象
|
|
|
+ *
|
|
|
+ * @param collection 实体类集合
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private List<DistributionActivityTemplateVo> entity2Vo(Collection<DistributionActivityTemplate> collection) {
|
|
|
+ List<DistributionActivityTemplateVo> voList = collection.stream()
|
|
|
+ .map(any -> BeanUtil.toBean(any, DistributionActivityTemplateVo.class))
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ if (collection instanceof Page) {
|
|
|
+ Page<DistributionActivityTemplate> page = (Page<DistributionActivityTemplate>)collection;
|
|
|
+ Page<DistributionActivityTemplateVo> pageVo = new Page<>();
|
|
|
+ BeanUtil.copyProperties(page,pageVo);
|
|
|
+ pageVo.addAll(voList);
|
|
|
+ voList = pageVo;
|
|
|
+ }
|
|
|
+ return voList;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+// @Transactional(rollbackFor = Exception.class)
|
|
|
+ public Boolean insertByAddBo(DistributionActivityTemplateAddBo bo) {
|
|
|
+ //活动模板基本信息
|
|
|
+ DistributionActivityTemplate add = BeanUtil.toBean(bo, DistributionActivityTemplate.class);
|
|
|
+ validEntityBeforeSave(add);
|
|
|
+ add.setCreateTime(DateUtils.getNowTime());
|
|
|
+ add.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ TopSysUser user = iTopSysUserService.getById(bo.getCreateTopSysUserId());
|
|
|
+ if (ObjectUtils.isNotNull(user)){
|
|
|
+ add.setCreateBy(user.getUserName());
|
|
|
+ }
|
|
|
+ this.save(add);
|
|
|
+ this.saveRelation(bo,add.getId());
|
|
|
+ if (ObjectUtils.isNotNull(bo.getPublishStatus()) && bo.getPublishStatus() == 1){
|
|
|
+ this.publishActivity(add.getId());
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ //添加关联信息
|
|
|
+ private void saveRelation(DistributionActivityTemplateAddBo bo, Long tempId){
|
|
|
+ //机构信息
|
|
|
+ if (ObjectUtils.isNotNull(bo.getIsAllOrg()) && bo.getIsAllOrg() == 1){
|
|
|
+ //发布所有机构
|
|
|
+ DistributionActivityTemplateRelation entity = new DistributionActivityTemplateRelation();
|
|
|
+ entity.setDistributionTempId(tempId);
|
|
|
+ entity.setTenantId(0L);
|
|
|
+ entity.setCreateTime(DateUtils.getNowTime());
|
|
|
+ entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ iDistributionActivityTemplateRelationService.save(entity);
|
|
|
+ }
|
|
|
+ if (CollectionUtils.isNotEmpty(bo.getTenantList())){
|
|
|
+ List<DistributionActivityTemplateRelation> entitys = bo.getTenantList().stream().map(tenant -> {
|
|
|
+ DistributionActivityTemplateRelation entity = new DistributionActivityTemplateRelation();
|
|
|
+ entity.setDistributionTempId(tempId);
|
|
|
+ entity.setTenantId(tenant.getTenantId());
|
|
|
+ entity.setCreateTime(DateUtils.getNowTime());
|
|
|
+ entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ return entity;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ iDistributionActivityTemplateRelationService.saveBatch(entitys);
|
|
|
+ }
|
|
|
+ //活动商品
|
|
|
+ if (CollectionUtils.isNotEmpty(bo.getGoodsList())){
|
|
|
+ List<DistributionActivityTemplateGoods> collect = bo.getGoodsList().stream().map(item -> {
|
|
|
+ DistributionActivityTemplateGoods entity = BeanUtil.toBean(item, DistributionActivityTemplateGoods.class);
|
|
|
+ entity.setDistributionTempId(tempId);
|
|
|
+ entity.setCreateTime(DateUtils.getNowTime());
|
|
|
+ entity.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ return entity;
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ iDistributionActivityTemplateGoodsService.saveBatch(collect);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public Boolean updateByEditBo(DistributionActivityTemplateEditBo bo) {
|
|
|
+ //校验
|
|
|
+ DistributionActivityTemplate activityTemp = getById(bo.getId());
|
|
|
+ if (activityTemp.getPublishStatus() == 1){
|
|
|
+ throw new CustomException("活动已发布,不能修改!");
|
|
|
+ }
|
|
|
+ DistributionActivityTemplate update = BeanUtil.toBean(bo, DistributionActivityTemplate.class);
|
|
|
+ validEntityBeforeSave(update);
|
|
|
+ update.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ this.updateById(update);
|
|
|
+ //删除活动商品和下发机构重新绑定
|
|
|
+ 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.setGoodsList(bo.getGoodsList());
|
|
|
+ addBo.setTenantList(bo.getTenantList());
|
|
|
+ this.saveRelation(addBo,bo.getId());
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 保存前的数据校验
|
|
|
+ *
|
|
|
+ * @param entity 实体类数据
|
|
|
+ */
|
|
|
+ private void validEntityBeforeSave(DistributionActivityTemplate entity){
|
|
|
+ //TODO 做一些数据校验,如唯一约束
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
|
|
+ if(isValid){
|
|
|
+ //TODO 做一些业务上的校验,判断是否需要校验
|
|
|
+ }
|
|
|
+ return this.removeByIds(ids);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean updateStatus(DistributionStatusEditBo bo) {
|
|
|
+ DistributionActivityTemplate template = getById(bo.getDistributionTemplateId());
|
|
|
+ if (ObjectUtils.isNull(template)){
|
|
|
+ throw new CustomException("活动模板吧存在,请检查!");
|
|
|
+ }
|
|
|
+ template.setStatus(bo.getStatus());
|
|
|
+ return updateById(template);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean publishActivity(Long templateId) {
|
|
|
+ DistributionActivityTemplate template = getById(templateId);
|
|
|
+ if (ObjectUtils.isNull(template)){
|
|
|
+ throw new CustomException("模板不存在,请检查!");
|
|
|
+ }
|
|
|
+ //商品信息
|
|
|
+ List<DistributionActivityTemplateGoods> goodsList = iDistributionActivityTemplateGoodsService
|
|
|
+ .list(new LambdaQueryWrapper<DistributionActivityTemplateGoods>()
|
|
|
+ .eq(DistributionActivityTemplateGoods::getDistributionTempId, templateId));
|
|
|
+ if (CollectionUtils.isEmpty(goodsList)){
|
|
|
+ throw new CustomException("模板商品信息为空,请检查!");
|
|
|
+ }
|
|
|
+ //机构信息
|
|
|
+ List<DistributionActivityTemplateRelation> relationList = iDistributionActivityTemplateRelationService
|
|
|
+ .list(new LambdaQueryWrapper<DistributionActivityTemplateRelation>()
|
|
|
+ .eq(DistributionActivityTemplateRelation::getDistributionTempId, templateId)
|
|
|
+ .eq(DistributionActivityTemplateRelation::getStatus,1));
|
|
|
+ if (CollectionUtils.isEmpty(relationList)) {
|
|
|
+ throw new CustomException("指定机构信息为空,请检查!");
|
|
|
+ }
|
|
|
+ List<Long> tenantId = new ArrayList<>();
|
|
|
+ if (relationList.stream().anyMatch(item -> item.getTenantId() == 0L)){
|
|
|
+ //全部机构
|
|
|
+ List<SysTenant> list = iSysTenantService.list(new LambdaQueryWrapper<SysTenant>().eq(SysTenant::getStatus, 1));
|
|
|
+ tenantId = list.stream().map(SysTenant::getTenantId).collect(Collectors.toList());
|
|
|
+ }else {
|
|
|
+ tenantId = relationList.stream().map(DistributionActivityTemplateRelation::getTenantId).collect(Collectors.toList());
|
|
|
+ }
|
|
|
+
|
|
|
+ tenantId.forEach(id -> {
|
|
|
+ //同步活动信息
|
|
|
+ DistributionActivityTemplatePoster templatePoster = iDistributionActivityTemplatePosterService.getById(template.getPosterTempId());
|
|
|
+ DistributionActivityPoster poster = BeanUtil.toBean(templatePoster, DistributionActivityPoster.class);
|
|
|
+ poster.setUrl(templatePoster.getPosterUrl());
|
|
|
+ poster.setTenantId(id);
|
|
|
+ iDistributionActivityPosterService.save(poster);
|
|
|
+ DistributionActivity dailyActivity = BeanUtil.toBean(template, DistributionActivity.class);
|
|
|
+ dailyActivity.setPosterId(poster.getPosterId());
|
|
|
+ dailyActivity.setTempId(template.getId());
|
|
|
+ dailyActivity.setTenantId(id);
|
|
|
+ dailyActivity.setUseStatus(0);
|
|
|
+ iDistributionActivityService.save(dailyActivity);
|
|
|
+ //商品
|
|
|
+ List<DistributionActivityGoods> activityGoodsList = new ArrayList<>();
|
|
|
+ goodsList.forEach(item -> {
|
|
|
+ TopGoods topGoods = iTopGoodsService.getById(item.getGoodsId());
|
|
|
+ Goods goods = iGoodsService.getOne(new LambdaQueryWrapper<Goods>()
|
|
|
+ .eq(Goods::getCode, topGoods.getCode())
|
|
|
+ .eq(Goods::getTenantId,id)
|
|
|
+ .eq(Goods::getStatus, 1).last("limit 1"));
|
|
|
+ if (ObjectUtils.isNotNull(goods)){
|
|
|
+ DistributionActivityGoods activityGoods = BeanUtil.toBean(item, DistributionActivityGoods.class);
|
|
|
+ activityGoods.setId(null);
|
|
|
+ activityGoods.setGoodsId(goods.getGoodsId());
|
|
|
+ activityGoods.setTenantId(id);
|
|
|
+ activityGoods.setDistributionId(dailyActivity.getDistributionId());
|
|
|
+ activityGoodsList.add(activityGoods);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ iDistributionActivityGoodsService.saveBatch(activityGoodsList);
|
|
|
+
|
|
|
+ //站内信通知业务员管理员 seller_admin
|
|
|
+ SysRole role = iSysRoleService.getOne(new LambdaQueryWrapper<SysRole>()
|
|
|
+ .eq(SysRole::getRoleKey, "seller_admin")
|
|
|
+ .eq(SysRole::getTenantId,id)
|
|
|
+ .eq(SysRole::getStatus, 1).last("limit 1"));
|
|
|
+ if (ObjectUtils.isNotNull(role)){
|
|
|
+ List<SysUserRole> sysUserRoles = iSysUserRoleService.list(new LambdaQueryWrapper<SysUserRole>()
|
|
|
+ .eq(SysUserRole::getRoleId, role.getRoleId())
|
|
|
+ .eq(SysUserRole::getTenantId, id));
|
|
|
+ InformRemindVo informRemindVo = informRemindService.queryByName("课程试卷未做完7天提醒");
|
|
|
+ if (CollectionUtils.isNotEmpty(sysUserRoles) && ObjectUtils.isNotNull(informRemindVo)){
|
|
|
+ sysUserRoles.forEach(item -> {
|
|
|
+ InformSysUserAddBo informUserAddBo = new InformSysUserAddBo();
|
|
|
+ informUserAddBo.setUserId(item.getUserId());
|
|
|
+ informUserAddBo.setSendStatus(1);
|
|
|
+ informUserAddBo.setSendTime(DateUtils.getNowTime());
|
|
|
+ informUserAddBo.setCreateTime(DateUtils.getNowTime());
|
|
|
+ informUserAddBo.setUpdateTime(DateUtils.getNowTime());
|
|
|
+ informUserAddBo.setSystemStatus(1);
|
|
|
+ informUserAddBo.setRemindId(informRemindVo.getId());
|
|
|
+ informUserAddBo.setPlanId(dailyActivity.getDistributionId());
|
|
|
+ informUserAddBo.setRemind("分销活动提醒");
|
|
|
+ informUserAddBo.setText("有新的分销活动,请查看!");
|
|
|
+ iInformSysUserService.insertByAddBo(informUserAddBo);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+ template.setPublishStatus(1);
|
|
|
+ return updateById(template);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<DistributionSellerVo> sellerList(DistributionSellerQuery query) {
|
|
|
+ return iDistributionSellerService.getSellerListByTenant(query);
|
|
|
+ }
|
|
|
+}
|