From c19cf2f4c2419e403294ebdc025fe90ff7dee74c Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期四, 13 三月 2025 14:28:48 +0800 Subject: [PATCH] 配置信息 --- src/main/java/com/zy/asrs/service/impl/LocMastServiceImpl.java | 70 ++++++++++++++++++++++++++++++++++ 1 files changed, 69 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/LocMastServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/LocMastServiceImpl.java index 1336d66..c5831e6 100644 --- a/src/main/java/com/zy/asrs/service/impl/LocMastServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/LocMastServiceImpl.java @@ -1,16 +1,34 @@ package com.zy.asrs.service.impl; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.core.common.Cools; +import com.core.common.R; import com.zy.asrs.entity.LocMast; +import com.zy.asrs.entity.WmsLocStatus; import com.zy.asrs.mapper.LocMastMapper; +import com.zy.asrs.service.ApiLogService; import com.zy.asrs.service.LocMastService; +import com.zy.asrs.utils.Utils; +import com.zy.common.utils.HttpHandler; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; +import java.util.HashMap; import java.util.List; +import java.util.Map; +@Slf4j @Service("locMastService") public class LocMastServiceImpl extends ServiceImpl<LocMastMapper, LocMast> implements LocMastService { + @Value("${wms.url}") + private String wmsUrl; + @Autowired + private ApiLogService apiLogService; @Override public List<Integer> queryDistinctRow(Integer crnNo) { @@ -54,11 +72,61 @@ @Override public LocMast selectByLocNo(String locNo) { - return this.baseMapper.selectByLocNo(locNo); + return this.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locNo)); + + //return this.baseMapper.selectByLocNo(locNo); } @Override public List<LocMast> selectLocByLev(Integer lev) { return this.baseMapper.selectLocByLev(lev); } + + @Override + public R toWmsLocStatus(LocMast locMast) { + String response = null; + Map<String, Object> map = new HashMap<>(); + map.put("x-api-key", "7a15b5db-29b6-552c-8cff-0cfec3756da2"); + WmsLocStatus param = new WmsLocStatus(); + param.setWarehouseId("1688469798893297665"); + param.setLocationCode(Utils.getWmsLocNo(locMast.getLocNo())); + param.setEmptyContainer(locMast.getEmptyContainer$()); + if (locMast.getLocSts().equals("Z")) { + param.setStatus("JY"); + } else { + param.setStatus("QY"); + } + if (Cools.isEmpty(locMast.getBarcode()) || locMast.getLocSts().equals("O")) { + param.setContainerCode(""); + param.setContainerTypeCode(""); + } else { + param.setContainerCode(locMast.getBarcode()); + param.setContainerTypeCode(locMast.getContainerTypeCode()); + } + + try { + response = new HttpHandler.Builder() + .setHeaders(map) + .setUri(wmsUrl) + .setPath("wcsManager/wcsInterface/locationUpdate") + .setJson(JSON.toJSONString(param)) + .build() + .doPost(); + } catch (Exception e) { + log.error("鍫嗗灈鏈轰换鍔″畬鎴愶紝璇锋眰wms浠诲姟瀹屾垚鎺ュ彛澶辫触"); + } + JSONObject jsonObject = JSON.parseObject(response); + + + apiLogService.save("Wms鍙樻洿璐т綅鐘舵��" + , wmsUrl + "wcsManager/wcsInterface/inboundTaskApply" + , null + , "127.0.0.1" + , JSON.toJSONString(param) + , response + , true + ); + + return null; + } } -- Gitblit v1.9.1