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

fw-u8c分支结构上传

This commit is contained in:
lvleigang 2024-09-14 10:17:59 +08:00
parent f0db5772a2
commit 2537ece2b1
38 changed files with 4814 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
base-webapp/pom.xml
View File

@ -65,11 +65,11 @@
<!-- <version>${revision}</version>--> <!-- <version>${revision}</version>-->
<!-- </dependency>--> <!-- </dependency>-->
<!-- <dependency>--> <dependency>
<!-- <groupId>com.hzya.frame</groupId>--> <groupId>com.hzya.frame</groupId>
<!-- <artifactId>fw-u8c</artifactId>--> <artifactId>fw-u8c</artifactId>
<!-- <version>${revision}</version>--> <version>${revision}</version>
<!-- </dependency>--> </dependency>
<!-- <dependency>--> <!-- <dependency>-->
<!-- <groupId>com.hzya.frame</groupId>--> <!-- <groupId>com.hzya.frame</groupId>-->

48
fw-u8c/pom.xml Normal file
View File

@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>kangarooDataCenterV3</artifactId>
<groupId>com.hzya.frame</groupId>
<version>${revision}</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>fw-u8c</artifactId>
<packaging>jar</packaging>
<version>${revision}</version>
<dependencies>
<dependency>
<groupId>com.hzya.frame</groupId>
<artifactId>base-service</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql-connector-java}</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<mainClass>none</mainClass> <!-- 取消查找本项目下的Main方法：为了解决Unable to find main class的问题 -->
<classifier>execute</classifier> <!-- 为了解决依赖模块找不到此模块中的类或属性 -->
<skip>true</skip>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

19
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/dao/IEncapsulationDao.java Normal file
View File

@ -0,0 +1,19 @@
package com.hzya.frame.u8c.Encapsulation.dao;
import com.hzya.frame.basedao.dao.IBaseDao;
import com.hzya.frame.u8c.Encapsulation.entity.EncapsulationEntity;
import java.util.List;
/**
* (bd_corp: table)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
public interface IEncapsulationDao extends IBaseDao<EncapsulationEntity, String> {
List<EncapsulationEntity> queryCgrkddh(EncapsulationEntity encapsulationEntity);
}

30
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/dao/impl/EncapsulationDaoImpl.java Normal file
View File

@ -0,0 +1,30 @@
package com.hzya.frame.u8c.Encapsulation.dao.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import com.hzya.frame.u8c.Encapsulation.dao.IEncapsulationDao;
import com.hzya.frame.u8c.Encapsulation.entity.EncapsulationEntity;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* (BdCorp)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
@Repository("encapsulationDaoImpl")
public class EncapsulationDaoImpl extends MybatisGenericDao<EncapsulationEntity, String> implements IEncapsulationDao {
@DS("#entity.dataSourceCode")
@Override
public List<EncapsulationEntity> queryCgrkddh(EncapsulationEntity entity) {
List<EncapsulationEntity> o = (List<EncapsulationEntity>) super.selectList(getSqlIdPrifx() + "queryCgrkddh", entity);
return o;
}
}

53
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/entity/EncapsulationEntity.java Normal file
View File

@ -0,0 +1,53 @@
package com.hzya.frame.u8c.Encapsulation.entity;
import com.hzya.frame.web.entity.BaseEntity;
/**
* (BdCorp)实体类
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
public class EncapsulationEntity extends BaseEntity {
//单据号
private String code;
//来源单据类型
private String type;
//公司
private String unitcode;
//单据类型
private String cbilltypecode;
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
public String getCbilltypecode() {
return cbilltypecode;
}
public void setCbilltypecode(String cbilltypecode) {
this.cbilltypecode = cbilltypecode;
}
public String getUnitcode() {
return unitcode;
}
public void setUnitcode(String unitcode) {
this.unitcode = unitcode;
}
}

23
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/entity/EncapsulationEntity.xml Normal file
View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.u8c.Encapsulation.dao.impl.EncapsulationDaoImpl">
<select id="queryCgrkddh" resultType="com.hzya.frame.u8c.Encapsulation.entity.EncapsulationEntity" parameterType = "com.hzya.frame.u8c.Encapsulation.entity.EncapsulationEntity">
SELECT
h.vbillcode as code,
a.unitcode
FROM
ic_general_h h
LEFT JOIN bd_corp a on a.pk_corp = h.pk_corp
WHERE
h.cgeneralhid in (
SELECT cgeneralhid FROM ic_general_b WHERE vfirstbillcode = #{code}
<if test="type != null and type != ''"> and csourcetype = #{type} </if>
)
<if test="cbilltypecode != null and cbilltypecode != ''"> and h.cbilltypecode = #{cbilltypecode} </if>
</select>
</mapper>

104
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/service/IEncapsulationService.java Normal file
View File

@ -0,0 +1,104 @@
package com.hzya.frame.u8c.Encapsulation.service;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.basedao.service.IBaseService;
import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity;
import com.hzya.frame.u8c.Encapsulation.entity.EncapsulationEntity;
/**
* (BdCorp)表服务接口
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
public interface IEncapsulationService extends IBaseService<EncapsulationEntity, String> {
/**
* @Author lvleigang
* @Description 采购订单删除接口
* 0、根据采购订单号查询入库单号,1、库存采购入库单取消签字，2、库存采购入库单删除,3、采购订单弃审,4、采购订单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object purchaseOrderDelete(JSONObject jsonObject);
SysExtensionApiEntity addPurchaseOrderDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 采购入库单删除接口
* 1、库存采购入库单取消签字，2、库存采购入库单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object purchaseWarehousingDelete(JSONObject jsonObject);
SysExtensionApiEntity addPurchaseWarehousingDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 销售订单删除接口
* 0、根据销售钉订单号查询出销售出库单号，1、库存销售出库单取消签字,2、库存销售出库单删除,3、销售订单取消审批,4、销售订单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object salesOrderDelete(JSONObject jsonObject);
SysExtensionApiEntity addSalesOrderDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 调拨订单删除接口
* 0、根据调拨订单号查询调拨入库，调拨出库单据，1、库存调拨出库取消签字 2、库存调拨出库删除 3、调拨入库取消签字 4、调拨入库删除 5、调拨订单弃审 6、调拨订单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object transferOrderDelete(JSONObject jsonObject);
SysExtensionApiEntity addTransferOrderDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 产成品入库删除接口
* 1、库存产成品入库单取消签字 2、库存产成品入库单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object finishedProductsAreStoredDelete(JSONObject jsonObject);
SysExtensionApiEntity addFinishedProductsAreStoredDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 材料出库删除接口
* 1、库存材料出库取消签字 2、库存材料出库单删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object materialDeliveryDelete(JSONObject jsonObject);
SysExtensionApiEntity addMaterialDeliveryDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 其他出库单删除接口
* 1、库存其他出库取消签字 2、库存其他出库删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object otherWarehouseOrdersDelete(JSONObject jsonObject);
SysExtensionApiEntity addOtherWarehouseOrdersDelete(SysExtensionApiEntity jsonObject);
/**
* @Author lvleigang
* @Description 其他入库单删除接口
* 1、库存其他入库单取消签字. 2、库存其他入库删除
* @Date 9:44 上午 2024/9/4
* @param jsonObject
* @return java.lang.Object
**/
Object otherWarehouseReceiptDelete(JSONObject jsonObject);
SysExtensionApiEntity addOtherWarehouseReceiptDelete(SysExtensionApiEntity jsonObject);
}

1320
fw-u8c/src/main/java/com/hzya/frame/u8c/Encapsulation/service/impl/EncapsulationImpl.java Normal file
View File

File diff suppressed because it is too large Load Diff

22
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/dao/IBdInvmandocDao.java Normal file
View File

@ -0,0 +1,22 @@
package com.hzya.frame.u8c.Invmandoc.dao;
import com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity;
import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List;
/**
* (bd_invmandoc: table)表数据库访问层
*
* @author makejava
* @since 2023-08-25 11:21:43
*/
public interface IBdInvmandocDao extends IBaseDao<BdInvmandocEntity, String> {
/**
* 根据存货编码查询存货管理档案
*
* @author liuyang
*/
List<BdInvmandocEntity> queryBdInvmandocByInvcode(BdInvmandocEntity bdInvmandocEntity) throws Exception;
}

25
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/dao/impl/BdInvmandocDaoImpl.java Normal file
View File

@ -0,0 +1,25 @@
package com.hzya.frame.u8c.Invmandoc.dao.impl;
import cn.hutool.core.lang.Assert;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity;
import com.hzya.frame.u8c.Invmandoc.dao.IBdInvmandocDao;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* (BdInvmandoc)表数据库访问层
*
* @author makejava
* @since 2023-08-25 11:21:44
*/
@Repository("serviceBdInvmandocDaoImpl")
public class BdInvmandocDaoImpl extends MybatisGenericDao<BdInvmandocEntity, String> implements IBdInvmandocDao {
@DS("sowow_sqlserver_pro")
@Override
public List<BdInvmandocEntity> queryBdInvmandocByInvcode(BdInvmandocEntity bdInvmandocEntity) throws Exception {
return (List<BdInvmandocEntity>) selectList("com.hzya.frame.u8c.Invmandoc.dao.impl.BdInvmandocDaoImpl.queryBdInvmandocByInvcode", bdInvmandocEntity);
}
}

69
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/entity/BdInvmandocEntity.java Normal file
View File

@ -0,0 +1,69 @@
package com.hzya.frame.u8c.Invmandoc.entity;
import com.hzya.frame.web.entity.BaseEntity;
/**
* (BdInvmandoc)实体类-存货管理档案
*
* @author makejava
* @since 2023-08-25 11:21:44
*/
public class BdInvmandocEntity extends BaseEntity {
private String pkInvbasdoc;
private String pkInvmandoc;
/**
* 存货编码
*/
private String invcode;
private String pkCorp;
/**
* 助记码=商家编码
*/
private String invmnecode;
public String getPkCorp() {
return pkCorp;
}
public void setPkCorp(String pkCorp) {
this.pkCorp = pkCorp;
}
public String getPkInvbasdoc() {
return pkInvbasdoc;
}
public void setPkInvbasdoc(String pkInvbasdoc) {
this.pkInvbasdoc = pkInvbasdoc;
}
public String getPkInvmandoc() {
return pkInvmandoc;
}
public void setPkInvmandoc(String pkInvmandoc) {
this.pkInvmandoc = pkInvmandoc;
}
public String getInvcode() {
return invcode;
}
public void setInvcode(String invcode) {
this.invcode = invcode;
}
public String getInvmnecode() {
return invmnecode;
}
public void setInvmnecode(String invmnecode) {
this.invmnecode = invmnecode;
}
}

37
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/entity/BdInvmandocEntity.xml Normal file
View File

@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.u8c.Invmandoc.dao.impl.BdInvmandocDaoImpl">
<resultMap id="get-BdInvmandocEntity-result" type="com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity" >
<result property="abctype" column="abctype" jdbcType="VARCHAR"/>
<result property="pkInvbasdoc" column="pk_invbasdoc" jdbcType="VARCHAR"/>
<result property="pkInvmandoc" column="pk_invmandoc" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询的字段-->
<sql id = "BdInvmandocEntity_Base_Column_List">
pk_invbasdoc
,pk_invmandoc
</sql>
<select id="queryBdInvmandocByInvcode" parameterType="com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity" resultMap="get-BdInvmandocEntity-result">
select pk_invbasdoc
,pk_invmandoc
from bd_invmandoc where pk_invbasdoc in (
select pk_invbasdoc from bd_invbasdoc bib
where bib.dr = 0
<if test="invcode!=null and invcode!=''">
and bib.invcode = #{invcode}
</if>
<if test="invmnecode!=null and invmnecode!=''">
and bib.invmnecode = #{invmnecode}
</if>
) and dr = 0 and pk_corp = #{pkCorp}
</select>
</mapper>

13
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/service/IBdInvmandocService.java Normal file
View File

@ -0,0 +1,13 @@
package com.hzya.frame.u8c.Invmandoc.service;
import com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity;
import com.hzya.frame.basedao.service.IBaseService;
/**
* (BdInvmandoc)表服务接口
*
* @author makejava
* @since 2023-08-25 11:21:44
*/
public interface IBdInvmandocService extends IBaseService<BdInvmandocEntity, String> {
}

29
fw-u8c/src/main/java/com/hzya/frame/u8c/Invmandoc/service/impl/BdInvmandocServiceImpl.java Normal file
View File

@ -0,0 +1,29 @@
package com.hzya.frame.u8c.Invmandoc.service.impl;
import com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity;
import com.hzya.frame.u8c.Invmandoc.dao.IBdInvmandocDao;
import com.hzya.frame.u8c.Invmandoc.service.IBdInvmandocService;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import javax.annotation.Resource;
import com.hzya.frame.basedao.service.impl.BaseService;
/**
* (BdInvmandoc)表服务实现类
*
* @author makejava
* @since 2023-08-25 11:21:44
*/
@Service("serviceBdInvmandocService")
public class BdInvmandocServiceImpl extends BaseService<BdInvmandocEntity, String> implements IBdInvmandocService {
private IBdInvmandocDao bdInvmandocDao;
@Autowired
public void setBdInvmandocDao(IBdInvmandocDao dao) {
this.bdInvmandocDao = dao;
this.dao = dao;
}
}

