ClientApps/CN_Gather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.微调实体信息

Browse Source
This commit is contained in:
wr
2024-12-20 08:55:46 +08:00
parent b0f54b0cde
commit 5dafcad3fa
8 changed files with 63 additions and 95 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java
View File

@@ -41,10 +41,6 @@ public class SocketDevResponseService {
private final IPqScriptDtlsService scriptDtlsService; private final IPqScriptDtlsService scriptDtlsService;
private final IPqScriptDtlsService pqScriptDtlsService; private final IPqScriptDtlsService pqScriptDtlsService;
/**
* 所有装置通道信息
*/
List<String> moniterIdList = new ArrayList<>();
/** /**
* 存储的装置相序数据 * 存储的装置相序数据
*/ */
@@ -53,24 +49,20 @@ public class SocketDevResponseService {
* 成功结束的装置 * 成功结束的装置
*/ */
List<String> success = new ArrayList<>(); List<String> success = new ArrayList<>();
/**
* 装置名称
*/
Map<String, String> devNameMap = new HashMap<>();
/** /**
* 所有装置通道信息 * 所有装置通道信息
*/ */
List<String> moniterIdListComm = new ArrayList<>(); List<String> monitorIdListComm = new ArrayList<>();
/**
* 成功结束的装置
*/
List<String> successComm = new ArrayList<>();
/** /**
* 装置名称 * 装置名称
*/ */
Map<String, String> devNameMapComm = new HashMap<>(); Map<String, String> devNameMapComm = new HashMap<>();
/**
* 成功结束的装置
*/
List<String> successComm = new ArrayList<>();
/** /**
@@ -78,10 +70,7 @@ public class SocketDevResponseService {
*/ */
List<String> successXieyi = new ArrayList<>(); List<String> successXieyi = new ArrayList<>();
List<String> successXieyi3 = new ArrayList<>(); List<String> successXieyi3 = new ArrayList<>();
/**
* 装置名称
*/
Map<String, String> devNameMapXieyi = new HashMap<>();
public void deal(PreDetectionParam param, String msg) { public void deal(PreDetectionParam param, String msg) {
SocketDataMsg socketDataMsg = MsgUtil.socketDataMsg(msg); SocketDataMsg socketDataMsg = MsgUtil.socketDataMsg(msg);
@@ -100,7 +89,7 @@ public class SocketDevResponseService {
switch (dictDataEnumByCode) { switch (dictDataEnumByCode) {
case SUCCESS: case SUCCESS:
//通讯校验成功 //通讯校验成功
switch (operateCodeEnum){ switch (operateCodeEnum) {
case QUIT_INIT_01: case QUIT_INIT_01:
break; break;
case QUIT_INIT_02: case QUIT_INIT_02:
@@ -153,8 +142,8 @@ public class SocketDevResponseService {
String mId = JSON.parseObject(msg).get("data").toString(); String mId = JSON.parseObject(msg).get("data").toString();
successComm.add(mId); successComm.add(mId);
System.out.println(successComm.size() + "=====" + moniterIdListComm.size()); System.out.println(successComm.size() + "=====" + monitorIdListComm.size());
if (successComm.size() == moniterIdListComm.size()) { if (successComm.size() == monitorIdListComm.size()) {
//开始进行协议校验 //开始进行协议校验
List<PreDetection> devList = iPqDevService.getDevInfo(param.getDevIds()); List<PreDetection> devList = iPqDevService.getDevInfo(param.getDevIds());
Map<String, List<PreDetection>> map = new HashMap(1); Map<String, List<PreDetection>> map = new HashMap(1);
@@ -184,7 +173,7 @@ public class SocketDevResponseService {
break; break;
case RE_OPERATE: case RE_OPERATE:
//发起关闭操作 //发起关闭操作
quitSend(param,socketMsg); quitSend(param, socketMsg);
break; break;
default: default:
WebSocketVO webSocketVO = new WebSocketVO(); WebSocketVO webSocketVO = new WebSocketVO();
@@ -211,7 +200,7 @@ public class SocketDevResponseService {
String type = jsonObject.get("operateCode").toString(); String type = jsonObject.get("operateCode").toString();
if (type.equals(SourceOperateCodeEnum.DEV_INIT_GATHER_02.getValue())) { if (type.equals(SourceOperateCodeEnum.DEV_INIT_GATHER_02.getValue())) {
successXieyi.add(mId); successXieyi.add(mId);
if (successXieyi.size() == moniterIdListComm.size()) { if (successXieyi.size() == monitorIdListComm.size()) {
//协议3校验 //协议3校验
successXieyi = new ArrayList<>(); successXieyi = new ArrayList<>();
@@ -230,21 +219,21 @@ public class SocketDevResponseService {
} }
} else if (type.equals(SourceOperateCodeEnum.DEV_INIT_GATHER_03.getValue())) { } else if (type.equals(SourceOperateCodeEnum.DEV_INIT_GATHER_03.getValue())) {
successXieyi3.add(mId); successXieyi3.add(mId);
System.out.println(successXieyi3.size() + "=====" + moniterIdListComm.size()); System.out.println(successXieyi3.size() + "=====" + monitorIdListComm.size());
if (successXieyi3.size() == moniterIdListComm.size()) { if (successXieyi3.size() == monitorIdListComm.size()) {
System.out.println("开始相序校验++++++++++"); System.out.println("开始相序校验++++++++++");
PqScriptIssueParam issueParam=new PqScriptIssueParam(); PqScriptIssueParam issueParam = new PqScriptIssueParam();
issueParam.setPlanId(param.getPlanId()); issueParam.setPlanId(param.getPlanId());
issueParam.setSourceId(param.getSourceId()); issueParam.setSourceId(param.getSourceId());
issueParam.setIsPhaseSequence(true); issueParam.setIsPhaseSequence(true);
issueParam.setDevIds(param.getDevIds()); issueParam.setDevIds(param.getDevIds());
List<SourceIssue> sourceIssues = pqScriptDtlsService.listSourceIssue(issueParam); List<SourceIssue> sourceIssues = pqScriptDtlsService.listSourceIssue(issueParam);
if(CollUtil.isNotEmpty(sourceIssues)){ if (CollUtil.isNotEmpty(sourceIssues)) {
SocketMsg xuMsg=new SocketMsg(); SocketMsg xuMsg = new SocketMsg();
xuMsg.setRequestId(SourceOperateCodeEnum.YJC_XUJY.getValue()); xuMsg.setRequestId(SourceOperateCodeEnum.YJC_XUJY.getValue());
xuMsg.setOperateCode(SourceOperateCodeEnum.OPER_GATHER.getValue()); xuMsg.setOperateCode(SourceOperateCodeEnum.OPER_GATHER.getValue());
xuMsg.setData(JSON.toJSONString(sourceIssues.get(0))); xuMsg.setData(JSON.toJSONString(sourceIssues.get(0)));
SocketManager.sendMsg(param.getUserPageId()+"_Source",JSON.toJSONString(xuMsg)); SocketManager.sendMsg(param.getUserPageId() + "_Source", JSON.toJSONString(xuMsg));
} }
} }
} }
@@ -255,7 +244,7 @@ public class SocketDevResponseService {
break; break;
case RE_OPERATE: case RE_OPERATE:
//发起关闭操作 //发起关闭操作
quitSend(param,socketMsg); quitSend(param, socketMsg);
break; break;
default: default:
WebSocketVO webSocketVO = new WebSocketVO(); WebSocketVO webSocketVO = new WebSocketVO();
@@ -268,24 +257,15 @@ public class SocketDevResponseService {
/** /**
* 退出检测 * 退出检测
*/ */
private void quitSend(PreDetectionParam param,SocketMsg socketMsg){ private void quitSend(PreDetectionParam param, SocketMsg socketMsg) {
socketMsg.setRequestId(SourceOperateCodeEnum.QUITE.getValue()); socketMsg.setRequestId(SourceOperateCodeEnum.QUITE.getValue());
socketMsg.setOperateCode(SourceOperateCodeEnum.QUIT_INIT_03.getValue()); socketMsg.setOperateCode(SourceOperateCodeEnum.QUIT_INIT_03.getValue());
SocketManager.sendMsg(param.getUserPageId()+handlerStr, JSON.toJSONString(socketMsg)); SocketManager.sendMsg(param.getUserPageId() + handlerStr, JSON.toJSONString(socketMsg));
} }
public void devXu(PreDetectionParam param, SocketDataMsg socketDataMsg) { public void devXu(PreDetectionParam param, SocketDataMsg socketDataMsg) {
if (CollUtil.isEmpty(moniterIdList)) {
List<PreDetection> pqDevList = iPqDevService.getDevInfo(param.getDevIds());
moniterIdList = pqDevList.stream().flatMap(x -> x.getMonitorList().stream())
.map(PreDetection.MonitorListDTO::getLineId)
.collect(Collectors.toList());
devNameMap = pqDevList.stream().collect(Collectors.toMap(PreDetection::getDevIP, PreDetection::getDevName));
// moniterIdList.add("192.168.1.186_1");
}
String data = socketDataMsg.getData(); String data = socketDataMsg.getData();
DevData devData = JSON.parseObject(data, DevData.class); DevData devData = JSON.parseObject(data, DevData.class);
SourceResponseCodeEnum dictDataEnumByCode = SourceResponseCodeEnum.getDictDataEnumByCode(socketDataMsg.getCode()); SourceResponseCodeEnum dictDataEnumByCode = SourceResponseCodeEnum.getDictDataEnumByCode(socketDataMsg.getCode());
@@ -295,7 +275,7 @@ public class SocketDevResponseService {
case SUCCESS: case SUCCESS:
devInfo.add(devData); devInfo.add(devData);
success.add(devData.getId()); success.add(devData.getId());
if (success.size() == moniterIdList.size()) { if (success.size() == monitorIdListComm.size()) {
PqScriptIssueParam sourceParam = new PqScriptIssueParam(); PqScriptIssueParam sourceParam = new PqScriptIssueParam();
sourceParam.setPlanId(param.getPlanId()); sourceParam.setPlanId(param.getPlanId());
sourceParam.setDevIds(param.getDevIds()); sourceParam.setDevIds(param.getDevIds());
@@ -308,16 +288,15 @@ public class SocketDevResponseService {
info.addAll(devIsSource(dev, sourceIssues.get(0))); info.addAll(devIsSource(dev, sourceIssues.get(0)));
} }
} }
xuClear();
String s = param.getUserPageId() + "_Source"; String s = param.getUserPageId() + "_Source";
SocketMsg msg= new SocketMsg(); SocketMsg msg = new SocketMsg();
msg.setRequestId(SourceOperateCodeEnum.YJC_YTXJY.getValue()); msg.setRequestId(SourceOperateCodeEnum.YJC_YTXJY.getValue());
msg.setOperateCode(SourceOperateCodeEnum.CLOSE_GATHER.getValue()); msg.setOperateCode(SourceOperateCodeEnum.CLOSE_GATHER.getValue());
Map<String,String> map=new HashMap<>(1); Map<String, String> map = new HashMap<>(1);
map.put("sourceId",sourceIssues.get(0).getSourceId()); map.put("sourceId", sourceIssues.get(0).getSourceId());
msg.setData(JSON.toJSONString(map)); msg.setData(JSON.toJSONString(map));
SocketManager.sendMsg(s, JSON.toJSONString(msg)); SocketManager.sendMsg(s, JSON.toJSONString(msg));
//向前端推送消息
socketMsg.setRequestId(SourceOperateCodeEnum.YJC_XUJY.getValue()); socketMsg.setRequestId(SourceOperateCodeEnum.YJC_XUJY.getValue());
socketMsg.setOperateCode(socketDataMsg.getOperateCode()); socketMsg.setOperateCode(socketDataMsg.getOperateCode());
socketMsg.setData(JSON.toJSONString(info)); socketMsg.setData(JSON.toJSONString(info));
@@ -425,28 +404,24 @@ public class SocketDevResponseService {
return compareDev; return compareDev;
} }
public void xuClear() {
this.moniterIdList.clear();
this.devInfo.clear();
this.success.clear();
}
/** /**
* 初始化集合 * 初始化集合
*/ */
public void initList(PreDetectionParam param) { public void initList(PreDetectionParam param) {
this.moniterIdListComm = new ArrayList<>(); this.monitorIdListComm = new ArrayList<>();
this.successComm = new ArrayList<>(); this.successComm = new ArrayList<>();
this.devNameMapComm = new HashMap<>();
this.successXieyi = new ArrayList<>(); this.successXieyi = new ArrayList<>();
this.successXieyi3 = new ArrayList<>(); this.successXieyi3 = new ArrayList<>();
this.devNameMapXieyi = new HashMap<>(); this.devInfo = new ArrayList<>();
this.success = new ArrayList<>();
List<PreDetection> pqDevList = iPqDevService.getDevInfo(param.getDevIds()); List<PreDetection> pqDevList = iPqDevService.getDevInfo(param.getDevIds());
this.moniterIdListComm = pqDevList.stream().flatMap(x -> x.getMonitorList().stream()) this.monitorIdListComm = pqDevList.stream().flatMap(x -> x.getMonitorList().stream())
.map(PreDetection.MonitorListDTO::getLineId) .map(PreDetection.MonitorListDTO::getLineId)
.collect(Collectors.toList()); .collect(Collectors.toList());
this.devNameMapComm = pqDevList.stream().collect(Collectors.toMap(PreDetection::getDevIP, PreDetection::getDevName));
} }

2
detection/src/main/java/com/njcn/gather/detection/pojo/param/PreDetectionParam.java
View File

@@ -33,7 +33,7 @@ public class PreDetectionParam {
private String scriptId; private String scriptId;
/** /**
* 检测脚本Id * 源id
*/ */
private String sourceId; private String sourceId;
} }

16
detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java
View File

@@ -87,6 +87,7 @@ public class PreDetectionServiceImpl implements PreDetectionService {
} }
private void sendYtxSocket(PreDetectionParam param) { private void sendYtxSocket(PreDetectionParam param) {
AdPlanSource planSource = adPlanSourceService.getOne(new LambdaQueryWrapper<AdPlanSource>() AdPlanSource planSource = adPlanSourceService.getOne(new LambdaQueryWrapper<AdPlanSource>()
.eq(AdPlanSource::getPlanId, param.getPlanId()) .eq(AdPlanSource::getPlanId, param.getPlanId())
@@ -95,20 +96,13 @@ public class PreDetectionServiceImpl implements PreDetectionService {
SourceInitialize sourceParam = pqSourceService.getSourceInitializeParam(planSource.getSourceId()); SourceInitialize sourceParam = pqSourceService.getSourceInitializeParam(planSource.getSourceId());
if (ObjectUtil.isNotNull(sourceParam)) { if (ObjectUtil.isNotNull(sourceParam)) {
//开始组装socket报文请求头 //开始组装socket报文请求头
SocketMsg msg ;
String s = param.getUserPageId() + "_Source";
//PQC600A_192.168.1.133_6806
Channel channel = SocketManager.getChannelByUserId(s);
socketDevResponseService.xuClear();
socketDevResponseService.initList(param); socketDevResponseService.initList(param);
SocketMsg msg = new SocketMsg();
msg= new SocketMsg();
msg.setRequestId(SourceOperateCodeEnum.YJC_YTXJY.getValue()); msg.setRequestId(SourceOperateCodeEnum.YJC_YTXJY.getValue());
msg.setOperateCode(SourceOperateCodeEnum.INIT_GATHER.getValue()); msg.setOperateCode(SourceOperateCodeEnum.INIT_GATHER.getValue());
msg.setData(JSON.toJSONString(sourceParam)); msg.setData(JSON.toJSONString(sourceParam));
NettyClient.socketClient(ip, port, param.getUserPageId(), JSON.toJSONString(msg),new NettySourceClientHandler(param, sourceResponseService)); param.setSourceId(sourceParam.getSourceId());
NettyClient.socketClient(ip, port, param.getUserPageId(), JSON.toJSONString(msg), new NettySourceClientHandler(param, sourceResponseService));
} else { } else {
throw new BusinessException(DetectionResponseEnum.SOURCE_INFO_NOT); throw new BusinessException(DetectionResponseEnum.SOURCE_INFO_NOT);
} }
@@ -129,7 +123,7 @@ public class PreDetectionServiceImpl implements PreDetectionService {
String ddId = param.getUserPageId() + "_Source"; String ddId = param.getUserPageId() + "_Source";
Channel channel = SocketManager.getChannelByUserId(ddId); Channel channel = SocketManager.getChannelByUserId(ddId);
if (channel == null || !channel.isActive()) { if (channel == null || !channel.isActive()) {
NettyClient.socketClient(ip, port, param.getUserPageId(),"start\n", new NettySourceClientHandler(param, sourceResponseService)); NettyClient.socketClient(ip, port, param.getUserPageId(), "start\n", new NettySourceClientHandler(param, sourceResponseService));
} }
} }

1
detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java
View File

@@ -92,7 +92,6 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler<String> {
@Override @Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
socketResponseService.xuClear();
// 处理异常，例如记录日志、关闭连接等 // 处理异常，例如记录日志、关闭连接等
cause.printStackTrace(); cause.printStackTrace();
// 根据异常类型进行不同的处理 // 根据异常类型进行不同的处理

4
device/src/main/java/com/njcn/gather/device/device/pojo/po/PqDev.java
View File

@@ -53,12 +53,12 @@ public class PqDev extends BaseEntity implements Serializable {
/** /**
* 额定电压（V） * 额定电压（V）
*/ */
private Float devVolt; private Double devVolt;
/** /**
* 额定电流（A） * 额定电流（A）
*/ */
private Float devCurr; private Double devCurr;
/** /**
* 设备厂家，字典表 * 设备厂家，字典表

2
device/src/main/java/com/njcn/gather/device/script/controller/PqScriptController.java
View File

@@ -151,7 +151,7 @@ public class PqScriptController extends BaseController {
String jsonString = JSON.toJSONString(sourceIssue,SerializerFeature.WriteNullStringAsEmpty); String jsonString = JSON.toJSONString(sourceIssue,SerializerFeature.WriteNullStringAsEmpty);
System.out.println(); System.out.println();
} }
String jsonString = JSON.toJSONString(sourceIssues, SerializerFeature.WriteMapNullValue); String jsonString =sourceIssues.get(0).toString();
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, sourceIssues, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, sourceIssues, methodDescribe);
} }
} }

12
device/src/main/java/com/njcn/gather/device/script/pojo/po/PqScriptDtls.java
View File

@@ -49,12 +49,12 @@ public class PqScriptDtls implements Serializable {
/** /**
* 值 * 值
*/ */
private Float value; private Double value;
/** /**
* 相角 * 相角
*/ */
private Float angle; private Double angle;
/** /**
* （间）谐波次数 * （间）谐波次数
@@ -66,25 +66,25 @@ public class PqScriptDtls implements Serializable {
* 暂态幅度（%） * 暂态幅度（%）
*/ */
@TableField("TransValue") @TableField("TransValue")
private Float transValue; private Double transValue;
/** /**
* 持续时间（周波） * 持续时间（周波）
*/ */
@TableField("RetainTime") @TableField("RetainTime")
private Float retainTime; private Double retainTime;
/** /**
* 变动频度（次/min） * 变动频度（次/min）
*/ */
@TableField("ChagFre") @TableField("ChagFre")
private Float chagFre; private Double chagFre;
/** /**
* 变动量（%） * 变动量（%）
*/ */
@TableField("ChagValue") @TableField("ChagValue")
private Float chagValue; private Double chagValue;
/** /**
* 状态：0-不启用 1-启用 * 状态：0-不启用 1-启用

32
device/src/main/java/com/njcn/gather/device/script/service/impl/PqScriptDtlsServiceImpl.java
View File

@@ -43,19 +43,19 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
private final static String DIP = "Dip"; private final static String DIP = "Dip";
private final static String FLICKER = "Flicker"; private final static String FLICKER = "Flicker";
@Value("${Dip.fPreTime}") @Value("${Dip.fPreTime}")
private Float fPreTime; private Double fPreTime;
@Value("${Dip.fRampIn}") @Value("${Dip.fRampIn}")
private Float fRampIn; private Double fRampIn;
@Value("${Dip.fRampOut}") @Value("${Dip.fRampOut}")
private Float fRampOut; private Double fRampOut;
@Value("${Dip.fAfterTime}") @Value("${Dip.fAfterTime}")
private Float fAfterTime; private Double fAfterTime;
@Value("${Flicker.waveFluType}") @Value("${Flicker.waveFluType}")
private String waveFluType; private String waveFluType;
@Value("${Flicker.waveType}") @Value("${Flicker.waveType}")
private String waveType; private String waveType;
@Value("${Flicker.fDutyCycle}") @Value("${Flicker.fDutyCycle}")
private Float fDutyCycle; private Double fDutyCycle;
private final IPqDevService pqDevService; private final IPqDevService pqDevService;
@@ -109,12 +109,12 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
.eq(PqDev::getState, DataStateEnum.ENABLE.getCode()) .eq(PqDev::getState, DataStateEnum.ENABLE.getCode())
); );
//额定电压信息 //额定电压信息
Set<Float> voltSet = list.stream().map(PqDev::getDevVolt).collect(Collectors.toSet()); Set<Double> voltSet = list.stream().map(PqDev::getDevVolt).collect(Collectors.toSet());
//额定电流信息 //额定电流信息
Set<Float> currSet = list.stream().map(PqDev::getDevCurr).collect(Collectors.toSet()); Set<Double> currSet = list.stream().map(PqDev::getDevCurr).collect(Collectors.toSet());
if (voltSet.size() == 1 && currSet.size() == 1) { if (voltSet.size() == 1 && currSet.size() == 1) {
Float volt = voltSet.stream().collect(Collectors.toList()).stream().findFirst().get(); Double volt = voltSet.stream().collect(Collectors.toList()).stream().findFirst().get();
Float curr = currSet.stream().collect(Collectors.toList()).stream().findFirst().get(); Double curr = currSet.stream().collect(Collectors.toList()).stream().findFirst().get();
List<PqScriptDtls> pqScriptDtls = this.pqScriptDtls(param.getScriptId(),param.getIsPhaseSequence(), volt, curr); List<PqScriptDtls> pqScriptDtls = this.pqScriptDtls(param.getScriptId(),param.getIsPhaseSequence(), volt, curr);
if (CollUtil.isNotEmpty(pqScriptDtls)) { if (CollUtil.isNotEmpty(pqScriptDtls)) {
/** /**
@@ -182,7 +182,7 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
return sourceIssues; return sourceIssues;
} }
private List<PqScriptDtls> pqScriptDtls(String scriptId,Boolean isPhaseSequence,Float volt, Float curr) { private List<PqScriptDtls> pqScriptDtls(String scriptId,Boolean isPhaseSequence,Double volt, Double curr) {
List<PqScriptDtls> pqScriptDtls; List<PqScriptDtls> pqScriptDtls;
if(isPhaseSequence){ if(isPhaseSequence){
pqScriptDtls = this.list(new MPJLambdaWrapper<PqScriptDtls>() pqScriptDtls = this.list(new MPJLambdaWrapper<PqScriptDtls>()
@@ -226,7 +226,7 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
List<PqScriptDtls> dtlsOtherList, List<PqScriptDtls> dtlsOtherList,
String harm, String harm,
String inHarm, String inHarm,
Float fFreq, Double fFreq,
String code, String code,
List<SourceIssue.ChannelListDTO> channelListDTOS) { List<SourceIssue.ChannelListDTO> channelListDTOS) {
for (PqScriptDtls dtls : dtlsList) { for (PqScriptDtls dtls : dtlsList) {
@@ -243,8 +243,8 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
channelListDTO.setInharmList(new ArrayList<>()); channelListDTO.setInharmList(new ArrayList<>());
//暂态数据 //暂态数据
SourceIssue.ChannelListDTO.DipDataDTO dipDataDTO = new SourceIssue.ChannelListDTO.DipDataDTO(); SourceIssue.ChannelListDTO.DipDataDTO dipDataDTO = new SourceIssue.ChannelListDTO.DipDataDTO();
dipDataDTO.setFTransValue(0.0f); dipDataDTO.setFTransValue(0.0);
dipDataDTO.setFRetainTime(0.0f); dipDataDTO.setFRetainTime(0.0);
dipDataDTO.setFPreTime(fPreTime); dipDataDTO.setFPreTime(fPreTime);
dipDataDTO.setFRampIn(fRampIn); dipDataDTO.setFRampIn(fRampIn);
@@ -259,8 +259,8 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
flickerDataDTO.setWaveType(waveType); flickerDataDTO.setWaveType(waveType);
flickerDataDTO.setFDutyCycle(fDutyCycle); flickerDataDTO.setFDutyCycle(fDutyCycle);
flickerDataDTO.setFChagFre(0.0f); flickerDataDTO.setFChagFre(0.0);
flickerDataDTO.setFChagValue(0.0f); flickerDataDTO.setFChagValue(0.0);
channelListDTO.setFlickerData(flickerDataDTO); channelListDTO.setFlickerData(flickerDataDTO);
@@ -290,7 +290,7 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl<PqScriptDtlsMapper, PqS
PqScriptDtls dip = dipList.get(0); PqScriptDtls dip = dipList.get(0);
dipDataDTO.setFTransValue(dip.getTransValue()); dipDataDTO.setFTransValue(dip.getTransValue());
// 1.0/频率*持续时间（周波）= 暂态持续时间（s） // 1.0/频率*持续时间（周波）= 暂态持续时间（s）
dipDataDTO.setFRetainTime(NumberUtil.round(1.0 / fFreq * dip.getRetainTime(), 3).floatValue()); dipDataDTO.setFRetainTime(NumberUtil.round(1.0 / fFreq * dip.getRetainTime(), 3).doubleValue());
channelListDTO.setDipFlag(true); channelListDTO.setDipFlag(true);
channelListDTO.setDipData(dipDataDTO); channelListDTO.setDipData(dipDataDTO);
} }