package com.qxueyou.scc.school.service.impl;

import javax.annotation.PostConstruct;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.base.service.IONSExceptionLogService;
//import com.qxueyou.scc.base.service.IONSMsgDealService;
//import com.qxueyou.scc.base.service.impl.CommonONSConsumer;
//import com.qxueyou.scc.base.util.UUIDUtils;
import com.qxueyou.scc.school.service.ISignService;

/**
 * 签到异步相关消息
 * 
 * @author ody.yuan
 *
 */
@Service("SchSignMsgDealService")
public class SchSignMsgDealService{
//public class SchSignMsgDealService implements IONSMsgDealService {

	@Autowired
	ISignService signService;

	@Autowired
	IONSExceptionLogService onsExceptionLogService;



	@SuppressWarnings("unused")
	private static Logger log = LogManager.getLogger("ONSExceptionLogService");

	@PostConstruct
	void init() {

//		CommonONSConsumer.registerHandler("SCH_SIGN_QUEUE", "SchSignMsgDealService");

	}

//	@Override
//	public void doHandle(Message msg, ConsumeContext context) {
//		
//		// 严格异常处理
//		try {
//			
//			String args = msg.getUserProperties("args");
//
//			signService.doHandleSignQueueMsg(args);
//
//
//		} catch (Exception e) {
//
//			String businessId = cfg.getConfigByEnv("ons-common-topic") + "-" + UUIDUtils.generateUUID();
//			String desp = "userId:" + msg.getUserProperties("userId") + ";userName:" + msg.getUserProperties("userName") + ";mobilePhone:" + msg.getUserProperties("mobilePhone") + ";appId:" + msg.getUserProperties("appId") + ";openId:" + msg.getUserProperties("openId");
//
//			log.error(businessId + " :签到学员处理失败:" + e, e);
//			onsExceptionLogService.logSaveExceptionLog(cfg.getConfigByEnv("ons-common-topic"), "SCH_SIGN_QUEUE", businessId, desp);
//		}
//
//	}

}