getCusInfo

controllers/book/book.go

@@ -216,8 +216,14 @@ func (c *BookController) ExcelInpuData() {
 
 	for _, sheet := range xlFile.Sheets {
 		for _, row := range sheet.Rows {
-			total, _ := row.Cells[2].Int()
-			Days, _ := row.Cells[3].Int()
+			total, err := row.Cells[2].Int()
+			if err != nil {
+				c.ResponseError(err)
+			}
+			Days, err := row.Cells[3].Int()
+			if err != nil {
+				c.ResponseError(err)
+			}
 			var book = model.TaBook{
 				CaseId:      caseId,
 				BookBarcode: row.Cells[0].String(),
@@ -230,7 +236,7 @@ func (c *BookController) ExcelInpuData() {
 				IsRecommend: 0,
 				Price:       "0",
 			}
-			err := c.serv.AuthBook(book)
+			err = c.serv.AuthBook(book)
 			if err != nil {
 				c.ResponseError(err)
 			}
@@ -301,3 +307,12 @@ func (c *BookController) GetBookById() {
 	}
 	c.ResponseJSON(list)
 }
+
+func (c *BookController) GetCustomerBorrowInfo() {
+	customerInfo := c.GetString(":customerInfo")
+	list, err := c.serv.GetCustomerBorrowInfo(customerInfo)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}

models/book/book.go

@@ -505,3 +505,29 @@ func (m *BookDAO) IsBarcodeExist(barcode, caseId string) (int, error) {
 	err := m.db.Sql(sql).Find(&book)
 	return len(book), err
 }
+
+type CustomerInfo struct {
+	Name      string
+	Phone     string
+	BorrowNum int
+	LateNum   int
+	IsLate    string
+}
+
+func (m *BookDAO) GetCustomerBorrowInfo(customerInfo string) (*CustomerInfo, error) {
+	var customer []CustomerInfo
+	sql := `SELECT
+	a.NAME,
+	a.phone ,
+	(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 
+	where a.phone = '` + customerInfo + `' OR a.barcode = '` + customerInfo + `'
+GROUP BY a.phone`
+	err := m.db.SQL(sql).Find(&customer)
+	if len(customer) <= 0 {
+		return nil, err
+	}
+	return &customer[0], err
+}

routers/common.go

@@ -363,6 +363,7 @@ func getCommonRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/book/excel", &book.BookController{}, "post:ExcelInpuData"),
 		beego.NSRouter("/book/cancel/:recordId", &book.BookController{}, "put:CancelReserve"),
 		beego.NSRouter("/book/:bookId", &book.BookController{}, "delete:DeleteBook"),
+		beego.NSRouter("/book/customer/:customerInfo", &book.BookController{}, "get:GetCustomerBorrowInfo"),
 
 		// booktype 图书类型管理
 		beego.NSRouter("/booktype", &booktype.BooktypeController{}, "get:GetList"),

service/book/book.go

@@ -2,7 +2,6 @@ package book
 
 import (
 	"errors"
-	"fmt"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/book"
 	"spaceofcheng/services/models/customer"
@@ -416,64 +415,72 @@ func (s *BookServ) DeleteBook(bookId string) error {
 	return nil
 }
 
-func (s *BookServ) SendMessageToCustomer() error {
-	weekList, err := s.dao.GetAllOneWeekRecord()
-	if err != nil {
-		utils.LogError("发送消息失败失败: " + err.Error())
-		return errors.New("发送消息失败失败")
-	}
-	lateList, err := s.dao.GetAllLateRecord()
-	if err != nil {
-		utils.LogError("发送消息失败失败: " + err.Error())
-		return errors.New("发送消息失败失败")
-	}
-	if len(weekList) > 0 {
-		for i := 0; i < len(weekList); i++ {
-			userMap, err := s.dao.GetUserMappingById(weekList[i].CustomerId)
-			if err != nil {
-				utils.LogError("发送消息失败失败: " + err.Error())
-				return errors.New("发送消息失败失败")
-			}
-			message := utils.Message{
-				To: utils.ClientID{ID: userMap.Openid},
-				Data: map[string]interface{}{
-					"orgid": weekList[i].OrgId,
-					"tplid": "6WoxRkdXrRyF0T7Kc4PU5CjkpzAPWKKsA6wBLAGSQQg",
-					"data": map[string]string{
-						"first":    "您好，您借阅图书即将逾期，请及时归还。",
-						"keyword1": weekList[i].BookName,
-						"keyword2": weekList[i].BorrowDate.Format("2006-01-02"),
-						"keyword3": weekList[i].EndDate.Format("2006-01-02"),
-						"remark":   fmt.Sprintf("避免影响您下次借阅，请及时归还至", weekList[i].CaseName),
-					},
-				},
-			}
-			go utils.SendWechat(message)
-		}
-	}
-	if len(lateList) > 0 {
-		for i := 0; i < len(lateList); i++ {
-			userMap, err := s.dao.GetUserMappingById(lateList[i].CustomerId)
-			if err != nil {
-				utils.LogError("发送消息失败失败: " + err.Error())
-				return errors.New("发送消息失败失败")
-			}
-			message := utils.Message{
-				To: utils.ClientID{ID: userMap.Openid},
-				Data: map[string]interface{}{
-					"orgid": lateList[i].OrgId,
-					"tplid": "ID:Be0a25NMb3fzLtNaaQn_YOuECQDnlCs1es5aVvfwRhs",
-					"data": map[string]string{
-						"first":    "您好，您借阅图书的时间已经逾期2天",
-						"keyword1": lateList[i].BookName,
-						"keyword2": weekList[i].BorrowDate.Format("2006-01-02"),
-						"keyword3": weekList[i].EndDate.Format("2006-01-02"),
-						"remark":   fmt.Sprintf("避免影响您下次借阅，请及时归还至", lateList[i].CaseName),
-					},
-				},
-			}
-			go utils.SendWechat(message)
-		}
+// func (s *BookServ) SendMessageToCustomer() error {
+// 	weekList, err := s.dao.GetAllOneWeekRecord()
+// 	if err != nil {
+// 		utils.LogError("发送消息失败失败: " + err.Error())
+// 		return errors.New("发送消息失败失败")
+// 	}
+// 	lateList, err := s.dao.GetAllLateRecord()
+// 	if err != nil {
+// 		utils.LogError("发送消息失败失败: " + err.Error())
+// 		return errors.New("发送消息失败失败")
+// 	}
+// 	if len(weekList) > 0 {
+// 		for i := 0; i < len(weekList); i++ {
+// 			userMap, err := s.dao.GetUserMappingById(weekList[i].CustomerId)
+// 			if err != nil {
+// 				utils.LogError("发送消息失败失败: " + err.Error())
+// 				return errors.New("发送消息失败失败")
+// 			}
+// 			message := utils.Message{
+// 				To: utils.ClientID{ID: userMap.Openid},
+// 				Data: map[string]interface{}{
+// 					"orgid": weekList[i].OrgId,
+// 					"tplid": "6WoxRkdXrRyF0T7Kc4PU5CjkpzAPWKKsA6wBLAGSQQg",
+// 					"data": map[string]string{
+// 						"first":    "您好，您借阅图书即将逾期，请及时归还。",
+// 						"keyword1": weekList[i].BookName,
+// 						"keyword2": weekList[i].BorrowDate.Format("2006-01-02"),
+// 						"keyword3": weekList[i].EndDate.Format("2006-01-02"),
+// 						"remark":   fmt.Sprintf("避免影响您下次借阅，请及时归还至", weekList[i].CaseName),
+// 					},
+// 				},
+// 			}
+// 			go utils.SendWechat(message)
+// 		}
+// 	}
+// 	if len(lateList) > 0 {
+// 		for i := 0; i < len(lateList); i++ {
+// 			userMap, err := s.dao.GetUserMappingById(lateList[i].CustomerId)
+// 			if err != nil {
+// 				utils.LogError("发送消息失败失败: " + err.Error())
+// 				return errors.New("发送消息失败失败")
+// 			}
+// 			message := utils.Message{
+// 				To: utils.ClientID{ID: userMap.Openid},
+// 				Data: map[string]interface{}{
+// 					"orgid": lateList[i].OrgId,
+// 					"tplid": "ID:Be0a25NMb3fzLtNaaQn_YOuECQDnlCs1es5aVvfwRhs",
+// 					"data": map[string]string{
+// 						"first":    "您好，您借阅图书的时间已经逾期2天",
+// 						"keyword1": lateList[i].BookName,
+// 						"keyword2": weekList[i].BorrowDate.Format("2006-01-02"),
+// 						"keyword3": weekList[i].EndDate.Format("2006-01-02"),
+// 						"remark":   fmt.Sprintf("避免影响您下次借阅，请及时归还至", lateList[i].CaseName),
+// 					},
+// 				},
+// 			}
+// 			go utils.SendWechat(message)
+// 		}
+// 	}
+// 	return nil
+// }
+func (s *BookServ) GetCustomerBorrowInfo(customerInfo string) (*book.CustomerInfo, error) {
+	customer, err := s.dao.GetCustomerBorrowInfo(customerInfo)
+	if err != nil {
+		utils.LogError("获取用户信息失败: " + err.Error())
+		return nil, errors.New("获取用户信息失败")
 	}
-	return nil
+	return customer, nil
 }