diff --git a/cloud-rule-engine/src/main/java/com/muyu/compile/CloudRulesServiceImpl.java b/cloud-rule-engine/src/main/java/com/muyu/compile/CloudRulesServiceImpl.java new file mode 100644 index 0000000..9edae46 --- /dev/null +++ b/cloud-rule-engine/src/main/java/com/muyu/compile/CloudRulesServiceImpl.java @@ -0,0 +1,188 @@ +//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 ""; +// } +// +//} diff --git a/cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java b/cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java index 434ab24..641b353 100644 --- a/cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java +++ b/cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java @@ -47,11 +47,10 @@ public class OSSFileLoad { } // 本地文件下载路径 String localPath = "home/"+fileName; - ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + fileName), new File(localPath)); - System.out.println(object); - - ossClient.shutdown(); - +// ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + fileName), new File(localPath)); +// System.out.println(object); +// +// ossClient.shutdown(); try { // 从OSS下载文件 InputStream inputStream = ossClient.getObject(bucketName, filePath+fileName).getObjectContent();