1

13693261870

2023-08-09 8dc3482deec2f25a0618f7ae1f62a1ce07116d7a

1

 src/main/java/com/moon/server/config/ScheduleConfig.java

@@ -91,27 +91,4 @@
            log.error(ex.getMessage(), ex);
        }
    }

    /**
     * 同步附件
     */
    @Scheduled(fixedRate = 30 * 1000)
    public void syncAttaches() {
        try {
            List<FmeLogEntity> list = attachService.selectFmeLogs();
            if (isBusy || null == list || list.isEmpty()) {
                return;
            }

            isBusy = true;
            for (FmeLogEntity entity : list) {
                attachService.syncAttaches(entity);
                attachService.updateFmeLog(entity.getId());
            }
            isBusy = false;
        } catch (Exception ex) {
            isBusy = false;
            log.error(ex.getMessage(), ex);
        }
    }
}

 src/main/java/com/moon/server/service/all/ScheduleService.java

@@ -140,7 +140,6 @@

    /**
     * 统计在线用户数
     * @return
     */
    public int countOnlineUsers() {
        Set<String> keys = redisTemplate.keys(RedisCacheKey.signUserKey("*"));
@@ -157,23 +156,26 @@
        return testResStatus(resList);
    }

    /**
     * 测试资源状态
     */
    private List<ResEntity> testResStatus(List<ResEntity> resList) {
        List<ResEntity> list = new ArrayList<ResEntity>();
        List<ResEntity> list = new ArrayList<>();
        for (ResEntity re : resList) {
            Socket socket = new Socket();
            try {
                if (StringHelper.isEmpty(re.getTest())) {
                if (StringHelper.isEmpty(re.getUrl())) {
                    list.add(re);
                    continue;
                }

                URI uri = new URI(re.getTest());
                URI uri = new URI(re.getUrl());
                SocketAddress add = new InetSocketAddress(uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort());

                // Ping通地址
                socket.connect(add, 2000);
            } catch (Exception e) {
                log.error(e.getMessage());
                // log.error(e.getMessage())
                list.add(re);
            } finally {
                try {