#

Junjie

8 天以前 cabc8e23b0b1eb4d256813e3941a4f214b32f4e4

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

@@ -199,6 +199,7 @@
        operateTrafficControl(param);

        applyRecordsMap.remove(shuttleNo);
        redisUtil.set(RedisKeyType.TRAFFIC_CONTROL_SUCCESS_APPLY.key + shuttleNo + "_" + taskNo, 1, 60 * 60);
        News.info("receipt traffic {},{}", shuttleNo, taskNo);
        return true;
    }
@@ -259,7 +260,7 @@
    }

    @Override
    public synchronized boolean cancelTrafficControl(Integer shuttleNo, Integer taskNo) {
    public boolean cancelTrafficControl(Integer shuttleNo, Integer taskNo) {
        TrafficControlDataModel dataModel = queryTrafficControl(shuttleNo, taskNo);
        if (dataModel == null) {
            return false;
@@ -273,7 +274,7 @@
    }

    @Override
    public synchronized boolean forceCancelTrafficControl(Integer shuttleNo) {
    public boolean forceCancelTrafficControl(Integer shuttleNo) {
        TrafficControlDataModel dataModel = queryTrafficControl(shuttleNo);
        if (dataModel == null) {
            return false;