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

rev：拍照改异步调用

Browse Source
This commit is contained in:
liuxy
2025-12-04 15:19:09 +08:00
parent 03f58fb220
commit 098a5f2d54
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/service/impl/AcsToWmsServiceImpl.java
View File

@@ -27,9 +27,13 @@ import org.nl.wms.warehouse_management.enums.IOSConstant;
import org.redisson.api.RLock; import org.redisson.api.RLock;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
/** /**
@@ -50,6 +54,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
@Autowired @Autowired
private RedissonClient redissonClient; private RedissonClient redissonClient;
@Resource
@Qualifier("threadPoolExecutor")
private ThreadPoolExecutor pool;
/* /*
* 任务服务 * 任务服务
*/ */
@@ -185,7 +193,13 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
SysParamServiceImpl sysParamService = SpringContextHolder.getBean(SysParamServiceImpl.class); SysParamServiceImpl sysParamService = SpringContextHolder.getBean(SysParamServiceImpl.class);
Param ParamDao = sysParamService.findByCode("is_pat"); Param ParamDao = sysParamService.findByCode("is_pat");
if (ParamDao.getValue().equals(IOSConstant.IS_DELETE_YES)) { if (ParamDao.getValue().equals(IOSConstant.IS_DELETE_YES)) {
HikvisionSnapshotUtil.sync截图(vehicleDao.getStoragevehicle_code(), taskDao.getTask_code()); CompletableFuture.runAsync(() -> {
try {
HikvisionSnapshotUtil.sync截图(vehicleDao.getStoragevehicle_code(), taskDao.getTask_code());
} catch (Exception e) {
log.info("调用海康拍照失败：" + e);
}
}, pool);
} }
log.info("ACS向WMS反馈重量，返回参数：--------------------------------------" + BaseResponse.responseOk(resultWeigh).toString()); log.info("ACS向WMS反馈重量，返回参数：--------------------------------------" + BaseResponse.responseOk(resultWeigh).toString());