加入1、线路总数2、在线车辆数3、当日计划班次、当日完成班次4、上一日班次执行率，首末班车准点率。4个接口

ljq
1 parent c2dfbe79
Showing 3 changed files with 194 additions and 1 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/server_rs/number/NumberService.java
src/main/java/com/bsth/server_rs/number/XlThread.java
@@ -14,6 +14,7 @@ import com.bsth.server_rs.electric.ElectricService;
 import com.bsth.server_rs.exception.AesExceptionMapper;
 import com.bsth.server_rs.gps.GpsRestService;
 import com.bsth.server_rs.logs.RealLogRestService;
+import com.bsth.server_rs.number.NumberService;
 import com.bsth.server_rs.schedule.plan.SchedulePlanService;
 import com.bsth.server_rs.schedule.real.ScheduleRealService;
 import com.bsth.server_rs.schedule.real.StaffViewRealService;
@@ -113,6 +114,8 @@ public class CXFConfig {
     @Autowired
     BigdataService bigdataService;
     @Autowired
+    NumberService numberService;
+    @Autowired
     StaffViewRealService staffViewRealService;
  
     @Bean
@@ -135,7 +138,8 @@ public class CXFConfig {
                 ld_roadSpeedRestService,
                 electricService,
                 staffViewRealService,
-                bigdataService));
+                bigdataService,
+                numberService));
         endpoint.setProviders(Arrays.asList(new JacksonJsonProvider(), new AesExceptionMapper()));
         //endpoint.setFeatures(Arrays.asList(new Swagger2Feature()));
         endpoint.getInInterceptors().add(new AuthorizeInterceptor_IN());
+package com.bsth.server_rs.number;
+
+import com.bsth.Application;
+import com.bsth.server_rs.bigdata.BigdataService;
+import com.bsth.server_rs.gps.GpsRestService;
+import com.bsth.server_rs.gps.entity.GpsEntity;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+@Component
+@Path("/number")
+@Produces({MediaType.APPLICATION_JSON})
+public class NumberService implements CommandLineRunner{
+
+    @Autowired
+    GpsRestService gpsRestService;
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+    @Autowired
+    BigdataService bigdataService;
+    @Autowired
+    XlThread xlThread;
+
+    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+    /**
+     * 线路总数
+     * @return
+     */
+    @GET
+    @Path("/xlnum")
+    public Map lxnum() {
+        Map<String,Object> map = new HashMap<>();
+        XlThread x = new XlThread();
+        map = x.pule();
+        return map;
+    }
+
+    /**
+     * 在线车辆数
+     * @return
+     */
+    @GET
+    @Path("/carnum")
+    public Map carnum(){
+        Map<String,Integer> map = new HashMap<>();
+        try {
+            Collection<GpsEntity> all = gpsRestService.findAll();
+            map.put("carnum", all.size());
+        }catch (Exception e){
+            logger.error("在线车辆数", e);
+        }
+        return map;
+
+    }
+
+    /**
+     * 当日计划班次、当日完成班次
+     * @return
+     */
+    @GET
+    @Path("/info")
+    public Map inforeal(){
+        Map<String,Integer> map = new HashMap<>();
+        try {
+            List<Map<String, Object>> list = bigdataService.findLineBcByDate("all",format.format(new Date()));
+            int jhnum = 0;
+            int sjnum = 0;
+            for(int i = 0;i < list.size() ;i++){
+                jhnum += Integer.parseInt(list.get(i).get("jhbc").toString());
+                sjnum += Integer.parseInt(list.get(i).get("sjbc").toString());
+            }
+
+            map.put("jhnum",jhnum);
+            map.put("sjnum",sjnum);
+        }catch (Exception e){
+            logger.error("当日计划班次、当日完成班次", e);
+        }
+        return map;
+    }
+
+    /**
+     *  上一日班次执行率，首末班车准点率
+     * @return
+     */
+    @GET
+    @Path("/fiducial")
+    public Map fiducial(){
+        Map<String,Double> map = new HashMap<>();
+        Calendar c = Calendar.getInstance();
+        c.setTime(new Date());
+        c.add(Calendar.DATE, -1);
+        Date start = c.getTime();
+        String qyt = format.format(start);//前
+        java.text.DecimalFormat myformat=new java.text.DecimalFormat("#0.00");//保留2为小数
+
+        try {
+            List<Map<String, Object>> list = bigdataService.departureTime(qyt, qyt, "all");
+            double bczxl = 0d; //上一日班次执行率
+            double smbczdlz = 0d;   //首末班车准点率
+            for (int i = 0; i < list.size(); i++) {
+                bczxl += Double.valueOf(list.get(i).get("bczxl").toString());
+                smbczdlz += Double.valueOf(list.get(i).get("smbczdlz").toString());
+            }
+            bczxl = bczxl / list.size();
+            smbczdlz = smbczdlz / list.size();
+            bczxl = Double.parseDouble(myformat.format(bczxl));//保留2为小数
+            smbczdlz = Double.parseDouble(myformat.format(smbczdlz));//保留2为小数
+
+            map.put("bczxl", bczxl);
+            map.put("smbczdlz", smbczdlz);
+        }catch (Exception e){
+            logger.error("上一日班次执行率，首末班车准点率", e);
+        }
+        return map;
+    }
+
+
+    @Override
+    public void run(String... strings) throws Exception {
+        Application.mainServices.scheduleWithFixedDelay(xlThread, 10, 60 * 60, TimeUnit.SECONDS);//查询线路总数
+    }
+}
+package com.bsth.server_rs.number;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Component;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+@Component
+public class XlThread extends Thread {
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+
+    private static Map<String,Object>  xlmap ;
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    public Map pule(){
+        return  xlmap;
+    }
+
+    @Override
+    public void run() {
+        Calendar c = Calendar.getInstance();
+        Map<String,Object> map = new HashMap<>();
+        c.setTime(new Date());
+        c.add(Calendar.DATE, -1);
+        Date start = c.getTime();
+        String qyt = format.format(start);//前
+        try {
+            String sql = "select  id from  bsth_c_s_sp_info_real where real_exec_date ='" + qyt + "' GROUP BY xl_bm";
+            List<Map<String, Object>> list = jdbcTemplate.query(sql,
+                    new RowMapper<Map<String, Object>>() {
+                        @Override
+                        public Map<String, Object> mapRow(ResultSet rs, int rowNum) throws SQLException {
+                            Map<String, Object> m = new HashMap<String, Object>();
+                            m.put("id", rs.getString("id"));
+                            return m;
+                        }
+                    });
+            map.put("xlnum", list.size());
+            xlmap = map;
+        }catch (Exception e){
+            logger.error("线路总数", e);
+        }
+        super.run();
+    }
+}