feat:新增学会学术表的敏感存储

src/main/java/com/tykj/sjc/controller/QkhController.java

 package com.tykj.sjc.controller;
 
-import com.tykj.sjc.service.SjcAcademicianService;
-import com.tykj.sjc.service.SjcDcExpertService;
-import com.tykj.sjc.service.SjcLearnMemberService;
-import com.tykj.sjc.service.SjcScienceTechnologyService;
+import com.tykj.sjc.service.*;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -30,6 +27,8 @@ public class QkhController {
     @Resource
     private SjcScienceTechnologyService sjcScienceTechnologyService;
 
+    @Resource
+    private SjcActivityService sjcActivityService;
 
     @GetMapping("/saveDcExpert")
     @ApiOperation("专家信息存储")
@@ -49,6 +48,11 @@ public class QkhController {
         sjcScienceTechnologyService.saveScienceTechnology();
     }
 
+    @GetMapping("/saveActivity")
+    @ApiOperation("学会学术活动信息存储")
+    public void saveActivity(){
+        sjcActivityService.saveActivity();
+    }
 
     @GetMapping("/saveAll")
     @ApiOperation("青科汇数据仓所有数据存储")
@@ -59,6 +63,8 @@ public class QkhController {
         log.info("科技工作者信息存储完成");
         sjcScienceTechnologyService.saveScienceTechnology();
         log.info("青年科技工作者信息存储完成");
+        sjcActivityService.saveActivity();
+        log.info("学会学术活动信息存储完成");
         log.info("数据仓存储完成");
     }
 }

src/main/java/com/tykj/sjc/mapper/SjcActivityMapper.java

+package com.tykj.sjc.mapper;
+
+import com.tykj.sjc.qkh_entity.SjcActivity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.mapstruct.Mapper;
+
+/**
+* @author tykj
+* @description 针对表【sjc_activity】的数据库操作Mapper
+* @createDate 2023-11-17 17:27:48
+* @Entity com.tykj.sjc.qkh_entity.SjcActivity
+*/
+@Mapper
+public interface SjcActivityMapper extends BaseMapper<SjcActivity> {
+
+}
+
+
+
+

src/main/java/com/tykj/sjc/service/SjcActivityService.java

+package com.tykj.sjc.service;
+
+import com.tykj.sjc.qkh_entity.SjcActivity;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author tykj
+* @description 针对表【sjc_activity】的数据库操作Service
+* @createDate 2023-11-17 17:27:48
+*/
+public interface SjcActivityService extends IService<SjcActivity> {
+ void saveActivity();
+}

src/main/java/com/tykj/sjc/service/impl/SjcActivityServiceImpl.java

+package com.tykj.sjc.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.tykj.sjc.mapper.SjcAcademicianMapper;
+import com.tykj.sjc.qkh_entity.SjcAcademician;
+import com.tykj.sjc.qkh_entity.SjcActivity;
+import com.tykj.sjc.service.SjcActivityService;
+import com.tykj.sjc.mapper.SjcActivityMapper;
+import com.tykj.sjc.util.BillDTO;
+import com.tykj.sjc.util.BillRemote;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+* @author tykj
+* @description 针对表【sjc_activity】的数据库操作Service实现
+* @createDate 2023-11-17 17:27:48
+*/
+@Service
+@Slf4j
+public class SjcActivityServiceImpl extends ServiceImpl<SjcActivityMapper, SjcActivity>
+    implements SjcActivityService{
+    @Resource
+    private SjcActivityMapper sjcActivityMapper;
+
+    @Resource
+    private BillRemote billRemote;
+
+    @Override
+    @Transactional
+    public void saveActivity() {
+        List<SjcActivity> sjcActivityList = sjcActivityMapper.selectList(null);
+        List<SjcActivity> rs=new ArrayList<>();
+        for (SjcActivity sjcActivity : sjcActivityList) {
+            BillDTO build = BillDTO.builder()
+                    .s1(sjcActivity.getContacts())
+                    .build();
+            String randomId = billRemote.sendSaveBill(build);
+            sjcActivity.setRandomId(randomId);
+            rs.add(sjcActivity);
+        }
+        updateBatchById(rs);
+        log.info("院士信息存储了{}条数据",rs.size());
+    }
+}
+
+
+
+