xignzi006 发布系统代码

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/impl/Ir_sequenceServiceImpl.java

@@ -58,6 +58,18 @@ public class Ir_sequenceServiceImpl extends ServiceImpl<Ir_sequenceMapper, Ir_se
     @Lazy
     protected cn.ibizlab.businesscentral.core.odoo_base.service.IRes_usersService resUsersService;
 
+    @Autowired
+    @Lazy
+    protected cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencecreate_sequenceLogic create_sequenceLogic;
+
+    @Autowired
+    @Lazy
+    protected cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencealter_sequenceLogic alter_sequenceLogic;
+
+    @Autowired
+    @Lazy
+    protected cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencedrop_sequenceLogic drop_sequenceLogic;
+
     protected int batchSize = 500;
 
     @Override
@@ -67,6 +79,7 @@ public class Ir_sequenceServiceImpl extends ServiceImpl<Ir_sequenceMapper, Ir_se
         if(!this.retBool(this.baseMapper.insert(et)))
             return false;
         CachedBeanCopier.copy(get(et.getId()),et);
+        create_sequenceLogic.execute(et);
         return true;
     }
 
@@ -84,6 +97,7 @@ public class Ir_sequenceServiceImpl extends ServiceImpl<Ir_sequenceMapper, Ir_se
          if(!update(et,(Wrapper) et.getUpdateWrapper(true).eq("id",et.getId())))
             return false;
         CachedBeanCopier.copy(get(et.getId()),et);
+        alter_sequenceLogic.execute(et);
         return true;
     }
 
