pushpkg/p/public.go

package p

import (
	"encoding/json"
	"fmt"
	"reflect"
	"sort"
	"strconv"
	"strings"
	"time"

	. "app.yhyue.com/moapp/jybase/common"
	util "app.yhyue.com/moapp/jybase/common"
	. "app.yhyue.com/moapp/jybase/date"
	. "app.yhyue.com/moapp/jybase/mongodb"
	. "app.yhyue.com/moapp/jybase/mysql"
	"app.yhyue.com/moapp/jybase/redis"

	"github.com/donnie4w/go-logger/logger"
)

//金额转化   金额：0-万元以下单位为元  ，万元以上至亿元以下单位为万元 ，亿元以上单位为亿元。保留 小数点后 2 位，不进行四舍五入。
func ConversionMoney(i_money interface{}) string {
	m := ""
	if reflect.TypeOf(i_money).Name() == "float64" {
		m = strconv.FormatFloat(Float64All(i_money), 'f', -1, 64)
	} else {
		m = ObjToString(i_money)
	}
	if m == "" {
		return m
	}
	m_arr := strings.Split(m, ".")
	m_1 := m_arr[0]
	len_m1 := len([]rune(m_1))
	if len_m1 >= 9 {
		m = m_1[0:len_m1-8] + "." + m_1[len_m1-8:len_m1-6] + "亿元"
	} else if len_m1 >= 5 {
		m = m_1[0:len_m1-4] + "." + m_1[len_m1-4:len_m1-2] + "万元"
	} else {
		if len(m_arr) == 1 {
			return m + ".00元"
		}
		m_2 := m_arr[1]
		if len([]rune(m_2)) > 1 {
			m_2 = m_2[0:2]
		} else {
			m_2 = m_2[0:1] + "0"
		}
		m = m_1 + "." + m_2 + "元"
	}
	return m
}

//微信模板消息 remark
func WxTplRemark(titles []string, lastTime int64, hasLen int) string {
	tip := ""
	second := time.Now().Unix() - lastTime
	if second > 0 {
		if second < 61 {
			tip = fmt.Sprintf("%d秒前发布的:\n", second)
		} else {
			second = second / 60
			if second < 121 {
				if second < 1 {
					second = 1
				}
				tip = fmt.Sprintf("%d分钟前发布的:\n", second)
			}
		}
	}
	lastTip := ""
	if len(titles) > 1 {
		lastTip = fmt.Sprintf("...(共%d条)", len(titles))
	}
	reLen := 199 - hasLen - len([]rune(tip))
	lastTipLen := len([]rune(lastTip))
	wxTplMsgTitle := ""
	bshow := false
	for n := 1; n < len(titles)+1; n++ {
		curTitle := titles[n-1]
		tmptitle := wxTplMsgTitle + fmt.Sprintf("%d %s\n", n, curTitle)
		ch := reLen - len([]rune(tmptitle))
		if ch < lastTipLen { //加上后大于后辍，则没有完全显示
			if ch == 0 && n == len(titles) {
				wxTplMsgTitle = tmptitle
				bshow = true
			} else {
				ch_1 := reLen - len([]rune(wxTplMsgTitle)) - lastTipLen
				if ch_1 > 8 {
					curLen := len([]rune(curTitle))
					if ch_1 > curLen {
						ch_1 = curLen
					}
					wxTplMsgTitle += fmt.Sprintf("%d %s\n", n, string([]rune(curTitle)[:ch_1-3]))
				}
			}
		} else {
			wxTplMsgTitle = tmptitle
			if n == len(titles) {
				bshow = true
			}
		}
	}
	if bshow {
		lastTip = ""
	}
	return tip + wxTplMsgTitle + lastTip
}

//获取信息行业
func GetSubScopeClass(subscopeclass interface{}) string {
	industry := ""
	if subscopeclass != nil {
		k2sub := strings.Split(ObjToString(subscopeclass), ",")
		if len(k2sub) > 0 {
			industry = k2sub[0]
			if industry != "" {
				ss := strings.Split(industry, "_")
				if len(ss) > 1 {
					industry = ss[0]
				}
			}
		}
	}
	return industry
}

