init

pump-admin/src/main/resources/application.yml

@@ -4,7 +4,7 @@ server:
 spring:
   profiles:
     # 使用生产环境
-    active: dev
+    active: prod
   main:
     allow-bean-definition-overriding: true
 mybatis-plus:

pump-admin/src/main/test/com/tuoren/web/Test.java

@@ -1,27 +0,0 @@
-package com.tuoren.web;
-
-import com.tuoren.TuorenApplication;
-import com.tuoren.web.rabbit.RabbitHandle;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-
-/**
- * @ClassName : Test
- * @Description :
- * @Author : LF
- * @Date: 2025年03月12日
- */
-@Slf4j
-@SpringBootTest(classes = TuorenApplication.class)
-public class Test {
-
-    @Autowired
-    private RabbitHandle rabbitHandle;
-    @org.junit.Test
-    public void test() throws Exception {
-        String str="{\\\"pumpCode\\\":\\\"3332343205340147\\\",\\\"patientCode\\\":\\\"999999999\\\",\\\"lastUploadTime\\\":1741744469,\\\"remainQuantity\\\":997.3,\\\"continueQuantity\\\":27.0,\\\"selfControlQuantity\\\":0.0,\\\"lockTime\\\":0,\\\"inputQuantity\\\":1.7,\\\"validTime\\\":0,\\\"invalidTime\\\":0,\\\"maxQuantity\\\":90,\\\"firstQuantity\\\":1,\\\"singleQuantity\\\":0.0,\\\"totalQuantity\\\":999,\\\"totalCount\\\":0,\\\"pulseQuantity\\\":null,\\\"pulseLockTime\\\":null,\\\"firsLockTime\\\":null,\\\"upperLimit\\\":null,\\\"lowerLimit\\\":null,\\\"customScate\\\":null,\\\"addValidTime\\\":null,\\\"addCycle\\\":null,\\\"reduceCycle\\\":null,\\\"runState\\\":4,\\\"bufState1\\\":3,\\\"bufState2\\\":0,\\\"bufState3\\\":0,\\\"bufState4\\\":0,\\\"bufState5\\\":0,\\\"bufState6\\\":53,\\\"bufState7\\\":0,\\\"bufState8\\\":0,\\\"bufState9\\\":0,\\\"score\\\":0,\\\"startTime\\\":1741742073,\\\"isRemove\\\":true,\\\"viewState\\\":\\\"未装药盒\\\",\\\"stateFlag\\\":4,\\\"callFlag\\\":0,\\\"noSignal\\\":null,\\\"remark\\\":\\\"1\\\",\\\"number1\\\":null,\\\"number2\\\":null,\\\"hospitalCode\\\":\\\"b5df38b8cba447afb02f29af8bc71b08\\\",\\\"productCode\\\":\\\"1\\\"}\\n\",\"stream\":\"stdout\",\"time\":\"2025-03-12T01:54:32.539934079Z\"}";
-        rabbitHandle.pumpHandle(str.getBytes());
-
-    }
-}

pump-admin/src/main/test/com/tuoren/web/Test1.java

@@ -0,0 +1,31 @@
+package com.tuoren.web;
+
+import com.tuoren.TuorenApplication;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.Arrays;
+
+/**
+ * @ClassName : Test
+ * @Description :
+ * @Author : LF
+ * @Date: 2025年03月12日
+ */
+@RunWith(SpringRunner.class)
+@Slf4j
+@SpringBootTest(classes = TuorenApplication.class)
+public class Test1 {
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+    @Test
+    public void test() throws Exception {
+        rabbitTemplate.convertAndSend("removePump","123412412", Arrays.asList("12","23","3455"));
+    }
+}

