package controllers
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"github.com/satori/go.uuid"
|
"strconv"
|
"time"
|
"vamicro/compTable-service/models"
|
"vamicro/compTable-service/service"
|
"vamicro/config"
|
)
|
|
type DbTableController struct {
|
|
}
|
|
// @Summary 显示底库列表
|
// @Description 显示同步或本地库列表
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 底库管理
|
// @Param isSync path string true "是否同步库 1 同步库 2本地库 qita 全部库"
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/queryDbTables [POST]
|
func (dbt DbTableController) QueryDbTables(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
type queryDbt struct {
|
IsSync int `json:"isSync"`
|
}
|
var arg queryDbt
|
if err := c.BindJSON(&arg);err != nil {
|
return &bhomeclient.Reply{Msg:err.Error()}
|
}
|
var sv service.DbTableService
|
arr, err := sv.FindByIsSync("", strconv.Itoa(arg.IsSync))
|
var total = 0
|
if arr !=nil {
|
total = len(arr)
|
}
|
if err ==nil {
|
var m = map[string]interface{}{
|
"total": total,
|
"datalist": arr,
|
}
|
return &bhomeclient.Reply{Success:true,Data:m}
|
} else {
|
var m = map[string]interface{}{
|
"total": total,
|
"datalist": []interface{}{},
|
}
|
return &bhomeclient.Reply{Msg:"查询失败",Data:m}
|
}
|
}
|
|
// @Summary 添加底库
|
// @Description 添加同步或本地库
|
// @Accept json
|
// @Produce json
|
// @Tags 底库管理
|
// @Param obj body models.Dbtables true "底库数据"
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/addDbTableInfo [PUT]
|
func (dtc DbTableController) Add(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var dbt models.Dbtables
|
err := c.BindJSON(&dbt)
|
if err !=nil || dbt.TableName == "" {
|
return &bhomeclient.Reply{Msg:"参数有误"}
|
}
|
if dbt.Id == "" {
|
dbt.Id = uuid.NewV4().String()
|
}
|
if dbt.AnalyServerId == "sync" {
|
dbt.AnalyServerId = ""
|
}
|
if dbt.AnalyServerId == "local" {
|
|
if config.Server.AnalyServerId == "" {
|
return &bhomeclient.Reply{Msg:"服务器serverId配置有误"}
|
}
|
dbt.AnalyServerId = config.Server.AnalyServerId
|
}
|
dbt.PriInsert() // 添加时间和创建人
|
currentTime := time.Now()
|
startTime := dbt.StartTime
|
endTime := ""
|
if dbt.EndTime != "" {
|
endTime = dbt.EndTime
|
}
|
st, _ := time.ParseInLocation("2006-01-02 15:04:05", startTime, time.Local)
|
if endTime != "" {
|
et, _ := time.ParseInLocation("2006-01-02 15:04:05", endTime, time.Local)
|
if et.After(currentTime) && st.Before(currentTime) {
|
dbt.Enable = 1
|
} else {
|
dbt.Enable = 0
|
}
|
} else {
|
if st.Before(currentTime) {
|
dbt.Enable = 1
|
} else {
|
dbt.Enable = 0
|
}
|
}
|
|
var sv service.DbTableService
|
b, err := sv.Add(dbt)
|
if err !=nil && err.Error() == "dbt exist" {
|
return &bhomeclient.Reply{Msg:"底库名称不允许重复"}
|
}
|
if b {
|
return &bhomeclient.Reply{Success:true,Data:dbt}
|
} else {
|
return &bhomeclient.Reply{Msg:"新增失败"}
|
}
|
}
|
|
// @Summary 删除底库
|
// @Description 删除同步或本地库
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 底库管理
|
// @Param id path string true "底库id "
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/deleteDBtablesById [POST]
|
func (dtc DbTableController) DeleteById(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
id := c.Query("id")
|
if id == "" {
|
return &bhomeclient.Reply{Msg:"参数有误"}
|
}
|
var sv service.DbTableService
|
b, _ := sv.DeleteById(id)
|
if b{
|
return &bhomeclient.Reply{Success:true, Msg:"删除成功"}
|
} else {
|
return &bhomeclient.Reply{Msg:"删除失败"}
|
}
|
}
|
|
// @Summary 修改底库
|
// @Description 修改底库
|
// @Accept json
|
// @Produce json
|
// @Tags 底库管理
|
// @Param table body models.Dbtables true "底库数据"
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/updateDbTables [POST]
|
func (dtc DbTableController) UpdateDbTables(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var dbt models.Dbtables
|
err := c.BindJSON(&dbt)
|
if err !=nil || dbt.TableName == "" || dbt.Id == "" {
|
return &bhomeclient.Reply{Msg:"参数有误"}
|
}
|
|
currentTime := time.Now()
|
startTime := dbt.StartTime
|
endTime := ""
|
if dbt.EndTime != "" {
|
endTime = dbt.EndTime
|
}
|
st, _ := time.ParseInLocation("2006-01-02 15:04:05", startTime, time.Local)
|
if endTime != "" {
|
et, _ := time.ParseInLocation("2006-01-02 15:04:05", endTime, time.Local)
|
if et.After(currentTime) && st.Before(currentTime) {
|
dbt.Enable = 1
|
} else {
|
dbt.Enable = 0
|
}
|
} else {
|
if st.Before(currentTime) {
|
dbt.Enable = 1
|
} else {
|
dbt.Enable = 0
|
}
|
}
|
|
var sv service.DbTableService
|
b, _ := sv.Update(dbt)
|
if b{
|
return &bhomeclient.Reply{Success:true, Msg:"更新成功"}
|
} else {
|
return &bhomeclient.Reply{Msg:"更新失败"}
|
}
|
}
|
|
type DbTStatusVo struct {
|
Id string `json:"id"`
|
Enable int `json:"enable"`
|
}
|
|
// @Summary 修改底库状态
|
// @Description 修改同步或本地库底库状态
|
// @Accept json
|
// @Produce json
|
// @Tags dbtable
|
// @Param obj body controllers.DbTStatusVo true "底库状态修改参数"
|
// @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"返回错误信息", success:false}"
|
// @Router /data/api-v/dbtable/updateDbTableStatus [POST]
|
func (dbt DbTableController) UpdateDbTableStatus(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var ds DbTStatusVo
|
err := c.BindJSON(&ds)
|
if err !=nil || ds.Id == "" || (ds.Enable !=0 && ds.Enable !=1) {
|
return &bhomeclient.Reply{Msg:"参数有误"}
|
}
|
|
var dt models.Dbtables
|
rows, e := dt.SelectById(ds.Id)
|
if e != nil || rows == 0 {
|
return &bhomeclient.Reply{Msg: "底库不存在"}
|
}
|
if ds.Enable == 1 {
|
str := dt.StartTime
|
etr := dt.EndTime
|
ct := time.Now()
|
st, _ := time.ParseInLocation("2006-01-02 15:04:05", str, time.Local)
|
b := false
|
if etr != "" {
|
et,_ := time.ParseInLocation("2006-01-02 15:04:05", etr, time.Local)
|
if et.After(ct) && st.Before(ct) {
|
b = true
|
}
|
} else {
|
if st.Before(ct) {
|
b = true
|
}
|
}
|
//b 为true才允许开启
|
if !b {
|
return &bhomeclient.Reply{ Msg: "当前不允许启用"}
|
}
|
}
|
|
var sv service.DbTableService
|
b,_ := sv.UpdateDbTableStatus(ds.Id, ds.Enable)
|
if b {
|
return &bhomeclient.Reply{Success:true, Msg:"更新成功"}
|
} else {
|
return &bhomeclient.Reply{Msg:"更新失败"}
|
}
|
}
|
|
type IdsArr struct {
|
Ids []string `json:"ids"`
|
}
|
|
// @Summary 查询底库列表
|
// @Description 查询底库列表
|
// @Accept json
|
// @Produce json
|
// @Tags 底库管理
|
// @Param ids body controllers.IdsArr true "底库ids"
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/dbtablesByIds [POST]
|
func (dbt DbTableController) DbtablesByIds(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var ids IdsArr
|
err := c.BindJSON(&ids)
|
if err !=nil || len(ids.Ids) == 0 {
|
return &bhomeclient.Reply{Msg:"参数有误"}
|
}
|
var sv service.DbTableService
|
arr,e := sv.FindByDbtIds(ids.Ids)
|
if e ==nil {
|
return &bhomeclient.Reply{Success:true,Data:arr}
|
} else {
|
return &bhomeclient.Reply{Msg:"查询失败",Data:[]interface{}{}}
|
}
|
}
|
|
// @Summary 查询本机所有底库列表
|
// @Description 查询本机所有底库列表
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags dbtable
|
// @Param isDelete query string true "0：查未删除，1：查已删除，其他：查所有"
|
// @Param type query string false "人员：person， 车辆库:car"
|
// @Success 200 {string} json "{"code":200, msg:"", success:true}"
|
// @Failure 500 {string} json "{"code":500, msg:"", success:false}"
|
// @Router /data/api-v/dbtable/findAllDbTablesByCurServer [GET]
|
func (dbt DbTableController) FindAllDbTablesByCurServer(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var sv service.DbTableService
|
isDeleteStr := c.Query("isDelete")
|
isDelete, _ := strconv.Atoi(isDeleteStr)
|
typ := c.Query("type")
|
arr,e := sv.FindAllDbTablesByCurServer(isDelete, typ)
|
if e == nil {
|
return &bhomeclient.Reply{Success:true,Data:arr}
|
} else {
|
return &bhomeclient.Reply{Msg:"查询失败",Data:[]interface{}{}}
|
}
|
}
|
|
// @Router /data/api-v/dbtable/findAllDbTables [GET]
|
func (dbt DbTableController) FindAllDbTables(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var sv service.DbTableService
|
arr,e := sv.FindAllDbTables()
|
if e == nil {
|
return &bhomeclient.Reply{Success:true,Data:arr}
|
} else {
|
return &bhomeclient.Reply{Msg:"查询失败",Data:[]interface{}{}}
|
}
|
}
|
|
// @Router /data/api-v/dbtable/findAllLocalDbTables [GET]
|
func (dbt DbTableController) FindAllLocalDbTables(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
isDelete := c.Query("isDelete")
|
var sv service.DbTableService
|
arr,e := sv.FindAllLocalDbTables(isDelete)
|
if e == nil {
|
return &bhomeclient.Reply{Success:true,Data:arr}
|
} else {
|
return &bhomeclient.Reply{Msg:"查询失败",Data:[]interface{}{}}
|
}
|
}
|
