hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加供应商同步更新插件

This commit is contained in:
476474485@qq.com 2025-03-07 18:16:59 +08:00
parent a6933e5a1d
commit e43c8d6ac5
7 changed files with 609 additions and 0 deletions

18
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/dao/IWsCustomerSynchronizationEventDao.java Normal file
View File

@ -0,0 +1,18 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.dao;
import com.hzya.frame.basedao.dao.IBaseDao;
import com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity;
/****
* 万盛客商档案同步插件
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 10:57
* @param
* @return
**/
public interface IWsCustomerSynchronizationEventDao extends IBaseDao<WsCustomerSynchronizationEventEntity, String> {
}

18
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/dao/impl/WsCustomerSynchronizationEventDaoImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.dao.impl;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import com.hzya.frame.plugin.wscustomersynchronizationevent.dao.IWsCustomerSynchronizationEventDao;
import com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity;
/***
* 万盛客商
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 11:12
* @param
* @return
**/
public class WsCustomerSynchronizationEventDaoImpl extends MybatisGenericDao<WsCustomerSynchronizationEventEntity, String> implements IWsCustomerSynchronizationEventDao {
}

16
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/entity/WsCustomerSynchronizationEventEntity.java Normal file
View File

@ -0,0 +1,16 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.entity;
import com.hzya.frame.web.entity.BaseEntity;
/****
* 万盛客商档案实体类
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 10:53
* @param
* @return
**/
public class WsCustomerSynchronizationEventEntity extends BaseEntity {
}

31
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/entity/WsCustomerSynchronizationEventEntity.xml Normal file
View File

@ -0,0 +1,31 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.plugin.masterData.dao.impl.MdmDaoImpl">
<resultMap id="get-WsCustomerSynchronizationEventEntity-result" type="com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity" >
<result property="id" column="id" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询的字段-->
<sql id = "WsCustomerSynchronizationEventEntity_Base_Column_List">
id
</sql>
<!-- 查询 采用==查询 -->
<select id="entity_list_base" resultMap="get-WsCustomerSynchronizationEventEntity-result" parameterType = "com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity">
select
<include refid="WsCustomerSynchronizationEventEntity_Base_Column_List" />
from mdm_customer
<trim prefix="where" prefixOverrides="and">
<if test="id != null and id != ''"> and id = #{id} </if>
</trim>
<if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
<if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
</select>
</mapper>

64
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/plugin/WsCustomerSynchronizationEventPluginInitializer.java Normal file
View File

@ -0,0 +1,64 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.plugin;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.wscustomersynchronizationevent.service.IWsCustomerSynchronizationEventService;
import com.hzya.frame.sysnew.comparison.masterData.service.IMasterDataService;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
/**
* 主数据同步
*
* @author makejava
* @since 2024-06-21 13:52:35
*/
public class WsCustomerSynchronizationEventPluginInitializer extends PluginBaseEntity{
Logger logger = LoggerFactory.getLogger(WsCustomerSynchronizationEventPluginInitializer.class);
@Autowired
private IWsCustomerSynchronizationEventService customerSynchronizationEventService;
@Override
public void initialize() {
logger.info(getPluginLabel() + "執行初始化方法initialize()");
}
@Override
public void destroy() {
logger.info(getPluginLabel() + "執行銷毀方法destroy()");
}
@Override
public String getPluginId() {
return "WsCustomerSynchronizationEventPluginInitializer";
}
@Override
public String getPluginName() {
return "万盛A8客商接收数据插件";
}
@Override
public String getPluginLabel() {
return "WsCustomerSynchronizationEventPluginInitializer";
}
@Override
public String getPluginType() {
return "1";
}
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) {
try {
logger.info("======开始执行客商档案同步========");
return customerSynchronizationEventService.customerSynchronization(requestJson);
// return masterDataService.queryArchives(requestJson);
}catch (Exception e){
logger.info("======客商档案同步失败:{}========",e.getMessage());
e.printStackTrace();
}
return null;
}
}

28
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/service/IWsCustomerSynchronizationEventService.java Normal file
View File

