Merge branch 'dev' of http://git.ycjcjy.com/SpaceOfCheng/services into dev

log/common.log

@@ -190,3 +190,73 @@
 2018/09/25 10:52:58 [E] 用户没有设置默认案场
 2018/09/25 10:53:02 [E] 用户没有设置默认案场
 2018/09/25 11:03:32 [E] 用户没有设置默认案场
+2018/09/25 14:50:11 [E] 用户没有设置默认案场
+2018/09/25 14:50:11 [E] 用户没有设置默认案场
+2018/09/25 14:50:35 [E] 用户没有设置默认案场
+2018/09/25 14:50:35 [E] 用户没有设置默认案场
+2018/09/25 14:53:32 [E] 用户没有设置默认案场
+2018/09/25 14:53:35 [E] 用户没有设置默认案场
+2018/09/25 14:54:20 [E] 用户没有设置默认案场
+2018/09/25 14:54:20 [E] 用户没有设置默认案场
+2018/09/25 14:57:27 [E] 用户没有设置默认案场
+2018/09/25 14:57:27 [E] 用户没有设置默认案场
+2018/09/25 14:57:40 [E] 用户没有设置默认案场
+2018/09/25 14:57:40 [E] 用户没有设置默认案场
+2018/09/25 14:57:57 [E] 用户没有设置默认案场
+2018/09/25 14:57:57 [E] 用户没有设置默认案场
+2018/09/25 14:58:01 [E] 用户没有设置默认案场
+2018/09/25 14:58:01 [E] 用户没有设置默认案场
+2018/09/25 14:58:01 [E] 用户没有设置默认案场
+2018/09/25 14:58:04 [E] 用户没有设置默认案场
+2018/09/25 14:58:04 [E] 用户没有设置默认案场
+2018/09/25 14:58:04 [E] 用户没有设置默认案场
+2018/09/25 14:58:05 [E] 用户没有设置默认案场
+2018/09/25 14:58:09 [E] 用户没有设置默认案场
+2018/09/25 14:58:09 [E] 用户没有设置默认案场
+2018/09/25 14:58:09 [E] 用户没有设置默认案场
+2018/09/25 14:59:59 [E] 用户没有设置默认案场
+2018/09/25 14:59:59 [E] 用户没有设置默认案场
+2018/09/25 14:59:59 [E] 用户没有设置默认案场
+2018/09/25 14:59:59 [E] 用户没有设置默认案场
+2018/09/25 15:00:14 [E] 用户没有设置默认案场
+2018/09/25 15:00:14 [E] 用户没有设置默认案场
+2018/09/25 15:00:14 [E] 用户没有设置默认案场
+2018/09/25 15:00:14 [E] 用户没有设置默认案场
+2018/09/25 15:00:38 [E] 用户没有设置默认案场
+2018/09/25 15:00:38 [E] 用户没有设置默认案场
+2018/09/25 15:00:38 [E] 用户没有设置默认案场
+2018/09/25 15:00:38 [E] 用户没有设置默认案场
+2018/09/25 15:00:57 [E] 用户没有设置默认案场
+2018/09/25 15:00:57 [E] 用户没有设置默认案场
+2018/09/25 15:00:58 [E] 用户没有设置默认案场
+2018/09/25 15:00:58 [E] 用户没有设置默认案场
+2018/09/25 15:00:59 [E] 用户没有设置默认案场
+2018/09/25 15:01:03 [E] 用户没有设置默认案场
+2018/09/25 15:01:04 [E] 用户没有设置默认案场
+2018/09/25 15:01:10 [E] 用户没有设置默认案场
+2018/09/25 15:01:10 [E] 用户没有设置默认案场
+2018/09/25 15:01:14 [E] 用户没有设置默认案场
+2018/09/25 15:01:14 [E] 用户没有设置默认案场
+2018/09/25 15:01:23 [E] 用户没有设置默认案场
+2018/09/25 15:01:25 [E] 用户没有设置默认案场
+2018/09/25 15:01:25 [E] 用户没有设置默认案场
+2018/09/25 15:01:25 [E] 用户没有设置默认案场
+2018/09/25 15:01:25 [E] 用户没有设置默认案场
+2018/09/25 15:01:30 [E] 用户没有设置默认案场
+2018/09/25 15:01:30 [E] 用户没有设置默认案场
+2018/09/25 15:01:31 [E] 用户没有设置默认案场
+2018/09/25 15:01:34 [E] 用户没有设置默认案场
+2018/09/25 15:02:05 [E] 用户没有设置默认案场
+2018/09/25 15:02:05 [E] 用户没有设置默认案场
+2018/09/25 15:02:06 [E] 用户没有设置默认案场
+2018/09/25 15:02:06 [E] 用户没有设置默认案场
+2018/09/25 15:02:08 [E] 用户没有设置默认案场
+2018/09/25 15:02:10 [E] 用户没有设置默认案场
+2018/09/25 15:02:11 [E] 用户没有设置默认案场
+2018/09/25 15:02:40 [E] 用户没有设置默认案场
+2018/09/25 15:02:45 [E] 用户没有设置默认案场
+2018/09/25 15:02:46 [E] 用户没有设置默认案场
+2018/09/25 15:04:13 [E] 用户没有设置默认案场
+2018/09/25 15:04:14 [E] 用户没有设置默认案场
+2018/09/25 15:04:50 [E] 用户没有设置默认案场
+2018/09/25 15:05:22 [E] 用户没有设置默认案场

