|
@@ -11,6 +11,8 @@ import (
|
|
|
"time"
|
|
|
. "util"
|
|
|
|
|
|
+ mgoutil "qfw/mongodb"
|
|
|
+
|
|
|
"github.com/go-xweb/xweb"
|
|
|
"github.com/lauyoume/gopinyin"
|
|
|
"gopkg.in/mgo.v2/bson"
|
|
@@ -107,10 +109,10 @@ func (c *Customer) CustomerEdit() {
|
|
|
defer qu.Catch()
|
|
|
id := c.GetString("id")
|
|
|
query := bson.M{}
|
|
|
- query["_id"] = qu.StringTOBsonId(id)
|
|
|
+ query["_id"] = mgoutil.StringTOBsonId(id)
|
|
|
data, _ := Mgo.FindOneByField("cuser", query, `{}`)
|
|
|
depart, _ := Mgo.Find("cuserdepart", bson.M{"s_userid": id, "b_delete": false}, nil, nil, false, -1, -1)
|
|
|
- (*data)["_id"] = qu.BsonIdToSId((*data)["_id"])
|
|
|
+ (*data)["_id"] = mgoutil.BsonIdToSId((*data)["_id"])
|
|
|
if (*data)["i_state"] == 1 {
|
|
|
tagRule, _ := Mgo.Find("eusertagrule", bson.M{"s_userid": id, "b_delete": false}, nil, nil, false, -1, -1)
|
|
|
c.T["tagrule"] = *tagRule
|
|
@@ -124,10 +126,10 @@ func (c *Customer) CustomerEuser() {
|
|
|
defer qu.Catch()
|
|
|
id := c.GetString("id")
|
|
|
query := bson.M{}
|
|
|
- query["_id"] = qu.StringTOBsonId(id)
|
|
|
+ query["_id"] = mgoutil.StringTOBsonId(id)
|
|
|
data, _ := Mgo.FindOneByField("euser", query, `{}`)
|
|
|
depart, _ := Mgo.Find("euserdepart", bson.M{"s_userid": id, "b_delete": false}, nil, nil, false, -1, -1)
|
|
|
- (*data)["_id"] = qu.BsonIdToSId((*data)["_id"])
|
|
|
+ (*data)["_id"] = mgoutil.BsonIdToSId((*data)["_id"])
|
|
|
if (*data)["i_state"] == 1 {
|
|
|
tagRule, _ := Mgo.Find("eusertagrule", bson.M{"s_userid": id, "b_delete": false}, nil, nil, false, -1, -1)
|
|
|
c.T["tagrule"] = *tagRule
|
|
@@ -173,7 +175,7 @@ func (c *Customer) CustomerSave() {
|
|
|
}
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(id),
|
|
|
}
|
|
|
rep = Mgo.Update("cuser", query, bson.M{"$set": data}, false, false)
|
|
|
}
|
|
@@ -296,7 +298,7 @@ func (c *Customer) CuserToEuser() {
|
|
|
"i_state": 1,
|
|
|
},
|
|
|
}
|
|
|
- b := Mgo.Update("cuser", bson.M{"_id": qu.StringTOBsonId(_id)}, set, false, false)
|
|
|
+ b := Mgo.Update("cuser", bson.M{"_id": mgoutil.StringTOBsonId(_id)}, set, false, false)
|
|
|
if !b {
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": b,
|
|
@@ -304,7 +306,7 @@ func (c *Customer) CuserToEuser() {
|
|
|
return
|
|
|
}
|
|
|
//2、复制信息(部门、规则)
|
|
|
- b = Mgo.Update("euser", bson.M{"_id": qu.StringTOBsonId(_id)}, cuser, true, false)
|
|
|
+ b = Mgo.Update("euser", bson.M{"_id": mgoutil.StringTOBsonId(_id)}, cuser, true, false)
|
|
|
if !b {
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": b,
|
|
@@ -374,14 +376,14 @@ func (c *Customer) SynEuser() {
|
|
|
"i_lastsynctime": nowTime,
|
|
|
},
|
|
|
}
|
|
|
- b := Mgo.Update("cuser", bson.M{"_id": qu.StringTOBsonId(_id)}, set, false, false)
|
|
|
+ b := Mgo.Update("cuser", bson.M{"_id": mgoutil.StringTOBsonId(_id)}, set, false, false)
|
|
|
if !b {
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": b,
|
|
|
})
|
|
|
return
|
|
|
}
|
|
|
- b = Mgo.Update("euser", bson.M{"_id": qu.StringTOBsonId(_id)}, cuser, true, false)
|
|
|
+ b = Mgo.Update("euser", bson.M{"_id": mgoutil.StringTOBsonId(_id)}, cuser, true, false)
|
|
|
if !b {
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": b,
|
|
@@ -552,7 +554,7 @@ func (c *Customer) CuserRuleCreate() {
|
|
|
}
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(id),
|
|
|
}
|
|
|
rep = Mgo.Update("cuserdepartrule", query, bson.M{"$set": data}, false, false)
|
|
|
}
|
|
@@ -584,9 +586,9 @@ func (c *Customer) CuserRuleCreate() {
|
|
|
func (c *Customer) CuserRuleEdit() {
|
|
|
defer qu.Catch()
|
|
|
id := c.GetString("id")
|
|
|
- query := bson.M{"_id": qu.StringTOBsonId(id)}
|
|
|
+ query := bson.M{"_id": mgoutil.StringTOBsonId(id)}
|
|
|
data, _ := Mgo.FindOneByField("cuserdepartrule", query, `{}`)
|
|
|
- (*data)["id"] = qu.BsonIdToSId((*data)["_id"])
|
|
|
+ (*data)["id"] = mgoutil.BsonIdToSId((*data)["_id"])
|
|
|
c.T["cid"] = (*data)["s_userid"]
|
|
|
c.T["ids"] = qu.ObjToString((*data)["s_departid"]) + "," + qu.ObjToString((*data)["s_userid"])
|
|
|
c.T["data"] = *data
|
|
@@ -606,9 +608,9 @@ func (c *Customer) CuserRuleEdit() {
|
|
|
func (c *Customer) EuserRule1() {
|
|
|
defer qu.Catch()
|
|
|
id := c.GetString("id")
|
|
|
- query := bson.M{"_id": qu.StringTOBsonId(id)}
|
|
|
+ query := bson.M{"_id": mgoutil.StringTOBsonId(id)}
|
|
|
data, _ := Mgo.FindOneByField("euserdepartrule", query, `{}`)
|
|
|
- (*data)["id"] = qu.BsonIdToSId((*data)["_id"])
|
|
|
+ (*data)["id"] = mgoutil.BsonIdToSId((*data)["_id"])
|
|
|
c.T["cid"] = (*data)["s_userid"]
|
|
|
c.T["ids"] = qu.ObjToString((*data)["s_departid"]) + "," + qu.ObjToString((*data)["s_userid"])
|
|
|
c.T["data"] = *data
|
|
@@ -694,7 +696,7 @@ func (c *Customer) EuserTagEdit() {
|
|
|
_id = Mgo.Save("eusertagrule", data)
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(_id),
|
|
|
}
|
|
|
rep = Mgo.Update("eusertagrule", query, bson.M{"$set": data}, false, false)
|
|
|
}
|
|
@@ -708,7 +710,7 @@ func (c *Customer) EuserTagEdit() {
|
|
|
rep = AddHistoryLogTag(data, false, _id)
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(_id),
|
|
|
}
|
|
|
reps := Mgo.Update("eusertagrule", query, bson.M{"$set": data}, false, false)
|
|
|
if reps {
|
|
@@ -752,7 +754,7 @@ func (c *Customer) EuserTag() {
|
|
|
_id = Mgo.Save("eusertagrule", data)
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(_id),
|
|
|
}
|
|
|
rep = Mgo.Update("eusertagrule", query, bson.M{"$set": data}, false, false)
|
|
|
}
|
|
@@ -881,13 +883,13 @@ func (c *Customer) CustomerHistory() {
|
|
|
id := c.GetString("id")
|
|
|
user := c.GetSession("user").(map[string]interface{})
|
|
|
query := bson.M{}
|
|
|
- query["_id"] = qu.StringTOBsonId(id)
|
|
|
+ query["_id"] = mgoutil.StringTOBsonId(id)
|
|
|
|
|
|
hid := c.GetString("hid")
|
|
|
history_id := ""
|
|
|
if hid != "" {
|
|
|
history_id = hid
|
|
|
- hData, ok := Mgo.FindOne("historylog", bson.M{"_id": qu.StringTOBsonId(history_id)})
|
|
|
+ hData, ok := Mgo.FindOne("historylog", bson.M{"_id": mgoutil.StringTOBsonId(history_id)})
|
|
|
if ok && hData != nil && len(*hData) > 0 {
|
|
|
c.T["history_rule"] = (*hData)["dep_rules"]
|
|
|
c.T["tagrule"] = (*hData)["tag_rules"]
|
|
@@ -924,7 +926,7 @@ func (c *Customer) CustomerAllRule() {
|
|
|
}
|
|
|
inc_query := bson.M{
|
|
|
"user_id": customerId,
|
|
|
- "_id": qu.StringTOBsonId(history_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(history_id),
|
|
|
}
|
|
|
//获取新增历史规则
|
|
|
inc_rules := []map[string]interface{}{}
|
|
@@ -985,7 +987,7 @@ func (c *Customer) SaveHistoryRule() {
|
|
|
// userid := c.GetString("userid")
|
|
|
if history_id != "" {
|
|
|
user_history, _ := Mgo.FindOne("historylog", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId(history_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(history_id),
|
|
|
})
|
|
|
if *user_history != nil && user_history != nil {
|
|
|
//获取私有标签
|
|
@@ -997,21 +999,21 @@ func (c *Customer) SaveHistoryRule() {
|
|
|
if len(dep_rules) > 0 {
|
|
|
for _, r := range dep_rules {
|
|
|
dep_new_rules = append(dep_new_rules, r)
|
|
|
- ruleMap[qu.BsonIdToSId(r["_id"])] = true
|
|
|
+ ruleMap[mgoutil.BsonIdToSId(r["_id"])] = true
|
|
|
}
|
|
|
}
|
|
|
rules_id_list := strings.Split(rules_id, ",")
|
|
|
for _, rule := range rules_id_list {
|
|
|
if !ruleMap[rule] {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(rule),
|
|
|
+ "_id": mgoutil.StringTOBsonId(rule),
|
|
|
"b_delete": false,
|
|
|
}
|
|
|
res, _ := Mgo.FindOne("euserdepartrule", query)
|
|
|
if res != nil && len(*res) != 0 {
|
|
|
//获取规则所属部门信息
|
|
|
department_info, _ := Mgo.FindOne("euserdepart", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId((*res)["s_departid"].(string)),
|
|
|
+ "_id": mgoutil.StringTOBsonId((*res)["s_departid"].(string)),
|
|
|
"b_delete": false,
|
|
|
})
|
|
|
(*res)["is_new"] = false
|
|
@@ -1028,7 +1030,7 @@ func (c *Customer) SaveHistoryRule() {
|
|
|
},
|
|
|
}
|
|
|
ok := Mgo.Update("historylog", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId(history_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(history_id),
|
|
|
}, set, false, false)
|
|
|
log.Println("ok", ok)
|
|
|
c.ServeJson(map[string]interface{}{
|
|
@@ -1040,14 +1042,14 @@ func (c *Customer) SaveHistoryRule() {
|
|
|
dep_rules := []map[string]interface{}{}
|
|
|
for _, rule := range rules_id_list {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(rule),
|
|
|
+ "_id": mgoutil.StringTOBsonId(rule),
|
|
|
"b_delete": false,
|
|
|
}
|
|
|
res, _ := Mgo.FindOne("euserdepartrule", query)
|
|
|
if res != nil && *res != nil {
|
|
|
//获取规则所属部门信息
|
|
|
department_info, _ := Mgo.FindOne("euserdepart", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId((*res)["s_departid"].(string)),
|
|
|
+ "_id": mgoutil.StringTOBsonId((*res)["s_departid"].(string)),
|
|
|
"b_delete": false,
|
|
|
})
|
|
|
(*res)["is_new"] = false
|
|
@@ -1063,7 +1065,7 @@ func (c *Customer) SaveHistoryRule() {
|
|
|
},
|
|
|
}
|
|
|
isupdata := Mgo.Update("historylog", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId(history_id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(history_id),
|
|
|
}, set, false, false)
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"status": isupdata,
|
|
@@ -1116,7 +1118,7 @@ func (c *Customer) HistoryRuleCreate() {
|
|
|
}
|
|
|
s_id = Mgo.Save("euserdepart", d_data)
|
|
|
} else {
|
|
|
- s_id = qu.BsonIdToSId((*dData)["_id"])
|
|
|
+ s_id = mgoutil.BsonIdToSId((*dData)["_id"])
|
|
|
}
|
|
|
data["s_userid"] = user_id
|
|
|
data["s_departid"] = s_id
|
|
@@ -1135,7 +1137,7 @@ func (c *Customer) HistoryRuleCreate() {
|
|
|
}
|
|
|
} else {
|
|
|
query := bson.M{
|
|
|
- "_id": qu.StringTOBsonId(id),
|
|
|
+ "_id": mgoutil.StringTOBsonId(id),
|
|
|
}
|
|
|
reps := Mgo.Update("euserdepartrule", query, bson.M{"$set": data}, false, false)
|
|
|
if reps {
|
|
@@ -1179,14 +1181,14 @@ func (c *Customer) HistoryTagAssociated() {
|
|
|
|
|
|
if userid != "" {
|
|
|
user_info, _ := Mgo.FindOne("historylog", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId(hid),
|
|
|
+ "_id": mgoutil.StringTOBsonId(hid),
|
|
|
})
|
|
|
if user_info != nil && *user_info != nil {
|
|
|
tagrules := (*user_info)["tag_rules"]
|
|
|
if tagrules != nil {
|
|
|
tagrulesArr := qu.ObjArrToMapArr(tagrules.([]interface{}))
|
|
|
for _, m := range tagrulesArr {
|
|
|
- if rule_id == qu.BsonIdToSId(m["_id"]) {
|
|
|
+ if rule_id == mgoutil.BsonIdToSId(m["_id"]) {
|
|
|
m["o_departruleids"] = tags
|
|
|
}
|
|
|
}
|
|
@@ -1196,7 +1198,7 @@ func (c *Customer) HistoryTagAssociated() {
|
|
|
},
|
|
|
}
|
|
|
is_updata := Mgo.Update("historylog", map[string]interface{}{
|
|
|
- "_id": qu.StringTOBsonId(hid),
|
|
|
+ "_id": mgoutil.StringTOBsonId(hid),
|
|
|
}, set, false, false)
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": is_updata,
|
|
@@ -1212,7 +1214,7 @@ func getTserTag(userid string) *[]map[string]interface{} {
|
|
|
}
|
|
|
|
|
|
func AddHistoryLogDep(ruleData map[string]interface{}, isUpdate bool, id string) bool {
|
|
|
- history_id := qu.StringTOBsonId(ruleData["history_id"].(string))
|
|
|
+ history_id := mgoutil.StringTOBsonId(ruleData["history_id"].(string))
|
|
|
hData, ok := Mgo.FindOne("historylog", bson.M{"_id": history_id})
|
|
|
if ok && hData != nil && *hData != nil && len(*hData) > 0 {
|
|
|
dep_rules := []map[string]interface{}{}
|
|
@@ -1222,7 +1224,7 @@ func AddHistoryLogDep(ruleData map[string]interface{}, isUpdate bool, id string)
|
|
|
ruleData["is_new"] = true
|
|
|
if isUpdate {
|
|
|
for k, v := range dep_rules {
|
|
|
- if qu.BsonIdToSId(v["_id"]) == id {
|
|
|
+ if mgoutil.BsonIdToSId(v["_id"]) == id {
|
|
|
dep_rules[k] = ruleData
|
|
|
}
|
|
|
}
|
|
@@ -1237,7 +1239,7 @@ func AddHistoryLogDep(ruleData map[string]interface{}, isUpdate bool, id string)
|
|
|
}
|
|
|
|
|
|
func AddHistoryLogTag(ruleData map[string]interface{}, isUpdate bool, id string) bool {
|
|
|
- history_id := qu.StringTOBsonId(qu.ObjToString(ruleData["hid"]))
|
|
|
+ history_id := mgoutil.StringTOBsonId(qu.ObjToString(ruleData["hid"]))
|
|
|
hData, ok := Mgo.FindOne("historylog", bson.M{"_id": history_id})
|
|
|
if ok && hData != nil && *hData != nil && len(*hData) > 0 {
|
|
|
tag_rules := []map[string]interface{}{}
|
|
@@ -1247,7 +1249,7 @@ func AddHistoryLogTag(ruleData map[string]interface{}, isUpdate bool, id string)
|
|
|
ruleData["is_new"] = true
|
|
|
if isUpdate {
|
|
|
for k, v := range tag_rules {
|
|
|
- if qu.BsonIdToSId(v["_id"]) == id {
|
|
|
+ if mgoutil.BsonIdToSId(v["_id"]) == id {
|
|
|
tag_rules[k] = ruleData
|
|
|
}
|
|
|
}
|
|
@@ -1267,18 +1269,18 @@ func (c *Customer) HistoryTagDel() {
|
|
|
// userid := c.GetString("userid")
|
|
|
tagid := c.GetString("tagid")
|
|
|
hid := c.GetString("hid")
|
|
|
- user_info, _ := Mgo.FindOne("historylog", bson.M{"_id": qu.StringTOBsonId(hid)})
|
|
|
+ user_info, _ := Mgo.FindOne("historylog", bson.M{"_id": mgoutil.StringTOBsonId(hid)})
|
|
|
if user_info != nil && *user_info != nil {
|
|
|
if (*user_info)["tag_rules"] != nil {
|
|
|
user_tag_rules := qu.ObjArrToMapArr((*user_info)["tag_rules"].([]interface{}))
|
|
|
ruleMap := map[string]bool{tagid: true}
|
|
|
ruleArr := []map[string]interface{}{}
|
|
|
for _, m := range user_tag_rules {
|
|
|
- if !ruleMap[qu.BsonIdToSId(m["_id"])] {
|
|
|
+ if !ruleMap[mgoutil.BsonIdToSId(m["_id"])] {
|
|
|
ruleArr = append(ruleArr, m)
|
|
|
}
|
|
|
}
|
|
|
- is_updata := Mgo.Update("historylog", bson.M{"_id": qu.StringTOBsonId(hid)}, bson.M{"$set": bson.M{"tag_rules": ruleArr}}, false, false)
|
|
|
+ is_updata := Mgo.Update("historylog", bson.M{"_id": mgoutil.StringTOBsonId(hid)}, bson.M{"$set": bson.M{"tag_rules": ruleArr}}, false, false)
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"rep": is_updata,
|
|
|
})
|
|
@@ -1338,7 +1340,7 @@ func (c *Customer) Addhistoryrule() {
|
|
|
"i_updatetime": c.GetString("i_updatetime"),
|
|
|
},
|
|
|
}
|
|
|
- isupdata := Mgo.UpdateById("historylog", qu.StringTOBsonId(his_id), set)
|
|
|
+ isupdata := Mgo.UpdateById("historylog", mgoutil.StringTOBsonId(his_id), set)
|
|
|
if isupdata {
|
|
|
c.ServeJson(map[string]interface{}{
|
|
|
"history_id": his_id,
|