发表于: 2018-02-05 17:55:44
1 690
今天完成的事情:
设置定时任务:
@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;
}
明天计划的事情:
继续复盘
遇到的问题:
无
收获:
无
评论