完成富士签名

CODE/smart-community/property-api/pom.xml

@@ -210,8 +210,15 @@
             <scope>compile</scope>
         </dependency>
 
+		<!-- https://mvnrepository.com/artifact/commons-codec/commons-codec -->
+		<dependency>
+			<groupId>commons-codec</groupId>
+			<artifactId>commons-codec</artifactId>
+			<version>1.10</version>
+		</dependency>
+
 
-    </dependencies>
+	</dependencies>
 
 	<dependencyManagement>
 		<dependencies>

CODE/smart-community/property-api/src/main/java/com/community/huiju/common/perproties/DaSuProperties.java

@@ -21,4 +21,6 @@ public class DaSuProperties {
 
     private String appSecret;
 
+    private String communityId;
+
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/common/sign/DaSuSign.java

@@ -1,14 +1,20 @@
 package com.community.huiju.common.sign;
 
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.commons.lang3.StringUtils;
 
-import java.util.HashMap;
+import java.io.UnsupportedEncodingException;
+import java.time.LocalDateTime;
 import java.util.Map;
 import java.util.Set;
+import java.util.TreeMap;
 
 /**
  * 大苏签名校验
  */
+@Slf4j
 public class DaSuSign {
 
     /**
@@ -17,7 +23,7 @@ public class DaSuSign {
      * @param val_2
      * @return true 相等  false 不相等
      */
-    public boolean isMD5Sign(String val_1, String val_2) {
+    public static boolean isMD5Sign(String val_1, String val_2) {
         return StringUtils.equals(val_1, val_2);
     }
 
@@ -29,23 +35,49 @@ public class DaSuSign {
      * @param appSecret
      * @param datetime 时间戳
      * @param encrypt 加密方式(目前就 MD5)
-     * @param communityid 小区id
+     * @param communityId 小区id
      * @return
      */
-    public String createSign(String appid, String appSecret, String datetime, String encrypt, String communityid) {
-        return null;
-    }
+    public static String createSign(String appid, String appSecret, String datetime, String encrypt, String communityId){
+        TreeMap<String ,Object> treeMap = Maps.newTreeMap();
+        treeMap.put("appid", appid);
+        treeMap.put("datetime", datetime);
+        treeMap.put("encrypt", encrypt);
+        treeMap.put("communityid", communityId);
 
+        String sign = "";
 
-    public static void main(String[] args) {
-        Map<String, Object> map = new HashMap<>();
-        map.put("a", "1");
-        map.put("d", "4");
-        map.put("b", "2");
+        StringBuilder sb = new StringBuilder();
+        Set<Map.Entry<String, Object>> entries = treeMap.entrySet();
+        entries.forEach(e-> {
+            sb.append(e.getKey());
+            sb.append("=");
+            sb.append(e.getValue());
+            sb.append("&");
+        });
+
+        sign = sb.toString();
+        sign = sign.substring(0, sign.lastIndexOf("&"));
+
+        log.info("签名之前参数: {}" , sign);
+
+        try {
+            String str = new String(sign.getBytes("UTF-8"), "UTF-8");
+            sign = DigestUtils.md5Hex( str + appSecret);
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
 
-        Set<Map.Entry<String, Object>> entries = map.entrySet();
-        entries.forEach(e -> System.out.println(e.getKey()));
+        log.info("签名: {}" , sign);
+
+        return sign;
+    }
+
+    public static void main(String[] args) {
 
+        Long timeMillis = System.currentTimeMillis();
+        System.out.println(timeMillis);
+        String sign = createSign("dssdw2576sd997", "fgexhd855sf4", timeMillis + "", "md5", "101");
     }
 
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/controller/UserController.java

@@ -11,6 +11,7 @@ import com.community.huiju.model.TaUser;
 import com.community.huiju.model.User;
 import com.community.huiju.service.IUserService;
 import com.community.huiju.vo.UserVO;
+import com.google.common.collect.Maps;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -20,6 +21,7 @@ import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpSession;
+import java.util.Map;
 
 /**
  * <p>
@@ -165,4 +167,34 @@ public class UserController extends BaseController {
 		return responseBean;
 	}
 
+	@ApiOperation(value = "获取令牌", notes = "获取令牌")
+	@ApiImplicitParams({
+			@ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "appid", value = "提供的appid"),
+			@ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "datetime", value = "时间戳"),
+			@ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "encrypt", value = "encrypt加密方式(目前值为md5)"),
+			@ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "communityId", value = "提供的小区编号"),
+			@ApiImplicitParam(dataTypeClass = String.class, paramType = "query", name = "sign", value = "生成的签名"),
+	})
+	@RequestMapping(value = "/user/token", method = RequestMethod.GET)
+	public ResponseBean daSuToken(@RequestParam("appid") String appid,
+								  @RequestParam("datetime") String datetime,
+								  @RequestParam("encrypt") String encrypt,
+								  @RequestParam("communityId") String communityId,
+								  @RequestParam("sign") String sign,
+								  HttpSession session){
+		ResponseBean responseBean = new ResponseBean();
+		responseBean = userService.daSuToken(appid, datetime, encrypt, communityId, sign);
+		// 为 0 表示成功
+		if ("0".equals(responseBean.getCode())) {
+			UserVO userVO = (UserVO)responseBean.getData();
+			setUserElement(session,userVO);
+			userVO.setToken(session.getId());
+
+			Map<String, Object> map = Maps.newHashMap();
+			map.put("token", session.getId());
+			responseBean.addSuccess(map);
+		}
+		return responseBean;
+	}
+
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/IUserService.java

@@ -84,4 +84,14 @@ public interface IUserService extends IService<User> {
      */
     ResponseBean allUserRole(Integer communityId);
 
+    /**
+     * 大苏 token生成
+     * @param appid
+     * @param datetime 时间戳
+     * @param encrypt 加密方式(默认MD5)
+     * @param communityId 小区
+     * @param sign 传过来的签名
+     * @return
+     */
+    ResponseBean daSuToken(String appid,  String datetime, String encrypt, String communityId, String sign);
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/impl/UserServiceImpl.java

@@ -9,6 +9,8 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.community.commom.mode.ResponseBean;
 import com.community.commom.session.UserElement;
 import com.community.commom.utils.BeanTools;
+import com.community.huiju.common.perproties.DaSuProperties;
+import com.community.huiju.common.sign.DaSuSign;
 import com.community.huiju.dao.*;
 import com.community.huiju.dao.UserMapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -28,7 +30,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.time.LocalDateTime;
+import java.time.*;
 import java.util.*;
 
 /**
@@ -62,6 +64,8 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
     @Autowired
     private  TaUserMapper taUserMapper;
 
+    @Autowired
+    private DaSuProperties daSuProperties;
 
     @Override
     public ResponseBean login(String phone, Integer communityId, String code) {
@@ -449,4 +453,56 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
         return result;
     }
 
+
+    @Override
+    public ResponseBean daSuToken(String appid, String datetime, String encrypt, String communityId, String sign) {
+        ResponseBean responseBean = new ResponseBean();
+
+        LocalDateTime currrenDate = LocalDateTime.now();
+        LocalDateTime parameDate = Instant.ofEpochMilli(Long.parseLong(datetime)).atZone(ZoneId.systemDefault()).toLocalDateTime();
+
+        long minutes = Duration.between(parameDate, currrenDate).toMinutes();
+        if (minutes > 10) {
+            responseBean.addError("签名已过期!");
+            return responseBean;
+        }
+
+
+        // server 端签名
+        String serverSign = DaSuSign.createSign(daSuProperties.getAppid(), daSuProperties.getAppSecret(), datetime, encrypt, communityId);
+        boolean isMd5Sign = DaSuSign.isMD5Sign(serverSign, sign);
+        if (!isMd5Sign) {
+            responseBean.addError("签名错误!");
+            return responseBean;
+        }
+
+        if (!daSuProperties.getCommunityId().equals(communityId)) {
+            responseBean.addError("小区不正确!");
+            return responseBean;
+        }
+
+        if (!daSuProperties.getAppid().equals(appid)) {
+            responseBean.addError("appid 不正确!");
+            return responseBean;
+        }
+
+        QueryWrapper<ToCommunities> queryCommunityWrapper = new QueryWrapper<>();
+        queryCommunityWrapper.eq("id", communityId);
+        ToCommunities toCommunities = toCommunitiesMapper.selectOne(queryCommunityWrapper);
+
+
+        // 查询用户
+        QueryWrapper<User> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("login_name", toCommunities.getLoginName());
+        queryWrapper.eq("community_id", communityId);
+        User user = userMapper.selectOne(queryWrapper) ;
+
+        UserVO userVO = new UserVO();
+        // 查询该用户的权限
+        // 获取用户权限
+        getUserRole(user,userVO);
+
+        responseBean.addSuccess(userVO);
+        return responseBean;
+    }
 }

CODE/smart-community/property-api/src/main/resources/application.yml

@@ -41,4 +41,5 @@ fu-shi:
 da-su:
   appid: dssdw2576sd997
   app-secret: fgexhd855sf4
+  community-id: 101