为了和另一个 uhf 插件区分，修改为 uhfcom13
This commit is contained in:
@@ -0,0 +1,256 @@
|
||||
package cordova.plugin.uhfcom;
|
||||
|
||||
import android.util.Log;
|
||||
import cn.pda.serialport.Tools;
|
||||
import com.android.hdhe.uhf.reader.UhfReader;
|
||||
import com.android.hdhe.uhf.readerInterface.TagModel;
|
||||
import org.apache.cordova.CallbackContext;
|
||||
import org.apache.cordova.CordovaPlugin;
|
||||
import org.apache.cordova.PluginResult;
|
||||
import org.json.JSONArray;
|
||||
import org.json.JSONException;
|
||||
import org.json.JSONObject;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
|
||||
/**
|
||||
* 超高频（UHF）读写卡插件。
|
||||
* 因不同的机型使用的so库不同，故无法适配所有机型。
|
||||
*/
|
||||
public class UHFCom13 extends CordovaPlugin {
|
||||
private UhfReader manager;
|
||||
private String selectedEpc = "";
|
||||
private byte[] password = Tools.HexString2Bytes("00000000");
|
||||
private boolean threadFlag;
|
||||
|
||||
@Override
|
||||
protected void pluginInitialize() {
|
||||
super.pluginInitialize();
|
||||
manager = UhfReader.getInstance();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean execute(String action, JSONArray args, CallbackContext callbackContext) throws JSONException {
|
||||
switch (action) {
|
||||
case "readCard":
|
||||
this.readCard(callbackContext);
|
||||
return true;
|
||||
case "searchCard":
|
||||
this.searchCard(callbackContext);
|
||||
return true;
|
||||
case "writeCard":
|
||||
this.writeCard(args, callbackContext);
|
||||
return true;
|
||||
case "setPower":
|
||||
this.setPower(args, callbackContext);
|
||||
return true;
|
||||
case "startWork":
|
||||
this.startWork(callbackContext);
|
||||
return true;
|
||||
case "endWork":
|
||||
this.endWork(callbackContext);
|
||||
return true;
|
||||
case "selectCard":
|
||||
this.selectCard(args, callbackContext);
|
||||
return true;
|
||||
case "inventoryCard":
|
||||
this.inventoryCard(callbackContext);
|
||||
return true;
|
||||
case "stopInventoryCard":
|
||||
this.stopInventoryCard(callbackContext);
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
private void startWork(CallbackContext callbackContext) {
|
||||
if (this.manager == null) {
|
||||
manager = UhfReader.getInstance();
|
||||
}
|
||||
callbackContext.success();
|
||||
}
|
||||
|
||||
private void endWork(CallbackContext callbackContext) {
|
||||
if (this.manager != null) {
|
||||
this.manager.close();
|
||||
this.manager = null;
|
||||
}
|
||||
callbackContext.success();
|
||||
}
|
||||
|
||||
|
||||
private void stopInventoryCard(CallbackContext callbackContext) {
|
||||
threadFlag = false;
|
||||
callbackContext.success("停止");
|
||||
}
|
||||
|
||||
private void searchCard(CallbackContext callbackContext) {
|
||||
try {
|
||||
JSONArray ja = onceSearchCard();
|
||||
callbackContext.success(ja);
|
||||
} catch (JSONException e) {
|
||||
callbackContext.error(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private void inventoryCard(CallbackContext callbackContext) {
|
||||
threadFlag = true;
|
||||
Thread thread = new InventoryThread(callbackContext);
|
||||
thread.start();
|
||||
}
|
||||
|
||||
private class InventoryThread extends Thread {
|
||||
|
||||
private CallbackContext cb;
|
||||
|
||||
public InventoryThread(CallbackContext cb) {
|
||||
super();
|
||||
this.cb = cb;
|
||||
}
|
||||
|
||||
public InventoryThread() {
|
||||
super();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
super.run();
|
||||
try {
|
||||
while (threadFlag) {
|
||||
JSONArray ja = onceSearchCard();
|
||||
PluginResult pr = new PluginResult(PluginResult.Status.OK, ja);
|
||||
pr.setKeepCallback(true);
|
||||
cb.sendPluginResult(pr);
|
||||
Thread.sleep(100);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
cb.error(e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 单次巡卡，每执行一次，就扫描一次范围内的卡片，将巡到的卡片信息以json数组的形式返回。
|
||||
*/
|
||||
private JSONArray onceSearchCard() throws JSONException {
|
||||
List<TagModel> tagList;
|
||||
tagList = manager.inventoryRealTime(); //实时盘存
|
||||
JSONArray ja = new JSONArray();
|
||||
JSONObject jo;
|
||||
String epcStr;
|
||||
if (tagList != null && !tagList.isEmpty()) {
|
||||
for (TagModel tag : tagList) {
|
||||
if (tag == null) {
|
||||
break;
|
||||
} else {
|
||||
epcStr = Tools.Bytes2HexString(tag.getmEpcBytes(), tag.getmEpcBytes().length);
|
||||
}
|
||||
jo = new JSONObject();
|
||||
jo.put("mEpcBytes", epcStr);
|
||||
jo.put("mRssi", tag.getmRssi());
|
||||
ja.put(jo);
|
||||
}
|
||||
}
|
||||
return ja;
|
||||
}
|
||||
|
||||
/**
|
||||
* 读卡，将USER区的hex字符串转换为ascii读取，因EPC区与TID区不能写入，故暂时只读取USER区，注释掉的部分为适应EPC区与TID区读取的代码
|
||||
* 将注释解开后应抛出JSONException
|
||||
*/
|
||||
private void readCard(CallbackContext callbackContext) {
|
||||
// JSONObject obj = message.getJSONObject(0);
|
||||
// int site = obj.getInt("site");
|
||||
// int addr = obj.getInt("addr");
|
||||
// if (site == 1) {
|
||||
// addr = 2;
|
||||
// length = 6;
|
||||
// } else if (site == 3) {
|
||||
// addr = 0;
|
||||
// length = 32;
|
||||
// } else if (site == 2) {
|
||||
// addr = 0;
|
||||
// length = 12;
|
||||
// }
|
||||
manager.selectEPC(Tools.HexString2Bytes(this.selectedEpc));
|
||||
int length = 32;
|
||||
byte[] data = manager.readFrom6C(3, 0, length, password);
|
||||
if (data != null && data.length >= 1) {
|
||||
String msg;
|
||||
// if (site == 3) { // 读取User区的时候，将16进制字符串转换为ascii
|
||||
msg = Util.bytes2Str(data);
|
||||
// } else { // 因EPC区与TID区不能写入，故读取时不转码
|
||||
// msg = Tools.Bytes2HexString(data, data.length);
|
||||
// }
|
||||
callbackContext.success(msg);
|
||||
} else {
|
||||
callbackContext.error("读取失败");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 选卡，将选到的卡储存在this.selectedEpc中
|
||||
*/
|
||||
private void selectCard(JSONArray message, CallbackContext callbackContext) throws JSONException {
|
||||
JSONObject obj = message.getJSONObject(0);
|
||||
String epc = obj.getString("epc");
|
||||
manager.selectEPC(Tools.HexString2Bytes(epc));
|
||||
this.selectedEpc = epc;
|
||||
callbackContext.success();
|
||||
}
|
||||
|
||||
/**
|
||||
* 写卡，将ascii转换为bytes并写入
|
||||
*/
|
||||
private void writeCard(JSONArray message, CallbackContext callbackContext) {
|
||||
manager.selectEPC(Tools.HexString2Bytes(this.selectedEpc));
|
||||
String _data = null;
|
||||
try {
|
||||
JSONObject obj = message.getJSONObject(0);
|
||||
_data = Util.str2HexStr(obj.getString("data"));
|
||||
} catch (JSONException e) {
|
||||
callbackContext.error("JSON解析失败");
|
||||
}
|
||||
// 处理_data，将ascii转换为16进制字符串，超过32 * 4位的16进制字符串报错，小于32 * 4时在16进制字符串末位补0x00作为完结标记，再转换为bytes
|
||||
if (_data != null && _data.length() > 32 * 4) {
|
||||
callbackContext.error("数据过长");
|
||||
return;
|
||||
}
|
||||
if (_data.length() < 32 * 4) {
|
||||
_data += "00";
|
||||
}
|
||||
byte[] dataBytes = Util.hexStringToBytes(_data);
|
||||
boolean writeFlag = false;
|
||||
if (dataBytes != null) {
|
||||
writeFlag = manager.writeTo6C(password, 3, 0, dataBytes.length / 2, dataBytes);
|
||||
}
|
||||
if (writeFlag) {
|
||||
callbackContext.success("写入成功");
|
||||
} else {
|
||||
callbackContext.error("写入失败");
|
||||
}
|
||||
}
|
||||
|
||||
private void setPower(JSONArray message, CallbackContext callbackContext) throws JSONException {
|
||||
int power = message.getInt(0);
|
||||
if (power > 26) {
|
||||
power = 26;
|
||||
} else if (power < 16) {
|
||||
power = 16;
|
||||
}
|
||||
if (manager.setOutputPower(power)) {
|
||||
callbackContext.success("设置成功");
|
||||
} else {
|
||||
callbackContext.error("设置失败");
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onDestroy() {
|
||||
if (this.manager != null) {
|
||||
this.manager.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user