|
|
@@ -22,6 +22,7 @@ import com.fdkankan.ucenter.common.PageInfo;
|
|
|
import com.fdkankan.fyun.face.FYunFileServiceInterface;
|
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
|
import com.fdkankan.ucenter.common.constants.ResultCodeMsg;
|
|
|
+import com.fdkankan.ucenter.config.ThreadPoolConfig;
|
|
|
import com.fdkankan.ucenter.constant.CameraConstant;
|
|
|
import com.fdkankan.ucenter.constant.LoginConstant;
|
|
|
import com.fdkankan.ucenter.entity.*;
|
|
|
@@ -216,10 +217,10 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
|
|
|
}
|
|
|
|
|
|
@Autowired
|
|
|
- private ExecutorService customThreadPool;
|
|
|
+ ThreadPoolConfig threadPoolConfig;
|
|
|
@Override
|
|
|
public void lockOrUnLockBySpace(CameraDetail cameraDetail, Long cameraId) {
|
|
|
- customThreadPool.execute(() -> {
|
|
|
+ threadPoolConfig.taskExecutor().execute(() -> {
|
|
|
log.info("异步任务执行，当前线程：" + Thread.currentThread().getName());
|
|
|
List<SimpleSceneVo> voList = this.getSimpleSceneVo(cameraDetail);
|
|
|
if(voList .size() <=0){
|
lyhzzz