From f0eaa3605bb2d87d94b0e8240d347c171a67123d Mon Sep 17 00:00:00 2001
From: 许鹏程 <1821349743@qq.com>
Date: 星期一, 02 九月 2024 11:38:09 +0800
Subject: [PATCH] 个人文档查询数量bug

---
 src/main/java/com/product/file/service/DocumentDirectoryService.java |  143 ++++++++++++++++++++++++-----------------------
 1 files changed, 74 insertions(+), 69 deletions(-)

diff --git a/src/main/java/com/product/file/service/DocumentDirectoryService.java b/src/main/java/com/product/file/service/DocumentDirectoryService.java
index 7d9dd21..1783b09 100644
--- a/src/main/java/com/product/file/service/DocumentDirectoryService.java
+++ b/src/main/java/com/product/file/service/DocumentDirectoryService.java
@@ -4,6 +4,7 @@
 import com.alibaba.fastjson.JSONObject;
 import com.product.common.collect.ListUtils;
 import com.product.common.lang.DateUtils;
+import com.product.core.config.CoreConst;
 import com.product.core.dao.BaseDao;
 import com.product.core.entity.DataTableEntity;
 import com.product.core.entity.FieldSetEntity;
@@ -39,9 +40,10 @@
 	public BaseDao baseDao;
 	@Autowired
 	public DocumentDirectoryService documentDirectoryService;
-	
+
 	/**
-	 * 	鍗曚綅鏂囦欢澶规爲
+	 * 鍗曚綅鏂囦欢澶规爲
+	 *
 	 * @return
 	 */
 	public DataTableEntity allDirectoryTree() {
@@ -52,68 +54,44 @@
 		return dtTree;
 	}
 
-	@Override
+	/**
+	 * 鏂囨。鐩綍淇濆瓨
+	 *
+	 * @param fse
+	 * @return
+	 */
 	@Transactional
