Skip to content

张云鹏 / uc-engine

Go to a project
Toggle navigation
Toggle navigation pinning
Commit 225e5813 225e5813121c3f225b2ee5db417f5aedaa5ea58c by xianghan
Options

1.添加发送绑定消息的日志记录

1 parent 7bfe629e
Inline Side-by-side
Showing 1 changed file with 9 additions and 5 deletions
...@@ -1067,8 +1067,10 @@ public class UserOperationServiceImpl implements UserOperationService { ...@@ -1067,8 +1067,10 @@ public class UserOperationServiceImpl implements UserOperationService {
1067 userTv.setId(userTvDTO.getId()); 1067 userTv.setId(userTvDTO.getId());
1068 userTv.setPriorityMemberCode(priorityMemberCode); 1068 userTv.setPriorityMemberCode(priorityMemberCode);
1069 // 更新大屏账户 1069 // 更新大屏账户
1070 userTvDTO = this.userTvService.doUpdatePriorityMemberCode(userTv); 1070 this.userTvService.doUpdatePriorityMemberCode(userTv);
1071 userTvDTO.setMemberCode(memberDTO.getCode()); 1071
1072
1073 userTvDTO.setPriorityMemberCode(memberDTO.getCode());
1072 } 1074 }
1073 1075
1074 Member member = new Member(); 1076 Member member = new Member();
...@@ -1094,9 +1096,10 @@ public class UserOperationServiceImpl implements UserOperationService { ...@@ -1094,9 +1096,10 @@ public class UserOperationServiceImpl implements UserOperationService {
1094 member.setBindIptvPlatformType(bindIptvPlatformType); 1096 member.setBindIptvPlatformType(bindIptvPlatformType);
1095 log.info("修改小屏会员对应的绑定关系，member ==>> {}", member); 1097 log.info("修改小屏会员对应的绑定关系，member ==>> {}", member);
1096 // 修改会员信息 1098 // 修改会员信息
1097 memberDTO = this.memberService.doUpdateMemberUserIptvIdAndBindIptvPlatformAndBindIptvTime(member); 1099 this.memberService.doUpdateMemberUserIptvIdAndBindIptvPlatformAndBindIptvTime(member);
1098 1100
1099 memberDTO.setPlatformAccount(platformAccount); 1101 memberDTO.setPlatformAccount(platformAccount);
1102 log.info("发送绑定消息至大屏，memberDTO ==>> {} || userTvDTO ==>> {}", memberDTO, userTvDTO);
1100 // 同步至iptv 1103 // 同步至iptv
1101 ((UserOperationServiceImpl)AopContext.currentProxy()) 1104 ((UserOperationServiceImpl)AopContext.currentProxy())
1102 .asyncMinaBind(new MemberAndUserTvDTO(memberDTO, userTvDTO)); 1105 .asyncMinaBind(new MemberAndUserTvDTO(memberDTO, userTvDTO));
...@@ -1141,6 +1144,8 @@ public class UserOperationServiceImpl implements UserOperationService { ...@@ -1141,6 +1144,8 @@ public class UserOperationServiceImpl implements UserOperationService {
1141 userTv.setPriorityMemberCode(memberDTO.getCode()); 1144 userTv.setPriorityMemberCode(memberDTO.getCode());
1142 1145
1143 this.userTvService.doUpdatePriorityMemberCode(userTv); 1146 this.userTvService.doUpdatePriorityMemberCode(userTv);
1147
1148 userTvDTO.setPriorityMemberCode(memberDTO.getCode());
1144 } 1149 }
1145 1150
1146 Member member = new Member(); 1151 Member member = new Member();
...@@ -1170,7 +1175,7 @@ public class UserOperationServiceImpl implements UserOperationService { ...@@ -1170,7 +1175,7 @@ public class UserOperationServiceImpl implements UserOperationService {
1170 1175
1171 memberDTO.setPlatformAccount(platformAccount); 1176 memberDTO.setPlatformAccount(platformAccount);
1172 1177
1173 log.info("发送到大屏侧的消息对象 会员信息 ==>> {} || 账号信息 ==>> {}", memberDTO , userTvDTO); 1178 log.info("发送绑定消息至大屏侧, 会员信息 ==>> {} || 账号信息 ==>> {}", memberDTO , userTvDTO);
1174 // 同步至iptv 1179 // 同步至iptv
1175 ((UserOperationServiceImpl)AopContext.currentProxy()).asyncMinaBind(new MemberAndUserTvDTO(memberDTO, userTvDTO)); 1180 ((UserOperationServiceImpl)AopContext.currentProxy()).asyncMinaBind(new MemberAndUserTvDTO(memberDTO, userTvDTO));
1176 1181
...@@ -1462,7 +1467,6 @@ public class UserOperationServiceImpl implements UserOperationService { ...@@ -1462,7 +1467,6 @@ public class UserOperationServiceImpl implements UserOperationService {
1462 1467
1463 1468
1464 1469
1465
1466 @AsyncMqSend 1470 @AsyncMqSend
1467 public void asyncMemberAndUserWeixin4Iptv(MemberAndWeixinUserDTO memberAndWeixinUserDTO) {} 1471 public void asyncMemberAndUserWeixin4Iptv(MemberAndWeixinUserDTO memberAndWeixinUserDTO) {}
1468 @AsyncMqSend 1472 @AsyncMqSend
......