tmrgo/routers/api/db.go

package api

import (
	"bytes"
	"database/sql"
	"encoding/json"
	"errors"
	"fmt"
	"io/ioutil"
	"net/http"
	"os"
	"path"
	"regexp"
	"strconv"
	"strings"
	"sync"
	"time"

	"../../pkg/app"
	"../../pkg/e"
	"../../pkg/logging"
	"../../pkg/setting"
	"../../routers/restful"
	"github.com/360EntSecGroup-Skylar/excelize"
	"github.com/Anderson-Lu/gofasion/gofasion"
	"github.com/astaxie/beego/logs"
	"github.com/gin-gonic/gin"
	"github.com/tealeg/xlsx"
	"github.com/xormplus/xorm"
)

// @Summary   根据SQL执行得到数据集
// @Tags getData
// @Accept json
// @Produce  json
// @Param  sql  query   string true "sql"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/getdata  [POST]
func GetData(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlstr := fsion.Get("sql").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	queryData, err := getDataBySql(sqlstr, offset, pagecount, returntype, nil)

	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, queryData)
	}
}

func Testpartitions(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	databaseName := fsion.Get("databaseName").ValueStr()                     //获取新数据库名称
	user := fsion.Get("user").ValueStr()                                     //获取新数据库用户
	passWord := fsion.Get("passWord").ValueStr()                             //获取新数据库名称
	host := fsion.Get("host").ValueStr()                                     //获取新数据库名称
	port := fsion.Get("port").ValueStr()                                     //获取新数据库名称
	sqls, err1 := restful.Engine.SQL("SELECT * FROM sql_new ").QueryString() //获取新数据库表
	if sqls == nil || err1 != nil {
		appG.Response(http.StatusOK, e.SUCCESS, "失败："+err1.Error())
	}
	sqlstrs := strings.Split(sqls[0]["sql"], ";") //分割sql
	connecting := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8", user, passWord, host, port, "mysql")
	mydb, err := sql.Open("mysql", connecting) //连接新连接
	if err != nil {
		println("err1", err.Error())
	}
	_, err = mydb.Exec("CREATE DATABASE IF NOT EXISTS `" + databaseName + "`") // 创建数据库
	if err != nil {
		println("err2", err.Error())
	}

	mydb.Close()

	connecting = fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8", user, passWord, host, port, databaseName) //连接新数据库，创建表格
	mydb, err = sql.Open("mysql", connecting)
	if err != nil {
		println("err3", err.Error())
	}
	defer mydb.Close()
	if err == nil {
		mydb.SetMaxOpenConns(10)
		mydb.SetMaxIdleConns(10)
	}
	errmsg := ""
	if err == nil {
		//tx ,_ :=mydb.Begin()

		for _, sqlstr := range sqlstrs {
			//println("sqlstr---",sqlstr)
			if sqlstr == "" {
				continue
			}
			_, err = mydb.Exec(sqlstr)
			if err != nil {
				println("err4", err.Error())
				errmsg = err.Error()
				//err1 :=tx.Rollback()
			}
		}

		//_, err = mydb.Exec("CREATE TABLE `sql_new` (`sql` text DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=latin1;")
		//err =tx.Commit()

	}
	if errmsg == "" {
		appG.Response(http.StatusOK, e.SUCCESS, "成功"+databaseName)
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, "失败"+errmsg)
	}

}

func TestData(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlstr := fsion.Get("sql").ValueStr()
	token := ""
	if tempv, exists := c.Get("jwt_username"); exists {
		token = tempv.(string)
	}
	appG.Response(http.StatusOK, e.SUCCESS, "你录入的名字是："+sqlstr+"；token:"+token)
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags GetDataByName
// @Accept json
// @Produce  json
// @Param  sqlname  body   string true "sqlname"
// @Param  offset  body   int true "offset"
// @Param  pagecount  body   int true "pagecount"
// @Param  returntype  body   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/GetDataByName  [POST]
func GetDataByName(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			if sqlnamestr != "getNoMesList" && sqlnamestr != "getNoMesCount" {
				logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, parammaps.ValueStr())
			}

			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						// if sqlnamestr == "getprocessAnalysis" && value == "tmrtname" {
						// 	tmrArray := parammaps.Get(strings.Trim(value, " ")).Array()
						// 	tmrNameList := []string{}
						// 	for _, tmr := range tmrArray {
						// 		tmrNameList = append(tmrNameList, tmr.ValueStr())
						// 	}
						// 	s_params = append(s_params, strings.Join(tmrNameList, ","))
						// } else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
						// }
					}
				}
			}
		} else if fsion.HasKey("params") {
			params := fsion.Get("params").Array()
			logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, params)
			for _, v_params := range params {
				s_params = append(s_params, v_params.ValueStr())
			}
		}
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			//c.File("c:/dd.xlsx")
			c.Header("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
			c.Header("Content-Disposition", "attachment; filename="+"Workbook.xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)

		} else {

			queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
			if err != nil {
				logging.Error("GetDataByName  err: ", err)
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
			} else {
				appG.Response(http.StatusOK, e.SUCCESS, queryData)
			}
		}

	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags GetDataByName
// @Accept json
// @Produce  json
// @Param  sqlname  body   string true "sqlname"
// @Param  offset  body   int true "offset"
// @Param  pagecount  body   int true "pagecount"
// @Param  returntype  body   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/GetDataByName  [POST]
func GetDataBySqlIN(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			if sqlnamestr != "getNoMesList" && sqlnamestr != "getNoMesCount" {
				logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, parammaps.ValueStr())
			}

			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		} else if fsion.HasKey("params") {
			params := fsion.Get("params").Array()
			logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, params)
			for _, v_params := range params {
				s_params = append(s_params, v_params.ValueStr())
			}
		}
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			//c.File("c:/dd.xlsx")
			c.Header("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
			c.Header("Content-Disposition", "attachment; filename="+"Workbook.xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)

		} else {

			queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
			if err != nil {
				logging.Error("GetDataByName  err: ", err)
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
			} else {
				appG.Response(http.StatusOK, e.SUCCESS, queryData)
			}
		}

	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// 错误处理
// 将报错信息处理成汉字
func geterrmsg(errstr string) (msgstr string) {
	var hzRegexp = regexp.MustCompile("^[\u4e00-\u9fa5]$") // 判断是否为汉字
	rs := []rune(errstr)
	if hzRegexp.MatchString(string(rs[0])) {
		msgstr = errstr
		return
	}

	if strings.Contains(errstr, "Duplicate entry") {
		strs := strings.Split(errstr, ` key '`)
		if len(strs) > 1 {
			if len(strs[len(strs)-1]) > 1 {
				errstr = "Duplicate entry :" + strs[len(strs)-1]
			}
		}
	}

	msg, err := restful.Engine.SQL("SELECT msg FROM err_msg where err = ? ", errstr).QueryString()
	if err != nil {
		msgstr = errstr
		return
	}
	if msg == nil || len(msg) == 0 {
		var param []interface{}
		param = append(param, errstr, errstr)
		go func() {
			tx := restful.Engine.NewSession()
			err := tx.Begin()
			defer func() {
				switch {
				case err != nil:
					logging.Error("tx.Begin 事务启动失败__error:", err)
					if tx != nil {
						tx.Rollback()
					}
				default:
					if tx != nil {
						err = tx.Commit()
					}
				}
				if tx != nil {
					tx.Close()
				}
			}()
			_, err = restful.ExecQueryT("insert into err_msg(err,msg) VALUES(?,?) ON DUPLICATE KEY UPDATE err=err", param, tx)
			if err != nil {
				logging.Error("insert into err_msg(err,msg) err", err)
			}

		}()
		msgstr = errstr
	} else {
		msgstr = msg[0]["msg"]
	}
	return
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags GetDataByNameForm
// @Accept json
// @Produce  json
// @Param  sqlname  body   json true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Param  s formData   json true "ss"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/GetDataByNameForm  [POST]
func GetDataByNameForm(c *gin.Context) {
	appG := app.Gin{C: c}
	//sqlnamestr := c.PostForm("measureNumber")
	//dataByte, _ := ioutil.ReadAll(c.Request.Body)
	//fsion := gofasion.NewFasion(string(dataByte))
	//sqlnamestr := fsion.Get("name").ValueStr()
	//offset := fsion.Get("offset").ValueInt()
	//pagecount := fsion.Get("pagecount").ValueInt()
	//returntype := fsion.Get("returntype").ValueStr()
	//params := fsion.Get("params").Array()

	c.Request.ParseForm()
	params := c.Request.Form
	offset := 0
	pageSize_ := 0
	returntype := params.Get("page")
	if returntype == "" {
		returntype = "0"
	}
	if tempv, exists := c.Get("jwt_username"); exists {
		params.Set("JwtUserName", tempv.(string))
	} else {
		params.Set("JwtUserName", "")
	}
	sqlnamestr := params.Get("name")
	logging.Info("GetDataByNameForm ", c.Keys, sqlnamestr)
	s_params := make([]interface{}, 0)
	if returntype == "1" {
		pageNum, error := strconv.Atoi(params.Get("pageNum"))
		if error != nil {
			appG.ResponseEq(http.StatusOK, e.ERROR, 0, "页码不是整数")
		}
		pageSize, error := strconv.Atoi(params.Get("pageSize"))
		if error != nil {
			appG.ResponseEq(http.StatusOK, e.ERROR, 0, "每页行数不是整数")
		}
		pageSize_ = pageSize
		offset = pageNum
	}

	sql, p := restful.GetSqlByNameDB(sqlnamestr)

	paramslist := strings.Split(p, ",")
	if len(paramslist) > 0 && p != "" {
		for _, value := range paramslist {
			s_params = append(s_params, params.Get(strings.Trim(value, " ")))
		}
	}

	if sql != "" {
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			c.Header("Content-Type", "application/octet-stream")
			c.Header("Content-Disposition", "attachment; filename="+sqlnamestr+".xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)
		} else {
			queryData, err := getDataBySql(sql, offset, pageSize_, returntype, s_params)

			if err != nil {
				appG.ResponseEq(http.StatusOK, e.ERROR, 1, err.Error())
			} else {
				appG.ResponseEq(http.StatusOK, e.SUCCESS, 0, queryData)
			}
		}

	} else {
		appG.ResponseEq(http.StatusOK, e.SUCCESS, 0, "后台没有数据接口")
	}
}

// @Summary   递归获取所有
// @Tags menu
// @Accept json
// @Produce  json
// @Param  Ton  query  string true "Ton"
// @Success 200 {string} json "{ "code": 200, "data": {}, "msg": "ok" }"
// @Router /authdata/GetRoleMenus  [GET]
func GetRecuDataByName(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	parentidname := fsion.Get("idname").ValueStr()
	sql, p := restful.GetSqlByNameDB(sqlnamestr)
	params := make(map[string]interface{})
	s_params := make([]interface{}, 0)
	if fsion.HasKey("params") {

		for _, v_params := range fsion.Get("params").Array() {
			s_params = append(s_params, v_params.ValueStr())
		}
		params["params"] = s_params

	} else {
		jparams := fsion.Get("parammaps")
		paramslist := strings.Split(p, ",")
		if len(paramslist) > 0 && p != "" {
			for _, value := range paramslist {
				if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
					if tempv, exists := c.Get("jwt_username"); exists {
						params[value] = tempv.(string)
					} else {
						params[value] = ""
					}
				} else {
					params[value] = jparams.Get(strings.Trim(value, " ")).ValueStr()
				}
			}

		}
	}
	queryData, err := GetRecuData_BySql(sql, p, parentidname, params, fsion.HasKey("params"))
	logging.Info("sqlname parammaps", c.Keys, c.Request.RemoteAddr, sqlnamestr, params)
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	}
	appG.Response(http.StatusOK, e.SUCCESS, queryData)
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags GetDataByNames
// @Accept json
// @Produce  json
// @RequestBody  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/GetDataByNames  [POST]
func GetDataByNames(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlParams := fsion.Array()
	queryData := make(map[string]interface{})
	for _, v := range sqlParams {
		fsion2 := gofasion.NewFasion(v.Json())
		logging.Info("GetDataByNames", c.Keys, fsion2.Get("name").ValueStr(), c.Request.RemoteAddr)
		sql, p := restful.GetSqlByNameDB(fsion2.Get("name").ValueStr())
		if sql == "" {
			errorm := make(map[string]interface{})
			errorm["code"] = e.ERROR
			errorm["message"] = "sql没找到"
			queryData[fsion2.Get("name").ValueStr()] = errorm
			continue
		} else if sql != "" {
			offset := fsion2.Get("offset").ValueInt()
			pagecount := fsion2.Get("pagecount").ValueInt()
			returntype := fsion2.Get("returntype").ValueStr()
			s_params := make([]interface{}, 0)
			if fsion2.HasKey("parammaps") {
				parammaps := fsion2.Get("parammaps")
				paramslist := strings.Split(p, ",")
				if len(paramslist) > 0 && p != "" {
					for _, value := range paramslist {
						if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
							if tempv, exists := c.Get("jwt_username"); exists {
								s_params = append(s_params, tempv.(string))
							} else {
								s_params = append(s_params, "")
							}
						} else {
							s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
						}
					}
				}
			} else if fsion2.HasKey("params") {
				params := fsion2.Get("params").Array()
				for _, v_params := range params {
					s_params = append(s_params, v_params.ValueStr())
				}
			}

			queryData1, err := getDataBySql(sql, offset, pagecount, returntype, s_params)

			if err != nil {
				errorm := make(map[string]interface{})
				errorm["code"] = e.ERROR
				errorm["message"] = err.Error()
				queryData[fsion2.Get("name").ValueStr()] = errorm
				logging.Error("GetDataByNames  err: ", err)
				continue
			} else {
				queryData[fsion2.Get("name").ValueStr()] = queryData1
			}
		}
	}
	appG.Response(http.StatusOK, e.SUCCESS, queryData)
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags PostDataByNameForm
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误朱红彬彬"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByNameForm  [POST]
func PostDataByNameForm(c *gin.Context) {
	appG := app.Gin{C: c}

	c.Request.ParseForm()
	params := c.Request.Form
	sqlnamestr := params.Get("name")
	logging.Info("PostDataByNameForm ", c.Keys, sqlnamestr)

	s_params := make([]interface{}, 0)

	sql, p := restful.GetSqlByNameDB(sqlnamestr)
	paramslist := strings.Split(p, ",")

	if len(paramslist) > 0 {
		for _, value := range paramslist {
			s_params = append(s_params, params.Get(strings.Trim(value, " ")))
		}
	}

	if sql != "" {
		queryData, err := execDataBySql(sql, s_params)

		if err != nil {
			appG.ResponseEq(http.StatusOK, e.ERROR, 1, err.Error())
		} else {
			appG.ResponseEq(http.StatusOK, e.SUCCESS, 0, queryData)
		}
	} else {
		appG.ResponseEq(http.StatusOK, e.SUCCESS, 0, "后台没有数据接口")
	}
}

// @Summary   将数据集转换格式
// @Tags PostDataByNameForm
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误朱红彬彬"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
func GetReportform(c *gin.Context) {

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)

	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	checked := fsion.Get("checked").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)

	parammaps := fsion.Get("parammaps")
	logging.Info("GetReportform ", c.Keys, sqlnamestr, parammaps)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	queryData, err := praseReportform(sqlnamestr, parammaps, tx, checked, offset, pagecount)
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, queryData)
	}

}

