TBoardStatisticController.java

package cn.chnmuseum.party.web.controller;

import cn.chnmuseum.party.common.util.DateUtil;
import cn.chnmuseum.party.model.*;
import cn.chnmuseum.party.service.TAreaService;
import cn.chnmuseum.party.service.TBoardStatisticService;
import cn.chnmuseum.party.web.controller.base.BaseController;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * <pre>
 * 展板统计信息表 前端控制器
 * </pre>
 *
 * @author Danny Lee
 * @since 2021-03-25
 */
@Slf4j
@RestController
@RequestMapping("/tBoardStatistic")
@Api(tags = {"展板统计信息表操作接口"})
public class TBoardStatisticController extends BaseController {

    @Resource
    private TBoardStatisticService tBoardStatisticService;

    @Autowired
    TAreaService areaService;

    //    @ApiImplicitParams(value = {
//            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
//            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer")
//    })
    @PostMapping("/getBoardSurvey")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:survey")
    @ApiOperation(value = "获取展板统计概况", notes = "获取展板统计概况")
    public Map<String, Object> getBoardSurvey(TBoardSurvey survey) {
        TUser user = null;
        try {
            user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                survey.setOrganCode(user.getOrgCode());
            }
        } catch (Exception e) {
            survey.setOrganCode(null);
        }
        // 默认当月
        if (StringUtils.isEmpty(survey.getStatisticDate())) {
            survey.setStatisticDate(DateUtil.getCurrentDate("yyyyMM"));
        }
        //加上区域条件
        List<String> areaIds = findAllAreaIdByParentCode(survey.getAreaCode());
        survey.setAreaIds(areaIds);
        TBoardSurvey result = this.tBoardStatisticService.getBoardSurvey(survey);

        return getResult(result);
    }

    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer")
    })
    @PostMapping("/getBoardRankPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:rankPage")
    @ApiOperation(value = "获取展板播放排行", notes = "获取展板播放排行")
    public Map<String, Object> getBoardRankPageList(TBoardPlayRank rank) {
        TUser user = null;
        try {
            user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                rank.setOrganCode(user.getOrgCode());
            }
        } catch (Exception e) {
            rank.setOrganCode(null);
        }
        // 默认当月
        if (StringUtils.isEmpty(rank.getPlayDate())) {
            rank.setPlayDate(DateUtil.getCurrentDate("yyyyMM"));
        }
        //加上区域条件
        List<String> areaIds = findAllAreaIdByParentCode(rank.getAreaCode());
        rank.setAreaIds(areaIds);
        Page<TBoardPlayRank> page = this.tBoardStatisticService.getBoardRankPageList(getPage(), rank);
        return getResult(page);
    }

    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer")
    })
    @PostMapping("/getBoardTrendPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:trendPage")
    @ApiOperation(value = "获取展板播放趋势", notes = "获取展板播放趋势")
    public Map<String, Object> getBoardTrendPageList(TBoardPlayTrend trend) throws ParseException {
        TUser user = null;
        try {
            user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                trend.setOrganCode(user.getOrgCode());
            }
        } catch (Exception e) {
            trend.setOrganCode(null);
        }
        // 如果查询日志为空，则默认当月
        if (StringUtils.isEmpty(trend.getPlayDate())) {
            trend.setPlayDate(DateUtil.getCurrentDate("yyyyMM"));
        }
        //加上区域条件
        List<String> areaIds = findAllAreaIdByParentCode(trend.getAreaCode());
        trend.setAreaIds(areaIds);

        Page<TBoardPlayTrend> page = this.tBoardStatisticService.getBoardTrendPageList(getPage(), trend);

//        List<TBoardPlayTrend> records = this.tBoardStatisticService.getBoardTrendPageList(getPage(), trend);
        // 处理数据为展板趋势图
        Map map = new HashMap();
        List dateList = new ArrayList();
        List cntList = new ArrayList();
        //按照 播放数据统计大屏 中 展板点播趋势图要求返回本月每天的播放量需求 修改接口
        getDateList(trend.getPlayDate(), dateList, cntList);
        for (TBoardPlayTrend t : page.getRecords()) {
//        for (TBoardPlayTrend t : records) {
//            dateList.add(t.getPlayDate());
//            cntList.add(t.getPlayNumber());
            int index = dateList.indexOf(t.getPlayDate());
            if (index >= 0) {
                cntList.set(index, t.getPlayNumber());
            }
        }
