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; } }