Browse Source

小喷菇说序号加完了,拉一下i

lihuilin/hotfix-20250810160509-余额地区传参
lihuilin 2 weeks ago
parent
commit
b57e0f5546
  1. 14
      src/main/java/com/example/demo/controller/bean/BeanAuditController.java
  2. 8
      src/main/java/com/example/demo/controller/bean/BeanConsumeController.java
  3. 1
      src/main/java/com/example/demo/domain/vo/bean/BeanAuditInfo.java
  4. 2
      src/main/java/com/example/demo/domain/vo/bean/BeanConsumeArticle.java
  5. 2
      src/main/java/com/example/demo/domain/vo/bean/BeanConsumeFan.java
  6. 1
      src/main/java/com/example/demo/domain/vo/bean/BeanConsumeGold.java
  7. 2
      src/main/java/com/example/demo/domain/vo/bean/BeanConsumeLive.java
  8. 1
      src/main/java/com/example/demo/domain/vo/bean/BeanUser.java
  9. 4
      src/main/java/com/example/demo/mapper/coin/BeanAuditMapper.java
  10. 10
      src/main/java/com/example/demo/mapper/live/LiveMapper.java
  11. 4
      src/main/java/com/example/demo/service/bean/BeanAuditService.java
  12. 3
      src/main/java/com/example/demo/service/bean/BeanConsumeService.java
  13. 10
      src/main/java/com/example/demo/serviceImpl/bean/BeanAuditServiceImpl.java
  14. 12
      src/main/java/com/example/demo/serviceImpl/bean/BeanConsumeServiceImpl.java
  15. 6
      src/main/resources/jindouMapper/BeanConsumeMapper.xml
  16. 3
      src/main/resources/jindouMapper/BeanUser.xml
  17. 108
      src/main/resources/liveMapper/LiveMapper.xml
  18. 7
      src/main/resources/mapper/BeanAuditMapper.xml

14
src/main/java/com/example/demo/controller/bean/BeanAuditController.java