//        page.getRecords().sort(Comparator.comparing(TBoardPlayTrend::getPlayNumber).reversed());
        map.put("dateList", dateList);
        map.put("cntList", cntList);
        map.put("page", page);
        return getResult(map);
    }

    /**
     * 按照 播放数据统计大屏 中 展板点播趋势图要求返回本月每天的播放量  新增方法
     *
     * @param dateFormat
     * @param dateList
     * @param cntList
     * @throws ParseException
     */
    private void getDateList(String dateFormat, List dateList, List cntList) throws ParseException {
        Date date;
        Date beginTime;
        Date endTime;
        Date nowDate = new Date();
        if (dateFormat.length() > 4) {
            date = new SimpleDateFormat("yyyyMM").parse(dateFormat);
            beginTime = cn.hutool.core.date.DateUtil.beginOfMonth(date);
            endTime = cn.hutool.core.date.DateUtil.endOfMonth(date);
            //  设置最后时间不能大于当前时间
            if (nowDate.after(beginTime) && nowDate.before(endTime)) {
                endTime = nowDate;
            }
        } else {
            date = new SimpleDateFormat("yyyy").parse(dateFormat);
            beginTime = cn.hutool.core.date.DateUtil.beginOfYear(date);
            endTime = cn.hutool.core.date.DateUtil.endOfYear(date);
            //  设置最后时间不能大于当前时间
            if (nowDate.after(beginTime) && nowDate.before(endTime)) {
                endTime = nowDate;
            }
        }
        //生成范围类的一系列日期
        List<DateTime> dateTimes = cn.hutool.core.date.DateUtil.rangeToList(beginTime, endTime, DateField.DAY_OF_MONTH);
        dateTimes.stream().forEach(dt -> {
            String yyyyMMdd = dt.toString("yyyyMMdd");
            dateList.add(yyyyMMdd);
            //默认初始值0
            cntList.add(0);
        });
    }

    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer")
    })
    @PostMapping("/getBoardDistrictPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:districtPage")
    @ApiOperation(value = "获取地区展板播统计", notes = "获取地区展板播统计")
    public Map<String, Object> getBoardDistrictPageList(TDistrictBoardStatistic district) {
        TUser user = null;
        try {
            user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                district.setOrganCode(user.getOrgCode());
            }
        } catch (Exception e) {
            district.setOrganCode(null);
        }
        // 默认当月
        if (StringUtils.isEmpty(district.getPlayDate())) {
            district.setPlayDate(DateUtil.getCurrentDate("yyyyMM"));
        }
        //加上区域条件
        List<String> areaIds = findAllAreaIdByParentCode(district.getAreaCode());
        district.setAreaIds(areaIds);
        Page<TDistrictBoardStatistic> page = this.tBoardStatisticService.getBoardDistrictPageList(getPage(), district);
        return getResult(page);
    }

    /**
     * 根据父地区code查询查询所有子下级  返回包含本机id以及所有的子集id
     *
     * @param areaCode
     * @return
     */
    private List<String> findAllAreaIdByParentCode(String areaCode) {
        List<String> areaIds = new ArrayList<>();
        if (StringUtils.isBlank(areaCode)) {
            return areaIds;
        }
        LambdaQueryWrapper<TArea> wrapper = new QueryWrapper<TArea>().lambda()
                .eq(TArea::getCode, areaCode);
        TArea one = areaService.getOne(wrapper, false);
        if (one == null) {
            return areaIds;
        }
        List<String> parentAreaIds = new ArrayList<>();
        String valueOf = String.valueOf(one.getId());
        parentAreaIds.add(valueOf);
        //加上自己本身的id
        areaIds.add(valueOf);
        //循环调用数据库，但实际只会调用3到4次，区域级别无非三四级
        while (!CollectionUtils.isEmpty(parentAreaIds)) {
            wrapper.clear();
            wrapper.in(TArea::getParentId, parentAreaIds)
                    .select(TArea::getId, TArea::getParentId);
            List<TArea> list = areaService.list(wrapper);
            if (CollectionUtils.isEmpty(list)) {
                //为空跳出循环
                break;
            }
            List<String> ids = list.stream().map(l -> String.valueOf(l.getId())).collect(Collectors.toList());
            parentAreaIds = ids;
            areaIds.addAll(parentAreaIds);
        }
        return areaIds;
    }

    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "organId", value = "统计机构", paramType = "query", dataType = "String")
    })
    @PostMapping("/getBoardProvincePlayTotalList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:provPlayList")
    @ApiOperation(value = "获取省级展板播放统计", notes = "获取省级展板播放统计")
    public Map<String, Object> getBoardProvincePlayTotalList(String organId) {
        String orgCode = null;
        try {
            TUser user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                orgCode = user.getOrgCode();
            }
        } catch (Exception e) {
            orgCode = null;
        }
        List list = this.tBoardStatisticService.getBoardProvincePlayTotalList(organId, orgCode);
        return getResult(list);
    }


    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "areaCode", value = "区域编码", paramType = "query", dataType = "String")
    })
    @PostMapping("/getBoardCityPlayTotalList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:provPlayList")
    @ApiOperation(value = "获取下级区域展板播放统计", notes = "获取下级展板播放统计")
    public Map<String, Object> getBoardCityPlayTotalList(String areaCode) {
        String orgCode = null;
        try {
            TUser user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                orgCode = user.getOrgCode();
            }
        } catch (Exception e) {
            orgCode = null;
        }
        List list = this.tBoardStatisticService.getBoardCityPlayTotalList(areaCode, orgCode);
        return getResult(list);
    }

    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "frequencyDate", value = "互动统计时间 年：yyyy 月：yyyyMM,默认当月", paramType = "query", dataType = "String")
    })
    @PostMapping("/getInteractionFrequencyPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:districtPage")
    @ApiOperation(value = "获取互动频次统计信息", notes = "获取互动频次统计信息")
    public Map<String, Object> getInteractionFrequencyPageList(String frequencyDate, String areaCode) {
        String orgCode = null;
        try {
            TUser user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                orgCode = user.getOrgCode();
            }
        } catch (Exception e) {
            orgCode = null;
        }
        if (StringUtils.isEmpty(frequencyDate)) {
            frequencyDate = DateUtil.getCurrentDate("yyyyMM");
        }
        //加上区域条件
        List<String> areaIds = findAllAreaIdByParentCode(areaCode);

        Page page = this.tBoardStatisticService.getInteractionFrequency(getPage(), frequencyDate, orgCode, areaIds);
        //
        Map map = new HashMap();
        List organList = new ArrayList<>();
        List cntList = new ArrayList();
        for (Object o : page.getRecords()) {
            Map m = (HashMap) o;
            organList.add(m.get("organName"));
            cntList.add(m.get("frequencyCnt"));
        }
        map.put("organList", organList);
        map.put("cntList", cntList);
        map.put("page", page);
        return getResult(map);
    }


    /**
     * 以下两个接口是pc端专用
     *
     * @param trend
     * @return
     */
    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer")
    })
    @PostMapping("/getBoardPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:board:statistic:Page")
    @ApiOperation(value = "获取展板播放趋势Pc", notes = "获取展板播放趋势Pc")
