package com.chinaztt.mes.quality.service.impl;

import cn.hutool.http.HttpRequest;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.mes.quality.dto.ZxWeightLabelDTO;
import com.chinaztt.mes.quality.entity.StockBean;
import com.chinaztt.mes.quality.entity.ZxLabelBindRelation;
import com.chinaztt.mes.quality.entity.ZxWeightLabel;
import com.chinaztt.mes.quality.entity.ZxWeightLabelConfig;
import com.chinaztt.mes.quality.mapper.ZxLabelBindRelationMapper;
import com.chinaztt.mes.quality.mapper.ZxWeightLabelConfigMapper;
import com.chinaztt.mes.quality.mapper.ZxWeightLabelMapper;
import com.chinaztt.mes.quality.service.ZxWeightLabelService;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
 * @Description : 中兴称重标签
 * @ClassName : ZxWeightLabelServiceImpl
 * @Author : sll
 * @Date: 2022-12-01  23:26
 */
@Service
@AllArgsConstructor
@Component
@Transactional(rollbackFor = Exception.class)
public class ZxWeightLabelServiceImpl extends ServiceImpl<ZxWeightLabelMapper, ZxWeightLabel> implements ZxWeightLabelService{
	private ZxWeightLabelConfigMapper zxWeightLabelConfigMapper;
	private ZxLabelBindRelationMapper zxLabelBindRelationMapper;
	private StockBean stockBean;
	private static final ScriptEngineManager manager = new ScriptEngineManager();

