package com.lxzn.plm.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.additional.query.impl.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fasterxml.jackson.core.type.TypeReference;
import com.lxzn.base.service.IDncLogService;
import com.lxzn.base.service.IEquipmentClassService;
import com.lxzn.framework.domain.base.DncLog;
import com.lxzn.framework.domain.base.EquipmentClass;
import com.lxzn.framework.domain.filesystem.response.FileUploadResult;
import com.lxzn.framework.domain.nc.*;
import com.lxzn.framework.domain.nc.response.DocumentCode;
import com.lxzn.framework.domain.plm.PdmProgramSource;
import com.lxzn.framework.domain.plm.QueryNcProgramLog;
import com.lxzn.framework.domain.plm.ext.PdmProgramResult;
import com.lxzn.framework.domain.plm.ext.PdmProgramReturn;
import com.lxzn.framework.domain.plm.ext.PdmProgramSourceExt;
import com.lxzn.framework.domain.plm.request.PdmProgramSourceRequest;
import com.lxzn.framework.exception.ExceptionCast;
import com.lxzn.framework.model.response.CommonCode;
import com.lxzn.framework.model.response.QueryPageResponseResult;
import com.lxzn.framework.utils.*;
import com.lxzn.framework.utils.date.DateUtil;
import com.lxzn.framework.utils.file.FileUtil;
import com.lxzn.nc.service.*;
import com.lxzn.plm.dao.PdmProgramSourceMapper;
import com.lxzn.plm.service.IPdmProgramSourceService;
import com.lxzn.plm.service.IQueryNcProgramLogService;
import com.lxzn.plm.service.PdmWebClientApi;
import lombok.extern.slf4j.Slf4j;
import net.lingala.zip4j.io.ZipInputStream;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.PropertySource;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @author clown
 * * @date 2022/9/19
 */
@Service
@Slf4j
@PropertySource("classpath:/scheduled.properties")
public class PdmProgramSourceServiceImpl extends ServiceImpl<PdmProgramSourceMapper,PdmProgramSource> implements IPdmProgramSourceService {

    @Autowired
    private IQueryNcProgramLogService queryNcProgramLogService;
    @Autowired
    private IProductInfoService productInfoService;
    @Autowired
    private PdmWebClientApi pdmWebClientApi;
    @Autowired
    private IComponentInfoService componentInfoService;
    @Autowired
    private IPermissionStreamService permissionStreamService;
    @Autowired
    private IComponentDepartmentService componentDepartmentService;
    @Autowired
    private IComponentPermissionService componentPermissionService;
    @Autowired
    private IPartsInfoService partsInfoService;
    @Autowired
    private IPartsDepartmentService partsDepartmentService;
    @Autowired
    private IPartsPermissionService partsPermissionService;
    @Autowired
    private IProcessStreamService processStreamService;
    @Autowired
    private IDocInfoService docInfoService;
    @Autowired
    private IDocRelativeService docRelativeService;
    @Autowired
    private IDocFileService docFileService;
    @Autowired
    private IDocClassificationService docClassificationService;
    @Autowired
    private IDncLogService dncLogService;
    @Autowired
    private IEquipmentClassService equipmentClassService;


    @Value("${ncPdm.file_path}")
    private String filePath;

    @Value("${ncPdm.product.root}")
    private String ncPdmProduct;


