|
@@ -79,10 +79,12 @@ public class WxMessageEvenServiceImpl implements IWxMessageEvenService {
|
|
|
public String scanSubscribeEvent(String fromUserName, String ticket,String token) {
|
|
|
|
|
|
String message = "";
|
|
|
- //判断是否存在父级推广关系
|
|
|
+ //判断是否存在父、子级推广关系
|
|
|
List<WxSpreadRelation> spreadRelations = wxSpreadRelationService.list(new QueryWrapper<WxSpreadRelation>().eq("openid", fromUserName));
|
|
|
- if (spreadRelations.isEmpty()){
|
|
|
- String openid = (String) redisTemplate.opsForValue().get(Constants.GZH_TICKET_KEY + ticket);
|
|
|
+ List<WxSpreadRelation> spreads = wxSpreadRelationService.list(new QueryWrapper<WxSpreadRelation>().eq("parent_openid", fromUserName));
|
|
|
+ String openid = (String) redisTemplate.opsForValue().get(Constants.GZH_TICKET_KEY + ticket);
|
|
|
+
|
|
|
+ if (spreadRelations.isEmpty() && spreads.isEmpty()){
|
|
|
//保存推广关系表
|
|
|
WxSpreadRelation wxSpreadRelation = new WxSpreadRelation();
|
|
|
wxSpreadRelation.setOpenid(fromUserName);
|
|
@@ -103,6 +105,8 @@ public class WxMessageEvenServiceImpl implements IWxMessageEvenService {
|
|
|
log.info("回复客服消息:[{}],响应信息:[{}]",jsonString,jsonObject);
|
|
|
|
|
|
message = "已成功绑定推广关系!";
|
|
|
+ }else if (!spreads.isEmpty()){
|
|
|
+ message = "已存在下级绑定关系!";
|
|
|
}else {
|
|
|
message = "已存在推广关系!";
|
|
|
}
|