commit

许鹏程

2024-09-14 cf0a6437bdfedad6b3eb8ec02ecf468457f56960

 src/main/java/com/product/file/service/DocumentDirectoryService.java

@@ -3,7 +3,7 @@
import com.alibaba.fastjson.JSONArray;
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;
@@ -16,11 +16,14 @@
import com.product.file.config.DocumentCode;
import com.product.file.service.ide.IDocumentDirectoryService;
import com.product.module.sys.entity.SystemUser;
import com.product.quartz.service.impl.SysJobService;
import com.product.util.BaseUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
@@ -35,240 +38,523 @@
@Component
public class DocumentDirectoryService extends AbstractBaseService implements IDocumentDirectoryService {

  @Autowired
  public BaseDao baseDao;
  @Autowired
  public DocumentDirectoryService documentDirectoryService;
   @Autowired
   public BaseDao baseDao;
   @Autowired
   public DocumentDirectoryService documentDirectoryService;
   @Autowired
   SysJobService sysJobService;
   /**
    * 单位文件夹树
    *
    * @return
    */
   public DataTableEntity allDirectoryTree() {
      DataTableEntity dtTree = baseDao.listTable(CmnConst.PRODUCT_OA_DIRECTORY, "directory_type = 1");
      if (!BaseUtil.dataTableIsEmpty(dtTree)) {
         return BaseUtil.dataTableToTreeTable(dtTree, CmnConst.TRICODE, CmnConst.TRICODE_PARENT, null);
      }
      return dtTree;
   }