//保养计划
func GetUpkeepPlan(c *gin.Context) {

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)

	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	month := fsion.Get("month").ValueDefaultStr("map")
	logging.Info("GetUpkeepPlan ", c.Keys, sqlnamestr, month)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		} else if fsion.HasKey("params") {
			params := fsion.Get("params").Array()
			for _, v_params := range params {
				s_params = append(s_params, v_params.ValueStr())
			}
		}
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			//c.File("c:/dd.xlsx")
			c.Header("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
			c.Header("Content-Disposition", "attachment; filename="+"Workbook.xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)

		} else {
			queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)

			if err != nil {
				appG.Response(http.StatusOK, e.ERROR, err.Error())
			} else {
				for index, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {
					if v, ok := value["id"]; ok {
						//month = "2020-03"
						seviceplans, _ := tx.SQL("SELECT * FROM seviceplan where eqId = ? and month=? ", v, month).QueryString() //获取保养计划
						if seviceplans != nil {
							for _, va := range seviceplans { //根据保养计划获取保养单
								//day,_ :=strconv.Atoi(va["day"])
								bigupkeeps, _ := tx.SQL("SELECT * FROM bigupkeep where seviceplanId = ?", va["id"]).QueryString() //获取保养计划中的保养单
								//buk := make(map[string]map[string]string)
								for _, bu := range bigupkeeps { //日期为key ，保养单为value 存到map中
									jstr := ""
									if bu["plantime"][8:9] == "0" {
										jstr = "m" + bu["plantime"][9:]
									} else {
										jstr = "m" + bu["plantime"][8:]
									}

									if bu["flowCompeleted"] < "2" && bu["plantime"] < time.Now().Format("2006-01-02") { //如果保养状态是0并且小于当前日期 则状态已延期2
										queryData.(map[string]interface{})["list"].([]map[string]interface{})[index][jstr] = va["upkeepName"] + "#" + va["id"] + "#2" + "#" + bu["id"] + "#" + bu["pushbackId"]
									} else {
										if bu["flowCompeleted"] >= "2" {
											queryData.(map[string]interface{})["list"].([]map[string]interface{})[index][jstr] = va["upkeepName"] + "#" + va["id"] + "#1" + "#" + bu["id"] + "#" + bu["pushbackId"]
										} else {
											queryData.(map[string]interface{})["list"].([]map[string]interface{})[index][jstr] = va["upkeepName"] + "#" + va["id"] + "#0" + "#" + bu["id"] + "#" + bu["pushbackId"]
										}
									}
								}

							}

						}
					}
				}
				appG.Response(http.StatusOK, e.SUCCESS, queryData)

			}
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// @Summary   根据APISQL表中的两条SQL执行得到数据集，其中name1会根据name的每一条去执行
// todo 优化性能 children统一查询
// @Tags PostDataByNameForm
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误朱红彬彬"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
func GetArrList(c *gin.Context) {

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)

	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	sqlnamestr1 := fsion.Get("name1").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	month := fsion.Get("month").ValueDefaultStr("map")
	logging.Info("GetUpkeepPlan ", c.Keys, sqlnamestr, month)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr1, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		}

		queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())

		} else {
			paramslist1 := strings.Split(p1, ",")
			for index, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {
				s_params1 := make([]interface{}, 0)
				if len(paramslist1) > 0 && p1 != "" {
					for _, v := range paramslist1 {
						s_params1 = append(s_params1, value[strings.ToLower(strings.Trim(v, " "))])
					}
				}
				arr, _ := tx.SQL(sql1, s_params1...).QueryString() //获取
				queryData.(map[string]interface{})["list"].([]map[string]interface{})[index]["arrList"] = arr
			}
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

func GetAccount(c *gin.Context) {

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			if sqlnamestr != "getNoMesList" && sqlnamestr != "getNoMesCount" {
				logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, parammaps.ValueStr())
			}

			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		} else if fsion.HasKey("params") {
			params := fsion.Get("params").Array()
			logging.Info("GetDataByName", c.Keys, c.Request.RemoteAddr, sqlnamestr, params)
			for _, v_params := range params {
				s_params = append(s_params, v_params.ValueStr())
			}
		}
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			//c.File("c:/dd.xlsx")
			c.Header("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
			c.Header("Content-Disposition", "attachment; filename="+"Workbook.xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)

		} else {
			queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)

			if err != nil {
				logging.Error("GetDataByName  err: ", err)
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
				//appG.Response(http.StatusOK, e.ERROR, err.Error())
			} else {
				appG.Response(http.StatusOK, e.SUCCESS, queryData)
			}
		}

	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags PostDataByName
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByName  [POST]
func PostDataByName(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()

	s_params := make([]interface{}, 0)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:

			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			logging.Info("PostDataByName ", c.Keys, c.Request.RemoteAddr, sqlnamestr, parammaps.ValueStr())
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
						ids, err := setting.SnowIds.NextId()
						if err != nil {
							ids = time.Now().UnixNano()
							logging.Info("create SnowIds err", err)
						}
						s_params = append(s_params, ids)
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}
		} else if fsion.HasKey("params") {
			params := fsion.Get("params").Array()
			logging.Info("PostDataByName ", c.Keys, c.Request.RemoteAddr, sqlnamestr, params)
			//ids,err := setting.SnowIds.NextId()
			//if err !=nil{
			//	ids = time.Now().UnixNano()
			//	logging.Info("create SnowIds err",err)
			//}
			//s_params = append(s_params, ids)
			for _, v_params := range params {
				s_params = append(s_params, v_params.ValueStr())
			}
		}
		queryData, err := execDataBySqlT(sql, s_params, tx)
		if err != nil {
			logging.Error("PostDataByName  err: ", err)
			//appG.Response(http.StatusOK, e.ERROR, err.Error())

			if (sqlnamestr == "copybarfeedremain" || sqlnamestr == "copyFtdry" || sqlnamestr == "copyPennsieve") &&
				strings.Contains(err.Error(), "Duplicate entry") {

				appG.Response(http.StatusOK, e.ERROR, "同一栏舍,同一班次不可重复录入")
			} else if (sqlnamestr == "copybarmilk" || sqlnamestr == "copyBodyscore" || sqlnamestr == "copyDungsieve" || sqlnamestr == "copyDungscore") &&
				strings.Contains(err.Error(), "Duplicate entry") {

				appG.Response(http.StatusOK, e.ERROR, "同一栏舍不可重复录入")
			} else {
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
			}
		} else {
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

//人脸识别/格润富德接口
func GetRJSBData(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)

	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	sqlnamestr1 := fsion.Get("name1").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("plancount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	month := fsion.Get("month").ValueDefaultStr("map")
	logging.Info("GetUpkeepPlan ", c.Keys, sqlnamestr, month)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	//STR :=Httppostdata("http://192.168.1.104:8081/authdata/GetDataBySqlIN","POST",string(dataByte),tx)

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr1, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		}

		queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())

		} else {
			paramslist1 := strings.Split(p1, ",")

			for index, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {
				s_params1 := make([]interface{}, 0)
				if len(paramslist1) > 0 && p1 != "" {
					for _, v := range paramslist1 {
						s_params1 = append(s_params1, value[strings.ToLower(strings.Trim(v, " "))])
					}
				}
				arr, _ := tx.SQL(sql1, s_params1...).QueryString() //获取
				queryData.(map[string]interface{})["list"].([]map[string]interface{})[index]["arrList"] = arr
			}
			var wg sync.WaitGroup
			for _, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {
				wg.Add(1)
				go func(value map[string]interface{}) {
					defer wg.Done()
					_, err = tx.SQL(`update downloadedplan set  havebutton = 1 where id = ? and pastureid = ? `, value["projuctid"], value["pastureid"]).Execute()
				}(value)
			}
			wg.Wait()
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}
func PostRJSBData(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	logging.Info("PostRJSBData  err: ", string(dataByte))

	s_params := make([]interface{}, 0)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT("updatedownloadedplanYJ", tx)
	sql1, p1 := restful.GetSqlByNameDBT("updated1YJ", tx)
	sql2, p2 := restful.GetSqlByNameDBT("updated1execYJ", tx)
	sql3, p3 := restful.GetSqlByNameDBT("updated2YJ", tx)
	if !fsion.HasKey("parammaps") {
		appG.Response(http.StatusOK, e.ERROR, "参数解析失败")
		return
	}
	parammaps := fsion.Get("parammaps")

	paramslist := strings.Split(p, ",")
	if len(paramslist) > 0 && p != "" {
		for _, value := range paramslist {
			s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
		}
	}
	_, err = tx.SQL(sql, s_params...).Execute()
	if err != nil {
		logging.Error("PostRJSBData  err: ", err)
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
		return
	}

	s_params = make([]interface{}, 0)
	paramslist = strings.Split(p1, ",")
	if len(paramslist) > 0 && p1 != "" {
		for _, value := range paramslist {
			// if value == "ID" {
			// 	id := parammaps.Get("ID").ValueStr()
			// 	pastureid := parammaps.Get("pastureid").ValueStr()
			// 	datalist, err := tx.SQL(`select d2.id as id from downloadplandtl1 d1 join downloadplandtl1_exec  d2 on d1.id = d2.id  where d1.pid =  (select pid  from downloadplandtl1 where id =  ? and pastureid = ? )  and
			// 	d1.sort = (select sort  from downloadplandtl1 where id =  ? and pastureid = ? )`, id, pastureid, id, pastureid).QueryString()
			// 	if err != nil {
			// 		logging.Error("PostRJSBData  err: ", err)
			// 		msg := geterrmsg(err.Error())
			// 		appG.Response(http.StatusOK, e.ERROR, msg)
			// 		return
			// 	}

			// 	for _, item := range datalist {
			// 		id = item["id"]
			// 	}
			// 	s_params = append(s_params, id)
			// } else {
			// 	s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			// }
			s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
		}
	}
	_, err = tx.SQL(sql1, s_params...).Execute()
	if err != nil {
		logging.Error("PostRJSBData1  err: ", err)
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
		return
	}
	s_params = make([]interface{}, 0)

	paramslist = strings.Split(p2, ",")
	if len(paramslist) > 0 && p2 != "" {
		for _, value := range paramslist {

			if value == "ID" {
				id := parammaps.Get("ID").ValueStr()
				pastureid := parammaps.Get("pastureid").ValueStr()
				datalist, err := tx.SQL(`select d2.id as id from downloadplandtl1 d1 join downloadplandtl1_exec  d2 on d1.id = d2.id  where d1.pid =  (select pid  from downloadplandtl1 where id =  ? and pastureid = ? )  and 
				d1.sort = (select sort  from downloadplandtl1 where id =  ? and pastureid = ? )`, id, pastureid, id, pastureid).QueryString()
				if err != nil {
					logging.Error("PostRJSBData  err: ", err)
					msg := geterrmsg(err.Error())
					appG.Response(http.StatusOK, e.ERROR, msg)
					return
				}

				for _, item := range datalist {
					id = item["id"]
				}
				s_params = append(s_params, id)
			} else {
				s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}

		}
	}

	_, err = tx.SQL(sql2, s_params...).Execute()
	if err != nil {
		logging.Error("PostRJSBData2  err: ", err)
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
		return
	}
	s_params = make([]interface{}, 0)

	paramslist = strings.Split(p3, ",")
	if len(paramslist) > 0 && p3 != "" {
		for _, value := range paramslist {
			s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
		}
	}
	_, err = tx.SQL(sql3, s_params...).Execute()
	if err != nil {
		logging.Error("PostRJSBData3  err: ", err)
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
		return
	}
	appG.Response(http.StatusOK, e.SUCCESS, "ok")
}
func PostRJSBDatas(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsions := gofasion.NewFasion(string(dataByte)).Array()
	logging.Info("PostRJSBDatas  err: ", string(dataByte))

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT("updatedownloadedplanYJ", tx)
	sql1, p1 := restful.GetSqlByNameDBT("updated1YJV2", tx)
	sql2, p2 := restful.GetSqlByNameDBT("updated1execYJV2", tx)
	sql3, p3 := restful.GetSqlByNameDBT("updated2YJV2", tx)

	for _, fsion := range fsions {
		if !fsion.HasKey("parammaps") {
			appG.Response(http.StatusOK, e.ERROR, "参数解析失败")
			return
		}
		parammaps := fsion.Get("parammaps")
		s_params := make([]interface{}, 0)
		paramslist := strings.Split(p, ",")
		if len(paramslist) > 0 && p != "" {
			for _, value := range paramslist {
				s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}
		}
		_, err = tx.SQL(sql, s_params...).Execute()

		if err != nil {
			logging.Error("PostRJSBData  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
			return
		}

		s_params = make([]interface{}, 0)
		paramslist = strings.Split(p1, ",")
		if len(paramslist) > 0 && p1 != "" {
			for _, value := range paramslist {
				// if value == "ID" {
				// 	id := parammaps.Get("ID").ValueStr()
				// 	pastureid := parammaps.Get("pastureid").ValueStr()
				// 	datalist, err := tx.SQL(`select d2.id as id from downloadplandtl1 d1 join downloadplandtl1_exec  d2 on d1.id = d2.id  where d1.pid =  (select pid  from downloadplandtl1 where id =  ? and pastureid = ? )  and
				// 	d1.sort = (select sort  from downloadplandtl1 where id =  ? and pastureid = ? )`, id, pastureid, id, pastureid).QueryString()
				// 	if err != nil {
				// 		logging.Error("PostRJSBData  err: ", err)
				// 		msg := geterrmsg(err.Error())
				// 		appG.Response(http.StatusOK, e.ERROR, msg)
				// 		return
				// 	}

				// 	for _, item := range datalist {
				// 		id = item["id"]
				// 	}
				// 	s_params = append(s_params, id)
				// } else {
				// 	s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
				// }
				s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}
		}
		_, err = tx.SQL(sql1, s_params...).Execute()
		if err != nil {
			logging.Error("PostRJSBData1  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
			return
		}
		s_params = make([]interface{}, 0)

		paramslist = strings.Split(p2, ",")
		if len(paramslist) > 0 && p2 != "" {
			for _, value := range paramslist {
				if value == "ID" {
					id := parammaps.Get("ID").ValueStr()
					pastureid := parammaps.Get("pastureid").ValueStr()
					datalist, err := tx.SQL(`select d2.id as id from downloadplandtl1 d1 join downloadplandtl1_exec  d2 on d1.id = d2.id  where d1.pid =  (select pid  from downloadplandtl1 where id =  ? and pastureid = ? )  and 
					d1.sort = (select sort  from downloadplandtl1 where id =  ? and pastureid = ? )`, id, pastureid, id, pastureid).QueryString()
					if err != nil {
						logging.Error("PostRJSBData  err: ", err)
						msg := geterrmsg(err.Error())
						appG.Response(http.StatusOK, e.ERROR, msg)
						return
					}

					for _, item := range datalist {
						id = item["id"]
					}
					s_params = append(s_params, id)
				} else {
					s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
				}
				// s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}
		}
		_, err = tx.SQL(sql2, s_params...).Execute()
		if err != nil {
			logging.Error("PostRJSBData2  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
			return
		}
		s_params = make([]interface{}, 0)

		paramslist = strings.Split(p3, ",")
		if len(paramslist) > 0 && p3 != "" {
			for _, value := range paramslist {
				s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}
		}
		_, err = tx.SQL(sql3, s_params...).Execute()
		if err != nil {
			logging.Error("PostRJSBData3  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
			return
		}
	}
	appG.Response(http.StatusOK, e.SUCCESS, "ok")
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags ExecDataByConfig
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByName  [POST]

func ExecDataByConfig(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	tempval_ := make(map[string]interface{})
	tempCommon := make(map[string]interface{})
	tempval := make([]map[string]interface{}, 0)
	err := json.Unmarshal(dataByte, &tempval_)
	logging.Info("ExecDataByConfig ", c.Keys, c.Request.RemoteAddr, tempval_["common"], tempval_["data"])
	// fmt.Println("ExecDataByConfig ", c.Keys, c.Request.RemoteAddr, tempval_["common"], tempval_["data"])
	if err != nil {
	} else {
		if v, ok := tempval_["common"].(map[string]interface{}); ok {
			tempCommon = v
		}

		if v, ok := tempval_["data"].([]interface{}); ok {
			for _, Tvalue := range v {
				if v1, ok := Tvalue.(map[string]interface{}); ok {
					tempval = append(tempval, v1)
				}
			}
		}
		tx := restful.Engine.NewSession()

		err := tx.Begin()
		if err != nil {
			logging.Error("tx.Begin 事务启动失败__error:", err)
		}
		defer func() {
			switch {
			case err != nil:
				if tx != nil {
					tx.Rollback()
				}
			default:
				if tx != nil {
					err = tx.Commit()
				}
			}
			if tx != nil {
				tx.Close()
			}
		}()

		if err == nil {
			if tempv, exists := c.Get("jwt_username"); exists {
				tempCommon["jwt_username"] = tempv.(string)
			}

			for _, paramvalue := range tempval {
				if _, ok := paramvalue["resultname"]; !ok {
					paramvalue["resultname"] = paramvalue["name"]
				}
				_, err = ExecDataParam(paramvalue, tempCommon, tempval, nil, nil, tx)
				if err != nil {
					logging.Error("ExecDataParam error:", err)
					break
				}
			}
			if err == nil {
				if tempCommon["returnmap"] != nil && tempCommon["returnmap"] != "" {
					appG.Response(http.StatusOK, e.SUCCESS, tempval)
				} else {
					appG.Response(http.StatusOK, e.SUCCESS, "成功执行！")
				}
			} else {
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
				//appG.Response(http.StatusOK, e.ERROR, err.Error())
			}
		}
	}
	if err != nil {
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
		//appG.Response(http.StatusOK, e.ERROR, err.Error())
	}
}

func interfacetostring(val interface{}) string {
	switch val.(type) {
	case string:
		ss := val.(string)
		return ss
		break
	case int:
		ss := val.(int)
		return strconv.Itoa(ss)
		break
	case int64:
		ss := val.(int64)
		return strconv.FormatInt(ss, 10)
		break
	case float64:
		ss := val.(float64)
		return strconv.FormatFloat(ss, 'E', -1, 32)
		break
	}
	return ""
}

func getParamValue(parammaps map[string]interface{}, value string, ParamMap []map[string]interface{}) string {

	if valuestring, ok := parammaps[strings.Trim(value, " ")].(string); ok {

		tempstrb := strings.IndexAny(valuestring, "@")
		tempstre := strings.IndexAny(valuestring, ".")
		if tempstrb > -1 && tempstre > -1 {
			for _, ParamMapList := range ParamMap {
				if v, ok := ParamMapList["resultname"]; ok {
					if v == valuestring[tempstrb+1:tempstre] {
						if v1, ok := ParamMapList["resultmaps"]; ok {
							if newA, ok := v1.([]map[string]interface{}); ok {
								return interfacetostring(newA[0][valuestring[tempstre+1:]])
							} else if newA, ok := v1.(map[string]interface{}); ok {
								return interfacetostring(newA[valuestring[tempstre+1:]])
							}

						}
					}
				}
			}
		} else {
			return valuestring
		}
	} else if valuestring, ok := parammaps[strings.Trim(value, " ")].(float64); ok {
		return strconv.FormatInt(int64(valuestring), 10)
	}
	return ""
}

func getParamValue_(parammaps map[string]interface{}, value string, ParamMap map[string]interface{}) string {
	if valuestring, ok := parammaps[strings.Trim(value, " ")].(string); ok {
		tempstrb := strings.IndexAny(valuestring, "@")
		tempstre := strings.IndexAny(valuestring, ".")
		if tempstrb > -1 && tempstre > -1 {
			if v, ok := ParamMap[valuestring[tempstre+1:]]; ok {
				if s, ok := v.(string); ok {
					return s
				} else if s, ok := v.(float64); ok {

					return strconv.FormatFloat(s, 'f', -1, 64)
					// return strconv.FormatInt(int64(s), 10)
				}
			}
		}
	}

	return ""
}

func ExecDataParam(fasion map[string]interface{}, CommonParamMap map[string]interface{}, ParamMap []map[string]interface{}, ParentParamMap map[string]interface{}, sameParamMap []map[string]interface{}, tx *xorm.Session) ([]map[string]interface{}, error) {
	sqlname := fasion["name"].(string)
	sqltype := "" //v  校验/s1 查询/sm 查询/e  执行
	if v, ok := fasion["type"]; ok {
		sqltype = v.(string)
	}
	sql := ""
	p := ""
	s_params := make([]interface{}, 0)
	if sqltype != "" {
		sql, p = restful.GetSqlByName(sqlname, tx)
		//sqlApi, _ := models.GetApisqlByName(sqlname)
		if v, ok := fasion["parammaps"].(map[string]interface{}); ok {
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					ss := ""
					if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
						ids, err := setting.SnowIds.NextId()
						if err != nil {
							ids = time.Now().UnixNano()
							logging.Info("create SnowIds err", err)
						}
						s_params = append(s_params, ids)
					} else {
						if ss == "" && CommonParamMap != nil {
							if valuestring, ok := v[strings.Trim(value, " ")].(string); ok {
								ss = valuestring
								tempstrb := strings.IndexAny(valuestring, "@")
								tempstre := strings.IndexAny(valuestring, ".")
								if (tempstre > tempstrb) && (strings.ToLower(valuestring[tempstrb+1:tempstre]) == "common") {
									if CommonParamMap[valuestring[tempstre+1:]] != nil {
										ss = CommonParamMap[valuestring[tempstre+1:]].(string)
									}
								} else {
									ss = ""
								}
							}

						}

						if ss == "" && ParentParamMap != nil {
							ss = getParamValue_(v, value, ParentParamMap)
						}
						if ss == "" && sameParamMap != nil {
							ss = getParamValue(v, value, sameParamMap)
						}
						if ss == "" && ParamMap != nil {
							ss = getParamValue(v, value, ParamMap)
						}
						s_params = append(s_params, ss)
					}

				}
			}

		}
	}
	if sql == "" {
		sqltype = ""
	}

	if sqltype == "s1" {
		tempValParam, err := restful.QueryByMap(sql, 0, 1, s_params)
		if v, ok := tempValParam.(map[string]interface{}); ok {
			fasion["resultmaps"] = v["list"].([]map[string]interface{})
		}
		if err != nil {
			return nil, err
		}
		err = ExitsChildrenParam(fasion, tempValParam, ParamMap, CommonParamMap, tx)
		if err != nil {
			return nil, err
		}
		return tempValParam.(map[string]interface{})["list"].([]map[string]interface{}), err
	} else if sqltype == "sm" {
		tempValParam, err := restful.QueryByMap(sql, 0, 0, s_params)
		if v, ok := tempValParam.(map[string]interface{}); ok {
			fasion["resultmaps"] = v["list"].([]map[string]interface{})
		} else {

		}

		if err != nil {
			return nil, err
		}
		err = ExitsChildrenParam(fasion, tempValParam, ParamMap, CommonParamMap, tx)
		if err != nil {
			return nil, err
		}
		return tempValParam.(map[string]interface{})["list"].([]map[string]interface{}), err

	} else if sqltype == "v" {
		tempValParam, err := restful.QueryByMap(sql, 0, 1, s_params)
		if v, ok := tempValParam.(map[string]interface{}); ok {
			fasion["resultmaps"] = v["list"].([]map[string]interface{})
		} else {

		}
		if err != nil {
			return nil, err
		}
		if tempValParam.(map[string]interface{})["list"].([]map[string]interface{})[0]["vmsg"] != "" {
			return nil, errors.New(tempValParam.(map[string]interface{})["list"].([]map[string]interface{})[0]["vmsg"].(string))
		}
	} else if sqltype == "e" {
		tempVal_arrary := make([]map[string]interface{}, 0)
		tempVal_map := make(map[string]interface{})
		tempValParam, err := restful.ExecQueryT(sql, s_params, tx)
		if err == nil {
			fasion["resultmaps"] = tempValParam.(map[string]interface{})
			tempVal_map["result"] = tempValParam.(map[string]interface{})["result"]
			tempVal_map["LastInsertId"] = tempValParam.(map[string]interface{})["LastInsertId"]
			tempVal_arrary = append(tempVal_arrary, tempVal_map)
			return tempVal_arrary, err
		}
		return nil, err
	} else {
		if tempValParam, ok := fasion["resultmaps"].(map[string]interface{}); ok {
			err := ExitsChildrenParam(fasion, tempValParam, ParamMap, CommonParamMap, tx)
			if err != nil {
				return nil, err
			}
			return nil, err
		}
	}
	return nil, nil
}

func ExitsChildrenParam(fasion map[string]interface{}, tempValParam interface{}, ParamMap []map[string]interface{}, commonParam map[string]interface{}, tx *xorm.Session) error {
	var err error
	subarray, ok := fasion["children"]

	if ok {
		for _, v := range tempValParam.(map[string]interface{})["list"].([]interface{}) { //遍历父集有多少行数据
			tempVal_arrary := make([]map[string]interface{}, 0)
			for _, subarrayvalue := range subarray.([]interface{}) { //遍历所有执行命令
				tempVal_ := make(map[string]interface{})
				if _, ok := subarrayvalue.(map[string]interface{})["resultname"]; !ok {
					tempVal_["resultname"] = subarrayvalue.(map[string]interface{})["name"]
				} else {
					tempVal_["resultname"] = subarrayvalue.(map[string]interface{})["resultname"]
				}
				tempVal_["resultmaps"], err = ExecDataParam(subarrayvalue.(map[string]interface{}), commonParam, ParamMap, v.(map[string]interface{}), tempVal_arrary, tx) //递归调用执行

				if err != nil {
					return err
				}
				tempVal_arrary = append(tempVal_arrary, tempVal_)
			}
			v.(map[string]interface{})["children"] = tempVal_arrary
		}
	}
	return nil
}

// @Summary   删除图片
// @Tags RemovePicByName
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByName  [POST]
func RemovePicByName(c *gin.Context) {
	logging.Info("RemovePicByName ", c.Keys)
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	picname := fsion.Get("picname").ValueStr()
	sql, _ := restful.GetSqlByNameDB(sqlnamestr)
	params := fsion.Get("params").Array()
	s_params := make([]interface{}, 0)
	for _, v_params := range params {
		s_params = append(s_params, v_params.ValueStr())
	}
	if sql != "" {
		queryData, err := execDataBySql(sql, s_params)

		if picname != "" {
			// Destination
			distPath := path.Join(setting.CurrentPath, setting.AppSetting.ImageSavePath, picname)

			err := os.Remove(distPath) //删除文件test.txt
			if err != nil {
				//如果删除失败则输出 file remove Error!
				fmt.Println("file remove Error!")
				//输出错误详细信息
				fmt.Printf("%s", err)
			} else {
				//如果删除成功则输出 file remove OK!
				fmt.Print("file remove OK!")
			}
			distPath = path.Join(setting.CurrentPath, setting.AppSetting.ThumbnailSavePath, picname)

			err = os.Remove(distPath) //删除文件test.txt
			if err != nil {
				//如果删除失败则输出 file remove Error!
				fmt.Println("file remove Error!")
				//输出错误详细信息
				fmt.Printf("%s", err)
			} else {
				//如果删除成功则输出 file remove OK!
				fmt.Print("file remove OK!")
			}
		}

		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())
		} else {
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// @Summary   删除文件
// @Tags RemoveFileByName
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByName  [POST]
func RemoveFileByName(c *gin.Context) {
	appG := app.Gin{C: c}
	id := c.Param("id")
	logging.Info("DownloadFile ", c.Keys, id)
	eqdoc, err := restful.Engine.SQL("SELECT * FROM eq_doc where id = ? ", id).QueryString()
	if eqdoc == nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
		return
	}
	distPath := path.Join(setting.CurrentPath, setting.AppSetting.FileSavePath, eqdoc[0]["docpath"], eqdoc[0]["newdocname"])

	err = os.Remove(distPath) //删除文件test.txt
	if err != nil {
		//如果删除失败则输出 file remove Error!
		fmt.Println("file remove Error!")
		//输出错误详细信息
		fmt.Printf("%s", err)
		appG.Response(http.StatusOK, e.ERROR, err.Error())
		return
	}
	_, err = restful.Engine.SQL("delete FROM eq_doc where id = ? ", id).QueryString()
	appG.Response(http.StatusOK, e.SUCCESS, "OK")

}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags PostDataByName
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDataByName  [POST]
func UpdateDataRelation(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	tablename := fsion.Get("name").ValueStr()
	dataname := fsion.Get("dataname").ValueStr()
	datavalue := fsion.Get("datavalue").ValueStr()
	valuename := fsion.Get("valuename").ValueStr()
	logging.Info("UpdateDataRelation ", c.Keys, c.Request.RemoteAddr, tablename, dataname, datavalue, valuename)
	values := fsion.Get("values").Array()
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	insertSqlstr := "insert into " + tablename + "( " + dataname + "," + valuename + ") select DISTINCT  ?, ? from DUAL " +
		" where NOT EXISTS (select " + valuename + " from " + tablename + " where " + valuename + " = ? and " + dataname + " = ?)"

	d_params := make([]interface{}, 4)
	d_params[0] = datavalue
	s_params := ""

	for _, v_values := range values {
		d_params[1] = v_values.ValueStr()
		if s_params == "" {
			s_params = v_values.ValueStr()
		} else {
			s_params = s_params + "," + v_values.ValueStr()
		}
		d_params[2] = d_params[1]
		d_params[3] = d_params[0]
		_, err := execDataBySqlT(insertSqlstr, d_params, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())
			break
		}
	}

	if s_params != "" {

		deleteSqlstr := "delete from " + tablename + " " +
			"           where " + dataname + " = " + datavalue + " and " + valuename + " not in (" + s_params + ")"
		queryData, err := execDataBySqlT(deleteSqlstr, nil, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())
		} else if err == nil {
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		deleteSqlstr := "delete from " + tablename + " " +
			"           where " + dataname + " = " + datavalue
		queryData, err := execDataBySqlT(deleteSqlstr, nil, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())
		} else if err == nil {
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	}
}

// @Summary   根据APISQL表中SQL执行得到数据集
// @Tags PostDatasByName
// @Accept json
// @Produce  json
// @Param  sqlname  query   string true "sqlname"
// @Param  offset  query   int true "offset"
// @Param  pagecount  query   int true "pagecount"
// @Param  returntype  query   string true "returntype"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/PostDatasByName  [POST]
func PostDataByNames(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlParams := fsion.Get("array").Array()
	queryData := make(map[string]interface{})
	for _, v := range sqlParams {
		fsion2 := gofasion.NewFasion(v.Json())
		ss := fsion2.Get("name")
		aa := fsion2.Get("params")
		fmt.Println(ss, aa)
		logging.Info("PostDataByNames ", c.Keys, fsion2.Get("name").ValueStr())
		sql, p := restful.GetSqlByNameDB(fsion2.Get("name").ValueStr())
		if sql == "" {
			errorm := make(map[string]interface{})
			errorm["code"] = e.ERROR
			errorm["message"] = "sql没有找到"
			errorm["param"] = ""
			queryData[fsion2.Get("name").ValueStr()] = errorm
			continue
		} else if sql != "" {
			s_params := make([]interface{}, 0)
			if fsion2.HasKey("parammaps") {
				parammaps := fsion2.Get("parammaps")

				paramslist := strings.Split(p, ",")
				if len(paramslist) > 0 && p != "" {
					for _, value := range paramslist {
						if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
							if tempv, exists := c.Get("jwt_username"); exists {
								s_params = append(s_params, tempv.(string))
							} else {
								s_params = append(s_params, "")
							}
						} else if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
							ids, err := setting.SnowIds.NextId()
							if err != nil {
								ids = time.Now().UnixNano()
								logging.Info("create SnowIds err", err)
							}
							s_params = append(s_params, ids)
						} else {
							s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
						}
					}
				}
			} else if fsion2.HasKey("params") {
				params := fsion2.Get("params").Array()
				//ids,err := setting.SnowIds.NextId()
				//if err !=nil{
				//	ids = time.Now().UnixNano()
				//	logging.Info("create SnowIds err",err)
				//}
				//s_params = append(s_params, ids)
				for _, v_params := range params {
					s_params = append(s_params, v_params.ValueStr())
				}
			}
			_, err := execDataBySql(sql, s_params)

			if err != nil {
				logging.Error("PostDataByName  err: ", err)
				errorm := make(map[string]interface{})
				errorm["code"] = e.ERROR
				errorm["message"] = err.Error()
				errorm["param"] = s_params
				queryData[fsion2.Get("name").ValueStr()] = errorm
				continue
			} else {
				errorm := make(map[string]interface{})
				errorm["code"] = e.SUCCESS
				errorm["message"] = "success"
				queryData[fsion2.Get("name").ValueStr()] = errorm
				continue
			}
		} else {
			errorm := make(map[string]interface{})
			errorm["code"] = e.ERROR
			errorm["message"] = "NO SQL"
			errorm["param"] = ""
			queryData[fsion2.Get("name").ValueStr()] = errorm
		}
	}
	appG.Response(http.StatusOK, e.SUCCESS, queryData)
}

