Browse Source

fix: 修复feign远程调用token传递

master
wangxiang 2 years ago
parent
commit
7386651564
  1. 2
      kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java
  2. 2
      kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java
  3. 2
      kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java
  4. 9
      kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java
  5. 5
      kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteDictService.java
  6. 5
      kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteRegionService.java
  7. 15
      kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java
  8. 2
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java
  9. 2
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java
  10. 2
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/OrgController.java
  11. 3
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushConcernFanController.java
  12. 4
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java
  13. 2
      kicc-platform/kicc-platform-biz/kicc-system-biz/src/main/java/com/cloud/kicc/system/controller/DictDataController.java

2
kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccAppUserDetailsServiceImpl.java

@ -34,7 +34,7 @@ public class KiccAppUserDetailsServiceImpl implements KiccUserDetailsService {
@Override @Override
@SneakyThrows @SneakyThrows
public UserDetails loadUserByUsername(String phone) { public UserDetails loadUserByUsername(String phone) {
R<User> result = remoteUserService.selectByPhone(phone, SecurityConstants.FROM_IN); R<User> result = remoteUserService.selectByPhone(phone);
UserDetails userDetails = getUserDetails(result); UserDetails userDetails = getUserDetails(result);
return userDetails; return userDetails;
} }

2
kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/service/impl/KiccUserDetailsServiceImpl.java

@ -35,7 +35,7 @@ public class KiccUserDetailsServiceImpl implements KiccUserDetailsService {
@Override @Override
@SneakyThrows @SneakyThrows
public UserDetails loadUserByUsername(String username) { public UserDetails loadUserByUsername(String username) {
R<User> result = remoteUserService.selectByUserName(username, SecurityConstants.FROM_IN); R<User> result = remoteUserService.selectByUserName(username);
UserDetails userDetails = getUserDetails(result); UserDetails userDetails = getUserDetails(result);
return userDetails; return userDetails;
} }

2
kicc-common/kicc-common-security/src/main/java/com/cloud/kicc/common/security/util/SecurityUtils.java

@ -85,7 +85,7 @@ public class SecurityUtils {
*/ */
public User openInterfaceTemporaryLoginSession(String userId){ public User openInterfaceTemporaryLoginSession(String userId){
RemoteUserService remoteUserService = SpringContextHolderUtil.getBean(RemoteUserService.class); RemoteUserService remoteUserService = SpringContextHolderUtil.getBean(RemoteUserService.class);
R<User> result = remoteUserService.selectByUserId(userId, SecurityConstants.FROM_IN); R<User> result = remoteUserService.selectByUserId(userId);
if (result == null || result.getData() == null) { if (result == null || result.getData() == null) {
throw new CheckedException("用户不存在"); throw new CheckedException("用户不存在");
} }

9
kicc-platform/kicc-platform-api/kicc-common-api/src/main/java/com/cloud/kicc/commonbiz/api/feign/RemotePushConcernFanService.java

@ -2,14 +2,11 @@ package com.cloud.kicc.commonbiz.api.feign;
import com.cloud.kicc.common.core.api.R; import com.cloud.kicc.common.core.api.R;
import com.cloud.kicc.common.core.constant.AppConstants; import com.cloud.kicc.common.core.constant.AppConstants;
import com.cloud.kicc.common.core.constant.SecurityConstants;
import com.cloud.kicc.common.core.constant.ServiceNameConstants; import com.cloud.kicc.common.core.constant.ServiceNameConstants;
import com.cloud.kicc.system.api.entity.User; import com.cloud.kicc.system.api.entity.User;
import feign.Param;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import java.util.List; import java.util.List;
@ -26,13 +23,13 @@ import java.util.Set;
@FeignClient(contextId = "remotePushConcernFanService", value = ServiceNameConstants.COMMON_SERVICE) @FeignClient(contextId = "remotePushConcernFanService", value = ServiceNameConstants.COMMON_SERVICE)
public interface RemotePushConcernFanService { public interface RemotePushConcernFanService {
@PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/enterpriseUserFanSave", headers = SecurityConstants.HEADER_FROM_IN) @PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/enterpriseUserFanSave")
R enterpriseUserFanSave(@RequestParam("innerEnterpriseUserId") String innerEnterpriseUserId, @RequestBody List<User> userList); R enterpriseUserFanSave(@RequestParam("innerEnterpriseUserId") String innerEnterpriseUserId, @RequestBody List<User> userList);
@PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/removeUserPushData", headers = SecurityConstants.HEADER_FROM_IN) @PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/removeUserPushData")
R removeUserPushData(@RequestParam("userIds") Set<String> userIds); R removeUserPushData(@RequestParam("userIds") Set<String> userIds);
@PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/bindConcernEnterpriseUser", headers = SecurityConstants.HEADER_FROM_IN) @PostMapping(value = AppConstants.APP_COMMON + "/pushConcernFan/bindConcernEnterpriseUser")
R bindConcernEnterpriseUser(@RequestParam("userId") String userId, @RequestBody List<User> enterpriseUserList); R bindConcernEnterpriseUser(@RequestParam("userId") String userId, @RequestBody List<User> enterpriseUserList);
} }

5
kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteDictService.java

@ -26,10 +26,9 @@ public interface RemoteDictService {
/** /**
* 根据 type 查询字典数据 * 根据 type 查询字典数据
* @param type 字典类型 * @param type 字典类型
* @param from 内部调用标志
* @return 返回字典项列表 * @return 返回字典项列表
*/ */
@GetMapping(AppConstants.APP_SYSTEM + "/dictData/getDictByType/{type}") @GetMapping(value = AppConstants.APP_SYSTEM + "/dictData/getDictByType/{type}", headers = SecurityConstants.HEADER_FROM_IN)
R<List<DictData>> getDictByType(@PathVariable("type") String type, @RequestHeader(SecurityConstants.FROM) String from); R<List<DictData>> getDictByType(@PathVariable("type") String type);
} }

5
kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteRegionService.java

@ -24,10 +24,9 @@ public interface RemoteRegionService {
/** /**
* 通过区域id查询区域信息 * 通过区域id查询区域信息
* @param regionIds 区域id * @param regionIds 区域id
* @param from 调用标志
* @return R * @return R
*/ */
@GetMapping(AppConstants.APP_SYSTEM + "/region/selectByRegionIds/{regionIds}") @GetMapping(value = AppConstants.APP_SYSTEM + "/region/selectByRegionIds/{regionIds}", headers = SecurityConstants.HEADER_FROM_IN)
R<List<Region>> selectByRegionIds(@PathVariable("regionIds") String[] regionIds, @RequestHeader(SecurityConstants.FROM) String from); R<List<Region>> selectByRegionIds(@PathVariable("regionIds") String[] regionIds);
} }

15
kicc-platform/kicc-platform-api/kicc-system-api/src/main/java/com/cloud/kicc/system/api/feign/RemoteUserService.java

@ -24,28 +24,25 @@ public interface RemoteUserService {
/** /**
* 通过用户名查询用户 * 通过用户名查询用户
* @param userName 用户名 * @param userName 用户名
* @param from 调用标志
* @return R * @return R
*/ */
@GetMapping(AppConstants.APP_SYSTEM + "/user/selectByUserName/{userName}") @GetMapping(value = AppConstants.APP_SYSTEM + "/user/selectByUserName/{userName}", headers = SecurityConstants.HEADER_FROM_IN)
R<User> selectByUserName(@PathVariable("userName") String userName, @RequestHeader(SecurityConstants.FROM) String from); R<User> selectByUserName(@PathVariable("userName") String userName);
/** /**
* 通过手机号码查询用户 * 通过手机号码查询用户
* @param phone 手机号码 * @param phone 手机号码
* @param from 调用标志
* @return R * @return R
*/ */
@GetMapping(AppConstants.APP_SYSTEM + "/user/selectByPhone/{phone}") @GetMapping(value = AppConstants.APP_SYSTEM + "/user/selectByPhone/{phone}", headers = SecurityConstants.HEADER_FROM_IN)
R<User> selectByPhone(@PathVariable("phone") String phone, @RequestHeader(SecurityConstants.FROM) String from); R<User> selectByPhone(@PathVariable("phone") String phone);
/** /**
* 通过用户ID查询用户 * 通过用户ID查询用户
* @param userid 用户id * @param userid 用户id
* @param from 调用标志
* @return R * @return R
*/ */
@GetMapping(AppConstants.APP_SYSTEM + "/user/getUser/{userId}") @GetMapping(value = AppConstants.APP_SYSTEM + "/user/getUser/{userId}", headers = SecurityConstants.HEADER_FROM_IN)
R<User> selectByUserId(@PathVariable("userId") String userid, @RequestHeader(SecurityConstants.FROM) String from); R<User> selectByUserId(@PathVariable("userId") String userid);
} }

