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

import com.ld.igds.m.service.InoutCommonService;
import lombok.extern.slf4j.Slf4j;

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

import com.ld.igds.constant.BizType;
import com.ld.igds.inout.InoutConstant;
import com.ld.igds.io.dto.WeightDto;
import com.ld.igds.io.notify.NotifyWeightService;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.websocket.WebSocketPacket;
import com.ld.igds.websocket.WebSocketServer;

/**
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2020年3月13日
 */
@Slf4j
@Component(NotifyWeightService.BEAN_ID)
public class NotifyWeightServiceImpl implements NotifyWeightService {

	@Autowired
	private WebSocketServer socketServer;
	@Autowired
	private InoutCommonService inoutManagerService;

	@SuppressWarnings("static-access")
	@Override
	public void notify(WeightDto response) {
		
		if(null == response.getCompanyId()){
			response.setCompanyId(ContextUtil.getDefaultCompanyId());
		}
		WebSocketPacket packet = new WebSocketPacket();
		packet.setBizTag(InoutConstant.PROGRESS_WEIGHT_TAG);
		packet.setBizType(response.getBizType());
		packet.setCompanyId(response.getCompanyId());
		packet.setBizId("WEIGH");

		packet.setData(response);
		
		//通知入库
		packet.setBizType(BizType.INOUT_IN.getCode());
		socketServer.sendByBizTag(packet);
		
		//通知出庫
		packet.setBizType(BizType.INOUT_OUT.getCode());
		socketServer.sendByBizTag(packet);
		
		log.debug("向前端发送地磅信息={}", packet.toString());
	}

	@Override
	public void onCreate(String address, Integer port) {
		inoutManagerService.updateInoutConfStatus(address, port,
				InoutConstant.MAC_STATUS_NORMAL);
	}

	@Override
	public void onDestroy(String address, Integer port) {
		inoutManagerService.updateInoutConfStatus(address, port,
				InoutConstant.MAC_STATUS_NO_SIGNAL);
	}

}