func getDataBySql(sqlstr string, offset, pagecount int, returntype string, params []interface{}) (interface{}, error) {
	if offset > 0 {
		offset = offset - 1
	}
	//if pagecount == 0 {
	//	pagecount = setting.AppSetting.PageSize
	//}else if pagecount>setting.AppSetting.PageSize{
	//	pagecount = setting.AppSetting.PageSize
	//}
	if returntype == "list" {
		queryData, err := restful.QueryByList(sqlstr, offset, pagecount, params)
		return queryData, err
	} else if returntype == "listlist" {
		queryData, err := restful.QueryByListList(sqlstr, offset, pagecount, params)
		return queryData, err
	} else {
		queryData, err := restful.QueryByMap(sqlstr, offset, pagecount, params)
		return queryData, err
	}
}
func getDataBySqlT(sqlstr string, offset, pagecount int, returntype string, params []interface{}, tx *xorm.Session) (interface{}, error) {
	if offset > 0 {
		offset = offset - 1
	}
	//if pagecount == 0 {
	//	pagecount = setting.AppSetting.PageSize
	//}else if pagecount>setting.AppSetting.PageSize{
	//	pagecount = setting.AppSetting.PageSize
	//}
	if returntype == "list" {
		queryData, err := restful.QueryByListT(sqlstr, offset, pagecount, params, tx)
		return queryData, err
	} else if returntype == "listlist" {
		queryData, err := restful.QueryByListListT(sqlstr, offset, pagecount, params, tx)
		return queryData, err
	} else {
		fmt.Println(params)
		queryData, err := restful.QueryByMapT(sqlstr, offset, pagecount, params, tx)
		return queryData, err
	}
}
func GetRecuData_BySql(sql string, Params string, idname string, thisParams map[string]interface{}, isList bool) (interface{}, error) {
	paramslist := strings.Split(Params, ",")
	s_params := make([]interface{}, 0)
	if isList {
		for _, v_params := range thisParams["params"].([]interface{}) {
			s_params = append(s_params, v_params)
		}
	} else {
		paramslist := strings.Split(Params, ",")
		if len(paramslist) > 0 && Params != "" {
			for _, value := range paramslist {
				s_params = append(s_params, thisParams[strings.Trim(value, " ")])
			}
		}
	}
	queryData, err := restful.QueryByMapMenu(sql, 0, 0, s_params)
	for _, queryData_ := range queryData {
		if v, ok := queryData_["haschildren"]; (ok && v.(int64) > 0) || !ok {
			if isList {
				if queryData_[idname] != nil {
					thisParams["params"].([]interface{})[len(thisParams["params"].([]interface{}))-1] = queryData_[idname].(interface{})
				}

			} else {
				if queryData_[idname] != nil {
					thisParams[idname] = queryData_[idname].(interface{})
				}
				if len(paramslist) > 0 && Params != "" {
					s_params = make([]interface{}, 0)
					for _, value := range paramslist {
						s_params = append(s_params, thisParams[strings.Trim(value, " ")])
					}
				}
			}
			queryData_["children"], _ = GetRecuData_BySql(sql, Params, idname, thisParams, isList)
		} else {

		}
	}
	return queryData, err
}

