* ===============LICENSE_END=======================================================================
*/
-package org.commscope.tr069adapter.vesagent.service;\r
-\r
-import com.google.gson.Gson;\r
-\r
-import java.util.ArrayList;\r
-import java.util.HashMap;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.concurrent.TimeUnit;\r
-import java.util.function.Function;\r
-\r
-import org.commscope.tr069adapter.acs.common.DeviceDetails;\r
-import org.commscope.tr069adapter.acs.common.DeviceRPCRequest;\r
-import org.commscope.tr069adapter.acs.common.ParameterDTO;\r
-import org.commscope.tr069adapter.mapper.model.VESNotification;\r
-import org.commscope.tr069adapter.vesagent.async.WaitForNotifications;\r
-import org.commscope.tr069adapter.vesagent.entity.DeviceDataEntity;\r
-import org.commscope.tr069adapter.vesagent.exception.VesAgentException;\r
-import org.commscope.tr069adapter.vesagent.repository.VesDataRepository;\r
-import org.commscope.tr069adapter.vesagent.timer.HeartBeatTimeoutTask;\r
-import org.commscope.tr069adapter.vesagent.timer.ScheduleInfo;\r
-import org.commscope.tr069adapter.vesagent.timer.ScheduleTaskService;\r
-import org.commscope.tr069adapter.vesagent.util.VesAgentConstants;\r
-import org.commscope.tr069adapter.vesagent.util.VesAgentUtils;\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.stereotype.Component;\r
-\r
-@Component\r
-public class VesAgentServiceHelper {\r
- private final Logger logger = LoggerFactory.getLogger(this.getClass());\r
-\r
- @Autowired\r
- private Function<String, HeartBeatTimeoutTask> beanFactory;\r
-\r
- public HeartBeatTimeoutTask getBeanInstance(String name) {\r
- return beanFactory.apply(name);\r
- }\r
-\r
- @Autowired\r
- VesDataRepository vesDataRepository;\r
-\r
- @Autowired\r
- WaitForNotifications waitForNotifications;\r
-\r
- @Autowired\r
- ScheduleTaskService timerService;\r
-\r
- private boolean saveDeviceDataEntity(DeviceDetails deviceDetails, String eNodeBName,\r
- String heartBeatPeriod) throws VesAgentException {\r
-\r
- List<DeviceDataEntity> deviceDataEntityList = vesDataRepository\r
- .findByDeviceIdAndAttrGroup(deviceDetails.getDeviceId(), VesAgentConstants.HEART_BEAT);\r
-\r
- DeviceDataEntity deviceDataEntity = null;\r
- Map<String, String> attrJsonMap = null;\r
-\r
- if (null == deviceDataEntityList || deviceDataEntityList.isEmpty()) {\r
- deviceDataEntity = new DeviceDataEntity();\r
-\r
- deviceDataEntity.setDeviceId(deviceDetails.getDeviceId());\r
- deviceDataEntity.seteNodeBName(eNodeBName);\r
- deviceDataEntity.setOui(deviceDetails.getOui());\r
- deviceDataEntity.setProductClass(deviceDetails.getProductClass());\r
- deviceDataEntity.setAttrGroup(VesAgentConstants.HEART_BEAT);\r
-\r
- attrJsonMap = new HashMap<>();\r
- } else {\r
- deviceDataEntity = deviceDataEntityList.get(0);\r
- attrJsonMap = deviceDataEntity.getAttributesMap();\r
- }\r
-\r
- String existingHeartBeatPeriod = attrJsonMap.get(VesAgentConstants.HEART_BEAT_PERIOD);\r
-\r
- if (null == heartBeatPeriod\r
- && (Boolean.TRUE.equals(VesAgentUtils.isNullOrEmpty(existingHeartBeatPeriod))\r
- || existingHeartBeatPeriod\r
- .equalsIgnoreCase(VesAgentConstants.REMOVE_HEART_BEAT_TIMER_VAL))) {\r
- return false;\r
- }\r
-\r
- if (!VesAgentUtils.isNullOrEmpty(heartBeatPeriod)) {\r
- attrJsonMap.put(VesAgentConstants.HEART_BEAT_PERIOD, heartBeatPeriod);\r
- }\r
-\r
- deviceDataEntity.setAttributesMap(attrJsonMap);\r
-\r
- vesDataRepository.save(deviceDataEntity);\r
-\r
- return true;\r
- }\r
-\r
- public void processHeartBeatSetRequest(DeviceRPCRequest deviceRPCRequest, String heartBeatPeriod,\r
- String countDownTimer) throws VesAgentException {\r
-\r
- String deviceId = deviceRPCRequest.getDeviceDetails().getDeviceId();\r
-\r
- VesAgentUtils.validateDeviceId(deviceId);\r
-\r
- if (VesAgentUtils.isNullOrEmpty(heartBeatPeriod)\r
- && VesAgentUtils.isNullOrEmpty(countDownTimer)) {\r
- String errorMsg =\r
- "Invalid input: HeartBeatPeriod and countDownTimer both are null for device " + deviceId;\r
- logger.error(errorMsg);\r
- throw new VesAgentException(VesAgentConstants.INVALID_PARAMETER_VALUE, errorMsg);\r
- }\r
-\r
- Object eNodeBNameObj = deviceRPCRequest.getContext().get(VesAgentConstants.ENODEB_NAME);\r
-\r
- String eNodeBName = null;\r
- if (null != eNodeBNameObj) {\r
- eNodeBName = (String) eNodeBNameObj;\r
- }\r
-\r
- boolean resetTimerJob =\r
- saveDeviceDataEntity(deviceRPCRequest.getDeviceDetails(), eNodeBName, heartBeatPeriod);\r
-\r
- if (resetTimerJob) {\r
- resetTimerJob(deviceId, heartBeatPeriod, countDownTimer);\r
- abortRunningDeviceConnectivityCheck(deviceRPCRequest);\r
- }\r
-\r
- }\r
-\r
- public void processHeartBeatGetRequest(DeviceRPCRequest deviceRPCRequest) {\r
-\r
- String deviceId = deviceRPCRequest.getDeviceDetails().getDeviceId();\r
- List<DeviceDataEntity> deviceDataEntityList =\r
- vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, VesAgentConstants.HEART_BEAT);\r
-\r
- if (VesAgentUtils.isNullOrEmpty(deviceDataEntityList)\r
- || VesAgentUtils.isNullOrEmpty(deviceDataEntityList.get(0).getAttributesMap())) {\r
- return;\r
- }\r
-\r
- DeviceDataEntity deviceDataEntity = deviceDataEntityList.get(0);\r
-\r
- List<ParameterDTO> resultparamDTOList = null;\r
- List<ParameterDTO> paramDTOList = deviceRPCRequest.getOpDetails().getParmeters();\r
-\r
- for (ParameterDTO paramDTO : paramDTOList) {\r
- resultparamDTOList = ifDataTypeObject(paramDTO, deviceDataEntity);\r
-\r
- if (!resultparamDTOList.isEmpty()) {\r
- break;\r
- }\r
-\r
- if (paramDTO.getParamName().equalsIgnoreCase(VesAgentConstants.COUNT_DOWN_TIMER)) {\r
- paramDTO.setParamValue(getCountDownTimerParam(deviceDataEntity).getParamValue());\r
- } else {\r
- paramDTO.setParamValue(deviceDataEntity.getAttributesMap().get(paramDTO.getParamName()));\r
- }\r
- }\r
-\r
- if (null != resultparamDTOList && !resultparamDTOList.isEmpty()) {\r
- deviceRPCRequest.getOpDetails().setParmeters(resultparamDTOList);\r
- }\r
- }\r
-\r
- public void processHeartBeatDeleteRequest(VESNotification vesNotification) {\r
- List<ParameterDTO> paramDTOList = vesNotification.getOperationDetails().getParmeters();\r
-\r
- for (ParameterDTO paramDTO : paramDTOList) {\r
- if (Boolean.TRUE.equals(VesAgentUtils.isVesNotificationRequest(paramDTO))) {\r
- List<DeviceDataEntity> deviceDataEntityList = vesDataRepository.findByDeviceIdAndAttrGroup(\r
- vesNotification.geteNodeBName(), VesAgentConstants.HEART_BEAT);\r
-\r
- if (Boolean.TRUE.equals(VesAgentUtils.isNullOrEmpty(deviceDataEntityList))) {\r
- return;\r
- }\r
- vesDataRepository.delete(deviceDataEntityList.get(0));\r
- timerService.cancelSchedule(vesNotification.geteNodeBName());\r
- break;\r
- }\r
- }\r
- }\r
-\r
- private List<ParameterDTO> ifDataTypeObject(ParameterDTO paramDTO,\r
- DeviceDataEntity deviceDataEntity) {\r
- List<ParameterDTO> paramDTOList = new ArrayList<>();\r
-\r
- if (null != paramDTO.getDataType()\r
- && paramDTO.getDataType().equalsIgnoreCase(VesAgentConstants.OBJECT_DATA_TYPE.toLowerCase())\r
- && paramDTO.getParamName().toLowerCase()\r
- .contains(VesAgentConstants.HEART_BEAT.toLowerCase())) {\r
-\r
- Map<String, String> attrMap = deviceDataEntity.getAttributesMap();\r
-\r
- for (Map.Entry<String, String> entry : attrMap.entrySet()) {\r
- ParameterDTO param = new ParameterDTO();\r
- param.setParamName(entry.getKey());\r
- param.setParamValue(entry.getValue());\r
-\r
- paramDTOList.add(param);\r
- }\r
-\r
- ParameterDTO countDownParam = getCountDownTimerParam(deviceDataEntity);\r
- paramDTOList.add(countDownParam);\r
- }\r
-\r
- return paramDTOList;\r
- }\r
-\r
- private ParameterDTO getCountDownTimerParam(DeviceDataEntity deviceDataEntity) {\r
- Long countDownTimerVal = timerService\r
- .getTimeRemainingTillNextExecution(deviceDataEntity.getDeviceId(), TimeUnit.MINUTES);\r
-\r
- ParameterDTO param = new ParameterDTO();\r
- param.setParamName(VesAgentConstants.COUNT_DOWN_TIMER);\r
-\r
- if (null != countDownTimerVal) {\r
- param.setParamValue(countDownTimerVal.toString());\r
- }\r
-\r
- return param;\r
- }\r
-\r
-\r
- public void processHeartBeatGetRequest(String deviceId, Integer HeartBeatPeriod,\r
- Integer countDownTimer) throws VesAgentException {\r
- VesAgentUtils.validateDeviceId(deviceId);\r
-\r
-\r
- if (null == HeartBeatPeriod && null == countDownTimer) {// this should just check if heartbeat\r
- // is null\r
- String errorMsg =\r
- "Invalid input: HeartBeatPeriod and countDownTimer both are null for device " + deviceId;\r
- logger.error(errorMsg);\r
- throw new VesAgentException(errorMsg);\r
- }\r
-\r
- List<DeviceDataEntity> deviceDataEntityList =\r
- vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, VesAgentConstants.HEART_BEAT);\r
-\r
- DeviceDataEntity deviceDataEntity = null;\r
- Map<String, String> attrJsonMap = null;\r
-\r
- if (null == deviceDataEntityList || deviceDataEntityList.isEmpty()) {\r
- deviceDataEntity = new DeviceDataEntity();\r
- deviceDataEntity.setDeviceId(deviceId);\r
- deviceDataEntity.setAttrGroup(VesAgentConstants.HEART_BEAT);\r
-\r
- attrJsonMap = new HashMap<String, String>();\r
- } else {\r
- deviceDataEntity = deviceDataEntityList.get(0);\r
- attrJsonMap = new Gson().fromJson(deviceDataEntity.getAttrJson(), Map.class);\r
- }\r
-\r
-\r
- if (null != HeartBeatPeriod) {\r
- attrJsonMap.put(VesAgentConstants.HEART_BEAT_PERIOD, HeartBeatPeriod.toString());\r
- }\r
-\r
- if (null != countDownTimer) {\r
- attrJsonMap.put(VesAgentConstants.COUNT_DOWN_TIMER, countDownTimer.toString());\r
- }\r
-\r
- String attrJson = new Gson().toJson(attrJsonMap);\r
- deviceDataEntity.setAttrJson(attrJson);\r
-\r
- vesDataRepository.save(deviceDataEntity);\r
- }\r
-\r
- private void resetTimerJob(String deviceId, String heartBeatPeriod, String countDownTimer) {\r
- if (null == heartBeatPeriod || heartBeatPeriod.isEmpty()) {\r
- scheduleTimerJob(deviceId, Integer.parseInt(countDownTimer));\r
- } else if (heartBeatPeriod.equals(VesAgentConstants.REMOVE_HEART_BEAT_TIMER_VAL)) {\r
- timerService.cancelSchedule(deviceId);\r
- } else {\r
- if (Boolean.FALSE.equals(VesAgentUtils.isNullOrEmpty(countDownTimer))) {\r
- scheduleTimerJob(deviceId, Integer.parseInt(countDownTimer));\r
- } else {\r
- scheduleTimerJob(deviceId, Integer.parseInt(heartBeatPeriod));\r
- }\r
- }\r
- }\r
-\r
- private void scheduleTimerJob(String deviceId, Integer timeoutInterval) {\r
- ScheduleInfo scheduleInfo = new ScheduleInfo();\r
- scheduleInfo.setInterval(timeoutInterval);\r
- scheduleInfo.setTimeUnit(TimeUnit.MINUTES);\r
-\r
- HeartBeatTimeoutTask callbackTask = getBeanInstance(deviceId);\r
-\r
- timerService.schedule(deviceId, scheduleInfo, callbackTask);\r
- }\r
-\r
- private void abortRunningDeviceConnectivityCheck(DeviceRPCRequest deviceRPCRequest) {\r
- waitForNotifications.notifyResult(VesAgentUtils.getErrorResponse(deviceRPCRequest, null, null));\r
- }\r
-\r
- public List<DeviceDataEntity> getAllDeviceDataEntity() {\r
- return (List<DeviceDataEntity>) vesDataRepository.findAll();\r
- }\r
-\r
- public List<DeviceDataEntity> findByDeviceIdAndGroup(String deviceId, String attrGroup) {\r
- return vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, attrGroup);\r
- }\r
-\r
-\r
-\r
-}\r
+package org.commscope.tr069adapter.vesagent.service;
+
+import com.google.gson.Gson;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Function;
+
+import org.commscope.tr069adapter.acs.common.DeviceDetails;
+import org.commscope.tr069adapter.acs.common.DeviceRPCRequest;
+import org.commscope.tr069adapter.acs.common.ParameterDTO;
+import org.commscope.tr069adapter.mapper.model.VESNotification;
+import org.commscope.tr069adapter.vesagent.async.WaitForNotifications;
+import org.commscope.tr069adapter.vesagent.entity.DeviceDataEntity;
+import org.commscope.tr069adapter.vesagent.exception.VesAgentException;
+import org.commscope.tr069adapter.vesagent.repository.VesDataRepository;
+import org.commscope.tr069adapter.vesagent.timer.HeartBeatTimeoutTask;
+import org.commscope.tr069adapter.vesagent.timer.ScheduleInfo;
+import org.commscope.tr069adapter.vesagent.timer.ScheduleTaskService;
+import org.commscope.tr069adapter.vesagent.util.VesAgentConstants;
+import org.commscope.tr069adapter.vesagent.util.VesAgentUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class VesAgentServiceHelper {
+ private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ @Autowired
+ private Function<String, HeartBeatTimeoutTask> beanFactory;
+
+ public HeartBeatTimeoutTask getBeanInstance(String name) {
+ return beanFactory.apply(name);
+ }
+
+ @Autowired
+ VesDataRepository vesDataRepository;
+
+ @Autowired
+ WaitForNotifications waitForNotifications;
+
+ @Autowired
+ ScheduleTaskService timerService;
+
+ private boolean saveDeviceDataEntity(DeviceDetails deviceDetails, String eNodeBName,
+ String heartBeatPeriod, String countDownTimer) throws VesAgentException {
+
+ List<DeviceDataEntity> deviceDataEntityList = vesDataRepository
+ .findByDeviceIdAndAttrGroup(deviceDetails.getDeviceId(), VesAgentConstants.HEART_BEAT);
+
+ DeviceDataEntity deviceDataEntity = null;
+ Map<String, String> attrJsonMap = null;
+
+ if (null == deviceDataEntityList || deviceDataEntityList.isEmpty()) {
+ deviceDataEntity = new DeviceDataEntity();
+
+ deviceDataEntity.setDeviceId(deviceDetails.getDeviceId());
+ deviceDataEntity.seteNodeBName(eNodeBName);
+ deviceDataEntity.setOui(deviceDetails.getOui());
+ deviceDataEntity.setProductClass(deviceDetails.getProductClass());
+ deviceDataEntity.setAttrGroup(VesAgentConstants.HEART_BEAT);
+
+ attrJsonMap = new HashMap<>();
+ } else {
+ deviceDataEntity = deviceDataEntityList.get(0);
+ attrJsonMap = deviceDataEntity.getAttributesMap();
+ }
+
+ String existingHeartBeatPeriod = attrJsonMap.get(VesAgentConstants.HEART_BEAT_PERIOD);
+
+ if (null == heartBeatPeriod
+ && (Boolean.TRUE.equals(VesAgentUtils.isNullOrEmpty(existingHeartBeatPeriod))
+ || existingHeartBeatPeriod
+ .equalsIgnoreCase(VesAgentConstants.REMOVE_HEART_BEAT_TIMER_VAL))) {
+ return false;
+ }
+ if (null != countDownTimer
+ && !countDownTimer.equalsIgnoreCase(VesAgentConstants.COUNT_DOWN_TIMER_ZERO)) {
+ if (null == heartBeatPeriod || heartBeatPeriod.equalsIgnoreCase(existingHeartBeatPeriod)) {
+ String exceptionReason = "Can't change timer value if heartbeat value is same";
+ throw new VesAgentException(VesAgentConstants.INVALID_PARAMETER_VALUE, exceptionReason);
+ }
+
+ }
+
+ if (!VesAgentUtils.isNullOrEmpty(heartBeatPeriod)) {
+ attrJsonMap.put(VesAgentConstants.HEART_BEAT_PERIOD, heartBeatPeriod);
+ }
+
+ deviceDataEntity.setAttributesMap(attrJsonMap);
+
+ vesDataRepository.save(deviceDataEntity);
+
+ return true;
+ }
+
+ public void processHeartBeatSetRequest(DeviceRPCRequest deviceRPCRequest, String heartBeatPeriod,
+ String countDownTimer) throws VesAgentException {
+
+ String deviceId = deviceRPCRequest.getDeviceDetails().getDeviceId();
+
+ VesAgentUtils.validateDeviceId(deviceId);
+
+ if (VesAgentUtils.isNullOrEmpty(heartBeatPeriod)
+ && VesAgentUtils.isNullOrEmpty(countDownTimer)) {
+ String errorMsg =
+ "Invalid input: HeartBeatPeriod and countDownTimer both are null for device " + deviceId;
+ errorMsg = errorMsg.replaceAll("[\n|\r|\t]", "_");
+ logger.error(errorMsg);
+ throw new VesAgentException(VesAgentConstants.INVALID_PARAMETER_VALUE, errorMsg);
+ }
+
+ Object eNodeBNameObj = deviceRPCRequest.getContext().get(VesAgentConstants.ENODEB_NAME);
+
+ String eNodeBName = null;
+ if (null != eNodeBNameObj) {
+ eNodeBName = (String) eNodeBNameObj;
+ }
+
+ boolean resetTimerJob = saveDeviceDataEntity(deviceRPCRequest.getDeviceDetails(), eNodeBName,
+ heartBeatPeriod, countDownTimer);
+
+ if (resetTimerJob) {
+ resetTimerJob(deviceId, heartBeatPeriod, countDownTimer);
+ abortRunningDeviceConnectivityCheck(deviceRPCRequest);
+ }
+
+ }
+
+ public void processHeartBeatGetRequest(DeviceRPCRequest deviceRPCRequest) {
+
+ String deviceId = deviceRPCRequest.getDeviceDetails().getDeviceId();
+ List<DeviceDataEntity> deviceDataEntityList =
+ vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, VesAgentConstants.HEART_BEAT);
+
+ if (VesAgentUtils.isNullOrEmpty(deviceDataEntityList)
+ || VesAgentUtils.isNullOrEmpty(deviceDataEntityList.get(0).getAttributesMap())) {
+ return;
+ }
+
+ DeviceDataEntity deviceDataEntity = deviceDataEntityList.get(0);
+
+ List<ParameterDTO> resultparamDTOList = null;
+ List<ParameterDTO> paramDTOList = deviceRPCRequest.getOpDetails().getParmeters();
+
+ for (ParameterDTO paramDTO : paramDTOList) {
+ resultparamDTOList = ifDataTypeObject(paramDTO, deviceDataEntity);
+
+ if (!resultparamDTOList.isEmpty()) {
+ break;
+ }
+
+ if (paramDTO.getParamName().equalsIgnoreCase(VesAgentConstants.COUNT_DOWN_TIMER)) {
+ paramDTO.setParamValue(getCountDownTimerParam(deviceDataEntity).getParamValue());
+ } else {
+ paramDTO.setParamValue(deviceDataEntity.getAttributesMap().get(paramDTO.getParamName()));
+ }
+ }
+
+ if (null != resultparamDTOList && !resultparamDTOList.isEmpty()) {
+ deviceRPCRequest.getOpDetails().setParmeters(resultparamDTOList);
+ }
+ }
+
+ public void processHeartBeatDeleteRequest(VESNotification vesNotification) {
+ List<ParameterDTO> paramDTOList = vesNotification.getOperationDetails().getParmeters();
+
+ for (ParameterDTO paramDTO : paramDTOList) {
+ if (Boolean.TRUE.equals(VesAgentUtils.isVesNotificationRequest(paramDTO))) {
+ List<DeviceDataEntity> deviceDataEntityList = vesDataRepository.findByDeviceIdAndAttrGroup(
+ vesNotification.geteNodeBName(), VesAgentConstants.HEART_BEAT);
+
+ if (Boolean.TRUE.equals(VesAgentUtils.isNullOrEmpty(deviceDataEntityList))) {
+ return;
+ }
+ vesDataRepository.delete(deviceDataEntityList.get(0));
+ timerService.cancelSchedule(vesNotification.geteNodeBName());
+ break;
+ }
+ }
+ }
+
+ private List<ParameterDTO> ifDataTypeObject(ParameterDTO paramDTO,
+ DeviceDataEntity deviceDataEntity) {
+ List<ParameterDTO> paramDTOList = new ArrayList<>();
+
+ if (null != paramDTO.getDataType()
+ && paramDTO.getDataType().equalsIgnoreCase(VesAgentConstants.OBJECT_DATA_TYPE.toLowerCase())
+ && paramDTO.getParamName().toLowerCase()
+ .contains(VesAgentConstants.HEART_BEAT.toLowerCase())) {
+
+ Map<String, String> attrMap = deviceDataEntity.getAttributesMap();
+
+ for (Map.Entry<String, String> entry : attrMap.entrySet()) {
+ ParameterDTO param = new ParameterDTO();
+ param.setParamName(entry.getKey());
+ param.setParamValue(entry.getValue());
+
+ paramDTOList.add(param);
+ }
+
+ ParameterDTO countDownParam = getCountDownTimerParam(deviceDataEntity);
+ paramDTOList.add(countDownParam);
+ }
+
+ return paramDTOList;
+ }
+
+ private ParameterDTO getCountDownTimerParam(DeviceDataEntity deviceDataEntity) {
+ Long countDownTimerVal = timerService
+ .getTimeRemainingTillNextExecution(deviceDataEntity.getDeviceId(), TimeUnit.MINUTES);
+
+ ParameterDTO param = new ParameterDTO();
+ param.setParamName(VesAgentConstants.COUNT_DOWN_TIMER);
+
+ if (null != countDownTimerVal) {
+ param.setParamValue(countDownTimerVal.toString());
+ }
+
+ return param;
+ }
+
+
+ public void processHeartBeatGetRequest(String deviceId, Integer heartBeatPeriod,
+ Integer countDownTimer) throws VesAgentException {
+ VesAgentUtils.validateDeviceId(deviceId);
+
+
+ if (null == heartBeatPeriod && null == countDownTimer) {// this should just check if heartbeat
+ // is null
+ String errorMsg =
+ "Invalid input: HeartBeatPeriod and countDownTimer both are null for device " + deviceId;
+ logger.error(errorMsg);
+ throw new VesAgentException(errorMsg);
+ }
+
+ List<DeviceDataEntity> deviceDataEntityList =
+ vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, VesAgentConstants.HEART_BEAT);
+
+ DeviceDataEntity deviceDataEntity = null;
+ Map<String, String> attrJsonMap = null;
+
+ if (null == deviceDataEntityList || deviceDataEntityList.isEmpty()) {
+ deviceDataEntity = new DeviceDataEntity();
+ deviceDataEntity.setDeviceId(deviceId);
+ deviceDataEntity.setAttrGroup(VesAgentConstants.HEART_BEAT);
+
+ attrJsonMap = new HashMap<>();
+ } else {
+ deviceDataEntity = deviceDataEntityList.get(0);
+ attrJsonMap = new Gson().fromJson(deviceDataEntity.getAttrJson(), Map.class);
+ }
+
+
+ if (null != heartBeatPeriod) {
+ attrJsonMap.put(VesAgentConstants.HEART_BEAT_PERIOD, heartBeatPeriod.toString());
+ }
+
+ if (null != countDownTimer) {
+ attrJsonMap.put(VesAgentConstants.COUNT_DOWN_TIMER, countDownTimer.toString());
+ }
+
+ String attrJson = new Gson().toJson(attrJsonMap);
+ deviceDataEntity.setAttrJson(attrJson);
+
+ vesDataRepository.save(deviceDataEntity);
+ }
+
+ private void resetTimerJob(String deviceId, String heartBeatPeriod, String countDownTimer) {
+ if (null == heartBeatPeriod || heartBeatPeriod.isEmpty()) {
+ scheduleTimerJob(deviceId, Integer.parseInt(countDownTimer));
+ } else if (heartBeatPeriod.equals(VesAgentConstants.REMOVE_HEART_BEAT_TIMER_VAL)) {
+ timerService.cancelSchedule(deviceId);
+ } else {
+ if (Boolean.FALSE.equals(VesAgentUtils.isNullOrEmpty(countDownTimer))) {
+ scheduleTimerJob(deviceId, Integer.parseInt(countDownTimer));
+ } else {
+ scheduleTimerJob(deviceId, Integer.parseInt(heartBeatPeriod));
+ }
+ }
+ }
+
+ private void scheduleTimerJob(String deviceId, Integer timeoutInterval) {
+ ScheduleInfo scheduleInfo = new ScheduleInfo();
+ scheduleInfo.setInterval(timeoutInterval);
+ scheduleInfo.setTimeUnit(TimeUnit.MINUTES);
+
+ HeartBeatTimeoutTask callbackTask = getBeanInstance(deviceId);
+
+ timerService.schedule(deviceId, scheduleInfo, callbackTask);
+ }
+
+ private void abortRunningDeviceConnectivityCheck(DeviceRPCRequest deviceRPCRequest) {
+ waitForNotifications.notifyResult(VesAgentUtils.getErrorResponse(deviceRPCRequest, null, null));
+ }
+
+ public List<DeviceDataEntity> getAllDeviceDataEntity() {
+ return (List<DeviceDataEntity>) vesDataRepository.findAll();
+ }
+
+ public List<DeviceDataEntity> findByDeviceIdAndGroup(String deviceId, String attrGroup) {
+ return vesDataRepository.findByDeviceIdAndAttrGroup(deviceId, attrGroup);
+ }
+
+
+
+}
Code Review / oam / tr069-adapter.git / blobdiff