From 69cb3ca5c0fd5f78b0c33bf92601066a37b0209e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 27 十月 2020 17:36:41 +0800
Subject: [PATCH] 爱奇艺/风行资源优化
---
src/main/java/com/yeshi/buwan/service/imp/UserService.java | 430 +++++++++++++++++++++++++++--------------------------
1 files changed, 221 insertions(+), 209 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/UserService.java b/src/main/java/com/yeshi/buwan/service/imp/UserService.java
index f291d87..474719d 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/UserService.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/UserService.java
@@ -24,242 +24,254 @@
@Service
public class UserService {
- public UserService() {
+ public UserService() {
- }
+ }
- @Resource
- private UserDao userDao;
+ @Resource
+ private UserDao userDao;
- @Resource
- private LoginUserDao loginUserDao;
+ @Resource
+ private LoginUserDao loginUserDao;
- public UserDao getUserDao() {
- return userDao;
- }
+ public UserDao getUserDao() {
+ return userDao;
+ }
- public void setUserDao(UserDao userDao) {
- this.userDao = userDao;
- }
+ public void setUserDao(UserDao userDao) {
+ this.userDao = userDao;
+ }
- // 鐢ㄦ埛鎿嶄綔
- public List<UserInfo> getUserList(int system, int page) {
- return userDao.list("from UserInfo u where u.system.id=? order by u.createtime desc",
- (page - 1) * Constant.pageCount, Constant.pageCount, new String[] { system + "" });
- }
+ // 鐢ㄦ埛鎿嶄綔
+ public List<UserInfo> getUserList(int system, int page) {
+ return userDao.list("from UserInfo u where u.system.id=? order by u.createtime desc",
+ (page - 1) * Constant.pageCount, Constant.pageCount, new String[]{system + ""});
+ }
- // 鑾峰彇鐢ㄦ埛鏁伴噺
- public long getUserInfoCount(int system) {
+ // 鑾峰彇鐢ㄦ埛鏁伴噺
+ public long getUserInfoCount(int system) {
- return userDao.getCount("select count(*) from UserInfo u where u.system.id=?", new String[] { system + "" });
- }
+ return userDao.getCount("select count(*) from UserInfo u where u.system.id=?", new String[]{system + ""});
+ }
- // 鑾峰彇鎬荤殑鐢ㄦ埛鏁伴噺
- public long getUserInfoCount() {
+ // 鑾峰彇鎬荤殑鐢ㄦ埛鏁伴噺
+ public long getUserInfoCount() {
- return userDao.getCount("select count(*) from UserInfo u");
- }
+ return userDao.getCount("select count(*) from UserInfo u");
+ }
- // 鑾峰彇鐢ㄦ埛鐨勯〉鏁�
- public long getUserInfoPage(int system) {
- long count = getUserInfoCount(system);
- return count % Constant.pageCount == 0 ? count / Constant.pageCount : count / Constant.pageCount + 1;
- }
+ // 鑾峰彇鐢ㄦ埛鐨勯〉鏁�
+ public long getUserInfoPage(int system) {
+ long count = getUserInfoCount(system);
+ return count % Constant.pageCount == 0 ? count / Constant.pageCount : count / Constant.pageCount + 1;
+ }
- // 鑾峰彇鏌愪釜鐢ㄦ埛鐨勮缁嗕俊鎭�
- @Cacheable(value = "longTimeCache", key = "'getUserInfo'+'-'+#id")
- public UserInfo getUserInfo(String id) {
+ // 鑾峰彇鏌愪釜鐢ㄦ埛鐨勮缁嗕俊鎭�
+ @Cacheable(value = "longTimeCache", key = "'getUserInfo'+'-'+#id")
+ public UserInfo getUserInfo(String id) {
- return userDao.find(UserInfo.class, id);
- }
+ return userDao.find(UserInfo.class, id);
+ }
- // 鏇存柊鐢ㄦ埛淇℃伅
- public void updateUserInfo(UserInfo userInfo) {
- userDao.update(userInfo);
- }
+ // 鏇存柊鐢ㄦ埛淇℃伅
+ public void updateUserInfo(UserInfo userInfo) {
+ userDao.update(userInfo);
+ }
- public void updateLoginUserInfo(LoginUser lu) {
- loginUserDao.update(lu);
- }
+ public void updateLoginUserInfo(LoginUser lu) {
+ loginUserDao.update(lu);
+ }
- public String getUid(String device, String system, String imei, String mac, String lat, String lng) {
- UserInfo info;
- info = new UserInfo();
- info.setDevice(device);
- if (!StringUtil.isNullOrEmpty(imei))
- info.setImei(imei);
- if (!StringUtil.isNullOrEmpty(mac))
- info.setMac(mac);
- if (!StringUtil.isNullOrEmpty(lat))
- info.setLat(lat);
- if (!StringUtil.isNullOrEmpty(lng))
- info.setLng(lng);
- String s;
- List<UserInfo> list = userDao.list("from UserInfo u where u.device=? and u.system.id=" + system,
- new String[] { device });
+ public String getUid(String device, String system, String imei, String mac, String lat, String lng) {
+ UserInfo info;
+ info = new UserInfo();
+ info.setDevice(device);
+ if (!StringUtil.isNullOrEmpty(imei))
+ info.setImei(imei);
+ if (!StringUtil.isNullOrEmpty(mac))
+ info.setMac(mac);
+ if (!StringUtil.isNullOrEmpty(lat))
+ info.setLat(lat);
+ if (!StringUtil.isNullOrEmpty(lng))
+ info.setLng(lng);
+ String s;
+ List<UserInfo> list = userDao.list("from UserInfo u where u.device=? and u.system.id=" + system,
+ device);
- if (list.size() <= 0) {//
- info.setScore("0");
- info.setCreatetime((new StringBuilder(String.valueOf(System.currentTimeMillis()))).toString());
- SystemInfo sys = new SystemInfo();
- sys.setId(system);
- info.setSystem(sys);
- userDao.create(info);
- s = queryUid(device, system);
- } else {
- UserInfo u = (UserInfo) list.get(0);
- s = u.getId();
- if (!StringUtil.isNullOrEmpty(imei))
- u.setImei(imei);
- if (!StringUtil.isNullOrEmpty(mac))
- u.setMac(mac);
- if (!StringUtil.isNullOrEmpty(lat))
- u.setLat(lat);
- if (!StringUtil.isNullOrEmpty(lng))
- u.setLng(lng);
- userDao.update(u);
- }
+ if (list.size() <= 0) {//
+ info.setScore("0");
+ info.setCreatetime((new StringBuilder(String.valueOf(System.currentTimeMillis()))).toString());
+ SystemInfo sys = new SystemInfo();
+ sys.setId(system);
+ info.setSystem(sys);
+ userDao.create(info);
+ s = queryUid(device, system);
+ } else {
+ UserInfo u = (UserInfo) list.get(0);
+ s = u.getId();
+ if (!StringUtil.isNullOrEmpty(imei))
+ u.setImei(imei);
+ if (!StringUtil.isNullOrEmpty(mac))
+ u.setMac(mac);
+ if (!StringUtil.isNullOrEmpty(lat))
+ u.setLat(lat);
+ if (!StringUtil.isNullOrEmpty(lng))
+ u.setLng(lng);
+ userDao.update(u);
+ }
- return s;
- }
+ return s;
+ }
- @SuppressWarnings("unchecked")
- public String queryUid(String device, String system) {
- String s = "0";
- List<UserInfo> list = userDao.list("from UserInfo u where u.device=? and u.system.id=" + system,
- new String[] { device });
- if (list.size() <= 0)
- s = "0";
- else
- s = ((UserInfo) list.get(0)).getId();
- return s;
- }
+ @SuppressWarnings("unchecked")
+ public String queryUid(String device, String system) {
+ String s = "0";
+ List<UserInfo> list = userDao.list("from UserInfo u where u.device=? and u.system.id=" + system,
+ new String[]{device});
+ if (list.size() <= 0)
+ s = "0";
+ else
+ s = ((UserInfo) list.get(0)).getId();
+ return s;
+ }
- @Cacheable(value = "userCache", key = "'getUserData'+'-'+#uid")
- public UserData getUserData(String uid) {
- UserData data = new UserData();
- data.setCollectCount((new StringBuilder(String.valueOf(userDao.getCount(
- (new StringBuilder("select count(*) from Collection c where c.user.id=")).append(uid).toString()))))
- .toString());
- data.setWatchCount((new StringBuilder(String.valueOf(userDao.getCount(
- (new StringBuilder("select count(*) from GetScoreWatch c where c.user.id=")).append(uid).toString()))))
- .toString());
- List<UserInfo> user = userDao
- .list((new StringBuilder("select count(*) from UserInfo u where u.id=")).append(uid).toString());
- // if (user != null && user.size() > 0)
- // data.setScore(((UserInfo) user.get(0)).getScore());
- // else
- // data.setScore("0");
- return data;
- }
+ @Cacheable(value = "userCache", key = "'getUserData'+'-'+#uid")
+ public UserData getUserData(String uid) {
+ UserData data = new UserData();
+ data.setCollectCount((new StringBuilder(String.valueOf(userDao.getCount(
+ (new StringBuilder("select count(*) from Collection c where c.user.id=")).append(uid).toString()))))
+ .toString());
+ data.setWatchCount((new StringBuilder(String.valueOf(userDao.getCount(
+ (new StringBuilder("select count(*) from GetScoreWatch c where c.user.id=")).append(uid).toString()))))
+ .toString());
+ List<UserInfo> user = userDao
+ .list((new StringBuilder("select count(*) from UserInfo u where u.id=")).append(uid).toString());
+ // if (user != null && user.size() > 0)
+ // data.setScore(((UserInfo) user.get(0)).getScore());
+ // else
+ // data.setScore("0");
+ return data;
+ }
- @SuppressWarnings("unchecked")
- public LoginUser getLoginUser(final String openid, final String detailSystem, final int type, final String portrait,
- final String name, final String ipInfo) {
- return (LoginUser) userDao.excute(new HibernateCallback<LoginUser>() {
- public LoginUser doInHibernate(Session session) throws HibernateException {
- try {
- List<LoginUser> list = session
- .createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
- .setParameter(0, openid).setParameter(1, type).list();
- if (list != null && list.size() > 0)
- return list.get(0);
- else {
- session.getTransaction().begin();
- LoginUser lu = new LoginUser();
- lu.setCreatetime(System.currentTimeMillis() + "");
- lu.setDetailsystem(detailSystem);
- lu.setLoginType(type);
- lu.setName(name);
- lu.setOpenid(openid);
- lu.setPortrait(portrait);
- lu.setIpinfo(ipInfo);
- session.save(lu);
- session.flush();
- session.getTransaction().commit();
- return lu;
- }
+ /**
+ *
+ * @param openid
+ * @param detailSystem
+ * @param type 1-QQ 2-寰俊
+ * @param portrait
+ * @param name
+ * @param ipInfo
+ * @return
+ */
+ @SuppressWarnings("unchecked")
+ public LoginUser getLoginUser(final String openid, final String detailSystem, final int type, final String portrait,
+ final String name, final String ipInfo) {
+ return (LoginUser) userDao.excute(new HibernateCallback<LoginUser>() {
+ public LoginUser doInHibernate(Session session) throws HibernateException {
+ try {
+ List<LoginUser> list = session
+ .createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
+ .setParameter(0, openid).setParameter(1, type).list();
- } catch (Exception e) {
- e.printStackTrace();
- session.getTransaction().rollback();
- }
- return null;
- }
- });
+ if (list != null && list.size() > 0)
+ return list.get(0);
+ else {
+ session.getTransaction().begin();
+ LoginUser lu = new LoginUser();
+ lu.setCreatetime(System.currentTimeMillis() + "");
+ lu.setDetailsystem(detailSystem);
+ lu.setLoginType(type);
+ lu.setName(name);
+ lu.setOpenid(openid);
+ lu.setPortrait(portrait);
+ lu.setIpinfo(ipInfo);
+ session.save(lu);
+ session.flush();
+ session.getTransaction().commit();
+ return lu;
+ }
- }
+ } catch (Exception e) {
+ e.printStackTrace();
+ session.getTransaction().rollback();
+ }
+ return null;
+ }
+ });
- public LoginUser getLoginUser(String id) {
- return loginUserDao.find(LoginUser.class, id);
- }
+ }
- public LoginUser getLoginUserByOpenId(String openid) {
- List<LoginUser> list = loginUserDao.list("from LoginUser lu where lu.openid=?", new Serializable[] { openid });
- if (list != null && list.size() > 0)
- return list.get(0);
- return null;
- }
+ public LoginUser getLoginUser(String id) {
+ return loginUserDao.find(LoginUser.class, id);
+ }
- /**
- * 鐢ㄦ埛娉ㄩ攢
- *
- * @param uid
- */
- @Transactional
- public void unRegister(Long uid) throws Exception {
- LoginUser user = loginUserDao.find(LoginUser.class, uid+"");
- if (user == null) {
- throw new Exception("鐢ㄦ埛涓嶅瓨鍦�");
- }
- if (user.getState() != LoginUser.STATE_NORMAL) {
- throw new Exception("璐︽埛宸茶娉ㄩ攢");
- }
- user.setState(LoginUser.STATE_UNREGISTER);
- loginUserDao.update(user);
- }
+ public LoginUser getLoginUserByOpenId(String openid) {
+ List<LoginUser> list = loginUserDao.list("from LoginUser lu where lu.openid=?", new Serializable[]{openid});
+ if (list != null && list.size() > 0)
+ return list.get(0);
+ return null;
+ }
- // 閭娉ㄥ唽
- public String registerByEmail(final LoginUser user) {
- return userDao.excute(new HibernateCallback<String>() {
- @SuppressWarnings("unchecked")
- public String doInHibernate(Session session) throws HibernateException {
- List<LoginUser> list = session.createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
- .setParameter(0, user.getOpenid()).setParameter(1, user.getLoginType()).list();
- if (list != null && list.size() > 0)
- return "璇ラ偖绠卞凡娉ㄥ唽";
- try {
- session.getTransaction().begin();
- session.save(user);
- session.flush();
- session.getTransaction().commit();
- return "娉ㄥ唽鎴愬姛";
- } catch (Exception e) {
- return "娉ㄥ唽澶辫触";
- }
- }
- }) + "";
- }
+ /**
+ * 鐢ㄦ埛娉ㄩ攢
+ *
+ * @param uid
+ */
+ @Transactional
+ public void unRegister(Long uid) throws Exception {
+ LoginUser user = loginUserDao.find(LoginUser.class, uid + "");
+ if (user == null) {
+ throw new Exception("鐢ㄦ埛涓嶅瓨鍦�");
+ }
+ if (user.getState() != LoginUser.STATE_NORMAL) {
+ throw new Exception("璐︽埛宸茶娉ㄩ攢");
+ }
+ user.setState(LoginUser.STATE_UNREGISTER);
+ loginUserDao.update(user);
+ }
- /**
- * 閭鐧诲綍
- *
- * @param user
- * @return
- */
- public LoginUser loginByEmail(final LoginUser user) {
- return (LoginUser) userDao.excute(new HibernateCallback<LoginUser>() {
- @SuppressWarnings("unchecked")
- public LoginUser doInHibernate(Session session) throws HibernateException {
- List<LoginUser> list = session.createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
- .setParameter(0, user.getOpenid()).setParameter(1, user.getLoginType()).list();
- if (list != null && list.size() > 0) {
- if (list.get(0).getPwd().equalsIgnoreCase(user.getPwd()))
- return list.get(0);
- }
- return null;
- }
- });
- }
+ // 閭娉ㄥ唽
+ public String registerByEmail(final LoginUser user) {
+ return userDao.excute(new HibernateCallback<String>() {
+ @SuppressWarnings("unchecked")
+ public String doInHibernate(Session session) throws HibernateException {
+ List<LoginUser> list = session.createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
+ .setParameter(0, user.getOpenid()).setParameter(1, user.getLoginType()).list();
+ if (list != null && list.size() > 0)
+ return "璇ラ偖绠卞凡娉ㄥ唽";
+ try {
+ user.setState(LoginUser.STATE_NORMAL);
+ session.getTransaction().begin();
+ session.save(user);
+ session.flush();
+ session.getTransaction().commit();
+ return "娉ㄥ唽鎴愬姛";
+ } catch (Exception e) {
+ return "娉ㄥ唽澶辫触";
+ }
+ }
+ }) + "";
+ }
+
+ /**
+ * 閭鐧诲綍
+ *
+ * @param user
+ * @return
+ */
+ public LoginUser loginByEmail(final LoginUser user) {
+ return (LoginUser) userDao.excute(new HibernateCallback<LoginUser>() {
+ @SuppressWarnings("unchecked")
+ public LoginUser doInHibernate(Session session) throws HibernateException {
+ List<LoginUser> list = session.createQuery("from LoginUser lu where lu.openid=? and lu.loginType=?")
+ .setParameter(0, user.getOpenid()).setParameter(1, user.getLoginType()).list();
+ if (list != null && list.size() > 0) {
+ if (list.get(0).getPwd().equalsIgnoreCase(user.getPwd()))
+ return list.get(0);
+ }
+ return null;
+ }
+ });
+ }
}
--
Gitblit v1.8.0