硬件协议对接

jiangping

2023-11-03 b52604d53c7568a522f2e0b471a72dbcd4d022fe

 server/services/src/main/java/com/doumee/core/constants/Constants.java

@@ -1,5 +1,6 @@
package com.doumee.core.constants;

import ch.qos.logback.core.util.COWArrayList;
import org.apache.commons.codec.binary.Hex;
import org.apache.commons.lang3.StringUtils;

@@ -23,211 +24,551 @@
  public static final String FALSE = "f";
  public static final String TOKEN ="TOKEN" ;
    public static final String SYSTEM ="SYSTEM" ;
    public static final String DINGDING ="DINGDING" ;
    public static final String MINI_PROGRAMME ="MINI_PROGRAMME" ;
    public static final String FREE_RENT_TIME ="FREE_RENT_TIME" ;
    public static final String IMG_DIR = "IMG_DIR";
    public static final String FILE_DIR ="FILE_DIR" ;
    public static final String PRIVATE_KEY = "PRIVATE_KEY";
    public static final String MINI_PROGRAMME ="MINI_PROGRAMME" ;
    public static final String PROJECT_FILE = "PROJECT_FILE";
    public static final String PROJECTS = "PROJECTS";
    public static final String FORCE_BACK_LOCK = "FORCE_BACK_LOCK";
    public static final String FORCE_BACK_SITE = "FORCE_BACK_SITE";
    //车辆类型数据
    public static final String  BIKE_TYPE ="0,1,2,3,4,5,6,7,8" ;
    public static String REDIS_DEBUG_STR="test_";
    public static final String AD = "AD";
    public static String REPAIR = "REPAIR";

  /**
    public  interface MqttTopic{

        String topic_index = "device/lock/";
        //开锁（发布）
        String pub_openLock = "device/lock/{siteId}/{lockId}/unlock";
        //锁信息，在初始化、状态变更时会推送锁的完整状态(订阅）
        String sub_lockInfo = "device/lock/+/+/info";
        //还车锁头（订阅）
        String sub_closeLock = "device/lock/+/+/bike";
        String sub_health= "device/lock/+/health";

        String sub_brokers = "$SYS/brokers/+/clients/#";
        //实时获取锁信息（发布）
        String pub_getLockInfo = "device/lock/{siteId}/{lockId}/getInfo";
    }

    /**
   * 数据权限范围：0只看自己；1只看自己所在校区；2看全部校区；3看指定校区（多选）
   */
  public interface PermissionType{
    int self =0;
    int self_campus =1;
    int all =2;
    int partful = 3;
        int self =0;
        int self_campus =1;
        int all =2;
        int partful = 3;
  }

  public interface RedisKeys {
        public static final String submission_period_key = "sp_";
    public interface LockStatus{
      //  //状态，0闭合, 1打开，2运行中, 3异常 -1自检
        int closed =0;
        int open =1;
        int running =2;
        int error= 3;
        int checking= -1;
    }
    public interface goodsorderStatus{
        int waitPay =0;
        int pay =1;
        int cancel =2;
        int fail = 3;
        int over = 4;
    }
    public interface goodsorderPayStatus{
        int waitPay =0;
        int pay =1;
    }
    public enum TRANSACTIONS_TYPE{
      //交易类型 0租车押金 1结算实际消费 2结算退款 3平台退款"
        DEPOSIT(0,"租车押金", "租车押金"),

        CONSUMPTION(1,"结算实际消费", "结算实际消费"),

  public static final String ACCESS_ID="ACCESS_ID";
        REFUND(2,"结算退款", "结算退款"),

  public static final String BUCKETNAME = "BUCKETNAME";
        PLATFORMREFUND(3,"平台退款", "平台退款")

  public static final String OSS = "OSS";
        ;
        String name;

  public static final String ACCESS_KEY = "ACCESS_KEY";
        Integer key;

  public static final String SCRATCH_REDIRECT = "SCRATCH_REDIRECT";
        String info;

  public static final String ENDPOINT = "ENDPOINT";

  public static final String TESTCASE_UPLOAD_PATH = "TESTCASE_UPLOAD_PATH";

  public static final String RESOURCE_PATH = "RESOURCE_PATH";
  public static final String UPLOAD_FILE = "UPLOAD_FILE";
  public static final String AVATAR_FILE = "AVATAR_FILE";

  public static final String FILES_DIR = "FILES_DIR";
  public static final String SCRATCH_REDIRECT_URL = "SCRATCH_REDIRECT_URL";
  public static final Integer ZERO = 0 ;
  public static final Integer ONE = 1 ;
    public static final Integer TWO = 2 ;

  public static int formatIntegerNum(Integer num){
   if(num == null){
    return 0;
   }
   return num;
  }

  public interface  UserActionsType{
      String cancelPrePay="CANCEL_PRE_PAY";

      //订单结算订单
      String  close="CLOSE";
      String  forceRefund="FORCE_REFUND";
      String login="LOGIN";
      String pay="PAY";
      String preForceRefund="PRE_FORCE_REFUND";
      String prePay="PRE_PAY";
      String preRefund="PRE_REFUND";
      String refund="REFUND";
      String register="REGISTER";
      String rent="RENT";
  }
  public static BigDecimal formatDecimalNum(BigDecimal num){
   if(num == null){
    return new BigDecimal(0);
   }
   return num;
  }
  public static int compareBigdecimal(BigDecimal num,BigDecimal num2){
   if(num == null){
    num =new BigDecimal(0);
   }
   if(num2 == null){
    num2 =new BigDecimal(0);
   }
   if (num.compareTo(num2) == 1) {
    return 1;
   } else if (num.compareTo(num2)== -1) {
    return -1;
   }
   return 0;
  }

  public static long formatLongNum(Long num){
   if(num == null){
    return 0;
   }
   return num;
  }
  public static String formatImgPath(String avatar, String imgPath) {
   if(StringUtils.isBlank(avatar)){
    return null;
   }
   return imgPath+avatar;
  }
    public static String getIpAddr(HttpServletRequest request) {
        String ipAddress = request.getHeader("x-forwarded-for");
        if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
            ipAddress = request.getHeader("Proxy-Client-IP");
        TRANSACTIONS_TYPE(Integer key, String name, String info) {
            this.name = name;
            this.key = key;
            this.info = info;
        }
        if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
            ipAddress = request.getHeader("WL-Proxy-Client-IP");
        }
        if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
            ipAddress = request.getRemoteAddr();
            String localIp = "127.0.0.1";
            String localIpv6 = "0:0:0:0:0:0:0:1";
            if (ipAddress.equals(localIp) || ipAddress.equals(localIpv6)) {
                // 根据网卡取本机配置的IP
                InetAddress inet = null;
                try {
                    inet = InetAddress.getLocalHost();
                    ipAddress = inet.getHostAddress();
                } catch (UnknownHostException e) {
                    e.printStackTrace();
        public static TRANSACTIONS_TYPE get(int key) {
            TRANSACTIONS_TYPE[] values = TRANSACTIONS_TYPE.values();
            for (TRANSACTIONS_TYPE object : values) {
                if (object.key == key) {
                    return object;
                }
            }
            return null;
        }
        // 对于通过多个代理的情况，第一个IP为客户端真实IP,多个IP按照','分割
        String ipSeparate = ",";
        int ipLength = 15;
        if (ipAddress != null && ipAddress.length() > ipLength) {
            if (ipAddress.indexOf(ipSeparate) > 0) {
                ipAddress = ipAddress.substring(0, ipAddress.indexOf(ipSeparate));

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public Integer getKey() {
            return key;
        }

        public void setKey(Integer key) {
            this.key = key;
        }

        public String getInfo() {
            return info;
        }

        public void setInfo(String info) {
            this.info = info;
        }
    }


public static  String getUUID(){
      return UUID.randomUUID().toString().replace("-","");
}
        public interface RedisKeys {
            public static final String submission_period_key = "sp_";
        }

        public static final String ACCESS_ID = "ACCESS_ID";
        public static final String BUCKETNAME = "BUCKETNAME";
        public static final String OSS = "OSS";
        public static final String ACCESS_KEY = "ACCESS_KEY";
        public static final String ENDPOINT = "ENDPOINT";
        public static final String RESOURCE_PATH = "RESOURCE_PATH";
        public static final String AVATAR_FILE = "AVATAR_FILE";
        //用户协议
        public static final String AGREEMENT = "AGREEMENT";
        //计价规则
        public static final String PRICING_RULE = "PRICING_RULE";
        //小程序主题名称
        public static final String PROJECT_NAME = "PROJECT_NAME";
        //小程序服务端电话
        public static final String SERVER_PHONE = "SERVER_PHONE";
        //小程序租赁流程视频
        public static final String RENT_TIPS_VIDEO = "RENT_TIPS_VIDEO";
        //租赁须知
        public static final String LEASE_NOTICE = "LEASE_NOTICE";
        //租赁须知图片
        public static final String LEASE_NOTICE_URL = "LEASE_NOTICE_URL";
        //押金
        public static final String RENT_DEPOSIT = "RENT_DEPOSIT";
        //温馨提示
        public static final String TIPS = "TIPS";
        //小程序停止服务提示
        public static final String STOP_SERVE_TIPS = "STOP_SERVE_TIPS";
        //小程序是否停止服务 0否 1是
        public static final String IS_STOP_SERVE = "IS_STOP_SERVE";
        //小程序停止开始时间
        public static final String STOP_SERVE_STARTTIME = "STOP_SERVE_STARTTIME";
        //小程序停止结束时间
        public static final String STOP_SERVE_ENDTIME = "STOP_SERVE_ENDTIME";
        //小程序每日服务开始时间
        public static final String BUSINESS_STARTTIME = "BUSINESS_STARTTIME";
        //小程序每日服务结束时间
        public static final String BUSINESS_ENDTIME = "BUSINESS_ENDTIME";

        //钉钉通知地址
        public static final String DINGDING_URL = "DINGDING_URL";
        //钉钉签名
        public static final String DINGDING_SECRET = "DINGDING_SECRET";

        //小程序满载预警(%)最大值
        public static final String WARN_MAX = "WARN_MAX";
        //小程序满载预警(%)最小值
        public static final String WARN_MIN = "WARN_MIN";


        public static final String FILES_DIR = "FILES_DIR";
        public static final String SCRATCH_REDIRECT_URL = "SCRATCH_REDIRECT_URL";
        public static final Integer ZERO = 0;
        public static final Integer ONE = 1;
        public static final Integer TWO = 2;
        public static final Integer THREE = 3;

        public static int formatIntegerNum(Integer num) {
            if (num == null) {
                return 0;
            }
            return num;
        }

        public interface UserActionsType {
            String cancelPrePay = "CANCEL_PRE_PAY";

            //订单结算订单
            String close = "CLOSE";
            String forceRefund = "FORCE_REFUND";
            String login = "LOGIN";
            String pay = "PAY";
            String preForceRefund = "PRE_FORCE_REFUND";
            String prePay = "PRE_PAY";
            String preRefund = "PRE_REFUND";
            String refund = "REFUND";
            String register = "REGISTER";
            String rent = "RENT";
        }

        public interface ActionLogObjType {
            int memberrides =0;//骑行记录

        }

        public enum ACTIONLOG_TYPE{
            //  0骑行记录
            FORCE_BACK(0,"强制还车","后台强制还车"),
            UPDATE_DURATION(1,"修改骑行时长","后台修改骑行时长")
            ;
            String name;

            Integer key;

            String info;

            ACTIONLOG_TYPE(Integer key,String name,  String info) {
                this.name = name;
                this.key = key;
                this.info = info;
            }

            public String getName() {
                return name;
            }

            public void setName(String name) {
                this.name = name;
            }

            public Integer getKey() {
                return key;
            }

            public void setKey(Integer key) {
                this.key = key;
            }

            public String getInfo() {
                return info;
            }

            public void setInfo(String info) {
                this.info = info;
            }
        }
        return ipAddress;
    }
        public enum GOODSORDER_STATUS{
            //            0待支付 1已支付 2已取消 3支付失败 4已结算
            UN_PAY("待支付", 0,"待支付"),

    public static String getSHA256Str(String str) {
        MessageDigest messageDigest;
        String encdeStr = "";
        try {
            messageDigest = MessageDigest.getInstance("SHA-256");
            byte[] hash = messageDigest.digest(str.getBytes("UTF-8"));
            encdeStr = Hex.encodeHexString(hash);
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return encdeStr;
    }
    public static String trimEndSpaceStr(String outPut){
        String newOutPut = "";
        if(StringUtils.isNotBlank(outPut)){
            String[] ostrs = outPut.split("\n");
            for(String str : ostrs){
                String  text = str.replace("\n","").replaceAll("\\s+$", "");
                newOutPut += text+"\n";
            HAVING_PAY("已支付", 1,"已支付"),

            CANCEL("已取消", 2,"已取消"),

            PAY_FAILURE("支付失败", 3,"支付失败"),

            CLOSE("已结算", 4,"已结算"),
            ;
            String name;

            Integer key;

            String info;

            GOODSORDER_STATUS(String name, Integer key, String info) {
                this.name = name;
                this.key = key;
                this.info = info;
            }
            if(newOutPut.endsWith("\n")){
                newOutPut = newOutPut.substring(0,newOutPut.length()-1);

            public String getName() {
                return name;
            }

            public void setName(String name) {
                this.name = name;
            }

            public Integer getKey() {
                return key;
            }

            public void setKey(Integer key) {
                this.key = key;
            }

            public String getInfo() {
                return info;
            }

            public void setInfo(String info) {
                this.info = info;
            }
        }
        return newOutPut;
    }

    public static String delHTMLTag(String htmlStr) {
        if (StringUtils.isBlank(htmlStr)) {
            return "";
    public enum REFUND_TYPE{
        // '退款类型 0用户结算退款 1平台自动结算退款 2强制结算退款 3结算后退款'
        NORMAL(  0,"用户结算退款",""),

        PLAT_AUTO( 1,"平台自动结算退款",""),

        PLAT_FORCE( 2,"强制结算退款",""),

        BACK( 3,"结算后退款",""),

        ;
        String name;

        Integer key;

        String info;


        REFUND_TYPE(Integer key,String name, String info) {
            this.name = name;
            this.key = key;
            this.info = info;
        }
        String regEx_script = "<script[^>]*?>[\\s\\S]*?<\\/script>"; // 定义script的正则表达式
        String regEx_style = "<style[^>]*?>[\\s\\S]*?<\\/style>"; // 定义style的正则表达式
        String regEx_html = "<[^>]+>"; // 定义HTML标签的正则表达式

        Pattern p_script = Pattern.compile(regEx_script, Pattern.CASE_INSENSITIVE);
        Matcher m_script = p_script.matcher(htmlStr);
        htmlStr = m_script.replaceAll(""); // 过滤script标签
        public static REFUND_TYPE get(int key) {
            REFUND_TYPE[] values = REFUND_TYPE.values();
            for (REFUND_TYPE object : values) {
                if (object.key == key) {
                    return object;
                }
            }
            return null;
        }
        public String getName() {
            return name;
        }

        Pattern p_style = Pattern.compile(regEx_style, Pattern.CASE_INSENSITIVE);
        Matcher m_style = p_style.matcher(htmlStr);
        htmlStr = m_style.replaceAll(""); // 过滤style标签
        public void setName(String name) {
            this.name = name;
        }

        Pattern p_html = Pattern.compile(regEx_html, Pattern.CASE_INSENSITIVE);
        Matcher m_html = p_html.matcher(htmlStr);
        htmlStr = m_html.replaceAll(""); // 过滤html标签
        public Integer getKey() {
            return key;
        }

        htmlStr = htmlStr.replace("&nbsp;&nbsp;","&nbsp;"); // 过滤空格标签
        htmlStr = htmlStr.replace("&nbsp;"," "); // 过滤空格标签
        public void setKey(Integer key) {
            this.key = key;
        }

        return htmlStr.trim(); // 返回文本字符串
        public String getInfo() {
            return info;
        }

        public void setInfo(String info) {
            this.info = info;
        }
    }
        public enum MEMBER_RIDES_STATUS{
//            0请求开锁中 1骑行中 2已还车  3开锁失败
            LOCKING("请求开锁中", 0,"请求开锁中"),

            RIDES_RUNNING("骑行中", 1,"骑行中"),

            BACK_CYCLING("已还车", 2,"已还车"),

            LOCKING_DEFEAT("开锁失败", 3,"开锁失败")
            ;
            String name;

            Integer key;

            String info;

            MEMBER_RIDES_STATUS(String name, Integer key, String info) {
                this.name = name;
                this.key = key;
                this.info = info;
            }

            public String getName() {
                return name;
            }

            public void setName(String name) {
                this.name = name;
            }

            public Integer getKey() {
                return key;
            }

            public void setKey(Integer key) {
                this.key = key;
            }

            public String getInfo() {
                return info;
            }

            public void setInfo(String info) {
                this.info = info;
            }
        }
        public static BigDecimal formatDecimalNum(BigDecimal num) {
            if (num == null) {
                return new BigDecimal(0);
            }
            return num;
        }

        public static int compareBigdecimal(BigDecimal num, BigDecimal num2) {
            if (num == null) {
                num = new BigDecimal(0);
            }
            if (num2 == null) {
                num2 = new BigDecimal(0);
            }
            if (num.compareTo(num2) == 1) {
                return 1;
            } else if (num.compareTo(num2) == -1) {
                return -1;
            }
            return 0;
        }
        public static long formatLongNum(Long num) {
            if (num == null) {
                return 0;
            }
            return num;
        }
        public static String formatImgPath(String avatar, String imgPath) {
            if (StringUtils.isBlank(avatar)) {
                return null;
            }
            return imgPath + avatar;
        }
        public static String getIpAddr(HttpServletRequest request) {
            String ipAddress = request.getHeader("x-forwarded-for");
            if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getHeader("Proxy-Client-IP");
            }
            if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getHeader("WL-Proxy-Client-IP");
            }
            if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
                ipAddress = request.getRemoteAddr();
                String localIp = "127.0.0.1";
                String localIpv6 = "0:0:0:0:0:0:0:1";
                if (ipAddress.equals(localIp) || ipAddress.equals(localIpv6)) {
                    // 根据网卡取本机配置的IP
                    InetAddress inet = null;
                    try {
                        inet = InetAddress.getLocalHost();
                        ipAddress = inet.getHostAddress();
                    } catch (UnknownHostException e) {
                        e.printStackTrace();
                    }
                }
            }
            // 对于通过多个代理的情况，第一个IP为客户端真实IP,多个IP按照','分割
            String ipSeparate = ",";
            int ipLength = 15;
            if (ipAddress != null && ipAddress.length() > ipLength) {
                if (ipAddress.indexOf(ipSeparate) > 0) {
                    ipAddress = ipAddress.substring(0, ipAddress.indexOf(ipSeparate));
                }
            }
            return ipAddress;
        }

        public static String getSHA256Str(String str) {
            MessageDigest messageDigest;
            String encdeStr = "";
            try {
                messageDigest = MessageDigest.getInstance("SHA-256");
                byte[] hash = messageDigest.digest(str.getBytes("UTF-8"));
                encdeStr = Hex.encodeHexString(hash);
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            return encdeStr;
        }

        public static String trimEndSpaceStr(String outPut) {
            String newOutPut = "";
            if (StringUtils.isNotBlank(outPut)) {
                String[] ostrs = outPut.split("\n");
                for (String str : ostrs) {
                    String text = str.replace("\n", "").replaceAll("\\s+$", "");
                    newOutPut += text + "\n";

                }
                if (newOutPut.endsWith("\n")) {
                    newOutPut = newOutPut.substring(0, newOutPut.length() - 1);
                }
            }
            return newOutPut;
        }

        public static String delHTMLTag(String htmlStr) {
            if (StringUtils.isBlank(htmlStr)) {
                return "";
            }
            String regEx_script = "<script[^>]*?>[\\s\\S]*?<\\/script>"; // 定义script的正则表达式
            String regEx_style = "<style[^>]*?>[\\s\\S]*?<\\/style>"; // 定义style的正则表达式
            String regEx_html = "<[^>]+>"; // 定义HTML标签的正则表达式

            Pattern p_script = Pattern.compile(regEx_script, Pattern.CASE_INSENSITIVE);
            Matcher m_script = p_script.matcher(htmlStr);
            htmlStr = m_script.replaceAll(""); // 过滤script标签

            Pattern p_style = Pattern.compile(regEx_style, Pattern.CASE_INSENSITIVE);
            Matcher m_style = p_style.matcher(htmlStr);
            htmlStr = m_style.replaceAll(""); // 过滤style标签

            Pattern p_html = Pattern.compile(regEx_html, Pattern.CASE_INSENSITIVE);
            Matcher m_html = p_html.matcher(htmlStr);
            htmlStr = m_html.replaceAll(""); // 过滤html标签

            htmlStr = htmlStr.replace("&nbsp;&nbsp;", "&nbsp;"); // 过滤空格标签
            htmlStr = htmlStr.replace("&nbsp;", " "); // 过滤空格标签

            return htmlStr.trim(); // 返回文本字符串
        }


    public static List<String> checkUUID(String checkValue){
            String [] str = checkValue.split(",");
        public static List<String> checkUUID(String checkValue) {
            String[] str = checkValue.split(",");
            List<String> strList = new ArrayList<>();
            for (String s:str) {
                try{
            for (String s : str) {
                try {
                    String uuid = UUID.fromString(s).toString();
                    strList.add(uuid);
                    //do something
                } catch (IllegalArgumentException exception){
                } catch (IllegalArgumentException exception) {
                    continue;
                }
            }
            return strList;
    }
        }


        public static BigDecimal translateMoney(BigDecimal money){
            return  Constants.formatDecimalNum(money).divide(new BigDecimal(100), 2, BigDecimal.ROUND_UP);

        }
}