新增sim卡流量查询和状态查询后台任务
1. 状态查询（每小时） 2. 流量查询 （每两小时）
This commit is contained in:
fengyarnom
parent
6d6a400dca
commit
bd0b87c75d
@ -0,0 +1,203 @@
|
||||
package com.imdroid.sideslope.task;
|
||||
|
||||
import com.alibaba.excel.util.StringUtils;
|
||||
import com.imdroid.secapi.dto.*;
|
||||
import com.imdroid.sideslope.sal.Device;
|
||||
import com.imdroid.sideslope.sal.DeviceService;
|
||||
import com.imdroid.sideslope.service.SimCardQueryServiceImpl;
|
||||
import com.imdroid.sideslope.service.WarningServiceImpl;
|
||||
import com.imdroid.sideslope.simcard.BaseResponse;
|
||||
import com.imdroid.sideslope.simcard.CardInfoData;
|
||||
import com.imdroid.sideslope.simcard.CardStatusData;
|
||||
import com.imdroid.sideslope.simcard.GprsData;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.math.BigDecimal;
|
||||
import java.util.*;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.ScheduledExecutorService;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
@Component
|
||||
@Configuration
|
||||
@EnableScheduling
|
||||
public class SimStatusChecker {
|
||||
// SIM 卡流量和状态查询定时任务
|
||||
// 1. 每小时任务
|
||||
// a. 通过CardInfo 检查 iccid 和 sim卡号
|
||||
// b. 通过QueryCardStatus 检查SIM卡当前的状态
|
||||
// 2. 每两小时任务
|
||||
// a. QueryGprs 检查 SIM 流量
|
||||
final Logger logger = LoggerFactory.getLogger(SimStatusChecker.class);
|
||||
@Autowired
|
||||
private GnssStatusMapper gnssStatusMapper;
|
||||
|
||||
@Autowired
|
||||
private WarningServiceImpl warningService;
|
||||
|
||||
@Autowired
|
||||
private SimCardsMapper simCardsMapper;
|
||||
@Resource(name = "local")
|
||||
private DeviceService deviceService;
|
||||
|
||||
private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
|
||||
@Autowired
|
||||
private SimCardQueryServiceImpl simCardQueryServiceImpl;
|
||||
|
||||
// 每小时执行一次状态检查调度
|
||||
@Scheduled(cron = "0 0 * * * ?")
|
||||
private void scheduleSimCardStatusCheck() {
|
||||
List<GnssStatusJoin> onlineDevices = gnssStatusMapper.queryOnline();
|
||||
//logger.debug("当前在线设备数量: {}", onlineDevices.size());
|
||||
|
||||
for (GnssStatusJoin onlineDevice : onlineDevices) {
|
||||
int delay = Math.abs(onlineDevice.getDeviceid().hashCode() % 3600 );
|
||||
//logger.debug("设备: {}, SIM状态查询，延迟执行: {}秒", onlineDevice.getDeviceid(), delay);
|
||||
|
||||
scheduler.schedule(() -> checkDeviceSimCardStatus(onlineDevice.getDeviceid()),
|
||||
delay, TimeUnit.SECONDS);
|
||||
}
|
||||
}
|
||||
|
||||
// 每两小时执行一次流量检查调度
|
||||
@Scheduled(cron = "0 0 0/2 * * ?")
|
||||
private void scheduleSimCardTrafficCheck() {
|
||||
List<GnssStatusJoin> onlineDevices = gnssStatusMapper.queryOnline();
|
||||
//logger.debug("当前在线设备数量: {}", onlineDevices.size());
|
||||
|
||||
for (GnssStatusJoin onlineDevice : onlineDevices) {
|
||||
int delay = Math.abs(onlineDevice.getDeviceid().hashCode() % 7200);
|
||||
//logger.debug("设备: {}, SIM流量查询，延迟执行: {}秒", onlineDevice.getDeviceid(), delay);
|
||||
|
||||
scheduler.schedule(() -> checkDeviceSimCardTraffic(onlineDevice.getDeviceid()),
|
||||
delay, TimeUnit.SECONDS);
|
||||
}
|
||||
}
|
||||
|
||||
private void checkDeviceSimCardStatus(String deviceId) {
|
||||
try {
|
||||
Device device = deviceService.findByDeviceId(deviceId);
|
||||
// 不允许尚未从自检得到 ICCID 的设备参加 SIM 卡状态查询
|
||||
if (!simCardQueryServiceImpl.hasValidIccid(device)) {
|
||||
return;
|
||||
}
|
||||
// SimCards 表中没有数据就初始化，这其实说明它在自检中刚获得属于自己的 ICCID 号
|
||||
SimCard simCard = simCardQueryServiceImpl.CreateOrUpdateSimCard(device);
|
||||
updateSimCardInfo(device, simCard);
|
||||
|
||||
} catch (Exception e) {
|
||||
logger.error("设备{}状态查询失败: ", deviceId, e);
|
||||
}
|
||||
}
|
||||
|
||||
private void checkDeviceSimCardTraffic(String deviceId) {
|
||||
try {
|
||||
Device device = deviceService.findByDeviceId(deviceId);
|
||||
// 不允许尚未从自检得到 ICCID 的设备参加 SIM 卡状态查询
|
||||
if (!simCardQueryServiceImpl.hasValidIccid(device)) {
|
||||
return;
|
||||
}
|
||||
// SimCards 表中没有数据就初始化，这说明它在自检中获得属于自己的 ICCID 号
|
||||
SimCard simCard = simCardQueryServiceImpl.CreateOrUpdateSimCard(device);
|
||||
// 如果该卡状态不是已激活，而是其他状态，那么不运行它参与 SIM 卡流量检测
|
||||
if(simCard.getStatus() != SimCard.STATUS_ACTIVATED){
|
||||
return;
|
||||
}
|
||||
updateSimCardTrafficFromAPI(device, simCard);
|
||||
|
||||
} catch (Exception e) {
|
||||
logger.error("设备{}查询失败: ", deviceId, e);
|
||||
}
|
||||
}
|
||||
|
||||
private void updateSimCardInfo(Device device, SimCard simCard) throws Exception {
|
||||
// 自检中只是获取保存了设备的 ICCID ，所有如果判断如果没有 MSISDN，先更新基本信息
|
||||
if (StringUtils.isBlank(simCard.getMsisdn())) {
|
||||
updateSimCardBasicInfoFromAPI(device, simCard);
|
||||
}
|
||||
// 更新状态
|
||||
updateSimCardStatusFromAPI(device, simCard);
|
||||
}
|
||||
private void updateSimCardBasicInfoFromAPI(Device device, SimCard simCard) {
|
||||
try {
|
||||
BaseResponse<CardInfoData> response = simCardQueryServiceImpl.queryCardInfo(device);
|
||||
if (!simCardQueryServiceImpl.isValidResponse(response)) {
|
||||
return;
|
||||
}
|
||||
|
||||
CardInfoData info = response.getData();
|
||||
simCard.setUpdatetime(new Date());
|
||||
simCard.setMsisdn(info.getMsisdn());
|
||||
simCardsMapper.updateSimCardInfo(simCard);
|
||||
|
||||
// logger.debug("更新SIM卡基本信息 - imsi: {}, msisdn: {}, iccid: {}",
|
||||
// info.getImsi(), info.getMsisdn(), info.getIccid());
|
||||
} catch (Exception e) {
|
||||
logger.error("更新设备{}的SIM卡基本信息失败: ", device.getDeviceId(), e);
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
private void updateSimCardStatusFromAPI(Device device, SimCard simCard) {
|
||||
try {
|
||||
BaseResponse<CardStatusData> response = simCardQueryServiceImpl.queryCardStatus(device);
|
||||
if (!simCardQueryServiceImpl.isValidResponse(response)) {
|
||||
return;
|
||||
}
|
||||
CardStatusData status = response.getData();
|
||||
simCard.setUpdatetime(new Date());
|
||||
simCard.setStatus(status.getStatusCode());
|
||||
simCard.setStatus(3);
|
||||
simCardsMapper.updateSimCardInfo(simCard);
|
||||
|
||||
warningService.checkSimCardStatus(device, simCard);
|
||||
|
||||
// logger.debug("更新SIM卡状态 - Code: {}, 描述: {}",
|
||||
// status.getStatusCode(), status.getStatusDesc());
|
||||
} catch (Exception e) {
|
||||
logger.error("更新设备{}的SIM卡状态失败: ", device.getDeviceId(), e);
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
private void updateSimCardTrafficFromAPI(Device device, SimCard simCard) {
|
||||
try {
|
||||
BaseResponse<GprsData> response = simCardQueryServiceImpl.queryGprs(device);
|
||||
if (!simCardQueryServiceImpl.isValidResponse(response)) {
|
||||
return;
|
||||
}
|
||||
|
||||
GprsData gprsData = response.getData();
|
||||
GprsData.GprsUsage usage = gprsData.getFirstGprsUsage();
|
||||
if (usage == null) {
|
||||
logger.warn("无可用流量数据查询, deviceId: {}", device.getDeviceId());
|
||||
return;
|
||||
}
|
||||
|
||||
simCard.setUpdatetime(new Date());
|
||||
simCard.setRemaining(BigDecimal.valueOf(usage.getLeft()));
|
||||
simCard.setUsed(BigDecimal.valueOf(usage.getUsed()));
|
||||
simCard.setTotal(BigDecimal.valueOf(usage.getTotal()));
|
||||
simCardsMapper.updateSimCardInfo(simCard);
|
||||
|
||||
warningService.checkSimCardTraffic(device, simCard);
|
||||
|
||||
// logger.info("更新流量信息成功 - deviceId: {}, 剩余: {}MB, 总量: {}MB, 已用: {}MB",
|
||||
// device.getIccid(),
|
||||
// simCard.getRemaining(),
|
||||
// simCard.getTotal(),
|
||||
// simCard.getUsed());
|
||||
|
||||
} catch (Exception e) {
|
||||
logger.error("设备{}更新SIM卡流量失败: ", device.getDeviceId(), e);
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
x
Reference in New Issue
Block a user