feat: 增加风险管控相关接口

pom.xml

@@ -140,6 +140,14 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
         </dependency>
+
+        <!-- lombok-->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.22</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
     <!-- 导入Spring Cloud的依赖管理 -->

src/main/java/com/chinaitop/depot/storage/controller/RiskManagementController.java

@@ -0,0 +1,143 @@
+package com.chinaitop.depot.storage.controller;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.chinaitop.depot.storage.model.RiskManagement;
+import com.chinaitop.depot.storage.model.StorageFoodothercheck;
+import com.chinaitop.depot.storage.service.RiskManagementService;
+import com.chinaitop.depot.unissoft.model.ResponseEntity;
+import com.chinaitop.depot.utils.ParameterUtil;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.google.common.collect.Maps;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 风险管控ctrl
+ * @author aihua
+ * @date 2022-04-17 09:43
+ */
+@RestController
+@RequestMapping("/riskManagement")
+@Api(value = "RiskManagementController", description = "风险管控-主页")
+@RequiredArgsConstructor
+@Slf4j
+public class RiskManagementController {
+
+    private final RiskManagementService riskManagementService;
+
+    @RequestMapping(value = "/getList",produces = MediaType.APPLICATION_JSON_VALUE,method = RequestMethod.GET)
+    @ApiOperation(value="查询风险管控", notes = "查询风险管控信息列表，支持分页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query"),
+            @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query"),
+            @ApiImplicitParam(name = "orgId", value = "组织机构ID", paramType = "query"),
+            @ApiImplicitParam(name = "startDate", value = "开始日期", paramType = "query"),
+            @ApiImplicitParam(name = "endDate", value = "结束日期", paramType = "query")
+    })
+    public ResponseEntity<PageInfo<RiskManagement>> listPage(Integer pageNum, Integer pageSize, Integer orgId, String startDate, String endDate){
+        PageInfo<RiskManagement> pageInfo = new PageInfo<>();
+        if (orgId == null) {
+            return ResponseEntity.failed("组织机构ID不能为空！");
+        }
+        Map<String, Object> queryMap = Maps.newHashMap();
+        queryMap.put("pageNum", (pageNum - 1) * pageSize);
+        queryMap.put("pageSize", pageSize);
+        queryMap.put("startDate", startDate);
+        queryMap.put("endDate", endDate);
+        queryMap.put("orgId", orgId);
+        List<RiskManagement> riskManagements = riskManagementService.selectListPage(queryMap);
+        pageInfo.setList(riskManagements);
+        pageInfo.setPages(riskManagements.size());
+        pageInfo.setTotal(riskManagementService.getListPageTotal(queryMap));
+        return ResponseEntity.ok(pageInfo);
+    }
+
+    @RequestMapping(value = "/saveData", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value = "保存风险管控", notes = "保存风险管控")
+    @ApiImplicitParam(name = "riskJson", value = "JSON数据对象", paramType = "form")
+    public ResponseEntity saveData(String riskJson) {
+        try {
+            log.info(riskJson);
+            if (StringUtils.isNotBlank(riskJson)) {
+                RiskManagement riskManagement = JSONObject.parseObject(riskJson, RiskManagement.class);
+                riskManagementService.saveData(riskManagement);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseEntity.failed(e.getMessage());
+        }
+        return ResponseEntity.ok();
+    }
+
+    @RequestMapping(value = "/updateData", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value = "更新风险管控", notes = "更新风险管控")
+    @ApiImplicitParam(name = "riskJson", value = "JSON数据对象", paramType = "form")
+    public ResponseEntity updateData(String riskJson) {
+        try {
+            log.info(riskJson);
+            if (StringUtils.isNotBlank(riskJson)) {
+                RiskManagement riskManagement = JSONObject.parseObject(riskJson, RiskManagement.class);
+                if (riskManagement.getId() == null) {
+                    return ResponseEntity.failed("更新数据ID不能为空！");
+                }
+                riskManagementService.updateDate(riskManagement);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseEntity.failed(e.getMessage());
+        }
+        return ResponseEntity.ok();
+    }
+
+    @RequestMapping(value = "/deleteRisk", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value="根据主键id移除数据信息", notes = "根据主键id移除数据信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "数据ID", paramType = "form")
+    })
+    public ResponseEntity deleteRisk(Integer id) {
+        try {
+            if (id == null) {
+                return ResponseEntity.failed("数据ID不能为空！");
+            }
+            riskManagementService.deleteRisk(id);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseEntity.failed(e.getMessage());
+        }
+        return ResponseEntity.ok();
+    }
+
+    @RequestMapping(value = "queryById", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET)
+    @ApiOperation(value = "根据id加载对应数据", notes = "根据id加载对应数据")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "id", paramType = "query"),
+    })
+    public ResponseEntity<RiskManagement> queryById(Integer id) {
+        try {
+            if (id == null) {
+                return ResponseEntity.failed("数据ID不能为空！");
+            }
+            return ResponseEntity.ok(riskManagementService.queryById(id));
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseEntity.failed(e.getMessage());
+        }
+
+    }
+}

