每次只删除返回的客户 其他客户不做清理

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

@@ -33,8 +33,6 @@ public class DanBao {
     private String fd_bgdate;
     @JSONField(name = "报告类型")
     private String fd_bgtype;
-    @JSONField(name = "担保事件说明")
-    private String fd_event;
     @JSONField(name = "担保方")
     private String fd_guarantor;
     @JSONField(name = "担保方式")
@@ -57,10 +55,12 @@ public class DanBao {
     private String fd_title;
     @JSONField(name = "被担保方")
     private String fd_bparty;
-    @JSONField(name = "详情")
-    private String fd_detail;
     private Long fd_fbid;
     private String fd_tyshxycode;
+    @JSONField(name = "担保事件说明")
+    private String fd_event;
+    @JSONField(name = "详情")
+    private String fd_detail;
 
     public Long getFd_id() {
         return fd_id;

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

@@ -17,8 +17,7 @@ public class Ssgg {
     @SequenceGenerator(name="FBSSGG_SEQ", sequenceName="FBSSGG_SEQ", allocationSize=1)
     @GeneratedValue(strategy= GenerationType.SEQUENCE, generator="FBSSGG_SEQ")
     private Long fss_id;
-    @JSONField(name = "entities")
-    private String fss_entities;
+    private Long fss_fbid;
     @JSONField(name = "公告人")
     private String fss_announcer;
     @JSONField(name = "公告时间")
@@ -27,11 +26,13 @@ public class Ssgg {
     private String fss_type;
     @JSONField(name = "当事人")
     private String fss_party;
-    @JSONField(name = "正文")
-    private String fss_text;
     @JSONField(name = "统一社会信用编号")
     private String fss_tyshxycode;
-    private Long fss_fbid;
+    @JSONField(name = "entities")
+    private String fss_entities;
+    @JSONField(name = "正文")
+    private String fss_text;
+
 
     public Long getFss_fbid() {
         return fss_fbid;

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

@@ -49,6 +49,6 @@ public interface CustomerService {
 
     void saveSsgg(String company_id);*/
 
-     void deleteAll();
+    /* void deleteAll();*/
 
 }

src/main/java/com/uas/service/Impl/CustomerServiceImpl.java

@@ -42,7 +42,8 @@ public class CustomerServiceImpl implements CustomerService {
         put("size",Integer.toString(size));
     }};
 
-
+    @Autowired
+    private BaseDao baseDao;
     @Autowired
     private BusinessDao businessDao;
     @Autowired
@@ -136,6 +137,7 @@ public class CustomerServiceImpl implements CustomerService {
     @Async("taskExecutor")
     @Override
     public void saveBusiness(String company_id) {
+        deleteByCompanyId(company_id);
         Map<String, String> param = new HashMap<>();
         param.put("apikey",apikey);
         String s = httpResponse(url + company + "/" + company_id, hender, param);
@@ -386,10 +388,10 @@ public class CustomerServiceImpl implements CustomerService {
                     List<CpwsDetail> cpwsDetails = JSON.parseArray(cpjes.toString(),CpwsDetail.class);
                     int det=1;
                     for (CpwsDetail cpwsDetail:cpwsDetails) {
-                        cpwsDetail.setFcd_fcid(fc_id);
                         cpwsDetail.setFcd_type("判决金额");
                         cpwsDetail.setFcd_detno(det);
                         cpwsDetail.setFcd_payer(stringArraytoString(cpwsDetail.getFcd_payer()));
+                        cpwsDetail.setFcd_fcid(fc_id);
                         det=det+1;
                     }
                     cpwsDetailDao.save(cpwsDetails);
@@ -563,9 +565,9 @@ public class CustomerServiceImpl implements CustomerService {
         if (jsonArray!=null) {
             List<Ssgg> ssggs = JSON.parseArray(jsonArray.toString(), Ssgg.class);
             for (Ssgg ssgg:ssggs) {
-                ssgg.setFss_entities(stringArraytoString(ssgg.getFss_entities()));
                 ssgg.setFss_party(stringArraytoString(ssgg.getFss_party()));
                 ssgg.setFss_tyshxycode(company_id);
+                ssgg.setFss_entities(stringArraytoString(ssgg.getFss_entities()));
                 ssgg.setFss_fbid(id);
             }
             ssggDao.save(ssggs);
@@ -587,10 +589,10 @@ public class CustomerServiceImpl implements CustomerService {
                 danBao.setFd_guarantor(stringArraytoString(danBao.getFd_guarantor()));
                 danBao.setFd_dbmethod(stringArraytoString(danBao.getFd_dbmethod()));
                 danBao.setFd_bparty(stringArraytoString(danBao.getFd_bparty()));
-                danBao.setFd_detail(stringArraytoString(danBao.getFd_detail()));
                 danBao.setFd_tyshxycode(company_id);
-                danBao.setFd_fbid(id);
                 danBao.setFd_detno(detno);
+                danBao.setFd_detail(stringArraytoString(danBao.getFd_detail()));
+                danBao.setFd_fbid(id);
                 detno=detno+1;
             }
             danBaoDao.save(danBaos);
@@ -601,49 +603,51 @@ public class CustomerServiceImpl implements CustomerService {
     /**
      * 清除所有相关表中数据
      */
-    @Override
-    public void deleteAll() {
-        //清除工商资料明细
-        businessDetailDao.deleteAll();
-        //清除工商资料
-        businessDao.deleteAll();
-        //清除工商变更
-        businessChangeDao.deleteAll();
-        //清除工商登记股东信息明细
-        investorRJDetailDao.deleteAll();
-        //清除工商登记股东信息
-        investorDao.deleteAll();
-        //清除主要成员
-        memberDao.deleteAll();
-        //清除开庭公告明细
-        ktggDetailDao.deleteAll();
-        //清除开庭公告
-        ktggDao.deleteAll();
-        //清除裁判文书明细
-        cpwsDetailDao.deleteAll();
-        //清除裁判文书
-        cpwsDao.deleteAll();
-        //清除被执行人
-        executedPersonDao.deleteAll();
-        //清除失信被执行人
-        sxbzxrDao.deleteAll();
-        //清除经营异常
-        jyycDao.deleteAll();
-        //清除重大税收违法
-        sswfDao.deleteAll();
-        //清除催缴/欠税
-        qsjlDao.deleteAll();
-        //清除动产抵押明细
-        dcdyDetailDao.deleteAll();
-        //清除动产抵押
-        dcdyDao.deleteAll();
-        //清除股权出质
-        gqczDao.deleteAll();
-        //清除司法协助
-        sfxzDao.deleteAll();
-        //清除涉诉公告
-        ssggDao.deleteAll();
-        danBaoDao.deleteAll();
+    private void deleteByCompanyId(String company_id) {
+        if (baseDao.checkIf("FBBUSINESS","fb_tyshxycode='"+company_id+"'")) {
+            //清除工商资料明细
+            baseDao.execute("delete from FBBUSINESSDETAIL where fbd_fbid in (select fb_id from FBBUSINESS where fb_tyshxycode='" + company_id + "')");
+            //清除工商资料
+            baseDao.execute("delete from FBBUSINESS where fb_tyshxycode='" + company_id + "'");
+            //清除工商变更
+            baseDao.execute("delete from FBBUSINESSCHANGE where fbc_tyshxycode='" + company_id + "'");
+            //清除工商登记股东信息明细
+            baseDao.execute("delete from FBINVESTORDETAIL where fid_fiid in (select fi_id from FBINVESTOR where fi_tyshxycode='" + company_id + "')");
+            //清除工商登记股东信息
+            baseDao.execute("delete from FBINVESTOR where fi_tyshxycode='" + company_id + "'");
+            //清除主要成员
+            baseDao.execute("delete from FBMEMBER where fm_tyshxycode='" + company_id + "'");
+            //清除开庭公告明细
+            baseDao.execute("delete from FBKTGGDETAIL where fkd_fkid in (select fk_id from FBKTGG where fk_tyshxycode='" + company_id + "')");
+            //清除开庭公告
+            baseDao.execute("delete from FBKTGG where fk_tyshxycode='" + company_id + "'");
+            //清除裁判文书明细
+            baseDao.execute("delete from FBCPWSDETAIL where fcd_fcid in (select fc_id from FBCPWS where fc_tyshxycode='" + company_id + "')");
+            //清除裁判文书
+            baseDao.execute("delete from FBCPWS where fc_tyshxycode='" + company_id + "'");
+            //清除被执行人
+            baseDao.execute("delete from FBEXECUTEDPERSON where fep_tyshxycode='" + company_id + "'");
+            //清除失信被执行人
+            baseDao.execute("delete from FBSXBZXR where fsx_tyshxycode='" + company_id + "'");
+            //清除经营异常
+            baseDao.execute("delete from FBJYYC where fj_tyshxycode='" + company_id + "'");
+            //清除重大税收违法
+            baseDao.execute("delete from FBSSWF where fs_tyshxycode='" + company_id + "'");
+            //清除催缴/欠税
+            baseDao.execute("delete from FBQSJL where fq_tyshxycode='" + company_id + "'");
+            //清除动产抵押明细
+            baseDao.execute("delete from FBDCDYDETAIL where fdd_fdid in (select fd_id from FBDCDY where fd_tyshxycode='" + company_id + "')");
+            //清除动产抵押
+            baseDao.execute("delete from FBDCDY where fd_tyshxycode='" + company_id + "'");
+            //清除股权出质
+            baseDao.execute("delete from FBGQCZ where fg_tyshxycode='" + company_id + "'");
+            //清除司法协助
+            baseDao.execute("delete from FBSFXZ where ff_tyshxycode='" + company_id + "'");
+            //清除涉诉公告
+            baseDao.execute("delete from FBSSGG where fss_tyshxycode='" + company_id + "'");
+            //清除担保信息
+            baseDao.execute("delete from FBDANBAO where fd_tyshxycode='" + company_id + "'");
+        }
 
     }
 

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

@@ -1,6 +1,5 @@
 package com.uas.task;
 
-import com.uas.entity.Group;
 import com.uas.service.CustomerService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -31,7 +30,6 @@ public class ScheduleTask {
         Date date = new Date();
         List<String> following = customerService.getFollowingByGroup();
         if (following != null) {
-            customerService.deleteAll();
             for (String s : following) {
                 customerService.saveBusiness(s);
             }