SpringBootApplicationTests.java 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package com.nb.admin;
  2. import cn.hutool.json.JSONUtil;
  3. import com.nb.web.service.bus.hospital.HospitalManagerRegister;
  4. import com.nb.web.service.bus.hospital.config.HospitalDeviceAutoUndoConfigHandler;
  5. import com.nb.web.service.bus.hospital.config.handler.DeputyDeviceAutoUndoHandler;
  6. import com.nb.core.Value;
  7. import com.nb.common.queue.delay.message.DelayMessage;
  8. import org.junit.Test;
  9. import org.junit.runner.RunWith;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.boot.test.context.SpringBootTest;
  12. import org.springframework.test.context.junit4.SpringRunner;
  13. import java.util.Date;
  14. /**
  15. * @author lifang
  16. * @version 1.0.0
  17. * @ClassName SpringBootApplicationTests.java
  18. * @Description TODO
  19. * @createTime 2022年03月17日 13:50:00
  20. */
  21. @RunWith(SpringRunner.class)
  22. @SpringBootTest(classes = AdminApplication.class)
  23. public class SpringBootApplicationTests {
  24. @Autowired
  25. DeputyDeviceAutoUndoHandler deputyDeviceAutoUndoHandler;
  26. @Autowired
  27. HospitalManagerRegister hospitalManagerRegister;
  28. @Test
  29. public void autoUndo(){
  30. String json="{\"msgId\":1551842476831064066,\"body\":{\"nativeValue\":{\"uploadTime\":1658823052919,\"deviceId\":\"43165411383902B1\",\"infusionId\":\"1551842476755566594\",\"tenantId\":\"1544525896866643970\",\"patientCode\":\"1000000000000\",\"timestamp\":1658823052972}},\"handlerId\":\"no_signal\",\"properties\":{\"expire\":30,\"timeUnit\":\"MINUTES\"}}";
  31. DelayMessage delayMessage = JSONUtil.parseObj(json).toBean(DelayMessage.class);
  32. String body="{\"uploadTime\":1658823052919,\"deviceId\":\"43165411383902B1\",\"infusionId\":\"1551842476755566594\",\"tenantId\":\"1544525896866643970\",\"patientCode\":\"1000000000000\",\"timestamp\":1658823052972}";
  33. HospitalDeviceAutoUndoConfigHandler.UndoEntity undoEntity = JSONUtil.parseObj(body).toBean(HospitalDeviceAutoUndoConfigHandler.UndoEntity.class);
  34. delayMessage.setBody(Value.simple(undoEntity));
  35. deputyDeviceAutoUndoHandler.handle(delayMessage);
  36. }
  37. @Test
  38. public void undo(){
  39. hospitalManagerRegister.get("1544525896866643970").getAutoUndoConfigHandler().judgeNoSignalAutoUndo("43165411383902B1","1544870134758293505","1544525896866643970","1551842476755566594",new Date(1658823052919L));
  40. }
  41. }