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

import java.util.List;
import com.ld.igds.check.service.CoreCheckStandardService;
import com.ld.igds.constant.BizType;
import com.ld.igds.inout.InoutConstant;
import com.ld.igds.check.dto.CheckItemData;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.notify.NotifyCheckMacService;
import com.ld.igds.io.response.ProtocolResponse;
import com.ld.igds.io.sample.data.SampleDto;
import com.ld.igds.m.service.InoutCommonService;
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.Component;

@Slf4j
@Component(NotifyCheckMacService.BEAN_ID)
public class NotifyCheckMacServiceImpl implements NotifyCheckMacService {

	@Autowired
	private InoutCommonService inoutManagerService;
	@Autowired
	private CoreCheckStandardService checkStandardService;

	@Override
	public void notify(ProtocolResponse<SampleDto> response) {
		log.info("扦样机暂无通知信息！！");
	}

	@Override
	public void notifyCheckResult(ProtocolResponse<List<CheckItemData>> response) {
		if (OrderRespEnum.MSG_SUCCESS.getCode().equals(response.getCode())) {
			try {
				int i = 0;
				for (CheckItemData checkItemData : response.getData()) {
					i = checkStandardService.updateCheckItemByResult(checkItemData);

					notifyToWeb(checkItemData, i);

					Thread.sleep(300);
				}
			} catch (InterruptedException e) {
				log.error("后台推送出现异常，信息={}", e.getMessage());
			}
		}
		log.debug("化验结果信息推送到服务器={}", response.toString());
	}

	/**
	 * 向前端推送结果信息
	 *
	 * @param checkItemData
	 */
	private void notifyToWeb(CheckItemData checkItemData, int result) {
		if (null == checkItemData.getRemarks()) {
			return;
		}
		// 开始推送
		WebSocketPacket packet = new WebSocketPacket();
		packet.setBizId("IN_CHECK");
		packet.setCompanyId(checkItemData.getCompanyId());
		packet.setBizType(BizType.INOUT_IN.getCode());
		packet.setBizTag(InoutConstant.PROGRESS_CHECK);
		packet.setData("【化验通知】单据号：" + checkItemData.getCheckId() + "\n 项目："
				+ checkItemData.getStandardName() + "\n 值："
				+ checkItemData.getValue() + "\n 结果："
				+ checkItemData.getRemarks());
		WebSocketServer.sendByBizTag(packet);
	}

	@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);
	}
}