es，智能刊登队列

es，优惠券记录

es，调价队列

2、增加字典类型92，记录同步的结点，生产已增加

3、增加服务AmazonQueuesCron

4、核心代码，三个es基本一致，以刊登队列代码为例

5、相关文件

优惠券记录es：http://10.158.158.165:9201/aq_autocoupondetail/_search

调价队列es：http://10.158.158.165:9201/aq_adjustpricequeue/_search

增加bi库的同步。

增加三张表

CREATE TABLE `zhcxkj_dw_bi`.`Bi_Aq_AdjustPriceQueue`  (
  `Id` varchar(255) NOT NULL COMMENT '唯一键，对应数据源的UniqueHash',
  `Date` datetime NOT NULL COMMENT '日期 yyyyMMdd格式',
  `OrderSourceID` int NOT NULL  COMMENT '来源渠道ID',
  `OrderSourceSKU` varchar(255) NULL COMMENT '来源渠道SKU',
  `StrategyId` int NOT NULL  COMMENT '策略ID',
  `Strategy` STRING NULL COMMENT '调价策略',
  `FeedSubmissionId` varchar(100) NULL COMMENT '批次号',
  `SKU` varchar(50) NULL COMMENT 'SKU',
  `ASIN` varchar(50) NULL COMMENT 'ASIN',
  `ListingPrice` decimal(10, 4) NOT NULL  COMMENT '原价',
  `Currency` varchar(10) NULL COMMENT '币种',
  `PreDiscountPrice` decimal(10, 4) NULL COMMENT '折前价',
  `DiscountSalesPrice` decimal(10, 4) NULL COMMENT '折后价',
  `DiscountStartTime` datetime NULL COMMENT '打折开始时间',
  `DiscountEndTime` datetime NULL COMMENT '打折结束时间',
  `DiscountRatio` decimal(10, 4) NOT NULL  COMMENT '折扣率',
  `Status` tinyint NOT NULL COMMENT '状态，2-成功，3-失败',
  `SubmitTime` datetime NULL COMMENT '提交时间',
  `ReturnTime` datetime NULL COMMENT '平台返回时间',
  `ErrorCode` varchar(50) NULL COMMENT '错误码',
  `Msg` varchar(2000) NULL COMMENT '消息/错误信息',
  `RetryNum` int NOT NULL  COMMENT '重试数量',
  `AddUserId` int NOT NULL  COMMENT '用户id',
  `AddUserName` varchar(100) NULL COMMENT '用户名称',
  `AddTime` datetime NOT NULL COMMENT '添加时间',
  `UpdateUserId` int NULL COMMENT '修改管理员id',
  `UpdateUserName` varchar(100) NULL COMMENT '修改管理员名称',
  `UpdateTime` datetime NULL COMMENT '修改时间',
  `OrderSourceName` varchar(100) NULL COMMENT '来源渠道名称'
)ENGINE = OLAP PRIMARY KEY(`Id`) COMMENT "调价队列"
DISTRIBUTED BY HASH(`Id`) BUCKETS 8 -- 重要就是这一句，需要分桶
PROPERTIES(
"replication_num" = "3",  -- 副本数为1,默认为3
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false",
"compression" = "LZ4"
); 

CREATE TABLE `zhcxkj_dw_bi`.`Bi_Aq_AutoCouponDetail`  (
  `Id` varchar(255) NOT NULL COMMENT '唯一键，对应数据源的UniqueHash',
`CouponUploadTaskV2ID` bigint  NULL COMMENT '优惠券队列ID',
`CouponId` varchar(200)  NULL COMMENT '优惠券ID',
`OrderSourceID` int  NULL COMMENT '来源渠道ID',        
`OrderSourceSKU` varchar(200)  NULL COMMENT '渠道SKU',        
`UploadStatus` int  NULL COMMENT '上传状态 0等待上传 1 上传成功 2上传失败 3超时未上传',        
`CancelStatus` int  NULL COMMENT '取消状态 0不取消 1 待取消 2已取消  ',        
`SKU` varchar(50)  NULL COMMENT 'SKU',        
`ASIN` varchar(50)  NULL COMMENT 'ASIN',        
`SiteCode` varchar(10)  NULL COMMENT '站点',        
`DiscountValue` decimal(10,4)  NULL COMMENT '折扣点',
`DiscountType` varchar(50)  NULL COMMENT '折扣类型,折扣类型分为百分比和金额',        
`BudgetUnits` decimal(10,4)  NULL COMMENT '优惠券预算数量 Ca站点使用',        
`BudgetType` varchar(50)  NULL COMMENT '预算类型  分为金额和数量',        
`Budget` decimal(10,4)  NULL COMMENT '预算金额',        
`StartDate` DateTime  NULL COMMENT '开始时间',        
`EndDate` DateTime  NULL COMMENT '结束时间',        
`TargetCustomers` varchar(200)  NULL COMMENT '目标买家',        
`IsPerCustomer` tinyint  NULL COMMENT '限制买家只能兑换一次',        
`FailureReason` varchar(500)  NULL COMMENT '失败原因',
`AddTime` DateTime  NULL COMMENT '添加时间',
`UpdateTime` DateTime  NULL COMMENT '修改时间',
`OrderSourceName` varchar(100)  NULL COMMENT '来源渠道名称'
)ENGINE = OLAP PRIMARY KEY(`Id`) COMMENT "优惠券队列"
DISTRIBUTED BY HASH(`Id`) BUCKETS 8 -- 重要就是这一句，需要分桶
PROPERTIES(
"replication_num" = "3",  -- 副本数为1,默认为3
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false",
"compression" = "LZ4"
); 

