张延森 2 years ago
parent
commit
c9cd5802eb
36 changed files with 1253 additions and 34 deletions
  1. 1
    1
      pom.xml
  2. 119
    0
      src/main/java/com/yunzhi/marketing/borker/controller/BkAccountRecordController.java
  3. 119
    0
      src/main/java/com/yunzhi/marketing/borker/controller/BkAgreementController.java
  4. 119
    0
      src/main/java/com/yunzhi/marketing/borker/controller/BkBankCardController.java
  5. 119
    0
      src/main/java/com/yunzhi/marketing/borker/controller/BkFirstScreenController.java
  6. 119
    0
      src/main/java/com/yunzhi/marketing/borker/controller/BkNoticeController.java
  7. 64
    0
      src/main/java/com/yunzhi/marketing/borker/entity/BkAccountRecord.java
  8. 52
    0
      src/main/java/com/yunzhi/marketing/borker/entity/BkAgreement.java
  9. 58
    0
      src/main/java/com/yunzhi/marketing/borker/entity/BkBankCard.java
  10. 64
    0
      src/main/java/com/yunzhi/marketing/borker/entity/BkFirstScreen.java
  11. 58
    0
      src/main/java/com/yunzhi/marketing/borker/entity/BkNotice.java
  12. 18
    0
      src/main/java/com/yunzhi/marketing/borker/mapper/BkAccountRecordMapper.java
  13. 18
    0
      src/main/java/com/yunzhi/marketing/borker/mapper/BkAgreementMapper.java
  14. 18
    0
      src/main/java/com/yunzhi/marketing/borker/mapper/BkBankCardMapper.java
  15. 18
    0
      src/main/java/com/yunzhi/marketing/borker/mapper/BkFirstScreenMapper.java
  16. 18
    0
      src/main/java/com/yunzhi/marketing/borker/mapper/BkNoticeMapper.java
  17. 16
    0
      src/main/java/com/yunzhi/marketing/borker/service/IBkAccountRecordService.java
  18. 16
    0
      src/main/java/com/yunzhi/marketing/borker/service/IBkAgreementService.java
  19. 16
    0
      src/main/java/com/yunzhi/marketing/borker/service/IBkBankCardService.java
  20. 16
    0
      src/main/java/com/yunzhi/marketing/borker/service/IBkFirstScreenService.java
  21. 16
    0
      src/main/java/com/yunzhi/marketing/borker/service/IBkNoticeService.java
  22. 20
    0
      src/main/java/com/yunzhi/marketing/borker/service/impl/BkAccountRecordServiceImpl.java
  23. 20
    0
      src/main/java/com/yunzhi/marketing/borker/service/impl/BkAgreementServiceImpl.java
  24. 20
    0
      src/main/java/com/yunzhi/marketing/borker/service/impl/BkBankCardServiceImpl.java
  25. 20
    0
      src/main/java/com/yunzhi/marketing/borker/service/impl/BkFirstScreenServiceImpl.java
  26. 20
    0
      src/main/java/com/yunzhi/marketing/borker/service/impl/BkNoticeServiceImpl.java
  27. 8
    0
      src/main/java/com/yunzhi/marketing/common/WxUtils.java
  28. 35
    32
      src/main/java/com/yunzhi/marketing/service/impl/MiniAppServiceImpl.java
  29. 7
    0
      src/main/resources/application-dev.yml
  30. 8
    1
      src/main/resources/application-prod.yml
  31. 8
    0
      src/main/resources/application-test.yml
  32. 5
    0
      src/main/resources/mapper/BkAccountRecordMapper.xml
  33. 5
    0
      src/main/resources/mapper/BkAgreementMapper.xml
  34. 5
    0
      src/main/resources/mapper/BkBankCardMapper.xml
  35. 5
    0
      src/main/resources/mapper/BkFirstScreenMapper.xml
  36. 5
    0
      src/main/resources/mapper/BkNoticeMapper.xml

+ 1
- 1
pom.xml View File

@@ -57,7 +57,7 @@
57 57
 		<dependency>
58 58
 			<groupId>com.github.binarywang</groupId>
59 59
 			<artifactId>weixin-java-miniapp</artifactId>
60
-			<version>3.8.0</version>
60
+			<version>4.3.0</version>
61 61
 		</dependency>
62 62
 		<dependency>
63 63
 			<groupId>com.github.binarywang</groupId>

+ 119
- 0
src/main/java/com/yunzhi/marketing/borker/controller/BkAccountRecordController.java View File

@@ -0,0 +1,119 @@
1
+package com.yunzhi.marketing.borker.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yunzhi.marketing.base.BaseController;
7
+import com.yunzhi.marketing.base.ResponseBean;
8
+import io.swagger.annotations.Api;
9
+import io.swagger.annotations.ApiOperation;
10
+import io.swagger.annotations.ApiParam;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.PathVariable;
15
+import org.springframework.web.bind.annotation.RequestBody;
16
+import org.springframework.web.bind.annotation.RequestMapping;
17
+import org.springframework.web.bind.annotation.RequestMethod;
18
+import org.springframework.web.bind.annotation.RequestParam;
19
+import com.yunzhi.marketing.borker.service.IBkAccountRecordService;
20
+import com.yunzhi.marketing.borker.entity.BkAccountRecord;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 经纪人佣金流水 前端控制器
26
+    * </p>
27
+ *
28
+ * @author yansen
29
+ * @since 2022-07-26
30
+ */
31
+
32
+@Api(tags = "经纪人佣金流水")
33
+@RestController
34
+@RequestMapping("/")
35
+public class BkAccountRecordController extends BaseController {
36
+
37
+    private final Logger logger = LoggerFactory.getLogger(BkAccountRecordController.class);
38
+
39
+    @Autowired
40
+    public IBkAccountRecordService iBkAccountRecordService;
41
+
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/bkAccountRecord",method= RequestMethod.GET)
50
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
51
+    public ResponseBean bkAccountRecordList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
52
+									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
53
+
54
+		    IPage<BkAccountRecord> pg = new Page<>(pageNum, pageSize);
55
+            QueryWrapper<BkAccountRecord> queryWrapper = new QueryWrapper<>();
56
+            queryWrapper.orderByDesc("create_date");
57
+
58
+            IPage<BkAccountRecord> result = iBkAccountRecordService.page(pg, queryWrapper);
59
+            return ResponseBean.success(result);
60
+    }
61
+
62
+    /**
63
+     * 保存对象
64
+     * @param bkAccountRecord 实体对象
65
+     * @return
66
+     */
67
+    @RequestMapping(value="/bkAccountRecord",method= RequestMethod.POST)
68
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
69
+    public ResponseBean bkAccountRecordAdd(@ApiParam("保存内容") @RequestBody BkAccountRecord bkAccountRecord) throws Exception{
70
+
71
+        if (iBkAccountRecordService.save(bkAccountRecord)){
72
+            return ResponseBean.success(bkAccountRecord);
73
+        }else {
74
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
75
+        }
76
+    }
77
+
78
+    /**
79
+     * 根据id删除对象
80
+     * @param id  实体ID
81
+     */
82
+    @RequestMapping(value="/bkAccountRecord/{id}", method= RequestMethod.DELETE)
83
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
84
+    public ResponseBean bkAccountRecordDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
85
+        if(iBkAccountRecordService.removeById(id)){
86
+            return ResponseBean.success("success");
87
+        }else {
88
+            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
89
+        }
90
+    }
91
+
92
+    /**
93
+     * 修改对象
94
+     * @param id  实体ID
95
+     * @param bkAccountRecord 实体对象
96
+     * @return
97
+     */
98
+    @RequestMapping(value="/bkAccountRecord/{id}",method= RequestMethod.PUT)
99
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
100
+    public ResponseBean bkAccountRecordUpdate(@ApiParam("对象ID") @PathVariable Integer id,
101
+                                        @ApiParam("更新内容") @RequestBody BkAccountRecord bkAccountRecord) throws Exception{
102
+
103
+        if (iBkAccountRecordService.updateById(bkAccountRecord)){
104
+            return ResponseBean.success(iBkAccountRecordService.getById(id));
105
+        }else {
106
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
107
+        }
108
+    }
109
+
110
+    /**
111
+     * 根据id查询对象
112
+     * @param id  实体ID
113
+     */
114
+    @RequestMapping(value="/bkAccountRecord/{id}",method= RequestMethod.GET)
115
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
116
+    public ResponseBean bkAccountRecordGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
117
+        return ResponseBean.success(iBkAccountRecordService.getById(id));
118
+    }
119
+}

