From 5898e5a15ddd4eb410539f2752c7c3cce6407082 Mon Sep 17 00:00:00 2001 From: "Mr.Li" Date: Sun, 23 Apr 2023 16:38:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=B9=E9=87=8F=E8=AE=A2=E5=8D=95=E5=AF=BC?= =?UTF-8?q?=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config/config.yaml | 120 ++++++++++++++++++++++++++++++++++++++++++--- 1 file changed, 113 insertions(+), 7 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index f8d79b3..dfc93f7 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -220,8 +220,114 @@ system: timestamp: true order: "o.create_time,o.order_number" file: "直连天下-下游订单-{begin}-{end}-{task}.xlsx" - size: 100000 + size: 1000000 + - name: "余额信息" + tasks: + - pk: + sql: >- + SELECT + b.reseller_id AS `分销商编号`, + r.`name` AS `简称`, + r.full_name AS `全称`, + balance AS `余额`, + rbd.day_balance as `日余额`, + extension AS `授信` + FROM + reseller_balance b + LEFT JOIN reseller r ON r.id = b.reseller_id + left join reseller_balance_day rbd on rbd.reseller_id = b.reseller_id and rbd.`day` = DATE_FORMAT(date_add('{end}', interval -1 day),"%Y-%m-%d") + elt: "r.`status` = 1" + timestamp: + order: "" + file: "直连天下-余额信息-{end}.xlsx" + size: 1000000 + - name: "批量充值" + tasks: + - pk: "流水号" + sql: >- + SELECT + bd.customer as `分销商`, + r.`name`, + bd.price as `商品价格`, + od.ours_product_id as `我们的商品id`, + op.NAME as `商品名称`, + p.name as `接口平台`, + CASE od.`status` + WHEN -6 THEN '手动失败' + WHEN -5 THEN '手动重试' + WHEN -3 THEN '卡单' + WHEN -2 THEN '失败重试' + WHEN -1 THEN '充值失败' + WHEN 0 THEN '待充值' + WHEN 1 THEN '充值成功' + WHEN 2 THEN '充值中' + else od.`status` + END + AS 充值状态, + pp.`code` as `接口平台产品编码`, + od.order_order_number as `系统订单号`, + od.serial_number as `流水号`, + od.terminal_account as `充值账号`, + od.trade_price as `成交价格`, + od.platform_price as `接口平台价格`, + od.create_time as `创建时间`, + od.execute_time as `执行时间`, + bd.ding_talk_sn as `钉钉审批序号`, + bd.remark as `批量备注` + FROM + order_direct od -- FORCE INDEX(idx_direct_create_time) + left JOIN ours_product op ON od.ours_product_id = op.id + left join platform_product pp on pp.id = od.platform_product_id + left join platform p on pp.platform_id = p.id + RIGHT JOIN batch_direct bd on bd.batch_id = od.order_order_number + LEFT JOIN reseller r on r.id = bd.reseller_id + elt: "bd.create_time BETWEEN {begin} AND {end} and od.serial_number > '{last}'" + timestamp: true + order: "od.create_time,od.serial_number" + - pk: "流水号" + sql: >- + SELECT + bd.customer as `分销商`, + r.`name`, + bd.price as `商品价格`, + od.ours_product_id as `我们的商品id`, + op.NAME as `商品名称`, + p.name as `接口平台`, + CASE od.`status` + WHEN -6 THEN '手动失败' + WHEN -5 THEN '手动重试' + WHEN -3 THEN '卡单' + WHEN -2 THEN '失败重试' + WHEN -1 THEN '充值失败' + WHEN 0 THEN '待充值' + WHEN 1 THEN '充值成功' + WHEN 2 THEN '充值中' + else od.`status` + END + AS 充值状态, + pp.`code` as `接口平台产品编码`, + od.order_order_number as `系统订单号`, + od.serial_number as `流水号`, + od.terminal_account as `充值账号`, + od.trade_price as `成交价格`, + od.platform_price as `接口平台价格`, + od.create_time as `创建时间`, + od.execute_time as `执行时间`, + bd.ding_talk_sn as `钉钉审批序号`, + bd.remark as `批量备注` + FROM + history_order_direct od + left JOIN ours_product op ON od.ours_product_id = op.id + left join platform_product pp on pp.id = od.platform_product_id + left join platform p on pp.platform_id = p.id + RIGHT JOIN batch_direct bd on bd.batch_id = od.order_order_number + LEFT JOIN reseller r on r.id = bd.reseller_id + elt: "bd.create_time BETWEEN {begin} AND {end} and od.serial_number > '{last}'" + timestamp: true + order: "od.create_time,od.serial_number" + file: "直连天下-批量充值-{begin}-{end}-{task}.xlsx" + size: 1000000 - name: "营销系统" db: "root:lhb767@tcp(120.79.35.82:3307)/market?charset=utf8mb4&parseTime=True" jobs: @@ -270,7 +376,7 @@ system: timestamp: false order: "o.create_time,o.order_number" file: "营销系统-订单信息-{begin}-{end}-{task}.xlsx" - size: 10000 + size: 1000000 - name: "雅兰芳" db: "root:lhb767@tcp(120.79.35.82:3307)/new_sys?charset=utf8mb4&parseTime=True" @@ -302,7 +408,7 @@ system: elt: "order_card.create_time BETWEEN {begin} AND {end} and order_card.order_number > {last}" order: "order_card.create_time,order_card.order_number" file: "雅兰芳-卡密订单-{begin}-{end}-{task}.xlsx" - size: 10000 + size: 1000000 - name: "上游订单" tasks: - pk: "流水号" @@ -352,7 +458,7 @@ system: elt: "od.create_time BETWEEN '{begin}' and '{end}' and od.serial_number > {last}" order: "od.create_time,od.serial_number" file: "雅兰芳-上游订单-{begin}-{end}-{task}.xlsx" - size: 10000 + size: 1000000 - name: "下游订单" tasks: - pk: "订单号" @@ -403,7 +509,7 @@ system: timestamp: true order: "o.create_time,o.order_number" file: "雅兰芳-下游订单-{begin}-{end}-{task}.xlsx" - size: 10000 + size: 1000000 - name: "创意择优" db: "root:lhb767@tcp(120.79.35.82:3307)/new_sys?charset=utf8mb4&parseTime=True" @@ -435,7 +541,7 @@ system: elt: "order_card.create_time BETWEEN {begin} AND {end} and order_card.order_number > {last}" order: "order_card.create_time,order_card.order_number" file: "创意择优-卡密订单-{begin}-{end}-{task}.xlsx" - size: 10000 + size: 1000000 - name: "上游订单" tasks: - pk: "流水号" @@ -536,4 +642,4 @@ system: timestamp: true order: "o.create_time,o.order_number" file: "创意择优-下游订单-{begin}-{end}-{task}.xlsx" - size: 10000 \ No newline at end of file + size: 1000000 \ No newline at end of file