| | |
| | | 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(); |
| | |
| | | |
| | | @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); |
| | |
| | | |
| | | @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; |
| | |
| | | |
| | | @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; |
| | |
| | | @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); |
| | | |
| | |
| | | |
| | | @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) { |
| | |
| | | @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()); |
| | |
| | | } |
| | | } |
| | | 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(); |
| | | Maintain nowVersion = getNowVersion(tableName); |