|
|
@@ -258,38 +258,38 @@ func (c *CustomerRule) ProductData() {
|
|
|
// var n int
|
|
|
// 小于1000的直接查
|
|
|
// if totalCount < 1000 {
|
|
|
- var times = 0
|
|
|
- var times2 = 0
|
|
|
- for {
|
|
|
- listLen := redis.GetInt("session", "es_status")
|
|
|
- if listLen == 0 {
|
|
|
- log.Println("es空闲！")
|
|
|
- break
|
|
|
- } else if times > 10 {
|
|
|
- err = errors.New("系统繁忙，请稍后再试")
|
|
|
- break
|
|
|
- } else {
|
|
|
- log.Println("es繁忙，", listLen)
|
|
|
- }
|
|
|
- times += 2
|
|
|
- time.Sleep(2 * time.Second)
|
|
|
- }
|
|
|
- for {
|
|
|
- listLens := int(redis.LLEN("datag", "jyqyfw_es_query"))
|
|
|
- if listLens < 2 {
|
|
|
- redis.RPUSH("datag", "jyqyfw_es_query", 1)
|
|
|
- err, count = UtilEsFind1(*tag)
|
|
|
- redis.LPOP("datag", "jyqyfw_es_query")
|
|
|
- break
|
|
|
- } else if times2 > 10 {
|
|
|
- err = errors.New("系统繁忙，请稍后再试")
|
|
|
- break
|
|
|
- } else {
|
|
|
- log.Println("企业级服务es进程数过多，", listLens)
|
|
|
- }
|
|
|
- times2 += 2
|
|
|
- time.Sleep(2 * time.Second)
|
|
|
- }
|
|
|
+ // var times = 0
|
|
|
+ // var times2 = 0
|
|
|
+ // for {
|
|
|
+ // listLen := redis.GetInt("session", "es_status")
|
|
|
+ // if listLen == 0 {
|
|
|
+ // log.Println("es空闲！")
|
|
|
+ // break
|
|
|
+ // } else if times > 10 {
|
|
|
+ // err = errors.New("系统繁忙，请稍后再试")
|
|
|
+ // break
|
|
|
+ // } else {
|
|
|
+ // log.Println("es繁忙，", listLen)
|
|
|
+ // }
|
|
|
+ // times += 2
|
|
|
+ // time.Sleep(2 * time.Second)
|
|
|
+ // }
|
|
|
+ // for {
|
|
|
+ // listLens := int(redis.LLEN("datag", "jyqyfw_es_query"))
|
|
|
+ // if listLens < 2 {
|
|
|
+ // redis.RPUSH("datag", "jyqyfw_es_query", 1)
|
|
|
+ err, count = UtilEsFind1(*tag)
|
|
|
+ // redis.LPOP("datag", "jyqyfw_es_query")
|
|
|
+ // break
|
|
|
+ // } else if times2 > 10 {
|
|
|
+ // err = errors.New("系统繁忙，请稍后再试")
|
|
|
+ // break
|
|
|
+ // } else {
|
|
|
+ // log.Println("企业级服务es进程数过多，", listLens)
|
|
|
+ // }
|
|
|
+ // times2 += 2
|
|
|
+ // time.Sleep(2 * time.Second)
|
|
|
+ // }
|
|
|
|
|
|
if err == nil {
|
|
|
rep = true
|
