融信失效跑批

taskMan/src/main/java/com/huyi/task/base/entity/SysNotice.java

@@ -0,0 +1,113 @@
+package com.huyi.task.base.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.util.Date;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 消息通知表
+ * </p>
+ *
+ * @author xuefy
+ * @since 2021-09-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("sys_notice")
+public class SysNotice implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 消息ID
+     */
+    @TableId("notice_id")
+    private String noticeId;
+
+    /**
+     * 公司id
+     */
+    @TableField("company_id")
+    private String companyId;
+
+    /**
+     * 关联表主键
+     */
+    @TableField("table_id")
+    private String tableId;
+
+    /**
+     * 公告标题
+     */
+    @TableField("notice_title")
+    private String noticeTitle;
+
+    /**
+     * 00:待办,01:消息提醒
+     */
+    @TableField("type")
+    private String type;
+
+    /**
+     * 消息提醒类型(00:平台欢迎信, 01:发起人审批结果通知, 02:经办人的平台审批结果通知, 03:融资企业经办人融信失效消息通知, 04:融资企业经办人融信生效消息通知)
+     */
+    @TableField("notice_type")
+    private String noticeType;
+
+    /**
+     * 待办类型:(00:融信审批待审批, 01:审批拒绝待编辑, 02:核心企业待确权, 03:待盖章, 04:待签收, 05:待融资, 06:待还款)
+     */
+    @TableField("work_type")
+    private String workType;
+
+    /**
+     * 状态（0待办 1已办）
+     */
+    @TableField("status")
+    private String status;
+
+    /**
+     * 是否短信提醒(0:不提醒, 1:提醒)
+     */
+    @TableField("message_send")
+    private String messageSend;
+
+    /**
+     * 已发短信ID
+     */
+    @TableField("message_id")
+    private String messageId;
+
+    /**
+     * 短信模板
+     */
+    @TableField("message_code")
+    private String messageCode;
+
+    /**
+     * 短信发送状态（0:未发送 1:已发送）
+     */
+    @TableField("message_status")
+    private String messageStatus;
+
+    /**
+     * 备注
+     */
+    @TableField("remark")
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    @TableField("create_time")
+    private Date createTime;
+
+
+}

taskMan/src/main/java/com/huyi/task/base/mapper/SysNoticeMapper.java

@@ -0,0 +1,16 @@
+package com.huyi.task.base.mapper;
+
+import com.huyi.task.base.entity.SysNotice;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 消息通知表 Mapper 接口
+ * </p>
+ *
+ * @author xuefy
+ * @since 2021-09-08
+ */
+public interface SysNoticeMapper extends BaseMapper<SysNotice> {
+
+}

taskMan/src/main/java/com/huyi/task/base/service/ISysNoticeService.java

@@ -0,0 +1,60 @@
+package com.huyi.task.base.service;
+
+import com.huyi.task.base.entity.SysNotice;
+
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+
+
+import java.util.List;
+
+/**
+ * ClassName: ISysNoticeService<br>
+ * Description: SysNoticeService接口 <br>
+ * Company: keao
+ *
+ * @author xuefy
+ * @version v1.0.0    2021-09-08  xuefy    由Generator自动创建
+ */
+public interface ISysNoticeService extends IService<SysNotice> {
+    /**
+     * 查询（分页）
+     *
+     * @param request QueryRequest
+     * @param wrapper LambdaQueryWrapper<SysNotice>
+     * @return IPage<SysNotice>
+     */
+    IPage<SysNotice> findSysNotices(QueryRequest request, LambdaQueryWrapper<SysNotice> wrapper);
+
+    /**
+     * 查询（所有）
+     *
+     * @param wrapper LambdaQueryWrapper<SysNotice>
+     * @return List<SysNotice>
+     */
+    List<SysNotice> findSysNotices(LambdaQueryWrapper<SysNotice> wrapper);
+
+    /**
+     * 新增
+     *
+     * @param sysNotice sysNotice
+     */
+    void createSysNotice(SysNotice sysNotice);
+
+    /**
+     * 修改
+     *
+     * @param sysNotice sysNotice
+     */
+    void updateSysNotice(SysNotice sysNotice);
+
+    /**
+     * 删除
+     *
+     * @param wrapper LambdaQueryWrapper<SysNotice>
+     */
+    void deleteSysNotice(LambdaQueryWrapper<SysNotice> wrapper);
+}

