From: snickersun Date: Tue, 4 Feb 2020 10:58:42 +0000 (+0800) Subject: 接收从UI传来的 心率和血压数据，并发送给服务器。 X-Git-Url: http://git.snicker.com.cn/?a=commitdiff_plain;h=3030c3dfddb90de7956e142d3b9bd57500a2e24e;p=protocol_srv.git 接收从UI传来的 心率和血压数据，并发送给服务器。 --- diff --git a/app/src/main/java/com/enqualcomm/support/Constants.java b/app/src/main/java/com/enqualcomm/support/Constants.java index d9711964..06bdf74f 100644 --- a/app/src/main/java/com/enqualcomm/support/Constants.java +++ b/app/src/main/java/com/enqualcomm/support/Constants.java @@ -192,7 +192,13 @@ public interface Constants { public static final int MSG_WHAT_SILENCE_STATUS = 1005; public static final int MSG_WHAT_VIDEO_CHAT = 1004; - + + public static final int MSG_WHAT_PPG = 1007; + public static final String key_ppg="ppg"; + public static final String key_bph="bph"; + public static final String key_bpl="bpl"; + + public static final int NEW_MEDIA_PUSH = 100; public static final String OTHER_ALARM_END = "com.enqualcomm.support.OTHER_ALARM_END"; diff --git a/app/src/main/java/com/enqualcomm/support/ICContentProvider.java b/app/src/main/java/com/enqualcomm/support/ICContentProvider.java index 7b3fb168..0d5aedbc 100644 --- a/app/src/main/java/com/enqualcomm/support/ICContentProvider.java +++ b/app/src/main/java/com/enqualcomm/support/ICContentProvider.java @@ -176,12 +176,12 @@ public class ICContentProvider extends ContentProvider { URI_MATCHER.addURI("com.enqualcomm.support", "unreadMsg", UNREADMSG); } - private int bulkInsertLocale(String paramString, ContentValues[] paramArrayOfContentValues) { + private int bulkInsertLocale(String table, ContentValues[] paramArrayOfContentValues) { this.db.beginTransaction(); try { int i = paramArrayOfContentValues.length; for (byte b = 0; b < i; b++) { - long l = this.db.insert(paramString, null, paramArrayOfContentValues[b]); + long l = this.db.insert(table, null, paramArrayOfContentValues[b]); if (l < 0L) return 0; } @@ -254,7 +254,7 @@ public class ICContentProvider extends ContentProvider { return i; } - public int delete(Uri paramUri, String paramString, String[] paramArrayOfString) { + public int delete(Uri paramUri, String whereClause, String[] whereArgs) { long l; int i=0,j; StringBuilder stringBuilder; @@ -262,7 +262,7 @@ public class ICContentProvider extends ContentProvider { switch (URI_MATCHER.match(paramUri)) { case UNREADMSG: - j = this.db.delete(UNREADMSG_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(UNREADMSG_TABLE_NAME, whereClause, whereArgs); if (j != 0) { getContext().getContentResolver().notifyChange(UNREAD_MSG_URI, null); @@ -283,7 +283,7 @@ public class ICContentProvider extends ContentProvider { break; case ANTIOFF: - j = this.db.delete(ANTIOFF_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(ANTIOFF_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(ANTIOFF_URI, null); @@ -291,7 +291,7 @@ public class ICContentProvider extends ContentProvider { } break; case STHEART_RATE: - j = this.db.delete(STHEART_RATE_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(STHEART_RATE_TABLE_NAME, whereClause, whereArgs); if (j != 0) { getContext().getContentResolver().notifyChange(STHEART_RATE_URL, null); @@ -313,7 +313,7 @@ public class ICContentProvider extends ContentProvider { } break; case DOWNLOADINFO: - j = this.db.delete(DOWNLOADINFO_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(DOWNLOADINFO_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(DOWNLOADINFO_URL, null); @@ -321,7 +321,7 @@ public class ICContentProvider extends ContentProvider { } break; case DEVICESTATUS: - j = this.db.delete(DEVICESTATUS_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(DEVICESTATUS_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(DEVICESTATUS_URL, null); @@ -329,7 +329,7 @@ public class ICContentProvider extends ContentProvider { } break; case WEATHER: - j = this.db.delete(WEATHER_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(WEATHER_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(WEATHER_URL, null); @@ -349,7 +349,7 @@ public class ICContentProvider extends ContentProvider { } break; case NOTICE: - j = this.db.delete(NOTICE_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(NOTICE_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(NOTICE_URL, null); @@ -370,7 +370,7 @@ public class ICContentProvider extends ContentProvider { } break; case URLDOWNLOADPIC: - j = this.db.delete(URLDOWNLOADPIC_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(URLDOWNLOADPIC_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(URLDOWNLOADPIC_URL, null); @@ -378,7 +378,7 @@ public class ICContentProvider extends ContentProvider { } break; case IKNOWLEDGE: - j = this.db.delete(IKNOWLEDGE_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(IKNOWLEDGE_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(IKNOWLEDGE_URL, null); @@ -399,7 +399,7 @@ public class ICContentProvider extends ContentProvider { } break; case SILENT: - j = this.db.delete(SILENT_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(SILENT_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(SILENT_URI, null); @@ -420,7 +420,7 @@ public class ICContentProvider extends ContentProvider { } break; case ALARM: - j = this.db.delete(ALARM_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(ALARM_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(ALARM_URI, null); @@ -441,7 +441,7 @@ public class ICContentProvider extends ContentProvider { } break; case MESSAGE: - j = this.db.delete(MESSAGE_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(MESSAGE_TABLE_NAME, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(MESSAGE_URI, null); @@ -463,7 +463,7 @@ public class ICContentProvider extends ContentProvider { break; case CONTACT: - j = this.db.delete(CONTACT_TABLE_NAME, paramString, paramArrayOfString); + j = this.db.delete(CONTACT_TABLE_NAME, whereClause, whereArgs); if (j != 0) { getContext().getContentResolver().notifyChange(CONTACT_URI, null); @@ -600,7 +600,7 @@ public class ICContentProvider extends ContentProvider { @Nullable @Override - public Cursor query(Uri paramUri, String[] paramArrayOfString1, String paramString1, String[] paramArrayOfString2, String paramString2) { + public Cursor query(Uri paramUri, String[] columns, String paramString1, String[] paramArrayOfString2, String paramString2) { long l; StringBuilder stringBuilder; @@ -610,91 +610,91 @@ public class ICContentProvider extends ContentProvider { default: return null; case UNREADMSG: - return this.db.query(UNREADMSG_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(UNREADMSG_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case ANTIOFF_ITEM: l = ContentUris.parseId(paramUri); stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(ANTIOFF_TABLE_NAME, paramArrayOfString1, paramString1.toString(), null, null, null, null); + return sQLiteDatabase.query(ANTIOFF_TABLE_NAME, columns, paramString1.toString(), null, null, null, null); case ANTIOFF: - return this.db.query(ANTIOFF_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(ANTIOFF_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case STHEART_RATE: - return this.db.query(STHEART_RATE_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(STHEART_RATE_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case DOWNLOADINFO_ITEM: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(DOWNLOADINFO_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(DOWNLOADINFO_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case DOWNLOADINFO: - return this.db.query(DOWNLOADINFO_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(DOWNLOADINFO_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case DEVICESTATUS: - return this.db.query(DEVICESTATUS_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(DEVICESTATUS_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case WEATHER: - return this.db.query(WEATHER_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(WEATHER_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case NOTICE_ITEM: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(NOTICE_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(NOTICE_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case NOTICE: - return this.db.query(NOTICE_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(NOTICE_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case URLDOWNLOADPIC_ITEM: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(URLDOWNLOADPIC_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(URLDOWNLOADPIC_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case URLDOWNLOADPIC: - return this.db.query(URLDOWNLOADPIC_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(URLDOWNLOADPIC_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case IKNOWLEDGE: - return this.db.query(IKNOWLEDGE_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(IKNOWLEDGE_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case SILENT_ITEM: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(SILENT_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(SILENT_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case SILENT: - return this.db.query(SILENT_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(SILENT_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case ALARM_ITEM: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(ALARM_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(ALARM_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case ALARM: - return this.db.query(ALARM_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(ALARM_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case 4: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(MESSAGE_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(MESSAGE_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case MESSAGE: - return this.db.query(MESSAGE_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(MESSAGE_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); case 2: l = ContentUris.parseId(paramUri); sQLiteDatabase = this.db; stringBuilder = new StringBuilder(); stringBuilder.append("_id="); stringBuilder.append(l); - return sQLiteDatabase.query(CONTACT_TABLE_NAME, paramArrayOfString1, stringBuilder.toString(), null, null, null, null); + return sQLiteDatabase.query(CONTACT_TABLE_NAME, columns, stringBuilder.toString(), null, null, null, null); case 1: break; } - return this.db.query(CONTACT_TABLE_NAME, paramArrayOfString1, paramString1, paramArrayOfString2, null, null, paramString2); + return this.db.query(CONTACT_TABLE_NAME, columns, paramString1, paramArrayOfString2, null, null, paramString2); } @Override - public int update(Uri paramUri, ContentValues paramContentValues, String paramString, String[] paramArrayOfString) { + public int update(Uri paramUri, ContentValues paramContentValues, String whereClause, String[] whereArgs) { long l; int i=0,j; StringBuilder stringBuilder; @@ -702,7 +702,7 @@ public class ICContentProvider extends ContentProvider { switch (URI_MATCHER.match(paramUri)) { case UNREADMSG: - j = this.db.update(UNREADMSG_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(UNREADMSG_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(UNREAD_MSG_URI, null); @@ -723,7 +723,7 @@ public class ICContentProvider extends ContentProvider { } return i; case ANTIOFF: - j = this.db.update(ANTIOFF_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(ANTIOFF_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(ANTIOFF_URI, null); @@ -731,7 +731,7 @@ public class ICContentProvider extends ContentProvider { } return i; case STHEART_RATE: - j = this.db.update(STHEART_RATE_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(STHEART_RATE_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(STHEART_RATE_URL, null); @@ -752,7 +752,7 @@ public class ICContentProvider extends ContentProvider { } return i; case DOWNLOADINFO: - j = this.db.update(DOWNLOADINFO_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(DOWNLOADINFO_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(DOWNLOADINFO_URL, null); @@ -760,7 +760,7 @@ public class ICContentProvider extends ContentProvider { } return i; case DEVICESTATUS: - j = this.db.update(DEVICESTATUS_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(DEVICESTATUS_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(DEVICESTATUS_URL, null); @@ -768,7 +768,7 @@ public class ICContentProvider extends ContentProvider { } return i; case WEATHER: - j = this.db.update(WEATHER_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(WEATHER_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(WEATHER_URL, null); @@ -789,7 +789,7 @@ public class ICContentProvider extends ContentProvider { } return i; case NOTICE: - j = this.db.update(NOTICE_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(NOTICE_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(NOTICE_URL, null); @@ -810,7 +810,7 @@ public class ICContentProvider extends ContentProvider { } return i; case URLDOWNLOADPIC: - j = this.db.update(URLDOWNLOADPIC_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(URLDOWNLOADPIC_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(URLDOWNLOADPIC_URL, null); @@ -818,7 +818,7 @@ public class ICContentProvider extends ContentProvider { } return i; case IKNOWLEDGE: - j = this.db.update(IKNOWLEDGE_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(IKNOWLEDGE_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(IKNOWLEDGE_URL, null); @@ -839,7 +839,7 @@ public class ICContentProvider extends ContentProvider { } return i; case SILENT: - j = this.db.update(SILENT_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(SILENT_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(SILENT_URI, null); @@ -860,7 +860,7 @@ public class ICContentProvider extends ContentProvider { } return i; case ALARM: - j = this.db.update(ALARM_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(ALARM_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(ALARM_URI, null); @@ -881,7 +881,7 @@ public class ICContentProvider extends ContentProvider { } return i; case MESSAGE: - j = this.db.update(MESSAGE_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(MESSAGE_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(MESSAGE_URI, null); @@ -903,7 +903,7 @@ public class ICContentProvider extends ContentProvider { return i; case CONTACT: - j = this.db.update(CONTACT_TABLE_NAME, paramContentValues, paramString, paramArrayOfString); + j = this.db.update(CONTACT_TABLE_NAME, paramContentValues, whereClause, whereArgs); i = j; if (j != 0) { getContext().getContentResolver().notifyChange(CONTACT_URI, null); diff --git a/app/src/main/java/com/enqualcomm/support/adapter/protocolAPIHelper.java b/app/src/main/java/com/enqualcomm/support/adapter/protocolAPIHelper.java index e9832088..99501fa7 100644 --- a/app/src/main/java/com/enqualcomm/support/adapter/protocolAPIHelper.java +++ b/app/src/main/java/com/enqualcomm/support/adapter/protocolAPIHelper.java @@ -953,6 +953,22 @@ public class protocolAPIHelper { .append(CMDSPLIT).append(ds.getHRS().getBPL()) .append(CMDEND).toString(); } + public static String APHT(String ppg,String bph,String bpl){ + //IWAPHT,60,130,85# + //说明： + //IW：标识符 + //APHT : 命令字符 + //60 : 表示心率 + //130: 血压高压 [收缩压] + //85 : 血压低压 [舒张压] + //平台响应： IWBPHT# + //表示平台已接收，可不作响应 + return new StringBuffer(CMDHEADER).append(cmdMap.get(CMD_TYPE.APHT)) + .append(CMDSPLIT).append(ppg) + .append(CMDSPLIT).append(bph) + .append(CMDSPLIT).append(bpl) + .append(CMDEND).toString(); + } //立即定位反馈 diff --git a/app/src/main/java/com/enqualcomm/support/service/HeartRateManager.java b/app/src/main/java/com/enqualcomm/support/service/HeartRateManager.java index 53959205..d46fb2cf 100644 --- a/app/src/main/java/com/enqualcomm/support/service/HeartRateManager.java +++ b/app/src/main/java/com/enqualcomm/support/service/HeartRateManager.java @@ -11,6 +11,7 @@ import android.os.Message; import android.os.Messenger; import android.os.PowerManager; +import com.enqualcomm.support.Constants; import com.ic.jni.ICJniUtils; import com.enqualcomm.support.LocationClient; import com.enqualcomm.support.adapter.protocolAPIHelper; @@ -28,6 +29,10 @@ import java.util.Timer; import java.util.TimerTask; import static com.enqualcomm.support.Constants.ACTION_HEATR_RATE_START; +import static com.enqualcomm.support.Constants.MSG_WHAT_PPG; +import static com.enqualcomm.support.Constants.key_bph; +import static com.enqualcomm.support.Constants.key_bpl; +import static com.enqualcomm.support.Constants.key_ppg; public class HeartRateManager extends AbstractInvokeHandlerService { private int mNetworkType; @@ -251,54 +256,34 @@ public static void triggerPPGtest(){ } public boolean onUserRequest(Message message, Connection connection, final Runtime runtime) { - Bundle bundle3; - String str3; - String str2; - String str1; - Bundle bundle2; - final Messenger callback2; + int i = 1; switch (message.what) { + case MSG_WHAT_PPG: + Bundle bundle3 = message.getData(); + String ppg = bundle3.getString(key_ppg); + String bph = bundle3.getString(key_bph); + String bpl = bundle3.getString(key_bpl); + if (ppg == null || bph == null || bpl==null || ppg.isEmpty()||bph.isEmpty()||bpl.isEmpty()) { + Logger.i("MSG_WHAT_PPG Data is null or empty ! Skip!"); + callback(message.replyTo, Constants.RESULT_ERROR); - case 1002: - this.mNetworkType = this.mSignalUtil.getNetworkType(); - bundle3 = message.getData(); - str1 = bundle3.getString("filepath"); - str2 = bundle3.getString("number"); - if (str1 != null) { - if (str2 == null) - return true; - StringBuilder stringBuilder = new StringBuilder(); - stringBuilder.append("filepath == "); - stringBuilder.append(str1); - stringBuilder.append("number == "); - stringBuilder.append(str2); - Logger.i(stringBuilder.toString()); -//do something - } else { - return true; - } - case 1001: - this.mSignalUtil = SimSignalUtil.getInstance((runtime.getContextProxy()).context); - this.mNetworkType = this.mSignalUtil.getNetworkType(); - bundle2 = message.getData(); - str2 = bundle2.getString("filepath"); - str3 = bundle2.getString("number"); - - if (str2 != null && str3 != null) { -// send - } else { return true; } - case 1000: - break; + + String PPGDATA = protocolAPIHelper.APHT(ppg,bph,bpl); + if (((NettyConnection)connection).isServerConnected()) { + connection.send(protocolAPIHelper.genStringMessage("APHT", PPGDATA)); + Logger.i("Send PPG " + PPGDATA); + } else { + Logger.i("Skip PPG " + PPGDATA); + } + callback(message.replyTo, Constants.RESULT_OK); default: - return false; + break; } -// Bundle bundle1 = paramMessage.getData(); -// i = bundle1.getInt("category"); return true; }