-	public String addDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException {
-
-		String triCode = CodeUtil.getNewCodeByTemp(CmnConst.PRODUCT_OA_DIRECTORY, CmnConst.TRICODE,
-				!StringUtils.isEmpty(fieldSetEntity.getString(CmnConst.TRICODE_PARENT))
-						? fieldSetEntity.getString(CmnConst.TRICODE_PARENT)
-						: "");
-		fieldSetEntity.setValue(CmnConst.TRICODE, triCode);
-		String[] codes = triCode.split("-");
-		String org_level_uuid = SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid();
-		fieldSetEntity.setValue(CmnConst.ORG_LEVEL_UUID, org_level_uuid);
-		fieldSetEntity.setValue(CmnConst.DIRECTORY_TIER, codes.length);
-		fieldSetEntity.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());// 鑾峰彇鐧诲綍甯愬彿
-		fieldSetEntity.setValue(CmnConst.CREATED_UTC_DATETIME, DateUtils.getDateTime());// 鍒涘缓鏃堕棿
-		return baseDao.add(fieldSetEntity);
-	}
-
-	@Override
-	@Transactional
-	public boolean upDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException {
-		String uuid = fieldSetEntity.getString(CmnConst.UUID);
-		FieldSetEntity fieldSet = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_DIRECTORY, uuid, false);
-		String tricode_parent1 = fieldSetEntity.getString(CmnConst.TRICODE_PARENT);
-		String tricode_parent2 = fieldSet.getString(CmnConst.TRICODE_PARENT);
-		boolean flag;
-		// 涓婄骇鐩綍tricode濡傛灉涓嶇浉绛�
-		if (!StringUtils.isEmpty(tricode_parent1) || !StringUtils.isEmpty(tricode_parent2)) {
-			if (!StringUtils.isEmpty(tricode_parent1) && !StringUtils.isEmpty(tricode_parent2)
-					&& !tricode_parent1.equals(tricode_parent2)) {
-				flag = true;
-			} else if (!StringUtils.isEmpty(tricode_parent1) && !StringUtils.isEmpty(tricode_parent2)
-					&& tricode_parent1.equals(tricode_parent2)) {
-				flag = false;
-			} else if (!StringUtils.isEmpty(tricode_parent1) && StringUtils.isEmpty(tricode_parent2)) {
-				tricode_parent2 = "";
-				flag = true;
-			} else if (!StringUtils.isEmpty(tricode_parent2) && StringUtils.isEmpty(tricode_parent1)) {
-				tricode_parent1 = "";
-				flag = true;
-			} else {
-				flag = false;
-			}
+	public boolean saveDocumentDireactory(FieldSetEntity fse) {
+		BaseUtil.createCreatorAndCreationTime(fse);
+		String tricode = null;
+		String tricodeParent = BaseUtil.strIsNull(fse.getString(CmnConst.TRICODE_PARENT)) ? "" : fse.getString(CmnConst.TRICODE_PARENT);
+		if (BaseUtil.strIsNull(fse.getUUID())) {
+			tricode = CodeUtil.getNewCodeByTemp(CmnConst.PRODUCT_OA_DIRECTORY, CmnConst.TRICODE, tricodeParent);
 		} else {
-			flag = false;
+			FieldSetEntity fseOrigin = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_DIRECTORY, fse.getUUID(), false);
+			if (fseOrigin == null) {
+				fse.remove(CoreConst.UUID);
+			}
+			String originParent = BaseUtil.strIsNull(fseOrigin.getString(CmnConst.TRICODE_PARENT)) ? "" : fseOrigin.getString(CmnConst.TRICODE_PARENT);
+			if (!originParent.equals(tricodeParent)) {
+				String originTricode = BaseUtil.strIsNull(fseOrigin.getString(CmnConst.TRICODE)) ? "" : fseOrigin.getString(CmnConst.TRICODE);
+				tricode = CodeUtil.getNewCodeByTemp(CmnConst.PRODUCT_OA_DIRECTORY, CmnConst.TRICODE, tricodeParent);
+				StringBuilder sql = new StringBuilder();
+				sql.append("update product_oa_directory ");
+				sql.append("set tricode=concat(replace(substring(tricode,1,locate(?,tricode)+length(?)),?,?),substring(tricode,locate(?,tricode)+length(?)+1)), ");
+				sql.append("tricode_parent=concat(replace(substring(tricode_parent,1,locate(?,tricode_parent)+length(?)),?,?),substring(tricode_parent,locate(?,tricode_parent)+length(?)+1)) ");
+				sql.append("where tricode like ? ");
+				baseDao.executeUpdate(sql.toString(), new Object[]{originTricode, originTricode, originTricode, tricode, originTricode, originTricode,
+						originTricode, originTricode, originTricode, tricode, originTricode, originTricode, originTricode + "-%"});
+			} else {
+				tricode = fseOrigin.getString(CmnConst.TRICODE);
+			}
 		}
-
-		if (flag) {
-			StringBuffer sql = new StringBuffer();
-			sql.append(" update PRODUCT_OA_directory set tricode=replace(");
-			sql.append(" tricode,concat(?,'-'),concat(?,'-')),");
-			sql.append(" tricode_parent=(case when tricode_parent=? then replace(tricode_parent,?,?) else ");
-			sql.append(" replace (tricode_parent,concat(?,'-'),concat(?,'-')) end )");
-			sql.append("  where  tricode like ?");
-			baseDao.executeUpdate(sql.toString(), new String[] { tricode_parent1, tricode_parent2, tricode_parent1,
-					tricode_parent1, tricode_parent2, tricode_parent1, tricode_parent2, tricode_parent1 + "-%", });
-		}
-
-		fieldSetEntity.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());// 鑾峰彇鐧诲綍甯愬彿
-		fieldSetEntity.setValue(CmnConst.UPDATED_UTC_DATETIME, DateUtils.getDateTime());// 鍒涘缓鏃堕棿
-		return baseDao.update(fieldSetEntity);
+		fse.setValue(CmnConst.TRICODE, tricode);
+		fse.setValue(CmnConst.DIRECTORY_TIER, tricode.split(",").length);
+		return baseDao.saveFieldSetEntity(fse);
 	}
+
 
 	@Override
 	@Transactional
