patch cent 1202-1204

go/gopath/src/fohow.com/apps/controllers/cron_controller/init.go

@@ -83,6 +83,8 @@ func exec(name string) {
 		registerWxUser()
 	case "cancel_order": //下单24h未支付改为已取消
 		OrderCancelAutomatically()
+	case "send_cent": //补发积分执行一次
+		patchCent()
 	default:
 		beego.BeeLogger.Error("Didn't get task wity name:[%s]", name)
 	}

go/gopath/src/fohow.com/apps/controllers/cron_controller/patch_cent.go

@@ -0,0 +1,40 @@
+package cron_controller
+
+import (
+	"fmt"
+	"fohow.com/apps/models/cent_model"
+	"fohow.com/apps/models/user_model"
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/orm"
+)
+
+/*
+	1202-1204补发 系统的额外赠送5积分
+*/
+func patchCent() {
+
+	var list []*user_model.BindUser
+	sql := `
+		select *
+		  from bind_users
+		 where date_add( created_at,interval 8 hour) >="2020-12-02 00:00:00" and  date_add( created_at,interval 8 hour) <="2020-12-05 00:00:00";
+	`
+	_, err := orm.NewOrm().Raw(sql).QueryRows(&list)
+	if err != nil {
+		beego.Debug("patchCent err=[%s]", err)
+		return
+	}
+
+	beego.BeeLogger.Warn("patchCent.len(list):%d", len(list))
+
+	for _, bindUser := range list {
+		wxUser := user_model.GetWxUserByUserNo(bindUser.UserNo)
+		if wxUser != nil {
+			//赠送5积分
+			s := cent_model.CENT_FIRST_LOGIN
+			count := int64(500)
+			remark := fmt.Sprintf("赠送积分：%.2f", float64(count)/float64(100))
+			new(cent_model.CentBalance).Create(wxUser.Id, count, s, s, remark)
+		}
+	}
+}