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

feat:[REQ-3282] 增加gaia rpc接口

Browse Source
This commit is contained in:
liuyang 2024-12-11 11:32:44 +08:00
parent 4d4d394579
commit 15ddb4b2ea
7 changed files with 116 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/GaiaOrderServiceClient.java Normal file
View File

@ -0,0 +1,26 @@
package cn.axzo.orgmanax.infra.client.gaia;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaBatchQueryWorkerIsAllConfirmedReq;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaBatchQueryWorkerIsAllConfirmedResp;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaListWorkerUnFinishWorkpointResp;
import java.util.List;
public interface GaiaOrderServiceClient {
/**
* 开放接口-获取未完成项目内班组记工单（按工人分组）
* @param workspaceId 工作台id
* @param projectTeamId 项目内班组id
* @return
*/
List<GaiaListWorkerUnFinishWorkpointResp> listWorkerUnFinishWorkpoint(Long workspaceId, Long projectTeamId);
/**
* 开放接口-项目内工人记工单是否全部完成，true:全部完成，false:未全部完成
* @param request
* @return
*/
List<GaiaBatchQueryWorkerIsAllConfirmedResp> batchQueryWorkerIsAllConfirmed(GaiaBatchQueryWorkerIsAllConfirmedReq request);
}

18
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/dto/GaiaBatchQueryWorkerIsAllConfirmedReq.java Normal file
View File

@ -0,0 +1,18 @@
package cn.axzo.orgmanax.infra.client.gaia.dto;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
@Data
public class GaiaBatchQueryWorkerIsAllConfirmedReq {
@NotNull(message = "workspaceId 不能为空！")
private Long workspaceId;
@NotEmpty(message = "workerIdentityIds 不能为空！")
private List<Long> workerIdentityIds;
}

14
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/dto/GaiaBatchQueryWorkerIsAllConfirmedResp.java Normal file
View File

@ -0,0 +1,14 @@
package cn.axzo.orgmanax.infra.client.gaia.dto;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
@Data
public class GaiaBatchQueryWorkerIsAllConfirmedResp {
private Long workerIdentityId;
private Boolean isAllConfirmed;
}

9
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/dto/GaiaGetToWorkerConfirmWorkpointTaskCountReq.java
View File

@ -1,9 +0,0 @@
package cn.axzo.orgmanax.infra.client.gaia.dto;
import cn.axzo.foundation.page.IPageReq;
import lombok.Data;
@Data
public class GaiaGetToWorkerConfirmWorkpointTaskCountReq {
}

7
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/dto/GaiaGetToWorkerConfirmWorkpointTaskCountResp.java
View File

@ -1,7 +0,0 @@
package cn.axzo.orgmanax.infra.client.gaia.dto;
import lombok.Data;
@Data
public class GaiaGetToWorkerConfirmWorkpointTaskCountResp {
}

18
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/gaia/dto/GaiaListWorkerUnFinishWorkpointResp.java Normal file
View File

@ -0,0 +1,18 @@
package cn.axzo.orgmanax.infra.client.gaia.dto;
import lombok.Data;
@Data
public class GaiaListWorkerUnFinishWorkpointResp {
/**
* 工人id
*/
private Long workerId;
/**
* 未完成记工单数量
*/
private Integer workpointNum;
}

40
orgmanax-integration/src/main/java/cn/axzo/orgmanax/integration/sdk/gaia/GaiaOrderServiceClientImpl.java Normal file
View File

@ -0,0 +1,40 @@
package cn.axzo.orgmanax.integration.sdk.gaia;
import cn.axzo.elise.cdzj.entity.request.PersonRegisterInfoReq;
import cn.axzo.elise.cdzj.entity.response.PersonRegisterInfoResp;
import cn.axzo.gaia.client.api.OrderServiceApi;
import cn.axzo.gaia.client.api.co.WorkerUnFinishWorkpointDTO;
import cn.axzo.gaia.client.api.co.request.WorkerConfirmedStatusRequest;
import cn.axzo.gaia.client.api.dto.WorkerConfirmedStatusResDTO;
import cn.axzo.orgmanax.infra.client.elise.dto.EliseListUserStateResp;
import cn.axzo.orgmanax.infra.client.gaia.GaiaOrderServiceClient;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaBatchQueryWorkerIsAllConfirmedReq;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaBatchQueryWorkerIsAllConfirmedResp;
import cn.axzo.orgmanax.infra.client.gaia.dto.GaiaListWorkerUnFinishWorkpointResp;
import cn.axzo.orgmanax.integration.core.RpcWrapper;
import cn.hutool.core.bean.BeanUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
import java.util.List;
@RequiredArgsConstructor
@Component
public class GaiaOrderServiceClientImpl implements GaiaOrderServiceClient {
private final OrderServiceApi orderServiceApi;
@Override
public List<GaiaListWorkerUnFinishWorkpointResp> listWorkerUnFinishWorkpoint(Long workspaceId, Long projectTeamId) {
List<WorkerUnFinishWorkpointDTO> resp = RpcWrapper.commonRes(() -> orderServiceApi.listWorkerUnFinishWorkpoint(workspaceId, projectTeamId));
return BeanUtil.copyToList(resp, GaiaListWorkerUnFinishWorkpointResp.class);
}
@Override
public List<GaiaBatchQueryWorkerIsAllConfirmedResp> batchQueryWorkerIsAllConfirmed(GaiaBatchQueryWorkerIsAllConfirmedReq request) {
WorkerConfirmedStatusRequest rpcReq = BeanUtil.copyProperties(request, WorkerConfirmedStatusRequest.class);
List<WorkerConfirmedStatusResDTO> list = RpcWrapper.commonRes(() -> orderServiceApi.batchQueryWorkerIsAllConfirmed(rpcReq));
return BeanUtil.copyToList(list, GaiaBatchQueryWorkerIsAllConfirmedResp.class);
}
}