DAL-TMS-TRUCK-API/src/main/java/com/steerinfo/dil/service/impl/StatisticalReportImpl.java

package com.steerinfo.dil.service.impl;

import com.steerinfo.dil.mapper.StatisticalReportMapper;
import com.steerinfo.dil.service.IStatisticalReportService;
import com.steerinfo.dil.util.DataChange;
import oracle.sql.DATE;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestBody;

import java.math.BigDecimal;
import java.util.*;

/**
 * @ author    :TXF
 * @ time      :2021/12/14 15:26
 */
@Service
public class StatisticalReportImpl implements IStatisticalReportService {

    @Autowired
    StatisticalReportMapper statisticalReportMapper;


    /**
     * 计算相差时间
     * @return
     */
    public void calculateDifferenceTime(Map<String, Object> mesMap){
        Object resultEntryGateTime = mesMap.get("resultEntryGateTime");
        Object resultOutGateTime = mesMap.get("resultOutGateTime");
        if(resultEntryGateTime != null && resultOutGateTime != null){
            Date enterDate = (Date) resultEntryGateTime;
            Date outDate = (Date) resultOutGateTime;
            //计算相差时间
            long dTime = outDate.getTime() - enterDate.getTime();
            mesMap.put("inPlantDwellTime", dTime / 60000 + "分钟");
        }
        if(resultEntryGateTime != null && resultOutGateTime == null){
            //如果没有出厂时间则以当前时间减去进厂时间
            Date enterDate = (Date) resultEntryGateTime;
            long dTime = new Date().getTime() - enterDate.getTime();
            mesMap.put("inPlantDwellTime", dTime / 60000 + "分钟");
        }
    }

    /**
     * 查询采购统计报表
     * @Author TXF
     * @Date 2022/1/6 9:52
     * @param map
     * @return
     **/
    public List<Map<String, Object>> getRLFLReport(Map<String, Object> map){
        List<Map<String, Object>> mapList = null;
        if(DataChange.dataToBigDecimal(map.get("orderTypee")).intValue() == 5){
            mapList = statisticalReportMapper.getFuPurchaseFLRLReport(map);
        }else {
            mapList = statisticalReportMapper.getAllPurchaseFLRLReport(map);
        }
        return mapList;
    }

    @Override
    public List<Map<String, Object>> getAllPurchaseFLRLReport(Map<String, Object> map) {
        return statisticalReportMapper.getAllPurchaseFLRLReport(map);
    }

    /**
     * 查询销售统计报表
     * @param map
     * @return
     */
    @Override
    public List<Map<String, Object>> getAllSaleReport(Map<String, Object> map) {
        List<Map<String, Object>> mapList = statisticalReportMapper.getAllSaleReport(map);
        for(Map<String, Object> map1 : mapList) {
            if ( map1.get("resultEntryGateTime") == null) {
                map1.put("transportStatus", "未进厂");
                continue;
            }
            if (map1.get("resultOutGateTime") == null) {
                map1.put("transportStatus", "已进厂");
                continue;
            }
            if (map1.get("arrivalAddress") == null) {
                map1.put("transportStatus", "已出厂");
                continue;
            }
            if (map1.get("receiptAddress") == null) {
                map1.put("transportStatus", "已抵达");
                continue;
            }
            else{
                map1.put("transportStatus", "已签收");
            }

        }
        for (Map<String, Object> mesMap : mapList) {
            calculateDifferenceTime(mesMap);
        }
        return mapList;
    }

    @Override
    public List<Map<String, Object>> getAllSaleReportNum(Map<String, Object> map) {
         List<Map<String, Object>> listMap = statisticalReportMapper.getAllSaleReport(map);
         return listMap;
    }

    /**
     * 查询零星物资进厂统计报表
     */
    @Override
    public List<Map<String, Object>> getSporadicSuppliesReportNum1(Map<String, Object> mapValue) {
        return statisticalReportMapper.getSporadicSuppliesReport1(mapValue);
    }

    @Override
    public List<Map<String, Object>> getSporadicSuppliesReport1(Map<String, Object> mapValue) {
        List<Map<String, Object>> mapList = statisticalReportMapper.getSporadicSuppliesReport1(mapValue);
        for (Map<String, Object> mesMap : mapList) {
            calculateDifferenceTime(mesMap);
        }
        return mapList;
    }

