传感器-GPS

api-common/src/main/java/api/common/pojo/param/model/GpsParam.java

@@ -0,0 +1,17 @@
+package api.common.pojo.param.model;
+
+
+import lombok.Data;
+
+@Data
+public class GpsParam {
+
+    //主键id
+    private String id;
+    //车辆名称
+    private String sensorName;
+    //创建人id
+    private String createUserId;
+    //是否分享
+    private String share;
+}

api-common/src/main/java/api/common/pojo/po/model/GpsPO.java

@@ -0,0 +1,27 @@
+package api.common.pojo.po.model;
+
+import api.common.pojo.common.CommonPO;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+@Data
+public class GpsPO extends CommonPO {
+
+    //主键id
+    private String id;
+    //传感器id
+    private String sensorId;
+    //传感器名称
+    private String sensorName;
+    //传感器描述
+    private String description;
+    //经度偏移量
+    private BigDecimal longitudeOffset;
+    //维度偏移量
+    private BigDecimal latitudeOffset;
+    //帧率
+    private BigDecimal frameRate;
+    //是否分享
+    private String share;
+}

api-common/src/main/java/api/common/pojo/vo/model/GpsVO.java

@@ -0,0 +1,26 @@
+package api.common.pojo.vo.model;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+@Data
+public class GpsVO {
+
+    //主键id
+    private String id;
+    //传感器id
+    private String sensorId;
+    //传感器名称
+    private String sensorName;
+    //传感器描述
+    private String description;
+    //经度偏移量
+    private BigDecimal longitudeOffset;
+    //维度偏移量
+    private BigDecimal latitudeOffset;
+    //帧率
+    private BigDecimal frameRate;
+    //是否分享
+    private String share;
+}

simulation-resource-server/src/main/java/com/css/simulation/resource/model/ctrl/GpsCtrl.java

@@ -0,0 +1,103 @@
+package com.css.simulation.resource.model.ctrl;
+
+
+import api.common.pojo.common.ResponseBodyVO;
+import api.common.pojo.param.model.GpsParam;
+import api.common.pojo.po.model.GpsPO;
+import api.common.pojo.vo.model.GpsVO;
+import api.common.util.ObjectUtil;
+import com.css.simulation.resource.model.service.GpsService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.util.List;
+
+@Controller
+@RequestMapping("/gps")
+public class GpsCtrl {
+
+    @Autowired
+    GpsService gpsService;
+
+    /**
+     * 获取列表
+     */
+    @RequestMapping("/getGpsList")
+    @ResponseBody
+    public ResponseBodyVO<List<GpsVO>> getGpsList(@RequestBody GpsParam gpsParam){
+        ResponseBodyVO<List<GpsVO>> response = new ResponseBodyVO<List<GpsVO>>(ResponseBodyVO.Response.SUCCESS);
+        response.setInfo(gpsService.getGpsList(gpsParam));
+        return response;
+    }
+
+    /**
+     * 获取私有列表
+     */
+    @RequestMapping("/getMyGpsList")
+    @ResponseBody
+    public ResponseBodyVO<List<GpsVO>> getMyCameraList(@RequestBody GpsParam gpsParam){
+        ResponseBodyVO<List<GpsVO>> response = new ResponseBodyVO<List<GpsVO>>(ResponseBodyVO.Response.SUCCESS);
+        response.setInfo(gpsService.getMyGpsList(gpsParam));
+        return response;
+    }
+
+    /**
+     * 根据id获取详情
+     */
+    @RequestMapping("/getGpsInfo")
+    @ResponseBody
+    public ResponseBodyVO<GpsVO> getGpsInfo(@RequestBody GpsParam gpsParam){
+        ResponseBodyVO<GpsVO> response = new ResponseBodyVO<GpsVO>(ResponseBodyVO.Response.SUCCESS);
+        response.setInfo(gpsService.getGpsInfo(gpsParam));
+        return response;
+    }
+
+    /**
+     * 新增、修改、另存为
+     */
+    @RequestMapping("/saveGps")
+    @ResponseBody
+    public ResponseBodyVO<GpsPO> saveGps(@RequestBody GpsPO gpsPO){
+        if(ObjectUtil.isNull(gpsPO)){
+            return new ResponseBodyVO(false, 500, "参数必传！",null);
+        }
+        ResponseBodyVO<GpsPO> response = new ResponseBodyVO<GpsPO>(ResponseBodyVO.Response.SUCCESS);
+        GpsPO po = gpsService.saveGps(gpsPO);
+        if(ObjectUtil.isNull(po.getId())){
+            return new ResponseBodyVO(false, 500, "传感器名称重复！",null);
+        }
+        response.setInfo(po);
+        return response;
+    }
+
+    /**
+     * 分享
+     */
+    @RequestMapping("/shareGps")
+    @ResponseBody
+    public ResponseBodyVO<GpsPO> shareGps(@RequestBody GpsPO gpsPO){
+        if(ObjectUtil.isNull(gpsPO)){
+            return new ResponseBodyVO(false, 500, "参数必传！",null);
+        }
+        ResponseBodyVO<GpsPO> response = new ResponseBodyVO<GpsPO>(ResponseBodyVO.Response.SUCCESS);
+        response.setInfo(gpsService.shareGps(gpsPO));
+        return response;
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delGpsById")
+    @ResponseBody
+    public ResponseBodyVO delGpsById(@RequestBody GpsPO gpsPO){
+        int i = gpsService.delGpsById(gpsPO);
+        if(i>0){
+            return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS);
+        }else{
+            return new ResponseBodyVO(false, 500, "删除失败！",null);
+        }
+    }
+}

