mjava-taisen/mjava-ts/src/main/java/com/malk/taisen/Timers/Time.java

package com.malk.taisen.Timers;

import java.time.LocalDateTime;

import com.alibaba.fastjson.JSON;
import com.malk.server.aliwork.YDConf;
import com.malk.server.aliwork.YDParam;
import com.malk.service.aliwork.YDClient;
import com.malk.taisen.service.NonPoServer;
import com.malk.utils.UtilMap;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;

@Slf4j
@Configuration
@EnableScheduling
@ConditionalOnProperty(name = {"npo.scheduling"}, havingValue = "true")

public class Time {

    private YDClient ydClient;
    @Autowired
    private NonPoServer nonPoServer;

    /**
     * 每5分钟时查询下 NPO 流程结束待推送的数据
     */
    //暂不开启
//
    @Value(value = "${sap.QA_sapUrl_Poc}")
    private String QA_sapUrl;

    //    @Scheduled(fixedRate = 1000 * 1800)
    @Scheduled(fixedRate = 1000 * 60 * 5)   //05   10   15  25  30   35  40  45  50  55  60
    public void JX() throws Exception {
        System.out.println("每5分钟时查询下NPO流程结束待推送的数据进行处理----开始    QA_sapUrl:" + QA_sapUrl);
       nonPoServer.NonPoinsetSAP0005list();
       // nonPoServer.FPGX("095ea634-826a-43c8-b348-ae940c8fd18f", "1920000001", "NP6900260017");
      //  nonPoServer.NPOCX( "18dd8ecb-8605-4a10-8594-b861eba91d5b", "FORM-7E5114C1793141E086D9E0B13F7DFD568AYM");

        System.out.println("NPO流程结束待推送的数据-结束");

    }

}