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

代码注释

Browse Source
This commit is contained in:
xy
2024-09-11 12:34:27 +08:00
parent 72e81b1b6d
commit 107c6d2637
1 changed files with 44 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

88
iot-analysis/analysis-stat/stat-boot/src/main/java/com/njcn/stat/service/impl/WlRecordServiceImpl.java
View File

@@ -1,44 +1,44 @@
package com.njcn.stat.service.impl;
import com.njcn.csdevice.api.EquipmentFeignClient;
import com.njcn.csdevice.api.WlRecordFeignClient;
import com.njcn.csdevice.pojo.po.CsEquipmentDeliveryPO;
import com.njcn.csdevice.pojo.po.WlRecord;
import com.njcn.mq.message.AppAutoDataMessage;
import com.njcn.stat.service.IWlRecordService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2023/8/14 9:32
*/
@Service
@Slf4j
@AllArgsConstructor
public class WlRecordServiceImpl implements IWlRecordService{
private final EquipmentFeignClient equipmentFeignClient;
private final WlRecordFeignClient wlRecordFeignClient;
@Override
public void addOrUpdateBaseData(AppAutoDataMessage appAutoDataMessage) {
WlRecord wlRecord = new WlRecord();
CsEquipmentDeliveryPO po = equipmentFeignClient.findDevByNDid(appAutoDataMessage.getId()).getData();
AppAutoDataMessage.DataArray dataArray = appAutoDataMessage.getMsg().getDataArray().get(0);
BeanUtils.copyProperties(dataArray, wlRecord);
wlRecord.setDevId(po.getId());
wlRecord.setLineId(po.getNdid() + appAutoDataMessage.getMsg().getClDid());
wlRecord.setGcDataPath(dataArray.getPrjDataPath());
if (dataArray.getPrjTimeEnd() == -1) {
wlRecord.setEndTime(null);
}
wlRecordFeignClient.addBaseData(wlRecord);
}
}
//package com.njcn.stat.service.impl;
//
//import com.njcn.csdevice.api.EquipmentFeignClient;
//import com.njcn.csdevice.api.WlRecordFeignClient;
//import com.njcn.csdevice.pojo.po.CsEquipmentDeliveryPO;
//import com.njcn.csdevice.pojo.po.WlRecord;
//import com.njcn.mq.message.AppAutoDataMessage;
//import com.njcn.stat.service.IWlRecordService;
//import lombok.AllArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.BeanUtils;
//import org.springframework.stereotype.Service;
//
///**
// * 类的介绍：
// *
// * @author xuyang
// * @version 1.0.0
// * @createTime 2023/8/14 9:32
// */
//@Service
//@Slf4j
//@AllArgsConstructor
//public class WlRecordServiceImpl implements IWlRecordService{
//
// private final EquipmentFeignClient equipmentFeignClient;
//
// private final WlRecordFeignClient wlRecordFeignClient;
//
// @Override
// public void addOrUpdateBaseData(AppAutoDataMessage appAutoDataMessage) {
// WlRecord wlRecord = new WlRecord();
// CsEquipmentDeliveryPO po = equipmentFeignClient.findDevByNDid(appAutoDataMessage.getId()).getData();
// AppAutoDataMessage.DataArray dataArray = appAutoDataMessage.getMsg().getDataArray().get(0);
// BeanUtils.copyProperties(dataArray, wlRecord);
// wlRecord.setDevId(po.getId());
// wlRecord.setLineId(po.getNdid() + appAutoDataMessage.getMsg().getClDid());
// wlRecord.setGcDataPath(dataArray.getPrjDataPath());
// if (dataArray.getPrjTimeEnd() == -1) {
// wlRecord.setEndTime(null);
// }
// wlRecordFeignClient.addBaseData(wlRecord);
// }
//}