feiqu-opensource-master.zip

package com.feiqu.web.controller; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.FileUtil; import cn.hutool.core.lang.UUID; import cn.hutool.core.lang.Validator; import cn.hutool.core.util.RandomUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.digest.DigestUtil; import com.alibaba.fastjson.JSON; import com.feiqu.common.base.BaseResult; import com.feiqu.common.enums.*; import com.feiqu.common.utils.DESUtils; import com.feiqu.common.utils.SpringUtils; import com.feiqu.framwork.constant.CommonConstant; import com.feiqu.framwork.constant.IconUrlConfig; import com.feiqu.framwork.support.cache.CacheManager; import com.feiqu.framwork.util.CommonUtils; import com.feiqu.framwork.util.CookieUtil; import com.feiqu.framwork.util.SpringContextUtil; import com.feiqu.framwork.util.WebUtil; import com.feiqu.framwork.web.base.BaseController; import com.feiqu.system.model.*; import com.feiqu.system.pojo.cache.FqUserCache; import com.feiqu.system.pojo.response.MessageUserDetail; import com.feiqu.system.pojo.response.SimThoughtDTO; import com.feiqu.system.pojo.response.ThoughtWithUser; import com.feiqu.system.service.*; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.google.common.collect.Lists; import com.jeesuite.cache.command.RedisString; import com.jeesuite.cache.redis.JedisProviderFactory; import com.jeesuite.filesystem.FileSystemClient; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.time.DateFormatUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.mail.MailException; import org.springframework.mail.javamail.JavaMailSenderImpl; import org.springframework.mail.javamail.MimeMessageHelper; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.util.Assert; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import redis.clients.jedis.JedisCommands; import javax.annotation.Resource; import javax.mail.MessagingException; import javax.mail.internet.MimeMessage; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.util.*; /** * @author cwd * @create 2017-09-16:19 **/ @Controller @RequestMapping("u") public class UserController extends BaseController { private static Logger logger = LoggerFactory.getLogger(UserController.class); /*@Autowired FSProviderSpringFacade provider;*/ @Autowired private ThoughtService thoughtService; @Autowired private ArticleService articleService; @Autowired private WebUtil webUtil; @Autowired private CMessageService messageService; @Autowired private UploadImgRecordService uploadImgRecordService; @Autowired private JavaMailSenderImpl mailSender; @Autowired private UserActivateService userActivateService; @Autowired private UserFollowService userFollowService; @Autowired private FqUserService userService; @Autowired private FqThirdPartyService fqThirdPartyService; @Autowired private FqLabelService fqLabelService; @Autowired private FqVisitRecordService visitRecordService; @Autowired private FqCollectService fqCollectService; //支付方式 @Resource private FqUserPayWayService fqUserPayWayService; @GetMapping("upLevel") public String upLevel(Model model){ FqUserCache fqUserCache = getCurrentUser(); int month = DateUtil.thisMonth()+1; int lastMonth = month == 1? 12 : month-1; JedisCommands commands = JedisProviderFactory.getJedisCommands(null); Double score = commands.zscore(CommonConstant.FQ_ACTIVE_USER_SORT+month,fqUserCache.getId().toString()); Double lastMonthScore = commands.zscore(CommonConstant.FQ_ACTIVE_USER_SORT+lastMonth,fqUserCache.getId().toString()); Double totolScore = (score == null?0:score)+(lastMonthScore==null?0:lastMonthScore); model.addAttribute("totolScore",totolScore); return "/user/upLevel"; } @PostMapping("upLevel") @ResponseBody public BaseResult upLevelGo(){ BaseResult result = new BaseResult(); try { FqUserCache fqUserCache = getCurrentUser(); if(fqUserCache == null){ result.setResult(ResultEnum.USER_NOT_LOGIN); return result; } int originLevel = fqUserCache.getLevel() == null?1:fqUserCache.getLevel(); int needActiveNum = 0; switch (originLevel){ case 1:needActiveNum = 300;break; case 2:needActiveNum = 800;break; case 3:needActiveNum = 1500;break; case 4:needActiveNum = 3000;break; default:needActiveNum = 300;break; } int month = DateUtil.thisMonth()+1; int lastMonth = month == 1? 12 : month-1; JedisCommands commands = JedisProviderFactory.getJedisCommands(null); Double score = commands.zscore(CommonConstant.FQ_ACTIVE_USER_SORT+month,fqUserCache.getId().toString()); Double lastMonthScore = commands.zscore(CommonConstant.FQ_ACTIVE_USER_SORT+lastMonth,fqUserCache.getId().toString()); Double totolScore = (score == null?0:score)+(lastMonthScore==null?0:lastMonthScore); if(totolScore < needActiveNum){ result.setResult(ResultEnum.PARAM_ERROR); result.setMessage("活跃度不足"); return result; } FqUser toUpdate = new FqUser(); toUpdate.setId(fqUserCache.getId()); toUpdate.setLevel(originLevel+1); userService.updateByPrimaryKeySelective(toUpdate); CacheManager.refreshUserCacheByUid(fqUserCache.getId()); commands.zadd(CommonConstant.FQ_ACTIVE_USER_SORT+month,totolScore.intValue()-needActiveNum,fqUserCache.getId().toString()); result.setData(originLevel+1); } catch (Exception e) { result.setResult(ResultEnum.FAIL); logger.error("升级报错",e); }finally { JedisProviderFactory.getJedisProvider(null).release(); } return result; } @RequestMapping("/manage") public String manage(Model model){ FqUserCache fqUserCache = getCurrentUser(); if(fqUserCache == null){ return USER_LOGIN_REDIRECT_URL; } if(fqUserCache.getRole() != 1){ return GENERAL_ERROR_URL; } return "/user/manage"; } @RequestMapping("/manage/list") @ResponseBody public Object list(Integer page){ BaseResult result = new BaseResult(); try { PageHelper.startPage(page,CommonConstant.DEAULT_PAGE_SIZE); FqUserExample example = new FqUserExample(); example.setOrderByClause("create_time desc"); List<FqUser> users = userService.selectByExample(example); PageInfo pageInfo = new PageInfo(users); result.setData(pageInfo); } catch (Exception e) { logger.error("用户分页出错",e); result.setCode("1"); result.setMessage("用户分页出错"); } return result; } @RequestMapping("/manage/changeStatus") @ResponseBody public Object changeStatus(Integer userId,Integer status){ BaseResult result = new BaseResult(); try { FqUserCache currentUser = getCurrentUser(); if(currentUser == null){ result.setResult(ResultEnum.USER_NOT_LOGIN); return result; } if(