add try

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/UserDataServiceImpl.java

@@ -11,6 +11,8 @@ import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.feign.adam.api.FeignAdamBaseClient;
 import com.liquidnet.service.sweet.config.WechatMpConfigure;
 import com.liquidnet.service.sweet.entity.SweetAppletUser;
+import com.liquidnet.service.sweet.entity.SweetAppletUsers;
+import com.liquidnet.service.sweet.entity.SweetWechatUsers;
 import com.liquidnet.service.sweet.mapper.SweetAppletUserMapper;
 import com.liquidnet.service.sweet.mapper.SweetAppletUsersMapper;
 import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
@@ -203,40 +205,44 @@ public class UserDataServiceImpl {
             for (SweetAppletUser info : sweetAppletUsers) {
                 SweetAppletUsersVo oldInfo = redisUtils.getSweetAppletUsersOfPhone(info.getGetPurePhoneNumber());
                 if (null == oldInfo) {
-                    ResponseDto<AdamUserInfoVo> userInfoVo = feignAdamBaseClient.registerByMobile(info.getGetPurePhoneNumber());
-                    AdamUserInfoVo userInfoVoData = userInfoVo.getData();
-                    String userId = userInfoVoData.getUid();
-
-                    LinkedList<String> sqlsA = CollectionUtil.linkedListString();
-                    LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-                    sqlsA.add(SqlMapping.get("sweet_applet_users.insert"));
-                    sqlsDataA.add(new Object[]{
-                            info.getUserId(), userId, info.getOpenId(), info.getUnionId(), info.getGetPhoneNumber(), info.getGetPurePhoneNumber(), info.getGetCountryCode(), info.getType()
-                    });
-                    queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
-                            SqlMapping.gets(sqlsA, sqlsDataA));
-
-                    /*SweetAppletUsers sweetAppletUsers1 = new SweetAppletUsers();
-                    sweetAppletUsers1.setAppletUserId(info.getUserId());
-                    sweetAppletUsers1.setUserId(userId);
-                    sweetAppletUsers1.setOpenId(info.getOpenId());
-                    sweetAppletUsers1.setUnionId(info.getUnionId());
-                    sweetAppletUsers1.setPhoneNumber(info.getGetPhoneNumber());
-                    sweetAppletUsers1.setPurePhoneNumber(info.getGetPurePhoneNumber());
-                    sweetAppletUsers1.setCountryCode(info.getGetCountryCode());
-                    sweetAppletUsers1.setType(info.getType());
-                    appletUsersMapper.insert(sweetAppletUsers1);*/
-
-                    SweetAppletUsersVo sweetAppletUsersVo = SweetAppletUsersVo.getNew();
-                    sweetAppletUsersVo.setAppletUserId(info.getUserId());
-                    sweetAppletUsersVo.setUserId(userId);
-                    sweetAppletUsersVo.setOpenId(info.getOpenId());
-                    sweetAppletUsersVo.setUnionId(info.getUnionId());
-                    sweetAppletUsersVo.setPhoneNumber(info.getGetPhoneNumber());
-                    sweetAppletUsersVo.setPurePhoneNumber(info.getGetPurePhoneNumber());
-                    sweetAppletUsersVo.setCountryCode(info.getGetCountryCode());
-                    sweetAppletUsersVo.setType(info.getType());
-                    redisUtils.setSweetAppletUsers(sweetAppletUsersVo);
+                    try {
+                        ResponseDto<AdamUserInfoVo> userInfoVo = feignAdamBaseClient.registerByMobile(info.getGetPurePhoneNumber());
+                        AdamUserInfoVo userInfoVoData = userInfoVo.getData();
+                        String userId = userInfoVoData.getUid();
+
+                        LinkedList<String> sqlsA = CollectionUtil.linkedListString();
+                        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+                        sqlsA.add(SqlMapping.get("sweet_applet_users.insert"));
+                        sqlsDataA.add(new Object[]{
+                                info.getUserId(), userId, info.getOpenId(), info.getUnionId(), info.getGetPhoneNumber(), info.getGetPurePhoneNumber(), info.getGetCountryCode(), info.getType()
+                        });
+                        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_WECHAT_USER_INSERT.getKey(),
+                                SqlMapping.gets(sqlsA, sqlsDataA));
+
+                        /*SweetAppletUsers sweetAppletUsers1 = new SweetAppletUsers();
+                        sweetAppletUsers1.setAppletUserId(info.getUserId());
+                        sweetAppletUsers1.setUserId(userId);
+                        sweetAppletUsers1.setOpenId(info.getOpenId());
+                        sweetAppletUsers1.setUnionId(info.getUnionId());
+                        sweetAppletUsers1.setPhoneNumber(info.getGetPhoneNumber());
+                        sweetAppletUsers1.setPurePhoneNumber(info.getGetPurePhoneNumber());
+                        sweetAppletUsers1.setCountryCode(info.getGetCountryCode());
+                        sweetAppletUsers1.setType(info.getType());
+                        appletUsersMapper.insert(sweetAppletUsers1);*/
+
+                        SweetAppletUsersVo sweetAppletUsersVo = SweetAppletUsersVo.getNew();
+                        sweetAppletUsersVo.setAppletUserId(info.getUserId());
+                        sweetAppletUsersVo.setUserId(userId);
+                        sweetAppletUsersVo.setOpenId(info.getOpenId());
+                        sweetAppletUsersVo.setUnionId(info.getUnionId());
+                        sweetAppletUsersVo.setPhoneNumber(info.getGetPhoneNumber());
+                        sweetAppletUsersVo.setPurePhoneNumber(info.getGetPurePhoneNumber());
+                        sweetAppletUsersVo.setCountryCode(info.getGetCountryCode());
+                        sweetAppletUsersVo.setType(info.getType());
+                        redisUtils.setSweetAppletUsers(sweetAppletUsersVo);
+                    } catch (Exception e) {
+                        log.error("feignAdamBaseClientException phone:{}, e:{}", info.getGetPurePhoneNumber(), e);
+                    }
                 }
             }
         }