package com.product.administration.service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.common.collect.Lists;
|
import com.product.admin.service.PublicService;
|
import com.product.administration.config.CmnConst;
|
import com.product.administration.service.ide.IKnowledgeSharingService;
|
import com.product.common.utils.StringUtils;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.file.service.FileManagerService;
|
import com.product.util.BaseUtil;
|
import org.apache.commons.codec.binary.Base64;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Arrays;
|
import java.util.List;
|
|
/**
|
* Copyright © 6c
|
*
|
* @Date 2022年06月14日 15:45
|
* @Author 6c
|
* @Description 知识共享
|
*/
|
@Component
|
public class KnowledgeSharingService implements IKnowledgeSharingService {
|
@Autowired
|
private BaseDao baseDao;
|
@Autowired
|
private PublicService publicService;
|
@Autowired
|
private FileManagerService fileManagerService;
|
|
/**
|
* 保存
|
* @param fse
|
* @return
|
*/
|
@Override
|
@Transactional
|
public String save(FieldSetEntity fse) {
|
String uuid = publicService.saveFieldSetEntity(fse);
|
|
perfectTypeTag(fse.getString(CmnConst.TYPE), 1);
|
perfectTypeTag(fse.getString(CmnConst.TAG), 2);
|
|
return uuid;
|
}
|
|
/**
|
* 将系统中没有的标签或者分类存入系统中
|
* @param typeTag
|
*/
|
private void perfectTypeTag(String typeTag, int type) {
|
DataTableEntity dte = type == 1 ? getType() : getTag();
|
List<Object> list = Lists.newArrayList(Arrays.asList(dte.getFieldAllValues(CmnConst.NAME)));
|
List<Object> curList = Lists.newArrayList(Arrays.asList(typeTag.split(",")));
|
curList.removeAll(list);
|
curList.forEach(name -> {
|
FieldSetEntity typeTagFse = new FieldSetEntity();
|
typeTagFse.setTableName(CmnConst.PRODUCT_OA_KNOWLEDGE_SHARING_TAG);
|
typeTagFse.setValue(CmnConst.NAME, name);
|
typeTagFse.setValue(CmnConst.TYPE, type);
|
publicService.saveFieldSetEntity(typeTagFse);
|
});
|
}
|
|
/**
|
* 获取详情
|
* @param fse
|
* @return
|
*/
|
public FieldSetEntity viewInfo(FieldSetEntity fse) {
|
FieldSetEntity resultFse = publicService.getFieldSetEntity(fse, false);
|
baseDao.loadPromptData(resultFse);
|
return resultFse;
|
}
|
|
/**
|
* 删除
|
* @param fse
|
*/
|
@Override
|
@Transactional
|
public void delete(FieldSetEntity fse) {
|
String[] uuidArr = fse.getString(CmnConst.UUID).split(",");
|
StringBuilder sql = new StringBuilder(128);
|
sql.append("select group_concat(type) type,group_concat(tag) tag");
|
sql.append("\nfrom product_oa_knowledge_sharing");
|
sql.append("\nwhere ").append(BaseUtil.buildQuestionMarkFilter(CmnConst.UUID, uuidArr.length, true));
|
FieldSetEntity paramFse = baseDao.getFieldSetEntityBySQL(sql.toString(), uuidArr, false);
|
String types = paramFse.getString(CmnConst.TYPE);
|
String tags = paramFse.getString(CmnConst.TAG);
|
|
publicService.delete(fse);
|
|
// 清理分类
|
String[] array = types.split(",");
|
sql.setLength(0);
|
sql.append("select t.name from product_oa_knowledge_sharing_tag t");
|
sql.append("\ninner join (");
|
sql.append("\n select * from product_oa_knowledge_sharing where 1=1");
|
for (String type : array) {
|
sql.append("\n or find_in_set('").append(type).append("',type)");
|
}
|
sql.append("\n) d on find_in_set(t.name,d.type)");
|
DataTableEntity dte = baseDao.listTable(sql.toString(), new Object[]{});
|
List<Object> residueList = Lists.newArrayList(Arrays.asList(dte.getFieldAllValues(CmnConst.NAME)));
|
List<Object> curList = Lists.newArrayList(array);
|
curList.removeAll(residueList);
|
sql.setLength(0);
|
sql.append("delete from product_oa_knowledge_sharing_tag where type=1");
|
if (!curList.isEmpty()) {
|
sql.append(" and ").append(BaseUtil.buildQuestionMarkFilter(CmnConst.NAME, curList.toArray().length, true));
|
}
|
baseDao.executeUpdate(sql.toString(), curList.toArray());
|
|
// 清理标签
|
array = tags.split(",");
|
sql.setLength(0);
|
sql.append("select t.name from product_oa_knowledge_sharing_tag t");
|
sql.append("\ninner join (");
|
sql.append("\n select * from product_oa_knowledge_sharing where 1=1");
|
for (String type : array) {
|
sql.append("\n or find_in_set('").append(type).append("',tag)");
|
}
|
sql.append("\n) d on find_in_set(t.name,d.tag)");
|
dte = baseDao.listTable(sql.toString(), new Object[]{});
|
residueList = Lists.newArrayList(Arrays.asList(dte.getFieldAllValues(CmnConst.NAME)));
|
curList = Lists.newArrayList(array);
|
curList.removeAll(residueList);
|
sql.setLength(0);
|
sql.append("delete from product_oa_knowledge_sharing_tag where type=2");
|
if (!curList.isEmpty()) {
|
sql.append(" and ").append(BaseUtil.buildQuestionMarkFilter(CmnConst.NAME, curList.toArray().length, true));
|
}
|
baseDao.executeUpdate(sql.toString(), curList.toArray());
|
}
|
|
/**
|
* 列表
|
* @param fse
|
*/
|
public JSONObject list(FieldSetEntity fse) {
|
JSONObject resultObj = new JSONObject();
|
|
StringBuilder defaultFilter = new StringBuilder(64);
|
// 分类过滤
|
String types = fse.getString(CmnConst.TYPE);
|
if (!StringUtils.isEmpty(types)) {
|
String[] typeArr = types.split(",");
|
for (String type : typeArr) {
|
if (defaultFilter.length() > 0) {
|
defaultFilter.append("\nor ");
|
}
|
defaultFilter.append("find_in_set('").append(type).append("',type)");
|
}
|
}
|
// 标签过滤
|
String tags = fse.getString(CmnConst.TAG);
|
if (!StringUtils.isEmpty(tags)) {
|
String[] tagArr = tags.split(",");
|
for (String tag : tagArr) {
|
if (defaultFilter.length() > 0) {
|
defaultFilter.append("\nor ");
|
}
|
defaultFilter.append("find_in_set('").append(tag).append("',tag)");
|
}
|
}
|
if (defaultFilter.length() > 0) {
|
fse.setValue(CmnConst.PARAM_FILTER, BaseUtil.addAimField(fse, CmnConst.PARAM_FILTER, defaultFilter.toString(), " and "));
|
}
|
|
DataTableEntity dte = publicService.listTable(fse);
|
FieldSetEntity tempFse;
|
for (int i = 0; i < dte.getRows(); i++) {
|
tempFse = dte.getFieldSetEntity(i);
|
try {
|
byte[] fileContent = fileManagerService.getFileContent(dte.getString(i, CmnConst.IMAGE));
|
if (fileContent != null) {
|
String bytes = Base64.encodeBase64String(fileContent);
|
dte.setFieldValue(i, CmnConst.IMAGE, "data:image/*;base64," + bytes);
|
} else {
|
dte.setFieldValue(i, CmnConst.IMAGE, null);
|
}
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(String.format("《%s》获取图片失败", tempFse.getString(CmnConst.TITLE)));
|
e.printStackTrace();
|
}
|
}
|
|
resultObj.put("list", BaseUtil.dataTableEntityToJson(dte));
|
resultObj.put("type", BaseUtil.dataTableEntityToJson(getType()));
|
resultObj.put("tag", BaseUtil.dataTableEntityToJson(getTag()));
|
return resultObj;
|
}
|
|
/**
|
* 获取所有分类
|
* @return
|
*/
|
public DataTableEntity getType() {
|
return baseDao.listTable(CmnConst.PRODUCT_OA_KNOWLEDGE_SHARING_TAG, "type=1", null, new Object[]{CmnConst.NAME});
|
}
|
|
/**
|
* 获取所有标签
|
* @return
|
*/
|
public DataTableEntity getTag() {
|
return baseDao.listTable(CmnConst.PRODUCT_OA_KNOWLEDGE_SHARING_TAG, "type=2", null, new Object[]{CmnConst.NAME});
|
}
|
}
|
