njzscloud-svr/src/main/java/com/njzscloud/supervisory/money/pojo/entity/MoneyBillEntity.java

@@ -3,7 +3,6 @@ package com.njzscloud.supervisory.money.pojo.entity;
 import com.baomidou.mybatisplus.annotation.*;
 import com.njzscloud.supervisory.money.contant.BillStatus;
 import com.njzscloud.supervisory.money.contant.InvoiceStatus;
-import com.njzscloud.supervisory.order.contant.OrderCategory;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
@@ -138,9 +137,4 @@ public class MoneyBillEntity {
      */
     private String goodsName;
 
-    /**
-     * 订单类型; 字典代码：order_category
-     */
-    private String orderCategory;
-
 }

njzscloud-svr/src/main/java/com/njzscloud/supervisory/money/pojo/result/MoneyBillResult.java

@@ -8,9 +8,6 @@ import lombok.experimental.Accessors;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 
-/**
- * @author ljw
- */
 @Getter
 @Setter
 @ToString
@@ -26,10 +23,6 @@ public class MoneyBillResult {
     private Long orderId;
     private BigDecimal discountMoney;
     private BigDecimal settleMoney;
-    /**
-     * 订单类型; 字典代码：order_category
-     */
-    private String orderCategory;
     /**
      * 净重
      */

njzscloud-svr/src/main/java/com/njzscloud/supervisory/money/quartz/MoneyBillQuartz.java

@@ -1,5 +1,6 @@
 package com.njzscloud.supervisory.money.quartz;
 
+import com.njzscloud.supervisory.goods.contant.MoneyStrategy;
 import com.njzscloud.supervisory.money.mapper.MoneyBillMapper;
 import com.njzscloud.supervisory.money.pojo.entity.MoneyBillEntity;
 import com.njzscloud.supervisory.money.pojo.result.MoneyBillResult;
@@ -16,9 +17,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
-/**
- * @author ljw
- */
 @Slf4j
 @Component
 @RequiredArgsConstructor
@@ -26,8 +24,8 @@ public class MoneyBillQuartz {
 
     private final MoneyBillMapper moneyBillMapper;
 
-   @Scheduled(cron = "0 0/5 * * * ?")//每1分钟一次
+   // @Scheduled(cron = "0 0/1 * * * ?")//每1分钟一次
-   //  @Scheduled(cron = "0 0 1 27 * ?")//每月27号凌晨1点执行
+    @Scheduled(cron = "0 0 1 27 * ?")//每月27号凌晨1点执行
     public void syncAssetsDiscover() {
         generateMoneyBill();
     }
@@ -35,11 +33,9 @@ public class MoneyBillQuartz {
     public void generateMoneyBill() {
         // 计算上个月的时间范围
         LocalDateTime now = LocalDateTime.now();
-        // 上个月1号0点0分0秒
+        LocalDateTime lastMonthStart = now.minusMonths(1).withDayOfMonth(1).with(LocalTime.MIN); // 上个月1号0点0分0秒
-        LocalDateTime lastMonthStart = now.minusMonths(1).withDayOfMonth(1).with(LocalTime.MIN);
-        // 上个月月末23点59分59秒
         LocalDateTime lastMonthEnd = now.minusMonths(1).withDayOfMonth(now.minusMonths(1).toLocalDate().lengthOfMonth())
-                .with(LocalTime.MAX);
+                .with(LocalTime.MAX); // 上个月月末23点59分59秒
 
         // 创建查询条件
         MoneyBillResult queryCondition = new MoneyBillResult();
@@ -48,46 +44,38 @@ public class MoneyBillQuartz {
 
         // 执行查询
         List<MoneyBillResult> billResults = moneyBillMapper.selectMoneyBillList(queryCondition);
-        // 仅保留订单类型为 PuTong 或 DuanBoRu 的记录
-        billResults = billResults.stream()
-                .filter(r -> "PuTong".equals(r.getOrderCategory()) || "DuanBoRu".equals(r.getOrderCategory()))
-                .collect(Collectors.toList());
 
         log.info("查询到上个月账单数据 {} 条", billResults.size());
 
-        if (!billResults.isEmpty()) {
+        if (billResults.size() > 0) {
-            // 先按transCompanyId、originExpenseItemId、orderCategory三层分组，区分不同订单类型（如 DuanBoRu 与 PuTong）
+            // 先按transCompanyId分组，再按originExpenseItemId分组
-            Map<Long, Map<Long, Map<String, List<MoneyBillResult>>>> groupedResults = billResults.stream()
+            Map<Long, Map<Long, List<MoneyBillResult>>> groupedResults = billResults.stream()
                     .collect(Collectors.groupingBy(
                             MoneyBillResult::getTransCompanyId,
-                            Collectors.groupingBy(MoneyBillResult::getOriginExpenseItemId,
+                            Collectors.groupingBy(MoneyBillResult::getOriginExpenseItemId)
-                                    Collectors.groupingBy(MoneyBillResult::getOrderCategory))
                     ));
 
-            log.info("按transCompanyId、originExpenseItemId和orderCategory三级分组后共 {} 个公司分组", groupedResults.size());
+            log.info("按transCompanyId和originExpenseItemId二级分组后共 {} 个公司分组", groupedResults.size());
 
             // 处理每个公司分组的数据
             List<MoneyBillEntity> entityList = Lists.newArrayList();
-            for (Map.Entry<Long, Map<Long, Map<String, List<MoneyBillResult>>>> companyEntry : groupedResults.entrySet()) {
+            for (Map.Entry<Long, Map<Long, List<MoneyBillResult>>> companyEntry : groupedResults.entrySet()) {
                 Long transCompanyId = companyEntry.getKey();
-                Map<Long, Map<String, List<MoneyBillResult>>> companyGroupResults = companyEntry.getValue();
+                Map<Long, List<MoneyBillResult>> companyGroupResults = companyEntry.getValue();
 
                 log.info("transCompanyId: {}, 该公司包含 {} 个originExpenseItemId分组",
                         transCompanyId, companyGroupResults.size());
 
                 // 处理该公司下的每个originExpenseItemId分组
-                for (Map.Entry<Long, Map<String, List<MoneyBillResult>>> itemEntry : companyGroupResults.entrySet()) {
+                for (Map.Entry<Long, List<MoneyBillResult>> itemEntry : companyGroupResults.entrySet()) {
                     Long originExpenseItemId = itemEntry.getKey();
-                    Map<String, List<MoneyBillResult>> categoryGroupMap = itemEntry.getValue();
+                    List<MoneyBillResult> itemGroupResults = itemEntry.getValue();
 
-                    for (Map.Entry<String, List<MoneyBillResult>> categoryEntry : categoryGroupMap.entrySet()) {
+                    log.info("transCompanyId: {}, originExpenseItemId: {}, 该分组包含 {} 条数据",
-                        String orderCategoryStr = categoryEntry.getKey();
+                            transCompanyId, originExpenseItemId, itemGroupResults.size());
-                        List<MoneyBillResult> itemGroupResults = categoryEntry.getValue();
 
-                        log.info("transCompanyId: {}, originExpenseItemId: {}, orderCategory: {}, 该分组包含 {} 条数据",
+                    // 这里可以根据业务需求处理每个分组的数据
-                                transCompanyId, originExpenseItemId, orderCategoryStr, itemGroupResults.size());
+                    // 例如：计算总金额、创建MoneyBillEntity等
-
-                        // 创建账单实体并计算汇总字段
                     MoneyBillEntity entity = new MoneyBillEntity();
                     entity.setStationId(transCompanyId);
                     entity.setStartTime(lastMonthStart.toLocalDate());
@@ -126,16 +114,9 @@ public class MoneyBillQuartz {
                     MoneyBillResult firstResult = itemGroupResults.get(0);
                     entity.setUserId(firstResult.getUserId());
                     entity.setGoodsName(firstResult.getExpenseItemName());
-
-                        // 如果存在订单类型字符串，则直接设置（实体中为 String 类型）
-                        if (orderCategoryStr != null) {
-                            entity.setOrderCategory(orderCategoryStr);
-                        }
-
                     entityList.add(entity);
-                        log.info("生成账单实体: transCompanyId={}, originExpenseItemId={}, orderCategory={}, 订单数={}, 总质量={}, 车数={}, 优惠金额={}, 账单金额={}",
+                    log.info("生成账单实体: transCompanyId={}, originExpenseItemId={}, 订单数={}, 总质量={}, 车数={}, 优惠金额={}, 账单金额={}",
-                                transCompanyId, originExpenseItemId, orderCategoryStr, orderCount, totalWeight, orderCount, totalDiscountMoney, totalSettleMoney);
+                            transCompanyId, originExpenseItemId, orderCount, totalWeight, orderCount, totalDiscountMoney, totalSettleMoney);
-                    }
                 }
             }
             // 账单入库

njzscloud-svr/src/main/java/com/njzscloud/supervisory/money/service/MoneyBillService.java

@@ -7,6 +7,7 @@ import com.njzscloud.common.mp.support.PageParam;
 import com.njzscloud.common.mp.support.PageResult;
 import com.njzscloud.common.security.util.SecurityUtil;
 import com.njzscloud.supervisory.biz.pojo.result.SearchCompanyResult;
+import com.njzscloud.supervisory.goods.contant.MoneyStrategy;
 import com.njzscloud.supervisory.money.mapper.MoneyBillMapper;
 import com.njzscloud.supervisory.money.pojo.entity.MoneyBillEntity;
 import com.njzscloud.supervisory.money.pojo.result.MoneyBillResult;
@@ -30,7 +31,6 @@ import java.util.Map;
 
 /**
  * 对账单
- * @author ljw
  */
 @Slf4j
 @Service
@@ -107,10 +107,9 @@ public class MoneyBillService extends ServiceImpl<MoneyBillMapper, MoneyBillEnti
         queryCondition.setEndTime(endTime);
         queryCondition.setOriginExpenseItemId(entity.getGoodsId());
         queryCondition.setTransCompanyId(entity.getStationId());
-        queryCondition.setOrderCategory(entity.getOrderCategory());
         // 执行查询
         List<MoneyBillResult> billResults = baseMapper.selectMoneyBillList(queryCondition);
-        if (null != billResults && !billResults.isEmpty()) {
+        if (null != billResults && billResults.size() > 0) {
             // 1. 订单数量：通过orderId分组，条数就是订单数
             long orderCount = billResults.stream().
                     map(MoneyBillResult::getOrderId)

njzscloud-svr/src/main/resources/mapper/money/MoneyBillMapper.xml

@@ -27,8 +27,7 @@
             u.nickname,
             bc.company_name as companyName,
             mb.goods_name as goodsName,
-            mb.car_count,
+            mb.car_count
-            mb.order_category
         FROM money_bill mb
         LEFT JOIN sys_user u ON mb.user_id = u.id
         LEFT JOIN biz_company bc ON mb.station_id = bc.id
@@ -60,9 +59,6 @@
             <if test="entity.goodsName != null and entity.goodsName != ''">
                 AND mb.goods_name LIKE CONCAT('%', #{entity.goodsName}, '%')
             </if>
-            <if test="entity.orderCategory != null">
-                AND mb.order_category = #{entity.orderCategory}
-            </if>
         </where>
         ORDER BY mb.modify_time DESC
     </select>
@@ -70,16 +66,12 @@
     <select id="selectMoneyBillList" resultType="com.njzscloud.supervisory.money.pojo.result.MoneyBillResult">
         SELECT
             oi.trans_company_id,
-            oi.order_category,
             bc.user_id,
             bc.company_name,
             su.nickname,
             oei.expense_item_name,
             oei.money_strategy,
-            CASE
+            oei.origin_expense_item_id,
-            WHEN oei.expense_item_category = 'ChanPin' THEN gi.id
-            ELSE oei.origin_expense_item_id
-            END AS origin_expense_item_id,
             oei.order_id,
             oei.discount_money,
             oei.settle_money,
@@ -87,8 +79,6 @@
         FROM
             order_expense_items oei
                 LEFT JOIN order_info oi ON oi.id = oei.order_id
-                LEFT JOIN order_goods og on og.id = oi.goods_id
-                LEFT JOIN goods_info gi on gi.id = og.origin_goods_id
                 LEFT JOIN biz_company bc ON oi.trans_company_id = bc.id
                 LEFT JOIN sys_user su ON bc.user_id = su.id
                 LEFT JOIN order_car_in_out ocio ON ocio.id = oi.car_in_out_id
@@ -104,10 +94,7 @@
                 AND oi.trans_company_id = #{entity.transCompanyId}
             </if>
             <if test="entity.originExpenseItemId != null">
-                AND (CASE WHEN oei.expense_item_category = 'ChanPin' THEN gi.id ELSE oei.origin_expense_item_id END) = #{entity.originExpenseItemId}
+                AND oei.origin_expense_item_id = #{entity.originExpenseItemId}
-            </if>
-            <if test="entity.orderCategory != null">
-                AND oi.order_category = #{entity.orderCategory}
             </if>
         order by oei.create_time desc
     </select>