Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
P
promotion-service
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
promotion
promotion-service
Commits
482601c2
提交
482601c2
authored
8月 08, 2024
作者:
李秋林
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
1、促销员上报取消售卖单元记录;2、 促销员注册-注册失败时提示信息细化
上级
b4e905fe
隐藏空白字符变更
内嵌
并排
正在显示
9 个修改的文件
包含
53 行增加
和
43 行删除
+53
-43
pom.xml
pom.xml
+1
-1
TemporaryActivityQueryController.java
.../activity/temporary/TemporaryActivityQueryController.java
+4
-6
WeChatUserCoreController.java
...promotion/controller/wechat/WeChatUserCoreController.java
+5
-2
TemporaryActivityReportedDaoImpl.java
...n/activity/dao/impl/TemporaryActivityReportedDaoImpl.java
+1
-1
TemActApproveStatus.java
...gxiaolu/promotion/enums/activity/TemActApproveStatus.java
+1
-0
WxTemporaryEnrollVo.java
...angxiaolu/promotion/pojo/user/vo/WxTemporaryEnrollVo.java
+27
-13
EmployeeCoreTemActivityServiceImpl.java
...ity/employee/impl/EmployeeCoreTemActivityServiceImpl.java
+3
-3
EmployeeQueryTemActivityServiceImpl.java
...ty/employee/impl/EmployeeQueryTemActivityServiceImpl.java
+4
-2
TemporaryActivityCoreServiceImpl.java
...vity/temporary/impl/TemporaryActivityCoreServiceImpl.java
+7
-15
没有找到文件。
pom.xml
浏览文件 @
482601c2
...
@@ -13,7 +13,7 @@
...
@@ -13,7 +13,7 @@
<groupId>
com.wangxiaolu
</groupId>
<groupId>
com.wangxiaolu
</groupId>
<artifactId>
wangxiaolu-promotion-service
</artifactId>
<artifactId>
wangxiaolu-promotion-service
</artifactId>
<version>
0.1.
6
</version>
<version>
0.1.
7
</version>
<name>
wangxiaolu-promotion-service
</name>
<name>
wangxiaolu-promotion-service
</name>
<description>
promotion-service
</description>
<description>
promotion-service
</description>
...
...
src/main/java/com/wangxiaolu/promotion/controller/activity/temporary/TemporaryActivityQueryController.java
浏览文件 @
482601c2
...
@@ -98,12 +98,10 @@ public class TemporaryActivityQueryController {
...
@@ -98,12 +98,10 @@ public class TemporaryActivityQueryController {
}
else
if
(
CollectionUtils
.
isEmpty
(
activityReportedDto
.
getPsvPhotoUrls
())){
}
else
if
(
CollectionUtils
.
isEmpty
(
activityReportedDto
.
getPsvPhotoUrls
())){
throw
new
DataException
(
RCode
.
NOT_POS_PHOTO_ERROR
);
throw
new
DataException
(
RCode
.
NOT_POS_PHOTO_ERROR
);
}
}
// List<TemporaryActivityMarketCellDto> marketCells = temporaryActivityQueryService.findActivityMarketCellByDb(activityId);
List
<
TemporaryActivityMarketCellDto
>
marketCells
=
temporaryActivityQueryService
.
findActivityMarketCellByDb
(
activityId
);
// if (CollectionUtils.isEmpty(marketCells)){
if
(
CollectionUtils
.
isEmpty
(
marketCells
)){
// throw new DataException(RCode.NOT_MARKET_CELL_ERROR);
throw
new
DataException
(
RCode
.
NOT_MARKET_CELL_ERROR
);
// }
}
return
R
.
success
();
return
R
.
success
();
}
}
}
}
src/main/java/com/wangxiaolu/promotion/controller/wechat/WeChatUserCoreController.java
浏览文件 @
482601c2
...
@@ -45,8 +45,11 @@ public class WeChatUserCoreController {
...
@@ -45,8 +45,11 @@ public class WeChatUserCoreController {
// 人员信息校验
// 人员信息校验
boolean
isIden
=
DataUtils
.
idenCardPattern
(
wxTemporaryEnrollVo
.
getIdenNumber
());
boolean
isIden
=
DataUtils
.
idenCardPattern
(
wxTemporaryEnrollVo
.
getIdenNumber
());
boolean
isPhone
=
DataUtils
.
phonePattern
(
wxTemporaryEnrollVo
.
getPhone
());
boolean
isPhone
=
DataUtils
.
phonePattern
(
wxTemporaryEnrollVo
.
getPhone
());
if
(!
isIden
||
!
isPhone
)
{
if
(!
isIden
)
{
throw
new
ParamException
(
RCode
.
ENROLL_PARAM_ERROR
,
null
);
throw
new
ParamException
(
RCode
.
IDEN_NUMBER_PARAM_ERROR
,
null
);
}
if
(!
isPhone
)
{
throw
new
ParamException
(
RCode
.
PHONE_PARAM_ERROR
,
null
);
}
}
/**
/**
...
...
src/main/java/com/wangxiaolu/promotion/domain/activity/dao/impl/TemporaryActivityReportedDaoImpl.java
浏览文件 @
482601c2
...
@@ -53,7 +53,7 @@ public class TemporaryActivityReportedDaoImpl implements TemporaryActivityReport
...
@@ -53,7 +53,7 @@ public class TemporaryActivityReportedDaoImpl implements TemporaryActivityReport
}
}
/**
/**
*
根据促销员id查询所有任务
*
分布查询数据
*/
*/
@Override
@Override
public
void
findPage
(
TemporaryActivityWrapper
taw
,
PageInfo
pageInfo
)
{
public
void
findPage
(
TemporaryActivityWrapper
taw
,
PageInfo
pageInfo
)
{
...
...
src/main/java/com/wangxiaolu/promotion/enums/activity/TemActApproveStatus.java
浏览文件 @
482601c2
...
@@ -20,6 +20,7 @@ public enum TemActApproveStatus {
...
@@ -20,6 +20,7 @@ public enum TemActApproveStatus {
IN_APPROVAL
(
"审批中"
),
IN_APPROVAL
(
"审批中"
),
APPROVED
(
"审批通过"
),
APPROVED
(
"审批通过"
),
SEND_BACK
(
"退回"
),
SEND_BACK
(
"退回"
),
ALL
(
"ALL"
),
;
;
private
String
msg
;
private
String
msg
;
...
...
src/main/java/com/wangxiaolu/promotion/pojo/user/vo/WxTemporaryEnrollVo.java
浏览文件 @
482601c2
...
@@ -90,19 +90,33 @@ public class WxTemporaryEnrollVo {
...
@@ -90,19 +90,33 @@ public class WxTemporaryEnrollVo {
String
chargerName
;
String
chargerName
;
public
void
validate
()
{
public
void
validate
()
{
if
(
if
(
StringUtils
.
isBlank
(
openId
)){
StringUtils
.
isBlank
(
openId
)
||
throw
new
ParamException
(
RCode
.
WX_OPENID_PARAM_ERROR
,
null
);
StringUtils
.
isBlank
(
avatarUrl
)
||
}
StringUtils
.
isBlank
(
name
)
||
StringUtils
.
isBlank
(
phone
)
||
if
(
StringUtils
.
isBlank
(
avatarUrl
)){
StringUtils
.
isBlank
(
phoneCode
)
||
throw
new
ParamException
(
RCode
.
NOT_AVATAR_URL_PARAM_ERROR
,
null
);
StringUtils
.
isBlank
(
idenNumber
)
||
}
StringUtils
.
isBlank
(
openId
)
||
StringUtils
.
isBlank
(
chargerQcId
)
||
if
(
StringUtils
.
isBlank
(
name
)){
StringUtils
.
isBlank
(
deptQcId
)
throw
new
ParamException
(
RCode
.
NOT_USER_NAME_PARAM_ERROR
,
null
);
)
{
}
throw
new
ParamException
(
RCode
.
ENROLL_PARAM_ERROR
,
null
);
}
if
(
StringUtils
.
isBlank
(
phone
)){
throw
new
ParamException
(
RCode
.
PHONE_PARAM_ERROR
,
null
);
}
if
(
StringUtils
.
isBlank
(
phoneCode
)){
throw
new
ParamException
(
RCode
.
TENCENT_SMS_PHONE_CODE_ERROR
,
null
);
}
if
(
StringUtils
.
isBlank
(
idenNumber
)){
throw
new
ParamException
(
RCode
.
IDEN_NUMBER_PARAM_ERROR
,
null
);
}
if
(
StringUtils
.
isBlank
(
chargerQcId
)){
throw
new
ParamException
(
RCode
.
CHARGER_ID_ERROR
,
null
);
}
}
}
}
}
src/main/java/com/wangxiaolu/promotion/service/activity/employee/impl/EmployeeCoreTemActivityServiceImpl.java
浏览文件 @
482601c2
...
@@ -35,8 +35,8 @@ public class EmployeeCoreTemActivityServiceImpl implements EmployeeCoreTemActivi
...
@@ -35,8 +35,8 @@ public class EmployeeCoreTemActivityServiceImpl implements EmployeeCoreTemActivi
private
TemporaryActivityReportedDao
temporaryActivityReportedDao
;
private
TemporaryActivityReportedDao
temporaryActivityReportedDao
;
@Autowired
@Autowired
private
TemporaryActivityLogDao
tempActivityLogDao
;
private
TemporaryActivityLogDao
tempActivityLogDao
;
@Autowired
//
@Autowired
private
TemporaryActivityMarketCellDao
temporaryActivityMarketCellDao
;
//
private TemporaryActivityMarketCellDao temporaryActivityMarketCellDao;
@Autowired
@Autowired
private
TemporaryActivityPhotoDao
temporaryActivityPhotoDao
;
private
TemporaryActivityPhotoDao
temporaryActivityPhotoDao
;
...
@@ -81,7 +81,7 @@ public class EmployeeCoreTemActivityServiceImpl implements EmployeeCoreTemActivi
...
@@ -81,7 +81,7 @@ public class EmployeeCoreTemActivityServiceImpl implements EmployeeCoreTemActivi
temporaryActivityReportedDao
.
updateById
(
updateDto
);
temporaryActivityReportedDao
.
updateById
(
updateDto
);
// 删除售卖单元
// 删除售卖单元
temporaryActivityMarketCellDao
.
deleteByActivityReportedId
(
activityDo
.
getId
());
//
temporaryActivityMarketCellDao.deleteByActivityReportedId(activityDo.getId());
// 删除记录图片
// 删除记录图片
TemporaryPhotoWrapper
tpw
=
new
TemporaryPhotoWrapper
();
TemporaryPhotoWrapper
tpw
=
new
TemporaryPhotoWrapper
();
...
...
src/main/java/com/wangxiaolu/promotion/service/activity/employee/impl/EmployeeQueryTemActivityServiceImpl.java
浏览文件 @
482601c2
...
@@ -47,7 +47,9 @@ public class EmployeeQueryTemActivityServiceImpl implements EmployeeQueryTemActi
...
@@ -47,7 +47,9 @@ public class EmployeeQueryTemActivityServiceImpl implements EmployeeQueryTemActi
public
void
getEmployeeApproveActivityPage
(
String
employeeQcId
,
PageInfo
pageInfo
)
{
public
void
getEmployeeApproveActivityPage
(
String
employeeQcId
,
PageInfo
pageInfo
)
{
TemporaryActivityWrapper
tw
=
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
pageInfo
.
getQueryParams
()),
TemporaryActivityWrapper
.
class
);
TemporaryActivityWrapper
tw
=
JSONObject
.
parseObject
(
JSONObject
.
toJSONString
(
pageInfo
.
getQueryParams
()),
TemporaryActivityWrapper
.
class
);
tw
=
Objects
.
isNull
(
tw
)
?
new
TemporaryActivityWrapper
()
:
tw
;
tw
=
Objects
.
isNull
(
tw
)
?
new
TemporaryActivityWrapper
()
:
tw
;
// tw.setNotApproveStatus(TemActApproveStatus.SUBMITTED.name());
if
(
TemActApproveStatus
.
ALL
.
name
().
equals
(
tw
.
getApproveStatus
())){
tw
.
setApproveStatus
(
null
);
}
temporaryActivityReportedDao
.
findPage
(
tw
,
pageInfo
);
temporaryActivityReportedDao
.
findPage
(
tw
,
pageInfo
);
// 查询活动记录关联的售卖单元列表(一次性查出)
// 查询活动记录关联的售卖单元列表(一次性查出)
...
@@ -62,7 +64,7 @@ public class EmployeeQueryTemActivityServiceImpl implements EmployeeQueryTemActi
...
@@ -62,7 +64,7 @@ public class EmployeeQueryTemActivityServiceImpl implements EmployeeQueryTemActi
repClockInfo
(
activityIds
,
records
);
repClockInfo
(
activityIds
,
records
);
// 查询售卖商品信息
// 查询售卖商品信息
repMarketCell
(
activityIds
,
records
);
//
repMarketCell(activityIds,records);
}
}
/**
/**
...
...
src/main/java/com/wangxiaolu/promotion/service/activity/temporary/impl/TemporaryActivityCoreServiceImpl.java
浏览文件 @
482601c2
...
@@ -89,18 +89,16 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
...
@@ -89,18 +89,16 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
// 保存图片
// 保存图片
saveActivityPhoto
(
temActDto
);
saveActivityPhoto
(
temActDto
);
/**
// 售卖单元新增保存
* 售卖单元新增保存
// String key = temMarketCellRedisKey(temActDto.getTemporaryId());
*/
// temporaryActivityMarketCellDao.saveList(reportedId,redisCache.getToJsonArray(key));
String
key
=
temMarketCellRedisKey
(
temActDto
.
getTemporaryId
());
temporaryActivityMarketCellDao
.
saveList
(
reportedId
,
redisCache
.
getToJsonArray
(
key
));
/**
/**
* 日志保存
* 日志保存
*/
*/
tempActivityLogDao
.
save
(
temActDto
.
getTemporaryId
(),
temActDto
.
getTemporaryName
(),
LogType
.
t_2
,
temActDto
.
getId
(),
temActDto
);
tempActivityLogDao
.
save
(
temActDto
.
getTemporaryId
(),
temActDto
.
getTemporaryName
(),
LogType
.
t_2
,
temActDto
.
getId
(),
temActDto
);
redisCache
.
removeKey
(
key
);
//
redisCache.removeKey(key);
return
reportedId
;
return
reportedId
;
}
}
...
@@ -116,10 +114,9 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
...
@@ -116,10 +114,9 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
temporaryActivityReportedDao
.
updateById
(
temActDto
);
temporaryActivityReportedDao
.
updateById
(
temActDto
);
// 售卖单元新增保存
// 售卖单元新增保存
String
key
=
temMarketCellRedisKey
(
temActDto
.
getTemporaryId
());
// String key = temMarketCellRedisKey(temActDto.getTemporaryId());
temporaryActivityMarketCellDao
.
saveList
(
temActDto
.
getId
(),
redisCache
.
getToJsonArray
(
key
));
// temporaryActivityMarketCellDao.saveList(temActDto.getId(),redisCache.getToJsonArray(key));
// redisCache.removeKey(key);
redisCache
.
removeKey
(
key
);
// 日志保存
// 日志保存
tempActivityLogDao
.
save
(
temActDto
.
getTemporaryId
(),
temActDto
.
getTemporaryName
(),
LogType
.
t_2
,
temActDto
.
getId
(),
temActDto
);
tempActivityLogDao
.
save
(
temActDto
.
getTemporaryId
(),
temActDto
.
getTemporaryName
(),
LogType
.
t_2
,
temActDto
.
getId
(),
temActDto
);
}
}
...
@@ -138,11 +135,6 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
...
@@ -138,11 +135,6 @@ public class TemporaryActivityCoreServiceImpl implements TemporaryActivityCoreSe
throw
new
ParamException
(
RCode
.
DATA_NOT_HAVE_ERROR
,
null
);
throw
new
ParamException
(
RCode
.
DATA_NOT_HAVE_ERROR
,
null
);
}
}
// TemActApproveStatus approveStatus = reportedDto.getApproveStatus();
// if (!TemActApproveStatus.SUBMITTED.name().equals(approveStatus.name()) && !TemActApproveStatus.SEND_BACK.name().equals(approveStatus.name())) {
// throw new FlowException(RCode.STATUS_UPDATE_ERROR, null);
// }
// 查询促销员负责人,将人员补充到审批中
// 查询促销员负责人,将人员补充到审批中
WxTemporaryInfoDto
wxTemporaryInfoDto
=
temporaryInfoDao
.
selectOneById
(
reportedDto
.
getTemporaryId
());
WxTemporaryInfoDto
wxTemporaryInfoDto
=
temporaryInfoDao
.
selectOneById
(
reportedDto
.
getTemporaryId
());
TemporaryActivityReportedDto
updateDto
=
new
TemporaryActivityReportedDto
()
TemporaryActivityReportedDto
updateDto
=
new
TemporaryActivityReportedDto
()
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论