ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java

@@ -58,6 +58,8 @@ public class RadarStatusController  {
         TableDataInfo rspData = new TableDataInfo();
         List<SysRadar> radarList = service.selectRadarList(sysRadar);
 
+
+
         PageDomain pageDomain = TableSupport.buildPageRequest();
         if (null == pageDomain.getPageNum() || null == pageDomain.getPageSize()) {
             rspData.setRows(radarList);
@@ -83,5 +85,6 @@ public class RadarStatusController  {
 
 
 
+
 }
 

ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysRadarController.java

@@ -26,7 +26,6 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.sql.*;
 import java.util.List;
-import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
 /**
@@ -78,9 +77,7 @@ public class SysRadarController extends BaseController {
         radar.setCreateBy(getLoginName());
         int result = radarService.insertRadar(radar);
         List<SysRadar> sysRadars = radarService.selectRadarList(new SysRadar());
-        CompletableFuture.runAsync(()->{
         radarRealTimeDataService.addRadar(sysRadars);
-        });
         return toAjax(result);
     }
 
@@ -112,9 +109,7 @@ public class SysRadarController extends BaseController {
     @ResponseBody
     public AjaxResult remove(String ids) {
         int result = radarService.deleteRadarByIds(ids);
-        CompletableFuture.runAsync(()->{
         radarRealTimeDataService.delRadar(Long.valueOf(ids));
-        });
         return toAjax(result);
     }
 
@@ -148,9 +143,7 @@ public class SysRadarController extends BaseController {
         ExcelUtil<RadarExcel> util = new ExcelUtil<RadarExcel>(RadarExcel.class);
         List<RadarExcel> radarList = util.importExcel(file.getInputStream());
         String message = radarService.importData(radarList, updateSupport);
-        CompletableFuture.runAsync(()->{
         radarRealTimeDataService.addRadar(radarService.selectRadarList(new SysRadar()));
-        });
         return AjaxResult.success(message);
     }
 

ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/PrimaryRadarData.java

@@ -85,8 +85,6 @@ public class PrimaryRadarData extends BaseEntity
     /** 删除标志（0代表存在 2代表删除） */
     private String delFlag;
 
-    private Integer  stationCode;
-
     private String type;
 
     public String getType() {
@@ -244,7 +242,6 @@ public class PrimaryRadarData extends BaseEntity
                 .append("type",getType())
                 .append("totalCount",getTotalCount())
                 .append("radarLocation",getRadarLocation())
-                .append("stationCode",getStationCode())
                 .append("ladleNumber",getLadleNumber())
                 .append("stationCode",getStationCode())
                 .append("radarIp",getRadarIp())

ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysDiscern.java

@@ -65,8 +65,6 @@ public class SysDiscern extends BaseEntity
      */
     private Date updateTime;
 
-    private Integer stationCode;
-
     public SysDiscern() {
     }
 
@@ -134,14 +132,6 @@ public class SysDiscern extends BaseEntity
         this.type = type;
     }
 
-    public Integer getStationCode() {
-        return stationCode;
-    }
-
-    public void setStationCode(Integer stationCode) {
-        this.stationCode = stationCode;
-    }
-
     @Override
     public Date getCreateTime() {
         return createTime;
@@ -171,7 +161,6 @@ public class SysDiscern extends BaseEntity
                 .append("number",getNumber())
                 .append("type",getType())
                 .append("count",getCount())
-                .append("stationCode",getStationCode())
                 .append("radarLocation",getRadarLocation())
                 .append("ladleNumber",getLadleNumber())
                 .append("createTime", getCreateTime())

ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/TsanaRadar.java

@@ -21,10 +21,6 @@ public class TsanaRadar {
 
     public Integer timeCount;
 
-    public TsanaRadar(){
-
-    }
-
 
     public TsanaRadar() {
         this.radarCode = radarCode;

ruoyi-common/src/main/java/com/ruoyi/common/utils/SocketUtil.java

@@ -19,21 +19,24 @@ public class SocketUtil {
         dataResponse.setRadarIp(radarIp);
         dataResponse.setRadarLocation(radarLocation);
         try {
-            boolean connected = socket.isConnected();
+//            boolean connected = socket.isConnected();
-            if (!connected) {
+//            if (!connected) {
-            dataResponse.setStatus(0);
+//
-            }else {
+//            }else {
-                dataResponse.setStatus(1);
+//
-            }
+//            }
-            RadarStatusWebSocket.sendToAll(JSON.toJSONString(dataResponse));
+
             InputStream inputStream = socket.getInputStream(); // 获取输入流
             int available = inputStream.available();
             byte[] buffer = new byte[available];
             inputStream.read(buffer, 0, available);
-
+            if (buffer.length!= 0){
+                dataResponse.setStatus(1);
+            }else {
 //                System.out.println("雷达：" + radarIp + "===" + radarLocation + ": 连接异常：{}" );
-
+                dataResponse.setStatus(0);
-
+                dataResponse.setData(null);
+            }
             String hex = new BigInteger(1, buffer).toString(16);
 
             if (!"0".equals(hex)) {
@@ -47,6 +50,7 @@ public class SocketUtil {
 
                 dataResponse.setData(decimal);
 
+                RadarStatusWebSocket.sendToAll(JSON.toJSONString(dataResponse));
                 return dataResponse;
             }
 

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RadarRealTimeDataServiceImpl.java

@@ -5,19 +5,16 @@ import com.ruoyi.common.utils.SocketModel;
 import com.ruoyi.common.utils.SocketUtil;
 import com.ruoyi.common.utils.bean.BeanUtils;
 import com.ruoyi.common.utils.bean.ModbusResponse;
-import com.ruoyi.system.service.*;
+import com.ruoyi.system.service.ISysIdentifierService;
-import org.apache.commons.lang3.ObjectUtils;
+import com.ruoyi.system.service.ISysRadarService;
-import org.apache.commons.lang3.RandomUtils;
+import com.ruoyi.system.service.PrimaryRadarDataService;
+import com.ruoyi.system.service.RadarRealTimeDataService;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.net.Socket;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.PreparedStatement;
-import java.sql.SQLException;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.stream.Collectors;
@@ -35,16 +32,12 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
     private ISysRadarService service;
 
     @Autowired
-    private ISysDiscernService discernService;
+    private ExecutorService executorService = Executors.newFixedThreadPool(10);
 
     public static CopyOnWriteArrayList<String> allRadar = new CopyOnWriteArrayList<>();
 
-//    public static Integer count = 0 ;
-//
-//    private Integer consecutiveZeros = 0;
 
-
+    private Map<Long,String> radarDelMap = new HashMap<>();
-    private Map<Long, String> radarDelMap = new HashMap<>();
 
     @Override
     public void afterPropertiesSet()  {
@@ -63,13 +56,16 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
                 radarDelMap.put(radar.getId(), "0");
 
                 CompletableFuture.runAsync(() -> {
-                    task(radar, socket);
 
-//                        try {
+                    while (StringUtils.equals("0",radarDelMap.get(radar.getId()))) {
-//                            Thread.sleep(3000);
+
-//                        } catch (InterruptedException e) {
+                        task(radar, socket);
-//                            throw new RuntimeException(e);
+                        try {
-//                        }
+                            Thread.sleep(3000);
+                        } catch (InterruptedException e) {
+                            throw new RuntimeException(e);
+                        }
+                    }
                 });
             } catch (Exception e) {
                 e.printStackTrace();
@@ -79,145 +75,71 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
     }
 
     private void task(SysRadar radar, Socket socket) {
-        long noDataStart = System.currentTimeMillis();
+        int count  = 0;
-        long start = noDataStart;
+        int consecutiveZeros = 0;
+        CompletableFuture.runAsync(() ->{
 
-        Map<String, List<PrimaryRadarData>> map = new HashMap<>();
+        });
-
+        Map<String, List<Integer>> pulse4Number = new HashMap<>();
-        while (StringUtils.equals("0", radarDelMap.get(radar.getId()))) {
-//            int count = 0;
-//            int consecutiveZeros = 0;
-
-
-            List<PrimaryRadarData> dataList = new ArrayList<>();
         try {
             // socket连接成功返回数据
             DataResponse data = SocketUtil.getData(socket, radar.getRadarLocation(), radar.getRadarIp());
-                long current = System.currentTimeMillis();
+            // 天线号字符串转集合
-
+            List<String> numberList = convertStringToList(radar.getRadarNum());
+            SysDiscern sysDiscern = copyDataToDiscern(data);
+            System.out.println(radar.getRadarIp() + ": " + data);
             // 雷达数据返回封装类赋值
             ModbusResponse modbusResponse = getModbusResponse(data);
             String tag = modbusResponse.getTagId();
             // 雷达原始数据对象
             PrimaryRadarData primaryRadarData = new PrimaryRadarData();
-                // 标识器对象
+
-                SysIdentifier sysIdentifier = new SysIdentifier();
             // 拷贝封装类属性到雷达原始数据对象
             BeanUtils.copyProperties(modbusResponse, primaryRadarData);
-                primaryRadarData.setRadarIp(radar.getRadarIp());
             primaryRadarData.setStationCode(radar.getStationCode());
             primaryRadarData.setRadarLocation(radar.getRadarLocation());
             //判断读取数据中是否携带标签
-
             if (!"0".equals(modbusResponse.getTagId())) {
+
                 // 根据标签去数据库查询标签列表
-                    sysIdentifier = identifierService.selectIdentifierByTag(tag);
+                // 标识器对象
+                SysIdentifier sysIdentifier = identifierService.selectIdentifierByTag(tag);
                 //判断数据库查询结果是否有数据
                 if (sysIdentifier != null) {
                     // 有数据将查询到的标识器配置属性放进原始数据对象
                     primaryRadarData.setLadleNumber(sysIdentifier.getLadleNumber());
                     primaryRadarData.setRadarIp(radar.getRadarIp());
-                        primaryRadarData.setType(sysIdentifier.getType().toString());
+                        if (modbusResponse.getValue4() != 0) {
-                        for (int i = 0; i < 20; i++) {
-                            dataList.add(primaryRadarData);
-                        }
-                        int count = 0;
-                        while (true){
-                            map.put(getMapKey(radar), dataList);
-                            if (count == 20){
-                                Date date = new Date();
-                                long milliseconds = date.getTime(); // 获取当前日期的毫秒数
-                                long newMilliseconds = milliseconds + (count * 200); // 加上次数乘以200毫秒
-                                Date newDate = new Date(newMilliseconds); // 转换成新的 Date 类型
-
-
-                                resolveDiscern(radar, primaryRadarData, map ,count,newDate ,date);
-                            }
-                            count++;
-                        }
-                        // 给雷达识别报表赋值
-                        //                            TsanaRadar tsanaRadar = new TsanaRadar();
-                        //                            tsanaRadar.setRadarCode(null);
-                        //                            tsanaRadar.setLabelCode(null);
-                        //                            tsanaRadar.setLocationIp(sysDiscern.getStationCode().toString());
-                        //                            tsanaRadar.setLabelNum(sysDiscern.getTagId());
-                        //                            tsanaRadar.setTimeBegin((java.sql.Date) sysDiscern.getCreateTime());
-                        //                            tsanaRadar.setTimeEnd((java.sql.Date) sysDiscern.getUpdateTime());
-                        //                            tsanaRadar.setTimeCount(count);
                             //
-                        //                            oracleInsert(tsanaRadar);
 
-                        // 没数据返回data.data == null
+                            //有效数据存储进临时集合，将数据放入进集合
-//                        if (Objects.isNull(data.getData())) {
+
-//                            // 连续5秒没读到数据，结束
+
-//                            if (current - noDataStart >= 5000) {
+                            // 有数据将查询到的标识器配置属性放进原始数据对象
-//                                // todo:存数据
+                            // 给雷达识别报表赋值
-//                                List<PrimaryRadarData> primaryRadarDataList = map.get(getMapKey(radar));
+                            SysIdentifier finalSysIdentifier = sysIdentifier;
-////                                primaryRadarDataList.stream().filter()
+                            CompletableFuture.runAsync(() -> {
-//                                noDataStart = current;
+                                sysDiscern.setType(finalSysIdentifier.getType());
-//                                continue;
+                                sysDiscern.setRadarLocation(radar.getRadarLocation());
-//                            }
+                                sysDiscern.setLadleNumber(finalSysIdentifier.getLadleNumber());
-//                        }
+                                sysDiscern.setCreateTime(new Date());
-//                        // 有数据返回数据
+                                sysDiscern.setNumber(modbusResponse.getNumber());
-//                        // 有id，且时间>=20000
+                                sysDiscern.setTagId(modbusResponse.getTagId());
-//                        if (data.getData().get(3) != 0 && current - start >= 20000) {
+                                sysDiscern.setValue4(modbusResponse.getValue4());
-//                            // todo:存数据
+                            } , executorService);
-//
+                        }
-//                            start = current;
-//                            continue;
-//                        }
                     }
-
-
                 } else {
-                    //连续10次读取标签号为0
-
                     // 没有配置过将铁包号置空
                     primaryRadarData.setLadleNumber(null);
                     primaryRadarData.setRadarIp(radar.getRadarIp());
                 }
                     CompletableFuture.runAsync(() -> {
-//                        primaryRadarDataService.insertPrimaryRadarData(primaryRadarData);
+                        primaryRadarDataService.insertPrimaryRadarData(primaryRadarData);
                     });
-                noDataStart = current;
             } catch (Exception e) {
             }
     }
-    }
-
-    private static String getMapKey(SysRadar radar) {
-        return radar.getRadarIp() + "-" + radar.getRadarNum();
-    }
-
-    private void resolveDiscern(SysRadar radar, PrimaryRadarData primaryRadarData, Map<String, List<PrimaryRadarData>> map , int count,Date newDate ,Date date) {
-        List<PrimaryRadarData> primaryRadarDataList1 = map.get(getMapKey(radar));
-
-        List<PrimaryRadarData> primaryRadarDataList = new ArrayList<>();
-        primaryRadarDataList.add(primaryRadarData);
-        map.put(getMapKey(radar), primaryRadarDataList);
-        List<String> numberList = convertStringToList(radar.getRadarNum());
-        SysDiscern sysDiscern = copyDataToDiscern(primaryRadarData);
-        // 给雷达识别报表赋值
-        sysDiscern.setType(Integer.parseInt(primaryRadarData.getType()));
-        sysDiscern.setRadarLocation(radar.getRadarLocation());
-        sysDiscern.setLadleNumber(primaryRadarData.getLadleNumber());
-        sysDiscern.setCreateTime(date );
-        sysDiscern.setTagId(primaryRadarData.getTagId());
-        sysDiscern.setCount(count);
-        sysDiscern.setUpdateTime(newDate);
-        sysDiscern.setStationCode(radar.getStationCode());
-        discernService.insertDiscern(sysDiscern);
-//        TsanaRadar tsanaRadar = new TsanaRadar();
-//        tsanaRadar.setRadarCode(null);
-//        tsanaRadar.setLabelCode(null);
-//        tsanaRadar.setLocationIp(sysDiscern.getStationCode().toString());
-//        tsanaRadar.setLabelNum(sysDiscern.getTagId());
-//        tsanaRadar.setTimeBegin((java.sql.Date) sysDiscern.getCreateTime());
-//        tsanaRadar.setTimeEnd((java.sql.Date) sysDiscern.getUpdateTime());
-//        tsanaRadar.setTimeCount(count);
-//
-//        oracleInsert(tsanaRadar);
-    }
 
     @Override
     public void addRadar(List<SysRadar> radarList) {
@@ -227,7 +149,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
 
     @Override
     public void delRadar(Long id) {
-        radarDelMap.put(id, "1");
+        radarDelMap.put(id,"1");
     }
 
 
@@ -248,11 +170,11 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
      * @param data
      * @return ModbusResponse
      */
-    private static SysDiscern copyDataToDiscern(PrimaryRadarData data) {
+    private static SysDiscern copyDataToDiscern(DataResponse data) {
         SysDiscern discern = new SysDiscern();
-        discern.setTagId(data.getTagId());
+        discern.setTagId(data.getData().get(3).toString());
-        discern.setValue4(data.getValue4());
+        discern.setValue4(data.getData().get(7));
-        discern.setNumber(data.getNumber());
+        discern.setNumber(data.getData().get(11));
         return discern;
     }
 
@@ -276,52 +198,4 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
         modbusResponse.setNumber(data.getData().get(11));
         return modbusResponse;
     }
-
-
-    private static void oracleInsert(TsanaRadar tsanaRadar) {
-        Connection connection = null;
-        PreparedStatement preparedStatement = null;
-        try {
-            Class.forName("oracle.jdbc.driver.OracleDriver");
-
-            String url = "jdbc:oracle:thin:@172.16.18.195:1523:xccb";
-            String user = "radartest";
-            String password = "radartest";
-            connection = DriverManager.getConnection(url,user,password);
-            System.out.println(" ============= 连接数据库成功 ==========");
-            //  ====================================================雷达编号，   标签编号，   工位代号，     标签号，    开始时间，     结束时间， 读取次数
-            String insertStatement = "INSERT INTO xccb.TS_ANARADAR (RADARCODE, LABELCODE, LOCATIONIP , LABELNUM , TIMEBEGIN , TIMEEND , TIMECOUNT) VALUES (?, ?, ?, ?, ?, ?, ?)";
-
-            preparedStatement = connection.prepareStatement(insertStatement);
-
-            preparedStatement.setString(1,null);
-            preparedStatement.setString(2,null);
-            preparedStatement.setString(3,tsanaRadar.getLocationIp());
-            preparedStatement.setString(4,tsanaRadar.getLabelNum());
-            preparedStatement.setDate(5,tsanaRadar.getTimeBegin());
-            preparedStatement.setDate(6,tsanaRadar.getTimeEnd());
-            preparedStatement.setInt(7,tsanaRadar.getTimeCount());
-
-            int i = preparedStatement.executeUpdate();
-            System.out.println("新增数据成功，新增数量：  " + i);
-        }catch (Exception e){
-            System.out.println("连接异常======" + e);
-        }finally {
-            // 关闭连接和statement
-            if (preparedStatement != null) {
-                try {
-                    preparedStatement.close();
-                } catch (SQLException e) {
-                    e.printStackTrace();
-                }
-            }
-            if (connection != null) {
-                try {
-                    connection.close();
-                } catch (SQLException e) {
-                    e.printStackTrace();
-                }
-            }
-        }
-    }
 }

ruoyi-system/src/main/resources/mapper/system/PrimaryRadarDataMapper.xml

@@ -17,8 +17,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 		<result property="number"     column="number"         />
 		<result property="radarLocation"     column="radar_location"         />
 		<result property="ladleNumber"     column="ladle_number"         />
-		<result property="stationCode" column="station_code" />
 		<result property="radarIp"     column="radar_ip"         />
+		<result property="stationCode" column="station_code"      />
 		<result property="totalCount" column="total_count"      />
 		<result property="type"        column="type"          />
 		<result property="createBy"      column="create_by"       />
@@ -30,7 +30,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 	</resultMap>
 
 	<select id="selectPrimaryRadarDataList" resultMap="PrimaryRadarDataResult">
-		select p.id,p.tag_id,p.value1,p.value2,p.value3,p.value4,p.value5,p.base_line,p.query_fre,p.number,p.radar_location,p.ladle_number,p.radar_ip, p.station_code,p.type,p.create_by,p.create_time,p.update_by,p.update_time,p.remark,p.del_flag from sys_primary_radar_data p
+		select p.id,p.tag_id,p.value1,p.value2,p.value3,p.value4,p.value5,p.base_line,p.query_fre,p.number,p.radar_location,p.ladle_number,p.radar_ip,p.create_by,p.create_time,p.update_by,p.update_time,p.remark,p.del_flag from sys_primary_radar_data p
 		where p.del_flag = '0'
 		<if test="radarLocation != null and radarLocation != ''">
 			AND p.radar_location like concat('%',#{radarLocation}, '%')
@@ -46,6 +46,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 		</if>
 	</select>
 
+<!--	<select id="selectRadarTable" resultMap="PrimaryRadarDataResult">-->
+<!--		SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id, create_time, update_time, total_count-->
+<!--		FROM (-->
+<!--		SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id, create_time, update_time,-->
+<!--		COUNT(*) OVER (PARTITION BY radar_location, ladle_number, number, value4, radar_ip, tag_id) AS total_count,-->
+<!--		ROW_NUMBER() OVER (PARTITION BY radar_location, ladle_number, number, value4, radar_ip, tag_id-->
+<!--		ORDER BY create_time, update_time) AS row_num-->
+<!--		FROM sys_primary_radar_data WHERE radar_ip IS NOT NULL  AND tag_id != 0-->
+<!--		) subquery-->
+<!--		WHERE row_num = 1-->
+<!--	</select>-->
+
 	<insert id="insertPrimaryRadarData">
 		insert into sys_primary_radar_data(
 		<if test="id != null and id != 0">id,</if>
@@ -57,9 +69,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 		value5,
 		base_line,
 		query_fre,
-		station_code,
 		number,
-		type,
 		<if test="radarLocation != null and radarLocation != ''">radar_location,</if>
 		<if test="ladleNumber != null and ladleNumber != ''">ladle_number,</if>
 		<if test="radarIp != null and radarIp != ''">radar_ip,</if>
@@ -77,9 +87,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 		#{value5},
 		#{baseLine},
 		#{queryFre},
-		#{stationCode},
 		#{number},
-		#{type},
 		<if test="radarLocation != null and radarLocation != ''">#{radarLocation},</if>
 		<if test="ladleNumber != null and ladleNumber != ''">#{ladleNumber},</if>
 		<if test="radarIp != null and radarIp != ''">#{radarIp},</if>
@@ -93,13 +101,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
 	<select id="selectRadarTable" resultMap="PrimaryRadarDataResult">
 
-		SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id, create_time, update_time, total_count
+		SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id,MIN(create_time) OVER () AS create_time,MAX(update_time) OVER () AS update_time, total_count,station_code,type
 		FROM (
-				 SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id, create_time, update_time,
+				 SELECT radar_location, ladle_number, number, value4, radar_ip, tag_id, create_time, update_time,station_code,type,
 						COUNT(*) OVER (PARTITION BY radar_location, ladle_number, number, value4, radar_ip, tag_id) AS total_count,
 						ROW_NUMBER() OVER (PARTITION BY radar_location, ladle_number, number, value4, radar_ip, tag_id
 							ORDER BY create_time, update_time) AS row_num
-				 FROM sys_primary_radar_data
+				 FROM sys_primary_radar_data WHERE radar_ip IS NOT NULL  AND tag_id != 0
 			 ) subquery
 		WHERE row_num = 1
 		<if test="tagId != null and tagId != ''">

ruoyi-system/src/main/resources/mapper/system/SysDiscernMapper.xml

@@ -11,7 +11,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 		<result property="radarLocation" 		 column="radar_location" />
 		<result property="count" 				 column="count" />
 		<result property="type" 				 column="type" />
-		<result property="stationCode"			 column="station_code" />
 		<result property="value4" 				 column="value4" />
 		<result property="number" 				 column="number" />
 		<result property="createTime"    		 column="create_time"     />
@@ -98,29 +97,27 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
 	<insert id="insertDiscern">
 		insert into sys_discern(
-		id,
+		<if test="id != null and id != 0">id,</if>
-		tag_id,
+		<if test="tagId != null and tagId != ''">tag_id,</if>
-		ladle_number,
+		<if test="ladleNumber != null and ladleNumber != ''">ladle_number,</if>
-		radar_location,
+		<if test="radarLocation != null and radarLocation != ''">radar_location,</if>
-		count,
+		<if test="count != null and count != ''">count,</if>
-		type,
+		<if test="type != null and type != ''">type,</if>
-		value4,
+		<if test="value4 != null and value4 != ''">value4,</if>
-		number,
+		<if test="number != null and number != ''">number,</if>
-		create_time,
+		<if test="createTime != null and createTime != ''">create_time,</if>
-		update_time,
+		<if test="updateTime != null and updateTime != ''">update_time,</if>
-		station_code
 		)values(
-		#{id},
+		<if test="id != null and id != 0">#{id},</if>
-		#{tagId},
+		<if test="tagId != null and tagId != ''">#{tagId},</if>
-		#{ladleNumber},
+		<if test="ladleNumber != null and ladleNumber != ''">#{ladleNumber},</if>
-		#{radarLocation},
+		<if test="radarLocation != null and radarLocation != ''">#{radarLocation},</if>
-		#{count},
+		<if test="count != null and count != ''">#{count},</if>
-		#{type},
+		<if test="type != null and type != ''">#{type},</if>
-		#{value4},
+		<if test="value4 != null and value4 != ''">#{value4},</if>
-		#{number},
+		<if test="number != null and number != ''">#{number},</if>
-		#{createTime},
+		<if test="createTime != null" >#{createTime},</if>
-		#{updateTime},
+		<if test="updateTime != null" >#{updateTime},</if>
-		#{stationCode}
 		)
 	</insert>