TASK#35638 冷同步热：存在FBA的Listing时，同国家同ASIN的冷数据Listing变为热 / 亚马逊Listing迁移 V2.0

任务描述

开发要点（12H）：

冷数据转热数据条件：ERP出现一条转FBA的Listing（具体的匹配条件以需求为准），冷库中其他自发货一起转热数据。

1、由于ListingFBA的数据来源较多，不在各个触发点去执行逻辑。在在售报告中同步，增加FBA状态更新时间。(2H)

2、初始化历史FBA数据（1H）

3、新增一个增量服务，对变更为FBA的数据，跟冷库中的数据进行核对，如果存在有冷库数据，符合转热数据条件的，触发转热逻辑。（5H）

4、这里由于要检索相同ASin、相同国家的数据，如果使用base表会导致跨部门多次查询，考虑引入聚合的StartRocks数据库（2H）

5、数据调试（2H）

需求描述：

冷数据表新增一个每天跑的定时服务，从在售报告表获取所有FBA的ASIN数据匹配（国家+ASIN相同）冷数据库中为冷数据状态的Listing；如果存在Listing能够匹配上，则Listing状态变为热数据并且同步Listing至热数据表。

同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值

需求描述

需求描述：

同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值

验收标准

暂无

历史记录

2023-02-06 10:47:09, 由 王翔宇 创建。
2023-02-06 10:47:23, 由 王翔宇 指派给肖雄。
修改了 指派给，旧值为 "wangxiangyu"，新值为 "xiaoxiong"。
2023-02-06 18:50:01, 由肖雄记录工时，消耗 8 小时。
修改了 总计消耗，旧值为 "0"，新值为 "8"。
修改了 预计剩余，旧值为 "12"，新值为 "4"。
修改了 任务状态，旧值为 "wait"，新值为 "doing"。
修改了 实际开始，旧值为 "0000-00-00 00:00:00"，新值为 "2023-02-06"。

2023-02-07 16:59:18, 由肖雄完成。

修改了 总计消耗，旧值为 "8"，新值为 "12"。
修改了 指派给 ，旧值为 "xiaoxiong"，新值为 "wangxiangyu"。
修改了 实际完成，旧值为 ""，新值为 "2023-02-07 15:58:07"。
修改了 任务状态，旧值为 "doing"，新值为 "done"。
修改了 预计剩余，旧值为 "4"，新值为 "0"。
修改了 由谁完成，旧值为 ""，新值为 "xiaoxiong"。

一、添加字段

alter table aml_amazon_product_base add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep81 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep84 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep85 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep86 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep87 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep88 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep89 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep123 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep410 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep500 add  ChangeToFBATime datetime;
alter table aml_amazon_product_base_dep9999 add  ChangeToFBATime datetime;

添加索引：

alter  table  aml_amazon_product_base  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep81  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep84  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep85  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep86  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep87  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep88  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep89  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep123  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep410  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep500  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);
alter  table  aml_amazon_product_base_dep9999  add  index  `idx_ConvertFBA` (`CustomerID`,`OrderSourceID`,`IsHotData`,`IsDelete`,`ChangeToFBATime`);

二、配置任务ColdListingToERPHotListingByChangeToFBACron

三、自测

同步销售报告更新为FAB

select *From Aml_AmazonListing_Report_Queue where id=5503;

转FBA同步到热库

SELECT * FROM `aml_amazon_product_base_dep87` where OrderSourceID in('8056')

select *From RB_Amazon_Product_Base_ColdHot_Temp;

四、svn提交

任务35638，冷同步热：存在FBA的Listing时，同国家同ASIN的冷数据Listing变为热

