package com.qxueyou.scc.school.service.impl;
|
|
import java.net.Inet4Address;
|
import java.net.InetAddress;
|
import java.net.NetworkInterface;
|
import java.util.Enumeration;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
import org.springframework.stereotype.Service;
|
|
import com.qxueyou.scc.base.service.IONSExceptionLogService;
|
import com.qxueyou.scc.config.AliOnsConfig;
|
import com.qxueyou.scc.school.service.IHandoutService;
|
|
/**
|
* 文档处理消息队列接收服务
|
*
|
* @author 德虎
|
*
|
*/
|
@Service("DocdealMsgDealService")
|
@EnableConfigurationProperties(AliOnsConfig.class)
|
public class DocdealMsgDealService{
|
//public class DocdealMsgDealService extends ONSBaseMsgConsumer implements IONSMsgDealService {
|
|
@Autowired
|
AliOnsConfig aliOnsConfig;
|
|
@Autowired
|
IHandoutService handoutService;
|
|
@Autowired
|
IONSExceptionLogService onsExceptionLogService;
|
|
@SuppressWarnings("unused")
|
private static Logger log = LogManager.getLogger("ONSExceptionLogService");
|
|
|
// @Override
|
// public void doHandle(Message msg, ConsumeContext context) {
|
//
|
// //TODO 严格异常处理，两次就直接返回,暂时一次
|
// try {
|
// // get params
|
// String docPath = msg.getUserProperties("docPath");
|
// String handoutId = msg.getUserProperties("handoutId");
|
// String uploadModule = msg.getUserProperties("uploadModule");
|
// String userId = msg.getUserProperties("userId");
|
//
|
// // parse office file(ppt\pptx)
|
//
|
// handoutService.insertHandoutPages(docPath, handoutId,uploadModule,userId,"PPT");
|
//
|
// }catch(Exception e){
|
//
|
// String businessId = getTopic() + "-" + UUIDUtils.generateUUID();
|
// String desp = "handoutId:" + msg.getUserProperties("handoutId")+
|
// ";docPath:" + msg.getUserProperties("docPath") +
|
// ";userId:" + msg.getUserProperties("userId") +
|
// ";uploadModule:" + msg.getUserProperties("uploadModule") ;
|
//
|
// log.error( businessId + " :上传讲义ppt消息发送失败:" + e , e);
|
// onsExceptionLogService.logSaveExceptionLog(getTopic(), "", businessId , desp );
|
// }
|
//
|
// }
|
//
|
/**
|
* 配置项ons-docdeal-receive-urls配置了多个ip地址，如果其中包含本机地址，说明支持文档处理
|
*/
|
protected boolean turnOn(){
|
String docdealUrls =aliOnsConfig.getDocdealReceiveUrls();
|
try {
|
Enumeration<NetworkInterface> nienum = NetworkInterface.getNetworkInterfaces();
|
while (nienum.hasMoreElements()) {
|
NetworkInterface ni = nienum.nextElement();
|
Enumeration<InetAddress> iaenum = ni.getInetAddresses();
|
while (iaenum.hasMoreElements()) {
|
InetAddress ia = iaenum.nextElement();
|
if (ia instanceof Inet4Address&&docdealUrls.contains("#" + ia.getHostAddress() + "#")) {
|
return true;
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return false;
|
}
|
|
// @Override
|
// protected String getConsumerId() {
|
// return cfg.getConfigByEnv("ons-docdeal-customer-id");
|
// }
|
//
|
// @Override
|
// protected String getTopic() {
|
// return cfg.getConfigByEnv("ons-docdeal-topic");
|
// }
|
|
}
|
