fix sync columen

windmill/sync_shorturl_event_from_mongo.ts

@@ -410,13 +410,21 @@ export async function main(
         (link_id, channel_id, visitor_id, session_id, event_type, ip_address, country, city, 
          referrer, utm_source, utm_medium, utm_campaign, user_agent, device_type, browser, os, 
          time_spent_sec, is_bounce, is_qr_scan, qr_code_id, conversion_type, conversion_value, custom_data)
-        VALUES ${clickhouseData.map(record => 
-          `('${record.link_id}', '${record.channel_id.replace(/'/g, "''")}', '${record.visitor_id}', '${record.session_id}', 
-            ${record.event_type}, '${record.ip_address}', '', '', 
-            '${record.referrer.replace(/'/g, "''")}', '', '', '', '${record.user_agent.replace(/'/g, "''")}', ${record.device_type}, 
-            '${record.browser.replace(/'/g, "''")}', '${record.os.replace(/'/g, "''")}', 
-            0, true, false, '', 1, 0, '${record.custom_data}')`
-        ).join(", ")}
+        VALUES ${clickhouseData.map(record => {
+          // 确保所有字符串值都是字符串类型，并安全处理替换
+          const safeReplace = (val: any): string => {
+            // 确保值是字符串，如果是null或undefined则使用空字符串
+            const str = val === null || val === undefined ? "" : String(val);
+            // 安全替换单引号
+            return str.replace(/'/g, "''");
+          };
+          
+          return `('${record.link_id}', '${safeReplace(record.channel_id)}', '${record.visitor_id}', '${record.session_id}', 
+            ${record.event_type}, '${safeReplace(record.ip_address)}', '', '', 
+            '${safeReplace(record.referrer)}', '', '', '', '${safeReplace(record.user_agent)}', ${record.device_type}, 
+            '${safeReplace(record.browser)}', '${safeReplace(record.os)}', 
+            0, true, false, '', 1, 0, '${safeReplace(record.custom_data)}')`;
+        }).join(", ")}
       `;
 
       if (insertSQL.length === 0) {