duxin před 1 měsícem
rodič
revize
51b28709de

+ 8 - 1
internal/logic/product/bigmember/bigcommon.go

@@ -529,7 +529,14 @@ func GetBigMemberProductTypeByOrderCode(level int) string {
 	return productType
 }
 
-func UserStEt(userId, lId string, isEnd bool) (st string, et string, err error) {
+func UserStEt(lId string, isEnd bool) (st string, et string, err error) {
+	var userId string
+	userIdData, _ := g.DB().GetOne(context.Background(), "SELECT dor.user_id FROM dataexport_order dor INNER JOIN jy_order_detail jod on dor.order_code = jod.order_code where jod.id =?", lId)
+	if userIdData.IsEmpty() {
+		err = errors.New("关联订单查询失败")
+		return
+	}
+	userId = gconv.String(userIdData.Map()["user_id"])
 	if isEnd {
 		entdata, _ := g.DB().GetOne(context.Background(), "SELECT start_time,end_time FROM entniche_order eo INNER JOIN entniche_wait_empower ewe on eo.wait_empower_id = ewe.id where eo.order_detail_id = ?", lId)
 		if entdata.IsEmpty() {

+ 1 - 1
internal/logic/product/bigmember/bigmember.go

@@ -344,7 +344,7 @@ func (p jyBigProduct) OpenService(ctx context.Context, serviceOpenTime time.Time
 			return err
 		}
 
-		st, et, err := UserStEt(p.param.UserId, p.param.LinkedOrderId, p.param.ReqSubject == 2)
+		st, et, err := UserStEt(p.param.LinkedOrderId, p.param.ReqSubject == 2)
 		if err == nil {
 			upData["service_starttime"] = st
 			upData["service_endtime"] = et

+ 1 - 1
internal/logic/product/bigmember/price.go

@@ -181,7 +181,7 @@ func (p jyBigProduct) GetPrice() (price int64, err error) {
 		//if err != nil {
 		//	return 0, fmt.Errorf("查询关联订单异常")
 		//}
-		st, _, err := UserStEt(p.param.UserId, p.param.LinkedOrderId, p.param.ReqSubject == 2)
+		st, _, err := UserStEt(p.param.LinkedOrderId, p.param.ReqSubject == 2)
 		if err != nil {
 			return 0, fmt.Errorf("关联服务起止时间查询异常")
 		}