lzq
/
njzscloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改 GPS

localizer
lzq 2025-10-14 11:24:28 +08:00
parent dc372595c0
commit 55efc16afe
2 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
njzscloud-svr/src/main/java/com/njzscloud/supervisory/biz/service/TruckLocationTrackService.java
View File

@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njzscloud.common.core.thread.ThreadPool;
import com.njzscloud.common.core.tuple.Tuple3; import com.njzscloud.common.core.tuple.Tuple3;
import com.njzscloud.common.core.utils.R; import com.njzscloud.common.core.utils.R;
import com.njzscloud.common.mp.support.PageParam; import com.njzscloud.common.mp.support.PageParam;
@ -30,10 +31,8 @@ import java.time.format.DateTimeFormatter;
import java.util.HashMap; import java.util.HashMap;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -43,7 +42,15 @@ import java.util.stream.Collectors;
@Slf4j @Slf4j
@Service @Service
public class TruckLocationTrackService extends ServiceImpl<TruckLocationTrackMapper, TruckLocationTrackEntity> implements IService<TruckLocationTrackEntity> { public class TruckLocationTrackService extends ServiceImpl<TruckLocationTrackMapper, TruckLocationTrackEntity> implements IService<TruckLocationTrackEntity> {
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 5, 0, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1)); ThreadPoolExecutor threadPoolExecutor = ThreadPool.createThreadPool(
"GPS 数据",
10,
200,
60,
1,
1,
new ThreadPoolExecutor.CallerRunsPolicy()
);
HashMap<String, List<SseEmitter>> emitters = new HashMap<>(); HashMap<String, List<SseEmitter>> emitters = new HashMap<>();
ReentrantLock lock = new ReentrantLock(); ReentrantLock lock = new ReentrantLock();
List<Tuple3<String, String, String>> realtimeDataListener = new LinkedList<>(); List<Tuple3<String, String, String>> realtimeDataListener = new LinkedList<>();
@ -531,7 +538,7 @@ public class TruckLocationTrackService extends ServiceImpl<TruckLocationTrackMap
realtimeDataListenerLock.unlock(); realtimeDataListenerLock.unlock();
} }
CompletableFuture.runAsync(() -> { /* CompletableFuture.runAsync(() -> {
while (true) { while (true) {
ThreadUtil.sleep(3000); ThreadUtil.sleep(3000);
realtimeDataListenerLock.lock(); realtimeDataListenerLock.lock();
@ -556,8 +563,7 @@ public class TruckLocationTrackService extends ServiceImpl<TruckLocationTrackMap
); );
} }
} }
}, threadPoolExecutor); }, threadPoolExecutor); */
/* CompletableFuture.runAsync(() -> { /* CompletableFuture.runAsync(() -> {
try { try {

2
njzscloud-svr/src/main/java/com/njzscloud/supervisory/order/service/OrderInfoService.java
View File

@ -609,7 +609,7 @@ public class OrderInfoService extends ServiceImpl<OrderInfoMapper, OrderInfoEnti
.setCheckerId(SecurityUtil.currentUserId()) .setCheckerId(SecurityUtil.currentUserId())
); );
truckLeaving(new TruckLeavingOrderParam().setOrderId(orderId), 0); // truckLeaving(new TruckLeavingOrderParam().setOrderId(orderId), 0);
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)