bug修改

log/common.log

@@ -271,3 +271,11 @@
 2018/09/19 17:42:09 [E] 用户没有设置默认案场
 2018/09/19 17:42:09 [E] 用户没有设置默认案场
 2018/09/19 17:51:33 [E] 获取用户基本信息失败: 没有查询到 ID (OPENID) 对应的用户
+2018/09/19 18:58:01 [E] 获取发送卡信息失败: Error 1054: Unknown column 'serial_code' in 'field list'
+2018/09/19 18:58:01 [E] 获取人员信息失败: 获取人员信息失败
+2018/09/19 19:00:04 [E] 获取发送卡信息失败: Error 1054: Unknown column 'price' in 'field list'
+2018/09/19 19:00:04 [E] 获取人员信息失败: 获取人员信息失败
+2018/09/19 19:00:37 [E] 获取发送券信息失败: Error 1054: Unknown column 'serial_code' in 'field list'
+2018/09/19 19:00:37 [E] 获取人员信息失败: 获取人员信息失败
+2018/09/19 19:06:05 [E] 获取发送券信息失败: Error 1054: Unknown column 'price' in 'field list'
+2018/09/19 19:06:05 [E] 获取人员信息失败: 获取人员信息失败

models/card/card.go

@@ -34,6 +34,7 @@ type CardInfo struct {
 	Images             []model.TaExperienceCardImage
 	Targets            []model.TaCouponCardTarget
 	Share              *model.TaExperienceCardShare
+	ChannelId          string
 }
 
 // GetCardList 获取卡列表
@@ -83,6 +84,13 @@ func (m *CardDAO) GetCardByID(cardid string) (*CardInfo, error) {
 		return nil, err
 	}
 	card[0].Share = share
+	channel, err := m.GetCardChannel(cardid)
+	if err != nil {
+		return nil, err
+	}
+	if channel != nil {
+		card[0].ChannelId = channel.ChannelId
+	}
 	return &card[0], err
 }
 
@@ -414,3 +422,36 @@ func (m *CardDAO) GetCustomerNoCardByCustomer(customerid, orgid string) ([]model
 	}
 	return cards, nil
 }
+
+// GetCardChannel 获取卡对应渠道
+func (m *CardDAO) GetCardChannel(cardid string) (*model.TaCardCouponChannel, error) {
+	var channels []model.TaCardCouponChannel
+	err := m.db.Where("card_coupon_type=?", models.COURSE_COUPON_CARD).And("card_coupon_id=?", cardid).And("status=?", models.STATUS_NORMAL).Find(&channels)
+	if err != nil {
+		return nil, err
+	}
+	if len(channels) > 0 {
+		return &channels[0], nil
+	}
+	return nil, nil
+}
+
+// DelCardChannel 删除卡对应渠道
+func (m *CardDAO) DelCardChannel(cardid string) error {
+	sql := `delete from ta_card_coupon_channel where card_coupon_id=? and card_coupon_type=?`
+	_, err := m.db.Exec(sql, cardid, models.COURSE_COUPON_CARD)
+	return err
+}
+
+// SaveCardChannel 保存卡对应渠道
+func (m *CardDAO) SaveCardChannel(channelid, cardid string) error {
+	var cardChannel = model.TaCardCouponChannel{
+		CardCouponChannelId: utils.GetGUID(),
+		CardCouponId:        cardid,
+		ChannelId:           channelid,
+		CardCouponType:      models.COURSE_COUPON_CARD,
+		Status:              models.STATUS_NORMAL,
+	}
+	_, err := m.db.Insert(&cardChannel)
+	return err
+}

models/coupon/coupon.go

@@ -86,6 +86,14 @@ func (m *CouponDAO) GetCouponInfoByID(id string) (*CouponInfo, error) {
 	cp.Rules = rules
 	cp.Share = share
 
+	channel, err := m.GetCouponChannel(id)
+	if err != nil {
+		return nil, err
+	}
+	if channel != nil {
+		cp.ChannelId = channel.ChannelId
+	}
+
 	return cp, nil
 }
 
@@ -519,3 +527,36 @@ func (m *CouponDAO) GetNoCouponByCustomer(orgid, customerid string) ([]model.TaC
 	err := m.db.Sql(sql, models.STATUS_DEL, customerid, orgid).Find(&coupons)
 	return coupons, err
 }
