caimei365-manager/src/main/java/com/caimei/modules/user/service/NewCmClubService.java

package com.caimei.modules.user.service;

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

import com.caimei.modules.bulkpurchase.dao.CmClubDao;
import com.caimei.modules.consult.entity.type.CmConsulttype;
import com.caimei.modules.oss.service.CmOssArchiveService;
import com.caimei.modules.oss.utils.OSSUtils;
import com.caimei.modules.project.model.ServiceProviderModel;
import com.caimei.modules.user.entity.*;
import com.thinkgem.jeesite.common.utils.StringUtils;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.thinkgem.jeesite.common.persistence.Page;
import com.thinkgem.jeesite.common.service.CrudService;
import com.caimei.modules.user.dao.NewCmClubDao;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.xml.crypto.Data;

/**
 * 用户模块重构--会所管理Service
 *
 * @author zcp
 * @version 2018-05-21
 */
@Service
@Transactional(readOnly = true)
public class NewCmClubService extends CrudService<NewCmClubDao, NewCmClub> {

    @Autowired
    private NewCmClubDao newCmClubDao;
    @Autowired
    private CmClubDao cmClubDao;

    @Autowired
    private CmOssArchiveService cmOssArchiveService;

    public NewCmClub get(String id) {
        return super.get(id);
    }

    public NewCmClub getclubByUserId(Integer userId) {
        return newCmClubDao.getclubByUserId(userId);
    }

    public List<NewCmClub> findList(NewCmClub userClub) {
        return super.findList(userClub);
    }

    public Page<NewCmClub> findPage(Page<NewCmClub> page, NewCmClub userClub) {
        return super.findPage(page, userClub);
    }

    @Transactional(readOnly = false)
    public void save(NewCmClub userClub) {
        super.save(userClub);
    }

    @Transactional(readOnly = false)
    public void insert(NewCmClub userClub) {
        newCmClubDao.insert(userClub);
    }

    @Transactional(readOnly = false)
    public void delete(NewCmClub userClub) {
        super.delete(userClub);
    }

    @Transactional(readOnly = false)
    public void update(NewCmClub userClub) {
        newCmClubDao.update(userClub);
    }

    public NewCmClub findClubById(Integer clubId) {
        List<NewCmClub> newCmClubs = newCmClubDao.findClubById(clubId);
        if (CollectionUtils.isNotEmpty(newCmClubs) && newCmClubs.size() > 0) {
            return newCmClubs.get(0);
        } else {
            return null;
        }
    }

    @Transactional(readOnly = false)
    public void insertBeansHistory(UserBeansHistory beansHistory) {
        newCmClubDao.insertBeansHistory(beansHistory);
    }

    public Page<CmClubRemarks> findRemarksPage(Page<CmClubRemarks> page, CmClubRemarks cmClubRemarks) {
        cmClubRemarks.setPage(page);
        List<CmClubRemarks> remarksList = newCmClubDao.findRemarksList(cmClubRemarks);
        remarksList.forEach(remarks -> {
            if (StringUtils.isNotBlank(remarks.getConsult())) {
                StringBuilder cons = new StringBuilder();
                if(remarks.getConsult().contains(",")){
                    String[] split = remarks.getConsult().split(",");
                    for (String string : split) {
                        cons.append(newCmClubDao.findClassName(string)).append(",");
                    }
                    cons = new StringBuilder(cons.substring(0, cons.length() - 1));
                }else{
                    cons = new StringBuilder(newCmClubDao.findClassName(remarks.getConsult()));
                }
                remarks.setConsultType(cons.toString());
            }
            List<String> imageList = newCmClubDao.getRemarksImageList(remarks.getRemarksId());
            List<RemarksFileVo> fileList = newCmClubDao.getRemarksFileList(remarks.getRemarksId());
            fileList.forEach(f -> f.setFileUrl(OSSUtils.getOssUrl(f.getOssName())));
            remarks.setImageList(imageList);
            remarks.setFileList(fileList);
        });
        page.setList(remarksList);
        return page;
    }

