From f6cf5fc685fb841a0bfbc4001d3b0721d70bae88 Mon Sep 17 00:00:00 2001 From: chenbingxuan <3581044601@qq.com> Date: Wed, 7 Feb 2024 13:28:27 +0800 Subject: [PATCH] =?UTF-8?q?=E5=81=87=E6=9C=9F=E4=BD=9C=E4=B8=9A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../HomeWork-MedicalTreatment/pom.xml | 17 -- .../HomeWork/controller/TreeController.java | 7 + .../java/HomeWork/domain/FloorEntity.java | 21 ++ .../main/java/HomeWork/domain/UnitEntity.java | 11 + .../main/java/HomeWork/domain/vo/UnitVo.java | 15 ++ .../main/java/HomeWork/mapper/TreeMapper.java | 6 + .../main/java/HomeWork/minio/MinioConfig.java | 30 --- .../java/HomeWork/minio/MinioProperties.java | 36 --- .../main/java/HomeWork/minio/MinioUtil.java | 221 ------------------ .../java/HomeWork/minio/UploadResponse.java | 21 -- .../java/HomeWork/service/TreeService.java | 4 + .../service/impl/TreeServiceImpl.java | 10 +- .../src/main/resources/mapper/TreeMapper.xml | 6 + HomeWork-modules/HomeWork-es/.gitignore | 38 +++ HomeWork-modules/HomeWork-es/pom.xml | 20 ++ .../src/main/java/HomeWork/Main.java | 7 + HomeWork-modules/HomeWork-kafka/.gitignore | 38 +++ HomeWork-modules/HomeWork-kafka/pom.xml | 20 ++ .../src/main/java/HomeWork/Main.java | 7 + HomeWork-modules/pom.xml | 2 + 20 files changed, 210 insertions(+), 327 deletions(-) create mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/FloorEntity.java create mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/UnitEntity.java create mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/vo/UnitVo.java delete mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioConfig.java delete mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioProperties.java delete mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioUtil.java delete mode 100644 HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/UploadResponse.java create mode 100644 HomeWork-modules/HomeWork-es/.gitignore create mode 100644 HomeWork-modules/HomeWork-es/pom.xml create mode 100644 HomeWork-modules/HomeWork-es/src/main/java/HomeWork/Main.java create mode 100644 HomeWork-modules/HomeWork-kafka/.gitignore create mode 100644 HomeWork-modules/HomeWork-kafka/pom.xml create mode 100644 HomeWork-modules/HomeWork-kafka/src/main/java/HomeWork/Main.java diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/pom.xml b/HomeWork-modules/HomeWork-MedicalTreatment/pom.xml index f3135ec..592139a 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/pom.xml +++ b/HomeWork-modules/HomeWork-MedicalTreatment/pom.xml @@ -13,23 +13,6 @@ - - - io.minio - minio - 8.5.2 - - - org.glassfish - javax.json - 1.0.4 - compile - - - net.srt - flink-app-1.14 - 2.0.0 - commons-io diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/controller/TreeController.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/controller/TreeController.java index a6814a9..cbf94c5 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/controller/TreeController.java +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/controller/TreeController.java @@ -4,6 +4,7 @@ import HomeWork.common.core.domain.R; import HomeWork.domain.dto.PlotDto; import HomeWork.domain.vo.PlotVo; import HomeWork.domain.vo.TreeVo; +import HomeWork.domain.vo.UnitVo; import HomeWork.service.TreeService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -45,4 +46,10 @@ public class TreeController { return R.ok(treeService.file(file)); } + @PostMapping("/unit") + public R> unit(@RequestParam("id") String id) { + List treeVos= treeService.unitListById(id); + return R.ok(treeVos); + } + } diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/FloorEntity.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/FloorEntity.java new file mode 100644 index 0000000..e716f58 --- /dev/null +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/FloorEntity.java @@ -0,0 +1,21 @@ +package HomeWork.domain; + +import lombok.Data; + +import java.util.Date; + +@Data +public class FloorEntity { + private Integer id; + private String villageCode; + private Integer buildingNo; + private Integer unitNo; + private String floor; + private Integer houseNo; + private String houseName; + private String type; + private String typeDesc; + private Date rowTime; + private Date mrowTime; + private String realPeopleCounts; +} diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/UnitEntity.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/UnitEntity.java new file mode 100644 index 0000000..74ef3cf --- /dev/null +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/UnitEntity.java @@ -0,0 +1,11 @@ +package HomeWork.domain; + +import lombok.Data; + +@Data +public class UnitEntity { + private Integer id; + private String unitNo; + private String unitOrder; + private String villageCode; +} diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/vo/UnitVo.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/vo/UnitVo.java new file mode 100644 index 0000000..f8223ee --- /dev/null +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/domain/vo/UnitVo.java @@ -0,0 +1,15 @@ +package HomeWork.domain.vo; + +import HomeWork.domain.FloorEntity; +import lombok.Data; + +import java.util.List; + +@Data +public class UnitVo { + private Integer id; + private String unitNo; + private String unitOrder; + private String villageCode; + private List floorEntities; +} diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/mapper/TreeMapper.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/mapper/TreeMapper.java index 5124990..b131345 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/mapper/TreeMapper.java +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/mapper/TreeMapper.java @@ -1,9 +1,12 @@ package HomeWork.mapper; +import HomeWork.domain.FloorEntity; import HomeWork.domain.TreeEntity; +import HomeWork.domain.UnitEntity; import HomeWork.domain.dto.PlotDto; import HomeWork.domain.vo.PlotVo; import HomeWork.domain.vo.TreeVo; +import HomeWork.domain.vo.UnitVo; import com.baomidou.dynamic.datasource.annotation.DS; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -31,4 +34,7 @@ public interface TreeMapper { List treeByParentId(Integer parentId); + List UnitListById(String id); + + List floorById(Integer id); } diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioConfig.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioConfig.java deleted file mode 100644 index c80cb6a..0000000 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioConfig.java +++ /dev/null @@ -1,30 +0,0 @@ -package HomeWork.minio; - -import io.minio.MinioClient; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.context.properties.EnableConfigurationProperties; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - * @ClassName MinioConfig - * @Description 描述 - * @Author 栗永斌 - */ -@Configuration -@EnableConfigurationProperties(MinioProperties.class) -public class MinioConfig { - - @Autowired - private MinioProperties minioProperties; - - @Bean - public MinioClient minioClient(){ - return MinioClient.builder() - .endpoint(minioProperties.getEndpoint()) - .credentials(minioProperties.getAccessKey(),minioProperties.getSecretKey()) - .build(); - } -} - - diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioProperties.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioProperties.java deleted file mode 100644 index effe421..0000000 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioProperties.java +++ /dev/null @@ -1,36 +0,0 @@ -package HomeWork.minio; - -import lombok.Data; -import org.springframework.boot.context.properties.ConfigurationProperties; -import org.springframework.stereotype.Component; - -/** - * @ClassName MinioProperties - * @Description 描述 - * @Author 栗永斌 - */ -@ConfigurationProperties(prefix = "minio") -@Component -@Data -public class MinioProperties { - - /** - * 连接地址 - */ - private String endpoint; - /** - * 用户名 - */ - private String accessKey; - /** - * 密码 - */ - private String secretKey; - /** - * 域名 - */ - private String nginxHost; - - -} - diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioUtil.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioUtil.java deleted file mode 100644 index 1785070..0000000 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioUtil.java +++ /dev/null @@ -1,221 +0,0 @@ -//package HomeWork.minio; -// -//import cn.hutool.core.date.DateUtil; -//import io.minio.*; -// -//import io.minio.messages.Bucket; -//import lombok.extern.slf4j.Slf4j; -//import org.apache.commons.fileupload.FileItem; -//import org.apache.commons.fileupload.FileItemFactory; -//import org.apache.commons.fileupload.disk.DiskFileItemFactory; -//import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.stereotype.Component; -//import org.springframework.web.multipart.MultipartFile; -//import org.springframework.web.multipart.commons.CommonsMultipartFile; -// -//import java.io.InputStream; -//import java.io.OutputStream; -// -//import java.util.List; -//import java.util.Random; -// -///** -// * @ClassName MinioUtil -// * @Description 描述 -// * @Author 栗永斌 -// */ -//@Component -//@Slf4j -//public class MinioUtil { -// -// @Autowired -// private MinioProperties minioProperties; -// -// @Autowired -// private MinioClient minioClient; -// -// private final Long maxSize = (long) (1024 * 1024); -// -// /** -// * 创建bucket -// */ -// public void createBucket(String bucketName) throws Exception { -// if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) { -// minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build()); -// } -// } -// -// /** -// * 上传文件 -// */ -// public UploadResponse uploadFile(MultipartFile file, String bucketName) throws Exception { -// //判断文件是否为空 -// if (null == file || 0 == file.getSize()) { -// return null; -// } -// //判断存储桶是否存在 不存在则创建 -// createBucket(bucketName); -// //文件名 -// String originalFilename = file.getOriginalFilename(); -// //新的文件名 = 时间戳_随机数.后缀名 -// assert originalFilename != null; -// long now = System.currentTimeMillis() / 1000; -// String fileName = DateUtil.format(DateUtil.date(),"yyyyMMdd")+"_"+ now + "_" + new Random().nextInt(1000) + -// originalFilename.substring(originalFilename.lastIndexOf(".")); -// //开始上传 -// log.info("file压缩前大小:{}",file.getSize()); -// if (file.getSize() > maxSize) { -// FileItemFactory fileItemFactory = new DiskFileItemFactory(); -// FileItem fileItem = fileItemFactory.createItem(fileName, "text/plain", true, fileName); -// OutputStream outputStream = fileItem.getOutputStream(); -// Thumbnails.of(file.getInputStream()).scale(1f).outputFormat(originalFilename.substring(originalFilename.lastIndexOf(".")+1)).outputQuality(0.25f).toOutputStream(outputStream); -// file = new CommonsMultipartFile(fileItem); -// } -// log.info("file压缩后大小:{}",file.getSize()); -// minioClient.putObject( -// PutObjectArgs.builder().bucket(bucketName).object(fileName).stream( -// file.getInputStream(), file.getSize(), -1) -// .contentType(file.getContentType()) -// .build()); -// String url = minioProperties.getEndpoint() + "/" + bucketName + "/" + fileName; -// String urlHost = minioProperties.getNginxHost() + "/" + bucketName + "/" + fileName; -// return new UploadResponse(url, urlHost); -// } -// -// -// /** -// * 获取全部bucket -// * -// * @return -// */ -// public List getAllBuckets() throws Exception { -// return minioClient.listBuckets(); -// } -// -// /** -// * 根据bucketName获取信息 -// * -// * @param bucketName bucket名称 -// */ -//// public Optional getBucket(String bucketName) throws IOException, InvalidKeyException, NoSuchAlgorithmException, InsufficientDataException, InvalidResponseException, InternalException, ErrorResponseException, ServerException, XmlParserException, ServerException { -//// return minioClient.listBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst(); -//// } -// -// /** -// * 根据bucketName删除信息 -// * -// * @param bucketName bucket名称 -// */ -// public void removeBucket(String bucketName) throws Exception { -// minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build()); -// } -// -// /** -// * 获取⽂件外链 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @param expires 过期时间 <=7 -// * @return url -// */ -// public String getObjectURL(String bucketName, String objectName, Integer expires) throws Exception { -// return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().bucket(bucketName).object(objectName).expiry(expires).build()); -// } -// -// /** -// * 获取⽂件 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @return ⼆进制流 -// */ -// public InputStream getObject(String bucketName, String objectName) throws Exception { -// return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(objectName).build()); -// } -// -// /** -// * 上传⽂件 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @param stream ⽂件流 -// * @throws Exception https://docs.minio.io/cn/java-minioClient-api-reference.html#putObject -// */ -// public void putObject(String bucketName, String objectName, InputStream stream) throws -// Exception { -// minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(stream, stream.available(), -1).contentType(objectName.substring(objectName.lastIndexOf("."))).build()); -// } -// -// /** -// * 上传⽂件 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @param stream ⽂件流 -// * @param size ⼤⼩ -// * @param contextType 类型 -// * @throws Exception https://docs.minio.io/cn/java-minioClient-api-reference.html#putObject -// */ -// public void putObject(String bucketName, String objectName, InputStream stream, long -// size, String contextType) throws Exception { -// minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(stream, size, -1).contentType(contextType).build()); -// } -// -// /** -// * 获取⽂件信息 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @throws Exception https://docs.minio.io/cn/java-minioClient-api-reference.html#statObject -// */ -// public StatObjectResponse getObjectInfo(String bucketName, String objectName) throws Exception { -// return minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build()); -// } -// -// /** -// * 删除⽂件 -// * -// * @param bucketName bucket名称 -// * @param objectName ⽂件名称 -// * @throws Exception https://docs.minio.io/cn/java-minioClient-apireference.html#removeObject -// */ -// public void removeObject(String bucketName, String objectName) throws Exception { -// minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(objectName).build()); -// } -// -// -// /*** -// * 上传视频 -// * @param file -// * @param bucketName -// * @return -// * @throws Exception -// */ -// public UploadResponse uploadVideo(MultipartFile file, String bucketName) throws Exception { -// //判断文件是否为空 -// if (null == file || 0 == file.getSize()) { -// return null; -// } -// //判断存储桶是否存在 不存在则创建 -// createBucket(bucketName); -// //文件名 -// String originalFilename = file.getOriginalFilename(); -// //新的文件名 = 时间戳_随机数.后缀名 -// assert originalFilename != null; -// long now = System.currentTimeMillis() / 1000; -// String fileName = DateUtil.format(DateUtil.date(),"yyyyMMdd")+"_"+ now + "_" + new Random().nextInt(1000) + -// originalFilename.substring(originalFilename.lastIndexOf(".")); -// //开始上传 -// log.info("file大小:{}",file.getSize()); -// minioClient.putObject( -// PutObjectArgs.builder().bucket(bucketName).object(fileName).stream( -// file.getInputStream(), file.getSize(), -1) -// .contentType("video/mp4") -// .build()); -// String url = minioProperties.getEndpoint() + "/" + bucketName + "/" + fileName; -// String urlHost = minioProperties.getNginxHost() + "/" + bucketName + "/" + fileName; -// return new UploadResponse(url, urlHost); -// } -//} -// -// diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/UploadResponse.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/UploadResponse.java deleted file mode 100644 index 9ca2aa4..0000000 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/UploadResponse.java +++ /dev/null @@ -1,21 +0,0 @@ -package HomeWork.minio; - -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NoArgsConstructor; - -/** - * @ClassName UploadResponse - * @Description 描述 - * @Author 栗永斌 - */ -@Data -@NoArgsConstructor -@AllArgsConstructor -public class UploadResponse { - - private String minIoUrl; - - private String nginxUrl; -} - diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/TreeService.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/TreeService.java index c335a38..ebff797 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/TreeService.java +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/TreeService.java @@ -4,6 +4,7 @@ import HomeWork.common.core.domain.R; import HomeWork.domain.dto.PlotDto; import HomeWork.domain.vo.PlotVo; import HomeWork.domain.vo.TreeVo; +import HomeWork.domain.vo.UnitVo; import org.springframework.web.multipart.MultipartFile; import java.util.List; @@ -19,4 +20,7 @@ public interface TreeService { List treeListByTreeParentId(Integer parentId); R file(MultipartFile file); + + List unitListById(String id); + } diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/impl/TreeServiceImpl.java b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/impl/TreeServiceImpl.java index 02c72c5..13f53af 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/impl/TreeServiceImpl.java +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/service/impl/TreeServiceImpl.java @@ -1,10 +1,13 @@ package HomeWork.service.impl; import HomeWork.common.core.domain.R; +import HomeWork.domain.FloorEntity; import HomeWork.domain.TreeEntity; +import HomeWork.domain.UnitEntity; import HomeWork.domain.dto.PlotDto; import HomeWork.domain.vo.PlotVo; import HomeWork.domain.vo.TreeVo; +import HomeWork.domain.vo.UnitVo; import HomeWork.mapper.TreeMapper; import HomeWork.service.TreeService; import org.springframework.beans.BeanUtils; @@ -77,6 +80,11 @@ public class TreeServiceImpl implements TreeService { return null; } + @Override + public List unitListById(String id) { + return null; + } + @Override public List treeList() { ArrayList treeVos = new ArrayList<>(); @@ -113,6 +121,4 @@ public class TreeServiceImpl implements TreeService { } return treeVos; } - - } diff --git a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/resources/mapper/TreeMapper.xml b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/resources/mapper/TreeMapper.xml index 8d98e37..a9a925d 100644 --- a/HomeWork-modules/HomeWork-MedicalTreatment/src/main/resources/mapper/TreeMapper.xml +++ b/HomeWork-modules/HomeWork-MedicalTreatment/src/main/resources/mapper/TreeMapper.xml @@ -43,4 +43,10 @@ + + diff --git a/HomeWork-modules/HomeWork-es/.gitignore b/HomeWork-modules/HomeWork-es/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/HomeWork-modules/HomeWork-es/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/HomeWork-modules/HomeWork-es/pom.xml b/HomeWork-modules/HomeWork-es/pom.xml new file mode 100644 index 0000000..5fb6bd7 --- /dev/null +++ b/HomeWork-modules/HomeWork-es/pom.xml @@ -0,0 +1,20 @@ + + + 4.0.0 + + HomeWork + HomeWork-modules + 3.6.3 + + + HomeWork-es + + + 17 + 17 + UTF-8 + + + diff --git a/HomeWork-modules/HomeWork-es/src/main/java/HomeWork/Main.java b/HomeWork-modules/HomeWork-es/src/main/java/HomeWork/Main.java new file mode 100644 index 0000000..1fb2371 --- /dev/null +++ b/HomeWork-modules/HomeWork-es/src/main/java/HomeWork/Main.java @@ -0,0 +1,7 @@ +package HomeWork; + +public class Main { + public static void main(String[] args) { + System.out.println("Hello world!"); + } +} \ No newline at end of file diff --git a/HomeWork-modules/HomeWork-kafka/.gitignore b/HomeWork-modules/HomeWork-kafka/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/HomeWork-modules/HomeWork-kafka/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/HomeWork-modules/HomeWork-kafka/pom.xml b/HomeWork-modules/HomeWork-kafka/pom.xml new file mode 100644 index 0000000..cdef7e1 --- /dev/null +++ b/HomeWork-modules/HomeWork-kafka/pom.xml @@ -0,0 +1,20 @@ + + + 4.0.0 + + HomeWork + HomeWork-modules + 3.6.3 + + + HomeWork-kafka + + + 17 + 17 + UTF-8 + + + diff --git a/HomeWork-modules/HomeWork-kafka/src/main/java/HomeWork/Main.java b/HomeWork-modules/HomeWork-kafka/src/main/java/HomeWork/Main.java new file mode 100644 index 0000000..1fb2371 --- /dev/null +++ b/HomeWork-modules/HomeWork-kafka/src/main/java/HomeWork/Main.java @@ -0,0 +1,7 @@ +package HomeWork; + +public class Main { + public static void main(String[] args) { + System.out.println("Hello world!"); + } +} \ No newline at end of file diff --git a/HomeWork-modules/pom.xml b/HomeWork-modules/pom.xml index a7dd070..c6ee353 100644 --- a/HomeWork-modules/pom.xml +++ b/HomeWork-modules/pom.xml @@ -14,6 +14,8 @@ HomeWork-job HomeWork-file HomeWork-MedicalTreatment + HomeWork-kafka + HomeWork-es HomeWork-modules