feats

src/main/java/com/yunzhi/marketing/borker/controller/BkAgentRuleController.java

+package com.yunzhi.marketing.borker.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.marketing.base.BaseController;
+import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.borker.entity.BkAgentRule;
+import com.yunzhi.marketing.borker.entity.BkAgreement;
+import com.yunzhi.marketing.borker.service.IBkAgentRuleService;
+import com.yunzhi.marketing.borker.service.IBkAgreementService;
+import com.yunzhi.marketing.common.CommConstant;
+import com.yunzhi.marketing.common.StringUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * <p>
+    * 经纪人规则 前端控制器
+    * </p>
+ *
+ * @author yansen
+ * @since 2022-07-26
+ */
+
+@Api(tags = "经纪人规则")
+@RestController
+@RequestMapping("/api")
+public class BkAgentRuleController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(BkAgentRuleController.class);
+
+    @Autowired
+    public IBkAgentRuleService iBkAgentRuleService;
+
+//
+//    /**
+//     * 分页查询列表
+//     * @param pageNum
+//     * @param pageSize
+//     * @return
+//     */
+//    @RequestMapping(value="/{client}/bkAgentRule",method= RequestMethod.GET)
+//    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
+//    public ResponseBean bkAgreementList(@ApiParam("客户端") @PathVariable String client,
+//                                        @ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+//                                        @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+//                                        @ApiParam("楼盘ID") @RequestParam(value ="buildingId", required = false) String buildingId,
+//                                        HttpServletRequest request) throws Exception {
+//
+//        IPage<BkAgreement> pg = new Page<>(pageNum, pageSize);
+//        QueryWrapper<BkAgreement> queryWrapper = new QueryWrapper<>();
+//        queryWrapper.eq("org_id", getOrgId(request));
+//        queryWrapper.eq(!StringUtils.isEmpty(buildingId), "building_id", buildingId);
+//        queryWrapper.gt("status", CommConstant.STATUS_DELETE);
+//        queryWrapper.orderByDesc("create_date");
+//
+//        IPage<BkAgreement> result = iBkAgreementService.page(pg, queryWrapper);
+//        return ResponseBean.success(result);
+//    }
+//
+    /**
+     * 保存对象
+     * @param bkAgreement 实体对象
+     * @return
+     */
+    @RequestMapping(value="/admin/bkAgentRule",method= RequestMethod.POST)
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
+    public ResponseBean bkAgreementAdd(@ApiParam("保存内容") @RequestBody BkAgentRule bkAgentRule,
+                                       HttpServletRequest request) throws Exception {
+        bkAgentRule.setOrgId(getOrgId(request));
+        if (StringUtils.isEmpty(bkAgentRule.getRuleId())) {
+            iBkAgentRuleService.save(bkAgentRule);
+        } else {
+            iBkAgentRuleService.updateById(bkAgentRule);
+        }
+        return ResponseBean.success(bkAgentRule);
+    }
+//
+//    /**
+//     * 根据id删除对象
+//     * @param id  实体ID
+//     */
+//    @RequestMapping(value="/admin/bkAgreement/{id}", method= RequestMethod.DELETE)
+//    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
+//    public ResponseBean bkAgreementDelete(@ApiParam("对象ID") @PathVariable String id,
+//                                          HttpServletRequest request) throws Exception{
+//
+//        BkAgreement bkAgreement = iBkAgreementService.getById(id);
+//        if (null == bkAgreement || CommConstant.STATUS_DELETE.equals(bkAgreement.getStatus())) {
+//            return ResponseBean.success("success");
+//        }
+//
+//        if (!bkAgreement.getOrgId().equals(getOrgId(request).toString())) {
+//            return ResponseBean.error("暂无权限", ResponseBean.ERROR_ILLEGAL_PARAMS);
+//        }
+//
+//        if(iBkAgreementService.removeById(id)){
+//            return ResponseBean.success("success");
+//        }else {
+//            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//    }
+//
+//    /**
+//     * 修改对象
+//     * @param id  实体ID
+//     * @param bkAgreement 实体对象
+//     * @return
+//     */
+//    @RequestMapping(value="/admin/bkAgreement/{id}",method= RequestMethod.PUT)
+//    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
+//    public ResponseBean bkAgreementUpdate(@ApiParam("对象ID") @PathVariable String id,
+//                                          @ApiParam("更新内容") @RequestBody BkAgreement bkAgreement,
+//                                          HttpServletRequest request) throws Exception {
+//
+//        if (StringUtils.isEmpty(bkAgreement.getBuildingId())) {
+//            return ResponseBean.error("未绑定楼盘", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//
+//        BkAgreement origin = iBkAgreementService.getById(id);
+//        if (CommConstant.STATUS_DELETE.equals(bkAgreement.getStatus())) {
+//            return ResponseBean.success("success");
+//        }
+//
+//        if (!getOrgId(request).toString().equals(bkAgreement.getOrgId())) {
+//            return ResponseBean.error("暂无权限", ResponseBean.ERROR_ILLEGAL_PARAMS);
+//        }
+//
+//        bkAgreement.setOrgId(origin.getOrgId());
+//        bkAgreement.setStatus(CommConstant.STATUS_NORMAL);
+//
+//        if (iBkAgreementService.updateById(bkAgreement)){
+//            return ResponseBean.success(iBkAgreementService.getById(id));
+//        }else {
+//            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//    }
+//
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/{client}/bkAgentRule",method= RequestMethod.GET)
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
+    public ResponseBean bkAgreementGet(@ApiParam("发布状态") @RequestParam(value ="status", required = false) Integer status,
+                                       HttpServletRequest request) throws Exception {
+        Integer orgId = getOrgId(request);
+        return ResponseBean.success(iBkAgentRuleService.getByOrgId(orgId, status));
+    }
+}

