ERP接口

k94314517

2023-12-14 7b3be7b18ddb0308190bf4463a63043b5b7649f9

ERP接口

 server/dmvisit_service/src/main/java/com/doumee/config/Jwt/JwtPayLoad.java

@@ -18,14 +18,14 @@
    /**
     * ç”¨æˆ·id
     */
    private Integer memberId;
    private String memberId;
    private long expire;


    public JwtPayLoad() {
    }

    public JwtPayLoad(Integer memberId) {
    public JwtPayLoad(String memberId) {
        this.memberId = memberId;
    }

@@ -52,7 +52,7 @@
            return new JwtPayLoad();
        } else {
            JwtPayLoad jwtPayLoad = new JwtPayLoad();
            jwtPayLoad.setMemberId((Integer) map.get("memberId"));
            jwtPayLoad.setMemberId((String) map.get("memberId"));

            return jwtPayLoad;
        }

 server/dmvisit_service/src/main/java/com/doumee/config/Jwt/JwtTokenUtil.java

@@ -126,7 +126,7 @@
    /**
     * ç”Ÿæˆtoken,根据userId和过期时间
     */
    public static String generateToken(Integer userId, Date exppiredDate, Map<String, Object> claims) {
    public static String generateToken(String userId, Date exppiredDate, Map<String, Object> claims) {

        final Date createdDate = new Date();
        String secret = getJwtSecret();

 server/dmvisit_service/src/main/java/com/doumee/config/Jwt/WebMvcConfig.java

@@ -1,14 +1,19 @@
package com.doumee.config.Jwt;

import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.config.annotation.ErpLoginRequired;
import com.doumee.config.annotation.LoginRequired;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.redis.RedisUtil;
import io.jsonwebtoken.JwtException;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.method.HandlerMethod;
@@ -26,6 +31,12 @@

    @Autowired
    private JdbcTemplate dao;

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Autowired
    private RedisTemplate<String,Object> redisTemplate;

    /**
     * æ·»åŠ æ‹¦æˆªå™¨
@@ -47,7 +58,7 @@
//                Method method = handlerMethod.getMethod();

                // æœ‰ @LoginRequired æ³¨è§£ï¼Œéœ€è¦ç™»å½•è®¤è¯
                if (beanType.isAnnotationPresent(LoginRequired.class)) {
                if (beanType.isAnnotationPresent(LoginRequired.class) || handlerMethod.hasMethodAnnotation(LoginRequired.class)) {
                    //获取token
                    String token = request.getHeader(JwtTokenUtil.HEADER_KEY);  // ä»Ž http è¯·æ±‚头中取出 token
                    if (StringUtils.isNotBlank(token)) {
@@ -55,12 +66,16 @@
                    } else {
                        throw new BusinessException(ResponseStatus.NO_LOGIN.getCode(),"未登录");
                    }
                }else if (handlerMethod.hasMethodAnnotation(LoginRequired.class)){
                    //获取token
                    String token = request.getHeader(JwtTokenUtil.HEADER_KEY);  // ä»Ž http è¯·æ±‚头中取出 token
                    if (StringUtils.isNotBlank(token)) {
                        checkLogin(request,response);
                    } else {
                } else if(beanType.isAnnotationPresent(ErpLoginRequired.class) || handlerMethod.hasMethodAnnotation(ErpLoginRequired.class)){
                    try {
                        //ERP ä¸šåŠ¡æ³¨è§£
                        String token = request.getHeader(JwtTokenUtil.HEADER_KEY);
                        String redisToken = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.ERP_TOKEN,String.class);
                        if(StringUtils.isBlank(redisToken)||!token.equals(redisToken)){
                            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未登录");
                        }
                        request.setAttribute(JwtTokenUtil.HEADER_KEY,token);
                    } catch (IllegalArgumentException | JwtException e) {
                        throw new BusinessException(ResponseStatus.NO_LOGIN.getCode(),"未登录");
                    }
//                    request.setAttribute("token", token);
@@ -68,7 +83,7 @@
                return true;
            }
        };
        registry.addInterceptor(TokenInterceptor).addPathPatterns("/web/**");
        registry.addInterceptor(TokenInterceptor).addPathPatterns("/web/**","/visitbiz/**");
    }


@@ -82,7 +97,7 @@
                throw new BusinessException(ResponseStatus.TOKEN_EXCEED_TIME.getCode(),"长时间未操作,请重新登录");
            }
            //获取账号ID
            Integer memberId = JwtTokenUtil.getJwtPayLoad(token).getMemberId();
            String memberId = JwtTokenUtil.getJwtPayLoad(token).getMemberId();
            Integer isDeleted = dao.queryForObject(" select COALESCE(DELETED,1)  from `system_user` where id  = ?", Integer.class, memberId);
            if(isDeleted== Constants.ONE){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户已删除,请联系管理员");

 server/dmvisit_service/src/main/java/com/doumee/config/annotation/ErpLoginRequired.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,10 @@
package com.doumee.config.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target({ElementType.METHOD,ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface ErpLoginRequired {}

 server/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/BaseRequst.java

@@ -1,8 +1,12 @@
package com.doumee.core.haikang.model.param;

import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;

@Data
public class BaseRequst<T> {
    private T data;
    @ApiModelProperty(hidden = true)
    private String token;
}

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/CarEventListRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -10,7 +11,7 @@
 */
@Data
@ApiModel("门禁出入事件同步请求信息")
public class CarEventListRequest {
public class CarEventListRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer eventId;
    @ApiModelProperty(value = "停车库编码（访客端ID）" )

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/DoorEventListRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -10,7 +11,7 @@
 */
@Data
@ApiModel("门禁出入事件同步请求信息")
public class DoorEventListRequest {
public class DoorEventListRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer eventId;
    @ApiModelProperty(value = "姓名,支持模糊匹配" )

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/OrgUpdateRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -12,20 +13,22 @@
 */
@Data
@ApiModel("组织信息更新请求信息")
public class OrgUpdateRequest {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer id;
    @ApiModelProperty(value = "名称" )
public class OrgUpdateRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,required = true)
    private String id;
    @ApiModelProperty(value = "名称" ,required = true)
    private String name;
    @ApiModelProperty(value = "上级组织编码")
    private String parentId;
    @ApiModelProperty(value = "是否已删除 0未删除 1已删除",example = "0")
    private int isdeleted  ;
    @ApiModelProperty(value = "状态 0启用 1禁用",example = "0")
    private int status  ;
    @ApiModelProperty(value = "更新时间,如2023-11-24 09:47:36")
    @ApiModelProperty(value = "更新时间,如2023-11-24 09:47:36",required = true)
    private Date editDate;
    @ApiModelProperty(value = "联系人姓名")
    @ApiModelProperty(value = "联系人姓名",required = true)
    private String linkName;
    @ApiModelProperty(value = "联系电话")
    @ApiModelProperty(value = "联系电话",required = true)
    private String linkPhone;

}

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/ParkListRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -10,7 +11,7 @@
 */
@Data
@ApiModel("停车库接口请求信息")
public class ParkListRequest {
public class ParkListRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer id;
    @ApiModelProperty(value = "名称,支持模糊匹配" )

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/RoleListRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -11,9 +12,10 @@
 */
@Data
@ApiModel("门禁组接口请求信息")
public class RoleListRequest {
public class RoleListRequest extends BaseRequst {
    @ApiModelProperty(value = "门禁组唯一标识" ,example = "1")
    private Integer id;
    @ApiModelProperty(value = "名称,支持模糊匹配" )
    private String name;

}

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/TokenRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.doumee.core.model.openapi.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

/**
 * åˆ†ç±»ä¿¡æ¯è¡¨
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("Token获取类")
public class TokenRequest {
    @ApiModelProperty(value = "访问key" ,example = "1")
    private String accessKey;
    @ApiModelProperty(value = "访问秘钥" )
    private String accessSecret;
}

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/UserUpdateRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -13,16 +14,16 @@
 */
@Data
@ApiModel("人员信息更新请求信息")
public class UserUpdateRequest {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer id;
    @ApiModelProperty(value = "姓名" )
public class UserUpdateRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,required = true)
    private String id;
    @ApiModelProperty(value = "姓名"  ,required = true)
    private String name;
    @ApiModelProperty(value = "证件号" )
    @ApiModelProperty(value = "证件号"  ,required = true)
    private String idNo;
    @ApiModelProperty(value = "证件类型 0身份证 1港澳通行证 2护照 ,默认为0" ,example = "0")
    @ApiModelProperty(value = "证件类型 0身份证 1港澳通行证 2护照 ,默认为0"  ,required = true)
    private int idType;
    @ApiModelProperty(value = "访客性别 1-男 2-女" ,example = "1")
    @ApiModelProperty(value = "访客性别 1-男 2-女"  ,required = true)
    private Integer sex;
    @ApiModelProperty(value = "是否已删除 0未删除 1已删除",example = "0")
    private int isdeleted  ;
@@ -30,11 +31,11 @@
    private int status  ;
    @ApiModelProperty(value = "更新时间,如2023-11-24 09:47:36")
    private Date editDate;
    @ApiModelProperty(value = "所属组织编码")
    private String orgId;
    @ApiModelProperty(value = "人脸照片地址")
    @ApiModelProperty(value = "所属组织编码" ,required = true)
    private Integer orgId;
    @ApiModelProperty(value = "人脸照片地址" ,required = true)
    private String faceImg;
    @ApiModelProperty(value = "工号")
    @ApiModelProperty(value = "工号" ,required = true)
    private String code;
    @ApiModelProperty(value = "手机号" , required = true)
    private String phone;

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/request/VisitListRequest.java

@@ -1,5 +1,6 @@
package com.doumee.core.model.openapi.request;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -10,7 +11,7 @@
 */
@Data
@ApiModel("访客出入事件同步请求信息")
public class VisitListRequest {
public class VisitListRequest extends BaseRequst {
    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer eventId;
    @ApiModelProperty(value = "访客名称,支持模糊匹配" )

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/response/CarEventListResponse.java

@@ -62,19 +62,4 @@
    @ApiModelProperty(value = "子品牌年款")
    private Integer subModel;

    @ApiModelProperty(value = "人员类型：0 æœªçŸ¥ï¼Œ1 æ™®é€šï¼Œ2 æ¥å®¾ï¼Œ3 é»‘名单，4 ç®¡ç†å‘˜",example = "1")
    private Integer type;
    @ApiModelProperty(value = "进出类型 1-进 0-出 -1:未知",example = "1" )
    private Integer eventInOut;
    @ApiModelProperty(value = "人员通道号" ,example = "1")
    private Integer extAccessChannel;
    @ApiModelProperty(value = "产生时间" )
    private String createTime ;
    @ApiModelProperty(value = "人手机号" )
    private String phone ;
    @ApiModelProperty(value = "人员Id（erp端用户编码）" )
    private String userId ;
    @ApiModelProperty(value = "所属组织Id(erp端组织编码)" )
    private String orgId     ;

}

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/response/DoorEventListResponse.java

@@ -17,7 +17,6 @@
    private Integer eventId;
    @ApiModelProperty(value = "事件类型 0-人脸认证通过（196893） 1-刷卡认证通过（198915）" )
    private String eventType;

    @ApiModelProperty(value = "性别 1-男 2-女" ,example = "1")
    private Integer sex;
    @ApiModelProperty(value = "设备名称" )

 server/dmvisit_service/src/main/java/com/doumee/core/model/openapi/response/ParkListResponse.java

@@ -15,7 +15,7 @@

    @ApiModelProperty(value = "唯一标识" ,example = "1")
    private Integer id;
    @ApiModelProperty(value = "" )
    @ApiModelProperty(value = "名称" )
    private String name;
    @ApiModelProperty(value = "状态 0禁用 1启用", example = "1")
    private Integer status;

 server/dmvisit_service/src/main/java/com/doumee/core/utils/Constants.java

@@ -50,7 +50,12 @@
    public static final String CAR_EVENT_IMG = "CAR_EVENT_IMG";
    public static final String DEVICE_EVENT_IMG = "DEVICE_EVENT_IMG";
    public static  boolean DEALING_HK_IMG = false;

    // ERP接口配置
    public static final String ERP_CONFIG = "ERP_CONFIG";
    // ERP ACCESS_KEY
    public static final String ERP_ACCESS_KEY = "ERP_ACCESS_KEY";
    // ERP ACCESS_SECRET
    public static final String ERP_ACCESS_SECRET = "ERP_ACCESS_SECRET";

    public static  Date  getBirthdyByCardNo(String idCard){
    if(idCard ==null || idCard.length()<14){
@@ -153,6 +158,7 @@




    public static final String WX_PLATFORM = "WX_PLATFORM";
    public static final String WX_PLATFORM_ACCESS_TOKEN = "WX_PLATFORM_ACCESS_TOKEN";
    public static final String WX_PLATFORM_APPID = "WX_PLATFORM_APPID";
@@ -164,6 +170,9 @@


    public interface RedisKeys {
        public static final String ERP_TOKEN ="ERP_TOKEN";
        public static final long EXPIRE_TIME = 7200;

        public static final String GOODSORDER_KEY = "ordercode_";
        public static final String ACTIVITY_SIGN_KEY = "actcode_";
        public static final String AFTERSALE_KEY = "salecode_";

 server/dmvisit_service/src/main/java/com/doumee/core/utils/redis/RedisConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.doumee.core.utils.redis;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * @author jiangping
 * @date 2021-8-10 14:40:35
 * redis配置
 */
@Configuration
public class RedisConfig {

    @Bean
    @SuppressWarnings("all")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(factory);
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        // key采用String的序列化方式
        template.setKeySerializer(stringRedisSerializer);
        // hash的key也采用String的序列化方式
        template.setHashKeySerializer(stringRedisSerializer);
        // value序列化方式采用jackson
        template.setValueSerializer(jackson2JsonRedisSerializer);
        // hash的value序列化方式采用jackson
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
}
/*@Configuration
public class RedisConfig {

    *//**
     * @param factory
     * @return è‡ªå®šä¹‰redisTemplate，自带的bean没有序列化器
     *//*
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(factory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());//设置key的序列化器
        redisTemplate.setValueSerializer(new RedisConverter());//设置值的序列化器
        return redisTemplate;
    }

}*/

 server/dmvisit_service/src/main/java/com/doumee/core/utils/redis/RedisConverter.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package com.doumee.core.utils.redis;
import org.springframework.core.convert.converter.Converter;
import org.springframework.core.serializer.support.DeserializingConverter;
import org.springframework.core.serializer.support.SerializingConverter;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;

/**
 * @author å½­ä¼Ÿ
 * @date 2018/8/28 9:31
 */
public class RedisConverter implements RedisSerializer<Object> {
    private Converter<Object, byte[]> serializer = new SerializingConverter();//序列化器
    private Converter<byte[], Object> deserializer = new DeserializingConverter();//反序列化器

    @Override
    public byte[] serialize(Object o) throws SerializationException {//将对象序列化成字节数组
        if (o == null) return new byte[0];
        try {
            return serializer.convert(o);
        } catch (Exception e) {
            e.printStackTrace();
            return new byte[0];
        }
    }

    @Override
    public Object deserialize(byte[] bytes) throws SerializationException {//将字节数组反序列化成对象
        if (bytes == null || bytes.length == 0) return null;
        try {
            return deserializer.convert(bytes);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

}

 server/dmvisit_service/src/main/java/com/doumee/core/utils/redis/RedisUtil.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,86 @@
package com.doumee.core.utils.redis;

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;

import java.util.concurrent.TimeUnit;

public class RedisUtil {
    /**
     * æ·»åŠ ä¸€ä¸ªValue为String
     * @param stringRedisTemplate
     * @param key
     * @param str
     */
    public static void addString( StringRedisTemplate stringRedisTemplate, String key, String str) {
        //1,添加一个Value为String
        stringRedisTemplate.opsForValue().set(key, str);

    }

    /**
     * æ ¹æ®key删除字符串缓存
     * @param stringRedisTemplate
     * @param key
     */
    public static void delString( StringRedisTemplate stringRedisTemplate, String key ) {
        //1,添加一个Value为String
        stringRedisTemplate.delete(key);

    }

    /**
     * æ ¹æ®key删除对象数据
     * @param redisTemplate
     * @param key
     */
    public static void deleteObject( RedisTemplate<String, Object> redisTemplate  , String key ) {

        redisTemplate.delete(key);

    }
    /**
     * æ·»åŠ ä¸€ä¸ªValue为对象
     * @param redisTemplate
     * @param key
     * @param obj
     */
    public static void addObject(RedisTemplate<String, Object> redisTemplate  , String key, Object obj) {
        redisTemplate.opsForValue().set(key, obj);
    }
    /**
     * æ·»åŠ ä¸€ä¸ªValue为对象
     * @param redisTemplate
     * @param key
     * @param obj
     */
    public static void addObject(RedisTemplate<String, Object> redisTemplate  , String key, Object obj,long time) {
//        redisTemplate.opsForValue().set(key, obj);
        redisTemplate.opsForValue().set(key,obj,time, TimeUnit.SECONDS);
    }

    /**
     * æ ¹æ®å‚数对象类型，返回相应缓存对象数据
     * @param stringRedisTemplate
     * @param key
     * @return
     */
    public static String getString(StringRedisTemplate stringRedisTemplate, String key){
       String val = stringRedisTemplate.opsForValue().get(key);
        return val;
    }

    /**
     * æ ¹æ®å‚数对象类型，返回相应缓存对象数据
     * @param redisTemplate
     * @param key
     * @param clazz
     * @param <T>
     * @return
     */
    public static <T> T getObject(RedisTemplate<String, Object> redisTemplate  , String key,Class<T> clazz){
        T t = (T) redisTemplate.opsForValue().get(key);
        return t;
    }

}

 server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Company.java

@@ -114,6 +114,7 @@
    @ApiModelProperty(value = "ERP标识")
    @ExcelColumn(name="ERP标识")
    private String erpId;

    @ApiModelProperty(value = "负责人编码（关联member)")
    @ExcelColumn(name="负责人编码")
    private String headId;

 server/dmvisit_service/src/main/java/com/doumee/dao/business/model/Member.java

@@ -152,7 +152,7 @@

    @ApiModelProperty(value = "ERP标识", example = "1")
    @ExcelColumn(name="ERP标识")
    private Integer erpId;
    private String erpId;

    @ApiModelProperty(value = "ERP同步时间")
    @ExcelColumn(name="ERP同步时间")

 server/dmvisit_service/src/main/java/com/doumee/service/business/DeviceRoleService.java

@@ -2,6 +2,8 @@

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.RoleListRequest;
import com.doumee.core.model.openapi.response.RoleListResponse;
import com.doumee.dao.business.model.DeviceRole;
import com.doumee.dao.web.response.DeviceRoleVO;

@@ -108,4 +110,6 @@


    List<DeviceRoleVO> findListByType(Integer type);


}

 server/dmvisit_service/src/main/java/com/doumee/service/business/ERPSyncService.java

@@ -1,11 +1,16 @@
package com.doumee.service.business;

import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.*;
import com.doumee.core.model.openapi.request.erp.OrgListRequest;
import com.doumee.core.model.openapi.request.erp.UserInfoRequest;
import com.doumee.core.model.openapi.request.erp.UserListRequest;
import com.doumee.core.model.openapi.response.*;

import java.util.List;

/**
 * åœè½¦åœºäº‹ä»¶æŽ¨é€è®°å½•è¡¨Service定义
@@ -34,4 +39,54 @@
     * @return
     */
    String syncUserInfo(UserInfoRequest param);


    /**
     * åˆ›å»ºERP访问令牌
     * @param accessKey
     * @param accessSecret
     * @return
     */
    AccessTokenResponse createERPToken(String accessKey, String accessSecret);


    /**
     * é—¨ç¦ç»„全量接口
     * @param param
     * @return
     */
    List<RoleListResponse> erpQueryDeviceList(RoleListRequest param);

    /**
     * åœè½¦åœºå…¨é‡ä¿¡æ¯æŽ¥å£
     * @param param
     * @return
     */
    List<ParkListResponse> parkList(ParkListRequest param);

    /**
     * è®¿å®¢å‡ºå…¥äº‹ä»¶åŒæ­¥æŽ¥å£
     * @param param
     * @return
     */
    PageData<VisitEventListResponse> visitListPage(PageWrap<VisitListRequest> param);


    /**
     * é—¨ç¦å‡ºå…¥äº‹ä»¶åŒæ­¥æŽ¥å£
     * @param param
     * @return
     */
    PageData<DoorEventListResponse> doorEventListPage(PageWrap<DoorEventListRequest> param);

    /**
     * è½¦è¾†å‡ºå…¥äº‹ä»¶åŒæ­¥æŽ¥å£
     * @param param
     * @return
     */
    PageData<CarEventListResponse> carEventList(PageWrap<CarEventListRequest> param);

    void orgUpdate(OrgUpdateRequest param);

    void userUpdate(UserUpdateRequest param);
}

 server/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java

@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.response.AccessTokenResponse;
import com.doumee.dao.admin.request.LaborEmpowerDTO;
import com.doumee.dao.admin.request.LaborMemberDTO;
import com.doumee.dao.admin.request.MemberQuery;
@@ -166,7 +167,6 @@


    MemberVO getVisitedMember(CheckVisitedDTO checkVisitedDTO);





 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/DeviceRoleServiceImpl.java

@@ -5,8 +5,12 @@
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.RoleListRequest;
import com.doumee.core.model.openapi.response.DeviceListResponse;
import com.doumee.core.model.openapi.response.RoleListResponse;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.DeviceMapper;
import com.doumee.dao.business.DeviceRoleMapper;
import com.doumee.dao.business.model.Device;
import com.doumee.dao.business.model.DeviceRole;
@@ -16,17 +20,19 @@
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.models.auth.In;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.checkerframework.checker.units.qual.C;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.*;
import java.util.stream.Collectors;

/**
 * é—¨ç¦è§’色信息表Service实现
@@ -38,6 +44,7 @@

    @Autowired
    private DeviceRoleMapper deviceRoleMapper;


    @Override
    public Integer create(DeviceRole deviceRole) {
@@ -248,4 +255,9 @@
    }







}

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java

@@ -1,23 +1,56 @@
package com.doumee.service.business.impl.erp;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.config.Jwt.JwtPayLoad;
import com.doumee.config.Jwt.JwtTokenUtil;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.DoorsListRequest;
import com.doumee.core.haikang.model.param.request.ParkListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.*;
import com.doumee.core.model.openapi.request.erp.OrgListRequest;
import com.doumee.core.model.openapi.request.erp.UserInfoRequest;
import com.doumee.core.model.openapi.request.erp.UserListRequest;
import com.doumee.core.model.openapi.response.*;
import com.doumee.core.model.openapi.response.erp.OrgListRespone;
import com.doumee.service.business.ERPSyncService;
import com.doumee.service.business.HkSyncService;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DESUtil;
import com.doumee.core.utils.Utils;
import com.doumee.core.utils.redis.RedisUtil;
import com.doumee.dao.admin.response.MemberInfoDTO;
import com.doumee.dao.business.*;
import com.doumee.dao.business.join.CarEventJoinMapper;
import com.doumee.dao.business.join.DeviceEventJoinMapper;
import com.doumee.dao.business.join.VisitEventJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.dao.web.reqeust.CheckVisitedDTO;
import com.doumee.dao.web.response.MemberVO;
import com.doumee.service.business.*;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.swagger.models.auth.In;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;
import java.util.*;
import java.util.stream.Collectors;

/**
 * è®¾å¤‡ä¿¡æ¯è¡¨Service实现
@@ -26,6 +59,49 @@
 */
@Service
public class ErpSyncServiceImpl implements ERPSyncService {

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Autowired
    private DeviceRoleMapper deviceRoleMapper;

    @Autowired
    private DeviceMapper deviceMapper;

    @Autowired
    private ParksMapper parksMapper;

    @Autowired
    private VisitEventMapper visitEventMapper;


    @Autowired
    private VisitEventJoinMapper visitEventJoinMapper;

    @Autowired
    private DeviceEventJoinMapper deviceEventJoinMapper;

    @Autowired
    private CarEventJoinMapper carEventJoinMapper;

    @Autowired
    private CompanyMapper companyMapper;

    @Autowired
    private MemberMapper memberMapper;
    
    @Autowired
    private MemberRoleMapper memberRoleMapper;

    @Autowired
    private MemberCardMapper memberCardMapper;

    @Autowired
    private InterfaceLogService interfaceLogService;

    /**
     * åŒæ­¥ERP组织信息
@@ -58,4 +134,422 @@
    public  String syncUserInfo(UserInfoRequest param){
        return  null;
    }


    @Override
    public AccessTokenResponse createERPToken(String accessKey, String accessSecret){
        AccessTokenResponse result = new AccessTokenResponse();
        try{
            String erpAccessKey = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_KEY).getCode();
            String erpAccessSecret = systemDictDataBiz.queryByCode(Constants.ERP_CONFIG,Constants.ERP_ACCESS_SECRET).getCode();
            if(!accessKey.equals(erpAccessKey)||!erpAccessSecret.equals(accessSecret)){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"秘钥匹配失败");
            }
            JwtPayLoad payLoad = new JwtPayLoad(erpAccessKey+"-"+erpAccessSecret);
            String token = JwtTokenUtil.generateToken(payLoad);
            RedisUtil.addObject(redisTemplate,Constants.RedisKeys.ERP_TOKEN,token,Constants.RedisKeys.EXPIRE_TIME);
            result.setToken(token);
            result.setExpireTime(Constants.RedisKeys.EXPIRE_TIME);
        }catch (Exception e){

        }finally {
            Map<String,String> param = new HashMap<>();
            param.put("accessKey",accessKey);
            param.put("accessSecret",accessSecret);
            saveInterfaceLog(param,"/visitBiz/accesstoken",JSONObject.toJSONString(result),Constants.ZERO);
        }


        return result;
    }

    /**
     * é—¨ç¦ç»„全量接口
     * @param param
     * @return
     */
    @Override
    public List<RoleListResponse> erpQueryDeviceList(RoleListRequest param){
        List<RoleListResponse> result = new ArrayList<>();
        try{
           List<DeviceRole> deviceRoleList = this.deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
                   .eq(DeviceRole::getIsdeleted,Constants.ZERO)
                   .eq(!Objects.isNull(param.getId()),DeviceRole::getId,param.getId())
                   .like(StringUtils.isNotBlank(param.getName()),DeviceRole::getName,param.getName())
                   .orderByAsc(DeviceRole::getCreateDate)
           );
           List<String> roleIds = new ArrayList<String>();
           if(CollectionUtils.isNotEmpty(deviceRoleList)){
               for (DeviceRole deviceRole:deviceRoleList) {
                   if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
                       List<String>  doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
                       roleIds.addAll(doorList);
                   }
               }
               if(CollectionUtils.isNotEmpty(roleIds)){
                   List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,roleIds));
                   for (DeviceRole deviceRole:deviceRoleList) {
                       RoleListResponse roleListResponse = new RoleListResponse();
                       BeanUtils.copyProperties(deviceRole,roleListResponse);
                       if(StringUtils.isNotBlank(deviceRole.getDoorIds())){
                           List<DeviceListResponse> DeviceListResponseList = new ArrayList<>();
                           List<String>  doorList = Arrays.asList(deviceRole.getDoorIds().split(","));
                           List<Device> roleDeviceList = deviceList.stream().filter(m-> doorList.contains(m.getId().toString())).collect(Collectors.toList());
                           for (Device device:roleDeviceList) {
                               DeviceListResponse deviceListResponse = new DeviceListResponse();
                               BeanUtils.copyProperties(device,deviceListResponse);
                               DeviceListResponseList.add(deviceListResponse);
                           }
                           roleListResponse.setDeviceList(DeviceListResponseList);
                       }
                       result.add(roleListResponse);
                   }
               }
           }
       }catch (Exception e){
           e.printStackTrace();
       }finally {
           saveInterfaceLog(param,"/visitBiz/resource/role/list",JSONObject.toJSONString(result),Constants.ZERO);
       }
       return result;
    }




    /**
     * åœè½¦åœºå…¨é‡ä¿¡æ¯æŽ¥å£
     * @param param
     * @return
     */
    @Override
    public List<ParkListResponse> parkList(ParkListRequest param){
        List<ParkListResponse> result = new ArrayList<>();
        try{
            List<Parks> parksList = this.parksMapper.selectList(new QueryWrapper<Parks>().lambda()
                    .eq(Parks::getIsdeleted,Constants.ZERO)
                    .eq(!Objects.isNull(param.getId()),Parks::getId,param.getId())
                    .like(StringUtils.isNotBlank(param.getName()),Parks::getName,param.getName())
            );
            if(CollectionUtils.isNotEmpty(parksList)){
                for (Parks parks:parksList) {
                    ParkListResponse parkListResponse = new ParkListResponse();
                    BeanUtils.copyProperties(parks,parkListResponse);
                    result.add(parkListResponse);
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/park/list",JSONObject.toJSONString(result),Constants.ZERO);
        }
        return result;
    }

    /**
     * è®¿å®¢å‡ºå…¥äº‹ä»¶åŒæ­¥æŽ¥å£
     * @param param
     * @return
     */
    @Override
    public PageData<VisitEventListResponse> visitListPage(PageWrap<VisitListRequest> param) {
        PageData<VisitEventListResponse> result = new PageData<>();
        try{
            VisitListRequest visitListRequest = param.getModel();
            IPage<VisitEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<VisitEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(visitListRequest);

            queryWrapper.selectAll(VisitEvent.class);
            queryWrapper.selectAs(Visits::getName, VisitEventListResponse::getVisitorName);
            queryWrapper.leftJoin(Visits.class,Visits::getId,VisitEvent::getVisitorId);

            if(!Objects.isNull(visitListRequest)){
                queryWrapper.eq(!Objects.isNull(visitListRequest.getEventId()),VisitEvent::getEventId, visitListRequest.getEventId());
                queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorName()),Visits::getName, visitListRequest.getVisitorName());
                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getIdNo()),VisitEvent::getIdNo, visitListRequest.getIdNo());
                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonId()),VisitEvent::getBeVisitedPersonId, visitListRequest.getBeVisitedPersonId());
                queryWrapper.eq(StringUtils.isNotBlank(visitListRequest.getBeVisitedPersonOrgId()),VisitEvent::getBeVisitedPersonOrgId, visitListRequest.getBeVisitedPersonOrgId());
                queryWrapper.like(StringUtils.isNotBlank(visitListRequest.getVisitorWorkUint()),VisitEvent::getVisitorWorkUint, visitListRequest.getVisitorWorkUint());
                queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getInStartTime()),VisitEvent::getStartTime, visitListRequest.getInStartTime());
                queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getInEndTime()),VisitEvent::getStartTime, visitListRequest.getInEndTime());
                queryWrapper.ge(StringUtils.isNotBlank(visitListRequest.getOutStartTime()),VisitEvent::getEndTime, visitListRequest.getOutStartTime());
                queryWrapper.le(StringUtils.isNotBlank(visitListRequest.getOutEndTime()),VisitEvent::getEndTime, visitListRequest.getOutEndTime());

                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }
            IPage<VisitEventListResponse> pageData = visitEventJoinMapper.selectJoinPage(page, VisitEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/visit/list",JSONObject.toJSONString(result),Constants.ZERO);
        }
        return result;
    }


    @Override
    public PageData<DoorEventListResponse> doorEventListPage(PageWrap<DoorEventListRequest> param) {
        PageData<DoorEventListResponse> result = new PageData<>();
        try{
            DoorEventListRequest doorEventListRequest = param.getModel();
            IPage<DeviceEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<DeviceEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(doorEventListRequest);
            queryWrapper.selectAs(DeviceEvent::getEventId,DoorEventListResponse::getEventId);
            queryWrapper.selectAs(DeviceEvent::getEventType,DoorEventListResponse::getEventType);
            queryWrapper.selectAs(DeviceEvent::getSex,DoorEventListResponse::getSex);
            queryWrapper.selectAs(DeviceEvent::getSrcName,DoorEventListResponse::getSrcName);
            queryWrapper.selectAs(DeviceEvent::getSrcType,DoorEventListResponse::getSrcType);
            queryWrapper.selectAs(DeviceEvent::getIdcardDecode,DoorEventListResponse::getIdcardNo);
            queryWrapper.selectAs(DeviceEvent::getName,DoorEventListResponse::getName);
            queryWrapper.selectAs(DeviceEvent::getUserType,DoorEventListResponse::getType);
            queryWrapper.selectAs(DeviceEvent::getExtEventInOut,DoorEventListResponse::getEventInOut);
            queryWrapper.selectAs(DeviceEvent::getExtAccessChannel,DoorEventListResponse::getExtAccessChannel);
            queryWrapper.selectAs(DeviceEvent::getCreateDate,DoorEventListResponse::getCreateTime);
            queryWrapper.selectAs(Member::getPhone,DoorEventListResponse::getPhone);
            queryWrapper.selectAs(Member::getErpId,DoorEventListResponse::getUserId);
            queryWrapper.selectAs(Member::getCompanyId,DoorEventListResponse::getOrgId);
            queryWrapper.leftJoin(Member.class,Member::getHkId,DeviceEvent::getExtEventPersonNo);

            if(!Objects.isNull(doorEventListRequest)){
                queryWrapper.eq(!Objects.isNull(doorEventListRequest.getEventId()),DeviceEvent::getEventId, doorEventListRequest.getEventId());
                queryWrapper.like(StringUtils.isNotBlank(doorEventListRequest.getName()),DeviceEvent::getName, doorEventListRequest.getName());
                if(StringUtils.isNotBlank(doorEventListRequest.getIdNo())){
                    //进行加密
                    String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,doorEventListRequest.getIdNo());
                    queryWrapper.eq(DeviceEvent::getIdNum, encryptIdNo);
                }
                queryWrapper.ge(StringUtils.isNotBlank(doorEventListRequest.getStartTime()),DeviceEvent::getHappenTime, doorEventListRequest.getStartTime());
                queryWrapper.le(StringUtils.isNotBlank(doorEventListRequest.getEndTime()),DeviceEvent::getHappenTime, doorEventListRequest.getEndTime());
                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }

            IPage<DoorEventListResponse> pageData = deviceEventJoinMapper.selectJoinPage(page, DoorEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/doorEvent/list",JSONObject.toJSONString(result),Constants.ZERO);
        }
        return result;
    }


    @Override
    public PageData<CarEventListResponse> carEventList(PageWrap<CarEventListRequest> param) {
        PageData<CarEventListResponse> result = new PageData<>();
        try{
            CarEventListRequest carEventListRequest = param.getModel();
            IPage<CarEvent> page = new Page<>(param.getPage(), param.getCapacity());
            MPJLambdaWrapper<CarEvent> queryWrapper = new MPJLambdaWrapper<>();
            Utils.MP.blankToNull(carEventListRequest);
            queryWrapper.selectAs(CarEvent::getEventId,CarEventListResponse::getEventId);
            queryWrapper.selectAs(CarEvent::getEventType,CarEventListResponse::getEventType);
            queryWrapper.selectAs(CarEvent::getInoutType,CarEventListResponse::getEventType);
            queryWrapper.selectAs(CarEvent::getAlarmCar,CarEventListResponse::getAlarmCar);
            queryWrapper.selectAs(CarEvent::getCarAttributeName,CarEventListResponse::getCarAttributeName);
            queryWrapper.selectAs(CarEvent::getCardNo,CarEventListResponse::getCardNo);
            queryWrapper.selectAs(CarEvent::getEventCmd,CarEventListResponse::getEventCmd);
            queryWrapper.selectAs(CarEvent::getGateIndex,CarEventListResponse::getGateIndex);
            queryWrapper.selectAs(CarEvent::getGateName,CarEventListResponse::getGateName);
            queryWrapper.selectAs(CarEvent::getMainLogo,CarEventListResponse::getMainLogo);
            queryWrapper.selectAs(CarEvent::getParkIndex,CarEventListResponse::getParkId);
            queryWrapper.selectAs(CarEvent::getParkName,CarEventListResponse::getParkName);
            queryWrapper.selectAs(CarEvent::getPlatePicUrl,CarEventListResponse::getPlatePicUrl);
            queryWrapper.selectAs(CarEvent::getVehiclePicUrl,CarEventListResponse::getVehiclePicUrl);
            queryWrapper.selectAs(CarEvent::getPlateNos,CarEventListResponse::getPlateNo);
            queryWrapper.selectAs(CarEvent::getPlateColor,CarEventListResponse::getPlateColor);
            queryWrapper.selectAs(CarEvent::getRoadwayName,CarEventListResponse::getRoadwayName);
            queryWrapper.selectAs(CarEvent::getRoadwayType,CarEventListResponse::getRoadwayType);
            queryWrapper.selectAs(CarEvent::getSubLogo,CarEventListResponse::getSubLogo);
            queryWrapper.selectAs(CarEvent::getSubModel,CarEventListResponse::getSubModel);

            if(!Objects.isNull(carEventListRequest)){
                queryWrapper.eq(!Objects.isNull(carEventListRequest.getEventId()),CarEvent::getEventId, carEventListRequest.getEventId());
                queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getParkId()),CarEvent::getParkIndex, carEventListRequest.getParkId());
                queryWrapper.like(StringUtils.isNotBlank(carEventListRequest.getParkName()),CarEvent::getParkName, carEventListRequest.getParkName());
                queryWrapper.eq(StringUtils.isNotBlank(carEventListRequest.getPlateNo()),CarEvent::getPlateNos, carEventListRequest.getPlateNo());
                queryWrapper.ge(StringUtils.isNotBlank(carEventListRequest.getStartTime()),CarEvent::getHappenTime, carEventListRequest.getStartTime());
                queryWrapper.le(StringUtils.isNotBlank(carEventListRequest.getEndTime()),CarEvent::getHappenTime, carEventListRequest.getEndTime());
                for(PageWrap.SortData sortData: param.getSorts()) {
                    if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                        queryWrapper.orderByDesc(sortData.getProperty());
                    } else {
                        queryWrapper.orderByAsc(sortData.getProperty());
                    }
                }
            }
            IPage<CarEventListResponse> pageData = carEventJoinMapper.selectJoinPage(page, CarEventListResponse.class,queryWrapper);
            result = PageData.from(pageData);
            result.getRecords().forEach(i->{
                if(i.getPlatePicUrl().startsWith(HKConstants.IMG_INDEX)){
                    i.setPlatePicUrl(null);
                }
                if(i.getVehiclePicUrl().startsWith(HKConstants.IMG_INDEX)){
                    i.setVehiclePicUrl(null);
                }
            });
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/carEventList",JSONObject.toJSONString(result),Constants.ZERO);
        }

        return  result;
    }




    @Override
    public void orgUpdate(OrgUpdateRequest param){
        try{
            if(Objects.isNull(param)
                    ||Objects.isNull(param.getId())
                    ||StringUtils.isBlank(param.getName())
                    ||StringUtils.isBlank(param.getLinkName())
                    ||StringUtils.isBlank(param.getLinkPhone())
                    ||Objects.isNull(param.getEditDate())
            ){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            Company company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getId()).last("limit 1"));
            if(Objects.isNull(company)){
                company = new Company();
                BeanUtils.copyProperties(param,company);
                company.setId(null);
                company.setCreateDate(new Date());
                company.setHkStatus(Constants.ZERO);
                company.setErpStatus(Constants.ONE);
                company.setErpDate(new Date());
                company.setErpId(param.getId());
                company.setFsStatus(Constants.ZERO);
                company.setType(Constants.ONE);
                companyMapper.insert(company);
                //TODO æµ·åº·æ•°æ®åˆ›å»º
            }else{
                BeanUtils.copyProperties(param,company);
                company.setEditDate(new Date());
                company.setErpDate(new Date());
                companyMapper.updateById(company);
                //TODO æµ·åº·æ•°æ®æ›´æ–°
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/orgUpdate",null,Constants.ZERO);
        }
    }



    @Override
    public void userUpdate(UserUpdateRequest param){
        try{
            if(Objects.isNull(param)
                    ||Objects.isNull(param.getId())
                    ||StringUtils.isBlank(param.getName())
                    ||StringUtils.isBlank(param.getIdNo())
                    ||Objects.isNull(param.getIdType())
                    ||Objects.isNull(param.getSex())
                    ||Objects.isNull(param.getOrgId())
                    ||StringUtils.isNotBlank(param.getFaceImg())
                    ||StringUtils.isNotBlank(param.getCode())
                    ||StringUtils.isNotBlank(param.getPhone())
                    ||Objects.isNull(param.getEditDate())
            ){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
            Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getId()).last("limit 1"));
            if(Objects.isNull(member)){
                member = new Member();
                BeanUtils.copyProperties(param,member);
                member.setCreateDate(new Date());
                member.setHkStatus(Constants.ZERO);
                member.setErpStatus(Constants.ONE);
                member.setErpDate(new Date());
                member.setErpId(param.getId());
                member.setFsStatus(Constants.ZERO);
                member.setType(Constants.memberType.internal);
                String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                member.setIdcardNo(encryptIdNo);
                member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                member.setCompanyId(param.getOrgId());
                memberMapper.insert(member);

                //TODO æµ·åº·æ•°æ®åˆ›å»º
            }else{
                BeanUtils.copyProperties(param,member);
                String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                member.setIdcardNo(encryptIdNo);
                member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                member.setCompanyId(param.getOrgId());
                member.setEditDate(new Date());
                member.setErpDate(new Date());
                memberMapper.updateById(member);
                //删除用户卡片数据  äººå‘˜è§’色关联
                memberCardMapper.delete(new QueryWrapper<MemberCard>().lambda().eq(MemberCard::getMemberId,member.getId()));
                memberRoleMapper.delete(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
                //TODO æµ·åº·æ•°æ®æ›´æ–°
            }
            //添加人员角关联数据
            if(!Objects.isNull(param.getRoleIds())&&param.getRoleIds().length>Constants.ZERO){
                //查询数据库存在的权限
                List<MemberRole> memberRoleList = memberRoleMapper.selectList(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getId,param.getRoleIds()));
                List<Integer> roleIds = Arrays.asList(param.getRoleIds());

//                List<MemberRole> memberRoleList = new ArrayList<>();
//
//                for (Integer id:roleIds) {
//
//                }




            }
            
            
            
            
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            saveInterfaceLog(param,"/visitBiz/resource/userUpdate",null,Constants.ZERO);
        }
    }





    private void saveInterfaceLog(Object param, String path,String result,Integer type) {
        InterfaceLog interfaceLog=new InterfaceLog();
        interfaceLog.setType(type);
        interfaceLog.setCreateDate(new Date());
        interfaceLog.setIsdeleted(Constants.ZERO);
        if(param!=null){
            interfaceLog.setRequest(JSONObject.toJSONString(param));
        }
        interfaceLog.setPlat(Constants.ONE);
        interfaceLog.setRepose(result);
        interfaceLog.setName(path);
        interfaceLog.setUrl(path);
        interfaceLogService.create(interfaceLog);
    }

}

 server/openapi/src/main/java/com/doumee/api/web/ApiController.java

