mjava-lanyun/src/main/java/com/malk/lanyun/controller/TimerController.java

@@ -58,8 +58,6 @@ public class TimerController {
         return McR.success();
     }
 
-
-
     @RequestMapping("testOne")
     McR testOne() {
         ncService.getNcInfo();
@@ -81,6 +79,12 @@ public class TimerController {
         return McR.success();
     }
 
+    @RequestMapping("testFive")
+    McR testFive() {
+        ncService.getSupplierPay();
+        return McR.success();
+    }
+
     /**
      * 采购订单导出excel
      * @param data 前端传入数据

mjava-lanyun/src/main/java/com/malk/lanyun/service/NCService.java

@@ -16,4 +16,7 @@ public interface NCService {
     //部门费用达成明细
     void getNcCollection();
 
+    //供应商付款
+    void getSupplierPay();
+
 }

mjava-lanyun/src/main/java/com/malk/lanyun/service/impl/NCServiceImpl.java

@@ -14,13 +14,11 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Service;
 
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.Statement;
+import java.sql.*;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.TemporalAdjusters;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -298,4 +296,66 @@ public class NCServiceImpl implements NCService {
             }
         }
     }
+
+    @Override
+    public void getSupplierPay() {
+        // 获取当前年
+        int year = today.getYear();
+        LocalDate firstDayOfYear = LocalDate.of(year, 1, 1);
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        String formattedBeginDate = firstDayOfYear.format(formatter);
+        Connection connection = null;
+        Statement statement = null;
+        ResultSet resultSet = null;
+
+        try {
+            // 加载 JDBC 驱动
+            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
+            // 建立连接
+            connection = DriverManager.getConnection(sqlBean.getUrl(), sqlBean.getUsername(), sqlBean.getPassword());
+
+            // 创建 Statement 对象
+            statement = connection.createStatement();
+
+            // 测试sql 执行查询
+            String sql = "EXECUTE GetAccountDetails  @IncrementFlag = 0, @BeginDate ='"+formattedBeginDate+"'  ";
+
+
+            resultSet = statement.executeQuery(sql);
+
+            while (resultSet.next()) {
+                Map hashMap = new HashMap();
+
+                String years =resultSet.getString("yearv");
+                hashMap.put("dateField_lzuyn2l8", UtilDateTime.parse(years,"yyyy"));
+                hashMap.put("textField_m0g4itw4", years);
+                hashMap.put("textField_m0g4itw6",resultSet.getString("SupplierCode"));
+                hashMap.put("textField_m0g4itw5",resultSet.getString("SupplierName"));
+                hashMap.put("numberField_m0g4itw7",resultSet.getBigDecimal("BeginMoney")); //期初金额
+                hashMap.put("numberField_m0g4itw8",resultSet.getBigDecimal("InvoiceMoney")); //本年到票金额
+                hashMap.put("numberField_m0g4itw9",resultSet.getBigDecimal("PayMoney"));//到票已付累计
+                hashMap.put("numberField_m0g4itwb",resultSet.getBigDecimal("SumPayMoney")); //到票未付累计
+                hashMap.put("numberField_m0g4itwa",resultSet.getBigDecimal("EstimationMoney")); //暂估金额
+
+                ydClient.operateData(YDParam.builder()
+                        .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                        .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                        .formUuid("FORM-09CDC75CDC6048379567EC87ED6CE7B6T8PP")
+                        .formDataJson(JSON.toJSONString(hashMap))
+                        .build(), YDConf.FORM_OPERATION.create);
+            }
+        } catch (Exception e) {
+            log.info("数据库连接异常"+e.toString());
+            e.printStackTrace();
+        } finally {
+            // 关闭资源
+            try {
+                if (resultSet != null) resultSet.close();
+                if (statement != null) statement.close();
+                if (connection != null) connection.close();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
 }