change sth

src/chain/ERC721Reactor.ts

@@ -56,17 +56,17 @@ export class ERC721Reactor {
     chain,
     address,
     to,
-    count,
+    amount,
     encodeABI = false,
   }: {
     chain: number
     address?: string
     to: string
-    count: number
+    amount: number
     encodeABI?: boolean
   }) {
     const { instance, account } = new ChainCache().getInstances(chain, address, abiBadge)
-    const countStr = count + ''
+    const countStr = amount + ''
     if (encodeABI) {
       return instance.methods.batchMint(to, countStr).encodeABI()
     }

src/controllers/workflow.controller.ts

@@ -64,6 +64,7 @@ class WorkFlowController extends BaseController {
     }
     const taskObj = {
       id: chainTask.id,
+      chain: chainTask.chain,
       name: chainTask.name,
       desc: chainTask.desc,
       starterName: chainTask.starterName,
@@ -119,7 +120,7 @@ class WorkFlowController extends BaseController {
     // let fileId = 'WWME_g-oYEAAACj738mha3is3XxxDavhb5w'
     // await new WechatWorkService().fetchFile(fileId, true)
     // console.log('11')
-    let spNo = '202305090004'
+    let spNo = '202307120001'
     new TaskQueue().addTaskToQueue(spNo)
     // let task = await ChainTask.findById('642fe42611845ce0e1def316')
     // for (let tid of task.tasks) {

src/models/ChainTask.ts

@@ -7,7 +7,7 @@ import { TaskSvr } from 'service/task.service'
 import { generateRandomBytes32 } from 'utils/wallet.util'
 
 import { BaseModule } from './Base'
-import { ReqTaskStatus, RequestTask, RequestTaskClass } from './RequestTask'
+import { ReqTaskStatus, RequestTask, RequestTaskClass, TaskType } from './RequestTask'
 
 export enum TaskStatus {
   NOTSTART = 0,
@@ -151,9 +151,16 @@ export class ChainTaskClass extends BaseModule {
     if (chainTask.newRecord) {
       let subTask
       let index = 0
+      let count = 0
       for (let sub of data) {
-        if (!subTask || subTask.reqDatas.length >= MAX_BATCH_REQ_COUNT) {
+        if (sub.type == TaskType.MINT_NFT && sub.amount && parseInt(sub.amount) > 1) {
+          count += parseInt(sub.amount)
+        } else {
+          count += 1
+        }
+        if (!subTask || count >= MAX_BATCH_REQ_COUNT) {
           index += 1
+          count = sub.type === TaskType.MINT_NFT && sub.amount && parseInt(sub.amount) > 1 ? parseInt(sub.amount) : 1
           subTask = new RequestTask({
             taskId,
             index,