swh
/
one-health-mybasic
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

pull/2/head
shaowenhao 2023-10-27 20:36:13 +08:00
parent b1de15ac8b b43951eb92
commit e915ec1ba8
17 changed files with 806 additions and 142 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
Dockerfile 100644
View File

@ -0,0 +1,17 @@
# 基础镜像
FROM anolis-registry.cn-zhangjiakou.cr.aliyuncs.com/openanolis/openjdk:17-8.6
#暴露端口位置
EXPOSE 9001
# 挂载目录
VOLUME /home/logs/health-mybasic
# 复制jar文件到docker内部
COPY /target/one-health-mybasic.jar /home/app.jar
#工作目录 exec -it 进来默认就是这个目
WORKDIR /home
# 启动java程序
ENTRYPOINT ["java","-Dfile.encoding=UTF-8","-jar","/home/app.jar"]

10
pom.xml
View File

@ -111,12 +111,14 @@
<version>1.26.5</version>
</dependency>
<!-- RuoYi Common core -->
<dependency>
<groupId>com.ruoyi</groupId>
<artifactId>health-common-core</artifactId>
<version>3.6.8</version>
</dependency>
<!-- RuoYi Common security -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
@ -194,6 +196,14 @@
<!-- <version>5.5.13.2</version>-->
<!-- </dependency>-->
<!-- RuoYi Common redis -->
<dependency>
<groupId>com.ruoyi</groupId>
<artifactId>health-common-redis</artifactId>
<version>3.6.3</version>
</dependency>
</dependencies>
<build>

152
src/main/java/com/ruoyi/mybasic/Text/Queue.java
View File

@ -1,76 +1,76 @@
//package com.ruoyi.mybasic.Text;
//
//import lombok.Data;
//
///**
// * @ClassName Queue
// * @Description 数据结构队列测试
// * @Author WenHao.Sao
// */
//@Data
//public class Queue {
//
// private int[] dataArray;//定义了一个数组
//
// private int front;//队头
//
// private int rear;//尾端
//
// public Queue(int capacity){
// this.dataArray = new int[capacity];
// }
//
// public void enQueue(int element){
// if ((rear + 1 ) % dataArray.length == front){
// System.out.println("队伍已经满了");
// System.out.println();
// return;
// }
// dataArray[rear] = element;
// rear = (rear + 1) % dataArray.length;
// System.out.println("入队后队头元素为:"+dataArray[front]);
// System.out.println("出队!后 队尾元素" + element);
// }
//
// public int deQueue(){
// if (rear == front){
// System.out.println("队以空");
// System.out.println("");
// }
// int deQueueElement = dataArray[front];
// front = (front + 1) % dataArray.length;
// System.out.println("出队后对头元素为:"+ dataArray[front]);
// System.out.println("出队后队元素为:"+dataArray[rear - 1]);
// System.out.println();
// return deQueueElement;
// }
//
//
// public void print(){
// for (int i = front; i != rear - i ; i = (i+1) % dataArray.length){
// System.out.println(dataArray[i] + "-->");
// }
// System.out.println(dataArray[rear -1]);
// System.out.println();
// }
//
//
// public static void main(String[] args) {
// Queue queue = new Queue(6);
// queue.enQueue(1);
// queue.enQueue(2);
// queue.enQueue(3);
// queue.enQueue(4);
// queue.enQueue(5);
// queue.enQueue(6);
// queue.print();
// queue.deQueue();
// queue.deQueue();
// queue.deQueue();
// queue.print();
// queue.enQueue(6);
// queue.enQueue(7);
// queue.print();
// }
//}
//
package com.ruoyi.mybasic.Text;
import lombok.Data;
/**
* @ClassName Queue
* @Description 数据结构队列测试
* @Author WenHao.Sao
*/
@Data
public class Queue {
private int[] dataArray;//定义了一个数组
private int front;//队头
private int rear;//尾端
public Queue(int capacity){
this.dataArray = new int[capacity];
}
public void enQueue(int element){
if ((rear + 1 ) % dataArray.length == front){
System.out.println("队伍已经满了");
System.out.println();
return;
}
dataArray[rear] = element;
rear = (rear + 1) % dataArray.length;
System.out.println("入队后队头元素为:"+dataArray[front]);
System.out.println("出队!后 队尾元素" + element);
}
public int deQueue(){
if (rear == front){
System.out.println("队以空");
System.out.println("");
}
int deQueueElement = dataArray[front];
front = (front + 1) % dataArray.length;
System.out.println("出队后对头元素为:"+ dataArray[front]);
System.out.println("出队后队元素为:"+dataArray[rear - 1]);
System.out.println();
return deQueueElement;
}
public void print(){
for (int i = front; i != rear - i ; i = (i+1) % dataArray.length){
System.out.println(dataArray[i] + "-->");
}
System.out.println(dataArray[rear -1]);
System.out.println();
}
public static void main(String[] args) {
Queue queue = new Queue(6);
queue.enQueue(1);
queue.enQueue(2);
queue.enQueue(3);
queue.enQueue(4);
queue.enQueue(5);
queue.enQueue(6);
queue.print();
queue.deQueue();
queue.deQueue();
queue.deQueue();
queue.print();
queue.enQueue(6);
queue.enQueue(7);
queue.print();
}
}

