3.28-修改线路新增接口以及查询接口，修改数据的返回格式

src/main/java/com/example/tdl/config/RedisConfig.java

@@ -216,6 +216,13 @@ public class RedisConfig extends CachingConfigurerSupport{
         return template;
     }
 
+    @Bean
+    public RedisTemplate<String, String> alarmRedisTemplate() {
+        StringRedisTemplate template = new StringRedisTemplate(redisConnectionFactory(3));
+        JsonRedisSerializer(template, false);
+        return template;
+    }
+
     @Bean
     public RedisTemplate<String, String> tokenRedisTemplate() {
         StringRedisTemplate template = new StringRedisTemplate(redisConnectionFactory(15));
@@ -223,5 +230,7 @@ public class RedisConfig extends CachingConfigurerSupport{
         return template;
     }
 
+
+
 }
 

src/main/java/com/example/tdl/domain/vo/AddCircuitVo.java

@@ -5,13 +5,15 @@ import java.util.List;
 
 public class AddCircuitVo {
 
+    private StartAddressVo startAddressVo;
+
     private List<AddressVo> addressVoList;
 
-    private String SN;
+    private EndAddressVo endAddressVo;
 
-    private String TDLSN;
+    private String SN;
 
-    private String alarmType;
+    private List<TDLAlarmVo> tdlAlarmList;
 
     private String cargoNo;//货物编号
 
@@ -21,6 +23,14 @@ public class AddCircuitVo {
 
     private String remark;
 
+    public StartAddressVo getStartAddressVo() {
+        return startAddressVo;
+    }
+
+    public void setStartAddressVo(StartAddressVo startAddressVo) {
+        this.startAddressVo = startAddressVo;
+    }
+
     public List<AddressVo> getAddressVoList() {
         return addressVoList;
     }
@@ -29,28 +39,28 @@ public class AddCircuitVo {
         this.addressVoList = addressVoList;
     }
 
-    public String getSN() {
-        return SN;
+    public EndAddressVo getEndAddressVo() {
+        return endAddressVo;
     }
 
-    public void setSN(String SN) {
-        this.SN = SN;
+    public void setEndAddressVo(EndAddressVo endAddressVo) {
+        this.endAddressVo = endAddressVo;
     }
 
-    public String getTDLSN() {
-        return TDLSN;
+    public String getSN() {
+        return SN;
     }
 
-    public void setTDLSN(String TDLSN) {
-        this.TDLSN = TDLSN;
+    public void setSN(String SN) {
+        this.SN = SN;
     }
 
-    public String getAlarmType() {
-        return alarmType;
+    public List<TDLAlarmVo> getTdlAlarmList() {
+        return tdlAlarmList;
     }
 
-    public void setAlarmType(String alarmType) {
-        this.alarmType = alarmType;
+    public void setTdlAlarmList(List<TDLAlarmVo> tdlAlarmList) {
+        this.tdlAlarmList = tdlAlarmList;
     }
 
     public String getCargoNo() {

src/main/java/com/example/tdl/domain/vo/AddressVo.java

@@ -2,8 +2,6 @@ package com.example.tdl.domain.vo;
 
 public class AddressVo {
 
-    private Integer sequence;
-
     private String country;
 
     private String city;
@@ -20,15 +18,6 @@ public class AddressVo {
 
     private Long compTime;//预计结束时间
 
-
-    public Integer getSequence() {
-        return sequence;
-    }
-
-    public void setSequence(Integer sequence) {
-        this.sequence = sequence;
-    }
-
     public String getCountry() {
         return country;
     }

src/main/java/com/example/tdl/domain/vo/AlarmRuleVo.java

+package com.example.tdl.domain.vo;
+
+public class AlarmRuleVo {
+
+    private String rule;
+
+    private String maxval;
+
+    private String minval;
+
+    private String mode;
+
+    private String priority;
+
+    public String getRule() {
+        return rule;
+    }
+
+    public void setRule(String rule) {
+        this.rule = rule;
+    }
+
+    public String getMaxval() {
+        return maxval;
+    }
+
+    public void setMaxval(String maxval) {
+        this.maxval = maxval;
+    }
+
+    public String getMinval() {
+        return minval;
+    }
+
+    public void setMinval(String minval) {
+        this.minval = minval;
+    }
+
+    public String getMode() {
+        return mode;
+    }
+
+    public void setMode(String mode) {
+        this.mode = mode;
+    }
+
+    public String getPriority() {
+        return priority;
+    }
+
+    public void setPriority(String priority) {
+        this.priority = priority;
+    }
+}

src/main/java/com/example/tdl/domain/vo/BindingVo.java

@@ -14,6 +14,8 @@ public class BindingVo {
 
     private String warehouseNo;
 
+    private String alarmType;
+
     public String getSN() {
         return SN;
     }
@@ -61,4 +63,12 @@ public class BindingVo {
     public void setWarehouseNo(String warehouseNo) {
         this.warehouseNo = warehouseNo;
     }
+
+    public String getAlarmType() {
+        return alarmType;
+    }
+
+    public void setAlarmType(String alarmType) {
+        this.alarmType = alarmType;
+    }
 }

src/main/java/com/example/tdl/domain/vo/CircuitMessageVo.java

@@ -18,7 +18,7 @@ public class CircuitMessageVo {
 
     private List<ResultCityVo> list;
 
-    List<ResultAlarmLog> alarmLogList;
+    private List<ResultAlarmLog> alarmLogList;
 
     public CircuitMessageVo() {
     }

src/main/java/com/example/tdl/domain/vo/DataVo.java

+package com.example.tdl.domain.vo;
+
+import java.util.List;
+
+public class DataVo {
+
+    private String description;
+
+    private List<HistoryDataVo> dataList;
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public List<HistoryDataVo> getDataList() {
+        return dataList;
+    }
+
+    public void setDataList(List<HistoryDataVo> dataList) {
+        this.dataList = dataList;
+    }
+}

src/main/java/com/example/tdl/domain/vo/EndAddressVo.java

+package com.example.tdl.domain.vo;
+
+public class EndAddressVo {
+
+    private String country;
+
+    private String city;
+
+    private String addressDetail;
+
+    private String lng;
+
+    private String lat;
+
+    private String postCode;
+
+    private Long compTime;//预计结束时间
+
+    public String getCountry() {
+        return country;
+    }
+
+    public void setCountry(String country) {
+        this.country = country;
+    }
+
+    public String getCity() {
+        return city;
+    }
+
+    public void setCity(String city) {
+        this.city = city;
+    }
+
+    public String getAddressDetail() {
+        return addressDetail;
+    }
+
+    public void setAddressDetail(String addressDetail) {
+        this.addressDetail = addressDetail;
+    }
+
+    public String getLng() {
+        return lng;
+    }
+
+    public void setLng(String lng) {
+        this.lng = lng;
+    }
+
+    public String getLat() {
+        return lat;
+    }
+
+    public void setLat(String lat) {
+        this.lat = lat;
+    }
+
+    public String getPostCode() {
+        return postCode;
+    }
+
+    public void setPostCode(String postCode) {
+        this.postCode = postCode;
+    }
+
+    public Long getCompTime() {
+        return compTime;
+    }
+
+    public void setCompTime(Long compTime) {
+        this.compTime = compTime;
+    }
+}

src/main/java/com/example/tdl/domain/vo/HistoryData.java

+package com.example.tdl.domain.vo;
+
+public class HistoryData {
+
+    private String time;
+
+    private String value;
+
+    public String getTime() {
+        return time;
+    }
+
+    public void setTime(String time) {
+        this.time = time;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+}

src/main/java/com/example/tdl/domain/vo/HistoryDataVo.java

+package com.example.tdl.domain.vo;
+
+import java.util.List;
+
+public class HistoryDataVo {
+    private String TDLSN;
+
+    private List<HistoryData> dataList;
+
+    public String getTDLSN() {
+        return TDLSN;
+    }
+
+    public void setTDLSN(String TDLSN) {
+        this.TDLSN = TDLSN;
+    }
+
+    public List<HistoryData> getDataList() {
+        return dataList;
+    }
+
+    public void setDataList(List<HistoryData> dataList) {
+        this.dataList = dataList;
+    }
+}

src/main/java/com/example/tdl/domain/vo/StartAddressVo.java

+package com.example.tdl.domain.vo;
+
+public class StartAddressVo {
+
+    private String country;
+
+    private String city;
+
+    private String addressDetail;
+
+    private String lng;
+
+    private String lat;
+
+    private String postCode;
+
+    private Long expTime;
+
+    public String getCountry() {
+        return country;
+    }
+
+    public void setCountry(String country) {
+        this.country = country;
+    }
+
+    public String getCity() {
+        return city;
+    }
+
+    public void setCity(String city) {
+        this.city = city;
+    }
+
+    public String getAddressDetail() {
+        return addressDetail;
+    }
+
+    public void setAddressDetail(String addressDetail) {
+        this.addressDetail = addressDetail;
+    }
+
+    public String getLng() {
+        return lng;
+    }
+
+    public void setLng(String lng) {
+        this.lng = lng;
+    }
+
+    public String getLat() {
+        return lat;
+    }
+
+    public void setLat(String lat) {
+        this.lat = lat;
+    }
+
+    public String getPostCode() {
+        return postCode;
+    }
+
+    public void setPostCode(String postCode) {
+        this.postCode = postCode;
+    }
+
+    public Long getExpTime() {
+        return expTime;
+    }
+
+    public void setExpTime(Long expTime) {
+        this.expTime = expTime;
+    }
+
+}

src/main/java/com/example/tdl/domain/vo/TDLAlarmVo.java

+package com.example.tdl.domain.vo;
+
+public class TDLAlarmVo {
+
+    private String TDLSN;
+
+    private String alarmType;
+
+    public String getTDLSN() {
+        return TDLSN;
+    }
+
+    public void setTDLSN(String TDLSN) {
+        this.TDLSN = TDLSN;
+    }
+
+    public String getAlarmType() {
+        return alarmType;
+    }
+
+    public void setAlarmType(String alarmType) {
+        this.alarmType = alarmType;
+    }
+}

src/main/java/com/example/tdl/mqtt/MqttListener.java

@@ -204,4 +204,5 @@ public class MqttListener implements MqttCallback {
             return 1;//重发
         }
     }
+
 }

src/main/java/com/example/tdl/service/redis/AlarmRedisService.java

+package com.example.tdl.service.redis;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+@Service
+public class AlarmRedisService extends RedisService {
+
+    @SuppressWarnings({ "unchecked", "rawtypes" })
+    @Autowired
+    public AlarmRedisService(RedisTemplate alarmRedisTemplate) {
+        super(alarmRedisTemplate);
+    }
+}

src/main/java/com/example/tdl/web/EquipmentBindingController.java

@@ -3,12 +3,13 @@ package com.example.tdl.web;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
-import com.alibaba.fastjson.serializer.FloatArraySerializer;
 import com.example.tdl.domain.dto.CommFeedback;
 import com.example.tdl.domain.vo.*;
+import com.example.tdl.service.AlarmService;
 import com.example.tdl.service.ConfigService;
 import com.example.tdl.service.GatewayService;
 import com.example.tdl.service.TDLDeviceService;
+import com.example.tdl.service.redis.AlarmRedisService;
 import com.google.gson.Gson;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -22,6 +23,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -44,6 +46,21 @@ public class EquipmentBindingController {
     @Autowired
     private TDLDeviceService tdlDeviceService;
 
+    @Autowired
+    private AlarmRedisService alarmRedisService;
+
+    @Autowired
+    private AlarmService alarmService;
+
+    List<String> list = new ArrayList<String>(){{
+        add("T");
+        add("h");
+        add("a0");
+        add("ta");
+//        add("");
+//        add("");
+    }};
+
     @ApiOperation(value = "绑定gateWay和tdl",notes = "绑定gateWay和tdl" +
             "   SN：gateWay编号，" +
             "   type：gateWay类型，" +
@@ -86,6 +103,7 @@ public class EquipmentBindingController {
         map.put("useScene",bindingVo.getMode());
         map.put("gSN",bindingVo.getSN());
         map.put("gType",bindingVo.getType());
+        map.put("alarmType",bindingVo.getAlarmType());
         map.put("message",gson.toJson(configCMDVo));
         map.put("flag",false);
         map.put("resp",null);
@@ -99,6 +117,34 @@ public class EquipmentBindingController {
         if (msg.get("msg").equals("配置网关成功")){
             fb.setCode(1);
             fb.setMessage(msg.get("msg").toString());
+            //根据报警类型货报警信息
+            ResultAlarmVo alarmVo =  alarmService.getByTypeAndScene(bindingVo.getAlarmType(),"运输");
+            for(String alias :list){
+                List<AlarmRuleVo> alarmRuleVos = new ArrayList<>();
+                AlarmRuleVo alarmRuleVo = new AlarmRuleVo();
+                if(alias.equals("T")){
+                    alarmRuleVo.setMinval(String.valueOf(alarmVo.getTemMin()));
+                    alarmRuleVo.setMaxval(String.valueOf(alarmVo.getTemMax()));
+                    alarmRuleVo.setMode("twoway");
+                    alarmRuleVo.setPriority("1");
+                }else if(alias.equals("h")){
+                    alarmRuleVo.setMinval(String.valueOf(alarmVo.getHumidityMin()));
+                    alarmRuleVo.setMaxval(String.valueOf(alarmVo.getHumidityMax()));
+                    alarmRuleVo.setMode("twoway");
+                    alarmRuleVo.setPriority("1");
+                }else if(alias.equals("ta")){
+                    alarmRuleVo.setMinval(String.valueOf(alarmVo.getTilt()));
+                    alarmRuleVo.setMode("equal");
+                    alarmRuleVo.setPriority("1");
+                }else if(alias.equals("a0")){
+                    alarmRuleVo.setMinval(String.valueOf(alarmVo.getShock()));
+                    alarmRuleVo.setMode("equal");
+                    alarmRuleVo.setPriority("1");
+                }
+                alarmRuleVos.add(alarmRuleVo);
+                //向redis中写入报警信息
+                alarmRedisService.hmSet("TDL/"+bindingVo.getType()+"/" +bindingVo.getSN()+"/Data","tdl-" +bindingVo.getTDLSN()+"_" +alias,gson.toJson(alarmRuleVos));
+            }
         }else{
             fb.setCode(0);
             fb.setMessage(msg.get("msg").toString());
@@ -106,6 +152,9 @@ public class EquipmentBindingController {
         return gson.toJson(fb);
     }
 
+
+
+
     @ApiOperation(value = "重置tdl",notes = "重置tdl")
     @ApiImplicitParams({
             @ApiImplicitParam(paramType="header", name = "Account_token", value = "token", required = true, dataType = "String"),
@@ -141,6 +190,8 @@ public class EquipmentBindingController {
         if (msg.get("msg").equals("解除网关成功")){
             fb.setCode(1);
             fb.setMessage(msg.get("msg").toString());
+            String key ="TDL/"+resultTDLDeviceVo.getGatewayType()+"/" +resultTDLDeviceVo.getGatewaySN() +"/Data";
+            alarmRedisService.delKey(key);
         }else{
             fb.setCode(0);
             fb.setMessage(msg.get("msg").toString());

src/main/resources/mapper/CircuitMapper.xml

@@ -3,18 +3,14 @@
 <mapper namespace="com.example.tdl.mapper.CircuitMapper">
    <!--获取所有线路的信息-->
    <select id="getAll" resultType="com.example.tdl.domain.vo.ResultCircuitVo">
-      SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-    (SELECT alarmType FROM alarm WHERE id=c.alarm_id) alarmType,(select GROUP_CONCAT(DISTINCT classify) alarm from  alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+      SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
     from circuit c where c.state=1
    </select>
 
 
    <!--根据条件查询线路信息-->
    <select id="getByTerm" resultType="com.example.tdl.domain.vo.ResultCircuitVo" parameterType="com.example.tdl.domain.vo.CircuitTermVo">
-      SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-      (SELECT alarmType FROM alarm WHERE id=c.alarm_id) alarmType,(select GROUP_CONCAT(DISTINCT classify) alarm from  alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+      SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
       from circuit c where c.state=1
       <if test="circuitState!=null">
          AND circuitState=#{circuitState,jdbcType=INTEGER}
@@ -39,7 +35,6 @@
                 #{startTime,mode=IN,jdbcType=BIGINT},
                 #{expTime,mode=IN,jdbcType=BIGINT},
                 #{compTime,mode=IN,jdbcType=BIGINT},
-                #{alarmType,mode=IN,jdbcType=VARCHAR},
                 #{cargoNo,mode=IN,jdbcType=VARCHAR},
                 #{cargoName,mode=IN,jdbcType=VARCHAR},
                 #{plateNo,mode=IN,jdbcType=VARCHAR},
@@ -61,7 +56,9 @@
                 #{compTimeVar,mode=IN,jdbcType=VARCHAR},
                 #{SN,mode=IN,jdbcType=VARCHAR},
                 #{type,mode=IN,jdbcType=VARCHAR},
-                #{TDLSN,mode=IN,jdbcType=VARCHAR},
+                #{TDLSNVar,mode=IN,jdbcType=VARCHAR},
+                #{alarmTypeVar,mode=IN,jdbcType=VARCHAR},
+                #{TDLCounts,mode=IN,jdbcType=VARCHAR},
                 #{message,mode=IN,jdbcType=VARCHAR},
                 #{flag,mode=IN,jdbcType=INTEGER},
                 #{untie,mode=IN,jdbcType=INTEGER},
@@ -138,27 +135,21 @@
 
    <!--根据线路编号获取线路信息-->
    <select id="getByTransportationNo" resultType="com.example.tdl.domain.vo.ResultCircuitVo" parameterType="String">
-     SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-      IFNULL((SELECT alarmType FROM alarm WHERE id=c.alarm_id),"正常") alarmType from circuit c
-      where c.state=1
-      AND transportationNo=#{transportationNo,jdbcType=VARCHAR}
+    SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+    from circuit c where c.state=1
+      AND c.transportationNo=#{transportationNo,jdbcType=VARCHAR}
    </select>
 
    <!--根据车牌号查线路-->
    <select id="getByContainerNo" parameterType="String" resultType="com.example.tdl.domain.vo.ResultCircuitVo">
-       SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-    (SELECT alarmType FROM alarm WHERE id=c.alarm_id) alarmType,(select GROUP_CONCAT(DISTINCT classify) alarm from  alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+      SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
     from circuit c where c.state=1 AND cargoNo=#{cargoNo,jdbcType=VARCHAR}
    </select>
 
 
    <!--根据运输状态查询线路信息-->
    <select id="getByCircuitState" parameterType="java.lang.Integer" resultType="com.example.tdl.domain.vo.ResultCircuitVo">
-       SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-    (SELECT alarmType FROM alarm WHERE id=c.alarm_id) alarmType,(select GROUP_CONCAT(DISTINCT classify) alarm from  alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+      SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
     from circuit c where c.state=1  AND circuitState=#{circuitState,jdbcType=INTEGER}
    </select>
 
@@ -181,9 +172,7 @@
    </select>
 
    <select id="getByTime" parameterType="java.lang.String" resultType="com.example.tdl.domain.vo.ResultCircuitVo">
-     SELECT transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,
-      startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,
-    (SELECT alarmType FROM alarm WHERE id=c.alarm_id) alarmType,(select GROUP_CONCAT(DISTINCT classify) alarm from  alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
+     SELECT c.transportationNo,cargoNo,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence LIMIT 1)) startCity,startTime,(SELECT city from city WHERE id =(SELECT city_id from circuit_transfer WHERE circuit_id=c.id ORDER BY sequence DESC LIMIT 1)) endCity,endTime,circuitState,(SELECT alarmType FROM alarm WHERE id IN (SELECT alarm_id from tdl_gateway_log WHERE transportationNo=c.transportationNo)) alarmType,(select GROUP_CONCAT(classify) from alarm_log al where al.transportationNo = c.transportationNo) alarm,evaluate
     from circuit c where c.state=1  AND  DATE_SUB(CURDATE(), INTERVAL #{time,jdbcType=VARCHAR} DAY) &lt;= date(FROM_UNIXTIME(createTime/1000,'%Y-%m-%d %H:%i:%s'))
    </select>
 

src/main/resources/mapper/ConfigMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.example.tdl.mapper.ConfigMapper">
-   <!-- &lt;!&ndash;绑定getway和tdl&ndash;&gt;
+    <!--绑定getway和tdl-->
     <insert id="addConfig" parameterType="java.util.Map" statementType="CALLABLE">
         <![CDATA[
         {
@@ -11,6 +11,7 @@
                 #{useScene,mode=IN,jdbcType=INTEGER},
                 #{gSN,mode=IN,jdbcType=VARCHAR},
                 #{gType,mode=IN,jdbcType=VARCHAR},
+                #{alarmType,mode=IN,jdbcType=VARCHAR},
                 #{message,mode=IN,jdbcType=VARCHAR},
                 #{flag,mode=IN,jdbcType=INTEGER},
                 #{resp,mode=IN,jdbcType=INTEGER},
@@ -24,12 +25,12 @@
       ]]>
     </insert>
 
-    &lt;!&ndash;获取绑定消息&ndash;&gt;
+    <!--获取绑定消息-->
     <select id="getConfig" parameterType="String" resultType="com.example.tdl.domain.vo.ConfigVo">
         select gSN,gType,message,flag,resp,state,untie from config where gSN= #{gSN,jdbcType=VARCHAR} and gType=#{gType,jdbcType=VARCHAR} and state = 1;
     </select>
 
-   &lt;!&ndash; 绑定回复&ndash;&gt;
+    <!--绑定回复-->
     <update id="bindiSuccess">
         update config set resp=#{resp,jdbcType=INTEGER},flag=true
         where gSN= #{gSN,jdbcType=VARCHAR}
@@ -37,7 +38,7 @@
         and state = 1;
     </update>
 
-    &lt;!&ndash;重置tdl&ndash;&gt;
+    <!--重置tdl-->
     <update id="updateConfig" parameterType="java.util.Map" statementType="CALLABLE">
         <![CDATA[
         {
@@ -54,28 +55,28 @@
       ]]>
     </update>
 
-    &lt;!&ndash;解绑成功&ndash;&gt;
+    <!--解绑成功-->
     <update id="delConfig" parameterType="String">
         update config set state = 0 where gSN= #{gSN,jdbcType=VARCHAR} and gType=#{gType,jdbcType=VARCHAR} and state = 1;
-    </update>-->
+    </update>
 
-    <!-- <insert id="addConfig" parameterType="com.example.tdl.domain.vo.ConfigVo">
-      insert into config
-      values(
-      null,
-      #{gSN,jdbcType=VARCHAR},
-      #{gType,jdbcType=VARCHAR},
-      #{message,jdbcType=VARCHAR},
-      #{flag,jdbcType=INTEGER},
-      #{resp,jdbcType=INTEGER},
-      #{state,jdbcType=INTEGER},
-      #{untie,jdbcType=INTEGER}
-      )
-    </insert>-->
-    <!--<update id="updateConfig">
-    update config set untie=#{untie,jdbcType=INTEGER}
-    where gSN= #{gSN,jdbcType=VARCHAR}
-    and gType=#{gType,jdbcType=VARCHAR}
-    and state = 1;
-    </update>-->
+     <!--<insert id="addConfig" parameterType="com.example.tdl.domain.vo.ConfigVo">-->
+      <!--insert into config-->
+      <!--values(-->
+      <!--null,-->
+      <!--#{gSN,jdbcType=VARCHAR},-->
+      <!--#{gType,jdbcType=VARCHAR},-->
+      <!--#{message,jdbcType=VARCHAR},-->
+      <!--#{flag,jdbcType=INTEGER},-->
+      <!--#{resp,jdbcType=INTEGER},-->
+      <!--#{state,jdbcType=INTEGER},-->
+      <!--#{untie,jdbcType=INTEGER}-->
+      <!--)-->
+    <!--</insert>-->
+    <!--<update id="updateConfig">-->
+    <!--update config set untie=#{untie,jdbcType=INTEGER}-->
+    <!--where gSN= #{gSN,jdbcType=VARCHAR}-->
+    <!--and gType=#{gType,jdbcType=VARCHAR}-->
+    <!--and state = 1;-->
+    <!--</update>-->
 </mapper>
\ No newline at end of file