package com.matrix.system.hiveErp.action;
|
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.tools.DateUtil;
|
import com.matrix.system.hiveErp.Vo.StatisticsParamVo;
|
import com.matrix.system.hiveErp.Vo.StatisticsTimeDaoParam;
|
import com.matrix.system.hiveErp.dao.TjVipSumDao;
|
import com.matrix.system.hiveErp.util.StatisticsTimeUtil;
|
import org.apache.commons.collections.MapUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import java.util.*;
|
|
@Controller
|
@RequestMapping(value = "admin/analysis")
|
public class CustomerAnalysis {
|
|
@Autowired
|
TjVipSumDao tjVipSumDao;
|
/**
|
* 到店次数趋势统计
|
*
|
* @return
|
*/
|
@RequestMapping(value = "/vipVisitTendency ")
|
public @ResponseBody
|
AjaxResult vipVisit(StatisticsParamVo statisticsParam) {
|
AjaxResult result = new AjaxResult();
|
//计算横坐标
|
List<Date> xAxis = StatisticsTimeUtil.getTimeSpace(statisticsParam.getBeginTime(), statisticsParam.getEndTime(), statisticsParam.getStatisticsUnit());
|
Map<String, Integer> yAxisMap = tjVipSumDao.countVisitByTime(buidParam(xAxis),null);
|
Integer[] series= getSeries(yAxisMap);
|
|
//构造返回对象
|
Map<Object,Object> data=new HashMap<>();
|
data.put("series",series);
|
data.put("xAxis", getFormartDateList(xAxis,statisticsParam));
|
result.setMapInfo(data);
|
result.setStatus(AjaxResult.STATUS_SUCCESS);
|
return result;
|
}
|
|
/**
|
* 获取map中的值为数组
|
* @param yAxisMap
|
* @return
|
*/
|
private Integer[] getSeries(Map<String, Integer> yAxisMap) {
|
if (MapUtils.isNotEmpty(yAxisMap)) {
|
Integer[] seroes = new Integer[yAxisMap.size()-1];
|
for (int index=0; index<yAxisMap.size()-1 ; index++) {
|
if(index<seroes.length){
|
seroes[index]=Integer.parseInt(yAxisMap.get("t"+index)+"");
|
}
|
}
|
return seroes;
|
} else {
|
return new Integer[0];
|
}
|
}
|
|
|
private String[] getFormartDateList(List<Date> xAxis,StatisticsParamVo statisticsParam) {
|
String[] dates=new String[xAxis.size()];
|
String dataFmt="";
|
switch (statisticsParam.getStatisticsUnit()){
|
case "时":
|
dataFmt= DateUtil.DATE_FORMAT_HH;
|
break;
|
case "日":
|
dataFmt=DateUtil.DATE_FORMAT_DD;
|
break;
|
case "月":
|
dataFmt=DateUtil.MONTH;
|
break;
|
case "年":
|
dataFmt=DateUtil.YEAR;
|
break;
|
|
}
|
for(int i=0 ; i<dates.length; i++ ){
|
dates[i]= DateUtil.dateToString(xAxis.get(i),dataFmt);
|
}
|
return dates;
|
}
|
|
|
/**
|
* 构建查询参数，带时间范围
|
* @param xAxis
|
* @return
|
*/
|
private List<StatisticsTimeDaoParam> buidParam(List<Date> xAxis) {
|
List<StatisticsTimeDaoParam> daoParams = new ArrayList<>();
|
for(int i=0 ;i<xAxis.size(); i++){
|
StatisticsTimeDaoParam param= new StatisticsTimeDaoParam();
|
param.setBeginTime(xAxis.get(i));
|
if(i+1<xAxis.size()){
|
param.setEndTime(xAxis.get(i+1));
|
}
|
daoParams.add(param);
|
}
|
return daoParams;
|
}
|
|
|
|
}
|
