package com.panzhihua.timejob.jobhandler; import javax.annotation.Resource; import org.springframework.stereotype.Component; import com.panzhihua.common.service.api.ApiServiceFeign; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.extern.slf4j.Slf4j; /** * program 攀枝花智慧社区项目 description 定时上报事件信息 * * @author manailin Date 2021-06-17 15:30 **/ @Slf4j @Component public class LangChaoEventUploadJobHandler { @Resource private ApiServiceFeign apiServiceFeign; /** * description 生成或更新redis里面的对接浪潮所需的token信息,token有效期12小时 * * @author manailin * @date 2021/6/10 17:00 */ @XxlJob("langChaoGetToken") public ReturnT langChaoGetToken(String param) { log.info("定时更新浪潮对接token。token有效期12小时"); apiServiceFeign.getToken("18080799023", "123456"); log.info("定时更新浪潮对接token完成"); return ReturnT.SUCCESS; } /** * description 向浪潮服务器提交网格事件登记包括基础信息和文件(图片、mp3、mp4)信息 * * @author manailin * @date 2021/6/10 17:00 */ @XxlJob("langChaoAutomationUpload") public ReturnT langChaoAutomationUpload(String param) { log.info("向浪潮服务器提交网格事件登记开始"); apiServiceFeign.automationUploadEventAndFile(); log.info("向浪潮服务器提交网格事件登记完成"); return ReturnT.SUCCESS; } /** * description 自动上传重点人员和流动人员走访记录 * * @author manailin * @date 2021/6/10 17:00 */ @XxlJob("automationUploadVisitRecord") public ReturnT automationUploadVisitRecord(String param) { log.info("向浪潮服务器自动上传重点人员和流动人员走访记录开始"); apiServiceFeign.automationUploadVisitRecord(); log.info("向浪潮服务器自动上传重点人员和流动人员走访记录完成"); return ReturnT.SUCCESS; } }