//    @MethodLog(operModule = OperModule.TEND, operType = OperType.SELECT)
    public Map<String, Object> getBoardPageList(TBoardPlayTrend trend) throws ParseException {
        TUser user = null;
        try {
            user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                trend.setOrganCode(user.getOrgCode());
            }
        } catch (Exception e) {
            trend.setOrganCode(null);
        }
        // 如果查询日志为空，则默认当月
        if (StringUtils.isEmpty(trend.getBeginDate())) {
            trend.setBeginDate(DateUtil.getCurrentDate("yyyy") + "01");
            trend.setEndDate(DateUtil.getCurrentDate("yyyyMM"));
        }
        Page<TBoardPlayTrend> page = this.tBoardStatisticService.getBoardPageList(getPage(), trend);
        // 处理数据为展板趋势图
        Map map = new HashMap();
        List dateList = new ArrayList();
        List cntList = new ArrayList();

        for (TBoardPlayTrend t : page.getRecords()) {
            dateList.add(t.getPlayDate());
            cntList.add(t.getPlayNumber());
        }
        List<TBoardPlayTrend> list = page.getRecords();
        list.sort(Comparator.comparing(TBoardPlayTrend::getPlayNumber, Comparator.reverseOrder()).thenComparing(TBoardPlayTrend::getPlayDate, Comparator.reverseOrder()));
        if (list.size() >= 10) {
            list = list.subList(0, 10);
        }
        page.setRecords(list);
        map.put("dateList", dateList);
        map.put("cntList", cntList);
        map.put("page", page);
        return getResult(map);
    }


    @ApiImplicitParams(value = {
            @ApiImplicitParam(name = "_index", value = "分页起始偏移量", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "_size", value = "返回条数", paramType = "query", dataType = "Integer"),
            @ApiImplicitParam(name = "frequencyDate", value = "互动统计时间 年：yyyy 月：yyyyMM,默认当月", paramType = "query", dataType = "String")
    })
    @PostMapping("/getInteractionPageList")
//    @RequiresAuthentication  //@RequiresPermissions("t:interaction:statistic:districtPage")
    @ApiOperation(value = "获取互动频次统计信息pc", notes = "获取互动频次统计信息pc")
//    @MethodLog(operModule = OperModule.INTERACTION, operType = OperType.SELECT)
    public Map<String, Object> getInteractionPageList(String frequencyDate) {
        String orgCode = null;
        try {
            TUser user = getcurUser();
            if (user.getRoleList().size() > 0 && !user.getRoleList().contains("1")) {
                orgCode = user.getOrgCode();
            }
        } catch (Exception e) {
            orgCode = null;
        }
        if (StringUtils.isEmpty(frequencyDate)) {
            frequencyDate = DateUtil.getCurrentDate("yyyyMM");
        }

        Page page = this.tBoardStatisticService.getInteractionFrequency(getPage(), frequencyDate, orgCode);
        //
        Map map = new HashMap();
        List organList = new ArrayList<>();
        List cntList = new ArrayList();
        for (Object o : page.getRecords()) {
            Map m = (HashMap) o;
            organList.add(m.get("organName"));
            cntList.add(m.get("frequencyCnt"));
        }
        map.put("organList", organList);
        map.put("cntList", cntList);
        map.put("page", page);
        return getResult(map);
    }
}