package com.lxzn.mes.service.impl;

import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.fasterxml.jackson.core.type.TypeReference;
import com.lxzn.base.service.IDncLogService;
import com.lxzn.base.service.IMultilevelDictionaryService;
import com.lxzn.framework.domain.base.DncLog;
import com.lxzn.framework.domain.base.MultilevelDictionary;
import com.lxzn.framework.domain.base.ext.MultilevelDictionaryExt;
import com.lxzn.framework.domain.mes.ext.MesDispatchTaskReceive;
import com.lxzn.framework.domain.mes.ext.MesProcedureFinishReceive;
import com.lxzn.framework.domain.mes.ext.MesSyncEquipmentReceive;
import com.lxzn.framework.domain.mes.ext.MesSyncWorkmanshipReceive;
import com.lxzn.framework.domain.plm.QueryNcProgramLog;
import com.lxzn.framework.utils.JsonMapper;
import com.lxzn.framework.utils.LogCodeUtil;
import com.lxzn.mes.ext.MesResultList;
import com.lxzn.mes.ext.MesResultModel;
import com.lxzn.mes.service.*;
import com.lxzn.plm.service.IPdmProgramSourceService;
import com.lxzn.plm.service.IQueryNcProgramLogService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.jws.WebParam;
import javax.jws.WebService;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author clown
 * * @date 2022/10/28
 */
@Component
@WebService(name = "MesWebServiceApi", targetNamespace = "http://mes.lxzn.com",
        endpointInterface = "com.lxzn.mes.service.MesWebServiceApi")
@Slf4j
public class MesWebServiceImpl implements MesWebServiceApi {

    @Autowired
    private IMesDispatchTaskService mesDispatchTaskService;
    @Autowired
    private IMesProcedureFinishService mesProcedureFinishService;
    @Autowired
    private IMesSyncEquipmentService mesSyncEquipmentService;
    @Autowired
    private IMesSyncWorkmanshipService mesSyncWorkmanshipService;
    @Autowired
    private IDncLogService dncLogService;
    @Autowired
    private IPdmProgramSourceService pdmProgramSourceService;
    @Autowired
    private IQueryNcProgramLogService queryNcProgramLogService;
    @Autowired
    private IMultilevelDictionaryService multilevelDictionaryService;


    @Override
    public String issuedDispatchTask(@WebParam String data) {
        if(null == data || "".equals(data.trim())){
            return MesResultModel.error("接收到的数据为空");
        }
        DncLog dncLog = new DncLog();
        dncLog.setNcType(LogCodeUtil.mes_code);
        JsonMapper mapper = new JsonMapper();
        try {
            MesDispatchTaskReceive setMes = mapper.fromJson(data, new TypeReference<MesDispatchTaskReceive>() {});
            dncLog.setIsSuccess(LogCodeUtil.success_is_false);
            if (StringUtils.isEmpty(setMes.getMdsWorkcenterId())) {
                dncLog.setContentName("工厂不存在,数据处理失败");
                dncLogService.save(dncLog);
                return MesResultModel.error("工厂不存在，数据处理失败");
            }
            dncLog.setWorkshopNo(setMes.getMdsWorkcenterId());
            if (StringUtils.isEmpty(setMes.getMdsEquipmentId())) {
                dncLog.setContentName("设备编号为空，数据处理失败");
                dncLogService.save(dncLog);
                return MesResultModel.error("设备编号为空，数据处理失败");
            }
            dncLog.setEquipmentId(setMes.getMdsEquipmentId());

            //去除部分数据
            List<MultilevelDictionaryExt> dictionaryList = multilevelDictionaryService.findListByTypeCode("workcenter");
            if (dictionaryList != null && !dictionaryList.isEmpty()) {
                Map<String,String> map = new HashMap<>();
                for (MultilevelDictionaryExt ext : dictionaryList) {
                    map.put(ext.getDicName(),ext.getDicName());
                }
                if (!map.containsKey(setMes.getMdsWorkcenterId())) {
                    return MesResultModel.error(setMes.getMdsWorkcenterId() + " 车间不在此实施范围内！！！");
                }
            }

            if (StringUtils.isEmpty(setMes.getMdsItemCode())) {
                dncLog.setContentName("零件号不存在,数据处理失败");
                dncLogService.save(dncLog);
                return MesResultModel.error("零件号不存在，数据处理失败");
            }
            if (StringUtils.isEmpty(setMes.getBatchNo())) {
                dncLog.setContentName("工艺信息不存在,数据处理失败");
                dncLogService.save(dncLog);
                return MesResultModel.error("工艺信息不存在，数据处理失败");
            }
            if (StringUtils.isEmpty(setMes.getRouteId())) {
                dncLog.setContentName("工艺规程版本不存在,数据处理失败");
                dncLogService.save(dncLog);
                return MesResultModel.error("工艺规程版本不存在，数据处理失败");
            }
            MesResultModel list = mesDispatchTaskService.saveOrUpdateDis(setMes);
            if(list == null) {
                log.error("[list]:数据保存失败");
                return MesResultModel.error("数据保存失败");
            }
            return MesResultModel.success(list.getSuccFlag());
        } catch (Exception e) {
            log.error(data);
            e.printStackTrace();
            return MesResultModel.error("数据异常，格式不对，无法解析" + "_"+  e.getMessage());

        }
    }

