package com.highdatas.mdm.controller;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.highdatas.mdm.entity.*;
|
import com.highdatas.mdm.mapper.TableInfoMapper;
|
import com.highdatas.mdm.pojo.CodeMsg;
|
import com.highdatas.mdm.pojo.Result;
|
import com.highdatas.mdm.pojo.ViewMapFieldItem;
|
import com.highdatas.mdm.service.*;
|
import com.highdatas.mdm.util.Constant;
|
import com.highdatas.mdm.util.DbUtils;
|
import lombok.SneakyThrows;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
* @desctiption 视图接口
|
* @author kimi
|
* @since 2020-04-15
|
*/
|
@RestController
|
@RequestMapping("/sysView")
|
public class SysViewController {
|
@Autowired
|
ISysViewService viewService;
|
@Autowired
|
ISysViewJoinService sysViewJoinService;
|
@Autowired
|
IMaintainService maintainService;
|
@Autowired
|
ISysMenuService menuService;
|
@Autowired
|
IMasterAuthorService masterAuthorService;
|
@Autowired
|
MasterDataService masterDataService;
|
@Autowired
|
TableInfoMapper tableInfoMapper;
|
@Autowired
|
IMenuMappingService menuMappingService;
|
@Autowired
|
ISysViewLogicService logicService;
|
@Autowired
|
ISysViewLogicmapService logicmapService;
|
|
/**
|
*
|
* @description: By用户获取视图list
|
* @param userId 用户id
|
* @return: 视图list
|
*
|
*/
|
@RequestMapping(value = "/all/{userId}", method = RequestMethod.GET)
|
public Result getAll(@PathVariable String userId, HttpServletRequest request) {
|
//ByuserId 获取视图列表
|
Wrapper<SysView> eq = new EntityWrapper<SysView>().eq(Constant.USERID, userId);
|
List<SysView> records = viewService.selectList(eq);
|
for (SysView record : records) {
|
String id = record.getId();
|
Maintain baseMaintain = viewService.getBaseMaintain(record);
|
//校验基准版本是否存在
|
if (baseMaintain == null) {
|
continue;
|
}
|
//获取 版本号，表名返回前端
|
record.setBaseTableName(baseMaintain.getTableName());
|
record.setBaseVersion(baseMaintain.getVersion());
|
String menuId = record.getMenuId();
|
SysMenu sysMenu = menuService.selectById(menuId);
|
//校验主题是否存在
|
if (sysMenu == null) {
|
continue;
|
}
|
//获取主题名称返回前端
|
record.setMenuName(sysMenu.getName());
|
//获取关联主题
|
List<SysViewJoin> sysViewJoins = sysViewJoinService.selectList(new EntityWrapper<SysViewJoin>().eq(Constant.PARENT_ID, id));
|
List<String> menuIds = sysViewJoins.stream()
|
.map(sysViewJoin -> sysViewJoin.getMenuId())
|
.collect(Collectors.toList());
|
if (!menuIds.isEmpty()) {
|
List<SysMenu> sysMenus = menuService.selectBatchIds(menuIds);
|
Collections.reverse(sysMenus);
|
String subMenuName = sysMenus.stream().map(subMenu -> subMenu.getName()).collect(Collectors.joining(Constant.SEMICOLON));
|
//获取关联主题的名称组合后返回给前端
|
record.setSubMenuName(subMenuName);
|
}
|
|
}
|
return Result.success(records);
|
}
|
|
/**
|
*
|
* @description: 更新视图数据
|
* @param id 视图id
|
* @return: 是否更新成功
|
*
|
*/
|
@RequestMapping(value = "/refreshData/{id}", method = RequestMethod.GET)
|
public Result createView(@RequestParam String id, @RequestParam Boolean active) {
|
//获取视图信息
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
//从新创建视图
|
viewService.createView(sysView.getId());
|
return Result.success(sysView);
|
}
|
|
/**
|
*
|
* @description: 保存关联字段信息
|
* @param id 视图id
|
* @param mapField 关联字段
|
* @return: 是否保存成功
|
*
|
*/
|
@RequestMapping(value = "/saveMapField/{id}", method = RequestMethod.GET)
|
public Result saveMapField(@RequestParam String id, @RequestParam String mapField) {
|
//获取视图信息
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
//保存关联字段
|
sysView.setMappingField(mapField).updateById();
|
return Result.success(sysView);
|
}
|
|
/**
|
*
|
* @description: 创建视图
|
* @param id 视图id
|
* @return: 是否创建成功
|
*
|
*/
|
|
@RequestMapping(value = "/createView/{id}", method = RequestMethod.GET)
|
public Result createView(@PathVariable String id) {
|
//获取视图信息
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
//创建视图
|
boolean view = viewService.createView(sysView.getId());
|
if (view) {
|
return Result.success(null);
|
} else {
|
return Result.error(CodeMsg.CREATE_ERROR);
|
}
|
|
}
|
|
/**
|
*
|
* @description: 更新视图激活状态
|
* @param id 视图id
|
* @return: 是否更新成功
|
*
|
*/
|
@RequestMapping(value = "/active/{id}", method = RequestMethod.GET)
|
public Result active(@PathVariable String id, @RequestParam Boolean active) {
|
//获取视图信息
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
//更新激活状态
|
sysView.setActive(active).updateById();
|
return Result.success(sysView);
|
}
|
|
/**
|
*
|
* @description: 获取视图数据
|
* @param id 视图id
|
* @param pageNo 页数
|
* @return: 视图术后据
|
*
|
*/
|
|
@RequestMapping(value = "/getViewData/{id}/page/{pageNo}", method = RequestMethod.GET)
|
public Result getViewData(@PathVariable String id, @PathVariable Integer pageNo, HttpServletRequest request) {
|
//pageSize ，每页数据量
|
String pageSizeStr = request.getParameter("pageSize");
|
//获取视图数据
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
int pageSize = 15;
|
if (!StringUtils.isEmpty(pageSizeStr)) {
|
pageSize = Integer.valueOf(pageSizeStr);
|
}
|
//分页获取视图数据
|
return viewService.getViewData(sysView, pageNo, pageSize);
|
|
}
|
|
/**
|
*
|
* @description: 获取视图一对一转换的map数据
|
* @param id 视图id
|
* @param pageNo 页数
|
* @return: map数据
|
*
|
*/
|
@RequestMapping(value = "/getMapData/{id}/page/{pageNo}", method = RequestMethod.GET)
|
public Result getMapData(@PathVariable String id, @PathVariable Integer pageNo, @RequestParam String changedField, HttpServletRequest request) {
|
//pageSize 每页数据
|
String pageSizeStr = request.getParameter("pageSize");
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
int pageSize = 15;
|
if (!StringUtils.isEmpty(pageSizeStr)) {
|
pageSize = Integer.valueOf(pageSizeStr);
|
}
|
//获取maping的数据
|
return viewService.getMapData(sysView, changedField, pageNo, pageSize);
|
|
}
|
|
/**
|
*
|
* @description: 通过用户获取有权限的字段
|
* @param userId 用户id
|
* @param needUpdate 是否需要从新获取一遍数据
|
* @param maintainId 版本id
|
* @return: 字段列表
|
*
|
*/
|
|
@RequestMapping(value = "/field/{userId}", method = RequestMethod.GET)
|
public Result<List<SysField>> fieldList(@PathVariable String userId, @RequestParam boolean needUpdate, @RequestParam String maintainId, HttpServletRequest request) {
|
//请求头里获取用户信息
|
TUser user = DbUtils.getUserById(userId);
|
if (user == null) {
|
return Result.error(CodeMsg.USER_NOT_MATHED);
|
}
|
|
if (needUpdate) {
|
//从新获取一遍最新的版本字段
|
Maintain nowVersion = maintainService.getNowVersion(maintainId);
|
List<SysField> field = masterAuthorService.getField(user, nowVersion.getId());
|
return Result.success(field) ;
|
}
|
//根据权限获取字段
|
List<SysField> field = masterAuthorService.getField(user, maintainId);
|
return Result.success(field) ;
|
}
|
|
/**
|
*
|
* @description: 获取视图一对一转换的map数据
|
* @param id 视图id
|
* @return: map数据
|
*
|
*/
|
@RequestMapping(value = "/mapFieldList/{id}", method = RequestMethod.GET)
|
public Result active(@PathVariable String id) {
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
|
List<ViewMapFieldItem> mapField = viewService.getMapField(sysView);
|
return Result.success(mapField);
|
}
|
|
/**
|
*
|
* @description: 获取视图数据
|
* @param id 视图id
|
* @return: 视图数据
|
*
|
*/
|
@RequestMapping(value = "/get/{id}", method = RequestMethod.GET)
|
public Result get(@PathVariable String id) {
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
String menuId = sysView.getMenuId();
|
//获取主题的父级主题链
|
LinkedHashSet<String> parentIdSet = new LinkedHashSet<>();
|
parentIdSet.add(menuId);
|
LinkedHashSet<String> byParentId = menuService.getByParentId(parentIdSet);
|
ArrayList<String> strings = new ArrayList<>(byParentId);
|
Collections.reverse(strings);
|
String collect = strings.stream().collect(Collectors.joining(Constant.SEMICOLON));
|
sysView.setMenuName(collect);
|
//获取关联主题
|
List<SysViewJoin> sysViewJoins = sysViewJoinService.selectList(new EntityWrapper<SysViewJoin>().eq(Constant.PARENT_ID, id));
|
for (SysViewJoin sysViewJoin : sysViewJoins) {
|
//获取关联主题的父级主题链
|
parentIdSet.clear();
|
parentIdSet.add(sysViewJoin.getMenuId());
|
LinkedHashSet<String> subParent = menuService.getByParentId(parentIdSet);
|
ArrayList<String> subList = new ArrayList<>(subParent);
|
Collections.reverse(subList);
|
String subMenuName = subList.stream().collect(Collectors.joining(Constant.SEMICOLON));
|
sysViewJoin.setMenuName(subMenuName);
|
}
|
sysView.setViewJoinList(sysViewJoins);
|
|
List<SysViewLogicmap> sysViewLogicmaps = logicmapService.selectList(new EntityWrapper<SysViewLogicmap>().eq(Constant.PARENT_ID, sysView.getId()));
|
sysView.setLogicmapList(sysViewLogicmaps);
|
return Result.success(sysView);
|
}
|
/**
|
*
|
* @description: 获取可用视图
|
* @param userId 用户id
|
* @return: 视图数
|
*
|
*/
|
@RequestMapping(value = "/getCnt/{userId}", method = RequestMethod.GET)
|
public Result cnt(@PathVariable String userId, HttpServletRequest request) {
|
//获取用户信息
|
TUser user = DbUtils.getUserById(userId);
|
if (user == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
Wrapper<SysView> userWrapper = new EntityWrapper<SysView>().eq("user_id", userId);
|
//获取视图总数
|
int totalCnt = viewService.selectCount(userWrapper);
|
//可用视图数
|
userWrapper.eq("active", true);
|
int activeCnt = viewService.selectCount(userWrapper);
|
//已注册视图数
|
userWrapper.eq("subscribe", true);
|
int subscribeCnt = viewService.selectCount(userWrapper);
|
JSONObject object = new JSONObject();
|
object.fluentPut("totalCnt", totalCnt);
|
object.fluentPut("activeCnt", activeCnt);
|
object.fluentPut("subscribeCnt", subscribeCnt);
|
return Result.success(object);
|
}
|
|
/**
|
*
|
* @description: 创建视图
|
* @param userId 用户id
|
* @return: 视图数据
|
*
|
*/
|
@RequestMapping(value = "/create/{userId}", method = RequestMethod.GET)
|
public Result add(@PathVariable String userId, HttpServletRequest request) {
|
SysView sysView = new SysView();
|
//设置视图初始数据
|
sysView.setId(DbUtils.getUUID())
|
.setUserId(userId)
|
.setCreateTime(new Date())
|
.setStatus(ViewStatus.edit)
|
.setEmptyData(true)
|
.insert();
|
//生成并保存mapping表 表名
|
viewService.getMappingTableName(sysView);
|
return Result.success(sysView);
|
}
|
|
/**
|
*
|
* @description: 删除一对一mapping
|
* @param id 视图id
|
* @return: map数据
|
*
|
*/
|
@SneakyThrows
|
@RequestMapping(value = "/deleteMap/{id}", method = RequestMethod.GET)
|
public Result deleteMap(@PathVariable String id, @RequestParam String changedField) {
|
//获取视图数据
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
//删除mapping字段
|
viewService.deleteMapField(sysView, changedField);
|
logicmapService.delete(new EntityWrapper<SysViewLogicmap>().eq(Constant.PARENT_ID, id).eq(Constant.FIELD, changedField));
|
List<SysViewLogicmap> sysViewLogicmaps = logicmapService.selectList(new EntityWrapper<SysViewLogicmap>().eq(Constant.PARENT_ID, sysView.getId()));
|
sysView.setLogicmapList(sysViewLogicmaps);
|
return Result.success(sysView);
|
}
|
/**
|
*
|
* @description: 删除关联主题数据
|
* @param id 视图关联主题id
|
* @return: 是否删除成功
|
*
|
*/
|
|
@SneakyThrows
|
@RequestMapping(value = "/delete/detail/{id}", method = RequestMethod.GET)
|
public Result deleteDetail(@PathVariable String id) {
|
//获取关联主题数据
|
SysViewJoin sysViewJoin = sysViewJoinService.selectById(id);
|
if (sysViewJoin == null) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
String parentId = sysViewJoin.getParentId();
|
SysView sysView = viewService.selectById(parentId);
|
String userId = sysView.getUserId();
|
//获取用户信息
|
TUser user = DbUtils.getUserById(userId);
|
|
//获取关联主题信息
|
Maintain joinMaintain = viewService.getJoinMaintain(sysViewJoin);
|
List<String> subFieldList = viewService.getSubFieldList(sysViewJoin, user);
|
boolean delete = false;
|
|
for (String subField: subFieldList) {
|
String changeFieldName = viewService.changeFieldName(joinMaintain.getTableName(), subField);
|
logicmapService.delete(new EntityWrapper<SysViewLogicmap>()
|
.eq(Constant.PARENT_ID, sysView.getId())
|
.eq(Constant.FIELD, changeFieldName)
|
);
|
//删除1对1mapping 表内数据
|
delete = viewService.deleteMapField(sysView, changeFieldName);
|
}
|
if (delete) {
|
return Result.success(CodeMsg.DELETE_SUCCESS);
|
} else {
|
return Result.error(CodeMsg.DELETE_ERROR);
|
}
|
}
|
/**
|
*
|
* @description: 删除视图
|
* @param id 视图id
|
* @return: 是否删除
|
*
|
*/
|
|
@SneakyThrows
|
@RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
|
public Result delete(@PathVariable String id) {
|
return viewService.deleteView(id);
|
}
|
|
/**
|
*
|
* @description: 通过用户获取某主题下的版本泪飙
|
* @param userId 用户id
|
* @param menuId 主题
|
* @return: map数据
|
*
|
*/
|
@RequestMapping(value = "/maintainList/{userId}", method = RequestMethod.GET)
|
public Result add(@PathVariable String userId, @RequestParam String menuId, HttpServletRequest request) {
|
//获取用户信息
|
TUser user = DbUtils.getUserById(userId);
|
if (user == null) {
|
return Result.error(CodeMsg.USER_NOT_MATHED);
|
}
|
//获取表名
|
String tableNameByMenu = menuMappingService.getTableNameByMenu(menuId);
|
if (StringUtils.isEmpty(tableNameByMenu)) {
|
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
|
}
|
//获取版本list
|
LinkedHashSet<Maintain> maintainSet = masterAuthorService.getMaintainSet(tableNameByMenu, user);
|
ArrayList<Maintain> maintains = new ArrayList<>(maintainSet);
|
for (Maintain maintain : maintains) {
|
maintain.setNeedUpdate(false);
|
}
|
Maintain max = new Maintain();
|
max.setId(tableNameByMenu);
|
max.setTableName(tableNameByMenu);
|
max.setNeedUpdate(true);
|
maintains.add(0, max);
|
return Result.success(maintains);
|
}
|
/**
|
*
|
* @description: 更新视图
|
* @return: 视图数据
|
*
|
*/
|
@RequestMapping(value = "/update", method = RequestMethod.POST)
|
public Result add(@RequestBody SysView view) {
|
//校验必传字段
|
if (StringUtils.isEmpty(view.getId())) {
|
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
|
}
|
if (StringUtils.isEmpty(view.getMenuId()) || StringUtils.isEmpty(view.getBaseMaintain()) ) {
|
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
|
}
|
if (StringUtils.isEmpty(view.getViewTableName())) {
|
viewService.getViewTableName(view);
|
}
|
List<SysViewLogicmap> logicmapList = view.getLogicmapList();
|
//delete 之前关联的逻辑转换 数据
|
logicmapService.delete(new EntityWrapper<SysViewLogicmap>().eq(Constant.PARENT_ID, view.getId()));
|
if (logicmapList != null) {
|
for (SysViewLogicmap logicmap : logicmapList) {
|
logicmap.setId(DbUtils.getUUID()).setParentId(view.getId()).insert();
|
}
|
}
|
|
view.setEmptyData(false).setStatus(ViewStatus.edit);
|
//delete 之前关联主题数据
|
sysViewJoinService.delete(new EntityWrapper<SysViewJoin>().eq(Constant.PARENT_ID, view.getId()));
|
|
List<SysViewJoin> viewJoinList = view.getViewJoinList();
|
boolean insert;
|
for (SysViewJoin sysViewJoin : viewJoinList) {
|
insert = sysViewJoin.setId(DbUtils.getUUID()).insert();
|
if (!insert) {
|
return Result.error(CodeMsg.INSERT_ERROR);
|
}
|
}
|
view.setUpdateTime(new Date());
|
view.updateById();
|
return Result.success(view);
|
}
|
/**
|
*
|
* @description: 下载视图一对一转换的map数据
|
* @param id 视图id
|
* @param menuId 主题id
|
* @param field 字段
|
* @return: map数据
|
*
|
*/
|
@SneakyThrows
|
@RequestMapping(value = "/download/{id}", method = RequestMethod.GET)
|
public void download(@PathVariable String id, @RequestParam String menuId, @RequestParam String field, HttpServletResponse response) {
|
//获取视图信息
|
SysView sysView = viewService.selectById(id);
|
if (sysView == null) {
|
return;
|
}
|
String userId = sysView.getUserId();
|
//获取用户信息
|
TUser user = DbUtils.getUserById(userId);
|
if (user == null) {
|
return;
|
}
|
//下载某个主题下的字段关联的1对1 mapping数据
|
viewService.downlodMap(sysView,user, response, field, menuId);
|
}
|
}
|