pump-common/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,57 +1,57 @@
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorAutoConfigurationSelector.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\annotation\RateLimit.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\push\Push.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\shiro\ShiroFilter.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterProperties.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\annotation\EnableFlowMonitor.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimitAutoConfigurationSelector.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\DiffTimeUtils.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\api\ResultCode.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\exception\GlobalExceptionHandler.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\MvcConfig.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\annotation\EnableWebShiro.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\WebUtils.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\annotation\Idempotent.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\api\AopOrderEnum.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\ConstastUtils.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimitMethodInterceptor.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\constant\CommonConstant.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\annotation\EnableIdempotent.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentMethodInterceptor.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\Interface\RateLimiter.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\RedisConfig.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorAutoConfiguration.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\push\BasePush.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\annotation\EnableRateLimit.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginAutoConfigurationSelector.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\exception\ApiException.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginMethodInterceptor.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorMethodInterceptor.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\redis\RedisService.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\SSLConfig.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\TokenBucketHandler.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\MybatisPlusConfig.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\shiro\ShiroSessionIdGenerator.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\shiro\ShiroSessionManager.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\api\CommonResult.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\mbg\CodeGenerator.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\enums\LogType.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\LocalDateTimeUtil.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentAutoConfigurationSelector.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\entity\MvcEntity.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\RabbitUtil.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\RedisBucketHandler.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\AsyncManager.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\redis\impl\RedisServiceImpl.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentAutoConfiguration.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\SpringUtil.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\Interface\RateLimiterHandler.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentProperties.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\utils\AESUtils.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\properties\MqttPushProperties.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\push\PushJsonBean.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\api\IErrorCode.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\GlobalCorsConfig.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterAutoConfigration.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginAutoConfiguration.java
-E:\Project\netpump\pump-common\src\main\java\com\tuoren\common\config\SwaggerConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\mbg\CodeGenerator.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\api\ResultCode.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\redis\RedisService.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\WebUtils.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\GlobalCorsConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\MvcConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\annotation\EnableFlowMonitor.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\AsyncManager.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\SpringUtil.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginAutoConfiguration.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\exception\ApiException.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\shiro\ShiroSessionIdGenerator.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\LocalDateTimeUtil.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\exception\GlobalExceptionHandler.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentAutoConfigurationSelector.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentProperties.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterAutoConfigration.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\annotation\RateLimit.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\redis\impl\RedisServiceImpl.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\shiro\ShiroFilter.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\push\Push.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\api\AopOrderEnum.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimitAutoConfigurationSelector.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\RedisBucketHandler.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\properties\MqttPushProperties.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\Interface\RateLimiter.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\MybatisPlusConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\shiro\ShiroSessionManager.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimitMethodInterceptor.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\api\CommonResult.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginAutoConfigurationSelector.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\constant\CommonConstant.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentAutoConfiguration.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\TokenBucketHandler.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\ConstastUtils.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\enums\LogType.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorMethodInterceptor.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterHandler\Interface\RateLimiterHandler.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\RateLimiterProperties.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\rateLimit\annotation\EnableRateLimit.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\AESUtils.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\DiffTimeUtils.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\SSLConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\push\PushJsonBean.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\annotation\EnableIdempotent.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\push\BasePush.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\RedisConfig.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\IdempotentMethodInterceptor.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\entity\MvcEntity.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\annotation\EnableWebShiro.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\utils\RabbitUtil.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\api\IErrorCode.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\shiroLogin\ShiroLoginMethodInterceptor.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorAutoConfigurationSelector.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\flowMonitor\FlowMonitorAutoConfiguration.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\commponent\idempotent\annotation\Idempotent.java
+E:\Project\netpump-lora\pump-common\src\main\java\com\tuoren\common\config\SwaggerConfig.java

pump-web/src/main/java/com/tuoren/web/layer/controller/BusPumpController.java

@@ -215,4 +215,16 @@ public class BusPumpController{
         }
     }
 
+
+    /**
+     * 撤泵
+     * @param ids
+     * @return
+     */
+    @ApiOperation("撤泵")
+    @PostMapping("/removePumpByIds")
+    public CommonResult<Boolean> removePump(@RequestBody List<String> ids) {
+        iBusPumpEntityService.removePump(ids);
+        return CommonResult.success(Boolean.TRUE);
+    }
 }

pump-web/src/main/java/com/tuoren/web/layer/controller/BusReceiveRecordController.java

