批量充值数据
This commit is contained in:
Mr.Li
parent
913442aa7f
commit
f1d9e7d140
|
|
@ -510,6 +510,113 @@ system:
|
|||
order: "o.create_time,o.order_number"
|
||||
file: "雅兰芳-下游订单-{begin}-{end}-{task}.xlsx"
|
||||
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)/new_sys?charset=utf8mb4&parseTime=True"
|
||||
|
|
@ -642,4 +749,111 @@ system:
|
|||
timestamp: true
|
||||
order: "o.create_time,o.order_number"
|
||||
file: "创意择优-下游订单-{begin}-{end}-{task}.xlsx"
|
||||
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
|
||||
Loading…
Reference in New Issue