models/constant.go

@@ -166,3 +166,8 @@ const (
 	RECEIVEING_TYPE_SALES   = "sales"
 	RECEIVEING_TYPE_CHANNEL = "channel"
 )
+
+// 二维码类型
+const (
+	QRCODE_TYPE_COURSE = "course"
+)

models/course/course.go

@@ -2,6 +2,7 @@ package course
 
 import (
 	"errors"
+	"math/rand"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
@@ -489,9 +490,9 @@ func (m *CourseDAO) GetCourseOfCustomer(custID, courseID string) (*model.TaCusto
 }
 
 // SaveCourseOfCustomer 保存我的课程
-func (m *CourseDAO) SaveCourseOfCustomer(course *model.TaCustomerCourse, details []model.TaCustomerCourseDetail) error {
+func (m *CourseDAO) SaveCourseOfCustomer(course *model.TaCustomerCourse, details []model.TaCustomerCourseDetail) (string, error) {
 	if course == nil || details == nil || len(details) == 0 {
-		return errors.New("没有有效的我的课程信息")
+		return "", errors.New("没有有效的我的课程信息")
 	}
 
 	course.CustomerCourseId = guid.NewGUIDString()
@@ -509,19 +510,36 @@ func (m *CourseDAO) SaveCourseOfCustomer(course *model.TaCustomerCourse, details
 	}
 
 	if _, err := m.db.Insert(&details); err != nil {
-		return err
+		return "", err
 	}
 
 	if _, err := m.db.Insert(course); err != nil {
-		return err
+		return "", err
 	}
 
 	// 课程参与人数+1
 	sql := `update ta_course set signup_num=signup_num+1 where course_id='` + course.CourseId + `'`
 	if _, err := m.db.Exec(sql); err != nil {
-		return err
+		return "", err
 	}
-	return nil
+	return course.CustomerCourseId, nil
+}
+
+func (m *CourseDAO) SaveCustomerCourseQrcode(qrcode *model.TaCustomerCourseQrcode) error {
+	_, err := m.db.Insert(qrcode)
+	return err
+}
+
+func (m *CourseDAO) GenerateQRCode() string {
+	var temp1 int = rand.Intn(9)*87 + 11
+	var temp2 int = rand.Intn(9)*89 + 13
+	nano := time.Now().UnixNano()
+	var nanostr string = strconv.FormatInt(nano, 10)
+	var temp3 string = nanostr[11:]
+	var temp4 string = "6"
+	var temp5 int = rand.Intn(9)*7 + 17
+	var code string = "66" + strconv.Itoa(temp1) + temp4 + strconv.Itoa(temp2) + temp3 + strconv.Itoa(temp5)
+	return code
 }
 
 // CustomerCourse 客户课程信息
@@ -583,18 +601,20 @@ func (m *CourseDAO) GetCustomerCourseDetail(customerCourseID string) ([]model.Ta
 func (m *CourseDAO) GetCustomerCourseByID(id string) (*CustomerCourse, error) {
 	var courses []CustomerCourse
 	sql := `SELECT
-		a.*, a.customer_course_id AS qr_code_string,
-		b.orders_no,
-		c.course_img,
-		d.case_address,
-		d.case_name,
-		c.begin_date,
-		c.end_date,
-		c.remark
-	FROM
-		ta_customer_course a
+	a.*,
+	e.customer_qrcode AS qr_code_string,
+	b.orders_no,
+	c.course_img,
+	d.case_address,
+	d.case_name,
+	c.begin_date,
+	c.end_date,
+	c.remark 
+FROM
+	ta_customer_course a
 	INNER JOIN ta_course c ON a.course_id = c.course_id
-	INNER JOIN sys_case d on a.case_id = d.case_id
+	INNER JOIN sys_case d ON a.case_id = d.case_id
+	INNER JOIN ta_customer_course_qrcode e ON a.customer_course_id = e.customer_course_id
 	LEFT JOIN ta_course_orders b ON a.source_id = b.orders_id
 	 where a.status>` + strconv.Itoa(models.STATUS_DEL) + ` and a.customer_course_id='` + id + `'`
 

models/system/user.go

@@ -143,8 +143,21 @@ func (m *UserDAO) GetUserRole(userid string) ([]model.SysRole, error) {
 
 // GetUserMenu 获取用户菜单
 func (m *UserDAO) GetUserMenu(userid string) ([]model.SysMenu, error) {
+	type Menus struct {
+		MenuIds string
+	}
+	var menu = Menus{}
+	sql := `select group_concat(menu_id) as menu_ids from sys_user_menu where user_id = ?`
+	m.db.Sql(sql, userid).Get(&menu)
 	var userMenu []model.SysMenu
-	err := m.db.In("menu_id", builder.Select("menu_id").From("sys_user_menu").Where(builder.Eq{"user_id": userid}).And(builder.Gt{"status": models.STATUS_DEL})).Asc("order_no").Find(&userMenu)
+	var err error
+	if menu.MenuIds != "" {
+		sql = `select * from sys_menu where menu_id in ('` + strings.Replace(menu.MenuIds, ",", "','", -1) + `')
+		UNION
+		select * from sys_menu where menu_id in (select father_id from sys_menu where menu_id in ('` + strings.Replace(menu.MenuIds, ",", "','", -1) + `'))
+		`
+		err = m.db.Sql(sql).Find(&userMenu)
+	}
 	return userMenu, err
 }
 

routers/wechat.go

@@ -1,7 +1,6 @@
 package routers
 
 import (
-	"cdkj-check/controllers/luckdraw"
 	"spaceofcheng/services/controllers/bodycheck"
 	"spaceofcheng/services/controllers/card"
 	"spaceofcheng/services/controllers/cases"
@@ -10,6 +9,7 @@ import (
 	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/goods"
 	"spaceofcheng/services/controllers/gymcard"
+	"spaceofcheng/services/controllers/luckdraw"
 	"spaceofcheng/services/controllers/user"
 
 	"github.com/astaxie/beego"

service/card/card.go

@@ -581,10 +581,23 @@ func (s *CardServ) SaveCustomerCourseByCard(customerCard *model.TaCustomerCard)
 			custCourseDetails = append(custCourseDetails, d2)
 		}
 
-		if err := s.courseDao.SaveCourseOfCustomer(&custCourse, custCourseDetails); err != nil {
+		customerCourseId, err := s.courseDao.SaveCourseOfCustomer(&custCourse, custCourseDetails)
+		if err != nil {
 			utils.LogError("插入我的课程失败: " + err.Error())
 			return errors.New("写入我的课程失败")
 		}
+		custQrcode := model.TaCustomerCourseQrcode{
+			CustomerCourseId: customerCourseId,
+			QrcodeType:       models.QRCODE_TYPE_COURSE,
+			CreateDate:       time.Now(),
+			CustomerQrcode:   s.courseDao.GenerateQRCode(),
+			Status:           models.STATUS_NORMAL,
+		}
+		err = s.courseDao.SaveCustomerCourseQrcode(&custQrcode)
+		if err != nil {
+			utils.LogError("生成我的课程二维码失败：" + err.Error())
+			return errors.New("生成我的课程二维码失败")
+		}
 	}
 	return nil
 }

service/course/order.go

@@ -371,16 +371,27 @@ func (s *CourseServ) SaveOrder(order *model.TaCourseOrders, course *course.Cours
 		}
 		custCourseDetails = append(custCourseDetails, d2)
 	}
-
-	if err := s.dao.SaveCourseOfCustomer(&custCourse, custCourseDetails); err != nil {
+	customerCourseId, err := s.dao.SaveCourseOfCustomer(&custCourse, custCourseDetails)
+	if err != nil {
 		utils.LogError("插入我的课程失败: " + err.Error())
 		return errors.New("写入我的课程失败")
 	}
+	custQRCode := model.TaCustomerCourseQrcode{
+		CustomerCourseId: customerCourseId,
+		CustomerQrcode:   s.dao.GenerateQRCode(),
+		CreateDate:       time.Now(),
+		Status:           models.STATUS_NORMAL,
+		QrcodeType:       models.QRCODE_TYPE_COURSE,
+	}
 
 	if err := s.dao.SaveCourseOrderDetail(details); err != nil {
 		utils.LogError("插入课程订单详情: " + err.Error())
 		return errors.New("写入课程订单详情失败")
 	}
+	if err := s.dao.SaveCustomerCourseQrcode(&custQRCode); err != nil {
+		utils.LogError("插入我的课程二维码失败: " + err.Error())
+		return errors.New("写入我的课程二维码失败")
+	}
 
 	return nil
 }

service/customer/customer.go

@@ -14,8 +14,6 @@ import (
 	"spaceofcheng/services/utils"
 	"strconv"
 	"time"
-
-	"github.com/astaxie/beego"
 )
 
 // CustomerServ 系统处理
@@ -132,7 +130,6 @@ func (s *CustomerServ) BindWechatUser(userMap *model.TaUserMapping, phone string
 
 		// 更新用户手机号码信息及userid信息
 		customer, err := s.dao.GetCustWithWXByOpenID(wxInfo.OpenID)
-		beego.Error(customer)
 		newCust := model.TaCustomer{
 			CustomerId: customer.CustomerId,
 			Phone:      user.Phone,

service/verify/verify.go

@@ -28,7 +28,7 @@ func NewVerifyServ(ctx *utils.Context) *VerifyServ {
 }
 
 // GetCustomerCourseDetailById 根据ID获取当日可核销课程
-func (s *VerifyServ) GetCustomerCourseDetailById(id, caseids string, page, pageSize int) (map[string]interface{}, error) {
+func (s *VerifyServ) GetCustomerCourseDetailById(qrcode, caseids string, page, pageSize int) (map[string]interface{}, error) {
 	// if err := utils.NewAuthEngine(s.ctx).CheckCase(caseid); err != nil {
 	// 	return nil, err
 	// }
@@ -38,11 +38,11 @@ func (s *VerifyServ) GetCustomerCourseDetailById(id, caseids string, page, pageS
 	if page == 0 {
 		page = 1
 	}
-	// id, err := s.dao.GetCustomerCourseIdByQrcode(qrcode)
-	// if err != nil {
-	// 	utils.LogError("获取列表失败: " + err.Error())
-	// 	return nil, errors.New("获取列表失败")
-	// }
+	id, err := s.dao.GetCustomerCourseIdByQrcode(qrcode)
+	if err != nil {
+		utils.LogError("获取列表失败: " + err.Error())
+		return nil, errors.New("获取列表失败")
+	}
 	customerDetail, err := s.dao.GetCustomerCourseList(id, caseids, page, pageSize)
 	if err != nil {
 		utils.LogError("获取列表失败: " + err.Error())