|
|
@@ -68,19 +68,19 @@ func exec(name string) {
|
|
|
//takeCash()
|
|
|
//autoTakeCash() //redis队列处理
|
|
|
case "orderReceiveAutomatically": //已发货订单7天自动收货
|
|
|
- OrderReceiveAutomatically()
|
|
|
+ go OrderReceiveAutomatically()
|
|
|
case "updateUserNicknameAndHead": //修复数据-只执行一次
|
|
|
- updateUserNicknameAndHead()
|
|
|
+ go updateUserNicknameAndHead()
|
|
|
case "udpate_sold_count": //更新已售数量
|
|
|
- updateSoldCount()
|
|
|
+ go updateSoldCount()
|
|
|
case "comb_three_user": //更新内部关系
|
|
|
go threebUserRelation()
|
|
|
case "register_wxuser": //修复数据--注册会员
|
|
|
- registerWxUser()
|
|
|
+ go registerWxUser()
|
|
|
case "cancel_order": //下单24h未支付改为已取消
|
|
|
- OrderCancelAutomatically()
|
|
|
+ go OrderCancelAutomatically()
|
|
|
case "send_cent": //补发积分执行一次
|
|
|
- patchCent()
|
|
|
+ go patchCent()
|
|
|
default:
|
|
|
beego.BeeLogger.Error("Didn't get task wity name:[%s]", name)
|
|
|
}
|
