风险管控措施,可通过传参"全量"和"每日"来控制上传数据范围

src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java

@@ -8,6 +8,7 @@ import com.hxjt.dataupload.utils.HttpUtils;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.apache.http.protocol.HTTP;
+import org.apache.ibatis.annotations.Param;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,11 +28,15 @@ public class FxgkcsJobHandler {
 
     @XxlJob(value = "FxgkcsJobHandler", init = "init", destroy = "destroy")
     public void execute(String param) {
-
-        ArrayList<Fxgkcs> fxgkcs = fxfxdxService.getFxgkcss();
-
+        String jobParam = XxlJobHelper.getJobParam();
+        ArrayList<Fxgkcs> fxgkcs = new ArrayList<>();
+        if (jobParam.equals("全量")) {
+            fxgkcs = fxfxdxService.getFxgkcss("N");
+        }else if(jobParam.equals("每日")){
+            fxgkcs = fxfxdxService.getFxgkcss("Y");
+        }
         for (int i = 0; i < fxgkcs.size(); i++) {
-
+            System.out.println(i + 1);
             String company = fxgkcs.get(i).getQiyemingcheng();
             String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/fengxianguankongqing/v1/fengxianguankongqing";
             switch (company) {
@@ -42,16 +47,16 @@ public class FxgkcsJobHandler {
                     try {
                         post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "7CTkAyBoL26Jo7ZMNVmg0EA57A0791FD71AB");
                         //System.out.println("post:"+post.toString());
-                        XxlJobHelper.log("执行日志:"+company+post.toString());
+                        //XxlJobHelper.log("执行日志:" + company + post.toString());
                     } catch (IOException e) {
                         e.printStackTrace();
-                        XxlJobHelper.handleFail("任务执行失败"+e.getMessage());
+                        XxlJobHelper.handleFail("任务执行失败" + e.getMessage());
                     }
                     break;
-                //System.out.println("post:"+post1.toString());
             }
         }
 
+
     }
 
 

src/main/java/com/hxjt/dataupload/mapper/FxfxdxMapper.java

@@ -5,6 +5,7 @@ import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdy;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxgkcs;
 import com.hxjt.dataupload.model.entity.doubleprevent.Fxsj;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.ArrayList;
 
@@ -18,5 +19,5 @@ public interface FxfxdxMapper {
 
     ArrayList<Fxsj> getFxsjs();
 
-    ArrayList<Fxgkcs> getFxgkcss();
+    ArrayList<Fxgkcs> getFxgkcss(@Param("isSingleDay")String isSingleDay);
 }

src/main/java/com/hxjt/dataupload/service/FxfxdxService.java

@@ -18,5 +18,5 @@ public interface FxfxdxService {
     //风险事件
     ArrayList<Fxsj> getFxsjs();
     //风险管控措施
-    ArrayList<Fxgkcs> getFxgkcss();
+    ArrayList<Fxgkcs> getFxgkcss(String isSingleDay);
 }

src/main/java/com/hxjt/dataupload/service/impl/FxfxdxServiceImpl.java

@@ -35,7 +35,7 @@ public class FxfxdxServiceImpl implements FxfxdxService {
     }
 
     @Override
-    public ArrayList<Fxgkcs> getFxgkcss() {
-        return fxfxdxMapper.getFxgkcss();
+    public ArrayList<Fxgkcs> getFxgkcss(String isSingleDay) {
+        return fxfxdxMapper.getFxgkcss(isSingleDay);
     }
 }

src/main/java/com/hxjt/dataupload/utils/HttpUtils.java

@@ -271,7 +271,7 @@ public class HttpUtils {
         httpPost.setHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
         httpPost.setHeader("entId","ningyanghuagongchany");
         httpPost.setHeader("keyAuthentication",keyAuthentication);
-        System.out.println("请求地址："+url);
+        //System.out.println("请求地址："+url);
         //执行请求操作，并拿到结果（同步阻塞）
         CloseableHttpResponse response = client.execute(httpPost);
         //获取结果实体

src/main/resources/mapper/FxfxdxMapper.xml

@@ -195,6 +195,12 @@
 		-- 左连接账户表
 		LEFT JOIN PF_ACCOUNT h ON a.CREATOR = h.id
 		WHERE
-			 a.ISDELETE = 'N';
+			 a.ISDELETE = 'N'
+			<if test='isSingleDay == "Y"'>
+				AND a.CREASTAMP BETWEEN
+				DATEADD(DAY, -90, CAST(SYSDATETIME() AS date)) AND
+				DATEADD(DAY, -1, CAST(SYSDATETIME() AS datetime2(6)))
+			</if>
+		ORDER BY jilushijian DESC
 	</select>
 </mapper>