|
@@ -8,6 +8,7 @@ package services
|
|
|
|
|
|
import (
|
|
|
"errors"
|
|
|
+ "log"
|
|
|
"net/http"
|
|
|
"net/url"
|
|
|
"strconv"
|
|
@@ -62,10 +63,8 @@ func (s *JlService) ProjectAdd(claimsData *viewmodels.Jl) (map[string]interface{
|
|
|
JlResultProject map[string]interface{}
|
|
|
JlResultAccount map[string]interface{}
|
|
|
accountData *models.CmProjectAccount
|
|
|
- sync int
|
|
|
)
|
|
|
|
|
|
- sync = 0
|
|
|
Jlzf := lib.NewJlzf()
|
|
|
// 1.获得计量 账号和项目 信息
|
|
|
if JlResultProject, JlResultAccount, err = Jlzf.GetProjectAndAccount(claimsData.Code, claimsData.Account); err != nil {
|
|
@@ -117,7 +116,7 @@ func (s *JlService) ProjectAdd(claimsData *viewmodels.Jl) (map[string]interface{
|
|
|
if err = s.dao.AddProjectAndAccount(project, account); err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
- sync = 1
|
|
|
+
|
|
|
} else {
|
|
|
// 1.需要开启互通
|
|
|
project := &models.CmProject{}
|
|
@@ -161,13 +160,21 @@ func (s *JlService) ProjectAdd(claimsData *viewmodels.Jl) (map[string]interface{
|
|
|
return nil, err
|
|
|
}
|
|
|
}
|
|
|
- sync = 1
|
|
|
+
|
|
|
}
|
|
|
} else {
|
|
|
//2-2. 普通账号
|
|
|
return nil, errors.New("只能由 管理员 创建 项目管理项目")
|
|
|
}
|
|
|
- return map[string]interface{}{"sync": sync}, nil
|
|
|
+
|
|
|
+ // 返回一个token 6秒
|
|
|
+ tokenString, _ := utils.CreateJlToken(jwt.MapClaims{
|
|
|
+ "data": map[string]string{"code": claimsData.Code, "account": claimsData.Account},
|
|
|
+ "exp": time.Now().Add(6 * time.Second).Unix(),
|
|
|
+ })
|
|
|
+ log.Println("登陆验证,=", tokenString)
|
|
|
+
|
|
|
+ return map[string]interface{}{"token": tokenString}, nil
|
|
|
}
|
|
|
|
|
|
// 授权登陆
|
|
@@ -265,6 +272,7 @@ func (s *JlService) AuthLogin(claimsData *viewmodels.Jl, writer http.ResponseWri
|
|
|
return &viewAccountData, nil
|
|
|
}
|
|
|
|
|
|
+// 项目存在
|
|
|
func (s *JlService) ProjectExist(projectId int, accountId int) (map[string]interface{}, error) {
|
|
|
exist := 0
|
|
|
projectData := s.dao.Get(projectId)
|
|
@@ -296,3 +304,33 @@ func (s *JlService) ProjectExist(projectId int, accountId int) (map[string]inter
|
|
|
})
|
|
|
return map[string]interface{}{"exist": exist, "token": tokenString}, nil
|
|
|
}
|
|
|
+
|
|
|
+// 项目存在
|
|
|
+func (s *JlService) AccountUpdate(claimsData *viewmodels.Jl) error {
|
|
|
+
|
|
|
+ // 1-1.工程项目是否存在
|
|
|
+ projectInfo := s.dao.GetCode(claimsData.Code)
|
|
|
+ if projectInfo.Id == 0 {
|
|
|
+ return errors.New("项目未找到")
|
|
|
+ }
|
|
|
+
|
|
|
+ newAccountData := s.accountDao.GetAccount(claimsData.NewAccount)
|
|
|
+ if newAccountData.Id != 0 {
|
|
|
+ return errors.New("项目管理 已存在该账号")
|
|
|
+ }
|
|
|
+
|
|
|
+ accountData := s.accountDao.GetAccountByAuth(claimsData.Account)
|
|
|
+ if accountData.Id == 0 {
|
|
|
+ return errors.New("未找到该项目下的 授权账号")
|
|
|
+ }
|
|
|
+
|
|
|
+ account := models.CmProjectAccount{}
|
|
|
+ updateField := []string{"account"}
|
|
|
+
|
|
|
+ account.Id = accountData.Id
|
|
|
+ account.Account = claimsData.NewAccount
|
|
|
+ if err := s.accountDao.Update(&account, updateField); err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ return nil
|
|
|
+}
|