库位锁定或释放 添加任务自动下发功能

skyouc

2 天以前 61eb8dfa4ff44b539d9dd03205705270ba6e1fa7

 src/main/java/com/zy/api/service/impl/HmesApiServiceImpl.java

@@ -5,6 +5,7 @@
import com.core.exception.CoolException;
import com.zy.api.controller.params.ReceviceTaskParams;
import com.zy.api.service.HmesApiService;
import com.zy.api.service.WcsApiService;
import com.zy.asrs.entity.BasDevice;
import com.zy.asrs.entity.LocAroundBind;
import com.zy.asrs.entity.LocMast;
@@ -33,6 +34,9 @@

    @Autowired
    private LocMastService locMastService;

    @Autowired
    private WcsApiService wcsApiService;
    /**
     * 接收MES穿线任务
     * @author Ryan
@@ -90,6 +94,7 @@
     * @return com.core.common.R
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public R releaseLock(ReceviceTaskParams params) {
        if (Objects.isNull(params) || Objects.isNull(params.getDeviceNo())) {
            return R.error("参数不能为空！！");
@@ -106,7 +111,20 @@
        }
        Set<String> locs = binds.stream().map(LocAroundBind::getBLocNo).collect(Collectors.toSet());

        List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().in("loc_no", locs).eq("loc_sts", LocStsType.LOC_STS_TYPE_X.type));
        if (Objects.isNull(locMasts) || locMasts.isEmpty()) {
            throw new CoolException("没有禁用库位，不需要释放！！");
        }

        return null;
        locMasts.forEach(loc -> {
           loc.setLocSts(LocStsType.LOC_STS_TYPE_O.type);
           if (!locMastService.updateById(loc)) {
               throw new CoolException("库位释放失败，请检查后再操作！！");
           }
        });

        wcsApiService.reportLockLocs(locs, "lock");

        return R.ok("释放成功 ！！");
    }
}