|
@@ -246,16 +246,16 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
*/
|
|
|
protected void sendApthReplyToClient(String deviceId, Channel channel) {
|
|
|
try {
|
|
|
- if (beatMap.isEmpty()
|
|
|
- || !beatMap.containsKey(deviceId)
|
|
|
- || beatMap.get(deviceId) == 1) {
|
|
|
- // 时间校验 1: 是否需要下发心率获取
|
|
|
- Boolean lag = deviceCronClient.getSendApThByDeviceId(deviceId);
|
|
|
- if (lag) {
|
|
|
+ // 时间校验 1: 是否需要下发心率获取
|
|
|
+ Boolean lag = deviceCronClient.getSendApThByDeviceId(deviceId);
|
|
|
+ if (lag) {
|
|
|
+ if (beatMap.isEmpty()
|
|
|
+ || !beatMap.containsKey(deviceId)
|
|
|
+ || 1 == beatMap.get(deviceId)) {
|
|
|
setBPXLToClient(deviceId, channel);
|
|
|
- } else {
|
|
|
- beatMap.remove(deviceId);
|
|
|
}
|
|
|
+ } else {
|
|
|
+ beatMap.remove(deviceId);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
logger.error("心率下行发送异常!!!!! deviceId=" + deviceId);
|