//控制一分钟最大推送数，均匀调度
func LimitMaxOneMinutePush(pushPoll *chan bool, maxOneMinute int) {
	max := int(maxOneMinute / 60)
	*pushPoll = make(chan bool, max)
	go func() {
		for {
			time.Sleep(time.Second)
			for i := 0; i < max; i++ {
				select {
				case *pushPoll <- true:
				default:
					continue
				}
			}
		}
	}()
}

//
func UpdateUserIsPush(Mgo *MongodbSim, userId string, err error) {
	if err == nil {
		return
	}
	if strings.Contains(err.Error(), "[43004]") {
		Mgo.UpdateById("user", userId, map[string]interface{}{
			"$set": map[string]interface{}{
				"i_ispush": 0,
			},
		})
	}
}

//查找我的子账号
func MySonAccounts(Mgo *MongodbSim, coll, userId string, field map[string]interface{}) *[]map[string]interface{} {
	users, _ := Mgo.Find(coll, map[string]interface{}{
		"i_member_sub_status": 1,
		"s_member_mainid":     userId,
		"i_member_status":     map[string]interface{}{"$gt": 0},
	}, nil, field, false, -1, -1)
	if users == nil {
		users = &[]map[string]interface{}{}
	}
	return users
}

//是否购买此服务
func HasService(mysql *Mysql, userId string, params ...int) *MemberService {
	args := []interface{}{}
	ws := []string{}
	for _, v := range params {
		args = append(args, v)
		ws = append(ws, "?")
	}
	args = append(args, args...)
	args = append(args, userId, NowFormat(Date_Full_Layout))
	list := mysql.SelectBySql(`SELECT a.l_starttime,b.id from bigmember_service_user a 
		INNER JOIN bigmember_service b on (((b.id in (`+strings.Join(ws, ",")+`) and a.s_serviceid=b.id) or (b.i_pid in (`+strings.Join(ws, ",")+`) and a.s_serviceid=b.i_pid)) and b.i_status=0 and a.s_userid=? and a.i_status=0 and a.l_endtime>?)`, args...)
	ms := &MemberService{
		Services: map[int]*memberService{},
	}
	if list != nil {
		for _, v := range *list {
			ms.IsBuy = true
			id := util.IntAll(v["id"])
			ms.Services[id] = &memberService{
				Id:        id,
				StartTime: util.ObjToString(v["l_starttime"]),
			}
		}
	}
	return ms
}

//
func GetInfoTitle(info *map[string]interface{}) string {
	title, _ := (*info)["title"].(string)
	jsondata, _ := (*info)["jsondata"].(map[string]interface{})
	if jsondata != nil {
		goods, _ := jsondata["goods"].(string)
		title += goods
	}
	title = strings.ToUpper(title)
	return title
}

//得到用户的关键词
func GetKeySets(a_key interface{}) ([]*KeySet, error) {
	var keySets []*KeySet
	if a_key == nil {
		return keySets, nil
	}
	_bs, err := json.Marshal(a_key)
	if err == nil {
		err = json.Unmarshal(_bs, &keySets)
	}
	return keySets, err
}

