更新

controllers/customer/customer.go

@@ -32,7 +32,13 @@ func (c *CustomerController) CustWXList() {
 	page, _ := c.GetInt("page")
 	pageSize, _ := c.GetInt("pagesize")
 
-	custList, total, err := c.serv.GetCustWithWXList(phone, username, recommendname, begindate, enddate, page, pageSize)
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+
+	custList, total, err := c.serv.GetCustWithWXList(phone, username, recommendname, begindate, enddate, caseids, page, pageSize)
 	if err != nil {
 		utils.LogError("获取客户列表失败: " + err.Error())
 		c.ResponseError(

log/common.log

@@ -10,3 +10,114 @@
 2018/09/19 14:00:13 [E] 获取人员信息失败: 获取人员信息失败
 2018/09/19 14:00:18 [E] 获取发送卡信息失败: Error 1054: Unknown column 'serial_code' in 'field list'
 2018/09/19 14:00:18 [E] 获取人员信息失败: 获取人员信息失败
+2018/09/19 15:43:34 [E] 用户没有设置默认案场
+2018/09/19 15:43:34 [E] 用户没有设置默认案场
+2018/09/19 15:43:36 [E] 用户没有设置默认案场
+2018/09/19 15:43:36 [E] 用户没有设置默认案场
+2018/09/19 15:43:41 [E] 用户没有设置默认案场
+2018/09/19 15:43:42 [E] 用户没有设置默认案场
+2018/09/19 15:43:45 [E] 用户没有设置默认案场
+2018/09/19 15:43:45 [E] 用户没有设置默认案场
+2018/09/19 15:43:45 [E] 用户没有设置默认案场
+2018/09/19 15:43:48 [E] 用户没有设置默认案场
+2018/09/19 15:43:48 [E] 用户没有设置默认案场
+2018/09/19 15:46:57 [E] 用户没有设置默认案场
+2018/09/19 15:46:57 [E] 用户没有设置默认案场
+2018/09/19 15:46:58 [E] 用户没有设置默认案场
+2018/09/19 15:46:58 [E] 用户没有设置默认案场
+2018/09/19 15:47:00 [E] 用户没有设置默认案场
+2018/09/19 15:47:00 [E] 用户没有设置默认案场
+2018/09/19 15:47:01 [E] 用户没有设置默认案场
+2018/09/19 15:47:06 [E] 用户没有设置默认案场
+2018/09/19 15:47:06 [E] 用户没有设置默认案场
+2018/09/19 15:47:10 [E] 用户没有设置默认案场
+2018/09/19 15:47:10 [E] 用户没有设置默认案场
+2018/09/19 15:47:11 [E] 用户没有设置默认案场
+2018/09/19 15:47:11 [E] 用户没有设置默认案场
+2018/09/19 15:47:14 [E] 用户没有设置默认案场
+2018/09/19 15:47:14 [E] 用户没有设置默认案场
+2018/09/19 15:47:15 [E] 用户没有设置默认案场
+2018/09/19 15:47:15 [E] 用户没有设置默认案场
+2018/09/19 15:47:19 [E] 用户没有设置默认案场
+2018/09/19 15:47:19 [E] 用户没有设置默认案场
+2018/09/19 15:48:07 [E] 用户没有设置默认案场
+2018/09/19 15:48:07 [E] 用户没有设置默认案场
+2018/09/19 15:48:14 [E] 用户没有设置默认案场
+2018/09/19 15:48:14 [E] 用户没有设置默认案场
+2018/09/19 15:48:14 [E] 用户没有设置默认案场
+2018/09/19 15:49:00 [E] 用户没有设置默认案场
+2018/09/19 15:49:04 [E] 用户没有设置默认案场
+2018/09/19 15:49:05 [E] 用户没有设置默认案场
+2018/09/19 15:49:43 [E] 用户没有设置默认案场
+2018/09/19 15:49:46 [E] 用户没有设置默认案场
+2018/09/19 15:49:47 [E] 用户没有设置默认案场
+2018/09/19 15:50:07 [E] 用户没有设置默认案场
+2018/09/19 15:50:08 [E] 用户没有设置默认案场
+2018/09/19 15:50:08 [E] 用户没有设置默认案场
+2018/09/19 15:50:15 [E] 用户没有设置默认案场
+2018/09/19 15:50:15 [E] 用户没有设置默认案场
+2018/09/19 15:50:27 [E] 用户没有设置默认案场
+2018/09/19 15:50:27 [E] 用户没有设置默认案场
+2018/09/19 15:50:48 [E] 用户没有设置默认案场
+2018/09/19 15:50:48 [E] 用户没有设置默认案场
+2018/09/19 15:50:50 [E] 用户没有设置默认案场
+2018/09/19 15:50:51 [E] 用户没有设置默认案场
+2018/09/19 15:50:51 [E] 用户没有设置默认案场
+2018/09/19 15:50:51 [E] 用户没有设置默认案场
+2018/09/19 15:50:53 [E] 用户没有设置默认案场
+2018/09/19 15:50:53 [E] 用户没有设置默认案场
+2018/09/19 15:51:05 [E] 用户没有设置默认案场
+2018/09/19 15:51:06 [E] 用户没有设置默认案场
+2018/09/19 15:51:07 [E] 用户没有设置默认案场
+2018/09/19 15:51:07 [E] 用户没有设置默认案场
+2018/09/19 15:51:08 [E] 用户没有设置默认案场
+2018/09/19 15:51:08 [E] 用户没有设置默认案场
+2018/09/19 15:51:12 [E] 用户没有设置默认案场
+2018/09/19 15:51:12 [E] 用户没有设置默认案场
+2018/09/19 15:51:15 [E] 用户没有设置默认案场
+2018/09/19 15:51:15 [E] 用户没有设置默认案场
+2018/09/19 15:51:42 [E] 用户没有设置默认案场
+2018/09/19 15:51:42 [E] 用户没有设置默认案场
+2018/09/19 15:53:40 [E] 用户没有设置默认案场
+2018/09/19 15:53:45 [E] 用户没有设置默认案场
+2018/09/19 15:53:45 [E] 用户没有设置默认案场
+2018/09/19 15:54:56 [E] 用户没有设置默认案场
+2018/09/19 15:55:15 [E] 用户没有设置默认案场
+2018/09/19 15:55:15 [E] 用户没有设置默认案场
+2018/09/19 16:00:01 [E] 用户没有设置默认案场
+2018/09/19 16:00:01 [E] 用户没有设置默认案场
+2018/09/19 16:00:01 [E] 获取客户列表失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '== '' or t.recommend_case is null)
+		 ORDER BY
+			t.create_date DESC
+	) as virtu' at line 19
+2018/09/19 16:00:51 [E] 用户没有设置默认案场
+2018/09/19 16:00:51 [E] 用户没有设置默认案场
+2018/09/19 16:01:04 [E] 用户没有设置默认案场
+2018/09/19 16:01:04 [E] 用户没有设置默认案场
+2018/09/19 16:07:17 [E] 获取用户基本信息失败: 没有查询到 ID (OPENID) 对应的用户
+2018/09/19 16:09:54 [E] 用户没有设置默认案场
+2018/09/19 16:09:54 [E] 用户没有设置默认案场
+2018/09/19 16:09:59 [E] 用户没有设置默认案场
+2018/09/19 16:10:01 [E] 用户没有设置默认案场
+2018/09/19 16:10:01 [E] 用户没有设置默认案场
+2018/09/19 16:10:06 [E] 用户没有设置默认案场
+2018/09/19 16:10:09 [E] 用户没有设置默认案场
+2018/09/19 16:10:09 [E] 用户没有设置默认案场
+2018/09/19 16:10:25 [E] 用户没有设置默认案场
+2018/09/19 16:10:26 [E] 用户没有设置默认案场
+2018/09/19 16:10:26 [E] 用户没有设置默认案场
+2018/09/19 16:10:28 [E] 用户没有设置默认案场
+2018/09/19 16:10:29 [E] 用户没有设置默认案场
+2018/09/19 16:10:30 [E] 用户没有设置默认案场
+2018/09/19 16:10:31 [E] 用户没有设置默认案场
+2018/09/19 16:10:31 [E] 用户没有设置默认案场
+2018/09/19 16:10:32 [E] 用户没有设置默认案场
+2018/09/19 16:10:33 [E] 用户没有设置默认案场
+2018/09/19 16:10:33 [E] 用户没有设置默认案场
+2018/09/19 16:10:33 [E] 用户没有设置默认案场
+2018/09/19 16:10:35 [E] 用户没有设置默认案场
+2018/09/19 16:10:36 [E] 用户没有设置默认案场
+2018/09/19 16:10:36 [E] 用户没有设置默认案场
+2018/09/19 16:10:37 [E] 用户没有设置默认案场
+2018/09/19 16:10:38 [E] 用户没有设置默认案场
+2018/09/19 16:10:38 [E] 用户没有设置默认案场

models/card/card.go

@@ -229,7 +229,7 @@ type CaseUsableCard struct {
 // GetCaseUsableCard 获取案场可用卡信息
 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() and send_type=? order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	sql := `select * from ta_coupon_card where case_id=? and status=? and DATE_FORMAT(end_date, '%Y-%m-%d')>=DATE_FORMAT(NOW(), '%Y-%m-%d') and send_type=? order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL, models.GIVE_TYPE_CASE).Find(&cards)
 	for inx, card := range cards {
 		if userid != "" {
@@ -251,7 +251,7 @@ func (m *CardDAO) GetCaseUsableCard(caseid, userid string, page, pageSize int) (
 // GetCaseUsableCardCount 获取案场可用卡数量
 func (m *CardDAO) GetCaseUsableCardCount(caseid, userid string) (int, error) {
 	var Coupons []CaseUsableCard
-	sql := `select * from ta_coupon_card where case_id=? and status=? and end_date>now() and send_type=?`
+	sql := `select * from ta_coupon_card where case_id=? and status=? and DATE_FORMAT(end_date, '%Y-%m-%d')>=DATE_FORMAT(NOW(), '%Y-%m-%d') and send_type=?`
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL, models.GIVE_TYPE_CASE).Find(&Coupons)
 	return len(Coupons), err
 }

models/coupon/coupon.go

@@ -291,7 +291,7 @@ func (m *CouponDAO) GetCouponBySendType(caseids, sendtype string) ([]model.TaCou
 // GetCaseUsableCoupon 获取案场可用优惠券信息
 func (m *CouponDAO) GetCaseUsableCoupon(caseid, userid string, page, pageSize int) ([]CaseCouponDetail, error) {
 	var Coupons []CaseCouponDetail
-	sql := `select * from ta_coupon where case_id=? and status=? and end_date>now() and send_type=? order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	sql := `select * from ta_coupon where case_id=? and status=? and DATE_FORMAT(end_date, '%Y-%m-%d')>=DATE_FORMAT(NOW(), '%Y-%m-%d') and send_type=? order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL, models.GIVE_TYPE_CASE).Find(&Coupons)
 	for inx, coupon := range Coupons {
 		if userid != "" {
@@ -320,7 +320,7 @@ func (m *CouponDAO) GetCouponShareByCouponID(couponid string) (*model.TaCouponSh
 // GetCaseUsableCouponCount 获取案场可用优惠券数量
 func (m *CouponDAO) GetCaseUsableCouponCount(caseid, userid string) (int, error) {
 	var Coupons []CaseCouponDetail
-	sql := `select * from ta_coupon where case_id=? and status=? and end_date>now() and send_type=?`
+	sql := `select * from ta_coupon where case_id=? and status=? and DATE_FORMAT(end_date, '%Y-%m-%d')>=DATE_FORMAT(NOW(), '%Y-%m-%d') and send_type=?`
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL, models.GIVE_TYPE_CASE).Find(&Coupons)
 
 	return len(Coupons), err

models/customer/customer.go

@@ -5,6 +5,7 @@ import (
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
+	"strings"
 	"time"
 
 	"github.com/yl10/kit/guid"
@@ -27,7 +28,7 @@ func NewCustomerDAO(ctx *utils.Context) *CustomerDAO {
 }
 
 // CustWithWXList 客户列表
-func (m *CustomerDAO) CustWithWXList(phone, username, recommendname, begindate, enddate string, page ...int) ([]CustWithWX, int64, error) {
+func (m *CustomerDAO) CustWithWXList(phone, username, recommendname, begindate, enddate, caseids string, page ...int) ([]CustWithWX, int64, error) {
 	org := m.ctx.Get("org").(model.SysOrg)
 
 	if phone == "" {
@@ -82,7 +83,9 @@ func (m *CustomerDAO) CustWithWXList(phone, username, recommendname, begindate,
 			AND t.customer_name like ?
 			AND t.recommend_name like ?
 		AND t.status > ?
-		AND t.org_id = '` + org.OrgId + `'`
+		AND t.org_id = '` + org.OrgId + `'
+		AND (t.recommend_case in ('` + strings.Replace(caseids, ",", "','", -1) + `') or t.recommend_case = '' or t.recommend_case is null)
+		`
 
 	if begindate != "" {
 		query = query + ` AND t.create_date>'` + begindate + `'`

models/sys.go

@@ -180,7 +180,7 @@ func UpdateTokenExpire(token, uid string) error {
 
 			if _, err := DBEngine.Cols("status").
 				Where("token=?", token).
-				Or("batch_no in ('" + strings.Join(batchNo, "','") + "'").
+				Or("batch_no in ('" + strings.Join(batchNo, "','") + "')").
 				Update(&tk); err != nil {
 				return err
 			}

service/customer/customer.go

@@ -41,8 +41,8 @@ func NewCustomerServ(ctx *utils.Context) *CustomerServ {
 }
 
 // GetCustWithWXList 获取客户列表
-func (s *CustomerServ) GetCustWithWXList(phone, username, recommendname, begindate, enddate string, page ...int) ([]customer.CustWithWX, int64, error) {
-	return s.dao.CustWithWXList(phone, username, recommendname, begindate, enddate, page...)
+func (s *CustomerServ) GetCustWithWXList(phone, username, recommendname, begindate, enddate, caseids string, page ...int) ([]customer.CustWithWX, int64, error) {
+	return s.dao.CustWithWXList(phone, username, recommendname, begindate, enddate, caseids, page...)
 }
 
 // GetCustWithWXByID 获取客户列表