Commit 86db86f5 by zhiwj

批量导入

parent cb185b9d
......@@ -2,6 +2,7 @@ package com.gic.store.service.impl;
import com.gic.api.base.commons.ServiceResponse;
import com.gic.commons.util.GlobalInfo;
import com.gic.store.constant.Constants;
import com.gic.store.constant.CreateTypeEnum;
import com.gic.store.dto.*;
import com.gic.store.entity.TabStoreBrand;
......@@ -168,8 +169,8 @@ public class StoreTaskServiceImpl extends AbstractTaskAllocationOperation implem
InitTaskQo initTaskQo = new InitTaskQo();
initTaskQo.setEnterpriseId(enterpriseId.toString());// 企业id
initTaskQo.setOperationUserId(userId);// 操作人id
initTaskQo.setTaskMqKey(GlobalInfo.MQ_ROUTER_BATCH_TMPSTORE);// 注册的队列名称
initTaskQo.setTaskType(GlobalInfo.TASK_TYPE_BATCH_IMPORT_STORE);// 任务类型
initTaskQo.setTaskMqKey(Constants.STORE_BATCH_IMPORT_MQ_KEY);// 注册的队列名称
initTaskQo.setTaskType(Constants.STORE_BATCH_IMPORT_TASK_TYPE);// 任务类型
initTaskQo.setParams(enterpriseId.toString());// 你自己处理需要的参数
initTaskQo.setTaskSignKey(uuId);// 任务类型 唯一标识符
TaskAllocationSdkClient instance = TaskAllocationSdkClient.getInstance();// 初始化sdk
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment