java/qijisheng.git

			@@ -1,22 +1,35 @@
			package com.ruoyi.other.service.impl;

			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
			import com.baomidou.mybatisplus.core.metadata.IPage;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.account.api.feignClient.AppUserClient;
			import com.ruoyi.account.api.model.AppUser;
			import com.ruoyi.common.core.utils.StringUtils;
			import com.ruoyi.common.core.web.page.PageInfo;
			import com.ruoyi.common.security.service.TokenService;
			import com.ruoyi.other.api.domain.Shop;
			import com.ruoyi.other.mapper.ShopPointMapper;
			import com.ruoyi.other.api.domain.ShopGiveawayTemporary;
			import com.ruoyi.other.api.domain.ShopPoint;
			import com.ruoyi.other.api.domain.ShopPointCopy;
			import com.ruoyi.other.api.enums.PointChangeType;
			import com.ruoyi.other.mapper.ShopGiveawayTemporaryMapper;
			import com.ruoyi.other.mapper.ShopPointCopyMapper;
			import com.ruoyi.other.mapper.ShopPointMapper;
			import com.ruoyi.other.service.ShopPointService;
			import com.ruoyi.other.service.ShopService;
			import com.ruoyi.other.vo.ShopPointStatistics;
			import com.ruoyi.system.api.domain.SysUser;
			import com.ruoyi.system.api.feignClient.SysUserClient;
			import io.swagger.models.auth.In;
			import org.springframework.stereotype.Service;
			import org.springframework.util.CollectionUtils;

			import javax.annotation.Resource;
			import java.time.LocalDateTime;
			import java.time.format.DateTimeFormatter;
			import java.util.ArrayList;
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.stream.Collectors;

			/**
			@@ -29,62 +42,175 @@
			*/
			@Service
			public class ShopPointServiceImpl extends ServiceImpl<ShopPointMapper, ShopPoint> implements ShopPointService {

			@Resource
			private ShopPointMapper shopPointMapper;
			private TokenService tokenService;
			@Resource
			private SysUserClient sysUserClient;
			@Resource
			private ShopService shopService;
			@Resource
			private ShopGiveawayTemporaryMapper shopGiveawayTemporaryMapper;

			@Resource
			private ShopPointCopyMapper shopPointCopyMapper;





			@Override
			public ShopPointStatistics statistics(IPage<ShopPoint> page, ShopPoint shopPoint) {
			Long userid = tokenService.getLoginUser().getUserid();
			SysUser sysUser = sysUserClient.getSysUser(userid).getData();
			if (sysUser.getRoleType()==1){

			String shopName = shopPoint.getShopName();
			String phone = shopPoint.getPhone();
			String shopLeaderName = shopPoint.getShopLeaderName();
			List<Integer> shopIds = shopService.listObjs(new LambdaQueryWrapper<Shop>()
			.select(Shop::getId)
			.like(StringUtils.isNotEmpty(shopName), Shop::getName, shopName)
			.like(StringUtils.isNotEmpty(phone), Shop::getPhone, phone)
			.like(StringUtils.isNotEmpty(shopLeaderName), Shop::getShopManager, shopLeaderName))
			.stream().map(o -> (Integer) o).collect(Collectors.toList());
			if (CollectionUtils.isEmpty(shopIds)) {
			return new ShopPointStatistics();
			}
			ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
			shopPointStatistics.setTotalPoint(0);
			shopPointStatistics.setSubShopCommissionPoint(0);
			shopPointStatistics.setShopPoint(0);
			shopPointStatistics.setShopCommissionPoint(0);

			IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
			shopPointIPage.getRecords().forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
			shopPointStatistics.setShopPointIPage(shopPointIPage);

			IPage<ShopPoint> page1 = new PageInfo<>(0, 100000);
			IPage<ShopPoint> shopPointIPage1 = this.baseMapper.queryShpointPage(page1, shopPoint);
			List<ShopPoint> shopPointList = shopPointIPage1.getRecords();
			shopPointList.forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
			Map<Integer, List<ShopPoint>> shopPointByTypeMap = shopPointList.stream().collect(Collectors.groupingBy(ShopPoint::getType));
			shopPointByTypeMap.forEach((type, shopPoints) -> {
			shopPoints.stream().map(ShopPoint::getVariablePoint).reduce(Integer::sum).ifPresent(sum -> {
			switch (type) {
			case 1:
			shopPointStatistics.setShopPoint(sum);
			break;
			case 2:
			shopPointStatistics.setShopCommissionPoint(sum);
			break;
			case 3:
			shopPointStatistics.setSubShopCommissionPoint(sum);
			break;
			default:
			break;
			}
			});
			});

			shopPoint.setShopIds(shopIds);
			LocalDateTime startTime = shopPoint.getStartTime();
			LocalDateTime endTime = shopPoint.getEndTime();
			if(null != startTime){
			List<ShopPoint> list = this.list(new LambdaUpdateWrapper<ShopPoint>()
			.eq(ShopPoint::getShopId, sysUser.getObjectId())
			.last(" and create_time between '" + startTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "' and '" + endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "'"));
			List<String> date = new ArrayList<>();
			List<Map<String, Integer>> data = new ArrayList<>();
			String format = "MM.dd";
			while (true){
			if(startTime.isAfter(endTime)){
			break;
			}
			date.add(startTime.format(DateTimeFormatter.ofPattern(format)));
			Map<String, Integer> map = new HashMap<>();
			//返佣积分
			LocalDateTime finalStartTime = startTime;
			List<ShopPoint> collect = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 2).collect(Collectors.toList());
			map.put("fyjf", collect.stream().mapToInt(ShopPoint::getVariablePoint).sum());


			ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
			List<ShopPoint> latestChangeByType = shopPointMapper.findLatestChangeByType(shopPoint);
			for (ShopPoint sp : latestChangeByType) {
			switch (sp.getType()) {
			case 1:
			shopPointStatistics.setShopPoint(sp.getVariablePoint());
			break;
			case 2:
			shopPointStatistics.setShopCommissionPoint(sp.getVariablePoint());
			break;
			case 3:
			shopPointStatistics.setSubShopCommissionPoint(sp.getVariablePoint());
			break;
			//服务积分
			List<ShopPoint> collect1 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 1).collect(Collectors.toList());
			map.put("fwjf", collect1.stream().mapToInt(ShopPoint::getVariablePoint).sum());
			//绑定下级门店返佣积分
			List<ShopPoint> collect2 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 3).collect(Collectors.toList());
			map.put("xjmdfyjf", collect2.stream().mapToInt(ShopPoint::getVariablePoint).sum());
			data.add(map);
			startTime = startTime.plusDays(1);
			}
			Map<String, Object> brokenLine = new HashMap<>();
			brokenLine.put("date", date);
			brokenLine.put("data", data);
			shopPointStatistics.setBrokenLine(brokenLine);
			}
			}
			shopPointStatistics.setTotalPoint(shopPointStatistics.getShopPoint() + shopPointStatistics.getShopCommissionPoint() + shopPointStatistics.getSubShopCommissionPoint());

			Integer shopPoint1 = shopPointStatistics.getShopPoint();
			Integer shopCommissionPoint = shopPointStatistics.getShopCommissionPoint();
			Integer subShopCommissionPoint = shopPointStatistics.getSubShopCommissionPoint();
			shopPointStatistics.setTotalPoint(shopPoint1 + shopCommissionPoint + subShopCommissionPoint);
			return shopPointStatistics;
			}else{
			Shop shop = shopService.getById(sysUser.getObjectId());
			List<ShopGiveawayTemporary> list1 = shopGiveawayTemporaryMapper.selectList(new LambdaQueryWrapper<ShopGiveawayTemporary>().eq(ShopGiveawayTemporary::getShopId, shop.getId()));
			int serverPointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getServerPoint).sum();
			int sharePointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getSharePoint).sum();
			int lowerLevelSharePointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getLowerLevelSharePoint).sum();
			shopPoint.setShopId(shop.getId());
			Integer serverPoint = shop.getServerPoint() + serverPointCopy;
			Integer sharePoint = shop.getSharePoint() + sharePointCopy;
			Integer lowerLevelSharePoint = shop.getLowerLevelSharePoint() + lowerLevelSharePointCopy;
			ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
			shopPointStatistics.setTotalPoint(serverPoint + sharePoint + lowerLevelSharePoint);
			shopPointStatistics.setShopPoint(serverPoint);
			shopPointStatistics.setShopCommissionPoint(sharePoint);
			shopPointStatistics.setSubShopCommissionPoint(lowerLevelSharePoint);

			IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
			shopPointIPage.getRecords().forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
			shopPointStatistics.setShopPointIPage(shopPointIPage);

			boolean condition = shopPoint.getStartTime() != null && shopPoint.getEndTime() != null;
			IPage<ShopPoint> shopPointIPage = page(page, new LambdaQueryWrapper<ShopPoint>()
			.in(!CollectionUtils.isEmpty(shopPoint.getShopIds()), ShopPoint::getShopId, shopPoint.getShopIds())
			.eq(shopPoint.getType() != null, ShopPoint::getType, shopPoint.getType())
			.between(condition, ShopPoint::getCreateTime, shopPoint.getStartTime(), shopPoint.getEndTime())
			.orderByDesc(ShopPoint::getCreateTime));
			List<ShopPoint> shopPoints = shopPointIPage.getRecords();
			for (ShopPoint sp : shopPoints) {
			Shop shop = shopService.getById(sp.getShopId());
			sp.setShopName(shop.getName());
			sp.setShopLeaderName(shop.getShopManager());
			sp.setPhone(shop.getPhone());
			LocalDateTime startTime = shopPoint.getStartTime();
			LocalDateTime endTime = shopPoint.getEndTime();
			if(null != startTime){
			List<ShopPoint> list = this.list(new LambdaUpdateWrapper<ShopPoint>()
			.eq(ShopPoint::getShopId, sysUser.getObjectId())
			.last(" and create_time between '" + startTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "' and '" + endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "'"));
			List<String> date = new ArrayList<>();
			List<Map<String, Integer>> data = new ArrayList<>();
			String format = "MM.dd";
			while (true){
			if(startTime.isAfter(endTime)){
			break;
			}
			date.add(startTime.format(DateTimeFormatter.ofPattern(format)));
			Map<String, Integer> map = new HashMap<>();
			//返佣积分
			LocalDateTime finalStartTime = startTime;
			List<ShopPoint> collect = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 2).collect(Collectors.toList());
			map.put("fyjf", collect.stream().mapToInt(ShopPoint::getVariablePoint).sum());

			//服务积分
			List<ShopPoint> collect1 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 1).collect(Collectors.toList());
			map.put("fwjf", collect1.stream().mapToInt(ShopPoint::getVariablePoint).sum());
			//绑定下级门店返佣积分
			List<ShopPoint> collect2 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
			.equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 3).collect(Collectors.toList());
			map.put("xjmdfyjf", collect2.stream().mapToInt(ShopPoint::getVariablePoint).sum());
			data.add(map);
			startTime = startTime.plusDays(1);
			}
			Map<String, Object> brokenLine = new HashMap<>();
			brokenLine.put("date", date);
			brokenLine.put("data", data);
			shopPointStatistics.setBrokenLine(brokenLine);
			}
			return shopPointStatistics;
			}
			shopPointStatistics.setShopPointIPage(shopPointIPage);
			return shopPointStatistics;
			}


			/**
			* 获取门店积分流水
			* @param page
			* @param shopPoint
			* @return
			*/
			@Override
			public IPage<ShopPoint> getShopPointPage(IPage<ShopPoint> page, ShopPoint shopPoint) {
			return this.baseMapper.queryShpointPage(page, shopPoint);
			}
			}