From 5b04a8ac44a05e20a48b654ead38a911b9c47d8a Mon Sep 17 00:00:00 2001
From: wxyclub <tjzdwxy@163.com>
Date: Wed, 25 Oct 2023 14:57:03 +0800
Subject: [PATCH] =?UTF-8?q?add=EF=BC=9A=E6=94=BF=E7=AD=96=E8=AF=BE?=
 =?UTF-8?q?=E9=A2=98=E5=85=A5=E4=BC=9A=E6=B5=81=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ActSarLawsTopicEOController.java          | 48 +++++++++++++++++++
 .../service/ActSarLawsTopicEOService.java     | 41 ++++++++++++++++
 2 files changed, 89 insertions(+)
 create mode 100644 adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarLawsTopicEOController.java
 create mode 100644 adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarLawsTopicEOService.java

diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarLawsTopicEOController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarLawsTopicEOController.java
new file mode 100644
index 00000000..1365d7cb
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/ActSarLawsTopicEOController.java
@@ -0,0 +1,48 @@
+package com.adc.da.workFlow.controller;
+
+import com.adc.da.http.ResponseMessage;
+import com.adc.da.http.Result;
+import com.adc.da.workFlow.service.ActSarLawsTopicEOService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+/**
+ * @author tjzdw
+ * @description 政策课题流程
+ * @date 2023/10/25
+ */
+
+@Api("政策课题")
+@RestController
+@RequestMapping("/${restPath}/lawss/sarLawsTopic")
+public class ActSarLawsTopicEOController {
+
+    @Resource
+    private ActSarLawsTopicEOService lawsTopicEOService;
+
+    @ApiOperation("政策课题入会")
+    @PostMapping("/processLawsTopicMembership")
+    public ResponseMessage<String> processLawsTopicMembership(String infoJson){
+        if (StringUtils.isBlank(infoJson)) {
+            return Result.error("传入数据json不能为空");
+        }
+        lawsTopicEOService.processLawsTopicMembership(infoJson);
+        return Result.success("入会成功");
+    }
+
+    @ApiOperation("政策课题参会")
+    @PostMapping("/processLawsTopicParticipation")
+    public ResponseMessage<String> processLawsTopicParticipation(String infoJson){
+        if (StringUtils.isBlank(infoJson)) {
+            return Result.error("传入数据json不能为空");
+        }
+        lawsTopicEOService.processLawsTopicParticipation(infoJson);
+        return Result.success("参会成功");
+    }
+}
diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarLawsTopicEOService.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarLawsTopicEOService.java
new file mode 100644
index 00000000..483548f3
--- /dev/null
+++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/service/ActSarLawsTopicEOService.java
@@ -0,0 +1,41 @@
+package com.adc.da.workFlow.service;
+
+import com.adc.da.exception.AdcDaBaseException;
+import com.adc.da.slrs.sarLawsTopic.entity.SarLawsTopic;
+import com.adc.da.slrs.sarLawsTopic.service.SarLawsTopicService;
+import com.alibaba.fastjson.JSONObject;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+/**
+ * @author tjzdw
+ * @description
+ * @date 2023/10/25
+ */
+@Service
+@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
+public class ActSarLawsTopicEOService {
+
+    @Resource
+    private SarLawsTopicService lawsTopicService;
+
+    private static final Logger logger = LoggerFactory.getLogger(ActSarLawsTopicEOService.class);
+
+    public void processLawsTopicMembership(String lawsTopicInfo) {
+        SarLawsTopic sarLawsTopic = JSONObject.parseObject(lawsTopicInfo, SarLawsTopic.class);
+        if (sarLawsTopic == null) {
+            throw new AdcDaBaseException("入库失败，政策课题信息出错");
+        }
+        logger.info("政策课题入会：" + sarLawsTopic);
+        lawsTopicService.addLawsTopicInfo(sarLawsTopic);
+    }
+
+    public void processLawsTopicParticipation(String infoJson) {
+
+    }
+}