// 注意如果是标准对象，那么直接加History即可，例如AccountHistory，如果是自定义对象__c，那么需要将__c替换为__History
conn.sobject('MyCustomObject__History').find({
  ParentId: "xxxxxxxxx",
  Field: "xxx",
  OldValue: "",
  NewValue: "",
})

var jsforce = require('jsforce');
var conn = new jsforce.Connection({
    loginUrl: process.env.SANDBOX_LOGIN_URL,
    maxRequest: 200,// 默认最大的并发请求数量(例如同时create多条记录)才10，超过会报错Exceeded max limit of concurrent call，但是这个值最大却只能200，否则也会报这样的错误EXCEEDED_ID_LIMIT: record limit reached. cannot submit more than 200 records into this call
});
conn.login('username@domain.com', `${password}${securityToken}`, function(err, res) {
  if (err) { return console.error(err); }
  conn.query('SELECT Id, Name FROM Account', function(err, res) {
    if (err) { return console.error(err); }
    console.log(res);// {"totalSize":0,"done":true,"records":[]}
  });
});

// 通过instanceUrl和accessToken进行连接
new jsforce.Connection({
  instanceUrl,
  accessToken,
});

// 通过refresh token登陆，注意refresh token只有在OAuth的response_type为code的时候才能拿来用，否则会报错invalid_grant: expired access/refresh token
// 也只有为code的时候canvas app才会在OAuth后发送signederquest到callback url
// 可以在Connected App中设置refresh token的过期策略，设置为9999个月后过期就能一直拿来用了
const conn = new jsforce.Connection({
  oauth2 : {
    clientId : 'Connected App的OAuth consumer key',  // 如果是安装的package，那么得是package作者的connected app的client id/secret
    clientSecret : 'Connected App的OAuth consumer secret',
    redirectUri : 'Connected App的callback uri',
    loginUrl: 'https://login.salesforce.com',   // 当为sandbox环境时是https://test.salesforce.com
  },
  instanceUrl : 'Oauth得到的instance url',
  accessToken : 'Oauth得到的accessToken', // 其实只要有refreshToken，这个值随便填啥都行
  refreshToken : 'Oauth response_type为code的时候的refresh token'
});

const results = await conn.oauth2.refreshToken(refreshToken); // 获取新的accessToken

conn.identity()// 能够获取到一些基本信息，例如organization_id

conn.describeSObject('Account');// 获取对象object的数据结构，包括recordTypeInfos

conn.metadata.list([{type: 'CustomObject'}]) // 列出所有的Custom Objects
conn.metadata.read('CustomObject', ['tableName__c'])// 列出指定object名的Custom Object

// 创建Object，会自动创建Created By、LastModified By、Owner、Name、IsDeleted(后台看不到)字段
conn.metadata.create('CustomObject', [{
  fullName: 'TableName__c',
  label: 'Table Label',
  pluralLabel: 'Table Label',
  nameField: {// 默认的name字段，这个字段不是唯一的
    type: 'Text',
    label: 'Name'
  },
  deploymentStatus: 'Deployed',
  sharingModel: 'ReadWrite'
}])

// 给Object添加字段
conn.metadata.create('CustomField', [{
  fullName: 'TableName__c.FieldName__c',
  label: 'FieldName',
  type: 'Text',
  length: 80,
  inlineHelpText: 'This is inline help text'
}])

// 查询
await conn.query('SELECT Id, Name FROM Account') // query语句能够实现简单的SQL(SOQL)查询
await conn.sobject("Contact").count()// 获取所有的记录数
conn.sobject('Contact').count({})// 统计指定条件的记录数，注意这里不是find再count，而是直接把条件放到count里面
conn.sobject('Account').find().select(['Id', 'Name']) // 获取指定字段，select必须在find后面，不能在前面
conn.sobject("Contact")// 类似ORM的查询方式
  .find(
    // conditions in JSON object，查询条件
    {
      LastName : {
      $like : 'A%',
          $ne: null// 不等于null
          $not: {// 非
          $ne: null
        }
    },
  $or: [
  {Name: {$like: "ha%"}},
  {Name: {$like: 'fly%'}},
  ],
      CreatedDate: { $gte : jsforce.Date.YESTERDAY },
      'Account.Name' : 'Sony, Inc.' },
    // fields in JSON object，下面是需要取的字段
    { Id: 1,
      Name: 1,
      CreatedDate: 1
    },
  )
  .sort({ CreatedDate: -1, Name : 1 })
  .limit(5)
  .skip(10)
  .execute(function(err, records) {
    if (err) { return console.error(err); }
    console.log("fetched : " + records.length);
  });

