ubcs.git - Gitblit

			@@ -2,41 +2,69 @@

			import com.alibaba.cloud.commons.lang.StringUtils;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.thoughtworks.xstream.XStream;
			import com.thoughtworks.xstream.io.xml.DomDriver;
			import com.vci.ubcs.code.bo.CodeClassifyFullInfoBO;
			import com.vci.ubcs.code.constant.MdmDuckingConstant;
			import com.vci.ubcs.code.dto.CodeOrderDTO;
			import com.vci.ubcs.code.dto.CodeOrderSecDTO;
			import com.vci.ubcs.code.entity.*;
			import com.vci.ubcs.code.enumpack.CodeSecTypeEnum;
			import com.vci.ubcs.code.enumpack.*;
			import com.vci.ubcs.code.mapper.CommonsMapper;
			import com.vci.ubcs.code.service.*;
			import com.vci.ubcs.code.util.ClientBusinessObject;
			import com.vci.ubcs.code.util.gennerAttrMapUtil;
			import com.vci.ubcs.code.vo.pagemodel.*;
			import com.vci.ubcs.code.vo.webserviceModel.apply.*;
			import com.vci.ubcs.code.vo.webserviceModel.attrmap.*;
			import com.vci.ubcs.code.vo.webserviceModel.attrmap.DataObjectVO;
			import com.vci.ubcs.code.vo.webserviceModel.classify.*;
			import com.vci.ubcs.code.vo.webserviceModel.classify.QueryClassifyVO;
			import com.vci.ubcs.code.vo.webserviceModel.classify.QueryData;
			import com.vci.ubcs.code.vo.webserviceModel.classify.QueryLibraryVO;
			import com.vci.ubcs.code.vo.webserviceModel.classify.ResultClassifyVO;
			import com.vci.ubcs.code.vo.webserviceModel.coderule.*;
			import com.vci.ubcs.code.vo.webserviceModel.data.*;
			import com.vci.ubcs.code.vo.webserviceModel.data.ResultDataVO;
			import com.vci.ubcs.code.vo.webserviceModel.result.json.*;
			import com.vci.ubcs.code.vo.webserviceModel.result.xml.XMLResultClassfyVO;
			import com.vci.ubcs.code.vo.webserviceModel.result.xml.XMLResultDataObjectDetailDO;
			import com.vci.ubcs.code.vo.webserviceModel.result.xml.XMLResultSystemVO;
			import com.vci.ubcs.code.webService.annotation.VciWebservice;
			import com.vci.ubcs.code.webService.config.AttributeMapConfig;
			import com.vci.ubcs.code.wrapper.CodeClassifyWrapper;
			import com.vci.ubcs.omd.feign.IBtmTypeClient;
			import com.vci.ubcs.omd.vo.BtmTypeVO;
			import com.vci.ubcs.starter.exception.VciBaseException;
			import com.vci.ubcs.starter.revision.model.TreeQueryObject;
			import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil;
			import com.vci.ubcs.starter.util.UBCSSqlKeyword;
			import com.vci.ubcs.starter.web.constant.QueryOptionConstant;
			import com.vci.ubcs.starter.web.pagemodel.SessionInfo;
			import com.vci.ubcs.starter.web.util.BeanUtilForVCI;
			import com.vci.ubcs.starter.web.util.VciBaseUtil;
			import com.vci.ubcs.webservice.annotation.VciWebservice;
			import com.vci.ubcs.webservice.config.AttributeMapConfig;
			import com.vci.ubcs.system.feign.ISysClient;
			import com.vci.ubcs.system.user.entity.User;
			import com.vci.ubcs.system.user.feign.IUserClient;
			import com.vci.ubcs.system.vo.DeptVO;
			import com.vci.ubcs.system.vo.RoleVO;
			import lombok.extern.slf4j.Slf4j;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springblade.core.tool.api.R;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.stereotype.Service;
			import org.springframework.util.CollectionUtils;

			import javax.annotation.Resource;
			import javax.jws.WebService;
			import java.util.*;
			import java.util.concurrent.CopyOnWriteArrayList;
			import java.util.concurrent.atomic.AtomicBoolean;
			import java.util.concurrent.atomic.AtomicReference;
			import java.util.stream.Collectors;

			import static com.vci.ubcs.code.constant.MdmEngineConstant.DEFAULT_SYNC_ATTR_LIST;
			import static com.vci.ubcs.code.enumpack.CodeSecTypeEnum.CODE_CLASSIFY_SEC;

			/***
			* 统一接口
			@@ -45,12 +73,8 @@
			@Slf4j
			@VciWebservice(path = "/universalInterface")
			public class UniversalInterfaceImpl<IDockingLogeServiceing> implements UniversalInterfaceI {

			/**
			* 日志
			*/
			private Logger logger = LoggerFactory.getLogger(getClass());

			@Value("${code.universalinterface.checkSystemConfig:true}")
			public boolean CODE_CHECKCONFIG;
			@Autowired(required = false)
			private AttributeMapConfig attributeMapConfig;
			/**
			@@ -63,6 +87,31 @@
			*/
			@Autowired(required = false)
			private ICodeClassifyService classifyService;

			/**
			* 业务类型的服务
			*/
			@Autowired
			private IBtmTypeClient btmTypeClient;

			/**
			* 人员服务
			*/
			@Autowired
			private ISysClient sysClient;

			/**
			* 人员服务
			*/
			@Autowired
			private IUserClient userClient;

			/**
			* 通用查询
			*/
			@Resource
			private CommonsMapper commonsMapper;

			/**
			* 主数据引擎的服务
			*/
			@@ -75,6 +124,13 @@

			@Resource
			private MdmIOService mdmIOService;

			@Resource
			private IDockingSystemConfigService dockingSystemConfigService;

			@Autowired
			private ICodeClassifyValueService codeClassifyValueService;

			/***
			* 集成接口日志服务的配置
			*/
			@@ -95,155 +151,191 @@
			*/
			@Override
			public String applyCode(String data, String dataType) throws Throwable {
			{
			String resultStr = "";
			String errorid="0";
			msg="成功";
			objerrorCode="0";
			objerrorMsg="成功";
			logger.info("申请编码的数据参数:->"+data);
			logger.info("申请编码的数据类型:->"+dataType);
			String systemId="";
			List<XMLResultClassfyVO> resultClassfyVOList = new ArrayList<>();
			String resultStr = "";
			final String[] errorid = {"0"};
			msg="成功";
			objerrorCode="0";
			objerrorMsg="成功";
			log.info("申请编码的数据参数:->"+data);
			log.info("申请编码的数据类型:->"+dataType);
			String systemId="";
			List<XMLResultClassfyVO> resultClassfyVOList = new ArrayList<>();
			try {
			if(StringUtils.isBlank(data)) {
			errorid[0] ="101";
			throw new Throwable("接口参数：传递为空");
			}
			InterParameterVO interParameterVO =new InterParameterVO();
			//如果dataType是xml则，通过xml序列化成对象形式，如果是json则通过json转换成对象格式
			try {
			if(StringUtils.isBlank(data)) {
			errorid="101";
			throw new Throwable("接口参数：传递为空");
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(RootDataVO.class);
			xStream.autodetectAnnotations(true);
			RootDataVO rootDataVO = (RootDataVO) xStream.fromXML(data);
			interParameterVO.setData(rootDataVO);
			} else {
			interParameterVO = JSONObject.toJavaObject(JSONObject.parseObject(data), InterParameterVO.class);
			}
			InterParameterVO interParameterVO =new InterParameterVO();
			//如果dataType是xml则，通过xml序列化成对象形式，如果是json则通过json转换成对象格式
			}catch (Throwable e){
			errorid[0] ="101";
			throw new Throwable("接口参数：传入数据参数解析失败");
			}
			ClassfysVO classfysVO = interParameterVO.getData().getClassifys();
			systemId = interParameterVO.getData().getSystemId();
			UserVO userVo = interParameterVO.getData().getUser();
			List<ClassfyVO> classVOList = classfysVO.getClassify();
			InterParameterVO finalInterParameterVO = interParameterVO;

			//这是账号信息
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
			// List<XMLResultDataObjectDetailDO> allResultDataObjectDetailDOS=new ArrayList<>();
			String finalSystemId = systemId;
			classVOList.stream().forEach(classVO -> {
			log.info("参数：分类COde:" + classVO.getClassCode());
			boolean isCodeOrGroupCode=false;
			LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
			String libray ="";
			//获取分类信息
			try {
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(RootDataVO.class);
			xStream.autodetectAnnotations(true);
			RootDataVO rootDataVO = (RootDataVO) xStream.fromXML(data);
			interParameterVO.setData(rootDataVO);
			} else {
			interParameterVO = JSONObject.toJavaObject(JSONObject.parseObject(data), InterParameterVO.class);
			libray = classVO.getLibrary();
			CodeClassifyVO codeClassifyVO = getClassfy(classVO,libray);
			log.info("end：分类查询完毕");
			//获取分类模板信息
			if(codeClassifyVO==null \|\| StringUtils.isBlank(codeClassifyVO.getOid())){
			objerrorCode="100";
			throw new Throwable ("根据传输的分类，未获取到分类信息");
			}
			}catch (Throwable e){
			errorid="101";
			throw new Throwable("接口参数：传入数据参数解析失败");
			}
			ClassfysVO classfysVO = interParameterVO.getData().getClassifys();
			systemId = interParameterVO.getData().getSystemId();
			UserVO userVo = interParameterVO.getData().getUser();
			List<ClassfyVO> classVOList = classfysVO.getClassify();
			InterParameterVO finalInterParameterVO = interParameterVO;
			String operation="";
			if(CODE_CHECKCONFIG) {
			//校验是否配置
			DockingSystemConfig dockingSystemConfig=null;
			dockingSystemConfig=checkIspass(finalSystemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_APPCODE.getValue(),codeClassifyVO.getOid());
			if(dockingSystemConfig==null){
			errorid[0] ="101";
			throw new Throwable("系统标识为【"+ finalSystemId +"】，集成分类为【"+codeClassifyVO.getName()+"】以上分类，"+sysIntegrationPushTypeEnum.ACCPET_APPCODE.getText()+"接口配置已停用或者未配置，请联系编码管理员！");
			}
			isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false;
			}
			CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid());
			if(templateVO==null\|\|StringUtils.isBlank(templateVO.getOid())){
			objerrorCode="1";
			throw new Throwable ("根据传输的分类，未获取MDM系统中对应模板");
			}
			log.info("end：模板查询完毕");
			ApplyDatasVO applyDatasVO = classVO.getObjects();
			DataObjectVO dataObjectVO = new DataObjectVO();
			List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())
			).collect(Collectors.toList());
			this.getConfigDatas(finalSystemId, libray, applyDatasVO, attrVOS, dataObjectVO);
			log.info("end：数据组织完毕");
			//规则的主键需要去获取
			CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(codeClassifyVO.getOid());
			if(classifyFullInfo==null \|\|classifyFullInfo.getCurrentClassifyVO()==null \|\| StringUtils.isBlank(classifyFullInfo.getCurrentClassifyVO().getOid())){
			objerrorCode="1";
			log.info("classifyFullInfo:"+"根据传输的分类，未获取分类相关信息");
			throw new Throwable ("根据传输的分类，未获取分类相关信息");
			}
			CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo);
			if(ruleVO==null\|\|StringUtils.isBlank(ruleVO.getOid())){
			objerrorCode="102";
			throw new Throwable ("根据传输的分类，未获取MDM系统中对应规则");
			}
			log.info("end：规则获取完毕");
			List<CodeOrderSecDTO> codeOrderSecDTOList = getRuleCodeOrderSecDTOs(classVO.getSections().getSection(), ruleVO,classifyFullInfo);
			log.info("end：码段获取完毕");
			CodeOrderDTO orderDTO = new CodeOrderDTO();
			orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//分类主键
			orderDTO.setSecDTOList(codeOrderSecDTOList);//分类码段
			mdmIOService.batchSyncApplyCode(orderDTO, dataObjectVO, resultDataObjectDetailDOs,isCodeOrGroupCode);
			//allResultDataObjectDetailDOS.add(resultDataObjectDetailDOs);
			log.info("end：申请获取完毕");
			} catch (Throwable e) {
			List<ApplyDataVO> applyDataVOList= classVO.getObjects().getObject();
			objerrorCode="1";
			if(!CollectionUtils.isEmpty(applyDataVOList)) {
			applyDataVOList.stream().forEach(applyDataVO -> {
			XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO();
			xmlResultDataObjectDetailDO.setCode("");
			xmlResultDataObjectDetailDO.setId(applyDataVO.getId());
			xmlResultDataObjectDetailDO.setErrorid(objerrorCode);
			xmlResultDataObjectDetailDO.setMsg("编码申请失败:" + e.getMessage());
			resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
			});
			}else{

			//这是账号信息
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);

			String finalSystemId = systemId;
			classVOList.stream().forEach(classVO -> {
			logger.info("参数：分类COde:" + classVO.getClassCode());
			LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
			//获取分类信息
			try {
			String libray = classVO.getLibrary();
			CodeClassifyVO codeClassifyVO = getClassfy(classVO);
			logger.info("end：分类查询完毕");
			//获取分类模板信息
			if(codeClassifyVO==null \|\| StringUtils.isBlank(codeClassifyVO.getOid())){
			objerrorCode="100";
			throw new Throwable ("根据传输的分类，未获取到分类信息");
			}
			CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid());
			if(templateVO==null\|\|StringUtils.isBlank(templateVO.getOid())){
			objerrorCode="1";
			throw new Throwable ("根据传输的分类，未获取MDM系统中对应模板");
			}
			logger.info("end：模板查询完毕");
			ApplyDatasVO applyDatasVO = classVO.getObjects();
			DataObjectVO dataObjectVO = new DataObjectVO();
			List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())
			).collect(Collectors.toList());
			this.getConfigDatas(finalSystemId, libray, applyDatasVO, attrVOS, dataObjectVO);
			logger.info("end：数据组织完毕");
			//规则的主键需要去获取
			CodeClassifyFullInfoBO classifyFullInfo = classifyService.getClassifyFullInfo(codeClassifyVO.getOid());
			if(classifyFullInfo==null \|\|classifyFullInfo.getCurrentClassifyVO()==null \|\| StringUtils.isBlank(classifyFullInfo.getCurrentClassifyVO().getOid())){
			objerrorCode="1";
			logger.info("classifyFullInfo:"+"根据传输的分类，未获取分类相关信息");
			throw new Throwable ("根据传输的分类，未获取分类相关信息");
			}
			CodeRuleVO ruleVO = engineService.getCodeRuleByClassifyFullInfo(classifyFullInfo);
			if(ruleVO==null\|\| StringUtils.isBlank(ruleVO.getOid())){
			objerrorCode="102";
			throw new Throwable ("根据传输的分类，未获取MDM系统中对应规则");
			}
			logger.info("end：规则获取完毕");
			List<CodeOrderSecDTO> codeOrderSecDTOList = getRuleCodeOrderSecDTOs(classVO.getSections().getSection(), ruleVO);
			logger.info("end：码段获取完毕");
			CodeOrderDTO orderDTO = new CodeOrderDTO();
			orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//分类主键
			orderDTO.setSecDTOList(codeOrderSecDTOList);//分类码段
			//mdmIOService.batchSyncApplyCode(orderDTO, dataObjectVO, resultDataObjectDetailDOs);
			logger.info("end：申请获取完毕");
			} catch (Throwable e) {
			XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO=new XMLResultDataObjectDetailDO();
			XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO();
			xmlResultDataObjectDetailDO.setCode("");
			xmlResultDataObjectDetailDO.setId("");
			xmlResultDataObjectDetailDO.setErrorid(objerrorCode);
			xmlResultDataObjectDetailDO.setMsg("编码申请失败:"+e.getMessage());
			xmlResultDataObjectDetailDO.setMsg("编码申请失败:" + e.getMessage());
			resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
			e.printStackTrace();
			}finally {
			XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO();
			resultClassfyVO.setClassCode(classVO.getClassCode());
			resultClassfyVO.setLibrary(classVO.getLibrary());
			resultClassfyVO.setFullclsfNamePath(classVO.getFullclsfNamePath());
			resultClassfyVO.setObjects(resultDataObjectDetailDOs);
			resultClassfyVOList.add(resultClassfyVO);
			}
			});
			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
			xmlResultSystemVO.setClassifys(resultClassfyVOList);
			xmlResultSystemVO.setMsg(msg);
			xmlResultSystemVO.setErrorid(errorid);
			resultStr= transferResultXMl(xmlResultSystemVO,dataType);
			}catch (Throwable e){
			e.printStackTrace();;
			msg="申请编码失败:"+e.getMessage();
			}finally {
			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
			xmlResultSystemVO.setClassifys(resultClassfyVOList);
			xmlResultSystemVO.setMsg(msg);
			xmlResultSystemVO.setErrorid(errorid);
			resultStr= transferResultXMl(xmlResultSystemVO,dataType);
			final boolean[] issucess = {true};
			if(!errorid.equals("0")) {
			issucess[0] = false;
			}else {
			if(!CollectionUtils.isEmpty(resultClassfyVOList)) {
			resultClassfyVOList.stream().forEach(xMLResultClassfyVO -> {
			xMLResultClassfyVO.getObjects().stream().forEach(objec -> {
			if (!(objec.getErrorid().equals("0") \|\| objec.getErrorid().equals("204"))) {
			issucess[0] = false;
			msg=objec.getMsg();
			}
			});
			});
			}

			}
			try {
			//记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "applyCode");
			}catch (Throwable e){
			e.printStackTrace();
			}finally {
			XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO();
			resultClassfyVO.setClassCode(classVO.getClassCode());
			resultClassfyVO.setLibrary(classVO.getLibrary());
			resultClassfyVO.setFullclsfNamePath(classVO.getFullclsfNamePath());
			resultClassfyVO.setObjects(resultDataObjectDetailDOs);
			resultClassfyVOList.add(resultClassfyVO);
			}
			}
			logger.info("返回参数:"+resultStr);
			});

			return resultStr;
			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
			xmlResultSystemVO.setClassifys(resultClassfyVOList);
			xmlResultSystemVO.setMsg(msg);
			xmlResultSystemVO.setErrorid(errorid[0]);
			resultStr= transferResultXMl(xmlResultSystemVO,dataType);
			}catch (Throwable e){
			e.printStackTrace();
			msg="申请编码失败:"+e.getMessage();
			/* XMLResultSystemVO XMLResultSystemVO=new XMLResultSystemVO();
			XMLResultSystemVO.setErrorid(errorid);
			XMLResultSystemVO.setMsg("申请编码失败：->"+e.getMessage());
			XMLResultSystemVO.setClassifys(resultClassfyVOList);
			resultStr=transferResultXMl(XMLResultSystemVO,dataType);

			log.error("申请编码失败：->"+e);
			return resultStr;*/
			}finally {
			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
			xmlResultSystemVO.setClassifys(resultClassfyVOList);
			xmlResultSystemVO.setMsg(msg);
			xmlResultSystemVO.setErrorid(errorid[0]);
			resultStr= transferResultXMl(xmlResultSystemVO,dataType);
			final boolean[] issucess = {true};
			if(!errorid[0].equals("0")) {
			issucess[0] = false;
			}else {
			if(!CollectionUtils.isEmpty(resultClassfyVOList)) {
			resultClassfyVOList.stream().forEach(xMLResultClassfyVO -> {
			xMLResultClassfyVO.getObjects().stream().forEach(objec -> {
			if (!(objec.getErrorid().equals("0") \|\| objec.getErrorid().equals("204"))) {
			issucess[0] = false;
			msg=objec.getMsg();
			}
			});
			});
			}

			}
			try {
			//记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "applyCode");
			}catch (Throwable e){
			e.printStackTrace();
			}
			}
			log.info("返回参数:"+resultStr);
			//调用集团申请接口申请集团码
			return resultStr;
			}


			/***
			* 统一更新接口（更改状态，更改属性信息）接口
			@@ -255,7 +347,166 @@
			@Override
			public String syncEditData(String data, String dataType) throws Throwable {

			return null;
			String resultStr = "";
			String errorid="0";
			msg="成功";
			String systemId="";
			objerrorCode="0";
			objerrorMsg="成功";
			log.info("更改编码的数据参数:->"+data);
			log.info("更改编码的数据类型:->"+dataType);
			List<XMLResultClassfyVO> resultClassfyVOList = new ArrayList<>();
			try {
			if (StringUtils.isBlank(data)) {
			errorid = "101";
			throw new Throwable("接口参数：传递为空");
			}
			InterParameterVO interParameterVO = new InterParameterVO();
			//如果dataType是xml则，通过xml序列化成对象形式，如果是json则通过json转换成对象格式
			try {
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(RootDataVO.class);
			xStream.autodetectAnnotations(true);
			RootDataVO rootDataVO = (RootDataVO) xStream.fromXML(data);
			interParameterVO.setData(rootDataVO);
			} else {
			interParameterVO = JSONObject.toJavaObject(JSONObject.parseObject(data), InterParameterVO.class);
			}
			} catch (Throwable e) {
			errorid = "101";
			throw new Throwable("接口参数：传入数据参数解析失败");

			}
			ClassfysVO classfysVO = interParameterVO.getData().getClassifys();
			systemId = interParameterVO.getData().getSystemId();
			UserVO userVo = interParameterVO.getData().getUser();
			List<ClassfyVO> classVOList = classfysVO.getClassify();
			InterParameterVO finalInterParameterVO = interParameterVO;
			//这是账号信息
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
			String finalSystemId = systemId;
			classVOList.stream().forEach(classVO->{
			log.info("参数：分类COde:" + classVO.getClassCode());
			boolean isCodeOrGroupCode=false;
			LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
			String libray ="";
			//获取分类信息
			try {
			libray = classVO.getLibrary();
			CodeClassifyVO codeClassifyVO = getClassfy(classVO,libray);
			if(codeClassifyVO==null \|\| StringUtils.isBlank(codeClassifyVO.getOid())){
			objerrorCode="100";
			throw new Throwable ("根据传输的分类，未获取到分类信息");
			}
			log.info("end：分类查询完毕");

			String operation="";
			if(CODE_CHECKCONFIG) {
			//校验是否配置
			DockingSystemConfig dockingSystemConfig= checkIspass(finalSystemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getValue(),codeClassifyVO.getOid());
			if(dockingSystemConfig==null){
			objerrorCode ="101";
			throw new Throwable("系统标识为【"+ finalSystemId +"】，集成分类为【"+codeClassifyVO.getName()+"】以上分类，"+sysIntegrationPushTypeEnum.ACCPET_EDITCODE.getText()+"接口配置已停用或者未配置，请联系编码管理员！");
			}
			isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false;
			}

			//获取分类模板信息
			CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(codeClassifyVO.getOid());
			if(templateVO==null\|\|StringUtils.isBlank(templateVO.getOid())){
			objerrorCode="102";
			throw new Throwable ("根据传输的分类，未获取MDM系统中对应模板");
			}
			log.info("end：模板查询完毕");
			ApplyDatasVO applyDatasVO = classVO.getObjects();
			DataObjectVO dataObjectVO = new DataObjectVO();
			//将默认的属性全部替换掉
			List<CodeClassifyTemplateAttrVO> attrVOS = templateVO.getAttributes().stream().filter(s -> !DEFAULT_SYNC_ATTR_LIST.contains(s.getId()) && VciBaseUtil.getBoolean(s.getFormDisplayFlag())
			).collect(Collectors.toList());
			this.getConfigDatas(finalSystemId, libray, applyDatasVO, attrVOS, dataObjectVO);
			log.info("end：数据构建完毕");
			log.info("start：修改数据执行完毕");
			mdmIOService.batchSyncEditDatas(codeClassifyVO,dataObjectVO, resultDataObjectDetailDOs,isCodeOrGroupCode);
			log.info("end：修改数据执行完毕");
			} catch (Throwable e) {
			List<ApplyDataVO> applyDataVOList= classVO.getObjects().getObject();
			objerrorCode="1";
			if(!CollectionUtils.isEmpty(applyDataVOList)) {
			applyDataVOList.stream().forEach(applyDataVO -> {
			XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO();
			xmlResultDataObjectDetailDO.setCode("");
			xmlResultDataObjectDetailDO.setId(applyDataVO.getId());
			xmlResultDataObjectDetailDO.setErrorid(objerrorCode);
			xmlResultDataObjectDetailDO.setMsg("编码更改/状态更改/删除:" + e.getMessage());
			resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
			});
			}else {

			XMLResultDataObjectDetailDO xmlResultDataObjectDetailDO = new XMLResultDataObjectDetailDO();
			xmlResultDataObjectDetailDO.setCode("");
			xmlResultDataObjectDetailDO.setId("");
			xmlResultDataObjectDetailDO.setErrorid(objerrorCode);
			xmlResultDataObjectDetailDO.setMsg("编码更改/状态更改/删除:" + e.getMessage());
			resultDataObjectDetailDOs.add(xmlResultDataObjectDetailDO);
			}
			e.printStackTrace();
			}finally {
			XMLResultClassfyVO resultClassfyVO = new XMLResultClassfyVO();
			resultClassfyVO.setClassCode(classVO.getClassCode());
			resultClassfyVO.setLibrary(classVO.getLibrary());
			resultClassfyVO.setFullclsfNamePath(classVO.getFullclsfNamePath());
			resultClassfyVO.setObjects(resultDataObjectDetailDOs);
			resultClassfyVOList.add(resultClassfyVO);
			}
			});
			}catch (Throwable e){
			e.printStackTrace();;
			msg="编码更改/状态更改/删除:"+e.getMessage();
			/* XMLResultSystemVO XMLResultSystemVO=new XMLResultSystemVO();
			XMLResultSystemVO.setErrorid(errorid);
			XMLResultSystemVO.setMsg("申请编码失败：->"+e.getMessage());
			XMLResultSystemVO.setClassifys(resultClassfyVOList);
			resultStr=transferResultXMl(XMLResultSystemVO,dataType);

			log.error("申请编码失败：->"+e);
			return resultStr;*/
			}finally {
			XMLResultSystemVO xmlResultSystemVO=new XMLResultSystemVO();
			xmlResultSystemVO.setClassifys(resultClassfyVOList);
			xmlResultSystemVO.setMsg(msg);
			xmlResultSystemVO.setErrorid(errorid);
			resultStr= transferResultXMl(xmlResultSystemVO,dataType);
			final boolean[] issucess = {true};
			if(!errorid.equals("0")) {
			issucess[0] = false;
			}else {
			if(!CollectionUtils.isEmpty(resultClassfyVOList)) {
			resultClassfyVOList.stream().forEach(xMLResultClassfyVO -> {
			xMLResultClassfyVO.getObjects().stream().forEach(objec -> {
			if (!(objec.getErrorid().equals("0") \|\| objec.getErrorid().equals("204"))) {
			issucess[0] = false;
			msg=objec.getMsg();
			}
			});
			});
			}

			}
			try {
			//记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess[0], msg, "syncEditData");
			}catch (Throwable e){
			e.printStackTrace();
			}
			}
			log.info("返回参数:"+resultStr);
			//存储日志
			return resultStr;
			}

			/***
			@@ -267,7 +518,159 @@
			*/
			@Override
			public String queryClassify(String data, String dataType) throws Throwable {
			return null;
			boolean issucess=false;
			String resultStr = "";
			String errorid="0";
			msg="成功";
			String systemId="";
			log.info("查询分类的数据参数:->"+data);
			log.info("查询分类的数据类型:->"+dataType);
			ResultClassifyVO resultClassifyVO =new ResultClassifyVO();
			List<ClassifyVO> classifyVOList=new ArrayList<>();
			ResultData resultData=new ResultData();
			try {
			if (StringUtils.isBlank(data)) {
			errorid = "101";
			throw new Throwable("接口参数：传递为空");
			}
			QueryClassifyVO queryClassifyVO = new QueryClassifyVO();
			//如果dataType是xml则，通过xml序列化成对象形式，如果是json则通过json转换成对象格式
			try {
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(QueryData.class);
			xStream.autodetectAnnotations(true);
			QueryData queryData = (QueryData) xStream.fromXML(data);
			queryClassifyVO.setData(queryData);
			} else {
			queryClassifyVO = JSONObject.toJavaObject(JSONObject.parseObject(data), QueryClassifyVO.class);
			}
			} catch (Throwable e) {
			errorid = "101";
			msg="接口参数：传入数据参数解析失败";
			e.printStackTrace();
			throw new Throwable("接口参数：传入数据参数解析失败");
			}
			QueryData queryData=queryClassifyVO.getData();
			UserVO userVo=queryData.getUser();
			systemId=queryData.getSystemId();
			QueryLibraryVO libraryVO= queryData.getLibrary();
			String libId= libraryVO.getId();
			List<String> classifyIdList= libraryVO.getClassifyid();
			List<CodeClassifyVO> codeClassifyVOS =new ArrayList<>();
			//校验是否配置
			boolean checkPass = checkIspass(systemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_QUERYCLAFILY.getValue());
			if (!checkPass) {
			errorid = "101";
			throw new Throwable("系统标识为【" + systemId + "】," + sysIntegrationPushTypeEnum.ACCPET_QUERYCLAFILY.getText() + "接口配置已停用或者未配置，请联系编码管理员！");
			}

			//这是账号信息
			//这是账号信息
			if(userVo!=null) {
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
			}else{
			errorid = "101";
			throw new Throwable("接口参数：账号信息获取失败");
			}
			List<CodeClassify> libIdDos =classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().in(CodeClassify::getId, libId));
			if(CollectionUtils.isEmpty(libIdDos)) {
			CodeClassify libCodeClassify =libIdDos.get(0);
			String oid=libCodeClassify.getOid();
			if (!CollectionUtils.isEmpty(classifyIdList)) {
			//先简称是否有关联模板，有模板要先删除
			List<CodeClassify> childCodeClassifyList = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().in(CodeClassify::getId, classifyIdList));
			List<CodeClassify>newchildCodeClassifyList=new ArrayList<>();
			if(!CollectionUtils.isEmpty(childCodeClassifyList)) {
			Map<String,String> errorMap=new HashMap<>();
			childCodeClassifyList.stream().forEach(codeClassify -> {
			CodeClassifyVO toClassifyVO= classifyService.getTopClassifyVO(codeClassify.getOid());
			if(toClassifyVO.getOid().equals(libCodeClassify.getOid())){
			newchildCodeClassifyList.add(codeClassify);
			}
			});
			Map<String/分类编号/, CodeClassify/分类对象/> classifyfCodeMap = newchildCodeClassifyList.stream().collect(Collectors.toMap(s -> s.getId(), t -> t));
			classifyIdList.stream().forEach(classifyfCode -> {
			if(!classifyfCodeMap.containsKey(classifyfCode)) {
			errorMap.put("error", errorMap.getOrDefault("error", "") + ";根据classCode：【" + classifyfCode + "】在library:【" + libCodeClassify.getId() + "】下未查询到");
			}
			});
			if(errorMap.size()>0){
			errorid = "101";
			msg = errorMap.getOrDefault("error","");
			throw new Throwable(msg);
			}
			codeClassifyVOS = classifyService.codeClassifyDO2VOs(newchildCodeClassifyList);
			}else{
			errorid = "101";
			msg = "接口参数：classCode 未查询到对应的分类信息";
			throw new Throwable(msg);
			}
			} else {
			TreeQueryObject treeQueryObject = new TreeQueryObject();
			treeQueryObject.setParentOid(oid);
			treeQueryObject.setQueryAllLevel(true);
			codeClassifyVOS = classifyService.selectCodeClassifyDOByTree(treeQueryObject);
			}
			}else{
			errorid = "101";
			throw new Throwable("接口参数：账号信息获取失败");
			}
			LibraryVO libraryVo=new LibraryVO();
			libraryVo.setId(libId);
			libraryVo.setName("");
			if(!CollectionUtils.isEmpty(codeClassifyVOS)){
			errorid = "0";
			msg="成功!";
			codeClassifyVOS.stream().forEach(codeClassifyDO -> {
			ClassifyVO classifyVO=new ClassifyVO();
			classifyVO.setId(codeClassifyDO.getOid());
			classifyVO.setLcStatus(codeClassifyDO.getLcStatus());
			classifyVO.setClassCode(codeClassifyDO.getId());
			classifyVO.setDescription(codeClassifyDO.getDescription());
			classifyVO.setName(codeClassifyDO.getName());
			classifyVO.setPid(codeClassifyDO.getParentCodeClassifyOid());
			classifyVO.setFullPathName(codeClassifyDO.getPath());
			classifyVOList.add(classifyVO);
			});
			libraryVo.setClassify(classifyVOList);
			}else{
			errorid = "100";
			msg="未查询到相关的分类信息";
			}
			issucess=true;
			resultData.setLibrary(libraryVo);
			}catch (Throwable e){
			e.printStackTrace();;
			msg="查询分类失败:"+e.getMessage();
			}finally {
			resultData.setErrorid(errorid);
			resultData.setMsg(msg);
			resultClassifyVO.setResultData(resultData);
			}
			if(dataType.equals("xml")){
			//组织返回接口信息
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(XMLResultSystemVO.class);
			xStream.autodetectAnnotations(true);
			resultStr = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(resultData);

			}else{
			Object object = JSONObject.toJSON(resultClassifyVO);
			resultStr = object.toString();
			}
			try {
			//记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess, msg, "queryClassify");
			}catch (Throwable e){
			e.printStackTrace();
			}
			log.info("返回参数:"+resultStr);
			return resultStr;
			}

			/***
			@@ -279,19 +682,668 @@
			*/
			@Override
			public String queryData(String data, String dataType) throws Throwable {
			return null;
			boolean issucess=false;
			String resultStr = "";
			String errorid="0";
			msg="成功";
			String systemId="";
			log.info("查询分类的数据参数:->"+data);
			log.info("查询分类的数据类型:->"+dataType);
			DataCondtionsVO dataCondtionsVO=new DataCondtionsVO();
			ResultDataVO resultDataVO=new ResultDataVO();
			try {
			try {
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(CondtionsVO.class);
			xStream.autodetectAnnotations(true);
			CondtionsVO condtionsVO = (CondtionsVO) xStream.fromXML(data);
			dataCondtionsVO.setCondtions(condtionsVO);
			} else {
			dataCondtionsVO = JSONObject.toJavaObject(JSONObject.parseObject(data), DataCondtionsVO.class);
			}
			} catch (Throwable e) {
			errorid = "101";
			msg = "接口参数：传入数据参数解析失败";
			e.printStackTrace();
			throw new Throwable("接口参数：传入数据参数解析失败");
			}
			CondtionsVO condtionsVO=dataCondtionsVO.getCondtions();
			systemId=condtionsVO.getSystemId();
			UserVO userVo=condtionsVO.getUser();
			CondtionVO condtionVO= condtionsVO.getCondtion();
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);

			String classCode=condtionVO.getClassCode();
			String library= condtionVO.getLibrary();
			String queryFileds= condtionVO.getQueryFileds();
			if(StringUtils.isBlank(library)){
			errorid = "101";
			msg = "接口参数：library 为null";
			throw new Throwable(msg);
			}

			/* //校验是否配置
			boolean checkPass = checkIspass(systemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_QUERYDATA.getValue());
			if (!checkPass) {
			errorid = "101";
			throw new Throwable("系统标识为【" + systemId + "】," + sysIntegrationPushTypeEnum.ACCPET_QUERYDATA.getText() + "接口配置已停用或者未配置，请联系编码管理员！");
			}
			*/
			//先简称是否有关联模板，有模板要先删除
			boolean isCodeOrGroupCode=false;
			List<CodeClassify> libIdDos =classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId,library));
			if(!CollectionUtils.isEmpty(libIdDos)){
			CodeClassify libCodeClassify=libIdDos.get(0);
			List<CodeClassify> codeClassifyList=classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId,classCode));
			if(!CollectionUtils.isEmpty(codeClassifyList)){
			final CodeClassify[] currentCodeClassify = {null};
			codeClassifyList.stream().forEach(codeClassify -> {
			CodeClassifyVO codeClassifyVO= classifyService.getTopClassifyVO(codeClassify.getOid());
			if(codeClassifyVO.getOid().equals(libCodeClassify.getOid())){
			currentCodeClassify[0] =codeClassify;
			}
			});
			if(currentCodeClassify[0]==null){
			errorid = "101";
			msg = "接口参数：classCode 未查询到对应的分类信息";
			throw new Throwable(msg);
			}

			String operation="";
			if(CODE_CHECKCONFIG) {
			//校验是否配置
			DockingSystemConfig dockingSystemConfig= checkIspass(systemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_QUERYDATA.getValue(),currentCodeClassify[0].getOid());
			if(dockingSystemConfig==null){
			errorid ="101";
			throw new Throwable("系统标识为【"+ systemId +"】，集成分类为【"+currentCodeClassify[0].getName()+"】以上分类，"+sysIntegrationPushTypeEnum.ACCPET_QUERYDATA.getText()+"接口配置已停用或者未配置，请联系编码管理员！");
			}
			isCodeOrGroupCode="true".equals(dockingSystemConfig.getIsGroupCodeFlag())?true:false;
			}
			List<CodeClassifyVO> dataCodeClassifyVOList =new ArrayList<>();
			String oid= currentCodeClassify[0].getOid();
			TreeQueryObject treeQueryObject=new TreeQueryObject();
			treeQueryObject.setParentOid(oid);
			treeQueryObject.setQueryAllLevel(true);
			dataCodeClassifyVOList=classifyService.selectCodeClassifyDOByTree(treeQueryObject);
			dataCodeClassifyVOList.add(CodeClassifyWrapper.build().entityVO(currentCodeClassify[0]));
			Map<String, CodeClassifyVO> oidCodeclassifyDOMap = dataCodeClassifyVOList.stream().filter(systeDataObject -> systeDataObject != null && StringUtils.isNotBlank(systeDataObject.getOid())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));

			List<PropertyVO> propertyVOS=condtionVO.getPro();
			List<String>statusList=new ArrayList<>();
			statusList.add(CodeDefaultLC.RELEASED.getValue());
			statusList.add(CodeDefaultLC.DISABLE.getValue());
			statusList.add(CodeDefaultLC.TASK_BACK.getValue());
			String tableName="";
			R<BtmTypeVO> r = btmTypeClient.getAllAttributeByBtmId(libCodeClassify.getBtmTypeId());
			if(!r.isSuccess()) {
			throw new Throwable(r.getMsg());
			}
			BtmTypeVO btmTypeVO = r.getData();
			if (btmTypeVO == null) {
			throw new Throwable("根据业务类型未查询到业务类型对象！");
			}
			tableName = btmTypeVO.getTableName();
			if (com.alibaba.nacos.common.utils.StringUtils.isBlank(tableName)) {
			throw new Throwable("根据业务类型未查询到业务类型相关联的表");
			}
			StringBuffer sb=new StringBuffer();
			sb.append(" select * from ");
			sb.append(tableName);
			sb.append(" where 1=1");
			if(isCodeOrGroupCode){
			sb.append(" and groupcode is not null ");
			}

			if(!CollectionUtils.isEmpty(propertyVOS)) {
			propertyVOS.stream().forEach(propertyVO -> {
			sb.append(" and " + propertyVO.getFiledName() + "='" + propertyVO.getFiledValue() + "'");
			});
			}
			sb.append(" and lastr=1 and lastv=1" );
			sb.append(" and codeclsfid in (" + VciBaseUtil.toInSql(oidCodeclassifyDOMap.keySet().toArray(new String[0])) +")");
			sb.append(" and Lcstatus in (" + VciBaseUtil.toInSql(statusList.toArray(new String[]{})) +")");
			List<Map<String,String>> newDataList= commonsMapper.queryByOnlySqlForMap(sb.toString());
			List<ClientBusinessObject> clientBusinessObjects= ChangeMapTOClientBusinessObjects(newDataList);
			List<com.vci.ubcs.code.vo.webserviceModel.data.DataObjectVO> dataObjectVOS=new ArrayList<>();
			if(!CollectionUtils.isEmpty(clientBusinessObjects)){
			CodeClassifyTemplateVO templateVO = engineService.getUsedTemplateByClassifyOid(currentCodeClassify[0].getOid());
			Map<String, CodeClassifyTemplateAttrVO> filedAttributeMap = templateVO.getAttributes().stream().filter(attribute -> attribute != null && StringUtils.isNotBlank(attribute.getId())).collect(Collectors.toList()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t));
			boolean finalIsCodeOrGroupCode = isCodeOrGroupCode;
			clientBusinessObjects.stream().forEach(cbo -> {
			com.vci.ubcs.code.vo.webserviceModel.data.DataObjectVO dataObjectVO=new com.vci.ubcs.code.vo.webserviceModel.data.DataObjectVO();
			String code="";
			if(finalIsCodeOrGroupCode){
			code= cbo.getAttributeValue("groupcode");
			}else {
			code=cbo.getId();
			}
			dataObjectVO.setCode(code);
			dataObjectVO.setStatus(cbo.getLcStatus());
			String codeclsfid=cbo.getAttributeValue("codeclsfid");
			if(oidCodeclassifyDOMap.containsKey(codeclsfid)){
			CodeClassifyVO codeClassifyVO= oidCodeclassifyDOMap.get(codeclsfid);
			dataObjectVO.setClassCode(codeClassifyVO.getId());
			}
			dataObjectVO.setLibrary(library);
			String [] newQueryFileds=queryFileds.split(",");
			List<PropertyVO> propertyVOList=new ArrayList<>();
			for(String filed:newQueryFileds){
			if(filedAttributeMap.containsKey(filed.toLowerCase(Locale.ROOT))){
			String value=cbo.getAttributeValue(filed);
			CodeClassifyTemplateAttrVO attrVO= filedAttributeMap.get(filed.toLowerCase(Locale.ROOT));
			PropertyVO propertyVO=new PropertyVO();
			propertyVO.setFiledName(filed);
			propertyVO.setFiledValue(value);
			propertyVO.setOutname(attrVO.getName());
			propertyVOList.add(propertyVO);
			}
			}
			dataObjectVO.setPro(propertyVOList);
			dataObjectVOS.add(dataObjectVO);
			});
			resultDataVO.setObject(dataObjectVOS);
			}
			}else{
			errorid = "101";
			msg = "接口参数：classCode 未查询到对应的分类信息";
			throw new Throwable(msg);
			}
			}else{
			errorid = "101";
			msg = "接口参数：library 未查询到对应的库节点信息";
			}
			errorid = "0";
			msg = "数据查询成功";
			}catch (Throwable e){
			e.printStackTrace();;
			msg="查询数据失败:"+e.getMessage();
			}finally {
			resultDataVO.setErrorid(errorid);
			resultDataVO.setMsg(msg);
			}
			ResultVO resultVO=new ResultVO();
			resultVO.setData(resultDataVO);
			if(dataType.equals("xml")){
			//组织返回接口信息
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(XMLResultSystemVO.class);
			xStream.autodetectAnnotations(true);
			resultStr = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(resultDataVO);
			}else{
			Object object = JSONObject.toJSON(resultVO);
			resultStr = object.toString();
			}
			try { //记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess, msg, "queryData");
			}catch (Throwable e){
			e.printStackTrace();
			}
			log.info("返回参数:"+resultStr);
			return resultStr;
			}



			@Override
			public String queryClassifyRule(String data, String datatype) throws Throwable {
			return null;
			public String queryClassifyRule(String data, String dataType) throws Throwable {

			boolean issucess=false;
			String resultStr = "";
			String errorid="0";
			msg="成功";
			String systemId="";
			log.info("查询分类的数据参数:->"+data);
			log.info("查询分类的数据类型:->"+dataType);
			ResultClassifyRuleVO resultClassifyRuleVO =new ResultClassifyRuleVO();
			List<com.vci.ubcs.code.vo.webserviceModel.coderule.ResultClassifyVO> classifyVOList=new ArrayList<>();
			ResultClassifyRuleData resultClassifyRuleData=new ResultClassifyRuleData();
			try {
			if (StringUtils.isBlank(data)) {
			errorid = "101";
			throw new Throwable("接口参数：传递为空");
			}
			QueryClassifyVO queryClassifyVO = new QueryClassifyVO();
			//如果dataType是xml则，通过xml序列化成对象形式，如果是json则通过json转换成对象格式
			try {
			if ("xml".equals(dataType)) {
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(QueryData.class);
			xStream.autodetectAnnotations(true);
			QueryData queryData = (QueryData) xStream.fromXML(data);
			queryClassifyVO.setData(queryData);
			} else {
			queryClassifyVO = JSONObject.toJavaObject(JSONObject.parseObject(data), QueryClassifyVO.class);
			}
			} catch (Throwable e) {
			errorid = "101";
			msg = "接口参数：传入数据参数解析失败";
			e.printStackTrace();
			throw new Throwable("接口参数：传入数据参数解析失败");
			}
			QueryData queryData=queryClassifyVO.getData();
			UserVO userVo=queryData.getUser();
			systemId=queryData.getSystemId();
			QueryLibraryVO libraryVO= queryData.getLibrary();
			String libId= libraryVO.getId();
			List<String> classifyIdList= libraryVO.getClassifyid();
			List<CodeClassifyVO> codeClassifyVOS =new ArrayList<>();

			//校验是否配置
			boolean checkPass = checkIspass(systemId, SysIntegrationDataFlowTypeEnum.ACCEPT.getValue(), sysIntegrationPushTypeEnum.ACCPET_QUERYCLAFILYRULE.getValue());
			if (!checkPass) {
			errorid = "101";
			throw new Throwable("系统标识为【" + systemId + "】," + sysIntegrationPushTypeEnum.ACCPET_QUERYCLAFILYRULE.getText() + "接口配置已停用或者未配置，请联系编码管理员！");
			}

			//这是账号信息
			//这是账号信息
			if(userVo!=null) {
			SessionInfo sessionInfo = new SessionInfo();
			sessionInfo.setUserId(userVo.getUserName());
			sessionInfo.setUserName(userVo.getTrueName());
			sessionInfo.setIp(userVo.getIp());
			VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
			}else{
			errorid = "101";
			throw new Throwable("接口参数：账号信息获取失败");
			}
			if(!CollectionUtils.isEmpty(classifyIdList)){
			//先简称是否有关联模板，有模板要先删除
			List<CodeClassify> libIdDos = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().in(CodeClassify::getId, classifyIdList));
			codeClassifyVOS=classifyService.codeClassifyDO2VOs(libIdDos);
			}else {
			List<CodeClassify> libIdDos = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId, libId));
			String oid= libIdDos.get(0).getOid();
			TreeQueryObject treeQueryObject=new TreeQueryObject();
			treeQueryObject.setParentOid(oid);
			treeQueryObject.setQueryAllLevel(true);
			codeClassifyVOS=classifyService.selectCodeClassifyDOByTree(treeQueryObject);
			}
			ResultLibraryVO resultLibraryVO=new ResultLibraryVO();
			resultLibraryVO.setId(libId);
			resultLibraryVO.setName("");
			if(!CollectionUtils.isEmpty(codeClassifyVOS)){
			errorid = "0";
			msg="成功!";
			codeClassifyVOS.stream().forEach(codeClassifyDO -> {
			//后去包含码段的编码规则
			CodeRuleVO codeRuleVO= this.engineService.getCodeRuleByClassifyOid(codeClassifyDO.getOid());
			ResultCodeRuleVO resultCodeRuleVO=new ResultCodeRuleVO();
			if(codeRuleVO!=null){
			CodeRuleVO resultClassifyRuleVO1=new CodeRuleVO();
			List<CodeBasicSecVO> codeBasicSecVOS= codeRuleVO.getSecVOList();
			List<CodeSectionVO> codeSectionVOList=new CopyOnWriteArrayList<>();
			Map<String,List<String>> secIdTOListValueOidMap=new HashMap<>();
			if(!CollectionUtils.isEmpty(codeBasicSecVOS)){
			codeBasicSecVOS.stream().forEach(codeBasicSecVO -> {
			List<CodeSectionValueVO> codeSectionValueVOList=new ArrayList<>();
			String secType= codeBasicSecVO.getSecType();
			if(secType.equals("codevariablesec")){//可变码段
			//空着，前端传
			}else if(secType.equals("codefixedsec")){//固定码段
			List<CodeFixedValueVO> fixedValueVOList=codeBasicSecVO.getFixedValueVOList();
			fixedValueVOList.stream().forEach(codeFixedValueVO -> {
			String id=StringUtils.isBlank(codeFixedValueVO.getOid())?"":codeFixedValueVO.getOid();
			String value=StringUtils.isBlank(codeFixedValueVO.getId())?"":codeFixedValueVO.getId();
			String num=StringUtils.isBlank(codeFixedValueVO.getOrderNum()+"")?"":codeFixedValueVO.getOrderNum()+"";
			String name=StringUtils.isBlank(codeFixedValueVO.getName())?"":codeFixedValueVO.getName();
			String description=StringUtils.isBlank(codeFixedValueVO.getDescription())?"":codeFixedValueVO.getDescription();
			CodeSectionValueVO sectionValueVO=new CodeSectionValueVO(id,num,value,name,"",description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}else if(secType.equals("codeclassifysec")){//分类码段
			String secOid=codeBasicSecVO.getOid();
			String parentClassifySecOid= codeBasicSecVO.getParentClassifySecOid();
			String parentClassifyValueOid="";
			if(secIdTOListValueOidMap.containsKey(parentClassifySecOid)){
			List<String> parentClassifyValueList= secIdTOListValueOidMap.get(parentClassifySecOid);
			parentClassifyValueOid=VciBaseUtil.array2String(parentClassifyValueList.toArray(new String[]{}));
			}
			List<CodeClassifyValueVO> codeClassifyValueVOS= this.codeClassifyValueService.listCodeClassifyValueBySecOid(secOid,parentClassifyValueOid);
			if(!CollectionUtils.isEmpty(codeClassifyValueVOS)){
			List<String>valueOidList=new ArrayList<>();

			codeClassifyValueVOS.stream().forEach(codeClassifyValueVO -> {
			String id=StringUtils.isBlank(codeClassifyValueVO.getOid())?"":codeClassifyValueVO.getOid();
			String value=StringUtils.isBlank(codeClassifyValueVO.getId())?"":codeClassifyValueVO.getId();
			String num=StringUtils.isBlank(codeClassifyValueVO.getOrderNum()+"")?"":codeClassifyValueVO.getOrderNum()+"";
			String name=StringUtils.isBlank(codeClassifyValueVO.getName())?"":codeClassifyValueVO.getName();
			String pid=StringUtils.isBlank(codeClassifyValueVO.getParentClassifyValueOid())?"":codeClassifyValueVO.getParentClassifyValueOid();
			String description=StringUtils.isBlank(codeClassifyValueVO.getDescription())?"":codeClassifyValueVO.getDescription();
			CodeSectionValueVO sectionValueVO=new CodeSectionValueVO(id,num,value,name,pid,description);
			codeSectionValueVOList.add(sectionValueVO);
			valueOidList.add(id);
			});
			secIdTOListValueOidMap.put(secOid,valueOidList);
			}
			}else if(secType.equals("codedatesec")){//日期码段
			//空着，前端传
			}else if(secType.equals("coderefersec")){//引用码段
			codeBasicSecVO.getReferAttributeId();
			codeBasicSecVO.getReferCodeClassifyOid();
			String referBtmId=codeBasicSecVO.getReferBtmId();
			String btmName=codeBasicSecVO.getReferBtmName();
			String referConfig= codeBasicSecVO.getReferConfig();
			CoderefersecSearchVO coderefersecSearchVO=new CoderefersecSearchVO();
			if(StringUtils.isNotBlank(referConfig)){
			coderefersecSearchVO = JSONObject.toJavaObject(JSONObject.parseObject(referConfig), CoderefersecSearchVO.class);
			}
			String buildSqlwhere="";
			if(coderefersecSearchVO!=null) {
			if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.DEFAULT.getValue()) \|\| coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.GRID.getValue())) {//默认样式/列表
			Map<String, Object> condtionMap = new HashMap<>();
			List<CodeSrchCondConfigVO> codeSrchCondConfigVOList = coderefersecSearchVO.getCodeSrchCondConfigVOS();

			if (!CollectionUtils.isEmpty(codeSrchCondConfigVOList)) {
			codeSrchCondConfigVOList.stream().forEach(codeSrchCondConfigVO -> {
			condtionMap.put(codeSrchCondConfigVO.getFilterField() + codeSrchCondConfigVO.getFilterType(), codeSrchCondConfigVO.getFilterValue());
			});
			buildSqlwhere = UBCSSqlKeyword.buildSqlwhere(condtionMap);
			}

			//使用传入的业务类型查询表
			R<List<BtmTypeVO>> listR = btmTypeClient.selectByIdCollection(Collections.singletonList(referBtmId));
			if (!listR.isSuccess() \|\| listR.getData().size() == 0) {
			throw new VciBaseException("传入业务类型未查询到相应表单，请检查！");
			}
			String referTable = listR.getData().get(0).getTableName();
			StringBuffer sb = new StringBuffer();
			sb.append(" select * from ");
			sb.append(referTable);
			sb.append(" where 1=1 ");
			if (StringUtils.isNotBlank(buildSqlwhere)) {
			sb.append(buildSqlwhere);
			}
			List<Map> ListMap = commonsMapper.selectBySql(sb.toString());
			String valueField = coderefersecSearchVO.getValueField();
			String textField = coderefersecSearchVO.getTextField();
			final int[] num = {0};
			if (!CollectionUtils.isEmpty(ListMap)) {
			ListMap.stream().forEach(map -> {
			num[0]++;
			String id = map.getOrDefault("OID".toUpperCase(Locale.ROOT), "").toString();
			String value = map.getOrDefault(valueField.toUpperCase(Locale.ROOT), "").toString();
			String text = map.getOrDefault(textField.toUpperCase(Locale.ROOT), "").toString();
			String description = map.getOrDefault("description".toUpperCase(Locale.ROOT), "").toString();
			CodeSectionValueVO sectionValueVO = new CodeSectionValueVO(id, num[0] + "", value, text, "", description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}
			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.TREE.getValue())) {//树形
			Map<String, Object> condtionMap = new HashMap<>();

			//使用传入的业务类型查询表
			R<List<BtmTypeVO>> listR = btmTypeClient.selectByIdCollection(Collections.singletonList(referBtmId));
			if (!listR.isSuccess() \|\| listR.getData().size() == 0) {
			throw new VciBaseException("传入业务类型未查询到相应表单，请检查！");
			}
			String referTable = listR.getData().get(0).getTableName();

			String oidFieldName = StringUtils.isNotBlank(coderefersecSearchVO.getParentUsedField())?coderefersecSearchVO.getParentUsedField():coderefersecSearchVO.getValueField();
			String parentValue =coderefersecSearchVO.getParentValue();
			String parentFieldName =StringUtils.isBlank(coderefersecSearchVO.getParentFieldName())?"":coderefersecSearchVO.getParentFieldName();
			List<CodeSrchCondConfigVO> codeSrchCondConfigVOList = coderefersecSearchVO.getCodeSrchCondConfigVOS();
			List<CodeShowFieldConfigVO> codeShowFieldConfigVOS=coderefersecSearchVO.getCodeShowFieldConfigVOS();
			if (!CollectionUtils.isEmpty(codeSrchCondConfigVOList)) {
			codeSrchCondConfigVOList.stream().forEach(codeSrchCondConfigVO -> {
			condtionMap.put(codeSrchCondConfigVO.getFilterField() + codeSrchCondConfigVO.getFilterType(), codeSrchCondConfigVO.getFilterValue());
			});
			buildSqlwhere = UBCSSqlKeyword.buildSqlwhere(condtionMap);
			}

			//if("all".equals(coderefersecSearchVO.getLoadType())) {
			String parentOidSql = "";
			if(StringUtils.isNotBlank(parentValue)){
			String temp=parentValue;
			if(temp.startsWith(QueryOptionConstant.IN)){
			temp = temp.substring((QueryOptionConstant.IN).length()).trim();
			parentOidSql = " in " + ((temp.startsWith("(") && temp.endsWith(")"))?temp:"(" + temp + ")");
			}else if(temp.startsWith(QueryOptionConstant.NOTIN)){
			parentOidSql = " not in " + ((temp.startsWith("(") && temp.endsWith(")"))?temp:"(" + temp + ")");
			}else if(temp.startsWith(QueryOptionConstant.NOTEQUAL)){
			temp = temp.substring((QueryOptionConstant.NOTEQUAL).length()).trim();
			parentOidSql = QueryOptionConstant.NOTEQUAL + " " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}else if(temp.startsWith(QueryOptionConstant.MORETHAN)){
			temp = temp.substring((QueryOptionConstant.MORETHAN).length()).trim();
			parentOidSql = QueryOptionConstant.MORETHAN + " " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}else if(temp.startsWith(QueryOptionConstant.MORE)){
			temp = temp.substring((QueryOptionConstant.MORE).length()).trim();
			parentOidSql = QueryOptionConstant.MORE + " " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}else if(temp.startsWith(QueryOptionConstant.LESSTHAN)){
			temp = temp.substring((QueryOptionConstant.LESSTHAN).length()).trim();
			parentOidSql = QueryOptionConstant.LESSTHAN + " " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}else if(temp.startsWith(QueryOptionConstant.LESS)){
			temp = temp.substring((QueryOptionConstant.LESS).length()).trim();
			parentOidSql = QueryOptionConstant.LESS + " " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}else if (temp.startsWith(QueryOptionConstant.ISNOTNULL)) {
			parentOidSql = " is not null";
			} else if (temp.startsWith(QueryOptionConstant.ISNULL)) {
			parentOidSql = " is null";
			} else if(temp.contains("*")){
			parentOidSql = " like " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'").replace("*","%");
			}else {
			parentOidSql = " = " + ((temp.startsWith("'") && temp.endsWith("'"))?temp:"'" + temp + "'");
			}
			}
			//查询全部的信息
			buildSqlwhere+= " and oid in (select oid from " +referTable + " START WITH " + coderefersecSearchVO.getParentFieldName() + " "+
			parentOidSql +
			" CONNECT BY PRIOR " + oidFieldName + " = " + parentFieldName + ")";

			/*}else{
			if(StringUtils.isNotBlank(coderefersecSearchVO.getParentFieldName()) && StringUtils.isNotBlank(parentValue)){
			buildSqlwhere+=" and "+coderefersecSearchVO.getParentFieldName()+"= '"+parentValue+"'";
			}
			}*/

			StringBuffer sb = new StringBuffer();
			sb.append(" select * from ");
			sb.append(referTable);
			sb.append(" where 1=1 ");
			if (StringUtils.isNotBlank(buildSqlwhere)) {
			sb.append(buildSqlwhere);
			}
			List<Map> ListMap = commonsMapper.selectBySql(sb.toString());
			String valueField = coderefersecSearchVO.getValueField();
			String textField = coderefersecSearchVO.getTextField();
			final int[] num = {0};
			if (!CollectionUtils.isEmpty(ListMap)) {
			ListMap.stream().forEach(map -> {
			num[0]++;
			String id = map.getOrDefault("OID".toUpperCase(Locale.ROOT), "").toString();
			String value = map.getOrDefault(valueField.toUpperCase(Locale.ROOT), "").toString();
			String text = map.getOrDefault(textField.toUpperCase(Locale.ROOT), "").toString();
			String description = map.getOrDefault("description".toUpperCase(Locale.ROOT), "").toString();
			String pid = map.getOrDefault(parentFieldName.toUpperCase(Locale.ROOT), "").toString();
			CodeSectionValueVO sectionValueVO = new CodeSectionValueVO(id, num[0] + "", value, text, pid, description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}


			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.ORGDEPARTMENTGRIDREFERS.getValue()) \|\|////部门列表
			coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.ORGDEPARTMENTREFER.getValue())//部门树
			) {
			R<List<DeptVO>> r = sysClient.deptList("");
			if (r.isSuccess()) {
			List<DeptVO> deptVOList = r.getData();
			if (!CollectionUtils.isEmpty(deptVOList)) {
			deptVOList.stream().forEach(deptVO -> {
			String id = String.valueOf(deptVO.getId());
			int num = deptVO.getSort();
			String value = String.valueOf(deptVO.getId());
			String text = deptVO.getDeptName();
			String description = deptVO.getRemark();
			String pid = deptVO.getParentId() + "";
			CodeSectionValueVO sectionValueVO = new CodeSectionValueVO(id, num + "", value, text, pid, description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}
			}
			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.SMUSERREFER.getValue())//用户
			\|\| coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.SMUSERGRIDREFER.getValue())//用户列表
			) {
			R<List<User>> r=userClient.selectAllUser();
			if (r.isSuccess()) {
			List<User> userList = r.getData();
			if (!CollectionUtils.isEmpty(userList)) {
			final int[] num = {0};
			userList.stream().forEach(user -> {
			String value=StringUtils.isBlank(user.getAccount())?"":user.getAccount();
			//String value= String.valueOf(StringUtils.isBlank(user.getCode())?"":user.getCode());
			String text=StringUtils.isBlank(user.getName())?"":user.getName();
			String pid=user.getDeptId();
			num[0]++;
			String description="";
			String id= String.valueOf(user.getId());
			CodeSectionValueVO sectionValueVO = new CodeSectionValueVO(id, num[0] + "", value, text, pid, description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}
			}

			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.SMROLEREFER.getValue())) {//角色列表

			R<List<RoleVO>> r = sysClient.roleTree("");
			if (r.isSuccess()) {
			List<RoleVO> roleVOList = r.getData();
			if (!CollectionUtils.isEmpty(roleVOList)) {
			roleVOList.stream().forEach(roleVO -> {
			String id = String.valueOf(roleVO.getId());
			int num = roleVO.getSort();
			String value = String.valueOf(roleVO.getId());
			String text = roleVO.getRoleName();
			String description = roleVO.getRoleAlias();
			String pid = roleVO.getParentId() + "";
			CodeSectionValueVO sectionValueVO = new CodeSectionValueVO(id, num + "", value, text, pid, description);
			codeSectionValueVOList.add(sectionValueVO);
			});
			}
			}
			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.ORGDUTYREFER.getValue())) {//职务


			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.SMWORKTYPEREFER.getValue())) {//工种


			} else if (coderefersecSearchVO.getType().equals(CodeReferConfigTypeEnum.WFPROCESSTEMPLATEREFER.getValue())) {//流程模板

			}
			}
			log.info(libId);
			}else if(secType.equals("codelevelsec")) {//层级码段
			int level = codeBasicSecVO.getCodeLevelValue();
			CodeClassifyVO levelCodeClassifyVO = new CodeClassifyVO();
			CodeClassifyFullInfoBO classifyFullInfoBO = this.classifyService.getClassifyFullInfo(codeClassifyDO.getOid());
			if(codeBasicSecVO.getCodeLevelType().equals("code_level_special")){//指定层级
			List<CodeClassifyVO> classifyVOS = classifyFullInfoBO.getParentClassifyVOs().stream().sorted(((o1, o2) -> o2.getDataLevel().compareTo(o1.getDataLevel()))).collect(Collectors.toList());
			if (classifyVOS.size() >= level && level > 0) {
			levelCodeClassifyVO = classifyVOS.get(level - 1);
			}
			}else{//最小层
			levelCodeClassifyVO=codeClassifyDO;
			}
			String id=StringUtils.isBlank(levelCodeClassifyVO.getOid())?"":levelCodeClassifyVO.getOid();
			String num="";
			String value=StringUtils.isBlank(levelCodeClassifyVO.getId())?"":levelCodeClassifyVO.getId();
			String name=StringUtils.isBlank(levelCodeClassifyVO.getName())?"":levelCodeClassifyVO.getName();
			String description=StringUtils.isBlank(levelCodeClassifyVO.getDescription())?"":levelCodeClassifyVO.getDescription();
			CodeSectionValueVO sectionValueVO=new CodeSectionValueVO(id,num,value,name,"",description);
			codeSectionValueVOList.add(sectionValueVO);
			}else if(secType.equals("codeattrsec")){//属性码段
			codeBasicSecVO.getReferAttributeId();
			codeBasicSecVO.getReferCodeClassifyOid();
			codeBasicSecVO.getReferBtmId();
			codeBasicSecVO.getReferBtmName();
			}else if(secType.equals("codeserialsec")){//流水码段

			}
			//构建规则码段
			CodeSectionVO codeSectionVO=new CodeSectionVO();
			codeSectionVO.setId(StringUtils.isBlank(codeBasicSecVO.getOid())?"":codeBasicSecVO.getOid());//主键
			codeSectionVO.setName(StringUtils.isBlank(codeBasicSecVO.getName())?"":codeBasicSecVO.getName());//码段名称
			codeSectionVO.setCodeSecLength(StringUtils.isBlank(codeBasicSecVO.getCodeSecLength())?"":codeBasicSecVO.getCodeSecLength());//码段长度
			codeSectionVO.setNum(StringUtils.isBlank(codeBasicSecVO.getOrderNum()+"")?"":codeBasicSecVO.getOrderNum()+"");//码段序号
			codeSectionVO.setCodeDateFormatStr(StringUtils.isBlank(codeBasicSecVO.getCodeDateFormatStr())?"":codeBasicSecVO.getCodeDateFormatStr());//日期类型
			codeSectionVO.setCodeSecLengthType(StringUtils.isBlank(codeBasicSecVO.getCodeSecLengthType())?"":codeBasicSecVO.getCodeSecLengthType());//码段长度类型
			codeSectionVO.setPkCodeRule(StringUtils.isBlank(codeRuleVO.getOid())?"":codeRuleVO.getOid());//规则主键
			codeSectionVO.setSecType(StringUtils.isBlank(codeBasicSecVO.getSecType())?"":codeBasicSecVO.getSecType());//码段类型
			codeSectionVO.setDescription(StringUtils.isBlank(codeBasicSecVO.getDescription())?"":codeBasicSecVO.getDescription());//描述
			codeSectionVO.setParentClassifySecOid(StringUtils.isBlank(codeBasicSecVO.getParentClassifySecOid())?"":codeBasicSecVO.getParentClassifySecOid());//分类码段上级
			codeSectionVO.setSecTypeText(StringUtils.isBlank(codeBasicSecVO.getSecTypeText())?"":codeBasicSecVO.getSecTypeText());
			//if(!CollectionUtils.isEmpty(codeSectionValueVOList)) {
			codeSectionVO.setSectionValue(codeSectionValueVOList);
			//}
			codeSectionVO.setSectionCode(codeBasicSecVO.getId());//码段编号
			codeSectionVOList.add(codeSectionVO);
			});
			}
			//构建规则信息
			resultCodeRuleVO.setId(StringUtils.isBlank(codeRuleVO.getOid())?"":codeRuleVO.getOid());//主键
			resultCodeRuleVO.setNum("");//序号
			resultCodeRuleVO.setName(StringUtils.isBlank(codeRuleVO.getName())?"":codeRuleVO.getName());//名称设置
			resultCodeRuleVO.setRuleCode(StringUtils.isBlank(codeRuleVO.getId())?"":codeRuleVO.getId());//规则编号
			resultCodeRuleVO.setDescription(StringUtils.isBlank(codeRuleVO.getDescription())?"":codeRuleVO.getDescription());//描述
			resultCodeRuleVO.setCodeSection(codeSectionVOList);
			}
			//构建分类信息
			com.vci.ubcs.code.vo.webserviceModel.coderule.ResultClassifyVO classifyVO=new com.vci.ubcs.code.vo.webserviceModel.coderule.ResultClassifyVO();
			classifyVO.setId(StringUtils.isBlank(codeClassifyDO.getOid())?"":codeClassifyDO.getOid());
			classifyVO.setLcStatus(StringUtils.isBlank(codeClassifyDO.getLcStatus())?"":codeClassifyDO.getLcStatus());
			classifyVO.setClassCode(StringUtils.isBlank(codeClassifyDO.getId())?"":codeClassifyDO.getId());
			classifyVO.setDescription(StringUtils.isBlank(codeClassifyDO.getDescription())?"":codeClassifyDO.getDescription());
			classifyVO.setName(StringUtils.isBlank(codeClassifyDO.getName())?"":codeClassifyDO.getName());
			classifyVO.setPid(StringUtils.isBlank(codeClassifyDO.getParentCodeClassifyOid())?"":codeClassifyDO.getParentCodeClassifyOid());
			classifyVO.setFullPathName(StringUtils.isBlank(codeClassifyDO.getPath())?"":codeClassifyDO.getPath());
			classifyVO.setCodeRule(resultCodeRuleVO);
			classifyVOList.add(classifyVO);
			});
			resultLibraryVO.setClassify(classifyVOList);
			}else{
			errorid = "100";
			msg="未查询到相关的分类信息";
			}
			issucess=true;
			resultClassifyRuleData.setLibrary(resultLibraryVO);
			}catch (Throwable e){
			e.printStackTrace();;
			msg="查询分类失败:"+e.getMessage();
			}finally {
			resultClassifyRuleData.setErrorid(errorid);
			resultClassifyRuleData.setMsg(msg);
			resultClassifyRuleVO.setData(resultClassifyRuleData);
			}
			if(dataType.equals("xml")){
			//组织返回接口信息
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(XMLResultSystemVO.class);
			xStream.autodetectAnnotations(true);
			resultStr = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(resultClassifyRuleData);

			}else{
			Object object = JSONObject.toJSON(resultClassifyRuleVO);
			resultStr = object.toString();
			}
			try {
			//记录日志
			this.saveLogs(systemId, systemId, data, resultStr, issucess, msg, "queryClassifyRule");
			}catch (Throwable e){
			e.printStackTrace();
			}
			log.info("返回参数:"+resultStr);
			return resultStr;
			}

			/***
			* 查询校验分类信息
			* @param classfyVO
			*/
			private CodeClassifyVO getClassfy(ClassfyVO classfyVO) throws Throwable{
			private CodeClassifyVO getClassfy(ClassfyVO classfyVO,String libray) throws Throwable{
			CodeClassifyVO classifyVO = new CodeClassifyVO();
			try {
			String classCode = classfyVO.getClassCode();
			@@ -300,13 +1352,19 @@
			if (StringUtils.isNotBlank(classfyVO.getClassCode())) {
			Map<String, String> conditionMap = new HashMap<>();
			List<CodeClassify> codeClassifyList = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId, classCode));
			final CodeClassify[] newCodeClassify = {new CodeClassify()};
			if (!CollectionUtils.isEmpty(codeClassifyList)) {
			CodeClassify classifyDO = codeClassifyList.get(0);
			//将DTO转换为DO
			codeClassifyList.stream().forEach(codeClassify -> {
			CodeClassifyVO codeClassifyVO= classifyService.getTopClassifyVO(codeClassify.getOid());
			if(codeClassifyVO.getId().equals(libray)){
			newCodeClassify[0] =codeClassify;
			}
			});
			classifyVO = new CodeClassifyVO();
			BeanUtilForVCI.copyPropertiesIgnoreCase(classifyDO, classifyVO);
			BeanUtilForVCI.copyPropertiesIgnoreCase(newCodeClassify[0], classifyVO);
			//将DTO转换为DO
			if(StringUtils.isBlank(classifyVO.getOid())){
			throw new Throwable("根据分类代号未查询到相应的分类信息");
			throw new Throwable("申请编码的分类：【"+classCode+"】不属于库节点【"+libray+"】，请检查参数分类节点/库节点信息是否匹配");
			}
			}else{
			throw new Throwable("根据分类代号未查询到相应的分类信息");
			@@ -319,39 +1377,82 @@
			}
			}catch (Throwable e){
			objerrorCode="100";
			new Throwable("获取分类信息失败:"+e.getMessage());
			throw new Throwable("获取分类信息失败:"+e.getMessage());
			}
			return classifyVO;
			}

			private List<ClientBusinessObject> ChangeMapTOClientBusinessObjects(List<Map<String,String>> oldDataMap){
			List<ClientBusinessObject> clientBusinessObjectList=new ArrayList<>();
			oldDataMap.stream().forEach(dataMap->{
			ClientBusinessObject clientBusinessObject=new ClientBusinessObject();
			DefaultAttrAssimtUtil.copplyDefaultAttrAssimt(dataMap,clientBusinessObject);
			for (String key:dataMap.keySet()){
			Object value= dataMap.getOrDefault(key,"");
			clientBusinessObject.setAttributeValue(key.toLowerCase(Locale.ROOT),value==null?"":value.toString());
			}
			clientBusinessObjectList.add(clientBusinessObject);
			});
			return clientBusinessObjectList;
			}
			/***
			* 根据穿入的参数信息校验码段规则
			*/
			private List<CodeOrderSecDTO> getRuleCodeOrderSecDTOs(List<SectionVO> SectionVOList,CodeRuleVO ruleVO) throws Throwable{
			private List<CodeOrderSecDTO> getRuleCodeOrderSecDTOs(List<SectionVO> SectionVOList,CodeRuleVO ruleVO,CodeClassifyFullInfoBO classifyFullInfo) throws Throwable{
			List<CodeBasicSecVO> codeBasicSecVOS= ruleVO.getSecVOList();
			Map<String,String> sectionVOMap=new HashMap<>();
			SectionVOList.stream().forEach(SectionVO->{
			sectionVOMap.put(SectionVO.getName(),SectionVO.getValue());
			});
			Map<String,CodeClassifyVO> codeClassifyVOMap= classifyFullInfo.getParentClassifyVOs().stream().collect(Collectors.toMap(s -> s.getId(), t -> t,(o1, o2)->o2));
			List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>();
			Map<String,String> errorMap=new HashMap<>();
			for(CodeBasicSecVO codeBasicSecVO: codeBasicSecVOS) {
			String sectype = codeBasicSecVO.getSecType();
			String classifySecOid= codeBasicSecVO.getOid();
			String message="";
			if (!sectype.equals(CodeSecTypeEnum.CODE_SERIAL_SEC.getValue())) {
			String name = codeBasicSecVO.getName();
			String sectypeText = codeBasicSecVO.getSecTypeText();
			logger.info("码段名称:"+name);
			logger.info("描述:"+sectypeText);
			log.info("码段名称:"+name);
			log.info("描述:"+sectypeText);
			CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO();
			if (sectionVOMap.containsKey(name)) {
			CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid());
			String sectypeValue = sectionVOMap.get(name);
			logger.info("码段值:"+sectypeValue);
			log.info("码段值:"+sectypeValue);
			CodeSecTypeEnum secType = CodeSecTypeEnum.forValue(sectype);
			if(CODE_CLASSIFY_SEC.equals(secType)) {//如果是分类的话，则需要匹配传过来的分类代号与
			//先简称是否有关联模板，有模板要先删除
			List<CodeClassifyValue> codeClassifyValueDOList = codeClassifyValueService.list(Wrappers.<CodeClassifyValue>query().lambda().eq(CodeClassifyValue::getCodeClassifySecOid,classifySecOid));

			if (!CollectionUtils.isEmpty(codeClassifyValueDOList)) {
			Map<String, CodeClassifyValue> codeClassifyValueDOMap = codeClassifyValueDOList.stream().collect(Collectors.toMap(s -> s.getId(), t -> t, (o1, o2) -> o2));
			if(codeClassifyValueDOMap.containsKey(sectypeValue)){
			CodeClassifyValue codeClassifyValue= codeClassifyValueDOMap.get(sectypeValue);
			sectypeValue=codeClassifyValue.getOid();
			}else {
			//throw new Throwable("传入的分类码段：【" + name + " 值：" + sectypeValue + "】，不符合当前分类层级代号");
			message="传入的分类码段：【" + name + " 值：" + sectypeValue + "】，不符合当前分类层级代号";
			errorMap.put("error",errorMap.getOrDefault("error","")+";"+message);
			}
			}
			}
			if(StringUtils.isBlank(sectypeValue)){
			message="传入的分类码段：【" + name + " 】的值不允许为空";
			errorMap.put("error",errorMap.getOrDefault("error","")+";"+message);
			}
			CodeOrderSecDTO.setSecValue(sectypeValue);
			codeOrderSecDTOList.add(CodeOrderSecDTO);
			} else {
			objerrorCode="101";
			throw new Throwable("传入的码段规则缺少" + name + "码段");
			message="传入的码段规则缺少" + name + "码段";
			errorMap.put("error",errorMap.getOrDefault("error","")+";"+message);
			}
			}
			}
			if(errorMap.size()>0){
			objerrorCode="101";
			throw new Throwable(errorMap.getOrDefault("error",""));
			}
			return codeOrderSecDTOList;
			}
			@@ -359,23 +1460,38 @@
			* 根据属性映射转换编码所需字段
			*/
			public void getConfigDatas(String systemId,String libray, ApplyDatasVO applyDatasVO,List<CodeClassifyTemplateAttrVO> codeClassifyTemplateAttrVOList,DataObjectVO dataObjectVO) throws Throwable {
			List<ApplyDataVO> applyDataVOList=applyDatasVO.getObject();

			LinkedHashMap<String,LinkedHashMap<String,String>> dataKeyValueMap=new LinkedHashMap<>();
			//如果将数据转换成所需要的数据对象
			Map<String, String> attrMapConfigMap=new HashMap<>();
			Map<String, String> propMaps=new HashMap<>();
			try {
			log.info("开始读取系统配置文件 start");
			Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
			log.info("集成系统属性映射配置文件条目数-》"+stringStringMap.size());
			//stringStringMap.put("RLM","D:\\RLM.xml");
			LibraryDO libraryDO= gennerAttrMapUtil.getNewInstance().gennerAttrMapBySystem(systemId,stringStringMap);
			List<LibraryClsfDO> libraryClsfDOList=libraryDO.getClsf();
			Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
			if(libPropMaps.containsKey(libray)){
			List<ClsfAttrMappingDO> clsfAttrMappingDOList=libPropMaps.get(libray);
			propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
			if(!CollectionUtils.isEmpty(stringStringMap)) {
			log.info("info：需要读取配置文件");
			LibraryDO libraryDO = gennerAttrMapUtil.getNewInstance().gennerAttrMapBySystem(systemId, stringStringMap);
			List<LibraryClsfDO> libraryClsfDOList = libraryDO.getClsf();
			if(!CollectionUtils.isEmpty(libraryClsfDOList)) {
			Map<String, List<ClsfAttrMappingDO>> libPropMaps = libraryClsfDOList.stream().collect(Collectors.toMap(LibraryClsfDO::getLibrary, LibraryClsfDO::getProp, (key1, key2) -> key2));
			log.info("根据参数：libray：-》" + libray + "从配置文件中找对应属性映射配置");
			String path=stringStringMap.get(systemId);
			if (libPropMaps.containsKey(libray)) {
			log.info("根据参数：libray：-》" + libray + "匹配到相应的属性映射信息");
			List<ClsfAttrMappingDO> clsfAttrMappingDOList = libPropMaps.get(libray);
			propMaps = clsfAttrMappingDOList.stream().collect(Collectors.toMap(ClsfAttrMappingDO::getSourceKey, ClsfAttrMappingDO::getTargetKey, (key1, key2) -> key2));
			log.info("根据参数：libray：-》" + libray + "匹配到相应的属性映射信息,属性映射条目数+" + clsfAttrMappingDOList.size());
			}else{
			throw new Throwable("根据系统标识【"+systemId+"】找到对应的配置文件:【"+path+"】，但未获取到对应的库【"+libray+"】属性映射信息配置");
			}
			}
			}
			log.info("根据参数：libray：-》"+libray+"从配置文件中找对应属性映射配置 end ");
			}catch (Throwable e){
			objerrorCode="1";
			e.printStackTrace();
			throw new Throwable("MDM集成属性配置文件读取失败");
			}
			LinkedList<String> rowNameList=new LinkedList<>();
			@@ -392,6 +1508,11 @@
			dataObjectVO.setColName(rowNameList);//放入属性
			attrMapConfigMap.putAll(propMaps);
			LinkedList<RowDatas> rowDataList = new LinkedList<>();
			List<ApplyDataVO> applyDataVOList=new ArrayList<>();

			if(!CollectionUtils.isEmpty(applyDatasVO.getObject())){
			applyDataVOList=applyDatasVO.getObject();
			}
			//Map<String, List<ProppertyVO>> dataPropMap = applyDataVOList.stream().collect(Collectors.toMap(ApplyDataVO::getId, ApplyDataVO::getProp, (key1, key2) -> key2));
			final int[] rowIndex = {0};
			applyDataVOList.stream().forEach(applyDataVO -> {
			@@ -469,13 +1590,14 @@
			dockingLoge.setParamString(parmaData);//参数信息
			dockingLoge.setReturnString(result);//返回信息
			dockingLoge.setType(operation);//日志操作类型
			dockingLoge.setCreateTime(new Date());
			if(isSucess) {
			dockingLoge.setInterfaceStatus("true");//接口集成状态
			}else{
			dockingLoge.setInterfaceStatus("false");//接口集成状态
			}
			dockingLogeService.save(dockingLoge);
			logger.info("集成推送数据成功,systemId:"+systemId+",systemname:"+systemName+",operation:"+operation+",param:"+parmaData);
			log.info("集成推送数据成功,systemId:"+systemId+",systemname:"+systemName+",operation:"+operation+",param:"+parmaData);
			}

			/***
			@@ -527,5 +1649,55 @@
			return resultStr;
			}

			/***
			* 校验是否做了配置
			* @param systemId,系统标识
			* @param type:接口类型
			* @param operationType:接口操作类型
			* @return
			*/
			private boolean checkIspass(String systemId,String type,String operationType){
			log.info("systemId："+systemId+",type:"+SysIntegrationDataFlowTypeEnum.getTextByValue(type)+",operationType:"+sysIntegrationPushTypeEnum.getTextByValue(operationType));
			if(!CODE_CHECKCONFIG) {
			return true;
			}
			//根据类型去查询需要集成的分类或者数据
			LambdaQueryWrapper<DockingSystemConfig> queryWrapper = Wrappers.<DockingSystemConfig>lambdaQuery();
			queryWrapper.eq(DockingSystemConfig::getUsedFlag, MdmDuckingConstant.SEND_FLAG_TRUE);
			queryWrapper.eq(DockingSystemConfig::getSysBaseId,systemId);
			queryWrapper.eq(DockingSystemConfig::getDataFlowType,type);
			queryWrapper.eq(DockingSystemConfig::getPushType,operationType);
			return dockingSystemConfigService.count(queryWrapper)>0?true:false;
			}

			/***
			* 校验是否做了配置
			* @param systemId,系统标识
			* @param type:接口类型
			* @param operationType:接口操作类型
			* @return
			*/
			private DockingSystemConfig checkIspass(String systemId,String type,String operationType,String classOid){
			log.info("systemId："+systemId+",type:"+SysIntegrationDataFlowTypeEnum.getTextByValue(type)+",operationType:"+sysIntegrationPushTypeEnum.getTextByValue(operationType)+",classOid:"+classOid);
			CodeClassifyVO codeClassifyVO= classifyService.getObjectByOid(classOid);
			classOid=codeClassifyVO.getOid();
			//根据类型去查询需要集成的分类或者数据
			LambdaQueryWrapper<DockingSystemConfig> queryWrapper = Wrappers.<DockingSystemConfig>lambdaQuery();
			queryWrapper.eq(DockingSystemConfig::getUsedFlag, MdmDuckingConstant.SEND_FLAG_TRUE);
			queryWrapper.eq(DockingSystemConfig::getSysBaseId,systemId);
			queryWrapper.eq(DockingSystemConfig::getDataFlowType,type);
			queryWrapper.eq(DockingSystemConfig::getPushType,operationType);
			if(StringUtils.isNotBlank(classOid)){
			queryWrapper.in(DockingSystemConfig::getClassifyOid,classOid);
			}
			List<DockingSystemConfig> dockingSystemConfigList= dockingSystemConfigList=dockingSystemConfigService.list(queryWrapper);
			if(!CollectionUtils.isEmpty(dockingSystemConfigList)){
			return dockingSystemConfigList.get(0);
			}else{
			if(StringUtils.isNotBlank(codeClassifyVO.getParentCodeClassifyOid())) {
			return checkIspass(systemId, type, operationType, codeClassifyVO.getParentCodeClassifyOid());
			}
			}
			return dockingSystemConfigList.get(0);
			}
			}