CREATE TABLE `zhcxkj_dw_bi`.`Bi_Aq_AutoPublishUploadProduct`  (
`Id` VARCHAR(255) not NULL COMMENT '唯一键,对应数据源的UniqueHash',
  `SiteCode` VARCHAR(10)  NULL COMMENT '站点',
`Date` DateTime  NULL COMMENT '日期 yyyyMMdd格式',
`QueueID` bigint  NULL COMMENT '关联刊登结果队列ID',
`OrderSourceID` int  NULL COMMENT '来源渠道ID',
`OrderSourceName` VARCHAR(100)  NULL COMMENT '来源渠道名',
`OrderSourceSKU` VARCHAR(100)  NULL COMMENT '来源渠道SKU',
`OrderSourceSKUID` int  NULL COMMENT '渠道SKUID',
`SKU` VARCHAR(50)  NULL COMMENT '系统SKU',
`ProductName` VARCHAR(2000)  NULL COMMENT '产品英文名',
`ProductNameCN` VARCHAR(2000)  NULL COMMENT '产品中文名',
`ASIN` VARCHAR(50)  NULL COMMENT 'ASIN',
`IsVariation` TINYINT  NULL COMMENT '是否变体',
`IsParent` TINYINT  NULL COMMENT '是否母体',
`ParentSKU` VARCHAR(50)  NULL COMMENT '母体SKU',
`VariantGroup` VARCHAR(200)  NULL COMMENT '变体组合',
`Currency` VARCHAR(10)  NULL COMMENT '币种',
`Price` decimal(10,4)  NULL COMMENT '价格',
`BrandAddTitle` TINYINT  NULL COMMENT '品牌是否添加到title',
`UPCorEAN` VARCHAR(50)  NULL COMMENT 'UPCorEAN',
`IsNeedUPCorEAN` TINYINT  NULL COMMENT '是否需要判断UPCorEAN',
`RetryNum` int  NULL COMMENT '重试次数',
`Status` TINYINT  NULL COMMENT '刊登产品状态',
`TranslateStatus` TINYINT  NULL COMMENT '翻译状态',
`PublishType` TINYINT  NULL COMMENT '刊登类型',
`ErrorCode` VARCHAR(50)  NULL COMMENT '错误码',
`Msg` VARCHAR(8000)  NULL COMMENT 'Msg',
`Attributes` STRING  NULL COMMENT '原刊登属性集合',
`TranslateAttributes` STRING  NULL COMMENT '翻译属性集合',
`AddUserId` int  NULL COMMENT 'User Id',
`AddUserName` VARCHAR(100)  NULL COMMENT '添加用户',
`AddTime` DateTime  NULL COMMENT '添加时间',
`UpdateUserId` int  NULL COMMENT '修改管理员id',
`UpdateUserName` VARCHAR(100)  NULL COMMENT '修改管理员名称',
`UpdateTime` DateTime  NULL COMMENT '修改时间',
`CategoryNamePath` VARCHAR(2000)  NULL COMMENT '刊登分类',
`AsinUrl` VARCHAR(1000)  NULL COMMENT 'asin地址',
`FeedSubmissionId` VARCHAR(100)  NULL COMMENT '批次编号'
)ENGINE = OLAP PRIMARY KEY(`Id`) COMMENT "智能刊登队列"
DISTRIBUTED BY HASH(`Id`) BUCKETS 8 -- 重要就是这一句，需要分桶
PROPERTIES(
"replication_num" = "3",  -- 副本数为1,默认为3
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false",
"compression" = "LZ4"
); 
相关文件

测试数据