企业审核

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/CompanyController.java

@@ -2,8 +2,16 @@ package com.yeejoin.amos.boot.module.ugp.biz.controller;
 
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yeejoin.amos.boot.biz.common.constants.CommonConstant;
+import com.yeejoin.amos.boot.module.common.api.dto.OrgUsrDto;
+import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService;
+import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.CompanyMapper;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -41,6 +49,8 @@ public class CompanyController extends BaseController {
     CompanyServiceImpl companyServiceImpl;
 	@Autowired(required = false)
 	CompanyMapper companyMapper;
+	@Autowired
+	OrgUsrServiceImpl iOrgUsrService;
 
     /**
      * 新增企业信息表
@@ -157,11 +167,45 @@ public class CompanyController extends BaseController {
 //		company= companyMapper.selectOne(lambdaQueryWrapper);
 
 
-
-
 		return ResponseHelper.buildResponse(companyMapper.selectById(companyList));
 
 
 	}
+	/**
+	 * 企业审核
+	 * 根据sequenceNbr更新，审核通过后的企业调用平台接口创建单位及管理员，并存业务的cb_org_usr表
+	 * @param sequenceNbr 主键
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+	@PostMapping(value = "check/{sequenceNbr}")
+	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新，并创建单位及管理员", notes = "根据sequenceNbr更新，并创建单位及管理员")
+	public ResponseModel<CompanyDto> companyCheck(@RequestBody CompanyDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) throws Exception{
+		model.setSequenceNbr(sequenceNbr);
+		if (model.getApproved().equals("已审核")){
+			final CompanyModel companyModel = new CompanyModel();
+			final AgencyUserModel agencyUserModel = new AgencyUserModel();
+
+			companyModel.setCompanyName(model.getName());
+			companyModel.setCompanyCode(model.getCreditCode());
+			companyModel.setAddress(model.getAddress());
+			companyModel.setParentId(model.getSequenceNbr());
+			companyModel.setLevel("headquarter");
+			companyModel.setAgencyCode("ugp");
+			final FeignClientResult<CompanyModel> companyModelFeignClientResult = Privilege.companyClient.create(companyModel);
+
+			agencyUserModel.setRealName(model.getContact());
+			agencyUserModel.setMobile(model.getContactPhone());
+			Privilege.agencyUserClient.create(agencyUserModel);
+
+			final OrgUsrDto orgUsrDto = new OrgUsrDto();
+			orgUsrDto.setBizOrgName(model.getName());
+			orgUsrDto.setAmosOrgId(companyModelFeignClientResult.getResult().getSequenceNbr().toString());
+			orgUsrDto.setAmosOrgCode(companyModelFeignClientResult.getResult().getOrgCode());
+			orgUsrDto.setBizOrgType(CommonConstant.BIZ_ORG_TYPE_COMPANY);
+			iOrgUsrService.saveOrgUsr(orgUsrDto);
+		}
+		return ResponseHelper.buildResponse(companyServiceImpl.updateWithModel(model));
+	}
 }