zjxpcyc 6 anni fa
parent
commit
0503d6539f
4 ha cambiato i file con 12 aggiunte e 8 eliminazioni
  1. 1
    0
      models/sys.go
  2. 8
    7
      service/customer/customer.go
  3. 2
    0
      service/events/events.go
  4. 1
    1
      utils/log.go

+ 1
- 0
models/sys.go Vedi File

283
 func GetAllOrgs() ([]model.SysOrg, error) {
283
 func GetAllOrgs() ([]model.SysOrg, error) {
284
 	var orgs []model.SysOrg
284
 	var orgs []model.SysOrg
285
 	err := DBEngine.Where("status=?", STATUS_NORMAL).Asc("org_id").Find(&orgs)
285
 	err := DBEngine.Where("status=?", STATUS_NORMAL).Asc("org_id").Find(&orgs)
286
+
286
 	return orgs, err
287
 	return orgs, err
287
 }
288
 }

+ 8
- 7
service/customer/customer.go Vedi File

198
 		return nil, utils.LogError("获取用户信息失败", err.Error())
198
 		return nil, utils.LogError("获取用户信息失败", err.Error())
199
 	}
199
 	}
200
 
200
 
201
-	newCust := model.TaCustomer{
202
-		CustomerId:  customer.CustomerId,
203
-		Phone:       phone,
204
-		BindingDate: time.Now(),
205
-	}
201
+	newCust := customer.TaCustomer
202
+	newCust.Phone = phone
203
+	newCust.BindingDate = time.Now().Local()
204
+
206
 	// 校验案场信息
205
 	// 校验案场信息
207
 	if recommendCode != "" {
206
 	if recommendCode != "" {
208
 		user, err := s.dao.GetSalesByRecommendCode(recommendCode)
207
 		user, err := s.dao.GetSalesByRecommendCode(recommendCode)
269
 
268
 
270
 	// triggerRegiteEvent 触发注册事件
269
 	// triggerRegiteEvent 触发注册事件
271
 	// if cust.RecommendCase != "" {
270
 	// if cust.RecommendCase != "" {
272
-	evtEngID := utils.EngineIDBy(cust.OrgId, "")
273
-	utils.EventEngineBus(evtEngID).EmitEvent(events.EvtRegiste, *cust)
271
+	evtEngID := utils.EngineIDBy(customer.OrgId, "")
272
+	evtEngine := utils.EventEngineBus(evtEngID)
273
+
274
+	evtEngine.EmitEvent(events.EvtRegiste, *cust)
274
 	// }
275
 	// }
275
 
276
 
276
 	// 如果客户ID 与映射表中一致, 说明已经绑定过了
277
 	// 如果客户ID 与映射表中一致, 说明已经绑定过了

+ 2
- 0
service/events/events.go Vedi File

81
 		}
81
 		}
82
 
82
 
83
 		for _, act := range acts {
83
 		for _, act := range acts {
84
+			utils.LogInfo(act)
85
+
84
 			// 加入 tpEvts 需要去重
86
 			// 加入 tpEvts 需要去重
85
 			if utils.StrSliceIndexOf(tpEvts, act.ActiveType) == -1 {
87
 			if utils.StrSliceIndexOf(tpEvts, act.ActiveType) == -1 {
86
 				tpEvts = append(tpEvts, act.ActiveType)
88
 				tpEvts = append(tpEvts, act.ActiveType)

+ 1
- 1
utils/log.go Vedi File

90
 		preMsg = fmt.Sprintf("file: %s    line=%d : ", file, line)
90
 		preMsg = fmt.Sprintf("file: %s    line=%d : ", file, line)
91
 	}
91
 	}
92
 
92
 
93
-	log.Error(preMsg, v...)
93
+	log.Info(preMsg, v...)
94
 }
94
 }
95
 
95
 
96
 // GetDefaultLogger 获取默认 logger
96
 // GetDefaultLogger 获取默认 logger