Revert "提交中标必听课及数据流量包支付完成后回调方法中调用分销记录"

This reverts commit 6277623941c246465bd64d2c1dfe34220e9ce03f.

src/jfw/modules/subscribepay/src/entity/dataExportPackStruct.go

@@ -60,7 +60,7 @@ func (this *dataExportPackStruct) PayCallBack(param *CallBackParam) bool {
 	orderData := util.Mysql.FindOne("dataexport_order", map[string]interface{}{
 		"out_trade_no": param.OutTradeno,
 		"product_type": "数据流量包",
-	}, "id,order_status,order_code,filter,user_id,d_relation_id,dis_word,order_money", "")
+	}, "id,order_status,order_code,filter,user_id,d_relation_id", "")
 	if orderData != nil {
 		now := time.Now()
 		if order_status := qutil.IntAll((*orderData)["order_status"]); order_status == 0 {
@@ -98,135 +98,9 @@ func (this *dataExportPackStruct) PayCallBack(param *CallBackParam) bool {
 					log.Println(fmt.Sprintf("%s 资源账户更改异常 %v", userId, err))
 					return false
 				}
-				dis_word := qutil.ObjToString((*orderData)["dis_word"])
-				//userId := qutil.ObjToString((*orderData)["user_id"])
-				if dis_word != "" {
-					log.Println("处理分销记录")
-					/*	//分销系统 分销记录
-						go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)*/
-					//分销系统 分销记录
-					suffix := dis_word[len(dis_word)-3 : len(dis_word)]
-					if suffix == suffix_msgt {
-						//go OtherDisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word, qutil.ObjToString((*orderdata)["user_id"]), qutil.ObjToString((*orderdata)["create_time"]))
-					} else if suffix == "_GX" {
-						// 判断是否是该企业签约一年内引流的新用户
-						// 查用户注册时的  分销口令 用于判断购买时分销是否和用户注册时分销id一致
-						userInfo, flag := util.MQFW.FindById("user", userId, nil)
-						if flag && userInfo != nil {
-							userInfoDisWord := qutil.ObjToString((*userInfo)["disWords"])
-							// 判断是否和这次口令的分销这id一致
-							//根据口令获取注册时的分销者id
-							redisRegDis := redis.GetStr("other", "DIS_"+userInfoDisWord[1:len(userInfoDisWord)])
-							var shareRegUId string
-							if redisRegDis != "" {
-								// 注册时的分销id
-								shareRegUId = strings.Split(redisRegDis, "##")[1]
-								//获取本次携带的分销id
-								redisDis := redis.GetStr("other", "DIS_"+dis_word[1:len(dis_word)])
-								if redisDis != "" {
-									//分销者id
-									shareUId := strings.Split(redisDis, "##")[1]
-									if shareRegUId == shareUId {
-										// 根据id查签约用户信息
-										partnerInfo := util.Mysql.FindOne("dis_partner", map[string]interface{}{"uid": shareUId}, "", "")
-										if partnerInfo != nil {
-											adopt_time := (*partnerInfo)["adopt_time"] // 签约时间即审核通过时间
-											// 判断是否在一年合约期内  在合约期内则 调用分销
-											adoptTime, _ := time.Parse(qutil.Date_Full_Layout, qutil.ObjToString(adopt_time))
-											endTime := adoptTime.AddDate(1, 0, 0)
-											// 判断当前时间是否在一年合约期内
-											if now.Before(endTime) {
-												go DisWordRecode(qutil.IntAll((*orderData)["id"]), qutil.IntAll((*orderData)["order_money"]), "数据流量包", dis_word, userId)
-
-											} else {
-												log.Println("不在一年签约期内不计入分销")
-											}
-										}else {
-											log.Println("获取分销者签约信息失败")
-										}
-									} else {
-										log.Println("注册时的分销者id与本次渠道分销者id不一致，不计入佣金")
-									}
-
-								}else {
-									log.Println("redis获取订单分销者失败")
-								}
-							}else {
-								log.Println("获取用户注册时分销信息失败")
-							}
-						}else {
-							log.Println("获取用户注册信息失败")
-						}
-
-					} else {
-						//go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)
-					}
-				}
 				return true
 			}
 		} else {
-			dis_word := qutil.ObjToString((*orderData)["dis_word"])
-			userId := qutil.ObjToString((*orderData)["user_id"])
-			if dis_word != "" {
-				log.Println("处理分销记录")
-				/*	//分销系统 分销记录
-					go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)*/
-				//分销系统 分销记录
-				suffix := dis_word[len(dis_word)-3 : len(dis_word)]
-				if suffix == suffix_msgt {
-					//go OtherDisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word, qutil.ObjToString((*orderdata)["user_id"]), qutil.ObjToString((*orderdata)["create_time"]))
-				} else if suffix == "_GX" {
-					// 判断是否是该企业签约一年内引流的新用户
-					// 查用户注册时的  分销口令 用于判断购买时分销是否和用户注册时分销id一致
-					userInfo, flag := util.MQFW.FindById("user", userId, nil)
-					if flag && userInfo != nil {
-						userInfoDisWord := qutil.ObjToString((*userInfo)["disWords"])
-						// 判断是否和这次口令的分销这id一致
-						//根据口令获取注册时的分销者id
-						redisRegDis := redis.GetStr("other", "DIS_"+userInfoDisWord[1:len(userInfoDisWord)])
-						var shareRegUId string
-						if redisRegDis != "" {
-							// 注册时的分销id
-							shareRegUId = strings.Split(redisRegDis, "##")[1]
-							//获取本次携带的分销id
-							redisDis := redis.GetStr("other", "DIS_"+dis_word[1:len(dis_word)])
-							if redisDis != "" {
-								//分销者id
-								shareUId := strings.Split(redisDis, "##")[1]
-								if shareRegUId == shareUId {
-									// 根据id查签约用户信息
-									partnerInfo := util.Mysql.FindOne("dis_partner", map[string]interface{}{"uid": shareUId}, "", "")
-									if partnerInfo != nil {
-										adopt_time := (*partnerInfo)["adopt_time"] // 签约时间即审核通过时间
-										// 判断是否在一年合约期内  在合约期内则 调用分销
-										adoptTime, _ := time.Parse(qutil.Date_Full_Layout, qutil.ObjToString(adopt_time))
-										endTime := adoptTime.AddDate(1, 0, 0)
-										// 判断当前时间是否在一年合约期内
-										if now.Before(endTime) {
-											go DisWordRecode(qutil.IntAll((*orderData)["id"]), qutil.IntAll((*orderData)["order_money"]), "数据流量包", dis_word, userId)
-
-										} else {
-											log.Println("不在一年签约期内不计入分销")
-										}
-									}else {
-										log.Println("获取分销者签约信息失败")
-									}
-								} else {
-									log.Println("注册时的分销者id与本次渠道分销者id不一致，不计入佣金")
-								}
-							}else {
-								log.Println("redis获取订单分销者失败")
-							}
-						}else {
-							log.Println("获取用户注册时分销信息失败")
-						}
-					}else {
-						log.Println("获取用户注册信息失败")
-					}
-				} else {
-					//go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)
-				}
-			}
 			return true
 		}
 	}

