版本检查

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/DEFieldDefaultValueAspect.java.ftl

@@ -26,7 +26,7 @@ import java.util.Map;
  * 实体属性默认值切面，只有新建（Create）时才会填充默认值
  */
 @Aspect
-@Order(0)
+@Order(50)
 @Component
 public class DEFieldDefaultValueAspect
 {

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/VersionCheckAspect.java.ftl

@@ -4,7 +4,6 @@ TARGET=PSSYSTEM
 package ${pub.getPKGCodeName()}.util.aspect;
 
 import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
 import ${pub.getPKGCodeName()}.util.annotation.VersionCheck;
 import ${pub.getPKGCodeName()}.util.domain.EntityBase;
 import ${pub.getPKGCodeName()}.util.errors.BadRequestAlertException;
@@ -27,7 +26,7 @@ import java.lang.reflect.Field;
  * 数据库版本检查
  */
 @Aspect
-@Order(0)
+@Order(50)
 @Component
 public class VersionCheckAspect
 {
@@ -36,22 +35,40 @@ public class VersionCheckAspect
     @SneakyThrows
     @Before("execution(* ${pub.getPKGCodeName()}.*.rest.*.update(..)) &&  @annotation(versionCheck)")
     public void BeforeUpdate(JoinPoint point, VersionCheck versionCheck){
-        EvaluationContext context = new StandardEvaluationContext();
         Object[] args = point.getArgs();
         Object id=args[0];
         Object dto=args[1];
         if(ObjectUtils.isEmpty(id) || ObjectUtils.isEmpty(dto))
             return;
         String versionField=versionCheck.versionfield();
-        if(StringUtils.isEmpty(versionCheck))
+        if(StringUtils.isEmpty(versionField))
+            return;
+        versionCheck(versionCheck,point.getTarget(),dto,id);
+    }
+
+    @SneakyThrows
+    @Before("execution(* ${pub.getPKGCodeName()}.*.rest.*.updateBy*(..)) &&  @annotation(versionCheck)")
+    public void BeforeUpdateBy(JoinPoint point, VersionCheck versionCheck){
+        Object[] args = point.getArgs();
+        Object id=args[1];
+        Object dto=args[2];
+        if(ObjectUtils.isEmpty(id) || ObjectUtils.isEmpty(dto))
+            return;
+        String versionField=versionCheck.versionfield();
+        if(StringUtils.isEmpty(versionField))
             return;
+        versionCheck(versionCheck,point.getTarget(),dto,id);
+    }
+
+    private void versionCheck(VersionCheck versionCheck,Object resource,Object dto,Object id ){
+        EvaluationContext context = new StandardEvaluationContext();
         context.setVariable("dto",dto);
-        Expression newExp = parser.parseExpression(String.format("#dto.%s",versionField));
+        Expression newExp = parser.parseExpression(String.format("#dto.%s",versionCheck.versionfield()));
         Object newVersion=newExp.getValue(context);
         if(ObjectUtils.isEmpty(newVersion))
             return;
         //进行版本检查
-        Object oldVersion =getDBVersion(versionCheck,getService(point.getTarget(),versionCheck.entity()),id);
+        Object oldVersion =getDBVersion(versionCheck,getService(resource,versionCheck.entity()),id);
         if(!ObjectUtils.isEmpty(oldVersion)){
             if(RuleUtils.gt(newVersion,oldVersion))
                 throw new BadRequestAlertException("数据已变更，可能后台数据已被修改，请重新加载数据","VersionCheckAspect","versionCheck");