新增客户单位信息同步

CZT

2023-08-10 7ac1c19249561ef5cc0bf277ef3c683e7515a146

新增客户单位信息同步

 src/main/java/com/fzzy/api/view/repository/Api1109Rep.java

@@ -1,15 +1,14 @@
package com.fzzy.api.view.repository;

import com.fzzy.api.entity.Api1109;
import com.fzzy.api.entity.Api1202;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.List;


public interface Api1109Rep extends JpaRepository<Api1109, String> , JpaSpecificationExecutor<Api1109> {

@@ -23,4 +22,7 @@

    @Query("from Api1109 where bizId=:bizId ")
    List<Api1109> getDataByBizId(@Param("bizId") String bizId);

    @Query("from Api1109 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1109> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/api/view/repository/Api1212Rep.java

@@ -17,9 +17,9 @@
    @Query("update Api1212 set czbz =:czbz where id=:id")
    void updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    @Query("from Api1212 where id=:id ")
    List<Api1212> getDataById(@Param("id") String id);

    @Query("from Api1212 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1212> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

    @Query("from Api1212 where id=:id ")
    List<Api1212> getDataById(@Param("id") String id);
}

 src/main/java/com/fzzy/async/fzzy35/Fzzy35SyncService12.java

@@ -35,6 +35,9 @@
    private Fzzy35Sync1208 fzzySync1208;
    @Autowired
    private Fzzy35Sync1209 fzzySync1209;
    @Autowired
    private Fzzy35Sync1212 fzzySync1212;


    @Override
    public String getProtocol() {
@@ -48,34 +51,35 @@
        String deptId = param.getDeptId();
        Date start = param.getStart();
        Date end = param.getEnd();
        //客户单位信息同步
        fzzySync1212.syncData(kqdm, deptId, start, end);


        //合同同步
        fzzySync1201.syncData(kqdm, deptId, start, end);

        //粮食入库同步
        fzzySync1202.syncData(kqdm, deptId, start, end);

        //粮食入库质检同步
        fzzySync1203.syncData(kqdm, deptId, start, end);

        //粮食入库结算同步
        fzzySync1204.syncData(kqdm, deptId, start, end);

        //粮食出库同步
        fzzySync1205.syncData(kqdm, deptId, start, end);

        //粮食出库结算同步
        fzzySync1206.syncData(kqdm, deptId, start, end);

        //粮食损溢同步
        fzzySync1209.syncData(kqdm, deptId, start, end);

        //文件信息同步
        fzzy35Sync1109.syncData(kqdm, deptId, start, end);

        //粮食库存同步
        fzzySync1208.syncData(kqdm, deptId, start, end);
//        //合同同步
//        fzzySync1201.syncData(kqdm, deptId, start, end);
//
//        //粮食入库同步
//        fzzySync1202.syncData(kqdm, deptId, start, end);
//
//        //粮食入库质检同步
//        fzzySync1203.syncData(kqdm, deptId, start, end);
//
//        //粮食入库结算同步
//        fzzySync1204.syncData(kqdm, deptId, start, end);
//
//        //粮食出库同步
//        fzzySync1205.syncData(kqdm, deptId, start, end);
//
//        //粮食出库结算同步
//        fzzySync1206.syncData(kqdm, deptId, start, end);
//
//        //粮食损溢同步
//        fzzySync1209.syncData(kqdm, deptId, start, end);
//
//        //文件信息同步
//        fzzy35Sync1109.syncData(kqdm, deptId, start, end);
//
//        //粮食库存同步
//        fzzySync1208.syncData(kqdm, deptId, start, end);
    }

}

 src/main/java/com/fzzy/async/fzzy35/entity/Fz35InoutCustomer.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,101 @@
package com.fzzy.async.fzzy35.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
import java.util.Date;

/**
 * å‡ºå…¥åº“客户-往来单位信息
 *
 * @author
 */
@Data
@Entity
@Table(name = "D_INOUT_CUSTOMER")
public class Fz35InoutCustomer implements Serializable{

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键id编码", description = "系统内编码")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "TYPE_", length = 4)
    @PropertyDef(label = "业务分类", description = "系统内使用：提货商、供货商")
    private String type;

    @Column(name = "khlx", length = 50)
    @PropertyDef(label = "客户类型", description = "1-企业，2-个人")
    private String khlx;

    @PropertyDef(label = "客户编码：企业客户填写统一社会信用代码，个人客户填写身份证号")
    @Column(name = "khbh", length = 18)
    private String khbh;

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "客户名称")
    private String name;

    @PropertyDef(label = "法定代表人")
    @Column(name = "fddbr", length = 64)
    private String fddbr;

    @Column(name = "ADDRESS_", length = 200)
    @PropertyDef(label = "通讯地址")
    private String address;

    @PropertyDef(label = "邮政编码")
    @Column(name = "yzbm", length = 6)
    private String yzbm;

