增加随行拍照

赣州-富士康-rfid
LAPTOP-S9HJSOEB\昊天 2 years ago
parent 4e8f980706
commit 916e07a081

@ -120,6 +120,11 @@ public class PlcService {
*/ */
public void orderStop(PlcCmdInfo plcCmdInfo) { public void orderStop(PlcCmdInfo plcCmdInfo) {
} }
public void orderStopByWarn(String orderNum) { public void orderStopByWarn(String orderNum) {
@ -238,6 +243,10 @@ public class PlcService {
delayTime = configProperties.getCameraConfig().getC3DelayCaptureTime(); delayTime = configProperties.getCameraConfig().getC3DelayCaptureTime();
} else if (code.startsWith("C4")) { } else if (code.startsWith("C4")) {
TransmissionPojo transmissionPojo = new TransmissionPojo( street, plcCmdInfo.getRow2(), plcCmdInfo.getColumn2());
ClientChanel.get(street.getPlcId()).writeAndFlush(transmissionPojo.toString(TransmissionType.GPS));
if (sep == 1) { if (sep == 1) {
delayTime = configProperties.getCameraConfig().getC4DelayCaptureTime(); delayTime = configProperties.getCameraConfig().getC4DelayCaptureTime();
} else { } else {

@ -99,7 +99,6 @@ public class Decoder extends DelimiterBasedFrameDecoder {
//获取照片后发送进行计算逻辑,并在拍照队列中取出拍照发送 //获取照片后发送进行计算逻辑,并在拍照队列中取出拍照发送
else if(GET_PHOTO_END.equals(transmissionPojo.getHeader())){ else if(GET_PHOTO_END.equals(transmissionPojo.getHeader())){
ClientChanel.get(transmissionPojo.getStreetNumber()).writeAndFlush(transmissionPojo.toString(TransmissionType.RTS)); ClientChanel.get(transmissionPojo.getStreetNumber()).writeAndFlush(transmissionPojo.toString(TransmissionType.RTS));
try { try {
Thread.sleep(50L); Thread.sleep(50L);
} catch (InterruptedException e) { } catch (InterruptedException e) {
@ -107,7 +106,6 @@ public class Decoder extends DelimiterBasedFrameDecoder {
} }
//删除队列的拍照数据 //删除队列的拍照数据
GetPhotoDelayExecutor.remove(transmissionPojo.getStreetNumber(),transmissionPojo.toString(TransmissionType.GPS)); GetPhotoDelayExecutor.remove(transmissionPojo.getStreetNumber(),transmissionPojo.toString(TransmissionType.GPS));
//发送给上位机 //发送给上位机
CameraDelayTask cameraDelayTask = GetPhotoDelayExecutor.getNext(transmissionPojo.getStreetNumber()); CameraDelayTask cameraDelayTask = GetPhotoDelayExecutor.getNext(transmissionPojo.getStreetNumber());
if (cameraDelayTask != null) { if (cameraDelayTask != null) {

@ -8,6 +8,7 @@ import lombok.Data;
import javax.validation.constraints.NotEmpty; import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.util.UUID;
@Data @Data
public class TransmissionPojo { public class TransmissionPojo {
@ -17,6 +18,7 @@ public class TransmissionPojo {
private String streetNumber;//巷道标识符 private String streetNumber;//巷道标识符
private Integer row;//行 private Integer row;//行
private Integer column;//列
private String pcd;//点位文件路径 private String pcd;//点位文件路径
private String taskId; private String taskId;
@ -33,19 +35,31 @@ public class TransmissionPojo {
this.streetNumber = street.getPlcId(); this.streetNumber = street.getPlcId();
this.taskId = checkLog.getLotnum(); this.taskId = checkLog.getLotnum();
this.row = checkLog.getRow(); this.row = checkLog.getRow();
this.column = checkLog.getColumn();
this.direction = checkLog.getDirection(); this.direction = checkLog.getDirection();
this.count = checkLog.getCount(); this.count = checkLog.getCount();
this.category = checkLog.getCategory().split("/")[0]; this.category = checkLog.getCategory().split("/")[0];
}
public TransmissionPojo( Street street,Integer row , Integer column){
this.streetNumber = street.getPlcId();
this.row = row;
this.column = column;
this.checkId = 0;
this.taskId = "0";
} }
public String toString(TransmissionType type) { public String toString(TransmissionType type) {
this.header = type.toString(); this.header = type.toString();
if (type == TransmissionType.ST) { if (type == TransmissionType.ST) {
return "ST&" + streetNumber + "&" + checkId + "&" + taskId + "&" + direction ; return "ST&" + streetNumber + "&" + checkId + "&" + taskId + "&" + direction ;
}else if (type == TransmissionType.GPS) { }else if (type == TransmissionType.GPS) {
return "GPS&" + streetNumber +"/"+row+ "&" + checkId + "&" + taskId + "&" + direction+ "&" + category + "&" + count; return "GPS&" + streetNumber +"/"+row +"/"+column+ "&" + checkId + "&" + taskId + "&" + direction+ "&" + category + "&" + count;
}else if (type == TransmissionType.RTS) { }else if (type == TransmissionType.RTS) {
return "RTS&" + streetNumber +"/"+row+ "&" + checkId + "&" + taskId + "&" + direction + "&" + category + "&" + count; return "RTS&" + streetNumber +"/"+row +"/"+column+ "&" + checkId + "&" + taskId + "&" + direction + "&" + category + "&" + count;
}else if (type == TransmissionType.SGPS) {
return "SRTS&" + streetNumber +"/"+row +"/"+column+ "&" + checkId + "&" + taskId + "&" + direction ;
} }
return ""; return "";
} }
@ -59,6 +73,7 @@ public class TransmissionPojo {
String[] dataArr = dataArray[1].split("/"); String[] dataArr = dataArray[1].split("/");
this.streetNumber = dataArr[0]; this.streetNumber = dataArr[0];
this.row = Integer.valueOf(dataArr[1]); this.row = Integer.valueOf(dataArr[1]);
this.column = Integer.valueOf(dataArr[2]);
}else { }else {
this.streetNumber = dataArray[1]; this.streetNumber = dataArray[1];
} }

@ -4,6 +4,8 @@ public enum TransmissionType {
ST , ST ,
GPS , GPS ,
GPE , GPE ,
SGPS ,
SGPE ,
RTS , RTS ,
RTE , RTE ,
EN , EN ,

Loading…
Cancel
Save