common

controllers/book/book.go

@@ -1,10 +1,13 @@
 package book
 
 import (
+	"io/ioutil"
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/book"
 	"strings"
+
+	"github.com/tealeg/xlsx"
 )
 
 // CaseController 信息
@@ -75,6 +78,7 @@ func (c *BookController) GetMineRecord() {
 	c.ResponseJSON(list)
 }
 
+// GetInStockChangeByBookId 获取图书盘点列表
 func (c *BookController) GetInStockChangeByBookId() {
 	page, _ := c.GetInt("page")
 	pagesize, _ := c.GetInt("pagesize")
@@ -88,7 +92,7 @@ func (c *BookController) GetInStockChangeByBookId() {
 
 }
 
-// 新增库存盘点
+// AddChangeRecord 新增库存盘点
 func (c *BookController) AddChangeRecord() {
 	change := model.TaInStockChange{}
 	if err := c.ParseForm(&change); err != nil {
@@ -104,6 +108,8 @@ func (c *BookController) AddChangeRecord() {
 
 	c.ResponseJSON("添加成功")
 }
+
+// BorrowBook 借书
 func (c *BookController) BorrowBook() {
 	bookIds := c.GetString(":bookIds")
 	customerId := c.GetString(":customerId")
@@ -119,6 +125,8 @@ func (c *BookController) BorrowBook() {
 	}
 	c.ResponseJSON("借阅成功")
 }
+
+// ReturnBook 还书
 func (c *BookController) ReturnBook() {
 	bookIds := c.GetString(":borrowIds")
 	bookId := strings.Split(bookIds, ",")
@@ -140,6 +148,8 @@ func (c *BookController) ReserveBook() {
 	}
 	c.ResponseJSON(record)
 }
+
+// GetCustomerReturnList 获取用户还书记录
 func (c *BookController) GetCustomerReturnList() {
 	customerInfo := c.GetString(":customerInfo")
 	caseIDs := c.GetString("caseid")
@@ -156,24 +166,77 @@ func (c *BookController) GetCustomerReturnList() {
 	c.ResponseJSON(list)
 }
 
-// func (c *BookController)ExcelInpuData(){
+// ExcelInpuData EXCEL导入数据
+func (c *BookController) ExcelInpuData() {
+	caseId := c.GetString("caseId")
+	org := c.Context.Get("org").(model.SysOrg)
+	file, _, err := c.GetFile("excel")
+	if err != nil {
+		c.ResponseError(err)
+	}
+	defer file.Close()
 
-// 	file, _, err := c.GetFile("excel")
-// 	if err != nil {
-// 		c.ResponseError(err)
-// 	}
-// 	defer file.Close()
+	fileBytes, err := ioutil.ReadAll(file)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	xlFile, err := xlsx.OpenBinary(fileBytes)
+	if err != nil {
+		c.ResponseError(err)
+	}
 
-// 	fileBytes, err := ioutil.ReadAll(file)
-// 	if err != nil {
-// 		c.ResponseError(err)
-// 	}
-// 	excel, err : = xlsx.OpenBinary(fileBytes)
-// 	if err != nil {
-// 		c.ResponseError(err)
-// 	}
+	for _, sheet := range xlFile.Sheets {
+		for _, row := range sheet.Rows {
+			total, _ := row.Cells[2].Int()
+			Days, _ := row.Cells[3].Int()
+			var book = model.TaBook{
+				CaseId:      caseId,
+				BookBarcode: row.Cells[0].String(),
+				BookName:    row.Cells[1].String(),
+				InStock:     total,
+				LeftNum:     total,
+				BorrowNum:   0,
+				BorrowDays:  Days,
+				OrgId:       org.OrgId,
+				IsRecommend: 0,
+			}
+			_, err := c.serv.AddBook(book)
+			if err != nil {
+				c.ResponseError(err)
+			}
 
-// 	for _,sheet:=rang excel.Sheets{
+		}
+	}
+	c.ResponseJSON("添加成功")
+}
 
-// 	}
-// }
+// GetCustomerByCustomerInfo 根据用户手机或条形码获取用户信息
+func (c *BookController) GetCustomerByCustomerInfo() {
+	customerInfo := c.GetString(":customerInfo")
+	customer, err := c.serv.GetCustomerByCustomerInfo(customerInfo)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customer)
+}
+
+// GetRecordList 获取借书，预约记录列表
+func (c *BookController) GetRecordList() {
+	borrowStatus := c.GetString("borrowstatus")
+	caseIDs := c.GetString("caseid")
+	if caseIDs == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseIDs = c.GetCaseIDs(cases)
+	}
+	customerName := c.GetString("customername")
+	customerPhone := c.GetString("customerphone")
+	bookName := c.GetString("bookname")
+	barcode := c.GetString("barcode")
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	list, err := c.serv.GetRecordList(borrowStatus, caseIDs, customerName, customerPhone, bookName, barcode, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}

models/book/book.go

@@ -157,6 +157,36 @@ FROM
 
 }
 
+func (m *BookDAO) GetRecordListCount(borrowStatus, caseid, customerName, customerPhone, bookName, barcode string) (int, error) {
+	var record []BorrowRecord
+	sql := `SELECT
+	a.*,
+	b.book_name,
+	b.book_barcode
+FROM
+	ta_book_borrow_record a
+	INNER JOIN ta_book b ON a.book_id = b.book_id
+	where a.case_id in('` + strings.Replace(caseid, ",", "','", -1) + `')`
+	if borrowStatus != "" {
+		sql += ` and a.borrow_status = '` + borrowStatus + `' `
+	}
+	if customerName != "" {
+		sql += ` and a.customer_name = '` + customerName + `' `
+	}
+	if customerPhone != "" {
+		sql += ` and a.customer_phone ='` + customerPhone + `' `
+	}
+	if bookName != "" {
+		sql += ` and b.book_name = '` + bookName + `' `
+	}
+	if barcode != "" {
+		sql += ` and b.book_barcode = '` + barcode + `'`
+	}
+	err := m.db.Sql(sql).Find(&record)
+	return len(record), err
+
+}
+
 func (m *BookDAO) GetBookRecommendList(caseid string, page, pageSize int) ([]model.TaBook, error) {
 	var book []model.TaBook
 	sql := `select * from ta_book where status = '` + strconv.Itoa(models.STATUS_NORMAL) + `'
@@ -356,3 +386,22 @@ WHERE
 	err := m.db.Sql(sql).Find(&record)
 	return len(record), err
 }
+func (m *BookDAO) GetCustomerByCustomerInfo(customerInfo string) (*model.TaCustomer, error) {
+	var customer []model.TaCustomer
+	sql := `select * from ta_customer a 
+	 where a.customer_phone = '` + customerInfo + `' 
+	 OR d.barcode = '` + customerInfo + `' )`
+	err := m.db.Sql(sql).Find(&customer)
+	if len(customer) <= 0 {
+		return nil, err
+	}
+	return &customer[0], err
+
+}
+func (m *BookDAO) GetAllRecord() ([]model.TaBookBorrowRecord, error) {
+	var record []model.TaBookBorrowRecord
+	sql := `select * from ta_book_borrow_record where 
+	a.borrow_status IN ( '` + models.BORROW_TYPE_BORROWED + `', '` + models.BORROW_TYPE_LATE + `' )`
+	err := m.db.Sql(sql).Find(&record)
+	return record, err
+}

models/model/ta_book.go

@@ -16,6 +16,7 @@ type TaBook struct {
 	InStock         int       `xorm:"INT(11)"`
 	LeftNum         int       `xorm:"INT(11)"`
 	BorrowNum       int       `xorm:"INT(11)"`
+	BorrowDays      int       `xorm:"INT(11)"`
 	BookDescription string    `xorm:"TEXT"`
 	IsRecommend     int       `xorm:"SMALLINT(6)"`
 	Status          int       `xorm:"SMALLINT(6)"`

routers/common.go

@@ -3,6 +3,7 @@ package routers
 import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/bodychecklist"
+	"spaceofcheng/services/controllers/book"
 	"spaceofcheng/services/controllers/calendar"
 	"spaceofcheng/services/controllers/card"
 	"spaceofcheng/services/controllers/cases"
@@ -345,5 +346,16 @@ func getCommonRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/calendar/:calendarId/:imgType", &calendar.CalendarController{}, "get:DownloadImg"),
 		beego.NSRouter("/calendar/:calendarIds", &calendar.CalendarController{}, "put:ChangeMakeStaus"),
 		beego.NSRouter("/calendar/excel", &calendar.CalendarController{}, "get:GetCalendarListExcel"),
+
+		// book 图书管理
+		beego.NSRouter("/book", &book.BookController{}, "get:GetBookList"),
+		beego.NSRouter("/book/record", &book.BookController{}, "get:GetRecordList"),
+		beego.NSRouter("/book/instock/:bookId", &book.BookController{}, "get:GetInStockChangeByBookId"),
+		beego.NSRouter("/book/change", &book.BookController{}, "post:AddChangeRecord"),
+		beego.NSRouter("/book/borrow/:bookIds/:customerId", &book.BookController{}, "put:BorrowBook"),
+		beego.NSRouter("/book/return/:borrowIds", &book.BookController{}, "post:ReturnBook"),
+		beego.NSRouter("/book/return/:customerInfo", &book.BookController{}, "get:GetCustomerReturnList"),
+		beego.NSRouter("/book/customer/:customerInfo", &book.BookController{}, "put:GetCustomerByCustomerInfo"),
+		beego.NSRouter("/book/excel", &book.BookController{}, "post:ExcelInpuData"),
 	)
 }

service/book/book.go

@@ -248,7 +248,11 @@ func (s *BookServ) ReturnBook(borrowId string) error {
 	if record == nil {
 		return errors.New("不存在的借阅信息")
 	}
-	record.BorrowStatus = models.BORROW_TYPE_RETURN
+	if record.BorrowStatus == models.BORROW_TYPE_LATE {
+		record.BorrowStatus = models.BORROW_TYPE_LATERETURN
+	} else {
+		record.BorrowStatus = models.BORROW_TYPE_RETURN
+	}
 	record.ReturnDate = time.Now()
 	_, err = s.dao.UpdateBookRecord(record)
 	if err != nil {
@@ -337,3 +341,34 @@ func (s *BookServ) ReserveBook(bookid string) (*model.TaBookBorrowRecord, error)
 	}
 	return &info, err
 }
+
+func (s *BookServ) GetCustomerByCustomerInfo(customerInfo string) (*model.TaCustomer, error) {
+	list, err := s.dao.GetCustomerByCustomerInfo(customerInfo)
+	if err != nil {
+		utils.LogError("获取用户信息失败：", err.Error())
+		return nil, errors.New("获取用户信息失败")
+	}
+	return list, nil
+}
+
+func (s *BookServ) GetRecordList(borrowStatus, caseid, customerName, customerPhone, bookName, barcode string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	list, err := s.dao.GetRecordList(borrowStatus, caseid, customerName, customerPhone, bookName, barcode, page, pageSize)
+	if err != nil {
+		utils.LogError("获取借书记录列表失败: " + err.Error())
+		return nil, errors.New("获取借书记录列表失败")
+	}
+	total, err := s.dao.GetRecordListCount(borrowStatus, caseid, customerName, customerPhone, bookName, barcode)
+	if err != nil {
+		utils.LogError("获取借书记录列表失败: " + err.Error())
+		return nil, errors.New("获取借书记录列表失败")
+	}
+	return map[string]interface{}{
+		"list":     list,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}