Category: Office work

on run {input, parameters}
    -- AppleScript code
end run

on run {input, parameters}
    -- AppleScript code
end run

cd /path/to/script
/opt/homebrew/bin/node scriptName.js

cd /path/to/script
/opt/homebrew/bin/node scriptName.js

tell application "Mail"
	-- Get the "newsletter" mailbox under the iCloud account
	set theAccount to account "iCloud"
	set theMailbox to mailbox "newsletter" of theAccount

	-- Get all unread emails in the "newsletter" mailbox
	set unreadMessages to (every message of theMailbox whose read status is false)

	-- Iterate through all unread emails
	repeat with eachMessage in unreadMessages
		-- Use the email subject as part of the filename
		set theSubject to subject of eachMessage
		-- Get the email content and convert it to plain text
		set theContent to content of eachMessage
		set plainTextContent to do shell script "echo " & quoted form of theContent & " | textutil -convert txt -stdin -stdout"

		-- Get the message-ID and generate a URI
		set messageID to message id of eachMessage
		set messageURL to "message://" & "%3c" & messageID & "%3e"
	
		-- Create a filename by removing illegal characters
		set cleanSubject to do shell script "echo " & quoted form of theSubject & " | tr -d '\"/:<>?\\|+[]{};=,'"
		set fileName to (cleanSubject & ".txt")
	
		-- Use the specified POSIX path and convert it to AppleScript path format
		set savePath to POSIX file "path to save txt files"
	
		-- Full file path
		set filePath to (savePath as string) & fileName
	
		-- Write the email content to the txt file at the specified path
		try
			set fileReference to open for access file filePath with write permission
			write plainTextContent to fileReference starting at eof
	
			-- Append the email URI at the end of the file
			write return & "emailURL=" & messageURL to fileReference starting at eof
			close access fileReference
		on error errMsg
			close access file filePath
			display dialog "Error: " & errMsg
		end try
	
		-- Mark the email as read
		set read status of eachMessage to true
	end repeat
end tell

return input

tell application "Mail"
	-- Get the "newsletter" mailbox under the iCloud account
	set theAccount to account "iCloud"
	set theMailbox to mailbox "newsletter" of theAccount

	-- Get all unread emails in the "newsletter" mailbox
	set unreadMessages to (every message of theMailbox whose read status is false)

	-- Iterate through all unread emails
	repeat with eachMessage in unreadMessages
		-- Use the email subject as part of the filename
		set theSubject to subject of eachMessage
		-- Get the email content and convert it to plain text
		set theContent to content of eachMessage
		set plainTextContent to do shell script "echo " & quoted form of theContent & " | textutil -convert txt -stdin -stdout"

		-- Get the message-ID and generate a URI
		set messageID to message id of eachMessage
		set messageURL to "message://" & "%3c" & messageID & "%3e"
	
		-- Create a filename by removing illegal characters
		set cleanSubject to do shell script "echo " & quoted form of theSubject & " | tr -d '\"/:<>?\\|+[]{};=,'"
		set fileName to (cleanSubject & ".txt")
	
		-- Use the specified POSIX path and convert it to AppleScript path format
		set savePath to POSIX file "path to save txt files"
	
		-- Full file path
		set filePath to (savePath as string) & fileName
	
		-- Write the email content to the txt file at the specified path
		try
			set fileReference to open for access file filePath with write permission
			write plainTextContent to fileReference starting at eof
	
			-- Append the email URI at the end of the file
			write return & "emailURL=" & messageURL to fileReference starting at eof
			close access fileReference
		on error errMsg
			close access file filePath
			display dialog "Error: " & errMsg
		end try
	
		-- Mark the email as read
		set read status of eachMessage to true
	end repeat
end tell

return input

const fs = require('fs');
const path = require('path');
const axios = require('axios');
const nodemailer = require('nodemailer');

const directoryPath = 'Directory path to store text files'; // The directory path to store text files
const today = new Date().toLocaleDateString('zh-CN'); // Get system local date

