package com.boying.service.impl;

import cn.hutool.http.Header;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.boying.common.R;
import com.boying.common.ReturnData;
import com.boying.common.SystemConfigProperties;
import com.boying.entity.Ticket;
import com.boying.mapper.TicketMapper;
import cn.hutool.core.date.DateUtil;
import com.boying.service.TicketService;
import com.boying.util.HTTPEntityUtil;
import com.google.gson.Gson;
import lombok.AllArgsConstructor;
import org.springframework.http.HttpHeaders;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * @author kdq
 * @version 1.0.0
 * @ClassName TicketServiceImpl.java
 * @Description TODO
 * @createTime 2022年11月20日 10:31:00
 */
@Service
@AllArgsConstructor
public class TicketServiceImpl extends ServiceImpl<TicketMapper, Ticket> implements TicketService {
    private final TicketMapper ticketMapper;
    private SystemConfigProperties systemConfigProperties;


    @Override
    public Integer count1() {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .isNotNull(Ticket::getPayCode);
        return ticketMapper.selectCount(wrapper);
    }

    @Override
    public int count2() {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .eq(Ticket::getPayStatus,1);
        return ticketMapper.selectCount(wrapper);
    }

    @Override
    public double sumByPrice() {
        Double a = null;
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.select("IFNULL(ROUND(SUM(money)),0) as money");
        wrapper.lambda().between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .eq(Ticket::getPayStatus,1);
        Map<String, Object> map = getMap(wrapper);
        a = Double.valueOf(map.get("money").toString());
        if(a==null){
            return 0.0;
        }else{
            return a;
        }
    }

    @Override
    public int count3() {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .between(Ticket::getCreateTime,DateUtil.beginOfMonth(new Date()),DateUtil.endOfMonth(new Date()));
        return ticketMapper.selectCount(wrapper);
    }

    @Override
    public double sumByPrice2() {
        Double a = null;
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.select("IFNULL(ROUND(SUM(money)),0) as money");
        wrapper.lambda().between(Ticket::getCreateTime,DateUtil.beginOfMonth(new Date()),DateUtil.endOfMonth(new Date()))
                .eq(Ticket::getPayStatus,1);
        Map<String, Object> map = getMap(wrapper);
        a = Double.valueOf(map.get("money").toString());
        if(a==null){
            return 0;
        }else{
            return a;
        }
    }

    @Override
    public int count4() {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .eq(Ticket::getPayStatus,1);
        int a = count(wrapper)*100;
        int b = count();
        return (a/b);
    }

    @Override
    public int count5(int type) {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .eq(Ticket::getType,1);
        if(type==1){
            return ticketMapper.selectCount(wrapper);
        }else{
            wrapper.lambda().eq(Ticket::getStatus,1);
            return ticketMapper.selectCount(wrapper);
        }
    }

    @Override
    public int count6() {
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .eq(Ticket::getType,1);
        return ticketMapper.selectCount(wrapper);
    }

    @Override
    public double sumByPrice3() {
        Double a = null;
        QueryWrapper<Ticket> wrapper = new QueryWrapper<>();
        wrapper.select("IFNULL(ROUND(SUM(money)),0) as money");
        wrapper.lambda().between(Ticket::getCreateTime,DateUtil.beginOfDay(new Date()),DateUtil.endOfDay(new Date()))
                .eq(Ticket::getType,0)
                .eq(Ticket::getPayStatus,1);
        Map<String, Object> map = getMap(wrapper);
        a = Double.valueOf(map.get("money").toString());
        if(a==null){
            return 0.0;
        }else{
            return a;
        }
    }

    @Override
    public void uploadInfo(Ticket ticket) {
        DateFormat sdf= new SimpleDateFormat("yyyy年MM月dd日");
        String ffzfIp = systemConfigProperties.getFfzfIp();
        String info = systemConfigProperties.getInfo();
        Map<String, Object> map = new HashMap<>();
        String jsonString = JSONUtil.toJsonStr(ticket);
        Gson gson = new Gson();
        map = gson.fromJson(jsonString, map.getClass());
        System.out.println(jsonString);
        RestTemplate restTemplate = new RestTemplate();
        ResponseEntity<R> entity = restTemplate.postForEntity(ffzfIp+info, HTTPEntityUtil.setEntity(map), R.class);
        int code = entity.getBody().getCode();
        if(code == 0){
            ticket.setPush(1);
            try {
                Date date = new Date();
                String format = sdf.format(date);
                ticket.setWordDate(format);
            }catch (Exception e){
                e.printStackTrace();
            }
            this.updateById(ticket);
        }
    }

    @Override
    public Ticket getNumber(Ticket byId) {
        String ffzfIp = systemConfigProperties.getFfzfIp();
        String getNumber = systemConfigProperties.getGetNumber();
        String loginIp = systemConfigProperties.getLoginIp();
        Map<String, Object> paramMap = new HashMap<>();
        paramMap.put("username","test");
        paramMap.put("password","ttt000");
        paramMap.put("randomStr","blockPuzzle");
        paramMap.put("grant_type","password");
        String body = HttpRequest.post(loginIp)
                .header(Header.CONTENT_TYPE, "application/x-www-form-urlencoded")
                .header("TENANT-ID", "1")
                .header("isToken", "false")
                .header(Header.AUTHORIZATION, "Basic YXBwOmFwcA==")
                .form(paramMap)
                .timeout(15000)
                .execute()
                .body();
        System.out.println(body);
        JSONObject map = JSON.parseObject(body);
        String access_token = (String)map.get("access_token");

        String body1 = HttpRequest.get(ffzfIp+getNumber)
                .header(Header.CONTENT_TYPE, "application/json")
                .header("TENANT-ID", "1")
                .header(Header.AUTHORIZATION, "bearer "+access_token)
                .timeout(15000)
                .execute()
                .body();
        System.out.println(body1);
        JSONObject map1 = JSON.parseObject(body1);
        String data = (String)map1.get("data");
        String[] split = data.split("-");
        byId.setYear(split[0]);
        byId.setNumber(split[1]);
        updateById(byId);
        return byId;
    }


}