From 6e5d889954701d4fc5d73d8ec2554ecba6b43f7d Mon Sep 17 00:00:00 2001 From: DB <2502523450@qq.com> Date: Thu, 30 Nov 2023 08:59:07 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B7=A5=E5=8D=95=E9=87=8D=E6=9E=84,=E5=AF=BC?= =?UTF-8?q?=E5=85=A5=E5=93=81=E7=89=8C=E4=B8=8E=E6=A0=A1=E5=8C=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/cpop/oam/web/CpopImportTests.java | 102 ++++++++++++++++++ .../oam/business/bo/TaskWorkOrderPageBo.java | 40 ------- .../dto/TaskWorkOrderReceiveDealPauseDto.java | 7 ++ .../com/cpop/oam/business/vo/StoreListVo.java | 7 ++ .../vo/TaskWorkOrderReceiveDealPauseVo.java | 7 ++ 5 files changed, 123 insertions(+), 40 deletions(-) create mode 100644 Cpop-Oam/Cpop-Oam-Web/src/test/java/com/cpop/oam/web/CpopImportTests.java delete mode 100644 Cpop-Oam/src/main/java/com/cpop/oam/business/bo/TaskWorkOrderPageBo.java create mode 100644 Cpop-Oam/src/main/java/com/cpop/oam/business/dto/TaskWorkOrderReceiveDealPauseDto.java create mode 100644 Cpop-Oam/src/main/java/com/cpop/oam/business/vo/StoreListVo.java create mode 100644 Cpop-Oam/src/main/java/com/cpop/oam/business/vo/TaskWorkOrderReceiveDealPauseVo.java diff --git a/Cpop-Oam/Cpop-Oam-Web/src/test/java/com/cpop/oam/web/CpopImportTests.java b/Cpop-Oam/Cpop-Oam-Web/src/test/java/com/cpop/oam/web/CpopImportTests.java new file mode 100644 index 0000000..1e5ed8c --- /dev/null +++ b/Cpop-Oam/Cpop-Oam-Web/src/test/java/com/cpop/oam/web/CpopImportTests.java @@ -0,0 +1,102 @@ +package com.cpop.oam.web; + +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.annotation.JSONField; +import lombok.Data; +import lombok.extern.slf4j.Slf4j; +import org.junit.jupiter.api.Test; +import org.springframework.boot.test.context.SpringBootTest; + +import java.io.*; +import java.util.ArrayList; +import java.util.List; +import java.util.stream.Collectors; + +/** + * @author DB + * @createTime 2023/11/27 17:24 + * @description 导入数据 + */ +@SpringBootTest +@Slf4j +public class CpopImportTests { + + /** + * @descriptions 导入品牌 + * @author DB + * @date 2023/11/27 17:26 + * @return: void + */ + @Test + public void importBrandJson() throws IOException { + String brandFileUrl = ""; + List filterList = new ArrayList<>(); + filterList.add("b00064a760d0c4f121b0835d09b909ca"); + filterList.add("ac1268b164d1d20700080aae1703ecf8"); + filterList.add("0122a5876468513f0d42569d389e8264"); + List jsonBrands = JSONArray.parseArray(readJson(brandFileUrl), JsonBrand.class); + //过滤已存在的品牌 + List filterBrand = jsonBrands.stream().filter(item -> !filterList.contains(item.getBrandCloudId())).collect(Collectors.toList()); + //打印 + filterBrand.forEach(item -> { + log.info("品牌信息:{}", item.toString()); + }); + } + + /** + * @descriptions 导入校区 + * @author DB + * @date 2023/11/27 17:26 + * @return: void + */ + @Test + public void importStoreJson() { + + + } + + /** + * json格式品牌 + */ + @Data + private class JsonBrand implements Serializable{ + + /** + * 品牌名 + */ + @JSONField(name = "") + private String brandName; + + /** + * 云品牌id + */ + @JSONField(name = "") + private String brandCloudId; + + } + + /** + * 读取json文件数据 + * + * @param jsonPath json文件路径 + * @return 字符串 + */ + public String readJson(String jsonPath) throws IOException { + File jsonFile = new File(jsonPath); + FileReader fileReader = new FileReader(jsonFile); + BufferedReader reader = new BufferedReader(fileReader); + StringBuilder sb = new StringBuilder(); + while (true) { + int ch = reader.read(); + if (ch != -1) { + sb.append((char) ch); + } else { + break; + } + } + fileReader.close(); + reader.close(); + return sb.toString(); + } + +} diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/TaskWorkOrderPageBo.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/TaskWorkOrderPageBo.java deleted file mode 100644 index 4df78ad..0000000 --- a/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/TaskWorkOrderPageBo.java +++ /dev/null @@ -1,40 +0,0 @@ -package com.cpop.oam.business.bo; - -import io.swagger.annotations.ApiModel; -import io.swagger.annotations.ApiModelProperty; -import lombok.Data; -import lombok.experimental.Accessors; - -import java.io.Serializable; -import java.util.List; - -/** - * @author: DB - * @Date: 2023/07/10/14:14 - * @Description: - */ -@Data -@Accessors(chain = true) -@ApiModel(value = "TaskWorkOrder对象", description = "任务-工单表") -public class TaskWorkOrderPageBo implements Serializable { - - private static final long serialVersionUID = 1L; - - /** - * 校区id - */ - @ApiModelProperty("校区id") - private String campusName; - - /** - * 任务名 - */ - @ApiModelProperty("任务名") - private String taskName; - - /** - * 任务状态 - */ - @ApiModelProperty("任务状态") - private List taskStatus; -} diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/dto/TaskWorkOrderReceiveDealPauseDto.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/dto/TaskWorkOrderReceiveDealPauseDto.java new file mode 100644 index 0000000..bc79133 --- /dev/null +++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/dto/TaskWorkOrderReceiveDealPauseDto.java @@ -0,0 +1,7 @@ +package com.cpop.oam.business.dto;/** + * @author DB + * @createTime 2023/11/28 15:42 + * @description + */ +public class TaskWorkOrderReceiveDealPauseDto { +} diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/StoreListVo.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/StoreListVo.java new file mode 100644 index 0000000..60e1936 --- /dev/null +++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/StoreListVo.java @@ -0,0 +1,7 @@ +package com.cpop.oam.business.vo;/** + * @author DB + * @createTime 2023/11/28 12:35 + * @description + */ +public class StoreListVo { +} diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/TaskWorkOrderReceiveDealPauseVo.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/TaskWorkOrderReceiveDealPauseVo.java new file mode 100644 index 0000000..611c34a --- /dev/null +++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/TaskWorkOrderReceiveDealPauseVo.java @@ -0,0 +1,7 @@ +package com.cpop.oam.business.vo;/** + * @author DB + * @createTime 2023/11/28 15:08 + * @description + */ +public class TaskWorkOrderReceiveDealPauseVo { +}