package com.qianwen.mdc.collect.service;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.mdc.collect.entity.mgr.WorkstationDatapoints;
import com.qianwen.mdc.collect.mapper.mgr.WorkstationDatapointsMapper;
import com.qianwen.mdc.collect.vo.WorkstationDatapointsVO;
/**
 * 工位数据点服务，主要用于获取数据点定义。定义在smartman应用
 */
@Service
public class WorkstationDatapointsService extends BaseServiceImpl<WorkstationDatapointsMapper, WorkstationDatapoints> {
	private Logger log = LoggerFactory.getLogger(this.getClass());
	
	
	/**
	 * 获取工位数据点配置 ,从缓存
	 * @param workstationId
	 * @return
	 */
	@Cacheable(value = "collect:datapoint" ,key = "#appId")
	public WorkstationDatapointsVO getDatapointsByAppIdFromCache(String appId) {
		return this.getDataPointByAppId(appId);
	}
	
	/*
	@CachePut(value = "collect:datapoint" ,key = "#appId")
	public WorkstationDatapointsVO datapointsCachePut(String appId) {
		return this.getDataPointByAppId(appId);
	}
	*/
	
	@CacheEvict(value = "collect:datapoint" ,key = "#appId")
	public void datapointsCacheEvict(String appId) {
		
	}
	/**
	 * 从数据库查询数据点定义
	 * @param workstationId 工位id
	 * @return
	 */
	WorkstationDatapointsVO getDataPointByAppId(String appId) {
		log.info("appid={}", appId);
		WorkstationDatapoints dp = baseMapper.selectOne(Wrappers.<WorkstationDatapoints>lambdaQuery()
				.eq(WorkstationDatapoints::getAppId, appId));

		log.info("dp={}", dp);

		WorkstationDatapointsVO dpVO = null;

		if (dp != null) {
			dpVO = new WorkstationDatapointsVO(dp.getWorkstationId(), dp.getAppId(), dp.getDpConfig());
		}
		return dpVO;
	}

}