func execDataBySql(sqlstr string, params []interface{}) (interface{}, error) {
	queryData, err := restful.ExecQuery(sqlstr, params)
	return queryData, err
}
func execDataBySqlT(sqlstr string, params []interface{}, tx *xorm.Session) (interface{}, error) {
	queryData, err := restful.ExecQueryT(sqlstr, params, tx)
	return queryData, err
}

func ExecDataBySql(sqlstr string, params []interface{}) (interface{}, error) {
	queryData, err := restful.ExecQuery(sqlstr, params)
	return queryData, err
}

// @Summary   导入excel文件到数据库，excel第一行作为参数
// @Tags ImportExcel
// @Accept json
// @Produce  json
// @Param  file  query   string true "文件名"
// @Param  name  header   string  true "执行sql的名字"
// @Success 200 {string} json  "{ "code": 200, "data": {}, "msg": "ok" }"
// @Failure 400 {string} json "{"code":400,  "data":null,"msg":"请求参数错误"}"
// @Failure 404 {string} json "{ "code": 404, "data":null,"msg":"请求参数错误"}"
// @Router /data/ImportExcel  [POST]
func ImportExcel(c *gin.Context) {
	appG := app.Gin{C: c}

	inputdata := ""
	c.Request.ParseForm()

	params := c.Request.Form
	file, _, err := c.Request.FormFile("file")
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err)
		return
	}
	sqlnamestrs := params.Get("name")
	sheetname := params.Get("sheetname")
	pastureid := params.Get("pastureid")
	//importParams := params.Get("importParams")
	logging.Info("ImportExcel ", c.Keys, c.Request.RemoteAddr, sqlnamestrs)

	// 必输项参数 （字符串格式 "field1，field2，field3"）
	requiredParams := params.Get("requiredParams")
	// 日期参数
	dateParams := params.Get("dateParams")
	// 数字参数
	numParams := params.Get("numParams")
	//将字符串分割开
	dateParamslist := strings.Split(dateParams, ",")
	requiredParamslist := strings.Split(requiredParams, ",")
	numParamslist := strings.Split(numParams, ",")
	queryData := make([]interface{}, 0)
	sqlslist := strings.Split(sqlnamestrs, ",")
	xlsx1, err := excelize.OpenReader(file)
	if err != nil {
		fmt.Println(err)
		return
	}
	ok := 0
	error := 0
	isdone := true

	rows, _ := xlsx1.GetRows(sheetname)
	// 限制10000条，多余的截取掉
	if len(rows) > 10000 {
		rows = rows[:10000]
	}
	for i, row := range rows {
		if i > 0 {

			entry := make(map[string]interface{})
			outentry := make(map[string]interface{})
			for j, colCell := range rows[0] {
				for k, colCell1 := range row {
					if j == k {
						outentry[colCell] = colCell1
						entry[colCell] = colCell1
					}
				}
			}
			inputdata = ""
			a := ""
			fmt.Println(outentry, entry)
			//校验日期格式
			for _, v := range dateParamslist {
				if v == "" {
					continue
				}
				if d, ok := outentry[strings.Trim(v, " ")]; ok {
					dtime, err := TransfTime(d.(string))
					if err != nil {
						a = strings.Trim(v, " ")
						break
					}
					outentry[strings.Trim(v, " ")] = dtime
				}
			}
			if a != "" {
				outentry["error_msg"] = a + " 格式错误"
				error++
				queryData = append(queryData, outentry)
				continue
			}
			a = ""
			//校验必填格式
			for _, v := range requiredParamslist {
				if v == "" {
					continue
				}

				if d, ok := outentry[strings.Trim(v, " ")]; !ok || d == "" {
					a = strings.Trim(v, " ")
					break
				}
			}
			if a != "" {
				outentry["error_msg"] = a + " 未填或格式错误"
				error++
				queryData = append(queryData, outentry)
				continue
			}
			a = ""
			//校验数字格式
			for _, v := range numParamslist {
				if v == "" {
					continue
				}
				d, ok := outentry[strings.Trim(v, " ")]
				if !ok || d == "" {
					outentry[strings.Trim(v, " ")] = 0
				} else {
					var fl float64
					switch d.(type) {
					case string:
						fl, err = strconv.ParseFloat(d.(string), 64)
					}
					if err != nil || fl < 0 {
						a = strings.Trim(v, " ")
						break
					}
				}
			}
			if a != "" {
				outentry["error_msg"] = a + " 为数值类型且不可为负数"
				error++
				queryData = append(queryData, outentry)
				continue
			}

			tx := restful.Engine.NewSession()
			err := tx.Begin()

			for _, sqlnamestr := range sqlslist {
				sql, paramslists := restful.GetSqlByNameDB(strings.Replace(sqlnamestr, " ", "", -1))
				paramslist := strings.Split(paramslists, ",")
				if len(paramslist) > 0 {
					s_params := make([]interface{}, 0)

					for _, value := range paramslist {
						if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
							if tempv, exists := c.Get("jwt_username"); exists {
								s_params = append(s_params, tempv.(string))
							} else {
								s_params = append(s_params, "")
							}
						} else if strings.ToLower(strings.Trim(value, " ")) == "pastureid" {
							s_params = append(s_params, pastureid)

						} else if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
							ids, err := setting.SnowIds.NextId()
							if err != nil {
								ids = time.Now().UnixNano()
								logging.Info("create SnowIds err", err)
							}
							s_params = append(s_params, ids)
						} else {
							if outentry[strings.Trim(value, " ")] == nil {
								s_params = append(s_params, "")
							} else {

								s_params = append(s_params, outentry[strings.Trim(value, " ")])
							}

						}
					}

					outentry["input"] = inputdata
					fmt.Println(sql, s_params)
					returnmsgmap1, err := tx.SQL(sql, s_params...).Query().List()

					if err != nil {
						if tx != nil {
							tx.Rollback()
						}
						if tx != nil {
							tx.Close()
						}

						msg := geterrmsg(err.Error())
						outentry["error_msg"] = msg
						error++
						queryData = append(queryData, outentry)
						isdone = true
						break
					} else {
						if len(returnmsgmap1) > 0 {
							if va, ok := returnmsgmap1[0]["msg"]; ok && va != "" {
								if tx != nil {
									tx.Rollback()
								}
								if tx != nil {
									tx.Close()
								}
								msg := geterrmsg(va.(string))
								outentry["error_msg"] = msg
								error++
								queryData = append(queryData, outentry)
								isdone = true
								break
							}
						}
						isdone = false
					}
				}
			}
			switch {
			case err != nil:
				if tx != nil {
					tx.Rollback()
				}
			default:
				if tx != nil {
					err = tx.Commit()
				}
			}
			if tx != nil {
				tx.Close()
			}
		}
		if !isdone {
			ok++
			isdone = true
		}
	}
	data := make(map[string]interface{})
	data["result"] = queryData
	data["success"] = ok
	data["err_count"] = error
	appG.Response(http.StatusOK, e.SUCCESS, data)
}

