From cc0e9036de6e922e8fe254fef01d8de9996024b7 Mon Sep 17 00:00:00 2001
From: hyingbo <1363390067@qq.com>
Date: 星期四, 17 七月 2025 18:16:03 +0800
Subject: [PATCH] 获取报警描述修改
---
lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/DncPassLogServiceImpl.java | 268 -----------------------------------------------------
1 files changed, 1 insertions(+), 267 deletions(-)
diff --git a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/DncPassLogServiceImpl.java b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/DncPassLogServiceImpl.java
index c70aaea..45e0481 100644
--- a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/DncPassLogServiceImpl.java
+++ b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/DncPassLogServiceImpl.java
@@ -1,73 +1,17 @@
package org.jeecg.modules.dnc.service.impl;
-import cn.hutool.crypto.SmUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.apache.commons.lang3.StringUtils;
-import org.jeecg.common.system.vo.DictModel;
-import org.jeecg.modules.dnc.dto.SysLogTypeObjectDto;
import org.jeecg.modules.dnc.entity.DncPassLog;
import org.jeecg.modules.dnc.mapper.DncPassLogMapper;
-import org.jeecg.modules.dnc.response.SysLogMessageDto;
-import org.jeecg.modules.dnc.utils.FileClient;
-import org.jeecg.modules.dnc.utils.SyslogClient;
-import org.jeecg.modules.dnc.utils.TelnetUtil;
-import org.jeecg.modules.dnc.utils.ValidateUtil;
-import org.jeecg.modules.dnc.utils.date.DateUtil;
-import org.jeecg.modules.system.service.ISysDictItemService;
-import org.jeecg.modules.system.service.ISysDictService;
import org.jeecg.modules.dnc.service.IDncPassLogService;
-import org.jeecg.modules.dnc.utils.file.FileUtilS;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.PropertySource;
-import org.springframework.scheduling.annotation.Scheduled;
+import org.jeecg.modules.dnc.utils.ValidateUtil;
import org.springframework.stereotype.Service;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.time.Duration;
-import java.time.Instant;
-import java.util.List;
-import java.util.stream.Stream;
-
/**
* @author clown
* * @date 2023/11/29
*/
@Service
public class DncPassLogServiceImpl extends ServiceImpl<DncPassLogMapper, DncPassLog> implements IDncPassLogService {
-
- @Value("${securedoc.serverIp}")
- private String serverIp;
- @Value("${securedoc.serverPort}")
- private String serverPort;
- @Value("${securedoc.username}")
- private String usernameService;
- @Value("${securedoc.pwd}")
- private String pwdService;
- @Value("${securedoc.addressToken}")
- private String addressToken;
- @Value("${securedoc.addressUploadFile}")
- private String addressUploadFile;
- @Value("${securedoc.localFilePath}")
- private String localFilePathC;
- @Value("${securedoc.servicePath}")
- private String servicePathS;
- @Value("${securedoc.copyFilePath}")
- private String newFilePathC;
- @Value("${securedoc.logIp}")
- private String logIp;
- @Value("${securedoc.logPort}")
- private String logPort;
- @Autowired
- private ISysDictService iSysDictService;
- @Autowired
- private ISysDictItemService iSysDictItemService;
@Override
public DncPassLog findDayTime(String dateDay) {
@@ -76,214 +20,4 @@
}
return super.baseMapper.findDateTimeDay(dateDay);
}
-
- @Override
- @Scheduled(cron = "${fileCron}")
- public void fileClientTxtOrNc() {
- SysLogMessageDto message = new SysLogMessageDto();
- String host = "127.0.0.1";
- if (StringUtils.isNotBlank(serverIp)) {
- host = serverIp;
- }
- String port = "8299";
- if (StringUtils.isNotBlank(serverPort)) {
- port = serverPort;
- }
- String username = "admin";
- if (StringUtils.isNotBlank(usernameService)) {
- username = usernameService;
- }
- String pwd = "123";
- if (StringUtils.isNotBlank(pwdService)) {
- pwd = pwdService;
- }
- //鏂囦欢鏈湴鍦板潃锛屾牴鎹湴鍧�鎵惧埌鏂囦欢锛屽皢鏂囦欢瑙ｆ瀽鎴愭枃浠舵祦
- String localFilePath = "/jar/test/a/";
-// String localFilePath = "E:\\test\\a\\";
- if (StringUtils.isNotBlank(localFilePathC)) {
- localFilePath = localFilePathC;
- }
- //鏂囦欢涓婁紶鐩殑鍦板潃锛屽皢鏂囦欢涓婁紶鍒拌鍦板潃
- String servicePath = "/jar/test/b/";
-// String servicePath = "E:\\test\\b\\";
- if (StringUtils.isNotBlank(servicePathS)) {
- servicePath = servicePathS;
- }
- boolean btelnetPort = TelnetUtil.telnetPort(serverIp,Integer.valueOf(serverPort),10);
- if (!btelnetPort) {
- System.out.println("鏈嶅姟鍣ㄨ繛鎺ワ細 " + serverIp + ":" + serverPort + " 寮傚父锛�" );
- return;
- }
- //绗竴姝ワ紝鑾峰彇token
- String token = null;
- try {
- token = FileClient.getToken(host,port,username,pwd,addressToken);
- } catch (Throwable throwable) {
- throwable.printStackTrace();
- }
-
- //鑻ヨ幏鍙杢oken鎴愬姛锛屽啀杩涜涓婁紶鏂囦欢鎺ュ彛璋冪敤
- if (token !=null && !token.equals("")){
- try {
- File f3 = new File(localFilePath);
- File[] files = f3.listFiles();
- for (File fi : files){
- if (fi.isFile()){
- SysLogTypeObjectDto objectName = new SysLogTypeObjectDto();
- objectName.setDateTime(DateUtil.format(DateUtil.getNow(),DateUtil.STR_DATE_TIME_SMALL));
- objectName.setFileName(fi.getName());
- objectName.setFileSize(FileUtilS.changeFileFormatKb(String.valueOf(new File(localFilePath).length())));
- objectName.setSourceAddress(localFilePath);
- objectName.setDestination(serverIp);//鏈嶅姟绔疘P
- //椤哄簭鍙�
- DncPassLog passLog = getById("num0001");
- if (passLog == null) {
- passLog = new DncPassLog();
- passLog.setId("num0001");
- passLog.setSequenceNumber(1);
- objectName.setFileNum(Integer.toString(1));
- save(passLog);
- } else {
- Integer number = passLog.getSequenceNumber()+1;
- removeById("num0001");
- objectName.setFileNum(Integer.toString(number));
-
- passLog = new DncPassLog();
- passLog.setId("num0001");
- passLog.setSequenceNumber(number);
- save(passLog);
- }
-
- InetAddress address = null;
- try {
- address = InetAddress.getLocalHost();
- String ip = address.getHostAddress();
- objectName.setSourceAddress("20.10.17.11");//瀹㈡埛绔疘P
- objectName.setAddress(ip);
- } catch (UnknownHostException e) {
- objectName.setSourceAddress("127.0.0.1");
- objectName.setAddress("127.0.0.1");
- }
- objectName.setDestination(host);
- objectName.setResult("澶辫触");
- //鑾峰彇鏌愪釜鏂囦欢涓嬬殑鎵�鏈夋枃浠�
- String loFilePath = localFilePath + fi.getName();
- String servicePathName =servicePath + fi.getName();
-// String loFilePath = localFilePath + "\\" + fi.getName();
-// String servicePathName =servicePath + "\\" + fi.getName();
- File file = new File(loFilePath);
- if (file == null || !file.exists()){
- objectName.setAbstract1("sm3");
- } else {
- String sm3 = SmUtil.sm3(file);
- objectName.setAbstract1(sm3);
- }
-
- String b = FileClient.uploadFile(host,port,token,fi.getName(),servicePathName,loFilePath,addressUploadFile);
- //鏂囦欢澶囦唤鍒犻櫎
- if (b == null) {
- try {
- objectName.setResult("澶辫触");
- objectName.setTypes("error");
- SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
- }catch (Exception e) {
- return;
- }
- }
- else if ( b.equals("鎴愬姛")) {
- //澶囦唤鏁版嵁
- boolean fCopy = FileUtilS.copyNcFile(loFilePath,newFilePathC + "/" + DateUtil.format(DateUtil.getNow(),
- DateUtil.STR_YEARMONTHDAY) + "/" +fi.getName());
- if (fCopy) {
- FileUtilS.deleteNcFile(loFilePath);
- } else {
- FileUtilS.copyNcFile(loFilePath,newFilePathC + "/" + DateUtil.format(DateUtil.getNow(),
- DateUtil.STR_YEARMONTHDAY) + "/" +fi.getName());
- FileUtilS.deleteNcFile(loFilePath);
- }
- try {
- objectName.setTypes("Info");
- objectName.setResult("鎴愬姛");
- SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
- }catch (Exception e) {
- return;
- }
- } else {
- try {
- objectName.setResult("澶辫触");
- objectName.setTypes("error");
- SyslogClient.sendClient(logIp,Integer.valueOf(logPort),objectName.toString());
- }catch (Exception e) {
- return;
- }
- }
- }
- }
-
- } catch (Throwable throwable) {
- throwable.printStackTrace();
- }
- }
- }
-
- /**
- * 瀹氭椂浠诲姟鎵ц鍣ㄥ弬鏁� 姣忓ぉ鍑屾櫒1.30鎵ц
- */
- @Override
-// @Scheduled(cron = "0 30 1 * * ?")
- public void deleteNcSendFile() {
- Integer day;
- //鍙栧瓧鍏告椂闂�
- List<DictModel> singleDictionaries=iSysDictService.queryDictItemsByCode("DEL_TIME_SEND");
- if (singleDictionaries.size()!=1){
- return;
- }else {
- day= Integer.valueOf(singleDictionaries.get(0).getValue());
- }
- Path ncDirectory = Paths.get("jar/NC");
- //澶╄浆绉�
- long dayToSecond = day * 24 * 60 * 60;
- if (Files.exists(ncDirectory) && Files.isDirectory(ncDirectory)) {
- // 閫掑綊鏌ユ壘NC鐩綍涓嬫墍鏈夊悕涓簊end鐨勬枃浠跺す
- try (Stream<Path> sendFolders = Files.walk(ncDirectory)
- .filter(Files::isDirectory)
- .filter(path -> path.getFileName().toString().equalsIgnoreCase("send"))) {
- sendFolders.forEach(sendFolder -> {
- try {
- // 鑾峰彇褰撳墠鏃堕棿
- Instant now = Instant.now();
- // 閬嶅巻SEND鏂囦欢澶瑰唴鐨勬墍鏈夋枃浠�
- Files.walk(sendFolder)
- .filter(Files::isRegularFile)
- .forEach(file -> {
- try {
- // 鑾峰彇鏂囦欢鐨勬渶鍚庝慨鏀规椂闂�
- Instant lastModified = Files.getLastModifiedTime(file).toInstant();
- // 璁＄畻鏃堕棿宸�
- Duration duration = Duration.between(lastModified, now);
- // 鍒ゆ柇鏄惁瓒呮椂锛堟椂闂村瓨鍦ㄥ瓧鍏镐腑锛宐ase_single_dictionary锛�
- if (duration.getSeconds() > dayToSecond) {
- try {
- Files.delete(file);
- System.out.println("宸插垹闄ゆ枃浠�: " + file);
- } catch (IOException e) {
- System.err.println("鍒犻櫎鏂囦欢 " + file + " 鏃跺嚭鐜伴敊璇�: " + e.getMessage());
- }
- }
- } catch (IOException e) {
- System.err.println("鑾峰彇鏂囦欢 " + file + " 鐨勬渶鍚庝慨鏀规椂闂存椂鍑虹幇閿欒: " + e.getMessage());
- }
- });
- } catch (IOException e) {
- System.err.println("閬嶅巻 " + sendFolder + " 鏂囦欢澶规椂鍑虹幇閿欒: " + e.getMessage());
- }
- });
- } catch (IOException e) {
- System.err.println("鏌ユ壘send鏂囦欢澶规椂鍑虹幇閿欒: " + e.getMessage());
- }
- } else {
- System.err.println("jar鐨凬C鐩綍涓嶅瓨鍦ㄦ垨涓嶆槸鏈夋晥鐨勭洰褰�");
- }
- }
-
}
--
Gitblit v1.9.3