Commit 78268436 authored by samz406's avatar samz406 Committed by qiaozhanwei
Browse files

update token add exist check (#1598) 

* misspell  words

* modify common queue TaskQueueZKImplTest.java unit test

* extends  BaseTaskQueueTest get zkServer

* modify zk config

* updateToken add entity exist check
parent 9de928ea

dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/AccessTokenService.java

+7 −2
Original line number Diff line number Diff line
@@ -154,8 +154,13 @@ public class AccessTokenService extends BaseService { 
     */

    public Map<String, Object> updateToken(int id,int userId, String expireTime, String token) {

        Map<String, Object> result = new HashMap<>(5);

        AccessToken accessToken = new AccessToken();

        accessToken.setId(id);



        AccessToken accessToken = accessTokenMapper.selectById(id);

        if (accessToken == null) {

            logger.error("access token not exist,  access token id {}", id);

            putMsg(result, Status.ACCESS_TOKEN_NOT_EXIST);

            return result;

        }

        accessToken.setUserId(userId);

        accessToken.setExpireTime(DateUtils.stringToDate(expireTime));

        accessToken.setToken(token);