| | |
|---|
| | | "errors" |
|---|
| | | "fmt" |
|---|
| | | "github.com/astaxie/beego" |
|---|
| | | "strings" |
|---|
| | | "sync" |
|---|
| | | "time" |
|---|
| | | ) |
|---|
| | |
|---|
| | | } |
|---|
| | | url := baseUrl+"/push/list/message" |
|---|
| | | intent := "intent:#Intent;action=android.intent.action.oppopush;launchFlags=0x14000000;component=uni.UNIEDF0B5C/io.dcloud.PandoraEntry;S.UP-OL-SU=true;S.title="+title+";S.content="+msg+";S.payload=test;end" |
|---|
| | | androidPush := map[string]map[string]map[string]string { |
|---|
| | | "ups": { |
|---|
| | | "notification": { |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | "big_text": msg, |
|---|
| | | "click_type": "intent", |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | } |
|---|
| | | iosPush := map[string]interface{}{ |
|---|
| | | "type":"notify", |
|---|
| | | "payload": "育英中学停车", |
|---|
| | | "aps":map[string]interface{}{ |
|---|
| | | "alert":map[string]string{ |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | }, |
|---|
| | | "content-available":0, |
|---|
| | | }, |
|---|
| | | } |
|---|
| | | reqBody := map[string]interface{} { |
|---|
| | | "request_id": time.Now().Format("20060102150405") + util.GenValidateCode(6), |
|---|
| | | "settings":map[string]int { |
|---|
| | |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | "push_channel": map[string]map[string]map[string]map[string]string { |
|---|
| | | "android": { |
|---|
| | | "ups": { |
|---|
| | | "notification": { |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | "click_type": "intent", |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | "push_channel": map[string]interface{} { |
|---|
| | | "android": androidPush, |
|---|
| | | "ios":iosPush, |
|---|
| | | }, |
|---|
| | | } |
|---|
| | | header := map[string]string { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //对已注册的用户进行消息推送。调用此接口前需调用创建消息接口设置消息内容 |
|---|
| | | func PushByAlias(title string, msg string) (bool, error) { |
|---|
| | | func PushByAlias(title string, msg string, isTest bool) (bool, error, []string) { |
|---|
| | | if !isPushOpen() { |
|---|
| | | return false,errors.New("推送开关已关闭"),nil |
|---|
| | | } |
|---|
| | | var aliasArr []string |
|---|
| | | |
|---|
| | | pushUserM := make(map[string]string) |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if len(pushUserM) == 0 { |
|---|
| | | return true,errors.New("len(pushUserM) == 0") |
|---|
| | | return false,errors.New("len(pushUserM) == 0"),aliasArr |
|---|
| | | } |
|---|
| | | carPersonM := make(map[string]string) //以车牌号为key，value是hik的personId |
|---|
| | | csv := NewCarService() |
|---|
| | | carPersons := csv.GetVehicleListByPerson("") |
|---|
| | | if carPersons != nil { |
|---|
| | | for _, cp := range carPersons { |
|---|
| | | carPersonM[cp.PlateNo] = cp.PersonId |
|---|
| | | ncPlateNo := preDealPlateNo(cp.PlateNo) //去掉汉字，D和0替换成* |
|---|
| | | if ncPlateNo != "" { |
|---|
| | | carPersonM[ncPlateNo] = cp.PersonId |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | delPersonIdM := make(map[string]string) |
|---|
| | | spaceNos := csv.FindSpaceNo("") |
|---|
| | | for _,sn := range spaceNos { |
|---|
| | | if sn.State == 1 && sn.PlateNo != "" { //已经把车停到停车场的车主，不再推送消息 |
|---|
| | | if pId,ok := carPersonM[sn.PlateNo];ok { |
|---|
| | | delPersonIdM[pId] = pId |
|---|
| | | delete(carPersonM, sn.PlateNo) |
|---|
| | | realPlateNo := preDealPlateNo(sn.PlateNo) |
|---|
| | | if realPlateNo != "" { |
|---|
| | | if pId,ok := carPersonM[realPlateNo];ok { |
|---|
| | | delPersonIdM[pId] = pId |
|---|
| | | delete(carPersonM, realPlateNo) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | fmt.Println("len(carPersonM):", len(carPersonM), "len(pushUserM):", len(pushUserM)) |
|---|
| | | var uc models.UserClient |
|---|
| | | for _,personId := range carPersonM { |
|---|
| | | if phoneNum,ok := pushUserM[personId]; ok { //此人已注册到系统,并且车不在停车库内 |
|---|
| | |
|---|
| | | } |
|---|
| | | lenAS := len(aliasArr) |
|---|
| | | if lenAS == 0 { |
|---|
| | | return true, errors.New("aliasArr is empty") |
|---|
| | | } else { |
|---|
| | | fmt.Println("PushByAlias arr:", aliasArr) |
|---|
| | | return false, errors.New("没有推送目标，aliasArr is empty"),aliasArr |
|---|
| | | } |
|---|
| | | if isTest { |
|---|
| | | //只给内部手机号推 |
|---|
| | | testPhones := beego.AppConfig.String("testPushPhones") |
|---|
| | | if testPhones == "" { |
|---|
| | | return false, errors.New("test push aliasArr is empty"),aliasArr |
|---|
| | | } |
|---|
| | | aliasArr = strings.Split(testPhones, ",") |
|---|
| | | } |
|---|
| | | |
|---|
| | | cResult, taskId, ce := createPushMsg(title, msg) |
|---|
| | | fmt.Println("createPushMsg taskId:", taskId, "cResult:",cResult, "err:", ce) |
|---|
| | | if !cResult { |
|---|
| | | return false, errors.New("创建推送前置消息失败") |
|---|
| | | return false, errors.New("创建推送前置消息失败"),aliasArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | //alias 单次推送长度上限是200 |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if isSuccess { |
|---|
| | | return true, nil |
|---|
| | | return true, nil,aliasArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | return false, errors.New("推送失败") |
|---|
| | | return false, errors.New("推送失败"),aliasArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | //预处理车牌号，去除首个汉字，以及忽略D和0 |
|---|
| | | func preDealPlateNo(pn string) string { |
|---|
| | | if pn != "" { |
|---|
| | | r := []rune(pn) |
|---|
| | | ncStr := string(r[1:]) |
|---|
| | | newPlateNo := strings.ReplaceAll(ncStr, "D", "*") |
|---|
| | | newPlateNo = strings.ReplaceAll(newPlateNo, "0", "*") |
|---|
| | | return newPlateNo |
|---|
| | | } |
|---|
| | | return "" |
|---|
| | | } |
|---|
| | | |
|---|
| | | func doPush(taskId string, aliasArr []string) (bool,error) { |
|---|
| | |
|---|
| | | return false, errors.New("推送失败") |
|---|
| | | } |
|---|
| | | |
|---|
| | | func NightPush(title string, msg string) (bool, error) { |
|---|
| | | func NightPush(title string, msg string) (bool, error, []string, []string) { |
|---|
| | | if !isPushOpen() { |
|---|
| | | return false,errors.New("推送开关已关闭"),nil,nil |
|---|
| | | } |
|---|
| | | var aliasArr []string |
|---|
| | | var carOwners []string |
|---|
| | | |
|---|
| | | pushUserM := make(map[string]string) |
|---|
| | | var userE models.User |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if len(pushUserM) == 0 { |
|---|
| | | return true,nil |
|---|
| | | return false, errors.New("len(pushUserM) == 0"), aliasArr, carOwners |
|---|
| | | } |
|---|
| | | carPersonM := make(map[string]string) |
|---|
| | | csv := NewCarService() |
|---|
| | | carPersons := csv.GetVehicleListByPerson("") |
|---|
| | | if carPersons != nil { |
|---|
| | | for _, cp := range carPersons { |
|---|
| | | carPersonM[cp.PlateNo] = cp.PersonId |
|---|
| | | cnPlateNo := preDealPlateNo(cp.PlateNo) |
|---|
| | | if cnPlateNo != "" { |
|---|
| | | carPersonM[cnPlateNo] = cp.PersonId |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //夜间某些领导的车可以停在车库内 |
|---|
| | | var vipPlateNoArr []string |
|---|
| | | vipArr := strings.Split(beego.AppConfig.String("nightVipPlateNos"), ",") |
|---|
| | | if vipArr != nil && len(vipArr) >0 { |
|---|
| | | for _,po := range vipArr { |
|---|
| | | if po != "" { |
|---|
| | | cnPo := preDealPlateNo(po) |
|---|
| | | if cnPo != "" { |
|---|
| | | vipPlateNoArr = append(vipPlateNoArr, cnPo) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | hikPersonMap := csv.GetHikPersonMap() |
|---|
| | | |
|---|
| | | spaceNos := csv.FindSpaceNo("") |
|---|
| | | var uc models.UserClient |
|---|
| | | for _,sn := range spaceNos { |
|---|
| | | if sn.State == 1 && sn.PlateNo != "" { //已经把车停到停车场的车主，不再推送消息 |
|---|
| | | if personId,ok := carPersonM[sn.PlateNo];ok { |
|---|
| | | if phoneNum,ok := pushUserM[personId]; ok { //此人已注册到系统,并且车不在停车库内 |
|---|
| | | if uc.Exist(phoneNum) { |
|---|
| | | aliasArr = append(aliasArr, phoneNum) |
|---|
| | | if sn.State == 1 { //车尚在停车场的车牌 |
|---|
| | | inCnPlateNo := preDealPlateNo(sn.PlateNo) |
|---|
| | | if inCnPlateNo != "" { |
|---|
| | | if !isVipCar(inCnPlateNo, vipPlateNoArr) { |
|---|
| | | if personId,ok := carPersonM[inCnPlateNo];ok { |
|---|
| | | if phoneNum,ok := pushUserM[personId]; ok { |
|---|
| | | if uc.Exist(phoneNum) { |
|---|
| | | aliasArr = append(aliasArr, phoneNum) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if v,ex := hikPersonMap[personId]; ex { |
|---|
| | | carOwners = append(carOwners, sn.PlateNo+"("+v.PersonName+")") |
|---|
| | | } |
|---|
| | | } else { //找不到车主，即视为临时车，将车牌作为车主姓名推送 |
|---|
| | | if sn.PlateNo == "无车牌" { |
|---|
| | | //无车牌的不推送 |
|---|
| | | //carOwners = append(carOwners, sn.PlateNo) |
|---|
| | | } else { |
|---|
| | | carOwners = append(carOwners, sn.PlateNo+"()") |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | if len(aliasArr) == 0 { |
|---|
| | | fmt.Println("没有推送目标,aliasArr is empty") |
|---|
| | | return true, nil |
|---|
| | | return false, errors.New("没有推送目标,aliasArr is empty"), aliasArr, carOwners |
|---|
| | | } |
|---|
| | | |
|---|
| | | cResult, taskId, ce := createPushMsg(title, msg) |
|---|
| | | if !cResult { |
|---|
| | | fmt.Println("createPushMsg taskId:", taskId, "err:", ce) |
|---|
| | | return false, errors.New("创建推送前置消息失败") |
|---|
| | | return false, errors.New("创建推送前置消息失败"), aliasArr, carOwners |
|---|
| | | } |
|---|
| | | |
|---|
| | | return doPush(taskId, aliasArr) |
|---|
| | | b,e := doPush(taskId, aliasArr) |
|---|
| | | return b,e, aliasArr, carOwners |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | //此方法做测试使用 |
|---|
| | | //获取停留在车库内车主的姓名，找不到姓名返回这牌 |
|---|
| | | func GetLeftCarOwners() []string { |
|---|
| | | var carOwners []string |
|---|
| | | pushUserM := make(map[string]string) |
|---|
| | | var userE models.User |
|---|
| | | allUsers, _ := userE.GetAllUsers() |
|---|
| | | if allUsers != nil { |
|---|
| | | for _,u := range allUsers { |
|---|
| | | pushUserM[u.Id] = u.PhoneNum |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | carPersonM := make(map[string]string) |
|---|
| | | csv := NewCarService() |
|---|
| | | carPersons := csv.GetVehicleListByPerson("") |
|---|
| | | if carPersons != nil { |
|---|
| | | for _, cp := range carPersons { |
|---|
| | | cnPlateNo := preDealPlateNo(cp.PlateNo) |
|---|
| | | if cnPlateNo != "" { |
|---|
| | | carPersonM[cnPlateNo] = cp.PersonId |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //夜间某些领导的车可以停在车库内 |
|---|
| | | var vipPlateNoArr []string |
|---|
| | | vipArr := strings.Split(beego.AppConfig.String("nightVipPlateNos"), ",") |
|---|
| | | if vipArr != nil && len(vipArr) >0 { |
|---|
| | | for _,po := range vipArr { |
|---|
| | | if po != "" { |
|---|
| | | cnPo := preDealPlateNo(po) |
|---|
| | | if cnPo != "" { |
|---|
| | | vipPlateNoArr = append(vipPlateNoArr, cnPo) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | hikPersonMap := csv.GetHikPersonMap() |
|---|
| | | |
|---|
| | | spaceNos := csv.FindSpaceNo("") |
|---|
| | | for _,sn := range spaceNos { |
|---|
| | | if sn.State == 1 { //车尚在停车场的车牌 |
|---|
| | | inCnPlateNo := preDealPlateNo(sn.PlateNo) |
|---|
| | | if inCnPlateNo != "" { |
|---|
| | | if !isVipCar(inCnPlateNo, vipPlateNoArr) { |
|---|
| | | if personId,ok := carPersonM[inCnPlateNo];ok { |
|---|
| | | |
|---|
| | | if v,ex := hikPersonMap[personId]; ex { |
|---|
| | | carOwners = append(carOwners, sn.PlateNo+"("+v.PersonName+")") |
|---|
| | | } |
|---|
| | | } else { //找不到车主，即视为临时车，将车牌作为车主姓名推送 |
|---|
| | | if sn.PlateNo == "无车牌" { |
|---|
| | | carOwners = append(carOwners, sn.PlateNo) |
|---|
| | | } else { |
|---|
| | | carOwners = append(carOwners, sn.PlateNo+"()") |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | return carOwners |
|---|
| | | } |
|---|
| | | |
|---|
| | | //vip车主，不接收请离开的通知，也不通知管理员这个车还在车库内 |
|---|
| | | func isVipCar(targetPlateNo string, vipPlateNoArr []string) bool { |
|---|
| | | b := false |
|---|
| | | if vipPlateNoArr != nil { |
|---|
| | | for _,v := range vipPlateNoArr { |
|---|
| | | if targetPlateNo == v { |
|---|
| | | b = true |
|---|
| | | break |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return b |
|---|
| | | } |
|---|
| | | |
|---|
| | | //如果夜间有给车库内的车主推送“请尽快驶离”的消息，则告知管理员 有哪些车尚停在车库内 |
|---|
| | | func Push2Manager(title string, msg string, isTest bool) (bool, error, []string) { |
|---|
| | | if !isPushOpen() { |
|---|
| | | return false,errors.New("推送开关已关闭"),nil |
|---|
| | | } |
|---|
| | | if len(msg) > 256 { |
|---|
| | | fmt.Println("夜间停留车太多，message:", msg) |
|---|
| | | |
|---|
| | | r := []rune(msg) |
|---|
| | | msg = string(r[:125])+"..." |
|---|
| | | } |
|---|
| | | managers := "" |
|---|
| | | if isTest { |
|---|
| | | managers = beego.AppConfig.String("testPushPhones") |
|---|
| | | } else { |
|---|
| | | managers = beego.AppConfig.String("nightManagerPhones") |
|---|
| | | } |
|---|
| | | if managers == "" { |
|---|
| | | return false, errors.New("夜间推送管理员手机号未配置"), []string{} |
|---|
| | | } |
|---|
| | | managerArr := strings.Split(managers, ",") |
|---|
| | | if len(managerArr) == 0 { |
|---|
| | | fmt.Println("没有推送目标,managerArr is empty") |
|---|
| | | return false, errors.New("管理员手机号未配置"), managerArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | cResult, taskId, ce := createPushMsg(title, msg) |
|---|
| | | if !cResult { |
|---|
| | | fmt.Println("createPushMsg taskId:", taskId, "err:", ce) |
|---|
| | | return false, errors.New("创建推送前置消息失败"), managerArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | b,e := doPush(taskId, managerArr) |
|---|
| | | return b,e, managerArr |
|---|
| | | } |
|---|
| | | |
|---|
| | | func isPushOpen() bool { |
|---|
| | | b, err := beego.AppConfig.Bool("pushOpen") |
|---|
| | | fmt.Println("pushOpen:", b, "err:", err) |
|---|
| | | if err != nil { |
|---|
| | | return false |
|---|
| | | } |
|---|
| | | return b |
|---|
| | | } |
|---|
| | | |
|---|
| | | /* |
|---|
| | | func PushAll(title string, msg string) (bool,error) { |
|---|
| | | appId := beego.AppConfig.String("pushAppId") |
|---|
| | | baseUrl := beego.AppConfig.String("pushBaseUrl") + appId |
|---|
| | |
|---|
| | | } |
|---|
| | | url := baseUrl+"/push/all" |
|---|
| | | intent := "intent:#Intent;action=android.intent.action.oppopush;launchFlags=0x14000000;component=uni.UNIEDF0B5C/io.dcloud.PandoraEntry;S.UP-OL-SU=true;S.title="+title+";S.content="+msg+";S.payload=test;end" |
|---|
| | | androidPush := map[string]map[string]map[string]string { |
|---|
| | | "ups": { |
|---|
| | | "notification": { |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | "click_type": "intent", |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | } |
|---|
| | | iosPush := map[string]interface{}{ |
|---|
| | | "type":"notify", |
|---|
| | | "payload":"育英中学停车", |
|---|
| | | "aps":map[string]interface{}{ |
|---|
| | | "alert":map[string]string{ |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | }, |
|---|
| | | "content-available":0, |
|---|
| | | //"sound":"com.gexin.ios.silence", |
|---|
| | | //"category":"ACTIONABLE", |
|---|
| | | }, |
|---|
| | | "auto_badge":"+1", |
|---|
| | | } |
|---|
| | | reqBody := map[string]interface{} { |
|---|
| | | "request_id": time.Now().Format("20060102150405") + util.GenValidateCode(6), |
|---|
| | | "settings":map[string]int { |
|---|
| | |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | "push_channel": map[string]map[string]map[string]map[string]string { |
|---|
| | | "android": { |
|---|
| | | "ups": { |
|---|
| | | "notification": { |
|---|
| | | "title": title, |
|---|
| | | "body": msg, |
|---|
| | | "click_type": "intent", |
|---|
| | | "intent": intent, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | }, |
|---|
| | | "push_channel": map[string]interface{} { |
|---|
| | | "android": androidPush, |
|---|
| | | "ios": iosPush, |
|---|
| | | }, |
|---|
| | | } |
|---|
| | | header := map[string]string { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | return false, errors.New("推送失败") |
|---|
| | | } |
|---|
| | | }*/ |
|---|
| | | |
|---|
| | | func RefreshToken() (*TokenResult,error) { |
|---|
| | | appId := beego.AppConfig.String("pushAppId") |
|---|
| | |
|---|
| | | return &t, nil |
|---|
| | | } |
|---|
| | | return nil, errors.New("获取unipush平台token失败") |
|---|
| | | } |
|---|
| | | } |
|---|
