springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionOutdoorLaborDynamicApi.java
New file @@ -0,0 +1,58 @@ package com.panzhihua.applets.api; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.community.ComMngStructAreaDistrictVO; import com.panzhihua.common.service.community.ComEquipmentUnionOutdoorLaborDynamicFeign; import com.panzhihua.common.service.community.CommunityService; 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; @Slf4j @RestController @RequestMapping("/unionOutdoorLaborDynamic/") @Api(tags = {"户外劳工动态服务"}) public class UnionOutdoorLaborDynamicApi { @Resource private ComEquipmentUnionOutdoorLaborDynamicFeign comEquipmentUnionOutdoorLaborDynamicFeign; @Resource private CommunityService communityService; /** * 分页总工会-户外劳工站-动态 * * @param unionOutdoorLaborDynamicDto * @return 动态结果 */ @PostMapping("page") R query(@RequestBody UnionOutdoorLaborDynamicDto unionOutdoorLaborDynamicDto) { return comEquipmentUnionOutdoorLaborDynamicFeign.query(unionOutdoorLaborDynamicDto); } /** * 查询总工会-户外劳工站-动态 * * @param id * 动态 id * @return 查找结果 */ @GetMapping("/{id}") R eventMainMemberDetails(@PathVariable("id") Long id) { return comEquipmentUnionOutdoorLaborDynamicFeign.unionOutdoorLaborDynamicDetail(id); } @ApiOperation(value = "所在地地址下拉列表(攀枝花)", response = ComMngStructAreaDistrictVO.class) @PostMapping("listarea") public R listArea() { Long cityAdcode = 510400l; return communityService.listAreaDistrict(cityAdcode); } } springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UnionOutdoorSiteApi.java
New file @@ -0,0 +1,52 @@ package com.panzhihua.applets.api; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.community.ComMngStructAreaDistrictVO; import com.panzhihua.common.service.community.ComEquipmentUnionOutdoorLaborDynamicFeign; import com.panzhihua.common.service.community.ComEquipmentUnionOutdoorSiteFeign; import com.panzhihua.common.service.community.CommunityService; 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; @Slf4j @RestController @RequestMapping("/unionOutdoorSite/") @Api(tags = {"户外劳工站"}) public class UnionOutdoorSiteApi { @Resource private ComEquipmentUnionOutdoorSiteFeign comEquipmentUnionOutdoorSiteFeign; /** * 分页总工会户外劳工站 * * @param unionOutdoorSiteDto * @return 动态结果 */ @PostMapping("page") R query(@RequestBody UnionOutdoorSiteDto unionOutdoorSiteDto) { return comEquipmentUnionOutdoorSiteFeign.query(unionOutdoorSiteDto); } /** * 查询总工会户外劳工站 * * @param id * 户外劳工站 id * @return 查找结果 */ @GetMapping("/{id}") R eventMainMemberDetails(@PathVariable("id") Long id) { return comEquipmentUnionOutdoorSiteFeign.unionOutdoorSiteDetail(id); } } springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/constants/Constants.java
@@ -244,6 +244,12 @@ */ public static final String SERVICE_COMMUNITY = "huacheng-community"; /** * equipment包(总工会户外劳工站) */ public static final String SERVICE_EQUIPMENT = "equipment"; /** * 操作类型 * */ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/constants/HttpStatus.java
@@ -6,6 +6,12 @@ * @author huanghongfa */ public class HttpStatus { /** * 正常 */ public static final int NORMAL = 0; /** * 操作成功 */ springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorLaborDynamicDto.java
New file @@ -0,0 +1,92 @@ package com.panzhihua.common.model.dtos.equipment; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.time.LocalDateTime; @ApiModel("总工会-户外劳工站-动态") @Data public class UnionOutdoorLaborDynamicDto { private static final long serialVersionUID = 1L; /** * ,主键 */ @ApiModelProperty(value = "主键") private Long id; /** * 标题 */ @ApiModelProperty(value = "标题") private String title; /** * 状态 0 待发布 1 已发布 */ @ApiModelProperty(value = "状态 0 待发布 1 已发布") private Integer status; /** * 是否置顶 0 否 1 是 */ @ApiModelProperty(value = "是否置顶 0 否 1 是") private Integer isTopping; /** * 发布时间 */ @ApiModelProperty(value = " 发布时间") private LocalDateTime publishAt; /** * 创建时间 */ @ApiModelProperty(value = "创建时间") private LocalDateTime createAt; /** * 修改时间 */ @ApiModelProperty(value = "修改时间") private LocalDateTime updateAt; /** * 动态内容 富文本 */ @ApiModelProperty(value = "动态内容 富文本") private String content; /** * 封面 */ @ApiModelProperty(value = "封面") private String cover; /** * 类型(1.通知公告 2.使用指南 3.工会信息) */ @ApiModelProperty(value = "类型(1.通知公告 2.使用指南 3.工会信息)") private Integer type; /** * 阅读量 */ @ApiModelProperty(value = "阅读量") private Integer readNum; /** * 图片链接 */ @ApiModelProperty(value = "图片链接") private String imageUrl; @ApiModelProperty(value = "分页-当前页数", example = "1") private Long pageNum = 1L; @ApiModelProperty(value = "分页-每页记录数", example = "10") private Long pageSize = 10L; } springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/equipment/UnionOutdoorSiteDto.java
New file @@ -0,0 +1,178 @@ package com.panzhihua.common.model.dtos.equipment; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.io.Serializable; import java.time.LocalDateTime; import java.time.LocalTime; /** * <p> * 总工会户外劳工站 * </p> * * @author fengjin * @since 2023-08-23 */ @Data @ApiModel("总工会户外劳工站") public class UnionOutdoorSiteDto{ private static final long serialVersionUID = 1L; private Integer id; /** * 商家名称 */ @ApiModelProperty(value = "商家名称") private String name; /** * 商家logo */ @ApiModelProperty(value = "商家logo") private String logo; /** * 联系人 */ @ApiModelProperty(value = "联系人") private String contacts; /** * 身份证号 */ @ApiModelProperty(value = "身份证号") private String idCard; /** * 咨询电话 */ @ApiModelProperty(value = "咨询电话") private String phone; /** * 商家地址 */ @ApiModelProperty(value = "商家地址") private String address; /** * 详细地址 */ @ApiModelProperty(value = "详细地址") private String detailedAddress; /** * 纬度 */ @ApiModelProperty(value = "主键") private String lat; /** * 经度 */ @ApiModelProperty(value = "经度") private String lon; /** * 营业开始时间 */ @ApiModelProperty(value = "营业开始时间") private LocalTime beginAt; /** * 营业结束时间 */ @ApiModelProperty(value = "营业结束时间") private LocalTime endAt; /** * 商家介绍 */ @ApiModelProperty(value = "商家介绍") private String introduction; /** * 是否营业中 */ @ApiModelProperty(value = "是否营业中") private Boolean businessStatus; /** * 商家绑定账户id */ @ApiModelProperty(value = "商家绑定账户id") private Long userId; /** * 咨询量 */ @ApiModelProperty(value = "咨询量") private Integer consultationVolume; /** * 浏览量 */ @ApiModelProperty(value = "浏览量") private Integer viewNum; /** * 是否删除 */ @ApiModelProperty(value = "是否删除") private Boolean isDel; /** * 创建时间 */ @ApiModelProperty(value = "创建时间") private LocalDateTime createdAt; /** * 创建人 */ @ApiModelProperty(value = "创建人") private Long createdBy; /** * 更新时间 */ @ApiModelProperty(value = "更新时间") private LocalDateTime updatedAt; /** * 更新人 */ @ApiModelProperty(value = "更新人") private Long updatedBy; /** * 区域编码 */ @ApiModelProperty(value = "区域编码") private String areaCode; /** * 手机号 */ @ApiModelProperty(value = "手机号") private String mobilePhone; /** * 服务范围 */ @ApiModelProperty(value = "服务范围") private String serviceRange; @ApiModelProperty(value = "分页-当前页数", example = "1") private Long pageNum = 1L; @ApiModelProperty(value = "分页-每页记录数", example = "10") private Long pageSize = 10L; } springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/ResultData.java
New file @@ -0,0 +1,95 @@ package com.panzhihua.common.model.vos; import com.panzhihua.common.constants.HttpStatus; public class ResultData<T> { //返回状态码 private Integer code; //返回数据 private String msg; //返回消息 private T date; public Integer getCode() { return code; } public void setCode(Integer code) { this.code = code; } public T getDate() { return date; } public void setDate( T success) { this.date = success; } public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; } //Success结果 public static <T> ResultData<T> success(T data) { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.SUCCESS); resultData.setDate(null); resultData.setMsg("success"); return resultData; } //Success结果 public static <T> ResultData<T> success(T data,String msg) { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.SUCCESS); resultData.setDate(null); resultData.setMsg(msg); return resultData; } public static <T> ResultData<T> normal(T data) { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.NORMAL); resultData.setMsg("success"); resultData.setDate(data); return resultData; } //Success结果 public static <T> ResultData<T> success() { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.SUCCESS); resultData.setDate(null); return resultData; } //Fail结果 public static <T> ResultData<T> fail(int code, String message) { ResultData<T> resultData = new ResultData<>(); resultData.setCode(code); resultData.setDate(null); return resultData; } //Fail结果 public static <T> ResultData<T> error(String message) { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.ERROR); resultData.setDate(null); return resultData; } //Fail结果 public static <T> ResultData<T> error() { ResultData<T> resultData = new ResultData<>(); resultData.setCode(HttpStatus.ERROR); resultData.setDate(null); return resultData; } } springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionOutdoorLaborDynamicFeign.java
New file @@ -0,0 +1,33 @@ package com.panzhihua.common.service.community; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; 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 = "unionOutdoorLaborDynamic", path = "unionOutdoorLaborDynamic") public interface ComEquipmentUnionOutdoorLaborDynamicFeign { /** * 分页总工会-户外劳工站-动态 * * @param unionOutdoorLaborDynamicDto * @return 动态结果 */ @PostMapping("/page") R query(UnionOutdoorLaborDynamicDto unionOutdoorLaborDynamicDto); /** * 查询总工会-户外劳工站-动态 * * @param id * 动态 id * @return 查找结果 */ @GetMapping("{id}") R unionOutdoorLaborDynamicDetail(@PathVariable("id") Long id); } springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/ComEquipmentUnionOutdoorSiteFeign.java
New file @@ -0,0 +1,34 @@ package com.panzhihua.common.service.community; import com.panzhihua.common.constants.Constants; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; 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 = "unionOutdoorSite", path = "unionOutdoorSite") public interface ComEquipmentUnionOutdoorSiteFeign { /** * 分页总工会户外劳工站 * * @param unionOutdoorSiteDto * @return 动态结果 */ @PostMapping("/page") R query(UnionOutdoorSiteDto unionOutdoorSiteDto); /** * 查询总工会户外劳工站 * * @param id * 户外劳工站 id * @return 查找结果 */ @GetMapping("{id}") R unionOutdoorSiteDetail(@PathVariable("id") Long id); } springcloud_k8s_panzhihuazhihuishequ/service_equipment/pom.xml
New file @@ -0,0 +1,134 @@ <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>com.panzhihua</groupId> <artifactId>zhihuishequ</artifactId> <version>1.0-SNAPSHOT</version> </parent> <groupId>com.panzhihua</groupId> <artifactId>service_equipment</artifactId> <version>0.0.1-SNAPSHOT</version> <name>service_equipment</name> <description>设备服务</description> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>com.netflix.hystrix</groupId> <artifactId>hystrix-javanica</artifactId> </dependency> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> </dependency> <dependency> <groupId>com.panzhihua</groupId> <artifactId>common</artifactId> </dependency> <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> </dependency> <dependency> <groupId>commons-lang</groupId> <artifactId>commons-lang</artifactId> <version>2.6</version> </dependency> <!--添加监控依赖包--> <dependency> <groupId>io.micrometer</groupId> <artifactId>micrometer-registry-prometheus</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <mainClass>com.panzhihua.service_equipment.ServiceEquipmentApplication</mainClass> </configuration> <executions> <execution> <goals> <goal>repackage</goal> </goals> </execution> </executions> </plugin> <plugin> <groupId>com.spotify</groupId> <artifactId>docker-maven-plugin</artifactId> <version>1.2.0</version> <configuration> <imageName>registry.cn-chengdu.aliyuncs.com/panzhihua/service_community:v1</imageName> <serverId></serverId> <baseImage>java</baseImage> <entryPoint>["java", "-jar", "/${project.build.finalName}.jar"]</entryPoint> <resources> <resource> <targetPath>/</targetPath> <directory>${project.build.directory}</directory> <include>${project.build.finalName}.jar</include> </resource> </resources> </configuration> </plugin> </plugins> </build> <repositories> <repository> <id>spring-milestones</id> <name>Spring Milestones</name> <url>https://repo.spring.io/milestone</url> </repository> </repositories> </project> springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/ServiceEquipmentApplication.java
New file @@ -0,0 +1,22 @@ package com.panzhihua.service_equipment; //import com.panzhihua.service_grid.service.impl.EventVisitingTasksServiceImpl; import org.springframework.boot.SpringApplication; import org.springframework.cloud.client.SpringCloudApplication; import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.context.annotation.ComponentScan; @SpringCloudApplication @EnableFeignClients(basePackages = {"com.panzhihua.common.service"}) @EnableEurekaClient @EnableCircuitBreaker @ComponentScan({"com.panzhihua.service_equipment", "com.panzhihua.common"}) public class ServiceEquipmentApplication { public static void main(String[] args) { SpringApplication.run(ServiceEquipmentApplication.class, args); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/RoomckWebApi.java
New file @@ -0,0 +1,25 @@ package com.panzhihua.service_equipment.api; import com.panzhihua.common.model.vos.ResultData; import com.panzhihua.service_equipment.model.dos.Structured; 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 java.util.List; @Api(tags = {"新闻基本面,技术面相关接口"}) @RestController @RequestMapping("/roomck-web") @Slf4j public class RoomckWebApi { @PostMapping("/roomck/ivsCommomEventController") public ResultData ivsCommomEventController(@RequestBody List<Structured> structureds){ log.info("传输参数为{}",structureds); return ResultData.normal(structureds); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionOutdoorLaborDynamicApi.java
New file @@ -0,0 +1,47 @@ package com.panzhihua.service_equipment.api; import com.baomidou.mybatisplus.core.metadata.IPage; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.grid.PageEventApplicationAppReleaseDTO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.grid.EventApplicationAppReleaseVO; import com.panzhihua.common.model.vos.grid.EventMainMemberDetailsVO; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; import com.panzhihua.service_equipment.service.UnionOutdoorLaborDynamicService; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @Slf4j @RestController @RequestMapping("/unionOutdoorLaborDynamic") public class UnionOutdoorLaborDynamicApi { @Resource private UnionOutdoorLaborDynamicService unionOutdoorLaborDynamicService; /** * 分页总工会-户外劳工站-动态 * * @param unionOutdoorLaborDynamicDto * @return 动态结果 */ @PostMapping("/page") R<IPage<UnionOutdoorLaborDynamic>> query(@RequestBody UnionOutdoorLaborDynamicDto unionOutdoorLaborDynamicDto) { return unionOutdoorLaborDynamicService.query(unionOutdoorLaborDynamicDto); } /** * 查询总工会-户外劳工站-动态 * * @param id * 动态 id * @return 查找结果 */ @GetMapping("/{id}") R unionOutdoorLaborDynamicDetail(@PathVariable("id") Long id) { return unionOutdoorLaborDynamicService.unionOutdoorLaborDynamicDetails(id); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionOutdoorSiteApi.java
New file @@ -0,0 +1,47 @@ package com.panzhihua.service_equipment.api; import com.baomidou.mybatisplus.core.metadata.IPage; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; import com.panzhihua.service_equipment.service.UnionOutdoorSiteService; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; @Slf4j @RestController @RequestMapping("/unionOutdoorSite") public class UnionOutdoorSiteApi { @Resource private UnionOutdoorSiteService unionOutdoorSiteService; /** * 分页总工会户外劳工站 * * @param unionOutdoorSiteDto * @return 动态结果 */ @PostMapping("/page") R<IPage<UnionOutdoorSite>> query(@RequestBody UnionOutdoorSiteDto unionOutdoorSiteDto) { return unionOutdoorSiteService.query(unionOutdoorSiteDto); } /** * 查询总工会户外劳工站 * * @param id * 户外劳工站 id * @return 查找结果 */ @GetMapping("/{id}") R unionOutdoorSiteDetail(@PathVariable("id") Long id) { return unionOutdoorSiteService.unionOutdoorSiteDetails(id); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/VideoManageApi.java
New file @@ -0,0 +1,4 @@ package com.panzhihua.service_equipment.api; public class VideoManageApi { } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MyMetaObjectHandler.java
New file @@ -0,0 +1,41 @@ package com.panzhihua.service_grid.config; import java.util.Date; import org.apache.ibatis.reflection.MetaObject; import org.springframework.stereotype.Component; import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler; import lombok.extern.slf4j.Slf4j; /** * @program: springcloud_k8s_panzhihuazhihuishequ * @description: 自动填充 * @author: huang.hongfa weixin hhf9596 qq 959656820 * @create: 2020-12-11 14:23 **/ @Slf4j @Component public class MyMetaObjectHandler implements MetaObjectHandler { @Override public void insertFill(MetaObject metaObject) { log.info("start insert fill ...."); // this.strictInsertFill(metaObject, "createTime", Date.class, new Date()); // 起始版本 3.3.0(推荐使用) // 或者 this.strictInsertFill(metaObject, "createAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐) this.strictInsertFill(metaObject, "updateAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐) // 或者 // this.fillStrategy(metaObject, "createTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug) } @Override public void updateFill(MetaObject metaObject) { log.info("start update fill ...."); // this.strictUpdateFill(metaObject, "updateTime", LocalDateTime.class, LocalDateTime.now()); // 起始版本 3.3.0(推荐) // 或者 this.strictUpdateFill(metaObject, "updateAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐) // 或者 // this.fillStrategy(metaObject, "updateTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug) } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MybatisHmkInterceptor.java
New file @@ -0,0 +1,24 @@ package com.panzhihua.service_grid.config; import com.baomidou.mybatisplus.core.toolkit.PluginUtils; import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.mapping.BoundSql; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.session.ResultHandler; import org.apache.ibatis.session.RowBounds; import java.sql.SQLException; public class MybatisHmkInterceptor implements InnerInterceptor { @Override public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException { String sql=boundSql.getSql(); if(sql.contains("community_id = 10086")){ sql=sql.replace("community_id = 10086","community_id in (30,31)"); PluginUtils.mpBoundSql(boundSql).sql(sql); } InnerInterceptor.super.beforeQuery(executor, ms, parameter, rowBounds, resultHandler, boundSql); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MybatisPlusConfig.java
New file @@ -0,0 +1,38 @@ package com.panzhihua.service_grid.config; import org.mybatis.spring.annotation.MapperScan; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.autoconfigure.ConfigurationCustomizer; import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; /** * @program: springcloud_k8s_panzhihuazhihuishequ * @description: 分页 * @author: huang.hongfa weixin hhf9596 qq 959656820 * @create: 2020-11-30 16:26 **/ @MapperScan({"com.panzhihua.service_grid.dao*"}) @Configuration public class MybatisPlusConfig { /** * 新的分页插件,一缓和二缓遵循mybatis的规则,需要设置 MybatisConfiguration#useDeprecatedExecutor = false 避免缓存出现问题(该属性会在旧插件移除后一同移除) */ @Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(new MybatisHmkInterceptor()); interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.H2)); return interceptor; } @Bean public ConfigurationCustomizer configurationCustomizer() { return configuration -> configuration.setUseDeprecatedExecutor(false); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionOutdoorLaborDynamicMapper.java
New file @@ -0,0 +1,18 @@ package com.panzhihua.service_equipment.dao; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; import org.apache.ibatis.annotations.Mapper; /** * <p> * 总工会-户外劳工站-动态 * </p> * * @author fengjin * @since 2023-08-21 */ @Mapper public interface UnionOutdoorLaborDynamicMapper extends BaseMapper<UnionOutdoorLaborDynamic> { } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionOutdoorServiceRangeMapper.java
New file @@ -0,0 +1,18 @@ package com.panzhihua.service_equipment.dao; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.panzhihua.service_equipment.model.dos.UnionOutdoorServiceRange; import org.apache.ibatis.annotations.Mapper; /** * <p> * 户外站点分类表 Mapper 接口 * </p> * * @author fengjin * @since 2023-08-23 */ @Mapper public interface UnionOutdoorServiceRangeMapper extends BaseMapper<UnionOutdoorServiceRange> { } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionOutdoorSiteMapper.java
New file @@ -0,0 +1,18 @@ package com.panzhihua.service_equipment.dao; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; import org.apache.ibatis.annotations.Mapper; /** * <p> * 总工会户外劳工站 Mapper 接口 * </p> * * @author fengjin * @since 2023-08-23 */ @Mapper public interface UnionOutdoorSiteMapper extends BaseMapper<UnionOutdoorSite> { } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/Structured.java
New file @@ -0,0 +1,91 @@ package com.panzhihua.service_equipment.model.dos; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.util.List; @ApiModel("结构化数据类") @Data public class Structured { @ApiModelProperty("跟踪 ID") private String traceId; @ApiModelProperty("结构化 ID") private String structuredId; @ApiModelProperty("外部设备 ID") private String extDeviceId; @ApiModelProperty("设备编码") private String deviceCode; @ApiModelProperty("平台编码") private String platformCode; @ApiModelProperty("应用密钥") private String appKey; @ApiModelProperty("能力编码") private String abilityCode; @ApiModelProperty("能力版本") private String abilityVersion; @ApiModelProperty("API ID") private Long apiId; @ApiModelProperty("创建时间") private Long gmtCreate; @ApiModelProperty("设备名称") private String deviceName; @ApiModelProperty("设备 ID") private Long deviceId; @ApiModelProperty("组织 ID") private Long orgId; @ApiModelProperty("结构化数据") private String structuredData; @ApiModelProperty("图片路径") private String picPath; @ApiModelProperty("图片 Base64") private String imageBase64; @ApiModelProperty("视频 Base64") private String videoBase64; @ApiModelProperty("视频路径") private String videoPath; @ApiModelProperty("能力名称") private String abilityName; @ApiModelProperty("能力 ID") private Long abilityId; @ApiModelProperty("识别结果") private String recognitionResult; @ApiModelProperty("帧时间") private String frameTime; @ApiModelProperty("API 参数") private String apiParams; @ApiModelProperty("平台代码") private String plaformCode; @ApiModelProperty("预设图像路径") private String presetImagePath; @ApiModelProperty("事件临时名称") private String eventTempName; } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorLaborDynamic.java
New file @@ -0,0 +1,94 @@ package com.panzhihua.service_equipment.model.dos; import com.baomidou.mybatisplus.annotation.TableName; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.io.Serializable; import java.time.LocalDateTime; /** * <p> * 总工会-户外劳工站-动态 * </p> * * @author fengjin * @since 2023-08-21 */ @TableName("union_outdoor_labor_dynamic") @Data public class UnionOutdoorLaborDynamic implements Serializable { /** * ,主键 */ @ApiModelProperty(value = "主键") private Long id; /** * 标题 */ @ApiModelProperty(value = "标题") private String title; /** * 状态 0 待发布 1 已发布 */ @ApiModelProperty(value = "状态 0 待发布 1 已发布") private Integer status; /** * 是否置顶 0 否 1 是 */ @ApiModelProperty(value = "是否置顶 0 否 1 是") private Integer isTopping; /** * 发布时间 */ @ApiModelProperty(value = " 发布时间") private LocalDateTime publishAt; /** * 创建时间 */ @ApiModelProperty(value = "创建时间") private LocalDateTime createAt; /** * 修改时间 */ @ApiModelProperty(value = "修改时间") private LocalDateTime updateAt; /** * 动态内容 富文本 */ @ApiModelProperty(value = "动态内容 富文本") private String content; /** * 封面 */ @ApiModelProperty(value = "封面") private String cover; /** * 类型(1.通知公告 2.使用指南 3.工会信息) */ @ApiModelProperty(value = "类型(1.通知公告 2.使用指南 3.工会信息)") private Integer type; /** * 阅读量 */ @ApiModelProperty(value = "阅读量") private Integer readNum; /** * 图片链接 */ @ApiModelProperty(value = "图片链接") private String imageUrl; } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorServiceRange.java
New file @@ -0,0 +1,72 @@ 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 lombok.Data; import java.io.Serializable; import java.time.LocalDateTime; /** * <p> * 户外站点分类表 * </p> * * @author fengjin * @since 2023-08-23 */ @Data @TableName("union_outdoor_service_range") public class UnionOutdoorServiceRange implements Serializable { private static final long serialVersionUID = 1L; /** * ,主键 */ @TableId(value = "id", type = IdType.AUTO) private Long id; /** * 产品分类名称 */ private String name; /** * 备注 */ private String remark; /** * 是否删除(0否1是) */ private Boolean isDel; /** * 创建时间 */ private LocalDateTime createdAt; /** * 创建人 */ private Long createdBy; /** * 更新时间 */ private LocalDateTime updatedAt; /** * 更新人 */ private Long updatedBy; /** * 父级id */ private Integer parentId; } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.java
New file @@ -0,0 +1,186 @@ package com.panzhihua.service_equipment.model.dos; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableField; 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; import java.time.LocalTime; import java.util.List; /** * <p> * 总工会户外劳工站 * </p> * * @author fengjin * @since 2023-08-23 */ @TableName("union_outdoor_site") @Data @ApiModel("总工会户外劳工站") public class UnionOutdoorSite implements Serializable { private static final long serialVersionUID = 1L; @TableId(value = "id", type = IdType.AUTO) private Integer id; /** * 商家名称 */ @ApiModelProperty(value = "商家名称") private String name; /** * 商家logo */ @ApiModelProperty(value = "商家logo") private String logo; /** * 联系人 */ @ApiModelProperty(value = "联系人") private String contacts; /** * 身份证号 */ @ApiModelProperty(value = "身份证号") private String idCard; /** * 咨询电话 */ @ApiModelProperty(value = "咨询电话") private String phone; /** * 商家地址 */ @ApiModelProperty(value = "商家地址") private String address; /** * 详细地址 */ @ApiModelProperty(value = "详细地址") private String detailedAddress; /** * 纬度 */ @ApiModelProperty(value = "主键") private String lat; /** * 经度 */ @ApiModelProperty(value = "经度") private String lon; /** * 营业开始时间 */ @ApiModelProperty(value = "营业开始时间") private LocalTime beginAt; /** * 营业结束时间 */ @ApiModelProperty(value = "营业结束时间") private LocalTime endAt; /** * 商家介绍 */ @ApiModelProperty(value = "商家介绍") private String introduction; /** * 是否营业中 */ @ApiModelProperty(value = "是否营业中") private Boolean businessStatus; /** * 商家绑定账户id */ @ApiModelProperty(value = "商家绑定账户id") private Long userId; /** * 咨询量 */ @ApiModelProperty(value = "咨询量") private Integer consultationVolume; /** * 浏览量 */ @ApiModelProperty(value = "浏览量") private Integer viewNum; /** * 是否删除 */ @ApiModelProperty(value = "是否删除") private Boolean isDel; /** * 创建时间 */ @ApiModelProperty(value = "创建时间") private LocalDateTime createdAt; /** * 创建人 */ @ApiModelProperty(value = "创建人") private Long createdBy; /** * 更新时间 */ @ApiModelProperty(value = "更新时间") private LocalDateTime updatedAt; /** * 更新人 */ @ApiModelProperty(value = "更新人") private Long updatedBy; /** * 区域编码 */ @ApiModelProperty(value = "区域编码") private String areaCode; /** * 手机号 */ @ApiModelProperty(value = "手机号") private String mobilePhone; /** * 服务范围 */ @ApiModelProperty(value = "服务范围") private String serviceRange; /** * 服务列表 */ @TableField(exist = false) @ApiModelProperty("服务列表") private List<UnionOutdoorServiceRange> unionOutdoorServiceRangeList; } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/helper/encrypt/ParammeterInterceptor.java
New file @@ -0,0 +1,118 @@ package com.panzhihua.service_equipment.model.helper.encrypt; import java.lang.reflect.Field; import java.sql.PreparedStatement; import java.util.Iterator; import java.util.Map; import java.util.Objects; import java.util.Properties; import org.apache.ibatis.binding.BindingException; import org.apache.ibatis.binding.MapperMethod; import org.apache.ibatis.executor.parameter.ParameterHandler; import org.apache.ibatis.plugin.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.stereotype.Component; import com.panzhihua.common.model.helper.encrypt.EncryptDecryptClass; import com.panzhihua.common.model.helper.encrypt.EncryptQuery; import com.panzhihua.common.model.helper.encrypt.EncryptQueryClass; import com.panzhihua.common.model.helper.encrypt.IEncryptDecrypt; import lombok.extern.slf4j.Slf4j; /** * 加密拦截器 包含加密字段查询时 的加密步骤 * * @author cedoo * @since 2021-4-1 10:40:52 */ @Intercepts({@Signature(type = ParameterHandler.class, method = "setParameters", args = PreparedStatement.class),}) @ConditionalOnProperty(value = "domain.encrypt", havingValue = "true") @Component @Slf4j public class ParammeterInterceptor implements Interceptor { @Autowired private IEncryptDecrypt encryptDecrypt; @Override public Object intercept(Invocation invocation) throws Throwable { // 拦截 ParameterHandler 的 setParameters 方法 动态设置参数 if (invocation.getTarget() instanceof ParameterHandler) { ParameterHandler parameterHandler = (ParameterHandler)invocation.getTarget(); PreparedStatement ps = (PreparedStatement)invocation.getArgs()[0]; // 反射获取 参数对像 Field parameterField = parameterHandler.getClass().getDeclaredField("parameterObject"); parameterField.setAccessible(true); Object parameterObject = parameterField.get(parameterHandler); if (Objects.nonNull(parameterObject)) { Class<?> parameterObjectClass = parameterObject.getClass(); EncryptDecryptClass encryptDecryptClass = AnnotationUtils.findAnnotation(parameterObjectClass, EncryptDecryptClass.class); if (Objects.nonNull(encryptDecryptClass)) { Field[] declaredFields = parameterObjectClass.getDeclaredFields(); final Object encrypt = encryptDecrypt.encrypt(declaredFields, parameterObject); } /** * 通过加密字段查询时, 将查询参数中的加密字段加密后查询 */ if (parameterObjectClass == MapperMethod.ParamMap.class) { MapperMethod.ParamMap paramMap = (MapperMethod.ParamMap)parameterObject; boolean encrypted = false; try { /** * 分页插件,会在分页查询时 进行多次查询,需要判断是否已对加密参数加密,防止多次加密后,查询失败 */ encrypted = paramMap.get("encrypted") != null; } catch (BindingException be) { encrypted = false; } if (!encrypted) { Iterator iterator = paramMap.entrySet().iterator(); while (iterator.hasNext()) { Map.Entry<String, Object> entry = (Map.Entry<String, Object>)iterator.next(); if (entry.getKey().startsWith("param")) { Object v = entry.getValue(); if (v != null) { EncryptQueryClass encryptQueryClass = AnnotationUtils.findAnnotation(v.getClass(), EncryptQueryClass.class); if (Objects.nonNull(encryptQueryClass)) { Field[] declaredFields = v.getClass().getDeclaredFields(); for (Field field : declaredFields) { if (field.isAnnotationPresent(EncryptQuery.class)) { try { final Object encrypt = encryptDecrypt.encrypt(new Field[] {field}, v); paramMap.put("encrypted", true); } catch (IllegalAccessException e) { e.printStackTrace(); } } } } } } } } } } } return invocation.proceed(); } @Override public Object plugin(Object o) { return Plugin.wrap(o, this); } @Override public void setProperties(Properties properties) { } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/helper/encrypt/ResultInterceptor.java
New file @@ -0,0 +1,78 @@ package com.panzhihua.service_equipment.model.helper.encrypt; import java.sql.Statement; import java.util.ArrayList; import java.util.Objects; import java.util.Properties; import org.apache.ibatis.executor.resultset.ResultSetHandler; import org.apache.ibatis.plugin.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; import com.panzhihua.common.model.helper.encrypt.EncryptDecryptClass; import com.panzhihua.common.model.helper.encrypt.IEncryptDecrypt; import lombok.extern.slf4j.Slf4j; /** * 解密拦截器 * * @author cedoo * @since 2021-4-1 10:40:52 */ @Intercepts({@Signature(type = ResultSetHandler.class, method = "handleResultSets", args = {Statement.class})}) @ConditionalOnProperty(value = "domain.decrypt", havingValue = "true") @Component @Slf4j @Order(110) public class ResultInterceptor implements Interceptor { @Autowired private IEncryptDecrypt encryptDecrypt; @Override public Object intercept(Invocation invocation) throws Throwable { Object result = invocation.proceed(); if (Objects.isNull(result)) { return null; } if (result instanceof ArrayList) { ArrayList resultList = (ArrayList)result; if (resultList != null && resultList.size() > 0 && needToDecrypt(resultList.get(0))) { for (int i = 0; i < resultList.size(); i++) { encryptDecrypt.decrypt(resultList.get(i)); } } } else { if (needToDecrypt(result)) { encryptDecrypt.decrypt(result); } } return result; } public boolean needToDecrypt(Object object) { if (object != null) { Class<?> objectClass = object.getClass(); EncryptDecryptClass encryptDecryptClass = AnnotationUtils.findAnnotation(objectClass, EncryptDecryptClass.class); return Objects.nonNull(encryptDecryptClass); } return false; } @Override public Object plugin(Object target) { return Plugin.wrap(target, this); } @Override public void setProperties(Properties properties) { } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/helper/sensitive/SensitiveInterceptor.java
New file @@ -0,0 +1,73 @@ package com.panzhihua.service_grid.model.helper.sensitive; import java.lang.reflect.Field; import java.sql.Statement; import java.util.List; import java.util.stream.Stream; import org.apache.ibatis.executor.resultset.ResultSetHandler; import org.apache.ibatis.plugin.Interceptor; import org.apache.ibatis.plugin.Intercepts; import org.apache.ibatis.plugin.Invocation; import org.apache.ibatis.plugin.Signature; import org.apache.ibatis.reflection.MetaObject; import org.apache.ibatis.reflection.SystemMetaObject; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; import com.panzhihua.common.model.helper.sensitive.Sensitive; import com.panzhihua.common.model.helper.sensitive.SensitiveStrategy; import lombok.extern.slf4j.Slf4j; /** * 字段脱敏拦截器 * * @author cedoo * @since 2021-4-1 10:40:52 */ @Intercepts(@Signature(type = ResultSetHandler.class, method = "handleResultSets", args = {Statement.class})) @Slf4j @ConditionalOnProperty(value = "domain.sensitive", havingValue = "true") @Component @Order(120) public class SensitiveInterceptor implements Interceptor { @SuppressWarnings("unchecked") @Override public Object intercept(Invocation invocation) throws Throwable { // log.debug("脱敏拦截器"); List<Object> records = (List<Object>)invocation.proceed(); // 对结果集脱敏 records.forEach(this::sensitive); return records; } private void sensitive(Object source) { if (source != null) { // 拿到返回值类型 Class<?> sourceClass = source.getClass(); // 初始化返回值类型的 MetaObject MetaObject metaObject = SystemMetaObject.forObject(source); // 捕捉到属性上的标记注解 @Sensitive 并进行对应的脱敏处理 Stream.of(sourceClass.getDeclaredFields()).filter(field -> field.isAnnotationPresent(Sensitive.class)) .forEach(field -> doSensitive(metaObject, field)); } } private void doSensitive(MetaObject metaObject, Field field) { // 拿到属性名 String name = field.getName(); // 获取属性值 Object value = metaObject.getValue(name); // 只有字符串类型才能脱敏 而且不能为null if (String.class == metaObject.getGetterType(name) && value != null) { Sensitive annotation = field.getAnnotation(Sensitive.class); // 获取对应的脱敏策略 并进行脱敏 SensitiveStrategy type = annotation.strategy(); Object o = type.getDesensitizer().apply((String)value); // 把脱敏后的值塞回去 metaObject.setValue(name, o); } } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionOutdoorLaborDynamicService.java
New file @@ -0,0 +1,26 @@ package com.panzhihua.service_equipment.service; import com.baomidou.mybatisplus.core.metadata.IPage; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; public interface UnionOutdoorLaborDynamicService { /** * 分页总工会-户外劳工站-动态 * * @param unionOutdoorLaborDynamicDto * @return 动态结果 */ R<IPage<UnionOutdoorLaborDynamic>> query(UnionOutdoorLaborDynamicDto unionOutdoorLaborDynamicDto); /** * 查询总工会-户外劳工站-动态 * * @param id * 动态 id * @return 查找结果 */ R<UnionOutdoorLaborDynamic> unionOutdoorLaborDynamicDetails(Long id); } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionOutdoorSiteService.java
New file @@ -0,0 +1,26 @@ package com.panzhihua.service_equipment.service; import com.baomidou.mybatisplus.core.metadata.IPage; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; public interface UnionOutdoorSiteService { /** * 分页总工会户外劳工站 * * @param unionOutdoorSiteDto * @return 动态结果 */ R<IPage<UnionOutdoorSite>> query(UnionOutdoorSiteDto unionOutdoorSiteDto); /** * 查询总工会户外劳工站 * * @param id * 户外劳工站 id * @return 查找结果 */ R<UnionOutdoorSite> unionOutdoorSiteDetails(Long id); } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.java
New file @@ -0,0 +1,66 @@ 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.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.grid.PageEasyAppDTO; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.grid.ComActEasyPhotoTypeDetailsVO; import com.panzhihua.common.model.vos.grid.ComActEasyPhotoVO; import com.panzhihua.service_equipment.dao.UnionOutdoorLaborDynamicMapper; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; import com.panzhihua.service_equipment.service.UnionOutdoorLaborDynamicService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; @Slf4j @Service public class UnionOutdoorLaborDynamicServiceImpl extends ServiceImpl<UnionOutdoorLaborDynamicMapper, UnionOutdoorLaborDynamic> implements UnionOutdoorLaborDynamicService { /** * 分页总工会-户外劳工站-动态 * * @param unionOutdoorLaborDynamicDto * @return 动态结果 */ @Override public R<IPage<UnionOutdoorLaborDynamic>> query(UnionOutdoorLaborDynamicDto unionOutdoorLaborDynamicDto) { Page page = new Page(unionOutdoorLaborDynamicDto.getPageNum(), unionOutdoorLaborDynamicDto.getPageSize()); QueryWrapper<UnionOutdoorLaborDynamic> unionOutdoorLaborDynamicQueryWrapper = new QueryWrapper<>(); if (unionOutdoorLaborDynamicDto.getType() != null) { switch (unionOutdoorLaborDynamicDto.getType()) { case 1: case 2: case 3: unionOutdoorLaborDynamicQueryWrapper.eq("type",unionOutdoorLaborDynamicDto.getType()); break; } } return R.ok( baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper)); } /** * 查询总工会-户外劳工站-动态 * * @param id * 动态 id * @return 查找结果 */ @Override public R<UnionOutdoorLaborDynamic> unionOutdoorLaborDynamicDetails(Long id) { UnionOutdoorLaborDynamic unionOutdoorLaborDynamic = baseMapper.selectById(id); if (unionOutdoorLaborDynamic != null) { // UnionOutdoorLaborDynamic unionOutdoorLaborDynamic1 = new ComActEasyPhotoTypeDetailsVO(); // BeanUtils.copyProperties(unionOutdoorLaborDynamic, comActEasyPhotoTypeDetailsVO); unionOutdoorLaborDynamic.setReadNum(unionOutdoorLaborDynamic.getReadNum()+1); baseMapper.updateById(unionOutdoorLaborDynamic); return R.ok(unionOutdoorLaborDynamic); } return R.fail(); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.java
New file @@ -0,0 +1,58 @@ 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.UnionOutdoorLaborDynamicDto; import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto; import com.panzhihua.common.model.vos.R; import com.panzhihua.service_equipment.dao.UnionOutdoorServiceRangeMapper; import com.panzhihua.service_equipment.dao.UnionOutdoorSiteMapper; import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic; import com.panzhihua.service_equipment.model.dos.UnionOutdoorServiceRange; import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite; import com.panzhihua.service_equipment.service.UnionOutdoorSiteService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.List; @Slf4j @Service public class UnionOutdoorSiteServiceImpl extends ServiceImpl<UnionOutdoorSiteMapper, UnionOutdoorSite> implements UnionOutdoorSiteService { @Resource private UnionOutdoorServiceRangeMapper unionOutdoorServiceRangeMapper; /** * 分页总工会户外劳工站 * * @param unionOutdoorSiteDto * @return 动态结果 */ @Override public R<IPage<UnionOutdoorSite>> query(UnionOutdoorSiteDto unionOutdoorSiteDto) { Page page = new Page(unionOutdoorSiteDto.getPageNum(), unionOutdoorSiteDto.getPageSize()); QueryWrapper<UnionOutdoorSite> unionOutdoorLaborDynamicQueryWrapper = new QueryWrapper<>(); if (unionOutdoorSiteDto.getAreaCode()!=null) unionOutdoorLaborDynamicQueryWrapper.eq("area_code",unionOutdoorSiteDto.getAreaCode()); return R.ok( baseMapper.selectPage(page, unionOutdoorLaborDynamicQueryWrapper)); } @Override public R<UnionOutdoorSite> unionOutdoorSiteDetails(Long id) { UnionOutdoorSite unionOutdoorSite = baseMapper.selectById(id); if (unionOutdoorSite != null) { unionOutdoorSite.setViewNum(unionOutdoorSite.getViewNum()+1); baseMapper.updateById(unionOutdoorSite); QueryWrapper<UnionOutdoorServiceRange> queryWrapper = new QueryWrapper<>(); queryWrapper.inSql("id", "SELECT service_range_id FROM union_outdoor_site_service_range WHERE site_id = " + id); unionOutdoorSite.setUnionOutdoorServiceRangeList(unionOutdoorServiceRangeMapper.selectList(queryWrapper)); return R.ok(unionOutdoorSite); } return R.fail(); } } springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/bootstrap.yml
New file @@ -0,0 +1,38 @@ spring: application: name: equipment cloud: config: discovery: enabled: true service-id: huacheng-config # 注册中心的服务名 profile: ${ENV:dev} # 指定配置文件的环境 uri: http://${CONFIG_URL:localhost}:6193/ profiles: active: ${ENV:dev} eureka: client: service-url: defaultZone: http://${EUREKA_URL:localhost}:8192/eureka #实体加密、解密、字段脱敏拦截设置 domain: decrypt: true encrypt: true aesKey: Ryo7M3n8loC5 sensitive: true management: endpoints: web: exposure: include: '*' endpoint: health: show-details: always metrics: tags: application: equipment springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/logback-spring.xml
New file @@ -0,0 +1,51 @@ <?xml version="1.0" encoding="UTF-8"?> <configuration debug="false"> <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径--> <springProfile name="dev"> <property name="LOG_HOME" value="F:/log" /> </springProfile> <springProfile name="test"> <property name="LOG_HOME" value="/mnt/data/gocd/log" /> </springProfile> <property name="LOG_HOME" value="/mnt/data/gocd/log" /> <!-- 控制台输出 --> <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> </encoder> </appender> <!-- 按照每天生成日志文件 --> <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <!--日志文件输出的文件名--> <FileNamePattern>${LOG_HOME}/service_grid.log.%d{yyyy-MM-dd}.log</FileNamePattern> <!--日志文件保留天数--> <MaxHistory>30</MaxHistory> </rollingPolicy> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> </encoder> <!--日志文件最大的大小--> <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> <MaxFileSize>10MB</MaxFileSize> </triggeringPolicy> </appender> <!--myibatis log configure--> <logger name="com.apache.ibatis" level="TRACE"/> <logger name="java.sql.Connection" level="DEBUG"/> <logger name="java.sql.Statement" level="DEBUG"/> <logger name="java.sql.PreparedStatement" level="DEBUG"/> <logger name="com.panzhihua.service_community" level="DEBUG"/> <!-- 日志输出级别 --> <root level="DEBUG"> <appender-ref ref="STDOUT" /> </root> <root level="INFO"> <appender-ref ref="STDOUT" /> <appender-ref ref="FILE" /> </root> </configuration> springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionOutdoorLaborDynamicMapper.xml
New file @@ -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.UnionOutdoorLaborDynamicMapper"> </mapper> springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionOutdoorServiceRangeMapper.xml
New file @@ -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.UnionOutdoorServiceRangeMapper"> </mapper> springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/resources/mapper/UnionOutdoorSiteMapper.xml
New file @@ -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.UnionOutdoorSiteMapper"> </mapper> springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/bootstrap.yml
New file @@ -0,0 +1,38 @@ spring: application: name: equipment cloud: config: discovery: enabled: true service-id: huacheng-config # 注册中心的服务名 profile: ${ENV:dev} # 指定配置文件的环境 uri: http://${CONFIG_URL:localhost}:6193/ profiles: active: ${ENV:dev} eureka: client: service-url: defaultZone: http://${EUREKA_URL:localhost}:8192/eureka #实体加密、解密、字段脱敏拦截设置 domain: decrypt: true encrypt: true aesKey: Ryo7M3n8loC5 sensitive: true management: endpoints: web: exposure: include: '*' endpoint: health: show-details: always metrics: tags: application: equipment springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/ServiceEquipmentApplication.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/RoomckWebApi.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/UnionOutdoorLaborDynamicApi.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/UnionOutdoorSiteApi.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/api/VideoManageApi.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/dao/UnionOutdoorLaborDynamicMapper.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/dao/UnionOutdoorServiceRangeMapper.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/dao/UnionOutdoorSiteMapper.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/Structured.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorLaborDynamic.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorServiceRange.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/dos/UnionOutdoorSite.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/helper/encrypt/ParammeterInterceptor.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/model/helper/encrypt/ResultInterceptor.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/UnionOutdoorLaborDynamicService.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/UnionOutdoorSiteService.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorLaborDynamicServiceImpl.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_equipment/service/impl/UnionOutdoorSiteServiceImpl.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_grid/config/MyMetaObjectHandler.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_grid/config/MybatisHmkInterceptor.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_grid/config/MybatisPlusConfig.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/com/panzhihua/service_grid/model/helper/sensitive/SensitiveInterceptor.classBinary files differ
springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/logback-spring.xml
New file @@ -0,0 +1,51 @@ <?xml version="1.0" encoding="UTF-8"?> <configuration debug="false"> <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径--> <springProfile name="dev"> <property name="LOG_HOME" value="F:/log" /> </springProfile> <springProfile name="test"> <property name="LOG_HOME" value="/mnt/data/gocd/log" /> </springProfile> <property name="LOG_HOME" value="/mnt/data/gocd/log" /> <!-- 控制台输出 --> <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> </encoder> </appender> <!-- 按照每天生成日志文件 --> <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <!--日志文件输出的文件名--> <FileNamePattern>${LOG_HOME}/service_grid.log.%d{yyyy-MM-dd}.log</FileNamePattern> <!--日志文件保留天数--> <MaxHistory>30</MaxHistory> </rollingPolicy> <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> <!--格式化输出:%d表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度%msg:日志消息,%n是换行符--> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> </encoder> <!--日志文件最大的大小--> <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy"> <MaxFileSize>10MB</MaxFileSize> </triggeringPolicy> </appender> <!--myibatis log configure--> <logger name="com.apache.ibatis" level="TRACE"/> <logger name="java.sql.Connection" level="DEBUG"/> <logger name="java.sql.Statement" level="DEBUG"/> <logger name="java.sql.PreparedStatement" level="DEBUG"/> <logger name="com.panzhihua.service_community" level="DEBUG"/> <!-- 日志输出级别 --> <root level="DEBUG"> <appender-ref ref="STDOUT" /> </root> <root level="INFO"> <appender-ref ref="STDOUT" /> <appender-ref ref="FILE" /> </root> </configuration> springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/mapper/UnionOutdoorLaborDynamicMapper.xml
New file @@ -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.UnionOutdoorLaborDynamicMapper"> </mapper> springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/mapper/UnionOutdoorServiceRangeMapper.xml
New file @@ -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.UnionOutdoorServiceRangeMapper"> </mapper> springcloud_k8s_panzhihuazhihuishequ/service_equipment/target/classes/mapper/UnionOutdoorSiteMapper.xml
New file @@ -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.UnionOutdoorSiteMapper"> </mapper>