src/main/java/com/chinaitop/depot/storage/mapper/RiskManagementMapper.java

@@ -0,0 +1,56 @@
+package com.chinaitop.depot.storage.mapper;
+
+import com.chinaitop.depot.storage.model.RiskManagement;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author aihua
+ * @since 2022-04-17
+ */
+public interface RiskManagementMapper{
+
+    /**
+     * 分页查询风险管控list
+     * @param queryMap 查询条件
+     * @return {@link RiskManagement} list
+     */
+    List<RiskManagement> selectListPage(Map<String, Object> queryMap);
+
+    /**
+     * 查询分页的总记录数
+     * @param queryMap 查询条件
+     * @return 总记录数
+     */
+    long getListPageTotal(Map<String, Object> queryMap);
+
+    /**
+     * 新增风险管控
+     * @param riskManagement 风险管控实体
+     */
+    void insert(RiskManagement riskManagement);
+
+    /**
+     * 更新风险管控
+     * @param riskManagement 风险管控实体
+     */
+    void updateById(RiskManagement riskManagement);
+
+    /**
+     * 根据ID查询风险管控
+     * @param id 主键ID
+     * @return 风险管控
+     */
+    RiskManagement selectById(Integer id);
+
+    /**
+     * 删除风险管控
+     * @param id 主键ID
+     */
+    void deleteById(Integer id);
+}

src/main/java/com/chinaitop/depot/storage/mapper/RiskManagementMapper.xml

