TRX 1 yıl önce
ebeveyn
işleme
f008cecdab

+ 9 - 9
OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/controller/payment/HxzController.java

@@ -22,14 +22,14 @@ public class HxzController {
 
     @Autowired
     private HxzService hxzService;
-
-    /**
-     * 系统时间
-     */
-    @Operation(summary = "获取服务器时间接口")
-    @PostMapping(value = "ServerTime", consumes = MediaType.APPLICATION_JSON_VALUE)
-    public ServerTimeResult serverTime(@RequestBody ServerTimeModel serverTimeModel) {
-        return hxzService.serverTime(serverTimeModel);
-    }
+    
+//    /**
+//     * 系统时间
+//     */
+//    @Operation(summary = "获取服务器时间接口")
+//    @PostMapping(value = "ServerTime", consumes = MediaType.APPLICATION_JSON_VALUE)
+//    public ServerTimeResult serverTime(@RequestBody ServerTimeModel serverTimeModel) {
+//        return hxzService.serverTime(serverTimeModel);
+//    }
 
 }

+ 8 - 31
OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/httpRequest/conf/FullCardAPIConfig.java

@@ -20,23 +20,16 @@ public class FullCardAPIConfig {
 
     public static final String ping = api + "/test/free/ping";
 
-    //-----------------------云版消费机 start -----------------------
-    public static final String ServerTime = api + "/hxz/v1/ServerTime";
-    public static final String ConsumTransactions = api + "/hxz/v1/ConsumTransactions";
-    public static final String orderQuery = api + "/hxz/v1/orderQuery";
-
-    public static final String QRCodeTransaction = api + "/hxz/v1/QRCodeTransaction";
-    public static final String TransactionInquiry = api + "/hxz/v1/TransactionInquiry";
-
     // 全卡业务平台 start -----------------
     // 同步设备
-    public static final String deviceSync = api + "/deviceSync/syncDevices";
-    public static final String syncGateWays = api + "/deviceSync/syncGateWays";
-
-    public static final String syncDeviceOnLineState = api + "/deviceSync/syncDeviceOnLineState";
-    public static final String lastDeviceOnLineTime = api + "/deviceSync/lastDeviceOnLineTime";
+    public static final String deviceSync = api + "/openAPI/v1/deviceSync/syncDevices";
+    // 同步删除设备
+    public static final String deleteDevice = api + "/openAPI/v1/deviceSync/deleteDevice";
 
-    public static final String iotQueryProjectConfig = api + "/openAPI/projectConfig/v1/iotQueryProjectConfig";
+    // 同步设备状态
+    public static final String syncDeviceOnLineState = api + "/openAPI/v1/deviceSync/syncDeviceOnLineState";
+    // 同步设备在线时间
+    public static final String lastDeviceOnLineTime = api + "/openAPI/v1/deviceSync/lastDeviceOnLineTime";
 
     public static final HashMap<String, ApiConfParam> map = new HashMap<>();
 
@@ -44,27 +37,11 @@ public class FullCardAPIConfig {
         map.put(sendMessage, ApiConfParam.builder().apiName(sendMessage).methodType(MethodType.Json.name()).build());
         map.put(ping, ApiConfParam.builder().apiName(ping).methodType(MethodType.Json.name()).build());
 
-        // ----------------------------云版消费机 start -----------------
-        map.put(ServerTime, ApiConfParam.builder().apiName(ServerTime).methodType(MethodType.Json.name()).build());
-
-        // 刷卡支付相关的接口配置
-        map.put(ConsumTransactions, ApiConfParam.builder().apiName(ConsumTransactions).methodType(MethodType.Json.name()).build());
-        map.put(orderQuery, ApiConfParam.builder().apiName(orderQuery).methodType(MethodType.Json.name()).build());
-
-        // B扫C功能接口配置
-        map.put(QRCodeTransaction, ApiConfParam.builder().apiName(QRCodeTransaction).methodType(MethodType.Json.name()).build());
-        map.put(TransactionInquiry, ApiConfParam.builder().apiName(TransactionInquiry).methodType(MethodType.Json.name()).build());
-
-
         // ----------------------------全卡项目 start -----------------
         map.put(deviceSync, ApiConfParam.builder().apiName(deviceSync).methodType(MethodType.Json.name()).build());
-        map.put(syncGateWays, ApiConfParam.builder().apiName(syncGateWays).methodType(MethodType.Json.name()).build());
         map.put(syncDeviceOnLineState, ApiConfParam.builder().apiName(syncDeviceOnLineState).methodType(MethodType.Json.name()).build());
         map.put(lastDeviceOnLineTime, ApiConfParam.builder().apiName(lastDeviceOnLineTime).methodType(MethodType.Json.name()).build());
-
-        // 查询项目的配置信息
-        map.put(iotQueryProjectConfig, ApiConfParam.builder().apiName(iotQueryProjectConfig).methodType(MethodType.Json.name()).build());
-
+        map.put(deleteDevice, ApiConfParam.builder().apiName(deleteDevice).methodType(MethodType.Json.name()).build());
     }
 
     public static ApiConfParam getApiConfParam(String apiName) {

+ 123 - 138
OneCardIotServer/src/main/java/com/zhongshu/iot/server/core/service/payment/HxzService.java

@@ -1,29 +1,14 @@
 package com.zhongshu.iot.server.core.service.payment;
 
-import cn.hutool.json.JSONUtil;
-import com.github.microservice.models.hxz.*;
-import com.github.microservice.types.payment.PaymentType;
 import com.zhongshu.iot.server.core.dao.mqtt.DeviceInfoDao;
 import com.zhongshu.iot.server.core.domain.ExecuteAnnotationService;
-import com.zhongshu.iot.server.core.domain.ExecuteAnnotationServiceMethod;
-import com.zhongshu.iot.server.core.domain.iot.device.DeviceInfo;
 import com.zhongshu.iot.server.core.httpRequest.ApiRequestService;
-import com.github.microservice.http.APIResponseModel;
-import com.zhongshu.iot.server.core.httpRequest.conf.FullCardAPIConfig;
 import com.zhongshu.iot.server.core.service.base.SuperService;
 import com.zhongshu.iot.server.core.service.other.RequestInfoService;
-import com.github.microservice.net.ResultContent;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.text.SimpleDateFormat;
-import java.time.DayOfWeek;
-import java.time.LocalDate;
-import java.util.Date;
-import java.util.Map;
-
 /**
  * @author TRX
  * @date 2024/6/25
@@ -42,128 +27,128 @@ public class HxzService extends SuperService {
     @Autowired
     ApiRequestService apiRequestService;
 
-    public ServerTimeResult serverTime(ServerTimeModel param) {
-        String deviceId = param.getDeviceID().toString();
-        ServerTimeResult result = new ServerTimeResult();
-        DeviceInfo deviceInfo = deviceInfoDao.findTopByDeviceId(deviceId);
-        if (ObjectUtils.isEmpty(deviceInfo)) {
-            result.setFailed("设备未注册");
-            requestInfoService.addHXZRequestInfo(param, result);
-            return result;
-        }
-        // 业务验证
-        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
-                FullCardAPIConfig.ServerTime, param);
-        if (resultContent.isSuccess()) {
-            ServerTimeResult timeResult = resultContent.toBean(ServerTimeResult.class);
-
-            if (timeResult.isSuccess()) {
-                var nowTime = new Date(System.currentTimeMillis());
-                LocalDate date = LocalDate.now();
-                int week = Map.of(DayOfWeek.MONDAY, 1, DayOfWeek.TUESDAY, 2, DayOfWeek.WEDNESDAY, 3, DayOfWeek.THURSDAY, 4, DayOfWeek.FRIDAY, 5, DayOfWeek.SATURDAY, 6, DayOfWeek.SUNDAY, 0).get(date.getDayOfWeek());
-                result.setSuccess();
-                result.setTime(new SimpleDateFormat("yyyyMMddHHmmss").format(nowTime) + "" + week);
-                result.setWLPage(0);
-                result.setWLUptate(0);
-                log.info("ServerTime : {} - {}", result);
-            } else {
-                result.setFailed(timeResult.getMsg());
-            }
-        } else {
-            result.setFailed(resultContent.getMsg());
-        }
-        return result;
-    }
-
-    /**
-     * 刷卡扣费
-     *
-     * @param dataStr
-     * @return
-     */
-    @ExecuteAnnotationServiceMethod(value = "ConsumTransactions", remark = "云版消费机 2.2 用户刷卡综合接口")
-    public ResultContent<Object> consumTransactions(String dataStr) {
-        ConsumTransactionsModel params = JSONUtil.toBean(dataStr, ConsumTransactionsModel.class);
-        ConsumTransactionsResult ret = new ConsumTransactionsResult();
-
-        ConsumTransactionsFullParam param = new ConsumTransactionsFullParam();
-        param.setParam(params);
-        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
-                FullCardAPIConfig.ConsumTransactions, param);
-        if (resultContent.isSuccess()) {
-            // 请求成功
-            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
-            ret = fullResult.getModel();
-        } else {
-            // 失败
-            ret.setStatus(0);
-            ret.setMsg(resultContent.getMsg());
-        }
-        return ResultContent.buildSuccess(ret);
-    }
-
-    @ExecuteAnnotationServiceMethod(value = "orderQuery", remark = "云版消费机 2.3 用户刷卡消费结果查询接口")
-    public ResultContent<Object> orderQuery(String dataStr) {
-        OrderQueryModel param = JSONUtil.toBean(dataStr, OrderQueryModel.class);
-
-        ConsumTransactionsResult ret = new ConsumTransactionsResult();
-        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
-                FullCardAPIConfig.orderQuery, param);
-        if (resultContent.isSuccess()) {
-            // 请求成功
-            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
-            ret = fullResult.getModel();
-        } else {
-            // 失败
-            ret.setStatus(0);
-            ret.setMsg(resultContent.getMsg());
-        }
-        return ResultContent.buildSuccess(ret);
-    }
-
-    /**
-     * 付款码(二维码)
-     *
-     * @param dataStr
-     * @return
-     */
-    @ExecuteAnnotationServiceMethod(value = "QRCodeTransaction", remark = "云版消费机 2.7 付款码(二维码)支付接口")
-    public ResultContent<Object> QRCodeTransaction(String dataStr) {
-        QRCodeTransactionModel params = JSONUtil.toBean(dataStr, QRCodeTransactionModel.class);
-        // 根据QR判断支付模式
-        params.setPaymentType(PaymentType.WxQrCode);
-
-        QRCodeTransactionResult ret = new QRCodeTransactionResult();
-        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
-                FullCardAPIConfig.QRCodeTransaction, params);
-        if (resultContent.isSuccess()) {
-            // 请求成功
-            QRCodeTransactionFullResult fullResult = resultContent.toBean(QRCodeTransactionFullResult.class);
-            ret = fullResult.getModel();
-        } else {
-            // 失败
-            ret.setStatus(0);
-            ret.setMsg(resultContent.getMsg());
-        }
-        return ResultContent.buildSuccess(ret);
-    }
-
-    @ExecuteAnnotationServiceMethod(value = "TransactionInquiry", remark = "云版消费机 2.8.二维码支付结果查询接口")
-    public ResultContent<Object> TransactionInquiry(String dataStr) {
-        TransactionInquiryModel params = JSONUtil.toBean(dataStr, TransactionInquiryModel.class);
-        ConsumTransactionsResult ret = new ConsumTransactionsResult();
-        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
-                FullCardAPIConfig.TransactionInquiry, params);
-        if (resultContent.isSuccess()) {
-            // 请求成功
-            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
-            ret = fullResult.getModel();
-        } else {
-            // 失败
-            ret.setStatus(0);
-            ret.setMsg(resultContent.getMsg());
-        }
-        return ResultContent.buildSuccess(ret);
-    }
+//    public ServerTimeResult serverTime(ServerTimeModel param) {
+//        String deviceId = param.getDeviceID().toString();
+//        ServerTimeResult result = new ServerTimeResult();
+//        DeviceInfo deviceInfo = deviceInfoDao.findTopByDeviceId(deviceId);
+//        if (ObjectUtils.isEmpty(deviceInfo)) {
+//            result.setFailed("设备未注册");
+//            requestInfoService.addHXZRequestInfo(param, result);
+//            return result;
+//        }
+//        // 业务验证
+//        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
+//                FullCardAPIConfig.ServerTime, param);
+//        if (resultContent.isSuccess()) {
+//            ServerTimeResult timeResult = resultContent.toBean(ServerTimeResult.class);
+//
+//            if (timeResult.isSuccess()) {
+//                var nowTime = new Date(System.currentTimeMillis());
+//                LocalDate date = LocalDate.now();
+//                int week = Map.of(DayOfWeek.MONDAY, 1, DayOfWeek.TUESDAY, 2, DayOfWeek.WEDNESDAY, 3, DayOfWeek.THURSDAY, 4, DayOfWeek.FRIDAY, 5, DayOfWeek.SATURDAY, 6, DayOfWeek.SUNDAY, 0).get(date.getDayOfWeek());
+//                result.setSuccess();
+//                result.setTime(new SimpleDateFormat("yyyyMMddHHmmss").format(nowTime) + "" + week);
+//                result.setWLPage(0);
+//                result.setWLUptate(0);
+//                log.info("ServerTime : {} - {}", result);
+//            } else {
+//                result.setFailed(timeResult.getMsg());
+//            }
+//        } else {
+//            result.setFailed(resultContent.getMsg());
+//        }
+//        return result;
+//    }
+//
+//    /**
+//     * 刷卡扣费
+//     *
+//     * @param dataStr
+//     * @return
+//     */
+//    @ExecuteAnnotationServiceMethod(value = "ConsumTransactions", remark = "云版消费机 2.2 用户刷卡综合接口")
+//    public ResultContent<Object> consumTransactions(String dataStr) {
+//        ConsumTransactionsModel params = JSONUtil.toBean(dataStr, ConsumTransactionsModel.class);
+//        ConsumTransactionsResult ret = new ConsumTransactionsResult();
+//
+//        ConsumTransactionsFullParam param = new ConsumTransactionsFullParam();
+//        param.setParam(params);
+//        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
+//                FullCardAPIConfig.ConsumTransactions, param);
+//        if (resultContent.isSuccess()) {
+//            // 请求成功
+//            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
+//            ret = fullResult.getModel();
+//        } else {
+//            // 失败
+//            ret.setStatus(0);
+//            ret.setMsg(resultContent.getMsg());
+//        }
+//        return ResultContent.buildSuccess(ret);
+//    }
+//
+//    @ExecuteAnnotationServiceMethod(value = "orderQuery", remark = "云版消费机 2.3 用户刷卡消费结果查询接口")
+//    public ResultContent<Object> orderQuery(String dataStr) {
+//        OrderQueryModel param = JSONUtil.toBean(dataStr, OrderQueryModel.class);
+//
+//        ConsumTransactionsResult ret = new ConsumTransactionsResult();
+//        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
+//                FullCardAPIConfig.orderQuery, param);
+//        if (resultContent.isSuccess()) {
+//            // 请求成功
+//            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
+//            ret = fullResult.getModel();
+//        } else {
+//            // 失败
+//            ret.setStatus(0);
+//            ret.setMsg(resultContent.getMsg());
+//        }
+//        return ResultContent.buildSuccess(ret);
+//    }
+//
+//    /**
+//     * 付款码(二维码)
+//     *
+//     * @param dataStr
+//     * @return
+//     */
+//    @ExecuteAnnotationServiceMethod(value = "QRCodeTransaction", remark = "云版消费机 2.7 付款码(二维码)支付接口")
+//    public ResultContent<Object> QRCodeTransaction(String dataStr) {
+//        QRCodeTransactionModel params = JSONUtil.toBean(dataStr, QRCodeTransactionModel.class);
+//        // 根据QR判断支付模式
+//        params.setPaymentType(PaymentType.WxQrCode);
+//
+//        QRCodeTransactionResult ret = new QRCodeTransactionResult();
+//        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
+//                FullCardAPIConfig.QRCodeTransaction, params);
+//        if (resultContent.isSuccess()) {
+//            // 请求成功
+//            QRCodeTransactionFullResult fullResult = resultContent.toBean(QRCodeTransactionFullResult.class);
+//            ret = fullResult.getModel();
+//        } else {
+//            // 失败
+//            ret.setStatus(0);
+//            ret.setMsg(resultContent.getMsg());
+//        }
+//        return ResultContent.buildSuccess(ret);
+//    }
+//
+//    @ExecuteAnnotationServiceMethod(value = "TransactionInquiry", remark = "云版消费机 2.8.二维码支付结果查询接口")
+//    public ResultContent<Object> TransactionInquiry(String dataStr) {
+//        TransactionInquiryModel params = JSONUtil.toBean(dataStr, TransactionInquiryModel.class);
+//        ConsumTransactionsResult ret = new ConsumTransactionsResult();
+//        APIResponseModel resultContent = apiRequestService.sendFullCardAPI(
+//                FullCardAPIConfig.TransactionInquiry, params);
+//        if (resultContent.isSuccess()) {
+//            // 请求成功
+//            ConsumTransactionsFullResult fullResult = resultContent.toBean(ConsumTransactionsFullResult.class);
+//            ret = fullResult.getModel();
+//        } else {
+//            // 失败
+//            ret.setStatus(0);
+//            ret.setMsg(resultContent.getMsg());
+//        }
+//        return ResultContent.buildSuccess(ret);
+//    }
 
 }