let allContents = ''; // Used to store all returned contents from the query API
let fileCounter = 0; // Used for file counting
let validFileCount = 0; // Valid file count
let emailSent = false; // A flag to track whether the email has been sent

// Read files under the specified directory
fs.readdir(directoryPath, async (err, files) => {
  if (err) {
    console.error('Failed to read directory:', err);
    return;
  }

  const filePromises = files.map(file => processFile(file));
  await Promise.all(filePromises);
  checkAllFilesProcessed();
});

async function processFile(file) {
  const filePath = path.join(directoryPath, file);

  try {
    const stats = await fs.promises.stat(filePath);
    const fileCreationDate = stats.birthtime.toLocaleDateString('zh-CN'); // Get file creation date
    if (fileCreationDate === today && path.extname(file) === '.txt') {
      validFileCount++; // Increase valid file count
      const content = await fs.promises.readFile(filePath, 'utf8');
      await callAIAPI(content, file);
    }
  } catch (err) {
    console.error('Error while processing file:', err);
  }
}

// Use async/await to optimize async handling
async function callAIAPI(content, fileName) {
  const apiUrl = 'https://api.coze.cn/v3/chat';
  const headers = getHeaders();
  
  // Choose bot_id depending on content length
  const botId = content.length > 32000 ? 'bot_id' : 'bot_id';
  
  const data = {
    bot_id: botId, // Dynamic bot_id
    user_id: '**',
    stream: false,
    auto_save_history: true,
    additional_messages: [
      {
        role: 'user',
        content: content,
        content_type: 'text'
      }
    ]
  };

  let attempts = 0;
  const maxAttempts = 5;

  while (attempts < maxAttempts) {
    try {
      const response = await axios.post(apiUrl, data, { headers, timeout: 5000 });
      console.log('API response:', response.data);
      const { id, conversation_id } = response.data.data;
      await new Promise(resolve => setTimeout(resolve, 1000)); // Add wait time: 1 second
      await pollConversationStatus(id, conversation_id, fileName);
      break;
    } catch (error) {
      attempts++;
      console.error(`API call error (attempt ${attempts}/${maxAttempts}):`, error);
      if (attempts >= maxAttempts) {
        console.error('Still failed after multiple attempts');
      }
    }
  }
}

// Extract headers function
function getHeaders() {
  return {
    'Authorization': 'Bearer api_key',
    'Content-Type': 'application/json'
  };
}

// Poll conversation detail interface
async function pollConversationStatus(chat_id, conversation_id, fileName) {
  const retrieveUrl = `https://api.coze.cn/v3/chat/retrieve?chat_id=${chat_id}&conversation_id=${conversation_id}`;
  const headers = getHeaders();

  let pollCount = 0;
  const maxPollCount = 120;

  return new Promise((resolve, reject) => {
    const intervalId = setInterval(async () => {
      pollCount++;
      if (pollCount > maxPollCount) {
        clearInterval(intervalId);
        reject(new Error(`Polling timeout, chat_id: ${chat_id}, conversation_id: ${conversation_id}`));
        return;
      }

      try {
        const response = await axios.get(retrieveUrl, { headers });
        // Cancel printing poll logs
        // console.log('Dialog detail API response:', response.data);
        if (response.data.data.status === 'completed') {
          clearInterval(intervalId);
          await queryAIAPI(chat_id, conversation_id, fileName);
          resolve();
        }
      } catch (error) {
        console.error('Dialog detail API error:', error);
        clearInterval(intervalId);
        reject(error);
      }
    }, 1000); // Poll every second
  });
}

