Merge remote-tracking branch 'origin/master'

胡仁荣

2023-09-11 937daff0ebc1aa16a852d5a86434ab1994d8a02d

 src/main/java/com/qxueyou/scc/sys/action/LoginController.java

@@ -54,12 +54,12 @@
import io.swagger.annotations.ApiOperation;

/**
 * 注册controller 提供注册，登录，注销服务
 * 注册controller 提供注册，录，注销服务
 *
 * @author 德虎
 * @history 2014-11-25 新建 夏德虎
 */
@Api(tags="登入相关接口")
@Api(tags="入相关接口")
@Controller
@CrossOrigin(origins="*",maxAge=3600)
@EnableConfigurationProperties(SccConfig.class)
@@ -116,6 +116,18 @@
   @Value("${wx.secret}")
   private String secret;

   /**
    * 公众号appID
    */
   @Value("${wx.app.appId}")
   private String wxappId;


   /**
    * 公众号secret
    */
   @Value("${wx.app.secret}")
   private String wxsecret;

   public static String UUNUMBER="QXYUUNUMBER";

@@ -123,14 +135,25 @@
   IWechatService wechatService;

   /**
    * 微信登录
    * 微信录
    *
    * @param uid
    * @throws IOException
    */

   @PostMapping("/wxAccountsLogin")
   @ApiOperation("微信公众号录")
   @ResponseBody
   public Result wxAccountsLogin(String code) {
      JSONObject gettoken = wechatService.gettoken(wxappId, wxsecret);
      JSONObject OpenId = wechatService.getSessionKeyOrOpenId(code);
      JSONObject user = wechatService.getUser(gettoken.get("access_token").toString(), OpenId.get("openid").toString());
      return new Result(true,"成功",user);
   }


   @PostMapping("/wxlogin")
   @ApiOperation("微信登录")
   @ApiOperation("微信小程序录")
   @ResponseBody
   public Result wechatLogin(String code,String number) {
      JSONObject sessionKeyOrOpenId = wechatService.getSessionKeyOrOpenId(code);
@@ -164,12 +187,22 @@
         String studentSql = "from StuStudent where deleteFlag is false and userId = ? ";
         List<Object> stuParams =  CollectionUtils.newList(user.getUserId());
         StuStudent stuStudent = commonDAO.findUnique(studentSql, stuParams, StuStudent.class);
         CacheParamters param = new CacheParamters();
         param.setUserId(user.getUserId());
         param.setCustomRoleValue(user.getEmail());
         param.setCustomOrgId(user.getImei());
         param.setCacheIpFlag(true);
         //       缓存到请求线程
         UserInfoWrapper wrapper = cacheUserInfo(param, null);
         // 存到redis
         redisTemplate.opsForValue().set(UserInfoWrapper.SESSION_USER_INFO_KEY, wrapper);
         return new Result(true,"授权成功",CollectionUtils.newObjectMap("user",user,"ClassId",stuStudent.getClassId()));
      }
      return phone;
}
   }

   @ApiOperation(value = "登入接口", notes = "")

   @ApiOperation(value = "入接口", notes = "")
   @ApiImplicitParams({
         @ApiImplicitParam(name = "account", value = "账号", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "password", value = "密码", required = true, paramType="query", dataType = "String"),
@@ -184,8 +217,8 @@
      // 查询用户信息
      String uuNumber=null;
      String uuReNumber=null;
      String hql = "from User where deleteFlag is false and account = ?";
      List<Object> params =  CollectionUtils.newList(account);
      String hql = "from User where deleteFlag is false and account = ? and password= ?";
      List<Object> params =  CollectionUtils.newList(account,password);
      User user = commonDAO.findUnique(hql,params, User.class);
      if (user == null ) {
         return new Result(false, "用户账户、密码错误");
@@ -224,7 +257,7 @@
      return new Result(true, "验证成功",CollectionUtils.newObjectMap("uuNumber",uuNumber,"uuReNumber",uuReNumber));
   }

   @ApiOperation(value = "登入接口", notes = "")
   @ApiOperation(value = "入接口", notes = "")
   @ApiImplicitParams({
         @ApiImplicitParam(name = "uuNumber", value = "uuNumber", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "uuReNumber", value = "uuReNumber", required = true, paramType="query", dataType = "String"),
@@ -260,7 +293,7 @@
      return new Result(true, "验证成功");
   }

   @ApiOperation(value = "登入接口", notes = "")
   @ApiOperation(value = "入接口", notes = "")
   @ApiImplicitParams({
         @ApiImplicitParam(name = "uuNumber", value = "uuNumber", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "uuReNumber", value = "uuReNumber", required = true, paramType="query", dataType = "String"),
@@ -294,32 +327,33 @@
      return new Result(true, "验证成功");
   }

   //退出登录 清除session
   @RequestMapping(value = "khdloginout", method = RequestMethod.POST)
   //退出录 清除session
   @RequestMapping(value = "release", method = RequestMethod.GET)
   @ResponseBody
   public void khdloginout(HttpServletRequest request, HttpServletResponse response) {
      System.out.println("清除session");
      HttpSession session = request.getSession();
      redisTemplate.delete(UserInfoWrapper.SESSION_USER_INFO_KEY);
      System.out.println(session.getAttribute("userId"));
      System.out.println(session.getAttribute("classId"));
      session.invalidate();
   public void release(HttpServletRequest request, HttpServletResponse response) {
//      System.out.println("清除session");
//      HttpSession session = request.getSession();
//      redisTemplate.delete(UserInfoWrapper.SESSION_USER_INFO_KEY);
//      System.out.println(session.getAttribute("userId"));
//      System.out.println(session.getAttribute("classId"));
      doRelease(request, response);
//      session.invalidate();
   }

   /**
    * 学员端登录
    * 学员端录
    *
    * @param account  账户
    * @param password 密码
    * @return
    */
   @ApiOperation(value = "登入接口", notes = "")
   @ApiOperation(value = "入接口", notes = "")
   @ApiImplicitParams({
         @ApiImplicitParam(name = "account", value = "账号", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "password", value = "密码", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "organizationId", value = "机构id", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "platForm", value = "登入平台（app，web，qLive，pc，weixin）", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "logType", value = "登入type（study学员，teacher教师,否则为后台）", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "platForm", value = "入平台（app，web，qLive，pc，weixin）", required = true, paramType="query", dataType = "String"),
         @ApiImplicitParam(name = "logType", value = "入type（study学员，teacher教师,否则为后台）", required = true, paramType="query", dataType = "String"),
   })
   @RequestMapping(value = "studentLogin", method = RequestMethod.POST)
   @ResponseBody
@@ -353,19 +387,19 @@
   }

   /**
     * 后台登录
     * 后台录
     *
     * @param account  账户
     * @param password 密码
     * @return
     */
    @ApiOperation(value = "登入接口", notes = "")
    @ApiOperation(value = "入接口", notes = "")
    @ApiImplicitParams({
        @ApiImplicitParam(name = "account", value = "账号", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "password", value = "密码", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "organizationId", value = "机构id", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "platForm", value = "登入平台（app，web，qLive，pc，weixin）", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "logType", value = "登入type（study学员，teacher教师,否则为后台）", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "platForm", value = "入平台（app，web，qLive，pc，weixin）", required = true, paramType="query", dataType = "String"),
        @ApiImplicitParam(name = "logType", value = "入type（study学员，teacher教师,否则为后台）", required = true, paramType="query", dataType = "String"),
    })
    @RequestMapping(value = "platformLogin", method = RequestMethod.POST)
    @ResponseBody
@@ -384,6 +418,9 @@
         hql = "from User where deleteFlag is false and account = ?";
         params = CollectionUtils.newList(account);
      }else if("portal".equals(logType)){
         hql = "from User where deleteFlag is false and email = ?";
         params = CollectionUtils.newList(account);
      }else if("zhyly".equals(logType)){
         hql = "from User where deleteFlag is false and mobilePhone = ?";
         params = CollectionUtils.newList(account);
      }else{
@@ -403,12 +440,12 @@
        User user = commonDAO.findUnique(hql,params, User.class);

       if(uuNumber!=null&&!"".equals(uuNumber)&&!"null".equals(uuNumber)){
          //登录成功存入user里，删除session里的uuNumber，下个人无法使用
          //录成功存入user里，删除session里的uuNumber，下个人无法使用
         user.setEmail(uuNumber);
//         request.getSession().removeAttribute("uuNumber");
      }
//       if(uuReNumber!=null&&!"".equals(uuReNumber)&&!"null".equals(uuReNumber)){
//          //登录成功存入user里，删除session里的uuReNumber，下个人无法使用
//          //录成功存入user里，删除session里的uuReNumber，下个人无法使用
//         user.setImei(uuReNumber);
//         request.getSession().removeAttribute("uuReNumber");
//      }
@@ -432,7 +469,7 @@
    }

    /**
     * 登入验证
     * 入验证
     * @param user
     * @param type
     * @param request
@@ -458,26 +495,26 @@
      // 存到redis
      redisTemplate.opsForValue().set(UserInfoWrapper.SESSION_USER_INFO_KEY, wrapper);
      request.getSession().setAttribute(UserInfoWrapper.SESSION_USER_INFO_KEY, wrapper);
      if ("study".equals(logType) || "portal".equals(logType)) {
      if ("study".equals(logType) || "portal".equals(logType) || "zhyly".equals(logType)) {
         /*if (StringUtils.isEmpty(ClientUtils.getClassId()) && user.getRoles() == null) {
            return new Result(false, "该用户未加入任何班级或未激活，请联系班主任");
         }*/

         if (StringUtils.isEmpty(user.getOrganizationId())) {
            return new Result(false, "该用户不属于任何机构，无法登入");
            return new Result(false, "该用户不属于任何机构，无法入");
         }
         if (StringUtils.isNoneBlank(organizationId) && !user.getOrganizationId().equals(organizationId)) {
            return new Result(false, "选择的机构错误，请确认");
         }

         //判断是否为学生，如果是学生，判断是否已冻结或移除，冻结或移除的学生不让登录
         //判断是否为学生，如果是学生，判断是否已冻结或移除，冻结或移除的学生不让录
           StuStudent stu = this.studentService.getStudentByUserId(user.getUserId());
           if(stu!=null && (stu.getDeleteFlag() || stu.getStatus().equalsIgnoreCase(StuStudent.STATUS_DEACTIVE))){
              return new Result(false, "用户账户已经被冻结或移除");
           }

         /*if(StringUtils.isEmpty(wrapper.getInfo(UserInfoWrapper.INF_CLASS_ID))) {
            return new Result(false, "该用户未加入任何班级，无法登入");
            return new Result(false, "该用户未加入任何班级，无法入");
         }*/
         // 保存到session中
         return new Result(true, "success",
@@ -488,16 +525,16 @@
      }else if("teacher".equals(logType)) {
         String teacherId = teacherService.getTeacherIdByUserId(user.getUserId());
         if (StringUtils.isEmpty(teacherId)) {
            return new Result(false, "该账户不是老师角色，无法登入");
            return new Result(false, "该账户不是老师角色，无法入");
         }
         if (StringUtils.isEmpty(user.getOrganizationId())) {
            return new Result(false, "该用户不属于任何机构，无法登入");
            return new Result(false, "该用户不属于任何机构，无法入");
         }
         if (StringUtils.isNoneBlank(organizationId) && !user.getOrganizationId().equals(organizationId)) {
            return new Result(false, "选择的机构错误，请确认");
         }

         //获取用户对应的sessionId是否与保存在redis中的一致，如果不一致则跳转到登录页面
         //获取用户对应的sessionId是否与保存在redis中的一致，如果不一致则跳转到录页面
//         stringRedisTemplate.opsForHash().put(UserInfoWrapper.REDIS_USER_ONLINE_MAP_KEY, user.getUserId(), request.getSession().getId());
         return new Result(true, "success",
               CollectionUtils.newObjectMap("userId", user.getUserId(), "userName", user.getName(), "imgPath",
@@ -524,7 +561,7 @@
   }

    /**
     * 后台：退出登录,后台系统
     * 后台：退出录,后台系统
     *
     * @param account 账户
     * @return
@@ -537,7 +574,7 @@
    }

    /**
     * 后台：退出登录,后台系统
     * 后台：退出录,后台系统
     *
     * @return
     */
@@ -567,7 +604,7 @@
    }

    /**
     * 插入登录日志
     * 插入录日志
     *
     * @param request
     * @param lstUser