//解析用户的订阅词
func GetSubSet(isFreeUser bool, userId string, obj map[string]interface{}) *SubSet {
	mailpush := util.IntAll(obj["i_mailpush"])
	email := strings.TrimSpace(util.ObjToString(obj["s_email"]))
	if mailpush == 1 && !MailReg.MatchString(email) {
		mailpush = -1
	}
	subSet := &SubSet{
		Keys:                  []string{},
		Notkeys:               []string{},
		Key_item:              map[string]string{},
		Key_notkey:            map[string]map[string]bool{},
		Key_area:              map[string]map[string]bool{},
		Key_subtype:           map[string]map[string]bool{},
		OriginalKeys:          []string{},
		Areas:                 []string{},
		Subtypes:              []string{},
		Buyerclasss:           []string{},
		WxPush:                util.IntAllDef(obj["i_wxpush"], 1),
		AppPush:               util.IntAllDef(obj["i_apppush"], 1),
		MailPush:              mailpush,
		Email:                 email,
		MatchWay:              util.IntAllDef(obj["i_matchway"], 1),
		Matchbuyerclass_other: util.IntAllDef(obj["i_matchbuyerclass_other"], 1),
		ProjectMatch:          util.IntAll(obj["i_projectmatch"]),
		RateMode:              util.IntAllDef(obj["i_ratemode"], 2),
		MaxPushSize:           util.IntAll(obj["i_maxpushsize"]),
		MaxMailSize:           util.IntAll(obj["i_maxmailsize"]),
	}
	var keySets []*KeySet
	if isFreeUser {
		var err error
		keySets, err = GetKeySets(obj["a_key"])
		if err != nil {
			logger.Error("获取用户关键词错误！", userId, obj["a_key"], err)
			return subSet
		}
		area := obj["o_area"]
		if ppStatus := util.IntAll(obj["i_ppstatus"]); ppStatus == 1 {
			area = obj["o_area_p"]
		}
		if newFree := util.IntAll(obj["i_newfree"]); newFree == 1 && area != nil {
			subSet.IsUpgrade = true
			subSet.Subtype, _ = obj["a_infotype"].([]interface{})
			subSet.Area, _ = area.(map[string]interface{})
		}
	} else {
		items, _ := obj["a_items"].([]interface{})
		for _, v := range items {
			item, _ := v.(map[string]interface{})
			itemName := strings.TrimSpace(util.ObjToString(item["s_item"]))
			subSet.Items = append(subSet.Items, itemName)
			kss, err := GetKeySets(item["a_key"])
			if err != nil {
				logger.Error("获取用户关键词错误！", userId, item["a_key"], err)
				continue
			}
			for _, vv := range kss {
				if vv == nil {
					continue
				}
				if vv.MatchWay == 1 {
					for _, vvv := range vv.Keys {
						keySets = append(keySets, &KeySet{
							Item:    itemName,
							Keys:    []string{vvv},
							NotKeys: vv.NotKeys,
						})
					}
					for _, vvv := range vv.AppendKeys {
						keySets = append(keySets, &KeySet{
							Item:    itemName,
							Keys:    []string{vvv},
							NotKeys: vv.NotKeys,
						})
					}
				} else {
					vv.Item = itemName
					keySets = append(keySets, vv)
				}
			}
		}
		subSet.Buyerclass, _ = obj["a_buyerclass"].([]interface{})
		subSet.Subtype, _ = obj["a_infotype"].([]interface{})
		subSet.Area, _ = obj["o_area"].(map[string]interface{})
	}
	for _, v := range subSet.Buyerclass {
		s_v, _ := v.(string)
		if s_v == "" {
			continue
		}
		subSet.Buyerclasss = append(subSet.Buyerclasss, s_v)
	}
	for _, v := range subSet.Subtype {
		s_v, _ := v.(string)
		if s_v == "" {
			continue
		}
		subSet.Subtypes = append(subSet.Subtypes, s_v)
	}
	for area, _ := range subSet.Area {
		if area == "" {
			continue
		}
		subSet.Areas = append(subSet.Areas, area)
	}
	////////////////
	for _, vs := range keySets {
		if vs == nil {
			logger.Error(userId, "关键词设置异常")
			continue
		}
		var vs_keys []string
		for _, vs_v := range [][]string{vs.Keys, vs.AppendKeys} {
			for _, vs_vv := range vs_v {
				vs_vv = strings.TrimSpace(vs_vv)
				if vs_vv == "" {
					continue
				}
				vs_keys = append(vs_keys, vs_vv)
			}
		}
		if len(vs_keys) == 0 {
			continue
		}
		key := strings.Join(vs_keys, "+")
		subSet.OriginalKeys = append(subSet.OriginalKeys, key)
		if KeyFilterReg.MatchString(key) {
			continue
		} else if !KeyRetainReg.MatchString(key) {
			continue
		}
		subSet.Keys = append(subSet.Keys, key)
		subSet.Notkeys = append(subSet.Notkeys, vs.NotKeys...)
		//转大写
		upperKey := strings.ToUpper(key)
		subSet.Key_item[upperKey] = vs.Item
		//建立与排除词的对应关系
		for _, notkey := range vs.NotKeys {
			upperNotkey := strings.ToUpper(notkey)
			if subSet.Key_notkey[upperKey] == nil {
				subSet.Key_notkey[upperKey] = map[string]bool{}
			}
			subSet.Key_notkey[upperKey][upperNotkey] = true
		}
		//免费用户需要进行映射
		if isFreeUser {
			//建立与信息范围的对应关系
			for _, area := range vs.Areas {
				if subSet.Key_area[upperKey] == nil {
					subSet.Key_area[upperKey] = map[string]bool{}
				}
				subSet.Key_area[upperKey][area] = true
			}
			//建立与信息类型的对应关系
			for _, subtype := range vs.SubTypes {
				if subSet.Key_subtype[upperKey] == nil {
					subSet.Key_subtype[upperKey] = map[string]bool{}
				}
				subSet.Key_subtype[upperKey][subtype] = true
			}
		}
	}
	return subSet
}

