报表中心

gic-platform-enterprise-web/src/main/java/com/gic/enterprise/web/controller/DownloadReportController.java

 package com.gic.enterprise.web.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.gic.api.base.commons.Page;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.webapi.reponse.RestResponse;
 import com.gic.download.utils.log.LogUtils;
 import com.gic.enterprise.ano.IgnoreLogin;
+import com.gic.enterprise.constant.DownloadReportDataTypeEnum;
+import com.gic.enterprise.constant.ExcelExtensionEnum;
 import com.gic.enterprise.dto.DownloadReportDTO;
+import com.gic.enterprise.dto.HiveDataDownloadDTO;
 import com.gic.enterprise.qo.DownloadReportQO;
+import com.gic.enterprise.response.EnterpriseRestResponse;
 import com.gic.enterprise.service.DownloadReportApiService;
+import com.gic.enterprise.service.HiveDataDownloadApiService;
 import com.gic.enterprise.utils.ResultControllerUtils;
 import com.gic.enterprise.utils.UserDetailUtils;
 import com.gic.enterprise.web.vo.DownloadReportVO;
@@ -29,6 +35,8 @@ public class DownloadReportController {
 
     @Autowired
     private DownloadReportApiService downloadReportApiService;
+    @Autowired
+    private HiveDataDownloadApiService hiveDataDownloadApiService;
 
     @RequestMapping("/list-download-report")
     public RestResponse listDownloadReport(@Validated({DownloadReportQO.SelectValidView.class}) DownloadReportQO downloadReportQO) {
@@ -70,4 +78,25 @@ public class DownloadReportController {
         ServiceResponse<Void> response = downloadReportApiService.receiveHeart(reportId);
         return RestResponse.success();
     }
+
+    @RequestMapping("download-hive-data")
+    @ResponseBody
+    @IgnoreLogin
+    public RestResponse downloadHiveData(){
+        HiveDataDownloadDTO dataDownloadDTO = new HiveDataDownloadDTO();
+        dataDownloadDTO.setEnterpriseId(1166);
+        dataDownloadDTO.setApplyUserId(13805);
+        dataDownloadDTO.setDataContent("用户-用户列表");
+        dataDownloadDTO.setDataType(DownloadReportDataTypeEnum.COMPLETE_DATA.getCode());
+        dataDownloadDTO.setDataUrl("https://four.gicdev.com/member-tag/member-tag/tag-val-edit?id=264137629747888139&name=111111");
+        //dataDownloadDTO.setDesenField();
+        dataDownloadDTO.setExcelExtension(ExcelExtensionEnum.CSV.getCode());
+        dataDownloadDTO.setFileName("boom hive test");
+        dataDownloadDTO.setSql("select order_id as '订单号' from extract_order_information");
+        ServiceResponse<Integer> downloadTask = hiveDataDownloadApiService.createDownloadTask(dataDownloadDTO);
+        if(downloadTask.isSuccess()){
+            return RestResponse.success();
+        }
+        return EnterpriseRestResponse.failure(downloadTask);
+    }
 }

gic-platform-enterprise-web/src/main/resources/dubbo-gic-platform-enterprise-web.xml

@@ -160,4 +160,5 @@
     <dubbo:reference interface="com.gic.member.config.api.service.UserListFieldApiService" id="userListFieldApiService" timeout="6000" retries="0"/>
     <dubbo:reference interface="com.gic.store.service.StoreResourceApiService" id="storeResourceApiService" timeout="6000" retries="0"/>
     <dubbo:reference interface="com.gic.enterprise.service.CustomGuideTopApiService" id="customGuideTopApiService" timeout="6000" retries="0"/>
+    <dubbo:reference interface="com.gic.enterprise.service.HiveDataDownloadApiService" id="hiveDataDownloadApiService" timeout="6000" retries="0"/>
 </beans>