|
|
@@ -128,7 +128,7 @@ func (e *EquityActive) processEquityInfo(activeName string, activeId, mold int)
|
|
|
countQuery := fmt.Sprintf("SELECT count(*) FROM %s where state= 0 and mold=? and active_id=? ;", TableEquityInfo)
|
|
|
rows, err := tx.Query(countQuery, mold, activeId)
|
|
|
if err != nil || rows == nil {
|
|
|
- log.Println("获取剩余库存数量失败：", err, rows)
|
|
|
+ log.Println("获取剩余库存数量失败：", err, rows,e.OrderCode)
|
|
|
return
|
|
|
}
|
|
|
defer rows.Close()
|
|
|
@@ -147,7 +147,7 @@ func (e *EquityActive) processEquityInfo(activeName string, activeId, mold int)
|
|
|
data, err := tx.Query(query, mold, activeId)
|
|
|
if err != nil || data == nil {
|
|
|
tx.Rollback()
|
|
|
- log.Println("获取视频权益码信息失败：", err, data)
|
|
|
+ log.Println("获取视频权益码信息失败：", err, data,e.OrderCode)
|
|
|
return
|
|
|
}
|
|
|
eId, name, code, exEndTime := 0, "", "", ""
|
|
|
@@ -156,7 +156,7 @@ func (e *EquityActive) processEquityInfo(activeName string, activeId, mold int)
|
|
|
err = data.Scan(&eId, &name, &code, &exEndTime)
|
|
|
}
|
|
|
if err != nil {
|
|
|
- log.Println("获取视频权益码失败：", err, data)
|
|
|
+ log.Println("获取视频权益码失败：", err, data,e.OrderCode)
|
|
|
tx.Rollback()
|
|
|
return
|
|
|
}
|
|
|
@@ -176,12 +176,12 @@ func (e *EquityActive) processEquityInfo(activeName string, activeId, mold int)
|
|
|
_, err = tx.Exec(update, e.OrderCode, valueStateGifted, date.NowFormat(date.Date_Full_Layout), eId)
|
|
|
if err != nil {
|
|
|
tx.Rollback()
|
|
|
- log.Println("更新视频权益码失败", err)
|
|
|
+ log.Println("更新视频权益码失败", e.OrderCode,eId,err)
|
|
|
return
|
|
|
}
|
|
|
err = tx.Commit()
|
|
|
if err != nil {
|
|
|
- log.Println("视频权益码commit失败", err)
|
|
|
+ log.Println("视频权益码commit失败",e.OrderCode,eId, err)
|
|
|
return
|
|
|
}
|
|
|
//6. 发送短信、站内信
|
