增加数据统计

log/common.log

@@ -2697,3 +2697,130 @@
 2018/09/11 14:15:33 [E] 用户没有设置默认案场
 2018/09/11 14:15:59 [E] 用户没有设置默认案场
 2018/09/11 14:16:44 [E] 用户没有设置默认案场
+2018/09/11 14:26:31 [E] 用户没有设置默认案场
+2018/09/11 14:26:34 [E] 用户没有设置默认案场
+2018/09/11 14:26:53 [E] 用户没有设置默认案场
+2018/09/11 14:27:39 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/11 14:27:39 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_rEPC9o2S5Ncg2-rmVVwkzOyBFcjTQYc5u_kABdZpsOLYBE4Wzq2Cu7alJz-xeD23PHchO7SASZnlitrNDK4fUdldW6QmB94dqjLUJ_JOThybbzc4ww2JyYWOcGgL6idxLCpJZeaW_rul9SK9JUGbAEAVGS","expires_in":7200})
+2018/09/11 14:27:39 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_rEPC9o2S5Ncg2-rmVVwkzOyBFcjTQYc5u_kABdZpsOLYBE4Wzq2Cu7alJz-xeD23PHchO7SASZnlitrNDK4fUdldW6QmB94dqjLUJ_JOThybbzc4ww2JyYWOcGgL6idxLCpJZeaW_rul9SK9JUGbAEAVGS expires_in:7200])
+2018/09/11 14:29:48 [E] 用户没有设置默认案场
+2018/09/11 14:29:55 [E] 用户没有设置默认案场
+2018/09/11 14:30:04 [E] 用户没有设置默认案场
+2018/09/11 14:30:38 [E] 用户没有设置默认案场
+2018/09/11 14:32:17 [E] 用户没有设置默认案场
+2018/09/11 14:32:40 [E] 用户没有设置默认案场
+2018/09/11 14:33:21 [E] 用户没有设置默认案场
+2018/09/11 14:33:54 [E] 用户没有设置默认案场
+2018/09/11 14:38:48 [E] 用户没有设置默认案场
+2018/09/11 14:47:06 [E] 用户没有设置默认案场
+2018/09/11 14:47:08 [E] 用户没有设置默认案场
+2018/09/11 14:47:08 [E] 用户没有设置默认案场
+2018/09/11 14:47:10 [E] 用户没有设置默认案场
+2018/09/11 14:48:23 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/11 14:48:23 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/11 14:48:23 [E] 用户没有设置默认案场
+2018/09/11 14:48:25 [E] 用户没有设置默认案场
+2018/09/11 14:48:25 [E] 用户没有设置默认案场
+2018/09/11 14:49:41 [E] 用户没有设置默认案场
+2018/09/11 14:50:00 [E] 用户没有设置默认案场
+2018/09/11 14:50:04 [E] 用户没有设置默认案场
+2018/09/11 14:50:08 [E] 用户没有设置默认案场
+2018/09/11 14:57:52 [E] 用户没有设置默认案场
+2018/09/11 14:58:11 [E] 用户没有设置默认案场
+2018/09/11 14:58:53 [E] 用户没有设置默认案场
+2018/09/11 14:59:05 [E] 用户没有设置默认案场
+2018/09/11 14:59:21 [E] 用户没有设置默认案场
+2018/09/11 14:59:26 [E] 用户没有设置默认案场
+2018/09/11 15:19:15 [E] 用户没有设置默认案场
+2018/09/11 15:20:50 [E] 用户没有设置默认案场
+2018/09/11 15:22:14 [E] 用户没有设置默认案场
+2018/09/11 15:22:14 [E] 用户没有设置默认案场
+2018/09/11 15:22:15 [E] 用户没有设置默认案场
+2018/09/11 15:22:15 [E] 用户没有设置默认案场
+2018/09/11 15:22:19 [E] 用户没有设置默认案场
+2018/09/11 15:23:59 [E] 用户没有设置默认案场
+2018/09/11 15:25:01 [E] 用户没有设置默认案场
+2018/09/11 15:37:01 [E] 用户没有设置默认案场
+2018/09/11 15:37:37 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/11 15:37:37 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_MhXWnAqHcTTlXBcY3B5li9hXD_ViskIoxwl4y7YnZpTZGoy9QhTJ--24YCYSzCp7Ya3c2LWviup_gWnxIFQGOBv_M671RVY7xjXZDzgO6lm2vnMuIdkChi028cxrKS0c263Ivdd-t086zWzPGGVdAAATTI","expires_in":7200})
+2018/09/11 15:37:37 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_MhXWnAqHcTTlXBcY3B5li9hXD_ViskIoxwl4y7YnZpTZGoy9QhTJ--24YCYSzCp7Ya3c2LWviup_gWnxIFQGOBv_M671RVY7xjXZDzgO6lm2vnMuIdkChi028cxrKS0c263Ivdd-t086zWzPGGVdAAATTI expires_in:7200])
+2018/09/11 15:37:53 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/11 15:37:53 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_xbKe8E8EGLiXdRKw3B5li9hXD_ViskIoxwl4y7YnZpTZGoy9QhTJ--24YCaqG-3KDwiV921WvTJ4jaQCcFRoqizA1Dn6AFVQbWTTP-yfzo8Rn5a6aqAhc7rH6sUusDIbOlDRLt9j-SIFEDcIANBdAAAWJX","expires_in":7200})
+2018/09/11 15:37:53 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_xbKe8E8EGLiXdRKw3B5li9hXD_ViskIoxwl4y7YnZpTZGoy9QhTJ--24YCaqG-3KDwiV921WvTJ4jaQCcFRoqizA1Dn6AFVQbWTTP-yfzo8Rn5a6aqAhc7rH6sUusDIbOlDRLt9j-SIFEDcIANBdAAAWJX expires_in:7200])
+2018/09/11 15:40:25 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/11 15:40:25 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_GfzcgjbXDNuI5gQnRouc5sin8BHZTUcYQXNEZupMTwlDQGySf9L35PZf2kRtdzgYj7hGZojZGXzmhgHmshMEIuNzhIgcO8RnLoWF2g28uxaGtbOIRuQu3gAFcExOSHky_V3j1X9HWAYrQ_0yGHGeAIACDC","expires_in":7200})
+2018/09/11 15:40:25 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_GfzcgjbXDNuI5gQnRouc5sin8BHZTUcYQXNEZupMTwlDQGySf9L35PZf2kRtdzgYj7hGZojZGXzmhgHmshMEIuNzhIgcO8RnLoWF2g28uxaGtbOIRuQu3gAFcExOSHky_V3j1X9HWAYrQ_0yGHGeAIACDC expires_in:7200])
+2018/09/11 15:50:29 [E] 用户没有设置默认案场
+2018/09/11 15:50:31 [E] 用户没有设置默认案场
+2018/09/11 15:55:28 [E] 用户没有设置默认案场
+2018/09/11 15:55:32 [E] 用户没有设置默认案场
+2018/09/11 15:55:35 [E] 用户没有设置默认案场
+2018/09/11 15:56:24 [E] 用户没有设置默认案场
+2018/09/11 15:56:26 [E] 用户没有设置默认案场
+2018/09/11 15:56:26 [E] 用户没有设置默认案场
+2018/09/11 15:56:26 [E] 用户没有设置默认案场
+2018/09/11 15:56:27 [E] 用户没有设置默认案场
+2018/09/11 15:56:27 [E] 用户没有设置默认案场
+2018/09/11 15:56:27 [E] 用户没有设置默认案场
+2018/09/11 15:56:33 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/11 15:56:33 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/11 15:56:33 [E] 用户没有设置默认案场
+2018/09/11 15:57:08 [E] 用户没有设置默认案场
+2018/09/11 15:57:08 [E] 用户没有设置默认案场
+2018/09/11 15:57:08 [E] 用户没有设置默认案场
+2018/09/11 15:57:22 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/11 15:57:22 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/11 15:57:22 [E] 用户没有设置默认案场
+2018/09/11 15:57:32 [E] 用户没有设置默认案场
+2018/09/11 15:57:32 [E] 用户没有设置默认案场
+2018/09/11 15:57:32 [E] 用户没有设置默认案场
+2018/09/11 15:57:32 [E] 用户没有设置默认案场
+2018/09/11 15:57:39 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/11 15:57:39 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/11 15:57:39 [E] 用户没有设置默认案场
+2018/09/11 15:58:57 [E] 用户没有设置默认案场
+2018/09/11 15:59:00 [E] 用户没有设置默认案场
+2018/09/11 15:59:00 [E] 用户没有设置默认案场
+2018/09/11 15:59:00 [E] 用户没有设置默认案场
+2018/09/11 15:59:01 [E] 用户没有设置默认案场
+2018/09/11 15:59:01 [E] 用户没有设置默认案场
+2018/09/11 15:59:01 [E] 用户没有设置默认案场
+2018/09/11 15:59:14 [E] 用户没有设置默认案场
+2018/09/11 15:59:14 [E] 用户没有设置默认案场
+2018/09/11 15:59:14 [E] 用户没有设置默认案场
+2018/09/11 15:59:40 [E] 用户没有设置默认案场
+2018/09/11 15:59:40 [E] 用户没有设置默认案场
+2018/09/11 15:59:40 [E] 用户没有设置默认案场
+2018/09/11 15:59:40 [E] 用户没有设置默认案场
+2018/09/11 15:59:47 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/11 15:59:47 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/11 15:59:47 [E] 用户没有设置默认案场
+2018/09/11 16:03:38 [E] 用户没有设置默认案场
+2018/09/11 16:07:00 [E] 用户没有设置默认案场
+2018/09/11 16:11:44 [E] 用户没有设置默认案场
+2018/09/11 16:16:41 [E] 用户没有设置默认案场
+2018/09/11 16:16:58 [E] 用户没有设置默认案场
+2018/09/11 16:17:14 [E] 用户没有设置默认案场
+2018/09/11 16:19:37 [E] 用户没有设置默认案场
+2018/09/11 16:26:10 [E] 用户没有设置默认案场
+2018/09/11 16:26:13 [E] 用户没有设置默认案场
+2018/09/11 16:26:15 [E] 用户没有设置默认案场
+2018/09/11 16:28:05 [E] 用户没有设置默认案场
+2018/09/11 16:28:10 [E] 用户没有设置默认案场
+2018/09/11 16:28:53 [E] 用户没有设置默认案场
+2018/09/11 16:29:49 [E] 用户没有设置默认案场
+2018/09/11 16:29:59 [E] 用户没有设置默认案场
+2018/09/11 16:30:54 [E] 用户没有设置默认案场
+2018/09/11 16:31:08 [E] 用户没有设置默认案场
+2018/09/11 16:31:17 [E] 用户没有设置默认案场
+2018/09/11 16:32:10 [E] 用户没有设置默认案场
+2018/09/11 16:32:12 [E] 用户没有设置默认案场
+2018/09/11 16:32:25 [E] 用户没有设置默认案场
+2018/09/11 16:32:39 [E] 用户没有设置默认案场
+2018/09/11 16:32:53 [E] 用户没有设置默认案场
+2018/09/11 16:34:10 [E] 用户没有设置默认案场
+2018/09/11 16:34:10 [E] 用户没有设置默认案场
+2018/09/11 16:59:57 [E] 用户没有设置默认案场
+2018/09/11 17:00:53 [E] 用户没有设置默认案场
+2018/09/11 17:01:40 [E] 用户没有设置默认案场
+2018/09/11 17:02:35 [E] 用户没有设置默认案场

