wms / wms_shandonghaiwang · Files

package com.huaheng.api.tv.controller;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;

import com.huaheng.api.tv.domain.AllBean;
import com.huaheng.api.tv.domain.TopBean;

import com.huaheng.api.tv.domain.TvBean;

import com.huaheng.api.tv.domain.UpBean;

import com.huaheng.api.wcs.domain.WcsTask;
import com.huaheng.common.constant.QuantityConstant;

import com.huaheng.framework.aspectj.lang.annotation.ApiLogger;

import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.container.domain.Container;
import com.huaheng.pc.config.container.service.ContainerService;
import com.huaheng.pc.config.location.domain.Location;
import com.huaheng.pc.config.location.service.LocationService;
import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.material.service.MaterialService;
import com.huaheng.pc.config.zone.domain.Zone;
import com.huaheng.pc.config.zone.service.ZoneService;
import com.huaheng.pc.inventory.InventoryMaterialSummary.domain.InventoryMaterialSummary;
import com.huaheng.pc.inventory.InventoryMaterialSummary.service.InventoryMaterialSummaryService;
import com.huaheng.pc.inventory.inventoryDetail.domain.InventoryDetail;
import com.huaheng.pc.inventory.inventoryDetail.service.InventoryDetailService;
import com.huaheng.pc.inventory.inventoryTransaction.service.InventoryTransactionService;

import com.huaheng.pc.shipment.shipmentDetail.domain.ShipmentDetailTv;
import com.huaheng.pc.shipment.shipmentDetail.mapper.ShipmentDetailMapper;

import com.huaheng.pc.task.taskDetail.domain.TaskDetail;

import com.huaheng.pc.task.taskDetail.service.TaskDetailService;

import com.huaheng.pc.task.taskHeader.domain.TaskHeader;
import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

import java.util.*;

@RestController

@CrossOrigin

@RequestMapping("/API/WMS/v2")
public class TvController extends BaseController {

    @Resource
    private TaskHeaderService taskHeaderService;
    @Resource

    private TaskDetailService taskDetailService;
    @Resource

    private ContainerService containerService;
    @Resource
    private LocationService locationService;
    @Resource
    private InventoryTransactionService inventoryTransactionService;
    @Resource
    private ZoneService zoneService;
    @Resource
    private InventoryDetailService inventoryDetailService;
    @Resource
    private InventoryMaterialSummaryService inventoryMaterialSummaryService;
    @Resource
    private MaterialService materialService;

    @Resource
    private ShipmentDetailMapper shipmentDetailMapper;

    @PostMapping("/getTvView")

    //@ApiLogger(apiName = "获取电视信息", from="TV")

