ZarshLocationService.java 4.2 KB
package com.huaheng.pc.sap.service;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.huaheng.api.utils.SAPUtils;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.framework.web.service.ConfigService;
import com.huaheng.pc.config.location.domain.Location;
import com.huaheng.pc.config.location.service.LocationService;
import com.huaheng.pc.sap.domain.Zarsh;
import com.huaheng.pc.sap.mapper.ZarshMapper;
import com.huaheng.pc.task.taskHeader.domain.TaskHeader;
import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;

/**
 * Created by Enzo Cotter on 2022/5/11.
 * @author zhouhong
 */
@Service
public class ZarshLocationService extends ServiceImpl<ZarshMapper, Zarsh> {
    @Resource
    private ZarsiService zarsiService;
    @Resource
    private TaskHeaderService taskHeaderService;
    @Resource
    private LocationService locationService;
    @Resource
    private ConfigService configService;

    /**
     * 配料仓中间仓查询任务表有几个未分配库位,库位表有无库位,预留2个库位
     * 成品仓有方向标的查询任务表有几个未分配库位,库位表有无库位
     * @param  zarsh
     * @param  area
     * @return
     */
    public AjaxResult checkLocationByZarsh(Zarsh zarsh, String area) {
        if (area.equals("4") || area.equals("5")) {
            String zoneCode = SAPUtils.getZoneCode(zarsh);

            LambdaQueryWrapper<TaskHeader> lambdaQuery = Wrappers.lambdaQuery();
            lambdaQuery.eq(TaskHeader::getZoneCode, zoneCode);
            lambdaQuery.eq(TaskHeader::getInternalTaskType, QuantityConstant.TASK_INTENERTYPE_RECEIPT);
            lambdaQuery.eq(TaskHeader::getToLocation, "");
            Integer taskNum = taskHeaderService.count(lambdaQuery);

            LambdaQueryWrapper<Location> lambdaQuery1 = Wrappers.lambdaQuery();
            lambdaQuery1.eq(Location::getArea, area);
            lambdaQuery1.eq(Location::getStatus, QuantityConstant.STATUS_LOCATION_EMPTY);
            lambdaQuery1.eq(Location::getContainerCode, "");

            String crnIn = zarsh.getCrnIn();
            if (area.equals("5")) {
                if (StringUtils.isNotEmpty(crnIn)) {
                    if (crnIn.equals("A")) {
                        lambdaQuery1.in(StringUtils.isNotEmpty(crnIn), Location::getAreaByWcs, "A", "B");
                    } else if (crnIn.equals("C")) {
                        lambdaQuery1.in(StringUtils.isNotEmpty(crnIn), Location::getAreaByWcs, "C", "B");
                    }
                }
            }
//            else if (area.equals("6")) {
//                // 外观仓如果配置了要上线区域划分,则比较库位
//                String value = configService.getKey("online_F");
//                if (StringUtils.isNotEmpty(value) && value.equals("1")) {
//                    if (crnIn.equals("A")) {
//                        lambdaQuery1.in(StringUtils.isNotEmpty(crnIn), Location::getAreaByWcs, "A", "B");
//                    } else if (crnIn.equals("B")) {
//                        lambdaQuery1.in(StringUtils.isNotEmpty(crnIn), Location::getAreaByWcs, "C", "B");
//                    }
//                } else {
//                    return AjaxResult.success();
//                }
//            }
            if (area.equals("5")) {
                lambdaQuery1.ge(StringUtils.isNotEmpty(zarsh.getHFlag()), Location::getHigh, zarsh.getHFlag());
            }
            if (area.equals("7")) {
//                lambdaQuery1.eq(StringUtils.isNotEmpty(zarsh.getRlFlag()), Location::getDirection, zarsh.getRlFlag());
            }
            Integer locationNum = locationService.count(lambdaQuery1);
            if ((locationNum.intValue() - taskNum.intValue()) <= 2) {
                return AjaxResult.error("空闲库位小于2,任务下发失败;请腾出空库位后解锁站台下发");
            }
        }
        return AjaxResult.success();
    }

}