xieb
2023-12-06 5f477a9fa1115d7f78c8795d9195275186c3c2c8
数据预警
5 files modified
38 ■■■■■ changed files
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/AttResBaseMapper.java 6 ●●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/AttResBaseMapper.xml 4 ●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/IAttResBaseService.java 2 ●●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResBaseServiceImpl.java 5 ●●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SendSmsXxlJob.java 21 ●●●●● patch | view | raw | blame | history
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/AttResBaseMapper.java
@@ -59,4 +59,10 @@
     * @return
     */
    AttResAdVO getWaterRegionInfoByResGuid(@Param("guid") String guid);
    /**
     * 获取水库基本信息表DimResInfo总数
     * @return
     */
    int getDimResInfoACount();
}
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/mapper/AttResBaseMapper.xml
@@ -182,4 +182,8 @@
        where a."guid" = #{guid}
    </select>
    <select id="getDimResInfoACount" resultType="java.lang.Integer">
        select count(*) from sjzt_dw."dim_res_info_a"
    </select>
</mapper>
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/IAttResBaseService.java
@@ -50,4 +50,6 @@
     * @return
     */
    AttResAdVO getWaterRegionInfoByResGuid(String guid);
    int getDimResInfoACount();
}
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResBaseServiceImpl.java
@@ -93,4 +93,9 @@
    public AttResAdVO getWaterRegionInfoByResGuid(String guid) {
        return baseMapper.getWaterRegionInfoByResGuid(guid);
    }
    @Override
    public int getDimResInfoACount() {
        return baseMapper.getDimResInfoACount();
    }
}
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SendSmsXxlJob.java
@@ -1,7 +1,7 @@
package cn.gistack.job.executor.jobhandler;
import cn.gistack.alerts.sms.feign.ISmsRecordClient;
import cn.gistack.sm.intelligentCall.feign.OutCallClient;
import cn.gistack.sm.sms.feign.IDataAbnormalWarnClient;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.xxl.job.core.biz.model.ReturnT;
@@ -21,6 +21,9 @@
    @Autowired
    private ISmsRecordClient smsRecordClient;
    @Autowired
    private IDataAbnormalWarnClient dataAbnormalWarnClient;
    /**
     * 外呼未接通-发送短信
@@ -45,4 +48,20 @@
        XxlJobLogger.log("结束自动创建任务...");
        return ReturnT.SUCCESS;
    }
    /**
     * 监测数据表异常,异常发送短信给运维人员
     * @return
     */
    @XxlJob("sendOperate")
    public ReturnT<String> sendOperate(String param) {
        XxlJobLogger.log("开始执行任务...");
        JSONObject jsonParam = JSON.parseObject(param);
        String tableName = jsonParam.getString("tableName");
        String phones = jsonParam.getString("phones");
        dataAbnormalWarnClient.sendOperate(tableName, phones);
        XxlJobLogger.log("结束执行任务...");
        return ReturnT.SUCCESS;
    }
}