java/cashier.git

			@@ -4,6 +4,7 @@
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.ruoyi.common.basic.PageInfo;
			import com.ruoyi.common.constant.Constants;
			import com.ruoyi.common.constant.OrderNumConstants;
			import com.ruoyi.common.core.redis.RedisCache;
			import com.ruoyi.common.exception.ServiceException;
			@@ -13,12 +14,15 @@
			import com.ruoyi.system.dto.OrderMealGeneratorDTO;
			import com.ruoyi.system.dto.OrderSaleGeneratorDTO;
			import com.ruoyi.system.mapper.TDataGeneratorMapper;
			import com.ruoyi.system.query.TDataGeneratorQuery;
			import com.ruoyi.system.query.*;
			import com.ruoyi.system.service.*;
			import com.ruoyi.system.vo.TDataGeneratorVO;
			import com.ruoyi.system.vo.TFoundationConfigVO;
			import com.ruoyi.system.vo.*;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Propagation;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.util.CollectionUtils;

			import java.math.BigDecimal;
			import java.math.RoundingMode;
			@@ -60,15 +64,18 @@
			@Autowired
			private TGoodsTypeService goodsTypeService;
			@Autowired
			private TShopService shopService;
			@Autowired
			private RedisCache redisCache;

			@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
			@Override
			public void mealDataGenerator(OrderMealGeneratorDTO dto) {
			// 存储数据生成数据
			TDataGenerator dataGenerator = new TDataGenerator();
			dataGenerator.setUserId(dto.getUserId());
			dataGenerator.setUserName(dto.getNickName());
			dataGenerator.setShopId(dataGenerator.getShopId());
			dataGenerator.setShopId(dto.getShopId());
			dataGenerator.setStartTime(dto.getStartTime());
			dataGenerator.setEndTime(dto.getEndTime());
			dataGenerator.setMinMoney(dto.getMinMoney());
			@@ -83,11 +90,22 @@
			this.save(dataGenerator);
			long start = System.currentTimeMillis();
			// 查询所有的人数用餐标准
			List<TFoundationConfigVO> foundationConfigs = foundationConfigService.getList();
			List<TFoundationConfigVO> foundationConfigs = foundationConfigService.getList(dto.getShopId());
			if(CollectionUtils.isEmpty(foundationConfigs)){
			throw new ServiceException("请先添加该店铺用餐标准");
			}
			// 查询所有桌子
			List<TBoard> boards = boardService.list();
			List<TBoard> boards = boardService.list(Wrappers.lambdaQuery(TBoard.class)
			.eq(TBoard::getShopId,dto.getShopId()));
			if(CollectionUtils.isEmpty(boards)){
			throw new ServiceException("请先添加该店铺桌台信息");
			}
			// 查询所有菜品
			List<TGoods> goods = goodsService.list();
			List<TGoods> goods = goodsService.list(Wrappers.lambdaQuery(TGoods.class)
			.eq(TGoods::getShopId,dto.getShopId()));
			if(CollectionUtils.isEmpty(goods)){
			throw new ServiceException("请先添加该店铺菜品信息");
			}
			// 循环待生成订单列表，添加到集合中，批量插入
			List<OrderMealGeneratorCountDTO> orderMealGeneratorCountDTOS = dto.getOrderMealGeneratorCountDTOS();
			List<TOrderMeal> orderMeals = new ArrayList<>();
			@@ -101,10 +119,13 @@
			orderMeal.setBoardId(board.getId());
			orderMeal.setMealType(1);
			orderMeal.setMealPerson(random);
			orderMeal.setOrderNum(OrderNumConstants.MEAL + CodeGenerateUtils.generateOrderSn());
			orderMeal.setMealTime(orderMealGeneratorCountDTO.getTime());
			orderMeal.setOrderNum(OrderNumConstants.MEAL + CodeGenerateUtils.generateVolumeSn());
			orderMeal.setStatus(2);
			List<TOrderMealGoods> orderMealGoods = new ArrayList<>();
			// 获取当前桌的菜品
			List<TFoundationConfigVO> foundationConfigVOS = foundationConfigs.stream().filter(e -> e.getMealCount().equals(random)).collect(Collectors.toList());
			// 每种菜品分类需要几个菜的生成
			foundationConfigVOS.forEach(e -> {
			int random1 = getRandom(e.getMinCount(), e.getMaxCount());
			List<TGoods> typeGoods = goods.stream().filter(m -> e.getTypeId().equals(m.getTypeId())).collect(Collectors.toList());
			@@ -125,18 +146,22 @@
			tOrderMealGoods.setGoodsPicture(typeGood.getGoodsPicture());
			tOrderMealGoods.setGoodsSalePrice(typeGood.getSalePrice());
			tOrderMealGoods.setGoodsCount(1);
			tOrderMealGoods.setTypeId(typeGood.getTypeId());
			tOrderMealGoods.setGoodsId(typeGood.getId());
			orderMealGoods.add(tOrderMealGoods);
			}
			}
			});
			orderMeal.setMealOrderGoods(orderMealGoods);
			orderMeal.setOrderMoney(orderMealGoods.stream().map(TOrderMealGoods::getGoodsSalePrice).reduce(BigDecimal::add).get());
			orderMeal.setPayMoney(orderMealGoods.stream().map(TOrderMealGoods::getGoodsSalePrice).reduce(BigDecimal::add).get());
			orderMeals.add(orderMeal);
			if(!CollectionUtils.isEmpty(orderMealGoods)){
			orderMeal.setMealOrderGoods(orderMealGoods);
			orderMeal.setOrderMoney(orderMealGoods.stream().map(good->good.getGoodsSalePrice().multiply(new BigDecimal(good.getGoodsCount()))).reduce(BigDecimal::add).get());
			orderMeal.setPayMoney(orderMealGoods.stream().map(good->good.getGoodsSalePrice().multiply(new BigDecimal(good.getGoodsCount()))).reduce(BigDecimal::add).get());
			orderMeals.add(orderMeal);
			}
			}
			}
			BigDecimal sumMoney = orderMeals.stream().map(TOrderMeal::getPayMoney).reduce(BigDecimal::add).get();
			if(sumMoney.compareTo(dto.getMinMoney()) >= 0 \|\| sumMoney.compareTo(dto.getMaxMoney()) <= 0){
			if(sumMoney.compareTo(dto.getMinMoney()) >= 0 && sumMoney.compareTo(dto.getMaxMoney()) <= 0){
			int weiXin = getRandomPayType(orderMeals.size(), dto.getWeiXinProportion());
			int ali = getRandomPayType(orderMeals.size(), dto.getAliProportion());
			int card = getRandomPayType(orderMeals.size(), dto.getCardProportion());
			@@ -210,11 +235,13 @@
			long end = System.currentTimeMillis() - start;
			System.err.println("相差时间========="+end);
			}else {
			this.removeById(dataGenerator);
			throw new ServiceException("数据生成不在营业额范围内");
			}

			}

			@Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
			@Override
			public void saleDataGenerator(OrderSaleGeneratorDTO dto) {
			// 查询上一次的数据生成时间
			@@ -235,6 +262,7 @@
			dataGenerator.setStartTime(dto.getStartTime());
			dataGenerator.setEndTime(dto.getEndTime());
			dataGenerator.setStatus(2);
			dataGenerator.setShopId(dto.getShopId());
			dataGenerator.setOrderType(2);
			this.save(dataGenerator);

			@@ -245,6 +273,10 @@

			// 添加销售订单数
			List<TOrderSale> orderSales = dto.getOrderSales();
			orderSales.forEach(e->{
			e.setGeneratorId(dataGenerator.getId());
			e.setOrderNum(OrderNumConstants.SALE + CodeGenerateUtils.generateVolumeSn());
			});
			List<TOrderSaleGoods> orderSaleGoods = orderSales.stream().map(TOrderSale::getOrderSaleGoods).flatMap(Collection::stream).collect(Collectors.toList());

			// 生成进货数据
			@@ -273,8 +305,10 @@
			tOrderStockGoods.setGoodsName(k);
			tOrderStockGoods.setGoodsNum(v.get(0).getGoodsNum());
			tOrderStockGoods.setCostPrice(v.get(0).getGoodsCostPrice());
			tOrderStockGoods.setSalePrice(v.get(0).getSalePrice());
			tOrderStockGoods.setSalePrice(v.get(0).getGoodsSalePrice());
			tOrderStockGoods.setThisSalePrice(v.get(0).getThisSalePrice());
			tOrderStockGoods.setGoodsPicture(v.get(0).getGoodsPicture());
			tOrderStockGoods.setGoodsId(v.get(0).getGoodsId());
			tOrderStockGoods.setStockCount(v.stream().mapToInt(TOrderSaleGoods::getGoodsCount).sum());
			orderStockGoods.add(tOrderStockGoods);
			});
			@@ -308,8 +342,10 @@
			tOrderStockGoods.setGoodsName(k);
			tOrderStockGoods.setGoodsNum(v.get(0).getGoodsNum());
			tOrderStockGoods.setCostPrice(v.get(0).getGoodsCostPrice());
			tOrderStockGoods.setSalePrice(v.get(0).getSalePrice());
			tOrderStockGoods.setSalePrice(v.get(0).getGoodsSalePrice());
			tOrderStockGoods.setThisSalePrice(v.get(0).getThisSalePrice());
			tOrderStockGoods.setGoodsPicture(v.get(0).getGoodsPicture());
			tOrderStockGoods.setGoodsId(v.get(0).getGoodsId());
			tOrderStockGoods.setStockCount(v.stream().mapToInt(TOrderSaleGoods::getGoodsCount).sum());
			orderStockGoods.add(tOrderStockGoods);
			});
			@@ -336,8 +372,10 @@
			tOrderStockGoods.setGoodsName(k);
			tOrderStockGoods.setGoodsNum(v.get(0).getGoodsNum());
			tOrderStockGoods.setCostPrice(v.get(0).getGoodsCostPrice());
			tOrderStockGoods.setSalePrice(v.get(0).getSalePrice());
			tOrderStockGoods.setSalePrice(v.get(0).getGoodsSalePrice());
			tOrderStockGoods.setThisSalePrice(v.get(0).getThisSalePrice());
			tOrderStockGoods.setGoodsPicture(v.get(0).getGoodsPicture());
			tOrderStockGoods.setGoodsId(v.get(0).getGoodsId());
			tOrderStockGoods.setStockCount(v.stream().mapToInt(TOrderSaleGoods::getGoodsCount).sum());
			orderStockGoods1.add(tOrderStockGoods);
			});
			@@ -364,8 +402,10 @@
			tOrderStockGoods.setGoodsName(k);
			tOrderStockGoods.setGoodsNum(v.get(0).getGoodsNum());
			tOrderStockGoods.setCostPrice(v.get(0).getGoodsCostPrice());
			tOrderStockGoods.setSalePrice(v.get(0).getSalePrice());
			tOrderStockGoods.setSalePrice(v.get(0).getGoodsSalePrice());
			tOrderStockGoods.setThisSalePrice(v.get(0).getThisSalePrice());
			tOrderStockGoods.setGoodsPicture(v.get(0).getGoodsPicture());
			tOrderStockGoods.setGoodsId(v.get(0).getGoodsId());
			tOrderStockGoods.setStockCount(v.stream().mapToInt(TOrderSaleGoods::getGoodsCount).sum());
			orderStockGoods.add(tOrderStockGoods);
			});
			@@ -391,7 +431,10 @@
			orderSale.getOrderSaleGoods().forEach(e->e.setOrderId(orderSale.getId()));
			}
			List<TGoodsType> list = goodsTypeService.list();
			orderSaleGoods.forEach(e->e.setTypeName(list.stream().filter(m->m.getId().equals(e.getTypeId())).findFirst().get().getTypeName()));
			// orderSaleGoods.forEach(e->e.setTypeName(list.stream().filter(m->m.getId().equals(e.getTypeId())).findFirst().get().getTypeName()));
			orderSaleGoods.forEach(e->{
			e.setId(null);
			});
			orderSaleGoodsService.saveBatch(orderSaleGoods);
			// 添加数据
			stockList.forEach(e->e.setShopId(dataGenerator.getShopId()));
			@@ -408,29 +451,37 @@
			PageInfo<TDataGeneratorVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
			List<TDataGeneratorVO> list = this.baseMapper.pageList(query,pageInfo);
			List<Long> ids = list.stream().map(TDataGeneratorVO::getId).collect(Collectors.toList());
			if(CollectionUtils.isEmpty(ids)){
			return new PageInfo<>();
			}
			if(query.getOrderType() == 1){
			List<TOrderMeal> orderMeals = orderMealService.list(Wrappers.lambdaQuery(TOrderMeal.class)
			.in(TOrderMeal::getGeneratorId, ids));
			List<Long> mealIds = orderMeals.stream().map(TOrderMeal::getId).collect(Collectors.toList());
			List<TOrderMealGoods> mealGoods = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)
			.in(TOrderMealGoods::getOrderId, mealIds));
			for (TDataGeneratorVO tDataGeneratorVO : list) {
			List<Long> collect = orderMeals.stream().filter(e -> e.getGeneratorId().equals(tDataGeneratorVO.getId())).map(TOrderMeal::getId).collect(Collectors.toList());
			BigDecimal money = mealGoods.stream().filter(e -> collect.contains(e.getOrderId()))
			.reduce(BigDecimal.ZERO, (x, y) -> x.add(y.getGoodsSalePrice().multiply(new BigDecimal(y.getGoodsCount()))), BigDecimal::add);
			tDataGeneratorVO.setTotalRevenue(money);
			if(!CollectionUtils.isEmpty(mealIds)){
			List<TOrderMealGoods> mealGoods = orderMealGoodsService.list(Wrappers.lambdaQuery(TOrderMealGoods.class)
			.in(TOrderMealGoods::getOrderId, mealIds));
			for (TDataGeneratorVO tDataGeneratorVO : list) {
			List<Long> collect = orderMeals.stream().filter(e -> e.getGeneratorId().equals(tDataGeneratorVO.getId())).map(TOrderMeal::getId).collect(Collectors.toList());
			BigDecimal money = mealGoods.stream().filter(e -> collect.contains(e.getOrderId()))
			.reduce(BigDecimal.ZERO, (x, y) -> x.add(y.getGoodsSalePrice().multiply(new BigDecimal(y.getGoodsCount()))), BigDecimal::add);
			tDataGeneratorVO.setTotalRevenue(money);
			}
			}
			}else {
			List<TOrderStock> orderStocks = orderStockService.list(Wrappers.lambdaQuery(TOrderStock.class)
			.in(TOrderStock::getGeneratorId, ids));
			List<Long> stockIds = orderStocks.stream().map(TOrderStock::getId).collect(Collectors.toList());
			List<TOrderStockGoods> stockGoods = orderStockGoodsService.list(Wrappers.lambdaQuery(TOrderStockGoods.class)
			.in(TOrderStockGoods::getOrderId, stockIds));
			List<TOrderSale> orderSales = orderSaleService.list(Wrappers.lambdaQuery(TOrderSale.class)
			.in(TOrderSale::getGeneratorId, ids));
			// List<Long> saleIds = orderSales.stream().map(TOrderSale::getId).collect(Collectors.toList());
			// List<TOrderSaleGoods> orderSaleGoods = orderSaleGoodsService.list(Wrappers.lambdaQuery(TOrderSaleGoods.class)
			// .in(TOrderSaleGoods::getOrderId, saleIds));
			for (TDataGeneratorVO tDataGeneratorVO : list) {
			List<Long> collect = orderStocks.stream().filter(e -> e.getGeneratorId().equals(tDataGeneratorVO.getId())).map(TOrderStock::getId).collect(Collectors.toList());
			BigDecimal money = stockGoods.stream().filter(e -> collect.contains(e.getOrderId()))
			.reduce(BigDecimal.ZERO, (x, y) -> x.add(y.getStockPrice().multiply(new BigDecimal(y.getStockCount()))), BigDecimal::add);
			tDataGeneratorVO.setTotalRevenue(money);
			// List<Long> collect = orderSales.stream().filter(e -> e.getGeneratorId().equals(tDataGeneratorVO.getId())).map(TOrderSale::getId).collect(Collectors.toList());
			// BigDecimal money = orderSaleGoods.stream().filter(e -> collect.contains(e.getOrderId()))
			// .reduce(BigDecimal.ZERO, (x, y) -> x.add(y.getGoodsCostPrice().multiply(new BigDecimal(y.getGoodsCount()))), BigDecimal::add);
			if(!CollectionUtils.isEmpty(orderSales)){
			BigDecimal money = orderSales.stream().map(TOrderSale::getPayMoney).reduce(BigDecimal::add).get();
			tDataGeneratorVO.setTotalRevenue(money);
			}
			}
			}
			pageInfo.setRecords(list);
			@@ -444,18 +495,105 @@
			if(dataGenerator.getOrderType() == 1){
			// 删除时间段的数据
			orderMealService.remove(Wrappers.lambdaQuery(TOrderMeal.class)
			.gt(TOrderMeal::getCreateTime, dataGenerator.getStartTime())
			.lt(TOrderMeal::getCreateTime, dataGenerator.getEndTime()));
			.gt(TOrderMeal::getMealTime, dataGenerator.getStartTime())
			.lt(TOrderMeal::getMealTime, dataGenerator.getEndTime()));
			// 修改覆盖类型为已覆盖
			orderMealService.update(Wrappers.lambdaUpdate(TOrderMeal.class).set(TOrderMeal::getIsCover, 1).eq(TOrderMeal::getGeneratorId, id));
			}else {
			// 删除时间段的数据
			orderStockService.remove(Wrappers.lambdaQuery(TOrderStock.class)
			.gt(TOrderStock::getStockTime, dataGenerator.getStartTime())
			.lt(TOrderStock::getStockTime, dataGenerator.getEndTime()));
			// 修改覆盖类型为已覆盖
			orderStockService.update(Wrappers.lambdaUpdate(TOrderStock.class).set(TOrderStock::getIsCover, 1).eq(TOrderStock::getGeneratorId, id));
			}
			dataGenerator.setStatus(3);
			this.updateById(dataGenerator);
			}

			@Override
			public TDataGeneratorMealDetailVO mealGeneratorDataDetail(TDataGeneratorMealQuery query) {
			// 查询餐饮数据生成详情
			TDataGenerator dataGenerator = this.getById(query.getGeneratorId());
			TDataGeneratorMealDetailVO data = new TDataGeneratorMealDetailVO();
			BeanUtils.copyProperties(dataGenerator,data);
			// 查询店铺
			TShop shop = shopService.getById(dataGenerator.getShopId());
			if(Objects.nonNull(shop)){
			data.setShopName(shop.getShopName());
			}
			// 查询订单
			PageInfo<TOrderMealVO> pageInfo = orderMealService.pageListGenerator(query);
			data.setOrderMealList(pageInfo);
			// 统计支付金额
			Map<String, Double> map = orderMealService.getDataGeneratorMealDetail(query);
			BigDecimal money = new BigDecimal(map.get("moneyPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal card = new BigDecimal(map.get("cardPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal weiXin = new BigDecimal(map.get("weiXinPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal ali = new BigDecimal(map.get("aliPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal other = new BigDecimal(map.get("otherPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			data.setMoneyPayAmount(money);
			data.setCardPayAmount(card);
			data.setWeiXinPayAmount(weiXin);
			data.setAliPayAmount(ali);
			data.setOtherPayAmount(other);
			return data;
			}

			@Override
			public TDataGeneratorSaleDetailVO saleGeneratorDataDetail(TDataGeneratorSaleQuery query) {
			// 查询餐饮数据生成详情
			TDataGeneratorSaleDetailVO data = new TDataGeneratorSaleDetailVO();
			// 查询订单
			TOrderSaleQuery orderSaleQuery = new TOrderSaleQuery();
			orderSaleQuery.setTimeType(query.getTimeType());
			orderSaleQuery.setPayType(query.getPayType());
			orderSaleQuery.setOrderNum(query.getOrderNum());
			orderSaleQuery.setGeneratorId(query.getGeneratorId());
			PageInfo<TOrderSaleVO> pageInfo = orderSaleService.pageList(orderSaleQuery);
			data.setOrderMealList(pageInfo);
			// 统计支付金额
			Map<String, Double> map = orderSaleService.getDataGeneratorSaleDetail(query);
			BigDecimal money = new BigDecimal(map.get("moneyPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal card = new BigDecimal(map.get("cardPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal weiXin = new BigDecimal(map.get("weiXinPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal ali = new BigDecimal(map.get("aliPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			BigDecimal other = new BigDecimal(map.get("otherPay")).setScale(2,BigDecimal.ROUND_HALF_UP);
			data.setMoneyPayAmount(money);
			data.setCardPayAmount(card);
			data.setWeiXinPayAmount(weiXin);
			data.setAliPayAmount(ali);
			data.setOtherPayAmount(other);
			return data;
			}

			@Override
			public TDataGeneratorStockDetailVO stockGeneratorDataDetail(TDataGeneratorStockQuery query) {
			// 查询餐饮数据生成详情
			TDataGeneratorStockDetailVO data = new TDataGeneratorStockDetailVO();
			// 查询订单
			TOrderStockQuery orderStockQuery = new TOrderStockQuery();
			orderStockQuery.setGeneratorId(query.getGeneratorId());
			orderStockQuery.setTimeType(query.getTimeType());
			orderStockQuery.setStockNum(query.getOrderNum());
			PageInfo<TOrderStockVO> pageInfo = orderStockService.pageList(orderStockQuery);
			data.setOrderStockVOList(pageInfo);
			// 统计支付金额
			Map<String, Object> map = orderStockService.getDataGeneratorStockDetail(query);
			Integer totalStock = Integer.parseInt(map.get("totalStock").toString());
			BigDecimal stockAmountSum = new BigDecimal(map.get("stockAmountSum").toString());
			data.setTotalStock(totalStock);
			data.setStockAmountSum(stockAmountSum);
			return data;
			}

			@Override
			public List<TOrderSaleVO> mealGeneratorExport(TDataGeneratorMealQuery query) {
			return null;
			}

			private int getRandomPayType(Integer size,BigDecimal count) {
			BigDecimal bigDecimal = new BigDecimal(size).multiply(count.divide(new BigDecimal(100))).setScale(0, RoundingMode.HALF_UP);
			BigDecimal bigDecimal = new BigDecimal(size).multiply(count.divide(new BigDecimal(100))).setScale(0, BigDecimal.ROUND_FLOOR);
			return Integer.parseInt(bigDecimal.toString());
			}

			@@ -476,13 +614,4 @@
			return selected;
			}

			public static void main(String[] args) {
			// System.err.println(new Random().nextInt(1 - 0 + 1) + 0);
			List<Integer> list = new ArrayList<>();
			list.add(1);
			list.add(2);
			list.add(3);
			list.add(4);
			System.err.println(list.subList(1,2));
			}
			}