package cn.iocoder.yudao.module.mes.service.pro.scan;
|
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
import cn.iocoder.yudao.framework.security.core.LoginUser;
|
import cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils;
|
import cn.iocoder.yudao.module.mes.controller.admin.pro.scan.vo.MesProScanEventCreateReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.scan.MesProScanEventDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.pro.scan.MesProScanEventMapper;
|
import org.junit.jupiter.api.*;
|
import org.springframework.security.core.context.SecurityContextHolder;
|
import org.springframework.test.util.ReflectionTestUtils;
|
import java.math.BigDecimal;
|
import static org.junit.jupiter.api.Assertions.*;
|
import static org.mockito.Mockito.*;
|
class MobileScanRetryTest {
|
private final MesProScanEventMapper mapper=mock(MesProScanEventMapper.class);
|
private final MesProScanEventServiceImpl service=new MesProScanEventServiceImpl();
|
private MesProScanEventCreateReqVO req;
|
private MesProScanEventDO existing;
|
@BeforeEach void setup(){
|
SecurityFrameworkUtils.setLoginUser(new LoginUser().setId(7L),new org.springframework.mock.web.MockHttpServletRequest());
|
ReflectionTestUtils.setField(service,"eventMapper",mapper);
|
req=new MesProScanEventCreateReqVO();req.setEventId("original");req.setBagCode("123");req.setQuantity(new BigDecimal("1.00"));req.setLocationId(2L);req.setAreaId(3L);
|
existing=new MesProScanEventDO().setEventId("original").setBagCode("123").setScanType("BAG").setQuantity(BigDecimal.ONE).setLocationId(2L).setAreaId(3L).setStatus("SUCCESS");
|
existing.setCreator("7");
|
when(mapper.selectByEventIdForUpdate("original")).thenReturn(existing);
|
}
|
@AfterEach void cleanup(){SecurityContextHolder.clearContext();}
|
@Test void sameOperationReturnsOriginalWithoutAnotherInventoryWrite(){
|
assertSame(existing,service.createInbound(req));verifyNoMoreInteractionsAfterLookup();
|
}
|
@Test void conflictNeverOverwritesOriginalSuccess(){
|
req.setAreaId(4L);
|
assertThrows(ServiceException.class,()->service.createInbound(req));
|
assertEquals("SUCCESS",existing.getStatus());assertNull(existing.getErrorCode());
|
verifyNoMoreInteractionsAfterLookup();
|
}
|
@Test void anotherUserCannotReplayOriginal(){
|
existing.setCreator("8");
|
assertThrows(ServiceException.class,()->service.createInbound(req));verifyNoMoreInteractionsAfterLookup();
|
}
|
@Test void changedBagQuantityCannotReuseOriginalOperation(){
|
req.setQuantity(BigDecimal.TEN);
|
assertThrows(ServiceException.class,()->service.createInbound(req));verifyNoMoreInteractionsAfterLookup();
|
}
|
@Test void palletReplayKeepsServerCalculatedQuantity(){
|
req.setScanType("PALLET");existing.setScanType("PALLET").setQuantity(BigDecimal.TEN);
|
assertSame(existing,service.createInbound(req));assertEquals(BigDecimal.TEN,existing.getQuantity());
|
verifyNoMoreInteractionsAfterLookup();
|
}
|
private void verifyNoMoreInteractionsAfterLookup(){verify(mapper).selectByEventIdForUpdate("original");verifyNoMoreInteractions(mapper);}
|
}
|