taskMan/src/main/java/com/huyi/task/base/service/impl/SysNoticeServiceImpl.java

@@ -0,0 +1,64 @@
+package com.huyi.task.base.service.impl;
+
+import com.huyi.task.base.entity.SysNotice;
+import com.huyi.task.base.mapper.SysNoticeMapper;
+import com.huyi.task.base.service.ISysNoticeService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.beans.factory.annotation.Autowired;
+import com.keao.tianhu.starter.mybatis.plus.entity.QueryRequest;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+
+import java.util.List;
+
+/**
+ * ClassName: SysNoticeServiceImpl<br>
+ * Description: ISysNoticeService实现 <br>
+ * Company: keao
+ *
+ * @author xuefy
+ * @version v1.0.0    2021-09-08  xuefy    由Generator自动创建
+ */
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class)
+public class SysNoticeServiceImpl extends ServiceImpl<SysNoticeMapper, SysNotice> implements ISysNoticeService {
+
+    @Autowired
+    private SysNoticeMapper sysNoticeMapper;
+
+    @Override
+    public IPage<SysNotice> findSysNotices(QueryRequest request, LambdaQueryWrapper<SysNotice> wrapper) {
+        Page<SysNotice> page = new Page<>(request.getPageNum(), request.getPageSize());
+        return this.page(page, wrapper);
+    }
+
+    @Override
+    public List<SysNotice> findSysNotices(LambdaQueryWrapper<SysNotice> wrapper) {
+		return this.list(wrapper);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void createSysNotice(SysNotice sysNotice) {
+        this.save(sysNotice);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateSysNotice(SysNotice sysNotice) {
+        this.saveOrUpdate(sysNotice);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void deleteSysNotice(LambdaQueryWrapper<SysNotice> wrapper) {
+	    this.remove(wrapper);
+	}
+}

taskMan/src/main/java/com/huyi/task/taskMan/controller/FinanceTimedTaskController.java

@@ -0,0 +1,271 @@
+package com.huyi.task.taskMan.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huyi.task.base.entity.*;
+import com.huyi.task.base.service.*;
+import com.huyi.task.taskMan.service.FinanceTimedTaskService;
+import com.keao.tianhu.core.util.AmtUtil;
+import com.tianhu.common.core.domain.R;
+import com.tianhu.common.core.utils.CommonUtil;
+import com.tianhu.common.core.utils.DateUtils;
+import com.tianhu.common.core.utils.IdUtils;
+import com.tianhu.common.redis.common.RedisUtils;
+import com.tianhu.system.api.RemoteConfigService;
+import com.tianhu.system.api.RemoteSystemService;
+import com.tianhu.system.api.domain.DictData;
+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 java.text.SimpleDateFormat;
+import java.util.*;
+
+@Configuration      //1.主要用于标记配置类，兼备Component的效果。
+@EnableScheduling   // 2.开启定时任务
+public class FinanceTimedTaskController {
+    private static final Logger log = LoggerFactory.getLogger(FinanceTimedTaskController.class);
+
+    @Autowired
+    private IZcFinanceInfService iZcFinanceInfService;
+    @Autowired
+    private IZcFinanceProductService iZcFinanceProductService;
+    @Autowired
+    private FinanceTimedTaskService financeTimedTaskService;
+    @Autowired
+    private RemoteSystemService remoteSystemService;
+    @Autowired
+    private ISysNoticeService iSysNoticeService;
+    @Autowired
+    private RemoteConfigService configService;
+
+    /**
+     * 融信消息提醒定时跑批
+     */
+    //每十分钟
+//    @Scheduled(cron = "0 */10 * * * ?")
+    //每一分钟(测试用)
+//    @Scheduled(cron = "0/10 * * * * ?")
+    private void financeInformation() throws Exception{
+        LambdaQueryWrapper<ZcFinanceProduct> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(ZcFinanceProduct::getZfpStatus,"01");
+        List<ZcFinanceProduct> productList = iZcFinanceProductService.findZcFinanceProducts(queryWrapper);
+        //融信融信到期前30天提醒
+        for (int i = 0; i < productList.size(); i++) {
+            //最短账期
+            String shortestPeriod= productList.get(i).getZfpShortestPeriod();
+            Map map = new HashMap();
+            //据当前时间还有30天的日期
+            String day = DateUtils.getFetureDate(30+Integer.parseInt(shortestPeriod));
+            map.put("day",day);
+            //融信信息
+            List<Map> list = financeTimedTaskService.selectFinanceInfList(map);
+            if(list.size()>0){
+                for(Map res :list){
+                    //主键
+                    String zfiId = CommonUtil.objToString(res.get("zfiId"));
+                    //经办人Id
+                    String user = CommonUtil.objToString(res.get("sucrUserId"));
+                    //企业
+                    String companyId = CommonUtil.objToString(res.get("sucrCompanyId"));
+                    //融信编号
+                    String zfiNumber = CommonUtil.objToString(res.get("zfiNumber"));
+                    //签发有效期
+                    String zfiEffectiveDate = CommonUtil.objToString(res.get("zfiEffectiveDate"));
+                    //申请金额
+                    String zfiAmount = CommonUtil.objToString(res.get("zfiAmount"));
+                    //金额大写
+                    String zfiAmountBig = AmtUtil.convert(AmtUtil.moneyFormat(zfiAmount));
+
+//                    List userList = new ArrayList();
+//                    userList.add(user);
+                    //到期前30天发送消息
+                    //标题
+                    String title = "【融信到期】您持有的一笔融信【"+zfiAmount+"】（大写："+zfiAmountBig+"）的融信【"+zfiNumber+"】将于【"+zfiEffectiveDate+"】失效，请尽快去融资";
+                    remoteSystemService.sendNotice(companyId, zfiId,title,"01","05","","0",user,"");
+                }
+            }
+        }
+        //融信融信到期前7天提醒
+        for (int i = 0; i < productList.size(); i++) {
+            //最短账期
+            String shortestPeriod= productList.get(i).getZfpShortestPeriod();
+            Map map = new HashMap();
+            //据当前时间还有30天的日期
+            String day = DateUtils.getFetureDate(7+Integer.parseInt(shortestPeriod));
+            map.put("day",day);
+            //融信信息
+            List<Map> list = financeTimedTaskService.selectFinanceInfList(map);
+            if(list.size()>0){
+                for(Map res :list){
+                    //主键
+                    String zfiId = CommonUtil.objToString(res.get("zfiId"));
+                    //经办人Id
+                    String user = CommonUtil.objToString(res.get("sucrUserId"));
+                    //企业
+                    String companyId = CommonUtil.objToString(res.get("sucrCompanyId"));
+                    //融信编号
+                    String zfiNumber = CommonUtil.objToString(res.get("zfiNumber"));
+                    //签发有效期
+                    String zfiEffectiveDate = CommonUtil.objToString(res.get("zfiEffectiveDate"));
+                    //申请金额
+                    String zfiAmount = CommonUtil.objToString(res.get("zfiAmount"));
+                    //金额大写
+                    String zfiAmountBig = AmtUtil.convert(AmtUtil.moneyFormat(zfiAmount));
+                    //核心企业名称
+                    String scyName = CommonUtil.objToString(res.get("scyName"));
+//                    List userList = new ArrayList();
+//                    userList.add(user);
+                    //到期前7天生成待办
+                    //标题
+                    String title = "【融资待办】【"+scyName+"】签发的融信【"+zfiNumber+"】将于【"+zfiEffectiveDate+"】失效，" +
+                            "融信金额【"+zfiAmount+"】（大写："+zfiAmountBig+"），请尽快融资";
+                    remoteSystemService.sendNotice(companyId, zfiId,title,"00","","05","0",user,"");
+                }
+            }
+        }
+        //融信融信到期前5天提醒
+        for (int i = 0; i < productList.size(); i++) {
+            //最短账期
+            String shortestPeriod= productList.get(i).getZfpShortestPeriod();
+            Map map = new HashMap();
+            //据当前时间还有30天的日期
+            String day = DateUtils.getFetureDate(5+Integer.parseInt(shortestPeriod));
+            map.put("day",day);
+            //融信信息
+            List<Map> list = financeTimedTaskService.selectFinanceInfList(map);
+            if(list.size()>0){
+                for(Map res :list){
+                    //主键
+                    String zfiId = CommonUtil.objToString(res.get("zfiId"));
+                    //经办人Id
+                    String user = CommonUtil.objToString(res.get("sucrUserId"));
+                    //手机号
+                    String phone = CommonUtil.objToString(res.get("phone"));
+                    //企业
+                    String companyId = CommonUtil.objToString(res.get("sucrCompanyId"));
+                    //融信编号
+                    String zfiNumber = CommonUtil.objToString(res.get("zfiNumber"));
+                    //签发有效期
+                    String zfiEffectiveDate = CommonUtil.objToString(res.get("zfiEffectiveDate"));
+                    //申请金额
+                    String zfiAmount = CommonUtil.objToString(res.get("zfiAmount"));
+                    //金额大写
+                    String zfiAmountBig = AmtUtil.convert(AmtUtil.moneyFormat(zfiAmount));
+//                    List userList = new ArrayList();
+//                    userList.add(user);
+                    //到期前5天发送短信
+                    //标题
+                    String title = "【招采云链】您持有的一笔【"+zfiAmount+"】（大写："+zfiAmountBig+"）"
+                            + "的融信【"+zfiNumber+"】将于【"+zfiEffectiveDate+"】失效，请尽快处理；";
+//                    remoteSystemService.sendNotice(companyId, zfiId,title,"","","","1",user,"");
+                    //手机模板
+                    String mould = RedisUtils.getDictValue("aliyun_message_code","zhuce");
+                    //参数
+                    Map map1 = new HashMap();
+                    map1.put("融信编号",zfiNumber);
+                    map1.put("融信金额",zfiAmount);
+                    map1.put("大写",zfiAmountBig);
+                    map1.put("失效期",zfiEffectiveDate);
+//                    JSONObject jsonObject = new JSONObject(map1);
+                    String json = JSONObject.toJSONString(map1);
+                    remoteSystemService.sendAliMessage(phone,mould,json,"");
+                }
+            }
+        }
+        //融信融信到期前3天提醒
+        for (int i = 0; i < productList.size(); i++) {
+            //最短账期
+            String shortestPeriod= productList.get(i).getZfpShortestPeriod();
+            Map map = new HashMap();
+            //据当前时间还有30天的日期
+            String day = DateUtils.getFetureDate(3+Integer.parseInt(shortestPeriod));
+            map.put("day",day);
+            //融信信息
+            List<Map> list = financeTimedTaskService.selectFinanceInfList(map);
+            if(list.size()>0){
+                for(Map res :list){
+                    //主键
+                    String zfiId = CommonUtil.objToString(res.get("zfiId"));
+                    //经办人Id
+                    String user = CommonUtil.objToString(res.get("sucrUserId"));
+                    //企业
+                    String companyId = CommonUtil.objToString(res.get("sucrCompanyId"));
+                    //融信编号
+                    String zfiNumber = CommonUtil.objToString(res.get("zfiNumber"));
+                    //签发有效期
+                    String zfiEffectiveDate = CommonUtil.objToString(res.get("zfiEffectiveDate"));
+                    //申请金额
+                    String zfiAmount = CommonUtil.objToString(res.get("zfiAmount"));
+                    //金额大写
+                    String zfiAmountBig = AmtUtil.convert(AmtUtil.moneyFormat(zfiAmount));
+                    //供应商
+                    String supplierName = CommonUtil.objToString(res.get("supplierName"));
+//                    List userList = new ArrayList();
+//                    userList.add(user);
+                    //到期前3天生成平台内部待办
+                    //标题
+                    String title = "【融资待办】【"+supplierName+"】融信【"+zfiNumber+"】融信金额【"+zfiAmount+"】（大写："+zfiAmountBig+"）" +
+                            "将于【"+zfiEffectiveDate+"】失效，请相关人员跟进！";
+                    remoteSystemService.sendNotice(companyId, zfiId,title,"00","","07","0",user,"");
+                }
+            }
+        }
+
+
+    }
+
+    /**
+     * 融信失效定时跑批
+     */
+    //每十分钟
+//    @Scheduled(cron = "0 */10 * * * ?")
+    //每一分钟(测试用)
+//    @Scheduled(cron = "0/10 * * * * ?")
+    private void financeStatus() throws Exception{
+        //融信到期 => 融信失效,待办删除
+        Map map = new HashMap();
+        List<Map> list = financeTimedTaskService.selectFinanceInfDetail(map);
+        for (int i = 0; i < list.size(); i++) {
+            //融信id
+            String zfiId = CommonUtil.objToString(list.get(i).get("zfiId"));
+            //签发有效期
+            String zfiEffectiveDate = CommonUtil.objToString(list.get(i).get("zfiEffectiveDate"));
+            //最短账期
+            int zfpShortestPeriod = Integer.parseInt(list.get(i).get("zfpShortestPeriod")+"");
+            //String 转 Date
+            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");//注意月份是MM
+            Date date = simpleDateFormat.parse(zfiEffectiveDate);
+            //签发有效期 - 最短账期(天数) = 失效日期
+            GregorianCalendar cal = new GregorianCalendar();
+            cal.setTime(date);
+            cal.add(Calendar.DATE, -zfpShortestPeriod);
+            //失效日期
+            String expirationDate=DateUtils.parseDateToStr("yyyy-MM-dd",cal.getTime());
+            //获取当前时间
+            String currentDate = DateUtils.getDate();
+            //失效日期 = 获取当前时间 修改融信状态,删除待办
+            if (expirationDate.equals(currentDate)){
+                //修改融信表
+                ZcFinanceInf zcFinanceInf = new ZcFinanceInf();
+                //主键
+                zcFinanceInf.setZfiId(zfiId);
+                //状态(00:待确权 01:待签收 02:已生效 03:已失效 04:融资中 05:已融资 06:平台退回 07:已失效(到期失效) 99:删除)
+                zcFinanceInf.setZfiStatus("07");
+                //修改待办表
+                LambdaQueryWrapper<SysNotice> queryWrapper = new LambdaQueryWrapper<>();
+                queryWrapper.eq(SysNotice::getTableId,zfiId);
+                SysNotice sysNotice = new SysNotice();
+                sysNotice.setStatus("2");
+                iSysNoticeService.update(sysNotice,queryWrapper);
+            }
+
+        }
+    }
+
+
+}
+

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

@@ -0,0 +1,28 @@
+package com.huyi.task.taskMan.mapper;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 还款Mapper接口
+ * 
+ * @author ch
+ * @date 2021-09-06
+ */
+public interface FinanceTimedTaskMapper
+{
+
+    /**
+     * 查询融信列表符合消息提醒数据
+     * @param map
+     * @return
+     */
+    public List<Map> selectFinanceInfList(Map map);
+
+    /**
+     * 查询融信列表是否已失效数据
+     * @param map
+     * @return
+     */
+    public List<Map> selectFinanceInfDetail(Map map);
+}

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

@@ -0,0 +1,30 @@
+package com.huyi.task.taskMan.service;
+
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 还款Service接口
+ * 
+ * @author ch
+ * @date 2021-09-06
+ */
+public interface FinanceTimedTaskService
+{
+    /**
+     * 查询融信列表符合消息提醒数据
+     * @param map
+     * @return
+     */
+    public List<Map> selectFinanceInfList(Map map);
+
+    /**
+     * 查询融信列表是否已失效数据
+     * @param map
+     * @return
+     */
+    public List<Map> selectFinanceInfDetail(Map map);
+
+
+}

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

@@ -0,0 +1,34 @@
+package com.huyi.task.taskMan.service.impl;
+
+import com.huyi.task.taskMan.mapper.FinanceTimedTaskMapper;
+import com.huyi.task.taskMan.mapper.OwnTaskManMapper;
+import com.huyi.task.taskMan.service.FinanceTimedTaskService;
+import com.huyi.task.taskMan.service.IOwnTaskManService;
+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 FinanceTimedTaskServiceImpl implements FinanceTimedTaskService
+{
+    @Autowired
+    private FinanceTimedTaskMapper financeTimedTaskMapper;
+
+    @Override
+    public List<Map> selectFinanceInfList(Map map){
+        return financeTimedTaskMapper.selectFinanceInfList(map);
+    }
+
+    @Override
+    public List<Map> selectFinanceInfDetail(Map map){return financeTimedTaskMapper.selectFinanceInfDetail(map);}
+
+
+}

taskMan/src/main/resources/mapper/base/SysNoticeMapper.xml

@@ -0,0 +1,23 @@
+<?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.base.mapper.SysNoticeMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.huyi.task.base.entity.SysNotice">
+        <id column="notice_id" property="noticeId" />
+        <result column="company_id" property="companyId" />
+        <result column="table_id" property="tableId" />
+        <result column="notice_title" property="noticeTitle" />
+        <result column="type" property="type" />
+        <result column="notice_type" property="noticeType" />
+        <result column="work_type" property="workType" />
+        <result column="status" property="status" />
+        <result column="message_send" property="messageSend" />
+        <result column="message_id" property="messageId" />
+        <result column="message_code" property="messageCode" />
+        <result column="message_status" property="messageStatus" />
+        <result column="remark" property="remark" />
+        <result column="create_time" property="createTime" />
+    </resultMap>
+
+</mapper>

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

@@ -0,0 +1,45 @@
+<?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.OwnTaskManMapper">
+
+    <select id="selectFinanceInfList" parameterType="map" resultType="map">
+        SELECT
+          i.zfi_id                'zfiId',
+          i.zfi_number            'zfiNumber',
+          i.zfi_amount            'zfiAmount',
+          i.zfi_effective_date    'zfiEffectiveDate',
+          p.zfp_shortest_period   'zfpShortestPeriod',
+          u.sucr_user_id          'sucrUserId',
+          u.sucr_company_id       'sucrCompanyId',
+          s.scy_name              'scyName',
+          c.scy_name              'supplierName',
+          r.user_name             'phone'
+        FROM
+          zc_finance_inf i
+          LEFT JOIN zc_finance_product p
+            ON p.zfp_id = i.zfi_product_id
+          LEFT JOIN sys_company s
+            ON s.scy_id = i.zfi_core_id
+          LEFT JOIN sys_company c
+            ON c.scy_id = i.zfi_supplier_id
+          LEFT JOIN sys_user_company_rel u
+            ON u.sucr_company_id = i.zfi_supplier_id
+            AND sucr_handler = '1'
+          LEFT JOIN sys_user r
+            ON r.user_id = u.sucr_user_id
+        WHERE zfi_status = '02'
+              and zfi_effective_date = #{day}
+    </select>
+    <select id="selectFinanceInfDetail" parameterType="map" resultType="map">
+        SELECT
+          zfi_id                'zfiId',
+          zfi_number            'zfiNumber',
+          zfi_effective_date    'zfiEffectiveDate',
+          zfp_shortest_period   'zfpShortestPeriod'
+        FROM
+          zc_finance_inf
+          LEFT JOIN zc_finance_product
+            ON zfp_id = zfi_product_id
+        WHERE zfi_status = '02'
+    </select>
+</mapper>