change event trigger condition

models/sys.go

@@ -278,3 +278,10 @@ func GetCaseByID(caseID string) (cs *model.SysCase, err error) {
 	_, err = DBEngine.Where("case_id=?", caseID).Get(cs)
 	return cs, err
 }
+
+// GetAllOrgs 获取所有机构
+func GetAllOrgs() ([]model.SysOrg, error) {
+	var orgs []model.SysOrg
+	err := DBEngine.Where("status=?", STATUS_NORMAL).Asc("org_id").Find(&orgs)
+	return orgs, err
+}

service/events/events.go

@@ -29,11 +29,12 @@ func ListenAllEvent(orgID, caseID string) {
 	mtx.Lock()
 	defer mtx.Unlock()
 
-	evtEngID := utils.EngineIDBy(orgID, caseID)
+	// 2018年10月30日 yansen 不区分案场
+	evtEngID := utils.EngineIDBy(orgID, "")
 	evtEngine := utils.ResetEventEngineBus(evtEngID)
 
 	// 所有需要执行的事件
-	allEvts, err := getAllEvents(orgID, caseID)
+	allEvts, err := getAllEvents(orgID, "")
 	if err != nil {
 		utils.LogError(err)
 	}
@@ -58,7 +59,7 @@ func getAllEvents(orgID, caseID string) (map[string][]string, error) {
 	var acts []model.SysActivityAction
 
 	if err := db.Where("org_id=?", orgID).
-		And("case_id=?", caseID).
+		// And("case_id=?", caseID).
 		And("status=?", models.STATUS_NORMAL).
 		Find(&evts); err != nil {
 		utils.LogError("查询营销活动配置表失败: " + err.Error())
@@ -99,13 +100,24 @@ var tsAction = func(e tinyevent.Event) error {
 }
 
 func EventInit() {
-	cases, err := models.GetAllCases()
+	// cases, err := models.GetAllCases()
+	// if err != nil {
+	// 	utils.LogError("获取有效案场列表失败: " + err.Error())
+	// 	return
+	// }
+
+	// for _, cs := range cases {
+	// 	ListenAllEvent(cs.OrgId, cs.CaseId)
+	// }
+
+	// 不区分案场
+	orgs, err := models.GetAllOrgs()
 	if err != nil {
-		utils.LogError("获取有效案场列表失败: " + err.Error())
+		utils.LogError("获取机构列表失败: " + err.Error())
 		return
 	}
 
-	for _, cs := range cases {
-		ListenAllEvent(cs.OrgId, cs.CaseId)
+	for _, org := range orgs {
+		ListenAllEvent(org.OrgId, "")
 	}
 }

service/events/giveCard.go

@@ -22,10 +22,13 @@ var giveCard = func(e tinyevent.Event) error {
 		return errors.New("注册送卡失败, 没有用户信息")
 	}
 	cust := e.Payload.(model.TaCustomer)
-	caseID := cust.RecommendCase
+	// caseID := cust.RecommendCase
 	orgID := cust.OrgId
 
 	utils.LogInfo("被赠送人: " + cust.CustomerId)
+
+	// 不区分案场，随便送
+	// 2018年10月30日 yansen 按照产品要求
 	query := `
 		SELECT
 			t.*
@@ -35,13 +38,12 @@ var giveCard = func(e tinyevent.Event) error {
 		WHERE
 		t.active_type = 'giveCard'
 		AND	s.org_id = ?
-		AND s.case_id = ?
 		AND s.status = ?
 		AND s.activity_type = ?
 	`
 
 	var acts []model.SysActivityAction
-	if err := models.DBEngine.SQL(query, orgID, caseID, models.STATUS_NORMAL, e.Name).Find(&acts); err != nil {
+	if err := models.DBEngine.SQL(query, orgID, models.STATUS_NORMAL, e.Name).Find(&acts); err != nil {
 		utils.LogError("检查营销活动失败: " + err.Error())
 		return errors.New("检查营销活动失败")
 	}

service/events/giveCoupon.go

@@ -26,11 +26,13 @@ var giveCoupon = func(e tinyevent.Event) error {
 	}
 
 	cust := e.Payload.(model.TaCustomer)
-	caseID := cust.RecommendCase
+	// caseID := cust.RecommendCase
 	orgID := cust.OrgId
 
 	utils.LogInfo("被赠送人: " + cust.CustomerId)
 
+	// 不区分案场，随便送
+	// 2018年10月30日 yansen 按照产品要求
 	query := `
 		SELECT
 			t.*
@@ -40,13 +42,12 @@ var giveCoupon = func(e tinyevent.Event) error {
 		WHERE
 		t.active_type = 'giveCoupon'
 		AND	s.org_id = ?
-		AND s.case_id = ?
 		AND s.status = ?
 		AND s.activity_type = ?
 	`
 
 	var acts []model.SysActivityAction
-	if err := models.DBEngine.SQL(query, orgID, caseID, models.STATUS_NORMAL, e.Name).Find(&acts); err != nil {
+	if err := models.DBEngine.SQL(query, orgID, models.STATUS_NORMAL, e.Name).Find(&acts); err != nil {
 		utils.LogError("检查营销活动失败: " + err.Error())
 		return errors.New("检查营销活动失败")
 	}