package com.vci.web.service.impl;
|
|
import com.vci.client.common.providers.ClientServiceProvider;
|
import com.vci.corba.common.PLException;
|
import com.vci.corba.omd.stm.StatePool;
|
import com.vci.starter.web.annotation.log.VciUnLog;
|
import com.vci.starter.web.exception.VciBaseException;
|
import com.vci.starter.web.pagemodel.BaseQueryObject;
|
import com.vci.starter.web.pagemodel.DataGrid;
|
import com.vci.starter.web.pagemodel.PageHelper;
|
import com.vci.starter.web.util.LangBaseUtil;
|
import com.vci.starter.web.util.VciBaseUtil;
|
import com.vci.starter.web.util.VciDateUtil;
|
import com.vci.web.dto.OsStatusDTO;
|
import com.vci.web.model.OsStatusDO;
|
import com.vci.web.pageModel.OsStatusVO;
|
import com.vci.web.service.OsLifeCycleServiceI;
|
import com.vci.web.service.OsStatusServiceI;
|
import com.vci.web.service.WebBoServiceI;
|
import com.vci.web.util.PlatformClientUtil;
|
import com.vci.web.util.WebUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
import static com.vci.frameworkcore.constant.FrameWorkBusLangCodeConstant.DATA_OID_NOT_EXIST;
|
|
/**
|
* 状态的服务
|
* @author weidy
|
* @date 2021-2-14
|
*/
|
@Service
|
public class OsStatusServiceImpl implements OsStatusServiceI {
|
|
/**
|
* 日志
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 平台的客户端
|
*/
|
@Autowired
|
private PlatformClientUtil platformClientUtil;
|
|
/**
|
* 业务
|
*/
|
@Autowired
|
private WebBoServiceI boService;
|
|
/**
|
* 生命周期的服务
|
*/
|
@Autowired(required = false)
|
@Lazy
|
private OsLifeCycleServiceI lifeCycleService;
|
|
/**
|
* 加载自身
|
*/
|
@Autowired(required = false)
|
@Lazy
|
private OsStatusServiceI self;
|
|
/**
|
* 数据对象转换为显示对象
|
*
|
* @param statePool 状态池的数据对象
|
* @return 显示对象
|
*/
|
@Override
|
public OsStatusVO statusDO2VO(com.vci.corba.omd.stm.StatePool statePool) {
|
OsStatusVO statusVO = new OsStatusVO();
|
if(statePool!=null){
|
statusVO.setOid(statePool.oid);
|
statusVO.setCreator(statePool.creator);
|
statusVO.setLastModifier(statePool.modifier);
|
try {
|
statusVO.setCreateTime(new Date(statePool.createTime));
|
statusVO.setLastModifyTime(new Date(statePool.modifyTime));
|
statusVO.setTs(VciDateUtil.str2Date(statePool.ts,VciDateUtil.DateTimeMillFormat));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
statusVO.setDescription(statePool.description);
|
statusVO.setId(statePool.name);
|
statusVO.setName(statePool.tag);
|
}
|
return statusVO;
|
}
|
|
/**
|
* 数据对象转换为显示对象
|
*
|
* @param statePools 状态池的数据对象 集合
|
* @return 显示对象
|
*/
|
@Override
|
public List<OsStatusVO> statusDO2VOs(Collection<com.vci.corba.omd.stm.StatePool> statePools) {
|
List<OsStatusVO> statusVOS = new ArrayList<>();
|
if(!CollectionUtils.isEmpty(statePools)){
|
statePools.stream().forEach(statePool -> {
|
OsStatusVO statusVO = statusDO2VO(statePool);
|
statusVOS.add(statusVO);
|
});
|
}
|
return statusVOS;
|
}
|
|
/**
|
* 查询所有的状态
|
*
|
* @return 状态的显示对象
|
*/
|
@Override
|
@VciUnLog
|
public List<OsStatusVO> selectAllStatus() {
|
try {
|
// return statusDO2VOs(Arrays.stream(platformClientUtil.getStatePoolService().getStatePools()).collect(Collectors.toList()));
|
return statusDO2VOs(Arrays.stream(ClientServiceProvider.getOMDService().getStateService().getStatePools()).collect(Collectors.toList()));
|
} catch (PLException vciError) {
|
throw WebUtil.getVciBaseException(vciError);
|
}
|
}
|
|
/**
|
* 清除缓存
|
*/
|
@Override
|
public void clearCache(){
|
//
|
}
|
|
/**
|
* 查询全部的状态映射
|
* @return key是状态的英文名称
|
*/
|
@Override
|
@VciUnLog
|
public Map<String,OsStatusVO> selectAllStatusMap(){
|
return Optional.ofNullable(self.selectAllStatus()).orElseGet(()->new ArrayList<>()).stream().collect(Collectors.toMap(s->s.getId(),t->t,(o1,o2)->o1));
|
}
|
|
/**
|
* 状态转换为显示文本
|
*
|
* @param status 状态
|
* @return 显示文本
|
*/
|
@Override
|
public String getStatusTextByValue(String status) {
|
if(StringUtils.isBlank(status)){
|
return "";
|
}
|
return self.selectAllStatusMap().getOrDefault(status,new OsStatusVO()).getName();
|
}
|
|
/**
|
* 批量添加状态
|
*
|
* @param statePoolList 状态内容
|
*/
|
@Override
|
public void batchAddStatus(List<StatePool> statePoolList) {
|
if(!CollectionUtils.isEmpty(statePoolList)){
|
for(StatePool statePool : statePoolList) {
|
try {
|
platformClientUtil.getStatePoolService().addStatePool(statePool);
|
} catch (PLException e) {
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
}
|
}
|
|
/**
|
* 批量修改状态
|
* @param statePoolList 状态内容
|
*/
|
@Override
|
public void batchEditSave(List<StatePool> statePoolList) {
|
if(!CollectionUtils.isEmpty(statePoolList)){
|
for(StatePool statePool : statePoolList) {
|
try {
|
platformClientUtil.getStatePoolService().modifyStatePool(statePool);
|
} catch (PLException e) {
|
throw WebUtil.getVciBaseException(e);
|
}
|
}
|
}
|
}
|
|
/**
|
* 状态列表
|
*
|
* @param conditionMap 查询对象
|
* @param pageHelper 分页列表
|
* @return 显示对象
|
*/
|
@Override
|
public DataGrid<OsStatusVO> gridStatus(Map<String, String> conditionMap, PageHelper pageHelper) {
|
BaseQueryObject baseQueryObject = new BaseQueryObject();
|
baseQueryObject.setConditionMap(conditionMap);
|
if (pageHelper == null) {
|
pageHelper = new PageHelper(-1);
|
}
|
baseQueryObject.setPage(pageHelper.getPage());
|
baseQueryObject.setLimit(pageHelper.getLimit());
|
baseQueryObject.setOrder(pageHelper.getOrder());
|
baseQueryObject.setSort(pageHelper.getSort());
|
|
return gridObject(baseQueryObject, OsStatusDO.class,self.selectAllStatusMap(),OsStatusVO.class);
|
}
|
|
/**
|
* 使用主键获取显示对象
|
*
|
* @param oid 主键
|
* @return 状态的显示对象
|
*/
|
@Override
|
public OsStatusVO getObjectByOid(String oid) {
|
List<OsStatusVO> statusVOList = self.selectAllStatusMap().values().stream().filter(status -> status.getOid().equalsIgnoreCase(oid)).collect(Collectors.toList());
|
if(CollectionUtils.isEmpty(statusVOList)){
|
throw new VciBaseException(DATA_OID_NOT_EXIST);
|
}
|
return statusVOList.get(0);
|
}
|
|
/**
|
* 使用主键集合查询
|
* @param oidCollection 主键集合
|
* @return 状态的内容
|
*/
|
@Override
|
public List<OsStatusVO> selectByOidCollection(Collection<String> oidCollection){
|
List<OsStatusVO> statusVOList = self.selectAllStatus().stream().filter(status -> oidCollection.contains(status.getOid())).collect(Collectors.toList());
|
if(CollectionUtils.isEmpty(statusVOList)){
|
throw new VciBaseException(DATA_OID_NOT_EXIST);
|
}
|
return statusVOList;
|
}
|
|
/**
|
* 添加状态
|
*
|
* @param statusDTO 状态的数据传输对象
|
*/
|
@Override
|
public void addSave(OsStatusDTO statusDTO) {
|
VciBaseUtil.alertNotNull(statusDTO,"状态的信息",statusDTO.getId(),"状态的英文名称",statusDTO.getName(),"状态的中文名称");
|
statusDTO.setOid(VciBaseUtil.getPk());
|
StatePool pool = statusDTO2DO(statusDTO);
|
List<StatePool> poolList = new ArrayList<>();
|
poolList.add(pool);
|
batchAddStatus(poolList);
|
clearCache();
|
self.selectAllStatusMap();
|
}
|
|
|
/**
|
* 编辑状态
|
* @param statusDTO 状态的数据传输对象
|
*/
|
@Override
|
public void editSave(OsStatusDTO statusDTO){
|
VciBaseUtil.alertNotNull(statusDTO,"状态的信息",statusDTO.getId(),"状态的英文名称",statusDTO.getName(),"状态的中文名称",statusDTO.getOid(),"主键");
|
OsStatusVO statusVO = getObjectByOid(statusDTO.getOid());
|
StatePool pool = statusDTO2DO(statusDTO);
|
pool.creator = statusVO.getCreator();
|
pool.createTime = VciDateUtil.getTime(statusVO.getCreateTime());
|
List<StatePool> poolList = new ArrayList<>();
|
poolList.add(pool);
|
batchEditSave(poolList);
|
clearCache();
|
self.selectAllStatusMap();
|
}
|
|
/**
|
* 删除状态
|
* @param oids 主键
|
*/
|
@Override
|
public void delete(String oids){
|
VciBaseUtil.alertNotNull(oids,"主键");
|
//判断是否被引用
|
List<OsStatusVO> statusVOList1 = selectByOidCollection(VciBaseUtil.str2List(oids));
|
if(statusVOList1.stream().anyMatch(statusVO -> lifeCycleService.checkStatusUsed(statusVO))){
|
throw new VciBaseException("状态在生命周期中被使用，不能删除");
|
}
|
statusVOList1.stream().forEach(statusVO -> {
|
try {
|
platformClientUtil.getStatePoolService().deleteStatePool(statusVO2DO(statusVO));
|
}catch (Throwable e){
|
throw new VciBaseException(LangBaseUtil.getErrorMsg(e),new String[]{},e);
|
}
|
});
|
clearCache();
|
self.selectAllStatusMap();
|
}
|
|
/**
|
* 状态的数据传输对象转换为数据对象
|
* @param statusDTO 数据传输对象
|
* @return 平台的数据对象
|
*/
|
@Override
|
public StatePool statusDTO2DO(OsStatusDTO statusDTO){
|
StatePool statePool = new StatePool();
|
statePool.oid = statusDTO.getOid();
|
statePool.id = "";
|
statePool.name = statusDTO.getId();
|
statePool.description = statusDTO.getDescription()==null?"":statusDTO.getDescription();
|
String userId = VciBaseUtil.getCurrentUserId();
|
long now = VciDateUtil.getNowTime();
|
statePool.creator = userId;
|
statePool.createTime = now;
|
statePool.modifier = userId;
|
statePool.modifyTime = now;
|
statePool.ts = statusDTO.getTs()==null?VciDateUtil.getNowString(VciDateUtil.DateTimeMillFormat):VciDateUtil.date2Str(statusDTO.getTs(),VciDateUtil.DateTimeMillFormat);
|
statePool.tag = statusDTO.getName();
|
return statePool;
|
}
|
|
/**
|
* 状态的显示对象转换为DO对象
|
* @param statusVO 显示对象
|
* @return 数据对象
|
*/
|
public StatePool statusVO2DO(OsStatusVO statusVO){
|
StatePool statePool = new StatePool();
|
statePool.oid = statusVO.getOid();
|
statePool.id = "";
|
statePool.name = statusVO.getId();
|
statePool.description = statusVO.getDescription()==null?"":statusVO.getDescription();
|
String userId = VciBaseUtil.getCurrentUserId();
|
String now = VciDateUtil.getNowString(VciDateUtil.DateTimeMillFormat);
|
statePool.creator = statusVO.getCreator();
|
statePool.createTime = VciDateUtil.getTime(statusVO.getCreateTime());
|
statePool.modifier = statusVO.getLastModifier();
|
statePool.modifyTime = VciDateUtil.getTime(statusVO.getLastModifyTime());
|
statePool.ts = statusVO.getTs()==null?now:VciDateUtil.date2Str(statusVO.getTs(),VciDateUtil.DateTimeMillFormat);
|
statePool.tag = statusVO.getName();
|
return statePool;
|
}
|
|
|
|
}
|
