diff --git a/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/controller/BreakLogController.java b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/controller/BreakLogController.java new file mode 100644 index 0000000..c72bb04 --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/controller/BreakLogController.java @@ -0,0 +1,31 @@ +package com.zhilian.business.controller; + +import com.zhilian.business.domain.BreakLog; +import com.zhilian.business.service.BreakLogService; +import com.zhilian.common.core.domain.Result; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * @ClassName BreakLogController + * @Description TODO + * @Author YuanYongH + * @Date 2024/4/8 20:48 + */ +@RestController +public class BreakLogController { + + @Autowired + private BreakLogService breakLogService; + + @PostMapping("log") + public Result> breakLog() { + List list = breakLogService.breakLog(); + Result> success = Result.success(list); + return success; + } + +} diff --git a/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/mapper/BreakLogMapper.java b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/mapper/BreakLogMapper.java new file mode 100644 index 0000000..0da85db --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/mapper/BreakLogMapper.java @@ -0,0 +1,18 @@ +package com.zhilian.business.mapper; + +import com.zhilian.business.domain.BreakLog; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * @ClassName BreakLogMapper + * @Description TODO + * @Author YuanYongH + * @Date 2024/4/8 20:49 + */ +@Mapper +public interface BreakLogMapper { + List breakLog(); + +} diff --git a/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/BreakLogService.java b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/BreakLogService.java new file mode 100644 index 0000000..a2c9dc0 --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/BreakLogService.java @@ -0,0 +1,16 @@ +package com.zhilian.business.service; + +import com.zhilian.business.domain.BreakLog; + +import java.util.List; + +/** + * @ClassName BreakLogService + * @Description TODO + * @Author YuanYongH + * @Date 2024/4/8 20:49 + */ +public interface BreakLogService { + List breakLog(); + +} diff --git a/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/impl/BreakLogServiceImpl.java b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/impl/BreakLogServiceImpl.java new file mode 100644 index 0000000..d373650 --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/java/com/zhilian/business/service/impl/BreakLogServiceImpl.java @@ -0,0 +1,67 @@ +package com.zhilian.business.service.impl; + +import com.zhilian.business.domain.BreakLog; +import com.zhilian.business.mapper.BreakLogMapper; +import com.zhilian.business.service.BreakLogService; +import lombok.extern.log4j.Log4j2; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.data.redis.RedisProperties; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @ClassName BreakLogServiceImpl + * @Description 定时扫描故障状态 + * @Author YuanYongH + * @Date 2024/4/8 20:49 + */ +@Service +@Log4j2 +public class BreakLogServiceImpl implements BreakLogService { + @Autowired + private BreakLogMapper breakLogMapper; + + @Autowired + private RedisTemplate redisTemplate; + + + @Override + public List breakLog() { + BreakLog breakLog = new BreakLog(); + // 10秒 + final long timeInterval = 10000; + Runnable runnable = new Runnable() { + @Override + public void run() { + while (true){ + breakLogMapper.breakLog(); + log.info("扫描故障状态"); + String breakState = breakLog.getBreakState(); + if (breakState != null){ + // 判断故障状态 + if (breakLog.getBreakState().equals("0")){ + log.info("正常"); + }else if (breakLog.getBreakState().equals("1")){ + log.info("故障"); + }else { + log.info("未知"); + } + + } + try { + Thread.sleep(timeInterval); + } catch (InterruptedException e) { + e.printStackTrace(); + } + } + } + }; + // 开启线程 + Thread thread = new Thread(runnable); + thread.start(); + // 返回故障日志 + return breakLogMapper.breakLog(); + } +} diff --git a/zhilian-modules/zhilian-business/src/main/resources/mapper/BreakLogMapper.xml b/zhilian-modules/zhilian-business/src/main/resources/mapper/BreakLogMapper.xml new file mode 100644 index 0000000..34de1ea --- /dev/null +++ b/zhilian-modules/zhilian-business/src/main/resources/mapper/BreakLogMapper.xml @@ -0,0 +1,10 @@ + + + + + + diff --git a/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhiLianResolverApplication.java b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhiLianResolverApplication.java new file mode 100644 index 0000000..a83628b --- /dev/null +++ b/zhilian-modules/zhilian-resolver/src/main/java/com/zhilian/resolver/ZhiLianResolverApplication.java @@ -0,0 +1,23 @@ +package com.zhilian.resolver; + +import com.zhilian.common.security.annotation.EnableCustomConfig; +import com.zhilian.common.security.annotation.EnableMyFeignClients; +import com.zhilian.common.swagger.annotation.EnableCustomSwagger2; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @ClassName ZhiLianResolverApplication + * @Description TODO + * @Author YuanYongH + * @Date 2024/4/8 17:25 + */ +@EnableCustomConfig +@EnableCustomSwagger2 +@EnableMyFeignClients +@SpringBootApplication +public class ZhiLianResolverApplication { + public static void main(String[] args) { + SpringApplication.run(ZhiLianResolverApplication.class,args); + } +}