wangli/riven
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-2960): 重命名泰州相关的一个handler和job的名字

Browse Source
This commit is contained in:
周敏 2024-09-07 17:21:58 +08:00
parent fbd7c1713a
commit 8338b69f4d
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
riven-third/src/main/java/cn/axzo/riven/third/taizhou/job/ManualUpdateThirdPersonJob.java → riven-third/src/main/java/cn/axzo/riven/third/taizhou/job/ManualUpdateTaizhouPersonIdJob.java
View File

@ -5,6 +5,7 @@ import cn.axzo.basics.profiles.api.UserProfileServiceApi;
import cn.axzo.basics.profiles.common.utils.RpcUtils;
import cn.axzo.basics.profiles.dto.basic.PersonProfileDto;
import cn.axzo.basics.profiles.dto.request.QueryPersonProfileByIdOrPhoneDto;
import cn.axzo.riven.client.common.enums.ThirdCodeEnum;
import cn.axzo.riven.third.dao.ThirdPersonDao;
import cn.axzo.riven.third.entity.ThirdPerson;
import cn.axzo.riven.third.taizhou.service.OperateLogService;
@ -41,7 +42,7 @@ import static cn.axzo.basics.profiles.common.enums.VerifyStatus.VERIFY_SUCCESS;
*/
@Slf4j
@Component
public class ManualUpdateThirdPersonJob extends IJobHandler {
public class ManualUpdateTaizhouPersonIdJob extends IJobHandler {
@Autowired
private ThirdPersonDao thirdPersonDao;
@ -51,7 +52,7 @@ public class ManualUpdateThirdPersonJob extends IJobHandler {
private OperateLogService operateLogService;
@Override
@XxlJob("manualUpdateThirdPersonJob")
@XxlJob("manualUpdateTaizhouPersonIdJob")
public ReturnT<String> execute(String param) throws Exception {
if (Strings.isNullOrEmpty(param)) {
XxlJobLogger.log("参数错误");
@ -65,6 +66,7 @@ public class ManualUpdateThirdPersonJob extends IJobHandler {
List<ThirdPerson> thirdPersonList = thirdPersonDao.listByIds(updateParam.getIds())
.stream()
.filter(t -> Objects.equals(t.getIsDelete(), TableIsDeleteEnum.NORMAL.value))
.filter(t -> Objects.equals(t.getThirdCode(), ThirdCodeEnum.TAI_ZHOU.getCode()))
.collect(Collectors.toList());
if (thirdPersonList.isEmpty()) {
XxlJobLogger.log("没有找到数据，处理0条");

2
riven-third/src/main/java/cn/axzo/riven/third/taizhou/mq/outer/UpdateThirdPersonOnPersonProfileMergedHandler.java → riven-third/src/main/java/cn/axzo/riven/third/taizhou/mq/outer/UpdateTaizhouPersonOnPersonProfileMergedHandler.java
View File

@ -32,7 +32,7 @@ import java.util.stream.Collectors;
*/
@Slf4j
@Component
public class UpdateThirdPersonOnPersonProfileMergedHandler implements InitializingBean {
public class UpdateTaizhouPersonOnPersonProfileMergedHandler implements InitializingBean {
@Autowired
private EventConsumer eventConsumer;