product-server-file
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
许鹏程
2024-08-28 4d610081d9d2da1a4db118ce260d5afeea312d9f 
 src/main/java/com/product/file/service/DocumentService.java


@@ -73,9 +73,6 @@


         fseDocument.setValue(CmnConst.FILE_SIZE, attachment.getString(CmnConst.ATTACHMENT_SIZE));


         fseDocument.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());


         fseDocument.setValue(CmnConst.CREATED_UTC_DATETIME, DateUtils.getDateTime());


         fseDocument.setValue("latest_version", fse.getObject("latest_version"));


         fseDocument.setValue("business_classify_uuid", fse.getObject("business_classify_uuid"));


         fseDocument.setValue("office_classify_uuid", fse.getObject("office_classify_uuid"));


         //文件名称


         String file_name = attachment.getString(CmnConst.FILE_NAME);


         fseDocument.setValue(CmnConst.FILE_NAME, file_name);


@@ -90,7 +87,7 @@


         BaseUtil.createCreatorAndCreationTime(fseDocumentHistory);


         fseDocumentHistory.setValue("document_uuid", documentUUID);


         fseDocumentHistory.setValue("attachment_uuid", attachment.getUUID());


         fseDocumentHistory.setValue("version_number", fseDocument.getObject("latest_version"));


            fseDocumentHistory.setValue("version_number", "v1");


         baseDao.add(fseDocumentHistory);




         uuidList.add(documentUUID);


@@ -156,7 +153,8 @@


      sql.append("LEFT JOIN product_sys_staffs B ON B.user_id = A.created_by \n");


      sql.append("LEFT JOIN product_sys_attachments C ON C.uuid = B.staff_avatar \n");


      sql.append("LEFT JOIN product_oa_document_collection D ON D.document_uuid = A.uuid AND D.created_by = ?");


      DataTableEntity documentData = baseDao.listTable(sql.toString(), new String[]{directory_uuid, SpringMVCContextHolder.getCurrentUserId()}, fieldSetEntity.getInteger(CmnConst.PAGESIZE), fieldSetEntity.getInteger(CmnConst.CPAGE));


        DataTableEntity documentData = baseDao.listTable(sql.toString(), new String[]{directory_uuid, SpringMVCContextHolder.getCurrentUserId()},


              fieldSetEntity.getInteger(CmnConst.PAGESIZE), fieldSetEntity.getInteger(CmnConst.CPAGE));


      baseDao.listInternationDataTable(documentData, null);


      return documentData;


   }


@@ -193,7 +191,10 @@


         fieldSetEntity.setValue(CmnConst.OPETYPE, opetype);


         fieldSetEntity.setValue(CmnConst.OPE_DOCUMENT, file_name[i]);


         StringBuffer state = new StringBuffer();


         state.append(opetype).append("了[").append(file_name[i]).append("]");


            state.append(opetype)


                    .append("了[")


                    .append(file_name[i])


                    .append("]");


         if (!BaseUtil.strIsNull(file_directory)) {


            state.append("到").append(file_directory).append("目录下");


         }


@@ -222,7 +223,13 @@


         fieldSetEntity.setValue(CmnConst.OPETYPE, opetype);


         fieldSetEntity.setValue(CmnConst.OPE_DOCUMENT, file_name[i]);


         StringBuffer state = new StringBuffer();


         state.append("把[").append(file_name[i]).append("]").append(opetype).append("为[").append(newFile_name[i]).append("]");


            state.append("把[")


                    .append(file_name[i])


                    .append("]")


                    .append(opetype)


                    .append("为[")


                    .append(newFile_name[i])


                    .append("]");


         fieldSetEntity.setValue(CmnConst.STATE, state.toString()); //说明


         fieldSetEntity.setValue(CmnConst.CREATED_BY, user.getUser_id());// 创建人


         fieldSetEntity.setValue(CmnConst.CREATED_UTC_DATETIME, DateUtils.getDateTime());// 创建时间


@@ -298,7 +305,9 @@


         FieldSetEntity org = baseDao.getFieldSetByFilter(CmnConst.PRODUCT_OA_DIRECTORY_RIGHTS, "directory_uuid=?", new String[]{directory_uuid}, false);


         if (verifyOrgExist(org.getString("storage_uuid"))) {


            StringBuffer sql = new StringBuffer();


            sql.append(" SELECT  substring_index(substring_index(a.rigths,',',b.help_topic_id+1),',',-1) fun FROM  PRODUCT_OA_directory_rights a ").append(" INNER join   mysql.help_topic b on b.help_topic_id < (length(a.rigths) - length(replace(a.rigths,',',''))+1) ").append(" WHERE a.directory_uuid = ? ");


                sql.append(" SELECT  substring_index(substring_index(a.rigths,',',b.help_topic_id+1),',',-1) fun FROM  PRODUCT_OA_directory_rights a ")


                        .append(" INNER join   mysql.help_topic b on b.help_topic_id < (length(a.rigths) - length(replace(a.rigths,',',''))+1) ")


                        .append(" WHERE a.directory_uuid = ? ");


            dataTableEntity = baseDao.listTable(sql.toString(), new String[]{directory_uuid});


         }


         StringBuffer button = new StringBuffer();


