Browse Source

提交评论管理接口

xuzuoyun 5 years ago
parent
commit
3d9b8b903b

+ 18 - 11
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/graphql/service/impl/KuaishouWebInterfaceServiceImpl.java

@@ -996,18 +996,25 @@ public class KuaishouWebInterfaceServiceImpl implements IKuaishouWebInterfaceSer
                         System.out.println(threadHttpClientEntity.getResult());
                         threadHttpClientEntity = httpClientUtils.callingGraph(threadHttpClientEntity, userInfoQuery());
                         System.out.println(threadHttpClientEntity.getResult());
-                        KuaishouUserCookie kuaishouUserCookie = new KuaishouUserCookie();
-                        kuaishouUserCookie.setCookie(new Gson().toJson(threadHttpClientEntity.getCookieStore()));
-                        kuaishouUserCookie.setKsid(String.valueOf(kuaishouUserVO.getUserId()));
-                        kuaishouUserCookie.setEid(kuaishouUserVO.getEid());
-                        kuaishouUserCookie.setUserName(kuaishouUserVO.getUserName());
                         LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
-//                        if(user == null){
-//                            user = new LoginUser();
-//                            user.setId("xxa");
-//                        }
-                        kuaishouUserCookie.setUserId(user.getId());
-                        kuaishouUserCookieService.saveOrUpdate(kuaishouUserCookie);
+                        QueryWrapper<KuaishouUserCookie> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("user_id", user.getId());
+                        queryWrapper.eq("ksid", kuaishouUserVO.getUserId());
+                        KuaishouUserCookie kuaishouUserCookie = kuaishouUserCookieService.getOne(queryWrapper);
+                        if (kuaishouUserCookie == null) {
+                            kuaishouUserCookie = new KuaishouUserCookie();
+                            kuaishouUserCookie.setCookie(new Gson().toJson(threadHttpClientEntity.getCookieStore()));
+                            kuaishouUserCookie.setKsid(String.valueOf(kuaishouUserVO.getUserId()));
+                            kuaishouUserCookie.setEid(kuaishouUserVO.getEid());
+                            kuaishouUserCookie.setUserName(kuaishouUserVO.getUserName());
+                            kuaishouUserCookie.setUserId(user.getId());
+                            kuaishouUserCookieService.save(kuaishouUserCookie);
+                        } else {
+                            kuaishouUserCookie.setCookie(new Gson().toJson(threadHttpClientEntity.getCookieStore()));
+                            kuaishouUserCookie.setUserName(kuaishouUserVO.getUserName());
+                            kuaishouUserCookieService.update(kuaishouUserCookie, queryWrapper);
+                        }
+
                     } catch (Exception e) {
                         e.printStackTrace();
                     }