24
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/dao/IAxDao.java Normal file
View File

@ -0,0 +1,24 @@
package com.hzya.frame.u8c.ax.dao;
import com.hzya.frame.u8c.ax.entity.ArchivesEntity;
import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List;
/**
* (bd_corp: table)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
public interface IAxDao extends IBaseDao<ArchivesEntity, String> {
List<ArchivesEntity> queryArchivesData(ArchivesEntity archivesEntity);
ArchivesEntity saveArchivesByType(ArchivesEntity archivesEntity);
Integer updateArchivesByType(ArchivesEntity archivesEntity);
Integer deleteArchivesByType(ArchivesEntity archivesEntity);
}

42
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/dao/impl/AxDaoImpl.java Normal file
View File

@ -0,0 +1,42 @@
package com.hzya.frame.u8c.ax.dao.impl;
import com.hzya.frame.sysnew.user.entity.SysUserEntity;
import com.hzya.frame.u8c.ax.dao.IAxDao;
import com.hzya.frame.u8c.ax.entity.ArchivesEntity;
import org.springframework.stereotype.Repository;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List;
/**
* (BdCorp)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
@Repository("axDaoImpl")
public class AxDaoImpl extends MybatisGenericDao<ArchivesEntity, String> implements IAxDao {
@Override
public List<ArchivesEntity> queryArchivesData(ArchivesEntity entity) {
List<ArchivesEntity> o = super.query(getSqlIdPrifx() + "queryArchivesData", entity);
return o;
}
@Override
public ArchivesEntity saveArchivesByType(ArchivesEntity entity) {
entity = super.save(getSqlIdPrifx() + "saveArchivesByType", entity);
return entity;
}
@Override
public Integer updateArchivesByType(ArchivesEntity entity) {
Integer o = super.update(getSqlIdPrifx() + "updateArchivesByType", entity);
return o;
}
@Override
public Integer deleteArchivesByType(ArchivesEntity entity) {
Integer o = super.update(getSqlIdPrifx() + "deleteArchivesByType", entity);
return o;
}
}

188
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/ArchivesEntity.java Normal file
View File

@ -0,0 +1,188 @@
package com.hzya.frame.u8c.ax.entity;
import cn.dev33.satoken.stp.StpUtil;
import com.hzya.frame.uuid.UUIDUtils;
import com.hzya.frame.web.entity.BaseEntity;
import java.util.Date;
/**
* (BdCorp)实体类
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
public class ArchivesEntity extends BaseEntity {
private String archivesType;//类型
private String leftCode;//左编码
private String rightCode;//右编码
private String leftAppId;//左应用id
private String leftAppCode;//左应用编码
private String leftAppName;//左应用名称
private String leftApiId;//左接口ID
private String leftId;//左id
private String leftName;//左名称
private String rightAppId;//右应用id
private String rightAppCode;//右应用编码
private String rightAppName;//右应用名称
private String rightApiId;//右接口ID
private String rightId;//右id
private String rightName;//右名称
private String leftOrg;//左公司
private String rightOrg;//右公司
public String getArchivesType() {
return archivesType;
}
public void setArchivesType(String archivesType) {
this.archivesType = archivesType;
}
public String getLeftCode() {
return leftCode;
}
public void setLeftCode(String leftCode) {
this.leftCode = leftCode;
}
public String getRightCode() {
return rightCode;
}
public void setRightCode(String rightCode) {
this.rightCode = rightCode;
}
public String getLeftAppId() {
return leftAppId;
}
public void setLeftAppId(String leftAppId) {
this.leftAppId = leftAppId;
}
public String getLeftAppCode() {
return leftAppCode;
}
public void setLeftAppCode(String leftAppCode) {
this.leftAppCode = leftAppCode;
}
public String getLeftAppName() {
return leftAppName;
}
public void setLeftAppName(String leftAppName) {
this.leftAppName = leftAppName;
}
public String getLeftApiId() {
return leftApiId;
}
public void setLeftApiId(String leftApiId) {
this.leftApiId = leftApiId;
}
public String getLeftId() {
return leftId;
}
public void setLeftId(String leftId) {
this.leftId = leftId;
}
public String getLeftName() {
return leftName;
}
public void setLeftName(String leftName) {
this.leftName = leftName;
}
public String getRightAppId() {
return rightAppId;
}
public void setRightAppId(String rightAppId) {
this.rightAppId = rightAppId;
}
public String getRightAppCode() {
return rightAppCode;
}
public void setRightAppCode(String rightAppCode) {
this.rightAppCode = rightAppCode;
}
public String getRightAppName() {
return rightAppName;
}
public void setRightAppName(String rightAppName) {
this.rightAppName = rightAppName;
}
public String getRightApiId() {
return rightApiId;
}
public void setRightApiId(String rightApiId) {
this.rightApiId = rightApiId;
}
public String getRightId() {
return rightId;
}
public void setRightId(String rightId) {
this.rightId = rightId;
}
public String getRightName() {
return rightName;
}
public void setRightName(String rightName) {
this.rightName = rightName;
}
public String getLeftOrg() {
return leftOrg;
}
public void setLeftOrg(String leftOrg) {
this.leftOrg = leftOrg;
}
public String getRightOrg() {
return rightOrg;
}
public void setRightOrg(String rightOrg) {
this.rightOrg = rightOrg;
}
public void setCreate() {
this.setId(UUIDUtils.getUUID());
this.setSts("Y");
this.setCreate_user_id("1");
this.setModify_user_id("1");
this.setCreate_time(new Date());
this.setModify_time(new Date());
this.setOrg_id("0");
this.setCompanyId("0");
}
//修改信息
public void setUpdate() {
this.setModify_user_id("1");
this.setModify_time(new Date());
}
}

207
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/ArchivesEntity.xml Normal file
View File

@ -0,0 +1,207 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.u8c.ax.dao.impl.AxDaoImpl">
<resultMap id="get-ArchivesEntity-result" type="com.hzya.frame.u8c.ax.entity.ArchivesEntity" >
<result property="id" column="id" jdbcType="VARCHAR"/>
<result property="leftAppId" column="left_app_id" jdbcType="VARCHAR"/>
<result property="leftAppCode" column="left_app_code" jdbcType="VARCHAR"/>
<result property="leftAppName" column="left_app_name" jdbcType="VARCHAR"/>
<result property="leftApiId" column="left_api_id" jdbcType="VARCHAR"/>
<result property="leftId" column="left_id" jdbcType="VARCHAR"/>
<result property="leftCode" column="left_code" jdbcType="VARCHAR"/>
<result property="leftName" column="left_name" jdbcType="VARCHAR"/>
<result property="rightAppId" column="right_app_id" jdbcType="VARCHAR"/>
<result property="rightAppCode" column="right_app_code" jdbcType="VARCHAR"/>
<result property="rightAppName" column="right_app_name" jdbcType="VARCHAR"/>
<result property="rightApiId" column="right_api_id" jdbcType="VARCHAR"/>
<result property="rightId" column="right_id" jdbcType="VARCHAR"/>
<result property="rightCode" column="right_code" jdbcType="VARCHAR"/>
<result property="rightName" column="right_name" jdbcType="VARCHAR"/>
<result property="sorts" column="sorts" jdbcType="INTEGER"/>
<result property="create_user_id" column="create_user_id" jdbcType="VARCHAR"/>
<result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
<result property="modify_user_id" column="modify_user_id" jdbcType="VARCHAR"/>
<result property="modify_time" column="modify_time" jdbcType="TIMESTAMP"/>
<result property="sts" column="sts" jdbcType="VARCHAR"/>
<result property="org_id" column="org_id" jdbcType="VARCHAR"/>
<result property="companyId" column="company_id" jdbcType="VARCHAR"/>
</resultMap>
<select id="queryArchivesData" resultMap="get-ArchivesEntity-result"
parameterType="com.hzya.frame.u8c.ax.entity.ArchivesEntity">
select
right_code
from
<choose>
<when test="archivesType == '1'.toString()"> sys_personnel_control </when>
<when test="archivesType == '2'.toString()"> sys_org_control </when>
<when test="archivesType == '6'.toString()"> sys_stock_control </when>
<when test="archivesType == '73'.toString()"> sys_merchant_control </when>
<when test="archivesType == 'D01'.toString()"> sys_taxrate_control </when>
<when test="archivesType == 'jobass'.toString()"> sys_project_control </when>
<when test="archivesType == '93'.toString()"> sys_bank_control </when>
<when test="archivesType == '96'.toString()"> sys_bankaccount_control </when>
<when test="archivesType == '22'.toString()"> sys_assets_control </when>
</choose>
<trim prefix="where" prefixOverrides="and">
<if test="leftCode != null and leftCode != ''">and left_code = #{leftCode}</if>
<if test="leftOrg != null and leftOrg != ''">and left_org = #{leftOrg}</if>
and sts='Y'
</trim>
</select>
<!--新增所有列-->
<insert id="saveArchivesByType" parameterType = "com.hzya.frame.u8c.ax.entity.ArchivesEntity">
insert into
<choose>
<when test="archivesType == '1'.toString()"> sys_personnel_control </when>
<when test="archivesType == '2'.toString()"> sys_org_control </when>
<when test="archivesType == '6'.toString()"> sys_stock_control </when>
<when test="archivesType == '73'.toString()"> sys_merchant_control </when>
<when test="archivesType == 'D01'.toString()"> sys_taxrate_control </when>
<when test="archivesType == 'jobass'.toString()"> sys_project_control </when>
<when test="archivesType == '93'.toString()"> sys_bank_control </when>
<when test="archivesType == '96'.toString()"> sys_bankaccount_control </when>
<when test="archivesType == '22'.toString()"> sys_assets_control </when>
</choose>
(
<trim suffix="" suffixOverrides=",">
<if test="id != null and id != ''"> id , </if>
<if test="leftAppId != null and leftAppId != ''"> left_app_id , </if>
<if test="leftAppCode != null and leftAppCode != ''"> left_app_code , </if>
<if test="leftAppName != null and leftAppName != ''"> left_app_name , </if>
<if test="leftApiId != null and leftApiId != ''"> left_api_id , </if>
<if test="leftId != null and leftId != ''"> left_id , </if>
<if test="leftCode != null and leftCode != ''"> left_code , </if>
<if test="leftName != null and leftName != ''"> left_name , </if>
<if test="rightAppId != null and rightAppId != ''"> right_app_id , </if>
<if test="rightAppCode != null and rightAppCode != ''"> right_app_code , </if>
<if test="rightAppName != null and rightAppName != ''"> right_app_name , </if>
<if test="rightApiId != null and rightApiId != ''"> right_api_id , </if>
<if test="rightId != null and rightId != ''"> right_id , </if>
<if test="rightCode != null and rightCode != ''"> right_code , </if>
<if test="rightName != null and rightName != ''"> right_name , </if>
<if test="sorts != null"> sorts , </if>
<if test="create_user_id != null and create_user_id != ''"> create_user_id , </if>
<if test="create_time != null"> create_time , </if>
<if test="modify_user_id != null and modify_user_id != ''"> modify_user_id , </if>
<if test="modify_time != null"> modify_time , </if>
<if test="sts != null and sts != ''"> sts , </if>
<if test="org_id != null and org_id != ''"> org_id , </if>
<if test="companyId != null and companyId != ''"> company_id , </if>
<if test="sts == null ">sts,</if>
</trim>
)values(
<trim suffix="" suffixOverrides=",">
<if test="id != null and id != ''"> #{id} ,</if>
<if test="leftAppId != null and leftAppId != ''"> #{leftAppId} ,</if>
<if test="leftAppCode != null and leftAppCode != ''"> #{leftAppCode} ,</if>
<if test="leftAppName != null and leftAppName != ''"> #{leftAppName} ,</if>
<if test="leftApiId != null and leftApiId != ''"> #{leftApiId} ,</if>
<if test="leftId != null and leftId != ''"> #{leftId} ,</if>
<if test="leftCode != null and leftCode != ''"> #{leftCode} ,</if>
<if test="leftName != null and leftName != ''"> #{leftName} ,</if>
<if test="rightAppId != null and rightAppId != ''"> #{rightAppId} ,</if>
<if test="rightAppCode != null and rightAppCode != ''"> #{rightAppCode} ,</if>
<if test="rightAppName != null and rightAppName != ''"> #{rightAppName} ,</if>
<if test="rightApiId != null and rightApiId != ''"> #{rightApiId} ,</if>
<if test="rightId != null and rightId != ''"> #{rightId} ,</if>
<if test="rightCode != null and rightCode != ''"> #{rightCode} ,</if>
<if test="rightName != null and rightName != ''"> #{rightName} ,</if>
<if test="sorts != null"> #{sorts} ,</if>
<if test="create_user_id != null and create_user_id != ''"> #{create_user_id} ,</if>
<if test="create_time != null"> #{create_time} ,</if>
<if test="modify_user_id != null and modify_user_id != ''"> #{modify_user_id} ,</if>
<if test="modify_time != null"> #{modify_time} ,</if>
<if test="sts != null and sts != ''"> #{sts} ,</if>
<if test="org_id != null and org_id != ''"> #{org_id} ,</if>
<if test="companyId != null and companyId != ''"> #{companyId} ,</if>
<if test="sts == null ">'Y',</if>
</trim>
)
</insert>
<!--通过主键修改方法-->
<update id="updateArchivesByType" parameterType = "com.hzya.frame.u8c.ax.entity.ArchivesEntity" >
update
<choose>
<when test="archivesType == '1'.toString()"> sys_personnel_control </when>
<when test="archivesType == '2'.toString()"> sys_org_control </when>
<when test="archivesType == '6'.toString()"> sys_stock_control </when>
<when test="archivesType == '73'.toString()"> sys_merchant_control </when>
<when test="archivesType == 'D01'.toString()"> sys_taxrate_control </when>
<when test="archivesType == 'jobass'.toString()"> sys_project_control </when>
<when test="archivesType == '93'.toString()"> sys_bank_control </when>
<when test="archivesType == '96'.toString()"> sys_bankaccount_control </when>
<when test="archivesType == '22'.toString()"> sys_assets_control </when>
</choose>
set
<trim suffix="" suffixOverrides=",">
<if test="id != null and id != ''"> id = #{id},</if>
<if test="leftAppId != null and leftAppId != ''"> left_app_id = #{leftAppId},</if>
<if test="leftAppCode != null and leftAppCode != ''"> left_app_code = #{leftAppCode},</if>
<if test="leftAppName != null and leftAppName != ''"> left_app_name = #{leftAppName},</if>
<if test="leftApiId != null and leftApiId != ''"> left_api_id = #{leftApiId},</if>
<if test="leftId != null and leftId != ''"> left_id = #{leftId},</if>
<if test="leftCode != null and leftCode != ''"> left_code = #{leftCode},</if>
<if test="leftName != null and leftName != ''"> left_name = #{leftName},</if>
<if test="rightAppId != null and rightAppId != ''"> right_app_id = #{rightAppId},</if>
<if test="rightAppCode != null and rightAppCode != ''"> right_app_code = #{rightAppCode},</if>
<if test="rightAppName != null and rightAppName != ''"> right_app_name = #{rightAppName},</if>
<if test="rightApiId != null and rightApiId != ''"> right_api_id = #{rightApiId},</if>
<if test="rightId != null and rightId != ''"> right_id = #{rightId},</if>
<if test="rightCode != null and rightCode != ''"> right_code = #{rightCode},</if>
<if test="rightName != null and rightName != ''"> right_name = #{rightName},</if>
<if test="sorts != null"> sorts = #{sorts},</if>
<if test="create_user_id != null and create_user_id != ''"> create_user_id = #{create_user_id},</if>
<if test="create_time != null"> create_time = #{create_time},</if>
<if test="modify_user_id != null and modify_user_id != ''"> modify_user_id = #{modify_user_id},</if>
<if test="modify_time != null"> modify_time = #{modify_time},</if>
<if test="sts != null and sts != ''"> sts = #{sts},</if>
<if test="org_id != null and org_id != ''"> org_id = #{org_id},</if>
<if test="companyId != null and companyId != ''"> company_id = #{companyId},</if>
</trim>
where right_id = #{rightId}
</update>
<!-- 多条件逻辑删除 -->
<update id="deleteArchivesByType" parameterType = "com.hzya.frame.u8c.ax.entity.ArchivesEntity" >
update
<choose>
<when test="archivesType == '1'.toString()"> sys_personnel_control </when>
<when test="archivesType == '2'.toString()"> sys_org_control </when>
<when test="archivesType == '6'.toString()"> sys_stock_control </when>
<when test="archivesType == '73'.toString()"> sys_merchant_control </when>
<when test="archivesType == 'D01'.toString()"> sys_taxrate_control </when>
<when test="archivesType == 'jobass'.toString()"> sys_project_control </when>
<when test="archivesType == '93'.toString()"> sys_bank_control </when>
<when test="archivesType == '96'.toString()"> sys_bankaccount_control </when>
<when test="archivesType == '22'.toString()"> sys_assets_control </when>
</choose>
set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id}
<trim prefix="where" prefixOverrides="and">
<if test="id != null and id != ''"> and id = #{id} </if>
<if test="leftAppId != null and leftAppId != ''"> and left_app_id = #{leftAppId} </if>
<if test="leftAppCode != null and leftAppCode != ''"> and left_app_code = #{leftAppCode} </if>
<if test="leftAppName != null and leftAppName != ''"> and left_app_name = #{leftAppName} </if>
<if test="leftApiId != null and leftApiId != ''"> and left_api_id = #{leftApiId} </if>
<if test="leftId != null and leftId != ''"> and left_id = #{leftId} </if>
<if test="leftCode != null and leftCode != ''"> and left_code = #{leftCode} </if>
<if test="leftName != null and leftName != ''"> and left_name = #{leftName} </if>
<if test="rightAppId != null and rightAppId != ''"> and right_app_id = #{rightAppId} </if>
<if test="rightAppCode != null and rightAppCode != ''"> and right_app_code = #{rightAppCode} </if>
<if test="rightAppName != null and rightAppName != ''"> and right_app_name = #{rightAppName} </if>
<if test="rightApiId != null and rightApiId != ''"> and right_api_id = #{rightApiId} </if>
<if test="rightId != null and rightId != ''"> and right_id = #{rightId} </if>
<if test="rightCode != null and rightCode != ''"> and right_code = #{rightCode} </if>
<if test="rightName != null and rightName != ''"> and right_name = #{rightName} </if>
<if test="sorts != null"> and sorts = #{sorts} </if>
<if test="sts != null and sts != ''"> and sts = #{sts} </if>
<if test="companyId != null and companyId != ''"> and company_id = #{companyId} </if>
and sts='Y'
</trim>
</update>
</mapper>

24
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/Ass.java Normal file
View File

@ -0,0 +1,24 @@
package com.hzya.frame.u8c.ax.entity;
public class Ass {
private String checktypecode;
private String checkvaluecode;
public String getChecktypecode() {
return checktypecode;
}
public void setChecktypecode(String checktypecode) {
this.checktypecode = checktypecode;
}
public String getCheckvaluecode() {
return checkvaluecode;
}
public void setCheckvaluecode(String checkvaluecode) {
this.checkvaluecode = checkvaluecode;
}
}

23
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/Cashflow.java Normal file
View File

@ -0,0 +1,23 @@
package com.hzya.frame.u8c.ax.entity;
public class Cashflow {
private String money;
private String pk_cashflow;
public String getMoney() {
return money;
}
public void setMoney(String money) {
this.money = money;
}
public String getPk_cashflow() {
return pk_cashflow;
}
public void setPk_cashflow(String pk_cashflow) {
this.pk_cashflow = pk_cashflow;
}
}

69
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/Voucher.java Normal file
View File

@ -0,0 +1,69 @@
package com.hzya.frame.u8c.ax.entity;
import java.util.List;
public class Voucher {
private List<VoucherDetails> details;
private String no;
private String pk_corp;
private String pk_glorgbook;
private String pk_prepared;
private String pk_vouchertype;
private String pk_voucher;
public List<VoucherDetails> getDetails() {
return details;
}
public void setDetails(List<VoucherDetails> details) {
this.details = details;
}
public String getNo() {
return no;
}
public void setNo(String no) {
this.no = no;
}
public String getPk_corp() {
return pk_corp;
}
public void setPk_corp(String pk_corp) {
this.pk_corp = pk_corp;
}
public String getPk_glorgbook() {
return pk_glorgbook;
}
public void setPk_glorgbook(String pk_glorgbook) {
this.pk_glorgbook = pk_glorgbook;
}
public String getPk_prepared() {
return pk_prepared;
}
public void setPk_prepared(String pk_prepared) {
this.pk_prepared = pk_prepared;
}
public String getPk_vouchertype() {
return pk_vouchertype;
}
public void setPk_vouchertype(String pk_vouchertype) {
this.pk_vouchertype = pk_vouchertype;
}
public String getPk_voucher() {
return pk_voucher;
}
public void setPk_voucher(String pk_voucher) {
this.pk_voucher = pk_voucher;
}
}

105
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/VoucherDetails.java Normal file
View File

@ -0,0 +1,105 @@
package com.hzya.frame.u8c.ax.entity;
import java.util.List;
public class VoucherDetails {
private List<Ass> ass;
private List<Cashflow> cashflow;
private String creditamount;
private String debitamount;
private String explanation;
private String localcreditamount;
private String localdebitamount;
private String pk_accsubj;
private String pk_currtype;
private String debitquantity;
private String price;
public String getDebitquantity() {
return debitquantity;
}
public void setDebitquantity(String debitquantity) {
this.debitquantity = debitquantity;
}
public String getPrice() {
return price;
}
public void setPrice(String price) {
this.price = price;
}
public List<Ass> getAss() {
return ass;
}
public void setAss(List<Ass> ass) {
this.ass = ass;
}
public List<Cashflow> getCashflow() {
return cashflow;
}
public void setCashflow(List<Cashflow> cashflow) {
this.cashflow = cashflow;
}
public String getCreditamount() {
return creditamount;
}
public void setCreditamount(String creditamount) {
this.creditamount = creditamount;
}
public String getDebitamount() {
return debitamount;
}
public void setDebitamount(String debitamount) {
this.debitamount = debitamount;
}
public String getExplanation() {
return explanation;
}
public void setExplanation(String explanation) {
this.explanation = explanation;
}
public String getLocalcreditamount() {
return localcreditamount;
}
public void setLocalcreditamount(String localcreditamount) {
this.localcreditamount = localcreditamount;
}
public String getLocaldebitamount() {
return localdebitamount;
}
public void setLocaldebitamount(String localdebitamount) {
this.localdebitamount = localdebitamount;
}
public String getPk_accsubj() {
return pk_accsubj;
}
public void setPk_accsubj(String pk_accsubj) {
this.pk_accsubj = pk_accsubj;
}
public String getPk_currtype() {
return pk_currtype;
}
public void setPk_currtype(String pk_currtype) {
this.pk_currtype = pk_currtype;
}
}

14
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/entity/VoucherRoot.java Normal file
View File

@ -0,0 +1,14 @@
package com.hzya.frame.u8c.ax.entity;
import java.util.List;
public class VoucherRoot {
private List<Voucher> voucher;
public List<Voucher> getVoucher() {
return voucher;
}
public void setVoucher(List<Voucher> voucher) {
this.voucher = voucher;
}
}

41
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/service/IAxService.java Normal file
View File

@ -0,0 +1,41 @@
package com.hzya.frame.u8c.ax.service;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.u8c.ax.entity.ArchivesEntity;
import com.hzya.frame.basedao.service.IBaseService;
import com.hzya.frame.web.entity.JsonResultEntity;
public interface IAxService extends IBaseService<ArchivesEntity, String>{
/**
* @Author lvleigang
* @Description 凭证新增
* @Date 3:42 下午 2024/4/24
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
Object thirdInterfaceVoucherInsert(JSONObject object);
/**
* @Author lvleigang
* @Description 档案新增
* @Date 3:42 下午 2024/4/24
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
Object thirdInterfaceArchivesInsert(JSONObject object);
/**
* @Author lvleigang
* @Description 档案修改
* @Date 3:42 下午 2024/4/24
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
Object thirdInterfaceArchivesUpdate(JSONObject object);
/**
* @Author lvleigang
* @Description 档案删除
* @Date 3:42 下午 2024/4/24
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
Object thirdInterfaceArchivesDelete(JSONObject object);
}

836
fw-u8c/src/main/java/com/hzya/frame/u8c/ax/service/impl/AxServiceImpl.java Normal file
View File

@ -0,0 +1,836 @@
package com.hzya.frame.u8c.ax.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.basedao.service.impl.BaseService;
import com.hzya.frame.u8c.ax.dao.IAxDao;
import com.hzya.frame.u8c.ax.entity.*;
import com.hzya.frame.u8c.ax.service.IAxService;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
/**
* (BdCorp)表服务实现类
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
@Service("axServiceImpl")
public class AxServiceImpl extends BaseService<ArchivesEntity, String> implements IAxService {
private IAxDao axDao;
@Autowired
public void setAxDao(IAxDao dao) {
this.axDao = dao;
this.dao = dao;
}
@Value("${zt.url}")
private String voucherUrl;
private final String publicKey = "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj";
private final String secretKey = "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=";
private final String appId = "800016";
private final String pzApiCodexz = "8000160014";//凭证新增
private final String pzApiCodexg = "8000160031";//凭证修改
private final String pzApiCodesc = "8000160033";//凭证删除
private final String pzApiCodezf = "8000160032";//凭证作废
private final String ryApiCodexz = "8000160029";//人员对照新增
private final String ryApiCodexg = "8000160029";//人员对照修改
private final String ryApiCodesc = "8000160030";//人员对照删除
private final String bmApiCodexz = "8000160015";//部门档案新增
private final String bmApiCodexg = "8000160016";//部门档案修改
private final String bmApiCodesc = "8000160017";//部门档案删除
private final String chApiCodexz = "8000160025";//存货对照新增
private final String chApiCodexg = "8000160026";//存货对照修改
private final String chApiCodesc = "8000160027";//存货对照删除
private final String ksApiCodexz = "8000160018";//客商辅助核算新增
private final String ksApiCodexg = "8000160019";//客商辅助核算修改
private final String ksApiCodesc = "8000160020";//客商辅助核算删除
private final String slApiCodexz = "8000160014";//税率新增
private final String slApiCodexg = "8000160014";//税率修改
private final String slApiCodesc = "8000160014";//税率删除
private final String xmApiCodexz = "8000160021";//项目辅助核算新增
private final String xmApiCodexg = "8000160022";//项目辅助核算修改
private final String xmApiCodesc = "8000160023";//项目辅助核算删除
private final String yhlbApiCodexz = "8000160014";//银行类别新增
private final String yhlbApiCodexg = "8000160014";//银行类别修改
private final String yhlbApiCodesc = "8000160014";//银行类别删除
private final String yhzhApiCodexz = "8000160014";//银行账户新增
private final String yhzhApiCodexg = "8000160014";//银行账户修改
private final String yhzhApiCodesc = "8000160014";//银行账户删除
private final String zcApiCodexz = "8000160014";//资产类别新增
private final String zcApiCodexg = "8000160014";//资产类别修改
private final String zcApiCodesc = "8000160014";//资产类别删除
private final Object lock = new Object();
/**
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
* @Author lvleigang
* @Description 凭证新增
* @Date 3:42 下午 2024/4/24
**/
@Override
public Object thirdInterfaceVoucherInsert(JSONObject object) {
JSONObject jsonObject = object.getJSONObject("jsonStr");
if (jsonObject == null) {
return BaseResult.getFailureMessageEntity("数据为空，请先传递数据");
}
if (!checkStr(jsonObject.getString("voucherType"))) {
return BaseResult.getFailureMessageEntity("voucherType为空");
}
if (!checkStr(jsonObject.getString("usercode"))) {
return BaseResult.getFailureMessageEntity("usercode为空");
}
if (!checkStr(jsonObject.getString("password"))) {
return BaseResult.getFailureMessageEntity("password为空");
}
if (!checkStr(jsonObject.getString("trantype"))) {
return BaseResult.getFailureMessageEntity("trantype为空");
}
if (!checkStr(jsonObject.getString("system"))) {
return BaseResult.getFailureMessageEntity("system为空");
}
if (!checkStr(jsonObject.getString("data"))) {
return BaseResult.getFailureMessageEntity("data为空");
}
String bodys = jsonObject.getString("data");
List<String> fzhs = Arrays.asList(new String[]{"1", "2", "6", "73", "D01", "jobass", "93", "96", "22"});
switch (jsonObject.getString("voucherType")) {
case "add"://新增
VoucherRoot entity1 = getData("data", jsonObject, VoucherRoot.class);
if (entity1 == null || entity1.getVoucher() == null || entity1.getVoucher().size() == 0) {
return BaseResult.getFailureMessageEntity("data为空");
}
for (int i = 0; i < entity1.getVoucher().size(); i++) {
Voucher voucher = entity1.getVoucher().get(i);
if (voucher.getDetails() != null && voucher.getDetails().size() > 0) {
for (int a = 0; a < voucher.getDetails().size(); a++) {
VoucherDetails voucherDetails = voucher.getDetails().get(a);
if (voucherDetails.getAss() != null && voucherDetails.getAss().size() > 0) {
for (int b = 0; b < voucherDetails.getAss().size(); b++) {
Ass ass = voucherDetails.getAss().get(b);
if (ass.getChecktypecode() != null && !"".equals(ass.getChecktypecode())) {
//存在需要转换的
if (fzhs.contains(ass.getChecktypecode())) {
ArchivesEntity archivesEntity = new ArchivesEntity();
archivesEntity.setArchivesType(ass.getChecktypecode());
archivesEntity.setLeftCode(ass.getCheckvaluecode());
archivesEntity.setLeftOrg(voucher.getPk_corp());
List<ArchivesEntity> archivesEntities = axDao.queryArchivesData(archivesEntity);
if (archivesEntities != null && archivesEntities.size() > 0) {
ass.setCheckvaluecode(archivesEntities.get(0).getRightCode());
}
}
}
}
}
}
}
}
bodys = JSON.toJSONString(entity1);
break;
case "update"://修改
VoucherRoot entity = getData("data", jsonObject, VoucherRoot.class);
if (entity == null || entity.getVoucher() == null || entity.getVoucher().size() == 0) {
return BaseResult.getFailureMessageEntity("data为空");
}
for (int i = 0; i < entity.getVoucher().size(); i++) {
Voucher voucher = entity.getVoucher().get(i);
if (voucher.getDetails() != null && voucher.getDetails().size() > 0) {
for (int a = 0; a < voucher.getDetails().size(); a++) {
VoucherDetails voucherDetails = voucher.getDetails().get(a);
if (voucherDetails.getAss() != null && voucherDetails.getAss().size() > 0) {
for (int b = 0; b < voucherDetails.getAss().size(); b++) {
Ass ass = voucherDetails.getAss().get(b);
if (ass.getChecktypecode() != null && !"".equals(ass.getChecktypecode())) {
//存在需要转换的
if (fzhs.contains(ass.getChecktypecode())) {
ArchivesEntity archivesEntity = new ArchivesEntity();
archivesEntity.setArchivesType(ass.getChecktypecode());
archivesEntity.setLeftCode(ass.getCheckvaluecode());
archivesEntity.setLeftOrg(voucher.getPk_corp());
List<ArchivesEntity> archivesEntities = axDao.queryArchivesData(archivesEntity);
if (archivesEntities != null && archivesEntities.size() > 0) {
ass.setCheckvaluecode(archivesEntities.get(0).getRightCode());
}
}
}
}
}
}
}
}
bodys = JSON.toJSONString(entity);
break;
case "delete"://删除
break;
case "cancellation"://作废
break;
default:
break;
}
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.disableCookieManagement().build();
HttpPost post = new HttpPost(voucherUrl);
CloseableHttpResponse response = null;
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000).build();
post.setConfig(requestConfig);//设置请求参数【超时时间】
post.setHeader("usercode", jsonObject.getString("usercode"));
post.setHeader("password", jsonObject.getString("password"));
post.setHeader("trantype", jsonObject.getString("trantype"));
post.setHeader("system", jsonObject.getString("system"));
post.setHeader("publicKey", publicKey);
post.setHeader("secretKey", secretKey);
post.setHeader("appId", appId);
post.setHeader("needStackTrace", jsonObject.getString("needStackTrace"));
switch (jsonObject.getString("voucherType")) {
case "add"://新增
post.setHeader("apiCode", pzApiCodexz);
break;
case "update"://修改
post.setHeader("apiCode", pzApiCodexg);
break;
case "delete"://删除
post.setHeader("apiCode", pzApiCodesc);
break;
case "cancellation"://作废
post.setHeader("apiCode", pzApiCodezf);
break;
default:
break;
}
StringBuilder body = new StringBuilder();
try {
if (bodys != null && !"".equals(bodys)) {
ByteArrayEntity byteArrayEntity = new ByteArrayEntity(bodys.getBytes("UTF-8"));
byteArrayEntity.setContentType("application/json");
post.setEntity(byteArrayEntity);
}
response = closeableHttpClient.execute(post);
HttpEntity httpEntity = response.getEntity();
synchronized (lock) {
body.append(EntityUtils.toString(httpEntity));
}
logger.info("返回结果：" + body);
JsonResultEntity resultEntity = JSON.parseObject(body.toString(), JsonResultEntity.class);
return resultEntity;
} catch (Exception e) {
logger.error("请求错误：" + e.getMessage());
body.append(e.getMessage());
return BaseResult.getFailureMessageEntity("转发失败", body);
} finally {
try {
// 关闭响应对象
if (response != null) {
response.close();
}
// 关闭响应对象
if (closeableHttpClient != null) {
closeableHttpClient.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
* @Author lvleigang
* @Description 档案新增
* @Date 3:42 下午 2024/4/24
**/
@Override
public Object thirdInterfaceArchivesInsert(JSONObject object) {
JSONObject jsonObject = object.getJSONObject("jsonStr");
if (jsonObject == null) {
return BaseResult.getFailureMessageEntity("数据为空，请先传递数据");
}
if (!checkStr(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型为空");
}
if (!checkStr(jsonObject.getString("usercode"))) {
return BaseResult.getFailureMessageEntity("usercode为空");
}
if (!checkStr(jsonObject.getString("password"))) {
return BaseResult.getFailureMessageEntity("password为空");
}
if (!checkStr(jsonObject.getString("trantype"))) {
return BaseResult.getFailureMessageEntity("trantype为空");
}
if (!checkStr(jsonObject.getString("system"))) {
return BaseResult.getFailureMessageEntity("system为空");
}
if (!checkStr(jsonObject.getString("data"))) {
return BaseResult.getFailureMessageEntity("data为空");
}
List<String> fzhs = Arrays.asList(new String[]{"1", "2", "6", "73", "D01", "jobass", "93", "96", "22"});
if (!fzhs.contains(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型错误，请联系管理员");
}
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.disableCookieManagement().build();
HttpPost post = new HttpPost(voucherUrl);
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000).build();
post.setConfig(requestConfig);//设置请求参数【超时时间】
post.setHeader("usercode", jsonObject.getString("usercode"));
post.setHeader("password", jsonObject.getString("password"));
post.setHeader("trantype", jsonObject.getString("trantype"));
post.setHeader("system", jsonObject.getString("system"));
post.setHeader("publicKey", publicKey);
post.setHeader("secretKey", secretKey);
post.setHeader("appId", appId);
CloseableHttpResponse response = null;
switch (jsonObject.getString("archivesType")) {
case "1"://人员对照
post.setHeader("apiCode", ryApiCodexz);
break;
case "2"://部门档案
post.setHeader("apiCode", bmApiCodexz);
break;
case "6"://存货对照
post.setHeader("apiCode", chApiCodexz);
break;
case "73"://客商辅助核算
post.setHeader("apiCode", ksApiCodexz);
break;
case "D01"://税率
post.setHeader("apiCode", slApiCodexz);
break;
case "jobass"://项目辅助核算
post.setHeader("apiCode", xmApiCodexz);
break;
case "93"://银行类别
post.setHeader("apiCode", yhlbApiCodexz);
break;
case "96"://银行账户
post.setHeader("apiCode", yhzhApiCodexz);
break;
case "22"://资产类别
post.setHeader("apiCode", zcApiCodexz);
break;
default:
break;
}
StringBuilder body = new StringBuilder();
try {
String senddata = jsonObject.getString("data");
if ("1".equals(jsonObject.getString("archivesType"))) {
JSONObject sendJson = JSONObject.parseObject(senddata);
JSONObject sendObject = new JSONObject();
if (sendJson != null) {
JSONArray psn = sendJson.getJSONArray("psn");
JSONArray sendpsn = new JSONArray();
if (psn != null && psn.size() > 0) {
for (int i = 0; i < psn.size(); i++) {
JSONObject person = psn.getJSONObject(i);
JSONObject parentvo = person.getJSONObject("parentvo");
JSONObject psnmanvo = parentvo.getJSONObject("psnmanvo");
ArchivesEntity archivesEntity = new ArchivesEntity();
archivesEntity.setArchivesType("2");
archivesEntity.setLeftCode(psnmanvo.getString("pk_deptdoc"));
archivesEntity.setLeftOrg(parentvo.getString("currentcorp"));
List<ArchivesEntity> archivesEntities = axDao.queryArchivesData(archivesEntity);
if (archivesEntities != null && archivesEntities.size() > 0) {
psnmanvo.put("pk_deptdoc",archivesEntities.get(0).getRightCode());
}
parentvo.put("psnmanvo",psnmanvo);
person.put("parentvo",parentvo);
sendpsn.add(person);
}
}
sendObject.put("psn",sendpsn);
}
senddata = sendObject.toJSONString();
}
ByteArrayEntity byteArrayEntity = new ByteArrayEntity(senddata.getBytes("UTF-8"));
byteArrayEntity.setContentType("application/json");
post.setEntity(byteArrayEntity);
response = closeableHttpClient.execute(post);
HttpEntity httpEntity = response.getEntity();
synchronized (lock) {
body.append(EntityUtils.toString(httpEntity));
}
logger.info("返回结果：" + body);
JsonResultEntity resultEntity = JSON.parseObject(body.toString(), JsonResultEntity.class);
return resultEntity;
//todo 暂时不保存
//JsonResultEntity resultEntity = JSON.parseObject(body.toString(),JsonResultEntity.class);
//if(resultEntity.isFlag() && "200".equals(resultEntity.getStatus())){
// if(JSONUtil.isTypeJSON(resultEntity.getAttribute().toString())){
// JSONObject attribute = JSONObject.parseObject(resultEntity.getAttribute().toString());
// if("success".equals(attribute.getString("status"))){
// if(attribute.getString("data") == null || "".equals(attribute.getString("data")) ){
// return resultEntity;
// }
// JSONArray jsonArray = JSONArray.parseArray(attribute.getString("data"));
// if(jsonArray == null || jsonArray.size() == 0 ){
// return resultEntity;
// }
// //解析具体数据
// switch (jsonObject.getString("archivesType")){
// case "1"://人员对照
//
//
// break;
// case "2"://部门档案
// //[{"pk_corp":"1001","unitcode":"01","unitname":"临安奥星电子股份有限公司","createdate":"2024-04-24","deptattr":"1","deptname":"DEV测试一级部门","deptcode":"99","pk_deptdoc":"1001F1100000000067BR"}]
// for (int i = 0; i < jsonArray.size(); i++) {
// JSONObject object1 = jsonArray.getJSONObject(i);
// ArchivesEntity archivesEntity = new ArchivesEntity();
// archivesEntity.setArchivesType(jsonObject.getString("archivesType"));
// archivesEntity.setCreate();
// archivesEntity.setLeftCode(object1.getString("unitcode"));//左
// archivesEntity.setLeftName(object1.getString("unitname"));//左
// archivesEntity.setRightId(object1.getString("pk_deptdoc"));//右
// archivesEntity.setRightCode(object1.getString("unitcode"));//右
// archivesEntity.setRightName(object1.getString("unitname"));//右
// axDao.saveArchivesByType(archivesEntity);
// }
// break;
// case "6"://存货对照
// for (int i = 0; i < jsonArray.size(); i++) {
// JSONObject object1 = jsonArray.getJSONObject(i);
// ArchivesEntity archivesEntity = new ArchivesEntity();
// archivesEntity.setArchivesType(jsonObject.getString("archivesType"));
// archivesEntity.setCreate();
// archivesEntity.setLeftCode(object1.getString("invclasscode"));//左
// archivesEntity.setLeftName(object1.getString("invclassname"));//左
// archivesEntity.setRightId(object1.getString("pk_invcl"));//右
// archivesEntity.setRightCode(object1.getString("invclasscode"));//右
// archivesEntity.setRightName(object1.getString("invclassname"));//右
// axDao.saveArchivesByType(archivesEntity);
// }
// break;
// case "73"://客商辅助核算
// break;
// case "D01"://税率
// break;
// case "jobass"://项目辅助核算
// break;
// case "93"://银行类别
// break;
// case "96"://银行账户
// break;
// case "22"://资产类别
// break;
// default:
// break;
// }
// return resultEntity;
// }else {
// return resultEntity;
// }
// }else {
// return resultEntity;
// }
//}else {
// //解析返回
// return resultEntity;
//}
} catch (Exception e) {
logger.error("请求错误：" + e.getMessage());
body.append(e.getMessage());
return BaseResult.getFailureMessageEntity("转发失败", body);
} finally {
try {
// 关闭响应对象
if (response != null) {
response.close();
}
// 关闭响应对象
if (closeableHttpClient != null) {
closeableHttpClient.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
* @Author lvleigang
* @Description 档案修改
* @Date 3:42 下午 2024/4/24
**/
@Override
public Object thirdInterfaceArchivesUpdate(JSONObject object) {
JSONObject jsonObject = object.getJSONObject("jsonStr");
if (jsonObject == null) {
return BaseResult.getFailureMessageEntity("数据为空，请先传递数据");
}
if (!checkStr(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型为空");
}
if (!checkStr(jsonObject.getString("usercode"))) {
return BaseResult.getFailureMessageEntity("usercode为空");
}
if (!checkStr(jsonObject.getString("password"))) {
return BaseResult.getFailureMessageEntity("password为空");
}
if (!checkStr(jsonObject.getString("trantype"))) {
return BaseResult.getFailureMessageEntity("trantype为空");
}
if (!checkStr(jsonObject.getString("system"))) {
return BaseResult.getFailureMessageEntity("system为空");
}
if (!checkStr(jsonObject.getString("data"))) {
return BaseResult.getFailureMessageEntity("data为空");
}
List<String> fzhs = Arrays.asList(new String[]{"1", "2", "6", "73", "D01", "jobass", "93", "96", "22"});
if (!fzhs.contains(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型错误，请联系管理员");
}
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.disableCookieManagement().build();
HttpPost post = new HttpPost(voucherUrl);
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000).build();
post.setConfig(requestConfig);//设置请求参数【超时时间】
post.setHeader("usercode", jsonObject.getString("usercode"));
post.setHeader("password", jsonObject.getString("password"));
post.setHeader("trantype", jsonObject.getString("trantype"));
post.setHeader("system", jsonObject.getString("system"));
post.setHeader("publicKey", publicKey);
post.setHeader("secretKey", secretKey);
post.setHeader("appId", appId);
CloseableHttpResponse response = null;
switch (jsonObject.getString("archivesType")) {
case "1"://人员对照
post.setHeader("apiCode", ryApiCodexg);
break;
case "2"://部门档案
post.setHeader("apiCode", bmApiCodexg);
break;
case "6"://存货对照
post.setHeader("apiCode", chApiCodexg);
break;
case "73"://客商辅助核算
post.setHeader("apiCode", ksApiCodexg);
break;
case "D01"://税率
post.setHeader("apiCode", slApiCodexg);
break;
case "jobass"://项目辅助核算
post.setHeader("apiCode", xmApiCodexg);
break;
case "93"://银行类别
post.setHeader("apiCode", yhlbApiCodexg);
break;
case "96"://银行账户
post.setHeader("apiCode", yhzhApiCodexg);
break;
case "22"://资产类别
post.setHeader("apiCode", zcApiCodexg);
break;
default:
break;
}
StringBuilder body = new StringBuilder();
try {
ByteArrayEntity byteArrayEntity = new ByteArrayEntity(jsonObject.getString("data").getBytes("UTF-8"));
byteArrayEntity.setContentType("application/json");
post.setEntity(byteArrayEntity);
response = closeableHttpClient.execute(post);
HttpEntity httpEntity = response.getEntity();
synchronized (lock) {
body.append(EntityUtils.toString(httpEntity));
}
logger.info("返回结果：" + body);
JsonResultEntity resultEntity = JSON.parseObject(body.toString(), JsonResultEntity.class);
return resultEntity;
//JsonResultEntity resultEntity = JSON.parseObject(body.toString(),JsonResultEntity.class);
//if(resultEntity.isFlag() && "200".equals(resultEntity.getStatus())){
// if(JSONUtil.isTypeJSON(resultEntity.getAttribute().toString())){
// //JSONObject attribute = JSONObject.parseObject(resultEntity.getAttribute().toString());
// JSONObject attribute = JSONObject.parseObject("{\n" +
// " \"status\": \"success\",\n" +
// " \"data\": \"[{\\\"pk_invcl\\\":\\\"0001F11000000000I6NN\\\",\\\"invclasscode\\\":\\\"04\\\",\\\"invclassname\\\":\\\"成品测试\\\",\\\"invclasslev\\\":\\\"1\\\",\\\"pk_corp\\\":\\\"0001\\\",\\\"unitcode\\\":\\\"0001\\\",\\\"unitname\\\":\\\"集团\\\"}]\",\n" +
// " \"taskNumber\": \"202404250048\"\n" +
// "}");
// if("success".equals(attribute.getString("status"))){
// if(attribute.getString("data") == null || "".equals(attribute.getString("data")) ){
// return resultEntity;
// }
// JSONArray jsonArray = JSONArray.parseArray(attribute.getString("data"));
// if(jsonArray == null || jsonArray.size() == 0 ){
// return resultEntity;
// }
// //解析具体数据
// switch (jsonObject.getString("archivesType")){
// case "1"://人员对照
// break;
// case "2"://部门档案
// break;
// case "6"://存货对照
// for (int i = 0; i < jsonArray.size(); i++) {
// JSONObject object1 = jsonArray.getJSONObject(i);
// ArchivesEntity archivesEntity = new ArchivesEntity();
// archivesEntity.setArchivesType(jsonObject.getString("archivesType"));
// archivesEntity.setUpdate();
// archivesEntity.setLeftCode(object1.getString("invclasscode"));//左
// archivesEntity.setLeftName(object1.getString("invclassname"));//左
// archivesEntity.setRightId(object1.getString("pk_invcl"));//右
// archivesEntity.setRightCode(object1.getString("invclasscode"));//右
// archivesEntity.setRightName(object1.getString("invclassname"));//右
// axDao.updateArchivesByType(archivesEntity);
// }
// break;
// case "73"://客商辅助核算
// break;
// case "D01"://税率
// break;
// case "jobass"://项目辅助核算
// break;
// case "93"://银行类别
// break;
// case "96"://银行账户
// break;
// case "22"://资产类别
// break;
// default:
// break;
// }
// return resultEntity;
// }else {
// return resultEntity;
// }
// }else {
// return resultEntity;
// }
//}else {
// //解析返回
// return resultEntity;
//}
} catch (Exception e) {
logger.error("请求错误：" + e.getMessage());
body.append(e.getMessage());
return BaseResult.getFailureMessageEntity("转发失败", body);
} finally {
try {
// 关闭响应对象
if (response != null) {
response.close();
}
// 关闭响应对象
if (closeableHttpClient != null) {
closeableHttpClient.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
* @Author lvleigang
* @Description 档案删除
* @Date 3:42 下午 2024/4/24
**/
@Override
public Object thirdInterfaceArchivesDelete(JSONObject object) {
JSONObject jsonObject = object.getJSONObject("jsonStr");
if (jsonObject == null) {
return BaseResult.getFailureMessageEntity("数据为空，请先传递数据");
}
if (!checkStr(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型为空");
}
if (!checkStr(jsonObject.getString("usercode"))) {
return BaseResult.getFailureMessageEntity("usercode为空");
}
if (!checkStr(jsonObject.getString("password"))) {
return BaseResult.getFailureMessageEntity("password为空");
}
if (!checkStr(jsonObject.getString("trantype"))) {
return BaseResult.getFailureMessageEntity("trantype为空");
}
if (!checkStr(jsonObject.getString("system"))) {
return BaseResult.getFailureMessageEntity("system为空");
}
if (!checkStr(jsonObject.getString("data"))) {
return BaseResult.getFailureMessageEntity("data为空");
}
List<String> fzhs = Arrays.asList(new String[]{"1", "2", "6", "73", "D01", "jobass", "93", "96", "22"});
if (!fzhs.contains(jsonObject.getString("archivesType"))) {
return BaseResult.getFailureMessageEntity("档案类型错误，请联系管理员");
}
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.disableCookieManagement().build();
HttpPost post = new HttpPost(voucherUrl);
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(60000).build();
post.setConfig(requestConfig);//设置请求参数【超时时间】
post.setHeader("usercode", jsonObject.getString("usercode"));
post.setHeader("password", jsonObject.getString("password"));
post.setHeader("trantype", jsonObject.getString("trantype"));
post.setHeader("system", jsonObject.getString("system"));
post.setHeader("publicKey", publicKey);
post.setHeader("secretKey", secretKey);
post.setHeader("appId", appId);
CloseableHttpResponse response = null;
switch (jsonObject.getString("archivesType")) {
case "1"://人员对照
post.setHeader("apiCode", ryApiCodesc);
break;
case "2"://部门档案
post.setHeader("apiCode", bmApiCodesc);
break;
case "6"://存货对照
post.setHeader("apiCode", chApiCodesc);
break;
case "73"://客商辅助核算
post.setHeader("apiCode", ksApiCodesc);
break;
case "D01"://税率
post.setHeader("apiCode", slApiCodesc);
break;
case "jobass"://项目辅助核算
post.setHeader("apiCode", xmApiCodesc);
break;
case "93"://银行类别
post.setHeader("apiCode", yhlbApiCodesc);
break;
case "96"://银行账户
post.setHeader("apiCode", yhzhApiCodesc);
break;
case "22"://资产类别
post.setHeader("apiCode", zcApiCodesc);
break;
default:
break;
}
StringBuilder body = new StringBuilder();
try {
ByteArrayEntity byteArrayEntity = new ByteArrayEntity(jsonObject.getString("data").getBytes("UTF-8"));
byteArrayEntity.setContentType("application/json");
post.setEntity(byteArrayEntity);
response = closeableHttpClient.execute(post);
HttpEntity httpEntity = response.getEntity();
synchronized (lock) {
body.append(EntityUtils.toString(httpEntity));
}
logger.info("返回结果：" + body);
JsonResultEntity resultEntity = JSON.parseObject(body.toString(), JsonResultEntity.class);
return resultEntity;
//JsonResultEntity resultEntity = JSON.parseObject(body.toString(),JsonResultEntity.class);
//if(resultEntity.isFlag() && "200".equals(resultEntity.getStatus())){
// if(JSONUtil.isTypeJSON(resultEntity.getAttribute().toString())){
// //JSONObject attribute = JSONObject.parseObject(resultEntity.getAttribute().toString());
// JSONObject attribute = JSONObject.parseObject("{\n" +
// " \"status\": \"success\",\n" +
// " \"data\": \"[{\\\"pk_invcl\\\":\\\"0001F11000000000I6NN\\\",\\\"invclasscode\\\":\\\"04\\\",\\\"invclassname\\\":\\\"成品测试\\\",\\\"invclasslev\\\":\\\"1\\\",\\\"pk_corp\\\":\\\"0001\\\",\\\"unitcode\\\":\\\"0001\\\",\\\"unitname\\\":\\\"集团\\\"}]\",\n" +
// " \"taskNumber\": \"202404250048\"\n" +
// "}");
// if("success".equals(attribute.getString("status"))){
// if(attribute.getString("data") == null || "".equals(attribute.getString("data")) ){
// return resultEntity;
// }
// JSONArray jsonArray = JSONArray.parseArray(attribute.getString("data"));
// if(jsonArray == null || jsonArray.size() == 0 ){
// return resultEntity;
// }
// //解析具体数据
// switch (jsonObject.getString("archivesType")){
// case "1"://人员对照
// break;
// case "2"://部门档案
// break;
// case "6"://存货对照
// for (int i = 0; i < jsonArray.size(); i++) {
// JSONObject object1 = jsonArray.getJSONObject(i);
// ArchivesEntity archivesEntity = new ArchivesEntity();
// archivesEntity.setArchivesType(jsonObject.getString("archivesType"));
// archivesEntity.setUpdate();
// archivesEntity.setLeftCode(object1.getString("invclasscode"));//左
// archivesEntity.setLeftName(object1.getString("invclassname"));//左
// archivesEntity.setRightId(object1.getString("pk_invcl"));//右
// archivesEntity.setRightCode(object1.getString("invclasscode"));//右
// archivesEntity.setRightName(object1.getString("invclassname"));//右
// axDao.deleteArchivesByType(archivesEntity);
// }
// break;
// case "73"://客商辅助核算
// break;
// case "D01"://税率
// break;
// case "jobass"://项目辅助核算
// break;
// case "93"://银行类别
// break;
// case "96"://银行账户
// break;
// case "22"://资产类别
// break;
// default:
// break;
// }
// return resultEntity;
// }else {
// return resultEntity;
// }
// }else {
// return resultEntity;
// }
//}else {
// //解析返回
// return resultEntity;
//}
} catch (Exception e) {
logger.error("请求错误：" + e.getMessage());
body.append(e.getMessage());
return BaseResult.getFailureMessageEntity("转发失败", body);
} finally {
try {
// 关闭响应对象
if (response != null) {
response.close();
}
// 关闭响应对象
if (closeableHttpClient != null) {
closeableHttpClient.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

26
fw-u8c/src/main/java/com/hzya/frame/u8c/bdCumandoc/dao/IBdCumandocDao.java Normal file
View File

@ -0,0 +1,26 @@
package com.hzya.frame.u8c.bdCumandoc.dao;
import com.hzya.frame.basedao.dao.IBaseDao;
import com.hzya.frame.u8c.bdCumandoc.entity.BdCumandocEntity;
import java.util.List;
/**
* (bd_cumandoc: table)表数据库访问层
*
* @author makejava
* @since 2023-08-25 09:42:24
*/
public interface IBdCumandocDao extends IBaseDao<BdCumandocEntity, String> {
/**
*
* @content 通过组织以及客户编码查询客户管理档案主键
* @author javaboy
* @date 2024/1/24 0024 13:58
*
*/
List<BdCumandocEntity> selectIdByCodeAndCorp(BdCumandocEntity cumandoc);
}

26
fw-u8c/src/main/java/com/hzya/frame/u8c/bdCumandoc/dao/impl/BdCumandocDaoImpl.java Normal file
View File

@ -0,0 +1,26 @@
package com.hzya.frame.u8c.bdCumandoc.dao.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import com.hzya.frame.u8c.bdCumandoc.dao.IBdCumandocDao;
import com.hzya.frame.u8c.bdCumandoc.entity.BdCumandocEntity;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* (BdCumandoc)表数据库访问层
*
* @author makejava
* @since 2023-08-25 09:42:24
*/
@Repository("U8cBdCumandocDaoImpl")
public class BdCumandocDaoImpl extends MybatisGenericDao<BdCumandocEntity, String> implements IBdCumandocDao {
@DS("sowow_sqlserver_pro")
@Override
public List<BdCumandocEntity> selectIdByCodeAndCorp(BdCumandocEntity cumandoc) {
return (List<BdCumandocEntity>) super.selectList("com.hzya.frame.u8c.bdCumandoc.dao.impl.BdCumandocDaoImpl.entity_list_base",cumandoc);
}
}

874
fw-u8c/src/main/java/com/hzya/frame/u8c/bdCumandoc/entity/BdCumandocEntity.java Normal file
View File

@ -0,0 +1,874 @@
package com.hzya.frame.u8c.bdCumandoc.entity;
import com.hzya.frame.web.entity.BaseEntity;
/**
* (BdCumandoc)实体类-客商管理档案
*
* @author makejava
* @since 2023-08-25 09:42:24
*/
public class BdCumandocEntity extends BaseEntity {
private String accawmny;
private String acclimit;
private String acclimitcontrol;
private String acclmtbegindate;
private String balancemny;
private String bp;
private String busawmny;
private String cmnecode;
private String cooperateflag;
private String cooperatingdayfrom;
private String cooperatingdayto;
private String correspsettleunit;
private String createtime;
private String creator;
private String creditcontrol;
private String creditlevel;
private String creditlimitnum;
private String creditmny;
private String creditmoney;
private Long credlimitflag;
private String custflag;
private Long custstate;
private String def1;
private String def10;
private String def11;
private String def12;
private String def13;
private String def14;
private String def15;
private String def16;
private String def17;
private String def18;
private String def19;
private String def2;
private String def20;
private String def21;
private String def22;
private String def23;
private String def24;
private String def25;
private String def26;
private String def27;
private String def28;
private String def29;
private String def3;
private String def30;
private String def4;
private String def5;
private String def6;
private String def7;
private String def8;
private String def9;
private String developdate;
private String diffcurrflag;
private String discountrate;
private Long dr;
private String freeofacclmtcheck;
private String freeofcremnycheck;
private String frozendate;
private String frozenflag;
private Long grade;
private Long innerctldays;
private String iounit;
private String isagent;
private String ispromtesettlement;
private String linkman;
private String memo;
private String mobilephone;
private String modifier;
private String modifytime;
private String ordawmny;
private String pkCalbody;
private String pkCorp;
private String pkCubasdoc;
private String pkCumandoc;
private String pkCurrtype1;
private String pkCusmandoc2;
private String pkCusmandoc3;
private String pkDefbusitype;
private String pkPayterm;
private String pkPricegroupcorp;
private String pkRespdept1;
private String pkResppsn1;
private String pkSalestru;
private String pkSendtype;
private String pkSettleunit;
private String pkStordoc2;
private Long prepaidratio;
private String ratifydate;
private String sealflag;
private Long stockpriceratio;
private String testsalemoney;
private String ts;
private String custcode;
public String getCustcode() {
return custcode;
}
public void setCustcode(String custcode) {
this.custcode = custcode;
}
/**
* 多个custflag值查询
*/
private String custflags;
public String getCustflags() {
return custflags;
}
public void setCustflags(String custflags) {
this.custflags = custflags;
}
public String getAccawmny() {
return accawmny;
}
public void setAccawmny(String accawmny) {
this.accawmny = accawmny;
}
public String getAcclimit() {
return acclimit;
}
public void setAcclimit(String acclimit) {
this.acclimit = acclimit;
}
public String getAcclimitcontrol() {
return acclimitcontrol;
}
public void setAcclimitcontrol(String acclimitcontrol) {
this.acclimitcontrol = acclimitcontrol;
}
public String getAcclmtbegindate() {
return acclmtbegindate;
}
public void setAcclmtbegindate(String acclmtbegindate) {
this.acclmtbegindate = acclmtbegindate;
}
public String getBalancemny() {
return balancemny;
}
public void setBalancemny(String balancemny) {
this.balancemny = balancemny;
}
public String getBp() {
return bp;
}
public void setBp(String bp) {
this.bp = bp;
}
public String getBusawmny() {
return busawmny;
}
public void setBusawmny(String busawmny) {
this.busawmny = busawmny;
}
public String getCmnecode() {
return cmnecode;
}
public void setCmnecode(String cmnecode) {
this.cmnecode = cmnecode;
}
public String getCooperateflag() {
return cooperateflag;
}
public void setCooperateflag(String cooperateflag) {
this.cooperateflag = cooperateflag;
}
public String getCooperatingdayfrom() {
return cooperatingdayfrom;
}
public void setCooperatingdayfrom(String cooperatingdayfrom) {
this.cooperatingdayfrom = cooperatingdayfrom;
}
public String getCooperatingdayto() {
return cooperatingdayto;
}
public void setCooperatingdayto(String cooperatingdayto) {
this.cooperatingdayto = cooperatingdayto;
}
public String getCorrespsettleunit() {
return correspsettleunit;
}
public void setCorrespsettleunit(String correspsettleunit) {
this.correspsettleunit = correspsettleunit;
}
public String getCreatetime() {
return createtime;
}
public void setCreatetime(String createtime) {
this.createtime = createtime;
}
public String getCreator() {
return creator;
}
public void setCreator(String creator) {
this.creator = creator;
}
public String getCreditcontrol() {
return creditcontrol;
}
public void setCreditcontrol(String creditcontrol) {
this.creditcontrol = creditcontrol;
}
public String getCreditlevel() {
return creditlevel;
}
public void setCreditlevel(String creditlevel) {
this.creditlevel = creditlevel;
}
public String getCreditlimitnum() {
return creditlimitnum;
}
public void setCreditlimitnum(String creditlimitnum) {
this.creditlimitnum = creditlimitnum;
}
public String getCreditmny() {
return creditmny;
}
public void setCreditmny(String creditmny) {
this.creditmny = creditmny;
}
public String getCreditmoney() {
return creditmoney;
}
public void setCreditmoney(String creditmoney) {
this.creditmoney = creditmoney;
}
public Long getCredlimitflag() {
return credlimitflag;
}
public void setCredlimitflag(Long credlimitflag) {
this.credlimitflag = credlimitflag;
}
public String getCustflag() {
return custflag;
}
public void setCustflag(String custflag) {
this.custflag = custflag;
}
public Long getCuststate() {
return custstate;
}
public void setCuststate(Long custstate) {
this.custstate = custstate;
}
public String getDef1() {
return def1;
}
public void setDef1(String def1) {
this.def1 = def1;
}
public String getDef10() {
return def10;
}
public void setDef10(String def10) {
this.def10 = def10;
}
public String getDef11() {
return def11;
}
public void setDef11(String def11) {
this.def11 = def11;
}
public String getDef12() {
return def12;
}
public void setDef12(String def12) {
this.def12 = def12;
}
public String getDef13() {
return def13;
}
public void setDef13(String def13) {
this.def13 = def13;
}
public String getDef14() {
return def14;
}
public void setDef14(String def14) {
this.def14 = def14;
}
public String getDef15() {
return def15;
}
public void setDef15(String def15) {
this.def15 = def15;
}
public String getDef16() {
return def16;
}
public void setDef16(String def16) {
this.def16 = def16;
}
public String getDef17() {
return def17;
}
public void setDef17(String def17) {
this.def17 = def17;
}
public String getDef18() {
return def18;
}
public void setDef18(String def18) {
this.def18 = def18;
}
public String getDef19() {
return def19;
}
public void setDef19(String def19) {
this.def19 = def19;
}
public String getDef2() {
return def2;
}
public void setDef2(String def2) {
this.def2 = def2;
}
public String getDef20() {
return def20;
}
public void setDef20(String def20) {
this.def20 = def20;
}
public String getDef21() {
return def21;
}
public void setDef21(String def21) {
this.def21 = def21;
}
public String getDef22() {
return def22;
}
public void setDef22(String def22) {
this.def22 = def22;
}
public String getDef23() {
return def23;
}
public void setDef23(String def23) {
this.def23 = def23;
}
public String getDef24() {
return def24;
}
public void setDef24(String def24) {
this.def24 = def24;
}
public String getDef25() {
return def25;
}
public void setDef25(String def25) {
this.def25 = def25;
}
public String getDef26() {
return def26;
}
public void setDef26(String def26) {
this.def26 = def26;
}
public String getDef27() {
return def27;
}
public void setDef27(String def27) {
this.def27 = def27;
}
public String getDef28() {
return def28;
}
public void setDef28(String def28) {
this.def28 = def28;
}
public String getDef29() {
return def29;
}
public void setDef29(String def29) {
this.def29 = def29;
}
public String getDef3() {
return def3;
}
public void setDef3(String def3) {
this.def3 = def3;
}
public String getDef30() {
return def30;
}
public void setDef30(String def30) {
this.def30 = def30;
}
public String getDef4() {
return def4;
}
public void setDef4(String def4) {
this.def4 = def4;
}
public String getDef5() {
return def5;
}
public void setDef5(String def5) {
this.def5 = def5;
}
public String getDef6() {
return def6;
}
public void setDef6(String def6) {
this.def6 = def6;
}
public String getDef7() {
return def7;
}
public void setDef7(String def7) {
this.def7 = def7;
}
public String getDef8() {
return def8;
}
public void setDef8(String def8) {
this.def8 = def8;
}
public String getDef9() {
return def9;
}
public void setDef9(String def9) {
this.def9 = def9;
}
public String getDevelopdate() {
return developdate;
}
public void setDevelopdate(String developdate) {
this.developdate = developdate;
}
public String getDiffcurrflag() {
return diffcurrflag;
}
public void setDiffcurrflag(String diffcurrflag) {
this.diffcurrflag = diffcurrflag;
}
public String getDiscountrate() {
return discountrate;
}
public void setDiscountrate(String discountrate) {
this.discountrate = discountrate;
}
public Long getDr() {
return dr;
}
public void setDr(Long dr) {
this.dr = dr;
}
public String getFreeofacclmtcheck() {
return freeofacclmtcheck;
}
public void setFreeofacclmtcheck(String freeofacclmtcheck) {
this.freeofacclmtcheck = freeofacclmtcheck;
}
public String getFreeofcremnycheck() {
return freeofcremnycheck;
}
public void setFreeofcremnycheck(String freeofcremnycheck) {
this.freeofcremnycheck = freeofcremnycheck;
}
public String getFrozendate() {
return frozendate;
}
public void setFrozendate(String frozendate) {
this.frozendate = frozendate;
}
public String getFrozenflag() {
return frozenflag;
}
public void setFrozenflag(String frozenflag) {
this.frozenflag = frozenflag;
}
public Long getGrade() {
return grade;
}
public void setGrade(Long grade) {
this.grade = grade;
}
public Long getInnerctldays() {
return innerctldays;
}
public void setInnerctldays(Long innerctldays) {
this.innerctldays = innerctldays;
}
public String getIounit() {
return iounit;
}
public void setIounit(String iounit) {
this.iounit = iounit;
}
public String getIsagent() {
return isagent;
}
public void setIsagent(String isagent) {
this.isagent = isagent;
}
public String getIspromtesettlement() {
return ispromtesettlement;
}
public void setIspromtesettlement(String ispromtesettlement) {
this.ispromtesettlement = ispromtesettlement;
}
public String getLinkman() {
return linkman;
}
public void setLinkman(String linkman) {
this.linkman = linkman;
}
public String getMemo() {
return memo;
}
public void setMemo(String memo) {
this.memo = memo;
}
public String getMobilephone() {
return mobilephone;
}
public void setMobilephone(String mobilephone) {
this.mobilephone = mobilephone;
}
public String getModifier() {
return modifier;
}
public void setModifier(String modifier) {
this.modifier = modifier;
}
public String getModifytime() {
return modifytime;
}
public void setModifytime(String modifytime) {
this.modifytime = modifytime;
}
public String getOrdawmny() {
return ordawmny;
}
public void setOrdawmny(String ordawmny) {
this.ordawmny = ordawmny;
}
public String getPkCalbody() {
return pkCalbody;
}
public void setPkCalbody(String pkCalbody) {
this.pkCalbody = pkCalbody;
}
public String getPkCorp() {
return pkCorp;
}
public void setPkCorp(String pkCorp) {
this.pkCorp = pkCorp;
}
public String getPkCubasdoc() {
return pkCubasdoc;
}
public void setPkCubasdoc(String pkCubasdoc) {
this.pkCubasdoc = pkCubasdoc;
}
public String getPkCumandoc() {
return pkCumandoc;
}
public void setPkCumandoc(String pkCumandoc) {
this.pkCumandoc = pkCumandoc;
}
public String getPkCurrtype1() {
return pkCurrtype1;
}
public void setPkCurrtype1(String pkCurrtype1) {
this.pkCurrtype1 = pkCurrtype1;
}
public String getPkCusmandoc2() {
return pkCusmandoc2;
}
public void setPkCusmandoc2(String pkCusmandoc2) {
this.pkCusmandoc2 = pkCusmandoc2;
}
public String getPkCusmandoc3() {
return pkCusmandoc3;
}
public void setPkCusmandoc3(String pkCusmandoc3) {
this.pkCusmandoc3 = pkCusmandoc3;
}
public String getPkDefbusitype() {
return pkDefbusitype;
}
public void setPkDefbusitype(String pkDefbusitype) {
this.pkDefbusitype = pkDefbusitype;
}
public String getPkPayterm() {
return pkPayterm;
}
public void setPkPayterm(String pkPayterm) {
this.pkPayterm = pkPayterm;
}
public String getPkPricegroupcorp() {
return pkPricegroupcorp;
}
public void setPkPricegroupcorp(String pkPricegroupcorp) {
this.pkPricegroupcorp = pkPricegroupcorp;
}
public String getPkRespdept1() {
return pkRespdept1;
}
public void setPkRespdept1(String pkRespdept1) {
this.pkRespdept1 = pkRespdept1;
}
public String getPkResppsn1() {
return pkResppsn1;
}
public void setPkResppsn1(String pkResppsn1) {
this.pkResppsn1 = pkResppsn1;
}
public String getPkSalestru() {
return pkSalestru;
}
public void setPkSalestru(String pkSalestru) {
this.pkSalestru = pkSalestru;
}
public String getPkSendtype() {
return pkSendtype;
}
public void setPkSendtype(String pkSendtype) {
this.pkSendtype = pkSendtype;
}
public String getPkSettleunit() {
return pkSettleunit;
}
public void setPkSettleunit(String pkSettleunit) {
this.pkSettleunit = pkSettleunit;
}
public String getPkStordoc2() {
return pkStordoc2;
}
public void setPkStordoc2(String pkStordoc2) {
this.pkStordoc2 = pkStordoc2;
}
public Long getPrepaidratio() {
return prepaidratio;
}
public void setPrepaidratio(Long prepaidratio) {
this.prepaidratio = prepaidratio;
}
public String getRatifydate() {
return ratifydate;
}
public void setRatifydate(String ratifydate) {
this.ratifydate = ratifydate;
}
public String getSealflag() {
return sealflag;
}
public void setSealflag(String sealflag) {
this.sealflag = sealflag;
}
public Long getStockpriceratio() {
return stockpriceratio;
}
public void setStockpriceratio(Long stockpriceratio) {
this.stockpriceratio = stockpriceratio;
}
public String getTestsalemoney() {
return testsalemoney;
}
public void setTestsalemoney(String testsalemoney) {
this.testsalemoney = testsalemoney;
}
public String getTs() {
return ts;
}
public void setTs(String ts) {
this.ts = ts;
}
}

212
fw-u8c/src/main/java/com/hzya/frame/u8c/bdCumandoc/entity/BdCumandocEntity.xml Normal file
View File

@ -0,0 +1,212 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.u8c.bdCumandoc.dao.impl.BdCumandocDaoImpl">
<resultMap id="get-BdCumandocEntity-result" type="com.hzya.frame.u8c.bdCumandoc.entity.BdCumandocEntity" >
<result property="accawmny" column="accawmny" jdbcType="VARCHAR"/>
<result property="acclimit" column="acclimit" jdbcType="VARCHAR"/>
<result property="acclimitcontrol" column="acclimitcontrol" jdbcType="VARCHAR"/>
<result property="acclmtbegindate" column="acclmtbegindate" jdbcType="VARCHAR"/>
<result property="balancemny" column="balancemny" jdbcType="VARCHAR"/>
<result property="bp" column="bp" jdbcType="VARCHAR"/>
<result property="busawmny" column="busawmny" jdbcType="VARCHAR"/>
<result property="cmnecode" column="cmnecode" jdbcType="VARCHAR"/>
<result property="cooperateflag" column="cooperateflag" jdbcType="VARCHAR"/>
<result property="cooperatingdayfrom" column="cooperatingdayfrom" jdbcType="VARCHAR"/>
<result property="cooperatingdayto" column="cooperatingdayto" jdbcType="VARCHAR"/>
<result property="correspsettleunit" column="correspsettleunit" jdbcType="VARCHAR"/>
<result property="createtime" column="createtime" jdbcType="VARCHAR"/>
<result property="creator" column="creator" jdbcType="VARCHAR"/>
<result property="creditcontrol" column="creditcontrol" jdbcType="VARCHAR"/>
<result property="creditlevel" column="creditlevel" jdbcType="VARCHAR"/>
<result property="creditlimitnum" column="creditlimitnum" jdbcType="VARCHAR"/>
<result property="creditmny" column="creditmny" jdbcType="VARCHAR"/>
<result property="creditmoney" column="creditmoney" jdbcType="VARCHAR"/>
<result property="credlimitflag" column="credlimitflag" jdbcType="INTEGER"/>
<result property="custflag" column="custflag" jdbcType="VARCHAR"/>
<result property="custstate" column="custstate" jdbcType="INTEGER"/>
<result property="def1" column="def1" jdbcType="VARCHAR"/>
<result property="def10" column="def10" jdbcType="VARCHAR"/>
<result property="def11" column="def11" jdbcType="VARCHAR"/>
<result property="def12" column="def12" jdbcType="VARCHAR"/>
<result property="def13" column="def13" jdbcType="VARCHAR"/>
<result property="def14" column="def14" jdbcType="VARCHAR"/>
<result property="def15" column="def15" jdbcType="VARCHAR"/>
<result property="def16" column="def16" jdbcType="VARCHAR"/>
<result property="def17" column="def17" jdbcType="VARCHAR"/>
<result property="def18" column="def18" jdbcType="VARCHAR"/>
<result property="def19" column="def19" jdbcType="VARCHAR"/>
<result property="def2" column="def2" jdbcType="VARCHAR"/>
<result property="def20" column="def20" jdbcType="VARCHAR"/>
<result property="def21" column="def21" jdbcType="VARCHAR"/>
<result property="def22" column="def22" jdbcType="VARCHAR"/>
<result property="def23" column="def23" jdbcType="VARCHAR"/>
<result property="def24" column="def24" jdbcType="VARCHAR"/>
<result property="def25" column="def25" jdbcType="VARCHAR"/>
<result property="def26" column="def26" jdbcType="VARCHAR"/>
<result property="def27" column="def27" jdbcType="VARCHAR"/>
<result property="def28" column="def28" jdbcType="VARCHAR"/>
<result property="def29" column="def29" jdbcType="VARCHAR"/>
<result property="def3" column="def3" jdbcType="VARCHAR"/>
<result property="def30" column="def30" jdbcType="VARCHAR"/>
<result property="def4" column="def4" jdbcType="VARCHAR"/>
<result property="def5" column="def5" jdbcType="VARCHAR"/>
<result property="def6" column="def6" jdbcType="VARCHAR"/>
<result property="def7" column="def7" jdbcType="VARCHAR"/>
<result property="def8" column="def8" jdbcType="VARCHAR"/>
<result property="def9" column="def9" jdbcType="VARCHAR"/>
<result property="developdate" column="developdate" jdbcType="VARCHAR"/>
<result property="diffcurrflag" column="diffcurrflag" jdbcType="VARCHAR"/>
<result property="discountrate" column="discountrate" jdbcType="VARCHAR"/>
<result property="dr" column="dr" jdbcType="INTEGER"/>
<result property="freeofacclmtcheck" column="freeofacclmtcheck" jdbcType="VARCHAR"/>
<result property="freeofcremnycheck" column="freeofcremnycheck" jdbcType="VARCHAR"/>
<result property="frozendate" column="frozendate" jdbcType="VARCHAR"/>
<result property="frozenflag" column="frozenflag" jdbcType="VARCHAR"/>
<result property="grade" column="grade" jdbcType="INTEGER"/>
<result property="innerctldays" column="innerctldays" jdbcType="INTEGER"/>
<result property="iounit" column="iounit" jdbcType="VARCHAR"/>
<result property="isagent" column="isagent" jdbcType="VARCHAR"/>
<result property="ispromtesettlement" column="ispromtesettlement" jdbcType="VARCHAR"/>
<result property="linkman" column="linkman" jdbcType="VARCHAR"/>
<result property="memo" column="memo" jdbcType="VARCHAR"/>
<result property="mobilephone" column="mobilephone" jdbcType="VARCHAR"/>
<result property="modifier" column="modifier" jdbcType="VARCHAR"/>
<result property="modifytime" column="modifytime" jdbcType="VARCHAR"/>
<result property="ordawmny" column="ordawmny" jdbcType="VARCHAR"/>
<result property="pkCalbody" column="pk_calbody" jdbcType="VARCHAR"/>
<result property="pkCorp" column="pk_corp" jdbcType="VARCHAR"/>
<result property="pkCubasdoc" column="pk_cubasdoc" jdbcType="VARCHAR"/>
<result property="pkCumandoc" column="pk_cumandoc" jdbcType="VARCHAR"/>
<result property="pkCurrtype1" column="pk_currtype1" jdbcType="VARCHAR"/>
<result property="pkCusmandoc2" column="pk_cusmandoc2" jdbcType="VARCHAR"/>
<result property="pkCusmandoc3" column="pk_cusmandoc3" jdbcType="VARCHAR"/>
<result property="pkDefbusitype" column="pk_defbusitype" jdbcType="VARCHAR"/>
<result property="pkPayterm" column="pk_payterm" jdbcType="VARCHAR"/>
<result property="pkPricegroupcorp" column="pk_pricegroupcorp" jdbcType="VARCHAR"/>
<result property="pkRespdept1" column="pk_respdept1" jdbcType="VARCHAR"/>
<result property="pkResppsn1" column="pk_resppsn1" jdbcType="VARCHAR"/>
<result property="pkSalestru" column="pk_salestru" jdbcType="VARCHAR"/>
<result property="pkSendtype" column="pk_sendtype" jdbcType="VARCHAR"/>
<result property="pkSettleunit" column="pk_settleunit" jdbcType="VARCHAR"/>
<result property="pkStordoc2" column="pk_stordoc2" jdbcType="VARCHAR"/>
<result property="prepaidratio" column="prepaidratio" jdbcType="INTEGER"/>
<result property="ratifydate" column="ratifydate" jdbcType="VARCHAR"/>
<result property="sealflag" column="sealflag" jdbcType="VARCHAR"/>
<result property="stockpriceratio" column="stockpriceratio" jdbcType="INTEGER"/>
<result property="testsalemoney" column="testsalemoney" jdbcType="VARCHAR"/>
<result property="ts" column="ts" jdbcType="VARCHAR"/>
<result property="custcode" column="custcode" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询的字段-->
<sql id = "BdCumandocEntity_Base_Column_List">
accawmny
,acclimit
,acclimitcontrol
,acclmtbegindate
,balancemny
,bp
,busawmny
,cmnecode
,cooperateflag
,cooperatingdayfrom
,cooperatingdayto
,correspsettleunit
,createtime
,creator
,creditcontrol
,creditlevel
,creditlimitnum
,creditmny
,creditmoney
,credlimitflag
,custflag
,custstate
,def1
,def10
,def11
,def12
,def13
,def14
,def15
,def16
,def17
,def18
,def19
,def2
,def20
,def21
,def22
,def23
,def24
,def25
,def26
,def27
,def28
,def29
,def3
,def30
,def4
,def5
,def6
,def7
,def8
,def9
,developdate
,diffcurrflag
,discountrate
,dr
,freeofacclmtcheck
,freeofcremnycheck
,frozendate
,frozenflag
,grade
,innerctldays
,iounit
,isagent
,ispromtesettlement
,linkman
,memo
,mobilephone
,modifier
,modifytime
,ordawmny
,pk_calbody
,pk_corp
,pk_cubasdoc
,pk_cumandoc
,pk_currtype1
,pk_cusmandoc2
,pk_cusmandoc3
,pk_defbusitype
,pk_payterm
,pk_pricegroupcorp
,pk_respdept1
,pk_resppsn1
,pk_salestru
,pk_sendtype
,pk_settleunit
,pk_stordoc2
,prepaidratio
,ratifydate
,sealflag
,stockpriceratio
,testsalemoney
,ts
</sql>
<!-- 查询 采用==查询 -->
<select id="entity_list_base" resultMap="get-BdCumandocEntity-result" parameterType = "com.hzya.frame.u8c.bdCumandoc.entity.BdCumandocEntity">
select
mand.pk_cumandoc ,
mand.pk_cubasdoc ,
basdoc.custcode,
mand.pk_corp
from bd_cumandoc mand
left join bd_cubasdoc basdoc on mand.pk_cubasdoc = basdoc.pk_cubasdoc and basdoc.dr = '0'
where mand.pk_corp = #{pkCorp} and basdoc.custcode = #{custcode}
and mand.dr='0'
and custflag in ('0','2')
</select>
</mapper>

40
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/dao/IBdCorpDao.java Normal file
View File

@ -0,0 +1,40 @@
package com.hzya.frame.u8c.bdcorp.dao;
import com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity;
import com.hzya.frame.basedao.dao.IBaseDao;
import java.util.List;
/**
* (bd_corp: table)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
public interface IBdCorpDao extends IBaseDao<BdCorpEntity, String> {
/**
*
* @content 通过组织主键，采购组织编码获取采购组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
List<BdCorpEntity> getPoPkByOrg(BdCorpEntity poCorp);
/**
*
* @content 通过组织主键，采购组织编码获取库存组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
List<BdCorpEntity> getStockPkByOrg(BdCorpEntity poCorp);
/**
*
* @content 通过组织主键，销售组织编码获取销售组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
List<BdCorpEntity> getSoPkByOrg(BdCorpEntity poCorp);
}

36
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/dao/impl/BdCorpDaoImpl.java Normal file
View File

@ -0,0 +1,36 @@
package com.hzya.frame.u8c.bdcorp.dao.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.hzya.frame.u8c.Invmandoc.entity.BdInvmandocEntity;
import com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity;
import com.hzya.frame.u8c.bdcorp.dao.IBdCorpDao;
import org.springframework.stereotype.Repository;
import com.hzya.frame.basedao.dao.MybatisGenericDao;
import java.util.List;
/**
* (BdCorp)表数据库访问层
*
* @author makejava
* @since 2023-09-06 14:47:17
*/
@Repository("serviceBdCorpDaoImpl")
public class BdCorpDaoImpl extends MybatisGenericDao<BdCorpEntity, String> implements IBdCorpDao{
@DS("sowow_sqlserver_pro")
@Override
public List<BdCorpEntity> getPoPkByOrg(BdCorpEntity poCorp) {
return (List<BdCorpEntity>) super.selectList("com.hzya.frame.u8c.bdcorp.dao.impl.BdCorpDaoImpl.entity_list_base_po", poCorp);
}
@DS("sowow_sqlserver_pro")
@Override
public List<BdCorpEntity> getStockPkByOrg(BdCorpEntity poCorp) {
return (List<BdCorpEntity>) super.selectList("com.hzya.frame.u8c.bdcorp.dao.impl.BdCorpDaoImpl.entity_list_base_stock", poCorp);
}
@DS("sowow_sqlserver_pro")
@Override
public List<BdCorpEntity> getSoPkByOrg(BdCorpEntity poCorp) {
return (List<BdCorpEntity>) super.selectList("com.hzya.frame.u8c.bdcorp.dao.impl.BdCorpDaoImpl.entity_list_base_so", poCorp);
}
}

51
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/entity/BdCorpEntity.java Normal file
View File

@ -0,0 +1,51 @@
package com.hzya.frame.u8c.bdcorp.entity;
import com.hzya.frame.web.entity.BaseEntity;
/**
* (BdCorp)实体类
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
public class BdCorpEntity extends BaseEntity {
private String pkPurorg;//采购组织主键
private String pkCorp;//所属公司
private String code;//编码
private String pkCalbody;//库存组织主键
public String getPkCalbody() {
return pkCalbody;
}
public void setPkCalbody(String pkCalbody) {
this.pkCalbody = pkCalbody;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getPkPurorg() {
return pkPurorg;
}
public void setPkPurorg(String pkPurorg) {
this.pkPurorg = pkPurorg;
}
public String getPkCorp() {
return pkCorp;
}
public void setPkCorp(String pkCorp) {
this.pkCorp = pkCorp;
}
}

35
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/entity/BdCorpEntity.xml Normal file
View File

@ -0,0 +1,35 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzya.frame.u8c.bdcorp.dao.impl.BdCorpDaoImpl">
<resultMap id="get-BdCorpEntity-result" type="com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity" >
<result property="begindate" column="begindate" jdbcType="VARCHAR"/>
<result property="pkPurorg" column="pk_purorg" jdbcType="VARCHAR"/>
<result property="pkCalbody" column="pk_calbody" jdbcType="VARCHAR"/>
<result property="pkCorp" column="pk_corp" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询的字段-->
<sql id = "BdCorpEntity_Base_Column_List">
id
</sql>
<!-- 查询 采用==查询 -->
<select id="entity_list_base_po" resultMap="get-BdCorpEntity-result" parameterType = "com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity">
select pk_purorg,code,name ,ownercorp from bd_purorg
where ownercorp = #{pkCorp} and code = #{code}
</select>
<!-- 查询 采用==查询 -->
<select id="entity_list_base_stock" resultMap="get-BdCorpEntity-result" parameterType = "com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity">
select pk_corp,bodycode,bodyname,pk_calbody from bd_calbody
where 1=1
<!-- and pk_corp = #{pkCorp}-->
and bodycode = #{code}
</select>
<!-- 查询 采用==查询 -->
<select id="entity_list_base_so" resultMap="get-BdCorpEntity-result" parameterType = "com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity">
select vsalestrucode,vsalestruname,csalestruid,belongcorp from bd_salestru
where belongcorp = #{pkCorp} and vsalestrucode = #{code}
</select>
</mapper>

36
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/service/IBdCorpService.java Normal file
View File

@ -0,0 +1,36 @@
package com.hzya.frame.u8c.bdcorp.service;
import com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity;
import com.hzya.frame.basedao.service.IBaseService;
/**
* (BdCorp)表服务接口
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
public interface IBdCorpService extends IBaseService<BdCorpEntity, String>{
/**
*
* @content 通过组织主键，采购组织编码获取采购组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
BdCorpEntity getPoPkByOrg(BdCorpEntity poCorp);
/**
*
* @content 通过组织主键，库存组织编码获取库存组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
BdCorpEntity getStockPkByOrg(BdCorpEntity poCorp);
/**
*
* @content 通过组织主键，销售组织编码获取销售组织主键
* @author makejava
* @date 2023/12/11 0011 16:32
*
*/
BdCorpEntity getSoPkByOrg(BdCorpEntity poCorp);
}

54
fw-u8c/src/main/java/com/hzya/frame/u8c/bdcorp/service/impl/BdCorpServiceImpl.java Normal file
View File

@ -0,0 +1,54 @@
package com.hzya.frame.u8c.bdcorp.service.impl;
import com.hzya.frame.u8c.bdcorp.entity.BdCorpEntity;
import com.hzya.frame.u8c.bdcorp.dao.IBdCorpDao;
import com.hzya.frame.u8c.bdcorp.service.IBdCorpService;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import javax.annotation.Resource;
import com.hzya.frame.basedao.service.impl.BaseService;
import java.util.List;
/**
* (BdCorp)表服务实现类
*
* @author makejava
* @since 2023-09-06 14:47:18
*/
@Service("serviceCorpServiceImpl")
public class BdCorpServiceImpl extends BaseService<BdCorpEntity, String> implements IBdCorpService {
private IBdCorpDao bdCorpDao;
@Autowired
public void setBdCorpDao(IBdCorpDao dao) {
this.bdCorpDao = dao;
this.dao = dao;
}
@Override
public BdCorpEntity getPoPkByOrg(BdCorpEntity poCorp) {
List<BdCorpEntity> bdCorpEntityList = bdCorpDao.getPoPkByOrg(poCorp);
if(bdCorpEntityList != null && bdCorpEntityList.size() > 0){
return bdCorpEntityList.get(0);
}
return null;
}
@Override
public BdCorpEntity getStockPkByOrg(BdCorpEntity poCorp) {
List<BdCorpEntity> bdCorpEntityList = bdCorpDao.getStockPkByOrg(poCorp);
if(bdCorpEntityList != null && bdCorpEntityList.size() > 0){
return bdCorpEntityList.get(0);
}
return null;
}
@Override
public BdCorpEntity getSoPkByOrg(BdCorpEntity poCorp) {
List<BdCorpEntity> bdCorpEntityList = bdCorpDao.getSoPkByOrg(poCorp);
if(bdCorpEntityList != null && bdCorpEntityList.size() > 0){
return bdCorpEntityList.get(0);
}
return null;
}
}

47
fw-u8c/src/main/java/com/hzya/frame/u8c/util/U8cHttpUtil.java Normal file
View File

@ -0,0 +1,47 @@
package com.hzya.frame.u8c.util;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
/**
* com.hzya.frame.u8c.util
*
* @author yqh
* @date 2023-11 -14 18:45
*/
public class U8cHttpUtil {
public static String baseUrl = "127.0.0.1:9999/kangarooDataCenterV3/entranceController/externalCallInterface";
public static JSONObject sendOATOU8CEsb(String parm, String apiCode){
String result = HttpRequest.post(baseUrl)
.header("usercode", "admin")//头信息，多个头信息多次调用此方法即可
// .header("needStackTrace", "Y")//头信息，多个头信息多次调用此方法即可
.header("password", "eddea5c9f7fab1a9d18410cda784c224")//头信息，多个头信息多次调用此方法即可
.header("trantype", "PK")//头信息，多个头信息多次调用此方法即可
.header("system", "sowow")//头信息，多个头信息多次调用此方法即可
.header("appId", "800005")//头信息，多个头信息多次调用此方法即可
.header("apiCode", apiCode)//头信息，多个头信息多次调用此方法即可
.header("publicKey", "ZJYAWb7lhAUTYqekPkU+uHJv1/ObJxb7dT7sD8HPRDGAgyhCe7eDIk+3zDUT+v578prj")//头信息，多个头信息多次调用此方法即可
.header("secretKey", "fviZnLBsQUAGF8w8FSOdJi7XlIm/XAZclMxRagDLfTyJFlvnIBF3w66Hrpfzs8cYj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=")//头信息，多个头信息多次调用此方法即可
.body(parm)//表单内容
.timeout(20000)//超时，毫秒
.execute().body();
if(StrUtil.isNotEmpty(result)){
return analytic(result);
}
return null;
}
public static JSONObject analytic(String parm){
JSONObject main = JSON.parseObject(parm);
String status = main.getString("status");
if("200".equals(status)){
String attribute = main.getString("attribute");
JSONObject attributeObj = JSON.parseObject(attribute);
return attributeObj;
}
return null;
}
}

6
fw-u8c/src/main/webapp/WEB-INF/web.xml Normal file
View File

@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
version="4.0">
</web-app>

2
pom.xml
View File

@ -16,7 +16,7 @@
<!-- <module>fw-ningbobank</module>--> <!-- <module>fw-ningbobank</module>-->
<!-- <module>fw-oa</module>--> <!-- <module>fw-oa</module>-->
<!-- <module>fw-u8</module>--> <!-- <module>fw-u8</module>-->
<!-- <module>fw-u8c</module>--> <module>fw-u8c</module>
<!-- <module>fw-u9c</module>--> <!-- <module>fw-u9c</module>-->
</modules> </modules>
<groupId>com.hzya.frame</groupId> <groupId>com.hzya.frame</groupId>