67
src/main/java/com/ruoyi/mybasic/common/domain/Archives.java 100644
View File

@ -0,0 +1,67 @@
package com.ruoyi.mybasic.common.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.List;
/**
* 档案表
* @author Lou-Zs
*/
@Data
public class Archives {
/**
* 档案id(用户编号)
*/
private Integer userId;
/**
* 主要病状
*/
private String diseaseMain;
/**
* 现在病史
*/
private String diseaseNow;
/**
* 既往病史
*/
private String diseaseBefore;
/**
* 最近治疗医院
*/
private String hospitalName;
/**
* 治疗过程
*/
private String treatmentProcess;
/**
* 开始时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
private Date startTime;
/**
* 结束时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
private Date endTime;
/**
* 照片路径
*/
private String pictureUrl;
/**
* pictureList[]
*/
private List<String> pictureList;
}

40
src/main/java/com/ruoyi/mybasic/common/domain/Purse.java 100644
View File

@ -0,0 +1,40 @@
package com.ruoyi.mybasic.common.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* 钱包表
* @author Lou_Zs
*/
@Data
public class Purse {
/**
* 钱包编号
*/
private Integer userId;
/**
* 钱包总收入
*/
private double walletIncome;
/**
* 钱包总支出
*/
private double walletOutcome;
/**
* 钱包可用余额
*/
private double balanceFee;
/**
* 修改时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date updateTime;
}

50
src/main/java/com/ruoyi/mybasic/common/domain/UserMoneyLogs.java 100644
View File

@ -0,0 +1,50 @@
package com.ruoyi.mybasic.common.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* 支出收入流水记录
* @author Lou_Zs
*/
@Data
public class UserMoneyLogs {
/**
* 记录主建
*/
private Integer id;
/**
* 状态
* 1:支出
* 2:收入
*/
private Integer status;
/**
* 详情
*/
private String moneyTypeName;
/**
* 钱包主建
*/
private Integer userId;
/**
* 具体金额
*/
private Integer amountIncome;
//审计字段
/**
* 创建时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date createTime;
}

35
src/main/java/com/ruoyi/mybasic/common/domain/request/RequestInvitationRecord.java 100644
View File

@ -0,0 +1,35 @@
package com.ruoyi.mybasic.common.domain.request;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* 邀请记录参数
* @author Lou_Zs
*/
@Data
public class RequestInvitationRecord {
/**
* 邀请记录主建
*/
private Integer id;
/**
* 邀请人
*/
private Integer userId;
/**
* 被邀请人
*/
private Integer userPid;
/**
* 邀请时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date createTime;
}

106
src/main/java/com/ruoyi/mybasic/controller/ArchivesController.java 100644
View File

@ -0,0 +1,106 @@
package com.ruoyi.mybasic.controller;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.mybasic.common.domain.Archives;
import com.ruoyi.mybasic.service.ArchivesService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
/**
* @ClassName: ArchivesController
* @BelongsProject: parent
* @BelongsPackage: com.ruoyi.archives.controller
* @Author: zhiS_Lou
* @CreateTime: 2023/10/17 11:02
*/
/**
* 档案控制层
* @author Lou_Zs
*/
@RestController
@RequestMapping("/Archives")
@Log4j2
public class ArchivesController {
@Autowired
private HttpServletRequest request;
@Autowired
private ArchivesService archivesService;
/**
* 查询我的档案
* @return
*/
@GetMapping("/findArchivesList")
public R<Archives> findArchivesList(){
log.info("功能介绍:获取我的档案详情,请求方式:{},请求路径:{},请求参数:{}",
request.getMethod(),request.getRequestURI(),"无参数");
Archives archives = archivesService.findArchivesList();
log.info("功能介绍:获取我的档案详情,请求方式:{},请求路径:{},响应结果:{}",
request.getMethod(),request.getRequestURI(), JSONObject.toJSONString(archives));
return R.ok(archives);
}
/**
* 添加我的档案
* @param archives
* @return
*/
@PostMapping("/insertArchivesAndPicture")
public R insertArchivesAndPicture(@RequestBody Archives archives){
log.info("功能介绍:添加我的档案,请求方式:{},请求路径:{},请求参数:{}",
request.getMethod(),request.getRequestURI(),JSONObject.toJSONString(archives));
archivesService.insertArchivesAndPicture(archives);
log.info("功能介绍:添加我的档案,请求方式:{},请求路径:{},响应结果:{}",
request.getMethod(),request.getRequestURI(),JSONObject.toJSONString(R.ok()));
return R.ok();
}
/**
* 编辑我的档案
* @param archives
* @return
*/
@PostMapping("/updateArchivesAndPicture")
public R updateArchivesAndPicture(@RequestBody Archives archives){
log.info("功能介绍:编辑我的档案,请求方式:{},请求路径:{},请求参数:{}",
request.getMethod(),request.getRequestURI(),JSONObject.toJSONString(archives));
archivesService.updateArchivesAndPicture(archives);
log.info("功能介绍:编辑我的档案,请求方式:{},请求路径:{},响应结果:{}",
request.getMethod(),request.getMethod(),JSONObject.toJSONString(R.ok()));
return R.ok();
}
/**
* 根据档案编号删除档案
* @param id
* @return
*/
@PostMapping("/deleteArchivesById/{id}")
public R deleteArchivesById(@PathVariable String id){
log.info("功能介绍:根据档案编号删除档案,请求方式:{},请求路径:{},请求参数:{}",
request.getMethod(),request.getRequestURI(),JSONObject.toJSONString(id));
archivesService.deleteArchivesById(id);
log.info("功能介绍:根据档案编号删除档案,请求方式:{},请求路径:{},响应结果:{}",
request.getMethod(),request.getRequestURI(), JSONObject.toJSONString(R.ok()));
return R.ok();
}
}

51
src/main/java/com/ruoyi/mybasic/controller/InvitationController.java
View File

@ -1,24 +1,28 @@
package com.ruoyi.mybasic.controller;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest;
import com.ruoyi.mybasic.common.domain.request.RequestInvitationRecord;
import com.ruoyi.mybasic.service.InvitationService;
import lombok.extern.log4j.Log4j2;
import org.apache.commons.fileupload.FileItemFactory;
import org.apache.commons.fileupload.FileUpload;
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 java.util.List;
import javax.servlet.http.HttpServletRequest;
/**
* @ClassName InvitationController
* @Description 邀请记录的控制层
* @Author WenHao.Sao
*/
/**
* 邀请获利控制层
* @author Lou_Zs
*/
@RestController
@RequestMapping("/Invitation")
@Log4j2
@ -26,29 +30,26 @@ public class InvitationController {
@Autowired
private InvitationService invitationService;
@Autowired
private HttpServletRequest request;
/**
* 当前用户查看自己的邀请记录表
* 新用户注册邀请获利
* @param requestInvitationRecord
* @return
*/
@GetMapping("/list")
public R<List<InvitationRecordRequest>> show(@PathVariable String userId){
return invitationService.show(userId);
@PostMapping("/UserInviteTask")
public R UserInviteTask(@RequestBody RequestInvitationRecord requestInvitationRecord){
log.info("功能介绍:新用户邀请,请求方式:{},请求路径:{},请求参数:{}",
request.getMethod(),request.getRequestURI(), JSONObject.toJSONString(requestInvitationRecord));
//邀请新用户
invitationService.UserInviteTask(requestInvitationRecord);
log.info("功能介绍:新用户邀请,请求方式:{},请求路径:{},响应结果:{}",
request.getMethod(),request.getRequestURI(),JSONObject.toJSONString(R.ok()));
return R.ok();
}
//调用依赖的上传文件
public static void main(String[] args) {
FileUpload fileUpload = new FileUpload();
FileItemFactory fileItemFactory = fileUpload.getFileItemFactory();
System.out.println(fileItemFactory);
System.out.println("21111111111111111111111111");
}
}

43
src/main/java/com/ruoyi/mybasic/mapper/ArchivesMapper.java 100644
View File

@ -0,0 +1,43 @@
package com.ruoyi.mybasic.mapper;
import com.ruoyi.mybasic.common.domain.Archives;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
/**
* 档案Mapper接口
* @author Lou_Zs
*/
@Mapper
public interface ArchivesMapper {
/**
* 查询患者档案
* @param userId
* @return
*/
Archives findArchivesList(@Param("userId") Long userId);
/**
* 添加我的档案
* @param archives
*/
int insertArchives(Archives archives);
/**
* 编辑我的档案
* @param archives
*/
int updateArchives(Archives archives);
/**
* 删除我的档案
* @param id
*/
int deleteArchivesById(@Param("id") String id);
}

17
src/main/java/com/ruoyi/mybasic/mapper/InvitationMapper.java
View File

@ -1,8 +1,10 @@
package com.ruoyi.mybasic.mapper;
import com.ruoyi.mybasic.common.domain.UserMoneyLogs;
import com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest;
import com.ruoyi.mybasic.common.domain.request.PurseRequest;
import com.ruoyi.mybasic.common.domain.request.RequestInvitationRecord;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -20,4 +22,19 @@ public interface InvitationMapper {
PurseRequest Inviteramount(long inviterId);
PurseRequest Inviteeamount(long inviteeId);
/**
* 邀请记录新增
* @param requestInvitationRecord
*/
int insertInvitationRecord(RequestInvitationRecord requestInvitationRecord);
/**
* 修改钱包信息
* @param userId
*/
int updateUserPurse(@Param("userId") Integer userId);
int insertUserMoneyLogs(UserMoneyLogs userMoneyLogs);
}

38
src/main/java/com/ruoyi/mybasic/service/ArchivesService.java 100644
View File

@ -0,0 +1,38 @@
package com.ruoyi.mybasic.service;
import com.ruoyi.mybasic.common.domain.Archives;
/**
* 档案持久层
* @author Lou_Zs
*/
public interface ArchivesService {
/**
* 查询我的档案列表
*
* @return
*/
Archives findArchivesList();
/**
* 添加我的档案
*/
void insertArchivesAndPicture(Archives archives);
/**
* 编辑我的档案
*
* @param archives
*/
void updateArchivesAndPicture(Archives archives);
/**
* 根据档案编号删除档案
*
* @param id
*/
void deleteArchivesById(String id);
}

117
src/main/java/com/ruoyi/mybasic/service/Impl/ArchivesServiceImpl.java 100644
View File

@ -0,0 +1,117 @@
package com.ruoyi.mybasic.service.Impl;
import com.ruoyi.common.security.utils.SecurityUtils;
import com.ruoyi.mybasic.common.domain.Archives;
import com.ruoyi.mybasic.mapper.ArchivesMapper;
import com.ruoyi.mybasic.service.ArchivesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @ClassName: ArchivesServiceImpl
* @BelongsProject: parent
* @BelongsPackage: com.ruoyi.archives.service.impl
* @Author: zhiS_Lou
* @CreateTime: 2023/10/17 11:05
*/
/**
* 档案实现层
* @author Lou_Zs
*/
@Service
public class ArchivesServiceImpl implements ArchivesService {
@Autowired
private ArchivesMapper archivesMapper;
/**
* 查询我的档案列表
*
* @return
*/
@Override
public Archives findArchivesList() {
//获取用户id
Long userId = SecurityUtils.getUserId();
Archives archives = archivesMapper.findArchivesList(userId);
if (null == archives){
throw new RuntimeException("查无此档案!");
}
return archives;
}
/**
* 添加我的档案
*
* @param archives
*/
@Override
public void insertArchivesAndPicture(Archives archives) {
//获取用户id
Long userId = SecurityUtils.getUserId();
//添加当前用户
archives.setUserId(Math.toIntExact(userId));
/**
* 若前台传输为[]
*/
//获取图片集合
List<String> pictureList = archives.getPictureList();
if (pictureList.size() > 0){
//将集合拼接为字符串
String join = String.join(",", pictureList);
//将拼接好的字符串添加到字段
archives.setPictureUrl(join);
}
//添加档案
int i = archivesMapper.insertArchives(archives);
if (i < 0){
throw new RuntimeException("未添加成功!");
}
}
/**
* 编辑我的档案
*
* @param archives
*/
@Override
public void updateArchivesAndPicture(Archives archives) {
/**
* 若前台传输为[]
*/
//获取图片集合
List<String> pictureList = archives.getPictureList();
if (pictureList.size() > 0){
//将集合拼接为字符串
String join = String.join(",", pictureList);
//将拼接好的字符串添加到字段
archives.setPictureUrl(join);
}
//编辑档案
int i = archivesMapper.updateArchives(archives);
if (i < 0){
throw new RuntimeException("编辑无效!");
}
}
/**
* 根据档案编号删除档案
*
* @param id
*/
@Override
public void deleteArchivesById(String id) {
//档案删除
int i = archivesMapper.deleteArchivesById(id);
if (i < 0){
throw new RuntimeException("删除失败!");
}
}
}

89
src/main/java/com/ruoyi/mybasic/service/Impl/InvitationServiceImpl.java
View File

@ -1,22 +1,24 @@
package com.ruoyi.mybasic.service.Impl;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.mybasic.common.domain.emal.IncomeAmount;
import com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest;
import com.ruoyi.mybasic.common.domain.request.PurseRequest;
import com.ruoyi.mybasic.common.domain.UserMoneyLogs;
import com.ruoyi.mybasic.common.domain.request.RequestInvitationRecord;
import com.ruoyi.mybasic.mapper.InvitationMapper;
import com.ruoyi.mybasic.service.InvitationService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
import java.util.Date;
/**
* @ClassName InvitationServiceImpl
* @Description 邀请记录业务层
* @Author WenHao.Sao
*/
/**
* 邀请获利实现层
* @author Lou_Zs
*/
@Service
public class InvitationServiceImpl implements InvitationService {
@ -24,37 +26,54 @@ public class InvitationServiceImpl implements InvitationService {
@Autowired
private InvitationMapper invitationMapper;
/***
* 获取到当用户邀请的人的列表
* 1.入参 对象：邀请人id 被邀请人id
* @param userId
* @return
/**
* 新用户注册邀请获利
* @param requestInvitationRecord
*/
@Override
public R<List<InvitationRecordRequest>> show(String userId) {
//获取到邀请记录表
List<InvitationRecordRequest> list = invitationMapper.show(userId);
//所有的邀请记录表进行循环查询
for (InvitationRecordRequest invitationRecord : list) {
//调用枚举类
IncomeAmount tenDollars = IncomeAmount.TEN_DOLLARS;
//赋值
int value = tenDollars.getValue();
//获取到邀请人钱包余额
PurseRequest inviter = invitationMapper.Inviteramount(invitationRecord.getInviterId());
//加上枚举值
inviter.setBalanceFee(inviter.getBalanceFee() + value);
//获取到被邀请人钱包余额
PurseRequest invitee = invitationMapper.Inviteeamount(invitationRecord.getInviteeId());
//加上枚举值
invitee.setBalanceFee(inviter.getBalanceFee() + value);
@Transactional //事务
public void UserInviteTask(RequestInvitationRecord requestInvitationRecord) {
int i = 0;
//新增一条邀请记录
i = invitationMapper.insertInvitationRecord(requestInvitationRecord);
if (i < 0){
throw new RuntimeException("该用户未完成邀请");
}
R<List<InvitationRecordRequest>> ok = R.ok(list);
return ok;
//被邀请人id
Integer userPid = requestInvitationRecord.getUserPid();
//邀请人id
Integer userId = requestInvitationRecord.getUserId();
//修改邀请人钱包 (1.可用余额+300 2.总计收入+300 3.修改时间)
i = invitationMapper.updateUserPurse(userId);
if (i < 0){
throw new RuntimeException("获利金额未增加到可用余额");
}
//同时添加钱包变更记录表
UserMoneyLogs PurseMoneyLogs = new UserMoneyLogs();
PurseMoneyLogs.setUserId(userId);
PurseMoneyLogs.setMoneyTypeName("NEW_USER_INVITE");
PurseMoneyLogs.setStatus(2);
PurseMoneyLogs.setAmountIncome(300);
PurseMoneyLogs.setCreateTime(new Date());
invitationMapper.insertUserMoneyLogs(PurseMoneyLogs);
//修改被邀请人钱包 (1.可用余额+300 2.总计收入+300 3.修改时间)
i = invitationMapper.updateUserPurse(userPid);
if (i < 0){
throw new RuntimeException("获利金额未增加到可用余额");
}
//同时添加钱包变更记录表
UserMoneyLogs PurseMoneyLogsTwo = new UserMoneyLogs();
PurseMoneyLogsTwo.setUserId(userPid);
PurseMoneyLogsTwo.setMoneyTypeName("NEW_USER_INVITE");
PurseMoneyLogsTwo.setStatus(2);
PurseMoneyLogsTwo.setAmountIncome(300);
PurseMoneyLogsTwo.setCreateTime(new Date());
invitationMapper.insertUserMoneyLogs(PurseMoneyLogsTwo);
}
}

20
src/main/java/com/ruoyi/mybasic/service/InvitationService.java
View File

@ -1,16 +1,24 @@
package com.ruoyi.mybasic.service;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import com.ruoyi.mybasic.common.domain.request.RequestInvitationRecord;
/**
* @ClassName InvitationService
* @Description 描述
* @Author WenHao.Sao
*/
/**
* 邀请获利持久层
* @author Lou_Zs
*/
public interface InvitationService {
R<List<InvitationRecordRequest>> show(@Param("userId") String userId);
/**
* 新用户注册邀请获利
*
* @param requestInvitationRecord
*/
void UserInviteTask(RequestInvitationRecord requestInvitationRecord);
}

54
src/main/resources/mapper/ArchivesMapper.xml 100644
View File

@ -0,0 +1,54 @@
<?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.ruoyi.mybasic.mapper.ArchivesMapper">
<!-- 查询患者档案-->
<select id="findArchivesList" resultType="com.ruoyi.mybasic.common.domain.Archives">
select * from t_archives where user_id = #{userId}
</select>
<!-- 添加患者档案-->
<insert id="insertArchives" keyProperty="id" useGeneratedKeys="true">
INSERT INTO t_archives
(user_id,
disease_main,
disease_now,
disease_before,
hospital_name,
treatment_process,
start_time,
end_time,
picture_url)
VALUES
(
#{userId},
#{diseaseMain},
#{diseaseNow},
#{diseaseBefore},
#{hospitalName},
#{treatmentProcess},
#{startTime},
#{endTime},
#{pictureUrl}
)
</insert>
<!-- 编辑档案-->
<update id="updateArchives">
UPDATE t_archives
SET
disease_main = #{diseaseMain},
disease_now = #{diseaseNow},
disease_before = #{diseaseBefore},
hospital_name = #{hospitalName},
treatment_process = #{treatmentProcess},
start_time = #{startTime},
end_time = #{endTime},
picture_url = #{pictureUrl}
WHERE
user_id = #{userId}
</update>
<!-- 删除该档案-->
<delete id="deleteArchivesById">
delete from t_archives where user_id = #{id}
</delete>
</mapper>

42
src/main/resources/mapper/InvitationMapper.xml
View File

@ -3,6 +3,7 @@
<mapper namespace="com.ruoyi.mybasic.mapper.InvitationMapper">
<select id="show" resultType="com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest">
</select>
@ -22,4 +23,45 @@ FROM
invitation_record ir
LEFT JOIN t_user USER ON ir.inviter_id = USER.id
</select>
<!-- 新增邀请记录-->
<insert id="insertInvitationRecord">
INSERT INTO invitation_record
( user_id,
user_pid,
create_time)
VALUES
(#{userId},
#{userPid},
now()
)
</insert>
<!-- 添加流水记录-->
<insert id="insertUserMoneyLogs">
INSERT INTO t_money_logs
(status,
money_type_name,
user_id,
amount_income,
create_time
)
VALUES
(#{status},
#{moneyTypeName},
#{userId},
#{amountIncome},
#{createTime}
)
</insert>
<!-- 修改钱包信息-->
<update id="updateUserPurse">
UPDATE t_purse
SET wallet_income = wallet_income + 300,
balance_fee = balance_fee + 300,
update_time = now()
WHERE
user_id = #{userId}
</update>
</mapper>