package com.vci.ubcs.code.service.impl;

import com.alibaba.cloud.commons.lang.StringUtils;
import com.alibaba.fastjson.JSONObject;
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.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.service.*;
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.classify.*;
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.starter.revision.model.TreeQueryObject;
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 lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

import static com.vci.ubcs.code.constant.MdmEngineConstant.DEFAULT_SYNC_ATTR_LIST;

/***
 * 统一接口
 */
@Service
@Slf4j
@VciWebservice(path = "/universalInterface")
public class UniversalInterfaceImpl<IDockingLogeServiceing> implements UniversalInterfaceI {

	@Autowired(required = false)
	private AttributeMapConfig attributeMapConfig;
	/**
	 * 缓存服务
	 */
	//@Autowired
	//private RedisService redisService;
	/**
	 * 主题库分类的服务
	 */
	@Autowired(required = false)
	private ICodeClassifyService classifyService;
	/**
	 * 主数据引擎的服务
	 */
	@Resource
	private MdmEngineService engineService;

	/**
	 * 密级的服务
	 */

	@Resource
	private MdmIOService mdmIOService;
	/***
	 * 集成接口日志服务的配置
	 */
	@Resource
	private IDockingLogeService dockingLogeService;

	private  static String separator="##VCI##";
	private  String errorid="0";
	private String msg="成功";
	private  String objerrorCode="0";
	private String objerrorMsg="成功";
	/***
	 * 申请编码接口
	 * @param data 传递的数据参数
	 * @param dataType 标识data是xml格式还是json格式，接口返回数据也是按照这个格式，以下接口类同
	 * @return
	 * @throws Throwable
	 */
	@Override
	public String applyCode(String data, String dataType) throws Throwable {
		{
			String resultStr = "";
			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="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());
					LinkedList<XMLResultDataObjectDetailDO> resultDataObjectDetailDOs = new LinkedList<>();
					//获取分类信息
					try {
						String libray = classVO.getLibrary();
						CodeClassifyVO codeClassifyVO = getClassfy(classVO);
						log.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系统中对应模板");
						}
						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);
						log.info("end：码段获取完毕");
						CodeOrderDTO orderDTO = new CodeOrderDTO();
						orderDTO.setCodeClassifyOid(codeClassifyVO.getOid());//分类主键
						orderDTO.setSecDTOList(codeOrderSecDTOList);//分类码段
						mdmIOService.batchSyncApplyCode(orderDTO, dataObjectVO, resultDataObjectDetailDOs);
						log.info("end：申请获取完毕");
					} catch (Throwable e) {
						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);
					}
				});
				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();
				}
			}
			log.info("返回参数:"+resultStr);

			return resultStr;
		}
	}

	/***
	 * 统一更新接口（更改状态，更改属性信息）接口
	 * @param data
	 * @param dataType
	 * @return
	 * @throws Throwable
	 */
	@Override
	public String syncEditData(String data, String dataType) throws Throwable {

		return null;
	}

	/***
	 * 分类查询
	 * @param data
	 * @param dataType
	 * @return
	 * @throws Throwable
	 */
	@Override
	public String queryClassify(String data, String dataType) throws Throwable {
		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<>();
			//这是账号信息
			//这是账号信息
			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);
			}
			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;
	}

	/***
	 * 数据查询
	 * @param data
	 * @param dataType
	 * @return
	 * @throws Throwable
	 */
	@Override
	public String queryData(String data, String dataType) throws Throwable {
		return null;
	}

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

	/***
	 * 查询校验分类信息
	 * @param classfyVO
	 */
	private  CodeClassifyVO getClassfy(ClassfyVO classfyVO) throws Throwable{
		CodeClassifyVO classifyVO = new CodeClassifyVO();
		try {
			String classCode = classfyVO.getClassCode();
			String className = classfyVO.getFullclsfNamePath();
			//根据分类代号查询分类信息
			if (StringUtils.isNotBlank(classfyVO.getClassCode())) {
				Map<String, String> conditionMap = new HashMap<>();
				List<CodeClassify> codeClassifyList = classifyService.selectByWrapper(Wrappers.<CodeClassify>query().lambda().eq(CodeClassify::getId, classCode));
				if (!CollectionUtils.isEmpty(codeClassifyList)) {
					CodeClassify classifyDO = codeClassifyList.get(0);
					//将DTO转换为DO
					classifyVO = new CodeClassifyVO();
					BeanUtilForVCI.copyPropertiesIgnoreCase(classifyDO, classifyVO);
					if(StringUtils.isBlank(classifyVO.getOid())){
						throw new  Throwable("根据分类代号未查询到相应的分类信息");
					}
				}else{
					throw new  Throwable("根据分类代号未查询到相应的分类信息");
				}
			} else {
				classifyVO = classifyService.getObjectByClsfNamePath(className.replace(separator, "/"));
				if(StringUtils.isBlank(classifyVO.getOid())){
					throw new  Throwable("根据分类名称路径未查询到相应的分类信息");
				}
			}
		}catch (Throwable e){
			objerrorCode="100";
			new  Throwable("获取分类信息失败:"+e.getMessage());
		}
		return classifyVO;
	}
	/***
	 * 根据穿入的参数信息校验码段规则
	 */
	private List<CodeOrderSecDTO> getRuleCodeOrderSecDTOs(List<SectionVO> SectionVOList,CodeRuleVO ruleVO) throws Throwable{
		List<CodeBasicSecVO>  codeBasicSecVOS= ruleVO.getSecVOList();
		Map<String,String> sectionVOMap=new HashMap<>();
		SectionVOList.stream().forEach(SectionVO->{
			sectionVOMap.put(SectionVO.getName(),SectionVO.getValue());
		});
		List<CodeOrderSecDTO> codeOrderSecDTOList=new ArrayList<>();
		for(CodeBasicSecVO codeBasicSecVO: codeBasicSecVOS) {
			String sectype = codeBasicSecVO.getSecType();
			if (!sectype.equals(CodeSecTypeEnum.CODE_SERIAL_SEC.getValue())) {
				String name = codeBasicSecVO.getName();
				String sectypeText = codeBasicSecVO.getSecTypeText();
				log.info("码段名称:"+name);
				log.info("描述:"+sectypeText);
				CodeOrderSecDTO CodeOrderSecDTO = new CodeOrderSecDTO();
				if (sectionVOMap.containsKey(name)) {
					CodeOrderSecDTO.setSecOid(codeBasicSecVO.getOid());
					String sectypeValue = sectionVOMap.get(name);
					log.info("码段值:"+sectypeValue);
					CodeOrderSecDTO.setSecValue(sectypeValue);
					codeOrderSecDTOList.add(CodeOrderSecDTO);
				} else {
					objerrorCode="101";
					throw new Throwable("传入的码段规则缺少" + name + "码段");
				}
			}
		}
		return codeOrderSecDTOList;
	}
	/***
	 * 根据属性映射转换编码所需字段
	 */
	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 {
			Map<String, String> stringStringMap=attributeMapConfig.getSystem_attrmap();
			//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));
			}
		}catch (Throwable e){
			objerrorCode="1";
			throw new Throwable("MDM集成属性配置文件读取失败");
		}
		LinkedList<String> rowNameList=new LinkedList<>();
		LinkedHashMap<String,Integer> filedIndexMap=new LinkedHashMap<>();
		//根据分类模板组织数据
		final int[] index = {0};
		try {
			codeClassifyTemplateAttrVOList.stream().forEach(codeClassifyTemplateAttrVO -> {
				String attrName = codeClassifyTemplateAttrVO.getName();
				String field = codeClassifyTemplateAttrVO.getId();
				rowNameList.add(attrName);
				filedIndexMap.put(field, index[0]++);
			});
			dataObjectVO.setColName(rowNameList);//放入属性
			attrMapConfigMap.putAll(propMaps);
			LinkedList<RowDatas> rowDataList = new LinkedList<>();
			//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 -> {
				rowIndex[0]++;
				RowDatas rowDatas = new RowDatas();
				rowDatas.setOid(applyDataVO.getId());
				rowDatas.setCreator(applyDataVO.getCreator());
				rowDatas.setEditor(applyDataVO.getEditor());
				rowDatas.setCode(applyDataVO.getCode());
				rowDatas.setOperation(applyDataVO.getOperate());
				rowDatas.setStatus(applyDataVO.getStatus());
				rowDatas.setRowIndex(rowIndex[0] + "");
				List<ProppertyVO> proppertyVOList = applyDataVO.getProp();

				LinkedHashMap<Integer, String> integerValueMap = new LinkedHashMap<>();
				Map<String, String> filedValueMap = new HashMap<>();
				if (!CollectionUtils.isEmpty(proppertyVOList)) {
					Map<String, String> sourceKeyValueMap = proppertyVOList.stream().collect(Collectors.toMap(ProppertyVO::getKey, ProppertyVO::getValue, (key1, key2) -> key2));
					Map<String, String> keyValueMap = new HashMap<>();
					//判断attrMapConfigMap是否有值，如果没有则说明基础默认的是编码系统字段
					if (!CollectionUtils.isEmpty(attrMapConfigMap)) {
						sourceKeyValueMap.keySet().forEach(sourceKey -> {
							String dataValue = sourceKeyValueMap.get(sourceKey);
							if (attrMapConfigMap.containsKey(sourceKey)) {
								String targetKey = attrMapConfigMap.get(sourceKey);
								keyValueMap.put(targetKey, StringUtils.isBlank(dataValue)?"":dataValue);
							}
						});
					} else {
						sourceKeyValueMap.forEach((filed,value)->{
							keyValueMap.put(filed,StringUtils.isBlank(value)?"":value) ;
						});
					}

					filedIndexMap.forEach((attrKey, column) -> {
						String keyValue = "";
						if (keyValueMap.containsKey(attrKey)) {
							keyValue =StringUtils.isBlank(keyValueMap.get(attrKey))?"":keyValueMap.get(attrKey);
						}
						integerValueMap.put(column, keyValue);
						filedValueMap.put(attrKey, keyValue);
					});
				}
				rowDatas.setData(integerValueMap);
				rowDatas.setFiledValue(filedValueMap);
				rowDataList.add(rowDatas);
			});
			dataObjectVO.setRowData(rowDataList);
		}catch (Throwable e){
			objerrorCode="1";
			throw new   Throwable("组织数据映射值失败");
		}
	}
	/***
	 * 记录日志信息
	 * @param systemId
	 * @param parmaData
	 * @param result
	 * @return
	 */
	private  void saveLogs(String systemId,String systemName,String parmaData, String result,boolean isSucess,String msg,String operation){
		//记录日志信息
		DockingLog dockingLoge=new DockingLog();
		//String oid=redisService.getUUIDEveryDay();
		dockingLoge.setSystemCode(StringUtils.isBlank(systemId)?"-":systemId);//设置系统标识
		dockingLoge.setSystemName(StringUtils.isBlank(systemName)?"-":systemName);
		dockingLoge.setMsg(msg);//日志消息
		dockingLoge.setClassifyId("-");//分类编号
		dockingLoge.setClassifyName("-");//分类名称
		dockingLoge.setClassifyOid("-");//分类主键
		dockingLoge.setUniqueCode("-");//唯一标识
		dockingLoge.setSystemOid("-");//系统标识
//        dockingLogeDO.setName(operation);
		//dockingLogeDO.setOid(oid);//日志主键
		dockingLoge.setParamString(parmaData);//参数信息
		dockingLoge.setReturnString(result);//返回信息
		dockingLoge.setType(operation);//日志操作类型
		if(isSucess) {
			dockingLoge.setInterfaceStatus("true");//接口集成状态
		}else{
			dockingLoge.setInterfaceStatus("false");//接口集成状态
		}
		dockingLogeService.save(dockingLoge);
		log.info("集成推送数据成功,systemId:"+systemId+",systemname:"+systemName+",operation:"+operation+",param:"+parmaData);
	}

	/***
	 * 数据维护与编码申请返回
	 * @param resultSystemVO
	 * @param dataType
	 * @return
	 */
	private String transferResultXMl(XMLResultSystemVO resultSystemVO,String dataType){
		String resultStr="";
		if ("xml".equals(dataType)) {
			//组织返回接口信息
			XStream xStream = new XStream(new DomDriver());
			xStream.processAnnotations(XMLResultSystemVO.class);
			xStream.autodetectAnnotations(true);
			resultStr = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + xStream.toXML(resultSystemVO);
		} else {
			List<XMLResultClassfyVO> resultClassfyVOList =resultSystemVO.getClassifys();
			JSONResultDataVO resultDataVO = new JSONResultDataVO();
			JSONResultSystemVO jsonResultSystemVO = new JSONResultSystemVO();
			JSONResultClassfysVO jsonResultClassfysVO = new JSONResultClassfysVO();
			List<JSONResultClassfyVO> jSONResultClassfyVOList = new ArrayList<>();
			resultClassfyVOList.stream().forEach(resultClassfyVO -> {
				List<XMLResultDataObjectDetailDO> xmlResultDataObjectDetailDOS = resultClassfyVO.getObjects();
				List<JSONResultDataObjectDetailDO> JSONResultDataObjectDetailDOList = new ArrayList<>();
				xmlResultDataObjectDetailDOS.stream().forEach(xmlResultDataObjectDetail -> {
					JSONResultDataObjectDetailDO jsonResultDataObjectDetail = new JSONResultDataObjectDetailDO();
					BeanUtilForVCI.copyPropertiesIgnoreCase(xmlResultDataObjectDetail, jsonResultDataObjectDetail);
					JSONResultDataObjectDetailDOList.add(jsonResultDataObjectDetail);
				});
				JSONResultClassfyVO jsonResultClassfyVO = new JSONResultClassfyVO();
				jsonResultClassfyVO.setClassCode(resultClassfyVO.getClassCode());
				jsonResultClassfyVO.setLibrary(resultClassfyVO.getLibrary());
				jsonResultClassfyVO.setFullclsfNamePath(resultClassfyVO.getFullclsfNamePath());
				JSONResultDataObjectDO JSONResultDataObjectDO = new JSONResultDataObjectDO();
				JSONResultDataObjectDO.setObject(JSONResultDataObjectDetailDOList);
				jsonResultClassfyVO.setObjects(JSONResultDataObjectDO);
				jSONResultClassfyVOList.add(jsonResultClassfyVO);
			});
			jsonResultClassfysVO.setClassify(jSONResultClassfyVOList);
			jsonResultSystemVO.setClassifys(jsonResultClassfysVO);
			jsonResultSystemVO.setErrorid(resultSystemVO.getErrorid());
			jsonResultSystemVO.setMsg(resultSystemVO.getMsg());
			resultDataVO.setData(jsonResultSystemVO);
			Object object = JSONObject.toJSON(resultDataVO);
			resultStr = object.toString();

		}
		return resultStr;
	}


}