1、优化推送密钥对接服务

src/main/java/com/chuanghai/controller/PushProjectController.java

@@ -29,6 +29,11 @@ public class PushProjectController {
     @Autowired
     private PushProjectService pushProjectService;
 
+//    @PostMapping("jjjj")
+//    public void ss(){
+//        System.out.println("11111");
+//    }
+
     /**
      * 查询推送项目
      * @return

src/main/java/com/chuanghai/controller/WxController.java

@@ -97,7 +97,7 @@ public class WxController {
             AesUtil aes = new AesUtil();
             String userString = aes.Decrypt(rawData, cKey, cIv);
             weixiaoPushDTO.setApp_secret(cIv);
-           // System.out.println(weixiaoPushDTO);
+//            System.out.println(weixiaoPushDTO);
             //推送微校通知
             pushProjectService.pushProject(weixiaoPushDTO);
             return ReturnValueUtil.ok();

src/main/java/com/chuanghai/service/impl/PushProjectServiceImpl.java

@@ -25,19 +25,21 @@ import java.util.Map;
 @Service
 public class PushProjectServiceImpl extends ServiceImpl<PushProjectMapper, PushProject> implements PushProjectService {
 
-   @Override
+    @Override
     public void pushProject(WeixiaoPushDTO weixiaoPushDTO) {
 
         String app_key = weixiaoPushDTO.getApp_key();
         String school_code = weixiaoPushDTO.getSchool_code();
         String event = weixiaoPushDTO.getEvent();
         String raw_data = weixiaoPushDTO.getRaw_data();
+        String app_secret = weixiaoPushDTO.getApp_secret();
 
         Map<String, String> tokenParams = new HashMap<>();
         tokenParams.put("app_key", app_key);
         tokenParams.put("school_code", school_code);
         tokenParams.put("event", event);
         tokenParams.put("raw_data", raw_data);
+        tokenParams.put("app_secret", app_secret);
 
         List<PushProject> pushProjectList = this.queryPushProject();
         pushProjectList.forEach(pushProject -> {
@@ -46,14 +48,14 @@ public class PushProjectServiceImpl extends ServiceImpl<PushProjectMapper, PushP
                 RestTemplate client = new RestTemplate();
                 ResponseEntity<String> tokenResponse = client.postForEntity(tokenUrl, tokenParams, String.class);
                 String body = tokenResponse.getBody();
-                log.info("微校推送服务接口状态=======》》推送项目:【{}】》》结果集:【{}】",pushProject.getProject(),body);
+                log.info("微校推送服务接口状态=======》》推送项目:【{}】》》结果集:【{}】", pushProject.getProject(), body);
 
                 ObjectMapper mapper = new ObjectMapper();
                 Map<String, Object> jsonMap = mapper.readValue(body, new TypeReference<Map<String, Object>>() {
                 });
                 String code = (String) jsonMap.get("code");
 
-            }catch (Exception e){
+            } catch (Exception e) {
                 throw new RRException(BizCodeEnume.FILE_IS_PUSH);
             }
         });
@@ -61,7 +63,8 @@ public class PushProjectServiceImpl extends ServiceImpl<PushProjectMapper, PushP
     }
 
     /**
-     *  添加推送项目
+     * 添加推送项目
+     *
      * @param url
      * @param project
      */
@@ -85,11 +88,12 @@ public class PushProjectServiceImpl extends ServiceImpl<PushProjectMapper, PushP
 
     /**
      * 查询有效的项目
+     *
      * @return
      */
-    public List<PushProject> queryPushProject(){
+    public List<PushProject> queryPushProject() {
         QueryWrapper<PushProject> wrapper = new QueryWrapper<>();
-        wrapper.eq("statu","0");
+        wrapper.eq("statu", "0");
         return this.list(wrapper);
     }
 }