	@Override
	public ZxWeightLabel addWeightLabel(ZxWeightLabelDTO zxWeightLabelDTO) throws Exception{
		if(null == zxWeightLabelDTO.getShopCode() || !zxWeightLabelDTO.getShopCode().equals("GD")){
			throw new RuntimeException("车间代码异常");
		}

		if(null == zxWeightLabelDTO.getPkgCode() || null == zxWeightLabelDTO.getGrossWeight()){
			throw new RuntimeException("PKG码及毛重数据不可为空");
		}

		//解析pkg码
		try{
			List<String> stringList = Arrays.asList(zxWeightLabelDTO.getPkgCode().split("&"));
			if(stringList.size() < 3){
				//正常的按&切割后是8段，但只有前3段对我们是有用的
				throw new RuntimeException("PKG码格式错误");
			}else{
				ZxWeightLabelDTO.PkgNode pkgNode = new ZxWeightLabelDTO.PkgNode();
				pkgNode.setPkgId(stringList.get(0));//pkgid
				pkgNode.setMaterialCode(stringList.get(1));//物料编码
				pkgNode.setQuality(new BigDecimal(stringList.get(2)));//数量
				zxWeightLabelDTO.setPkgNode(pkgNode);
			}
		}catch(Exception e){
			throw new RuntimeException("解析pkg码异常 -> " + e.getMessage());
		}

		//校验
		//1.pkgid是否绑定
		ZxLabelBindRelation zxLabelBindRelation = zxLabelBindRelationMapper.selectOne(Wrappers.<ZxLabelBindRelation>lambdaQuery().eq(ZxLabelBindRelation::getPkgId,zxWeightLabelDTO.getPkgNode().getPkgId()).last("limit 1"));
		if(null == zxLabelBindRelation){
			throw new RuntimeException("该PKG码未进行标签关系绑定 -> PKGID = 【" + zxWeightLabelDTO.getPkgNode().getPkgId() + "】");
		}

		//2.pkgid是否已经生产过称重标签
		ZxWeightLabel zxWeightLabel = baseMapper.selectOne(Wrappers.<ZxWeightLabel>lambdaQuery().eq(ZxWeightLabel::getPkgId,zxWeightLabelDTO.getPkgNode().getPkgId()).last("limit 1"));
		if(null != zxWeightLabel){
			throw new RuntimeException("该PKGID = 【" + zxWeightLabelDTO.getPkgNode().getPkgId() + "】 -> 已生成过称重记录");
		}

		//3.根据客户物料编码去配置表中取配置数据
		List<ZxWeightLabelConfig> zxWeightLabelConfigList = zxWeightLabelConfigMapper.selectList(Wrappers.<ZxWeightLabelConfig>lambdaQuery().eq(ZxWeightLabelConfig::getMaterialCode,zxWeightLabelDTO.getPkgNode().getMaterialCode()));
		if(null == zxWeightLabelConfigList || zxWeightLabelConfigList.size() == 0){
			throw new RuntimeException("客户物料编码 = 【" + zxWeightLabelDTO.getPkgNode().getMaterialCode() + "】 -> 未找到包装配置数据");
		}

		ScriptEngine se = manager.getEngineByName("js");
		Boolean door = false;//标记
		for(ZxWeightLabelConfig zxWeightLabelConfig : zxWeightLabelConfigList){
			zxWeightLabelDTO.setMeterWeight(zxWeightLabelConfig.getMeterWeight());//米重
			zxWeightLabelDTO.setFloatParam(zxWeightLabelConfig.getFloatParam());//防呆范围浮动参数
			String s = zxWeightLabelConfig.getMeterScope().replace("x",zxWeightLabelDTO.getPkgNode().getQuality().toString());//将公式中的x替换成pkg码中解析出来的数量
			if((Boolean)se.eval(s)){
				//判断对应的包装参数是否需要人工手动填写
				if(!zxWeightLabelConfig.getIsAuto()){
					//判断前端是否传入包装参数
					if(null == zxWeightLabelDTO.getPackMaterial() || null == zxWeightLabelDTO.getPackSize() || null == zxWeightLabelDTO.getPackWeight()){
						//前端没传，则需要前端弹出窗体，让用户填写
						zxWeightLabelDTO.setPopWindow(true);
						return zxWeightLabelDTO;
					}else{
						//检验一下包装尺寸格式是否合规
						List<String> stringList = Arrays.asList(zxWeightLabelDTO.getPackSize().split("\\*"));
						if(null == stringList || stringList.size() != 3){
							throw new RuntimeException("包尺寸格式不合规");
						}
						for(String cc : stringList){
							if(!StringUtils.isNumber(cc) || Double.parseDouble(cc) <= 0){
								throw new RuntimeException("包装尺寸 -> 长、宽、高必须填写数值且不可小于等于0");
							}
						}
						door = true;
						break;
					}
				}else{
					zxWeightLabelDTO.setPackMaterial(zxWeightLabelConfig.getPackMaterial());//包装材料
					zxWeightLabelDTO.setPackSize(zxWeightLabelConfig.getPackSize());//包装尺寸
					zxWeightLabelDTO.setPackWeight(zxWeightLabelConfig.getPackWeight());//包装重量
					door = true;//获取配置成功
					break;
				}
			}
		}

		//4.分割米标是否合规
		if(!door){
			throw new RuntimeException("根据客户物料编码 = 【" + zxWeightLabelDTO.getPkgNode().getMaterialCode() + "】的分割计米 = 【" + zxWeightLabelDTO.getPkgNode().getQuality() + "】 -> 不合规");
		}

		//5.校验重量范围 净重*（1-防呆范围浮动参数）<=理论重量<=净重*（1+防呆范围浮动参数）
		zxWeightLabelDTO.setNetWeight(zxWeightLabelDTO.getGrossWeight().subtract(zxWeightLabelDTO.getPackWeight()));//净重 = 毛重 - 包装重量
		zxWeightLabelDTO.setTheoryWeight(zxWeightLabelDTO.getPkgNode().getQuality().multiply(zxWeightLabelDTO.getMeterWeight()));//理论重量 = pkg码中数量 * 米重
		BigDecimal a = new BigDecimal("1");
		BigDecimal b = zxWeightLabelDTO.getFloatParam();//防呆范围浮动参数改成从配置表中获取
		if(zxWeightLabelDTO.getTheoryWeight().compareTo(zxWeightLabelDTO.getNetWeight().multiply(a.subtract(b))) >= 0 && zxWeightLabelDTO.getTheoryWeight().compareTo(zxWeightLabelDTO.getNetWeight().multiply(a.add(b))) <= 0){
			//创建数据
			zxWeightLabelDTO.setPkgId(zxWeightLabelDTO.getPkgNode().getPkgId());//pkgid
			zxWeightLabelDTO.setQuantity(zxWeightLabelDTO.getPkgNode().getQuality());//数量
			zxWeightLabelDTO.setMaterialCode(zxWeightLabelDTO.getPkgNode().getMaterialCode());//客户物料编码
			baseMapper.insert(zxWeightLabelDTO);

			return zxWeightLabelDTO;
		}else{
			DecimalFormat decimalFormatTip = new DecimalFormat("00.00");//报错提示精度
			throw new RuntimeException("理论净重 = 【" + decimalFormatTip.format(zxWeightLabelDTO.getTheoryWeight()) + "】 -> 不在[" + decimalFormatTip.format(zxWeightLabelDTO.getNetWeight().multiply(a.subtract(b))) + "," + decimalFormatTip.format(zxWeightLabelDTO.getNetWeight().multiply(a.add(b))) + "]范围内");
		}

	}

