#

Junjie

8 天以前 190201789934d7b2b4344e0eba6b4a0c2e38f54e

#

 pom.xml

@@ -18,7 +18,7 @@
        <cool.version>3.4.0</cool.version>
        <mysql-driver.version>5.1.47</mysql-driver.version>
        <mybatis-plus.version>2.3.2</mybatis-plus.version>
        <fastjson.version>1.2.58</fastjson.version>
        <fastjson.version>1.2.83</fastjson.version>
        <springfox.version>2.7.0</springfox.version>
    </properties>


 src/main/java/com/zy/core/model/protocol/LiftProtocol.java

@@ -200,14 +200,6 @@
        return this.taskNo == null ? 0 : this.taskNo;
    }

    public synchronized void setSyncTaskNo(Integer taskNo) {
        RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class);
        if (null != redisUtil) {
            redisUtil.set(RedisKeyType.LIFT_FLAG.key + this.liftNo, taskNo);
            this.taskNo = taskNo;
        }
    }

    public String getModel$() {
        if (this.model == null) {
            return "";

 src/main/java/com/zy/core/model/protocol/ShuttleProtocol.java

@@ -247,17 +247,6 @@
        return this.taskNo == null ? 0 : this.taskNo;
    }

    public synchronized void setSyncTaskNo(Integer taskNo) {
        RedisUtil redisUtil = null;
        try {
            redisUtil = SpringUtils.getBean(RedisUtil.class);
        }catch (Exception e) {}
        if (null != redisUtil) {
            redisUtil.set(RedisKeyType.SHUTTLE_FLAG.key + this.shuttleNo, taskNo);
            this.taskNo = taskNo;
        }
    }

    @Override
    public ShuttleProtocol clone() {
        try {

 src/main/java/com/zy/core/thread/impl/NyLiftThread.java

@@ -483,7 +483,8 @@

    @Override
    public boolean setSyncTaskNo(Integer taskNo) {
        this.liftProtocol.setSyncTaskNo(taskNo);
        redisUtil.setSync(RedisKeyType.LIFT_FLAG.key + liftProtocol.getLiftNo(), taskNo);
        this.liftProtocol.setTaskNo(taskNo);
        return true;
    }


 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -762,13 +762,15 @@

    @Override
    public synchronized boolean setTaskNo(Integer taskNo) {
        redisUtil.set(RedisKeyType.SHUTTLE_FLAG.key + shuttleProtocol.getShuttleNo(), taskNo);
        this.shuttleProtocol.setTaskNo(taskNo);
        return true;
    }

    @Override
    public synchronized boolean setSyncTaskNo(Integer taskNo) {
        this.shuttleProtocol.setSyncTaskNo(taskNo);
        redisUtil.setSync(RedisKeyType.SHUTTLE_FLAG.key + shuttleProtocol.getShuttleNo(), taskNo);
        this.shuttleProtocol.setTaskNo(taskNo);
        return true;
    }