package com.gkhy.safePlatform.emergency.rpc.provider;
|
|
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import com.gkhy.safePlatform.emergency.rpc.api.EmergencyRpcAPi;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.req.EmergencyExecuteNumRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.req.EmergencyExecuteTimeRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.resp.EmergencyExecuteNumRPCResp;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.resp.EmergencyExecuteTimeRPCResp;
|
import com.gkhy.safePlatform.emergency.service.EmergencyCountService;
|
import org.apache.dubbo.config.annotation.DubboService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.List;
|
|
@DubboService
|
public class EmergencyRpcProvider implements EmergencyRpcAPi {
|
|
@Autowired
|
private EmergencyCountService emergencyCountService;
|
|
|
@Override
|
public SearchResultVO<EmergencyExecuteTimeRPCResp> getTimeByDeptId(EmergencyExecuteTimeRPCReq query) {
|
EmergencyExecuteTimeRPCResp emergencyExecuteTimeRPCResp = emergencyCountService.getTimeByDeptId(query);
|
return new SearchResultVO(
|
false,
|
null,
|
null,
|
null,
|
(long)1,
|
emergencyExecuteTimeRPCResp,
|
ResultCodes.OK
|
);
|
}
|
|
@Override
|
public SearchResultVO<List<EmergencyExecuteTimeRPCResp>> getTimeByDeptIds(EmergencyExecuteTimeRPCReq query) {
|
List<EmergencyExecuteTimeRPCResp> emergencyExecuteTimeRPCRespList = emergencyCountService.getTimeByDeptIds(query);
|
return new SearchResultVO(
|
false,
|
null,
|
null,
|
null,
|
(long)emergencyExecuteTimeRPCRespList.size(),
|
emergencyExecuteTimeRPCRespList,
|
ResultCodes.OK
|
);
|
}
|
|
@Override
|
public SearchResultVO<EmergencyExecuteNumRPCResp> getNumByDeptId(EmergencyExecuteNumRPCReq query) {
|
EmergencyExecuteNumRPCResp emergencyExecuteNumRPCResp = emergencyCountService.getNumByDeptId(query);
|
return new SearchResultVO(
|
false,
|
null,
|
null,
|
null,
|
(long)1,
|
emergencyExecuteNumRPCResp,
|
ResultCodes.OK
|
);
|
}
|
|
@Override
|
public SearchResultVO<List<EmergencyExecuteNumRPCResp>> getNumByDeptIds(EmergencyExecuteNumRPCReq query) {
|
List<EmergencyExecuteNumRPCResp> emergencyExecuteNumRPCRespList = emergencyCountService.getNumByDeptIds(query);
|
return new SearchResultVO(
|
false,
|
null,
|
null,
|
null,
|
(long)emergencyExecuteNumRPCRespList.size(),
|
emergencyExecuteNumRPCRespList,
|
ResultCodes.OK
|
);
|
}
|
}
|