微信剧上传审核 增加7天过期

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/BytedanceProductUpdateMapper.xml

@@ -135,7 +135,7 @@
         select app_id, secret as app_secret from deepthink.bytedance_auth_config where auth_status=1 limit 1
     </select>
     <select id="selectWaitingAlbums"  resultType="com.alibaba.fastjson.JSONObject">
-        select album_id, tb2.name
+        select album_id, tb2.name, tb1.create_time
         from deepthink.bytedance_upload_album tb1
         left join thirtpart.ly_videos tb2 on tb1.ly_video_id=tb2.id
         where can_promotion is null or can_promotion=0

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceProductUpdateServiceImpl.java

@@ -5,6 +5,7 @@ import cn.com.ctop.job.bytedance.data.entity.AigcProductPlatform;
 import cn.com.ctop.job.bytedance.data.mapper.BytedanceProductUpdateMapper;
 import cn.com.ctop.job.bytedance.data.service.IBytedanceProductUpdateService;
 import cn.com.ctop.job.bytedance.data.utils.Check;
+import cn.com.ctop.job.bytedance.data.utils.DateUtils;
 import cn.com.ctop.job.bytedance.data.utils.HttpUtils;
 import cn.com.ctop.job.bytedance.utils.BytedanceProductDocProperties;
 import cn.com.ctop.job.bytedance.utils.FeishuRobotUtil;
@@ -83,19 +84,19 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
 
 
 
-        log.info("免费商品库更新中...");
-        List<AigcProductPlatform> iaaPlatformList = bytedanceProductUpdateMapper.getPlatformList("IAA", platformId); //商品库列表
-        if (!iaaPlatformList.isEmpty()){
-            List<AigcProductAlbum> iaaVideoList = bytedanceProductUpdateMapper.getIAAVideoList(); //剧目列表
-            List<JSONObject> iaaProductTypeEnums = bytedanceProductUpdateMapper.getProductTypeEnums("IAA"); //商品类型
-            Map<String, JSONObject> iaaProductTypeMap = iaaProductTypeEnums.stream().collect(Collectors.toMap(
-                    obj -> obj.getString("third_type_name"),
-                    obj -> obj,
-                    (existing, replacement) -> replacement
-            ));
-            runMpProductTask(iaaPlatformList, iaaVideoList, iaaProductTypeMap, errors, BusinessType.IAA);
-        }
-        log.info("免费商品库更新完成");
+//        log.info("免费商品库更新中...");
+//        List<AigcProductPlatform> iaaPlatformList = bytedanceProductUpdateMapper.getPlatformList("IAA", platformId); //商品库列表
+//        if (!iaaPlatformList.isEmpty()){
+//            List<AigcProductAlbum> iaaVideoList = bytedanceProductUpdateMapper.getIAAVideoList(); //剧目列表
+//            List<JSONObject> iaaProductTypeEnums = bytedanceProductUpdateMapper.getProductTypeEnums("IAA"); //商品类型
+//            Map<String, JSONObject> iaaProductTypeMap = iaaProductTypeEnums.stream().collect(Collectors.toMap(
+//                    obj -> obj.getString("third_type_name"),
+//                    obj -> obj,
+//                    (existing, replacement) -> replacement
+//            ));
+//            runMpProductTask(iaaPlatformList, iaaVideoList, iaaProductTypeMap, errors, BusinessType.IAA);
+//        }
+//        log.info("免费商品库更新完成");
 
 
         errors.removeIf(s -> s.contains("剧目不可用"));
@@ -744,6 +745,17 @@ public class BytedanceProductUpdateServiceImpl implements IBytedanceProductUpdat
         for (JSONObject album : listAlbum){
             String al = album.getString("album_id");
             String albumName = album.getString("name");
+            String createTime = album.getString("create_time");
+            //增加判断：如果已经提审超过7天，直接标记为失败
+            Date createDate = DateUtils.getDateByPattern(createTime, "yyyy-MM-dd HH:mm:ss");
+            if (createDate != null){
+                long diff = System.currentTimeMillis() - createDate.getTime();
+                if (diff > 7L * 24 * 60 * 60 *1000){
+                    bytedanceProductUpdateMapper.updateAlbumInfo(al, 2, "审核超时");
+                    info.add("短剧审核超时，albumId: " + al + ", 剧目名称: " + albumName + ", 原因: 审核超时");
+                    continue;
+                }
+            }
             String url = "https://api.oceanengine.com/open_api/v3.0/dpa/album_status/get/";
             Map<String, String> headers = new HashMap<>();
             headers.put("App-Access-Token", appAccessToken);