+ 119
- 0
src/main/java/com/yunzhi/marketing/borker/controller/BkAgreementController.java View File

@@ -0,0 +1,119 @@
1
+package com.yunzhi.marketing.borker.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yunzhi.marketing.base.BaseController;
7
+import com.yunzhi.marketing.base.ResponseBean;
8
+import io.swagger.annotations.Api;
9
+import io.swagger.annotations.ApiOperation;
10
+import io.swagger.annotations.ApiParam;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.PathVariable;
15
+import org.springframework.web.bind.annotation.RequestBody;
16
+import org.springframework.web.bind.annotation.RequestMapping;
17
+import org.springframework.web.bind.annotation.RequestMethod;
18
+import org.springframework.web.bind.annotation.RequestParam;
19
+import com.yunzhi.marketing.borker.service.IBkAgreementService;
20
+import com.yunzhi.marketing.borker.entity.BkAgreement;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 佣金规则 前端控制器
26
+    * </p>
27
+ *
28
+ * @author yansen
29
+ * @since 2022-07-26
30
+ */
31
+
32
+@Api(tags = "佣金规则")
33
+@RestController
34
+@RequestMapping("/")
35
+public class BkAgreementController extends BaseController {
36
+
37
+    private final Logger logger = LoggerFactory.getLogger(BkAgreementController.class);
38
+
39
+    @Autowired
40
+    public IBkAgreementService iBkAgreementService;
41
+
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/bkAgreement",method= RequestMethod.GET)
50
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
51
+    public ResponseBean bkAgreementList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
52
+									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
53
+
54
+		    IPage<BkAgreement> pg = new Page<>(pageNum, pageSize);
55
+            QueryWrapper<BkAgreement> queryWrapper = new QueryWrapper<>();
56
+            queryWrapper.orderByDesc("create_date");
57
+
58
+            IPage<BkAgreement> result = iBkAgreementService.page(pg, queryWrapper);
59
+            return ResponseBean.success(result);
60
+    }
61
+
62
+    /**
63
+     * 保存对象
64
+     * @param bkAgreement 实体对象
65
+     * @return
66
+     */
67
+    @RequestMapping(value="/bkAgreement",method= RequestMethod.POST)
68
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
69
+    public ResponseBean bkAgreementAdd(@ApiParam("保存内容") @RequestBody BkAgreement bkAgreement) throws Exception{
70
+
71
+        if (iBkAgreementService.save(bkAgreement)){
72
+            return ResponseBean.success(bkAgreement);
73
+        }else {
74
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
75
+        }
76
+    }
77
+
78
+    /**
79
+     * 根据id删除对象
80
+     * @param id  实体ID
81
+     */
82
+    @RequestMapping(value="/bkAgreement/{id}", method= RequestMethod.DELETE)
83
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
84
+    public ResponseBean bkAgreementDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
85
+        if(iBkAgreementService.removeById(id)){
86
+            return ResponseBean.success("success");
87
+        }else {
88
+            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
89
+        }
90
+    }
91
+
92
+    /**
93
+     * 修改对象
94
+     * @param id  实体ID
95
+     * @param bkAgreement 实体对象
96
+     * @return
97
+     */
98
+    @RequestMapping(value="/bkAgreement/{id}",method= RequestMethod.PUT)
99
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
100
+    public ResponseBean bkAgreementUpdate(@ApiParam("对象ID") @PathVariable Integer id,
101
+                                        @ApiParam("更新内容") @RequestBody BkAgreement bkAgreement) throws Exception{
102
+
103
+        if (iBkAgreementService.updateById(bkAgreement)){
104
+            return ResponseBean.success(iBkAgreementService.getById(id));
105
+        }else {
106
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
107
+        }
108
+    }
109
+
110
+    /**
111
+     * 根据id查询对象
112
+     * @param id  实体ID
113
+     */
114
+    @RequestMapping(value="/bkAgreement/{id}",method= RequestMethod.GET)
115
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
116
+    public ResponseBean bkAgreementGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
117
+        return ResponseBean.success(iBkAgreementService.getById(id));
118
+    }
119
+}

+ 119
- 0
src/main/java/com/yunzhi/marketing/borker/controller/BkBankCardController.java View File

