From 3bf1449635317d9490ce9dff0af5cba82b772d6b Mon Sep 17 00:00:00 2001
From: lensferno <lensferno@outlook.com>
Date: Sun, 27 Mar 2022 10:37:22 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=98=AF=E5=86=99=E5=AE=8C=E4=BA=86?=
 =?UTF-8?q?=EF=BC=9F=20=E4=B8=BB=E8=A6=81=E4=BF=AE=E6=94=B9=EF=BC=9A=20-?=
 =?UTF-8?q?=20=E4=BF=AE=E6=94=B9=E6=95=B0=E6=8D=AE=E6=96=87=E4=BB=B6?=
 =?UTF-8?q?=E8=B7=AF=E5=BE=84=E6=8C=87=E5=AE=9A=E6=96=B9=E5=BC=8F=EF=BC=88?=
 =?UTF-8?q?Tools.java=EF=BC=89=20-=20=E6=9B=B4=E6=94=B9=E9=83=A8=E5=88=86?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86=E6=96=B9=E5=BC=8F=E5=8F=8A?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF(Tools.java,=20RequestPageTooLargeException.j?=
 =?UTF-8?q?ava)=20-=20=E4=B8=BAidea=E9=85=8D=E7=BD=AE=E7=9B=B8=E5=85=B3?=
 =?UTF-8?q?=E8=BF=90=E8=A1=8C=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/runConfigurations/vegetables.xml        |  1 +
 .../vegetables/ResponseProcessor.java         | 38 +++++++++++-
 .../src/me/lensfrex/vegetables/Tools.java     | 14 ++---
 .../lensfrex/vegetables/VegetablesMain.java   | 61 +++++++++++++++++++
 .../lensfrex/vegetables/data/Vegetable.java   |  4 +-
 .../RequestPageTooLargeException.java         |  4 +-
 .../vegetables/resopnse/ResponseTool.java     |  4 +-
 .../vegetables/resopnse/UnityResponse.java    |  6 +-
 .../me/lensfrex/vegetables/utils/IOUtils.java | 28 ++++-----
 9 files changed, 126 insertions(+), 34 deletions(-)

diff --git a/.idea/runConfigurations/vegetables.xml b/.idea/runConfigurations/vegetables.xml
index 642f73d..addb653 100644
--- a/.idea/runConfigurations/vegetables.xml
+++ b/.idea/runConfigurations/vegetables.xml
@@ -4,6 +4,7 @@
     <option name="ALTERNATIVE_JRE_PATH_ENABLED" value="true" />
     <option name="MAIN_CLASS_NAME" value="me.lensfrex.vegetables.VegetablesMain" />
     <module name="vegetables" />
+    <option name="WORKING_DIRECTORY" value="./vegetables" />
     <method v="2">
       <option name="Make" enabled="true" />
       <option name="com.soywiz.korge.intellij.UpdateResourceBeforeRunTask" enabled="false" />
diff --git a/vegetables/src/me/lensfrex/vegetables/ResponseProcessor.java b/vegetables/src/me/lensfrex/vegetables/ResponseProcessor.java
index 84b3640..077a536 100644
--- a/vegetables/src/me/lensfrex/vegetables/ResponseProcessor.java
+++ b/vegetables/src/me/lensfrex/vegetables/ResponseProcessor.java
@@ -1,22 +1,56 @@
 package me.lensfrex.vegetables;
 
 import me.lensfrex.vegetables.data.Vegetable;
+import me.lensfrex.vegetables.exceptions.IllegalPageParamException;
+import me.lensfrex.vegetables.exceptions.RequestPageTooLargeException;
+import me.lensfrex.vegetables.resopnse.ResponseTool;
 import me.lensfrex.vegetables.resopnse.UnityResponse;
+import me.lensfrex.vegetables.utils.IOUtils;
 
 import java.util.ArrayList;