// Call query interface
async function queryAIAPI(chat_id, conversation_id, fileName) {
  const queryUrl = `https://api.coze.cn/v3/chat/message/list?chat_id=${chat_id}&conversation_id=${conversation_id}`;
  const headers = getHeaders();

  try {
    const response = await axios.get(queryUrl, { headers });
    console.log('Query API response:', response.data);
    const contents = response.data.data
      .filter(item => item.type === 'answer') // Filter items of type 'answer'
      .map(item => item.content)
      .join('\n');

    // Read last line of file to get MessageID
    const filePath = path.join(directoryPath, fileName);
    const fileContent = await fs.promises.readFile(filePath, 'utf8');
    const lastLine = fileContent.trim().split('\n').pop();
    const messageId = lastLine.split('=')[1]; // Extract MessageID

    fileCounter++; // Increase file count
    console.log(`File count: ${fileCounter}`);
    const fileNameWithoutExt = fileName.replace(/\.[^/.]+$/, ""); // Remove extension
    allContents += `<h3><a href="${messageId}">${fileCounter}. ${fileNameWithoutExt}</a></h3><br>${contents.replace(/\n/g, '<br>')}<br><br>`;
  } catch (error) {
    console.error('Query API error:', error);
  }
}

// Check if all files are processed
function checkAllFilesProcessed() {
  if (fileCounter === validFileCount && !emailSent) {
    emailSent = true; // Mark email as sent
    sendEmail(allContents); // Call send email function
  }
}

// Send email
function sendEmail(contents) {
  const transporter = nodemailer.createTransport({
    host: 'smtp.qq.com',
    port: 465,
    secure: true, // Use SSL
    auth: {
      user: 'Email address', // Your email address
      pass: 'Email authorization code' // Your email authorization code
    }
  });

  const mailOptions = {
    from: 'Email address', // Sender email address
    to: 'Email address',    // Recipient email address
    subject: `${today} Daily Email Summary`, // Email subject
    html: `Unread email count: ${validFileCount}<br><br>${contents}` // HTML content
  };

  transporter.sendMail(mailOptions, (error, info) => {
    if (error) {
      return console.error('Failed to send email:', error);
    }
    console.log('Email sent:', info.response);
  });
}

const fs = require('fs');
const path = require('path');
const axios = require('axios');
const nodemailer = require('nodemailer');

const directoryPath = 'Directory path to store text files'; // The directory path to store text files
const today = new Date().toLocaleDateString('zh-CN'); // Get system local date

let allContents = ''; // Used to store all returned contents from the query API
let fileCounter = 0; // Used for file counting
let validFileCount = 0; // Valid file count
let emailSent = false; // A flag to track whether the email has been sent

// Read files under the specified directory
fs.readdir(directoryPath, async (err, files) => {
  if (err) {
    console.error('Failed to read directory:', err);
    return;
  }

  const filePromises = files.map(file => processFile(file));
  await Promise.all(filePromises);
  checkAllFilesProcessed();
});

async function processFile(file) {
  const filePath = path.join(directoryPath, file);

  try {
    const stats = await fs.promises.stat(filePath);
    const fileCreationDate = stats.birthtime.toLocaleDateString('zh-CN'); // Get file creation date
    if (fileCreationDate === today && path.extname(file) === '.txt') {
      validFileCount++; // Increase valid file count
      const content = await fs.promises.readFile(filePath, 'utf8');
      await callAIAPI(content, file);
    }
  } catch (err) {
    console.error('Error while processing file:', err);
  }
}

// Use async/await to optimize async handling
async function callAIAPI(content, fileName) {
  const apiUrl = 'https://api.coze.cn/v3/chat';
  const headers = getHeaders();
  
  // Choose bot_id depending on content length
  const botId = content.length > 32000 ? 'bot_id' : 'bot_id';
  
  const data = {
    bot_id: botId, // Dynamic bot_id
    user_id: '**',
    stream: false,
    auto_save_history: true,
    additional_messages: [
      {
        role: 'user',
        content: content,
        content_type: 'text'
      }
    ]
  };

  let attempts = 0;
  const maxAttempts = 5;

  while (attempts < maxAttempts) {
    try {
      const response = await axios.post(apiUrl, data, { headers, timeout: 5000 });
      console.log('API response:', response.data);
      const { id, conversation_id } = response.data.data;
      await new Promise(resolve => setTimeout(resolve, 1000)); // Add wait time: 1 second
      await pollConversationStatus(id, conversation_id, fileName);
      break;
    } catch (error) {
      attempts++;
      console.error(`API call error (attempt ${attempts}/${maxAttempts}):`, error);
      if (attempts >= maxAttempts) {
        console.error('Still failed after multiple attempts');
      }
    }
  }
}

