diff --git a/casic-metering-common/src/main/java/com/casic/missiles/listeners/flowable/ProcessUpdateStateListener.java b/casic-metering-common/src/main/java/com/casic/missiles/listeners/flowable/ProcessUpdateStateListener.java
index 26a4e2c..ff5e94e 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/listeners/flowable/ProcessUpdateStateListener.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/listeners/flowable/ProcessUpdateStateListener.java
@@ -41,6 +41,7 @@
 public class ProcessUpdateStateListener implements ExecutionListener {
 
     @Override
+    @Transactional
     public void notify(DelegateExecution execution) {
         RepositoryService repositoryService = SpringContextUtil.getBean(RepositoryService.class);
         SystemFlowFormMapper flowFormMapper = SpringContextUtil.getBean(SystemFlowFormMapper.class);
@@ -118,17 +119,20 @@
             UpdateWrapper<EquipmentStateChangeLog> logUpdateWrapper = new UpdateWrapper<>();
             // 修改状态变更记录结束时间
             logUpdateWrapper.in("equipment_id", equipmentIds).isNull("end_date").set("end_date", DateUtils.format(new Date()));
-            stateChangeLogMapper.update(null, logUpdateWrapper);
+            if(stateChangeLogMapper.update(null, logUpdateWrapper)<=0){
+                throw new BusinessException(BusinessExceptionEnum.HANDLE_FAILED);
+            };
             // 获取当前申请的信息
             EquipmentApply equipmentApply = equipmentApplyMapper.selectById(id);
             // 新增状态变更记录
             for (EquipmentApplyEquipment equipment : equipmentApplyEquipments) {
                 EquipmentStateChangeLog stateChangeLog = new EquipmentStateChangeLog(Long.parseLong(id), Long.parseLong(equipment.getEquipmentId()), state, DateUtils.format(new Date()), null, Long.parseLong(equipmentApply.getApplyPerson()));
-                stateChangeLogMapper.insert(stateChangeLog);
+                if(stateChangeLogMapper.insert(stateChangeLog)<=0){
+                    throw new BusinessException(BusinessExceptionEnum.HANDLE_FAILED);
+                }
             }
-            if (meterFixedAssetsMapper.update(null, updateWrapper) <= 0) {
-                throw new BusinessException(BusinessExceptionEnum.HANDLE_FAILED);
-            }
+        }else{
+            throw new BusinessException(BusinessExceptionEnum.HANDLE_FAILED);
         }
     }