    public void downloadRemarks(String fileName, String ossName, HttpServletRequest request, HttpServletResponse response) throws IOException {
        OSSUtils.downFile(ossName, fileName);
        cmOssArchiveService.download(request, response, fileName);
    }

    public Page<CmClubRemarks> findRegistPage(Page<CmClubRemarks> cmClubRemarksPage, CmClubRemarks cmClubRemarks) {
        cmClubRemarks.setPage(cmClubRemarksPage);
        List<CmClubRemarks> remarksList = newCmClubDao.findRegistList(cmClubRemarks);
        remarksList.forEach(remarks -> {
            if (StringUtils.isNotBlank(remarks.getConsult())) {
                StringBuilder cons = new StringBuilder();
                if(remarks.getConsult().contains(",")){
                    String[] split = remarks.getConsult().split(",");
                    for (String string : split) {
                        cons.append(newCmClubDao.findClassName(string)).append(",");
                    }
                    cons = new StringBuilder(cons.substring(0, cons.length() - 1));
                }else{
                    cons = new StringBuilder(newCmClubDao.findClassName(remarks.getConsult()));
                }
                remarks.setConsultType(cons.toString());
            }
            List<String> imageList = newCmClubDao.getRemarksImageList(remarks.getRemarksId());
            List<RemarksFileVo> fileList = newCmClubDao.getRemarksFileList(remarks.getRemarksId());
            fileList.forEach(f -> f.setFileUrl(OSSUtils.getOssUrl(f.getOssName())));
            remarks.setImageList(imageList);
            remarks.setFileList(fileList);
        });
        if (StringUtils.isNotBlank(cmClubRemarks.getConsult())) {
            remarksList.removeIf(r -> !r.getConsult().contains(cmClubRemarks.getConsult()));
        }
        cmClubRemarksPage.setList(remarksList);
        return cmClubRemarksPage;
    }

    public List<CmConsulttype> findConsults() {
        return newCmClubDao.findConsults();
    }

    public List<CmSaleMan> findTeams() {
        return newCmClubDao.findTeams();
    }

    public List<ServiceProviderModel> findGroup(Integer leaderId) {
        return newCmClubDao.findGroup(leaderId);
    }

    @Transactional(readOnly = false)
    public String upremakasList(CmRemaks cmRemaks){return newCmClubDao.upremakasList(cmRemaks);}

    @Transactional(readOnly = false)
    public void upremarks(CmRemaks cmRemaks){newCmClubDao.upremarks(cmRemaks);}

    @Transactional(readOnly = false)
    public void addRemarks(CmRemaks cmRemaks){
         newCmClubDao.addRemarks(cmRemaks);
     }

    @Transactional(readOnly = false)
     public void deleteRamarks(CmRemaks cmRemaks){newCmClubDao.deleteRamarks(cmRemaks);}

    @Transactional(readOnly = false)
    public List<Integer> ClubsIds(ClubChangeSp clubChangeSp){

          return newCmClubDao.ClubsIds(clubChangeSp);
    }

    @Transactional(readOnly = false)
    public void oldname(Integer oldserviceProviderId,Integer clubID , Integer oldSpID,Integer newSpID){

         newCmClubDao.oldname(oldserviceProviderId, clubID,oldSpID,newSpID);
    }

    @Transactional(readOnly = false)
    public void oldnames(Integer clubID , Integer oldSpID,Integer newSpID){

        newCmClubDao.oldnames(clubID,oldSpID,newSpID);
    }

    @Transactional(readOnly = false)
    public void updateServiceProvider(Integer clubId , Integer oldSpID,Integer newSpID){

        cmClubDao.updateServiceProvider(clubId,oldSpID,newSpID);
    }


    public Page<CmReport> ReportList(Page<CmReport> cmReports ,CmReport cmReport){
       cmReport.setPage(cmReports);
       List<CmReport>list= newCmClubDao.ReportList(cmReport);
       cmReports.setList(list);
       return cmReports;
    }

