diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java index 3106085e..fc3be07e 100644 --- a/buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java @@ -1009,6 +1009,18 @@ public class MdmModulePluginInitializer extends PluginBaseEntity { parameterJson.put("body",apiEntity.getBodyIn()); parameterJson.put("query",apiEntity.getQueryIn()); parameterJson.put("data",doObjects.get(i)); + //1、根据主数据id、数据id、应用ID默认查询主数据应用下发三方id表，只查询最新的一条数据 + MdmModuleDistributeTripartiteEntity mdmModuleDistributeTripartiteEntity1 = new MdmModuleDistributeTripartiteEntity(); + mdmModuleDistributeTripartiteEntity1.setSts("Y"); + mdmModuleDistributeTripartiteEntity1.setMdmId(mdmId); + mdmModuleDistributeTripartiteEntity1.setDataId(objects.get(i).getString("id")); + mdmModuleDistributeTripartiteEntity1.setAppId(sysApplicationEntity.getId()); + mdmModuleDistributeTripartiteEntity1 = mdmModuleDistributeTripartiteDao.queryOneTripartite(mdmModuleDistributeTripartiteEntity1); + String tripartiteId = ""; + if(mdmModuleDistributeTripartiteEntity1 != null && mdmModuleDistributeTripartiteEntity1.getTripartiteId() != null ){ + tripartiteId = mdmModuleDistributeTripartiteEntity1.getTripartiteId(); + } + parameterJson.put("tripartiteId", tripartiteId); /** head */ Map header = null; /** query */ diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/plugin/SalesBillingPluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/plugin/SalesBillingPluginInitializer.java new file mode 100644 index 00000000..5aba75cb --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/plugin/SalesBillingPluginInitializer.java @@ -0,0 +1,98 @@ +package com.hzya.frame.plugin.u8c.plugin; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.base.PluginBaseEntity; +import com.hzya.frame.plugin.u8c.service.ISalesBillingService; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + + +public class SalesBillingPluginInitializer extends PluginBaseEntity { + Logger logger = LoggerFactory.getLogger(SalesBillingPluginInitializer.class); + + @Autowired + private ISalesBillingService salesBillingService; + + /*** + * 插件初始化方法 + * @Author 👻👻👻👻👻👻👻👻 gjh + * @Date 2023-08-02 10:48 + * @Param [] + * @return void + **/ + @Override + public void initialize() { + + } + + /**** + * 插件销毁方法 + * @author 👻👻👻👻👻👻👻👻 gjh + * @date 2023-08-02 10:48 + * @return void + **/ + @Override + public void destroy() { + logger.info(getPluginLabel() + "執行銷毀方法destroy()"); + } + + /**** + * 插件的ID + * @author 👻👻👻👻👻👻👻👻 gjh + * @date 2023-08-02 10:48 + * @return void + **/ + @Override + public String getPluginId() { + return "SalesBillingPlugin"; + } + + /**** + * 插件的名称 + * @author 👻👻👻👻👻👻👻👻 gjh + * @date 2023-08-02 10:48 + * @return void + **/ + @Override + public String getPluginName() { + return "u8c销售开票审核状态同步插件"; + } + + /**** + * 插件的显示值 + * @author 👻👻👻👻👻👻👻👻 gjh + * @date 2023-08-02 10:48 + * @return void + **/ + @Override + public String getPluginLabel() { + return "u8c销售开票审核状态同步插件"; + } + + /*** + * 插件类型 1、场景插件 + * @Author 👻👻👻👻👻👻👻👻 gjh + * @Date 2023-08-02 14:01 + * @Param [] + * @return java.lang.String + **/ + @Override + public String getPluginType() { + return "1"; + } + + /*** + * 执行业务代码 + * @Author 👻👻👻👻👻👻👻👻 gjh + * @Date 2023-08-07 11:20 + * @param requestJson 执行业务代码的参数 + * @return void + **/ + @Override + public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception { + JsonResultEntity jsonResultEntity = salesBillingService.doSalesBilling(requestJson); + return jsonResultEntity; + } +} diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/ISalesBillingService.java b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/ISalesBillingService.java new file mode 100644 index 00000000..5b0b6184 --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/ISalesBillingService.java @@ -0,0 +1,17 @@ +package com.hzya.frame.plugin.u8c.service; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.web.entity.JsonResultEntity; + +public interface ISalesBillingService { + + + /** + * @Author lvleigang + * @Description OA同步销售开票审核状态到U8C + * @Date 10:21 上午 2024/8/2 + * @param requestJson + * @return com.hzya.frame.web.entity.JsonResultEntity + **/ + JsonResultEntity doSalesBilling(JSONObject requestJson); +} diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/impl/SalesBillingServiceImpl.java b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/impl/SalesBillingServiceImpl.java new file mode 100644 index 00000000..6318757b --- /dev/null +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/u8c/service/impl/SalesBillingServiceImpl.java @@ -0,0 +1,149 @@ +package com.hzya.frame.plugin.u8c.service.impl; + +import cn.hutool.core.map.MapBuilder; +import cn.hutool.http.HttpRequest; +import cn.hutool.json.JSONUtil; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.plugin.u8c.service.ISalesBillingService; +import com.hzya.frame.u8c.salesBilling.entity.U8cSalesBillingEntity; +import com.hzya.frame.u8c.salesBilling.service.IU8cSalesBillingService; +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; +import org.springframework.beans.factory.annotation.Value; + +import java.util.List; +import java.util.Map; + + +public class SalesBillingServiceImpl implements ISalesBillingService { + + Logger logger = LoggerFactory.getLogger(SalesBillingServiceImpl.class); + + @Value("${OA.data_source_code}") + private String oa_data_source_code; + @Autowired + private IU8cSalesBillingService iu8cSalesBillingService; + + private final String appId = "800035"; + private final String apiCode = "8000350047"; + private final String publicKey = "ZJYATW/MfYZX7zF0eAh4DJXbyTLwUtwSoSz5Y/o1ksAaN/dCe7eDIk+3zDUT+v578prj"; + private final String secretKey = "+5BUkLQh3iX3VHgEt5bE2IPh+ZeebGvDaEspsvVu739Ar6sFnwg+fpPod4t6XhoTj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA="; + + /** + * @param requestJson + * @return com.hzya.frame.web.entity.JsonResultEntity + * @Author lvleigang + * @Description 同步销售开票审核状态 + * @Date 10:21 上午 2024/8/2 + **/ + @Override + public JsonResultEntity doSalesBilling(JSONObject requestJson) { + //查询需要同步的数据 + + try { + U8cSalesBillingEntity u8cSalesBillingEntity = new U8cSalesBillingEntity(); + u8cSalesBillingEntity.setDataSourceCode(oa_data_source_code); + List u8cSalesBillingEntities = iu8cSalesBillingService.queryDoSalesBilling(u8cSalesBillingEntity); + + if (u8cSalesBillingEntities != null && u8cSalesBillingEntities.size() > 0) { + for (int i = 0; i < u8cSalesBillingEntities.size(); i++) { + U8cSalesBillingEntity entity = u8cSalesBillingEntities.get(i); + String params = getSendData(entity); + //发送数据 + String returnData = executeEsb(params,appId,apiCode,publicKey,secretKey); + //解析结果 + boolean flag = analyzeReturnData(returnData); + if(flag){ + entity.setPushStatus("Y"); + }else { + entity.setPushStatus("N"); + } + entity.setDataSourceCode(oa_data_source_code); + iu8cSalesBillingService.updateDoSalesBilling(entity); + } + return BaseResult.getSuccessMessageEntity("同步销售开票审核状态成功"); + } else { + return BaseResult.getSuccessMessageEntity("同步销售开票审核状态成功"); + } + } catch (Exception e) { + return BaseResult.getFailureMessageEntity("同步销售开票审核状态失败" + e.getMessage()); + } + } + + /** + * @Author lvleigang + * @Description 解析返回状态 + * @Date 2:50 下午 2024/8/2 + * @param returnData + * @return boolean + **/ + private boolean analyzeReturnData(String returnData) { + boolean falg = false ; + if (JSONUtil.isTypeJSON(returnData)) { + JSONObject jsonObject = JSONObject.parseObject(returnData); + if(jsonObject != null && jsonObject.get("flag") != null && jsonObject.getBoolean("flag")) { + JSONObject attribute = jsonObject.getJSONObject("attribute"); + if(attribute != null && attribute.get("status") != null && "success".equals(attribute.getString("status"))) { + falg = true; + } + } + } + return falg; + } + + private String getSendData(U8cSalesBillingEntity entity) { + String params = ""; + //{ + // "queryinfo": { + // "code": [ + // "SITH1904180026", + // "SOTH1805240023" + // ], + // "corp": "1000", + // "date_begin": "2019-03-24", + // "date_end": "2019-05-24" + // }, + // "approveinfo": { + // "approvid": "18612329914", + // "approveDate": "2018-04-19", + // "status": "Y", + // "note": "哈哈" + // } + //} + JSONObject data = new JSONObject(); + JSONObject queryinfo = new JSONObject(); + JSONObject approveinfo = new JSONObject(); + JSONArray code = new JSONArray(); + code.add(entity.getCode());//单据号 + queryinfo.put("code", code); + queryinfo.put("corp", entity.getCorp());//公司编码 + queryinfo.put("date_begin", entity.getDateBegin());//单据开始日期 + queryinfo.put("date_end", entity.getDateEnd());//单据结束日期 + approveinfo.put("approvid", entity.getApprovid());//审批人 + approveinfo.put("approveDate", entity.getApprovedate());//审核时间 + approveinfo.put("status", entity.getStatus());//审批状态（Y：通过，N：不通过，R：驳回） + approveinfo.put("note", entity.getNote());//批语 + + data.put("queryinfo", queryinfo); + data.put("approveinfo", approveinfo); + params = data.toJSONString(); + return params; + } + + + public String executeEsb(String params, String appId, String apiCode, String publicKey, String secretKey) { + logger.info("请求apiCode:{},参数:{}", apiCode, params); + Map header = MapBuilder.create(true) + .put("apiCode", apiCode) + .put("publicKey", publicKey) + .put("secretKey", secretKey) + .put("appId", appId) + .build(); + String res = HttpRequest.post("http://127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface").addHeaders(header).body(params).timeout(60000).execute().body(); + return res; + } +} diff --git a/buildpackage/src/main/resources/application-llg.yml b/buildpackage/src/main/resources/application-llg.yml index 2920f2eb..f24d567c 100644 --- a/buildpackage/src/main/resources/application-llg.yml +++ b/buildpackage/src/main/resources/application-llg.yml @@ -49,4 +49,4 @@ cbs8: #电子回单下载临时存放位置 elec_path: /Users/xiangerlin/Downloads/ OA: - data_source_code: yc_oa \ No newline at end of file + data_source_code: djoatest \ No newline at end of file diff --git a/buildpackage/src/main/resources/cfgHome/plugin/u8c/pluginCfg.xml b/buildpackage/src/main/resources/cfgHome/plugin/u8c/pluginCfg.xml new file mode 100644 index 00000000..70c76f15 --- /dev/null +++ b/buildpackage/src/main/resources/cfgHome/plugin/u8c/pluginCfg.xml @@ -0,0 +1,6 @@ + + +SalesBillingPlugin +u8c插件 +202408020001 + diff --git a/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-plugin.xml b/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-plugin.xml new file mode 100644 index 00000000..593229f6 --- /dev/null +++ b/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-plugin.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-service.xml b/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-service.xml new file mode 100644 index 00000000..c011db17 --- /dev/null +++ b/buildpackage/src/main/resources/cfgHome/plugin/u8c/spring/spring-buildpackage-service.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/common/src/main/java/com/hzya/frame/util/GroovyUtil.java b/common/src/main/java/com/hzya/frame/util/GroovyUtil.java index eec3019b..2b88f25f 100644 --- a/common/src/main/java/com/hzya/frame/util/GroovyUtil.java +++ b/common/src/main/java/com/hzya/frame/util/GroovyUtil.java @@ -51,6 +51,7 @@ public class GroovyUtil { logger.info("创建newInstance失败:"+ e); throw new BaseSystemException(e); } + logger.info("开始执行脚本:"+parameterJson); Object returnObj = groovyObject.invokeMethod("execute",parameterJson); logger.info("执行脚本结束:"+returnObj); return returnObj; diff --git a/service/src/main/java/com/hzya/frame/sysnew/comparison/service/impl/ComparisonServiceImpl.java b/service/src/main/java/com/hzya/frame/sysnew/comparison/service/impl/ComparisonServiceImpl.java index 9defee72..fa22661d 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/comparison/service/impl/ComparisonServiceImpl.java +++ b/service/src/main/java/com/hzya/frame/sysnew/comparison/service/impl/ComparisonServiceImpl.java @@ -206,11 +206,24 @@ public class ComparisonServiceImpl extends BaseService } } if(jsonObjectMain!=null && jsonObjectMain.size()>0) { - Map map = new HashMap<>();//将主表数据存到map中 + Map map = new HashMap<>();//将主表数据存到map中 List>> mapDetails = new ArrayList<>();//将子表数据存到map中 if (comparisonEntities != null && comparisonEntities.size() > 0) { map = spliceMainMap(comparisonEntities, jsonObjectMain, map, comparisonEntity, comparisonDetailsEntity); + //根据data_id判断数据是否已经保存在相关表中,避免重复保存 + List fields = getFields(comparisonEntity); + Map mapDataId=new HashMap<>(); + mapDataId.put("data_id",jsonObjectMain.getString("data_id")); + ComparisonEntity comparisonDataId=new ComparisonEntity(); + comparisonDataId.setMap(mapDataId); + comparisonDataId.setDbName(comparisonEntity.getDbName()); + comparisonDataId.setFields(fields); + List> listDataId = comparisonDao.queryComparisonPage(comparisonDataId); + if(CollectionUtils.isNotEmpty(listDataId)){ + return BaseResult.getFailureMessageEntity(comparisonEntity.getDbName()+"表中已经存在data_id为:"+jsonObjectMain.getString("data_id")+"的数据"); + } + //判断输入的主表字段是否是必填项 for (ComparisonEntity entity : comparisonEntities) { //如果必填字段不为空 diff --git a/service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java b/service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java index a93ed74b..e8c9e6e0 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java +++ b/service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java @@ -34,49 +34,32 @@ public class GroovyIntegrationServiceImpl implements IGroovyIntegrationService { } public static void main(String[] args) { -// java.lang.String str = "{\"data\":{\"document_rule\":\"WLFL-2024-07-31-00025\",\"create_user_id\":\"1\",\"create_time\":1722405930000,\"company_id\":\"Y\",\"modify_time\":1722405930000,\"materiel_classify_name\":\"测试下发一级\",\"document_rule_num\":25,\"materiel_classify_code\":\"09\",\"add_status\":\"0\",\"update_status\":\"0\",\"sts\":\"Y\",\"delete_status\":\"1\",\"org_id\":\"Y\",\"id\":\"3dac9727cc0648baa8c1355464ad44b8\",\"data_status\":\"F\",\"modify_user_id\":\"1\",\"sorts\":34},\"query\":\"[]\",\"header\":\"[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":0,\\\"parameterName\\\":\\\"usercode\\\",\\\"id\\\":\\\"e2c4013a-a5ad-4d21-9e91-aac0dd738838\\\",\\\"example\\\":\\\"17633965916\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"password\\\",\\\"id\\\":\\\"22373440-45f5-450c-9497-40ede659e831\\\",\\\"example\\\":\\\"92d40fd65a74377608c0039eaafdba99\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"parameterName\\\":\\\"trantype\\\",\\\"id\\\":\\\"12fd925a-29c1-42ca-a3e6-edf3c925c495\\\",\\\"example\\\":\\\"code\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"parameterName\\\":\\\"system\\\",\\\"id\\\":\\\"11dd627c-bb82-4304-bff0-2ba54e2b8907\\\",\\\"example\\\":\\\"01\\\"}]\",\"tripartiteId\":\"0001A110000000000R6D\",\"body\":\"[{\\\"parameterType\\\":\\\"complex\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"description\\\":\\\"分类编码\\\",\\\"parameterName\\\":\\\"invclasscode\\\",\\\"id\\\":\\\"3b2af319-87c8-400a-b38a-d54f9b207f26\\\",\\\"example\\\":\\\"04\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"description\\\":\\\"分类名称\\\",\\\"parameterName\\\":\\\"invclassname\\\",\\\"id\\\":\\\"7c5bd695-ed84-4a92-a1c7-31c862e98d21\\\",\\\"example\\\":\\\"成品测试1\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":4,\\\"description\\\":\\\"公司编码默认0001\\\",\\\"parameterName\\\":\\\"pk_corp\\\",\\\"id\\\":\\\"482d659b-b374-4fb5-b31b-32bca4a6d8be\\\",\\\"example\\\":\\\"0001\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":5,\\\"description\\\":\\\"分类主键\\\",\\\"parameterName\\\":\\\"pk_invcl\\\",\\\"id\\\":\\\"3fa6caac-e0cd-4ec7-8df4-7c990504ee25\\\",\\\"example\\\":\\\"0001F11000000000I6NN\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"invcl\\\",\\\"id\\\":\\\"0638670a-e65d-46e1-aabd-adc7a956c4cb\\\"}],\\\"concreteType\\\":\\\"Object\\\",\\\"index\\\":0,\\\"id\\\":\\\"81cdd912-9bf3-4cb4-b74f-2a8ee27de93a\\\",\\\"parameterName\\\":\\\"body\\\",\\\"first\\\":true}]\"}"; -// A88772 s = new A88772(); -// System.out.println(s.execute(str)); + java.lang.String str = "{\"data\":{\"pk_areacl\":\"01\",\"document_rule\":\"KH-2024-08-02-00001\",\"create_user_id\":\"1\",\"code\":\"K202408010001\",\"create_time\":1722580487000,\"company_id\":\"Y\",\"modify_time\":1722580487000,\"document_rule_num\":1,\"mdm_customer_bank\":[],\"add_status\":\"0\",\"update_status\":\"1\",\"sts\":\"Y\",\"delete_status\":\"1\",\"org_id\":\"Y\",\"name\":\"测试手动下发\",\"id\":\"f0daa2ce563949968aeb2b4cfd7f4fad\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":136,\"custshortname\":\"测试手动下发\"},\"query\":\"[]\",\"header\":\"[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":0,\\\"parameterName\\\":\\\"usercode\\\",\\\"id\\\":\\\"7e7c7f83-9cb1-491d-bd1a-d23744bacba8\\\",\\\"example\\\":\\\"17633965916\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"password\\\",\\\"id\\\":\\\"e6c1a7c7-0bcc-4246-b62c-e2313b092438\\\",\\\"example\\\":\\\"92d40fd65a74377608c0039eaafdba99\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"parameterName\\\":\\\"trantype\\\",\\\"id\\\":\\\"b4ff0ceb-d797-462a-8c93-124f5a053628\\\",\\\"example\\\":\\\"code\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"parameterName\\\":\\\"system\\\",\\\"id\\\":\\\"a8962ee0-108f-427a-8862-8f8e5c8e61ab\\\",\\\"example\\\":\\\"01\\\"}]\",\"body\":\"[{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"parameterName\\\":\\\"accname\\\",\\\"id\\\":\\\"69014133-b81e-4a9d-82fc-7c29821e77f9\\\",\\\"example\\\":\\\"666601\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"parameterName\\\":\\\"account\\\",\\\"id\\\":\\\"51980e53-c1dd-448a-bf36-d24fd817b1a5\\\",\\\"example\\\":\\\"test001\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":4,\\\"parameterName\\\":\\\"accountname\\\",\\\"id\\\":\\\"97111e2d-8df9-4465-a241-e1969b032287\\\",\\\"example\\\":\\\"zy测试银行账户\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":5,\\\"parameterName\\\":\\\"banktypename\\\",\\\"id\\\":\\\"176cd4c8-5228-4dd6-bee7-2101f09a16d3\\\",\\\"example\\\":\\\"6666\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":6,\\\"parameterName\\\":\\\"defflag\\\",\\\"id\\\":\\\"8d833cbf-a396-41af-ba52-cb58b3aa5a74\\\",\\\"example\\\":\\\"Y\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":7,\\\"parameterName\\\":\\\"pk_currtype\\\",\\\"id\\\":\\\"d80241ec-c9fb-480c-9e0a-bd1589595a20\\\",\\\"example\\\":\\\"CNY\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":8,\\\"parameterName\\\":\\\"status\\\",\\\"id\\\":\\\"2c7d4b42-b26e-4aa9-a294-3b330e08cf70\\\",\\\"example\\\":\\\"2\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":9,\\\"parameterName\\\":\\\"unitname\\\",\\\"id\\\":\\\"9e6a593f-e35f-456e-879a-41d3d63bb94b\\\",\\\"example\\\":\\\"测试001\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"banks\\\",\\\"id\\\":\\\"3815c339-d96b-40d6-a96c-81b8cf68be28\\\"},{\\\"parameterType\\\":\\\"complex\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":11,\\\"parameterName\\\":\\\"conaddr\\\",\\\"id\\\":\\\"b5990933-94e0-4015-9f53-2ce6fa9bc3da\\\",\\\"example\\\":\\\"测试33145411113\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":12,\\\"parameterName\\\":\\\"creator\\\",\\\"id\\\":\\\"f0cce0b5-b5fa-4ea7-8f15-f1ac075eb7f1\\\",\\\"example\\\":\\\"0001F8100000000000PL\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":13,\\\"parameterName\\\":\\\"custcode\\\",\\\"id\\\":\\\"853453c3-dad1-4155-998b-9d1c4b8e2acd\\\",\\\"example\\\":\\\"ceshi007\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":14,\\\"parameterName\\\":\\\"custname\\\",\\\"id\\\":\\\"2b06423d-827a-465d-b829-42471733fa51\\\",\\\"example\\\":\\\"测试007\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":15,\\\"parameterName\\\":\\\"custprop\\\",\\\"id\\\":\\\"c4277bcb-7d80-4c12-8508-935086e2c7df\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":16,\\\"parameterName\\\":\\\"custshortname\\\",\\\"id\\\":\\\"6c02f4ec-618c-4973-babe-a0c81c179743\\\",\\\"example\\\":\\\"测试007\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":17,\\\"parameterName\\\":\\\"freecustflag\\\",\\\"id\\\":\\\"48c1d795-4396-4189-8f22-9228b2424fce\\\",\\\"example\\\":\\\"N\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":18,\\\"parameterName\\\":\\\"isconnflag\\\",\\\"id\\\":\\\"92be035c-eb7c-46be-a2c3-5e48ce18cf4f\\\",\\\"example\\\":\\\"N\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":19,\\\"parameterName\\\":\\\"pk_areacl\\\",\\\"id\\\":\\\"8bc3d731-ab42-46d5-afc3-3227de0df96b\\\",\\\"example\\\":\\\"01\\\"}],\\\"concreteType\\\":\\\"Object\\\",\\\"index\\\":10,\\\"parameterName\\\":\\\"parentvo\\\",\\\"id\\\":\\\"627af933-4b7f-433b-beb5-f2a49b50cfaa\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":0,\\\"parameterName\\\":\\\"cbdocvo\\\",\\\"id\\\":\\\"33aac70c-d95a-475d-8f98-28925223f305\\\"}]\"}"; + A88772 s = new A88772(); + System.out.println(s.execute(str)); - String str = "{\"data\":\"{\\\"msg\\\":\\\"转发成功\\\",\\\"type\\\":null,\\\"flag\\\":true,\\\"status\\\":\\\"200\\\",\\\"attribute\\\":{\\\"data\\\":\\\"[{\\\\\\\"pk_invcl\\\\\\\":\\\\\\\"0001A110000000000QPW\\\\\\\",\\\\\\\"invclasscode\\\\\\\":\\\\\\\"09\\\\\\\",\\\\\\\"invclassname\\\\\\\":\\\\\\\"测试下发一级\\\\\\\",\\\\\\\"invclasslev\\\\\\\":\\\\\\\"1\\\\\\\",\\\\\\\"pk_corp\\\\\\\":\\\\\\\"0001\\\\\\\"}]\\\",\\\"taskNumber\\\":\\\"202407310125\\\",\\\"status\\\":\\\"success\\\"}}\"}"; - g_482610back t = new g_482610back(); - System.out.println(t.execute(str)); - } - static class test0001{ - String execute(String jsonStr) { - com.alibaba.fastjson.JSONObject returnObject = new com.alibaba.fastjson.JSONObject(); - com.alibaba.fastjson.JSONObject reqData = com.alibaba.fastjson.JSON.parseObject(jsonStr); - if(null !=reqData){ - com.alibaba.fastjson.JSONObject header = new com.alibaba.fastjson.JSONObject(); - if(null !=reqData.getString("status")&& !"".equals(reqData.getString("status"))){ - com.alibaba.fastjson.JSONArray dataArr = com.alibaba.fastjson.JSON.parseArray(reqData.getString("data")); - com.alibaba.fastjson.JSONObject data = (JSONObject) dataArr.get(0); - returnObject.put("success","true"); - returnObject.put("tripartiteId",data.getString("pk_invcl")); - }else{ - returnObject.put("success","false"); - } - }else{ - returnObject.put("success","false"); - } - return returnObject.toJSONString(); - } +// String str = "{\"data\":\"{\\\"msg\\\":\\\"转发成功\\\",\\\"type\\\":null,\\\"flag\\\":true,\\\"status\\\":\\\"200\\\",\\\"attribute\\\":{\\\"data\\\":\\\"[{\\\\\\\"parentvo\\\\\\\":{\\\\\\\"pk_corp\\\\\\\":\\\\\\\"0001\\\\\\\",\\\\\\\"invcode\\\\\\\":\\\\\\\"CS202408020001\\\\\\\",\\\\\\\"invname\\\\\\\":\\\\\\\"测试存货档案\\\\\\\",\\\\\\\"pk_invcl\\\\\\\":\\\\\\\"0001A110000000000RB3\\\\\\\",\\\\\\\"invclcode\\\\\\\":\\\\\\\"0901\\\\\\\",\\\\\\\"invclname\\\\\\\":\\\\\\\"测试二级-1-1-1\\\\\\\",\\\\\\\"pk_measdoc\\\\\\\":\\\\\\\"0001A110000000000J7T\\\\\\\",\\\\\\\"meascode\\\\\\\":\\\\\\\"BAO\\\\\\\",\\\\\\\"measname\\\\\\\":\\\\\\\"包\\\\\\\",\\\\\\\"pk_taxitems\\\\\\\":\\\\\\\"40040000000000000037\\\\\\\",\\\\\\\"taxitemscode\\\\\\\":\\\\\\\"1001\\\\\\\",\\\\\\\"taxitemsname\\\\\\\":\\\\\\\"水泥\\\\\\\",\\\\\\\"unitvolume\\\\\\\":\\\\\\\"0.00000000\\\\\\\",\\\\\\\"unitweight\\\\\\\":\\\\\\\"0.00000000\\\\\\\",\\\\\\\"laborflag\\\\\\\":false,\\\\\\\"discountflag\\\\\\\":false,\\\\\\\"setpartsflag\\\\\\\":false,\\\\\\\"asset\\\\\\\":false,\\\\\\\"iselectrans\\\\\\\":false,\\\\\\\"isretail\\\\\\\":false,\\\\\\\"assistunit\\\\\\\":true,\\\\\\\"autobalancemeas\\\\\\\":false,\\\\\\\"ismngstockbygrswt\\\\\\\":false,\\\\\\\"isstorebyconvert\\\\\\\":false,\\\\\\\"creator\\\\\\\":\\\\\\\"openapi\\\\\\\",\\\\\\\"createtime\\\\\\\":\\\\\\\"2024-08-02 10:38:10\\\\\\\",\\\\\\\"pk_invbasdoc\\\\\\\":\\\\\\\"0001A110000000000SZM\\\\\\\",\\\\\\\"dr\\\\\\\":\\\\\\\"0\\\\\\\"},\\\\\\\"childrenvo\\\\\\\":[]}]\\\",\\\"taskNumber\\\":\\\"202408020006\\\",\\\"status\\\":\\\"success\\\"}}\"}"; +// g_482610back t = new g_482610back(); +// System.out.println(t.execute(str)); } + static class A88772 { String execute(String jsonStr) { com.alibaba.fastjson.JSONObject returnObject = new com.alibaba.fastjson.JSONObject(); com.alibaba.fastjson.JSONObject bodys = new com.alibaba.fastjson.JSONObject(); - com.alibaba.fastjson.JSONArray invcl = new com.alibaba.fastjson.JSONArray(); + com.alibaba.fastjson.JSONArray cbdocvo = new com.alibaba.fastjson.JSONArray(); com.alibaba.fastjson.JSONObject main = new com.alibaba.fastjson.JSONObject(); + com.alibaba.fastjson.JSONObject parentvo = new com.alibaba.fastjson.JSONObject(); com.alibaba.fastjson.JSONObject reqData = com.alibaba.fastjson.JSON.parseObject(jsonStr); com.alibaba.fastjson.JSONObject data = reqData.getJSONObject("data"); - main.put("invclasscode", data.getString("materiel_classify_code")); - main.put("invclassname", data.getString("materiel_classify_name")); - main.put("pk_invcl", reqData.getString("tripartiteId")); - main.put("pk_corp", "0001"); - invcl.add(main); - bodys.put("invcl",invcl); + parentvo.put("pk_areacl", data.getString("pk_areacl")); + parentvo.put("custcode", data.getString("code")); + parentvo.put("custshortname", data.getString("custshortname")); + parentvo.put("custname", data.getString("name")); + main.put("parentvo",parentvo); + cbdocvo.add(main); + bodys.put("cbdocvo",cbdocvo); returnObject.put("bodys",bodys.toJSONString()); return returnObject.toJSONString(); @@ -96,10 +79,10 @@ public class GroovyIntegrationServiceImpl implements IGroovyIntegrationService { com.alibaba.fastjson.JSONObject header = new com.alibaba.fastjson.JSONObject(); if(null !=reqData.getString("status")&& !"".equals(reqData.getString("status"))){ com.alibaba.fastjson.JSONArray dataArr = com.alibaba.fastjson.JSON.parseArray(reqData.getString("data")); -// com.alibaba.fastjson.JSONObject data = (com.alibaba.fastjson.JSONObject) dataArr.get(0); com.alibaba.fastjson.JSONObject data = dataArr.getJSONObject(0); + com.alibaba.fastjson.JSONObject parentvo = data.getJSONObject("parentvo"); returnObject.put("success","true"); - returnObject.put("tripartiteId",data.getString("pk_invcl")); + returnObject.put("tripartiteId",parentvo.getString("pk_invbasdoc")); }else{ returnObject.put("success","false"); } @@ -110,5 +93,25 @@ public class GroovyIntegrationServiceImpl implements IGroovyIntegrationService { returnObject.put("success","false"); } return returnObject.toJSONString(); } } + static class g_494689 { + public static void main(String[] args) { + String str = "{\"data\":{\"pk_areacl\":\"01\",\"document_rule\":\"KH-2024-08-02-00007\",\"create_user_id\":\"1\",\"code\":\"K202408010006\",\"create_time\":1722584236000,\"company_id\":\"Y\",\"modify_time\":1722584236000,\"document_rule_num\":7,\"mdm_customer_bank\":[],\"add_status\":\"0\",\"update_status\":\"1\",\"sts\":\"Y\",\"delete_status\":\"1\",\"org_id\":\"Y\",\"custstate\":\"测试自动分配03\",\"id\":\"d9ccd167d0ae4e3884f2b76c31a88a34\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":142,\"custshortname\":\"测试自动分配03\"},\"query\":\"[]\",\"header\":\"[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":0,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"8e704f6e-20a8-49f9-b10a-fd1a6090565a\\\",\\\"parameterName\\\":\\\"usercode\\\",\\\"required\\\":false,\\\"example\\\":\\\"17633965916\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":1,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"5ca85472-dc42-45d8-9be6-dedf20cb09d9\\\",\\\"parameterName\\\":\\\"password\\\",\\\"example\\\":\\\"92d40fd65a74377608c0039eaafdba99\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":2,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"d32b0dfd-2f06-4ee1-a56d-03882f9003d4\\\",\\\"parameterName\\\":\\\"trantype\\\",\\\"example\\\":\\\"code\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":3,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"1f48a05d-8f89-4bb2-b29a-e1a6eac7f5b7\\\",\\\"parameterName\\\":\\\"system\\\",\\\"example\\\":\\\"01\\\"}]\",\"body\":\"[{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"pk_corp\\\",\\\"id\\\":\\\"33bc86ee-652c-4822-b6a8-dbd329a20779\\\",\\\"example\\\":\\\"1004\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"parameterName\\\":\\\"custprop\\\",\\\"id\\\":\\\"b5d55712-b378-4dbd-b2ae-04bcb3d0fb2b\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"parameterName\\\":\\\"pk_cubasdoc\\\",\\\"id\\\":\\\"0c4a5614-effb-4d88-83e2-e9cd0f33ea3a\\\",\\\"example\\\":\\\"0001F810000000000FE0\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":0,\\\"parameterName\\\":\\\"custbasvo\\\",\\\"id\\\":\\\"df932132-3a93-463c-aaa7-7393b0abfa80\\\"}]\"}"; + g_494689 s = new g_494689(); + System.out.println(s.execute(str)); + } + String execute (String jsonStr){ + com.alibaba.fastjson.JSONObject returnObject = new com.alibaba.fastjson.JSONObject(); + com.alibaba.fastjson.JSONObject bodys = new com.alibaba.fastjson.JSONObject(); + com.alibaba.fastjson.JSONArray custbasvo = new com.alibaba.fastjson.JSONArray(); + com.alibaba.fastjson.JSONObject main = new com.alibaba.fastjson.JSONObject(); + com.alibaba.fastjson.JSONObject reqData = com.alibaba.fastjson.JSON.parseObject(jsonStr); + com.alibaba.fastjson.JSONObject data = reqData.getJSONObject("data"); + main.put("pk_corp", "002"); + main.put("pk_cubasdoc", reqData.getString("tripartiteId")); + main.put("custprop", "2"); + custbasvo.add(main); + bodys.put("custbasvo",custbasvo); + returnObject.put("bodys",bodys.toJSONString()); + return returnObject.toJSONString(); } } } diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/IU8cSalesBillingDao.java b/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/IU8cSalesBillingDao.java new file mode 100644 index 00000000..ce8ccd13 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/IU8cSalesBillingDao.java @@ -0,0 +1,20 @@ +package com.hzya.frame.u8c.salesBilling.dao; + +import com.hzya.frame.basedao.dao.IBaseDao; +import com.hzya.frame.mdm.mdmModule.entity.MdmModuleEntity; +import com.hzya.frame.u8c.salesBilling.entity.U8cSalesBillingEntity; + +import java.util.List; + +/** + * 脚本表(u8c_sales_billing: table)表数据库访问层 + * + * @author makejava + * @since 2024-08-02 11:07:43 + */ +public interface IU8cSalesBillingDao extends IBaseDao { + List queryDoSalesBilling(U8cSalesBillingEntity entity); + + int updateDoSalesBilling(U8cSalesBillingEntity entity); +} + diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/impl/U8cSalesBillingDaoImpl.java b/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/impl/U8cSalesBillingDaoImpl.java new file mode 100644 index 00000000..411317d0 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/dao/impl/U8cSalesBillingDaoImpl.java @@ -0,0 +1,29 @@ +package com.hzya.frame.u8c.salesBilling.dao.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +import com.hzya.frame.mdm.mdmModule.entity.MdmModuleEntity; +import com.hzya.frame.u8c.salesBilling.dao.IU8cSalesBillingDao; +import com.hzya.frame.u8c.salesBilling.entity.U8cSalesBillingEntity; +import org.springframework.stereotype.Repository; + +import java.util.List; + +@Repository(value = "U8cSalesBillingDaoImpl") +public class U8cSalesBillingDaoImpl extends MybatisGenericDao implements IU8cSalesBillingDao{ + @DS("#entity.dataSourceCode") + @Override + public List queryDoSalesBilling(U8cSalesBillingEntity entity) { + List o = (List) super.selectList(getSqlIdPrifx() + "queryDoSalesBilling", entity); + return o; + } + + + @DS("#entity.dataSourceCode") + @Override + public int updateDoSalesBilling(U8cSalesBillingEntity entity) { + Integer o = super.update(getSqlIdPrifx() + "updateDoSalesBilling", entity); + return o; + } +} + diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.java b/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.java new file mode 100644 index 00000000..ff4c1951 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.java @@ -0,0 +1,111 @@ +package com.hzya.frame.u8c.salesBilling.entity; + + +import com.hzya.frame.web.entity.BaseEntity; + +public class U8cSalesBillingEntity extends BaseEntity { + + /** 单据号 */ + private String code; + /** 公司编码 */ + private String corp; + /** 单据开始日期 */ + private String dateBegin; + /** 单据结束日期 */ + private String dateEnd; + /** 审批人 */ + private String approvid; + /** 审核时间 */ + private String approvedate; + /** 审批状态（Y：通过，N：不通过，R：驳回） */ + private String status; + /** 批语 */ + private String note; + //数据源 + private String dataSourceCode; + //推送状态 Y成功N失败 + private String pushStatus; + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getCorp() { + return corp; + } + + public void setCorp(String corp) { + this.corp = corp; + } + + public String getDateBegin() { + return dateBegin; + } + + public void setDateBegin(String dateBegin) { + this.dateBegin = dateBegin; + } + + public String getDateEnd() { + return dateEnd; + } + + public void setDateEnd(String dateEnd) { + this.dateEnd = dateEnd; + } + + public String getApprovid() { + return approvid; + } + + public void setApprovid(String approvid) { + this.approvid = approvid; + } + + public String getApprovedate() { + return approvedate; + } + + public void setApprovedate(String approvedate) { + this.approvedate = approvedate; + } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + public String getNote() { + return note; + } + + public void setNote(String note) { + this.note = note; + } + + @Override + public String getDataSourceCode() { + return dataSourceCode; + } + + @Override + public void setDataSourceCode(String dataSourceCode) { + this.dataSourceCode = dataSourceCode; + } + + public String getPushStatus() { + return pushStatus; + } + + public void setPushStatus(String pushStatus) { + this.pushStatus = pushStatus; + } +} + diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.xml b/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.xml new file mode 100644 index 00000000..e3f49a5d --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/entity/U8cSalesBillingEntity.xml @@ -0,0 +1,40 @@ + + + + + + + + + + + + + + + + + + + + update formmain_0049 set + field0044 = #{pushStatus} + where id = #{id} + + + diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/IU8cSalesBillingService.java b/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/IU8cSalesBillingService.java new file mode 100644 index 00000000..80b7b9e5 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/IU8cSalesBillingService.java @@ -0,0 +1,13 @@ +package com.hzya.frame.u8c.salesBilling.service; + +import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.mdm.mdmModule.entity.MdmModuleEntity; +import com.hzya.frame.u8c.salesBilling.entity.U8cSalesBillingEntity; + +import java.util.List; + +public interface IU8cSalesBillingService extends IBaseService { + List queryDoSalesBilling(U8cSalesBillingEntity u8cSalesBillingEntity); + + int updateDoSalesBilling(U8cSalesBillingEntity entity); +} diff --git a/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/impl/U8cSalesBillingServiceImpl.java b/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/impl/U8cSalesBillingServiceImpl.java new file mode 100644 index 00000000..56ea26f8 --- /dev/null +++ b/service/src/main/java/com/hzya/frame/u8c/salesBilling/service/impl/U8cSalesBillingServiceImpl.java @@ -0,0 +1,35 @@ +package com.hzya.frame.u8c.salesBilling.service.impl; + +import com.baomidou.dynamic.datasource.annotation.DS; +import com.hzya.frame.basedao.service.impl.BaseService; +import com.hzya.frame.mdm.mdmModule.dao.IMdmModuleDao; +import com.hzya.frame.u8c.salesBilling.dao.IU8cSalesBillingDao; +import com.hzya.frame.u8c.salesBilling.entity.U8cSalesBillingEntity; +import com.hzya.frame.u8c.salesBilling.service.IU8cSalesBillingService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; + +@Service(value = "u8cSalesBillingService") +public class U8cSalesBillingServiceImpl extends BaseService implements IU8cSalesBillingService { + + private IU8cSalesBillingDao u8cSalesBillingDao; + + @Autowired + public void setU8cSalesBillingDao(IU8cSalesBillingDao dao) { + this.u8cSalesBillingDao = dao; + this.dao = dao; + } + @Override + public List queryDoSalesBilling(U8cSalesBillingEntity entity) { + List u8cSalesBillingEntityList = u8cSalesBillingDao.queryDoSalesBilling(entity); + return u8cSalesBillingEntityList; + } + + @Override + public int updateDoSalesBilling(U8cSalesBillingEntity entity) { + return u8cSalesBillingDao.updateDoSalesBilling(entity); + } +}