lqc 5 лет назад
Родитель
Сommit
81448cd8c6

+ 13 - 6
src/main/java/com/mokamrp/privates/controller/pangu/FosterwxFlowListController.java

@@ -65,12 +65,6 @@ public class FosterwxFlowListController extends BaseController<FosterwxFlowList>
         // 查看是否超过百分之五十
         if (fosterwxFlowList.getBusFans() > maxFans / 2.0) {
             // 超过
-            // 更新个微池状态为停用
-            fosterwxMobilePool.setStatus(0);
-            fosterwxMobilePool.setUpdateUid(fosterwxFlowList.getUpdateUid());
-            fosterwxMobilePool.setUpdateAt(LocalDateTime.now());
-            fosterwxMobilePoolService.updateById(fosterwxMobilePool);
-
             // 更新
             FosterwxFlowList lastPosition = fosterwxFlowListService.getOne(new QueryWrapper<FosterwxFlowList>().eq("pool_id", fosterwxFlowList.getPoolId()));
             String position = "";
@@ -87,6 +81,14 @@ public class FosterwxFlowListController extends BaseController<FosterwxFlowList>
             fosterwxFlowListService.save(fosterwxFlowList);
             // 更新全部位置为超限
             fosterwxFlowListService.update(new FosterwxFlowList(1), new QueryWrapper<FosterwxFlowList>().eq("pool_id", fosterwxFlowList.getPoolId()));
+
+
+            // 更新个微池状态为停用
+            fosterwxMobilePool.setStatus(0);
+            fosterwxMobilePool.setFlowPosition(position);
+            fosterwxMobilePool.setUpdateUid(fosterwxFlowList.getUpdateUid());
+            fosterwxMobilePool.setUpdateAt(LocalDateTime.now());
+            fosterwxMobilePoolService.updateById(fosterwxMobilePool);
         } else {
             // 未超过
             // 查找上一个流量位置
@@ -108,6 +110,11 @@ public class FosterwxFlowListController extends BaseController<FosterwxFlowList>
             // 设置状态
             fosterwxFlowList.setStatus(1);
             fosterwxFlowListService.save(fosterwxFlowList);
+            // 更新个微池流量位置
+            fosterwxMobilePool.setFlowPosition(position);
+            fosterwxMobilePool.setUpdateUid(fosterwxFlowList.getUpdateUid());
+            fosterwxMobilePool.setUpdateAt(LocalDateTime.now());
+            fosterwxMobilePoolService.updateById(fosterwxMobilePool);
         }