Salesforce 编程语言 Apex 概述

trigger OpportunityTrigger on Opportunity (after update) {
    if (Trigger.isAfter && Trigger.isUpdate) {
        OpportunityTriggerHandler.handleAfterUpdate(Trigger.new, Trigger.oldMap);
    }
}

public class OpportunityTriggerHandler {
    public static void handleAfterUpdate(List<Opportunity> news, Map<Id, Opportunity> oldMap) {
        List<Task> tasks = new List<Task>();
        List<Id> toScore = new List<Id>();
        for (Opportunity o : news) {
            Opportunity oldO = oldMap.get(o.Id);
            Boolean turnedWon = (o.StageName == 'Closed Won') && (oldO.StageName != 'Closed Won');
            if (turnedWon) {
                tasks.add(new Task(
                    WhatId = o.Id,
                    Subject = 'Post-Sale Follow-up',
                    Status  = 'Not Started',
                    Priority = 'Normal'
                ));
                toScore.add(o.AccountId);
            }
        }
        if (!tasks.isEmpty()) {
            insert tasks;
        }
        if (!toScore.isEmpty()) {
            System.enqueueJob(new AccountScoringJob(toScore));
        }
    }
}

public class AccountScoringJob implements Queueable, Database.AllowsCallouts {
    private List<Id> accountIds;
    public AccountScoringJob(List<Id> ids) { this.accountIds = ids; }

    public void execute(QueueableContext ctx) {
        List<Account> accts = [SELECT Id, Name FROM Account WHERE Id IN :accountIds];
        for (Account a : accts) {
            HttpRequest req = new HttpRequest();
            req.setMethod('GET');
            req.setEndpoint('callout:ScoringService/scores?accountId=' + a.Id);
            Http http = new Http();
            HttpResponse res = http.send(req);
            if (res.getStatusCode() == 200) {
                // 假设响应是簡單的分值，例如 87
                Integer score = Integer.valueOf(res.getBody());
                a.put('Customer_Score__c', score);
            }
        }
        if (!accts.isEmpty()) {
            update accts;
        }
    }
}

global class ScoreCleanupBatch implements Database.Batchable<SObject>, Schedulable {
    global Database.QueryLocator start(Database.BatchableContext bc) {
        return Database.getQueryLocator(
            'SELECT Id, Customer_Score__c, LastModifiedDate FROM Account ' +
            'WHERE Customer_Score__c != NULL AND LastModifiedDate < LAST_N_DAYS:90'
        );
    }
    global void execute(Database.BatchableContext bc, List<SObject> scope) {
        List<Account> accs = (List<Account>)scope;
        for (Account a : accs) { a.put('Customer_Score__c', null); }
        if (!accs.isEmpty()) { update accs; }
    }
    global void finish(Database.BatchableContext bc) {}
    global void execute(SchedulableContext sc) {
        Database.executeBatch(new ScoreCleanupBatch(), 200);
    }
}

// 每天凌晨 2:15 运行
System.schedule('Daily Score Cleanup', '0 15 2 * * ?', new ScoreCleanupBatch());

@RestResource(urlMapping='/score/*')
global with sharing class ScoreApi {
    @HttpGet
    global static String getScore() {
        Id accountId = RestContext.request.params.get('accountId');
        Account a = [SELECT Id, Customer_Score__c FROM Account WHERE Id = :accountId LIMIT 1];
        return String.valueOf(a.get('Customer_Score__c'));
    }
}

@IsTest
private class DemoTests {
    @IsTest
    static void testClosedWonFlow() {
        // 构造账户与商机
        Account acc = new Account(Name='Acme');
        insert acc;
        Opportunity o = new Opportunity(Name='Deal', StageName='Prospecting', CloseDate=Date.today().addDays(10), AccountId=acc.Id);
        insert o;

        // 模拟外部评分服务
        Test.setMock(HttpCalloutMock.class, new SimpleScoreMock(88));

        Test.startTest();
        o.StageName = 'Closed Won';
        update o; // 触发器将插入 Task 并排队评分作业
        Test.stopTest(); // 等待异步完成

        // 验证评分已写回
        acc = [SELECT Customer_Score__c FROM Account WHERE Id = :acc.Id];
        System.assertEquals(88, acc.get('Customer_Score__c'));
    }

    // 简单的 HTTP 模拟
    private class SimpleScoreMock implements HttpCalloutMock {
        Integer score;
        SimpleScoreMock(Integer s) { score = s; }
        public HTTPResponse respond(HTTPRequest req) {
            HttpResponse res = new HttpResponse();
            res.setStatusCode(200);
            res.setBody(String.valueOf(score));
            return res;
        }
    }

    @IsTest
    static void testRestApi() {
        Account a = new Account(Name='Beta');
        a.put('Customer_Score__c', 73);
        insert a;

        RestRequest req = new RestRequest();
        req.requestUri = '/services/apexrest/score?accountId=' + a.Id;
        req.httpMethod = 'GET';
        RestContext.request = req;
        RestContext.response = new RestResponse();

        String body = ScoreApi.getScore();
        System.assertEquals('73', body);
    }
}