@@ -0,0 +1,119 @@
1
+package com.yunzhi.marketing.borker.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yunzhi.marketing.base.BaseController;
7
+import com.yunzhi.marketing.base.ResponseBean;
8
+import io.swagger.annotations.Api;
9
+import io.swagger.annotations.ApiOperation;
10
+import io.swagger.annotations.ApiParam;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.PathVariable;
15
+import org.springframework.web.bind.annotation.RequestBody;
16
+import org.springframework.web.bind.annotation.RequestMapping;
17
+import org.springframework.web.bind.annotation.RequestMethod;
18
+import org.springframework.web.bind.annotation.RequestParam;
19
+import com.yunzhi.marketing.borker.service.IBkBankCardService;
20
+import com.yunzhi.marketing.borker.entity.BkBankCard;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 经纪人银行卡信息 前端控制器
26
+    * </p>
27
+ *
28
+ * @author yansen
29
+ * @since 2022-07-26
30
+ */
31
+
32
+@Api(tags = "经纪人银行卡信息")
33
+@RestController
34
+@RequestMapping("/")
35
+public class BkBankCardController extends BaseController {
36
+
37
+    private final Logger logger = LoggerFactory.getLogger(BkBankCardController.class);
38
+
39
+    @Autowired
40
+    public IBkBankCardService iBkBankCardService;
41
+
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/bkBankCard",method= RequestMethod.GET)
50
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
51
+    public ResponseBean bkBankCardList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
52
+									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
53
+
54
+		    IPage<BkBankCard> pg = new Page<>(pageNum, pageSize);
55
+            QueryWrapper<BkBankCard> queryWrapper = new QueryWrapper<>();
56
+            queryWrapper.orderByDesc("create_date");
57
+
58
+            IPage<BkBankCard> result = iBkBankCardService.page(pg, queryWrapper);
59
+            return ResponseBean.success(result);
60
+    }
61
+
62
+    /**
63
+     * 保存对象
64
+     * @param bkBankCard 实体对象
65
+     * @return
66
+     */
67
+    @RequestMapping(value="/bkBankCard",method= RequestMethod.POST)
68
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
69
+    public ResponseBean bkBankCardAdd(@ApiParam("保存内容") @RequestBody BkBankCard bkBankCard) throws Exception{
70
+
71
+        if (iBkBankCardService.save(bkBankCard)){
72
+            return ResponseBean.success(bkBankCard);
73
+        }else {
74
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
75
+        }
76
+    }
77
+
78
+    /**
79
+     * 根据id删除对象
80
+     * @param id  实体ID
81
+     */
82
+    @RequestMapping(value="/bkBankCard/{id}", method= RequestMethod.DELETE)
83
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
84
+    public ResponseBean bkBankCardDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
85
+        if(iBkBankCardService.removeById(id)){
86
+            return ResponseBean.success("success");
87
+        }else {
88
+            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
89
+        }
90
+    }
91
+
92
+    /**
93
+     * 修改对象
94
+     * @param id  实体ID
95
+     * @param bkBankCard 实体对象
96
+     * @return
97
+     */
98
+    @RequestMapping(value="/bkBankCard/{id}",method= RequestMethod.PUT)
99
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
100
+    public ResponseBean bkBankCardUpdate(@ApiParam("对象ID") @PathVariable Integer id,
101
+                                        @ApiParam("更新内容") @RequestBody BkBankCard bkBankCard) throws Exception{
102
+
103
+        if (iBkBankCardService.updateById(bkBankCard)){
104
+            return ResponseBean.success(iBkBankCardService.getById(id));
105
+        }else {
106
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
107
+        }
108
+    }
109
+
110
+    /**
111
+     * 根据id查询对象
112
+     * @param id  实体ID
113
+     */
114
+    @RequestMapping(value="/bkBankCard/{id}",method= RequestMethod.GET)
115
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
116
+    public ResponseBean bkBankCardGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
117
+        return ResponseBean.success(iBkBankCardService.getById(id));
118
+    }
119
+}

+ 119
- 0
src/main/java/com/yunzhi/marketing/borker/controller/BkFirstScreenController.java View File

@@ -0,0 +1,119 @@
1
+package com.yunzhi.marketing.borker.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yunzhi.marketing.base.BaseController;
7
+import com.yunzhi.marketing.base.ResponseBean;
8
+import io.swagger.annotations.Api;
9
+import io.swagger.annotations.ApiOperation;
10
+import io.swagger.annotations.ApiParam;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.PathVariable;
15
+import org.springframework.web.bind.annotation.RequestBody;
16
+import org.springframework.web.bind.annotation.RequestMapping;
17
+import org.springframework.web.bind.annotation.RequestMethod;
18
+import org.springframework.web.bind.annotation.RequestParam;
19
+import com.yunzhi.marketing.borker.service.IBkFirstScreenService;
20
+import com.yunzhi.marketing.borker.entity.BkFirstScreen;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 经纪人首屏广告 前端控制器
26
+    * </p>
27
+ *
28
+ * @author yansen
29
+ * @since 2022-07-26
30
+ */
31
+
32
+@Api(tags = "经纪人首屏广告")
33
+@RestController
34
+@RequestMapping("/")
35
+public class BkFirstScreenController extends BaseController {
36
+
37
+    private final Logger logger = LoggerFactory.getLogger(BkFirstScreenController.class);
38
+
39
+    @Autowired
40
+    public IBkFirstScreenService iBkFirstScreenService;
41
+
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/bkFirstScreen",method= RequestMethod.GET)
50
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
51
+    public ResponseBean bkFirstScreenList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
52
+									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
53
+
54
+		    IPage<BkFirstScreen> pg = new Page<>(pageNum, pageSize);
55
+            QueryWrapper<BkFirstScreen> queryWrapper = new QueryWrapper<>();
56
+            queryWrapper.orderByDesc("create_date");
57
+
58
+            IPage<BkFirstScreen> result = iBkFirstScreenService.page(pg, queryWrapper);
59
+            return ResponseBean.success(result);
60
+    }
61
+
62
+    /**
63
+     * 保存对象
64
+     * @param bkFirstScreen 实体对象
65
+     * @return
66
+     */
67
+    @RequestMapping(value="/bkFirstScreen",method= RequestMethod.POST)
68
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
69
+    public ResponseBean bkFirstScreenAdd(@ApiParam("保存内容") @RequestBody BkFirstScreen bkFirstScreen) throws Exception{
70
+
71
+        if (iBkFirstScreenService.save(bkFirstScreen)){
72
+            return ResponseBean.success(bkFirstScreen);
73
+        }else {
74
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
75
+        }
76
+    }
77
+
78
+    /**
79
+     * 根据id删除对象
80
+     * @param id  实体ID
81
+     */
82
+    @RequestMapping(value="/bkFirstScreen/{id}", method= RequestMethod.DELETE)
83
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
84
+    public ResponseBean bkFirstScreenDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
85
+        if(iBkFirstScreenService.removeById(id)){
86
+            return ResponseBean.success("success");
87
+        }else {
88
+            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
89
+        }
90
+    }
91
+
92
+    /**
93
+     * 修改对象
94
+     * @param id  实体ID
95
+     * @param bkFirstScreen 实体对象
96
+     * @return
97
+     */
98
+    @RequestMapping(value="/bkFirstScreen/{id}",method= RequestMethod.PUT)
99
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
100
+    public ResponseBean bkFirstScreenUpdate(@ApiParam("对象ID") @PathVariable Integer id,
101
+                                        @ApiParam("更新内容") @RequestBody BkFirstScreen bkFirstScreen) throws Exception{
102
+
103
+        if (iBkFirstScreenService.updateById(bkFirstScreen)){
104
+            return ResponseBean.success(iBkFirstScreenService.getById(id));
105
+        }else {
106
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
107
+        }
108
+    }
109
+
110
+    /**
111
+     * 根据id查询对象
112
+     * @param id  实体ID
113
+     */
114
+    @RequestMapping(value="/bkFirstScreen/{id}",method= RequestMethod.GET)
115
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
116
+    public ResponseBean bkFirstScreenGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
117
+        return ResponseBean.success(iBkFirstScreenService.getById(id));
118
+    }
119
+}

