4dkankan-after-sale/src/main/java/com/fdkankan/sale/service/impl/RepairSupplyService.java

package com.fdkankan.sale.service.impl;
import java.math.BigDecimal;
import java.util.Date;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fdkankan.sale.common.PageInfo;
import com.fdkankan.sale.common.RepairStatusEnum;
import com.fdkankan.sale.common.ResultCode;
import com.fdkankan.sale.entity.*;
import com.fdkankan.sale.exception.BusinessException;
import com.fdkankan.sale.service.*;
import com.fdkankan.sale.util.DateUtil;
import com.fdkankan.sale.util.StatusUtil;
import com.fdkankan.sale.vo.request.CheckRegisterParam;
import com.fdkankan.sale.vo.request.OrderReceivingParam;
import com.fdkankan.sale.vo.request.RecordingParam;
import com.fdkankan.sale.vo.request.RepairParam;
import com.fdkankan.sale.vo.response.RepairRegisterPartVo;
import com.fdkankan.sale.vo.response.RepairerVo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

@Service
public class RepairSupplyService {

    @Autowired
    IRepairService repairService;
    @Autowired
    IRepairLogService repairLogService;
    @Autowired
    IOrderReceivingService orderReceivingService;
    @Autowired
    ICustomerService customerService;
    @Autowired
    ICustomerAddressService customerAddressService;
    @Autowired
    ICameraService cameraService;
    @Autowired
    ISysUserService sysUserService;
    @Autowired
    IRepairRegisterService repairRegisterService;
    @Autowired
    IRepairRegisterPartService repairRegisterPartService;
    @Autowired
    IPartService partService;
    @Autowired
    IPriceListService priceListService;
    @Autowired
    IPartLogService partLogService;

    /**
     * 维修备件管理 供应链
     * statusParam 0 待备料，1已备料，2待回收
     *      * status 0待接单，10待检测，20待报价，30待确认，40已取消，50待备料，60维修中，70待测试，
     *      *        80待支付（已完结），90待回收，100待发货，110已发货
     */
    public Object supplyOrderList(RepairParam param) {
        List<Integer> repairStatus = StatusUtil.getSupplyStatus(param.getStatusParam());
        param.setStatusList(repairStatus);
        Page<RepairerVo>  voPage = repairService.supplyOrderList(param);
        sysUserService.setSaleNameAndRepairManName(voPage.getRecords());
        return PageInfo.PageInfo(voPage);
    }

    public List<RepairRegisterPartVo> partInfo(String repairId,Integer type) {
        if(type == 0){  //获取备件出库单
            HashMap<Integer,PriceList> priceMap = new HashMap<>();
            List<RepairRegisterPartVo> parts = new ArrayList<>();
            List<PriceList> priceListList = priceListService.getByRepairId(repairId);
            for (PriceList priceList : priceListList) {
                if(priceList.getStatus() == 1){
                    if(priceList.getPartId() != null &&  priceList.getType() == 0){
                        if(priceMap.get(priceList.getPartId()) == null){
                            priceMap.put(priceList.getPartId(),priceList);
                        }else {
                            PriceList priceList1 = priceMap.get(priceList.getPartId());
                            priceList1.setCount(priceList1.getCount() + priceList.getCount());
                        }
                    }
                }
            }
            for (Integer partId : priceMap.keySet()) {
                RepairRegisterPartVo vo = new RepairRegisterPartVo();
                vo.setPartId(partId);
                vo.setPartName(priceMap.get(partId).getName());
                vo.setPartCount(priceMap.get(partId).getCount());
                Part part =  partService.getById(partId);
                if(part != null){
                    vo.setPartNum(part.getPartNum());
                }
                parts.add(vo);
            }

            return  parts;
        }



        LambdaQueryWrapper<PartLog> wrapper2 = new LambdaQueryWrapper<>();
        wrapper2.eq(PartLog::getRepairId,repairId);
        wrapper2.eq(PartLog::getStatus,1);
        List<PartLog> partLogs = partLogService.list(wrapper2);
        HashMap<Integer,PartLog> map = new HashMap<>();
        for (PartLog partLog : partLogs) {
            if(map.get(partLog.getPartId()) != null){
                PartLog partLog1 = map.get(partLog.getPartId());
                partLog1.setCount(partLog1.getCount() + partLog.getCount());
            }else {
                map.put(partLog.getPartId(),partLog);
            }
        }

        List<RepairRegisterPartVo> parts = new ArrayList<>();

        for (Integer partId : map.keySet()) {
            Part part =  partService.getById(partId);
            if(part == null){
                continue;
            }
            RepairRegisterPartVo vo = new RepairRegisterPartVo();
            vo.setPartId(partId);
            vo.setPartName(part.getPartName());
            vo.setPartCount(map.get(partId).getCount());
            vo.setPartNum(part.getPartNum());
            parts.add(vo);
        }
        return parts;
    }

    public void partOut(Repair param, Long userId) {
        if(StringUtils.isBlank(param.getRepairId())){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }

        Repair repair = repairService.getById(param.getRepairId());
        if(repair == null){
            throw new BusinessException(ResultCode.REPAIR_NOT_EXITS);
        }
        if(!repair.getStatus().equals(RepairStatusEnum.TO_BE_PREPARED.status())){
            throw new BusinessException(ResultCode.REPAIR_STATUS_NOT_EXITS);
        }
        List<RepairRegisterPartVo> partVoList = this.partInfo(param.getRepairId(),0);
        for (RepairRegisterPartVo partVo : partVoList) {
            partService.outStockCheck(partVo.getPartId(),partVo.getPartCount(),userId,repair.getRepairId());
        }
        for (RepairRegisterPartVo partVo : partVoList) {
            partService.outStock(partVo.getPartId(),partVo.getPartCount(),userId,repair.getRepairId());
        }

        repairLogService.saveBySysUser(userId,param.getRepairId(),RepairStatusEnum.TO_BE_REPAIRED.status(),repair.getStatus(),"备件出库");
    }

    public void partRecovery(Repair param, Long userId) {
        if(StringUtils.isBlank(param.getRepairId())){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }

        Repair repair = repairService.getById(param.getRepairId());
        if(repair == null){
            throw new BusinessException(ResultCode.REPAIR_NOT_EXITS);
        }
        if(!repair.getStatus().equals(RepairStatusEnum.TO_BE_RECOVERED.status())
                && !repair.getStatus().equals(RepairStatusEnum.TO_BE_CANCELED_RECOVERED.status())){
            throw new BusinessException(ResultCode.REPAIR_STATUS_NOT_EXITS);
        }
        List<RepairRegisterPartVo> partVoList = this.partInfo(param.getRepairId(),1);
        for (RepairRegisterPartVo partVo : partVoList) {
            partService.recovery(partVo.getPartId(),partVo.getPartCount(),userId,repair.getRepairId(),repair.getStatus());
        }
        String remark = null;
        if(StringUtils.isNotBlank(param.getRemark())){
            remark = "回收备注："+param.getRemark();
        }
        repairLogService.saveBySysUser(userId,param.getRepairId(),RepairStatusEnum.TO_BE_SHIPPED.status(),repair.getStatus(),"备件回收",remark);
    }
}