package com.vci.ubcs.code.algorithm;

import com.alibaba.nacos.common.utils.CollectionUtils;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.vci.ubcs.code.annotation.MdmSerialAlgorithm;
import com.vci.ubcs.code.annotation.MdmSerialAlgorithmMethod;
import com.vci.ubcs.code.dto.CodeCustomSerialDTO;
import com.vci.ubcs.code.entity.CodeAllCode;
import com.vci.ubcs.code.enumpack.CodeBZOperationTypeEnum;
import com.vci.ubcs.code.service.ICodeAllCodeService;
import com.vci.ubcs.code.vo.pagemodel.CodeBasicSecVO;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import io.reactivex.internal.util.LinkedArrayList;
import net.logstash.logback.encoder.org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import javax.management.StringValueExp;
import java.util.*;
import java.util.stream.Collectors;

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

/****
 * 自定义罗马流水算法自定义类
 */
@MdmSerialAlgorithm(text = "自定义罗马流水",serialType="custom_serial_roman",description = "自定义罗马流水算法")
@Component
public class CustomRomanSerialAlgorithmExample {
	/**
	 * 编码规则的服务
	 */
	@Autowired
	private ICodeAllCodeService codeAllCodeService;
	/***
	 * 操作类型
	 */
	@Value("${bzApply.operationType:operationType}")
	private String operationType;
	/***
	 * 是否系列
	 */
	@Value("${bzApply.isSeries:isSeries}")
	private String isSeries;

