gongdecai 2 years ago
parent
commit
21d78463c1

+ 1 - 1
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/GeneratorCodeByTables.java

@@ -53,7 +53,7 @@ public class GeneratorCodeByTables {
     }
 
     public static void main(String[] args) throws IOException {
-        generateByTables("Gdc", "com.yh.saas.plugin.yiliangyiyun","hy_order_travel_path");
+        generateByTables("Gdc", "com.yh.saas.plugin.yiliangyiyun","hy_token");
     }
 
     /**

+ 61 - 12
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/controller/CommonUserController.java

@@ -1,14 +1,10 @@
 package com.yh.saas.plugin.yiliangyiyun.controller;
 
 
-import cn.hutool.cache.CacheUtil;
-import cn.hutool.cache.impl.TimedCache;
-import cn.hutool.core.util.IdUtil;
-import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.extra.qrcode.QrCodeUtil;
-import cn.hutool.extra.qrcode.QrConfig;
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.plugins.Page;
+import com.openapi.sdk.service.DataExchangeService;
 import com.winsea.svc.base.base.entity.CommonCompany;
 import com.winsea.svc.base.base.entity.CommonStaff;
 import com.winsea.svc.base.base.entity.CommonStaffRole;
@@ -25,13 +21,11 @@ import com.winsea.svc.notice.entity.NoticeTaskInfo;
 import com.yh.saas.common.support.util.IdGenerator;
 import com.yh.saas.common.support.util.StringUtils;
 import com.yh.saas.plugin.yiliangyiyun.constant.ImageCensorConsts;
-import com.yh.saas.plugin.yiliangyiyun.entity.AjaxResult;
-import com.yh.saas.plugin.yiliangyiyun.entity.CommonUser;
-import com.yh.saas.plugin.yiliangyiyun.entity.SessionPojo;
-import com.yh.saas.plugin.yiliangyiyun.entity.UnimallMessage;
+import com.yh.saas.plugin.yiliangyiyun.entity.*;
 import com.yh.saas.plugin.yiliangyiyun.entity.view.UserDefinedBean;
 import com.yh.saas.plugin.yiliangyiyun.exception.ServiceException;
 import com.yh.saas.plugin.yiliangyiyun.service.ICommonUserService;
+import com.yh.saas.plugin.yiliangyiyun.service.IHyTokenService;
 import com.yh.saas.plugin.yiliangyiyun.util.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -48,8 +42,6 @@ import com.google.gson.Gson;
 import java.util.*;
 
 import com.aliyuncs.sts.model.v20150401.*;
-import org.springframework.web.server.ServerWebExchange;
-import reactor.core.publisher.Mono;
 
 import javax.servlet.http.HttpServletRequest;
 import java.net.URLEncoder;
@@ -87,6 +79,8 @@ public class CommonUserController {
     private ICommonCompanyService companyService;
     @Autowired
     private WebSocket webSocket;
+    @Autowired
+    private IHyTokenService hyToken;
 
 
 
@@ -397,5 +391,60 @@ public class CommonUserController {
         messageDO.setPath("XXXXX");
         webSocket.sendOneMessage(messageDO);
     }
+
+
+
+    public void login() {
+        try {
+            Map<String, String> map = new HashMap<String, String>(4);
+            map.put("user", "e8a253b1-12ee-46a4-aebe-58b55df34301");
+            map.put("pwd", "o1v78Rwje3U297j0owa7F2591174d5");
+            map.put("srt", "dfd28720-6c40-4029-8f3f-88e7e0ceec74");
+            map.put("cid", "26f33235-dff0-43d6-871b-9d1682996c12");
+            String url = "https://openapi-test.sinoiov.cn/save/apis/login";
+            // 设置 http 读写超时
+            DataExchangeService des = new DataExchangeService(5000, 8000);
+            System.out.println("请求地址:"+url);
+            // 通过 https 方式调用,此方法内部会使用私钥生成签名参数 sign,私钥不会发送
+            String res = des.postHttps(url, map);
+            HyToken token = new HyToken();
+            token.setId(IdGenerator.generateUUID());
+            token.setToken(res);
+            hyToken.insert(token);
+            System.out.println("返回:"+ res);
+        } catch (Exception e) {
+            System.out.println("e:" + e.getMessage());
+        }
+    }
+    @PostMapping("/orderPath")
+    public  void orderPath() throws Exception {
+        HyToken token = hyToken.selectOne(new EntityWrapper<HyToken>()
+        .eq("delete_flag",0));
+        if(token == null){
+            login();
+            token = hyToken.selectOne(new EntityWrapper<HyToken>()
+                    .eq("delete_flag",0));
+        }
+        Map<String, String> map = new HashMap<String, String>(4);
+        map.put("token", token.getToken());
+        map.put("cid", "26f33235-dff0-43d6-871b-9d1682996c12");
+        map.put("srt", "dfd28720-6c40-4029-8f3f-88e7e0ceec74");
+        map.put("vclN", "陕 YH0009");
+        map.put("vco", "2");
+        map.put("qryBtm", "2021-09-05 15:56:46");
+        map.put("qryEtm", "2021-09-06 15:56:46");
+        map.put("startLonlat", " 116.31795,30.4252");
+        map.put("endLonlat", "110.9946817,25.9089816");
+        map.put("startAreaCode", "431102");
+        map.put("endAreaCode", "450324");
+
+
+        String url = "https://openapi-test.sinoiov.cn/save/apis/routerPath";
+        // 设置 http 读写超时
+        DataExchangeService des = new DataExchangeService(5000, 8000);
+        System.out.println("请求地址:"+url);
+        // 通过 https 方式调用,此方法内部会使用私钥生成签名参数 sign,私钥不会发送
+        String res = des.postHttps(url, map);
+    }
 }
 

+ 21 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/controller/HyTokenController.java

@@ -0,0 +1,21 @@
+package com.yh.saas.plugin.yiliangyiyun.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 记录token 前端控制器
+ * </p>
+ *
+ * @author Gdc
+ * @since 2022-07-07
+ */
+@RestController
+@RequestMapping("/hyToken")
+public class HyTokenController {
+
+}
+