    @Column(name = "CONTACT_USER_", length = 50)
    @PropertyDef(label = "联系人")
    private String contactUser;

    @Column(name = "PHONE_", length = 20)
    @PropertyDef(label = "联系电话")
    private String phone;

    @Column(name = "CARD_ID_", length = 20)
    @PropertyDef(label = "联系人身份证号")
    private String cardId;

    @PropertyDef(label = "电子信箱")
    @Column(name = "dzyx", length = 64)
    private String dzyx;

    @Column(name = "BANK_", length = 50)
    @PropertyDef(label = "开户银行")
    private String bank;

    @Column(name = "BANK_NUM_", length = 30)
    @PropertyDef(label = "银行账号")
    private String bankNum;

    @Column(name = "FOOD_AREA_", length = 30)
    @PropertyDef(label = "种植面积")
    private Double foodArea = 0.0;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;

}

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1201.java

@@ -98,8 +98,8 @@
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodVariety());
                apiData.setLsxzdm(mappingCode);

                //单价：元/公斤-->元/吨
                apiData.setHtdj(sysData.getPrice() == null ? 0.0 : sysData.getPrice()*1000);
                //单价：元/吨
                apiData.setHtdj(sysData.getPrice() == null ? 0.0 : sysData.getPrice());
                apiData.setYdgxlssl(sysData.getContactAmount() == null ? 0.0 : sysData.getContactAmount());

                apiData.setHtzje(new BigDecimal(sysData.getMoney()));

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1212.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,110 @@
package com.fzzy.async.fzzy35.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1212;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1212Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.Fz35InoutCustomer;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1212Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;

/**
 * å®¢æˆ·å•ä½ä¿¡æ¯æ•°æ®æŽ¥å£
 */
@Slf4j
@Component
public class Fzzy35Sync1212 {

    @Autowired
    private Fzzy35Sync1212Rep fzzySync1212Rep;
    @Autowired
    private Api1212Rep api1212Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;


    /**
     * åŒæ­¥å®¢æˆ·å•ä½ä¿¡æ¯æŽ¥å£
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1212接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1201);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz35InoutCustomer> list = fzzySync1212Rep.listInoutCustomer(deptId);

            if (null == list || list.isEmpty()) {
                log.debug("-------------没有获取到单位信息------------------");
                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1201 = api1102Rep.findById(kqdm).get();

            Api1212 apiData;
            List<Api1212> api1212List;
            for (Fz35InoutCustomer sysData : list) {

                apiData = new Api1212();
                //单位代码
                apiData.setId(sysData.getId());
                apiData.setDwdm(api1201.getDwdm());
                apiData.setKqdm(kqdm);
                apiData.setKhlx(sysData.getKhlx());
                apiData.setKhtyshxydmhsfzh(sysData.getKhbh());
                apiData.setKhmc(sysData.getName());
                apiData.setFddbr(sysData.getFddbr());
                apiData.setTxdz(StringUtils.isEmpty(sysData.getAddress()) ? "单位地址" :sysData.getAddress());
                apiData.setYzbm(StringUtils.isEmpty(sysData.getYzbm()) ? "" :sysData.getYzbm());
                apiData.setLxrxm(StringUtils.isEmpty(sysData.getContactUser()) ? sysData.getFddbr() :sysData.getContactUser());
                apiData.setLxrdh(StringUtils.isEmpty(sysData.getPhone()) ? "" :sysData.getPhone());
                apiData.setLxrsfzh(StringUtils.isEmpty(sysData.getCardId()) ? "100000000000000000" :sysData.getCardId());
                apiData.setDzyx(StringUtils.isEmpty(sysData.getDzyx()) ? "" :sysData.getDzyx());
//                apiData.setKhfkhh(StringUtils.isEmpty(sysData.getBank()) ? "" :sysData.getBank());
                apiData.setKhfzh(StringUtils.isEmpty(sysData.getBankNum()) ? "" :sysData.getBankNum());
                apiData.setZhgxsj(sysData.getUpdateTime() == null ? new Date() : sysData.getUpdateTime());
                apiData.setBizId(sysData.getId());


                api1212List = api1212Rep.getDataById(sysData.getKhbh());
                if(null == api1212List || api1212List.isEmpty()){
                    apiData.setCzbz(Constant.CZBZ_I);
                }else {
                    apiData.setCzbz(api1212List.get(0).getCzbz());
                }

                //保存数据
                api1212Rep.save(apiData);

                log.info("1212---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---客户单位同步执行失败----{}", e);
            apiLog.setResult("同步客户单位信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1212Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.fzzy.async.fzzy35.repository;

import com.fzzy.async.fzzy35.entity.Fz35InoutCustomer;
import com.fzzy.async.fzzy35.entity.Fz35MContract;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;

/**
 * ç²®é£Ÿè´­é”€-客户单位信息接口数据获取
 */
public interface Fzzy35Sync1212Rep extends JpaRepository<Fz35InoutCustomer, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–客户单位信息
     *
     * @return
     */
    @Query("from Fz35InoutCustomer where deptId=:deptId order by id ")
    List<Fz35InoutCustomer> listInoutCustomer(@Param("deptId") String deptId);


