Browse Source

no message

xingzai 6 months ago
parent
commit
0661e1499f
3 changed files with 16 additions and 1 deletions
  1. 1 0
      controllers/order.go
  2. 8 0
      models/order/order_virtual_asset.go
  3. 7 1
      services/order.go

+ 1 - 0
controllers/order.go

@@ -256,6 +256,7 @@ func (this *OrderController) AddByActivity() {
 			br.ErrMsg = "获取信息失败,音视频数据类型错误"
 			return
 		}
+		item.SourceTitle = title
 	}
 
 	//如果十分钟之内有相同的订单就修改,没有就新增

+ 8 - 0
models/order/order_virtual_asset.go

@@ -96,6 +96,14 @@ func GetCygxOrderVirtualAssetdCount(condition string, pars []interface{}) (count
 	return
 }
 
+// 获取数量
+func GetCygxOrderVirtualAssetdCountByVivo(sourceId int) (count int, err error) {
+	o := orm.NewOrm()
+	sqlCount := ` SELECT COUNT(1) AS  count  FROM cygx_order_virtual_asset WHERE source IN ('activityvideo','activityvoice')   AND  source_id = ? `
+	err = o.Raw(sqlCount, sourceId).QueryRow(&count)
+	return
+}
+
 // 获取购买的单场活动
 func GetCygxOrderVirtualAssetActivityList(sourceIds []int, mobile string) (items []*CygxOrderVirtualAsset, err error) {
 	lenArr := len(sourceIds)

+ 7 - 1
services/order.go

@@ -158,7 +158,13 @@ func GetActivityVivoPoints(item *models.ActivityDetail, wxUser *models.WxUserIte
 		return
 	}
 
-	if totalMySuccess > 0 {
+	totalPayVivo, e := order.GetCygxOrderVirtualAssetdCountByVivo(activityId)
+	if e != nil {
+		err = errors.New("GetCygxActivityPointsSetUserNum, Err: " + e.Error())
+		return
+	}
+	//如果报了名,或者付费了,就直接观看
+	if totalMySuccess > 0 || totalPayVivo > 0 {
 		vivoPointsResp.HavePoint = true
 	}