发表于: 2018-02-05 17:55:44

1 691


今天完成的事情:

设置定时任务:

@Scheduled(cron = "0 0 0 * * ?") // 每天凌晨执行
public void taskForUpdateSign() {
try{
log.info("开始准备执行定时任务:更新用户签到");
      Class.forName("com.MySQL.jdbc.Driver");
      Connection connection = DriverManager.getConnection("jdbc:mysql://118.126.113.248:3306/academy_karazhan",
              "arthur", "arthur");
      connection.setAutoCommit(false);
      log.info("正在执行定时任务:更新用户签到");
      String sql ="update users set sign = 0";
      PreparedStatement preparedStatement = connection.prepareStatement(sql);
      int number = preparedStatement.executeUpdate();
      log.info("定时任务执行完毕,更新用户签到情况,一共更新了"+number+"条数据");
      connection.commit();
      if(preparedStatement!=null){
preparedStatement.close();
      }
if(connection!=null){
connection.close();
      }
}catch (Exception e){
e.printStackTrace();
      log.info("更新签到定时任务执行失败。");
  }


//用户绑定手机
@RequestMapping(value = "/a/phone",method = RequestMethod.POST)
public String getCode(@RequestBody Users users, Model model,HttpSession session){
try{
System.out.println(users.getPhone());
     Long id = usersService.getUseridByPhone(users.getPhone());
     Users user = usersService.getObjectById(users.getId());
     System.out.println("id------->"+id);
     if(id == null || id.equals(users.getId()) ){
System.out.println("**************");
        if(user.getMessageCount() < 3) {
Random random = new Random();
           String codePhone = String.valueOf(random.nextInt(999999));
           session.setAttribute("codePhone", codePhone);
           System.out.println("session中的code---->"+session.getAttribute("codePhone"));
           session.setMaxInactiveInterval(60);
           String phone = String.valueOf(users.getPhone());
           SendMes.sendSms(codePhone, phone);
           model.addAttribute("message", "验证码已发送请在1分钟内输入。");
           user.setMessageCount(user.getMessageCount() + 1);
           usersService.update(user);
           return "users/json/usersDetailJson";
        }else {
model.addAttribute("message", "今日该帐号发送次数已达上限。");
           return "users/json/usersDetailJson";
        }
}else {
model.addAttribute("message", "该手机号已经被绑定。");
        return "users/json/usersDetailJson";
     }
}catch (Exception e){
e.printStackTrace();
  }
return null;
}
//用户提交手机验证码
@RequestMapping(value = "/a/phonebinding",method = RequestMethod.POST)
public String getPhonebinding(@RequestBody Users users,HttpSession session,Model model){
try{
Users user = usersService.getObjectById(users.getId());
     System.out.println("user---->"+users.getName());
     System.out.println("session中的code---->"+session.getAttribute("codePhone"));
     if(users.getName().equals(session.getAttribute("codePhone"))){
log.info("user.phone---->"+user.getPhone());
        log.info("user.eamil---->"+user.getEmail());
        if(user.getPhone()==null && user.getEmail()==null){//判断是否增加20豆子
           log.info("用户第一次绑定,增加20豆子");
           user.setBeans(user.getBeans()+20L);
           user.setPhone(users.getPhone());//更新电话号码
           usersService.update(user);
           model.addAttribute("message", "第一次绑定增加20豆子");
           model.addAttribute("users",user);
           return "users/json/usersDetailJson";
        }else{
log.info("未增加豆子且更新用户");
           user.setPhone(users.getPhone());//更新电话号码
           usersService.update(user);
           model.addAttribute("message", "未增加豆子且更新用户");
           model.addAttribute("users",user);
           return  "users/json/usersDetailJson";
        }
}else {
model.addAttribute("message", "请输入正确的验证码");
        model.addAttribute("users",user);
        return "users/json/usersDetailJson";
     }
}catch (Exception e){
e.printStackTrace();
  }
return null;
}



明天计划的事情:

继续复盘
遇到的问题:


收获:


返回列表 返回列表
评论

    分享到