	@Override
	public String weighing(){
		//从地磅获取称重
		String ok = "OK";
		String key = "result";
		String weight = "message";

		JSONObject jsonObject;

		try {
			//从地磅获取称重
			Map<String, Object> paramMap = new HashMap<>(16);
			String result = HttpRequest.get(stockBean.getGd_1()).form(paramMap).execute().body();
			//String result = "[{\"result\":\"OK\",\"message\":\"0.5\"}]";//测试用
			JSONArray jsonArray = JSONObject.parseArray(result);
			jsonObject = jsonArray.getJSONObject(0);

		} catch (Exception e) {
			throw new RuntimeException("调用接口失败");
		}

		if (jsonObject.getString(key).equals(ok)){
			return jsonObject.getString(weight);
		}else{
			throw new RuntimeException("获取称重失败 -> " + jsonObject.getString(weight));
		}



//		String xmlres = "<ArrayOfWeightModel xmlns:i=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns=\"http://schemas.datacontract.org/2004/07/Models\"><WeightModel><message>10</message><result>OK</result></WeightModel></ArrayOfWeightModel>";
//		String res = "0";
//		Map<String, Object> paramMap = new HashMap<>(16);
//		if(true){
//			xmlres = HttpRequest.get(stockBean.getGd_1()).form(paramMap).execute().body();
//		}
//
//		Pattern p = Pattern.compile("\r|\n");
//		Matcher m = p.matcher(xmlres);
//		xmlres = m.replaceAll("");
//
//		// 创建一个新的字符串
//		StringReader read = new StringReader(xmlres);
//		// 创建新的输入源SAX 解析器将使用 InputSource 对象来确定如何读取 XML 输入
//		InputSource source = new InputSource(read);
//		// 创建一个新的SAXBuilder
//		SAXBuilder sb = new SAXBuilder();
//		// 通过输入源构造一个Document
//		Document doc = sb.build(source);
//		// 取的根元素
//		Element root = doc.getRootElement();
//		System.out.println(root.getName());// 输出根元素的名称（测试）ArrayOfWeightModel
//		// 得到根元素所有子元素的集合
//		List jiedian = root.getChildren();
//		// 获得XML中的命名空间（XML中未定义可不写）
//		Namespace name = root.getNamespace();
//		Element et = null;
//
//		for (int i = 0; i < jiedian.size(); i++) {
//			et = (Element) jiedian.get(i);// 循环依次得到子元素
//			if (i == 0) {//获取参数
//				if (et.getChild("result", name).getText().equals("OK")){
//					res = et.getChild("message", name).getText();
//				}else{
//					throw new RuntimeException("获取称重数据失败 -> " + et.getChild("message", name).getText());
//				}
//			}
//		}
//		return res;
	}
}