simulation-resource-server/src/main/java/com/css/simulation/resource/model/mapper/GpsMapper.java

@@ -0,0 +1,27 @@
+package com.css.simulation.resource.model.mapper;
+
+
+import api.common.pojo.param.model.GpsParam;
+import api.common.pojo.po.model.GpsPO;
+import api.common.pojo.vo.model.GpsVO;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Mapper
+@Repository
+public interface GpsMapper {
+
+    List<GpsVO> getGpsList(GpsParam gpsParam);
+
+    GpsVO getGpsInfo(GpsParam gpsParam);
+
+    List<GpsVO> checkGpsName(GpsPO gpsPO);
+
+    void insert(GpsPO gpsPO);
+
+    void update(GpsPO gpsPO);
+
+    int delGpsById(GpsPO gpsPO);
+}

simulation-resource-server/src/main/java/com/css/simulation/resource/model/service/GpsService.java

@@ -0,0 +1,93 @@
+package com.css.simulation.resource.model.service;
+
+import api.common.pojo.constants.DictConstants;
+import api.common.pojo.param.model.GpsParam;
+import api.common.pojo.po.model.GpsPO;
+import api.common.pojo.vo.model.GpsVO;
+import api.common.util.ObjectUtil;
+import api.common.util.StringUtil;
+import api.common.util.TimeUtil;
+import com.css.simulation.resource.common.utils.AuthUtil;
+import com.css.simulation.resource.model.mapper.GpsMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.sql.Timestamp;
+import java.util.List;
+
+@Service
+public class GpsService {
+
+    @Autowired
+    GpsMapper gpsMapper;
+
+    public List<GpsVO> getGpsList(GpsParam gpsParam) {
+        gpsParam.setCreateUserId(AuthUtil.getCurrentUserId());
+        gpsParam.setShare(null);
+        List<GpsVO> list = gpsMapper.getGpsList(gpsParam);
+        return list;
+    }
+
+    public List<GpsVO> getMyGpsList(GpsParam gpsParam) {
+        gpsParam.setCreateUserId(AuthUtil.getCurrentUserId());
+        gpsParam.setShare(DictConstants.NO);
+        List<GpsVO> list = gpsMapper.getGpsList(gpsParam);
+        return list;
+    }
+
+    public GpsVO getGpsInfo(GpsParam gpsParam) {
+        return gpsMapper.getGpsInfo(gpsParam);
+    }
+
+    public GpsPO saveGps(GpsPO gpsPO) {
+        //常规字段赋值
+        String currentUserId = AuthUtil.getCurrentUserId();
+        Timestamp currentTime = TimeUtil.getNowForMysql();
+        gpsPO.setCreateUserId(currentUserId);
+        gpsPO.setCreateTime(currentTime);
+        gpsPO.setModifyUserId(currentUserId);
+        gpsPO.setModifyTime(currentTime);
+        gpsPO.setIsDeleted(DictConstants.NO);
+        //名称校验
+        List<GpsVO> list = gpsMapper.checkGpsName(gpsPO);
+        if(ObjectUtil.isNotNull(list)){
+            gpsPO.setId(null);
+            return gpsPO;
+        }
+        String id = gpsPO.getId();
+        if(ObjectUtil.isNull(id)){//新增
+            gpsPO.setId(StringUtil.getRandomUUID());
+            gpsPO.setSensorId(StringUtil.getRandomUUID());
+            gpsPO.setShare(DictConstants.NO);//私有
+            gpsMapper.insert(gpsPO);
+        }else{//修改
+            gpsMapper.update(gpsPO);
+        }
+        return gpsPO;
+    }
+
+    public GpsPO shareGps(GpsPO gpsPO) {
+        //常规字段赋值
+        String currentUserId = AuthUtil.getCurrentUserId();
+        Timestamp currentTime = TimeUtil.getNowForMysql();
+        gpsPO.setCreateUserId(currentUserId);
+        gpsPO.setCreateTime(currentTime);
+        gpsPO.setModifyUserId(currentUserId);
+        gpsPO.setModifyTime(currentTime);
+        gpsPO.setIsDeleted(DictConstants.NO);
+
+        gpsPO.setShare(DictConstants.YES);//转公有
+        gpsPO.setId(StringUtil.getRandomUUID());
+        gpsPO.setSensorId(StringUtil.getRandomUUID());
+        gpsMapper.insert(gpsPO);
+        return gpsPO;
+    }
+
+    public int delGpsById(GpsPO gpsPO) {
+        gpsPO.setIsDeleted(DictConstants.YES);
+        gpsPO.setModifyUserId(AuthUtil.getCurrentUserId());
+        gpsPO.setModifyTime(TimeUtil.getNowForMysql());
+        int i = gpsMapper.delGpsById(gpsPO);
+        return i;
+    }
+}