// 也可以写Raw SQL
conn.sobject("Contact")
  .select('*, Account.*') // asterisk means all fields in specified level are targeted.
  .where("CreatedDate = TODAY") // conditions in raw SOQL where clause.
  .limit(10)
  .offset(20) // synonym of "skip"
  .execute(function(err, records) {
    for (var i=0; i<records.length; i++) {
      var record = records[i];
      console.log("First Name: " + record.FirstName); 
    }
  });

// 联表子查询
conn.sobject("Contact")
  .select('*, Account.*')
  .include("Cases") // include child relationship records in query result. 
     // after include() call, entering into the context of child query.
     .select("*")
     .where({
        Status: 'New',
        OwnerId : conn.userInfo.id,
     })
     .orderby("CreatedDate", "DESC")
     .end() // be sure to call end() to exit child query context
  .where("CreatedDate = TODAY")
  .limit(10)
  .offset(20)
  .execute()

conn.sobject("Contact").find({ CreatedDate: jsforce.Date.TODAY })// 如果要查询所有字段可以不给find第二个参数
conn.sobject("Contact").find({ CreatedDate: jsforce.Date.TODAY }, '*')// 同上

// 在所有对象上进行搜索
conn.search("FIND {Un*} IN ALL FIELDS RETURNING Account(Id, Name), Lead(Id, Name)",
  function(err, res) {
    if (err) { return console.error(err); }
    console.log(res);
  }
);

// 直接根据主Id获取对象
await conn.sobject("Account").retrieve("0017000000hOMChAAO");
await conn.sobject("Account").retrieve(["0017000000hOMChAAO", "0017000000hOMChAAO"]);// 获取多个


// 创建记录
await conn.sobject("Account").create({ Name : 'My Account #1' });
await conn.sobject("Account").create([{ Name : 'My Account #1'}, { Name : 'My Account #2'} ]); // 同时创建多条记录
await conn.sobject("Account").create(accounts, {allowRecursive: true}); // 同时创建多条记录，默认一次最多200条，可以添加allowRecursive参数创建更多的记录


// 更新记录
await conn.sobject("Account").update({ 
  Id : '0017000000hOMChAAO',
  Name : 'Updated Account #1'
};
await conn.sobject("Account").update([// 更新多条
  { Id : '0017000000hOMChAAO', Name : 'Updated Account #1' },
  { Id : '0017000000iKOZTAA4', Name : 'Updated Account #2' }
];
await conn.sobject('Opportunity')// 查找并更新
    .find({ 'Account.Name' : 'Salesforce.com' })
    .update({ CloseDate: '2013-08-31' }
                                     
                                     
// 创建或者更新upsert
await conn.sobject("UpsertTable__c").upsert({ 
  Name : 'Record #1',
  ExtId__c : 'ID-0000001'
}, 'ExtId__c')
                                     
                                    
// 删除记录
await conn.sobject("Account").destroy('0017000000hOMChAAO');
await conn.sobject('Account').find({xxx}).destroy()
conn.sobject("Account").del(['0017000000hOMChAAO','0017000000iKOZTAA4']; // 删除多条

const onClickOAuth = () => {
  // 需要注意的是sandbox的login uri是不一样的
  const uri = hostname.includes('sandbox') ? 'https://test.salesforce.com/services/oauth2/authorize' : Sfdc.canvas.oauth.loginUrl();

  Sfdc.canvas.oauth.login({
    uri,
    params: {
      response_type : "code",   // 使用code的方式才能获取到refresh token
      client_id : SFDC_CLIENT_ID, // 在package的canvas app的client id
      redirect_uri : encodeURIComponent(SFDC_REDIRECT_URI), // 在Package的canvas app里面设置的回调地址
    }
  })
}

// oauth完成后关闭弹窗
if (window.opener) {
  try {
    window.opener.Sfdc.canvas.oauth
      .childWindowUnloadNotification(window.location.hash);
  } catch (e) {
    // do nothing
  }
  window.close();
}

// 登陆成功后获取对应的信息
const _loggedIn = Sfdc.canvas.oauth.loggedin();
const token = Sfdc.canvas.oauth.token();
const client = Sfdc.canvas.oauth.client();
Sfdc.canvas.client.refreshSignedRequest(function(data: any) {
  if (data.status === 200) {
    const signedRequest =  data.payload.response;
    const part = signedRequest.split('.')[1];
    const obj = JSON.parse(Sfdc.canvas.decode(part));

    console.log('obj', obj);    // 可以获取到obj.client.instanceUrl,obj.client.oauthToken,obj.client.refreshToken,obj.context.organization.organizationId,obj.context.organization.name
  }
})

Sfdc.canvas.client.ctx(function(ctx: any) {
  if (ctx.status === 200) {
      console.log(ctx.payload.organization.organizationId, ctx.payload.organization.name);
  }
}, client);