1

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
+//}

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
 
 }
 

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"`
+}

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