|
|
|
@ -19,6 +19,8 @@ import java.util.concurrent.ArrayBlockingQueue;
|
|
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
|
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import static com.zhehekeji.web.pojo.Cmd.SC02;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 昆船通讯协议(TCP 传输JSON)
|
|
|
|
* 昆船通讯协议(TCP 传输JSON)
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@ -214,7 +216,11 @@ public class KsecDecoder extends DelimiterBasedFrameDecoder {
|
|
|
|
log.info("盘点结束:"+ksecInfo.getData().toString());
|
|
|
|
log.info("盘点结束:"+ksecInfo.getData().toString());
|
|
|
|
|
|
|
|
|
|
|
|
}else if (Cmd.SC.name().equals(ksecInfo.getType())) {
|
|
|
|
}else if (Cmd.SC.name().equals(ksecInfo.getType())) {
|
|
|
|
plcService.checkVision(dataInfo,true);
|
|
|
|
boolean flag = plcService.checkVision(dataInfo,true);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
ksecInfo.getData().setCmdName("SC02");
|
|
|
|
|
|
|
|
ksecInfo.getData().setCheckRlt(flag?1:0);
|
|
|
|
|
|
|
|
ctx.channel().writeAndFlush(ksecInfo);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//找到该货位的最后一张照片与现在的照片比照
|
|
|
|
//找到该货位的最后一张照片与现在的照片比照
|
|
|
|
//plcService.recordStock(plcCmdInfo, dataInfo.getCode(), 0, 0);
|
|
|
|
//plcService.recordStock(plcCmdInfo, dataInfo.getCode(), 0, 0);
|
|
|
|
|