From c8aee7b9bfd79cfd741d7e5692520f4f51a31a86 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期一, 18 五月 2020 18:30:01 +0800
Subject: [PATCH] bak 修改 获取版本数据前
---
src/main/java/com/highdatas/mdm/controller/MasterDataController.java | 103 ++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 85 insertions(+), 18 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/controller/MasterDataController.java b/src/main/java/com/highdatas/mdm/controller/MasterDataController.java
index d33f3d5..c81d304 100644
--- a/src/main/java/com/highdatas/mdm/controller/MasterDataController.java
+++ b/src/main/java/com/highdatas/mdm/controller/MasterDataController.java
@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.highdatas.mdm.entity.Character;
import com.highdatas.mdm.entity.*;
import com.highdatas.mdm.mapper.TableInfoMapper;
import com.highdatas.mdm.pojo.CodeMsg;
@@ -12,17 +13,18 @@
import com.highdatas.mdm.service.*;
import com.highdatas.mdm.util.Constant;
import com.highdatas.mdm.util.DbUtils;
+import com.highdatas.mdm.util.NoticeClient;
+import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.text.MessageFormat;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
import java.util.stream.Collectors;
/**
@@ -32,6 +34,7 @@
*/
@RestController
+@Slf4j
@RequestMapping("/master")
public class MasterDataController {
@Autowired
@@ -41,7 +44,8 @@
IMaintainService maintainService;
@Autowired
IMaintainDetailService maintainDetailService;
-
+ @Autowired
+ IMaintainFieldService maintainFieldService;
@Autowired
IMenuMappingService menuMappingService;
@@ -50,6 +54,12 @@
@Autowired
IMasterModifiedService masterModifiedService;
+ @Autowired
+ IMasterAuthorService masterAuthorService;
+ @Autowired
+ ISysMenuService menuService;
+ @Autowired
+ NoticeClient noticeClient;
@RequestMapping(value = "{tableName}/uploaded", method = RequestMethod.GET)
public Result get(@PathVariable String tableName, HttpServletRequest request) {
@@ -57,12 +67,19 @@
SysAssembleUpdateType uploadType;
if (StringUtils.isEmpty(uploadTypeStr)) {
uploadType = SysAssembleUpdateType.Increment;
+ }else {
+ uploadType = SysAssembleUpdateType.valueOf(uploadTypeStr);
}
- uploadType = SysAssembleUpdateType.valueOf(uploadTypeStr);
- TUser user = (TUser) request.getSession().getAttribute(Constant.USER);
+
+ TUser user = DbUtils.getUser(request);
Maintain maintain = masterDataService.uploadedData(tableName, uploadType, user.getUserId());
// 澶勭悊鍏宠仈浜�
- masterModifiedService.dealAssemble(maintain.getId(), user.getUserId(), true);
+ //masterModifiedService.dealAssemble(maintain.getId(), user.getUserId(), true);
+ //娣诲姞 std_id 绱㈠紩
+ String recordTableName = tableName + Constant.RECORD;
+
+ masterDataService.createIdx(recordTableName);
+
JSONObject object = new JSONObject();
object.fluentPut("maintainId",maintain.getId());
object.fluentPut("version",maintain.getVersion());
@@ -77,6 +94,12 @@
@RequestMapping(value = "{tableName}/all/{pageNo}", method = RequestMethod.GET)
public Result getByPage(@PathVariable String tableName, @PathVariable Integer pageNo, HttpServletRequest request) throws UnsupportedEncodingException {
+ String uuid = DbUtils.getUUID();
+ Date start = new Date();
+ Character character = DbUtils.getCharacter(request);
+ Date end = new Date();
+ log.info(MessageFormat.format("master tag:{0} MASTER-- form userID selct user:{1} ms",uuid, (end.getTime() - start.getTime())));
+
String pageSizeStr = request.getParameter("pageSize");
String whereSegment = request.getParameter(Constant.WHERE_SEGMENT);
String fields = request.getParameter(Constant.FIELDS);
@@ -106,33 +129,48 @@
}
version = String.valueOf(maxVersion.getVersion());
}
+ Maintain maintainFromVersion = maintainService.getMaintainFromVersion(tableName, version);
+ if (maintainFromVersion == null) {
+ return null;
+ }
+ //ADD Filter
+ start = new Date();
+ log.info(MessageFormat.format("master tag:{0} MASTER-- select maintain:{1} ms",uuid, (start.getTime() - end.getTime())));
+
+ String filter = masterAuthorService.getFilter(character, maintainFromVersion.getId(), uuid);
+ if (!StringUtils.isEmpty(filter)) {
+ whereSegment = DbUtils.StrJoin(whereSegment, Constant.AND, filter);
+ }
+ end = new Date();
+ log.info(MessageFormat.format("master tag:{0} MASTER-- select filter:{1} ms",uuid, (end.getTime() - start.getTime())));
if (StringUtils.isEmpty(fields)) {
if (StringUtils.isEmpty(pageSizeStr)) {
- return masterDataService.selectListByPageByVersion(tableName, whereSegment,pageNo,version, findMax);
+ return masterDataService.selectListByPageByVersion(character, tableName, whereSegment,pageNo,version, findMax,uuid);
}
- return masterDataService.selectListByPageByVersion(tableName, null, whereSegment,pageNo, Integer.valueOf(pageSizeStr),version,findMax);
+ return masterDataService.selectListByPageByVersion(character, tableName, null, whereSegment,pageNo, Integer.valueOf(pageSizeStr),version,findMax, uuid);
}else {
String[] split = fields.split(Constant.COMMA_TRIM);
List<String> fieldList = Arrays.stream(split).collect(Collectors.toList());
if (StringUtils.isEmpty(pageSizeStr)) {
- return masterDataService.selectListByPageByVersion(tableName, fieldList, whereSegment,pageNo, null,version, findMax);
+ return masterDataService.selectListByPageByVersion(character, tableName, fieldList, whereSegment,pageNo, null,version, findMax, uuid);
}
- return masterDataService.selectListByPageByVersion(tableName, fieldList, whereSegment,pageNo, Integer.valueOf(pageSizeStr), findMax);
+ return masterDataService.selectListByPageByVersion(character, tableName, fieldList, whereSegment,pageNo, Integer.valueOf(pageSizeStr), findMax, uuid);
}
}
@RequestMapping(value = "{tableName}/all", method = RequestMethod.GET)
public Result<MenuMapping> getAll(@PathVariable String tableName,HttpServletRequest request) {
+ TUser user = DbUtils.getUser(request);
String whereSegment = request.getParameter(Constant.WHERE_SEGMENT);
String version = request.getParameter(Constant.VERSION);
if (StringUtils.isEmpty(version)) {
version = String.valueOf(maintainService.getNowVersion(tableName).getVersion());
}
if (StringUtils.isEmpty(whereSegment)) {
- return masterDataService.selectList(tableName);
+ return masterDataService.selectList(user, tableName,Constant.WHERE_DEFAULT, version);
}
- return masterDataService.selectList(tableName,whereSegment);
+ return masterDataService.selectList(user, tableName,whereSegment, version);
}
@RequestMapping(value = "{maintainId}/modify/{operateStr}", method = RequestMethod.POST)
@@ -145,7 +183,7 @@
String[] split = modify.split(Constant.SEMICOLON);
modifyFields = Arrays.stream(split).collect(Collectors.toList());
}
- TUser user = (TUser) request.getSession().getAttribute("user");
+ TUser user = DbUtils.getUser(request);
switch (operate) {
case delete:
@@ -197,10 +235,11 @@
@RequestMapping(value = "{tableName}/{operateStr}", method = RequestMethod.POST)
+ @Transactional(rollbackFor = {RuntimeException.class, Error.class})
public Result insert(@PathVariable String tableName,@PathVariable String operateStr, @RequestParam String datas, @RequestParam String modify, HttpServletRequest request) {
String fields = request.getParameter("fields");
Operate operate = Operate.parse(operateStr);
- TUser user = (TUser) request.getSession().getAttribute("user");
+ TUser user = DbUtils.getUser(request);
String userId = user.getUserId();
Maintain maintain = maintainService.getMaxVersion(tableName);
Maintain nowMaintain = maintainService.getNextMaintain(tableName, userId);
@@ -265,6 +304,7 @@
List<String> ids = (List<String>) result.getData();
nowMaintain.insertOrUpdate();
+
for (String id : ids) {
MaintainDetail maintainDetail = new MaintainDetail();
maintainDetail.setId(DbUtils.getUUID());
@@ -280,7 +320,23 @@
Maintain firstVersionMaintain = maintainService.getMaintainFromVersion(tableName, Constant.VERSION_Default);
MenuMapping menuMapping = menuMappingService.selectOne(new EntityWrapper<MenuMapping>().eq("table_name", firstVersionMaintain.getTableName()));
+ String menuId = menuMapping.getMenuId();
+ SysMenu menu = menuService.selectById(menuId);
+ if (menu != null) {
+ LinkedHashSet<String> parentIdSet = new LinkedHashSet<>();
+ parentIdSet.add(menuId);
+ LinkedHashSet<String> byParentId = menuService.getByParentId(parentIdSet);
+ if (byParentId == null) {
+ noticeClient.EditMasterData(menu, null, user.getUserId(), operate);
+ } else {
+ if (!byParentId.isEmpty()) {
+ List<SysMenu> sysMenus = menuService.selectBatchIds(byParentId);
+ SysMenu parentMenu = sysMenus.get(0);
+ noticeClient.EditMasterData(menu, parentMenu, user.getUserId(),operate);
+ }
+ }
+ }
SysOperateLog operateLog = new SysOperateLog();
operateLog.setChargeId(user.getUserId()).setId(DbUtils.getUUID())
.setMaintainId(nowMaintain.getId())
@@ -334,10 +390,21 @@
}
}
+ @RequestMapping(value = "/getValByMaintainFieldId/{maintainFieldId}", method = RequestMethod.GET)
+ public Result getValByMaintainFieldId(@PathVariable String maintainFieldId,@RequestParam String menuId, @RequestParam String field, HttpServletRequest request) {
+ String tableName = menuMappingService.getTableNameByMenu(menuId);
+ if (StringUtils.isEmpty(tableName)) {
+ return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
+ }
+ if (maintainFieldId.equalsIgnoreCase(Constant.All)) {
+ Set<String> fieldValList = masterDataService.getFieldValByTable(tableName, field);
+ return Result.success(fieldValList);
+ }
+ Set<String> fieldValByMaintainField = masterDataService.getFieldValByMaintainField(maintainFieldId, field, tableName);
- @RequestMapping(value = "{tableName}/getFieldVal/{field}", method = RequestMethod.GET)
- public Result getFieldVal(@PathVariable String tableName, @PathVariable String field) {
- return masterDataService.getFieldValByTable(tableName,field);
+ return Result.success(fieldValByMaintainField);
}
+
+
}
--
Gitblit v1.8.0