修改

huimv-eartag2-eartag/src/main/java/com/huimv/eartag2/eartag/config/RestTemplateConfig.java

@@ -43,9 +43,9 @@ public class RestTemplateConfig {
                 .build();
         PoolingHttpClientConnectionManager poolingHttpClientConnectionManager = new PoolingHttpClientConnectionManager(registry);
         //最大连接数
-        poolingHttpClientConnectionManager.setMaxTotal(200);
+        poolingHttpClientConnectionManager.setMaxTotal(1000);
         //最大路由数
-        poolingHttpClientConnectionManager.setDefaultMaxPerRoute(100);
+        poolingHttpClientConnectionManager.setDefaultMaxPerRoute(1000);
         //定义不活动的时间
         poolingHttpClientConnectionManager.setValidateAfterInactivity(2000);
         RequestConfig requestConfig = RequestConfig.custom()

huimv-eartag2-eartag/src/main/java/com/huimv/eartag2/eartag/listener/EartagListener.java

@@ -177,6 +177,7 @@ public class EartagListener {
                 return;
             }
             dataJo.put("farmId",farmId);
+
             //计算小时运动量
             rabbitTemplate.convertAndSend(Const.EXCHANGE_COUNT_ACT_HOUR,Const.ROUTING_KEY_COUNT_ACT_HOUR,dataJo);
 
@@ -207,9 +208,9 @@ public class EartagListener {
             //判断该设备编号是否存在牧场缓存在线集合当中
             rabbitTemplate.convertAndSend(Const.EXCHANGE_AllSTATUS,Const.ROUTING_KEY_AllSTATUS,dataJo);
 
-
+//            eartagService.handleEartag(dataJo);
         }
-//        eartagService.handleEartag(dataJo);
+
     }
 
 

huimv-eartag2-eartag/src/main/java/com/huimv/eartag2/eartag/service/impl/EartagServiceImpl.java

@@ -125,7 +125,7 @@ public class EartagServiceImpl implements IEartagService {
 //            countHourAct(dataJo);
 
             //{保存耳标流水(所有耳标数据，可能重复上传)}
-//            saveEartagFlow(dataJo, nowTimestamp, todayDate, farmId);
+            saveEartagFlow(dataJo);
 
             //{保存耳标流水，过滤设定时间范围重复耳标上传数据}
 //            saveEartagFlow2(dataJo, nowTimestamp, todayDate, farmId);