diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java
index 2a84c1a3..bdd82a6f 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/mdmDistribute/plugin/MdmModulePluginInitializer.java
@@ -743,7 +743,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
         map1.put("tableName",mainDb);
         //map1.put("dataStatus", "F");
         map1.put("updateStatus", "0");
-        map1.put("size", 50);
+        //map1.put("size", 50);
         objects = mdmModuleDao.queryMdmSTs(map1);
         objects = toLowerCaseKeys(objects);
 
@@ -937,7 +937,7 @@ public class MdmModulePluginInitializer extends PluginBaseEntity {
         map1.put("tableName",mainDb);
         //map1.put("dataStatus", "Y");
         map1.put("addStatus", "0");
-        map1.put("size", 50);
+        //map1.put("size", 50);
         objects = mdmModuleDao.queryMdmSTs(map1);
         objects = toLowerCaseKeys(objects);
 
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/entity/ProjectMainFlowEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/entity/ProjectMainFlowEntity.xml
index 29ffca4c..fef09f6e 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/entity/ProjectMainFlowEntity.xml
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/entity/ProjectMainFlowEntity.xml
@@ -64,6 +64,7 @@
         WHERE 1=1
         and CTP_AFFAIR.node_policy = '审计完成' AND CTP_AFFAIR.complete_time is not null
         and CTP_AFFAIR.state = '4' and  CTP_AFFAIR.sub_state = '0' and field0427 is null
+        and rownum < 100 and field0274 in ('浙S-QZWLJS2402YXZ001-05','浙S-QZWLJS2402YXZ001-04','浙D-NB2412TH15001')
         <trim prefix="where" prefixOverrides="and">
             <if test="id != null and id != ''"> and id = #{id} </if>
         </trim>
@@ -82,7 +83,8 @@
         LEFT JOIN org_member m4 ON m4.id=field0081
         WHERE 1=1
         and CTP_AFFAIR.node_policy = '归档' AND CTP_AFFAIR.complete_time is not null
-        and CTP_AFFAIR.state = '4' and  CTP_AFFAIR.sub_state = '0' and field0425 is null and formmain_0219.id='4000079310249084585'
+        and CTP_AFFAIR.state = '4' and  CTP_AFFAIR.sub_state = '0' and field0425 is null
+        and rownum &lt; 100 and field0274 in ('浙S-QZWLJS2402YXZ001-05','浙S-QZWLJS2402YXZ001-04','浙D-NB2412TH15001')
         <trim prefix="where" prefixOverrides="and">
             <if test="id != null and id != ''"> and id = #{id} </if>
         </trim>
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowArchivistPluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowArchivistPluginInitializer.java
index 9585fe46..22e1921e 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowArchivistPluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowArchivistPluginInitializer.java
@@ -110,7 +110,7 @@ public class ProjectMainFlowArchivistPluginInitializer extends PluginBaseEntity
                     //发送数据
                     String result = HttpRequest.post(url).
                             header("appId", "800050").
-                            header("apiCode", "8000500016").
+                            header("apiCode", "8000500011").
                             header("access_token", tokenBody).
                             header("publicKey", "ZJYAQ/VtQ66PqKXlV0EowrrlKkhBHYgS/Zk39Q5ezIQne51Ce7eDIk+3zDUT+v578prj").
                             header("secretKey", "iLLk424Bmzknbu+ROeJoiVDMYY5EFXtbZY/aU13HmVYIiQrIw9c0Ag4ipxbfpUqqj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=").
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowAuditPluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowAuditPluginInitializer.java
index 1ba41d6f..46a32cab 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowAuditPluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/projectMainFlow/plugin/ProjectMainFlowAuditPluginInitializer.java
@@ -111,7 +111,7 @@ public class ProjectMainFlowAuditPluginInitializer extends PluginBaseEntity {
                     //发送数据
                     String result = HttpRequest.post(url).
                             header("appId", "800050").
-                            header("apiCode", "8000500016").
+                            header("apiCode", "8000500011").
                             header("access_token", tokenBody).
                             header("publicKey", "ZJYAQ/VtQ66PqKXlV0EowrrlKkhBHYgS/Zk39Q5ezIQne51Ce7eDIk+3zDUT+v578prj").
                             header("secretKey", "iLLk424Bmzknbu+ROeJoiVDMYY5EFXtbZY/aU13HmVYIiQrIw9c0Ag4ipxbfpUqqj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=").
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/ISalesContractDao.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/ISalesContractDao.java
new file mode 100644
index 00000000..0cfea7f4
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/ISalesContractDao.java
@@ -0,0 +1,29 @@
+package com.hzya.frame.plugin.salesContract.dao;
+
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.plugin.salesContract.entity.SalesContractEntity;
+
+import java.util.List;
+
+public interface ISalesContractDao extends IBaseDao<SalesContractEntity,String> {
+
+    /**
+     *
+     * @content 查询未推送的销售合同
+     * @Param
+     * @Return
+     * @Author hecan
+     * @Date 2025-04-03 11:07
+     * **/
+    List<SalesContractEntity> querySalesContract(SalesContractEntity salesContractEntity);
+
+    /**
+     *
+     * @content 更新销售合同的推送标识
+     * @Param
+     * @Return
+     * @Author hecan
+     * @Date 2025-04-03 11:09
+     * **/
+    Integer updateSalesContract(SalesContractEntity entity);
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/impl/SalesContractDaoImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/impl/SalesContractDaoImpl.java
new file mode 100644
index 00000000..7a7d0ef0
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/dao/impl/SalesContractDaoImpl.java
@@ -0,0 +1,22 @@
+package com.hzya.frame.plugin.salesContract.dao.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+import com.hzya.frame.plugin.salesContract.dao.ISalesContractDao;
+import com.hzya.frame.plugin.salesContract.entity.SalesContractEntity;
+
+import java.util.List;
+
+public class SalesContractDaoImpl extends MybatisGenericDao<SalesContractEntity,String> implements ISalesContractDao {
+    @DS("#entity.dataSourceCode")
+    @Override
+    public List<SalesContractEntity> querySalesContract(SalesContractEntity entity) {
+        return (List<SalesContractEntity>) super.selectList("querySalesContract",entity);
+    }
+
+    @DS("#entity.dataSourceCode")
+    @Override
+    public Integer updateSalesContract(SalesContractEntity entity) {
+        return super.update("updateSalesContract",entity);
+    }
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.java
new file mode 100644
index 00000000..98691005
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.java
@@ -0,0 +1,249 @@
+package com.hzya.frame.plugin.salesContract.entity;
+
+import com.hzya.frame.web.entity.BaseEntity;
+
+public class SalesContractEntity extends BaseEntity {
+    private  String pk_group;//集团编码
+    private  String pk_org;//公司编码
+    private  String contractno;//合同号
+    private  String contractName;//合同名称
+    private  String creator;//创建人用户
+    private  String creationtime;//创建时间
+    private  String contractor;//订单负责人名称
+    private  String cdeptid;//事业部
+    private  String approvestatus;//审批状态默认-1
+    private  String belongtodeptid;//单据归属部门
+    private  String dpk_custclass;//合同对应客户大类
+    private  String dcustomerid;//合同对应客户大类
+    private  String zcustomerid;//
+    private  String cinvoicecustid;//开票客户名称
+    private  String cemployeeid;//业务人员
+    private  String ccurrencyid;//币种
+    private  String totalamount;//原币总金额
+    private  String rmbtotalamount;//人民币总金额
+    private  String presentrate;//汇率 CPO汇率
+    private  String def13;//IPO合同号
+    private  String def16;//IPO汇率
+    private  String def8;//贸易方式
+    private  String def27;//IPO币种
+    private  String def17;//收款账期
+    private  String def18;//账簿本币金额
+    private  String def26;//当前账簿兑人民币汇率
+    private  String pushStatus;//推送标识
+
+    public String getPushStatus() {
+        return pushStatus;
+    }
+
+    public void setPushStatus(String pushStatus) {
+        this.pushStatus = pushStatus;
+    }
+
+    public String getPk_group() {
+        return pk_group;
+    }
+
+    public void setPk_group(String pk_group) {
+        this.pk_group = pk_group;
+    }
+
+    public String getPk_org() {
+        return pk_org;
+    }
+
+    public void setPk_org(String pk_org) {
+        this.pk_org = pk_org;
+    }
+
+    public String getContractno() {
+        return contractno;
+    }
+
+    public void setContractno(String contractno) {
+        this.contractno = contractno;
+    }
+
+    public String getContractName() {
+        return contractName;
+    }
+
+    public void setContractName(String contractName) {
+        this.contractName = contractName;
+    }
+
+    public String getCreator() {
+        return creator;
+    }
+
+    public void setCreator(String creator) {
+        this.creator = creator;
+    }
+
+    public String getCreationtime() {
+        return creationtime;
+    }
+
+    public void setCreationtime(String creationtime) {
+        this.creationtime = creationtime;
+    }
+
+    public String getContractor() {
+        return contractor;
+    }
+
+    public void setContractor(String contractor) {
+        this.contractor = contractor;
+    }
+
+    public String getCdeptid() {
+        return cdeptid;
+    }
+
+    public void setCdeptid(String cdeptid) {
+        this.cdeptid = cdeptid;
+    }
+
+    public String getApprovestatus() {
+        return approvestatus;
+    }
+
+    public void setApprovestatus(String approvestatus) {
+        this.approvestatus = approvestatus;
+    }
+
+    public String getBelongtodeptid() {
+        return belongtodeptid;
+    }
+
+    public void setBelongtodeptid(String belongtodeptid) {
+        this.belongtodeptid = belongtodeptid;
+    }
+
+    public String getDpk_custclass() {
+        return dpk_custclass;
+    }
+
+    public void setDpk_custclass(String dpk_custclass) {
+        this.dpk_custclass = dpk_custclass;
+    }
+
+    public String getDcustomerid() {
+        return dcustomerid;
+    }
+
+    public void setDcustomerid(String dcustomerid) {
+        this.dcustomerid = dcustomerid;
+    }
+
+    public String getZcustomerid() {
+        return zcustomerid;
+    }
+
+    public void setZcustomerid(String zcustomerid) {
+        this.zcustomerid = zcustomerid;
+    }
+
+    public String getCinvoicecustid() {
+        return cinvoicecustid;
+    }
+
+    public void setCinvoicecustid(String cinvoicecustid) {
+        this.cinvoicecustid = cinvoicecustid;
+    }
+
+    public String getCemployeeid() {
+        return cemployeeid;
+    }
+
+    public void setCemployeeid(String cemployeeid) {
+        this.cemployeeid = cemployeeid;
+    }
+
+    public String getCcurrencyid() {
+        return ccurrencyid;
+    }
+
+    public void setCcurrencyid(String ccurrencyid) {
+        this.ccurrencyid = ccurrencyid;
+    }
+
+    public String getTotalamount() {
+        return totalamount;
+    }
+
+    public void setTotalamount(String totalamount) {
+        this.totalamount = totalamount;
+    }
+
+    public String getRmbtotalamount() {
+        return rmbtotalamount;
+    }
+
+    public void setRmbtotalamount(String rmbtotalamount) {
+        this.rmbtotalamount = rmbtotalamount;
+    }
+
+    public String getPresentrate() {
+        return presentrate;
+    }
+
+    public void setPresentrate(String presentrate) {
+        this.presentrate = presentrate;
+    }
+
+    public String getDef13() {
+        return def13;
+    }
+
+    public void setDef13(String def13) {
+        this.def13 = def13;
+    }
+
+    public String getDef16() {
+        return def16;
+    }
+
+    public void setDef16(String def16) {
+        this.def16 = def16;
+    }
+
+    public String getDef8() {
+        return def8;
+    }
+
+    public void setDef8(String def8) {
+        this.def8 = def8;
+    }
+
+    public String getDef27() {
+        return def27;
+    }
+
+    public void setDef27(String def27) {
+        this.def27 = def27;
+    }
+
+    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 getDef26() {
+        return def26;
+    }
+
+    public void setDef26(String def26) {
+        this.def26 = def26;
+    }
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.xml b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.xml
new file mode 100644
index 00000000..09c7ede1
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/entity/SalesContractEntity.xml
@@ -0,0 +1,73 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hzya.frame.plugin.salesContract.dao.impl.SalesContractDaoImpl">
+    <resultMap id="get-SalesContractEntity-result" type="com.hzya.frame.plugin.salesContract.entity.SalesContractEntity" >
+        <result property="id" column="id" 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>
+
+    <sql id = "SalesContractEntity_Base_Column_List">
+        formmain_8694.id as id,
+            'SW01' as pk_group, -- 集团编码
+            field0132 as pk_org, -- 公司编码
+            field0009 as contractno, -- 合同号
+            field0010 as contractName, -- 合同名称
+            'field0146' as pushStatusFiald, -- 推送标识字段
+            field0146 as pushStatus,  -- 推送标识
+            'OA' as creator, -- 创建人用户
+            to_char(field0007,'yyyy-MM-dd HH24:mi:ss') as creationtime, -- 创建时间
+            '' as contractor, -- 订单负责人名称
+            '' as cdeptid, -- 事业部
+            '-1' as approvestatus, -- 审批状态默认
+            '' as belongtodeptid, -- 单据归属部门
+            '' as dpk_custclass, -- 合同对应客户大类
+            '' as dcustomerid, -- 合同对应客户大类
+            '' as zcustomerid,
+            '' as cinvoicecustid, -- 开票客户名称
+            field0145 as cemployeeid, -- 业务人员
+            field0143 as ccurrencyid, -- 币种
+            field0012 as totalamount, -- 原币总金额
+            '' as rmbtotalamount, -- 人民币总金额
+            '' as presentrate, -- 汇率
+            '' as def13, -- IPO合同号
+            '' as def16, -- IPO汇率
+            myfs.SORTNUMBER as def8, -- 贸易方式
+            '' as def27, -- IPO币种
+            skzq.SORTNUMBER as def17, -- 收款账期
+            '' as def18, -- 账簿本币金额
+            '' as def26 -- 当前账簿兑人民币汇率
+    </sql>
+
+    <!--查询审计完成的数据,推送BIP新增-->
+    <select id="querySalesContract" resultMap="get-SalesContractEntity-result" parameterType = "com.hzya.frame.plugin.salesContract.entity.SalesContractEntity">
+        select
+        <include refid="SalesContractEntity_Base_Column_List" />
+        from
+        formmain_8694
+        LEFT JOIN COL_SUMMARY summary ON summary.FORM_RECORDID = formmain_8694.id
+        left join CTP_ENUM_ITEM myfs on myfs.id=field0141
+        left join CTP_ENUM_ITEM skzq on skzq.id=field0138
+        where  field0146 is null and to_char(field0007,'yyyy-MM-dd HH24:mi:ss')>'2025-01-01'
+        and summary.state in ('1','3')
+        and field0132 is not null and field0009='4501889245'
+        <trim prefix="where" prefixOverrides="and">
+            <if test="id != null and id != ''"> and id = #{id} </if>
+        </trim>
+    </select>
+
+
+    <update id="updateSalesContract" parameterType="com.hzya.frame.plugin.salesContract.entity.SalesContractEntity">
+        update formmain_8694 set field0146 = #{pushStatus} where id = #{id}
+    </update>
+
+
+
+</mapper>
+
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/plugin/SalesContractPluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/plugin/SalesContractPluginInitializer.java
new file mode 100644
index 00000000..ecfd8bcf
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/plugin/SalesContractPluginInitializer.java
@@ -0,0 +1,213 @@
+package com.hzya.frame.plugin.salesContract.plugin;
+
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpRequest;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.hzya.frame.base.PluginBaseEntity;
+import com.hzya.frame.plugin.projectMainFlow.entity.ProjectMainFlowEntity;
+import com.hzya.frame.plugin.salesContract.dao.ISalesContractDao;
+import com.hzya.frame.plugin.salesContract.entity.SalesContractEntity;
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.service.IIntegrationTaskLivingDetailsService;
+import com.hzya.frame.uuid.UUIDUtils;
+import com.hzya.frame.web.entity.BaseResult;
+import com.hzya.frame.web.entity.JsonResultEntity;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+
+import java.util.Date;
+import java.util.List;
+
+public class SalesContractPluginInitializer extends PluginBaseEntity {
+    Logger logger = LoggerFactory.getLogger(SalesContractPluginInitializer.class);
+
+    @Autowired
+    private ISalesContractDao salesContractDao;
+
+    @Autowired
+    private IIntegrationTaskLivingDetailsService taskLivingDetailsService;
+
+    @Value("${zt.url}")
+    private String url;
+
+    @Override
+    public void initialize() {
+        logger.info(getPluginLabel() + "執行初始化方法initialize()");
+    }
+
+    @Override
+    public void destroy() {
+        logger.info(getPluginLabel() + "執行銷毀方法destroy()");
+    }
+
+    @Override
+    public String getPluginId() {
+        return "SalesContractPluginInitializer";
+    }
+
+    @Override
+    public String getPluginName() {
+        return "销售合同新增";
+    }
+
+    @Override
+    public String getPluginLabel() {
+        return "SalesContractPluginInitializer";
+    }
+
+    @Override
+    public String getPluginType() {
+        return "1";
+    }
+
+    @Override
+    public JsonResultEntity executeBusiness(JSONObject requestJson)  {
+        try {
+            logger.info("======开始执行销售合同推送BIP========");
+            //重试方法
+            if (null != requestJson) {
+                //如果这个id不为空,说明是重试的
+                String id = requestJson.getString("integration_task_living_details_id");
+                //执行重新发送
+                SalesContractEntity salesContractEntity = new SalesContractEntity();
+                salesContractEntity.setDataSourceCode("SW-OA");
+                if (StrUtil.isNotEmpty(id)) {
+                    salesContractEntity.setId(id);
+                }
+                //查询未推送的数据
+                List<SalesContractEntity> salesContractEntities = salesContractDao.querySalesContract(salesContractEntity);
+                if(salesContractEntities == null || salesContractEntities.size() == 0){
+                    logger.info("=====没有需要推送BIP的销售合同==========");
+                    return BaseResult.getSuccessMessageEntity("查询成功");
+                }
+                for (SalesContractEntity contractEntity : salesContractEntities) {
+                    //组装数据
+                    JSONObject sendData = getSendData(contractEntity);
+                    JSONObject tokenData = getBipTokenData();
+                    contractEntity.setDataSourceCode("SW-OA");
+                    //获取TOKEN
+                    String tokenResult = HttpRequest.post(url).
+                            header("appId", "800050").
+                            header("apiCode", "8000500003").
+                            header("publicKey", "ZJYAQ/VtQ66PqKXlV0EowrrlKkhBHYgS/Zk39Q5ezIQne51Ce7eDIk+3zDUT+v578prj").
+                            header("secretKey", "iLLk424Bmzknbu+ROeJoiVDMYY5EFXtbZY/aU13HmVYIiQrIw9c0Ag4ipxbfpUqqj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=").
+                            body(tokenData.toString()).
+                            execute().
+                            body();
+                    logger.error("销售合同推送BIPtoken返回结果:"+tokenResult);
+                    JSONObject tokenResultJson = JSONObject.parseObject(tokenResult);
+                    if(!tokenResultJson.getBoolean("flag")){
+                        logger.info("=========销售合同获取biptoken错误,开始修改销售合同推送标识为失败==========");
+                        contractEntity.setPushStatus("0");
+                        salesContractDao.updateSalesContract(contractEntity);
+                        logger.info("=========销售合同获取biptoken错误,修改销售合同推送标识完毕==========");
+                        continue;
+                    }
+                    String tokenBody = tokenResultJson.getJSONObject("attribute").getJSONObject("data").getString("access_token");
+                    //发送数据
+                    String result = HttpRequest.post(url).
+                            header("appId", "800050").
+                            header("apiCode", "8000500012").
+                            header("access_token", tokenBody).
+                            header("publicKey", "ZJYAQ/VtQ66PqKXlV0EowrrlKkhBHYgS/Zk39Q5ezIQne51Ce7eDIk+3zDUT+v578prj").
+                            header("secretKey", "iLLk424Bmzknbu+ROeJoiVDMYY5EFXtbZY/aU13HmVYIiQrIw9c0Ag4ipxbfpUqqj3JzOP8MtA1LSGvL+2BWG8c/o7DKi92S4mr3zcGearA=").
+                            body(sendData.toString()).
+                            execute().
+                            body();
+                    logger.error("销售合同推送BIP返回结果:"+result);
+                    JSONObject resultJson = JSONObject.parseObject(result);
+                    if(!resultJson.getBoolean("flag")){
+                        logger.info("=========销售合同获取bip返回结果错误,开始修改销售合同推送标识为失败==========");
+                        contractEntity.setPushStatus("0");
+                        salesContractDao.updateSalesContract(contractEntity);
+                        logger.info("=========销售合同获取bip返回结果错误,修改销售合同推送标识为失败完毕==========");
+                        saveTaskLivingDetails(contractEntity.getId(),contractEntity.getContractno(),sendData.toString(),resultJson.toJSONString(),false);
+                    }else {
+                        logger.info("=========销售合同获取bip返回结果成功,开始修改销售合同推送标识为成功==========");
+                        contractEntity.setPushStatus("1");
+                        salesContractDao.updateSalesContract(contractEntity);
+                        logger.info("=========销售合同获取bip返回结果成功,修改销售合同推送标识为成功完毕==========");
+                        saveTaskLivingDetails(contractEntity.getId(),contractEntity.getContractno(),sendData.toString(),resultJson.toJSONString(),true);
+                    }
+                }
+            }
+            logger.info("=======销售合同推送BIP执行成功=======");
+            return BaseResult.getSuccessMessageEntity("销售合同执行成功");
+        }catch (Exception e){
+            logger.info("======执行销售合同推送BIP失败:{}========", e.getMessage());
+            e.printStackTrace();
+        }
+        return BaseResult.getFailureMessageEntity("销售合同执行失败");
+    }
+
+    private JSONObject getSendData(SalesContractEntity contractEntity) {
+        JSONObject bill = new JSONObject();
+        bill.put("pk_group",contractEntity.getPk_group());//集团编码
+        bill.put("pk_org",contractEntity.getPk_org());//公司编码
+        bill.put("contractno",contractEntity.getContractno());//合同号
+        bill.put("name",contractEntity.getContractName());//合同名称
+        bill.put("creator",contractEntity.getCreator());//创建人用户
+        bill.put("creationtime",contractEntity.getCreationtime());//创建时间
+        bill.put("contractor",contractEntity.getContractor());//订单负责人名称
+        bill.put("cdeptid",contractEntity.getCdeptid());//事业部
+        bill.put("approvestatus",contractEntity.getApprovestatus());//审批状态默认
+        bill.put("belongtodeptid",contractEntity.getBelongtodeptid());//单据归属部门
+        bill.put("dpk_custclass",contractEntity.getDpk_custclass());//合同对应客户大类
+        bill.put("dcustomerid",contractEntity.getDcustomerid());//合同对应客户大类
+        bill.put("zcustomerid",contractEntity.getZcustomerid());
+        bill.put("cinvoicecustid",contractEntity.getCinvoicecustid());//开票客户名称
+        bill.put("cemployeeid",contractEntity.getCemployeeid());//业务人员
+        bill.put("ccurrencyid",contractEntity.getCcurrencyid());//币种
+        bill.put("totalamount",contractEntity.getTotalamount());//原币总金额
+        bill.put("rmbtotalamount",contractEntity.getRmbtotalamount());//人民币总金额
+        bill.put("presentrate",contractEntity.getPresentrate());//汇率
+        bill.put("def13",contractEntity.getDef13());//IPO合同号
+        bill.put("def16",contractEntity.getDef16());//IPO汇率
+        bill.put("def8",contractEntity.getDef8());//贸易方式
+        bill.put("def27",contractEntity.getDef27());//IPO币种
+        bill.put("def17",contractEntity.getDef17());//收款账期
+        bill.put("def18",contractEntity.getDef18());//账簿本币金额
+        bill.put("def26",contractEntity.getDef26());//当前账簿兑人民币汇率
+        JSONObject htdd01Master=new JSONObject();
+        htdd01Master.put("htdd01Master",bill);
+        return htdd01Master;
+    }
+
+    private JSONObject getBipTokenData() {
+        JSONObject jsonObject = new JSONObject();
+
+
+
+        return jsonObject;
+    }
+
+
+    private void saveTaskLivingDetails(String rootAppPk,String rootAppBill,String rootAppNewData,String newTransmitInfo,boolean flag) {
+        try {
+            IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity();
+            integrationTaskLivingDetailsEntity.setId(UUIDUtils.getUUID());
+            integrationTaskLivingDetailsEntity.setSts("Y");
+            integrationTaskLivingDetailsEntity.setCreate_user_id("1");
+            integrationTaskLivingDetailsEntity.setModify_user_id("1");
+            integrationTaskLivingDetailsEntity.setCreate_time(new Date());
+            integrationTaskLivingDetailsEntity.setModify_time(new Date());
+            integrationTaskLivingDetailsEntity.setOrg_id("0");
+            integrationTaskLivingDetailsEntity.setCompanyId("0");
+            integrationTaskLivingDetailsEntity.setRootAppPk(rootAppPk);
+            integrationTaskLivingDetailsEntity.setRootAppBill(rootAppBill);
+            integrationTaskLivingDetailsEntity.setPluginId("SalesContractPluginInitializer");
+            integrationTaskLivingDetailsEntity.setRootAppNewData(rootAppNewData);
+            integrationTaskLivingDetailsEntity.setNewTransmitInfo(newTransmitInfo);
+            if (flag) {
+                taskLivingDetailsService.saveLogToSuccess(integrationTaskLivingDetailsEntity);
+            } else {
+                taskLivingDetailsService.saveLogToFail(integrationTaskLivingDetailsEntity);
+            }
+        } catch (Exception e) {
+            logger.info("保存日志到集成任务日志明细中失败:{}", e.getMessage());
+        }
+    }
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/ISalesContractService.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/ISalesContractService.java
new file mode 100644
index 00000000..bb764464
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/ISalesContractService.java
@@ -0,0 +1,7 @@
+package com.hzya.frame.plugin.salesContract.service;
+
+import com.hzya.frame.basedao.service.IBaseService;
+import com.hzya.frame.plugin.salesContract.entity.SalesContractEntity;
+
+public interface ISalesContractService extends IBaseService<SalesContractEntity,String> {
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/impl/SalesContractServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/impl/SalesContractServiceImpl.java
new file mode 100644
index 00000000..0e6c4e7a
--- /dev/null
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/salesContract/service/impl/SalesContractServiceImpl.java
@@ -0,0 +1,18 @@
+package com.hzya.frame.plugin.salesContract.service.impl;
+
+import com.hzya.frame.basedao.service.impl.BaseService;
+import com.hzya.frame.plugin.salesContract.dao.ISalesContractDao;
+import com.hzya.frame.plugin.salesContract.entity.SalesContractEntity;
+import com.hzya.frame.plugin.salesContract.service.ISalesContractService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class SalesContractServiceImpl extends BaseService<SalesContractEntity,String> implements ISalesContractService {
+
+    private ISalesContractDao salesContractDao;
+
+    @Autowired
+    public void setSalesContractDao(ISalesContractDao dao) {
+        this.salesContractDao = dao;
+        this.dao = dao;
+    }
+}
diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/serviceData/plugin/ServiceDataDistributePluginInitializer.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/serviceData/plugin/ServiceDataDistributePluginInitializer.java
index 84f9389b..10e424c3 100644
--- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/serviceData/plugin/ServiceDataDistributePluginInitializer.java
+++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/serviceData/plugin/ServiceDataDistributePluginInitializer.java
@@ -612,7 +612,7 @@ public class ServiceDataDistributePluginInitializer extends PluginBaseEntity{
         map1.put("tableName",mainDb);
         map1.put("dataStatus", "N");
         map1.put("deleteStatus", "0");
-        map1.put("size", 50);
+        //map1.put("size", 50);
         objects = mdmModuleDao.queryMdmSTs(map1);
         objects = toLowerCaseKeys(objects);
 
@@ -807,7 +807,7 @@ public class ServiceDataDistributePluginInitializer extends PluginBaseEntity{
         map1.put("tableName",mainDb);
         //map1.put("dataStatus", "F");
         map1.put("updateStatus", "0");
-        map1.put("size", 50);
+        //map1.put("size", 50);
         objects = mdmModuleDao.queryMdmSTs(map1);
         objects = toLowerCaseKeys(objects);
 
@@ -995,7 +995,7 @@ public class ServiceDataDistributePluginInitializer extends PluginBaseEntity{
         map1.put("tableName",mainDb);
         //map1.put("dataStatus", "Y");
         map1.put("addStatus", "0");
-        map1.put("size", 50);
+       //map1.put("size", 50);
         objects = mdmModuleDao.queryMdmSTs(map1);
         objects = toLowerCaseKeys(objects);