更新

controllers/coupon/coupon.go

@@ -167,3 +167,14 @@ func (c *CouponController) GiveCoupon() {
 
 	c.ResponseJSON("ok")
 }
+
+// GetCouponBySendType 根据类型获取优惠券
+func (c *CouponController) GetCouponBySendType() {
+	sendtype := c.GetString(":type")
+	coupons, err := c.serv.GetCouponBySendType(sendtype)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(coupons)
+}

controllers/user/user.go

@@ -251,11 +251,11 @@ func (c *UserController) GetUserByTel() {
 
 // GetForbidUsers 获取所有禁止人员信息
 func (c *UserController) GetForbidUsers() {
-	caseid := c.GetString("caseid")
-	if caseid == "" {
-		c.ResponseError(errors.New("没有案场信息"))
-	}
-	users, err := c.dao.GetForbidUsers(caseid)
+	// caseid := c.GetString("caseid")
+	// if caseid == "" {
+	// 	c.ResponseError(errors.New("没有案场信息"))
+	// }
+	users, err := c.dao.GetForbidUsers()
 	if err != nil {
 		utils.LogError("获取禁止人员信息失败: " + err.Error())
 		c.ResponseError(errors.New("获取禁止人员信息失败"))
@@ -286,3 +286,14 @@ func (c *UserController) OpenForbidUser() {
 	}
 	c.ResponseJSON("操作成功")
 }
+
+// GetCaseUserByType 根据用户类型获取用户信息
+func (c *UserController) GetCaseUserByType() {
+	usertype := c.GetString(":type")
+	users, err := c.dao.GetCaseUserByType(usertype)
+	if err != nil {
+		utils.LogError("获取人员信息失败: " + err.Error())
+		c.ResponseError(errors.New("获取人员信息失败"))
+	}
+	c.ResponseJSON(users)
+}

models/card/card.go

@@ -215,15 +215,55 @@ func (m *CardDAO) CheckCustCard(custID, CardID string, startDate, endDate time.T
 // 案场可用卡信息
 type CaseUsableCard struct {
 	model.TaCouponCard `xorm:"extends"`
-	UserSendCount      int
-	UserUsedCount      int
+	CustomerCard       []model.TaCustomerCard
 }
 
 // GetCaseUsableCard 获取案场可用卡信息
-func (m *CardDAO) GetCaseUsableCard(caseid string) ([]CaseUsableCard, error) {
+func (m *CardDAO) GetCaseUsableCard(caseid, userid string, page, pageSize int) ([]CaseUsableCard, error) {
 	var cards []CaseUsableCard
-	sql := `select * from ta_coupon_card where case_id=? and status=? and end_date>now() order by create_date limit `
-	err := m.db.Sql(sql).Find(&cards)
-	// err := m.db.Where("case_id=?", caseid).And("status=?", models.STATUS_NORMAL).And("end_date>now()").Desc("create_date").Find(&cards)
+	sql := `select * from ta_coupon_card where case_id=? and status=? and end_date>now() order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL).Find(&cards)
+	if userid != "" {
+		for inx, card := range cards {
+			cCards, err := m.GetCustomerCardByCardAndUser(card.CardId, userid)
+			if err != nil {
+				return nil, err
+			}
+			cards[inx].CustomerCard = cCards
+		}
+	}
 	return cards, err
 }
+
+// GetCustomerCardByCardAndUser 根据卡与用户获取领取的用户信息
+func (m *CardDAO) GetCustomerCardByCardAndUser(cardid, userid string) ([]model.TaCustomerCard, error) {
+	var customerCards []model.TaCustomerCard
+	err := m.db.Where("card_id=?", cardid).And("sales_id=?", userid).And("status>?", models.STATUS_DEL).Find(&customerCards)
+	return customerCards, err
+}
+
+// GetCardDetail 获取卡详情
+func (m *CardDAO) GetCardDetail(cardid string) (*CaseUsableCard, error) {
+	var card = new(CaseUsableCard)
+	sql := `select * from ta_coupon_card where card_id=? and status>?`
+	_, err := m.db.Sql(sql, cardid, models.STATUS_DEL).Get(&card)
+	if err != nil {
+		return nil, err
+	}
+	if card == nil || card.CardId == "" {
+		return nil, errors.New("无卡信息")
+	}
+	ccards, err := m.GetCustomerCardByCard(cardid)
+	if err != nil {
+		return nil, err
+	}
+	card.CustomerCard = ccards
+	return card, nil
+}
+
+// GetCustomerCardByCard 根据卡获取领取的用户信息
+func (m *CardDAO) GetCustomerCardByCard(cardid string) ([]model.TaCustomerCard, error) {
+	var customerCards []model.TaCustomerCard
+	err := m.db.Where("card_id=?", cardid).And("status>?", models.STATUS_DEL).Find(&customerCards)
+	return customerCards, err
+}

models/coupon/coupon.go

@@ -251,3 +251,10 @@ func (m *CouponDAO) SaveCouponRecoreds(recs []model.TaCouponGiveRecord) error {
 
 	return nil
 }
+
+// GetCouponBySendType 根据类型获取优惠券
+func (m *CouponDAO) GetCouponBySendType(caseids, sendtype string) ([]model.TaCoupon, error) {
+	var coupons []model.TaCoupon
+	err := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("send_type=?", sendtype).And("status=?", models.STATUS_NORMAL).Find(&coupons)
+	return coupons, err
+}

models/system/user.go

@@ -496,3 +496,20 @@ func (m *UserDAO) OpenForbidUser(forbid *model.TaForbidUser) error {
 	_, err := m.db.Cols(col...).Where("forbid_id=?", forbid.ForbidId).Update(forbid)
 	return err
 }
+
+// UserWithCouponAndCard 用户关联卡券信息
+type UserWithCouponAndCard struct {
+	model.SysUser  `xorm:"extends"`
+	CustomerCoupon []model.TaCustomerCoupon
+	CustomerCard   []model.TaCustomerCard
+}
+
+// GetCaseUserByType 获取案场所有销售信息
+func (m *UserDAO) GetCaseUserByType(caseid, usertype string) ([]UserWithCouponAndCard, error) {
+	var users []UserWithCouponAndCard
+	sql := `select a.* from sys_user a inner join sys_user_type b on a.user_id=b.user_id
+	inner join sys_user_case c on a.user_id=c.user_id
+	where a.status>? and c.case_id =? and b.type_id=?`
+	err := m.db.Sql(sql, models.STATUS_DEL, caseid, usertype).Find(&users)
+	return users, err
+}

routers/common.go

@@ -230,6 +230,7 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/coupon/:id", &coupon.CouponController{}, "get:GetCouponByIDForAdmin"),
 		beego.NSRouter("/coupon/:id", &coupon.CouponController{}, "put:UpdateCoupon"),
 		beego.NSRouter("/coupon/:id/to/:users", &coupon.CouponController{}, "post:GiveCoupon"),
+		beego.NSRouter("/coupon/type/:type", &coupon.CouponController{}, "get:GetCouponBySendType"),
 
 		// 卡
 		beego.NSRouter("/card", &card.CardController{}, "get:ListByCase"),

routers/wechat.go

@@ -41,5 +41,8 @@ func getWechatRoutes() beego.LinkNamespace {
 		beego.NSRouter("/user/forbid", &user.UserController{}, "get:GetForbidUsers"),
 		beego.NSRouter("/user/forbid/:userid/:type", &user.UserController{}, "post:SaveForbidUser"),
 		beego.NSRouter("/user/forbid/:userid/:type", &user.UserController{}, "put:OpenForbidUser"),
+
+		// 用户
+		beego.NSRouter("/user/:type", &user.UserController{}, "get:GetCaseUserByType"),
 	)
 }

service/coupon/coupon.go

@@ -350,3 +350,21 @@ func (s *CouponServ) GetCouponByIDWithCheck(cpID string) (*coupon.CouponInfo, er
 
 	return cp, nil
 }
+
+// GetCouponBySendType 根据发送类型获取优惠券
+func (s *CouponServ) GetCouponBySendType(sendtype string) ([]model.TaCoupon, error) {
+	cases := s.ctx.Get("cases").([]model.SysUserCase)
+	caseIDs := ""
+	for _, value := range cases {
+		if caseIDs != "" {
+			caseIDs = caseIDs + ","
+		}
+		caseIDs = caseIDs + value.CaseId
+	}
+	coupon, err := s.dao.GetCouponBySendType(caseIDs, sendtype)
+	if err != nil {
+		utils.LogError("获取优惠券失败: " + err.Error())
+		return nil, errors.New("校验优惠券失败")
+	}
+	return coupon, nil
+}

service/user.go

@@ -3,6 +3,7 @@ package service
 import (
 	"errors"
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/card"
 	"spaceofcheng/services/models/cases"
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
@@ -19,6 +20,7 @@ type UserServ struct {
 	dao         *system.UserDAO
 	casedao     *cases.CaseDAO
 	customerdao *customer.CustomerDAO
+	carddao     *card.CardDAO
 }
 
 // NewUserServ 初始化
@@ -28,6 +30,7 @@ func NewUserServ(ctx *utils.Context) *UserServ {
 		dao:         system.NewUserDAO(ctx),
 		casedao:     cases.NewCaseDAO(ctx),
 		customerdao: customer.NewCustomerDAO(ctx),
+		carddao:     card.NewCardDAO(ctx),
 	}
 }
 
@@ -411,11 +414,19 @@ func (s *UserServ) GetUserByTel(tel string) (*model.SysUser, error) {
 }
 
 // GetForbidUsers 获取所有禁止人员信息
-func (s *UserServ) GetForbidUsers(caseid string) ([]model.TaForbidUser, error) {
-	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseid); err != nil {
+func (s *UserServ) GetForbidUsers() ([]model.TaForbidUser, error) {
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	if customer.CustomerId == "" || customer.UserId == "" {
+		return nil, errors.New("当前用户没有权限查看用户信息")
+	}
+	caseinfo, err := s.dao.GetUserBelongCase(customer.UserId)
+	if err != nil {
 		return nil, err
 	}
-	users, err := s.dao.GetForbidUsers(caseid)
+	// if err := utils.NewAuthEngine(s.ctx).CheckCase(caseid); err != nil {
+	// 	return nil, err
+	// }
+	users, err := s.dao.GetForbidUsers(caseinfo.CaseId)
 	return users, err
 }
 
@@ -508,3 +519,28 @@ func (s *UserServ) OpenForbidUser(userid string, forbidtype string) error {
 	err = s.dao.OpenForbidUser(&forbiduser)
 	return err
 }
+
+// GetCaseUserByType 根据用户类型获取人员信息
+func (s *UserServ) GetCaseUserByType(usertype string) ([]system.UserWithCouponAndCard, error) {
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	if customer.CustomerId == "" || customer.UserId == "" {
+		return nil, errors.New("当前用户没有权限查看用户信息")
+	}
+	caseinfo, err := s.dao.GetUserBelongCase(customer.UserId)
+	if err != nil {
+		return nil, err
+	}
+
+	users, err := s.dao.GetCaseUserByType(caseinfo.CaseId, usertype)
+	if err != nil {
+		return nil, err
+	}
+	for inx, user := range users {
+		cards, err := s.carddao.GetCustomerCardByCardAndUser(caseinfo.CaseId, user.UserId)
+		if err != nil {
+			return nil, err
+		}
+		users[inx].CustomerCard = cards
+	}
+	return users, err
+}