package com.qxueyou.scc.school.service.impl;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.stereotype.Service;
|
|
//import com.qxueyou.scc.base.model.ONSMsg;
|
import com.qxueyou.scc.base.model.Result;
|
//import com.qxueyou.scc.base.service.impl.ONSBaseMsgProducer;
|
import com.qxueyou.scc.school.service.IDocdealMsgSenderService;
|
|
/**
|
*
|
* @author 德虎
|
*
|
*/
|
@Service
|
public class DocdealMsgSenderService implements IDocdealMsgSenderService {
|
//public class DocdealMsgSenderService extends ONSBaseMsgProducer implements IDocdealMsgSenderService {
|
|
@SuppressWarnings("unused")
|
private Logger log = LogManager.getLogger("DocdealMsgSenderService");
|
|
/*
|
* (non-Javadoc)
|
* @see com.qxueyou.scc.school.service.IDocdealMsgSenderService#sendMsg(java.lang.String, java.lang.String)
|
*/
|
@Override
|
public Result sendMsg(String docPath, String handoutId,String uploadModule,String userId) {
|
|
// ONSMsg msg = new ONSMsg(getTopic());
|
//
|
// msg.put("msgType", "SCH_DOCDEAL");
|
// msg.put("docPath", docPath);
|
// msg.put("handoutId", handoutId);
|
// msg.put("uploadModule", uploadModule);
|
// msg.put("userId", userId);
|
//
|
// try {
|
//
|
// producer.send(msg.toONSMsg());
|
//
|
// return new Result(true);
|
//
|
// } catch (Exception e) {
|
// log.error("call DocdealMsgSendService fail.docPath: "+ docPath + " ;handoutId= " + handoutId,e);
|
// }
|
//
|
return new Result(false);
|
}
|
|
// @Override
|
// protected String getProducerId() {
|
// return cfg.getConfigByEnv("ons-docdeal-producer-id");
|
// }
|
//
|
// @Override
|
// protected String getTopic() {
|
// return cfg.getConfigByEnv("ons-docdeal-topic");
|
// }
|
}
|
