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 deleted file mode 100644 index 9edae46..0000000 --- a/cloud-rule-engine/src/main/java/com/muyu/compile/CloudRulesServiceImpl.java +++ /dev/null @@ -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 ""; -// } -// -//}