+ 119
- 0
src/main/java/com/yunzhi/marketing/borker/controller/BkNoticeController.java View File

@@ -0,0 +1,119 @@
1
+package com.yunzhi.marketing.borker.controller;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yunzhi.marketing.base.BaseController;
7
+import com.yunzhi.marketing.base.ResponseBean;
8
+import io.swagger.annotations.Api;
9
+import io.swagger.annotations.ApiOperation;
10
+import io.swagger.annotations.ApiParam;
11
+import org.slf4j.Logger;
12
+import org.slf4j.LoggerFactory;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.PathVariable;
15
+import org.springframework.web.bind.annotation.RequestBody;
16
+import org.springframework.web.bind.annotation.RequestMapping;
17
+import org.springframework.web.bind.annotation.RequestMethod;
18
+import org.springframework.web.bind.annotation.RequestParam;
19
+import com.yunzhi.marketing.borker.service.IBkNoticeService;
20
+import com.yunzhi.marketing.borker.entity.BkNotice;
21
+import org.springframework.web.bind.annotation.RestController;
22
+
23
+/**
24
+ * <p>
25
+    * 通知公告 前端控制器
26
+    * </p>
27
+ *
28
+ * @author yansen
29
+ * @since 2022-07-26
30
+ */
31
+
32
+@Api(tags = "通知公告")
33
+@RestController
34
+@RequestMapping("/")
35
+public class BkNoticeController extends BaseController {
36
+
37
+    private final Logger logger = LoggerFactory.getLogger(BkNoticeController.class);
38
+
39
+    @Autowired
40
+    public IBkNoticeService iBkNoticeService;
41
+
42
+
43
+    /**
44
+     * 分页查询列表
45
+     * @param pageNum
46
+     * @param pageSize
47
+     * @return
48
+     */
49
+    @RequestMapping(value="/bkNotice",method= RequestMethod.GET)
50
+    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
51
+    public ResponseBean bkNoticeList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
52
+									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
53
+
54
+		    IPage<BkNotice> pg = new Page<>(pageNum, pageSize);
55
+            QueryWrapper<BkNotice> queryWrapper = new QueryWrapper<>();
56
+            queryWrapper.orderByDesc("create_date");
57
+
58
+            IPage<BkNotice> result = iBkNoticeService.page(pg, queryWrapper);
59
+            return ResponseBean.success(result);
60
+    }
61
+
62
+    /**
63
+     * 保存对象
64
+     * @param bkNotice 实体对象
65
+     * @return
66
+     */
67
+    @RequestMapping(value="/bkNotice",method= RequestMethod.POST)
68
+    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
69
+    public ResponseBean bkNoticeAdd(@ApiParam("保存内容") @RequestBody BkNotice bkNotice) throws Exception{
70
+
71
+        if (iBkNoticeService.save(bkNotice)){
72
+            return ResponseBean.success(bkNotice);
73
+        }else {
74
+            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
75
+        }
76
+    }
77
+
78
+    /**
79
+     * 根据id删除对象
80
+     * @param id  实体ID
81
+     */
82
+    @RequestMapping(value="/bkNotice/{id}", method= RequestMethod.DELETE)
83
+    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
84
+    public ResponseBean bkNoticeDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
85
+        if(iBkNoticeService.removeById(id)){
86
+            return ResponseBean.success("success");
87
+        }else {
88
+            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
89
+        }
90
+    }
91
+
92
+    /**
93
+     * 修改对象
94
+     * @param id  实体ID
95
+     * @param bkNotice 实体对象
96
+     * @return
97
+     */
98
+    @RequestMapping(value="/bkNotice/{id}",method= RequestMethod.PUT)
99
+    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
100
+    public ResponseBean bkNoticeUpdate(@ApiParam("对象ID") @PathVariable Integer id,
101
+                                        @ApiParam("更新内容") @RequestBody BkNotice bkNotice) throws Exception{
102
+
103
+        if (iBkNoticeService.updateById(bkNotice)){
104
+            return ResponseBean.success(iBkNoticeService.getById(id));
105
+        }else {
106
+            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
107
+        }
108
+    }
109
+
110
+    /**
111
+     * 根据id查询对象
112
+     * @param id  实体ID
113
+     */
114
+    @RequestMapping(value="/bkNotice/{id}",method= RequestMethod.GET)
115
+    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
116
+    public ResponseBean bkNoticeGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
117
+        return ResponseBean.success(iBkNoticeService.getById(id));
118
+    }
119
+}

+ 64
- 0
src/main/java/com/yunzhi/marketing/borker/entity/BkAccountRecord.java View File

@@ -0,0 +1,64 @@
1
+package com.yunzhi.marketing.borker.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import java.time.LocalDateTime;
5
+import com.baomidou.mybatisplus.annotation.TableId;
6
+import java.io.Serializable;
7
+import io.swagger.annotations.ApiModel;
8
+import io.swagger.annotations.ApiModelProperty;
9
+import lombok.Data;
10
+import lombok.EqualsAndHashCode;
11
+import lombok.experimental.Accessors;
12
+
13
+/**
14
+ * <p>
15
+ * 经纪人佣金流水
16
+ * </p>
17
+ *
18
+ * @author yansen
19
+ * @since 2022-07-26
20
+ */
21
+@Data
22
+@EqualsAndHashCode(callSuper = false)
23
+@Accessors(chain = true)
24
+@ApiModel(value="BkAccountRecord对象", description="经纪人佣金流水")
25
+public class BkAccountRecord implements Serializable {
26
+
27
+    private static final long serialVersionUID = 1L;
28
+
29
+    @ApiModelProperty(value = "流水ID")
30
+    @TableId(value = "rec_id", type = IdType.INPUT)
31
+    private String recId;
32
+
33
+    @ApiModelProperty(value = "报备ID")
34
+    private String channelCustomerId;
35
+
36
+    @ApiModelProperty(value = "人员ID")
37
+    private String personId;
38
+
39
+    @ApiModelProperty(value = "楼盘ID")
40
+    private String buildingId;
41
+
42
+    @ApiModelProperty(value = "楼盘名称")
43
+    private String builidngName;
44
+
45
+    @ApiModelProperty(value = "佣金;单位分")
46
+    private Integer charges;
47
+
48
+    @ApiModelProperty(value = "收支类型;1收,-1支")
49
+    private Integer chargeType;
50
+
51
+    @ApiModelProperty(value = "费用说明;到访,签约等")
52
+    private String chargeDesc;
53
+
54
+    @ApiModelProperty(value = "费用代码")
55
+    private String chargeCode;
56
+
57
+    @ApiModelProperty(value = "状态")
58
+    private Integer status;
59
+
60
+    @ApiModelProperty(value = "创建时间")
61
+    private LocalDateTime createDate;
62
+
63
+
64
+}