    @Query("from Fz35InoutCustomer where khbh=:khbh ")
    List<Fz35InoutCustomer> getDataById(@Param("khbh") String khbh);
}

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1212.java

@@ -3,7 +3,6 @@
import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1212Rep;
import com.fzzy.api.view.repository.ApiLogRep;
@@ -27,8 +26,6 @@
    private Fzzy40Sync1212Rep fzzySync1212Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1212Rep api1212Rep;
    @Autowired
@@ -63,37 +60,33 @@

            //根据库区代码获取库区代码
            Api1102 api1201 = api1102Rep.findById(kqdm).get();
            List<Api1101> list1 = api1101Rep.findPushData(kqdm);
            Api1101 api1101 = list1.get(0);

            Api1212 apiData;
            List<Api1212> api1212List;
            for (Fz40InoutCustomer sysData : list) {

                apiData = new Api1212();

                apiData.setId(sysData.getId());
                //单位代码（ 1101 æŽ¥å£çš„单位代 ç ï¼‰ +自定义编码
                apiData.setDwdm(api1101.getDwdm());
                apiData.setDwmc(api1101.getDwmc());
                apiData.setKqmc(api1201.getKqmc());
                //单位代码
                apiData.setId(sysData.getKhbh());
                apiData.setDwdm(api1201.getDwdm());
                apiData.setKqdm(kqdm);
                apiData.setKhlx(StringUtils.isEmpty(sysData.getKhlx()) ? "1":sysData.getKhlx());
                apiData.setKhtyshxydmhsfzh(sysData.getCardId());
                apiData.setKhlx(sysData.getKhlx());
                apiData.setKhtyshxydmhsfzh(sysData.getKhbh());
                apiData.setKhmc(sysData.getName());

                apiData.setFddbr(StringUtils.isEmpty(sysData.getFddbr())? "法定人" : sysData.getFddbr());

                apiData.setTxdz(sysData.getAddress());
                apiData.setYzbm(sysData.getYzbm());
                apiData.setLxrdh(sysData.getContactUser());
                apiData.setKhfkhh(sysData.getBank());
                apiData.setKhfzh(sysData.getBankNum());
                apiData.setFddbr(sysData.getFddbr());
                apiData.setTxdz(StringUtils.isEmpty(sysData.getAddress()) ? "单位地址" :sysData.getAddress());
                apiData.setYzbm(StringUtils.isEmpty(sysData.getYzbm()) ? "" :sysData.getYzbm());
                apiData.setLxrxm(StringUtils.isEmpty(sysData.getContactUser()) ? sysData.getFddbr() :sysData.getContactUser());
                apiData.setLxrdh(StringUtils.isEmpty(sysData.getPhone()) ? "" :sysData.getPhone());
                apiData.setLxrsfzh(StringUtils.isEmpty(sysData.getCardId()) ? "100000000000000000" :sysData.getCardId());
                apiData.setDzyx(StringUtils.isEmpty(sysData.getDzyx()) ? "" :sysData.getDzyx());
//                apiData.setKhfkhh(StringUtils.isEmpty(sysData.getBank()) ? "" :sysData.getBank());
                apiData.setKhfzh(StringUtils.isEmpty(sysData.getBankNum()) ? "" :sysData.getBankNum());
                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getId());
                apiData.setZhgxsj(new Date());

                api1212List = api1212Rep.getDataById(apiData.getId());

                api1212List = api1212Rep.getDataById(sysData.getKhbh());
                if(null == api1212List || api1212List.isEmpty()){
                    apiData.setCzbz(Constant.CZBZ_I);
                }else {
@@ -103,7 +96,7 @@
                //保存数据
                api1212Rep.save(apiData);

                log.info("1201---同步数据：{}", apiData.toString());
                log.info("1212---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---合同同步执行失败----{}", e);

 src/main/java/com/fzzy/push/impl/ComPushService12.java

@@ -46,7 +46,7 @@
     */
    public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {

        List<Api1109> items = api1109Rep.findPushData(param.getKqdm());
        List<Api1109> items = api1109Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == items || items.isEmpty()) {
            return;

 src/main/resources/application-pro.yml

@@ -1,4 +1,4 @@
##########################  å¹¿ä¸œæƒ å·žæƒ é˜³   ##########################
##########################  å¹¿ä¸œæ½®é˜³   ##########################
server:
  port: 8090
  jetty:
@@ -38,7 +38,7 @@
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
  # Redis相关配置
  redis:
    database: 1
    database: 0
    host: 127.0.0.1
    port: 6379
    password: Abc123..
@@ -51,7 +51,7 @@
      timeout: 6000
igds:
  default:
    companyId: 5326
    companyId: 5317

  file-path: D:/IGDS-API/FILE/
  img-path: D:/IGDS/FILE/