change

models/book/book.go

@@ -531,7 +531,7 @@ func (m *BookDAO) GetCustomerBorrowInfo(customerInfo string) (*CustomerInfo, err
 	(select count(1) from ta_book_borrow_record c WHERE borrow_status = '1' and c.customer_id = a.customer_id)as borrow_num,
 	(select count(1) from ta_book_borrow_record c WHERE borrow_status = '0' and c.customer_id = a.customer_id)as late_num
 FROM
-	ta_customer a INNER JOIN ta_book_borrow_record b on a.customer_id = b.customer_id 
+	ta_customer a LEFT JOIN ta_book_borrow_record b on a.customer_id = b.customer_id 
 	where a.phone = '` + customerInfo + `' OR a.barcode = '` + customerInfo + `'
 GROUP BY a.phone`
 	err := m.db.SQL(sql).Find(&customer)

models/customer/customer.go

@@ -65,7 +65,7 @@ func (m *CustomerDAO) CustWithWXList(phone, username, recommendname, begindate,
 	if enddate != "" {
 		query = query + ` AND t.create_date<'` + begindate + `'`
 	}
-	query = query + ` AND t.customer_name <> ''`
+	query = query + ` AND (t.customer_name <> '' and t.headimgurl <> '' and t.phone <>'')`
 
 	query = query + ` ORDER BY
 			t.create_date DESC limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
@@ -93,7 +93,7 @@ func (m *CustomerDAO) CustWithWXListCount(phone, username, recommendname, begind
 	}
 
 	if username != "" {
-		query += " and t.customer_name like '%" + username + "%'"
+		query += " and t.name like '%" + username + "%'"
 	}
 
 	if recommendname != "" {
@@ -107,7 +107,7 @@ func (m *CustomerDAO) CustWithWXListCount(phone, username, recommendname, begind
 	if enddate != "" {
 		query = query + ` AND t.create_date<'` + begindate + `'`
 	}
-
+	query = query + ` AND (t.customer_name <> '' and t.headimgurl <> '' and t.phone <>'')`
 	var custs []model.TaCustomer
 	err := m.db.Sql(query, models.STATUS_DEL).Find(&custs)
 

models/task.go

@@ -13,16 +13,17 @@ import (
 func InitTask() {
 	kernel := utils.NewKernel()
 	kernel.SetTask("sendmessage", SendMessageToCustomer)
-	timeStr := time.Now().Format("2006-01-02") + beego.AppConfig.String("job::sendmessagetime")
-	ten, _ := time.Parse(timeStr, "2006-01-02 15:04:05")
+	now := time.Now().Local()
+	timeStr := now.Format("2006-01-02") + " " + beego.AppConfig.String("job::sendmessagetime")
+	ten, _ := time.ParseInLocation("2006-01-02 15:04:05", timeStr, time.Local)
 	var tomorrow time.Time
-	if time.Now().Before(ten) {
+	if now.Before(ten) {
 		tomorrow = ten
 	} else {
 		tomorrow = ten.AddDate(0, 0, 1)
 	}
-	dur := tomorrow.Sub(time.Now())
-
+	dur := tomorrow.Sub(now)
+	beego.Error(dur)
 	kernel.StartTask("sendmessage", dur)
 }
 
@@ -53,8 +54,6 @@ WHERE
 	DATE_FORMAT( a.end_date, "%Y-%m-%d" ) = DATE_FORMAT( ( SELECT date_add( now( ), INTERVAL 1 WEEK ) ), "%Y-%m-%d" )
 	and a.borrow_status = '1'`
 	DBEngine.Sql(sql).Find(&weekList)
-	beego.Error("________________________sql", sql)
-	beego.Error("________________________weekList", weekList)
 	var lateList []TimeRecordList
 	sqlLate := `SELECT
 	a.*,
@@ -70,8 +69,6 @@ WHERE
 	DATE_FORMAT( now(), "%Y-%m-%d" ) = DATE_FORMAT( ( SELECT date_add( a.end_date, INTERVAL 2 DAY ) ), "%Y-%m-%d" )
 	and a.borrow_status = '0'`
 	DBEngine.Sql(sqlLate).Find(&lateList)
-	beego.Error("________________________sql", sqlLate)
-	beego.Error("________________________weekList", lateList)
 	// 发消息
 	if len(weekList) > 0 {
 		for i := 0; i < len(weekList); i++ {
@@ -96,6 +93,7 @@ WHERE
 				continue
 			}
 			utils.WxClientSingleton(weekList[i].OrgId, cert)
+			time.Sleep(5 * time.Second)
 			go utils.SendWechat(message)
 		}
 	}
@@ -122,10 +120,10 @@ WHERE
 				continue
 			}
 			utils.WxClientSingleton(weekList[i].OrgId, cert)
+			time.Sleep(5 * time.Second)
 			go utils.SendWechat(message)
 		}
 	}
 	timeNext, _ := time.ParseDuration("24h")
-	beego.Error("___________________timeNext", timeNext)
 	return timeNext
 }