	/***
	 * 是否变更系列
	 */
	@Value("${bzApply.isEditSeries:isEditSeries}")
	private String isEditSeries;
	/***
	 * 源标准号
	 */
	@Value("${bzApply.oldCode:oldCode}")
	private String oldCode;
	/***
	 *发布时间
	 */
	@Value("${bzApply.releaseTime:releaseTime}")
	private String releaseTime;
	/***
	 * 控制是否写入值的码段名称
	 */
	@Value("${bzApply.yearSecName:年代号}")
	private String yearSecName;
	/**
	 * 生成罗马流水号的方法
	 * @return 流水号的信息
	 */
	@MdmSerialAlgorithmMethod
	public String serialGenerate(CodeCustomSerialDTO codeCustomSerialDTO){
//		boolean isSeriesValue=false;
		boolean isCrete=false;//是否成产罗马顺序号
		String romanValue="";
		List<CodeBasicSecVO> codeBasicSecVOList= codeCustomSerialDTO.getCodeBasicSecVOList();
		int yearSecValue=0;//年代号
		List<String> secValueList=codeCustomSerialDTO.getSecValueList();
		String serialUnitString=codeCustomSerialDTO.getSerialUnitString();
		//源标准类型
		boolean isSeriesValue=codeCustomSerialDTO.getBaseModel().getData().containsKey(isSeries)&&StringUtils.isNotBlank(codeCustomSerialDTO.getBaseModel().getData().get(isSeries))&&codeCustomSerialDTO.getBaseModel().getData().get(isEditSeries).equals("true")?true:false;
		//是否变更系列
		boolean isEditSeriesValue=codeCustomSerialDTO.getBaseModel().getData().containsKey(isEditSeries)&&StringUtils.isNotBlank(codeCustomSerialDTO.getBaseModel().getData().get(isEditSeries))&&codeCustomSerialDTO.getBaseModel().getData().get(isEditSeries).equals("true")?true:false;
		//如果标修订为标准，原有表准系列号不变，则比较年代号，如果年代号跨年（次年1月后则为跨年）
		String operationTypeValue=codeCustomSerialDTO.getBaseModel().getData().containsKey(operationType)&&StringUtils.isNotBlank(codeCustomSerialDTO.getBaseModel().getData().get(operationType))?codeCustomSerialDTO.getBaseModel().getData().get(operationType):"";
		//发布时间
		String releaseTimeValue=codeCustomSerialDTO.getBaseModel().getData().containsKey(releaseTime)&&StringUtils.isNotBlank(codeCustomSerialDTO.getBaseModel().getData().get(releaseTime))?codeCustomSerialDTO.getBaseModel().getData().get(releaseTime):"";
		if(operationTypeValue.equals(CodeBZOperationTypeEnum.CODE_BZ_AMENDMENT.getValue())){//如果是修订
			//源标准号
			String oldCodeValue=codeCustomSerialDTO.getBaseModel().getData().containsKey(oldCode)&&StringUtils.isNotBlank(codeCustomSerialDTO.getBaseModel().getData().get(oldCode))?codeCustomSerialDTO.getBaseModel().getData().get(oldCode):"";
			if(StringUtils.isNotBlank(oldCodeValue)){
				//还需要修改allCode的生命周期
				QueryWrapper<CodeAllCode> allCodeWrapper = new QueryWrapper<>();
				allCodeWrapper.in("id", VciBaseUtil.str2List(oldCodeValue));
				List<CodeAllCode>codeAllcodeList=codeAllCodeService.selectByWrapper(allCodeWrapper);
				if(!CollectionUtils.isEmpty(codeAllcodeList)){
					String codeDelimit=codeAllcodeList.get(0).getCodeDelimit();
					String[] secValues= StringUtils.splitByWholeSeparatorPreserveAllTokens(codeDelimit,SERIAL_VALUE_SPACE);
					int yearIndex=0;
					if((!isSeriesValue&&!isEditSeriesValue)||(isSeriesValue&&isSeriesValue)){//如果是标准修订为标准，或者系列修订为系列时候，则判断年代号
						for (int i=0;i<codeBasicSecVOList.size();i++){
							CodeBasicSecVO codeBasicSecVO=codeBasicSecVOList.get(i);
							if(codeBasicSecVO.getName().equals(yearSecName)){
								yearSecValue=Integer.parseInt((secValues[i]));
								yearIndex=i;
							}
						}
						//则获取年代号比较，如果年代号跨年则需要不需要增加罗马流水，直接改年代号，如果不跨年则增加流水
						if(StringUtils.isNotBlank(releaseTimeValue)){//发布时间
						 String[] yearMoths=	StringUtils.splitByWholeSeparatorPreserveAllTokens(releaseTimeValue,"-");
						 String[] serialUnitStrings=StringUtils.splitByWholeSeparatorPreserveAllTokens(serialUnitString,SERIAL_UNIT_SPACE);
						 List<String>serialUnitStringList=new ArrayList<>();
						 serialUnitStringList= Arrays.asList(serialUnitStrings);
						 int newYear=0;
							int month=0;
						  if(yearMoths.length>2){
							  String year=yearMoths[0];
							  if(year.length()>String.valueOf(yearSecValue).length()){//有时候发布时间的年长度大于码段的长度，则需要截取后2位
								  newYear= Integer.parseInt(year.substring(2));
							  }else {
								  newYear=Integer.parseInt(year);
							  }
							  month=Integer.parseInt(yearMoths[1]);
						  }
						  if(newYear>yearSecValue&&month>1){
							  secValueList.set(yearIndex,String.valueOf(newYear));
							  serialUnitStringList.set(yearIndex, String.valueOf(newYear));
							  codeCustomSerialDTO.setSecValueList(secValueList);
							  String newSerialUnitString = serialUnitStringList.size() == 0 ? EMPTY_SERIAL_UNIT : serialUnitStringList.stream().collect(Collectors.joining(SERIAL_UNIT_SPACE));
							  codeCustomSerialDTO.setSerialUnitString(newSerialUnitString);
						  }else{
							  isCrete=true;
						  }
						}
					}
				}
			}

		}

		if(isCrete){
			CodeBasicSecVO secVO= codeCustomSerialDTO.getSerialCodeCodeBasicSec();
			String currentFlowValue=codeCustomSerialDTO.getCurrentFlowValue();
			Double newThisSerialValue = 0d;
			if(StringUtils.isBlank(currentFlowValue)){
				//第一个编码
				newThisSerialValue = VciBaseUtil.getDouble(secVO.getSerialStart());
			}else {
				//流水号肯定是数字
				//将罗马流水转为数字流水
				int arabicValue=VciBaseUtil.convertRomanToArabic(currentFlowValue);
				newThisSerialValue = (double)(arabicValue + secVO.getSerialStep()) ;
			}
			//要看是否超过最大的流水值
			if (newThisSerialValue >= secVO.getCodeFillLimit()) {
				throw new VciBaseException("流水号已经超过允许的最大流水值{0}", new String[]{secVO.getCodeFillLimit().toString()});
			}
			//将数字流水转为罗马流水
			romanValue=VciBaseUtil.convertArabicToRoman(newThisSerialValue.intValue());
		}

		return romanValue;
	}

}