WcsServiceImpl.java 4.91 KB
package com.huaheng.api.wcs.service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.huaheng.api.wcs.domain.WcsTask;
import com.huaheng.api.wcs.service.warecellAllocation.LocationAllocationService;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.framework.web.service.ConfigService;
import com.huaheng.pc.config.container.domain.Container;
import com.huaheng.pc.config.container.service.ContainerService;
import com.huaheng.pc.config.containerType.domain.ContainerType;
import com.huaheng.pc.config.containerType.service.ContainerTypeService;
import com.huaheng.pc.config.location.domain.Location;
import com.huaheng.pc.config.location.service.LocationService;
import com.huaheng.pc.config.locationType.domain.LocationType;
import com.huaheng.pc.config.locationType.service.LocationTypeService;
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.inventoryDetail.domain.InventoryDetail;
import com.huaheng.pc.inventory.inventoryDetail.service.InventoryDetailService;
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 org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;

import static java.util.stream.Collectors.toList;

/**
 * @author 游杰
 */
@Service
public class WcsServiceImpl implements WcsService {

    @Resource
    private TaskHeaderService taskheaderService;
    @Resource
    private InventoryDetailService inventoryDetailService;
    @Resource
    private TaskHeaderService taskHeaderService;
    @Resource
    private TaskDetailService taskDetailService;
    @Resource
    private MaterialService materialService;


    /**
     *
     * @param wcsTask
     * @return
     */
    @Override
    public AjaxResult innerBack(WcsTask wcsTask) {
        String containerCode = wcsTask.getContainerCode();
        LambdaQueryWrapper<TaskHeader> taskHeaderLambdaQueryWrapper = Wrappers.lambdaQuery();
        //根据容器号查找
        taskHeaderLambdaQueryWrapper.eq(TaskHeader::getContainerCode, containerCode);
        taskHeaderLambdaQueryWrapper.lt(TaskHeader::getStatus, QuantityConstant.TASK_STATUS_COMPLETED);
        TaskHeader taskHeader = taskheaderService.getOne(taskHeaderLambdaQueryWrapper);
        if(taskHeader == null) {
            return AjaxResult.error("没有找到任务,不允许回库");
        }
        int back = taskHeader.getBack();
        LambdaQueryWrapper<InventoryDetail> inventoryDetailLambdaQueryWrapper = Wrappers.lambdaQuery();;
        inventoryDetailLambdaQueryWrapper.eq(InventoryDetail::getContainerCode, containerCode);
        List<InventoryDetail> inventoryDetailList =
                inventoryDetailService.list(inventoryDetailLambdaQueryWrapper);
        int flag = 0;
        int size = inventoryDetailList.size();
        if(size > 0) {
            flag = 1;
        }
        if(back == 1) {
            return AjaxResult.success("允许回库").setData(flag);
        }
        return AjaxResult.error("任务ID:" + taskHeader.getId() + "不允许回库");
    }

    @Override
    public AjaxResult calculateWeight(String taskNo, String weight1) {
        BigDecimal bigDecimal = new BigDecimal(weight1);
        TaskHeader taskHeader = taskHeaderService.getById(taskNo);
        if(taskHeader == null) {
            return AjaxResult.error("没有找到对应任务:" + taskNo);
        }
        String materialCode = taskHeader.getMaterialCode();
        if(StringUtils.isEmpty(materialCode)) {
            return AjaxResult.error("物料信息为空");
        }
        String warehouseCode = taskHeader.getWarehouseCode();
        LambdaQueryWrapper<TaskDetail> taskDetailLambdaQueryWrapper = Wrappers.lambdaQuery();
        taskDetailLambdaQueryWrapper.eq(TaskDetail::getTaskId, taskNo);
        List<TaskDetail> taskDetailList = taskDetailService.list(taskDetailLambdaQueryWrapper);
        int qty = taskDetailList.size();
        Material material = materialService.getMaterialByCode(materialCode, warehouseCode);
        BigDecimal pieceWeight = material.getPieceWeight();
        // 四舍五入
        BigDecimal totalQty = bigDecimal.divide(pieceWeight, BigDecimal.ROUND_HALF_UP);
        int abs = totalQty.intValue() - qty;
        if(abs == 0) {
            return AjaxResult.success("称重符合数量");
        }
        return AjaxResult.error("称重数量为" + totalQty + "   系统数量为" + qty);
    }
}