package com.ld.igds.quantity.service;

import com.ld.igds.constant.RedisConst;
import com.ld.igds.models.QuantityConf;
import com.ld.igds.quantity.dto.QuantityData;
import com.ld.igds.quantity.dto.QuantityParam;
import com.ld.igds.quantity.mapper.QuantityMapper;
import com.ld.igds.util.RedisUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;

/**
 * @author vince.xu
 * @Title: CoreQuantityServiceImpl
 * @ProjectName igds-dev
 * @Description:
 * @date 2021/6/17 001715:09
 */
@Service(CoreQuantityService.BEAN_ID)
public class CoreQuantityServiceImpl implements CoreQuantityService {

    @Autowired
    private QuantityMapper quantityMapper;

    @Autowired
    private RedisUtil redisUtil;

    @Override
    public void saveData(QuantityData data) {
        quantityMapper.saveData(data);
    }

    @Override
    public QuantityData getLastData(QuantityParam param) {
        return quantityMapper.getLastData(param);
    }

    @Override
    public void setCacheQuantityConf(List<QuantityConf> list) {
        if (null == list || list.isEmpty()) return;

        String key;
        for (QuantityConf conf : list) {
            if (StringUtils.isEmpty(conf.getSn())) {
                conf.setSn(conf.getYtIp());
            }
            key = RedisConst.buildKeyByPrefix(RedisConst.KEY_QUANTITY_CONF, conf.getSn());
            redisUtil.set(key, conf);
        }
    }

    public void setCacheQuantityConf(QuantityConf conf) {
        if (StringUtils.isEmpty(conf.getSn())) {
            conf.setSn(conf.getYtIp());
        }
        String key = RedisConst.buildKeyByPrefix(RedisConst.KEY_QUANTITY_CONF, conf.getSn());
        redisUtil.set(key, conf);
    }

    @Override
    public void refreshQuantityConfCache() {
        this.setCacheQuantityConf(quantityMapper.queryAll());
    }

    @Override
    public QuantityConf getCacheQuantityConf(String companyId, String depotId) {

        String pattern = RedisConst.buildKeyByPrefix(RedisConst.KEY_QUANTITY_CONF, null);

        Set<String> keys = redisUtil.keys(pattern);

        if (null == keys || keys.isEmpty()) return null;

        QuantityConf conf;
        for (String key : keys) {
            conf = (QuantityConf) redisUtil.get(key);
            if (null == conf) continue;

            if (conf.getCompanyId().equals(companyId) && conf.getDepotId().equals(depotId)) return conf;
        }

        return null;
    }

    @Override
    public List<QuantityConf> getCacheQuantityConf(String companyId) {

        String pattern = RedisConst.buildKeyByPrefix(RedisConst.KEY_QUANTITY_CONF, null);

        Set<String> keys = redisUtil.keys(pattern);

        if (null == keys || keys.isEmpty()) return null;

        List<QuantityConf> list = new ArrayList<>();
        QuantityConf conf;
        for (String key : keys) {
            conf = (QuantityConf) redisUtil.get(key);
            if (null == conf) {
                continue;
            }
            list.add(conf);
        }
        if (list.isEmpty()) {
            return null;
        }
        return list;
    }

    @Override
    public QuantityConf getCacheQuantityConfBySn(String sn) {

        String key = RedisConst.buildKeyByPrefix(RedisConst.KEY_QUANTITY_CONF, sn);

        return (QuantityConf) redisUtil.get(key);
    }

    @Override
    public void updateQuantityConfBySn(QuantityConf conf) {
        // 更新数据库
        quantityMapper.updateQuantityConfBySn(conf);

        setCacheQuantityConf(conf);
    }

    @Override
    public List<QuantityData> getQuantityData(QuantityParam param) {
        return quantityMapper.getQuantityData(param);
    }

    @Override
    public List<QuantityData> getDataByLimit(QuantityParam param) {
        return quantityMapper.getDataByLimit(param);
    }
}