人员附码业务代码

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/DynamicLabelEnum.java

+package com.yeejoin.amos.boot.module.common.api.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author
+ * @title: EquipQrcodeColorEnum
+ * <pre>
+ * @description: TODO
+ * </pre>
+ * @date 2020/12/12 14:23
+ */
+@Getter
+@AllArgsConstructor
+public enum DynamicLabelEnum {
+
+    NAME("name","姓名"),
+    CODE("personNumber","员工编码"),
+    BIZORGNAME("bizOrgName","所属单位"),
+    PERSONTYPE("peopleType","人员类型"),
+    TELPHONE("mobilePhone","联系电话"),
+    SEX("gender", "性别"),
+    CARDTYPE("certificatesType","证件类型"),
+    CARDNUM("certificatesNumber","证件号码"),
+    GWLX("jobTitle","岗位类型"),
+    GWZZ("postQualification","岗位资质"),
+    XFGLGW("fireManagementPost","消防管理岗位"),
+    GLZH("amosName","关联账户"),
+    GWZT("state","岗位状态"),
+    DISPDATE("birthdayTime","出生日期");
+
+    private String code;
+
+    private String describe;
+
+    public static DynamicLabelEnum getEnumByKey(String key) {
+        DynamicLabelEnum colorEnum = null;
+        for (DynamicLabelEnum u : DynamicLabelEnum.values()) {
+            if (u.getCode().equals(key)) {
+                colorEnum = u;
+                break;
+            }
+        }
+        return colorEnum;
+    }
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/RiskBizInfoVo.java

+package com.yeejoin.amos.boot.module.common.api.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author keyong
+ * @title: RiskBizInfoVo
+ * <pre>
+ * @description: TODO
+ * </pre>
+ * @date 2023/5/17 11:22
+ */
+@Data
+public class RiskBizInfoVo {
+
+    private String warningObjectName;
+
+    private String warningObjectCode;
+
+    private String warningTime;
+
+    private String sourceAttribution;
+
+    private String sourceAttributionDesc;
+
+    private List<RiskDynamicDetailsVo> dynamicDetails;
+
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/RiskDynamicDetailsVo.java

+package com.yeejoin.amos.boot.module.common.api.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author keyong
+ * @title: RiskDynamicDetailsVo
+ * <pre>
+ * @description: TODO
+ * </pre>
+ * @date 2023/5/17 11:36
+ */
+@Data
+public class RiskDynamicDetailsVo {
+
+    private String tabName;
+
+    private List<TableContentVo> tabContent;
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/TableContentVo.java

+package com.yeejoin.amos.boot.module.common.api.dto;
+
+import lombok.Data;
+
+/**
+ * @author keyong
+ * @title: TableContentVo
+ * <pre>
+ * @description: TODO
+ * </pre>
+ * @date 2023/5/17 11:20
+ */
+@Data
+public class TableContentVo {
+
+    private String key;
+
+    private String label;
+
+    private Object value;
+
+    private String type;
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/OrgUsrMapper.java

@@ -152,5 +152,7 @@ public interface OrgUsrMapper extends BaseMapper<OrgUsr> {
 
     List<OrgUsr> companyUserTreeByUserAndTypeALL(@Param("bizorgcode") String bizorgcode);
 
+    void updatePersonStatus(String status, String id);
+
     List<Map<String, Object>> getFireProtectionAndMaintenance();
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IOrgUsrService.java

@@ -383,4 +383,8 @@ public interface IOrgUsrService {
 
     List<FirefightersPost> selectPostById(List<String> ids);
 
+    RiskBizInfoVo getPersonInfo(String id,String type);
+
+    void updatePersonStatus(String status, String id);
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/OrgUsrMapper.xml

@@ -858,8 +858,11 @@ GROUP BY
      WHERE biz_org_code like concat(#{code}, '%');
 
     </update>
+    <update id="updatePersonStatus">
+        update cb_org_usr set person_status = #{status} where id = #{id}
+    </update>
 
-  <select id ='getPersonSimpleDetail' resultType='Map'>
+    <select id ='getPersonSimpleDetail' resultType='Map'>
   SELECT
 	person.biz_org_name as name,
 	cdf.field_value as phone

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/OrgUsrServiceImpl.java

@@ -16,6 +16,7 @@ import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import com.yeejoin.amos.boot.biz.common.entity.DataDictionary;
 import com.yeejoin.amos.boot.biz.common.interceptors.PermissionInterceptorContext;
 import com.yeejoin.amos.boot.biz.common.service.impl.DataDictionaryServiceImpl;
+import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
 import com.yeejoin.amos.boot.biz.common.utils.TreeParser;
@@ -58,6 +59,7 @@ import javax.annotation.Resource;
 import java.io.Serializable;
 import java.lang.reflect.Field;
 import java.lang.reflect.Method;
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -3446,6 +3448,132 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
 		return iFirefightersPostService.list(queryWrapper);
 	}
 
+	@Override
+	public RiskBizInfoVo getPersonInfo(String id, String type) {
+		RiskBizInfoVo riskBizInfoVo = new RiskBizInfoVo();
+		if ("personInfo".equals(type)) {
+			PeopleInfoDto peopleInfoDto =iOrgUsrService.selectPeopleById(Long.valueOf(id));
+		   return getRiskBizInfo(riskBizInfoVo,peopleInfoDto, id);
+		} else {
+			LambdaQueryWrapper<OrgUsr> queryWrapper = new LambdaQueryWrapper<>();
+			queryWrapper.eq(OrgUsr::getAmosOrgId,id);
+			OrgUsr orgUsr = iOrgUsrService.getOne(queryWrapper);
+			PeopleInfoDto peopleInfoDto =iOrgUsrService.selectPeopleById(orgUsr.getSequenceNbr());
+			return getRiskBizInfo(riskBizInfoVo,peopleInfoDto,String.valueOf(orgUsr.getSequenceNbr()));
+		}
+	}
+
+	@Override
+	public void updatePersonStatus(String status, String id) {
+		orgUsrMapper.updatePersonStatus(status,id);
+	}
+
+	private RiskBizInfoVo getRiskBizInfo(RiskBizInfoVo riskBizInfoVo, PeopleInfoDto peopleInfoDto,String id) {
+		riskBizInfoVo.setWarningObjectName(peopleInfoDto.getFirefighters().getName());
+		riskBizInfoVo.setWarningObjectCode(id); // 存为cb_org_user 表id 返回给idx 为附码业务后续处理
+		riskBizInfoVo.setSourceAttribution(peopleInfoDto.getFirefighters().getBizOrgCode());
+		riskBizInfoVo.setSourceAttributionDesc(peopleInfoDto.getFirefighters().getBizOrgName());
+		try {
+			riskBizInfoVo.setWarningTime(DateUtils.dateFormat(new Date(), DateUtils.DATE_TIME_PATTERN));
+		} catch (ParseException e) {
+			e.printStackTrace();
+		}
+
+		List<RiskDynamicDetailsVo> detailsVos = new ArrayList<>();
+		RiskDynamicDetailsVo dynamicDetailsVo = new RiskDynamicDetailsVo();
+		dynamicDetailsVo.setTabName("人员基本信息");
+		List<TableContentVo> contentVos = new ArrayList<>();
+		for (DynamicLabelEnum u : DynamicLabelEnum.values()) {
+			TableContentVo contentVo = new TableContentVo();
+			contentVo.setKey(u.getCode());
+			switch (u.getCode()) {
+				case "name":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getName());
+					contentVo.setType("text");
+					break;
+				case "personNumber":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getPersonNumber());
+					contentVo.setType("text");
+					break;
+				case "bizOrgName":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getBizOrgName());
+					contentVo.setType("text");
+					break;
+				case "peopleType":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getPeopleType());
+					contentVo.setType("text");
+					break;
+				case "mobilePhone":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getMobilePhone());
+					contentVo.setType("text");
+					break;
+				case "gender":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getGender());
+					contentVo.setType("text");
+					break;
+				case "certificatesType":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getCertificatesType());
+					contentVo.setType("text");
+					break;
+				case "certificatesNumber":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getCertificatesNumber());
+					contentVo.setType("text");
+					break;
+				case "jobTitle":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getPostEduDtoObj().getFirefightersPost().getJobTitle());
+					contentVo.setType("text");
+					break;
+				case "postQualification":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getPostEduDtoObj().getFirefightersPost().getPostQualification());
+					contentVo.setType("text");
+					break;
+				case "fireManagementPost":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getPostEduDtoObj().getFirefightersPost().getFireManagementPost());
+					contentVo.setType("text");
+					break;
+				case "amosName":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getAmosName());
+					contentVo.setType("text");
+					break;
+				case "state":
+					contentVo.setLabel(u.getDescribe());
+					contentVo.setValue(peopleInfoDto.getFirefighters().getState());
+					contentVo.setType("text");
+					break;
+				case "birthdayTime":
+					contentVo.setLabel(u.getDescribe());
+					try {
+						contentVo.setValue(DateUtils.dateFormat(peopleInfoDto.getFirefighters().getBirthdayTime(), DateUtils.DATE_TIME_PATTERN));
+					} catch (ParseException e) {
+						e.printStackTrace();
+					}
+					contentVo.setType("text");
+					break;
+				default:
+					log.debug("方法参数错误 !!!");
+					break;
+			}
+			contentVos.add(contentVo);
+		}
+
+		dynamicDetailsVo.setTabContent(contentVos);
+		detailsVos.add(dynamicDetailsVo);
+		riskBizInfoVo.setDynamicDetails(detailsVos);
+		return riskBizInfoVo;
+	}
+
 
 	public IPage<Map<String, Object>> getUserByPeopleType(String pageNum, String pageSize, Map<String, Object> map) {
 		IPage<Map<String, Object>> pageBean = null;

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/RiskController.java

+package com.yeejoin.amos.boot.module.jcs.biz.controller;
+
+
+import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService;
+import com.yeejoin.amos.boot.module.common.biz.utils.CommonResponseUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+@Api(tags = "风险相关")
+@RestController
+@RequestMapping("/riskSource")
+public class RiskController {
+
+    @Autowired
+    private IOrgUsrService orgUsrService;
+
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(value = "获取人员信息详情发送至风险", notes = "获取人员信息详情发送至风险")
+    @RequestMapping(value = "/risk/person/detail", produces = "application/json;charset=UTF-8", method = RequestMethod.GET)
+    public ResponseModel getPersonDetailById(@RequestParam(value = "source") String source,
+                                                 @RequestParam(value = "id") String id
+                                                ) {
+        return CommonResponseUtil.success(orgUsrService.getPersonInfo(id,source));
+    }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @ApiOperation(value = "人员附码状态回显", notes = "人员附码状态回显")
+    @RequestMapping(value = "/update/person/status", produces = "application/json;charset=UTF-8", method = RequestMethod.GET)
+    public ResponseModel updatePersonStatus(@RequestParam(value = "status") String status,
+                                             @RequestParam(value = "id") String id
+    ) {
+        orgUsrService.updatePersonStatus(status,id);
+        return CommonResponseUtil.success();
+    }
+
+}