逻辑修改

data-docking/src/main/java/com/qmth/data/docking/api/DataDockingController.java

@@ -16,6 +16,8 @@ import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.io.IOException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
 
 /**
  * <p>
@@ -49,7 +51,7 @@ public class DataDockingController {
     @RequestMapping(value = "/course", method = RequestMethod.GET)
     @ApiResponses({@ApiResponse(code = 200, message = "返回数据", response = ZufeCourseResult.class)})
     @Aac(auth = false)
-    public Result course(@ApiParam(value = "access_token", required = true) @RequestParam String accessToken) throws IOException {
+    public Result course(@ApiParam(value = "access_token", required = true) @RequestParam String accessToken) throws IOException, NoSuchAlgorithmException, KeyManagementException {
         zufeDataDockingUtil.course(accessToken);
         return ResultUtil.ok(true);
     }
@@ -59,7 +61,7 @@ public class DataDockingController {
     @RequestMapping(value = "/exam", method = RequestMethod.GET)
     @ApiResponses({@ApiResponse(code = 200, message = "返回数据", response = ZufeExamResult.class)})
     @Aac(auth = false)
-    public Result exam(@ApiParam(value = "access_token", required = true) @RequestParam String accessToken) throws IOException {
+    public Result exam(@ApiParam(value = "access_token", required = true) @RequestParam String accessToken) throws IOException, NoSuchAlgorithmException, KeyManagementException {
         zufeDataDockingUtil.exam(accessToken);
         return ResultUtil.ok(true);
     }

data-docking/src/main/java/com/qmth/data/docking/service/JobService.java

@@ -1,6 +1,8 @@
 package com.qmth.data.docking.service;
 
 import java.io.IOException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
 
 /**
  * @Description: job service
@@ -14,5 +16,5 @@ public interface JobService {
     /**
      * 同步浙财教务数据
      */
-    void syncZufeData() throws IOException;
+    void syncZufeData() throws IOException, NoSuchAlgorithmException, KeyManagementException;
 }

data-docking/src/main/java/com/qmth/data/docking/service/YjxtKcxxService.java

@@ -3,6 +3,8 @@ package com.qmth.data.docking.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.qmth.data.docking.entity.YjxtKcxx;
 
+import java.util.List;
+
 /**
  * <p>
  * 课程信息表 服务类
@@ -13,4 +15,12 @@ import com.qmth.data.docking.entity.YjxtKcxx;
  */
 public interface YjxtKcxxService extends IService<YjxtKcxx> {
 
+    /**
+     * 根据code和collegeName查找
+     *
+     * @param codeList
+     * @param collegeNameList
+     * @return
+     */
+    List<YjxtKcxx> findByCodeAndCollegeName(List<String> codeList, List<String> collegeNameList);
 }

data-docking/src/main/java/com/qmth/data/docking/service/YjxtKsxxService.java

@@ -3,6 +3,8 @@ package com.qmth.data.docking.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.qmth.data.docking.entity.YjxtKsxx;
 
+import java.util.List;
+
 /**
  * <p>
  * 考生数据表 服务类
@@ -13,4 +15,15 @@ import com.qmth.data.docking.entity.YjxtKsxx;
  */
 public interface YjxtKsxxService extends IService<YjxtKsxx> {
 
+    /**
+     * 查找数据
+     *
+     * @param xnmList
+     * @param xqmList
+     * @param courseCodeList
+     * @param paperNumberList
+     * @param studentCodeList
+     * @return
+     */
+    List<YjxtKsxx> findByField(List<String> xnmList, List<String> xqmList, List<String> courseCodeList, List<String> paperNumberList, List<String> studentCodeList);
 }

data-docking/src/main/java/com/qmth/data/docking/service/impl/JobServiceImpl.java

@@ -9,6 +9,8 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.io.IOException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
 import java.util.Objects;
 
 /**
@@ -29,7 +31,7 @@ public class JobServiceImpl implements JobService {
      * 同步浙财教务数据
      */
     @Override
-    public void syncZufeData() throws IOException {
+    public void syncZufeData() throws IOException, NoSuchAlgorithmException, KeyManagementException {
         TSToken tsToken = zufeDataDockingUtil.login(com.qmth.data.docking.util.zufe.Constants.KEY, com.qmth.data.docking.util.zufe.Constants.SECRET);
         if (Objects.nonNull(tsToken) && Objects.nonNull(tsToken.getAccessToken())) {
             zufeDataDockingUtil.course(tsToken.getAccessToken());

data-docking/src/main/java/com/qmth/data/docking/service/impl/YjxtKcxxServiceImpl.java

@@ -1,11 +1,14 @@
 package com.qmth.data.docking.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.qmth.data.docking.entity.YjxtKcxx;
 import com.qmth.data.docking.mapper.YjxtKcxxMapper;
 import com.qmth.data.docking.service.YjxtKcxxService;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 课程信息表 服务实现类
@@ -17,4 +20,17 @@ import org.springframework.stereotype.Service;
 @Service
 public class YjxtKcxxServiceImpl extends ServiceImpl<YjxtKcxxMapper, YjxtKcxx> implements YjxtKcxxService {
 
+    /**
+     * 根据code和collegeName查找
+     *
+     * @param codeList
+     * @param collegeNameList
+     * @return
+     */
+    @Override
+    public List<YjxtKcxx> findByCodeAndCollegeName(List<String> codeList, List<String> collegeNameList) {
+        QueryWrapper<YjxtKcxx> yjxtKcxxQueryWrapper = new QueryWrapper<>();
+        yjxtKcxxQueryWrapper.lambda().in(YjxtKcxx::getCode, codeList).and(x -> x.in(YjxtKcxx::getCollegeName, collegeNameList));
+        return this.list(yjxtKcxxQueryWrapper);
+    }
 }

data-docking/src/main/java/com/qmth/data/docking/service/impl/YjxtKsxxServiceImpl.java

@@ -1,11 +1,14 @@
 package com.qmth.data.docking.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.qmth.data.docking.entity.YjxtKsxx;
 import com.qmth.data.docking.mapper.YjxtKsxxMapper;
 import com.qmth.data.docking.service.YjxtKsxxService;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 考生数据表 服务实现类
@@ -17,4 +20,24 @@ import org.springframework.stereotype.Service;
 @Service
 public class YjxtKsxxServiceImpl extends ServiceImpl<YjxtKsxxMapper, YjxtKsxx> implements YjxtKsxxService {
 
+    /**
+     * 查找数据
+     *
+     * @param xnmList
+     * @param xqmList
+     * @param courseCodeList
+     * @param paperNumberList
+     * @param studentCodeList
+     * @return
+     */
+    @Override
+    public List<YjxtKsxx> findByField(List<String> xnmList, List<String> xqmList, List<String> courseCodeList, List<String> paperNumberList, List<String> studentCodeList) {
+        QueryWrapper<YjxtKsxx> yjxtKsxxQueryWrapper = new QueryWrapper<>();
+        yjxtKsxxQueryWrapper.lambda().in(YjxtKsxx::getXnm, xnmList)
+                .and(x -> x.in(YjxtKsxx::getXqm, xqmList))
+                .and(x -> x.in(YjxtKsxx::getCourseCode, courseCodeList))
+                .and(x -> x.in(YjxtKsxx::getPaperNumber, paperNumberList))
+                .and(x -> x.in(YjxtKsxx::getStudentCode, studentCodeList));
+        return this.list(yjxtKsxxQueryWrapper);
+    }
 }