package com.xzx.gc.common.utils;
|
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import cn.hutool.core.util.ReflectUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.google.common.base.CaseFormat;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.constant.MqConstants;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.amqp.core.AmqpTemplate;
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.core.MessageBuilder;
|
import org.springframework.amqp.core.MessageProperties;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
|
@Component
|
@Slf4j
|
public class MqUtil {
|
|
@Autowired
|
private AmqpTemplate amqpTemplate;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
private IdUtils idUtils;
|
|
/**
|
* 发送队列
|
* @param queueName
|
* @param t 队列KEY
|
* @param <T> 对象
|
*/
|
@Async
|
public <T> void send(String queueName,T t) {
|
if(t!=null&&!SpringUtil.isCloud()){
|
ReflectUtil.setFieldValue(t,"id",idUtils.generate( CaseFormat.LOWER_UNDERSCORE.to(CaseFormat.LOWER_CAMEL, queueName),0));
|
ReflectUtil.setFieldValue(t,"createTime",DateUtil.now());
|
ReflectUtil.setFieldValue(t,"queueName",queueName);
|
String s = JSONUtil.toJsonStr(t);
|
String uuid = IdUtil.fastSimpleUUID()+RandomUtil.randomNumbers(16);
|
Message message = MessageBuilder.withBody(s.getBytes())
|
.setContentType(MessageProperties.CONTENT_TYPE_JSON).setContentEncoding("utf-8")
|
.setMessageId(uuid).build();
|
try {
|
amqpTemplate.convertAndSend(queueName, message);
|
} catch (Exception e) {
|
redisUtil.rpush(Constants.REDIS_LOG_KEY + "errQueue", s);
|
e.printStackTrace();
|
}
|
|
}
|
}
|
|
|
/**
|
* 发送操作账户日志
|
* @param operationAppLog
|
*/
|
@Async
|
public void sendApp(OperationAppLog operationAppLog){
|
operationAppLog.setCreateTime(new Date());
|
send(MqConstants.OPERATION_APP_LOG_QUEUE, operationAppLog);
|
}
|
|
|
|
|
|
}
|
