Преглед изворни кода

Merge #75 into master from pingkang

获取素材视频

* pingkang: (1 commits)
  获取素材视频

Signed-off-by: 黄平康 <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>
Merged-by: 黄平康 <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>

CR-link: https://codeup.aliyun.com/60c06368dbbed34fe0f0c263/job/hr_job-bytedance/change/75
huangpingkang пре 1 година
родитељ
комит
f544ae725c

+ 5 - 0
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceMaterialReportServiceImpl.java

@@ -2,6 +2,7 @@ package cn.com.ctop.job.bytedance.data.service.impl;
 
 
 import cn.com.ctop.job.bytedance.data.entity.BytedanceErrorLog;
 import cn.com.ctop.job.bytedance.data.entity.BytedanceErrorLog;
 import cn.com.ctop.job.bytedance.data.mapper.BytedancePromoterReportMapper;
 import cn.com.ctop.job.bytedance.data.mapper.BytedancePromoterReportMapper;
+import cn.com.ctop.job.bytedance.data.mapper.BytedanceRefreshTokenMapper;
 import cn.com.ctop.job.bytedance.data.service.IBytedanceMaterialReportService;
 import cn.com.ctop.job.bytedance.data.service.IBytedanceMaterialReportService;
 import cn.com.ctop.job.bytedance.data.utils.AlertUtils;
 import cn.com.ctop.job.bytedance.data.utils.AlertUtils;
 import cn.com.ctop.job.bytedance.data.utils.Check;
 import cn.com.ctop.job.bytedance.data.utils.Check;
@@ -29,11 +30,14 @@ public class BytedanceMaterialReportServiceImpl implements IBytedanceMaterialRep
     @Autowired
     @Autowired
     private DorisMultiTableStreamLoadManager dorisLoadManager;
     private DorisMultiTableStreamLoadManager dorisLoadManager;
     @Autowired
     @Autowired
+    private BytedanceRefreshTokenMapper tokenMapper;
+    @Autowired
     private RedisTemplate redisTemplate_db2;
     private RedisTemplate redisTemplate_db2;
 
 
     @Override
     @Override
     public void getBytedanceMaterialDailyReport(Long advertiserId, String accessToken, String startDate, String endDate, Integer page, Long errorId, Integer isLog, Integer isSend, int retry) {
     public void getBytedanceMaterialDailyReport(Long advertiserId, String accessToken, String startDate, String endDate, Integer page, Long errorId, Integer isLog, Integer isSend, int retry) {
         try {
         try {
+            accessToken = tokenMapper.onlyGetToken(advertiserId);
             String url = "https://api.oceanengine.com/open_api/v3.0/report/custom/get/";
             String url = "https://api.oceanengine.com/open_api/v3.0/report/custom/get/";
             Map<String, Object> paramsMap = new HashMap<>();
             Map<String, Object> paramsMap = new HashMap<>();
             paramsMap.put("advertiser_id", advertiserId);
             paramsMap.put("advertiser_id", advertiserId);
@@ -138,6 +142,7 @@ public class BytedanceMaterialReportServiceImpl implements IBytedanceMaterialRep
 
 
     public void getBytedanceMaterialVideo(Long advertiserId, Set<Long> materialIds, String accessToken, String startTime, String endTime, Integer page, Long errorId, Integer isLog, Integer isSend, int retry) {
     public void getBytedanceMaterialVideo(Long advertiserId, Set<Long> materialIds, String accessToken, String startTime, String endTime, Integer page, Long errorId, Integer isLog, Integer isSend, int retry) {
         try {
         try {
+            accessToken = tokenMapper.onlyGetToken(advertiserId);
             String url = "https://api.oceanengine.com/open_api/2/file/video/get/";
             String url = "https://api.oceanengine.com/open_api/2/file/video/get/";
             Map<String, Object> paramsMap = new HashMap<>();
             Map<String, Object> paramsMap = new HashMap<>();
             paramsMap.put("advertiser_id", advertiserId);
             paramsMap.put("advertiser_id", advertiserId);