更新数据

src/main/java/cn/quantgroup/customer/repo/TransactionReceiptRecordRepo.java

@@ -36,9 +36,8 @@ public interface TransactionReceiptRecordRepo extends JpaRepository<TransactionR
     @Query(value = "update  transaction_receipt_record set import_status = ?1 where import_status = 0 and  order_no =?2 ", nativeQuery = true)
     int updateTransactionStatusByImportStatus(Integer status,String orderNo);
 
-    @Modifying
-    @Transactional
-    @Query(value = "update  transaction_receipt_record set sign_status =?1 ,export_status =?2 where order_no =?3 and import_status = 1  and export_status = 0 ", nativeQuery = true)
-    int updatePDFStatusByOrderNo(Integer status,Integer exportStatus,String orderNo);
+    @Query(value = "select * from transaction_receipt_record where order_no = ?1 and import_status = 1 ", nativeQuery = true)
+    List<TransactionReceiptRecord> selectRecords(String orderNo);
+
 
 }

src/main/java/cn/quantgroup/customer/service/impl/TransactionReceiptRecordServiceImpl.java

@@ -116,6 +116,8 @@ public class TransactionReceiptRecordServiceImpl implements ITransactionReceiptR
 
             if (StringUtils.isNotEmpty(query.getExportStatus())) {
                 predicates.add(criteriaBuilder.equal(root.get("exportStatus"), query.getExportStatus()));
+            }else{
+                predicates.add(criteriaBuilder.equal(root.get("exportStatus"), 1));
             }
             // 设置查询条件
             criteriaQuery.where(criteriaBuilder.and(predicates.toArray(new Predicate[predicates.size()])));
@@ -375,6 +377,9 @@ public class TransactionReceiptRecordServiceImpl implements ITransactionReceiptR
         log.info("uploadFile | 断开ftp");
         log.info("[TransactionReceiptRecordServiceImpl.kdspOperationUrl  调用kdsp-op 接口end]",System.currentTimeMillis());
         //调用签章接口
+        if(filePathList.isEmpty()){
+            throw new RuntimeException("没有可以签章的数据");
+        }
         log.info("contractUrl /contract/batch/sign 调用签章接口");
         String url = contractUrl + "/contract/batch/sign";
         Map<String, String> header = Maps.newHashMap();
@@ -606,15 +611,27 @@ public class TransactionReceiptRecordServiceImpl implements ITransactionReceiptR
         //pdf签章成功
         if(!successList.isEmpty()){
             for(String orderNo :successList){
-                int i = transactionReceiptRecordRepo.updatePDFStatusByOrderNo(1,1,orderNo);
-                System.out.println(i);
+                if(StringUtils.isNotBlank(orderNo)){
+                    List<TransactionReceiptRecord> list = transactionReceiptRecordRepo.selectRecords(orderNo);
+                    if(!list.isEmpty()){
+                        list.get(0).setExportStatus(1);
+                        list.get(0).setSignStatus(1);
+                        transactionReceiptRecordRepo.save(list.get(0));
+                    }
+                }
             }
         }
         //pdf签章失败
         if(!failList.isEmpty()){
             for(String orderNo :failList){
-                int i = transactionReceiptRecordRepo.updatePDFStatusByOrderNo(2,2,orderNo);
-                //System.out.println(i);
+                if(StringUtils.isNotBlank(orderNo)) {
+                    List<TransactionReceiptRecord> list = transactionReceiptRecordRepo.selectRecords(orderNo);
+                    if(!list.isEmpty()){
+                        list.get(0).setExportStatus(2);
+                        list.get(0).setSignStatus(2);
+                        transactionReceiptRecordRepo.save(list.get(0));
+                    }
+                }
             }
         }
     }