Merge branch 'develop' into feature-licancan

yifu-common/yifu-common-core/src/main/java/com/yifu.cloud.plus.v1/yifu/common/core/constant/CommonConstants.java

@@ -275,6 +275,8 @@ public interface CommonConstants {
 
 	String DATA_CAN_NOT_EMPTY = "数据不可为空";
 
+	String NO_DATA_TO_HANDLE = "无数据可操作！";
+
 	String PLEASE_LOG_IN = "请登录！";
 
 	String SEX_MAN = "1";

yifu-common/yifu-common-core/src/main/java/com/yifu/cloud/plus/v1/yifu/common/core/redis/RedisDistributedLock.java

+package com.yifu.cloud.plus.v1.yifu.common.core.redis;
+
+/**
+ * @program: master
+ * @description: 分布式锁
+ * @author: pwang
+ * @create: 2020-06-01 15:51
+ **/
+
+import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.SpringContextHolder;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.script.DefaultRedisScript;
+import org.springframework.scripting.support.ResourceScriptSource;
+
+import java.util.Collections;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * redis分布式式锁
+ *
+ * @Author pwang
+ * @Date 2020-06-02 14:53
+ * @return
+ **/
+@Slf4j
+public class RedisDistributedLock {
+
+    private static final StringRedisTemplate redisTemplate = SpringContextHolder.getBean(StringRedisTemplate.class);
+    private static final DefaultRedisScript<Long> LOCK_SCRIPT;
+    private static final DefaultRedisScript<Object> UNLOCK_SCRIPT;
+    private static String prefix = "RedisDistributedLock_";
+
+    static {
+        // 加载释放锁的脚本
+        LOCK_SCRIPT = new DefaultRedisScript<>();
+        LOCK_SCRIPT.setScriptSource(new ResourceScriptSource(new ClassPathResource("lock.lua")));
+        LOCK_SCRIPT.setResultType(Long.class);
+
+        // 加载释放锁的脚本
+        UNLOCK_SCRIPT = new DefaultRedisScript<>();
+        UNLOCK_SCRIPT.setScriptSource(new ResourceScriptSource(new ClassPathResource("unlock.lua")));
+    }
+
+    /**
+     * 获取锁
+     *
+     * @param lockName    锁名称
+     * @param releaseTime 超时时间(单位:秒)
+     * @return key 解锁标识
+     */
+    public static String getLock(String lockName, String releaseTime) {
+        // 存入的线程信息的前缀，防止与其它JVM中线程信息冲突
+        String key = UUID.randomUUID().toString();
+        // 执行脚本
+        Long result = redisTemplate.execute(
+                LOCK_SCRIPT,
+                Collections.singletonList(prefix.concat(lockName)),
+                key + Thread.currentThread().getId(), releaseTime);
+
+        // 判断结果
+        if (result != null && result.intValue() == 1) {
+            return key;
+        } else {
+            return null;
+        }
+    }
+    /**
+     * 默认三秒过期
+     * @Author pwang
+     * @Date 2021-07-30 18:00
+     * @param lockName
+     * @return
+     **/
+    public static String getLock(String lockName) {
+       return getLock(lockName,"3");
+    }
+
+    /**
+     * 释放锁
+     *
+     * @param lockName 锁名称
+     * @param key      解锁标识
+     */
+    public static void unlock(String lockName, String key) {
+        // 执行脚本
+        redisTemplate.execute(
+                UNLOCK_SCRIPT,
+                Collections.singletonList(prefix.concat(lockName)),
+                key + Thread.currentThread().getId(), null);
+    }
+
+
+    /**
+     * 锁在给定的等待时间内空闲，则获取锁成功 返回true， 否则返回false，作为阻塞式锁使用
+     *
+     * @param key                            锁键
+     * @param releaseTime                    超时时间(单位:秒)
+     * @param timeout                        尝试获取锁时长，建议传递500,结合实践单位，则可表示500毫秒
+     * @param unit，建议传递TimeUnit.MILLISECONDS
+     * @return requestId
+     * @throws InterruptedException
+     */
+    public static String tryLock(String key, String releaseTime, long timeout, TimeUnit unit) throws InterruptedException {
+        //纳秒
+        long begin = System.nanoTime();
+        if (null == unit) {
+            unit = TimeUnit.MILLISECONDS;
+        }
+        do {
+            //LOGGER.debug("{}尝试获得{}的锁.", value, key);
+            String result = getLock(key, releaseTime);
+            if (Common.isNotNull(result)) {
+                /*  log.debug(value + "-成功获取{}的锁,设置锁过期时间为{}秒 ", key, timeout);*/
+                return result;
+            } else {
+                // 存在锁 ，但可能获取不到，原因是获取的一刹那间
+            }
+            if (timeout == 0) {
+                break;
+            }
+            //在其睡眠的期间，锁可能被解，也可能又被他人占用，但会尝试继续获取锁直到指定的时间
+            Thread.sleep(10);
+
+
+        } while ((System.nanoTime() - begin) < unit.toNanos(timeout));
+        //因超时没有获得锁
+        return null;
+    }
+    /**
+     * 默认保存时间3秒，锁获取时间3000毫秒
+     * @Author pwang
+     * @Date 2020-06-02 15:00
+     * @param key
+     * @return
+     **/
+    public static String tryLock(String key) throws InterruptedException {
+        return tryLock(key, "3", 3000, null);
+    }
+
+
+    /**
+     * @param key
+     * @param time
+     * @Author: wangan
+     * @Date: 2020/9/30
+     * @Description:  审批时间较长。需要设置超过3秒时间
+     * @return: java.lang.String
+     **/
+    public static String tryLockAndTime(String key,String time) throws InterruptedException {
+        return tryLock(key, time, 3000, null);
+    }
+}
+

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/concurrent/threadpool/YFSocialImportThreadPoolExecutor.java

+package com.yifu.cloud.plus.v1.yifu.social.concurrent.threadpool;
+
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.RejectedExecutionException;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @description: 社保导入线程池初始化配置
+ * @author: wangweiguo
+ * @date: 2021/6/30
+ */
+
+public class YFSocialImportThreadPoolExecutor extends ThreadPoolExecutor {
+
+    private static final int CORE_POOL_SIZE = 8;
+    private static final int MAX_POOL_SIZE = 12;
+    private static final long KEEP_ALIVE_TIME = 15;
+    private static final int CAPACITY = 1024;
+
+    /**
+     * @description: 社保导入线程池构造方法
+     * @param yfThreadFactory
+     * @return:
+     * @author: wangweiguo
+     * @date: 2021/8/4
+     */
+    public YFSocialImportThreadPoolExecutor(YFThreadFactory yfThreadFactory) {
+        super(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS, new LinkedBlockingQueue<>(CAPACITY), yfThreadFactory, (runnable, executor) -> {
+            try {
+                final Thread t = new Thread(runnable, "Temporary task executor");
+                t.start();
+            } catch (Throwable e) {
+                throw new RejectedExecutionException(
+                        "Failed to start a new thread", e);
+            }
+        });
+    }
+
+    /**
+     * @description: 获取剩余可以添加的任务数量
+     * @return: int
+     * @author: wangweiguo
+     * @date: 2021/8/4
+     */
+    public int getResidualCapacity() {
+        return CAPACITY - this.getQueue().size() + this.getPoolSize() - this.getActiveCount();
+    }
+
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/concurrent/threadpool/YFThreadFactory.java

+package com.yifu.cloud.plus.v1.yifu.social.concurrent.threadpool;
+
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * @description:
+ * @author: wangweiguo
+ * @date: 2021/6/30
+ */
+public class YFThreadFactory implements ThreadFactory {
+    private final AtomicInteger poolNumber = new AtomicInteger(1);
+
+    private final ThreadGroup threadGroup;
+
+    private final AtomicInteger threadNumber = new AtomicInteger(1);
+
+    public  final String namePrefix;
+
+    YFThreadFactory(String name){
+        SecurityManager s = System.getSecurityManager();
+        threadGroup = (s != null) ? s.getThreadGroup() :
+                Thread.currentThread().getThreadGroup();
+        if (null==name || "".equals(name.trim())){
+            name = "pool";
+        }
+        namePrefix = name +"-"+
+                poolNumber.getAndIncrement() +
+                "-thread-";
+    }
+
+    @Override
+    public Thread newThread(Runnable r) {
+        Thread t = new Thread(threadGroup, r,
+                namePrefix + threadNumber.getAndIncrement(),
+                0);
+        if (t.isDaemon())
+            t.setDaemon(false);
+        if (t.getPriority() != Thread.NORM_PRIORITY)
+            t.setPriority(Thread.NORM_PRIORITY);
+        return t;
+    }
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/concurrent/threadpool/YFThreadPoolConfig.java

+package com.yifu.cloud.plus.v1.yifu.social.concurrent.threadpool;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @description: 线程池配置添加到spring管理，并初始化线程池名称
+ * @author: wangweiguo
+ * @date: 2021/6/30
+ */
+
+@Configuration
+public class YFThreadPoolConfig {
+
+
+    @Bean(name = "yfSocialImportThreadPoolExecutor")
+    YFSocialImportThreadPoolExecutor yfSocialImportThreadPoolExecutor(@Qualifier("yfThreadFactory") YFThreadFactory yfThreadFactory) {
+        return new YFSocialImportThreadPoolExecutor(yfThreadFactory);
+    }
+
+    @Bean(name = "yfThreadFactory")
+    YFThreadFactory yfThreadFactory() {
+        return new YFThreadFactory("social_import");
+    }
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/entity/TPaymentInfo.java

@@ -372,4 +372,223 @@ public class TPaymentInfo extends BaseEntity {
     @ExcelProperty("财务账单ID")
     private String financeBillId;
 
+	/**
+	 * 单位社保补缴利息
+	 */
+	@ExcelAttribute(name = "单位社保补缴利息"  )
+	@ExcelProperty("单位社保补缴利息")
+	private BigDecimal companyAccrual;
+	/**
+	 * 个人社保补缴利息
+	 */
+	@ExcelAttribute(name = "个人社保补缴利息"  )
+	@ExcelProperty("个人社保补缴利息")
+	private BigDecimal personalAccrual;
+	/**
+	 * 单位养老基数
+	 */
+	@ExcelAttribute(name = "单位养老基数"  )
+	@ExcelProperty("单位养老基数")
+	private BigDecimal unitPensionSet;
+	/**
+	 * 单位医疗基数
+	 */
+	@ExcelAttribute(name = "单位医疗基数"  )
+	@ExcelProperty("单位医疗基数")
+	private BigDecimal unitMedicalSet;
+	/**
+	 * 单位失业基数
+	 */
+	@ExcelAttribute(name = "单位失业基数"  )
+	@ExcelProperty("单位失业基数")
+	private BigDecimal unitUnemploymentSet;
+	/**
+	 * 单位工伤基数
+	 */
+	@ExcelAttribute(name = "单位工伤基数"  )
+	@ExcelProperty("单位工伤基数")
+	private BigDecimal unitInjurySet;
+	/**
+	 * 单位生育基数
+	 */
+	@ExcelAttribute(name = "单位生育基数"  )
+	@ExcelProperty("单位生育基数")
+	private BigDecimal unitBirthSet;
+	/**
+	 * 个人养老基数
+	 */
+	@ExcelAttribute(name = "个人养老基数"  )
+	@ExcelProperty("个人养老基数")
+	private BigDecimal personalPensionSet;
+	/**
+	 * 个人医疗基数
+	 */
+	@ExcelAttribute(name = "个人医疗基数"  )
+	@ExcelProperty("个人医疗基数")
+	private BigDecimal personalMedicalSet;
+	/**
+	 * 个人失业基数
+	 */
+	@ExcelAttribute(name = "个人失业基数"  )
+	@ExcelProperty("个人失业基数")
+	private BigDecimal personalUnemploymentSet;
+	/**
+	 * 单位养老比例
+	 */
+	@ExcelAttribute(name = "单位养老比例"  )
+	@ExcelProperty("单位养老比例")
+	private BigDecimal unitPensionPer;
+	/**
+	 * 单位医疗比例
+	 */
+	@ExcelAttribute(name = "单位医疗比例"  )
+	@ExcelProperty("单位医疗比例")
+	private BigDecimal unitMedicalPer;
+	/**
+	 * 单位失业比例
+	 */
+	@ExcelAttribute(name = "单位失业比例"  )
+	@ExcelProperty("单位失业比例")
+	private BigDecimal unitUnemploymentPer;
+	/**
+	 * 单位工伤比例
+	 */
+	@ExcelAttribute(name = "单位工伤比例"  )
+	@ExcelProperty("单位工伤比例")
+	private BigDecimal unitInjuryPer;
+	/**
+	 * 单位生育比例
+	 */
+	@ExcelAttribute(name = "单位生育比例"  )
+	@ExcelProperty("单位生育比例")
+	private BigDecimal unitBirthPer;
+	/**
+	 * 个人养老比例
+	 */
+	@ExcelAttribute(name = "个人养老比例"  )
+	@ExcelProperty("个人养老比例")
+	private BigDecimal personalPensionPer;
+	/**
+	 * 个人医疗比例
+	 */
+	@ExcelAttribute(name = "个人医疗比例"  )
+	@ExcelProperty("个人医疗比例")
+	private BigDecimal personalMedicalPer;
+	/**
+	 * 个人失业比例
+	 */
+	@ExcelAttribute(name = "个人失业比例"  )
+	@ExcelProperty("个人失业比例")
+	private BigDecimal personalUnemploymentPer;
+	/**
+	 * 单位大病比例
+	 */
+	@ExcelAttribute(name = "单位大病比例"  )
+	@ExcelProperty("单位大病比例")
+	private BigDecimal unitBigailmentPer;
+	/**
+	 * 个人大病比例
+	 */
+	@ExcelAttribute(name = "个人大病比例"  )
+	@ExcelProperty("个人大病比例")
+	private BigDecimal personalBigailmentPer;
+	/**
+	 * 单位养老金额
+	 */
+	@ExcelAttribute(name = "单位养老金额"  )
+	@ExcelProperty("单位养老金额")
+	private BigDecimal unitPensionMoney;
+	/**
+	 * 单位医疗金额
+	 */
+	@ExcelAttribute(name = "单位医疗金额"  )
+	@ExcelProperty("单位医疗金额")
+	private BigDecimal unitMedicalMoney;
+	/**
+	 * 单位失业金额
+	 */
+	@ExcelAttribute(name = "单位失业金额"  )
+	@ExcelProperty("单位失业金额")
+	private BigDecimal unitUnemploymentMoney;
+	/**
+	 * 单位工伤金额
+	 */
+	@ExcelAttribute(name = "单位工伤金额"  )
+	@ExcelProperty("单位工伤金额")
+	private BigDecimal unitInjuryMoney;
+	/**
+	 * 单位生育金额
+	 */
+	@ExcelAttribute(name = "单位生育金额"  )
+	@ExcelProperty("单位生育金额")
+	private BigDecimal unitBirthMoney;
+	/**
+	 * 单位大病金额
+	 */
+	@ExcelAttribute(name = "单位大病金额"  )
+	@ExcelProperty("单位大病金额")
+	private BigDecimal unitBigmailmentMoney;
+	/**
+	 * 个人养老金额
+	 */
+	@ExcelAttribute(name = "个人养老金额"  )
+	@ExcelProperty("个人养老金额")
+	private BigDecimal personalPensionMoney;
+	/**
+	 * 个人医疗金额
+	 */
+	@ExcelAttribute(name = "个人医疗金额"  )
+	@ExcelProperty("个人医疗金额")
+	private BigDecimal personalMedicalMoney;
+	/**
+	 * 个人失业金额
+	 */
+	@ExcelAttribute(name = "个人失业金额"  )
+	@ExcelProperty("个人失业金额")
+	private BigDecimal personalUnemploymentMoney;
+	/**
+	 * 个人大病金额
+	 */
+	@ExcelAttribute(name = "个人大病金额"  )
+	@ExcelProperty("个人大病金额")
+	private BigDecimal personalBigmailmentMoney;
+	/**
+	 * 公积金编号
+	 */
+	@ExcelAttribute(name = "公积金编号"  , maxLength = 50 )
+	@Size(max = 50, message = "公积金编号不可超过50位")
+	@ExcelProperty("公积金编号")
+	private String providentNo;
+	/**
+	 * 单位公积金基数
+	 */
+	@ExcelAttribute(name = "单位公积金基数"  )
+	@ExcelProperty("单位公积金基数")
+	private BigDecimal unitProvidentSet;
+	/**
+	 * 单边公积金比例
+	 */
+	@ExcelAttribute(name = "单边公积金比例"  )
+	@ExcelProperty("单边公积金比例")
+	private BigDecimal providentPercent;
+	/**
+	 * 单位公积金费用
+	 */
+	@ExcelAttribute(name = "单位公积金费用"  )
+	@ExcelProperty("单位公积金费用")
+	private BigDecimal unitProvidentSum;
+	/**
+	 * 个人公积金基数
+	 */
+	@ExcelAttribute(name = "个人公积金基数"  )
+	@ExcelProperty("个人公积金基数")
+	private BigDecimal personalProidentSet;
+	/**
+	 * 个人公积金费用
+	 */
+	@ExcelAttribute(name = "个人公积金费用"  )
+	@ExcelProperty("个人公积金费用")
+	private BigDecimal personalProvidentSum;
+
+
 }

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/entity/TPaymentInfoImportLog.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.yifu.cloud.plus.v1.yifu.social.entity;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.yifu.cloud.plus.v1.yifu.common.mybatis.base.BaseEntity;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
+import lombok.NoArgsConstructor;
+import org.hibernate.validator.constraints.Length;
+
+/**
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("t_payment_info_import_log")
+@EqualsAndHashCode(callSuper = true)
+@Schema(description = "")
+public class TPaymentInfoImportLog extends BaseEntity {
+
+	/**
+	 * 主键
+	 */
+	@TableId(type = IdType.ASSIGN_ID)
+	@ExcelProperty("主键")
+	private Integer id;
+	/**
+	 * 姓名
+	 */
+	@ExcelAttribute(name = "姓名", maxLength = 50)
+	@Length(max = 50, message = "姓名不能超过50个字符")
+	@ExcelProperty("姓名")
+	private String empName;
+	/**
+	 * 身份证号
+	 */
+	@ExcelAttribute(name = "身份证号", maxLength = 32)
+	@Length(max = 32, message = "身份证号不能超过32个字符")
+	@ExcelProperty("身份证号")
+	private String idCard;
+	/**
+	 * 错误信息
+	 */
+	@ExcelAttribute(name = "错误信息", maxLength = 500)
+	@Length(max = 500, message = "错误信息不能超过500个字符")
+	@ExcelProperty("错误信息")
+	private String errMsg;
+	/**
+	 * 问题行数
+	 */
+	@ExcelAttribute(name = "问题行数")
+	@ExcelProperty("问题行数")
+	private Integer line;
+	/**
+	 * 导入标识key
+	 */
+	@ExcelAttribute(name = "导入标识key", maxLength = 64)
+	@Length(max = 64, message = "导入标识key不能超过64个字符")
+	@ExcelProperty("导入标识key")
+	private String randomKey;
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentHeFeiVo.java

+package com.yifu.cloud.plus.v1.yifu.social.vo;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
+import com.yifu.cloud.plus.v1.yifu.common.core.vo.RowIndex;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import org.hibernate.validator.constraints.Length;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * @ClassName TPaymentHeFeiVo
+ * @Description 合肥三险导入  养老 工伤 失业 生育
+ * @author huyc
+ * @date 2022-07-26 17:01:22
+ */
+@Data
+public class TPaymentHeFeiVo extends RowIndex implements Serializable {
+    /**
+     * 员工姓名
+     */
+    @Length(max = 20, message = "员工姓名不能超过20个字符")
+    @ExcelAttribute(name = "员工姓名", maxLength = 20)
+	@Schema(description = "员工姓名")
+	@ExcelProperty("员工姓名")
+    private String empName;
+    /**
+     * 员工编码
+     */
+    @Length(max = 32, message = "员工编码不能超过32个字符")
+    @ExcelAttribute(name = "员工编码",  maxLength = 32)
+	@Schema(description = "员工编码")
+	@ExcelProperty("员工编码")
+    private String empNo;
+    /**
+     * 员工ID
+     */
+    @Length(max = 32, message = "员工ID不能超过32个字符")
+    @ExcelAttribute(name = "员工ID", maxLength = 32)
+	@Schema(description = "员工ID")
+	@ExcelProperty("员工ID")
+    private String empId;
+    /**
+     * 员工身份证
+     */
+    @Length(max = 100, message = "不能超过100个字符")
+    @ExcelAttribute(name = "身份证号", isNotEmpty = true, maxLength = 100,errorInfo = "身份证字段不可为空！")
+	@Schema(description = "身份证号")
+	@ExcelProperty("身份证号")
+    private String empIdcard;
+    /**
+     * 社保编号
+     */
+    @Length(max = 20, message = "社保编号不能超过20个字符")
+    @ExcelAttribute(name = "社保编号", maxLength = 20)
+	@Schema(description = "社保编号")
+	@ExcelProperty("社保编号")
+    private String socialSecurityNo;
+    /**
+     * 社保缴纳地
+     */
+    @Length(max = 50, message = "社保缴纳地不能超过50个字符")
+    @ExcelAttribute(name = "社保缴纳地", isNotEmpty = true, errorInfo = "社保缴纳地不可为空", maxLength = 50)
+	@Schema(description = "社保缴纳地")
+	@ExcelProperty("社保缴纳地")
+    private String socialPayAddr;
+
+    /**
+     * 社保缴纳地-省
+     */
+    @Length(max = 32, message = "不能超过32个字符")
+    @ExcelAttribute(name = "社保缴纳地-省",  maxLength = 32, isDataId = true, isArea = true, parentField = "")
+	@Schema(description = "社保缴纳地-省")
+	@ExcelProperty("社保缴纳地-省")
+    private Integer socialProvince;
+    /**
+     * 社保缴纳地-市
+     */
+    @Length(max = 32, message = "不能超过32个字符")
+    @ExcelAttribute(name = "社保缴纳地-市",  maxLength = 32, isDataId = true, isArea = true, parentField = "socialProvince")
+	@Schema(description = "社保缴纳地-市")
+	@ExcelProperty("社保缴纳地-市")
+    private Integer socialCity;
+    /**
+     * 社保缴纳地-县
+     */
+    @Length(max = 32, message = "不能超过32个字符")
+    @ExcelAttribute(name = "社保缴纳地-县",  maxLength = 32, isDataId = true, isArea = true, parentField = "socialCity")
+	@Schema(description = "社保缴纳地-县")
+	@ExcelProperty("社保缴纳地-县")
+    private Integer socialTown;
+    /**
+     * 社保缴纳月份empNo
+     */
+    @Length(max = 6, message = "社保缴纳月份不能超过6个字符")
+    @ExcelAttribute(name = "社保缴纳月份", isNotEmpty = true, errorInfo = "社保缴纳月份不可为空", maxLength = 6)
+	@Schema(description = "社保缴纳月份")
+	@ExcelProperty("社保缴纳月份")
+    private String socialPayMonth;
+    /**
+     * 社保生成月份
+     */
+    @Length(max = 6, message = "社保生成月份不能超过6个字符")
+    @ExcelAttribute(name = "社保生成月份", isNotEmpty = true, errorInfo = "社保生成月份不可为空",  maxLength = 6)
+	@Schema(description = "社保生成月份")
+	@ExcelProperty("社保生成月份")
+    private String socialCreateMonth;
+
+    /**
+     * 参保险种: 养老保险，失业保险， 工伤保险
+     */
+    @ExcelAttribute(name = "参保险种")
+	@Schema(description = "参保险种")
+	@ExcelProperty("参保险种")
+    private String riskType;
+    /**
+     * 个人缴费基数
+     */
+    @ExcelAttribute(name = "个人缴费基数")
+	@Schema(description = "个人缴费基数")
+	@ExcelProperty("个人缴费基数")
+    private BigDecimal personalSet;
+    /**
+     * 单位缴费基数
+     */
+    @ExcelAttribute(name = "单位缴费基数")
+	@Schema(description = "单位缴费基数")
+	@ExcelProperty("单位缴费基数")
+    private BigDecimal unitSet;
+
+    /**
+     * 个人缴费额
+     */
+    @ExcelAttribute(name = "个人缴费额")
+	@Schema(description = "个人缴费额")
+	@ExcelProperty("个人缴费额")
+    private BigDecimal personalMoney;
+    /**
+     * 单位缴费额
+     */
+    @ExcelAttribute(name = "单位缴费额")
+	@Schema(description = "单位缴费额")
+	@ExcelProperty("单位缴费额")
+    private BigDecimal unitMoney;
+
+    /**
+     * 医保基数
+     */
+    @ExcelAttribute(name = "医保基数")
+	@Schema(description = "医保基数")
+	@ExcelProperty("医保基数")
+    private BigDecimal medicalSet;
+    /**
+     * 医保单位缴费
+     */
+    @ExcelAttribute(name = "医保单位缴费")
+	@Schema(description = "医保单位缴费")
+	@ExcelProperty("医保单位缴费")
+    private BigDecimal unitMedicalMoney;
+    /**
+     * 医保个人缴费
+     */
+    @ExcelAttribute(name = "医保个人缴费")
+	@Schema(description = "医保个人缴费")
+	@ExcelProperty("医保个人缴费")
+    private BigDecimal personalMedicalMoney;
+
+    /**
+     * 单位医疗救助金 (对应单位大病)
+     */
+    @ExcelAttribute(name = "单位医疗救助金")
+	@Schema(description = "单位医疗救助金")
+	@ExcelProperty("单位医疗救助金")
+    private BigDecimal unitBigailmentMoney;
+
+    /**
+     * 个人医疗救助金 (对应个人大病)
+     */
+    @ExcelAttribute(name = "个人医疗救助金")
+	@Schema(description = "个人医疗救助金")
+	@ExcelProperty("个人医疗救助金")
+    private BigDecimal personalBigailmentMoney;
+
+    /**
+     *  社保ID
+     */
+    @Length(max = 32, message = "不能超过32个字符")
+    @ExcelAttribute(name = "社保ID", maxLength = 32, isDataId = true)
+	@Schema(description = "社保ID")
+	@ExcelProperty("社保ID")
+    private String socialId;
+
+    /**
+     *  公积金ID
+     */
+    @Length(max = 32, message = "不能超过32个字符")
+    @ExcelAttribute(name = "公积金ID", maxLength = 32, isDataId = true)
+	@Schema(description = "公积金ID")
+	@ExcelProperty("公积金ID")
+    private String fundId;
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentInfoImportLogVo.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.yifu.cloud.plus.v1.yifu.social.vo;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.yifu.cloud.plus.v1.yifu.common.core.vo.RowIndex;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+@Data
+public class TPaymentInfoImportLogVo extends RowIndex implements Serializable {
+
+	/**
+	 * 主键
+	 */
+	@TableId(type = IdType.ASSIGN_ID)
+	@NotBlank(message = "主键 不能为空")
+	@ExcelAttribute(name = "主键", isNotEmpty = true, errorInfo = "主键 不能为空")
+	@Schema(description = "主键")
+	@ExcelProperty("主键")
+	private Integer id;
+	/**
+	 * 姓名
+	 */
+	@Length(max = 50, message = "姓名 不能超过50 个字符")
+	@ExcelAttribute(name = "姓名", maxLength = 50)
+	@Schema(description = "姓名")
+	@ExcelProperty("姓名")
+	private String empName;
+	/**
+	 * 身份证号
+	 */
+	@Length(max = 32, message = "身份证号 不能超过32 个字符")
+	@ExcelAttribute(name = "身份证号", maxLength = 32)
+	@Schema(description = "身份证号")
+	@ExcelProperty("身份证号")
+	private String idCard;
+	/**
+	 * 错误信息
+	 */
+	@Length(max = 500, message = "错误信息 不能超过500 个字符")
+	@ExcelAttribute(name = "错误信息", maxLength = 500)
+	@Schema(description = "错误信息")
+	@ExcelProperty("错误信息")
+	private String errMsg;
+	/**
+	 * 问题行数
+	 */
+	@ExcelAttribute(name = "问题行数")
+	@Schema(description = "问题行数")
+	@ExcelProperty("问题行数")
+	private Integer line;
+	/**
+	 * 导入标识key
+	 */
+	@Length(max = 64, message = "导入标识key 不能超过64 个字符")
+	@ExcelAttribute(name = "导入标识key", maxLength = 64)
+	@Schema(description = "导入标识key")
+	@ExcelProperty("导入标识key")
+	private String randomKey;
+
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentInfoSearchVo.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.yifu.cloud.plus.v1.yifu.social.vo;
+
+import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfo;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 缴费库
+ *
+ * @author huyc
+ * @date 2022-07-22 17:01:22
+ */
+@Data
+public class TPaymentInfoSearchVo extends TPaymentInfo {
+
+/**
+ * 多选导出或删除等操作
+ */
+@Schema(description = "选中ID,id数组")
+private List<String> idList;
+
+/**
+ * 创建时间区间 [开始时间，结束时间]
+ */
+@Schema(description = "创建时间区间")
+private LocalDateTime[] createTimes;
+/**
+ * @Author fxj
+ * 查询数据起
+**/
+@Schema(description = "查询limit  开始")
+private int limitStart;
+/**
+ * @Author fxj
+ * 查询数据止
+ **/
+@Schema(description = "查询limit  数据条数")
+private int limitEnd;
+
+}

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TSocialFundInfoExportVo.java

@@ -63,7 +63,7 @@ public class TSocialFundInfoExportVo extends RowIndex implements Serializable {
 	@ExcelProperty("身份证号")
 	private String empIdcard;
 
-	@ExcelAttribute(name = "员工类型", maxLength = 32)
+	@ExcelAttribute(name = "员工类型", isDataId = true,dataType = ExcelAttributeConstants.EMP_NATRUE)
 	@Schema(description = "员工类型")
 	@ExcelProperty("员工类型")
 	private String empType;
@@ -144,20 +144,24 @@ public class TSocialFundInfoExportVo extends RowIndex implements Serializable {
 
 	@ExcelAttribute(name = "合同类型", maxLength = 32, needExport = true)
 	@Schema(description = "合同类型", name = "contractName")
+	@ExcelProperty("合同类型")
 	private String contractName;
 
 	@ExcelAttribute(name = "业务细分", maxLength = 32)
 	@Schema(description = "业务细分", name = "contractSubName")
+	@ExcelProperty("业务细分")
 	private String contractSubName;
 
 	// 社保户——2022-7-26 15:02:00 倩倩告诉房工，社保户就是合同甲方
 	@ExcelAttribute(name = "合同甲方", maxLength = 50, needExport = true)
 	@Schema(description = "合同甲方")
 	@Size(max = 50, message = "合同甲方不可超过50位")
+	@ExcelProperty("合同甲方")
 	private String contractParty;
 
 	@ExcelAttribute(name = "签订期限", maxLength = 32, isDataId = true, dataType = ExcelAttributeConstants.EMPLOYEE_CONTRACT_TYPE, needExport = true)
 	@Schema(description = "签订期限", name = "contractType")
+	@ExcelProperty("签订期限")
 	private String contractType;
 
 	@DateTimeFormat("yyyy-MM-dd")
@@ -179,6 +183,7 @@ public class TSocialFundInfoExportVo extends RowIndex implements Serializable {
 
 	@ExcelAttribute(name = "学历", maxLength = 32)
 	@Schema(description = "学历", name = "contractName")
+	@ExcelProperty("学历")
 	private String educationName;
 
 	@ExcelAttribute(name = "备案基数", maxLength = 255)

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TSocialFundInfoSearchVo.java

@@ -16,12 +16,14 @@
  */
 package com.yifu.cloud.plus.v1.yifu.social.vo;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Set;
 
 /**
  * 社保公积金查询表
@@ -32,12 +34,13 @@ import java.util.List;
 @Data
 public class TSocialFundInfoSearchVo extends TSocialFundInfo {
 
-	/**
-	 * 多选导出或删除等操作
-	 */
-	@Schema(description = "选中ID,多个逗号分割")
-	private String ids;
 
+
+	@TableField(exist = false)
+	@Schema(description = "导出的表头的Set")
+	private Set<String> exportFields;
+
+	@Schema(description = "选中的idList")
 	private List<String> idList;
 	/**
 	 * 创建时间区间 [开始时间，结束时间]

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/constants/PaymentConstants.java

+package com.yifu.cloud.plus.v1.yifu.social.constants;
+
+/**
+ * 缴费库导入静态数据
+ * @Author huyc
+ * @Date 2022-07-27
+ **/
+public class PaymentConstants {
+
+    public static  final  String saveFailExistsSocialSettlement = "社保数据已生成核准表，无法删除！";
+
+    public static  final  String saveFailExistsSalarySocialSettlement = "社保数据已工资结算，无法删除！";
+
+    public static  final  String saveFailExistsFundSettlement = "公积金数据已生成核准表，无法删除！";
+
+    public static  final  String saveFailExistsSalaryFundSettlement = "公积金数据已工资结算，无法删除！";
+
+    public static  final  String saveFailExistsAgentSettlement = "对应缴费库数据已生成代理类结算单，无法删除！";
+
+    public static  final  String saveFailExistsFinanceBillSettlement = "数据已生成财务账单，无法删除！";
+    public static  final  String PENSION_RISK = "养老保险";
+    public static  final  String PENSION = "养老";
+    public static  final  String UNEMPLOYEEMENT_RISK = "失业保险";
+    public static  final  String UNEMPLOYEEMENT = "失业";
+    public static final String INJURY_RISK = "工伤保险";
+    public static final String INJURY = "工伤";
+    public static final String MEDICAL = "医疗";
+}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/constants/SocialConstants.java

@@ -11,4 +11,12 @@ public class SocialConstants {
 	public static final String EMP_NAME_ERROR = "员工姓名错误！";
 	public static final String DIFF_TYPE_ONE = "预估";
 	public static final String DIFF_TYPE_TWO = "差额";
+
+	public static final String YL = "养老";
+	public static final String DB = "大病";
+	public static final String SY = "失业";
+	public static final String BIR = "生育";
+	public static final String GS = "工伤";
+	public static final String YB = "医保";
+
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/controller/TPaymentInfoImportLogController.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.yifu.cloud.plus.v1.yifu.social.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.RedisUtil;
+import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
+import com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner;
+import com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils;
+import com.yifu.cloud.plus.v1.yifu.social.service.TPaymentInfoImportLogService;
+import com.yifu.cloud.plus.v1.yifu.social.util.ServiceUtil;
+import org.apache.commons.lang.StringUtils;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.security.SecurityRequirement;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpHeaders;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+
+
+/**
+ * 
+ *
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/tpaymentinfoimportlog" )
+@Tag(name = "管理")
+@SecurityRequirement(name = HttpHeaders.AUTHORIZATION)
+public class TPaymentInfoImportLogController {
+
+    private final TPaymentInfoImportLogService tPaymentInfoImportLogService;
+
+	private final RedisUtil redisUtil;
+
+	@Operation(description = "导出社保导入日志")
+	@GetMapping("/exportPaymentInfoLog")
+	public void exportPaymentInfoLog(HttpServletResponse response) {
+		YifuUser user = SecurityUtils.getUser();
+		String key = user.getId() + CommonConstants.DOWN_LINE_STRING + CommonConstants.PAYMENT_SOCIAL_WAIT_EXPORT;
+		String importRandom = (String) redisUtil.get(key);
+		if (StringUtils.isBlank(importRandom)) {
+			ServiceUtil.runTimeExceptionDiy("当前社保数据还未导入完成或者数据不存在");
+		}
+		String res = tPaymentInfoImportLogService.exportPaymentInfoLog(response, importRandom);
+		if (Common.isNotNull(res)){
+			ServiceUtil.runTimeExceptionDiy(res);
+		}
+	}
+
+
+	/**
+	 * @description: 清空社保导入日志表
+	 * @return: com.yifu.cloud.v1.common.core.util.R<java.lang.Void>
+	 * @author: huyc
+	 * @date: 2022/7/25
+	 */
+	@Inner
+	@DeleteMapping("/inner/delPaymentInfoLog")
+	public R<Void> delPaymentInfoLog() {
+		boolean flag = tPaymentInfoImportLogService.remove(new QueryWrapper<>());
+		if (flag) {
+			return R.ok();
+		} else {
+			return R.failed("操作失败！");
+		}
+	}
+
+}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/controller/TSocialFundInfoController.java

@@ -80,7 +80,7 @@ public class TSocialFundInfoController {
      * @param id id
      * @return R
      */
-    @Operation(summary = "通过id查询", description = "通过id查询：hasPermission('demo_tsocialfundinfo_get')")
+    @Operation(summary = "通过id查询", description = "通过id查询：hasPermission('tsocialfundinfo_get')")
     @GetMapping("/{id}" )
     @PreAuthorize("@pms.hasPermission('tsocialfundinfo_get')" )
     public R<TSocialFundInfo> getById(@PathVariable("id" ) String id) {
@@ -94,12 +94,12 @@ public class TSocialFundInfoController {
      * @date 2022-07-15 11:38:05
 	 **/
     @SneakyThrows
-    @Operation(description = "批量调基 hasPermission('demo_tsocialfundinfo-batch-import')")
+    @Operation(description = "批量调基 hasPermission('tsocialfundinfo-batch-import')")
     @SysLog("批量调基")
     @PostMapping("/importListAdd")
     @PreAuthorize("@pms.hasPermission('tsocialfundinfo-batch-import')")
-    public R<List<ErrorMessage>> importListAdd(@RequestBody MultipartFile file){
-        return tSocialFundInfoService.importDiy(file.getInputStream());
+    public R<List<ErrorMessage>> importListAdd(@RequestBody MultipartFile file, @RequestParam String doMonth){
+        return tSocialFundInfoService.importDiy(file.getInputStream(), doMonth);
     }
 
     /**
@@ -107,9 +107,9 @@ public class TSocialFundInfoController {
      * @author fxj
      * @date 2022-07-15 11:38:05
      **/
-    @Operation(description = "导出社保公积金查询表 hasPermission('demo_tsocialfundinfo-export')")
+    @Operation(description = "导出社保公积金查询表 hasPermission('tsocialfundinfo-export')")
     @PostMapping("/export")
-    @PreAuthorize("@pms.hasPermission('demo_tsocialfundinfo-export')")
+    @PreAuthorize("@pms.hasPermission('tsocialfundinfo-export')")
     public void export(HttpServletResponse response, @RequestBody TSocialFundInfoSearchVo searchVo) {
             tSocialFundInfoService.listExport(response,searchVo);
     }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/mapper/TPaymentInfoImportLogMapper.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.yifu.cloud.plus.v1.yifu.social.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfoImportLog;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 
+ *
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+@Mapper
+public interface TPaymentInfoImportLogMapper extends BaseMapper<TPaymentInfoImportLog> {
+}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/mapper/TPaymentInfoMapper.java

@@ -21,9 +21,13 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfo;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoSearchVo;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoVo;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * 缴费库
  *
@@ -38,4 +42,56 @@ public interface TPaymentInfoMapper extends BaseMapper<TPaymentInfo> {
      * @return
      */
     IPage<TPaymentInfo> getTPaymentInfoPage(Page<TPaymentInfo> page, @Param("tPaymentInfo") TPaymentInfo tPaymentInfo);
+
+	/**
+	 * 缴费库简单分页查询
+	 * @param searchVo 缴费库
+	 * @return
+	 */
+	Integer selectCountTPaymentInfo(@Param("tPaymentInfo") TPaymentInfoSearchVo searchVo);
+
+	/**
+	 * 缴费库简单分页查询
+	 * @param searchVo 缴费库
+	 * @return
+	 */
+	List<TPaymentInfo> getTPaymentInfoNoPage(@Param("tPaymentInfo") TPaymentInfoSearchVo searchVo);
+
+	/**
+	 * 更新社保或者公积金
+	 * @param tPaymentInfo 缴费库
+	 * @return
+	 */
+	int updateDeleteInfo(@Param("tPaymentInfo")TPaymentInfo tPaymentInfo);
+
+	/**
+	 * 通过ID获取缴费库 及社保、公积金明细
+	 * @param id
+	 * @return
+	 **/
+	TPaymentInfoVo getAllInfoById(String id);
+
+	/**
+	 * 查询要删除的数据
+	 * @param queryEntity
+	 * @return
+	 **/
+	List<TPaymentInfo> selectListForDelete(@Param("queryEntity")TPaymentInfo queryEntity);
+
+	/*
+	* 已存在社保缴费库数据  非删除状态
+	* @param months
+	* @param idcards
+	* @return
+	* */
+	List<TPaymentInfo> selectListForPaymentImport(@Param("months")List<String> months, @Param("idcards")List<String> idcards);
+
+	/*
+	 * 已存在社保缴费库数据  非删除状态
+	 * @param months
+	 * @param idcards
+	 * @return
+	 * */
+	List<TPaymentInfoVo> selectPaymentAllInfoByMonthAndIdCard(@Param("months")List<String> months, @Param("idcards")List<String> idcards);
+
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/mapper/TPreDispatchInfoMapper.java

@@ -38,17 +38,50 @@ public interface TPreDispatchInfoMapper extends BaseMapper<TPreDispatchInfo> {
     /**
      * 预派单记录简单分页查询
      * @param tPreDispatchInfo 预派单记录
+	 * @author huyc
+	 * @date 2022-07-14
      * @return
      */
     IPage<TPreDispatchInfo> getTPreDispatchInfoPage(Page<TPreDispatchInfo> page, @Param("tPreDispatchInfo") TPreDispatchInfo tPreDispatchInfo);
 
+	/*
+	 * 清空预派单默认的派单合同信息
+	 * @param preInfo
+	 * @author huyc
+	 * @date 2022-07-14
+	 * */
 	void clearContractInfo(List<String> idList);
 
+	/*
+	 * 修改资料是否提交状态
+	 * @param tPreDispatchInfo
+	 * @author huyc
+	 * @date 2022-07-14
+	 * */
 	void modifyDataSubmitStatus(@Param("idList")List<String> idList, @Param("status")String status);
 
+	/*
+	 * 更新派单信息
+	 * @param tPreDispatchInfo
+	 * @author huyc
+	 * @date 2022-07-14
+	 * */
 	int updatePreDispatchInfoById(TPreDispatchInfo tPreDispatchInfo);
 
+	/*
+	* 处理派单结果
+	* @param preInfo
+	 * @author huyc
+	 * @date 2022-07-14
+	* */
 	void updatePreStatusById(TPreDispatchInfo preInfo);
 
+	/**
+	 * 获取导出的数据
+	 * @param tPreDispatchInfo 预派单记录
+	 * @author huyc
+	 * @date 2022-07-14
+	 * @return
+	 */
 	List<TPreDispatchExportVo> getListForExport(@Param("tPreDispatchInfo")TPreDispatchInfo tPreDispatchInfo);
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TForecastLibraryService.java

@@ -21,12 +21,11 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
-import com.yifu.cloud.plus.v1.yifu.social.entity.TAgentConfig;
+import com.yifu.cloud.plus.v1.yifu.social.entity.SysBaseSetInfo;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TForecastLibrary;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
 
 import javax.servlet.http.HttpServletResponse;
-import java.util.HashMap;
 import java.util.List;
 
 /**
@@ -66,7 +65,7 @@ public interface TForecastLibraryService extends IService<TForecastLibrary> {
 	 * @Date: 2022/7/25 17:33
 	 * @return: void
 	 **/
-	R<String> updateToneForecastLibary(TSocialFundInfo socialFundInfo);
+	R<String> updateToneForecastLibary(TSocialFundInfo socialFundInfo, String doMonth);
 
 	/**
 	 * @param socialFundInfo
@@ -83,7 +82,7 @@ public interface TForecastLibraryService extends IService<TForecastLibrary> {
 	 * @Date: 2022/7/26 19:09
 	 * @return: void
 	 **/
-	void updateForecastLibaryBySysBase();
+	void updateForecastLibaryBySysBase(SysBaseSetInfo newSysBaseSetInfo);
 
 	/**
 	 * @Description: 每月定时预估库 TODO-加定时器

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TPaymentInfoImportLogService.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+
+package com.yifu.cloud.plus.v1.yifu.social.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfoImportLog;
+
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * 
+ *
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+public interface TPaymentInfoImportLogService extends IService<TPaymentInfoImportLog> {
+
+	/**
+	 * @description: 导出社保导入日志
+	 * @param response
+	 * @param random
+	 * @return: void
+	 * @author: huyc
+	 * @date: 2022/7/25
+	 */
+	String exportPaymentInfoLog(HttpServletResponse response, String random);
+}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TPaymentInfoService.java

-/*
+package com.yifu.cloud.plus.v1.yifu.social.service;/*
  *    Copyright (c) 2018-2025, lengleng All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -15,24 +15,92 @@
  * Author: lengleng (wangiegie@gmail.com)
  */
 
-package com.yifu.cloud.plus.v1.yifu.social.service;
-
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfo;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoSearchVo;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.InputStream;
+import java.util.List;
 
 /**
  * 缴费库
- *
  * @author huyc
- * @date 2022-07-14 18:53:42
+ * @date 2022-07-22 17:01:22
  */
 public interface TPaymentInfoService extends IService<TPaymentInfo> {
-    /**
-     * 缴费库简单分页查询
-     * @param tPaymentInfo 缴费库
-     * @return
-     */
-    IPage<TPaymentInfo> getTPaymentInfoPage(Page<TPaymentInfo> page, TPaymentInfo tPaymentInfo);
+	/**
+	 * 缴费库简单分页查询
+	 * @param tPaymentInfo 缴费库
+	 * @return
+	 */
+	IPage<TPaymentInfo> getTPaymentInfoPage(Page<TPaymentInfo> page, TPaymentInfo tPaymentInfo);
+
+	/**
+	 * 缴费库批量导入社保
+	 * @param inputStream
+	 * @return
+	 */
+	R<List<ErrorMessage>> importSocialDiy(InputStream inputStream, String random);
+
+	/**
+	 * 批量新增缴费库-合肥三险
+	 * @param inputStream
+	 * @param random
+	 * @param type
+	 * @return
+	 */
+	R<List<ErrorMessage>> importSocialHeFeiDiy(InputStream inputStream, String random, String type);
+
+	/**
+	 * 批量导入公积金
+	 * @param inputStream
+	 * @return
+	 */
+	R<List<ErrorMessage>> batchImportPaymentFundInfo(InputStream inputStream);
+
+	/**
+	 * 导出缴费库
+	 * @param response
+	 * @param searchVo
+	 * @return
+	 */
+	void listExport(HttpServletResponse response, TPaymentInfoSearchVo searchVo);
+
+	/**
+	 * 按类型删除
+	 * @Author huyc
+	 * @Date 2022-07-24
+	 * @param id
+	 * @param type
+	 * @return
+	 **/
+	R<Boolean> removeByIdAndType(String id, String type);
+
+	/**
+	 * 通过ID获取缴费库 及社保、公积金明细
+	 * @Author huyc
+	 * @Date 2022-07-24
+	 * @param id
+	 * @return
+	 **/
+	R getAllInfoById(String id);
+
+	/**
+	 * 删除当月 当前登录人的 指定类型的缴费库数据
+	 * @Author huyc
+	 * @Date 2022-07-27
+	 * @param type
+	 * @param settleDepartId
+	 * @param unitId
+	 * @param empIdCard
+	 * @param socialHouseId
+	 * @param fundHouseId
+	 * @return
+	 **/
+	R removeBatchByIdsAndType(String type, String settleDepartId, String unitId, String empIdCard, String socialHouseId, String fundHouseId);
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TSocialFundInfoService.java

@@ -45,13 +45,13 @@ public interface TSocialFundInfoService extends IService<TSocialFundInfo> {
     IPage<TSocialFundInfo> getTSocialFundInfoPage(Page<TSocialFundInfo> page, TSocialFundInfoSearchVo tSocialFundInfo);
 
 	/**
-	 * @param inputStream
+	 * @param doMonth 执行月份
 	 * @Description: 批量调基
 	 * @Author: hgw
 	 * @Date: 2022/7/22 11:32
 	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.util.List < com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage>>
 	 **/
-	R<List<ErrorMessage>> importDiy(InputStream inputStream);
+	R<List<ErrorMessage>> importDiy(InputStream inputStream, String doMonth);
 
 	/**
 	 * @Description: 导出

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/SysBaseSetInfoServiceImpl.java

@@ -31,11 +31,11 @@ import com.yifu.cloud.plus.v1.yifu.social.entity.SysPayProportion;
 import com.yifu.cloud.plus.v1.yifu.social.mapper.SysBaseSetInfoMapper;
 import com.yifu.cloud.plus.v1.yifu.social.service.SysBaseSetInfoService;
 import com.yifu.cloud.plus.v1.yifu.social.service.SysPayProportionService;
+import com.yifu.cloud.plus.v1.yifu.social.service.TForecastLibraryService;
 import com.yifu.cloud.plus.v1.yifu.social.service.TSocialLogService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
-import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
@@ -55,6 +55,8 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 
 	private final SysPayProportionService sysPayProportionService;
 
+	private final TForecastLibraryService tForecastLibraryService;
+
 	/**
 	 * 基数设置表简单分页查询
 	 *
@@ -80,12 +82,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.eq(SysBaseSetInfo::getDepartId, sysBaseSetInfo.getDepartId())
 					.eq(SysBaseSetInfo::getTown, sysBaseSetInfo.getTown())
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.last(CommonConstants.LAST_ONE_SQL));
@@ -104,12 +101,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.eq(SysBaseSetInfo::getCity, sysBaseSetInfo.getCity())
 					.isNull(SysBaseSetInfo::getTown)
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.last(CommonConstants.LAST_ONE_SQL));
@@ -129,12 +121,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.eq(SysBaseSetInfo::getProvince, sysBaseSetInfo.getProvince())
 					.isNull(SysBaseSetInfo::getCity)
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.last(CommonConstants.LAST_ONE_SQL));
@@ -180,12 +167,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.ne(SysBaseSetInfo::getId, sysBaseSetInfo.getId())
 					.eq(SysBaseSetInfo::getStatus, CommonConstants.ZERO_INT)
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.last(CommonConstants.LAST_ONE_SQL));
@@ -197,12 +179,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.eq(SysBaseSetInfo::getCity, sysBaseSetInfo.getCity())
 					.isNull(SysBaseSetInfo::getTown)
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.ne(SysBaseSetInfo::getId, sysBaseSetInfo.getId())
@@ -216,12 +193,7 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 					.eq(SysBaseSetInfo::getProvince, sysBaseSetInfo.getProvince())
 					.isNull(SysBaseSetInfo::getCity)
 					.and(obj -> obj
-							.and(obj1 -> obj1
-									.le(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
-									.and(obj2 -> obj2
-											.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate())
-											.or()
-											.isNull(SysBaseSetInfo::getApplyEndDate)))
+							.ge(SysBaseSetInfo::getApplyStartDate, sysBaseSetInfo.getApplyStartDate())
 							.or()
 							.ge(SysBaseSetInfo::getApplyEndDate, sysBaseSetInfo.getApplyStartDate()))
 					.ne(SysBaseSetInfo::getId, sysBaseSetInfo.getId())
@@ -251,7 +223,10 @@ public class SysBaseSetInfoServiceImpl extends ServiceImpl<SysBaseSetInfoMapper,
 		} else {
 			sysBaseSetInfo.setStatus(CommonConstants.ZERO_INT);
 			sysBaseSetInfo.setDeleteFlag(CommonConstants.ZERO_STRING);
+			sysBaseSetInfo.setIsNew(CommonConstants.ONE_STRING);
 			baseMapper.insert(sysBaseSetInfo);
+			// TODO-测试用（同步社保公积金查询、预估库），后面可删除
+			tForecastLibraryService.updateForecastLibaryBySysBase(sysBaseSetInfo);
 		}
 		List<SysPayProportion> payProportionList = sysBaseSetInfo.getFundProList();
 		if (Common.isNotNull(payProportionList)) {

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TPaymentInfoImportLogServiceImpl.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.yifu.cloud.plus.v1.yifu.social.service.impl;
+
+import com.alibaba.excel.EasyExcel;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeProjectExportVO;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.DateUtil;
+import com.yifu.cloud.plus.v1.yifu.common.core.util.ExcelUtil;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfoImportLog;
+import com.yifu.cloud.plus.v1.yifu.social.mapper.TPaymentInfoImportLogMapper;
+import com.yifu.cloud.plus.v1.yifu.social.service.TPaymentInfoImportLogService;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoImportLogVo;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.lang.reflect.Field;
+import java.net.URLEncoder;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * @author huyc
+ * @date 2022-07-25 14:08:58
+ */
+@Log4j2
+@Service
+public class TPaymentInfoImportLogServiceImpl extends ServiceImpl<TPaymentInfoImportLogMapper, TPaymentInfoImportLog> implements TPaymentInfoImportLogService {
+
+	/**
+	 * @param response
+	 * @param random
+	 * @description: 导出社保导入日志
+	 * @return: void
+	 * @author: huyc
+	 * @date: 2022/7/25
+	 */
+	@Override
+	public String exportPaymentInfoLog(HttpServletResponse response, String random) {
+
+		String fileName = "社保导入日志" + DateUtil.getThisTime() + ".xlsx";
+
+		List<TPaymentInfoImportLogVo> list = new ArrayList<>();
+		List<TPaymentInfoImportLog> paymentInfoImportLogList = lambdaQuery()
+				.eq(TPaymentInfoImportLog::getRandomKey, random).orderByAsc(TPaymentInfoImportLog::getLine).list();
+		if (CollectionUtils.isEmpty(paymentInfoImportLogList)) {
+			return "导出数据为空";
+		}
+		paymentInfoImportLogList.forEach(v -> {
+			TPaymentInfoImportLogVo paymentInfoLogVO = new TPaymentInfoImportLogVo();
+			BeanUtils.copyProperties(v, paymentInfoLogVO);
+			list.add(paymentInfoLogVO);
+		});
+
+		ServletOutputStream out = null;
+		try {
+			out = response.getOutputStream();
+			ExcelUtil<TPaymentInfoImportLogVo> util = new ExcelUtil<>(TPaymentInfoImportLogVo.class);
+			for (TPaymentInfoImportLogVo vo : list) {
+				util.convertEntity(vo, null, null, null);
+			}
+			response.setContentType("multipart/form-data");
+			response.setCharacterEncoding("utf-8");
+			response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
+			// 这里 需要指定写用哪个class去写，然后写到第一个sheet，然后文件流会自动关闭
+			EasyExcel.write(out, EmployeeProjectExportVO.class).includeColumnFiledNames(getExportFieldNameDetailByClass(TPaymentInfoImportLogVo.class)).sheet("社保导入日志")
+					.doWrite(list);
+			out.flush();
+		} catch (IOException e) {
+			log.error("导出缴费库导入记录异常！", e);
+			e.printStackTrace();
+			return "操作失败，发生异常！";
+		}
+		return null;
+	}
+
+	private Set<String> getExportFieldNameDetailByClass(Class<?> clazz) {
+		Set<String> exportfieldsName = new HashSet<>();
+		Field[] fields = clazz.getDeclaredFields();
+		for (Field field : fields) {
+			ExcelAttribute annotation = field.getAnnotation(ExcelAttribute.class);
+			if (annotation != null && Common.isNotNull(annotation.name()) && annotation.needExport()) {
+				exportfieldsName.add(annotation.name());
+			}
+		}
+		return exportfieldsName;
+	}
+}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TSocialFundInfoServiceImpl.java

@@ -32,6 +32,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
+import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeContractExportVO;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.*;
 import com.yifu.cloud.plus.v1.yifu.common.dapr.util.ArchivesDaprUtil;
@@ -105,7 +106,7 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 			response.setCharacterEncoding("utf-8");
 			response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
 			// 这里 需要指定写用哪个class去写，然后写到第一个sheet，然后文件流会自动关闭
-			ExcelWriter excelWriter = EasyExcel.write(out, TSocialFundInfo.class).build();
+			ExcelWriter excelWriter = EasyExcel.write(out, TSocialFundInfoExportVo.class).includeColumnFiledNames(searchVo.getExportFields()).build();
 			int index = 0;
 			if (count > CommonConstants.ZERO_INT) {
 				for (int i = 0; i <= count; i += CommonConstants.EXCEL_EXPORT_LIMIT) {
@@ -148,9 +149,8 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 	@Override
 	public List<TSocialFundInfo> noPageDiy(TSocialFundInfoSearchVo searchVo) {
 		LambdaQueryWrapper<TSocialFundInfo> wrapper = buildQueryWrapper(searchVo);
-		List<String> idList = Common.getList(searchVo.getIds());
-		if (Common.isNotNull(idList)) {
-			wrapper.in(TSocialFundInfo::getId, idList);
+		if (Common.isNotNull(searchVo.getIdList())) {
+			wrapper.in(TSocialFundInfo::getId, searchVo.getIdList());
 		}
 		if (searchVo.getLimitStart() >= 0 && searchVo.getLimitEnd() > 0) {
 			wrapper.last(" limit " + searchVo.getLimitStart() + "," + searchVo.getLimitEnd());
@@ -160,18 +160,16 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 	}
 
 	private List<TSocialFundInfoExportVo> export(TSocialFundInfoSearchVo searchVo) {
-		List<String> idList = Common.getList(searchVo.getIds());
-		if (Common.isNotNull(idList)) {
-			searchVo.setIdList(idList);
+		if (Common.isNotNull(searchVo.getIdList())) {
+			searchVo.setIdList(searchVo.getIdList());
 		}
 		return baseMapper.exportList(searchVo);
 	}
 
 	private Long noPageCountDiy(TSocialFundInfoSearchVo searchVo) {
 		LambdaQueryWrapper<TSocialFundInfo> wrapper = buildQueryWrapper(searchVo);
-		List<String> idList = Common.getList(searchVo.getIds());
-		if (Common.isNotNull(idList)) {
-			wrapper.in(TSocialFundInfo::getId, idList);
+		if (Common.isNotNull(searchVo.getIdList())) {
+			wrapper.in(TSocialFundInfo::getId, searchVo.getIdList());
 		}
 		return baseMapper.selectCount(wrapper);
 	}
@@ -190,21 +188,21 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 	}
 
 	/**
-	 * @param inputStream
+	 * @param doMonth 执行月份
 	 * @Description: 批量调基
 	 * @Author: hgw
 	 * @Date: 2022/7/22 11:32
 	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.util.List < com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage>>
 	 **/
 	@Override
-	public R<List<ErrorMessage>> importDiy(InputStream inputStream) {
+	public R<List<ErrorMessage>> importDiy(InputStream inputStream, String doMonth) {
 		List<ErrorMessage> errorMessageList = new ArrayList<>();
 		ExcelUtil<TSocialFundHistoryVo> util1 = new ExcelUtil<>(TSocialFundHistoryVo.class);
 		// 写法2：
 		// 匿名内部类 不用额外写一个DemoDataListener
 		// 这里 需要指定读用哪个class去读，然后读取第一个sheet 文件流会自动关闭
 		try {
-			EasyExcel.read(inputStream, TSocialFundInfoVo.class, new ReadListener<TSocialFundHistoryVo>() {
+			EasyExcel.read(inputStream, TSocialFundHistoryVo.class, new ReadListener<TSocialFundHistoryVo>() {
 				/**
 				 * 单次缓存的数据量
 				 */
@@ -242,7 +240,7 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 				 */
 				private void saveData() {
 					log.info("{}条数据，开始存储数据库！", cachedDataList.size());
-					importTSocialFundInfo(cachedDataList, errorMessageList);
+					importTSocialFundInfo(cachedDataList, errorMessageList, doMonth);
 					log.info("存储数据库成功！");
 				}
 			}).sheet().doRead();
@@ -253,7 +251,8 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 		return R.ok(errorMessageList);
 	}
 
-	private void importTSocialFundInfo(List<TSocialFundHistoryVo> excelVOList, List<ErrorMessage> errorMessageList) {
+	private void importTSocialFundInfo(List<TSocialFundHistoryVo> excelVOList
+			, List<ErrorMessage> errorMessageList, String doMonth) {
 		// 执行数据插入操作 组装
 		TSocialFundHistoryVo excel;
 		List<String> idCardList = new ArrayList<>();
@@ -373,7 +372,7 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 					// 3：新增变更日志
 					tSocialLogService.saveModificationRecord(CommonConstants.ONE_INT, oldSocialFundInfo.getId(), oldSocialFundInfo, socialFundInfo);
 					// 4：同步预估库
-					tForecastLibraryService.updateToneForecastLibary(socialFundInfo);
+					tForecastLibraryService.updateToneForecastLibary(socialFundInfo, doMonth);
 					// 返回信息处理
 					initResSuccessMessage(errorMessageList, excel.getRowIndex(), isSocial, isFund);
 				} else {
@@ -419,8 +418,12 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
 			socialFundInfo.setPersonalMedicalCardinal(baseSetVo.getUnitMedicalCardinal());
 			socialFundInfo.setPersonalUnemploymentCardinal(baseSetVo.getUnitUnemploymentCardinal());
 
-			socialFundInfo.setUnitBigailmentMoney(baseSetVo.getUnitBigailmentMoney());
-			socialFundInfo.setPersonalBigailmentMoney(baseSetVo.getPersonalBigailmentMoney());
+			if (baseSetVo.getUnitBigailmentMoney() != null) {
+				socialFundInfo.setUnitBigailmentMoney(baseSetVo.getUnitBigailmentMoney());
+			}
+			if (baseSetVo.getPersonalBigailmentMoney() != null) {
+				socialFundInfo.setPersonalBigailmentMoney(baseSetVo.getPersonalBigailmentMoney());
+			}
 		} else if (CommonConstants.ZERO_INT == baseSetVo.getPaymentType()) {
 			BigDecimal limitBase = socialSetInfo.getLowerLimit();
 			this.setLimtBase(socialFundInfo, limitBase);

yifu-social/yifu-social-biz/src/main/resources/mapper/TPaymentInfoImportLogMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+  ~
+  ~      Copyright (c) 2018-2025, lengleng All rights reserved.
+  ~
+  ~  Redistribution and use in source and binary forms, with or without
+  ~  modification, are permitted provided that the following conditions are met:
+  ~
+  ~ Redistributions of source code must retain the above copyright notice,
+  ~  this list of conditions and the following disclaimer.
+  ~  Redistributions in binary form must reproduce the above copyright
+  ~  notice, this list of conditions and the following disclaimer in the
+  ~  documentation and/or other materials provided with the distribution.
+  ~  Neither the name of the yifu4cloud.com developer nor the names of its
+  ~  contributors may be used to endorse or promote products derived from
+  ~  this software without specific prior written permission.
+  ~  Author: lengleng (wangiegie@gmail.com)
+  ~
+  -->
+
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yifu.cloud.plus.v1.yifu.social.mapper.TPaymentInfoImportLogMapper">
+
+  <resultMap id="tPaymentInfoImportLogMap" type="com.yifu.cloud.plus.v1.yifu.social.entity.TPaymentInfoImportLog">
+    <id property="id" column="id"/>
+    <result property="empName" column="emp_name"/>
+    <result property="idCard" column="id_card"/>
+    <result property="errMsg" column="err_msg"/>
+    <result property="line" column="line"/>
+    <result property="randomKey" column="random_key"/>
+  </resultMap>
+    <sql id="Base_Column_List">
+                a.id,
+                a.emp_name,
+                a.id_card,
+                a.err_msg,
+                a.line,
+                a.random_key
+    </sql>
+    <sql id="tPaymentInfoImportLog_where">
+        <if test="tPaymentInfoImportLog != null">
+                    <if test="tPaymentInfoImportLog.id != null">
+                        AND a.id = #{tPaymentInfoImportLog.id}
+                    </if>
+                    <if test="tPaymentInfoImportLog.empName != null and tPaymentInfoImportLog.empName.trim() != ''">
+                        AND a.emp_name = #{tPaymentInfoImportLog.empName}
+                    </if>
+                    <if test="tPaymentInfoImportLog.idCard != null and tPaymentInfoImportLog.idCard.trim() != ''">
+                        AND a.id_card = #{tPaymentInfoImportLog.idCard}
+                    </if>
+                    <if test="tPaymentInfoImportLog.errMsg != null and tPaymentInfoImportLog.errMsg.trim() != ''">
+                        AND a.err_msg = #{tPaymentInfoImportLog.errMsg}
+                    </if>
+                    <if test="tPaymentInfoImportLog.line != null">
+                        AND a.line = #{tPaymentInfoImportLog.line}
+                    </if>
+                    <if test="tPaymentInfoImportLog.randomKey != null and tPaymentInfoImportLog.randomKey.trim() != ''">
+                        AND a.random_key = #{tPaymentInfoImportLog.randomKey}
+                    </if>
+        </if>
+    </sql>
+    <!--tPaymentInfoImportLog简单分页查询-->
+    <select id="getTPaymentInfoImportLogPage" resultMap="tPaymentInfoImportLogMap">
+        SELECT
+        <include refid="Base_Column_List"/>
+        FROM t_payment_info_import_log a
+        <where>
+            1=1
+            <include refid="tPaymentInfoImportLog_where"/>
+        </where>
+    </select>
+</mapper>

yifu-social/yifu-social-biz/src/main/resources/mapper/TPreDispatchInfoMapper.xml

@@ -561,6 +561,7 @@
             1=1
             <include refid="tPreDispatchInfo_where"/>
         </where>
+		ORDER BY a.CREATE_TIME desc
     </select>
 	<!--tPreDispatchInfo无分页查询-->
 	<select id="getListForExport" resultMap="tPreDispatchExportMap">