|
@ -29,7 +29,7 @@ func (t *ShakeRedEnvelopeCtl) Status() { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func (t *ShakeRedEnvelopeCtl) Shake() { |
|
|
func (t *ShakeRedEnvelopeCtl) Shake() { |
|
|
customerId := t.MustGetInt64("customer_id") |
|
|
|
|
|
|
|
|
//customerId := t.MustGetInt64("customer_id")
|
|
|
ruleId := t.MustGetInt64("shake_red_envelope_rule_id") |
|
|
ruleId := t.MustGetInt64("shake_red_envelope_rule_id") |
|
|
userId := t.MustGetUID() |
|
|
userId := t.MustGetUID() |
|
|
areaId := t.MustGetAreaId() |
|
|
areaId := t.MustGetAreaId() |
|
@ -104,7 +104,7 @@ func (t *ShakeRedEnvelopeCtl) Shake() { |
|
|
|
|
|
|
|
|
go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id), |
|
|
go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id), |
|
|
define.TYPE_H5USER, userId, map[string]interface{}{ |
|
|
define.TYPE_H5USER, userId, map[string]interface{}{ |
|
|
"customer_id": customerId, |
|
|
|
|
|
|
|
|
"customer_id": activity.CustomerId, |
|
|
"user_id": user.Id, |
|
|
"user_id": user.Id, |
|
|
"type": "shake_rb", |
|
|
"type": "shake_rb", |
|
|
"data": map[string]interface{}{ |
|
|
"data": map[string]interface{}{ |
|
@ -117,8 +117,8 @@ func (t *ShakeRedEnvelopeCtl) Shake() { |
|
|
}) |
|
|
}) |
|
|
|
|
|
|
|
|
go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id), |
|
|
go ws_send_service.SendShakeRedEnvelope(fmt.Sprintf("%d", activity.Id), |
|
|
define.TYPE_CUSTOMER, customerId, map[string]interface{}{ |
|
|
|
|
|
"customer_id": customerId, |
|
|
|
|
|
|
|
|
define.TYPE_CUSTOMER, activity.CustomerId, map[string]interface{}{ |
|
|
|
|
|
"customer_id": activity.CustomerId, |
|
|
"user_id": user.Id, |
|
|
"user_id": user.Id, |
|
|
"type": "shake_rb", |
|
|
"type": "shake_rb", |
|
|
"data": map[string]interface{}{ |
|
|
"data": map[string]interface{}{ |
|
|