数据可视化

EricsHu

2023-06-19 bc3b37b1622091def1f6ee4c3eb3ff79499b3466

数据可视化

 src/main/java/com/qxueyou/scc/controller/VideoLiveController.java

@@ -95,6 +95,14 @@
                        ))));
    }

    @ApiOperation(value = "获取已结束直播列表")
    @GetMapping(value = "listvideo")
    public Result listvideo() {

        List<MediaVideoLive> data = liveService.listvideo("9");

        return new Result(true, "success", CollectionUtils.newObjectMap("listVideo",data));
    }
    /**
     * 新增直播/更新直播
     * 

 src/main/java/com/qxueyou/scc/operation/topic/service/impl/TopicService.java

@@ -677,6 +677,7 @@

        List<Map<String, Object>> topicLst = findListWithMapByHql(hql, hqlMap, new Pager(pageSize, pageNum));

        int sunCount=0;
        for (Map<String, Object> map : topicLst) {
            String topicId = (String) map.get("topicId");
            String findPeopleCountByHql = "select distinct c.commentterId as commentterId from CommentObject o,Comment c where o.deleteFlag is false and o.commentObjectUid =:topicId and"
@@ -684,10 +685,10 @@
            List<Map<String, Object>> commentIdLst = findListWithMapByHql(findPeopleCountByHql,
                    CollectionUtils.newObjectMap("topicId", topicId));
            int peopleCount = commentIdLst.size();// 参与人数
            sunCount+=peopleCount;
            map.put("peopleCount", peopleCount);
        }
        return new Result(true, "success",
                CollectionUtils.newObjectMap("topicLst", topicLst, "topicCount", topicCount));
        return new Result(true, "success",CollectionUtils.newObjectMap("topicLst", topicLst, "topicCount", topicCount,"sunCount",sunCount));
    }

    @Override

 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)
@@ -135,14 +135,14 @@
    IWechatService wechatService;

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

    @PostMapping("/wxAccountsLogin")
    @ApiOperation("微信公众号登录")
    @ApiOperation("微信公众号录")
    @ResponseBody
    public Result wxAccountsLogin(String code) {
        JSONObject gettoken = wechatService.gettoken(wxappId, wxsecret);
@@ -153,7 +153,7 @@


    @PostMapping("/wxlogin")
    @ApiOperation("微信小程序登录")
    @ApiOperation("微信小程序录")
    @ResponseBody
    public Result wechatLogin(String code,String number) {
        JSONObject sessionKeyOrOpenId = wechatService.getSessionKeyOrOpenId(code);
@@ -202,7 +202,7 @@
    }


    @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"),
@@ -257,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"),
@@ -293,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"),
@@ -327,7 +327,7 @@
        return new Result(true, "验证成功");
    }

    //退出登录 清除session
    //退出录 清除session
    @RequestMapping(value = "khdloginout", method = RequestMethod.POST)
    @ResponseBody
    public void khdloginout(HttpServletRequest request, HttpServletResponse response) {
@@ -340,19 +340,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 = "studentLogin", method = RequestMethod.POST)
    @ResponseBody
@@ -386,19 +386,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
@@ -436,12 +436,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");
//        }
@@ -465,7 +465,7 @@
    }

    /**
     * 登入验证
     * 入验证
     * @param user
     * @param type
     * @param request
@@ -497,20 +497,20 @@
            }*/

            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",
@@ -521,16 +521,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",
@@ -557,7 +557,7 @@
    }

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

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

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

 src/main/java/com/qxueyou/scc/teach/live/service/IMediaLiveService.java

@@ -53,6 +53,8 @@
     */
    int listCountOfMine(String keyword);

    List<MediaVideoLive> listvideo(String status);

    /**
     * 查询直播
     * @param keyword 查询关键字

 src/main/java/com/qxueyou/scc/teach/live/service/impl/MediaLiveService.java

@@ -333,6 +333,15 @@
        return this.findCountByComplexHql(hql.toString(), params);
    }
    
    @Override
    public List<MediaVideoLive> listvideo(String status) {

        String hql = "from MediaVideoLive where deleteFlag is false and status=?  order by createTime desc";


        return find(hql, CollectionUtils.newList(status), MediaVideoLive.class);
    }

    @Override
    public List<MediaVideoLive> listOfMine(String keyword, Integer pageNum, Integer pageSize) {
        

 src/main/java/com/qxueyou/scc/user/service/IUserService.java

@@ -119,4 +119,6 @@
    boolean exists(String account);

    Result countUser();

    Result countUsersex();
}

 src/main/java/com/qxueyou/scc/user/service/impl/UserService.java

@@ -287,5 +287,9 @@
        String hql = "from count User where sex=? and deleteFlag is false";
        return new Result(true,findCount(hql,CollectionUtils.newList(1)));
    }

    @Override
    public Result countUsersex() {
        String hql = "from count User where sex=? and deleteFlag is false";
        return new Result(true,findCount(hql,CollectionUtils.newList(0)));
    }
}