+import java.util.LinkedList;
 
 /**
  * 请求处理类，上层处理请求，主要为对返回数据的封装。
  * 由于功能简单，仅有处理分页数据
  */
 public class ResponseProcessor {
+
+    public final String sourceFilePath;
+
+    /**
+     * 初始化ResponseProcessor实例，并指定源数据文件的路径
+     * @param sourceFilePath 数据源文件路径
+     */
+    public ResponseProcessor(String sourceFilePath) {
+        this.sourceFilePath = sourceFilePath;
+    }
+
+    /**
+     * 从文件中读取并根据参数进行分页
+     * @param pageNum 页码（从1开始）
+     * @param pageSize 每页结果的数量
+     * @return UnityResponse<ArrayList<Vegetable>> 统一的响应类
+     */
     public UnityResponse<ArrayList<Vegetable>> getListPage(int pageNum, int pageSize) {
+        Tools tools = new Tools();
         try {
+            LinkedList<String> sourceData = IOUtils.getListFromFile(sourceFilePath);
+
+            LinkedList<Vegetable> allVegetables = tools.getAllVegetables(sourceData);
 
+            ArrayList<Vegetable> result = new ArrayList<>(tools.getListPage(pageNum, pageSize, allVegetables));
+
+            return ResponseTool.success(result, "成功");
+        } catch (RequestPageTooLargeException e) {
+            e.printStackTrace();
+            return ResponseTool.error("请求的页码超过最大值", UnityResponse.ResultCode.PAGE_OUT_OF_MAX);
+        } catch (IllegalPageParamException e) {
+            e.printStackTrace();
+            return ResponseTool.error("请求的分页参数有误", UnityResponse.ResultCode.PAGE_PARAM_WORN);
         } catch (Exception e) {
             e.printStackTrace();
+            return ResponseTool.error("未知错误", UnityResponse.ResultCode.UNKNOWN_ERROR);
         }
-
-        return null;
     }
 }
