Commit f602cc19 authored by tianbo's avatar tianbo

Merge branch 'develop_tzs_register' of…

Merge branch 'develop_tzs_register' of http://36.40.66.175:5000/moa/amos-boot-biz into develop_tzs_register
parents 5d7903be 176817df
...@@ -29,5 +29,5 @@ public interface TzsUserInfoMapper extends BaseMapper<TzsUserInfo> { ...@@ -29,5 +29,5 @@ public interface TzsUserInfoMapper extends BaseMapper<TzsUserInfo> {
List<String> selectUserIds(); List<String> selectUserIds();
List<GroupAndPersonInfoDto> getUnitInfoByUserIds(@Param("userIds")List<String> userIds); List<GroupAndPersonInfoDto> getUnitInfoByUserId(Long groupId);
} }
...@@ -8,12 +8,15 @@ import com.yeejoin.amos.component.feign.model.FeignClientResult; ...@@ -8,12 +8,15 @@ import com.yeejoin.amos.component.feign.model.FeignClientResult;
import com.yeejoin.amos.feign.privilege.model.AgencyUserModel; import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
import com.yeejoin.amos.feign.privilege.model.CompanyModel;
import com.yeejoin.amos.feign.privilege.model.VerifyCodeAuthModel; import com.yeejoin.amos.feign.privilege.model.VerifyCodeAuthModel;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.typroject.tyboot.core.restful.utils.ResponseModel; import org.typroject.tyboot.core.restful.utils.ResponseModel;
import java.util.Collection;
@FeignClient(value = "AMOS-API-PRIVILEGE", configuration = {FeignConfiguration.class}) @FeignClient(value = "AMOS-API-PRIVILEGE", configuration = {FeignConfiguration.class})
public interface PrivilegeFeginService { public interface PrivilegeFeginService {
...@@ -24,6 +27,9 @@ public interface PrivilegeFeginService { ...@@ -24,6 +27,9 @@ public interface PrivilegeFeginService {
@RequestMapping(value = "/privilege/v1/company/tree", method = RequestMethod.GET) @RequestMapping(value = "/privilege/v1/company/tree", method = RequestMethod.GET)
FeignClientResult tree(@RequestHeader("token") String token, @RequestHeader("appKey") String appKey, @RequestHeader("product") String product); FeignClientResult tree(@RequestHeader("token") String token, @RequestHeader("appKey") String appKey, @RequestHeader("product") String product);
@RequestMapping(value = {"/privilege/v1/company/tree/cache"}, method = {RequestMethod.GET})
FeignClientResult queryAgencyTreeForCache(@RequestHeader("token") String token, @RequestHeader("appKey") String appKey, @RequestHeader("product") String product) throws InnerInvokException;
//获取省级行政区划 //获取省级行政区划
@RequestMapping(value = "systemctl/v1/region/level", method = RequestMethod.GET) @RequestMapping(value = "systemctl/v1/region/level", method = RequestMethod.GET)
FeignClientResult getProvince(@RequestParam String level); FeignClientResult getProvince(@RequestParam String level);
......
...@@ -180,26 +180,24 @@ ...@@ -180,26 +180,24 @@
GROUP BY tui.amos_user_id GROUP BY tui.amos_user_id
</select> </select>
<select id="getUnitInfoByUserIds" resultType="com.yeejoin.amos.boot.module.tcm.api.dto.GroupAndPersonInfoDto"> <select id="getUnitInfoByUserId" resultType="com.yeejoin.amos.boot.module.tcm.api.dto.GroupAndPersonInfoDto">
SELECT SELECT
${groupId} groupId,
tui.amos_user_id userId, tui.amos_user_id userId,
tui.amos_user_name userName, tui.amos_user_name userName,
tui.unit_name, tui.unit_name,
tui.unit_code, tui.unit_code,
replace(tzei.unit_type,'#', ',') unitType, REPLACE ( tzei.unit_type, '#', ',' ) unitType,
tzei.equip_category tzei.equip_category,
pc.org_code
FROM FROM
tzs_user_info tui tzs_user_info tui
LEFT JOIN tz_base_enterprise_info tzei ON tui.unit_code = tzei.use_code LEFT JOIN tz_base_enterprise_info tzei ON tui.unit_code = tzei.use_code
<where> LEFT JOIN privilege_company pc ON tui.unit_code = pc.company_code
tzei.equip_category is not null WHERE
and tzei.is_delete = '0' tzei.equip_category IS NOT NULL
<if test="userIds != null and userIds.size() > 0"> AND tzei.is_delete = '0'
and amos_user_id in AND tzei.unit_type <![CDATA[<>]]> '检验检测机构'
<foreach item="item" collection="userIds" separator="," open="(" close=")" index=""> AND tui.amos_user_id IN (SELECT USER_ID FROM privilege_group_user WHERE GROUP_SEQ = #{groupId})
#{item}
</foreach>
</if>
</where>
</select> </select>
</mapper> </mapper>
\ No newline at end of file
...@@ -23,6 +23,7 @@ import com.yeejoin.amos.boot.module.tcm.biz.utils.JsonUtils; ...@@ -23,6 +23,7 @@ import com.yeejoin.amos.boot.module.tcm.biz.utils.JsonUtils;
import com.yeejoin.amos.boot.module.tcm.flc.api.feign.IdxFeignService; import com.yeejoin.amos.boot.module.tcm.flc.api.feign.IdxFeignService;
import com.yeejoin.amos.boot.module.tcm.flc.api.feign.PrivilegeFeginService; import com.yeejoin.amos.boot.module.tcm.flc.api.feign.PrivilegeFeginService;
import com.yeejoin.amos.component.feign.model.FeignClientResult; import com.yeejoin.amos.component.feign.model.FeignClientResult;
import com.yeejoin.amos.feign.privilege.Privilege;
import com.yeejoin.amos.feign.privilege.model.CompanyModel; import com.yeejoin.amos.feign.privilege.model.CompanyModel;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchRequest;
...@@ -290,7 +291,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD ...@@ -290,7 +291,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
@Override @Override
public List<LinkedHashMap> creatTree() { public List<LinkedHashMap> creatTree() {
FeignClientResult tree = privilegeFeginService.tree(RequestContext.getToken(), RequestContext.getAppKey(), RequestContext.getProduct()); FeignClientResult tree = privilegeFeginService.queryAgencyTreeForCache(RequestContext.getToken(), RequestContext.getAppKey(), RequestContext.getProduct());
List<LinkedHashMap> result = (List<LinkedHashMap>) tree.getResult(); List<LinkedHashMap> result = (List<LinkedHashMap>) tree.getResult();
List<LinkedHashMap> treeData = deleteRegulatorTreeData(result); List<LinkedHashMap> treeData = deleteRegulatorTreeData(result);
List<LinkedHashMap> supervisionTree = treeData.stream().filter(e -> code.equals(e.get("orgCode"))).collect(Collectors.toList()); List<LinkedHashMap> supervisionTree = treeData.stream().filter(e -> code.equals(e.get("orgCode"))).collect(Collectors.toList());
......
...@@ -457,28 +457,12 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI ...@@ -457,28 +457,12 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI
@Override @Override
public List<GroupAndPersonInfoDto> getGroupAndPersonInfo(Long groupId) { public List<GroupAndPersonInfoDto> getGroupAndPersonInfo(Long groupId) {
RequestContext.setProduct(amosRequestContext.getProduct());
RequestContext.setAppKey(amosRequestContext.getAppKey());
RequestContext.setToken(amosRequestContext.getToken());
List<GroupAndPersonInfoDto> result = new ArrayList<>(); List<GroupAndPersonInfoDto> result = new ArrayList<>();
List<AgencyUserModel> agencyUserModelList = Privilege.groupUserClient.queryForList(groupId).getResult(); List<GroupAndPersonInfoDto> groupAndPersonInfoDtoList = tzsUserInfoMapper.getUnitInfoByUserId(groupId);
List<CompanyModel> companyModelList = Privilege.companyClient.queryForCompanyList(null, "company").getResult();
HashMap<String,Object> companyMap = new HashMap<>();
for (CompanyModel companyModel : companyModelList) {
companyMap.put(companyModel.getCompanyCode(), companyModel.getOrgCode());
}
StopWatch stopWatch = new StopWatch();
stopWatch.start();
List<String> UserIds = agencyUserModelList.stream().map(AgencyUserModel::getUserId).collect(Collectors.toList());
List<GroupAndPersonInfoDto> groupAndPersonInfoDtoList = tzsUserInfoMapper.getUnitInfoByUserIds(UserIds);
DataDictionary dataDictionary = iDataDictionaryService.getByExtend(groupId.toString(), QYRYGW); DataDictionary dataDictionary = iDataDictionaryService.getByExtend(groupId.toString(), QYRYGW);
for (GroupAndPersonInfoDto groupAndPersonInfoDto : groupAndPersonInfoDtoList) { for (GroupAndPersonInfoDto groupAndPersonInfoDto : groupAndPersonInfoDtoList) {
if (!ObjectUtils.isEmpty(groupAndPersonInfoDto)) { if (!ObjectUtils.isEmpty(groupAndPersonInfoDto)) {
groupAndPersonInfoDto.setGroupId(groupId);
groupAndPersonInfoDto.setGroupName(ObjectUtils.isEmpty(dataDictionary) ? null : dataDictionary.getName()); groupAndPersonInfoDto.setGroupName(ObjectUtils.isEmpty(dataDictionary) ? null : dataDictionary.getName());
String unitOrgCode = String.valueOf(companyMap.get(groupAndPersonInfoDto.getUnitCode()));
groupAndPersonInfoDto.setUnitOrgCode("null".equals(unitOrgCode)? null: unitOrgCode);
String[] UnitType = groupAndPersonInfoDto.getUnitType().split(","); String[] UnitType = groupAndPersonInfoDto.getUnitType().split(",");
if (UnitType.length > 0) { if (UnitType.length > 0) {
StringBuilder unitTypeCode = new StringBuilder(); StringBuilder unitTypeCode = new StringBuilder();
...@@ -516,8 +500,6 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI ...@@ -516,8 +500,6 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI
result.add(groupAndPersonInfoDto); result.add(groupAndPersonInfoDto);
} }
} }
stopWatch.stop();
System.out.printf("组装数据耗时%f秒/n", stopWatch.getTotalTimeSeconds());
return result; return result;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment