Merge branch 'developer' of 172.16.10.76:moa/amos-boot-biz into develop

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

@@ -181,7 +181,7 @@ public interface IOrgUsrService {
 
     List<OrgUsrExcelDto> exportToExcel();
 
-    UserUnitDto getUserUnit(String id, String type, String code);
+    UserUnitDto getUserUnit(String userId);
 
 	/**
 	 * 根据登陆人获取公司部门人员树

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/FirefightersPostController.java

@@ -16,6 +16,7 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -36,163 +37,180 @@ import com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersWorkexpe
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 
-
 /**
-* 岗位信息
-*
-* @author tb
-* @date 2021-06-07
-*/
+ * 岗位信息
+ *
+ * @author tb
+ * @date 2021-06-07
+ */
 @RestController
 @Api(tags = "岗位信息Api")
 @RequestMapping(value = "/firefighters-post")
 public class FirefightersPostController extends BaseController {
 
-    @Autowired
-    FirefightersPostServiceImpl iFirefightersPostService;
-    @Autowired
-    FirefightersContactsServiceImpl ifirefightersContactsService;
-    @Autowired
-    FirefightersEducationServiceImpl ifirefightersEducationService;
-    @Autowired
-    FirefightersWorkexperienceServiceImpl ifirefightersWorkexperienceService;
-    @Autowired
-    RedisUtils redisUtils;
-    @Value("${redis.cache.failure.time}")
-    private long time;
-    /**
-    * 新增岗位信息
-    * @return
-    */
-    @TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/save", method = RequestMethod.POST)
-    @ApiOperation(httpMethod = "POST", value = "新增岗位信息", notes = "新增岗位信息")
-    @Transactional
-    public ResponseModel<Object> saveFirefightersPost(@RequestBody FirefightersDataDto firefightersDataDto) {
-        try {
-            iFirefightersPostService.save(firefightersDataDto.getFirefightersPost());
-            ifirefightersWorkexperienceService.save(firefightersDataDto.getFirefightersWorkexperience());
-            ifirefightersEducationService.save(firefightersDataDto.getFirefightersEducation());
-		    		 return ResponseHelper.buildResponse(null);  
-		    } catch (Exception e) {
-				
-				throw new RuntimeException("系统异常");
-			}	 
-     }
-
-    /**
-    * 根据id删除
-    * @param id
-    * @return
-    */
-    @TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
-    @ApiOperation(httpMethod = "DELETE", value = "根据消防人员id删除岗位和学历信息", notes = "根据 id删除")
-    @Transactional
-    public ResponseModel<Object> deleteById(@PathVariable Long id){
-	    try {
-	    	iFirefightersPostService.update(new UpdateWrapper<FirefightersPost>().eq("firefighters_id", id).set("is_delete", 1));
-	    	ifirefightersWorkexperienceService.update(new UpdateWrapper<FirefightersWorkexperience>().eq("firefighters_id", id).set("is_delete", 1));
-	    	ifirefightersEducationService.update(new UpdateWrapper<FirefightersEducation>().eq("firefighters_id", id).set("is_delete", 1));
-	        //删除缓存
-	        redisUtils.del(RedisKey.EDUCATION_POST_EXPERIENCE_FIREFIGHTERS_ID+id);
-	    	return ResponseHelper.buildResponse(null); 
-	    } catch (Exception e) {
-			
-			throw new RuntimeException("系统异常");
-		}	 
-    }
-
-    /**
-    * 修改岗位信息
-    * @return
-    */
-    @TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/updateById", method = RequestMethod.PUT)
-    @ApiOperation(httpMethod = "PUT", value = "修改岗位信息", notes = "修改岗位信息")
-    @Transactional
-    public ResponseModel<Object> updateByIdFirefightersPost(@RequestBody FirefightersDataDto firefightersDataDto) {
-	     try {
-             FirefightersPost firefightersPost = firefightersDataDto.getFirefightersPost();
-             iFirefightersPostService.updateById(firefightersPost);
-             ifirefightersWorkexperienceService.updateById(firefightersDataDto.getFirefightersWorkexperience());
-             ifirefightersEducationService.updateById(firefightersDataDto.getFirefightersEducation());
-             //删除缓存
-             redisUtils.del(RedisKey.EDUCATION_POST_EXPERIENCE_FIREFIGHTERS_ID + firefightersPost.getSequenceNbr());
-             return ResponseHelper.buildResponse(null);
-	    } catch (Exception e) {
-			
-			throw new RuntimeException("系统异常");
-		}	 
-    }
-
+	@Autowired
+	FirefightersPostServiceImpl iFirefightersPostService;
+	@Autowired
+	FirefightersContactsServiceImpl ifirefightersContactsService;
+	@Autowired
+	FirefightersEducationServiceImpl ifirefightersEducationService;
+	@Autowired
+	FirefightersWorkexperienceServiceImpl ifirefightersWorkexperienceService;
+	@Autowired
+	RedisUtils redisUtils;
+	@Value("${redis.cache.failure.time}")
+	private long time;
+
+	/**
+	 * 新增岗位信息
+	 * 
+	 * @return
+	 */
+	@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
+	@RequestMapping(value = "/save", method = RequestMethod.POST)
+	@ApiOperation(httpMethod = "POST", value = "新增岗位信息", notes = "新增岗位信息")
+	@Transactional
+	public ResponseModel<Object> saveFirefightersPost(@RequestBody FirefightersDataDto firefightersDataDto) {
+		try {
+			/*---------修改bug:2179   解決崗位与学历可以重复添加导致的列表页展示消防人员信息呈现多条的情况  on 2021-08-21 陈浩---start*/
+			LambdaQueryWrapper<FirefightersPost> queryWrapper = new LambdaQueryWrapper<FirefightersPost>();
+			queryWrapper.eq(FirefightersPost::getFirefightersId, firefightersDataDto.getFirefightersPost().getFirefightersId());
+			FirefightersPost firefightersPost = iFirefightersPostService.getOne(queryWrapper);
+
+			if (firefightersPost == null) {
+				iFirefightersPostService.save(firefightersDataDto.getFirefightersPost());
+			} else {
+				iFirefightersPostService.update(firefightersDataDto.getFirefightersPost(), queryWrapper);
+			}
+			// iFirefightersPostService.save(firefightersDataDto.getFirefightersPost());
+			/*---------修改bug:2179   解決崗位与学历可以重复添加导致的列表页展示消防人员信息呈现多条的情况  on 2021-08-21 陈浩---end*/
+			ifirefightersWorkexperienceService.save(firefightersDataDto.getFirefightersWorkexperience());
+			ifirefightersEducationService.save(firefightersDataDto.getFirefightersEducation());
+			return ResponseHelper.buildResponse(null);
+		} catch (Exception e) {
 
+			throw new RuntimeException("系统异常");
+		}
+	}
+
+	/**
+	 * 根据id删除
+	 * 
+	 * @param id
+	 * @return
+	 */
+	@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
+	@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
+	@ApiOperation(httpMethod = "DELETE", value = "根据消防人员id删除岗位和学历信息", notes = "根据 id删除")
+	@Transactional
+	public ResponseModel<Object> deleteById(@PathVariable Long id) {
+		try {
+			iFirefightersPostService
+					.update(new UpdateWrapper<FirefightersPost>().eq("firefighters_id", id).set("is_delete", 1));
+			ifirefightersWorkexperienceService.update(
+					new UpdateWrapper<FirefightersWorkexperience>().eq("firefighters_id", id).set("is_delete", 1));
+			ifirefightersEducationService
+					.update(new UpdateWrapper<FirefightersEducation>().eq("firefighters_id", id).set("is_delete", 1));
+			// 删除缓存
+			redisUtils.del(RedisKey.EDUCATION_POST_EXPERIENCE_FIREFIGHTERS_ID + id);
+			return ResponseHelper.buildResponse(null);
+		} catch (Exception e) {
 
-    /**
-    * 根据id查询
-    * @param id
-    * @return
-    */
-    @SuppressWarnings("unchecked")
+			throw new RuntimeException("系统异常");
+		}
+	}
+
+	/**
+	 * 修改岗位信息
+	 * 
+	 * @return
+	 */
 	@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
-    @ApiOperation(httpMethod = "GET", value = "根据消防员id查询", notes = "根据消防员id查询")
-    public ResponseModel<Object> selectById(@PathVariable Long id){
-            @SuppressWarnings("rawtypes")
-            QueryWrapper queryWrapper=new QueryWrapper<>();
-            queryWrapper.eq("firefighters_id", id);
-        FirefightersDataDto firefightersDataDto = new FirefightersDataDto(ifirefightersWorkexperienceService.getOne(queryWrapper), ifirefightersEducationService.getOne(queryWrapper), iFirefightersPostService.getOne(queryWrapper));
-        return ResponseHelper.buildResponse(firefightersDataDto);
-    }
-
-
-
-    /**
-    * 列表分页查询
-    * @return
-    */
-    @TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/list", method = RequestMethod.GET)
-    @ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
-    public IPage<FirefightersPost> listPage(String pageNum,String pageSize, FirefightersPost firefightersPost){
-
-        Page<FirefightersPost> pageBean;
-        QueryWrapper<FirefightersPost> firefightersPostQueryWrapper = new QueryWrapper<>();
-        Class<? extends FirefightersPost> aClass = firefightersPost.getClass();
-        Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
-            try {
-                field.setAccessible(true);
-                Object o = field.get(firefightersPost);
-                if (o != null) {
-                    Class<?> type = field.getType();
-                    String name = NameUtils.camel2Underline(field.getName());
-                    if (type.equals(Integer.class)) {
-                        Integer fileValue = (Integer) field.get(firefightersPost);
-                        firefightersPostQueryWrapper.eq(name, fileValue);
-                    } else if (type.equals(Long.class)) {
-                        Long fileValue = (Long) field.get(firefightersPost);
-                        firefightersPostQueryWrapper.eq(name, fileValue);
-                    } else if (type.equals(String.class)) {
-                        String fileValue = (String) field.get(firefightersPost);
-                        firefightersPostQueryWrapper.eq(name, fileValue);
-                    } else {
-                    	if(!name.equals(NameUtils.camel2Underline("serialVersionUID"))) {
-                        String fileValue = (String) field.get(firefightersPost);
-                        firefightersPostQueryWrapper.eq(name, fileValue);
-                    }}
-                }
-            } catch (Exception e) {
-                throw  new RuntimeException("系统异常");
-            }
-        });
-        IPage<FirefightersPost> page;
-        if (StringUtils.isBlank(pageNum) || StringUtils.isBlank(pageSize)) {
-            pageBean = new Page<>(0, Long.MAX_VALUE);
-        } else {
-            pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
-        }
-        page = iFirefightersPostService.page(pageBean, firefightersPostQueryWrapper);
-            return page;
-        }
-    }
+	@RequestMapping(value = "/updateById", method = RequestMethod.PUT)
+	@ApiOperation(httpMethod = "PUT", value = "修改岗位信息", notes = "修改岗位信息")
+	@Transactional
+	public ResponseModel<Object> updateByIdFirefightersPost(@RequestBody FirefightersDataDto firefightersDataDto) {
+		try {
+			FirefightersPost firefightersPost = firefightersDataDto.getFirefightersPost();
+			iFirefightersPostService.updateById(firefightersPost);
+			ifirefightersWorkexperienceService.updateById(firefightersDataDto.getFirefightersWorkexperience());
+			ifirefightersEducationService.updateById(firefightersDataDto.getFirefightersEducation());
+			// 删除缓存
+			redisUtils.del(RedisKey.EDUCATION_POST_EXPERIENCE_FIREFIGHTERS_ID + firefightersPost.getSequenceNbr());
+			return ResponseHelper.buildResponse(null);
+		} catch (Exception e) {
 
+			throw new RuntimeException("系统异常");
+		}
+	}
+
+	/**
+	 * 根据id查询
+	 * 
+	 * @param id
+	 * @return
+	 */
+	@SuppressWarnings("unchecked")
+	@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
+	@RequestMapping(value = "/{id}", method = RequestMethod.GET)
+	@ApiOperation(httpMethod = "GET", value = "根据消防员id查询", notes = "根据消防员id查询")
+	public ResponseModel<Object> selectById(@PathVariable Long id) {
+		@SuppressWarnings("rawtypes")
+		QueryWrapper queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("firefighters_id", id);
+		FirefightersDataDto firefightersDataDto = new FirefightersDataDto(
+				ifirefightersWorkexperienceService.getOne(queryWrapper),
+				ifirefightersEducationService.getOne(queryWrapper), iFirefightersPostService.getOne(queryWrapper));
+		return ResponseHelper.buildResponse(firefightersDataDto);
+	}
+
+	/**
+	 * 列表分页查询
+	 * 
+	 * @return
+	 */
+	@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
+	@RequestMapping(value = "/list", method = RequestMethod.GET)
+	@ApiOperation(httpMethod = "GET", value = "列表分页查询", notes = "列表分页查询")
+	public IPage<FirefightersPost> listPage(String pageNum, String pageSize, FirefightersPost firefightersPost) {
+
+		Page<FirefightersPost> pageBean;
+		QueryWrapper<FirefightersPost> firefightersPostQueryWrapper = new QueryWrapper<>();
+		Class<? extends FirefightersPost> aClass = firefightersPost.getClass();
+		Arrays.stream(aClass.getDeclaredFields()).forEach(field -> {
+			try {
+				field.setAccessible(true);
+				Object o = field.get(firefightersPost);
+				if (o != null) {
+					Class<?> type = field.getType();
+					String name = NameUtils.camel2Underline(field.getName());
+					if (type.equals(Integer.class)) {
+						Integer fileValue = (Integer) field.get(firefightersPost);
+						firefightersPostQueryWrapper.eq(name, fileValue);
+					} else if (type.equals(Long.class)) {
+						Long fileValue = (Long) field.get(firefightersPost);
+						firefightersPostQueryWrapper.eq(name, fileValue);
+					} else if (type.equals(String.class)) {
+						String fileValue = (String) field.get(firefightersPost);
+						firefightersPostQueryWrapper.eq(name, fileValue);
+					} else {
+						if (!name.equals(NameUtils.camel2Underline("serialVersionUID"))) {
+							String fileValue = (String) field.get(firefightersPost);
+							firefightersPostQueryWrapper.eq(name, fileValue);
+						}
+					}
+				}
+			} catch (Exception e) {
+				throw new RuntimeException("系统异常");
+			}
+		});
+		IPage<FirefightersPost> page;
+		if (StringUtils.isBlank(pageNum) || StringUtils.isBlank(pageSize)) {
+			pageBean = new Page<>(0, Long.MAX_VALUE);
+		} else {
+			pageBean = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
+		}
+		page = iFirefightersPostService.page(pageBean, firefightersPostQueryWrapper);
+		return page;
+	}
+}

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/OrgUsrController.java