func TransfTime(timestr string) (string, error) {
	if timestr == "" {
		return time.Now().Format("2006-01-02"), nil
	}
	days, err := strconv.Atoi(timestr)
	if err != nil {
		if len(timestr) == 8 && strings.Count(timestr, "-") == 2 {
			return "20" + timestr[6:] + "-" + timestr[:5], nil
		}
		_, err := time.Parse("2006-01-02", timestr)
		if err != nil {
			t, err := time.Parse("2006/01/02", timestr)
			if err != nil {
				t, err := time.Parse("2006.01.02", timestr)
				if err != nil {
					return "", err
				} else {
					return t.Format("2006-01-02"), nil
				}
			} else {
				return t.Format("2006-01-02"), nil
			}
		} else {
			return timestr, nil
		}
	}
	times, _ := time.Parse("2006-01-02", "1899-12-30")
	times = times.AddDate(0, 0, days)

	return times.Format("2006-01-02"), nil
}

func Createchart(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	chart_name := fsion.Get("chart_name").ValueStr()
	desc := fsion.Get("desc").ValueStr()
	pastureid := fsion.Get("pastureid").ValueStr()
	source_id := fsion.Get("source_id").ValueStr()
	emp := fsion.Get("emp").ValueStr()
	content := fsion.Get("content").Json()
	var mapResult map[string]interface{}
	err1 := json.Unmarshal([]byte(content), &mapResult)
	if err1 != nil {
		fmt.Println("JsonToMapDemo err: ", err1)
	}

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	ids, err := setting.SnowIds.NextId()
	if err != nil {
		ids = time.Now().UnixNano()
		logging.Info("create SnowIds err", err)
	}

	exec, err := tx.Exec("insert into chart(id,pastureid,cname,statue,emp,opratetime,content,sourceid)VALUEs(?,?,?,?,?,?,?)",
		ids, pastureid, chart_name, 0, emp, desc, source_id)
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, exec)
	}
}
func Updatedashboard(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	dashboard_id := fsion.Get("dashboard_id").ValueStr()
	pastureid := fsion.Get("pastureid").ValueStr()
	content := fsion.Get("content").Json()

	var mapResult map[string]interface{}
	err1 := json.Unmarshal([]byte(content), &mapResult)
	if err1 != nil {
		fmt.Println("JsonToMapDemo err: ", err1)
	}

	layout := mapResult["layout"]

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	exec, err := tx.SQL("select content from dashboard where pastureid=? and id=?", pastureid, dashboard_id).Query().List()
	if err != nil {
		println("2", err.Error())
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	} else {
		if exec != nil {
			if exec[0]["content"] == nil {
				mapR := make(map[string]interface{})
				mapR["layout"] = layout
				mjson, _ := json.Marshal(mapR)
				mString := string(mjson)
				exec1, err3 := tx.Exec("update dashboard set content=? where pastureid=? and id=?", mString, pastureid, dashboard_id)
				if err3 != nil {
					println("3", err3.Error())
					appG.Response(http.StatusOK, e.ERROR, err3.Error())
				} else {
					appG.Response(http.StatusOK, e.SUCCESS, exec1)
				}
			} else {
				var mapR map[string]interface{}
				err2 := json.Unmarshal([]byte(exec[0]["content"].(string)), &mapR)
				if err1 != nil {
					fmt.Println("JsonToMapDemo err: ", err2)
				}
				mapR["layout"] = layout
				mjson, _ := json.Marshal(mapR)
				mString := string(mjson)
				exec1, err3 := tx.Exec("update dashboard set content=? where pastureid=? and id=?", mString, pastureid, dashboard_id)
				if err3 != nil {
					println("3", err3.Error())
					appG.Response(http.StatusOK, e.ERROR, err3.Error())
				} else {
					appG.Response(http.StatusOK, e.SUCCESS, exec1)
				}
			}

		} else {
			appG.Response(http.StatusOK, e.ERROR, "未找到对应的仪表盘")
		}

	}
}

func ExecSQL(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	content := fsion.Get("content").Json()
	pastureid := fsion.Get("pastureid").ValueStr()

	var mapResult map[string]interface{}
	err1 := json.Unmarshal([]byte(content), &mapResult)
	if err1 != nil {
		fmt.Println("JsonToMapDemo err: ", err1)
	}
	sqlstr := "select "
	groupstr := " GROUP BY "
	for _, value := range mapResult["selectedDimension"].([]interface{}) {

		sqlstr = sqlstr + value.(map[string]interface{})["Column"].(string) + ","
		groupstr = groupstr + value.(map[string]interface{})["Column"].(string) + ","
	}

	for _, value := range mapResult["selectedCalcul"].([]interface{}) {
		if value.(map[string]interface{})["calculFunc"].(string) == "none" {
			sqlstr = sqlstr + value.(map[string]interface{})["Column"].(string) + ","
			groupstr = groupstr + value.(map[string]interface{})["Column"].(string) + ","
		} else if value.(map[string]interface{})["calculFunc"].(string) == "custbiaozhun" {
			tem := "STDDEV" + "(" + value.(map[string]interface{})["Column"].(string) + ") as " + value.(map[string]interface{})["Column"].(string)
			sqlstr = sqlstr + tem + ","
		} else if value.(map[string]interface{})["calculFunc"].(string) == "custbianyi" {
			tem := "STDDEV" + "(" + value.(map[string]interface{})["Column"].(string) + ")/ AVG(" + value.(map[string]interface{})["Column"].(string) + ")as " + value.(map[string]interface{})["Column"].(string)
			sqlstr = sqlstr + tem + ","
		} else {
			tem := value.(map[string]interface{})["calculFunc"].(string) + "(" + value.(map[string]interface{})["Column"].(string) + ") as " + value.(map[string]interface{})["Column"].(string)
			sqlstr = sqlstr + tem + ","
		}
	}
	if _, ok := mapResult["selectedCalcul2"]; ok {
		for _, value := range mapResult["selectedCalcul2"].([]interface{}) {
			if value.(map[string]interface{})["calculFunc"].(string) == "none" {
				sqlstr = sqlstr + value.(map[string]interface{})["Column"].(string) + ","
				groupstr = groupstr + value.(map[string]interface{})["Column"].(string) + ","
			} else if value.(map[string]interface{})["calculFunc"].(string) == "custbiaozhun" {
				tem := "STDDEV" + "(" + value.(map[string]interface{})["Column"].(string) + ") as " + value.(map[string]interface{})["Column"].(string)
				sqlstr = sqlstr + tem + ","
			} else if value.(map[string]interface{})["calculFunc"].(string) == "custbianyi" {
				tem := "STDDEV" + "(" + value.(map[string]interface{})["Column"].(string) + ")/ AVG(" + value.(map[string]interface{})["Column"].(string) + ")as " + value.(map[string]interface{})["Column"].(string)
				sqlstr = sqlstr + tem + ","
			} else {
				tem := value.(map[string]interface{})["calculFunc"].(string) + "(" + value.(map[string]interface{})["Column"].(string) + ") as " + value.(map[string]interface{})["Column"].(string)
				sqlstr = sqlstr + tem + ","
			}
		}
	}

	sqlstr = sqlstr[0 : len(sqlstr)-1]
	sqlstr = sqlstr + " from " + mapResult["dataSrc"].(string)

	sqlstr = sqlstr + " where pastureid=" + pastureid

	if len(mapResult["filters"].([]interface{})) > 0 {
		sqlstr = sqlstr + " and "
	}
	println(len(mapResult["filters"].([]interface{})), sqlstr)
	for _, value := range mapResult["filters"].([]interface{}) {
		switch value.(map[string]interface{})["filterOperator"].(string) {
		case ">", "=", "<", ">=", "<=", "!=", "like":
			sqlstr = sqlstr + value.(map[string]interface{})["filteCol"].(string) + value.(map[string]interface{})["filterOperator"].(string) + " " + value.(map[string]interface{})["value"].(map[string]interface{})["value1"].(string) + " AND "
		case "IN":
			sqlstr = sqlstr + value.(map[string]interface{})["filteCol"].(string) + " " + value.(map[string]interface{})["filterOperator"].(string) + "("
			for _, value1 := range value.(map[string]interface{})["value"].(map[string]interface{})["arrValue"].([]interface{}) {
				sqlstr = sqlstr + value1.(string) + ","
			}
			sqlstr = sqlstr[0 : len(sqlstr)-1]
			sqlstr = sqlstr + ")" + " AND "
		case "BETWEEN":
			sqlstr = sqlstr + value.(map[string]interface{})["filteCol"].(string) + " " + value.(map[string]interface{})["filterOperator"].(string) + " " + value.(map[string]interface{})["value"].(map[string]interface{})["value1"].(string) + " and " + value.(map[string]interface{})["value"].(map[string]interface{})["value2"].(string) + " AND "
		}

	}
	if len(mapResult["filters"].([]interface{})) > 0 {
		sqlstr = sqlstr[0 : len(sqlstr)-4]
	}

	//
	groupstr = groupstr[0 : len(groupstr)-1]
	sqlstr = sqlstr + groupstr + " "
	if len(mapResult["orderByStrs"].([]interface{})) > 0 {
		sqlstr = sqlstr + " order by "
	}
	//
	for key, value := range mapResult["orderByStrs"].([]interface{}) {
		if key == len(mapResult["orderByStrs"].([]interface{}))-1 {
			sqlstr = sqlstr + value.(string) + " "
		} else {
			sqlstr = sqlstr + value.(string) + ","
		}
	}
	//
	sqlstr = sqlstr + " limit " + strconv.Itoa(int(mapResult["limit"].(float64)))

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	exec, err := tx.SQL(sqlstr).Query().List()
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, err.Error())
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, exec)
	}
}

