package cn.gistack.sm.sms.feign;
|
|
import cn.com.flaginfo.sdk.cmc.api.sms.send.SMSSendRequest;
|
import cn.gistack.sm.sjztmd.entity.AttStBase;
|
import cn.gistack.sm.sjztmd.service.*;
|
import cn.gistack.sm.sms.util.SmsUtils;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RestController;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
/**
|
* @PROJECT_NAME: skjcmanager
|
* @DESCRIPTION: 数据异常告警feign实现
|
* @USER: aix
|
* @DATE: 2023/12/5 15:39
|
*/
|
@NonDS
|
@ApiIgnore
|
@RestController
|
@AllArgsConstructor
|
@Slf4j
|
public class DataAbnormalWarnClient implements IDataAbnormalWarnClient{
|
|
@Autowired
|
private IAttResBaseService resBaseService;
|
|
@Autowired
|
private IAttStBaseService attStBaseService;
|
@Autowired
|
private IAttResStagCharService attResStagCharService;
|
|
@Autowired
|
private IAttResRsbNorspiService attResRsbNorspiService;
|
|
@Autowired
|
private IAttResFlseLimService attResFlseLimService;
|
|
@Override
|
public void sendOperate(String tableName, String phones) {
|
//汇聚任务水库基本信息表 用于判断是否有数据
|
long count = 1l;
|
if (tableName.equals("dim_res_info_a"))
|
count = resBaseService.getDimResInfoACount();
|
else if (tableName.equals("att_res_base"))
|
count = resBaseService.count();
|
else if (tableName.equals("att_st_base")) {
|
// 构造 QueryWrapper 对象
|
QueryWrapper<AttStBase> wrapper = new QueryWrapper<>();
|
wrapper.isNotNull("\"share_st_code\"").ne("\"share_st_code\"", "");
|
count = attStBaseService.count(wrapper);
|
} else if (tableName.equals("att_res_stag_char")) {
|
count = attResStagCharService.count();
|
} else if (tableName.equals("att_res_rsb_norspi")) {
|
count = attResRsbNorspiService.count();
|
} else if (tableName.equals("att_res_flse_lim")) {
|
count = attResFlseLimService.count();
|
}
|
|
log.info("预警数量count:" + count);
|
|
if (count == 0) {
|
sendMsg(tableName, phones);
|
}
|
|
}
|
|
private void sendMsg(String tableName, String phones) {
|
SMSSendRequest request = new SMSSendRequest();
|
String [] phoness = phones.split(",");
|
for (String n: phoness) {
|
request.setUserNumber(n);
|
request.setTemplateId("2431012268292");
|
request.setMessageContent("紧急通知：数据表异常，请立即检查数据源并填充缺失的数据！"+tableName+"，数据为空");
|
SmsUtils.sendMsg(request);
|
}
|
}
|
|
}
|