@ -58,8 +58,10 @@ public class BeanAuditController {
@PostMapping("/status1") @PostMapping("/status1")
public Result updateStatus1(@RequestBody BeanAuditInfo beanAuditInfo) { public Result updateStatus1(@RequestBody BeanAuditInfo beanAuditInfo) {
try { try {
return beanAuditService.updateStatus1(beanAuditInfo.getId());
if (ObjectUtils.isEmpty(beanAuditInfo.getId())) {
return Result.error("id不能为空");
}
return beanAuditService.updateStatus1(beanAuditInfo);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
return Result.error("更新失败,查看id"); return Result.error("更新失败,查看id");
@ -69,7 +71,13 @@ public class BeanAuditController {
@PostMapping("/status2") @PostMapping("/status2")
public Result updateStatus2(@RequestBody BeanAuditInfo beanAuditInfo) { public Result updateStatus2(@RequestBody BeanAuditInfo beanAuditInfo) {
try { try {
beanAuditService.updateStatus2(beanAuditInfo.getId());
if (ObjectUtils.isEmpty(beanAuditInfo.getId())) {
return Result.error("id不能为空");
}
if (ObjectUtils.isEmpty(beanAuditInfo.getReason())) {
return Result.error("审核意见不能为空");
}
beanAuditService.updateStatus2(beanAuditInfo);
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
return Result.error("更新失败,查看id"); return Result.error("更新失败,查看id");

8
src/main/java/com/example/demo/controller/bean/BeanConsumeController.java

@ -37,6 +37,14 @@ public class BeanConsumeController {
return Result.success(deptList); return Result.success(deptList);
} }
//获取直播消费用户分部信息
@PostMapping("/getLiveDept")
public Result getLiveDept(){
List<String> deptList = beanConsumeService.getLiveDept();
return Result.success(deptList);
}
//筛选查询直播消费记录 //筛选查询直播消费记录
@PostMapping("/selectLiveBy") @PostMapping("/selectLiveBy")
public Result selectLiveBy(@RequestBody Page page){ public Result selectLiveBy(@RequestBody Page page){

1
src/main/java/com/example/demo/domain/vo/bean/BeanAuditInfo.java

@ -30,6 +30,7 @@ public class BeanAuditInfo {
private String remark; // 备注 private String remark; // 备注
private String submitName; // 提交人名称 private String submitName; // 提交人名称
private String auditName; // 审核人名称 private String auditName; // 审核人名称
private String reason; // 审核意见
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date createTime; //创建时间 private Date createTime; //创建时间
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")

2
src/main/java/com/example/demo/domain/vo/bean/BeanConsumeArticle.java

@ -22,6 +22,8 @@ import java.util.Date;
@JsonIgnoreProperties(ignoreUnknown = true) @JsonIgnoreProperties(ignoreUnknown = true)
public class BeanConsumeArticle { public class BeanConsumeArticle {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
@ExcelProperty("ID")
private Integer id;
@ExcelProperty("姓名") @ExcelProperty("姓名")
private String name; //姓名 private String name; //姓名
@ExcelProperty("精网号") @ExcelProperty("精网号")

2
src/main/java/com/example/demo/domain/vo/bean/BeanConsumeFan.java

@ -22,6 +22,8 @@ import java.util.Date;
@JsonIgnoreProperties(ignoreUnknown = true) @JsonIgnoreProperties(ignoreUnknown = true)
public class BeanConsumeFan { public class BeanConsumeFan {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
@ExcelProperty("ID")
private Integer id;
@ExcelProperty("姓名") @ExcelProperty("姓名")
private String name; //姓名 private String name; //姓名
@ExcelProperty("精网号") @ExcelProperty("精网号")

1
src/main/java/com/example/demo/domain/vo/bean/BeanConsumeGold.java

@ -17,6 +17,7 @@ import lombok.NoArgsConstructor;
@JsonIgnoreProperties(ignoreUnknown = true) @JsonIgnoreProperties(ignoreUnknown = true)
public class BeanConsumeGold { public class BeanConsumeGold {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
private Integer sumBean ; //总金豆
private Integer permanentBean ; //付费金豆 private Integer permanentBean ; //付费金豆
private Integer freeBean ; //免费金豆 private Integer freeBean ; //免费金豆
private Integer totalNum; //总条数 private Integer totalNum; //总条数

2
src/main/java/com/example/demo/domain/vo/bean/BeanConsumeLive.java

@ -24,6 +24,8 @@ import java.util.List;
@JsonIgnoreProperties(ignoreUnknown = true) @JsonIgnoreProperties(ignoreUnknown = true)
public class BeanConsumeLive { public class BeanConsumeLive {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
@ExcelProperty("ID")
private Integer id;
@ExcelProperty("姓名") @ExcelProperty("姓名")
private String name; //姓名 private String name; //姓名
@ExcelProperty("精网号") @ExcelProperty("精网号")

1
src/main/java/com/example/demo/domain/vo/bean/BeanUser.java

@ -16,6 +16,7 @@ import lombok.NoArgsConstructor;
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
public class BeanUser { public class BeanUser {
private Integer id;
private String name; //姓名 private String name; //姓名
private Integer jwcode; //精网号 private Integer jwcode; //精网号
private String dept; //分部 private String dept; //分部

4
src/main/java/com/example/demo/mapper/coin/BeanAuditMapper.java

@ -24,8 +24,8 @@ public interface BeanAuditMapper {
BeanAuditInfo selectById(Long id); BeanAuditInfo selectById(Long id);
//根据id更新状态为1 //根据id更新状态为1
void updateStatus1(Long id);
void updateStatus1(BeanAuditInfo beanAuditInfo);
//根据id更新状态为2 //根据id更新状态为2
void updateStatus2(Long id);
void updateStatus2(BeanAuditInfo beanAuditInfo);
} }

10
src/main/java/com/example/demo/mapper/live/LiveMapper.java

@ -1,5 +1,6 @@
package com.example.demo.mapper.live; package com.example.demo.mapper.live;
import com.example.demo.domain.vo.bean.BeanConsumeGold;
import com.example.demo.domain.vo.bean.BeanConsumeLive; import com.example.demo.domain.vo.bean.BeanConsumeLive;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@ -16,5 +17,14 @@ import java.util.List;
**/ **/
@Mapper @Mapper
public interface LiveMapper { public interface LiveMapper {
//筛选查询直播消费列表
List<BeanConsumeLive> selectLiveBy(@Param("beanConsumeLive") BeanConsumeLive beanConsumeLive); List<BeanConsumeLive> selectLiveBy(@Param("beanConsumeLive") BeanConsumeLive beanConsumeLive);
//获取直播礼物列表
List<String> getLiveGift();
//获取直播频道列表
List<String> getLiveChannel();
//计算直播消费金豆合计数
BeanConsumeGold selectSumLiveBy(@Param("beanConsumeLive") BeanConsumeLive beanConsumeLive);
//获取直播客户地区
List<String> getDept();
} }

4
src/main/java/com/example/demo/service/bean/BeanAuditService.java

@ -19,9 +19,9 @@ public interface BeanAuditService {
//查找审核信息 //查找审核信息
PageInfo<BeanAuditInfo> selectBy(Integer pageNum, Integer pageSize, BeanAuditInfo beanAuditInfo); PageInfo<BeanAuditInfo> selectBy(Integer pageNum, Integer pageSize, BeanAuditInfo beanAuditInfo);
Result updateStatus1(Long id);
Result updateStatus1(BeanAuditInfo beanAuditInfo);
void updateStatus2(Long id);
void updateStatus2(BeanAuditInfo beanAuditInfo);
GoldBean statsBean(BeanAuditInfo beanAuditInfo); GoldBean statsBean(BeanAuditInfo beanAuditInfo);
} }

3
src/main/java/com/example/demo/service/bean/BeanConsumeService.java

@ -31,5 +31,6 @@ public interface BeanConsumeService {
//获取直播频道 //获取直播频道
List<String> getLiveChannel(); List<String> getLiveChannel();
//获取直播客户地区
List<String> getLiveDept();
} }

10
src/main/java/com/example/demo/serviceImpl/bean/BeanAuditServiceImpl.java

@ -54,8 +54,8 @@ public class BeanAuditServiceImpl implements BeanAuditService {
@Transactional @Transactional
@Override @Override
public Result updateStatus1(Long id) {
BeanAuditInfo beanAuditInfo = beanAuditMapper.selectById(id);
public Result updateStatus1(BeanAuditInfo info) {
BeanAuditInfo beanAuditInfo = beanAuditMapper.selectById(info.getId());
String jwcode = beanAuditInfo.getJwcode().toString(); String jwcode = beanAuditInfo.getJwcode().toString();
String op = "recharge"; // 操作类型根据实际业务定义例如"recharge"表示充值 String op = "recharge"; // 操作类型根据实际业务定义例如"recharge"表示充值
String content = beanAuditInfo.getRemark(); // 备注作为content参数 String content = beanAuditInfo.getRemark(); // 备注作为content参数
@ -88,13 +88,13 @@ public class BeanAuditServiceImpl implements BeanAuditService {
if (!response2.getStatusCode().is2xxSuccessful()) { if (!response2.getStatusCode().is2xxSuccessful()) {
return Result.error("付费远程接口调用失败,状态码:" + response2.getStatusCodeValue()); return Result.error("付费远程接口调用失败,状态码:" + response2.getStatusCodeValue());
} }
beanAuditMapper.updateStatus1(id);
beanAuditMapper.updateStatus1(info);
return Result.success(); return Result.success();
} }
@Override @Override
public void updateStatus2(Long id) {
beanAuditMapper.updateStatus2(id);
public void updateStatus2(BeanAuditInfo beanAuditInfo) {
beanAuditMapper.updateStatus2(beanAuditInfo);
} }
@Override @Override

12
src/main/java/com/example/demo/serviceImpl/bean/BeanConsumeServiceImpl.java

@ -64,7 +64,7 @@ public class BeanConsumeServiceImpl implements BeanConsumeService {
Integer payType = page.getPayType(); Integer payType = page.getPayType();
if (payType==1) { if (payType==1) {
//直播消费合计 //直播消费合计
gold = beanConsumeMapper.selectSumLiveBy(page.getBeanConsumeLive());
gold = liveMapper.selectSumLiveBy(page.getBeanConsumeLive());
}else if (payType==7) { }else if (payType==7) {
//充值消费合计 //充值消费合计
gold = beanConsumeMapper.selectSumFansBy(page.getBeanConsumeFan()); gold = beanConsumeMapper.selectSumFansBy(page.getBeanConsumeFan());
@ -79,11 +79,17 @@ public class BeanConsumeServiceImpl implements BeanConsumeService {
@Override @Override
public List<String> getLiveGift() { public List<String> getLiveGift() {
return beanConsumeMapper.getLiveGift();
return liveMapper.getLiveGift();
} }
//查询直播全部频道 //查询直播全部频道
@Override @Override
public List<String> getLiveChannel() { public List<String> getLiveChannel() {
return beanConsumeMapper.getLiveChannel();
return liveMapper.getLiveChannel();
}
@Override
public List<String> getLiveDept() {
List<String> liveDeptList = liveMapper.getDept();
return liveDeptList;
} }
} }

6
src/main/resources/jindouMapper/BeanConsumeMapper.xml

@ -124,7 +124,8 @@
</select> </select>
<!--筛选铁粉消费记录--> <!--筛选铁粉消费记录-->
<select id="selectFanBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeFan"> <select id="selectFanBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeFan">
SELECT fm.nickname AS name,
SELECT fyr.id AS id,
fm.nickname AS name,
fm.jwcode, fm.jwcode,
fm.dept, fm.dept,
fyr.money AS beanNum, fyr.money AS beanNum,
@ -196,7 +197,8 @@
</select> </select>
<!--筛选文章消费记录--> <!--筛选文章消费记录-->
<select id="selectArticleBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeArticle"> <select id="selectArticleBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeArticle">
SELECT fm.nickname AS name,
SELECT fyr.id AS id,
fm.nickname AS name,
fm.jwcode, fm.jwcode,
fm.dept, fm.dept,
fyr.source_type AS type, fyr.source_type AS type,

3
src/main/resources/jindouMapper/BeanUser.xml

@ -22,7 +22,8 @@
</select> </select>
<!--查询客户金豆余额--> <!--查询客户金豆余额-->
<select id="selectUserBy" resultType="com.example.demo.domain.vo.bean.BeanUser"> <select id="selectUserBy" resultType="com.example.demo.domain.vo.bean.BeanUser">
SELECT fm.nickname AS name,
SELECT fm.id as id,
fm.nickname AS name,
fm.jwcode, fm.jwcode,
fm.dept, fm.dept,
fy.jinbi AS beanNum, fy.jinbi AS beanNum,

108
src/main/resources/liveMapper/LiveMapper.xml

@ -4,7 +4,8 @@
<select id="selectLiveBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeLive"> <select id="selectLiveBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeLive">
select mi.name as name,
select lgg.id as id,
mi.name as name,
lgg.jwcode as jwcode, lgg.jwcode as jwcode,
mi.deptName as dept, mi.deptName as dept,
lg.name as gift, lg.name as gift,
@ -14,11 +15,106 @@
lp.title as liveChannel, lp.title as liveChannel,
l.name as liveName, l.name as liveName,
lgg.created_at as consumeTime lgg.created_at as consumeTime
from live_give_gifts lgg
left join member_info mi on mi.jwcode = lgg.jwcode
left join live_gifts lg on lg.id = lgg.g_id
left join live l on l.id = lgg.live_id
left join live_pindao lp on lp.id = l.channel_id
FROM live_give_gifts lgg
LEFT JOIN live_gifts lg ON lg.id = lgg.g_id
LEFT JOIN live l ON l.id = lgg.live_id
LEFT JOIN live_pindao lp ON lp.pd_id = l.channel_id
LEFT JOIN member_info mi ON mi.jwcode = lgg.jwcode
<where>
<if test="beanConsumeLive.jwcode != null and beanConsumeLive.jwcode != ''">
AND lgg.jwcode = #{beanConsumeLive.jwcode}
</if>
<if test="beanConsumeLive.dept != null and beanConsumeLive.dept != ''">
AND mi.deptName = #{beanConsumeLive.dept}
</if>
<!-- <if test="beanConsumeLive.type != null and beanConsumeLive.type != ''">
AND fyr.source_type = #{beanConsumeLive.type}
</if>-->
<if test="beanConsumeLive.startTime != null and beanConsumeLive.endTime != null">
AND lgg.created_at BETWEEN #{beanConsumeLive.startTime}
AND #{beanConsumeLive.endTime}
</if>
<if test="beanConsumeLive.gift != null and beanConsumeLive.gift != ''">
AND lg.name =#{beanConsumeLive.gift}
</if>
<if test="beanConsumeLive.liveChannel != null and beanConsumeLive.liveChannel != ''">
AND lp.title = #{beanConsumeLive.liveChannel}
</if>
<if test="beanConsumeLive.liveName != null and beanConsumeLive.liveName != ''">
AND l.name LIKE CONCAT('%', #{beanConsumeLive.liveName}, '%')
</if>
</where>
<choose>
<when test="beanConsumeLive.sortField != null and beanConsumeLive.sortField != '' and beanConsumeLive.sortOrder != null and beanConsumeLive.sortOrder != ''">
ORDER BY ${beanConsumeLive.sortField} ${beanConsumeLive.sortOrder}
</when>
<otherwise>
ORDER BY consumeTime DESC
</otherwise>
</choose>
</select>
<!--获取直播礼物列表-->
<select id="getLiveGift" resultType="java.lang.String">
select distinct name from live_gifts
</select>
<!--获取直播频道列表-->
<select id="getLiveChannel" resultType="java.lang.String">
select distinct title from live_pindao
</select>
<!--计算直播消费金豆合计数-->
<select id="selectSumLiveBy" resultType="com.example.demo.domain.vo.bean.BeanConsumeGold">
select
ifnull(sum(t.beanNum),0) as sunBeam,
ifnull(sum(t.freeBean),0) as freeBean,
ifnull(sum(t.buyBean),0) as permanentBean,
count(*) as totalNum
from
(select mi.name as name,
lgg.jwcode as jwcode,
mi.deptName as dept,
lg.name as gift,
lgg.gold_beans as beanNum,
lgg.gold_free as freeBean,
lgg.gold_buy as buyBean,
lp.title as liveChannel,
l.name as liveName,
lgg.created_at as consumeTime
FROM live_give_gifts lgg
LEFT JOIN live_gifts lg ON lg.id = lgg.g_id
LEFT JOIN live l ON l.id = lgg.live_id
LEFT JOIN live_pindao lp ON lp.pd_id = l.channel_id
LEFT JOIN member_info mi ON mi.jwcode = lgg.jwcode
<where>
lgg.knapsack=0
<if test="beanConsumeLive.jwcode != null and beanConsumeLive.jwcode != ''">
AND lgg.jwcode = #{beanConsumeLive.jwcode}
</if>
<if test="beanConsumeLive.dept != null and beanConsumeLive.dept != ''">
AND mi.deptName = #{beanConsumeLive.dept}
</if>
<!-- <if test="beanConsumeLive.type != null and beanConsumeLive.type != ''">
AND fyr.source_type = #{beanConsumeLive.type}
</if>-->
<if test="beanConsumeLive.startTime != null and beanConsumeLive.endTime != null">
AND lgg.created_at BETWEEN #{beanConsumeLive.startTime}
AND #{beanConsumeLive.endTime}
</if>
<if test="beanConsumeLive.gift != null and beanConsumeLive.gift != ''">
AND lg.name =#{beanConsumeLive.gift}
</if>
<if test="beanConsumeLive.liveChannel != null and beanConsumeLive.liveChannel != ''">
AND lp.title = #{beanConsumeLive.liveChannel}
</if>
<if test="beanConsumeLive.liveName != null and beanConsumeLive.liveName != ''">
AND l.name LIKE CONCAT('%', #{beanConsumeLive.liveName}, '%')
</if>
</where>)t
</select>
<select id="getDept" resultType="java.lang.String">
select distinct deptName from member_info
where deptName is not null and deptName != ''
</select> </select>
</mapper> </mapper>

7
src/main/resources/mapper/BeanAuditMapper.xml

@ -69,14 +69,17 @@
<update id="updateStatus1"> <update id="updateStatus1">
update audit update audit
set audit_status = 1
set audit_status = 1,
audit_name = #{auditName}
where id = #{id} where id = #{id}
</update> </update>
<update id="updateStatus2"> <update id="updateStatus2">
update audit update audit
set audit_status = 2
set audit_status = 2,
audit_name = #{auditName},
reason = #{reason}
where id = #{id} where id = #{id}
</update> </update>

Loading…
Cancel
Save