增加mongodb驱动，简单版本

application.go

@@ -7,6 +7,7 @@ import (
 	. "code.hoteas.com/golang/hotime/db"
 	. "code.hoteas.com/golang/hotime/log"
 	"database/sql"
+	"fmt"
 	"github.com/sirupsen/logrus"
 	"io/ioutil"
 	"net/http"
@@ -22,7 +23,6 @@ type Application struct {
 	MakeCodeRouter map[string]*code.MakeCode
 	MethodRouter
 	Router
-	ContextBase
 	Error
 	Log             *logrus.Logger
 	WebConnectLog   *logrus.Logger
@@ -237,10 +237,8 @@ func (that *Application) SetConfig(configPath ...string) {
 
 	}
 
-	that.Log = GetLog(that.Config.GetString("logFile"), true)
+	if that.Error.GetError() != nil {
-	that.Error = Error{Logger: that.Log}
+		fmt.Println(that.Error.GetError().Error())
-	if that.Config.Get("webConnectLogShow") == nil || that.Config.GetBool("webConnectLogShow") {
-		that.WebConnectLog = GetLog(that.Config.GetString("webConnectLogFile"), false)
 	}
 
 	//文件如果损坏则不写入配置防止配置文件数据丢失
@@ -267,6 +265,12 @@ func (that *Application) SetConfig(configPath ...string) {
 
 	}
 
+	that.Log = GetLog(that.Config.GetString("logFile"), true)
+	that.Error = Error{Logger: that.Log}
+	if that.Config.Get("webConnectLogShow") == nil || that.Config.GetBool("webConnectLogShow") {
+		that.WebConnectLog = GetLog(that.Config.GetString("webConnectLogFile"), false)
+	}
+
 }
 
 // SetConnectListener 连接判断,返回false继续传输至控制层，true则停止传输
@@ -370,15 +374,17 @@ func (that *Application) handler(w http.ResponseWriter, req *http.Request) {
 	}()
 
 	//访问拦截true继续false暂停
-	connectListenerLen := len(that.connectListener)
+	connectListenerLen := len(that.connectListener) - 1
-
-	for i := connectListenerLen - 1; i >= 0; i-- {
-
-		if that.connectListener[i](&context) {
 
+	for true {
+		if connectListenerLen < 0 {
+			break
+		}
+		if that.connectListener[connectListenerLen](&context) {
 			context.View()
 			return
 		}
+		connectListenerLen--
 	}
 
 	//接口服务
@@ -562,14 +568,9 @@ func Init(config string) *Application {
 				codeMake["name"] = codeMake.GetString("table")
 			}
 
-			if appIns.Config.GetInt("mode") > 0 {
+			appIns.MakeCodeRouter[codeMake.GetString("name")] = &code.MakeCode{Error: appIns.Error}
-				appIns.MakeCodeRouter[codeMake.GetString("name")] = &code.MakeCode{Error: appIns.Error}
+			appIns.MakeCodeRouter[codeMake.GetString("name")].Db2JSON(&appIns.Db, codeMake)
 
-				appIns.MakeCodeRouter[codeMake.GetString("name")].Db2JSON(&appIns.Db, codeMake)
-			} else {
-				appIns.MakeCodeRouter[codeMake.GetString("name")] = &code.MakeCode{Error: appIns.Error}
-				appIns.MakeCodeRouter[codeMake.GetString("name")].Db2JSON(nil, codeMake)
-			}
 			//接入动态代码层
 			if appIns.Router == nil {
 				appIns.Router = Router{}
@@ -588,9 +589,7 @@ func Init(config string) *Application {
 				appIns.Router[codeMake.GetString("name")][k1] = appIns.Router[codeMake.GetString("name")]["hotimeCommon"]
 			}
 
-			go func() {
+			setMakeCodeListener(codeMake.GetString("name"), &appIns)
-				setMakeCodeLintener(codeMake.GetString("name"), &appIns)
-			}()
 
 		}
 
@@ -660,7 +659,7 @@ func SetSqliteDB(appIns *Application, config Map) {
 	})
 }
 
-func setMakeCodeLintener(name string, appIns *Application) {
+func setMakeCodeListener(name string, appIns *Application) {
 	appIns.SetConnectListener(func(context *Context) (isFinished bool) {
 
 		codeIns := appIns.MakeCodeRouter[name]
@@ -754,7 +753,7 @@ func setMakeCodeLintener(name string, appIns *Application) {
 			context.Router[context.RouterString[0]][context.RouterString[1]]["remove"](context)
 		}
 
-		context.View()
+		//context.View()
 		return true
 	})
 }

code.go

@@ -57,45 +57,6 @@ var TptProject = Proj{
 					}
 					re[link] = that.Db.Get(column.GetString("link"), seStr, Map{"id": v})
 				}
-
-				//权限设置
-				if column["type"] == "auth" {
-
-					btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
-
-					if err != nil {
-						that.Display(4, "找不到权限配置文件")
-						return
-					}
-
-					conf := ObjToMap(string(btes))
-					menus := conf.GetSlice("menus")
-
-					userAuth := re.GetMap("auth")
-
-					for k1, _ := range menus {
-						v1 := menus.GetMap(k1)
-						if userAuth[v1.GetString("name")] != nil {
-							v1["auth"] = userAuth[v1.GetString("name")]
-						}
-						if userAuth[v1.GetString("table")] != nil {
-							v1["auth"] = userAuth[v1.GetString("table")]
-						}
-						v1menus := v1.GetSlice("menus")
-						for k2, _ := range v1menus {
-							v2 := v1menus.GetMap(k2)
-							if userAuth[v2.GetString("name")] != nil {
-								v2["auth"] = userAuth[v2.GetString("name")]
-							}
-							if userAuth[v2.GetString("table")] != nil {
-								v2["auth"] = userAuth[v2.GetString("table")]
-							}
-						}
-					}
-					re["auth"] = menus.ToJsonString()
-					//that.Display(0,menus)
-				}
-
 			}
 
 			//如果有table字段则代为link
@@ -135,230 +96,109 @@ var TptProject = Proj{
 
 			for _, v := range that.MakeCodeRouter[hotimeName].TableColumns[fileConfig.GetString("table")] {
 				if v.GetString("link") != "" {
-
+					//与用户信息有关联的parent_id自填充
 					if v.GetString("link") == tableName && that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["parent_id"] != nil {
-						if inData["parent_id"] == nil {
+						if inData["parent_id"] == nil && data[v.GetString("name")] != nil {
 							inData["parent_id"] = data.GetCeilInt64(v.GetString("name"))
-							pre := that.Db.Get(v.GetString("link"), "parent_ids", Map{"id": data.GetCeilInt64(v.GetString("name"))})
+							//pre := that.Db.Get(v.GetString("link"), "parent_ids", Map{"id": data.GetCeilInt64(v.GetString("name"))})
-							inData["parent_ids"] = pre.GetString("parent_ids")
+							//inData["parent_ids"] = pre.GetString("parent_ids")+ObjToStr(data.GetCeilInt64(v.GetString("name")))+","
 						}
 
 					}
 				}
-			}
 
-			if inData["auth"] != nil {
+				if v.GetString("link") == tableName && that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"] != nil {
+					linkAuthMap := that.Db.Get(v.GetString("link"), "auth", Map{"id": data.GetCeilInt(v.GetString("name"))})
+					linkAuth := linkAuthMap.GetMap("auth")
 
-				btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
+					if linkAuth == nil {
+						btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
+						if err != nil {
+							that.Display(4, "找不到配置文件")
+							return
+						}
+						linkAuth = Map{}
+						conf := ObjToMap(string(btes))
+						menus := conf.GetSlice("menus")
 
-				if err != nil {
+						for k1, _ := range menus {
-					that.Display(4, "找不到配置文件")
+							v1 := menus.GetMap(k1)
-					return
+							name := v1.GetString("name")
-				}
+							if name == "" {
-
+								name = v1.GetString("table")
-				conf := ObjToMap(string(btes))
+							}
-				menus := conf.GetSlice("menus")
+							if v1["auth"] != nil {
-
-				for _, v := range that.MakeCodeRouter[hotimeName].TableColumns[fileConfig.GetString("table")] {
-					if v.GetString("link") != "" && that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"] != nil {
-						//linkHasAuth := that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"]
-						//if linkHasAuth != nil {
-
-						linkAuthMap := that.Db.Get(v.GetString("link"), "auth", Map{"id": data.GetCeilInt(v.GetString("name"))})
-						linkAuth := linkAuthMap.GetMap("auth")
-						myAuth := Map{}
-						if linkAuth != nil {
-
-							for k1, _ := range menus {
-
-								v1 := menus.GetMap(k1)
-
-								if linkAuth[v1.GetString("table")] != nil {
-									v1["auth"] = linkAuth[v1.GetString("table")]
-
-								}
-								if linkAuth[v1.GetString("name")] != nil {
-									v1["auth"] = linkAuth[v1.GetString("name")]
-
-								}
-
-								if v1.GetString("name") != "" && v1["auth"] == nil {
-									v1["auth"] = Slice{"show"}
-
-								}
-
-								if v1.GetString("table") != "" && v1["auth"] == nil {
-									v1["auth"] = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(v1.GetString("table"))["auth"]
-								}
-
-								if v1.GetString("table") != "" {
-									myAuth[v1.GetString("table")] = v1
-								}
-								if v1.GetString("name") != "" {
-									myAuth[v1.GetString("name")] = v1
-								}
-
-								v1menus := v1.GetSlice("menus")
-								for k2, _ := range v1menus {
-									v2 := v1menus.GetMap(k2)
-									if linkAuth[v2.GetString("table")] != nil {
-										v2["auth"] = linkAuth[v2.GetString("table")]
 
+								if linkAuth[name] == nil {
+									linkAuth[name] = v1["auth"]
+								} else {
+									newAuth := Slice{}
+									for k2, _ := range linkAuth.GetSlice(name) {
+										v2 := linkAuth.GetSlice(name).GetString(k2)
+										if strings.Contains(v1.GetString("auth"), v2) {
+											newAuth = append(newAuth, v2)
+										}
 									}
+									linkAuth[name] = newAuth
+								}
+							}
 
-									if linkAuth[v2.GetString("name")] != nil {
+							menusChild := v1.GetSlice("menus")
-										v2["auth"] = linkAuth[v2.GetString("name")]
+							for k2, _ := range menusChild {
-									}
+								v2 := menusChild.GetMap(k2)
+								name := v2.GetString("name")
+								if name == "" {
+									name = v2.GetString("table")
+								}
+								if v2["auth"] != nil {
 
-									if v2.GetString("name") != "" && v2["auth"] == nil {
+									if linkAuth[name] == nil {
-										v2["auth"] = Slice{"show"}
+										linkAuth[name] = v2["auth"]
 
-									}
+									} else {
 
-									if v2.GetString("table") != "" && v2["auth"] == nil {
+										newAuth := Slice{}
-										v2["auth"] = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(v2.GetString("table"))["auth"]
+										for k3, _ := range linkAuth.GetSlice(name) {
-									}
+											v3 := linkAuth.GetSlice(name).GetString(k3)
+											if strings.Contains(v2.GetString("auth"), v3) {
+												newAuth = append(newAuth, v3)
+											}
+										}
+										linkAuth[name] = newAuth
+										continue
 
-									if v2.GetString("table") != "" {
-										myAuth[v2.GetString("table")] = v2
-									}
-
-									if v2.GetString("name") != "" {
-										myAuth[v2.GetString("name")] = v2
 									}
 								}
 							}
 						}
+					}
 
-						newAuth := inData.GetSlice("auth")
+					toDB := Map{}
-						toDB := Map{}
+					newAuth := inData.GetMap("auth")
-						for k1, _ := range newAuth {
+					if newAuth == nil {
-							v1 := newAuth.GetMap(k1)
+						inData["auth"] = linkAuth.ToJsonString()
+						continue
+					}
 
-							if myAuth.GetMap(v1.GetString("name")) == nil && myAuth.GetMap(v1.GetString("table")) == nil {
+					for k1, _ := range newAuth {
+						v1 := newAuth.GetSlice(k1)
+						if linkAuth.GetString(k1) == "" {
+							continue
+						}
+						toDbli := Slice{}
+						for k2, _ := range v1 {
+							v2 := v1.GetString(k2)
+
+							if !strings.Contains(linkAuth.GetString(k1), `"`+v2+`"`) {
 								continue
 							}
-
+							toDbli = append(toDbli, v2)
-							auth := Slice{}
-
-							str := v1.GetString("name")
-
-							if v1.GetString("table") != "" {
-
-								str = v1.GetString("table")
-							}
-
-							if v1.GetString("auth") == "" {
-								if myAuth.GetMap(str).GetString("table") != "" {
-									auth = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(str).GetSlice("auth")
-								} else {
-									auth = Slice{"show"}
-								}
-
-							} else {
-
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"show"`) &&
-									strings.Contains(v1.GetString("auth"), `"show"`) {
-									auth = append(auth, "show")
-
-								}
-
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"download"`) &&
-									strings.Contains(v1.GetString("auth"), `"download"`) {
-									auth = append(auth, "download")
-
-								}
-
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"add"`) &&
-									strings.Contains(v1.GetString("auth"), `"add"`) {
-									auth = append(auth, "add")
-									//continue
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"edit"`) &&
-									strings.Contains(v1.GetString("auth"), `"edit"`) {
-									auth = append(auth, "edit")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"delete"`) &&
-									strings.Contains(v1.GetString("auth"), `"delete"`) {
-									auth = append(auth, "delete")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"info"`) &&
-									strings.Contains(v1.GetString("auth"), `"info"`) {
-									auth = append(auth, "info")
-
-								}
-
-							}
-							toDB[str] = auth
-							v1Menus := v1.GetSlice("menus")
-							for k2, _ := range v1Menus {
-								v2 := v1Menus.GetMap(k2)
-
-								if myAuth.GetMap(v2.GetString("name")) == nil && myAuth.GetMap(v2.GetString("table")) == nil {
-									continue
-								}
-
-								auth := Slice{}
-
-								str := v2.GetString("name")
-
-								if v2.GetString("table") != "" {
-
-									str = v2.GetString("table")
-								}
-
-								if v2.GetString("auth") == "" {
-									if myAuth.GetMap(str).GetString("table") != "" {
-										auth = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(str).GetSlice("auth")
-									} else {
-										auth = Slice{"show"}
-									}
-
-								} else {
-
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"show"`) &&
-										strings.Contains(v2.GetString("auth"), `"show"`) {
-										auth = append(auth, "show")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"download"`) &&
-										strings.Contains(v1.GetString("auth"), `"download"`) {
-										auth = append(auth, "download")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"add"`) &&
-										strings.Contains(v2.GetString("auth"), `"add"`) {
-										auth = append(auth, "add")
-										//continue
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"edit"`) &&
-										strings.Contains(v2.GetString("auth"), `"edit"`) {
-										auth = append(auth, "edit")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"delete"`) &&
-										strings.Contains(v2.GetString("auth"), `"delete"`) {
-										auth = append(auth, "delete")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"info"`) &&
-										strings.Contains(v2.GetString("auth"), `"info"`) {
-										auth = append(auth, "info")
-
-									}
-
-								}
-								toDB[str] = auth
-
-							}
-
 						}
-						inData["auth"] = toDB.ToJsonString()
+						toDB[k1] = toDbli
-						break
 					}
-					//}
+
+					inData["auth"] = toDB.ToJsonString()
+					//break
 				}
 			}
 
@@ -369,14 +209,16 @@ var TptProject = Proj{
 				return
 			}
 			//索引管理，便于检索以及权限
-			if inData.Get("parent_id") != nil && inData.GetString("parent_ids") != "" {
+			if inData.Get("parent_id") != nil {
 				index := that.Db.Get(tableName, "`parent_ids`", Map{"id": inData.Get("parent_id")})
-				inData["parent_ids"] = index.GetString("parent_ids") + ObjToStr(re) + ","
+				parent_ids := index.GetString("parent_ids")
-				that.Db.Update(tableName, Map{"parent_ids": inData["parent_ids"]}, Map{"id": re})
+				if parent_ids == "" {
-			} else if inData.GetString("parent_ids") != "" {
+					parent_ids = ","
-				inData["parent_ids"] = "," + ObjToStr(re) + ","
+				}
+				inData["parent_ids"] = parent_ids + ObjToStr(re) + ","
 				that.Db.Update(tableName, Map{"parent_ids": inData["parent_ids"]}, Map{"id": re})
 			}
+
 			that.Log["table_id"] = re
 			that.Display(0, re)
 		},
@@ -393,254 +235,144 @@ var TptProject = Proj{
 				that.Display(3, "没有找到要更新的数据")
 				return
 			}
+
 			data := that.Db.Get(fileConfig.GetString("table"), "*", Map{"id": that.Session(fileConfig.GetString("table") + "_id").ToCeilInt()})
 
 			//树状结构不允许修改自身的属性，修改别人的可以
-			if fileConfig.GetString("table") == tableName && that.RouterString[2] == that.Session(fileConfig.GetString("table")+"_id").ToStr() {
+			btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
+			if err != nil {
+				that.Display(4, "找不到权限配置文件")
+				return
+			}
 
-				for _, v := range that.MakeCodeRouter[hotimeName].TableColumns[fileConfig.GetString("table")] {
+			conf := ObjToMap(string(btes))
-
-					if v.GetString("link") == "" {
-						continue
-					}
-
-					if that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["parent_id"] != nil {
-
-						delete(inData, v.GetString("name"))
-					}
 
+			stop := conf.GetSlice("stop")
+			for k, _ := range stop {
+				v := stop.GetString(k)
+				//不能改对应行数据
+				if tableName == v && data.GetCeilInt64(v+"_id") == ObjToCeilInt64(that.RouterString[2]) {
+					that.Display(4, "你没有权限修改当前数据")
+					return
+				}
+				//不能改自身对应的数据
+				if tableName == fileConfig.GetString("table") && inData[v+"_id"] != nil {
+					delete(inData, v+"_id")
 				}
 
 			}
 
 			if inData["auth"] != nil {
-
-				btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
-
-				if err != nil {
-					that.Display(4, "找不到配置文件")
-					return
-				}
-
-				conf := ObjToMap(string(btes))
 				menus := conf.GetSlice("menus")
-
 				for _, v := range that.MakeCodeRouter[hotimeName].TableColumns[fileConfig.GetString("table")] {
-					if v.GetString("link") != "" && that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"] != nil {
-						//linkHasAuth := that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"]
-						//if linkHasAuth != nil {
 
+					if v.GetString("link") != "" && that.MakeCodeRouter[hotimeName].TableColumns[v.GetString("link")]["auth"] != nil {
 						linkAuthMap := that.Db.Get(v.GetString("link"), "auth", Map{"id": data.GetCeilInt(v.GetString("name"))})
 						linkAuth := linkAuthMap.GetMap("auth")
-						myAuth := Map{}
+						//conf := ObjToMap(string(btes))
-						if linkAuth != nil {
+						//menus := conf.GetSlice("menus")
+						if linkAuth == nil {
+							linkAuth = Map{}
+						}
 
-							for k1, _ := range menus {
+						for k1, _ := range menus {
-
+							v1 := menus.GetMap(k1)
-								v1 := menus.GetMap(k1)
+							name := v1.GetString("name")
-
+							if name == "" {
-								if linkAuth[v1.GetString("table")] != nil {
+								name = v1.GetString("table")
-									v1["auth"] = linkAuth[v1.GetString("table")]
+							}
-
+							if v1["auth"] != nil {
-								}
-								if linkAuth[v1.GetString("name")] != nil {
-									v1["auth"] = linkAuth[v1.GetString("name")]
-
-								}
-
-								if v1.GetString("name") != "" && v1["auth"] == nil {
-									v1["auth"] = Slice{"show"}
-
-								}
-
-								if v1.GetString("table") != "" && v1["auth"] == nil {
-									v1["auth"] = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(v1.GetString("table"))["auth"]
-								}
-
-								if v1.GetString("table") != "" {
-									myAuth[v1.GetString("table")] = v1
-								}
-								if v1.GetString("name") != "" {
-									myAuth[v1.GetString("name")] = v1
-								}
-
-								v1menus := v1.GetSlice("menus")
-								for k2, _ := range v1menus {
-									v2 := v1menus.GetMap(k2)
-									if linkAuth[v2.GetString("table")] != nil {
-										v2["auth"] = linkAuth[v2.GetString("table")]
 
+								if linkAuth[name] == nil {
+									linkAuth[name] = v1["auth"]
+								} else {
+									newAuth := Slice{}
+									for k2, _ := range linkAuth.GetSlice(name) {
+										v2 := linkAuth.GetSlice(name).GetString(k2)
+										if strings.Contains(v1.GetString("auth"), v2) {
+											newAuth = append(newAuth, v2)
+										}
 									}
+									linkAuth[name] = newAuth
+								}
+							}
 
-									if linkAuth[v2.GetString("name")] != nil {
+							menusChild := v1.GetSlice("menus")
-										v2["auth"] = linkAuth[v2.GetString("name")]
+							for k2, _ := range menusChild {
-									}
+								v2 := menusChild.GetMap(k2)
+								name := v2.GetString("name")
+								if name == "" {
+									name = v2.GetString("table")
+								}
+								if v2["auth"] != nil {
 
-									if v2.GetString("name") != "" && v2["auth"] == nil {
+									if linkAuth[name] == nil {
-										v2["auth"] = Slice{"show"}
+										linkAuth[name] = v2["auth"]
 
-									}
+									} else {
 
-									if v2.GetString("table") != "" && v2["auth"] == nil {
+										newAuth := Slice{}
-										v2["auth"] = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(v2.GetString("table"))["auth"]
+										for k3, _ := range linkAuth.GetSlice(name) {
-									}
+											v3 := linkAuth.GetSlice(name).GetString(k3)
+											if strings.Contains(v2.GetString("auth"), v3) {
+												newAuth = append(newAuth, v3)
+											}
+										}
+										linkAuth[name] = newAuth
+										continue
 
-									if v2.GetString("table") != "" {
-										myAuth[v2.GetString("table")] = v2
-									}
-
-									if v2.GetString("name") != "" {
-										myAuth[v2.GetString("name")] = v2
 									}
 								}
 							}
 						}
 
-						newAuth := inData.GetSlice("auth")
 						toDB := Map{}
+						newAuth := inData.GetMap("auth")
+						if newAuth == nil || len(newAuth) == 0 {
+							inData["auth"] = linkAuth.ToJsonString()
+							break
+						}
+						//不可超出用户权限
 						for k1, _ := range newAuth {
-							v1 := newAuth.GetMap(k1)
+							v1 := newAuth.GetSlice(k1)
-
+							if linkAuth.GetString(k1) == "" {
-							if myAuth.GetMap(v1.GetString("name")) == nil && myAuth.GetMap(v1.GetString("table")) == nil {
 								continue
 							}
-
+							toDbli := Slice{}
-							auth := Slice{}
+							for k2, _ := range v1 {
-
+								v2 := v1.GetString(k2)
-							str := v1.GetString("name")
+								if !strings.Contains(linkAuth.GetString(k1), `"`+v2+`"`) {
-
-							if v1.GetString("table") != "" {
-
-								str = v1.GetString("table")
-							}
-
-							if v1.GetString("auth") == "" {
-								if myAuth.GetMap(str).GetString("table") != "" {
-									auth = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(str).GetSlice("auth")
-								} else {
-									auth = Slice{"show"}
-								}
-
-							} else {
-
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"show"`) &&
-									strings.Contains(v1.GetString("auth"), `"show"`) {
-									auth = append(auth, "show")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"download"`) &&
-									strings.Contains(v1.GetString("auth"), `"download"`) {
-									auth = append(auth, "download")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"add"`) &&
-									strings.Contains(v1.GetString("auth"), `"add"`) {
-									auth = append(auth, "add")
-									//continue
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"edit"`) &&
-									strings.Contains(v1.GetString("auth"), `"edit"`) {
-									auth = append(auth, "edit")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"delete"`) &&
-									strings.Contains(v1.GetString("auth"), `"delete"`) {
-									auth = append(auth, "delete")
-
-								}
-								if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"info"`) &&
-									strings.Contains(v1.GetString("auth"), `"info"`) {
-									auth = append(auth, "info")
-
-								}
-
-							}
-							toDB[str] = auth
-							v1Menus := v1.GetSlice("menus")
-							for k2, _ := range v1Menus {
-								v2 := v1Menus.GetMap(k2)
-
-								if myAuth.GetMap(v2.GetString("name")) == nil && myAuth.GetMap(v2.GetString("table")) == nil {
 									continue
 								}
-
+								toDbli = append(toDbli, v2)
-								auth := Slice{}
-
-								str := v2.GetString("name")
-
-								if v2.GetString("table") != "" {
-
-									str = v2.GetString("table")
-								}
-
-								if v2.GetString("auth") == "" {
-									if myAuth.GetMap(str).GetString("table") != "" {
-										auth = that.MakeCodeRouter[hotimeName].TableConfig.GetMap(str).GetSlice("auth")
-									} else {
-										auth = Slice{"show"}
-									}
-
-								} else {
-
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"show"`) &&
-										strings.Contains(v2.GetString("auth"), `"show"`) {
-										auth = append(auth, "show")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"download"`) &&
-										strings.Contains(v1.GetString("auth"), `"download"`) {
-										auth = append(auth, "download")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"add"`) &&
-										strings.Contains(v2.GetString("auth"), `"add"`) {
-										auth = append(auth, "add")
-										//continue
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"edit"`) &&
-										strings.Contains(v2.GetString("auth"), `"edit"`) {
-										auth = append(auth, "edit")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"delete"`) &&
-										strings.Contains(v2.GetString("auth"), `"delete"`) {
-										auth = append(auth, "delete")
-
-									}
-									if strings.Contains(myAuth.GetMap(str).GetString("auth"), `"info"`) &&
-										strings.Contains(v2.GetString("auth"), `"info"`) {
-										auth = append(auth, "info")
-
-									}
-
-								}
-								toDB[str] = auth
-
 							}
-
+							toDB[k1] = toDbli
 						}
+
 						inData["auth"] = toDB.ToJsonString()
 						break
 					}
-					//}
 				}
+
 			}
 
-			//索引管理，便于检索以及权限
+			if inData.Get("parent_id") != nil {
-			if inData.GetString("parent_ids") != "" {
+				//1
-				if inData.Get("parent_id") != nil {
+				//12        62
-					Index := that.Db.Get(tableName, "`index`", Map{"id": that.RouterString[2]})
+				//123       623
-					parentIndex := that.Db.Get(tableName, "`index`", Map{"id": inData.Get("parent_id")})
+				Index := that.Db.Get(tableName, "parent_id,`parent_ids`", Map{"id": that.RouterString[2]})
-					inData["parent_ids"] = parentIndex.GetString("parent_ids") + that.RouterString[2] + ","
+				if inData.GetCeilInt64("parent_id") != Index.GetCeilInt64("parent_id") {
-
+					parentIndex := that.Db.Get(tableName, "`parent_ids`", Map{"id": inData.Get("parent_id")})
-					childNodes := that.Db.Select(tableName, "id,`index``", Map{"index[~]": "," + that.RouterString[2] + ","})
+					if strings.Contains(parentIndex.GetString("parent_ids"), ","+that.RouterString[2]+",") {
-
+						that.Display(4, "不能将子级设置为父级")
+						return
+					}
+					parent_ids := parentIndex.GetString("parent_ids") + that.RouterString[2] + ","
+					childNodes := that.Db.Select(tableName, "id,`parent_ids`", Map{"parent_ids[~]": "," + that.RouterString[2] + ","})
 					for _, v := range childNodes {
-						v["parent_ids"] = strings.Replace(v.GetString("parent_ids"), Index.GetString("parent_ids"), inData.GetString("parent_ids"), -1)
+						v["parent_ids"] = strings.Replace(v.GetString("parent_ids"), Index.GetString("parent_ids"), parent_ids, -1)
 						that.Db.Update(tableName, Map{"parent_ids": v["parent_ids"]}, Map{"id": v.GetCeilInt("id")})
 					}
-				} else {
-					delete(inData, "parent_ids")
 				}
 
 			}
@@ -652,21 +384,18 @@ var TptProject = Proj{
 				return
 			}
 
+			//索引管理，便于检索以及权限
 			that.Display(0, re)
 		},
 		"remove": func(that *Context) {
 			tableName := that.RouterString[1]
 			that.Log = Map{"table": tableName, "type": 3, "table_id": that.RouterString[2]}
 			hotimeName := that.RouterString[0]
-			inData := that.MakeCodeRouter[hotimeName].Delete(tableName, that.Req)
+
-			if inData == nil {
-				that.Display(3, "请求参数不足")
-				return
-			}
 			re := int64(0)
-			//索引管理，便于检索以及权限
+			//有索引则删除对应的参数
-			if inData.Get("parent_id") != nil && inData.GetSlice("parent_ids") != nil {
+			if that.MakeCodeRouter[hotimeName].TableColumns[tableName]["parent_id"] != nil {
-				re = that.Db.Delete(tableName, Map{"index[~]": "," + that.RouterString[2] + ","})
+				re = that.Db.Delete(tableName, Map{"parent_ids[~]": "," + that.RouterString[2] + ","})
 			} else {
 				re = that.Db.Delete(tableName, Map{"id": that.RouterString[2]})
 			}
@@ -931,47 +660,7 @@ var TptProject = Proj{
 					}
 					re[link] = that.Db.Get(column.GetString("link"), seStr, Map{"id": v})
 				}
-
-				//权限设置
-				if column["type"] == "auth" {
-
-					btes, err := ioutil.ReadFile(fileConfig.GetString("config"))
-
-					if err != nil {
-						that.Display(4, "找不到权限配置文件")
-						return
-					}
-
-					conf := ObjToMap(string(btes))
-					menus := conf.GetSlice("menus")
-
-					userAuth := re.GetMap("auth")
-
-					for k1, _ := range menus {
-						v1 := menus.GetMap(k1)
-						if userAuth[v1.GetString("name")] != nil {
-							v1["auth"] = userAuth[v1.GetString("name")]
-						}
-						if userAuth[v1.GetString("table")] != nil {
-							v1["auth"] = userAuth[v1.GetString("table")]
-						}
-						v1menus := v1.GetSlice("menus")
-						for k2, _ := range v1menus {
-							v2 := v1menus.GetMap(k2)
-							if userAuth[v2.GetString("name")] != nil {
-								v2["auth"] = userAuth[v2.GetString("name")]
-							}
-							if userAuth[v2.GetString("table")] != nil {
-								v2["auth"] = userAuth[v2.GetString("table")]
-							}
-						}
-					}
-					re["auth"] = menus.ToJsonString()
-					//that.Display(0,menus)
-				}
-
 			}
-
 			//如果有table字段则代为link
 			if re["table"] != nil && re["table_id"] != nil {
 
@@ -1008,11 +697,15 @@ var TptProject = Proj{
 			where := Map{"name": name}
 			if that.MakeCodeRouter[hotimeName].TableColumns[fileConfig.GetString("table")]["phone"] != nil {
 				where["phone"] = name
-				where = Map{"AND": Map{"OR": where, "password": Md5(password)}}
+				where = Map{"OR": where, "password": Md5(password)}
 			} else {
 				where["password"] = Md5(password)
 			}
 
+			if len(where) > 1 {
+				where = Map{"AND": where}
+			}
+
 			user := that.Db.Get(fileConfig.GetString("table"), "*", where)
 
 			if user == nil {
@@ -1073,58 +766,118 @@ var TptProject = Proj{
 
 					linkAuthMap := that.Db.Get(v.GetString("link"), "auth", Map{"id": user.GetCeilInt(v.GetString("name"))})
 					linkAuth := linkAuthMap.GetMap("auth")
+					//conf := ObjToMap(string(btes))
+					//menus := conf.GetSlice("menus")
+					if linkAuth == nil {
+						linkAuth = Map{}
+					}
 
 					for k1, _ := range menus {
 						v1 := menus.GetMap(k1)
-						if linkAuth[v1.GetString("name")] != nil {
+						name := v1.GetString("name")
-							v1["auth"] = linkAuth[v1.GetString("name")]
+						if name == "" {
+							name = v1.GetString("table")
 						}
-						if linkAuth[v1.GetString("table")] != nil {
+						if v1["auth"] != nil {
-							v1["auth"] = linkAuth[v1.GetString("table")]
+
+							if linkAuth[name] == nil {
+								linkAuth[name] = v1["auth"]
+							} else {
+								newAuth := Slice{}
+								for k2, _ := range linkAuth.GetSlice(name) {
+									v2 := linkAuth.GetSlice(name).GetString(k2)
+									if strings.Contains(v1.GetString("auth"), v2) {
+										newAuth = append(newAuth, v2)
+									}
+								}
+								linkAuth[name] = newAuth
+							}
 						}
+
+						menusChild := v1.GetSlice("menus")
+						for k2, _ := range menusChild {
+							v2 := menusChild.GetMap(k2)
+							name := v2.GetString("name")
+							if name == "" {
+								name = v2.GetString("table")
+							}
+							if v2["auth"] != nil {
+
+								if linkAuth[name] == nil {
+									linkAuth[name] = v2["auth"]
+
+								} else {
+
+									newAuth := Slice{}
+									for k3, _ := range linkAuth.GetSlice(name) {
+										v3 := linkAuth.GetSlice(name).GetString(k3)
+										if strings.Contains(v2.GetString("auth"), v3) {
+											newAuth = append(newAuth, v3)
+										}
+									}
+									linkAuth[name] = newAuth
+									continue
+
+								}
+							}
+						}
+					}
+
+					for k1, _ := range menus {
+						v1 := menus.GetMap(k1)
+						//保证个人权限可用
+						if fileConfig.GetString("table") == v1.GetString("table") {
+							v1["auth"] = Slice{"info", "edit"}
+						}
+						name := v1.GetString("name")
+						if name == "" {
+							name = v1.GetString("table")
+						}
+
+						if linkAuth[name] != nil {
+							v1["auth"] = linkAuth[name]
+						}
+
 						v1menus := v1.GetSlice("menus")
 						for k2, _ := range v1menus {
 							v2 := v1menus.GetMap(k2)
-							if linkAuth[v2.GetString("name")] != nil {
+							//保证个人权限可用
-								v2["auth"] = linkAuth[v2.GetString("name")]
+							if fileConfig.GetString("table") == v2.GetString("table") {
+								v2["auth"] = Slice{"info", "edit"}
+
 							}
-							if linkAuth[v2.GetString("table")] != nil {
+							name := v2.GetString("name")
-								v2["auth"] = linkAuth[v2.GetString("table")]
+							if name == "" {
+								name = v2.GetString("table")
 							}
+							if linkAuth[name] != nil {
+								v2["auth"] = linkAuth[name]
+							}
+
 						}
 					}
 
+					break
 				}
 			}
 
-			userAuth := user.GetMap("auth")
-			for k1, _ := range menus {
-				v1 := menus.GetMap(k1)
-				if userAuth[v1.GetString("table")] != nil {
-					v1["auth"] = userAuth[v1.GetString("table")]
-				}
-				v1menus := v1.GetSlice("menus")
-				for k2, _ := range v1menus {
-					v2 := v1menus.GetMap(k2)
-					if userAuth[v2.GetString("table")] != nil {
-						v2["auth"] = userAuth[v2.GetString("table")]
-					}
-				}
-			}
 			//不可读写数据
 			config := DeepCopyMap(that.MakeCodeRouter[hotimeName].Config).(Map)
 
 			config["menus"] = menus
 			newTables := Map{}
+			newTables[fileConfig.GetString("table")] = config.GetMap("tables").GetMap(fileConfig.GetString("table"))
 			for k1, _ := range menus {
 				v1 := menus.GetMap(k1)
-				if config.GetMap("tables").GetMap(v1.GetString("table")) != nil {
+				if config.GetMap("tables").GetMap(v1.GetString("table")) != nil && len(v1.GetSlice("auth")) != 0 {
+					config.GetMap("tables").GetMap(v1.GetString("table"))["auth"] = Slice{}
 					newTables[v1.GetString("name")] = config.GetMap("tables").GetMap(v1.GetString("table"))
 				}
 				v1menus := v1.GetSlice("menus")
 				for k2, _ := range v1.GetSlice("menus") {
 					v2 := v1menus.GetMap(k2)
-					if config.GetMap("tables").GetMap(v2.GetString("table")) != nil {
+					if config.GetMap("tables").GetMap(v2.GetString("table")) != nil && len(v2.GetSlice("auth")) != 0 {
+
 						//有自定义配置文件
 						if conf.GetMap("tables") != nil && conf.GetMap("tables").GetMap(v2.GetString("table")) != nil {
 
@@ -1143,7 +896,7 @@ var TptProject = Proj{
 
 							}
 						}
-
+						config.GetMap("tables").GetMap(v2.GetString("table"))["auth"] = Slice{}
 						newTables[v2.GetString("table")] = config.GetMap("tables").GetMap(v2.GetString("table"))
 
 					}

code/config.go

@@ -8,6 +8,15 @@ var Config = Map{
 	"name": "HoTimeDashBoard",
 	//"id":    "2f92h3herh23rh2y8",
 	"label": "HoTime管理平台",
+	"stop":  Slice{"role", "org"}, //不更新的，同时不允许修改用户自身对应的表数据
+	"labelConfig": Map{
+		"show":     "开启",
+		"add":      "添加",
+		"delete":   "删除",
+		"edit":     "编辑",
+		"info":     "查看详情",
+		"download": "下载清单",
+	},
 	"menus": []Map{
 		//{"label": "平台首页", "name": "HelloWorld", "icon": "el-icon-s-home"},
 		//{"label": "测试表格", "table": "table", "icon": "el-icon-suitcase"},

code/makecode.go

@@ -43,20 +43,6 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 	that.Config = DeepCopyMap(Config).(Map)
 
 	that.Config["name"] = config.GetString("table")
-	//if err == nil {
-	//	cmap := Map{}
-	//	//文件是否损坏
-	//	cmap.JsonToMap(string(btes), &that.Error)
-	//	for k, v := range cmap {
-	//		that.Config[k] = v //程序配置
-	//		//Config[k] = v      //系统配置
-	//	}
-	//	hasConfigFile = true
-	//} else {
-	//
-	//	that.Error.SetError(errors.New("config配置文件不存在，或者配置出错，使用缺省默认配置"))
-	//
-	//}
 	//加载规则文件
 	btesRule, errRule := ioutil.ReadFile(config.GetString("rule"))
 	that.RuleConfig = []Map{}
@@ -84,38 +70,6 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 	}
 
 	that.IndexMenus = Map{}
-	//menusConfig := that.Config.GetSlice("menus")
-	////将配置写入到内存中仅作为判断用
-	//if menusConfig != nil {
-	//	for kmenu, _ := range menusConfig {
-	//		menu := menusConfig.GetMap(kmenu)
-	//		if menu != nil {
-	//			mname := menu.GetString("table")
-	//			if mname == "" { //如果为空则不是表格
-	//				mname = menu.GetString("name")
-	//			}
-	//			that.IndexMenus[mname] = menu
-	//			childMenus := menu.GetSlice("menus")
-	//			if childMenus != nil {
-	//				for ckmenu, _ := range childMenus {
-	//					cmenu := childMenus.GetMap(ckmenu)
-	//					if cmenu != nil {
-	//						cname := cmenu.GetString("table")
-	//						if cmenu.GetString("table") == "" {
-	//							continue
-	//						}
-	//						that.IndexMenus[mname+"/"+cname] = cmenu
-	//					}
-	//
-	//				}
-	//
-	//			}
-	//
-	//		}
-	//
-	//	}
-	//}
-
 	that.TableConfig = that.Config.GetMap("tables")
 	if that.TableConfig == nil {
 		that.TableConfig = Map{}
@@ -179,7 +133,8 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 				"auth":    []string{"show", "add", "delete", "edit", "info", "download"},
 				"columns": []Map{},
 				"search": []Map{
-
+					{"type": "search", "name": "keywordtable", "label": "筛选", "options": Slice{Map{"name": "无", "value": nil}}, "value": nil},
+					{"type": "search", "name": "daterangetable", "label": "筛选", "options": Slice{Map{"name": "无", "value": nil}}, "value": nil},
 					{"type": "search", "name": "keyword", "label": "请输入关键词", "value": nil},
 					{"type": "search", "name": "daterange", "label": "时间段", "value": nil},
 					{"type": "search", "name": "sort", "label": "排序", "value": nil},
@@ -321,13 +276,6 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 				//}
 
 			}
-			//else {
-			//
-			//	//if !(coloum.GetString("label") != "备注" && info.GetString("label") == "备注") {
-			//	//	coloum["label"] = info.GetString("label")
-			//	//}
-			//	//coloum["type"] = info.GetString("type")
-			//}
 
 			//暂时不关闭参数，保证表数据完全读取到
 			that.TableColumns[v.GetString("name")][info.GetString("name")] = coloum
@@ -371,21 +319,6 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 	//数据生成完后进一步解析
 	for fk, fv := range that.TableColumns {
 
-		//判断是否将表写入menu中
-		//isMenusGet := false //判断是否被目录收录
-		//for indexKey, _ := range that.IndexMenus {
-		//	indexCode := strings.Index(indexKey, fk)
-		//	if indexCode == 0 || indexCode == 4 {
-		//		isMenusGet = false
-		//		continue
-		//	}
-		//	//如果相等或者表名在目录中已经设置（主要前一位是/并且他是最后一个字符串）
-		//	if indexKey == fk || (indexCode != -1 && indexKey[indexCode-1] == '/' && indexKey[indexCode:] == fk) {
-		//		isMenusGet = true
-		//		break
-		//	}
-		//}
-
 		//目录没有收录
 		//if !isMenusGet {
 		//if !hasConfigFile {
@@ -410,14 +343,14 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 
 		prefixName = DefaultMenuParentName + ":" + prefixName
 
-		menuIns := Map{"label": that.TableConfig.GetMap(fk).GetString("label"), "table": fk}
+		menuIns := Map{"label": that.TableConfig.GetMap(fk).GetString("label"), "table": fk, "auth": that.TableConfig.GetMap(fk).GetSlice("auth")}
 		//多耗费一点内存
-		mMenu := Map{"menus": Slice{menuIns}, "label": that.TableConfig.GetMap(fk).GetString("label"), "name": prefixName, "icon": "el-icon-setting"}
+		mMenu := Map{"menus": Slice{menuIns}, "auth": Slice{"show"}, "label": that.TableConfig.GetMap(fk).GetString("label"), "name": prefixName, "icon": "Setting"}
 		//表名有前缀
 		if !isNewPrefix {
 			//是否已有对应前缀，已经有对应的menu只需要push进去即可
 			prefixName = DefaultMenuParentName
-			mMenu = Map{"menus": Slice{menuIns}, "label": "系统管理", "name": prefixName, "icon": "el-icon-setting"}
+			mMenu = Map{"menus": Slice{menuIns}, "auth": Slice{"show"}, "label": "系统管理", "name": prefixName, "icon": "Setting"}
 		}
 		//没有新前缀
 		if that.IndexMenus[prefixName] != nil {
@@ -438,103 +371,129 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 			that.IndexMenus[prefixName+"/"+fk] = menuIns
 		}
 		//}
-
+		search := that.TableConfig.GetMap(fk).GetSlice("search")
 		for k, v := range fv {
 
+			//虚招后缀是_id结尾的表字段 假设org_id
+			if !(len(k) <= 3 || strings.LastIndex(k, "_id") != len(k)-3) {
+				//普通表匹配 org_id匹配为org
+				oldTableName := k[:len(k)-3]
+				//上级ID匹配
+				if oldTableName == "parent" {
+					oldTableName = fk
+				}
+				//如果本身匹配则不再继续精简匹配
+				if that.TableConfig[oldTableName] == nil {
+
+					//如果依然找不到则查询system_org是否存在
+					if that.TableConfig[DefaultMenuParentName+"_"+oldTableName] != nil {
+						oldTableName = DefaultMenuParentName + "_" + oldTableName
+					}
+
+					//字段有动词前缀，自动进行解析
+					prefixColumn := strings.Index(oldTableName, "_")
+
+					//sys_org_id oldTableName即为sys此处判断为org表存在
+
+					if prefixColumn > -1 && that.TableConfig[oldTableName[prefixColumn+1:]] != nil {
+						oldTableName = oldTableName[prefixColumn+1:]
+					}
+					if prefixColumn >= len(oldTableName) {
+						prefixColumn = -1
+					}
+					//如果依然找不到则查询system_org是否存在
+					if prefixColumn > -1 && that.TableConfig[DefaultMenuParentName+"_"+oldTableName[prefixColumn+1:]] != nil {
+						oldTableName = DefaultMenuParentName + "_" + oldTableName[prefixColumn+1:]
+					}
+				}
+
+				//普通方式查询不到，则转换为大型项目模块划分,暂时只支持一级模块划分，
+				//比如表sys_user 字段org_id，查询不到sys_org表则查询org表，org表查询不到则查询默认前缀system_org表
+				//都查询不到则找不到，
+				prefix := strings.Index(fk, "_")
+				tableName := oldTableName
+				if prefix > 0 {
+					//表模块前缀sys_user sys即为前缀 sys_org
+					tableName = fk[:prefix+1] + oldTableName
+					if that.TableConfig[tableName] == nil || that.TableConfig[oldTableName] != nil {
+						//不存在则改为org
+						tableName = oldTableName
+					}
+					//表前缀+去除字段前缀
+					prefixColumn := strings.Index(oldTableName, "_")
+					if prefixColumn > -1 {
+						tableName = fk[:prefix+1] + oldTableName[prefixColumn+1:]
+						if that.TableConfig[tableName] == nil {
+							tableName = oldTableName
+						}
+					}
+				}
+
+				//如果数据匹配则写入到配置中
+				if that.TableConfig[tableName] != nil {
+					v["link"] = tableName
+					//一般查询name字段或者label字段，如果没有name字段则默认第二个地段
+					if that.TableColumns[tableName]["name"] != nil {
+						v["value"] = "name"
+						continue
+					}
+					if that.TableColumns[tableName]["label"] != nil {
+						v["value"] = "label"
+						continue
+					}
+					tempC := that.TableConfig.GetMap(tableName).GetSlice("columns")
+					isGet := true
+					for k2, _ := range tempC {
+						if strings.Contains(tempC.GetMap(k2).GetString("name"), "name") || strings.Contains(tempC.GetMap(k2).GetString("name"), "title") {
+							v["value"] = tempC.GetMap(k2).GetString("name")
+							isGet = false
+							break
+						}
+					}
+
+					if isGet && len(that.TableConfig.GetMap(tableName).GetSlice("columns")) > 2 {
+						v["value"] = that.TableConfig.GetMap(tableName).GetSlice("columns").GetMap(1).GetString("name")
+						continue
+					}
+
+				}
+
+			}
+
 			//搜索服务
 			if that.SearchColumns[fk][v.GetString("name")] == nil &&
 				v.GetString("type") == "select" {
-				search := that.TableConfig.GetMap(fk).GetSlice("search")
+				//search := that.TableConfig.GetMap(fk).GetSlice("search")
 				sv := DeepCopyMap(v).(Map)
 				sv["value"] = nil
 				sv["options"] = append(sv.GetSlice("options"), Map{"name": "全部", "value": nil})
-				that.TableConfig.GetMap(fk)["search"] = append(search, sv)
+				search = append(search, sv)
+				that.TableConfig.GetMap(fk)["search"] = search
 				that.SearchColumns[fk][k] = sv
 			}
 
-			//虚招后缀是_id结尾的表字段 假设org_id
+			//搜索关键字
-			if len(k) <= 3 || strings.LastIndex(k, "_id") != len(k)-3 {
+			if strings.Contains(v.GetString("type"), "text") || v.GetString("name") == "id" {
-				continue
+				keyWordSearchData := search.GetMap(0)
+
+				keyWordSearchData["options"] = append(keyWordSearchData.GetSlice("options"), Map{"name": v.GetString("label"), "value": v.GetString("name")})
+				search[0] = keyWordSearchData
 			}
-			//普通表匹配 org_id匹配为org
+			if v.GetString("link") != "" &&
-			oldTableName := k[:len(k)-3]
+				v.GetString("name") != "parent_id" {
-			//上级ID匹配
-			if oldTableName == "parent" {
-				oldTableName = fk
-			}
-			//如果本身匹配则不再继续精简匹配
-			if that.TableConfig[oldTableName] == nil {
 
-				//如果依然找不到则查询system_org是否存在
+				keyWordSearchData := search.GetMap(0)
-				if that.TableConfig[DefaultMenuParentName+"_"+oldTableName] != nil {
+				name := strings.Replace(that.TableConfig.GetMap(v.GetString("link")).GetString("label"), "管理", "", -1)
-					oldTableName = DefaultMenuParentName + "_" + oldTableName
+				keyWordSearchData["options"] = append(keyWordSearchData.GetSlice("options"), Map{"name": name, "value": v.GetString("name")})
-				}
+				search[0] = keyWordSearchData
-
-				//字段有动词前缀，自动进行解析
-				prefixColumn := strings.Index(oldTableName, "_")
-
-				//sys_org_id oldTableName即为sys此处判断为org表存在
-
-				if prefixColumn > -1 && that.TableConfig[oldTableName[prefixColumn+1:]] != nil {
-					oldTableName = oldTableName[prefixColumn+1:]
-				}
-				if prefixColumn >= len(oldTableName) {
-					prefixColumn = -1
-				}
-				//如果依然找不到则查询system_org是否存在
-				if prefixColumn > -1 && that.TableConfig[DefaultMenuParentName+"_"+oldTableName[prefixColumn+1:]] != nil {
-					oldTableName = DefaultMenuParentName + "_" + oldTableName[prefixColumn+1:]
-				}
 			}
 
-			//普通方式查询不到，则转换为大型项目模块划分,暂时只支持一级模块划分，
+			//搜索时间
-			//比如表sys_user 字段org_id，查询不到sys_org表则查询org表，org表查询不到则查询默认前缀system_org表
+			if strings.Contains(v.GetString("type"), "time") {
-			//都查询不到则找不到，
+				daterangeData := search.GetMap(1)
-			prefix := strings.Index(fk, "_")
-			tableName := oldTableName
-			if prefix > 0 {
-				//表模块前缀sys_user sys即为前缀 sys_org
-				tableName = fk[:prefix+1] + oldTableName
-				if that.TableConfig[tableName] == nil || that.TableConfig[oldTableName] != nil {
-					//不存在则改为org
-					tableName = oldTableName
-				}
-				//表前缀+去除字段前缀
-				prefixColumn := strings.Index(oldTableName, "_")
-				if prefixColumn > -1 {
-					tableName = fk[:prefix+1] + oldTableName[prefixColumn+1:]
-					if that.TableConfig[tableName] == nil {
-						tableName = oldTableName
-					}
-				}
-			}
 
-			//如果数据匹配则写入到配置中
+				daterangeData["options"] = append(daterangeData.GetSlice("options"), Map{"name": v.GetString("label"), "value": v.GetString("name")})
-			if that.TableConfig[tableName] != nil {
+				search[1] = daterangeData
-				v["link"] = tableName
-				//一般查询name字段或者label字段，如果没有name字段则默认第二个地段
-				if that.TableColumns[tableName]["name"] != nil {
-					v["value"] = "name"
-					continue
-				}
-				if that.TableColumns[tableName]["label"] != nil {
-					v["value"] = "label"
-					continue
-				}
-				tempC := that.TableConfig.GetMap(tableName).GetSlice("columns")
-				isGet := true
-				for k2, _ := range tempC {
-					if strings.Contains(tempC.GetMap(k2).GetString("name"), "name") || strings.Contains(tempC.GetMap(k2).GetString("name"), "title") {
-						v["value"] = tempC.GetMap(k2).GetString("name")
-						isGet = false
-						break
-					}
-				}
-
-				if isGet && len(that.TableConfig.GetMap(tableName).GetSlice("columns")) > 2 {
-					v["value"] = that.TableConfig.GetMap(tableName).GetSlice("columns").GetMap(1).GetString("name")
-					continue
-				}
 
 			}
 
@@ -550,9 +509,12 @@ func (that *MakeCode) Db2JSON(db *db.HoTimeDB, config Map) {
 				search := that.TableConfig.GetMap(fk).GetSlice("search")
 				sv := Map{"type": "tree", "label": v["label"], "name": v["name"], "value": v["value"], "link": v["link"]}
 				that.TableConfig.GetMap(fk)["search"] = append(search, sv)
-
 				that.SearchColumns[fk][k] = sv
 			}
+
+			if fk == that.FileConfig.GetString("table") && v["link"] != nil && that.TableColumns[v.GetString("link")]["parent_id"] != nil {
+				that.Config["stop"] = append(that.Config.GetSlice("stop"), v.GetString("link"))
+			}
 		}
 	}
 
@@ -763,15 +725,18 @@ func (that *MakeCode) Edit(table string, req *http.Request) Map {
 	for _, v := range that.TableColumns[table] {
 		//不可使用，未在前端展示，但在内存中保持有
 		if v.GetBool("notUse") {
-			if v.GetString("type") == "index" && that.TableColumns[table]["parent_id"] != nil {
+			//if v.GetString("type") == "index" && that.TableColumns[table]["parent_id"] != nil {
-				data[v.GetString("name")] = ","
+			//	data[v.GetString("name")] = ","
-			}
+			//}
 			continue
 		}
 
 		if v.Get("edit") == nil || v.GetBool("edit") {
+			if len(req.Form[v.GetString("name")]) == 0 {
+				continue
+			}
 			reqValue := req.FormValue(v.GetString("name"))
-			if reqValue == "" || reqValue == "null" {
+			if reqValue == "null" {
 				continue
 			}
 			if v.GetString("type") == "password" {
@@ -799,16 +764,16 @@ func (that *MakeCode) Edit(table string, req *http.Request) Map {
 }
 func (that *MakeCode) Delete(table string, req *http.Request) Map {
 	data := Map{}
-	for _, v := range that.TableColumns[table] {
+	//for _, v := range that.TableColumns[table] {
-		//不可使用，未在前端展示，但在内存中保持有
+	//	//不可使用，未在前端展示，但在内存中保持有
-		if v.GetBool("notUse") {
+	//	if v.GetBool("notUse") {
-			if v.GetString("type") == "index" && that.TableColumns[table]["parent_id"] != nil {
+	//		//if v.GetString("type") == "index" && that.TableColumns[table]["parent_id"] != nil {
-				data[v.GetString("name")] = ","
+	//		//	data[v.GetString("name")] = ","
-			}
+	//		//}
-			continue
+	//		continue
-		}
+	//	}
-
+	//
-	}
+	//}
 	return data
 }
 
@@ -823,6 +788,8 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 	hasUser := false
 
 	keywordStr := req.FormValue("keyword")
+	keywordTableStr := req.FormValue("keywordtable")
+	daterangeTableStr := req.FormValue("daterangetable")
 
 	testQu := []string{}
 	testQuData := that.TableColumns[table]
@@ -831,7 +798,6 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 		testQu = append(testQu, key)
 	}
 	sort.Strings(testQu)
-
 	for _, k := range testQu {
 		v := testQuData[k]
 		//不可使用，未在前端展示，但在内存中保持有
@@ -839,6 +805,7 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 
 			continue
 		}
+
 		if v["list"] != false {
 
 			if v.GetString("link") != "" &&
@@ -871,9 +838,17 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 				}
 
 			} else {
+
 				reStr += table + "." + v.GetString("name") + ","
 			}
 
+			if v["name"] == "parent_id" && v.GetString("link") != "" {
+				leftJoin["[>]"+v.GetString("link")+" selfParent"] =
+					"selfParent.id=" +
+						v.GetString("link") + "." + v.GetString("name")
+				reStr += "selfParent." + v.GetString("value") + " AS " + v.GetString("link") + "_" + v.GetString("name") + "_" + v.GetString("value") + ","
+			}
+
 			//准备加入索引权限
 			if v.GetString("link") != "" &&
 				userData != nil &&
@@ -917,29 +892,44 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 
 			}
 
-			if keywordStr != "" {
+		}
-				if v.GetString("type") == "text" {
-					keyword[table+"."+v.GetString("name")+"[~]"] = keywordStr
 
-				}
+		if strings.Contains(v.GetString("type"), "text") {
-				if v.GetString("name") == "id" {
+			reqValue := req.FormValue(v.GetString("name"))
-					keyword[table+"."+v.GetString("name")] = keywordStr
+			if reqValue != "" {
-				}
+				data[table+"."+v.GetString("name")+"[~]"] = reqValue
-				if v.GetString("link") != "" &&
-					v.GetString("name") != "parent_id" {
-					childs := db.Select(v.GetString("link"), "id", Map{v.GetString("value") + "[~]": keywordStr})
-					childIds := Slice{}
-					for _, cv := range childs {
-						childIds = append(childIds, cv.GetString("id"))
-					}
-					if len(childIds) != 0 {
-						keyword[v.GetString("link")+".id"] = childIds
-					}
-
-				}
 			}
 
 		}
+
+		if v.GetString("type") == "unixtime" {
+
+			if len(req.Form[v.GetString("name")]) == 1 {
+				daterange[table+"."+v.GetString("name")+"[>]"] = req.FormValue("daterange")
+			} else if len(req.Form[v.GetString("name")]) == 2 {
+				daterange[table+"."+v.GetString("name")+"[<>]"] = ObjToSlice(req.Form["daterange"])
+			}
+
+			//fmt.Println(req.Form["daterange"])
+
+		}
+
+		if v.GetString("type") == "time" {
+			//fmt.Println(req.Form["daterange"])
+
+			if len(req.Form[v.GetString("name")]) == 1 {
+				t := time.Unix(ObjToCeilInt64(req.FormValue(v.GetString("name"))), 0).Format("2006-01-02 15:04:05")
+
+				daterange[table+"."+v.GetString("name")+"[>]"] = t
+
+			} else if len(req.Form[v.GetString("name")]) == 2 {
+				t1 := time.Unix(ObjToCeilInt64(req.Form[v.GetString("name")][0]), 0).Format("2006-01-02 15:04:05")
+				t2 := time.Unix(ObjToCeilInt64(req.Form[v.GetString("name")][1]), 0).Format("2006-01-02 15:04:05")
+				daterange[table+"."+v.GetString("name")+"[<>]"] = Slice{t1, t2}
+			}
+
+		}
+
 	}
 	if len(reStr) != 0 {
 		reStr = reStr[:len(reStr)-1]
@@ -949,48 +939,57 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 	for k, _ := range search {
 		searchItem := search.GetMap(k)
 		searchItemName := searchItem.GetString("name")
+		if data[table+"."+searchItemName] != nil {
+			delete(data, table+"."+searchItemName)
+		}
+		reqValue := req.Form[searchItemName]
 		parent_idsStr := ""
-		parent_ids := that.TableColumns[searchItem.GetString("link")]["parent_ids"]
+		if searchItem.GetString("link") != "" {
-		if parent_ids != nil {
-			parent_idsStr = "parent_ids[~]"
-		}
-		index := that.TableColumns[searchItem.GetString("link")]["index"]
-		if index != nil {
-			parent_idsStr = "index[~]"
-		}
-
-		reqValue := req.Form[search.GetMap(k).GetString("name")]
-
-		//reqValue := req.FormValue(search.GetMap(k).GetString("name"))
-		if len(reqValue) == 0 || reqValue[0] == "" {
-
-			if parent_idsStr != "" && userData[searchItem.GetString("name")] != nil {
-				where := Map{parent_idsStr: "," + ObjToStr(userData.GetCeilInt64(searchItem.GetString("name"))) + ","}
-				r := db.Select(searchItem.GetString("link"), "id", where)
-				reqValue = []string{}
-				for _, v := range r {
-					reqValue = append(reqValue, v.GetString("id"))
-				}
-
-				data[table+"."+searchItemName] = reqValue
 
+			parent_ids := that.TableColumns[searchItem.GetString("link")]["parent_ids"]
+			if parent_ids != nil {
+				parent_idsStr = "parent_ids[~]"
+			}
+			index := that.TableColumns[searchItem.GetString("link")]["index"]
+			if index != nil {
+				parent_idsStr = "index[~]"
 			}
 
-			continue
+			//reqValue := req.FormValue(search.GetMap(k).GetString("name"))
-		}
+			if len(reqValue) == 0 || reqValue[0] == "" {
 
+				if parent_idsStr != "" && userData[searchItem.GetString("name")] != nil {
+					where := Map{parent_idsStr: "," + ObjToStr(userData.GetCeilInt64(searchItem.GetString("name"))) + ","}
+					r := db.Select(searchItem.GetString("link"), "id", where)
+					reqValue = []string{}
+					for _, v := range r {
+						reqValue = append(reqValue, v.GetString("id"))
+					}
+
+					data[table+"."+searchItemName] = reqValue
+
+				}
+
+				continue
+			}
+
+		}
 		//columns := that.TableConfig.GetMap(table).GetSlice("columns")
 		if searchItem.GetString("type") == "search" {
 			for _, v := range that.TableColumns[table] {
-				if v["list"] == false {
+				//if v["list"] == false {
-					continue
+				//	continue
-				}
+				//}
 				//日期类型
 				if searchItemName == "daterange" {
+
+					if daterangeTableStr != "" && daterangeTableStr != v.GetString("name") {
+						continue
+					}
 					if v.GetString("type") == "unixtime" {
 						//fmt.Println(req.Form["daterange"])
-						if len(req.Form["daterange"]) == 1 {
+						if len(req.Form["daterange"]) == 1 && req.Form["daterange"][0] != "" {
-							daterange[table+"."+v.GetString("name")+"[<]"] = req.FormValue("daterange")
+							daterange[table+"."+v.GetString("name")+"[>]"] = req.FormValue("daterange")
 						} else if len(req.Form["daterange"]) == 2 {
 
 							daterange[table+"."+v.GetString("name")+"[<>]"] = ObjToSlice(req.Form["daterange"])
@@ -999,10 +998,10 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 					if v.GetString("type") == "time" {
 						//fmt.Println(req.Form["daterange"])
 
-						if len(req.Form["daterange"]) == 1 {
+						if len(req.Form["daterange"]) == 1 && req.Form["daterange"][0] != "" {
 							t := time.Unix(ObjToCeilInt64(req.FormValue("daterange")), 0).Format("2006-01-02 15:04:05")
 
-							daterange[table+"."+v.GetString("name")+"[<]"] = t
+							daterange[table+"."+v.GetString("name")+"[>]"] = t
 
 						} else if len(req.Form["daterange"]) == 2 {
 							t1 := time.Unix(ObjToCeilInt64(req.Form["daterange"][0]), 0).Format("2006-01-02 15:04:05")
@@ -1012,44 +1011,79 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 					}
 
 				}
+
+				if searchItemName == "keyword" && keywordStr != "" {
+
+					if keywordTableStr != "" {
+						if keywordTableStr == v.GetString("name") {
+							keyword[table+"."+keywordTableStr+"[~]"] = keywordStr
+						}
+
+						if keywordTableStr == v.GetString("value") {
+							childs := db.Select(v.GetString("link"), "id", Map{v.GetString("value") + "[~]": keywordStr})
+							childIds := Slice{}
+							for _, cv := range childs {
+								childIds = append(childIds, cv.GetString("id"))
+							}
+							if len(childIds) != 0 {
+								keyword[v.GetString("link")+".id"] = childIds
+							}
+						}
+						continue
+					}
+
+					if strings.Contains(v.GetString("type"), "text") {
+						keyword[table+"."+v.GetString("name")+"[~]"] = keywordStr
+
+					}
+					if v.GetString("name") == "id" {
+						keyword[table+"."+v.GetString("name")] = keywordStr
+					}
+					if v.GetString("link") != "" &&
+						v.GetString("name") != "parent_id" {
+						childs := db.Select(v.GetString("link"), "id", Map{v.GetString("value") + "[~]": keywordStr})
+						childIds := Slice{}
+						for _, cv := range childs {
+							childIds = append(childIds, cv.GetString("id"))
+						}
+						if len(childIds) != 0 {
+							keyword[v.GetString("link")+".id"] = childIds
+						}
+
+					}
+
+				}
 			}
 
-			if searchItem.GetString("name") == "sort" {
+			if len(reqValue) != 0 && searchItem.GetString("name") == "sort" && reqValue[0] != "" {
 				sortMap["ORDER"] = table + "." + reqValue[0]
 			}
 
 			continue
 		}
+
 		//树节点模式搜索
 		if searchItemName == "parent_id" {
-			//if parent_idsStr != "" {
-			//
-			//	where := Map{}
-			//
-			//	for _, v := range reqValue {
-			//		if len(where) == 0 {
-			//			where[parent_idsStr] = "," + v + ","
-			//			continue
-			//		}
-			//		where = Map{"OR": where, parent_idsStr: "," + v + ","}
-			//	}
-			//	//用户
-			//	if userData[searchItem.GetString("name")] != nil {
-			//		where = Map{"AND": Map{parent_idsStr: "," + ObjToStr(userData.GetCeilInt64(searchItem.GetString("name"))) + ",", "OR": where}}
-			//	}
-			//	r := db.Select(searchItem.GetString("link"), "id", where)
-			//	for _, v := range r {
-			//		reqValue = append(reqValue, v.GetString("id"))
-			//	}
-			//
-			//}
-
 			parentID := ObjToInt(req.FormValue("parent_id"))
 			if parentID == 0 {
 				parentID = userData.GetCeilInt(table + "_id")
 				data["OR"] = Map{table + ".id": parentID, table + ".parent_id": nil}
 			} else {
-				data[table+".parent_id"] = reqValue
+
+				if req.FormValue("showself") != "" {
+					where := Map{}
+					for _, v := range reqValue {
+						if len(where) == 0 {
+							where[table+"."+parent_idsStr] = "," + v + ","
+							continue
+						}
+						where = Map{"OR": where, table + "." + parent_idsStr: "," + v + ","}
+					}
+					data["OR"] = Map{"OR": where, table + ".id": reqValue}
+				} else {
+					data[table+".parent_id"] = reqValue
+				}
+
 			}
 			continue
 		}
@@ -1059,28 +1093,43 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 			if parent_idsStr != "" {
 
 				where := Map{}
-
+				if len(reqValue) == 1 {
-				for _, v := range reqValue {
 					if len(where) == 0 {
-						where[parent_idsStr] = "," + v + ","
+						where[table+"."+searchItem.GetString("name")] = reqValue[0]
-						continue
+
+					} else {
+						where = Map{"OR": where, table + "." + searchItem.GetString("name"): reqValue[0]}
+					}
+
+				} else {
+					for _, v := range reqValue {
+						if len(where) == 0 {
+							where[searchItem.GetString("link")+"."+parent_idsStr] = "," + v + ","
+							continue
+						}
+						where = Map{"OR": where, searchItem.GetString("link") + "." + parent_idsStr: "," + v + ","}
 					}
-					where = Map{"OR": where, parent_idsStr: "," + v + ","}
 				}
 				//用户
 				if userData[searchItem.GetString("name")] != nil {
-					where = Map{"AND": Map{parent_idsStr: "," + ObjToStr(userData.GetCeilInt64(searchItem.GetString("name"))) + ",", "OR": where}}
+
-				}
+					where = Map{"AND": Map{searchItem.GetString("link") + "." + parent_idsStr: "," + ObjToStr(userData.GetCeilInt64(searchItem.GetString("name"))) + ",", "OR": where}}
-				r := db.Select(searchItem.GetString("link"), "id", where)
-				for _, v := range r {
-					reqValue = append(reqValue, v.GetString("id"))
 				}
+				data["OR"] = where
+
+				continue
+				//r := db.Select(searchItem.GetString("link"), "id", where)
+				//for _, v := range r {
+				//	reqValue = append(reqValue, v.GetString("id"))
+				//}
 
 			}
-
 		}
 
-		data[table+"."+searchItemName] = reqValue
+		if len(reqValue) != 0 && reqValue[0] != "" {
+			data[table+"."+searchItemName] = reqValue
+		}
+
 	}
 
 	if sortMap["ORDER"] == nil {
@@ -1095,10 +1144,16 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 		}
 	}
 	if len(keyword) > 1 {
-		if data["OR"] != nil {
+
-			data = Map{"AND": data, "OR": keyword}
+		if data["AND"] != nil {
+			and := data.GetMap("AND")
+			for k, v := range keyword {
+				and[k] = v
+			}
+
+			//data = Map{"AND":Map{"OR": keyword} data, }
 		} else {
-			data["OR"] = keyword
+			data["AND"] = keyword
 		}
 
 	}
@@ -1139,7 +1194,3 @@ func (that *MakeCode) Search(table string, userData Map, req *http.Request, db *
 
 	return reStr, leftJoin, where
 }
-
-func setListener() {
-
-}

context.go

@@ -1,11 +1,11 @@
 package hotime
 
 import (
-	. "code.hoteas.com/golang/hotime/cache"
 	. "code.hoteas.com/golang/hotime/common"
 	. "code.hoteas.com/golang/hotime/db"
 	"encoding/json"
 	"net/http"
+	"strings"
 	"time"
 )
 
@@ -19,7 +19,7 @@ type Context struct {
 	Db           *HoTimeDB
 	RespData     Map
 	RespFunc     func()
-	CacheIns
+	//CacheIns
 	SessionIns
 	DataSize   int
 	HandlerStr string //复写请求url
@@ -75,6 +75,16 @@ func (that *Context) View() {
 		if that.Session("user_id").Data != nil {
 			that.Log["user_id"] = that.Session("user_id").ToCeilInt()
 		}
+		ipStr := Substr(that.Req.RemoteAddr, 0, strings.Index(that.Req.RemoteAddr, ":"))
+		//负载均衡优化
+		if ipStr == "127.0.0.1" {
+			if that.Req.Header.Get("X-Forwarded-For") != "" {
+				ipStr = that.Req.Header.Get("X-Forwarded-For")
+			} else if that.Req.Header.Get("X-Real-IP") != "" {
+				ipStr = that.Req.Header.Get("X-Real-IP")
+			}
+		}
+		that.Log["ip"] = ipStr
 		that.Db.Insert("logs", that.Log)
 	}
 

db/hotimedb.go

@@ -34,7 +34,7 @@ type HoTimeDB struct {
 }
 
 type HotimeDBBuilder struct {
-	*HoTimeDB
+	HoTimeDB  *HoTimeDB
 	table     string
 	selects   []interface{}
 	join      Slice
@@ -70,7 +70,21 @@ func (that *HotimeDBBuilder) Select(qu ...interface{}) []Map {
 	return that.HoTimeDB.Select(that.table, that.join, qu, that.where)
 }
 
-func (that *HotimeDBBuilder) Update(data Map) int64 {
+func (that *HotimeDBBuilder) Update(qu ...interface{}) int64 {
+	lth := len(qu)
+	if lth == 0 {
+		return 0
+	}
+	data := Map{}
+	if lth == 1 {
+		data = ObjToMap(qu[0])
+	}
+	if lth > 1 {
+		for k := 1; k < lth; k++ {
+			data[ObjToStr(qu[k-1])] = qu[k]
+			k++
+		}
+	}
 
 	return that.HoTimeDB.Update(that.table, data, that.where)
 }
@@ -101,19 +115,51 @@ func (that *HotimeDBBuilder) FullJoin(table, joinStr string) *HotimeDBBuilder {
 	return that
 }
 
-func (that *HotimeDBBuilder) Join(join Map) *HotimeDBBuilder {
+func (that *HotimeDBBuilder) Join(qu ...interface{}) *HotimeDBBuilder {
+	lth := len(qu)
+	if lth == 0 {
+		return that
+	}
+	data := Map{}
+	if lth == 1 {
+		data = ObjToMap(qu[0])
+	}
+	if lth > 1 {
+		for k := 1; k < lth; k++ {
+			data[ObjToStr(qu[k-1])] = qu[k]
+			k++
+		}
+	}
+
 	if that.join == nil {
 		that.join = Slice{}
 	}
-	if join == nil {
+	if data == nil {
 		return that
 	}
 
-	that.join = append(that.join, join)
+	that.join = append(that.join, data)
 	return that
 }
 
-func (that *HotimeDBBuilder) And(where Map) *HotimeDBBuilder {
+func (that *HotimeDBBuilder) And(qu ...interface{}) *HotimeDBBuilder {
+
+	lth := len(qu)
+	if lth == 0 {
+		return that
+	}
+	var where Map
+	if lth == 1 {
+		where = ObjToMap(qu[0])
+	}
+	if lth > 1 {
+		where = Map{}
+		for k := 1; k < lth; k++ {
+			where[ObjToStr(qu[k-1])] = qu[k]
+			k++
+		}
+	}
+
 	if where == nil {
 		return that
 	}
@@ -129,7 +175,22 @@ func (that *HotimeDBBuilder) And(where Map) *HotimeDBBuilder {
 	return that
 }
 
-func (that *HotimeDBBuilder) Or(where Map) *HotimeDBBuilder {
+func (that *HotimeDBBuilder) Or(qu ...interface{}) *HotimeDBBuilder {
+	lth := len(qu)
+	if lth == 0 {
+		return that
+	}
+	var where Map
+	if lth == 1 {
+		where = ObjToMap(qu[0])
+	}
+	if lth > 1 {
+		where = Map{}
+		for k := 1; k < lth; k++ {
+			where[ObjToStr(qu[k-1])] = qu[k]
+			k++
+		}
+	}
 	if where == nil {
 		return that
 	}
@@ -144,7 +205,24 @@ func (that *HotimeDBBuilder) Or(where Map) *HotimeDBBuilder {
 
 	return that
 }
-func (that *HotimeDBBuilder) Where(where Map) *HotimeDBBuilder {
+func (that *HotimeDBBuilder) Where(qu ...interface{}) *HotimeDBBuilder {
+
+	lth := len(qu)
+	if lth == 0 {
+		return that
+	}
+	var where Map
+	if lth == 1 {
+		where = ObjToMap(qu[0])
+	}
+	if lth > 1 {
+		where = Map{}
+		for k := 1; k < lth; k++ {
+			where[ObjToStr(qu[k-1])] = qu[k]
+			k++
+		}
+	}
+
 	if where == nil {
 		return that
 	}
@@ -193,7 +271,11 @@ func (that *HoTimeDB) GetType() string {
 
 // Action 事务，如果action返回true则执行成功；false则回滚
 func (that *HoTimeDB) Action(action func(db HoTimeDB) (isSuccess bool)) (isSuccess bool) {
-	db := HoTimeDB{DB: that.DB, HoTimeCache: that.HoTimeCache, Prefix: that.Prefix}
+	db := HoTimeDB{that.DB, that.ContextBase, that.DBName,
+		that.HoTimeCache, that.Log, that.Type,
+		that.Prefix, that.LastQuery, that.LastData,
+		that.ConnectFunc, that.LastErr, that.limit, that.Tx,
+		that.SlaveDB, that.Mode}
 	tx, err := db.Begin()
 	if err != nil {
 		that.LastErr.SetError(err)
@@ -236,7 +318,7 @@ func (that *HoTimeDB) InitDb(err ...*Error) *Error {
 		e := that.SlaveDB.Ping()
 		that.LastErr.SetError(e)
 	}
-
+	//that.DB.SetConnMaxLifetime(time.Second)
 	return that.LastErr
 }
 
@@ -456,7 +538,7 @@ func (that *HoTimeDB) md5(query string, args ...interface{}) string {
 
 func (that *HoTimeDB) Query(query string, args ...interface{}) []Map {
 	defer func() {
-		if that.Mode == 2 {
+		if that.Mode != 0 {
 			that.Log.Info("SQL:"+that.LastQuery, " DATA:", that.LastData, " ERROR:", that.LastErr.GetError())
 		}
 	}()
@@ -484,16 +566,18 @@ func (that *HoTimeDB) Query(query string, args ...interface{}) []Map {
 		resl, err = db.Query(query, args...)
 	}
 
+	if err != nil && that.LastErr.GetError() != nil &&
+		that.LastErr.GetError().Error() == err.Error() {
+		return nil
+	}
+
 	that.LastErr.SetError(err)
 	if err != nil {
-		if err = db.Ping(); err != nil {
+
-			that.LastErr.SetError(err)
+		if err = db.Ping(); err == nil {
-			_ = that.InitDb()
-			if that.LastErr.GetError() != nil {
-				return nil
-			}
 			return that.Query(query, args...)
 		}
+		that.LastErr.SetError(err)
 		return nil
 	}
 
@@ -502,7 +586,7 @@ func (that *HoTimeDB) Query(query string, args ...interface{}) []Map {
 
 func (that *HoTimeDB) Exec(query string, args ...interface{}) (sql.Result, *Error) {
 	defer func() {
-		if that.Mode == 2 {
+		if that.Mode != 0 {
 			that.Log.Info("SQL: "+that.LastQuery, " DATA: ", that.LastData, " ERROR: ", that.LastErr.GetError())
 		}
 	}()
@@ -523,19 +607,18 @@ func (that *HoTimeDB) Exec(query string, args ...interface{}) (sql.Result, *Erro
 		resl, e = that.DB.Exec(query, args...)
 	}
 
+	if e != nil && that.LastErr.GetError() != nil &&
+		that.LastErr.GetError().Error() == e.Error() {
+		return resl, that.LastErr
+	}
 	that.LastErr.SetError(e)
-
 	//判断是否连接断开了
 	if e != nil {
 
-		if e = that.DB.Ping(); e != nil {
+		if e = that.DB.Ping(); e == nil {
-			that.LastErr.SetError(e)
-			_ = that.InitDb()
-			if that.LastErr.GetError() != nil {
-				return resl, that.LastErr
-			}
 			return that.Exec(query, args...)
 		}
+		that.LastErr.SetError(e)
 		return resl, that.LastErr
 	}
 
@@ -582,11 +665,13 @@ func (that *HoTimeDB) Select(table string, qu ...interface{}) []Map {
 			data := ObjToSlice(qu[intQs])
 			for i := 0; i < len(data); i++ {
 				k := data.GetString(i)
-				if strings.Contains(k, " AS ") {
+				if strings.Contains(k, " AS ") ||
+					strings.Contains(k, ".") {
 
 					query += " " + k + " "
 
 				} else {
+
 					query += " `" + k + "` "
 				}
 
@@ -618,9 +703,9 @@ func (that *HoTimeDB) Select(table string, qu ...interface{}) []Map {
 		}
 
 		if reflect.ValueOf(qu[0]).Type().String() == "common.Slice" {
-
+			qu0 := ObjToSlice(qu[0])
-			for key, _ := range testQuData {
+			for key, _ := range qu0 {
-				v := testQuData.GetMap(key)
+				v := qu0.GetMap(key)
 				for k1, v1 := range v {
 					testQu = append(testQu, k1)
 					testQuData[k1] = v1
@@ -634,15 +719,42 @@ func (that *HoTimeDB) Select(table string, qu ...interface{}) []Map {
 			v := testQuData[k]
 			switch Substr(k, 0, 3) {
 			case "[>]":
-				query += " LEFT JOIN `" + Substr(k, 3, len(k)-3) + "` ON " + v.(string) + " "
+				func() {
+					table := Substr(k, 3, len(k)-3)
+					if !strings.Contains(table, " ") {
+						table = "`" + table + "`"
+					}
+					query += " LEFT JOIN " + table + " ON " + v.(string) + " "
+				}()
 			case "[<]":
-				query += " RIGHT JOIN `" + Substr(k, 3, len(k)-3) + "` ON " + v.(string) + " "
+				func() {
+					table := Substr(k, 3, len(k)-3)
+					if !strings.Contains(table, " ") {
+						table = "`" + table + "`"
+					}
+					query += " RIGHT JOIN " + table + " ON " + v.(string) + " "
+				}()
+
 			}
 			switch Substr(k, 0, 4) {
 			case "[<>]":
-				query += " FULL JOIN `" + Substr(k, 4, len(k)-4) + "` ON " + v.(string) + " "
+				func() {
+					table := Substr(k, 4, len(k)-4)
+					if !strings.Contains(table, " ") {
+						table = "`" + table + "`"
+					}
+					query += " FULL JOIN " + table + " ON " + v.(string) + " "
+				}()
+
 			case "[><]":
-				query += " INNER JOIN `" + Substr(k, 4, len(k)-4) + "` ON " + v.(string) + " "
+				func() {
+					table := Substr(k, 4, len(k)-4)
+					if !strings.Contains(table, " ") {
+						table = "`" + table + "`"
+					}
+					query += " INNER JOIN " + table + " ON " + v.(string) + " "
+				}()
+
 			}
 		}
 	}

dri/mongodb/mongodb.go

@@ -0,0 +1,119 @@
+package mongodb
+
+import (
+	. "code.hoteas.com/golang/hotime/common"
+	"context"
+	"fmt"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+type mongoDb struct {
+	Client   *mongo.Client
+	Ctx      context.Context
+	DataBase *mongo.Database
+	Connect  *mongo.Collection
+	LastErr  error
+}
+
+func Init(database, url string) (*mongoDb, error) {
+	db := mongoDb{}
+	clientOptions := options.Client().ApplyURI(url)
+
+	db.Ctx = context.TODO()
+	// Connect to MongoDB
+	var err error
+	db.Client, err = mongo.Connect(db.Ctx, clientOptions)
+	if err != nil {
+		return nil, err
+	}
+	// Check the connection
+	err = db.Client.Ping(db.Ctx, nil)
+	if err != nil {
+		return nil, err
+	}
+	fmt.Println("Connected to MongoDB!")
+	//databases, err := db.Client.ListDatabaseNames(db.Ctx, bson.M{})
+	//if err != nil {
+	//	return nil, err
+	//}
+	//fmt.Println(databases)
+	db.DataBase = db.Client.Database(database)
+	return &db, nil
+
+}
+
+func (that *mongoDb) Insert(table string, data interface{}) string {
+	collection := that.DataBase.Collection(table)
+	re, err := collection.InsertOne(that.Ctx, data)
+	if err != nil {
+		that.LastErr = err
+		return ""
+	}
+	return ObjToStr(re.InsertedID)
+}
+
+func (that *mongoDb) InsertMany(table string, data ...interface{}) Slice {
+	collection := that.DataBase.Collection(table)
+	re, err := collection.InsertMany(that.Ctx, data)
+	if err != nil {
+		that.LastErr = err
+		return Slice{}
+	}
+
+	return ObjToSlice(re.InsertedIDs)
+
+}
+
+func (that *mongoDb) Get(table string, where Map) Map {
+	results := []Map{}
+	var cursor *mongo.Cursor
+	var err error
+	collection := that.DataBase.Collection(table)
+	if cursor, err = collection.Find(that.Ctx, where, options.Find().SetSkip(0), options.Find().SetLimit(2)); err != nil {
+		that.LastErr = err
+		return nil
+	}
+	//延迟关闭游标
+	defer func() {
+		if err := cursor.Close(that.Ctx); err != nil {
+			that.LastErr = err
+
+		}
+	}()
+	//这里的结果遍历可以使用另外一种更方便的方式：
+	if err = cursor.All(that.Ctx, &results); err != nil {
+		that.LastErr = err
+		return nil
+	}
+	return results[0]
+}
+
+func (that mongoDb) Select(table string, where Map, page, pageRow int64) []Map {
+	page = (page - 1) * pageRow
+	if page < 0 {
+		page = 0
+	}
+	results := []Map{}
+	var cursor *mongo.Cursor
+	var err error
+	collection := that.DataBase.Collection(table)
+	if cursor, err = collection.Find(that.Ctx, where, options.Find().SetSkip(page), options.Find().SetLimit(pageRow)); err != nil {
+		that.LastErr = err
+		return results
+	}
+	//延迟关闭游标
+	defer func() {
+		if err := cursor.Close(that.Ctx); err != nil {
+			that.LastErr = err
+
+		}
+	}()
+	//这里的结果遍历可以使用另外一种更方便的方式：
+
+	if err = cursor.All(that.Ctx, &results); err != nil {
+		that.LastErr = err
+		return results
+	}
+	return results
+}

example/app/article.go

@@ -1,104 +0,0 @@
-package app
-
-import (
-	. "code.hoteas.com/golang/hotime"
-	. "code.hoteas.com/golang/hotime/common"
-	"time"
-)
-
-var ArticleCtr = Ctr{
-	"info": func(that *Context) {
-		sn := that.Req.FormValue("sn")
-		article := that.Db.Get("article", Map{"[><]ctg_article": "article.id=ctg_article.article_id"}, "article.*,ctg_article.ctg_id AS sctg_id", Map{"ctg_article.sn": sn})
-		if article == nil {
-			that.Display(4, "找不到对应数据")
-			return
-		}
-		ctgId := article.GetCeilInt64("sctg_id")
-		ctg := that.Db.Get("ctg", "*", Map{"id": ctgId})
-		parents := []Map{}
-		parentId := ctg.GetCeilInt64("parent_id")
-		article["tongji"] = that.Db.Select("ctg", "sn,name,img,parent_id", Map{"parent_id": parentId})
-		for true {
-
-			if parentId == 0 {
-				break
-			}
-
-			parent := that.Db.Get("ctg", "sn,name,img,parent_id", Map{"id": parentId})
-			if parent == nil {
-				break
-			}
-
-			parents = append(parents, parent)
-			parentId = parent.GetCeilInt64("parent_id")
-
-		}
-
-		ctg["parents"] = parents
-
-		article["ctg"] = ctg
-		that.Display(0, article)
-	},
-	"list": func(that *Context) {
-		sn := that.Req.FormValue("ctg_sn") //ctgsn
-		page := ObjToInt(that.Req.FormValue("page"))
-		pageSize := ObjToInt(that.Req.FormValue("pageSize"))
-
-		if page == 0 {
-			page = 1
-		}
-		if pageSize == 0 {
-			pageSize = 10
-		}
-
-		keywords := that.Req.FormValue("keywords")
-
-		lunbo := ObjToInt(that.Req.FormValue("lunbo"))
-
-		sort := that.Req.FormValue("sort")
-
-		where := Map{"article.push_time[<]": time.Now().Format("2006-01-02 15:04"), "article.state": 0}
-		if sn != "" {
-			ctg := that.Db.Get("ctg", "id", Map{"sn": sn})
-			if ctg != nil {
-				where["ctg_article.ctg_id"] = ctg.GetCeilInt("id")
-			}
-		}
-
-		startTime := that.Req.FormValue("start_time")   //ctgsn
-		finishTime := that.Req.FormValue("finish_time") //ctgsn
-
-		if lunbo != 0 {
-			where["article.lunbo"] = lunbo
-		}
-
-		if len(startTime) > 5 {
-			where["article.push_time[>=]"] = startTime
-		}
-		if len(finishTime) > 5 {
-			where["article.push_time[<=]"] = finishTime
-		}
-
-		if keywords != "" {
-			where["OR"] = Map{"article.title[~]": keywords, "article.description[~]": keywords, "article.author[~]": keywords, "article.sn[~]": keywords, "article.origin[~]": keywords, "article.url[~]": keywords}
-		}
-
-		if len(where) > 1 {
-			where = Map{"AND": where}
-		}
-
-		if sort == "" {
-			where["ORDER"] = Slice{"article.sort DESC", "article.push_time DESC"}
-		}
-
-		if sort == "time" {
-			where["ORDER"] = "article.push_time DESC"
-		}
-		count := that.Db.Count("article", Map{"[><]ctg_article": "article.id=ctg_article.article_id"}, where)
-		article := that.Db.Page(page, pageSize).PageSelect("article", Map{"[><]ctg_article": "article.id=ctg_article.article_id"}, "ctg_article.sn,article.img,article.title,article.description,article.push_time,article.lunbo,article.author,article.origin,article.url", where)
-
-		that.Display(0, Map{"count": count, "data": article})
-
-	},
-}

example/app/ctg.go

@@ -1,77 +0,0 @@
-package app
-
-import (
-	. "code.hoteas.com/golang/hotime"
-	. "code.hoteas.com/golang/hotime/common"
-)
-
-var CtgCtr = Ctr{
-	"info": func(that *Context) {
-		sn := that.Req.FormValue("sn")
-		ctg := that.Db.Get("ctg", "*", Map{"sn": sn})
-		parents := []Map{}
-		parentId := ctg.GetCeilInt64("parent_id")
-		ctg["tongji"] = that.Db.Select("ctg", "sn,name,img,parent_id", Map{"parent_id": parentId})
-		for true {
-
-			if parentId == 0 {
-				break
-			}
-
-			parent := that.Db.Get("ctg", "sn,name,img,parent_id", Map{"id": parentId})
-			if parent == nil {
-				break
-			}
-
-			parents = append(parents, parent)
-			parentId = parent.GetCeilInt64("parent_id")
-
-		}
-
-		if ctg.GetCeilInt64("article_id") != 0 {
-			ctg["article"] = that.Db.Get("article", "*", Map{"id": ctg.GetCeilInt64("article_id")})
-		}
-
-		ctg["parents"] = parents
-		that.Display(0, ctg)
-	},
-	"list": func(that *Context) {
-		sn := that.Req.FormValue("sn") //ctgsn
-		page := ObjToInt(that.Req.FormValue("page"))
-		pageSize := ObjToInt(that.Req.FormValue("pageSize"))
-
-		if page == 0 {
-			page = 1
-		}
-		if pageSize == 0 {
-			pageSize = 50
-		}
-
-		keywords := that.Req.FormValue("keywords")
-
-		//sort:=that.Req.FormValue("sort")
-
-		where := Map{"state": 0}
-		if sn != "" {
-			ctg := that.Db.Get("ctg", "id", Map{"sn": sn})
-			if ctg != nil {
-				where["parent_id"] = ctg.GetCeilInt("id")
-			}
-		}
-
-		if keywords != "" {
-			where["OR"] = Map{"name[~]": keywords, "url[~]": keywords, "sn[~]": keywords}
-		}
-
-		if len(where) > 1 {
-			where = Map{"AND": where}
-		}
-
-		where["ORDER"] = Slice{"sort DESC", "id DESC"}
-
-		article := that.Db.Page(page, pageSize).PageSelect("ctg", "name,sn,sort,url,img", where)
-
-		that.Display(0, article)
-
-	},
-}

example/app/init.go

@@ -1,127 +0,0 @@
-package app
-
-import (
-	. "code.hoteas.com/golang/hotime"
-	. "code.hoteas.com/golang/hotime/common"
-	"time"
-)
-
-var AppProj = Proj{
-	"article": ArticleCtr,
-	"org":     OrgCtr,
-	"ctg":     CtgCtr,
-	"mail":    MailCtr,
-	"test": {
-		"test": func(that *Context) {
-			//data:=that.Db.Table("admin").Order("id DESC").Select("*")
-			//data1:=that.Db.Table("admin").Where(Map{"name[~]":"m"}).Order("id DESC").Select("*")
-			//
-			//data3:=that.Db.Select("admin","*",Map{"name[~]":"m"})
-			data2 := that.Db.Table("article").Where(Map{"title[~]": "m"}).Order("id DESC").Page(1, 10).Select("*")
-			c := that.Db.Table("article").Where(Map{"title[~]": "m"}).Order("id DESC").Group("title").Select("*")
-			//that.Display(0,Slice{data1,data,data3,data2})
-			that.Display(0, Slice{data2, c})
-		},
-		"res": func(that *Context) {
-			ebw_res := that.Db.Select("ebw_res", "*")
-
-			for _, v := range ebw_res {
-				data := Map{"id": v.GetCeilInt("id"), "name": v.GetString("name"),
-					"parent_id": v.GetCeilInt64("pid"),
-					"sn":        v.GetString("url"), "create_time": time.Now().Format("2006-01-02 15:04"),
-					"modify_time": time.Now().Format("2006-01-02 15:04"), "admin_id": 1}
-				if data.GetCeilInt("parent_id") == 0 {
-					data["parent_id"] = nil
-				}
-				that.Db.Insert("ctg", data)
-			}
-
-			that.Db.Exec("UPDATE ctg SET parent_id =NULL WHERE parent_id=id")
-
-			ss(0, that)
-
-			that.Display(0, len(ebw_res))
-
-		},
-		"news": func(that *Context) {
-			ebw_news := that.Db.Select("ebw_news", "*")
-
-			for _, v := range ebw_news {
-				ctg := that.Db.Get("ctg", "*", Map{"sn": v.GetString("type")})
-				data := Map{"sn": v.GetString("id"), "title": v.GetString("title"),
-					"content": v.GetString("content"), "push_time": v.GetString("timedate"),
-					"author": v.GetString("owner"), "origin": v.GetString("source"), "click_num": v.GetString("readtime"),
-					"sort": v.GetCeilInt("zhiding"), "create_time": time.Now().Format("2006-01-02 15:04"),
-					"modify_time": time.Now().Format("2006-01-02 15:04"), "admin_id": 1}
-				if ctg != nil {
-					data["ctg_id"] = ctg.GetCeilInt("id")
-				}
-				that.Db.Insert("article", data)
-			}
-
-			that.Display(0, len(ebw_news))
-
-		},
-		"res2news": func(that *Context) {
-			ebw_news_addition_res := that.Db.Select("ebw_news_addition_res", "*")
-
-			for _, v := range ebw_news_addition_res {
-				ctg := that.Db.Get("ctg", "*", Map{"sn": v.GetString("fk_res")})
-				article := that.Db.Get("article", "*", Map{"sn": v.GetString("fk_newsid")})
-				data := Map{"sn": Md5(ObjToStr(time.Now().UnixNano()) + ObjToStr(RandX(10000, 100000))),
-					"create_time": time.Now().Format("2006-01-02 15:04"),
-					"modify_time": time.Now().Format("2006-01-02 15:04"), "admin_id": 1}
-				if ctg != nil {
-					data["ctg_id"] = ctg.GetCeilInt("id")
-				}
-				if article != nil {
-					data["article_id"] = article.GetCeilInt("id")
-				}
-				that.Db.Insert("ctg_article", data)
-			}
-
-			that.Display(0, len(ebw_news_addition_res))
-		},
-		//将文章没有关联的ctg_article进行关联
-		"article": func(that *Context) {
-			articles := that.Db.Select("article", "id,ctg_id")
-			for _, v := range articles {
-				ctg_article := that.Db.Get("ctg_article", "id", Map{"article_id": v.GetCeilInt("id")})
-				if ctg_article == nil {
-
-					data := Map{"sn": Md5(ObjToStr(time.Now().UnixNano()) + ObjToStr(RandX(10000, 100000))),
-						"create_time": time.Now().Format("2006-01-02 15:04"),
-						"modify_time": time.Now().Format("2006-01-02 15:04"), "admin_id": 1}
-					if v.GetCeilInt("ctg_id") == 0 || v.GetCeilInt("id") == 0 {
-						continue
-					}
-					data["ctg_id"] = v.GetCeilInt("ctg_id")
-					data["article_id"] = v.GetCeilInt("id")
-					that.Db.Insert("ctg_article", data)
-				}
-
-			}
-			that.Display(0, len(articles))
-
-		},
-	},
-}
-
-func ss(parent_id int, that *Context) {
-	var ctgs []Map
-	ctg := that.Db.Get("ctg", "*", Map{"id": parent_id})
-	if parent_id == 0 {
-		ctgs = that.Db.Select("ctg", "*", Map{"parent_id": nil})
-	} else {
-		ctgs = that.Db.Select("ctg", "*", Map{"parent_id": parent_id})
-	}
-
-	for _, v := range ctgs {
-		if ctg == nil {
-			ctg = Map{"parent_ids": ","}
-		}
-		ids := ctg.GetString("parent_ids") + ObjToStr(v.GetCeilInt("id")) + ","
-		that.Db.Update("ctg", Map{"parent_ids": ids}, Map{"id": v.GetCeilInt("id")})
-		ss(v.GetCeilInt("id"), that)
-	}
-}

example/app/mail.go

@@ -1,96 +0,0 @@
-package app
-
-import (
-	. "code.hoteas.com/golang/hotime"
-	. "code.hoteas.com/golang/hotime/common"
-	"time"
-)
-
-var MailCtr = Ctr{
-	"add": func(that *Context) {
-		title := that.Req.FormValue("title")
-		name := that.Req.FormValue("name")
-		phone := that.Req.FormValue("phone")
-		content := that.Req.FormValue("content")
-
-		tp := ObjToInt(that.Req.FormValue("type"))
-		show := ObjToInt(that.Req.FormValue("show"))
-
-		if len(title) < 5 {
-			that.Display(3, "标题过短")
-			return
-		}
-		if len(name) < 2 {
-			that.Display(3, "姓名错误")
-			return
-		}
-		if len(phone) < 8 {
-			that.Display(3, "联系方式错误")
-			return
-		}
-		if len(content) < 10 {
-			that.Display(3, "内容过短")
-			return
-		}
-
-		data := Map{
-			"sn":   Md5(ObjToStr(time.Now().UnixNano()) + ObjToStr(RandX(10000, 100000))),
-			"name": name, "title": title, "phone": phone, "content": content, "type": tp, "show": show,
-			"modify_time[#]": "NOW()", "create_time[#]": "NOW()",
-		}
-		id := that.Db.Insert("mail", data)
-		if id == 0 {
-			that.Display(4, "创建失败")
-			return
-		}
-
-		that.Display(0, "成功")
-		return
-
-	},
-	"info": func(that *Context) {
-		sn := that.Req.FormValue("sn")
-
-		mail := that.Db.Get("mail", "*", Map{"sn": sn})
-
-		that.Display(0, mail)
-	},
-	"list": func(that *Context) {
-		page := ObjToInt(that.Req.FormValue("page"))
-		pageSize := ObjToInt(that.Req.FormValue("pageSize"))
-
-		if page == 0 {
-			page = 1
-		}
-		if pageSize == 0 {
-			pageSize = 10
-		}
-
-		//keywords:=that.Req.FormValue("keywords")
-
-		//sort:=that.Req.FormValue("sort")
-
-		where := Map{"state": 0, "show": 1}
-
-		//if keywords!=""{
-		//	where["OR"]=Map{"title[~]":keywords,"description[~]":keywords,"author[~]":keywords,"sn[~]":keywords,"origin[~]":keywords,"url[~]":keywords}
-		//}
-
-		if len(where) > 1 {
-			where = Map{"AND": where}
-		}
-
-		//if sort==""{
-		//	where["ORDER"]=Slice{"sort DESC","push_time DESC"}
-		//}
-		//
-		//if sort=="time"{
-		where["ORDER"] = "create_time DESC"
-		//}
-		count := that.Db.Count("mail", where)
-		mail := that.Db.Page(page, pageSize).PageSelect("mail", "*", where)
-
-		that.Display(0, Map{"count": count, "data": mail})
-
-	},
-}

example/app/org.go

@@ -1,60 +0,0 @@
-package app
-
-import (
-	. "code.hoteas.com/golang/hotime"
-	. "code.hoteas.com/golang/hotime/common"
-	"time"
-)
-
-var OrgCtr = Ctr{
-	"info": func(that *Context) {
-		sn := that.Req.FormValue("sn")
-		article := that.Db.Get("article", "*", Map{"sn": sn})
-		that.Display(0, article)
-	},
-	"list": func(that *Context) {
-		sn := that.Req.FormValue("sn") //orgsn
-		page := ObjToInt(that.Req.FormValue("page"))
-		pageSize := ObjToInt(that.Req.FormValue("pageSize"))
-
-		if page == 0 {
-			page = 1
-		}
-		if pageSize == 0 {
-			pageSize = 50
-		}
-
-		keywords := that.Req.FormValue("keywords")
-
-		sort := that.Req.FormValue("sort")
-
-		where := Map{"push_time[<=]": time.Now().Format("2006-01-02 15:04"), "state": 0}
-		if sn != "" {
-			org := that.Db.Get("org", "id", Map{"sn": sn})
-			if org != nil {
-				where["org_id"] = org.GetCeilInt("id")
-			}
-		}
-
-		if keywords != "" {
-			where["OR"] = Map{"title[~]": keywords, "description[~]": keywords, "author[~]": keywords, "sn[~]": keywords, "origin[~]": keywords, "url[~]": keywords}
-		}
-
-		if len(where) > 1 {
-			where = Map{"AND": where}
-		}
-
-		if sort == "" {
-			where["ORDER"] = Slice{"sort DESC", "id DESC"}
-		}
-
-		if sort == "time" {
-			where["ORDER"] = "push_time DESC"
-		}
-
-		article := that.Db.Page(page, pageSize).PageSelect("article", "sn,title,description,push_time,lunbo,author,origin,url", where)
-
-		that.Display(0, article)
-
-	},
-}

example/main.go

@@ -2,7 +2,6 @@ package main
 
 import (
 	. "code.hoteas.com/golang/hotime"
-	"code.hoteas.com/golang/hotime/example/app"
 )
 
 func main() {
@@ -13,6 +12,6 @@ func main() {
 		return isFinished
 	})
 
-	appIns.Run(Router{"app": app.AppProj})
+	appIns.Run(Router{})
 
 }

go.mod

@@ -12,5 +12,6 @@ require (
 	github.com/sirupsen/logrus v1.8.1
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.364
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ocr v1.0.364
+	go.mongodb.org/mongo-driver v1.10.1
 	golang.org/x/net v0.0.0-20220225172249-27dd8689420f
 )

go.sum

@@ -14,10 +14,16 @@ github.com/go-pay/gopay v1.5.78 h1:wIHp8g/jK0ik5bZo2MWt3jAQsktT3nkdXZxlRZvljko=
 github.com/go-pay/gopay v1.5.78/go.mod h1:M6Nlk2VdZHCbWphOw3rtbnz4SiOk6Xvxg6mxwDfg+Ps=
 github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE=
 github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
+github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
+github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/gomodule/redigo v1.8.5 h1:nRAxCa+SVsyjSBrtZmG/cqb6VbTmuRzpg/PoTFlpumc=
 github.com/gomodule/redigo v1.8.5/go.mod h1:P9dn9mFrCBvWhGE1wpxx6fgq7BAeLBk+UUUzlpkBYO0=
+github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542 h1:2VTzZjLZBgl62/EtslCrtky5vbi9dd7HrQPQIx6wqiw=
 github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542/go.mod h1:Ow0tF8D4Kplbc8s8sSb3V2oUCygFHVp8gC3Dn6U4MNI=
+github.com/klauspost/compress v1.13.6 h1:P76CopJELS0TiO2mebmnzgWaajssP/EszplttgQxcgc=
+github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
@@ -25,8 +31,12 @@ github.com/mattn/go-sqlite3 v1.14.12 h1:TJ1bhYJPV44phC+IMu1u2K/i5RriLTPe+yc68XDJ
 github.com/mattn/go-sqlite3 v1.14.12/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
 github.com/mohae/deepcopy v0.0.0-20170929034955-c48cc78d4826 h1:RWengNIwukTxcDr9M+97sNutRR1RKhG96O6jWumTTnw=
 github.com/mohae/deepcopy v0.0.0-20170929034955-c48cc78d4826/go.mod h1:TaXosZuwdSHYgviHp1DAtfrULt5eUgsSMsZf+YrPgl8=
+github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe h1:iruDEfMl2E6fbMZ9s0scYfZQ84/6SPL6zC8ACM2oIL0=
+github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc=
 github.com/nbio/st v0.0.0-20140626010706-e9e8d9816f32/go.mod h1:9wM+0iRr9ahx58uYLpLIr5fm8diHn0JbqRycJi6w0Ms=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/silenceper/wechat/v2 v2.1.2 h1:+QfIMiYfwST2ZloTwmYp0O0p5Y1LYRZxfLWfMuSE30k=
@@ -39,20 +49,36 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.2.3-0.20181224173747-660f15d67dbb/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.364 h1:X1Jws4XqrTH+p7FBQ7BpjW4qFXObKHWm0/XhW/GvqRs=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.364/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ocr v1.0.364 h1:kbor60vo37v7Hu+i17gooox9Rw281fVHNna8zwtDG1w=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ocr v1.0.364/go.mod h1:LeIUBOLhc+Y5YCEpZrULPD9lgoXXV4/EmIcoEvmHz9c=
+github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
+github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
+github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
+github.com/xdg-go/scram v1.1.1 h1:VOMT+81stJgXW3CpHyqHN3AXDYIMsx56mEFrB37Mb/E=
+github.com/xdg-go/scram v1.1.1/go.mod h1:RaEWvsqvNKKvBPvcKeFjrG2cJqOkHTiyTpzz23ni57g=
+github.com/xdg-go/stringprep v1.0.3 h1:kdwGpVNwPFtjs98xCGkHjQtGKh86rDcRZN17QEMCOIs=
+github.com/xdg-go/stringprep v1.0.3/go.mod h1:W3f5j4i+9rC0kuIEJL0ky1VpHXQU3ocBgklLGvcBnW8=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
+go.mongodb.org/mongo-driver v1.10.1 h1:NujsPveKwHaWuKUer/ceo9DzEe7HIj1SlJ6uvXZG0S4=
+go.mongodb.org/mongo-driver v1.10.1/go.mod h1:z4XpeoU6w+9Vht+jAFyLgVrD+jGSQQe0+CBWFHNiHt8=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20210220033148-5ea612d1eb83/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I=
 golang.org/x/crypto v0.0.0-20220331220935-ae2d96664a29 h1:tkVvjkPTB7pnW3jnid7kNyAMPVWllTNOf/qKDze4p9o=
 golang.org/x/crypto v0.0.0-20220331220935-ae2d96664a29/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d h1:sK3txAijHtOK88l68nt020reeT1ZdKLIYetKl95FzVY=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
 golang.org/x/net v0.0.0-20220225172249-27dd8689420f h1:oA4XRj0qtSt8Yo1Zms0CUlsT3KG69V2UGQWPBxujDmc=
 golang.org/x/net v0.0.0-20220225172249-27dd8689420f/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
+golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ=
+golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -66,12 +92,16 @@ golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9sn
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7 h1:olpwvP2KacW1ZWvsR7uQhoyTYvKAupfQrRGBFM352Gk=
 golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/h2non/gock.v1 v1.0.15 h1:SzLqcIlb/fDfg7UvukMpNcWsu7sI5tWwL+KCATZqks0=
 gopkg.in/h2non/gock.v1 v1.0.15/go.mod h1:sX4zAkdYX1TRGJ2JY156cFspQn4yRWn6p9EMdODlynE=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

log/logrus.go

@@ -94,6 +94,9 @@ func findCaller(skip int) string {
 				if file == "code/makecode.go" {
 					file, line = getCaller(skip + i + j)
 				}
+				if strings.Index(file, "common/") == 0 {
+					file, line = getCaller(skip + i + j)
+				}
 				if strings.Contains(file, "application.go") {
 					file, line = getCaller(skip + i + j)
 				}

vendor/modules.txt

@@ -23,13 +23,26 @@ github.com/go-pay/gopay/wechat/v3
 # github.com/go-sql-driver/mysql v1.6.0
 ## explicit
 github.com/go-sql-driver/mysql
+# github.com/golang/snappy v0.0.1
+github.com/golang/snappy
 # github.com/gomodule/redigo v1.8.5
 github.com/gomodule/redigo/redis
+# github.com/klauspost/compress v1.13.6
+github.com/klauspost/compress
+github.com/klauspost/compress/fse
+github.com/klauspost/compress/huff0
+github.com/klauspost/compress/internal/snapref
+github.com/klauspost/compress/zstd
+github.com/klauspost/compress/zstd/internal/xxhash
 # github.com/mattn/go-sqlite3 v1.14.12
 ## explicit
 github.com/mattn/go-sqlite3
 # github.com/mohae/deepcopy v0.0.0-20170929034955-c48cc78d4826
 github.com/mohae/deepcopy
+# github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe
+github.com/montanaflynn/stats
+# github.com/pkg/errors v0.9.1
+github.com/pkg/errors
 # github.com/silenceper/wechat/v2 v2.1.2
 ## explicit
 github.com/silenceper/wechat/v2
@@ -106,13 +119,65 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/regions
 # github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ocr v1.0.364
 ## explicit
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ocr/v20181119
-# golang.org/x/crypto v0.0.0-20220331220935-ae2d96664a29
+# github.com/xdg-go/pbkdf2 v1.0.0
+github.com/xdg-go/pbkdf2
+# github.com/xdg-go/scram v1.1.1
+github.com/xdg-go/scram
+# github.com/xdg-go/stringprep v1.0.3
+github.com/xdg-go/stringprep
+# github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d
+github.com/youmark/pkcs8
+# go.mongodb.org/mongo-driver v1.10.1
+## explicit
+go.mongodb.org/mongo-driver/bson
+go.mongodb.org/mongo-driver/bson/bsoncodec
+go.mongodb.org/mongo-driver/bson/bsonoptions
+go.mongodb.org/mongo-driver/bson/bsonrw
+go.mongodb.org/mongo-driver/bson/bsontype
+go.mongodb.org/mongo-driver/bson/primitive
+go.mongodb.org/mongo-driver/event
+go.mongodb.org/mongo-driver/internal
+go.mongodb.org/mongo-driver/internal/randutil
+go.mongodb.org/mongo-driver/internal/randutil/rand
+go.mongodb.org/mongo-driver/internal/uuid
+go.mongodb.org/mongo-driver/mongo
+go.mongodb.org/mongo-driver/mongo/address
+go.mongodb.org/mongo-driver/mongo/description
+go.mongodb.org/mongo-driver/mongo/options
+go.mongodb.org/mongo-driver/mongo/readconcern
+go.mongodb.org/mongo-driver/mongo/readpref
+go.mongodb.org/mongo-driver/mongo/writeconcern
+go.mongodb.org/mongo-driver/tag
+go.mongodb.org/mongo-driver/version
+go.mongodb.org/mongo-driver/x/bsonx
+go.mongodb.org/mongo-driver/x/bsonx/bsoncore
+go.mongodb.org/mongo-driver/x/mongo/driver
+go.mongodb.org/mongo-driver/x/mongo/driver/auth
+go.mongodb.org/mongo-driver/x/mongo/driver/auth/internal/awsv4
+go.mongodb.org/mongo-driver/x/mongo/driver/auth/internal/gssapi
+go.mongodb.org/mongo-driver/x/mongo/driver/connstring
+go.mongodb.org/mongo-driver/x/mongo/driver/dns
+go.mongodb.org/mongo-driver/x/mongo/driver/mongocrypt
+go.mongodb.org/mongo-driver/x/mongo/driver/mongocrypt/options
+go.mongodb.org/mongo-driver/x/mongo/driver/ocsp
+go.mongodb.org/mongo-driver/x/mongo/driver/operation
+go.mongodb.org/mongo-driver/x/mongo/driver/session
+go.mongodb.org/mongo-driver/x/mongo/driver/topology
+go.mongodb.org/mongo-driver/x/mongo/driver/wiremessage
+# golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d
+golang.org/x/crypto/ocsp
+golang.org/x/crypto/pbkdf2
 golang.org/x/crypto/pkcs12
 golang.org/x/crypto/pkcs12/internal/rc2
 # golang.org/x/net v0.0.0-20220225172249-27dd8689420f
 ## explicit
 golang.org/x/net/websocket
+# golang.org/x/sync v0.0.0-20210220032951-036812b2e83c
+golang.org/x/sync/errgroup
 # golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e
 golang.org/x/sys/internal/unsafeheader
 golang.org/x/sys/unix
 golang.org/x/sys/windows
+# golang.org/x/text v0.3.7
+golang.org/x/text/transform
+golang.org/x/text/unicode/norm