src/main/java/com/yunzhi/marketing/borker/entity/BkAgentRule.java

+package com.yunzhi.marketing.borker.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 佣金规则
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-07-26
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="BkAgentRule对象", description="经纪人规则")
+public class BkAgentRule implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "规则ID")
+    @TableId(value = "rule_id", type = IdType.UUID)
+    private String ruleId;
+
+    @ApiModelProperty(value = "规则内容")
+    private String content;
+
+    @ApiModelProperty(value = "机构ID")
+    private Integer orgId;
+
+    @ApiModelProperty(value = "状态")
+    private Integer status;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+}

src/main/java/com/yunzhi/marketing/borker/mapper/BkAgentRuleMapper.java

+package com.yunzhi.marketing.borker.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.marketing.borker.entity.BkAgentRule;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * <p>
+ * 佣金规则 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-07-26
+ */
+@Mapper
+public interface BkAgentRuleMapper extends BaseMapper<BkAgentRule> {
+
+    BkAgentRule getByOrgId(@Param("orgId") Integer orgId,
+                           @Param("status") Integer status);
+}

src/main/java/com/yunzhi/marketing/borker/service/IBkAgentRuleService.java

+package com.yunzhi.marketing.borker.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.marketing.borker.entity.BkAgentRule;
+
+/**
+ * <p>
+ * 经纪人规则 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-07-26
+ */
+public interface IBkAgentRuleService extends IService<BkAgentRule> {
+    BkAgentRule getByOrgId(Integer orgId, Integer status);
+}

src/main/java/com/yunzhi/marketing/borker/service/impl/BkAgentRuleServiceImpl.java

+package com.yunzhi.marketing.borker.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yunzhi.marketing.borker.entity.BkAgentRule;
+import com.yunzhi.marketing.borker.mapper.BkAgentRuleMapper;
+import com.yunzhi.marketing.borker.service.IBkAgentRuleService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 经纪人规则 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-07-26
+ */
+@Service
+public class BkAgentRuleServiceImpl extends ServiceImpl<BkAgentRuleMapper, BkAgentRule> implements IBkAgentRuleService {
+
+    @Override
+    public BkAgentRule getByOrgId(Integer orgId, Integer status) {
+        return baseMapper.getByOrgId(orgId, status);
+    }
+}

src/main/resources/mapper/BkAgentrRuleMapper.xml

+<?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.yunzhi.marketing.borker.mapper.BkAgentRuleMapper">
+
+    <select id="getByOrgId" resultType="com.yunzhi.marketing.borker.entity.BkAgentRule">
+        SELECT
+            *
+        FROM
+            bk_agent_rule t
+        WHERE
+            t.org_id = #{orgId}
+          <if test="status != null">
+              AND t.`status` = #{status}
+          </if>
+          AND t.`status` &gt; -1
+        ORDER BY
+            t.create_date DESC
+            LIMIT 1
+    </select>
+</mapper>