@@ -97,7 +111,10 @@ public class Ir_sequenceServiceImpl extends ServiceImpl<Ir_sequenceMapper, Ir_se
     @Override
     @Transactional
     public boolean remove(Long key) {
+        Ir_sequence et=new Ir_sequence();
+        et.set("id",key);
         boolean result=removeById(key);
+        drop_sequenceLogic.execute(et);
         return result ;
     }
 

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/IIr_sequencealter_sequenceLogic.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[alter_sequence] 对象
+ */
+public interface IIr_sequencealter_sequenceLogic {
+
+    void execute(Ir_sequence et) ;
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/IIr_sequencecreate_sequenceLogic.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[create_sequence] 对象
+ */
+public interface IIr_sequencecreate_sequenceLogic {
+
+    void execute(Ir_sequence et) ;
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/IIr_sequencedrop_sequenceLogic.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[drop_sequence] 对象
+ */
+public interface IIr_sequencedrop_sequenceLogic {
+
+    void execute(Ir_sequence et) ;
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/impl/Ir_sequencealter_sequenceLogicImpl.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic.impl;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.extern.slf4j.Slf4j;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.kie.api.runtime.KieSession;
+import org.kie.api.runtime.KieContainer;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencealter_sequenceLogic;
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[alter_sequence] 对象
+ */
+@Slf4j
+@Service
+public class Ir_sequencealter_sequenceLogicImpl implements IIr_sequencealter_sequenceLogic{
+
+    @Autowired
+    private KieContainer kieContainer;
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIr_sequenceService() {
+        return this.ir_sequenceservice;
+    }
+
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysDefaultService;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIBzSysDefaultService() {
+        return this.iBzSysDefaultService;
+    }
+
+    public void execute(Ir_sequence et){
+
+          KieSession kieSession = null;
+        try{
+           kieSession=kieContainer.newKieSession();
+           kieSession.insert(et); 
+           kieSession.setGlobal("ir_sequencealter_sequencedefault",et);
+           kieSession.setGlobal("ir_sequenceservice",ir_sequenceservice);
+           kieSession.setGlobal("iBzSysIr_sequenceDefaultService",iBzSysDefaultService);
+           kieSession.setGlobal("curuser", cn.ibizlab.businesscentral.util.security.AuthenticationUser.getAuthenticationUser());
+           kieSession.startProcess("cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencealter_sequence");
+
+        }catch(Exception e){
+            throw new RuntimeException("执行[alter_sequence]处理逻辑发生异常"+e);
+        }finally {
+            if(kieSession!=null)
+            kieSession.destroy();
+        }
+    }
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/impl/Ir_sequencecreate_sequenceLogicImpl.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic.impl;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.extern.slf4j.Slf4j;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.kie.api.runtime.KieSession;
+import org.kie.api.runtime.KieContainer;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencecreate_sequenceLogic;
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[create_sequence] 对象
+ */
+@Slf4j
+@Service
+public class Ir_sequencecreate_sequenceLogicImpl implements IIr_sequencecreate_sequenceLogic{
+
+    @Autowired
+    private KieContainer kieContainer;
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIr_sequenceService() {
+        return this.ir_sequenceservice;
+    }
+
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysDefaultService;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIBzSysDefaultService() {
+        return this.iBzSysDefaultService;
+    }
+
+    public void execute(Ir_sequence et){
+
+          KieSession kieSession = null;
+        try{
+           kieSession=kieContainer.newKieSession();
+           kieSession.insert(et); 
+           kieSession.setGlobal("ir_sequencecreate_sequencedefault",et);
+           kieSession.setGlobal("ir_sequenceservice",ir_sequenceservice);
+           kieSession.setGlobal("iBzSysIr_sequenceDefaultService",iBzSysDefaultService);
+           kieSession.setGlobal("curuser", cn.ibizlab.businesscentral.util.security.AuthenticationUser.getAuthenticationUser());
+           kieSession.startProcess("cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencecreate_sequence");
+
+        }catch(Exception e){
+            throw new RuntimeException("执行[create_sequence]处理逻辑发生异常"+e);
+        }finally {
+            if(kieSession!=null)
+            kieSession.destroy();
+        }
+    }
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_ir/service/logic/impl/Ir_sequencedrop_sequenceLogicImpl.java

+package cn.ibizlab.businesscentral.core.odoo_ir.service.logic.impl;
+
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.HashMap;
+
+import lombok.extern.slf4j.Slf4j;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.kie.api.runtime.KieSession;
+import org.kie.api.runtime.KieContainer;
+
+import cn.ibizlab.businesscentral.core.odoo_ir.service.logic.IIr_sequencedrop_sequenceLogic;
+import cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence;
+
+/**
+ * 关系型数据实体[drop_sequence] 对象
+ */
+@Slf4j
+@Service
+public class Ir_sequencedrop_sequenceLogicImpl implements IIr_sequencedrop_sequenceLogic{
+
+    @Autowired
+    private KieContainer kieContainer;
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIr_sequenceService() {
+        return this.ir_sequenceservice;
+    }
+
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysDefaultService;
+
+    public cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService getIBzSysDefaultService() {
+        return this.iBzSysDefaultService;
+    }
+
+    public void execute(Ir_sequence et){
+
+          KieSession kieSession = null;
+        try{
+           kieSession=kieContainer.newKieSession();
+           kieSession.insert(et); 
+           kieSession.setGlobal("ir_sequencedrop_sequencedefault",et);
+           kieSession.setGlobal("ir_sequenceservice",ir_sequenceservice);
+           kieSession.setGlobal("iBzSysIr_sequenceDefaultService",iBzSysDefaultService);
+           kieSession.setGlobal("curuser", cn.ibizlab.businesscentral.util.security.AuthenticationUser.getAuthenticationUser());
+           kieSession.startProcess("cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencedrop_sequence");
+
+        }catch(Exception e){
+            throw new RuntimeException("执行[drop_sequence]处理逻辑发生异常"+e);
+        }finally {
+            if(kieSession!=null)
+            kieSession.destroy();
+        }
+    }
+
+}

businesscentral-core/src/main/resources/rules/Ir_sequencealter_sequenceRule.drl

+package cn.ibizlab.businesscentral.odoo_ir.logic.ir_sequencelogic.alter_sequence;
+import java.util.Map;
+import java.util.HashMap;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.util.StringUtils;
+import org.springframework.util.ObjectUtils;
+import cn.ibizlab.businesscentral.util.errors.BadRequestAlertException;
+global cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence ir_sequencealter_sequencedefault;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysIr_sequenceDefaultService;
+global cn.ibizlab.businesscentral.util.security.AuthenticationUser curuser;
+
+
+no-loop
+
+//逻辑处理节点[开始]
+rule "begin"
+ruleflow-group "ir_sequencealter_sequencebegin"
+    when
+    then
+    end
+
+//逻辑处理节点[alter_sequence]
+rule "deaction1"
+ruleflow-group "ir_sequencealter_sequencedeaction1"
+    when
+    then
+    ir_sequenceservice.alter_sequence(ir_sequencealter_sequencedefault);
+    update(ir_sequencealter_sequencedefault);//更新fact中变量值
+    end
+

businesscentral-core/src/main/resources/rules/Ir_sequencealter_sequenceRuleFlow.bpmn

+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:g="http://www.jboss.org/drools/flow/gpd" xmlns:tns="http://www.jboss.org/drools" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" expressionLanguage="http://www.mvel.org/2.0" id="Definition" name="" targetNamespace="http://www.jboss.org/drools" typeLanguage="http://www.java.com/javaTypes">
+    <process id="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencealter_sequence" isClosed="false" isExecutable="true" name="ScoreRule" processType="Private" tns:packageName="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencealter_sequence">
+        <extensionElements>
+            <tns:import name="java.util.Map" />
+            <tns:import name="org.springframework.util.StringUtils"/>
+            <tns:import name="cn.ibizlab.businesscentral.util.helper.RuleUtils"/>
+        <tns:global identifier="ir_sequencealter_sequencedefault" type="cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence" />
+        </extensionElements>
+     <startEvent id="begin" isInterrupting="true"/>
+     <businessRuleTask activiti:exclusive="true" g:ruleFlowGroup="ir_sequencealter_sequencedeaction1" id="deaction1" implementation="http://www.jboss.org/drools/rule" name="alter_sequence"/>
+     <endEvent id="deaction1_end" name="end"/>
+     <sequenceFlow id="deaction1_end_line" sourceRef="deaction1" targetRef="deaction1_end"/>
+     <sequenceFlow id="begin_deaction1" sourceRef="begin" targetRef="deaction1">
+     </sequenceFlow>
+    </process>
+</definitions>
+

businesscentral-core/src/main/resources/rules/Ir_sequencecreate_sequenceRule.drl

+package cn.ibizlab.businesscentral.odoo_ir.logic.ir_sequencelogic.create_sequence;
+import java.util.Map;
+import java.util.HashMap;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.util.StringUtils;
+import org.springframework.util.ObjectUtils;
+import cn.ibizlab.businesscentral.util.errors.BadRequestAlertException;
+global cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence ir_sequencecreate_sequencedefault;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysIr_sequenceDefaultService;
+global cn.ibizlab.businesscentral.util.security.AuthenticationUser curuser;
+
+
+no-loop
+
+//逻辑处理节点[开始]
+rule "begin"
+ruleflow-group "ir_sequencecreate_sequencebegin"
+    when
+    then
+    end
+
+//逻辑处理节点[create_sequence]
+rule "deaction1"
+ruleflow-group "ir_sequencecreate_sequencedeaction1"
+    when
+    then
+    ir_sequenceservice.create_sequence(ir_sequencecreate_sequencedefault);
+    update(ir_sequencecreate_sequencedefault);//更新fact中变量值
+    end
+

businesscentral-core/src/main/resources/rules/Ir_sequencecreate_sequenceRuleFlow.bpmn

+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:g="http://www.jboss.org/drools/flow/gpd" xmlns:tns="http://www.jboss.org/drools" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" expressionLanguage="http://www.mvel.org/2.0" id="Definition" name="" targetNamespace="http://www.jboss.org/drools" typeLanguage="http://www.java.com/javaTypes">
+    <process id="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencecreate_sequence" isClosed="false" isExecutable="true" name="ScoreRule" processType="Private" tns:packageName="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencecreate_sequence">
+        <extensionElements>
+            <tns:import name="java.util.Map" />
+            <tns:import name="org.springframework.util.StringUtils"/>
+            <tns:import name="cn.ibizlab.businesscentral.util.helper.RuleUtils"/>
+        <tns:global identifier="ir_sequencecreate_sequencedefault" type="cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence" />
+        </extensionElements>
+     <startEvent id="begin" isInterrupting="true"/>
+     <businessRuleTask activiti:exclusive="true" g:ruleFlowGroup="ir_sequencecreate_sequencedeaction1" id="deaction1" implementation="http://www.jboss.org/drools/rule" name="create_sequence"/>
+     <endEvent id="deaction1_end" name="end"/>
+     <sequenceFlow id="deaction1_end_line" sourceRef="deaction1" targetRef="deaction1_end"/>
+     <sequenceFlow id="begin_deaction1" sourceRef="begin" targetRef="deaction1">
+     </sequenceFlow>
+    </process>
+</definitions>
+

businesscentral-core/src/main/resources/rules/Ir_sequencedrop_sequenceRule.drl

+package cn.ibizlab.businesscentral.odoo_ir.logic.ir_sequencelogic.drop_sequence;
+import java.util.Map;
+import java.util.HashMap;
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.util.StringUtils;
+import org.springframework.util.ObjectUtils;
+import cn.ibizlab.businesscentral.util.errors.BadRequestAlertException;
+global cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence ir_sequencedrop_sequencedefault;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService ir_sequenceservice;
+global cn.ibizlab.businesscentral.core.odoo_ir.service.IIr_sequenceService iBzSysIr_sequenceDefaultService;
+global cn.ibizlab.businesscentral.util.security.AuthenticationUser curuser;
+
+
+no-loop
+
+//逻辑处理节点[drop_sequence]
+rule "deaction1"
+ruleflow-group "ir_sequencedrop_sequencedeaction1"
+    when
+    then
+    ir_sequenceservice.drop_sequence(ir_sequencedrop_sequencedefault);
+    update(ir_sequencedrop_sequencedefault);//更新fact中变量值
+    end
+
+//逻辑处理节点[开始]
+rule "begin"
+ruleflow-group "ir_sequencedrop_sequencebegin"
+    when
+    then
+    end
+

businesscentral-core/src/main/resources/rules/Ir_sequencedrop_sequenceRuleFlow.bpmn

+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:g="http://www.jboss.org/drools/flow/gpd" xmlns:tns="http://www.jboss.org/drools" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" expressionLanguage="http://www.mvel.org/2.0" id="Definition" name="" targetNamespace="http://www.jboss.org/drools" typeLanguage="http://www.java.com/javaTypes">
+    <process id="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencedrop_sequence" isClosed="false" isExecutable="true" name="ScoreRule" processType="Private" tns:packageName="cn.ibizlab.businesscentral.core.odoo_ir.service.logic.ir_sequencedrop_sequence">
+        <extensionElements>
+            <tns:import name="java.util.Map" />
+            <tns:import name="org.springframework.util.StringUtils"/>
+            <tns:import name="cn.ibizlab.businesscentral.util.helper.RuleUtils"/>
+        <tns:global identifier="ir_sequencedrop_sequencedefault" type="cn.ibizlab.businesscentral.core.odoo_ir.domain.Ir_sequence" />
+        </extensionElements>
+     <businessRuleTask activiti:exclusive="true" g:ruleFlowGroup="ir_sequencedrop_sequencedeaction1" id="deaction1" implementation="http://www.jboss.org/drools/rule" name="drop_sequence"/>
+     <endEvent id="deaction1_end" name="end"/>
+     <sequenceFlow id="deaction1_end_line" sourceRef="deaction1" targetRef="deaction1_end"/>
+     <startEvent id="begin" isInterrupting="true"/>
+     <sequenceFlow id="begin_deaction1" sourceRef="begin" targetRef="deaction1">
+     </sequenceFlow>
+    </process>
+</definitions>
+