@@ -127,10 +105,10 @@
 		DataTableEntity dataTableEntity = baseDao.listTable(
 				"SELECT * FROM PRODUCT_OA_directory WHERE directory_type = ? AND tricode_parent = (SELECT tricode FROM PRODUCT_OA_directory where uuid = ?)"
 						+ filter,
-				new String[] { directory_type, uuid });
+				new String[]{directory_type, uuid});
 		if (BaseUtil.dataTableIsEmpty(dataTableEntity)) {
-			baseDao.delete(CmnConst.PRODUCT_OA_DOCUMENT, "directory_uuid = ?", new String[] { uuid });
-			return baseDao.delete(CmnConst.PRODUCT_OA_DIRECTORY, new String[] { uuid });
+			baseDao.delete(CmnConst.PRODUCT_OA_DOCUMENT, "directory_uuid = ?", new String[]{uuid});
+			return baseDao.delete(CmnConst.PRODUCT_OA_DIRECTORY, new String[]{uuid});
 		} else {
 			throw new BaseException(DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getValue(),
 					DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getText(), this.getClass(),
@@ -140,7 +118,7 @@
 
 	/**
 	 * 鑾峰彇褰撳墠鏂囦欢璺緞
-	 * 
+	 *
 	 * @param fieldSetEntity
 	 * @return
 	 * @throws BaseException
@@ -198,13 +176,13 @@
 		if ("1".equals(directory_type)) {
 			String org_level_uuid = user.getOrg_level_uuid();
 			sql.append("where directory_type = 1 AND org_level_uuid = ? ");
-			data = baseDao.listTable(sql.toString(), new Object[] { org_level_uuid });
+			data = baseDao.listTable(sql.toString(), new Object[]{org_level_uuid});
 //      data = baseDao.listTable(CmnConst.PRODUCT_OA_DIRECTORY, " directory_type = 1 AND org_level_uuid = ?", new String[]{org_level_uuid}, "tricode");
 			// 涓汉鏂囦欢澶�
 		} else {
 			Integer userId = user.getUser_id();
 			sql.append("where directory_type = 2 AND created_by = ? ");
-			data = baseDao.listTable(sql.toString(), new Object[] { userId });
+			data = baseDao.listTable(sql.toString(), new Object[]{userId});
 
 //      data = baseDao.listTable(CmnConst.PRODUCT_OA_DIRECTORY, " directory_type = 2 AND created_by = ?", new Object[]{userId}, "tricode");
 		}
@@ -217,13 +195,40 @@
 		orgLevelInfo.put("org_level_uuid", user.getOrg_level_uuid());
 		orgLevelInfo.put("children", menus);
 		JSONArray array = new JSONArray();
+		if (!"1".equals(directory_type)) {
+//		鏌ヨ鏁伴噺
+			sql.setLength(0);
+			sql.append(" SELECT\n");
+			sql.append("		( SELECT count(*) FROM product_oa_document_collection WHERE document_collector = ? ) collection_count,\n");
+			sql.append("		( SELECT count( sub_uuid ) FROM product_oa_document_borrow_sub WHERE borrow_uuid IN ( SELECT uuid FROM product_oa_document_borrow WHERE borrower = ? and flow_flag= 2 )  ) borrow_count\n");
+			sql.append("		FROM\n");
+			sql.append("DUAL\n");
+			FieldSetEntity fieldSetBySQL = baseDao.getFieldSetBySQL(sql.toString(), new Object[]{user.getUser_id(), user.getUser_id()}, false);
+			int collectionCount = 0;
+			int borrowCount = 0;
+			if (fieldSetBySQL != null) {
+				collectionCount = BaseUtil.ifNull(fieldSetBySQL.getInteger("collection_count"), 0);
+				borrowCount = BaseUtil.ifNull(fieldSetBySQL.getInteger("borrow_count"), 0);
+			}
+			//娣诲姞鏀惰棌澶瑰拰鍊熼槄鏂囦欢澶�
+			JSONObject favorite = new JSONObject();
+			favorite.put("directory_name", "鏀惰棌澶�");
+			favorite.put("uuid", "!favorite");
+			favorite.put("number", collectionCount);
+			menus.add(0, favorite);
+			JSONObject borrow = new JSONObject();
+			borrow.put("directory_name", "鍊熼槄鏂囦欢");
+			borrow.put("uuid", "!borrow");
+			borrow.put("number", borrowCount);
+			menus.add(1, borrow);
+		}
 		array.add(orgLevelInfo);
 		return array;
 	}
 
 	/**
 	 * 灏佽鏍戞柟娉�
-	 * 
+	 *
 	 * @param
 	 * @return
 	 * @throws BaseException
@@ -265,7 +270,7 @@
 
 	/**
 	 * 绉诲姩鍒扮洰褰曞垪琛紙鏍规嵁褰撳墠鐢ㄦ埛杩囨护灞曠ず鐩綍鍒楄〃锛� 鑾峰彇鐢ㄦ埛鏈夋柊澧烇紙涓婁紶锛夋潈闄愮殑鍒楄〃
-	 * 
+	 *
 	 * @param
 	 * @return
 	 * @throws BaseException
@@ -287,7 +292,7 @@
 			param.append(userId);
 			sql.append("SELECT * FROM PRODUCT_OA_directory ").append(" WHERE directory_type = 2 AND created_by = ? ");
 		}
-		DataTableEntity dataTableEntity = baseDao.listTable(sql.toString(), new String[] { param.toString() });
+		DataTableEntity dataTableEntity = baseDao.listTable(sql.toString(), new String[]{param.toString()});
 		baseDao.listInternationDataTable(dataTableEntity, null);
 		return dataTableEntity;
 	}

--
Gitblit v1.9.2