models/model/ta_customer.go

@@ -18,4 +18,5 @@ type TaCustomer struct {
 	CreateDate    time.Time `xorm:"DATETIME"`
 	Status        int       `xorm:"SMALLINT(6)"`
 	UserId        string    `xorm:"VARCHAR(64)"`
+	BindingDate   time.Time `xorm:"DATETIME"`
 }

models/statistics/statistics.go

@@ -0,0 +1,110 @@
+package statistics
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"strings"
+
+	"github.com/go-xorm/xorm"
+)
+
+// StatisticsDAO 当前数据库操作对象
+type StatisticsDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewStatisticsDAO New Inst
+func NewStatisticsDAO(ctx *utils.Context) *StatisticsDAO {
+	return &StatisticsDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+// GetCustomerCount 获取会员总数
+func (m *StatisticsDAO) GetCustomerCount(orgid string) (int, error) {
+	var customers []model.TaCustomer
+	err := m.db.Where("org_id=?", orgid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&customers)
+	if err != nil {
+		return 0, err
+	}
+	return len(customers), nil
+}
+
+// GetCourseOrderCount 获取课程预约总量
+func (m *StatisticsDAO) GetCourseOrderCount(caseids string) (int64, error) {
+	var courses = new(model.TaCustomerCourse)
+	total, err := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("status>"+strconv.Itoa(models.STATUS_DEL)).SumInt(courses, "course_num")
+	if err != nil {
+		return 0, err
+	}
+	return total, nil
+}
+
+// GetGoodsOrderCount 获取商品下单总量
+func (m *StatisticsDAO) GetGoodsOrderCount(caseids string) (int64, error) {
+	var goodsorder = new(model.TaGoodsOrders)
+	total, err := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("status>"+strconv.Itoa(models.STATUS_DEL)).SumInt(goodsorder, "orders_num")
+	if err != nil {
+		return 0, err
+	}
+	return total, nil
+}
+
+// GetCustomerCountByDate 根据时间获取新增会员数量
+func (m *StatisticsDAO) GetCustomerCountByDate(caseids, begindate, enddate string) (int, error) {
+	var customers []model.TaCustomer
+	err := m.db.Where("recommend_case in ('" + strings.Replace(caseids, ",", "','", -1) + "')").And("binding_date BETWEEN '" + begindate + "' AND '" + enddate + "'").And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&customers)
+	if err != nil {
+		return 0, err
+	}
+	return len(customers), nil
+}
+
+// GetCoursesCountByDate 根据时间获取课程数
+func (m *StatisticsDAO) GetCoursesCountByDate(caseids, begindate, enddate string) (int, error) {
+	var details []model.TaCourseDetail
+	sql := `select a.* from ta_course_detail a inner join ta_course b on a.course_id=b.course_id where b.status=` + strconv.Itoa(models.STATUS_NORMAL)
+	sql += ` and a.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `') and a.begin_date  BETWEEN '` + begindate + `' AND '` + enddate + `'`
+	err := m.db.Sql(sql).Find(&details)
+	if err != nil {
+		return 0, err
+	}
+	return len(details), nil
+}
+
+// GetCourseOrderCountByDate 根据时间获取课程预约数量
+func (m *StatisticsDAO) GetCourseOrderCountByDate(caseids, begindate, enddate string) (int64, error) {
+	courses := new(model.TaCustomerCourse)
+	total, err := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("status>"+strconv.Itoa(models.STATUS_DEL)).And("create_date BETWEEN '"+begindate+"' AND '"+enddate+"'").SumInt(courses, "course_num")
+	if err != nil {
+		return 0, err
+	}
+	return total, nil
+}
+
+// GetCourseVerifyCountByDate 根据时间获取课程核销人数
+func (m *StatisticsDAO) GetCourseVerifyCountByDate(caseids, begindate, enddate string) ([]model.TaCourseVerifcation, error) {
+	var courseVerify []model.TaCourseVerifcation
+	err := m.db.Where("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").And("status>" + strconv.Itoa(models.STATUS_DEL)).And("create_date BETWEEN '" + begindate + "' AND '" + enddate + "'").Find(&courseVerify)
+	return courseVerify, err
+}
+
+// GetGymVerifyCountByDate 根据时间获取健身卡核销人数
+func (m *StatisticsDAO) GetGymVerifyCountByDate(caseids, begindate, enddate string) ([]model.TaGymCardUsage, error) {
+	var gyms []model.TaGymCardUsage
+	err := m.db.Where("status>" + strconv.Itoa(models.STATUS_DEL)).And("use_case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").And("create_date BETWEEN '" + begindate + "' AND '" + enddate + "'").Find(&gyms)
+	return gyms, err
+}
+
+// GetGoodsOrderCountByDate 根据时间获取商品下单
+func (m *StatisticsDAO) GetGoodsOrderCountByDate(caseids, begindate, enddate string) ([]model.TaGoodsOrders, error) {
+	var goodsorder []model.TaGoodsOrders
+	err := m.db.Where("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").And("create_date BETWEEN '" + begindate + "' AND '" + enddate + "'").And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&goodsorder)
+	return goodsorder, err
+}
+
+//

service/customer/customer.go

@@ -9,6 +9,7 @@ import (
 	"spaceofcheng/services/service/events"
 	"spaceofcheng/services/utils"
 	"strconv"
+	"time"
 )
 
 // CustomerServ 系统处理
@@ -177,8 +178,9 @@ func (s *CustomerServ) BindWechatCust(userMap *model.TaUserMapping, phone, caseI
 		openid := wxInfo["openid"].(string)
 		customer, err := s.dao.GetCustWithWXByOpenID(openid)
 		newCust := model.TaCustomer{
-			CustomerId: customer.CustomerId,
-			Phone:      phone,
+			CustomerId:  customer.CustomerId,
+			Phone:       phone,
+			BindingDate: time.Now(),
 		}
 		// 校验案场信息
 		if caseID != "" {
@@ -218,6 +220,7 @@ func (s *CustomerServ) BindWechatCust(userMap *model.TaUserMapping, phone, caseI
 			"recommend_id",
 			"recommend_case",
 			"recommend_name",
+			"binding_date",
 		})
 		if err != nil {
 			utils.LogError(err.Error())