springtestcase

admin/src/test/java/SpringTestCase.java

@@ -0,0 +1,20 @@
+import com.kym.admin.AdminApplication;
+import com.kym.service.admin.ActivityService;
+import com.kym.service.admin.impl.ActivityServiceImpl;
+import jakarta.annotation.Resource;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+
+@SpringBootTest(classes = AdminApplication.class)
+public class SpringTestCase {
+
+    @Resource
+    private ActivityService activityService;
+
+    @Test
+    public void testActivityAsync() throws InterruptedException {
+        activityService.handleRechargeActivity(100001,1);
+        Thread.sleep(210*1000);
+    }
+}

service/src/main/java/com/kym/service/admin/impl/ActivityServiceImpl.java

@@ -174,6 +174,7 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
 
         @Override
         public void run() {
+            log.info("RechargeActivityTask run....");
             // 进行中的充值权益活动
             var activity = lambdaQuery().eq(Activity::getDiscountType, DISCOUNT_TYPE_服务费折扣权益).eq(Activity::getStatus, Activity.STATUS_进行中).one();
             // 充值金额，匹配到到具体的充值权益，生成用户权益
@@ -190,6 +191,7 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
                     userRechargeRightsService.save(userRechargeRights.setStartTime(LocalDateTime.now()).setEndTime(endTime));
                 }
             }
+            log.info("RechargeActivityTask run end....");
         }
     }
 }