    public Page<ClubStatistics> statisticsList(Page<ClubStatistics> page, ClubStatistics statistics){
        statistics.setPage(page);
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        Date date = new Date();
        String monthStartTime = "";
        String yearStartTime = "";
        String endTime = "";
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        // 获取近一个月、近一年结束时间
        calendar.add(Calendar.DAY_OF_MONTH, -1);
        Date time = calendar.getTime();
        endTime = dateFormat.format(date);
        statistics.setMonthEndTime(endTime);
        statistics.setYearEndTime(endTime);
        // 近一个月开始时间
        calendar.setTime(time);
        calendar.add(Calendar.MONTH,-1);
        statistics.setMonthStartTime(dateFormat.format(calendar.getTime()));
        // 近一年开始时间
        calendar.setTime(time);
        calendar.add(Calendar.YEAR,-1);
        statistics.setYearStartTime(dateFormat.format(calendar.getTime()));
        List<ClubStatistics> selStatisticsList = new ArrayList<>();
        if (StringUtils.isNotBlank(statistics.getClubDataIntegrity())) {
            ClubStatistics clubData = new ClubStatistics();
            clubData.setMonthStartTime(statistics.getMonthStartTime());
            clubData.setMonthEndTime(statistics.getMonthEndTime());
            clubData.setYearStartTime(statistics.getYearStartTime());
            clubData.setYearEndTime(statistics.getYearEndTime());
            clubData.setClubDataIntegrity(statistics.getClubDataIntegrity());
            selStatisticsList = newCmClubDao.selStatisticsList(clubData);
        } else {
            selStatisticsList = newCmClubDao.selStatisticsList(statistics);
        }
        List<ClubStatistics> statisticsList = setListData(selStatisticsList, statistics);
        if (StringUtils.isNotBlank(statistics.getClubDataIntegrity())) {
            int pageNo = page.getPageNo();
            int pageSize = page.getPageSize();
            int number = 0;
            if (pageNo == 1) {
                number = 0;
            } else {
                number = (pageNo - 1) * pageSize;
            }
            List<ClubStatistics> list = new ArrayList<>();
            for (int i = 0; i <= statisticsList.size()-1 ; i++) {
                if (i >= number && i < number+pageSize) {
                    list.add(statisticsList.get(i));
                }
            }
            page.setCount(statisticsList.size());
            page.setList(list);
        } else {
            page.setList(statisticsList);
        }
        return page;
    }

    public List<easyExcel> exportExcel(ClubStatistics statistics) {
        List<easyExcel> statisticsList = newCmClubDao.findExcelList(statistics);
        List<easyExcel> easyExcels = setExData(statisticsList, statistics);
        return easyExcels;
    }

