public void addOrder() {
    // 1.獲取當前年月日以及商戶標識
    String currentDate = "yyyyMMddHHmmss";
    String businessman = "商戶標識";
    // 2.獲取獲取序列號
    long index = getIndex();
    // 3.拼接訂單號
    String orderNum = businessman + currentDate + index;
    // 4.生成訂單
    save(訂單對象);
}

public String getIndex() {
    // 根據(jù)算法生成唯一序列號
    return buildIndexUtils.build();
}

public String getIndex() {
    // 1.獲取當前商戶、當前單據(jù)已生成的最大序列號
    Integer index = dao.getIndex(商戶, 單據(jù)) + 1;
    // 2.序列號 + 1
    index = index++;
    // 3.修改當前商戶、當前單據(jù)已生成的最大序列號
    dao.update(商戶, 單據(jù), index);
    // 4.返回序列號
    return index + "";
}

/**
 * @param id     數(shù)據(jù)ID
 * @param status 數(shù)據(jù)的狀態(tài)
 */
public void update(Long id, Integer status) {
    // 1.根據(jù)ID查詢數(shù)據(jù)
    PO po = dao.select(id);
    // 2.判斷數(shù)據(jù)的狀態(tài)是否符合修改要求(這一步主要是應對兩個線程都進入Controller層，其中線程1剛好提交事務后，線程2開始事務的情況)
    if(!status.equals(po.getStatus())) {
        throw new TJCException("數(shù)據(jù)已被修改，請刷新后重試");
    }
    // 3.修改數(shù)據(jù)(啟用樂觀鎖機制，主要應對線程1提交事務之前線程2開啟事務的情況)
    int i = dao.update("update table set xxx = ?, version = version + 1 where id = ? and version > ?");
    if(i == 0) {
        throw new TJCException("數(shù)據(jù)已被修改，請刷新后重試");
    }
    // 繼續(xù)執(zhí)行下面業(yè)務
}

// 上游服務發(fā)送消息
public void request() {
    String messageId = "xxxx";
    rpc.request(messageId, message);
}

// 下游服務消費消息
public void consume(String messageId, String message) {
    // 將messageId存儲在redis中, 單機環(huán)境也可以直接找個map去存或者存在Guava中
    Boolean flag = stringRedisTemplate.opsForValue()
                .setIfAbsent(messageId, "1", 60, TimeUnit.SECONDS);
    if(!flag) {
       log.error("重復消息攔截");
       return;
    }
    // 繼續(xù)執(zhí)行下面業(yè)務
     .....
    // 事務完成后(提交/回滾)，刪除標識
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
        @Override
        public void afterCompletion(int status) {
            stringRedisTemplate.delete(messageId);
        }
    });
}

// 序列號的key可以設置為(模塊名:orderIndex:訂單類型:yyyyMMdd)
String dateFormat = getCurrentDateFormat("yyyyMMdd");
// key
String key = 模塊名 + ":" + orderIndex + ":" + 訂單類型 + ":" + dateFormat;
String script = "if (redis.call('exists', KEYS[1]) == 0) then redis.call('setex', KEYS[1], ARGV[1], ARGV[2]) return 1 else return redis.call('incr', KEYS[1]) end";
DefaultRedisScript<Long> defaultRedisScript = new DefaultRedisScript<>();
defaultRedisScript.setResultType(Long.class);
defaultRedisScript.setScriptText(script);
long count = stringRedisTemplate.execute(defaultRedisScript, Arrays.asList(key), (3600 * 24) + "", "1");

/**
 * @param indexStdId         標準ID
 * @param currentTeamClassId 班ID
 * @param dataId             數(shù)據(jù)ID
 * @param count              計數(shù)要求
 */
public List<Long> countMonitor(Long indexStdId, Long currentTeamClassId, Long 
dataId, Integer count) {
        StringBuilder countMonitorLua = new StringBuilder();
        countMonitorLua.append("if (redis.call('hget', KEYS[1], KEYS[2]) == ARGV[2]) ");
        countMonitorLua.append("then ");
        countMonitorLua.append("    if (redis.call('hget', KEYS[1], KEYS[3]) == ARGV[3]) ");
        countMonitorLua.append("    then ");
        countMonitorLua.append("        redis.call('hset', KEYS[1], KEYS[3], 0) ");
        countMonitorLua.append("        redis.call('lpush', KEYS[4], ARGV[1]) ");
        countMonitorLua.append("        local list = redis.call('lrange', KEYS[4], 0, -1) ");
        countMonitorLua.append("        redis.call('del', KEYS[4]) ");
        countMonitorLua.append("        return list ");
        countMonitorLua.append("    else ");
        countMonitorLua.append("        redis.call('lpush', KEYS[4], ARGV[1]) ");
        countMonitorLua.append("        redis.call('hincrby', KEYS[1], KEYS[3], 1) ");
        countMonitorLua.append("        return {} ");
        countMonitorLua.append("    end ");
        countMonitorLua.append("else ");
        countMonitorLua.append("    redis.call('del', KEYS[4]) ");
        countMonitorLua.append("    redis.call('lpush', KEYS[4], ARGV[1]) ");
        countMonitorLua.append("    redis.call('hset', KEYS[1], KEYS[3], 1) ");
        countMonitorLua.append("    redis.call('hset', KEYS[1], KEYS[2], ARGV[2]) ");
        countMonitorLua.append("    if (redis.call('hget', KEYS[1], KEYS[3]) == ARGV[4]) ");
        countMonitorLua.append("    then ");
        countMonitorLua.append("        redis.call('hset', KEYS[1], KEYS[3], 0) ");
        countMonitorLua.append("        local list2 = redis.call('lrange', KEYS[4], 0, -1) ");
        countMonitorLua.append("        redis.call('del', KEYS[4]) ");
        countMonitorLua.append("        return list2 ");
        countMonitorLua.append("    else ");
        countMonitorLua.append("        return {} ");
        countMonitorLua.append("    end ");
        countMonitorLua.append("end ");

        DefaultRedisScript<List> defaultRedisScript = new DefaultRedisScript<>();
        defaultRedisScript.setResultType(List.class);
        defaultRedisScript.setScriptText(countMonitorLua.toString());
        List<String> keys = new ArrayList<>();
        keys.add(COUNTMONITOR_HASH.replace("${indexStd}", indexStdId.toString()));
        keys.add(COUNTMONITOR_HASH_CURRENTTEAMCLASSID);
        keys.add(COUNTMONITOR_HASH_COUNT);
        keys.add(COUNTMONITOR_LIST.replace("${indexStd}", indexStdId.toString()));
        List dataIdList = stringRedisTemplate.execute(defaultRedisScript, keys, gapDataId.toString(), currentTeamClassId.toString(), (count - 1) + "", count + "");

        List<Long> collect = null;
        if(!gapDataIdList.isEmpty()) {
            collect = (List<Long>) gapDataIdList.stream().map(o -> Long.valueOf(o.toString())).collect(Collectors.toList());
        }
        return collect;
    }