fengji 添加邮件测试

mec-biz/src/main/java/com/ym/mec/biz/service/TenantInfoService.java

@@ -36,4 +36,6 @@ public interface TenantInfoService extends IService<TenantInfo> {
     Boolean rechargeCheck(String orderNo) throws Exception;
 
     TenantProductSumm queryTenantInfoProductSumm(Integer id);
+
+    Boolean testEmail();
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/OrderPayOpsServiceImpl.java

@@ -267,6 +267,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
         });
     }
 
+    // 检查云教室
     private void delayCheckCloudTeacherOrder(TenantOrderRecord record) {
         RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
         if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
@@ -276,7 +277,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
         CompletableFuture.runAsync(() -> {
             //检查5次
             Boolean ret = false;
-            for (int i = 0; i <= 5; i++) {
+            for (int i = 0; i <= 15; i++) {
                 try {
                     ret = cloudTeacherOrderService.payCheck(record);
                     if (ret) break;
@@ -294,6 +295,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
         });
     }
 
+    // 检查机构充值
     private void delayCheckTenantRecharge(TenantOrderRecord record) {
         RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
         if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
@@ -303,7 +305,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
         //异步
         CompletableFuture.runAsync(() -> {
             //检查5次
-            for (int i = 0; i <= 5; i++) {
+            for (int i = 0; i <= 15; i++) {
                 try {
                     Boolean ret = tenantOrderRecordService.rechargeCheck(record);
                     if (ret) break;

mec-biz/src/main/java/com/ym/mec/biz/service/impl/TenantInfoServiceImpl.java

@@ -24,6 +24,7 @@ import com.ym.mec.common.page.PageInfo;
 import com.ym.mec.common.page.PageUtil;
 import com.ym.mec.common.page.WrapperUtil;
 import com.ym.mec.common.service.IdGeneratorService;
+import com.ym.mec.thirdparty.message.MessageSenderPluginContext;
 import com.ym.mec.thirdparty.yqpay.DateUtils;
 import com.ym.mec.thirdparty.yqpay.Msg;
 import com.ym.mec.util.date.DateUtil;
@@ -82,6 +83,8 @@ public class TenantInfoServiceImpl extends ServiceImpl<TenantInfoDao, TenantInfo
     private TenantAssetsInfoService assetsInfoService;
     @Autowired
     private StudentService studentService;
+    @Autowired
+    private SysMessageService sysMessageService;
 
     /**
      * 新增机构
@@ -665,4 +668,9 @@ public class TenantInfoServiceImpl extends ServiceImpl<TenantInfoDao, TenantInfo
     }
 
 
+    @Override
+    public Boolean testEmail() {
+        // sysMessageService.batchSendMessage(MessageSener.);
+        return false;
+    }
 }

mec-web/src/main/java/com/ym/mec/web/controller/TenantInfoController.java

@@ -133,4 +133,10 @@ public class TenantInfoController extends BaseController {
     ) throws Exception {
         return succeed(tenantInfoService.rechargeCheck(orderNo));
     }
+
+    @ApiOperation(value = "测试邮件")
+    @GetMapping("/testEmail")
+    public HttpResponseResult<Boolean> testEmail() throws Exception {
+        return succeed(tenantInfoService.testEmail());
+    }
 }