【】【根据文档修改获取方式，改为按时间段处理】

src/main/java/com/uas/entity/DayCount.java

@@ -0,0 +1,377 @@
+package com.uas.entity;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * @author koul
+ * @email koul@usoftchina.com
+ * @date 2021-02-02 16:56
+ */
+@Entity
+@Table(name = "FBDAYCOUNT")
+public class DayCount {
+    @Id
+    @SequenceGenerator(name="FBDAYCOUNT_SEQ", sequenceName="FBDAYCOUNT_SEQ", allocationSize=1)
+    @GeneratedValue(strategy= GenerationType.SEQUENCE, generator="FBDAYCOUNT_SEQ")
+    private Long fdc_id;
+    private Date fdc_date;
+    private Long fdc_fbid;
+    private String fdc_tyshxycode;
+    private String fdc_name;
+    private int fdc_gsbgaddcount;
+    private int fdc_gsbgcount;
+    private int fdc_investoraddcount;
+    private int fdc_investorcount;
+    private int fdc_memberaddcount;
+    private int fdc_membercount;
+    private int fdc_ktggaddcount;
+    private int fdc_ktggcount;
+    private int fdc_cpwsaddcount;
+    private int fdc_cpwscount;
+    private int fdc_zhixingaddcount;
+    private int fdc_zhixingcount;
+    private int fdc_shixinaddcount;
+    private int fdc_shixincount;
+    private int fdc_jyycaddcount;
+    private int fdc_jyyccount;
+    private int fdc_sswfaddcount;
+    private int fdc_sswfcount;
+    private int fdc_qsjladdcount;
+    private int fdc_qsjlcount;
+    private int fdc_dcdyaddcount;
+    private int fdc_dcdycount;
+    private int fdc_gqczaddcount;
+    private int fdc_gqczcount;
+    private int fdc_sfxzaddcount;
+    private int fdc_sfxzcount;
+    private int fdc_ssggaddcount;
+    private int fdc_ssggcount;
+    private int fdc_danbaoaddcount;
+    private int fdc_danbaocount;
+    private int fdc_zczbbgaddcount;
+    private int fdc_tzrbgaddcount;
+    private int fdc_fddbraddcount;
+    private int fdc_ggbdaddcount;
+    private int fdc_jyfwbgaddcount;
+
+    public int getFdc_zczbbgaddcount() {
+        return fdc_zczbbgaddcount;
+    }
+
+    public void setFdc_zczbbgaddcount(int fdc_zczbbgaddcount) {
+        this.fdc_zczbbgaddcount = fdc_zczbbgaddcount;
+    }
+
+    public int getFdc_tzrbgaddcount() {
+        return fdc_tzrbgaddcount;
+    }
+
+    public void setFdc_tzrbgaddcount(int fdc_tzrbgaddcount) {
+        this.fdc_tzrbgaddcount = fdc_tzrbgaddcount;
+    }
+
+    public int getFdc_fddbraddcount() {
+        return fdc_fddbraddcount;
+    }
+
+    public void setFdc_fddbraddcount(int fdc_fddbraddcount) {
+        this.fdc_fddbraddcount = fdc_fddbraddcount;
+    }
+
+    public int getFdc_ggbdaddcount() {
+        return fdc_ggbdaddcount;
+    }
+
+    public void setFdc_ggbdaddcount(int fdc_ggbdaddcount) {
+        this.fdc_ggbdaddcount = fdc_ggbdaddcount;
+    }
+
+    public int getFdc_jyfwbgaddcount() {
+        return fdc_jyfwbgaddcount;
+    }
+
+    public void setFdc_jyfwbgaddcount(int fdc_jyfwbgaddcount) {
+        this.fdc_jyfwbgaddcount = fdc_jyfwbgaddcount;
+    }
+
+    public Long getFdc_id() {
+        return fdc_id;
+    }
+
+    public void setFdc_id(Long fdc_id) {
+        this.fdc_id = fdc_id;
+    }
+
+    public Date getFdc_date() {
+        return fdc_date;
+    }
+
+    public void setFdc_date(Date fdc_date) {
+        this.fdc_date = fdc_date;
+    }
+
+    public Long getFdc_fbid() {
+        return fdc_fbid;
+    }
+
+    public void setFdc_fbid(Long fdc_fbid) {
+        this.fdc_fbid = fdc_fbid;
+    }
+
+    public String getFdc_tyshxycode() {
+        return fdc_tyshxycode;
+    }
+
+    public void setFdc_tyshxycode(String fdc_tyshxycode) {
+        this.fdc_tyshxycode = fdc_tyshxycode;
+    }
+
+    public String getFdc_name() {
+        return fdc_name;
+    }
+
+    public void setFdc_name(String fdc_name) {
+        this.fdc_name = fdc_name;
+    }
+
+    public int getFdc_gsbgaddcount() {
+        return fdc_gsbgaddcount;
+    }
+
+    public void setFdc_gsbgaddcount(int fdc_gsbgaddcount) {
+        this.fdc_gsbgaddcount = fdc_gsbgaddcount;
+    }
+
+    public int getFdc_gsbgcount() {
+        return fdc_gsbgcount;
+    }
+
+    public void setFdc_gsbgcount(int fdc_gsbgcount) {
+        this.fdc_gsbgcount = fdc_gsbgcount;
+    }
+
+    public int getFdc_investoraddcount() {
+        return fdc_investoraddcount;
+    }
+
+    public void setFdc_investoraddcount(int fdc_investoraddcount) {
+        this.fdc_investoraddcount = fdc_investoraddcount;
+    }
+
+    public int getFdc_investorcount() {
+        return fdc_investorcount;
+    }
+
+    public void setFdc_investorcount(int fdc_investorcount) {
+        this.fdc_investorcount = fdc_investorcount;
+    }
+
+    public int getFdc_memberaddcount() {
+        return fdc_memberaddcount;
+    }
+
+    public void setFdc_memberaddcount(int fdc_memberaddcount) {
+        this.fdc_memberaddcount = fdc_memberaddcount;
+    }
+
+    public int getFdc_membercount() {
+        return fdc_membercount;
+    }
+
+    public void setFdc_membercount(int fdc_membercount) {
+        this.fdc_membercount = fdc_membercount;
+    }
+
+    public int getFdc_ktggaddcount() {
+        return fdc_ktggaddcount;
+    }
+
+    public void setFdc_ktggaddcount(int fdc_ktggaddcount) {
+        this.fdc_ktggaddcount = fdc_ktggaddcount;
+    }
+
+    public int getFdc_ktggcount() {
+        return fdc_ktggcount;
+    }
+
+    public void setFdc_ktggcount(int fdc_ktggcount) {
+        this.fdc_ktggcount = fdc_ktggcount;
+    }
+
+    public int getFdc_cpwsaddcount() {
+        return fdc_cpwsaddcount;
+    }
+
+    public void setFdc_cpwsaddcount(int fdc_cpwsaddcount) {
+        this.fdc_cpwsaddcount = fdc_cpwsaddcount;
+    }
+
+    public int getFdc_cpwscount() {
+        return fdc_cpwscount;
+    }
+
+    public void setFdc_cpwscount(int fdc_cpwscount) {
+        this.fdc_cpwscount = fdc_cpwscount;
+    }
+
+    public int getFdc_zhixingaddcount() {
+        return fdc_zhixingaddcount;
+    }
+
+    public void setFdc_zhixingaddcount(int fdc_zhixingaddcount) {
+        this.fdc_zhixingaddcount = fdc_zhixingaddcount;
+    }
+
+    public int getFdc_zhixingcount() {
+        return fdc_zhixingcount;
+    }
+
+    public void setFdc_zhixingcount(int fdc_zhixingcount) {
+        this.fdc_zhixingcount = fdc_zhixingcount;
+    }
+
+    public int getFdc_shixinaddcount() {
+        return fdc_shixinaddcount;
+    }
+
+    public void setFdc_shixinaddcount(int fdc_shixinaddcount) {
+        this.fdc_shixinaddcount = fdc_shixinaddcount;
+    }
+
+    public int getFdc_shixincount() {
+        return fdc_shixincount;
+    }
+
+    public void setFdc_shixincount(int fdc_shixincount) {
+        this.fdc_shixincount = fdc_shixincount;
+    }
+
+    public int getFdc_jyycaddcount() {
+        return fdc_jyycaddcount;
+    }
+
+    public void setFdc_jyycaddcount(int fdc_jyycaddcount) {
+        this.fdc_jyycaddcount = fdc_jyycaddcount;
+    }
+
+    public int getFdc_jyyccount() {
+        return fdc_jyyccount;
+    }
+
+    public void setFdc_jyyccount(int fdc_jyyccount) {
+        this.fdc_jyyccount = fdc_jyyccount;
+    }
+
+    public int getFdc_sswfaddcount() {
+        return fdc_sswfaddcount;
+    }
+
+    public void setFdc_sswfaddcount(int fdc_sswfaddcount) {
+        this.fdc_sswfaddcount = fdc_sswfaddcount;
+    }
+
+    public int getFdc_sswfcount() {
+        return fdc_sswfcount;
+    }
+
+    public void setFdc_sswfcount(int fdc_sswfcount) {
+        this.fdc_sswfcount = fdc_sswfcount;
+    }
+
+    public int getFdc_qsjladdcount() {
+        return fdc_qsjladdcount;
+    }
+
+    public void setFdc_qsjladdcount(int fdc_qsjladdcount) {
+        this.fdc_qsjladdcount = fdc_qsjladdcount;
+    }
+
+    public int getFdc_qsjlcount() {
+        return fdc_qsjlcount;
+    }
+
+    public void setFdc_qsjlcount(int fdc_qsjlcount) {
+        this.fdc_qsjlcount = fdc_qsjlcount;
+    }
+
+    public int getFdc_dcdyaddcount() {
+        return fdc_dcdyaddcount;
+    }
+
+    public void setFdc_dcdyaddcount(int fdc_dcdyaddcount) {
+        this.fdc_dcdyaddcount = fdc_dcdyaddcount;
+    }
+
+    public int getFdc_dcdycount() {
+        return fdc_dcdycount;
+    }
+
+    public void setFdc_dcdycount(int fdc_dcdycount) {
+        this.fdc_dcdycount = fdc_dcdycount;
+    }
+
+    public int getFdc_gqczaddcount() {
+        return fdc_gqczaddcount;
+    }
+
+    public void setFdc_gqczaddcount(int fdc_gqczaddcount) {
+        this.fdc_gqczaddcount = fdc_gqczaddcount;
+    }
+
+    public int getFdc_gqczcount() {
+        return fdc_gqczcount;
+    }
+
+    public void setFdc_gqczcount(int fdc_gqczcount) {
+        this.fdc_gqczcount = fdc_gqczcount;
+    }
+
+    public int getFdc_sfxzaddcount() {
+        return fdc_sfxzaddcount;
+    }
+
+    public void setFdc_sfxzaddcount(int fdc_sfxzaddcount) {
+        this.fdc_sfxzaddcount = fdc_sfxzaddcount;
+    }
+
+    public int getFdc_sfxzcount() {
+        return fdc_sfxzcount;
+    }
+
+    public void setFdc_sfxzcount(int fdc_sfxzcount) {
+        this.fdc_sfxzcount = fdc_sfxzcount;
+    }
+
+    public int getFdc_ssggaddcount() {
+        return fdc_ssggaddcount;
+    }
+
+    public void setFdc_ssggaddcount(int fdc_ssggaddcount) {
+        this.fdc_ssggaddcount = fdc_ssggaddcount;
+    }
+
+    public int getFdc_ssggcount() {
+        return fdc_ssggcount;
+    }
+
+    public void setFdc_ssggcount(int fdc_ssggcount) {
+        this.fdc_ssggcount = fdc_ssggcount;
+    }
+
+    public int getFdc_danbaoaddcount() {
+        return fdc_danbaoaddcount;
+    }
+
+    public void setFdc_danbaoaddcount(int fdc_danbaoaddcount) {
+        this.fdc_danbaoaddcount = fdc_danbaoaddcount;
+    }
+
+    public int getFdc_danbaocount() {
+        return fdc_danbaocount;
+    }
+
+    public void setFdc_danbaocount(int fdc_danbaocount) {
+        this.fdc_danbaocount = fdc_danbaocount;
+    }
+}

