package com.xzx.order;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import cn.hutool.poi.excel.ExcelReader;
import cn.hutool.poi.excel.ExcelUtil;
import com.xzx.gc.GcOrderApplication;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.common.utils.IdUtils;
import com.xzx.gc.common.utils.gdmap.GdMapUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.dto.GdAreaDto;
import com.xzx.gc.order.mapper.*;
import org.apache.tomcat.jni.Address;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import tk.mybatis.mapper.code.ORDER;
import tk.mybatis.mapper.entity.Example;

import java.io.File;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.stream.Collectors;

/**
 * 专页修复
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = {GcOrderApplication.class})
@ActiveProfiles(profiles = {"temp"})
public class FixTest {

    @Autowired
    private AddressLevelInfoMapper addressLevelInfoMapper;

    @Autowired
    private AddressLevelInfoBatchMapper addressLevelInfoBatchMapper;

    @Autowired
    private OrderDetailMapper orderDetailMapper;

    @Autowired
    private OrderStorageInfoMapper orderStorageInfoMapper;

    @Autowired
    private OrderStorageDetailMapper orderStorageDetailMapper;

    @Autowired
    private IdUtils idUtils;

    @Autowired
    private OtherUserMapper otherUserMapper;
    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private OrderItemInfoMapper orderItemInfoMapper;

//    @Test
//    public void 修复地址层级表的编码(){
//        String path="d:/AMap_adcode_citycode.xlsx";
//        ExcelReader reader = ExcelUtil.getReader(FileUtil.file(path));
//        List<List<Object>> readAll = reader.read();
//        List<AddressLevelInfo> addressLevelInfos = addressLevelInfoMapper.selectAll();
//
//        List<AddressLevelInfo> list=new ArrayList<>();
//
//        for (AddressLevelInfo addressLevelInfo : addressLevelInfos) {
//            String level3Name = addressLevelInfo.getLevel3Name();
//            String level2Name = addressLevelInfo.getLevel2Name();
//            for (List<Object> objects : readAll) {
//                if(objects.size()==3) {
//                    String name = (String) objects.get(0);
//                    String adoce = (String) objects.get(1);
//                    String citycode = (String) objects.get(2);
//                    //根据citycode找到名称
//                    String cityName = getcityName(readAll, citycode);
//
//                    if (name.equals(level3Name) && cityName.equals(level2Name)) {
//
//                        System.out.println("匹配到"+cityName+","+citycode+","+name+","+adoce);
//                        addressLevelInfo.setCitycode(citycode);
//                        addressLevelInfo.setAdcode(adoce);
//                        addressLevelInfoMapper.updateByPrimaryKeySelective(addressLevelInfo);
//                        break;
//                    }
//                }
//            }
//        }
//
//    }

    @Test
    public void 修复地址层级表的编码2() throws InterruptedException {
        List<AddressLevelInfo> list=new ArrayList<>();
        Example example=new Example(AddressLevelInfo.class);
//        example.createCriteria().andIsNull("adcode");
        List<AddressLevelInfo> addressLevelInfos = addressLevelInfoMapper.selectByExample(example);
        CountDownLatch countDownLatch = ThreadUtil.newCountDownLatch(addressLevelInfos.size());
        for (AddressLevelInfo addressLevelInfo : addressLevelInfos) {

            Runnable callable=()->{
                AddressLevelInfo addressLevelInfo1 = fixAdd(addressLevelInfo);
                if(addressLevelInfo1!=null){
                    list.add(addressLevelInfo1);
                }
                countDownLatch.countDown();
            };

            ThreadUtil.execAsync(callable,true);
        }

        countDownLatch.await();

        if(CollUtil.isNotEmpty(list)) {
            addressLevelInfoBatchMapper.updateBatchByPrimaryKeySelective(list);
        }
    }

    public AddressLevelInfo fixAdd(AddressLevelInfo addressLevelInfo){
        String level3Name = addressLevelInfo.getLevel3Name();
        String level2Name = addressLevelInfo.getLevel2Name();

        Result result = GdMapUtil.findByAreaName(level3Name);

        if(result.getCode()==0) {
            List<GdAreaDto> list = (List<GdAreaDto>) result.getData();
            if (list.size() == 1) {
                addressLevelInfo.setCitycode(list.get(0).getCitycode());
                addressLevelInfo.setAdcode(list.get(0).getAdcode());
            } else if(list.size()>1) {
                Result<List<GdAreaDto>> byAreaName = GdMapUtil.findByAreaName(level2Name);
                if(byAreaName.getCode()==0) {
                    List<GdAreaDto> data = byAreaName.getData();
                    if(data.size()>0) {
                        String citycode = data.get(0).getCitycode();
                        addressLevelInfo.setCitycode(citycode);
                        List<GdAreaDto> collect = list.stream().filter(x -> x.getCitycode().equals(citycode)).collect(Collectors.toList());
                        if (CollUtil.isNotEmpty(collect)) {
                            addressLevelInfo.setAdcode(collect.get(0).getAdcode());
                        } else {
                            System.err.println("匹配市对应区失败" + level2Name + "," + citycode + "==" + JSONUtil.toJsonStr(list));
                        }
                    }else {
                        System.err.println("匹配市失败" + level2Name);
                    }

                }
            }else {
                System.err.println("匹配区失败"+level3Name);
            }

            System.out.println("匹配到"+level2Name+","+addressLevelInfo.getCitycode()+","+level3Name+","+addressLevelInfo.getAdcode());

            if(StrUtil.isNotBlank(addressLevelInfo.getCitycode())&&StrUtil.isNotBlank(addressLevelInfo.getAdcode())){
               return addressLevelInfo;
            }

        }

        return null;

    }


    private String getcityName(List<List<Object>> readAll,String code){
        for (List<Object> objects : readAll) {
            if(objects.size()==3) {
                String name = (String) objects.get(0);
                String adoce = (String) objects.get(1);
                String citycode = (String) objects.get(2);
                if (citycode.equals(code)) {
                    return name;
                }
            }
        }
        return "";
    }

    @Test
    public void 指定回收员哪些订单入库(){

        System.out.println("start");
        String receiver="472";
        Example example=new Example(OrderInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("receiver",receiver);
        criteria.andEqualTo("orderStatus","4");
        criteria.andLessThanOrEqualTo("createTime","2019-12-03 23:59:59");
        List<OrderInfo> orderInfos = orderMapper.selectByExample(example);
//        List<OrderInfo> orderInfos=new ArrayList<>();
//
//        String s="DD1196275805278306304,DD1196301593952256000,DD1196632895394021376,DD1196639747204841472,DD1196643257531105280,DD1196644437254602752,DD1197073829600559104,DD1197335739881357312,DD1197346586385055744,DD1197352297819144192,DD1197668095540461568,DD1198047754463608832,DD1198170901275869184,DD1198476178009227264,DD1198492224514555904,DD1198808419436462080,DD1198808823960305664,DD1198839269809061888,DD1198857459725369344,DD1199149116035301376,DD1199162750044078080,DD1199189482717446144,DD1199214392185585664,DD1199220954371325952,DD1199231880965259264,DD1199596796792406016,DD1199859477315190784,DD1199869354041278464,DD1199875477645426688,DD1199888299230101504,DD1199954145944141824,DD1199960183762190336,DD1200240149108228096,DD1200244848930717696,DD1200259857106731008,DD1200334622609776640,DD1200573291039948800,DD1200598016130678784,DD1200650205410754560,DD1200974416486465536,DD1200981872696492032,DD1200982805434204160,DD1201052333946044416,DD1201070321717870592,DD1201291665969643520,DD1201342043901788160,DD1201381950401675264,DD1201393463938121728,DD1201655979343740928,DD1201735933238575104,DD1201738093221249024,DD1201743726033108992,DD1201777301650538496,DD1201778550244507648";
//        String[] split = s.split(",");
//        for (String s1 : split) {
//            OrderInfo  orderInfo=new OrderInfo();
//            orderInfo.setOrderId(s1);
//            orderInfos.add(orderInfo);
//        }

        BigDecimal money=Constants.MONEY_INIT;
        BigDecimal weight=Constants.WEIGHT_INIT;

//        if(orderInfos.size()!=54){
//            System.out.println(orderInfos.size());
//            return;
//        }
//        if(orderInfos.size()!=54)return;

        //订单id
        List<String> ids=new ArrayList<>();
        for (OrderInfo orderInfo : orderInfos) {
            String orderId = orderInfo.getOrderId();
            OrderDetailInfo orderDetailInfo=new OrderDetailInfo();
            orderDetailInfo.setOrderId(orderId);
            OrderDetailInfo orderDetailInfo1 = orderDetailMapper.selectOne(orderDetailInfo);
            money=NumberUtil.add(money,Convert.toBigDecimal(orderDetailInfo1.getMoney()));
            weight=NumberUtil.add(weight,Convert.toBigDecimal(orderDetailInfo1.getWeight()));
            ids.add(orderId);
            orderDetailInfo1.setStorageUserId("USER1190571142298341376");
            orderDetailInfo1.setStorageUserName("陈松");
            orderDetailInfo1.setStorageUserPhone("17788919577");
            orderDetailInfo1.setStorageMoney(orderDetailInfo1.getMoney());
            orderDetailMapper.updateByPrimaryKeySelective(orderDetailInfo1);
        }

        //金额总值
        String moneyStr = NumberUtil.roundStr(money.toString(), 2, RoundingMode.DOWN);
        //重量总值
        String weightStr = NumberUtil.roundStr(weight.toString(), 3, RoundingMode.DOWN);



        //订单总值
        String orderIds = StrUtil.join(",",ids);


        //添加入库记录
        OtherUserInfo otherUserInfo = otherUserMapper.selectByPrimaryKey(receiver);
        OrderStorageInfo orderStorageInfo=new OrderStorageInfo();
        orderStorageInfo.setStorageUserId("USER1190571142298341376");
        orderStorageInfo.setStorageStatus(Convert.toShort(0));
        orderStorageInfo.setStorageUserName("陈松");
        orderStorageInfo.setStorageUserPhone("17788919577");
        orderStorageInfo.setSysStorageId(1L);

        orderStorageInfo.setReceiver(receiver);
        orderStorageInfo.setReceiverAvatar(otherUserInfo.getAvatar());
        orderStorageInfo.setReceiverPhone(otherUserInfo.getMobilePhone());
        orderStorageInfo.setReceiverName(otherUserInfo.getNickName());

        orderStorageInfo.setStorageTime(DateUtil.now());
        orderStorageInfo.setOrderId(orderIds);
        String storageId=idUtils.generate("RK",2);
        orderStorageInfo.setStorageId(storageId);

        orderStorageInfo.setRecycleMoney(Convert.toBigDecimal(moneyStr));
        orderStorageInfo.setStorageMoney(Convert.toBigDecimal(moneyStr));
        orderStorageInfo.setStorageWeight(weightStr);
        orderStorageInfo.setRecycleWeight(weightStr);
        orderStorageInfoMapper.insertSelective(orderStorageInfo);


        //添加入库详情

        for (String id : ids) {
            OrderItemInfo orderItemInfo=new OrderItemInfo();
            orderItemInfo.setOrderId(id);
            List<OrderItemInfo> select = orderItemInfoMapper.select(orderItemInfo);
            for (OrderItemInfo itemInfo : select) {
                OrderStorageDetailInfo orderStorageDetailInfo=new OrderStorageDetailInfo();
                orderStorageDetailInfo.setStorageId(storageId);
                orderStorageDetailInfo.setFlag("1");
                orderStorageDetailInfo.setItemType(itemInfo.getItemType());
                orderStorageDetailInfo.setWeight(Convert.toBigDecimal(itemInfo.getWeight()));
                orderStorageDetailInfo.setMoney(itemInfo.getMoney());
                OrderStorageDetailInfo orderStorageDetailInfo2=new OrderStorageDetailInfo();
                BeanUtil.copyProperties(orderStorageDetailInfo,orderStorageDetailInfo2);
                orderStorageDetailInfo2.setFlag("2");
                orderStorageDetailMapper.insertSelective(orderStorageDetailInfo);
                orderStorageDetailMapper.insertSelective(orderStorageDetailInfo2);
            }

            OrderInfo orderInfo=new OrderInfo();
            orderInfo.setOrderId(id);
            orderInfo.setOrderStatus("5");
            orderMapper.updateByPrimaryKeySelective(orderInfo);
        }

        System.out.println("success");



    }
}