docus-mz-empcllect/src/main/java/com/docus/bgts/config/MyScheduling.java

package com.docus.bgts.config;


import com.alibaba.fastjson.JSON;
import com.docus.bgts.entity.ReportDownDto;
import com.docus.bgts.entity.ReportDownPatientDto;
import com.docus.bgts.entity.ReportDownScanFileDto;
import com.docus.bgts.enums.Codes;
import com.docus.bgts.facade.IAfCollectTaskService;
import com.docus.bgts.facade.IMrReportErrorService;
import com.docus.bgts.utils.FileUtils;
import com.docus.bgts.utils.HttpUtils;
import com.docus.bgts.utils.XmlUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.axis.client.Call;
import org.apache.axis.encoding.XMLType;
import org.apache.axis.utils.ByteArrayOutputStream;
import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import org.dom4j.Element;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.xml.namespace.QName;
import javax.xml.rpc.ParameterMode;
import java.io.ByteArrayInputStream;
import java.io.PrintStream;
import java.net.URISyntaxException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

@Slf4j
@Component
public class MyScheduling {

    public static Date oneDate;
    public static String namespance = "";
    private static String methodName = "";
    private static String url;
    private static String pdfUrl;

    static {
        url = String.valueOf(FileUtils.getJsonByName("zyUrl"));
        methodName = String.valueOf(FileUtils.getJsonByName("zyMethod"));
        pdfUrl = String.valueOf(FileUtils.getJsonByName("pdfUrl"));
        namespance = String.valueOf(FileUtils.getJsonByName("zyNamespance"));
        SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
        try {
            oneDate = fmt.parse(String.valueOf(FileUtils.getJsonByName("zysj")));
        } catch (ParseException e) {
            e.printStackTrace();
        }
    }

    @Autowired
    private IMrReportErrorService mrReportErrorService;

    @Autowired
    private IAfCollectTaskService afCollectTaskService;

    @Value("${beat.url}")
    private String beatUrl;

    private Logger logger = LogManager.getLogger(MyScheduling.class);

    //10分钟执行一次
    @Scheduled(fixedRate = 1000 * 60 * 5)
    public void beat() {
        logger.info("------------心跳开始---------------");
        Map<String, String> params = new HashMap<>();
        params.put("code", String.valueOf(FileUtils.getJsonByName("collectorid")));
        try {
            HttpUtils.get(beatUrl, params);
        } catch (URISyntaxException e) {
            e.printStackTrace();
            logger.info("心跳推送出错，可能是住院服务没有开启");
        } finally {
            logger.info("-------------心跳结束---------------");
        }
    }

