自动解冻处理

clueSync/autoTask.go

@@ -184,23 +184,7 @@ GROUP BY
 			if trailstatus == "01" {
 				//该线索最近一次分配给该电销人员后存在通话记录
 				uid := gconv.String(v["uid"])
-				phoneData := TiDb.FindOne("dwd_f_userbase_contacts", map[string]interface{}{
-					"baseinfo_id": uid,
-				}, "phone", "")
-				if phoneData == nil || len(*phoneData) == 0 {
-					//数据不对跳过去
-					continue
-				}
-				phone := gconv.String((*phoneData)["phone"])
-				callData := TiDb.FindOne("Call_Accounting.voice_record", map[string]interface{}{
-					"CalledNo": phone,
-				}, "Exten", "createTime")
-				if callData == nil || len(*callData) == 0 {
-					//手机号没有通话记录
-					continue
-				}
-				exten := gconv.String((*callData)["Exten"])
-				if seatNumber != exten {
+				if PhoneState(uid, seatNumber) {
 					continue
 				}
 			}
@@ -243,6 +227,8 @@ GROUP BY
 		//发送信息
 		if fool {
 			AutoReleaseNots()
+		} else {
+			CantBeAssignedNots()
 		}
 	}
 }
@@ -500,3 +486,29 @@ func IsBreak(currentTime time.Time) bool {
 		return isok
 	}
 }
+func PhoneState(uid, seatNumber string) bool {
+	phoneData := TiDb.SelectBySql("select DISTINCT phone from  dwd_f_userbase_contacts  where   baseinfo_id= ?", uid)
+	if phoneData == nil || len(*phoneData) == 0 {
+		//数据不对跳过去
+		return false
+	}
+	aa := false
+	for _, v1 := range *phoneData {
+		phone := gconv.String(v1["phone"])
+		callData := TiDb.FindOne("Call_Accounting.voice_record", map[string]interface{}{
+			"CalledNo": phone,
+		}, "Exten", "createTime")
+		if callData == nil || len(*callData) == 0 {
+			//手机号没有通话记录
+			continue
+		}
+		exten := gconv.String((*callData)["Exten"])
+		if seatNumber != exten {
+			continue
+		} else {
+			aa = true
+			break
+		}
+	}
+	return aa
+}