|
@@ -1,7 +1,5 @@
|
|
|
package com.caimei365.tools.listener;
|
|
|
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
-import com.alibaba.fastjson.TypeReference;
|
|
|
import com.caimei365.tools.model.po.IpSavePo;
|
|
|
import com.caimei365.tools.service.impl.IpSaveService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
@@ -11,19 +9,12 @@ import org.apache.rocketmq.spring.core.RocketMQListener;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
-import java.applet.Applet;
|
|
|
import java.io.UnsupportedEncodingException;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.Date;
|
|
|
-import java.util.HashMap;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.stream.Stream;
|
|
|
|
|
|
/**
|
|
|
- * 测试消息监听
|
|
|
- *
|
|
|
- * @author : Charles
|
|
|
- * @date : 2021/6/17
|
|
|
+ * @author Administrator
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@Component
|
|
@@ -92,9 +83,10 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
if (StringUtils.isNotBlank(ip)) {
|
|
|
ipSavePo.setIp(ip);
|
|
|
}
|
|
|
- SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss");
|
|
|
String nowDate = format.format(new Date());
|
|
|
- ipSavePo.setSaveTime(nowDate);
|
|
|
+ Long aLong = Long.valueOf(nowDate);
|
|
|
+ ipSavePo.setSaveTime(aLong);
|
|
|
ipSaveService.save(ipSavePo);
|
|
|
}
|
|
|
}
|