  @Override
  @Transactional
  public String addDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException {
   /**
    * 文档目录保存
    *
    * @param fse
    * @return
    */
   @Transactional
   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 {
         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);
            // 刷新code
            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 + "-%"});
            // 刷新层级
            StringBuilder sb = new StringBuilder();
            sb.append("UPDATE product_oa_directory \n");
            sb.append("SET directory_tier = ( \n");
            sb.append("    (LENGTH(tricode) - LENGTH(REPLACE(tricode, '-', '')) + 1) \n");
            sb.append(") \n");
            sb.append("WHERE tricode LIKE ? \n");
            baseDao.executeUpdate(sb.toString(), new Object[] {tricode + "%"});
         }else {
            tricode = fseOrigin.getString(CmnConst.TRICODE);
         }
      }
      fse.setValue(CmnConst.TRICODE, tricode);
      fse.setValue(CmnConst.DIRECTORY_TIER, tricode.split("-").length);
      return baseDao.saveFieldSetEntity(fse);
   }
   @Transactional
   @Override
   public boolean saveFileConfig(FieldSetEntity fse) {
      //获取功能表名
      FieldSetEntity functionUuid = baseDao.getFieldSet(CmnConst.PRODUCT_SYS_FUNCTIONS, fse.getString("function_uuid"), false);

    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;
      }
    }else {
      flag = false;
    }

    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);
  }

  @Override
  @Transactional
  public boolean delDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException {
    String uuid = fieldSetEntity.getString(CmnConst.UUID);
    String directory_type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
    String filter = "";
    if("2".equals(directory_type)){
      filter = " AND " +  "created_by = " + SpringMVCContextHolder.getCurrentUserId();
    }
    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});
    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});
    }else {
      throw new BaseException(DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getValue(), DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getText(), this.getClass(),"public boolean delDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException");
    }
  }

  /**
   * 获取当前文件路径
   * @param fieldSetEntity
   * @return
   * @throws BaseException
   */
  @Override
  public DataTableEntity getDirectoryStructure(FieldSetEntity fieldSetEntity) throws BaseException {
    String uuid = fieldSetEntity.getString(CmnConst.DIRECTORY_UUID);
    fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.product_oa_DIRECTORY, uuid, false);
    String triCode = fieldSetEntity.getString(CmnConst.TRICODE);
    String type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
    List<String> codeList = ListUtils.newArrayList();
    //拆分为上级目录
  if(triCode.indexOf('-') != -1) {
    do {
      codeList.add(0, triCode);
      triCode = triCode.substring(0, triCode.lastIndexOf('-'));
    } while (triCode.indexOf('-') != -1);
      codeList.add(0,triCode);
  }else {
      codeList.add(triCode);
  }
  SystemUser user = SpringMVCContextHolder.getCurrentUser();
  DataTableEntity dataTableEntity;
  //单位文件夹
  if("1".equals(type)){
    codeList.add(0,user.getOrg_level_uuid());
    dataTableEntity = baseDao.listTable(CmnConst.product_oa_DIRECTORY,"directory_type = 1 AND org_level_uuid = ? AND "+BaseUtil.buildQuestionMarkFilter(CmnConst.TRICODE,codeList.size()-1,true),codeList.toArray(),"tricode");
   //个人文件夹
  }else {
    codeList.add(0,String.valueOf(user.getUser_id()));
    dataTableEntity = baseDao.listTable(CmnConst.product_oa_DIRECTORY,"directory_type = 2 AND created_by = ? AND "+BaseUtil.buildQuestionMarkFilter(CmnConst.TRICODE,codeList.size()-1,true),codeList.toArray(),"tricode");
  }
    baseDao.listInternationDataTable(dataTableEntity, null);
    return dataTableEntity;
  }
      DataTableEntity field = baseDao.listTable(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD, "table_uuid=? and field_name=?", new String[]{functionUuid.getString("table_uuid"), "archive_flag"});
        if (field.getRows()==0){
         FieldSetEntity fs = new FieldSetEntity();
         fs.setTableName(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD);
         fs.setValue("table_uuid",functionUuid.getString("table_uuid"));
         fs.setValue("field_name","archive_flag");
         fs.setValue("field_type","int");
         fs.setValue("field_show_name","归档标识");
         fs.setValue("field_description","归档标识");
         fs.setValue("field_length",10);
         fs.setValue("field_unit",0);
         fs.setValue("is_required",0);
         fs.setValue("is_unique",0);
         fs.setValue("is_filter",0);
         fs.setValue("field_sequence",0);
         fs.setValue("created_by",SpringMVCContextHolder.getCurrentUser().getUser_id());
         fs.setValue("created_utc_datetime",new Date());
         baseDao.saveFieldSetEntity(fs);
         FieldSetEntity table = baseDao.getFieldSet(CmnConst.PRODUCT_SYS_DATAMODEL_TABLE, functionUuid.getString("table_uuid"), false);
         baseDao.executeUpdate("ALTER TABLE "+table.getString("table_name")+" ADD COLUMN archive_flag INT(4) COMMENT '归档标识';");
      }


  @Override
  public JSONArray treeListAll(FieldSetEntity fieldSetEntity) throws BaseException {
    //关联公司uuid
    String directory_type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
    //公司文件夹
    DataTableEntity data;
    SystemUser user = SpringMVCContextHolder.getCurrentUser();
    if("1".equals(directory_type)){
      String org_level_uuid = user.getOrg_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();
      data = baseDao.listTable(CmnConst.product_oa_DIRECTORY, " directory_type = 2 AND created_by = ?", new Object[]{userId}, "tricode");
    }
    baseDao.listInternationDataTable(data, null);
    JSONArray menus = this.encapsulationTree(data);
    //获取当前公司
    JSONObject orgLevelInfo = new JSONObject();
    orgLevelInfo.put("directory_name", user.getOrg_level_name());
    orgLevelInfo.put("tricode", "");
    orgLevelInfo.put("org_level_uuid",  user.getOrg_level_uuid());
    orgLevelInfo.put("children",menus);
    JSONArray array = new JSONArray();
    array.add(orgLevelInfo);
    return array;
  }
  /**
   * 封装树方法
   * @param
   * @return
   * @throws BaseException
   */
  @Override
  public JSONArray encapsulationTree(DataTableEntity data) throws BaseException {
    JSONArray menus = new JSONArray();
    JSONObject parent_menu = new JSONObject();
    if (!BaseUtil.dataTableIsEmpty(data)) {
      for (int i = 0; i < data.getRows(); i++) {
        FieldSetEntity fs = data.getFieldSetEntity(i);
        JSONObject menu = BaseUtil.fieldSetEntityToJson(fs);
        String tricode = fs.getString(CmnConst.TRICODE_PARENT);
        if (StringUtils.isEmpty(tricode) || parent_menu.getString(tricode) == null) {
          menus.add(menu);
        } else {// 上级目录
          JSONObject pm = parent_menu.getJSONObject(tricode);
          JSONArray subs = pm.getJSONArray(CmnConst.CHILDREN);
          JSONArray submenus = null;
          if (subs == null) {
            submenus = new JSONArray();
            pm.put(CmnConst.CHILDREN, submenus);
          } else {
            submenus = subs;
          }
          submenus.add(menu);
        }
        parent_menu.put(menu.getString(CmnConst.TRICODE), menu);
      }
    }
    return menus;
  }
      FieldSetEntity timedTask = baseDao.getFieldSetByFilter("product_sys_timed_task", "job_name=? and invoke_target like concat('%',?,'%') ", new String[]{fse.getString("filing_name") + "定时", fse.getString("uuid")}, false);
        String timeTaskUuid=null;
      if (!FieldSetEntity.isEmpty(timedTask)){
         timeTaskUuid=timedTask.getUUID();
      }
      boolean re = baseDao.saveFieldSetEntity(fse);
      createdTimeTask(fse.getString("filing_name"),fse.getString("cron"),fse.getUUID(),timeTaskUuid);
      return re;
   }
   private FieldSetEntity createdTimeTask(String target_table, String execute_time, String task_uuid, String timeTaskUuid) throws BaseException {
      //
      FieldSetEntity fse = new FieldSetEntity();
      try {
         fse.setTableName("product_sys_timed_task");
         fse.setValue("uuid", timeTaskUuid);
         fse.setValue("job_name", target_table + "定时");//任务名称
         fse.setValue("job_group", "system");//分组
         fse.setValue("invoke_target", "documentDirectoryService.fileTime('" + task_uuid + "')");//调用目标字符串
         fse.setValue("cron_expression", execute_time);//cron表达式
         fse.setValue("misfire_policy", "3");//错误执行策略  只执行一次
         fse.setValue("concurrent", 0);//不允许并发执行
         fse.setValue("remark", target_table + "定时");
         fse.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
         fse.setValue("created_utc_datetime", new Date());
         fse.setValue("status", 1);
         fse.setValue("is_conceal", 1);
         if (!com.product.common.lang.StringUtils.isEmpty(timeTaskUuid)) {
            sysJobService.updateJob(fse);
         } else {
            sysJobService.insertJob(fse);
         }
         return fse;
      } catch (Exception e) {
         e.printStackTrace();
         throw new BaseException(DocumentCode.CRATED_TIMED_TASK_FAIL);
      }
//
   }
   /**
    * 归档定时任务
    */
   @Transactional
    public void fileTime(String uuid){
      FieldSetEntity fs = baseDao.getFieldSet(CmnConst.PRODUCT_AO_FILING_CONFIG,uuid,false);
      FieldSetEntity functionUuid = baseDao.getFieldSet(CmnConst.PRODUCT_SYS_FUNCTIONS, fs.getString("function_uuid"), false);
      DataTableEntity fieldTable = baseDao.listTable(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD, "table_uuid=? and (field_type='file' or field_name='flow_flag')", new String[]{functionUuid.getString("table_uuid")}," field_type ");

  @Override
  public FieldSetEntity documentDirectoryInfo(FieldSetEntity fieldSetEntity) throws BaseException {
    String uuid = fieldSetEntity.getString(CmnConst.UUID);
    return baseDao.getFieldSetEntity(CmnConst.product_oa_DIRECTORY, uuid, true);
  }
      FieldSetEntity table = baseDao.getFieldSet(CmnConst.PRODUCT_SYS_DATAMODEL_TABLE, functionUuid.getString("table_uuid"), false);
      StringBuilder sb = new StringBuilder();
      sb.append("select  concat(");
      String flow_flag="";
         for (int i = 0; i <fieldTable.getRows() ; i++) {
            if (i==0&&!fieldTable.getString(i, "field_name").equals("flow_flag")){
               sb.append("a.").append(fieldTable.getString(i, "field_name"));
            }else if (i!=0&&!fieldTable.getString(i, "field_name").equals("flow_flag")){
               sb.append(",',',").append("a.").append(fieldTable.getString(i, "field_name"));

  /**
   * 移动到目录列表（根据当前用户过滤展示目录列表）
   * 获取用户有新增（上传）权限的列表
   * @param
   * @return
   * @throws BaseException
   */
  @Override
  public DataTableEntity moveToList(FieldSetEntity fse) throws BaseException {
    String type = fse.getString(CmnConst.DIRECTORY_TYPE);
    StringBuffer sql = new StringBuffer();
    Integer userId = SpringMVCContextHolder.getCurrentUser().getUser_id();
    StringBuffer param = new StringBuffer();
    //1为单位文件夹
    if("1".equals(type)) {
      param.append("%").append(userId).append("%");
      sql.append("SELECT a.* FROM "+CmnConst.product_oa_DIRECTORY+" a LEFT JOIN ")
              .append(" product_oa_directory_rights b ON a.uuid = b.directory_uuid ")
              .append(" LEFT JOIN product_sys_organizational_structure_storage c on b.storage_uuid = c.uuid ")
              .append(" WHERE a.directory_type = 1 AND b.rigths like '%3%' AND c.staff_ids like ? GROUP BY a.tricode ");
    }else {
      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()});
    baseDao.listInternationDataTable(dataTableEntity, null);
    return dataTableEntity;
  }
            }else if (fieldTable.getString(i,"field_name").equals("flow_flag")){
               flow_flag=" and a.flow_flag=2";
            }
         }
      sb.append(") file,a.uuid,b.uuid directory_uuid,");
      sb.append("a.").append(fs.getString("field_title"));
      sb.append(",a.").append(fs.getString("field_send_time")).append(" send_time");
      sb.append(",c.user_name ");
      sb.append(" from ");
      sb.append(table.getString("table_name")).append(" a ");
      sb.append(" LEFT JOIN (SELECT uuid,directory_name,filing_config_field_uuid FROM product_oa_directory where filing_config_table=? and tricode_parent='").append(fs.getString("filing_catalog")).append("')  b ");
      sb.append("on a.").append(fs.getString("field_title")).append("=b.directory_name and a.uuid=b.filing_config_field_uuid   ");

  @Override
  @Transactional
  public boolean upDocumentDirectoryName(FieldSetEntity fse) throws BaseException {
    String uuid = fse.getString(CmnConst.UUID);
    String directoryName = fse.getString(CmnConst.DIRECTORY_NAME);
    FieldSetEntity docField = baseDao.getFieldSetEntity(CmnConst.product_oa_DIRECTORY, uuid, false);
    docField.setValue(CmnConst.DIRECTORY_NAME, directoryName);
    return baseDao.update(docField);
  }
      sb.append(" LEFT JOIN  product_sys_users c on a.").append(fs.getString("field_send_user")).append("=c.user_id");
      sb.append(" where (a.archive_flag!=1 or a.archive_flag is null) ");
      sb.append(flow_flag);
      sb.append(" ORDER BY a.id LIMIT 1000 ");

      //获取流程里面的附件sql
      StringBuffer nodeSal = new StringBuffer();
      nodeSal.append(" select  a.uuid,b.flow_attachment  from ");
      nodeSal.append(table.getString("table_name")).append(" a ");
      nodeSal.append(" LEFT JOIN product_sys_flow_detail b on a.uuid=b.record_uuid ");
      nodeSal.append(" where (a.archive_flag!=1 or a.archive_flag is null) and b.flow_attachment is not null");
      nodeSal.append(flow_flag);
      nodeSal.append(" ORDER BY a.id LIMIT 1000 ");

      fieldLimit(sb.toString(),nodeSal.toString(),fs.getString("field_title"),fs.getString("filing_catalog"),fs.getString("turn_button"),table.getString("table_name"));


   }

   /**
    *
    * @param sql
    * @param field_title 标题字段
    * @param filing_catalog 父级归档目录
    */
   private void  fieldLimit(String sql,String nodeSal,String field_title,String filing_catalog,String turn_button,String table){

      //获取父类文档信息
      FieldSetEntity parentDirectory = baseDao.getFieldSetByFilter(CmnConst.PRODUCT_OA_DIRECTORY, "tricode=?", new String[]{filing_catalog}, false);
      DataTableEntity fieldDt = baseDao.listTable(sql, new String[]{table});
      //获取流程附件并加入到file里
      DataTableEntity nodeDt = baseDao.listTable(nodeSal, new String[]{});
      for (int i = 0; i <nodeDt.getRows() ; i++) {
         FieldSetEntity fieldfs = fieldDt.getFieldSetEntity(nodeDt.getString(i, "uuid")).get(0);
            if (!FieldSetEntity.isEmpty(fieldfs)){
            if (StringUtils.isEmpty(fieldfs.getString("file"))){
               fieldfs.setValue("file",nodeDt.getString(i,"flow_attachment"));
            }else {
               fieldfs.setValue("file",fieldfs.getString("file")+","+nodeDt.getString(i,"flow_attachment"));
            }
         }
      }

      ArrayList<String> fileList = new ArrayList<>();
      for (int i = 0; i <fieldDt.getRows() ; i++) {
         String file = fieldDt.getString(i, "file");
         if (!StringUtils.isEmpty(file)){
            for (int j = 0; j < file.split(",").length; j++) {
               fileList.add(file.split(",")[j]);
            }
         }
      }
      DataTableEntity attachments = baseDao.listTable(CmnConst.PRODUCT_SYS_ATTACHMENTS, BaseUtil.buildQuestionMarkFilter("uuid", fileList.size(), true), fileList.toArray(new String[0]));
      if (fieldDt.getRows()>0) {
         for (int i = 0; i < fieldDt.getRows(); i++) {
            FieldSetEntity fs = fieldDt.getFieldSetEntity(i);
            String directoryUUID=null;
            if (StringUtils.isEmpty(fs.getString("directory_uuid"))){
                  //根据上级目录获取目录编号
                  String tricode = CodeUtil.getNewCodeByTemp(CmnConst.PRODUCT_OA_DIRECTORY, CmnConst.TRICODE, filing_catalog);
                  //获取目录名称
                  String title = fs.getString(field_title);
                  directoryUUID = addDirectory(title, tricode, filing_catalog, parentDirectory.getInteger("directory_tier") + 1,fs.getUUID(),table);

            }else {
               directoryUUID=fs.getString("directory_uuid");
            }
            String file = fs.getString("file");
            if (!StringUtils.isEmpty(file)){
               for (int j = 0; j <file.split(",").length ; j++) {
                  //创建文件
                  String f = file.split(",")[j];
                  if (StringUtils.isEmpty(file.split(",")[j])||DataTableEntity.isEmpty(attachments)){
                     continue;
                  }
                  FieldSetEntity attachmentsFs = attachments.getFieldSetEntity(f).get(0);
                  FieldSetEntity document = new FieldSetEntity();
                  document.setTableName(CmnConst.PRODUCT_OA_DOCUMENT);
                  document.setValue("directory_uuid",directoryUUID);
                  document.setValue("file_name",attachmentsFs.getString("file_name"));
                  document.setValue("attachments_uuid",f);
                  String[] type = f.split("\\.");
                  document.setValue("file_type",type[type.length-1]);
                  document.setValue("created_by", 1);
                  document.setValue("created_utc_datetime", new Date());
                  document.setValue("file_size", attachmentsFs.getString("attachment_size"));
                  baseDao.saveFieldSetEntity(document);
               }
            }
            FieldSetEntity document = new FieldSetEntity();
            document.setTableName(CmnConst.PRODUCT_OA_DOCUMENT);
            document.setValue("directory_uuid",directoryUUID);
            document.setValue("file_name",fs.getString(field_title)+" "+fs.getString("user_name")+" "+fs.getString("send_time"));
            document.setValue("created_by", 1);
            document.setValue("created_utc_datetime", new Date());
            document.setValue("turn_button", turn_button);
            document.setValue("file_size", 0);
            document.setValue("file_type","虚拟文档");

            baseDao.saveFieldSetEntity(document);
            baseDao.executeUpdate("UPDATE "+table+" set archive_flag =1 where uuid=?",new String[]{fs.getUUID()});
         }
         fieldLimit(sql,nodeSal,field_title,filing_catalog,turn_button,table);
      }
   }

   /**
    *
    * @param field_title 目录标题
    * @param tricode  编号
    * @param tricode_parent 父级编号
    * @param directory_tier 目录层级
    */

    private String addDirectory(String field_title,String tricode,String tricode_parent,Integer directory_tier,String filing_config_field_uuid,String table){
        //新建目录
      FieldSetEntity fsDirectory = new FieldSetEntity();
      fsDirectory.setTableName(CmnConst.PRODUCT_OA_DIRECTORY);
      fsDirectory.setValue("created_by", 1);
      fsDirectory.setValue("created_utc_datetime", new Date());
      fsDirectory.setValue("org_level_uuid", "00000000-0000-0000-0000-000000000000");
      fsDirectory.setValue("directory_name", field_title);
      fsDirectory.setValue("directory_tier", directory_tier);
      fsDirectory.setValue("directory_type", 1);
      fsDirectory.setValue("tricode", tricode);
      fsDirectory.setValue("tricode_parent", tricode_parent);
      fsDirectory.setValue("filing_config_field_uuid", filing_config_field_uuid);
      fsDirectory.setValue("filing_config_table", table);

      baseDao.saveFieldSetEntity(fsDirectory);
      return fsDirectory.getUUID();
   }






   @Override
   @Transactional
   public boolean delDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException {
      String uuid = fieldSetEntity.getString(CmnConst.UUID);
      String directory_type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
      String filter = "";
      if ("2".equals(directory_type)) {
         filter = " AND " + "created_by = " + SpringMVCContextHolder.getCurrentUserId();
      }
      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});
      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});
      } else {
         throw new BaseException(DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getValue(),
               DocumentCode.DOCUMENT_CATALOG_DELETE_FAIL.getText(), this.getClass(),
               "public boolean delDocumentDirectory(FieldSetEntity fieldSetEntity) throws BaseException");
      }
   }

   /**
    * 获取当前文件路径
    *
    * @param fieldSetEntity
    * @return
    * @throws BaseException
    */
   @Override
   public DataTableEntity getDirectoryStructure(FieldSetEntity fieldSetEntity) throws BaseException {
      String uuid = fieldSetEntity.getString(CmnConst.DIRECTORY_UUID);
      fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_DIRECTORY, uuid, false);
      String triCode = fieldSetEntity.getString(CmnConst.TRICODE);
      String type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
      List<String> codeList = ListUtils.newArrayList();
      // 拆分为上级目录
      if (triCode.indexOf('-') != -1) {
         do {
            codeList.add(0, triCode);
            triCode = triCode.substring(0, triCode.lastIndexOf('-'));
         } while (triCode.indexOf('-') != -1);
         codeList.add(0, triCode);
      } else {
         codeList.add(triCode);
      }
      SystemUser user = SpringMVCContextHolder.getCurrentUser();
      DataTableEntity dataTableEntity;
      // 单位文件夹
      if ("1".equals(type)) {
         codeList.add(0, user.getOrg_level_uuid());
         dataTableEntity = baseDao.listTable(CmnConst.PRODUCT_OA_DIRECTORY,
               "directory_type = 1 AND org_level_uuid = ? AND "
                     + BaseUtil.buildQuestionMarkFilter(CmnConst.TRICODE, codeList.size() - 1, true),
               codeList.toArray(), "tricode");
         // 个人文件夹
      } else {
         codeList.add(0, String.valueOf(user.getUser_id()));
         dataTableEntity = baseDao.listTable(CmnConst.PRODUCT_OA_DIRECTORY,
               "directory_type = 2 AND created_by = ? AND "
                     + BaseUtil.buildQuestionMarkFilter(CmnConst.TRICODE, codeList.size() - 1, true),
               codeList.toArray(), "tricode");
      }
      baseDao.listInternationDataTable(dataTableEntity, null);
      return dataTableEntity;
   }

   @Override
   public JSONArray treeListAll(FieldSetEntity fieldSetEntity) throws BaseException {
      // 关联公司uuid
      String directory_type = fieldSetEntity.getString(CmnConst.DIRECTORY_TYPE);
      // 公司文件夹
      DataTableEntity data;
      SystemUser user = SpringMVCContextHolder.getCurrentUser();
      StringBuffer sql = new StringBuffer();
      sql.append("SELECT a.*,ifnull(b.number,0) number FROM PRODUCT_OA_directory a LEFT JOIN ");
      sql.append(
            "(SELECT COUNT(*) number,directory_uuid FROM PRODUCT_OA_document GROUP BY directory_uuid)  b on a.uuid=b.directory_uuid ");

      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(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(CmnConst.PRODUCT_OA_DIRECTORY, " directory_type = 2 AND created_by = ?", new Object[]{userId}, "tricode");
      }


      baseDao.listInternationDataTable(data, null);
      JSONArray menus = this.encapsulationTree(data);
      // 获取当前公司
      JSONObject orgLevelInfo = new JSONObject();
      String orgLevelName = user.getOrg_level_name();

      orgLevelInfo.put("directory_name", orgLevelName);
      orgLevelInfo.put("tricode", "");
      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 = ? ) GROUP BY sub_uuid ) 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
    */
   @Override
   public JSONArray encapsulationTree(DataTableEntity data) throws BaseException {
      JSONArray menus = new JSONArray();
      JSONObject parent_menu = new JSONObject();
      if (!BaseUtil.dataTableIsEmpty(data)) {
         for (int i = 0; i < data.getRows(); i++) {
            FieldSetEntity fs = data.getFieldSetEntity(i);
            JSONObject menu = BaseUtil.fieldSetEntityToJson(fs);
            String tricode = fs.getString(CmnConst.TRICODE_PARENT);
            if (StringUtils.isEmpty(tricode) || parent_menu.getString(tricode) == null) {
               menus.add(menu);
            } else {// 上级目录
               JSONObject pm = parent_menu.getJSONObject(tricode);
               JSONArray subs = pm.getJSONArray(CmnConst.CHILDREN);
               JSONArray submenus = null;
               if (subs == null) {
                  submenus = new JSONArray();
                  pm.put(CmnConst.CHILDREN, submenus);
               } else {
                  submenus = subs;
               }
               submenus.add(menu);
            }
            parent_menu.put(menu.getString(CmnConst.TRICODE), menu);
         }
      }
      return menus;
   }

   @Override
   public FieldSetEntity documentDirectoryInfo(FieldSetEntity fieldSetEntity) throws BaseException {
      String uuid = fieldSetEntity.getString(CmnConst.UUID);
      return baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_DIRECTORY, uuid, true);
   }

   /**
    * 移动到目录列表（根据当前用户过滤展示目录列表） 获取用户有新增（上传）权限的列表
    *
    * @param
    * @return
    * @throws BaseException
    */
   @Override
   public DataTableEntity moveToList(FieldSetEntity fse) throws BaseException {
      String type = fse.getString(CmnConst.DIRECTORY_TYPE);
      StringBuffer sql = new StringBuffer();
      Integer userId = SpringMVCContextHolder.getCurrentUser().getUser_id();
      StringBuffer param = new StringBuffer();
      // 1为单位文件夹
      if ("1".equals(type)) {
         param.append("%").append(userId).append("%");
         sql.append("SELECT a.* FROM " + CmnConst.PRODUCT_OA_DIRECTORY + " a LEFT JOIN ")
               .append(" PRODUCT_OA_directory_rights b ON a.uuid = b.directory_uuid ")
               .append(" LEFT JOIN product_sys_organizational_structure_storage c on b.storage_uuid = c.uuid ")
               .append(" WHERE a.directory_type = 1 AND b.rigths like '%3%' AND c.staff_ids like ? GROUP BY a.tricode ");
      } else {
         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()});
      baseDao.listInternationDataTable(dataTableEntity, null);
      return dataTableEntity;
   }

   @Override
   @Transactional
   public boolean upDocumentDirectoryName(FieldSetEntity fse) throws BaseException {
      String uuid = fse.getString(CmnConst.UUID);
      String directoryName = fse.getString(CmnConst.DIRECTORY_NAME);
      FieldSetEntity docField = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_DIRECTORY, uuid, false);
      docField.setValue(CmnConst.DIRECTORY_NAME, directoryName);
      return baseDao.update(docField);
   }
}