2023-02-07 20:24:48, 由 王翔宇 指派给肖雄。
修改了 指派给，旧值为 "wangxiangyu"，新值为 "xiaoxiong"。
2023-02-08 15:38:54, 由肖雄编辑。
修改了 任务描述，区别为：
002-
002+
003- ~~冷数据转热数据条件：ERP出现一条转FBA的Listing（具体的匹配条件以需求为准），冷库中其他自发货一起转热数据。~~
003+ 冷数据转热数据条件：ERP出现一条转FBA的Listing（具体的匹配条件以需求为准），冷库中其他自发货一起转热数据。
004- ~~1、由于ListingFBA的数据来源较多，不在各个触发点去执行逻辑。在在售报告中同步，增加FBA状态更新时间。(2H)~~
004+ 1、由于ListingFBA的数据来源较多，不在各个触发点去执行逻辑。在在售报告中同步，增加FBA状态更新时间。(2H)
005- ~~2、初始化历史FBA数据（1H）~~
005+ 2、初始化历史FBA数据（1H）
006- ~~3、新增一个增量服务，对变更为FBA的数据，跟冷库中的数据进行核对，如果存在有冷库数据，符合转热数据条件的，触发转热逻辑。（5H）~~
006+ 3、新增一个增量服务，对变更为FBA的数据，跟冷库中的数据进行核对，如果存在有冷库数据，符合转热数据条件的，触发转热逻辑。（5H）
007- ~~4、这里由于要检索相同ASin、相同国家的数据，如果使用base表会导致跨部门多次查询，考虑引入聚合的StartRocks数据库（2H）~~
007+ 4、这里由于要检索相同ASin、相同国家的数据，如果使用base表会导致跨部门多次查询，考虑引入聚合的StartRocks数据库（2H）
008- ~~5、数据调试（2H）~~
008+ 5、数据调试（2H）
009-
009+
010-
010+
012-
012+ 需求描述：
013- ~~需求描述：~~
013+ 冷数据表新增一个每天跑的定时服务，从在售报告表获取所有FBA的ASIN数据匹配（国家+ASIN相同）冷数据库中为冷数据状态的Listing；如果存在Listing能够匹配上，则Listing状态变为热数据并且同步Listing至热数据表。
014- 冷数据表新增一个每天跑的定时服务，从在售报告表获取所有FBA的ASIN数据匹配（国家+ASIN相同）冷数据库中为冷数据状态的Listing；如果存在Listing能够匹配上，则Listing状态变为热数据并且同步Listing至热数据表。
014+
015-
015+ 同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值
016- ~~同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值~~
016+ <a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener">
017- ~~<a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="/zentao/file-read-240503.png" alt="" />~~

002- ~~<p style="font-size:14px;background-color:#FFFFFF;">~~
002+ <p style="font-size:14px;background-color:#FFFFFF;"><br /></p>
003- ~~</p><div style="font-size:14px;">冷数据转热数据条件：ERP出现一条转FBA的Listing（具体的匹配条件以需求为准），冷库中其他自发货一起转热数据。</div>~~
003+ <div style="font-size:14px;">冷数据转热数据条件：ERP出现一条转FBA的Listing（具体的匹配条件以需求为准），冷库中其他自发货一起转热数据。</div>
004- ~~<p style="font-size:14px;">1、由于ListingFBA的数据来源较多，不在各个触发点去执行逻辑。在在售报告中同步，增加FBA状态更新时间。(2H)</p>~~
004+ <p style="font-size:14px;">1、由于ListingFBA的数据来源较多，不在各个触发点去执行逻辑。在在售报告中同步，增加FBA状态更新时间。(2H)</p>
005- ~~<p style="font-size:14px;">2、初始化历史FBA数据（1H）</p>~~
005+ <p style="font-size:14px;">2、初始化历史FBA数据（1H）</p>
006- <div style="font-size:14px;">3、新增一个增量服务，对变更为FBA的数据，跟冷库中的数据进行核对，如果存在有冷库数据，符合转热数据条件的，触发转热逻辑。（5H）</div>
006+ <div style="font-size:14px;">3、新增一个增量服务，对变更为FBA的数据，跟冷库中的数据进行核对，如果存在有冷库数据，符合转热数据条件的，触发转热逻辑。（5H）</div>
007- ~~<div style="font-size:14px;">4、这里由于要检索相同ASin、相同国家的数据，如果使用base表会导致跨部门多次查询，考虑引入聚合的StartRocks数据库（2H）</div>~~
007+ <div style="font-size:14px;">4、这里由于要检索相同ASin、相同国家的数据，如果使用base表会导致跨部门多次查询，考虑引入聚合的StartRocks数据库（2H）</div>
008- ~~<div style="font-size:14px;">5、数据调试（2H）</div>~~
008+ <div style="font-size:14px;">5、数据调试（2H）</div>
009- ~~<div style="font-size:14px;"></div>~~
009+ <div style="font-size:14px;"></div>
010-
010+ <p style="font-size:14px;background-color:#FFFFFF;"><br /></p>
012- ~~<p style="font-size:14px;background-color:#FFFFFF;"><br /></p>~~
012+ <p style="font-size:14px;background-color:#FFFFFF;">需求描述：</p>
013- ~~<p style="font-size:14px;background-color:#FFFFFF;">需求描述：</p>~~
013+ <p style="font-size:14px;background-color:#FFFFFF;">冷数据表新增一个每天跑的定时服务，从在售报告表获取所有FBA的ASIN数据匹配（国家+ASIN相同）冷数据库中为冷数据状态的Listing；如果存在Listing能够匹配上，则Listing状态变为热数据并且同步Listing至热数据表。</p>
014- <p style="font-size:14px;background-color:#FFFFFF;">冷数据表新增一个每天跑的定时服务，从在售报告表获取所有FBA的ASIN数据匹配（国家+ASIN相同）冷数据库中为冷数据状态的Listing；如果存在Listing能够匹配上，则Listing状态变为热数据并且同步Listing至热数据表。</p>
014+ <p style="font-size:14px;background-color:#FFFFFF;"><br /></p>
015- ~~<p style="font-size:14px;background-color:#FFFFFF;"><br /></p>~~
015+ <p style="font-size:14px;background-color:#FFFFFF;">同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值</p>
016- ~~<p style="font-size:14px;background-color:#FFFFFF;">同步字段：冷数据库有且热数据表也存在的字段，其他字段默认不赋值</p>~~
016+ <p style="font-size:14px;background-color:#FFFFFF;"><a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="{240503.png}" alt="" /></a></p>
017- ~~<p style="font-size:14px;background-color:#FFFFFF;"><a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="/zentao/file-read-240503.png" alt="" /></a></p>~~

