1、核验同步过程同商户listing插表(m_allegro_listing)成功/失败 队列中间表(m_allegro_listing_productid)状态更新 (验证截图)
2、SQL统计
1)自动刊登表有记录,队列中间表没有数据的数据统计SQL,
2)将步骤1)的结果插入队列中间表SQL
1、核验同步过程同商户listing插表(m_allegro_listing)成功/失败 队列中间表(m_allegro_listing_productid)状态更新 (验证截图)
2、SQL统计
1)自动刊登表有记录,队列中间表没有数据的数据统计SQL,
2)将步骤1)的结果插入队列中间表SQL
需求背景:
Allegro 平台数据同步存在延迟/数据插入listing表异常等问题,建立需求,统一优化
需求价值:
控制风险:解决因为listing数据不一致造成的其余业务堵塞/执行错误的问题(自动调价,自动补货,自动下架,重新刊登等)
需求内容:
001-Allegro平台数据同步优化V1_listing同步优化
001+ Allegro平台数据同步优化V1_listing同步中间表状态验证
001-Allegro平台数据同步优化V1_listing同步优化
001+ Allegro平台数据同步优化V1_listing同步中间表状态验证
| 所属迭代 | 综合平台智能刊登系统优化专项 |
|---|---|
| 所属模块 | / |
| 相关需求 | Allegro平台数据同步优化V1 |
| 指派给 | Closed 于 2023-01-18 09:20:36 |
| 任务类型 | 后端 |
| 任务标签 | 初始 |
| 开发组 | |
| 任务状态 | 已关闭 |
| 进度 | 100% |
| 优先级 | P1 |
| 关键词 | |
| 抄送给 |
| 由谁创建 | 韦思成 于 2022-08-23 20:00:58 |
|---|---|
| 由谁完成 | 韦思成 于 2022-08-24 19:27:36 |
| 由谁取消 | 暂无 |
| 由谁关闭 | 韦思成 于 2023-01-18 09:20:36 |
| 关闭原因 | 已完成 |
| 最后编辑 | 韦思成 于 2023-01-18 09:20:36 |
| 团队 | 最初预计 | 总计消耗 | 预计剩余 |
|---|
| 最初预计 | 8工时 |
|---|---|
| 总计消耗 | 9工时 |
| 预计剩余 | 0工时 |
| 预计开始 | 2022-08-24 |
| 实际开始 | 2022-08-24 |
| 截止日期 | 2022-08-24 |
1、Allegro 自动刊登队列表有记录 listing表无记录SQL
select COUNT(1) from ap_autopublish_allegro_queue a left join m_allegro_listing b on a.CustomerId = b.CustomerId and a.OrderSourceId = b.OrderSourceId
and a.SellerSku = b.SellerSku
where a.`Status` ='success' and DATE_ADD(a.CreationTime,INTERVAL 8 HOUR) >CURDATE()
and b.SellerSku is NULL and DATE_ADD(b.CreationTime,INTERVAL 8 HOUR) >CURDATE();
2、动刊登队列表与同步中间表
-- 2.1)Allegro 自动刊登队列表有记录 同步中间表无记录SQL
select a.OrderSourceId,a.SellerSku,0,'',20220824, NOW(),0,'系统管理员(人工生成)',NOW(), 0,'系统管理员(人工生成)',NOW() from ap_autopublish_allegro_queue a left join
m_allegro_listing_productid b on a.OrderSourceId=b.OrderSourceId
and a.SellerSku=b.SellerSku and b.id is null
where a.CustomerId=1 and a.`Status`='success' and a.Date=20220824
-- 将2.1) 插入 同步中间表
-- INSERT IGNORE INTO m_allegro_listing_productid(OrderSourceId,SellerSku,`Status`,`FailureLog`,Date,Time,CreatorId,Creator,CreationTime,LastModifierId,LastModifier,LastModificationTime)
select a.OrderSourceId,a.SellerSku,0,'',20220824, NOW(),0,'系统管理员(人工生成)',NOW(), 0,'系统管理员(人工生成)',NOW() from ap_autopublish_allegro_queue a left join
m_allegro_listing_productid b on a.OrderSourceId=b.OrderSourceId
and a.SellerSku=b.SellerSku and b.id is null
where a.CustomerId=1 and a.`Status`='success' and a.Date=20220824
3、同步中间表与listing表
-- 3.1)Allegro同步中间表(成功状态)有 listing表无记录SQL
select COUNT(*) from m_allegro_listing_productid a left join
m_allegro_listing b on a.OrderSourceId=b.OrderSourceId
and a.SellerSku=b.SellerSku and b.id is null
where a.CustomerId=1 and a.`Status`=1 and a.Date=20220823
-- 将3.1) 插入 同步中间表
-- INSERT IGNORE INTO m_allegro_listing_productid(OrderSourceId,ProductId,SellerSku,`Status`,`FailureLog`,Date,Time,CreatorId,Creator,CreationTime,LastModifierId,LastModifier,LastModificationTime,PrimaryImage)
select a.OrderSourceId,a.ProductId,a.SellerSku,0,'',20220824, NOW(),0,'系统管理员(人工生成)',NOW(), 0,'系统管理员(人工生成)',NOW(),PrimaryImage from m_allegro_listing_productid a left join
m_allegro_listing b on a.OrderSourceId=b.OrderSourceId
and a.SellerSku=b.SellerSku and b.id is null
where a.CustomerId=1 and a.`Status`=1 and a.Date=20220823