    /**
     * 查询零星物资出厂统计报表
     */
    @Override
    public List<Map<String, Object>> getSporadicSuppliesReportNum2(Map<String, Object> mapValue) {
        return statisticalReportMapper.getSporadicSuppliesReport2(mapValue);
    }

    @Override
    public List<Map<String, Object>> getSporadicSuppliesReport2(Map<String, Object> mapValue) {
        List<Map<String, Object>> mapList = statisticalReportMapper.getSporadicSuppliesReport2(mapValue);
        for (Map<String, Object> mesMap : mapList) {
            calculateDifferenceTime(mesMap);
        }
        return mapList;
    }

    //采购内转统计报表
    @Override
    public List<Map<String, Object>> getPurInwardReport( Map<String, Object> mapValue) {
        List<Map<String, Object>> inwardReportResult = statisticalReportMapper.getInwardReportResult(mapValue);
        for (Map<String,Object>inwardReport:inwardReportResult
        ) {
            if(DataChange.dataToBigDecimal(inwardReport.get("orderType")).intValue() == 10){
                inwardReport.put("transRange","化工园区铁专线-焦化二厂");
            }else{
                inwardReport.put("transRange","化工园区铁专线-达钢厂区");
            }
            BigDecimal netWeightSecond = DataChange.dataToBigDecimal(inwardReport.get("netWeightSecond"));
            BigDecimal netWeightFirst = DataChange.dataToBigDecimal(inwardReport.get("netWeightFirst"));
            BigDecimal netTract = netWeightSecond.subtract(netWeightFirst).divide(new BigDecimal(1), 2, 4);
            //第二次净重减第一次净重
            inwardReport.put("newTract",netTract);
            calculateDifferenceTime(inwardReport);
        }
        return inwardReportResult;
    }

    //采购内转统计报表
    @Override
    public List<Map<String, Object>> getLXInwardReport( Map<String, Object> mapValue) {
        List<Map<String, Object>> lxReportResult = statisticalReportMapper.getLXReportResult(mapValue);
        for (Map<String,Object>inwardReport:lxReportResult
        ) {

            BigDecimal netWeightSecond = DataChange.dataToBigDecimal(inwardReport.get("netWeightSecond"));
            BigDecimal netWeightFirst = DataChange.dataToBigDecimal(inwardReport.get("netWeightFirst"));
            BigDecimal netTract = netWeightSecond.subtract(netWeightFirst).divide(new BigDecimal(1), 2, 4);
            //第二次净重减第一次净重
            inwardReport.put("newTract",netTract);
            calculateDifferenceTime(inwardReport);
        }
        return lxReportResult;
    }

    @Override
    public List<Map<String, Object>> getInwardReport(Map<String, Object> mapValue) {
        return statisticalReportMapper.getInwardReport(mapValue);
    }

    @Override
    public List<Map<String, Object>> getLoading(Map<String, Object> mapValue) {
        return statisticalReportMapper.getLoading(mapValue);
    }

    @Override
    public List<Map<String, Object>> getUnLoading(Map<String, Object> mapValue) {
        return statisticalReportMapper.getUnLoading(mapValue);
    }

    @Override
    public List<Map<String, Object>> getLoaderResult(Map<String, Object> mapValue) {
        return statisticalReportMapper.getLoaderResult(mapValue);
    }

    @Override
    public List<Map<String, Object>> getCapacityByDefend(Map<String, Object> map) {
        return statisticalReportMapper.getCapacityByDefend(map);
    }

    @Override
    public List<Map<String, Object>> getInwardReportForAssemble(Map<String, Object> mapValue) {
        return statisticalReportMapper.getInwardReportForAssemble(mapValue);
    }

    @Override
    public List<Map<String, Object>> getLoaderForResultDetail(Map<String, Object> mapValue) {
        //判断是否含有装机备注

        return statisticalReportMapper.getLoaderForResultDetail(mapValue);
    }


    //查看该组织架构下的销售订单统计报表
    @Override
    public List<Map<String, Object>> getSaleOrderList(Map<String, Object> mapValue) {
        return statisticalReportMapper.getSaleOrderList(mapValue);
    }

