提交批量手动结算车主结算单接口

performance-api/src/main/java/com/clx/performance/param/pc/driver/BatchUpdatePayDriverSettlementParam.java

+package com.clx.performance.param.pc.driver;
+
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+/**
+ * @ClassName BatchUpdatePayDriverSettlementParam
+ * @Description
+ * @Author kavin
+ * @Date 2023/12/4 19:58
+ * @Version 1.0
+ */
+@Getter
+@Setter
+public class BatchUpdatePayDriverSettlementParam {
+
+    private List<Integer> ids;
+}

performance-web/src/main/java/com/clx/performance/controller/pc/carrier/CarrierSettlementDriverController.java

 package com.clx.performance.controller.pc.carrier;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.clx.performance.param.pc.driver.BatchUpdatePayDriverSettlementParam;
 import com.clx.performance.param.pc.driver.PageCarrierSettlementDriverParam;
 import com.clx.performance.service.settle.SettlementDriverService;
 import com.clx.performance.vo.pc.carrier.settle.CarrierPageSettlementDriverVO;
@@ -38,8 +39,8 @@ public class CarrierSettlementDriverController {
 
     @ApiOperation(value = "批量结算车主结算单",notes = "<br>By:刘海泉")
     @PostMapping("/updateBatchPayDriverSettlement")
-    public Result<Object> updateBatchPayDriverSettlement() {
-        //IPage<CarrierPageSettlementDriverVO> page  = settlementDriverService.updateBatchPayDriverSettlement(param);
+    public Result<Object> updateBatchPayDriverSettlement(BatchUpdatePayDriverSettlementParam param) {
+        settlementDriverService.updateBatchPayDriverSettlement(param);
         return Result.ok();
     }
 

performance-web/src/main/java/com/clx/performance/dao/impl/settle/SettlementDriverDetailDaoImpl.java

@@ -72,4 +72,9 @@ public class SettlementDriverDetailDaoImpl extends BaseDaoImpl<SettlementDriverD
     public List<SettlementDriverDetail> listUnPay(LocalDateTime beginTime) {
         return baseMapper.listUnPay(beginTime);
     }
+
+    @Override
+    public List<SettlementDriverDetail> findByDriverSettlementIds(List<Integer> ids) {
+        return baseMapper.findByDriverSettlementIds(ids);
+    }
 }

performance-web/src/main/java/com/clx/performance/dao/settle/SettlementDriverDetailDao.java

@@ -28,4 +28,6 @@ public interface SettlementDriverDetailDao extends BaseDao<SettlementDriverDetai
     IPage<SettlementDriverDetail> pageSettlementDriverDetail(PageCarrierSettlementDriverDetailParam param);
 
     List<SettlementDriverDetail> listUnPay(LocalDateTime beginTime);
+
+    List<SettlementDriverDetail> findByDriverSettlementIds(List<Integer> ids);
 }

performance-web/src/main/java/com/clx/performance/mapper/settle/SettlementDriverDetailMapper.java

@@ -16,4 +16,7 @@ public interface SettlementDriverDetailMapper extends BaseMapper<SettlementDrive
 
     @SelectProvider(type = SettlementDriverDetailSqlProvider.class, method = "listUnPay")
     List<SettlementDriverDetail> listUnPay(@Param("beginTime") LocalDateTime beginTime);
+
+    @SelectProvider(type = SettlementDriverDetailSqlProvider.class, method = "findByDriverSettlementIds")
+    List<SettlementDriverDetail> findByDriverSettlementIds(List<Integer> ids);
 }
\ No newline at end of file

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementDriverServiceImpl.java

@@ -3,9 +3,13 @@ package com.clx.performance.service.impl.settle;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dao.settle.SettlementDriverDao;
+import com.clx.performance.dao.settle.SettlementDriverDetailDao;
 import com.clx.performance.model.settle.SettlementDriver;
+import com.clx.performance.model.settle.SettlementDriverDetail;
+import com.clx.performance.param.pc.driver.BatchUpdatePayDriverSettlementParam;
 import com.clx.performance.param.pc.driver.PageCarrierSettlementDriverParam;
 import com.clx.performance.service.settle.SettlementDriverService;
+import com.clx.performance.service.settle.SettlementMqHandlerService;
 import com.clx.performance.struct.settle.SettlementDriverStruct;
 import com.clx.performance.vo.pc.carrier.settle.CarrierPageSettlementDriverVO;
 import lombok.AllArgsConstructor;
@@ -24,7 +28,10 @@ public class SettlementDriverServiceImpl implements SettlementDriverService {
 
 
     SettlementDriverDao settlementDriverDao;
+    SettlementDriverDetailDao settlementDriverDetailDao;
     SettlementDriverStruct settlementDriverStruct;
+    SettlementMqHandlerService settlementMqHandlerService;
+
 
 
     @Override
@@ -34,4 +41,12 @@ public class SettlementDriverServiceImpl implements SettlementDriverService {
                 page.getRecords());
         return new Page<CarrierPageSettlementDriverVO>().setRecords(list).setTotal(page.getTotal()).setPages(page.getPages());
     }
+
+    @Override
+    public void updateBatchPayDriverSettlement(BatchUpdatePayDriverSettlementParam param) {
+        List<SettlementDriverDetail> list = settlementDriverDetailDao.findByDriverSettlementIds(param.getIds());
+        list.forEach(item->{
+            settlementMqHandlerService.paySettlementDriver(item);
+        });
+    }
 }

performance-web/src/main/java/com/clx/performance/service/settle/SettlementDriverService.java

 package com.clx.performance.service.settle;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.clx.performance.param.pc.driver.BatchUpdatePayDriverSettlementParam;
 import com.clx.performance.param.pc.driver.PageCarrierSettlementDriverParam;
 import com.clx.performance.vo.pc.carrier.settle.CarrierPageSettlementDriverVO;
 
@@ -11,4 +12,6 @@ import com.clx.performance.vo.pc.carrier.settle.CarrierPageSettlementDriverVO;
  */
 public interface SettlementDriverService  {
     IPage<CarrierPageSettlementDriverVO> pageCarrierSettlementDriver(PageCarrierSettlementDriverParam param);
+
+    void updateBatchPayDriverSettlement(BatchUpdatePayDriverSettlementParam param);
 }

performance-web/src/main/java/com/clx/performance/sqlProvider/settle/SettlementDriverDetailSqlProvider.java

@@ -17,4 +17,15 @@ public class SettlementDriverDetailSqlProvider {
         }}.toString();
     }
 
+
+    public String findByDriverSettlementIds() {
+        return new SQL(){{
+            SELECT("a.* ");
+            FROM("settlement_owner_detail a ");
+            LEFT_OUTER_JOIN("settlement_driver b on a.settlement_no = b.settlement_no");
+            WHERE("b.id IN ");
+            ORDER_BY("b.create_time");
+        }}.toString();
+    }
+
 }