diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java index 63f5820..c6e9122 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java @@ -34,6 +34,7 @@ import com.njcn.system.pojo.po.DictData; import com.njcn.system.pojo.po.EleEvtParm; import com.njcn.web.pojo.param.BaseParam; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; @@ -42,6 +43,7 @@ import java.io.IOException; import java.io.ObjectInputStream; import java.text.SimpleDateFormat; import java.time.ZoneId; +import java.time.ZoneOffset; import java.util.*; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -54,6 +56,7 @@ import java.util.stream.Stream; * @author guofeihu * @since 2024-07-03 */ +@Slf4j @Service @RequiredArgsConstructor public class PortableOfflLogServiceImpl extends ServiceImpl implements IPortableOfflLogService { @@ -112,7 +115,7 @@ public class PortableOfflLogServiceImpl extends ServiceImpl 也即:该文件夹下所有解析的文件对应的结果集 List response = (List) obj; //临时记录下cfg结果集(用作log绑定对应的cfg波形文件) - if(OfflineConstant.LOG.equals(dictData.getCode())){ + if(OfflineConstant.COMTRADE.equals(dictData.getCode())){ cfgResponse.addAll(response); } responses.addAll(response); @@ -163,7 +166,8 @@ public class PortableOfflLogServiceImpl extends ServiceImpl= 0) { + if ((sing!= null && sing.getTimeStart()!= null && sing.getTimeEnd() !=null && sing.getTimeTrigger().compareTo(date) <= 0 && sing.getTimeEnd().compareTo(date) >= 0)) { for(MultipartFile f : uploadDataParam.getFiles()){ - String cfg = res.getFilename(); - String dat = cfg.substring(0,cfg.lastIndexOf("."))+OfflineConstant.CFG; - String sharPath = OfflineConstant.COMTRADE+"/"+DataParam.wlRecordPath+uploadDataParam.getDevId()+"/"+uploadDataParam.getLineId()+"/"+getFolderName()+"/"; if(f.getOriginalFilename().equals(cfg) || f.getOriginalFilename().equals(dat)){ fileStorageUtil.uploadMultipart(f, sharPath); wavePath = sharPath; @@ -254,6 +258,8 @@ public class PortableOfflLogServiceImpl extends ServiceImpl saveBatchEventList(@RequestBody List csEventPOS) {