data-upload/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java

package com.hxjt.dataupload.jobhandler.doubleprevent;

import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx;
import com.hxjt.dataupload.model.entity.doubleprevent.Yhpcrw;
import com.hxjt.dataupload.model.entity.doubleprevent.Yhzlda;
import com.hxjt.dataupload.service.FxfxdxService;
import com.hxjt.dataupload.utils.AmountConverter;
import com.hxjt.dataupload.utils.HttpUtils;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.protocol.HTTP;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

@Component
public class YhzldaJobHandler {


    private Logger log = LoggerFactory.getLogger(YhzldaJobHandler.class);

    @Autowired
    FxfxdxService fxfxdxService;

    @XxlJob(value = "YhzldaJobHandler", init = "init", destroy = "destroy")
    public void execute(String param) {
        String jobParam = XxlJobHelper.getJobParam();

        int pageSize = 1000;
        int success = 0;
        int fail = 0;
        long total = 0;


        int pageNum = 1;
        do {
            //System.out.println("dowhile");
            List<Yhzlda> onePage = new ArrayList<>();
            // 1. 启动分页（必须紧邻查询语句）
            PageHelper.startPage(pageNum, pageSize);
            // 2. 执行查询（此时SQL已被自动拦截并添加分页逻辑）
            if (jobParam.equals("全量")) {
                onePage = fxfxdxService.getOneYhzldasPage("N");
            } else {
                onePage = fxfxdxService.getOneYhzldasPage("Y");
            }

            // 3. 封装分页结果
            PageInfo<Yhzlda> pageInfo = new PageInfo<>(onePage);
            //设置总数
            total = pageInfo.getTotal();
            System.out.println("总条数:" + total);
            System.out.println("第" + pageNum + "页");
            System.out.println("本页条数:" + pageInfo.getList().size());
            //对本页数据进行上传
            for (int x = 0; x < pageInfo.getList().size(); x++) {
                pageInfo.getList().get(x).setZijinwanyuan(AmountConverter.convertToTenThousandYuan(pageInfo.getList().get(x).getZijinwanyuan()));





                //在此进行上传


                String company = pageInfo.getList().get(x).getQiyemingcheng();
                String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/yinhuanzhilidangan/v1/yinhuanzhilidangan";
                switch (company) {
                    case "山东恒信高科能源有限公司":
                    case "恒信中碳氢能源科技（山东）有限公司":
                        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(pageInfo.getList().get(x));
                        String post = null;
                        try {
                            post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "Tk4xNbES1nIUaIzEOPnc29269B98C15B1EE4");


                            boolean thisFailFlag = false;
                            boolean postIsNull = false;
                            boolean postNoMsgs = false;
                            if(!StringUtils.isBlank(post)){
                                JSONObject postJsonObj = JSONObject.parseObject(post);
                                if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){
                                    if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status
                                        //成功
                                        System.out.println("成功"+(x+1)+",");
                                        //System.out.println(jsonObject);
                                        //System.out.println("post:" + post.toString());
                                        //XxlJobHelper.log("执行日志:" + company + post.toString());

                                        success++;
                                    }else{
                                        thisFailFlag = true;
                                    }
                                }else{
                                    thisFailFlag = true;
                                    postNoMsgs = true;
                                }
                            }else{
                                postIsNull = true;
                                thisFailFlag = true;
                            }
                            if(thisFailFlag){//异常情况
                                System.out.println("失败"+(x+1)+",隐患排查任务");
                                if(!postIsNull){
                                    System.out.println("post:" + post.toString());
                                    XxlJobHelper.log("执行日志:" + company + post.toString());
                                }

                                fail++;
                            }
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                        break;
                }


            }
            pageNum++;
        } while (total > (pageNum - 1) * pageSize);

        if (total > 0) {
            XxlJobHelper.log("执行日志:本次有" + total + "条需要上传,成功上传" + success + "条,失败" + fail + "条");
        } else {
            XxlJobHelper.log("执行日志:本次无新数据需上传");
        }


    }


    private void init() {
        log.info("init 方法调用成功");
    }

    private void destroy() {
        log.info("destroy 方法调用成功");
    }
}