我的客户列表

src/customerService/customService.go

@@ -223,37 +223,61 @@ func CustomSendMsgService(param *customMsg, sendStatus int, loginUserName string
 	return 0, errors.New("发送消息出错")
 }
 
-func MyCustomerService(state, updateTimeStart, updateTimeEnd, companyName, phone, adminPhone string, offSet, pageSize int) (count int64, data *[]map[string]interface{}) {
-	sql := "SELECT * FROM customer where owner = '" + adminPhone + "' "
-	str := ""
-	sqlc := "SELECT COUNt(id) FROM customer where owner = '" + adminPhone + "' "
+func MyCustomerService(state, updateTimeStart, updateTimeEnd, companyName, phone, adminPhone string, offSet, pageSize int) (count int64, data []map[string]interface{}) {
+	salesperson := util.CusTiDb.FindOne("jy_salesperson_info", map[string]interface{}{"phone": adminPhone}, "seatNumber", "")
+	if salesperson != nil && len(*salesperson) > 0 {
+		code := qutil.ObjToString((*salesperson)["seatNumber"])
+		sql := "SELECT company,id,phone,status999,lastUpdateTime FROM customer where owner = '" + code + "' "
+		str := ""
+		sqlc := "SELECT COUNt(id) FROM customer where owner = '" + code + "' "
 
-	if state != "" {
-		str += " and status999 = " + state
-	}
-	if updateTimeStart != "" {
-		str += " and lastUpdateTime >= " + updateTimeStart
-	}
-	if updateTimeEnd != "" {
-		str += " and lastUpdateTime < " + updateTimeEnd
-	}
-	if companyName != "" {
-		str += " and company = " + companyName
-	}
-	if phone != "" {
-		str += " and phone = " + phone
-	}
-	log.Println(sql, sqlc)
-	if str != "" {
-		sql += str + " order by id desc limit " + fmt.Sprint(offSet) + " " + "," + " " + fmt.Sprint(pageSize)
-		sqlc += str
-	}
-	log.Println("sql:", sql)
-	log.Println("sqlc:", sqlc)
-	count = util.CusTiDb.CountBySql(sqlc)
-	if count > 0 {
-		data = util.CusTiDb.SelectBySql(sql)
+		if state != "" {
+			str += " and status999 = '" + state + "'"
+		}
+		if updateTimeStart != "" {
+			str += " and lastUpdateTime >= '" + updateTimeStart + "'"
+		}
+		if updateTimeEnd != "" {
+			str += " and lastUpdateTime < '" + updateTimeEnd + "'"
+		}
+		if companyName != "" {
+			str += " and company like '%" + companyName + "%'"
+		}
+		if phone != "" {
+			str += " and phone like '%" + phone + "%'"
+		}
+		log.Println(sql, sqlc)
+		if str != "" {
+			sql += str + " order by id desc limit " + fmt.Sprint(offSet) + " " + "," + " " + fmt.Sprint(pageSize)
+			sqlc += str
+		}
+		log.Println("sql:", sql)
+		log.Println("sqlc:", sqlc)
+		count = util.CusTiDb.CountBySql(sqlc)
+		if count > 0 {
+			res := util.CusTiDb.SelectBySql(sql)
+			if res != nil && len(*res) > 0 {
+				for _, v := range *res {
+					userId := qutil.ObjToString(v["id"])
+					//获取用户注册手机号
+					userData, ok := util.MQFW.FindById("user", userId, `"s_phone":1,"s_m_phone":1`)
+					if userData != nil && len(*userData) > 0 && ok {
+						if qutil.ObjToString((*userData)["s_phone"]) != "" {
+							v["registePhone"] = qutil.ObjToString((*userData)["s_phone"])
+						} else {
+							v["registePhone"] = qutil.ObjToString((*userData)["s_m_phone"])
+						}
+					} else {
+						v["registePhone"] = ""
+					}
+					data = append(data, v)
+				}
+			}
+		}
+	} else {
+		log.Println("登陆人员暂无呼叫中心坐席号")
 	}
+
 	return count, data
 }