From a44e41f30ec70520528a5a089d38eb90d78b6842 Mon Sep 17 00:00:00 2001
From: 354798ggg <1074825718@qq.com>
Date: 星期一, 30 十月 2023 14:26:06 +0800
Subject: [PATCH] 项目台账和出库台账策略权限

---
 product-server-project-management/src/main/java/com/product/project/management/service/ProjectInfoService.java |  313 ++++++++++++++++++++++++----------------------------
 1 files changed, 144 insertions(+), 169 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 f298f33..b1babe8 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
@@ -1,10 +1,8 @@
 package com.product.project.management.service;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 
+import com.alibaba.fastjson.JSONArray;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -13,6 +11,7 @@
 import com.product.core.entity.DataTableEntity;
 import com.product.core.entity.FieldSetEntity;
 import com.product.core.exception.BaseException;
+import com.product.core.permission.PermissionService;
 import com.product.core.service.support.AbstractBaseService;
 import com.product.project.management.config.Cmnconst;
 import com.product.project.management.config.SystemCode;
@@ -21,172 +20,148 @@
 import cn.hutool.json.JSONObject;
 
 @Component("qxlw-project-service")
-public class ProjectInfoService extends AbstractBaseService{
+public class ProjectInfoService extends AbstractBaseService {
 
-	@Autowired
-	BaseDao baseDao;
-	
-	/**
-	 * 	閫氳繃椤圭洰绫诲瀷鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栨ā鏉垮垎椤癸級
-	 * @param projectType
-	 * @return
-	 */
-	public DataTableEntity getProjectTypeItem(String projectType) {
-		DataTableEntity dtProjectItem = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BASE_PROJECT_ITEM, "itemize_type=?", new Object[] {projectType}, new Object[] {Cmnconst.ITEMIZE, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_TYPE, Cmnconst.ITEMIZE_PARENT_CODE});
-		if (!BaseUtil.dataTableIsEmpty(dtProjectItem)) {
-			DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(dtProjectItem, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
-			return newDtProjectItem;
+    @Autowired
+    BaseDao baseDao;
+    
+    @Autowired
+    PermissionService permissionService;
+    
+    /**
+     * 	椤圭洰淇℃伅鍒楄〃
+     * @param cpage
+     * @param pageSize
+     * @return
+     */
+    public DataTableEntity listProjectByCreated(Integer cpage, Integer pageSize) {
+
+    	String queryFilter = permissionService.getDataFilter(Cmnconst.PRODUCT_PROJECT_QXLW, "project_leader,materialman");
+    	DataTableEntity dt = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_QXLW, queryFilter, new Object [] {}, null, Cmnconst.CREATED_UTC_DATETIME_DESC, pageSize, cpage);
+    	baseDao.loadPromptData(dt);
+    	return dt;
+    }
+    
+    /**
+     * 閫氳繃椤圭洰绫诲瀷鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栨ā鏉垮垎椤癸級
+     *
+     * @param projectType
+     * @return
+     */
+    public DataTableEntity getProjectTypeItem(String projectType) {
+        DataTableEntity dtProjectItem = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BASE_PROJECT_ITEM, "itemize_type=?", new Object[]{projectType}, new Object[]{Cmnconst.ITEMIZE, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_TYPE, Cmnconst.ITEMIZE_PARENT_CODE});
+        if (!BaseUtil.dataTableIsEmpty(dtProjectItem)) {
+            DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(dtProjectItem, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
+            return newDtProjectItem;
+        }
+        return null;
+    }
+
+    /**
+     * 閫氳繃椤圭洰UUID鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栦繚瀛樼殑瀛愯〃鍒嗛」--澶氫釜鏍戯級
+     *
+     * @param uuid
+     * @return
+     */
+    public FieldSetEntity getProjectItem(String uuid) {
+        FieldSetEntity fseProject = baseDao.getFieldSetEntity(Cmnconst.PRODUCT_PROJECT_QXLW, uuid, true);
+        DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(fseProject.getSubDataTable(Cmnconst.PRODUCT_PROJECT_ITEM), Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
+        Map<String, DataTableEntity> dtSubTable = fseProject.getSubData();
+        dtSubTable.put(Cmnconst.PRODUCT_PROJECT_ITEM, newDtProjectItem);
+        return fseProject;
+    }
+
+    /**
+     * 閫氳繃椤圭洰UUID鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栦繚瀛樼殑瀛愯〃鍒嗛」--鍗曚釜鏍戯級
+     *
+     * @param uuid
+     * @return
+     */
+    public DataTableEntity getProjectAllItem(String uuid) {
+        DataTableEntity dtProjectItemize = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_ITEM, "project_uuid=?", new Object[]{uuid}, new Object[]{CoreConst.UUID, Cmnconst.ITEMIZE, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, Cmnconst.ITEMIZE_FULL_NAME});
+        if (!BaseUtil.dataTableIsEmpty(dtProjectItemize)) {
+            DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(dtProjectItemize, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
+            return newDtProjectItem;
+        }
+        return null;
+    }
+
+    /**
+     * 鑾峰彇鎵�鏈夐」鐩俊鎭�
+     *
+     * @return
+     */
+    public DataTableEntity listProject() {
+        return baseDao.listTable(Cmnconst.PRODUCT_PROJECT_QXLW, null, null, new Object[]{CoreConst.UUID, Cmnconst.PROJECT_NAME});
+    }
+
+    
+
+    /**
+     * 鍒犻櫎瀛愰」楠岃瘉锛堝凡缁忕敓鎴愰绠楃殑瀛愰」涓嶈兘鍒犻櫎锛�
+     *
+     * @param uuid
+     */
+    public void deleteItemizeValidate(String uuid) {
+        DataTableEntity dtBudget = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BUDGET, "budget_code=?", new Object[]{uuid});
+        if (!BaseUtil.dataTableIsEmpty(dtBudget)) {
+            throw new BaseException(SystemCode.PROJECT_ITEMIZE_DEL_FAIL_HAS_BUDGET.getValue(), SystemCode.PROJECT_ITEMIZE_DEL_FAIL_HAS_BUDGET.getText());
+        }
+    }
+
+    /**
+     * 鑾峰彇鍒嗛」棰勭畻淇℃伅
+     *
+     * @param itemizeUUID 鍒嗛」UUID
+     * @param capge       褰撳墠椤�
+     * @param pageSize    椤靛ぇ灏�
+     * @return
+     */
+    public DataTableEntity listItemizeBudget(String itemizeUUID, Integer capge, Integer pageSize) {
+    	if (!BaseUtil.strIsNull(itemizeUUID)) {
+    		DataTableEntity dtItemizeBudget = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BUDGET, "project_itemize_uuid = ?", new Object[] {itemizeUUID}, null, null, pageSize, capge);
+            if (!BaseUtil.dataTableIsEmpty(dtItemizeBudget)) {
+                baseDao.loadPromptData(dtItemizeBudget);
+            }
+            return dtItemizeBudget;
 		}
-		return null;
-	}
-	
-	/**
-	 * 	閫氳繃椤圭洰UUID鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栦繚瀛樼殑瀛愯〃鍒嗛」--澶氫釜鏍戯級
-	 * @param uuid
-	 * @return
-	 */
-	public FieldSetEntity getProjectItem(String uuid) {
-		FieldSetEntity fseProject = baseDao.getFieldSetEntity(Cmnconst.PRODUCT_PROJECT_QXLW, uuid, true);
-		DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(fseProject.getSubDataTable(Cmnconst.PRODUCT_PROJECT_ITEM), Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
-		Map<String, DataTableEntity>dtSubTable = fseProject.getSubData();
-		dtSubTable.put(Cmnconst.PRODUCT_PROJECT_ITEM, newDtProjectItem);
-		return fseProject;
-	}
-	
-	/**
-	 * 	閫氳繃椤圭洰UUID鑾峰彇椤圭洰鍒嗛」锛堣幏鍙栦繚瀛樼殑瀛愯〃鍒嗛」--鍗曚釜鏍戯級
-	 * @param uuid
-	 * @return
-	 */
-	public DataTableEntity getProjectAllItem(String uuid) {
-		DataTableEntity dtProjectItemize = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_ITEM, "project_uuid=?", new Object[] {uuid}, new Object[] {CoreConst.UUID, Cmnconst.ITEMIZE, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE});
-		if (!BaseUtil.dataTableIsEmpty(dtProjectItemize)) {
-			DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(dtProjectItemize,Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
-			return newDtProjectItem;
-		}
-		return null;
-	}
-	
-	/**
-	 * 	鑾峰彇鎵�鏈夐」鐩俊鎭�
-	 * @return
-	 */
-	public DataTableEntity listProject() {
-		return baseDao.listTable(Cmnconst.PRODUCT_PROJECT_QXLW, null, null, new Object[] {CoreConst.UUID, Cmnconst.PROJECT_NAME});
-	}
-	
-	/**
-	 * 	椤圭洰鏁版嵁鍒嗘瀽
-	 * @param project_uuid
-	 * @return
-	 */
-	public JSONObject statistAnalysis(String project_uuid) {
-		
-		JSONObject returnJson = new JSONObject();
-		
-		//鑾峰彇鏁版嵁搴撳師濮嬫暟鎹�
-		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(" 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(" ) ")
-		.append(" SELECT A.project_uuid,A.project_itemize,A.total_outbound_weight,B.material_type,B.material_code,B.outbound_weight ")
-		.append(" FROM ( ")
-		.append(" SELECT project_uuid,project_itemize,SUM(outbound_weight)total_outbound_weight ")
-		.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 ");
-		DataTableEntity dtItemizeInfo = baseDao.listTable(sb.toString(), new Object[] {project_uuid});
-		if(!BaseUtil.dataTableIsEmpty(dtItemizeInfo)) {
-			
-			Map<String, FieldSetEntity> convertData = new HashMap<>();
-			String [] materialTypes = new String[3];
-			
-			//閫氳繃Java寰幆灏�"鏉愭枡"鍜�"鍑哄簱閲�"鏁版嵁琛岃浆鍒�
-			for (int i = 0; i < dtItemizeInfo.getRows(); i++) {
-				FieldSetEntity fseItemize = dtItemizeInfo.getFieldSetEntity(i);
-				
-				//鑾峰彇鏉愭枡缂栫爜锛屾潗鏂欑被鍨嬶紝鍑哄簱閲�
-				String materialCode = fseItemize.getString(Cmnconst.MATERIAL_CODE);
-				String outboundWeight = fseItemize.getString(Cmnconst.OUTBOUND_WEIGHT);
-				Integer materialType = fseItemize.getInteger(Cmnconst.MATERIAL_TYPE);
-				
-				//鏀堕泦鑾峰彇鎵�鏈夎〃澶村垪锛堟潗鏂欑紪鐮侊級
-				if (BaseUtil.strIsNull(materialTypes[materialType])) {
-					materialTypes[materialType] = materialCode;
-				}else {
-					materialTypes[fseItemize.getInteger(Cmnconst.MATERIAL_TYPE)]+=","+materialCode;
-				}
-				
-				//鏀堕泦琛岃浆鍒楁暟鎹�
-				String itemize = fseItemize.getString(Cmnconst.PROJECT_ITEMIZE);
-				if(convertData.containsKey(itemize)) {
-					convertData.get(itemize).setValue(materialCode, outboundWeight);
-				}else {
-					FieldSetEntity fseConvertData = new FieldSetEntity(Cmnconst.PRODUCT_PROJECT_QXLW);
-					fseConvertData.setValue(Cmnconst.PROJECT_ITEMIZE, itemize);
-					fseConvertData.setValue(Cmnconst.TOTAL_OUTBOUND_WEIGHT, fseItemize.getString(Cmnconst.TOTAL_OUTBOUND_WEIGHT));
-					fseConvertData.setValue(materialCode, outboundWeight);
-					convertData.put(itemize, fseConvertData);
-				}
-			}
-			//灏嗘暟鎹浆涓篋ataTableEntity杩斿洖
-			if (!convertData.isEmpty()) {
-				DataTableEntity finalConvertData = new DataTableEntity(); 
-				convertData.forEach((k,v) -> {
-					finalConvertData.addFieldSetEntity(v);
-				});
-				returnJson.set("data", BaseUtil.dataTableEntityToJson(finalConvertData));
-			}
-			for (int i = 0; i < materialTypes.length; i++) {
-				if(!BaseUtil.strIsNull(materialTypes[i])) {
-					returnJson.set("type"+i, materialTypes[i]);
-				}
-			}
-		}
-	    return returnJson;
-	}
-	
-	/**
-	 * 	鍒犻櫎瀛愰」楠岃瘉锛堝凡缁忕敓鎴愰绠楃殑瀛愰」涓嶈兘鍒犻櫎锛�
-	 * @param uuid
-	 */
-	public void deleteItemizeValidate(String uuid) {
-		DataTableEntity dtBudget = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BUDGET, "budget_code=?", new Object[] {uuid});
-		if (!BaseUtil.dataTableIsEmpty(dtBudget)) {
-			throw new BaseException(SystemCode.PROJECT_MANAGEMENT_ITEMIZE_DEL_FAIL.getValue(), SystemCode.PROJECT_MANAGEMENT_ITEMIZE_DEL_FAIL.getText());
-		}
-	}
-	
-	/**
-	 * 	鑾峰彇鍒嗛」棰勭畻淇℃伅
-	 * @param projectUUID	椤圭洰UUID
-	 * @param itemizeCode	鍒嗛」缂栫爜
-	 * @param capge			褰撳墠椤�
-	 * @param pageSize		椤靛ぇ灏�
-	 * @return
-	 */
-	public DataTableEntity listItemizeBudget(String projectUUID, String itemizeCode, Integer capge, Integer pageSize) {
-		
-		String filter;
-		List <String> params= new ArrayList<>();
-		if (BaseUtil.strIsNull(itemizeCode)) {
-			filter = "project_itemize_uuid IN (SELECT uuid FROM product_project_item WHERE project_uuid=?)";
-			params.add(projectUUID);
-		}else {
-			filter = "project_itemize_uuid IN (SELECT uuid FROM product_project_item WHERE project_uuid=? AND itemize_code like ?)";
-			params.add(projectUUID);
-			params.add(itemizeCode+"%");
-		}
-		DataTableEntity dtItemizeBudget = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_BUDGET, filter, params.toArray(), null, null, pageSize, capge);
-		if (!BaseUtil.dataTableIsEmpty(dtItemizeBudget)) {
-			baseDao.loadPromptData(dtItemizeBudget);
-		}
-		return dtItemizeBudget;
-	}
+        return null;
+    }
+
+    /**
+     * 鏇村叿椤圭洰鍒嗛」uuid鑾峰彇椤圭洰鍒嗛」涓嬬殑鏉愭枡
+     * @param uuid
+     * @param capge
+     * @param pageSize
+     * @return
+     */
+    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
+     * @return
+     */
+    public JSONArray getTreeProjectItem(String uuid) {
+        DataTableEntity dtProjectItemize = baseDao.listTable(Cmnconst.PRODUCT_PROJECT_ITEM, "project_uuid=?", new Object[]{uuid}, new Object[]{CoreConst.UUID, Cmnconst.ITEMIZE, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE});
+        DataTableEntity newDtProjectItem = BaseUtil.dataTableToTreeTable(dtProjectItemize, Cmnconst.ITEMIZE_CODE, Cmnconst.ITEMIZE_PARENT_CODE, null);
+        JSONArray objects = BaseUtil.dataTableEntityToJson(newDtProjectItem);
+        JSONObject json = new JSONObject();
+        json.set("itemize", "椤圭洰鍒嗛儴鍒嗛」");
+        json.set("children", objects);
+        json.set("type", 1);
+        JSONArray array = new JSONArray();
+        array.add(json);
+        return array;
+    }
 }

--
Gitblit v1.9.2