appId支持多个

@@ -10,9 +10,11 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.sql.Connection;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 @Component
 @Slf4j
@@ -21,28 +23,35 @@ public class AutoBindAppProcessor {
     DbUtil dbUtil;
 
     @Value("${entity.appId}")
-    private Long APP_ID;
+    private String APP_ID;
 
     public void execute() {
         Connection connection = null;
         try {
             connection = dbUtil.getConnection();
+            List<Long> appIds = Arrays.stream(APP_ID.split(",")).map(Long::parseLong).collect(Collectors.toList());
+            for (Long appId : appIds) {
                 // 查询未绑定
-            String sql = StrUtil.format(" select xm.id,xm.name from x_media xm LEFT JOIN x_media__app xma on xm.id = xma.media_id and xma.app_id = {} where xma.id is null limit 100 ", APP_ID);
+                String sql = StrUtil.format(" select xm.id,xm.name from x_media xm LEFT JOIN x_media__app xma on xm.id = xma.media_id and xma.app_id = {} where xma.id is null limit 100 ", appId);
                 List<Map<String, Object>> list = dbUtil.queryList(connection, sql);
 //            开启事务
                 dbUtil.beginTransaction(connection);
+
+
                 for (Map<String, Object> map : list) {
                     var mediaId = (Long) map.get("id");
                     var mapData = new HashMap<String, Object>();
                     mapData.put("media_id", mediaId);
-                mapData.put("app_id", APP_ID);
+                    mapData.put("app_id", appId);
                     String objectName = "x_media__app";
 //                添加关联关系
                     dbUtil.save(connection, mapData, objectName);
                 }
+
 //            提交事务
                 dbUtil.commitTransaction(connection);
+            }
+
 
         } catch (Exception ex) {
             ex.printStackTrace();