@@ -351,7 +360,10 @@


      //1为公司文件目录


      if ("1".equals(type)) {


         //String staffId = user.getCurrentStaff().getString("staff_id");


         sql.append(" select a.* from PRODUCT_OA_directory a  ").append(" LEFT JOIN (  SELECT a.directory_uuid FROM PRODUCT_OA_directory_rights a  LEFT JOIN product_sys_organizational_structure_storage b ").append(" on a.storage_uuid = b.uuid WHERE a.rigths like '%3%' AND CONCAT(',',b.staff_ids,',') like ? GROUP BY ").append(" a.directory_uuid) b ON a.uuid = b.directory_uuid  where a.directory_type = 1  and a.org_level_uuid = ? ");


            sql.append(" select a.* from PRODUCT_OA_directory a  ")


                    .append(" LEFT JOIN (  SELECT a.directory_uuid FROM PRODUCT_OA_directory_rights a  LEFT JOIN product_sys_organizational_structure_storage b ")


                    .append(" on a.storage_uuid = b.uuid WHERE a.rigths like '%3%' AND CONCAT(',',b.staff_ids,',') like ? GROUP BY ")


                    .append(" a.directory_uuid) b ON a.uuid = b.directory_uuid  where a.directory_type = 1  and a.org_level_uuid = ? ");


         String staffId = "%" + user.getCurrentStaff().getString("staff_id") + "%";


         param.add(staffId);


         param.add(user.getOrg_level_uuid());


@@ -431,7 +443,9 @@


      //1为公司文件夹


      if (directory_type == 1) {


         StringBuffer sql = new StringBuffer();


         sql.append(" SELECT * FROM PRODUCT_OA_directory_rights  ").append(" WHERE directory_uuid = ? ").append(" AND rigths like '%3%' AND concat(',',storage_uuid,',') like ? ");//3为新增


            sql.append(" SELECT * FROM PRODUCT_OA_directory_rights  ")


                    .append(" WHERE directory_uuid = ? ")


                    .append(" AND rigths like '%3%' AND concat(',',storage_uuid,',') like ? ");//3为新增


         String user_id = String.valueOf(SpringMVCContextHolder.getCurrentUser().getUser_id());


         user_id = "%," + user_id + ",%";


         DataTableEntity dataTableEntity = baseDao.listTable(sql.toString(), new String[]{directory_uuid, user_id});


@@ -464,12 +478,12 @@




   @Override


   public DataTableEntity getDocumentLog(FieldSetEntity fieldSetEntity) throws BaseException {


      return baseDao.listTable("SELECT CONCAT(b.show_name, a.state) log,a.created_utc_datetime FROM PRODUCT_OA_document_log a LEFT JOIN product_sys_staffs b on a.created_by = b.user_id WHERE document_uuid = ? ORDER BY a.created_utc_datetime DESC", new String[]{fieldSetEntity.getString(CmnConst.DOCUMENT_UUID)}, fieldSetEntity.getInteger(CmnConst.PAGESIZE), fieldSetEntity.getInteger(CmnConst.CPAGE));


        return baseDao.listTable("SELECT CONCAT(b.show_name, a.state) log,a.created_utc_datetime FROM PRODUCT_OA_document_log a LEFT JOIN product_sys_staffs b on a.created_by = b.user_id WHERE document_uuid = ? ORDER BY a.created_utc_datetime DESC",


                new String[]{fieldSetEntity.getString(CmnConst.DOCUMENT_UUID)}, fieldSetEntity.getInteger(CmnConst.PAGESIZE), fieldSetEntity.getInteger(CmnConst.CPAGE));


   }




   /**


    * 文档收藏


    *


    * @param fse


    * @return


    */


@@ -481,7 +495,6 @@




   /**


    * 文档取消收藏


    *


    * @param documentUUID


    * @return


    */


@@ -491,23 +504,21 @@




   /**


    * 查询文档历史版本


    *


    * @param documentUUID


    * @return


    */


   public DataTableEntity findDocumentHistory(String documentUUID) {


      StringBuilder sql = new StringBuilder();


      sql.append("SELECT A.*,B.file_name\n");


       sql.append("SELECT A.*,B.file_name");


      sql.append("FROM product_oa_document_history A \n");


      sql.append("LEFT JOIN product_oa_document B ON B.uuid = A.document_uuid \n");


      sql.append("WHERE A.document_uuid = ?\n");


       sql.append("LEFT JOIN product_oa_document_history B ON B.uuid = A.document_uuid \n");


       sql.append("WHERE A.document_uuid = ?");


      sql.append("ORDER BY A.version_number");


      return baseDao.listTable(sql.toString(), new Object[]{documentUUID});


   }




   /**


    * 文档最新版本保存


    *


    * @param fse


    * @return


    */


@@ -515,7 +526,7 @@


   public boolean documentSaveNewVersion(FieldSetEntity fse) {


      // 获取文档数据和最大编号


      StringBuilder sql = new StringBuilder();


      sql.append("SELECT A.*, IFNULL(B.max_version_number, '0')AS max_version_number \n");


       sql.append("SELECT A.*, IFNULL(B.max_version_number, 'v0')AS max_version_number \n");


      sql.append("FROM product_oa_document A \n");


      sql.append("LEFT JOIN ( \n");


      sql.append("    SELECT document_uuid, MAX(version_number) AS max_version_number \n");


@@ -524,33 +535,19 @@


      sql.append("    GROUP BY document_uuid \n");


      sql.append(") B ON B.document_uuid = A.uuid \n");


      sql.append("WHERE uuid = ? \n");


      String documentUuid = fse.getString("document_uuid");


      FieldSetEntity fseDocument = baseDao.getFieldSetEntityBySQL(sql.toString(), new Object[]{documentUuid, documentUuid}, false);


       FieldSetEntity fseDocument = baseDao.getFieldSetEntityBySQL(sql.toString(), new Object[] {fse.getString("document_uuid"),fse.getString("document_uuid")}, false);


      if (fseDocument == null) {


         throw new BaseException(DocumentCode.DOCUMENT_DATA_NO_EXIST.getValue(), DocumentCode.DOCUMENT_DATA_NO_EXIST.getText());


      }




      String attachmentUuid = fse.getString("attachment_uuid");


      FieldSetEntity fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ATTACHMENTS, attachmentUuid, false);


      fseDocument.setValue("file_size", fieldSetEntity.getString(CmnConst.ATTACHMENT_SIZE));


      fseDocument.setValue("file_name", fieldSetEntity.getString("file_name"));


      fseDocument.setValue("attachments_uuid", attachmentUuid);


      fseDocument.setValue("latest_version", fseDocument.getInteger("max_version_number") + 1);




       fseDocument.setValue("attachments_uuid", fse.getString("attachment_uuid"));


      baseDao.saveFieldSetEntity(fseDocument);




      //创建文档版本数据容器


      FieldSetEntity fseDocumentHistory = new FieldSetEntity(CmnConst.PRODUCT_OA_DOCUMENT_HISTORY);


      BaseUtil.createCreatorAndCreationTime(fseDocumentHistory);


      fseDocumentHistory.setValue("document_uuid", documentUuid);


      fseDocumentHistory.setValue("attachment_uuid", attachmentUuid);


      fseDocumentHistory.setValue("version_number", fseDocument.getObject("latest_version"));


      return baseDao.saveFieldSetEntity(fseDocumentHistory);


       fse.setValue("version_number", versionNUmberAddne(fseDocument.getString("max_version_number")));


       return baseDao.saveFieldSetEntity(fse);


   }




   /**


    * 文档版本+1


    *


    * @param originNumber


    * @return


    */


@@ -639,13 +636,13 @@


      StringBuilder sb = new StringBuilder();


      List<String> param = new ArrayList<>();


      sb.append(" SELECT b.* FROM (");


      sb.append(" SELECT t.uuid,t.file_name,s.show_name,t.created_utc_datetime,count(t.uuid) as applyCount");


        sb.append(" SELECT t.uuid,t.file_name,t.file_size,s.show_name,t.created_utc_datetime,count(t.uuid) as applyCount");


      sb.append(" FROM product_oa_document_borrow_sub b");


      sb.append(" JOIN product_oa_document t");


      sb.append(" on b.sub_uuid=t.uuid");


      sb.append(" JOIN product_sys_staffs s ");


      sb.append(" on t.created_by=s.user_id");


      sb.append(" group by t.file_name,t.uuid,s.show_name,t.created_utc_datetime");


        sb.append(" group by t.file_name,t.uuid,s.show_name,t.created_utc_datetime,t.file_size");


      sb.append(" )b order by  b.applyCount asc");


      DataTableEntity dataTableEntity = baseDao.listTable(sb.toString(), param.toArray());


      return dataTableEntity;


@@ -658,14 +655,14 @@


      sb.append(" SELECT a.borrower,a.show_name,a.applayCount,a.applayFileCount ");


      sb.append(" FROM (");


      sb.append(" SELECT w.borrower,s.show_name,");


      sb.append(" (select   count(borrower)  from  product_oa_document_borrow group by borrower ) as  applayCount,");


        sb.append(" count( borrower )  AS applayCount,");


      sb.append(" count(sub_uuid) as applayFileCount ");


      sb.append(" FROM product_oa_document_borrow  w ");


      sb.append(" JOIN product_oa_document_borrow_sub b");


        sb.append(" left JOIN product_oa_document_borrow_sub b");


      sb.append(" on b.borrow_uuid=w.uuid");


      sb.append(" JOIN product_oa_document t");


        sb.append(" left JOIN product_oa_document t");


      sb.append(" on b.sub_uuid=t.uuid");


      sb.append(" JOIN product_sys_staffs s");


        sb.append(" left JOIN product_sys_staffs s");


      sb.append(" on w.borrower=s.user_id");


      sb.append(" GROUP BY w.borrower,s.show_name");


      sb.append(" )a");