package com.ld.igds.io.notify.impl;

import com.ld.igds.constant.BizType;
import com.ld.igds.constant.RedisConst;
import com.ld.igds.inout.dto.InoutApiData;
import com.ld.igds.io.notify.NotifyLprService;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.RedisUtil;
import com.ld.igds.websocket.WebSocketPacket;
import com.ld.igds.websocket.WebSocketServer;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

@Slf4j
@Repository(NotifyLprService.BEAN_ID)
public class NotifyLprServiceImpl implements NotifyLprService {

	@Autowired
	private WebSocketServer socketServer;
	@Autowired
	private RedisUtil redisUtil;

	public static  final String KEY_LPR = "T_LPR";

	@SuppressWarnings("static-access")
	@Override
	public void notify(InoutApiData plate) {
		if (null == plate) return;
		WebSocketPacket packet = new WebSocketPacket();
		packet.setCompanyId(ContextUtil.getDefaultCompanyId());
		packet.setBizType(BizType.INOUT_IN.getCode());
		packet.setBizTag(plate.getInoutProgress());
		packet.setUserId(plate.getUserId());
		packet.setBizId("PLATE_NUM");
		
		packet.setData(plate);
		
		log.debug("向前端推送车牌信息={}", plate.toString());
		socketServer.sendByUser(packet);
	}



	@Override
	public InoutApiData getLpr(String key) {
		key = RedisConst.buildKey(ContextUtil.getDefaultCompanyId(),KEY_LPR,key);
		InoutApiData lprDto = (InoutApiData) redisUtil.get(key);
		if(null == lprDto) return null;
		return lprDto;
	}

	@Override
	public void remove(String key) {
		key = RedisConst.buildKey(ContextUtil.getDefaultCompanyId(),KEY_LPR,key);
		redisUtil.del(key);
	}

	@Override
	public void setLpr(String sn, InoutApiData lprDto) {
		String key = RedisConst.buildKey(ContextUtil.getDefaultCompanyId(),KEY_LPR,sn);
		redisUtil.set(key,lprDto, 60 * 60);
	}

}