package com.wms_admin.server.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.wms_admin.server.entity.Product;
import com.wms_admin.server.mapper.ProductMapper;
import com.wms_admin.server.service.ProductModelService;
import com.wms_admin.server.service.ProductNameService;
import com.wms_admin.server.service.ProductService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.wms_admin.utils.MyUtils;
import com.wms_admin.utils.RedisUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.*;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author 江苏鵷雏网络科技有限公司
 * @since 2023-05-24
 */
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {

    @Resource
    private ProductMapper mapper;

    @Autowired
    private ProductModelService modelService;

    @Autowired
    private ProductNameService nameService;
    /**
     * 入库添加操作
     * @param product 实体类
     * @return 返回结果：1 成功；0：失败
     */
    @Override
    public Integer AddProductMessage(Product product) {
        Integer productModelId = modelService.SelectProductModelId(product.getProductModel(), product.getProductCode());
        product.setProductModelId(productModelId);
        Integer productNameId = nameService.SelectProductNameId(product.getProductName());
        product.setProductNameId(productNameId);
        return mapper.insert(product);
    }

    /**
     * 根据条件分页查询数据
     * @param startTime 开始时间，可以为空，但是一旦有开始时间那么一定有结束时间
     * @param endTime 结束时间
     * @param productModel 库存型号
     * @param page 分页条件
     * @return 返回数据
     */
    @Override
    public IPage<Product> ListProductMessage(String startTime, String endTime, String productModel, Page page) {
        return mapper.SelectHistory(startTime, endTime, productModel, page);
    }

    /**
     * 根据条件导出所有的数据
     * @param startTime 开始时间，可以为空，但是一旦有开始时间那么一定有结束时间
     * @param endTime 结束时间
     * @param productModel 库存型号
     * @return 返回查询到的数据
     */
    @Override
    public List<Product> ExcelDerive(String startTime, String endTime, String productModel) {
        return mapper.SelectHistory(startTime, endTime, productModel);
    }

    @Override
    public List<Map<String, Object>> SelectExceedThirtyDayData() {
        return mapper.ExceedThirtyDay();
    }

    @Override
    public Map<String, Object> SelectWeekNumData() {
        List<Map<String, Object>> maps = mapper.SelectWeekNumData();
        List<Object> xList = new ArrayList<>();
        List<Object> enterList = new ArrayList<>();
        List<Object> outList = new ArrayList<>();
        for (Map<String, Object> map : maps) {
            Object date = map.get("date");
            String time0 = MyUtils.getTime_0((Date) date);
            xList.add(time0);
            enterList.add(map.get("product_num"));
            outList.add(map.get("out_product_num"));
        }
        Collections.reverse(xList);
        Collections.reverse(enterList);
        Collections.reverse(outList);
        Map<String, Object> map = new HashMap<>();
        map.put("xList", xList);
        map.put("yEnterList", enterList);
        map.put("yOutList", outList);
        return map;
    }

    @Override
    public Integer TimerCountWeekDayData() {
        return mapper.TimerCountWeekDayData();
    }

    @Override
    public List<Map<String, Object>> SelectNameData(String productName) {
        return mapper.SelectNameData(productName);
    }

    @Override
    public List<Map<String, Object>> PieData() {
        String beginningMonthKey = "beginningMonth";
        String endOfMonthKey = "endOfMonth";
        // 将月初，月末数据拼接到该数据中，并且时间对应
        List<Map<String, Object>> maps = mapper.PieData();
        // 月初剩余库总数数据
        Map<String, Object> beginningMonth = JSONObject.parseObject(JSON.toJSONString(RedisUtil.get("beginningMonth")));
        // 月末剩余库总数数据
        Map<String, Object> endOfMonth = JSONObject.parseObject(JSON.toJSONString(RedisUtil.get("endOfMonth")));
        // 拼接月初剩余库总数数据
        List<Map<String, Object>> beginningMonthMaps = publicCode(maps, beginningMonth, beginningMonthKey);
        // 在拼接完月初的数据后以此为基础拼接
        return publicCode(beginningMonthMaps, endOfMonth, endOfMonthKey);
    }

    @Override
    public Product SelectIdProduct(String code) {
        return mapper.SelectIdProduct(code);
    }

    // 将Redis中的数据与Mysql中的数据拼接
    private List<Map<String, Object>> publicCode(List<Map<String, Object>> mainMaps, Map<String, Object> maps, String jsonKey){
        for (Map<String, Object> map : mainMaps){
            // mysql中的时间，以此为基础拼接
            String mainKey = (String)map.get("datetime");
            // 库存参数
            List<String> num = JSON.parseArray(maps.get("num").toString(), String.class);
            // Redis中存储的月份
            List<String> datetime = JSON.parseArray(maps.get("datetime").toString(), String.class);
            // 循环，如果时间相同则进行拼接
            for (int i = 0; i < datetime.size(); i++){
                if (mainKey.equals(datetime.get(i))){
                    map.put(jsonKey, num.get(i));
                }
            }
            // 判断是否存在key，如果不存在拼接为0
            if (!map.containsKey(jsonKey)){
                // 如果不存在赋值为0
                map.put(jsonKey, 0);
            }
        }
        return mainMaps;
    }
}