package com.product.org.admin.controller;
|
|
|
import com.product.core.permission.PermissionService;
|
import com.product.module.sys.config.SystemErrorCode;
|
import com.product.module.sys.entity.SystemUser;
|
import org.apache.commons.lang3.StringUtils;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.servlet.http.HttpSession;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.core.config.CoreConst;
|
import com.product.core.controller.support.AbstractBaseController;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.entity.RequestParameterEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.module.sys.service.UserService;
|
import com.product.module.sys.version.ApiVersion;
|
import com.product.org.admin.config.CmnConst;
|
import com.product.org.admin.config.SystemCode;
|
import com.product.org.admin.service.ViewTableService;
|
import com.product.org.admin.service.idel.IViewTableService;
|
import com.product.org.admin.util.ResultInfo;
|
import com.product.util.BaseUtil;
|
|
import java.util.Map;
|
|
/**
|
* Copyright © LX-BASE
|
* @Title: ViewTableController
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020-05-29 11:42:06
|
* @Author: Xin.Luo
|
* @Description: 视图管理
|
*/
|
@RestController
|
@RequestMapping("/api/view")
|
public class ViewTableController extends AbstractBaseController {
|
@Autowired
|
public ViewTableService viewTableService;
|
@Autowired
|
UserService userService;
|
|
@Autowired
|
BaseDao baseDao;
|
/**
|
* 数据权限验证
|
*/
|
@Autowired
|
PermissionService permissionService;
|
|
@ResponseBody
|
@RequestMapping(value = "/saveViewInfo/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String saveViewInfo(HttpServletResponse response,HttpServletRequest request,HttpSession session){
|
try {
|
//获取参数
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
if (bean != null) {
|
RequestParameterEntity reqp = (RequestParameterEntity) bean;
|
fse = reqp.getFormData();
|
}
|
//判断参数是否为空
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
String table_uuid = fse.getString(CmnConst.UUID);//表uuid
|
Boolean create_view_sql_status = Boolean.valueOf(fse.getString("create_view_sql_status"));//执行的sql状态
|
fse.remove("create_view_sql_status");
|
fse.setValue("table_type", 2);
|
//取出子表
|
DataTableEntity dataTable = fse.getSubDataTable(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD);
|
if(!BaseUtil.dataTableIsEmpty(dataTable)) {
|
//删除子表 单独保存
|
fse.removeSubData(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD);
|
}
|
//如果是子公司 将子公司单位ID添加至视图名
|
IViewTableService ser=(IViewTableService)getProxyInstance(viewTableService);
|
ser.addNameSubsidiary(fse);
|
if(StringUtils.isEmpty(table_uuid)) {
|
IViewTableService service=(IViewTableService)getProxyInstance(viewTableService);
|
fse.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());//创建人
|
fse.setValue(CmnConst.TABLE_PRIMARY_KEY, CmnConst.UUID);//指定主键为UUID
|
service.addAView(fse);
|
}else {
|
//超级管理员为1
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
int type;
|
if(currentUser.getUserType() == 1){
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_USER;
|
}else {
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_ORG;
|
}
|
//数据操作的权限验证
|
if(!permissionService.validDataPermission(CmnConst.PRODUCT_SYS_DATAMODEL_TABLE,table_uuid,type)) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
return this.error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
}
|
IViewTableService service=(IViewTableService)getProxyInstance(viewTableService);
|
fse.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());//修改人
|
fse.setValue(CmnConst.UUID, table_uuid);
|
service.updateTableName(fse);
|
}
|
//如果sql 已经修改,替换之前sql 并删除之前字段信息
|
if(create_view_sql_status && !StringUtils.isEmpty(table_uuid)){
|
IViewTableService service=(IViewTableService)getProxyInstance(viewTableService);
|
service.updateViewSql(fse);
|
}
|
return OK();
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e);
|
}catch(Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(SystemCode.SYSTEM_SAVE_VIEW_FAIL.getValue(),SystemCode.SYSTEM_SAVE_VIEW_FAIL.getText());
|
}
|
}
|
@ResponseBody
|
@RequestMapping(value = "/runSql/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String testSql(HttpServletResponse response,HttpServletRequest request,HttpSession session){
|
try {
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
RequestParameterEntity reqp = (RequestParameterEntity) bean;
|
String view_sql = reqp.getFormData().getValue(CmnConst.VIEW_SQL).toString();
|
IViewTableService service=(IViewTableService)getProxyInstance(viewTableService);
|
DataTableEntity field = service.runSql(view_sql);
|
//返回data
|
if(field.getRows()>0) {
|
return OK_List(field);
|
}
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_SQL_START_FAIL.getValue(),SystemCode.SYSTEM_SQL_START_FAIL.getText());
|
return this.error(SystemCode.SYSTEM_SQL_START_FAIL.getValue(),SystemCode.SYSTEM_SQL_START_FAIL.getText());
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e);
|
}catch(Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(SystemCode.SYSTEM_SQL_START_FAIL.getValue(),SystemCode.SYSTEM_SQL_START_FAIL.getText());
|
}
|
}
|
@ResponseBody
|
@RequestMapping(value = "/getViewTableInfo/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String getTableInfo(HttpServletResponse response,HttpServletRequest request,HttpSession session){
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
if (bean != null) {
|
RequestParameterEntity reqp = (RequestParameterEntity) bean;
|
fse = reqp.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
String arr_uuid = fse.getString(CmnConst.UUID);
|
if(StringUtils.isEmpty(arr_uuid)){
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
//超级管理员为1
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
int type;
|
if(currentUser.getUserType() == 1){
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_USER;
|
}else {
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_ORG;
|
}
|
//数据操作的权限验证
|
if(!permissionService.validDataPermission(CmnConst.PRODUCT_SYS_DATAMODEL_TABLE,arr_uuid,type)) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
return this.error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
}
|
String[] split = arr_uuid.split(",");
|
FieldSetEntity field = viewTableService.getTableInfo(split[0]);
|
if(field != null){
|
Map<String, DataTableEntity> subData = field.getSubData();
|
subData.get(CmnConst.PRODUCT_SYS_DATAMODEL_FIELD);
|
return OK_List(field);
|
}else {
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_GET_TABLE_FAIL.getValue(), SystemCode.SYSTEM_GET_TABLE_FAIL.getText());
|
return this.error(SystemCode.SYSTEM_GET_TABLE_FAIL.getValue(), SystemCode.SYSTEM_GET_TABLE_FAIL.getText());
|
}
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e);
|
} catch(Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(SystemCode.SYSTEM_GET_TABLE_FAIL.getValue(),SystemCode.SYSTEM_GET_TABLE_FAIL.getText());
|
}
|
}
|
@ResponseBody
|
@RequestMapping(value = "/deleteTable/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String delTable(HttpServletResponse response,HttpServletRequest request,HttpSession session){
|
try {
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
if (bean != null) {
|
RequestParameterEntity reqp = (RequestParameterEntity) bean;
|
fse = reqp.getFormData();
|
}
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
String uuid = fse.getString(CmnConst.UUID);
|
if(StringUtils.isEmpty(uuid)){
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
//超级管理员为1
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
int type;
|
if(currentUser.getUserType() == 1){
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_USER;
|
}else {
|
type = CoreConst.DATA_PERMISSION_VALID_TYPE_ORG;
|
}
|
//数据操作的权限验证
|
if(!permissionService.validDataPermission(CmnConst.PRODUCT_SYS_DATAMODEL_TABLE,uuid,type)) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
return this.error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
|
}
|
String[] split = uuid.split(",");
|
JSONObject jsonObject = new JSONObject();
|
IViewTableService service=(IViewTableService)getProxyInstance(viewTableService);
|
if(service.delTable(split)){
|
jsonObject.put("flag", "true");
|
return ResultInfo.success(jsonObject);
|
}else{
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_DELETE_VIEW_FAIL.getValue(),SystemCode.SYSTEM_DELETE_VIEW_FAIL.getText());
|
return this.error(SystemCode.SYSTEM_DELETE_VIEW_FAIL.getValue(),SystemCode.SYSTEM_DELETE_VIEW_FAIL.getText());
|
}
|
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e);
|
} catch(Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(SystemCode.SYSTEM_DELETE_VIEW_FAIL.getValue(),SystemCode.SYSTEM_DELETE_VIEW_FAIL.getText());
|
}
|
}
|
@ResponseBody
|
@RequestMapping(value = "/getViewTableAll/{version}", method = RequestMethod.POST)
|
@ApiVersion(1)
|
public String getViewTableAll(HttpServletResponse response,HttpServletRequest request,HttpSession session){
|
try {
|
//获取参数
|
FieldSetEntity fse = null;
|
Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
|
if (bean != null) {
|
RequestParameterEntity reqp = (RequestParameterEntity) bean;
|
fse = reqp.getFormData();
|
}
|
//判断参数是否为空
|
if (fse == null) {
|
SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
|
}
|
return OK_List(viewTableService.getViewTableAll(fse));
|
} catch (BaseException e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(e);
|
} catch(Exception e) {
|
e.printStackTrace();
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
return this.error(SystemCode.SYSTEM_GET_TABLE_FAIL.getValue(),SystemCode.SYSTEM_GET_TABLE_FAIL.getText());
|
}
|
}
|
|
}
|