    @ResponseBody
    public AjaxResult getTvView(@RequestBody WcsTask wcsTask) {

        String area = wcsTask.getArea();

        List<TaskHeader> taskHeaderList = taskHeaderService.list(new LambdaQueryWrapper<TaskHeader>()
                .eq(TaskHeader::getArea, area)

                .lt(TaskHeader::getStatus, QuantityConstant.TASK_STATUS_COMPLETED)

                .orderByDesc(TaskHeader::getId));

        //写入物料编码
        if (taskHeaderList != null && !taskHeaderList.isEmpty()) {

            for (TaskHeader taskHeader : taskHeaderList) {

                String materialCode = taskHeader.getMaterialCode();
                String warehouseCode = taskHeader.getWarehouseCode();
                Material material = materialService.getMaterialByCode(materialCode, warehouseCode);

                if (material != null) {

                    taskHeader.setMaterialCode(material.getName());
                }
            }
        }

        //获取指定库区的空托盘数量
        List<Container> containerEmptyList = containerService.list(new LambdaQueryWrapper<Container>()
                .eq(Container::getArea, area)

                .eq(Container::getStatus, QuantityConstant.STATUS_CONTAINER_EMPTY)

                .ne(Container::getLocationCode, ""));

        int containerEmptySize = containerEmptyList.size();

        //获取指定库区的有货托盘数量
        //List<Container> manyEmptyList = containerService.list(new LambdaQueryWrapper<Container>()
        //        .eq(Container::getArea, area)
        //        .eq(Container::getStatus, QuantityConstant.STATUS_CONTAINER_MANY)
        //        .ne(Container::getLocationCode, ""));
        //int manyEmptyListSize = manyEmptyList.size();
        //空托盘的数量+有货托盘数量*6   （有货托盘数量这个项目好像没有啊，所以直接返回空托盘数量）
        //containerEmptySize = containerEmptySize + manyEmptyListSize * 6;

        //获取指定库区的有货托盘数量
        List<Container> containerSomeList = containerService.list(new LambdaQueryWrapper<Container>()
                .eq(Container::getArea, area)

                .eq(Container::getStatus, QuantityConstant.STATUS_CONTAINER_SOME)

                .ne(Container::getLocationCode, ""));

        int containerSomeSize = containerSomeList.size();

        //指定库区总库位数
        List<Location> locationList = locationService.list(new LambdaQueryWrapper<Location>().eq(Location::getArea, area));

        int totalLocationSize = locationList.size();

        //获取指定区域的所有库存数
        Zone zone = zoneService.getOne(new LambdaQueryWrapper<Zone>().eq(Zone::getArea, area));
        List<InventoryDetail> inventoryDetailList = inventoryDetailService.list(new LambdaQueryWrapper<InventoryDetail>()
                .eq(InventoryDetail::getZoneCode, zone.getCode()));

        int inventorySize = inventoryDetailList.size();

        //库存物料汇总
        List<InventoryMaterialSummary> list = inventoryMaterialSummaryService.list(new LambdaQueryWrapper<InventoryMaterialSummary>()
                .eq(InventoryMaterialSummary::getZoneCode, zone.getCode()));

        if (list == null) {
            list = Collections.emptyList();
        }
        //筛选库存汇总数据的专用方法
        List<InventoryMaterialSummary> details = inventoryMaterialSummaryService.duplicateRemoval(list);

        TvBean tvBean = new TvBean();
        tvBean.setDetails(details);
        tvBean.setContainerEmptySize(containerEmptySize);
        tvBean.setContainerSomeSize(containerSomeSize);
        tvBean.setTotalLocationSize(totalLocationSize);
        tvBean.setTaskHeaderList(taskHeaderList);
        tvBean.setInventorySize(inventorySize);
        return AjaxResult.success(tvBean);
    }

    @PostMapping("/getTvReceiptView")
    @ResponseBody

    @ApiLogger(apiName = "获取电视入库信息", from = "TV")

    public AjaxResult getTvReceiptView() {

        AllBean allBean = new AllBean();
        LambdaQueryWrapper<TaskDetail> queryWrapper = Wrappers.lambdaQuery();
        List<String> str = Arrays.asList("100", "200");
        queryWrapper.in(TaskDetail::getTaskType, str)

                .last(" and  date_format( created, '%Y-%m-%d' )= date_format( now(), '%Y-%m-%d' ) and `status`>=100");

        List<TaskDetail> list = taskDetailService.list(queryWrapper);
        List<TopBean> topList = new ArrayList<>();

        if (!list.isEmpty()) {

            topList = taskDetailService.getTvReceiptView("1");

        }

        allBean.setTopList(topList);

        List<UpBean> upList = taskDetailService.getTvNotReceiptList("1");

        allBean.setUpList(upList);
        return AjaxResult.success(allBean);
    }

    @PostMapping("/getTvShipmentView")
    @ResponseBody

    @ApiLogger(apiName = "获取电视出库信息", from = "TV")

    public AjaxResult getTvShipmentView(@RequestBody Map<String, String> map) {
        AllBean allBean = new AllBean();
        List<String> str = Arrays.asList("300", "400");

        List<TaskDetail> list = taskDetailService.list(new LambdaQueryWrapper<TaskDetail>()
                .in(TaskDetail::getTaskType, str)
                .last(" and  date_format( created, '%Y-%m-%d' )= date_format( now(), '%Y-%m-%d' ) and `status`>=100"));

        List<TopBean> topList = new ArrayList<>();

        if (!list.isEmpty()) {

            topList = taskDetailService.getTvReceiptView("2");

        }

        allBean.setTopList(topList);

        List<UpBean> upList = taskDetailService.getTvNotReceiptList("2");

        allBean.setUpList(upList);

        String par = map.get("par");

        List<ShipmentDetailTv> portList = shipmentDetailMapper.getTvOutList(par);

        allBean.setPortList(portList);

        return AjaxResult.success(allBean);
    }

    @PostMapping("/getTvPortShipmentView")
    @ApiOperation("获取出站口出库信息")
    @ResponseBody

    @ApiLogger(apiName = "获取出站口出库信息", from = "TV")
    public AjaxResult getTvPortShipmentView(@RequestBody Map<String, String> map) {

        String par = map.get("par");

        List<ShipmentDetailTv> upList = shipmentDetailMapper.getTvOutList(par);

        return AjaxResult.success(upList);
    }

}