@@ -62,7 +62,7 @@ public class BusReceiveRecordController{
     @ApiOperation("分页查询所有数据")
     @GetMapping
     public CommonResult selectAll(@RequestParam("pageNo") Integer pageNo,@RequestParam("pageSize") Integer pageSize,
-                                  @RequestParam("viewState") String viewState,
+                                  @RequestParam(value = "viewState",required = false) String viewState,
                                   BusReceiveRecordEntity busReceiveRecordEntity) {
         IPage<BusReceiveRecordEntity> page = new Page<>(pageNo,pageSize);
         LambdaQueryWrapper<BusReceiveRecordEntity> wrapper =

pump-web/src/main/java/com/tuoren/web/layer/entity/BusReceiveRecordCopyEntity.java

@@ -172,28 +172,28 @@ public class BusReceiveRecordCopyEntity implements Serializable {
     @ApiModelProperty(value = "更新时间",hidden = true)
     private LocalDateTime gmtModified;
 
-//    @ApiModelProperty("电机运行时采集的压力数据")
-//    private String number1;
-//
-//    @ApiModelProperty("电机非运行时采集的压力数据")
-//    private String number2;
-//
-//    @ApiModelProperty("电机状态")
-//    private String numberStatus;
-//
-//    private String number3;
-//
-//    private String number4;
-//
-//    private String number5;
-//
-//    private String number6;
-//
-//    private String number7;
-//
-//    private String number8;
-//
-//    private String MotorCode;
+    @ApiModelProperty("电机运行时采集的压力数据")
+    private String number1;
+
+    @ApiModelProperty("电机非运行时采集的压力数据")
+    private String number2;
+
+    @ApiModelProperty("电机状态")
+    private String numberStatus;
+
+    private String number3;
+
+    private String number4;
+
+    private String number5;
+
+    private String number6;
+
+    private String number7;
+
+    private String number8;
+
+    private String MotorCode;
 
     private String dataVersion;
 

pump-web/src/main/java/com/tuoren/web/layer/service/IBusPumpService.java

@@ -57,5 +57,5 @@ public interface IBusPumpService extends IService<BusPumpEntity> {
     List<PumpVo> queryPumpInfo(PumpParam pumpParam);
 
 
-
+    void removePump(List<String> ids);
 }

pump-web/src/main/java/com/tuoren/web/layer/service/impl/BusPumpServiceImpl.java

@@ -1,5 +1,6 @@
 package com.tuoren.web.layer.service.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -14,12 +15,17 @@ import com.tuoren.web.layer.service.IBusPumpService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 
+import com.tuoren.web.rabbit.RabbitHandle;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import com.tuoren.web.layer.d0.PumpVo;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
+import java.util.Collection;
 import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -37,7 +43,11 @@ public class BusPumpServiceImpl extends ServiceImpl<BusPumpMapper, BusPumpEntity
 
     @Autowired
     BusReceiveRecordCopyMapper busReceiveRecordCopyMapper;
-	
+
+    @Autowired
+    @Lazy
+    private RabbitHandle rabbitHandle;
+
 	@Override
 	public void pumpRabbitHandle(BusPumpEntity record) {
 		// TODO Auto-generated method stub
@@ -164,4 +174,26 @@ public class BusPumpServiceImpl extends ServiceImpl<BusPumpMapper, BusPumpEntity
                 pumpParam.getHospitalCode()
         );
     }
+
+    @Override
+    public void removePump(List<String> ids) {
+        if(CollectionUtil.isEmpty(ids)){
+            return;
+        }
+        Collection<BusPumpEntity> pumps = this.listByIds(ids);
+        if(CollectionUtil.isEmpty(pumps)){
+            return;
+        }
+        Map<String, List<BusPumpEntity>> pumpMap = pumps.stream()
+                .peek(p -> p.setIsRemove(Boolean.FALSE))
+                .collect(Collectors.groupingBy(BusPumpEntity::getHospitalCode));
+
+        this.updateBatchById(pumps);
+        try {
+            //下发
+            rabbitHandle.sendRemovePump(pumpMap);
+        }catch (Exception e){
+
+        }
+    }
 }

pump-web/src/main/java/com/tuoren/web/rabbit/RabbitHandle.java

@@ -2,10 +2,15 @@ package com.tuoren.web.rabbit;
 
 import java.io.UnsupportedEncodingException;
 import java.time.LocalDateTime;
+import java.util.Arrays;
 import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
@@ -43,6 +48,7 @@ import javax.annotation.PostConstruct;
 @Slf4j
 @AllArgsConstructor
 public class RabbitHandle {
+	private final RabbitTemplate rabbitTemplate;
 
 	private final ISysBreathService iSysBreathService;
 
@@ -264,4 +270,10 @@ public class RabbitHandle {
 		}
 		return message;
 	}
+
+	public void sendRemovePump(Map<String, List<BusPumpEntity>> removePumpMap) {
+		removePumpMap.forEach((k,v)->{
+			rabbitTemplate.convertAndSend("removePump", k,JSONUtil.toJsonStr(v.stream().map(BusPumpEntity::getPumpCode).collect(Collectors.toList())));
+		});
+	}
 }

