From ade17e76514f9d8219f432ff4f24f64b5873fce3 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期二, 11 八月 2020 15:41:47 +0800
Subject: [PATCH] csv must use NewCarService

---
 service/msgPush.go |   25 +++++++++++++++----------
 1 files changed, 15 insertions(+), 10 deletions(-)

diff --git a/service/msgPush.go b/service/msgPush.go
index f13e9a2..d957beb 100644
--- a/service/msgPush.go
+++ b/service/msgPush.go
@@ -238,37 +238,42 @@
 		}
 	}
 	if len(pushUserM) == 0 {
-		return true,nil
+		return true,errors.New("len(pushUserM) == 0")
 	}
-	carPersonM := make(map[string]string)
-	var csv CarService
+	carPersonM := make(map[string]string) //浠ヨ溅鐗屽彿涓簁ey锛寁alue鏄痟ik鐨刾ersonId
+	csv := NewCarService()
 	carPersons := csv.GetVehicleListByPerson("")
 	if carPersons != nil {
 		for _, cp := range carPersons {
 			carPersonM[cp.PlateNo] = cp.PersonId
 		}
 	}
+	delPersonIdM := make(map[string]string)
 	spaceNos := csv.FindSpaceNo("")
 	for _,sn := range spaceNos {
 		if sn.State == 1 && sn.PlateNo != "" { //宸茬粡鎶婅溅鍋滃埌鍋滆溅鍦虹殑杞︿富锛屼笉鍐嶆帹閫佹秷鎭�
-			if _,ok := carPersonM[sn.PlateNo];ok {
+			if pId,ok := carPersonM[sn.PlateNo];ok {
+				delPersonIdM[pId] = pId
 				delete(carPersonM, sn.PlateNo)
 			}
 		}
 	}
 	for _,personId := range carPersonM {
 		if phoneNum,ok := pushUserM[personId]; ok { //姝や汉宸叉敞鍐屽埌绯荤粺,骞朵笖杞︿笉鍦ㄥ仠杞﹀簱鍐�
-			aliasArr = append(aliasArr, phoneNum)
+			if _,in := delPersonIdM[personId];!in {
+				aliasArr = append(aliasArr, phoneNum)
+			}
 		}
 	}
 	if len(aliasArr) == 0 {
-		fmt.Println("娌℃湁鎺ㄩ�佺洰鏍�,aliasArr is empty")
-		return true, nil
+		return true, errors.New("aliasArr is empty")
+	} else {
+		fmt.Println("PushByAlias arr:", aliasArr)
 	}
 
 	cResult, taskId, ce := createPushMsg(title, msg)
+	fmt.Println("createPushMsg taskId:", taskId, "cResult:",cResult, "err:", ce)
 	if !cResult {
-		fmt.Println("createPushMsg taskId:", taskId, "err:", ce)
 		return false, errors.New("鍒涘缓鎺ㄩ�佸墠缃秷鎭け璐�")
 	}
 
@@ -286,7 +291,7 @@
 			"alias": aliasArr,
 		},
 		"taskid": taskId,
-		"is_async": true,
+		"is_async": false,
 	}
 	header := map[string]string {
 		"token": token,
@@ -335,7 +340,7 @@
 		return true,nil
 	}
 	carPersonM := make(map[string]string)
-	var csv CarService
+	csv := NewCarService()
 	carPersons := csv.GetVehicleListByPerson("")
 	if carPersons != nil {
 		for _, cp := range carPersons {

--
Gitblit v1.8.0