package com.product.admin.service;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.config.SystemCode;
|
import com.product.admin.service.idel.IPortalsService;
|
import com.product.common.lang.StringUtils;
|
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 org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title: PortalsService
|
* @Project: LX-BASE-SERVER
|
* @Date: 2021-03-18 09:55
|
* @Author: ZhouJie
|
* @Description: 门户配置
|
*/
|
@Component
|
public class PortalsService extends AbstractBaseService implements IPortalsService {
|
@Autowired
|
public BaseDao baseDao;
|
|
/**
|
* @Date: 2020-03-18 10:36
|
* @Author: ZhouJie
|
* @Description: 门户配置列表查询
|
*/
|
public DataTableEntity getPortalList(FieldSetEntity fs) throws BaseException {
|
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_SYS_PORTALS, null, null, null, null, fs.getInteger(CmnConst.PAGESIZE), fs.getInteger(CmnConst.CPAGE));
|
baseDao.loadPromptData(dt);
|
return dt;
|
}
|
|
public FieldSetEntity findUserIndexPortal() throws BaseException {
|
int userType = SpringMVCContextHolder.getCurrentUser().getUserType();
|
FieldSetEntity fieldSetBySQL = baseDao.getFieldSetBySQL("SELECT uuid FROM `product_sys_portals` where portal_type=? ORDER BY sequence limit 1", new Object[]{userType}, false);
|
if (fieldSetBySQL == null || StringUtils.isEmpty(fieldSetBySQL.getUUID())) {
|
throw new BaseException(SystemCode.USER_PORTAL_EMPTY);
|
}
|
return getPortalInfo(fieldSetBySQL);
|
}
|
|
/**
|
* @Date: 2020-03-18 10:18
|
* @Author: ZhouJie
|
* @Description: 门户配置详情查询
|
*/
|
public FieldSetEntity getPortalInfo(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PORTALS, fs.getUUID(), true);
|
DataTableEntity dt = fss.getSubDataTable(CmnConst.PRODUCT_SYS_PORTALS_SUB);
|
if (dt != null && dt.getRows() > 0) {
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsub = dt.getFieldSetEntity(i);
|
FieldSetEntity fspage = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PORTAL_COLUMN_CONFIG, CmnConst.UUID + "=?", new Object[]{fsub.getString("page_uuid")}, true);
|
fsub.setValue("page_name", fspage.getString("page_name"));
|
fsub.setValue("page_type", fspage.getString("page_type"));
|
fsub.setValue("is_use", fspage.getString("is_use"));
|
fsub.setValue("chart_name", fspage.getString("chart_name"));
|
fsub.setValue("link_address", fspage.getString("link_address"));
|
fsub.setValue("data_source", fspage.getString("data_source"));
|
fsub.setValue("click_view_more", fspage.getString("click_view_more"));
|
fsub.setValue("is_refresh_button", fspage.getString("is_refresh_button"));
|
fsub.setValue("is_show_underline", fspage.getString("is_show_underline"));
|
fsub.setValue("is_more_button", fspage.getString("is_more_button"));
|
fsub.setValue("is_add_button", fspage.getString("is_add_button"));
|
fsub.setValue("new_url", fspage.getString("new_url"));
|
fsub.setValue("is_show_title", fspage.getString("is_show_title"));
|
fsub.setValue("refresh_time", fspage.getInteger("refresh_time"));
|
fsub.setValue("column_type", fspage.getObject("column_type"));
|
fsub.setValue("color", fspage.getObject("color"));
|
fsub.setValue("icon", fspage.getObject("icon"));
|
String custom_button = fspage.getString("custom_button");
|
if (!StringUtils.isEmpty(custom_button) && JSON.isValid(custom_button)) {
|
JSONObject parse = JSON.parseObject(custom_button);
|
for (String key : parse.keySet()) {
|
String value = parse.getString(key);
|
if (JSON.isValidArray(value)) {
|
parse.put(key, JSON.parseArray(value));
|
}
|
if (JSON.isValidObject(value)) {
|
JSONObject jsonObject = JSON.parseObject(value);
|
parse.put(key, jsonObject);
|
}
|
}
|
fspage.setValue("custom_button", parse);
|
}
|
fsub.setValue("custom_button", fspage.getString("custom_button"));
|
fsub.setValue("is_custom_button", fspage.getString("is_custom_button"));
|
fsub.setValue("title_name", fspage.getString("title_name"));
|
if (!com.alibaba.druid.util.StringUtils.isEmpty(fsub.getString("page_uuid"))) {
|
FieldSetEntity fpage = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PORTAL_COLUMN_CONFIG, fsub.getString("page_uuid"), false);
|
FieldSetEntity fsrc = null;
|
FieldSetEntity fsmp = null;
|
if (fpage != null && fpage.getInteger("page_type") == 1) {
|
fsrc = baseDao.getFieldSetEntityByFilter("product_sys_report_config", CmnConst.UUID + "=?", new Object[]{fpage.getString("data_source")}, false);
|
}
|
if (fpage != null && fpage.getInteger("page_type") == 2) {
|
fsrc = baseDao.getFieldSetEntityByFilter("product_sys_report_config ", CmnConst.UUID + "=?", new Object[]{fpage.getString("chart_name")}, false);
|
}
|
if (fsrc != null) {
|
fsmp = baseDao.getFieldSetEntityByFilter("product_sys_mvc_page ", "function_uuid = ?", new Object[]{fsrc.getString("function_uuid")}, false);
|
if (fsmp != null) {
|
fsub.setValue("link_address", fsmp.getString("page_url"));
|
}
|
}
|
}
|
}
|
}
|
return fss;
|
//return baseDao.listInternationDataTable(baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_PORTALS, fs.getString(CmnConst.UUID), true),null);
|
}
|
|
/**
|
* @Date: 2020-03-18 11:29
|
* @Author: ZhouJie
|
* @Description: 新增门户配置
|
*/
|
public String addPortal(FieldSetEntity fs) throws BaseException {
|
String addPortal = "addPortal";
|
//判断菜单是否已在其他门户配置
|
if (!StringUtils.isEmpty(fs.getString("portal_menu"))) {
|
FieldSetEntity mfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PORTALS, "portal_menu=?", new Object[]{fs.getString("portal_menu")}, false);
|
if (mfs != null) {
|
throw new BaseException(SystemCode.SYSTEM_MENUS_ALREADY_EXIST.getValue(), SystemCode.SYSTEM_MENUS_ALREADY_EXIST.getText(), this.getClass(), addPortal);
|
}
|
}
|
|
//fs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue(CmnConst.CREATED_BY, 1);
|
fs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
|
return baseDao.add(fs);
|
}
|
|
/**
|
* @Date: 2020-03-18 14:07
|
* @Author: ZhouJie
|
* @Description: 修改门户配置
|
*/
|
@Transactional
|
public boolean updatePortal(FieldSetEntity fs) throws BaseException {
|
String updatePortal = "updatePortal";
|
//判断菜单是否已在其他门户配置
|
if (!StringUtils.isEmpty(fs.getString("portal_menu"))) {
|
FieldSetEntity mfs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_PORTALS, "portal_menu=?", new Object[]{fs.getString("portal_menu")}, false);
|
if (mfs == null) {
|
throw new BaseException(SystemCode.SYSTEM_MENUS_ALREADY_EXIST.getValue(), SystemCode.SYSTEM_MENUS_ALREADY_EXIST.getText(), this.getClass(), updatePortal);
|
}
|
}
|
//fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue(CmnConst.UPDATED_BY, 1);
|
fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
return baseDao.update(fs, true);
|
}
|
|
/**
|
* @Date: 2020-03-18 15:11
|
* @Author: ZhouJie
|
* @Description: 删除门户配置
|
*/
|
@Transactional
|
public boolean deletePortal(FieldSetEntity fs) throws BaseException {
|
|
|
baseDao.delete(CmnConst.PRODUCT_SYS_PORTALS_SUB, "portal_uuid=?", new Object[]{fs.getString("portal_uuid")});
|
/*
|
* if (dt.getRows() > 0) { for (int i = 0; i < dt.getRows(); i++) {
|
* FieldSetEntity fssub = dt.getFieldSetEntity(i); String fuuid =
|
* fssub.getString(CmnConst.UUID);
|
* baseDao.delete(CmnConst.PRODUCT_SYS_PORTALS_SUB, new
|
* Object[]{fssub.getString(CmnConst.UUID)}); } }
|
*/
|
return baseDao.delete(CmnConst.PRODUCT_SYS_PORTALS, new Object[]{fs.getString(CmnConst.UUID)});
|
}
|
|
|
}
|