+
+// GetCouponChannel 获取优惠券对应渠道
+func (m *CouponDAO) GetCouponChannel(couponid string) (*model.TaCardCouponChannel, error) {
+	var channels []model.TaCardCouponChannel
+	err := m.db.Where("card_coupon_type=?", models.COURSE_COUPON_COUPON).And("card_coupon_id=?", couponid).And("status=?", models.STATUS_NORMAL).Find(&channels)
+	if err != nil {
+		return nil, err
+	}
+	if len(channels) > 0 {
+		return &channels[0], nil
+	}
+	return nil, nil
+}
+
+// DelCouponChannel 删除优惠券对应渠道
+func (m *CouponDAO) DelCouponChannel(couponid string) error {
+	sql := `delete from ta_card_coupon_channel where card_coupon_id=? and card_coupon_type=?`
+	_, err := m.db.Exec(sql, couponid, models.COURSE_COUPON_COUPON)
+	return err
+}
+
+// SaveCouponChannel 保存优惠券对应渠道
+func (m *CouponDAO) SaveCouponChannel(channelid, couponid string) error {
+	var couponChannel = model.TaCardCouponChannel{
+		CardCouponChannelId: utils.GetGUID(),
+		CardCouponId:        couponid,
+		ChannelId:           channelid,
+		CardCouponType:      models.COURSE_COUPON_COUPON,
+		Status:              models.STATUS_NORMAL,
+	}
+	_, err := m.db.Insert(&couponChannel)
+	return err
+}

models/coupon/types.go

@@ -17,6 +17,7 @@ type CouponInfo struct {
 	Targets        []model.TaCouponTarget
 	Images         []model.TaCouponImage
 	Rules          []model.TaCouponRule
+	ChannelId      string
 }
 
 // CaseUsableCoupon 案场可用优惠券信息

service/card/card.go

@@ -122,6 +122,14 @@ func (s *CardServ) SaveCard(cd *card.CardInfo) error {
 		return errors.New("保存卡关联内容失败")
 	}
 
+	// 保存渠道
+	if cd.ChannelId != "" {
+		if err := s.dao.SaveCardChannel(cd.ChannelId, cd.CardId); err != nil {
+			utils.LogError("保存对应渠道失败: " + err.Error())
+			return errors.New("保存对应渠道失败")
+		}
+	}
+
 	return nil
 }
 
@@ -158,6 +166,19 @@ func (s *CardServ) UpdateCard(cd *card.CardInfo) error {
 		return errors.New("更新卡分享失败")
 	}
 
+	// 删除渠道
+	if err := s.dao.DelCardChannel(cd.CardId); err != nil {
+		utils.LogError("删除对应渠道信息失败: " + err.Error())
+		return errors.New("删除对应渠道信息失败")
+	}
+
+	// 保存渠道
+	if cd.ChannelId != "" {
+		if err := s.dao.SaveCardChannel(cd.ChannelId, cd.CardId); err != nil {
+			utils.LogError("保存对应渠道失败: " + err.Error())
+			return errors.New("保存对应渠道失败")
+		}
+	}
 	// 关联内容 规则 不允许更新
 	return nil
 }

service/coupon/coupon.go

@@ -124,6 +124,14 @@ func (s *CouponServ) SaveCoupon(cp *coupon.CouponInfo) error {
 		return errors.New("保存优惠券规则失败")
 	}
 
+	// 保存渠道
+	if cp.ChannelId != "" {
+		if err := s.dao.SaveCouponChannel(cp.ChannelId, cp.CouponId); err != nil {
+			utils.LogError("保存对应渠道失败: " + err.Error())
+			return errors.New("保存对应渠道失败")
+		}
+	}
+
 	return nil
 }
 
@@ -183,6 +191,19 @@ func (s *CouponServ) UpdateCoupon(cp *coupon.CouponInfo) error {
 		return errors.New("保存优惠券规则失败")
 	}
 
+	// 删除渠道
+	if err := s.dao.DelCouponChannel(cp.CouponId); err != nil {
+		utils.LogError("删除对应渠道信息失败: " + err.Error())
+		return errors.New("删除对应渠道信息失败")
+	}
+
+	// 保存渠道
+	if cp.ChannelId != "" {
+		if err := s.dao.SaveCouponChannel(cp.ChannelId, cp.CouponId); err != nil {
+			utils.LogError("保存对应渠道失败: " + err.Error())
+			return errors.New("保存对应渠道失败")
+		}
+	}
 	return nil
 }
 

service/course/course.go

@@ -141,7 +141,7 @@ func (s *CourseServ) SaveCourse(course model.TaCourse, tagids string) (*model.Ta
 	if course.BeginDate.IsZero() || course.EndDate.IsZero() {
 		return nil, utils.LogError("课程时间不允许为空！")
 	}
-	if !course.EndDate.After(course.BeginDate) {
+	if !course.EndDate.After(course.BeginDate) && course.EndDate != course.BeginDate {
 		return nil, utils.LogError("截止时间必须大于开始时间！")
 	}
 	if tagids == "" {