假期作业

HomeWork-modules/HomeWork-MedicalTreatment/pom.xml

@@ -13,23 +13,6 @@
 
     <dependencies>
 
-        <!-- https://mvnrepository.com/artifact/io.minio/minio -->
-        <dependency>
-            <groupId>io.minio</groupId>
-            <artifactId>minio</artifactId>
-            <version>8.5.2</version>
-        </dependency>
-        <dependency>
-            <groupId>org.glassfish</groupId>
-            <artifactId>javax.json</artifactId>
-            <version>1.0.4</version>
-            <scope>compile</scope>
-        </dependency>
-        <dependency>
-            <groupId>net.srt</groupId>
-            <artifactId>flink-app-1.14</artifactId>
-            <version>2.0.0</version>
-        </dependency>
 
         <dependency>
             <groupId>commons-io</groupId>

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<List<UnitVo>> unit(@RequestParam("id") String id) {
+        List<UnitVo> treeVos= treeService.unitListById(id);
+        return R.ok(treeVos);
+    }
+
 }

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;
+}

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;
+}

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<FloorEntity> floorEntities;
+}

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<TreeEntity> treeByParentId(Integer parentId);
 
+    List<UnitEntity> UnitListById(String id);
+
+    List<FloorEntity> floorById(Integer id);
 }

HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioConfig.java

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

HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioProperties.java

@@ -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;
-
-
-}
-

HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/MinioUtil.java

@@ -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<Bucket> getAllBuckets() throws Exception {
-//        return minioClient.listBuckets();
-//    }
-//
-//    /**
-//     * 根据bucketName获取信息
-//     *
-//     * @param bucketName bucket名称
-//     */
-////    public Optional<Bucket> 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);
-//    }
-//}
-//
-//

HomeWork-modules/HomeWork-MedicalTreatment/src/main/java/HomeWork/minio/UploadResponse.java

@@ -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;
-}
-

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<TreeVo> treeListByTreeParentId(Integer parentId);
 
     R file(MultipartFile file);
+
+    List<UnitVo> unitListById(String id);
+
 }

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<UnitVo> unitListById(String id) {
+        return null;
+    }
+
     @Override
     public List<TreeVo> treeList() {
         ArrayList<TreeVo> treeVos = new ArrayList<>();
@@ -113,6 +121,4 @@ public class TreeServiceImpl implements TreeService {
         }
         return treeVos;
     }
-
-
 }

HomeWork-modules/HomeWork-MedicalTreatment/src/main/resources/mapper/TreeMapper.xml

@@ -43,4 +43,10 @@
     <select id="treeByParentId" resultType="HomeWork.domain.TreeEntity">
         select * from tree where parent_id = #{parentId}
     </select>
+    <select id="UnitListById" resultType="HomeWork.domain.UnitEntity">
+        select * from unit where village_code = #{id}
+    </select>
+    <select id="floorById" resultType="HomeWork.domain.FloorEntity">
+        select * from floor where village_code = #{id}
+    </select>
 </mapper>

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

HomeWork-modules/HomeWork-es/pom.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>HomeWork</groupId>
+        <artifactId>HomeWork-modules</artifactId>
+        <version>3.6.3</version>
+    </parent>
+
+    <artifactId>HomeWork-es</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

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!");
+    }
+}

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

HomeWork-modules/HomeWork-kafka/pom.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>HomeWork</groupId>
+        <artifactId>HomeWork-modules</artifactId>
+        <version>3.6.3</version>
+    </parent>
+
+    <artifactId>HomeWork-kafka</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

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!");
+    }
+}

HomeWork-modules/pom.xml

@@ -14,6 +14,8 @@
         <module>HomeWork-job</module>
         <module>HomeWork-file</module>
         <module>HomeWork-MedicalTreatment</module>
+        <module>HomeWork-kafka</module>
+        <module>HomeWork-es</module>
     </modules>
 
     <artifactId>HomeWork-modules</artifactId>