func Dashboards(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)

	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	//sqlnamestr1 := fsion.Get("name1").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	month := fsion.Get("month").ValueDefaultStr("map")
	logging.Info("GetUpkeepPlan ", c.Keys, sqlnamestr, month)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	//sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr1, tx)
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
						if tempv, exists := c.Get("jwt_username"); exists {
							s_params = append(s_params, tempv.(string))
						} else {
							s_params = append(s_params, "")
						}
					} else {
						s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
					}
				}
			}

		}

		queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
		if err != nil {
			appG.Response(http.StatusOK, e.ERROR, err.Error())
		} else {
			//paramslist1 := strings.Split(p1, ",")

			dids := make([]interface{}, 0)
			for index, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {

				var mapResult map[string]interface{}
				dids = append(dids, value["dashboard_id"])

				if value["content"] != nil {
					err1 := json.Unmarshal([]byte(value["content"].(string)), &mapResult)
					if err1 != nil {
						println("JsonToMapDemo1 err: ", err1)
					}
					temap := make(map[string]interface{})
					tem := mapResult["layout"].([]interface{})
					if v, ok := value["chartids"]; ok {
						chartids := strings.Split(v.(string), ",")
						for _, va := range chartids {
							a := false
							for _, v2 := range tem {
								if v2.(map[string]interface{})["id"].(string) == va {
									a = true
									//println("va1======",va)
								}
							}

							if !a {
								laytem := "{\"bottomLine\":[[3,18],[15,18]],\"h\":9,\"i\":\"" +
									va + "\",\"id\":\"" + va +
									"\",\"moved\":false,\"topLine\":[[3,9],[15,9]],\"w\":12,\"x\":0,\"xOffSet\":15,\"y\":100,\"yOffSet\":18}"
								var mapTem map[string]interface{}
								err1 := json.Unmarshal([]byte(laytem), &mapTem)
								if err1 != nil {
									println("JsonToMapDemo err: ", err1)
								}
								tem = append(tem, mapTem)
							}

						}
						temap["layout"] = tem
						queryData.(map[string]interface{})["list"].([]map[string]interface{})[index]["content"] = temap
					}

				} else {

					temap := make(map[string]interface{})
					tem := make([]interface{}, 0)
					if v, ok := value["chartids"]; ok {

						chartids := strings.Split(v.(string), ",")
						for _, va := range chartids {

							laytem := "{\"bottomLine\":[[3,18],[15,18]],\"h\":9,\"i\":\"" +
								va + "\",\"id\":\"" + va +
								"\",\"moved\":false,\"topLine\":[[3,9],[15,9]],\"w\":12,\"x\":0,\"xOffSet\":15,\"y\":0,\"yOffSet\":18}"
							var mapTem map[string]interface{}
							err1 := json.Unmarshal([]byte(laytem), &mapTem)
							if err1 != nil {
								println("JsonToMapDemo err: ", err1)
							}
							tem = append(tem, mapTem)
						}
						temap["layout"] = tem
						queryData.(map[string]interface{})["list"].([]map[string]interface{})[index]["content"] = temap
					}
				}

			}

			queryData.(map[string]interface{})["order"] = dids
			queryData.(map[string]interface{})["dashboards"] = queryData.(map[string]interface{})["list"]
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}

}

func HttpPostData(url, RequestMethod, parammaps string, tx *xorm.Session) string {
	fsion := gofasion.NewFasion(parammaps)
	sqlnamestr := fsion.Get("name").ValueStr()
	sqlnamestr1 := fsion.Get("name1").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr1, tx)
	body := []byte("")
	if sql != "" {
		s_params := make([]interface{}, 0)
		if fsion.HasKey("parammaps") {
			parammaps := fsion.Get("parammaps")
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
				}
			}
		}
		queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
		if err != nil {

		} else {
			paramslist1 := strings.Split(p1, ",")
			for index, value := range queryData.(map[string]interface{})["list"].([]map[string]interface{}) {
				s_params1 := make([]interface{}, 0)
				if len(paramslist1) > 0 && p1 != "" {
					for _, v := range paramslist1 {
						s_params1 = append(s_params1, value[strings.ToLower(strings.Trim(v, " "))])
					}
				}
				arr, _ := tx.SQL(sql1, s_params1...).QueryString() //获取
				queryData.(map[string]interface{})["list"].([]map[string]interface{})[index]["arrList"] = arr
				body, _ = json.Marshal(queryData)
			}
		}

	}

	bs := bytes.NewBuffer(body)
	client := &http.Client{}
	//body1 := bytes.NewBuffer([]byte("{\"username\":\"00028\",\"password\":\"123456\"}"))
	req, err := http.NewRequest(RequestMethod,
		url,
		bs,
	)
	if err != nil {

	}
	req.Header.Set("Content-Type", "application/json;charset=utf-8")
	req.Header.Set("token", "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjAwMDI4IiwicGFzc3dvcmQiOiJlMTBhZGMzOTQ5YmE1OWFiYmU1NmUwNTdmMjBmODgzZSIsImV4cCI6MTYxOTM4NjU0MiwiaXNzIjoiaHR0cHM6Ly9naXRodWIuY29tL2twdHl1bi9nby1hZG1pbi8ifQ.sJwnE9HTOVnDNOaeHqOQzi7cSydYkWS4uQHxtjY7UMY")
	if err != nil {
		// handle error
	}
	resp, err := client.Do(req)
	if err != nil {
		return ""
	}

	defer resp.Body.Close()

	result_body, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return ""
	}

	fmt.Println(string(result_body))
	return ""
}

