盘点

models/book/book.go

@@ -150,3 +150,53 @@ func (m *BookDAO) GetBookRecommendList(caseid string, page, pageSize int) ([]mod
 	err := m.db.Sql(sql).Find(&book)
 	return book, err
 }
+
+type InStockChange struct {
+	model.TaInStockChange `xorm:"extends"`
+	RealName              string
+	BookName              string
+	InStock               int
+	LeftNum               int
+}
+
+func (m *BookDAO) GetInStockChangeByBookId(bookId string, page, pageSize int) ([]InStockChange, error) {
+	var change []InStockChange
+	sql := `SELECT
+	a.*,
+	b.book_name,
+	b.left_num,
+	b.in_stock,
+	c.real_name
+FROM
+	ta_in_stock_change a
+	INNER JOIN ta_book b ON a.book_id = b.book_id
+	INNER JOIN sys_user c on a.change_user = c.user_id
+	WHERE a.book_id = '` + bookId + `'`
+	sql += ` order by a.change_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&change)
+	return change, err
+}
+
+func (m *BookDAO) GetInStockChangeByBookIdCount(bookId string) (int, error) {
+	var change []InStockChange
+	sql := `SELECT
+	a.*,
+	b.book_name,
+	b.left_num,
+	c.real_name
+FROM
+	ta_in_stock_change a
+	INNER JOIN ta_book b ON a.book_id = b.book_id
+	INNER JOIN sys_user c on a.change_user = c.user_id
+	WHERE a.book_id = '` + bookId + `'`
+	err := m.db.Sql(sql).Find(&change)
+	return len(change), err
+}
+
+func (m *BookDAO) AddChangeRecord(change model.TaInStockChange) error {
+	change.ChangeDate = time.Now()
+	change.RecordId = utils.GetGUID()
+	_, err := m.db.Insert(change)
+	return err
+
+}

service/book/book.go

@@ -87,3 +87,25 @@ func (s *BookServ) EditBook(book model.TaBook) error {
 	}
 	return nil
 }
+
+func (s *BookServ) GetInStockChangeByBookId(bookId string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	list, err := s.dao.GetInStockChangeByBookId(bookId, page, pageSize)
+	if err != nil {
+		utils.LogError("获取库存盘点列表失败: " + err.Error())
+		return nil, errors.New("获取库存盘点列表失败")
+	}
+	total, err := s.dao.GetInStockChangeByBookIdCount(bookId)
+	if err != nil {
+		utils.LogError("获取库存盘点列表失败: " + err.Error())
+		return nil, errors.New("获取库存盘点列表失败")
+	}
+	return map[string]interface{}{
+		"list":     list,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}