|
@@ -1,16 +1,19 @@
|
|
|
package org.jeecg.modules.adweb.enquiry.controller;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+
|
|
|
import io.swagger.v3.oas.annotations.Operation;
|
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
+
|
|
|
import jakarta.annotation.Resource;
|
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
|
import jakarta.servlet.http.HttpServletResponse;
|
|
|
+
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
import org.apache.commons.lang3.tuple.Pair;
|
|
@@ -69,32 +72,25 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
@Value("${enquiry.disable-admin-read:true}")
|
|
|
private Boolean disableAdminRead;
|
|
|
+
|
|
|
@Value("${enquiry.demoFlag:false}")
|
|
|
private Boolean demoFlag;
|
|
|
|
|
|
- @Resource
|
|
|
- private IAdwebEnquiryService adwebEnquiryService;
|
|
|
+ @Resource private IAdwebEnquiryService adwebEnquiryService;
|
|
|
|
|
|
- @Resource
|
|
|
- private AdwebEnquiryMapper adwebEnquiryMapper;
|
|
|
+ @Resource private AdwebEnquiryMapper adwebEnquiryMapper;
|
|
|
|
|
|
- @Resource
|
|
|
- private SysAdwebApi sysAdwebApi;
|
|
|
+ @Resource private SysAdwebApi sysAdwebApi;
|
|
|
|
|
|
- @Resource
|
|
|
- private IAdwebSiteService adwebSiteService;
|
|
|
+ @Resource private IAdwebSiteService adwebSiteService;
|
|
|
|
|
|
- @Resource
|
|
|
- private ISiteUserPermissionService siteUserPermissionService;
|
|
|
+ @Resource private ISiteUserPermissionService siteUserPermissionService;
|
|
|
|
|
|
- @Resource
|
|
|
- private ISysDictService sysDictService;
|
|
|
+ @Resource private ISysDictService sysDictService;
|
|
|
|
|
|
- @Resource
|
|
|
- private AwsTranslateUtils awsTranslateUtils;
|
|
|
+ @Resource private AwsTranslateUtils awsTranslateUtils;
|
|
|
|
|
|
- @Resource
|
|
|
- private ISysUserService sysUserService;
|
|
|
+ @Resource private ISysUserService sysUserService;
|
|
|
|
|
|
/**
|
|
|
* 分页列表查询
|
|
@@ -105,13 +101,14 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
* @param principalUid
|
|
|
* @return
|
|
|
*/
|
|
|
- //@AutoLog(value = "询盘信息存储表单-分页列表查询")
|
|
|
+ // @AutoLog(value = "询盘信息存储表单-分页列表查询")
|
|
|
@Operation(summary = "询盘信息存储表单-分页列表查询")
|
|
|
@GetMapping(value = "/list")
|
|
|
- public Result<?> queryPageList(EnquiryListSearchDto searchDto,
|
|
|
- @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
|
|
|
- @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize,
|
|
|
- String principalUid) {
|
|
|
+ public Result<?> queryPageList(
|
|
|
+ EnquiryListSearchDto searchDto,
|
|
|
+ @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
|
|
|
+ @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize,
|
|
|
+ String principalUid) {
|
|
|
|
|
|
if (sysAdwebApi.isNotOwnSite(searchDto.getSiteId())) {
|
|
|
return Result.OK(new Page<>());
|
|
@@ -139,17 +136,22 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
if (searchDto.getSiteId() != null) {
|
|
|
String siteCode = adwebSiteService.getSiteCodeById(searchDto.getSiteId());
|
|
|
if (StringUtils.isNotBlank(siteCode)) {
|
|
|
- QueryWrapper<AdwebSite> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.eq("id", searchDto.getSiteId()).or().eq("parent_group_code", siteCode);
|
|
|
- queryWrapper.ne("status", 0);
|
|
|
- queryWrapper.in(!sysAdwebApi.isAdmin(), "code", siteCodeList);
|
|
|
- codeList = adwebSiteService.list(queryWrapper).stream().map(AdwebSite::getCode).collect(Collectors.toList());
|
|
|
+ LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ queryWrapper
|
|
|
+ .eq(AdwebSite::getId, searchDto.getSiteId())
|
|
|
+ .or()
|
|
|
+ .eq(AdwebSite::getParentGroupCode, siteCode);
|
|
|
+ queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
|
+ queryWrapper.in(!sysAdwebApi.isAdmin(), AdwebSite::getCode, siteCodeList);
|
|
|
+ codeList =
|
|
|
+ adwebSiteService.list(queryWrapper).stream()
|
|
|
+ .map(AdwebSite::getCode)
|
|
|
+ .collect(Collectors.toList());
|
|
|
}
|
|
|
} else {
|
|
|
codeList = siteCodeList;
|
|
|
}
|
|
|
|
|
|
-
|
|
|
String dateType = searchDto.getDateType();
|
|
|
Date start = searchDto.getStart();
|
|
|
Date end = searchDto.getEnd();
|
|
@@ -170,9 +172,20 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
String userEfftecive = "(" + searchDto.getUserEffective() + ")";
|
|
|
|
|
|
-
|
|
|
- IPage<EnquiryListDto> pageList = adwebEnquiryMapper.selectEnquiryList(page, codeList, userEfftecive, searchDto.getWasteEnquiryType(),
|
|
|
- searchDto.getSearchText(), searchDto.getSearchContent(), start, end, searchDto.getWhatsApp(), searchDto.getReadStatus(), principalUid, selfPrincipalUid);
|
|
|
+ IPage<EnquiryListDto> pageList =
|
|
|
+ adwebEnquiryMapper.selectEnquiryList(
|
|
|
+ page,
|
|
|
+ codeList,
|
|
|
+ userEfftecive,
|
|
|
+ searchDto.getWasteEnquiryType(),
|
|
|
+ searchDto.getSearchText(),
|
|
|
+ searchDto.getSearchContent(),
|
|
|
+ start,
|
|
|
+ end,
|
|
|
+ searchDto.getWhatsApp(),
|
|
|
+ searchDto.getReadStatus(),
|
|
|
+ principalUid,
|
|
|
+ selfPrincipalUid);
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(pageList.getRecords())) {
|
|
|
dealInfo(pageList.getRecords());
|
|
@@ -190,56 +203,64 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
return;
|
|
|
}
|
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
- List<DictModel> userEffectiveDict = sysDictService.queryDictItemsByCode(AdwebConstant.ENQUIRY_EFFECTIVE);
|
|
|
+ List<DictModel> userEffectiveDict =
|
|
|
+ sysDictService.queryDictItemsByCode(AdwebConstant.ENQUIRY_EFFECTIVE);
|
|
|
AtomicInteger atomicInteger = new AtomicInteger();
|
|
|
|
|
|
- enquiryList.forEach(enquiry -> {
|
|
|
- // 来源页面如果以 / 结尾,去掉最后一个字符
|
|
|
- String fromPage = enquiry.getFromPage();
|
|
|
- if (StringUtils.isNotBlank(fromPage)) {
|
|
|
- if (fromPage.endsWith("/")) {
|
|
|
- enquiry.setFromPage(fromPage.substring(0, fromPage.length() - 1));
|
|
|
- }
|
|
|
- }
|
|
|
- atomicInteger.getAndIncrement();
|
|
|
- enquiry.setDataIndex(atomicInteger.get());
|
|
|
-
|
|
|
- // 示例关键信息脱敏
|
|
|
- if (demoFlag) {
|
|
|
- enquiry.setFormCompany("**********");
|
|
|
- enquiry.setFromEmail("**********");
|
|
|
- enquiry.setWhatsApp("**********");
|
|
|
- enquiry.setPhone("**********");
|
|
|
- String siteName = enquiry.getSiteName();
|
|
|
- enquiry.setSiteName(siteName.substring(0, 2) + "**********" + siteName.substring(siteName.length() - 2));
|
|
|
- }
|
|
|
+ enquiryList.forEach(
|
|
|
+ enquiry -> {
|
|
|
+ // 来源页面如果以 / 结尾,去掉最后一个字符
|
|
|
+ String fromPage = enquiry.getFromPage();
|
|
|
+ if (StringUtils.isNotBlank(fromPage)) {
|
|
|
+ if (fromPage.endsWith("/")) {
|
|
|
+ enquiry.setFromPage(fromPage.substring(0, fromPage.length() - 1));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ atomicInteger.getAndIncrement();
|
|
|
+ enquiry.setDataIndex(atomicInteger.get());
|
|
|
+
|
|
|
+ // 示例关键信息脱敏
|
|
|
+ if (demoFlag) {
|
|
|
+ enquiry.setFormCompany("**********");
|
|
|
+ enquiry.setFromEmail("**********");
|
|
|
+ enquiry.setWhatsApp("**********");
|
|
|
+ enquiry.setPhone("**********");
|
|
|
+ String siteName = enquiry.getSiteName();
|
|
|
+ enquiry.setSiteName(
|
|
|
+ siteName.substring(0, 2)
|
|
|
+ + "**********"
|
|
|
+ + siteName.substring(siteName.length() - 2));
|
|
|
+ }
|
|
|
|
|
|
- /**********************字典数据处理***********************/
|
|
|
- if (CollectionUtils.isNotEmpty(userEffectiveDict)) {
|
|
|
- userEffectiveDict.forEach(dict -> {
|
|
|
- if (dict.getValue().equals(enquiry.getUserEffective() + "")) {
|
|
|
- enquiry.setUserEffectiveStr(dict.getLabel());
|
|
|
+ /**********************字典数据处理***********************/
|
|
|
+ if (CollectionUtils.isNotEmpty(userEffectiveDict)) {
|
|
|
+ userEffectiveDict.forEach(
|
|
|
+ dict -> {
|
|
|
+ if (dict.getValue().equals(enquiry.getUserEffective() + "")) {
|
|
|
+ enquiry.setUserEffectiveStr(dict.getLabel());
|
|
|
+ }
|
|
|
+ });
|
|
|
}
|
|
|
- });
|
|
|
- }
|
|
|
|
|
|
- // 询盘中用户自定义的字段处理
|
|
|
- if (StringUtils.isNotBlank(enquiry.getSpecialField())) {
|
|
|
- List<EnquirySpecialFields> specialFieldsList = FastJsonUtil.parseList(enquiry.getSpecialField(), EnquirySpecialFields.class);
|
|
|
- enquiry.setSpecialFieldList(specialFieldsList);
|
|
|
- enquiry.setSpecialField(null);
|
|
|
- }
|
|
|
+ // 询盘中用户自定义的字段处理
|
|
|
+ if (StringUtils.isNotBlank(enquiry.getSpecialField())) {
|
|
|
+ List<EnquirySpecialFields> specialFieldsList =
|
|
|
+ FastJsonUtil.parseList(
|
|
|
+ enquiry.getSpecialField(), EnquirySpecialFields.class);
|
|
|
+ enquiry.setSpecialFieldList(specialFieldsList);
|
|
|
+ enquiry.setSpecialField(null);
|
|
|
+ }
|
|
|
|
|
|
- if (StringUtils.isNotBlank(enquiry.getContext())) {
|
|
|
- String context = enquiry.getContext();
|
|
|
- Pattern CRLF = Pattern.compile("(\r\n|\r|\n|\n\r)");
|
|
|
- Matcher m = CRLF.matcher(context);
|
|
|
- if (m.find()) {
|
|
|
- context = m.replaceAll("<br/>");
|
|
|
- }
|
|
|
- enquiry.setContext(context);
|
|
|
- }
|
|
|
- });
|
|
|
+ if (StringUtils.isNotBlank(enquiry.getContext())) {
|
|
|
+ String context = enquiry.getContext();
|
|
|
+ Pattern CRLF = Pattern.compile("(\r\n|\r|\n|\n\r)");
|
|
|
+ Matcher m = CRLF.matcher(context);
|
|
|
+ if (m.find()) {
|
|
|
+ context = m.replaceAll("<br/>");
|
|
|
+ }
|
|
|
+ enquiry.setContext(context);
|
|
|
+ }
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -266,7 +287,9 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
@AutoLog(value = "询盘信息存储表单-编辑")
|
|
|
@Operation(summary = "询盘信息存储表单-编辑")
|
|
|
@PreAuthorize("@jps.requiresPermissions('adweb:adweb_enquiry:edit')")
|
|
|
- @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST})
|
|
|
+ @RequestMapping(
|
|
|
+ value = "/edit",
|
|
|
+ method = {RequestMethod.PUT, RequestMethod.POST})
|
|
|
public Result<String> edit(@RequestBody AdwebEnquiry adwebEnquiry) {
|
|
|
adwebEnquiryService.updateById(adwebEnquiry);
|
|
|
return Result.OK("编辑成功!");
|
|
@@ -308,7 +331,7 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
* @param id
|
|
|
* @return
|
|
|
*/
|
|
|
- //@AutoLog(value = "询盘信息存储表单-通过id查询")
|
|
|
+ // @AutoLog(value = "询盘信息存储表单-通过id查询")
|
|
|
@Operation(summary = "询盘信息存储表单-通过id查询")
|
|
|
@GetMapping(value = "/queryById")
|
|
|
public Result<AdwebEnquiry> queryById(@RequestParam(name = "id", required = true) String id) {
|
|
@@ -344,12 +367,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
return super.importExcel(request, response, AdwebEnquiry.class);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 获取需要轮流询盘的站点code
|
|
|
- */
|
|
|
+ /** 获取需要轮流询盘的站点code */
|
|
|
@GetMapping("/getTurnInquiryCode")
|
|
|
public Result<?> getTurnInquiryCode() {
|
|
|
- List<DictPropertyModel> siteRes = sysAdwebApi.queryDictInfoByDictCode("turn_inquiry_site_code");
|
|
|
+ List<DictPropertyModel> siteRes =
|
|
|
+ sysAdwebApi.queryDictInfoByDictCode("turn_inquiry_site_code");
|
|
|
if (CollectionUtils.isNotEmpty(siteRes)) {
|
|
|
return Result.OK(siteRes);
|
|
|
}
|
|
@@ -361,7 +383,8 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
*/
|
|
|
@GetMapping(value = "/getEnquiryCatalog")
|
|
|
public Result<?> getEnquiryCatalog() {
|
|
|
- List<DictPropertyModel> userEffectiveDict = sysAdwebApi.queryDictInfoByDictCode(AdwebConstant.ENQUIRY_EFFECTIVE);
|
|
|
+ List<DictPropertyModel> userEffectiveDict =
|
|
|
+ sysAdwebApi.queryDictInfoByDictCode(AdwebConstant.ENQUIRY_EFFECTIVE);
|
|
|
return Result.OK(FastJsonUtil.toJSONString(userEffectiveDict));
|
|
|
}
|
|
|
|
|
@@ -372,10 +395,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
* @return 数量信息
|
|
|
*/
|
|
|
@GetMapping("getEnquiryNums")
|
|
|
- public Result<?> getEnquiryNums(Integer siteId,
|
|
|
- String dateType,
|
|
|
- @DateTimeFormat(pattern = "yyyy-MM-dd") Date start,
|
|
|
- @DateTimeFormat(pattern = "yyyy-MM-dd") Date end) {
|
|
|
+ public Result<?> getEnquiryNums(
|
|
|
+ Integer siteId,
|
|
|
+ String dateType,
|
|
|
+ @DateTimeFormat(pattern = "yyyy-MM-dd") Date start,
|
|
|
+ @DateTimeFormat(pattern = "yyyy-MM-dd") Date end) {
|
|
|
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
if (StringUtils.isNotBlank(dateType)) {
|
|
|
Pair<Date, Date> dateRange = DateUtil.getDateRangeByType(dateType);
|
|
@@ -386,27 +410,32 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
List<Integer> siteIds = null;
|
|
|
if (siteId != null) {
|
|
|
String siteCode = adwebSiteService.getSiteCodeById(siteId);
|
|
|
- QueryWrapper<AdwebSite> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.eq("code", siteCode).or().eq("parent_group_code", siteCode);
|
|
|
- queryWrapper.ne("status", 0);
|
|
|
+ LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ queryWrapper
|
|
|
+ .eq(AdwebSite::getCode, siteCode)
|
|
|
+ .or()
|
|
|
+ .eq(AdwebSite::getParentGroupCode, siteCode);
|
|
|
+ queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
|
} else {
|
|
|
if (sysAdwebApi.isAdmin()) {
|
|
|
- QueryWrapper<AdwebSite> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.ne("status", 0);
|
|
|
+ LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
|
} else if (sysAdwebApi.isChannelAdmin()) {
|
|
|
List<String> channelGroupUids = sysAdwebApi.getChannelGroupUids();
|
|
|
- List<String> codeList = siteUserPermissionService.getSiteCodeListByUids(channelGroupUids);
|
|
|
+ List<String> codeList =
|
|
|
+ siteUserPermissionService.getSiteCodeListByUids(channelGroupUids);
|
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
|
} else {
|
|
|
- List<String> codeList = siteUserPermissionService.getSiteCodeList(loginUser.getId());
|
|
|
+ List<String> codeList =
|
|
|
+ siteUserPermissionService.getSiteCodeList(loginUser.getId());
|
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
@@ -420,79 +449,95 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
principalUid = loginUser.getId();
|
|
|
}
|
|
|
|
|
|
- QueryWrapper<AdwebEnquiry> enquiryQueryWrapper = new QueryWrapper<>();
|
|
|
- enquiryQueryWrapper.eq("status", 1);
|
|
|
+ LambdaQueryWrapper<AdwebEnquiry> enquiryQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ enquiryQueryWrapper.eq(AdwebEnquiry::getStatus, 1);
|
|
|
if (start != null) {
|
|
|
- enquiryQueryWrapper.ge("record_ctime", start);
|
|
|
+ enquiryQueryWrapper.ge(AdwebEnquiry::getRecordCtime, start);
|
|
|
}
|
|
|
if (end != null) {
|
|
|
- enquiryQueryWrapper.lt("record_ctime", DateUtil.addDays(end, 1));
|
|
|
+ enquiryQueryWrapper.lt(AdwebEnquiry::getRecordCtime, DateUtil.addDays(end, 1));
|
|
|
}
|
|
|
if (siteIds != null) {
|
|
|
- enquiryQueryWrapper.in("site_id", siteIds);
|
|
|
+ enquiryQueryWrapper.in(AdwebEnquiry::getSiteId, siteIds);
|
|
|
}
|
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
|
String finalPrincipalUid = principalUid;
|
|
|
- enquiryQueryWrapper.and(wrapper -> wrapper.eq("principal_uid", finalPrincipalUid).or().eq("principal_uid", "ALL"));
|
|
|
+ enquiryQueryWrapper.and(
|
|
|
+ wrapper ->
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
+ .or()
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
}
|
|
|
- enquiryQueryWrapper.ne("user_effective", 0);
|
|
|
+ enquiryQueryWrapper.ne(AdwebEnquiry::getUserEffective, 0);
|
|
|
int all = (int) adwebEnquiryService.count(enquiryQueryWrapper);
|
|
|
|
|
|
- QueryWrapper<AdwebEnquiry> enquiryQueryWrapper1 = new QueryWrapper<>();
|
|
|
- enquiryQueryWrapper1.eq("status", 1);
|
|
|
+ LambdaQueryWrapper<AdwebEnquiry> enquiryQueryWrapper1 = new LambdaQueryWrapper<>();
|
|
|
+ enquiryQueryWrapper1.eq(AdwebEnquiry::getStatus, 1);
|
|
|
if (start != null) {
|
|
|
- enquiryQueryWrapper1.ge("record_ctime", start);
|
|
|
+ enquiryQueryWrapper1.ge(AdwebEnquiry::getRecordCtime, start);
|
|
|
}
|
|
|
if (end != null) {
|
|
|
- enquiryQueryWrapper1.lt("record_ctime", DateUtil.addDays(end, 1));
|
|
|
+ enquiryQueryWrapper1.lt(AdwebEnquiry::getRecordCtime, DateUtil.addDays(end, 1));
|
|
|
}
|
|
|
if (siteIds != null) {
|
|
|
- enquiryQueryWrapper1.in("site_id", siteIds);
|
|
|
+ enquiryQueryWrapper1.in(AdwebEnquiry::getSiteId, siteIds);
|
|
|
}
|
|
|
- enquiryQueryWrapper1.eq("read_status", 0);
|
|
|
+ enquiryQueryWrapper1.eq(AdwebEnquiry::getReadStatus, 0);
|
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
|
String finalPrincipalUid = principalUid;
|
|
|
- enquiryQueryWrapper1.and(wrapper -> wrapper.eq("principal_uid", finalPrincipalUid).or().eq("principal_uid", "ALL"));
|
|
|
+ enquiryQueryWrapper1.and(
|
|
|
+ wrapper ->
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
+ .or()
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
}
|
|
|
- enquiryQueryWrapper1.ne("user_effective", 0);
|
|
|
+ enquiryQueryWrapper1.ne(AdwebEnquiry::getUserEffective, 0);
|
|
|
int noRead = (int) adwebEnquiryService.count(enquiryQueryWrapper1);
|
|
|
|
|
|
- QueryWrapper<AdwebEnquiry> enquiryQueryWrapper2 = new QueryWrapper<>();
|
|
|
- enquiryQueryWrapper2.eq("status", 1);
|
|
|
+ LambdaQueryWrapper<AdwebEnquiry> enquiryQueryWrapper2 = new LambdaQueryWrapper<>();
|
|
|
+ enquiryQueryWrapper2.eq(AdwebEnquiry::getStatus, 1);
|
|
|
if (start != null) {
|
|
|
- enquiryQueryWrapper2.ge("record_ctime", start);
|
|
|
+ enquiryQueryWrapper2.ge(AdwebEnquiry::getRecordCtime, start);
|
|
|
}
|
|
|
if (end != null) {
|
|
|
- enquiryQueryWrapper2.lt("record_ctime", DateUtil.addDays(end, 1));
|
|
|
+ enquiryQueryWrapper2.lt(AdwebEnquiry::getRecordCtime, DateUtil.addDays(end, 1));
|
|
|
}
|
|
|
if (siteIds != null) {
|
|
|
- enquiryQueryWrapper2.in("site_id", siteIds);
|
|
|
+ enquiryQueryWrapper2.in(AdwebEnquiry::getSiteId, siteIds);
|
|
|
}
|
|
|
- enquiryQueryWrapper2.eq("user_effective", 1);
|
|
|
+ enquiryQueryWrapper2.eq(AdwebEnquiry::getUserEffective, 1);
|
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
|
String finalPrincipalUid = principalUid;
|
|
|
- enquiryQueryWrapper2.and(wrapper -> wrapper.eq("principal_uid", finalPrincipalUid).or().eq("principal_uid", "ALL"));
|
|
|
+ enquiryQueryWrapper2.and(
|
|
|
+ wrapper ->
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
+ .or()
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
}
|
|
|
- enquiryQueryWrapper2.ne("user_effective", 0);
|
|
|
+ enquiryQueryWrapper2.ne(AdwebEnquiry::getUserEffective, 0);
|
|
|
int product = (int) adwebEnquiryService.count(enquiryQueryWrapper2);
|
|
|
|
|
|
- QueryWrapper<AdwebEnquiry> enquiryQueryWrapper3 = new QueryWrapper<>();
|
|
|
- enquiryQueryWrapper3.eq("status", 1);
|
|
|
+ LambdaQueryWrapper<AdwebEnquiry> enquiryQueryWrapper3 = new LambdaQueryWrapper<>();
|
|
|
+ enquiryQueryWrapper3.eq(AdwebEnquiry::getStatus, 1);
|
|
|
if (start != null) {
|
|
|
- enquiryQueryWrapper3.ge("record_ctime", start);
|
|
|
+ enquiryQueryWrapper3.ge(AdwebEnquiry::getRecordCtime, start);
|
|
|
}
|
|
|
if (end != null) {
|
|
|
- enquiryQueryWrapper3.lt("record_ctime", DateUtil.addDays(end, 1));
|
|
|
+ enquiryQueryWrapper3.lt(AdwebEnquiry::getRecordCtime, DateUtil.addDays(end, 1));
|
|
|
}
|
|
|
if (siteIds != null) {
|
|
|
- enquiryQueryWrapper3.in("site_id", siteIds);
|
|
|
+ enquiryQueryWrapper3.in(AdwebEnquiry::getSiteId, siteIds);
|
|
|
}
|
|
|
- enquiryQueryWrapper3.eq("user_effective", 2);
|
|
|
+ enquiryQueryWrapper3.eq(AdwebEnquiry::getUserEffective, 2);
|
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
|
String finalPrincipalUid = principalUid;
|
|
|
- enquiryQueryWrapper3.and(wrapper -> wrapper.eq("principal_uid", finalPrincipalUid).or().eq("principal_uid", "ALL"));
|
|
|
+ enquiryQueryWrapper3.and(
|
|
|
+ wrapper ->
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
+ .or()
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
}
|
|
|
- enquiryQueryWrapper3.ne("user_effective", 0);
|
|
|
+ enquiryQueryWrapper3.ne(AdwebEnquiry::getUserEffective, 0);
|
|
|
int wait = (int) adwebEnquiryService.count(enquiryQueryWrapper3);
|
|
|
|
|
|
Map<String, Integer> map = new HashMap<>();
|
|
@@ -515,9 +560,9 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
if (disableAdminRead && (sysAdwebApi.isAdmin() || sysAdwebApi.isChannelAdmin())) {
|
|
|
return Result.OK();
|
|
|
}
|
|
|
- UpdateWrapper<AdwebEnquiry> updateWrapper = new UpdateWrapper<>();
|
|
|
- updateWrapper.in("id", id);
|
|
|
- updateWrapper.set("read_status", 1);
|
|
|
+ LambdaUpdateWrapper<AdwebEnquiry> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.in(AdwebEnquiry::getId, id);
|
|
|
+ updateWrapper.set(AdwebEnquiry::getReadStatus, 1);
|
|
|
adwebEnquiryService.update(updateWrapper);
|
|
|
return Result.OK();
|
|
|
}
|
|
@@ -530,17 +575,15 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
@ResponseBody
|
|
|
public Result<String> getEnquiryTrans(String query, String id) {
|
|
|
String text = awsTranslateUtils.translate(query);
|
|
|
- UpdateWrapper<AdwebEnquiry> updateWrapper = new UpdateWrapper<>();
|
|
|
- updateWrapper.eq("id", id);
|
|
|
- updateWrapper.set("trans_content", text);
|
|
|
+ LambdaUpdateWrapper<AdwebEnquiry> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.eq(AdwebEnquiry::getId, id);
|
|
|
+ updateWrapper.set(AdwebEnquiry::getTrackStatus, text);
|
|
|
adwebEnquiryService.update(updateWrapper);
|
|
|
|
|
|
return Result.ok(text);
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 更改询盘用户有效性
|
|
|
- */
|
|
|
+ /** 更改询盘用户有效性 */
|
|
|
@PostMapping("/update/user/effective")
|
|
|
public Result<?> updateUserEffective(EffectiveEnquiryParamDto effectiveEnquiryParamDto) {
|
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
@@ -552,12 +595,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
return Result.error("fail");
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 转发询盘
|
|
|
- */
|
|
|
+ /** 转发询盘 */
|
|
|
@AutoLog(value = "转发询盘")
|
|
|
@GetMapping(value = "/setForward")
|
|
|
- public Result<?> setForward(@RequestParam String ids, @RequestParam String uid, @RequestParam String code) {
|
|
|
+ public Result<?> setForward(
|
|
|
+ @RequestParam String ids, @RequestParam String uid, @RequestParam String code) {
|
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
|
|
SysUser user = sysUserService.getById(uid);
|
|
@@ -565,42 +607,42 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
return Result.error("该账户未设置邮箱!");
|
|
|
}
|
|
|
List<String> idList = Arrays.asList(ids.split(","));
|
|
|
- UpdateWrapper<AdwebEnquiry> updateWrapper = new UpdateWrapper<>();
|
|
|
- updateWrapper.in("id", idList);
|
|
|
- updateWrapper.set("principal_uid", uid);
|
|
|
- updateWrapper.set("principal_type", 1);
|
|
|
+ LambdaUpdateWrapper<AdwebEnquiry> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.in(AdwebEnquiry::getId, idList);
|
|
|
+ updateWrapper.set(AdwebEnquiry::getPrincipalUid, uid);
|
|
|
+ updateWrapper.set(AdwebEnquiry::getPrincipalType, 1);
|
|
|
adwebEnquiryService.update(updateWrapper);
|
|
|
|
|
|
- QueryWrapper<AdwebEnquiry> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.in("id", idList);
|
|
|
+ LambdaQueryWrapper<AdwebEnquiry> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ queryWrapper.in(AdwebEnquiry::getId, idList);
|
|
|
List<AdwebEnquiry> list = adwebEnquiryService.list(queryWrapper);
|
|
|
- //获取站点
|
|
|
- QueryWrapper<AdwebSite> adwebSiteQueryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.eq("code", code);
|
|
|
+ // 获取站点
|
|
|
+ LambdaQueryWrapper<AdwebSite> adwebSiteQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ adwebSiteQueryWrapper.eq(AdwebSite::getCode, code);
|
|
|
AdwebSite adwebSite = adwebSiteService.getOne(adwebSiteQueryWrapper);
|
|
|
|
|
|
- //返回跟进人名称
|
|
|
+ // 返回跟进人名称
|
|
|
for (String id : idList) {
|
|
|
AdwebEnquiry adwebEnquiry = adwebEnquiryService.getById(id);
|
|
|
|
|
|
adwebEnquiryService.specialSendEmail(adwebEnquiry, adwebSite);
|
|
|
if (adwebEnquiry != null && StringUtils.isNotBlank(adwebEnquiry.getRecordId())) {
|
|
|
- adwebEnquiryService.returnSalesperson(code, adwebEnquiry.getRecordId(), user.getUsername());
|
|
|
+ adwebEnquiryService.returnSalesperson(
|
|
|
+ code, adwebEnquiry.getRecordId(), user.getUsername());
|
|
|
}
|
|
|
}
|
|
|
return Result.OK();
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 回收站列表接口
|
|
|
- */
|
|
|
+ /** 回收站列表接口 */
|
|
|
@AutoLog(value = "adweb_enquiry-分页列表查询")
|
|
|
@GetMapping(value = "/queryWasteEnquiryList")
|
|
|
- public Result<?> queryWasteEnquiryList(Integer siteId,
|
|
|
- String searchText,
|
|
|
- String enquiryType,
|
|
|
- @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
|
|
|
- @RequestParam(name = "pageSize", defaultValue = "1000") Integer pageSize) {
|
|
|
+ public Result<?> queryWasteEnquiryList(
|
|
|
+ Integer siteId,
|
|
|
+ String searchText,
|
|
|
+ String enquiryType,
|
|
|
+ @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
|
|
|
+ @RequestParam(name = "pageSize", defaultValue = "1000") Integer pageSize) {
|
|
|
if (sysAdwebApi.isNotOwnSite(siteId)) {
|
|
|
return Result.OK(new Page<>());
|
|
|
}
|
|
@@ -622,10 +664,19 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
siteCodeList = siteUserPermissionService.getSiteCodeListByUids(uidList);
|
|
|
}
|
|
|
|
|
|
- codeList = adwebSiteService.list(new LambdaQueryWrapper<AdwebSite>()
|
|
|
- .eq(siteId != null, AdwebSite::getId, siteId)
|
|
|
- .in(!sysAdwebApi.isAdmin(), AdwebSite::getCode, siteCodeList)
|
|
|
- .ne(AdwebSite::getStatus, 0)).stream().map(AdwebSite::getCode).collect(Collectors.toList());
|
|
|
+ codeList =
|
|
|
+ adwebSiteService
|
|
|
+ .list(
|
|
|
+ new LambdaQueryWrapper<AdwebSite>()
|
|
|
+ .eq(siteId != null, AdwebSite::getId, siteId)
|
|
|
+ .in(
|
|
|
+ !sysAdwebApi.isAdmin(),
|
|
|
+ AdwebSite::getCode,
|
|
|
+ siteCodeList)
|
|
|
+ .ne(AdwebSite::getStatus, 0))
|
|
|
+ .stream()
|
|
|
+ .map(AdwebSite::getCode)
|
|
|
+ .collect(Collectors.toList());
|
|
|
|
|
|
String principalUid = null;
|
|
|
if (sysAdwebApi.isAdwebSubVip()) {
|
|
@@ -635,7 +686,17 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
searchText = searchText.trim();
|
|
|
}
|
|
|
enquiryType = "(" + enquiryType + ")";
|
|
|
- IPage<EnquiryListDto> pageList = adwebEnquiryMapper.queryWasteEnquiryList(page, codeList, "", enquiryType, searchText, null, null, null, principalUid);
|
|
|
+ IPage<EnquiryListDto> pageList =
|
|
|
+ adwebEnquiryMapper.queryWasteEnquiryList(
|
|
|
+ page,
|
|
|
+ codeList,
|
|
|
+ "",
|
|
|
+ enquiryType,
|
|
|
+ searchText,
|
|
|
+ null,
|
|
|
+ null,
|
|
|
+ null,
|
|
|
+ principalUid);
|
|
|
if (CollectionUtils.isNotEmpty(pageList.getRecords())) {
|
|
|
dealInfo(pageList.getRecords());
|
|
|
return Result.OK(pageList);
|
|
@@ -654,9 +715,9 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
public Result<?> refreshBatch(@RequestBody AdwebEnquiry adwebEnquiry) {
|
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
|
|
- UpdateWrapper<AdwebEnquiry> updateWrapper = new UpdateWrapper<>();
|
|
|
- updateWrapper.in("id", adwebEnquiry.getNo().split(","));
|
|
|
- updateWrapper.set("status", 1);
|
|
|
+ LambdaUpdateWrapper<AdwebEnquiry> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.in(AdwebEnquiry::getId, adwebEnquiry.getNo().split(","));
|
|
|
+ updateWrapper.set(AdwebEnquiry::getStatus, 1);
|
|
|
adwebEnquiryService.update(updateWrapper);
|
|
|
|
|
|
return Result.OK("批量复原成功!");
|
|
@@ -671,37 +732,37 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
@GetMapping(value = "/delBatch")
|
|
|
public Result<?> delBatch(@RequestParam("id") String id) {
|
|
|
|
|
|
- UpdateWrapper<AdwebEnquiry> updateWrapper = new UpdateWrapper<>();
|
|
|
- updateWrapper.in("id", id.split(","));
|
|
|
- updateWrapper.set("status", 0);
|
|
|
+ LambdaUpdateWrapper<AdwebEnquiry> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ updateWrapper.in(AdwebEnquiry::getId, id.split(","));
|
|
|
+ updateWrapper.set(AdwebEnquiry::getStatus, 0);
|
|
|
this.adwebEnquiryService.update(updateWrapper);
|
|
|
return Result.OK("批量删除成功!");
|
|
|
}
|
|
|
|
|
|
@GetMapping("/getWastedEnquiry")
|
|
|
- public Result<List<EnquiryListDto>> getWastedEnquiry(EnquiryListSearchDto enquiryListSearchDto) {
|
|
|
-
|
|
|
- List<EnquiryListDto> wasterEnquiries = adwebEnquiryMapper.getWastedEnquiry(
|
|
|
- enquiryListSearchDto.getWasteEnquiryType()
|
|
|
- , enquiryListSearchDto.getIp()
|
|
|
- , enquiryListSearchDto.getEmail()
|
|
|
- , enquiryListSearchDto.getKeyword()
|
|
|
- , enquiryListSearchDto.getSearchText()
|
|
|
- , enquiryListSearchDto.getType()
|
|
|
- , enquiryListSearchDto.getSiteId()
|
|
|
- );
|
|
|
+ public Result<List<EnquiryListDto>> getWastedEnquiry(
|
|
|
+ EnquiryListSearchDto enquiryListSearchDto) {
|
|
|
+
|
|
|
+ List<EnquiryListDto> wasterEnquiries =
|
|
|
+ adwebEnquiryMapper.getWastedEnquiry(
|
|
|
+ enquiryListSearchDto.getWasteEnquiryType(),
|
|
|
+ enquiryListSearchDto.getIp(),
|
|
|
+ enquiryListSearchDto.getEmail(),
|
|
|
+ enquiryListSearchDto.getKeyword(),
|
|
|
+ enquiryListSearchDto.getSearchText(),
|
|
|
+ enquiryListSearchDto.getType(),
|
|
|
+ enquiryListSearchDto.getSiteId());
|
|
|
|
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
|
|
return Result.OK(wasterEnquiries);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
* 根据询盘信息创建邮件发送记录
|
|
|
*
|
|
|
* @param adwebEnquiry 询盘信息
|
|
|
- * @param email 接收邮箱
|
|
|
+ * @param email 接收邮箱
|
|
|
* @return
|
|
|
*/
|
|
|
private static EnquiryEmailMessage newEmail(AdwebEnquiry adwebEnquiry, String email) {
|
|
@@ -716,5 +777,4 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
return enquiryEmailMessage;
|
|
|
}
|
|
|
-
|
|
|
}
|