@@ -0,0 +1,137 @@
+<?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.chinaitop.depot.storage.mapper.RiskManagementMapper">
+
+    <select id="selectListPage" resultType="com.chinaitop.depot.storage.model.RiskManagement">
+        select skip #{pageNum} first #{pageSize}
+            id,
+            library_point_name as libraryPointName,
+            identify_person as identifyPerson,
+            link_part as linkPart,
+            risk_classification as riskClassification,
+            risk_type_id as riskTypeId,
+            risk_type_name as riskTypeName,
+            risk_identification as riskIdentification,
+            accident_type as accidentType,
+            risk_measures as riskMeasures,
+            responsible_dept as responsibleDept,
+            responsible_person as responsiblePerson,
+            org_id as orgId,
+            create_time as createTime
+        from
+            risk_management
+        where
+            org_id = #{orgId}
+        <if test="starDate != null and endDate != null" >
+            and create_time BETWEEN #{starDate} AND #{endDate}
+        </if>
+        <if test="starDate != null and endDate != null" >
+            and create_time &lt;= #{endDate}
+        </if>
+    </select>
+
+    <select id="getListPageTotal" resultType="long">
+        select count(1)
+        from
+        risk_management
+        where
+        org_id = #{orgId}
+        <if test="starDate != null and endDate != null" >
+            and create_time BETWEEN #{starDate} AND #{endDate}
+        </if>
+        <if test="starDate != null and endDate != null" >
+            and create_time &lt;= #{endDate}
+        </if>
+    </select>
+
+    <insert id="insert">
+        INSERT INTO risk_management
+        (id,library_point_name, identify_person, link_part, risk_classification, risk_type_id, risk_type_name, risk_identification,
+         accident_type, risk_measures, responsible_dept, responsible_person, org_id, create_time)
+        VALUES (SEQ_STORAGE_DEVICEKEEP.nextVal,
+                #{libraryPointName,jdbcType=VARCHAR},
+                #{identifyPerson,jdbcType=VARCHAR},
+                #{linkPart,jdbcType=VARCHAR},
+                #{riskClassification,jdbcType=VARCHAR},
+                #{riskTypeId,jdbcType=INTEGER},
+                #{riskTypeName,jdbcType=VARCHAR},
+                #{riskIdentification,jdbcType=VARCHAR},
+                #{accidentType,jdbcType=VARCHAR},
+                #{riskMeasures,jdbcType=VARCHAR},
+                #{responsibleDept,jdbcType=VARCHAR},
+                #{responsiblePerson,jdbcType=VARCHAR},
+                #{orgId,jdbcType=INTEGER},
+                #{createTime,jdbcType=VARCHAR})
+
+    </insert>
+
+    <update id="updateById">
+        UPDATE risk_management
+        <set>
+            <if test="libraryPointName != null">
+                library_point_name = #{libraryPointName,jdbcType=VARCHAR},
+            </if>
+            <if test="identifyPerson != null">
+                identify_person = #{identifyPerson,jdbcType=VARCHAR},
+            </if>
+            <if test="linkPart != null">
+                link_part = #{linkPart,jdbcType=VARCHAR},
+            </if>
+            <if test="riskClassification != null">
+                risk_classification = #{riskClassification,jdbcType=VARCHAR},
+            </if>
+            <if test="riskTypeId != null">
+                risk_type_id = #{riskTypeId,jdbcType=INTEGER},
+            </if>
+            <if test="riskTypeName != null">
+                risk_type_name = #{riskTypeName,jdbcType=VARCHAR},
+            </if>
+            <if test="riskIdentification != null">
+                risk_identification = #{riskIdentification,jdbcType=VARCHAR},
+            </if>
+            <if test="accidentType != null">
+                accident_type = #{accidentType,jdbcType=VARCHAR},
+            </if>
+            <if test="riskMeasures != null">
+                risk_measures = #{riskMeasures,jdbcType=VARCHAR},
+            </if>
+            <if test="responsibleDept != null">
+                responsible_dept = #{responsibleDept,jdbcType=VARCHAR},
+            </if>
+            <if test="responsiblePerson != null">
+                responsible_person = #{responsiblePerson,jdbcType=VARCHAR},
+            </if>
+            <if test="modifyTime != null">
+                modify_time = #{modifyTime,jdbcType=VARCHAR},
+            </if>
+        </set>
+        where id = #{id,jdbcType=INTEGER}
+    </update>
+
+    <select id="selectById" resultType="com.chinaitop.depot.storage.model.RiskManagement">
+        select
+            id,
+            library_point_name as libraryPointName,
+            identify_person as identifyPerson,
+            link_part as linkPart,
+            risk_classification as riskClassification,
+            risk_type_id as riskTypeId,
+            risk_type_name as riskTypeName,
+            risk_identification as riskIdentification,
+            accident_type as accidentType,
+            risk_measures as riskMeasures,
+            responsible_dept as responsibleDept,
+            responsible_person as responsiblePerson,
+            org_id as orgId,
+            create_time as createTime,
+            modify_time as modifyTime
+        from
+            risk_management
+        where id = #{id,jdbcType=INTEGER}
+    </select>
+
+    <delete id="deleteById">
+        delete from risk_management where id = #{id,jdbcType=INTEGER}
+    </delete>
+</mapper>
+

src/main/java/com/chinaitop/depot/storage/model/RiskManagement.java

@@ -0,0 +1,91 @@
+package com.chinaitop.depot.storage.model;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+/**
+ * <p>
+ * 风险管控model
+ * </p>
+ *
+ * @author jobob
+ * @since 2022-04-17
+ */
+@Data
+@Accessors(chain = true)
+public class RiskManagement {
+
+    private Integer id;
+
+    /**
+     * 库点名称
+     */
+    private String libraryPointName;
+
+    /**
+     * 识别人
+     */
+    private String identifyPerson;
+
+    /**
+     * 环节/部位
+     */
+    private String linkPart;
+
+    /**
+     * 风险分级
+     */
+    private String riskClassification;
+
+    /**
+     * 风险类型ID
+     */
+    private Integer riskTypeId;
+
+    /**
+     * 风险类型名称
+     */
+    private String riskTypeName;
+
+    /**
+     * 风险辨识
+     */
+    private String riskIdentification;
+
+    /**
+     * 可能导致事故类型
+     */
+    private String accidentType;
+
+    /**
+     * 风险管控措施
+     */
+    private String riskMeasures;
+
+    /**
+     * 责任部门
+     */
+    private String responsibleDept;
+
+    /**
+     * 责任人
+     */
+    private String responsiblePerson;
+
+    /**
+     * 组织机构ID
+     */
+    private Integer orgId;
+
+    /**
+     * 创建时间
+     */
+    private String createTime;
+
+    /**
+     * 修改时间
+     */
+    private String modifyTime;
+}

src/main/java/com/chinaitop/depot/storage/service/RiskManagementService.java

@@ -0,0 +1,51 @@
+package com.chinaitop.depot.storage.service;
+
+import com.chinaitop.depot.storage.model.RiskManagement;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 风险管控
+ * @author aihua
+ */
+public interface RiskManagementService {
+    /**
+     * 分页查询风险管控list
+     * @param queryMap 查询条件
+     * @return {@link RiskManagement} list
+     */
+    List<RiskManagement> selectListPage(Map<String, Object> queryMap);
+
+    /**
+     * 查询分页的总记录数
+     * @param queryMap 查询条件
+     * @return 总记录数
+     */
+    long getListPageTotal(Map<String, Object> queryMap);
+
+    /**
+     * 新增风险管控
+     * @param riskManagement 风险管控实体
+     */
+    void saveData(RiskManagement riskManagement);
+
+    /**
+     * 更新风险管控
+     * @param riskManagement 风险管控实体
+     */
+    void updateDate(RiskManagement riskManagement);
+
+    /**
+     * 根据ID查询风险管控
+     * @param id 主键ID
+     * @return 风险管控
+     */
+    RiskManagement queryById(Integer id);
+
+    /**
+     * 删除风险管控
+     * @param id 主键ID
+     */
+    void deleteRisk(Integer id);
+}

src/main/java/com/chinaitop/depot/storage/service/impl/RiskManagementServiceImpl.java

@@ -0,0 +1,84 @@
+package com.chinaitop.depot.storage.service.impl;
+
+import com.chinaitop.depot.storage.mapper.RiskManagementMapper;
+import com.chinaitop.depot.storage.model.RiskManagement;
+import com.chinaitop.depot.storage.service.RiskManagementService;
+import com.chinaitop.depot.utils.DateUtil;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 风险管控实现类
+ * @author aihua
+ * @date 2022-04-17 09:48
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class RiskManagementServiceImpl implements RiskManagementService {
+
+    private final RiskManagementMapper riskManagementMapper;
+
+    /**
+     * 分页查询风险管控list
+     * @param queryMap 查询条件
+     * @return {@link RiskManagement} list
+     */
+    @Override
+    public List<RiskManagement> selectListPage(Map<String, Object> queryMap) {
+        return riskManagementMapper.selectListPage(queryMap);
+    }
+
+    /**
+     * 查询分页的总记录数
+     * @param queryMap 查询条件
+     * @return 总记录数
+     */
+    @Override
+    public long getListPageTotal(Map<String, Object> queryMap) {
+        return riskManagementMapper.getListPageTotal(queryMap);
+    }
+
+    /**
+     * 新增风险管控
+     * @param riskManagement 风险管控实体
+     */
+    @Override
+    public void saveData(RiskManagement riskManagement) {
+        riskManagement.setCreateTime(DateUtil.getNow());
+        riskManagementMapper.insert(riskManagement);
+    }
+
+    /**
+     * 更新风险管控
+     * @param riskManagement 风险管控实体
+     */
+    @Override
+    public void updateDate(RiskManagement riskManagement) {
+        riskManagement.setModifyTime(DateUtil.getNow());
+        riskManagementMapper.updateById(riskManagement);
+    }
+
+    /**
+     * 根据ID查询风险管控
+     * @param id 主键ID
+     * @return 风险管控
+     */
+    @Override
+    public RiskManagement queryById(Integer id) {
+        return riskManagementMapper.selectById(id);
+    }
+
+    /**
+     * 删除风险管控
+     * @param id 主键ID
+     */
+    @Override
+    public void deleteRisk(Integer id) {
+        riskManagementMapper.deleteById(id);
+    }
+}

src/main/java/com/chinaitop/depot/utils/DateUtil.java

@@ -0,0 +1,18 @@
+package com.chinaitop.depot.utils;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * @author aihua
+ * @date 2022-04-16 14:10
+ */
+public class DateUtil {
+
+    public static final String FORMAT = "yyyy-MM-dd HH:mm:ss";
+
+    public static String getNow() {
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat(FORMAT);
+        return simpleDateFormat.format(new Date());
+    }
+}