//加载数据到内存中
func LoadBidding(mgo *MongodbSim, dbName, coll string, startTime int64, redisCache bool) (*[]map[string]interface{}, int64) {
	defer util.Catch()
	endTime := time.Now().Unix()
	query := map[string]interface{}{
		"pici": map[string]interface{}{
			"$gte": startTime,
			"$lt":  endTime,
		},
	}
	// query = map[string]interface{}{
	// 	"_id": map[string]interface{}{
	// 		"$in": ToObjectIds([]string{"5b7bd6b9a5cb26b9b7449fd7", "5b7bd6b9a5cb26b9b7449fe4", "626c4b63923488e172579d81", "5b7bd6b9a5cb26b9b7449fde"}),
	// 	},
	// }
	logger.Info("开始加载", coll, "数据", query)
	var res []map[string]interface{}
	sess := mgo.GetMgoConn()
	defer mgo.DestoryMongoConn(sess)
	it := sess.DB(dbName).C(coll).Find(query).Select(map[string]interface{}{
		"title":           1,
		"detail":          1,
		"projectname":     1,
		"projectcode":     1,
		"buyer":           1,
		"buyerperson":     1,
		"buyertel":        1,
		"s_winner":        1,
		"agency":          1,
		"bidopentime":     1,
		"projectscope":    1,
		"publishtime":     1,
		"toptype":         1,
		"subtype":         1,
		"area":            1,
		"s_subscopeclass": 1,
		"city":            1,
		"buyerclass":      1,
		"jsondata":        1,
		"budget":          1,
		"bidamount":       1,
		"isValidFile":     1,
	}).Iter()
	index := 0
	for temp := make(map[string]interface{}); it.Next(&temp); {
		_id := BsonIdToSId(temp["_id"])
		if publishtime := util.Int64All(temp["publishtime"]); startTime-publishtime > 7*86400 {
			logger.Info(_id, "发布时间大于7天，不参与匹配", startTime, publishtime)
			continue
		}
		temp["_id"] = _id
		title, _ := temp["title"].(string)
		title = strings.ReplaceAll(title, "\n", "")
		temp["title"] = title
		if util.ObjToString(temp["area"]) == "A" {
			temp["area"] = "全国"
		}
		temp["attachment_count"] = GetAttachmentCount(temp)
		delete(temp, "projectinfo")
		res = append(res, temp)
		if redisCache {
			//信息缓存3天
			info := map[string]interface{}{}
			for _, v := range SaveBiddingField {
				if v == "_id" || temp[v] == nil {
					continue
				}
				info[v] = temp[v]
			}
			redis.Put(Pushcache_1, "info_"+_id, info, 259200)
		}
		temp = make(map[string]interface{})
		index++
		if index%500 == 0 {
			logger.Info("加载", coll, "数据：", index)
		}
	}
	logger.Info(coll, "数据已经加载结束。。。", index)
	return &res, endTime
}

//
func IsVipUser(vipStatus int) bool {
	if vipStatus == 1 || vipStatus == 2 {
		return true
	}
	return false
}

//
func ToSortList(list interface{}) *SortList {
	sl := make(SortList, 0)
	if list == nil {
		return &sl
	}
	b, err := json.Marshal(list)
	if err != nil {
		return &sl
	}
	err = json.Unmarshal(b, &sl)
	if err != nil {
		return &sl
	}
	sort.Sort(sl)
	return &sl
}

