Browse Source

分销提成->分销记录查询

fushengqian 1 year ago
parent
commit
c3adcd6b57

+ 71 - 0
fuint-application/src/main/java/com/fuint/common/dto/CommissionLogDto.java

@@ -0,0 +1,71 @@
+package com.fuint.common.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 分销提成记录实体
+ * Created by FSQ
+ * CopyRight https://www.fuint.cn
+ */
+@Data
+public class CommissionLogDto implements Serializable {
+
+    @ApiModelProperty("自增ID")
+    private Integer id;
+
+    @ApiModelProperty("分佣类型,member:会员分销;staff:员工提成")
+    private String type;
+
+    @ApiModelProperty("分佣等级")
+    private Integer level;
+
+    @ApiModelProperty("会员ID")
+    private Integer userId;
+
+    @ApiModelProperty("商户ID")
+    private Integer merchantId;
+
+    @ApiModelProperty("店铺ID")
+    private Integer storeId;
+
+    @ApiModelProperty("员工ID")
+    private Integer staffId;
+
+    @ApiModelProperty("订单ID")
+    private Integer orderId;
+
+    @ApiModelProperty("分佣金额")
+    private BigDecimal amount;
+
+    @ApiModelProperty("规则ID")
+    private Integer ruleId;
+
+    @ApiModelProperty("备注")
+    private String description;
+
+    @ApiModelProperty("提现记录ID")
+    private Integer cashId;
+
+    @ApiModelProperty("最后操作人")
+    private String isCash;
+
+    @ApiModelProperty("提现时间")
+    private Date cashTime;
+
+    @ApiModelProperty("是否提现")
+    private Date createTime;
+
+    @ApiModelProperty("更新时间")
+    private Date updateTime;
+
+    @ApiModelProperty("最后操作人")
+    private String operator;
+
+    @ApiModelProperty("状态")
+    private String status;
+
+}

+ 3 - 18
fuint-application/src/main/java/com/fuint/common/service/CommissionLogService.java

@@ -1,14 +1,12 @@
 package com.fuint.common.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.fuint.common.dto.CommissionLogDto;
 import com.fuint.framework.pagination.PaginationRequest;
 import com.fuint.framework.pagination.PaginationResponse;
 import com.fuint.framework.exception.BusinessCheckException;
 import com.fuint.repository.model.MtCommissionLog;
 
-import java.util.List;
-import java.util.Map;
-
 /**
  * 分销提成记录业务接口
  *
@@ -23,7 +21,7 @@ public interface CommissionLogService extends IService<MtCommissionLog> {
      * @param paginationRequest
      * @return
      */
-    PaginationResponse<MtCommissionLog> queryDataByPagination(PaginationRequest paginationRequest) throws BusinessCheckException;
+    PaginationResponse<MtCommissionLog> queryCommissionLogByPagination(PaginationRequest paginationRequest) throws BusinessCheckException;
 
     /**
      * 添加分销提成记录
@@ -39,7 +37,7 @@ public interface CommissionLogService extends IService<MtCommissionLog> {
      * @param  id
      * @throws BusinessCheckException
      */
-    MtCommissionLog queryCommissionLogById(Integer id) throws BusinessCheckException;
+    CommissionLogDto queryCommissionLogById(Integer id) throws BusinessCheckException;
 
     /**
      * 根据ID删除分销提成记录
@@ -49,17 +47,4 @@ public interface CommissionLogService extends IService<MtCommissionLog> {
      * @throws BusinessCheckException
      */
     void deleteCommissionLog(Integer id, String operator) throws BusinessCheckException;
-
-    /**
-     * 更新数据
-     * @param  commissionLog
-     * @throws BusinessCheckException
-     * */
-    MtCommissionLog updateCommissionLog(MtCommissionLog commissionLog) throws BusinessCheckException;
-
-    /**
-     * 根据条件搜索分销提成记录
-     * */
-    List<MtCommissionLog> queryDataByParams(Map<String, Object> params) throws BusinessCheckException;
-
 }

+ 17 - 60
fuint-application/src/main/java/com/fuint/common/service/impl/CommissionLogServiceImpl.java