@ -0,0 +1,28 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.service;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.basedao.service.IBaseService;
import com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity;
import com.hzya.frame.web.entity.JsonResultEntity;
/***
* 万盛客商档案同步插件
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 10:55
* @param
* @return
**/
public interface IWsCustomerSynchronizationEventService extends IBaseService<WsCustomerSynchronizationEventEntity, String> {
/****
* 万盛客商档案同步插件，根据不同类型事件处理客商信息
* @content: onBeforeStart 发起前验证供应商重复 onProcessFinished 结束后同步数据到U8C
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 14:11
* @param
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
JsonResultEntity customerSynchronization(JSONObject requestJson);
}

434
base-buildpackage/src/main/java/com/hzya/frame/plugin/wscustomersynchronizationevent/service/impl/WsCustomerSynchronizationEventServiceImpl.java Normal file
View File

@ -0,0 +1,434 @@
package com.hzya.frame.plugin.wscustomersynchronizationevent.service.impl;
import cn.hutool.core.map.MapBuilder;
import cn.hutool.crypto.SecureUtil;
import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.basedao.service.impl.BaseService;
import com.hzya.frame.plugin.wscustomersynchronizationevent.dao.IWsCustomerSynchronizationEventDao;
import com.hzya.frame.plugin.wscustomersynchronizationevent.entity.WsCustomerSynchronizationEventEntity;
import com.hzya.frame.plugin.wscustomersynchronizationevent.service.IWsCustomerSynchronizationEventService;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.HashMap;
import java.util.Map;
/***
* 万盛客商档案同步插件
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 10:56
* @param
* @return
**/
public class WsCustomerSynchronizationEventServiceImpl extends BaseService<WsCustomerSynchronizationEventEntity, String> implements IWsCustomerSynchronizationEventService {
private IWsCustomerSynchronizationEventDao wsCustomerSynchronizationEventDao;
@Autowired
public void setWsCustomerSynchronizationEventDao(IWsCustomerSynchronizationEventDao wsCustomerSynchronizationEventDao) {
this.wsCustomerSynchronizationEventDao = wsCustomerSynchronizationEventDao;
this.dao = wsCustomerSynchronizationEventDao;
}
@Override
public JsonResultEntity customerSynchronization(JSONObject requestJson) {
JSONObject reqJson = new JSONObject();
JSONObject jsonStr = requestJson.getJSONObject("jsonStr");
JSONObject businessDataStr = jsonStr.getJSONObject("businessDataStr");
String formAppId = requestJson.getString("formAppId");
String eventType = requestJson.getString("eventType");
switch (eventType){
case "onBeforeStart":
//发起前事件，验证供应商重复
return validateCustomerName( businessDataStr);
case "onBeforeFinishWorkitem":
//发起前事件，OA插件错误,临时配置事件
return validateCustomerName( businessDataStr);
case "onProcessFinished":
//流程结束事件，同步客商到U8C
return optionCustomerSynchronization(businessDataStr);
default:
return BaseResult.getFailureMessageEntity("未匹配到流程监听事件！当前传入的eventType："+eventType);
}
}
/****
* 验证客商档案重复
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-03 15:22
* @param
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
private JsonResultEntity validateCustomerName(JSONObject data){
JSONObject formBean = data.getJSONObject("formmain_4389");
//客商名称
String field0006 = formBean.getString("field0006");
//纳税人登记号
String field0007 = formBean.getString("field0007");
JSONObject requestJson = new JSONObject();
requestJson.put("custname",field0006);
requestJson.put("taxpayer",field0007);
String body = requestApi("validateCustomerName",requestJson, "800054","8000540095",null);
JSONObject req = JSON.parseObject(body);
boolean flag = req.getBoolean("flag");
if(flag){
JSONObject attribute = req.getJSONObject("attribute");
String status = attribute.getString("status");
if("success".equals(status)){
JSONObject detailsData = attribute.getJSONObject("data");
Integer allcount = detailsData.getInteger("allcount");
if(allcount>0){
return BaseResult.getFailureMessageEntity("客商名称+纳税人识别号重复！");
}else{
return BaseResult.getSuccessMessageEntity("客商未重复！");
}
}else{
return BaseResult.getFailureMessageEntity("转发失败！");
}
}else{
return BaseResult.getFailureMessageEntity("转发失败！"+req.getString("msg"));
}
}
/****
* 执行客商同步新增和分配
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-04 10:45
* @param
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
private JsonResultEntity optionCustomerSynchronization(JSONObject data) {
JSONObject formBean = data.getJSONObject("formmain_4389");
//客商名称
String field0006 = formBean.getString("field0006");
//纳税人登记号
String field0007 = formBean.getString("field0007");
//绑定客商参数
JSONObject requestJson = bindMerchantParameters(data);
String apiCode = "8000540093";
String body = requestApi("optionCustomerSynchronization客商新增",requestJson, "800054",apiCode,null);
JSONObject req = JSON.parseObject(body);
boolean flag = req.getBoolean("flag");
String pk_cubasdoc = null;
if (flag) {
JSONObject attribute = req.getJSONObject("attribute");
String status = attribute.getString("status");
if ("success".equals(status)) {
JSONArray returnData = attribute.getJSONArray("data");
if(null != returnData && returnData.size() >0){
pk_cubasdoc = returnData.getJSONObject(0).getJSONObject("parentvo").getString("pk_cubasdoc");
String custcode = returnData.getJSONObject(0).getJSONObject("parentvo").getString("custcode");
//执行客商档案编码回传OA
updateCustomerCode(custcode);
}
logger.info("客商新增成功！返回数据",body);
} else {
logger.info("客商新增失败！返回数据",body);
}
} else {
return BaseResult.getFailureMessageEntity("转发失败！" + req.getJSONObject("attribute").getString("errormsg"));
}
//绑定客商分配参数
requestJson = bindMerchantDefineParameters(data,pk_cubasdoc);
body = requestApi("optionCustomerSynchronization客商分配",requestJson, "800054","8000540094",null);
req = JSON.parseObject(body);
flag = req.getBoolean("flag");
if (flag) {
JSONObject attribute = req.getJSONObject("attribute");
String status = attribute.getString("status");
if ("success".equals(status)) {
logger.info("客商分配成功！返回数据",body);
} else {
logger.info("客商分配失败！返回数据",body);
}
} else {
return BaseResult.getFailureMessageEntity("转发失败！" + req.getJSONObject("attribute").getString("errormsg"));
}
return BaseResult.getSuccessMessageEntity("执行客商同步方法成功");
}
/***
* 更新OA客商编码
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-07 16:43
* @param
* @return com.alibaba.fastjson.JSONObject
**/
private JSONObject updateCustomerCode(String code) {
String sql="update formmain_0013 set field0002 = '222' where id = '-1747569164838812797' ";
String md5 = SecureUtil.md5(sql);
System.out.println("明文摘要"+md5);
String key = "`o7eotan9ws8c:aj";
String encrypt = SecureUtil.aes(key.getBytes()).encryptHex(sql);
JSONObject requestJson = new JSONObject();
requestJson.put("userName","hzya_rest");
requestJson.put("password","45562434-8459-47b4-8df0-78fad8405bc4");
requestJson.put("data",md5);
requestJson.put("sign",encrypt);
String tokenRest = requestApi("获取token", requestJson,"800055", "8000550010",null);
String token = JSON.parseObject(tokenRest).getJSONObject("attribute").getString("id");
String result = requestApi("更新A8客商档案", requestJson,"800055", "8000550000",token);
//调用OArest接口
logger.info("更新A8客商档案结果:"+result);
return null;
}
/***
* 绑定客商分配参数
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-05 15:02
* @param
* @param pk_cubasdoc
* @return com.alibaba.fastjson.JSONObject
**/
private JSONObject bindMerchantDefineParameters(JSONObject data, String pk_cubasdoc) {
JSONObject formBean = data.getJSONObject("formmain_4389");
JSONObject returnData = new JSONObject();
JSONArray custbasvo = new JSONArray();
//客商档案
JSONObject customer = new JSONObject();
//币种类别
String pk_currtype = formBean.getString("field0028");
switch (pk_currtype){
case "-4050088431526461175":
//欧元
pk_currtype = "EUR";
break;
case "-715249687436703161":
//港币
pk_currtype = "HKD";
break;
case "-608291659984190122":
//日元
pk_currtype = "IPY";
break;
case "-7769974812583704757":
//英镑
pk_currtype = "GBP";
break;
case "169453635852845727":
//新台币
pk_currtype = "NTD";
break;
case "-4870779097911440184":
//比素
pk_currtype = "MXN";
break;
case "-3124898727237565150":
//人民币
pk_currtype = "CNY";
break;
case "-7439566099063946667":
//美元
pk_currtype = "USD.";
break;
case "-5937286571420073707":
//泰铢
pk_currtype = "THB";
break;
default:
pk_currtype = null;
break;
}
customer.put("pk_currtype1",pk_currtype);
//公司 TODO 修改为取编码 pk_corp
// customer.put("pk_corp",formBean.getString("field0056"));
customer.put("pk_corp",formBean.getString("field0056"));
String custprop = formBean.getString("field0027");
//客商属性 0：客户，1：供应商，2 ：客商
switch (custprop){
case "4109154014131407336":
//客户
custprop = "0";
break;
case "-6536959240623403744":
//供应商
custprop = "1";
break;
case "5695613751532077780":
//客商
custprop = "2";
break;
default:
custprop = null;
break;
}
customer.put("custprop",custprop);
//客商ID
customer.put("pk_cubasdoc",pk_cubasdoc);
custbasvo.add(customer);
returnData.put("custbasvo",custbasvo);
return returnData;
}
/****
* 请求API
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-04 16:52
* @param
* @return java.lang.String
**/
private String requestApi(String method, JSONObject requestJson, String appId,String apiCode,String token) {
Map<String, String> headerMap = MapBuilder.<String, String>create(true)
.put("apiCode", String.valueOf(apiCode))
//这里用中台做为发送方
.put("publicKey", "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj")
.put("secretKey", "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")
.put("appId",appId)
.build();
if(null != token){
headerMap .put("token",token);
}
String body = HttpRequest.post("http://127.0.0.1:10086/kangarooDataCenterV3/entranceController/externalCallInterface").addHeaders(headerMap).body(requestJson.toJSONString()).timeout(60000).execute().body();
logger.info("中台转发到ESB"+method+":{}", body);
return body;
}
/****
* 绑定OA和U8C客商参数
* @content:
* @author 👻👻👻👻👻👻👻👻 gjh
* @date 2025-03-04 10:53
* @param
* @return com.alibaba.fastjson.JSONObject
**/
private JSONObject bindMerchantParameters(JSONObject data) {
JSONObject formBean = data.getJSONObject("formmain_4389");
JSONObject returnData = new JSONObject();
JSONArray cbdocvo = new JSONArray();
//客商档案
JSONObject customer = new JSONObject();
JSONArray banks = new JSONArray();
JSONObject bank = new JSONObject();
bank.put("accaddr", "银行地址");
//银行账号
bank.put("account", formBean.getString("field0011"));
//账户名称
bank.put("accountname", formBean.getString("field0012"));
bank.put("defflag", "Y");
bank.put("memo", formBean.getString("field0054"));
//开户银行
bank.put("pk_bankdoc", formBean.getString("field0013"));
//银行类别 TODO 修改为取编码
bank.put("banktypename", formBean.getString("field0014"));
//公司 TODO 修改为取编码 pk_corp
bank.put("pk_corp",formBean.getString("field0056"));
//币种类别
String pk_currtype = formBean.getString("field0028");
switch (pk_currtype){
case "-4050088431526461175":
//欧元
pk_currtype = "EUR";
break;
case "-715249687436703161":
//港币
pk_currtype = "HKD";
break;
case "-608291659984190122":
//日元
pk_currtype = "IPY";
break;
case "-7769974812583704757":
//英镑
pk_currtype = "GBP";
break;
case "169453635852845727":
//新台币
pk_currtype = "NTD";
break;
case "-4870779097911440184":
//比素
pk_currtype = "MXN";
break;
case "-3124898727237565150":
//人民币
pk_currtype = "CNY";
break;
case "-7439566099063946667":
//美元
pk_currtype = "USD.";
break;
case "-5937286571420073707":
//泰铢
pk_currtype = "THB";
break;
default:
pk_currtype = null;
break;
}
bank.put("pk_currtype",pk_currtype);
banks.add(bank);
JSONObject parentvo = new JSONObject();
//创建人 TODO 修改为取编码
parentvo.put("creator",formBean.getString("field0019"));
//客商名称
parentvo.put("custname",formBean.getString("field0006"));
//客商类型（0 - 外部单位1 - 内部核算单位2 - 内部法人单位3 - 内部渠道成员）
String custprop = formBean.getString("field0026");
switch (custprop){
case "-5116388890160378443":
custprop = "0";
break;
case "8996290534573949076":
custprop = "1";
break;
case "-2495523144656008721":
custprop = "2";
break;
case "7042886455598794854":
custprop = "3";
break;
default:
custprop = null;
break;
}
parentvo.put("custprop", custprop);
//客商简称
parentvo.put("custshortname",formBean.getString("field0001"));
//币种
parentvo.put("def1111",formBean.getString("field0028"));
//邮箱
parentvo.put("email",formBean.getString("field0052"));
//联系人1
parentvo.put("linkman1",formBean.getString("field0010"));
parentvo.put("memo",formBean.getString("field0054"));
//手机
parentvo.put("mobilephone1",formBean.getString("field0008"));
//所属地区编码 TODO 修改为取编码
parentvo.put("pk_areacl",formBean.getString("field0034"));
//对应公司
parentvo.put("pk_corp1",formBean.getString("field0056"));
//总公司名称 TODO 修改为取编码
parentvo.put("pk_cubasdoc1",formBean.getString("field0022"));
//纳税人识别号
parentvo.put("taxpayerid",formBean.getString("field0007"));
customer.put("parentvo",parentvo);
customer.put("banks",banks);
cbdocvo.add(customer);
returnData.put("cbdocvo",cbdocvo);
return returnData;
}
}