//第一个参数是老数据，第二个参数是新进数据
func MergeSortList(o, n interface{}, maxPushSize int) *SortList {
	of, oo := o.(*SortList)
	if !oo {
		of = ToSortList(o)
	}
	nf, no := n.(*SortList)
	if !no {
		nf = ToSortList(n)
	}
	idMap := map[string]bool{}
	for _, v := range *nf {
		idMap[util.ObjToString((*v.Info)["_id"])] = true
	}
	for _, v := range *of {
		if idMap[util.ObjToString((*v.Info)["_id"])] {
			continue
		}
		*nf = append(*nf, v)
	}
	sort.Sort(nf)
	if len(*nf) > maxPushSize {
		*nf = (*nf)[:maxPushSize]
	}
	return nf
}

//获取招标信息附件数量
func GetAttachmentCount(temp map[string]interface{}) int {
	isValidFile, _ := temp["isValidFile"].(bool)
	if isValidFile {
		return 1
	}
	return 0
}

//获取招标信息附件数量
func GetAttachmentCountById(mgo *MongodbSim, dbName, coll, _id string) int {
	sess := mgo.GetMgoConn()
	defer mgo.DestoryMongoConn(sess)
	temp := map[string]interface{}{}
	sess.DB(dbName).C(coll).Find(map[string]interface{}{
		"_id": StringTOBsonId(_id),
	}).Select(map[string]interface{}{
		"isValidFile": 1,
	}).One(&temp)
	if temp != nil {
		return GetAttachmentCount(temp)
	}
	return -1
}

//
func NewBiddingInfo(info *map[string]interface{}, keys []string) *BiddingInfo {
	bi := &BiddingInfo{}
	bi.Title, _ = (*info)["title"].(string)
	bi.ClearTitle = TitleClearRe.ReplaceAllString(strings.Replace(bi.Title, "\n", "", -1), "$1")
	bi.Area, _ = (*info)["area"].(string)
	bi.AreaTitle = fmt.Sprintf("[%s]%s", bi.Area, bi.ClearTitle)
	bi.Publishtime = util.Int64All((*info)["publishtime"])
	bi.PublishtimeYMD = FormatDateByInt64(&bi.Publishtime, Date_Short_Layout)
	bi.PublishtimeDiff = util.TimeDiff(time.Unix(bi.Publishtime, 0))
	bi.Buyerclass, _ = (*info)["buyerclass"].(string)
	bi.Subscopeclass = GetSubScopeClass((*info)["s_subscopeclass"])
	bi.Bidamount = (*info)["bidamount"]
	bi.Budget = (*info)["budget"]
	if bi.Bidamount != nil {
		bi.Acount = ConversionMoney(bi.Bidamount)
	} else if bi.Budget != nil {
		bi.Acount = ConversionMoney(bi.Budget)
	}
	bi.Id, _ = (*info)["_id"].(string)
	bi.Subtype, _ = (*info)["subtype"].(string)
	bi.Toptype, _ = (*info)["toptype"].(string)
	bi.Infotype = bi.Subtype
	if bi.Infotype == "" {
		bi.Infotype = bi.Toptype
	}
	bi.HighlightTitle = bi.ClearTitle
	for _, kw := range keys {
		kws := strings.Split(kw, "+")
		n := 0
		otitle := bi.HighlightTitle
		for _, kwn := range kws {
			ot := strings.Replace(otitle, kwn, "<span class='keys'>"+kwn+"</span>", 1)
			if ot != bi.HighlightTitle {
				n++
				otitle = ot
			} else {
				break
			}
		}
		if n == len(kws) {
			bi.HighlightTitle = otitle
			break
		}
	}
	return bi
}

//
func SortListSplit(list *SortList, f func(v interface{})) {
	l := len(*list)
	if l == 0 {
		return
	}
	i := Mgo_ListSize
	for {
		if l > i {
			arr := (*list)[i-Mgo_ListSize : i]
			f(&arr)
		} else if l > i-Mgo_ListSize {
			arr := (*list)[i-Mgo_ListSize:]
			f(&arr)
			break
		}
		i += Mgo_ListSize
	}
}

