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