simulation-resource-server/src/main/resources/mapper/model/GpsMapper.xml

@@ -0,0 +1,107 @@
+<?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.css.simulation.resource.model.mapper.GpsMapper" >
+
+    <resultMap id="GpsVOVOMap" type="api.common.pojo.vo.model.GpsVO">
+        <id column="ID" property="id" jdbcType="VARCHAR" />
+    </resultMap>
+
+    <select id="getGpsList" parameterType="api.common.pojo.param.model.GpsParam" resultMap="GpsVOVOMap">
+        select
+            id,
+            sensor_name,
+            description,
+            share
+        from model_sensor_gps
+        where is_deleted = '0'
+        <if test="sensorName != null and sensorName != ''">
+            and sensor_name like CONCAT('%',#{sensorName,jdbcType=VARCHAR},'%')
+        </if>
+        <if test="share != null and share != ''">
+            and create_user_id = #{createUserId,jdbcType=VARCHAR}
+            and share = '0'
+        </if>
+        <if test="share == null or share == ''">
+            and (create_user_id = #{createUserId,jdbcType=VARCHAR} or share = '1')
+        </if>
+        order by create_time desc
+    </select>
+
+    <select id="getGpsInfo" parameterType="api.common.pojo.param.model.GpsParam" resultMap="GpsVOVOMap">
+        select
+            id,
+            sensor_id,
+            sensor_name,
+            description,
+            longitude_offset,
+            latitude_offset,
+            frame_rate,
+            share
+        from model_sensor_gps c
+        where c.id = #{id,jdbcType=VARCHAR} limit 1
+    </select>
+
+    <select id="checkGpsName" parameterType="api.common.pojo.po.model.GpsPO" resultMap="GpsVOVOMap">
+        select
+            id
+        from model_sensor_gps
+        where is_deleted = '0' and share = '0'
+          and sensor_name = #{sensorName,jdbcType=VARCHAR}
+          and create_user_id = #{createUserId,jdbcType=VARCHAR}
+          and id &lt;&gt; #{id,jdbcType=VARCHAR}
+    </select>
+
+    <insert id="insert" parameterType="api.common.pojo.po.model.GpsPO">
+        insert into model_sensor_gps(
+            id,
+            sensor_id,
+            sensor_name,
+            description,
+            longitude_offset,
+            latitude_offset,
+            frame_rate,
+            share,
+            create_time,
+            modify_time,
+            create_user_id,
+            modify_user_id,
+            is_deleted
+        )
+        values(
+            #{id,jdbcType=VARCHAR},
+            #{sensorId,jdbcType=VARCHAR},
+            #{sensorName,jdbcType=VARCHAR},
+            #{description,jdbcType=VARCHAR},
+            #{longitudeOffset,jdbcType=DECIMAL},
+            #{latitudeOffset,jdbcType=DECIMAL},
+            #{frameRate,jdbcType=DECIMAL},
+            #{share,jdbcType=VARCHAR},
+            #{createTime,jdbcType=TIMESTAMP},
+            #{modifyTime,jdbcType=TIMESTAMP},
+            #{createUserId,jdbcType=VARCHAR},
+            #{modifyUserId,jdbcType=VARCHAR},
+            #{isDeleted,jdbcType=VARCHAR}
+        )
+    </insert>
+
+    <update id="update" parameterType="api.common.pojo.po.model.GpsPO">
+        update model_sensor_gps set
+            sensor_id = #{sensorId,jdbcType=VARCHAR},
+            sensor_name = #{sensorName,jdbcType=VARCHAR},
+            description = #{description,jdbcType=VARCHAR},
+            longitude_offset = #{longitudeOffset,jdbcType=DECIMAL},
+            latitude_offset = #{latitudeOffset,jdbcType=DECIMAL},
+            frame_rate = #{frameRate,jdbcType=DECIMAL},
+            modify_time = #{modifyTime,jdbcType=TIMESTAMP},
+            modify_user_id = #{modifyUserId,jdbcType=VARCHAR}
+        where id = #{id,jdbcType=VARCHAR}
+    </update>
+
+    <update id="delGpsById" parameterType="api.common.pojo.po.model.GpsPO">
+        update model_sensor_gps set
+          modify_time = #{modifyTime,jdbcType=TIMESTAMP},
+          modify_user_id = #{modifyUserId,jdbcType=VARCHAR},
+          is_deleted = #{isDeleted,jdbcType=VARCHAR}
+        where id = #{id,jdbcType=VARCHAR}
+    </update>
+</mapper>