//获取企业授权超级订阅/大会员的用户
func LoadEntProductUsers(m *Mysql, testUserIds []int) (map[string]*UserInfo, map[int]*UserInfo, map[int]*UserInfo, []*UserInfo) {
	logger.Info("开始加载企业授权用户。。。")
	phoneMap := map[string]*UserInfo{}
	userMap := map[int]*UserInfo{}
	entMap := map[int]*UserInfo{}
	all := []*UserInfo{}
	query := `SELECT DISTINCT a.ent_id,IF(instr(a.product_type,'` + Ent_EmpowerMember + `')>0,'` + Ent_EmpowerMember + `','` + Ent_EmpowerVip + `') as product_type,c.phone,b.ent_user_id,d.name as ent_name,d.power_source,d.isNew from entniche_wait_empower a 
		inner join entniche_power b on (a.end_time>? and b.status=1 and (a.product_type like '%` + Ent_EmpowerVip + `%' or a.product_type like '%` + Ent_EmpowerMember + `%') and a.id=b.wait_empower_id)
		inner join entniche_user c on (`
	if len(testUserIds) > 0 {
		array := []string{}
		for _, v := range testUserIds {
			array = append(array, fmt.Sprint(v))
		}
		query += `c.id in (` + strings.Join(array, ",") + `) and `
	}
	query += `b.ent_user_id=c.id)
		inner join entniche_info d on (d.id=a.ent_id)`
	m.SelectByBath(200, func(l *[]map[string]interface{}) bool {
		for _, v := range *l {
			phone, _ := v["phone"].(string)
			if phone == "" {
				continue
			}
			u := &UserInfo{
				Entniche: &Entniche{
					EntId:       util.IntAll(v["ent_id"]),
					EntName:     util.ObjToString(v["ent_name"]),
					UserId:      util.IntAll(v["ent_user_id"]),
					ProductType: util.ObjToString(v["product_type"]),
					PowerSource: util.IntAll(v["power_source"]),
					IsNew:       util.IntAll(v["isNew"]),
				},
				Phone: phone,
			}
			if strings.Contains(u.Entniche.ProductType, Ent_EmpowerMember) {
				u.MemberStatus = 1
			} else if strings.Contains(u.Entniche.ProductType, Ent_EmpowerVip) {
				u.VipStatus = 1
			} else {
				continue
			}
			phoneMap[phone] = u
			userMap[u.Entniche.UserId] = u
			all = append(all, u)
			entMap[u.Entniche.EntId] = u
			logger.Info("加载企业授权用户", u.Entniche.EntName, u.Entniche.EntId, u.Entniche.UserId, u.Entniche.ProductType, u.Phone)
		}
		return true
	}, query, NowFormat(Date_Full_Layout))
	logger.Info("企业授权用户加载结束。。。", len(phoneMap), len(userMap), len(entMap), len(all))
	return phoneMap, userMap, entMap, all
}

//加载商机管理用户
func LoadEntnicheUsers(m *Mysql) map[string]bool {
	logger.Info("开始加载新版商机管理用户。。。")
	r := map[string]bool{}
	m.SelectByBath(200, func(l *[]map[string]interface{}) bool {
		for _, v := range *l {
			phone := util.ObjToString(v["phone"])
			if phone != "" {
				r[phone] = true
				logger.Info("加载商机管理用户", phone)
			}
		}
		return true
	}, `SELECT b.phone from entniche_info a INNER JOIN entniche_user b on (a.status=1 and a.power_source is null and b.power=1 and a.id=b.ent_id)`)
	logger.Info("商机管理用户加载结束。。。", len(r))
	return r
}

//
func GetWxTplMsg(subSet *SubSet) (string, string) {
	keyword := strings.Join(subSet.Keys, " ")
	if len([]rune(keyword)) > 10 {
		keyword = string([]rune(keyword)[:10]) + "..."
	}
	area := strings.Join(subSet.Areas, " ")
	if len([]rune(area)) > 10 {
		area = string([]rune(area)[:10]) + "..."
	}
	return keyword, area
}

//
func GetPhone(u map[string]interface{}) string {
	phone := util.ObjToString(u["s_phone"])
	if phone == "" {
		phone = util.ObjToString(u["s_m_phone"])
	}
	return phone
}

