From affbba0568f48d558ad84fb5247c135d7be96bde Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期五, 11 八月 2023 16:23:14 +0800
Subject: [PATCH] #报价单审核机制

---
 src/main/java/com/zy/crm/common/web/DatavController.java |   89 +++++++++++++++++++++++++++++++-------------
 1 files changed, 63 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/zy/crm/common/web/DatavController.java b/src/main/java/com/zy/crm/common/web/DatavController.java
index 4994858..ea43349 100644
--- a/src/main/java/com/zy/crm/common/web/DatavController.java
+++ b/src/main/java/com/zy/crm/common/web/DatavController.java
@@ -1,41 +1,78 @@
 package com.zy.crm.common.web;
 
+import com.core.common.Cools;
 import com.core.common.R;
+import com.zy.crm.common.service.DbSqlServer;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.ClassPathResource;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.List;
+import java.util.Map;
 
 /**
  * Created by vincent on 2023/7/25
  */
 @RestController
+@SuppressWarnings("all")
 public class DatavController {
 
-    @GetMapping("/1test")
-    public R test1() {
-        /**
-         * select
-         * (case  when A.org='1002208180000267' then '鍢夊杽'
-         *        when A.org='1002208180000506' then '骞垮痉'
-         * 	   else '' end) as 缁勭粐,
-         * A.DocNo as 鍗曞彿,A3.Code as 椤圭洰鍙�,
-         * (case  when A.DocState='0' then '寮�绔�'
-         *        when A.DocState='1' then '宸插鏍�'
-         * 	   when A.DocState='2' then '寮�宸�'
-         * 	   when A.DocState='3' then '瀹屽伐'
-         * 	   when A.DocState='4' then '鏍稿噯涓�'
-         * 	   ELSE''  end) as 鐘舵��,
-         * A.StartDate as 璁″垝寮�宸ユ棩,
-         * A.CompleteDate as 璁″垝瀹屽伐鏃�,A2.Code as 鏂欏彿,A2.name as 鍝佸悕,A2.SPECS as 瑙勬牸 , a.ProductQty as 鐢熶骇鏁伴噺,TotalCompleteQty as 瀹屽伐鏁伴噺
-         * from MO_MO as A
-         * left join CBO_ItemMaster as A2 on (A.ItemMaster = A2.ID)
-         * left join CBO_Project as A3 on (A.Project = A3.ID)
-         * where
-         * A.MODocType != '1002306121624435'  --杩囨护鍐呴儴鐮斿彂椤圭洰
-         * and A.IsWBSTask!=1                 --杩囨护鐜板満鏂藉伐浠诲姟
-         * and A.DocState != '3'              --杩囨护瀹屽伐鐘舵�佺殑璁㈠崟
-         * ORDER BY A.CompleteDate
-         */
-        return R.ok();
+    private String 鐢熶骇璁㈠崟;
+    private String 閿�鍞鍗�;
+
+    {
+        try {
+            this.鐢熶骇璁㈠崟 = read(new ClassPathResource("datav/sql/鐢熶骇璁㈠崟.sql").getInputStream());
+            this.閿�鍞鍗� = read(new ClassPathResource("datav/sql/閿�鍞鍗�.sql").getInputStream());
+        } catch (IOException ignore) {}
+    }
+
+    @Autowired
+    private DbSqlServer dbSqlServer;
+
+    @GetMapping("/data1")
+    public R data1() {
+        List<Map<String, Object>> res = dbSqlServer.select(this.鐢熶骇璁㈠崟);
+        if (Cools.isEmpty(res)) {
+            return R.ok();
+        }
+        int limit = 30;
+        if (res.size() > limit) {
+            res = res.subList(0, limit);
+        }
+        return R.ok().add(res);
+    }
+
+    @GetMapping("/data3")
+    public R data3() {
+        List<Map<String, Object>> res = dbSqlServer.select(this.閿�鍞鍗�);
+        if (Cools.isEmpty(res)) {
+            return R.ok();
+        }
+        return R.ok().add(res);
+    }
+
+    private static String read(InputStream inputStream) {
+        StringBuilder stringBuilder = new StringBuilder();
+        byte[] buffer = new byte[1024];
+        try {
+            int bytesRead;
+            while ((bytesRead = inputStream.read(buffer)) != -1) {
+                stringBuilder.append(new String(buffer, 0, bytesRead));
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                inputStream.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return stringBuilder.toString();
     }
 
 }

--
Gitblit v1.9.1