微调
This commit is contained in:
@@ -26,10 +26,12 @@ import com.njcn.gather.detection.util.socket.SocketManager;
|
|||||||
import com.njcn.gather.detection.util.socket.cilent.NettyClient;
|
import com.njcn.gather.detection.util.socket.cilent.NettyClient;
|
||||||
import com.njcn.gather.detection.util.socket.cilent.NettySourceClientHandler;
|
import com.njcn.gather.detection.util.socket.cilent.NettySourceClientHandler;
|
||||||
import com.njcn.gather.device.device.service.IPqDevService;
|
import com.njcn.gather.device.device.service.IPqDevService;
|
||||||
|
import com.njcn.gather.device.script.pojo.param.PqScriptCheckDataParam;
|
||||||
import com.njcn.gather.device.script.pojo.param.PqScriptIssueParam;
|
import com.njcn.gather.device.script.pojo.param.PqScriptIssueParam;
|
||||||
import com.njcn.gather.device.script.pojo.po.PqScriptCheckData;
|
import com.njcn.gather.device.script.pojo.po.PqScriptCheckData;
|
||||||
import com.njcn.gather.device.script.pojo.po.PqScriptDtls;
|
import com.njcn.gather.device.script.pojo.po.PqScriptDtls;
|
||||||
import com.njcn.gather.device.script.pojo.po.SourceIssue;
|
import com.njcn.gather.device.script.pojo.po.SourceIssue;
|
||||||
|
import com.njcn.gather.device.script.service.IPqScriptCheckDataService;
|
||||||
import com.njcn.gather.device.script.service.IPqScriptDtlsService;
|
import com.njcn.gather.device.script.service.IPqScriptDtlsService;
|
||||||
import com.njcn.gather.device.source.pojo.po.PqSource;
|
import com.njcn.gather.device.source.pojo.po.PqSource;
|
||||||
import com.njcn.gather.device.source.pojo.po.SourceInitialize;
|
import com.njcn.gather.device.source.pojo.po.SourceInitialize;
|
||||||
@@ -69,8 +71,7 @@ public class PreDetectionServiceImpl implements PreDetectionService {
|
|||||||
|
|
||||||
private final SocketDevResponseService socketDevResponseService;
|
private final SocketDevResponseService socketDevResponseService;
|
||||||
private final SocketSourceResponseService socketSourceResponseService;
|
private final SocketSourceResponseService socketSourceResponseService;
|
||||||
private final AdHarmonicService adHarmonicService;
|
private final IPqScriptCheckDataService iPqScriptCheckDataService;
|
||||||
|
|
||||||
|
|
||||||
@Value("${socket.source.ip:192.168.1.136}")
|
@Value("${socket.source.ip:192.168.1.136}")
|
||||||
private String ip;
|
private String ip;
|
||||||
@@ -214,7 +215,12 @@ public class PreDetectionServiceImpl implements PreDetectionService {
|
|||||||
SocketManager.sendMsg(param.getUserPageId() + source, JSON.toJSONString(xuMsg));
|
SocketManager.sendMsg(param.getUserPageId() + source, JSON.toJSONString(xuMsg));
|
||||||
} else {
|
} else {
|
||||||
//TODO 是否最终检测完成需要推送给用户
|
//TODO 是否最终检测完成需要推送给用户
|
||||||
iPqDevService.updateResult(param.getDevIds(), param.getCode());
|
PqScriptCheckDataParam checkDataParam=new PqScriptCheckDataParam();
|
||||||
|
checkDataParam.setScriptId(param.getScriptId());
|
||||||
|
checkDataParam.setIsValueTypeName(false);
|
||||||
|
List<String> valueType = iPqScriptCheckDataService.getValueType(checkDataParam);
|
||||||
|
|
||||||
|
iPqDevService.updateResult(param.getDevIds(), valueType,param.getCode());
|
||||||
CnSocketUtil.quitSend(param);
|
CnSocketUtil.quitSend(param);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user