+ 52
- 0
src/main/java/com/yunzhi/marketing/borker/entity/BkAgreement.java View File

@@ -0,0 +1,52 @@
1
+package com.yunzhi.marketing.borker.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import java.time.LocalDateTime;
5
+import com.baomidou.mybatisplus.annotation.TableId;
6
+import java.io.Serializable;
7
+import io.swagger.annotations.ApiModel;
8
+import io.swagger.annotations.ApiModelProperty;
9
+import lombok.Data;
10
+import lombok.EqualsAndHashCode;
11
+import lombok.experimental.Accessors;
12
+
13
+/**
14
+ * <p>
15
+ * 佣金规则
16
+ * </p>
17
+ *
18
+ * @author yansen
19
+ * @since 2022-07-26
20
+ */
21
+@Data
22
+@EqualsAndHashCode(callSuper = false)
23
+@Accessors(chain = true)
24
+@ApiModel(value="BkAgreement对象", description="佣金规则")
25
+public class BkAgreement implements Serializable {
26
+
27
+    private static final long serialVersionUID = 1L;
28
+
29
+    @ApiModelProperty(value = "规则ID")
30
+    @TableId(value = "rule_id", type = IdType.INPUT)
31
+    private String ruleId;
32
+
33
+    @ApiModelProperty(value = "规则内容")
34
+    private String content;
35
+
36
+    @ApiModelProperty(value = "城市")
37
+    private String cityId;
38
+
39
+    @ApiModelProperty(value = "机构ID")
40
+    private String orgId;
41
+
42
+    @ApiModelProperty(value = "机构code")
43
+    private String institutionId;
44
+
45
+    @ApiModelProperty(value = "状态")
46
+    private Integer status;
47
+
48
+    @ApiModelProperty(value = "创建时间")
49
+    private LocalDateTime createDate;
50
+
51
+
52
+}

+ 58
- 0
src/main/java/com/yunzhi/marketing/borker/entity/BkBankCard.java View File

@@ -0,0 +1,58 @@
1
+package com.yunzhi.marketing.borker.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import com.baomidou.mybatisplus.annotation.TableId;
5
+import java.time.LocalDateTime;
6
+import java.io.Serializable;
7
+import io.swagger.annotations.ApiModel;
8
+import io.swagger.annotations.ApiModelProperty;
9
+import lombok.Data;
10
+import lombok.EqualsAndHashCode;
11
+import lombok.experimental.Accessors;
12
+
13
+/**
14
+ * <p>
15
+ * 经纪人银行卡信息
16
+ * </p>
17
+ *
18
+ * @author yansen
19
+ * @since 2022-07-26
20
+ */
21
+@Data
22
+@EqualsAndHashCode(callSuper = false)
23
+@Accessors(chain = true)
24
+@ApiModel(value="BkBankCard对象", description="经纪人银行卡信息")
25
+public class BkBankCard implements Serializable {
26
+
27
+    private static final long serialVersionUID = 1L;
28
+
29
+    @ApiModelProperty(value = "主键ID")
30
+    @TableId(value = "card_id", type = IdType.AUTO)
31
+    private Integer cardId;
32
+
33
+    @ApiModelProperty(value = "所属人")
34
+    private String personId;
35
+
36
+    @ApiModelProperty(value = "持卡人姓名")
37
+    private String ownerName;
38
+
39
+    @ApiModelProperty(value = "银行名称")
40
+    private String bankName;
41
+
42
+    @ApiModelProperty(value = "银行卡号")
43
+    private String cardNo;
44
+
45
+    @ApiModelProperty(value = "银行卡正面")
46
+    private String cardImg;
47
+
48
+    @ApiModelProperty(value = "设为默认")
49
+    private Integer isDefault;
50
+
51
+    @ApiModelProperty(value = "状态")
52
+    private Integer status;
53
+
54
+    @ApiModelProperty(value = "创建时间")
55
+    private LocalDateTime createDate;
56
+
57
+
58
+}

+ 64
- 0
src/main/java/com/yunzhi/marketing/borker/entity/BkFirstScreen.java View File

@@ -0,0 +1,64 @@
1
+package com.yunzhi.marketing.borker.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import java.time.LocalDateTime;
5
+import com.baomidou.mybatisplus.annotation.TableId;
6
+import java.io.Serializable;
7
+import io.swagger.annotations.ApiModel;
8
+import io.swagger.annotations.ApiModelProperty;
9
+import lombok.Data;
10
+import lombok.EqualsAndHashCode;
11
+import lombok.experimental.Accessors;
12
+
13
+/**
14
+ * <p>
15
+ * 经纪人首屏广告
16
+ * </p>
17
+ *
18
+ * @author yansen
19
+ * @since 2022-07-26
20
+ */
21
+@Data
22
+@EqualsAndHashCode(callSuper = false)
23
+@Accessors(chain = true)
24
+@ApiModel(value="BkFirstScreen对象", description="经纪人首屏广告")
25
+public class BkFirstScreen implements Serializable {
26
+
27
+    private static final long serialVersionUID = 1L;
28
+
29
+    @ApiModelProperty(value = "ID")
30
+    @TableId(value = "screen_id", type = IdType.INPUT)
31
+    private String screenId;
32
+
33
+    @ApiModelProperty(value = "显示类型")
34
+    private String showType;
35
+
36
+    @ApiModelProperty(value = "图片")
37
+    private String imageUrl;
38
+
39
+    @ApiModelProperty(value = "内容")
40
+    private String content;
41
+
42
+    @ApiModelProperty(value = "链接页面")
43
+    private String linkPage;
44
+
45
+    @ApiModelProperty(value = "页面参数")
46
+    private String pageParam;
47
+
48
+    @ApiModelProperty(value = "城市")
49
+    private String cityId;
50
+
51
+    @ApiModelProperty(value = "机构ID")
52
+    private String orgId;
53
+
54
+    @ApiModelProperty(value = "机构code")
55
+    private String institutionId;
56
+
57
+    @ApiModelProperty(value = "状态")
58
+    private Integer status;
59
+
60
+    @ApiModelProperty(value = "创建时间")
61
+    private LocalDateTime createDate;
62
+
63
+
64
+}

+ 58
- 0
src/main/java/com/yunzhi/marketing/borker/entity/BkNotice.java View File