2
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskController.java

@ -87,7 +87,7 @@ public class MapTaskController {
mapTask.setBatchCode(batchCode); mapTask.setBatchCode(batchCode);
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
R<User> user = remoteUserService.selectByUserId(mapTask.getCourierUserId(), SecurityConstants.FROM_IN); R<User> user = remoteUserService.selectByUserId(mapTask.getCourierUserId());
Hospital hospital = hospitalService.getById(mapTask.getHospitalId()); Hospital hospital = hospitalService.getById(mapTask.getHospitalId());
jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount());
if (StrUtil.isNotBlank(mapTask.getOrgId())) { if (StrUtil.isNotBlank(mapTask.getOrgId())) {

2
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapTaskPresetController.java

@ -83,7 +83,7 @@ public class MapTaskPresetController {
String batchCode = UUID.fromString(UUID.randomUUID().toString()).toString(); String batchCode = UUID.fromString(UUID.randomUUID().toString()).toString();
mapTaskPreset.setBatchCode(batchCode); mapTaskPreset.setBatchCode(batchCode);
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
R<User> user = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId(), SecurityConstants.FROM_IN); R<User> user = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId());
if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) { if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) {
Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId()); Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId());
jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount());

2
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/OrgController.java

@ -59,7 +59,7 @@ public class OrgController {
Org org = orgService.getById(id); Org org = orgService.getById(id);
resultVo.setResult(org); resultVo.setResult(org);
// 查询省市级联名称数据 // 查询省市级联名称数据
R<List<Region>> result = remoteRegionService.selectByRegionIds(StrUtil.splitToArray(org.getRegionIds(),","), SecurityConstants.FROM_IN); R<List<Region>> result = remoteRegionService.selectByRegionIds(StrUtil.splitToArray(org.getRegionIds(),","));
resultVo.setExtend(result.getData().stream().map(item -> item.getName()).collect(Collectors.toList())); resultVo.setExtend(result.getData().stream().map(item -> item.getName()).collect(Collectors.toList()));
return R.ok(resultVo); return R.ok(resultVo);
} }

