Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
P
pms-ci-test
概览
概览
详情
活动
周期分析
版本库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
问题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程表
图表
维基
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
test-ci
pms-ci-test
Commits
1a012e0e
提交
1a012e0e
authored
6月 09, 2023
作者:
panda
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
作业服务相关接口-优化
上级
508d78cc
显示空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
28 行增加
和
8 行删除
+28
-8
BackstageTaskServiceImpl.java
...va/com/mmc/pms/service/Impl/BackstageTaskServiceImpl.java
+28
-8
没有找到文件。
src/main/java/com/mmc/pms/service/Impl/BackstageTaskServiceImpl.java
浏览文件 @
1a012e0e
package
com
.
mmc
.
pms
.
service
.
Impl
;
package
com
.
mmc
.
pms
.
service
.
Impl
;
import
com.alibaba.fastjson.JSONArray
;
import
com.alibaba.fastjson.JSONObject
;
import
com.mmc.pms.common.ResultBody
;
import
com.mmc.pms.common.ResultBody
;
import
com.mmc.pms.common.ResultEnum
;
import
com.mmc.pms.common.ResultEnum
;
import
com.mmc.pms.constant.TokenConstant
;
import
com.mmc.pms.constant.TokenConstant
;
...
@@ -15,17 +17,22 @@ import com.mmc.pms.model.work.dto.ServiceDTO;
...
@@ -15,17 +17,22 @@ import com.mmc.pms.model.work.dto.ServiceDTO;
import
com.mmc.pms.model.work.dto.WorkServiceDTO
;
import
com.mmc.pms.model.work.dto.WorkServiceDTO
;
import
com.mmc.pms.model.work.vo.ServiceVO
;
import
com.mmc.pms.model.work.vo.ServiceVO
;
import
com.mmc.pms.page.PageResult
;
import
com.mmc.pms.page.PageResult
;
import
com.mmc.pms.redis.RedisConstant
;
import
com.mmc.pms.service.BackstageTaskService
;
import
com.mmc.pms.service.BackstageTaskService
;
import
com.mmc.pms.service.InspComtService
;
import
com.mmc.pms.service.InspComtService
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.RandomUtils
;
import
org.apache.commons.lang3.RandomUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.time.DateUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.ApplicationContext
;
import
org.springframework.context.ApplicationContext
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.CollectionUtils
;
import
org.springframework.util.CollectionUtils
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletRequest
;
import
java.util.*
;
import
java.util.*
;
import
java.util.concurrent.TimeUnit
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
/**
/**
...
@@ -45,6 +52,8 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
...
@@ -45,6 +52,8 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
@Autowired
private
InspComtService
inspComtService
;
@Autowired
private
InspComtService
inspComtService
;
@Autowired
private
RedisTemplate
redisTemplate
;
@Override
@Override
public
ResultBody
addWorkService
(
ServiceVO
param
,
Integer
userAccountId
)
{
public
ResultBody
addWorkService
(
ServiceVO
param
,
Integer
userAccountId
)
{
ServiceDO
serviceDO
=
new
ServiceDO
(
param
,
userAccountId
);
ServiceDO
serviceDO
=
new
ServiceDO
(
param
,
userAccountId
);
...
@@ -134,7 +143,7 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
...
@@ -134,7 +143,7 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
List
<
Integer
>
userIds
=
null
;
List
<
Integer
>
userIds
=
null
;
Integer
provinceCode
=
param
.
getProvinceCode
();
Integer
provinceCode
=
param
.
getProvinceCode
();
if
(
provinceCode
!=
null
){
if
(
provinceCode
!=
null
){
userIds
=
userAppApi
.
feignListUserAccountIds
(
provinceCode
,
null
,
null
,
request
.
getHeader
(
TokenConstant
.
TOKEN
)
);
userIds
=
userAppApi
.
feignListUserAccountIds
(
provinceCode
,
null
,
null
,
null
);
if
(
CollectionUtils
.
isEmpty
(
userIds
)){
if
(
CollectionUtils
.
isEmpty
(
userIds
)){
log
.
warn
(
"根据地区信息查询用户id为空"
);
log
.
warn
(
"根据地区信息查询用户id为空"
);
}
}
...
@@ -146,23 +155,34 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
...
@@ -146,23 +155,34 @@ public class BackstageTaskServiceImpl implements BackstageTaskService {
Integer
pageNo
=
param
.
getPageNo
();
Integer
pageNo
=
param
.
getPageNo
();
param
.
buildCurrentPage
();
param
.
buildCurrentPage
();
List
<
ServiceDO
>
pageList
=
backstageTaskServiceDao
.
queryPageByLimit
(
param
,
userIds
);
List
<
ServiceDO
>
pageList
=
backstageTaskServiceDao
.
queryPageByLimit
(
param
,
userIds
);
// 随机获取50条以上的评论
List
<
InspComtDO
>
inspComtRandomList
=
inspComtService
.
randomGetInspComtList
(
RandomUtils
.
nextInt
(
50
,
9999
));
if
(
inspComtRandomList
==
null
){
inspComtRandomList
=
Collections
.
emptyList
();
}
// 用户暂时无关联公司数据,先用假数据展示
// 用户暂时无关联公司数据,先用假数据展示
String
companyName
=
"浙江科比特创新科技有限公司"
;
String
companyName
=
"浙江科比特创新科技有限公司"
;
List
<
WorkServiceDTO
>
workServiceDTOList
=
new
ArrayList
<>();
List
<
WorkServiceDTO
>
workServiceDTOList
=
new
ArrayList
<>();
for
(
ServiceDO
item
:
pageList
)
{
for
(
ServiceDO
item
:
pageList
)
{
WorkServiceDTO
workServiceDTO
=
WorkServiceDTO
.
builder
().
id
(
item
.
getId
()).
serviceName
(
item
.
getServiceName
()).
companyName
(
companyName
)
WorkServiceDTO
workServiceDTO
=
WorkServiceDTO
.
builder
().
id
(
item
.
getId
()).
serviceName
(
item
.
getServiceName
()).
companyName
(
companyName
)
.
coverPlan
(
item
.
getCoverPlan
()).
serviceIntroduction
(
item
.
getServiceIntroduction
()).
video
(
item
.
getVideo
()).
shareCard
(
item
.
getShareCard
()).
build
();
.
coverPlan
(
item
.
getCoverPlan
()).
serviceIntroduction
(
item
.
getServiceIntroduction
()).
video
(
item
.
getVideo
()).
shareCard
(
item
.
getShareCard
()).
build
();
Collections
.
shuffle
(
inspComtRandomList
);
List
<
InspComtDO
>
inspComtList
=
RandomGetInspComt
(
item
.
getId
());
List
<
InspComtDO
>
inspComtList
=
inspComtRandomList
.
subList
(
0
,
RandomUtils
.
nextInt
(
0
,
inspComtRandomList
.
size
()));
workServiceDTO
.
setInspComtList
(
inspComtList
);
workServiceDTO
.
setInspComtList
(
inspComtList
);
workServiceDTO
.
setInspComtAmount
(
inspComtList
.
size
());
workServiceDTO
.
setInspComtAmount
(
inspComtList
.
size
());
workServiceDTOList
.
add
(
workServiceDTO
);
workServiceDTOList
.
add
(
workServiceDTO
);
}
}
return
PageResult
.
buildPage
(
pageNo
,
param
.
getPageSize
(),
count
,
workServiceDTOList
);
return
PageResult
.
buildPage
(
pageNo
,
param
.
getPageSize
(),
count
,
workServiceDTOList
);
}
}
/**
* 根据id随机获取50条以上的评论
*/
private
List
<
InspComtDO
>
RandomGetInspComt
(
Integer
id
)
{
String
listStr
=
(
String
)
redisTemplate
.
opsForValue
().
get
(
id
);
List
<
InspComtDO
>
inspComtRandomList
=
null
;
if
(
StringUtils
.
isNotBlank
(
listStr
)){
inspComtRandomList
=
JSONArray
.
parseArray
(
listStr
,
InspComtDO
.
class
);
}
else
{
inspComtRandomList
=
inspComtService
.
randomGetInspComtList
(
RandomUtils
.
nextInt
(
50
,
9999
));
String
toJSONString
=
JSONObject
.
toJSONString
(
inspComtRandomList
);
redisTemplate
.
opsForValue
().
set
(
id
,
toJSONString
,
2L
,
TimeUnit
.
DAYS
);
}
return
inspComtRandomList
;
}
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论