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

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.vci.ubcs.code.constant.MdmBtmTypeConstant;
import com.vci.ubcs.code.dto.DockingSysIntHeaderDTO;
import com.vci.ubcs.code.dto.DockingSystemConfigDTO;
import com.vci.ubcs.code.dto.DockingSysIntParamDTO;
import com.vci.ubcs.code.entity.DockingSysIntHeader;
import com.vci.ubcs.code.entity.DockingSysIntParam;
import com.vci.ubcs.code.entity.DockingSystem;
import com.vci.ubcs.code.entity.DockingSystemConfig;
import com.vci.ubcs.code.enumpack.SysIntegrationRequestTypeEnum;
import com.vci.ubcs.code.mapper.DockingSysIntHeaderMapper;
import com.vci.ubcs.code.mapper.DockingSysIntParamMapper;
import com.vci.ubcs.code.mapper.DockingSystemConfigMapper;
import com.vci.ubcs.code.mapper.DockingSystemMapper;
import com.vci.ubcs.code.service.IDockingSysIntHeaderService;
import com.vci.ubcs.code.service.IDockingSysIntParamService;
import com.vci.ubcs.code.service.IDockingSystemConfigService;
import com.vci.ubcs.code.vo.pagemodel.DockingSysIntHeaderVO;
import com.vci.ubcs.code.vo.pagemodel.DockingSystemVO;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.revision.service.RevisionModelUtil;
import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil;
import com.vci.ubcs.starter.web.util.BeanUtilForVCI;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.util.*;

/***
 * 系统接口管理-接口配置服务
 * @author xiejun
 * @date 2023-06-01
 */
@Slf4j
@Service
public class DockingSystemConfigServiceImpl extends ServiceImpl<DockingSystemConfigMapper, DockingSystemConfig> implements IDockingSystemConfigService{

	/***
	 * 集成系统管理服务
	 */
	@Autowired(required = false)
	private DockingSystemConfigMapper dockingSystemConfigMapper;

	/***
	 * 集成接口-集成接口管理参数服务
	 */
	@Autowired(required = false)
	private IDockingSysIntParamService dockingSysIntParamService;



	/***
	 * 集成接口-集成接口管理参数服务
	 */
	@Autowired(required = false)
	private IDockingSysIntHeaderService dockingSysIntHeaderService;


	/***
	 * 集成接口-集成系统服务
	 */
	@Autowired(required = false)
	private DockingSystemMapper dockingSystemMapper;

	/**
	 * 对象的操作
	 */
	@Autowired
	private RevisionModelUtil revisionModelUtil;
	/**
	 * 增加系统集成的接口管理信息
	 * @param dockingSystemConfigDTO 系统集成的系统信息数据传输对象
	 * @return 执行结果，success为true表示成功，msg是失败的提示信息，obj是添加完成后的显示对象
	 */
	@Transactional(rollbackFor = Exception.class)
	@Override
	public boolean addSave(DockingSystemConfigDTO dockingSystemConfigDTO) {
		log.info(" 增加系统集成的接口管理信息:"+dockingSystemConfigDTO.toString());
		VciBaseUtil.alertNotNull(dockingSystemConfigDTO, "需要添加的数据对象");
		checkColumnNotNull(dockingSystemConfigDTO);
		String sourcesystemoid = dockingSystemConfigDTO.getSourceSystemOid();
		DockingSystem dockingSystem = dockingSystemMapper.selectById(sourcesystemoid);
		dockingSystemConfigDTO.setSysBaseOid(sourcesystemoid);
		dockingSystemConfigDTO.setSysBaseId(dockingSystem.getId());
		dockingSystemConfigDTO.setSysBaseName(dockingSystem.getName());
		dockingSystemConfigDTO.setUsedFlag("true");//设置默认启用状态

		//将DTO转换为DO
		DockingSystemConfig dockingSystemConfig = new DockingSystemConfig();
		revisionModelUtil.copyFromDTOIgnore(dockingSystemConfigDTO,dockingSystemConfig);


		List<DockingSysIntParamDTO> sysIntParamDTOList=  dockingSystemConfigDTO.getSysIntParamDTOS();
		List<DockingSysIntParam> sysIntParamList=new ArrayList<>();
		if(!CollectionUtils.isEmpty(sysIntParamDTOList)) {
			sysIntParamDTOList.stream().forEach(sysIntParamDTO -> {
				DockingSysIntParam sysIntParamDO = new DockingSysIntParam();
				sysIntParamDTO.setInfoOid(dockingSystemConfigDTO.getOid());
				BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntParamDTO, sysIntParamDO);
				DefaultAttrAssimtUtil.addDefaultAttrAssimt(sysIntParamDO,MdmBtmTypeConstant.SYS_INT_PARAMTERY);
				sysIntParamList.add(sysIntParamDO);
			});
		}
		List<DockingSysIntHeaderDTO> sysIntHeaderDTOs= dockingSystemConfigDTO.getSysIntHeaderDTOS();
		List<DockingSysIntHeader> sysIntHeaderList = new ArrayList<>();
		if(!CollectionUtils.isEmpty(sysIntHeaderDTOs)) {
			sysIntHeaderDTOs.stream().forEach(sysIntHeaderDTO -> {
				DockingSysIntHeader dockingSysIntHeader = new DockingSysIntHeader();
				sysIntHeaderDTO.setInfoOid(dockingSystemConfigDTO.getOid());
				BeanUtilForVCI.copyPropertiesIgnoreCase(sysIntHeaderDTO, dockingSysIntHeader);
				DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSysIntHeader,MdmBtmTypeConstant.SYS_INT_HEADER);
				sysIntHeaderList.add(dockingSysIntHeader);
			});
		}
		dockingSysIntParamService.saveBatch(sysIntParamList);
		dockingSysIntHeaderService.saveBatch(sysIntHeaderList);
		DefaultAttrAssimtUtil.addDefaultAttrAssimt(dockingSystemConfig,MdmBtmTypeConstant.SYS_INT_INFO);
		dockingSystemConfigMapper.insert(dockingSystemConfig);

		return true;

	}

	@Override
	public DockingSystemVO editSave(DockingSystemConfigDTO dockingSystemDTO) {
		return null;
	}

	@Override
	public boolean deleteDataById(String oids) {
		return false;
	}

	/**
	 * 系统集成接口基础信息Null字段检验
	 * @param dockingSystemConfigDTO 系统集成基础信息数据传输对象
	 * @throws VciBaseException 参数为空，唯一项，必输项不通过时会抛出异常
	 */
	private void checkColumnNotNull(DockingSystemConfigDTO  dockingSystemConfigDTO) throws VciBaseException {
		if (SysIntegrationRequestTypeEnum.HTTP.getValue().equals(dockingSystemConfigDTO.getInterfaceType())){
			VciBaseUtil.alertNotNull(dockingSystemConfigDTO.getRequestUrl(),"HTTP接口的请求地址",dockingSystemConfigDTO.getRequestMethod(),"HTTP接口的请求方式");
		}
		if (SysIntegrationRequestTypeEnum.WEB_SERVICE.getValue().equals(dockingSystemConfigDTO.getInterfaceType())){
			VciBaseUtil.alertNotNull(dockingSystemConfigDTO.getInterfaceFunction(),"WebService的接口函数");
		}
		if (SysIntegrationRequestTypeEnum.CLASSPATH.getValue().equals(dockingSystemConfigDTO.getInterfaceType())){
			VciBaseUtil.alertNotNull(dockingSystemConfigDTO.getClassPath(),"类路径");
		}
	}
}