package entity

import (
	. "online_datasync/config"
	. "online_datasync/db"
)

var (
	Integral_flow *integral_flow
)

type integral_flow struct {
}

func (i *integral_flow) TableName() string {
	return "integral_flow"
}

//
func (i *integral_flow) SaveFields() []string {
	return []string{"id", "userId", "pointType", "SourceId", "sourceType", "point", "createTime", "endDate", "appId", "sort", "abstract", "operationType", "serialNumber"}
}

//
func (i *integral_flow) Run(start_unix, end_unix int64, start_layout, end_layout string) {
	TimeTask.Integral_flow_id = sync_add(Mysql_From_Jypoints, i.TableName(), i.SaveFields(), TimeTask.Integral_flow_id, nil)
}