//
func GetAllByEntUserId(mgo *MongodbSim, msl *Mysql, entUserId, tp int) (*map[string]interface{}, *map[string]interface{}) {
	entUsers := msl.SelectBySql(`select phone from entniche_user where id=?`, entUserId)
	if entUsers == nil || len(*entUsers) == 0 {
		logger.Info("entniche_user表中没有找到该企业用户", entUserId)
		return nil, nil
	}
	phone, _ := (*entUsers)[0]["phone"].(string)
	if phone == "" {
		return nil, nil
	}
	return getEntPushSet(mgo, msl, entUserId, tp, phone)
}

//
func GetAllByEntPositionId(mgo *MongodbSim, tidb, msl *Mysql, positionId, tp int) (*map[string]interface{}, *map[string]interface{}) {
	position := tidb.SelectBySql(`select a.ent_id,b.phone from base_position a inner join base_user b on (a.id=? and a.user_id=b.id)`, positionId)
	if position == nil || len(*position) == 0 {
		logger.Info("无效的职位id", position)
		return nil, nil
	}
	entId := util.Int64All((*position)[0]["ent_id"])
	if entId == 0 {
		logger.Info("该职位id没有找到对应的企业id", position)
		return nil, nil
	}
	phone, _ := (*position)[0]["phone"].(string)
	if phone == "" {
		logger.Info("该职位id没有找到对应的手机号", position)
		return nil, nil
	}
	entUsers := msl.SelectBySql(`select id from entniche_user where phone=? and ent_id=?`, phone, entId)
	if entUsers == nil || len(*entUsers) == 0 {
		logger.Info("entniche_user表中没有找到该企业用户", phone, entId)
		return nil, nil
	}
	return getEntPushSet(mgo, msl, util.IntAll((*entUsers)[0]["id"]), tp, phone)
}

//
func getEntPushSet(mgo *MongodbSim, msl *Mysql, entUserId, tp int, phone string) (*map[string]interface{}, *map[string]interface{}) {
	users, ok := mgo.Find(Mgo_User, map[string]interface{}{
		"$or": []map[string]interface{}{
			map[string]interface{}{
				"s_phone": phone,
			},
			map[string]interface{}{
				"s_m_phone": phone,
			},
		},
	}, map[string]interface{}{
		"_id":           0,
		"s_m_openid":    1,
		"i_ispush":      1,
		"s_jpushid":     1,
		"s_opushid":     1,
		"s_appponetype": 1,
	}, `{"s_phone":-1}`, false, -1, -1)
	if !ok || users == nil || len(*users) == 0 {
		logger.Info("user表中没有找到该企业用户", entUserId)
		return nil, nil
	}
	user := map[string]interface{}{}
	for _, v := range *users {
		s_m_openid := util.ObjToString(v["s_m_openid"])
		i_ispush := util.IntAll(v["i_ispush"])
		s_jpushid := util.ObjToString(v["s_jpushid"])
		s_opushid := util.ObjToString(v["s_opushid"])
		s_appponetype := util.ObjToString(v["s_appponetype"])
		if user["s_m_openid"] == nil && user["i_ispush"] == nil && s_m_openid != "" && i_ispush == 1 {
			user["s_m_openid"] = s_m_openid
			user["i_ispush"] = i_ispush
		}
		if user["s_jpushid"] == nil && user["s_opushid"] == nil && user["s_appponetype"] == nil && s_appponetype != "" && (s_jpushid != "" || s_opushid != "") {
			user["s_jpushid"] = s_jpushid
			user["s_opushid"] = s_opushid
			user["s_appponetype"] = s_appponetype
		}
	}
	entniche_rule, ok := mgo.FindOneByField("entniche_rule", map[string]interface{}{
		"i_userid": entUserId,
		"i_type":   tp,
	}, `{"o_entniche":1,"l_endtime":1,"i_status":1}`)
	if !ok || entniche_rule == nil || len(*entniche_rule) == 0 {
		logger.Info("没有找到该企业用户的订阅设置", entUserId)
		return nil, nil
	}
	return &user, entniche_rule
}