Microservice/govern
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
xy
2024-11-12 16:42:36 +08:00
parent 10910e36e0
commit 625ed864c7
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/RealDataServiceImpl.java
View File

@@ -2,6 +2,7 @@ package com.njcn.csharmonic.service.impl;
import com.njcn.access.api.AskDeviceDataFeignClient; import com.njcn.access.api.AskDeviceDataFeignClient;
import com.njcn.access.utils.MqttUtil; import com.njcn.access.utils.MqttUtil;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.csdevice.api.CsLineFeignClient; import com.njcn.csdevice.api.CsLineFeignClient;
import com.njcn.csdevice.api.DataSetFeignClient; import com.njcn.csdevice.api.DataSetFeignClient;
import com.njcn.csdevice.pojo.po.CsDataSet; import com.njcn.csdevice.pojo.po.CsDataSet;
@@ -34,7 +35,7 @@ public class RealDataServiceImpl implements RealDataService {
String clientName = "NJCN-" + nDid.substring(nDid.length() - 6); String clientName = "NJCN-" + nDid.substring(nDid.length() - 6);
boolean mqttClient = mqttUtil.judgeClientOnline(clientName); boolean mqttClient = mqttUtil.judgeClientOnline(clientName);
if (!mqttClient) { if (!mqttClient) {
throw new RuntimeException("装置离线"); throw new BusinessException("装置离线");
} }
Integer clDid = Integer.parseInt(lineId.substring(lineId.length() - 1)); Integer clDid = Integer.parseInt(lineId.substring(lineId.length() - 1));
//获取装置所用模板 //获取装置所用模板
@@ -53,8 +54,8 @@ public class RealDataServiceImpl implements RealDataService {
result = false; result = false;
} }
} }
} catch (InterruptedException e) { } catch (Exception e) {
throw new RuntimeException(e.getMessage()); throw new BusinessException(e.getMessage());
} }
return result; return result;
} }
@@ -67,7 +68,7 @@ public class RealDataServiceImpl implements RealDataService {
String clientName = "NJCN-" + nDid.substring(nDid.length() - 6); String clientName = "NJCN-" + nDid.substring(nDid.length() - 6);
boolean mqttClient = mqttUtil.judgeClientOnline(clientName); boolean mqttClient = mqttUtil.judgeClientOnline(clientName);
if (!mqttClient) { if (!mqttClient) {
throw new RuntimeException("装置离线"); throw new BusinessException("装置离线");
} }
Integer clDid = Integer.parseInt(lineId.substring(lineId.length() - 1)); Integer clDid = Integer.parseInt(lineId.substring(lineId.length() - 1));
//获取装置所用模板 //获取装置所用模板
@@ -87,8 +88,8 @@ public class RealDataServiceImpl implements RealDataService {
result = false; result = false;
} }
} }
} catch (InterruptedException e) { } catch (Exception e) {
throw new RuntimeException(e.getMessage()); throw new BusinessException(e.getMessage());
} }
return result; return result;
} }