2023-04-28

Nats/Nats.go

@@ -5,6 +5,7 @@ import (
 	"ERP_user/models/Account"
 	"ERP_user/models/System"
 	"fmt"
+	powerlibs "git.baozhida.cn/ERP_libs/Power"
 	"github.com/nats-io/nats.go"
 	"github.com/vmihailenco/msgpack/v5"
 )
@@ -82,6 +83,24 @@ func NatsInit() {
 		b, _ := msgpack.Marshal(&t_R)
 		_ = Nats.Publish(m.Reply, b)
 	})
+	// 请求-响应 获取所有权限列表
+	_, _ = Nats.Subscribe("ERP_User_Read_Power_List_All", func(m *nats.Msg) {
+
+		type T_R struct {
+			Code  int16               `xml:"Code"`
+			Msg   string              `xml:"Msg"`
+			Count int64               `xml:"Count"`
+			Data  []powerlibs.Power_R `xml:"Data"` // 泛型
+		}
+
+		var t_R T_R
+		t_R.Code = 200
+		t_R.Msg = "ok"
+		t_R.Data, t_R.Count = Account.Read_Power_List("", 0, 9999)
+
+		b, _ := msgpack.Marshal(&t_R)
+		_ = Nats.Publish(m.Reply, b)
+	})
 	// 发布-订阅 模式，异步订阅 系统日志
 	_, _ = Nats.Subscribe("ERP_AddSysLogs", func(m *nats.Msg) {
 		fmt.Printf("ERP_AddSysLogs message: %v\n", string(m.Data))

README.md

@@ -1,22 +1,29 @@
 # ERP_user 用户管理
 
 ### 导入线上库
+
 git config --global url."git@git.baozhida.cn/ERP_libs".insteadOf "http://120.55.48.97:3000/bzd_zeng/ERP_libs"
 
 ### 导入本地库
+
 go mod edit -replace git.baozhida.cn/ERP_libs=/Users/zoie/work/bzd_project/ERP/ERP_libs
 
 ### 添加新系统
- - 在 **app.conf** SYS 配置
- - 向新系统power表中同步用户系统power表，将 **erp_storage** 替换为新系统数据库名称
+
+- 在 **app.conf** SYS 配置
+- 向新系统power表中同步用户系统power表，将 **erp_storage** 替换为新系统数据库名称
+
 ```
 INSERT INTO erp_storage.power(ID,t_id,t_name,t__state,create_time,update_time) 
 SELECT ID,t_id,t_name,t__state,create_time,update_time FROM erp_user.power
 ```
 
 ### 系统列表
-| 系统名称 | 项目名称   | 端口号 |
-| -------- | ---------- | ------ |
-| 用户管理 | ERP_user   | 6700   |
-| 考勤管理 | ERP_ams    | 6701   |
-| 薪资管理 | ERP_salary | 6702   |
+
+| 系统名称 | 项目名称        | 端口号  |
+|------|-------------|------|
+| 用户管理 | ERP_user    | 6700 |
+| 考勤管理 | ERP_ams     | 6701 |
+| 薪资管理 | ERP_salary  | 6702 |
+| 仓库管理 | ERP_storage | 6703 |
+| 项目管理 | ERP_project | 6704 |

conf/app.conf

@@ -30,6 +30,8 @@ Qiniu_Url = "https://erposs.baozhida.cn/"
 FilterExcludeURL = /Login_verification
 FilterOnlyLoginCheckURL = /Menu/List,/User/Info,/User/Post,/Menu/User_List,/User/List,/User/Get,/UpFileToken,/Dept/List,/Post/List,/News/List,/News/See
 
-# Sys = ERP_ACCOUNT|账号管理,ERP_STORAGE|仓库管理,ERP_AMS|考勤管理,ERP_SALARY|薪资管理
+#Sys = ERP_ACCOUNT|账号管理,ERP_AMS|考勤管理,ERP_SALARY|薪资管理,ERP_STORAGE|仓库管理,ERP_PROJECT|项目管理
 Sys = ERP_ACCOUNT|账号管理,ERP_AMS|考勤管理,ERP_SALARY|薪资管理
+# Sys = ERP_ACCOUNT|账号管理,ERP_STORAGE|仓库管理
+
 

controllers/Power.go

@@ -216,47 +216,6 @@ func (c *PowerController) Edit() {
 		return
 	}
 
-	// 向除开用户系统的其他系统修改权限
-	// 查询新系统是否存在与用户系统powerT_id相同的power 存在=>修改 不存在=>添加
-	//for _, prefix := range Account.ERP_Sys_prefix {
-	//	// Nats 发送失败 重试3次
-	//	i := 3
-	//	for {
-	//		power, err = NatsServer.ERP_Read_Power_ByT_id(prefix, T_id)
-	//		if err != nil {
-	//			if err.Error() == orm.ErrNoRows.Error() {
-	//				var_ := powerlibs.Power{
-	//					T_id:   power.T_id,
-	//					T_name: T_name,
-	//				}
-	//				_, err = NatsServer.ERP_Add_Power(prefix, var_)
-	//				if err == nil || i == 0 {
-	//					break
-	//				}
-	//			} else {
-	//				c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
-	//				c.ServeJSON()
-	//				return
-	//			}
-	//		}
-	//		if power.Id > 0 {
-	//			power.T_name = T_name
-	//			_, err = NatsServer.ERP_Update_Power(prefix, power)
-	//			if err == nil || i == 0 {
-	//				break
-	//			}
-	//		}
-	//		i--
-	//	}
-	//
-	//	if err != nil {
-	//		sysName := Account.Get_Sys_Name(prefix)
-	//		c.Data["json"] = lib.JSONS{Code: 202, Msg: sysName + "修改失败!"}
-	//		c.ServeJSON()
-	//		return
-	//	}
-	//}
-
 	for _, prefix := range Account.ERP_Sys_prefix {
 		go func(sys string) {
 			// Nats 发送失败 重试10次

controllers/User.go

@@ -62,9 +62,7 @@ func (c *UserController) List() {
 	T_power := c.GetString("T_power")
 	T_dept, _ := c.GetInt("T_dept")
 	T_dept_leader, _ := c.GetInt("T_dept_leader")
-	if T_dept_leader == 1 {
-		T_dept = c.User.T_dept
-	}
+
 	R_List, R_cnt := Account.Read_User_List(T_name, T_power, T_dept, T_dept_leader, page, page_z)
 
 	var r_jsons lib.R_JSONS
@@ -313,12 +311,12 @@ func (c *UserController) Edit() {
 		cols = append(cols, "T_post")
 	}
 
-	if T_dept_leader_err != nil {
+	if T_dept_leader_err == nil {
 		user.T_dept_leader = T_dept_leader
 		cols = append(cols, "T_dept_leader")
 	}
 
-	if T_sex_err != nil {
+	if T_sex_err == nil {
 		user.T_sex = T_sex
 		cols = append(cols, "T_sex")
 	}
@@ -346,7 +344,7 @@ func (c *UserController) Edit() {
 		user.T_phone = T_phone
 		cols = append(cols, "T_phone")
 	}
-	if T_marry_err != nil {
+	if T_marry_err == nil {
 		user.T_marry = T_marry
 		cols = append(cols, "T_marry")
 	}
@@ -378,7 +376,7 @@ func (c *UserController) Edit() {
 		user.T_contract_end_time = T_contract_end_time
 		cols = append(cols, "T_contract_end_time")
 	}
-	if T_expire_err != nil {
+	if T_expire_err == nil {
 		user.T_expire = T_expire
 		cols = append(cols, "T_expire")
 	}

main.go

@@ -80,15 +80,16 @@ func RecoverPanic(ctx *context.Context, config *beego.Config) {
 		}
 		//显示错误
 		data := map[string]interface{}{
-			"ret":           4000,
-			"AppError":      fmt.Sprintf("%v", err),
-			"RequestMethod": ctx.Input.Method(),
-			"RequestURL":    ctx.Input.URI(),
-			"RemoteAddr":    ctx.Input.IP(),
-			"Stack":         stack,
-			"GoVersion":     runtime.Version(),
-			"Code":          500,
-			"Msg":           "请稍后重试!",
+			"AppError": fmt.Sprintf("%v", err),
+			"Code":     500,
+			"Msg":      "请稍后重试!",
+		}
+		if conf.RunMode == "dev" {
+			data["RequestMethod"] = ctx.Input.Method()
+			data["RequestURL"] = ctx.Input.URI()
+			data["RemoteAddr"] = ctx.Input.IP()
+			data["Stack"] = stack
+			data["GoVersion"] = runtime.Version()
 		}
 		_ = ctx.Output.JSON(data, true, true)
 		//if ctx.Output.Status != 0 {

models/Account/User.go

@@ -39,6 +39,7 @@ type User struct {
 	T_contract_end_time   string `orm:"size(32);null"`       // 劳动合同结束时间
 	T_expire              int    `orm:"size(8);default(0)"`  // 是否到期 0-否 1-是
 	T_remark              string `orm:"size(32);null"`       // 备注
+	T_cold_uuid           string `orm:"size(32);null"`       // 关联冷链uuid
 
 	T_State    int       `orm:"size(200);default(1)"`                                  //  0删除  1 正常
 	CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now 每次 model 保存时都会对时间自动更新
@@ -215,9 +216,10 @@ func Read_User_List(T_name string, T_power string, T_dept, T_dept_leader, page,
 	}
 	if T_dept > 0 {
 		cond1 = cond1.And("T_dept", T_dept)
-		if T_dept_leader > 0 {
-			cond1 = cond1.And("T_dept_leader", 1)
-		}
+	}
+
+	if T_dept_leader > 0 {
+		cond1 = cond1.And("T_dept_leader", 1)
 	}
 
 	// 查询