From c007f0ca1785db093d48f4846cda82fe8e955765 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期三, 27 五月 2020 09:59:29 +0800
Subject: [PATCH] merage
---
src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java | 142 +++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 125 insertions(+), 17 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java b/src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java
index c698aab..1a3420d 100644
--- a/src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java
+++ b/src/main/java/com/highdatas/mdm/service/impl/SysViewServiceImpl.java
@@ -67,7 +67,13 @@
AntianaphylaxisClient antianaphylaxisClient;
@Autowired
RedisClient redisClient;
-
+ /**
+ *
+ * @description: 閫氳繃id鑾峰彇瑙嗗浘鍒嗗彂鐨勫垎椤电殑鍥炰俊
+ * @param viewId 瑙嗗浘id
+ * @return: 鍒嗛〉瀵硅薄
+ *
+ */
@Override
public Page getInitPageInfo(String viewId) {
@@ -90,10 +96,7 @@
int length = tableSchemaResult.getLength();
totalLength += length;
}
- int pageSize = 20;
- if (totalLength != 0) {
- pageSize = Constant.MaxDispenseSize / totalLength;
- }
+ int pageSize = Constant.MaxDispenseSize / totalLength;
page.setPageSize(pageSize);
Long viewCount = getViewCount(sysView);
if (viewCount == 0) {
@@ -112,6 +115,13 @@
redisClient.putRedisValObj(realRedisKey, page);
return page;
}
+ /**
+ *
+ * @description: 鍒涘缓瑙嗗浘
+ * @param viewId 瑙嗗浘id
+ * @return: 鍒涘缓鏄惁鎴愬姛
+ *
+ */
@Override
public boolean createView(String viewId) {
try {
@@ -203,7 +213,13 @@
}
}
-
+ /**
+ *
+ * @description: 瑙嗗浘璐ㄩ噺妫�楠�
+ * @param sysView 瑙嗗浘
+ * @return: 鏄惁閫氳繃妫�楠�
+ *
+ */
private boolean checkTempData(SysView sysView) {
SysAssembleCheckType checkType = sysView.getCheckType();
if (checkType == null) {
@@ -235,7 +251,13 @@
}
return true;
}
-
+ /**
+ *
+ * @description: 鎻掑叆鍏宠仈琛ㄦ暟鎹�
+ * @param sysView 瑙嗗浘
+ * @return:
+ *
+ */
private void InsertJoin(SysView sysView) {
String userId = sysView.getUserId();
TUser user = DbUtils.getUserById(userId);
@@ -272,7 +294,13 @@
}
tableInfoMapper.updateJoin(tableName, joinSql, updateFieldBuilder.toString(), Constant.WHERE_DEFAULT);
}
-
+ /**
+ *
+ * @description: 1瀵�1 鏁版嵁杞崲
+ * @param sysView 瑙嗗浘
+ * @return:
+ *
+ */
private void changeValCommon(SysView sysView) {
String mappingField = sysView.getMappingField();
String tableName = sysView.getViewTableName();
@@ -296,7 +324,14 @@
tableInfoMapper.updateJoin(tableName, changeJoinStr, updateSegment.toRawString(), filterSegment.toString());
}
}
-
+ /**
+ *
+ * @description: 浠庢柊鐢熸垚瑙嗗浘琛�
+ * @param tableName 琛ㄥ悕
+ * @param totalFieldList 瀛楁鍒楄〃
+ * @return: 鐢熸垚鏄惁鎴愬姛
+ *
+ */
private boolean dropCreateViewTable(List<String> totalFieldList, String tableName) {
boolean created = unBigDataDataSourceInfo.dropData(tableName);
if (!created) {
@@ -311,6 +346,13 @@
return true;
}
+ /**
+ *
+ * @description: 鑾峰彇瑙嗗浘鐨勭墿鐞嗚〃鍚�
+ * @param view 瑙嗗浘瀵硅薄
+ * @return: 鐗╃悊琛ㄥ悕
+ *
+ */
@Override
public String getViewTableName(SysView view) {
String viewTableName = view.getViewTableName();
@@ -321,7 +363,13 @@
}
return viewTableName;
}
-
+ /**
+ *
+ * @description: 鑾峰彇瑙嗗浘 mapping鐨勭墿鐞嗚〃鍚�
+ * @param view 瑙嗗浘瀵硅薄
+ * @return: mapping鐨勭墿鐞嗚〃鍚�
+ *
+ */
@Override
public String getMappingTableName(SysView view) {
String id = view.getId();
@@ -330,6 +378,15 @@
view.setMappingTable(mappingTableName).updateById();
return mappingTableName;
}
+ /**
+ *
+ * @description: 鑾峰彇鍏宠仈涓婚鐨勬湁鏉冮檺鐨勫瓧娈�
+ * @param user 鐢ㄦ埛
+ * @param join 鍏宠仈涓婚瀵硅薄
+ * @return: 鍏宠仈涓婚鐨勬湁鏉冮檺鐨勫瓧娈�
+ *
+ */
+
@Override
public List<String> getSubFieldList(SysViewJoin join, TUser user) {
String fieldsStr = join.getFields();
@@ -346,7 +403,13 @@
return baseFieldList;
}
-
+ /**
+ *
+ * @description: 鑾峰彇鍩哄噯涓婚鐨勬湁鏉冮檺鐨勫瓧娈�
+ * @param sysView 涓婚
+ * @return: 鍩哄噯涓婚鐨勬湁鏉冮檺鐨勫瓧娈�
+ *
+ */
private List<String> getBaseFieldList(SysView sysView) {
String fieldsStr = sysView.getFields();
List<String> baseFieldList = new ArrayList<>();
@@ -362,6 +425,13 @@
return baseFieldList;
}
+ /**
+ *
+ * @description: 鑾峰彇1瀵�1杞崲鐨勫瓧娈�
+ * @param sysView 瑙嗗浘
+ * @return: 1瀵�1杞崲鐨勫瓧娈靛垪琛�
+ *
+ */
@Override
public List<ViewMapFieldItem> getMapField(SysView sysView) {
List<ViewMapFieldItem> result = new ArrayList<>();
@@ -412,14 +482,26 @@
}
return result;
}
-
+ /**
+ *
+ * @description: 鑾峰彇鍏宠仈涓婚瀵硅薄
+ * @param sysView 瑙嗗浘
+ * @return: 鑾峰彇鍏宠仈涓婚瀵硅薄
+ *
+ */
private List<SysViewJoin> getJoinList(SysView sysView) {
String id = sysView.getId();
Wrapper<SysViewJoin> eq = new EntityWrapper<SysViewJoin>().eq(Constant.PARENT_ID, id);
List<SysViewJoin> joinList = joinService.selectList(eq);
return joinList;
}
-
+ /**
+ *
+ * @description: 鑾峰彇鍏ㄩ儴瀛楁鍒楄〃
+ * @param sysView 瑙嗗浘
+ * @return: 鍏ㄩ儴瀛楁鍒楄〃
+ *
+ */
public List<String> getTotalFieldList(SysView sysView) {
String userId = sysView.getUserId();
TUser user = DbUtils.getUserById(userId);
@@ -443,7 +525,13 @@
sysView.setViewJoinList(sysViewJoins);
return totalFieldList;
}
-
+ /**
+ *
+ * @description: 鑾峰彇鍩哄噯涓婚瀵硅薄
+ * @param sysView 瑙嗗浘
+ * @return: 鑾峰彇鍩哄噯涓婚瀵硅薄
+ *
+ */
@Override
public Maintain getBaseMaintain(SysView sysView) {
@@ -459,7 +547,13 @@
}
return baseMaintain;
}
-
+ /**
+ *
+ * @description: 鑾峰彇鍏宠仈涓婚瀵硅薄
+ * @param viewJoin 瑙嗗浘鍏宠仈涓婚
+ * @return: 鑾峰彇鍏宠仈涓婚瀵硅薄
+ *
+ */
@Override
public Maintain getJoinMaintain(SysViewJoin viewJoin) {
@@ -475,12 +569,26 @@
}
return baseMaintain;
}
-
+ /**
+ *
+ * @description: 鑾峰彇瑙嗗浘瀹為檯浣跨敤鐨勫瓧娈�
+ * @param field 涓婚瀛楁
+ * @param baseTableName 琛ㄥ悕
+ * @return: 瑙嗗浘瀹為檯浣跨敤鐨勫瓧娈�
+ *
+ */
@Override
public String changeFieldName(String baseTableName, String field) {
return DbUtils.StrJoinLink(Constant.EMPTY_Str, baseTableName, Constant.UnderLine, field);
}
-
+ /**
+ *
+ * @description: 瀹℃壒缁撴潫鍚庢牴鎹潯浠堕噸鏂扮敓鎴愯鍥惧苟鍒嗗彂
+ * @param maintainId 鐗堟湰id
+ * @param status 瀹℃壒鐘舵��
+ * @return:
+ *
+ */
@Override
public void dealFlow(String maintainId, ActivitiStatus status) {
try {
--
Gitblit v1.8.0