验证：

delete RB_Amazon_Product_Base_ColdData where CustomerID=1 and OrderSourceSKUID in(1086151750,1092360073);
delete RB_Amazon_Product_Base_ColdHot_Temp where CustomerID=1 and OrderSourceSKUID in(1086151750,1092360073);
一、先修改冷库数据为非FBA且为冷数据
UPDATE aml_amazon_product_base_dep86 SET IsFBA=0,IsHotData=0,ChangeToFBATime=null WHERE CustomerID=1 AND id IN(25372,25401);
二、同步一次在售服务（OnSalesReportToColdListingCron）
服务会将当前记录修改为转FBA数据，且更新字段ChangeToFBATime、IsFBA
SELECT ChangeToFBATime,IsFBA from aml_amazon_product_base_dep86 WHERE CustomerID=1 AND OrderSourceSKUID IN(1086151750,1092360073)
三、同步FBA转热数据服务（ColdListingToERPHotListingByChangeToFBACron）
此时数据会修改为热数据且提交到热数据库表
2023-02-13 11:20:19, 由 王翔宇 编辑。
修改了 相关需求，旧值为 "0"，新值为 "13519"。
修改了 需求版本，旧值为 "1"，新值为 "3"。
修改了 任务描述，区别为：
016- ~~<a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="/zentao/file-read-240503.png" alt="" />~~
016+ <a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener">

016- ~~<p style="font-size:14px;background-color:#FFFFFF;"><a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="/zentao/file-read-240503.png" alt="" /></a></p>~~
016+ <p style="font-size:14px;background-color:#FFFFFF;"><a href="/zentao/file-read-240503.png" target="_blank" rel="noreferrer noopener"><img src="{240503.png}" alt="" /></a></p>
2023-03-23 09:00:50, 由肖雄关闭。
修改了 任务状态，旧值为 "done"，新值为 "closed"。
修改了 指派给 ，旧值为 "xiaoxiong"，新值为 "closed"。
修改了 由谁关闭，旧值为 ""，新值为 "xiaoxiong"。
修改了 关闭时间，旧值为 "0000-00-00 00:00:00"，新值为 "2023-03-23 09:00:50"。
修改了 关闭原因，旧值为 ""，新值为 "done"。

基本信息
任务的一生

所属迭代	亚马逊Listing迁移 V2.0
所属模块	/
相关需求	亚马逊Listing迁移符合热数据条件时从冷库同步热库（责任人：梁贵荣）
指派给	Closed 于 2023-03-23 09:00:50
任务类型	后端
任务标签	初始
开发组	运营开发组
任务状态	已关闭
进度	100%
优先级	P2
关键词
抄送给

由谁创建	王翔宇于 2023-02-06 10:47:09
由谁完成	肖雄于 2023-02-07 15:58:07
由谁取消	暂无
由谁关闭	肖雄于 2023-03-23 09:00:50
关闭原因	已完成
最后编辑	肖雄于 2023-03-23 09:00:50

团队	最初预计	总计消耗	预计剩余

工时信息

最初预计	12工时
总计消耗	12工时
预计剩余	0工时
预计开始	0000-00-00
实际开始	2023-02-06
截止日期	2023-02-07