@@ -0,0 +1,58 @@
1
+package com.yunzhi.marketing.borker.entity;
2
+
3
+import com.baomidou.mybatisplus.annotation.IdType;
4
+import java.time.LocalDateTime;
5
+import com.baomidou.mybatisplus.annotation.TableId;
6
+import java.io.Serializable;
7
+import io.swagger.annotations.ApiModel;
8
+import io.swagger.annotations.ApiModelProperty;
9
+import lombok.Data;
10
+import lombok.EqualsAndHashCode;
11
+import lombok.experimental.Accessors;
12
+
13
+/**
14
+ * <p>
15
+ * 通知公告
16
+ * </p>
17
+ *
18
+ * @author yansen
19
+ * @since 2022-07-26
20
+ */
21
+@Data
22
+@EqualsAndHashCode(callSuper = false)
23
+@Accessors(chain = true)
24
+@ApiModel(value="BkNotice对象", description="通知公告")
25
+public class BkNotice implements Serializable {
26
+
27
+    private static final long serialVersionUID = 1L;
28
+
29
+    @ApiModelProperty(value = "公告ID")
30
+    @TableId(value = "notice_id", type = IdType.INPUT)
31
+    private String noticeId;
32
+
33
+    @ApiModelProperty(value = "楼盘ID")
34
+    private String buildingId;
35
+
36
+    @ApiModelProperty(value = "楼盘名称")
37
+    private String builidngName;
38
+
39
+    @ApiModelProperty(value = "公告内容")
40
+    private String content;
41
+
42
+    @ApiModelProperty(value = "城市")
43
+    private String cityId;
44
+
45
+    @ApiModelProperty(value = "机构ID")
46
+    private String orgId;
47
+
48
+    @ApiModelProperty(value = "机构code")
49
+    private String institutionId;
50
+
51
+    @ApiModelProperty(value = "状态")
52
+    private Integer status;
53
+
54
+    @ApiModelProperty(value = "创建时间")
55
+    private LocalDateTime createDate;
56
+
57
+
58
+}

+ 18
- 0
src/main/java/com/yunzhi/marketing/borker/mapper/BkAccountRecordMapper.java View File

@@ -0,0 +1,18 @@
1
+package com.yunzhi.marketing.borker.mapper;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAccountRecord;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 经纪人佣金流水 Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author yansen
13
+ * @since 2022-07-26
14
+ */
15
+@Mapper
16
+public interface BkAccountRecordMapper extends BaseMapper<BkAccountRecord> {
17
+
18
+}

+ 18
- 0
src/main/java/com/yunzhi/marketing/borker/mapper/BkAgreementMapper.java View File

@@ -0,0 +1,18 @@
1
+package com.yunzhi.marketing.borker.mapper;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAgreement;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 佣金规则 Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author yansen
13
+ * @since 2022-07-26
14
+ */
15
+@Mapper
16
+public interface BkAgreementMapper extends BaseMapper<BkAgreement> {
17
+
18
+}

+ 18
- 0
src/main/java/com/yunzhi/marketing/borker/mapper/BkBankCardMapper.java View File

@@ -0,0 +1,18 @@
1
+package com.yunzhi.marketing.borker.mapper;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkBankCard;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 经纪人银行卡信息 Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author yansen
13
+ * @since 2022-07-26
14
+ */
15
+@Mapper
16
+public interface BkBankCardMapper extends BaseMapper<BkBankCard> {
17
+
18
+}

+ 18
- 0
src/main/java/com/yunzhi/marketing/borker/mapper/BkFirstScreenMapper.java View File

@@ -0,0 +1,18 @@
1
+package com.yunzhi.marketing.borker.mapper;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkFirstScreen;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 经纪人首屏广告 Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author yansen
13
+ * @since 2022-07-26
14
+ */
15
+@Mapper
16
+public interface BkFirstScreenMapper extends BaseMapper<BkFirstScreen> {
17
+
18
+}

+ 18
- 0
src/main/java/com/yunzhi/marketing/borker/mapper/BkNoticeMapper.java View File

@@ -0,0 +1,18 @@
1
+package com.yunzhi.marketing.borker.mapper;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkNotice;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+import org.apache.ibatis.annotations.Mapper;
6
+
7
+/**
8
+ * <p>
9
+ * 通知公告 Mapper 接口
10
+ * </p>
11
+ *
12
+ * @author yansen
13
+ * @since 2022-07-26
14
+ */
15
+@Mapper
16
+public interface BkNoticeMapper extends BaseMapper<BkNotice> {
17
+
18
+}

+ 16
- 0
src/main/java/com/yunzhi/marketing/borker/service/IBkAccountRecordService.java View File

@@ -0,0 +1,16 @@
1
+package com.yunzhi.marketing.borker.service;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAccountRecord;
4
+import com.baomidou.mybatisplus.extension.service.IService;
5
+
6
+/**
7
+ * <p>
8
+ * 经纪人佣金流水 服务类
9
+ * </p>
10
+ *
11
+ * @author yansen
12
+ * @since 2022-07-26
13
+ */
14
+public interface IBkAccountRecordService extends IService<BkAccountRecord> {
15
+
16
+}

+ 16
- 0
src/main/java/com/yunzhi/marketing/borker/service/IBkAgreementService.java View File

@@ -0,0 +1,16 @@
1
+package com.yunzhi.marketing.borker.service;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAgreement;
4
+import com.baomidou.mybatisplus.extension.service.IService;
5
+
6
+/**
7
+ * <p>
8
+ * 佣金规则 服务类
9
+ * </p>
10
+ *
11
+ * @author yansen
12
+ * @since 2022-07-26
13
+ */
14
+public interface IBkAgreementService extends IService<BkAgreement> {
15
+
16
+}

+ 16
- 0
src/main/java/com/yunzhi/marketing/borker/service/IBkBankCardService.java View File

@@ -0,0 +1,16 @@
1
+package com.yunzhi.marketing.borker.service;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkBankCard;
4
+import com.baomidou.mybatisplus.extension.service.IService;
5
+
6
+/**
7
+ * <p>
8
+ * 经纪人银行卡信息 服务类
9
+ * </p>
10
+ *
11
+ * @author yansen
12
+ * @since 2022-07-26
13
+ */
14
+public interface IBkBankCardService extends IService<BkBankCard> {
15
+
16
+}

+ 16
- 0
src/main/java/com/yunzhi/marketing/borker/service/IBkFirstScreenService.java View File

@@ -0,0 +1,16 @@
1
+package com.yunzhi.marketing.borker.service;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkFirstScreen;
4
+import com.baomidou.mybatisplus.extension.service.IService;
5
+
6
+/**
7
+ * <p>
8
+ * 经纪人首屏广告 服务类
9
+ * </p>
10
+ *
11
+ * @author yansen
12
+ * @since 2022-07-26
13
+ */
14
+public interface IBkFirstScreenService extends IService<BkFirstScreen> {
15
+
16
+}

+ 16
- 0
src/main/java/com/yunzhi/marketing/borker/service/IBkNoticeService.java View File

@@ -0,0 +1,16 @@
1
+package com.yunzhi.marketing.borker.service;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkNotice;
4
+import com.baomidou.mybatisplus.extension.service.IService;
5
+
6
+/**
7
+ * <p>
8
+ * 通知公告 服务类
9
+ * </p>
10
+ *
11
+ * @author yansen
12
+ * @since 2022-07-26
13
+ */
14
+public interface IBkNoticeService extends IService<BkNotice> {
15
+
16
+}

