#
zy
2025-07-31 d4da001ed4dbebed683c9f0f1e06a4d8f4d12eaf
#
1个文件已修改
67 ■■■■ 已修改文件
src/main/java/com/zy/core/thread/fake/FakeNyShuttleThread.java 67 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/thread/fake/FakeNyShuttleThread.java
@@ -267,8 +267,13 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    //delay
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    fakeStatus.put("hasLift", true);
                    fakeStatus.put("deviceStatus", 1);//设备空闲
                    fakeStatusMap.put(key, fakeStatus);
@@ -276,8 +281,13 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    //delay
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    fakeStatus.put("hasLift", false);
                    fakeStatus.put("deviceStatus", 1);//设备空闲
                    fakeStatusMap.put(key, fakeStatus);
@@ -285,16 +295,24 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    //delay
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    fakeStatus.put("hasCharge", true);
                    Integer batteryPower = Integer.parseInt(fakeStatus.getString("batteryPower"));
                    while (true) {
                        Thread.sleep(10000);
                        if((System.currentTimeMillis() - startTime) < 1000 * 10) {
                            continue;
                        }
                        batteryPower = batteryPower + 1;
                        fakeStatus.put("batteryPower", batteryPower);
                        fakeStatusMap.put(key, fakeStatus);
                        startTime = System.currentTimeMillis();
                        if (batteryPower >= 100) {
                            break;
                        }
@@ -306,8 +324,13 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    //delay
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    fakeStatus.put("hasCharge", false);
                    fakeStatus.put("deviceStatus", 1);//设备空闲
                    fakeStatusMap.put(key, fakeStatus);
@@ -315,8 +338,13 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    //delay
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    JSONObject body = command.getJSONObject("commandBody");
                    String currentCode = fakeStatus.getString("currentCode");
@@ -348,7 +376,13 @@
                    fakeStatus.put("deviceStatus", 0);//设备忙碌
                    fakeStatusMap.put(key, fakeStatus);
                    Thread.sleep(2000);
                    long startTime = System.currentTimeMillis();
                    while (true) {
                        if((System.currentTimeMillis() - startTime) < 1000 * 2) {
                            continue;
                        }
                        break;
                    }
                    while (true) {
                        Set<String> searchKeys = redisUtil.searchKeys(baseCommandKey);
@@ -379,6 +413,13 @@
                                break;
                            }
                            while (true) {
                                if((System.currentTimeMillis() - startTime) < 1000 * 1) {
                                    continue;
                                }
                                break;
                            }
                            String currentCode = fakeStatus.getString("currentCode");
                            JSONObject point = JSON.parseObject(currentCode);
                            point.put("x", path.getInteger("xp"));
@@ -387,7 +428,7 @@
                            fakeStatus.put("currentCode", JSON.toJSONString(point));
                            fakeStatus.put("deviceStatus", 0);//设备忙碌
                            fakeStatusMap.put(key, fakeStatus);
                            Thread.sleep(2000);
                            startTime = System.currentTimeMillis();
                        }
                        redisUtil.del(first);
                    }