package com.taoke.autopay;

import com.taoke.autopay.dao.KeyOrderMapper;
import com.taoke.autopay.entity.KeyOrder;
import com.taoke.autopay.utils.Constant;
import com.taoke.autopay.utils.TimeUtil;
import net.sf.json.JSONObject;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.yeshi.utils.StringUtil;

import javax.annotation.Resource;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.math.BigDecimal;
import java.util.*;

/**
 * @author hxh
 * @title: LogTest
 * @description: TODO
 * @date 2024/7/19 12:15
 */
@SpringBootTest
public class LogTest {


    @Resource
    private KeyOrderMapper keyOrderMapper;

    @Test
    public void parseLog() throws FileNotFoundException {

        String[] days = new String[]{"2024-07-15","2024-07-16","2024-07-17","2024-07-18"};
        for(String day:days) {
            Scanner scanner = new Scanner(new FileInputStream("D:\\文件传输\\交易\\日志文件\\xcp\\pay.log.gz."+day));
            while (scanner.hasNextLine()) {
                String line = scanner.nextLine();
                if (!line.contains("setOrderNo:")) {
                    continue;
                }
                String[] sts = line.split("setOrderNo:")[1].split("-");
                String id = sts[0].trim();
                String money = sts[sts.length - 1].replace("¥", "");
                System.out.println(id + ":" + money);
                KeyOrder order = keyOrderMapper.selectById(id);
                if(order!=null){
                    KeyOrder update=new KeyOrder();
                    update.setId(id);
                    update.setOrderMoney(new BigDecimal(money));
                    keyOrderMapper.updateByPrimaryKeySelective(update);
                }
            }
            scanner.close();

        }

    }

    @Test
    public void parseLogForChannel() throws FileNotFoundException {

        String[] days = new String[]{"2024-07-15","2024-07-16","2024-07-17","2024-07-18"};

        for(String day:days) {
            Set<String> bps=new HashSet<>();
            Set<String> cyx=new HashSet<>();
            Scanner scanner = new Scanner(new FileInputStream("D:\\文件传输\\交易\\日志文件\\xcp\\info.log.gz."+day));
            while (scanner.hasNextLine()) {
                String line = scanner.nextLine();
                if (!line.contains("抖音订单查询")) {
                    continue;
                }
                line =  line.split("dyorderApiLogger -")[1];
                int startIndex = line.indexOf("：");
                String tag = line.substring(0,startIndex).trim();
                String id =  line.substring(startIndex + 1,line.indexOf("-")).trim();
                String data =  line.substring(line.indexOf("-")+1);
                if(tag.contains("(1)")){
                    cyx.add(id);
                }else if(tag.contains("(2)")){
                    bps.add(id);
                }
            }

            Set<String> totalOrderNos=new HashSet<>();
            totalOrderNos.addAll(bps);
            totalOrderNos.addAll(cyx);
            Map<String,String> orderChannelMap = new HashMap<>();
            // 交集里面的订单不属于任何一个渠道
            Set<String> intersection = new HashSet<>(bps);
            intersection.retainAll(cyx);
            for(String r:intersection){
                orderChannelMap.put(r,null);
            }
            // 差集属于bps
            Set<String> difference = new HashSet<>(cyx);
            difference.removeAll(bps);
            for(String r:difference){
                orderChannelMap.put(r,Constant.ORDER_CHANNEL_BPS);
            }

            // 当天订单与totalOrderNos的所有差集属于cyx
            Date minCreateTime =new Date(TimeUtil.convertToTimeTemp(day,"yyyy-MM-dd"));
            Date maxCreateTime =TimeUtil.getNextDay(1,new Date(TimeUtil.convertToTimeTemp(day,"yyyy-MM-dd")).getTime());
            KeyOrderMapper.DaoQuery query=new KeyOrderMapper.DaoQuery();
            query.minCreateTime =minCreateTime;
            query.maxCreateTime =maxCreateTime;
            query.start = 0;
            query.count =10000;
            query.state = KeyOrder.STATE_PAY;
            List<KeyOrder> orders =  keyOrderMapper.list(query);
            Set<String> dayOrderNos=new HashSet<>();
            for(KeyOrder o:orders){
                if(!StringUtil.isNullOrEmpty(o.getOrderNo())) {
                    dayOrderNos.add(o.getOrderNo());
                }
            }
            dayOrderNos.removeAll(totalOrderNos);
            for(String r:dayOrderNos){
                orderChannelMap.put(r,Constant.ORDER_CHANNEL_CYX);
            }
        for(Iterator<String> its= orderChannelMap.keySet().iterator();its.hasNext();){
            String orderNo = its.next();
            query=new KeyOrderMapper.DaoQuery();
            query.orderNo = orderNo;
            query.start=0;
            query.count =100;
            orders =  keyOrderMapper.list(query);
            for(KeyOrder order:orders){
                if(order.getState()== KeyOrder.STATE_PAY){
                  String channel =  orderChannelMap.get(orderNo);
                  if(channel!=null){
                      KeyOrder update=new KeyOrder();
                      update.setId(order.getId());
                      update.setOrderChannel(channel);
                      update.setUpdateTime(new Date());
                      keyOrderMapper.updateByPrimaryKeySelective(update);
                  }
                }
            }
        }
            scanner.close();
        }



    }

}