pump-web/src/main/java/com/tuoren/web/rabbit/config/RabbitTemplateConfig.java

@@ -42,7 +42,7 @@ public class RabbitTemplateConfig {
     @Autowired
     public RedisService redisService;
 
-    @Bean
+//    @Bean
     public RabbitTemplate simpleRabbitTemplate( ConnectionFactory connectionFactory){
         final RabbitTemplate rabbitTemplate = new RabbitTemplate();
         rabbitTemplate.setConnectionFactory(connectionFactory);

pump-web/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -12,6 +12,7 @@ com\tuoren\web\layer\controller\BusReceiveRecordController.class
 com\tuoren\web\shiro\realm\UserRealm.class
 com\tuoren\web\layer\service\ISysRolePermissionService.class
 com\tuoren\web\layer\entity\SysBlackListEntity.class
+com\tuoren\web\layer\service\impl\BusReceiveRecordCopyServiceImpl.class
 com\tuoren\web\netty\NettyServer.class
 com\tuoren\web\utils\BlackListConstants.class
 com\tuoren\web\layer\mapper\BusSolutionMapper.class
@@ -35,6 +36,7 @@ com\tuoren\web\layer\controller\SysRoleController.class
 com\tuoren\web\layer\vo\PumpParam.class
 com\tuoren\web\netty\enums\BanLevelType.class
 com\tuoren\web\shiro\utils\ShiroUtils.class
+com\tuoren\web\layer\entity\BusReceiveRecordCopyEntity.class
 com\tuoren\web\utils\DataUtils.class
 com\tuoren\web\layer\vo\HospitalParam.class
 com\tuoren\web\utils\listener\lmpl\ConverterContextListener.class
@@ -71,10 +73,12 @@ com\tuoren\web\layer\entity\SysLogEntity.class
 com\tuoren\web\layer\service\impl\BusPumpServiceImpl.class
 com\tuoren\web\layer\mapper\BusReceiveRecordMapper.class
 com\tuoren\web\layer\mapper\SysUserMapper.class
+com\tuoren\web\layer\vo\BusReceiveRecordCopyParam.class
 com\tuoren\web\layer\controller\SysRolePermissionController.class
 com\tuoren\web\layer\mapper\BusPumpMapper.class
 com\tuoren\web\layer\service\ISysBlackListService.class
 com\tuoren\web\rabbit\config\RabbitTemplateConfig$2.class
+com\tuoren\web\layer\mapper\BusReceiveRecordCopyMapper.class
 com\tuoren\web\layer\service\ISysPermissionService.class
 com\tuoren\web\layer\entity\BusPumpEntity.class
 com\tuoren\web\netty\blackList\SysBlackList.class
@@ -100,6 +104,7 @@ com\tuoren\web\layer\mapper\SysRolePermissionMapper.class
 com\tuoren\web\push\PushInfo.class
 com\tuoren\web\netty\handler\ExceptionTailHandler.class
 com\tuoren\web\layer\service\IBusReceiveRecordService.class
+com\tuoren\web\layer\vo\ReceiveRecordCopyParam.class
 com\tuoren\web\netty\enums\PumpType.class
 com\tuoren\web\layer\controller\SysBlackListController.class
 com\tuoren\web\layer\controller\BusLoginController.class
@@ -149,6 +154,7 @@ com\tuoren\web\utils\listener\ListenerStarter$1.class
 com\tuoren\web\layer\service\impl\SysBlackListServiceImpl.class
 com\tuoren\web\netty\handler\TailHandler.class
 com\tuoren\web\layer\service\impl\BusSolutionServiceImpl.class
+com\tuoren\web\layer\service\IBusReceiveRecordCopyService.class
 com\tuoren\web\layer\entity\BusSolutionEntity.class
 com\tuoren\web\netty\blackList\SysBlackListConfig.class
 com\tuoren\web\layer\service\IBusPatientService.class

pump-web/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -1,151 +1,157 @@
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\listener\lmpl\ConverterContextListener.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysUserMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\param\PipeLineDO.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysBlackListServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\ReceiveParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\LogUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\enums\PumpType.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\PumpParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\job\RemoveInvalidQueueJob.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\PipeLineLimitConstants.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusProductEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysBreathServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\handler\ListTypeHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\TailHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogMethodInterceptor.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\d0\PumpVo.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysBlackListMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\NettyServerHandlerInitializer.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\rabbit\RabbitHandle.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusPumpService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\NettyStarter.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\rabbit\config\AnalgesicScoreMqConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysConfigController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusPumpEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\InterfaceFlowStatisticsParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\job\InterfaceFlowStatisticsJob.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysInterfaceFlowStatisticsController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysBreathController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\UserLoginParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysLogMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\AnalgesicScoreParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusAnalgesicScoreMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusPatientServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusProductServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysBlackListService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusProductController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusReceiveRecordMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusAnalgesicScoreController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysLogService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\listener\ListenerProperties.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\rabbit\config\RabbitTemplateConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysUserRoleEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusReceiveRecordEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysUserRoleMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusPumpServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysUserEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\enums\BanLevelType.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusLoginController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysRolePermissionEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\blackList\SysBlackListConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\ReceiveRecordParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusPatientController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysPermissionService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\push\PushInfo.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysConfigService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysUserService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusSolutionService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\ExceptionTailHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\shiro\realm\UserRealm.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysBreathEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\PumpRecvSerivce.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusHospitalService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusPumpMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysBreathService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysInterfaceFlowStatisticsService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysInterfaceFlowStatisticsMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysBreathMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\shiro\utils\ActiverUserUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysRoleController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysRoleMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusHospitalServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusHospitalController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusPumpController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\ThreadPoolExectorUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysRolePermissionController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysPermissionMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusHospitalEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysLogServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusHospitalMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\blackList\SysBlackList.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\config\CommponentConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\NettyUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusReceiveRecordService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\webLog\javaBean\WebLog.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\PipeLineFactory.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\job\CommonJob.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\enums\BusServiceEnum.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\UserChangePwdParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\listener\ListenerStarter.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysUserServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysUserController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysLogEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysBlackListEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\shiro\ShiroConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysLogController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\HospitalParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusPatientEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusPatientService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysPermissionEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysUserRoleController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\ConverterUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusProductMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\job\SysConfigJob.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\PatientParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\DataUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\d0\PushVo.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysRoleEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\LimitAndPumpMessageDecoder.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysInterfaceFlowStatisticsEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysRoleService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogAutoConfigurationSelector.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusReceiveRecordController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\NettyServer.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\enums\BanType.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\webLog\annotation\EnableWebLog.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysConfigMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\BlackListConstants.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\ServerIdleStateHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\NettyServerHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusSolutionMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysRoleServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysUserRoleService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysPermissionController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\DefaultPumpMessageDecoder.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\rabbit\config\PumpMqConfig.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusSolutionEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\PipeLineInitHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysUserRoleServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\shiro\utils\ShiroUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysRolePermissionMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusSolutionServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysConfigServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusAnalgesicScoreServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysInterfaceFlowStatisticsServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\BusAnalgesicScoreEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusPatientMapper.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\SysBlackListController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysRolePermissionServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\AbstarctPumpMessageDecoder.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusProductService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\DateFormatUtils.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\entity\SysConfigEntity.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogAutoConfigration.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\ISysRolePermissionService.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysPermissionServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\vo\RolePermissionParam.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\netty\handler\StateHandler.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\utils\listener\AbstractListener.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusReceiveRecordServiceImpl.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\controller\BusSolutionController.java
-E:\Project\netpump\pump-web\src\main\java\com\tuoren\web\layer\service\IBusAnalgesicScoreService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusReceiveRecordMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusPumpService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\d0\PumpVo.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysBreathEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusReceiveRecordCopyService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\enums\BanLevelType.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysRoleMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusAnalgesicScoreEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\param\PipeLineDO.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\job\InterfaceFlowStatisticsJob.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\NettyServer.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\shiro\utils\ActiverUserUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogMethodInterceptor.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\listener\AbstractListener.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusAnalgesicScoreController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysConfigController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysBlackListServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysBlackListController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\handler\ListTypeHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysRolePermissionMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\NettyServerHandlerInitializer.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusPatientMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusSolutionService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\BusReceiveRecordCopyParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\ReceiveRecordCopyParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\shiro\realm\UserRealm.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\job\CommonJob.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysBreathService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusProductEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\PipeLineInitHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\BlackListConstants.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusHospitalServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysConfigEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysLogServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusPumpEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysUserEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\ReceiveParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\listener\lmpl\ConverterContextListener.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysRoleService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysRoleEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysLogService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\PipeLineFactory.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusProductController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysUserRoleMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\shiro\ShiroConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysLogEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\PatientParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\PumpRecvSerivce.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysBlackListService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysRoleController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\PumpParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusPumpController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysUserRoleEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusProductService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysInterfaceFlowStatisticsServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\rabbit\RabbitHandle.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysUserRoleServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\config\CommponentConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusPatientEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusAnalgesicScoreMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusPumpMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysUserMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysConfigService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogAutoConfigurationSelector.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\enums\PumpType.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\rabbit\config\AnalgesicScoreMqConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\NettyServerHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\blackList\SysBlackListConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysUserRoleService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\NettyStarter.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusHospitalEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\AnalgesicScoreParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\webLog\annotation\EnableWebLog.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusHospitalMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysUserController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\webLog\javaBean\WebLog.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\ExceptionTailHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysRolePermissionService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\push\PushInfo.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\d0\PushVo.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusReceiveRecordCopyServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysConfigServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysUserServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\HospitalParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\listener\ListenerStarter.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysInterfaceFlowStatisticsEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\ThreadPoolExectorUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysLogController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\ServerIdleStateHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusPatientServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusReceiveRecordServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusAnalgesicScoreServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusSolutionController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\enums\BanType.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysRolePermissionController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysInterfaceFlowStatisticsService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\DataUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\ConverterUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\commponent\webLog\WebLogAutoConfigration.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusProductServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysLogMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusHospitalService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysPermissionService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\blackList\SysBlackList.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysInterfaceFlowStatisticsMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusPatientService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusAnalgesicScoreService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\ReceiveRecordParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysConfigMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\enums\BusServiceEnum.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysRoleServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\RolePermissionParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\job\SysConfigJob.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysBreathMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\UserChangePwdParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusReceiveRecordCopyEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysBreathController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\IBusReceiveRecordService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusPumpServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusSolutionMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\AbstarctPumpMessageDecoder.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusSolutionEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysInterfaceFlowStatisticsController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\rabbit\config\PumpMqConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\BusSolutionServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\LimitAndPumpMessageDecoder.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\job\RemoveInvalidQueueJob.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusReceiveRecordCopyMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\PipeLineLimitConstants.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysRolePermissionServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysPermissionServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\BusReceiveRecordEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\UserLoginParam.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\rabbit\config\RabbitTemplateConfig.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusHospitalController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusReceiveRecordController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysPermissionEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysRolePermissionEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\decoder\DefaultPumpMessageDecoder.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\StateHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\shiro\utils\ShiroUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\DateFormatUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusLoginController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\entity\SysBlackListEntity.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\BusPatientController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\ISysUserService.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysPermissionController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\netty\handler\TailHandler.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\controller\SysUserRoleController.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\NettyUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysPermissionMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\LogUtils.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\utils\listener\ListenerProperties.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\BusProductMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\mapper\SysBlackListMapper.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\service\impl\SysBreathServiceImpl.java
+E:\Project\netpump-lora\pump-web\src\main\java\com\tuoren\web\layer\vo\InterfaceFlowStatisticsParam.java