package com.fzzy.igds.grain.service;

import com.fzzy.igds.dzhwk.constant.RedisConst;
import com.fzzy.igds.grain.dto.GrainData;
import com.fzzy.igds.grain.dto.GrainParam;
import com.fzzy.igds.grain.mapper.GrainServiceMapper;
import com.ruoyi.common.core.redis.RedisCache;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;

/**
 * @Description 粮情模块核心接口
 * @Author CZT
 * @Date 2024/12/02 15:33
 */
@Slf4j
@Service("dzhwk.grainService")
public class GrainService {

    @Resource
    private RedisCache redisCache;
    @Resource
    private GrainServiceMapper grainServiceMapper;


    /**
     * 获取缓存中最新的粮情检测数据
     *
     * @param companyId
     * @return key=参考编码
     */
    public GrainData getCacheGrainDate(String companyId, String depotId) {
        if (null == companyId || null == depotId) {
            return null;
        }

        String key = RedisConst.buildKey(companyId, RedisConst.KEY_GRAIN, depotId);

        GrainData grainData = redisCache.getCacheObject(key);

        if (null == grainData) {
            GrainParam param = new GrainParam();;
            param.setCompanyId(companyId);
            param.setDepotId(depotId);
            List<GrainData> list = grainServiceMapper.getGrainData(param);
            if (list != null && !list.isEmpty()) {
                grainData = list.get(0);
                redisCache.setCacheObject(key, grainData);
            }
        }

        return grainData;
    }



}