| | |
| | | import com.xxl.job.core.handler.annotation.XxlJob; |
| | | import com.xxl.job.core.log.XxlJobLogger; |
| | | import org.jetbrains.annotations.NotNull; |
| | | import org.springblade.core.mp.base.BaseEntity; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * 短信定时发送任务执行器 |
| | |
| | | |
| | | @Autowired |
| | | private IDataAbnormalWarnClient dataAbnormalWarnClient; |
| | | |
| | | |
| | | /** |
| | | * 外呼未接通-发送短信 |
| | |
| | | return ReturnT.SUCCESS; |
| | | } |
| | | |
| | | /** |
| | | * 试点白蚁报警,发送短信给水库人员监测监测点 |
| | | * @param param |
| | | * @return |
| | | */ |
| | | @XxlJob("sendWarmInfo") |
| | | public ReturnT<String> sendWarmInfo(String param) { |
| | | XxlJobLogger.log("开始执行任务..."); |
| | | List<BaseEntity> baseEntities = skBaiYiService.selectList(); |
| | | |
| | | // JSONObject jsonParam = JSON.parseObject(param); |
| | | // java.lang.String tableName = jsonParam.getString("resultList"); |
| | | // java.lang.String phones = jsonParam.getString("phone"); |
| | | // dataAbnormalWarnClient.sendOperate(tableName, phones); |
| | | |
| | | XxlJobLogger.log("结束执行任务..."); |
| | | return ReturnT.SUCCESS; |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @XxlJob("sendOperateCZ") |
| | | public ReturnT<String> sendOperateCZ(String param) { |
| | | XxlJobLogger.log("开始执行任务..."); |