|
@@ -43,6 +43,7 @@ import com.github.zuihou.common.util.StringUtil;
|
|
import com.github.zuihou.database.mybatis.auth.DataScope;
|
|
import com.github.zuihou.database.mybatis.auth.DataScope;
|
|
import com.github.zuihou.database.mybatis.conditions.Wraps;
|
|
import com.github.zuihou.database.mybatis.conditions.Wraps;
|
|
import com.github.zuihou.database.mybatis.conditions.query.LbqWrapper;
|
|
import com.github.zuihou.database.mybatis.conditions.query.LbqWrapper;
|
|
|
|
+import com.github.zuihou.exception.BizException;
|
|
import com.github.zuihou.injection.annonation.InjectionResult;
|
|
import com.github.zuihou.injection.annonation.InjectionResult;
|
|
import com.github.zuihou.utils.BeanPlusUtil;
|
|
import com.github.zuihou.utils.BeanPlusUtil;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
@@ -619,6 +620,11 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
@Override
|
|
@Override
|
|
public boolean szbStockHandle(boolean isFetched, TaskNode taskNode){
|
|
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>().in(Storge::getPointId, Arrays.asList(DictionaryKey.ZEISS_LOCATION.get("M"))));
|
|
|
|
+
|
|
|
|
+ if(storgeList.isEmpty()){
|
|
|
|
+ throw new BizException("没有查询到可用的三坐标数据,点位"+DictionaryKey.ZEISS_LOCATION.get("M") );
|
|
|
|
+ }
|
|
|
|
+
|
|
List<StockInfo> mPointList = stockInfoMapper.selectList(new LbqWrapper<StockInfo>().eq(StockInfo::getStorgeId, storgeList.get(0).getId()));
|
|
List<StockInfo> mPointList = stockInfoMapper.selectList(new LbqWrapper<StockInfo>().eq(StockInfo::getStorgeId, storgeList.get(0).getId()));
|
|
// List<StockInfo> lPointList = stockInfoMapper.selectList(new LbqWrapper<StockInfo>().eq(StockInfo::getStorgeId, storgeList.get(1).getId()));
|
|
// List<StockInfo> lPointList = stockInfoMapper.selectList(new LbqWrapper<StockInfo>().eq(StockInfo::getStorgeId, storgeList.get(1).getId()));
|
|
|
|
|
|
@@ -627,7 +633,7 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
if(isFetched) {
|
|
if(isFetched) {
|
|
//todo wang.sq三坐标调用地址释放
|
|
//todo wang.sq三坐标调用地址释放
|
|
// 查询三坐标是否允许取
|
|
// 查询三坐标是否允许取
|
|
-// String fetchStatus = msgUtil.getCcsData("/api/GetMiddleThreeCoordinates", params, taskNode);
|
|
|
|
|
|
+ //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 = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
|
|
|
JSONObject fetchObject = JSONObject.parseObject(fetchStatus);
|
|
JSONObject fetchObject = JSONObject.parseObject(fetchStatus);
|
|
@@ -650,7 +656,7 @@ public class StorgeServiceImpl extends SuperCacheServiceImpl<StorgeMapper, Storg
|
|
//三坐标中间放操作
|
|
//三坐标中间放操作
|
|
// 查询三坐标是否允许放
|
|
// 查询三坐标是否允许放
|
|
//todo wang.sq三坐标调用地址释放
|
|
//todo wang.sq三坐标调用地址释放
|
|
-// String sendStatus = msgUtil.getCcsData("/api/QueryThreeCoordinatesFreePos", params, taskNode);
|
|
|
|
|
|
+ //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 = "{\"taskID\":null,\"taskNodeID\":null,\"result\":\"true\",\"resultMsg\":\"设备已离线:192.168.0.10\",\"concurrency\":\"false\",\"data\":null}";
|
|
|
|
|
|
JSONObject sendObject = JSONObject.parseObject(sendStatus);
|
|
JSONObject sendObject = JSONObject.parseObject(sendStatus);
|