检查silk2mp3

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/OpenStaffServiceImpl.java

@@ -31,6 +31,7 @@ import com.gic.haoban.manage.service.pojo.QwOpenResultInitBO;
 import com.gic.haoban.manage.service.service.OpenStaffService;
 import com.gic.haoban.manage.service.service.StaffClerkRelationService;
 import com.gic.haoban.manage.service.util.OpenUtils;
+import com.gic.redis.data.util.RedisUtil;
 import com.github.pagehelper.PageHelper;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -254,16 +255,24 @@ public class OpenStaffServiceImpl implements OpenStaffService {
     @Override
     public void openStaffTimer() {
         log.info("定时检查托管状态");
+        Object o = RedisUtil.getCache("haobansilk2mp3") ;
+        if(null == o) {
+            com.gic.haoban.common.utils.DingUtils.send("请检查silk2mp3", false);
+        }
         List<TabOpenStaff> list = this.openStaffMapper.listAllOnline(null, null);
         for (TabOpenStaff item : list) {
-            String uuid = item.getUuid();
-            boolean isLogin = OpenUtils.isLogin(uuid);
-            // 未登录
-            if (!isLogin) {
-                String autLogin = this.autoLogin(item.getOpenStaffId(), item.getQwUserId());
-                if (null == autLogin) {
-                    this.logout(uuid, "定时检查异", 0, OpenStaffOfflineEnum.OFFLINE2.getDesc());
+            try{
+                String uuid = item.getUuid();
+                boolean isLogin = OpenUtils.isLogin(uuid);
+                // 未登录
+                if (!isLogin) {
+                    String autLogin = this.autoLogin(item.getOpenStaffId(), item.getQwUserId());
+                    if (null == autLogin) {
+                        this.logout(uuid, "定时检查异", 0, OpenStaffOfflineEnum.OFFLINE2.getDesc());
+                    }
                 }
+            }catch (Exception e) {
+                log.info("异常",e);
             }
         }
     }

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/open/QywxOpenTaskController.java

@@ -42,6 +42,7 @@ import com.gic.member.tag.api.dto.MemberTagItemDTO;
 import com.gic.member.tag.api.service.MemberTagApiService;
 import com.gic.member.tag.api.service.MemberTagGroupApiService;
 import com.gic.qcloud.BucketNameEnum;
+import com.gic.redis.data.util.RedisUtil;
 import com.gic.thirdparty.cloudfile.CloudFileUtil;
 import com.gic.thirdparty.cloudfile.enums.CloudFileBusinessOptEnum;
 import com.gic.thirdparty.cloudfile.enums.CloudFileTypeEnum;
@@ -66,6 +67,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -781,6 +783,7 @@ public class QywxOpenTaskController {
     @IgnoreLogin
     public Object listSilk() {
         List<OpenQwSilkMp3DTO> ret = this.openQwApiService.listSilk();
+        RedisUtil.setCache("haobansilk2mp3",1,3L, TimeUnit.MINUTES);
         return RestResponse.successResult(ret);
     }