root/lanzhouhailiang_one
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt:分配添加锁释放时间

Browse Source
This commit is contained in:
zhangzq
2025-02-20 18:30:38 +08:00
parent adcbee19c1
commit e838f4c267
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lms/nladmin-system/src/main/java/org/nl/b_lms/storage_manage/ios/service/iostorInv/impl/StIvtIostorinvOutServiceImpl.java
View File

@@ -277,7 +277,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl<StIvtIostorinvOutM
} }
RLock lock = redissonClient.getLock("all_divTwo"); RLock lock = redissonClient.getLock("all_divTwo");
boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS); boolean tryLock = lock.tryLock(0, 60,TimeUnit.SECONDS);
try { try {
if (tryLock) { if (tryLock) {
// 用于插入分配明细的集合 // 用于插入分配明细的集合
@@ -800,7 +800,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl<StIvtIostorinvOutM
if (ObjectUtil.isNotEmpty(taskArr)) { if (ObjectUtil.isNotEmpty(taskArr)) {
throw new BadRequestException("有任务未完成，不允许强制确认!"); throw new BadRequestException("有任务未完成，不允许强制确认!");
} }
// 需要更新的库存集合 // 需要更新的库存集合
List<JSONObject> needUpdateIvtList = new ArrayList<>(); List<JSONObject> needUpdateIvtList = new ArrayList<>();
@@ -1638,7 +1638,7 @@ public class StIvtIostorinvOutServiceImpl extends ServiceImpl<StIvtIostorinvOutM
JSONObject jsonTask = taskList.stream() JSONObject jsonTask = taskList.stream()
.filter(row -> row.getString("task_id").equals(json.getString("task_code"))) .filter(row -> row.getString("task_id").equals(json.getString("task_code")))
.collect(Collectors.toList()).get(0); .collect(Collectors.toList()).get(0);
// 完成 // 完成
if (jsonTask.getString("task_status").equals(TaskStatusEnum.FINISHED.getCode())) { if (jsonTask.getString("task_status").equals(TaskStatusEnum.FINISHED.getCode())) {