diff --git a/vegetables/src/me/lensfrex/vegetables/Tools.java b/vegetables/src/me/lensfrex/vegetables/Tools.java
index f3e7493..7c8c0e0 100644
--- a/vegetables/src/me/lensfrex/vegetables/Tools.java
+++ b/vegetables/src/me/lensfrex/vegetables/Tools.java
@@ -13,7 +13,7 @@ import java.util.List;
  */
 public class Tools {
     // 测试用路径，使用前记得改 :P
-    public static final String SOURCE_FILE_PATH = "C:\\Users\\lenfrex\\projects\\AmberGround\\vegetables\\resources\\vegetables.txt";
+    // public static final String SOURCE_FILE_PATH = "C:\\Users\\lenfrex\\projects\\AmberGround\\vegetables\\resources\\vegetables.txt";
 
     /**
      * 根据给定的页索引以及页大小，对全部蔬菜数据进行分页并返回分页后的List。
@@ -38,7 +38,7 @@ public class Tools {
 
         // 判断上一页的记录是不是已经超过最后一条记录，防止页码超过最大值
         if ((pageNum - 1)*pageSize >= resultSize) {
-            throw new RequestPageTooLargeException();
+            throw new RequestPageTooLargeException("请求页码：" + pageNum);
         }
 
         LinkedList<Vegetable> pagedVegetableList = new LinkedList<>();
@@ -52,7 +52,7 @@ public class Tools {
     /**
      * 根据数据字符串解析并获取蔬菜数据
      *
-     * @param vegetableStrings 蔬菜数据源字符串列表，字符串信息格式应为
+     * @param vegetableStrings 蔬菜数据源字符串列表，每条字符串信息格式应为
      *                         "蔬菜名 最低价 平均价 最高价 信息日期"
      *                         其中信息日期格式应为 "yyyy-mm-dd hh:mm:ss"
      * @return LinkedList<Vegetable> 解析后的蔬菜信息列表
@@ -66,12 +66,6 @@ public class Tools {
         return vegetables;
     }
 
-    private static void printMessage() {
-        System.out.println("Get data source from: " + SOURCE_FILE_PATH);
-        System.out.println("This is just for test.");
-        System.out.println("If some IO error occurred, try to change SOURCE_FILE_PATH in me.lensfrex.vegetables.Tools :P");
-    }
-
     /**
      * 解析Vegetable的信息字符串，并返回相应的蔬菜信息数据
      *
@@ -88,7 +82,7 @@ public class Tools {
         vegetable.setPrice(Double.parseDouble(spilt[1]), Vegetable.PRICE_MIN);
         vegetable.setPrice(Double.parseDouble(spilt[2]), Vegetable.PRICE_AVG);
         vegetable.setPrice(Double.parseDouble(spilt[3]), Vegetable.PRICE_MAX);
-        vegetable.setPriceDate(spilt[4] + spilt[5]);
+        vegetable.setPriceDate(spilt[4] + ' ' + spilt[5]);
 
         return vegetable;
     }
diff --git a/vegetables/src/me/lensfrex/vegetables/VegetablesMain.java b/vegetables/src/me/lensfrex/vegetables/VegetablesMain.java
index 21089ae..94fa934 100644
--- a/vegetables/src/me/lensfrex/vegetables/VegetablesMain.java
+++ b/vegetables/src/me/lensfrex/vegetables/VegetablesMain.java
@@ -1,7 +1,68 @@
 package me.lensfrex.vegetables;
 
+import me.lensfrex.vegetables.data.Vegetable;
+import me.lensfrex.vegetables.resopnse.UnityResponse;
+
+import java.util.ArrayList;
+
 public class VegetablesMain {
 
+    // 如果要使用其他目录的测试数据文件，请在命令行指定参数（第一个参数）
+    // 否则将会使用默认的目录("/{运行目录，一般为工程目录}/vegetables/resources/vegetables.txt")
+    // 此项目的idea runConfigure已经设置好运行目录，一般情况下可以直接读取到
     public static void main(String[] args) {
+        new VegetablesMain().run(args);
+    }
+
+    private void run(String[] args) {
+        UnityResponse<ArrayList<Vegetable>> response = null;
+        ResponseProcessor responseProcessor = null;
+
+        if (args.length != 0) {
+            System.out.println("Read source data from: " + args[0]);
+            responseProcessor = new ResponseProcessor(args[0]);
+        } else {
+            String sourceDataLocation = System.getProperty("user.dir") + "/resources/vegetables.txt";
+            System.out.println("Command line param not specify, will read source data from: " + sourceDataLocation);
+            responseProcessor = new ResponseProcessor(sourceDataLocation);
+        }
+
+        // 测试正常情况
+        response = responseProcessor.getListPage(1,10);
+        System.out.println("------------------------------------");
+        System.out.println("测试：正常情况(page 1, pageSize 10)");
+        System.out.println(response);
+
+        response = responseProcessor.getListPage(2,10);
+        System.out.println("------------------------------------");
+        System.out.println("测试：正常情况(page 2, pageSize 10)");
+        System.out.println(response);
+
+        response = responseProcessor.getListPage(1,15);
+        System.out.println("------------------------------------");
+        System.out.println("测试：正常情况(page 1, pageSize 15)");
+        System.out.println(response);
+
+        response = responseProcessor.getListPage(2,15);
+        System.out.println("------------------------------------");
+        System.out.println("测试：正常情况(page 2, pageSize 15)");
+        System.out.println(response);
+
+        // 测试页码超限
+        response = responseProcessor.getListPage(100000, 100);
+        System.out.println("------------------------------------");
+        System.out.println("测试：页码超限");
+        System.out.println(response);
+
+        // 测试分页参数有误
+        response = responseProcessor.getListPage(-1, 150);
+        System.out.println("------------------------------------");
+        System.out.println("测试：参数有误");
+        System.out.println(response);
+
+        // 测试炒饭...
+        System.out.println("------------------------------------");
+        System.out.println("测试：点炒饭");
+        System.out.println("炸了");
     }
 }
diff --git a/vegetables/src/me/lensfrex/vegetables/data/Vegetable.java b/vegetables/src/me/lensfrex/vegetables/data/Vegetable.java
index d633154..172c5d8 100644
--- a/vegetables/src/me/lensfrex/vegetables/data/Vegetable.java
+++ b/vegetables/src/me/lensfrex/vegetables/data/Vegetable.java
@@ -11,7 +11,7 @@ public class Vegetable {
     public static final int PRICE_MAX = 2;
 
     private String name;
-    private double[] price;
+    private double[] price = new double[3];
 
     private String priceDate;
 
@@ -41,7 +41,7 @@ public class Vegetable {
 
     @Override
     public String toString() {
-        return "Vegetable{" +
+        return "{" +
                 "name='" + name + '\'' +
                 ", price=" + Arrays.toString(price) +
                 ", priceDate='" + priceDate + '\'' +
diff --git a/vegetables/src/me/lensfrex/vegetables/exceptions/RequestPageTooLargeException.java b/vegetables/src/me/lensfrex/vegetables/exceptions/RequestPageTooLargeException.java
index ffef88b..4fdc3fb 100644
--- a/vegetables/src/me/lensfrex/vegetables/exceptions/RequestPageTooLargeException.java
+++ b/vegetables/src/me/lensfrex/vegetables/exceptions/RequestPageTooLargeException.java
@@ -4,7 +4,7 @@ package me.lensfrex.vegetables.exceptions;
  * 用于当请求数据的页数已经超过最大页数时抛出的异常
  */
 public class RequestPageTooLargeException extends Exception {
-    public RequestPageTooLargeException() {
-        super("请求结果的页数已超过最大数量");
+    public RequestPageTooLargeException(String additionalMessage) {
+        super("请求结果的页数已超过最大数量：" + additionalMessage);
     }
 }
diff --git a/vegetables/src/me/lensfrex/vegetables/resopnse/ResponseTool.java b/vegetables/src/me/lensfrex/vegetables/resopnse/ResponseTool.java
index 2394c84..3c4d001 100644
--- a/vegetables/src/me/lensfrex/vegetables/resopnse/ResponseTool.java
+++ b/vegetables/src/me/lensfrex/vegetables/resopnse/ResponseTool.java
@@ -18,7 +18,7 @@ public class ResponseTool {
      * @param code 失败状态码，应从UnityResponse.ResultCode中定义的常量中选择
      * @return 构建出的请求响应类
      */
-    public static UnityResponse<String> error(String message, int code) {
-        return new UnityResponse<>(code, message, "null");
+    public static <T> UnityResponse<T> error(String message, int code) {
+        return new UnityResponse<>(code, message, null);
     }
 }
diff --git a/vegetables/src/me/lensfrex/vegetables/resopnse/UnityResponse.java b/vegetables/src/me/lensfrex/vegetables/resopnse/UnityResponse.java
index 088283d..d0ec918 100644
--- a/vegetables/src/me/lensfrex/vegetables/resopnse/UnityResponse.java
+++ b/vegetables/src/me/lensfrex/vegetables/resopnse/UnityResponse.java
@@ -55,9 +55,11 @@ public class UnityResponse<T> {
         this.data = data;
     }
 
+    // 手动拼成json格式...
+    // 当然真正生成json还是看gson之类的吧...
     @Override
     public String toString() {
-        return "UnityResponse{" +
+        return "{" +
                 "code=" + code +
                 ", message='" + message + '\'' +
                 ", data=" + data +
@@ -67,7 +69,7 @@ public class UnityResponse<T> {
     /**
      * 状态码的常量
      */
-    static class ResultCode {
+    public static class ResultCode {
         /**
          * 请求成功
          */
diff --git a/vegetables/src/me/lensfrex/vegetables/utils/IOUtils.java b/vegetables/src/me/lensfrex/vegetables/utils/IOUtils.java
index a4b5ca3..a9038ff 100644
--- a/vegetables/src/me/lensfrex/vegetables/utils/IOUtils.java
+++ b/vegetables/src/me/lensfrex/vegetables/utils/IOUtils.java
@@ -1,6 +1,7 @@
 package me.lensfrex.vegetables.utils;
 
 import java.io.BufferedReader;
+import java.io.FileNotFoundException;
 import java.io.FileReader;
 import java.io.IOException;
 import java.util.LinkedList;
@@ -10,25 +11,24 @@ public class IOUtils {
     /**
      * 从文件中读取每行数据。
      * 为保证性能，此处使用LinkedList
+     *
      * @param path 文件的存储路径
      * @return LinkedList<String> 读取到的每行文本
      */
-    public static LinkedList<String> getListFromFile(String path) {
+    public static LinkedList<String> getListFromFile(String path) throws IOException {
         LinkedList<String> list = new LinkedList<>();
-        try{
-            //读取文件内容
-            //创建一个新的 FileReader ，给定要读取的文件的名称。
-            //创建使用默认大小的输入缓冲区的缓冲字符输入流
-            BufferedReader br = new BufferedReader(new FileReader(path));
-            String data = "";
-            while ( ( data = br.readLine() ) != null ) { // 一次读取一行
-                list.add(data);
-            }
-            //关闭资源
-            br.close();
-        } catch(IOException e) {
-            e.printStackTrace();
+
+        //读取文件内容
+        //创建一个新的 FileReader ，给定要读取的文件的名称。
+        //创建使用默认大小的输入缓冲区的缓冲字符输入流
+        BufferedReader br = new BufferedReader(new FileReader(path));
+        String data;
+        while ((data = br.readLine()) != null) { // 一次读取一行
+            list.add(data);
         }
+        //关闭资源
+        br.close();
+
         return list;
     }
 }