tijiao

entity/integral.go

@@ -1,7 +1,8 @@
 package entity
 
-import "time"
+import "github.com/go-xorm/xorm"
 
+var Engine *xorm.Engine
 //积分余额
 type Balance struct {
 	Id          int64  `xorm:"pk autoincr id" form:"id" json:"id"`
@@ -12,23 +13,23 @@ type Balance struct {
 
 //积分流水
 type Flow struct {
-	Id             int64     `xorm:"pk autoincr id" form:"id" json:"id"`
-	UserId         string    `xorm:"userId" form:"userId" json:"userId"`                           //用户标识
-	PointType      int       `xorm:"pointType" form:"pointType" json:"pointType"`                  //积分类型
-	BusinessTypeId int       `xorm:"businessTypeId" form:"businessTypeId" json:"businessTypeId"`   //业务单据标识
-	BusinessType   string    `xorm:"businessType" form:"businessType" json:"businessType"`         //业务类型
-	Point          int       `xorm:"point" form:"point" json:"point"`                              //积分
-	TimeStamp      time.Time `xorm:"timeStamp" time_format:"2006-01-02 15:04:05" json:"timeStamp"` //创建时间
-	EndDate        time.Time `xorm:"endDate" time_format:"2006-01-02 15:04:05" json:"endDate"`     //截止时间
-	AppId          int       `xorm:"appId" form:"appId" json:"appId"`                              //剑鱼标识
+	Id             int64  `xorm:"pk autoincr id" form:"id" json:"id"`
+	UserId         string `xorm:"userId" form:"userId" json:"userId"`                         //用户标识
+	PointType      int    `xorm:"pointType" form:"pointType" json:"pointType"`                //积分类型
+	BusinessTypeId int    `xorm:"businessTypeId" form:"businessTypeId" json:"businessTypeId"` //业务单据标识
+	BusinessType   string `xorm:"businessType" form:"businessType" json:"businessType"`       //业务类型
+	Point          int    `xorm:"point" form:"point" json:"point"`                            //积分
+	CreateTime     string `xorm:"createTime" form:"createTime" json:"createTime"`             //创建时间
+	EndDate        string `xorm:"endDate" form:"endDate" json:"endDate"`                      //截止时间
+	AppId          int    `xorm:"appId" form:"appId" json:"appId"`                            //剑鱼标识
 }
 
 //积分结存
 type Solde struct {
-	Id              int64     `xorm:"pk autoincr id" form:"id" json:"id"`
-	PerManEntPoints int       `xorm:"perManEntPoints" form:"perManEntPoints" json:"perManEntPoints"` //永久积分
-	TimePoints      int       `xorm:"timePoints" form:"timePoints" json:"timePoints"`                //时效积分
-	EndDate         time.Time `xorm:"endDate" time_format:"2006-01-02 15:04:05" json:"endDate"`      //有效期止
-	CountPoints     int       `xorm:"countPoints" form:"countPoints" json:"countPoints"`             //合计
-	AppId           int       `xorm:"appId" form:"appId" json:"appId"`                               //剑鱼标识
+	Id              int64  `xorm:"pk autoincr id" form:"id" json:"id"`
+	PerManEntPoints int    `xorm:"perManEntPoints" form:"perManEntPoints" json:"perManEntPoints"` //永久积分
+	TimePoints      int    `xorm:"timePoints" form:"timePoints" json:"timePoints"`                //时效积分
+	EndDate         string `xorm:"endDate" form:"endDate" json:"endDate"`                         //有效期止
+	CountPoints     int    `xorm:"countPoints" form:"countPoints" json:"countPoints"`             //合计
+	AppId           int    `xorm:"appId" form:"appId" json:"appId"`                               //剑鱼标识
 }

rpc/integral.go

@@ -6,6 +6,8 @@ import (
 	_ "github.com/go-sql-driver/mysql"
 	"github.com/go-xorm/xorm"
 	"log"
+	"points_service/entity"
+	"points_service/service"
 
 	"points_service/rpc/integral"
 	"points_service/rpc/internal/config"
@@ -19,6 +21,10 @@ import (
 
 var configFile = flag.String("f", "etc/integral.yaml", "the config file")
 var c config.Config
+var (
+	integralService = &service.IntegralService{}
+)
+
 
 func main() {
 	conf.MustLoad(*configFile, &c)
@@ -38,9 +44,10 @@ func init() {
 	var err error
 	conf.MustLoad(*configFile, &c)
 	fmt.Println(c.DataSource)
-	config.Engine, err = xorm.NewEngine("mysql", c.DataSource)
+	entity.Engine, err = xorm.NewEngine("mysql", c.DataSource)
 	if err != nil {
 		log.Fatal("数据库连接失败:", err)
 	}
+	log.Println("积分流水：",integralService.IntegralConsumeService())
 	fmt.Println(c.DataSource+"链接成功")
 }

service/integralService.go

@@ -1 +1,9 @@
 package service
+
+
+
+//积分表新增数据
+
+//结存调整
+
+//余额调整