Commit d6d8dfdb by 蘑菇🍄

add jnby pomme sql

parent 9a389372
/*
Navicat MySQL Data Transfer
Source Server : 商品中间库
Source Server Version : 50628
Source Host : sh-cdb-qov3z1u5.sql.tencentcdb.com:63613
Source Database : gic_middledb_batch
Target Server Type : MYSQL
Target Server Version : 50628
File Encoding : 65001
Date: 2018-11-20 16:15:32
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for order_batch_deliver_import
-- ----------------------------
DROP TABLE IF EXISTS `order_batch_deliver_import`;
CREATE TABLE `order_batch_deliver_import` (
`order_number` varchar(128) DEFAULT NULL COMMENT '订单号',
`erp_order_id` varchar(64) DEFAULT NULL COMMENT 'erp订单id',
`logistics_company_name` varchar(128) DEFAULT NULL COMMENT '物流公司名称',
`courier_number` varchar(64) DEFAULT NULL COMMENT '快递单号',
`logistics_information` varchar(4000) DEFAULT NULL COMMENT '物流信息',
`mall_pro_code` varchar(256) DEFAULT NULL COMMENT '商品code',
`send_num` int(32) DEFAULT NULL COMMENT '发货数量',
`create_time` varchar(64) DEFAULT NULL COMMENT '新增时间',
`update_time` varchar(64) DEFAULT NULL COMMENT '修改时间',
`member_card_no` varchar(128) DEFAULT NULL COMMENT '会员卡号',
`status` int(32) DEFAULT NULL COMMENT '0-未处理 1-已处理',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_evaluate_import
-- ----------------------------
DROP TABLE IF EXISTS `order_evaluate_import`;
CREATE TABLE `order_evaluate_import` (
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码',
`evaluate_type` int(32) DEFAULT NULL COMMENT '评价类型(0:服务态度 1:发货速度 2:订单项商品)',
`erp_order_id` varchar(64) DEFAULT NULL COMMENT '被评价订单的erp中的ID',
`order_number` varchar(128) DEFAULT NULL COMMENT '被评价订单编号',
`erp_goods_id` varchar(64) DEFAULT NULL COMMENT '被评价在erp商品ID',
`mall_pro_code` varchar(64) DEFAULT NULL COMMENT '被评价商品code',
`mall_pro_sku_code` varchar(128) DEFAULT NULL COMMENT '被评价商品skucode',
`evaluate_content` varchar(4000) DEFAULT NULL COMMENT '评价内容',
`evaluate_score` int(16) DEFAULT NULL COMMENT '评分',
`show_status` int(32) DEFAULT NULL COMMENT '是否显示(0:否,1:是)',
`status` int(32) DEFAULT NULL COMMENT '状态(0:无效,1:有效)',
`reply_content` varchar(4000) DEFAULT NULL COMMENT '商家回复内容',
`reply_status` int(32) DEFAULT NULL COMMENT '评价回复状态:0未回复 1-已回复',
`reply_date` varchar(64) DEFAULT NULL COMMENT '回复时间',
`create_time` varchar(64) DEFAULT NULL COMMENT '评价时间',
`member_card_no` varchar(64) DEFAULT NULL COMMENT '会员卡号'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_import
-- ----------------------------
DROP TABLE IF EXISTS `order_import`;
CREATE TABLE `order_import` (
`order_number` varchar(256) DEFAULT NULL COMMENT '订单流水号',
`erp_order_id` varchar(128) DEFAULT NULL COMMENT 'erp订单主键',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码',
`member_card_num` varchar(128) DEFAULT NULL COMMENT '会员卡',
`mall_pro_all_price` double(32,2) DEFAULT NULL COMMENT '订单商品零售总价',
`actual_freight` double(32,2) DEFAULT NULL COMMENT '最终实际运费(可手动修改)',
`discount_amount` double(32,2) DEFAULT NULL COMMENT '优惠折扣金额',
`discount_amount_info` varchar(512) DEFAULT NULL COMMENT '优惠折扣详情 格式:400=50||500=10',
`amount_payable_info` varchar(512) DEFAULT NULL COMMENT '应付金额详情 JSON 如 100=10||200=10',
`pay_amount_all` double(32,2) DEFAULT NULL COMMENT '实付金额 含运费',
`pay_amount` double(32,2) DEFAULT NULL COMMENT '实付金额 不含运费',
`pay_type` int(32) DEFAULT NULL COMMENT '支付方式 1微信 2支付宝 3充值 4信用卡 5银联',
`coupon_card_code` varchar(256) DEFAULT NULL COMMENT '使用的卡券code',
`get_points` int(32) DEFAULT NULL COMMENT '可以获得积分',
`use_points` int(32) DEFAULT NULL COMMENT '使用积分',
`address_info` varchar(2000) DEFAULT NULL COMMENT '收货地址 如:华星时代广场1103',
`buyer_name` varchar(128) DEFAULT NULL COMMENT '收货人',
`store_code` varchar(64) DEFAULT NULL COMMENT '店铺编码',
`clerk_code` varchar(64) DEFAULT NULL COMMENT '导购编码',
`buyer_phone` varchar(32) DEFAULT NULL COMMENT '收货人联系方式',
`logistics_company_code` varchar(128) DEFAULT NULL COMMENT '快递公司信息code 如顺丰快递:SF',
`logistics_number` varchar(64) DEFAULT NULL COMMENT '快递单号',
`order_step` int(32) DEFAULT NULL COMMENT '订单流程阶段 \r\n0交易关闭 1未付款(待付款、等待买家付款) \r\n2已付款未发货(待发货、买家已付款) \r\n3已发货未签收(待收货、已发货) \r\n4已确认交易结束,5已发货订单项退款中,\r\n6待付款订单项退款中,7部分发货',
`pay_number` varchar(128) DEFAULT NULL COMMENT '支付流水号',
`pay_time` varchar(128) DEFAULT NULL COMMENT '付款时间',
`order_show` int(32) DEFAULT NULL COMMENT '买家是否可见 买家删除 0不可见 1可见',
`evaluation_status` int(32) DEFAULT NULL COMMENT '评价状态 0未评价 1已评价',
`new_status` int(32) DEFAULT NULL COMMENT '是否最新需要通知的订单 0不是 1是',
`remarks` varchar(2000) DEFAULT NULL COMMENT '备注留言,如:我要红色',
`create_time` varchar(128) DEFAULT NULL COMMENT '订单创建时间',
`stock_decrease` int(32) DEFAULT NULL COMMENT '库存扣减 1创建时 2付款时'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_item_import
-- ----------------------------
DROP TABLE IF EXISTS `order_item_import`;
CREATE TABLE `order_item_import` (
`order_number` varchar(256) DEFAULT NULL COMMENT '订单编号',
`erp_order_id` varchar(128) DEFAULT NULL COMMENT 'erp对应订单id',
`order_item_number` varchar(256) DEFAULT NULL COMMENT '订单项号',
`erp_order_item_id` varchar(128) DEFAULT NULL COMMENT 'erp对应订单项id',
`mall_pro_code` varchar(128) DEFAULT NULL COMMENT '商品货号',
`mall_pro_name` varchar(256) DEFAULT NULL COMMENT '商城商品Name',
`mall_pro_price` double(64,2) DEFAULT NULL COMMENT '商城商品零售价',
`mall_pro_number` int(32) DEFAULT NULL COMMENT '商城商品件数(或单位 贵金属-重量等)',
`mall_pro_spu_price` double(64,2) DEFAULT NULL COMMENT '商品SPU价',
`mall_pro_sku_code` varchar(128) DEFAULT NULL COMMENT '商城商品SKU_CODE',
`discount_amount_info` varchar(512) DEFAULT NULL COMMENT '优惠折扣详情 格式:400=50||500=10',
`amount_payable_info` varchar(512) DEFAULT NULL COMMENT '应付金额详情 JSON 如 100=10||200=10',
`pay_amount` double(64,2) DEFAULT NULL COMMENT '实付金额',
`get_points` int(32) DEFAULT NULL COMMENT '获得积分',
`use_points` int(32) DEFAULT NULL COMMENT '使用积分',
`order_item_freight` int(32) DEFAULT NULL COMMENT '运费',
`refund_status` int(32) DEFAULT NULL COMMENT '是否有退款 0无退款 1退款中 2成功 3失败',
`create_time` varchar(128) DEFAULT NULL COMMENT '订单项创建时间',
`member_card_no` varchar(128) DEFAULT NULL COMMENT '会员卡号',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_logistics_import
-- ----------------------------
DROP TABLE IF EXISTS `order_logistics_import`;
CREATE TABLE `order_logistics_import` (
`order_number` varchar(128) DEFAULT NULL COMMENT '订单号',
`erp_order_id` varchar(128) DEFAULT NULL COMMENT 'erp订单id',
`logistics_company_name` varchar(128) DEFAULT NULL COMMENT '物流公司名称',
`courier_number` varchar(256) DEFAULT NULL COMMENT '快递单号',
`logistics_information` varchar(4000) DEFAULT NULL COMMENT '物流信息',
`mall_pro_code` varchar(256) DEFAULT NULL COMMENT '商品code',
`send_num` int(32) DEFAULT NULL COMMENT '发货数量',
`create_time` varchar(64) DEFAULT NULL COMMENT '新增时间',
`update_time` varchar(64) DEFAULT NULL COMMENT '修改时间',
`member_card_no` varchar(128) DEFAULT NULL COMMENT '会员卡号',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_process_import
-- ----------------------------
DROP TABLE IF EXISTS `order_process_import`;
CREATE TABLE `order_process_import` (
`order_number` varchar(128) DEFAULT NULL COMMENT '订单号',
`erp_order_id` varchar(64) DEFAULT NULL COMMENT 'erp订单id',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码',
`member_card_no` varchar(64) DEFAULT NULL COMMENT '会员卡号',
`order_step` int(32) DEFAULT NULL COMMENT '订单流程阶段 \r\n0交易关闭 1未付款(待付款、等待买家付款) \r\n2已付款未发货(待发货、买家已付款) \r\n3已发货未签收(待收货、已发货) \r\n4已确认交易结束,5已发货订单项退款中,\r\n6待付款订单项退款中,7部分发货',
`order_close` int(32) DEFAULT NULL COMMENT '订单是否关闭 0关闭 1正常',
`create_time` varchar(64) DEFAULT NULL COMMENT '新增时间',
`update_time` varchar(64) DEFAULT NULL COMMENT '修改时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_refund_import
-- ----------------------------
DROP TABLE IF EXISTS `order_refund_import`;
CREATE TABLE `order_refund_import` (
`order_number` varchar(128) DEFAULT NULL COMMENT '订单编号',
`erp_order_id` varchar(128) DEFAULT NULL COMMENT 'erp订单编号',
`order_item_number` varchar(128) DEFAULT NULL COMMENT '订单项编号',
`erp_order_item_id` varchar(64) DEFAULT NULL COMMENT 'erp订单项编号',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码',
`member_card_no` varchar(64) DEFAULT NULL COMMENT '会员卡号',
`actual_number` int(32) DEFAULT NULL COMMENT '实际商品退款的数量',
`refund_number` int(32) DEFAULT NULL COMMENT '退款商品件数(或单位 贵金属-重量等)',
`apply_refund_price` double(64,2) DEFAULT NULL COMMENT '申请退款金额',
`refund_price` double(64,2) DEFAULT NULL COMMENT '退款金额 实付部分',
`refund_points` int(32) DEFAULT NULL COMMENT '退款 积分部分',
`refund_status` int(32) DEFAULT NULL COMMENT '该阶段是 1退款待处理 2成功 \r\n3退款关闭 4待买家退货 5待商家收货 6拒绝退款',
`refund_reason` varchar(4000) DEFAULT NULL COMMENT '退款原因',
`create_time` varchar(64) DEFAULT NULL COMMENT '创建记录时间',
`out_trade_no` varchar(128) DEFAULT NULL COMMENT '商户支付订单号',
`apply_user` varchar(32) DEFAULT NULL COMMENT '申请人,可以是用户,可以是商家',
`apply_channel` varchar(64) DEFAULT NULL COMMENT '渠道:TYP_MALL|TYP_VENDOR',
`refund_type` int(32) DEFAULT NULL COMMENT '退款类型:1,仅退款,2退货退款',
`order_item_num` int(32) DEFAULT NULL COMMENT '本次退此订单项数量',
`order_item_sum_num` int(32) DEFAULT NULL COMMENT '本订单项总数量',
`order_num` int(32) DEFAULT NULL COMMENT '订单购买总数量',
`refund_deliver_type` int(32) DEFAULT NULL COMMENT '退款时发货类型:1:未发货类型,2:已发货类型'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for order_refund_logistics_import
-- ----------------------------
DROP TABLE IF EXISTS `order_refund_logistics_import`;
CREATE TABLE `order_refund_logistics_import` (
`order_number` varchar(128) DEFAULT NULL COMMENT '订单号',
`erp_order_id` varchar(64) DEFAULT NULL COMMENT 'erp订单id',
`logistics_company_name` varchar(128) DEFAULT NULL COMMENT '物流公司名称',
`courier_number` varchar(128) DEFAULT NULL COMMENT '快递单号',
`logistics_information` varchar(4000) DEFAULT NULL COMMENT '物流信息',
`create_time` varchar(64) DEFAULT NULL COMMENT '新增时间',
`update_time` varchar(64) DEFAULT NULL COMMENT '修改时间',
`member_card_no` varchar(128) DEFAULT NULL COMMENT '会员卡号',
`mall_pro_code` varchar(64) DEFAULT NULL COMMENT '商品code',
`send_num` varchar(64) DEFAULT NULL COMMENT '发货数量',
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for collect_import
-- ----------------------------
DROP TABLE IF EXISTS `collect_import`;
CREATE TABLE `collect_import` (
`factory_code` varchar(64) DEFAULT NULL COMMENT '企业编码',
`erp_member_id` varchar(64) DEFAULT NULL COMMENT 'erp中的会员编号',
`card_No` varchar(128) DEFAULT NULL COMMENT '会员卡号',
`mall_pro_code` varchar(64) DEFAULT NULL COMMENT '商城商品code',
`mall_pro_name` varchar(64) DEFAULT NULL COMMENT '商城商品Name',
`status` int(32) DEFAULT NULL COMMENT ' 0-已删除 1有效 2-商品已失效',
`create_time` varchar(64) DEFAULT NULL COMMENT '收藏时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
This source diff could not be displayed because it is too large. You can view the blob instead.
drop function if exists clearTempImportData;
drop function if exists clearTempImportData;
-- 创建一个无参的函数
create function clearTempImportData () returns int
-- 设置函数的返回类型
begin-- 函数头
delete from tab_gic_mall_order_copy ;
delete from tab_gic_mall_order_item_copy ;
delete from tab_gic_mall_order_logistics_copy ;
delete from tab_gic_mall_order_process_copy ;
delete from tab_gic_mall_order_refund_consult_copy ;
delete from tab_gic_mall_order_refund_copy ;
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 `3.0`.tab_gic_member_address_copy;
delete from tab_gic_mall_shopping_cart_copy;
RETURN 0;
end;
drop function if exists copyImportDataToProTable;
-- 创建一个无参的函数
create function copyImportDataToProTable () returns int
-- 设置函数的返回类型
begin-- 函数头
insert into tab_gic_mall_order select * from tab_gic_mall_order_copy;
insert into tab_gic_mall_order_item select * from tab_gic_mall_order_item_copy;
insert into tab_gic_mall_order_logistics select * from tab_gic_mall_order_logistics_copy;
insert into tab_gic_mall_order_process select * from tab_gic_mall_order_process_copy;
insert into tab_gic_mall_order_refund_consult select * from tab_gic_mall_order_refund_consult_copy;
insert into tab_gic_mall_order_refund select * from tab_gic_mall_order_refund_copy;
insert into tab_gic_mall_order_refund_logistics select * from tab_gic_mall_order_refund_logistics_copy;
insert into tab_gic_mall_collection select * from tab_gic_mall_collection_copy;
insert into tab_gic_mall_evaluate select * from tab_gic_mall_evaluate_copy;
insert into tab_gic_mall_order_batch_deliver_log select * from tab_gic_mall_order_batch_deliver_log_copy;
insert into tab_gic_mall_shopping_cart select * from tab_gic_mall_shopping_cart_copy;
insert into `gic3.0`.tab_gic_member_address select * from `gic3.0`.tab_gic_member_address_copy;
RETURN 0;
end;
\ No newline at end of file
-- 数据合并
-- 数据合并
insert into tab_gic_mall_order select * from tab_gic_mall_order_copy;
insert into tab_gic_mall_order_item select * from tab_gic_mall_order_item_copy;
insert into tab_gic_mall_order_logistics select * from tab_gic_mall_order_logistics_copy;
insert into tab_gic_mall_order_process select * from tab_gic_mall_order_process_copy;
insert into tab_gic_mall_order_refund_consult select * from tab_gic_mall_order_refund_consult_copy;
insert into tab_gic_mall_order_refund select * from tab_gic_mall_order_refund_copy;
insert into tab_gic_mall_order_refund_logistics select * from tab_gic_mall_order_refund_logistics_copy;
insert into tab_gic_mall_collection select * from tab_gic_mall_collection_copy;
insert into tab_gic_mall_evaluate select * from tab_gic_mall_evaluate_copy;
insert into tab_gic_mall_order_batch_deliver_log select * from tab_gic_mall_order_batch_deliver_log_copy;
insert into tab_gic_mall_shopping_cart select * from tab_gic_mall_shopping_cart_copy;
-- 清除导入的临时数据
delete from tab_gic_mall_order_copy ;
delete from tab_gic_mall_order_item_copy ;
delete from tab_gic_mall_order_logistics_copy ;
delete from tab_gic_mall_order_process_copy ;
delete from tab_gic_mall_order_refund_consult_copy ;
delete from tab_gic_mall_order_refund_copy ;
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 tab_gic_mall_shopping_cart_copy
-- 清除全部导入的数据
DELETE FROM tab_gic_mall_order WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_item WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_logistics WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_process WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_refund_consult WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_refund WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_refund_logistics WHERE from_erp = 1;
DELETE FROM tab_gic_mall_collection WHERE from_erp = 1;
DELETE FROM tab_gic_mall_evaluate WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order_batch_deliver_log WHERE from_erp = 1;
DELETE FROM tab_gic_mall_order WHERE member_id ='ff808081671d4dd501673a76508d32ce' AND enterprise_id= 'ff8080816170e8990161f6736b4c6033' and from_erp=1;
DELETE FROM tab_gic_mall_order_item WHERE member_id ='ff808081671d4dd501673a76508d32ce' AND enterprise_id= 'ff8080816170e8990161f6736b4c6033' and from_erp=1;
\ No newline at end of file
alter table tab_gic_mall_order add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order add erp_order_id varchar(32) default null COMMENT 'erp_order_id';
alter table tab_gic_mall_order_item add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_logistics add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_process add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_refund_consult add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_refund add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_refund_logistics add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_collection add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_evaluate add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_shopping_cart add from_erp int(1) default 0 COMMENT '是否导入';
alter table tab_gic_mall_order_batch_deliver_log add from_erp int(1) default 0 COMMENT '是否导入';
CREATE TABLE tab_gic_mall_order_copy LIKE tab_gic_mall_order;
CREATE TABLE tab_gic_mall_order_item _copy LIKE tab_gic_mall_order_item;
CREATE TABLE tab_gic_mall_order_logistics _copy LIKE tab_gic_mall_order_logistics;
CREATE TABLE tab_gic_mall_order_process_copy LIKE tab_gic_mall_order_process;
CREATE TABLE tab_gic_mall_order_refund_consult_copy LIKE tab_gic_mall_order_refund_consult;
CREATE TABLE tab_gic_mall_order_refund_copy LIKE tab_gic_mall_order_refund;
CREATE TABLE tab_gic_mall_order_refund_logistics_copy LIKE tab_gic_mall_order_refund_logistics;
CREATE TABLE tab_gic_mall_collection_copy LIKE tab_gic_mall_collection;
CREATE TABLE tab_gic_mall_evaluate_copy LIKE tab_gic_mall_evaluate;
CREATE TABLE tab_gic_member_address_copy LIKE `gic3.0`.tab_gic_member_address
CREATE TABLE tab_gic_mall_shopping_cart_copy LIKE tab_gic_mall_shopping_cart;
CREATE TABLE tab_gic_mall_order_batch_deliver_log_copy LIKE tab_gic_mall_order_batch_deliver_log
\ No newline at end of file
-- 清除导入的临时数据
delete from tab_gic_mall_order_copy ;
delete from tab_gic_mall_order_item_copy ;
delete from tab_gic_mall_order_logistics_copy ;
delete from tab_gic_mall_order_process_copy ;
delete from tab_gic_mall_order_refund_consult_copy ;
delete from tab_gic_mall_order_refund_copy ;
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
-- 订单地址所在区域
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
)
set A.area_id = c.county_id
;
-- 把没有的地址保存起来
INSERT INTO `gic3.0`.`tab_gic_member_address_copy`
(
`member_address_id`, `member_id`, `member_personal_id`, `is_default`, `address_type`
, `address`
, `county_id`, `longitude`, `latitude`, `create_time`, `update_time`, `status`
, `enterprise_id`, `member_name`, `phone_number`
, `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
;
-- tab_gic_mall_order
INSERT INTO `tab_gic_mall_order_copy`
(
`order_id`,`erp_order_id`, `order_number`, `enterprise_id`, `brand_id`, `member_id`, `mall_pro_all_price`
,`actual_freight`, `mall_order_freight`, `discount_amount`, `discount_amount_info`, `amount_payable_info`
,`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
)
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.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
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 (
SELECT * FROM `gic3_test`.tab_gic_member_address
UNION
SELECT * FROM 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
GROUP BY oi.erp_order_id
;
-- tab_gic_mall_order_item
INSERT INTO `tab_gic_mall_order_item_copy`
(
`order_item_id`, `order_id`, `enterprise_id`, `brand_id`, `member_id`
, `mall_pro_id`, `mall_pro_name`, `mall_pro_price`, `mall_pro_image_url`
, `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`
, `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`
, `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
,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
,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
,oitem.member_card_no,0 as delivered_count, 0 as no_delivere_count ,1 as from_erp
FROM order_item_import oitem
left join tab_gic_mall_order_copy o on o.erp_order_id = oitem.erp_order_id
left join tab_gic_mall_pro pro on pro.pro_code = oitem.mall_pro_code
left join tab_gic_mall_pro_sku sku on sku.mall_pro_sku_code = oitem.mall_pro_sku_code
where
o.order_id is not NULL
and oitem.member_card_no is not NULL
GROUP BY oitem.erp_order_item_id
;
INSERT INTO `tab_gic_mall_order_logistics_copy`
(
`mall_order_logistics_id`, `mall_order_id`, `logistics_company_id`, `logistics_company_name`
, `logistics_company_code`, `courier_number`, `logistics_information`, `create_time`, `update_time`
, `enterprise_id`, `clique_id`, `member_id`, `clique_member_id`, `weight`, `order_item_id`
, `order_item_num`, `order_item_sum_num`,from_erp
)
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
,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,'%' )
;
INSERT INTO `tab_gic_mall_order_refund_logistics_copy`
(
`mall_order_logistics_id`, `mall_order_id`
, `logistics_company_id`, `logistics_company_name`, `logistics_company_code`
, `courier_number`, `logistics_information`, `create_time`, `update_time`, `weight`, `order_item_id`,from_erp
)
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
,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,'%' )
;
INSERT INTO `tab_gic_mall_order_process_copy`
(
`order_process_id`, `order_id`, `enterprise_id`, `brand_id`, `member_id`
, `order_step`, `order_close`, `order_refund`, `create_time`, `update_time`
, `reminding_times`, `clique_id`, `clique_member_id`,from_erp
)
select o.order_process_id ,o.order_id ,o.enterprise_id,o.brand_id,o.member_id
,p.order_step, p.order_close,0 as order_refund ,p.create_time,p.update_time
,0 as reminding_times, o.`clique_id`, o.`clique_member_id`,1 as from_erp
FROM order_process_import p
left join tab_gic_mall_order_copy o on o.erp_order_id = p.erp_order_id
WHERE o.order_id is not NULL
;
INSERT INTO `tab_gic_mall_order_refund_copy`
(
`order_refund_id`, `order_id`, `order_item_id`, `enterprise_id`, `brand_id`
, `apply_user`, `actual_number`, `member_id`, `order_process_id`, `refund_number`
, `max_refund_price`, `apply_refund_price`, `refund_price`, `refund_points`, `refund_status`
, `refund_reason`, `refund_fail_reason`, `create_time`, `update_time`, `out_trade_no`
, `refund_describe`, `order_refund_number`, `clique_id`, `clique_member_id`, `apply_channel`
, `refund_type`, `refund_logistics_id`, `order_item_num`, `order_item_sum_num`, `order_num`
, `refund_deliver_type`, `refund_seller_address_id`, `refund_seller_desc`
, `refund_process_time`, `refund_goods_time`,from_erp
)
SELECT replace(uuid(), '-', '') as order_refund_id,o.order_id,item.order_item_id,members_view.enterprise_id,o.brand_id
,members_view.member_id as apply_user ,r.actual_number,members_view.member_id,o.order_process_id,r.refund_number
,r.apply_refund_price as max_refund_price ,r.apply_refund_price,r.refund_price,r.refund_points,r.refund_status
,r.refund_reason,null as refund_fail_reason,r.create_time,r.create_time as update_time,r.out_trade_no
,null as refund_describe,replace(uuid(), '-', '') as order_refund_number,members_view.clique_id,members_view.clique_member_id,r.apply_channel
,r.refund_type,null as refund_logistics_id,r.order_item_num,r.order_item_sum_num,SUM(item.mall_pro_number) as order_num
,r.refund_deliver_type,null as refund_seller_address_id,null as refund_seller_desc
,null as refund_process_time ,null as refund_goods_time,1 as from_erp
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
WHERE o.order_id is not NULL
group by r.order_item_number
;
INSERT INTO `tab_gic_mall_order_batch_deliver_log_copy` (
`mall_order_batch_deliver_log_id`, `enterprise_id`, `batch_id`, `order_id`, `order_number`
, `courier_number`, `logistics_company_id`, `logistics_company_code`, `logistics_company_name`
, `create_time`, `update_time`, `status`, `clique_id`,from_erp
)
select replace(uuid(), '-', '') as mall_order_batch_deliver_log_id,o.enterprise_id
,( concat(o.enterprise_id, REPLACE(unix_timestamp(d.`create_time`),'.','')))as batch_id ,o.order_id,o.order_number
,d.courier_number,logistics.logistics_company_id,logistics.logistics_company_code,logistics.logistics_company_name
,d.`create_time`, d.`update_time`, d.`status`, o.`clique_id` ,1 as from_erp
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,'%' )
WHERE o.order_id is not NULL
;
INSERT INTO `tab_gic_mall_order_refund_consult_copy`
(
`order_refund_consult_id`, `order_refund_id`, `role`, `msg`
, `refund_reason`, `refund_type`, `refund_price`, `description`
, `img_url`, `create_time`, `update_time`, `refund_point`
, `msg_type`, `refund_deliver_type`,from_erp
)
SELECT replace(uuid(), '-', '') as order_refund_consult_id,r.order_refund_id,2 as role ,'商家已同意退货' as msg
,'不喜欢/不想要' as refund_reason, 2 as refund_type,r.refund_price,null as description
,null as img_url,r.create_time,r.create_time as update_time,r.refund_points
,null as msg_type,1 as refund_deliver_type,1 as from_erp
FROM tab_gic_mall_order_refund_copy r
;
INSERT INTO `tab_gic_mall_evaluate`
(
`evaluate_id`, `enterprise_id`, `member_id`, `evaluate_type`, `mall_order_id`
, `mall_order_item_id`, `mall_pro_id`, `evaluate_content`, `evaluate_score`
, `show_status`, `status`, `reply_content`, `reply_status`, `reply_date`
, `create_time`, `update_time`, `clique_id`, `clique_member_id`
, `member_card_no`, `member_nickname`,from_erp
)
SELECT replace(uuid(), '-', '') as evaluate_id,personal.enterprise_id,personal.member_id , 0 as evaluate_type,itemc.order_id as mall_order_id
,itemc.order_item_id as mall_order_item_id,itemc.mall_pro_id,e.evaluate_content,e.evaluate_score
,e.show_status,e.status,e.reply_content,e.reply_status,e.reply_date
,e.create_time,null as update_time,personal.clique_id,personal.clique_member_id
,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
;
INSERT INTO `tab_gic_mall_collection_copy`
(
`collection_id`, `member_id`, `enterprise_id`, `brand_id`, `mall_pro_id`
, `mall_pro_name`, `mall_pro_collected_price`, `mall_pro_price`
, `mall_pro_image_url`, `mall_pro_spu_price`, `status`
, `create_time`, `update_time`, `clique_id`, `clique_member_id`,from_erp
)
SELECT
replace(uuid(), '-', '') as collection_id,members_view.member_id,members_view.enterprise_id,pro.brand_id,pro.mall_pro_id
,pro.pro_name as mall_pro_name ,pro.mall_pro_spu_price as mall_pro_collected_price,pro.mall_pro_spu_price as mall_pro_price
,pro.mall_pro_image_url ,pro.mall_pro_spu_price,co.`status`
,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
;
-- 订单项的发货,未发货,退款数量
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
;
\ No newline at end of file
-- 清除导入的临时数据
delete from tab_gic_mall_order_copy ;
delete from tab_gic_mall_order_item_copy ;
delete from tab_gic_mall_order_logistics_copy ;
delete from tab_gic_mall_order_process_copy ;
delete from tab_gic_mall_order_refund_consult_copy ;
delete from tab_gic_mall_order_refund_copy ;
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 `3.0`.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
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)
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`
(
`member_address_id`, `member_id`, `member_personal_id`, `is_default`, `address_type`
, `address`
, `county_id`, `longitude`, `latitude`, `create_time`, `update_time`, `status`
, `enterprise_id`, `member_name`, `phone_number`
, `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,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.0`.tab_gic_member_pommedeterre members_view on members_view.card_num = addr.member_number
left join `gic3.0`.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`
(
`order_id`,`erp_order_id`, `order_number`, `enterprise_id`, `brand_id`, `member_id`, `mall_pro_all_price`
,`actual_freight`, `mall_order_freight`, `discount_amount`, `discount_amount_info`, `amount_payable_info`
,`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,`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 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 ,'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 (
SELECT * FROM `gic3.0`.tab_gic_member_address
UNION
SELECT * FROM `gic3.0`.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
GROUP BY oi.erp_order_id
;
-- tab_gic_mall_order_item
INSERT INTO `tab_gic_mall_order_item_copy`
(
`order_item_id`, `order_id`, `enterprise_id`, `brand_id`, `member_id`
, `mall_pro_id`, `mall_pro_name`, `mall_pro_price`, `mall_pro_image_url`
, `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`, `create_time`
, `update_time`, `refund_number`
, `activity_discount_id`, `activity_full_reduction_id`
, `activity_freight_id`, `activity_tiered_id`, `clique_id`, `clique_member_id`
, `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
,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,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
,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
left join tab_gic_mall_order_copy o on o.erp_order_id = oitem.erp_order_id
left join tab_gic_mall_pro pro on pro.pro_code = oitem.mall_pro_code
left join tab_gic_mall_pro_sku sku on sku.mall_pro_sku_code = oitem.mall_pro_sku_code
where
o.order_id is not NULL
and oitem.member_card_no is not NULL
GROUP BY oitem.erp_order_item_id
;
-- 0无退款 1退款中 2成功 3失败
-- 0(交易关闭),2待发货,3已发货,4已确认(交易成功)
-- 0交易关闭 1未付款(待付款、等待买家付款) 2已付款未发货(待发货、买家已付款) 3已发货未签收(待收货、已发货) 4已确认交易结束,5已发货订单项退款中,6待付款订单项退款中,7部分发货',
1
INSERT INTO `tab_gic_mall_order_logistics_copy`
(
`mall_order_logistics_id`, `mall_order_id`, `logistics_company_id`, `logistics_company_name`
, `logistics_company_code`, `courier_number`, `logistics_information`, `create_time`, `update_time`
, `enterprise_id`, `clique_id`, `member_id`, `clique_member_id`, `weight`, `order_item_id`
, `order_item_num`, `order_item_sum_num`,from_erp
)
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
, 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,'%' )
;
INSERT INTO `tab_gic_mall_order_refund_logistics_copy`
(
`mall_order_logistics_id`, `mall_order_id`
, `logistics_company_id`, `logistics_company_name`, `logistics_company_code`
, `courier_number`, `logistics_information`, `create_time`, `update_time`, `weight`, `order_item_id`,from_erp
)
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
, 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,'%' )
GROUP BY logis.courier_number
;
INSERT INTO `tab_gic_mall_order_process_copy`
(
`order_process_id`, `order_id`, `enterprise_id`, `brand_id`, `member_id`
, `order_step`, `order_close`, `order_refund`, `create_time`, `update_time`
, `reminding_times`, `clique_id`, `clique_member_id`,from_erp
)
select o.order_process_id ,o.order_id ,o.enterprise_id,o.brand_id,o.member_id
,p.order_step, p.order_close,0 as order_refund ,p.create_time,p.update_time
,0 as reminding_times, o.`clique_id`, o.`clique_member_id`,1 as from_erp
FROM order_process_import p
left join tab_gic_mall_order_copy o on o.erp_order_id = p.erp_order_id
WHERE o.order_id is not NULL
;
INSERT INTO `tab_gic_mall_order_refund_copy`
(
`order_refund_id`, `order_id`, `order_item_id`, `enterprise_id`, `brand_id`
, `apply_user`, `actual_number`, `member_id`, `order_process_id`, `refund_number`
, `max_refund_price`, `apply_refund_price`, `refund_price`, `refund_points`, `refund_status`
, `refund_reason`, `refund_fail_reason`, `create_time`, `update_time`, `out_trade_no`
, `refund_describe`, `order_refund_number`, `clique_id`, `clique_member_id`, `apply_channel`
, `refund_type`, `refund_logistics_id`, `order_item_num`, `order_item_sum_num`, `order_num`
, `refund_deliver_type`, `refund_seller_address_id`, `refund_seller_desc`
, `refund_process_time`, `refund_goods_time`,from_erp
)
SELECT replace(uuid(), '-', '') as order_refund_id,o.order_id,item.order_item_id,members_view.enterprise_id,o.brand_id
,members_view.member_id as apply_user ,r.actual_number,members_view.member_id,o.order_process_id,r.refund_number
,r.apply_refund_price as max_refund_price ,r.apply_refund_price,r.refund_price,r.refund_points,r.refund_status
,r.refund_reason,null as refund_fail_reason,r.create_time,r.create_time as update_time,r.out_trade_no
,null as refund_describe,replace(uuid(), '-', '') as order_refund_number,members_view.clique_id,members_view.clique_member_id,r.apply_channel
,r.refund_type,null as refund_logistics_id,r.order_item_num,r.order_item_sum_num,SUM(item.mall_pro_number) as order_num
,r.refund_deliver_type,null as refund_seller_address_id,null as refund_seller_desc
,null as refund_process_time ,null as refund_goods_time,1 as from_erp
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
WHERE o.order_id is not NULL
group by r.order_item_number
;
INSERT INTO `tab_gic_mall_order_batch_deliver_log_copy` (
`mall_order_batch_deliver_log_id`, `enterprise_id`, `batch_id`, `order_id`, `order_number`
, `courier_number`, `logistics_company_id`, `logistics_company_code`, `logistics_company_name`
, `create_time`, `update_time`, `status`, `clique_id`,from_erp
)
select replace(uuid(), '-', '') as mall_order_batch_deliver_log_id,o.enterprise_id
,( concat(o.enterprise_id, REPLACE(unix_timestamp(d.`create_time`),'.','')))as batch_id ,o.order_id,o.order_number
,d.courier_number,logistics.logistics_company_id,logistics.logistics_company_code,logistics.logistics_company_name
,d.`create_time`, d.`update_time`, d.`status`, o.`clique_id` ,1 as from_erp
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,'%' )
WHERE o.order_id is not NULL
;
INSERT INTO `tab_gic_mall_order_refund_consult_copy`
(
`order_refund_consult_id`, `order_refund_id`, `role`, `msg`
, `refund_reason`, `refund_type`, `refund_price`, `description`
, `img_url`, `create_time`, `update_time`, `refund_point`
, `msg_type`, `refund_deliver_type`,from_erp
)
SELECT replace(uuid(), '-', '') as order_refund_consult_id,r.order_refund_id,2 as role ,'商家已同意退货' as msg
,'不喜欢/不想要' as refund_reason, 2 as refund_type,r.refund_price,null as description
,null as img_url,r.create_time,r.create_time as update_time,r.refund_points
,null as msg_type,1 as refund_deliver_type,1 as from_erp
FROM tab_gic_mall_order_refund_copy r
;
INSERT INTO `tab_gic_mall_evaluate`
(
`evaluate_id`, `enterprise_id`, `member_id`, `evaluate_type`, `mall_order_id`
, `mall_order_item_id`, `mall_pro_id`, `evaluate_content`, `evaluate_score`
, `show_status`, `status`, `reply_content`, `reply_status`, `reply_date`
, `create_time`, `update_time`, `clique_id`, `clique_member_id`
, `member_card_no`, `member_nickname`,from_erp
)
SELECT replace(uuid(), '-', '') as evaluate_id,personal.enterprise_id,personal.member_id , 0 as evaluate_type,itemc.order_id as mall_order_id
,itemc.order_item_id as mall_order_item_id,itemc.mall_pro_id,e.evaluate_content,e.evaluate_score
,e.show_status,e.status,e.reply_content,e.reply_status,e.reply_date
,e.create_time,null as update_time,personal.clique_id,personal.clique_member_id
,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
;
INSERT INTO `tab_gic_mall_collection_copy`
(
`collection_id`, `member_id`, `enterprise_id`, `brand_id`, `mall_pro_id`
, `mall_pro_name`, `mall_pro_collected_price`, `mall_pro_price`
, `mall_pro_image_url`, `mall_pro_spu_price`, `status`
, `create_time`, `update_time`, `clique_id`, `clique_member_id`,from_erp
)
SELECT
replace(uuid(), '-', '') as collection_id,members_view.member_id,members_view.enterprise_id,pro.brand_id,pro.mall_pro_id
,pro.pro_name as mall_pro_name ,pro.mall_pro_spu_price as mall_pro_collected_price,pro.mall_pro_spu_price as mall_pro_price
,pro.mall_pro_image_url ,pro.mall_pro_spu_price,co.`status`
,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
group by co.card_no,co.mall_pro_code
;
--购物车
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.0`.tab_gic_member_pommedeterre 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