update判断

xumiao
1 parent 87fc18e2
Showing 2 changed files with 12 additions and 4 deletions
src/main/java/com/huaheng/pc/config/location/service/LocationServiceImpl.java
src/main/java/com/huaheng/pc/task/taskHeader/service/TaskHeaderServiceImpl.java
@@ -370,6 +370,7 @@ public class LocationServiceImpl extends ServiceImpl&lt;LocationMapper, Location&gt; i
      * 修改容器和库位状态
      */
     @Override
+    @Transactional
     public void updateContainerCodeAndStatus(String locationCode, String containerCode, String status) {
         if (StringUtils.isNotEmpty(locationCode) || StringUtils.isNotEmpty(containerCode)) {
             LambdaUpdateWrapper<Location> updateWrapper = Wrappers.lambdaUpdate();
@@ -378,11 +379,14 @@ public class LocationServiceImpl extends ServiceImpl&lt;LocationMapper, Location&gt; i
                     .eq(Location::getWarehouseCode, "CS0001")
                     .eq(Location::getCode, locationCode)
                     .ne(Location::getStatus,status);
-            locationService.update(updateWrapper);
+            if (!locationService.update(updateWrapper)) {
+                throw new ServiceException("更新库位状态失败");
+            }
         }
     }
     @Override
+    @Transactional
     public void updateContainerCodeAndStatus(String locationCode, String containerCode,
                                              String status, String warehouseCode) {
         if (StringUtils.isNotEmpty(locationCode) || StringUtils.isNotEmpty(containerCode)) {
@@ -392,9 +396,13 @@ public class LocationServiceImpl extends ServiceImpl&lt;LocationMapper, Location&gt; i
                     .eq(Location::getWarehouseCode, warehouseCode)
                     .eq(Location::getCode, locationCode)
                     .ne(Location::getStatus,status);
-            locationService.update(updateWrapper);
+            if (!locationService.update(updateWrapper)) {
+                throw new ServiceException("更新库位状态失败");
+            }
         }
-    }    public LocationInfo getAllLocation(String type) {
+    }
+
+    public LocationInfo getAllLocation(String type) {
         if (StringUtils.isNotEmpty(type)) {
             Location location = locationMapper.getAllLocation(ShiroUtils.getWarehouseCode(), type);
             LocationInfo locationInfo = new LocationInfo();
@@ -358,7 +358,7 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
      * WMS完成任务
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @Transactional
     public AjaxResult completeTaskByWMS(Integer[] taskIds, String[] weightConvert) {
         AjaxResult  ajaxResult = null;
         for (int i = 0; i < taskIds.length; i++) {