package doumeemes.service.ext.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import doumeemes.biz.system.SystemDictDataBiz;
import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.ApiResponse;
import doumeemes.core.model.LoginUserInfo;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.core.utils.excel.EasyExcelUtil;
import doumeemes.dao.business.RouteCardMapper;
import doumeemes.dao.business.model.Bom;
import doumeemes.dao.business.model.RouteCard;
import doumeemes.dao.business.model.RouteProcedure;
import doumeemes.dao.business.model.Workorder;
import doumeemes.dao.ext.BomExtMapper;
import doumeemes.dao.ext.BomVersionExtMapper;
import doumeemes.dao.ext.RouteCardExtMapper;
import doumeemes.dao.ext.beanDto.QueryBomDTO;
import doumeemes.dao.ext.dto.QueryBomVersionExtDTO;
import doumeemes.dao.ext.dto.QueryDepartmentExtDTO;
import doumeemes.dao.ext.dto.QueryRouteCardExtDTO;
import doumeemes.dao.ext.vo.*;
import doumeemes.service.business.impl.*;
import doumeemes.service.ext.RouteCardExtService;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 工艺卡管理Service实现
 * @author 江蹄蹄
 * @date 2022/06/27 13:58
 */
@Service
public class RouteCardExtServiceImpl implements RouteCardExtService {

    @Autowired
    private RouteCardExtMapper routeCardExtMapper;

    @Autowired
    private RouteCardMapper routeCardMapper;
    @Autowired
    private DepartmentExtServiceImpl departmentExtServiceimpl;
    @Autowired
    private BomExtMapper bomExtMapper;
    @Autowired
    private RouteServiceImpl routeServiceimpl;

    @Autowired
    private ProceduresExtServiceImpl proceduresExtService;


    @Autowired
    private BomVersionExtMapper bomVersionExtMapper;
    @Autowired
    private RouteCardServiceImpl routeCardServiceimpl;

    @Autowired
    public SystemDictDataBiz systemDictDataBiz;

    @Autowired
    private WorkorderServiceImpl workorderServiceimpl;

    @Autowired
    private  BomServiceImpl bomServiceimpl;


    @Autowired
    private RouteProcedureServiceImpl routeProcedureServiceimpl;

    @Override
    public PageData<RouteCardExtListVO> findPage(PageWrap<QueryRouteCardExtDTO> pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        pageWrap.getModel().setDeleted(Constants.ZERO);
        pageWrap.getModel().setRootDepartId(user.getRootDepartment().getId());
        pageWrap.getModel().setDepartId(user.getCurComDepartment().getId());
        //当前登录用户所在所有工厂型组织
        QueryDepartmentExtDTO querydepart=new QueryDepartmentExtDTO();
        querydepart.setType(Constants.ONE);
        List<DepartmentExtListVO> departList= departmentExtServiceimpl.getDepartmentListByConditon(querydepart);
        if(departList.size()>0){
            List<Integer> departIds =departList.stream().map(DepartmentExtListVO::getId).collect(Collectors.toList());
            pageWrap.getModel().setDepartIds(departIds);
        }
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());

        String resourcePath=  systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode();

