上线逻辑调整

 package com.topdraw.platform.executor;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.topdraw.platform.util.DbUtil;
 import lombok.extern.slf4j.Slf4j;
+import lombok.var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -11,6 +13,7 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.sql.Connection;
 import java.util.Date;
+import java.util.Map;
 
 @Component
 @Slf4j
@@ -26,14 +29,18 @@ public class AutoOnlineProcessor {
         String today = DateUtil.today();
         try {
             connection = dbUtil.getConnection();
-            // 查询未绑定
-            String sql = StrUtil.format(" update `x_media` set `status` = '001',`update_time` = '{}' " +
-                                        "where id in ( select a.id from " +
-                                        "(select xm.id from `x_media` xm LEFT JOIN x_content_status_change xcsc on xm.id = xcsc.content_id and xcsc.content_class = 'media' " +
-                                        "where xm.`status` = '000' and xm.file_status = '001' and xm.create_time >= ? and xcsc.id is null " +
-                                        ") as a ) ", DateUtil.now());
-            dbUtil.doExecute(connection, sql, today);
-
+            String quSql = "select xm.id from `x_media` xm LEFT JOIN x_content_status_change xcsc on xm.id = xcsc.content_id and xcsc.content_class = 'media' " +
+                           "where xm.`status` = '000' and xm.file_status = '001' and xm.update_time >= ? and xcsc.id is null ";
+            var mapList = dbUtil.queryList(connection, quSql, today);
+            dbUtil.beginTransaction(connection);
+            if (CollUtil.isNotEmpty(mapList)) {
+                for (Map<String, Object> map : mapList) {
+                    var id = (Long) map.get("id");
+                    String upSql = StrUtil.format(" update `x_media` set `status` = '001',`update_time` = '{}' where id = ?", DateUtil.now());
+                    dbUtil.doExecute(connection, upSql, id);
+                }
+            }
+            dbUtil.commitTransaction(connection);
         } catch (Exception ex) {
             ex.printStackTrace();
         } finally {