|
@@ -23,19 +23,19 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import vip.xiaonuo.auth.core.util.StpLoginUserUtil;
|
|
|
+import vip.xiaonuo.biz.modular.org.entity.BizOrg;
|
|
|
+import vip.xiaonuo.biz.modular.org.mapper.BizOrgMapper;
|
|
|
import vip.xiaonuo.common.exception.CommonException;
|
|
|
import vip.xiaonuo.common.listener.CommonDataChangeEventCenter;
|
|
|
import vip.xiaonuo.common.page.CommonPageRequest;
|
|
|
import vip.xiaonuo.core.enums.BaseDataTypeEnum;
|
|
|
import vip.xiaonuo.modular.base.baseConfig.entity.BaseConfig;
|
|
|
import vip.xiaonuo.modular.base.baseConfig.mapper.BaseConfigMapper;
|
|
|
-import vip.xiaonuo.modular.base.baseConfig.param.BaseConfigAddParam;
|
|
|
-import vip.xiaonuo.modular.base.baseConfig.param.BaseConfigEditParam;
|
|
|
-import vip.xiaonuo.modular.base.baseConfig.param.BaseConfigIdParam;
|
|
|
-import vip.xiaonuo.modular.base.baseConfig.param.BaseConfigListChildParam;
|
|
|
+import vip.xiaonuo.modular.base.baseConfig.param.*;
|
|
|
import vip.xiaonuo.modular.base.baseConfig.service.BaseConfigService;
|
|
|
|
|
|
import javax.validation.constraints.NotBlank;
|
|
@@ -51,10 +51,12 @@ import java.util.stream.Collectors;
|
|
|
**/
|
|
|
@Service
|
|
|
public class BaseConfigServiceImpl extends ServiceImpl<BaseConfigMapper, BaseConfig> implements BaseConfigService {
|
|
|
+ @Autowired
|
|
|
+ private BizOrgMapper bizOrgMapper;
|
|
|
|
|
|
@Override
|
|
|
- public List<Tree<String>> tree() {
|
|
|
- String orgId = StpLoginUserUtil.getLoginUser().getOrgId();
|
|
|
+ public List<Tree<String>> tree(BaseConfigOrgIdParam baseConfigOrgIdParam) {
|
|
|
+ String orgId = baseConfigOrgIdParam.getOrgId();
|
|
|
List<BaseConfig> allConfigs = new ArrayList<>();
|
|
|
List<BaseConfig> baseConfigs = this.list(new LambdaQueryWrapper<BaseConfig>().eq(BaseConfig::getParentId, 0).orderByAsc(BaseConfig::getSortCode));
|
|
|
List<BaseConfig> childConfigs = this.list(new LambdaQueryWrapper<BaseConfig>().eq(BaseConfig::getOrgId, orgId).orderByAsc(BaseConfig::getSortCode));
|
|
@@ -72,13 +74,13 @@ public class BaseConfigServiceImpl extends ServiceImpl<BaseConfigMapper, BaseCon
|
|
|
@Override
|
|
|
public void add(BaseConfigAddParam baseConfigAddParam) {
|
|
|
BaseConfig baseConfig = BeanUtil.toBean(baseConfigAddParam, BaseConfig.class);
|
|
|
- if (this.count(new QueryWrapper<BaseConfig>().lambda().eq(BaseConfig::getConfigName,baseConfig.getConfigName())) > 0) {
|
|
|
+ if (this.count(new QueryWrapper<BaseConfig>().lambda()
|
|
|
+ .eq(BaseConfig::getOrgId,baseConfigAddParam.getOrgId())
|
|
|
+ .eq(BaseConfig::getParentId,baseConfigAddParam.getParentId())
|
|
|
+ .eq(BaseConfig::getConfigName,baseConfig.getConfigName())) > 0) {
|
|
|
throw new CommonException("存在重复配置名称!");
|
|
|
}
|
|
|
this.save(baseConfig);
|
|
|
-
|
|
|
- // 发布增加事件
|
|
|
- CommonDataChangeEventCenter.doAddWithData(BaseDataTypeEnum.BASE_CONFIG.getValue(), JSONUtil.createArray().put(baseConfig));
|
|
|
}
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -86,13 +88,14 @@ public class BaseConfigServiceImpl extends ServiceImpl<BaseConfigMapper, BaseCon
|
|
|
public void edit(BaseConfigEditParam baseConfigEditParam) {
|
|
|
BaseConfig baseConfig = this.queryEntity(baseConfigEditParam.getId());
|
|
|
BeanUtil.copyProperties(baseConfigEditParam, baseConfig);
|
|
|
- if (this.count(new QueryWrapper<BaseConfig>().lambda().ne(BaseConfig::getId,baseConfig.getId()).eq(BaseConfig::getConfigName,baseConfig.getConfigName())) > 0) {
|
|
|
+ if (this.count(new QueryWrapper<BaseConfig>().lambda()
|
|
|
+ .ne(BaseConfig::getId,baseConfig.getId())
|
|
|
+ .eq(BaseConfig::getOrgId,baseConfig.getOrgId())
|
|
|
+ .eq(BaseConfig::getParentId,baseConfig.getParentId())
|
|
|
+ .eq(BaseConfig::getConfigName,baseConfig.getConfigName())) > 0) {
|
|
|
throw new CommonException("存在重复配置名称!");
|
|
|
}
|
|
|
this.updateById(baseConfig);
|
|
|
-
|
|
|
- // 发布更新事件
|
|
|
- CommonDataChangeEventCenter.doUpdateWithData(BaseDataTypeEnum.BASE_CONFIG.getValue(), JSONUtil.createArray().put(baseConfig));
|
|
|
}
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -101,9 +104,6 @@ public class BaseConfigServiceImpl extends ServiceImpl<BaseConfigMapper, BaseCon
|
|
|
List<String> toDeleteBaseConfigIdList = CollStreamUtil.toList(baseConfigIdParamList, BaseConfigIdParam::getId);
|
|
|
// 执行删除
|
|
|
this.removeByIds(toDeleteBaseConfigIdList);
|
|
|
-
|
|
|
- // 发布删除事件
|
|
|
- CommonDataChangeEventCenter.doDeleteWithDataId(BaseDataTypeEnum.BASE_CONFIG.getValue(), toDeleteBaseConfigIdList);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -122,12 +122,26 @@ public class BaseConfigServiceImpl extends ServiceImpl<BaseConfigMapper, BaseCon
|
|
|
|
|
|
@Override
|
|
|
public Page<BaseConfig> listChild(BaseConfigListChildParam baseConfigListChildParam) {
|
|
|
- String orgId = StpLoginUserUtil.getLoginUser().getOrgId();
|
|
|
+ String orgId = baseConfigListChildParam.getOrgId();
|
|
|
QueryWrapper<BaseConfig> queryWrapper = new QueryWrapper();
|
|
|
queryWrapper.lambda().eq(BaseConfig::getParentId, baseConfigListChildParam.getParentId()).eq(BaseConfig::getOrgId, orgId);
|
|
|
Page<BaseConfig> baseConfigList = this.page(CommonPageRequest.defaultPage(),queryWrapper);
|
|
|
return baseConfigList;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public List<BizOrg> listOrgId() {
|
|
|
+ List<BizOrg> bizOrgs = new ArrayList<>();
|
|
|
+ String orgId = StpLoginUserUtil.getLoginUser().getOrgId();
|
|
|
+ BizOrg bizOrg = bizOrgMapper.selectById(orgId);
|
|
|
+ if (bizOrg.getParentId().equals("0")){
|
|
|
+ List<BizOrg> bizOrgs1 = bizOrgMapper.selectList(new QueryWrapper<BizOrg>().lambda().eq(BizOrg::getParentId, orgId));
|
|
|
+ bizOrgs.addAll(bizOrgs1);
|
|
|
+ }else {
|
|
|
+ bizOrgs.add(bizOrg);
|
|
|
+ }
|
|
|
+ return bizOrgs;
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
}
|