package com.gkhy.safePlatform.equipment.rpc.provider;

import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.equipment.entity.MaterialReceiveRecordsBO;
import com.gkhy.safePlatform.equipment.entity.MaterialReceiveRecordsDO;
import com.gkhy.safePlatform.equipment.entity.SafeMaterialClassifyDO;
import com.gkhy.safePlatform.equipment.excepiton.EquipmentException;
import com.gkhy.safePlatform.equipment.model.dto.req.MaterialSpwDeliveryReq;
import com.gkhy.safePlatform.equipment.model.dto.req.MaterialSpwReq;
import com.gkhy.safePlatform.equipment.model.dto.resp.SafeMaterialClassifyDto;
import com.gkhy.safePlatform.equipment.model.dto.resp.SafeMaterialClassifyStockDto;
import com.gkhy.safePlatform.equipment.model.dto.resp.SafeRfidMaterialDetailDto;
import com.gkhy.safePlatform.equipment.rpc.api.EquipmentRpcAPi;
import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialReceiveRecordsRPCReq;
import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialSpwDeliveryRPCReq;
import com.gkhy.safePlatform.equipment.rpc.api.model.dto.req.MaterialSpwRPCReq;
import com.gkhy.safePlatform.equipment.rpc.api.model.dto.resp.*;
import com.gkhy.safePlatform.equipment.service.MaterialClassifyService;
import com.gkhy.safePlatform.equipment.service.MaterialReceiveRecordsService;
import com.gkhy.safePlatform.equipment.service.SafeMaterialDetailService;
import com.gkhy.safePlatform.equipment.service.impl.MaterialReceiveRecordsServiceImpl;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;

import java.util.ArrayList;
import java.util.List;

@DubboService
public class EquipmentRpcProvider implements EquipmentRpcAPi {
    @Autowired
    private MaterialClassifyService materialClassifyService;
    @Autowired
    private SafeMaterialDetailService safeMaterialDetailService;
    @Autowired
    private MaterialReceiveRecordsService materialReceiveRecordsService;


    public ResultVO<List<SafeMaterialClassifyRPCRespDto>> getMaterialClassifyList(){
      ResultVO<List<SafeMaterialClassifyRPCRespDto>> resultVO = new ResultVO(ResultCodes.OK);
        List<SafeMaterialClassifyDto> list = materialClassifyService.list();
        List<SafeMaterialClassifyRPCRespDto> rpcRespList = new ArrayList<>();
        for (SafeMaterialClassifyDto classifyDto:list) {
            SafeMaterialClassifyRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyRPCRespDto();
            classifyRPCRespDto.setId(classifyDto.getId());
            classifyRPCRespDto.setParentId(classifyDto.getParentId());
            classifyRPCRespDto.setMaterialClassifyName(classifyDto.getMaterialClassifyName());
            List<SafeMaterialClassifyDto> childList = classifyDto.getChildList();
            List<SafeMaterialClassifyRPCRespDto> childRPCList = new ArrayList<>();
            for(SafeMaterialClassifyDto child:childList){
                //临时限制一下
                if(child.getConsumable() == 1){
                    SafeMaterialClassifyRPCRespDto childRPCRespDto = new SafeMaterialClassifyRPCRespDto();
                    childRPCRespDto.setId(child.getId());
                    childRPCRespDto.setParentId(child.getParentId());
                    childRPCRespDto.setMaterialClassifyName(child.getMaterialClassifyName());
                    childRPCRespDto.setConsumable(child.getConsumable());
                    childRPCRespDto.setConsumableName(child.getConsumableName());
                    childRPCList.add(childRPCRespDto);
                }

            }
            classifyRPCRespDto.setChildList(childRPCList);
            rpcRespList.add(classifyRPCRespDto);

        }
       resultVO.setData(rpcRespList);
       return resultVO;
    }

