|
@@ -1,12 +1,14 @@
|
|
|
package org.jeecg.modules.adweb.api.controller;
|
|
|
|
|
|
-import cn.hutool.core.bean.BeanUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+
|
|
|
import jakarta.annotation.Resource;
|
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
|
+
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.jeecg.common.api.vo.Result;
|
|
@@ -16,7 +18,6 @@ import org.jeecg.modules.adweb.api.vo.EnquiryInfoVO;
|
|
|
import org.jeecg.modules.adweb.api.vo.EnquiryPageVO;
|
|
|
import org.jeecg.modules.adweb.api.vo.ProductInfoVO;
|
|
|
import org.jeecg.modules.adweb.common.mapper.CommonMapper;
|
|
|
-import org.jeecg.modules.adweb.common.util.DateUtil;
|
|
|
import org.jeecg.modules.adweb.enquiry.entity.AdwebEnquiry;
|
|
|
import org.jeecg.modules.adweb.enquiry.service.IAdwebEnquiryService;
|
|
|
import org.jeecg.modules.adweb.product.entity.AdwebProduct;
|
|
@@ -39,21 +40,15 @@ public class OpenAPIController {
|
|
|
private static final String BEARER_TOKEN_HEADER = "AdWeb-Authorization";
|
|
|
private static final String STATIC_BEARER_TOKEN = "Bearer uxl9Wpzh65vXNUyDvynJDjBo";
|
|
|
|
|
|
- @Resource
|
|
|
- private CommonMapper commonMapper;
|
|
|
+ @Resource private CommonMapper commonMapper;
|
|
|
|
|
|
- @Resource
|
|
|
- private IAdwebSiteService adwebSiteService;
|
|
|
+ @Resource private IAdwebSiteService adwebSiteService;
|
|
|
|
|
|
- @Resource
|
|
|
- private IAdwebProductService adwebProductService;
|
|
|
+ @Resource private IAdwebProductService adwebProductService;
|
|
|
|
|
|
- @Resource
|
|
|
- private IAdwebEnquiryService adwebEnquiryService;
|
|
|
+ @Resource private IAdwebEnquiryService adwebEnquiryService;
|
|
|
|
|
|
- /**
|
|
|
- * 外部api请求获取产品列表
|
|
|
- */
|
|
|
+ /** 外部api请求获取产品列表 */
|
|
|
@IgnoreAuth
|
|
|
@PostMapping("/product/list")
|
|
|
@ResponseBody
|
|
@@ -63,26 +58,24 @@ public class OpenAPIController {
|
|
|
this.validateAuthToken(authToken);
|
|
|
|
|
|
log.info("苏豪通请求产品列表 parameter: {}", apiRequest);
|
|
|
+
|
|
|
QueryWrapper<AdwebSite> adwebSiteQueryWrapper = new QueryWrapper<>();
|
|
|
adwebSiteQueryWrapper.like("domain", apiRequest.getDomain());
|
|
|
- List<AdwebSite> adwebSites = adwebSiteService.getBaseMapper().selectList(adwebSiteQueryWrapper);
|
|
|
+ List<AdwebSite> adwebSites =
|
|
|
+ adwebSiteService.getBaseMapper().selectList(adwebSiteQueryWrapper);
|
|
|
|
|
|
- List<ProductInfoVO> productVOList;
|
|
|
if (CollectionUtils.isNotEmpty(adwebSites)) {
|
|
|
QueryWrapper<AdwebProduct> adwebProductQueryWrapper = new QueryWrapper<>();
|
|
|
adwebSiteQueryWrapper.eq("domain", adwebSites.get(0).getCode());
|
|
|
- List<AdwebProduct> adwebProducts = adwebProductService.getBaseMapper().selectList(adwebProductQueryWrapper);
|
|
|
- productVOList = adwebProducts.stream().map(adwebProduct -> BeanUtil.copyProperties(adwebProduct, ProductInfoVO.class)).toList();
|
|
|
+ List<AdwebProduct> adwebProducts =
|
|
|
+ adwebProductService.getBaseMapper().selectList(adwebProductQueryWrapper);
|
|
|
+ return Result.ok(adwebProducts.stream().map(ProductInfoVO::fromAdwebProduct).toList());
|
|
|
} else {
|
|
|
return Result.error("未找到该站点!");
|
|
|
}
|
|
|
-
|
|
|
- return Result.ok(productVOList);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 外部api请求获取询盘列表
|
|
|
- */
|
|
|
+ /** 外部api请求获取询盘列表 */
|
|
|
@IgnoreAuth
|
|
|
@PostMapping("/enquiry/list")
|
|
|
@ResponseBody
|
|
@@ -95,10 +88,10 @@ public class OpenAPIController {
|
|
|
|
|
|
QueryWrapper<AdwebSite> adwebSiteQueryWrapper = new QueryWrapper<>();
|
|
|
adwebSiteQueryWrapper.like("domain", apiRequest.getDomain());
|
|
|
- List<AdwebSite> adwebSites = adwebSiteService.getBaseMapper().selectList(adwebSiteQueryWrapper);
|
|
|
+ List<AdwebSite> adwebSites =
|
|
|
+ adwebSiteService.getBaseMapper().selectList(adwebSiteQueryWrapper);
|
|
|
|
|
|
EnquiryPageVO enquiryPage = new EnquiryPageVO();
|
|
|
-
|
|
|
if (CollectionUtils.isNotEmpty(adwebSites)) {
|
|
|
Page<AdwebEnquiry> page = new Page<>(apiRequest.getPageNo(), apiRequest.getPageSize());
|
|
|
|
|
@@ -108,16 +101,11 @@ public class OpenAPIController {
|
|
|
IPage<AdwebEnquiry> pageList = adwebEnquiryService.page(page, enquiryQueryWrapper);
|
|
|
|
|
|
if (pageList != null && CollectionUtils.isNotEmpty(pageList.getRecords())) {
|
|
|
-
|
|
|
// 复制属性到需要返回的新对象
|
|
|
- List<EnquiryInfoVO> enquiryInfoVOS = pageList.getRecords().stream().map(adwebEnquiry -> {
|
|
|
-
|
|
|
- EnquiryInfoVO enquiryInfoVO = BeanUtil.copyProperties(adwebEnquiry, EnquiryInfoVO.class);
|
|
|
- enquiryInfoVO.setPageUrl(adwebEnquiry.getFromPage());
|
|
|
- enquiryInfoVO.setCreateTime(DateUtil.formatDate(adwebEnquiry.getRecordCtime(), DateUtil.DATE_FORMAT_MINUTE));
|
|
|
-
|
|
|
- return enquiryInfoVO;
|
|
|
- }).toList();
|
|
|
+ List<EnquiryInfoVO> enquiryInfoVOS =
|
|
|
+ pageList.getRecords().stream()
|
|
|
+ .map(EnquiryInfoVO::fromAdwebEnquiry)
|
|
|
+ .toList();
|
|
|
|
|
|
enquiryPage.setPages(pageList.getPages());
|
|
|
enquiryPage.setSize(pageList.getSize());
|
|
@@ -125,7 +113,6 @@ public class OpenAPIController {
|
|
|
enquiryPage.setTotal(pageList.getTotal());
|
|
|
enquiryPage.setRecords(enquiryInfoVOS);
|
|
|
}
|
|
|
-
|
|
|
} else {
|
|
|
return Result.error("未找到该站点!");
|
|
|
}
|