@@ -360,14 +360,14 @@ public class OrgUsrController extends BaseController {
     /**
      * 获取用户单位归属
      *
-     * @param id
+     * @param userId
      * @return
      */
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/getUserUnit", method = RequestMethod.GET)
+    @RequestMapping(value = "/{userId}/userUnit", method = RequestMethod.GET)
     @ApiOperation(httpMethod = "GET", value = "获取用户单位归属", notes = "获取用户单位归属")
-    public ResponseModel<UserUnitDto> getUserUnit(@RequestParam String id, @RequestParam String type, @RequestParam String code) {
-        return ResponseHelper.buildResponse(iOrgUsrService.getUserUnit(id, type, code));
+    public ResponseModel<UserUnitDto> getUserUnit(@PathVariable String userId) {
+        return ResponseHelper.buildResponse(iOrgUsrService.getUserUnit(userId));
     }
 
 }
\ No newline at end of file

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

@@ -46,6 +46,11 @@ import java.util.stream.Collectors;
 
 @Service
 public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapper> implements IOrgUsrService {
+
+    private static final String TYPE = "PERSON,COMPANY";
+
+    private static final String CODE = "amosAccount";
+
     @Autowired
     DynamicFormInstanceServiceImpl alertFormValueServiceImpl;
     @Autowired
@@ -1003,13 +1008,13 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
     }
 
     @Override
-    public UserUnitDto getUserUnit(String id, String type, String code) {
-        if (StringUtils.isNotBlank(id) && StringUtils.isNotBlank(type) && StringUtils.isNotBlank(code)) {
-            String[] typeArr = type.split(",");
+    public UserUnitDto getUserUnit(String userId) {
+        if (StringUtils.isNotBlank(userId)) {
+            String[] typeArr = TYPE.split(",");
             //	业主单位
-            List<UserUnitDto> list = orgUsrMapper.getUserUnit(id, typeArr[0], null);
+            List<UserUnitDto> list = orgUsrMapper.getUserUnit(userId, typeArr[0], null);
             //     维保单位
-            List<DynamicFormInstance> instanceList = alertFormValueServiceImpl.getInstanceByCodeAndValue(code, id);
+            List<DynamicFormInstance> instanceList = alertFormValueServiceImpl.getInstanceByCodeAndValue(CODE, userId);
             if (!CollectionUtils.isEmpty(list) && !CollectionUtils.isEmpty(instanceList)) {
                 throw new RuntimeException("人员绑定单位重复！");
             } else {

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/FireTeamServiceImpl.java

@@ -6,6 +6,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
+import com.yeejoin.amos.boot.biz.common.entity.DataDictionary;
+import com.yeejoin.amos.boot.biz.common.service.impl.DataDictionaryServiceImpl;
 import com.yeejoin.amos.boot.biz.common.utils.Menu;
 import com.yeejoin.amos.boot.biz.common.utils.MenuFrom;
 import com.yeejoin.amos.boot.biz.common.utils.TreeParser;
@@ -56,6 +58,9 @@ public class FireTeamServiceImpl extends BaseService<FireTeamDto, FireTeam, Fire
     @Autowired
     OrgUsrServiceImpl orgUsrService;
 
+    @Autowired
+    DataDictionaryServiceImpl iDataDictionaryService;
+
     /**
      * 获取监控大队列表
      *
@@ -185,6 +190,11 @@ public class FireTeamServiceImpl extends BaseService<FireTeamDto, FireTeam, Fire
             FireTeam parentTeam = getById(fireTeam.getParent());
             fireTeam.setTreeCode(parentTeam.getTreeCode() + TreeParser.genTreeCode());
         }
+
+        DataDictionary dataDictionary = iDataDictionaryService.getById(fireTeam.getTypeCode());
+        if(null !=dataDictionary ) {
+            fireTeam.setType(dataDictionary.getName());
+        }
         if (ValidationUtil.isEmpty(fireTeam.getSequenceNbr())) {
             save(fireTeam);
         } else {