fix: 修复事务

dev_fifo_z
chenhc 6 months ago
parent 4b7e671514
commit f0bcd57933

@ -24,6 +24,8 @@ import java.util.stream.Collectors;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.glxp.api.dao.collect.IoCollectCodeMapper; import com.glxp.api.dao.collect.IoCollectCodeMapper;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional;
@Service @Service
public class IoCollectCodeService extends ServiceImpl<IoCollectCodeMapper, IoCollectCode> { public class IoCollectCodeService extends ServiceImpl<IoCollectCodeMapper, IoCollectCode> {
@ -61,6 +63,7 @@ public class IoCollectCodeService extends ServiceImpl<IoCollectCodeMapper, IoCol
/** /**
* *
*/ */
@Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
public void insertCodesByBill(String billNo) { public void insertCodesByBill(String billNo) {
IoCollectOrder collectOrder = collectOrderService.getByBillNo(billNo); IoCollectOrder collectOrder = collectOrderService.getByBillNo(billNo);

@ -50,6 +50,7 @@ import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy; import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
@ -391,7 +392,7 @@ public class IoCollectOrderBackupService extends ServiceImpl<IoCollectOrderBacku
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
public Boolean orderUpload(String billNo, AuthAdmin authAdmin) { public Boolean orderUpload(String billNo, AuthAdmin authAdmin) {
IoCollectOrderBackup updateOrder = new IoCollectOrderBackup(); IoCollectOrderBackup updateOrder = new IoCollectOrderBackup();
updateOrder.setBillNo(billNo); updateOrder.setBillNo(billNo);

@ -907,6 +907,7 @@ public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoC
} }
@Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
private void removeOrderByBillNo(IoCollectOrder collectOrder) { private void removeOrderByBillNo(IoCollectOrder collectOrder) {
String billNo = collectOrder.getBillNo(); String billNo = collectOrder.getBillNo();
this.remove(new LambdaUpdateWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, billNo)); this.remove(new LambdaUpdateWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, billNo));

Loading…
Cancel
Save