新增海康设备水尺监测定时任务

zrj

2024-06-05 34b9d8c56f430bfb3b4026450aca0e3b862c2716

新增海康设备水尺监测定时任务

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/hk/HkStaffGaugeMonClientFallback.java

New file
@@ -0,0 +1,18 @@
package cn.gistack.sm.hk;

import org.springframework.stereotype.Component;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 海康设备水尺监测
 * @USER: zhongrj
 * @DATE: 2024/06/05
 */
@Component
public class HkStaffGaugeMonClientFallback implements IHkStaffGaugeMonClient {

    @Override
    public void insertHkStaffGaugeMonInfo() {

    }
}

 skjcmanager/skjcmanager-service-api/skjcmanager-sm-api/src/main/java/cn/gistack/sm/hk/IHkStaffGaugeMonClient.java

New file
@@ -0,0 +1,26 @@
package cn.gistack.sm.hk;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 海康设备水尺监测
 * @USER: zhongrj
 * @DATE: 2024/06/05
 */
@FeignClient(
    value = "blade-sm",
    fallback = HkStaffGaugeMonClientFallback.class
)
public interface IHkStaffGaugeMonClient {

    String API_PREFIX = "/client";
    String INSERT_HK_STAFF_GAUGE_MON = API_PREFIX + "/insertHkStaffGaugeMonInfo";


    @GetMapping(INSERT_HK_STAFF_GAUGE_MON)
    void insertHkStaffGaugeMonInfo();

}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/hk/feign/HkStaffGaugeMonClient.java

New file
@@ -0,0 +1,33 @@
package cn.gistack.sm.hk.feign;

import cn.gistack.sm.hk.IHkStaffGaugeMonClient;
import cn.gistack.sm.hk.service.HkStaffGaugeMonService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tenant.annotation.NonDS;
import org.springframework.web.bind.annotation.RestController;
import springfox.documentation.annotations.ApiIgnore;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 海康设备水尺监测
 * @USER: zhongrj
 * @DATE: 2024/06/05
 */
@NonDS
@ApiIgnore
@RestController
@AllArgsConstructor
@Slf4j
public class HkStaffGaugeMonClient implements IHkStaffGaugeMonClient {

    private final HkStaffGaugeMonService hkStaffGaugeMonService;

    /**
     * 保存水尺监测数据
     */
    @Override
    public void insertHkStaffGaugeMonInfo() {
        hkStaffGaugeMonService.saveHkStaffGaugeMonInfo();
    }
}

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/hk/service/HkStaffGaugeMonService.java

@@ -22,13 +22,13 @@
    IPage<HkStaffGaugeMonVO> selectHkStaffGaugeMonPage(IPage<HkStaffGaugeMonVO> page, HkStaffGaugeMonVO hkStaffGaugeMon);

    /**
     * 保存数据
     * 保存水尺监测数据
     * @return
     */
    void saveHkStaffGaugeMonInfo();

    /**
     * 保存数据
     * 测试保存水尺监测数据
     * @param data
     * @return
     */

 skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/HkStaffGaugeMonXxlJob.java

New file
@@ -0,0 +1,43 @@
package cn.gistack.job.executor.jobhandler;

import cn.gistack.sm.hk.IHkStaffGaugeMonClient;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @PROJECT_NAME: skjcmanager
 * @DESCRIPTION: 海康设备水尺监测
 * @USER: zhongrj
 * @DATE: 2024/06/05
 */
@Component
public class HkStaffGaugeMonXxlJob {

    @Autowired
    private IHkStaffGaugeMonClient hkStaffGaugeMonClient;

    /**
     * 海康设备水尺监测
     * @return
     */
    @XxlJob("insertHkStaffGaugeMonInfo")
    public ReturnT<String> insertHkStaffGaugeMonInfo(String param) {
        XxlJobLogger.log("开始执行任务...");
        // 海康设备水尺监测任务
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        executorService.submit(() -> {
            // 这里是你的异步任务逻辑
            hkStaffGaugeMonClient.insertHkStaffGaugeMonInfo();
        });

        XxlJobLogger.log("结束自动创建任务...");
        // 返回
        return ReturnT.SUCCESS;
    }

}