diff --git a/consume/canal_mall_order_for_numerical_statement_consume.go b/consume/canal_mall_order_for_numerical_statement_consume.go new file mode 100644 index 0000000..f214dc5 --- /dev/null +++ b/consume/canal_mall_order_for_numerical_statement_consume.go @@ -0,0 +1,282 @@ +package consume + +const ZhiOsMallPlaceOrderNumOfPeopleHashMapCacheKey = "%s:zhiOs_mall_place_order_num_of_people_hash_map_cache:%s" //下单人数缓存hashMap键 + +//func CanalMallOrderForNumericalStatementConsume(queue md.MqQueue) { +// ch, err := rabbit.Cfg.Pool.GetChannel() +// if err != nil { +// logx.Error(err) +// return +// } +// defer ch.Release() +// //1、将自己绑定到交换机上 +// ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) +// //2、取出数据进行消费 +// ch.Qos(100) +// delivery := ch.Consume(queue.Name, false) +// +// var res amqp.Delivery +// var ok bool +// for { +// res, ok = <-delivery +// if ok == true { +// //fmt.Println(string(res.Body)) +// fmt.Println(">>>>>>>>>>>>>>>>CanalGuideOrderForNumericalStatementConsume<<<<<<<<<<<<<<<<<<<<<<<<<") +// err = handleCanalGuideOrderForNumericalStatementTable(res.Body) +// if err != nil { +// fmt.Println("err ::: ", err) +// utils.FilePutContents("CanalGuideOrderForNumericalStatementConsume_ERR", "[err]:"+err.Error()) +// _ = res.Reject(false) +// ////TODO::重新推回队列末尾，避免造成队列堵塞 +// //var msg *md.OneCirclesStructForSignIn +// //json.Unmarshal(res.Body, &msg) +// //ch.Publish(queue.ExchangeName, msg, queue.RoutKey) +// } else { +// _ = res.Ack(true) +// } +// } else { +// panic(errors.New("error getting message")) +// } +// } +// fmt.Println("get msg done") +//} +// +//func handleCanalMallOrderForNumericalStatementTable(msg []byte) error { +// //1、解析canal采集至mq中queue的数据结构体 +// var canalMsg *md.CanalMallOrder +// err := json.Unmarshal(msg, &canalMsg) +// if err != nil { +// return err +// } +// now := time.Now() +// +// //2、获取masterId +// masterId := utils.StrToInt(strings.Split(canalMsg.Database, "_")[1]) +// +// //TODO::日志记录 +// utils.FilePutContents("handleCanalGuideOrderForNumericalStatementTable_"+utils.IntToStr(masterId)+"_"+now.Format("2006-01-02"), string(msg)) +// +// //2、判断操作(insert | update) +// if canalMsg.Type == md.CanalMsgInsertSqlType || canalMsg.Type == md.CanalMsgUpdateSqlType { +// var isUpdate bool +// //3、查找是否有数据 +// var ordDate string +// for _, item := range canalMsg.Data { +// ordDate = time.Unix(utils.StrToInt64(item.CreateAt), 0).Format("2006-01-02") +// } +// statistics, err := db2.GetMasterGuideOrderStatistics(db.Db, masterId, ordDate) +// if err != nil { +// return err +// } +// if statistics == nil && canalMsg.Type == md.CanalMsgInsertSqlType { +// statistics = &model.MasterGuideOrderStatistics{ +// MasterId: masterId, +// PaymentTotal: "", +// OrderCount: 0, +// EstimatedCommission: "", +// EstimatedProfit: "", +// LoseOrderCount: 0, +// PlaceOrderNumOfPeople: 0, +// EffectiveOrderCount: 0, +// EffectiveCommission: "", +// ReceiveCommission: "", +// LoseCommission: "", +// AvgCommission: "", +// CustomerUnitPrice: "", +// Date: ordDate, +// CreateAt: now.Format("2006-01-02 15:04:05"), +// UpdateAt: now.Format("2006-01-02 15:04:05"), +// } +// _, err = db2.MasterGuideOrderStatisticsInsert(db.Db, statistics) +// if err != nil { +// return err +// } +// } +// if statistics == nil { +// return errors.New("过期订单数据不予处理") +// } +// +// paymentTotal := statistics.PaymentTotal +// orderCount := statistics.OrderCount +// estimatedCommission := statistics.EstimatedCommission +// estimatedProfit := statistics.EstimatedProfit +// loseOrderCount := statistics.LoseOrderCount +// placeOrderNumOfPeople := statistics.PlaceOrderNumOfPeople +// effectiveOrderCount := statistics.EffectiveOrderCount +// effectiveCommission := statistics.EffectiveCommission +// loseCommission := statistics.LoseCommission +// avgCommission := statistics.AvgCommission +// customerUnitPrice := statistics.CustomerUnitPrice +// effectivePaymentTotal := statistics.EffectivePaymentTotal +// if canalMsg.Type == md.CanalMsgInsertSqlType { +// for _, item := range canalMsg.Data { +// orderCount++ +// if item.State == "4" { +// loseOrderCount++ +// } else { +// effectiveOrderCount++ +// } +// +// cacheKey := fmt.Sprintf(ZhiOsGuidePlaceOrderNumOfPeopleHashMapCacheKey, utils.IntToStr(masterId), ordDate) +// get, _ := cache.HGetString(cacheKey, item.Uid) +// paymentTotal = utils.Float64ToStr(utils.StrToFloat64(paymentTotal) + utils.StrToFloat64(item.PaidPrice)) //付款金额 +// estimatedCommission = utils.Float64ToStr(utils.StrToFloat64(estimatedCommission) + utils.StrToFloat64(item.BenefitAll)) //预估佣金(元) +// estimatedProfit = utils.Float64ToStr(utils.StrToFloat64(estimatedProfit) + utils.StrToFloat64(item.SysCommission)) //预估利润(元) +// effectiveCommission = utils.Float64ToStr(utils.StrToFloat64(effectiveCommission) + utils.StrToFloat64(item.BenefitAll)) //有效佣金(元) +// effectivePaymentTotal = utils.Float64ToStr(utils.StrToFloat64(effectivePaymentTotal) + utils.StrToFloat64(item.PaidPrice)) //有效付款金额(元) +// +// estimatedCommissionValue, _ := decimal.NewFromString(estimatedCommission) +// orderCountValue := decimal.NewFromInt(int64(orderCount)) +// avgCommission = estimatedCommissionValue.Div(orderCountValue).String() //平均佣金 +// +// if get == "" { +// placeOrderNumOfPeople++ //下单人数 +// cache.HSet(cacheKey, item.Uid, "1") +// } else { +// cache.HSet(cacheKey, item.Uid, utils.IntToStr(utils.StrToInt(get)+1)) +// } +// cache.Expire(cacheKey, md.ZhiOsUserVisitIpAddressHashMapCacheTime) +// paymentTotalValue, _ := decimal.NewFromString(paymentTotal) +// if placeOrderNumOfPeople == 0 { +// return errors.New("divider cannot be 0 in division operation") +// } +// placeOrderNumOfPeopleValue := decimal.NewFromInt(int64(placeOrderNumOfPeople)) +// customerUnitPrice = paymentTotalValue.Div(placeOrderNumOfPeopleValue).String() //客单价 +// isUpdate = true +// } +// } +// +// if canalMsg.Type == md.CanalMsgUpdateSqlType { +// judgeSate := JudgeSate(*canalMsg) +// if judgeSate > 0 { +// if judgeSate == 2 { +// //TODO::未收货失效 +// loseOrderCount++ +// effectiveOrderCount-- +// for _, item := range canalMsg.Data { +// loseCommission = utils.Float64ToStr(utils.StrToFloat64(loseCommission) + utils.StrToFloat64(item.BenefitAll)) +// effectiveCommission = utils.Float64ToStr(utils.StrToFloat64(effectiveCommission) - utils.StrToFloat64(item.BenefitAll)) +// effectivePaymentTotal = utils.Float64ToStr(utils.StrToFloat64(effectivePaymentTotal) - utils.StrToFloat64(item.PaidPrice)) +// isUpdate = true +// } +// } +// if judgeSate == 3 { +// //TODO::已收货失效 +// loseOrderCount++ +// effectiveOrderCount-- +// for _, item := range canalMsg.Data { +// loseCommission = utils.Float64ToStr(utils.StrToFloat64(loseCommission) + utils.StrToFloat64(item.BenefitAll)) +// effectiveCommission = utils.Float64ToStr(utils.StrToFloat64(effectiveCommission) - utils.StrToFloat64(item.BenefitAll)) +// effectivePaymentTotal = utils.Float64ToStr(utils.StrToFloat64(effectivePaymentTotal) - utils.StrToFloat64(item.PaidPrice)) +// isUpdate = true +// } +// } +// +// if judgeSate == 1 || judgeSate == 3 { +// //TODO::收货额外处理 +// +// //查找是否有数据 +// var ordConfirmAt string +// for _, item := range canalMsg.Data { +// ordConfirmAt = time.Unix(utils.StrToInt64(item.ConfirmAt), 0).Format("2006-01-02") +// } +// ordConfirmStatistics, err := db2.GetMasterGuideOrderStatistics(db.Db, masterId, ordConfirmAt) +// if err != nil { +// return err +// } +// if ordConfirmStatistics == nil { +// return errors.New("过期收货订单数据不予处理") +// } +// +// if judgeSate == 1 { +// //TODO::收货 +// for _, item := range canalMsg.Data { +// ordConfirmStatistics.ReceiveCommission = utils.Float64ToStr(utils.StrToFloat64(ordConfirmStatistics.ReceiveCommission) + utils.StrToFloat64(item.BenefitAll)) +// } +// } +// if judgeSate == 3 { +// //TODO::已收货失效 +// for _, item := range canalMsg.Data { +// ordConfirmStatistics.ReceiveCommission = utils.Float64ToStr(utils.StrToFloat64(ordConfirmStatistics.ReceiveCommission) - utils.StrToFloat64(item.BenefitAll)) +// } +// } +// ordConfirmStatistics.UpdateAt = now.Format("2006-01-02 15:04:05") +// _, err = db2.MasterGuideOrderStatisticsUpdate(db.Db, ordConfirmStatistics.Id, ordConfirmStatistics, +// "receive_commission", "update_at") +// } +// } +// } +// +// if isUpdate { +// statistics.PaymentTotal = paymentTotal +// statistics.OrderCount = orderCount +// statistics.EstimatedCommission = estimatedCommission +// statistics.EstimatedProfit = estimatedProfit +// statistics.LoseOrderCount = loseOrderCount +// statistics.PlaceOrderNumOfPeople = placeOrderNumOfPeople +// statistics.EffectiveOrderCount = effectiveOrderCount +// statistics.EffectiveCommission = effectiveCommission +// statistics.LoseCommission = loseCommission +// statistics.AvgCommission = avgCommission +// statistics.CustomerUnitPrice = customerUnitPrice +// statistics.EffectivePaymentTotal = effectivePaymentTotal +// statistics.UpdateAt = now.Format("2006-01-02 15:04:05") +// _, err = db2.MasterGuideOrderStatisticsUpdate(db.Db, statistics.Id, statistics, +// "payment_total", "order_count", "estimated_commission", "estimated_profit", "lose_order_count", +// "place_order_num_of_people", "effective_order_count", "effective_commission", "lose_commission", +// "avg_commission", "customer_unit_price", "effective_payment_total", "update_at") +// if err != nil { +// return err +// } +// } +// +// } +// return nil +//} +// +// +//// JudgeSate 处理订单状态(judgeSate[0:不需要处理 1:收货 2:未收货失效 3:已收货失效]) +//func JudgeSate(message md.CanalGuideOrderMessage[md.CanalGuideOrder]) (judgeSate int) { +// oldData := message.Old +// +// //1、获取 旧的订单状态 +// var oldOrdState string +// for _, item := range oldData { +// if item.State != "" { +// oldOrdState = item.State +// } +// } +// if oldOrdState == "" { +// return +// } +// +// //2、获取 新的订单状态 +// var nowOrdState string +// for _, item := range message.Data { +// if item.State != "" { +// nowOrdState = item.State +// } +// } +// if nowOrdState == "" { +// return +// } +// +// if oldOrdState == nowOrdState { +// return +// } +// +// //3、进行状态比较判断 +// if oldOrdState == "0" { +// if nowOrdState == "4" { //未收货失效 +// return 2 +// } +// if nowOrdState == "1" || nowOrdState == "2" || nowOrdState == "3" || nowOrdState == "5" { //收货 +// return 1 +// } +// } else { +// if nowOrdState == "4" { //已收货失效 +// return 3 +// } +// } +// return +//} diff --git a/consume/init.go b/consume/init.go index 9712293..43c85d5 100644 --- a/consume/init.go +++ b/consume/init.go @@ -83,12 +83,12 @@ func initConsumes() { //////////////////////////////////////// oneCircles ///////////////////////////////////////////////////// - //jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume - //jobs[consumeMd.OneCirclesStartLevelDividendFunName] = OneCirclesStartLevelDividendConsume - //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyConsume - //jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume - //jobs[consumeMd.OneCirclesSettlementPublicGiveActivityCoinFunName] = OneCirclesSettlementPublicGiveActivityCoinConsume - //jobs[consumeMd.OneCirclesAddPublicPlatoonUserRelationCommissionFunName] = OneCirclesAddPublicPlatoonUserRelationCommissionConsume + jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume + jobs[consumeMd.OneCirclesStartLevelDividendFunName] = OneCirclesStartLevelDividendConsume + jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyConsume + jobs[consumeMd.OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName] = OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume + jobs[consumeMd.OneCirclesSettlementPublicGiveActivityCoinFunName] = OneCirclesSettlementPublicGiveActivityCoinConsume + jobs[consumeMd.OneCirclesAddPublicPlatoonUserRelationCommissionFunName] = OneCirclesAddPublicPlatoonUserRelationCommissionConsume //jobs[consumeMd.OneCirclesSignInCopyGreenEnergyFunName] = OneCirclesSignInCopyGreenEnergyConsume //////////////////////////////////////// withdraw ///////////////////////////////////////////////////// @@ -106,7 +106,8 @@ func initConsumes() { //jobs[consumeMd.SuperCloudIssuanceMsgCallBackFunName] = SuperCloudIssuanceMsgCallBackConsume //jobs[consumeMd.SuperCloudIssuanceAsyncMLoginFunName] = SuperCloudIssuanceAsyncMLoginConsume - jobs[consumeMd.CanalGimMessageConsumeFunName] = CanalGimMessageConsume + ////////////////////////////////////// DMS ///////////////////////////////////////////////////// + //jobs[consumeMd.CanalGimMessageConsumeFunName] = CanalGimMessageConsume } diff --git a/consume/md/md_canal_mall_order_consume.go b/consume/md/md_canal_mall_order_consume.go new file mode 100644 index 0000000..34dcaaa --- /dev/null +++ b/consume/md/md_canal_mall_order_consume.go @@ -0,0 +1,297 @@ +package md + +type CanalMallOrder struct { + Data []struct { + OrdId string `json:"ord_id"` + MainOrdId string `json:"main_ord_id"` + Uid string `json:"uid"` + BuyerName string `json:"buyer_name"` + BuyerPhone string `json:"buyer_phone"` + CostPrice string `json:"cost_price"` + State string `json:"state"` + PayTime interface{} `json:"pay_time"` + PayChannel string `json:"pay_channel"` + ShippingTime string `json:"shipping_time"` + LogisticCompany string `json:"logistic_company"` + LogisticNum string `json:"logistic_num"` + ReceiverPhone string `json:"receiver_phone"` + ReceiverName string `json:"receiver_name"` + ReceiverAddressDetail string `json:"receiver_address_detail"` + ShippingType string `json:"shipping_type"` + CouponDiscount string `json:"coupon_discount"` + DiscountPrice string `json:"discount_price"` + ReturnInsuranceFee string `json:"return_insurance_fee"` + IsReceipt string `json:"is_receipt"` + ShippingFee string `json:"shipping_fee"` + Comment string `json:"comment"` + ProvinceName string `json:"province_name"` + CityName string `json:"city_name"` + CountyName string `json:"county_name"` + PayNum string `json:"pay_num"` + ConfirmTime string `json:"confirm_time"` + EstimateIntegral string `json:"estimate_integral"` + EstimateCommission string `json:"estimate_commission"` + CreateTime string `json:"create_time"` + UpdateTime string `json:"update_time"` + DeletedTime interface{} `json:"deleted_time"` + FinishTime interface{} `json:"finish_time"` + OrderType string `json:"order_type"` + Data string `json:"data"` + GroupBuyCommission string `json:"group_buy_commission"` + GroupBuyCommissionTime interface{} `json:"group_buy_commission_time"` + CommissionTime string `json:"commission_time"` + GroupBuySettleTime interface{} `json:"group_buy_settle_time"` + SettleTime interface{} `json:"settle_time"` + CostVirtualCoin string `json:"cost_virtual_coin"` + VirtualCoinId string `json:"virtual_coin_id"` + UserCouponId string `json:"user_coupon_id"` + ShareUid string `json:"share_uid"` + IsConsign string `json:"is_consign"` + UserLevelData string `json:"user_level_data"` + GoodsId string `json:"goods_id"` + IsHasUserLevel string `json:"is_has_user_level"` + UserLevel string `json:"user_level"` + IsGiveUserLevel string `json:"is_give_user_level"` + ReturnMoneySettleAt string `json:"return_money_settle_at"` + IsSetReduce string `json:"is_set_reduce"` + DeductCoin string `json:"deduct_coin"` + ConsumptionCoinReward string `json:"consumption_coin_reward"` + DeductCoinReward string `json:"deduct_coin_reward"` + IsSubsidyEnd string `json:"is_subsidy_end"` + RunTime string `json:"run_time"` + SupplierMerchantId string `json:"supplier_merchant_id"` + SupplierOrdId string `json:"supplier_ord_id"` + PayOnBehalfUid string `json:"pay_on_behalf_uid"` + IsSetSubsidy string `json:"is_set_subsidy"` + ProvinceId string `json:"province_id"` + CityId string `json:"city_id"` + CountyId string `json:"county_id"` + CurrencyCode string `json:"currency_code"` + TotalShippingFee string `json:"total_shipping_fee"` + StoreOrdId string `json:"store_ord_id"` + IsSetOutAch string `json:"is_set_out_ach"` + SupplierStoreOrdId string `json:"supplier_store_ord_id"` + TransactionId string `json:"transaction_id"` + PayData interface{} `json:"pay_data"` + SubOrderPayType interface{} `json:"sub_order_pay_type"` + ConsumptionCoinRewardOut string `json:"consumption_coin_reward_out"` + DeductCoinRewardOut string `json:"deduct_coin_reward_out"` + IcbcIntegral string `json:"icbc_integral"` + ParentUid string `json:"parent_uid"` + SupplierCloudChainOrdId string `json:"supplier_cloud_chain_ord_id"` + GoodsType string `json:"goods_type"` + RewardCoinId string `json:"reward_coin_id"` + IsVirtualGoods string `json:"is_virtual_goods"` + RewardCoinAmount string `json:"reward_coin_amount"` + RewardVirtualUserLv string `json:"reward_virtual_user_lv"` + BaseCommission string `json:"base_commission"` + PlatformCostPrice string `json:"platform_cost_price"` + IsSettle string `json:"is_settle"` + Pvd string `json:"pvd"` + PointId string `json:"point_id"` + MacaoAddress string `json:"macao_address"` + AddressType string `json:"address_type"` + VirtualGoodsInfo string `json:"virtual_goods_info"` + PayWay string `json:"pay_way"` + } `json:"data"` + Database string `json:"database"` + Es int64 `json:"es"` + Id int `json:"id"` + IsDdl bool `json:"isDdl"` + MysqlType struct { + OrdId string `json:"ord_id"` + MainOrdId string `json:"main_ord_id"` + Uid string `json:"uid"` + BuyerName string `json:"buyer_name"` + BuyerPhone string `json:"buyer_phone"` + CostPrice string `json:"cost_price"` + State string `json:"state"` + PayTime string `json:"pay_time"` + PayChannel string `json:"pay_channel"` + ShippingTime string `json:"shipping_time"` + LogisticCompany string `json:"logistic_company"` + LogisticNum string `json:"logistic_num"` + ReceiverPhone string `json:"receiver_phone"` + ReceiverName string `json:"receiver_name"` + ReceiverAddressDetail string `json:"receiver_address_detail"` + ShippingType string `json:"shipping_type"` + CouponDiscount string `json:"coupon_discount"` + DiscountPrice string `json:"discount_price"` + ReturnInsuranceFee string `json:"return_insurance_fee"` + IsReceipt string `json:"is_receipt"` + ShippingFee string `json:"shipping_fee"` + Comment string `json:"comment"` + ProvinceName string `json:"province_name"` + CityName string `json:"city_name"` + CountyName string `json:"county_name"` + PayNum string `json:"pay_num"` + ConfirmTime string `json:"confirm_time"` + EstimateIntegral string `json:"estimate_integral"` + EstimateCommission string `json:"estimate_commission"` + CreateTime string `json:"create_time"` + UpdateTime string `json:"update_time"` + DeletedTime string `json:"deleted_time"` + FinishTime string `json:"finish_time"` + OrderType string `json:"order_type"` + Data string `json:"data"` + GroupBuyCommission string `json:"group_buy_commission"` + GroupBuyCommissionTime string `json:"group_buy_commission_time"` + CommissionTime string `json:"commission_time"` + GroupBuySettleTime string `json:"group_buy_settle_time"` + SettleTime string `json:"settle_time"` + CostVirtualCoin string `json:"cost_virtual_coin"` + VirtualCoinId string `json:"virtual_coin_id"` + UserCouponId string `json:"user_coupon_id"` + ShareUid string `json:"share_uid"` + IsConsign string `json:"is_consign"` + UserLevelData string `json:"user_level_data"` + GoodsId string `json:"goods_id"` + IsHasUserLevel string `json:"is_has_user_level"` + UserLevel string `json:"user_level"` + IsGiveUserLevel string `json:"is_give_user_level"` + ReturnMoneySettleAt string `json:"return_money_settle_at"` + IsSetReduce string `json:"is_set_reduce"` + DeductCoin string `json:"deduct_coin"` + ConsumptionCoinReward string `json:"consumption_coin_reward"` + DeductCoinReward string `json:"deduct_coin_reward"` + IsSubsidyEnd string `json:"is_subsidy_end"` + RunTime string `json:"run_time"` + SupplierMerchantId string `json:"supplier_merchant_id"` + SupplierOrdId string `json:"supplier_ord_id"` + PayOnBehalfUid string `json:"pay_on_behalf_uid"` + IsSetSubsidy string `json:"is_set_subsidy"` + ProvinceId string `json:"province_id"` + CityId string `json:"city_id"` + CountyId string `json:"county_id"` + CurrencyCode string `json:"currency_code"` + TotalShippingFee string `json:"total_shipping_fee"` + StoreOrdId string `json:"store_ord_id"` + IsSetOutAch string `json:"is_set_out_ach"` + SupplierStoreOrdId string `json:"supplier_store_ord_id"` + TransactionId string `json:"transaction_id"` + PayData string `json:"pay_data"` + SubOrderPayType string `json:"sub_order_pay_type"` + ConsumptionCoinRewardOut string `json:"consumption_coin_reward_out"` + DeductCoinRewardOut string `json:"deduct_coin_reward_out"` + IcbcIntegral string `json:"icbc_integral"` + ParentUid string `json:"parent_uid"` + SupplierCloudChainOrdId string `json:"supplier_cloud_chain_ord_id"` + GoodsType string `json:"goods_type"` + RewardCoinId string `json:"reward_coin_id"` + IsVirtualGoods string `json:"is_virtual_goods"` + RewardCoinAmount string `json:"reward_coin_amount"` + RewardVirtualUserLv string `json:"reward_virtual_user_lv"` + BaseCommission string `json:"base_commission"` + PlatformCostPrice string `json:"platform_cost_price"` + IsSettle string `json:"is_settle"` + Pvd string `json:"pvd"` + PointId string `json:"point_id"` + MacaoAddress string `json:"macao_address"` + AddressType string `json:"address_type"` + VirtualGoodsInfo string `json:"virtual_goods_info"` + PayWay string `json:"pay_way"` + } `json:"mysqlType"` + Old []struct { + State string `json:"state"` + ConfirmTime interface{} `json:"confirm_time"` + UpdateTime string `json:"update_time"` + } `json:"old"` + PkNames []string `json:"pkNames"` + Sql string `json:"sql"` + SqlType struct { + OrdId int `json:"ord_id"` + MainOrdId int `json:"main_ord_id"` + Uid int `json:"uid"` + BuyerName int `json:"buyer_name"` + BuyerPhone int `json:"buyer_phone"` + CostPrice int `json:"cost_price"` + State int `json:"state"` + PayTime int `json:"pay_time"` + PayChannel int `json:"pay_channel"` + ShippingTime int `json:"shipping_time"` + LogisticCompany int `json:"logistic_company"` + LogisticNum int `json:"logistic_num"` + ReceiverPhone int `json:"receiver_phone"` + ReceiverName int `json:"receiver_name"` + ReceiverAddressDetail int `json:"receiver_address_detail"` + ShippingType int `json:"shipping_type"` + CouponDiscount int `json:"coupon_discount"` + DiscountPrice int `json:"discount_price"` + ReturnInsuranceFee int `json:"return_insurance_fee"` + IsReceipt int `json:"is_receipt"` + ShippingFee int `json:"shipping_fee"` + Comment int `json:"comment"` + ProvinceName int `json:"province_name"` + CityName int `json:"city_name"` + CountyName int `json:"county_name"` + PayNum int `json:"pay_num"` + ConfirmTime int `json:"confirm_time"` + EstimateIntegral int `json:"estimate_integral"` + EstimateCommission int `json:"estimate_commission"` + CreateTime int `json:"create_time"` + UpdateTime int `json:"update_time"` + DeletedTime int `json:"deleted_time"` + FinishTime int `json:"finish_time"` + OrderType int `json:"order_type"` + Data int `json:"data"` + GroupBuyCommission int `json:"group_buy_commission"` + GroupBuyCommissionTime int `json:"group_buy_commission_time"` + CommissionTime int `json:"commission_time"` + GroupBuySettleTime int `json:"group_buy_settle_time"` + SettleTime int `json:"settle_time"` + CostVirtualCoin int `json:"cost_virtual_coin"` + VirtualCoinId int `json:"virtual_coin_id"` + UserCouponId int `json:"user_coupon_id"` + ShareUid int `json:"share_uid"` + IsConsign int `json:"is_consign"` + UserLevelData int `json:"user_level_data"` + GoodsId int `json:"goods_id"` + IsHasUserLevel int `json:"is_has_user_level"` + UserLevel int `json:"user_level"` + IsGiveUserLevel int `json:"is_give_user_level"` + ReturnMoneySettleAt int `json:"return_money_settle_at"` + IsSetReduce int `json:"is_set_reduce"` + DeductCoin int `json:"deduct_coin"` + ConsumptionCoinReward int `json:"consumption_coin_reward"` + DeductCoinReward int `json:"deduct_coin_reward"` + IsSubsidyEnd int `json:"is_subsidy_end"` + RunTime int `json:"run_time"` + SupplierMerchantId int `json:"supplier_merchant_id"` + SupplierOrdId int `json:"supplier_ord_id"` + PayOnBehalfUid int `json:"pay_on_behalf_uid"` + IsSetSubsidy int `json:"is_set_subsidy"` + ProvinceId int `json:"province_id"` + CityId int `json:"city_id"` + CountyId int `json:"county_id"` + CurrencyCode int `json:"currency_code"` + TotalShippingFee int `json:"total_shipping_fee"` + StoreOrdId int `json:"store_ord_id"` + IsSetOutAch int `json:"is_set_out_ach"` + SupplierStoreOrdId int `json:"supplier_store_ord_id"` + TransactionId int `json:"transaction_id"` + PayData int `json:"pay_data"` + SubOrderPayType int `json:"sub_order_pay_type"` + ConsumptionCoinRewardOut int `json:"consumption_coin_reward_out"` + DeductCoinRewardOut int `json:"deduct_coin_reward_out"` + IcbcIntegral int `json:"icbc_integral"` + ParentUid int `json:"parent_uid"` + SupplierCloudChainOrdId int `json:"supplier_cloud_chain_ord_id"` + GoodsType int `json:"goods_type"` + RewardCoinId int `json:"reward_coin_id"` + IsVirtualGoods int `json:"is_virtual_goods"` + RewardCoinAmount int `json:"reward_coin_amount"` + RewardVirtualUserLv int `json:"reward_virtual_user_lv"` + BaseCommission int `json:"base_commission"` + PlatformCostPrice int `json:"platform_cost_price"` + IsSettle int `json:"is_settle"` + Pvd int `json:"pvd"` + PointId int `json:"point_id"` + MacaoAddress int `json:"macao_address"` + AddressType int `json:"address_type"` + VirtualGoodsInfo int `json:"virtual_goods_info"` + PayWay int `json:"pay_way"` + } `json:"sqlType"` + Table string `json:"table"` + Ts int64 `json:"ts"` + Type string `json:"type"` +} diff --git a/go.mod b/go.mod index 2df75db..9621036 100644 --- a/go.mod +++ b/go.mod @@ -9,7 +9,7 @@ require ( code.fnuoos.com/go_rely_warehouse/zyos_go_condition_statistics.git v1.1.2-0.20240607091816-3df1433a2f0d code.fnuoos.com/go_rely_warehouse/zyos_go_es.git v1.0.0 code.fnuoos.com/go_rely_warehouse/zyos_go_mq.git v0.0.5 - code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git v1.9.10-0.20240703034234-2ab228956242 + code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git v1.9.10-0.20240719082936-c249de79edce code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git v1.6.2-0.20231116085701-9ba6e19f877b code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git v1.1.21-0.20240611024753-7cd929a03014 code.fnuoos.com/go_rely_warehouse/zyos_model.git v0.0.4-0.20240717064604-5e4000e89365