Skip to content

C
cloud-web
Commit 9c80c463 by 阳浪
Options

埋点

parent 0a67cae7
Showing with 200 additions and 18 deletions
cloud-web-manage/src/main/java/com/yizhi/application/portal/controller/EventTrackManageController.java 0 → 100644
package com.yizhi.application.portal.controller;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.site.application.vo.site.DayNumVo;
import com.yizhi.site.application.vo.site.EventTrackDayNumVo;
import com.yizhi.site.application.vo.site.EventTrackDeptNumVo;
import com.yizhi.site.application.vo.site.EventTrackTypeNumVo;
import com.yizhi.util.application.domain.Response;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* com.yizhi.site.application.controller.api
*
* @author yanglang
* @create 2025-01-14 10:57:55
*/
@RestController
@RequestMapping("/manage/api/eventTrack")
public class EventTrackManageController {
@Autowired
private EventTrackApiClients eventTrackApiClients;
@GetMapping("/addEvent")
public Response addEvent(@RequestParam("type") String type, @RequestParam("businessId") Long businessId){
eventTrackApiClients.addEvent(type,businessId);
return Response.ok();
}
@GetMapping("/getTodayNum")
public Response<EventTrackDayNumVo> getTodayNum(@RequestParam(value = "date",required = false) String date){
return Response.ok(eventTrackApiClients.getTodayNum(date));
}
@GetMapping("/api/eventTrack/getNumByType")
public Response<DayNumVo> getNumByType(@RequestParam(value = "date",required = false) String date, @RequestParam("types") List<Integer> types){
return Response.ok(eventTrackApiClients.getNumByType(date,types));
}
@GetMapping("/api/eventTrack/queryNumByType")
public Response<List<EventTrackTypeNumVo>> queryNumByType(@RequestParam(value = "date",required = false) String date, @RequestParam("types")List<Integer> types){
return Response.ok(eventTrackApiClients.queryNumByType(date,types));
}
@GetMapping("/api/eventTrack/queryDeptByType")
public Response<List<EventTrackDeptNumVo>> queryDeptByType(@RequestParam(value = "date",required = false) String date, @RequestParam("types")List<Integer> types){
return Response.ok(eventTrackApiClients.queryDeptByType(date,types));
}
}
cloud-web-manage/src/main/java/com/yizhi/application/portal/controller/LeaveWordManageController.java
......@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.plugins.Page;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.point.application.feign.PointListenerClients;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.training.application.feign.LeaveWordClient;
import com.yizhi.training.application.vo.domain.LeaveWordParamVo;
import com.yizhi.training.application.vo.domain.LeaveWordVo;
......@@ -17,6 +18,8 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.Objects;
/**
* com.yizhi.application.portal.controller
*
......@@ -35,6 +38,9 @@ public class LeaveWordManageController {
@Autowired
private PointListenerClients pointListenerClients;
@Autowired
private EventTrackApiClients eventTrackApiClients;
@PostMapping("/page")
@ApiOperation(value = "分页查询", notes = "分页查询")
......@@ -56,6 +62,10 @@ public class LeaveWordManageController {
RequestContext context = ContextHolder.get();
leaveWordParamVo.setCreateById(context.getAccountId());
Page<LeaveWordVo> page = leaveWordClient.page(leaveWordParamVo);
// 添加留言埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("leave_word",context.getAccountId());
}
return Response.ok(page);
}catch (Exception e){
logger.error("分页查询失败");
......
cloud-web-manage/src/main/java/com/yizhi/application/portal/controller/SitePublicationManageController.java
......@@ -8,6 +8,7 @@ import com.yizhi.lecturer.application.enums.DeleteFlag;
import com.yizhi.point.application.feign.PointListenerClients;
import com.yizhi.site.application.feign.PortalManagePCFeignClients;
import com.yizhi.site.application.feign.PublicationManageFeignClients;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.site.application.vo.domain.ProtalPlateVo;
import com.yizhi.site.application.vo.domain.PublicationVo;
import com.yizhi.site.application.vo.site.*;
......@@ -22,6 +23,7 @@ import org.springframework.web.bind.annotation.*;
import java.util.Date;
import java.util.List;
import java.util.Objects;
/**
* 投稿管理
......@@ -44,6 +46,9 @@ public class SitePublicationManageController {
@Autowired
private PointListenerClients pointListenerClients;
@Autowired
private EventTrackApiClients eventTrackApiClients;
/**
* 投稿列表
*
......@@ -53,7 +58,13 @@ public class SitePublicationManageController {
@PostMapping("/list")
public Response<Page<PublicationVo>> list(@RequestBody PublicationParamVO vo) {
try {
vo.setSiteId(ContextHolder.get().getSiteId());
RequestContext context = ContextHolder.get();
vo.setSiteId(context.getSiteId());
// 添加我的投稿埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("event_publication",context.getAccountId());
}
return Response.ok(publicationManageFeignClients.list(vo));
} catch (Exception e) {
e.printStackTrace();
......@@ -107,7 +118,7 @@ public class SitePublicationManageController {
}
}
@ApiOperation(value = "保存资料分类", notes = "保存资料分类")
@ApiOperation(value = "保存投稿", notes = "保存投稿")
@PostMapping("/insert")
public Response<Boolean> insert(@RequestBody PublicationVo information) {
try {
......@@ -124,6 +135,11 @@ public class SitePublicationManageController {
if (id == null) {
Response.fail(InternationalEnums.SITEINFORMATIONMANAGECONTROLLER.getCode());
}
// 添加我的投稿埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("event_publication_"+information.getTypeOne(),id);
}
information.setId(id);
return Response.ok(true);
} catch (Exception e) {
......
cloud-web-manage/src/main/java/com/yizhi/application/research/controller/manage/ResearchController.java
......@@ -19,6 +19,7 @@ import com.yizhi.research.application.vo.domain.TrResearchRemindVo;
import com.yizhi.research.application.vo.manage.RemindTimeVo;
import com.yizhi.research.application.vo.manage.RemindVo;
import com.yizhi.research.application.vo.manage.ResearchVo;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.statistics.application.refactor.TrResearchAuthorizeVO;
import com.yizhi.system.application.vo.AccountVO;
import com.yizhi.system.application.vo.OrgVO;
......@@ -67,6 +68,9 @@ public class ResearchController {
@Autowired
private TaskSendMessage taskSendMessage;
@Autowired
private EventTrackApiClients eventTrackApiClients;
/**
* 新增调研接口
*
......@@ -250,6 +254,12 @@ public class ResearchController {
model.setContext(ContextHolder.get());
model.setObj(page);
RequestContext context = ContextHolder.get();
// 添加调研埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("event_research",context.getAccountId());
}
return Response.ok(researchClient.listPage(model));
} catch (Exception e) {
LOGGER.error("", e);
......
cloud-web-student/src/main/java/com/yizhi/application/caseLibrary/controller/StudyCaseController.java
package com.yizhi.application.caseLibrary.controller;
import com.baomidou.mybatisplus.plugins.Page;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.library.application.feign.StudyCaseClient;
import com.yizhi.library.application.param.InformParam;
import com.yizhi.library.application.vo.CommentReplyVO;
import com.yizhi.library.application.vo.CommentVO;
import com.yizhi.site.application.feign.InformationStudentFeignClients;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.site.application.vo.site.IdOneVO;
import com.yizhi.site.application.vo.site.InformationViewVO;
import com.yizhi.util.application.domain.Response;
import com.yizhi.util.application.enums.i18n.Constants;
import io.swagger.annotations.*;
......@@ -15,6 +21,7 @@ import org.springframework.web.bind.annotation.*;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
/**
* @author Ding
......@@ -32,12 +39,25 @@ public class StudyCaseController {
@Autowired
private StudyCaseClient studyCaseClient;
@Autowired
private EventTrackApiClients eventTrackApiClients;
@Autowired
InformationStudentFeignClients informationStudentFeignClients;
@ApiOperation(value = "学习案例点赞", notes = "学习案例点赞")
@GetMapping("/admire")
public Response<Object> admireStudentCase(@ApiParam(value = "学员案例id", required = true) @RequestParam(name = "studentCaseId", required = true) Long studentCaseId) {
try {
if (studyCaseClient.admireStudentCase(studentCaseId)) {
RequestContext context = ContextHolder.get();
IdOneVO idOneVO =new IdOneVO();
idOneVO.setId(studentCaseId);
InformationViewVO viewVO = informationStudentFeignClients.getInformation(idOneVO);
// 添加点赞埋点
if(Objects.equals(context.getSiteType(),2)&&viewVO!=null&&viewVO.getTypeOne()!=null){
eventTrackApiClients.addEvent("event_admire_"+viewVO.getTypeOne(),studentCaseId);
}
return Response.ok();
} else {
LOGGER.error("############学习案例点赞过程中出现错误");
......@@ -56,6 +76,14 @@ public class StudyCaseController {
try {
if (studyCaseClient.cancelAdmireStudentCase(studentCaseId)) {
RequestContext context = ContextHolder.get();
IdOneVO idOneVO =new IdOneVO();
idOneVO.setId(studentCaseId);
InformationViewVO viewVO = informationStudentFeignClients.getInformation(idOneVO);
// 添加点赞埋点
if(Objects.equals(context.getSiteType(),2)&&viewVO!=null&&viewVO.getTypeOne()!=null){
eventTrackApiClients.addEvent("event_admire_"+viewVO.getTypeOne(),studentCaseId);
}
return Response.ok();
} else {
LOGGER.error("############学习案例取消点赞过程中出现错误");
......@@ -74,6 +102,14 @@ public class StudyCaseController {
try {
if (studyCaseClient.favorite(studentCaseId)) {
RequestContext context = ContextHolder.get();
IdOneVO idOneVO =new IdOneVO();
idOneVO.setId(studentCaseId);
InformationViewVO viewVO = informationStudentFeignClients.getInformation(idOneVO);
// 添加点赞埋点
if(Objects.equals(context.getSiteType(),2)&&viewVO!=null&&viewVO.getTypeOne()!=null){
eventTrackApiClients.addEvent("event_favorite_"+viewVO.getTypeOne(),studentCaseId);
}
return Response.ok();
} else {
LOGGER.error("############学习案例收藏过程中出现错误");
......@@ -158,6 +194,14 @@ public class StudyCaseController {
try {
if (studyCaseClient.admireComment(commentId)) {
RequestContext context = ContextHolder.get();
IdOneVO idOneVO =new IdOneVO();
idOneVO.setId(commentId);
InformationViewVO viewVO = informationStudentFeignClients.getInformation(idOneVO);
// 添加点赞埋点
if(Objects.equals(context.getSiteType(),2)&&viewVO!=null&&viewVO.getTypeOne()!=null){
eventTrackApiClients.addEvent("event_admire_"+viewVO.getTypeOne(),commentId);
}
return Response.ok();
} else {
LOGGER.error("############评论点赞过程中出现错误");
......@@ -191,8 +235,8 @@ public class StudyCaseController {
@ApiOperation(value = "获取评论列表", notes = "获取评论列表", response = CommentVO.class)
@GetMapping("/comment/list")
public Response<CommentVO> getCommentList(@ApiParam(value = "学员案例id", required = true) @RequestParam(name = "studentCaseId", required = true) Long studentCaseId,
@ApiParam(value = "当前第几页", required = true) @RequestParam(name = "pageNo", required = true) Integer pageNo,
@ApiParam(value = "每页显示条数", required = true) @RequestParam(name = "pageSize", required = true) Integer pageSize) {
@ApiParam(value = "当前第几页", required = true) @RequestParam(name = "pageNo", required = true) Integer pageNo,
@ApiParam(value = "每页显示条数", required = true) @RequestParam(name = "pageSize", required = true) Integer pageSize) {
try {
return Response.ok(studyCaseClient.getCommentList(studentCaseId, pageNo, pageSize));
......@@ -205,8 +249,8 @@ public class StudyCaseController {
@ApiOperation(value = "获取回复列表", notes = "获取回复列表", response = CommentReplyVO.class)
@GetMapping("/comment/replyList")
public Response<CommentReplyVO> getReplyList(@ApiParam(value = "评论id", required = true) @RequestParam(name = "commentId", required = true) Long commentId,
@ApiParam(value = "当前第几页", required = true) @RequestParam(name = "pageNo", required = true) Integer pageNo,
@ApiParam(value = "每页显示条数", required = true) @RequestParam(name = "pageSize", required = true) Integer pageSize) {
@ApiParam(value = "当前第几页", required = true) @RequestParam(name = "pageNo", required = true) Integer pageNo,
@ApiParam(value = "每页显示条数", required = true) @RequestParam(name = "pageSize", required = true) Integer pageSize) {
try {
Page<CommentReplyVO> page = studyCaseClient.getReplyList(commentId, pageNo, pageSize);
......
cloud-web-student/src/main/java/com/yizhi/application/enroll/controller/EnrollApiController.java
package com.yizhi.application.enroll.controller;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.enroll.application.feign.EnrollFeignClient;
import com.yizhi.enroll.application.vo.IdEnrollVO;
import com.yizhi.point.application.feign.PointListenerClients;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.training.application.feign.TpEnrollPassedClient;
import com.yizhi.util.application.constant.ReturnCode;
import com.yizhi.util.application.domain.Response;
......@@ -20,6 +23,8 @@ import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import java.util.Objects;
@Api(tags = "学员端接口", description = "学员端接口")
@RestController
@RequestMapping("/api/enroll")
......@@ -36,6 +41,9 @@ public class EnrollApiController {
@Autowired
private PointListenerClients pointListenerClients;
@Autowired
private EventTrackApiClients eventTrackApiClients;
@ApiOperation(value = "添加学员报名信息", notes = "添加学员报名信息")
@PostMapping("/student")
@ApiImplicitParams({
......@@ -46,9 +54,15 @@ public class EnrollApiController {
if (vo.getId() == null) {
return Response.fail("参数错误");
}
RequestContext requestContext = ContextHolder.get();
Long id = enrollFeignClient.insertTrEnrollRecord(vo.getId());
tpEnrollPassedClient.insertTpStudentEnrollPassed(vo.getId(), id);
pointListenerClients.addPoint("CreditClendarDone", id);
// 添加学院报名埋点
if(Objects.equals(requestContext.getSiteType(),2)){
eventTrackApiClients.addEvent("event_enroll_student",vo.getId());
}
return Response.ok(id);
} catch (Exception e) {
LOG.error("添加学员报名信息:" + e);
......
cloud-web-student/src/main/java/com/yizhi/application/exam/controller/ExamApiController.java
package com.yizhi.application.exam.controller;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;
import com.yizhi.core.application.context.ContextHolder;
......@@ -18,6 +15,7 @@ import com.yizhi.exam.application.vo.domain.Exam;
import com.yizhi.exam.application.vo.domain.TrExamAuthorize;
import com.yizhi.exam.application.vo.exam.*;
import com.yizhi.point.application.feign.PointRedisFeignClients;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.util.application.constant.ReturnCode;
import com.yizhi.util.application.domain.Response;
import com.yizhi.util.application.enums.i18n.Constants;
......@@ -56,6 +54,10 @@ public class ExamApiController {
@Autowired
private PointRedisFeignClients pointRedisClient;
@Autowired
private EventTrackApiClients eventTrackApiClients;
/*@Autowired
private RabbitTemplate rabbitTemplate;*/
......@@ -289,6 +291,10 @@ public class ExamApiController {
examDetailsVO = examApiClient.scanCodeExam(myExamParameterVO);
// 添加培训测试埋点
if(Objects.equals(requestContext.getSiteType(),2)){
eventTrackApiClients.addEvent("event_scan_exam",examAnswerApiListVo.getExamId());
}
return Response.ok(examDetailsVO);
}
}
cloud-web-student/src/main/java/com/yizhi/application/exam/controller/MyExamController.java
......@@ -10,10 +10,7 @@
*/
package com.yizhi.application.exam.controller;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
......@@ -22,6 +19,7 @@ import com.yizhi.exam.application.feign.MyExamClient;
import com.yizhi.exam.application.vo.MyExamParameterVO;
import com.yizhi.exam.application.vo.MyExamVO;
import com.yizhi.exam.application.vo.exam.MyExamPageVO;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.site.application.vo.site.PortalHomeSearchVO;
import com.yizhi.training.application.feign.TrainingProjectClient;
import com.yizhi.training.application.vo.domain.TrainingProjectVo;
......@@ -68,6 +66,9 @@ public class MyExamController {
@Autowired
TrainingProjectClient trainingProjectClient;
@Autowired
private EventTrackApiClients eventTrackApiClients;
@ApiOperation(value = "我的考试（未完成、进行中、已完成、已逾期）", notes = "我的考试（未完成、进行中、已完成、已逾期）", response = MyExamVO.class)
@PostMapping("/list")
public Response<MyExamVO> getMyExamList(@RequestBody MyExamParameterVO myExamParameterVO) {
......@@ -100,6 +101,11 @@ public class MyExamController {
page.put("pageNo", myExamParameterVO.getPageNo());
page.put("pageSize", myExamParameterVO.getPageSize());
page.put("pageTotal", myExamPageVO.getPageTotal());
// 添加培训测试埋点
if(Objects.equals(requestContext.getSiteType(),2)){
eventTrackApiClients.addEvent("event_exam",requestContext.getAccountId());
}
return Response.ok(myExamVOS, page);
} catch (Exception e) {
LOG.error("", e);
......
cloud-web-student/src/main/java/com/yizhi/application/project/controller/TpCommentApiController.java
......@@ -6,6 +6,7 @@ import com.yizhi.application.project.controller.util.CommentUtil;
import com.yizhi.application.tools.PageTools;
import com.yizhi.core.application.context.ContextHolder;
import com.yizhi.core.application.context.RequestContext;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import com.yizhi.training.application.constant.ProjectConstant;
import com.yizhi.training.application.feign.TpCommentClient;
import com.yizhi.training.application.feign.TpCommentReplyClient;
......@@ -25,6 +26,7 @@ import org.springframework.web.bind.annotation.*;
import java.util.Date;
import java.util.Map;
import java.util.Objects;
/**
* <p>
......@@ -48,6 +50,9 @@ public class TpCommentApiController {
@Autowired
private CommentUtil workUtil;
@Autowired
private EventTrackApiClients eventTrackApiClients;
private static final Logger LOGGER = LoggerFactory.getLogger(TpCommentApiController.class);
......@@ -69,6 +74,12 @@ public class TpCommentApiController {
tpComment.setOrgId(requestContext.getOrgId() == null ? 0l : requestContext.getOrgId());
tpComment.setAuditStatus(ProjectConstant.COMMENT_AUDIT_STATUS_UP.toString());
Boolean f = tpCommentClient.save(tpComment);
RequestContext context = ContextHolder.get();
// 添加发表评论埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("event_tp_comment",tpComment.getId());
}
if (f) {
LOGGER.info("发表评论成功");
return Response.ok("发表评论成功");
......
cloud-web-student/src/main/java/com/yizhi/application/project/controller/TrainingProjectController.java
package com.yizhi.application.project.controller;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;
import com.yizhi.site.application.feign.api.EventTrackApiClients;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
......@@ -80,6 +78,9 @@ public class TrainingProjectController {
@Autowired
private ProjectWorkUtil workUtil;
@Autowired
private EventTrackApiClients eventTrackApiClients;
@PostMapping("/page/list")
......@@ -128,6 +129,7 @@ public class TrainingProjectController {
}
}
}*/
return Response.ok(resultPage);
} catch (Exception e) {
LOGGER.error("", e);
......@@ -496,6 +498,12 @@ public class TrainingProjectController {
public Response<TrainingActivityVO> getTrainingActivity(@RequestParam("bizType") Integer bizType,
@RequestParam(name = "startDate", required = false) String startDate, @RequestParam(name = "endDate", required = false) String endDate) {
TrainingActivityVO result = trainingProjectClient.getTrainingActivity(bizType, startDate, endDate);
RequestContext context = ContextHolder.get();
// 添加活动埋点
if(Objects.equals(context.getSiteType(),2)){
eventTrackApiClients.addEvent("event_training_activity",context.getAccountId());
}
return Response.ok(result);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment