From 6c6fdb4db59a2a2343e43ffd73a07f17b057c4fa Mon Sep 17 00:00:00 2001
From: kimi42345 <kimi42345@outlook.com>
Date: 星期二, 17 三月 2020 22:37:43 +0800
Subject: [PATCH] 3/17 添加 请求log
---
src/main/java/com/highdatas/mdm/service/impl/MaintainServiceImpl.java | 80 ++++++++++++++++++++++++++++++++-------
1 files changed, 65 insertions(+), 15 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/service/impl/MaintainServiceImpl.java b/src/main/java/com/highdatas/mdm/service/impl/MaintainServiceImpl.java
index f7c8f61..a1e8f76 100644
--- a/src/main/java/com/highdatas/mdm/service/impl/MaintainServiceImpl.java
+++ b/src/main/java/com/highdatas/mdm/service/impl/MaintainServiceImpl.java
@@ -20,10 +20,7 @@
import org.springframework.stereotype.Service;
import java.text.MessageFormat;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
import java.util.stream.Collectors;
/**
@@ -45,6 +42,7 @@
MasterDataService masterDataService;
@Autowired
ISysFieldService fieldService;
+
@Autowired
MaintainMapper maintainMapper;
@@ -97,7 +95,10 @@
if (status.equals(ActivitiStatus.close)) {
String collect = maintainDetailList.stream().map(detail -> DbUtils.quotedStr(detail.getPreMergeId())).collect(Collectors.joining(Constant.COMMA));
//delete temp
- masterDataService.delete(tableName + Constant.RECORD, "id in (" +collect+ ")");
+ if (!StringUtils.isEmpty(collect)) {
+ masterDataService.delete(tableName + Constant.RECORD, "id in (" +collect+ ")");
+ }
+
//delete detail
for (MaintainDetail maintainDetail : maintainDetailList) {
maintainDetail.deleteById();
@@ -172,7 +173,7 @@
@Override
public Result getUnSubmitData(String tableName, Integer pageNo, String pageSize, String whereSegment) {
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNull("flow_id").orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNull("flow_id").orderBy("order_no desc");
Maintain maintain = selectOne(versionWrapper);
if (maintain == null) {
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
@@ -198,6 +199,49 @@
}
@Override
+ public Maintain getNextMaintain(String tableName, String userId) {
+ Maintain maintain = this.getMaxVersion(tableName);
+ Maintain unFlowMaxVersion = this.getUnFlowMaxVersion(tableName);
+ if (unFlowMaxVersion == null) {
+ unFlowMaxVersion = new Maintain();
+ if (maintain != null) {
+ unFlowMaxVersion.setVersion(DbUtils.versionAddSub(maintain.getVersion()));
+ int orderNo = maintain.getOrderNo();
+ orderNo++;
+ unFlowMaxVersion.setOrderNo(orderNo);
+ } else {
+ unFlowMaxVersion.setVersion(Constant.VERSION_Default);
+ unFlowMaxVersion.setOrderNo(0);
+ }
+
+ unFlowMaxVersion.setId(DbUtils.getUUID());
+ unFlowMaxVersion.setChargeId(userId);
+ unFlowMaxVersion.setCreateTime(new Date());
+ unFlowMaxVersion.setTableName(tableName);
+ }
+
+ Maintain nowMaintain = unFlowMaxVersion;
+ if (DbUtils.compareVersion(maintain, unFlowMaxVersion) != 0) {
+ nowMaintain = new Maintain();
+ String maintanId = DbUtils.getUUID();
+ nowMaintain.setId(maintanId);
+ nowMaintain.setCreateTime(new Date());
+ int orderNo = maintain.getOrderNo();
+ orderNo++;
+ nowMaintain.setVersion(DbUtils.versionAddSub(maintain.getVersion()));
+ nowMaintain.setOrderNo(orderNo);
+ nowMaintain.setTableName(tableName);
+ }
+
+ nowMaintain.setChargeId(userId);
+ String maintainId = nowMaintain.getId();
+ if(StringUtils.isEmpty(maintainId)) {
+ nowMaintain.setId(DbUtils.getUUID());
+ }
+ return nowMaintain;
+ }
+
+ @Override
public boolean checkdMaxVersion(String maintainId) {
Maintain maintain = selectById(maintainId);
Maintain maxVersion = getMaxVersion(maintain.getTableName());
@@ -211,7 +255,7 @@
@Override
public Maintain getMaxVersion(String tableName) {
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");
Maintain maxVersion = selectOne(versionWrapper);
return maxVersion;
@@ -219,7 +263,7 @@
@Override
public Maintain getUnFlowMaxVersion(String tableName) {
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().isNull("flow_id").eq("table_name", tableName).orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().isNull("flow_id").eq("table_name", tableName).orderBy("order_no desc");
Maintain maxVersion = selectOne(versionWrapper);
return maxVersion;
@@ -228,7 +272,7 @@
@Override
public Maintain getInvalidMaxVersion(String tableName) {
Maintain result = null;
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");
List<Maintain> maintainList = selectList(versionWrapper);
@@ -278,7 +322,7 @@
@Override
public Maintain getNowVersion(String tableName) {
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("order_no desc");
List<Maintain> maintains = selectList(versionWrapper);
for (Maintain maintain : maintains) {
@@ -298,7 +342,7 @@
@Override
public Maintain getRecentHistoryVersion(String tableName) {
Maintain nowMaintain = null;
- Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("version desc");
+ Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).isNotNull("flow_id").orderBy("order_no desc");
List<Maintain> maintains = selectList(versionWrapper);
for (Maintain maintain : maintains) {
Flows flows = flowsService.selectById(maintain.getFlowId());
@@ -306,16 +350,22 @@
continue;
}
ActivitiStatus status = flows.getStatus();
- if (status.equals(ActivitiStatus.open)) {
+ if (status.equals(ActivitiStatus.open) && nowMaintain == null) {
nowMaintain = maintain;
- break;
+ continue;
+ }
+ if (!status.equals(ActivitiStatus.open) && nowMaintain != null){
+ nowMaintain = null;
}
}
if (nowMaintain == null) {
- nowMaintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("version desc"));
+ nowMaintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc"));
}
int orderNo = nowMaintain.getOrderNo();
- orderNo--;
+ Maintain nowVersion = getNowVersion(tableName);
+ if (nowVersion != null && nowVersion.getOrderNo() == orderNo) {
+ orderNo--;
+ }
Maintain maintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", nowMaintain.getTableName()).eq("order_no", orderNo));
return maintain;
}
--
Gitblit v1.8.0