jsonUtil
public class JsonUtil
{
// 定义jackson对象
private static final ObjectMapper MAPPER = new ObjectMapper();
/**
* 将对象转换成json字符串。
* <p>Title: pojoToJson</p>
* <p>Description: </p>
* @param data
* @return
*/
public static String objectToJson(Object data) {
try {
String string = MAPPER.writeValueAsString(data);
return string;
} catch (JsonProcessingException e) {
e.printStackTrace();
}
return null;
}
/**
* 将json结果集转化为对象
*
* @param jsonData json数据
* @param clazz 对象中的object类型
* @return
*/
public static <T> T jsonToPojo(String jsonData, Class<T> beanType) {
try {
T t = MAPPER.readValue(jsonData, beanType);
return t;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 将json数据转换成pojo对象list
* <p>Title: jsonToList</p>
* <p>Description: </p>
* @param jsonData
* @param beanType
* @return
*/
public static <T>List<T> jsonToList(String jsonData, Class<T> beanType) {
JavaType javaType = MAPPER.getTypeFactory().constructParametricType(List.class, beanType);
try {
List<T> list = MAPPER.readValue(jsonData, javaType);
return list;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}
利用redis自增
@Service
public class SerialNumGeneration
{
@Autowired
protected DefaultRedisClient redisClient;
//生成订单号
public String createOrderNumber(String orderCode) {
Date date = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
String todayTime = sdf.format(date);
String key = orderCode + todayTime.substring(4);
if (redisClient.get(key) == null) {
redisClient.setEx(key, String.format("%04d", 1), 24 * 60 * 60);
return key + String.format("%04d", 1);
}
Object num = redisClient.get(key);
int value = Integer.valueOf(num.toString()) + 1;
if (value == 10000) {
value = 1;
}
redisClient.set(key, String.format("%04d", value));
return key + String.format("%04d", value);
}
}
时间多加一天
//endTime 多加一天
if(storeOutBillReturnDTO.getEndTime() !=null){
Calendar c = Calendar.getInstance();
c.setTime(storeOutBillReturnDTO.getEndTime());
c.add(Calendar.DAY_OF_MONTH, 1);
storeOutBillReturnDTO.setEndTime(c.getTime());
}
rabbitMq一些配置
public class AmqpProviderConfig {
// 交换机名称
public static final String EXCHANGE = "mj-invengo-factory-exchange";
// 路由关键字
public static final String ROUTINGKEY = "mj-invengo-factory-routingKey";
private static RabbitTemplate rabbitTemplate = null;;
/**
* 连接工厂
*
* @return
*/
public static ConnectionFactory connectionFactory() {
CachingConnectionFactory factory = new CachingConnectionFactory();
String address = ReadProperties.get("RABBITMQ_ADDRESS");
factory.setAddresses(address);
factory.setUsername("root");
factory.setPassword("root");
factory.setVirtualHost("/");
factory.setPublisherConfirms(true);
return factory;
}
/**
* 获取template模板
*
* @return
*/
public static RabbitTemplate providerRabbitTemplate() {
if (rabbitTemplate == null) {
rabbitTemplate = new RabbitTemplate(connectionFactory());
rabbitTemplate.setExchange(EXCHANGE);
return rabbitTemplate;
}
return rabbitTemplate;
}
}
@Configuration
public class AmqpConsumerConfig {
@Autowired
private MqMessageListener mqMessageListener;
@Autowired
private InnerMqMessageListener innerMqMessageListener;
// 交换机名称
public static final String EXCHANGE = "mj-lead-factory-exchange";
// 路由关键字
public static final String ROUTINGKEY = "mj-lead-factory-routingKey";
// 门店工厂交换机名称
public static final String INNEREXCHANGE = "mj-invengo-sf-exchange";
//门店工厂路由关键字
public static final String INNERROUTINGKEY = "mj-invengo-sf-routingKey";
@Bean
public DirectExchange defaultExchange() {
return new DirectExchange(EXCHANGE);
}
@Bean
public Queue queue() {
return new Queue("mj-lead-factory-queue", true);
}
@Bean
public Binding binding() {
return BindingBuilder.bind(queue()).to(defaultExchange()).with(ROUTINGKEY);
}
/**
* 消息监听
*
* @return
*/
@Bean
public SimpleMessageListenerContainer messageContainer() {
if( ReadProperties.get("OUTER_LISTENER").equals("false"))
return null;
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(mqConnectionFactory());
container.setQueues(queue());
container.setExposeListenerChannel(true);
container.setMaxConcurrentConsumers(1);
container.setConcurrentConsumers(1);
container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
// 设计消息监听
container.setMessageListener(this.mqMessageListener);
return container;
}
/**
* 连接工厂
*
* @return
*/
@Bean
public ConnectionFactory mqConnectionFactory() {
CachingConnectionFactory factory = new CachingConnectionFactory();
String address = ReadProperties.get("RABBITMQ_ADDRESS");
factory.setAddresses(address);
factory.setUsername("invengo");
factory.setPassword("invengMQrfid.");
factory.setVirtualHost("/");
factory.setPublisherConfirms(true);
return factory;
}
/*
* *门店工厂监听器
*/
@Bean
public SimpleMessageListenerContainer InnerMessageContainer() {
if( ReadProperties.get("INNER_LISTENER").equals("false"))
return null;
SimpleMessageListenerContainer container = new
SimpleMessageListenerContainer(mqConnectionFactory());
container.setQueues(innerQueue());
container.setExposeListenerChannel(true);
container.setMaxConcurrentConsumers(1);
container.setConcurrentConsumers(1);
container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
// 设计消息监听
container.setMessageListener(this.innerMqMessageListener);
return container;
}
@Bean
public DirectExchange innerExchange() {
return new DirectExchange(INNEREXCHANGE);
}
@Bean
public Queue innerQueue() {
return new Queue("mj-invengo-sf-queue", true);
}
@Bean
public Binding innnerBinding() {
return BindingBuilder.bind(innerQueue()).to(innerExchange()).with(INNERROUTINGKEY);
}
}
@Component
public class MqMessageListener implements ChannelAwareMessageListener {
private static final Logger logger = LoggerFactory.getLogger(MqMessageListener.class);
@Autowired
private CheckFactoryOrderExService checkFactoryOrderExService;
@Override
public void onMessage(Message message, Channel channel) throws Exception {
// TODO Auto-generated method stub
byte[] body = message.getBody();
try
{
JSONObject messageObject = JSONObject.parseObject(new String(body));
String type = messageObject.getString("type");
String data = messageObject.getString("data");
logger.warn("**********来源信息**********:" + messageObject.toJSONString());
if (!StringUtils.isEmpty(type) && BillType.SCType.containsKey(type) && !StringUtils.isEmpty(data)) {
if (Objects.equals("9", type)) {
OrderInfoDTOSC orderInfoDTOSC = JSON.parseObject(messageObject.toJSONString(),
OrderInfoDTOSC.class);
logger.info("***************调条SC接口发过来的信息为：**********"+JsonUtilsLJ.objectToJson(orderInfoDTOSC));
OrderInfoDTOSCDetial orderInfoDTOSCDetial = orderInfoDTOSC.getData();
checkFactoryOrderExService.saveOrderInfoFromSC(orderInfoDTOSCDetial);
}
// 确认消息成功消费
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
System.err.println("message data:" + new String(body));
}else{
// 不需要重试的消息
logger.error("Mq message ERROR DATA > " + messageObject);
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
}
}
catch (Exception e)
{
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
logger.error("Mq message Listener error > ", e);
}
}
}
/**
* 发送mq类
*
* @author
*
*/
@Component
public class RabbitMqSend implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback {
private static final Logger log = LoggerFactory.getLogger(RabbitMqSend.class);
/**
* 发送方法
*
* @param msg
* @throws Exception
*/
public void sendMsg(String msg) throws Exception {
log.warn("***********消息中间件发送的消息*************：" + msg);
CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
AmqpProviderConfig.providerRabbitTemplate().setConfirmCallback(this);
AmqpProviderConfig.providerRabbitTemplate().setReturnCallback(this);
AmqpProviderConfig.providerRabbitTemplate().convertAndSend(AmqpProviderConfig.EXCHANGE,
AmqpProviderConfig.ROUTINGKEY, msg, correlationData);
}
/**
* 将消息发送到mq server
*/
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
// TODO Auto-generated method stub
log.debug("send id:" + correlationData.getId());
if (ack) {// 调用成功
log.warn(correlationData.getId() + ":" + "发送成功.");
} else {
log.warn(correlationData.getId() + ":" + "发送失败.");
}
}
@Override
public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
// TODO Auto-generated method stub
log.info("{message:" + message + ",replyCode:" + replyCode + ",replyText:" + replyText + ",exchange" + exchange
+ ",routingKey" + routingKey + "}");
}
public static void main(String[] args) throws Exception {
RabbitMqSend send = new RabbitMqSend();
send.sendMsg("123");
TimeUnit.SECONDS.sleep(3);
}
}
