|
@@ -10,7 +10,7 @@ import com.payne.reader.bean.receive.Failure;
|
|
|
import com.payne.reader.bean.receive.Success;
|
|
import com.payne.reader.bean.receive.Success;
|
|
|
import com.payne.reader.bean.send.*;
|
|
import com.payne.reader.bean.send.*;
|
|
|
import com.payne.reader.process.ReaderImpl;
|
|
import com.payne.reader.process.ReaderImpl;
|
|
|
-import com.zd.alg.netty.base.FridConsumer;
|
|
|
|
|
|
|
+import com.zd.alg.netty.base.RfidConsumer;
|
|
|
import com.zd.alg.netty.service.ISendService;
|
|
import com.zd.alg.netty.service.ISendService;
|
|
|
import com.zd.alg.netty.service.IService;
|
|
import com.zd.alg.netty.service.IService;
|
|
|
import com.zd.common.core.exception.ServiceException;
|
|
import com.zd.common.core.exception.ServiceException;
|
|
@@ -34,7 +34,7 @@ public class WuYuanRFIDServiceImpl implements IService {
|
|
|
private static final String MSG = "请先连接设备";
|
|
private static final String MSG = "请先连接设备";
|
|
|
private static final String SCANNER_MSG = "服务已断开,请检查连接状态正常后重启程序:";
|
|
private static final String SCANNER_MSG = "服务已断开,请检查连接状态正常后重启程序:";
|
|
|
@Resource
|
|
@Resource
|
|
|
- private FridConsumer fridConsumer;
|
|
|
|
|
|
|
+ private RfidConsumer rfidConsumer;
|
|
|
@Resource
|
|
@Resource
|
|
|
private ISendService sendService;
|
|
private ISendService sendService;
|
|
|
@Resource
|
|
@Resource
|
|
@@ -91,7 +91,7 @@ public class WuYuanRFIDServiceImpl implements IService {
|
|
|
Byte index = sessionIndex;
|
|
Byte index = sessionIndex;
|
|
|
InventoryConfig config = new InventoryConfig.Builder()
|
|
InventoryConfig config = new InventoryConfig.Builder()
|
|
|
.setInventory(inventory)
|
|
.setInventory(inventory)
|
|
|
- .setOnInventoryTagSuccess(fridConsumer)
|
|
|
|
|
|
|
+ .setOnInventoryTagSuccess(rfidConsumer)
|
|
|
//读取失败
|
|
//读取失败
|
|
|
.setOnFailure(failure -> errorMsg(failure, index, SCANNER_MSG, hardware))
|
|
.setOnFailure(failure -> errorMsg(failure, index, SCANNER_MSG, hardware))
|
|
|
.build();
|
|
.build();
|