From 66e4211cbfa154a87390b25c93b32d722e0d690c Mon Sep 17 00:00:00 2001 From: xiang <5914123@qq.com> Date: 星期四, 14 九月 2023 15:22:37 +0800 Subject: [PATCH] Merge branch 'haucheng_panzhihua' of http://gitlab.nhys.cdnhxx.com/root/zhihuishequ into haucheng_panzhihua --- springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionReportMapper.xml | 5 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionRePortFeign.java | 33 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionReportService.java | 26 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessUtil.java | 109 +++ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java | 6 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionInspectionMapper.java | 18 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/QRCodeUtil.java | 108 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java | 12 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java | 5 springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.class | 0 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionUserFeign.java | 35 springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.class | 0 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionUserService.java | 30 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionInspectionServiceImpl.java | 74 ++ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionInspectionDto.java | 109 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.class | 0 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionUserDto.java | 164 ++++ springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionUserApi.java | 69 + springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionInspectionMapper.xml | 5 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionReportApi.java | 61 + springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionAccessMapper.java | 19 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java | 5 springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.class | 0 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/HttpClientUtil.java | 72 ++ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionInspectionFeign.java | 34 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionInspectionApi.java | 51 + springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessConfig.java | 21 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionUserServiceImpl.java | 113 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionReportMapper.java | 17 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionUserMapper.java | 17 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionInspectionApi.java | 65 + springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionReportServiceImpl.java | 76 ++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionInspection.java | 121 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionUser.java | 181 +++++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionInspectionService.java | 27 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionUserApi.java | 47 + springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionUserMapper.xml | 5 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionReport.java | 117 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionReportApi.java | 46 + springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/ServiceUserApplication.java | 1 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/SwaggerConfig.java | 6 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionAccessMapper.xml | 5 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionReportDto.java | 113 +++ springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionAccess.java | 74 ++ 44 files changed, 2,097 insertions(+), 5 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionInspectionApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionInspectionApi.java new file mode 100644 index 0000000..1a69cac --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionInspectionApi.java @@ -0,0 +1,65 @@ +package com.panzhihua.applets.api; + + +import com.panzhihua.common.controller.BaseController; +import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.common.service.community.ComEquipmentUnionInspectionFeign; +import com.panzhihua.common.service.community.ComEquipmentUnionRePortFeign; +import com.panzhihua.common.service.user.UserService; +import io.swagger.annotations.Api; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; + + +@Slf4j +@RestController +@RequestMapping("/unionInspection/") +@Api(tags = {"户外劳工站巡查"}) +public class UnionInspectionApi extends BaseController { + + @Resource + private ComEquipmentUnionInspectionFeign comEquipmentUnionInspectionFeign; + + @Resource + private UserService userService; + + + /** + * 新增户外劳工站巡查 + * + * @param unionInspectionDto + * @return 新增结果 + */ + @PostMapping("/add") + public R add(@RequestBody UnionInspectionDto unionInspectionDto) { +// LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + unionInspectionDto.setCreateUserId(userInfoByUserId.getUserId()); + return comEquipmentUnionInspectionFeign.add(unionInspectionDto); + } + + /** + * 分页户外劳工站巡查 + * + * @param unionInspectionDto + * @return 动态结果 + */ + @PostMapping("/query") + public R query(@RequestBody UnionInspectionDto unionInspectionDto) { + // LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + unionInspectionDto.setCreateUserId(userInfoByUserId.getUserId()); + unionInspectionDto.setIsApplets(1); + return comEquipmentUnionInspectionFeign.query(unionInspectionDto); + } +} \ No newline at end of file diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionReportApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionReportApi.java new file mode 100644 index 0000000..ad7ef73 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionReportApi.java @@ -0,0 +1,61 @@ +package com.panzhihua.applets.api; + + +import com.panzhihua.common.controller.BaseController; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.common.service.community.ComEquipmentUnionRePortFeign; +import com.panzhihua.common.service.community.ComEquipmentUnionUserFeign; +import com.panzhihua.common.service.user.UserService; +import io.swagger.annotations.Api; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; + + +@Slf4j +@RestController +@RequestMapping("/unionReport/") +@Api(tags = {"户外劳工站上报"}) +public class UnionReportApi extends BaseController { + + @Resource + private ComEquipmentUnionRePortFeign comEquipmentUnionRePortFeign; + + @Resource + private UserService userService; + + + /** + * 户外劳工站上报表 + * + * @param unionReportDto + * @return 新增结果 + */ + @PostMapping("/add") + public R add(@RequestBody UnionReportDto unionReportDto) { +// LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + unionReportDto.setCreateUserId(userInfoByUserId.getUserId()); + return comEquipmentUnionRePortFeign.add(unionReportDto); + } + + /** + * 分页户外劳工站上报表 + * + * @param unionReportDto + * @return 动态结果 + */ + @PostMapping("/query") + public R query(@RequestBody UnionReportDto unionReportDto) { + // LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + unionReportDto.setCreateUserId(userInfoByUserId.getUserId()); + unionReportDto.setIsApplets(1); + return comEquipmentUnionRePortFeign.query(unionReportDto); + } +} \ No newline at end of file diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionUserApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionUserApi.java new file mode 100644 index 0000000..71f223b --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionUserApi.java @@ -0,0 +1,69 @@ +package com.panzhihua.applets.api; + + +import com.panzhihua.common.constants.TokenConstant; +import com.panzhihua.common.controller.BaseController; +import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; +import com.panzhihua.common.model.dtos.equipment.UnionUserDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.common.model.vos.community.acid.ComActAcidRecordVO; +import com.panzhihua.common.service.community.ComEquipmentUnionOutdoorSiteFeign; +import com.panzhihua.common.service.community.ComEquipmentUnionUserFeign; +import com.panzhihua.common.service.user.UserService; +import com.panzhihua.common.utlis.JWTTokenUtil; +import io.jsonwebtoken.Claims; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; + + +@Slf4j +@RestController +@RequestMapping("/unionUser/") +@Api(tags = {"户外劳工站登录"}) +public class UnionUserApi extends BaseController { + + @Resource + private ComEquipmentUnionUserFeign comEquipmentUnionUserFeign; + + @Resource + private UserService userService; + + + /** + * 总工会户外劳登录 + * + * + * @return 总工会户外劳共用户 + */ + @ApiOperation(value = "总工会户外劳登录",response = UnionUserDto.class) + @GetMapping("/login") + public R login(){ +// LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + return comEquipmentUnionUserFeign.login(userInfoByUserId); + } + + /** + * 总工会户外劳工站用户认证 + * + * @param unionUserDto + * @return 总工会户外劳共用户 + */ + @ApiOperation(value = "总工会户外劳工站用户认证",response = UnionUserDto.class) + @PostMapping("/authentication") + public R authentication(@RequestBody UnionUserDto unionUserDto){ + // LoginUserInfoVO loginUser = this.getLoginUserInfo(); +// LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId(loginUser.getUserId().toString()).getData(); + LoginUserInfoVO userInfoByUserId = userService.getUserInfoByUserId("1588095866109984769").getData(); + unionUserDto.setUserId(userInfoByUserId.getUserId()); +// unionUserDto.setId(userInfoByUserId.getId); + return comEquipmentUnionUserFeign.authentication(unionUserDto); + } +} \ No newline at end of file diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/SwaggerConfig.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/SwaggerConfig.java index f4e26f2..c19f4ab 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/SwaggerConfig.java +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/SwaggerConfig.java @@ -22,9 +22,9 @@ public class SwaggerConfig { @Bean public Docket createRestApi() { - return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()).select() - .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class)) - .apis(RequestHandlerSelectors.basePackage("com.panzhihua")).paths(PathSelectors.any()).build(); + return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()).enable(true).select() +// .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class)) + .apis(RequestHandlerSelectors.basePackage("com.panzhihua.applets")).build(); } private ApiInfo apiInfo() { diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionInspectionDto.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionInspectionDto.java new file mode 100644 index 0000000..c55a8d4 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionInspectionDto.java @@ -0,0 +1,109 @@ +package com.panzhihua.common.model.dtos.equipment; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.time.LocalDateTime; +@Data +@ApiModel("户外劳工站巡查表") +public class UnionInspectionDto { + + /** + * ,主键 + */ + @ApiModelProperty(value = "主键") + private Integer id; + + /** + * 创建人户外劳工站id + */ + @ApiModelProperty(value = "创建人户外劳工站id") + private Long createUnionUserId; + + /** + * 站点id + */ + @ApiModelProperty(value = "站点id") + private Integer siteId; + + /** + * 创建人id + */ + @ApiModelProperty(value = "创建人id") + private Long createUserId; + + /** + * 类型(1正常2异常) + */ + @ApiModelProperty(value = "类型(1正常2异常)") + private Integer type; + + /** + * 内容 + */ + @ApiModelProperty(value = "内容") + private String content; + + /** + * 图片地址 + */ + @ApiModelProperty(value = "图片地址") + private String url; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 标题 + */ + @ApiModelProperty(value = "标题") + private String title; + + /** + * 处理人户外劳工站id + */ + @ApiModelProperty(value = "处理人户外劳工站id") + private Integer disposeUnionUserId; + + /** + * 处理内容 + */ + @ApiModelProperty(value = "处理内容") + private String disposeContent; + + /** + * 处理时间 + */ + @ApiModelProperty(value = "处理时间") + private LocalDateTime disposeAt; + + /** + * 处理照片地址 + */ + @ApiModelProperty(value = "处理照片地址") + private String disposeUrl; + + /** + * 状态(1未回复2已回复) + */ + @ApiModelProperty(value = "状态(1未接单2已接单3已解决)") + private Integer status; + + + /** + * 是否小程序 + */ + @ApiModelProperty(value = "是否小程序 1是 0否") + private Integer isApplets; + + @ApiModelProperty(value = "分页-当前页数", example = "1") + private Long pageNum = 1L; + + @ApiModelProperty(value = "分页-每页记录数", example = "10") + private Long pageSize = 10L; + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java index 97bd829..4367726 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java @@ -164,6 +164,12 @@ private String mobilePhone; /** + * 关键词 + */ + @ApiModelProperty(value = "关键词") + private String keyWord; + + /** * 服务范围 */ @ApiModelProperty(value = "服务范围") diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionReportDto.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionReportDto.java new file mode 100644 index 0000000..79d8623 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionReportDto.java @@ -0,0 +1,113 @@ +package com.panzhihua.common.model.dtos.equipment; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.time.LocalDateTime; + +@Data +@ApiModel("户外劳工站上报表") +public class UnionReportDto { + + private static final long serialVersionUID = 1L; + + /** + * ,主键 + */ + @ApiModelProperty(value = "主键") + private Integer id; + + /** + * 创建人户外劳工站id + */ + @ApiModelProperty(value = "创建人户外劳工站id") + private Long createUnionUserId; + + /** + * 站点id + */ + @ApiModelProperty(value = "站点id") + private Integer siteId; + + /** + * 创建人id + */ + @ApiModelProperty(value = "创建人id") + private Long createUserId; + + + /** + * 类型(1意见反馈2故障保修) + */ + @ApiModelProperty(value = "类型(1意见反馈2故障保修)") + private Integer type; + + /** + * 内容 + */ + @ApiModelProperty(value = "内容") + private String content; + + /** + * 图片地址 + */ + @ApiModelProperty(value = "图片地址") + private String url; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 标题 + */ + @ApiModelProperty(value = "标题") + private String title; + + /** + * 处理人户外劳工站id + */ + @ApiModelProperty(value = "处理人户外劳工站id") + private Integer disposeUnionUserId; + + /** + * 处理内容 + */ + @ApiModelProperty(value = "处理内容") + private String disposeContent; + + /** + * 处理时间 + */ + @ApiModelProperty(value = "处理时间") + private LocalDateTime disposeAt; + + /** + * 处理照片地址 + */ + @ApiModelProperty(value = "处理照片地址") + private String disposeUrl; + + /** + * 是否小程序 + */ + @ApiModelProperty(value = "是否小程序 1是 0否") + private Integer isApplets; + + /** + * 状态(1未回复2已回复) + */ + @ApiModelProperty(value = "状态(1未回复2已回复)") + private Integer status; + + + @ApiModelProperty(value = "分页-当前页数", example = "1") + private Long pageNum = 1L; + + @ApiModelProperty(value = "分页-每页记录数", example = "10") + private Long pageSize = 10L; + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionUserDto.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionUserDto.java new file mode 100644 index 0000000..01f8b96 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionUserDto.java @@ -0,0 +1,164 @@ +package com.panzhihua.common.model.dtos.equipment; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.time.LocalDateTime; + +@Data +@ApiModel("总工会户外劳工站") +public class UnionUserDto { + + private static final long serialVersionUID = 1L; + + /** + * 主键id + */ + @ApiModelProperty(value = "主键id") + private Long id; + + /** + * () + */ + @ApiModelProperty(value = "姓名") + private String name; + + /** + *商家名称 + */ + @ApiModelProperty(value = "商家名称") + private String sex; + + /** + * 联系方式 + */ + @ApiModelProperty(value = "联系方式") + private String phone; + + /** + * 人员类型(1、普通工会用户 2、巡查人员 3、站点负责人 + */ + @ApiModelProperty(value = "人员类型(1、普通工会用户 2、巡查人员 3、站点负责人 ") + private String type; + + /** + * 删除标识 + */ + @ApiModelProperty(value = "删除标识") + private Boolean deleteFlag; + + /** + * 备注 + */ + @ApiModelProperty(value = "备注") + private String remark; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 更新时间 + */ + @ApiModelProperty(value = "更新时间") + private LocalDateTime updateAt; + + /** + * 修改用户 + */ + @ApiModelProperty(value = "修改用户") + private Long updateBy; + + /** + * 创建用户 + */ + @ApiModelProperty(value = "创建用户") + private Long createBy; + + /** + * 认证照片地址 + */ + @ApiModelProperty(value = "认证照片地址") + private String certifiedPhotoUrl; + + /** + * 微信小程序唯一标识 + */ + @ApiModelProperty(value = "微信小程序唯一标识") + private String openid; + + /** + * 身份证号 + */ + @ApiModelProperty(value = "身份证号") + private String idCard; + + /** + * 1 启用 2 禁用 + */ + @ApiModelProperty(value = "1 启用 2 禁用") + private Integer status; + + /** + * 账号 + */ + @ApiModelProperty(value = "账号") + private String account; + + /** + * 昵称 + */ + @ApiModelProperty(value = "昵称") + private String nickName; + + /** + * 密码 + */ + @ApiModelProperty(value = "密码") + private String password; + + /** + * 头像 + */ + @ApiModelProperty(value = "头像") + private String imageUrl; + + /** + * 站点id(普通用户为空) + */ + @ApiModelProperty(value = " 站点id(普通用户为空)") + private Integer siteId; + + @ApiModelProperty("花城user_id") + private Long userId; + + + /** + * 区域编码 + */ + @ApiModelProperty(value = "区域编码") + private String areaCode; + + /** + * 是否认证 + */ + @ApiModelProperty(value = " 是否认证0否1认证") + private Integer isAuthenticated; + + /** + * 认证图片地址 + */ + @ApiModelProperty(value = " 认证图片地址") + private String authenticatedUrl; + + /** + * 认证图片地址(base_64) + */ + @ApiModelProperty(value = " 认证图片地址(base_64)") + private String authenticatedUrlBase; + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionInspectionFeign.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionInspectionFeign.java new file mode 100644 index 0000000..032ace6 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionInspectionFeign.java @@ -0,0 +1,34 @@ +package com.panzhihua.common.service.community; + +import com.panzhihua.common.constants.Constants; +import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.R; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; + +@FeignClient(name = Constants.SERVICE_EQUIPMENT, contextId = "unionInspection", path = "unionInspection") +public interface ComEquipmentUnionInspectionFeign { + + + /** + * 新增户外劳工站巡查 + * + * @param unionInspectionDto + * @return 新增结果 + */ + @PostMapping("/add") + R add(UnionInspectionDto unionInspectionDto); + + + /** + * 分页户外劳工站巡查 + * + * @param unionInspectionDto + * @return 动态结果 + */ + @PostMapping("/query") + R query(UnionInspectionDto unionInspectionDto); + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionRePortFeign.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionRePortFeign.java new file mode 100644 index 0000000..19fa7a7 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionRePortFeign.java @@ -0,0 +1,33 @@ +package com.panzhihua.common.service.community; + +import com.panzhihua.common.constants.Constants; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; + +@FeignClient(name = Constants.SERVICE_EQUIPMENT, contextId = "unionReport", path = "unionReport") +public interface ComEquipmentUnionRePortFeign { + + /** + * 总工会户外劳登录 + * + * @param unionReportDto + * @return 总工会户外劳工上报 + */ + @PostMapping("/add") + R add(UnionReportDto unionReportDto); + + + /** + * 分页户外劳工站上报表 + * + * @param unionReportDto + * @return 动态结果 + */ + @PostMapping("/query") + R query(UnionReportDto unionReportDto); + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionUserFeign.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionUserFeign.java new file mode 100644 index 0000000..2779a7a --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionUserFeign.java @@ -0,0 +1,35 @@ +package com.panzhihua.common.service.community; + +import com.panzhihua.common.constants.Constants; +import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; +import com.panzhihua.common.model.dtos.equipment.UnionUserDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; + +@FeignClient(name = Constants.SERVICE_EQUIPMENT, contextId = "unionUser", path = "unionUser") +public interface ComEquipmentUnionUserFeign { + + /** + * 总工会户外劳登录 + * + * @param loginUserInfoVO + * @return 总工会户外劳共用户 + */ + @PostMapping("/login") + R login(LoginUserInfoVO loginUserInfoVO); + + /** + * 总工会户外劳工站用户认证 + * + * @param unionUserDto + * @return 总工会户外劳共用户 + */ + @PostMapping("/authentication") + R authentication(UnionUserDto unionUserDto); + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/HttpClientUtil.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/HttpClientUtil.java index 68c3341..2853f1a 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/HttpClientUtil.java +++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/HttpClientUtil.java @@ -264,6 +264,78 @@ } } + + /** + * http请求工具类,post请求 + * + * @param url + * url + * @param param + * 参数值 仅支持String + * @return + * @throws Exception + */ + public static String httpPostAndToken(String url, String param,Map headerMap) throws Exception { + DefaultHttpClient defaultHttpClient = null; + BufferedReader bufferedReader = null; + try { + defaultHttpClient = new DefaultHttpClient(); + HttpPost httpPost = new HttpPost(url); + httpPost.setHeader("Content-Type", "application/json;charset=utf-8"); + httpPost.setHeader("Authorization", headerMap.get("Authorization").toString()); + httpPost.setHeader("Host", headerMap.get("Host").toString()); + + for (Object key : headerMap.keySet()) { + httpPost.setHeader(key.toString(), headerMap.get(key).toString()); + } + if (StringUtils.isNotBlank(param)) { + log.info("参数值:{}", param); + HttpEntity httpEntity = new StringEntity(param, "utf-8"); + httpPost.setEntity(httpEntity); +// httpPost.setHeader("Content-Length", String.valueOf(httpEntity.getContentLength())); + } + HttpResponse httpResponse = defaultHttpClient.execute(httpPost); + if (httpResponse.getStatusLine().getStatusCode() != 200) { + int statusCode = httpResponse.getStatusLine().getStatusCode(); + String errorLog = "请求失败,errorCode:" + httpResponse.getStatusLine().getStatusCode(); + log.info(errorLog); + throw new Exception(url + errorLog); + } + // 读取返回信息 + String output; + bufferedReader = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent(), "utf-8")); + StringBuilder stringBuilder = new StringBuilder(); + while ((output = bufferedReader.readLine()) != null) { + stringBuilder.append(output); + } + log.info("调用接口返回的参数:" + stringBuilder.toString()); + return stringBuilder.toString(); + } catch (IOException e) { + e.printStackTrace(); + throw e; + } finally { + if (defaultHttpClient != null) + defaultHttpClient.getConnectionManager().shutdown(); + if (bufferedReader != null) + bufferedReader.close(); + } + } + + public static void main(String[] args) throws IOException { + DefaultHttpClient defaultHttpClient = new DefaultHttpClient(); + HttpPost httpPost = new HttpPost("https://dptest.d-power.com.cn:14404/v1/face"); +// httpPost.setHeader("Content-Type", "application/json;charset=utf-8"); + httpPost.setHeader("Authorization", "DpToken P3JHgjLbyljfLrFnS9OZbATRJmacdt4b"); + httpPost.setHeader("Host", "123.60.2.66"); +// httpPost.setHeader("Content-Length", String.valueOf(entity.getContentLength())); + +// httpPost.setHeader("User-Agent", "Apache-HttpClient/4.5.12 (Java/1.8.0_162)[\\r][\\n]"); + httpPost.setEntity(new StringEntity("{\"positions\":[{\"role\":\"occupant\",\"communityId\":\"64f99b2ed26106d4f0fe93f4\",\"unitId\":\"64f99b2ed26106d4f0fe93f7\"}],\"tel\":\"15696695118\",\"name\":\"四月里3\",\"timeout\":10,\"image\":\"fsdfsdfsdf\"}", "utf-8")); +// httpPost.setHeader("Content-Length", String.valueOf(entity.getContentLength())); + HttpResponse httpResponse = defaultHttpClient.execute(httpPost); + System.out.println(httpResponse.getEntity()); + } + /** * get请求 * diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionInspectionApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionInspectionApi.java new file mode 100644 index 0000000..068f6d0 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionInspectionApi.java @@ -0,0 +1,51 @@ +package com.panzhihua.service_equipment.api; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import com.panzhihua.service_equipment.service.UnionInspectionService; +import com.panzhihua.service_equipment.service.UnionReportService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; + + +@Slf4j +@RestController +@RequestMapping("/unionInspection") +public class UnionInspectionApi { + + @Resource + private UnionInspectionService unionInspectionService; + + + + /** + * 新增户外劳工站巡查 + * + * @param unionInspectionDto + * @return 新增结果 + */ + @PostMapping("/add") + public R add(@RequestBody UnionInspectionDto unionInspectionDto) { + return unionInspectionService.add(unionInspectionDto); + } + + + /** + * 分页户外劳工站巡查 + * + * @param unionInspectionDto + * @return 动态结果 + */ + @PostMapping("/query") + public R<IPage<UnionReport>> query(@RequestBody UnionInspectionDto unionInspectionDto) { + return unionInspectionService.query(unionInspectionDto); + } +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionReportApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionReportApi.java new file mode 100644 index 0000000..2ccd69a --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionReportApi.java @@ -0,0 +1,46 @@ +package com.panzhihua.service_equipment.api; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import com.panzhihua.service_equipment.service.UnionReportService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; + +@Slf4j +@RestController +@RequestMapping("/unionReport") +public class UnionReportApi { + + @Resource + private UnionReportService unionReportService; + + /** + * 户外劳工站上报表 + * + * @param unionReportDto + * @return 新增结果 + */ + @PostMapping("/add") + public R add(@RequestBody UnionReportDto unionReportDto) { + return unionReportService.add(unionReportDto); + } + + + /** + * 分页户外劳工站上报表 + * + * @param unionReportDto + * @return 动态结果 + */ + @PostMapping("/query") + public R<IPage<UnionReport>> query(@RequestBody UnionReportDto unionReportDto) { + return unionReportService.query(unionReportDto); + } +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionUserApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionUserApi.java new file mode 100644 index 0000000..209015a --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionUserApi.java @@ -0,0 +1,47 @@ +package com.panzhihua.service_equipment.api; + +import com.panzhihua.common.model.dtos.equipment.UnionUserDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionUser; +import com.panzhihua.service_equipment.service.UnionUserService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; + +@Slf4j +@RestController +@RequestMapping("/unionUser") +public class UnionUserApi { + + @Resource + private UnionUserService userService; + + /** + * 总工会户外劳登录 + * + * @param loginUserInfoVO + * @return 总工会户外劳共用户 + */ + @PostMapping("/login") + public R<UnionUser> login(@RequestBody LoginUserInfoVO loginUserInfoVO){ + return userService.login(loginUserInfoVO); + } + + /** + * 总工会户外劳工站用户认证 + * + * @param unionUserDto + * @return 总工会户外劳共用户 + */ + @PostMapping("/authentication") + public R authentication(@RequestBody UnionUserDto unionUserDto){ + return userService.authentication(unionUserDto); + } + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessConfig.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessConfig.java new file mode 100644 index 0000000..22fd428 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessConfig.java @@ -0,0 +1,21 @@ +package com.panzhihua.service_equipment.config; + +import io.swagger.annotations.ApiModel; +import lombok.Data; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.context.annotation.Configuration; +import org.springframework.stereotype.Component; + +@ApiModel("门禁账号密码") +@Data +@Component +@ConfigurationProperties(prefix = "uni") +public class AccessConfig { + + @Value("${access.username}") + private String userName; + // FTP 登录密码 + @Value("${access.password}") + private String password; +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessUtil.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessUtil.java new file mode 100644 index 0000000..a649e12 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessUtil.java @@ -0,0 +1,109 @@ +package com.panzhihua.service_equipment.config; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.HashMap; +import java.util.Map; + +import static com.panzhihua.common.utlis.HttpClientUtil.*; + + +@Slf4j +@Service +public class AccessUtil { + + + @Resource + private AccessConfig accessConfig; + + + /** + * 刷新token + * @return token + * @throws Exception + */ + public Map refreshToken() throws Exception { + String url = "https://dptest.d-power.com.cn:14404/v1/token/refresh"; + return JSONObject.parseObject(httpPost(url, JSON.toJSONString(accessConfig)), Map.class); + } + + /** + * 注册人脸 + * @return 返回结果 + * @throws Exception + */ + public Map faceEnroll(String tel,String name,String image,String communityId,String unitId) { + String url="https://dptest.d-power.com.cn:14404/v1/face"; + String token="DpToken "; + Map headerMap = new HashMap(); + try { + Map map = refreshToken(); + if (map!=null&&map.get("token")!=null){ + token =token+map.get("token").toString(); + log.info("生成的token为:{}",token); + headerMap.put("Authorization",token); + headerMap.put("Host","dptest.d-power.com.cn"); + } + else { + log.info("生成token错误"); + return null; + } + } catch (Exception e) { + throw new RuntimeException(e); + } + Map result=new HashMap(); + result.put("role","occupant"); + result.put("communityId",communityId); + result.put("unitId",unitId); + result.put("tel",tel); + result.put("name",name); + result.put("timeout",10); + result.put("image",image); + try { + return JSONObject.parseObject(httpPostAndToken(url, JSON.toJSONString(result),headerMap), Map.class); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + + /** + * 开门 + * @return 返回结果 + * @throws Exception + */ + public Map deviceOpen(String sn,String opener,String kind,String role) { + String url="https://dptest.d-power.com.cn:14404/v1/device/open"; + String token="DpToken "; + Map headerMap = new HashMap(); + try { + Map map = refreshToken(); + if (map!=null&&map.get("token")!=null){ + token =token+map.get("token").toString(); + log.info("生成的token为:{}",token); + headerMap.put("Authorization",token); + headerMap.put("Host","dptest.d-power.com.cn"); + } + else { + log.info("生成token错误"); + return null; + } + } catch (Exception e) { + throw new RuntimeException(e); + } + Map result=new HashMap(); + result.put("sn",sn); + result.put("kind",kind); + result.put("role",role); + result.put("opener",opener); + try { + return JSONObject.parseObject(httpPostAndToken(url, JSON.toJSONString(result),headerMap), Map.class); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + + +} \ No newline at end of file diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/QRCodeUtil.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/QRCodeUtil.java new file mode 100644 index 0000000..a107d7f --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/QRCodeUtil.java @@ -0,0 +1,108 @@ +//package com.panzhihua.service_equipment.config; +// +//import org.apache.commons.lang3.StringUtils; +//import org.mybatis.logging.Logger; +//import org.mybatis.logging.LoggerFactory; +// +//import javax.swing.filechooser.FileSystemView; +//import java.io.File; +// +///** +// * 二维码工具 +// * @Author:debug (SteadyJack) +// * @Link: weixin-> debug0868 qq-> 1948831260 +// * @Date: 2020/11/16 22:38 +// **/ +//public class QRCodeUtil { +// private static final Logger log= LoggerFactory.getLogger(QRCodeUtil.class); +// +// //CODE_WIDTH:二维码宽度,单位像素 +// private static final int CODE_WIDTH = 400; +// //CODE_HEIGHT:二维码高度,单位像素 +// private static final int CODE_HEIGHT = 400; +// //FRONT_COLOR:二维码前景色,0x000000 表示黑色 +// private static final int FRONT_COLOR = 0x000000; +// //BACKGROUND_COLOR:二维码背景色,0xFFFFFF 表示白色 +// //演示用 16 进制表示,和前端页面 CSS 的取色是一样的,注意前后景颜色应该对比明显,如常见的黑白 +// private static final int BACKGROUND_COLOR = 0xFFFFFF; +// +// public static void createCodeToFile(String content, File codeImgFileSaveDir, String fileName) { +// try { +// if (StringUtils.isBlank(content) || StringUtils.isBlank(fileName)) { +// return; +// } +// content = content.trim(); +// if (codeImgFileSaveDir==null || codeImgFileSaveDir.isFile()) { +// //二维码图片存在目录为空,默认放在桌面... +// codeImgFileSaveDir = FileSystemView.getFileSystemView().getHomeDirectory(); +// } +// if (!codeImgFileSaveDir.exists()) { +// //二维码图片存在目录不存在,开始创建... +// codeImgFileSaveDir.mkdirs(); +// } +// +// //核心代码-生成二维码 +// BufferedImage bufferedImage = getBufferedImage(content); +// +// File codeImgFile = new File(codeImgFileSaveDir, fileName); +// ImageIO.write(bufferedImage, "png", codeImgFile); +// +// log.info("二维码图片生成成功:" + codeImgFile.getPath()); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// /** +// * 生成二维码并输出到输出流, 通常用于输出到网页上进行显示,输出到网页与输出到磁盘上的文件中,区别在于最后一句 ImageIO.write +// * write(RenderedImage im,String formatName,File output):写到文件中 +// * write(RenderedImage im,String formatName,OutputStream output):输出到输出流中 +// * @param content :二维码内容 +// * @param outputStream :输出流,比如 HttpServletResponse 的 getOutputStream +// */ +// public static void createCodeToOutputStream(String content, OutputStream outputStream) { +// try { +// if (StringUtils.isBlank(content)) { +// return; +// } +// content = content.trim(); +// //核心代码-生成二维码 +// BufferedImage bufferedImage = getBufferedImage(content); +// +// //区别就是这一句,输出到输出流中,如果第三个参数是 File,则输出到文件中 +// ImageIO.write(bufferedImage, "png", outputStream); +// +// log.info("二维码图片生成到输出流成功..."); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// //核心代码-生成二维码 +// private static BufferedImage getBufferedImage(String content) throws WriterException { +// +// //com.google.zxing.EncodeHintType:编码提示类型,枚举类型 +// Map<EncodeHintType, Object> hints = new HashMap(); +// +// //EncodeHintType.CHARACTER_SET:设置字符编码类型 +// hints.put(EncodeHintType.CHARACTER_SET, "UTF-8"); +// +// //EncodeHintType.ERROR_CORRECTION:设置误差校正 +// //ErrorCorrectionLevel:误差校正等级,L = ~7% correction、M = ~15% correction、Q = ~25% correction、H = ~30% correction +// //不设置时,默认为 L 等级,等级不一样,生成的图案不同,但扫描的结果是一样的 +// hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.M); +// +// //EncodeHintType.MARGIN:设置二维码边距,单位像素,值越小,二维码距离四周越近 +// hints.put(EncodeHintType.MARGIN, 1); +// +// MultiFormatWriter multiFormatWriter = new MultiFormatWriter(); +// BitMatrix bitMatrix = multiFormatWriter.encode(content, BarcodeFormat.QR_CODE, CODE_WIDTH, CODE_HEIGHT, hints); +// BufferedImage bufferedImage = new BufferedImage(CODE_WIDTH, CODE_HEIGHT, BufferedImage.TYPE_INT_BGR); +// for (int x = 0; x < CODE_WIDTH; x++) { +// for (int y = 0; y < CODE_HEIGHT; y++) { +// bufferedImage.setRGB(x, y, bitMatrix.get(x, y) ? FRONT_COLOR : BACKGROUND_COLOR); +// } +// } +// return bufferedImage; +// } +//} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionAccessMapper.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionAccessMapper.java new file mode 100644 index 0000000..926bba1 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionAccessMapper.java @@ -0,0 +1,19 @@ +package com.panzhihua.service_equipment.dao; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.panzhihua.service_equipment.model.dos.UnionAccess; +import org.apache.ibatis.annotations.Mapper; + + +/** + * <p> + * 户外劳工站门禁设备 Mapper 接口 + * </p> + * + * @author fengjin + * @since 2023-09-11 + */ +@Mapper +public interface UnionAccessMapper extends BaseMapper<UnionAccess> { + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionInspectionMapper.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionInspectionMapper.java new file mode 100644 index 0000000..0ba9d44 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionInspectionMapper.java @@ -0,0 +1,18 @@ +package com.panzhihua.service_equipment.dao; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.panzhihua.service_equipment.model.dos.UnionInspection; +import org.apache.ibatis.annotations.Mapper; + +/** + * <p> + * 户外劳工站巡查表 Mapper 接口 + * </p> + * + * @author fengjin + * @since 2023-08-25 + */ +@Mapper +public interface UnionInspectionMapper extends BaseMapper<UnionInspection> { + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionReportMapper.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionReportMapper.java new file mode 100644 index 0000000..c3aad78 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionReportMapper.java @@ -0,0 +1,17 @@ +package com.panzhihua.service_equipment.dao; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import org.apache.ibatis.annotations.Mapper; +/** + * <p> + * 户外劳工站上报表 Mapper 接口 + * </p> + * + * @author fengjin + * @since 2023-08-24 + */ +@Mapper +public interface UnionReportMapper extends BaseMapper<UnionReport> { + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionUserMapper.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionUserMapper.java new file mode 100644 index 0000000..519f4f3 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionUserMapper.java @@ -0,0 +1,17 @@ +package com.panzhihua.service_equipment.dao; +import org.apache.ibatis.annotations.Mapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.panzhihua.service_equipment.model.dos.UnionUser; + +/** + * <p> + * 户外劳工站用户 + * </p> + * + * @author fengjin + * @since 2023-08-24 + */ +@Mapper +public interface UnionUserMapper extends BaseMapper<UnionUser> { + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionAccess.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionAccess.java new file mode 100644 index 0000000..53f3c00 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionAccess.java @@ -0,0 +1,74 @@ +package com.panzhihua.service_equipment.model.dos; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * <p> + * 户外劳工站门禁设备 + * </p> + * + * @author fengjin + * @since 2023-09-11 + */ +@TableName("union_access") +@Data +@ApiModel("户外劳工站门禁设备") +public class UnionAccess implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId(value = "id", type = IdType.AUTO) + @ApiModelProperty(value = "主键") + private Integer id; + + /** + * 站点id + */ + @ApiModelProperty(value = "站点id") + private Integer siteId; + + /** + * 小区id + */ + @ApiModelProperty(value = "小区id") + private String communityExternalId; + + /** + * 小区名 + */ + @ApiModelProperty(value = "小区名") + private String community; + + /** + * 单元id + */ + @ApiModelProperty(value = "单元id") + private String unitId; + + /** + * 设备序列号 + */ + @ApiModelProperty(value = "设备序列号") + private String sn; + + /** + * 设备名 + */ + @ApiModelProperty(value = "设备名") + private String name; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionInspection.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionInspection.java new file mode 100644 index 0000000..6729df3 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionInspection.java @@ -0,0 +1,121 @@ +package com.panzhihua.service_equipment.model.dos; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * <p> + * 户外劳工站巡查表 + * </p> + * + * @author fengjin + * @since 2023-08-25 + */ +@TableName("union_inspection") +@Data +@ApiModel("户外劳工站巡查表") +public class UnionInspection implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * ,主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @ApiModelProperty(value = "主键") + private Integer id; + + /** + * 创建人户外劳工站id + */ + @ApiModelProperty(value = "创建人户外劳工站id") + private Long createUnionUserId; + + /** + * 站点id + */ + @ApiModelProperty(value = "站点id") + private Integer siteId; + + /** + * 创建人id + */ + @ApiModelProperty(value = "创建人id") + private Long createUserId; + + /** + * 类型(1正常2异常) + */ + @ApiModelProperty(value = "类型(1正常2异常)") + private Integer type; + + /** + * 内容 + */ + @ApiModelProperty(value = "内容") + private String content; + + /** + * 图片地址 + */ + @ApiModelProperty(value = "图片地址") + private String url; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 标题 + */ + @ApiModelProperty(value = "标题") + private String title; + + /** + * 处理人户外劳工站id + */ + @ApiModelProperty(value = "处理人户外劳工站id") + private Integer disposeUnionUserId; + + /** + * 处理内容 + */ + @ApiModelProperty(value = "处理内容") + private String disposeContent; + + /** + * 处理时间 + */ + @ApiModelProperty(value = "处理时间") + private LocalDateTime disposeAt; + + /** + * 处理照片地址 + */ + @ApiModelProperty(value = "处理照片地址") + private String disposeUrl; + + /** + * 状态(1未回复2已回复) + */ + @ApiModelProperty(value = "状态(1未接单2已接单3已解决)") + private Integer status; + + /** + * 创建人电话 + */ + @ApiModelProperty(value = "创建人电话") + private String createPhone; + + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java index 844d2d7..65301f4 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java @@ -175,6 +175,11 @@ @ApiModelProperty(value = "服务范围") private String serviceRange; + /** + * 站点环境图(,)分隔 + */ + @ApiModelProperty(value = "站点环境图(,)分隔") + private String siteEnvironmentUrl; /** * 服务列表 diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionReport.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionReport.java new file mode 100644 index 0000000..748e39e --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionReport.java @@ -0,0 +1,117 @@ +package com.panzhihua.service_equipment.model.dos; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * <p> + * 户外劳工站上报表 + * </p> + * + * @author fengjin + * @since 2023-08-24 + */ +@TableName("union_report") +@Data +@ApiModel("户外劳工站上报表") +public class UnionReport implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * ,主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @ApiModelProperty(value = "主键") + private Integer id; + + /** + * 创建人户外劳工站id + */ + @ApiModelProperty(value = "创建人户外劳工站id") + private Long createUnionUserId; + + /** + * 站点id + */ + @ApiModelProperty(value = "站点id") + private Integer siteId; + + /** + * 创建人id + */ + @ApiModelProperty(value = "创建人id") + private Long createUserId; + + + /** + * 类型(1意见反馈2故障保修) + */ + @ApiModelProperty(value = "类型(1意见反馈2故障保修)") + private Integer type; + + /** + * 内容 + */ + @ApiModelProperty(value = "内容") + private String content; + + /** + * 图片地址 + */ + @ApiModelProperty(value = "图片地址") + private String url; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 标题 + */ + @ApiModelProperty(value = "标题") + private String title; + + /** + * 处理人户外劳工站id + */ + @ApiModelProperty(value = "处理人户外劳工站id") + private Integer disposeUnionUserId; + + /** + * 处理内容 + */ + @ApiModelProperty(value = "处理内容") + private String disposeContent; + + /** + * 处理时间 + */ + @ApiModelProperty(value = "处理时间") + private LocalDateTime disposeAt; + + /** + * 处理照片地址 + */ + @ApiModelProperty(value = "处理照片地址") + private String disposeUrl; + + + /** + * 状态(1未回复2已回复) + */ + @ApiModelProperty(value = "状态(1未回复2已回复)") + private Integer status; + + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionUser.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionUser.java new file mode 100644 index 0000000..09f822c --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionUser.java @@ -0,0 +1,181 @@ +package com.panzhihua.service_equipment.model.dos; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.ToStringSerializer; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDateTime; + +/** + * <p> + * 户外劳工站用户 + * </p> + * + * @author fengjin + * @since 2023-08-24 + */ +@TableName("union_user") +@Data +@ApiModel("总工会户外劳工站") +public class UnionUser implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 主键id + */ + @TableId(value = "id", type = IdType.AUTO) + @ApiModelProperty(value = "主键id") + private Long id; + + /** + * () + */ + @ApiModelProperty(value = "姓名") + private String name; + + /** + *商家名称 + */ + @ApiModelProperty(value = "商家名称") + private String sex; + + /** + * 联系方式 + */ + @ApiModelProperty(value = "联系方式") + private String phone; + + /** + * 人员类型(1、普通工会用户 2、巡查人员 3、站点负责人 + */ + @ApiModelProperty(value = "人员类型(1、普通工会用户 2、巡查人员 3、站点负责人 ") + private String type; + + /** + * 删除标识 + */ + @ApiModelProperty(value = "删除标识") + private Boolean deleteFlag; + + /** + * 备注 + */ + @ApiModelProperty(value = "备注") + private String remark; + + /** + * 创建时间 + */ + @ApiModelProperty(value = "创建时间") + private LocalDateTime createAt; + + /** + * 更新时间 + */ + @ApiModelProperty(value = "更新时间") + private LocalDateTime updateAt; + + /** + * 修改用户 + */ + @ApiModelProperty(value = "修改用户") + private Long updateBy; + + /** + * 创建用户 + */ + @ApiModelProperty(value = "创建用户") + private Long createBy; + + /** + * 认证照片地址 + */ + @ApiModelProperty(value = "认证照片地址") + private String certifiedPhotoUrl; + + /** + * 微信小程序唯一标识 + */ + @ApiModelProperty(value = "微信小程序唯一标识") + private String openid; + + /** + * 身份证号 + */ + @ApiModelProperty(value = "身份证号") + private String idCard; + + /** + * 1 启用 2 禁用 + */ + @ApiModelProperty(value = "1 启用 2 禁用") + private Integer status; + + /** + * 账号 + */ + @ApiModelProperty(value = "账号") + private String account; + + /** + * 昵称 + */ + @ApiModelProperty(value = "昵称") + private String nickName; + + /** + * 密码 + */ + @ApiModelProperty(value = "密码") + private String password; + + /** + * 头像 + */ + @ApiModelProperty(value = "头像") + private String imageUrl; + + /** + * 站点id(普通用户为空) + */ + @ApiModelProperty(value = " 站点id(普通用户为空)") + private Integer siteId; + + @ApiModelProperty("花城user_id") + private Long userId; + + + /** + * 区域编码 + */ + @ApiModelProperty(value = "区域编码") + private String areaCode; + + /** + * 是否认证 + */ + @ApiModelProperty(value = " 是否认证0否1认证") + private Integer isAuthenticated; + + + /** + * 认证图片地址 + */ + @ApiModelProperty(value = " 认证图片地址") + private String authenticatedUrl; + + /** + * 认证图片地址(base_64) + */ + @ApiModelProperty(value = " 认证图片地址(base_64)") + private String authenticatedUrlBase; + + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionInspectionService.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionInspectionService.java new file mode 100644 index 0000000..9de5aba --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionInspectionService.java @@ -0,0 +1,27 @@ +package com.panzhihua.service_equipment.service; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionReport; + +public interface UnionInspectionService { + + /** + * 新增户外劳工站巡查 + * + * @param unionInspectionDto + * @return 新增结果 + */ + R add(UnionInspectionDto unionInspectionDto); + + + + /** + * 分页户外劳工站巡查 + * + * @param unionInspectionDto + * @return 动态结果 + */ + R<IPage<UnionReport>> query(UnionInspectionDto unionInspectionDto); +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionReportService.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionReportService.java new file mode 100644 index 0000000..bf766e4 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionReportService.java @@ -0,0 +1,26 @@ +package com.panzhihua.service_equipment.service; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionReport; + +public interface UnionReportService { + + /** + * 户外劳工站上报表 + * + * @param unionReportDto + * @return 新增结果 + */ + R add(UnionReportDto unionReportDto); + + + /** + * 分页户外劳工站上报表 + * + * @param unionReportDto + * @return 动态结果 + */ + R<IPage<UnionReport>> query(UnionReportDto unionReportDto); +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionUserService.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionUserService.java new file mode 100644 index 0000000..29ed86d --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionUserService.java @@ -0,0 +1,30 @@ +package com.panzhihua.service_equipment.service; + +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.dtos.equipment.UnionUserDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import com.panzhihua.service_equipment.model.dos.UnionUser; + +public interface UnionUserService { + + + /** + * 总工会户外劳登录 + * + * @param loginUserInfoVO + * @return 总工会户外劳共用户 + */ + R<UnionUser> login(LoginUserInfoVO loginUserInfoVO); + + /** + * 总工会户外劳工站用户认证 + * + * @param unionUserDto + * @return 总工会户外劳共用户 + */ + R authentication(UnionUserDto unionUserDto); + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionInspectionServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionInspectionServiceImpl.java new file mode 100644 index 0000000..dcdaec8 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionInspectionServiceImpl.java @@ -0,0 +1,74 @@ +package com.panzhihua.service_equipment.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.dao.UnionInspectionMapper; +import com.panzhihua.service_equipment.dao.UnionUserMapper; +import com.panzhihua.service_equipment.model.dos.UnionInspection; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import com.panzhihua.service_equipment.model.dos.UnionUser; +import com.panzhihua.service_equipment.service.UnionInspectionService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.time.LocalDateTime; + +@Slf4j +@Service +public class UnionInspectionServiceImpl extends ServiceImpl<UnionInspectionMapper, UnionInspection> implements UnionInspectionService { + + @Resource + private UnionUserMapper unionUserMapper; + + + /** + * 新增户外劳工站巡查 + * + * @param unionInspectionDto + * @return 新增结果 + */ + @Override + public R add(UnionInspectionDto unionInspectionDto) { + UnionInspection unionInspection = new UnionInspection(); + BeanUtils.copyProperties(unionInspectionDto, unionInspection); + UnionUser unionUser = unionUserMapper + .selectOne(new QueryWrapper<UnionUser>().eq("user_id", unionInspection.getCreateUserId())); + if (unionUser!=null){ + unionInspection.setCreateUnionUserId(unionUser.getId()); + unionInspection.setCreatePhone(unionUser.getPhone()); + } + unionInspection.setStatus(1); + unionInspection.setCreateAt(LocalDateTime.now()); + if (baseMapper.insert(unionInspection) > 0) { + return R.ok(); + } + return R.fail(); + } + + /** + * 分页户外劳工站巡查 + * + * @param unionInspectionDto + * @return 动态结果 + */ + @Override + public R<IPage<UnionReport>> query(UnionInspectionDto unionInspectionDto) { + Page page = new Page(unionInspectionDto.getPageNum(), unionInspectionDto.getPageSize()); + QueryWrapper<UnionInspection> unionOutdoorLaborDynamicQueryWrapper = new QueryWrapper<>(); + if (unionInspectionDto.getIsApplets().equals(1)){ + unionOutdoorLaborDynamicQueryWrapper.eq("create_user_id",unionInspectionDto.getCreateUserId()).eq("type",2); + if (unionInspectionDto.getStatus()!=null) + unionOutdoorLaborDynamicQueryWrapper.eq("status",unionInspectionDto.getStatus()); + } + Page pageResult = baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper); + pageResult.setTotal(pageResult.getRecords().size()); + return R.ok(pageResult); + } +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java index 1b0847f..545db93 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java @@ -36,11 +36,14 @@ case 1: case 2: case 3: + case 4: unionOutdoorLaborDynamicQueryWrapper.eq("type",unionOutdoorLaborDynamicDto.getType()); break; } } - return R.ok( baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper)); + Page pageResult = baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper); + pageResult.setTotal(pageResult.getRecords().size()); + return R.ok(pageResult); } /** diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java index f43362f..0c994c8 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java @@ -14,6 +14,7 @@ import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; import com.panzhihua.service_equipment.service.UnionOutdoorSiteService; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -39,7 +40,16 @@ QueryWrapper<UnionOutdoorSite> unionOutdoorLaborDynamicQueryWrapper = new QueryWrapper<>(); if (unionOutdoorSiteDto.getAreaCode()!=null) unionOutdoorLaborDynamicQueryWrapper.eq("area_code",unionOutdoorSiteDto.getAreaCode()); - return R.ok( baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper)); + if (unionOutdoorSiteDto.getKeyWord()!=null) + unionOutdoorLaborDynamicQueryWrapper.and(wrapper -> wrapper.like("name", unionOutdoorSiteDto.getKeyWord()) + .or() + .like("introduction", unionOutdoorSiteDto.getKeyWord()) + .or() + .like("detailed_address", unionOutdoorSiteDto.getKeyWord())); + + Page pageResult = baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper); + pageResult.setTotal(pageResult.getRecords().size()); + return R.ok(pageResult); } @Override diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionReportServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionReportServiceImpl.java new file mode 100644 index 0000000..1972279 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionReportServiceImpl.java @@ -0,0 +1,76 @@ +package com.panzhihua.service_equipment.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; +import com.panzhihua.common.model.dtos.equipment.UnionReportDto; +import com.panzhihua.common.model.dtos.grid.ComActEasyPhotoAddDTO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.dao.UnionReportMapper; +import com.panzhihua.service_equipment.dao.UnionUserMapper; +import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; +import com.panzhihua.service_equipment.model.dos.UnionReport; +import com.panzhihua.service_equipment.model.dos.UnionUser; +import com.panzhihua.service_equipment.service.UnionReportService; +import com.panzhihua.service_equipment.service.UnionUserService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.time.LocalDateTime; +import java.util.Date; + +@Service +@Slf4j +public class UnionReportServiceImpl extends ServiceImpl<UnionReportMapper, UnionReport> implements UnionReportService { + + @Resource + private UnionUserMapper unionUserMapper; + + + /** + * 户外劳工站上报表 + * + * @param unionReportDto + * @return 新增结果 + */ + @Override + public R add(UnionReportDto unionReportDto) { + UnionReport unionReport = new UnionReport(); + BeanUtils.copyProperties(unionReportDto, unionReport); + UnionUser unionUser = unionUserMapper + .selectOne(new QueryWrapper<UnionUser>().eq("user_id", unionReport.getCreateUserId())); + if (unionUser!=null) + unionReport.setCreateUnionUserId(unionUser.getId()); + unionReport.setStatus(1); + unionReport.setCreateAt(LocalDateTime.now()); + if (baseMapper.insert(unionReport) > 0) { + return R.ok(); + } + return R.fail(); + } + + /** + * 分页户外劳工站上报表 + * + * @param unionReportDto + * @return 动态结果 + */ + @Override + public R<IPage<UnionReport>> query(UnionReportDto unionReportDto) { + Page page = new Page(unionReportDto.getPageNum(), unionReportDto.getPageSize()); + QueryWrapper<UnionReport> unionOutdoorLaborDynamicQueryWrapper = new QueryWrapper<>(); + if (unionReportDto.getIsApplets().equals(1)){ + unionOutdoorLaborDynamicQueryWrapper.eq("create_user_id",unionReportDto.getCreateUserId()); + if (unionReportDto.getType()!=null) + unionOutdoorLaborDynamicQueryWrapper.eq("type",unionReportDto.getType()); + } + Page pageResult = baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper); + pageResult.setTotal(pageResult.getRecords().size()); + return R.ok(pageResult); + } + +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionUserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionUserServiceImpl.java new file mode 100644 index 0000000..a0a095d --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionUserServiceImpl.java @@ -0,0 +1,113 @@ +package com.panzhihua.service_equipment.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.panzhihua.common.model.dtos.equipment.UnionUserDto; +import com.panzhihua.common.model.vos.LoginUserInfoVO; +import com.panzhihua.common.model.vos.R; +import com.panzhihua.service_equipment.config.AccessUtil; +import com.panzhihua.service_equipment.dao.UnionAccessMapper; +import com.panzhihua.service_equipment.dao.UnionUserMapper; +import com.panzhihua.service_equipment.model.dos.UnionAccess; +import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; +import com.panzhihua.service_equipment.model.dos.UnionUser; +import com.panzhihua.service_equipment.service.UnionUserService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.time.LocalDateTime; +import java.util.List; + +@Service +@Slf4j +public class UnionUserServiceImpl extends ServiceImpl<UnionUserMapper, UnionUser> implements UnionUserService { + + @Resource + private AccessUtil accessUtil; + + @Resource + private UnionAccessMapper unionAccessMapper; + + /** + * 总工会户外劳登录 + * + * @param loginUserInfoVO + * @return 总工会户外劳共用户 + */ + @Override + public R<UnionUser> login(LoginUserInfoVO loginUserInfoVO) { + UnionUser unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("user_id", loginUserInfoVO.getUserId())); + if (unionUser != null) { + return R.ok(unionUser); + } else { + unionUser = new UnionUser(); + unionUser.setSex(loginUserInfoVO.getSex().toString()); + unionUser.setPhone(loginUserInfoVO.getPhone()); + unionUser.setDeleteFlag(false); + unionUser.setCreateAt(LocalDateTime.now()); + unionUser.setUpdateAt(LocalDateTime.now()); + unionUser.setStatus(1); + unionUser.setNickName(loginUserInfoVO.getNickName()); + unionUser.setUserId(loginUserInfoVO.getUserId()); + if (loginUserInfoVO.getImageUrl() != null) + unionUser.setImageUrl(loginUserInfoVO.getImageUrl()); + int insert = baseMapper.insert(unionUser); + if (insert > 0) { + return R.ok(unionUser); + } else { + return R.fail(); + } + } + + } + + /** + * 总工会户外劳工站用户认证 + * + * @param unionUserDto + * @return 总工会户外劳共用户 + */ + + @Override + public R authentication(UnionUserDto unionUserDto){ + UnionUser unionUser = baseMapper.selectOne(new QueryWrapper<UnionUser>().eq("user_id", unionUserDto.getUserId())); + if (unionUser != null){ + log.info("查询到用户开始认证操作{}",unionUser); + //设备下发照片代码 + LambdaQueryWrapper<UnionAccess> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.inSql(UnionAccess::getSiteId, "SELECT id FROM union_outdoor_site WHERE area_code='" + unionUserDto.getAreaCode() + "'"); + List<UnionAccess> unionAccesses = unionAccessMapper.selectList(queryWrapper); + for (UnionAccess unionAccess : unionAccesses) { + try { + log.info("人脸注册"); + accessUtil.faceEnroll(unionUser.getPhone(), unionUserDto.getName(), unionUserDto.getAuthenticatedUrlBase(), unionAccess.getCommunityExternalId(), unionAccess.getUnitId()); + } catch (Exception e) { + // 处理异常 + e.printStackTrace(); + return R.fail("认证失败,请验证照片是否符合规范或者联系工作人员"); // 或者抛出自定义异常,根据实际情况进行处理 + } + } + //更改数据库 + unionUser.setName(unionUserDto.getName()); + unionUser.setIdCard(unionUserDto.getIdCard()); + unionUser.setAreaCode(unionUserDto.getAreaCode()); + unionUser.setAuthenticatedUrl(unionUserDto.getAuthenticatedUrl()); + unionUser.setAuthenticatedUrlBase(unionUserDto.getAuthenticatedUrlBase()); + unionUser.setIsAuthenticated(1); + int i = baseMapper.updateById(unionUser); + if (i>0){ + return R.ok("认证成功"); + } + else { + return R.fail("认证失败"); + } + } + else { + log.info("未查询到用户"); + return R.fail("认证失败"); + } + + } +} diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionAccessMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionAccessMapper.xml new file mode 100644 index 0000000..05977c5 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionAccessMapper.xml @@ -0,0 +1,5 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.panzhihua.service_equipment.dao.UnionAccessMapper"> + +</mapper> diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionInspectionMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionInspectionMapper.xml new file mode 100644 index 0000000..2ff276e --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionInspectionMapper.xml @@ -0,0 +1,5 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.panzhihua.service_equipment.dao.UnionInspectionMapper"> + +</mapper> diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionReportMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionReportMapper.xml new file mode 100644 index 0000000..bba0214 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionReportMapper.xml @@ -0,0 +1,5 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.panzhihua.service_equipment.dao.UnionReportMapper"> + +</mapper> diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionUserMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionUserMapper.xml new file mode 100644 index 0000000..407a010 --- /dev/null +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionUserMapper.xml @@ -0,0 +1,5 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.panzhihua.service_equipment.dao.UnionUserMapper"> + +</mapper> diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.class b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.class index a5164e8..b109219 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.class +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.class Binary files differ diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.class b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.class index 11612e9..111a537 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.class +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.class Binary files differ diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.class b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.class index e395bc4..c427ca1 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.class +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.class Binary files differ diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.class b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.class index b86946a..4fc4463 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.class +++ b/springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.class Binary files differ diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/ServiceUserApplication.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/ServiceUserApplication.java index 360afaf..df77f4b 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/ServiceUserApplication.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/ServiceUserApplication.java @@ -12,6 +12,7 @@ @ComponentScan({"com.panzhihua.service_user", "com.panzhihua.common"}) public class ServiceUserApplication { + public static void main(String[] args) { SpringApplication.run(ServiceUserApplication.class, args); } -- Gitblit v1.7.1