TvController.java 8.96 KB
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);
    }
}