Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
W
wangxiaolu-export
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
promotion
wangxiaolu-export
Commits
2f4c3a01
提交
2f4c3a01
authored
9月 04, 2024
作者:
李秋林
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
同步促销员活动数据时,如果查询为0条数据,则停止同步
上级
1545f3e6
全部展开
隐藏空白字符变更
内嵌
并排
正在显示
4 个修改的文件
包含
11 行增加
和
98 行删除
+11
-98
PromotionActivityExport.java
.../export/controller/promotion/PromotionActivityExport.java
+1
-3
ExcelClassField.java
...main/java/com/wangxiaolu/export/util/ExcelClassField.java
+0
-89
ExcelUtils.java
src/main/java/com/wangxiaolu/export/util/ExcelUtils.java
+0
-0
XxlJobHandler.java
.../java/com/wangxiaolu/export/xxljobtask/XxlJobHandler.java
+10
-6
没有找到文件。
src/main/java/com/wangxiaolu/export/controller/promotion/PromotionActivityExport.java
浏览文件 @
2f4c3a01
package
com
.
wangxiaolu
.
export
.
controller
.
promotion
;
package
com
.
wangxiaolu
.
export
.
controller
.
promotion
;
import
cn.hutool.core.date.DateUtil
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityClockDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityClockDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityPhotoDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityPhotoDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityReportedDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityReportedDO
;
import
com.wangxiaolu.export.pojo.ActivityVo
;
import
com.wangxiaolu.export.pojo.ActivityVo
;
import
com.wangxiaolu.export.service.PromotionActivityService
;
import
com.wangxiaolu.export.service.PromotionActivityService
;
import
com.wangxiaolu.export.util.ExcelUtils
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.util.CollectionUtils
;
import
org.springframework.util.CollectionUtils
;
...
@@ -212,7 +210,7 @@ public class PromotionActivityExport {
...
@@ -212,7 +210,7 @@ public class PromotionActivityExport {
log
.
info
(
"活动记录数据处理完成,开始导出"
);
log
.
info
(
"活动记录数据处理完成,开始导出"
);
System
.
out
.
println
(
"1:"
+
System
.
currentTimeMillis
());
System
.
out
.
println
(
"1:"
+
System
.
currentTimeMillis
());
ExcelUtils
.
export
(
response
,
"活动数据导出_"
+
DateUtil
.
today
(),
sheet
);
//
ExcelUtils.export(response, "活动数据导出_"+ DateUtil.today(), sheet);
System
.
out
.
println
(
"7:"
+
System
.
currentTimeMillis
());
System
.
out
.
println
(
"7:"
+
System
.
currentTimeMillis
());
log
.
info
(
"============== 活动记录导出 end =============="
);
log
.
info
(
"============== 活动记录导出 end =============="
);
}
}
...
...
src/main/java/com/wangxiaolu/export/util/ExcelClassField.java
deleted
100644 → 0
浏览文件 @
1545f3e6
package
com
.
wangxiaolu
.
export
.
util
;
import
java.util.LinkedHashMap
;
/**
* @author sunnyzyq
* @date 2021/12/17
*/
public
class
ExcelClassField
{
/**
* 字段名称
*/
private
String
fieldName
;
/**
* 表头名称
*/
private
String
name
;
/**
* 映射关系
*/
private
LinkedHashMap
<
String
,
String
>
kvMap
;
/**
* 示例值
*/
private
Object
example
;
/**
* 排序
*/
private
int
sort
;
/**
* 是否为注解字段:0-否,1-是
*/
private
int
hasAnnotation
;
public
String
getFieldName
()
{
return
fieldName
;
}
public
void
setFieldName
(
String
fieldName
)
{
this
.
fieldName
=
fieldName
;
}
public
String
getName
()
{
return
name
;
}
public
void
setName
(
String
name
)
{
this
.
name
=
name
;
}
public
LinkedHashMap
<
String
,
String
>
getKvMap
()
{
return
kvMap
;
}
public
void
setKvMap
(
LinkedHashMap
<
String
,
String
>
kvMap
)
{
this
.
kvMap
=
kvMap
;
}
public
Object
getExample
()
{
return
example
;
}
public
void
setExample
(
Object
example
)
{
this
.
example
=
example
;
}
public
int
getSort
()
{
return
sort
;
}
public
void
setSort
(
int
sort
)
{
this
.
sort
=
sort
;
}
public
int
getHasAnnotation
()
{
return
hasAnnotation
;
}
public
void
setHasAnnotation
(
int
hasAnnotation
)
{
this
.
hasAnnotation
=
hasAnnotation
;
}
}
src/main/java/com/wangxiaolu/export/util/ExcelUtils.java
deleted
100644 → 0
浏览文件 @
1545f3e6
差异被折叠。
点击展开。
src/main/java/com/wangxiaolu/export/xxljobtask/XxlJobHandler.java
浏览文件 @
2f4c3a01
...
@@ -5,15 +5,13 @@ import cn.hutool.core.date.DateUtil;
...
@@ -5,15 +5,13 @@ import cn.hutool.core.date.DateUtil;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityClockDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityClockDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityPhotoDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityPhotoDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityReportedDO
;
import
com.wangxiaolu.export.mapper.entity.TemporaryActivityReportedDO
;
import
com.wangxiaolu.export.pojo.ActivityVo
;
import
com.wangxiaolu.export.service.ActivityToFeishuSheetService
;
import
com.wangxiaolu.export.service.ActivityToFeishuSheetService
;
import
com.wangxiaolu.export.service.PromotionActivityService
;
import
com.wangxiaolu.export.service.PromotionActivityService
;
import
com.xxl.job.core.handler.annotation.XxlJob
;
import
com.xxl.job.core.handler.annotation.XxlJob
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Component
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.util.CollectionUtils
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
java.util.HashMap
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
...
@@ -45,13 +43,20 @@ public class XxlJobHandler {
...
@@ -45,13 +43,20 @@ public class XxlJobHandler {
*/
*/
@XxlJob
(
"yesterday_activity_push_feishu"
)
@XxlJob
(
"yesterday_activity_push_feishu"
)
public
void
pushFeishuTask
()
{
public
void
pushFeishuTask
()
{
log
.
info
(
"============== 活动记录上传飞书 start =============="
);
/**
/**
* 1>> 查询前一天的活动记录
* 1>> 查询前一天的活动记录
*/
*/
String
yt
=
DateUtil
.
format
(
DateUtil
.
yesterday
(),
DatePattern
.
NORM_DATE_PATTERN
);
String
yt
=
DateUtil
.
format
(
DateUtil
.
yesterday
(),
DatePattern
.
NORM_DATE_PATTERN
);
List
<
TemporaryActivityReportedDO
>
reportedDos
=
promotionActivityService
.
findActivityListByCreateDate
(
yt
);
List
<
TemporaryActivityReportedDO
>
reportedDos
=
promotionActivityService
.
findActivityListByCreateDate
(
yt
);
log
.
info
(
"应上传飞书{}条活动记录"
,
reportedDos
.
size
());
if
(
CollectionUtils
.
isEmpty
(
reportedDos
)){
log
.
info
(
"无活动记录,停止上传"
);
}
List
<
Long
>
activityId
=
reportedDos
.
stream
().
map
(
TemporaryActivityReportedDO:
:
getId
).
collect
(
Collectors
.
toList
());
List
<
Long
>
activityId
=
reportedDos
.
stream
().
map
(
TemporaryActivityReportedDO:
:
getId
).
collect
(
Collectors
.
toList
());
Map
<
Long
,
List
<
TemporaryActivityPhotoDO
>>
activityPhotos
=
promotionActivityService
.
findActivityPhotos
(
activityId
);
Map
<
Long
,
List
<
TemporaryActivityPhotoDO
>>
activityPhotos
=
promotionActivityService
.
findActivityPhotos
(
activityId
);
...
@@ -64,11 +69,10 @@ public class XxlJobHandler {
...
@@ -64,11 +69,10 @@ public class XxlJobHandler {
clockPhotoMap
.
put
(
cp
.
getTemporaryId
()
+
"-"
+
cp
.
getCreateDate
(),
cp
.
getPhotoList
());
clockPhotoMap
.
put
(
cp
.
getTemporaryId
()
+
"-"
+
cp
.
getCreateDate
(),
cp
.
getPhotoList
());
});
});
log
.
info
(
"============== 活动记录上传飞书 start("
+
System
.
currentTimeMillis
()
+
") =============="
);
activityToFeishuSheetService
.
activityDataToFeishuSheet
(
reportedDos
,
activityPhotos
,
clockPhotoMap
);
activityToFeishuSheetService
.
activityDataToFeishuSheet
(
reportedDos
,
activityPhotos
,
clockPhotoMap
);
log
.
info
(
"============== 活动记录上传飞书 end
("
+
System
.
currentTimeMillis
()
+
")
=============="
);
log
.
info
(
"============== 活动记录上传飞书 end =============="
);
}
}
}
}
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论