Skip to content

A
amos-boot-zx-biz
Commit a13e95b9 authored by wujiang's avatar wujiang
Browse files
Options

修改安全上传

parent b73bc0b7
Hide whitespace changes
Inline Side-by-side
Showing with 656 additions and 637 deletions
amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/UnitInfoController.java
View file @ a13e95b9
...@@ -48,6 +48,8 @@ import org.typroject.tyboot.core.restful.utils.ResponseModel; ...@@ -48,6 +48,8 @@ import org.typroject.tyboot.core.restful.utils.ResponseModel;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.io.File; import java.io.File;
import java.util.*; import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/** /**
* 经销商人员信息 * 经销商人员信息
...@@ -60,8 +62,8 @@ import java.util.*; ...@@ -60,8 +62,8 @@ import java.util.*;
@RequestMapping(value = "/unit-info") @RequestMapping(value = "/unit-info")
public class UnitInfoController extends BaseController { public class UnitInfoController extends BaseController {
@Autowired @Autowired
UnitInfoServiceImpl unitInfoServiceImpl; UnitInfoServiceImpl unitInfoServiceImpl;
@Autowired @Autowired
AmosRequestContext requestContext; AmosRequestContext requestContext;
...@@ -72,138 +74,142 @@ public class UnitInfoController extends BaseController { ...@@ -72,138 +74,142 @@ public class UnitInfoController extends BaseController {
@Value("${hygf.sms.tempCode}") @Value("${hygf.sms.tempCode}")
private String smsTempCode; private String smsTempCode;
@Value("${regionalCompanies.company.seq}") @Value("${regionalCompanies.company.seq}")
private Long regionalCompanies; private Long regionalCompanies;
@Value("${dealer.group}") @Value("${dealer.group}")
private Long group; private Long group;
@Autowired @Autowired
RegionalCompaniesMapper regionalCompaniesMapper; RegionalCompaniesMapper regionalCompaniesMapper;
@Autowired @Autowired
SendSmsCode sendSmsCode; SendSmsCode sendSmsCode;
public static final String HYGF_USER_TEL = "hygf_tel_"; public static final String HYGF_USER_TEL = "hygf_tel_";
@Autowired @Autowired
DealerReviewServiceImpl dealerReviewServiceImpl; DealerReviewServiceImpl dealerReviewServiceImpl;
@Autowired @Autowired
CommerceInfoMapper commerceInfoMapper; CommerceInfoMapper commerceInfoMapper;
@Autowired @Autowired
UnitInfoMapper unitInfoMapper; UnitInfoMapper unitInfoMapper;
@Autowired @Autowired
PublicAgencyUserMapper publicAgencyUserMapper; PublicAgencyUserMapper publicAgencyUserMapper;
@Autowired @Autowired
PersonnelBusinessMapper personnelBusinessMapper; PersonnelBusinessMapper personnelBusinessMapper;
@Autowired @Autowired
PeasantHouseholdMapper peasantHouseholdMapper; PeasantHouseholdMapper peasantHouseholdMapper;
/** /**
* 验证码过期时间 * 验证码过期时间
*/ */
private long time = 180L; private long time = 60L;
// 常见的手机号正则表达式（以中国大陆手机号为例）
private static final String PHONE_NUMBER_REGEX = "^1[3-9]\\d{9}$";
/** /**
* 根据sequenceNbr更新 * 根据sequenceNbr更新
* *
* @param sequenceNbr 主键 * @param sequenceNbr 主键
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}") @PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新经销商人员信息", notes = "根据sequenceNbr更新经销商人员信息") @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新经销商人员信息", notes = "根据sequenceNbr更新经销商人员信息")
public ResponseModel<UnitInfoDto> updateBySequenceNbrUnitInfo(@RequestBody UnitInfoDto model,@ApiParam(value = "主键", example = "1706869110685569025")@PathVariable(value = "sequenceNbr") Long sequenceNbr) { public ResponseModel<UnitInfoDto> updateBySequenceNbrUnitInfo(@RequestBody UnitInfoDto model,
model.setSequenceNbr(sequenceNbr); @ApiParam(value = "主键", example = "1706869110685569025") @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateWithModel(model)); model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateWithModel(model));
} }
/** /**
* 根据sequenceNbr删除 * 根据sequenceNbr删除
* *
* @param sequenceNbr 主键 * @param sequenceNbr 主键
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除经销商人员信息", notes = "根据sequenceNbr删除经销商人员信息")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request,@ApiParam(value = "主键", example = "1706869110685569025") @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(unitInfoServiceImpl.removeById(sequenceNbr));
}
/**
* 根据sequenceNbr查询
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个经销商人员信息", notes = "根据sequenceNbr查询单个经销商人员信息") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除经销商人员信息", notes = "根据sequenceNbr删除经销商人员信息")
public ResponseModel<UnitInfoDto> selectOne(@ApiParam(value = "主键", example = "1706869110685569025")@PathVariable Long sequenceNbr) { public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request,
return ResponseHelper.buildResponse(unitInfoServiceImpl.queryBySeq(sequenceNbr)); @ApiParam(value = "主键", example = "1706869110685569025") @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.removeById(sequenceNbr));
} }
/**
* 根据sequenceNbr查询
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个经销商人员信息", notes = "根据sequenceNbr查询单个经销商人员信息")
public ResponseModel<UnitInfoDto> selectOne(
@ApiParam(value = "主键", example = "1706869110685569025") @PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.queryBySeq(sequenceNbr));
}
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getOne/{sequenceNbr}") @GetMapping(value = "/getOne/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个经销商人员信息", notes = "根据sequenceNbr查询单个经销商人员信息") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个经销商人员信息", notes = "根据sequenceNbr查询单个经销商人员信息")
public ResponseModel<UnitInfoData> getOne(@ApiParam(value = "主键", example = "1706869110685569025")@PathVariable String sequenceNbr) { public ResponseModel<UnitInfoData> getOne(
@ApiParam(value = "主键", example = "1706869110685569025") @PathVariable String sequenceNbr) {
UnitInfo unitInfo= unitInfoServiceImpl.getById(sequenceNbr);
unitInfo.setHeadCardPhotoBackList(toCommonFile(unitInfo.getHeadCardPhotoBack())); UnitInfo unitInfo = unitInfoServiceImpl.getById(sequenceNbr);
unitInfo.setHeadCardPhotoFrontList(toCommonFile(unitInfo.getHeadCardPhotoFront())); unitInfo.setHeadCardPhotoBackList(toCommonFile(unitInfo.getHeadCardPhotoBack()));
CommerceInfo commerceInfo= commerceInfoMapper.selectOne(new QueryWrapper<CommerceInfo>().eq("unit_seq", sequenceNbr)); unitInfo.setHeadCardPhotoFrontList(toCommonFile(unitInfo.getHeadCardPhotoFront()));
commerceInfo.setLegalPersonCardPhotoBackList(toCommonFile(commerceInfo.getLegalPersonCardPhotoBack())); CommerceInfo commerceInfo = commerceInfoMapper
commerceInfo.setBusinessLicensePhotoList(toCommonFile(commerceInfo.getBusinessLicensePhoto())); .selectOne(new QueryWrapper<CommerceInfo>().eq("unit_seq", sequenceNbr));
commerceInfo.setLegalPersonCardPhotoFrontList(toCommonFile(commerceInfo.getLegalPersonCardPhotoFront())); commerceInfo.setLegalPersonCardPhotoBackList(toCommonFile(commerceInfo.getLegalPersonCardPhotoBack()));
UnitInfoData unitInfoData=new UnitInfoData(unitInfo, unitInfo, commerceInfo); commerceInfo.setBusinessLicensePhotoList(toCommonFile(commerceInfo.getBusinessLicensePhoto()));
return ResponseHelper.buildResponse(unitInfoData); commerceInfo.setLegalPersonCardPhotoFrontList(toCommonFile(commerceInfo.getLegalPersonCardPhotoFront()));
} UnitInfoData unitInfoData = new UnitInfoData(unitInfo, unitInfo, commerceInfo);
return ResponseHelper.buildResponse(unitInfoData);
}
/** /**
* 列表分页查询 * 列表分页查询
* *
* @param current 当前页 * @param current 当前页
* @param current 每页大小 * @param current 每页大小
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page") @GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "经销商人员信息分页查询", notes = "经销商人员信息分页查询") @ApiOperation(httpMethod = "GET", value = "经销商人员信息分页查询", notes = "经销商人员信息分页查询")
public ResponseModel<Page<UnitInfoDto>> queryForPage(@ApiParam(value = "页码", example = "1")@RequestParam(value = "current") int current,@ApiParam(value = "页数大小", example = "20")@RequestParam public ResponseModel<Page<UnitInfoDto>> queryForPage(
(value = "size") int size) { @ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
Page<UnitInfoDto> page = new Page<UnitInfoDto>(); @ApiParam(value = "页数大小", example = "20") @RequestParam(value = "size") int size) {
page.setCurrent(current); Page<UnitInfoDto> page = new Page<UnitInfoDto>();
page.setSize(size); page.setCurrent(current);
return ResponseHelper.buildResponse(unitInfoServiceImpl.queryForUnitInfoPage(page)); page.setSize(size);
return ResponseHelper.buildResponse(unitInfoServiceImpl.queryForUnitInfoPage(page));
} }
@TycloudOperation(ApiLevel = UserType.AGENCY)
@TycloudOperation(ApiLevel = UserType.AGENCY) @GetMapping(value = "/queryForDealerReviewPage")
@GetMapping(value = "/queryForDealerReviewPage") @ApiOperation(httpMethod = "GET", value = "经销商人员信息分页查询", notes = "经销商人员信息分页查询")
@ApiOperation(httpMethod = "GET",value = "经销商人员信息分页查询", notes = "经销商人员信息分页查询") public ResponseModel<Page<ReviewDto>> queryForDealerReviewPage(
public ResponseModel<Page<ReviewDto>> queryForDealerReviewPage(@ApiParam(value = "页码", example = "1")@RequestParam(value = "current") int current, @ApiParam(value = "页数大小", example = "20")@RequestParam @ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
(value = "size") int size, ReviewDto reviewDto) { @ApiParam(value = "页数大小", example = "20") @RequestParam(value = "size") int size, ReviewDto reviewDto) {
Page<ReviewDto> page=dealerReviewServiceImpl.queryForDealerReviewPage(current,size,reviewDto); Page<ReviewDto> page = dealerReviewServiceImpl.queryForDealerReviewPage(current, size, reviewDto);
return ResponseHelper.buildResponse(page); return ResponseHelper.buildResponse(page);
} }
/** /**
* 列表全部数据查询 * 列表全部数据查询
* *
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "经销商人员信息列表全部数据查询", notes = "经销商人员信息列表全部数据查询") @ApiOperation(httpMethod = "GET", value = "经销商人员信息列表全部数据查询", notes = "经销商人员信息列表全部数据查询")
@GetMapping(value = "/list") @GetMapping(value = "/list")
public ResponseModel<List<UnitInfoDto>> selectForList() { public ResponseModel<List<UnitInfoDto>> selectForList() {
return ResponseHelper.buildResponse(unitInfoServiceImpl.queryForUnitInfoList()); return ResponseHelper.buildResponse(unitInfoServiceImpl.queryForUnitInfoList());
} }
/** /**
* 管理员身份证图片上传 无token * 管理员身份证图片上传 无token
* *
...@@ -212,20 +218,25 @@ public class UnitInfoController extends BaseController { ...@@ -212,20 +218,25 @@ public class UnitInfoController extends BaseController {
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@PostMapping(value = "/uploadFile") @PostMapping(value = "/uploadFile")
@ApiOperation(httpMethod = "POST", value = "管理员身份证图片上传 无token", notes = "管理员身份证图片上传 无token") @ApiOperation(httpMethod = "POST", value = "管理员身份证图片上传 无token", notes = "管理员身份证图片上传 无token")
public ResponseModel<String> uploadFile(@ApiParam(value = "文件", required = true)@RequestParam MultipartFile file) { public ResponseModel<String> uploadFile(@ApiParam(value = "文件", required = true) @RequestParam MultipartFile file) {
if (ValidationUtil.isEmpty(file)){ if (ValidationUtil.isEmpty(file)) {
throw new BadRequest("参数校验失败."); throw new BadRequest("参数校验失败.");
} }
/// List<String> NOT_ALLOWED_TYPES =Arrays.asList("text/html");
// 只支持图片类型
if (file.getContentType() == null || !file.getContentType().startsWith("image/")) {
throw new BadRequest("只支持图片类型上传");
}
RequestContext.setAppKey("AMOS_STUDIO"); RequestContext.setAppKey("AMOS_STUDIO");
RequestContext.setProduct("AMOS_STUDIO_WEB"); RequestContext.setProduct("AMOS_STUDIO_WEB");
RequestContext.setToken(requestContext.getToken()); RequestContext.setToken(requestContext.getToken());
FeignClientResult<Map<String, String>> date = Systemctl.fileStorageClient.updateCommonFile(file); FeignClientResult<Map<String, String>> date = Systemctl.fileStorageClient.updateCommonFile(file);
String urlString=""; String urlString = "";
if (date != null) { if (date != null) {
Map<String, String> map = date.getResult(); Map<String, String> map = date.getResult();
Iterator<String> it = map.keySet().iterator(); Iterator<String> it = map.keySet().iterator();
while (it.hasNext()) { while (it.hasNext()) {
urlString=it.next(); urlString = it.next();
} }
} }
return ResponseHelper.buildResponse(urlString); return ResponseHelper.buildResponse(urlString);
...@@ -233,6 +244,7 @@ public class UnitInfoController extends BaseController { ...@@ -233,6 +244,7 @@ public class UnitInfoController extends BaseController {
/** /**
* 获取组织机构树 * 获取组织机构树
*
* @return * @return
*/ */
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
...@@ -242,68 +254,69 @@ public class UnitInfoController extends BaseController { ...@@ -242,68 +254,69 @@ public class UnitInfoController extends BaseController {
RequestContext.setAppKey("AMOS_STUDIO"); RequestContext.setAppKey("AMOS_STUDIO");
RequestContext.setProduct("AMOS_STUDIO_WEB"); RequestContext.setProduct("AMOS_STUDIO_WEB");
RequestContext.setToken(requestContext.getToken()); RequestContext.setToken(requestContext.getToken());
return ResponseHelper.buildResponse(Systemctl.regionClient.queryForTree(null).getResult()); return ResponseHelper.buildResponse(Systemctl.regionClient.queryForTree(null).getResult());
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping(value = "/management-unit/tree") @GetMapping(value = "/management-unit/tree")
@ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树") @ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树")
public ResponseModel<Collection<CompanyModel>> managementUnitTree(@ApiParam(value = "区域Code", example = "86*355*443*479")@RequestParam(required = false)String orgCode) { public ResponseModel<Collection<CompanyModel>> managementUnitTree(
@ApiParam(value = "区域Code", example = "86*355*443*479") @RequestParam(required = false) String orgCode) {
RequestContext.setAppKey("AMOS_STUDIO"); RequestContext.setAppKey("AMOS_STUDIO");
RequestContext.setProduct("AMOS_STUDIO_WEB"); RequestContext.setProduct("AMOS_STUDIO_WEB");
RequestContext.setToken(requestContext.getToken()); RequestContext.setToken(requestContext.getToken());
FeignClientResult<Collection<CompanyModel>> feignClientResult= Privilege.companyClient.querySubAgencyTree(regionalCompanies); FeignClientResult<Collection<CompanyModel>> feignClientResult = Privilege.companyClient
.querySubAgencyTree(regionalCompanies);
Collection<CompanyModel> companyModel = (List<CompanyModel>)feignClientResult.getResult(); Collection<CompanyModel> companyModel = (List<CompanyModel>) feignClientResult.getResult();
return ResponseHelper.buildResponse(companyModel); return ResponseHelper.buildResponse(companyModel);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@PostMapping(value = "/unitRegister") @PostMapping(value = "/unitRegister")
@ApiOperation(httpMethod = "POST", value = "单位注册", notes = "单位注册") @ApiOperation(httpMethod = "POST", value = "单位注册", notes = "单位注册")
@Transactional @Transactional
public ResponseModel<UnitRegisterDto> save(@RequestBody UnitRegisterDto model) { public ResponseModel<UnitRegisterDto> save(@RequestBody UnitRegisterDto model) {
try { try {
//判断公司名称重复， // 判断公司名称重复，
LambdaQueryWrapper<UnitInfo> qudg=new LambdaQueryWrapper<>(); LambdaQueryWrapper<UnitInfo> qudg = new LambdaQueryWrapper<>();
qudg.eq(UnitInfo::getName,model.getUnitInfoDto().getName()); qudg.eq(UnitInfo::getName, model.getUnitInfoDto().getName());
qudg.eq(UnitInfo::getIsDelete,0); qudg.eq(UnitInfo::getIsDelete, 0);
qudg.ne(UnitInfo::getAuditStatus,3); qudg.ne(UnitInfo::getAuditStatus, 3);
List<UnitInfo> unitInfo= unitInfoMapper.selectList(qudg); List<UnitInfo> unitInfo = unitInfoMapper.selectList(qudg);
if(unitInfo!=null&&!unitInfo.isEmpty()){ if (unitInfo != null && !unitInfo.isEmpty()) {
throw new BadRequest("公司名称重复");
}
//判断公司统一信息用代码重复 throw new BadRequest("公司名称重复");
List<CommerceInfo> commerceInfo= commerceInfoMapper.selectListby( model.getCommerceInfoDto().getCreditCode()); }
if(commerceInfo!=null&&!commerceInfo.isEmpty()){
throw new BadRequest("统一信用代码重复");
}
//用户名重复 // 判断公司统一信息用代码重复
LambdaQueryWrapper<UnitInfo> qudg1=new LambdaQueryWrapper<>(); List<CommerceInfo> commerceInfo = commerceInfoMapper
qudg1.eq(UnitInfo::getAdminLoginName,model.getUnitInfoDto().getAdminLoginName()); .selectListby(model.getCommerceInfoDto().getCreditCode());
qudg1.eq(UnitInfo::getIsDelete,0); if (commerceInfo != null && !commerceInfo.isEmpty()) {
qudg1.ne(UnitInfo::getAuditStatus,3);
List<UnitInfo> unitInfo1= unitInfoMapper.selectList(qudg1);
if(unitInfo1!=null&&!unitInfo1.isEmpty()){
throw new BadRequest("管理员账户名重复,请更换"); throw new BadRequest("统一信用代码重复");
} }
LambdaQueryWrapper<PublicAgencyUser> qud2=new LambdaQueryWrapper<>(); // 用户名重复
qud2.eq(PublicAgencyUser::getAmosUserName,model.getUnitInfoDto().getAdminLoginName()); LambdaQueryWrapper<UnitInfo> qudg1 = new LambdaQueryWrapper<>();
List<PublicAgencyUser> publicAgencyUse= publicAgencyUserMapper.selectList(qud2); qudg1.eq(UnitInfo::getAdminLoginName, model.getUnitInfoDto().getAdminLoginName());
if(publicAgencyUse!=null&&!publicAgencyUse.isEmpty()){ qudg1.eq(UnitInfo::getIsDelete, 0);
qudg1.ne(UnitInfo::getAuditStatus, 3);
List<UnitInfo> unitInfo1 = unitInfoMapper.selectList(qudg1);
if (unitInfo1 != null && !unitInfo1.isEmpty()) {
throw new BadRequest("管理员账户名重复,请更换"); throw new BadRequest("管理员账户名重复,请更换");
} }
LambdaQueryWrapper<PublicAgencyUser> qud2 = new LambdaQueryWrapper<>();
qud2.eq(PublicAgencyUser::getAmosUserName, model.getUnitInfoDto().getAdminLoginName());
List<PublicAgencyUser> publicAgencyUse = publicAgencyUserMapper.selectList(qud2);
if (publicAgencyUse != null && !publicAgencyUse.isEmpty()) {
throw new BadRequest("管理员账户名重复,请更换");
}
RequestContext.setAppKey("AMOS_STUDIO"); RequestContext.setAppKey("AMOS_STUDIO");
RequestContext.setProduct("AMOS_STUDIO_WEB"); RequestContext.setProduct("AMOS_STUDIO_WEB");
...@@ -312,7 +325,8 @@ public class UnitInfoController extends BaseController { ...@@ -312,7 +325,8 @@ public class UnitInfoController extends BaseController {
return ResponseHelper.buildResponse(model); return ResponseHelper.buildResponse(model);
} catch (Exception e) { } catch (Exception e) {
ResponseModel<UnitRegisterDto> response = new ResponseModel<>(); ResponseModel<UnitRegisterDto> response = new ResponseModel<>();
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
.getRequest();
response.setResult(null); response.setResult(null);
response.setDevMessage(e.getMessage()); response.setDevMessage(e.getMessage());
response.setStatus(HttpStatus.INTERNAL_SERVER_ERROR.value()); response.setStatus(HttpStatus.INTERNAL_SERVER_ERROR.value());
...@@ -323,34 +337,31 @@ public class UnitInfoController extends BaseController { ...@@ -323,34 +337,31 @@ public class UnitInfoController extends BaseController {
} }
public List<CommonFile> toCommonFile(String url){ public List<CommonFile> toCommonFile(String url) {
List<CommonFile> list=new ArrayList<>();
CommonFile commonFile=new CommonFile(url, url.substring(url.lastIndexOf(File.separator)+1), UUID.randomUUID().toString(), "done");
list.add(commonFile);
return list;
}
/**
* 判断用户名是否存在
*
* @return
*/
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/hasExistUserName/{userName}")
@ApiOperation(httpMethod = "GET", value = "判断用户名是否存在", notes = "判断用户名是否存在")
public ResponseModel hasExistUserName( @ApiParam(value = "用户名", example = "admin")@PathVariable(value = "userName") String userName) {
try {
return CommonResponseNewUtil.success(unitInfoServiceImpl.hasExistPhoneOrUserName(null, userName));
} catch (Exception e) {
return CommonResponseNewUtil.failure("该用户名已经注册");
}
}
List<CommonFile> list = new ArrayList<>();
CommonFile commonFile = new CommonFile(url, url.substring(url.lastIndexOf(File.separator) + 1),
UUID.randomUUID().toString(), "done");
list.add(commonFile);
return list;
}
/**
* 判断用户名是否存在
*
* @return
*/
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/hasExistUserName/{userName}")
@ApiOperation(httpMethod = "GET", value = "判断用户名是否存在", notes = "判断用户名是否存在")
public ResponseModel hasExistUserName(
@ApiParam(value = "用户名", example = "admin") @PathVariable(value = "userName") String userName) {
try {
return CommonResponseNewUtil.success(unitInfoServiceImpl.hasExistPhoneOrUserName(null, userName));
} catch (Exception e) {
return CommonResponseNewUtil.failure("该用户名已经注册");
}
}
/** /**
* 判断用户号码是否存在 * 判断用户号码是否存在
...@@ -360,7 +371,8 @@ public class UnitInfoController extends BaseController { ...@@ -360,7 +371,8 @@ public class UnitInfoController extends BaseController {
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/hasExistPhone/{phone}") @GetMapping(value = "/hasExistPhone/{phone}")
@ApiOperation(httpMethod = "GET", value = "判断用户号码是否存在", notes = "判断用户号码是否存在") @ApiOperation(httpMethod = "GET", value = "判断用户号码是否存在", notes = "判断用户号码是否存在")
public ResponseModel hasExistPhone(@ApiParam(value = "手机号", example = "15895233587") @PathVariable(value = "phone") String phone) { public ResponseModel hasExistPhone(
@ApiParam(value = "手机号", example = "15895233587") @PathVariable(value = "phone") String phone) {
try { try {
return CommonResponseNewUtil.success(unitInfoServiceImpl.hasExistPhoneOrUserName(phone, null)); return CommonResponseNewUtil.success(unitInfoServiceImpl.hasExistPhoneOrUserName(phone, null));
} catch (Exception e) { } catch (Exception e) {
...@@ -376,25 +388,34 @@ public class UnitInfoController extends BaseController { ...@@ -376,25 +388,34 @@ public class UnitInfoController extends BaseController {
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/sendTelCode/{tel}") @GetMapping(value = "/sendTelCode/{tel}")
@ApiOperation(httpMethod = "GET", value = "发送手机号验证码", notes = "发送手机号验证码") @ApiOperation(httpMethod = "GET", value = "发送手机号验证码", notes = "发送手机号验证码")
public ResponseModel<Boolean> sendTelCode(@ApiParam(value = "手机号", example = "15895233587")@PathVariable(value = "tel") String tel, public ResponseModel<Boolean> sendTelCode(
@ApiParam(value = "类型", example = "1") @RequestParam(value = "type", required = false) String type) { @ApiParam(value = "手机号", example = "15895233587") @PathVariable(value = "tel") String tel,
@ApiParam(value = "类型", example = "1") @RequestParam(value = "type", required = false) String type) {
if (ValidationUtil.isEmpty(tel)) { if (ValidationUtil.isEmpty(tel)) {
throw new BadRequest("参数校验失败."); throw new BadRequest("参数校验失败");
}
Pattern pattern = Pattern.compile(PHONE_NUMBER_REGEX);
Matcher matcher = pattern.matcher(tel);
if (!matcher.matches()) {
throw new BadRequest("请输入单个正确手机号");
}
String key = HYGF_USER_TEL + tel;
if (redisUtil.get(key) != null) {
throw new BadRequest("请稍后再试");
} }
Boolean flag = true; Boolean flag = true;
HashMap<String, String> params = new HashMap<>(3); HashMap<String, String> params = new HashMap<>(3);
String code = this.getRandomCode(); String code = this.getRandomCode();
params.put("code",code); params.put("code", code);
params.put("mobile",tel); params.put("mobile", tel);
params.put("smsCode", smsTempCode); params.put("smsCode", smsTempCode);
try { try {
// sendSmsCode.sendSmsCode(tel, s); // sendSmsCode.sendSmsCode(tel, s);
Systemctl.smsClient.sendCommonSms(params).getResult(); Systemctl.smsClient.sendCommonSms(params).getResult();
// code 保存到缓存中 // code 保存到缓存中
redisUtil.set(HYGF_USER_TEL + tel, code, time); redisUtil.set(key, code, time);
} catch (Exception e) { } catch (Exception e) {
throw new BadRequest("发送短信失败：" + e.getMessage()); throw new BadRequest("发送短信失败：" + e.getMessage());
} }
return ResponseHelper.buildResponse(flag); return ResponseHelper.buildResponse(flag);
...@@ -408,522 +429,515 @@ public class UnitInfoController extends BaseController { ...@@ -408,522 +429,515 @@ public class UnitInfoController extends BaseController {
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY) @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/verifyTelCode/{tel}/{code}") @GetMapping(value = "/verifyTelCode/{tel}/{code}")
@ApiOperation(httpMethod = "GET", value = "验证手机号验证码是否成功", notes = "验证手机号验证码是否成功") @ApiOperation(httpMethod = "GET", value = "验证手机号验证码是否成功", notes = "验证手机号验证码是否成功")
public ResponseModel<Boolean> verifyTelCode(@ApiParam(value = "手机号", example = "15895233587")@PathVariable(value = "tel") String adminTel, public ResponseModel<Boolean> verifyTelCode(
@ApiParam(value = "验证码", example = "258546")@PathVariable(value = "code") String code) { @ApiParam(value = "手机号", example = "15895233587") @PathVariable(value = "tel") String adminTel,
@ApiParam(value = "验证码", example = "258546") @PathVariable(value = "code") String code) {
Boolean flag = false; Boolean flag = false;
if (ValidationUtil.isEmpty(adminTel) || ValidationUtil.isEmpty(code)) { if (ValidationUtil.isEmpty(adminTel) || ValidationUtil.isEmpty(code)) {
throw new BadRequest("参数校验失败."); throw new BadRequest("参数校验失败.");
} }
if(redisUtil.hasKey(HYGF_USER_TEL + adminTel)) { if (redisUtil.hasKey(HYGF_USER_TEL + adminTel)) {
String redisCode = redisUtil.get(HYGF_USER_TEL + adminTel).toString(); String redisCode = redisUtil.get(HYGF_USER_TEL + adminTel).toString();
if(code.equals(redisCode)) { if (code.equals(redisCode)) {
flag = true; flag = true;
} }
} }
return ResponseHelper.buildResponse(flag); return ResponseHelper.buildResponse(flag);
} }
private String getRandomCode(){ private String getRandomCode() {
String code = ""; String code = "";
Random random = new Random(); Random random = new Random();
for (int i = 0; i < 6; i++) { for (int i = 0; i < 6; i++) {
int r = random.nextInt(10); int r = random.nextInt(10);
if(r==0){ if (r == 0) {
r=1; r = 1;
} }
code = code + r; code = code + r;
} }
return code; return code;
} }
/**
* 列表全部数据查询
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "POST", value = "经销商审核", notes = "经销商审核")
@PostMapping(value = "/powerStationExamine")
public ResponseModel<String> powerStationExamine(
@ApiParam(value = "分页Id", example = "1706974721737756674") @RequestParam(value = "pageId") long pageId,
@ApiParam(value = "节点Code", example = "1") @RequestParam(value = "nodeCode") String nodeCode,
@ApiParam(value = "场站Id", example = "1711627029541031938") @RequestParam(value = "stationId") String stationId,
@ApiParam(value = "任务Id", example = "1712383951215005697") @RequestParam(value = "taskId") String taskId,
@ApiParam(value = "计划实例Id", example = "64ddb490-7261-11ef-b7e1-02420a1c0012") @RequestParam(value = "planInstanceId") String planInstanceId,
@RequestBody Map<String, Object> kv) {
return ResponseHelper.buildResponse(
unitInfoServiceImpl.powerStationExamine(pageId, nodeCode, stationId, taskId, planInstanceId, kv));
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "经销商人员加入黑名单/撤销黑名单", notes = "经销商人员加入黑名单/撤销黑名单")
@GetMapping(value = "/updateUser")
public ResponseModel<Object> updateUser(@ApiParam(value = "管理员用户Id", example = "8121589") String adminUserId,
@ApiParam(value = "主键", example = "1813102468876234754") String sequenceNbr,
@ApiParam(value = "类型", example = "1") String type) {
FeignClientResult<List<String>> userResult = null;
UnitInfo unitInfo = unitInfoServiceImpl.getById(sequenceNbr);
if ("LOCK".equals(type)) {
userResult = Privilege.agencyUserClient.lockUsers(adminUserId);
unitInfo.setBlacklist(1);
} else {
userResult = Privilege.agencyUserClient.unlockUsers(adminUserId);
unitInfo.setBlacklist(0);
}
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateById(unitInfo));
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "获取经销商单位", notes = "获取经销商单位")
@GetMapping(value = "/getUnit")
public ResponseModel<List<UnitInfo>> getUnit(
@ApiParam(value = "经销商公司", example = "1702216914824097794") @RequestParam(required = false) String amosCompanySeq) {
LambdaQueryWrapper<UnitInfo> unitInfoque = new LambdaQueryWrapper<>();
unitInfoque.eq(!ValidationUtil.isEmpty(amosCompanySeq), UnitInfo::getAmosCompanySeq, amosCompanySeq);
unitInfoque.eq(UnitInfo::getAuditStatus, 2);
List<UnitInfo> list = unitInfoMapper.selectList(unitInfoque);
return ResponseHelper.buildResponse(list);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUnitDataDto")
@ApiOperation(httpMethod = "GET", value = "获取组织机构树", notes = "获取组织机构树")
public ResponseModel<UnitDataDto> getUnitDataDto() {
/** // 获取用户所在经销商单位
* 列表全部数据查询 UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
* .getUserUnitInformationDto(getUserInfo().getUserId());
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "POST",value = "经销商审核", notes = "经销商审核")
@PostMapping(value = "/powerStationExamine")
public ResponseModel<String> powerStationExamine(@ApiParam(value = "分页Id", example = "1706974721737756674")@RequestParam(value = "pageId") long pageId,
@ApiParam(value = "节点Code", example = "1") @RequestParam(value = "nodeCode") String nodeCode,
@ApiParam(value = "场站Id", example = "1711627029541031938") @RequestParam(value = "stationId") String stationId,
@ApiParam(value = "任务Id", example = "1712383951215005697") @RequestParam(value = "taskId") String taskId,
@ApiParam(value = "计划实例Id", example = "64ddb490-7261-11ef-b7e1-02420a1c0012") @RequestParam(value = "planInstanceId") String planInstanceId,
@RequestBody Map<String, Object> kv) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.powerStationExamine(pageId, nodeCode, stationId, taskId, planInstanceId, kv));
}
UnitDataDto unitDataDto = unitInfoServiceImpl.getUnitDataDto(userUnitInformationDto.getAmosDealerId());
return ResponseHelper.buildResponse(unitDataDto);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/updateUnitDataDto")
@ApiOperation(httpMethod = "POST", value = "修改单位信息", notes = "修改单位信息")
public ResponseModel<Boolean> updateUnitDataDto(@RequestBody UnitDataDto unitDataDto) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateUnitDataDto(unitDataDto));
}
// 获取经销商组织机构
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUnit/tree")
@ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树")
public ResponseModel<List<CompanyModel>> unitTree() {
@TycloudOperation(ApiLevel = UserType.AGENCY) // 获取用户所在经销商单位
@ApiOperation(httpMethod = "GET",value = "经销商人员加入黑名单/撤销黑名单", notes = "经销商人员加入黑名单/撤销黑名单") UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
@GetMapping(value = "/updateUser") .getUserUnitInformationDto(getUserInfo().getUserId());
public ResponseModel<Object> updateUser(@ApiParam(value = "管理员用户Id", example = "8121589")String adminUserId ,
@ApiParam(value = "主键", example = "1813102468876234754")String sequenceNbr ,
@ApiParam(value = "类型", example = "1")String type) {
FeignClientResult<List<String>> userResult =null;
UnitInfo unitInfo= unitInfoServiceImpl.getById(sequenceNbr);
if("LOCK".equals(type)){ CompanyModel companyM = new CompanyModel();
userResult = Privilege.agencyUserClient.lockUsers(adminUserId);
unitInfo.setBlacklist(1);
}else{
userResult = Privilege.agencyUserClient.unlockUsers(adminUserId);
unitInfo.setBlacklist(0);
}
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateById(unitInfo));
}
companyM.setCompanyName(userUnitInformationDto.getAmosDealerName());
companyM.setSequenceNbr(userUnitInformationDto.getAmosDealerId());
companyM.setOrgCode(userUnitInformationDto.getAmosDealerOrgCode());
@TycloudOperation(ApiLevel = UserType.AGENCY) FeignClientResult<Collection<CompanyModel>> feignClientResult;
@ApiOperation(httpMethod = "GET",value = "获取经销商单位", notes = "获取经销商单位") Collection<CompanyModel> children = null;
@GetMapping(value = "/getUnit") try {
public ResponseModel< List<UnitInfo>> getUnit(@ApiParam(value = "经销商公司", example = "1702216914824097794") @RequestParam(required = false)String amosCompanySeq) { feignClientResult = Privilege.companyClient.querySubAgencyTree(userUnitInformationDto.getAmosDealerId());
children = feignClientResult.getResult();
LambdaQueryWrapper<UnitInfo> unitInfoque=new LambdaQueryWrapper<>(); } catch (InnerInvokException e) {
e.printStackTrace();
}
companyM.setChildren(children);
List<CompanyModel> data = new ArrayList<>();
data.add(companyM);
return ResponseHelper.buildResponse(data);
}
unitInfoque.eq(!ValidationUtil.isEmpty(amosCompanySeq),UnitInfo::getAmosCompanySeq,amosCompanySeq); @TycloudOperation(ApiLevel = UserType.AGENCY)
unitInfoque.eq(UnitInfo::getAuditStatus,2); @GetMapping(value = "/getCompanyModelList")
List<UnitInfo> list=unitInfoMapper.selectList(unitInfoque); @ApiOperation(httpMethod = "GET", value = "分页查询", notes = "分页查询")
public ResponseModel<IPage<CompanyDto>> getCompanyModelList(CompanyDto dto) {
String userid = getUserInfo().getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud = new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId, userid);
PublicAgencyUser publicAgencyUse = publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug = new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId, publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines = personnelBusinessMapper.selectOne(qug);
dto.setComid(personnelBusines.getAmosDealerId());
Map<String, String> map = personnelBusinessMapper.getorgcode(dto.getCompanyTreeid());
dto.setOrgCode(map.get("orgCode"));
return ResponseHelper.buildResponse(unitInfoServiceImpl.getCompanyDto(dto));
}
return ResponseHelper.buildResponse(list); // 获取经销商组织机构
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUnitTree")
@ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树")
public ResponseModel<Collection<CompanyModel>> getUnitTree() {
// 获取用户所在经销商单位
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
.getUserUnitInformationDto(getUserInfo().getUserId());
} FeignClientResult<Collection<CompanyModel>> feignClientResult;
Collection<CompanyModel> children = null;
try {
feignClientResult = Privilege.companyClient.querySubAgencyTree(userUnitInformationDto.getAmosDealerId());
children = feignClientResult.getResult();
} catch (InnerInvokException e) {
e.printStackTrace();
}
@TycloudOperation(ApiLevel = UserType.AGENCY) return ResponseHelper.buildResponse(children);
@GetMapping(value = "/getUnitDataDto") }
@ApiOperation(httpMethod = "GET", value = "获取组织机构树", notes = "获取组织机构树")
public ResponseModel<UnitDataDto> getUnitDataDto() {
//获取用户所在经销商单位 @TycloudOperation(ApiLevel = UserType.AGENCY)
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); @GetMapping(value = "/getRegionalCompaniesTree")
@ApiOperation(httpMethod = "GET", value = "区域公司", notes = "区域公司")
public ResponseModel<List<RegionalCompanies>> getRegionalCompaniesTree() {
String userid = getUserInfo().getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud = new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId, userid);
PublicAgencyUser publicAgencyUse = publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug = new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId, publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines = personnelBusinessMapper.selectOne(qug);
LambdaQueryWrapper<RegionalCompanies> qu = new LambdaQueryWrapper<>();
qu.eq(RegionalCompanies::getUnitId, personnelBusines.getAmosDealerId());
List<RegionalCompanies> data = regionalCompaniesMapper.selectList(qu);
return ResponseHelper.buildResponse(data);
}
UnitDataDto unitDataDto = unitInfoServiceImpl.getUnitDataDto(userUnitInformationDto.getAmosDealerId()); @TycloudOperation(ApiLevel = UserType.AGENCY)
return ResponseHelper.buildResponse(unitDataDto); @GetMapping(value = "/getGroupTree")
} @ApiOperation(httpMethod = "GET", value = "经销商用户组", notes = "经销商用户组")
public ResponseModel<Collection<GroupModel>> getGroupTree() {
FeignClientResult<Collection<GroupModel>> feignClientResult = Privilege.groupClient.selectForList(group, null);
Collection<GroupModel> children = feignClientResult.getResult();
Collection<GroupModel> chil = new ArrayList<>();
for (GroupModel child : children) {
if ("户用光伏-经销商-管理员".equals(child.getGroupName()) || "用户光伏-农户".equals(child.getGroupName())
|| "户用光伏-经销商-空角色".equals(child.getGroupName())) {
// 排除其余角色
} else {
chil.add(child);
}
}
return ResponseHelper.buildResponse(chil);
}
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping (value = "/updateUnitDataDto") @GetMapping(value = "/getGroupTreeAll")
@ApiOperation(httpMethod = "POST", value = "修改单位信息", notes = "修改单位信息") @ApiOperation(httpMethod = "GET", value = "经销商用户组全部", notes = "经销商用户组全部")
public ResponseModel<Boolean> updateUnitDataDto(@RequestBody UnitDataDto unitDataDto) { public ResponseModel<Collection<GroupModel>> getGroupTreeAll() {
return ResponseHelper.buildResponse(unitInfoServiceImpl.updateUnitDataDto(unitDataDto));
} FeignClientResult<Collection<GroupModel>> feignClientResult = Privilege.groupClient.selectForList(group, null);
Collection<GroupModel> children = feignClientResult.getResult();
Collection<GroupModel> chil = new ArrayList<>();
for (GroupModel child : children) {
if ("用户光伏-农户".equals(child.getGroupName())) {
// 排除其余角色
} else {
chil.add(child);
}
}
return ResponseHelper.buildResponse(chil);
}
//获取经销商组织机构 // 根据角色获取区域公司
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUnit/tree") @GetMapping(value = "/getRegionalCompanies")
@ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树") @ApiOperation(httpMethod = "GET", value = "根据角色获取区域公司", notes = "根据角色获取区域公司")
public ResponseModel<List<CompanyModel>> unitTree() { public ResponseModel<Collection<CompanyModel>> getRegionalCompanies() {
AgencyUserModel agencyUserModel = getUserInfo();
String org = agencyUserModel.getOrgNames();
Collection<CompanyModel> companyModel = new ArrayList<>();
if (org.contains("-经销商")) {
String userid = agencyUserModel.getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud = new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId, userid);
PublicAgencyUser publicAgencyUse = publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug = new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId, publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines = personnelBusinessMapper.selectOne(qug);
if (org.contains("户用光伏-经销商-管理员")) {
// 如果是经销商管理员
LambdaQueryWrapper<RegionalCompanies> qu = new LambdaQueryWrapper<>();
qu.eq(RegionalCompanies::getUnitId, personnelBusines.getAmosDealerId());
List<RegionalCompanies> data = regionalCompaniesMapper.selectList(qu);
if (data != null && !data.isEmpty()) {
for (RegionalCompanies datum : data) {
CompanyModel co = new CompanyModel();
co.setSequenceNbr(datum.getRegionalCompaniesSeq());
co.setCompanyName(datum.getRegionalCompaniesName());
co.setOrgCode(datum.getRegionalCompaniesCode());
companyModel.add(co);
}
}
} else {
// 如果是经销商普通员工
CompanyModel co = new CompanyModel();
co.setSequenceNbr(personnelBusines.getRegionalCompaniesSeq());
co.setCompanyName(personnelBusines.getRegionalCompaniesName());
co.setOrgCode(personnelBusines.getRegionalCompaniesCode());
companyModel.add(co);
}
} else {
// 如果是管理端
FeignClientResult<Collection<CompanyModel>> feignClientResult = Privilege.companyClient
.querySubAgencyTree(regionalCompanies);
companyModel = (List<CompanyModel>) feignClientResult.getResult();
}
return ResponseHelper.buildResponse(companyModel);
}
//获取用户所在经销商单位 @TycloudOperation(ApiLevel = UserType.AGENCY)
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); @ApiOperation(httpMethod = "GET", value = "获取审核通过的经销商", notes = "获取审核通过的经销商")
@GetMapping(value = "/getlistUnitInfo")
CompanyModel companyM= new CompanyModel(); @UserLimits
public ResponseModel<List<UnitInfo>> getlistUnitInfo() {
companyM.setCompanyName(userUnitInformationDto.getAmosDealerName());
companyM.setSequenceNbr(userUnitInformationDto.getAmosDealerId());
companyM.setOrgCode(userUnitInformationDto.getAmosDealerOrgCode());
FeignClientResult<Collection<CompanyModel>> feignClientResult;
Collection<CompanyModel> children=null;
try {
feignClientResult = Privilege.companyClient.querySubAgencyTree(userUnitInformationDto.getAmosDealerId());
children = feignClientResult.getResult();
} catch (InnerInvokException e) {
e.printStackTrace();
}
companyM.setChildren(children);
List<CompanyModel> data=new ArrayList<>();
data.add(companyM);
return ResponseHelper.buildResponse(data);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getCompanyModelList")
@ApiOperation(httpMethod = "GET",value = "分页查询", notes = "分页查询")
public ResponseModel<IPage<CompanyDto>> getCompanyModelList(CompanyDto dto) {
String userid= getUserInfo().getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud=new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId,userid);
PublicAgencyUser publicAgencyUse= publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug=new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId,publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines=personnelBusinessMapper.selectOne(qug);
dto.setComid(personnelBusines.getAmosDealerId());
Map<String,String> map= personnelBusinessMapper.getorgcode(dto.getCompanyTreeid());
dto.setOrgCode(map.get("orgCode"));
return ResponseHelper.buildResponse(unitInfoServiceImpl.getCompanyDto(dto));
}
//获取经销商组织机构
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUnitTree")
@ApiOperation(httpMethod = "GET", value = "管辖机构树", notes = "管辖机构树")
public ResponseModel<Collection<CompanyModel>> getUnitTree() {
//获取用户所在经销商单位
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId());
FeignClientResult<Collection<CompanyModel>> feignClientResult;
Collection<CompanyModel> children=null;
try {
feignClientResult = Privilege.companyClient.querySubAgencyTree(userUnitInformationDto.getAmosDealerId());
children = feignClientResult.getResult();
} catch (InnerInvokException e) {
e.printStackTrace();
}
return ResponseHelper.buildResponse(children);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getRegionalCompaniesTree")
@ApiOperation(httpMethod = "GET", value = "区域公司", notes = "区域公司")
public ResponseModel<List<RegionalCompanies>> getRegionalCompaniesTree() {
String userid= getUserInfo().getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud=new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId,userid);
PublicAgencyUser publicAgencyUse= publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug=new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId,publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines=personnelBusinessMapper.selectOne(qug);
LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper<>();
qu.eq(RegionalCompanies::getUnitId,personnelBusines.getAmosDealerId());
List<RegionalCompanies> data= regionalCompaniesMapper.selectList(qu);
return ResponseHelper.buildResponse(data);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getGroupTree")
@ApiOperation(httpMethod = "GET", value = "经销商用户组", notes = "经销商用户组")
public ResponseModel<Collection<GroupModel>> getGroupTree() {
FeignClientResult<Collection<GroupModel>> feignClientResult= Privilege.groupClient.selectForList(group,null);
Collection<GroupModel> children = feignClientResult.getResult();
Collection<GroupModel> chil =new ArrayList<>();
for (GroupModel child : children) {
if("户用光伏-经销商-管理员".equals(child.getGroupName())||"用户光伏-农户".equals(child.getGroupName())||"户用光伏-经销商-空角色".equals(child.getGroupName())){
//排除其余角色
}else{
chil.add(child);
}
}
return ResponseHelper.buildResponse(chil);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getGroupTreeAll")
@ApiOperation(httpMethod = "GET", value = "经销商用户组全部", notes = "经销商用户组全部")
public ResponseModel<Collection<GroupModel>> getGroupTreeAll() {
FeignClientResult<Collection<GroupModel>> feignClientResult= Privilege.groupClient.selectForList(group,null);
Collection<GroupModel> children = feignClientResult.getResult();
Collection<GroupModel> chil =new ArrayList<>();
for (GroupModel child : children) {
if("用户光伏-农户".equals(child.getGroupName())){
//排除其余角色
}else{
chil.add(child);
}
}
return ResponseHelper.buildResponse(chil);
}
//根据角色获取区域公司
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getRegionalCompanies")
@ApiOperation(httpMethod = "GET", value = "根据角色获取区域公司", notes = "根据角色获取区域公司")
public ResponseModel<Collection<CompanyModel>> getRegionalCompanies() {
AgencyUserModel agencyUserModel= getUserInfo();
String org=agencyUserModel.getOrgNames();
Collection<CompanyModel> companyModel=new ArrayList<>();
if(org.contains("-经销商")){
String userid= agencyUserModel.getUserId();
LambdaQueryWrapper<PublicAgencyUser> qud=new LambdaQueryWrapper<>();
qud.eq(PublicAgencyUser::getAmosUserId,userid);
PublicAgencyUser publicAgencyUse= publicAgencyUserMapper.selectOne(qud);
LambdaQueryWrapper<PersonnelBusiness> qug=new LambdaQueryWrapper<>();
qug.eq(PersonnelBusiness::getFoundationId,publicAgencyUse.getSequenceNbr());
PersonnelBusiness personnelBusines=personnelBusinessMapper.selectOne(qug);
if(org.contains("户用光伏-经销商-管理员")){
//如果是经销商管理员
LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper<>();
qu.eq(RegionalCompanies::getUnitId,personnelBusines.getAmosDealerId());
List<RegionalCompanies> data= regionalCompaniesMapper.selectList(qu);
if(data!=null&&!data.isEmpty()){
for (RegionalCompanies datum : data) {
CompanyModel co=new CompanyModel();
co.setSequenceNbr(datum.getRegionalCompaniesSeq());
co.setCompanyName(datum.getRegionalCompaniesName());
co.setOrgCode(datum.getRegionalCompaniesCode());
companyModel.add(co);
}
}
}else{
//如果是经销商普通员工
CompanyModel co=new CompanyModel();
co.setSequenceNbr(personnelBusines.getRegionalCompaniesSeq());
co.setCompanyName(personnelBusines.getRegionalCompaniesName());
co.setOrgCode(personnelBusines.getRegionalCompaniesCode());
companyModel.add(co);
}
}else{
//如果是管理端
FeignClientResult<Collection<CompanyModel>> feignClientResult= Privilege.companyClient.querySubAgencyTree(regionalCompanies);
companyModel = (List<CompanyModel>)feignClientResult.getResult();
}
return ResponseHelper.buildResponse(companyModel);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "获取审核通过的经销商", notes = "获取审核通过的经销商")
@GetMapping(value = "/getlistUnitInfo")
@UserLimits
public ResponseModel<List<UnitInfo>> getlistUnitInfo() {
// LambdaQueryWrapper<UnitInfo> qu=new LambdaQueryWrapper(); // LambdaQueryWrapper<UnitInfo> qu=new LambdaQueryWrapper();
// qu.eq(UnitInfo::getIsDelete,false); // qu.eq(UnitInfo::getIsDelete,false);
// qu.eq(UnitInfo::getAuditStatus,2); // qu.eq(UnitInfo::getAuditStatus,2);
// List<UnitInfo> list=unitInfoMapper.selectList(qu); // List<UnitInfo> list=unitInfoMapper.selectList(qu);
List<UnitInfo> list=unitInfoMapper.getlistUnitInfo(); List<UnitInfo> list = unitInfoMapper.getlistUnitInfo();
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") @ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getRegionalCompanie") @GetMapping(value = "/getRegionalCompanie")
@UserLimits @UserLimits
public ResponseModel< List<RegionalCompanies> > getRegionalCompanie( public ResponseModel<List<RegionalCompanies>> getRegionalCompanie(
@ApiParam(value = "主键", example = "1702216914824097794") @RequestParam(required=false) Long sequenceNbr @ApiParam(value = "主键", example = "1702216914824097794") @RequestParam(required = false) Long sequenceNbr) {
) {
// LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper(); // LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper();
// qu.eq(RegionalCompanies::getUnitInfoId,sequenceNbr); // qu.eq(RegionalCompanies::getUnitInfoId,sequenceNbr);
// qu.eq(RegionalCompanies::getIsDelete,false); // qu.eq(RegionalCompanies::getIsDelete,false);
// List<RegionalCompanies> list=regionalCompaniesMapper.selectList(qu); // List<RegionalCompanies> list=regionalCompaniesMapper.selectList(qu);
List<RegionalCompanies> list=regionalCompaniesMapper.selectListRegionalCompanies(sequenceNbr); List<RegionalCompanies> list = regionalCompaniesMapper.selectListRegionalCompanies(sequenceNbr);
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getRegionalCompanieById")
public ResponseModel< RegionalCompanies > getRegionalCompanieById(
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required=false) Long regionalCompaniesSeq,
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required=false) Long unitInfoId
) {
LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper();
qu.eq(RegionalCompanies::getRegionalCompaniesSeq,regionalCompaniesSeq);
qu.eq(RegionalCompanies::getUnitInfoId,unitInfoId);
qu.eq(RegionalCompanies::getIsDelete,false);
RegionalCompanies list=regionalCompaniesMapper.selectOne(qu);
return ResponseHelper.buildResponse(list);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getRegionalCompanieUnitInfo")
public ResponseModel< List<RegionalCompanies> > getRegionalCompanieUnitInfo(
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required=false) Long unitInfoId,
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required=false) Long regionalCompaniesSeq
) {
LambdaQueryWrapper<RegionalCompanies> qu=new LambdaQueryWrapper();
qu.eq(RegionalCompanies::getRegionalCompaniesSeq,regionalCompaniesSeq);
qu.eq(RegionalCompanies::getUnitInfoId,unitInfoId);
RegionalCompanies list=regionalCompaniesMapper.selectOne(qu);
UnitInfo unitInfo=unitInfoMapper.selectById(unitInfoId);
List<RegionalCompanies> date=null;
if(list!=null&&unitInfo!=null){
list.setRegionalCompaniesName(unitInfo.getName()+"-"+list.getRegionalCompaniesName());
date=new ArrayList();
date.add(list);
}
return ResponseHelper.buildResponse(date);
}
//获取电站列表
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getUnitInfoListData")
public ResponseModel< List<Map<String,Object>> > getUnitInfoListData(
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required=false) Long unitInfoId,
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required=false) Long regionalCompaniesSeq
) {
UnitInfo unitInfo=unitInfoMapper.selectById(unitInfoId);
List<PeasantHousehold> list=peasantHouseholdMapper.selectPeasantHouseholdList(unitInfo.getAmosCompanySeq(),regionalCompaniesSeq,null,null,null,null);
List<Map<String,Object>> date=new ArrayList<>();
if(list!=null){
for (PeasantHousehold peasantHousehold : list) {
Map<String,Object> map=new HashMap<>();
map.put("children",new ArrayList<>());
map.put("title",peasantHousehold.getPeasantHouseholdNo()+"-"+peasantHousehold.getOwnersName());
map.put("value",peasantHousehold.getSequenceNbr());
map.put("key",peasantHousehold.getSequenceNbr());
date.add(map);
}
}
return ResponseHelper.buildResponse(date);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getPeasantHouseholdData")
public ResponseModel<Page<PeasantHousehold>> getPeasantHouseholdData(
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required=false) Long unitInfoId,
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required=false) Long regionalCompaniesSeq,
@ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
@ApiParam(value = "页数大小", example = "20") @RequestParam (value = "size") int size,
@ApiParam(value = "农户ID", example = "1710823964114186242") @RequestParam (required=false) String peasantHouseholdNo,
@ApiParam(value = "电站名称", example = "admin") @RequestParam (required=false) String ownersName,
@ApiParam(value = "id", example = "1710823964114186242,1717088938155339777") @RequestParam (required=false) String ids
) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.getPeasantHouseholdData( unitInfoId,regionalCompaniesSeq, current,size,peasantHouseholdNo,ownersName,ids));
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getPeasantHouseholdDataNew")
public ResponseModel<Page<PeasantHousehold>> getPeasantHouseholdDataNew(
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required=false) Long unitInfoId,
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required=false) Long regionalCompaniesSeq,
@ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
@ApiParam(value = "页数大小", example = "20") @RequestParam (value = "size") int size,
@ApiParam(value = "农户ID", example = "1710823964114186242") @RequestParam (required=false) String peasantHouseholdNo,
@ApiParam(value = "电站名称", example = "admin") @RequestParam (required=false) String ownersName,
@ApiParam(value = "id", example = "1710823964114186242,1717088938155339777") @RequestParam (required=false) String ids
) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.getPeasantHouseholdDataNew(unitInfoId, regionalCompaniesSeq, current, size, peasantHouseholdNo, ownersName, ids));
}
/**获取当前登录人区域公司*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getRegionalCompanieByuser")
public ResponseModel< List<Map<String,Object>> > getRegionalCompanieByuser(
) {
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId());
List<Map<String,Object>> date=new ArrayList<>();
if(userUnitInformationDto!=null&&userUnitInformationDto.getRegionalCompaniesSeq()!=null&&userUnitInformationDto.getRegionalCompaniesName()!=null){
Map<String,Object> map=new HashMap<>();
map.put("value",userUnitInformationDto.getRegionalCompaniesSeq());
map.put("name",userUnitInformationDto.getRegionalCompaniesName());
date.add(map);
}
return ResponseHelper.buildResponse(date);
}
/***获取经销商，区域公司下 工程负责人**/ @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@TycloudOperation(ApiLevel = UserType.AGENCY) @GetMapping(value = "/getRegionalCompanieById")
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") public ResponseModel<RegionalCompanies> getRegionalCompanieById(
@GetMapping(value = "/getuserList") @ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required = false) Long regionalCompaniesSeq,
public ResponseModel< List<Map<String,Object>> > getuserList( @ApiParam(value = "角色Id", example = "6582473") @RequestParam(required=false) Long role, @ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required = false) Long unitInfoId) {
@ApiParam(value = "注册区域Id", example = "1710823964114186242") @RequestParam(required=false) Long regionalCompaniesSeq LambdaQueryWrapper<RegionalCompanies> qu = new LambdaQueryWrapper();
qu.eq(RegionalCompanies::getRegionalCompaniesSeq, regionalCompaniesSeq);
) { qu.eq(RegionalCompanies::getUnitInfoId, unitInfoId);
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); qu.eq(RegionalCompanies::getIsDelete, false);
// List<Map<String,Object>> date= unitInfoMapper.getuserList(null,role,regionalCompaniesSeq,userUnitInformationDto.getAmosDealerId()); RegionalCompanies list = regionalCompaniesMapper.selectOne(qu);
List<Map<String,Object>> date= unitInfoMapper.getuserListByOrgCode(null,role,regionalCompaniesSeq,userUnitInformationDto.getAmosDealerOrgCode()); return ResponseHelper.buildResponse(list);
return ResponseHelper.buildResponse(date); }
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
/***获取经销商，区域公司下 工程负责人**/ @GetMapping(value = "/getRegionalCompanieUnitInfo")
public ResponseModel<List<RegionalCompanies>> getRegionalCompanieUnitInfo(
@TycloudOperation(ApiLevel = UserType.AGENCY) @ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required = false) Long unitInfoId,
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") @ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required = false) Long regionalCompaniesSeq) {
@GetMapping(value = "/getuserListAll") LambdaQueryWrapper<RegionalCompanies> qu = new LambdaQueryWrapper();
public ResponseModel< List<Map<String,Object>> > getuserListAll( @ApiParam(value = "角色Id", example = "6582473") @RequestParam(required=false) Long role, qu.eq(RegionalCompanies::getRegionalCompaniesSeq, regionalCompaniesSeq);
@ApiParam(value = "注册区域Id", example = "1710823964114186242") @RequestParam(required=false) Long regionalCompaniesSeq qu.eq(RegionalCompanies::getUnitInfoId, unitInfoId);
RegionalCompanies list = regionalCompaniesMapper.selectOne(qu);
) { UnitInfo unitInfo = unitInfoMapper.selectById(unitInfoId);
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); List<RegionalCompanies> date = null;
List<Map<String,Object>> date= unitInfoMapper.getuserListAllByOrgCode(null,role,regionalCompaniesSeq,userUnitInformationDto.getAmosDealerOrgCode()); if (list != null && unitInfo != null) {
return ResponseHelper.buildResponse(date); list.setRegionalCompaniesName(unitInfo.getName() + "-" + list.getRegionalCompaniesName());
} date = new ArrayList();
date.add(list);
@TycloudOperation(ApiLevel = UserType.AGENCY) }
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") return ResponseHelper.buildResponse(date);
@GetMapping(value = "/getuserTelephone") }
public ResponseModel< Map<String,Object> > getuserTelephone(@ApiParam(value = "用户名称", example = "admin") @RequestParam(required=false) String userName // 获取电站列表
) { Map<String,Object> data=null;
if(StringUtils.isNotEmpty(userName)){ @TycloudOperation(ApiLevel = UserType.AGENCY)
List<Map<String,Object>> date= unitInfoMapper.getuserListtelephone(userName,null,null,null); @ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
if(date!=null&&!date.isEmpty()){ @GetMapping(value = "/getUnitInfoListData")
data=date.get(0); public ResponseModel<List<Map<String, Object>>> getUnitInfoListData(
} @ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required = false) Long unitInfoId,
} @ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required = false) Long regionalCompaniesSeq) {
UnitInfo unitInfo = unitInfoMapper.selectById(unitInfoId);
List<PeasantHousehold> list = peasantHouseholdMapper.selectPeasantHouseholdList(unitInfo.getAmosCompanySeq(),
return ResponseHelper.buildResponse(data); regionalCompaniesSeq, null, null, null, null);
} List<Map<String, Object>> date = new ArrayList<>();
@TycloudOperation(ApiLevel = UserType.AGENCY) if (list != null) {
@ApiOperation(httpMethod = "GET",value = "根据userId查询手机号", notes = "根据userId查询手机号") for (PeasantHousehold peasantHousehold : list) {
@GetMapping(value = "/getUserTelephoneByUserId") Map<String, Object> map = new HashMap<>();
public ResponseModel< Map<String,Object> > getUserTelephoneByUserId( @ApiParam(value = "用户Id", example = "8542741")@RequestParam(required=false) String userId map.put("children", new ArrayList<>());
) { Map<String,Object> data=null; map.put("title", peasantHousehold.getPeasantHouseholdNo() + "-" + peasantHousehold.getOwnersName());
if(StringUtils.isNotEmpty(userId)){ map.put("value", peasantHousehold.getSequenceNbr());
List<Map<String,Object>> date= unitInfoMapper.getUserTelephoneByUserId(userId); map.put("key", peasantHousehold.getSequenceNbr());
if(date!=null&&!date.isEmpty()){ date.add(map);
data=date.get(0); }
} }
} return ResponseHelper.buildResponse(date);
}
return ResponseHelper.buildResponse(data); @TycloudOperation(ApiLevel = UserType.AGENCY)
} @ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getPeasantHouseholdData")
@TycloudOperation(ApiLevel = UserType.AGENCY) public ResponseModel<Page<PeasantHousehold>> getPeasantHouseholdData(
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") @ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required = false) Long unitInfoId,
@GetMapping(value = "/selectPeasantHouseholdListsg") @ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required = false) Long regionalCompaniesSeq,
public ResponseModel<Page<PeasantHousehold>> selectPeasantHouseholdListsg( @ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
@RequestParam(required=false) Long regionalCompaniesSeq, @ApiParam(value = "页数大小", example = "20") @RequestParam(value = "size") int size,
@RequestParam(value = "current") int current, @ApiParam(value = "农户ID", example = "1710823964114186242") @RequestParam(required = false) String peasantHouseholdNo,
@RequestParam (value = "size") int size, @ApiParam(value = "电站名称", example = "admin") @RequestParam(required = false) String ownersName,
@RequestParam (required=false) String peasantHouseholdNo, @ApiParam(value = "id", example = "1710823964114186242,1717088938155339777") @RequestParam(required = false) String ids
@RequestParam (required=false) String ownersName,
@RequestParam (required=false) String ids ) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.getPeasantHouseholdData(unitInfoId,
) { regionalCompaniesSeq, current, size, peasantHouseholdNo, ownersName, ids));
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto( getUserInfo().getUserId()); }
return ResponseHelper.buildResponse(unitInfoServiceImpl.selectPeasantHouseholdListsg( userUnitInformationDto.getAmosDealerOrgCode(),regionalCompaniesSeq, current,size,peasantHouseholdNo,ownersName, ids));
} @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getPeasantHouseholdDataNew")
public ResponseModel<Page<PeasantHousehold>> getPeasantHouseholdDataNew(
@ApiParam(value = "人员Id", example = "1715318790759149570") @RequestParam(required = false) Long unitInfoId,
@ApiParam(value = "注册公司ID", example = "1702216914824097794") @RequestParam(required = false) Long regionalCompaniesSeq,
@ApiParam(value = "页码", example = "1") @RequestParam(value = "current") int current,
@ApiParam(value = "页数大小", example = "20") @RequestParam(value = "size") int size,
@ApiParam(value = "农户ID", example = "1710823964114186242") @RequestParam(required = false) String peasantHouseholdNo,
@ApiParam(value = "电站名称", example = "admin") @RequestParam(required = false) String ownersName,
@ApiParam(value = "id", example = "1710823964114186242,1717088938155339777") @RequestParam(required = false) String ids
) {
return ResponseHelper.buildResponse(unitInfoServiceImpl.getPeasantHouseholdDataNew(unitInfoId,
regionalCompaniesSeq, current, size, peasantHouseholdNo, ownersName, ids));
}
/** 获取当前登录人区域公司 */
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getRegionalCompanieByuser")
public ResponseModel<List<Map<String, Object>>> getRegionalCompanieByuser() {
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
.getUserUnitInformationDto(getUserInfo().getUserId());
List<Map<String, Object>> date = new ArrayList<>();
if (userUnitInformationDto != null && userUnitInformationDto.getRegionalCompaniesSeq() != null
&& userUnitInformationDto.getRegionalCompaniesName() != null) {
Map<String, Object> map = new HashMap<>();
map.put("value", userUnitInformationDto.getRegionalCompaniesSeq());
map.put("name", userUnitInformationDto.getRegionalCompaniesName());
date.add(map);
}
return ResponseHelper.buildResponse(date);
}
/*** 获取经销商，区域公司下 工程负责人 **/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getuserList")
public ResponseModel<List<Map<String, Object>>> getuserList(
@ApiParam(value = "角色Id", example = "6582473") @RequestParam(required = false) Long role,
@ApiParam(value = "注册区域Id", example = "1710823964114186242") @RequestParam(required = false) Long regionalCompaniesSeq
) {
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
.getUserUnitInformationDto(getUserInfo().getUserId());
// List<Map<String,Object>> date=
// unitInfoMapper.getuserList(null,role,regionalCompaniesSeq,userUnitInformationDto.getAmosDealerId());
List<Map<String, Object>> date = unitInfoMapper.getuserListByOrgCode(null, role, regionalCompaniesSeq,
userUnitInformationDto.getAmosDealerOrgCode());
return ResponseHelper.buildResponse(date);
}
/*** 获取经销商，区域公司下 工程负责人 **/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getuserListAll")
public ResponseModel<List<Map<String, Object>>> getuserListAll(
@ApiParam(value = "角色Id", example = "6582473") @RequestParam(required = false) Long role,
@ApiParam(value = "注册区域Id", example = "1710823964114186242") @RequestParam(required = false) Long regionalCompaniesSeq
) {
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
.getUserUnitInformationDto(getUserInfo().getUserId());
List<Map<String, Object>> date = unitInfoMapper.getuserListAllByOrgCode(null, role, regionalCompaniesSeq,
userUnitInformationDto.getAmosDealerOrgCode());
return ResponseHelper.buildResponse(date);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/getuserTelephone")
public ResponseModel<Map<String, Object>> getuserTelephone(
@ApiParam(value = "用户名称", example = "admin") @RequestParam(required = false) String userName) {
Map<String, Object> data = null;
if (StringUtils.isNotEmpty(userName)) {
List<Map<String, Object>> date = unitInfoMapper.getuserListtelephone(userName, null, null, null);
if (date != null && !date.isEmpty()) {
data = date.get(0);
}
}
return ResponseHelper.buildResponse(data);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "根据userId查询手机号", notes = "根据userId查询手机号")
@GetMapping(value = "/getUserTelephoneByUserId")
public ResponseModel<Map<String, Object>> getUserTelephoneByUserId(
@ApiParam(value = "用户Id", example = "8542741") @RequestParam(required = false) String userId) {
Map<String, Object> data = null;
if (StringUtils.isNotEmpty(userId)) {
List<Map<String, Object>> date = unitInfoMapper.getUserTelephoneByUserId(userId);
if (date != null && !date.isEmpty()) {
data = date.get(0);
}
}
return ResponseHelper.buildResponse(data);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/selectPeasantHouseholdListsg")
public ResponseModel<Page<PeasantHousehold>> selectPeasantHouseholdListsg(
@RequestParam(required = false) Long regionalCompaniesSeq, @RequestParam(value = "current") int current,
@RequestParam(value = "size") int size, @RequestParam(required = false) String peasantHouseholdNo,
@RequestParam(required = false) String ownersName, @RequestParam(required = false) String ids
) {
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
.getUserUnitInformationDto(getUserInfo().getUserId());
return ResponseHelper.buildResponse(
unitInfoServiceImpl.selectPeasantHouseholdListsg(userUnitInformationDto.getAmosDealerOrgCode(),
regionalCompaniesSeq, current, size, peasantHouseholdNo, ownersName, ids));
}
} }
amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/PreparationMoneyServiceImpl.java
View file @ a13e95b9
...@@ -300,10 +300,15 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto ...@@ -300,10 +300,15 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
ids.add(documentStation.getStationId()); ids.add(documentStation.getStationId());
} }
//获取所有电站Bom，分组合并，暂时不相加 //获取所有电站Bom，分组合并，暂时不相加
List<DesignInformation> li= new ArrayList<>();
if(!ids.isEmpty())
{
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
designInformationQueryWrapper.in("peasant_household_id", ids);
li = designInformationMapper.selectList(designInformationQueryWrapper);
}
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
designInformationQueryWrapper.in("peasant_household_id", ids);
List<DesignInformation> li = designInformationMapper.selectList(designInformationQueryWrapper);
DesignInformation designInformation = new DesignInformation(); DesignInformation designInformation = new DesignInformation();
//组件 //组件
List<Object> assembly = new ArrayList<>(); List<Object> assembly = new ArrayList<>();
......
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