|
@@ -4,12 +4,16 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
+
|
|
import io.swagger.v3.oas.annotations.Operation;
|
|
import io.swagger.v3.oas.annotations.Operation;
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
|
+
|
|
import jakarta.annotation.Resource;
|
|
import jakarta.annotation.Resource;
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
import jakarta.servlet.http.HttpServletResponse;
|
|
import jakarta.servlet.http.HttpServletResponse;
|
|
|
|
+
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
+
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang3.tuple.Pair;
|
|
import org.apache.commons.lang3.tuple.Pair;
|
|
@@ -32,7 +36,6 @@ import org.jeecg.modules.adweb.enquiry.dto.param.EnquirySearchDto;
|
|
import org.jeecg.modules.adweb.enquiry.dto.result.EnquiryListDto;
|
|
import org.jeecg.modules.adweb.enquiry.dto.result.EnquiryListDto;
|
|
import org.jeecg.modules.adweb.enquiry.dto.result.EnquirySpecialFields;
|
|
import org.jeecg.modules.adweb.enquiry.dto.result.EnquirySpecialFields;
|
|
import org.jeecg.modules.adweb.enquiry.entity.AdwebEnquiry;
|
|
import org.jeecg.modules.adweb.enquiry.entity.AdwebEnquiry;
|
|
-import org.jeecg.modules.adweb.enquiry.entity.AdwebEnquiryBlacklist;
|
|
|
|
import org.jeecg.modules.adweb.enquiry.entity.EnquiryEmailMessage;
|
|
import org.jeecg.modules.adweb.enquiry.entity.EnquiryEmailMessage;
|
|
import org.jeecg.modules.adweb.enquiry.mapper.AdwebEnquiryMapper;
|
|
import org.jeecg.modules.adweb.enquiry.mapper.AdwebEnquiryMapper;
|
|
import org.jeecg.modules.adweb.enquiry.service.IAdwebEnquiryService;
|
|
import org.jeecg.modules.adweb.enquiry.service.IAdwebEnquiryService;
|
|
@@ -69,32 +72,25 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
@Value("${enquiry.disable-admin-read:true}")
|
|
@Value("${enquiry.disable-admin-read:true}")
|
|
private Boolean disableAdminRead;
|
|
private Boolean disableAdminRead;
|
|
|
|
+
|
|
@Value("${enquiry.demoFlag:false}")
|
|
@Value("${enquiry.demoFlag:false}")
|
|
private Boolean demoFlag;
|
|
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
|
|
* @param principalUid
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
- //@AutoLog(value = "询盘信息存储表单-分页列表查询")
|
|
|
|
|
|
+ // @AutoLog(value = "询盘信息存储表单-分页列表查询")
|
|
@Operation(summary = "询盘信息存储表单-分页列表查询")
|
|
@Operation(summary = "询盘信息存储表单-分页列表查询")
|
|
@GetMapping(value = "/list")
|
|
@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())) {
|
|
if (sysAdwebApi.isNotOwnSite(searchDto.getSiteId())) {
|
|
return Result.OK(new Page<>());
|
|
return Result.OK(new Page<>());
|
|
@@ -140,16 +137,21 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
String siteCode = adwebSiteService.getSiteCodeById(searchDto.getSiteId());
|
|
String siteCode = adwebSiteService.getSiteCodeById(searchDto.getSiteId());
|
|
if (StringUtils.isNotBlank(siteCode)) {
|
|
if (StringUtils.isNotBlank(siteCode)) {
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
- queryWrapper.eq(AdwebSite::getId, searchDto.getSiteId()).or().eq(AdwebSite::getParentGroupCode, siteCode);
|
|
|
|
|
|
+ queryWrapper
|
|
|
|
+ .eq(AdwebSite::getId, searchDto.getSiteId())
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebSite::getParentGroupCode, siteCode);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
queryWrapper.in(!sysAdwebApi.isAdmin(), AdwebSite::getCode, siteCodeList);
|
|
queryWrapper.in(!sysAdwebApi.isAdmin(), AdwebSite::getCode, siteCodeList);
|
|
- codeList = adwebSiteService.list(queryWrapper).stream().map(AdwebSite::getCode).collect(Collectors.toList());
|
|
|
|
|
|
+ codeList =
|
|
|
|
+ adwebSiteService.list(queryWrapper).stream()
|
|
|
|
+ .map(AdwebSite::getCode)
|
|
|
|
+ .collect(Collectors.toList());
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
codeList = siteCodeList;
|
|
codeList = siteCodeList;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
String dateType = searchDto.getDateType();
|
|
String dateType = searchDto.getDateType();
|
|
Date start = searchDto.getStart();
|
|
Date start = searchDto.getStart();
|
|
Date end = searchDto.getEnd();
|
|
Date end = searchDto.getEnd();
|
|
@@ -170,9 +172,20 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
String userEfftecive = "(" + searchDto.getUserEffective() + ")";
|
|
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())) {
|
|
if (CollectionUtils.isNotEmpty(pageList.getRecords())) {
|
|
dealInfo(pageList.getRecords());
|
|
dealInfo(pageList.getRecords());
|
|
@@ -190,56 +203,64 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
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();
|
|
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 = "询盘信息存储表单-编辑")
|
|
@AutoLog(value = "询盘信息存储表单-编辑")
|
|
@Operation(summary = "询盘信息存储表单-编辑")
|
|
@Operation(summary = "询盘信息存储表单-编辑")
|
|
@PreAuthorize("@jps.requiresPermissions('adweb:adweb_enquiry:edit')")
|
|
@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) {
|
|
public Result<String> edit(@RequestBody AdwebEnquiry adwebEnquiry) {
|
|
adwebEnquiryService.updateById(adwebEnquiry);
|
|
adwebEnquiryService.updateById(adwebEnquiry);
|
|
return Result.OK("编辑成功!");
|
|
return Result.OK("编辑成功!");
|
|
@@ -308,7 +331,7 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
* @param id
|
|
* @param id
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
- //@AutoLog(value = "询盘信息存储表单-通过id查询")
|
|
|
|
|
|
+ // @AutoLog(value = "询盘信息存储表单-通过id查询")
|
|
@Operation(summary = "询盘信息存储表单-通过id查询")
|
|
@Operation(summary = "询盘信息存储表单-通过id查询")
|
|
@GetMapping(value = "/queryById")
|
|
@GetMapping(value = "/queryById")
|
|
public Result<AdwebEnquiry> queryById(@RequestParam(name = "id", required = true) String id) {
|
|
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);
|
|
return super.importExcel(request, response, AdwebEnquiry.class);
|
|
}
|
|
}
|
|
|
|
|
|
- /**
|
|
|
|
- * 获取需要轮流询盘的站点code
|
|
|
|
- */
|
|
|
|
|
|
+ /** 获取需要轮流询盘的站点code */
|
|
@GetMapping("/getTurnInquiryCode")
|
|
@GetMapping("/getTurnInquiryCode")
|
|
public Result<?> 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)) {
|
|
if (CollectionUtils.isNotEmpty(siteRes)) {
|
|
return Result.OK(siteRes);
|
|
return Result.OK(siteRes);
|
|
}
|
|
}
|
|
@@ -361,7 +383,8 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
*/
|
|
*/
|
|
@GetMapping(value = "/getEnquiryCatalog")
|
|
@GetMapping(value = "/getEnquiryCatalog")
|
|
public Result<?> 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));
|
|
return Result.OK(FastJsonUtil.toJSONString(userEffectiveDict));
|
|
}
|
|
}
|
|
|
|
|
|
@@ -372,10 +395,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
* @return 数量信息
|
|
* @return 数量信息
|
|
*/
|
|
*/
|
|
@GetMapping("getEnquiryNums")
|
|
@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();
|
|
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
if (StringUtils.isNotBlank(dateType)) {
|
|
if (StringUtils.isNotBlank(dateType)) {
|
|
Pair<Date, Date> dateRange = DateUtil.getDateRangeByType(dateType);
|
|
Pair<Date, Date> dateRange = DateUtil.getDateRangeByType(dateType);
|
|
@@ -387,7 +411,10 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
if (siteId != null) {
|
|
if (siteId != null) {
|
|
String siteCode = adwebSiteService.getSiteCodeById(siteId);
|
|
String siteCode = adwebSiteService.getSiteCodeById(siteId);
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
- queryWrapper.eq(AdwebSite::getCode, siteCode).or().eq(AdwebSite::getParentGroupCode, siteCode);
|
|
|
|
|
|
+ queryWrapper
|
|
|
|
+ .eq(AdwebSite::getCode, siteCode)
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebSite::getParentGroupCode, siteCode);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
@@ -399,14 +426,16 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
} else if (sysAdwebApi.isChannelAdmin()) {
|
|
} else if (sysAdwebApi.isChannelAdmin()) {
|
|
List<String> channelGroupUids = sysAdwebApi.getChannelGroupUids();
|
|
List<String> channelGroupUids = sysAdwebApi.getChannelGroupUids();
|
|
- List<String> codeList = siteUserPermissionService.getSiteCodeListByUids(channelGroupUids);
|
|
|
|
|
|
+ List<String> codeList =
|
|
|
|
+ siteUserPermissionService.getSiteCodeListByUids(channelGroupUids);
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
List<AdwebSite> sites = adwebSiteService.list(queryWrapper);
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
siteIds = sites.stream().map(AdwebSite::getId).collect(Collectors.toList());
|
|
} else {
|
|
} else {
|
|
- List<String> codeList = siteUserPermissionService.getSiteCodeList(loginUser.getId());
|
|
|
|
|
|
+ List<String> codeList =
|
|
|
|
+ siteUserPermissionService.getSiteCodeList(loginUser.getId());
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<AdwebSite> queryWrapper = new LambdaQueryWrapper<>();
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
queryWrapper.in(AdwebSite::getCode, codeList);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
queryWrapper.ne(AdwebSite::getStatus, 0);
|
|
@@ -433,7 +462,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
}
|
|
}
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
String finalPrincipalUid = principalUid;
|
|
String finalPrincipalUid = principalUid;
|
|
- enquiryQueryWrapper.and(wrapper -> wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid).or().eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
|
|
|
+ enquiryQueryWrapper.and(
|
|
|
|
+ wrapper ->
|
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
}
|
|
}
|
|
enquiryQueryWrapper.ne(AdwebEnquiry::getUserEffective, 0);
|
|
enquiryQueryWrapper.ne(AdwebEnquiry::getUserEffective, 0);
|
|
int all = (int) adwebEnquiryService.count(enquiryQueryWrapper);
|
|
int all = (int) adwebEnquiryService.count(enquiryQueryWrapper);
|
|
@@ -452,7 +485,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
enquiryQueryWrapper1.eq(AdwebEnquiry::getReadStatus, 0);
|
|
enquiryQueryWrapper1.eq(AdwebEnquiry::getReadStatus, 0);
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
String finalPrincipalUid = principalUid;
|
|
String finalPrincipalUid = principalUid;
|
|
- enquiryQueryWrapper1.and(wrapper -> wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid).or().eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
|
|
|
+ enquiryQueryWrapper1.and(
|
|
|
|
+ wrapper ->
|
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
}
|
|
}
|
|
enquiryQueryWrapper1.ne(AdwebEnquiry::getUserEffective, 0);
|
|
enquiryQueryWrapper1.ne(AdwebEnquiry::getUserEffective, 0);
|
|
int noRead = (int) adwebEnquiryService.count(enquiryQueryWrapper1);
|
|
int noRead = (int) adwebEnquiryService.count(enquiryQueryWrapper1);
|
|
@@ -471,7 +508,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
enquiryQueryWrapper2.eq(AdwebEnquiry::getUserEffective, 1);
|
|
enquiryQueryWrapper2.eq(AdwebEnquiry::getUserEffective, 1);
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
String finalPrincipalUid = principalUid;
|
|
String finalPrincipalUid = principalUid;
|
|
- enquiryQueryWrapper2.and(wrapper -> wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid).or().eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
|
|
|
+ enquiryQueryWrapper2.and(
|
|
|
|
+ wrapper ->
|
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
}
|
|
}
|
|
enquiryQueryWrapper2.ne(AdwebEnquiry::getUserEffective, 0);
|
|
enquiryQueryWrapper2.ne(AdwebEnquiry::getUserEffective, 0);
|
|
int product = (int) adwebEnquiryService.count(enquiryQueryWrapper2);
|
|
int product = (int) adwebEnquiryService.count(enquiryQueryWrapper2);
|
|
@@ -490,7 +531,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
enquiryQueryWrapper3.eq(AdwebEnquiry::getUserEffective, 2);
|
|
enquiryQueryWrapper3.eq(AdwebEnquiry::getUserEffective, 2);
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
if (StringUtils.isNotBlank(principalUid)) {
|
|
String finalPrincipalUid = principalUid;
|
|
String finalPrincipalUid = principalUid;
|
|
- enquiryQueryWrapper3.and(wrapper -> wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid).or().eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
|
|
|
|
+ enquiryQueryWrapper3.and(
|
|
|
|
+ wrapper ->
|
|
|
|
+ wrapper.eq(AdwebEnquiry::getPrincipalUid, finalPrincipalUid)
|
|
|
|
+ .or()
|
|
|
|
+ .eq(AdwebEnquiry::getPrincipalUid, "ALL"));
|
|
}
|
|
}
|
|
enquiryQueryWrapper3.ne(AdwebEnquiry::getUserEffective, 0);
|
|
enquiryQueryWrapper3.ne(AdwebEnquiry::getUserEffective, 0);
|
|
int wait = (int) adwebEnquiryService.count(enquiryQueryWrapper3);
|
|
int wait = (int) adwebEnquiryService.count(enquiryQueryWrapper3);
|
|
@@ -538,9 +583,7 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
return Result.ok(text);
|
|
return Result.ok(text);
|
|
}
|
|
}
|
|
|
|
|
|
- /**
|
|
|
|
- * 更改询盘用户有效性
|
|
|
|
- */
|
|
|
|
|
|
+ /** 更改询盘用户有效性 */
|
|
@PostMapping("/update/user/effective")
|
|
@PostMapping("/update/user/effective")
|
|
public Result<?> updateUserEffective(EffectiveEnquiryParamDto effectiveEnquiryParamDto) {
|
|
public Result<?> updateUserEffective(EffectiveEnquiryParamDto effectiveEnquiryParamDto) {
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
@@ -552,12 +595,11 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
return Result.error("fail");
|
|
return Result.error("fail");
|
|
}
|
|
}
|
|
|
|
|
|
- /**
|
|
|
|
- * 转发询盘
|
|
|
|
- */
|
|
|
|
|
|
+ /** 转发询盘 */
|
|
@AutoLog(value = "转发询盘")
|
|
@AutoLog(value = "转发询盘")
|
|
@GetMapping(value = "/setForward")
|
|
@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();
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
|
|
SysUser user = sysUserService.getById(uid);
|
|
SysUser user = sysUserService.getById(uid);
|
|
@@ -579,28 +621,28 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
adwebSiteQueryWrapper.eq(AdwebSite::getCode, code);
|
|
adwebSiteQueryWrapper.eq(AdwebSite::getCode, code);
|
|
AdwebSite adwebSite = adwebSiteService.getOne(adwebSiteQueryWrapper);
|
|
AdwebSite adwebSite = adwebSiteService.getOne(adwebSiteQueryWrapper);
|
|
|
|
|
|
- //返回跟进人名称
|
|
|
|
|
|
+ // 返回跟进人名称
|
|
for (String id : idList) {
|
|
for (String id : idList) {
|
|
AdwebEnquiry adwebEnquiry = adwebEnquiryService.getById(id);
|
|
AdwebEnquiry adwebEnquiry = adwebEnquiryService.getById(id);
|
|
|
|
|
|
adwebEnquiryService.specialSendEmail(adwebEnquiry, adwebSite);
|
|
adwebEnquiryService.specialSendEmail(adwebEnquiry, adwebSite);
|
|
if (adwebEnquiry != null && StringUtils.isNotBlank(adwebEnquiry.getRecordId())) {
|
|
if (adwebEnquiry != null && StringUtils.isNotBlank(adwebEnquiry.getRecordId())) {
|
|
- adwebEnquiryService.returnSalesperson(code, adwebEnquiry.getRecordId(), user.getUsername());
|
|
|
|
|
|
+ adwebEnquiryService.returnSalesperson(
|
|
|
|
+ code, adwebEnquiry.getRecordId(), user.getUsername());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return Result.OK();
|
|
return Result.OK();
|
|
}
|
|
}
|
|
|
|
|
|
- /**
|
|
|
|
- * 回收站列表接口
|
|
|
|
- */
|
|
|
|
|
|
+ /** 回收站列表接口 */
|
|
@AutoLog(value = "adweb_enquiry-分页列表查询")
|
|
@AutoLog(value = "adweb_enquiry-分页列表查询")
|
|
@GetMapping(value = "/queryWasteEnquiryList")
|
|
@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)) {
|
|
if (sysAdwebApi.isNotOwnSite(siteId)) {
|
|
return Result.OK(new Page<>());
|
|
return Result.OK(new Page<>());
|
|
}
|
|
}
|
|
@@ -622,10 +664,19 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
siteCodeList = siteUserPermissionService.getSiteCodeListByUids(uidList);
|
|
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;
|
|
String principalUid = null;
|
|
if (sysAdwebApi.isAdwebSubVip()) {
|
|
if (sysAdwebApi.isAdwebSubVip()) {
|
|
@@ -635,7 +686,17 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
searchText = searchText.trim();
|
|
searchText = searchText.trim();
|
|
}
|
|
}
|
|
enquiryType = "(" + enquiryType + ")";
|
|
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())) {
|
|
if (CollectionUtils.isNotEmpty(pageList.getRecords())) {
|
|
dealInfo(pageList.getRecords());
|
|
dealInfo(pageList.getRecords());
|
|
return Result.OK(pageList);
|
|
return Result.OK(pageList);
|
|
@@ -679,29 +740,29 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
}
|
|
}
|
|
|
|
|
|
@GetMapping("/getWastedEnquiry")
|
|
@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();
|
|
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
|
|
return Result.OK(wasterEnquiries);
|
|
return Result.OK(wasterEnquiries);
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 根据询盘信息创建邮件发送记录
|
|
* 根据询盘信息创建邮件发送记录
|
|
*
|
|
*
|
|
* @param adwebEnquiry 询盘信息
|
|
* @param adwebEnquiry 询盘信息
|
|
- * @param email 接收邮箱
|
|
|
|
|
|
+ * @param email 接收邮箱
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
private static EnquiryEmailMessage newEmail(AdwebEnquiry adwebEnquiry, String email) {
|
|
private static EnquiryEmailMessage newEmail(AdwebEnquiry adwebEnquiry, String email) {
|
|
@@ -716,5 +777,4 @@ public class AdwebEnquiryController extends JeecgController<AdwebEnquiry, IAdweb
|
|
|
|
|
|
return enquiryEmailMessage;
|
|
return enquiryEmailMessage;
|
|
}
|
|
}
|
|
-
|
|
|
|
}
|
|
}
|