From 51aa6b4f8a3d199b3e5f93f7b5513a040aecfc10 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 14 四月 2022 15:00:22 +0800
Subject: [PATCH] 优化代码

---
 service-job/src/main/java/com/java110/job/adapt/DatabusAdaptImpl.java |  109 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 108 insertions(+), 1 deletions(-)

diff --git a/service-job/src/main/java/com/java110/job/adapt/DatabusAdaptImpl.java b/service-job/src/main/java/com/java110/job/adapt/DatabusAdaptImpl.java
old mode 100644
new mode 100755
index 4573330..391d309
--- a/service-job/src/main/java/com/java110/job/adapt/DatabusAdaptImpl.java
+++ b/service-job/src/main/java/com/java110/job/adapt/DatabusAdaptImpl.java
@@ -16,8 +16,14 @@
 package com.java110.job.adapt;
 
 import com.alibaba.fastjson.JSONObject;
+import com.java110.core.client.RestTemplate;
+import com.java110.dto.businessDatabus.CustomBusinessDatabusDto;
+import com.java110.dto.machine.MachineDto;
+import com.java110.dto.tempCarFeeConfig.TempCarPayOrderDto;
 import com.java110.entity.order.Business;
+import com.java110.job.adapt.hcIot.GetToken;
 import com.java110.vo.ResultVo;
+import org.springframework.http.HttpHeaders;
 
 import java.util.List;
 
@@ -26,12 +32,113 @@
  */
 public abstract class DatabusAdaptImpl implements IDatabusAdapt {
 
+    /**
+     * 灏佽澶翠俊鎭�
+     *
+     * @return
+     */
+    protected HttpHeaders getHeaders(RestTemplate outRestTemplate) {
+        HttpHeaders httpHeaders = new HttpHeaders();
+        httpHeaders.add("access_token", GetToken.get(outRestTemplate, false));
+        //httpHeaders.add("Content-Type", "application/x-www-form-urlencoded");
+        return httpHeaders;
+    }
 
+
+    /**
+     * 寮�闂�
+     *
+     * @param paramIn 涓氬姟淇℃伅
+     * @return
+     */
     @Override
     public ResultVo openDoor(JSONObject paramIn) {
         return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
     }
 
     @Override
-    public abstract void execute(Business business, List<Business> businesses);
+    public ResultVo getQRcode(JSONObject reqJson) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    @Override
+    public ResultVo customCarInOut(JSONObject reqJson) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    @Override
+    public ResultVo payVideo(MachineDto machineDto) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    @Override
+    public ResultVo heartbeatVideo(JSONObject reqJson) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+
+    /**
+     * 閲嶅惎璁惧
+     *
+     * @param paramIn
+     * @return
+     */
+    @Override
+    public ResultVo restartMachine(JSONObject paramIn) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    /**
+     * 澶辫触閲嶆柊閫両OT
+     *
+     * @param paramIn
+     * @return
+     */
+    @Override
+    public ResultVo reSendToIot(JSONObject paramIn) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    /**
+     * 鏌ヨ 涓存椂杞﹀緟鏀粯璁㈠崟
+     *
+     * @param tempCarPayOrderDto
+     * @return
+     */
+    @Override
+    public ResultVo getTempCarFeeOrder(TempCarPayOrderDto tempCarPayOrderDto) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+    /**
+     * 鏌ヨ 涓存椂杞﹀緟鏀粯璁㈠崟
+     *
+     * @param tempCarPayOrderDto
+     * @return
+     */
+    @Override
+    public ResultVo notifyTempCarFeeOrder(TempCarPayOrderDto tempCarPayOrderDto) {
+        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
+    }
+
+
+    /**
+     * 涓氫富澶勭悊鎵ц
+     *
+     * @param business   褰撳墠澶勭悊涓氬姟
+     * @param businesses 鎵�鏈変笟鍔′俊鎭�
+     */
+    @Override
+    public void execute(Business business, List<Business> businesses) throws Exception {
+
+    }
+
+    /**
+     * 鎵嬪伐 閫佹暟鎹�
+     *
+     * @param customBusinessDatabusDto
+     */
+    public void customExchange(CustomBusinessDatabusDto customBusinessDatabusDto) {
+
+    }
 }

--
Gitblit v1.8.0