+ 20
- 0
src/main/java/com/yunzhi/marketing/borker/service/impl/BkAccountRecordServiceImpl.java View File

@@ -0,0 +1,20 @@
1
+package com.yunzhi.marketing.borker.service.impl;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAccountRecord;
4
+import com.yunzhi.marketing.borker.mapper.BkAccountRecordMapper;
5
+import com.yunzhi.marketing.borker.service.IBkAccountRecordService;
6
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 经纪人佣金流水 服务实现类
12
+ * </p>
13
+ *
14
+ * @author yansen
15
+ * @since 2022-07-26
16
+ */
17
+@Service
18
+public class BkAccountRecordServiceImpl extends ServiceImpl<BkAccountRecordMapper, BkAccountRecord> implements IBkAccountRecordService {
19
+
20
+}

+ 20
- 0
src/main/java/com/yunzhi/marketing/borker/service/impl/BkAgreementServiceImpl.java View File

@@ -0,0 +1,20 @@
1
+package com.yunzhi.marketing.borker.service.impl;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkAgreement;
4
+import com.yunzhi.marketing.borker.mapper.BkAgreementMapper;
5
+import com.yunzhi.marketing.borker.service.IBkAgreementService;
6
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 佣金规则 服务实现类
12
+ * </p>
13
+ *
14
+ * @author yansen
15
+ * @since 2022-07-26
16
+ */
17
+@Service
18
+public class BkAgreementServiceImpl extends ServiceImpl<BkAgreementMapper, BkAgreement> implements IBkAgreementService {
19
+
20
+}

+ 20
- 0
src/main/java/com/yunzhi/marketing/borker/service/impl/BkBankCardServiceImpl.java View File

@@ -0,0 +1,20 @@
1
+package com.yunzhi.marketing.borker.service.impl;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkBankCard;
4
+import com.yunzhi.marketing.borker.mapper.BkBankCardMapper;
5
+import com.yunzhi.marketing.borker.service.IBkBankCardService;
6
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 经纪人银行卡信息 服务实现类
12
+ * </p>
13
+ *
14
+ * @author yansen
15
+ * @since 2022-07-26
16
+ */
17
+@Service
18
+public class BkBankCardServiceImpl extends ServiceImpl<BkBankCardMapper, BkBankCard> implements IBkBankCardService {
19
+
20
+}

+ 20
- 0
src/main/java/com/yunzhi/marketing/borker/service/impl/BkFirstScreenServiceImpl.java View File

@@ -0,0 +1,20 @@
1
+package com.yunzhi.marketing.borker.service.impl;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkFirstScreen;
4
+import com.yunzhi.marketing.borker.mapper.BkFirstScreenMapper;
5
+import com.yunzhi.marketing.borker.service.IBkFirstScreenService;
6
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 经纪人首屏广告 服务实现类
12
+ * </p>
13
+ *
14
+ * @author yansen
15
+ * @since 2022-07-26
16
+ */
17
+@Service
18
+public class BkFirstScreenServiceImpl extends ServiceImpl<BkFirstScreenMapper, BkFirstScreen> implements IBkFirstScreenService {
19
+
20
+}

+ 20
- 0
src/main/java/com/yunzhi/marketing/borker/service/impl/BkNoticeServiceImpl.java View File

@@ -0,0 +1,20 @@
1
+package com.yunzhi.marketing.borker.service.impl;
2
+
3
+import com.yunzhi.marketing.borker.entity.BkNotice;
4
+import com.yunzhi.marketing.borker.mapper.BkNoticeMapper;
5
+import com.yunzhi.marketing.borker.service.IBkNoticeService;
6
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
7
+import org.springframework.stereotype.Service;
8
+
9
+/**
10
+ * <p>
11
+ * 通知公告 服务实现类
12
+ * </p>
13
+ *
14
+ * @author yansen
15
+ * @since 2022-07-26
16
+ */
17
+@Service
18
+public class BkNoticeServiceImpl extends ServiceImpl<BkNoticeMapper, BkNotice> implements IBkNoticeService {
19
+
20
+}

+ 8
- 0
src/main/java/com/yunzhi/marketing/common/WxUtils.java View File

@@ -6,6 +6,7 @@ import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
6 6
 import com.yunzhi.marketing.entity.TaMiniapp;
7 7
 import com.yunzhi.marketing.service.IMiniAppService;
8 8
 import org.springframework.beans.factory.annotation.Autowired;
9
+import org.springframework.beans.factory.annotation.Value;
9 10
 import org.springframework.stereotype.Component;
10 11
 
11 12
 import javax.annotation.PostConstruct;
@@ -19,6 +20,9 @@ public class WxUtils {
19 20
     @Autowired
20 21
     IMiniAppService iMiniAppService;
21 22
 
23
+    @Value("${yz.config.miniapp.env}")
24
+    String env;
25
+
22 26
     public WxMaService getMiniApp(String appid) {
23 27
         return serives.get(appid);
24 28
     }
@@ -54,4 +58,8 @@ public class WxUtils {
54 58
 
55 59
         return service;
56 60
     }
61
+
62
+    public String getEnv() {
63
+        return env;
64
+    }
57 65
 }

+ 35
- 32
src/main/java/com/yunzhi/marketing/service/impl/MiniAppServiceImpl.java View File

