定时任务修改

fhKeeper/formulahousekeeper/collectdata/src/main/java/com/management/collectdata/controller/DataCollectController.java

@@ -71,6 +71,7 @@ public class DataCollectController {
     public String insertCisData(@RequestBody List<TisTimeVO> tisList) {
 //        List<TisTimeVO> tisTimeVOS = JSONArray.parseArray(jsonarray, TisTimeVO.class);
         if(!CollectionUtils.isEmpty(tisList)){
+            int count = 0;
             for (TisTimeVO tisTimeVO : tisList) {
                 String sqlQuery = "select top 1 iRealCOID from ca_batchmap where cMOCode = ? and iMOSubSN = ? ";
                 try (Connection connection = sqlServerDataSource.getConnection()) {
@@ -80,22 +81,24 @@ public class DataCollectController {
                     ResultSet queryRs = queryStmt.executeQuery();
                     if (queryRs.next()) {
                         tisTimeVO.setCoId(queryRs.getString("iRealCOID"));
-                    }
-                    String sqlInsert = "insert into CA_DayTiS(cPPID,iRealWkt,dDate) values(?,?,?)";
-                    PreparedStatement insertStmt = connection.prepareStatement(sqlInsert);
-                    insertStmt.setString(1,tisTimeVO.getCoId());
-                    insertStmt.setBigDecimal(2,tisTimeVO.getWorkTime());
-                    insertStmt.setString(3,tisTimeVO.getDateStr());
-                    int i = insertStmt.executeUpdate();
-                    if(i>0){
+                        String sqlInsert = "insert into CA_DayTiS(cPPID,iRealWkt,dDate) values(?,?,?)";
+                        PreparedStatement insertStmt = connection.prepareStatement(sqlInsert);
+                        insertStmt.setString(1,tisTimeVO.getCoId());
+                        insertStmt.setBigDecimal(2,tisTimeVO.getWorkTime());
+                        insertStmt.setString(3,tisTimeVO.getDateStr());
+                        int i = insertStmt.executeUpdate();
+                        if(i>0){
+                            count++;
 //                        System.out.println("执行成功");
-                    }else{
-                        System.out.println(tisTimeVO.getCoId()+"执行失败");
+                        }else{
+                            System.out.println(tisTimeVO.getCoId()+"执行失败");
+                        }
                     }
                 } catch (SQLException e) {
                     System.err.println("数据库操作错误: " + e.getMessage());
                 }
             }
+            System.out.println("本批次总数量:"+tisList.size()+",成功插入条数:"+count);
 
         }
         return "ok";