稽核类型

server/src/main/java/edp/core/inteceptor/CurrentPlatformMethodArgumentResolverInterface.java

@@ -35,3 +35,4 @@ public interface CurrentPlatformMethodArgumentResolverInterface extends HandlerM
                                   NativeWebRequest webRequest,
                                   WebDataBinderFactory binderFactory) throws Exception;
 }
+

server/src/main/java/edp/davinci/controller/AuditClassificationController.java

@@ -0,0 +1,139 @@
+package edp.davinci.controller;
+
+import edp.core.annotation.CurrentUser;
+import edp.davinci.common.controller.BaseController;
+import edp.davinci.core.common.Constants;
+import edp.davinci.core.common.ResultMap;
+import edp.davinci.model.AuditClassification;
+import edp.davinci.model.User;
+import edp.davinci.service.AuditClassificationService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
+import io.swagger.annotations.ApiResponses;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.*;
+import springfox.documentation.annotations.ApiIgnore;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.validation.Valid;
+import java.util.List;
+
+/**
+ *  稽核分类
+ */
+@Api(value = "/auditClassification", tags = "check", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+@ApiResponses(@ApiResponse(code = 404, message = "auditClassification not found"))
+@Slf4j
+@RestController
+@RequestMapping(value = Constants.BASE_API_PATH + "/auditClassification", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+public class AuditClassificationController extends BaseController {
+
+    @Autowired
+    private AuditClassificationService auditClassificationService;
+
+    /**
+     * 获取 主题
+     *
+     * @param user
+     * @param request
+     * @return
+     */
+    @ApiOperation(value = "get auditClassification")
+    @GetMapping(value = "/getAuditClassification")
+    public ResponseEntity getAuditClassification(@ApiIgnore @CurrentUser User user,
+                                         HttpServletRequest request) {
+
+        List<AuditClassification> auditClassifications = auditClassificationService.getAuditClassification();
+        return ResponseEntity.ok(new ResultMap(tokenUtils).successAndRefreshToken(request).payloads(auditClassifications));
+    }
+
+    /**
+     * 新建主题
+     *
+     * @param AuditClassification
+     * @param bindingResult
+     * @param user
+     * @param request
+     * @return
+     */
+    @ApiOperation(value = "create AuditClassification")
+    @PostMapping(value = "/createAuditClassification",consumes = MediaType.APPLICATION_JSON_VALUE)
+    public ResponseEntity createAuditClassification(@Valid @RequestBody AuditClassification auditClassification,
+                                            @ApiIgnore BindingResult bindingResult,
+                                            @ApiIgnore @CurrentUser User user,
+                                            HttpServletRequest request) {
+
+        if (bindingResult.hasErrors()) {
+            ResultMap resultMap = new ResultMap(tokenUtils).failAndRefreshToken(request).message(bindingResult.getFieldErrors().get(0).getDefaultMessage());
+            return ResponseEntity.status(resultMap.getCode()).body(resultMap);
+        }
+
+
+        auditClassification = auditClassificationService.createAuditClassification(auditClassification);
+
+        return ResponseEntity.ok(new ResultMap(tokenUtils).successAndRefreshToken(request).payload(auditClassification));
+    }
+
+    /**
+     * 修改AuditClassification
+     *
+     * @param id
+     * @param AuditClassification
+     * @param bindingResult
+     * @param user
+     * @param request
+     * @return
+     */
+    @ApiOperation(value = "update auditClassification")
+    @PutMapping(value = "/updateAuditClassification/{id}", consumes = MediaType.APPLICATION_JSON_VALUE)
+    public ResponseEntity updateAuditClassification(@PathVariable Long id,
+                                            @Valid @RequestBody AuditClassification auditClassification,
+                                            @ApiIgnore BindingResult bindingResult,
+                                            @ApiIgnore @CurrentUser User user,
+                                            HttpServletRequest request) {
+
+
+        if (invalidId(id) || !id.equals(auditClassification.getId())) {
+            ResultMap resultMap = new ResultMap(tokenUtils).failAndRefreshToken(request).message("Invalid auditClassification id");
+            return ResponseEntity.status(resultMap.getCode()).body(resultMap);
+        }
+
+        if (bindingResult.hasErrors()) {
+            ResultMap resultMap = new ResultMap(tokenUtils).failAndRefreshToken(request).message(bindingResult.getFieldErrors().get(0).getDefaultMessage());
+            return ResponseEntity.status(resultMap.getCode()).body(resultMap);
+        }
+
+        auditClassificationService.updateAuditClassification(auditClassification);
+        return ResponseEntity.ok(new ResultMap(tokenUtils).successAndRefreshToken(request));
+    }
+
+
+    /**
+     * 删除dataSubject
+     *
+     * @param id
+     * @param user
+     * @param request
+     * @return
+     */
+    @ApiOperation(value = "delete auditClassification")
+    @DeleteMapping("/deleteAuditClassification/{id}")
+    public ResponseEntity deleteAuditClassification(@PathVariable Long id,
+                                            @ApiIgnore @CurrentUser User user,
+                                            HttpServletRequest request) {
+        if (invalidId(id)) {
+            ResultMap resultMap = new ResultMap(tokenUtils).failAndRefreshToken(request).message("Invalid dataSubject id");
+            return ResponseEntity.status(resultMap.getCode()).body(resultMap);
+        }
+
+        auditClassificationService.deleteAuditClassification(id);
+
+        return ResponseEntity.ok(new ResultMap(tokenUtils).successAndRefreshToken(request));
+    }
+
+}

server/src/main/java/edp/davinci/dao/AuditClassificationMapper.java

@@ -0,0 +1,26 @@
+package edp.davinci.dao;
+
+import edp.davinci.model.AuditClassification;
+import org.apache.ibatis.annotations.Delete;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public interface AuditClassificationMapper
+{
+    int insert(AuditClassification auditClassification);
+
+    @Delete({"delete from `audit_classification` where id = #{id}"})
+    int deleteById(@Param("id") Long id);
+
+    int update(AuditClassification auditClassification);
+
+    @Select({"SELECT * from `audit_classification`"})
+    List<AuditClassification> getAuditClassificationList();
+
+    @Select({"select * from `audit_classification` where id = #{id}"})
+    AuditClassification getAuditClassification(@Param("id") Long id);
+}

server/src/main/java/edp/davinci/model/AuditClassification.java

@@ -0,0 +1,14 @@
+package edp.davinci.model;
+
+import edp.core.model.RecordInfo;
+import lombok.Data;
+
+@Data
+public class AuditClassification extends RecordInfo<AuditClassification> {
+
+    private Long id;
+
+    // 分类名称
+    private String name;
+
+}

server/src/main/java/edp/davinci/model/QualityTask.java

@@ -19,6 +19,8 @@ public class QualityTask extends RecordInfo<QualityTask>
 
     private Long viewId; // view id
 
+    private Long pId; // 分类ID
+
     private String metadataConfig; // [{"fieldName"："","fieldType":"","fieldAlias":"","subjectId":"","subjectName":""}]
 
 }

server/src/main/java/edp/davinci/service/AuditClassificationService.java

@@ -0,0 +1,19 @@
+package edp.davinci.service;
+
+import edp.core.exception.ServerException;
+import edp.davinci.model.AuditClassification;
+import edp.davinci.model.DataSubject;
+
+import java.util.List;
+
+public interface AuditClassificationService {
+
+    AuditClassification createAuditClassification(AuditClassification auditClassification) throws ServerException;
+
+    void updateAuditClassification(AuditClassification auditClassification);
+
+    List<AuditClassification> getAuditClassification();
+
+    void deleteAuditClassification(Long id);
+
+}

server/src/main/java/edp/davinci/service/impl/AuditClassificationServiceImpl.java

@@ -0,0 +1,41 @@
+package edp.davinci.service.impl;
+
+import edp.core.exception.ServerException;
+import edp.davinci.dao.AuditClassificationMapper;
+import edp.davinci.model.AuditClassification;
+import edp.davinci.model.DataSubject;
+import edp.davinci.service.AuditClassificationService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Slf4j
+@Service("auditClassificationService")
+public class AuditClassificationServiceImpl implements AuditClassificationService {
+
+    @Autowired
+    private AuditClassificationMapper auditClassificationMapper;
+
+    @Override
+    public AuditClassification createAuditClassification(AuditClassification auditClassification) throws ServerException {
+        auditClassificationMapper.insert(auditClassification);
+        return auditClassification;
+    }
+
+    @Override
+    public void updateAuditClassification(AuditClassification auditClassification) {
+        auditClassificationMapper.update(auditClassification);
+    }
+
+    @Override
+    public List<AuditClassification> getAuditClassification() {
+        return auditClassificationMapper.getAuditClassificationList();
+    }
+
+    @Override
+    public void deleteAuditClassification(Long id) {
+        auditClassificationMapper.deleteById(id);
+    }
+}

server/src/main/resources/mybatis/mapper/AuditClassification.xml

@@ -0,0 +1,32 @@
+<?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="edp.davinci.dao.AuditClassificationMapper">
+
+    <insert id="insert" parameterType="edp.davinci.model.AuditClassification">
+        insert into `audit_classification`
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="name != null">
+                `name`,
+            </if>
+            `create_by`,
+            `create_time`
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="name != null">
+                #{name,jdbcType=VARCHAR},
+            </if>
+            #{createBy,jdbcType=BIGINT},
+            #{createTime,jdbcType=TIMESTAMP}
+        </trim>
+    </insert>
+
+    <update id="update"  parameterType="edp.davinci.model.AuditClassification">
+        UPDATE audit_classification
+        <trim prefix="set" suffixOverrides=",">
+            <if test="name!=null">name=#{name}</if>
+        </trim>
+        WHERE id=#{id}
+    </update>
+
+
+</mapper>