| | |
| | | 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; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | /** |
| | | * program 攀枝花智慧社区项目 |
| | | * description 定时上报事件信息 |
| | | * program 攀枝花智慧社区项目 description 定时上报事件信息 |
| | | * |
| | | * @author manailin |
| | | * Date 2021-06-17 15:30 |
| | | * @author manailin Date 2021-06-17 15:30 |
| | | **/ |
| | | @Slf4j |
| | | @Component |
| | | public class LangChaoEventUploadJobHandler { |
| | | |
| | | |
| | | @Resource |
| | | private ApiServiceFeign ApiServiceFeign; |
| | | private ApiServiceFeign apiServiceFeign; |
| | | |
| | | /** |
| | | * description 生成或更新redis里面的对接浪潮所需的token信息,token有效期12小时 |
| | |
| | | @XxlJob("langChaoGetToken") |
| | | public ReturnT<String> langChaoGetToken(String param) { |
| | | log.info("定时更新浪潮对接token。token有效期12小时"); |
| | | ApiServiceFeign.getToken("18080799023", "123456"); |
| | | apiServiceFeign.getToken("18080799023", "123456"); |
| | | log.info("定时更新浪潮对接token完成"); |
| | | return ReturnT.SUCCESS; |
| | | } |
| | |
| | | @XxlJob("langChaoAutomationUpload") |
| | | public ReturnT<String> langChaoAutomationUpload(String param) { |
| | | log.info("向浪潮服务器提交网格事件登记开始"); |
| | | ApiServiceFeign.automationUploadEventAndFile(); |
| | | apiServiceFeign.automationUploadEventAndFile(); |
| | | log.info("向浪潮服务器提交网格事件登记完成"); |
| | | return ReturnT.SUCCESS; |
| | | } |
| | |
| | | @XxlJob("automationUploadVisitRecord") |
| | | public ReturnT<String> automationUploadVisitRecord(String param) { |
| | | log.info("向浪潮服务器自动上传重点人员和流动人员走访记录开始"); |
| | | ApiServiceFeign.automationUploadVisitRecord(); |
| | | apiServiceFeign.automationUploadVisitRecord(); |
| | | log.info("向浪潮服务器自动上传重点人员和流动人员走访记录完成"); |
| | | return ReturnT.SUCCESS; |
| | | } |