Browse Source

刷新数据

wangzhe 2 years ago
parent
commit
4ee5115923

+ 7 - 3
mybusiness/src/main/java/com/sooka/system/service/impl/TUInterfaceinfoServiceImpl.java

@@ -195,6 +195,8 @@ public class TUInterfaceinfoServiceImpl implements ITUInterfaceinfoService
      */
      */
     @Override
     @Override
     public void refreshData(){
     public void refreshData(){
+        //(164-57) t_guiji_gas_zenner_gas_purchase_center_infor - 归集-市燃气(真兰收费系统)-中心计费购气信息 - 467184 ms total:[12746163]
+        //t_guiji_gas_zenner_meter_reading_infor
         List<TUInterfaceinfo> tuInterfaceinfoList = tUInterfaceinfoMapper.selectTUInterfaceinfoList(new TUInterfaceinfo());
         List<TUInterfaceinfo> tuInterfaceinfoList = tUInterfaceinfoMapper.selectTUInterfaceinfoList(new TUInterfaceinfo());
         for (int i = 0; i < tuInterfaceinfoList.size(); i++) {
         for (int i = 0; i < tuInterfaceinfoList.size(); i++) {
             TUInterfaceinfo tuInterfaceinfo = tuInterfaceinfoList.get(i);
             TUInterfaceinfo tuInterfaceinfo = tuInterfaceinfoList.get(i);
@@ -203,13 +205,15 @@ public class TUInterfaceinfoServiceImpl implements ITUInterfaceinfoService
                 System.out.println("(" + tuInterfaceinfoList.size() + "-" + (i + 1) + ") " + tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + 0 + " ms");
                 System.out.println("(" + tuInterfaceinfoList.size() + "-" + (i + 1) + ") " + tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + 0 + " ms");
                 continue;
                 continue;
             }
             }
+            System.out.println(tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + "updating database... id = " + tuInterfaceinfo.getId());
+            //select count(id) callsuccnum from ${tableName}
             Date dateBegin = new Date();
             Date dateBegin = new Date();
             TUInterfaceinfo result = tUInterfaceinfoMapper.selectCountByTableName(tuInterfaceinfo);
             TUInterfaceinfo result = tUInterfaceinfoMapper.selectCountByTableName(tuInterfaceinfo);
-            System.out.println(tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + "updating database...");
-            tuInterfaceinfo.setCallsuccnum(result.getCallsuccnum());
-            tUInterfaceinfoMapper.updateInterfaceCallsuccnum(tuInterfaceinfo);
             Long interval = new Date().getTime() - dateBegin.getTime();//接口查询总数所用时间
             Long interval = new Date().getTime() - dateBegin.getTime();//接口查询总数所用时间
             System.out.println("(" + tuInterfaceinfoList.size() + "-" + (i + 1) + ") " + tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + interval + " ms total:[" + result.getCallsuccnum() + "]");
             System.out.println("(" + tuInterfaceinfoList.size() + "-" + (i + 1) + ") " + tuInterfaceinfo.getTableName() + " - " + tuInterfaceinfo.getInterfaceName() + " - " + interval + " ms total:[" + result.getCallsuccnum() + "]");
+            tuInterfaceinfo.setCallsuccnum(result.getCallsuccnum());
+            tUInterfaceinfoMapper.updateInterfaceCallsuccnum(tuInterfaceinfo);
+            //update t_u_interfaceinfo set callsuccnum = #{callsuccnum} where id = #{id}
         }
         }
     }
     }