package com.vci.web.service.impl;
|
|
import com.vci.corba.common.PLException;
|
import com.vci.corba.omd.atm.AttributeDef;
|
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.VciBaseUtil;
|
import com.vci.starter.web.util.VciDateUtil;
|
import com.vci.web.model.OsAttributeDO;
|
import com.vci.web.pageModel.OsAttributeVO;
|
import com.vci.web.service.OsAttributeServiceI;
|
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.client.omd.attribpool.ui.VTDataTypePanel.*;
|
|
/**
|
* 属性池服务 --已经调用了平台的服务，因此不在提供Dao层
|
* @author weidy
|
* @date 2021-2-15
|
*/
|
@Service
|
public class OsAttributeServiceImpl implements OsAttributeServiceI {
|
|
/**
|
* 日志
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 平台的调用工具类
|
*/
|
@Autowired
|
private PlatformClientUtil platformClientUtil;
|
|
/**
|
* 加载自身
|
*/
|
@Autowired(required = false)
|
@Lazy
|
private OsAttributeServiceI self;
|
|
/**
|
* 默认的属性
|
*/
|
private static List<OsAttributeVO> defaultAttributeVOs = new ArrayList<>();
|
|
/**
|
* 默认属性的映射，key是小写
|
*/
|
private static Map<String,OsAttributeVO> defaultAttributeVOMap = new HashMap<>();
|
|
/**
|
* 获取默认的属性
|
* @return 默认的属性列表
|
*/
|
@Override
|
public List<OsAttributeVO> getDefaultAttributeVOs() {
|
return OsAttributeServiceImpl.defaultAttributeVOs;
|
}
|
|
/**
|
* 设置默认的属性
|
* @param defaultAttributeVOs 默认的属性列表
|
*/
|
@Override
|
public void setDefaultAttributeVOs(List<OsAttributeVO> defaultAttributeVOs) {
|
OsAttributeServiceImpl.defaultAttributeVOs = defaultAttributeVOs;
|
}
|
|
/**
|
* 获取的默认属性的映射
|
* @return 默认的属性映射
|
*/
|
@Override
|
public Map<String, OsAttributeVO> getDefaultAttributeVOMap() {
|
return OsAttributeServiceImpl.defaultAttributeVOMap;
|
}
|
|
/**
|
* 设置默认的属性的映射
|
* @param defaultAttributeVOMap 默认的属性映射
|
*/
|
@Override
|
public void setDefaultAttributeVOMap(Map<String, OsAttributeVO> defaultAttributeVOMap) {
|
OsAttributeServiceImpl.defaultAttributeVOMap = defaultAttributeVOMap;
|
}
|
|
/**
|
* 查询所有的属性
|
*
|
* @return 属性的显示对象
|
*/
|
@Override
|
public List<OsAttributeVO> selectAllAttribute() {
|
//后面两个分页数，完全没有用
|
try {
|
return attributeDO2VOs(Arrays.stream(platformClientUtil.getAttributeService().getAttributeDefs("",1,1)).collect(Collectors.toList()));
|
} catch (PLException vciError) {
|
throw WebUtil.getVciBaseException(vciError);
|
}
|
}
|
|
/**
|
* 查询所有的属性映射
|
*
|
* @return key是属性的英文名称小写，value是属性的显示对象
|
*/
|
@Override
|
@VciUnLog
|
public Map<String, OsAttributeVO> selectAllAttributeMap() {
|
return Optional.ofNullable(self.selectAllAttribute()).orElseGet(()->new ArrayList<>()).stream().collect(Collectors.toMap(s->s.getId().toLowerCase(),t->t,(o1,o2)->o1));
|
}
|
|
/**
|
* 属性的数据对象转换为显示对象
|
*
|
* @param attribItems 数据对象
|
* @return 显示对象
|
*/
|
@Override
|
public List<OsAttributeVO> attributeDO2VOs(Collection<AttributeDef> attribItems) {
|
List<OsAttributeVO> vos = new ArrayList<>();
|
Optional.ofNullable(attribItems).orElseGet(()->new ArrayList<>()).stream().forEach(attribItem -> {
|
vos.add(attributeDO2VO(attribItem));
|
});
|
return vos;
|
}
|
|
/**
|
* 属性的数据对象转换为显示对象
|
*
|
* @param attribItem 数据对象
|
* @return 显示对象
|
*/
|
@Override
|
public OsAttributeVO attributeDO2VO(AttributeDef attribItem) {
|
OsAttributeVO attributeVO = new OsAttributeVO();
|
if(attribItem!=null){
|
attributeVO.setOid(attribItem.oid);
|
attributeVO.setId(attribItem.name);
|
attributeVO.setCreator(attribItem.creator);
|
try {
|
attributeVO.setCreateTime(VciDateUtil.str2Date(String.valueOf(attribItem.createTime),VciDateUtil.DateTimeFormat));
|
attributeVO.setLastModifyTime(VciDateUtil.str2Date(String.valueOf(attribItem.modifyTime),VciDateUtil.DateTimeFormat));
|
attributeVO.setTs(VciDateUtil.str2Date(attribItem.ts,VciDateUtil.DateTimeMillFormat));
|
}catch (Throwable e){
|
|
}
|
attributeVO.setLastModifier(attribItem.modifier);
|
attributeVO.setName(attribItem.label);
|
attributeVO.setDescription(attribItem.description);
|
attributeVO.setAttributeDataType(attribItem.vtDataType);
|
attributeVO.setAttributeDataTypeText(VciFieldTypeEnum.getTextByValue(attribItem.vtDataType));
|
attributeVO.setDefaultValue(attribItem.defValue);
|
attributeVO.setRange(attribItem.rage);
|
if(StringUtils.isNotBlank(attribItem.other)) {
|
if (isReferAttr(attribItem.other)) {
|
//说明这个的确是参照字段
|
String[] others = attribItem.other.split(";");
|
for (String s : others) {
|
if (s.toLowerCase().contains("btm") && s.split("=").length > 1) {//必须要判断长度，因为枚举的时候也是包含这个btm的
|
attributeVO.setBtmTypeId(s.split("=")[1].trim());
|
}
|
//链接类型不支持
|
}
|
}
|
//必输和长度
|
String[] others = attribItem.other.split(";");
|
for (String s : others) {
|
if (s.toLowerCase().contains("allownull") && s.split("=").length > 1) {//必须要判断长度，因为枚举的时候也是包含这个btm的
|
boolean allownull = false;
|
if (s.split("=")[1].trim().toLowerCase().equals("yes")) {
|
allownull = true;
|
}
|
attributeVO.setNullableFlag(allownull);
|
}
|
if (s.toLowerCase().indexOf("length") > -1 && s.split("=").length > 1) {
|
int length = WebUtil.getInt(s.split("=")[1].trim());
|
if (length > 0) {
|
attributeVO.setAttrLength(length);
|
}
|
}
|
}
|
//枚举
|
if(isEnumAttr(attribItem.other)){
|
for (String s : others) {
|
if(s.contains("enumName") && s.split("=").length>1) {
|
attributeVO.setEnumId(s.split("=")[1].trim());
|
}
|
}
|
}
|
}
|
}
|
return attributeVO;
|
}
|
|
/**
|
* 属性的显示对象转换为数据对象
|
*
|
* @param attributeVO 显示对象
|
* @return 数据对象
|
*/
|
@Override
|
public AttributeDef attributeVO2DO(OsAttributeVO attributeVO) {
|
AttributeDef attribItem = new AttributeDef();
|
attribItem.oid = attributeVO.getOid();
|
attribItem.ts = VciDateUtil.date2Str(attributeVO.getTs(),VciDateUtil.DateTimeFormat);
|
attribItem.creator = attributeVO.getCreator();
|
attribItem.createTime = attributeVO.getCreateTime() != null?attributeVO.getCreateTime().getTime():null;
|
attribItem.modifier = attributeVO.getLastModifier();
|
attribItem.modifyTime = attributeVO.getLastModifyTime() != null ? attributeVO.getLastModifyTime().getTime():null;
|
attribItem.name = attributeVO.getId();
|
attribItem.label = attributeVO.getName();
|
attribItem.description = attributeVO.getDescription() == null ?"":attributeVO.getDescription();
|
attribItem.vtDataType = attributeVO.getAttributeDataType() == null ? VciFieldTypeEnum.VTString.name() : attributeVO.getAttributeDataType();
|
attribItem.defValue = attributeVO.getDefaultValue() == null?"":attributeVO.getDefaultValue();
|
attribItem.rage = attributeVO.getRange() == null ? "" : attributeVO.getRange();
|
//other需要自行处理
|
StringBuffer sb = new StringBuffer();
|
sb.append(ALLOWNULL).append(" = ").append(attributeVO.isNullableFlag() ? "yes" : "no").append(";");
|
VciFieldTypeEnum fieldTypeEnum = VciFieldTypeEnum.valueOf(attributeVO.getAttributeDataType());
|
String[] otherInfos = attribItem.other.split(";");
|
int length = 0;
|
if(otherInfos!=null&& otherInfos.length > 0){
|
for(String s : otherInfos){
|
if(s.contains(LENGTH+" =") || s.contains(LENGTH+"=")){
|
length = VciBaseUtil.getInt(s.split("=")[1]);
|
break;
|
}
|
}
|
}
|
switch (fieldTypeEnum) {
|
case VTDouble:
|
if(attributeVO.getAttrLength() == null){
|
attributeVO.setAttrLength(20);
|
}
|
if(attributeVO.getPrecisionLength() == null){
|
attributeVO.setPrecisionLength(2);
|
}
|
sb.append(ACCURACY).append(" = ").append(attributeVO.getPrecisionLength()).append(";");
|
sb.append(LENGTH).append(" = ").append(length > attributeVO.getAttrLength()?length:attributeVO.getAttrLength()).append(";");
|
|
break;
|
case VTInteger:
|
if (StringUtils.isNotBlank(attributeVO.getEnumId())) {
|
sb.append(ENUMNAME).append(" = ").append(attributeVO.getEnumId()).append(";");
|
}
|
break;
|
case VTString:
|
if (StringUtils.isNotBlank(attributeVO.getBtmTypeId())) {
|
//参照
|
sb.append(BTM).append(" = ").append(attributeVO.getBtmTypeId()).append(";");
|
//链接类型暂时不支持
|
}
|
sb.append(LENGTH).append(" = ").append(length > attributeVO.getAttrLength()?length:attributeVO.getAttrLength()).append(";");
|
if (StringUtils.isNotBlank(attributeVO.getEnumId())) {
|
sb.append(ENUMNAME).append(" = ").append(attributeVO.getEnumId()).append(";");
|
}
|
break;
|
default:
|
//不需要处理
|
break;
|
}
|
attribItem.other = sb.toString();
|
if (attribItem.other.endsWith(";")) {
|
attribItem.other = attribItem.other.substring(0, attribItem.other.length() - 1);
|
}
|
return attribItem;
|
}
|
|
/**
|
* 根据属性的名称获取属性对象
|
* @param attrCode 属性英文名称
|
* @return 属性的基本信息
|
*/
|
@Override
|
public OsAttributeVO getAttr(String attrCode) {
|
if(StringUtils.isBlank(attrCode)){
|
return null;
|
}
|
return self.selectAllAttributeMap().getOrDefault(attrCode.toLowerCase(),null);
|
}
|
|
/**
|
* 使用属性编号获取对象--批量
|
*
|
* @param attrCodes 属性的英文名称
|
* @return 属性的显示对象
|
*/
|
@Override
|
public List<OsAttributeVO> listAttrByIds(Collection<String> attrCodes) {
|
if(CollectionUtils.isEmpty(attrCodes)){
|
return null;
|
}
|
Map<String, OsAttributeVO> attributeVOMap = self.selectAllAttributeMap();
|
List<OsAttributeVO> attributeVOS = new ArrayList<>();
|
attrCodes.stream().forEach(attrCode->{
|
OsAttributeVO attributeVO = attributeVOMap.getOrDefault(attrCode.toLowerCase(),null);
|
if(attributeVO!=null){
|
attributeVOS.add(attributeVO);
|
}
|
});
|
return attributeVOS;
|
}
|
|
/**
|
* 批量添加属性
|
*
|
* @param attribItemList 属性的列表
|
*/
|
@Override
|
public void batchAddAttribute(List<AttributeDef> attribItemList) {
|
if(!CollectionUtils.isEmpty(attribItemList)){
|
attribItemList.stream().forEach(attribItem -> {
|
try {
|
platformClientUtil.getAttributeService().addAttributeDef(attribItem);
|
} catch (PLException e) {
|
throw WebUtil.getVciBaseException(e);
|
}
|
});
|
}
|
}
|
|
/**
|
* 批量编辑属性
|
* @param editAttrList 属性的列表
|
*/
|
@Override
|
public void batchEditAttribute(List<AttributeDef> editAttrList) {
|
if(!CollectionUtils.isEmpty(editAttrList)){
|
editAttrList.stream().forEach(attribItem -> {
|
try {
|
platformClientUtil.getAttributeService().modifyAttributeDef(attribItem);
|
} catch (PLException e) {
|
throw WebUtil.getVciBaseException(e);
|
}
|
});
|
}
|
}
|
|
/**
|
* 属性列表
|
*
|
* @param baseQueryObject 查询对象
|
* @return 属性的显示对象
|
*/
|
@Override
|
public DataGrid<OsAttributeVO> gridAttribute(BaseQueryObject baseQueryObject) {
|
return gridObject(baseQueryObject, OsAttributeDO.class,self.selectAllAttributeMap(),OsAttributeVO.class);
|
}
|
|
/**
|
* 是否默认的属性
|
*
|
* @param attr 属性编号
|
* @return true表示是默认属性
|
*/
|
@Override
|
public boolean isDefaultAttr(String attr) {
|
if(StringUtils.isBlank(attr)){
|
return false;
|
}
|
return getDefaultAttributeVOMap().containsKey(attr.toLowerCase(Locale.ROOT));
|
}
|
|
/**
|
* 是否为参照属性
|
* @param other 配置的其他
|
* @return true 是参照
|
*/
|
private boolean isReferAttr(String other){
|
if(StringUtils.isNotBlank(other)
|
&& (other.toLowerCase().contains("btm") || other.toLowerCase().contains("ltm"))){
|
//还不能确定，因为枚举的时候也会设置btm
|
String[] temp = other.split(";");
|
for(String s : temp){
|
if((s.contains("btm") || s.contains("ltm")) && s.split("=").length>1){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
|
|
/**
|
* 是否为枚举的属性
|
* @param other 配置的内容
|
* @return true 是枚举
|
*/
|
private boolean isEnumAttr(String other){
|
if(StringUtils.isNotBlank(other)
|
&& other.contains("enumName")){
|
//还不能确定，因为枚举的时候也会设置btm
|
String[] temp = other.split(";");
|
for(String s : temp){
|
if(s.contains("enumName")&& s.split("=").length>1){
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
|
|
/**
|
* 清除缓存
|
*/
|
@Override
|
public void clearCache() {
|
|
}
|
}
|