    @Override
    public ResultVO<List<SafeMaterialBsClassifyRPCRespDto>> getTraceabilityClassifyList(List<Long> smallClassifyIds) {
        ResultVO<List<SafeMaterialBsClassifyRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
        try {
            List<SafeMaterialClassifyDO> list = materialClassifyService.getTraceabilityClassifyList(smallClassifyIds);
            List<SafeMaterialBsClassifyRPCRespDto> classifyRPCRespDtoList= new ArrayList<>();
            for(SafeMaterialClassifyDO classifyDO:list){
                SafeMaterialBsClassifyRPCRespDto bsClassifyRPCRespDto = new SafeMaterialBsClassifyRPCRespDto();
                BeanUtils.copyProperties(classifyDO,bsClassifyRPCRespDto);
                classifyRPCRespDtoList.add(bsClassifyRPCRespDto);
            }
            resultVO.setData(classifyRPCRespDtoList);
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }

    public ResultVO<SafeMaterialBsClassifyRPCRespDto> getBigAndSmallClassifyInfo(Long smallClassifyId){
        ResultVO<SafeMaterialBsClassifyRPCRespDto> resultVO = new ResultVO<>(ResultCodes.OK);
        try {
            SafeMaterialClassifyDO safeMaterialClassifyDO = materialClassifyService.getBigAndSmallClassifyInfo(smallClassifyId);
            SafeMaterialBsClassifyRPCRespDto bsClassifyRPCRespDto = new SafeMaterialBsClassifyRPCRespDto();
            if(null != safeMaterialClassifyDO){
                BeanUtils.copyProperties(safeMaterialClassifyDO,bsClassifyRPCRespDto);
            }
            resultVO.setData(bsClassifyRPCRespDto);
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }

    @Override
    public ResultVO<List<SafeMaterialClassifyRPCRespDto>> getClassifyListByIds(List<Long> ids) {
        ResultVO<List<SafeMaterialClassifyRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
        try {
            List<SafeMaterialClassifyDto> listBySmallClassify = materialClassifyService.getClassifyListByIds(ids);
            List<SafeMaterialClassifyRPCRespDto> classifyRPCRespDtoList = new ArrayList<>();
            for(SafeMaterialClassifyDto classifyDto:listBySmallClassify){
                SafeMaterialClassifyRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyRPCRespDto();
                BeanUtils.copyProperties(classifyDto,classifyRPCRespDto);
                classifyRPCRespDtoList.add(classifyRPCRespDto);
            }
            resultVO.setData(classifyRPCRespDtoList);
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }

    @Override
    public ResultVO<List<SafeMaterialClassifyStockRPCRespDto>> getSmallClassifyStockByIds(List<Long> smallClassifyIds) {
        ResultVO<List<SafeMaterialClassifyStockRPCRespDto>> resultVO = new ResultVO<>(ResultCodes.OK);
        try {
            List<SafeMaterialClassifyStockDto> smallClassifyStockList  = safeMaterialDetailService.getSmallClassifyStockByIds(smallClassifyIds);
            List<SafeMaterialClassifyStockRPCRespDto> classifyRPCRespDtoList = new ArrayList<>();
            for(SafeMaterialClassifyStockDto classifyStockDto:smallClassifyStockList){
                SafeMaterialClassifyStockRPCRespDto classifyRPCRespDto = new SafeMaterialClassifyStockRPCRespDto();
                BeanUtils.copyProperties(classifyStockDto,classifyRPCRespDto);
                classifyRPCRespDtoList.add(classifyRPCRespDto);
            }
            resultVO.setData(classifyRPCRespDtoList);
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }

    @Override
    public ResultVO deliveryBatchSpw(MaterialSpwRPCReq req) {
        ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
        MaterialSpwReq materialSpwReq = new MaterialSpwReq();
        List<MaterialSpwDeliveryReq> list = new ArrayList<>();
        List<MaterialSpwDeliveryRPCReq> deliveryRPCReqList = req.getDeliveryReqList();
        if(!CollectionUtils.isEmpty(deliveryRPCReqList)){
            for (MaterialSpwDeliveryRPCReq deliveryRPCReq:deliveryRPCReqList) {
                MaterialSpwDeliveryReq deliveryReq = new MaterialSpwDeliveryReq();
                BeanUtils.copyProperties(deliveryRPCReq,deliveryReq);
                list.add(deliveryReq);
            }
        }
        materialSpwReq.setClaimantId(req.getClaimantId());
        materialSpwReq.setDeliveryReqList(list);

        try {
            safeMaterialDetailService.deliveryBatchSpw(materialSpwReq);
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());
        }
        return resultVO;
    }

    @Override
    public ResultVO<List<SafeRfidMaterialDetailRPCRespDto>> getListByRfid(List<String> rfids) {
        ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
        try {
            List<SafeRfidMaterialDetailDto> listByRfids = safeMaterialDetailService.getListByRfids(rfids);
            if(listByRfids.size()>0){
                List<SafeRfidMaterialDetailRPCRespDto> safeRfidMaterialDetailRPCRespDtos = BeanCopyUtils.copyBeanList(listByRfids, SafeRfidMaterialDetailRPCRespDto.class);
                resultVO.setData(safeRfidMaterialDetailRPCRespDtos);
            }
        }catch (EquipmentException e){
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }

    @Override
    public ResultVO<List<MaterialReceiveRecordsRPCRespDto>> getMaterialReceiveRecords(MaterialReceiveRecordsRPCReq req) {
        ResultVO resultVO = new ResultVO<>(ResultCodes.OK);
        MaterialReceiveRecordsBO  materialReceiveRecordsBO = new MaterialReceiveRecordsBO();
        if(null != req){
            BeanUtils.copyProperties(req,materialReceiveRecordsBO);
        }
        try {
            List<MaterialReceiveRecordsDO> list = materialReceiveRecordsService.getReceiveRecordsByReceiveUids(materialReceiveRecordsBO);
            List<MaterialReceiveRecordsRPCRespDto> materialReceiveRecordsRPCRespDtos = new ArrayList<>();
            if(list.size()>0){
                for(MaterialReceiveRecordsDO recordsDO:list){
                    MaterialReceiveRecordsRPCRespDto receiveRecordsRPCRespDto = new MaterialReceiveRecordsRPCRespDto();
                    BeanUtils.copyProperties(recordsDO,receiveRecordsRPCRespDto);
                    materialReceiveRecordsRPCRespDtos.add(receiveRecordsRPCRespDto);
                }
                resultVO.setData(materialReceiveRecordsRPCRespDtos);
            }
        }catch (EquipmentException e){
            e.printStackTrace();
            resultVO.setCode(e.getCode());
            resultVO.setMsg(e.getMessage());
        }catch (Exception e){
            e.printStackTrace();
            resultVO.setCode(ResultCodes.SERVER_ERROR.getCode());
            resultVO.setMsg(ResultCodes.SERVER_ERROR.getDesc());

        }
        return resultVO;
    }
}