package com.product.admin.service;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.common.base.Joiner;
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.entity.RouterEntity;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.cache.DataPoolCacheImpl;
|
import com.product.core.cache.util.RedisUtil;
|
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.module.sys.entity.SystemUser;
|
import com.product.util.BaseUtil;
|
import com.product.util.SystemParamReplace;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title: SystemButtonsService
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020-06-09 16:25
|
* @Author: ZhouJie
|
* @Description: 按钮Service层
|
*/
|
@Service
|
public class SystemButtonsService extends AbstractBaseService {
|
|
@Autowired
|
public BaseDao baseDao;
|
|
/***
|
* 查询按钮列表
|
* @param function_uuid 功能uuid
|
* @return
|
*/
|
public DataTableEntity getButtonList(String function_uuid) throws BaseException {
|
String sql = "select button.uuid,button.button_name,button.button_title,button.button_description,button.url,button.script,button.script_method,button.is_main,button.sequence,button.created_by,button.created_utc_datetime," +
|
"button.function_uuid," +
|
"button.button_type,dicttype.dict_label as button_type_name," +
|
"button.button_category_uuid,dictcategory.dict_label as button_category_name " +
|
" FROM product_sys_buttons button " +
|
" left join product_sys_dict dicttype on button.button_type = dicttype.uuid " +
|
" left join product_sys_dict dictcategory on button.button_category_uuid = dictcategory.uuid " +
|
" where button.function_uuid = ? ";
|
DataTableEntity dataTableEntity = baseDao.listTable(sql, new Object[]{function_uuid});
|
return dataTableEntity;
|
}
|
|
|
/***
|
* 获取排序序号
|
* @param function_uuid 功能uuid
|
* @throws BaseException
|
*/
|
public int getSequence(String function_uuid) throws BaseException {
|
String sql = "select max(sequence) as sequence FROM product_sys_buttons where function_uuid = ? ";
|
DataTableEntity dataTableEntity = baseDao.listTable(sql, new Object[]{function_uuid});
|
if (dataTableEntity != null && dataTableEntity.getMeta() != null) {
|
FieldSetEntity fieldSetEntity = dataTableEntity.getFieldSetEntity(0);
|
//周杰 2020年12月17日 上午11:16
|
if (!StringUtils.isEmpty(fieldSetEntity.getString("sequence"))) {
|
return fieldSetEntity.getInteger("sequence") + 1;
|
} else {
|
return 1;
|
}
|
} else {
|
return 1;
|
}
|
}
|
|
public FieldSetEntity getDict(String uuid) throws BaseException {
|
FieldSetEntity fieldSetEntity = baseDao.getFieldSetEntity("product_sys_dict", uuid, false);
|
return fieldSetEntity;
|
}
|
|
/**
|
* @Date: 2020-06-11 17:08
|
* @Author: ZhouJie
|
* @Description: 按钮详情查看
|
*/
|
public FieldSetEntity findButton(FieldSetEntity fs) throws BaseException {
|
return baseDao.getFieldSetEntity("product_sys_buttons", fs.getString("uuid"), false);
|
}
|
|
/**
|
* @throws BaseException
|
* @Date: 2020-06-11 17:46
|
* @Author: ZhouJie
|
* @Description: 按钮版本号
|
*/
|
public FieldSetEntity findBottonVersion(FieldSetEntity fs) throws BaseException {
|
String version = null;
|
String version1 = fs.getString("version");
|
if (version1 != null) {
|
String version2 = version1.substring(0, version1.indexOf(".", version1.indexOf(".") + 1) + 1) + String.valueOf(Integer.valueOf(version1.substring(version1.indexOf(".", version1.indexOf(".") + 1) + 1, version1.length())) + 1);
|
version = version1 + "," + version2;
|
}
|
fs.setValue("version", version);
|
return fs;
|
}
|
|
/**
|
* 获取路由信息
|
*
|
* @return
|
*/
|
public RouterEntity getRouterEntity() {
|
return (RouterEntity) RedisUtil.get("system-cache:router");
|
}
|
|
/**
|
* @throws BaseException
|
* @Date: 2020-06-12 11:05
|
* @Author: ZhouJie
|
* @Description: 新增按钮
|
*/
|
public String addButton(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity newFunction = baseDao.getFieldSetEntityByFilter("product_sys_functions", " uuid = ?", new Object[]{fs.getString("function_uuid")}, false);
|
FieldSetEntity newModule = baseDao.getFieldSetEntityByFilter("product_sys_modules", " uuid = ?", new Object[]{newFunction.getString("module_uuid")}, false);
|
String bfs = fs.getString("version");
|
String ffs = newFunction.getString("version");
|
String mfs = newModule.getString("version");
|
//功能版本号小于按钮的版本号，则回写到功能版本号
|
if (Integer.valueOf(ffs.substring(ffs.indexOf(".", ffs.indexOf(".") + 1) + 1, ffs.length())) <
|
Integer.valueOf(bfs.substring(bfs.indexOf(".", bfs.indexOf(".") + 1) + 1, bfs.length()))) {
|
newFunction.setValue("version", bfs);
|
baseDao.update(newFunction);//回写上级功能的版本号
|
}
|
//模块的版本号小于按钮长级后的版本，则把版本号回写到模块
|
if (Integer.valueOf(mfs.substring(mfs.indexOf(".") + 1, mfs.indexOf(".", mfs.indexOf(".") + 1))) <
|
Integer.valueOf(bfs.substring(bfs.indexOf(".") + 1, bfs.indexOf(".", bfs.indexOf(".") + 1)))) {
|
newModule.setValue("version", bfs);
|
baseDao.update(newModule);//回写上级模块的版本号
|
}
|
return baseDao.add(fs);
|
}
|
|
/**
|
* @throws BaseException
|
* @Date: 2020-06-13 10:19
|
* @Author: ZhouJie
|
* @Description: 按钮版本号升级并回写版本号
|
*/
|
public FieldSetEntity upVersion(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity now = baseDao.getFieldSetEntityByFilter("product_sys_function_buttons ", " uuid = ?", new Object[]{fs.getString("uuid")}, false);
|
//当前按钮版本号
|
String bfs = now.getString("version");
|
//升一级后的按钮版本号
|
String version = bfs.substring(0, bfs.indexOf(".", bfs.indexOf(".") + 1) + 1) + String.valueOf(Integer.valueOf(bfs.substring(bfs.indexOf(".", bfs.indexOf(".") + 1) + 1, bfs.length())) + 1);
|
fs.setValue("version", version);
|
baseDao.update(fs);
|
//回写版本号
|
FieldSetEntity newFunction = baseDao.getFieldSetEntityByFilter("product_sys_functions ", " uuid = ?", new Object[]{now.getString("function_uuid")}, false);
|
FieldSetEntity newModule = baseDao.getFieldSetEntityByFilter("product_sys_modules ", " uuid = ?", new Object[]{newFunction.getString("module_uuid")}, false);
|
String ffs = newFunction.getString("version");
|
String mfs = newModule.getString("version");
|
if (Integer.valueOf(ffs.substring(ffs.indexOf(".", ffs.indexOf(".") + 1) + 1, ffs.length())) <
|
Integer.valueOf(version.substring(version.indexOf(".", version.indexOf(".") + 1) + 1, version.length()))) {
|
newFunction.setValue("version", version);
|
baseDao.update(newFunction);//回写上级功能的版本号
|
}
|
//模块的版本号小于按钮长级后的版本，则把版本号回写到模块
|
if (Integer.valueOf(mfs.substring(mfs.indexOf(".") + 1, mfs.indexOf(".", mfs.indexOf(".") + 1))) <
|
Integer.valueOf(version.substring(version.indexOf(".") + 1, version.indexOf(".", version.indexOf(".") + 1)))) {
|
newModule.setValue("version", version);
|
baseDao.update(newModule);//回写上级模块的版本号
|
}
|
return fs;
|
}
|
|
/**
|
* 查询页面的按钮
|
*
|
* @param fse
|
*/
|
public DataTableEntity findButtonByPage(FieldSetEntity fse) throws BaseException {
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
if (currentUser == null || StringUtils.isEmpty(currentUser.getRoles())) {
|
return null;
|
}
|
String function_uuid = fse.getString(CmnConst.FUNCTION_UUID);
|
//当前人拥有的角色
|
String[] role_uuid = currentUser.getRoles().split(",");
|
List<DataTableEntity> permission = new ArrayList<>();
|
for (int i = 0; i < role_uuid.length; i++) {
|
//根据角色取出功能权限
|
permission.add(DataPoolCacheImpl.getInstance().getCacheData("功能权限", new String[]{role_uuid[i], function_uuid}));
|
}
|
Set<String> buttons = new HashSet<>();
|
//循环功能权限将按钮权限放入Set集合
|
for (int i = 0; i < permission.size(); i++) {
|
if (BaseUtil.dataTableIsEmpty(permission.get(i))) {
|
continue;
|
}
|
for (int j = 0; j < permission.get(i).getRows(); j++) {
|
String button_uuid = permission.get(i).getString(j, "button_uuid");
|
if (!StringUtils.isEmpty(button_uuid)) {
|
buttons.addAll(Arrays.asList(button_uuid.split(",")));
|
}
|
}
|
}
|
DataTableEntity dt = DataPoolCacheImpl.getInstance().getCacheData("页面-按钮", new String[]{fse.getString(CmnConst.MVC_PAGE_UUID), function_uuid});
|
DataTableEntity button;
|
if (!BaseUtil.dataTableIsEmpty(dt)) {
|
button = dt.clones();
|
} else {
|
return null;
|
}
|
RouterEntity routerEntity = getRouterEntity();
|
for (int i = 0; i < button.getRows(); i++) {
|
String button_uuid = button.getString(i, "button_uuid");
|
String params = button.getString(i, "params");
|
String upload_parameter = button.getString(i, "upload_parameter");
|
if (!buttons.contains(button_uuid)) {
|
if (!StringUtils.isEmpty(params)) {
|
if (JSON.isValidObject(params)) {
|
JSONObject jsonObject = JSON.parseObject(params);
|
for (Map.Entry<String, Object> v : jsonObject.entrySet()) {
|
String value = (String) v.getValue();
|
List<String> matchStr = BaseUtil.getMatchStr("(\\{#)([\\w]+)(#\\})", value);
|
if (matchStr.size() > 0) {
|
if (StringUtils.isEmpty(upload_parameter)) {
|
upload_parameter = "";
|
} else if (upload_parameter.length() > 0) {
|
upload_parameter += ',';
|
}
|
upload_parameter += Joiner.on(",").join(matchStr);
|
|
}
|
}
|
button.setFieldValue(i, "upload_parameter", upload_parameter);
|
}
|
}
|
button.removeFieldSetEntity(i);
|
i--;
|
continue;
|
}
|
RouterEntity.RouterMeta routerByButton = routerEntity.getRouterByButton(button_uuid);
|
if (routerByButton != null) {
|
button.setFieldValue(i, "page_type", routerByButton.getPageType());
|
}
|
}
|
return button;
|
}
|
|
/**
|
* 查询页面的按钮
|
*
|
* @param fse
|
*/
|
public FieldSetEntity findFromButtonByPage(FieldSetEntity fse) throws BaseException {
|
// xupengheng 2021年3月10日14:15:18
|
String function_uuid = fse.getString(CmnConst.FUNCTION_UUID);
|
String mvc_page_uuid = fse.getString(CmnConst.MVC_PAGE_UUID);
|
String last_button = fse.getString("last_button");
|
Object[] param = null;
|
String filter = "";
|
if (StringUtils.isEmpty(last_button)) {
|
param = new Object[]{function_uuid, mvc_page_uuid};
|
} else {
|
param = new Object[]{function_uuid, mvc_page_uuid, last_button};
|
filter = " and (route_name =?) ";
|
}
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT ");
|
sql.append(" a.*,JSON_object('face_uuid',c.face_uuid,'flow_title',flow_title,'uuid',c.uuid,'page_type',c.page_type,'tree_data',c.tree_data,'tree_data_type',tree_data_type ,'flow_uuid' ,c.flow_uuid,'page_element_disabled',c.page_element_disabled,'page_name',c.page_name,'from_param_key',c.from_param_key) as current_page, ");
|
sql.append(" ( SELECT table_name FROM product_sys_datamodel_table where uuid =(select table_uuid FROM product_sys_functions b WHERE a.function_uuid = b.uuid and data_type=1) ) table_name ");
|
sql.append(" FROM ");
|
sql.append(" product_sys_function_buttons a ");
|
sql.append(" JOIN product_sys_link b ON b.line_from = a.uuid ");
|
sql.append(" JOIN product_sys_mvc_page c ON c.uuid = b.line_to ");
|
sql.append(" WHERE ");
|
sql.append(" b.function_uuid = ? ");
|
sql.append(" AND b.line_to = ? ");
|
sql.append(filter);
|
sql.append(" AND b.from_type IN ( 0, 1 ) ");
|
FieldSetEntity fs = baseDao.getFieldSetEntityBySQL(sql.toString(), param, false);
|
if (fs != null && !StringUtils.isEmpty(fs.getString("params"))) {
|
String params = fs.getString("params");
|
boolean valid = JSON.isValid(params);
|
if (valid) {
|
JSONObject json = JSON.parseObject(params);
|
for (Map.Entry<String, Object> one : json.entrySet()) {
|
String val;
|
Object value = one.getValue();
|
if (value != null) {
|
val = value.toString();
|
} else {
|
continue;
|
}
|
one.setValue(SystemParamReplace.replaceParams(val, null));
|
}
|
fs.setValue("params", json.toJSONString());
|
}
|
}
|
return fs;
|
}
|
|
|
}
|