func GetSummary(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")
	parammaps := fsion.Get("parammaps")

	status := parammaps.Get("status").ValueStr() //0 按驾驶员   1  配方名称  2 栏舍名称 3 牲畜名称 4 车次 5  tmr名称
	genre := parammaps.Get("genre").ValueStr()   //0 混料  1 撒料
	isDate := parammaps.Get("isdate").ValueStr() //0 不按时间 1 按时间
	tx := restful.Engine.NewSession()
	defer tx.Close()

	sqlnamestr := ""
	if genre == "0" {
		if status == "0" {
			sqlnamestr = "getAccuracyJSY"
		} else if status == "1" {
			sqlnamestr = "getAccuracyHFT"
		} else if status == "2" {
			sqlnamestr = "getAccuracyHNS"
		} else if status == "3" {
			sqlnamestr = "getAccuracyHSC"
		} else if status == "4" {
			sqlnamestr = "getAccuracyHCC"
		} else if status == "5" {
			sqlnamestr = "getAccuracyMC"
		}
	} else {
		if status == "0" {
			sqlnamestr = "getAccuracySCCJSY"
		} else if status == "1" {
			sqlnamestr = "getAccuracySFT"
		} else if status == "2" {
			sqlnamestr = "getAccuracySNS"
		} else if status == "3" {
			sqlnamestr = "getAccuracySSC"
		} else if status == "4" {
			sqlnamestr = "getAccuracySCC"
		} else if status == "5" {
			sqlnamestr = "getAccuracySLCL"
		}
	}
	if isDate == "1" {
		sqlnamestr += "Date"
	}

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	// fmt.Println(sqlnamestr, sql)
	if sql != "" {
		s_params := make([]interface{}, 0)
		// if fsion.HasKey("parammaps") {
		fmt.Println(s_params, "222", p)
		paramslist := strings.Split(p, ",")
		if len(paramslist) > 0 && p != "" {
			for _, value := range paramslist {
				if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
					if tempv, exists := c.Get("jwt_username"); exists {
						s_params = append(s_params, tempv.(string))
					} else {
						s_params = append(s_params, "")
					}
				} else {
					s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
				}
			}
		}
		fmt.Println(s_params, "111")
		if returntype == "xlsx" {
			var xlsxfile *xlsx.File
			xlsxfile, _ = restful.QueryByXlsx(sql, s_params)
			//c.File("c:/dd.xlsx")
			c.Header("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
			c.Header("Content-Disposition", "attachment; filename="+"Workbook.xlsx")
			c.Header("Content-Transfer-Encoding", "binary")
			_ = xlsxfile.Write(c.Writer)

		} else {

			queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
			if err != nil {
				logging.Error("GetDataByName  err: ", err)
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
			} else {
				appG.Response(http.StatusOK, e.SUCCESS, queryData)
			}
		}

	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

// type lpplanStruct struct {
// 	Id          int64   `xorm:"id"`
// 	Tmrname     string  `xorm:"tmrname"`
// 	Tmrid       int64   `xorm:"tmrid"`
// 	Sort        int64   `xorm:"sort"`
// 	Sel         int64   `xorm:"sel"`
// 	Times       int64   `xorm:"times"`
// 	Ftname      string  `xorm:"ftname"`
// 	Ftid        int64   `xorm:"ftid"`
// 	Maxweight   float64 `xorm:"maxweight"`
// 	Sumweight   float64 `xorm:"sumweight"`
// 	Sumcowcount int64   `xorm:"sumcowcount"`
// 	Pastureid   string  `xorm:"pastureid"`
// 	Display     string  `xorm:"display"`
// 	Issplit     int64   `xorm:"issplit"`
// 	BeginTime   string  `xorm:"begintime"`
// }

func UpdateFTdetail(c *gin.Context) {
	fmt.Println(time.Now())
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	tempval_ := make(map[string]interface{})
	tempCommon := make(map[string]interface{})
	tempval := make([]map[string]interface{}, 0)
	fTChange := make(map[string]interface{}, 0)
	fpdOldDataList := make([]map[string]interface{}, 0)
	fpdDataList := make([]map[string]interface{}, 0)
	err := json.Unmarshal(dataByte, &tempval_)
	if err != nil {
		appG.Response(http.StatusOK, e.ERROR, false)
		return
	}

	logging.Info("ExecDataByConfig ", c.Keys, c.Request.RemoteAddr, tempval_["common"], tempval_["data"])

	tx := restful.Engine.NewSession()
	err = tx.Begin()
	if err != nil {
		logging.Error("tx.Begin 事务启动失败__error:", err)
	}
	defer func() {
		if err != nil {
			if tx != nil {
				tx.Rollback()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	if err != nil {
	} else {
		if v, ok := tempval_["common"].(map[string]interface{}); ok {
			tempCommon = v
		}

		if v, ok := tempval_["data"].([]interface{}); ok {
			for _, Tvalue := range v {
				if v1, ok := Tvalue.(map[string]interface{}); ok {
					if v1["name"] == "updateFPbyFTChange" {
						fTChange = v1
						continue
					}
					tempval = append(tempval, v1)
				}
			}
		}
		parammaps := fTChange["parammaps"].(map[string]interface{})
		fpdOldDataList, err = tx.SQL(`select * from (SELECT TRIM(id) id,times,tratio,ifnull(ROUND(ptsrate*weight,2)-ptsuse,0) weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
		(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,0 AS fttype,cowcount,ccountradio,1 isfill  FROM fpdetail
		WHERE fpdetail.pastureid = ?   and (ptid = ? or ptsid = ?)
		UNION
		SELECT TRIM(id) id,times,tratio,ifnull(ROUND((1-ptsrate)*weight,2)-ptuse,0) weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
		(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,1 AS fttype,cowcount,ccountradio,0 isfill  FROM fpdetail
		WHERE fpdetail.pastureid = ?   and (ptid = ? or ptsid = ?)) t
		order by t.barname,t.times`, parammaps["pastureid"], parammaps["ftid"], parammaps["ftid"], parammaps["pastureid"], parammaps["ftid"], parammaps["ftid"]).Query().List()

		if err == nil {
			if tempv, exists := c.Get("jwt_username"); exists {
				tempCommon["jwt_username"] = tempv.(string)
			}

			for _, paramvalue := range tempval {
				if _, ok := paramvalue["resultname"]; !ok {
					paramvalue["resultname"] = paramvalue["name"]
				}
				_, err = ExecDataParam(paramvalue, tempCommon, tempval, nil, nil, tx)
				if err != nil {
					logging.Error("ExecDataParam error:", err)
					break
				}
			}
			if err != nil {
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
				//appG.Response(http.StatusOK, e.ERROR, err.Error())
			}
		}
	}
	tx.Commit()
	// go func() {
	if fTChange != nil {
		parammaps := fTChange["parammaps"].(map[string]interface{})
		if parammaps["type"].(float64) == 1 {
			_, err = tx.SQL(`UPDATE feedp fp
				set
				fp.ftweight= IFNULL(IF(
				(SELECT sysopt.inforvalue FROM sysopt WHERE sysopt.pastureid= fp.pastureid AND sysopt.inforname='isLockCount')=0,
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid ),0)*ccountratio,
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=0),0)*ccountratio +
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=1),0)*ccount
				),0),fp.feedweight = IFNULL(IF(
				(SELECT sysopt.inforvalue FROM sysopt WHERE sysopt.pastureid= fp.pastureid AND sysopt.inforname='isLockCount')=0,
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid ),0)*ccountratio,
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=0),0)*ccountratio +
				IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ftid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=1),0)*ccount
				),0) +fp.supplyweight
				WHERE fp.pastureid = ? AND fp.ftid =?`, parammaps["pastureid"], parammaps["ftid"]).Execute()

			_, err = tx.SQL(`UPDATE fpdetail fpd
		INNER JOIN feedp fp
		ON fpd.barid = fp.barid AND fpd.pastureid = fp.pastureid
		SET fpd.weight = fp.feedweight*fpd.tratio/100,
		ptsrate=fp.supplyweight/(fp.feedweight)
		WHERE fp.pastureid = ? AND fp.ftid =?`, parammaps["pastureid"], parammaps["ftid"]).Execute()

		} else {
			_, err = tx.SQL(`UPDATE feedp fp
					SET
					fp.supplyweight= IFNULL(IF(
					(SELECT sysopt.inforvalue FROM sysopt WHERE sysopt.pastureid= fp.pastureid AND sysopt.inforname='isLockCount')=0,
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid ),0)*ccountratio,
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=0),0)*ccountratio +
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=1),0)*ccount
					),0),fp.feedweight = IFNULL(IF(
					(SELECT sysopt.inforvalue FROM sysopt WHERE sysopt.pastureid= fp.pastureid AND sysopt.inforname='isLockCount')=0,
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid ),0)*ccountratio,
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=0),0)*ccountratio +
					IFNULL((SELECT SUM(fweight) FROM ftdetail WHERE ftdetail.ftid =fp.ptsfid AND ftdetail.pastureid=fp.pastureid AND ftdetail.islockcount=1),0)*ccount
					),0) +fp.supplyweight
					WHERE fp.pastureid = ? AND fp.ptsfid =?`, parammaps["pastureid"], parammaps["ftid"]).Execute()

			_, err = tx.SQL(`UPDATE fpdetail fpd
				INNER JOIN feedp fp
				ON fpd.barid = fp.barid AND fpd.pastureid = fp.pastureid
				SET fpd.weight = fp.feedweight*fpd.tratio/100,
				ptsrate=fp.supplyweight/(fp.feedweight)
				WHERE fp.pastureid = ? AND fp.ptsfid =?`, parammaps["pastureid"], parammaps["ftid"]).Execute()
		}

		fpdDataList, err = tx.SQL(`select * from (SELECT TRIM(id) id,times,tratio,ifnull(ROUND(ptsrate*weight,2)-ptsuse,0) weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
		(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,0 AS fttype,cowcount,ccountradio,1 isfill  FROM fpdetail
		WHERE fpdetail.pastureid = ?    and (ptid = ? or ptsid = ?)
		UNION
		SELECT TRIM(id) id,times,tratio,ifnull(ROUND((1-ptsrate)*weight,2)-ptuse,0) weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
		(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,1 AS fttype,cowcount,ccountradio,0 isfill  FROM fpdetail
		WHERE fpdetail.pastureid = ?  and (ptid = ? or ptsid = ?)) t
		order by t.barname,t.times`, parammaps["pastureid"], parammaps["ftid"], parammaps["ftid"], parammaps["pastureid"], parammaps["ftid"], parammaps["ftid"]).Query().List()

		lpplanList := make([]*lpplanStruct, 0)
		err = tx.SQL(`select id,times,maxweight  from lpplan where pastureid = ? and ftid = ? order by  sort desc`, parammaps["pastureid"], parammaps["ftid"]).Find(&lpplanList)
		if err != nil {
			logs.Error(err, 1)
			return
		}

		lppidlist := []string{}
		for _, lpp := range lpplanList {
			lppidlist = append(lppidlist, strconv.FormatInt(lpp.Id, 10))
		}
		lpplandtl1AllList := make([]*lpplandtl1, 0)
		err = tx.SQL(fmt.Sprintf(`select id,lppid,barid,fpdid,lweight from lpplandtl1 where pastureid = ? and lppid in (%s) 
						 order by sort desc`, strings.Join(lppidlist, ",")), parammaps["pastureid"]).Find(&lpplandtl1AllList)
		if err != nil {
			// tx.Rollback()
			logs.Error(err, 2, parammaps["pastureid"])
			return
		}

		var wg sync.WaitGroup
		for _, old := range fpdOldDataList {
			for _, fpd := range fpdDataList {
				wg.Add(1)
				go func(old, fpd map[string]interface{}) {
					updateLppandList := make([]*lpplandtl1, 0)
					defer wg.Done()
					// fmt.Println(old, i)
					// fmt.Println(fpd, i)
					if fpd["id"].(string) == old["id"].(string) && fpd["fttype"].(int64) == old["fttype"].(int64) &&
						fpd["weight"].(string) != old["weight"].(string) && fpd["times"].(int64) == old["times"].(int64) {

						weight, _ := strconv.ParseFloat(fpd["weight"].(string), 64)
						oldweight, _ := strconv.ParseFloat(old["weight"].(string), 64)

						var w float64
						var status int

						if weight < oldweight {
							if weight >= 0 {
								return
							}
							w = weight
							status = 0
						} else {
							if oldweight > 0 {
								return
							}
							w = weight
							status = 1
						}
						// fweight = w
						for _, lpp := range lpplanList {
							var fweight float64
							var lweight float64
							lpplandtl1List := make([]*lpplandtl1, 0)

							for _, lppland := range lpplandtl1AllList {
								if lppland.Lppid == lpp.Id {
									lpplandtl1List = append(lpplandtl1List, lppland)
								}
							}
							// err = tx.SQL(`select id,lppid,barid,fpdid,lweight from lpplandtl1 where pastureid = ? and lppid = ?
							//  order by sort desc`, parammaps["pastureid"], lpp.Id).Find(&lpplandtl1List)
							// if err != nil {
							// 	tx.Rollback()
							// 	logs.Error(err, 2, parammaps["pastureid"], lpp.Id)
							// 	return
							// }
							for _, lppland := range lpplandtl1List {
								lweight += lppland.Lweight
							}

							if status == 0 {
								if lweight <= 0 {
									continue
								}
							} else {
								if lpp.Maxweight <= lweight {
									continue
								}
							}

							for _, lppland := range lpplandtl1List {

								fpdid, _ := strconv.ParseInt(fpd["id"].(string), 10, 64)
								if fpdid == lppland.Fpdid {

									if status == 1 {
										// if w <= lppland.Lweight {
										if lpp.Maxweight <= lweight {
											continue
										}
										if w+lweight <= lpp.Maxweight {
											lppland.Lweight += w
											lweight += w
											fweight += w
											w = 0
										} else {
											// if w < lpp.Maxweight-lppland.Lweight {
											// 	// w = w - (lpp.Maxweight - lweight)
											// 	lppland.Lweight = lppland.Lweight + w
											// 	// lweight += (lpp.Maxweight - lweight)
											// }
											w = w - (lpp.Maxweight - lweight)
											n := (lpp.Maxweight - lweight)
											lppland.Lweight = lppland.Lweight + n
											lweight += n
											fweight += n

										}
									} else {
										if lppland.Lweight == 0 {
											continue
										}
										if w+lppland.Lweight >= 0 {
											lppland.Lweight = lppland.Lweight + w
											lweight = lweight + w
											fweight = fweight + w
											w = 0
										} else {
											w = w + lppland.Lweight
											lweight = lweight - lppland.Lweight
											fweight = fweight - lppland.Lweight
											lppland.Lweight = 0
										}

									}
									// go func(parammaps map[string]interface{}, lppland *lpplandtl1, status int) {
									updateLppandList = append(updateLppandList, lppland)
									// tx.Begin()
									// fmt.Println(lppland.Lweight, lppland.Id, parammaps["pastureid"], status)
									// 	_, err = tx.SQL(`update lpplandtl1  set Lweight = ?  where id = ? and pastureid = ?`, lppland.Lweight, lppland.Id, parammaps["pastureid"]).Execute()
									// 	if err != nil {
									// 		fmt.Println(lppland.Lweight, lppland.Id, parammaps["pastureid"], status)
									// 		// tx.Rollback()
									// 		logs.Error(err, 3)
									// 		return
									// 	}
									// 	// tx.Commit()
									// }(parammaps, lppland, status)
									break
								}
							}

							// go func(parammaps map[string]interface{}, fweight float64, status int) {
							// tx.Begin()
							_, err = tx.SQL(`UPDATE fpdetail SET ptuse=IF(?=1,IF(ptuse+? <0,0,ptuse+?),ptuse),
						ptsuse=IF(?=0,IF(ptsuse+?<0,0,ptsuse+?),ptsuse)
						WHERE pastureid=? AND id=?`, parammaps["type"], fweight, fweight, parammaps["type"], fweight, fweight, parammaps["pastureid"], fpd["id"]).Execute()
							if err != nil {
								// tx.Rollback()
								logs.Error(err, 4, parammaps["type"], fweight, fweight, parammaps["type"], fweight, fweight, parammaps["pastureid"], fpd["id"])
								return
							}

							// var wg sync.WaitGroup
							// wg.Add(len(updateLppandList))
							// go func(parammaps map[string]interface{}, updateLppandList []*lpplandtl1, status int) {
							for _, lppland := range updateLppandList {

								fmt.Println(lppland.Lweight, lppland.Id, parammaps["pastureid"], status)
								_, err = tx.SQL(`update lpplandtl1  set Lweight = ?  where id = ? and pastureid = ?`, lppland.Lweight, lppland.Id, parammaps["pastureid"]).Execute()
								if err != nil {
									fmt.Println(lppland.Lweight, lppland.Id, parammaps["pastureid"], status)
									// tx.Rollback()
									logs.Error(err, 3)
									return
								}
								// defer wg.Done()
							}
							updateLppandList = []*lpplandtl1{}
							// }(parammaps, updateLppandList, status)
							// wg.Wait()
							// tx.Commit()
							// }(parammaps, fweight, status)

							if w == 0 {
								break
							}
						}

						// if weight < oldweight {
						// 	fmt.Println("下调")
						// } else {
						// 	fmt.Println("上调")
						// }
						// break
					}
				}(old, fpd)
			}

		}
		wg.Wait()
	}
	// }()
	fmt.Println(time.Now())
	appG.Response(http.StatusOK, e.SUCCESS, true)
}

type lpplandtlInfo struct {
	Id          int64   `xorm:"id"`
	Pastureid   int64   `xorm:"pastureid"`
	Lppid       int64   `xorm:"lppid"`
	Barid       int64   `xorm:"barid"`
	Barname     string  `xorm:"barname"`
	Fpdid       int64   `xorm:"fpdid"`
	Fttype      int64   `xorm:"fttype"`
	Lweight     float64 `xorm:"lweight"`
	Sort        int64   `xorm:"sort"`
	Tmrid       int64   `xorm:"tmrid"`
	Tmrname     string  `xorm:"tmrname"`
	Cowcount    int64   `xorm:"cowcount"`
	Ccountradio float64 `xorm:"ccountradio"`
	Background  string  `xorm:"background"`
	Lweighthis  float64 `xorm:"lweighthis"`
	Maxweight   float64 `xorm:"maxweight"`
}

func UpdateFpdetailBar(c *gin.Context) {

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	pastureid := fsion.Get("pastureid").ValueStr()
	id := fsion.Get("id").ValueStr()

	tx := restful.Engine.NewSession()
	tx.Begin()

	for _, list := range fsion.Get("data").Array() {
		ftmap := make(map[string]interface{})
		ftmap["old"] = list.Get("old").ValueFloat64()
		ftmap["new"] = list.Get("new").ValueFloat64()
		ftmap["times"] = list.Get("times").ValueInt64()
		ftmap["ptid"] = list.Get("ptid").ValueStr()
		ftmap["ptsid"] = list.Get("ptsid").ValueStr()
		// fmt.Println(ftmap)

		fpdDataList, err := tx.SQL(`select * from (SELECT TRIM(id) id,times,tratio,ifnull(ROUND(ptsrate*weight,2)-ptsuse,"") weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
			(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,0 AS fttype,cowcount,ccountradio,1 isfill  FROM fpdetail
			WHERE fpdetail.pastureid = ?   and barid = ? and  times = ?
			UNION
			SELECT TRIM(id) id,times,tratio,ifnull(ROUND((1-ptsrate)*weight,2)-ptuse,"") weight,TRIM(barid) barid,TRIM(pastureid) pastureid,TRIM(ptid) ptid,TRIM(ptsid ) ptsid ,
			(select bname  from bar where pastureid =fpdetail.pastureid and id = fpdetail.barid ) barname,1 AS fttype,cowcount,ccountradio,0 isfill  FROM fpdetail
			WHERE fpdetail.pastureid = ?  and barid = ? and  times = ? ) t
			order by t.barname,t.times`, pastureid, id, ftmap["times"], pastureid, id, ftmap["times"]).Query().List()
		// fmt.Println(pastureid, id, ftmap["times"], pastureid, id, ftmap["times"])
		if err != nil {
			tx.Rollback()
			logs.Error(err)
		}

		for _, fpd := range fpdDataList {

			if fpd["times"].(int64) == ftmap["times"].(int64) && (fpd["ptid"].(string) == ftmap["ptid"].(string) || fpd["ptsid"].(string) == ftmap["ptsid"].(string)) {
				fttype := -1
				if ftmap["ptid"].(string) != "-1" {
					fttype = 1
				}

				var fweight float64
				var lweight float64
				lpplandtl1List := make([]*lpplandtlInfo, 0)
				err = tx.SQL(`select lppland.*,lpp.maxweight from lpplan lpp
					join lpplandtl1 lppland on lpp.id = lppland.lppid  where lppland.fpdid =?
					and lppland.fttype = ? and lpp.pastureid = ?  and lpp.times  = ? order by lpp.sort desc `,
					fpd["id"], fttype, pastureid, ftmap["times"]).Find(&lpplandtl1List)
				if err != nil {
					tx.Rollback()
					logs.Error(err)
				}

				weight, _ := strconv.ParseFloat(fpd["weight"].(string), 64)

				var w float64
				var status int

				if ftmap["new"].(float64) < ftmap["old"].(float64) {
					if weight >= 0 {
						continue
					}
					w = weight
					status = 0
				} else {
					if weight-(ftmap["new"].(float64)-ftmap["old"].(float64)) > 0 {
						continue
					}
					w = weight
					status = 1
				}

				for _, lppland := range lpplandtl1List {
					lweight += lppland.Lweight
				}

				for _, lppland := range lpplandtl1List {

					if status == 1 {
						// if w <= lppland.Lweight {
						if lppland.Maxweight <= lweight {
							continue
						}
						if w+lweight <= lppland.Maxweight {
							lppland.Lweight += w
							lweight += w
							fweight += w
							w = 0
						} else {

							w = w - (lppland.Maxweight - lweight)
							n := (lppland.Maxweight - lweight)
							lppland.Lweight = lppland.Lweight + n
							lweight += n
							fweight += n

						}
					} else {
						if lppland.Lweight == 0 {
							continue
						}
						if w+lppland.Lweight >= 0 {
							lppland.Lweight = lppland.Lweight + w
							lweight = lweight + w
							fweight = fweight + w
							w = 0
						} else {
							w = w + lppland.Lweight
							lweight = lweight - lppland.Lweight
							fweight = fweight - lppland.Lweight
							lppland.Lweight = 0
						}

					}

					_, err = tx.SQL(`update lpplandtl1  set Lweight = ?  where id = ? and pastureid = ?`, lppland.Lweight, lppland.Id, pastureid).Execute()
					if err != nil {
						tx.Rollback()
						logs.Error(err)
						return
					}
					break
				}
				_, err = tx.SQL(`UPDATE fpdetail SET ptuse=IF(?=1,IF(ptuse+? <0,0,ptuse+?),ptuse),
					ptsuse=IF(?=0,IF(ptsuse+?<0,0,ptsuse+?),ptsuse)
					WHERE pastureid=? AND id=?`, fttype, fweight, fweight, fttype, fweight, fweight, pastureid, fpd["id"]).Execute()
				if err != nil {
					tx.Rollback()
					logs.Error(err)
				}
				if w == 0 {
					break
				}
			}

		}
	}
	tx.Commit()
	appG.Response(http.StatusOK, e.SUCCESS, true)
}

func GetProcessAnalysis(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()
	offset := fsion.Get("offset").ValueDefaultInt(0)
	pagecount := fsion.Get("pagecount").ValueDefaultInt(0)
	returntype := fsion.Get("returntype").ValueDefaultStr("map")

	parammaps := fsion.Get("parammaps")

	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:
			logging.Error("tx.Begin 事务启动失败__error:", err)
			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()

	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)

	s_params := make([]interface{}, 0)
	paramslist := strings.Split(p, ",")
	if len(paramslist) > 0 && p != "" {
		for _, value := range paramslist {
			if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
				if tempv, exists := c.Get("jwt_username"); exists {
					s_params = append(s_params, tempv.(string))
				} else {
					s_params = append(s_params, "")
				}
			} else {
				s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
			}
		}
	}
	tmrtnameStr := ""
	for _, tmr := range parammaps.Get("tmrtname").Array() {
		if len(tmrtnameStr) == 0 {
			tmrtnameStr = fmt.Sprintf("'%s'", tmr.ValueStr())
		} else {
			tmrtnameStr += fmt.Sprintf(",'%s'", tmr.ValueStr())
		}
	}
	if len(tmrtnameStr) > 0 {
		sql += fmt.Sprintf(" AND (d.`tmrtname` in (%s) ) ", tmrtnameStr)
	}
	sql += " ORDER BY d.intime"

	queryData, err := getDataBySqlT(sql, offset, pagecount, returntype, s_params, tx)
	if err != nil {
		logging.Error("GetDataByName  err: ", err)
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, queryData)
	}
}

func UpdateFeedtempletStatus(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	parammaps := fsion.Get("parammaps")

	tx := restful.Engine.NewSession()
	tx.Begin()

	_, err := tx.SQL(fmt.Sprintf(" update feedtemplet  set enable = ? where id in (%s) ", parammaps.Get("id").ValueStr()), parammaps.Get("enable").ValueInt64()).Execute()
	if err != nil {
		tx.Rollback()
		logs.Error(err)
		appG.Response(http.StatusOK, e.ERROR, err)
		return
	}
	tx.Commit()
	appG.Response(http.StatusOK, e.SUCCESS, true)
}

func AddFtdry(c *gin.Context) {
	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	fsion := gofasion.NewFasion(string(dataByte))
	sqlnamestr := fsion.Get("name").ValueStr()

	s_params := make([]interface{}, 0)
	tx := restful.Engine.NewSession()
	err := tx.Begin()
	defer func() {
		switch {
		case err != nil:

			if tx != nil {
				tx.Rollback()
			}
		default:
			if tx != nil {
				err = tx.Commit()
			}
		}
		if tx != nil {
			tx.Close()
		}
	}()
	sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
	if sql != "" {
		parammaps := fsion.Get("parammaps")

		logging.Info("AddFtdry ", c.Keys, c.Request.RemoteAddr, sqlnamestr, parammaps.ValueStr())
		paramslist := strings.Split(p, ",")
		if len(paramslist) > 0 && p != "" {
			for _, value := range paramslist {
				if strings.ToLower(strings.Trim(value, " ")) == "jwt_username" {
					if tempv, exists := c.Get("jwt_username"); exists {
						s_params = append(s_params, tempv.(string))
					} else {
						s_params = append(s_params, "")
					}
				} else if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
					ids, err := setting.SnowIds.NextId()
					if err != nil {
						ids = time.Now().UnixNano()
						logging.Info("create SnowIds err", err)
					}
					s_params = append(s_params, ids)
				} else {
					s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
				}
			}
		}

		var actweight float64
		actweightList, err := tx.SQL(`select ROUND(avg(actweight),2) as actweight  from ftdry  
	where barid in ( select barid from feedp where ftid in ( select ftid from feedp where barid = ? and pastureid = ?))  
	and operatetime  = (select date_format(operatetime ,'%Y-%m-%d') from ftdry 
	where barid  in ( select barid from feedp where ftid in ( select ftid from feedp where barid = ? and pastureid = ? )) 
	and date_format(operatetime ,'%Y-%m-%d') <date_format(? ,'%Y-%m-%d')  and pastureid = ?
	group by operatetime  order by operatetime desc  limit 1) and pastureid = ?`,
			parammaps.Get("barid").ValueStr(), parammaps.Get("pastureid").ValueStr(), parammaps.Get("barid").ValueStr(), parammaps.Get("pastureid").ValueStr(), parammaps.Get("operatetime").ValueStr(), parammaps.Get("pastureid").ValueStr(), parammaps.Get("pastureid").ValueStr()).Query().List()
		if err != nil {
			logging.Error("AddFtdry  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
		}
		if len(actweightList) > 0 {
			for _, item := range actweightList {
				fl, err := strconv.ParseFloat(item["actweight"].(string), 64)
				if err != nil {
					logging.Error("AddFtdry  err: ", err)
					msg := geterrmsg(err.Error())
					appG.Response(http.StatusOK, e.ERROR, msg)
				}
				actweight = fl
			}
		} else {
			dryList, err := tx.SQL(`select ifnull(dry,0.0) as dry from feednur  where fid in (select fid from  ftdetail  
				where ftid = (select ftid from feedp where barid = ? and pastureid = ?)) and pastureid = ?`,
				parammaps.Get("barid").ValueStr(), parammaps.Get("pastureid").ValueStr(), parammaps.Get("pastureid").ValueStr()).Query().List()
			if err != nil {
				logging.Error("AddFtdry  err: ", err)
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusOK, e.ERROR, msg)
			}
			for _, item := range dryList {
				dry, err := strconv.ParseFloat(item["dry"].(string), 64)
				if err != nil {
					logging.Error("AddFtdry  err: ", err)
					msg := geterrmsg(err.Error())
					appG.Response(http.StatusOK, e.ERROR, msg)
				}
				actweight += parammaps.Get("freshweight").ValueFloat64() * dry
			}
		}
		if sqlnamestr == "insertFtdry" {
			s_params = append(s_params, actweight)
		} else if sqlnamestr == "updateFtdry" {
			sql = fmt.Sprintf(sql, actweight)
		}

		queryData, err := execDataBySqlT(sql, s_params, tx)
		if err != nil {
			logging.Error("AddFtdry  err: ", err)
			msg := geterrmsg(err.Error())
			appG.Response(http.StatusOK, e.ERROR, msg)
		} else {
			appG.Response(http.StatusOK, e.SUCCESS, queryData)
		}
	} else {
		appG.Response(http.StatusOK, e.SUCCESS, nil)
	}
}

func CheckDates(c *gin.Context) {

	tx := restful.Engine.NewSession()
	defer tx.Close()

	appG := app.Gin{C: c}
	dataByte, _ := ioutil.ReadAll(c.Request.Body)
	tempval_ := make(map[string]interface{})
	tempCommon := make(map[string]interface{})
	tempval := make([]map[string]interface{}, 0)
	err := json.Unmarshal(dataByte, &tempval_)
	logging.Info("ExecDataByConfig ", c.Keys, c.Request.RemoteAddr, tempval_["common"], tempval_["data"])
	// fmt.Println("ExecDataByConfig ", c.Keys, c.Request.RemoteAddr, tempval_["common"], tempval_["data"])
	if err != nil {
	} else {
		if v, ok := tempval_["common"].(map[string]interface{}); ok {
			tempCommon = v
		}

		if v, ok := tempval_["data"].([]interface{}); ok {
			for _, Tvalue := range v {
				if v1, ok := Tvalue.(map[string]interface{}); ok {
					tempval = append(tempval, v1)
				}
			}
		}

		if err == nil {
			if tempv, exists := c.Get("jwt_username"); exists {
				tempCommon["jwt_username"] = tempv.(string)
			}
			for _, paramvalue := range tempval {
				if _, ok := paramvalue["resultname"]; !ok {
					paramvalue["resultname"] = paramvalue["name"]
				}
				_, err := ExecDataQuery(paramvalue, tempCommon, tempval, nil, nil, tx)
				if err != nil {
					logging.Error("ExecDataParam error:", err)

				}
			}
			if err == nil {
				vmsg := ""
				for _, item := range tempval {
					for _, list := range item["resultmaps"].(map[string]interface{}) {
						for _, childrenList := range list.([]interface{}) {
							for k, children := range childrenList.(map[string]interface{}) {
								if k != "children" {
									continue
								}
								for _, v := range children.([]map[string]interface{}) {
									for k1, v1 := range v["resultmaps"].(map[string]interface{}) {
										if k1 == "list" {
											for _, v2 := range v1.([]map[string]interface{}) {
												if v2["vmsg"].(string) != "1" {
													if len(vmsg) == 0 {
														vmsg = v2["vmsg"].(string)
													} else {
														vmsg = fmt.Sprintf("%s,%s", vmsg, v2["vmsg"])
													}
												}
											}

										}
									}
								}
							}
						}
					}
				}
				if len(vmsg) > 0 {
					appG.Response(http.StatusOK, e.SUCCESS, vmsg)
				} else {
					appG.Response(http.StatusOK, e.SUCCESS, true)
				}
			} else {
				msg := geterrmsg(err.Error())
				appG.Response(http.StatusInternalServerError, e.ERROR, msg)
			}
		}
	}
	if err != nil {
		msg := geterrmsg(err.Error())
		appG.Response(http.StatusOK, e.ERROR, msg)

	}
}

func ExecDataQuery(fasion map[string]interface{}, CommonParamMap map[string]interface{}, ParamMap []map[string]interface{}, ParentParamMap map[string]interface{}, sameParamMap []map[string]interface{}, tx *xorm.Session) (interface{}, error) {
	sqlname := fasion["name"].(string)
	sqltype := "" //v  校验/s1 查询/sm 查询/e  执行
	if v, ok := fasion["type"]; ok {
		sqltype = v.(string)
	}
	sql := ""
	p := ""
	s_params := make([]interface{}, 0)
	if sqltype != "" {
		sql, p = restful.GetSqlByName(sqlname, tx)
		//sqlApi, _ := models.GetApisqlByName(sqlname)
		if v, ok := fasion["parammaps"].(map[string]interface{}); ok {
			paramslist := strings.Split(p, ",")
			if len(paramslist) > 0 && p != "" {
				for _, value := range paramslist {
					ss := ""
					if strings.ToLower(strings.Trim(value, " ")) == "snowid" {
						ids, err := setting.SnowIds.NextId()
						if err != nil {
							ids = time.Now().UnixNano()
							logging.Info("create SnowIds err", err)
						}
						s_params = append(s_params, ids)
					} else {
						if ss == "" && CommonParamMap != nil {
							if valuestring, ok := v[strings.Trim(value, " ")].(string); ok {
								ss = valuestring
								tempstrb := strings.IndexAny(valuestring, "@")
								tempstre := strings.IndexAny(valuestring, ".")
								if (tempstre > tempstrb) && (strings.ToLower(valuestring[tempstrb+1:tempstre]) == "common") {
									if CommonParamMap[valuestring[tempstre+1:]] != nil {
										ss = CommonParamMap[valuestring[tempstre+1:]].(string)
									}
								} else {
									ss = ""
								}
							}

						}

						if ss == "" && ParentParamMap != nil {
							ss = getParamValue_(v, value, ParentParamMap)
						}
						if ss == "" && sameParamMap != nil {
							ss = getParamValue(v, value, sameParamMap)
						}
						if ss == "" && ParamMap != nil {
							ss = getParamValue(v, value, ParamMap)
						}
						s_params = append(s_params, ss)
					}

				}
			}

		}
	}
	if sql == "" {
		sqltype = ""
	}
	if sql != "" {
		tempValParam, err := restful.QueryByMap(sql, 0, 1, s_params)
		if err != nil {
			return nil, err
		}
		// fmt.Println(tempValParam)
		return tempValParam.(map[string]interface{}), nil
	} else {
		if tempValParam, ok := fasion["resultmaps"].(map[string]interface{}); ok {
			err := ExitsChildrenQuery(fasion, tempValParam, ParamMap, CommonParamMap, tx)
			if err != nil {
				return nil, err
			}
			return nil, err
		}
	}

	return nil, nil
}

func ExitsChildrenQuery(fasion map[string]interface{}, tempValParam interface{}, ParamMap []map[string]interface{}, commonParam map[string]interface{}, tx *xorm.Session) error {
	var err error
	subarray, ok := fasion["children"]

	if ok {
		for _, v := range tempValParam.(map[string]interface{})["list"].([]interface{}) { //遍历父集有多少行数据
			tempVal_arrary := make([]map[string]interface{}, 0)
			for _, subarrayvalue := range subarray.([]interface{}) { //遍历所有执行命令
				tempVal_ := make(map[string]interface{})
				if _, ok := subarrayvalue.(map[string]interface{})["resultname"]; !ok {
					tempVal_["resultname"] = subarrayvalue.(map[string]interface{})["name"]
				} else {
					tempVal_["resultname"] = subarrayvalue.(map[string]interface{})["resultname"]
				}
				tempVal_["resultmaps"], err = ExecDataQuery(subarrayvalue.(map[string]interface{}), commonParam, ParamMap, v.(map[string]interface{}), tempVal_arrary, tx) //递归调用执行

				if err != nil {
					return err
				}
				tempVal_arrary = append(tempVal_arrary, tempVal_)
			}
			v.(map[string]interface{})["children"] = tempVal_arrary
		}
	}
	return nil
}