package com.product.file.service;
|
|
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.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.core.util.CodeUtil;
|
import com.product.file.config.CmnConst;
|
import com.product.file.config.DocumentCode;
|
import com.product.file.service.ide.IDocumentDirectoryService;
|
import com.product.module.sys.entity.SystemUser;
|
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.List;
|
|
/**
|
* Copyright lx
|
*
|
* @Title: ClaimExpenseController
|
* @Project: lx-SERVER
|
* @Date: 2020-11-18 11:30:48
|
* @Author: luoxin
|
* @Description: 文件夹管理server
|
*/
|
@Component
|
public class DocumentDirectoryService extends AbstractBaseService implements IDocumentDirectoryService {
|
|
@Autowired
|
public BaseDao baseDao;
|
@Autowired
|
public DocumentDirectoryService documentDirectoryService;
|
|
@Override
|
@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;
|
}
|
}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;
|
}
|
|
|
@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;
|
}
|
|
@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);
|
}
|
}
|
