update...

潘钊
1 parent 8e8799a6
Showing 2 changed files with 150 additions and 6 deletions
src/main/java/com/bsth/controller/realcontrol/ServiceDataInterface.java
src/main/java/com/bsth/data/directive/DayOfDirectives.java
 package com.bsth.controller.realcontrol;
  
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.data.BasicData;
+import com.bsth.data.directive.DayOfDirectives;
+import com.bsth.data.directive.DirectiveCreator;
+import com.bsth.data.directive.GatewayHttpUtils;
+import com.bsth.data.gpsdata.GpsEntity;
+import com.bsth.data.gpsdata.GpsRealData;
 import com.bsth.data.schedule.DayOfSchedule;
+import com.bsth.entity.directive.D60;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.repository.directive.D60Repository;
+import com.google.common.base.Splitter;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
  
-import java.util.ArrayList;
-import java.util.List;
+import java.util.*;
  
 /**
  * 对外的营运数据接口
@@ -21,9 +31,56 @@ public class ServiceDataInterface {
  
     private final static String SECRE_KEY = "dVPHJkWUt5FhMT7jrM2dLV7QvlHAmZFd42rs1P0usBx8A7HZki";
  
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
     @Autowired
     DayOfSchedule dayOfSchedule;
  
+    @Autowired
+    DayOfDirectives dayOfDirectives;
+
+    @Autowired
+    D60Repository d60Repository;
+
+    @Autowired
+    GpsRealData gpsRealData;
+
+    /**
+     * 获取车辆 和 当前执行班次对照信息
+     * @return
+     */
+    @RequestMapping("/execSchList")
+    public List<JSONObject> execSchList(@RequestParam String secretKey){
+        if (StringUtils.isEmpty(secretKey) || !secretKey.equals(SECRE_KEY))
+            return null;
+
+        List<JSONObject> rs = new ArrayList<>();
+        Collection<ScheduleRealInfo> list = dayOfSchedule.execPlanMap().values();
+
+        JSONObject obj;
+        for(ScheduleRealInfo sch : list){
+            obj = new JSONObject();
+            obj.put("clZbh", sch.getClZbh());
+            obj.put("jGh", sch.getjGh());
+            obj.put("sGh", sch.getsGh());
+            obj.put("lpName", sch.getLpName());
+            obj.put("xlBm", sch.getXlBm());
+            obj.put("xlName", sch.getXlName());
+            obj.put("xlDir", sch.getXlDir());
+            obj.put("qdzName", sch.getQdzName());
+            obj.put("zdzName", sch.getZdzName());
+            obj.put("fcsj", sch.getFcsj());
+            obj.put("dfsj", sch.getDfsj());
+            obj.put("zdsj", sch.getZdsj());
+            obj.put("bcType", sch.getBcType());
+            obj.put("remarks", sch.getRemark());
+            obj.put("status", sch.getStatus());
+
+            rs.add(obj);
+        }
+        return rs;
+    }
+
     @RequestMapping("/getCurrentDayPlan")
     public List<ScheduleRealInfo> getCurrentDayPlan(
             @RequestParam String companyId,
@@ -98,4 +155,87 @@ public class ServiceDataInterface {
         }
         return rs;
     }
+
+    /**
+     * 向指定的车辆下发消息短语
+     * @param nbbm
+     * @param txt
+     * @return
+     */
+    @RequestMapping(value = "/send60Phrase", method = RequestMethod.POST)
+    public int send60Phrase(@RequestBody Map<String, String> map,@RequestParam String secretKey){
+        try{
+            String nbbm = map.get("nbbm");
+            String txt = map.get("txt");
+            String sender = map.get("sender");
+            if(txt.length() > 50)
+                txt = txt.substring(0, 50);
+            if (StringUtils.isEmpty(secretKey) || !secretKey.equals(SECRE_KEY))
+                return -500;
+
+            //车辆和设备号对照
+            String deviceId = BasicData.deviceId2NbbmMap.inverse().get(nbbm);
+            if(StringUtils.isEmpty(deviceId))
+                return -404;
+
+            //检查设备是否在线
+            long t = System.currentTimeMillis();
+            GpsEntity gps = gpsRealData.get(deviceId);
+            if(null == gps ||  (t - gps.getServerTimestamp()) > 1000 * 60 * 5)
+                return -405;
+
+            Short dispatchInstruct = 0;//消息短语
+            D60 d60 = new DirectiveCreator().createD60(nbbm, txt, dispatchInstruct, gps.getUpDown(), gps.getState(), gps.getLineId());
+            d60.setSender(sender);
+            // 发送指令
+            int code = GatewayHttpUtils.postJson(JSON.toJSONString(d60));
+            d60.setHttpCode(code);
+
+            if (code == 0) {
+                // 添加到缓存
+                dayOfDirectives.put60(d60, true);
+            } else {
+                d60.setErrorText("网关通讯失败, code: " + code);
+                d60Repository.save(d60);
+                dayOfDirectives.put60(d60, false);
+            }
+
+            return d60.getMsgId();
+        }catch (Exception e){
+            logger.error("", e);
+            return -500;
+        }
+    }
+
+    /**
+     * 根据msg id 查询指令响应情况
+     * @param msgIDs
+     * @return
+     */
+    @RequestMapping("/findD60Reply")
+    public List<Map<String, Object>> findD60Reply(@RequestParam String msgIds){
+        List<Map<String, Object>> rs = new ArrayList<>();
+        try{
+            Map<String, Object> map = new HashMap();
+
+            List<String> ids = Splitter.on(",").splitToList(msgIds);
+            D60 d60;
+            for(String id : ids){
+                if(StringUtils.isEmpty(id))
+                    continue;
+
+                d60 = dayOfDirectives.get(Integer.parseInt(id));
+                if(null == d60)
+                    continue;
+
+                map.put("msgId", d60.getMsgId());
+                map.put("deviceReplyTime", d60.getReply46Time());
+                map.put("jsyReplyTime", d60.getReply47Time());
+                rs.add(map);
+            }
+        }catch (Exception e){
+            logger.error("", e);
+        }
+        return rs;
+    }
 }
@@ -197,7 +197,11 @@ public class DayOfDirectives {
 	public Collection<D64> all64(){
 		return d64Map.values();
 	}
-	
+
+	public D60 get(Integer msgId){
+		return d60Map.get(msgId);
+	}
+
 	public Collection<Directive> all(){
 		List<Directive> all = new ArrayList<>();
 		all.addAll(d60Map.values());