diff --git a/base-buildpackage/pom.xml b/base-buildpackage/pom.xml
index a745746a..c9143ecf 100644
--- a/base-buildpackage/pom.xml
+++ b/base-buildpackage/pom.xml
@@ -43,6 +43,12 @@
httest
+
+ dev
+
+ dev
+
+
xel
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/ht/plugin/InvoiceDistributePluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/ht/plugin/InvoiceDistributePluginInitializer.java
index 14fc3fe7..af9593bc 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/ht/plugin/InvoiceDistributePluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/ht/plugin/InvoiceDistributePluginInitializer.java
@@ -1092,26 +1092,6 @@ public class InvoiceDistributePluginInitializer extends PluginBaseEntity {
headers.putAll(header);
}
if (SysEnum.NEED_LOGIN.getValue().equals(apiEntity.getNeedLogin())) {
- /* logger.info("=========正常开票申请单申请数据新增开始执行登录接口==============");
- //找到登陆接口
- SysApplicationApiEntity loginApi = sysApplicationApiDao.get(apiEntity.getAuthenticationPort());
- if (null == loginApi) {
- saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","发送错误,认证接口不存在",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
- continue;
- }
- String rzquerys = getQuery(loginApi,null,null);
- Map headersa = new HashMap<>();
- headersa.put("publicKey", "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj");
- headersa.put("secretKey", "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=");
- headersa.put("appId", sysApplicationEntity.getAppId().toString());
- headersa.put("apiCode", loginApi.getApiCode().toString());
- Map rzheaders = getHeaders(loginApi,headersa,null);
- String rzbodys = getBodys(loginApi,null,null);
- JsonResultEntity rzjsonResultEntity = sendData(loginApi,rzheaders,rzbodys,rzquerys);
- if (!rzjsonResultEntity.isFlag()) {
- saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","发送错误,认证接口错误",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
- continue;
- }*/
JSONObject jsonObject=new JSONObject();
jsonObject.put("accessKey","6X3B526P5HqE6ums");
jsonObject.put("accessSecret","34e5fc32ac894a2ba2ade8c3852c7a0a");
@@ -1168,11 +1148,27 @@ public class InvoiceDistributePluginInitializer extends PluginBaseEntity {
mdmModuleDistributeTripartiteEntity.setAppId(sysApplicationEntity.getId());
mdmModuleDistributeTripartiteEntity.setTripartiteId(backJsonResultEntity.getString("tripartiteId"));
mdmModuleDistributeTripartiteDao.save(mdmModuleDistributeTripartiteEntity);
+ //修改下发状态
+ logger.info("===开票申请单申请正常下发时候完毕更新新增状态为1=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "1");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
}
}
} catch (Exception e) {
logger.error("开票申请单申请下发新增返回脚本解析保存三方id错误"+jsonResultEntity.getAttribute());
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","新增返回脚本解析保存三方id错误",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
+ //修改下发状态
+ logger.info("===开票申请单申请正常下发时候完毕更新新增状态为2=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "2");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}
}
@@ -1186,12 +1182,20 @@ public class InvoiceDistributePluginInitializer extends PluginBaseEntity {
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","转发失败:"+jsonResultEntity.getAttribute(),mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
objects.get(i).put("sendsanfzt123",false);
logger.info("========开票申请单申请数据新增下发完成,日志保存为失败============");
+ //修改下发状态
+ logger.info("===开票申请单申请正常下发时候完毕更新新增状态为2=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "2");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}
}
}
- //所有下发发送完成,修改数据状态
+ /* //所有下发发送完成,修改数据状态
for (int i = 0; i < objects.size(); i++) {
if(objects.get(i).getBoolean("sendsanfzt123")){
Map updateMap = new HashMap<>();
@@ -1201,7 +1205,7 @@ public class InvoiceDistributePluginInitializer extends PluginBaseEntity {
updateMap.put("id", objects.get(i).getString("id"));
mdmModuleDao.updateMdmSTs(updateMap);
}
- }
+ }*/
}
private void saveMdmModuleSendLogEntity(Long mdmCode,String distributeId,String dataType,String remark,String dbname,String formmain_id, String target_app, String appId, String target_api,String apiID, String source_data, String option_type) throws Exception {
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/IIncomeInvoiceDao.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/IIncomeInvoiceDao.java
index 8fb161da..10b95891 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/IIncomeInvoiceDao.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/IIncomeInvoiceDao.java
@@ -32,5 +32,7 @@ public interface IIncomeInvoiceDao extends IBaseDao
List queryZtzz(IncomeInvoiceEntity entity);
List queryByAloneId(IncomeInvoiceEntity jnquerydata);
+
+ List queryAccount(IncomeInvoiceEntity jnentity);
}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/impl/IncomeInvoiceDaoImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/impl/IncomeInvoiceDaoImpl.java
index 8582aab4..8488fc63 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/impl/IncomeInvoiceDaoImpl.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/dao/impl/IncomeInvoiceDaoImpl.java
@@ -66,5 +66,11 @@ public class IncomeInvoiceDaoImpl extends MybatisGenericDao o = (List) super.selectList(getSqlIdPrifx() + "queryByAloneId", entity);
return o;
}
+
+ @Override
+ public List queryAccount(IncomeInvoiceEntity jnentity) {
+ List o = (List) super.selectList(getSqlIdPrifx() + "queryAccountByZq", jnentity);
+ return o;
+ }
}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.java
index 27f90943..de25701b 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.java
@@ -15,6 +15,8 @@ public class IncomeInvoiceEntity extends BaseEntity {
private String field0128;
private String field0129;
private String field0130;
+ private String field0138;
+ private String field0139;
private String field0003;
@@ -121,5 +123,21 @@ public class IncomeInvoiceEntity extends BaseEntity {
public void setField0003(String field0003) {
this.field0003 = field0003;
}
+
+ public String getField0138() {
+ return field0138;
+ }
+
+ public void setField0138(String field0138) {
+ this.field0138 = field0138;
+ }
+
+ public String getField0139() {
+ return field0139;
+ }
+
+ public void setField0139(String field0139) {
+ this.field0139 = field0139;
+ }
}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.xml
index 4fc5953d..f1355be3 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.xml
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/entity/IncomeInvoiceEntity.xml
@@ -195,6 +195,8 @@
field0128 = #{field0128},
field0129 = #{field0129},
field0130 = #{field0130},
+ field0138 = #{field0138},
+ field0139 = #{field0139},
where id = #{dataId}
@@ -208,6 +210,8 @@
field0128 ,
field0129 ,
field0130 ,
+ field0138 ,
+ field0139 ,
)values(
@@ -218,6 +222,8 @@
#{field0128} ,
#{field0129} ,
#{field0130} ,
+ #{field0138} ,
+ #{field0139} ,
)
@@ -256,276 +262,276 @@
SELECT
a.ALONE_ID as ALONE_ID,
- a.M10004 as aM10004,
- a.M10005 as aM10005,
- a.M10010 as aM10010,
- a.M10012 as aM10012,
- a.M10014 as aM10014,
- a.M10019 as aM10019,
- a.M10020 as aM10020,
- a.M10021 as aM10021,
- a.M10022 as aM10022,
- a.M10025 as aM10025,
- a.M10110 as aM10110,
- a.M10027 as aM10027,
- a.M10112 as aM10112,
- a.M10029 as aM10029,
- a.M10032 as aM10032,
- a.M10033 as aM10033,
- a.M10034 as aM10034,
- a.M10035 as aM10035,
- a.M10040 as aM10040,
- a.M10128 as aM10128,
- a.M10042 as aM10042,
- a.M10130 as aM10130,
- a.M10044 as aM10044,
- a.M10045 as aM10045,
- a.M10046 as aM10046,
- a.M10047 as aM10047,
- a.M10048 as aM10048,
- a.M10049 as aM10049,
- a.M10050 as aM10050,
- a.M10051 as aM10051,
- a.M10052 as aM10052,
- a.M10053 as aM10053,
- a.M10054 as aM10054,
- a.M10055 as aM10055,
- a.M10057 as aM10057,
- a.M10059 as aM10059,
- a.M10060 as aM10060,
- a.M10061 as aM10061,
- a.M10062 as aM10062,
- a.M10063 as aM10063,
- a.M10064 as aM10064,
- a.M10065 as aM10065,
- a.M10066 as aM10066,
- a.M10073 as aM10073,
- a.M10146 as aM10146,
- a.M10075 as aM10075,
- a.M10148 as aM10148,
- a.M10077 as aM10077,
- a.M10078 as aM10078,
- a.M10079 as aM10079,
- a.M10080 as aM10080,
- a.M10081 as aM10081,
- a.M10082 as aM10082,
- a.M10083 as aM10083,
- a.M10084 as aM10084,
- a.M10087 as aM10087,
- a.M10088 as aM10088,
- a.M10091 as aM10091,
- a.M10164 as aM10164,
- a.M10093 as aM10093,
- a.M10166 as aM10166,
- a.M10095 as aM10095,
- a.M10096 as aM10096,
- a.M10097 as aM10097,
- a.M10098 as aM10098,
- a.M10099 as aM10099,
- a.M10100 as aM10100,
- a.M10101 as aM10101,
- a.M10102 as aM10102,
- a.M10105 as aM10105,
- a.M10106 as aM10106,
- a.M10109 as aM10109,
- a.M10182 as aM10182,
- a.M10111 as aM10111,
- a.M10184 as aM10184,
- a.M10113 as aM10113,
- a.M10114 as aM10114,
- a.M10115 as aM10115,
- a.M10116 as aM10116,
- a.M10117 as aM10117,
- a.M10118 as aM10118,
- a.M10119 as aM10119,
- a.M10120 as aM10120,
- a.M10123 as aM10123,
- a.M10124 as aM10124,
- a.M10127 as aM10127,
- a.M10200 as aM10200,
- a.M10129 as aM10129,
- a.M10202 as aM10202,
- a.M10131 as aM10131,
- a.M10132 as aM10132,
- a.M10133 as aM10133,
- a.M10134 as aM10134,
- a.M10135 as aM10135,
- a.M10138 as aM10138,
- a.M10141 as aM10141,
- a.M10142 as aM10142,
- a.M10143 as aM10143,
- a.M10144 as aM10144,
- a.M10145 as aM10145,
- a.M10147 as aM10147,
- a.M10149 as aM10149,
- a.M10150 as aM10150,
- a.M10151 as aM10151,
- a.M10152 as aM10152,
- a.M10153 as aM10153,
- a.M10154 as aM10154,
- a.M10155 as aM10155,
- a.M10156 as aM10156,
- a.M10257 as aM10257,
- a.M10259 as aM10259,
- a.M10159 as aM10159,
- a.M10160 as aM10160,
- a.M10161 as aM10161,
- a.M10162 as aM10162,
- a.M10163 as aM10163,
- a.M10165 as aM10165,
- a.M10167 as aM10167,
- a.M10168 as aM10168,
- a.M10169 as aM10169,
- a.M10170 as aM10170,
- a.M10171 as aM10171,
- a.M10172 as aM10172,
- a.M10173 as aM10173,
- a.M10174 as aM10174,
- a.M10281 as aM10281,
- a.M10283 as aM10283,
- a.M10179 as aM10179,
- a.M10180 as aM10180,
- a.M10181 as aM10181,
- a.M10222 as aM10222,
- a.M10183 as aM10183,
- a.M10224 as aM10224,
- a.M10185 as aM10185,
- a.M10186 as aM10186,
- a.M10187 as aM10187,
- a.M10188 as aM10188,
- a.M10189 as aM10189,
- a.M10190 as aM10190,
- a.M10191 as aM10191,
- a.M10192 as aM10192,
- a.M10295 as aM10295,
- a.M10193 as aM10193,
- a.M10297 as aM10297,
- a.M10194 as aM10194,
- a.M10195 as aM10195,
- a.M10196 as aM10196,
- a.M10197 as aM10197,
- a.M10198 as aM10198,
- a.M10199 as aM10199,
- a.M10201 as aM10201,
- a.M10203 as aM10203,
- a.M10208 as aM10208,
- a.M10209 as aM10209,
- a.M10212 as aM10212,
- a.M10310 as aM10310,
- a.M10214 as aM10214,
- a.M10312 as aM10312,
- a.M10216 as aM10216,
- a.M10217 as aM10217,
- a.M10218 as aM10218,
- a.M10219 as aM10219,
- a.M10220 as aM10220,
- a.M10221 as aM10221,
- a.M10223 as aM10223,
- a.M10225 as aM10225,
- a.M10226 as aM10226,
- a.M10227 as aM10227,
- a.M10230 as aM10230,
- a.M10231 as aM10231,
- a.M10234 as aM10234,
- a.M10325 as aM10325,
- a.M10236 as aM10236,
- a.M10327 as aM10327,
- a.M10238 as aM10238,
- a.M10239 as aM10239,
- a.M10240 as aM10240,
- a.M10241 as aM10241,
- a.M10242 as aM10242,
- a.M10243 as aM10243,
- a.M10244 as aM10244,
- a.M10245 as aM10245,
- a.M10246 as aM10246,
- a.M10247 as aM10247,
- a.M10248 as aM10248,
- a.M10249 as aM10249,
- a.M10250 as aM10250,
- a.M10251 as aM10251,
- a.M10252 as aM10252,
- a.M10253 as aM10253,
- a.M10256 as aM10256,
- a.M10340 as aM10340,
- a.M10258 as aM10258,
- a.M10342 as aM10342,
- a.M10260 as aM10260,
- a.M10265 as aM10265,
- a.M10266 as aM10266,
- a.M10267 as aM10267,
- a.M10268 as aM10268,
- a.M10269 as aM10269,
- a.M10276 as aM10276,
- a.M10277 as aM10277,
- a.M10280 as aM10280,
- a.M10282 as aM10282,
- a.M10284 as aM10284,
- a.M10287 as aM10287,
- a.M10288 as aM10288,
- a.M10289 as aM10289,
- a.M10290 as aM10290,
- a.M10291 as aM10291,
- a.M10292 as aM10292,
- a.M10293 as aM10293,
- a.M10294 as aM10294,
- a.M10011 as aM10011,
- a.M10296 as aM10296,
- a.M10013 as aM10013,
- a.M10298 as aM10298,
- a.M10299 as aM10299,
- a.M10300 as aM10300,
- a.M10301 as aM10301,
- a.M10304 as aM10304,
- a.M10305 as aM10305,
- a.M10306 as aM10306,
- a.M10307 as aM10307,
- a.M10308 as aM10308,
- a.M10309 as aM10309,
- a.M10026 as aM10026,
- a.M10311 as aM10311,
- a.M10028 as aM10028,
- a.M10313 as aM10313,
- a.M10314 as aM10314,
- a.M10315 as aM10315,
- a.M10316 as aM10316,
- a.M10319 as aM10319,
- a.M10320 as aM10320,
- a.M10321 as aM10321,
- a.M10323 as aM10323,
- a.M10326 as aM10326,
- a.M10041 as aM10041,
- a.M10328 as aM10328,
- a.M10043 as aM10043,
- a.M10329 as aM10329,
- a.M10334 as aM10334,
- a.M10335 as aM10335,
- a.M10336 as aM10336,
- a.M10338 as aM10338,
- a.M10337 as aM10337,
- a.M10339 as aM10339,
- a.M10341 as aM10341,
- a.M10056 as aM10056,
- a.M10343 as aM10343,
- a.M10058 as aM10058,
- a.M10344 as aM10344,
- a.M10347 as aM10347,
- a.M10348 as aM10348,
- a.M10349 as aM10349,
- a.M10350 as aM10350,
- a.M10351 as aM10351,
- a.M10352 as aM10352,
- a.M10353 as aM10353,
- a.M10354 as aM10354,
- b.MPQW10U as bMPQW10U,
- b.MP81A2Z as bMP81A2Z,
- b.MS13DPL as bMS13DPL,
- b.M6TFKPL as bM6TFKPL,
- c.M10002 as cM10002,
- c.M10000 as cM10000,
- c.M10004 as cM10004,
- c.M10003 as cM10003,
- c.M10001 as cM10001
+ a.M10004 as AM10004,
+ a.M10005 as AM10005,
+ a.M10010 as AM10010,
+ a.M10012 as AM10012,
+ a.M10014 as AM10014,
+ a.M10019 as AM10019,
+ a.M10020 as AM10020,
+ a.M10021 as AM10021,
+ a.M10022 as AM10022,
+ a.M10025 as AM10025,
+ a.M10110 as AM10110,
+ a.M10027 as AM10027,
+ a.M10112 as AM10112,
+ a.M10029 as AM10029,
+ a.M10032 as AM10032,
+ a.M10033 as AM10033,
+ a.M10034 as AM10034,
+ a.M10035 as AM10035,
+ a.M10040 as AM10040,
+ a.M10128 as AM10128,
+ a.M10042 as AM10042,
+ a.M10130 as AM10130,
+ a.M10044 as AM10044,
+ a.M10045 as AM10045,
+ a.M10046 as AM10046,
+ a.M10047 as AM10047,
+ a.M10048 as AM10048,
+ a.M10049 as AM10049,
+ a.M10050 as AM10050,
+ a.M10051 as AM10051,
+ a.M10052 as AM10052,
+ a.M10053 as AM10053,
+ a.M10054 as AM10054,
+ a.M10055 as AM10055,
+ a.M10057 as AM10057,
+ a.M10059 as AM10059,
+ a.M10060 as AM10060,
+ a.M10061 as AM10061,
+ a.M10062 as AM10062,
+ a.M10063 as AM10063,
+ a.M10064 as AM10064,
+ a.M10065 as AM10065,
+ a.M10066 as AM10066,
+ a.M10073 as AM10073,
+ a.M10146 as AM10146,
+ a.M10075 as AM10075,
+ a.M10148 as AM10148,
+ a.M10077 as AM10077,
+ a.M10078 as AM10078,
+ a.M10079 as AM10079,
+ a.M10080 as AM10080,
+ a.M10081 as AM10081,
+ a.M10082 as AM10082,
+ a.M10083 as AM10083,
+ a.M10084 as AM10084,
+ a.M10087 as AM10087,
+ a.M10088 as AM10088,
+ a.M10091 as AM10091,
+ a.M10164 as AM10164,
+ a.M10093 as AM10093,
+ a.M10166 as AM10166,
+ a.M10095 as AM10095,
+ a.M10096 as AM10096,
+ a.M10097 as AM10097,
+ a.M10098 as AM10098,
+ a.M10099 as AM10099,
+ a.M10100 as AM10100,
+ a.M10101 as AM10101,
+ a.M10102 as AM10102,
+ a.M10105 as AM10105,
+ a.M10106 as AM10106,
+ a.M10109 as AM10109,
+ a.M10182 as AM10182,
+ a.M10111 as AM10111,
+ a.M10184 as AM10184,
+ a.M10113 as AM10113,
+ a.M10114 as AM10114,
+ a.M10115 as AM10115,
+ a.M10116 as AM10116,
+ a.M10117 as AM10117,
+ a.M10118 as AM10118,
+ a.M10119 as AM10119,
+ a.M10120 as AM10120,
+ a.M10123 as AM10123,
+ a.M10124 as AM10124,
+ a.M10127 as AM10127,
+ a.M10200 as AM10200,
+ a.M10129 as AM10129,
+ a.M10202 as AM10202,
+ a.M10131 as AM10131,
+ a.M10132 as AM10132,
+ a.M10133 as AM10133,
+ a.M10134 as AM10134,
+ a.M10135 as AM10135,
+ a.M10138 as AM10138,
+ a.M10141 as AM10141,
+ a.M10142 as AM10142,
+ a.M10143 as AM10143,
+ a.M10144 as AM10144,
+ a.M10145 as AM10145,
+ a.M10147 as AM10147,
+ a.M10149 as AM10149,
+ a.M10150 as AM10150,
+ a.M10151 as AM10151,
+ a.M10152 as AM10152,
+ a.M10153 as AM10153,
+ a.M10154 as AM10154,
+ a.M10155 as AM10155,
+ a.M10156 as AM10156,
+ a.M10257 as AM10257,
+ a.M10259 as AM10259,
+ a.M10159 as AM10159,
+ a.M10160 as AM10160,
+ a.M10161 as AM10161,
+ a.M10162 as AM10162,
+ a.M10163 as AM10163,
+ a.M10165 as AM10165,
+ a.M10167 as AM10167,
+ a.M10168 as AM10168,
+ a.M10169 as AM10169,
+ a.M10170 as AM10170,
+ a.M10171 as AM10171,
+ a.M10172 as AM10172,
+ a.M10173 as AM10173,
+ a.M10174 as AM10174,
+ a.M10281 as AM10281,
+ a.M10283 as AM10283,
+ a.M10179 as AM10179,
+ a.M10180 as AM10180,
+ a.M10181 as AM10181,
+ a.M10222 as AM10222,
+ a.M10183 as AM10183,
+ a.M10224 as AM10224,
+ a.M10185 as AM10185,
+ a.M10186 as AM10186,
+ a.M10187 as AM10187,
+ a.M10188 as AM10188,
+ a.M10189 as AM10189,
+ a.M10190 as AM10190,
+ a.M10191 as AM10191,
+ a.M10192 as AM10192,
+ a.M10295 as AM10295,
+ a.M10193 as AM10193,
+ a.M10297 as AM10297,
+ a.M10194 as AM10194,
+ a.M10195 as AM10195,
+ a.M10196 as AM10196,
+ a.M10197 as AM10197,
+ a.M10198 as AM10198,
+ a.M10199 as AM10199,
+ a.M10201 as AM10201,
+ a.M10203 as AM10203,
+ a.M10208 as AM10208,
+ a.M10209 as AM10209,
+ a.M10212 as AM10212,
+ a.M10310 as AM10310,
+ a.M10214 as AM10214,
+ a.M10312 as AM10312,
+ a.M10216 as AM10216,
+ a.M10217 as AM10217,
+ a.M10218 as AM10218,
+ a.M10219 as AM10219,
+ a.M10220 as AM10220,
+ a.M10221 as AM10221,
+ a.M10223 as AM10223,
+ a.M10225 as AM10225,
+ a.M10226 as AM10226,
+ a.M10227 as AM10227,
+ a.M10230 as AM10230,
+ a.M10231 as AM10231,
+ a.M10234 as AM10234,
+ a.M10325 as AM10325,
+ a.M10236 as AM10236,
+ a.M10327 as AM10327,
+ a.M10238 as AM10238,
+ a.M10239 as AM10239,
+ a.M10240 as AM10240,
+ a.M10241 as AM10241,
+ a.M10242 as AM10242,
+ a.M10243 as AM10243,
+ a.M10244 as AM10244,
+ a.M10245 as AM10245,
+ a.M10246 as AM10246,
+ a.M10247 as AM10247,
+ a.M10248 as AM10248,
+ a.M10249 as AM10249,
+ a.M10250 as AM10250,
+ a.M10251 as AM10251,
+ a.M10252 as AM10252,
+ a.M10253 as AM10253,
+ a.M10256 as AM10256,
+ a.M10340 as AM10340,
+ a.M10258 as AM10258,
+ a.M10342 as AM10342,
+ a.M10260 as AM10260,
+ a.M10265 as AM10265,
+ a.M10266 as AM10266,
+ a.M10267 as AM10267,
+ a.M10268 as AM10268,
+ a.M10269 as AM10269,
+ a.M10276 as AM10276,
+ a.M10277 as AM10277,
+ a.M10280 as AM10280,
+ a.M10282 as AM10282,
+ a.M10284 as AM10284,
+ a.M10287 as AM10287,
+ a.M10288 as AM10288,
+ a.M10289 as AM10289,
+ a.M10290 as AM10290,
+ a.M10291 as AM10291,
+ a.M10292 as AM10292,
+ a.M10293 as AM10293,
+ a.M10294 as AM10294,
+ a.M10011 as AM10011,
+ a.M10296 as AM10296,
+ a.M10013 as AM10013,
+ a.M10298 as AM10298,
+ a.M10299 as AM10299,
+ a.M10300 as AM10300,
+ a.M10301 as AM10301,
+ a.M10304 as AM10304,
+ a.M10305 as AM10305,
+ a.M10306 as AM10306,
+ a.M10307 as AM10307,
+ a.M10308 as AM10308,
+ a.M10309 as AM10309,
+ a.M10026 as AM10026,
+ a.M10311 as AM10311,
+ a.M10028 as AM10028,
+ a.M10313 as AM10313,
+ a.M10314 as AM10314,
+ a.M10315 as AM10315,
+ a.M10316 as AM10316,
+ a.M10319 as AM10319,
+ a.M10320 as AM10320,
+ a.M10321 as AM10321,
+ a.M10323 as AM10323,
+ a.M10326 as AM10326,
+ a.M10041 as AM10041,
+ a.M10328 as AM10328,
+ a.M10043 as AM10043,
+ a.M10329 as AM10329,
+ a.M10334 as AM10334,
+ a.M10335 as AM10335,
+ a.M10336 as AM10336,
+ a.M10338 as AM10338,
+ a.M10337 as AM10337,
+ a.M10339 as AM10339,
+ a.M10341 as AM10341,
+ a.M10056 as AM10056,
+ a.M10343 as AM10343,
+ a.M10058 as AM10058,
+ a.M10344 as AM10344,
+ a.M10347 as AM10347,
+ a.M10348 as AM10348,
+ a.M10349 as AM10349,
+ a.M10350 as AM10350,
+ a.M10351 as AM10351,
+ a.M10352 as AM10352,
+ a.M10353 as AM10353,
+ a.M10354 as AM10354,
+ b.MPQW10U as BMPQW10U,
+ b.MP81A2Z as BMP81A2Z,
+ b.MS13DPL as BMS13DPL,
+ b.M6TFKPL as BM6TFKPL,
+ c.M10002 as CM10002,
+ c.M10000 as CM10000,
+ c.M10004 as CM10004,
+ c.M10003 as CM10003,
+ c.M10001 as CM10001
FROM
iufo_measure_data_qi0xy5nl a
LEFT JOIN iufo_measure_data_v40w9co7 b on a.ALONE_ID = b.ALONE_ID
@@ -534,5 +540,183 @@
and a.ALONE_ID = #{aloneId}
+
+
+
+
+
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/plugin/FinancialReportPluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/plugin/FinancialReportPluginInitializer.java
index 81153779..d10e99f8 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/plugin/FinancialReportPluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/plugin/FinancialReportPluginInitializer.java
@@ -3,6 +3,7 @@ package com.hzya.frame.plugin.incomeInvoiceData.plugin;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.incomeInvoiceData.service.IIncomeInvoiceService;
+import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -53,7 +54,8 @@ public class FinancialReportPluginInitializer extends PluginBaseEntity{
public JsonResultEntity executeBusiness(JSONObject requestJson) {
try {
logger.info("======开始执行财务信息同步========");
- return incomeInvoiceService.sendFinancialReportPlugin(requestJson);
+ return BaseResult.getSuccessMessageEntity("数据获取成功");
+ //return incomeInvoiceService.sendFinancialReportPlugin(requestJson);
}catch (Exception e){
logger.info("======执行财务同步失败:{}========",e.getMessage());
e.printStackTrace();
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java
index 916c69a3..b0ee7ad6 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java
@@ -17,7 +17,6 @@ import com.hzya.frame.uuid.UUIDLong;
import com.hzya.frame.uuid.UUIDUtils;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
-import org.apache.commons.collections.CollectionUtils;
import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
@@ -33,7 +32,9 @@ import org.apache.http.util.EntityUtils;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import com.hzya.frame.basedao.service.impl.BaseService;
+import org.springframework.core.task.TaskExecutor;
+import javax.annotation.Resource;
import javax.net.ssl.SSLContext;
import java.io.IOException;
import java.math.BigDecimal;
@@ -62,6 +63,9 @@ public class IncomeInvoiceServiceImpl extends BaseService parametersMap = new HashMap<>();
- parametersMap.put("accessKey",accessKey);
- parametersMap.put("timestamp",timestamp);
- String a = YzfSignUtil.signRequest(parametersMap,accessSecret);
- dayabody.put("sign",a);
+ if(flags) {
+ Map parametersMap = new HashMap<>();
+ parametersMap.put("accessKey",accessKey);
+ parametersMap.put("timestamp",timestamp);
+ String a = YzfSignUtil.signRequest(parametersMap,accessSecret);
+ dayabody.put("sign",a);
+ }
Map headers = new HashMap<>();
headers.put("Content-Type", "application/json; charset=utf-8");
String returndata = sendPost(url, headers, dayabody.toJSONString());
@@ -405,56 +428,6 @@ public class IncomeInvoiceServiceImpl extends BaseService headers) {
- SSLContext sslContext = null;
- try {
- sslContext = new SSLContextBuilder()
- .loadTrustMaterial(null, TrustAllStrategy.INSTANCE)
- .build();
- } catch (Exception e) {
-
- }
- CloseableHttpClient closeableHttpClient = HttpClients.custom()
- .setSSLContext(sslContext)
- .setSSLHostnameVerifier(NoopHostnameVerifier.INSTANCE)
- .build();
- // HttpClient
- HttpGet get = new HttpGet(url);
- CloseableHttpResponse response = null;
-
- RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000).build();
- get.setConfig(requestConfig);//设置请求参数【超时时间】
- if (headers != null && headers.size() > 0) {
- for (String key : headers.keySet()) {
- get.setHeader(key, headers.get(key));
- }
- }
- StringBuilder body = new StringBuilder();
-
- try {
- response = closeableHttpClient.execute(get);
- HttpEntity entity = response.getEntity();
- body.append(EntityUtils.toString(entity,"UTF-8"));
- logger.info("返回结果:" + body);
- } catch (Exception e) {
- logger.error("请求错误:" + e.getMessage());
- body.append(e.getMessage());
- } finally {
- try {
- // 关闭响应对象
- if (response != null) {
- response.close();
- }
- // 关闭响应对象
- if (closeableHttpClient != null) {
- closeableHttpClient.close();
- }
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- return body.toString();
- }
/**
@@ -488,7 +461,9 @@ public class IncomeInvoiceServiceImpl extends BaseService list = incomeInvoiceDao.queryOaZb(incomeInvoiceEntity);
if(list != null && list.size() == 1){
incomeInvoiceEntity.setFormmainId(list.get(0).getDataId());
@@ -539,7 +514,9 @@ public class IncomeInvoiceServiceImpl extends BaseService");
stringBuffer.append("");
stringBuffer.append("");
- stringBuffer.append("");
+ stringBuffer.append("");
+ stringBuffer.append("");
+ stringBuffer.append("");
stringBuffer.append("");
stringBuffer.append("");
@@ -631,8 +608,19 @@ public class IncomeInvoiceServiceImpl extends BaseService":"");
stringBuffer.append("").append("");
- stringBuffer.append("").append("");
- stringBuffer.append(jsonObject.getString("fpwj") != null?"":"");
+ stringBuffer.append("").append("");
+ //stringBuffer.append(jsonObject.getString("url") != null?"":"");
+ stringBuffer.append("");
+ stringBuffer.append("").append("");
+
+ stringBuffer.append("").append("");
+ //stringBuffer.append(jsonObject.getString("ofdurl") != null?"":"");
+ stringBuffer.append("");
+ stringBuffer.append("").append("");
+
+ stringBuffer.append("").append("");
+ //stringBuffer.append(jsonObject.getString("xmlurl") != null?"":"");
+ stringBuffer.append("");
stringBuffer.append("").append("");
@@ -695,22 +683,36 @@ public class IncomeInvoiceServiceImpl extends BaseService sendAccountCodeReport(ztbm,cjzq,rwbm));//科目余额
+ return BaseResult.getSuccessMessageEntity("数据获取成功");
+ }
+ if(businessDataStr.getString("dataType").equals("2")){//财报
+ if(ztbm == null || "".equals(ztbm)){
+ return BaseResult.getFailureMessageEntity("账套编码为空");
+ }
+ if(cjzq == null || "".equals(cjzq)){
+ return BaseResult.getFailureMessageEntity("采集账期为空");
+ }
+ if(rwbm == null || "".equals(rwbm)){
+ return BaseResult.getFailureMessageEntity("任务编码为空");
+ }
+ taskExecutor.execute(() -> sendFinancialReport(ztbm,cjzq,rwbm));
+ return BaseResult.getSuccessMessageEntity("数据获取成功");
}
- if(businessData.getString("field0007").equals("2")){//财报
- return sendFinancialReport(businessData);
- }
- if(businessData.getString("field0007").equals("3")){//进项发票
+ if(businessDataStr.getString("dataType").equals("3")){//进项发票
return BaseResult.getFailureMessageEntity("数据类型错误");
}
- if(businessData.getString("field0007").equals("4")){//销项发票
+ if(businessDataStr.getString("dataType").equals("4")){//销项发票
return BaseResult.getFailureMessageEntity("数据类型错误");
}
return BaseResult.getSuccessMessageEntity("推送数据成功");
@@ -722,39 +724,77 @@ public class IncomeInvoiceServiceImpl extends BaseService jnlist = incomeInvoiceDao.queryAccount(jnentity);
+ //正常来说数组不存在空的情况 如果为空就直接下发空数组给他们
+ JSONObject sendData = new JSONObject();
+ sendData.put("accessKey",accessKey);
+ long timestamp = System.currentTimeMillis();
+ sendData.put("timestamp",timestamp);
+ sendData.put("taskNo",rwbm);
+ sendData.put("period",cjzq);
+ String a = YzfSignUtil.signRequest(sendData,accessSecret);
+ sendData.put("sign",a);
+ sendData.put("balanceTableList",jnlist);
+ Map headers = new HashMap<>();
+ headers.put("Content-Type", "application/json; charset=utf-8");
+ String returndata = sendPost(url, headers, sendData.toJSONString());
+ if (returndata != null && JSONObject.isValidObject(returndata)) {
+ JSONObject dataJson = JSONObject.parseObject(returndata);
+ if(dataJson != null && dataJson.getString("code") != null && "0".equals( dataJson.getString("code"))){
+ JSONObject data = dataJson.getJSONObject("result");
+ if(data != null ){
+ if(data != null && data.getString("resultCode") != null && "0".equals( data.getString("resultCode"))){
+ return BaseResult.getSuccessMessageEntity("执行成功");
+ }else {
+ return BaseResult.getFailureMessageEntity("发送失败:"+data.getString("message"));
+ }
+ }else {
+ return BaseResult.getFailureMessageEntity("发送失败:"+returndata);
+ }
+ }else {
+ return BaseResult.getFailureMessageEntity("发送失败:"+returndata);
+ }
+ }else {
+ return BaseResult.getFailureMessageEntity("发送失败:"+returndata);
+ }
+ }
+
+
+ /**
+ * @Author lvleigang
+ * @Description
+ * @Date 3:18 下午 2025/4/24
+ * @param ztbm 账套编码
+ * @param cjzq 采集账期
+ * @param rwbm 任务编码
+ * @return com.hzya.frame.web.entity.JsonResultEntity
+ **/
+ private JsonResultEntity sendFinancialReport(String ztbm ,String cjzq,String rwbm) {
+ String access_token = "";
+ if(flags){
+ access_token = getToken();
+ if (access_token == null) {
+ return BaseResult.getFailureMessageEntity("token获取失败");
+ }
+ }
+
String url = cbUrl+access_token;
- String ztbm = businessData.getString("field0005");//账套编码
- String sh = businessData.getString("field0006");//税号
- String sjlx = businessData.getString("field0007");//数据类型
- String cjzq = businessData.getString("field0008");//采集账期
- String rwbm = businessData.getString("field0009");//任务编码
- if(ztbm == null || "".equals(ztbm)){
- return BaseResult.getSuccessMessageEntity("账套编码为空");
- }
- if(cjzq == null || "".equals(cjzq)){
- return BaseResult.getSuccessMessageEntity("采集账期为空");
- }
- if(rwbm == null || "".equals(rwbm)){
- return BaseResult.getSuccessMessageEntity("任务编码为空");
- }
-
-
Date date = null;
String qncjzq = null;
-
IncomeInvoiceEntity dyAloneId = null;
JSONObject dydata = null;
JSONObject qndata = null;
@@ -774,7 +814,7 @@ public class IncomeInvoiceServiceImpl extends BaseService jnlist = incomeInvoiceDao.queryZtzz(jnentity);
@@ -785,7 +825,7 @@ public class IncomeInvoiceServiceImpl extends BaseService qnlist = incomeInvoiceDao.queryZtzz(qnentity);
@@ -797,7 +837,7 @@ public class IncomeInvoiceServiceImpl extends BaseService dydataList = incomeInvoiceDao.queryByAloneId(jnquerydata);
if(dydataList != null && dydataList.size() == 1){
@@ -809,7 +849,7 @@ public class IncomeInvoiceServiceImpl extends BaseService qndataList = incomeInvoiceDao.queryByAloneId(qnquerydata);
if(qndataList != null && qndataList.size() == 1){
@@ -818,45 +858,167 @@ public class IncomeInvoiceServiceImpl extends BaseService headers = new HashMap<>();
headers.put("Content-Type", "application/json; charset=utf-8");
String returndata = sendPost(url, headers, sendData.toJSONString());
@@ -869,7 +1031,7 @@ public class IncomeInvoiceServiceImpl extends BaseService updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "F");
+ updateMap.put("updateStatus", "1");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}else {
//保存日志
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","转发失败:"+jsonResultEntity.getAttribute(),mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"2");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "F");
+ updateMap.put("updateStatus", "2");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}
}
}
- //所有下发发送完成,修改数据状态
+ /*//所有下发发送完成,修改数据状态
for (int i = 0; i < objects.size(); i++) {
Map updateMap = new HashMap<>();
updateMap.put("tableName",mainDb);
@@ -904,7 +918,7 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
updateMap.put("updateStatus", "1");
updateMap.put("id", objects.get(i).getString("id"));
mdmModuleDao.updateMdmSTs(updateMap);
- }
+ }*/
}
/**
@@ -1083,19 +1097,19 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
continue;
}
JSONObject attritube = JSONObject.parseObject(rzjsonResultEntity.getAttribute().toString());
- logger.info("=======主数据正常新增下发登录返回数据:{}========",attritube.toJSONString());
+ logger.info("=======中信司库付款单数据正常新增下发登录返回数据:{}========",attritube.toJSONString());
querys = getQuery(apiEntity,querys,attritube);
headers = getHeaders(apiEntity,headers,attritube);
bodys = getBodys(apiEntity,bodys,attritube);
}
//组装数据发送
- logger.info("=========开始执行主业务新增数据下发脚本,第二次==============");
+ logger.info("=========开始执行中信司库付款单新增数据下发脚本,第二次==============");
JsonResultEntity jsonResultEntity = sendData(apiEntity,headers,bodys,querys);
- logger.info("=====主数据新增下发返回结果为:{}",JSONObject.parseObject(jsonResultEntity.getAttribute().toString()).toJSONString());
+ logger.info("=====中信司库付款单新增下发返回结果为:{}",JSONObject.parseObject(jsonResultEntity.getAttribute().toString()).toJSONString());
if(jsonResultEntity.isFlag()){
if (scriptEntity != null && scriptEntity.getId() != null && scriptEntity.getBackScriptData() != null ) {
- logger.info("=========开始执行主数据新增返回脚本==============");
+ logger.info("=========开始执行中信司库付款单新增返回脚本==============");
JSONObject backScriptJson = new JSONObject();
backScriptJson.put("data", jsonResultEntity.getAttribute());
groovy.put("code", scriptEntity.getScriptCode()+"back");
@@ -1124,30 +1138,54 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
mdmModuleDistributeTripartiteEntity.setAppId(sysApplicationEntity.getId());
mdmModuleDistributeTripartiteEntity.setTripartiteId(backJsonResultEntity.getString("tripartiteId"));
mdmModuleDistributeTripartiteDao.save(mdmModuleDistributeTripartiteEntity);
+ //修改下发状态
+ logger.info("===中信司库付款单正常下发时候完毕更新新增状态为1=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "1");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
}
}
} catch (Exception e) {
- logger.error("新增返回脚本解析保存三方id错误"+jsonResultEntity.getAttribute());
+ logger.error("中信司库付款单新增返回脚本解析保存三方id错误"+jsonResultEntity.getAttribute());
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","新增返回脚本解析保存三方id错误",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
+ //修改下发状态
+ logger.info("===中信司库付款单正常下发时候完毕更新新增状态为2=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "2");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}
}
//保存日志
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"1","发送成功",mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
objects.get(i).put("sendsanfzt123",true);
- logger.info("========主数据新增下发完成,日志保存为成功============");
+ logger.info("========中信司库付款单新增下发完成,日志保存为成功============");
continue;
}else {
//保存日志
saveMdmModuleSendLogEntity(mainCode,mdmModuleDistributeEntities.get(i1).getId(),"2","转发失败:"+jsonResultEntity.getAttribute(),mainDb,objects.get(i).getString("id"),sysApplicationEntity.getName(),sysApplicationEntity.getId(),apiEntity.getApiName(),apiEntity.getId(),doObjects.get(i).toJSONString(),"1");
objects.get(i).put("sendsanfzt123",false);
- logger.info("========主数据新增下发完成,日志保存为失败============");
+ logger.info("========中信司库付款单新增下发完成,日志保存为失败============");
+ //修改下发状态
+ logger.info("===中信司库付款单正常下发时候完毕更新新增状态为2=======");
+ Map updateMap = new HashMap<>();
+ updateMap.put("tableName",mainDb);
+ //updateMap.put("dataStatus", "Y");
+ updateMap.put("addStatus", "2");
+ updateMap.put("id", objects.get(i).getString("id"));
+ mdmModuleDao.updateMdmSTs(updateMap);
continue;
}
}
}
- //所有下发发送完成,修改数据状态
+ /* //所有下发发送完成,修改数据状态
for (int i = 0; i < objects.size(); i++) {
if(objects.get(i).getBoolean("sendsanfzt123")){
Map updateMap = new HashMap<>();
@@ -1157,7 +1195,7 @@ public class ZxBankDistributePluginInitializer extends PluginBaseEntity {
updateMap.put("id", objects.get(i).getString("id"));
mdmModuleDao.updateMdmSTs(updateMap);
}
- }
+ }*/
}
private void saveMdmModuleSendLogEntity(Long mdmCode,String distributeId,String dataType,String remark,String dbname,String formmain_id, String target_app, String appId, String target_api,String apiID, String source_data, String option_type) throws Exception {
diff --git a/base-buildpackage/src/main/resources/application-dev.yml b/base-buildpackage/src/main/resources/application-dev.yml
new file mode 100644
index 00000000..4121bb71
--- /dev/null
+++ b/base-buildpackage/src/main/resources/application-dev.yml
@@ -0,0 +1,42 @@
+#######################dev环境#######################
+logging:
+ #日志级别 指定目录级别
+ level:
+ root: warn
+ encodings: GBK
+ file:
+ # 日志保存路径
+ path: /home/webservice/zt/log
+spring:
+ datasource:
+ dynamic:
+ datasource:
+ master:
+ url: jdbc:mysql://ufidahz.com.cn:9014/businesscenter?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowLoadLocalInfile=false&autoReconnect=true&failOverReadOnly=false&connectTimeout=30000&socketTimeout=30000&autoReconnectForPools=true
+ username: root
+ password: bd993088e8a7c3dc5f44441617f9b4bf
+ driver-class-name: com.mysql.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
+savefile:
+ # 文件保存路径
+ path: /home/webservice/zt/file
+# path: D:\webservice\file
+# pluginpath: D:\webservice\plugin
+ pluginpath: /home/webservice/zt/plugin
+# tomcatpath: D:\apache-tomcat-9.0.69\webapps\kangarooDataCenter\WEB-INF\classes\
+ tomcatpath: /home/webservice/zt/tomcatV3/webapps/kangarooDataCenterV3/WEB-INF/classes/
+cbs8:
+ appId: 1P4AGrpz
+ appSecret: 2c2369ae5dc04382844bbe3a5abf39e1bea9cd3a
+ url: https://cbs8-openapi-reprd.csuat.cmburl.cn
+ # 测试用这个 这个是银行给的,和下面的公钥不是一对密钥
+ ya_private_key: 83BA7EC821D35F4CB31FF9A51C1EFA520FC52AF828C2337F88E91CF119B07F44
+ # 这个私钥到时候上传到cbs,和下面到是同一对
+ #ya_private_key: e1eacfdee9b8d4184437d5a2071e17ce31befc3d93395f9f05709ed562e8dc46
+ ya_public_key: 044fa399d2223760f17b81b863cb482b009294c4516f8a605dea1475ec09e720eaa98468715e5ad509a592a0b426061551c5a3df236966c23253a7d894eac0dcde
+ cbs_public_key: 0469146F06BF3B01236E84632441E826
+ #电子回单下载临时存放位置
+ elec_path: /Users/xiangerlin/Downloads/
+OA:
+ data_source_code: yc_oa
+zt:
+ url: http://127.0.0.1:9082/kangarooDataCenterV3/entranceController/externalCallInterface
diff --git a/base-common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java b/base-common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java
index ff02bcc4..329daca0 100644
--- a/base-common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java
+++ b/base-common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java
@@ -1,5 +1,6 @@
package com.hzya.frame.execsql.service;
+import cn.hutool.core.util.StrUtil;
import com.hzya.frame.datasource.DataSourceUtil;
import com.hzya.frame.execsql.entity.ExecSqlEntity;
import org.apache.ibatis.session.SqlSession;
@@ -80,7 +81,7 @@ public class ExecSqlServiceImpl implements IExecSqlService {
@Override
public int execUpdateSql(String sql, String data_source_code) throws Exception {
logger.info("=============进入execUpdateSql方法============");
- if (ObjectUtils.isEmpty(sql)) {
+ if (StrUtil.isNotEmpty(sql)) {
if (sql.contains("where") || sql.contains("WHERE")) {
// SqlSession sqlSession = getSqlSession(data_source_code);
// SqlSession sqlSession = new DataSourceUtil().getDefaultSqlSession();
diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java
index ee5ee3a1..ac2aaef4 100644
--- a/base-service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java
+++ b/base-service/src/main/java/com/hzya/frame/sysnew/grovy/service/impl/GroovyIntegrationServiceImpl.java
@@ -34,49 +34,67 @@ public class GroovyIntegrationServiceImpl implements IGroovyIntegrationService {
}
public static void main(String[] args) {
- java.lang.String str = "{\"data\":{\"enablestate\":\"2\",\"user_password\":\"Hzya@1314\",\"gender\":\"12312\",\"user_name\":\"测试用户\",\"modify_time\":1719305835000,\"document_rule_num\":112,\"pk_org\":{\"org_mnecode\":\"1\",\"modify_time\":1718866279000,\"document_rule_num\":4,\"add_status\":\"0\",\"org_address\":\"1\",\"delete_status\":\"1\",\"org_innercode\":\"1\",\"id\":\"f7a8cee35fce4aa8ab266b3c7f125d7d\",\"data_status\":\"F\",\"modify_user_id\":\"1\",\"org_name\":\"开发部\",\"sorts\":4,\"document_rule\":\"ZZ-2024-06-20-00004\",\"create_user_id\":\"1\",\"create_time\":1718864103000,\"company_id\":\"Y\",\"org_memo\":\"1\",\"update_status\":\"0\",\"sts\":\"Y\",\"org_tel\":\"1\",\"org_id\":\"Y\",\"org_ncindustry\":\"1\",\"org_fatherorg\":\"c4913dde8da142bab4206fc084269382\",\"org_code\":\"003\",\"org_principal\":\"1\",\"org_countryzone\":\"1\"},\"add_status\":\"0\",\"pwdlevelcode\":\"\",\"user_type\":\"1\",\"user_code\":\"17633965916\",\"delete_status\":\"1\",\"id\":\"d99fe4e1c211450a960f7a1057da0d2c\",\"data_status\":\"F\",\"modify_user_id\":\"1\",\"sorts\":346,\"document_rule\":\"YH-2024-06-25-00112\",\"create_user_id\":\"1\",\"create_time\":1719305229000,\"company_id\":\"Y\",\"user_code_q\":\"KP003\",\"format\":\"ZH-CN\",\"mobile\":\"123123\",\"identityverifycode\":\"静态密码验证\",\"islocked\":\"N\",\"update_status\":\"0\",\"base_doc_type\":\"0\",\"sts\":\"Y\",\"login_name\":\"123123\",\"pwdparam\":\"2024-06-17\",\"org_id\":\"Y\",\"abledate\":\"2024-06-17 00:00:00\",\"isca\":\"Y\",\"contentlang\":\"ZH\"},\"query\":\"[]\",\"header\":\"[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"length\\\":\\\"100\\\",\\\"index\\\":0,\\\"description\\\":\\\"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA87rrNR\\\",\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"7127798c-b731-453a-b3ac-cfe9033eeace\\\",\\\"parameterName\\\":\\\"pubKey\\\",\\\"required\\\":true,\\\"example\\\":\\\"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA87rrNREgMNeOEOwlvM2iqqEfshDadRHziDSB2PbRnoMqSv1nGr3XBlZuseNj5HmxDEkLhOdfyw0yjzoz3wK7XhFpeN4Iyf7NT7hps5jAQMEpnul9Qwmj5qUr/eK5SaO9H8n7sh9BvCdrX9oRUh+U2/ceA3O+y/MUHk5DRvSadc8FhpqbOaNBbAzPnyYAwpVUPvaJ90jcGN1ZG99HR1GEzC+Cn9s6vgt7dYL6ysMs36bSP47xraDSxpfr0CLwa6JV/9KjLIeqL1ZaMtK0CJ1zJGCBA6O6kgxeE9Ul7q2lSS6mPAEJ78izaTYsrjhLpKT+eTtFBOLFbiCrbLp8tVE5kwIDAQAB\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"length\\\":\\\"50\\\",\\\"index\\\":1,\\\"description\\\":\\\"OA\\\",\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"7f965281-df0f-4d2f-b005-07e061fcde49\\\",\\\"parameterName\\\":\\\"client_id\\\",\\\"required\\\":true,\\\"example\\\":\\\"OA\\\"},{\\\"parameterType\\\":\\\"authport\\\",\\\"length\\\":\\\"50\\\",\\\"index\\\":2,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"cbc0e105-17c0-4385-8863-8903303edc1f\\\",\\\"parameterName\\\":\\\"access_token\\\",\\\"example\\\":[\\\"attribute\\\",\\\"data\\\",\\\"access_token\\\"]}]\",\"body\":\"[{\\\"index\\\":0,\\\"id\\\":\\\"beeedbc6-24c2-4093-9a5e-20fced9fb1b4\\\",\\\"parameterName\\\":\\\"body\\\",\\\"first\\\":true}]\"}";
+ java.lang.String str = "{\"data\":{\"year\":\"2024\",\"prepared\":\"demo\",\"modify_time\":1730863191000,\"num\":\"13\",\"gl_detail\":[{\"create_user_id\":\"1\",\"amount\":\"5000\",\"formmain_id\":\"9da5a28900084951913df0d233427178\",\"create_time\":1730863191000,\"company_id\":\"0\",\"globalcreditamount\":\"0\",\"modify_time\":1730863191000,\"localcreditamount\":\"0\",\"localdebitamount\":\"5000\",\"explanation\":\"演示分录1\",\"globaldebitamount\":\"5000\",\"detail_id\":\"1\",\"groupdebitamount\":\"5000\",\"sts\":\"Y\",\"currtype_code\":\"CNY\",\"org_id\":\"0\",\"busidate\":\"2024-11-05\",\"groupcreditamount\":\"0\",\"detailindex\":\"1\",\"account_code\":\"100210\",\"id\":\"0eb6d3d5f12944e1bcbb00883cc4f13e\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":1},{\"create_user_id\":\"1\",\"amount\":\"5000\",\"formmain_id\":\"9da5a28900084951913df0d233427178\",\"create_time\":1730863191000,\"company_id\":\"0\",\"globalcreditamount\":\"5000\",\"modify_time\":1730863191000,\"localcreditamount\":\"5000\",\"localdebitamount\":\"0\",\"explanation\":\"演示分录2\",\"globaldebitamount\":\"0\",\"detail_id\":\"2\",\"groupdebitamount\":\"0\",\"sts\":\"Y\",\"currtype_code\":\"CNY\",\"org_id\":\"0\",\"busidate\":\"2024-11-05\",\"groupcreditamount\":\"5000\",\"detailindex\":\"2\",\"account_code\":\"2231\",\"id\":\"db9c531af7a94af2975d1c9f1ae21813\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":2}],\"document_rule_num\":1,\"add_status\":\"0\",\"vouchertype\":\"01\",\"attachment\":\"0\",\"delete_status\":\"1\",\"id\":\"9da5a28900084951913df0d233427178\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":1,\"document_rule\":\"PZ-20241106-00001\",\"create_user_id\":\"1\",\"period\":\"11\",\"create_time\":1730863191000,\"company_id\":\"Y\",\"update_status\":\"1\",\"accbook_code\":\"101-0002\",\"sts\":\"Y\",\"org_id\":\"Y\",\"prepareddate\":\"2024-11-05\",\"voucher_id\":\"1\",\"gl_fixtmpfreevalue\":[{\"create_user_id\":\"1\",\"formmain_id\":\"9da5a28900084951913df0d233427178\",\"create_time\":1730863191000,\"company_id\":\"0\",\"checktypecode\":\"0012\",\"modify_time\":1730863191000,\"checkvaluecode\":\"101\",\"detail_id\":\"2\",\"sts\":\"Y\",\"org_id\":\"0\",\"voucher_id\":\"1\",\"id\":\"779d40051ae3470583885d9c202d5ba1\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":1},{\"create_user_id\":\"1\",\"formmain_id\":\"9da5a28900084951913df0d233427178\",\"create_time\":1730863191000,\"company_id\":\"0\",\"checktypecode\":\"0006\",\"modify_time\":1730863191000,\"checkvaluecode\":\"000001\",\"detail_id\":\"2\",\"sts\":\"Y\",\"org_id\":\"0\",\"voucher_id\":\"1\",\"id\":\"f313361e495445958245ec61a00a1216\",\"data_status\":\"Y\",\"modify_user_id\":\"1\",\"sorts\":2}]},\"query\":\"[]\",\"header\":\"[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":0,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"77ba4bd1-c693-488f-b3b7-69bb4c02be76\\\",\\\"parameterName\\\":\\\"pubKey\\\",\\\"example\\\":\\\"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmlnN6sXjhJN6wUY0DILqiIL1ZX9ZU5Q40Hrr+4qhf3fddV/+/D1CyJo7aVGd3mJjD1BC1RXtnfxetaLzLrfTViq80RQvmmmKgt6rKiYMiW8ibcWoKaWMvwrlm0uT7RzYeXDP0l4qvoe8vjVWL63mQbx0y17p4opwTA9BV7P/CZ+9QyIJstN+yAg/owlNn48Jq4WspQps0/Zl/HvpiRjAPggVOqZLXkCjoBGrpNn/tlrDFbt+btK7tjhvsfT1zPMVAq8dNUKCMw5LoLsMxfT/ZWlI62zUAIbyO2/0iv5kCZw0I+DxPmGKVEOQ4x9FwXosSSD202H93CuBvVy/P31iUwIDAQAB\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"index\\\":1,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"df32aa53-9c8e-4d31-8a9b-d78bc70f9214\\\",\\\"parameterName\\\":\\\"client_id\\\",\\\"example\\\":\\\"u8c\\\"},{\\\"parameterType\\\":\\\"authport\\\",\\\"index\\\":2,\\\"concreteType\\\":\\\"String\\\",\\\"id\\\":\\\"de304f55-ca04-47d9-93f9-70b52d9bba50\\\",\\\"parameterName\\\":\\\"access_token\\\",\\\"example\\\":[\\\"attribute\\\",\\\"data\\\",\\\"access_token\\\"]}]\",\"body\":\"[{\\\"parameterType\\\":\\\"complex\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"complex\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":2,\\\"parameterName\\\":\\\"accbookCode\\\",\\\"id\\\":\\\"95ff2224-bdb7-4a9d-a45b-8c19f444022b\\\",\\\"example\\\":\\\"X0644-0001\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":3,\\\"parameterName\\\":\\\"prepareddate\\\",\\\"id\\\":\\\"7106bf79-133c-446e-be58-bf18d43a7c14\\\",\\\"example\\\":\\\"2023-09-19\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":4,\\\"parameterName\\\":\\\"year\\\",\\\"id\\\":\\\"9b005ca9-e246-41c0-bbbb-aead5d6f44f1\\\",\\\"example\\\":\\\"2023\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":5,\\\"parameterName\\\":\\\"num\\\",\\\"id\\\":\\\"fbe1d3a2-69e9-4df7-91d0-bb9005cd333e\\\",\\\"example\\\":\\\"4\\\"},{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":7,\\\"parameterName\\\":\\\"detailindex\\\",\\\"id\\\":\\\"386e20b9-5992-4a95-8fa7-fb64677d55e9\\\",\\\"example\\\":\\\"1\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":8,\\\"parameterName\\\":\\\"explanation\\\",\\\"id\\\":\\\"20cab876-bd5a-46b8-96ba-7112104a273f\\\",\\\"example\\\":\\\"测试\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":9,\\\"parameterName\\\":\\\"accountCode\\\",\\\"id\\\":\\\"e1a89672-8449-4bda-a404-478f0594ac70\\\",\\\"example\\\":\\\"150401\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":10,\\\"parameterName\\\":\\\"currtypeCode\\\",\\\"id\\\":\\\"43b33900-c5da-4afb-bbd7-0865bd02db58\\\",\\\"example\\\":\\\"CNY\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":11,\\\"parameterName\\\":\\\"amount\\\",\\\"id\\\":\\\"4b0fd6a4-b1d0-489e-aec1-ca509e9221ad\\\",\\\"example\\\":\\\"1000\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":12,\\\"parameterName\\\":\\\"localdebitamount\\\",\\\"id\\\":\\\"9a43ad19-f903-4a8a-a5ac-f13c9fba445e\\\",\\\"example\\\":\\\"1000\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":13,\\\"parameterName\\\":\\\"localcreditamount\\\",\\\"id\\\":\\\"df2d1f92-89cb-411d-83ba-62366e931dba\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":14,\\\"parameterName\\\":\\\"groupdebitamount\\\",\\\"id\\\":\\\"61965366-0500-40d7-bae4-5dd16eb90761\\\",\\\"example\\\":\\\"1000\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":15,\\\"parameterName\\\":\\\"groupcreditamount\\\",\\\"id\\\":\\\"bdc3c6c2-de87-45f1-85cf-24f3b92920c6\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":16,\\\"parameterName\\\":\\\"globaldebitamount\\\",\\\"id\\\":\\\"a6069792-2a6b-43ba-97d7-504e1c5e3156\\\",\\\"example\\\":\\\"1000\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":17,\\\"parameterName\\\":\\\"globalcreditamount\\\",\\\"id\\\":\\\"528b2c6b-86a5-47ec-8b26-00259dacb0b4\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":18,\\\"parameterName\\\":\\\"busidate\\\",\\\"id\\\":\\\"11636e2a-b9d8-4ee3-81fc-0e809d11bf4f\\\",\\\"example\\\":\\\"2023-09-19\\\"},{\\\"parameterType\\\":\\\"complexlist\\\",\\\"children\\\":[{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":20,\\\"parameterName\\\":\\\"checktypecode\\\",\\\"id\\\":\\\"b56bf160-7180-47ea-996a-acd8307eb5fa\\\",\\\"example\\\":\\\"0004\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":21,\\\"parameterName\\\":\\\"checkvaluecode\\\",\\\"id\\\":\\\"88d4fbb0-d3b7-4f1e-981d-71e60d10e603\\\",\\\"example\\\":\\\"X0015\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":19,\\\"parameterName\\\":\\\"ass\\\",\\\"id\\\":\\\"c10103af-f382-4c9b-a8f4-0738b664abb0\\\"}],\\\"concreteType\\\":\\\"ObjectCom\\\",\\\"index\\\":6,\\\"parameterName\\\":\\\"detail\\\",\\\"id\\\":\\\"70f9d810-039e-4884-b986-bc5b75331fb4\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":22,\\\"parameterName\\\":\\\"period\\\",\\\"id\\\":\\\"de91d6ad-c07b-4f84-a8c9-52e87de39d50\\\",\\\"example\\\":\\\"09\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":23,\\\"parameterName\\\":\\\"vouchertype\\\",\\\"id\\\":\\\"5de12ed3-d27e-4848-a008-5fb2e5c656a8\\\",\\\"example\\\":\\\"01\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":24,\\\"parameterName\\\":\\\"attachment\\\",\\\"id\\\":\\\"cc0ae4fb-5f33-46c9-a0bf-775b46ae8511\\\",\\\"example\\\":\\\"0\\\"},{\\\"parameterType\\\":\\\"fundamental\\\",\\\"concreteType\\\":\\\"String\\\",\\\"index\\\":25,\\\"parameterName\\\":\\\"prepared\\\",\\\"id\\\":\\\"4b1622d6-980e-4920-82d0-e078e8bdb009\\\",\\\"example\\\":\\\"zhuc\\\"}],\\\"concreteType\\\":\\\"Object\\\",\\\"index\\\":1,\\\"parameterName\\\":\\\"sendData\\\",\\\"id\\\":\\\"2fc2918b-73fd-4c31-ba9f-1721132f1fdf\\\"}],\\\"concreteType\\\":\\\"Object\\\",\\\"index\\\":0,\\\"id\\\":\\\"669eebef-e4ae-474e-9b88-46a5490dc3db\\\",\\\"parameterName\\\":\\\"body\\\",\\\"first\\\":true}]\"}";
A88772 s = new A88772();
s.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.JSONObject reqData = com.alibaba.fastjson.JSON.parseObject(jsonStr);
com.alibaba.fastjson.JSONObject data = reqData.getJSONObject("data");
- com.alibaba.fastjson.JSONObject ufinterfaceObject = new com.alibaba.fastjson.JSONObject();
- ufinterfaceObject.put("billtype", "customer");
- ufinterfaceObject.put("isexchange", "Y");
- ufinterfaceObject.put("replace", "Y");
- ufinterfaceObject.put("sender", "openUser");
- ufinterfaceObject.put("account", "ycjf");
- ufinterfaceObject.put("groupcode", "ycjf");
- com.alibaba.fastjson.JSONObject billObject = new com.alibaba.fastjson.JSONObject();
- com.alibaba.fastjson.JSONObject billheadObject = new com.alibaba.fastjson.JSONObject();
- billheadObject.put("code", data.get("code"));
- billheadObject.put("custprop", data.get("custprop"));
- billheadObject.put("custstate", data.get("custstate"));
- billheadObject.put("pk_custclass", data.get("pk_custclass"));
- billheadObject.put("pk_country", data.get("pk_country"));
- billheadObject.put("pk_timezone", "P0800");
- billheadObject.put("pk_format", "ZH-CN");
- billheadObject.put("enablestate", data.get("enablestate"));
- billheadObject.put("name", data.get("name"));
- billheadObject.put("pk_group", data.get("pk_group"));
- billheadObject.put("pk_org", data.get("pk_org"));
- billheadObject.put("taxpayerid", data.get("taxpayerid"));
- billObject.put("billhead", billheadObject);
- ufinterfaceObject.put("bill", billObject);
- bodys.put("ufinterface", ufinterfaceObject);
- returnObject.put("bodys",bodys.toJSONString());
+ com.alibaba.fastjson.JSONArray gl_detail = data.getJSONArray("gl_detail");
+ com.alibaba.fastjson.JSONArray gl_fixtmpfreevalue = data.getJSONArray("gl_fixtmpfreevalue");
+
+ com.alibaba.fastjson.JSONObject returnObject = new com.alibaba.fastjson.JSONObject();
+ com.alibaba.fastjson.JSONObject sendData = new com.alibaba.fastjson.JSONObject();
+ sendData.put("accbookCode",data.getString("accbook_code"));
+ sendData.put("prepareddate",data.getString("prepareddate"));
+ sendData.put("year",data.getString("year"));
+ sendData.put("num",data.getString("num"));
+ sendData.put("period",data.getString("period"));
+ sendData.put("vouchertype",data.getString("vouchertype"));
+ sendData.put("attachment",data.getString("attachment"));
+ sendData.put("prepared",data.getString("prepared"));
+ com.alibaba.fastjson.JSONArray detail = new com.alibaba.fastjson.JSONArray();
+ if(gl_detail != null && gl_detail.size() > 0){
+ for (int i = 0; i < gl_detail.size(); i++) {
+ com.alibaba.fastjson.JSONObject detaildata = gl_detail.getJSONObject(i);
+ com.alibaba.fastjson.JSONObject object1 = new com.alibaba.fastjson.JSONObject();
+ object1.put("detailindex",detaildata.getString("detailindex"));
+ object1.put("explanation",detaildata.getString("explanation"));
+ object1.put("accountCode",detaildata.getString("account_code"));
+ object1.put("currtypeCode",detaildata.getString("currtype_code"));
+ object1.put("amount",detaildata.getString("amount"));
+ object1.put("localdebitamount",detaildata.getString("localdebitamount"));
+ object1.put("localcreditamount",detaildata.getString("localcreditamount"));
+ object1.put("groupdebitamount",detaildata.getString("groupdebitamount"));
+ object1.put("groupcreditamount",detaildata.getString("groupcreditamount"));
+ object1.put("globaldebitamount",detaildata.getString("globaldebitamount"));
+ object1.put("globalcreditamount",detaildata.getString("globalcreditamount"));
+ object1.put("busidate",detaildata.getString("busidate"));
+ detail.add(object1);
+ if(gl_fixtmpfreevalue != null && gl_fixtmpfreevalue.size() > 0){
+ com.alibaba.fastjson.JSONArray ass = new com.alibaba.fastjson.JSONArray();
+ for (int i1 = 0; i1 < gl_fixtmpfreevalue.size(); i1++) {
+ if(gl_fixtmpfreevalue.getJSONObject(i1).getString("voucher_id").equals(data.getString("voucher_id"))
+ && gl_fixtmpfreevalue.getJSONObject(i1).getString("detail_id").equals(detaildata.getString("detail_id"))){
+ com.alibaba.fastjson.JSONObject assdetail1 = new com.alibaba.fastjson.JSONObject();
+ assdetail1.put("checktypecode",gl_fixtmpfreevalue.getJSONObject(i1).getString("checktypecode"));
+ assdetail1.put("checkvaluecode",gl_fixtmpfreevalue.getJSONObject(i1).getString("checkvaluecode"));
+ ass.add(assdetail1);
+ }
+ }
+ if(ass.size() > 0){
+ object1.put("ass",ass);
+
+ }
+ }
+ }
+ }
+ sendData.put("detail",detail);
+ returnObject.put("bodys",sendData);
return returnObject.toJSONString();
-
-
-
-
-
}
}
diff --git a/base-webapp/pom.xml b/base-webapp/pom.xml
index 3507e248..f751b1fe 100644
--- a/base-webapp/pom.xml
+++ b/base-webapp/pom.xml
@@ -18,11 +18,11 @@
base-service
${revision}
-
-
-
-
-
+
+ com.hzya.frame
+ fw-bip
+ ${revision}
+
diff --git a/fw-bip/pom.xml b/fw-bip/pom.xml
new file mode 100644
index 00000000..f0f762fa
--- /dev/null
+++ b/fw-bip/pom.xml
@@ -0,0 +1,85 @@
+
+
+
+ kangarooDataCenterV3
+ com.hzya.frame
+ ${revision}
+
+ 4.0.0
+ fw-bip
+ jar
+ ${revision}
+
+
+
+ com.hzya.frame
+ base-service
+ ${revision}
+
+
+ mysql
+ mysql-connector-java
+ ${mysql-connector-java}
+
+
+
+ com.hzya.bip
+ pubbaseapp_nccloud_rtLevel
+ 1
+ system
+ ${basedir}/src/main/webapp/WEB-INF/lib/pubbaseapp_nccloud_rtLevel-1.jar
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+ none
+ execute
+ true
+
+
+
+
+ repackage
+
+
+
+
+
+
+
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipArchivesDao.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipArchivesDao.java
new file mode 100644
index 00000000..02516313
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipArchivesDao.java
@@ -0,0 +1,15 @@
+package com.hzya.frame.bip.v3.v2207.dao;
+
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipArchivesEntity;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsEntity;
+
+import java.util.List;
+
+
+public interface IBipArchivesDao extends IBaseDao {
+
+ List queryArchivesData(BipArchivesEntity archivesEntity);
+ List queryArchivesDatays(BipArchivesEntity archivesEntity);
+
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDao.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDao.java
new file mode 100644
index 00000000..0ad05a4c
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDao.java
@@ -0,0 +1,17 @@
+package com.hzya.frame.bip.v3.v2207.dao;
+
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsEntity;
+
+import java.util.List;
+
+
+public interface IBipOrgsDao extends IBaseDao {
+
+ /**
+ * 查询BIP业务单元
+ * @param BipOrgsEntity
+ * @return
+ */
+ List thirdInterfaceGetOrgs(BipOrgsEntity BipOrgsEntity);
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDetailsDao.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDetailsDao.java
new file mode 100644
index 00000000..e0e6ea3f
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipOrgsDetailsDao.java
@@ -0,0 +1,17 @@
+package com.hzya.frame.bip.v3.v2207.dao;
+
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsDetailsEntity;
+
+import java.util.List;
+
+
+public interface IBipOrgsDetailsDao extends IBaseDao {
+
+ /**
+ * 查询BIP业务单元银行账户
+ * @param BipOrgsDetailsEntity
+ * @return
+ */
+ List thirdInterfaceGetOrgsDetails(BipOrgsDetailsEntity BipOrgsDetailsEntity);
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDao.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDao.java
new file mode 100644
index 00000000..ba069080
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDao.java
@@ -0,0 +1,18 @@
+package com.hzya.frame.bip.v3.v2207.dao;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierEntity;
+
+import java.util.List;
+
+
+public interface IBipSupplierDao extends IBaseDao {
+
+ /**
+ * 查询BIP供应商
+ * @param bipSupplierEntity
+ * @return
+ */
+ List thirdInterfaceGetSupplier(BipSupplierEntity bipSupplierEntity);
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDetailsDao.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDetailsDao.java
new file mode 100644
index 00000000..2edaa29e
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/IBipSupplierDetailsDao.java
@@ -0,0 +1,18 @@
+package com.hzya.frame.bip.v3.v2207.dao;
+
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierDetailsEntity;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierEntity;
+
+import java.util.List;
+
+
+public interface IBipSupplierDetailsDao extends IBaseDao {
+
+ /**
+ * 查询BIP供应商明细
+ * @param bipSupplierDetailsEntity
+ * @return
+ */
+ List thirdInterfaceGetSupplierDetails(BipSupplierDetailsEntity bipSupplierDetailsEntity);
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipArchivesDaoImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipArchivesDaoImpl.java
new file mode 100644
index 00000000..987d702c
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipArchivesDaoImpl.java
@@ -0,0 +1,25 @@
+package com.hzya.frame.bip.v3.v2207.dao.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipArchivesDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipOrgsDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipArchivesEntity;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsEntity;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository("bipArchivesDaoImpl")
+public class BipArchivesDaoImpl extends MybatisGenericDao implements IBipArchivesDao {
+
+ @Override
+ public List queryArchivesData(BipArchivesEntity entity) {
+ List o = super.query(getSqlIdPrifx() + "queryArchivesData", entity);
+ return o;
+ } @Override
+ public List queryArchivesDatays(BipArchivesEntity entity) {
+ List o = super.query(getSqlIdPrifx() + "queryArchivesDatays", entity);
+ return o;
+ }
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDaoImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDaoImpl.java
new file mode 100644
index 00000000..478c54ca
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDaoImpl.java
@@ -0,0 +1,24 @@
+package com.hzya.frame.bip.v3.v2207.dao.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipOrgsDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipSupplierDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsEntity;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository("bipOrgsDaoImpl")
+public class BipOrgsDaoImpl extends MybatisGenericDao implements IBipOrgsDao {
+ /**
+ * 查询BIP业务单元
+ * @param BipOrgsEntity
+ * @return
+ */
+ @DS("oracle91")
+ @Override
+ public List thirdInterfaceGetOrgs(BipOrgsEntity BipOrgsEntity) {
+ return super.query("com.hzya.frame.bip.v3.v2207.dao.impl.BipOrgsDaoImpl.thirdInterfaceGetOrgs",BipOrgsEntity);
+ }
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDetailsDaoImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDetailsDaoImpl.java
new file mode 100644
index 00000000..5d51da6d
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipOrgsDetailsDaoImpl.java
@@ -0,0 +1,19 @@
+package com.hzya.frame.bip.v3.v2207.dao.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipOrgsDetailsDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipSupplierDetailsDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipOrgsDetailsEntity;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository("bipOrgsDetailsDaoImpl")
+public class BipOrgsDetailsDaoImpl extends MybatisGenericDao implements IBipOrgsDetailsDao {
+ @DS("oracle91")
+ @Override
+ public List thirdInterfaceGetOrgsDetails(BipOrgsDetailsEntity bipOrgsDetailsEntity) {
+ return super.query("com.hzya.frame.bip.v3.v2207.dao.impl.BipOrgsDetailsDaoImpl.thirdInterfaceGetOrgsDetails",bipOrgsDetailsEntity);
+ }
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDaoImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDaoImpl.java
new file mode 100644
index 00000000..9abe9ee7
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDaoImpl.java
@@ -0,0 +1,25 @@
+package com.hzya.frame.bip.v3.v2207.dao.impl;
+
+import cn.hutool.http.HttpRequest;
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipSupplierDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierEntity;
+import com.hzya.frame.util.HttpUtil;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository("bipSupplierDaoImpl")
+public class BipSupplierDaoImpl extends MybatisGenericDao implements IBipSupplierDao {
+ /**
+ * 查询BIP供应商
+ * @param bipSupplierEntity
+ * @return
+ */
+ @DS("oracle91")
+ @Override
+ public List thirdInterfaceGetSupplier(BipSupplierEntity bipSupplierEntity) {
+ return super.query("com.hzya.frame.bip.v3.v2207.dao.impl.BipSupplierDaoImpl.thirdInterfaceGetSupplier",bipSupplierEntity);
+ }
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDetailsDaoImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDetailsDaoImpl.java
new file mode 100644
index 00000000..89443371
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dao/impl/BipSupplierDetailsDaoImpl.java
@@ -0,0 +1,20 @@
+package com.hzya.frame.bip.v3.v2207.dao.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipSupplierDao;
+import com.hzya.frame.bip.v3.v2207.dao.IBipSupplierDetailsDao;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierDetailsEntity;
+import com.hzya.frame.bip.v3.v2207.entity.BipSupplierEntity;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository("bipSupplierDetailsDaoImpl")
+public class BipSupplierDetailsDaoImpl extends MybatisGenericDao implements IBipSupplierDetailsDao {
+ @DS("oracle91")
+ @Override
+ public List thirdInterfaceGetSupplierDetails(BipSupplierDetailsEntity bipSupplierDetailsEntity) {
+ return super.query("com.hzya.frame.bip.v3.v2207.dao.impl.BipSupplierDetailsDaoImpl.thirdInterfaceGetSupplierDetails",bipSupplierDetailsEntity);
+ }
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/IPayMentService.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/IPayMentService.java
new file mode 100644
index 00000000..ba800dce
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/IPayMentService.java
@@ -0,0 +1,38 @@
+package com.hzya.frame.bip.v3.v2207.dps.service;
+
+import com.alibaba.fastjson.JSONObject;
+
+
+public interface IPayMentService {
+
+ /**
+ *
+ * @content 获取杭泰OA付款单传递CFS
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/16 11:59
+ * **/
+ String sendOAPayMentToCFS(JSONObject jsonObject, String type);
+
+ /**
+ *
+ * @content 获取CFS登录校验码
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/16 13:37
+ * **/
+ String sendCFSToken(String name, String password);
+
+ /**
+ *
+ * @content 获取杭泰OA报销单传递CFS
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/16 16:17
+ * **/
+ String sendExpenseToCFS(JSONObject jsonObject);
+
+}
diff --git a/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/impl/PayMentServiceImpl.java b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/impl/PayMentServiceImpl.java
new file mode 100644
index 00000000..1b9308a5
--- /dev/null
+++ b/fw-bip/src/main/java/com/hzya/frame/bip/v3/v2207/dps/service/impl/PayMentServiceImpl.java
@@ -0,0 +1,389 @@
+package com.hzya.frame.bip.v3.v2207.dps.service.impl;
+
+import cn.hutool.http.HttpRequest;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.hzya.frame.bip.v3.v2207.dps.service.IPayMentService;
+import com.hzya.frame.dateutil.DateUtil;
+import org.dom4j.Document;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Element;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.xml.sax.InputSource;
+
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import java.io.StringReader;
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+
+@Service(value = "payMentServiceImpl")
+public class PayMentServiceImpl implements IPayMentService {
+
+ private static final Logger logger = LoggerFactory.getLogger(PayMentServiceImpl.class);
+
+ private static final String NAME="admin";
+ private static final String PASSWORD="aHRzejg4OA==";
+ private static final String CFSURL="http://101.132.140.208:26883/erp/services/";//测试端口:26893,正式端口:26883
+
+ /**
+ *
+ * @content 杭泰OA付款单传递CFS 注:付款单,资金归集,资金拨付,同名账户划转和借款单都用同一个接口
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/13 10:40
+ * **/
+ public String sendOAPayMentToCFS(JSONObject jsonStr,String type){
+ logger.info("开始执行杭泰OA付款单传递CFS");
+ try {
+ String cfsToken = sendCFSToken(NAME, PASSWORD);
+ if(null!=cfsToken) {
+ String jsonStrObj = jsonStr.getString("jsonStr");
+ JSONObject jsonObjectMain = JSON.parseObject(jsonStrObj);
+ String erpVoucherNo = jsonObjectMain.getString("erpVoucherNo");//OA主键
+ String purpose = jsonObjectMain.getString("purpose");//摘要
+ String isForindividual = "0";//是否对私付款
+ StringBuffer stringBuffer = new StringBuffer();
+ String documentType=null;
+ switch (type){
+ case "pay"://付款单
+ documentType="01";
+ break;
+ case "fundc"://资金归集
+ documentType="02";
+ break;
+ case "funda"://资金拨付
+ documentType="03";
+ break;
+ case "acc"://同名账户划转
+ documentType="04";
+ break;
+ case "loan"://借款单
+ documentType="05";
+ break;
+ default:
+ break;
+ }
+ JSONArray jsonStrList = jsonObjectMain.getJSONArray("details");
+ if (null != jsonStrList && jsonStrList.size() > 0) {
+ for (Object seeyonEntity : jsonStrList) {
+ JSONObject jsonObjectFormson = JSON.parseObject(JSON.toJSONString(seeyonEntity));
+ String payerAccName = jsonObjectFormson.getString("payerAccName");//转出方账户名(付款账户)
+ String payerAccNo = jsonObjectFormson.getString("payerAccNo");//转出方账号(付款账号)
+ String curCode = jsonObjectFormson.getString("curCode");//付款方币种
+ String payeeAccName = jsonObjectFormson.getString("payeeAccName");//收款人帐户名称
+ String payeeAccNo = jsonObjectFormson.getString("payeeAccNo");//收款方账户号
+ BigDecimal amount = jsonObjectFormson.getBigDecimal("amount");//发生额
+ String payeeBankCode = jsonObjectFormson.getString("payeeBankCode");//联行号
+ String isQuick = jsonObjectFormson.getString("isQuick");//加急标志
+ String payType = jsonObjectFormson.getString("payType");//结算方式
+ String businessType = jsonObjectFormson.getString("businessType");//业务类别
+ stringBuffer.append("\n");
+ }
+ } else {
+ stringBuffer.append("\n");
+ }
+ String result=null;
+ String xml= requestXML(cfsToken,"BkPaymentMainExchange",stringBuffer,"OA付款单同步发送");
+ String url = "HTSZ_OA_BkPaymentMainWebService?wsdl";
+ switch (type){
+ case "pay"://付款单
+ logger.info("OA付款单发送CFS的请求参数为:{}", xml);
+ result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA付款单发送CFS的返回参数为:{}", result);
+ break;
+ case "fundc"://资金归集
+ logger.info("OA资金归集发送CFS的请求参数为:{}", xml);
+ result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA资金归集发送CFS的返回参数为:{}", result);
+ break;
+ case "funda"://资金调拨
+ logger.info("OA资金拨付发送CFS的请求参数为:{}", xml);
+ result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA资金拨付发送CFS的返回参数为:{}", result);
+ break;
+ case "acc"://同名账户划转
+ logger.info("OA同名账户划转发送CFS的请求参数为:{}", xml);
+ result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA同名账户划转发送CFS的返回参数为:{}", result);
+ break;
+ case "loan"://借款单
+ logger.info("OA借还款发送CFS的请求参数为:{}", xml);
+ result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA借还款发送CFS的返回参数为:{}", result);
+ break;
+ default:
+ break;
+ }
+ return analyzeXML(result,"pay");
+ }else{
+ logger.info("请先登录CFS登录接口获取Token");
+ return null;
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.info("杭泰OA付款单传递CFS错误,原因为:{}", e.getMessage());
+ }
+ return null;
+ }
+
+ /**
+ *
+ * @content 获取CFS登录校验码
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/13 15:38
+ * **/
+ public String sendCFSToken(String name,String password) {
+ try {
+ String xml="\n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ "\n" +
+ "\n" +
+ "LogOn\n" +
+ ""+DateUtil.dateToString(new Date(), "yyyy-MM-dd HH:mm:ss")+"\n" +
+ "OA\n" +
+ "CFS\n" +
+ "OA登录验证发送\n" +
+ "\n" +
+ "\n" +
+ ""+name+"\n" +
+ ""+password+"\n" +
+ "\n" +
+ "\n" +
+ " ]]>\n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ "";
+ logger.info("CFS登录的请求参数为:{}",xml);
+ String url="HTSZ_OA_LogOnWebService?wsdl";
+ String result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("CFS登录的返回参数为:{}",result);
+ return analyzeXML(result,"login");
+ }catch (Exception e){
+ e.printStackTrace();
+ logger.info("获取CFS登录失败,原因为:{}",e.getMessage());
+ }
+ return null;
+ }
+
+ /**
+ *
+ * @content 获取杭泰OA报销单传递CFS
+ * @Param
+ * @Return
+ * @Author hecan
+ * @Date 2023/10/16 16:17
+ * **/
+ @Override
+ public String sendExpenseToCFS(JSONObject jsonStr) {
+ logger.info("开始执行杭泰OA报销单传递CFS");
+ try {
+ String token = sendCFSToken(NAME, PASSWORD);
+ if(null != token){
+ String jsonStrObj = jsonStr.getString("jsonStr");
+ JSONObject jsonObjectMain = JSON.parseObject(jsonStrObj);
+ String erpVoucherNo = jsonObjectMain.getString("erpVoucherNo");//OA主键
+ String purpose = jsonObjectMain.getString("purpose");//摘要
+ StringBuffer stringBuffer = new StringBuffer();
+ JSONArray jsonStrList = jsonObjectMain.getJSONArray("details");
+ if(null != jsonStrList && jsonStrList.size()>0){
+ for (Object o : jsonStrList) {
+ JSONObject jsonObjectDetails = JSON.parseObject(JSON.toJSONString(o));
+ String payerAccName = jsonObjectDetails.getString("payerAccName");//转出方账户名(付款账户)
+ String payerAccNo = jsonObjectDetails.getString("payerAccNo");//转出方账号(付款账号)
+ String curCode = jsonObjectDetails.getString("curCode");//付款方币种
+ String payeeAccName = jsonObjectDetails.getString("payeeAccName");//收款人帐户名称
+ String payeeAccNo = jsonObjectDetails.getString("payeeAccNo");//收款方账户号
+ BigDecimal amount = jsonObjectDetails.getBigDecimal("amount");//发生额
+ String payeeBankCode = jsonObjectDetails.getString("payeeBankCode");//联行号
+ String isQuick = jsonObjectDetails.getString("isQuick");//加急标志
+ String payType = jsonObjectDetails.getString("payType");//结算方式
+ stringBuffer.append("\n");
+ }
+ } else {
+ stringBuffer.append("\n");
+ }
+ String xml= requestXML(token,"BkExpenseExchange",stringBuffer,"OA费用报销单同步发送");
+ logger.info("OA报销单发送CFS的请求参数为:{}", xml);
+ String url = "HTSZ_OA_BkExpenseWebService?wsdl";
+ String result = HttpRequest.post(CFSURL+url).header("Content-Type", "soap/xml").timeout(30000).body(xml).execute().body();
+ logger.info("OA报销单发送CFS的返回参数为:{}", result);
+ return analyzeXML(result,"pay");
+ }
+ }catch (Exception e){
+ logger.info("杭泰OA报销单传递CFS错误,原因为:{}", e.getMessage());
+ }
+ return null;
+ }
+
+ //null转成空字符串
+ private static String nullConvert(String str){
+ if (null == str){
+ return "";
+ }
+ return str;
+ }
+
+ private String requestXML(String token,String code,StringBuffer stringBuffer,String remark){
+ String xml = "\n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ "\n" +
+ "\n" +
+ "" + code + "\n" +
+ "" + DateUtil.dateToString(new Date(), "yyyy-MM-dd HH:mm:ss") + "\n" +
+ "OA\n" +
+ "CFS\n" +
+ "" + remark + "\n" +
+ "" + token + "\n" +
+ "\n" +
+ "\n" +
+ "\n";
+ if (stringBuffer != null) {
+ xml += stringBuffer.toString();
+ xml += "
\n" +
+ "\n" +
+ "\n" +
+ " ]]>\n" +
+ " \n" +
+ " \n" +
+ " \n" +
+ "";
+ } else {
+ xml += "\n" +
+ "