소스 검색

Merge branch 'ydev' of http://git.tjyourong.com.cn/ctop/adsp-boot into ydev

huangxuechao 3 년 전
부모
커밋
ca5dfa271f

+ 7 - 0
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/material/mapper/ByteDanceVideoInfoMapper.java

@@ -15,4 +15,11 @@ import java.util.List;
 public interface ByteDanceVideoInfoMapper extends BaseMapper<ByteDanceVideoInfo> {
 
     void replaceBatch(@Param(value = "videoList") List<ByteDanceVideoInfo> videoInfoList);
+
+    /**
+     * 头条上传视频素材信息 根据账户id 修改状态
+     * @param accountId 账户id
+     * @param status  0-删除 1-正常
+     */
+    void updaBytedanceVideoByAccountId(@Param(value = "accountId") Long accountId, @Param(value = "status") Integer status);
 }

+ 9 - 0
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/material/mapper/xml/ByteDanceVideoInfoMapper.xml

@@ -55,4 +55,13 @@
             )
         </foreach>
     </insert>
+
+    <!-- 修改素材信息 状态 -->
+    <update id="updaBytedanceVideoByAccountId">
+        UPDATE ctop_bytedance_video_info
+        SET status = #{status}
+        where account_id = #{accountId}
+    </update>
+
+
 </mapper>

+ 24 - 0
module-toutiao/src/main/java/cn/com/ctop/toutiao/modules/material/service/impl/ByteDanceAdvertiserDataServiceImpl.java

@@ -5,6 +5,7 @@ import cn.com.ctop.common.module.service.ICtopOauthTokenService;
 import cn.com.ctop.common.module.utils.*;
 import cn.com.ctop.toutiao.modules.material.entity.*;
 import cn.com.ctop.toutiao.modules.material.mapper.ByteDanceCreativeMapper;
+import cn.com.ctop.toutiao.modules.material.mapper.ByteDanceVideoInfoMapper;
 import cn.com.ctop.toutiao.modules.material.service.*;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -16,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * @author 宋英豪
@@ -44,6 +46,9 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
     @Autowired
     private IByteDanceVideoInfoService videoInfoService;
 
+    @Autowired
+    private ByteDanceVideoInfoMapper byteDanceVideoInfoMapper;
+
     @Override
     public JSONObject getAdvertiserList(String token, Long accountId) {
         JSONObject returnJson = new JSONObject();
@@ -637,6 +642,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
 
     @Override
     public void getMaterialList(CtopOauthToken token) {
+        updaBytedanceVideoByAccountId(token);
         getVideoByPage(token, "", 1);
         getImageByPage(token, "", 1);
     }
@@ -723,12 +729,14 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
             log.info("获取视频素材完成==》accountId:{},message:{}", token.getAccountId(), resultObject.getString("message"));
             return;
         }
+        log.info("数据数量======》》》{}",data.size());
         List<ByteDanceVideoInfo> videoInfoList = new ArrayList<>();
         for (int i = 0; i < data.size(); i++) {
             JSONObject dataObject = data.getJSONObject(i);
             ByteDanceVideoInfo videoInfo = new ByteDanceVideoInfo(dataObject, token);
             videoInfoList.add(videoInfo);
         }
+        log.info("数据======》》》{}",videoInfoList);
         videoInfoService.replaceBatch(videoInfoList);
         getVideoByPage(token, videoIds, page + 1);
     }
@@ -787,4 +795,20 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
     }
 
 
+    /**
+     * 头条上传视频素材信息 根据账户id 修改状态
+     * @param token
+     */
+    public void updaBytedanceVideoByAccountId(CtopOauthToken token){
+    byteDanceVideoInfoMapper.updaBytedanceVideoByAccountId(token.getAccountId(),0);
+}
+
+
+
+
+
+
+
+
+
 }