Merge branch 'dev4.5.5' of http://127.0.0.1:8080/qmx/jy into dev4.5.5

src/config.json

@@ -295,5 +295,6 @@
     "phoneFilterFlag":true,
     "pcindexCacheTime":7200,
     "pcIndexHotCacheTime":7200,
-    "pcindexCacheKey":"jypcindex2"
+    "pcindexCacheKey":"jypcindex2",
+    "dedupUrl":  "http://127.0.0.1:8888/data/deduplication"
 }

src/jfw/front/dataExport.go

@@ -811,7 +811,8 @@ func (d *DataExport) EntDataExport(_id string) error {
 	data := &[]map[string]interface{}{}
 	current := GetCurrentCount(entId)
 	log.Println("企业总条数", current)
-	count, newCount, data = public.GetEntDataExportCount(id, entId, entUserId, remain_nums, current, isFirst, util.ObjToString(config.Sysconfig["webdomain"]))
+	url := config.Sysconfig["dedupUrl"].(string)
+	count, newCount, data = public.GetEntDataExportCount(id, entId, entUserId, remain_nums, current, isFirst, util.ObjToString(config.Sysconfig["webdomain"]), url)
 	isExport := true
 	isEntExport := true
 	if newCount > current {

src/jfw/front/swordfish.go

@@ -29,7 +29,6 @@ import (
 
 	"github.com/go-xweb/httpsession"
 	"github.com/go-xweb/xweb"
-	. "github.com/thinxer/go-word2vec"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 )
@@ -40,14 +39,8 @@ const (
 	bidSearch_sort    = `{"publishtime":-1}`
 )
 
-var M *Model
-var recomKWChan chan bool = make(chan bool, 1)
 var listlock = &sync.Mutex{}
 
-func init() {
-	M, _ = Load("./zb.bin")
-}
-
 //剑鱼标讯推送三级页点赞暂弃 改成剑鱼标讯实验室点赞功能
 func (m *Front) Praise() error {
 	defer util.Catch()
@@ -1501,70 +1494,8 @@ func (f *Front) MyFeedbacks() error {
 	return nil
 }
 func (f *Front) GetRecomKWs() {
-	maxCount := 500
-	recomKWChan <- true
-	defer func() {
-		<-recomKWChan
-	}()
-	value := f.GetString("value")
 	count, _ := f.GetInteger("count")
-	ves := strings.Split(value, " ")
-	var pairs []map[string]interface{}
-	for _, v := range ves {
-		//获取随机数
-		arr := generateRandomNumber(0, maxCount, count)
-		Pw, _ := M.MostSimilar(strings.Split(v, "+"), []string{}, maxCount)
-		for k, p := range Pw {
-			sim := p.Sim
-			word := p.Word
-			// if sim < float32(config.Sysconfig["recommendThreshold"].(float64)) {
-			// 	continue
-			// }
-			if !isinByInt(k, arr) {
-				continue
-			}
-			if strings.HasSuffix(word, "路") || public.DealString(word) {
-				continue
-			}
-			pairs = append(pairs, map[string]interface{}{
-				"sim":  sim,
-				"word": word,
-			})
-
-		}
-	}
-	f.ServeJson(pairs)
-}
-
-//随机数查询
-func generateRandomNumber(start int, end int, count int) []int {
-	//范围检查
-	if end < start || (end-start) < count {
-		return nil
-	}
-	//存放结果的slice
-	nums := make([]int, 0)
-	m := map[int]bool{}
-	//随机数生成器，加入时间戳保证每次生成的随机数不一样
-	r := rand.New(rand.NewSource(time.Now().UnixNano()))
-	for len(nums) < count {
-		//生成随机数
-		num := r.Intn((end - start)) + start
-		if !m[num] {
-			m[num] = true
-			nums = append(nums, num)
-		}
-	}
-	return nums
-}
-
-func isinByInt(i int, arr []int) bool {
-	for _, v := range arr {
-		if i == v {
-			return true
-		}
-	}
-	return false
+	f.ServeJson(public.RecomKws.GetRecomKws(f.GetString("value"), count))
 }
 
 //记录用户行为--推荐关键词

src/jfw/modules/app/src/app/front/swordfish.go

@@ -19,7 +19,6 @@ import (
 	"time"
 
 	"github.com/go-xweb/httpsession"
-	. "github.com/thinxer/go-word2vec"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 )
@@ -33,14 +32,8 @@ const (
 	bidSearch_sort    = `{"publishtime":-1}`
 )
 
-var M *Model
-var recomKWChan chan bool = make(chan bool, 1)
 var listlock = &sync.Mutex{}
 
-func init() {
-	M, _ = Load("./zb.bin")
-}
-
 //剑鱼标讯推送三级页点赞暂弃 改成剑鱼标讯实验室点赞功能
 func (m *Front) Praise() error {
 	defer util.Catch()
@@ -625,74 +618,8 @@ func wxvisitD(sid, userId string) (objdata map[string]interface{}) {
 	return obj
 }
 func (f *Front) GetRecomKWs() {
-	maxCount := 500
-	recomKWChan <- true
-	defer func() {
-		<-recomKWChan
-	}()
-	value := f.GetString("value")
 	count, _ := f.GetInteger("count")
-	ves := strings.Split(value, " ")
-	var pairs []map[string]interface{}
-	for _, v := range ves {
-		Pw, _ := M.MostSimilar(strings.Split(v, "+"), []string{}, maxCount)
-		arr := generateRandomNumber(0, maxCount, count)
-		for k, p := range Pw {
-			sim := p.Sim
-			word := p.Word
-			// if sim < float32(config.Sysconfig["recommendThreshold"].(float64)) {
-			// 	continue
-			// }
-			if !isinByInt(k, arr) {
-				continue
-			}
-			if strings.HasSuffix(word, "路") || public.DealString(word) {
-				continue
-			}
-			pairs = append(pairs, map[string]interface{}{
-				"sim":  sim,
-				"word": word,
-			})
-		}
-	}
-	f.ServeJson(pairs)
-}
-
-//随机数查询
-func generateRandomNumber(start int, end int, count int) []int {
-	//范围检查
-	if end < start || (end-start) < count {
-		return nil
-	}
-	//存放结果的slice
-	nums := make([]int, 0)
-	//随机数生成器，加入时间戳保证每次生成的随机数不一样
-	r := rand.New(rand.NewSource(time.Now().UnixNano()))
-	for len(nums) < count {
-		//生成随机数
-		num := r.Intn((end - start)) + start
-		//查重
-		exist := false
-		for _, v := range nums {
-			if v == num {
-				exist = true
-				break
-			}
-		}
-		if !exist {
-			nums = append(nums, num)
-		}
-	}
-	return nums
-}
-
-func isinByInt(i int, arr []int) bool {
-	for _, v := range arr {
-		if i == v {
-			return true
-		}
-	}
-	return false
+	f.ServeJson(public.RecomKws.GetRecomKws(f.GetString("value"), count))
 }
 
 //记录用户行为--推荐关键词

src/jfw/modules/app/src/web/staticres/jyapp/vipsubscribe/js/keyWord.js

@@ -38,6 +38,23 @@ var vm = new Vue({
     selectedCount: function () {
       var selectedArr = this.getSelectedArr()
       return selectedArr.length
+    },
+    totalKeywordsCount: function () {
+      var count = 0
+      this.filter.allKeywordsList.forEach(function (item) {
+        if (item.matchway == 1) {
+          // 模糊匹配
+          var key = item.key
+          if (Array.isArray(item.appendkey)) {
+            key = key.concat(item.appendkey)
+          }
+          count += key.length
+        } else {
+          // 精准匹配(matchway：0/undefined)
+          count++
+        }
+      })
+      return count
     }
   },
   created: function () {
@@ -348,7 +365,6 @@ var vm = new Vue({
     getGroupIndexWithGroupName: function (gn) {
       var groupIndex = -1
       this.keywordsGroupList.forEach(function(item, index) {
-        console.log(item)
         if (gn === item.s_item) {
           groupIndex = index
         }

src/jfw/modules/app/src/web/staticres/jyapp/vipsubscribe/js/keyword-info.js

@@ -49,8 +49,31 @@ var vm = new Vue({
   computed: {
     tooLittleTipShow: function () {
       return this.pInfo.pushCount < 30
+    },
+    // 监听关键词和匹配方式变化
+    needGetRecList: function () {
+      return {
+        key: this.keyInfo.key,
+        matchWay: this.keyInfo.matchWay
+      }
+    },
+    // 监听关键词、匹配方式和排除词变化
+    keyInfoChange: function () {
+      return {
+        key: this.keyInfo.key,
+        notKey: this.keyInfo.notKey,
+        matchWay: this.keyInfo.matchWay
+      }
     }
   },
+  watch: {
+    needGetRecList: utils.debounce(function (newVal, oldVal) {
+      this.getKeyRecommend()
+    }, 2000),
+    keyInfoChange: utils.debounce(function () {
+      this.getPushCount()
+    }, 2000)
+  },
   created: function () {
     // 获取url参数
     var type = utils.getParam('type')
@@ -67,9 +90,8 @@ var vm = new Vue({
     this.getKeywordsGroupList({
       needLoading: true,
       callback: function () {
-        this.getKeyRecommend()
-        if (this.pInfo.editType === 'edit') {
-          this.getPushCount()
+        if (this.pInfo.editType === 'add') {
+          this.getKeyRecommend()
         }
       }.bind(this)
     })
@@ -105,31 +127,16 @@ var vm = new Vue({
       return this.$dialog.confirm(defaultConf)
     },
     getPushCount: function () {
-      var groupInfo = {
-        name: '',
-        kIndex: -1
-      }
-      if (this.pInfo.editType === 'add') {
-        
-      } else if (this.pInfo.editType === 'edit') {
-        groupInfo.name = this.keywordsGroupList[this.pInfo.gIndex].s_item
-        groupInfo.kIndex = this.pInfo.kIndex
-      } else {
-        return
-      }
-
-      this.getPushCountConfirmed(groupInfo)
-    },
-    getPushCountConfirmed: function (groupInfo) {
       var _this = this
       // 全部关键词-推送结果预览总数参数：item值为空 index值为-1
       // 某个关键词组-推送结果预览总数参数：item值不为空 index值大于等于0
       $.ajax({
-        url: '/subscribepay/afterPay/getPushCount',
+        url: '/subscribepay/afterPay/keyset/getPushCount',
         type: 'POST',
         data: {
-          item: groupInfo.name, // 关键词组所在分类名称
-          index: groupInfo.kIndex // 关键词组所在分类下的索引位置
+          key: this.keyInfo.key.trim().replace(/\s+/g, ' '),
+          notkey: this.getNotKeyArr().join(' '),
+          matchway: this.keyInfo.matchWay
         },
         success: function (res) {
           if (res && res.count) {
@@ -207,7 +214,8 @@ var vm = new Vue({
         groupNameList.push({
           name: item.s_item, // 分类名
           checked: false,
-          count: count // 分类下有多少个关键词
+          count: count, // 分类下有多少个关键词
+          gIndex: index
         })
       })
       return groupNameList
@@ -290,7 +298,6 @@ var vm = new Vue({
       })
       return groupInfo
     },
-    getPageKeyInfoFromGroupList: function () {},
     delThisKey: function () {
       var _this = this
       this.showDialog({
@@ -430,7 +437,7 @@ var vm = new Vue({
         pageType: 'keyWords',
         actionType: 'SK',
         match_way: this.keyInfo.matchWay,
-        kws_name: this.keyInfo.key.trim(),
+        kws_name: this.keyInfo.key.trim().replace(/\s+/g, ' '),
         not_kws: this.getNotKeyArr(),
         kwscount: this.allKeywordsList.length,
         classify_index: groupInfo.gIndex,
@@ -482,24 +489,43 @@ var vm = new Vue({
       if (this.pInfo.gIndex !== null && this.pInfo.gIndex !== undefined && this.pInfo.gIndex !== '') {
         // url中取到索引，可以直接用
         filterArr = this.keywordsGroupList[this.pInfo.gIndex].a_key
+        filterArr = JSON.parse(JSON.stringify(filterArr))
+        if (this.pInfo.editType === 'edit') {
+          filterArr.splice(this.pInfo.kIndex, 1)
+          filterArr.push({
+            key: this.keyInfo.key.split(/\s+/),
+            matchway: this.keyInfo.matchWay
+          })
+        }
       } else {
-        filterArr = this.filterKeywordsList('未分类')
+        filterArr = this.allKeywordsList
       }
 
       filterArr.forEach(function (item) {
-        if (item.key) {
-          if (item.key instanceof Array) {
-            keysArr.push(item.key.join('+'))
-          } else {
-            keysArr.push(item.key)
-          }
+        // 关键词1：信息 技术   关键词2：软件
+        // 模糊匹配，参数是：信息 技术 软件
+        // 精准匹配，参数是：信息+技术 软件
+        var key = Array.isArray(item.key) ? item.key : []
+        if (Array.isArray(item.appendkey)) {
+          key = key.concat(item.appendkey)
+        }
+
+        if (item.matchway == 1) {
+          // 模糊匹配
+          keysArr.push(key.join(' '))
+        } else {
+          // 精准匹配
+          keysArr.push(key.join('+'))
         }
       })
 
       if (keysArr.length === 0) return
 
+      if (this.recListState.loading) return
+      this.recListState.loading = true
+
       var fetchData = {
-        count: 20,
+        count: 20, // 最少需要多少条数据
         value: utils.unique(keysArr).join(' ')
       }
       $.ajax({
@@ -507,13 +533,21 @@ var vm = new Vue({
         type: 'POST',
         data: fetchData,
         success: function (r) {
+          _this.recListState.loading = false
           if (r && r instanceof Array && r.length !== 0) {
             _this.loadKeyRecommend(r)
           }
+        },
+        complete: function () {
+          _this.recListState.loading = false
         }
       })
     },
     loadKeyRecommend: function (list) {
+      // 页码初始化
+      this.recListState.pageNum = 1
+      this.recListState.total = 0
+
       var afterFilterArr = this.filterKeyRecommend(list)
       this.recommendTags = afterFilterArr.slice(0, this.conf.recommendTagsCount)
 

src/jfw/modules/app/src/web/templates/vipsubscribe/keyWord.html

@@ -92,7 +92,7 @@
                     <span class="button-text">订阅关键词</span>
                 </button>
                 <div class="keywords-count">
-                    关键词添加数量：<span class="highlight-text">${ filter.allKeywordsList.length }</span> / ${ conf.keywordMax }
+                    关键词添加数量：<span class="highlight-text">${ totalKeywordsCount }</span> / ${ conf.keywordMax }
                 </div>
           </div>
         </div>
@@ -114,7 +114,7 @@
             <div class="j-button-group" v-else>
                 <button class="j-button-confirm" @click="addKeyWord" :disabled="filter.allKeywordsList.length >= conf.keywordMax">
                     <span class="info-text">新增关键词</span>
-                    <span class="sub-text">（${ filter.allKeywordsList.length } / ${ conf.keywordMax }）</span>
+                    <span class="sub-text">（${ totalKeywordsCount } / ${ conf.keywordMax }）</span>
                 </button>
             </div>
         </div>

src/jfw/modules/common/src/qfw/util/jy/entnichepush.go

@@ -3,9 +3,11 @@ package jy
 import (
 	"encoding/json"
 	"fmt"
+	"io/ioutil"
 	"log"
 	"math"
 	mg "mongodb"
+	"net/http"
 	. "qfw/util"
 	"qfw/util/elastic"
 	"qfw/util/mysql"
@@ -217,11 +219,11 @@ func (e *entnichePush) GetCache(code, key string) ([]*SubPushList, error) {
 	return p, nil
 }
 
-func (e *entnichePush) NewDatas(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum int, selectTime, area, buyerclass string, isEnt bool) (hasNextPage bool, result []map[string]interface{}, allCount int) {
+func (e *entnichePush) NewDatas(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum int, selectTime, area, buyerclass string, isEnt bool,url string) (hasNextPage bool, result []map[string]interface{}, allCount int) {
 	if pageNum < 1 {
 		pageNum = 1
 	}
-	result, allCount = e.newGetDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, pageNum, pageSizes, selectTime, area, buyerclass, true, isEnt)
+	result, allCount = e.newGetDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, pageNum, pageSizes, selectTime, area, buyerclass, true, isEnt,url)
 	if result == nil {
 		result = []map[string]interface{}{}
 	}
@@ -229,11 +231,11 @@ func (e *entnichePush) NewDatas(Mgo_bidding mg.MongodbSim, bidding, bidding_back
 	return
 }
 
-func (e *entnichePush) NewExportDatas(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, selectTime, area, buyerclass string, isEnt bool, maxCount int) (result []map[string]interface{}, allCount, secondCount int) {
+func (e *entnichePush) NewExportDatas(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, selectTime, area, buyerclass string, isEnt bool, maxCount int,url string) (result []map[string]interface{}, allCount, secondCount int) {
 	if selectTime == "" && area == "" {
-		result, allCount, secondCount = e.newGetExportDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, 1, pageSizes, selectTime, area, buyerclass, false, isEnt, maxCount)
+		result, allCount, secondCount = e.newGetExportDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, 1, pageSizes, selectTime, area, buyerclass, false, isEnt, maxCount,url)
 	} else {
-		result, allCount, secondCount = e.newGetExportDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, 1, pageSizes, selectTime, area, buyerclass, false, isEnt, maxCount)
+		result, allCount, secondCount = e.newGetExportDatasFromMysql(Mgo_bidding, bidding, bidding_back, PushMysql, entId, userId, 1, pageSizes, selectTime, area, buyerclass, false, isEnt, maxCount,url)
 	}
 	if result == nil {
 		result = []map[string]interface{}{}
@@ -241,7 +243,7 @@ func (e *entnichePush) NewExportDatas(Mgo_bidding mg.MongodbSim, bidding, biddin
 	return
 }
 
-func (e *entnichePush) newGetDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum, myPageSize int, selectTime, area, buyerclass string, isLimit bool, isEnt bool) (result []map[string]interface{}, count int) {
+func (e *entnichePush) newGetDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum, myPageSize int, selectTime, area, buyerclass string, isLimit bool, isEnt bool,url string) (result []map[string]interface{}, count int) {
 	findSQL := ""
 	if isEnt {
 		findSQL = "select id,date,infoid,buyerclass,isvisit,matchkeys,type,1 as isvip from pushentniche where entid=" + fmt.Sprint(entId)
@@ -300,7 +302,7 @@ func (e *entnichePush) newGetDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding,
 	list := PushMysql.SelectBySql(findSQL)
 	counts := len(*list)
 	if counts > 0 {
-		result, _ = e.GetExportInfoByIds(Mgo_bidding, bidding, bidding_back, *list, false, entId)
+		result, _ = e.GetExportInfoByIds(Mgo_bidding, bidding, bidding_back, *list, false, entId,url)
 	}
 	if counts == 0 || *list == nil || list == nil {
 		result = []map[string]interface{}{}
@@ -308,7 +310,7 @@ func (e *entnichePush) newGetDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding,
 	return
 }
 
-func (e *entnichePush) newGetExportDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum, myPageSize int, selectTime, area, buyerclass string, isLimit bool, isEnt bool, maxCount int) (result []map[string]interface{}, counts, secondCount int) {
+func (e *entnichePush) newGetExportDatasFromMysql(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, PushMysql *mysql.Mysql, entId, userId int, pageNum, myPageSize int, selectTime, area, buyerclass string, isLimit bool, isEnt bool, maxCount int,url string) (result []map[string]interface{}, counts, secondCount int) {
 	findSQL := ""
 	countSQL := ""
 	if isEnt {
@@ -379,7 +381,7 @@ func (e *entnichePush) newGetExportDatasFromMysql(Mgo_bidding mg.MongodbSim, bid
 			log.Println("findSQL ", findSQL)
 			list = PushMysql.SelectBySql(findSQL)
 		}
-		result, secondCount = e.GetExportInfoByIds(Mgo_bidding, bidding, bidding_back, *list, true, entId)
+		result, secondCount = e.GetExportInfoByIds(Mgo_bidding, bidding, bidding_back, *list, true, entId,url)
 	}
 	if counts == 0 || len(*list) == 0 || list == nil {
 		result = []map[string]interface{}{}
@@ -388,27 +390,72 @@ func (e *entnichePush) newGetExportDatasFromMysql(Mgo_bidding mg.MongodbSim, bid
 }
 
 //根据id取内容
-func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, pushCas []map[string]interface{}, isInfoId bool, entId int) ([]map[string]interface{}, int) {
+func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bidding_back string, pushCas []map[string]interface{}, isInfoId bool, entId int,url string) ([]map[string]interface{}, int) {
 	array := []map[string]interface{}{}
-	var newsDatalen = make(chan bool, 1000000)
+	//var newsDatalen = make(chan bool, 1000000)
+	newCount :=0  // 新导出数量
+	infoIdList := []string{} // 临时infoid数组
+	//log.Println(pushCas,"啦啦啦")
 	if len(pushCas) == 0 {
 		return array, 0
 	}
 	m := map[string]bool{}
 	ids := []string{}
+	// 20210716  判重由redis 改为请求判重中台接口  每一千个请求一次
 	for _, v := range pushCas {
 		infoid := ObjToString(v["infoid"])
-		isExist, err := redis.Exists("other", "entexportdata_"+infoid+"_"+fmt.Sprintln(entId))
-		if err != nil {
-			log.Println("企业搜索数据导出redis判重失败")
-		} else if !isExist {
-			newsDatalen <- true
-		}
 		if m[infoid] {
 			continue
 		}
 		m[infoid] = true
 		ids = append(ids, infoid)
+		// 20210716  判重由redis 改为请求判重中台接口  每一千个请求一次
+		if len(infoIdList) > 1000 {
+			//	 调接口
+			rs, err5 := Post(url, map[string]string{
+				"personId": "0",  // 这个参数没有用
+				"infoId":   strings.Join(infoIdList, ","),
+				"entId":    fmt.Sprintf("%d", entId),
+				"isInsert": "false",  // 是否插入数据
+				"isEnt":    "true", // 是否根据企业id判重
+			})
+			if err5 != nil || IntAll(rs["code"])!=0{
+				log.Println("企业订阅数据导出接口判重失败", err5)
+			} else {
+				log.Println("企业订阅数据导出", rs)
+				// 置空
+				infoIdList = []string{}
+				// 本次数据累计
+				returnData := rs["data"].(map[string]interface{})
+				//log.Println(newCount,"加之前121")
+				newCount+=int(returnData["newCount"].(float64))
+				//log.Println(newCount,"加之后121")
+			}
+
+		}
+		infoIdList = append(infoIdList,infoid)
+	}
+	//
+	if len(infoIdList)>0{
+		log.Println(entId)
+		rs,err5 := Post(url, map[string]string{
+			"personId":"0",
+			"infoId":strings.Join(infoIdList,","),
+			"entId":fmt.Sprintf("%d", entId),
+			"isInsert":"false",
+			"isEnt":"true",
+
+		})
+		if err5 !=nil|| IntAll(rs["code"])!=0{
+			log.Println("判重失败===",err5)
+		}else {
+			// 置空
+			infoIdList = []string{}
+			// 本次数据累计
+			returnData := rs["data"].(map[string]interface{})
+			newCount+=int(returnData["newCount"].(float64))
+		}
+
 	}
 	infos := map[string]map[string]interface{}{}
 	//elasticsearch
@@ -492,6 +539,30 @@ func (e *entnichePush) GetExportInfoByIds(Mgo_bidding mg.MongodbSim, bidding, bi
 		info = InfoFormats(info, v)
 		array = append(array, info)
 	}
-	log.Println("newsDatalen", len(newsDatalen))
-	return array, len(newsDatalen)
+	log.Println("newsDatalen", newCount)
+	log.Println(len(array))
+	return array, newCount
+}
+func Post(url string, form map[string]string) (data map[string]interface{}, err error) {
+	str := ""
+	for k, v := range form {
+		str += "&" + k + "=" + v
+	}
+	//log.Println(str)
+	res, err1 := http.Post(url, "application/x-www-form-urlencoded", strings.NewReader(str))
+	log.Println(res)
+	if err1 != nil {
+		log.Println("post err:", err1.Error())
+		return nil, err1
+
+	} else if res.Body != nil {
+		defer res.Body.Close()
+		bs, _ := ioutil.ReadAll(res.Body)
+		err2 := json.Unmarshal(bs, &data)
+		if err2 != nil {
+			return nil, err2
+		}
+
+	}
+	return data, nil
 }

src/jfw/modules/subscribepay/src/config.json

@@ -27,8 +27,8 @@
 		"userName": "admin",
 		"password": "123456"
 	},
-    "redisaddrs": "other=192.168.3.11:1712,session=192.168.3.11:1713,push=192.168.3.206:1712,pushcache_1=192.168.3.206:5000,pushcache_2_a=192.168.3.206:5001",
-    "elasticsearch": "http://192.168.3.206:9800",
+    "redisaddrs": "other=127.0.0.1:1712,session=127.0.0.1:1713,push=127.0.0.1:1712,pushcache_1=127.0.0.1:5000,pushcache_2_a=127.0.0.1:5001",
+    "elasticsearch": "http://127.0.0.1:1800",
     "elasticPoolSize": 30,
     "appid": "wx5b1c6e7cc4dac0e4",
     "appsecret": "b026103ffebd2291b3edb7a269612112",

src/jfw/modules/subscribepay/src/config/config.go

@@ -95,6 +95,7 @@ type messageConfig struct {
 	WxTpl_Expired            *WxTplMsg //已到期
 	WxTpl_Unpaid             *WxTplMsg //未支付订单
 	WxTpl_PaySuccess         *WxTplMsg //支付成功
+	WxTpl_DataReport         *WxTplMsg //数据报告
 }
 
 type WxTplMsg struct {
@@ -238,6 +239,13 @@ var WxPayConf map[string]interface{}
 
 var Wxoauth, Wxoauthinfo string
 var AutoMergeTimeStamp int64
+var (
+	WxTpl_OnTrial_SoonExpire_SceneCode string
+	WxTpl_OnTrial_Expired_SceneCode    string
+	WxTpl_SoonExpire_SceneCode         string
+	WxTpl_Expired_SceneCode            string
+	WxTpl_DataReport_SceneCode         string
+)
 
 func init() {
 	//程序配置文件
@@ -275,5 +283,10 @@ func init() {
 		panic(err)
 	}
 	AutoMergeTimeStamp = time.Unix()
-
+	//
+	WxTpl_OnTrial_SoonExpire_SceneCode = MessageConfig.WxTpl_OnTrial_SoonExpire.First.Value
+	WxTpl_OnTrial_Expired_SceneCode = MessageConfig.WxTpl_OnTrial_Expired.First.Value
+	WxTpl_SoonExpire_SceneCode = MessageConfig.WxTpl_SoonExpire.First.Value
+	WxTpl_Expired_SceneCode = MessageConfig.WxTpl_Expired.First.Value
+	WxTpl_DataReport_SceneCode = MessageConfig.WxTpl_DataReport.First.Value
 }

src/jfw/modules/subscribepay/src/entity/dataReportStruct.go

@@ -170,9 +170,13 @@ func sendtemp(openid, order_coded, product_type, pay_time string) {
 	if openid == "" || order_coded == "" || product_type == "" || pay_time == "" {
 		fmt.Println("数据报告模板参数异常")
 	} else {
+		wxTplMsgErr := (&util.WxTplMsgCustom{}).DataReport()
+		if wxTplMsgErr != nil {
+			log.Println(wxTplMsgErr)
+		}
 		ok, status := frpc.WxPush(config.Config.Weixinrpc, "WeiXinRpc.SendDataReportMsg", &frpc.NotifyMsg{
 			Openid:  openid,
-			Title:   "尊敬的客户，您的订单已支付成功",
+			Title:   config.MessageConfig.WxTpl_DataReport.First.Value,
 			Detail:  product_type, //产品类型
 			Service: order_coded,  //订单编号
 			Date:    pay_time,     //支付时间

src/jfw/modules/subscribepay/src/main.go

@@ -11,13 +11,22 @@ import (
 	"rpcfollow"
 	_ "service"
 	"timetask"
-	_ "util"
+	"util"
 
 	"github.com/go-xweb/xweb"
 )
 
+func init() {
+	wxTplMsgExpiredErr := (&util.WxTplMsgCustom{}).Expired()
+	if wxTplMsgExpiredErr != nil {
+		log.Fatalln(wxTplMsgExpiredErr)
+	}
+	wxTplMsgDataReportErr := (&util.WxTplMsgCustom{}).DataReport()
+	if wxTplMsgDataReportErr != nil {
+		log.Fatalln(wxTplMsgDataReportErr)
+	}
+}
 func main() {
-
 	go func() {
 		frpc := new(rpcfollow.JyPayRpc)
 		rpc.Register(frpc)
@@ -31,7 +40,6 @@ func main() {
 			log.Println("ListenAndServe: ", err)
 		}
 	}()
-
 	go timetask.Run()
 	mux1 := http.NewServeMux()
 	xweb.RunBase(":"+Config.Webport, mux1)

src/jfw/modules/subscribepay/src/message.json

@@ -2,7 +2,7 @@
 	"WxTpl_OnTrial_SoonExpire": {
 		"id": "_2qGuk_KkOQtiO8oV_7ZOCWfjX2FQjs6pUDYBHkpygI",
 		"first":{
-			"value":"您试用的超级订阅服务即将到期，如需获取更多精准招标信息，请及时购买。",
+			"value":"001",
 			"color":"#FE737A"
 		},
 		"remark": {
@@ -12,7 +12,7 @@
 	"WxTpl_OnTrial_Expired": {
 		"id": "_2qGuk_KkOQtiO8oV_7ZOCWfjX2FQjs6pUDYBHkpygI",
 		"first":{
-			"value":"您试用的超级订阅服务已到期，如需获取更多精准招标信息，请及时购买。",
+			"value":"002",
 			"color":"#FE737A"
 		},
 		"remark": {
@@ -22,7 +22,7 @@
 	"WxTpl_SoonExpire": {
 		"id": "3_VPNbD7fmfd8BsdjLW-a7FOP4wIhEGV7Jx-11-9c7g",
 		"first":{
-			"value":"超级订阅服务即将到期，请及时续费",
+			"value":"001",
 			"color":"#FE737A"
 		},
 		"keyword2": {
@@ -38,7 +38,7 @@
 	"WxTpl_Expired": {
 		"id": "3_VPNbD7fmfd8BsdjLW-a7FOP4wIhEGV7Jx-11-9c7g",
 		"first":{
-			"value":"超级订阅服务已到期，点击续费",
+			"value":"002",
 			"color":"#FE737A"
 		},
 		"keyword2": {
@@ -95,5 +95,11 @@
 		"keyword1": {
 			"value":"超级订阅%s"
 		}
+	},
+	"WxTpl_DataReport": {
+		"id": "1p3eqXz28HNlIJxhLoWl8zP7y0l8ZGd8YTsLvTq2J28",
+		"first":{
+			"value":"001"
+		}
 	}
 }

src/jfw/modules/subscribepay/src/timetask/timetask.go

@@ -269,6 +269,9 @@ func expireRemind() {
 	crontab(false, TimeTaskConfig.ExpireRemind, func() {
 		defer qutil.Catch()
 		log.Println("定时任务，到期提醒，开始推送消息")
+		if wxTplMsgErr := (&util.WxTplMsgCustom{}).Expired(); wxTplMsgErr != nil {
+			log.Println(wxTplMsgErr)
+		}
 		sess := util.MQFW.GetMgoConn()
 		for {
 			if sess != nil {

src/jfw/modules/subscribepay/src/util/wxtplmsgcustom.go

@@ -0,0 +1,86 @@
+package util
+
+import (
+	. "config"
+	"errors"
+	"log"
+	. "qfw/util/rpc"
+	"strings"
+)
+
+type WxTplMsgCustom struct {
+}
+
+/* 获取自定义模板消息
+ * @Param tplId 模板消息id
+ * @Param sceneCode 场景代码
+ */
+func (w *WxTplMsgCustom) Get(tplId string, sceneCode ...string) map[string]*TmplItem {
+	param := []interface{}{tplId}
+	wh := []string{}
+	for _, v := range sceneCode {
+		param = append(param, v)
+		wh = append(wh, "?")
+	}
+	list := Mysql.SelectBySql(`select firstdata,sceneCode from scene a 
+	inner join template_message b on (a.templateId=b.id and b.templateId=? and a.sceneCode in (`+strings.Join(wh, ",")+`) and a.state=1 and a.isTest=1)`, param...)
+	m := map[string]*TmplItem{}
+	if list != nil {
+		for _, v := range *list {
+			sceneCode, _ := v["sceneCode"].(string)
+			sceneCode = strings.TrimSpace(sceneCode)
+			//
+			firstdata, _ := v["firstdata"].(string)
+			firstdata = strings.TrimSpace(firstdata)
+			//
+			m[sceneCode] = &TmplItem{
+				Value: firstdata,
+			}
+		}
+	}
+	return m
+}
+
+//超级订阅试用即将到期、超级订阅试用已到期、超级订阅即将到期、超级订阅已到期
+func (w *WxTplMsgCustom) Expired() error {
+	//试用-微信模板消息自定义
+	onTrial_WxTplMsg := w.Get(MessageConfig.WxTpl_OnTrial_SoonExpire.Id, WxTpl_OnTrial_SoonExpire_SceneCode, WxTpl_OnTrial_Expired_SceneCode)
+	//试用-即将到期
+	if onTrial_WxTplMsg[WxTpl_OnTrial_SoonExpire_SceneCode] == nil {
+		return errors.New("试用-即将到期，微信模板消息异常")
+	}
+	MessageConfig.WxTpl_OnTrial_SoonExpire.First.Value = onTrial_WxTplMsg[WxTpl_OnTrial_SoonExpire_SceneCode].Value
+	log.Println("试用-即将到期，微信模板消息first_data", MessageConfig.WxTpl_OnTrial_SoonExpire.First.Value)
+	//试用-已到期
+	if onTrial_WxTplMsg[WxTpl_OnTrial_Expired_SceneCode] == nil {
+		return errors.New("试用-已到期，微信模板消息异常")
+	}
+	MessageConfig.WxTpl_OnTrial_Expired.First.Value = onTrial_WxTplMsg[WxTpl_OnTrial_Expired_SceneCode].Value
+	log.Println("试用-已到期，微信模板消息first_data", MessageConfig.WxTpl_OnTrial_Expired.First.Value)
+	//购买-微信模板消息自定义
+	wxTplMsg := w.Get(MessageConfig.WxTpl_Expired.Id, WxTpl_SoonExpire_SceneCode, WxTpl_Expired_SceneCode)
+	//即将到期
+	if wxTplMsg[WxTpl_SoonExpire_SceneCode] == nil {
+		return errors.New("即将到期，微信模板消息异常")
+	}
+	MessageConfig.WxTpl_SoonExpire.First.Value = wxTplMsg[WxTpl_SoonExpire_SceneCode].Value
+	log.Println("即将到期，微信模板消息first_data", MessageConfig.WxTpl_SoonExpire.First.Value)
+	//已到期
+	if wxTplMsg[WxTpl_Expired_SceneCode] == nil {
+		return errors.New("已到期，微信模板消息异常")
+	}
+	MessageConfig.WxTpl_Expired.First.Value = wxTplMsg[WxTpl_Expired_SceneCode].Value
+	log.Println("已到期，微信模板消息first_data", MessageConfig.WxTpl_Expired.First.Value)
+	return nil
+}
+
+//数据报告
+func (w *WxTplMsgCustom) DataReport() error {
+	wxTplMsg := w.Get(MessageConfig.WxTpl_DataReport.Id, WxTpl_DataReport_SceneCode)
+	if wxTplMsg[WxTpl_DataReport_SceneCode] == nil {
+		return errors.New("数据报告，微信模板消息异常")
+	}
+	MessageConfig.WxTpl_DataReport.First.Value = wxTplMsg[WxTpl_DataReport_SceneCode].Value
+	log.Println("数据报告，微信模板消息first_data", MessageConfig.WxTpl_DataReport.First.Value)
+	return nil
+}

src/jfw/public/dataexport.go

@@ -148,8 +148,10 @@ func (this *BidSearchExport) PassBidSearchExport() (returnData map[string]interf
 		starttime := fmt.Sprint(time.Date(now.Year(), now.Month(), now.Day()-30, 0, 0, 0, 0, time.Local).Unix())
 		publishtimeSave = fmt.Sprintf("%s_%d", starttime, now.Unix())
 	} else if this.Publishtime == "thisyear" { //去年
-		starttime := fmt.Sprint(time.Date(now.Year()-1, 1, 1, 0, 0, 0, 0, time.Local).Unix())
-		endtime := fmt.Sprint(time.Date(now.Year()-1, 12, 31, 23, 59, 59, 0, time.Local).Unix())
+		// starttime := fmt.Sprint(time.Date(now.Year()-1, 1, 1, 0, 0, 0, 0, time.Local).Unix())
+		// endtime := fmt.Sprint(time.Date(now.Year()-1, 12, 31, 23, 59, 59, 0, time.Local).Unix())
+		starttime := fmt.Sprint(time.Date(now.Year()-1, now.Month(), now.Day(), now.Hour(), now.Minute(), now.Second(), 0, time.Local).Unix())
+		endtime := fmt.Sprint(now.Unix())
 		publishtimeSave = fmt.Sprintf("%s_%s", starttime, endtime)
 	}
 	returnData = map[string]interface{}{

src/jfw/public/entdataexport.go

@@ -1,25 +1,27 @@
 package public
 
 import (
+	"encoding/json"
 	"fmt"
 	"go.mongodb.org/mongo-driver/bson"
+	"io/ioutil"
 	"log"
+	"net/http"
 	"qfw/util"
 	"qfw/util/dataexport"
 	"qfw/util/elastic"
-	"qfw/util/redis"
 	"strings"
 	"sync"
 	"time"
 )
 
-func GetEntDataExportCount(_id string, entId, entUserId, limitNum, current int, isFirst bool, webdomain string) (count, newCount int, data *[]map[string]interface{}) {
+func GetEntDataExportCount(_id string, entId, entUserId, limitNum, current int, isFirst bool, webdomain string, url string) (count, newCount int, data *[]map[string]interface{}) {
 	defer util.Catch()
 	var (
 		searchsWaitGroup = &sync.WaitGroup{}
-		searchsPool      = make(chan bool, 20)
+		//searchsPool      = make(chan bool, 20)
 		// res              = &[]map[string]interface{}{}
-		newCountPool = make(chan bool, 20000)
+		//newCountPool = make(chan bool, 20000)
 	)
 	//count = GetDataExportSearchCountUseId(_id)
 	count = dataexport.GetDataExportSearchCountByScdId(MQFW, DbConf.Elasticsearch.Main.Address, _id)
@@ -35,33 +37,49 @@ func GetEntDataExportCount(_id string, entId, entUserId, limitNum, current int,
 		log.Println("企业数据导出错误 ", err)
 		return 0, 0, nil
 	}
-	// secondCount := 0
-
-	// isOK := true
-	// if secondCount > current {
-	// 	isOK = false
-	// }
+	//  20210716 由原来的redis判重改为调用判重中台接口进行判重
+	m := map[string]bool{}
+	infoIdList := []string{}
+	insertFlag := "false"
+	if !isFirst {
+		insertFlag = "true"
+	}
 	for _, v := range *res {
-		searchsWaitGroup.Add(1)
-		searchsPool <- true
 		id := util.ObjToString(v["_id"])
-		go func(id string) {
-			defer func() {
-				searchsWaitGroup.Done()
-				<-searchsPool
-			}()
-			isExist, err := redis.Exists("other", "entexportdata_"+id+"_"+fmt.Sprintln(entId))
-			if err != nil {
-				log.Println("企业搜索数据导出redis判重失败")
-			} else if isExist {
-				log.Println("数据重复，id ", id, "entid ", entId, "userid ", entUserId)
-				return
-			}
-			newCountPool <- true
-			if !isFirst {
-				redis.Put("other", "entexportdata_"+id+"_"+fmt.Sprintln(entId), 1, -1)
+		if m[id] {
+			continue
+		}
+		m[id] = true
+		//  20210716  redis判重调整为调用判重中台接口  每一千个调用一次
+		infoIdList = append(infoIdList, id)
+		if len(infoIdList) > 1000 {
+			//	 调接口
+			rs, err5 := Post(url, map[string]string{
+				"personId": "0", // 没有使用这个参数
+				"infoId":   strings.Join(infoIdList, ","),
+				"entId":    fmt.Sprintf("%d", entId),
+				"isInsert": insertFlag,
+				"isEnt":    "true",
+			})
+			log.Println("响应结果：",rs)
+			if err5 != nil|| util.IntAll(rs["code"])!=0 {
+				log.Println("企业订阅数据导出接口判重失败", err5)
+				log.Println("企业订阅数据导出接口判重失败rs:",rs)
+				log.Println("企业订阅数据导出接口判重失败rs[code]:",rs["code"])
+				log.Println("企业订阅数据导出接口判重失败code是否为0",util.IntAll(rs["code"])!=0)
+				log.Println("企业订阅数据导出接口判重失败", err5,"rs:",rs," rs[code]:",rs["code"]," ",util.IntAll(rs["code"]),"code是否为0",util.IntAll(rs["code"])!=0)
+			} else {
+				log.Println("企业订阅数据导出")
+				// 置空
+				infoIdList = []string{}
+				// 本次数据累计
+				returnData := rs["data"].(map[string]interface{})
+				log.Println(newCount, "加之前")
+				newCount += int(returnData["newCount"].(float64))
+				log.Println(newCount, "加之后")
 			}
-		}(id)
+
+		}
 		if !isFirst {
 			delete(v, "_id")
 			v["entid"] = entId
@@ -70,9 +88,36 @@ func GetEntDataExportCount(_id string, entId, entUserId, limitNum, current int,
 			v["createtime"] = time.Now().Unix()
 		}
 	}
+	if len(infoIdList) > 0 {
+		rs, err5 := Post(url, map[string]string{
+			"personId": "0", // 没有使用这个参数
+			"infoId":   strings.Join(infoIdList, ","),
+			"entId":    fmt.Sprintf("%d", entId),
+			"isInsert": insertFlag,
+			"isEnt":    "true",
+		})
+		log.Println(rs)
+		if err5 != nil|| util.IntAll(rs["code"])!=0{
+			log.Println("企业订阅数据导出接口判重失败", err5)
+			log.Println("企业订阅数据导出接口判重失败rs:",rs)
+			log.Println("企业订阅数据导出接口判重失败rs[code]:",rs["code"])
+			log.Println("企业订阅数据导出接口判重失败code是否为0",util.IntAll(rs["code"])!=0)
+			log.Println("企业订阅数据导出接口判重失败", err5,"rs:",rs," rs[code]:",rs["code"]," ",util.IntAll(rs["code"]),"code是否为0",util.IntAll(rs["code"])!=0)
+		} else {
+			log.Println("企业订阅数据导出")
+			// 置空
+			infoIdList = []string{}
+			// 本次数据累计
+			returnData := rs["data"].(map[string]interface{})
+			log.Println(newCount, "加之前")
+			newCount += int(returnData["newCount"].(float64))
+			log.Println(newCount, "加之后")
+
+		}
+	}
 	searchsWaitGroup.Wait()
 	log.Println("企业数据导出--数据遍历完成")
-	newCount = len(newCountPool)
+	//newCount = len(newCountPool)
 	log.Println("new", newCount)
 	data = res
 	return
@@ -278,3 +323,27 @@ func FormatExportDatas(data *[]map[string]interface{}, webdomain string, dataTyp
 //	}
 //	return &res, nil
 //}
+
+func Post(url string, form map[string]string) (data map[string]interface{}, err error) {
+	str := ""
+	for k, v := range form {
+		str += "&" + k + "=" + v
+	}
+	//log.Println(str)
+	res, err1 := http.Post(url, "application/x-www-form-urlencoded", strings.NewReader(str))
+	log.Println(res)
+	if err1 != nil {
+		log.Println("post err:", err1.Error())
+		return nil, err1
+
+	} else if res.Body != nil {
+		defer res.Body.Close()
+		bs, _ := ioutil.ReadAll(res.Body)
+		err2 := json.Unmarshal(bs, &data)
+		if err2 != nil {
+			return nil, err2
+		}
+
+	}
+	return data, nil
+}

src/jfw/public/recomKws.go

@@ -0,0 +1,115 @@
+package public
+
+import (
+	"math/rand"
+	. "qfw/util"
+	"sort"
+	"strings"
+	"sync"
+	"time"
+
+	. "github.com/thinxer/go-word2vec"
+)
+
+var RecomKws = &recomKws{
+	reqPool: make(chan bool, 5),
+}
+
+func init() {
+	RecomKws.model, _ = Load("./zb.bin")
+}
+
+type recomKws struct {
+	reqPool chan bool
+	model   *Model
+}
+
+func (rk *recomKws) GetRecomKws(value string, count int) []*map[string]interface{} {
+	rk.reqPool <- true
+	defer func() {
+		<-rk.reqPool
+	}()
+	recomPool := make(chan bool, 5)
+	wait := &sync.WaitGroup{}
+	lock := &sync.Mutex{}
+	maxCount := count * 3
+	if maxCount > 100 {
+		maxCount = 100
+	}
+	keys := strings.Split(value, " ")
+	wordMap := map[string]bool{}
+	randomNum := rk.generateRandomNumber(maxCount, count)
+	keyMap := map[string]bool{}
+	allKeyMap := map[string]bool{}
+	for _, key := range keys {
+		for _, v := range strings.Split(key, "+") {
+			v = strings.TrimSpace(v)
+			if v == "" {
+				continue
+			}
+			allKeyMap[v] = true
+		}
+	}
+	sl := &ComSortList{
+		SortKeys: []*ComSortKey{
+			&ComSortKey{
+				Keys:  []string{"sim"},
+				Order: -1,
+				Type:  "float",
+			},
+		},
+		List: []*map[string]interface{}{},
+	}
+	for _, key := range keys {
+		key = strings.TrimSpace(key)
+		if keyMap[key] {
+			continue
+		}
+		keyMap[key] = true
+		recomPool <- true
+		wait.Add(1)
+		go func(v string) {
+			defer func() {
+				<-recomPool
+				wait.Done()
+			}()
+			//获取随机数
+			pw, _ := rk.model.MostSimilar(strings.Split(v, "+"), []string{}, maxCount)
+			for k, p := range pw {
+				p.Word = strings.TrimSpace(p.Word)
+				if p.Word == "" || !randomNum[k] || allKeyMap[p.Word] || len([]rune(p.Word)) == 1 {
+					continue
+				}
+				if strings.HasSuffix(p.Word, "路") || DealString(p.Word) {
+					continue
+				}
+				lock.Lock()
+				if !wordMap[p.Word] {
+					sl.List = append(sl.List, &map[string]interface{}{
+						"sim":  p.Sim,
+						"word": p.Word,
+					})
+				}
+				wordMap[p.Word] = true
+				lock.Unlock()
+			}
+		}(key)
+	}
+	wait.Wait()
+	sort.Sort(sl)
+	if len(sl.List) > 100 {
+		return sl.List[:100]
+	}
+	return sl.List
+}
+
+//随机数查询
+func (rk *recomKws) generateRandomNumber(max int, count int) map[int]bool {
+	nums := map[int]bool{}
+	//随机数生成器，加入时间戳保证每次生成的随机数不一样
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
+	for len(nums) < count {
+		nums[r.Intn(max)] = true
+	}
+	return nums
+}

src/web/staticres/vipsubscribe/css/public.css

@@ -3,6 +3,10 @@
   display: none;
 }
 
+[v-cloak] {
+  display: none!important;
+}
+
 html,
 body {
   width: 100%;

src/web/staticres/vipsubscribe/js/keyWord.js

@@ -38,6 +38,23 @@ var vm = new Vue({
     selectedCount: function () {
       var selectedArr = this.getSelectedArr()
       return selectedArr.length
+    },
+    totalKeywordsCount: function () {
+      var count = 0
+      this.filter.allKeywordsList.forEach(function (item) {
+        if (item.matchway == 1) {
+          // 模糊匹配
+          var key = item.key
+          if (Array.isArray(item.appendkey)) {
+            key = key.concat(item.appendkey)
+          }
+          count += key.length
+        } else {
+          // 精准匹配(matchway：0/undefined)
+          count++
+        }
+      })
+      return count
     }
   },
   created: function () {
@@ -348,7 +365,6 @@ var vm = new Vue({
     getGroupIndexWithGroupName: function (gn) {
       var groupIndex = -1
       this.keywordsGroupList.forEach(function(item, index) {
-        console.log(item)
         if (gn === item.s_item) {
           groupIndex = index
         }

src/web/staticres/vipsubscribe/js/keyword-info.js

@@ -49,8 +49,31 @@ var vm = new Vue({
   computed: {
     tooLittleTipShow: function () {
       return this.pInfo.pushCount < 30
+    },
+    // 监听关键词和匹配方式变化
+    needGetRecList: function () {
+      return {
+        key: this.keyInfo.key,
+        matchWay: this.keyInfo.matchWay
+      }
+    },
+    // 监听关键词、匹配方式和排除词变化
+    keyInfoChange: function () {
+      return {
+        key: this.keyInfo.key,
+        notKey: this.keyInfo.notKey,
+        matchWay: this.keyInfo.matchWay
+      }
     }
   },
+  watch: {
+    needGetRecList: utils.debounce(function (newVal, oldVal) {
+      this.getKeyRecommend()
+    }, 2000),
+    keyInfoChange: utils.debounce(function () {
+      this.getPushCount()
+    }, 2000)
+  },
   created: function () {
     // 获取url参数
     var type = utils.getParam('type')
@@ -67,9 +90,8 @@ var vm = new Vue({
     this.getKeywordsGroupList({
       needLoading: true,
       callback: function () {
-        this.getKeyRecommend()
-        if (this.pInfo.editType === 'edit') {
-          this.getPushCount()
+        if (this.pInfo.editType === 'add') {
+          this.getKeyRecommend()
         }
       }.bind(this)
     })
@@ -105,31 +127,16 @@ var vm = new Vue({
       return this.$dialog.confirm(defaultConf)
     },
     getPushCount: function () {
-      var groupInfo = {
-        name: '',
-        kIndex: -1
-      }
-      if (this.pInfo.editType === 'add') {
-        
-      } else if (this.pInfo.editType === 'edit') {
-        groupInfo.name = this.keywordsGroupList[this.pInfo.gIndex].s_item
-        groupInfo.kIndex = this.pInfo.kIndex
-      } else {
-        return
-      }
-
-      this.getPushCountConfirmed(groupInfo)
-    },
-    getPushCountConfirmed: function (groupInfo) {
       var _this = this
       // 全部关键词-推送结果预览总数参数：item值为空 index值为-1
       // 某个关键词组-推送结果预览总数参数：item值不为空 index值大于等于0
       $.ajax({
-        url: '/subscribepay/afterPay/getPushCount',
+        url: '/subscribepay/afterPay/keyset/getPushCount',
         type: 'POST',
         data: {
-          item: groupInfo.name, // 关键词组所在分类名称
-          index: groupInfo.kIndex // 关键词组所在分类下的索引位置
+          key: this.keyInfo.key.trim().replace(/\s+/g, ' '),
+          notkey: this.getNotKeyArr().join(' '),
+          matchway: this.keyInfo.matchWay
         },
         success: function (res) {
           if (res && res.count) {
@@ -207,7 +214,8 @@ var vm = new Vue({
         groupNameList.push({
           name: item.s_item, // 分类名
           checked: false,
-          count: count // 分类下有多少个关键词
+          count: count, // 分类下有多少个关键词
+          gIndex: index
         })
       })
       return groupNameList
@@ -290,7 +298,6 @@ var vm = new Vue({
       })
       return groupInfo
     },
-    getPageKeyInfoFromGroupList: function () {},
     delThisKey: function () {
       var _this = this
       this.showDialog({
@@ -430,7 +437,7 @@ var vm = new Vue({
         pageType: 'keyWords',
         actionType: 'SK',
         match_way: this.keyInfo.matchWay,
-        kws_name: this.keyInfo.key.trim(),
+        kws_name: this.keyInfo.key.trim().replace(/\s+/g, ' '),
         not_kws: this.getNotKeyArr(),
         kwscount: this.allKeywordsList.length,
         classify_index: groupInfo.gIndex,
@@ -482,38 +489,66 @@ var vm = new Vue({
       if (this.pInfo.gIndex !== null && this.pInfo.gIndex !== undefined && this.pInfo.gIndex !== '') {
         // url中取到索引，可以直接用
         filterArr = this.keywordsGroupList[this.pInfo.gIndex].a_key
+        filterArr = JSON.parse(JSON.stringify(filterArr))
+        if (this.pInfo.editType === 'edit') {
+          filterArr.splice(this.pInfo.kIndex, 1)
+          filterArr.push({
+            key: this.keyInfo.key.split(/\s+/),
+            matchway: this.keyInfo.matchWay
+          })
+        }
       } else {
-        filterArr = this.filterKeywordsList('未分类')
+        filterArr = this.allKeywordsList
       }
 
       filterArr.forEach(function (item) {
-        if (item.key) {
-          if (item.key instanceof Array) {
-            keysArr.push(item.key.join('+'))
-          } else {
-            keysArr.push(item.key)
-          }
+        // 关键词1：信息 技术   关键词2：软件
+        // 模糊匹配，参数是：信息 技术 软件
+        // 精准匹配，参数是：信息+技术 软件
+        var key = Array.isArray(item.key) ? item.key : []
+        if (Array.isArray(item.appendkey)) {
+          key = key.concat(item.appendkey)
+        }
+
+        if (item.matchway == 1) {
+          // 模糊匹配
+          keysArr.push(key.join(' '))
+        } else {
+          // 精准匹配
+          keysArr.push(key.join('+'))
         }
       })
 
       if (keysArr.length === 0) return
 
       var fetchData = {
-        count: 20,
+        count: 20, // 最少需要多少条数据
         value: utils.unique(keysArr).join(' ')
       }
+
+      if (this.recListState.loading) return
+      this.recListState.loading = true
+
       $.ajax({
         url: '/member/getRecomKWs',
         type: 'POST',
         data: fetchData,
         success: function (r) {
+          _this.recListState.loading = false
           if (r && r instanceof Array && r.length !== 0) {
             _this.loadKeyRecommend(r)
           }
+        },
+        complete: function () {
+          _this.recListState.loading = false
         }
       })
     },
     loadKeyRecommend: function (list) {
+      // 页码初始化
+      this.recListState.pageNum = 1
+      this.recListState.total = 0
+
       var afterFilterArr = this.filterKeyRecommend(list)
       this.recommendTags = afterFilterArr.slice(0, this.conf.recommendTagsCount)
 

src/web/templates/weixin/vipsubscribe/keyWord.html

@@ -86,7 +86,7 @@
                     <span class="button-text">订阅关键词</span>
                 </button>
                 <div class="keywords-count">
-                    关键词添加数量：<span class="highlight-text">${ filter.allKeywordsList.length }</span> / ${ conf.keywordMax }
+                    关键词添加数量：<span class="highlight-text">${ totalKeywordsCount }</span> / ${ conf.keywordMax }
                 </div>
           </div>
         </div>
@@ -108,7 +108,7 @@
             <div class="j-button-group" v-else>
                 <button class="j-button-confirm" @click="addKeyWord" :disabled="filter.allKeywordsList.length >= conf.keywordMax">
                     <span class="info-text">新增关键词</span>
-                    <span class="sub-text">（${ filter.allKeywordsList.length } / ${ conf.keywordMax }）</span>
+                    <span class="sub-text">（${ totalKeywordsCount } / ${ conf.keywordMax }）</span>
                 </button>
             </div>
         </div>