    @Override
   /* @Scheduled(cron = "${plmCron}")*/
    public void pdmProgramSourceList() {
        List<QueryNcProgramLog> logList = queryNcProgramLogService.findListNcLog();
        if (logList == null || logList.isEmpty()) {
            log.error("======= 无日志新增记录=======");
            return;
        }
        List<PdmProgramSource> sourceList = new ArrayList<>();
        for (QueryNcProgramLog ncLog : logList ) {
            DncLog dncLog = new DncLog();
            dncLog.setNcType(LogCodeUtil.plm_code);
            PdmProgramReturn pro = new PdmProgramReturn();
            pro.setSkgxId(ncLog.getSkgxId());
            pro.setPartRevId(ncLog.getSkgxRevId());
            pro.setSqzt(ncLog.getSqzt());
            JsonMapper mapper = new JsonMapper();
            try {
                Object[] objects = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"",""};
                //String program = "{\"code\":1,\"message\":\"\",\"response\":[{\"skgx_id\":\"CX信息中心10000070\",\"skgx_rev_id\":\"1\",\"skgx_name\":\"焊接数控程序\",\"sqzt\":\"S状态\",\"ae8nc_cxno\":\"CX信息中心10000070\",\"ae8nc_gfrev\":\"1\",\"ae8nc_sbno\":\"2240080\",\"ae8nc_jcid\":\"QJK006\",\"ae8nc_os\":\"华中数控-HNC848C\",\"ae8nc_filename\":\"107052PA5\",\"ae8nc_cxfz\":\"计算机仿真\",\"ae8nc_operator\":\"\",\"ae8nc_inspect\":\"\",\"ae8nc_acceptview\":\"\",\"ae8nc_cxno_unit\":\"信息中心\",\"ae8nc_filename_unit\":\"PA\",\"ae8gallery\":\"\",\"ae8nc_plant\":\"信息中心\",\"ae8nc_modelno\":\"jx\",\"ae8nc_batchno\":\"\",\"meop_id\":\"OPHJ000000000049108\",\"meop_rev_id\":\"A\",\"meop_name\":\"焊接\",\"meop_type\":\"AE8Operation Revision\",\"ae8gx_no\":\"5\",\"process_id\":\"JZG2022008107653\",\"process_rev_id\":\"1\",\"process_name\":\"107052\",\"ae8part_no\":\"107052\",\"ae8stageidentifying\":\"L\",\"ae8gy_type\":\"机加工艺设计\",\"ae8plant\":\"信息中心\",\"part_id\":\"1047051\",\"part_rev_id\":\"01\",\"part_name\":\"集成测试件\",\"create_by\":\"用户2(user2)\",\"create_date\":\"02-9月-22 17:15:14\",\"filename\":\"DNC-CX信息中心10000070-1.zip\",\"filepath\":\"http://192.168.2.234:8081/ncprogram/202209/DNC-CX信息中心10000070-1.zip\"}]}\n";
                String program =pdmWebClientApi.queryNcProgramAttrInfo(objects);
                if (StringUtils.isEmpty(program)) {
                    log.error("======= 无 "+ ncLog.getSkgxId()  +" 新增记录=======");
                    continue;
                }
                PdmProgramResult result = mapper.fromJson(program, new TypeReference<PdmProgramResult>() {
                });
                if (result == null ) {
                    log.error("======= 解析失败,请联系开发人员=======");
                    continue;
                }
                if (result.getResponse() == null) {
                    log.error("======= 解析失败,请联系开发人员=======");
                    continue;
                }
                dncLog.setContentName(program);
                List<PdmProgramSourceExt>  pdmExt = result.getResponse();
                PdmProgramSource source = new PdmProgramSource();
                if(pdmExt == null || pdmExt.isEmpty()) {
                    log.error("======= pdmExt =======");
                    continue;
                }
                BeanMapper.copy(pdmExt.get(0),source);
                //处理字段位空的问题 不进行数据保存 直接返回
                if(StringUtils.isEmpty(source.getFilePath() )) {
                    dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                    dncLog.setRemarks("无NC程序文件,数据不生成");
                    dncLogService.save(dncLog);
                    Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"无程序","失败",null};
                    ncProgramReceived(receivedObject);
                    continue;
                }
                if (StringUtils.isEmpty(source.getAe8ncSbno())
                        || StringUtils.isEmpty(source.getProcessRevId())
                        || StringUtils.isEmpty(source.getAe8ncPlant())
                        || StringUtils.isEmpty(source.getAe8partNo())
                        || StringUtils.isEmpty(source.getAe8gxNo())) {
                    dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                    dncLog.setRemarks("无NC程序文件,数据不生成");
                    dncLogService.save(dncLog);
                    Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"数据缺失内容","失败",null};
                    ncProgramReceived(receivedObject);
                    continue;
                }
                sourceList.add(source);
                //权限分配
                boolean b =  saveProductInfo(source);
                if (!b) {
                    log.error("======= 权限分配,请联系开发人员=======");
                    continue;
                }
                super.save(source);
                Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"","成功",null};
                try {
                    String programReceived = ncProgramReceived(receivedObject);
                    dncLog.setIsSuccess(LogCodeUtil.success_is_true);
                    dncLog.setRemarks("数据生成成功");
                    dncLogService.save(dncLog);
                    log.info(programReceived);
                }catch (Exception e) {
                    continue;
                }

            }catch (Exception e) {
                e.printStackTrace();
                continue;
            }
        }
        queryNcProgramLogService.saveBatch(logList);

    }

    @Override
    @Transactional(rollbackFor = {Exception.class})
    public boolean pdmProgramSyncSave(QueryNcProgramLog ncLog) {
        if (ncLog == null ) {
            log.error("======= 无日志新增记录=======");
            return false;
        }
        //queryNcProgramLogService.save(ncLog);
        DncLog dncLog = new DncLog();
        dncLog.setNcType(LogCodeUtil.plm_code);
        PdmProgramReturn pro = new PdmProgramReturn();
        pro.setSkgxId(ncLog.getSkgxId());
        pro.setPartRevId(ncLog.getSkgxRevId());
        pro.setSqzt(ncLog.getSqzt());
        JsonMapper mapper = new JsonMapper();
        PdmProgramSource source = new PdmProgramSource();
        try {
            Object[] objects = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"",""};
            //String program = "{\"code\":1,\"message\":\"\",\"response\":[{\"skgx_id\":\"CX信息中心10000070\",\"skgx_rev_id\":\"1\",\"skgx_name\":\"焊接数控程序\",\"sqzt\":\"S状态\",\"ae8nc_cxno\":\"CX信息中心10000070\",\"ae8nc_gfrev\":\"1\",\"ae8nc_sbno\":\"2240080\",\"ae8nc_jcid\":\"QJK006\",\"ae8nc_os\":\"华中数控-HNC848C\",\"ae8nc_filename\":\"107052PA5\",\"ae8nc_cxfz\":\"计算机仿真\",\"ae8nc_operator\":\"\",\"ae8nc_inspect\":\"\",\"ae8nc_acceptview\":\"\",\"ae8nc_cxno_unit\":\"信息中心\",\"ae8nc_filename_unit\":\"PA\",\"ae8gallery\":\"\",\"ae8nc_plant\":\"信息中心\",\"ae8nc_modelno\":\"jx\",\"ae8nc_batchno\":\"\",\"meop_id\":\"OPHJ000000000049108\",\"meop_rev_id\":\"A\",\"meop_name\":\"焊接\",\"meop_type\":\"AE8Operation Revision\",\"ae8gx_no\":\"5\",\"process_id\":\"JZG2022008107653\",\"process_rev_id\":\"1\",\"process_name\":\"107052\",\"ae8part_no\":\"107052\",\"ae8stageidentifying\":\"L\",\"ae8gy_type\":\"机加工艺设计\",\"ae8plant\":\"信息中心\",\"part_id\":\"1047051\",\"part_rev_id\":\"01\",\"part_name\":\"集成测试件\",\"create_by\":\"用户2(user2)\",\"create_date\":\"02-9月-22 17:15:14\",\"filename\":\"DNC-CX信息中心10000070-1.zip\",\"filepath\":\"http://192.168.2.234:8081/ncprogram/202209/DNC-CX信息中心10000070-1.zip\"}]}\n";
            String program =pdmWebClientApi.queryNcProgramAttrInfo(objects);
            if (StringUtils.isEmpty(program)) {
                log.error("======= 无 "+ ncLog.getSkgxId()  +" 新增记录=======");
                return false;
            }
            PdmProgramResult result = mapper.fromJson(program, new TypeReference<PdmProgramResult>() {
            });
            if (result == null ) {
                log.error("======= 解析失败,请联系开发人员=======");
                return false;
            }
            if (result.getResponse() == null) {
                log.error("======= 解析失败,请联系开发人员=======");
                return false;
            }
            dncLog.setContentName(program);
            List<PdmProgramSourceExt>  pdmExt = result.getResponse();

            if(pdmExt == null || pdmExt.isEmpty()) {
                log.error("======= pdmExt =======");
                return false;
            }
            BeanMapper.copy(pdmExt.get(0),source);
            //处理字段位空的问题 不进行数据保存 直接返回
            if(StringUtils.isEmpty(source.getFilePath() )) {
                dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                dncLog.setRemarks("无NC程序文件,数据不生成");
                dncLogService.save(dncLog);
                Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"失败","无程序",null};
                ncProgramReceived(receivedObject);
                return false;
            }
            if (StringUtils.isEmpty(source.getAe8ncSbno())
                    || StringUtils.isEmpty(source.getProcessRevId())
                    || StringUtils.isEmpty(source.getAe8ncPlant())
                    || StringUtils.isEmpty(source.getAe8partNo())
                    || StringUtils.isEmpty(source.getAe8gxNo())) {
                dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                dncLog.setRemarks("无NC程序文件,数据不生成");
                dncLogService.save(dncLog);
                Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"失败","数据缺失内容",null};
                ncProgramReceived(receivedObject);
                return true;
            }
            //权限分配
            boolean b =  saveProductInfo(source);
            if (!b) {
                log.error("======= 权限分配,请联系开发人员=======");
                return false;
            }
            super.save(source);
            Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"成功","",null};
            try {
                String programReceived = ncProgramReceived(receivedObject);
                dncLog.setIsSuccess(LogCodeUtil.success_is_true);
                dncLog.setRemarks("数据生成成功");
                dncLogService.save(dncLog);
                log.info(programReceived);
            }catch (Exception e) {
                return false;
            }

        }catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    @Override
    @Scheduled(cron = "${plmCron}")
    public boolean pdmSaveSyncNew() {
        List<QueryNcProgramLog> logNcs = queryNcProgramLogService.findLogNewLogOneDate();
        if (logNcs == null || logNcs.isEmpty()) {
            return false;
        }
        QueryNcProgramLog ncLog = logNcs.get(0);
        if (ncLog == null ) {
            log.error("======= 无日志新增记录=======");
            return false;
        }
        //queryNcProgramLogService.save(ncLog);
        DncLog dncLog = new DncLog();
        dncLog.setNcType(LogCodeUtil.plm_code);

        PdmProgramReturn pro = new PdmProgramReturn();
        pro.setSkgxId(ncLog.getSkgxId());
        pro.setPartRevId(ncLog.getSkgxRevId());
        pro.setSqzt(ncLog.getSqzt());
        JsonMapper mapper = new JsonMapper();
        PdmProgramSource source = new PdmProgramSource();
        try {
            Object[] objects = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"",""};
            //String program = "{\"code\":1,\"message\":\"\",\"response\":[{\"skgx_id\":\"CX信息中心10000070\",\"skgx_rev_id\":\"1\",\"skgx_name\":\"焊接数控程序\",\"sqzt\":\"S状态\",\"ae8nc_cxno\":\"CX信息中心10000070\",\"ae8nc_gfrev\":\"1\",\"ae8nc_sbno\":\"2240080\",\"ae8nc_jcid\":\"QJK006\",\"ae8nc_os\":\"华中数控-HNC848C\",\"ae8nc_filename\":\"107052PA5\",\"ae8nc_cxfz\":\"计算机仿真\",\"ae8nc_operator\":\"\",\"ae8nc_inspect\":\"\",\"ae8nc_acceptview\":\"\",\"ae8nc_cxno_unit\":\"401\",\"ae8nc_filename_unit\":\"PA\",\"ae8gallery\":\"\",\"ae8nc_plant\":\"401\",\"ae8nc_modelno\":\"jx\",\"ae8nc_batchno\":\"\",\"meop_id\":\"OPHJ000000000049108\",\"meop_rev_id\":\"A\",\"meop_name\":\"焊接\",\"meop_type\":\"AE8Operation Revision\",\"ae8gx_no\":\"5\",\"process_id\":\"JZG2022008107653\",\"process_rev_id\":\"1\",\"process_name\":\"107052\",\"ae8part_no\":\"107052\",\"ae8stageidentifying\":\"L\",\"ae8gy_type\":\"机加工艺设计\",\"ae8plant\":\"信息中心\",\"part_id\":\"1047051\",\"part_rev_id\":\"01\",\"part_name\":\"集成测试件\",\"create_by\":\"用户2(user2)\",\"create_date\":\"02-9月-22 17:15:14\",\"filename\":\"DNC-CX信息中心10000070-1.zip\",\"filepath\":\"http://192.168.2.234:8081/ncprogram/202209/DNC-CX信息中心10000070-1.zip\"}]}\n";
            String program =pdmWebClientApi.queryNcProgramAttrInfo(objects);
            if (StringUtils.isEmpty(program)) {
                log.error("======= 无 "+ ncLog.getSkgxId()  +" 新增记录=======");
                return false;
            }
            ncLog.setUpdateSave("1");
            queryNcProgramLogService.saveOrUpdate(ncLog);
            PdmProgramResult result = mapper.fromJson(program, new TypeReference<PdmProgramResult>() {
            });
            if (result == null ) {
                log.error("======= 解析失败,请联系开发人员=======");
                return false;
            }
            if (result.getResponse() == null) {
                log.error("======= 解析失败,请联系开发人员=======");
                return false;
            }

            dncLog.setContentName(program);
            List<PdmProgramSourceExt>  pdmExt = result.getResponse();

            if(pdmExt == null || pdmExt.isEmpty()) {
                log.error("======= pdmExt =======");
                return false;
            }
            BeanMapper.copy(pdmExt.get(0),source);
            //处理字段位空的问题 不进行数据保存 直接返回
            if(StringUtils.isEmpty(source.getFilePath() )) {
                dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                dncLog.setRemarks("无NC程序文件,数据不生成");
                dncLogService.save(dncLog);
                Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"失败","无程序",null};
                ncProgramReceived(receivedObject);
                return false;
            }
            if (StringUtils.isEmpty(source.getAe8ncSbno())
                    || StringUtils.isEmpty(source.getProcessRevId())
                    || StringUtils.isEmpty(source.getAe8ncPlant())
                    || StringUtils.isEmpty(source.getAe8partNo())
                    || StringUtils.isEmpty(source.getAe8gxNo())) {
                dncLog.setIsSuccess(LogCodeUtil.success_is_false);
                dncLog.setRemarks("无NC程序文件,数据不生成");
                dncLogService.save(dncLog);
                Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"失败","数据缺失内容",null};
                ncProgramReceived(receivedObject);
                return true;
            }
            dncLog.setEquipmentId(source.getAe8ncSbno());
            dncLog.setWorkshopNo(source.getAe8ncPlant());
            //权限分配
            boolean b =  saveProductInfo(source);
            if (!b) {
                log.error("======= 权限分配,请联系开发人员=======");
                return false;
            }
            super.save(source);
            Object[] receivedObject = new  Object[]{ncLog.getSkgxId(),ncLog.getSkgxRevId(),ncLog.getSqzt(),"成功","",null};
            try {
                String programReceived = ncProgramReceived(receivedObject);
                dncLog.setIsSuccess(LogCodeUtil.success_is_true);
                dncLog.setRemarks("数据生成成功");
                dncLogService.save(dncLog);
                log.info(programReceived);
            }catch (Exception e) {
                return false;
            }

        }catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    public String ncProgramReceived( Object[] receivedObject){
        try {
            String programReceived = pdmWebClientApi.setNcProgramReceived(receivedObject);
            return programReceived;
        }catch (Exception e) {
            return null;
        }
    }

    @Override
    @Transactional(rollbackFor = {Exception.class})
    public boolean saveProductInfo(PdmProgramSource source) {
        ProductInfo processInfo = productInfoService.getById(ncPdmProduct);
        if (processInfo == null) {
            log.error("======= 产品层级异常,请联系开发人员=======");
            return false;
        }
        /**
         * 1、部件总 按照部门（车间 ae8nc_plant ）维度建立
         * 2、子部件  型别
         * 3、零件 图号（零件号） ae8part_no
         * 4、工序  工艺ID（工艺规程编号/临规编号）
         */
        //1、部件总
        ComponentInfo compTotal = componentInfoService.getByCode(source.getAe8ncPlant());
        if (compTotal == null) {
            compTotal = new ComponentInfo();
            compTotal.setComponentCode(source.getAe8ncPlant());
            compTotal.setProductId(ncPdmProduct);
            compTotal.setComponentName(source.getAe8ncPlant());
            compTotal.setComponentStatus(1);
            compTotal.setRankLevel(1);
            compTotal.setComponentId(IdWorker.getIdStr());
            boolean b = componentInfoService.save(compTotal);
            if(!b) {
                return false;
            }
            boolean c = savePermissionList(compTotal,processInfo.getProductId());
            if (!c) {
                return false;
            }
        }
        ComponentInfo compTotalF = componentInfoService.getByCode(source.getAe8ncModelNo() +"_" + source.getAe8ncPlant());
        if (compTotalF == null) {
            compTotalF = new ComponentInfo();
            compTotalF.setComponentCode(source.getAe8ncModelNo() +"_" + source.getAe8ncPlant());
            compTotalF.setProductId(ncPdmProduct);
            compTotalF.setComponentName(source.getAe8ncModelNo());
            compTotalF.setComponentStatus(1);
            compTotalF.setRankLevel(2);
            compTotalF.setParentId(compTotal.getComponentId());
            compTotalF.setComponentId(IdWorker.getIdStr());
            boolean b = componentInfoService.save(compTotalF);
            if(!b) {
                return false;
            }
            boolean c = savePermissionList(compTotalF,processInfo.getProductId());
            if (!c) {
                return false;
            }
        }

        //3、零件 图号（零件号） ae8part_no
        PartsInfo part = partsInfoService.getByCode(source.getAe8partNo());
        if(part == null) {
            List<PartsDepartment> partsDepartPermList = new ArrayList<>();
            List<PermissionStream> partsPermList = new ArrayList<>();
            List<PartsPermission> partsUserPermList = new ArrayList<>();
            PartsDepartment department;
            PartsPermission permission;
            PermissionStream stream;
            part = new PartsInfo();
            part.setPartsId(IdWorker.getIdStr());
            part.setComponentId(compTotalF.getComponentId());
            part.setProductId(compTotalF.getProductId());
            part.setPartsStatus(1);
            part.setPartsCode(source.getAe8partNo());
            part.setPartsName(source.getAe8partNo());
            part.setPartsModel(source.getAe8partNo());
          /*  part.setMaterielCode(source.getAe8partNo());
            part.setMaterielDesp(source.getAe8partNo());*/

            boolean b = partsInfoService.save(part);
            if(!b) {
                return false;
            }
            //权限
            List<PermissionStream> oldPermissionList = permissionStreamService.getAllByProductId(ncPdmProduct);
            if(oldPermissionList != null && !oldPermissionList.isEmpty()) {
                for(PermissionStream p : oldPermissionList) {
                    if(ValidateUtil.validateString(p.getUserId())) {
                        //用户权限
                        permission = new PartsPermission();
                        permission.setPartsId(part.getPartsId());
                        permission.setUserId(p.getUserId());
                        partsUserPermList.add(permission);

                        stream = new PermissionStream();
                        stream.setUserId(p.getUserId());
                        stream.setProductId(part.getProductId());
                        stream.setComponentId(part.getComponentId());
                        stream.setPartsId(part.getPartsId());
                        partsPermList.add(stream);
                    }
                    if(ValidateUtil.validateString(p.getDepartId())) {
                        //部门权限
                        department = new PartsDepartment();
                        department.setPartsId(part.getPartsId());
                        department.setDepartId(p.getDepartId());
                        partsDepartPermList.add(department);
                        stream = new PermissionStream();
                        stream.setProductId(part.getProductId());
                        stream.setComponentId(part.getComponentId());
                        stream.setPartsId(part.getPartsId());
                        stream.setDepartId(p.getDepartId());
                        partsPermList.add(stream);
                    }
                }
                if(!partsUserPermList.isEmpty()) {
                    b = partsPermissionService.saveBatch(partsUserPermList);
                    if(!b) {
                        return false;
                    }
                }
                if(!partsDepartPermList.isEmpty()) {
                    b = partsDepartmentService.saveBatch(partsDepartPermList);
                    if(!b) {
                        return false;
                    }
                }
                if(!partsPermList.isEmpty()) {
                    b = permissionStreamService.saveBatch(partsPermList);
                    if(!b) {
                        return false;
                    }
                }
            }

        }
        //4、工序  工艺ID（工艺规程编号/临规编号）
        List<ProcessStream> addProcessList = new ArrayList<>();

        List<ProcessStream> updateProcessList = new ArrayList<>();
        ProcessStream stream; //ae8gx_no
        String processCode = source.getAe8gxNo();
        if (!StringUtils.isEmpty(source.getAe8ncSbno())) {
            processCode = processCode + "_" + source.getAe8ncSbno();
        }
        stream = processStreamService.findByProcessNoAndPartsId(processCode, part.getPartsId());
        if(stream == null) {
            stream = new ProcessStream();
            stream.setProcessId(IdWorker.getIdStr());
            stream.setProductId(part.getProductId());
            stream.setComponentId(part.getComponentId());
            stream.setPartsId(part.getPartsId());
            stream.setProcessCode(processCode);
            stream.setProcessName(source.getSkgxName());
            /*数控工序号*/
            stream.setCraftNo(source.getSkgxId());
            stream.setCraftVersion(source.getProcessRevId());

            stream.setDescription(source.getSqzt());
            //stream.set
            /*机床操作系统  ae8nc_os*/
            EquipmentClass classE = equipmentClassService.findEquipmentIdsFromEqId(source.getAe8ncPlant(),source.getAe8ncSbno());
            if (classE != null && StringUtils.isNotEmpty(classE.getEquipmentIds())) {
                stream.setProcessingEquipmentCode(classE.getEquipmentIds());
            } else {
                stream.setProcessingEquipmentCode(source.getAe8ncSbno());
            }
            stream.setProcessingEquipmentOs(source.getAe8ncOs());
            stream.setProcessingEquipmentModel(source.getAe8ncJcId());
            addProcessList.add(stream);
        }else {
            stream.setProcessName(source.getSkgxName());
            stream.setDescription(source.getSqzt());
            updateProcessList.add(stream);
        }

        if(!addProcessList.isEmpty()) {
            boolean b = processStreamService.saveBatch(addProcessList);
            if(!b) {
                return false;
            }
        }
        if(!updateProcessList.isEmpty()){
            boolean b = processStreamService.updateBatchById(updateProcessList);
            if(!b) {
                return false;
            }
        }
        //下载数据并解压
        if(stream == null) {
            return false;
        }
        String itemCode = stream.getProcessCode();
        DocClassification docClass = docClassificationService.getByCode("NC");
        if(docClass == null) {
            return false;
        }
        try {
            String fileName = readFileName(itemCode);
            boolean b =  HttpRequest.downLoadFromUrl(source.getFilePath(),fileName,filePath);
            if(b){
                String localPath = filePath;
                File file = new File(localPath + File.separator + fileName);
                if(file.exists() && file.isFile() && file.length() > 0) {
                    Map<String, ZipInputStream> map = ZipUtil.readZipFileStream(file);
                    if(map == null || map.isEmpty()) {
                        ExceptionCast.cast(CommonCode.FAIL);
                    }
                    for(Map.Entry<String, ZipInputStream> entry : map.entrySet()) {
                        String suffix = FileUtil.getFileSuffix(entry.getKey());
                        if (suffix.contentEquals("docx") || suffix.contentEquals("pdf") ) {
                            continue;
                        }
                        DocInfo docInfo = docInfoService.findByAttrAndDocName(FileUtil.getFilenameNonSuffix(entry.getKey()), 5,
                                stream.getProcessId(),suffix);
                        //新增
                        FileUploadResult fileUploadResult = FileUtil.uploadFile(entry.getKey(),
                                entry.getValue());
                        if(fileUploadResult == null) {
                            ExceptionCast.cast(DocumentCode.DOC_UPLOAD_ERROR);
                        }
                        if(docInfo == null) {
                            //代码逻辑调整
                            //TODO
                            docInfo = new DocInfo();
                            String docId = IdWorker.getIdStr();
                            docInfo.setDocId(docId);
                            docInfo.setDocName(fileUploadResult.getFileName());
                            docInfo.setDocSuffix(fileUploadResult.getFileSuffix());
                            docInfo.setDocStatus(1);
                            DocRelative docRelative = new DocRelative();
                            docRelative.setAttributionId(stream.getProcessId());
                            docRelative.setDocId(docInfo.getDocId());
                            docRelative.setAttributionType(5);
                            docRelative.setClassificationId(docClass.getClassificationId());
                            b = docRelativeService.save(docRelative);
                            if(!b) {
                                return false;
                            }
                            DocFile docFile = new DocFile();
                            docFile.setDocId(docInfo.getDocId());
                            docFile.setFileName(fileUploadResult.getFileName());
                            docFile.setFileEncodeName(fileUploadResult.getEncodeFileName());
                            docFile.setFilePath(fileUploadResult.getFilePath());
                            docFile.setFileSize(fileUploadResult.getFileSize());
                            docFile.setFileSuffix(fileUploadResult.getFileSuffix());
                            b =  docFileService.addDocFile(docFile);
                            if(!b) {
                                return false;
                            }
                            docInfo.setPublishVersion(docFile.getDocVersion());
                            docInfo.setPublishFileId(docFile.getFileId());
                            b =  docInfoService.save(docInfo);
                            if(!b){
                                return false;
                            }
                        }else {
                            //升版
                            DocFile docFile = new DocFile();
                            docFile.setDocId(docInfo.getDocId());
                            docFile.setFileName(fileUploadResult.getFileName());
                            docFile.setFileEncodeName(fileUploadResult.getEncodeFileName());
                            docFile.setFilePath(fileUploadResult.getFilePath());
                            docFile.setFileSize(fileUploadResult.getFileSize());
                            docFile.setFileSuffix(fileUploadResult.getFileSuffix());
                            b = docFileService.addDocFile(docFile);
                            if(!b){
                                return false;
                            }
                            docInfo.setPublishVersion(docFile.getDocVersion());
                            docInfo.setPublishFileId(docFile.getFileId());
                            b = docInfoService.updateById(docInfo);
                            if(!b) {
                                return false;
                            }
                        }
                    }
                    return true;
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage());
            return false;
        }
        return false;
    }


    private boolean savePermissionList(ComponentInfo comp, String totalOrSonId) {
        boolean b;
        List<PermissionStream> oldPermissionList = permissionStreamService.getAllByProductId(totalOrSonId);
        //权限
        List<ComponentDepartment> componentDepartmentList = new ArrayList<>();
        List<PermissionStream> componentDepartPermList = new ArrayList<>();
        List<ComponentPermission> componentPermissionList = new ArrayList<>();
        ComponentDepartment department;
        ComponentPermission permission;
        PermissionStream stream;
        if(oldPermissionList != null && !oldPermissionList.isEmpty()) {
            for (PermissionStream p : oldPermissionList) {
                if (ValidateUtil.validateString(p.getUserId())) {
                    //部门权限
                    permission = new ComponentPermission();
                    permission.setComponentId(comp.getComponentId());
                    permission.setUserId(p.getUserId());
                    componentPermissionList.add(permission);

                    stream = new PermissionStream();
                    stream.setUserId(p.getUserId());
                    stream.setProductId(comp.getProductId());
                    stream.setComponentId(comp.getComponentId());
                    componentDepartPermList.add(stream);
                }
                if (ValidateUtil.validateString(p.getDepartId())) {
                    //用户权限
                    department = new ComponentDepartment(comp.getComponentId(), p.getDepartId());
                    componentDepartmentList.add(department);
                    stream = new PermissionStream(comp.getProductId(), comp.getComponentId());
                    stream.setDepartId(p.getDepartId());
                    componentDepartPermList.add(stream);
                }

            }
        }
        if(!componentDepartmentList.isEmpty()) {
            b = componentDepartmentService.saveBatch(componentDepartmentList);
            if(!b) {
                return false;
            }
        }
        if(!componentPermissionList.isEmpty()) {
            b = componentPermissionService.saveBatch(componentPermissionList);
            if(!b) {
                return false;
            }
        }
        if(!componentDepartPermList.isEmpty()) {
            b = permissionStreamService.saveBatch(componentDepartPermList);
            if(!b) {
                return false;
            }
        }
        return true;
    }

    @Override
    public String readFileName(String itemCode){
        return "pdm_" + itemCode + ".zip";
    }

    @Override
    public QueryPageResponseResult<PdmProgramSource> findPageList(int page, int size, PdmProgramSourceRequest requestParams) {
        if(page < 1 || size < 1) {
            ExceptionCast.cast(CommonCode.INVALID_PAGE);
        }
        IPage<PdmProgramSource> pageData = new Page<>(page, size);
        LambdaQueryChainWrapper<PdmProgramSource> lambdaQuery = super.lambdaQuery();
        if(requestParams != null) {
            if(ValidateUtil.validateString(requestParams.getAe8gxNo())) {
                lambdaQuery.eq(PdmProgramSource::getAe8gxNo, requestParams.getAe8gxNo());
            }
            if(ValidateUtil.validateString(requestParams.getAe8ncSbno())) {
                lambdaQuery.eq(PdmProgramSource::getAe8ncSbno, requestParams.getAe8ncSbno());
            }
            if(ValidateUtil.validateString(requestParams.getPartName())) {
                lambdaQuery.like(PdmProgramSource::getPartName, requestParams.getPartName());
            }
            if(ValidateUtil.validateString(requestParams.getProcessId())) {
                lambdaQuery.like(PdmProgramSource::getProcessId, requestParams.getProcessId());
            }
            if(ValidateUtil.validateString(requestParams.getProcessRevId())) {
                lambdaQuery.like(PdmProgramSource::getProcessRevId, requestParams.getProcessRevId());
            }
            if(ValidateUtil.validateString(requestParams.getEndTime())) {
                String date = DateUtil.format(DateUtil.plusTime(DateUtil.toDate(requestParams.getEndTime(),DateUtil.STR_DATE),1),DateUtil.STR_DATE);
                lambdaQuery.lt(PdmProgramSource::getCreateTime,date);
            }
            if(ValidateUtil.validateString(requestParams.getStartTime())) {
                lambdaQuery.ge(PdmProgramSource::getCreateTime,requestParams.getStartTime());
            }
            if(ValidateUtil.validateString(requestParams.getWorkshopNo())) {
                lambdaQuery.like(PdmProgramSource::getAe8ncPlant, requestParams.getWorkshopNo());
            }
            if(ValidateUtil.validateString(requestParams.getCreateTime())) {
                if (requestParams.getCreateTime().equals("asc")) {
                    lambdaQuery.orderByAsc(true,PdmProgramSource::getCreateTime);
                } else  if (requestParams.getCreateTime().equals("desc")) {
                    lambdaQuery.orderByDesc(true,PdmProgramSource::getCreateTime);
                }
            }
        }
        IPage<PdmProgramSource> userIPage = lambdaQuery.page(pageData);
        return new QueryPageResponseResult<>(CommonCode.SUCCESS, userIPage);
    }
}