|
|
|
@ -47,6 +47,7 @@ import java.util.concurrent.locks.Lock;
|
|
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import static com.zhehekeji.web.pojo.stock.StockStatus.COUNT_ERROR;
|
|
|
|
import static com.zhehekeji.web.service.client.GetPhotoDelayExecutor.cameraDelayTaskMap;
|
|
|
|
import static com.zhehekeji.web.service.client.GetPhotoDelayExecutor.cameraDelayTaskMap;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -280,7 +281,7 @@ public class PlcService {
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
delayTime = configProperties.getCameraConfig().getC2OutDelayCaptureTime();
|
|
|
|
delayTime = configProperties.getCameraConfig().getC2OutDelayCaptureTime();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sendHttp( street,plcCmdInfo.getLeftRight1());
|
|
|
|
// sendHttp( street,plcCmdInfo.getLeftRight1());
|
|
|
|
|
|
|
|
|
|
|
|
//拍照拉平
|
|
|
|
//拍照拉平
|
|
|
|
} else if (code.startsWith("C3")) {
|
|
|
|
} else if (code.startsWith("C3")) {
|
|
|
|
@ -294,7 +295,7 @@ public class PlcService {
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
delayTime = configProperties.getCameraConfig().getC4OutDelayCaptureTime();
|
|
|
|
delayTime = configProperties.getCameraConfig().getC4OutDelayCaptureTime();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sendHttp( street,plcCmdInfo.getLeftRight2());
|
|
|
|
// sendHttp( street,plcCmdInfo.getLeftRight2());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// path = PathUtil.createFileNameByRowColumn("jpg", cameraId, row, column);
|
|
|
|
// path = PathUtil.createFileNameByRowColumn("jpg", cameraId, row, column);
|
|
|
|
// path = cameraCapture(cameraId, delay, delayTime, path);
|
|
|
|
// path = cameraCapture(cameraId, delay, delayTime, path);
|
|
|
|
@ -733,15 +734,15 @@ public class PlcService {
|
|
|
|
checkLog.setCategory(dataInfo.getTypeNum());
|
|
|
|
checkLog.setCategory(dataInfo.getTypeNum());
|
|
|
|
|
|
|
|
|
|
|
|
}else {
|
|
|
|
}else {
|
|
|
|
checkLog.setStatus(StockStatus.ERROR.getStatus());
|
|
|
|
checkLog.setStatus(StockStatus.CATEGORY_ERROR.getStatus());
|
|
|
|
stock.setStatus(StockStatus.ERROR.getStatus());
|
|
|
|
stock.setStatus(StockStatus.CATEGORY_ERROR.getStatus());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
checkLog.setPic("http://"+street.getPlcIp()+":9007/pic/"+algorithmPojo.getDeterminePath());
|
|
|
|
checkLog.setPic("http://"+street.getPlcIp()+":9007/pic/"+algorithmPojo.getDeterminePath());
|
|
|
|
stock.setCheckPic("http://"+street.getPlcIp()+":9007/pic/"+algorithmPojo.getDeterminePath());
|
|
|
|
stock.setCheckPic("http://"+street.getPlcIp()+":9007/pic/"+algorithmPojo.getDeterminePath());
|
|
|
|
}else {
|
|
|
|
}else {
|
|
|
|
checkLog.setStatus(StockStatus.ERROR.getStatus());
|
|
|
|
checkLog.setStatus(StockStatus.CATEGORY_ERROR.getStatus());
|
|
|
|
stock.setStatus(StockStatus.ERROR.getStatus());
|
|
|
|
stock.setStatus(StockStatus.CATEGORY_ERROR.getStatus());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
checkLogMapper.insert(checkLog);
|
|
|
|
checkLogMapper.insert(checkLog);
|
|
|
|
@ -847,11 +848,6 @@ public class PlcService {
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static void main(String[] args) {
|
|
|
|
|
|
|
|
Street street = new Street();
|
|
|
|
|
|
|
|
street.setPlcIp("127.0.0.1");
|
|
|
|
|
|
|
|
sendHttp(street,1);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public static AlgorithmPojo sendHttp(Street street,Integer direction ){
|
|
|
|
public static AlgorithmPojo sendHttp(Street street,Integer direction ){
|
|
|
|
// 创建RestTemplate实例
|
|
|
|
// 创建RestTemplate实例
|
|
|
|
@ -922,13 +918,13 @@ public class PlcService {
|
|
|
|
checkLog.setCount(count);
|
|
|
|
checkLog.setCount(count);
|
|
|
|
stock.setCount(count);
|
|
|
|
stock.setCount(count);
|
|
|
|
if(flag && checkLog.getWmsCount()==count&& checkLog.getWmsCategory().equals(checkLog.getCategory())){
|
|
|
|
if(flag && checkLog.getWmsCount()==count&& checkLog.getWmsCategory().equals(checkLog.getCategory())){
|
|
|
|
checkLog.setStatus(2);
|
|
|
|
checkLog.setStatus(StockStatus.SUCCESS.getStatus());
|
|
|
|
stock.setStatus(2);
|
|
|
|
stock.setStatus(StockStatus.SUCCESS.getStatus());
|
|
|
|
}else {
|
|
|
|
}else {
|
|
|
|
checkLog.setStatus(1);
|
|
|
|
checkLog.setStatus(StockStatus.COUNT_ERROR.getStatus());
|
|
|
|
stock.setStatus(1);
|
|
|
|
stock.setStatus(StockStatus.COUNT_ERROR.getStatus());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
stock.setEndTime( LocalDateTime.now());
|
|
|
|
checkLogMapper.updateById(checkLog);
|
|
|
|
checkLogMapper.updateById(checkLog);
|
|
|
|
stockMapper.updateById(stock);
|
|
|
|
stockMapper.updateById(stock);
|
|
|
|
return checkLog.getStatus()>2?1:0;
|
|
|
|
return checkLog.getStatus()>2?1:0;
|
|
|
|
|