package com.xcong.excoin.modules.datamove;

import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.xcong.excoin.modules.datamove.dao.*;
import com.xcong.excoin.modules.datamove.entity.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * @author wzy
 * @date 2021-07-01
 **/
@Service
public class DataMoveService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Autowired
    private JhyInfoMapper jhyInfoMapper;

    @Autowired
    private JhyOrderMapper jhyOrderMapper;

    @Autowired
    private JhyOrderItemsMapper jhyOrderItemsMapper;

    public <T> T mapToBane(Map<String, Object> map, Class<T> t) {
        String s = JSONObject.toJSONString(map);
        return JSONObject.parseObject(s, t);
    }

    @DS("slave")
    public List<Map<String, Object>> oldJhyTest() {
        return jdbcTemplate.queryForList("select * from zx_jhy");
    }

    public void newJhyInfoTest(List<Map<String, Object>> datas) {
        for (Map<String, Object> data : datas) {
            JhyInfo jhyInfo = mapToBane(data, JhyInfo.class);
            String date = data.get("create_time").toString();
            jhyInfo.setCreatedTime(DateUtil.parse(date, "yyyy-MM-dd HH:mm:ss"));
            jhyInfo.setCardPos(data.get("card").toString());
            jhyInfo.setIsJhy("1");
            jhyInfo.setStatus(2);
            jhyInfoMapper.insert(jhyInfo);
        }
    }

    @DS("slave")
    public List<Map<String, Object>> oldOrderTest() {
        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from zx_jhy_order_info");
        for (Map<String, Object> map : maps) {
            List<Map<String, Object>> goods = jdbcTemplate.queryForList("select * from zx_jhy_order_goods where order_id=" + map.get("id"));
            if (map.get("jhy") != null && !"0".equals(map.get("jhy").toString())) {
                Map<String, Object> jhy = jdbcTemplate.queryForMap("select * from zx_users where id=" + map.get("jhy"));
                if (jhy != null) {
                    map.put("jhy_id", jhy.get("yhid"));
                }
            }

            map.put("items", goods);
        }
        return maps;
    }


    @Transactional(rollbackFor = Exception.class)
    public void newOrderTest(List<Map<String, Object>> datas) {
        for (Map<String, Object> data : datas) {
            JhyOrder jhyOrder = mapToBane(data, JhyOrder.class);
            String createTime = data.get("create_time").toString();
            jhyOrder.setCreatedTime(DateUtil.parse(createTime, "yyyy-MM-dd HH:mm:ss"));
            jhyOrder.setArea(data.get("address_area").toString());
            jhyOrder.setOrderNo(data.get("order_id").toString());
            jhyOrder.setAddress(data.get("address").toString());
            String udpateTime = data.get("update_time").toString();
            jhyOrder.setReceivingTime(DateUtil.parse(udpateTime, "yyyy-MM-dd HH:mm:ss"));
            jhyOrder.setWeight(data.get("remark").toString());
            jhyOrder.setIsCommented(null);
            String reserveDate = data.get("create_time").toString();
            jhyOrder.setReserveDate(DateUtil.parse(reserveDate, "yyyy-MM-dd"));
            jhyOrder.setIsAnonymous(null);
            jhyOrder.setUsername(data.get("username").toString());
            switch (jhyOrder.getStatus()) {
                case 4 :
                    jhyOrder.setStatus(3);
                    break;
                case 6:
                    jhyOrder.setStatus(5);
            }

            Map<String, Object> userId = jdbcTemplate.queryForMap("select * from xzx_user_info where user_id='" + jhyOrder.getUserId() + "'");
            jhyOrder.setPhone(userId.get("mobile_phone").toString());
            jhyOrderMapper.insert(jhyOrder);

            boolean flag = false;
            List<Map<String, Object>> items = (List<Map<String, Object>>) data.get("items");
            for (Map<String, Object> item : items) {
                JhyOrderItems jhyOrderItems = mapToBane(item, JhyOrderItems.class);
                jhyOrderItems.setOrderId(jhyOrder.getId());
                if (jhyOrder.getStatus() != 5) {
                    String total = data.get("ordersum").toString();
                    jhyOrderItems.setScore(total);

                    if (items.size() > 1) {
                        if (!flag) {
                            jhyOrderItems.setWeight(new BigDecimal(total).divide(BigDecimal.valueOf(40), 2, BigDecimal.ROUND_DOWN));
                        } else {
                            jhyOrderItems.setWeight(BigDecimal.ZERO);
                            jhyOrderItems.setScore("0");
                        }
                        flag = true;
                    } else {
                        jhyOrderItems.setWeight(new BigDecimal(total).divide(BigDecimal.valueOf(40), 2, BigDecimal.ROUND_DOWN));
                    }
                }

                jhyOrderItemsMapper.insert(jhyOrderItems);
            }
        }
    }


    @DS("slave")
    public List<Map<String, Object>> oldShopOrderList() {
        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from zx_order_info");
        for (Map<String, Object> map : maps) {
            Map<String, Object> sku = jdbcTemplate.queryForMap("select * from zx_order_goods where order_id=" + map.get("id"));

            Map<String, Object> user = jdbcTemplate.queryForMap("select * from zx_users where id=" + map.get("user_id"));

            System.out.println(sku.get("sku_id"));
            Map<String, Object> goods = jdbcTemplate.queryForMap("select * from zx_goods where id=" + sku.get("sku_id"));
            map.put("user_id", user.get("yhid"));
            map.put("sku", sku);
            map.put("goods", goods);
        }
        return maps;
    }

    public  String generate(String prefix,long datacenterId){
        Snowflake snowflake = IdUtil.getSnowflake(Convert.toLong(0), datacenterId);
        return prefix+snowflake.nextIdStr();
    }

    @Autowired
    private ScoreOrderMapper scoreOrderMapper;

    @Autowired
    private ScoreExpressInfoMapper scoreExpressInfoMapper;

    @Autowired
    private ScoreOrderDetailsMapper scoreOrderDetailsMapper;

    public void newShopOrderList(List<Map<String, Object>> maps) {
        for (Map<String, Object> map : maps) {
            Map<String, Object> goods = (Map<String, Object>) map.get("goods");

            ScoreOrder scoreOrder = mapToBane(map, ScoreOrder.class);
            scoreOrder.setGoodsName(goods.get("name").toString());
            scoreOrder.setOrderNo(generate("JF", 9));
            scoreOrder.setCnt(Integer.parseInt(map.get("number").toString()));
            scoreOrder.setTotalPrice(new BigDecimal(map.get("total_mount").toString()));
            String createTime = map.get("create_time").toString();
            scoreOrder.setCreatedTime(DateUtil.parse(createTime, "yyyy-MM-dd HH:mm:ss"));
            scoreOrder.setIsFinish(2);
            scoreOrderMapper.insert(scoreOrder);

            ScoreExpressInfo expressInfo = new ScoreExpressInfo();
            expressInfo.setOrderId(scoreOrder.getId());
            expressInfo.setAddress(map.get("address").toString());
            expressInfo.setPhone(map.get("mobile").toString());
            expressInfo.setUsername(map.get("username").toString());
            expressInfo.setCreatedTime(DateUtil.parse(createTime, "yyyy-MM-dd HH:mm:ss"));
            expressInfo.setUserId(scoreOrder.getUserId());
            scoreExpressInfoMapper.insert(expressInfo);

            Map<String, Object> sku = (Map<String, Object>) map.get("sku");
            ScoreOrderDetails orderDetails = new ScoreOrderDetails();
            orderDetails.setOrderId(scoreOrder.getId());
            orderDetails.setCnt(scoreOrder.getCnt());
            orderDetails.setUnitPrice(new BigDecimal(goods.get("present_price").toString()));
            orderDetails.setStyle(goods.get("style").toString());
            orderDetails.setSku(goods.get("specs").toString());
            orderDetails.setThumb("https://pic.cnxzx.com/media/" + goods.get("image_url"));
            orderDetails.setTotalPrice(new BigDecimal(map.get("total_mount").toString()));
            orderDetails.setGoodsName(goods.get("name").toString());
            scoreOrderDetailsMapper.insert(orderDetails);
        }
    }

    @DS("slave")
    public List<Map<String, Object>> oldScoreDetails() {
        List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from zx_integral_records");
        for (Map<String, Object> map : maps) {
            Map<String, Object> user = jdbcTemplate.queryForMap("select * from zx_users where id=" + map.get("user_id"));
            map.put("user_id", user.get("yhid"));
        }
        return maps;
    }

    @Autowired
    private ScoreDetailsMapper scoreDetailsMapper;

    public void newScoreDetails(List<Map<String, Object>> maps) {
        for (Map<String, Object> map : maps) {
            ScoreDetails scoreDetails = mapToBane(map, ScoreDetails.class);
            String createTime = map.get("create_time").toString();
            scoreDetails.setCreatedTime(DateUtil.parse(createTime, "yyyy-MM-dd HH:mm:ss"));
            scoreDetails.setCurrentScore(new BigDecimal(map.get("present").toString()));
            scoreDetails.setChangeScore(new BigDecimal(map.get("change").toString()));
            scoreDetails.setOriginalScore(new BigDecimal(map.get("original").toString()));
            scoreDetails.setType(Integer.parseInt(map.get("source_type").toString()));
            scoreDetails.setOrderNo(map.get("order_id").toString());
            scoreDetailsMapper.insert(scoreDetails);
        }
    }

    @DS("slave")
    public List<Map<String, Object>> oldScore() {
        return jdbcTemplate.queryForList("select * from zx_users where integral!=0");
    }


    public void newScore(List<Map<String, Object>> maps) {
        for (Map<String, Object> map : maps) {
            jdbcTemplate.update("update xzx_account_info set collect_score=" + map.get("integral") + " where user_id='" + map.get("yhid") + "'");
        }
    }
}