test

liuxiaolong

2020-08-11 13a31b1caab8ffa0049dc8299cab8b8c4a31b6ed

 service/msgPush.go

@@ -238,9 +238,9 @@
      }
   }
   if len(pushUserM) == 0 {
      return true,nil
      return true,errors.New("len(pushUserM) == 0")
   }
   carPersonM := make(map[string]string)
   carPersonM := make(map[string]string) //以车牌号为key，value是hik的personId
   var csv CarService
   carPersons := csv.GetVehicleListByPerson("")
   if carPersons != nil {
@@ -248,27 +248,32 @@
         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,