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();
|
// }
|
// }
|
// }
|
// }
|
}
|
