当前位置:首页 > JAVA > 正文内容

x2-300单据提交后数据如何分发到其他中心的档案中

高老师4个月前 (11-01)JAVA160

x2-300中通过jms提交到档案中心,一般我们只调用档案中心的接口,例如

post/archive/v1/style/tab/save

post请求档案中心的接口发送数据,但是这样只是修改了档案中心的档案数据,其他中心有相同的档案数据没有修改。例如商品档案,商品档案在每个中心都有自己的表需要同步。因为我们需要在每个中心定义相同的接口并在底层注册接口信息。


在底层包com.x3.bills.common.branch.core中可以定义拦截请求信息,例如

package com.x3.bills.common.branch.core.styletab;

import com.x3.base.core.branch.Branch;
import com.x3.base.core.branch.BranchEntity;
import com.x3.base.core.branch.BranchUrlEntity;
import com.x3.base.core.branch.IBranchService;
import com.x3.base.core.jackson.JSON;
import com.x3.base.core.util.ServiceUtil;
import com.x3.bills.common.branch.core.styletab.request.ArchiveStyleTabRequest;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 拦截档案中心-款式标签保存接口,提交至各大数据中心
 */
@Branch(url = "post/archive/v1/style/tab/save", tag = "拦截档案中心-款式标签保存接口,提交至各大数据中心")
@Component
public class StyleTabBaseBranchServiceImpl implements IBranchService {

    @Override
    public BranchEntity getNewDate(Object postData) {

        // 获取原请求参数
        String request_json = JSON.toJSONString(postData);
        List<ArchiveStyleTabRequest> billsStyleList = JSON.parseArray(request_json, ArchiveStyleTabRequest.class);

        // 提交其他中心地址
        BranchUrlEntity bi_url = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BI_ID+"/bi/archive/v1/style/tab/save");
        BranchUrlEntity bill_url = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BILLS_ID+"/bill/archive/v1/style/tab/save");
        BranchUrlEntity vipUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_VIPBIllS_ID+"/vip/bill/archive/v1/style/tab/save");
        BranchUrlEntity biPojoUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BI_POJO_ID+"/bi/pojo/archive/v1/style/tab/save");
        BranchUrlEntity clickHoseUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_CLICKHOUSE_ID+"/clickhouse/archive/v1/style/tab/save");

        //添加实体
        BranchEntity branchEntity = new BranchEntity();
        branchEntity.add(bi_url);
        branchEntity.add(bill_url);
        branchEntity.add(vipUrl);
        branchEntity.add(biPojoUrl);
        branchEntity.add(clickHoseUrl);
        branchEntity.setData(billsStyleList);
        return branchEntity;
    }
}

这是我定义的拦截配置,底层会将@Branch(url = "post/archive/v1/style/tab/save")配置的url请求拦截,并同步将请求信息发到其他中心地址,所以需要在其他中心实现对应的接口地址。

实现起来很麻烦,这种方案是否可以更好为其他自动同步的方案好一点呢?

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/846.html

分享给朋友:

“x2-300单据提交后数据如何分发到其他中心的档案中” 的相关文章

java增强型for循环

java增强型for循环

Java5 引入了一种主要用于数组的增强型 for 循环,类似js中的for inpublic class Member {     public static void main(String[]&...

java Character 类,java判断字符是否是一个字母,java判断字符是否是一个数字,java判断字符是否是一个空白,java判断字符是否是小写字母,java判断字符是否是大写字母,java转换字符为大写,java转换字符为小写

java Character 类,java判断字符是否是一个字母,java判断字符是否是一个数字,java判断字符是否是一个空白,java判断字符是否是小写字母,java判断字符是否是大写字母,java转换字符为大写,java转换字符为小写

java判断字符是否是一个字母System.out.println(Character.isLetter('a'));java判断字符是否是一个数字System.out.println(Character.isDigit('0'));java判断字符是否是一个空白Sy...

java睡眠方法,java睡眠函数,java睡眠时间,java睡眠一分钟,java睡眠五秒钟

java睡眠方法,java睡眠函数,java睡眠时间,java睡眠一分钟,java睡眠五秒钟

(1).java睡眠函数Thread.sleep(时间);  //单位为毫秒(2).java睡眠函数例子Date dNow = new Date(); SimpleDateFormat ft = new&nbs...

java正则表达式捕获组

java正则表达式捕获组

java正则表达式的捕获组捕获组可以将匹配到的结果根据正则中的括号进行分组,这里变量我加了$符,php转java的坏习惯,懒得改了,能跑就行// 匹配字符串 String $line = "gaojiufeng 1994! ok?...

java匹配一个字符串在另外一个字符串中出现的次数,java正则start,java正则end

java匹配一个字符串在另外一个字符串中出现的次数,java正则start,java正则end

java匹配一个字符串在另外一个字符串中出现的次数,java正则start,java正则end// 正则 String pattern = "\\bgao\\b"; // 字符串 String content ...

java lookingAt匹配字符串和java matches匹配字符串,java正则replaceAll,java正则replaceFirst

java lookingAt匹配字符串和java matches匹配字符串,java正则replaceAll,java正则replaceFirst

(4).java lookingAt匹配字符串和java matches匹配字符串lookingAt不要求整个字符串全匹配,例如me和me_you都是匹配的,但是lookingAt从第一个字符串开始匹配,匹配失败了也不会继续匹配,意味着me和you_me是无法匹配的matches匹配字符串要求全部匹...