old mode 100644
new mode 100755
| | |
|---|
| | | import com.genersoft.iot.vmp.service.IDeviceService; |
|---|
| | | import com.genersoft.iot.vmp.utils.DateUtil; |
|---|
| | | import gov.nist.javax.sip.message.SIPRequest; |
|---|
| | | import org.apache.commons.lang3.ObjectUtils; |
|---|
| | | import org.dom4j.Element; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | logger.error("[命令发送失败] 心跳回复: {}", e.getMessage()); |
|---|
| | | } |
|---|
| | | if (device.getKeepaliveTime() != null && DateUtil.getDifferenceForNow(device.getKeepaliveTime()) <= 3000L){ |
|---|
| | | if (!ObjectUtils.isEmpty(device.getKeepaliveTime()) && DateUtil.getDifferenceForNow(device.getKeepaliveTime()) <= 3000L) { |
|---|
| | | logger.info("[收到心跳] 心跳发送过于频繁，已忽略 device: {}, callId: {}", device.getDeviceId(), request.getCallIdHeader().getCallId()); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void handForPlatform(RequestEvent evt, ParentPlatform parentPlatform, Element element) { |
|---|
| | | // 不会收到上级平台的心跳信息 |
|---|
| | | |
|---|
| | | // 个别平台保活不回复200OK会判定离线 |
|---|
| | | try { |
|---|
| | | responseAck((SIPRequest) evt.getRequest(), Response.OK); |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | logger.error("[命令发送失败] 心跳回复: {}", e.getMessage()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
