diff --git a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java index 0d04ab20..c5058b04 100644 --- a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java +++ b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java @@ -28,7 +28,7 @@ public class DataMigrationUtil extends Thread { // courseCatalogue(); // courseCatalogueChapter(); // courseCatalogueChapterVideo(); - user();//用的都是copy表里的数据 +// user();//用的都是copy表里的数据 } diff --git a/src/main/java/com/peanut/modules/common/entity/JfTransactionDetails.java b/src/main/java/com/peanut/modules/common/entity/JfTransactionDetails.java index d06c1469..a825a2c8 100644 --- a/src/main/java/com/peanut/modules/common/entity/JfTransactionDetails.java +++ b/src/main/java/com/peanut/modules/common/entity/JfTransactionDetails.java @@ -45,4 +45,7 @@ public class JfTransactionDetails implements Serializable { @TableLogic private Integer delFlag; + @TableField(exist = false) + private MyUserEntity user; + } diff --git a/src/main/java/com/peanut/modules/master/controller/JfTransactionDetailsController.java b/src/main/java/com/peanut/modules/master/controller/JfTransactionDetailsController.java index 5e8b23fd..047b45a0 100644 --- a/src/main/java/com/peanut/modules/master/controller/JfTransactionDetailsController.java +++ b/src/main/java/com/peanut/modules/master/controller/JfTransactionDetailsController.java @@ -4,7 +4,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.peanut.common.utils.R; import com.peanut.modules.common.entity.JfTransactionDetails; +import com.peanut.modules.common.entity.MyUserEntity; import com.peanut.modules.master.service.JfTransactionDetailsService; +import com.peanut.modules.master.service.MyUserService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -12,6 +14,8 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.math.BigDecimal; +import java.util.List; import java.util.Map; /** @@ -25,15 +29,25 @@ public class JfTransactionDetailsController { @Autowired private JfTransactionDetailsService jfService; + @Autowired + private MyUserService userService; + /** * 列表 */ @RequestMapping("/listByPage") public R listByPage(@RequestBody Map params) { MPJLambdaWrapper wrapper = new MPJLambdaWrapper(); + wrapper.leftJoin(MyUserEntity.class,MyUserEntity::getId,JfTransactionDetails::getUserId); + wrapper.selectAll(JfTransactionDetails.class); if (params.containsKey("userId")&& StringUtils.isNotEmpty(params.get("userId").toString())) { wrapper.eq(JfTransactionDetails::getUserId,params.get("userId")); } + if (params.containsKey("userName")&& StringUtils.isNotEmpty(params.get("userName").toString())) { + wrapper.like(MyUserEntity::getName,params.get("userName")); + wrapper.like(MyUserEntity::getNickname,params.get("userName")); + } + if (params.containsKey("actType")&&StringUtils.isNotEmpty(params.get("actType").toString())) { wrapper.eq(JfTransactionDetails::getActType,params.get("actType")); } @@ -41,9 +55,16 @@ public class JfTransactionDetailsController { wrapper.like(JfTransactionDetails::getRemark,params.get("remark")); } wrapper.orderByDesc(JfTransactionDetails::getCreateTime); - Page records = jfService.page(new Page<>( + Page page = jfService.page(new Page<>( Long.parseLong(params.get("current").toString()), Long.parseLong(params.get("limit").toString())), wrapper); - return R.ok().put("result", records); + List records = page.getRecords(); + if (records.size() > 0) { + for (int i=0;i params) { + JfTransactionDetails jf = new JfTransactionDetails(); + MyUserEntity user = userService.getById(params.get("userId").toString()); + BigDecimal changeAmount = new BigDecimal(params.get("changeAmount").toString()); + String actType = params.get("actType").toString(); + if (actType.equals("0")) { + jf.setActType(0); + user.setJf(user.getJf().add(changeAmount)); + }else { + jf.setActType(1); + user.setJf(user.getJf().subtract(changeAmount)); + } + userService.updateById(user); + jf.setUserId(user.getId()); + jf.setChangeAmount(changeAmount); + jf.setRemark(params.get("remark").toString()); + jf.setUserBalance(user.getJf()); + jfService.save(jf); + return R.ok(); + } + + + + + @RequestMapping("/saveOrUpdateJfTransactionDetails") public R saveOrUpdateJfTransactionDetails(@RequestBody JfTransactionDetails jf) { jfService.saveOrUpdate(jf);