        List<RouteCardExtListVO> result = routeCardExtMapper.selectList(pageWrap.getModel());
        for(int i=0;i<result.size();i++){
            RouteCardExtListVO rev=result.get(i);
            rev.setResourcePath(resourcePath);
        }
        return PageData.from(new PageInfo<>(result));
    }

    @Transactional(rollbackFor = {BusinessException.class,Exception.class})
    @Override
    public void importExcel(MultipartFile file)  {

        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！");
        }
        //解析excel
        List<RouteCardExtListVO> list = EasyExcelUtil.importExcel(file, 1, 1, RouteCardExtListVO.class);

        if(list == null || list.size()==0){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "导入数据内容有误！");
        }
        for(int i=0;i<list.size();i++){
            RouteCardExtListVO routeCardExtListVO=list.get(i);
            routeCardExtListVO.setDepartId(user.getCurComDepartment().getId());


            /**
             * 工厂
             */
          /*  if(StringUtils.isEmpty(routeCardExtListVO.getDepartName())){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "工厂不能为空！");
            }*/
         /*   QueryDepartmentExtDTO queryDepartmentExtDTOpagewrap=new QueryDepartmentExtDTO();
            queryDepartmentExtDTOpagewrap.setType(Constants.ONE);
            queryDepartmentExtDTOpagewrap.setName(routeCardExtListVO.getDepartName());
            List<DepartmentExtListVO> departList=  departmentExtServiceimpl.getDepartmentListByConditon(queryDepartmentExtDTOpagewrap);
            if(departList==null||departList.size()<=0){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"“"+routeCardExtListVO.getDepartName()+"“工厂不存在！");
            }else{
                routeCardExtListVO.setDepartId(departList.get(0).getId());
            }*/

            /**
             * bom产品
             */
            if(StringUtils.isEmpty(routeCardExtListVO.getMarterialName())){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"产品名称不能为空");

            }
            QueryBomDTO queryboxextpageWrap=new QueryBomDTO();
             queryboxextpageWrap.setDeleted(Constants.ZERO);
            queryboxextpageWrap.setDepartId(user.getCurComDepartment().getId());
            queryboxextpageWrap.setRootDepartId(user.getRootDepartment().getId());
            queryboxextpageWrap.setAbsolutionMaterialName(routeCardExtListVO.getMarterialName());
            List<BomExtListVO> bomlist = bomExtMapper.selectAdminList(queryboxextpageWrap);
            if(bomlist==null&&bomlist.size()<=0){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"“"+routeCardExtListVO.getMarterialName()+"“产品名称不存在！");

            }else{
                routeCardExtListVO.setBomId(bomlist.get(0).getId());
            }

            QueryBomVersionExtDTO bb=new QueryBomVersionExtDTO();
            bb.setBomId(bomlist.get(0).getId());
            BomVersionExtListVO bve= bomVersionExtMapper.selectListByOne(bb);
            if(bve==null){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"“"+routeCardExtListVO.getMarterialName()+"bom历史信息不存在");

            }

            /**
             * 工序
             */
            if(StringUtils.isEmpty(routeCardExtListVO.getProductName())){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"工序不能为空！");

            }
            List<ProceduresExtListVO> producelist= proceduresExtService.getGYListByCondition(bomlist.get(0).getRouteId());
            if(producelist.size()>0){
                Boolean procutemark=true;
                for(int p=0;p<producelist.size();p++){
                    ProceduresExtListVO pv=producelist.get(p);
                    if(StringUtils.equals(pv.getName(),routeCardExtListVO.getProductName().trim())){
                        routeCardExtListVO.setRouteProcedureId(pv.getDmodelRouteProductId());
                        procutemark=false;
                    }
                }
                if(procutemark){
                    throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"工序不存在，请重新输入！");

                }

            }else{
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"“"+routeCardExtListVO.getMarterialName()+"“产品工序不存在！");

            }

            if(StringUtils.isNotEmpty(routeCardExtListVO.getTips())&&routeCardExtListVO.getTips().length()>200){

                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"工艺卡事项最多输入200字");

            }


            RouteCard find=new RouteCard();
            find.setDeleted(Constants.ZERO);
            find.setRootDepartId(user.getRootDepartment().getId());
            find.setDepartId(user.getCurComDepartment().getId());
            find.setBomId(bve.getId());
            find.setRouteProcedureId(routeCardExtListVO.getRouteProcedureId());
            RouteCard finddata= routeCardServiceimpl.findOne(find);
            if(finddata!=null){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"工序已存在，不允许添加");
                }

            RouteCard routeCard=new RouteCard();
            routeCard.setDeleted(Constants.ZERO);
            routeCard.setRootDepartId(user.getRootDepartment().getId());
            routeCard.setDepartId(user.getCurComDepartment().getId());
            routeCard.setCreateTime(new Date());
            routeCard.setCreateUser(user.getId());
            routeCard.setRouteProcedureId(routeCardExtListVO.getRouteProcedureId());
            routeCard.setBomId(bve.getId());
            routeCard.setTips(routeCardExtListVO.getTips());
            routeCardMapper.insert(routeCard);
        }
    }


    @Override
    public List<RouteCardExtListVO> findlistBycondition(PageWrap<QueryRouteCardExtDTO> pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        pageWrap.getModel().setDeleted(Constants.ZERO);
        pageWrap.getModel().setRootDepartId(user.getRootDepartment().getId());
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());

        String resourcePath=  systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode();

        List<RouteCardExtListVO> result = routeCardExtMapper.selectList(pageWrap.getModel());
        for(int i=0;i<result.size();i++){
            RouteCardExtListVO rev=result.get(i);
            rev.setResourcePath(resourcePath);
        }
        return result;
    }



    @Override
    public ApiResponse<RouteCardExtListVO> getListByWorkOrderId(QueryRouteCardExtDTO pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();

        Workorder workorder= workorderServiceimpl.findById(Integer.valueOf(pageWrap.getWorkOrderId()));


        Bom bom=new Bom();
        bom.setRootDepartId(workorder.getRootDepartId());
        bom.setDepartId(workorder.getDepartId());
        bom.setMaterialId(workorder.getMaterialId());
        bom.setDeleted(Constants.ZERO);
        bom.setProcedureId(workorder.getProcedureId());
        Bom bd=bomServiceimpl.findOne(bom);
        Boolean  cardMark=false;
        if(bd!=null){

            //查询工艺关联工序的id
            RouteProcedure routeProcedure=new RouteProcedure();
          //  routeProcedure.setDepartId(workorder.getDepartId());
            routeProcedure.setRouteId(bd.getRouteId());
            routeProcedure.setProcedureId(bd.getProcedureId());
            routeProcedure.setDeleted(Constants.ZERO);
            RouteProcedure findroute=  routeProcedureServiceimpl.findOne(routeProcedure);
            if(findroute==null){
                return ApiResponse.failed("工艺卡关联的工序不存在！");
            }
            String resourcePath=  systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode();
            //查询BOM version的id
            QueryBomVersionExtDTO bb=new QueryBomVersionExtDTO();
            bb.setBomId(bd.getId());
            bb.setRootDepartId(workorder.getRootDepartId());
            bb.setDepartId(workorder.getDepartId());
            bb.setMaterialId(workorder.getMaterialId());
            bb.setProcedureId(workorder.getProcedureId());
            List<BomVersionExtListVO> bomversionlist= bomVersionExtMapper.selectList(bb);
            if(bomversionlist.size()>0){

                for(int i=0;i<bomversionlist.size();i++){
                    BomVersionExtListVO belv=bomversionlist.get(i);
                    pageWrap.setRouteProcedureId(findroute.getId());
                    pageWrap.setBomId(belv.getId());
                    pageWrap.setRootDepartId(workorder.getRootDepartId());
                    pageWrap.setDepartId(workorder.getDepartId());
                    pageWrap.setDeleted(Constants.ZERO);
                    List<RouteCardExtListVO> result = routeCardExtMapper.selectList(pageWrap);
                    if(result.size()>0){
                        cardMark=true;

                        result.get(0).setResourcePath(resourcePath);
                        return ApiResponse.success(result.get(0));
                    }
                }
                if(!cardMark){
                    return ApiResponse.failed("工艺卡信息为空！");
                }
            }else{
                return ApiResponse.failed("BOM历史信息不存在！");
            }

        }else{
            return ApiResponse.failed("BOM不存在！");
        }

        return ApiResponse.success(null);
    }

}