feat():测试
parent
6310f615fd
commit
82ef32e43c
|
|
@ -1,188 +0,0 @@
|
|||
//package com.muyu.etl.rule.service.impl;
|
||||
//
|
||||
//import com.aliyun.oss.OSS;
|
||||
//import com.aliyun.oss.OSSClientBuilder;
|
||||
//import com.aliyun.oss.model.GetObjectRequest;
|
||||
//import com.aliyun.oss.model.OSSObject;
|
||||
//import com.aliyun.oss.model.PutObjectRequest;
|
||||
//import com.muyu.common.core.domain.Result;
|
||||
//import com.muyu.etl.rule.complie.SourceCodeCompiler;
|
||||
//import com.muyu.etl.rule.service.ICloudRulesService;
|
||||
//import com.muyu.etl.util.OSSClientConfig;
|
||||
//import lombok.extern.log4j.Log4j2;
|
||||
//import org.springframework.stereotype.Service;
|
||||
//
|
||||
//import java.io.*;
|
||||
//import java.nio.charset.StandardCharsets;
|
||||
//
|
||||
///**
|
||||
// * @Author：liuxinyue
|
||||
// * @Package：com.muyu.dataClean.service.impl
|
||||
// * @Project：cloud-etl-rules
|
||||
// * @name：CloudRulesServiceImpl
|
||||
// * @Date：2024/8/26 14:44
|
||||
// */
|
||||
//@Service
|
||||
//@Log4j2
|
||||
//public class CloudRulesServiceImpl implements ICloudRulesService {
|
||||
//
|
||||
//
|
||||
// /**
|
||||
// * 方法名称
|
||||
// */
|
||||
// public static String Method = "desensitizePhoneNumber";
|
||||
//
|
||||
// /**
|
||||
// * 包名称
|
||||
// */
|
||||
// public static String pack = "com.muyu.etl.rule.store";
|
||||
//
|
||||
//
|
||||
// /**
|
||||
// * 上传文件到oss中
|
||||
// * @param content
|
||||
// * @param fileName
|
||||
// * @return
|
||||
// */
|
||||
// @Override
|
||||
// public void uploadFiles(String content,String fileName) {
|
||||
//
|
||||
//
|
||||
// String endPoint = "oss-cn-shanghai.aliyuncs.com";
|
||||
//
|
||||
// String accessKeyId = "LTAI5tAaKm2qAT3Yg7i8tcrv";
|
||||
//
|
||||
// String accessKeySecret = "MoKEft9RWETLnNmMewmyfbXsZJpDkr";
|
||||
//
|
||||
// String bucketName = "liuyibo123";
|
||||
//
|
||||
//
|
||||
// String location ="/home/"+fileName+".java";
|
||||
//
|
||||
// OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);
|
||||
//
|
||||
// // 你的Bucket名称
|
||||
// // 上传到OSS后文件保存的目录，例如：folder/subfolder/，最后以斜杠结尾
|
||||
// String objectName = "number/yueliang/"+fileName+".java";
|
||||
//
|
||||
// try {
|
||||
// // 将内容转换为字节数组输入流
|
||||
// ByteArrayInputStream inputStream = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
|
||||
//
|
||||
// // 构造上传请求
|
||||
// PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
|
||||
//
|
||||
// // 执行上传操作
|
||||
// ossClient.putObject(putObjectRequest);
|
||||
//
|
||||
// log.info("文件"+fileName+".java"+"存储成功");
|
||||
//
|
||||
// } catch (Exception e) {
|
||||
// e.printStackTrace();
|
||||
//
|
||||
// log.info("文件"+fileName+".java"+"存储失败");
|
||||
// }
|
||||
//
|
||||
// //取出OSS文件上传到服务器程序内部
|
||||
//
|
||||
// try {
|
||||
// // 从OSS下载文件
|
||||
// InputStream inputStream = ossClient.getObject(bucketName, objectName).getObjectContent();
|
||||
// File downloadFile = new File(location);
|
||||
// FileOutputStream outputStream = new FileOutputStream(downloadFile);
|
||||
//
|
||||
// byte[] buffer = new byte[1024];
|
||||
// int len;
|
||||
// while ((len = inputStream.read(buffer)) != -1) {
|
||||
// outputStream.write(buffer, 0, len);
|
||||
// }
|
||||
// outputStream.close();
|
||||
// inputStream.close();
|
||||
//
|
||||
// System.out.println("存放路径:" + location);
|
||||
// } catch (Exception e) {
|
||||
// e.printStackTrace();
|
||||
// } finally {
|
||||
// // 关闭OSSClient
|
||||
// if (ossClient != null) {
|
||||
// ossClient.shutdown();
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// //对路径里的.java文件进行编译
|
||||
// SourceCodeCompiler.javaCompilerPath("/home");
|
||||
// System.out.println("第一步");
|
||||
// File outputDir = new File("/home"); // 或者是你指定的其他输出目录
|
||||
// System.out.println("第一步");
|
||||
// File[] classFiles = outputDir.listFiles(); // 获取输出目录中的所有文件
|
||||
// System.out.println("第三步");
|
||||
// if (classFiles != null) {
|
||||
// for (File classFile : classFiles) {
|
||||
// if (classFile.getName().endsWith(".class")) {
|
||||
// // 这里可以处理每个.class文件，例如读取、复制或移动
|
||||
// System.out.println("找到class文件 " + classFile.getName());
|
||||
// }
|
||||
// }
|
||||
// //把.class文件存入oss中
|
||||
// }else {
|
||||
// System.out.println("没有找到文件");
|
||||
// }
|
||||
// }
|
||||
//
|
||||
//
|
||||
//
|
||||
// /**
|
||||
// * 根据文件名读取指定的.java名称
|
||||
// *
|
||||
// * @param fileName 参数
|
||||
// * @return 结果
|
||||
// */
|
||||
// @Override
|
||||
// public Result readFile(String fileName) {
|
||||
//
|
||||
// String bucketName = "liuyibo123";
|
||||
// String objectName = "number/yueliange/"+fileName+".java";
|
||||
// OSS ossClient = OSSClientConfig.getOSSClient();
|
||||
// String filePath="C:\\Users\\86176\\Desktop\\测试";
|
||||
//
|
||||
// File file = new File(filePath);
|
||||
//
|
||||
// // 判断文件是否存在
|
||||
// if (!file.exists()) {
|
||||
// // 如果文件不存在，则创建新文件
|
||||
// try {
|
||||
// boolean isCreated = file.createNewFile();
|
||||
// if (isCreated) {
|
||||
// System.out.println("文件创建成功：" + filePath);
|
||||
// } else {
|
||||
// System.out.println("文件创建失败，可能由于权限问题或路径错误。");
|
||||
// }
|
||||
// } catch (IOException e) {
|
||||
// e.printStackTrace();
|
||||
// System.out.println("文件创建时发生错误：" + e.getMessage());
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// try {
|
||||
// // 调用getObject方法下载文件。
|
||||
// ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(filePath));
|
||||
//
|
||||
// return Result.success(null,fileName+".java文件下载成功");
|
||||
// } catch (Exception e) {
|
||||
// e.printStackTrace();
|
||||
// return Result.success(null,fileName+".java文件下载失败");
|
||||
// } finally {
|
||||
// // 关闭OSSClient。
|
||||
// if (ossClient != null) {
|
||||
// ossClient.shutdown();
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public String readRuleType(String fileName) {
|
||||
// return "";
|
||||
// }
|
||||
//
|
||||
//}
|
||||
Loading…
Reference in New Issue