package com.gkhy.safePlatform.emergency.rpc.provider;
|
|
|
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
|
import com.gkhy.safePlatform.commons.vo.ResultVO;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import com.gkhy.safePlatform.emergency.model.dto.resp.EmergencySuppliesRespDTO;
|
import com.gkhy.safePlatform.emergency.model.dto.resp.EmergencySuppliesTypeRespDTO;
|
import com.gkhy.safePlatform.emergency.rpc.api.EmergencyRpcAPi;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencyExecuteNumRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencyExecuteTimeRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.resp.EmergencyExecuteNumRPCResp;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.resp.EmergencyExecuteTimeRPCResp;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.resp.EmergencySuppliesRPCResp;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.resp.EmergencySuppliesTypeRPCResp;
|
import com.gkhy.safePlatform.emergency.service.EmergencyCountService;
|
import com.gkhy.safePlatform.emergency.service.EmergencySuppliesService;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.dubbo.config.annotation.DubboService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@DubboService
|
public class EmergencyRpcProvider implements EmergencyRpcAPi {
|
@Autowired
|
private EmergencySuppliesService emergencySuppliesService;
|
|
@Autowired
|
private EmergencyCountService emergencyCountService;
|
|
|
@Override
|
public SearchResultVO<EmergencyExecuteTimeRPCResp> getTimeByDeptId(EmergencyExecuteTimeRPCReq query) {
|
return emergencyCountService.getTimeByDeptId(query);
|
}
|
|
@Override
|
public SearchResultVO<List<EmergencyExecuteTimeRPCResp>> getTimeByDeptIds(EmergencyExecuteTimeRPCReq query) {
|
return emergencyCountService.getTimeByDeptIds(query);
|
}
|
|
@Override
|
public SearchResultVO<EmergencyExecuteNumRPCResp> getNumByDeptId(EmergencyExecuteNumRPCReq query) {
|
return emergencyCountService.getNumByDeptId(query);
|
}
|
|
@Override
|
public SearchResultVO<List<EmergencyExecuteNumRPCResp>> getNumByDeptIds(EmergencyExecuteNumRPCReq query) {
|
return emergencyCountService.getNumByDeptIds(query);
|
}
|
|
@Override
|
public ResultVO<List<EmergencySuppliesTypeRPCResp>> emergencySuppliesList(ContextCacheUser currentUser) {
|
|
List<EmergencySuppliesTypeRespDTO> list = (List<EmergencySuppliesTypeRespDTO>)emergencySuppliesService.emergencySuppliesList(currentUser).getData();
|
List<EmergencySuppliesTypeRPCResp> typeRPCRespList = new ArrayList<>();
|
for (EmergencySuppliesTypeRespDTO typeRespDTO:list) {
|
EmergencySuppliesTypeRPCResp typeRPCResp = new EmergencySuppliesTypeRPCResp();
|
typeRPCResp.setMaterialType(typeRespDTO.getMaterialType());
|
typeRPCResp.setMaterialTypeName(typeRespDTO.getMaterialTypeName());
|
if(!CollectionUtils.isEmpty(typeRespDTO.getList())){
|
List<EmergencySuppliesRPCResp> emergencySuppliesRPCRespList = BeanCopyUtils.copyBeanList(typeRespDTO.getList(), EmergencySuppliesRPCResp.class);
|
typeRPCResp.setList(emergencySuppliesRPCRespList);
|
}
|
typeRPCRespList.add(typeRPCResp);
|
}
|
return new ResultVO<>(ResultCodes.OK,typeRPCRespList);
|
}
|
|
@Override
|
public ResultVO<List<EmergencySuppliesRPCResp>> listCountByIds(ContextCacheUser currentUser,List<Long> ids) {
|
List<EmergencySuppliesRespDTO> list = (List<EmergencySuppliesRespDTO>)emergencySuppliesService.listCountByIds(currentUser,ids).getData();
|
List<EmergencySuppliesRPCResp> emergencySuppliesRPCRespList = null;
|
if(!CollectionUtils.isEmpty(list)){
|
emergencySuppliesRPCRespList = BeanCopyUtils.copyBeanList(list, EmergencySuppliesRPCResp.class);
|
}
|
|
return new ResultVO<>(ResultCodes.OK,emergencySuppliesRPCRespList);
|
}
|
}
|
