jypkg/common/src/qfw/util/dataexport/common.go

package dataexport

import (
	qutil "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/mysql"
	"fmt"
	"strings"
)

// GetLastExportPhoneAndMail 数据导出联想上次导出手机号和邮箱查询
func GetLastExportPhoneAndMail(mysqlSess *mysql.Mysql, userId, entUserId string) (phone, email string) {
	var searchSql []string
	var searchValue []interface{}

	if userId != "" {
		//个人直接支付数据导出
		searchSql = append(searchSql, `(SELECT user_phone AS phone,user_mail AS mail,UNIX_TIMESTAMP(create_time) AS exportDate FROM dataexport_order where user_mail  IS NOT NULL and user_phone is NOT NULL AND user_id =? AND product_type ='历史数据' ORDER BY create_time DESC LIMIT 1)`)
		searchValue = append(searchValue, userId)

		//每日限量包和个人线上数据包
		searchSql = append(searchSql, `(SELECT phone,mail,date AS exportDate FROM datapacket_record WHERE  phone IS NOT NULL AND mail IS NOT NULL AND useid = ? ORDER BY id DESC LIMIT 1)`)
		searchValue = append(searchValue, userId)

	}

	//企业数据导出查询
	if entUserId != "" {
		searchSql = append(searchSql, `(SELECT export_phone AS phone,export_mail AS mail,UNIX_TIMESTAMP(export_time) AS exportDate FROM entniche_export_log WHERE export_phone IS NOT NULL AND export_mail IS NOT NULL AND user_id =? ORDER BY id desc limit 1)`)
		searchValue = append(searchValue, entUserId)
	}

	//log.Println(fmt.Sprintf(`SELECT phone,mail FROM ( %s ) AS allData ORDER BY exportDate DESC limit 1`, strings.Join(searchSql, ` UNION ALL `)))
	res := mysqlSess.Query(fmt.Sprintf(`SELECT phone,mail FROM ( %s ) AS allData ORDER BY exportDate DESC limit 1`, strings.Join(searchSql, ` UNION ALL `)), searchValue...)
	if res != nil && len(*res) > 0 {
		phone, _ = (*res)[0]["phone"].(string)
		email, _ = (*res)[0]["mail"].(string)
	}
	return
}

// GetDataExportMatchKey key 关键词 逗号分隔 或的关系进行关联  types 匹配类型  data数据
// title 标题,detail 正文,filetext 附件,purchasing 标的物,projectname.pname 项目命,mbuyer 采购单位,mwinner 中标单位,magency 代理机构
func GetDataExportMatchKey(scd *SieveCondition, list *[]map[string]interface{}) {
	if list == nil || len(*list) == 0 {
		return
	}
	if scd.Comeinfrom == "pushHistory" { //历史推送数据使用推送匹配关键词 if len(scd.PushKeyWords) == len(*list) {
		for _, v := range *list {
			for k, v1 := range scd.SelectIds {
				if v1 == qutil.InterfaceToStr(v["_id"]) {
					v["keyword"] = scd.PushKeyWords[k]
				}
			}
			//v["keyword"] = scd.PushKeyWords[qutil.InterfaceToStr(v["_id"])]
		}
	} else if len(scd.Keyword) > 0 { //关键词二次匹配
		types := scd.SelectType
		var keys []string
		//统计关键词
		for _, vk := range scd.Keyword {
			key := []string{}
			for _, v := range strings.Split(vk.Keyword, " ") {
				if v != "" {
					key = append(key, v)
				}
			}
			if len(vk.Appended) > 0 {
				for _, v := range vk.Appended {
					if v != "" {
						key = append(key, strings.Split(v, " ")...)
					}
				}
			}
			vk.Keyword = strings.Join(key, ",")
			keys = append(keys, strings.ReplaceAll(vk.Keyword, "+", ","))
		}
		key := strings.Join(keys, ",")
		if key != "" {
			//二次匹配
			for _, data := range *list {
				keyWord := []string{}
				if strings.Contains(types, "title") {
					title := qutil.ObjToString(data["title"])
					keyWord = KeyWordToDatas(title, key, keyWord)
				}
				if strings.Contains(types, "detail") {
					detail := qutil.ObjToString(data["detail"])
					keyWord = KeyWordToDatas(detail, key, keyWord)
				}
				if strings.Contains(types, "purchasing") {
					purchasing := qutil.ObjToString(data["purchasing"])
					keyWord = KeyWordToDatas(purchasing, key, keyWord)
				}
				if strings.Contains(types, "filetext") {
					filetext := qutil.ObjToString(data["filetext"])
					keyWord = KeyWordToDatas(filetext, key, keyWord)
				}
				if strings.Contains(types, "projectname.pname") {
					projectname := qutil.ObjToString(data["projectname"])
					keyWord = KeyWordToDatas(projectname, key, keyWord)
				}
				if strings.Contains(types, "buyer.mbuyer") {
					buyer := qutil.ObjToString(data["buyer"])
					keyWord = KeyWordToDatas(buyer, key, keyWord)
				}
				if strings.Contains(types, "s_winner.mwinner") {
					winner := qutil.ObjToString(data["s_winner"])
					keyWord = KeyWordToDatas(winner, key, keyWord)
				}
				if strings.Contains(types, "agency.magency") {
					winner := qutil.ObjToString(data["agency"])
					keyWord = KeyWordToDatas(winner, key, keyWord)
				}
				keyMap := map[string]bool{}
				keyArr := []string{}
				for _, key1 := range keyWord {
					keyMap[key1] = true
				}
				for k, _ := range keyMap {
					keyArr = append(keyArr, k)
				}
				data["keyword"] = strings.Join(keyArr, ",")
			}
		}
	}
}

func KeyWordToDatas(item, key string, keyWord []string) []string {
	for _, mk := range strings.Split(key, ",") {
		if strings.Contains(mk, "&&") {
			arr := strings.Split(mk, "&&")
			for _, s := range arr {
				if s != "" {
					if strings.Contains(strings.ToUpper(item), strings.ToUpper(s)) {
						keyWord = append(keyWord, mk)
					}
				}
			}
		} else {
			if strings.Contains(strings.ToUpper(item), strings.ToUpper(mk)) {
				keyWord = append(keyWord, mk)
			}
		}
	}
	return keyWord
}

// 获取关键词匹配字段
func getKeywordFields() {

}