基于Spark电商用户行为分析的电商后台程序

package com.ecommerce.analysis.controller; import com.ecommerce.analysis.bean.R; import com.ecommerce.analysis.entity.PVResult; import com.ecommerce.analysis.entity.UserBehaviour; import com.ecommerce.analysis.service.PVResultService; import com.ecommerce.analysis.service.UserBehaviourService; 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.RequestMethod; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.servlet.ModelAndView; import java.util.HashMap; import java.util.List; import java.util.Map; @RestController @RequestMapping(value = "/page") public class IndexController { @Autowired private PVResultService pvResultService; @Autowired private UserBehaviourService userBehaviourService; /** * 首页,显示用户行为漏斗页面 * @return */ @RequestMapping(value = "index",method = RequestMethod.GET) public ModelAndView index(){ // 0. 新建ModelAndView对象 ModelAndView mv=new ModelAndView(); mv.setViewName("index.html"); return mv; } @GetMapping("getUserData") public R getData(){ // 0. 创建Map Map<String,Integer> map = new HashMap<>(); // 1. 获取PV数据 List<PVResult> pvResults = pvResultService.list(null); if (pvResults != null && pvResults.size() > 0){ map.put("pv",pvResults.get(0).getCount()); } // 2. 获取用户行为数据 List<UserBehaviour> behaviourList = userBehaviourService.list(null); if (behaviourList != null && behaviourList.size() > 0){ map.put("clickCount",behaviourList.get(0).getClickCount().intValue()); map.put("orderCount",behaviourList.get(0).getOrderCount().intValue()); map.put("payCount",behaviourList.get(0).getPayCount().intValue()); } return R.ok().data("map",map); } }