提交 platform

liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/task/FeignKylinTaskClient.java → liquidnet-bus-feign/liquidnet-api-feign-kylin/src/main/java/com/liquidnet/service/feign/kylin/task/FeignPlatformTaskClient.java

@@ -7,14 +7,14 @@ import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.PostMapping;
 
 @Component
-@FeignClient(name = "liquidnet-service-kylin",
-        contextId = "FeignKylinTaskClient", path = "",
+@FeignClient(name = "liquidnet-service-platform",
+        contextId = "FeignPlatformTaskClient", path = "",
         fallback = FallbackFactory.Default.class)
-public interface FeignKylinTaskClient {
+public interface FeignPlatformTaskClient {
 
-    @PostMapping("kylin/order/checkOrderTime")
+    @PostMapping("platform/order/checkOrderTime")
     ResponseDto<Boolean> checkOrderTime();
 
-    @PostMapping("kylin/performance/checkPerformanceTime")
+    @PostMapping("platform/performance/checkPerformanceTime")
     ResponseDto<String> checkPerformanceTime();
 }

liquidnet-bus-service/liquidnet-service-executor-all/liquidnet-service-executor-main/src/main/java/com/liquidnet/service/executor/main/handler/KylinTaskHandler.java

 package com.liquidnet.service.executor.main.handler;
 
-import com.liquidnet.service.feign.kylin.task.FeignKylinTaskClient;
-import com.rabbitmq.client.Return;
+import com.liquidnet.service.feign.kylin.task.FeignPlatformTaskClient;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -22,12 +21,12 @@ public class KylinTaskHandler {
     private static final Logger log = LoggerFactory.getLogger(KylinTaskHandler.class);
 
     @Autowired
-    private FeignKylinTaskClient feignKylinTaskClient;
+    private FeignPlatformTaskClient feignPlatformTaskClient;
 
-    @XxlJob(value = "sev-kylin:checkOrderTimeHandler")
+    @XxlJob(value = "sev-platform:checkOrderTimeHandler")
     public ReturnT<String> checkOrderTimeHandler() {
         try {
-            boolean result = feignKylinTaskClient.checkOrderTime().getData();
+            boolean result = feignPlatformTaskClient.checkOrderTime().getData();
             log.info("checkOrderTimeHandler：结果："+result);
             return ReturnT.SUCCESS;
         } catch (Exception e) {
@@ -35,10 +34,10 @@ public class KylinTaskHandler {
         }
     }
 
-    @XxlJob(value = "sev-kylin:checkPerformanceTimeHandler")
+    @XxlJob(value = "sev-platform:checkPerformanceTimeHandler")
     public ReturnT<String> checkPerformanceTimeHandler() {
         try {
-            String result = feignKylinTaskClient.checkPerformanceTime().getData();
+            String result = feignPlatformTaskClient.checkPerformanceTime().getData();
             log.info("checkPerformanceTimeHandler：结果："+result);
             return ReturnT.SUCCESS;
         } catch (Exception e) {

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

+package com.liquidnet.service.platform.controller.kylin;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.platform.service.impl.kylin.DataImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+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.RestController;
+
+
+@Api(tags = "数据迁移 (会重复)")
+@RestController
+@RequestMapping("data")
+public class DataController {
+
+    @Autowired
+    private DataImpl data;
+
+    @PostMapping("performance")
+    @ApiOperation("演出数据迁移")
+    public ResponseDto<Boolean> performance() {
+        Boolean result = data.performance();
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("order")
+    @ApiOperation("订单数据迁移")
+    public ResponseDto<Boolean> order(String month) {
+        Boolean result = data.order(month);
+        return ResponseDto.success(result);
+    }
+
+    @PostMapping("roadShow")
+    @ApiOperation("巡演数据迁移")
+    public ResponseDto<Boolean> roadShow() {
+        Boolean result = data.roadShow();
+        return ResponseDto.success(result);
+    }
+
+}

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

+package com.liquidnet.service.platform.controller.kylin;
+
+
+import com.github.pagehelper.PageInfo;
+import com.liquidnet.service.base.ErrorMapping;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.dto.param.PayAgainParam;
+import com.liquidnet.service.kylin.dto.param.PayOrderParam;
+import com.liquidnet.service.kylin.dto.param.SyncOrderParam;
+import com.liquidnet.service.kylin.dto.vo.returns.*;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketsService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotNull;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * <p>
+ * 订单 前端控制器
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-20
+ */
+@Api(tags = "前端-订单相关")
+@RestController
+@RequestMapping("order")
+@Validated
+public class KylinOrderTicketsController {
+
+    @Autowired
+    IKylinOrderTicketsService orderTicketsService;
+
+    @PostMapping("checkOrderTime")
+    @ApiOperation("订单过期脚本")
+    @ApiResponse(code = 200, message = "接口返回对象参数")
+    public ResponseDto<Boolean> checkOrderTime() {
+        return ResponseDto.success(orderTicketsService.checkOrderTime(""));
+    }
+}

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

+package com.liquidnet.service.platform.controller.kylin;
+
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.platform.utils.PerformanceVoTask;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * <p>
+ * 演出 前端控制器
+ * </p>
+ *
+ * @author jiangxiulong
+ * @since 2021-05-11
+ */
+@Api(tags = "前端-演出")
+@RestController
+@RequestMapping("performance")
+public class KylinPerformancesController {
+
+    @Autowired
+    private PerformanceVoTask performanceVoTask;
+
+    @PostMapping("/checkPerformanceTime")
+    @ApiOperation("演出脚本")
+    public ResponseDto<String> checkPerformanceTime(@RequestParam(value = "performancesId",required = false)String performancesId){
+        try {
+            performanceVoTask.performanceVoStatus(performancesId);
+            return ResponseDto.success("成功");
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseDto.success("失败");
+        }
+    }
+}

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinBuyNoticePartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinBuyNoticePartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinCheckUserPartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinCheckUserPerformancesPartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPerformancesPartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinPerformancesPartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinPerformancesPartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinTicketTimesPartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketTimesPartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/partner/impl/KylinTicketsPartnerServiceImpl.java → liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketsPartnerServiceImpl.java

-package com.liquidnet.service.platform.service.partner.impl;
+package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/PerformanceVoTask.java

@@ -16,8 +16,8 @@ import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.TicketTimesTicketCreatePartnerVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
-import com.liquidnet.service.platform.service.partner.impl.KylinTicketTimesPartnerServiceImpl;
-import com.liquidnet.service.platform.service.partner.impl.KylinTicketsPartnerServiceImpl;
+import com.liquidnet.service.platform.service.impl.partner.KylinTicketTimesPartnerServiceImpl;
+import com.liquidnet.service.platform.service.impl.partner.KylinTicketsPartnerServiceImpl;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
 import com.mongodb.client.model.ReturnDocument;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/resources/bootstrap-service-platform.yml

@@ -15,4 +15,4 @@ spring:
       name: ${spring.application.name} #默认为spring.application.name
       discovery:
         enabled: true
-        service-id: liquidnet-support-config
+        service-id: liquidnet-support-config
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/resources/bootstrap.yml

@@ -2,4 +2,4 @@ spring:
   application:
     name: liquidnet-service-platform
   profiles:
-    active: dev
+    active: test
\ No newline at end of file