Skip to content

S
script
Commit 9a5f9491 by 蘑菇🍄
Options

dev 状态对应

parent 2bf8ae83
Showing with 115 additions and 55 deletions
jnby-pomme/函数.sql
drop function if exists clearTempImportData;
drop function if exists clearTempImportData;
......@@ -17,7 +17,7 @@ begin-- 函数头
delete from tab_gic_mall_collection_copy ;
delete from tab_gic_mall_evaluate_copy ;
delete from tab_gic_mall_order_batch_deliver_log_copy ;
-- delete from `3.0`.tab_gic_member_address_copy;
delete from `gic3.0`.tab_gic_member_address_copy;
delete from tab_gic_mall_shopping_cart_copy;
......
jnby-pomme/数据组装dev.sql
......@@ -13,20 +13,22 @@ delete from tab_gic_mall_order_refund_logistics_copy ;
delete from tab_gic_mall_collection_copy ;
delete from tab_gic_mall_evaluate_copy ;
delete from tab_gic_mall_order_batch_deliver_log_copy ;
delete from tab_gic_member_address_copy
delete from `gic3_test`.tab_gic_member_address_copy;
delete from tab_gic_mall_shopping_cart_copy;
-- 订单地址所在区域
update order_import A inner join(select county_id,full_name from `gic3.0`.tab_gic_county ) c
-- 订单地址所在区域
update order_import A inner join(select county_id,full_name from `gic3.0`.tab_gic_county ) c
on
(
locate(A.province_name,c.full_name) >0
and locate(A.city_name,c.full_name) >0
and locate(A.area_name,c.full_name) >0
)
(locate(A.province_name,c.full_name) >0 and locate(A.city_name,c.full_name) >0 and locate(A.area_name,c.full_name) >0)
set A.area_id = c.county_id
;
update order_member_address A inner join(select county_id,full_name from `gic3.0`.tab_gic_county ) c
on
(locate(A.province,c.full_name) >0 and locate(A.city,c.full_name) >0 and locate(A.area,c.full_name) >0)
set A.county_id = c.county_id
;
-- 把没有的地址保存起来
INSERT INTO `gic3.0`.`tab_gic_member_address_copy`
......@@ -38,22 +40,20 @@ and locate(A.area_name,c.full_name) >0
, `nationcode`, `clique_id`, `clique_member_id`, `ecommerce_buyer_id`, `subscribe_status`
)
select replace(uuid(), '-', '') as member_address_id, members_view.member_id,null as member_personal_id,0 as is_default,1 as address_type
,oi.address_info address
,oi.area_id as county_id,null as longitude,null as latitude,now() as create_time,now() as update_time,1 as status
,members_view.enterprise_id,oi.buyer_name,oi.buyer_phone as phone_number
,null as nationcode,members_view.clique_id,members_view.clique_member_id,-1 as ecommerce_buyer_id,1 as subscribe_status
FROM order_import oi
left join `gic3.0`.tab_gic_member_pommedeterre members_view on members_view.card_num = oi.member_card_num
where
NOT EXISTS(
SELECT address FROM `gic3.0`.tab_gic_member_address addr WHERE addr.address = oi.address_info
and addr.member_id = members_view.member_id
)
GROUP BY oi.address_info
select replace(uuid(), '-', '') as member_address_id, members_view.member_id,null as member_personal_id,addr.isdefault as is_default,1 as address_type
,addr.address
,addr.county_id ,null as longitude,null as latitude,now() as create_time,now() as update_time,1 as status
,members_view.enterprise_id,addr.buyer_name,addr.buyer_moile as phone_number
,null as nationcode,members_view.clique_id,members_view.clique_member_id,-1 as ecommerce_buyer_id,s.unsubscribe as subscribe_status
FROM order_member_address addr
left join `gic3_test`.members_view on members_view.card_num = addr.member_number
left join `gic3_test`.tab_gic_member_sms s on s.phone_number = addr.buyer_moile
GROUP BY addr.member_number,addr.address_info
;
-- tab_gic_mall_order
INSERT INTO `tab_gic_mall_order_copy`
(
......@@ -62,25 +62,25 @@ FROM order_import oi
,`pay_amount`, `pay_type`, `coupon_card_log_id`, `coupon_card_code`, `get_points`, `use_points`, `clerk_id`, `store_id`, `address_id`
,`address_info`, `area_id`, `buyer_name`, `buyer_phone`, `logistics_company_id`, `logistics_number`, `order_process_id`, `order_step`
,`pay_number`, `pay_time`, `order_show`, `evaluation_status`, `new_status`, `remarks`, `create_time`, `update_time`, `pay_amount_all`
,`stock_decrease`, `clique_id`, `clique_member_id`, `deliver_store_id`, `delivery_type`, `store_code`, `clerk_code`, `trade_close_reason`, `order_version`,from_erp
,`stock_decrease`, `clique_id`, `clique_member_id`, `deliver_store_id`, `delivery_type`, `store_code`, `clerk_code`, `trade_close_reason`, `order_version`,from_erp,`order_sequence`
)
select replace(uuid(), '-', '') as order_id,oi.erp_order_id ,IFNULL(CONCAT('RE9',floor(UNIX_TIMESTAMP(oi.create_time))),oi.order_number) as order_number ,members_view.enterprise_id, '-1' as brand_id ,members_view.member_id,oi.mall_pro_all_price
,oi.actual_freight, oi.actual_freight, oi.discount_amount,oi.discount_amount_info,oi.amount_payable_info
,oi.actual_freight, oi.actual_freight as mall_order_freight, oi.discount_amount,oi.discount_amount_info,oi.amount_payable_info
,oi.pay_amount, oi.pay_type,null as coupon_card_log_id ,oi.coupon_card_code,oi.get_points,oi.use_points,clerk.clerk_id,clerk.store_id_order as store_id,addr.member_address_id
,oi.address_info, addr.county_id as area_id,oi.buyer_name,oi.buyer_phone,logistics.`logistics_company_id`,oi.logistics_number,replace(uuid(), '-', '') as order_process_id ,oi.order_step
,oi.pay_number, oi.pay_time,oi.order_show,oi.evaluation_status,oi.new_status,oi.remarks,oi.create_time,oi.create_time as update_time,oi.pay_amount_all
,oi.stock_decrease,members_view.clique_id,members_view.clique_member_id,null as deliver_store_id,0 as delivery_type,oi.store_code,oi.clerk_code,null as trade_close_reason ,null as order_version,1 as from_erp
,oi.stock_decrease,members_view.clique_id,members_view.clique_member_id,null as deliver_store_id,0 as delivery_type,oi.store_code,oi.clerk_code,null as trade_close_reason ,'version_1.0' as order_version,1 as from_erp,null as order_sequence
FROM order_import oi
left join `gic3.0`.tab_gic_member_pommedeterre members_view on members_view.card_num = oi.member_card_num
left join `gic3_test`.members_view members_view on members_view.card_num = oi.member_card_num
LEFT join (
SELECT * FROM `gic3_test`.tab_gic_member_address
UNION
SELECT * FROM tab_gic_member_address_copy
SELECT * FROM `gic3_test`.tab_gic_member_address_copy
) addr on addr.member_id = members_view.member_id
left join `gic3.0`.tab_gic_logistics_company logistics on oi.logistics_company_code LIKE CONCAT('%',logistics.logistics_company_name,'%' )
left join `gic3.0`.tab_gic_member_clerk_pommedeterre clerk on clerk.member_id = members_view.member_id
left join `gic3_test`.tab_gic_logistics_company logistics on oi.logistics_company_code LIKE CONCAT('%',logistics.logistics_company_name,'%' )
left join `gic3_test`.main_store_view clerk on clerk.member_id = members_view.member_id
GROUP BY oi.erp_order_id
;
......@@ -95,24 +95,28 @@ FROM order_import oi
, `mall_pro_number`, `mall_pro_spu_price`, `mall_pro_sku_id`
, `mall_pro_sku_code`, `mall_pro_sku_attr`, `discount_amount_info`, `amount_payable_info`
, `pay_amount`, `get_points`, `use_points`, `order_item_freight`, `freight_template_id`
, `max_refund_price`, `refund_price`, `refund_points`, `refund_status`, `create_time`
, `max_refund_price`, `refund_price`, `refund_points`, `create_time`
, `update_time`, `refund_number`
, `activity_discount_id`, `activity_full_reduction_id`
, `activity_freight_id`, `activity_tiered_id`, `clique_id`, `clique_member_id`
, `order_item_status`, `pro_code`, `order_item_number`, `brand_code`
, `refund_status`
, `order_item_status`
, `pro_code`, `order_item_number`, `brand_code`
, `member_card_no`, `delivered_count`, `no_delivere_count`,from_erp
)
select
replace(uuid(), '-', '') as order_item_id ,o.order_id,o.enterprise_id,o.brand_id,o.member_id
select replace(uuid(), '-', '') as order_item_id ,o.order_id,o.enterprise_id,o.brand_id,o.member_id
,pro.mall_pro_id,pro.pro_name as mall_pro_name,IFNULL(oitem.mall_pro_price,0),sku.mall_pro_propvalue_image_url as mall_pro_image_url
,IFNULL(oitem.mall_pro_number, 0),IFNULL(pro.mall_pro_spu_price,0),sku.mall_pro_sku_id
,oitem.mall_pro_sku_code,IFNULL(sku.mall_prop_values,'[{}]') as mall_pro_sku_attr,oitem.discount_amount_info,oitem.amount_payable_info
,IFNULL(oitem.pay_amount, 0),IFNULL(oitem.get_points,0),oitem.use_points,oitem.order_item_freight,null as freight_template_id
,IFNULL(oitem.pay_amount,0) as max_refund_price,IFNULL(oitem.pay_amount,0) as refund_price,IFNULL(oitem.get_points,0) as refund_points,0 as refund_status,oitem.create_time
,IFNULL(oitem.pay_amount, 0),IFNULL(oitem.get_points,0),oitem.use_points,oitem.order_item_freight,pro.freight_template_id
,IFNULL(oitem.pay_amount,0) as max_refund_price,IFNULL(oitem.pay_amount,0) as refund_price,IFNULL(oitem.get_points,0) as refund_points,oitem.create_time
,oitem.create_time as update_time,0 as refund_number
,NULL as activity_discount_id,NULL as activity_full_reduction_id
,NULL as activity_freight_id, NULL as activity_tiered_id,o.clique_id,o.clique_member_id
,0 as order_item_status,pro.pro_code,oitem.order_item_number,pro.brand_code
,IF(o.order_step=5||o.order_step=6,1,0) as refund_status
,IF(o.order_step<=4,o.order_step,2) as order_item_status
,pro.pro_code,oitem.order_item_number,pro.brand_code
,oitem.member_card_no,0 as delivered_count, 0 as no_delivere_count ,1 as from_erp
FROM order_item_import oitem
......@@ -126,6 +130,10 @@ FROM order_item_import oitem
;
-- 0无退款 1退款中 2成功 3失败
-- 0(交易关闭),2待发货,3已发货,4已确认(交易成功)
-- 0交易关闭 1未付款（待付款、等待买家付款） 2已付款未发货（待发货、买家已付款） 3已发货未签收（待收货、已发货） 4已确认交易结束,5已发货订单项退款中,6待付款订单项退款中,7部分发货',
INSERT INTO `tab_gic_mall_order_logistics_copy`
(
......@@ -136,13 +144,24 @@ INSERT INTO `tab_gic_mall_order_logistics_copy`
)
select replace(uuid(), '-', '') as mall_order_logistics_id ,o.order_id as mall_order_id ,logistics.logistics_company_id,logistics.logistics_company_name
,logistics.logistics_company_code,logis.courier_number,logis.logistics_information,logis.create_time,logis.update_time
,logistics.logistics_company_code,logis.courier_number
, CONCAT(
'{',
GROUP_CONCAT(CONCAT('"', 'EBusinessID', '":"', '1283242', '"')),
GROUP_CONCAT(CONCAT(',"', 'LogisticCode', '":"', logis.courier_number, '"')),
GROUP_CONCAT(CONCAT(',"', 'Reason', '":"', IF(ISNULL(logis.logistics_information),'暂无轨迹信息',''), '"')),
GROUP_CONCAT(CONCAT(',"', 'ShipperCode', '":"', logistics.logistics_company_code, '"')),
GROUP_CONCAT(CONCAT(',"', 'State', '":"', '0', '"')),
GROUP_CONCAT(CONCAT(',"', 'Traces', '":"', logis.logistics_information, '"')),
'}'
) as logistics_information
,logis.create_time,logis.update_time
,o.`enterprise_id`,o.`clique_id`,o.`member_id`,o.`clique_member_id`,0 as weight, item.order_item_id
,logis.send_num, IFNULL(item.mall_pro_number,0) as `order_item_sum_num`,1 as from_erp
FROM order_logistics_import logis
left join tab_gic_mall_order_copy o on o.order_number = logis.order_number
left join tab_gic_mall_order_item_copy item on item.pro_code= logis.mall_pro_code
left join `gic3.0`.tab_gic_logistics_company logistics on logis.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
left join `gic3_test`.tab_gic_logistics_company logistics on logis.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
;
......@@ -161,17 +180,28 @@ FROM order_logistics_import logis
)
select replace(uuid(), '-', '') as mall_order_logistics_id ,o.order_id as mall_order_id
,logistics.logistics_company_id,logistics.logistics_company_name,logistics.logistics_company_code
,logis.courier_number,logis.logistics_information,logis.create_time,logis.update_time
,logis.courier_number
, CONCAT(
'{',
GROUP_CONCAT(CONCAT('"', 'EBusinessID', '":"', '1283242', '"')),
GROUP_CONCAT(CONCAT(',"', 'LogisticCode', '":"', logis.courier_number, '"')),
GROUP_CONCAT(CONCAT(',"', 'Reason', '":"', IF(ISNULL(logis.logistics_information),'暂无轨迹信息',''), '"')),
GROUP_CONCAT(CONCAT(',"', 'ShipperCode', '":"', logistics.logistics_company_code, '"')),
GROUP_CONCAT(CONCAT(',"', 'State', '":"', '0', '"')),
GROUP_CONCAT(CONCAT(',"', 'Traces', '":"', logis.logistics_information, '"')),
'}'
) as logistics_information
,logis.create_time,logis.update_time
,0 as weight,item.order_item_id,1 as from_erp
FROM order_refund_logistics_import logis
left join tab_gic_mall_order_copy o on o.order_number = logis.order_number
left join tab_gic_mall_order_item_copy item on item.pro_code= logis.mall_pro_code
left join `gic3.0`.tab_gic_logistics_company logistics on logis.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
left join `gic3_test`.tab_gic_logistics_company logistics on logis.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
GROUP BY logis.courier_number
;
INSERT INTO `tab_gic_mall_order_process_copy`
(
`order_process_id`, `order_id`, `enterprise_id`, `brand_id`, `member_id`
......@@ -217,7 +247,7 @@ FROM order_process_import p
FROM order_refund_import r
left join tab_gic_mall_order_copy o on o.erp_order_id = r.erp_order_id
left join tab_gic_mall_order_item_copy item on item.order_item_number = r.order_item_number
left join `gic3.0`.tab_gic_member_pommedeterre members_view on members_view.card_num = r.member_card_no
left join `gic3_test`.tab_gic_member_pommedeterre members_view on members_view.card_num = r.member_card_no
WHERE o.order_id is not NULL
group by r.order_item_number
;
......@@ -240,7 +270,7 @@ INSERT INTO `tab_gic_mall_order_batch_deliver_log_copy` (
from
order_batch_deliver_import d
left join tab_gic_mall_order_copy o on o.order_number = d.order_number
left join `gic3.0`.tab_gic_logistics_company logistics on d.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
left join `gic3_test`.tab_gic_logistics_company logistics on d.logistics_company_name LIKE CONCAT('%',logistics.logistics_company_name,'%' )
WHERE o.order_id is not NULL
;
......@@ -280,7 +310,7 @@ SELECT replace(uuid(), '-', '') as evaluate_id,personal.enterprise_id,personal.
,e.member_card_no, personal.member_name,1 as from_erp
FROM order_evaluate_import e
left join tab_gic_mall_order_item_copy itemc on itemc.pro_code = e.mall_pro_code
left join `gic3.0`.tab_gic_member_personal_pommedeterre personal on personal.member_id = itemc.member_id
left join `gic3_test`.member_personal personal on personal.member_id = itemc.member_id
;
......@@ -299,22 +329,51 @@ replace(uuid(), '-', '') as collection_id,members_view.member_id,members_view.e
,co.create_time,null,members_view.clique_id,members_view.clique_member_id,1 as from_erp
from collect_import co
left join tab_gic_mall_pro pro on pro.pro_code = co.mall_pro_code
left join `gic3.0`.tab_gic_member_pommedeterre members_view on members_view.card_num = co.card_no
left join `gic3_test`.members_view on members_view.card_num = co.card_no
group by co.card_no,co.mall_pro_code
;
-- 订单项的发货，未发货，退款数量
update tab_gic_mall_order_item_copy A
inner join (select order_item_id,sum(order_item_num) delivered_count from tab_gic_mall_order_logistics_copy` group by order_item_id ) c on A.order_item_id = c.order_item_id
left join (select count(1) refund_number from tab_gic_mall_order_refund_copy status = 2 group by order_item_id ) r on A.order_item_id = r.order_item_id
set A.delivered_count = c.delivered_count
,A.no_delivere_count = (mall_pro_number-c.delivered_count)
,A.refund_number = r.refund_number
--购物车
INSERT INTO `tab_gic_mall_shopping_cart_copy` (
`shopping_cart_id`, `member_id`, `enterprise_id`, `brand_id`
, `mall_pro_id`, `mall_pro_name`, `mall_pro_sku_id`, `mall_pro_sku_attr`
, `mall_pro_price`, `mall_pro_image_url`, `mall_pro_number`, `mall_pro_sku_price`
, `mall_pro_payable_price`, `status`, `create_time`, `update_time`, `mall_pro_summary_price`
, `clique_id`, `clique_member_id`, `from_erp`
)
SELECT
replace(uuid(), '-', '') as shopping_cart_id,members_view.member_id,pro.enterprise_id,pro.brand_id
,pro.mall_pro_id,pro.pro_name as mall_pro_name ,sku.mall_pro_sku_id,IFNULL(sku.mall_prop_values,'[{}]') as mall_pro_sku_attr
,cart.mall_pro_price ,pro.mall_pro_image_url,cart.mall_pro_number,sku.mall_pro_sku_price
,cart.mall_pro_summary_price as mall_pro_payable_price ,1 as status,cart.create_time ,cart.create_time as update_time,cart.mall_pro_summary_price
, members_view.clique_id,members_view.clique_member_id,1 as from_erp
from mall_shoopping_cart cart
left join tab_gic_mall_pro_sku sku on sku.mall_pro_sku_code = cart.mall_sku_code
left join tab_gic_mall_pro pro on pro.pro_code = cart.mall_pro_code
left join `gic3_test`.members_view on members_view.card_num = cart.cardno
group by cart.cardno,cart.mall_pro_code,cart.mall_sku_code
;
-- 订单项的发货，未发货
update tab_gic_mall_order_item_copy A
INNER JOIN (
select order_item_id,IFNULL(sum(order_item_num),0) delivered_count
from tab_gic_mall_order_logistics_copy group by order_item_id
) c on A.order_item_id = c.order_item_id
set A.delivered_count = c.delivered_count
,A.no_delivere_count = (mall_pro_number-c.delivered_count)
;
-- 退款数量
update tab_gic_mall_order_item_copy A
INNER JOIN (
select IFNULL(count(order_item_id),0) refund_number,order_item_id from tab_gic_mall_order_refund_copy WHERE refund_status = 2 group by order_item_id
) r on A.order_item_id = r.order_item_id
set A.refund_number = r.refund_number
;
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment