洪水预报接口对接

guoshilong

2024-03-05 2f8eaa7c850445fde0cdca0e8ecddcb7e2a936a3

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/feign/AttResManagePersonClient.java

@@ -3,18 +3,23 @@
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实现类
@@ -31,6 +36,7 @@

   private final IAttResManagePersonService attResManagePersonService;
   private final IAttAdBaseService adBaseService;
   private final IAttResBaseService attResBaseService;

   @Override
   @GetMapping(QUERY_LIST_BY_PHONE)
@@ -56,4 +62,58 @@

      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);
   }
}