package com.lxzn.base.service.impl;
|
|
import com.lxzn.base.service.IReceiveFileService;
|
import com.lxzn.base.service.ISingleDictionaryService;
|
import com.lxzn.framework.domain.base.SingleDictionary;
|
import com.lxzn.framework.domain.base.ext.NcTxtFilePathInfo;
|
import com.lxzn.framework.utils.date.DateUtil;
|
import com.lxzn.framework.utils.file.FileUtil;
|
import com.lxzn.nc.service.IDocInfoService;
|
import org.apache.commons.lang3.StringUtils;
|
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.springframework.stereotype.Service;
|
|
import java.io.*;
|
import java.util.Scanner;
|
|
/**
|
* @author clown
|
* * @date 2023/12/15
|
*/
|
@Service
|
@PropertySource("classpath:/scheduled.properties")
|
public class ReceiveFileServiceImpl implements IReceiveFileService {
|
|
@Autowired
|
private IDocInfoService docInfoService;
|
@Autowired
|
private ISingleDictionaryService dictionaryService;
|
@Value("${serviceIntranet.filePath}")
|
private String filePath;
|
|
@Value("${serviceIntranet.newFilePath}")
|
private String newFilePath;
|
@Value("${fileNCPath}")
|
private String fileNCPath;
|
|
@Override
|
@Scheduled(cron = "${ncFileRec}")
|
public void analysisAndCopyFileRec() {
|
if (StringUtils.isBlank(filePath)) {
|
return;
|
}
|
File f3 = new File(filePath);
|
File[] files = f3.listFiles();
|
for (File fi : files){
|
InputStreamReader input =null;
|
BufferedReader bufferedReader =null;
|
String loFilePath = filePath + fi.getName();
|
System.out.println(loFilePath);
|
try {
|
if (FileUtil.getFileSuffix(fi.getName()).equals("nc")) {
|
String line;
|
int count = 0;
|
NcTxtFilePathInfo result = new NcTxtFilePathInfo();
|
FileInputStream fis = null;
|
try {
|
fis = new FileInputStream(loFilePath);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
Scanner sc = new Scanner(fis, "UTF-8");
|
while (count < 8 && sc.hasNext()) {
|
line = sc.nextLine();
|
if (count ==0) {
|
result.setFileTxtName(line.trim());
|
} else if (count ==1) {
|
result.setFileNcName(line.trim());
|
}else if (count ==2) {
|
result.setOrigFileName(line.trim());
|
}else if (count ==3) {
|
result.setOrigFileSuffix(line.trim());
|
}else if (count ==4) {
|
result.setFilePath(line.trim());
|
}else if (count ==5) {
|
result.setEquipmentId(line.trim());
|
}else if (count ==6) {
|
result.setFileAddOrDelete(Integer.valueOf(line.trim()));
|
}else if (count == 7) {
|
result.setFileSize(line.trim());
|
}
|
count++;
|
}
|
if (sc != null) {
|
sc.close();
|
}
|
if (bufferedReader != null) {
|
bufferedReader.close();
|
}
|
if (input != null) {
|
input.close();
|
}
|
if (result == null) {
|
continue;
|
}
|
if (result.getFileAddOrDelete() != null ) {
|
if ( result.getFileAddOrDelete()==1) {
|
String path = "";
|
SingleDictionary singleDictionary=dictionaryService.findListFromTypeCode("virtual_equipment_id").get(0);
|
String docEquipmentId = null;
|
if (singleDictionary != null) {
|
docEquipmentId= String.valueOf(singleDictionary.getDicValue());
|
}
|
if (result.getEquipmentId().equals(docEquipmentId)) {
|
//虚拟设备处理
|
path = filePath + result.getOrigFileName();
|
if (StringUtils.isNotBlank(result.getOrigFileName()) &&
|
result.getOrigFileName().equals("null")) {
|
//文件待处理
|
//备份数据
|
FileUtil.deleteFileNewRec(loFilePath);
|
continue;
|
}
|
}else {
|
path = filePath + result.getFileNcName()+ ".NC";
|
if (StringUtils.isNotBlank(result.getFileNcName()) &&
|
result.getFileNcName().equals("null")) {
|
//文件待处理
|
//备份数据
|
FileUtil.deleteFileNewRec(loFilePath);
|
continue;
|
}
|
}
|
File ncFile = new File(path);
|
if (ncFile == null) {
|
continue;
|
} else {
|
//已经存在文件需要备份
|
String size = String.valueOf(ncFile.length());
|
if (!size.equals(result.getFileSize())) {
|
continue;
|
}
|
|
boolean bool = docInfoService.addDocInfoRecService(result.getEquipmentId(),
|
ncFile,result.getOrigFileSuffix(),
|
FileUtil.getFilenameNonSuffix(result.getOrigFileName())
|
,result.getFilePath());
|
if (bool) {
|
FileUtil.deleteFileNewRec(path);
|
FileUtil.deleteFileNewRec(loFilePath);
|
}
|
}
|
} else {
|
String path;
|
/*if(StringUtils.isBlank(result.getOrigFileSuffix())) {
|
path = fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName();
|
} else {
|
path = fileNCPath + "/" + result.getFilePath() + "/send/" +result.getOrigFileName()+ "." + result.getOrigFileSuffix();
|
}*/
|
|
/*File ncFile = new File(path);*/
|
/*if (ncFile == null) {
|
return;
|
} else {
|
//待优化
|
boolean deleteFile = FileUtil.copyFileNcToBak(result.getFilePath(),
|
result.getOrigFileName(), result.getOrigFileSuffix());
|
FileUtil.deleteFile(path);
|
FileUtil.deleteFile(loFilePath);
|
}*/
|
}
|
|
}
|
}
|
} catch (Exception e1) {
|
try {
|
if (bufferedReader != null) {
|
bufferedReader.close();
|
}
|
if (input != null) {
|
input.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
e1.printStackTrace();
|
} finally {
|
try {
|
if (bufferedReader != null) {
|
bufferedReader.close();
|
}
|
if (input != null) {
|
input.close();
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
}
|