@@ -4,9 +4,9 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 
+import com.fuint.common.dto.CommissionLogDto;
 import com.fuint.common.service.CommissionLogService;
 import com.fuint.framework.annoation.OperationServiceLog;
-import com.fuint.framework.exception.BusinessCheckException;
 import com.fuint.framework.pagination.PaginationRequest;
 import com.fuint.framework.pagination.PaginationResponse;
 import com.fuint.repository.mapper.MtCommissionLogMapper;
@@ -19,6 +19,7 @@ import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import com.github.pagehelper.Page;
+import org.springframework.beans.BeanUtils;
 import org.springframework.data.domain.PageImpl;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;
@@ -46,7 +47,7 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
      * @return
      */
     @Override
-    public PaginationResponse<MtCommissionLog> queryDataByPagination(PaginationRequest paginationRequest) {
+    public PaginationResponse<MtCommissionLog> queryCommissionLogByPagination(PaginationRequest paginationRequest) {
         Page<MtCommissionLog> pageHelper = PageHelper.startPage(paginationRequest.getCurrentPage(), paginationRequest.getPageSize());
         LambdaQueryWrapper<MtCommissionLog> lambdaQueryWrapper = Wrappers.lambdaQuery();
         lambdaQueryWrapper.ne(MtCommissionLog::getStatus, StatusEnum.DISABLE.getKey());
@@ -55,6 +56,10 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
         if (StringUtils.isNotBlank(status)) {
             lambdaQueryWrapper.eq(MtCommissionLog::getStatus, status);
         }
+        String merchantId = paginationRequest.getSearchParams().get("merchantId") == null ? "" : paginationRequest.getSearchParams().get("merchantId").toString();
+        if (StringUtils.isNotBlank(merchantId)) {
+            lambdaQueryWrapper.eq(MtCommissionLog::getMerchantId, merchantId);
+        }
         String storeId = paginationRequest.getSearchParams().get("storeId") == null ? "" : paginationRequest.getSearchParams().get("storeId").toString();
         if (StringUtils.isNotBlank(storeId)) {
             lambdaQueryWrapper.eq(MtCommissionLog::getStoreId, storeId);
@@ -79,6 +84,7 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
      * @param commissionLog
      */
     @Override
+    @Transactional
     @OperationServiceLog(description = "新增分销提成记录")
     public MtCommissionLog addCommissionLog(MtCommissionLog commissionLog) {
         MtCommissionLog mtCommissionLog = new MtCommissionLog();
@@ -97,8 +103,13 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
      * @param id
      */
     @Override
-    public MtCommissionLog queryCommissionLogById(Integer id) {
-        return mtCommissionLogMapper.selectById(id);
+    public CommissionLogDto queryCommissionLogById(Integer id) {
+        MtCommissionLog mtCommissionLog = mtCommissionLogMapper.selectById(id);
+        CommissionLogDto commissionLogDto = null;
+        if (mtCommissionLog != null) {
+            BeanUtils.copyProperties(mtCommissionLog, commissionLogDto);
+        }
+        return commissionLogDto;
     }
 
     /**
@@ -108,9 +119,10 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
      * @param operator 操作人
      */
     @Override
+    @Transactional
     @OperationServiceLog(description = "删除分销提成记录")
     public void deleteCommissionLog(Integer id, String operator) {
-        MtCommissionLog mtCommissionLog = queryCommissionLogById(id);
+        MtCommissionLog mtCommissionLog =  mtCommissionLogMapper.selectById(id);
         if (mtCommissionLog == null) {
             logger.error("删除分销提成记录失败...");
             return;
@@ -119,59 +131,4 @@ public class CommissionLogServiceImpl extends ServiceImpl<MtCommissionLogMapper,
         mtCommissionLog.setUpdateTime(new Date());
         mtCommissionLogMapper.updateById(mtCommissionLog);
     }
-
-    /**
-     * 更新分销提成记录
-     *
-     * @param  commissionLog
-     * @throws BusinessCheckException
-     */
-    @Override
-    @Transactional(rollbackFor = Exception.class)
-    @OperationServiceLog(description = "更新分销提成记录")
-    public MtCommissionLog updateCommissionLog(MtCommissionLog commissionLog) throws BusinessCheckException {
-        MtCommissionLog mtCommissionLog = queryCommissionLogById(commissionLog.getId());
-        if (mtCommissionLog == null) {
-            logger.error("更新分销提成记录失败...");
-            throw new BusinessCheckException("该数据状态异常");
-        }
-        mtCommissionLog.setId(commissionLog.getId());
-        if (commissionLog.getStoreId() != null) {
-            mtCommissionLog.setStoreId(commissionLog.getStoreId());
-        }
-        if (commissionLog.getDescription() != null) {
-            mtCommissionLog.setDescription(commissionLog.getDescription());
-        }
-        if (commissionLog.getOperator() != null) {
-            mtCommissionLog.setOperator(commissionLog.getOperator());
-        }
-        if (commissionLog.getStatus() != null) {
-            mtCommissionLog.setStatus(commissionLog.getStatus());
-        }
-        mtCommissionLog.setUpdateTime(new Date());
-        mtCommissionLogMapper.updateById(mtCommissionLog);
-        return mtCommissionLog;
-    }
-
-    @Override
-    public List<MtCommissionLog> queryDataByParams(Map<String, Object> params) {
-        String status =  params.get("status") == null ? StatusEnum.ENABLED.getKey(): params.get("status").toString();
-        String storeId =  params.get("storeId") == null ? "" : params.get("storeId").toString();
-
-        LambdaQueryWrapper<MtCommissionLog> lambdaQueryWrapper = Wrappers.lambdaQuery();
-        if (StringUtils.isNotBlank(status)) {
-            lambdaQueryWrapper.eq(MtCommissionLog::getStatus, status);
-        }
-        if (StringUtils.isNotBlank(storeId)) {
-            lambdaQueryWrapper.and(wq -> wq
-                              .eq(MtCommissionLog::getStoreId, 0)
-                              .or()
-                              .eq(MtCommissionLog::getStoreId, storeId));
-        }
-
-        lambdaQueryWrapper.orderByAsc(MtCommissionLog::getId);
-        List<MtCommissionLog> dataList = mtCommissionLogMapper.selectList(lambdaQueryWrapper);
-
-        return dataList;
-    }
 }

+ 17 - 89
fuint-application/src/main/java/com/fuint/module/backendApi/controller/BackendCommissionLogController.java

@@ -1,9 +1,8 @@
 package com.fuint.module.backendApi.controller;
 
 import com.fuint.common.dto.AccountInfo;
-import com.fuint.common.dto.CommissionRuleDto;
-import com.fuint.common.param.CommissionRuleParam;
-import com.fuint.common.service.CommissionRuleService;
+import com.fuint.common.dto.CommissionLogDto;
+import com.fuint.common.service.CommissionLogService;
 import com.fuint.common.service.StoreService;
 import com.fuint.common.util.TokenUtil;
 import com.fuint.framework.web.BaseController;
@@ -13,7 +12,7 @@ import com.fuint.common.enums.StatusEnum;
 import com.fuint.framework.pagination.PaginationRequest;
 import com.fuint.framework.pagination.PaginationResponse;
 import com.fuint.framework.exception.BusinessCheckException;
-import com.fuint.repository.model.MtCommissionRule;
+import com.fuint.repository.model.MtCommissionLog;
 import com.fuint.repository.model.MtStore;
 import com.fuint.utils.StringUtil;
 import io.swagger.annotations.Api;
@@ -32,16 +31,16 @@ import java.util.Map;
  * Created by FSQ
  * CopyRight https://www.fuint.cn
  */
-@Api(tags="管理端-销提成记录相关接口")
+@Api(tags="管理端-销提成记录相关接口")
 @RestController
 @AllArgsConstructor
 @RequestMapping(value = "/backendApi/commissionLog")
 public class BackendCommissionLogController extends BaseController {
 
     /**
-     * 分销提成规则服务接口
+     * 分销提成记录业务接口
      */
-    private CommissionRuleService commissionRuleService;
+    private CommissionLogService commissionLogService;
 
     /**
      * 店铺服务接口
@@ -49,15 +48,15 @@ public class BackendCommissionLogController extends BaseController {
     private StoreService storeService;
 
     /**
-     * 规则列表查询
+     * 分销提成记录列表查询
      *
-     * @param  request HttpServletRequest对象
-     * @return 规则列表
+     * @param request HttpServletRequest对象
+     * @return 分销提成记录
      */
-    @ApiOperation(value = "规则列表查询")
+    @ApiOperation(value = "分销提成记录查询")
     @RequestMapping(value = "/list", method = RequestMethod.GET)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionLog:index')")
+    @PreAuthorize("@pms.hasPermission('commission:log:index')")
     public ResponseObject list(HttpServletRequest request) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         Integer page = request.getParameter("page") == null ? Constants.PAGE_NUMBER : Integer.parseInt(request.getParameter("page"));
@@ -92,7 +91,7 @@ public class BackendCommissionLogController extends BaseController {
             params.put("storeId", storeId);
         }
         paginationRequest.setSearchParams(params);
-        PaginationResponse<MtCommissionRule> paginationResponse = commissionRuleService.queryDataByPagination(paginationRequest);
+        PaginationResponse<MtCommissionLog> paginationResponse = commissionLogService.queryCommissionLogByPagination(paginationRequest);
 
         Map<String, Object> paramsStore = new HashMap<>();
         paramsStore.put("status", StatusEnum.ENABLED.getKey());
@@ -112,86 +111,15 @@ public class BackendCommissionLogController extends BaseController {
     }
 
     /**
-     * 更新分销提成规则状态
-     *
-     * @return
-     */
-    @ApiOperation(value = "更新分销提成规则状态")
-    @RequestMapping(value = "/updateStatus", method = RequestMethod.POST)
-    @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionLog:index')")
-    public ResponseObject updateStatus(HttpServletRequest request, @RequestBody Map<String, Object> params) throws BusinessCheckException {
-        String token = request.getHeader("Access-Token");
-        String status = params.get("status") != null ? params.get("status").toString() : StatusEnum.ENABLED.getKey();
-        Integer id = params.get("id") == null ? 0 : Integer.parseInt(params.get("id").toString());
-
-        AccountInfo accountInfo = TokenUtil.getAccountInfoByToken(token);
-        if (accountInfo == null) {
-            return getFailureResult(1001, "请先登录");
-        }
-
-        CommissionRuleDto commissionRuleDto = commissionRuleService.queryCommissionRuleById(id);
-        if (commissionRuleDto == null) {
-            return getFailureResult(201);
-        }
-
-        String operator = accountInfo.getAccountName();
-
-        CommissionRuleParam commissionRule = new CommissionRuleParam();
-        commissionRule.setOperator(operator);
-        commissionRule.setId(id);
-        commissionRule.setStatus(status);
-        commissionRuleService.updateCommissionRule(commissionRule);
-
-        return getSuccessResult(true);
-    }
-
-    /**
-     * 保存分销提成规则
-     *
-     * @param request HttpServletRequest对象
-     * @return
-     */
-    @ApiOperation(value = "保存分销提成规则")
-    @RequestMapping(value = "/save", method = RequestMethod.POST)
-    @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionLog:index')")
-    public ResponseObject saveHandler(HttpServletRequest request, @RequestBody CommissionRuleParam params) throws BusinessCheckException {
-        String token = request.getHeader("Access-Token");
-        String id = params.getId() == null ? "" : params.getId().toString();
-        String name = params.getName() == null ? "" : params.getName();
-        String description = params.getDescription() == null ? "" : params.getDescription();
-        String status = params.getStatus() == null ? "" : params.getStatus();
-
-        AccountInfo accountInfo = TokenUtil.getAccountInfoByToken(token);
-        if (accountInfo == null) {
-            return getFailureResult(1001, "请先登录");
-        }
-
-        MtCommissionRule info = new MtCommissionRule();
-        info.setName(name);
-        info.setDescription(description);
-        info.setOperator(accountInfo.getAccountName());
-        info.setStatus(status);
-        if (StringUtil.isNotEmpty(id)) {
-            info.setId(Integer.parseInt(id));
-            commissionRuleService.updateCommissionRule(params);
-        } else {
-            commissionRuleService.addCommissionRule(params);
-        }
-        return getSuccessResult(true);
-    }
-
-    /**
-     * 获取分销提成规则详情
+     * 获取分销提成记录详情
      *
      * @param  id
      * @return
      */
-    @ApiOperation(value = "获取分销提成规则详情")
+    @ApiOperation(value = "获取分销提成记录详情")
     @RequestMapping(value = "/info/{id}", method = RequestMethod.GET)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionLog:index')")
+    @PreAuthorize("@pms.hasPermission('commission:log:index')")
     public ResponseObject info(HttpServletRequest request, @PathVariable("id") Integer id) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         AccountInfo accountInfo = TokenUtil.getAccountInfoByToken(token);
@@ -199,9 +127,9 @@ public class BackendCommissionLogController extends BaseController {
             return getFailureResult(1001, "请先登录");
         }
 
-        CommissionRuleDto commissionRuleDto = commissionRuleService.queryCommissionRuleById(id);
+        CommissionLogDto commissionLog = commissionLogService.queryCommissionLogById(id);
         Map<String, Object> result = new HashMap<>();
-        result.put("commissionRule", commissionRuleDto);
+        result.put("commissionLog", commissionLog);
 
         return getSuccessResult(result);
     }

+ 4 - 4
fuint-application/src/main/java/com/fuint/module/backendApi/controller/BackendCommissionRuleController.java

@@ -57,7 +57,7 @@ public class BackendCommissionRuleController extends BaseController {
     @ApiOperation(value = "规则列表查询")
     @RequestMapping(value = "/list", method = RequestMethod.GET)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionRule:index')")
+    @PreAuthorize("@pms.hasPermission('commission:rule:index')")
     public ResponseObject list(HttpServletRequest request) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         Integer page = request.getParameter("page") == null ? Constants.PAGE_NUMBER : Integer.parseInt(request.getParameter("page"));
@@ -126,7 +126,7 @@ public class BackendCommissionRuleController extends BaseController {
     @ApiOperation(value = "更新分销提成规则状态")
     @RequestMapping(value = "/updateStatus", method = RequestMethod.POST)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionRule:index')")
+    @PreAuthorize("@pms.hasPermission('commission:rule:index')")
     public ResponseObject updateStatus(HttpServletRequest request, @RequestBody Map<String, Object> params) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         String status = params.get("status") != null ? params.get("status").toString() : StatusEnum.ENABLED.getKey();
@@ -162,7 +162,7 @@ public class BackendCommissionRuleController extends BaseController {
     @ApiOperation(value = "保存分销提成规则")
     @RequestMapping(value = "/save", method = RequestMethod.POST)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionRule:index')")
+    @PreAuthorize("@pms.hasPermission('commission:rule:index')")
     public ResponseObject saveHandler(HttpServletRequest request, @RequestBody CommissionRuleParam params) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         String id = params.getId() == null ? "" : params.getId().toString();
@@ -194,7 +194,7 @@ public class BackendCommissionRuleController extends BaseController {
     @ApiOperation(value = "获取分销提成规则详情")
     @RequestMapping(value = "/info/{id}", method = RequestMethod.GET)
     @CrossOrigin
-    @PreAuthorize("@pms.hasPermission('commissionRule:index')")
+    @PreAuthorize("@pms.hasPermission('commission:rule:index')")
     public ResponseObject info(HttpServletRequest request, @PathVariable("id") Integer id) throws BusinessCheckException {
         String token = request.getHeader("Access-Token");
         AccountInfo accountInfo = TokenUtil.getAccountInfoByToken(token);

+ 0 - 1
fuint-repository/src/main/java/com/fuint/repository/mapper/MtBalanceMapper.java

@@ -3,7 +3,6 @@ package com.fuint.repository.mapper;
 import com.fuint.repository.model.MtBalance;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Param;
-
 import java.util.List;
 
 /**