添加了一个测试类.patch 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226
  1. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/ReceivePackageSerivce.java
  2. IDEA additional info:
  3. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  4. <+>UTF-8
  5. ===================================================================
  6. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/ReceivePackageSerivce.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  7. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/ReceivePackageSerivce.java (date 1646122535364)
  8. @@ -126,14 +126,13 @@
  9. if(findeartagRegisterEntity == null){
  10. - System.out.println("没有手动登记的耳标号 请手动注册登记"+eartag_no);
  11. RawDataEntity rawDataEntity = new RawDataEntity();
  12. rawDataEntity.setDetailData(rawdata+"没有手动登记");
  13. rawDataEntity.setStatus(0);
  14. rawDataEntity.setCreateTime(new Date());
  15. rawDataService.save(rawDataEntity);
  16. //耳标号没有注册 直接返回
  17. - /* EartagRegisterEntity eartagRegisterEntity = new EartagRegisterEntity();
  18. + EartagRegisterEntity eartagRegisterEntity = new EartagRegisterEntity();
  19. eartagRegisterEntity.setAge(0);
  20. eartagRegisterEntity.setDeviceCode(device_code);//给绑定的设备编码死否会改变
  21. eartagRegisterEntity.setEartagNo(eartag_no);
  22. @@ -144,7 +143,7 @@
  23. eartagRegisterEntity.setStage(collectorRegisterEntity.getStage());
  24. eartagRegisterEntity.setStage(collectorRegisterEntity.getUnitId());
  25. eartagRegisterService.save(eartagRegisterEntity);//存储一条还没有处理的数据*/
  26. - return null;
  27. + return null ;
  28. }
  29. Double a = Double.parseDouble(env_temp)/100-Double.parseDouble(df.format(ln(Integer.parseInt(split[2]))));
  30. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/SendPackageService.java
  31. IDEA additional info:
  32. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  33. <+>UTF-8
  34. ===================================================================
  35. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/SendPackageService.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  36. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/service/impl/SendPackageService.java (date 1646188688940)
  37. @@ -24,6 +24,8 @@
  38. **/
  39. @Component
  40. public class SendPackageService {
  41. +
  42. +
  43. @Autowired
  44. private CollectorRegisterDao collectorRegisterDao;
  45. @@ -31,6 +33,7 @@
  46. private HeartBeatRecordService heartBeatRecordService;
  47. +
  48. /**
  49. * @Method : _handleGetDeviceId
  50. * @Description : 获取设备id
  51. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/HuimvSmartEartagDataAcquisitionApplication.java
  52. IDEA additional info:
  53. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  54. <+>UTF-8
  55. ===================================================================
  56. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/HuimvSmartEartagDataAcquisitionApplication.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  57. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/HuimvSmartEartagDataAcquisitionApplication.java (date 1646188688929)
  58. @@ -17,7 +17,7 @@
  59. //这是新项目深度优化版本,可以深度修改,改完了记得上传
  60. //只充当存储数据的服务是没有任何问题的----已经复原之前的功能仅仅
  61. @EnableScheduling
  62. -//排除掉 security
  63. +//排除掉 security--不然接口会一直报错
  64. @SpringBootApplication(exclude = {org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class})
  65. public class HuimvSmartEartagDataAcquisitionApplication {
  66. public static void main(String[] args) throws InterruptedException {
  67. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/controller/EartagDataController.java
  68. IDEA additional info:
  69. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  70. <+>UTF-8
  71. ===================================================================
  72. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/controller/EartagDataController.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  73. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/controller/EartagDataController.java (date 1646098189828)
  74. @@ -88,7 +88,7 @@
  75. /**
  76. - * 列表 耳标个体数据----电大展示专用
  77. + * 列表 耳标个体数据----杭电展示专用--耳标写死了的
  78. */
  79. @RequestMapping("/listEartagDeatils")
  80. public R listEartagDeatils( @RequestBody EartagParamVo eartagParamVo) throws ParseException {
  81. Index: cloud-platform-acquisition/src/main/resources/application-dev.yml
  82. IDEA additional info:
  83. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  84. <+>UTF-8
  85. ===================================================================
  86. --- cloud-platform-acquisition/src/main/resources/application-dev.yml (revision ad2aa865790715476d6de77dca02190fce53450a)
  87. +++ cloud-platform-acquisition/src/main/resources/application-dev.yml (date 1646187762065)
  88. @@ -2,7 +2,7 @@
  89. port: 9502
  90. spring:
  91. datasource:
  92. - url: jdbc:mysql://122.112.224.199:3306/huimv-eartag-show?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
  93. + url: jdbc:mysql://122.112.224.199:3306/huimv-eartag-cloud-test1?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
  94. username: root
  95. password: hm123456
  96. driver-class-name: com.mysql.cj.jdbc.Driver
  97. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/service/impl/EartagDataServiceImpl.java
  98. IDEA additional info:
  99. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  100. <+>UTF-8
  101. ===================================================================
  102. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/service/impl/EartagDataServiceImpl.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  103. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/service/impl/EartagDataServiceImpl.java (date 1646113777807)
  104. @@ -42,14 +42,14 @@
  105. @Autowired
  106. private BasePigpenDao basePigpenDao;
  107. -
  108. @Autowired
  109. private CollectorRegisterDao collectorRegisterDao ;
  110. -
  111. @Autowired
  112. private MovePigpenDao movePigpenDao;
  113. +
  114. + //这个接口写的太辣鸡了
  115. @Override
  116. public PageUtils findByConditions(Map<String, Object> params) throws ParseException {
  117. @@ -151,8 +151,6 @@
  118. }
  119. -
  120. -
  121. @Override
  122. public PageUtils queryPage(Map<String, Object> params) {
  123. IPage<EartagDataEntity> page = this.page(
  124. @@ -162,21 +160,20 @@
  125. return new PageUtils(page);
  126. }
  127. - //迁移接口
  128. - //耳标详细数据
  129. +
  130. + //杭电展示专用接口--耳标号目前写死 部署在35服务器 数据库为 huimv—eartag-show
  131. @Override
  132. public Map queryEartagDeatils(EartagParamVo eartagParamVo) throws ParseException {
  133. String eartagNo1 ="133083123620938";
  134. String eartagNo2 ="133083123623215";
  135. -
  136. LambdaQueryWrapper<EartagDataEntity> wrapper1 = Wrappers.lambdaQuery();
  137. wrapper1.eq(EartagDataEntity::getEartagNo, eartagNo1).orderByDesc(EartagDataEntity::getId);
  138. if(eartagParamVo.getStarTime()!=null){
  139. //传了时间按照时间
  140. wrapper1.between(EartagDataEntity::getTime, eartagParamVo.getStarTime(), eartagParamVo.getEndTime());
  141. }else {
  142. - //没有时间返回最近的1000条
  143. + //没有时间返回最近的500条
  144. wrapper1.last( "limit 50");
  145. }
  146. System.out.println("耳标号="+eartagParamVo.getEartagNo());
  147. @@ -193,10 +190,7 @@
  148. wrapper2.last( "limit 50");
  149. }
  150. List<EartagDataEntity> eartagDataEntities2 = eartagDataDao.selectList(wrapper2);
  151. -
  152. -
  153. -
  154. -
  155. +
  156. Map resultMap = new HashMap();
  157. List<String> timeList = new ArrayList<>();
  158. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServer2.java
  159. IDEA additional info:
  160. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  161. <+>UTF-8
  162. ===================================================================
  163. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServer2.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  164. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServer2.java (date 1646188179540)
  165. @@ -25,9 +25,10 @@
  166. public class EartagServer2 {
  167. @Autowired
  168. private EartagServerHandler2 serverHandler;
  169. - //外面的版本 金华的端口 10024 10025 部署在31 服务器上面好了
  170. + //外面的版本 金华的端口 10024 10025 部署在31 服务器上面好了 10023是test1平台的
  171. //创建构造方法
  172. - private int port = 10025;
  173. +
  174. + private int port = 10023;
  175. public EartagServer2(){
  176. }
  177. Index: cloud-platform-acquisition/pom.xml
  178. IDEA additional info:
  179. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  180. <+>UTF-8
  181. ===================================================================
  182. --- cloud-platform-acquisition/pom.xml (revision ad2aa865790715476d6de77dca02190fce53450a)
  183. +++ cloud-platform-acquisition/pom.xml (date 1646122330753)
  184. @@ -146,5 +146,4 @@
  185. -
  186. </project>
  187. \ No newline at end of file
  188. Index: cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServerHandler2.java
  189. IDEA additional info:
  190. Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
  191. <+>UTF-8
  192. ===================================================================
  193. --- cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServerHandler2.java (revision ad2aa865790715476d6de77dca02190fce53450a)
  194. +++ cloud-platform-acquisition/src/main/java/com/huimv/acquisition/socket/eartagrecive/eartagsocket/EartagServerHandler2.java (date 1646116041508)
  195. @@ -46,10 +46,8 @@
  196. public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
  197. ByteBuf data = (ByteBuf) msg;
  198. String clientAsk = data.toString(CharsetUtil.UTF_8);
  199. -
  200. -
  201. /* 处理客户端请求数据 */
  202. String answer = iClientDataPacketService.handleClientSendPacket(clientAsk);
  203. if (answer != null) {