package com.highdatas.mdm.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.highdatas.mdm.entity.*;
|
import com.highdatas.mdm.mapper.MaintainDetailMapper;
|
import com.highdatas.mdm.mapper.MaintainMapper;
|
import com.highdatas.mdm.mapper.TableInfoMapper;
|
import com.highdatas.mdm.pojo.*;
|
import com.highdatas.mdm.service.*;
|
import com.highdatas.mdm.util.Constant;
|
import com.highdatas.mdm.util.DbUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.text.MessageFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author kimi
|
* @since 2019-12-16
|
*/
|
@Service
|
public class MaintainServiceImpl extends ServiceImpl<MaintainMapper, Maintain> implements IMaintainService {
|
@Autowired
|
IMaintainDetailService maintainDetailService;
|
|
@Autowired
|
TableInfoMapper tableInfoMapper;
|
@Autowired
|
MasterDataService masterDataService;
|
@Autowired
|
ISysFieldService fieldService;
|
|
@Autowired
|
MaintainMapper maintainMapper;
|
|
@Autowired
|
IFlowsService flowsService;
|
@Autowired
|
MaintainDetailMapper maintainDetailMapper;
|
@Autowired
|
IMaintainFieldService maintainFieldService;
|
|
@Override
|
public JSONObject compare(String maintainId, String maintainId2, Operate operate, int pageNo, int pageSize) {
|
Maintain baseMaintain = selectById(maintainId);
|
Maintain compareMaintain = selectById(maintainId2);
|
|
HashMap<Operate, Object> operateIntegerMap = new HashMap<Operate, Object>();
|
List<Map<String, Object>> maps;
|
Page page;
|
List<SysField> fieldByMaintain;
|
if (DbUtils.compareVersion(baseMaintain, compareMaintain) > 0) {
|
String maintainTableName = baseMaintain.getTableName();
|
String tempName = baseMaintain.getTableName() + Constant.RECORD;
|
fieldByMaintain = fieldService.getFieldByMaintain(baseMaintain.getId());
|
String collect = fieldByMaintain.stream().map(sysField -> sysField.getField()).collect(Collectors.joining(Constant.COMMA));
|
maps = maintainDetailMapper.selectOperateDatas("count(*) as cnt", tempName, operate.name(), maintainTableName, compareMaintain.getOrderNo(), baseMaintain.getOrderNo(), null, null);
|
Object cnt = maps.get(0).get("cnt");
|
page = new Page(Integer.valueOf(cnt.toString()));
|
page.setPageNo(pageNo);
|
page.setPageSize(pageSize);
|
maps = maintainDetailMapper.selectOperateDatas(collect, tempName, operate.name(), maintainTableName, compareMaintain.getOrderNo(), baseMaintain.getOrderNo(), "desc", page.getLimitSQL());
|
|
} else {
|
if (operate.equals(Operate.create)) {
|
operate = Operate.delete;
|
} else if (operate.equals(Operate.delete)) {
|
operate = Operate.create;
|
}
|
String maintainTableName = compareMaintain.getTableName();
|
String tempName = compareMaintain.getTableName() + Constant.RECORD;
|
fieldByMaintain = fieldService.getFieldByMaintain(compareMaintain.getId());
|
String collect = fieldByMaintain.stream().map(sysField -> sysField.getField()).collect(Collectors.joining(Constant.COMMA));
|
maps = maintainDetailMapper.selectOperateDatas("count(*) as cnt", tempName, operate.name(), maintainTableName, baseMaintain.getOrderNo(), compareMaintain.getOrderNo(), null, null);
|
Object cnt = maps.get(0).get("cnt");
|
page = new Page(Integer.valueOf(cnt.toString()));
|
page.setPageNo(pageNo);
|
page.setPageSize(pageSize);
|
maps = maintainDetailMapper.selectOperateDatas(collect, tempName, operate.name(), maintainTableName, baseMaintain.getOrderNo(), compareMaintain.getOrderNo(), null, page.getLimitSQL());
|
}
|
|
JSONObject object = new JSONObject();
|
object.fluentPut("total", page.getRecordCount());
|
object.fluentPut("size", page.getPageSize());
|
object.fluentPut("pages", page.getPageCount());
|
object.fluentPut("current", page.getPageNo());
|
object.fluentPut("records", maps);
|
object.fluentPut("fields", fieldByMaintain);
|
|
return object;
|
}
|
|
private void addCompareInfo(Maintain baseMaintain, Maintain compareMaintain, HashMap<Operate, Object> operateIntegerMap) {
|
Integer fromNo = compareMaintain.getOrderNo();
|
Integer toNo = baseMaintain.getOrderNo();
|
for (int i = fromNo + 1; i <= toNo; i++) {
|
Maintain maintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", baseMaintain.getTableName()).eq("order_no", i));
|
List<MaintainDetail> maintainDetailList = maintainDetailService.selectList(new EntityWrapper<MaintainDetail>().eq("parent_id", maintain.getId()));
|
for (MaintainDetail maintainDetail : maintainDetailList) {
|
Operate operate = maintainDetail.getOperate();
|
Integer integer = (Integer) operateIntegerMap.get(operate);
|
if (integer == null) {
|
integer = 1;
|
} else {
|
integer++;
|
}
|
operateIntegerMap.put(operate, integer);
|
}
|
}
|
}
|
|
@Override
|
public void dealFlow(String maintainId, ActivitiStatus status) {
|
try {
|
Maintain maintain = selectById(maintainId);
|
String tableName = maintain.getTableName();
|
List<MaintainDetail> maintainDetailList = maintainDetailService.selectList(new EntityWrapper<MaintainDetail>().eq("parent_id", maintainId));
|
if (status.equals(ActivitiStatus.close)) {
|
String collect = maintainDetailList.stream().map(detail -> DbUtils.quotedStr(detail.getPreMergeId())).collect(Collectors.joining(Constant.COMMA));
|
//delete temp
|
if (!StringUtils.isEmpty(collect)) {
|
masterDataService.delete(tableName + Constant.RECORD, "id in (" + collect + ")");
|
}
|
|
//delete detail
|
for (MaintainDetail maintainDetail : maintainDetailList) {
|
maintainDetail.deleteById();
|
}
|
//delete maintain
|
maintain.deleteById();
|
return;
|
}
|
String fields = masterDataService.getTempFields(null, tableName);
|
String tempFields = masterDataService.getFields(tableName + Constant.RECORD);
|
|
String tableTempName = tableName + Constant.RECORD;
|
// insert 2 std
|
tableInfoMapper.tempCreate2std(tableName, fields, tableTempName, DbUtils.quotedStr(maintainId));
|
|
|
// update
|
List<Map<String, Object>> updeateDatas = tableInfoMapper.tempByOperate(DbUtils.quotedStr(Operate.update.name()), tempFields, tableTempName, DbUtils.quotedStr(maintainId));
|
for (Map<String, Object> updeateData : updeateDatas) {
|
String stdId = updeateData.get(Constant.STD_ID).toString();
|
String id = updeateData.get(Constant.ID).toString();
|
Result result = masterDataService.selectById(tableName, stdId);
|
Object tempData = result.getData();
|
String datas = JSON.toJSONString(tempData);
|
JSONObject object = JSON.parseObject(datas);
|
Object grid = object.get("grid");
|
object = JSON.parseObject(JSON.toJSONString(grid));
|
|
object.put(Constant.STD_ID, stdId);
|
object.put(Constant.ID, id);
|
|
datas = JSON.toJSONString(object);
|
|
masterDataService.updateById(tableTempName, datas, id, true);
|
|
updeateData.put(Constant.STD_ID, null);
|
updeateData.put(Constant.ID, stdId);
|
|
masterDataService.updateById(tableName, JSON.toJSONString(updeateData), stdId, true);
|
}
|
//delete
|
List<Map<String, Object>> delDatas = tableInfoMapper.tempByOperate(DbUtils.quotedStr(Operate.delete.name()), tempFields, tableTempName, DbUtils.quotedStr(maintainId));
|
for (Map<String, Object> delData : delDatas) {
|
Object id = delData.get(Constant.STD_ID);
|
masterDataService.deleteById(tableName, id.toString());
|
}
|
// update deal
|
tableInfoMapper.tempDeal(tableTempName, DbUtils.quotedStr(maintainId));
|
}
|
catch (Exception e ){
|
e.printStackTrace();
|
}
|
|
|
}
|
|
@Override
|
public boolean checkNowVersion(String maintainId) {
|
Maintain maintain = selectById(maintainId);
|
Maintain maxVersion = getNowVersion(maintain.getTableName());
|
Integer compared = DbUtils.compareVersion(maxVersion, maintain);
|
if (compared != null && compared == 0) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
@Override
|
public boolean checkFirstVersion(String id) {
|
Maintain maintain = selectById(id);
|
Maintain order_no = selectOne(new EntityWrapper<Maintain>().eq("table_name", maintain.getTableName()).orderBy("order_no"));
|
if (maintain.getId().equalsIgnoreCase(order_no.getId())) {
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public Long getUnSubmitDataCnt(TUser user, String tableName, String whereSegment) {
|
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 null;
|
}
|
String maintainId = maintain.getId();
|
String tempName = tableName + Constant.RECORD;
|
Long aLong = maintainMapper.countUnSubmitData(tempName, whereSegment, DbUtils.quotedStr(maintainId));
|
return aLong;
|
}
|
@Override
|
public Result getUnSubmitData(TUser user, String tableName, Integer pageNo, String pageSize, String whereSegment) {
|
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);
|
}
|
String maintainId = maintain.getId();
|
String tempName = tableName + Constant.RECORD;
|
Long aLong = maintainMapper.countUnSubmitData(tempName, whereSegment, DbUtils.quotedStr(maintainId));
|
Page page = new Page(aLong);
|
page.setPageNo(pageNo);
|
if (!StringUtils.isEmpty(pageSize)) {
|
page.setPageSize(Integer.valueOf(pageSize));
|
}
|
String tempFields = masterDataService.getTempFields(user, tableName);
|
List<Map<String, Object>> maps = maintainMapper.selectUnSubmitData(tempName, tempFields, whereSegment, DbUtils.quotedStr(maintainId), page.getLimitSQL());
|
JSONObject object = new JSONObject();
|
object.fluentPut("records", maps);
|
object.fluentPut("maintainId", maintainId);
|
object.fluentPut("total", page.getRecordCount());
|
object.fluentPut("size", page.getPageSize());
|
object.fluentPut("pages", page.getPageCount());
|
object.fluentPut("current", page.getPageNo());
|
return Result.success(object);
|
}
|
|
@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 JSONObject compareField(String maintainId1, String maintainId2) {
|
Maintain baseMaintain = selectById(maintainId1);
|
Maintain compareMaintain = selectById(maintainId2);
|
boolean pre = false;
|
if (DbUtils.compareVersion(baseMaintain, compareMaintain) > 0) {
|
pre = true;
|
}
|
|
List<SysField> baseFieldList = fieldService.getFieldByMaintain(maintainId1);
|
List<SysField> compareFieldList = fieldService.getFieldByMaintain(maintainId2);
|
List<String> baseFieldStrList = baseFieldList.stream().map(sysField -> sysField.getField()).collect(Collectors.toList());
|
List<String> compareFieldStrList = compareFieldList.stream().map(sysField -> sysField.getField()).collect(Collectors.toList());
|
|
List<String> baseExportList = baseFieldStrList.stream().filter(s -> !compareFieldStrList.contains(s)).collect(Collectors.toList());
|
List<SysField> baseExprotFieldList = baseFieldList.stream().filter(sysField -> baseExportList.contains(sysField.getField())).collect(Collectors.toList());
|
List<String> compareExportList = compareFieldStrList.stream().filter(s -> !baseFieldStrList.contains(s)).collect(Collectors.toList());
|
List<SysField> compareExprotFieldList = compareFieldList.stream().filter(sysField -> compareExportList.contains(sysField.getField())).collect(Collectors.toList());
|
|
List<String> collect = baseFieldStrList.stream().filter(s -> compareFieldList.contains(s)).collect(Collectors.toList());
|
List<SysField> changedList = new ArrayList<>();
|
for (String s : collect) {
|
List<SysField> baseCol = baseFieldList.stream().filter(sysField -> sysField.getField().equalsIgnoreCase(s)).collect(Collectors.toList());
|
List<SysField> compareCol = compareFieldList.stream().filter(sysField -> sysField.getField().equalsIgnoreCase(s)).collect(Collectors.toList());
|
SysField baseField = baseCol.get(0);
|
SysField sysField = compareCol.get(0);
|
if (!baseField.equals(sysField)) {
|
if (pre) {
|
//base 大
|
changedList.add(baseField);
|
} else {
|
changedList.add(sysField);
|
}
|
}
|
}
|
JSONObject object = new JSONObject();
|
if (pre) {
|
object.fluentPut("create", baseExprotFieldList);
|
object.fluentPut("delete", compareExprotFieldList);
|
object.fluentPut("update", changedList);
|
} else {
|
object.fluentPut("create", compareExprotFieldList);
|
object.fluentPut("delete", baseExprotFieldList);
|
object.fluentPut("update", changedList);
|
}
|
return object;
|
}
|
|
@Override
|
public boolean checkdMaxVersion(String maintainId) {
|
Maintain maintain = selectById(maintainId);
|
Maintain maxVersion = getMaxVersion(maintain.getTableName());
|
Integer compared = DbUtils.compareVersion(maxVersion, maintain);
|
if (compared == 0) {
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
@Override
|
public Maintain getMaxVersion(String tableName) {
|
Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");
|
|
Maintain maxVersion = selectOne(versionWrapper);
|
return maxVersion;
|
}
|
|
@Override
|
public Maintain getUnFlowMaxVersion(String tableName) {
|
Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().isNull("flow_id").eq("table_name", tableName).orderBy("order_no desc");
|
|
Maintain maxVersion = selectOne(versionWrapper);
|
return maxVersion;
|
}
|
|
@Override
|
public Maintain getInvalidMaxVersion(String tableName) {
|
Maintain result = null;
|
Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("order_no desc");
|
|
List<Maintain> maintainList = selectList(versionWrapper);
|
|
for (Maintain maintain : maintainList) {
|
String flowId = maintain.getFlowId();
|
if (StringUtils.isEmpty(flowId)) {
|
result = maintain;
|
} else {
|
Flows flows = flowsService.selectById(flowId);
|
if (flows == null) {
|
continue;
|
}
|
if (!flows.getStatus().equals(ActivitiStatus.open) && !flows.getStatus().equals(ActivitiStatus.close)) {
|
result = maintain;
|
}
|
}
|
|
}
|
return result;
|
}
|
|
@Override
|
public Long getInvalidVerionDataCnt(TUser user, String tableName, String where) {
|
Maintain invalidVersion = getInvalidMaxVersion(tableName);
|
if (invalidVersion == null) {
|
return null;
|
}
|
String tableTempName = tableName + Constant.RECORD;
|
String tempFields = masterDataService.getTempFields(user, tableName);
|
Long count = maintainMapper.countInvalidVersionData(tableTempName, where, invalidVersion.getOrderNo());
|
return count;
|
}
|
@Override
|
public Result getInvalidVerionData(TUser user, String tableName, String where, Integer pageNo, Integer pageSize) {
|
Maintain invalidVersion = getInvalidMaxVersion(tableName);
|
if (invalidVersion == null) {
|
return Result.success(null);
|
}
|
String tableTempName = tableName + Constant.RECORD;
|
String tempFields = masterDataService.getTempFields(user, tableName);
|
Long count = maintainMapper.countInvalidVersionData(tableTempName, where, invalidVersion.getOrderNo());
|
Page page = new Page(count);
|
page.setPageNo(pageNo);
|
if (pageSize != null) {
|
page.setPageSize(pageSize);
|
}
|
List<Map<String, Object>> maps = maintainMapper.selectInvalidVersionData(tableTempName, tempFields, where, invalidVersion.getOrderNo(), page.getLimitSQL());
|
JSONObject resultObj = new JSONObject();
|
JSONObject object = new JSONObject();
|
object.fluentPut("record", maps);
|
object.fluentPut("total", page.getRecordCount());
|
object.fluentPut("size", page.getPageSize());
|
object.fluentPut("pages", page.getPageCount());
|
object.fluentPut("current", page.getPageNo());
|
resultObj.fluentPut("grid", object);
|
return Result.success(resultObj);
|
}
|
|
@Override
|
public Maintain getNowVersion(String tableName) {
|
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());
|
if (flows == null) {
|
continue;
|
}
|
ActivitiStatus status = flows.getStatus();
|
if (status.equals(ActivitiStatus.open)) {
|
return maintain;
|
}
|
}
|
return null;
|
//return selectOne(new EntityWrapper<Maintain>().eq("table_name", tableName).orderBy("version desc"));
|
}
|
|
|
@Override
|
public Maintain getMaintainFromVersion(String tableName, String verison) {
|
Wrapper<Maintain> versionWrapper = new EntityWrapper<Maintain>().eq("version", verison).eq("table_name", tableName);
|
Maintain maxVersion = selectOne(versionWrapper);
|
return maxVersion;
|
}
|
|
|
@Override
|
public List<Map<String, Object>> selectVersionOperatorByType(String tableTempName, String maintaInId, Operate operate) {
|
return maintainMapper.selectVersionOperatorByType(tableTempName, Constant.WHERE_DEFAULT, maintaInId, operate.name());
|
}
|
|
|
@Override
|
public long countVersionOperatorByType(String tableTempName, String filterSegment, String maintaInId, Operate operate) {
|
return maintainMapper.countVersionOperatorByType(tableTempName, filterSegment, maintaInId, operate.name());
|
}
|
|
|
@Override
|
public List<Map<String, Object>> selectVersionOperatorByTypeByPage(String tableTempName, String maintaInId, Operate operate, String limit) {
|
return maintainMapper.selectVersionOperatorByTypeByPage(tableTempName, Constant.WHERE_DEFAULT, maintaInId, operate.name(), limit);
|
}
|
|
|
@Override
|
public List<String> getCompareVersionMaintains(Maintain unFlowMaxVersion, Maintain maintainFromVersion) {
|
Integer compare = DbUtils.compareVersion(unFlowMaxVersion, maintainFromVersion);
|
ArrayList<String> ids = new ArrayList<>();
|
if (compare > 0) {
|
getVerionMatintains(unFlowMaxVersion, maintainFromVersion, ids);
|
} else if (compare == 0) {
|
ids.add(unFlowMaxVersion.getId());
|
} else {
|
getVerionMatintains(maintainFromVersion, unFlowMaxVersion, ids);
|
}
|
return ids;
|
}
|
|
@Override
|
public Result tempDataByVersionByFlow(TUser user, String flowId, String whereSegment, Integer pageNo, Integer pageSize) {
|
Flows flows = flowsService.selectById(flowId);
|
if (flows == null) {
|
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
|
}
|
String businessId = flows.getBusinessId();
|
Maintain maintain = selectById(businessId);
|
if (maintain == null) {
|
return Result.error(CodeMsg.SELECT_ERROR_NOTFOUND);
|
}
|
String fields = masterDataService.getTempFields(user, maintain.getTableName());
|
String tableTempName = maintain.getTableName() + Constant.RECORD;
|
long total = maintainMapper.countTempDataByVersionByFlow(tableTempName, flowId, whereSegment);
|
|
Page page = new Page(total);
|
if (pageNo != null) {
|
page.setPageNo(pageNo);
|
if (pageSize != null) {
|
page.setPageSize(pageSize);
|
}
|
} else {
|
page.setPageNo(1);
|
}
|
|
List<Map<String, Object>> maps = maintainMapper.tempDataByVersionByFlow(tableTempName, flowId, fields, whereSegment, page.getLimitSQL());
|
|
JSONObject object = new JSONObject();
|
|
object.fluentPut("total", page.getRecordCount());
|
object.fluentPut("size", page.getPageSize());
|
object.fluentPut("pages", page.getPageCount());
|
object.fluentPut("current", page.getPageNo());
|
object.fluentPut("record", maps);
|
|
return Result.success(object);
|
}
|
|
@Override
|
public Map<String, Object> getPreInfo(Maintain maintain, String id) {
|
String maintainTableName = maintain.getTableName();
|
String recordTableName = maintainTableName + Constant.RECORD;
|
List<Map<String, Object>> maps = maintainDetailMapper.seleMaintainDetailByDataId(recordTableName, maintain.getId(), id);
|
|
if (maps == null) {
|
return null;
|
}
|
if (maps == null || maps.isEmpty()) {
|
return null;
|
}
|
Map<String, Object> stringObjectMap = maps.get(0);
|
String createTime = stringObjectMap.get("createTime").toString();
|
List<SysField> fieldByMaintain = fieldService.getFieldByMaintain(maintain.getId());
|
String fields = fieldByMaintain.stream().map(sysField -> sysField.getField())
|
.map(s -> s.equalsIgnoreCase(Constant.ID) ? MessageFormat.format("{0} as id", Constant.STD_ID) : s)
|
.collect(Collectors.joining(Constant.COMMA));
|
|
List<Map<String, Object>> preData = maintainDetailMapper.getPreData(fields, recordTableName, id, createTime);
|
if (preData == null || preData.isEmpty()) {
|
return null;
|
}
|
Map<String, Object> result = preData.get(0);
|
String maintainId = result.get("maintainId").toString();
|
Maintain preMaintain = selectById(maintainId);
|
if (preMaintain != null) {
|
String chargeId = preMaintain.getChargeId();
|
TUser userById = DbUtils.getUserById(chargeId);
|
if (userById != null) {
|
result.put("userName", userById.getUserName());
|
}
|
}
|
return result;
|
}
|
|
|
private void getVerionMatintains(Maintain firstVersion, Maintain secondVersion, List<String> ids) {
|
Integer fromNo = firstVersion.getOrderNo();
|
Integer toNo = secondVersion.getOrderNo();
|
for (int i = fromNo + 1; i <= toNo; i++) {
|
Maintain maintain = selectOne(new EntityWrapper<Maintain>().eq("table_name", firstVersion.getTableName()).eq("order_no", i));
|
ids.add(maintain.getId());
|
}
|
}
|
}
|
