package com.ruoyi.doublePrevention.scheduls;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.doublePrevention.entity.CJReport.ReportResultDTO;
import com.ruoyi.doublePrevention.entity.PreventReportConfig;
import com.ruoyi.doublePrevention.enums.SyncEnum;
import com.ruoyi.doublePrevention.service.baseService.*;
import com.ruoyi.doublePrevention.utilsCJ.AesGcm256Util;
import com.ruoyi.project.tr.report.service.ReportService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.*;

@Component
public class CheckExecResultSchedule {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    @Autowired
    private ReportService reportService;

    @Autowired
    private PreventCJReportRiskAnaUnitService CJRiskAnaUnitService;
    @Autowired
    private PreventCJReportRiskEventService CJEventService;
    @Autowired
    private PreventCJReportRiskControlMeasureService CJMeasureService;
    @Autowired
    private PreventCJReportCheckTaskFromWorkService CJTaskFromWorkService;
    @Autowired
    private PreventCJReportCheckRecordFromTaskService CJTaskRecordService;
    @Autowired
    private PreventCJReportDangerInfoService CJDangerInfoService;
    @Autowired
    private PreventCJReportPointService CJPointService;
    @Autowired
    private PreventCJReportOverhaulLogService CJOverhaulLogService;
    @Autowired
    private PreventReportConfigService preventReportConfigService;

    String token = "GT6gGJV7JV";
    String key = "Bv+NeBolwqg2Pbc1yVwrZA==";
    String iv = "4QC9V8eAiB7tdlgBkMsTAw==";

    public static final int MAC_BIT_SIZE = 128;

//    public static String encrypt(String plainText, byte[] key, byte[] iv) {
//        String sr;
//        try {
//            byte[] plainBytes = plainText.getBytes(StandardCharsets.UTF_8);
//            GCMBlockCipher cipher = new GCMBlockCipher(new
//                    AESFastEngine());
//            AEADParameters parameters =
//                    new AEADParameters(new KeyParameter(key),
//                            MAC_BIT_SIZE, iv, null);
//            cipher.init(true, parameters);
//            byte[] encryptedBytes = new
//                    byte[cipher.getOutputSize(plainBytes.length)];
//            int retLen = cipher.processBytes(plainBytes, 0, plainBytes.length,
//                    encryptedBytes, 0);
//            cipher.doFinal(encryptedBytes, retLen);
//            sr = Base64.getEncoder().encodeToString(encryptedBytes);
//        } catch (Exception ex) {
//            throw new RuntimeException(ex.getMessage());
//        }
//        return sr;
//    }
//


    @Transactional
//    @Scheduled(cron = "0 0 23 * * ?")    //每天晚上23点执行一次0 0 22,23 * * ?
//    @Scheduled(cron = "0 0 22,23 * * ?")    //每天晚上22、23点执行一次
//    @Scheduled(cron = "0 0/1 * * * ? ")    // 分钟
//    @Scheduled(cron = "0 0/20 * * * ? ")    // 分钟
//    @Scheduled(cron = "0/10 * * * * ?")
    public void execReportDateSchedule() throws UnsupportedEncodingException {
        logger.info("【￥￥】检查上报结果...");

        String token = "4348187236";  // todo token暂时使用众泰
        String key = "84702E415A73CE27077B5F726E7BDBB0";
        String iv = "1C7AA98593AA69F4AAE119BD5C01D9ED";

        HttpURLConnection con = null;
        BufferedReader buffer = null;
        int responseCode = 200;

        SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd HH:MM:ss");

        Date date = new Date();
        //格式化时间，作为token的时间戳
        SimpleDateFormat tokenDate= new SimpleDateFormat("yyyyMMddHHMMssSSS");
        String formatDate = tokenDate.format(date);

        //使用风险分析单元数据上报主配置，作为自动上报开关
        PreventReportConfig reportConfig = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_ANA_UNIT.getCode());
        if (reportConfig.getReportType() == 0){
            return;
        }

        /**
         * 1、处理安全风险分析单元数据
         * */
        logger.info("查询处理数据...");
        //加密数据
        StringBuffer unitResultBuffer = null;

        List<String> batchId = new ArrayList<>();
        batchId.add("e7272b6b-fb68-4db7-ad06-f763a43b351c");

        //上报数据
        try {
            URL url = new URL("http://117.190.86.66:6022/v2/data/receive/getLog");
            //得到连接对象
            con = (HttpURLConnection) url.openConnection();
            //设置请求类型
            con.setRequestMethod("POST");
            //允许写出
            con.setDoOutput(true);
            //允许读入
            con.setDoInput(true);
            //不使用缓存
            con.setUseCaches(false);
            con.setInstanceFollowRedirects(true);
            //设置请求头
            con.setRequestProperty("Authorization",token + formatDate.toString());
            //设置Content-Type，此处根据实际情况确定
            con.setRequestProperty("Content-Type", "application/json;charset=utf8");

            OutputStream os = con.getOutputStream();
            Map paraMap = new HashMap();
            paraMap.put("batchId", batchId);
            /**封装数据*/
            //组装入参，设置请求体
            os.write(JSON.toJSONString(paraMap).getBytes());

            //本段日志，测试成功后，可注释掉
            if (responseCode == HttpURLConnection.HTTP_OK) {
                //得到响应流
                InputStream inputStream = con.getInputStream();
                //将响应流转换成字符串
                unitResultBuffer = new StringBuffer();
                String line;
                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
                while ((line = buffer.readLine()) != null) {
                    unitResultBuffer.append(line);
                }
                logger.info("result:" + unitResultBuffer.toString());
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        //接收返回值，保存返回值
        List<String> errorIdList= new ArrayList<>();

        //拼接上报数据的uuid
        StringBuffer idTextBuffer = new StringBuffer();

        //接收参数，转为对象
        ReportResultDTO unitResult = JSONObject.parseObject(unitResultBuffer.toString(), ReportResultDTO.class);

        //设置所有数据上报成功
//            for (PreventCJReportRiskAnaUnit riskAnaUnit : CJRiskAnaUnits) {
//                HandlerReportParam handlerReportParam = new HandlerReportParam();
//                //封装数据
//                handlerReportParam.setId(riskAnaUnit.getRiskUnitId());
//                handlerReportParam.setReportStatus(SyncEnum.SYNC_EXEC_SUCCESS.getCode());
//                handlerReportParam.setReportTime(date);
//                CJRiskAnaUnitService.updateReportStatus(handlerReportParam);
//                idTextBuffer.append(riskAnaUnit.getId() + ";");
//            }


    }

}