package cn.iocoder.yudao.module.mes.service.wm.itemreceipt;
|
|
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.itemreceipt.MesWmItemReceiptDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.wm.itemreceipt.MesWmItemReceiptMapper;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmItemReceiptStatusEnum;
|
import cn.iocoder.yudao.module.mes.service.wm.itemreceipt.listener.MesWmItemReceiptStatusListener;
|
import org.junit.jupiter.api.Test;
|
import org.springframework.test.util.ReflectionTestUtils;
|
import static org.mockito.Mockito.*;
|
|
class MesWmItemReceiptStatusListenerTest {
|
@Test void ignoresAnotherProcessWithSameBusinessKey() {
|
var listener = new MesWmItemReceiptStatusListener();
|
var mapper = mock(MesWmItemReceiptMapper.class);
|
var service = mock(MesWmItemReceiptService.class);
|
ReflectionTestUtils.setField(listener, "itemReceiptMapper", mapper);
|
ReflectionTestUtils.setField(listener, "itemReceiptService", service);
|
var receipt = new MesWmItemReceiptDO().setId(12L).setProcessInstanceId("receipt-process").setStatus(MesWmItemReceiptStatusEnum.APPROVING.getStatus());
|
when(mapper.selectById(12L)).thenReturn(receipt);
|
var event = new BpmProcessInstanceStatusEvent(this).setBusinessKey("12").setId("unrelated-process").setStatus(2);
|
listener.onApplicationEvent(event);
|
verifyNoInteractions(service);
|
}
|
@Test void updatesMatchingProcess() {
|
var listener = new MesWmItemReceiptStatusListener();
|
var mapper = mock(MesWmItemReceiptMapper.class);
|
var service = mock(MesWmItemReceiptService.class);
|
ReflectionTestUtils.setField(listener, "itemReceiptMapper", mapper);
|
ReflectionTestUtils.setField(listener, "itemReceiptService", service);
|
when(mapper.selectById(12L)).thenReturn(new MesWmItemReceiptDO().setId(12L).setProcessInstanceId("receipt-process").setStatus(MesWmItemReceiptStatusEnum.APPROVING.getStatus()));
|
listener.onApplicationEvent(new BpmProcessInstanceStatusEvent(this).setBusinessKey("12").setId("receipt-process").setStatus(2));
|
verify(service).updateItemReceiptAuditStatus(12L, 2);
|
}
|
}
|
