package jiekou;
|
import chushihua.SlotManager;
|
import xitongshezhi.Fkj;
|
|
/**
|
* 轮询卡槽状态类
|
* 用于定期轮询并输出所有卡槽的状态信息
|
*/
|
public class lunxunkazhuangtai {
|
private static Thread pollThread;
|
private static volatile boolean isRunning = false;
|
private static final int POLL_INTERVAL = 30000; // 30秒间隔
|
|
/**
|
* 启动轮询线程
|
*/
|
public static void startPolling() {
|
if (isRunning) {;
|
return;
|
}
|
|
isRunning = true;
|
pollThread = new Thread(new PollingTask(), "SlotStatusPollingThread");
|
pollThread.setDaemon(true); // 设置为守护线程，当主线程结束时自动结束
|
pollThread.start();
|
}
|
|
/**
|
* 停止轮询线程
|
*/
|
public static void stopPolling() {
|
isRunning = false;
|
if (pollThread != null) {
|
pollThread.interrupt();
|
pollThread = null;
|
}
|
System.out.println("卡槽状态轮询线程已停止");
|
}
|
|
/**
|
* 检查轮询线程是否在运行
|
* @return 运行状态
|
*/
|
public static boolean isPolling() {
|
return isRunning;
|
}
|
|
/**
|
* 轮询任务实现
|
*/
|
private static class PollingTask implements Runnable {
|
@Override
|
public void run() {
|
while (isRunning && !Thread.currentThread().isInterrupted()) {
|
try {
|
// 输出所有卡槽状态
|
printAllSlotsStatus();
|
|
// 等待指定间隔
|
Thread.sleep(POLL_INTERVAL);
|
} catch (InterruptedException e) {
|
System.out.println("轮询线程被中断");
|
Thread.currentThread().interrupt();
|
break;
|
} catch (Exception e) {
|
System.err.println("轮询过程中发生错误: " + e.getMessage());
|
e.printStackTrace();
|
}
|
}
|
isRunning = false;
|
}
|
|
/**
|
* 输出所有卡槽状态信息
|
*/
|
private void printAllSlotsStatus() {
|
Fkj[] slots = SlotManager.getSlotArray();
|
if (slots == null || slots.length == 0) {
|
return;
|
}
|
for (Fkj slot : slots) {
|
if (slot != null) {
|
//使用下面的推给服务器卡的状态
|
String kacaobianhao=safeGetValue(slot.getSlotNumber());
|
String kahao=safeGetValue(slot.getCardNumber());
|
String shifouyouka=formatHasCard(safeGetValue(slot.getHasCard()));
|
String kazhuangtai=formatWorkStatus(safeGetValue(slot.getWorkStatus()));
|
String kacaodianya=safeGetValue(slot.getVoltage());
|
String kacaodianliu=safeGetValue(slot.getCurrent());
|
String guzhangyuanyin=formatFault(safeGetValue(slot.getFault()));
|
}
|
}
|
|
}
|
|
/**
|
* 安全获取值，避免空指针
|
*/
|
private String safeGetValue(String value) {
|
return value != null ? value : "null";
|
}
|
|
/**
|
* 格式化有卡状态
|
*/
|
private String formatHasCard(String hasCard) {
|
if ("1".equals(hasCard)) return "有卡";
|
if ("0".equals(hasCard)) return "无卡";
|
if ("-1".equals(hasCard)) return "未知";
|
return hasCard;
|
}
|
|
/**
|
* 格式化工作状态
|
*/
|
private String formatWorkStatus(String status) {
|
switch (status) {
|
case "0": return "无效";
|
case "1": return "待机";
|
case "2": return "充电中";
|
case "3": return "已充满";
|
case "4": return "故障";
|
case "5": return "授权到期";
|
case "6": return "通信超时";
|
case "-1": return "未知";
|
default: return status;
|
}
|
}
|
|
/**
|
* 格式化故障状态
|
*/
|
private String formatFault(String fault) {
|
switch (fault) {
|
case "0": return "正常";
|
case "1": return "插卡错误";
|
case "2": return "过流";
|
case "3": return "门控故障";
|
case "4": return "过压";
|
case "5": return "欠压";
|
case "-1": return "未知";
|
default: return fault;
|
}
|
}
|
}
|
|
/**
|
* 设置轮询间隔（单位：毫秒）
|
* @param interval 间隔时间，毫秒
|
*/
|
public static void setPollInterval(int interval) {
|
// 注意：这个设置不会立即生效，需要重启轮询线程
|
System.out.println("新的轮询间隔将在下次启动时生效: " + interval + "ms");
|
}
|
|
/**
|
* 获取当前轮询间隔
|
* @return 轮询间隔（毫秒）
|
*/
|
public static int getPollInterval() {
|
return POLL_INTERVAL;
|
}
|
|
/**
|
* 手动触发一次状态输出（不等待间隔）
|
*/
|
public static void triggerManualOutput() {
|
if (isRunning) {
|
new PollingTask().printAllSlotsStatus();
|
} else {
|
System.out.println("轮询线程未运行，无法手动触发输出");
|
}
|
}
|
}
|
