d

concurrent.txt

+(async () => {
+  let ts = new TradetransferService()
+  let fs = require("fs")
+  let k = {
+    "audit": "2",//5
+    "uppershelf": "1",//1
+    "lowershelf": "2",//2
+    "oversales": "3",//3
+    "addbaseinfo": "2",
+    "fail": "6"//6
+  }
+  function subTask(row){
+    return()=>{
+      return new Promise(async (resv,rej)=>{
+        try{
+        let ds = row.split("-")
+        let code = ds[0]
+        let status = k[ds[1]]
+        let nclcode = ds[2]
+        if(nclcode.length==1){
+          nclcode="0"+nclcode
+        }
+        console.log("xxxxxxxxxxxxxxxx==================="+code)
+        let st=6*Math.random()
+        wait(Math.round(st))
+        let rs = await ts.facOnSaleFunc(code)()
+        console.log(rs,"xxxxxxxxxxxxxxxxxxxxxxxxxx",code)
+        if (rs && rs.Trademarks && rs.Trademarks.length > 0) {
+          let isFind = false
+          let statusEqual = false
+          let alistatus = null
+          rs.Trademarks.forEach((item) => {
+            if (nclcode == item.Classification) {
+              isFind = true
+              if (status == "" + item.Status + "") {
+                statusEqual = true
+              } else {
+                alistatus = item.Status
+              }
+            }
+            //fs.appendFileSync("./a.txt",item.RegistrationNumber+"-"+item.Status+"-"+item.Classification+"\n")
+          })
+          if (isFind) {
+            if (!statusEqual) {
+              fs.appendFileSync("./statusnotequal.txt", row + "\n")
+            }
+          } else {
+            fs.appendFileSync("./notfound.txt", row + "\n")
+          }
+        } else {
+          console.log("query no result.....")
+          fs.appendFileSync("./notfound.txt", row + "\n")
+        }
+    
+        console.log(row,"over.....")
+        resv(row)
+        }catch(e){
+          fs.appendFileSync("./error.txt", row+ "\n")
+          console.log(row,"error...............")
+          return rej(e)
+        }
+      })
+    }
+
+  }
+  function wait(second) {
+    // execSync 属于同步方法；异步方式请根据需要自行查询 node.js 的 child_process 相关方法；
+    let ChildProcess_ExecSync = require('child_process').execSync;
+    ChildProcess_ExecSync('sleep ' + second);
+  };
+  let strstr = fs.readFileSync("./a.txt", "utf8")
+  let rows = strstr.split("\n")
+  console.log(rows.length)
+  //59570--596页
+  function BatchHandlerFac(rows,start,offset){
+    return async()=>{
+      let tasks=[]
+      for (let n = start; n < offset; n++) {
+        let row=rows[n]
+        tasks.push(subTask(row)())
+      }
+      return Promise.all(tasks)
+    }
+
+  }
+  for(let i=1;i<=11914;i++){
+    let start =(i-1)*5
+    let offset=start+5
+    try{
+      let ps=await BatchHandlerFac(rows,start,offset)()
+      console.log(ps)
+      console.log("page.......................===="+i)
+    }catch(e){
+      console.log(e)
+    }
+  }
+})()
\ No newline at end of file