src/main/java/com/uas/entity/Dcdy.java

@@ -48,6 +48,7 @@ public class Dcdy {
     @JSONField(name = "统一社会信用编号")
     private String fd_tyshxycode;
     private Long fd_fbid;
+    private int fd_detno;
 
     public Long getFd_fbid() {
         return fd_fbid;

src/main/java/com/uas/entity/ExecutedPerson.java

@@ -36,6 +36,15 @@ public class ExecutedPerson {
     @JSONField(name = "统一社会信用编号")
     private String fep_tyshxycode;
     private Long fep_fbid;
+    private int fep_detno;
+
+    public int getFep_detno() {
+        return fep_detno;
+    }
+
+    public void setFep_detno(int fep_detno) {
+        this.fep_detno = fep_detno;
+    }
 
     public Long getFep_fbid() {
         return fep_fbid;

src/main/java/com/uas/entity/Gqcz.java

@@ -42,6 +42,15 @@ public class Gqcz {
     @JSONField(name = "统一社会信用编号")
     private String fg_tyshxycode;
     private Long fg_fbid;
+    private int fg_detno;
+
+    public int getFg_detno() {
+        return fg_detno;
+    }
+
+    public void setFg_detno(int fg_detno) {
+        this.fg_detno = fg_detno;
+    }
 
     public Long getFg_fbid() {
         return fg_fbid;

src/main/java/com/uas/entity/Jyyc.java

@@ -33,6 +33,15 @@ public class Jyyc {
     @JSONField(name = "统一社会信用代码")
     private String fj_tyshxycode;
     private Long fj_fbid;
+    private int fj_detno;
+
+    public int getFj_detno() {
+        return fj_detno;
+    }
+
+    public void setFj_detno(int fj_detno) {
+        this.fj_detno = fj_detno;
+    }
 
     public Long getFj_fbid() {
         return fj_fbid;

src/main/java/com/uas/entity/Qsjl.java

@@ -37,6 +37,15 @@ public class Qsjl {
     @JSONField(name = "统一社会信用编号")
     private String fq_tyshxycode;
     private Long fq_fbid;
+    private int fq_detno;
+
+    public int getFq_detno() {
+        return fq_detno;
+    }
+
+    public void setFq_detno(int fq_detno) {
+        this.fq_detno = fq_detno;
+    }
 
     public Long getFq_fbid() {
         return fq_fbid;

src/main/java/com/uas/entity/Sfxz.java

@@ -50,6 +50,15 @@ public class Sfxz {
     @JSONField(name = "统一社会信用编号")
     private String ff_tyshxycode;
     private Long ff_fbid;
+    private int ff_detno;
+
+    public int getFf_detno() {
+        return ff_detno;
+    }
+
+    public void setFf_detno(int ff_detno) {
+        this.ff_detno = ff_detno;
+    }
 
     public Long getFf_fbid() {
         return ff_fbid;

src/main/java/com/uas/entity/Ssgg.java

@@ -32,7 +32,15 @@ public class Ssgg {
     private String fss_entities;
     @JSONField(name = "正文")
     private String fss_text;
+    private int fss_detno;
 
+    public int getFss_detno() {
+        return fss_detno;
+    }
+
+    public void setFss_detno(int fss_detno) {
+        this.fss_detno = fss_detno;
+    }
 
     public Long getFss_fbid() {
         return fss_fbid;

src/main/java/com/uas/entity/Sswf.java

@@ -37,6 +37,15 @@ public class Sswf {
     @JSONField(name = "统一社会信用编号")
     private String fs_tyshxycode;
     private Long fs_fbid;
+    private int fs_detno;
+
+    public int getFs_detno() {
+        return fs_detno;
+    }
+
+    public void setFs_detno(int fs_detno) {
+        this.fs_detno = fs_detno;
+    }
 
     public Long getFs_fbid() {
         return fs_fbid;

src/main/java/com/uas/entity/Sxbzxr.java

@@ -49,6 +49,15 @@ public class Sxbzxr {
     @JSONField(name = "统一社会信用编号")
     private String fsx_tyshxycode;
     private Long fsx_fbid;
+    private int fsx_detno;
+
+    public int getFsx_detno() {
+        return fsx_detno;
+    }
+
+    public void setFsx_detno(int fsx_detno) {
+        this.fsx_detno = fsx_detno;
+    }
 
     public Long getFsx_fbid() {
         return fsx_fbid;

src/main/java/com/uas/service/CustomerService.java

@@ -12,9 +12,9 @@ import java.util.List;
  */
 public interface CustomerService {
 
-    List<String> getFollowingByGroup()  throws Exception;
+    List<String> getFollowingByGroup();
 
-    void saveBusiness(String company_id) throws Exception;
+    void saveBusiness(String company_id);
 
     void updateGZStatus(List<String> list);
 

src/main/java/com/uas/task/ScheduleTask.java

@@ -25,22 +25,17 @@ public class ScheduleTask {
      * 保存客户资料
      */
     public void saveFbCustomer() {
-        try {
-            logger.info("保存客户资料开始");
-            Date date = new Date();
-            List<String> following = customerService.getFollowingByGroup();
-            if (following != null) {
-                customerService.updateGZStatus(following);
-                for (String s : following) {
-                    customerService.saveBusiness(s);
-                }
-                customerService.updateCUGZStatus(following);
+        logger.info("保存客户资料开始");
+        Date date = new Date();
+        List<String> following = customerService.getFollowingByGroup();
+        if (following != null) {
+            customerService.updateGZStatus(following);
+            for (String s : following) {
+                customerService.saveBusiness(s);
             }
-            logger.info("保存客户资料结束:用时" + ((System.currentTimeMillis() - date.getTime()) / 1000));
-        } catch (Exception e) {
-            logger.error(e.getMessage());
-            e.printStackTrace();
+            customerService.updateCUGZStatus(following);
         }
+        logger.info("保存客户资料结束:用时" + ((System.currentTimeMillis() - date.getTime()) / 1000));
 
     }
 }