xignzi006 发布系统代码

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/client/mail_messageFallback.java

@@ -69,6 +69,10 @@ public class mail_messageFallback implements mail_messageFeignClient{
      }
 
 
+    public Mail_message generate_tracking_message_id( Long id, Mail_message mail_message){
+            return null;
+     }
+
     public Boolean save(Mail_message mail_message){
             return false;
      }

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/client/mail_messageFeignClient.java

@@ -64,6 +64,10 @@ public interface mail_messageFeignClient {
     Boolean checkKey(@RequestBody Mail_message mail_message);
 
 
+    @RequestMapping(method = RequestMethod.POST, value = "/mail_messages/{id}/generate_tracking_message_id")
+    Mail_message generate_tracking_message_id(@PathVariable("id") Long id,@RequestBody Mail_message mail_message);
+
+
     @RequestMapping(method = RequestMethod.POST, value = "/mail_messages/save")
     Boolean save(@RequestBody Mail_message mail_message);
 

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/service/IMail_messageService.java

@@ -35,6 +35,7 @@ public interface IMail_messageService extends IService<Mail_message>{
     Mail_message get(Long key) ;
     Mail_message getDraft(Mail_message et) ;
     boolean checkKey(Mail_message et) ;
+    Mail_message generate_tracking_message_id(Mail_message et) ;
     boolean save(Mail_message et) ;
     void saveBatch(List<Mail_message> list) ;
     Page<Mail_message> searchDefault(Mail_messageSearchContext context) ;

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/service/impl/Mail_messageServiceImpl.java

@@ -89,6 +89,10 @@ public class Mail_messageServiceImpl extends EBSServiceImpl<Mail_messageMapper,
     @Lazy
     protected cn.ibizlab.businesscentral.core.odoo_base.service.IRes_usersService resUsersService;
 
+    @Autowired
+    @Lazy
+    protected cn.ibizlab.businesscentral.core.odoo_mail.service.logic.IMail_messagegenerate_tracking_message_idLogic generate_tracking_message_idLogic;
+
     protected int batchSize = 500;
 
     public String getIrModel(){
@@ -102,6 +106,7 @@ public class Mail_messageServiceImpl extends EBSServiceImpl<Mail_messageMapper,
         boolean mail_create_nolog = et.get("mail_create_nolog") != null;
         boolean mail_notrack = et.get("mail_notrack") != null;
         fillParentData(et);
+        generate_tracking_message_idLogic.execute(et);
         if(!this.retBool(this.baseMapper.insert(et)))
             return false;
         CachedBeanCopier.copy(get(et.getId()),et);
@@ -187,6 +192,13 @@ public class Mail_messageServiceImpl extends EBSServiceImpl<Mail_messageMapper,
     public boolean checkKey(Mail_message et) {
         return (!ObjectUtils.isEmpty(et.getId()))&&(!Objects.isNull(this.getById(et.getId())));
     }
+    @Override
+    @Transactional
+    public Mail_message generate_tracking_message_id(Mail_message et) {
+        //自定义代码
+        return et;
+    }
+
     @Override
     @Transactional
     public boolean save(Mail_message et) {

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/service/logic/IMail_messagegenerate_tracking_message_idLogic.java

+package cn.ibizlab.businesscentral.core.odoo_mail.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_mail.domain.Mail_message;
+
+/**
+ * 关系型数据实体[generate_tracking_message_id] 对象
+ */
+public interface IMail_messagegenerate_tracking_message_idLogic {
+
+    void execute(Mail_message et) ;
+
+}

businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_mail/service/logic/impl/Mail_messagegenerate_tracking_message_idLogicImpl.java

+package cn.ibizlab.businesscentral.core.odoo_mail.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_mail.service.logic.IMail_messagegenerate_tracking_message_idLogic;
+import cn.ibizlab.businesscentral.core.odoo_mail.domain.Mail_message;
+
+/**
+ * 关系型数据实体[generate_tracking_message_id] 对象
+ */
+@Slf4j
+@Service
+public class Mail_messagegenerate_tracking_message_idLogicImpl implements IMail_messagegenerate_tracking_message_idLogic{
+
+    @Autowired
+    private KieContainer kieContainer;
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService mail_messageservice;
+
+    public cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService getMail_messageService() {
+        return this.mail_messageservice;
+    }
+
+
+    @Autowired
+    private cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService iBzSysDefaultService;
+
+    public cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService getIBzSysDefaultService() {
+        return this.iBzSysDefaultService;
+    }
+
+    public void execute(Mail_message et){
+
+          KieSession kieSession = null;
+        try{
+           kieSession=kieContainer.newKieSession();
+           kieSession.insert(et); 
+           kieSession.setGlobal("mail_messagegenerate_tracking_message_iddefault",et);
+           kieSession.setGlobal("mail_messageservice",mail_messageservice);
+           kieSession.setGlobal("iBzSysMail_messageDefaultService",iBzSysDefaultService);
+           kieSession.setGlobal("curuser", cn.ibizlab.businesscentral.util.security.AuthenticationUser.getAuthenticationUser());
+           kieSession.startProcess("cn.ibizlab.businesscentral.core.odoo_mail.service.logic.mail_messagegenerate_tracking_message_id");
+
+        }catch(Exception e){
+            throw new RuntimeException("执行[generate_tracking_message_id]处理逻辑发生异常"+e);
+        }finally {
+            if(kieSession!=null)
+            kieSession.destroy();
+        }
+    }
+
+}

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

+package cn.ibizlab.businesscentral.odoo_mail.logic.mail_messagelogic.generate_tracking_message_id;
+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_mail.domain.Mail_message mail_messagegenerate_tracking_message_iddefault;
+global cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService mail_messageservice;
+global cn.ibizlab.businesscentral.core.odoo_mail.service.IMail_messageService iBzSysMail_messageDefaultService;
+global cn.ibizlab.businesscentral.util.security.AuthenticationUser curuser;
+
+
+no-loop
+
+//逻辑处理节点[generate_tracking_message_id]
+rule "deaction1"
+ruleflow-group "mail_messagegenerate_tracking_message_iddeaction1"
+    when
+    then
+    mail_messageservice.generate_tracking_message_id(mail_messagegenerate_tracking_message_iddefault);
+    update(mail_messagegenerate_tracking_message_iddefault);//更新fact中变量值
+    end
+
+//逻辑处理节点[开始]
+rule "begin"
+ruleflow-group "mail_messagegenerate_tracking_message_idbegin"
+    when
+    then
+    end
+

businesscentral-core/src/main/resources/rules/Mail_messagegenerate_tracking_message_idRuleFlow.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_mail.service.logic.mail_messagegenerate_tracking_message_id" isClosed="false" isExecutable="true" name="ScoreRule" processType="Private" tns:packageName="cn.ibizlab.businesscentral.core.odoo_mail.service.logic.mail_messagegenerate_tracking_message_id">
+        <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="mail_messagegenerate_tracking_message_iddefault" type="cn.ibizlab.businesscentral.core.odoo_mail.domain.Mail_message" />
+        </extensionElements>
+     <businessRuleTask activiti:exclusive="true" g:ruleFlowGroup="mail_messagegenerate_tracking_message_iddeaction1" id="deaction1" implementation="http://www.jboss.org/drools/rule" name="generate_tracking_message_id"/>
+     <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>
+

businesscentral-provider/businesscentral-provider-core/src/main/java/cn/ibizlab/businesscentral/core/rest/Mail_messageResource.java

@@ -121,6 +121,17 @@ public class Mail_messageResource {
         return  ResponseEntity.status(HttpStatus.OK).body(mail_messageService.checkKey(mail_messageMapping.toDomain(mail_messagedto)));
     }
 
+    @PreAuthorize("hasAnyAuthority('ROLE_SUPERADMIN','iBizBusinessCentral-Mail_message-Generate_tracking_message_id-all')")
+    @ApiOperation(value = "generate_tracking_message_id", tags = {"消息" },  notes = "generate_tracking_message_id")
+	@RequestMapping(method = RequestMethod.POST, value = "/mail_messages/{mail_message_id}/generate_tracking_message_id")
+    public ResponseEntity<Mail_messageDTO> generate_tracking_message_id(@PathVariable("mail_message_id") Long mail_message_id, @RequestBody Mail_messageDTO mail_messagedto) {
+        Mail_message domain = mail_messageMapping.toDomain(mail_messagedto);
+        domain.setId(mail_message_id);
+        domain = mail_messageService.generate_tracking_message_id(domain);
+        mail_messagedto = mail_messageMapping.toDto(domain);
+        return ResponseEntity.status(HttpStatus.OK).body(mail_messagedto);
+    }
+
     @PreAuthorize("hasPermission(this.mail_messageMapping.toDomain(#mail_messagedto),'iBizBusinessCentral-Mail_message-Save')")
     @ApiOperation(value = "保存消息", tags = {"消息" },  notes = "保存消息")
 	@RequestMapping(method = RequestMethod.POST, value = "/mail_messages/save")