3
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushConcernFanController.java

@ -115,7 +115,6 @@ public class PushConcernFanController {
return R.ok(); return R.ok();
} }
@Inner
@ApiOperation("创建内部新用户强制关联内部企业") @ApiOperation("创建内部新用户强制关联内部企业")
@PostMapping("/bindConcernEnterpriseUser") @PostMapping("/bindConcernEnterpriseUser")
public R bindConcernEnterpriseUser(String userId, @Valid @RequestBody List<User> enterpriseUserList) { public R bindConcernEnterpriseUser(String userId, @Valid @RequestBody List<User> enterpriseUserList) {
@ -149,7 +148,6 @@ public class PushConcernFanController {
return R.ok(); return R.ok();
} }
@Inner
@ApiOperation("内部企业用户粉丝保存") @ApiOperation("内部企业用户粉丝保存")
@PostMapping("/enterpriseUserFanSave") @PostMapping("/enterpriseUserFanSave")
public R enterpriseUserFanSave(String innerEnterpriseUserId, @Valid @RequestBody List<User> userList) { public R enterpriseUserFanSave(String innerEnterpriseUserId, @Valid @RequestBody List<User> userList) {
@ -216,7 +214,6 @@ public class PushConcernFanController {
return R.ok(); return R.ok();
} }
@Inner
@ApiOperation("移除用户推送相关数据") @ApiOperation("移除用户推送相关数据")
@DeleteMapping("/removeUserPushData") @DeleteMapping("/removeUserPushData")
public R<Boolean> removeUserPushData(@RequestParam Set<String> userIds) { public R<Boolean> removeUserPushData(@RequestParam Set<String> userIds) {

4
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticServiceImpl.java

@ -117,7 +117,7 @@ public class MapLogisticServiceImpl extends ServiceImpl<MapLogisticMapper, MapLo
mapLogistic.getMapTask().forEach(mapTask -> { mapLogistic.getMapTask().forEach(mapTask -> {
if (mapTask.getEnabledCreateReport()) { if (mapTask.getEnabledCreateReport()) {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
R<User> user = remoteUserService.selectByUserId(mapTask.getCourierUserId(), SecurityConstants.FROM_IN); R<User> user = remoteUserService.selectByUserId(mapTask.getCourierUserId());
Hospital hospital = hospitalService.getById(mapTask.getHospitalId()); Hospital hospital = hospitalService.getById(mapTask.getHospitalId());
jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount());
if (StrUtil.isNotBlank(mapTask.getOrgId())) { if (StrUtil.isNotBlank(mapTask.getOrgId())) {
@ -140,7 +140,7 @@ public class MapLogisticServiceImpl extends ServiceImpl<MapLogisticMapper, MapLo
mapTask.getMapTaskPreset().forEach(mapTaskPreset -> { mapTask.getMapTaskPreset().forEach(mapTaskPreset -> {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
if (mapTaskPreset.getEnabledCreateReport()) { if (mapTaskPreset.getEnabledCreateReport()) {
R<User> taskPresetUser = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId(), SecurityConstants.FROM_IN); R<User> taskPresetUser = remoteUserService.selectByUserId(mapTaskPreset.getCourierUserId());
if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) { if (StrUtil.isNotBlank(mapTaskPreset.getOrginPresetId())) {
Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId()); Hospital hospital = hospitalService.getById(mapTaskPreset.getOrginPresetId());
jsonObject.put("hospitalId", hospital.getKlabHospitalAccount()); jsonObject.put("hospitalId", hospital.getKlabHospitalAccount());

2
kicc-platform/kicc-platform-biz/kicc-system-biz/src/main/java/com/cloud/kicc/system/controller/DictDataController.java

@ -66,7 +66,7 @@ public class DictDataController {
@GetMapping("/dictType/{dictType}") @GetMapping("/dictType/{dictType}")
public R dictType(@PathVariable String dictType) { public R dictType(@PathVariable String dictType) {
return remoteDictService.getDictByType(dictType, SecurityConstants.FROM_IN); return remoteDictService.getDictByType(dictType);
} }
@SysLog("字典数据新增") @SysLog("字典数据新增")

Loading…
Cancel
Save