    //查看该组织架构下的采购订单统计报表
    @Override
    public List<Map<String, Object>> getPurchaseOrderList(Map<String, Object> mapValue) {
        return  statisticalReportMapper.getPurchaseOrderList(mapValue);
    }

    //查看该组织架构下的采购内转统计报表
    @Override
    public List<Map<String, Object>> getPurchaseInwardList(Map<String, Object> mapValue) {
        return  statisticalReportMapper.getPurchaseInwardList(mapValue);
    }

    //查看该组织架构下的内转统计报表
    @Override
    public List<Map<String, Object>> getInwardInFactory(Map<String, Object> mapValue) {
        return  statisticalReportMapper.getInwardInFactory(mapValue);
    }

    @Override
    public List<Map<String, Object>> getOutFactoryInwardList(Map<String, Object> mapValue) {
        return statisticalReportMapper.getOutFactoryInwardList(mapValue);
    }


    @Override
    public List<Map<String, Object>> getSaleSteelReport(Map<String, Object> mapValue) {
        List<Map<String, Object>> saleSteelReport = statisticalReportMapper.getSaleSteelReport(mapValue);
        return saleSteelReport;
    }



    @Override
    public List<Map<String, Object>> getInwardSaleSteelReport(Map<String, Object> map) {
        return statisticalReportMapper.getInwardSaleSteelReport(map);
    }

    @Override
    public List<Map<String, Object>> getInwardSaleSteelOrder(Map<String, Object> map) {
        List<Map<String, Object>> results=statisticalReportMapper.getInwardSaleSteelOrder(map);
        if(results!=null){
            //遍历找到所有已使用的分录
            Set<BigDecimal> saleMaterialIds=new HashSet<>();
            for(Map<String,Object> temp:results){
                if(temp.get("orderId")!=null){
                    saleMaterialIds.add(DataChange.dataToBigDecimal(temp.get("saleMaterialId")));
                }
            }
            //查询分录已使用但订单id为null的记录
            List<Map<String, Object>> disResults=new ArrayList<>();
            for(Map<String,Object> temp:results){
                if(temp.get("orderId")==null && saleMaterialIds.contains(DataChange.dataToBigDecimal(temp.get("saleMaterialId")))){
                    disResults.add(temp);
                }
            }
            //删除这些记录，防止重复派单
            results.removeAll(disResults);
        }
        return results;
    }

    @Override
    public Map<String,Object> getSteelReportDetailsBySmId(BigDecimal saleOrderMaterialId) {
        //获取主表数据
        Map<String,Object> map = statisticalReportMapper.getSteelReportDetailsBySmId(saleOrderMaterialId);
        //获取子表数据
        List<Map<String,Object>> mapList = statisticalReportMapper.getSteelReportDetailsListBySmId(saleOrderMaterialId);
        if (map != null){
            if(DataChange.dataToBigDecimal(map.get("orderStatu")).intValue() == 5 && map.get("queueStartTime") != null && DataChange.dataToBigDecimal(map.get("lineSqe")).intValue() == 0){
                map.put("orderStatus","排队中");
                map.put("orderStatusTime",map.get("queueStartTime"));
            }else if(DataChange.dataToBigDecimal(map.get("orderStatu")).intValue() == 5 && DataChange.dataToBigDecimal(map.get("lineSqe")).intValue() != 0 && map.get("outGateTime") == null){
                map.put("orderStatus","已进厂");
                map.put("orderStatusTime",map.get("entryGateTime"));
            }else if(DataChange.dataToBigDecimal(map.get("orderStatu")).intValue() == 5 && map.get("outGateTime") != null){
                map.put("orderStatus","已出厂");
                map.put("orderStatusTime",map.get("outGateTime"));
            }
            map.put("mapList",mapList);
        }
        return map;
    }

    @Override
    public String getaddress(BigDecimal addressid) {
        String address = statisticalReportMapper.queryAddress(addressid);
        return address;
    }

    @Override
    public String getcapacityNumber(BigDecimal capacitynumber) {
        String s = statisticalReportMapper.queryCapacityNumber(capacitynumber);
        return s;
    }

}