|
@@ -13,6 +13,7 @@ import (
|
|
"qfw/util/redis"
|
|
"qfw/util/redis"
|
|
"strconv"
|
|
"strconv"
|
|
"strings"
|
|
"strings"
|
|
|
|
+ "sync"
|
|
"time"
|
|
"time"
|
|
|
|
|
|
"github.com/SKatiyar/qr"
|
|
"github.com/SKatiyar/qr"
|
|
@@ -35,6 +36,7 @@ var industrylist map[string][]string
|
|
var sortArray []string
|
|
var sortArray []string
|
|
var PCS_index map[string]interface{}
|
|
var PCS_index map[string]interface{}
|
|
var PCS_time int
|
|
var PCS_time int
|
|
|
|
+var PCSLock = &sync.Mutex{}
|
|
|
|
|
|
//
|
|
//
|
|
func init() {
|
|
func init() {
|
|
@@ -46,7 +48,9 @@ func init() {
|
|
time.Sleep(time.Second * 5)
|
|
time.Sleep(time.Second * 5)
|
|
PCS_task()
|
|
PCS_task()
|
|
}()
|
|
}()
|
|
|
|
+ PCSLock.Lock()
|
|
PCS_index = map[string]interface{}{}
|
|
PCS_index = map[string]interface{}{}
|
|
|
|
+ PCSLock.Unlock()
|
|
}
|
|
}
|
|
|
|
|
|
//定时清理搜索列表页 从redis获取存入内存中的数据
|
|
//定时清理搜索列表页 从redis获取存入内存中的数据
|
|
@@ -60,7 +64,9 @@ func PCS_task() {
|
|
select {
|
|
select {
|
|
case <-timer.C:
|
|
case <-timer.C:
|
|
{
|
|
{
|
|
|
|
+ PCSLock.Lock()
|
|
PCS_index = map[string]interface{}{}
|
|
PCS_index = map[string]interface{}{}
|
|
|
|
+ PCSLock.Unlock()
|
|
timer.Reset(time.Hour * time.Duration(PCS_time))
|
|
timer.Reset(time.Hour * time.Duration(PCS_time))
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -75,6 +81,8 @@ func PCS_list(page_type string) interface{} {
|
|
if page_type == "" {
|
|
if page_type == "" {
|
|
_page_type = "page_index"
|
|
_page_type = "page_index"
|
|
}
|
|
}
|
|
|
|
+ PCSLock.Lock()
|
|
|
|
+ defer PCSLock.Unlock()
|
|
if PCS_index[_page_type] == nil {
|
|
if PCS_index[_page_type] == nil {
|
|
PCS_index[_page_type] = Newbids(page_type)[0]
|
|
PCS_index[_page_type] = Newbids(page_type)[0]
|
|
}
|
|
}
|