Merge branch 'hz_dev' into base-modify

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/entity/Menu.java

@@ -25,6 +25,8 @@ public class Menu {
 
     private String type;
 
+    private String state;
+
     private String description;
 
     @Column(name = "crt_time")
@@ -167,6 +169,20 @@ public class Menu {
         this.type = type;
     }
 
+    /**
+     * @return state
+     */
+    public String getState() {
+        return state;
+    }
+
+    /**
+     * @param state
+     */
+    public void setState(String state) {
+        this.state = state;
+    }
+
     /**
      * @return description
      */

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/UserController.java

@@ -120,8 +120,8 @@ public class UserController extends CommonBaseController {
 
     @RequestMapping(value = "/front/menus", method = RequestMethod.GET)
     public @ResponseBody
-    List<MenuTree> getMenusByUsername(String token) throws Exception {
-        return permissionService.getMenusByUsername(token);
+    List<MenuTree> getMenusByUsername(String token,String state) throws Exception {
+        return permissionService.getMenusByUsername(token,state);
     }
 
     @RequestMapping(value = "/front/menu/all", method = RequestMethod.GET)

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rpc/service/PermissionService.java

@@ -170,13 +170,14 @@ public class PermissionService {
         return frontUser;
     }
 
-    public List<MenuTree> getMenusByUsername(String token) throws Exception {
+    public List<MenuTree> getMenusByUsername(String token,String state) throws Exception {
         String username = userAuthUtil.getInfoFromToken(token).getUniqueName();
         if (username == null) {
             return null;
         }
         User user = userBiz.getUserByUsername(username);
         List<Menu> menus = menuBiz.getUserAuthorityMenuByUserId(user.getId());
+        menus=menus.stream().filter(a->state.contains(a.getState())).collect(Collectors.toList());
         return getMenuTree(menus,AdminCommonConstant.ROOT);
     }
 }

ace-modules/ace-admin/src/main/resources/mapper/MenuMapper.xml

@@ -12,6 +12,7 @@
         <result column="href" jdbcType="VARCHAR" property="href"/>
         <result column="icon" jdbcType="VARCHAR" property="icon"/>
         <result column="type" jdbcType="CHAR" property="type"/>
+        <result column="state" jdbcType="INTEGER" property="state"/>
         <result column="description" jdbcType="VARCHAR" property="description"/>
         <result column="crt_time" jdbcType="DATE" property="crtTime"/>
         <result column="crt_user" jdbcType="VARCHAR" property="crtUser"/>

xx-universal/xx-universal-api/pom.xml

@@ -72,6 +72,17 @@
             <artifactId>junrar</artifactId>
             <version>0.7</version>
         </dependency>
+        <!-- jpush -->
+        <dependency>
+            <groupId>cn.jpush.api</groupId>
+            <artifactId>jpush-client</artifactId>
+            <version>3.3.7</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.jpush.api</groupId>
+            <artifactId>jiguang-common</artifactId>
+            <version>1.1.1</version>
+        </dependency>
     </dependencies>
 
 

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/biz/JPushBiz.java

+package com.xxfc.platform.universal.biz;
+
+
+import cn.jiguang.common.ClientConfig;
+import cn.jiguang.common.resp.APIConnectionException;
+import cn.jiguang.common.resp.APIRequestException;
+import cn.jpush.api.JPushClient;
+import cn.jpush.api.push.PushResult;
+import cn.jpush.api.push.model.PushPayload;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.universal.service.SmsService;
+import com.xxfc.platform.universal.utils.CCPRestSmsUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+@Service
+@Slf4j
+public class JPushBiz {
+
+
+    @Value("${universal.MASTER_SECRET}")
+    private  String MASTER_SECRET;
+    @Value("${universal.APP_KEY}")
+    private  String APP_KEY;
+
+    //推送给所有平台设备
+    public ObjectRestResponse jpushToAllPlat(String title){
+        ClientConfig clientConfig = ClientConfig.getInstance();
+        final JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, clientConfig);
+        PushPayload payload = PushPayload.alertAll(title);
+        try {
+            PushResult result = jpushClient.sendPush(payload);
+            log.debug("\n推送结果:"+result);
+           return  ObjectRestResponse.succ();
+        } catch (APIConnectionException e) {
+            // Connection error, should retry later
+            log.debug("\nConnection error, should retry later"+e);
+            return  ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,e.getMessage());
+        } catch (APIRequestException e) {
+            // Should review the error, and fix the request
+            log.debug("\nShould review the error, and fix the request"+ e);
+            log.debug("\nHTTP Status: " + e.getStatus());
+            log.debug("\nError Code: " + e.getErrorCode());
+            log.debug("\nError Message: " + e.getErrorMessage());
+            return  ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,e.getMessage());
+        }
+    }
+
+
+}

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/JPushController.java

+package com.xxfc.platform.universal.controller;
+
+
+
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.xxfc.platform.universal.biz.JPushBiz;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * 极光推送
+ */
+@RestController
+@RequestMapping("jpush")
+@IgnoreUserToken
+public class JPushController {
+
+       @Autowired
+       JPushBiz jPushBiz;
+
+
+
+    @RequestMapping(value = "/app/unauth/all", method = RequestMethod.GET) //匹配的是href中的download请求
+    public ObjectRestResponse sendSms(@RequestParam("title") String title) throws Exception {
+
+        return jPushBiz.jpushToAllPlat(title);
+    }
+}
+