|
@@ -619,7 +619,7 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
|
*/
|
|
|
@Override
|
|
|
public boolean szbStockHandle(boolean isFetched, TaskNode taskNode){
|
|
|
- List<Storge> storgeList = baseMapper.selectList(new LbqWrapper<Storge>().in(Storge::getPointId, Arrays.asList(DictionaryKey.ZEISS_LOCATION.get("M"))));
|
|
|
+ List<Storge> storgeList = baseMapper.selectList(new LbqWrapper<Storge>().eq(Storge::getLockStatus, "1").in(Storge::getPointId, Arrays.asList(DictionaryKey.ZEISS_LOCATION.get("M"))));
|
|
|
|
|
|
if(storgeList.isEmpty()){
|
|
|
throw new BizException("没有查询到可用的三坐标数据,点位"+DictionaryKey.ZEISS_LOCATION.get("M") );
|
|
@@ -633,8 +633,8 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
|
if(isFetched) {
|
|
|
//todo wang.sq三坐标调用地址释放, $需要换地址$
|
|
|
// 查询三坐标是否允许取
|
|
|
- //String fetchStatus = msgUtil.getCcsData("/api/GetMiddleThreeCoordinates", params, taskNode);
|
|
|
- String fetchStatus = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
+ String fetchStatus = msgUtil.getCcsData("/api/GetMiddleThreeCoordinates", params, taskNode);
|
|
|
+ //String fetchStatus = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
|
|
|
JSONObject fetchObject = JSONObject.parseObject(fetchStatus);
|
|
|
logger.warn("三坐标节点{}取查询接口返回{}", taskNode.getId(), fetchObject.toJSONString());
|
|
@@ -656,8 +656,8 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
|
//三坐标中间放操作
|
|
|
// 查询三坐标是否允许放
|
|
|
//todo wang.sq三坐标调用地址释放$需要换地址$
|
|
|
- //String sendStatus = msgUtil.getCcsData("/api/QueryThreeCoordinatesFreePos", params, taskNode);
|
|
|
- String sendStatus = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
+ String sendStatus = msgUtil.getCcsData("/api/QueryThreeCoordinatesFreePos", params, taskNode);
|
|
|
+ //String sendStatus = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
|
|
|
JSONObject sendObject = JSONObject.parseObject(sendStatus);
|
|
|
logger.warn("三坐标节点{}放查询接口返回{}", taskNode.getId(), sendObject.toJSONString());
|