| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- package com.nb.admin;
- import cn.hutool.json.JSONUtil;
- import com.nb.web.service.bus.hospital.HospitalManagerRegister;
- import com.nb.web.service.bus.hospital.config.HospitalDeviceAutoUndoConfigHandler;
- import com.nb.web.service.bus.hospital.config.handler.DeputyDeviceAutoUndoHandler;
- import com.nb.core.Value;
- import com.nb.common.queue.delay.message.DelayMessage;
- import org.junit.Test;
- import org.junit.runner.RunWith;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.boot.test.context.SpringBootTest;
- import org.springframework.test.context.junit4.SpringRunner;
- import java.util.Date;
- /**
- * @author lifang
- * @version 1.0.0
- * @ClassName SpringBootApplicationTests.java
- * @Description TODO
- * @createTime 2022年03月17日 13:50:00
- */
- @RunWith(SpringRunner.class)
- @SpringBootTest(classes = AdminApplication.class)
- public class SpringBootApplicationTests {
- @Autowired
- DeputyDeviceAutoUndoHandler deputyDeviceAutoUndoHandler;
- @Autowired
- HospitalManagerRegister hospitalManagerRegister;
- @Test
- public void autoUndo(){
- 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\"}}";
- DelayMessage delayMessage = JSONUtil.parseObj(json).toBean(DelayMessage.class);
- String body="{\"uploadTime\":1658823052919,\"deviceId\":\"43165411383902B1\",\"infusionId\":\"1551842476755566594\",\"tenantId\":\"1544525896866643970\",\"patientCode\":\"1000000000000\",\"timestamp\":1658823052972}";
- HospitalDeviceAutoUndoConfigHandler.UndoEntity undoEntity = JSONUtil.parseObj(body).toBean(HospitalDeviceAutoUndoConfigHandler.UndoEntity.class);
- delayMessage.setBody(Value.simple(undoEntity));
- deputyDeviceAutoUndoHandler.handle(delayMessage);
- }
- @Test
- public void undo(){
- hospitalManagerRegister.get("1544525896866643970").getAutoUndoConfigHandler().judgeNoSignalAutoUndo("43165411383902B1","1544870134758293505","1544525896866643970","1551842476755566594",new Date(1658823052919L));
- }
- }
|