开发ar前端。接口。

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinArActiveService.java

+package com.liquidnet.service.kylin.service;
+
+import com.liquidnet.service.base.ResponseDto;
+
+/**
+ * ar前端接口
+ */
+public interface IKylinArActiveService {
+    /**
+     * 兑换
+     * @param code
+     * @param uid
+     * @return
+     */
+    ResponseDto exchange(String code, String uid);
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinTicketActiveService.java → liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/admin/IKylinTicketActiveService.java

-package com.liquidnet.service.kylin.service;
+package com.liquidnet.service.kylin.service.admin;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.github.pagehelper.PageInfo;
 import com.liquidnet.service.kylin.dao.KylinTicketActive;
 
 import java.util.List;

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinAcitveServiceImpl.java

@@ -11,7 +11,7 @@ import com.liquidnet.service.kylin.dao.KylinAcitve;
 import com.liquidnet.service.kylin.dao.KylinTicketActive;
 import com.liquidnet.service.kylin.mapper.KylinAcitveMapper;
 import com.liquidnet.service.kylin.mapper.KylinTicketActiveMapper;
-import com.liquidnet.service.kylin.service.IKylinTicketActiveService;
+import com.liquidnet.service.kylin.service.admin.IKylinTicketActiveService;
 import com.liquidnet.service.kylin.service.admin.IKylinAcitveService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinTicketActiveServiceImpl.java

@@ -7,7 +7,7 @@ import com.github.pagehelper.PageHelper;
 import com.liquidnet.client.admin.zhengzai.kylin.dto.ActiveTicketExportVo;
 import com.liquidnet.service.kylin.dao.KylinTicketActive;
 import com.liquidnet.service.kylin.mapper.KylinTicketActiveMapper;
-import com.liquidnet.service.kylin.service.IKylinTicketActiveService;
+import com.liquidnet.service.kylin.service.admin.IKylinTicketActiveService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinArActiveController.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.kylin.controller;
 
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.service.impl.KylinArActiveServiceImpl;
 import com.liquidnet.service.kylin.utils.DataUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -10,6 +11,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -24,8 +26,8 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("arActive")
 @Slf4j
 public class KylinArActiveController {
-    /*@Autowired
-    private IKylinAcitveService iKylinAcitveService;*/
+    @Autowired
+    private KylinArActiveServiceImpl kylinArActiveService;
     @Autowired
     private DataUtils dataUtils;
 
@@ -39,13 +41,12 @@ public class KylinArActiveController {
             return   ResponseDto.success(dataUtils.getUserStatus(uid));
         }
     }
-  /*  @PostMapping("exchangeCode")
+    @PostMapping("exchangeCode")
     @ApiOperation("兑换码兑换")
     public ResponseDto<String> exchangeCode(@RequestParam(value = "code")String code) {
         String uid = CurrentUtil.getCurrentUid();
-        return iKylinAcitveService.exchange(code,uid);
+        return kylinArActiveService.exchange(code,uid);
     }
-*/
 
 
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinArActiveServiceImpl.java

+package com.liquidnet.service.kylin.service.impl;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.kylin.dao.KylinTicketActive;
+import com.liquidnet.service.kylin.service.IKylinArActiveService;
+import com.liquidnet.service.kylin.utils.DataUtils;
+import com.liquidnet.service.kylin.utils.QueueUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 人流量检测记录表 服务实现类
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2022-01-10
+ */
+@Service
+public class KylinArActiveServiceImpl implements IKylinArActiveService {
+    @Autowired
+    private DataUtils dataUtils;
+    @Autowired
+    private QueueUtils queueUtils;
+    @Override
+    public ResponseDto exchange(String code, String uid) {
+        //1 查看是否有兑换码
+        KylinTicketActive kylinTicketActive=dataUtils.getArTicket(code);
+        if(null==kylinTicketActive){
+            return ResponseDto.failure("兑换码错误");
+        }
+        //2、查看该用户是否绑定
+        if(null!=dataUtils.getUserStatus(uid)){
+            return ResponseDto.failure("该用户已经绑定");
+        }
+        //判断是否用过卷了
+        if(kylinTicketActive.getState()==2){
+            return ResponseDto.failure("该券已经兑换");
+        }
+        //开始绑定
+        //修改redis缓存
+        dataUtils.setUser(uid,"1");
+        kylinTicketActive.setState(2);
+        dataUtils.setArTicket(kylinTicketActive);
+        //队列 修改券的状态。
+        queueUtils.sendMsgByRedis(
+                MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getKey(),
+                SqlMapping.get(
+                        "kylin_ar_ticket.update",
+                        new Object[]{
+                            uid, LocalDateTime.now(),code
+                        }
+                ));
+        return ResponseDto.success();
+    }
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java

@@ -5,6 +5,7 @@ import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
+import com.liquidnet.service.kylin.dao.KylinTicketActive;
 import com.liquidnet.service.kylin.dto.vo.KylinApiCameraDevicesVo;
 import com.liquidnet.service.kylin.dto.vo.WqTempVo;
 import com.liquidnet.service.kylin.dto.vo.admin.OrderRefundAddress;
@@ -950,5 +951,18 @@ public class DataUtils {
     public String getUserStatus(String userId) {
         return (String) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_USER+ userId);
     }
+    //获得 ar券
+    public KylinTicketActive getArTicket(String code){
+       return (KylinTicketActive) redisUtil.get(KylinRedisConst.ACTIVE_TICKET_AR_TICKET+code);
+    }
+    //设置 tikcet
+    public void setArTicket(KylinTicketActive kylinTicketActive){
+        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_TICKET+kylinTicketActive.getCode(),kylinTicketActive);
+    }
+    //设置用户状态。
+    public void setUser(String userId,String value){
+        redisUtil.set(KylinRedisConst.ACTIVE_TICKET_AR_USER+userId,value);
+
+    }
 
 }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/sqlmap.properties

@@ -36,3 +36,5 @@ kylin_perform_sub.insert=INSERT INTO kylin_perform_sub (perform_sub_id,performan
 # ------------------------ 万青弥补订单 ----------------------------
 kylin_order_express_ex.insert = INSERT INTO kylin_order_express_ex (`order_id`,`express_contacts`,`express_address`,`province`,`city`,`county`,`express_phone`,`created_at`) VALUES (?,?,?,?,?,?,?,?)
 kylin_order_express_ex.sendMail = UPDATE kylin_order_express_ex SET mail_no = ? , updated_at = ? where order_id = ?
+# ------------------------ ar演出队列 ----------------------------
+kylin_ar_ticket.update =update kylin_ticket_active set redeem_uid= ?,redeem_at= ? where `code`= ？
\ No newline at end of file