链接
2026-01-07 21:40:14 0 举报图片
作者其他创作
大纲/内容
数量大于允许最大任务同时执行并发量
创建sku并绑定店内分类
拿到上面任务List进行迭代处理
更新总任务表task_status=SUCCESS
更新建品任务表条件：taskStatus=ERROR
否
总任务表cateTota>0
根据taskId查询到门店一级分类信息循环处理以下
根据美团提供的一级分类名称和到家名称匹配
创建spu并绑定店内分类
下次work执行
是
更新建品任务表条件：taskStatus=SUCCESS
查询建品任务表条件：taskStatus=SUCCESS
结束
SUCCESS
更新总任务表店内分类状态shopCateStatus=ERROR
任务中店内分类状态
selectTasks
总任务表(superTotal)实际同步搬品数量
获取到到家一级分类id
调海博接口创建搬品任务
结果
下次worker执行
更新总任务表task_status=DOING
更新店内分类表字段:status=INITIAL
查询总任务表task_status=DOINGshopCateStatus=SUCCESS的数据返回
更新总任务task_staus=ERROR结束(下次work不执行)
接收到消息(消息体)1.authorizeCode2.orgCode3.stationNo
更新总任务表task_status=ERROR
成功
循环创建店内二级分类
拿到上面任务IdList进行迭代处理
查询总任务表task_status=DOING的数据返回
execute
创建一级店内分类
不成功
ERROR
否(0)
更新店内分类表（一级分类）status=ERROR
失败
所有分类的状态!=INITIAL
是否成功
更新店内分类（二级）status=ERROR
有
更新店内分类(二级)status=SUCCESS
循环结束更新店内分类(一级)status=SUCCESS
superTotal大于0
查询当前任务id下的所有店内分类信息
门店分类worker
匹配结果
数据统计worker
创建结果
非SUCCESS
更新总任务表字段1:orgCode字段2:stationNo 字段3:task_status=DOING
判断sku.size>1
上述查询数量==0
查询总任务表task_status=DOINGshopCateStatus=INITIALcateTotal=0的数据返回
消息消费者
更新店内分类表字段1:orgCode字段2:status=INITIAL
查询总任务表task_status=DOING的数量
更新总任务表店内分类状态shopCateStatus=SUCCESS
查询建品任务表条件：taskStatus=INITIAL，DOING
查询总任务表task_status=INITIAL的数据返回
建品worker
查询店内分类表是否有数据
总任务worker
无
0 条评论
下一页