src/jfw/modules/subscribepay/src/entity/jyCourseOnlineStruct.go

@@ -4,13 +4,10 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"log"
 	. "mongodb"
 	"pay"
 	qutil "qfw/util"
-	"qfw/util/redis"
 	frpc "qfw/util/rpc"
-	"strings"
 	"time"
 	"util"
 
@@ -29,7 +26,7 @@ func (this *jyCourseOnline) PayCallBack(param *CallBackParam) bool {
 	update := false
 	orderdata := util.Mysql.FindOne("dataexport_order", map[string]interface{}{
 		"out_trade_no": param.OutTradeno,
-	}, "id,order_status,order_money,order_code,filter_id,user_id,dis_word", "")
+	}, "id,order_status,order_money,order_code,filter_id,user_id", "")
 	pay_time := qutil.FormatDate(&now, qutil.Date_Full_Layout)
 	if orderdata != nil {
 		order_status := qutil.IntAll((*orderdata)["order_status"])
@@ -62,75 +59,6 @@ func (this *jyCourseOnline) PayCallBack(param *CallBackParam) bool {
 			update = true
 		}
 	}
-
-	// 调用分销记录 2021-09-18  添加
-	dis_word := qutil.ObjToString((*orderdata)["dis_word"])
-	userId := qutil.ObjToString((*orderdata)["user_id"])
-	// 查分销
-	if update {
-		if dis_word != "" {
-			log.Println("处理分销记录")
-			/*	//分销系统 分销记录
-				go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)*/
-			//分销系统 分销记录
-			suffix := dis_word[len(dis_word)-3 : len(dis_word)]
-			if suffix == suffix_msgt {
-				//go OtherDisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word, qutil.ObjToString((*orderdata)["user_id"]), qutil.ObjToString((*orderdata)["create_time"]))
-			} else if suffix == "_GX" {
-				// 判断是否是该企业签约一年内引流的新用户
-				// 查用户注册时的  分销口令 用于判断购买时分销是否和用户注册时分销id一致
-
-				userInfo, flag := util.MQFW.FindById("user", userId, nil)
-				if flag && userInfo != nil {
-					userInfoDisWord := qutil.ObjToString((*userInfo)["disWords"])
-
-					// 判断是否和这次口令的分销这id一致
-					//根据口令获取注册时的分销者id
-					redisRegDis := redis.GetStr("other", "DIS_"+userInfoDisWord[1:len(userInfoDisWord)])
-					var shareRegUId string
-					if redisRegDis != "" {
-						// 注册时的分销id
-						shareRegUId = strings.Split(redisRegDis, "##")[1]
-						//获取本次携带的分销id
-						redisDis := redis.GetStr("other", "DIS_"+dis_word[1:len(dis_word)])
-						if redisDis != "" {
-							//分销者id
-							shareUId := strings.Split(redisDis, "##")[1]
-							// 分销者一致
-							if shareRegUId == shareUId {
-								// 根据id查签约用户信息
-								partnerInfo := util.Mysql.FindOne("dis_partner", map[string]interface{}{"uid": shareUId}, "", "")
-								if partnerInfo != nil {
-									adopt_time := (*partnerInfo)["adopt_time"] // 签约时间即审核通过时间
-									// 判断是否在一年合约期内  在合约期内则 调用分销
-									adoptTime, _ := time.Parse(qutil.Date_Full_Layout, qutil.ObjToString(adopt_time))
-									endTime := adoptTime.AddDate(1, 0, 0)
-									// 判断当前时间是否在一年合约期内
-									if now.Before(endTime) {
-										go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "中标必听课", dis_word, userId)
-									} else {
-										log.Println("签约超过一年不计入佣金")
-									}
-								}
-							} else {
-								log.Println("注册时的分销者id与本次渠道分销者id不一致，不计入佣金")
-							}
-						} else {
-							log.Println("redis获取本次订单携带的分销者信息失败")
-						}
-					} else {
-						log.Println("redis获取注册时的分销者信息失败")
-					}
-				} else {
-					log.Println("分销记录 获取用户注册信息失败")
-				}
-
-			} else {
-				//go DisWordRecode(qutil.IntAll((*orderdata)["id"]), qutil.IntAll((*orderdata)["order_money"]), "超级订阅", dis_word)
-			}
-		}
-	}
-
 	return update
 }