package com.changhong.epc.parsing.service.loop.impl;

import com.changhong.epc.bean.parsing.BillInfo;
import com.changhong.epc.bean.parsing.RuleMsgColumn;
import com.changhong.epc.bean.tenant.bill.RuleCheckMsg;
import com.changhong.epc.bean.tenant.bill.RuleMsg;
import com.changhong.epc.bean.tenant.bill.RuleMsgExtend;
import com.changhong.epc.bean.tenant.master.MasterValue;
import com.changhong.epc.constter.parsing.ConstRuleMsg;
import com.changhong.epc.constter.system.SystemClients;
import com.changhong.epc.parsing.mapper.tenant.BillInfoMapper;
import com.changhong.epc.parsing.mapper.tenant.RuleCheckMsgMapper;
import com.changhong.epc.parsing.mapper.tenant.RuleMapper;
import com.changhong.epc.parsing.mapper.tenant.RuleMsgMapper;
import com.changhong.epc.parsing.service.loop.IRuleMsgHandService;
import com.changhong.epc.rely.api.epc.admin.CorresElFieldApi;
import com.changhong.epc.rely.api.epc.tenant.MasterApi;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.Optional;

/**
 * 
 * @ClassName: RuleMsgHandServiceImpl
 * @author [九鼎联合科技]
 * @date 2017年6月19日 下午6:36:15
 */
@Component("ruleMsgHandService")
@Slf4j
public class RuleMsgHandServiceImpl extends LoopSuper implements SystemClients, IRuleMsgHandService, ConstRuleMsg {
	
	@Resource
	private RuleMsgMapper ruleMsgMapper;
	
	@Resource
	private RuleMapper ruleMapper;
	
	@Resource
	private BillInfoMapper billInfoMapper;
	
	@Resource
	private RuleCheckMsgMapper ruleCheckMsgMapper;

	@Override
	public String getThreadName() {
		return "解析规则检查服务";
	}

	@Override
	public void businessHandle() {
		Manager();
	}

	/**
	 * 取出te_bill_check_msg表规则信息的json字符串数据 解析 
	 * void 返回类型 @throws
	 */
	private void Manager() {
		insertRuleMsg(ruleCheckMsgMapper.selectUntreatedRuleCheckMsg());
}
	
	/**
	 * 传入json字符串集合解析存入rule_msg数据表 @Title: insertRuleMsg @param @param rcmList
	 * 设定文件 @return void 返回类型 @throws
	 */
	public void insertRuleMsg(List<RuleCheckMsg> rcmList) {
		if(ObjectUtil.empty(rcmList)){
			return;
		}
		for (RuleCheckMsg rcm : rcmList) {
			log.debug("----------------开始解析规则检查结果--------------");
			BillInfo billInfo = billInfoMapper.selectByOrderCode(rcm.getOrderCode());
			if(billInfo == null ||billInfo.getInfo() == null || Objects.equals("",billInfo.getInfo())){
				log.debug("当前订单号:-->"+rcm.getOrderCode());
				log.debug("当前不可规则检查-->"+ JSONTool.toJson(billInfo));
				continue;
			}
			RuleMsg t = new RuleMsg();
			t.setCouldNumber(rcm.getOrderCode());
			ruleMapper.delete(t);
			/*将解析后的数据添加到rule_msg表中*/
			RuleMsgExtend rList = JSONTool.toObj(rcm.getMsg(), RuleMsgExtend.class);
			Optional.ofNullable(rList)
					.map(RuleMsgExtend::getCheckResultList)
					.orElse(new ArrayList<>())
					.stream().forEach(rl ->{
						RuleMsg ruleMsg = new RuleMsg();
						ruleMsg.setResult(rl.getResult());
						ruleMsg.setBillCode(rl.getBillCode());
						ruleMsg.setCouldNumber(rList.getOrderCode());
						ruleMsg.setRulecode(rl.getRulecode());
						ruleMsg.setRulename(rl.getRulename());
						ruleMsg.setLevel(getLevel(rl.getRulecode()));
						ruleMsg.setType(RU_TYPE3);
						ruleMsg.setStatus(RU_STATUS1);
						ruleMsg.initParam();
						ruleMapper.insert(ruleMsg);

					});
			/*将原始检查票据表状态更新*/
			rcm.setDataStart(99);
			ruleCheckMsgMapper.updateByPrimaryKey(rcm);
			log.debug("修改订单标号为" + rList.getOrderCode() + "的状态为可分配行程状态");
			//修改票据状态
			billInfoMapper.updateBillState(rList.getOrderCode());
		}
	}
			
	/**
	 * 获取错误级别level,code错误则默认level等级为10 @Title: getLevel @param @param
	 * code @param @return 设定文件 @return int 返回类型 @throws
	 */
	@SuppressWarnings("unchecked")
	public int getLevel(String code) {
		String mdCode = SpringUtil.getBean(CorresElFieldApi.class).getCorresElField(RULE_MSG_MDCODE).getMdCode();

		MasterValue masterValue = SpringUtil.getBean(MasterApi.class).getMasterVal(mdCode, code);
		if(!ObjectUtil.notEmpty(masterValue) && !ObjectUtil.notEmpty(masterValue.getEleValue())){
			return NumberUtils.createInteger(masterValue.getEleValue());
		}else{
			return LEVEL_10;
		}
	}

	@Override
	public void insertRuleMsg(RuleMsgColumn ruleMsg) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void Manager(RuleCheckMsg ruleCheckMsg) {
		// TODO Auto-generated method stub
		
	}

	
}