@@ -1,5 +1,6 @@
package com.doumee.api.web;

import com.doumee.config.Jwt.JwtTokenUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@@ -25,4 +26,10 @@
        return request;
    }

    protected String getToken() {
        Object obj = this.getRequest().getAttribute(JwtTokenUtil.HEADER_KEY);
        return obj != null ? obj.toString() : null;
    }


}

 server/openapi/src/main/java/com/doumee/api/web/BizResourceController.java

@@ -1,17 +1,30 @@
package com.doumee.api.web;

import com.doumee.config.Jwt.JwtPayLoad;
import com.doumee.config.Jwt.JwtTokenUtil;
import com.doumee.config.annotation.ErpLoginRequired;
import com.doumee.config.annotation.LoginRequired;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.*;
import com.doumee.core.model.openapi.response.*;
import com.doumee.core.utils.Constants;
import com.doumee.service.business.DeviceRoleService;
import com.doumee.service.business.DeviceService;
import com.doumee.service.business.ERPSyncService;
import com.doumee.service.business.MemberService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.http.HttpRequest;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List;

@@ -24,9 +37,13 @@

@Api(tags = "1、【访客端】数据资源接口（向ERP端提供或提交数据信息）")
@RestController
@RequestMapping("/visitbiz/resource")
@RequestMapping("/visitbiz")
@Slf4j
public class BizResourceController extends ApiController{