// Extract headers function
function getHeaders() {
  return {
    'Authorization': 'Bearer api_key',
    'Content-Type': 'application/json'
  };
}

// Poll conversation detail interface
async function pollConversationStatus(chat_id, conversation_id, fileName) {
  const retrieveUrl = `https://api.coze.cn/v3/chat/retrieve?chat_id=${chat_id}&conversation_id=${conversation_id}`;
  const headers = getHeaders();

  let pollCount = 0;
  const maxPollCount = 120;

  return new Promise((resolve, reject) => {
    const intervalId = setInterval(async () => {
      pollCount++;
      if (pollCount > maxPollCount) {
        clearInterval(intervalId);
        reject(new Error(`Polling timeout, chat_id: ${chat_id}, conversation_id: ${conversation_id}`));
        return;
      }

      try {
        const response = await axios.get(retrieveUrl, { headers });
        // Cancel printing poll logs
        // console.log('Dialog detail API response:', response.data);
        if (response.data.data.status === 'completed') {
          clearInterval(intervalId);
          await queryAIAPI(chat_id, conversation_id, fileName);
          resolve();
        }
      } catch (error) {
        console.error('Dialog detail API error:', error);
        clearInterval(intervalId);
        reject(error);
      }
    }, 1000); // Poll every second
  });
}

// Call query interface
async function queryAIAPI(chat_id, conversation_id, fileName) {
  const queryUrl = `https://api.coze.cn/v3/chat/message/list?chat_id=${chat_id}&conversation_id=${conversation_id}`;
  const headers = getHeaders();

  try {
    const response = await axios.get(queryUrl, { headers });
    console.log('Query API response:', response.data);
    const contents = response.data.data
      .filter(item => item.type === 'answer') // Filter items of type 'answer'
      .map(item => item.content)
      .join('\n');

    // Read last line of file to get MessageID
    const filePath = path.join(directoryPath, fileName);
    const fileContent = await fs.promises.readFile(filePath, 'utf8');
    const lastLine = fileContent.trim().split('\n').pop();
    const messageId = lastLine.split('=')[1]; // Extract MessageID

    fileCounter++; // Increase file count
    console.log(`File count: ${fileCounter}`);
    const fileNameWithoutExt = fileName.replace(/\.[^/.]+$/, ""); // Remove extension
    allContents += `<h3><a href="${messageId}">${fileCounter}. ${fileNameWithoutExt}</a></h3><br>${contents.replace(/\n/g, '<br>')}<br><br>`;
  } catch (error) {
    console.error('Query API error:', error);
  }
}

// Check if all files are processed
function checkAllFilesProcessed() {
  if (fileCounter === validFileCount && !emailSent) {
    emailSent = true; // Mark email as sent
    sendEmail(allContents); // Call send email function
  }
}

// Send email
function sendEmail(contents) {
  const transporter = nodemailer.createTransport({
    host: 'smtp.qq.com',
    port: 465,
    secure: true, // Use SSL
    auth: {
      user: 'Email address', // Your email address
      pass: 'Email authorization code' // Your email authorization code
    }
  });

  const mailOptions = {
    from: 'Email address', // Sender email address
    to: 'Email address',    // Recipient email address
    subject: `${today} Daily Email Summary`, // Email subject
    html: `Unread email count: ${validFileCount}<br><br>${contents}` // HTML content
  };

  transporter.sendMail(mailOptions, (error, info) => {
    if (error) {
      return console.error('Failed to send email:', error);
    }
    console.log('Email sent:', info.response);
  });
}