授信跑批失效

taskMan/src/main/java/com/huyi/task/taskMan/mapper/CreditTaskMapper.java

@@ -0,0 +1,17 @@
+package com.huyi.task.taskMan.mapper;
+
+import java.util.List;
+import java.util.Map;
+
+
+public interface CreditTaskMapper
+{
+
+    /**
+     * 查询到期的授信
+     * @param map
+     * @return
+     */
+    public List<Map> selectExpireCredit(Map map);
+
+}

taskMan/src/main/java/com/huyi/task/taskMan/schedule/CreditTask.java

@@ -0,0 +1,50 @@
+package com.huyi.task.taskMan.schedule;
+
+import com.huyi.task.base.entity.ZcFinanceProComRel;
+import com.huyi.task.base.service.IZcFinanceProComRelService;
+import com.huyi.task.taskMan.service.CreditTaskService;
+import com.tianhu.common.core.utils.CommonUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Configuration      //1.主要用于标记配置类，兼备Component的效果。
+@EnableScheduling   // 2.开启定时任务
+public class CreditTask {
+    private static final Logger log = LoggerFactory.getLogger(CreditTask.class);
+
+    @Autowired
+    private CreditTaskService   creditTaskService;
+    @Autowired
+    private IZcFinanceProComRelService financeProComRelService;
+
+    /**
+     * 授信失效定时跑批
+     */
+    //每2分钟
+    //@Scheduled(cron = "0 */2 * * * ?")
+    //每天凌晨一点
+    @Scheduled(cron = "0 0 1 * * ?")
+    private void changeCreditStates() throws Exception{
+        Map<String,String>  map = new HashMap();
+        List<Map> list = creditTaskService.selectExpireCredit(map);
+        for(int i =0 ; i < list.size();i++){
+            Map rel = list.get(i);
+            //获取主键
+            String zfpcrId = CommonUtil.objToString(rel.get("zfpcrId"));
+            ZcFinanceProComRel proComRel = new ZcFinanceProComRel();
+            proComRel.setZfpcrId(zfpcrId);
+            proComRel.setZfpcrStatus("01");
+            financeProComRelService.updateById(proComRel);
+        }
+    }
+
+
+}
+

taskMan/src/main/java/com/huyi/task/taskMan/service/CreditTaskService.java

@@ -0,0 +1,20 @@
+package com.huyi.task.taskMan.service;
+
+
+import java.util.List;
+import java.util.Map;
+
+
+public interface CreditTaskService
+{
+    /**
+     * 查询到期的授信
+     * @param map
+     * @return
+     */
+    public List<Map> selectExpireCredit(Map map);
+
+
+
+
+}

taskMan/src/main/java/com/huyi/task/taskMan/service/impl/CreditTaskServiceImpl.java

@@ -0,0 +1,30 @@
+package com.huyi.task.taskMan.service.impl;
+
+import com.huyi.task.taskMan.mapper.CreditTaskMapper;
+import com.huyi.task.taskMan.mapper.FinanceTimedTaskMapper;
+import com.huyi.task.taskMan.service.CreditTaskService;
+import com.huyi.task.taskMan.service.FinanceTimedTaskService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 还款Service业务层处理
+ * 
+ * @author ch
+ * @date 2021-09-06
+ */
+@Service
+public class CreditTaskServiceImpl implements CreditTaskService
+{
+    @Autowired
+    private CreditTaskMapper creditTaskMapper;
+
+
+    @Override
+    public List<Map> selectExpireCredit(Map map) {
+        return creditTaskMapper.selectExpireCredit(map);
+    }
+}

taskMan/src/main/resources/mapper/taskMan/CreditTaskMapper.xml

@@ -0,0 +1,17 @@
+<?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.huyi.task.taskMan.mapper.CreditTaskMapper">
+
+    <select id="selectExpireCredit" parameterType="map" resultType="map">
+        SELECT
+                zfpcr_id    'zfpcrId'
+
+        FROM  zc_finance_pro_com_rel
+        WHERE zfpcr_date_type = '1'
+        AND zfpcr_status = '00'
+        AND zfpcr_end_date IS NOT NULL
+        AND to_days(zfpcr_end_date) &lt; to_days(now())
+
+    </select>
+
+</mapper>