diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..549e00a --- /dev/null +++ b/.gitignore @@ -0,0 +1,33 @@ +HELP.md +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea +*.iws +*.iml +*.ipr + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ diff --git a/Dockerfile-gz b/Dockerfile-gz new file mode 100644 index 0000000..982ea9b --- /dev/null +++ b/Dockerfile-gz @@ -0,0 +1,7 @@ +FROM harbor.dcos.guangzhou.unicom.local/eshop/skywalking_agent_springboot_8.1.0:v1.0 +ENV LC_ALL=zh_CN.utf8 +ENV LANG=zh_CN.utf8 +ENV LANGUAGE=zh_CN.utf8 +RUN localedef -c -f UTF-8 -i zh_CN zh_CN.utf8 +ADD /target/biz_service_ebtp_extend-0.0.1.jar /biz_service_ebtp_extend-0.0.1.jar +ENTRYPOINT ["java", "-Djava.security.egd=file:/dev/./urandom", "-jar", "/biz_service_ebtp_extend-0.0.1.jar"] diff --git a/README.md b/README.md new file mode 100644 index 0000000..33c31eb --- /dev/null +++ b/README.md @@ -0,0 +1,10 @@ +# 扩展功能微服务组件 + + 公告通知功能、共享文档... + +## 组件模块 + + 1. 包名：功能 + 2. 包名：功能 + 3. 包名：功能 + diff --git a/READNE.md b/READNE.md deleted file mode 100644 index c57eff5..0000000 --- a/READNE.md +++ /dev/null @@ -1 +0,0 @@ -Hello World! \ No newline at end of file diff --git a/config-gz b/config-gz new file mode 100644 index 0000000..6fe3b43 --- /dev/null +++ b/config-gz @@ -0,0 +1,17 @@ +apiVersion: v1 +clusters: +- cluster: + insecure-skip-tls-verify: true + server: https://10.125.164.35:48662 + name: demok8s +contexts: +- context: + cluster: demok8s + user: cluster-admin + name: default +current-context: default +kind: Config +users: +- name: cluster-admin + user: + token: df5e4896a4f6d1b1447b2584ca7405f7 diff --git a/deployment-gz.yaml b/deployment-gz.yaml new file mode 100644 index 0000000..ae3756b --- /dev/null +++ b/deployment-gz.yaml @@ -0,0 +1,83 @@ +# 接口版本 +apiVersion: apps/v1 +# 接口类型 +kind: Deployment +metadata: + name: biz-service-ebtp-extend + namespace: default + labels: + app: biz-service-ebtp-extend + +# 必选，详细定义 +spec: + # pod 副本数量 + replicas: 1 + + # 滚动升级配置信息 + strategy: + rollingUpdate: + maxSurge: 1 + maxUnavailable: 1 + + # 选择器，匹配pod模板 + selector: + matchLabels: + app: biz-service-ebtp-extend + + template: + metadata: + labels: + # 模板名称 + app: biz-service-ebtp-extend + + # 定义容器模板，该模板可以包含多个容器 + spec: + # 挂载日志存储 + volumes: + - name: log + persistentVolumeClaim: + claimName: log-pvc + readOnly: false + - name: storage + persistentVolumeClaim: + claimName: file-pvc + readOnly: false + + # 必选，Pod中容器列表 + containers: + - name: biz-service-ebtp-extend + image: harbor.dcos.guangzhou.unicom.local/eshop/biz-service-ebtp-extend:latest + # 在容器中挂载日志存储区 + volumeMounts: + - name: log + mountPath: /log + - name: storage + mountPath: /storage + # 需要暴露的端口库号列表 + ports: + - containerPort: 18018 + # 容器运行前需设置的环境变量列表 + env: + # Apollo 配置中心变量设置 + - name: APOLLO_CONFIGSERVICE + value: http://10.242.31.158:6001 +--- +kind: Service +apiVersion: v1 +metadata: + name: biz-service-ebtp-extend + namespace: default + labels: + app: biz-service-ebtp-extend + annotations: + lb.cke.tg.unicom/target-vports: 18018-18018 +spec: + ports: + - port: 18018 + targetPort: 18018 + selector: + app: biz-service-ebtp-extend +status: + loadBalancer: {} + +--- \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..f696803 --- /dev/null +++ b/pom.xml @@ -0,0 +1,117 @@ + + + 4.0.0 + + + com.chinaunicom.ebtp + mall-ebtp-cloud-parent + 0.0.1-SNAPSHOT + + + com.chinaunicom.mall.ebtp + biz_service_ebtp_extend + 0.0.1 + biz_service_ebtp_extend + + + + + com.chinaunicom.mall.ebtp + uboot-core + 0.0.2-SNAPSHOT + + + com.chinaunicom.ebtp + mall-ebtp-cloud-security-starter + + + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-attachment-sdk + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-eureka-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-feign-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-apollo-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-jpa-starter + + + mysql + mysql-connector-java + + + org.apache.shardingsphere + sharding-jdbc-spring-boot-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-seata-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-swagger-starter + + + + com.chinaunicom.ebtp + mall-ebtp-cloud-redis-starter + + + + + + + maven-snapshot-local + maven-snapshot-local + http://ccp.tianti.tg.unicom.local/artifactory/tianti-maven-snapshot-local/ + + false + + + true + + + + + + + + src/main/resources + true + + + src/main/java + + **/mapper/*Mapper.xml + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/BizServiceEbtpExtendApplication.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/BizServiceEbtpExtendApplication.java new file mode 100644 index 0000000..4cdccbc --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/BizServiceEbtpExtendApplication.java @@ -0,0 +1,26 @@ +package com.chinaunicom.mall.ebtp.extend; + +import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure; +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.cloud.netflix.eureka.EnableEurekaClient; +import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.context.annotation.ComponentScan; + +@SpringBootApplication(exclude = { + DataSourceAutoConfiguration.class, + DruidDataSourceAutoConfigure.class +}) +@EnableFeignClients +@EnableEurekaClient +@MapperScan({"com.chinaunicom.mall.ebtp.extend.**.dao"}) +@ComponentScan("com.chinaunicom.mall.ebtp.*") +public class BizServiceEbtpExtendApplication { + + public static void main(String[] args) { + SpringApplication.run(BizServiceEbtpExtendApplication.class, args); + } + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/column/BizBidNoticeField.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/column/BizBidNoticeField.java new file mode 100644 index 0000000..7265bf7 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/column/BizBidNoticeField.java @@ -0,0 +1,42 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.column; + +/** + * 字段常量 BizBidNotice + * + * @auto.generated + */ +public class BizBidNoticeField { + + + /** + * + */ + public static final String NOTICE_ID = "notice_id"; + + /** + * 标题 + */ + public static final String NOTICE_TITLE = "notice_title"; + + /** + * 内容 + */ + public static final String NOTICE_CONTENT = "notice_content"; + + /** + * 文件名 + */ + public static final String NOTICE_FILE_NAME = "notice_file_name"; + + /** + * 文件URL + */ + public static final String NOTICE_FILE_URL = "notice_file_url"; + + + + + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/controller/BizBidNoticeController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/controller/BizBidNoticeController.java new file mode 100644 index 0000000..5266a1a --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/controller/BizBidNoticeController.java @@ -0,0 +1,202 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.controller; + +import java.util.List; + +import javax.annotation.Resource; +import javax.validation.Valid; + +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +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 com.chinaunicom.mall.ebtp.common.base.entity.BaseResponse; +import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.entity.BizBidNotice; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.service.IBizBidNoticeService; + +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; + +@RestController +@Api(tags = "通知公告管理") +@RequestMapping("/api/biz-service-ebtp-extend/v1/bizbidnotice") +public class BizBidNoticeController { + + @Resource + private IBizBidNoticeService ibizBidNoticeService; + + @Autowired + private IBaseCacheUserService iBaseCacheUserService; + + /** + * 查询发布数据 + * + * @param id + * + * @return + */ + @ApiOperation("查询发布列表") + @PostMapping("/list") + public BaseResponse> get(@RequestBody BizBidNotice bizBidNotice) { + if (bizBidNotice.getCurrent() == null || bizBidNotice.getPageSize() == null) { + return BaseResponse.fail("请传入分页功能所需参数，current,pageSize", null); + } + // 前端第一页默认传1而不是0 + if (bizBidNotice.getCurrent() == 1) { + bizBidNotice.setCurrent(0); + } + if("已发布".equals(bizBidNotice.getNoticeRelease())){ + bizBidNotice.setNoticeRelease("open"); + }else if("未发布".equals(bizBidNotice.getNoticeRelease())){ + bizBidNotice.setNoticeRelease("close"); + } + return BaseResponse.success(ibizBidNoticeService.getlist(bizBidNotice)); + + } + + /** + * 查询所有数据 + * + * @param id + * + * @return + */ + @ApiOperation("查询所有列表") + @PostMapping("/allList") + public BaseResponse> getAll(@RequestBody BizBidNotice bizBidNotice) { + if (bizBidNotice.getCurrent() == null || bizBidNotice.getPageSize() == null) { + return BaseResponse.fail("请传入分页功能所需参数，current,pageSize", null); + } + // 前端第一页默认传1而不是0 + if (bizBidNotice.getCurrent() == 1) { + bizBidNotice.setCurrent(0); + } + if("已发布".equals(bizBidNotice.getNoticeRelease())){ + bizBidNotice.setNoticeRelease("open"); + }else if("未发布".equals(bizBidNotice.getNoticeRelease())){ + bizBidNotice.setNoticeRelease("close"); + }else{ + bizBidNotice.setNoticeRelease(null); + } + return BaseResponse.success(ibizBidNoticeService.getAllList(bizBidNotice)); + } + + /** + * 插入新数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("插入新数据") + @PostMapping("/add") + public BaseResponse insert( + @ApiParam(value = "对象数据", required = true) @RequestBody @Valid BizBidNotice bizBidNotice) { + bizBidNotice.setNoticeName(iBaseCacheUserService.getCacheUser().getFullName()); + return BaseResponse.success(ibizBidNoticeService.saveOrUpdate(bizBidNotice)); + } + + /** + * 修改数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("修改数据") + @PostMapping("/update") + public BaseResponse update( + @ApiParam(value = "对象数据", required = true) @RequestBody BizBidNotice bizBidNotice) { + return BaseResponse.success(ibizBidNoticeService.saveOrUpdate(bizBidNotice)); + } + + + /** + * 发布数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("发布数据") + @PostMapping("/fabu/{id}") + public BaseResponse fabu(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + + return BaseResponse.success(ibizBidNoticeService.fabu(id)); + } + + /** + * 取消发布数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("发布数据") + @PostMapping("/qxfabu/{id}") + public BaseResponse qxfabu(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + + return BaseResponse.success(ibizBidNoticeService.qxfabu(id)); + } + + /** + * 置顶数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("置顶数据") + @PostMapping("/top/{id}") + public BaseResponse top(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + + return BaseResponse.success(ibizBidNoticeService.top(id)); + } + + /** + * 取消置顶数据 + * + * @param bizBidNotice + * + * @return + */ + @ApiOperation("取消置顶数据") + @PostMapping("/qxtop/{id}") + public BaseResponse qxtop(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + + return BaseResponse.success(ibizBidNoticeService.qxtop(id)); + } + + /** + * 查询数据 + * + * @param id + * + * @return + */ + @ApiOperation("查询数据") + @GetMapping("/select/{id}") + public BaseResponse get(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + return BaseResponse.success(ibizBidNoticeService.getById(id)); + } + + /** + * 删除数据 + * + * @param id + * + * @return + */ + @ApiOperation("删除数据") + @PostMapping("/delete/{id}") + public BaseResponse delete(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + return BaseResponse.success(ibizBidNoticeService.deleteOff(id)); + } + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/BizBidNoticeMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/BizBidNoticeMapper.java new file mode 100644 index 0000000..de94fd2 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/BizBidNoticeMapper.java @@ -0,0 +1,30 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.dao; + +import java.time.LocalDateTime; +import java.util.List; + +import org.apache.ibatis.annotations.Param; + +import com.chinaunicom.mall.ebtp.common.base.dao.IBaseMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.entity.BizBidNotice; + + +public interface BizBidNoticeMapper extends IBaseMapper { + public int deleteOff(Long id); + + public List getList(@Param("noticeTitle")String noticeTitle,@Param("noticeName") String noticeName, @Param("createDate")LocalDateTime createDate,@Param("noticeRelease") String noticeRelease, @Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); + + public List getListByTitle(@Param("noticeTitle")String noticeTitle,@Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); + + public List getAllList(@Param("noticeTitle")String noticeTitle,@Param("noticeName") String noticeName, @Param("createDate")LocalDateTime createDate,@Param("noticeRelease") String noticeRelease,@Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); + + public List getAllListByTitle(@Param("noticeTitle")String noticeTitle,@Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); + + public Boolean fabu(@Param("id")Long id); + + public Boolean qxfabu(@Param("id")Long id); + + public Boolean top(@Param("id")Long id); + + public Boolean qxtop(@Param("id")Long id); +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/mapper/BizBidNoticeMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/mapper/BizBidNoticeMapper.xml new file mode 100644 index 0000000..8f15396 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/dao/mapper/BizBidNoticeMapper.xml @@ -0,0 +1,134 @@ + + + + + + + + + + + + + + + + + + + + + + + + select id,notice_name, notice_title, notice_content, notice_file,notice_release,notice_top, create_by, + create_date, update_by, update_date,tenant_id,tenant_name,last_update_time, delete_flag from biz_bid_notice + + + + + + + + + + + + update biz_bid_notice + set + delete_flag="deleted" + where notice_id=#{notice_id} limit #{pageIndex},#{pageSize} + + + + update biz_bid_notice + set + notice_release="open" + where id=#{id} + + + + update biz_bid_notice + set + notice_release="close" + where id=#{id} + + + + update biz_bid_notice + set + notice_top="0" + where id=#{id} + + + + update biz_bid_notice + set + notice_top="1" + where id=#{id} + + + + + update biz_bid_notice + + notice_name = #{noticeName}, + notice_title = #{noticeTitle}, + notice_content = #{noticeContent}, + notice_file = #{noticeFile}, + notice_release=#{noticeRelease} + notice_top=#{noticeTop} + update_by = #{updatBy}, + update_date = #{updateDate}, + tenant_id = #{tenantId}, + tenant_name = #{tenantName}, + last_update_time = #{lastTpdateTime}, + + where ID=#{id} + + + + + update biz_bid_notice + set + delete_flag="deleted" + where ID=#{id,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/entity/BizBidNotice.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/entity/BizBidNotice.java new file mode 100644 index 0000000..504084d --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/entity/BizBidNotice.java @@ -0,0 +1,148 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.chinaunicom.mall.ebtp.common.base.entity.BaseEntity; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.experimental.Accessors; + +import java.io.Serializable; + +/** + * 实体类 BizBidNotice + * + * @auto.generated + */ +@Data +@Accessors(chain = true) +@ApiModel +@TableName(value = "biz_bid_notice", autoResultMap = true) +public class BizBidNotice extends BaseEntity implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * + */ + @ApiModelProperty(value = "ID") + @TableId(value = "id", type = IdType.AUTO) + private Long id; + + /** + * + */ + @ApiModelProperty(value = "noticeName") + private String noticeName; + + /** + * 标题 + */ + @ApiModelProperty(value = "标题") + private String noticeTitle; + + /** + * 内容 + */ + @ApiModelProperty(value = "内容") + private String noticeContent; + /** + * 文件ID + */ + @ApiModelProperty(value = "文件ID") + private String noticeFile; + /** + * 是否发布 + */ + @ApiModelProperty(value = "是否发布") + private String noticeRelease; + + /** + * 是否置顶 + */ + @ApiModelProperty(value = "是否置顶") + private String noticeTop; + + private Integer current; + + private Integer pageSize; + + public String getNoticeName() { + return noticeName; + } + + public void setNoticeName(String noticeName) { + this.noticeName = noticeName; + } + + public Integer getCurrent() { + return current; + } + + public void setCurrent(Integer current) { + this.current = current; + } + + public Integer getPageSize() { + return pageSize; + } + + public void setPageSize(Integer pageSize) { + this.pageSize = pageSize; + } + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getNoticeFile() { + return noticeFile; + } + + public void setNoticeFile(String noticeFile) { + this.noticeFile = noticeFile; + } + + public String getNoticeRelease() { + return noticeRelease; + } + + public void setNoticeRelease(String noticeRelease) { + this.noticeRelease = noticeRelease; + } + + public String getNoticeTop() { + return noticeTop; + } + + public void setNoticeTop(String noticeTop) { + this.noticeTop = noticeTop; + } + + public String getNoticeTitle() { + return noticeTitle; + } + + public void setNoticeTitle(String noticeTitle) { + this.noticeTitle = noticeTitle; + } + + public String getNoticeContent() { + return noticeContent; + } + + public void setNoticeContent(String noticeContent) { + this.noticeContent = noticeContent; + } + + public static long getSerialversionuid() { + return serialVersionUID; + } + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/IBizBidNoticeService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/IBizBidNoticeService.java new file mode 100644 index 0000000..899eb57 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/IBizBidNoticeService.java @@ -0,0 +1,33 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.service; + + +import java.util.List; + +import com.chinaunicom.mall.ebtp.common.base.service.IBaseService; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.entity.BizBidNotice; + +/** + * 对数据表 biz_bid_notice 操作的 service + * @author Auto create + * + */ +public interface IBizBidNoticeService extends IBaseService{ + + public int deleteOff(Long id); + + public List getlist(BizBidNotice bizBidNotice); + + public List getListByTitle(BizBidNotice bizBidNotice); + + public List getAllList(BizBidNotice bizBidNotice); + + public List getAllListByTitle(BizBidNotice bizBidNotice); + + public Boolean fabu(Long id); + + public Boolean qxfabu(Long id); + + public Boolean top(Long id); + + public Boolean qxtop(Long id); +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/impl/BizBidNoticeServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/impl/BizBidNoticeServiceImpl.java new file mode 100644 index 0000000..236b7a6 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidnotice/service/impl/BizBidNoticeServiceImpl.java @@ -0,0 +1,88 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidnotice.service.impl; + +import java.util.List; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import com.chinaunicom.mall.ebtp.common.base.service.impl.BaseServiceImpl; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.dao.BizBidNoticeMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.entity.BizBidNotice; +import com.chinaunicom.mall.ebtp.extend.bizbidnotice.service.IBizBidNoticeService; + +/** + * 对数据表 biz_bid_notice 操作的 serviceImpl + * + * @author Auto create + * + */ +@Service +public class BizBidNoticeServiceImpl extends BaseServiceImpl + implements IBizBidNoticeService { + @Autowired + BizBidNoticeMapper bizBidNoticeMapper; + + @Override + public int deleteOff(Long id) { + return bizBidNoticeMapper.deleteOff(id); + } + + public List listRelease(List list) { + for (BizBidNotice bizBidNotice2 : list) { + if ("open".equals(bizBidNotice2.getNoticeRelease())) { + bizBidNotice2.setNoticeRelease("已发布"); + } + if ("close".equals(bizBidNotice2.getNoticeRelease())) { + bizBidNotice2.setNoticeRelease("未发布"); + } + } + return list; + } + + @Override + public List getlist(BizBidNotice bizBidNotice) { + List list = bizBidNoticeMapper.getList(bizBidNotice.getNoticeTitle(),bizBidNotice.getNoticeName(),bizBidNotice.getCreateDate(),bizBidNotice.getNoticeRelease(),bizBidNotice.getCurrent(), bizBidNotice.getPageSize()); + return listRelease(list); + } + + @Override + public List getListByTitle(BizBidNotice bizBidNotice) { + List list = bizBidNoticeMapper.getListByTitle(bizBidNotice.getNoticeTitle(), + bizBidNotice.getCurrent(), bizBidNotice.getPageSize()); + return listRelease(list); + } + + @Override + public List getAllList(BizBidNotice bizBidNotice) { + List list = bizBidNoticeMapper.getAllList(bizBidNotice.getNoticeTitle(),bizBidNotice.getNoticeName(),bizBidNotice.getCreateDate(),bizBidNotice.getNoticeRelease(),bizBidNotice.getCurrent(), bizBidNotice.getPageSize()); + return listRelease(list); + } + + @Override + public List getAllListByTitle(BizBidNotice bizBidNotice) { + List list = bizBidNoticeMapper.getAllListByTitle(bizBidNotice.getNoticeTitle(), + bizBidNotice.getCurrent(), bizBidNotice.getPageSize()); + return listRelease(list); + } + + @Override + public Boolean fabu(Long id) { + return bizBidNoticeMapper.fabu(id); + } + + @Override + public Boolean qxfabu(Long id) { + return bizBidNoticeMapper.qxfabu(id); + } + + @Override + public Boolean top(Long id) { + return bizBidNoticeMapper.top(id); + } + + @Override + public Boolean qxtop(Long id) { + return bizBidNoticeMapper.qxtop(id); + } + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/column/BizBidSharedField.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/column/BizBidSharedField.java new file mode 100644 index 0000000..e62f793 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/column/BizBidSharedField.java @@ -0,0 +1,50 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.column; + +/** + * 字段常量 BizBidShared + * + * @auto.generated + */ +public class BizBidSharedField { + + + /** + * + */ + public static final String ID = "id"; + + /** + * + */ + public static final String SHARED_ID = "shared_id"; + + /** + * 鏍囬 + */ + public static final String SHARED_NAME = "shared_name"; + + /** + * 鍐呭 + */ + public static final String SHARED_ROLE = "shared_role"; + + /** + * 閺傚洣娆RL + */ + public static final String SHARED_FILE = "shared_file"; + + /** + * 闁哄嫷鍨伴幆渚€宕ｉ幋婵堫伌 + */ + public static final String SHARED_REMARKS = "shared_remarks"; + + + + + + + + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/controller/BizBidSharedController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/controller/BizBidSharedController.java new file mode 100644 index 0000000..a6cd300 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/controller/BizBidSharedController.java @@ -0,0 +1,120 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.controller; + + +import java.util.List; + +import javax.annotation.Resource; +import javax.validation.Valid; + +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import com.chinaunicom.mall.ebtp.common.base.entity.BaseResponse; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.entity.BizBidShared; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.service.IBizBidSharedService; + +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; + +@RestController +@Api(tags = "") +@RequestMapping("/api/biz-service-ebtp-extend/v1/bizbidshared") +public class BizBidSharedController{ + + @Resource + private IBizBidSharedService ibizBidSharedService; + + /** + * 查询数据列表 + * + * @param id + * + * @return + */ + @ApiOperation("查询数据列表") + @PostMapping("/list") + public BaseResponse> getList(@RequestBody BizBidShared bizBidShared){ + if (bizBidShared.getCurrent() == null || bizBidShared.getPageSize() == null) { + return BaseResponse.fail("请传入分页功能所需参数，current,pageSize", null); + } + // 前端第一页默认传1而不是0 + if (bizBidShared.getCurrent() == 1) { + bizBidShared.setCurrent(0); + } + return BaseResponse.success(ibizBidSharedService.getlist(bizBidShared)); + } + + /** + * 插入新数据 + * + * @param bizBidShared + * + * @return + */ + @ApiOperation("插入新数据") + @PostMapping("/add") + public BaseResponse insert(@ApiParam(value = "对象数据", required = true) @RequestBody @Valid BizBidShared bizBidShared){ + List recordRole = bizBidShared.getSharedRoles(); + StringBuffer sb = new StringBuffer(); + for (String string : recordRole) { + sb.append(string).append(","); + } + String keywordStr = sb.deleteCharAt(sb.length() - 1).toString(); + bizBidShared.setSharedRole(keywordStr); + boolean save = ibizBidSharedService.saveOrUpdate(bizBidShared); + + return BaseResponse.success(save); + } + + /** + * 修改数据 + * + * @param bizBidShared + * + * @return + */ + @ApiOperation("修改数据") + @PostMapping("") + public BaseResponse update(@ApiParam(value = "对象数据", required = true) @RequestBody BizBidShared bizBidShared){ + + return BaseResponse.success(ibizBidSharedService.saveOrUpdate(bizBidShared)); + } + + /** + * 查询数据 + * + * @param id + * + * @return + */ + @ApiOperation("查询数据") + @GetMapping("/{id}") + public BaseResponse get(@ApiParam(value = "主键id", required = true) @PathVariable Long id){ + + BizBidShared bizBidShared = ibizBidSharedService.getById(id); + + return BaseResponse.success(bizBidShared); + } + + /** + * 删除数据 + * + * @param id + * + * @return + */ + @ApiOperation("删除数据") + @PostMapping("/delete/{id}") + public BaseResponse delete(@ApiParam(value = "主键id", required = true) @PathVariable Long id) { + return BaseResponse.success(ibizBidSharedService.deleteOff(id)); + } + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/BizBidSharedMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/BizBidSharedMapper.java new file mode 100644 index 0000000..d27607d --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/BizBidSharedMapper.java @@ -0,0 +1,19 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.dao; + + +import java.time.LocalDateTime; +import java.util.List; + +import org.apache.ibatis.annotations.Param; + +import com.chinaunicom.mall.ebtp.common.base.dao.IBaseMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.entity.BizBidShared; + +public interface BizBidSharedMapper extends IBaseMapper { + + List getListByTitle( @Param("sharedName")String sharedName, @Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); + + List getList(@Param("sharedName")String sharedName, @Param("sharedRole")String sharedRole,@Param("LocalDateTime") LocalDateTime localDateTime,@Param("pageIndex") Integer current,@Param("pageSize") Integer pageSize); + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/mapper/BizBidSharedMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/mapper/BizBidSharedMapper.xml new file mode 100644 index 0000000..8d7b42b --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/dao/mapper/BizBidSharedMapper.xml @@ -0,0 +1,54 @@ + + + + + + + + + + + + + + + + + + + + + + + select id,shared_id, shared_name, shared_role, shared_file,shared_remarks, create_by, + create_date, update_by, update_date,tenant_id,tenant_name,last_update_time, delete_flag from biz_bid_shared + + + + + + + + + update biz_bid_shared + set + delete_flag="deleted" + where ID=#{id,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/entity/BizBidShared.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/entity/BizBidShared.java new file mode 100644 index 0000000..aa58d8b --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/entity/BizBidShared.java @@ -0,0 +1,160 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.entity; + + +import java.io.Serializable; +import java.util.List; + +import org.springframework.data.annotation.Transient; + +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 com.chinaunicom.mall.ebtp.common.base.entity.BaseEntity; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.experimental.Accessors; + +/** + * 实体类 BizBidShared + * + * @auto.generated + */ +@Data +@Accessors(chain = true) +@ApiModel +@TableName(value = "biz_bid_shared", autoResultMap = true) +public class BizBidShared extends BaseEntity implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * + */ + @ApiModelProperty(value = "ID") + @TableId(value = "id", type = IdType.AUTO) + private Long id; + + /** + * + */ + @ApiModelProperty(value = "sharedId") + private String sharedId; + + /** + * 共享文档文件名 + */ + @ApiModelProperty(value = "共享文档文件名") + private String sharedName; + + /** + * 共享文档使用角色 + */ + @ApiModelProperty(value = "共享文档使用角色") + private String sharedRole; + /** + * 共享文档使用角色list + */ + + @Transient + @TableField(exist= false) + private List sharedRoles; + /** + * 共享文档ID + */ + @ApiModelProperty(value = "共享文档ID") + private String sharedFile; + + /** + * 共享文档备注 + */ + @ApiModelProperty(value = "共享文档备注") + private String sharedRemarks; + + private Integer current; + + private Integer pageSize; + + + + public Integer getCurrent() { + return current; + } + + public void setCurrent(Integer current) { + this.current = current; + } + + public Integer getPageSize() { + return pageSize; + } + + public void setPageSize(Integer pageSize) { + this.pageSize = pageSize; + } + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getSharedId() { + return sharedId; + } + + public void setSharedId(String sharedId) { + this.sharedId = sharedId; + } + + public String getSharedName() { + return sharedName; + } + + public void setSharedName(String sharedName) { + this.sharedName = sharedName; + } + + public String getSharedRole() { + return sharedRole; + } + + public void setSharedRole(String sharedRole) { + this.sharedRole = sharedRole; + } + + public String getSharedFile() { + return sharedFile; + } + + public void setSharedFile(String sharedFile) { + this.sharedFile = sharedFile; + } + + public String getSharedRemarks() { + return sharedRemarks; + } + + public void setSharedRemarks(String sharedRemarks) { + this.sharedRemarks = sharedRemarks; + } + + public static long getSerialversionuid() { + return serialVersionUID; + } + + public List getSharedRoles() { + return sharedRoles; + } + + public void setSharedRoles(List sharedRoles) { + this.sharedRoles = sharedRoles; + } + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/IBizBidSharedService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/IBizBidSharedService.java new file mode 100644 index 0000000..cb429ff --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/IBizBidSharedService.java @@ -0,0 +1,21 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.service; + + +import java.util.List; + +import com.chinaunicom.mall.ebtp.common.base.service.IBaseService; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.entity.BizBidShared; + +/** + * 对数据表 biz_bid_shared 操作的 service + * @author Auto create + * + */ +public interface IBizBidSharedService extends IBaseService{ + + public int deleteOff(Long id); + + public List getlist(BizBidShared bizBidNotice); + + public List getListByTitle(BizBidShared bizBidNotice); +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/impl/BizBidSharedServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/impl/BizBidSharedServiceImpl.java new file mode 100644 index 0000000..966d372 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidshared/service/impl/BizBidSharedServiceImpl.java @@ -0,0 +1,39 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidshared.service.impl; + + +import java.util.List; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import com.chinaunicom.ebtp.mall.cloud.attachment.sdk.api.AttachmentClient; +import com.chinaunicom.mall.ebtp.common.base.service.impl.BaseServiceImpl; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.dao.BizBidSharedMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.entity.BizBidShared; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.service.IBizBidSharedService; +/** + * 对数据表 biz_bid_shared 操作的 serviceImpl + * @author Auto create + * + */ +@Service +public class BizBidSharedServiceImpl extends BaseServiceImpl implements IBizBidSharedService { + @Autowired + BizBidSharedMapper bizBidSharedMapper; + @Autowired + AttachmentClient attachmentClient; + @Override + public int deleteOff(Long id) { + return bizBidSharedMapper.deleteOff(id); + } + @Override + public List getlist(BizBidShared bizBidNotice) { + return bizBidSharedMapper.getList(bizBidNotice.getSharedName(),bizBidNotice.getSharedRole(),bizBidNotice.getCreateDate(),bizBidNotice.getCurrent(),bizBidNotice.getPageSize()); + } + + @Override + public List getListByTitle(BizBidShared bizBidNotice) { + return bizBidSharedMapper.getListByTitle(bizBidNotice.getSharedName(),bizBidNotice.getCurrent(),bizBidNotice.getPageSize()); + } + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/column/BizBidSharedRecordField.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/column/BizBidSharedRecordField.java new file mode 100644 index 0000000..5cec5bb --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/column/BizBidSharedRecordField.java @@ -0,0 +1,50 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.column; + +/** + * 字段常量 BizBidSharedRecord + * + * @auto.generated + */ +public class BizBidSharedRecordField { + + + /** + * + */ + public static final String ID = "id"; + + /** + * + */ + public static final String RECORD_ID = "record_id"; + + /** + * + */ + public static final String RECORD_ROLE = "record_role"; + + /** + * + */ + public static final String RECORD_NAME = "record_name"; + + /** + * + */ + public static final String RECORD_STAFF = "record_staff"; + + /** + * + */ + public static final String RECORD_ACCOUNT = "record_account"; + + + + + + + + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/controller/BizBidSharedRecordController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/controller/BizBidSharedRecordController.java new file mode 100644 index 0000000..461f181 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/controller/BizBidSharedRecordController.java @@ -0,0 +1,86 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.controller; + + +import java.util.List; + +import javax.annotation.Resource; +import javax.validation.Valid; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import com.chinaunicom.mall.ebtp.common.base.entity.BaseResponse; +import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService; +import com.chinaunicom.mall.ebtp.extend.bizbidshared.entity.BizBidShared; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.entity.BizBidSharedRecord; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.service.IBizBidSharedRecordService; + +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; + +@RestController +@Api(tags = "") +@RequestMapping("/api/biz-service-ebtp-extend/v1/bizbidsharedrecord") +public class BizBidSharedRecordController{ + + @Resource + private IBizBidSharedRecordService ibizBidSharedRecordService; + @Autowired + private IBaseCacheUserService iBaseCacheUserService; + /** + * 查询数据列表 + * + * @param id + * + * @return + */ + @ApiOperation("查询数据列表") + @PostMapping("/list/{id}") + public BaseResponse> getList(@PathVariable("id") String id,@ApiParam(value = "对象数据", required = true)@RequestBody @Valid BizBidSharedRecord bizBidShared){ + bizBidShared.setRecordId(id); + return BaseResponse.success(ibizBidSharedRecordService.getlist(bizBidShared)); + } + + /** + * 插入新数据 + * + * @param bizBidSharedRecord + * + * @return + */ + @ApiOperation("插入新数据") + @PostMapping("/add") + public BaseResponse insert(@ApiParam(value = "对象数据", required = true) @RequestBody @Valid BizBidShared bizBidShared){ + Long userId = iBaseCacheUserService.getCacheUser().getUserId(); + BizBidSharedRecord bizBidSharedRecord=new BizBidSharedRecord(); + bizBidSharedRecord.setId(null); + bizBidSharedRecord.setCreateBy(userId); + bizBidSharedRecord.setRecordId(bizBidShared.getId().toString()); + boolean save = ibizBidSharedRecordService.save(bizBidSharedRecord); + + return BaseResponse.success(save); + } + + /** + * 修改数据 + * + * @param bizBidSharedRecord + * + * @return + */ + @ApiOperation("修改数据") + @PutMapping("") + public BaseResponse update(@ApiParam(value = "对象数据", required = true) @RequestBody BizBidSharedRecord bizBidSharedRecord){ + + return BaseResponse.success(ibizBidSharedRecordService.saveOrUpdate(bizBidSharedRecord)); + } + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/BizBidSharedRecordMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/BizBidSharedRecordMapper.java new file mode 100644 index 0000000..ed2a1b1 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/BizBidSharedRecordMapper.java @@ -0,0 +1,16 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.dao; + + +import java.util.List; + +import org.apache.ibatis.annotations.Param; + +import com.chinaunicom.mall.ebtp.common.base.dao.IBaseMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.entity.BizBidSharedRecord; + +public interface BizBidSharedRecordMapper extends IBaseMapper { + + List getlist(BizBidSharedRecord bizBidSharedRecord); + + BizBidSharedRecord getByIdInfo(@Param("recordId")String id,@Param("pageIndex") Integer getPageNo,@Param("pageSize") Integer pageSize); +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/mapper/BizBidSharedRecordMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/mapper/BizBidSharedRecordMapper.xml new file mode 100644 index 0000000..ed9b47a --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/dao/mapper/BizBidSharedRecordMapper.xml @@ -0,0 +1,66 @@ + + + + + + + + + + + + + + + + + + + + + + + + select id,record_id, record_role, record_name, record_staff,record_account, create_by, + create_date, update_by, update_date,tenant_id,tenant_name,last_update_time, delete_flag from biz_bid_shared_record + + + + + + + + + + update biz_bid_shared_record + set + delete_flag="deleted" + where ID=#{id,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/entity/BizBidSharedRecord.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/entity/BizBidSharedRecord.java new file mode 100644 index 0000000..9a1937a --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/entity/BizBidSharedRecord.java @@ -0,0 +1,168 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.entity; + +import java.io.Serializable; +import java.util.List; + +import org.springframework.data.annotation.Transient; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.chinaunicom.mall.ebtp.common.base.entity.BaseEntity; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.experimental.Accessors; + +/** + * 实体类 BizBidSharedRecord + * + * @auto.generated + */ +@Data +@Accessors(chain = true) +@ApiModel +@TableName(value = "biz_bid_shared_record", autoResultMap = true) +public class BizBidSharedRecord extends BaseEntity implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * + */ + @ApiModelProperty(value = "ID") + private Long id; + + /** + * + */ + @ApiModelProperty(value = "recordId") + private String recordId; + + /** + * + */ + + @Transient + @TableField(exist= false) + private List recordRoles; + + /** + * + */ + @ApiModelProperty(value = "使用角色") + + private String recordRole; + + /** + * + */ + @ApiModelProperty(value = "机构名称") + private String recordName; + + /** + * + */ + @ApiModelProperty(value = "下载人") + private String recordStaff; + + /** + * + */ + @ApiModelProperty(value = "下载账号") + private String recordAccount; + + private Integer current; + + private Integer pageSize; + + + + public Integer getCurrent() { + return current; + } + + public void setCurrent(Integer current) { + this.current = current; + } + + public Integer getPageSize() { + return pageSize; + } + + public void setPageSize(Integer pageSize) { + this.pageSize = pageSize; + } + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getRecordId() { + return recordId; + } + + public void setRecordId(String recordId) { + this.recordId = recordId; + } + + public void setRecordRole(String recordRole) { + this.recordRole = recordRole; + } + + public List getRecordRoles() { + return recordRoles; + } + + public void setRecordRoles(List recordRoles) { + this.recordRoles = recordRoles; + } + + public String getRecordRole() { + return recordRole; + } + + public String getRecordName() { + return recordName; + } + + public void setRecordName(String recordName) { + this.recordName = recordName; + } + + public String getRecordStaff() { + return recordStaff; + } + + public void setRecordStaff(String recordStaff) { + this.recordStaff = recordStaff; + } + + public String getRecordAccount() { + return recordAccount; + } + + public void setRecordAccount(String recordAccount) { + this.recordAccount = recordAccount; + } + + + public static long getSerialversionuid() { + return serialVersionUID; + } + + + + + + + + + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/IBizBidSharedRecordService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/IBizBidSharedRecordService.java new file mode 100644 index 0000000..57adde9 --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/IBizBidSharedRecordService.java @@ -0,0 +1,22 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.service; + + +import java.util.List; + +import com.chinaunicom.mall.ebtp.common.base.service.IBaseService; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.entity.BizBidSharedRecord; + +/** + * 对数据表 biz_bid_shared_record 操作的 service + * @author Auto create + * + */ +public interface IBizBidSharedRecordService extends IBaseService{ + + public List getlist(BizBidSharedRecord bizBidSharedRecord); + + public BizBidSharedRecord getByIdInfo(BizBidSharedRecord bizBidSharedRecord); + + + +} diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/impl/BizBidSharedRecordServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/impl/BizBidSharedRecordServiceImpl.java new file mode 100644 index 0000000..ef97cbe --- /dev/null +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizbidsharedrecord/service/impl/BizBidSharedRecordServiceImpl.java @@ -0,0 +1,33 @@ +package com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.service.impl; + + +import java.util.List; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import com.chinaunicom.mall.ebtp.common.base.service.impl.BaseServiceImpl; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.dao.BizBidSharedRecordMapper; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.entity.BizBidSharedRecord; +import com.chinaunicom.mall.ebtp.extend.bizbidsharedrecord.service.IBizBidSharedRecordService; +/** + * 对数据表 biz_bid_shared_record 操作的 serviceImpl + * @author Auto create + * + */ +@Service +public class BizBidSharedRecordServiceImpl extends BaseServiceImpl implements IBizBidSharedRecordService { + + @Autowired + BizBidSharedRecordMapper bizBidSharedRecordMapper; + @Override + public List getlist(BizBidSharedRecord bizBidSharedRecord) { + return bizBidSharedRecordMapper.getlist(bizBidSharedRecord); + } + @Override + public BizBidSharedRecord getByIdInfo(BizBidSharedRecord bizBidSharedRecord) { + return bizBidSharedRecordMapper.getByIdInfo(bizBidSharedRecord.getRecordId(),bizBidSharedRecord.getCurrent(),bizBidSharedRecord.getPageSize()); + } + + +} diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml new file mode 100644 index 0000000..7d976f2 --- /dev/null +++ b/src/main/resources/application-dev.yml @@ -0,0 +1,194 @@ +server: + port: 18018 + servlet: + context-path: / + +# 对应 apollo 配置中心的应用名 +app: + id: biz-service-ebtp-extend + +# Apollo 配置信息 +apollo: + meta: http://10.242.31.158:6001/ + bootstrap: + namespace: application + enabled: true + eagerLoad: + enabled: true + +spring: + aop: + auto: true #开启spring的aop配置 + proxy-target-class: true + + application: + name: biz-service-ebtp-extend + + shardingsphere: + datasource: + names: ds0 + ds0: + type: com.alibaba.druid.pool.DruidDataSource + driver-class-name: com.mysql.cj.jdbc.Driver + username: root + password: root + jdbc-url: jdbc:mysql://10.242.31.158:3033/ebtp_mall_extend?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true + url: jdbc:mysql://10.242.31.158:3033/ebtp_mall_extend?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true + filters: stat,wall,log4j + maxActive: 20 + initialSize: 1 + maxWait: 60000 + minIdle: 1 + timeBetweenEvictionRunsMillis: 60000 + minEvictableIdleTimeMillis: 300000 + validationQuery: select 'x' + testWhileIdle: true + testOnBorrow: false + testOnReturn: false + poolPreparedStatements: true + maxOpenPreparedStatements: 20 + connection-properties: druid.stat.merggSql=ture;druid.stat.slowSqlMillis=5000 + props: + sql: + show: true + + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + serialization: + write-dates-as-timestamps: false + + # 天宫Kafka增加了安全认证，需要配置安全属性 + kafka: + bootstrap-servers: 10.125.164.192:32005,10.125.164.193:32005,10.125.164.194:32005 + template: + default-topic: jl_test + + # 生产者配置参数 + producer: + client-id: core-service-ebtp-crypt + properties: + security.protocol: SASL_PLAINTEXT + sasl.mechanism: SCRAM-SHA-256 + sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="jltest" password="Unicom#123"; + + # 消费者配置参数 + consumer: + group-id: core-service-ebtp-crypt-consumer + auto-offset-reset: latest + properties: + security.protocol: SASL_PLAINTEXT + sasl.mechanism: SCRAM-SHA-256 + sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="jltest" password="Unicom#123"; + + # 天宫 redis 需要使用哨兵进行访问 + redis: + sentinel: + master: eshop-redis + nodes: 10.125.164.124:32718, 10.125.164.118:32716, 10.125.164.121:32716 + password: Unicom#135 + + lettuce: + # jedis: + pool: + maxTotal: 50 + minIdle: 1 + maxWaitMillis: 5000 + maxIdle: 5 + testOnBorrow: true + testOnReturn: true + testWhileIdle: true + token: + database: 0 + host: 125.32.114.204 + port: 16379 + password: redis@CC1234 + timeout: 6000 + uuid: + database: 1 + host: 125.32.114.204 + port: 16379 + password: redis@CC1234 + timeout: 6000 + cache: + database: 2 + host: 125.32.114.204 + port: 16379 + password: redis@CC1234 + timeout: 6000 + +# 天宫Eureka配置 +eureka: + client: + service-url: + defaultZone: http://10.242.31.158:5001/eureka,http://10.242.31.158:5002/eureka,http://10.242.31.158:5003/eureka + instance: + prefer-ip-address: true + hostname: ${spring.cloud.client.ip-address} + instance-ip: ${spring.cloud.client.ip-address}:${server.port} + +mybatis-plus: + configuration: + # 是否开启自动驼峰命名规则映射:从数据库列名到Java属性驼峰命名的类似映射 + map-underscore-to-camel-case: true + auto-mapping-behavior: full + # 这个配置会将执行的sql打印出来，在开发或测试的时候可以用 + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + mapper-locations: classpath*:com/chinaunicom/mall/ebtp/**/mapper/*Mapper.xml + global-config: + # 逻辑删除配置 + db-config: + # logic-delete-field: flag # 全局逻辑删除的实体字段名(since 3.3.0,配置后可以忽略不配置步骤2) @TableLogic + logic-delete-value: deleted # 逻辑已删除值 + logic-not-delete-value: normal # 逻辑未删除值 + +# --------------feign ------------ +feign: + httpclient: + enabled: false + okhttp: + enabled: true + client: + config: + default: + connect-timeout: 20000 + read-timeout: 20000 + +hystrix: + command: + default: + execution: + timeout: + enabled: true + isolation: + strategy: SEMAPHORE + thread: + timeoutInMilliseconds: 200000 #熔断超时时间 + circuitBreaker: + sleepWindowInMilliseconds: 20000 + forceClosed: true +ribbon: + ReadTimeout: 20000 #请求处理的超时时间 + ConnectTimeout: 20000 #请求连接超时时间 + MaxAutoRetries: 0 #对当前实例的重试次数 + MaxAutoRetriesNextServer: 1 #切换实例的重试次数 1 + +mconfig: + workerId: 1 + datacenterId: 1 + remote: + approval: true #是否需要提交公告审批 + media: true #是否需要发送到媒体 + + #中国联通电子商城外网接入平台 相关参数 + token: + userName: zbgg + password: eip_13579 + file-wjpt-storage-path: http://111.198.162.67:8081/enr/api/base/file/cgDownload/ #测试地址 + #获取file地址 + file: + address: http://125.32.114.204:8760/api/core-service-ebtp-updownload/v1/download/oid/ + #提交审批相关字段 + approve: + wfSectionNo: 002 + wfSectionName: 采购审批 diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml new file mode 100644 index 0000000..caf4dfc --- /dev/null +++ b/src/main/resources/application.yml @@ -0,0 +1,3 @@ +spring: + profiles: + active: dev \ No newline at end of file diff --git a/src/main/resources/file.conf b/src/main/resources/file.conf new file mode 100644 index 0000000..d591bab --- /dev/null +++ b/src/main/resources/file.conf @@ -0,0 +1,66 @@ +transport { + # tcp udt unix-domain-socket + type = "TCP" + #NIO NATIVE + server = "NIO" + #enable heartbeat + heartbeat = true + # the client batch send request enable + enableClientBatchSendRequest = true + #thread factory for netty + threadFactory { + bossThreadPrefix = "NettyBoss" + workerThreadPrefix = "NettyServerNIOWorker" + serverExecutorThread-prefix = "NettyServerBizHandler" + shareBossWorker = false + clientSelectorThreadPrefix = "NettyClientSelector" + clientSelectorThreadSize = 1 + clientWorkerThreadPrefix = "NettyClientWorkerThread" + # netty boss thread size,will not be used for UDT + bossThreadSize = 1 + #auto default pin or 8 + workerThreadSize = "default" + } + shutdown { + # when destroy server, wait seconds + wait = 3 + } + serialization = "seata" + compressor = "none" +} +service { + #transaction service group mapping + vgroupMapping.biz-service-ebtp-expenses-fescar-service-group = "default" + #only support when registry.type=file, please don't set multiple addresses + default.grouplist = "127.0.0.1:8091" + #degrade, current not support + enableDegrade = false + #disable seata + disableGlobalTransaction = false +} + +client { + rm { + asyncCommitBufferLimit = 10000 + lock { + retryInterval = 10 + retryTimes = 30 + retryPolicyBranchRollbackOnConflict = true + } + reportRetryCount = 5 + tableMetaCheckEnable = false + reportSuccessEnable = false + } + tm { + commitRetryCount = 5 + rollbackRetryCount = 5 + } + undo { + dataValidation = true + logSerialization = "jackson" + logTable = "undo_log" + } + log { + exceptionRate = 100 + } +} \ No newline at end of file diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml new file mode 100644 index 0000000..62285f5 --- /dev/null +++ b/src/main/resources/logback.xml @@ -0,0 +1,89 @@ + + + + + + + ${logback.appname} + + + + + + + %d{yyyy-MM-dd HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{50} - %msg%n + + + + + + + + + ERROR + + DENY + + ACCEPT + + + ${logback.logdir}/info.${logback.appname}.log + + + + ${logback.logdir}/info.${logback.appname}.%d{yyyy-MM-dd}.log + + 3 + + true + + + + + + UTF-8 + %d [%thread] %-5level %logger{64} %line - %msg%n + + + + + + + Error + + + ${logback.logdir}/error.${logback.appname}.log + + + + ${logback.logdir}/error.${logback.appname}.%d{yyyy-MM-dd}.log + + 3 + + true + + + + + + UTF-8 + %d [%thread] %-5level %logger{128} %line - %msg%n + + + + + + + + + + + + diff --git a/src/main/resources/registry.conf b/src/main/resources/registry.conf new file mode 100644 index 0000000..bd724ed --- /dev/null +++ b/src/main/resources/registry.conf @@ -0,0 +1,79 @@ +registry { + # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa + type = "eureka" + + nacos { + application = "seata-server" + serverAddr = "localhost" + namespace = "" + username = "" + password = "" + } + eureka { + serviceUrl = "http://10.242.31.158:5001/eureka,http://10.242.31.158:5002/eureka,http://10.242.31.158:5003/eureka" + weight = "1" + } + redis { + serverAddr = "localhost:6379" + db = "0" + password = "" + timeout = "0" + } + zk { + serverAddr = "127.0.0.1:2181" + sessionTimeout = 6000 + connectTimeout = 2000 + username = "" + password = "" + } + consul { + serverAddr = "127.0.0.1:8500" + } + etcd3 { + serverAddr = "http://localhost:2379" + } + sofa { + serverAddr = "127.0.0.1:9603" + region = "DEFAULT_ZONE" + datacenter = "DefaultDataCenter" + group = "SEATA_GROUP" + addressWaitTime = "3000" + } + file { + name = "file.conf" + } +} + +config { + # file、nacos 、apollo、zk、consul、etcd3、springCloudConfig + type = "file" + + nacos { + serverAddr = "localhost" + namespace = "" + group = "SEATA_GROUP" + username = "" + password = "" + } + consul { + serverAddr = "127.0.0.1:8500" + } + apollo { + appId = "seata-server" + apolloMeta = "http://192.168.1.204:8801" + namespace = "application" + } + zk { + serverAddr = "127.0.0.1:2181" + sessionTimeout = 6000 + connectTimeout = 2000 + username = "" + password = "" + } + etcd3 { + serverAddr = "http://localhost:2379" + } + file { + name = "file.conf" + } +} diff --git a/src/main/resources/seata.conf b/src/main/resources/seata.conf new file mode 100644 index 0000000..c656a9c --- /dev/null +++ b/src/main/resources/seata.conf @@ -0,0 +1,21 @@ +## --------------------------------------------------------------------------- +## Licensed to the Apache Software Foundation (ASF) under one or more +## contributor license agreements. See the NOTICE file distributed with +## this work for additional information regarding copyright ownership. +## The ASF licenses this file to You under the Apache License, Version 2.0 +## (the "License"); you may not use this file except in compliance with +## the License. You may obtain a copy of the License at +## +## http://www.apache.org/licenses/LICENSE-2.0 +## +## Unless required by applicable law or agreed to in writing, software +## distributed under the License is distributed on an "AS IS" BASIS, +## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +## See the License for the specific language governing permissions and +## limitations under the License. +## --------------------------------------------------------------------------- + +client { + application.id = biz-service-ebtp-extend + transaction.service.group = biz-service-ebtp-extend-fescar-service-group +} diff --git a/src/main/resources/swagger-configuration.properties b/src/main/resources/swagger-configuration.properties new file mode 100644 index 0000000..6624bf1 --- /dev/null +++ b/src/main/resources/swagger-configuration.properties @@ -0,0 +1,7 @@ +unifast.swagger.basePackage=com.chinaunicom.mall.ebtp.extend +unifast.swagger.title=\u6d4b\u8bd5\u63a5\u53e3\u6587\u6863 +unifast.swagger.contactName=\u5409\u6797\u9879\u76ee\u7ec4 +unifast.swagger.contactUrl=http://chinaunicom.com +unifast.swagger.contactEmail=chinaunicom@chinaunicom.com +unifast.swagger.version=0.0.1 +unifast.swagger.description=\u7840\u540e\u53f0\u529f\u80fd\u6846\u67b6 \ No newline at end of file