1

13693261870

2024-12-11 c6550a4d9bd69e59e9bb6ac6ad740e509edbd215

1

 docker-compose/mysql/initdb/se_cloud_20240629.sql

@@ -634,8 +634,8 @@
  primary key (job_id, job_name, job_group)
) engine=innodb auto_increment=4 comment = '定时任务调度表';

insert into sys_job values(1, '软件状态检测定时任务',   'DEFAULT', 'ryTask.runSoftTest',    '0/10 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
insert into sys_job values(2, '系统状态检测定时任务', 'DEFAULT', 'ryTask.runSubSysTest',  '0/10 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
insert into sys_job values(1, '软件状态检测定时任务',   'DEFAULT', 'ryTask.runSoftTest',    '0/20 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
insert into sys_job values(2, '系统状态检测定时任务', 'DEFAULT', 'ryTask.runSubSysTest',  '0/20 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
-- insert into sys_job values(3, '系统默认（多参）', 'DEFAULT', 'ryTask.ryMultipleParams(\'ry\', true, 2000L, 316.50D, 100)',  '0/20 * * * * ?', '3', '1', '1', 'admin', sysdate(), '', null, '');
-- select * from sys_job order by job_id;


 se-common/se-common-core/src/main/java/com/se/common/core/utils/ServletUtils.java

@@ -283,7 +283,7 @@
     */
    public static Mono<Void> webFluxResponseWriter(ServerHttpResponse response, Object value)
    {
        return webFluxResponseWriter(response, HttpStatus.OK, value, R.FAIL);
        return webFluxResponseWriter(response, HttpStatus.INTERNAL_SERVER_ERROR, value, R.FAIL);
    }

    /**

 se-modules/se-system/src/main/java/com/se/system/mapper/SysStatusCtrlMapper.java

@@ -2,6 +2,7 @@

import java.util.List;
import com.se.system.domain.SysStatusCtrl;
import org.apache.ibatis.annotations.Param;

/**
 * ç³»ç»ŸçŠ¶æ€ç›‘控Mapper接口
@@ -9,8 +10,8 @@
 * @author se
 * @date 2024-12-07
 */
public interface SysStatusCtrlMapper 
{
@SuppressWarnings("ALL")
public interface SysStatusCtrlMapper {
    /**
     * æŸ¥è¯¢ç³»ç»ŸçŠ¶æ€ç›‘控
     * 
@@ -58,4 +59,6 @@
     * @return ç»“æžœ
     */
    public int deleteSysStatusCtrlByStatusIds(Long[] statusIds);

    public int updates(@Param("list") List<SysStatusCtrl> list);
}

 se-modules/se-system/src/main/java/com/se/system/service/impl/SysSoftServiceImpl.java

@@ -107,10 +107,12 @@
        return list;
    }

    public void runSoftTest() throws Exception {
    public void runSoftTest() {
        List<SysSoft> list = getList();
        if (CollectionUtils.isEmpty(list)) return;

        //
        for (SysSoft soft : list) {
            //docker
        }
    }
}

 se-modules/se-system/src/main/java/com/se/system/service/impl/SysStatusCtrlServiceImpl.java

@@ -2,8 +2,9 @@

import java.util.List;
import com.se.common.core.utils.DateUtils;
import com.se.system.domain.SysSoft;
import com.se.system.utils.CaffeineUtils;
import com.se.system.utils.ConnectUtils;
import com.se.system.utils.StringUtils;
import org.springframework.stereotype.Service;
import com.se.system.mapper.SysStatusCtrlMapper;
import com.se.system.domain.SysStatusCtrl;
@@ -108,10 +109,23 @@
        return list;
    }

    public void runSubSysTest() throws Exception {
    public void runSubSysTest() {
        List<SysStatusCtrl> list = getList();
        if (CollectionUtils.isEmpty(list)) return;

        //
        for (SysStatusCtrl ctrl : list) {
            ctrl.setStatus("0");
            ctrl.setRemark("");
            if (!StringUtils.isEmpty(ctrl.getIp()) && !ConnectUtils.isReachable(ctrl.getIp())) {
                ctrl.setStatus("1");
                ctrl.setRemark("IP不连通");
            }
            if (!StringUtils.isEmpty(ctrl.getUrl()) && !ConnectUtils.testUrl(ctrl.getUrl(), ctrl.getMethod())) {
                ctrl.setStatus("1");
                ctrl.setRemark((ctrl.getRemark().length() > 0 ? ctrl.getRemark() + "，" : "") + "URL连接不上");
            }
        }

        sysStatusCtrlMapper.updates(list);
    }
}

 se-modules/se-system/src/main/java/com/se/system/utils/ConnectUtils.java

@@ -1,8 +1,6 @@
package com.se.system.utils;

import java.net.HttpURLConnection;
import java.net.InetAddress;
import java.net.URL;
import java.net.*;

@SuppressWarnings("ALL")
public class ConnectUtils {
@@ -10,18 +8,33 @@
        try {
            InetAddress inetAddress = InetAddress.getByName(ip);

            return inetAddress.isReachable(1000);
            return inetAddress.isReachable(1500);
        } catch (Exception ex) {
            return false;
        }
    }

    public static boolean getUrl(String uri, String method) {
    public static boolean isReachable(String addr) {
        try {
            String[] strs = addr.split(":");
            InetSocketAddress socketAddress = new InetSocketAddress(strs[0], strs.length < 2 || StringUtils.isEmpty(strs[1]) ? 80 : Integer.parseInt(strs[1]));

            Socket socket = new Socket();
            socket.connect(socketAddress, 1500);
            socket.close();

            return true;
        } catch (Exception ex) {
            return false;
        }
    }

    public static boolean testUrl(String uri, String method) {
        try {
            URL url = new URL(uri);

            HttpURLConnection con = (HttpURLConnection) url.openConnection();
            con.setRequestMethod(method);
            con.setRequestMethod(StringUtils.isEmpty(method) ? "GET" : method);
            con.setConnectTimeout(1000);
            con.setReadTimeout(1000);


 se-modules/se-system/src/main/java/com/se/system/utils/RyTask.java

@@ -36,12 +36,12 @@
        System.out.println("执行无参方法");
    }

    public void runSoftTest() throws Exception {
    public void runSoftTest() {
        System.out.println("ryTask.runSoftTest()");
        sysSoftService.runSoftTest();
    }

    public void runSubSysTest() throws Exception {
    public void runSubSysTest() {
        System.out.println("ryTask.runSubSysTest()");
        sysStatusCtrlService.runSubSysTest();
    }

 se-modules/se-system/src/main/resources/mapper/system/SysStatusCtrlMapper.xml

@@ -98,4 +98,12 @@
            #{statusId}
        </foreach>
    </delete>

    <update id="updates">
        <foreach collection="list" item="item" index="index" separator=";">
            update sys_status_ctrl
            set status = #{item.status}, remark = #{item.remark}, update_time = now()
            where status_id = #{item.statusId}
        </foreach>
    </update>
</mapper>

 ˵Ã÷.txt

@@ -109,3 +109,5 @@
top -N 10
ps -ef | grep wgcloud
kill -9 10086

url: jdbc:mysql://localhost:3306/se-cloud?useUnicode=true&characterEncoding=utf8&rewriteBatchedStatements=true&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8