package com.boying.job;

import cn.hutool.core.thread.ThreadUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.boying.common.ReturnData;
import com.boying.common.SystemConfigProperties;
import com.boying.controller.phone.PayController;
import com.boying.entity.Barrier;
import com.boying.entity.OutPark;
import com.boying.service.*;
import com.boying.util.HTTPEntityUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Slf4j
@Component
public class PayResultScheduled {


    @Autowired
    private OutParkService outParkService;
    @Autowired
    private BarrierService barrierService;
    @Autowired
    private SystemConfigProperties systemConfigProperties;
    @Autowired
    private PayController payController;

    Boolean taskFlag = false;

    @Scheduled(cron = "0/2 * * * * ?")
    public void execute() throws Exception {
        if(taskFlag == true){
            System.out.println("正在运行，强制退出-------》");
            return;
        }
        taskFlag = true;
        QueryWrapper<Barrier> barrierQueryWrapper = new QueryWrapper<>();
        barrierQueryWrapper.lambda()
                .eq(Barrier::getType,0)
                .isNotNull(Barrier::getCarNo);
        for (Barrier barrier : barrierService.list(barrierQueryWrapper)) {
            //根据道闸查询最后一个出场纪录
            QueryWrapper<OutPark> wrapper = new QueryWrapper<>();
            wrapper.lambda()
                    .eq(OutPark::getBarrierId,barrier.getId())
                    .eq(OutPark::getStatus,0)
                    .eq(OutPark::getCarNo,barrier.getCarNo())
                    .ne(OutPark::getPrice,0)
                    .isNotNull(OutPark::getPayCode)
                    .orderByDesc(OutPark::getCreateTime);
            List<OutPark> outParks = outParkService.list(wrapper);
            if(outParks.size()>0){
                //查询到最后一个出场没缴费的记录
                OutPark outPark = outParks.get(0);
                log.info("查询到最后的出场信息为："+outPark);
                //查询缴款码记录更新
                doPay(outPark);
            }
        }
        taskFlag = false;
    }

    public void doPay(OutPark outPark){
        ThreadUtil.execute(() -> {
            //查询缴款码记录更新
            Map<String,Object> map1 = new HashMap<>();
            map1.put("eticketnum",outPark.getPayCode());
            String urlRoad = systemConfigProperties.getETICKET();
            String urlIp = systemConfigProperties.getIp4();
            RestTemplate restTemplate = new RestTemplate();
            ResponseEntity<ReturnData> entity = restTemplate.postForEntity(urlIp+urlRoad, HTTPEntityUtil.setEntity(map1), ReturnData.class);
            log.info("查询是否支付成功返回为："+entity.getBody());
            System.out.println("查询是否支付成功返回为："+entity.getBody());
            if(entity.getBody().getCode() == 1){
                //更新订单
                payController.updateOrderRecord(outPark.getPayCode(),"03");
            }

        });
    }

    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            String s= i+"";
            ThreadUtil.execute(() -> {
              //  System.out.println(s);
            });
        }
    }
}