1

src/main/java/cn/van333/wxsend/business/controller/DCController.java

@@ -0,0 +1,49 @@
+package cn.van333.wxsend.business.controller;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.van333.wxsend.aop.annotation.RateLimiter;
+import cn.van333.wxsend.business.model.R;
+import cn.van333.wxsend.business.service.LogService;
+import cn.van333.wxsend.enums.WXMessageType;
+import cn.van333.wxsend.util.SourceForQLUtil;
+import cn.van333.wxsend.util.TokenUtil;
+import cn.van333.wxsend.util.WxSendUtil;
+import cn.van333.wxsend.util.request.MessageRequest;
+import com.alibaba.fastjson2.JSON;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * @author Leo
+ * @version 1.0
+ * @create 2023/10/07 0007 下午 02:25
+ * @description：
+ */
+@RestController
+@RequestMapping("/dc")
+public class DCController {
+    private static final Logger logger = LoggerFactory.getLogger(LogService.class);
+
+    @RequestMapping(value = "/send/ty")
+    @ResponseBody
+    @RateLimiter(time = 10, count = 60)
+    public R sendToTY(@RequestBody MessageRequest message) throws Exception {
+        logger.info(message.toString());
+
+        if (!TokenUtil.checkToken(message.getVanToken())) {
+            return R.error("vanToken无效");
+        }
+        if (!StrUtil.isAllNotEmpty(message.getTitle(), message.getText())) {
+            return R.error("缺少标题和内容");
+        }
+        String result = WxSendUtil.sendNotify(message.getTitle(), message.getText(), message.getTouser(), WXMessageType.TY);
+        return R.ok(result);
+    }
+}

src/main/java/cn/van333/wxsend/util/JDUtils.java

@@ -0,0 +1,61 @@
+package cn.van333.wxsend.util;
+
+import com.alibaba.fastjson2.JSON;
+import com.jd.open.api.sdk.DefaultJdClient;
+import com.jd.open.api.sdk.JdClient;
+import com.jd.open.api.sdk.domain.kplunion.OrderService.request.query.OrderRowReq;
+import com.jd.open.api.sdk.domain.kplunion.OrderService.response.query.OrderRowResp;
+import com.jd.open.api.sdk.request.JdRequest;
+import com.jd.open.api.sdk.request.kplunion.UnionOpenOrderRowQueryRequest;
+import com.jd.open.api.sdk.response.AbstractResponse;
+import com.jd.open.api.sdk.response.kplunion.UnionOpenOrderRowQueryResponse;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * @author Leo
+ * @version 1.0
+ * @create 2024/11/5 17:40
+ * @description：
+ */
+public class JDUtils {
+    private static final String SERVER_URL =
+            "https://api.jd.com/routerjson";
+    private static final String APP_KEY =
+            "98e21c89ae5610240ec3f5f575f86a59";
+    private static final String SECRET_KEY =
+            "3dcb6b23a1104639ac433fd07adb6dfb";
+
+
+    public static void main(String[] args) throws Exception {
+        String accessToken = "";
+        JdClient client = new DefaultJdClient(SERVER_URL, accessToken, APP_KEY, SECRET_KEY);
+        UnionOpenOrderRowQueryRequest request = new UnionOpenOrderRowQueryRequest();
+        OrderRowReq orderReq = new OrderRowReq();
+        orderReq.setPageIndex(1);
+        orderReq.setPageSize(20);
+        orderReq.setStartTime("2024-11-01 00:00:00");
+        orderReq.setEndTime("2024-11-05 23:59:59");
+        orderReq.setType(1);
+
+
+        request.setOrderReq(orderReq);
+        request.setVersion("1.0");
+        request.setSignmethod("md5");
+        // 时间戳，格式为yyyy-MM-dd HH:mm:ss，时区为GMT+8。API服务端允许客户端请求最大时间误差为10分钟
+        Date date = new Date();
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        request.setTimestamp(simpleDateFormat.format(date));
+
+
+        UnionOpenOrderRowQueryResponse response = client.execute(request);
+        System.out.println("响应码：" + response.getQueryResult().getCode());
+        System.out.println(JSON.toJSONString(response));
+        OrderRowResp[] orderRowResps = response.getQueryResult().getData();
+        //for (OrderRowResp orderRowResp : orderRowResps) {
+        //    System.out.println(orderRowResp.getOrderId());
+        //}
+    }
+
+}