修改

job-adq/src/main/java/cn/com/ctop/job/adq/controller/AdqController.java

@@ -44,10 +44,6 @@ public class AdqController {
     @Autowired
     private IDailyBalanceReportService dailyBalanceReportService;
     @Autowired
-    private IClCreativeUserService creativeUserService;
-    @Autowired
-    private IMovieLevelService movieLevelService;
-    @Autowired
     private IRefreshTokenService refreshTokenService;
     @Autowired
     private AdqRetryReportJob adqRetryReportJob;
@@ -64,24 +60,6 @@ public class AdqController {
 
     }
 
-    @GetMapping("/sendMovie")
-    public JSONObject sendMovie() throws InterruptedException {
-        movieLevelService.sendMovieLevel();
-        return null;
-
-    }
-
-
-    @GetMapping("/clCreativeUser")
-    public JSONObject clCreativeUser() throws InterruptedException {
-
-        creativeUserService.getCreativeUser(1);
-
-        return null;
-
-    }
-
-
     @GetMapping("/getBalanceReport")
     public JSONObject getBalanceReport() throws InterruptedException {
 

job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/RefreshTokenMapper.java

@@ -9,5 +9,5 @@ import java.util.List;
 public interface RefreshTokenMapper {
     List<JSONObject> getAllTokenList();
 
-    void updateToken(@Param("adminAdvertiserId") Long adminAdvertiserId, @Param("updateAccessToken") String updateAccessToken, @Param("updateRefreshToken") String updateRefreshToken);
+    void updateToken(@Param("id") Long id, @Param("updateAccessToken") String updateAccessToken, @Param("updateRefreshToken") String updateRefreshToken);
 }

job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/xml/RefreshTokenMapper.xml

@@ -2,15 +2,22 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
 <mapper namespace="cn.com.ctop.job.adq.data.mapper.RefreshTokenMapper">
     <update id="updateToken">
-        update deepthink.adq_auth_list
+        update media_auth_account
         set access_token  = #{updateAccessToken},
             refresh_token = #{updateRefreshToken}
-        where admin_advertiser_id = #{adminAdvertiserId}
+        where id = #{id}
     </update>
 
 
     <select id="getAllTokenList" resultType="com.alibaba.fastjson.JSONObject">
-        select admin_advertiser_id as 'adminAdvertiserId', client_id as 'clientId', client_secret as 'clientSecret', refresh_token as 'refreshToken'
-        from deepthink.adq_auth_list
+        select t1.id            as 'id',
+               t1.app_id        as 'clientId',
+               t2.client_secret as 'clientSecret',
+               t1.refresh_token as 'refreshToken'
+        from media_auth_account t1
+                 inner join media_auth_config t2 on t1.app_id = t2.app_id and t2.media_type = 3
+        where t1.media_type = 3
+          and t1.is_valid = 1
+          and t2.status = 1
     </select>
 </mapper>

job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/RefreshTokenServiceImpl.java

@@ -25,7 +25,7 @@ public class RefreshTokenServiceImpl implements IRefreshTokenService {
             return;
         }
         for (JSONObject tokenJson : tokenList) {
-            Long adminAdvertiserId = tokenJson.getLong("adminAdvertiserId");
+            Long id = tokenJson.getLong("id");
             String clientId = tokenJson.getString("clientId");
             String clientSecret = tokenJson.getString("clientSecret");
             String refreshToken = tokenJson.getString("refreshToken");
@@ -49,7 +49,7 @@ public class RefreshTokenServiceImpl implements IRefreshTokenService {
             }
             String updateAccessToken = data.getString("access_token");
             String updateRefreshToken = data.getString("refresh_token");
-            refreshTokenMapper.updateToken(adminAdvertiserId, updateAccessToken, updateRefreshToken);
+            refreshTokenMapper.updateToken(id, updateAccessToken, updateRefreshToken);
         }