update 电单车协议

jsowell-netty/src/main/java/com/jsowell/netty/handler/electricbicycles/SettlementUploadHandler.java

@@ -3,15 +3,30 @@ package com.jsowell.netty.handler.electricbicycles;
 import com.alibaba.fastjson2.JSON;
 import com.jsowell.common.constant.Constants;
 import com.jsowell.common.core.domain.ebike.EBikeDataProtocol;
+import com.jsowell.common.core.redis.RedisCache;
+import com.jsowell.common.enums.ykc.OrderStatusEnum;
+import com.jsowell.common.util.StringUtils;
 import com.jsowell.common.util.YKCUtils;
+import com.jsowell.common.util.id.IdUtils;
 import com.jsowell.netty.factory.EBikeOperateFactory;
+import com.jsowell.pile.domain.OrderBasicInfo;
 import com.jsowell.pile.domain.ebike.AbsEBikeMessage;
 import com.jsowell.pile.domain.ebike.EBikeCommandEnum;
 import com.jsowell.pile.domain.ebike.deviceupload.EBikeMessageCmd03;
+import com.jsowell.pile.service.OrderBasicInfoService;
+import com.jsowell.pile.service.PersonalChargingRecordService;
+import com.jsowell.pile.service.PileBasicInfoService;
+import com.jsowell.pile.service.PileMerchantInfoService;
+import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
+import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
+import com.jsowell.thirdparty.common.CommonService;
 import io.netty.channel.ChannelHandlerContext;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
+
 /**
  * 结算消费信息上传
  */
@@ -21,6 +36,24 @@ public class SettlementUploadHandler extends AbstractEBikeHandler {
     // private final String type = EBikeCommandEnum.SETTLEMENT_UPLOAD.getCode();
     private final String type = YKCUtils.frameType2Str(EBikeCommandEnum.SETTLEMENT_UPLOAD.getBytes());
 
+    @Autowired
+    private RedisCache redisCache;
+
+    @Autowired
+    private OrderBasicInfoService orderBasicInfoService;
+
+    @Autowired
+    private PileMerchantInfoService pileMerchantInfoService;
+
+    @Autowired
+    private CommonService commonService;
+
+    @Autowired
+    private PileBasicInfoService pileBasicInfoService;
+
+    @Autowired
+    private PersonalChargingRecordService personalChargingRecordService;
+
     @Override
     public void afterPropertiesSet() throws Exception {
         EBikeOperateFactory.register(type, this);
@@ -42,8 +75,64 @@ public class SettlementUploadHandler extends AbstractEBikeHandler {
         EBikeMessageCmd03.SettlementInfo settlementInfo = message.getSettlementInfo();
         log.info("结算消费信息上传:{}", JSON.toJSONString(message));
 
+        String transactionCode = settlementInfo.getOrderNumber();
+        // 处理订单加锁/结算电单车订单
+        String lockKey = "settle_order_" + transactionCode;
+        String uuid = IdUtils.fastUUID();
+        try {
+            // redis锁
+            Boolean isLock = redisCache.lock(lockKey, uuid, 1500);
+            if (isLock) {
+                processOrder(message);
+            }
+        } catch (Exception e) {
+            log.error("处理订单transactionCode:{}, 发生异常", transactionCode, e);
+        } finally {
+            if (uuid.equals(redisCache.getCacheObject(lockKey).toString())) {
+                redisCache.unLock(lockKey);
+            }
+        }
+
         // 返回结果
         return getResult(dataProtocol, Constants.zeroByteArray);
     }
 
+    /**
+     * 收到交易记录 处理订单
+     */
+    private void processOrder(EBikeMessageCmd03 message) {
+        EBikeMessageCmd03.SettlementInfo settlementInfo = message.getSettlementInfo();
+        String transactionCode = settlementInfo.getOrderNumber();
+        // 根据交易流水号查询订单信息
+        OrderBasicInfo orderBasicInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
+        if (orderBasicInfo != null) {
+            // 平台存在订单
+            String stopReason = settlementInfo.getStopReason();
+            // orderBasicInfo.setReason(data.getStopReasonMsg());
+            // 如果订单状态为 异常，则改为 待结算
+            if (StringUtils.equals(OrderStatusEnum.ABNORMAL.getValue(), orderBasicInfo.getOrderStatus())) {
+                orderBasicInfo.setOrderStatus(OrderStatusEnum.STAY_SETTLEMENT.getValue());
+            }
+
+            // 校验结束时间
+            if (orderBasicInfo.getChargeEndTime().before(orderBasicInfo.getChargeStartTime())) {
+                orderBasicInfo.setChargeEndTime(new Date());
+            }
+
+            orderBasicInfoService.updateOrderBasicInfo(orderBasicInfo);
+
+            // 重新查询订单信息
+            orderBasicInfo = orderBasicInfoService.getOrderInfoByTransactionCode(transactionCode);
+
+            // 结算订单操作
+            try {
+                // 新逻辑
+                String mode = pileMerchantInfoService.getDelayModeByMerchantId(orderBasicInfo.getMerchantId());
+                AbstractProgramLogic orderLogic = ProgramLogicFactory.getProgramLogic(mode);
+                orderLogic.settleOrderForEBike(message, orderBasicInfo);
+            } catch (Exception e) {
+                log.error("结算订单发生异常 orderCode:{}", orderBasicInfo.getOrderCode(), e);
+            }
+        }
+    }
 }