From 8ea31f9805070e6742be12f0f7e1956e9efd560e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E7=86=99=E6=9C=9D?=
<13694051+wangxizhao123@user.noreply.gitee.com>
Date: Wed, 8 May 2024 17:01:38 +0800
Subject: [PATCH] =?UTF-8?q?fase()=E5=BC=95=E6=93=8E=E8=A7=84=E5=88=99?=
=?UTF-8?q?=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
muyu-modules/muyu-goods-test/pom.xml | 21 +++
.../com/muyu/goods/MuYuGoodsApplication.java | 1 +
.../goods/constant/ConfigCodeConstants.java | 1 +
.../goods/controller/ConfigController.java | 7 +-
.../muyu/goods/controller/CopeController.java | 20 ++-
.../goods/controller/EditionController.java | 115 ++++++++++++++
.../controller/RuleEngineController.java | 31 +++-
.../java/com/muyu/goods/domain/Anduser.java | 75 +++++++++
.../java/com/muyu/goods/domain/Edition.java | 150 ++++++++++++++++++
.../com/muyu/goods/domain/req/SpliceRep.java | 5 +
.../goods/domain/resp/AnduserIndexResp.java | 35 ++++
.../goods/domain/resp/AnduserQueryResp.java | 37 +++++
.../goods/domain/resp/AnduserUpdateResp.java | 38 +++++
.../com/muyu/goods/mapper/EditionMapper.java | 60 +++++++
.../muyu/goods/mapper/RuleEngineMapper.java | 4 +
.../main/java/com/muyu/goods/scope/ToCode.txt | 24 +++
.../com/muyu/goods/service/CopeService.java | 6 +
.../muyu/goods/service/IConfigService.java | 2 +
.../muyu/goods/service/IEditionService.java | 68 ++++++++
.../goods/service/IRuleEngineService.java | 14 ++
.../goods/service/impl/ConfigServiceImpl.java | 12 +-
.../goods/service/impl/CopeServiceImpl.java | 43 +++++
.../service/impl/EditionServiceImpl.java | 105 ++++++++++++
.../service/impl/RuleEngineServiceImpl.java | 60 +++++++
.../muyu-goods/src/main/java/strasd.java | 12 ++
.../muyu-goods/src/main/java/stream.java | 66 +++++++-
.../resources/mapper/goods/EditionMapper.xml | 71 +++++++++
.../mapper/goods/RuleEngineMapper.xml | 10 ++
pom.xml | 1 +
29 files changed, 1074 insertions(+), 20 deletions(-)
create mode 100644 muyu-modules/muyu-goods-test/pom.xml
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/EditionController.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Anduser.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Edition.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/req/SpliceRep.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserIndexResp.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserQueryResp.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserUpdateResp.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/EditionMapper.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/scope/ToCode.txt
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IEditionService.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/EditionServiceImpl.java
create mode 100644 muyu-modules/muyu-goods/src/main/java/strasd.java
create mode 100644 muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml
diff --git a/muyu-modules/muyu-goods-test/pom.xml b/muyu-modules/muyu-goods-test/pom.xml
new file mode 100644
index 0000000..9c22e86
--- /dev/null
+++ b/muyu-modules/muyu-goods-test/pom.xml
@@ -0,0 +1,21 @@
+
+
+ 4.0.0
+
+ com.muyu
+ muyu
+ 3.6.3
+ ../../pom.xml
+
+
+ muyu-goods-test
+
+
+ 17
+ 17
+ UTF-8
+
+
+
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/MuYuGoodsApplication.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/MuYuGoodsApplication.java
index 5a91b0c..d8a5f35 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/MuYuGoodsApplication.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/MuYuGoodsApplication.java
@@ -4,6 +4,7 @@ import com.muyu.common.security.annotation.EnableCustomConfig;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import com.muyu.common.swagger.annotation.EnableCustomSwagger2;
import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableCustomConfig
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/constant/ConfigCodeConstants.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/constant/ConfigCodeConstants.java
index 2fe820c..5e03f0c 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/constant/ConfigCodeConstants.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/constant/ConfigCodeConstants.java
@@ -16,6 +16,7 @@ public class ConfigCodeConstants {
* 配置文件名数组
*/
public final static String[] CONFIG_FILE_NAME_ARRAY=new String[]{"TestClass.txt","TaskContextHolder.java","DataSetContextHolder.java","RecordContextHolder.java","DataModelContextHolder.java"};
+ public final static String[] CONFIG_FILE_NAME_CODE=new String[]{"ToCode.txt","TaskContextHolder.java","DataSetContextHolder.java","RecordContextHolder.java","DataModelContextHolder.java"};
/**
* 配置文件类型数组
*/
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/ConfigController.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/ConfigController.java
index 165a87b..0812472 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/ConfigController.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/ConfigController.java
@@ -118,7 +118,7 @@ public class ConfigController extends BaseController
/**
* 引擎测试
- * @param id
+ * @param textData
* @return
*/
@PostMapping("/testData")
@@ -135,4 +135,9 @@ public class ConfigController extends BaseController
public Result getScopeInfo(@PathVariable Integer id) {
return success(configService.getScopeInfo(id));
}
+
+ @PostMapping("queryConfigInfo/{ruleId}")
+ public Result> queryConfigInfo(@PathVariable Long ruleId){
+ return success(configService.queryConfigInfo(ruleId));
+ }
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/CopeController.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/CopeController.java
index 5c6cdda..31cbeed 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/CopeController.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/CopeController.java
@@ -2,13 +2,12 @@ package com.muyu.goods.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
+import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.goods.domain.Cope;
import com.muyu.goods.service.CopeService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
import java.util.List;
@@ -22,4 +21,19 @@ public class CopeController extends BaseController {
public Result> list() {
return success(service.list());
}
+
+ @PostMapping("/list2")
+ public Result> list2() {
+ return success(service.list2());
+ }
+
+ @PostMapping("selType/{name}")
+ public Result> selType(@PathVariable String name){
+ return success(service.selType(name));
+ }
+
+ @PostMapping("selObject")
+ public Result> selObject(@RequestBody Cope cope){
+ return success(service.selObject(cope));
+ }
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/EditionController.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/EditionController.java
new file mode 100644
index 0000000..13d79e4
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/EditionController.java
@@ -0,0 +1,115 @@
+package com.muyu.goods.controller;
+
+import java.util.List;
+import javax.servlet.http.HttpServletResponse;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import com.muyu.common.log.annotation.Log;
+import com.muyu.common.log.enums.BusinessType;
+import com.muyu.common.security.annotation.RequiresPermissions;
+import com.muyu.goods.domain.Edition;
+import com.muyu.goods.service.IEditionService;
+import com.muyu.common.core.web.controller.BaseController;
+import com.muyu.common.core.domain.Result;
+import com.muyu.common.core.utils.poi.ExcelUtil;
+import com.muyu.common.core.web.page.TableDataInfo;
+
+/**
+ * 规则引擎版本Controller
+ *
+ * @author muyu
+ * @date 2024-05-06
+ */
+@RestController
+@RequestMapping("/edition")
+public class EditionController extends BaseController
+{
+ @Autowired
+ private IEditionService editionService;
+
+ /**
+ * 查询规则引擎版本列表
+ */
+ @RequiresPermissions("goods:edition:list")
+ @GetMapping("/list")
+ public Result> list()
+ {
+ startPage();
+ List list = editionService.selectEditionList();
+ return getDataTable(list);
+ }
+
+ /**
+ * 获取相应的规则引擎版本
+ * @param ruleId
+ * @return
+ */
+ @PostMapping("/selectListRuleId/{ruleId}")
+ public Result> selectListRuleId(@PathVariable Long ruleId){
+ return success(editionService.selectListRuleId(ruleId));
+ }
+
+ /**
+ * 导出规则引擎版本列表
+ */
+ @RequiresPermissions("goods:edition:export")
+ @Log(title = "规则引擎版本", businessType = BusinessType.EXPORT)
+ @PostMapping("/export")
+ public void export(HttpServletResponse response, Edition edition)
+ {
+ List list = editionService.selectEditionList();
+ ExcelUtil util = new ExcelUtil(Edition.class);
+ util.exportExcel(response, list, "规则引擎版本数据");
+ }
+
+ /**
+ * 获取规则引擎版本详细信息
+ */
+ @RequiresPermissions("goods:edition:query")
+ @GetMapping(value = "/{id}")
+ public Result getInfo(@PathVariable("id") Long id)
+ {
+ return success(editionService.selectEditionById(id));
+ }
+
+ /**
+ * 新增规则引擎版本
+ */
+ @RequiresPermissions("goods:edition:add")
+ @Log(title = "规则引擎版本", businessType = BusinessType.INSERT)
+ @PostMapping
+ public Result add(@RequestBody Edition edition)
+ {
+ return toAjax(editionService.insertEdition(edition));
+ }
+
+ /**
+ * 修改规则引擎版本
+ */
+ @RequiresPermissions("goods:edition:edit")
+ @Log(title = "规则引擎版本", businessType = BusinessType.UPDATE)
+ @PutMapping
+ public Result edit(@RequestBody Edition edition)
+ {
+ return toAjax(editionService.updateEdition(edition));
+ }
+
+ /**
+ * 删除规则引擎版本
+ */
+ @RequiresPermissions("goods:edition:remove")
+ @Log(title = "规则引擎版本", businessType = BusinessType.DELETE)
+ @DeleteMapping("/{ids}")
+ public Result remove(@PathVariable Long[] ids)
+ {
+ return toAjax(editionService.deleteEditionByIds(ids));
+ }
+
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/RuleEngineController.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/RuleEngineController.java
index 61fcc51..95f96ae 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/RuleEngineController.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/controller/RuleEngineController.java
@@ -3,14 +3,7 @@ package com.muyu.goods.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
import com.muyu.common.log.annotation.Log;
import com.muyu.common.log.enums.BusinessType;
import com.muyu.common.security.annotation.RequiresPermissions;
@@ -69,6 +62,11 @@ public class RuleEngineController extends BaseController
return success(ruleEngineService.selectRuleEngineByRuleId(ruleId));
}
+ @PostMapping("selectRuleEngineOne/{ruleId}")
+ public Result selectRuleEngineOne(@PathVariable Long ruleId){
+ return success(ruleEngineService.selectRuleEngineOne(ruleId));
+ }
+
/**
* 新增规则引擎
*/
@@ -111,4 +109,21 @@ public class RuleEngineController extends BaseController
public Result description(@PathVariable Integer ruleId){
return success(ruleEngineService.description(ruleId));
}
+
+ @PutMapping("/updateRuleIsActivate")
+ public Result updateRuleIsActivate(@RequestBody RuleEngine ruleEngine){
+ ruleEngineService.updateRuleIsActivate(ruleEngine);
+ return success("改变激活状态");
+ }
+ @PutMapping("/updateRuleStatus")
+ public Result updateRuleStatus(@RequestBody RuleEngine ruleEngine){
+ ruleEngineService.updateRuleStatus(ruleEngine);
+ return success("改变规则状态");
+ }
+
+ @PostMapping("/spliceNameToCode")
+ public Result spliceNameToCode(@RequestParam String name, @RequestParam String code,@RequestParam String level){
+ return ruleEngineService.spliceNameToCode(name,code,level);
+ }
+
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Anduser.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Anduser.java
new file mode 100644
index 0000000..3d6a2eb
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Anduser.java
@@ -0,0 +1,75 @@
+package com.muyu.goods.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.web.domain.BaseEntity;
+import com.muyu.goods.domain.resp.AnduserIndexResp;
+import com.muyu.goods.domain.resp.AnduserQueryResp;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName("engine_config")
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "Anduser", description = "测试项目")
+public class Anduser extends BaseEntity {
+ private static final long serialVersionUID = 1L;
+ /**
+ *主键
+ */
+ @TableId(value = "id",type = IdType.AUTO)
+ @ApiModelProperty(name = "主键", value = "主键")
+ private Long id;
+ /**
+ * 名称
+ */
+ @TableId(value = "name")
+ @ApiModelProperty(name = "名称", value = "名称")
+ private String name;
+ /**
+ * 性别
+ */
+ @TableId(value = "sex")
+ @ApiModelProperty(name = "性别", value = "性别")
+ private String sex;
+ /**
+ * 年龄
+ */
+ @TableId(value = "age")
+ @ApiModelProperty(name = "年龄", value = "年龄")
+ private Integer age;
+
+ /**
+ * 查询
+ */
+ public static Anduser query(AnduserQueryResp anduserQueryResp){
+ return Anduser.builder()
+ .name(anduserQueryResp.getName())
+ .sex(anduserQueryResp.getSex())
+ .age(anduserQueryResp.getAge())
+ .build();
+ }
+ /**
+ * 添加
+ */
+ public static Anduser index(AnduserIndexResp anduserIndexResp){
+ return Anduser.builder()
+ .name(anduserIndexResp.getName())
+ .sex(anduserIndexResp.getSex())
+ .age(anduserIndexResp.getAge())
+ .build();
+ }
+
+ /**
+ * 修改
+ */
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Edition.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Edition.java
new file mode 100644
index 0000000..889e0a0
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/Edition.java
@@ -0,0 +1,150 @@
+package com.muyu.goods.domain;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.muyu.common.core.annotation.Excel;
+import com.muyu.common.core.web.domain.BaseEntity;
+
+/**
+ * 规则引擎版本对象 edition
+ *
+ * @author muyu
+ * @date 2024-05-06
+ */
+public class Edition extends BaseEntity
+{
+ private static final long serialVersionUID = 1L;
+
+ /** 主键 */
+ private Long id;
+
+ /** 规则序号 */
+ @Excel(name = "规则序号")
+ private Long ruleId;
+
+ /** 版本类 */
+ @Excel(name = "版本类")
+ private String versionClass;
+
+ /** 版本名称 */
+ @Excel(name = "版本名称")
+ private String name;
+
+ /** 版本编码 */
+ @Excel(name = "版本编码")
+ private String versionCode;
+
+ /** 版本状态 */
+ @Excel(name = "是否发布")
+ private Integer editionStatus;
+
+ /** 引擎状态 */
+ @Excel(name = "是否激活")
+ private String ruleStatus;
+
+ @Excel(name = "是否测试")
+ private Integer ruleIsTest;
+
+ /** 内容 */
+ @Excel(name = "内容描述")
+ private String editionContent;
+
+ @Excel(name = "规则内容")
+ private String ruleContent;
+
+ public Long getId() {
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public Long getRuleId() {
+ return ruleId;
+ }
+
+ public void setRuleId(Long ruleId) {
+ this.ruleId = ruleId;
+ }
+
+ public String getVersionClass() {
+ return versionClass;
+ }
+
+ public void setVersionClass(String versionClass) {
+ this.versionClass = versionClass;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public String getVersionCode() {
+ return versionCode;
+ }
+
+ public void setVersionCode(String versionCode) {
+ this.versionCode = versionCode;
+ }
+
+ public Integer getEditionStatus() {
+ return editionStatus;
+ }
+
+ public void setEditionStatus(Integer editionStatus) {
+ this.editionStatus = editionStatus;
+ }
+
+ public String getRuleStatus() {
+ return ruleStatus;
+ }
+
+ public void setRuleStatus(String ruleStatus) {
+ this.ruleStatus = ruleStatus;
+ }
+
+ public Integer getRuleIsTest() {
+ return ruleIsTest;
+ }
+
+ public void setRuleIsTest(Integer ruleIsTest) {
+ this.ruleIsTest = ruleIsTest;
+ }
+
+ public String getEditionContent() {
+ return editionContent;
+ }
+
+ public void setEditionContent(String editionContent) {
+ this.editionContent = editionContent;
+ }
+
+ public String getRuleContent() {
+ return ruleContent;
+ }
+
+ public void setRuleContent(String ruleContent) {
+ this.ruleContent = ruleContent;
+ }
+
+ @Override
+ public String toString() {
+ return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+ .append("id", getId())
+ .append("ruleId", getRuleId())
+ .append("versionClass", getVersionClass())
+ .append("name", getName())
+ .append("versionCode", getVersionCode())
+ .append("editionStatus", getEditionStatus())
+ .append("ruleStatus", getRuleStatus())
+ .append("ruleIsTest",getRuleIsTest())
+ .append("ruleContent",getRuleContent())
+ .append("editionContent", getEditionContent())
+ .toString();
+ }
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/req/SpliceRep.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/req/SpliceRep.java
new file mode 100644
index 0000000..ef1dd06
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/req/SpliceRep.java
@@ -0,0 +1,5 @@
+package com.muyu.goods.domain.req;
+
+public class SpliceRep {
+
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserIndexResp.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserIndexResp.java
new file mode 100644
index 0000000..bc2cc58
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserIndexResp.java
@@ -0,0 +1,35 @@
+package com.muyu.goods.domain.resp;
+
+import com.muyu.goods.domain.Anduser;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value = "AnduserIndexResp", description = "测试添加")
+public class AnduserIndexResp {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 名称
+ */
+ @ApiModelProperty(name = "名称", value = "名称")
+ private String name;
+ /**
+ * 性别
+ */
+ @ApiModelProperty(name = "性别", value = "性别")
+ private String sex;
+ /**
+ * 年龄
+ */
+ @ApiModelProperty(name = "年龄", value = "年龄")
+ private Integer age;
+
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserQueryResp.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserQueryResp.java
new file mode 100644
index 0000000..45ade93
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserQueryResp.java
@@ -0,0 +1,37 @@
+package com.muyu.goods.domain.resp;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.muyu.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value = "AnduserQueryResp", description = "测试查询")
+public class AnduserQueryResp extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 名称
+ */
+ @ApiModelProperty(name = "名称", value = "名称")
+ private String name;
+ /**
+ * 性别
+ */
+ @ApiModelProperty(name = "性别", value = "性别")
+ private String sex;
+ /**
+ * 年龄
+ */
+ @ApiModelProperty(name = "年龄", value = "年龄")
+ private Integer age;
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserUpdateResp.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserUpdateResp.java
new file mode 100644
index 0000000..f76801f
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/domain/resp/AnduserUpdateResp.java
@@ -0,0 +1,38 @@
+package com.muyu.goods.domain.resp;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value = "AnduserQueryResp", description = "测试查询")
+public class AnduserUpdateResp {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键
+ */
+ @ApiModelProperty(name = "主键", value = "主键")
+ private String id;
+ /**
+ * 名称
+ */
+ @ApiModelProperty(name = "名称", value = "名称")
+ private String name;
+ /**
+ * 性别
+ */
+ @ApiModelProperty(name = "性别", value = "性别")
+ private String sex;
+ /**
+ * 年龄
+ */
+ @ApiModelProperty(name = "年龄", value = "年龄")
+ private Integer age;
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/EditionMapper.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/EditionMapper.java
new file mode 100644
index 0000000..47a507f
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/EditionMapper.java
@@ -0,0 +1,60 @@
+package com.muyu.goods.mapper;
+
+import java.util.List;
+import com.muyu.goods.domain.Edition;
+
+/**
+ * 规则引擎版本Mapper接口
+ *
+ * @author muyu
+ * @date 2024-05-06
+ */
+public interface EditionMapper
+{
+ /**
+ * 查询规则引擎版本
+ *
+ * @param id 规则引擎版本主键
+ * @return 规则引擎版本
+ */
+ public Edition selectEditionById(Long id);
+
+ /**
+ * 查询规则引擎版本列表
+ *
+ * @return 规则引擎版本集合
+ */
+ public List selectEditionList();
+
+ /**
+ * 新增规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ public int insertEdition(Edition edition);
+
+ /**
+ * 修改规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ public int updateEdition(Edition edition);
+
+ /**
+ * 删除规则引擎版本
+ *
+ * @param id 规则引擎版本主键
+ * @return 结果
+ */
+ public int deleteEditionById(Long id);
+
+ /**
+ * 批量删除规则引擎版本
+ *
+ * @param ids 需要删除的数据主键集合
+ * @return 结果
+ */
+ public int deleteEditionByIds(Long[] ids);
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/RuleEngineMapper.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/RuleEngineMapper.java
index 7f53457..9dcaeb1 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/RuleEngineMapper.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/mapper/RuleEngineMapper.java
@@ -61,4 +61,8 @@ public interface RuleEngineMapper
public int deleteRuleEngineByRuleIds(Long[] ruleIds);
String description(@Param("ruleId") Integer ruleId);
+
+ void updateRuleIsActivate(@Param("ruleId") Long ruleId, @Param("ruleIsActivate") String ruleIsActivate);
+
+ void updateRuleStatus(@Param("ruleId") Long ruleId, @Param("ruleStatus") String ruleStatus);
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/scope/ToCode.txt b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/scope/ToCode.txt
new file mode 100644
index 0000000..41c3514
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/scope/ToCode.txt
@@ -0,0 +1,24 @@
+let packageName = "com.muyu.rule.goods";
+ let customName = "custom";
+ let templateName = "template";
+ let ruleContent = `package ${packageName}.${customName};
+
+import com.muyu.engine.action.ActionDiscard;
+import com.muyu.engine.scope.parentClass;
+
+/**
+ * @Author: DongZeLiang
+ * @date: 2024/5/6
+ * @Description: this.form.name-this.form.versionCode
+ * @Version: 1.0
+ */
+public class this.form.versionCode extends parentClass {
+ @Override
+ public void execution () {
+ Object value = getValue();
+
+ if (value == null || "".equals(value) || "null".equals(value)) {
+ throw new ActionDiscard();
+ }
+ }
+}`;
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/CopeService.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/CopeService.java
index e2c5386..4f2d42a 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/CopeService.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/CopeService.java
@@ -6,4 +6,10 @@ import java.util.List;
public interface CopeService {
List list();
+
+ List list2();
+
+ List selType(String name);
+
+ List selObject(Cope cope);
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IConfigService.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IConfigService.java
index caf70ad..41adeea 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IConfigService.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IConfigService.java
@@ -76,4 +76,6 @@ public interface IConfigService
* @return
*/
EngineConfigResp getScopeInfo(Integer id);
+
+ List queryConfigInfo(Long ruleId);
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IEditionService.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IEditionService.java
new file mode 100644
index 0000000..2752d66
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IEditionService.java
@@ -0,0 +1,68 @@
+package com.muyu.goods.service;
+
+import java.util.List;
+import com.muyu.goods.domain.Edition;
+
+/**
+ * 规则引擎版本Service接口
+ *
+ * @author muyu
+ * @date 2024-05-06
+ */
+public interface IEditionService
+{
+ /**
+ * 查询规则引擎版本
+ *
+ * @param id 规则引擎版本主键
+ * @return 规则引擎版本
+ */
+ public Edition selectEditionById(Long id);
+
+ /**
+ * 获取相应的规则引擎版本
+ *
+ * @param ruleId
+ * @return
+ */
+ List selectListRuleId(Long ruleId);
+ /**
+ * 查询规则引擎版本列表
+ *
+ * @return 规则引擎版本集合
+ */
+ public List selectEditionList();
+
+ /**
+ * 新增规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ public int insertEdition(Edition edition);
+
+ /**
+ * 修改规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ public int updateEdition(Edition edition);
+
+ /**
+ * 批量删除规则引擎版本
+ *
+ * @param ids 需要删除的规则引擎版本主键集合
+ * @return 结果
+ */
+ public int deleteEditionByIds(Long[] ids);
+
+ /**
+ * 删除规则引擎版本信息
+ *
+ * @param id 规则引擎版本主键
+ * @return 结果
+ */
+ public int deleteEditionById(Long id);
+
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IRuleEngineService.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IRuleEngineService.java
index 015957f..7603fc6 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IRuleEngineService.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/IRuleEngineService.java
@@ -1,6 +1,8 @@
package com.muyu.goods.service;
import java.util.List;
+
+import com.muyu.common.core.domain.Result;
import com.muyu.goods.domain.RuleEngine;
/**
@@ -19,6 +21,12 @@ public interface IRuleEngineService
*/
public RuleEngine selectRuleEngineByRuleId(Long ruleId);
+ /**
+ * 规则详情
+ * @param ruleId
+ * @return
+ */
+ RuleEngine selectRuleEngineOne(Long ruleId);
/**
* 查询规则引擎列表
*
@@ -60,4 +68,10 @@ public interface IRuleEngineService
public int deleteRuleEngineByRuleId(Long ruleId);
String description(Integer ruleId);
+
+ void updateRuleIsActivate(RuleEngine ruleEngine);
+
+ void updateRuleStatus(RuleEngine ruleEngine);
+
+ Result spliceNameToCode(String name, String code, String level);
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/ConfigServiceImpl.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/ConfigServiceImpl.java
index 011fcbf..6e4e4bc 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/ConfigServiceImpl.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/ConfigServiceImpl.java
@@ -7,6 +7,7 @@ import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;
import java.util.Map;
+import java.util.stream.Collectors;
import com.muyu.common.core.exception.ServiceException;
import com.muyu.goods.constant.ConfigCodeConstants;
@@ -164,12 +165,9 @@ public class ConfigServiceImpl implements IConfigService
.build();
}
- public static String ruleTest(List list) {
- for (Object o : list) {
- if (o.toString().contains("@163")){
- list.remove(o);
- }
- }
- return list.toString();
+ @Override
+ public List queryConfigInfo(Long ruleId) {
+ return selectConfigList(null).stream().filter(c -> c.getRuleId().equals(ruleId)).collect(Collectors.toList())
+ ;
}
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/CopeServiceImpl.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/CopeServiceImpl.java
index 5f7e9ef..15ff234 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/CopeServiceImpl.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/CopeServiceImpl.java
@@ -3,10 +3,15 @@ package com.muyu.goods.service.impl;
import com.muyu.goods.domain.Cope;
import com.muyu.goods.mapper.CopeMapper;
import com.muyu.goods.service.CopeService;
+import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
@Service
public class CopeServiceImpl implements CopeService {
@@ -17,4 +22,42 @@ public class CopeServiceImpl implements CopeService {
public List list() {
return mapper.list();
}
+
+ @Override
+ public List list2() {
+ return list().stream().collect(Collectors.toList());
+ }
+
+ @Override
+ public List selType(String name) {
+ Stream copeStream = list().stream().filter(c -> c.getType().equals(name));
+ return copeStream.collect(Collectors.toList());
+ }
+
+ @Override
+ public List selObject(Cope cope) {
+ System.out.println(cope);
+ List collect = new ArrayList<>();
+ List collect1 = new ArrayList<>();
+ if (cope.getType()!=null && cope.getType()!=""){
+ collect = list().stream().filter(c -> c.getType().equals(cope.getType())).collect(Collectors.toList());
+ }else {
+ collect = list();
+ }
+ if (cope.getVal()!=null && cope.getVal()!=""){
+ collect1 = list().stream().filter(c -> c.getVal().contains(cope.getVal())).collect(Collectors.toList());
+ }else {
+ collect1 = list();
+ }
+ List copes = new ArrayList<>();
+ for (Cope cope1 : collect) {
+ for (Cope cope2 : collect1) {
+ if (cope1.equals(cope2)){
+ copes.add(cope1);
+ }
+ }
+ }
+ System.out.println(copes);
+ return copes;
+ }
}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/EditionServiceImpl.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/EditionServiceImpl.java
new file mode 100644
index 0000000..fc441d6
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/EditionServiceImpl.java
@@ -0,0 +1,105 @@
+package com.muyu.goods.service.impl;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.muyu.goods.mapper.EditionMapper;
+import com.muyu.goods.domain.Edition;
+import com.muyu.goods.service.IEditionService;
+
+/**
+ * 规则引擎版本Service业务层处理
+ *
+ * @author muyu
+ * @date 2024-05-06
+ */
+@Service
+public class EditionServiceImpl implements IEditionService
+{
+ @Autowired
+ private EditionMapper editionMapper;
+
+ /**
+ * 查询规则引擎版本
+ *
+ * @param id 规则引擎版本主键
+ * @return 规则引擎版本
+ */
+ @Override
+ public Edition selectEditionById(Long id)
+ {
+ return editionMapper.selectEditionById(id);
+ }
+
+ /**
+ * 获取相应的规则引擎版本
+ *
+ * @param ruleId
+ * @return
+ */
+ @Override
+ public List selectListRuleId(Long ruleId) {
+ return selectEditionList().stream().filter(c -> c.getRuleId().equals(ruleId)).collect(Collectors.toList());
+ }
+
+ /**
+ * 查询规则引擎版本列表
+ *
+ * @return 规则引擎版本
+ */
+ @Override
+ public List selectEditionList()
+ {
+ return editionMapper.selectEditionList();
+ }
+
+ /**
+ * 新增规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ @Override
+ public int insertEdition(Edition edition)
+ {
+ return editionMapper.insertEdition(edition);
+ }
+
+ /**
+ * 修改规则引擎版本
+ *
+ * @param edition 规则引擎版本
+ * @return 结果
+ */
+ @Override
+ public int updateEdition(Edition edition)
+ {
+ return editionMapper.updateEdition(edition);
+ }
+
+ /**
+ * 批量删除规则引擎版本
+ *
+ * @param ids 需要删除的规则引擎版本主键
+ * @return 结果
+ */
+ @Override
+ public int deleteEditionByIds(Long[] ids)
+ {
+ return editionMapper.deleteEditionByIds(ids);
+ }
+
+ /**
+ * 删除规则引擎版本信息
+ *
+ * @param id 规则引擎版本主键
+ * @return 结果
+ */
+ @Override
+ public int deleteEditionById(Long id)
+ {
+ return editionMapper.deleteEditionById(id);
+ }
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/RuleEngineServiceImpl.java b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/RuleEngineServiceImpl.java
index e02ca3b..b3a55ce 100644
--- a/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/RuleEngineServiceImpl.java
+++ b/muyu-modules/muyu-goods/src/main/java/com/muyu/goods/service/impl/RuleEngineServiceImpl.java
@@ -1,6 +1,15 @@
package com.muyu.goods.service.impl;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.goods.constant.ConfigCodeConstants;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.muyu.goods.mapper.RuleEngineMapper;
@@ -31,6 +40,18 @@ public class RuleEngineServiceImpl implements IRuleEngineService
return ruleEngineMapper.selectRuleEngineByRuleId(ruleId);
}
+ /**
+ * 规则引擎详情
+ * @param ruleId
+ * @return
+ */
+ @Override
+ public RuleEngine selectRuleEngineOne(Long ruleId) {
+ List ruleEngines = selectRuleEngineList(null);
+ List collect = ruleEngines.stream().filter(c -> c.getRuleId().equals(ruleId)).collect(Collectors.toList());
+ return collect.get(0);
+ }
+
/**
* 查询规则引擎列表
*
@@ -95,4 +116,43 @@ public class RuleEngineServiceImpl implements IRuleEngineService
public String description(Integer ruleId) {
return ruleEngineMapper.description(ruleId);
}
+
+ @Override
+ public void updateRuleIsActivate(RuleEngine ruleEngine) {
+ if (ruleEngine.getRuleIsActivate().equals("Y")){
+ ruleEngine.setRuleIsActivate("N");
+ }else{
+ ruleEngine.setRuleIsActivate("Y");
+ }
+ ruleEngineMapper.updateRuleIsActivate(ruleEngine.getRuleId(),ruleEngine.getRuleIsActivate());
+ }
+
+ @Override
+ public void updateRuleStatus(RuleEngine ruleEngine) {
+ if (ruleEngine.getRuleStatus().equals("Y")){
+ ruleEngine.setRuleStatus("N");
+ }else{
+ ruleEngine.setRuleStatus("Y");
+ }
+ ruleEngineMapper.updateRuleStatus(ruleEngine.getRuleId(),ruleEngine.getRuleStatus());
+ }
+
+ @Override
+ public Result spliceNameToCode(String name, String code, String level) {
+ String val = name + "_" + code;
+ String scope = ConfigCodeConstants.CONFIG_FILE_NAME_CODE[0];
+ String path = ConfigCodeConstants.BASE_FILE_PATH+scope;
+ String cod = null;
+ try {
+ cod = Files.readString(Paths.get(path));
+ String s1 = Pattern.compile("this.form.name").matcher(cod).replaceAll(name);
+ String s2 = Pattern.compile("this.form.versionCode").matcher(s1).replaceAll(code);
+ String s3 = Pattern.compile("parentClass").matcher(s2).replaceAll(level);
+
+ System.out.println(cod);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ return Result.success(val,cod);
+ }
}
diff --git a/muyu-modules/muyu-goods/src/main/java/strasd.java b/muyu-modules/muyu-goods/src/main/java/strasd.java
new file mode 100644
index 0000000..b7bcbcc
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/java/strasd.java
@@ -0,0 +1,12 @@
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class strasd {
+ public static void main(String[] args) {
+ java.lang.String sss = "sabacdeaces";
+ Pattern es = Pattern.compile("es");
+ Matcher matcher = es.matcher(sss);
+ String s = matcher.replaceAll("a1");
+ System.out.println(s);
+ }
+}
diff --git a/muyu-modules/muyu-goods/src/main/java/stream.java b/muyu-modules/muyu-goods/src/main/java/stream.java
index f9dccd7..2bfd488 100644
--- a/muyu-modules/muyu-goods/src/main/java/stream.java
+++ b/muyu-modules/muyu-goods/src/main/java/stream.java
@@ -1,8 +1,11 @@
+import com.muyu.goods.domain.Cope;
+
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.*;
+import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@@ -25,12 +28,73 @@ public class stream {
stringList.add("2596325@163.com");
stringList.add("157492533@qq.com");
stringList.add("1547859633@qq.com");
+ stringList.add("1547859633@qq.com");
//filter 筛选操作
-// stringList.stream().filter(c -> c.contains("@163")).forEach(System.out::println);
+ stringList.stream().filter(c -> c.contains("@163")).forEach(System.out::println);
//map 映射 map(表::展示字段)
+ System.out.println("筛选操作");
stringList.stream().map(String::new).forEach(System.out::println);
//flatMap 将每个元素映射为一个Stream对象,并将所有的Stream对象的元素合并为一个steam对象
+ System.out.println("将所有的Stream对象的元素合并为一个steam对象");
stringList.stream().flatMap(c -> Arrays.asList(c).stream()).forEach(System.out::println);
+ // distinct 去除重复元素
+ System.out.println("去除重复元素");
+ stringList.stream().distinct().forEach(System.out::println);
+ // sorted 对元素进行排序
+ System.out.println("排序");
+ stringList.stream().sorted((a,b) -> a.length() - b.length()).forEach(System.out::println);
+ // peek 对每个元素进行特定操作
+ System.out.println("对每个元素进行特定操作");
+ stringList.stream().peek(c -> System.out.println(c.length())).map(p -> p.length() % 2 == 0).forEach(System.out::println);
+ // limit 限制stream中的元素数量
+ System.out.println("限制stream中的元素数量");
+ stringList.stream().limit(1).forEach(System.out::println);
+ //结束
+ // forEach 对每个元素进行指定操作,无返回值
+ //toArray 将流中的元素转为数组
+ System.out.println("将流中的元素转为数组");
+ String[] array1 = stringList.stream().toArray(String[]::new);
+ for (String s : array1) {
+ System.out.println(s);
+ }
+ //reduce 将流中的元素按照指定的操作进行归约,返回一个值
+ // identity是初始值,accumulator是一个二次元操作符,通常用于与流中的元素进行聚合操作
+ System.out.println("归约");
+ Optional reduce = list.stream().map(Integer::bitCount).reduce(Integer::compare);
+ System.out.println(reduce.get());
+ // collect 将流中的元素收集到一个集合中
+ System.out.println("将流中的元素收集到一个集合中");
+ Set collect2 = list.stream().collect(Collectors.toSet());
+ for (Integer i : collect2) {
+ System.out.println(i);
+ }
+ //min 返回最小值 max返回最大值
+ //count 返回流中的个数
+ //allMatch 判断流中的所有元素是否满足给定的条件
+ //noneMatch 判断流中所有的元素是否不满足给定条件
+ //findFirst 返回流的第一个元素
+ System.out.println("返回流的第一个元素");
+ Optional first = stringList.stream().findFirst();
+ System.out.println(first.stream().collect(Collectors.toSet()));
+ //findAny 返回流的任意一个元素
+ // peek 修改元素
+ List copes = new ArrayList<>();
+ for (int i = 1; i <= 3; i++) {
+ Cope cope = new Cope();
+ cope.setCode("code"+i);
+ cope.setType("type"+i);
+ cope.setVal("val"+i);
+ copes.add(cope);
+ }
+ System.out.println(copes);
+ Stream peek = copes.stream().peek(c -> {
+ if (c.getVal().contains("1")){
+ c.setVal("123");
+ }
+ });
+ List collect3 = peek.collect(Collectors.toList());
+ System.out.println(collect3);
+ //
}
}
diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml
new file mode 100644
index 0000000..aa0dfb2
--- /dev/null
+++ b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/EditionMapper.xml
@@ -0,0 +1,71 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ select id, rule_id, version_class, name, version_code, edition_status, rule_status, rule_is_test, edition_content, rule_content from edition
+
+
+
+
+
+
+
+ insert into edition
+
+ rule_id,
+ version_class,
+ name,
+ version_code,
+ edition_content,
+ rule_content,
+
+
+ #{ruleId},
+ #{versionClass},
+ #{name},
+ #{versionCode},
+ #{editionContent},
+ #{ruleContent},
+
+
+
+
+ update edition
+
+ rule_content = #{ruleContent},
+
+ where id = #{id}
+
+
+
+ delete from edition where id = #{id}
+
+
+
+ delete from edition where id in
+
+ #{id}
+
+
+
diff --git a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml
index e3a31c2..e1e0c02 100644
--- a/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml
+++ b/muyu-modules/muyu-goods/src/main/resources/mapper/goods/RuleEngineMapper.xml
@@ -78,6 +78,16 @@
where rule_id = #{ruleId}
+
+ update rule_engine
+ set rule_is_activate = #{ruleIsActivate}
+ where rule_id = #{ruleId};
+
+
+ update rule_engine
+ set rule_status = #{ruleStatus}
+ where rule_id = #{ruleId};
+
delete from rule_engine where rule_id = #{ruleId}
diff --git a/pom.xml b/pom.xml
index fc97f1d..e363204 100644
--- a/pom.xml
+++ b/pom.xml
@@ -215,6 +215,7 @@
muyu-visual
muyu-modules
muyu-common
+ muyu-modules/muyu-goods-test
pom