From 608deccc0cdcf17b90cf80978b069fa59a9ae0d9 Mon Sep 17 00:00:00 2001
From: 2369059705@qq.com <2369059705@qq.com>
Date: 星期一, 17 七月 2023 14:32:47 +0800
Subject: [PATCH] 项目预警

---
 product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java |   24 +++++++++++++++++-------
 1 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java b/product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java
index e414305..7f946b6 100644
--- a/product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java
+++ b/product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java
@@ -6,7 +6,6 @@
 import java.util.Map;
 
 import com.alibaba.fastjson.JSONArray;
-import com.product.core.websocket.config.CmnConst;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -94,12 +93,13 @@
         //鑾峰彇鏁版嵁搴撳師濮嬫暟鎹�
         StringBuilder sb = new StringBuilder();
         sb.append("WITH outbound AS(")
-                .append(" SELECT A.project_uuid,A.project_itemize,C.material_type,B.material_code,SUM(B.outbound_weight)outbound_weight ")
+                .append(" SELECT A.project_uuid,D.itemize project_itemize,C.material_type,B.material_code,SUM(B.outbound_weight)outbound_weight ")
                 .append(" FROM product_project_outbound A ")
                 .append(" LEFT JOIN product_project_outbound_sub B ON A.uuid=B.outbound_uuid ")
                 .append(" LEFT JOIN product_project_base_material C ON B.material_uuid = C.uuid ")
-                .append(" WHERE project_uuid = ? ")
-                .append(" GROUP BY A.project_uuid,A.project_itemize,C.material_type,B.material_code ")
+                .append(" LEFT JOIN product_project_item D ON A.project_itemize = D.uuid ")
+                .append(" WHERE A.flow_flag=2 AND A.project_uuid = ? ")
+                .append(" GROUP BY A.project_uuid,D.itemize,C.material_type,B.material_code ")
                 .append(" ) ")
                 .append(" SELECT A.project_uuid,A.project_itemize,A.total_outbound_weight,B.material_type,B.material_code,B.outbound_weight ")
                 .append(" FROM ( ")
@@ -107,7 +107,8 @@
                 .append(" FROM outbound ")
                 .append(" GROUP BY project_uuid,project_itemize ")
                 .append(" )A ")
-                .append(" RIGHT JOIN outbound B ON A.project_uuid=B.project_uuid AND A.project_itemize=B.project_itemize ");
+                .append(" RIGHT JOIN outbound B ON A.project_uuid=B.project_uuid AND A.project_itemize=B.project_itemize ")
+        		.append(" ORDER BY project_itemize,material_code");
         DataTableEntity dtItemizeInfo = baseDao.listTable(sb.toString(), new Object[]{project_uuid});
         if (!BaseUtil.dataTableIsEmpty(dtItemizeInfo)) {
 
@@ -127,7 +128,9 @@
                 if (BaseUtil.strIsNull(materialTypes[materialType])) {
                     materialTypes[materialType] = materialCode;
                 } else {
-                    materialTypes[fseItemize.getInteger(Cmnconst.MATERIAL_TYPE)] += "," + materialCode;
+                	if(materialTypes[fseItemize.getInteger(Cmnconst.MATERIAL_TYPE)].indexOf(materialCode)<0) {
+                		materialTypes[fseItemize.getInteger(Cmnconst.MATERIAL_TYPE)] += "," + materialCode;
+                	}
                 }
 
                 //鏀堕泦琛岃浆鍒楁暟鎹�
@@ -182,6 +185,7 @@
      */
     public DataTableEntity listItemizeBudget(String projectUUID, String itemizeCode, Integer capge, Integer pageSize) {
 
+
         String filter;
         List<String> params = new ArrayList<>();
         if (BaseUtil.strIsNull(itemizeCode)) {
@@ -209,7 +213,13 @@
     public DataTableEntity listMaterialV(String uuid, Integer capge, Integer pageSize) {
         return baseDao.listTable("product_project_base_material_v","project_itemize_uuid=?",new String[]{uuid},null,null,pageSize, capge);
     }
-
+    /**
+     * 鏇村叿浠撳簱鍜屾潗鏂欒幏鍙栧簱瀛�
+     * @return
+     */
+    public FieldSetEntity findInventoryV(String warehouse_uuid, String material_uuid) {
+        return baseDao.getFieldSetByFilter("product_project_inventory_v","warehouse_uuid=? and uuid=?",new String[]{warehouse_uuid,material_uuid},false);
+    }
     /**
      * 鏍规嵁椤圭洰uuid鑾峰彇椤圭洰鍒嗛」鏍戠粨鏋�
      * @param uuid

--
Gitblit v1.9.2