package cn.gistack.sm.sjztmd.feign;
|
|
import cn.gistack.sm.sjztmd.entity.AttAdBase;
|
import cn.gistack.sm.sjztmd.entity.AttResManagePerson;
|
import cn.gistack.sm.sjztmd.service.IAttAdBaseService;
|
import cn.gistack.sm.sjztmd.service.IAttResBaseService;
|
import cn.gistack.sm.sjztmd.service.IAttResManagePersonService;
|
import cn.gistack.sm.sjztmd.vo.PersonVO;
|
import jodd.util.StringUtil;
|
import lombok.AllArgsConstructor;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springblade.core.tool.api.R;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* @ClassName SM服务Feign实现类
|
* @Description TODO
|
* @Author aix
|
* @Date 2023/4/23 19:42
|
* @Version 1.0
|
*/
|
@NonDS
|
@ApiIgnore
|
@RestController
|
@AllArgsConstructor
|
public class AttResManagePersonClient implements IAttResManagePersonClient {
|
|
private final IAttResManagePersonService attResManagePersonService;
|
private final IAttAdBaseService adBaseService;
|
private final IAttResBaseService attResBaseService;
|
|
@Override
|
@GetMapping(QUERY_LIST_BY_PHONE)
|
public R queryListByPhone(String userPhone) {
|
AttResManagePerson attResManagePerson = new AttResManagePerson();
|
attResManagePerson.setUserPhone(userPhone);
|
List<AttResManagePerson> list = attResManagePersonService.list(Condition.getQueryWrapper(attResManagePerson));
|
List<String> reslist = new ArrayList<>();
|
list.forEach(item->{
|
reslist.add(item.getResGuid());
|
});
|
return R.data(StringUtil.join(reslist,","));
|
}
|
|
@Override
|
@GetMapping(GET_AD_BASE)
|
public R getAdBaseById(String guid) {
|
AttAdBase attAdBase = new AttAdBase();
|
attAdBase.setGuid(guid);
|
List<AttAdBase> attAdBases = adBaseService.list(Condition.getQueryWrapper(attAdBase));
|
if (attAdBases.size() > 0)
|
return R.data(attAdBases.get(0));
|
|
return R.data(null);
|
}
|
|
/**
|
* 查询责任人相关信息
|
* @param guid
|
* @param personList
|
* @return
|
*/
|
@Override
|
public List<PersonVO> getPersonListByResGuid(String guid, String personList) {
|
return attResManagePersonService.getPersonListByResGuid(guid, Arrays.asList(personList.split(",")));
|
}
|
|
/**
|
*
|
* @param res_cd
|
* @param areaList
|
* @return
|
*/
|
@Override
|
public List<PersonVO> getUserListByResGuid(String res_cd, String areaList) {
|
return adBaseService.getPersonListByResGuid(res_cd,areaList);
|
}
|
|
@Override
|
public int syncharonization_add_user() {
|
return attResManagePersonService.synchronizationAddUser();
|
}
|
|
@Override
|
public int syncharonization_update_user() {
|
return attResManagePersonService.synchronizationUpdateUser();
|
}
|
|
/**
|
* 通过水库代码获取巡查责任人及技术责任人手机号
|
* @param list
|
* @return
|
*/
|
@Override
|
@PostMapping(GET_PERSON_LIST_BY_WATER_CODE_LIST)
|
public Set<String> getPersonListByWaterCodeList(List<String> list) {
|
return attResManagePersonService.getPersonListByWaterCodeList(list);
|
}
|
|
/**
|
* 根据水库编号查询市县水利部人员姓名及联系方式
|
* @param res_cd 水库编号
|
* @return
|
*/
|
@Override
|
@GetMapping(GET_CITY_COUNTY_PERSONG_LIST_BY_RES_GUID)
|
public List<PersonVO> getCityCountyPersonListByResGuid(String res_cd) {
|
return attResManagePersonService.getCityCountyPersonListByResGuid(res_cd);
|
}
|
}
|
