|
|
|
|
|
|
|
|
"time" |
|
|
"time" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
func onSubscribe(in* InWechatMsg) { |
|
|
|
|
|
|
|
|
func onSubscribe(in *InWechatMsg) { |
|
|
openID := in.header.FromUserName |
|
|
openID := in.header.FromUserName |
|
|
//check whether we have his own record in the CRM system |
|
|
//check whether we have his own record in the CRM system |
|
|
info, found, err := crmFindLeadByOpenID(openID) |
|
|
info, found, err := crmFindLeadByOpenID(openID) |
|
|
|
|
|
|
|
|
sendGreeting4ExistingUser(in, info) |
|
|
sendGreeting4ExistingUser(in, info) |
|
|
} else { //new user |
|
|
} else { //new user |
|
|
//get user info from wechat |
|
|
//get user info from wechat |
|
|
info := WechatUserInfo{} |
|
|
|
|
|
info.getUserInfo(openID, "zh_CN") |
|
|
|
|
|
info.registerNewLeadWithInfo(in.header.FromUserName) |
|
|
|
|
|
|
|
|
crmCreateLeadByOpenID(openID) |
|
|
in.askUserFillupBasicInfo() |
|
|
in.askUserFillupBasicInfo() |
|
|
} |
|
|
} |
|
|
//some error happened |
|
|
//some error happened |
|
|
|
|
|
|
|
|
templateSendJoinCommunity(in.header.FromUserName, url, first, remark, communityName, joinDate) |
|
|
templateSendJoinCommunity(in.header.FromUserName, url, first, remark, communityName, joinDate) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func sendGreeting4ExistingUser(in* InWechatMsg, info crmdLead) { |
|
|
|
|
|
|
|
|
func sendGreeting4ExistingUser(in *InWechatMsg, info crmdLead) { |
|
|
|
|
|
|
|
|
first := "欢迎" + info.Name + "返回澳洲校友会" |
|
|
first := "欢迎" + info.Name + "返回澳洲校友会" |
|
|
//url := "http://wechat.hitxy.org.au/profile_newly_register" |
|
|
//url := "http://wechat.hitxy.org.au/profile_newly_register" |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
//when user left |
|
|
//when user left |
|
|
func onUnSubscribe(in* InWechatMsg) { |
|
|
|
|
|
|
|
|
func onUnSubscribe(in *InWechatMsg) { |
|
|
info, found, err := crmFindLeadByOpenID(in.header.FromUserName) |
|
|
info, found, err := crmFindLeadByOpenID(in.header.FromUserName) |
|
|
|
|
|
|
|
|
if err != nil { |
|
|
if err != nil { |