@ -1,12 +1,14 @@
@@ -1,12 +1,14 @@
package apelet.common.botp.service.impl ;
import apelet.common.botp.dao.ConvertPluginEntryMapper ;
import apelet.common.botp.dao.ReverseWritingRulesMapper ;
import apelet.common.botp.dao.ReverseWritingRulesVerMapper ;
import apelet.common.botp.dto.ReverseWritingRulesDto ;
import apelet.common.botp.dto.RuleVersionDiffDto ;
import apelet.common.botp.model.* ;
import apelet.common.botp.model.ReverseWritingBusiness ;
import apelet.common.botp.model.ReverseWritingFormula ;
import apelet.common.botp.model.ReverseWritingRules ;
import apelet.common.botp.model.ReverseWritingRulesVer ;
import apelet.common.botp.service.IReverseWritingBusinessService ;
import apelet.common.botp.service.IReverseWritingFormulaService ;
import apelet.common.botp.service.IReverseWritingRulesService ;
@ -23,7 +25,12 @@ import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +25,12 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service ;
import org.springframework.transaction.annotation.Transactional ;
import java.util.* ;
import java.util.ArrayList ;
import java.util.Arrays ;
import java.util.Date ;
import java.util.LinkedHashMap ;
import java.util.List ;
import java.util.Map ;
import java.util.stream.Collectors ;
@Service
@ -38,8 +45,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
@@ -38,8 +45,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
ReverseWritingRulesMapper reverseWritingRulesMapper ;
@Autowired
ReverseWritingRulesVerMapper reverseWritingRulesVerMapper ;
@Autowired
ConvertPluginEntryMapper convertPluginEntryMapper ;
@ -54,13 +59,11 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
@@ -54,13 +59,11 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
}
List < ReverseWritingBusiness > businessesList = businessService . list ( new LambdaQueryWrapper < ReverseWritingBusiness > ( ) . in ( ReverseWritingBusiness : : getRulesId , ids ) ) ;
List < ReverseWritingFormula > formulaList = formulaService . list ( new LambdaQueryWrapper < ReverseWritingFormula > ( ) . in ( ReverseWritingFormula : : getRulesId , ids ) ) ;
List < ConvertPluginEntry > convertPluginEntryList = convertPluginEntryMapper . selectList ( new LambdaQueryWrapper < ConvertPluginEntry > ( ) . in ( ConvertPluginEntry : : getParentId , ids ) ) ;
list . forEach ( f - > {
ReverseWritingRulesDto dto = new ReverseWritingRulesDto ( ) ;
BeanUtils . copyProperties ( f , dto ) ;
dto . setBusinessList ( businessesList . stream ( ) . filter ( b - > b . getRulesId ( ) . equals ( f . getId ( ) ) ) . collect ( Collectors . toList ( ) ) ) ;
dto . setFormulaList ( formulaList . stream ( ) . filter ( b - > b . getRulesId ( ) . equals ( f . getId ( ) ) ) . collect ( Collectors . toList ( ) ) ) ;
dto . setConvertPluginEntryList ( convertPluginEntryList . stream ( ) . filter ( b - > b . getParentId ( ) . equals ( f . getId ( ) . toString ( ) ) ) . collect ( Collectors . toList ( ) ) ) ;
dtoList . add ( dto ) ;
} ) ;
return dtoList ;
@ -102,7 +105,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
@@ -102,7 +105,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
// 分录按规则id全量覆盖
formulaService . remove ( new LambdaQueryWrapper < ReverseWritingFormula > ( ) . eq ( ReverseWritingFormula : : getRulesId , reverseWritingRules . getId ( ) ) ) ;
businessService . remove ( new LambdaQueryWrapper < ReverseWritingBusiness > ( ) . eq ( ReverseWritingBusiness : : getRulesId , reverseWritingRules . getId ( ) ) ) ;
convertPluginEntryMapper . delete ( new LambdaQueryWrapper < ConvertPluginEntry > ( ) . eq ( ConvertPluginEntry : : getParentId , reverseWritingRules . getId ( ) . toString ( ) ) ) ;
remark = RuleSnapshotUtil . REMARK_UPDATE ;
snapshotVersion = RuleVersionUtil . next ( baseVersion ) ;
} else {
@ -128,14 +130,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
@@ -128,14 +130,6 @@ public class ReverseWritingRulesServiceImpl extends ServiceImpl<ReverseWritingRu
businessList . forEach ( f - > f . setRulesId ( reverseWritingRules . getId ( ) ) ) ;
businessService . saveBatch ( businessList ) ;
}
List < ConvertPluginEntry > convertPluginEntryList = dto . getConvertPluginEntryList ( ) ;
if ( ObjectUtil . isNotEmpty ( convertPluginEntryList ) ) {
convertPluginEntryList . forEach ( f - > {
f . setParentId ( reverseWritingRules . getId ( ) . toString ( ) ) ;
convertPluginEntryMapper . insert ( f ) ;
} ) ;
}
// 落全量快照
saveSnapshot ( reverseWritingRules . getId ( ) , snapshotVersion , remark ) ;
return reverseWritingRules ;