    public List<easyExcel> setExData(List<easyExcel> selStatisticsList, ClubStatistics statistics) {
        int number = 0;
        String type = "" ;
        Integer item = 0 ;
//        List<ClubStatistics> clubStatisticsList = selStatisticsList;
        List<CmBehaviorRecord> pageLableList = newCmClubDao.selPageLable();

        for (easyExcel clubStatistics : selStatisticsList) {
            // 机构类型
            if (StringUtils.isNotBlank(clubStatistics.getFirstClubType())) {
                type += clubStatistics.getFirstClubType();
            }
            if (StringUtils.isNotBlank(clubStatistics.getClassify())) {
                type += "-" + clubStatistics.getClassify();
            }
            clubStatistics.setClubType(type);
            // 计算资料完整度
            if (StringUtils.isNotBlank(clubStatistics.getName())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getLinkMan())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractMobile())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getLinkManIdentity())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getAddress())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getBusinessLicenseImage())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getUserIdentity())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getSname())) {
                number += 3;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractEmail())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractPhone())) {
                number += 4;
            }
            if (StringUtils.isNotBlank(clubStatistics.getFax())) {
                number += 3;
            }
            if (StringUtils.isNotBlank(clubStatistics.getHeadpic())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getSocialCreditCode())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getInfo())) {
                number += 5;
            }
            clubStatistics.setNumber(number);
            clubStatistics.setClubDataIntegrity(number+"%");

            number=0;
            type = "";
            // 处理最常搜索词
            List<CmBehaviorRecord> collect = pageLableList.stream().filter(data -> data.getUserID().equals(clubStatistics.getUserID())).collect(Collectors.toList());
            if (collect.size() > 0) {
                clubStatistics.setPageLabel(collect.get(0).getPageLabel());
                item = collect.get(0).getNumber();
                for (int i = 0; i < collect.size()-1; i++) {
                    if (item < collect.get(i).getNumber()) {
                        item = collect.get(i).getNumber();
                        clubStatistics.setPageLabel(collect.get(i).getPageLabel());
                    }
                }
            }
        }
        // 资料完整度处理
        if (StringUtils.isNotBlank(statistics.getClubDataIntegrity())) {
            if ("1".equals(statistics.getClubDataIntegrity())) {
                selStatisticsList = selStatisticsList.stream().filter(data -> (data.getNumber() > 20 && data.getNumber() < 70)).collect(Collectors.toList());
            } else {
                selStatisticsList = selStatisticsList.stream().filter(data -> data.getNumber() > 70).collect(Collectors.toList());
            }
        }
        return selStatisticsList;

    }

    public List<ClubStatistics> setListData(List<ClubStatistics> selStatisticsList, ClubStatistics statistics) {
        int number = 0;
        String type = "" ;
        Integer item = 0 ;
//        List<ClubStatistics> clubStatisticsList = selStatisticsList;
        List<CmBehaviorRecord> pageLableList = newCmClubDao.selPageLable();

        for (ClubStatistics clubStatistics : selStatisticsList) {
            // 机构类型
            if (StringUtils.isNotBlank(clubStatistics.getFirstClubType())) {
                type += clubStatistics.getFirstClubType();
            }
            if (StringUtils.isNotBlank(clubStatistics.getClassify())) {
                type += "-" + clubStatistics.getClassify();
            }
            clubStatistics.setClubType(type);
            // 计算资料完整度
            if (StringUtils.isNotBlank(clubStatistics.getName())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getLinkMan())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractMobile())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getLinkManIdentity())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getAddress())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getBusinessLicenseImage())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getUserIdentity())) {
                number += 10;
            }
            if (StringUtils.isNotBlank(clubStatistics.getSname())) {
                number += 3;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractEmail())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getContractPhone())) {
                number += 4;
            }
            if (StringUtils.isNotBlank(clubStatistics.getFax())) {
                number += 3;
            }
            if (StringUtils.isNotBlank(clubStatistics.getHeadpic())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getSocialCreditCode())) {
                number += 5;
            }
            if (StringUtils.isNotBlank(clubStatistics.getInfo())) {
                number += 5;
            }
            clubStatistics.setNumber(number);
            clubStatistics.setClubDataIntegrity(number+"%");

            number=0;
            type = "";
            // 处理最常搜索词
            List<CmBehaviorRecord> collect = pageLableList.stream().filter(data -> data.getUserID().equals(clubStatistics.getUserID())).collect(Collectors.toList());
            if (collect.size() > 0) {
                clubStatistics.setPageLabel(collect.get(0).getPageLabel());
                item = collect.get(0).getNumber();
                for (int i = 0; i < collect.size()-1; i++) {
                    if (item < collect.get(i).getNumber()) {
                        item = collect.get(i).getNumber();
                        clubStatistics.setPageLabel(collect.get(i).getPageLabel());
                    }
                }
            }
        }
        // 资料完整度处理
        if (StringUtils.isNotBlank(statistics.getClubDataIntegrity())) {
            if ("1".equals(statistics.getClubDataIntegrity())) {
                selStatisticsList = selStatisticsList.stream().filter(data -> (data.getNumber() > 20 && data.getNumber() < 70)).collect(Collectors.toList());
            } else {
                selStatisticsList = selStatisticsList.stream().filter(data -> data.getNumber() > 70).collect(Collectors.toList());
            }
        }
        return selStatisticsList;
    }
}