同步财务开票信息

dao/src/main/java/com/dayou/mapper/DyoaHistoryMapper.java

@@ -41,4 +41,6 @@ public interface DyoaHistoryMapper {
     List<HisAssetsProduction> queryAssetsProduction(@Param("id") String id);
 
     List<String> getNewFinanceInvoice(@Param("max") Date max);
+
+    Map<String, Object> getInvoiceInfo(@Param("id") String id);
 }

dao/src/main/resources/mapper/DyoaHistoryMapper.xml

@@ -355,4 +355,33 @@
             </if>
         </where>
     </select>
+
+    <select id="getInvoiceInfo" parameterType="java.lang.String" resultType="map">
+        select
+            id,
+            incomeId,
+            orderId,
+            address,
+            bankNO,
+            bankName,
+            companyNO,
+            companyName,
+            invoiceType,
+            project,
+            planMoney,
+            realMoney,
+            taxPoint,
+            planDate,
+            realDate,
+            unit,
+            taxAmount,
+            status,
+            reason,
+            description,
+            invoiceEmp,
+            ticketNo,
+            orderType
+            from dy_finance_invoice
+        where id = #{id}
+    </select>
 </mapper>

domain/src/main/java/com/dayou/entity/FinanceInvoice.java

@@ -27,6 +27,11 @@ public class FinanceInvoice extends BaseEntity {
     private static final long serialVersionUID=1L;
 
     /**
+     * 实收款id
+     */
+    private Long realFundId;
+
+    /**
      * 订单收款id
      */
     private Long orderFundId;
@@ -180,6 +185,13 @@ public class FinanceInvoice extends BaseEntity {
     private BigDecimal taxAmount;
 
     /**
+     * 发票号码
+     */
+    @ImportCell
+    @ExportCell(columnName = "发票号码")
+    private String ticketNo;
+
+    /**
      * 备注
      */
     @ImportCell

domain/src/main/java/com/dayou/enums/MainBusinessEnum.java

@@ -39,7 +39,9 @@ public enum MainBusinessEnum implements CodeMsgEnumInterface<String,String> {
 
     REAL_AMOUNT_CLAIM("REAL_AMOUNT_CLAIM","实收款认领"),
 
-    ASSETS_ORDER("ASSETS_ORDER","资产订单")
+    ASSETS_ORDER("ASSETS_ORDER","资产订单"),
+
+    FINANCE_INVOICE("FINANCE_INVOICE","财务开票")
     ;
 
    MainBusinessEnum(String code, String name) {

service/src/main/java/com/dayou/dyoa/DyoaHistoryServiceImpl.java

@@ -37,6 +37,9 @@ import org.springframework.stereotype.Service;
 import java.io.UnsupportedEncodingException;
 import java.lang.reflect.Field;
 import java.math.BigDecimal;
+import java.sql.Timestamp;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -83,7 +86,7 @@ public class DyoaHistoryServiceImpl implements IDyoaHistoryService{
 
     private static final Map<String,String> ASSETS_PRODUCTION_COLUM = new HashMap<>();
 
-    private static final Map<String,String> FINANCE_CLAIM_COLUM = new HashMap<>();
+    private static final Map<String,String> FINANCE_INVOICE_COLUM = new HashMap<>();
 
 
 
@@ -135,6 +138,10 @@ public class DyoaHistoryServiceImpl implements IDyoaHistoryService{
 
     @Autowired
     private IAssetsProductionService assetsProductionService;
+
+    @Autowired
+    private IFinanceInvoiceService financeInvoiceService;
+
     static {
 //        MAJOR_ORDER_COLUM.put("id","id");
         MAJOR_ORDER_COLUM.put("name","name");
@@ -286,25 +293,27 @@ public class DyoaHistoryServiceImpl implements IDyoaHistoryService{
         ASSETS_PRODUCTION_COLUM.put("type","productionType");
 
         //财务开票字段
-        FINANCE_CLAIM_COLUM.put("companyName","title");
-        FINANCE_CLAIM_COLUM.put("companyNO","taxNo");
-        FINANCE_CLAIM_COLUM.put("bankName","bankName");
-        FINANCE_CLAIM_COLUM.put("bankNO","bankAccount");
-        FINANCE_CLAIM_COLUM.put("address","bankAddress");
-        FINANCE_CLAIM_COLUM.put("invoiceType","type");
-        FINANCE_CLAIM_COLUM.put("project","makeItem");
-        FINANCE_CLAIM_COLUM.put("planMoney","planAmount");
-        FINANCE_CLAIM_COLUM.put("realMoney","realAmount");
-        FINANCE_CLAIM_COLUM.put("taxPoint","taxRate");
-        FINANCE_CLAIM_COLUM.put("planDate","planMakeDate");
-        FINANCE_CLAIM_COLUM.put("realDate","realMakeDate");
-        FINANCE_CLAIM_COLUM.put("unit","itemUnit");
-        FINANCE_CLAIM_COLUM.put("number","itemQuantity");
-        FINANCE_CLAIM_COLUM.put("taxAmount","taxAmount");
-        FINANCE_CLAIM_COLUM.put("status","state");
-        FINANCE_CLAIM_COLUM.put("reason","reason");
-        FINANCE_CLAIM_COLUM.put("description","remark");
-        FINANCE_CLAIM_COLUM.put("invoiceEmp","makerId");
+        FINANCE_INVOICE_COLUM.put("orderId","orderFundId");
+        FINANCE_INVOICE_COLUM.put("incomeId","realFundId");
+        FINANCE_INVOICE_COLUM.put("companyName","title");
+        FINANCE_INVOICE_COLUM.put("companyNO","taxNo");
+        FINANCE_INVOICE_COLUM.put("bankName","bankName");
+        FINANCE_INVOICE_COLUM.put("bankNO","bankAccount");
+        FINANCE_INVOICE_COLUM.put("address","bankAddress");
+        FINANCE_INVOICE_COLUM.put("invoiceType","type");
+        FINANCE_INVOICE_COLUM.put("project","makeItem");
+        FINANCE_INVOICE_COLUM.put("planMoney","planAmount");
+        FINANCE_INVOICE_COLUM.put("realMoney","realAmount");
+        FINANCE_INVOICE_COLUM.put("taxPoint","taxRate");
+        FINANCE_INVOICE_COLUM.put("planDate","planMakeDate");
+        FINANCE_INVOICE_COLUM.put("realDate","realMakeDate");
+        FINANCE_INVOICE_COLUM.put("unit","itemUnit");
+        FINANCE_INVOICE_COLUM.put("taxAmount","taxAmount");
+        FINANCE_INVOICE_COLUM.put("status","state");
+        FINANCE_INVOICE_COLUM.put("reason","reason");
+        FINANCE_INVOICE_COLUM.put("description","remark");
+        FINANCE_INVOICE_COLUM.put("invoiceEmp","makerId");
+        FINANCE_INVOICE_COLUM.put("ticketNo","ticketNo");
     }
 
 
@@ -590,10 +599,70 @@ public class DyoaHistoryServiceImpl implements IDyoaHistoryService{
         Date max = dyoaRecordService.getMaxFinanceInvoiceCreatedTime();
         List<String> newInvoice = dyoaHistoryMapper.getNewFinanceInvoice(max);
         newInvoice.stream().forEach(x-> {
-            //todo
+            fetchFinanceInvoiceDetail(x);
         });
     }
 
+    private void fetchFinanceInvoiceDetail(String id) {
+        try{
+            Map<String,Object> resultMap = dyoaHistoryMapper.getInvoiceInfo(id);
+            FinanceInvoice invoice = new FinanceInvoice();
+            Class<FinanceInvoice> fClass = FinanceInvoice.class;
+            String dyoaId = (String) resultMap.get("id");
+            for (Map.Entry<String, String> entry : FINANCE_INVOICE_COLUM.entrySet()){
+                Object columValue = resultMap.get(entry.getKey());
+                if (columValue!=null){
+                    String mbsColum = entry.getValue();
+                    Field field = fClass.getDeclaredField(mbsColum);
+                    field.setAccessible(true);
+                    switch (mbsColum){
+                        case "orderFundId":
+                            Long orderFundMbsId = findOrderFundId((String) columValue);
+                            if (orderFundMbsId==null){
+                                return;
+                            }
+                            field.set(invoice, orderFundMbsId);
+                            break;
+                        case "realFundId":
+                            Long realFundId = findRealAmountMbsId((String) columValue);
+                            if (realFundId==null){
+                                return;
+                            }
+                            field.set(invoice, realFundId);
+                            break;
+                        case "planAmount":
+                        case "realAmount":
+                        case "taxAmount":
+                        case "taxRate":
+                            field.set(invoice,BigDecimal.valueOf((Double) columValue));
+                            break;
+                        case "planMakeDate":
+                        case "realMakeDate":
+                            Timestamp ts = (Timestamp) columValue;
+                            field.set(invoice, DateUtils.dateToLocalDate(new Date(ts.getTime())));
+                            break;
+                        case "makerId":
+                            field.set(invoice,getMbsUserId((String) columValue));
+                            break;
+                        default:
+                            field.set(invoice,columValue);
+                    }
+
+                }
+            }
+            Date createdDatetime = (Date) resultMap.get("createdDatetime");
+            invoice.setCreated(createdDatetime);
+            financeInvoiceService.save(invoice);
+            //插入同步记录表
+            Long mbsId = invoice.getId();
+            dyoaRecordService.insert(MainBusinessEnum.FINANCE_INVOICE, mbsId, dyoaId,createdDatetime);
+        }catch (NoSuchFieldException e) {
+            throw new RuntimeException(e);
+        } catch (IllegalAccessException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
     @DSTransactional
     @Override
     public void fetchAssetsOrderProduction() {

service/src/main/java/com/dayou/dyoa/IDyoaHistoryService.java

@@ -28,11 +28,11 @@ public interface IDyoaHistoryService {
 
     void fetchDyoaPersonalOrder();
 
-    void fetchRealAmountClaimData();
+    void fetchAssetsOrderProduction();
 
     void fetchRealAmount();
 
-     void fetchAssetsOrderProduction();
+    void fetchRealAmountClaimData();
 
     void fetchFinanceInvoiceRecord();
 }

service/src/main/java/com/dayou/dyoa/task/FetchDyoaDataSchedule.java

@@ -13,25 +13,47 @@ public class FetchDyoaDataSchedule {
     @Autowired
     private IDyoaHistoryService dyoaHistoryService;
 
-
 //    //每天凌晨01:30触发
 //    @Scheduled(cron = "0 30 1 * * ?")
-//    public void syncRealAmountDate(){
-//        dyoaHistoryService.fetchRealAmount();
-//        log.info("同步实收款数据完成");
+//    public void syncDyoaPersonalData(){
+//        dyoaHistoryService.fetchDyoaPersonalOrder();
+//        log.info("同步个贷数据完成");
 //    }
 //
 //    //每天凌晨02:00触发
 //    @Scheduled(cron = "0 0 2 * * ?")
-//    public void syncDyoaMajorDate(){
+//    public void syncDyoaMajorData(){
 //        dyoaHistoryService.fetchDyoaMajorOrderProduction();
 //        log.info("同步大中型数据完成");
 //    }
 //
+
+
 //    //每天凌晨02:30触发
 //    @Scheduled(cron = "0 30 2 * * ?")
-//    public void syncDyoaPersonalDate(){
-//        dyoaHistoryService.fetchDyoaPersonalOrder();
-//        log.info("同步个贷数据完成");
+//    public void syncAssetsData(){
+//        dyoaHistoryService.fetchAssetsOrderProduction();
+//        log.info("同步资产数据完成");
+//    }
+
+//    //每天凌晨03:00触发
+//    @Scheduled(cron = "0 0 3 * * ?")
+//    public void syncRealAmountData(){
+//        dyoaHistoryService.fetchRealAmount();
+//        log.info("同步实收款数据完成");
+//    }
+//
+//    //每天凌晨03:30触发
+//    @Scheduled(cron = "0 30 3 * * ?")
+//    public void syncRealClaimData(){
+//        dyoaHistoryService.fetchRealAmountClaimData();
+//        log.info("同步实收款认领数据完成");
+//    }
+
+//    //每天凌晨04:00触发
+//    @Scheduled(cron = "0 0 4 * * ?")
+//    public void syncFinanceInvoiceData(){
+//        dyoaHistoryService.fetchFinanceInvoiceRecord();
+//        log.info("同步财务开票数据完成");
 //    }
 }

service/src/main/java/com/dayou/service/impl/FinanceInvoiceServiceImpl.java

@@ -2,6 +2,7 @@ package com.dayou.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.dayou.common.BaseEntity;
 import com.dayou.dto.MajorProductionSimpleDTO;
 import com.dayou.entity.FinanceInvoice;
@@ -48,6 +49,7 @@ import com.dayou.enums.BatchTaskTypeEnum;
  * @author wucl
  * @since 2023-12-08
  */
+@DS("mbs")
 @Service
 public class FinanceInvoiceServiceImpl extends ServiceImpl<FinanceInvoiceMapper, FinanceInvoice> implements IFinanceInvoiceService {
 

sql/update_sql.sql

@@ -636,6 +636,16 @@ ALTER TABLE `personal_target` ADD qr_code varchar(255) NULL COMMENT '出入库
   操作人：苟耕铨
  */
 
+/**
+   日期：2024-08-15
+   修改人:吴长林
+   未更新到test-env
+*/
+ALTER TABLE `finance_invoice` ADD ticket_no varchar(100) NULL COMMENT '发票号码';
+ALTER TABLE `finance_invoice` MODIFY COLUMN apply_id bigint(32) NULL COMMENT '申请人id';
+ALTER TABLE major MODIFY COLUMN terminal_clientele_type varchar(100) NULL COMMENT '终端客户类型（企业，个人）';
+ALTER TABLE major MODIFY COLUMN clientele_type varchar(100) NULL COMMENT '客户类型（企业，个人）';
+ALTER TABLE finance_invoice ADD COLUMN real_fund_id bigint NULL COMMENT '实收款id';