0

我正在尝试使用节点 js / jsforce 库连接到 Salesforce 并使用承诺。不幸的是，其中一种方法是在获得连接之前执行的。

我有方法 A：makeconnection，它返回连接我有方法 B：它根据方法 A 的连接引用从 Salesforce 加载数据我有方法 C：它根据方法 A 的连接从 Salesforce 获取依赖项

我希望执行以下命令 A ==> B ==> C

不幸的是，C 似乎首先运行，然后是 A 和 B，因此连接为空并且失败

大致这是代码

let jsforce = require("jsforce");
const sfdcSoup = require("sfdc-soup");
const fs = require("fs");
let _ = require("lodash");
let trgarr = [];
let clsarr = [];
let entityarr = [];

function makeConnection() {


  return new Promise((resolve,reject) => {
     const conn = new jsforce.Connection({
          loginUrl: "https://test.salesforce.com",
          instanceUrl: "salesforce.com",
          serverUrl: "xxx",
          version: "50.0"
        });

      
        conn.login(username, password, function (err, userInfo) {
          if (err) {
            return console.error(err);
          }
      
          // console.log(conn.accessToken);
          //console.log(conn.instanceUrl);
      
          //console.log("User ID: " + userInfo.id);
          //console.log("Org ID: " + userInfo.organizationId);
          console.log("logged in");
        });  
         resolve(conn);
   });
}

function loadClasses(conn) {

  return new Promise((resolve,reject) => {
     const querystr =
     "select apiVersion,name,body from apexClass where NamespacePrefix = null";
 
   let query = conn
     .query(querystr)
     .on("record", function (rec) {
       clsarr.push(rec);
     })
     .on("end", function () {
       console.log("number of class is " + clsarr.length);
       console.log("loaded all classes");
     });  
     resolve(conn,clsarr);
  });
}

async function getDependencies(conn) {




   return new Promise((resolve,reject) => {


     let entryPoint = {
          name: "xxx",
          type: "CustomField",
          id: yyy
        };
     
     let connection = {
          token: conn.accessToken,
          url: "abc.com",
          apiVersion: "50.0"
        };

       let usageApi =  sfdcSoup.usageApi(connection, entryPoint);

        usageApi.getUsage().then((response) => {
          console.log(response.stats);
          console.log(response.csv);

        });

   });

}
async function run() {
 makeConnection().then(conn => loadClasses(conn)).then(conn=>getDependencies(conn));
}

run();

我不断收到一条错误消息，提示UnhandledPromiseRejectionWarning: E​​rror: Access token and URL are required on the connection object

原因是连接需要从方法 A 获得并发送到方法 C ，这没有发生。你能指导我哪里可能错了吗？

另外为什么方法 C 在 A 和 B 之前执行。为什么我的承诺链接不能按承诺工作？

我在 Vscode 中运行代码并使用节点 14

4

2 回答 2

0

你的2方法有小修正第一种方法makeConnection，解决应该在login里面console.log("logged in")

其次loadClasses，解析应该在“结束”事件中。请检查以下2种方法。

function makeConnection() {
  return new Promise((resolve,reject) => {
     const conn = new jsforce.Connection({
          loginUrl: "https://test.salesforce.com",
          instanceUrl: "salesforce.com",
          serverUrl: "xxx",
          version: "50.0"
        });
      
        conn.login(username, password, function (err, userInfo) {
          if (err) {
            return console.error(err);
          }
      
          // console.log(conn.accessToken);
          //console.log(conn.instanceUrl);
      
          //console.log("User ID: " + userInfo.id);
          //console.log("Org ID: " + userInfo.organizationId);
          console.log("logged in");
          resolve(conn);
        });  
         
   });
}

function loadClasses(conn) {

  return new Promise((resolve,reject) => {
     const querystr =
     "select apiVersion,name,body from apexClass where NamespacePrefix = null";
 
     let query = conn
     .query(querystr)
     .on("record", function (rec) {
       clsarr.push(rec);
     })
     .on("end", function () {
       console.log("number of class is " + clsarr.length);
       console.log("loaded all classes");
       resolve(conn,clsarr);
     });  
     
  });
}
于 2020-12-02T06:54:53.047 回答
0

如果方法相互依赖，则应使用 Promise 系列，如果方法不依赖，则应使用 Promise 并行。 阅读有关 Promise 系列和并行的更多信息。

于 2021-08-20T06:13:03.340 回答