    @Override
    public String issuedProcedureFinish(String data) {
        if(null == data || "".equals(data.trim())){
            return MesResultList.error("接收到的数据为空");
        }
        JsonMapper mapper = new JsonMapper();
        try {
            MesProcedureFinishReceive setMes = mapper.fromJson(data, new TypeReference<MesProcedureFinishReceive>(){});

            MesResultModel list = mesProcedureFinishService.saveOrUpdateDis(setMes);
            if(list == null) {
                log.error("[list]:数据保存失败");
                return MesResultModel.error("数据保存失败");
            }
            return MesResultModel.success(list.getSuccFlag());
        } catch (Exception e) {
            log.error("接收到数据:" + data);
            e.printStackTrace();
            return MesResultModel.error("数据异常，格式不对，无法解析" + "_"+  e.getMessage());

        }
    }


    @Override
    public String syncEquipmentListInfo(String data) {
        if(null == data || "".equals(data.trim())){
            return MesResultList.error("接收到的数据为空");
        }
        JsonMapper mapper = new JsonMapper();
        try {
            MesSyncEquipmentReceive setMes = mapper.fromJson(data, new TypeReference<MesSyncEquipmentReceive>() {});

            MesResultModel list = mesSyncEquipmentService.saveOrUpdateDis(setMes);
            if(list == null) {
                log.error("[list]:数据保存失败");
                return MesResultModel.error("数据保存失败");
            }
            return MesResultModel.success(list.getSuccFlag());
        } catch (Exception e) {
            log.error("接收到数据:" + data);
            e.printStackTrace();
            return MesResultModel.error("数据异常，格式不对，无法解析" + "_"+  e.getMessage());

        }
    }

    @Override
    public String syncWorkmanship(String data) {
        if(null == data || "".equals(data.trim())){
            return MesResultList.error("接收到的数据为空");
        }
        JsonMapper mapper = new JsonMapper();
        try {
            MesSyncWorkmanshipReceive setMes = mapper.fromJson(data, new TypeReference<MesSyncWorkmanshipReceive>() {});
            log.error("接收到数据:" + data);
            MesResultModel list = mesSyncWorkmanshipService.saveOrUpdateMes(setMes);
            if(list == null) {
                log.error("[list]:数据保存失败");
                return MesResultModel.error("数据保存失败");
            }
            return MesResultModel.success(list.getSuccFlag());
        } catch (Exception e) {
            e.printStackTrace();
            return  MesResultModel.error("数据异常，格式不对，无法解析" + "_"+  e.getMessage());

        }
    }

    @Override
    public String syncPlmNcLogProgram(String data) {
        if(null == data || "".equals(data.trim())){
            return MesResultModel.error("接收到的数据为空");
        }
        JsonMapper mapper = new JsonMapper();
        try {
            QueryNcProgramLog setMes = mapper.fromJson(data, new TypeReference<QueryNcProgramLog>(){});

            queryNcProgramLogService.save(setMes);
            /*try {
                pdmProgramSourceService.pdmProgramSyncSave(setMes);
            }catch (Exception e) {
                e.getMessage();
                return MesResultModel.success("2");
            }*/
            /*if(!bf) {
                log.error("[list]:数据保存失败");
                return MesResultModel.error("数据保存失败");
            }*/
            return MesResultModel.success("1");
        } catch (Exception e) {
            log.error("接收到数据:" + data);
            e.printStackTrace();
        }
        return MesResultModel.error("接收到的数据为空");
    }

}