+ 43 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/entity/HyToken.java

@@ -0,0 +1,43 @@
+package com.yh.saas.plugin.yiliangyiyun.entity;
+
+import com.baomidou.mybatisplus.activerecord.Model;
+import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotations.Version;
+
+import com.yh.saas.common.support.entity.BaseModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 记录token
+ * </p>
+ *
+ * @author Gdc
+ * @since 2022-07-07
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+public class HyToken extends BaseModel<HyToken> {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    private String id;
+    /**
+     * token
+     */
+    private String token;
+
+
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+
+}

+ 16 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/mapper/HyTokenMapper.java

@@ -0,0 +1,16 @@
+package com.yh.saas.plugin.yiliangyiyun.mapper;
+
+import com.yh.saas.plugin.yiliangyiyun.entity.HyToken;
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 记录token Mapper 接口
+ * </p>
+ *
+ * @author Gdc
+ * @since 2022-07-07
+ */
+public interface HyTokenMapper extends BaseMapper<HyToken> {
+
+}

+ 16 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/IHyTokenService.java

@@ -0,0 +1,16 @@
+package com.yh.saas.plugin.yiliangyiyun.service;
+
+import com.yh.saas.plugin.yiliangyiyun.entity.HyToken;
+import com.baomidou.mybatisplus.service.IService;
+
+/**
+ * <p>
+ * 记录token 服务类
+ * </p>
+ *
+ * @author Gdc
+ * @since 2022-07-07
+ */
+public interface IHyTokenService extends IService<HyToken> {
+
+}

+ 20 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/HyTokenServiceImpl.java

@@ -0,0 +1,20 @@
+package com.yh.saas.plugin.yiliangyiyun.service.impl;
+
+import com.yh.saas.plugin.yiliangyiyun.entity.HyToken;
+import com.yh.saas.plugin.yiliangyiyun.mapper.HyTokenMapper;
+import com.yh.saas.plugin.yiliangyiyun.service.IHyTokenService;
+import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 记录token 服务实现类
+ * </p>
+ *
+ * @author Gdc
+ * @since 2022-07-07
+ */
+@Service
+public class HyTokenServiceImpl extends ServiceImpl<HyTokenMapper, HyToken> implements IHyTokenService {
+
+}

+ 5 - 0
winsea-haixin-plugin-wangluohuoyun/src/main/resources/mapper/HyTokenMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yh.saas.plugin.yiliangyiyun.mapper.HyTokenMapper">
+
+</mapper>