    //10分钟执行一次
//    @Scheduled(fixedRate = 1000 * 60 * 60 * 5)
//    public void ruyuan() {
//        log.info("----------开始采集------------");
//        SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        String format = fmt.format(oneDate);
//        log.info("-----采集时间：开始时间："+ format);
//        Date twoDate = new Date();
//        String format1 = fmt.format(twoDate);
//        log.info("-----采集时间：结束时间："+ format1);
//
//        //获取jzh列表
//        List<String> jzhs = afCollectTaskService.listJZHByDate(format, format1);
//        int size = jzhs.size();
//        log.info("-------本次采集数：" + size);
//        if(size==0){
//            oneDate=twoDate;
//            log.info("------------采集结束-----------------");
//            return;
//        }
//        Object[] params;
//        List<String> keys = new ArrayList<>();
//        keys.add("action");
//        keys.add("message");
//        XmlUtils xmlUtils;
//        List<String> zyDirectory = (List<String>) FileUtils.getJsonByName("zyDirectory");
//        String assortid = String.valueOf(FileUtils.getJsonByName("assortid"));
//        String collectorid = String.valueOf(FileUtils.getJsonByName("collectorid"));
//        String filesource = String.valueOf(FileUtils.getJsonByName("filesource"));
//        String filestoragetype = String.valueOf(FileUtils.getJsonByName("filestoragetype"));
//        String res;
//        Element element;
//        Map<String, Object> headMap = new HashMap<>();
//        headMap.put("Content-Type", "application/json");
//        for (String jzh : jzhs) {
//            try {
//                params = new Object[]{"flow-mra-queryencounterpdf", "<Req>\n" +
//                        "<Params>\n" +
//                        "<ENCT_ID>" + jzh + "</ENCT_ID>\n" +
//                        "</Params>\n" +
//                        "</Req>"};
//                res = requestFunctionWebService(params, url, methodName, namespance, keys);
//                log.info("返回值：" + res);
//                xmlUtils = new XmlUtils(new ByteArrayInputStream(res.getBytes("UTF-8")));
//                element = xmlUtils.getElement(zyDirectory);
//                List<Element> items = element.elements("ITEM");
//                if (items == null || items.size() <= 0) {
//                    throw new RuntimeException("查询到的信息不存在");
//                }
//                ReportDownDto reportDownDto = new ReportDownDto();
//                reportDownDto.setCollectorid(collectorid);
//                reportDownDto.setAssortid(assortid);
//
//                ReportDownPatientDto reportDownPatientDto = new ReportDownPatientDto();
//                reportDownPatientDto.setJzh(jzh);
//                reportDownDto.setPatient(reportDownPatientDto);
//                List<ReportDownScanFileDto> scanFileDtos = new ArrayList<>();
//                ReportDownScanFileDto reportDownScanFileDto;
//
//                for (Element item : items) {
//                    Element pdfId = item.element("PDF_ID");
//                    if (pdfId != null && StringUtils.isNotBlank(pdfId.getText())) {
//                        //采集流水号
//                        String pdfIdText = pdfId.getText();
//                        //文件标题
//                        String fileTitle = item.element("MED_REC_CAT_NAME").getText();
//                        //url地址
//                        String pdf = pdfUrl + pdfIdText;
//
//                        reportDownScanFileDto = new ReportDownScanFileDto();
//                        reportDownScanFileDto.setFiletitle(fileTitle);
//                        reportDownScanFileDto.setFilesource(Integer.parseInt(filesource));
//                        reportDownScanFileDto.setFilestoragetype(Integer.parseInt(filestoragetype));
//                        reportDownScanFileDto.setSerialnum(pdfIdText);
//                        reportDownScanFileDto.setDownurl(pdf);
//                        scanFileDtos.add(reportDownScanFileDto);
//                    } else {
//                        log.info("记账号：", jzh + "不存在pdfId");
//                        size--;
//                        throw new RuntimeException("记账号：" + jzh + "不存在pdfId");
//                    }
//                }
//                log.info("文件信息：" + scanFileDtos);
//                reportDownDto.setScanfiles(scanFileDtos);
//                afCollectTaskService.insert(reportDownDto);
//                String post = "";
//                logger.info("--------执行上传功能----------");
//                Map paramMap = JSON.parseObject(JSON.toJSONString(reportDownDto), Map.class);
//                logger.info("上传参数：" + paramMap);
//                post = HttpUtils.post(String.valueOf(FileUtils.getJsonByName(Codes.UPLOAD.getMessage())), headMap, paramMap);
////            String post = HttpUtils.post(String.valueOf(FileUtils.getJsonByName(Codes.UPLOAD.getMessage())), map, headMap);
//                if (StringUtils.isBlank(post)) {
//                    logger.info("--------上传时出现错误，可能是文件服务没有启动----------");
//                    throw new RuntimeException("上传时出现错误，可能是文件服务没有启动");
//                }
//                Map resMap = JSON.parseObject(post, Map.class);
//                if (String.valueOf(resMap.get("code")).equals("500")) {
//                    throw new RuntimeException(String.valueOf(resMap.get("msg")));
//                } else {
//                    logger.info("----------执行成功,当前最后更新日期" + twoDate + "-----------");
//                }
//
//            } catch (Exception e) {
//                log.info(e.getMessage());
//                e.printStackTrace();
//                size--;
//                mrReportErrorService.insert(jzh);
//            }
//        }
//        log.info("-------本次成功采集数：" + size);
////        oneDate = twoDate;
//    }

    private String requestFunctionWebService(Object[] params,
                                             String url,
                                             String methodName,
                                             String namespance,
                                             List<String> parameterNames) {
        String result = "";
        if (null != params) {
            try {
                org.apache.axis.client.Service service = new org.apache.axis.client.Service();
                Call call = (Call) service.createCall();
                call.setTargetEndpointAddress(url);
                call.setOperationName(new QName(namespance, methodName));
                for (int i = 0; i < parameterNames.size(); i++) {
                    call.addParameter(parameterNames.get(i), XMLType.XSD_STRING, ParameterMode.IN);//接口的参数
                }
                call.setReturnType(XMLType.XSD_STRING);//设置返回类型
                result = (String) call.invoke(params);
            } catch (Exception e) {
                e.printStackTrace();
                //方法名
                ByteArrayOutputStream baos = new ByteArrayOutputStream();
                e.printStackTrace(new PrintStream(baos));
                String exception = baos.toString();
                log.error("requestFunctionWebService请求接口异常：" + exception);
            }
        }
        return result;
    }

}