开票通知

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

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.dao.settle.SettlementOwnerDetailDao;
+import com.clx.performance.enums.settle.SettlementOwnerEnum;
 import com.clx.performance.mapper.settle.SettlementOwnerDetailMapper;
 import com.clx.performance.model.settle.SettlementOwnerDetail;
 import com.clx.performance.param.pc.owner.PageCarrierSettlementOwnerDetailParam;
@@ -74,6 +75,13 @@ public class SettlementOwnerDetailDaoImpl extends BaseDaoImpl<SettlementOwnerDet
         return list(lQrWrapper().eq(SettlementOwnerDetail::getSettlementNo, settlementNo));
     }
 
+    @Override
+    public List<SettlementOwnerDetail> getBySettlementNoAndInvoiceType(String settlementNo, Integer invoiceType) {
+        return list(lQrWrapper().eq(SettlementOwnerDetail::getSettlementNo, settlementNo)
+                .eq(SettlementOwnerDetail::getInvoiceType, invoiceType)
+        );
+    }
+
 
     @Override
     public IPage<SettlementOwnerDetail> pageSettlementOwnerDetail(
@@ -100,6 +108,14 @@ public class SettlementOwnerDetailDaoImpl extends BaseDaoImpl<SettlementOwnerDet
         return baseMapper.getInvoiceType(orderNo);
     }
 
+    @Override
+    public void updateSettlementByChildNoList(List<String> childNoList) {
+         update(lUdWrapper()
+                .in(SettlementOwnerDetail::getChildNo, childNoList)
+                .set(SettlementOwnerDetail::getInvoiceStatus, SettlementOwnerEnum.InvoiceStatus.INVOICED.getCode())
+        );
+    }
+
     @Override
     public IPage<SettlementOwnerDetail> pageOwnerSettlementOrderDetailList(PageOwnerSettlementOwnerDetailParam param) {
         LambdaQueryWrapper<SettlementOwnerDetail> query = new LambdaQueryWrapper<>();

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

@@ -30,9 +30,14 @@ public interface SettlementOwnerDetailDao extends BaseDao<SettlementOwnerDetailM
     Optional<SettlementOwnerDetail> getByChildNo(String childNo);
     List<SettlementOwnerDetail> getBySettlementNo(String settlementNo);
 
+    List<SettlementOwnerDetail> getBySettlementNoAndInvoiceType(String settlementNo, Integer invoiceType);
+
+
     IPage<SettlementOwnerDetail> pageOwnerSettlementOrderDetailList(PageOwnerSettlementOwnerDetailParam param);
 
     IPage<SettlementOwnerDetail> pageSettlementOwnerDetail(PageCarrierSettlementOwnerDetailParam param);
 
     Integer getInvoiceType(String orderNo);
+
+    void updateSettlementByChildNoList(List<String> childNoList);
 }

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

@@ -11,10 +11,7 @@ import com.clx.performance.dao.settle.SettlementPlatformAccountDao;
 import com.clx.performance.dto.InvoicingStatusNotifyDTO;
 import com.clx.performance.enums.OrderChildLogEnum;
 import com.clx.performance.enums.PerformanceResultEnum;
-import com.clx.performance.enums.settle.SettlementLogEnum;
-import com.clx.performance.enums.settle.SettlementOwnerDetailEnum;
-import com.clx.performance.enums.settle.SettlementOwnerEnum;
-import com.clx.performance.enums.settle.SettlementWayEnum;
+import com.clx.performance.enums.settle.*;
 import com.clx.performance.feign.TransportFeignService;
 import com.clx.performance.model.settle.SettlementLog;
 import com.clx.performance.model.settle.SettlementOwner;
@@ -489,7 +486,8 @@ public class SettlementOwnerServiceImpl  implements SettlementOwnerService {
                 param.setOwnerMobile(mobile);
                 List<OwnerSettlementSyncParam.SettlementItem> settlementList = new LinkedList<>();
                 param.setSettlementList(settlementList);
-                List<SettlementOwnerDetail> settlementOwnerDetailList = settlementOwnerDetailDao.getBySettlementNo(settlementNo);
+                List<SettlementOwnerDetail> settlementOwnerDetailList = settlementOwnerDetailDao.getBySettlementNoAndInvoiceType(settlementNo,
+                        SettlementDriverEnum.InvoiceType.ONLINE.getCode());
                 for (SettlementOwnerDetail settlementOwnerDetail : settlementOwnerDetailList) {
                     String childNo = settlementOwnerDetail.getChildNo();
                     OwnerSettlementSyncParam.SettlementItem  item = new OwnerSettlementSyncParam.SettlementItem();
@@ -521,6 +519,7 @@ public class SettlementOwnerServiceImpl  implements SettlementOwnerService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void invoicingStatusNotify(InvoicingStatusNotifyDTO invoicingStatusNotifyDTO) {
         List<String> childNoList = invoicingStatusNotifyDTO.getChildNoList();
         if (CollectionUtil.isEmpty(childNoList)) {
@@ -528,10 +527,12 @@ public class SettlementOwnerServiceImpl  implements SettlementOwnerService {
         }
         SettlementOwnerDetail settlementOwnerDetail = settlementOwnerDetailDao.getByChildNo(childNoList.get(0)).get();
         String settlementNo = settlementOwnerDetail.getSettlementNo();
-        List<SettlementOwnerDetail> list = settlementOwnerDetailDao.getBySettlementNo(settlementNo);
-        for (SettlementOwnerDetail ownerDetail : list) {
+        List<SettlementOwnerDetail> list = settlementOwnerDetailDao.getBySettlementNoAndInvoiceType(settlementNo,
+            SettlementOwnerEnum.InvoiceType.ONLINE.getCode()
+        );
+        settlementOwnerDetailDao.updateSettlementByChildNoList(childNoList);
+
 
-        }
     }