基于java和JavaScript开发的连锁超市管理系统前端和后端系统源码+sql数据库(毕业设计).zip

package com.cqupt.th.supermarket.service.impl; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.cqupt.th.supermarket.constants.EmployeeConstant; import com.cqupt.th.supermarket.constants.IncomeExpenseConstant; import com.cqupt.th.supermarket.constants.PurchaseOrderConstant; import com.cqupt.th.supermarket.entity.*; import com.cqupt.th.supermarket.mapper.*; import com.cqupt.th.supermarket.service.RegionService; import com.cqupt.th.supermarket.service.StatisticsService; import com.cqupt.th.supermarket.service.WarehouseService; import com.cqupt.th.supermarket.utils.CommonResult; import com.cqupt.th.supermarket.vo.InventoryVo; import com.cqupt.th.supermarket.vo.PurchaseOrderVo; import com.cqupt.th.supermarket.vo.PurchaseVo; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import javax.annotation.Resource; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; /** * @author th * @date 2023/4/16 16:57 */ @Service("statisticsService") public class StatisticsServiceImpl implements StatisticsService { @Resource private PurchaseMapper purchaseMapper; @Resource private PurchaseOrderMapper purchaseOrderMapper; @Resource private ProductMapper productMapper; @Resource private SupplierMapper supplierMapper; @Resource private StoreMapper storeMapper; @Autowired @Qualifier("warehouseService") private WarehouseService warehouseService; @Autowired @Qualifier("regionService") private RegionService regionService; @Resource private MemberMapper memberMapper; @Resource private IncomeExpenseMapper incomeExpenseMapper; @Resource private OutstockMapper outstockMapper; @Resource private EmployeeMapper employeeMapper; @Resource private UserBrowsingHistoryMapper userBrowsingHistoryMapper; @Resource private InventoryMapper inventoryMapper; @Override public CommonResult getPriceComparison(Product product) { List<PurchaseOrder> purchaseOrders = purchaseOrderMapper.selectList(new QueryWrapper<PurchaseOrder>().ne("is_pay", PurchaseOrderConstant.IS_CANCEL.getCode())); List<Integer> ids = purchaseOrders.stream().map(PurchaseOrder::getPurchaseId).collect(Collectors.toList()); if (ids == null || ids.size() == 0) { return CommonResult.ok(); } QueryWrapper<Purchase> purchaseQueryWrapper = new QueryWrapper<Purchase>().in("id", ids).orderByDesc("gmt_modified"); if (product != null) { if (product.getId() != null) { purchaseQueryWrapper.eq("product_id", product.getId()); } } List<Purchase> purchases = purchaseMapper.selectList(purchaseQueryWrapper); List<Integer> productIds = purchases.stream().map(Purchase::getProductId).distinct().collect(Collectors.toList()); ArrayList<JSONObject> jsonObjects = new ArrayList<>(); for (Integer productId : productIds) { Product product1 = productMapper.selectById(productId); JSONObject oneMeun = new JSONObject(); oneMeun.put("name", product1.getName()); oneMeun.put("type", "line"); List<BigDecimal> data = new ArrayList<>(); for (Purchase purchase : purchases) { if (purchase.getProductId().equals(productId)) { data.add(purchase.getPurchasePrice()); } } oneMeun.put("data", data); jsonObjects.add(oneMeun); } return CommonResult.ok().data("items", jsonObjects); } @Override public CommonResult getSupplierPriceChange(Product product) { List<PurchaseOrder> purchaseOrders = purchaseOrderMapper.selectList(new QueryWrapper<PurchaseOrder>().ne("is_pay", PurchaseOrderConstant.IS_CANCEL.getCode())); List<Integer> ids = purchaseOrders.stream().map(PurchaseOrder::getPurchaseId).collect(Collectors.toList()); if (ids == null || ids.size() == 0) { return CommonResult.ok(); } QueryWrapper<Purchase> purchaseQueryWrapper = new QueryWrapper<Purchase>().in("id", ids).orderByDesc("gmt_modified"); if (product != null) { if (product.getId() != null) { purchaseQueryWrapper.eq("product_id", product.getId()); } else { //查询数据库第一条数据productMapper purchaseQueryWrapper.eq("product_id", productMapper.selectOne(new QueryWrapper<Product>().last("limit 1"))); } } List<Purchase> purchases = purchaseMapper.selectList(purchaseQueryWrapper); List<Integer> supplierIds = purchases.stream().map(Purchase::getSupplierId).distinct().collect(Collectors.toList()); JSONObject jsonObject = new JSONObject(); jsonObject.put("name", "进价"); jsonObject.put("type", "bar"); jsonObject.put("barWidth", "60%"); List<BigDecimal> data = new ArrayList<>(); ArrayList<String> list = new ArrayList<>(); for (Integer supplierId : supplierIds) { list.add(supplierMapper.selectById(supplierId).getName()); for (Purchase purchase : purchases) { if (purchase.getSupplierId().equals(supplierId)) { data.add(purchase.getPurchasePrice()); break; } } } jsonObject.put("data", data); jsonObject.put("list", list); return CommonResult.ok().data("items", jsonObject); } @Override public CommonResult getMemberRegister() { //统计当月会员注册数量 Long aLong = memberMapper.selectCount(new QueryWrapper<Member>().last("where DATE_FORMAT(gmt_create,'%Y%m') = DATE_FORMAT(CURDATE(),'%Y%m')")); return CommonResult.ok().data("items", aLong); } @Override public CommonResult getOrders() { //统计当月订单数量,排除未支付订单is_pay=3 Long aLong = purchaseOrderMapper.selectCount(new QueryWrapper<PurchaseOrder>().last("where is_pay <> 3 and DATE_FORMAT(gmt_create,'%Y%m') = DATE_FORMAT(CURDATE(),'%Y%m')")); return CommonResult.ok().data("items", aLong); } @Override public CommonResult getIncome() { //查找上月的收入 IncomeExpense incomeExpense = incomeExpenseMapper.selectOne(new QueryWrapper<IncomeExpense>().last("where type = 1 and DATE_FORMAT(gmt_create,'%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH),'%Y%m')")); return CommonResult.ok().data("items", incomeExpense == null ? null : incomeExpense.getAmount()); } @Override public CommonResult getExpendse() { //查找上月的支出 IncomeExpense incomeExpense = incomeExpenseMapper.selectOne(new QueryWrapper<IncomeExpense>().last("where type = 0 and DATE_FORMAT(gmt_create,'%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH),'%Y%m')")); return CommonResult.ok().data("items", incomeExpense == null ? null : incomeExpense.getAmount()); } @Override public CommonResult getIncomeAndExpendse() { //查找每个月的收入和支出 List<IncomeExpense> incomeExpenses = incomeExpenseMapper.selectList(new QueryWrapper<IncomeExpense>().orderByAsc("gmt_create")); ArrayList<BigDecimal> inCome = new ArrayList<>(); ArrayList<BigDecimal> expendse = new ArrayList<>(); incomeExpenses.stream().forEach(incomeExpense -> { if (incomeExpense.getType().equals(IncomeExpenseConstant.INCOME.getCode())) { inCome.add(incomeExpense.getAmount()); } else { expendse.add(incomeExpense.getAmount()); }