    @Autowired
    private ERPSyncService erpSyncService;


    @ApiOperation(value = "调用凭据获取接口", notes = "访客端提供，供ERP端调用，向ERP提供统接口调用凭证")
    @GetMapping("/accesstoken")
@@ -34,16 +51,19 @@
            @ApiImplicitParam(paramType = "query", dataType = "String", name = "accessKey", value = "访问key，由访客端提供", required = true),
            @ApiImplicitParam(paramType = "query", dataType = "String", name = "accessSecret", value = "访问秘钥，由访客端提供", required = true)
    })
    public ApiResponse<AccessTokenResponse> roleList(@RequestParam  String accessKey, @RequestParam  String accessSecret) {
        return  ApiResponse.success(new AccessTokenResponse());
    public ApiResponse<AccessTokenResponse> accesstoken(@RequestParam  String accessKey, @RequestParam  String accessSecret) {
        return  ApiResponse.success(erpSyncService.createERPToken(accessKey,accessSecret));
    }

    @ErpLoginRequired
    @ApiOperation(value = "门禁组全量接口", notes = "访客端提供，供ERP端调用，ERP端同步获取门禁组全量信息")
    @PostMapping("/resource/role/list")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse<List<RoleListResponse>> roleList(@RequestBody RoleListRequest param) {
        return  ApiResponse.success(new ArrayList<RoleListResponse>());
        param.setToken(this.getToken());
        return  ApiResponse.success(erpSyncService.erpQueryDeviceList(param));
    }

    @ApiOperation(value = "停车场全量信息接口", notes = "访客端提供，供ERP端调用，ERP端同步全部停车场数据")
@@ -51,8 +71,9 @@
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse<ParkListResponse> parkList(@RequestBody ParkListRequest param) {
        return  ApiResponse.success(new ParkListResponse());
    public ApiResponse<List<ParkListResponse>> parkList(@RequestBody ParkListRequest param) {
        param.setToken(this.getToken());
        return  ApiResponse.success(erpSyncService.parkList(param));
    }

    @ApiOperation(value = "访客出入事件同步接口", notes = "访客端提供，供ERP端调用，ERP端获取访客出入记录信息")
@@ -61,40 +82,52 @@
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse<PageData<VisitEventListResponse>> visitList (@RequestBody PageWrap<VisitListRequest> pageWrap) {
        return ApiResponse.success(null);
        pageWrap.getModel().setToken(this.getToken());
        return ApiResponse.success(erpSyncService.visitListPage(pageWrap));
    }

    @ApiOperation(value = "门禁出入事件同步接口", notes = "访客端提供，供ERP端调用，ERP端获取门禁出入记录信息")
    @PostMapping("/resource/doorEvent/list")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse<PageData<DoorEventListResponse>> doorEventList (@RequestBody PageWrap<DoorEventListRequest> pageWrap) {
        return ApiResponse.success(null);
        pageWrap.getModel().setToken(this.getToken());
        return ApiResponse.success(erpSyncService.doorEventListPage(pageWrap));
    }

    @ApiOperation(value = "车辆出入事件同步接口", notes = "访客端提供，供ERP端调用，ERP端获取车辆出入记录信息")
    @PostMapping("/resource/carvisit/list")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse<PageData<CarEventListResponse>> carEventList (@RequestBody PageWrap<CarEventListResponse> pageWrap) {
        return ApiResponse.success(null);
    public ApiResponse<PageData<CarEventListResponse>> carEventList (@RequestBody PageWrap<CarEventListRequest> pageWrap) {
        pageWrap.getModel().setToken(this.getToken());
        return ApiResponse.success(erpSyncService.carEventList(pageWrap));
    }

    @ApiOperation(value = "组织变化接口", notes = "访客端提供，供ERP端调用，完成访客端组织信息同步，该接口支持单个组织新增、更新、删除需求")
    @PostMapping("/event/org/update")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse orgUpdate(@RequestBody OrgUpdateRequest param) {
        param.setToken(this.getToken());
        erpSyncService.orgUpdate(param);
        return  ApiResponse.success(null);
    }

    @ApiOperation(value = "人员变化接口", notes = "访客端提供，供ERP端调用，完成访客端人员信息同步，该接口支持单个人员新增、更新、删除需求")
    @PostMapping("/event/user/update")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "授权token值", required = true)
    })
    public ApiResponse userUpdate(@RequestBody UserUpdateRequest param) {
        param.setToken(this.getToken());
        erpSyncService.userUpdate(param);
        return  ApiResponse.success(null);
    }

    @ApiOperation(value = "人员门禁组授权接口", notes = "访客端提供，供ERP端调用，访客端人员同步门禁组授权信息，该接口支持人员门禁组授权新增、更新、清空需求。")
    @PostMapping("/event/role/userAuthor")
    @ApiImplicitParams({
@@ -103,6 +136,7 @@
    public ApiResponse roleUserAuthor(@RequestBody UserAuthorRequest param) {
        return  ApiResponse.success(null);
    }

    @ApiOperation(value = "车辆授权停车场接口", notes = "访客端提供，供ERP端调用，访客端同步车辆对停车场的使用权限，该接口支持车辆绑定、解绑归属人，支持新增、更新、清空车辆授权信息")
    @PostMapping("/event/park/carAuthor")
    @ApiImplicitParams({
@@ -111,6 +145,7 @@
    public ApiResponse parkCarAuthor(@RequestBody CarAuthorRequest param) {
        return  ApiResponse.success(null);
    }

    @ApiOperation(value = "访客申请审批结果通知接口", notes = "访客端提供，供访客端调用，提交访客申请审批的结果")
    @PostMapping("/event/approve/notice")
    @ApiImplicitParams({