lbqms.git - Gitblit

¶Ô±ÈÐÂÎÄ¼þ
			@@ -0,0 +1,117 @@
			package org.dromara.workflow.service.impl;

			import cn.hutool.core.collection.CollUtil;
			import org.dromara.common.core.utils.MapstructUtils;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import lombok.RequiredArgsConstructor;
			import org.dromara.workflow.domain.WfDefinitionConfig;
			import org.dromara.workflow.domain.bo.WfDefinitionConfigBo;
			import org.dromara.workflow.domain.vo.WfDefinitionConfigVo;
			import org.dromara.workflow.service.IWfDefinitionConfigService;
			import org.springframework.stereotype.Service;
			import org.dromara.workflow.mapper.WfDefinitionConfigMapper;
			import org.springframework.transaction.annotation.Transactional;

			import java.util.List;
			import java.util.Collection;

			/**
			* æµç¨å®ä¹éç½®Serviceä¸å¡å±å¤ç
			*
			* @author may
			* @date 2024-03-18
			*/
			@RequiredArgsConstructor
			@Service
			public class WfDefinitionConfigServiceImpl implements IWfDefinitionConfigService {

			private final WfDefinitionConfigMapper baseMapper;

			/**
			* æ¥è¯¢æµç¨å®ä¹éç½®
			*/
			@Override
			public WfDefinitionConfigVo getByDefId(String definitionId) {
			return baseMapper.selectVoOne(new LambdaQueryWrapper<WfDefinitionConfig>().eq(WfDefinitionConfig::getDefinitionId, definitionId));
			}

			/**
			* æ¥è¯¢æµç¨å®ä¹éç½®
			*
			* @param tableName è¡¨å
			* @return ç»æ
			*/
			@Override
			public WfDefinitionConfigVo getByTableNameLastVersion(String tableName) {
			List<WfDefinitionConfigVo> wfDefinitionConfigVos = baseMapper.selectVoList(
			new LambdaQueryWrapper<WfDefinitionConfig>().eq(WfDefinitionConfig::getTableName, tableName).orderByDesc(WfDefinitionConfig::getVersion));
			if (CollUtil.isNotEmpty(wfDefinitionConfigVos)) {
			return wfDefinitionConfigVos.get(0);
			}
			return null;
			}

			/**
			* æ¥è¯¢æµç¨å®ä¹éç½®
			*
			* @param definitionId æµç¨å®ä¹id
			* @param tableName è¡¨å
			* @return ç»æ
			*/
			@Override
			public WfDefinitionConfigVo getByDefIdAndTableName(String definitionId, String tableName) {
			return baseMapper.selectVoOne(new LambdaQueryWrapper<WfDefinitionConfig>()
			.eq(WfDefinitionConfig::getDefinitionId, definitionId)
			.eq(WfDefinitionConfig::getTableName, tableName));
			}

			/**
			* æ¥è¯¢æµç¨å®ä¹éç½®æé¤å½åæ¥è¯¢çæµç¨å®ä¹
			*
			* @param tableName è¡¨å
			* @param definitionId æµç¨å®ä¹id
			*/
			@Override
			public List<WfDefinitionConfigVo> getByTableNameNotDefId(String tableName, String definitionId) {
			return baseMapper.selectVoList(new LambdaQueryWrapper<WfDefinitionConfig>()
			.eq(WfDefinitionConfig::getTableName, tableName)
			.ne(WfDefinitionConfig::getDefinitionId, definitionId));
			}

			/**
			* æ¥è¯¢æµç¨å®ä¹éç½®åè¡¨
			*/
			@Override
			public List<WfDefinitionConfigVo> queryList(List<String> definitionIds) {
			return baseMapper.selectVoList(new LambdaQueryWrapper<WfDefinitionConfig>().in(WfDefinitionConfig::getDefinitionId, definitionIds));
			}

			/**
			* æ°å¢æµç¨å®ä¹éç½®
			*/
			@Override
			@Transactional(rollbackFor = Exception.class)
			public Boolean saveOrUpdate(WfDefinitionConfigBo bo) {
			WfDefinitionConfig add = MapstructUtils.convert(bo, WfDefinitionConfig.class);
			baseMapper.delete(new LambdaQueryWrapper<WfDefinitionConfig>().eq(WfDefinitionConfig::getTableName, bo.getTableName()));
			add.setTableName(add.getTableName().toLowerCase());
			boolean flag = baseMapper.insertOrUpdate(add);
			if (baseMapper.insertOrUpdate(add)) {
			bo.setId(add.getId());
			}
			return flag;
			}

			/**
			* æ¹éå é¤æµç¨å®ä¹éç½®
			*/
			@Override
			public Boolean deleteByIds(Collection<Long> ids) {
			return baseMapper.deleteBatchIds(ids) > 0;
			}

			@Override
			public Boolean deleteByDefIds(Collection<String> ids) {
			return baseMapper.delete(new LambdaQueryWrapper<WfDefinitionConfig>().in(WfDefinitionConfig::getDefinitionId, ids)) > 0;
			}
			}