package com.vci.web.service.impl;
|
|
import com.vci.corba.common.PLException;
|
import com.vci.corba.omd.ltm.LinkType;
|
import com.vci.starter.web.annotation.log.VciUnLog;
|
import com.vci.starter.web.enumpck.VciFieldTypeEnum;
|
import com.vci.starter.web.pagemodel.BaseQueryObject;
|
import com.vci.starter.web.pagemodel.DataGrid;
|
import com.vci.starter.web.util.BeanUtil;
|
import com.vci.starter.web.util.VciBaseUtil;
|
import com.vci.starter.web.util.VciDateUtil;
|
import com.vci.web.constant.CacheKeyConstant;
|
import com.vci.web.model.OsLinkTypeDO;
|
import com.vci.web.pageModel.*;
|
import com.vci.web.service.*;
|
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.cache.annotation.CacheEvict;
|
import org.springframework.cache.annotation.Cacheable;
|
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.web.constant.CacheNameConstant.VCI_OBJECT_SERVICE;
|
|
/**
|
* 链接类型服务
|
* @author weidy
|
* @date 2021-2-15
|
*/
|
@Service
|
public class OsLinkTypeServiceImpl implements OsLinkTypeServiceI {
|
|
/**
|
* 日志
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
|
/**
|
* 平台的调用工具类
|
*/
|
@Autowired
|
private PlatformClientUtil platformClientUtil;
|
|
/**
|
* 属性的服务
|
*/
|
@Autowired
|
private OsAttributeServiceI attributeService;
|
|
/**
|
* 枚举的服务
|
*/
|
@Autowired
|
private OsEnumServiceI enumService;
|
|
/**
|
* 业务类型服务
|
*/
|
@Autowired
|
private OsBtmServiceI btmService;
|
|
/**
|
* 业务数据查询服务
|
*/
|
@Autowired
|
private WebBoServiceI boService;
|
|
/**
|
* 加载自身
|
*/
|
@Autowired(required = false)
|
@Lazy
|
private OsLinkTypeServiceI self;
|
|
/**
|
* 查询所有的链接类型
|
*
|
* @return 链接类型对象
|
*/
|
@Override
|
@VciUnLog
|
public List<OsLinkTypeVO> selectAllLink() {
|
try {
|
return linkTypeDO2VOs(Arrays.stream(platformClientUtil.getLinkTypeService().getLinkTypes()).collect(Collectors.toList()));
|
} catch (PLException vciError) {
|
throw WebUtil.getVciBaseException(vciError);
|
}
|
}
|
|
/**
|
* 查询所有的业务类型映射
|
*
|
* @return key 是业务的英文名称的小写
|
*/
|
@Override
|
@VciUnLog
|
@Cacheable(value = VCI_OBJECT_SERVICE,key = CacheKeyConstant.ALL_Link,unless = "#result == null")
|
public Map<String, OsLinkTypeVO> selectAllLinkMap() {
|
return Optional.ofNullable(self.selectAllLink()).orElseGet(()->new ArrayList<>()).stream().collect(Collectors.toMap(s->s.getId().toLowerCase(),t->t,(o1,o2)->o1));
|
}
|
|
/**
|
* 数据对象转换为显示对象
|
*
|
* @param linkTypes 数据对象
|
* @return 显示对象
|
*/
|
@Override
|
public List<OsLinkTypeVO> linkTypeDO2VOs(Collection<LinkType> linkTypes) {
|
List<OsLinkTypeVO> VOS = new ArrayList<>();
|
Optional.ofNullable(linkTypes).orElseGet(()->new ArrayList<>()).stream().forEach(linkType -> {
|
OsLinkTypeVO vo = linkTypeDO2VO(linkType);
|
VOS.add(vo);
|
});
|
return VOS;
|
}
|
|
/**
|
* 数据对象转换为显示对象
|
*
|
* @param linkType 数据对象
|
* @return 显示对象
|
*/
|
@Override
|
public OsLinkTypeVO linkTypeDO2VO(LinkType linkType) {
|
OsLinkTypeVO vo = new OsLinkTypeVO();
|
if(linkType !=null){
|
vo.setOid(linkType.oid);
|
vo.setCreator(linkType.creator);
|
vo.setLastModifier(linkType.modifier);
|
try {
|
vo.setCreateTime(VciDateUtil.long2Date(linkType.createTime));
|
vo.setLastModifyTime(VciDateUtil.long2Date(linkType.modifyTime));
|
vo.setTs(VciDateUtil.long2Date(linkType.ts));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
vo.setDescription(linkType.description);
|
vo.setId(linkType.name);
|
vo.setName(linkType.tag);
|
vo.setFromBtmTypeVOS(btmService.listBtmByIds(Arrays.stream(linkType.btmItemsFrom).collect(Collectors.toSet())));
|
if(!CollectionUtils.isEmpty(vo.getFromBtmTypeVOS())){
|
vo.setFromBtmType(Arrays.stream(linkType.btmItemsFrom).collect(Collectors.joining(",")));
|
vo.setFromBtmTypeName(vo.getFromBtmTypeVOS().stream().map(OsBtmTypeVO::getName).collect(Collectors.joining(",")));
|
}
|
vo.setToBtmTypeVOS(btmService.listBtmByIds(Arrays.stream(linkType.btmItemsTo).collect(Collectors.toSet())));
|
if(!CollectionUtils.isEmpty(vo.getToBtmTypeVOS())){
|
vo.setToBtmType(Arrays.stream(linkType.btmItemsTo).collect(Collectors.joining(",")));
|
vo.setToBtmTypeName(vo.getToBtmTypeVOS().stream().map(OsBtmTypeVO::getName).collect(Collectors.joining(",")));
|
}
|
vo.setImplClass(linkType.implClass);
|
vo.setShape(linkType.shape);
|
List<OsAttributeVO> attributeVOS = attributeService.listAttrByIds(Arrays.stream(linkType.attributes).collect(Collectors.toList()));
|
List<OsLinkTypeAttributeVO> linkTypeAttributeVOS = new ArrayList<>();
|
Optional.ofNullable(attributeVOS).orElseGet(()->new ArrayList<>()).stream().forEach(attributeVO->{
|
OsLinkTypeAttributeVO linkTypeAttributeVO = new OsLinkTypeAttributeVO();
|
BeanUtil.convert(attributeVO,linkTypeAttributeVO);
|
linkTypeAttributeVO.setPkLinkType(vo.getOid());
|
if(StringUtils.isNotBlank(attributeVO.getBtmTypeId())){
|
linkTypeAttributeVO.setReferFlag(true);
|
linkTypeAttributeVO.setReferBtmTypeId(attributeVO.getBtmTypeId());
|
}
|
if(StringUtils.isNotBlank(attributeVO.getEnumId())){
|
linkTypeAttributeVO.setEnumFlag(true);
|
linkTypeAttributeVO.setEnumItemMap(enumService.getEnumValueMap(linkTypeAttributeVO.getEnumId()));
|
}
|
linkTypeAttributeVOS.add(linkTypeAttributeVO);
|
});
|
vo.setAttributes(linkTypeAttributeVOS);
|
}
|
return vo;
|
}
|
|
/**
|
* 使用编号获取链接类型
|
*
|
* @param linkIds 编号
|
* @return 链接类型
|
*/
|
@Override
|
public List<OsLinkTypeVO> listLinkTypeIds(Collection<String> linkIds) {
|
if(CollectionUtils.isEmpty(linkIds)){
|
return null;
|
}
|
Map<String, OsLinkTypeVO> linkTypeVOMap = self.selectAllLinkMap();
|
List<OsLinkTypeVO> linkTypeVOS = new ArrayList<>();
|
linkIds.stream().forEach(id->{
|
if(linkTypeVOMap.containsKey(id.toLowerCase())){
|
linkTypeVOS.add(linkTypeVOMap.get(id.toLowerCase()));
|
}
|
});
|
return linkTypeVOS;
|
}
|
|
/**
|
* 使用编号获取链接类型
|
*
|
* @param id 编号
|
* @return 链接类型
|
*/
|
@Override
|
public OsLinkTypeVO getLinkTypeById(String id) {
|
if(StringUtils.isBlank(id)){
|
return null;
|
}
|
return self.selectAllLinkMap().getOrDefault(id.toLowerCase(),null);
|
}
|
|
/**
|
* 获取链接类型的属性
|
*
|
* @param linkTypeId 链接类型的编号
|
* @return 链接类型的属性
|
*/
|
@Override
|
public List<OsLinkTypeAttributeVO> listAttributeByLinkId(String linkTypeId) {
|
OsLinkTypeVO linkTypeVO = getLinkTypeById(linkTypeId);
|
return linkTypeVO.getAttributes();
|
}
|
|
/**
|
* 链接类型的列表
|
*
|
* @param baseQueryObject 查询对象
|
* @return 链接类型的显示对象
|
*/
|
@Override
|
public DataGrid<OsLinkTypeVO> gridLinkType(BaseQueryObject baseQueryObject) {
|
return gridObject(baseQueryObject, OsLinkTypeDO.class,self.selectAllLinkMap(),OsLinkTypeVO.class);
|
}
|
|
/**
|
* 使用主键获取显示对象
|
*
|
* @param linkTypeOid 链接类型的主键
|
* @return 链接类型的显示对象
|
*/
|
@Override
|
public OsLinkTypeVO selectByOid(String linkTypeOid) {
|
List<OsLinkTypeVO> linkTypeVOS = self.selectAllLinkMap().values().stream().collect(Collectors.toList());
|
return Optional.ofNullable(linkTypeVOS).orElseGet(()->new ArrayList<>()).stream().filter(s->s.getOid().equalsIgnoreCase(linkTypeOid)).findFirst().orElseGet(()->null);
|
|
}
|
|
/**
|
* 获取链接类型关联的所有业务类型中属性类型差异的信息
|
*
|
* @param linkTypeOid 链接类型的主键
|
* @return 有错误的属性
|
*/
|
@Override
|
public List<OsBtmTypeAttributeVO> checkAttributeTypeDifferent(String linkTypeOid) {
|
if(StringUtils.isBlank(linkTypeOid)){
|
return new ArrayList<>();
|
}
|
OsLinkTypeVO linkTypeVO = selectByOid(linkTypeOid);
|
List<OsBtmTypeVO> fromBtmTypeVOS = linkTypeVO.getFromBtmTypeVOS();
|
List<OsBtmTypeVO> toBtmTypeVOS = linkTypeVO.getToBtmTypeVOS();
|
List<OsBtmTypeVO> btmTypeVOS = new ArrayList<>();
|
btmTypeVOS.addAll(fromBtmTypeVOS);
|
btmTypeVOS.addAll(toBtmTypeVOS);
|
|
List<OsBtmTypeAttributeVO> diffList = new ArrayList<>();
|
btmTypeVOS.stream().forEach(btmTypeVO -> {
|
//查询这个表的信息
|
String sql = "select t.column_name,t.data_type,t.data_length,t.nullable,t.data_precision,t.data_scale,c.comments from user_tab_columns t " +
|
"inner JOIN user_col_comments c on t.TABLE_NAME = c.table_name and t.COLUMN_NAME = c.column_name where " +
|
"t.table_name = '" + VciBaseUtil.getTableName(btmTypeVO.getId()).toUpperCase(Locale.ROOT) + "' order by t.column_name asc";
|
Map<String, OsBtmTypeAttributeVO> attributeVOMap = btmTypeVO.getAttributes().stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
|
List<com.vci.client.bof.ClientBusinessObject> cbosList = boService.queryBySql(sql, new HashMap<>());
|
if(!CollectionUtils.isEmpty(cbosList)){
|
cbosList.stream().forEach(cbo->{
|
String attrId = cbo.getAttributeValue("column_name");
|
String dataType = cbo.getAttributeValue("data_type");
|
if(StringUtils.isNotBlank(dataType) && dataType.contains("(")){
|
dataType = dataType.substring(0,dataType.indexOf("("));
|
}
|
OsBtmTypeAttributeVO attributeVO = attributeVOMap.getOrDefault(attrId.toLowerCase(Locale.ROOT), null);
|
if(attributeVO!=null){
|
String vtType = attributeVO.getAttrDataType();
|
String attrType = "";
|
VciFieldTypeEnum fieldTypeEnum = VciFieldTypeEnum.forValue(vtType);
|
if(fieldTypeEnum == null) {
|
attrType = "VARCHAR2";
|
}else {
|
switch (fieldTypeEnum) {
|
case VTString:
|
case VTBoolean:
|
attrType = "VARCHAR2";
|
break;
|
case VTInteger:
|
case VTLong:
|
case VTDouble:
|
attrType = "NUMBER";
|
break;
|
case VTDate:
|
attrType = "DATE";
|
break;
|
case VTDateTime:
|
case VTTime:
|
attrType = "TIMESTAMP";
|
break;
|
default:
|
attrType = "VARCHAR2";
|
break;
|
}
|
}
|
if(!attrType.equalsIgnoreCase(dataType)) {
|
diffList.add(attributeVO);
|
}
|
}
|
});
|
}
|
});
|
return diffList;
|
}
|
|
/**
|
* 清除缓存
|
*/
|
@Override
|
@CacheEvict(value = VCI_OBJECT_SERVICE,key = CacheKeyConstant.ALL_Link)
|
public void clearCache() {
|
|
}
|
}
|