@@ -394,7 +394,9 @@ public class MiniAppServiceImpl implements IMiniAppService {
394 394
             String newScene = String.valueOf(taQrcode.getSerialNo());
395 395
             System.out.println("==========生成二维码参数--->" + newScene);
396 396
 
397
-            File qrFile = wxService.getQrcodeService().createWxaCodeUnlimit(newScene, page, width, autoColor, lineColor, isHyaline);
397
+            boolean checkPath = true;
398
+            String envVersion = wxUtils.getEnv();
399
+            File qrFile = wxService.getQrcodeService().createWxaCodeUnlimit(newScene, page, checkPath, envVersion, width, autoColor, lineColor, isHyaline);
398 400
             String qrcode = AliOSSUtils.putObject(qrFile, CommConstant.ALIOSS_DEFAULT_UPLOAD);
399 401
             taQrcode.setQrCode(qrcode);
400 402
             taMiniappQrcodeMapper.updateById(taQrcode);
@@ -433,35 +435,36 @@ public class MiniAppServiceImpl implements IMiniAppService {
433 435
         return taMiniappList;
434 436
     }
435 437
 
438
+    // 小程序模板消息业务已被微信取消
436 439
     @Deprecated
437 440
     private void sendMessage(String tplName, TaPerson toUser, String link, List<WxMaTemplateData> data) {
438
-        String appid = toUser.getMiniappId();
439
-        if (StringUtils.isEmpty(appid)) {
440
-            log.error("人员 {} 无对应来源小程序信息", toUser);
441
-        }
442
-
443
-        TaMiniappTemplate tpl = getTplByType(tplName, toUser.getMiniappId());
444
-        if (null == tpl) return;
445
-
446
-        String formid = taMiniFormidsService.getFormidBy(toUser.getMiniOpenid(), true);
447
-        if (StringUtils.isEmpty(formid)) {
448
-            log.error("发送消息失敗, 沒有有效的 formid");
449
-            return;
450
-        }
451
-
452
-        WxMaTemplateMessage message = WxMaTemplateMessage.builder()
453
-                .templateId(tpl.getTplId())
454
-                .data(data)
455
-                .formId(formid)
456
-                .page(StringUtils.ifNull(link, CommConstant.MINIAPP_INDEX))
457
-                .toUser(toUser.getMiniOpenid())
458
-                .build();
459
-        try {
460
-            WxMaService wxService = wxUtils.getMiniApp(appid);
461
-            wxService.getMsgService().sendTemplateMsg(message);
462
-        } catch (WxErrorException e) {
463
-            e.printStackTrace();
464
-        }
441
+//        String appid = toUser.getMiniappId();
442
+//        if (StringUtils.isEmpty(appid)) {
443
+//            log.error("人员 {} 无对应来源小程序信息", toUser);
444
+//        }
445
+//
446
+//        TaMiniappTemplate tpl = getTplByType(tplName, toUser.getMiniappId());
447
+//        if (null == tpl) return;
448
+//
449
+//        String formid = taMiniFormidsService.getFormidBy(toUser.getMiniOpenid(), true);
450
+//        if (StringUtils.isEmpty(formid)) {
451
+//            log.error("发送消息失敗, 沒有有效的 formid");
452
+//            return;
453
+//        }
454
+//
455
+//        WxMaTemplateMessage message = WxMaTemplateMessage.builder()
456
+//                .templateId(tpl.getTplId())
457
+//                .data(data)
458
+//                .formId(formid)
459
+//                .page(StringUtils.ifNull(link, CommConstant.MINIAPP_INDEX))
460
+//                .toUser(toUser.getMiniOpenid())
461
+//                .build();
462
+//        try {
463
+//            WxMaService wxService = wxUtils.getMiniApp(appid);
464
+//            wxService.getMsgService().sendTemplateMsg(message);
465
+//        } catch (WxErrorException e) {
466
+//            e.printStackTrace();
467
+//        }
465 468
 
466 469
         // TODO 写消息发送日志
467 470
     }
@@ -481,7 +484,7 @@ public class MiniAppServiceImpl implements IMiniAppService {
481 484
             return ResponseBean.error("小程序消息模板未设置字段内容", ResponseBean.ERROR_ILLEGAL_PARAMS);
482 485
         }
483 486
 
484
-        List<WxMaSubscribeMessage.Data> sendData = createMessageData(data, tpl.getTplFields());
487
+        List<WxMaSubscribeMessage.MsgData> sendData = createMessageData(data, tpl.getTplFields());
485 488
 
486 489
         WxMaSubscribeMessage message = WxMaSubscribeMessage.builder()
487 490
                 .templateId(tpl.getTplId())
@@ -531,15 +534,15 @@ public class MiniAppServiceImpl implements IMiniAppService {
531 534
         return success ? null : "短信发送失败";
532 535
     }
533 536
 
534
-    private List<WxMaSubscribeMessage.Data> createMessageData(String[] list, String fieldsStr) {
535
-        List<WxMaSubscribeMessage.Data> data = new ArrayList<>();
537
+    private List<WxMaSubscribeMessage.MsgData> createMessageData(String[] list, String fieldsStr) {
538
+        List<WxMaSubscribeMessage.MsgData> data = new ArrayList<>();
536 539
         if (list == null || list.length == 0 || StringUtils.isEmpty(fieldsStr)) return data;
537 540
 
538 541
         String[] fileds = fieldsStr.split("\\|");
539 542
 
540 543
         int length = Math.min(fileds.length, list.length);
541 544
         for (int i = 0; i < length; i++) {
542
-            data.add(new WxMaSubscribeMessage.Data(fileds[i], list[i]));
545
+            data.add(new WxMaSubscribeMessage.MsgData(fileds[i], list[i]));
543 546
         }
544 547
         return data;
545 548
     }

+ 7
- 0
src/main/resources/application-dev.yml View File

@@ -29,3 +29,10 @@ workwx:
29 29
   corpid: wwf5f7889b49bb2510
30 30
   agentid: 3010097
31 31
   secret: 0zKXGe3lmIoAfedoeLV_6DK96PM-Sg_c79rHqpSlvDs
32
+
33
+# 系统配置
34
+yz:
35
+  config:
36
+    miniapp:
37
+      # 正式版为 "release",体验版为 "trial",开发版为 "develop"。
38
+      env: develop

+ 8
- 1
src/main/resources/application-prod.yml View File

@@ -28,4 +28,11 @@ logging:
28 28
 workwx:
29 29
   corpid: ww5d25337525b92d79
30 30
   agentid: 3010097
31
-  secret: Pfh7UEIn8QEbFlaU5Z_9aPDYHzHlFJJ9rzdm385my28
31
+  secret: Pfh7UEIn8QEbFlaU5Z_9aPDYHzHlFJJ9rzdm385my28
32
+
33
+# 系统配置
34
+yz:
35
+  config:
36
+    miniapp:
37
+      # 正式版为 "release",体验版为 "trial",开发版为 "develop"。
38
+      env: release

+ 8
- 0
src/main/resources/application-test.yml View File

@@ -29,3 +29,11 @@ workwx:
29 29
   corpid: wwf5f7889b49bb2510
30 30
   agentid: 3010097
31 31
   secret: 0zKXGe3lmIoAfedoeLV_6DK96PM-Sg_c79rHqpSlvDs
32
+
33
+
34
+# 系统配置
35
+yz:
36
+  config:
37
+    miniapp:
38
+      # 正式版为 "release",体验版为 "trial",开发版为 "develop"。
39
+      env: trial

+ 5
- 0
src/main/resources/mapper/BkAccountRecordMapper.xml View File

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.yunzhi.marketing.borker.mapper.BkAccountRecordMapper">
4
+
5
+</mapper>

+ 5
- 0
src/main/resources/mapper/BkAgreementMapper.xml View File

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.yunzhi.marketing.borker.mapper.BkAgreementMapper">
4
+
5
+</mapper>

+ 5
- 0
src/main/resources/mapper/BkBankCardMapper.xml View File

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.yunzhi.marketing.borker.mapper.BkBankCardMapper">
4
+
5
+</mapper>

+ 5
- 0
src/main/resources/mapper/BkFirstScreenMapper.xml View File

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.yunzhi.marketing.borker.mapper.BkFirstScreenMapper">
4
+
5
+</mapper>

+ 5
- 0
src/main/resources/mapper/BkNoticeMapper.xml View File

@@ -0,0 +1,5 @@
1
+<?xml version="1.0" encoding="UTF-8"?>
2
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
+<mapper namespace="com.yunzhi.marketing.borker.mapper.BkNoticeMapper">
4
+
5
+</mapper>