|
|
@@ -2,6 +2,10 @@ package rtx
|
|
|
|
|
|
import (
|
|
|
"fmt"
|
|
|
+ "log"
|
|
|
+
|
|
|
+ "strconv"
|
|
|
+ "strings"
|
|
|
|
|
|
"dashoo.cn/backend/api/business/oilrtx"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplier"
|
|
|
@@ -9,8 +13,6 @@ import (
|
|
|
. "dashoo.cn/backend/api/controllers"
|
|
|
"dashoo.cn/business2/userRole"
|
|
|
"dashoo.cn/utils"
|
|
|
- "strconv"
|
|
|
- "strings"
|
|
|
)
|
|
|
|
|
|
type RtxController struct {
|
|
|
@@ -73,7 +75,8 @@ func (this *RtxController) PtrLogin() {
|
|
|
passWord := this.GetString("password")
|
|
|
fmt.Println(userName + passWord)
|
|
|
resp := rtxSvc.HandlePtrLogin(userName, passWord, BaseUserName)
|
|
|
-
|
|
|
+ log.Println("userName= ", userName)
|
|
|
+ log.Println("passWord= ", passWord)
|
|
|
var datainfo DataInfo
|
|
|
datainfo.Items = resp.Code
|
|
|
this.Data["json"] = &datainfo
|
|
|
@@ -85,8 +88,8 @@ func (this *RtxController) PtrLogin() {
|
|
|
// @Success 200 {object} historicTasks
|
|
|
// @router /syncUser [get]
|
|
|
func (this *RtxController) SyncUserList() {
|
|
|
- var tmpuserlist []oilrtx.Tmp_User
|
|
|
- var baseuser userRole.Base_User
|
|
|
+ var tmpuserlist []oilrtx.Tmp_User
|
|
|
+ var baseuser userRole.Base_User
|
|
|
rtxSvc := supplier.GetOilSupplierService(utils.DBE)
|
|
|
rtxSvc.GetEntitysByWhere("tmp_user", "fullname<>'null'", &tmpuserlist)
|
|
|
pwd, key, _ := utils.TripleDesEncrypt("123456")
|
|
|
@@ -99,13 +102,13 @@ func (this *RtxController) SyncUserList() {
|
|
|
baseuser.Username = tmpuser.Username
|
|
|
baseuser.Userpassword = pwd
|
|
|
baseuser.Publickey = key
|
|
|
- _,err := rtxSvc.InsertEntity(&baseuser)
|
|
|
+ _, err := rtxSvc.InsertEntity(&baseuser)
|
|
|
if err == nil {
|
|
|
counts++
|
|
|
} else {
|
|
|
fails++
|
|
|
}
|
|
|
- fmt.Println(counts,"==",fails)
|
|
|
+ fmt.Println(counts, "==", fails)
|
|
|
}
|
|
|
var datainfo DataInfo
|
|
|
datainfo.StartIndex = counts
|
|
|
@@ -123,12 +126,12 @@ func (this *RtxController) SyncUserDept() {
|
|
|
var tmp_userlist []oilrtx.Tmp_User
|
|
|
var orglist []organize.Base_Organize
|
|
|
svc := supplier.GetOilSupplierService(utils.DBE)
|
|
|
- svc.GetEntitysByWhere("tmp_user", "fullname<>'null'",&tmp_userlist)
|
|
|
- svc.GetEntitysByWhere("Base_Organize", "1=1",&orglist)
|
|
|
- for _, tmp_user := range tmp_userlist{
|
|
|
- for _,org := range orglist {
|
|
|
+ svc.GetEntitysByWhere("tmp_user", "fullname<>'null'", &tmp_userlist)
|
|
|
+ svc.GetEntitysByWhere("Base_Organize", "1=1", &orglist)
|
|
|
+ for _, tmp_user := range tmp_userlist {
|
|
|
+ for _, org := range orglist {
|
|
|
var dept = strings.Replace(org.Description, "/", "\\", -1)
|
|
|
- if tmp_user.Department == dept{
|
|
|
+ if tmp_user.Department == dept {
|
|
|
where := "username='" + tmp_user.Username + "'"
|
|
|
tmp_user1.Deptid = strconv.Itoa(org.Id)
|
|
|
col := []string{"deptid"}
|
|
|
@@ -138,4 +141,4 @@ func (this *RtxController) SyncUserDept() {
|
|
|
}
|
|
|
fmt.Println(tmp_user)
|
|
|
}
|
|
|
-}
|
|
|
+}
|