import { Agent } from '@openclaw/core';
import { EmailClient } from './clients/email';
import { LinkedInClient } from './clients/linkedin';
import { DnBClient } from './clients/dnb';

interface InquiryTask {
  type: 'parse' | 'translate' | 'due_diligence' | 
        'quote' | 'follow_up';
  emailId: string;
  parameters?: Record<string, any>;
}

export const foreignTradeAgent = new Agent({
  name: 'foreign-trade-inquiry',
  description: '外贸询盘与客户管理 AI Agent：邮件解析/翻译/背调/报价/跟进',
  
  config: {
    emailProviders: ['gmail', 'outlook', 'imap'],
    languages: ['en', 'zh', 'es', 'fr', 'de', 'ja', 'ko'],
    autoReplyEnabled: true,
    dueDiligenceSources: ['linkedin', 'dnb', 'customs']
  },

  onStart: async (context) => {
    context.logger.info('🚀 启动外贸 AI Agent...');
    
    // 初始化客户端
    const email = new EmailClient(process.env.EMAIL_CONFIG);
    const linkedin = new LinkedInClient(process.env.LINKEDIN_ACCESS_TOKEN);
    const dnb = new DnBClient(process.env.DNB_API_KEY);

    // 监听新邮件
    email.on('new_message', async (message) => {
      if (isInquiry(message)) {
        await processInquiry(message, context);
      }
    });

    // 定时跟进任务
    setInterval(async () => {
      await checkFollowUps(context);
    }, 3600000); // 每小时检查
  },

  onStop: async (context) => {
    context.logger.info('🛑 停止外贸 AI Agent');
  }
});

async function processInquiry(message: any, context: any) {
  try {
    // 1. 邮件解析
    const parsed = await parseEmail(message);
    
    // 2. 语言检测与翻译
    const language = detectLanguage(parsed.content);
    const translated = await translate(parsed.content, language, 'zh');
    
    // 3. 客户背调
    const companyInfo = await extractCompany(parsed.sender);
    const dueDiligence = await runDueDiligence(companyInfo, context);
    
    // 4. 智能报价
    const quote = await generateQuote(parsed.products, dueDiligence);
    
    // 5. 生成回复
    const reply = await context.llm.generate(`
      你是专业外贸业务员，请用${language}回复客户：
      
      客户需求：${translated}
      背调结果：${JSON.stringify(dueDiligence)}
      报价方案：${JSON.stringify(quote)}
      
      要求：
      1. 语气专业友好
      2. 确认产品规格/数量/交期
      3. 附上正式报价单
      4. 引导下一步沟通
    `);
    
    // 6. 发送邮件
    await email.send({
      to: parsed.sender,
      subject: `Re: ${parsed.subject}`,
      body: reply,
      attachments: [quote.pdf]
    });
    
    // 7. 创建跟进任务
    await context.db.save({
      type: 'inquiry',
      customer: companyInfo,
      status: 'quoted',
      nextFollowUp: new Date(Date.now() + 3 * 24 * 3600000), // 3 天后
      value: quote.totalAmount
    });
    
  } catch (error) {
    context.logger.error('❌ 询盘处理失败:', error);
    await context.notify('wechat', { 
      message: `⚠️ 外贸 Agent 异常：${error.message}`,
      level: 'high'
    });
  }
}

{
  "email": {
    "provider": "gmail",
    "credentials": {
      "user": "${EMAIL_USER}",
      "password": "${EMAIL_PASSWORD}"
    },
    "checkInterval": 60000,
    "autoReply": true
  },
  "linkedin": {
    "enabled": true,
    "accessToken": "${LINKEDIN_TOKEN}",
    "salesNavigator": true
  },
  "dunAndBradstreet": {
    "enabled": true,
    "apiKey": "${DNB_API_KEY}",
    "products": ["credit_report", "company_profile"]
  },
  "pricing": {
    "baseMargin": 0.20,
    "currencyRisk": true,
    "customerTiers": {
      "A": { "discount": 0.05 },
      "B": { "discount": 0.03 },
      "C": { "discount": 0.00 }
    }
  },
  "followUp": {
    "rules": [
      { "daysAfterQuote": 3, "action": "send_reminder" },
      { "daysAfterQuote": 7, "action": "call_customer" },
      { "daysAfterQuote": 15, "action": "offer_discount" }
    ]
  }
}