Merge remote-tracking branch 'origin/dev_mysql' into dev_mysql

atms-api/src/main/java/pwc/taxtech/atms/common/message/ErrorMessage.java

@@ -7,5 +7,9 @@ public class ErrorMessage {
     public static final String  NoFile = "NoFile";
 
     public static final String  NoSelectSheet = "NoSelectSheet";
-    
+    public static final String  DIDNOTSELECTPERIOD = "You should select period!";
+    public static final String  ImportFailed = "ImportFailed!";
+
+
+
 }

atms-api/src/main/java/pwc/taxtech/atms/common/message/ErrorMessageCN.java

+package pwc.taxtech.atms.common.message;
+
+public class ErrorMessageCN {
+
+    public static final String  NoCompanyError = "未映射到主体";
+    public static final String  ExistDataPeriodsError = "存在非选择期间数据";
+    public static final String  DONOTSELECTPERIOD = "未选择期间";
+
+}

atms-api/src/main/java/pwc/taxtech/atms/constant/enums/EnumImportType.java

+package pwc.taxtech.atms.constant.enums;
+
+public enum EnumImportType {
+    Undefined(0),
+    ProfitLoss(1),
+    BalanceSheet(2);
+
+    private Integer code;
+
+    EnumImportType(Integer code) {
+        this.code = code;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+}

atms-api/src/main/java/pwc/taxtech/atms/controller/DataImportController.java

 package pwc.taxtech.atms.controller;
 
 import org.springframework.web.bind.annotation.*;
+import com.google.common.collect.Lists;
+import org.springframework.web.multipart.MultipartFile;
+import pwc.taxtech.atms.common.message.ErrorMessage;
 import pwc.taxtech.atms.dpo.PagingDto;
 import pwc.taxtech.atms.dto.ApiResultDto;
+import pwc.taxtech.atms.dto.DataImportLogDto;
+import pwc.taxtech.atms.dto.OperationResultDto;
 import pwc.taxtech.atms.dto.PagingResultDto;
 import pwc.taxtech.atms.dto.vatdto.TrialBalanceDto;
 import pwc.taxtech.atms.dto.vatdto.TrialBalanceParam;
+import pwc.taxtech.atms.exception.ServiceException;
 import pwc.taxtech.atms.service.impl.DataImportService;
 import pwc.taxtech.atms.service.impl.LgGlBalanceService;
 
@@ -41,4 +47,49 @@ public class DataImportController extends BaseController {
         lgGlBalanceService.queryGlBalance(param.getOrgId(), param.getPeriodStart(), param.getPeriodEnd());
         return resultDto;
     }
+
+    @ResponseBody
+    @RequestMapping(value = "PLExcelFile", method = RequestMethod.POST)
+    public OperationResultDto importPLExcelFile(@RequestParam MultipartFile file,@RequestParam String periodDate,@RequestParam Integer importType) {
+        try {
+            if (null == file) {
+                return OperationResultDto.error(ErrorMessage.NoFile);
+            }
+            dataImportService.importPLExcelFile(file, periodDate,importType);
+            return OperationResultDto.success();
+        } catch (ServiceException e) {
+            return OperationResultDto.error(e.getMessage());
+        } catch (Exception e) {
+            logger.error("importTemplateGroupExcelFile error.", e);
+        }
+        return OperationResultDto.error(ErrorMessage.SystemError);
+    }
+
+    @ResponseBody
+    @RequestMapping(value = "BSExcelFile", method = RequestMethod.POST)
+    public OperationResultDto importBSExcelFile(@RequestParam MultipartFile file,@RequestParam String periodDate,@RequestParam Integer importType) {
+        try {
+            if (null == file) {
+                return OperationResultDto.error(ErrorMessage.NoFile);
+            }
+            return dataImportService.importBSExcelFile(file, periodDate,importType);
+        } catch (ServiceException e) {
+            return OperationResultDto.error(e.getMessage());
+        } catch (Exception e) {
+            logger.error("importTemplateGroupExcelFile error.", e);
+        }
+        return OperationResultDto.error(ErrorMessage.SystemError);
+    }
+
+    @ResponseBody
+    @RequestMapping(value = "displayImportLog", method = RequestMethod.GET)
+    public List<DataImportLogDto> displayImportLog(@RequestParam Integer type) {
+        List<DataImportLogDto> dataImportLogDtos = Lists.newArrayList();
+        try {
+            dataImportLogDtos = dataImportService.displayImportLog(type);
+        } catch (Exception e) {
+            logger.error("displayImportLog error.", e);
+        }
+        return dataImportLogDtos;
+    }
 }

atms-api/src/main/java/pwc/taxtech/atms/data/UserData.java

+package pwc.taxtech.atms.data;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Service;
+import pwc.taxtech.atms.dao.UserMapper;
+import pwc.taxtech.atms.entity.User;
+
+/**
+ * @Auther: Gary J Li
+ * @Date: 11/01/2019 14:32
+ * @Description:
+ */
+@Service
+public class UserData {
+    private static final Logger logger = LoggerFactory.getLogger(UserData.class);
+    @Autowired
+    private UserMapper userMapper;
+
+    // todo logOut时清除
+    @Cacheable(value = "user", key = "#inputLoginName")
+    public User selectByUserNameIgnoreCase(String inputLoginName){
+        return userMapper.selectByUserNameIgnoreCase(inputLoginName);
+    }
+}

atms-api/src/main/java/pwc/taxtech/atms/dto/vatdto/dd/BalanceSheetDto.java

@@ -72,6 +72,17 @@ public class BalanceSheetDto implements Serializable {
      */
     private String source;
 
+    /**
+     * Database Column Remarks:
+     *   税务系统期间yyyymm
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    private Integer tmsPeriod;
+
     /**
      * Database Column Remarks:
      *   期间 yyyymm
@@ -365,6 +376,30 @@ public class BalanceSheetDto implements Serializable {
         this.source = source == null ? null : source.trim();
     }
 
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column balance_sheet.tms_period
+     *
+     * @return the value of balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    public Integer getTmsPeriod() {
+        return tmsPeriod;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column balance_sheet.tms_period
+     *
+     * @param tmsPeriod the value for balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    public void setTmsPeriod(Integer tmsPeriod) {
+        this.tmsPeriod = tmsPeriod;
+    }
+
     /**
      * This method was generated by MyBatis Generator.
      * This method returns the value of the database column balance_sheet.period
@@ -731,6 +766,8 @@ public class BalanceSheetDto implements Serializable {
      *
      * @mbg.generated
      */
+
+
     @Override
     public String toString() {
         StringBuilder sb = new StringBuilder();
@@ -742,6 +779,7 @@ public class BalanceSheetDto implements Serializable {
         sb.append(", projectId=").append(projectId);
         sb.append(", date=").append(date);
         sb.append(", source=").append(source);
+        sb.append(", tmsPeriod=").append(tmsPeriod);
         sb.append(", period=").append(period);
         sb.append(", status=").append(status);
         sb.append(", ledgerId=").append(ledgerId);

atms-api/src/main/java/pwc/taxtech/atms/dto/vatdto/dd/ProfitLossStatementDto.java

@@ -72,6 +72,17 @@ public class ProfitLossStatementDto implements Serializable {
      */
     private String source;
 
+    /**
+     * Database Column Remarks:
+     *   税务系统期间yyyymm
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    private Integer tmsPeriod;
+
     /**
      * Database Column Remarks:
      *   期间 yyyymm
@@ -365,6 +376,30 @@ public class ProfitLossStatementDto implements Serializable {
         this.source = source == null ? null : source.trim();
     }
 
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column profit_loss_statement.tms_period
+     *
+     * @return the value of profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    public Integer getTmsPeriod() {
+        return tmsPeriod;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column profit_loss_statement.tms_period
+     *
+     * @param tmsPeriod the value for profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    public void setTmsPeriod(Integer tmsPeriod) {
+        this.tmsPeriod = tmsPeriod;
+    }
+
     /**
      * This method was generated by MyBatis Generator.
      * This method returns the value of the database column profit_loss_statement.period
@@ -742,6 +777,7 @@ public class ProfitLossStatementDto implements Serializable {
         sb.append(", projectId=").append(projectId);
         sb.append(", date=").append(date);
         sb.append(", source=").append(source);
+        sb.append(", tmsPeriod=").append(tmsPeriod);
         sb.append(", period=").append(period);
         sb.append(", status=").append(status);
         sb.append(", ledgerId=").append(ledgerId);

atms-api/src/main/java/pwc/taxtech/atms/service/impl/MenuServiceImpl.java

@@ -124,6 +124,26 @@ public class MenuServiceImpl {
         // 数据问题，，暂时用这种蠢办法
         menuIds.add("91223c21-c15a-4882-89cc-42f3807ec9e3");
         menuIds.add("9bf855fb-6b44-49cd-b95b-41a6a9a8c098");
+
+        menuIds.add("6b404066-2200-4d11-9436-d0870dfd3188");
+        menuIds.add("6b404066-2200-4d11-9436-d0870dfd3189");
+
+        menuIds.add("5bdbc9a7-197b-43cc-b0e6-3f50e41b13eb");
+        menuIds.add("5bdbc9a7-197b-43cc-b0e6-3f50e41b13ec");
+        menuIds.add("5bdbc9a7-197b-43cc-b0e6-3f50e41b13eg");
+        menuIds.add("5bdbc9a7-197b-43cc-b0e6-3f50e41b13eh");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0813");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0814");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0815");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0816");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0817");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0818");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0819");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0820");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0821");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0822");
+        menuIds.add("a9b1cd87-89ef-4dae-b798-b19e9bbe0823");
+        menuIds.add("b8c74ee9-e5d7-467b-8565-e77efe6a499f");
         //        List<MenuDto> menus = getMenus(moduleId).stream().filter(x -> permissionNames.contains(x.getName())).collect(Collectors.toList());
         return menuIds;
 

atms-api/src/main/resources/conf/conf_profile_staging.properties

-jdbc_url=jdbc:oracle:thin:@127.0.0.1:1521:XE
-jdbc_user=tax_admin_longi
-jdbc_password=tax_admin_longi
+jdbc_url=jdbc:mysql://10.158.230.16:3306/tax_admin_didi?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
+jdbc_user=root
+jdbc_password=taxadmin2018
 #jdbc_password=111111
-jdbc_admin_db=tax_admin_longi
-
-jdbc2_url=jdbc:oracle:thin:@127.0.0.1:1521:XE
-jdbc2_user=pwc_invoice
-jdbc2_password=pwc_invoice
-jdbc2_admin_db=pwc_invoices
+jdbc_admin_db=taxadmin2018
 
 jdbc_url_demo=jdbc:mysql://10.158.230.144:3306/demo_db_name?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
 
@@ -15,7 +10,7 @@ mail_jdbc_url=jdbc:sqlserver://192.168.1.102:1434;DatabaseName=MAILMaster
 mail_jdbc_user=sa
 mail_jdbc_password=atmsunittestSQL
 
-web.url=http://etms.longi-silicon.com:8180
+web.url=http://etms.longi-silicon.com:10000
 #web.url=*
 jwt.base64Secret=TXppQjFlZFBSbnJzMHc0Tg==
 jwt.powerToken=xxxx
@@ -33,7 +28,7 @@ max_file_length=104857600
 distributed_id_datacenter=10
 distributed_id_machine=10
 
-api.url=http://etms.longi-silicon.com:8182
+api.url=http://etms.longi-silicon.com:20000
 
 # Longi config
 longi_api_basic_user=

atms-dao/etc/generator-mysql/generator.properties

 jdbc.driverClass=com.mysql.jdbc.Driver
-jdbc.connectionURL=jdbc:mysql://10.158.230.144:3306/tax_admin_didi?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
+jdbc.connectionURL=jdbc:mysql://10.158.230.16:3306/tax_admin_didi?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
 jdbc.userId=root
-jdbc.password=tax@Admin2018
+jdbc.password=taxadmin2018

atms-dao/etc/generator-mysql/generatorConfig.xml

@@ -41,6 +41,19 @@
             <property name="rootInterface" value="pwc.taxtech.atms.MyMapper"/>
         </javaClientGenerator>
 
+        <table tableName="data_import_log" domainObjectName="DataImportLog">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+            <columnOverride column="type" javaType="java.lang.Integer" jdbcType="TINYINT"/>
+            <columnOverride column="tms_period_month" javaType="java.lang.Integer" jdbcType="TINYINT"/>
+            <columnOverride column="period_month" javaType="java.lang.Integer" jdbcType="TINYINT"/>
+        </table>
+
+        <!--<table tableName="organization_extra" domainObjectName="OrganizationExtra">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
         <table tableName="organization_tax_rule" domainObjectName="OrganizationTaxRule">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
@@ -67,6 +80,16 @@
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
 
+        <table tableName="organization_employee" domainObjectName="OrganizationEmployee">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
+        <table tableName="organization_taxpayer_qualification" domainObjectName="OrganizationTaxpayerQualification">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
         <table tableName="organization_approved_levy_info" domainObjectName="OrganizationApprovedLevyInfo">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
@@ -77,10 +100,10 @@
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
 
-        <!--<table tableName="equity_information_history" domainObjectName="EquityInformationHistory">
+        &lt;!&ndash;<table tableName="equity_information_history" domainObjectName="EquityInformation">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
-        </table>-->
+        </table>&ndash;&gt;
 
 
         <table tableName="organization" domainObjectName="Organization">
@@ -237,7 +260,7 @@
             <columnOverride column="is_active" property="isActive" javaType="Boolean"/>
         </table>
 
-        <!--<table tableName="input_ap_invoice" domainObjectName="InputApInvoice">
+        &lt;!&ndash;<table tableName="input_ap_invoice" domainObjectName="InputApInvoice">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
@@ -280,7 +303,7 @@
         <table tableName="input_vendor_site" domainObjectName="InputVendorSite">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
-        </table>-->
+        </table>&ndash;&gt;
 
         <table tableName="key_value_config" domainObjectName="KeyValueConfig">
             <property name="useActualColumnNames" value="false"/>
@@ -383,7 +406,7 @@
             <columnOverride column="is_active" property="isActive" javaType="Boolean"/>
         </table>
 
-        <!--<table tableName="output_ar_invoice" domainObjectName="OutputArInvoice">
+        &lt;!&ndash;<table tableName="output_ar_invoice" domainObjectName="OutputArInvoice">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
@@ -456,7 +479,7 @@
         <table tableName="output_ra_interface" domainObjectName="OutputRaInterface">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
-        </table>-->
+        </table>&ndash;&gt;
 
         <table tableName="period_approve" domainObjectName="PeriodApprove">
             <property name="useActualColumnNames" value="false"/>
@@ -634,10 +657,10 @@
         </table>
 
 
-        <!--<table tableName="table_test" domainObjectName="TableTest">
+        &lt;!&ndash;<table tableName="table_test" domainObjectName="TableTest">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
-        </table>-->
+        </table>&ndash;&gt;
 
         <table tableName="tax_payer_report_rule" domainObjectName="TaxPayerReportRule">
             <property name="useActualColumnNames" value="false"/>
@@ -721,7 +744,7 @@
         <table tableName="user_role" domainObjectName="UserRole">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
-        </table>
+        </table>-->
 
     </context>
 </generatorConfiguration>
\ No newline at end of file

atms-dao/etc/generator-mysql/vatGenerator.properties

 jdbc.driverClass=com.mysql.jdbc.Driver
-jdbc.connectionURL=jdbc:mysql://10.158.230.144:3306/tax_admin_didi?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
+jdbc.connectionURL=jdbc:mysql://10.158.230.16:3306/tax_admin_didi?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
 jdbc.userId=root
-jdbc.password=tax@Admin2018
+jdbc.password=taxadmin2018

atms-dao/etc/generator-mysql/vatGeneratorConfig.xml

@@ -41,12 +41,27 @@
             <property name="rootInterface" value="pwc.taxtech.atms.MyVatMapper" />
         </javaClientGenerator>
 
-        <table tableName="trial_balance" domainObjectName="TrialBalance">
+        <!--<table tableName="profit_loss_statement_manual" domainObjectName="ProfitLossStatementManual">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
+        <table tableName="balance_sheet_manual" domainObjectName="BalanceSheetManual">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
+        <table tableName="profit_loss_statement_final" domainObjectName="ProfitLossStatementFinal">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>-->
+
+        <table tableName="balance_sheet_final" domainObjectName="BalanceSheetFinal">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
 
-        <table tableName="profit_loss_statement" domainObjectName="ProfitLossStatement">
+        <!--<table tableName="profit_loss_statement" domainObjectName="ProfitLossStatement">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
@@ -61,7 +76,12 @@
             <property name="ignoreQualifiersAtRuntime" value="true"/>
         </table>
 
-        <!--<table tableName="account" domainObjectName="Account">
+        <table tableName="trial_balance" domainObjectName="TrialBalance">
+            <property name="useActualColumnNames" value="false"/>
+            <property name="ignoreQualifiersAtRuntime" value="true"/>
+        </table>
+
+        <table tableName="account" domainObjectName="Account">
             <property name="useActualColumnNames" value="false"/>
             <property name="ignoreQualifiersAtRuntime" value="true"/>
             <columnOverride column="is_leaf" javaType="Boolean"/>

atms-dao/src/main/java/pwc/taxtech/atms/dao/DataImportLogMapper.java

+package pwc.taxtech.atms.dao;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.session.RowBounds;
+import pwc.taxtech.atms.MyMapper;
+import pwc.taxtech.atms.entity.DataImportLog;
+import pwc.taxtech.atms.entity.DataImportLogExample;
+
+@Mapper
+public interface DataImportLogMapper extends MyMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    long countByExample(DataImportLogExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(DataImportLogExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int insert(DataImportLog record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int insertSelective(DataImportLog record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    List<DataImportLog> selectByExampleWithRowbounds(DataImportLogExample example, RowBounds rowBounds);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    List<DataImportLog> selectByExample(DataImportLogExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    DataImportLog selectByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") DataImportLog record, @Param("example") DataImportLogExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") DataImportLog record, @Param("example") DataImportLogExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(DataImportLog record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table data_import_log
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(DataImportLog record);
+}
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/BalanceSheetFinalMapper.java

+package pwc.taxtech.atms.vat.dao;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.session.RowBounds;
+import pwc.taxtech.atms.MyVatMapper;
+import pwc.taxtech.atms.vat.dpo.BalanceSheetCondition;
+import pwc.taxtech.atms.vat.entity.BalanceSheet;
+import pwc.taxtech.atms.vat.entity.BalanceSheetExample;
+
+@Mapper
+public interface BalanceSheetFinalMapper extends MyVatMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    long countByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int insert(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int insertSelective(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    List<BalanceSheet> selectByExampleWithRowbounds(BalanceSheetExample example, RowBounds rowBounds);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    List<BalanceSheet> selectByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    BalanceSheet selectByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") BalanceSheet record, @Param("example") BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") BalanceSheet record, @Param("example") BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_final
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(BalanceSheet record);
+
+    List<BalanceSheet> selectByCondition(@Param("bsCondition") BalanceSheetCondition condition);
+
+    int insertBatch(List<BalanceSheet> bls);
+}
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/BalanceSheetManualMapper.java

+package pwc.taxtech.atms.vat.dao;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.session.RowBounds;
+import pwc.taxtech.atms.MyVatMapper;
+import pwc.taxtech.atms.vat.dpo.BalanceSheetCondition;
+import pwc.taxtech.atms.vat.entity.BalanceSheet;
+import pwc.taxtech.atms.vat.entity.BalanceSheetExample;
+
+@Mapper
+public interface BalanceSheetManualMapper extends MyVatMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    long countByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int insert(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int insertSelective(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    List<BalanceSheet> selectByExampleWithRowbounds(BalanceSheetExample example, RowBounds rowBounds);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    List<BalanceSheet> selectByExample(BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    BalanceSheet selectByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") BalanceSheet record, @Param("example") BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") BalanceSheet record, @Param("example") BalanceSheetExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(BalanceSheet record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table balance_sheet_manual
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(BalanceSheet record);
+
+    List<BalanceSheet> selectByCondition(@Param("bsCondition") BalanceSheetCondition condition);
+
+    int insertBatch(List<BalanceSheet> bls);
+}
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/BalanceSheetMapper.java

@@ -108,4 +108,6 @@ public interface BalanceSheetMapper extends MyVatMapper {
     int updateByPrimaryKey(BalanceSheet record);
 
     List<BalanceSheet> selectByCondition(@Param("bsCondition") BalanceSheetCondition condition);
+
+    int insertBatch(List<BalanceSheet> bls);
 }
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/ProfitLossStatementFinalMapper.java

+package pwc.taxtech.atms.vat.dao;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.session.RowBounds;
+import pwc.taxtech.atms.MyVatMapper;
+import pwc.taxtech.atms.vat.dpo.ProfitLossStatementCondition;
+import pwc.taxtech.atms.vat.entity.ProfitLossStatement;
+import pwc.taxtech.atms.vat.entity.ProfitLossStatementExample;
+
+@Mapper
+public interface ProfitLossStatementFinalMapper extends MyVatMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    long countByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int insert(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int insertSelective(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    List<ProfitLossStatement> selectByExampleWithRowbounds(ProfitLossStatementExample example, RowBounds rowBounds);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    List<ProfitLossStatement> selectByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    ProfitLossStatement selectByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") ProfitLossStatement record, @Param("example") ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") ProfitLossStatement record, @Param("example") ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_final
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(ProfitLossStatement record);
+
+    List<ProfitLossStatement> selectByCondition(@Param("plCondition") ProfitLossStatementCondition condition);
+
+    int insertBatch(List<ProfitLossStatement> pls);
+}
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/ProfitLossStatementManualMapper.java

+package pwc.taxtech.atms.vat.dao;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.session.RowBounds;
+import pwc.taxtech.atms.MyVatMapper;
+import pwc.taxtech.atms.vat.dpo.ProfitLossStatementCondition;
+import pwc.taxtech.atms.vat.entity.ProfitLossStatement;
+import pwc.taxtech.atms.vat.entity.ProfitLossStatementExample;
+
+@Mapper
+public interface ProfitLossStatementManualMapper extends MyVatMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    long countByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int deleteByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int deleteByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int insert(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int insertSelective(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    List<ProfitLossStatement> selectByExampleWithRowbounds(ProfitLossStatementExample example, RowBounds rowBounds);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    List<ProfitLossStatement> selectByExample(ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    ProfitLossStatement selectByPrimaryKey(Long id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int updateByExampleSelective(@Param("record") ProfitLossStatement record, @Param("example") ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int updateByExample(@Param("record") ProfitLossStatement record, @Param("example") ProfitLossStatementExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKeySelective(ProfitLossStatement record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table profit_loss_statement_manual
+     *
+     * @mbg.generated
+     */
+    int updateByPrimaryKey(ProfitLossStatement record);
+
+    List<ProfitLossStatement> selectByCondition(@Param("plCondition") ProfitLossStatementCondition condition);
+
+    int insertBatch(List<ProfitLossStatement> pls);
+}
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/dao/ProfitLossStatementMapper.java

@@ -109,4 +109,5 @@ public interface ProfitLossStatementMapper extends MyVatMapper {
 
     List<ProfitLossStatement> selectByCondition(@Param("plCondition")ProfitLossStatementCondition condition);
 
+    int insertBatch(List<ProfitLossStatement> pls);
 }
\ No newline at end of file

atms-dao/src/main/java/pwc/taxtech/atms/vat/entity/BalanceSheet.java

@@ -68,6 +68,17 @@ public class BalanceSheet extends BaseEntity implements Serializable {
      */
     private String source;
 
+    /**
+     * Database Column Remarks:
+     *   税务系统期间yyyymm
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    private Integer tmsPeriod;
+
     /**
      * Database Column Remarks:
      *   期间 yyyymm
@@ -361,6 +372,30 @@ public class BalanceSheet extends BaseEntity implements Serializable {
         this.source = source == null ? null : source.trim();
     }
 
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column balance_sheet.tms_period
+     *
+     * @return the value of balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    public Integer getTmsPeriod() {
+        return tmsPeriod;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column balance_sheet.tms_period
+     *
+     * @param tmsPeriod the value for balance_sheet.tms_period
+     *
+     * @mbg.generated
+     */
+    public void setTmsPeriod(Integer tmsPeriod) {
+        this.tmsPeriod = tmsPeriod;
+    }
+
     /**
      * This method was generated by MyBatis Generator.
      * This method returns the value of the database column balance_sheet.period
@@ -738,6 +773,7 @@ public class BalanceSheet extends BaseEntity implements Serializable {
         sb.append(", projectId=").append(projectId);
         sb.append(", date=").append(date);
         sb.append(", source=").append(source);
+        sb.append(", tmsPeriod=").append(tmsPeriod);
         sb.append(", period=").append(period);
         sb.append(", status=").append(status);
         sb.append(", ledgerId=").append(ledgerId);

atms-dao/src/main/java/pwc/taxtech/atms/vat/entity/BalanceSheetExample.java

@@ -526,6 +526,66 @@ public class BalanceSheetExample {
             return (Criteria) this;
         }
 
+        public Criteria andTmsPeriodIsNull() {
+            addCriterion("tms_period is null");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodIsNotNull() {
+            addCriterion("tms_period is not null");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodEqualTo(Integer value) {
+            addCriterion("tms_period =", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotEqualTo(Integer value) {
+            addCriterion("tms_period <>", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodGreaterThan(Integer value) {
+            addCriterion("tms_period >", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodGreaterThanOrEqualTo(Integer value) {
+            addCriterion("tms_period >=", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodLessThan(Integer value) {
+            addCriterion("tms_period <", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodLessThanOrEqualTo(Integer value) {
+            addCriterion("tms_period <=", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodIn(List<Integer> values) {
+            addCriterion("tms_period in", values, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotIn(List<Integer> values) {
+            addCriterion("tms_period not in", values, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodBetween(Integer value1, Integer value2) {
+            addCriterion("tms_period between", value1, value2, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotBetween(Integer value1, Integer value2) {
+            addCriterion("tms_period not between", value1, value2, "tmsPeriod");
+            return (Criteria) this;
+        }
+
         public Criteria andPeriodIsNull() {
             addCriterion("period is null");
             return (Criteria) this;

atms-dao/src/main/java/pwc/taxtech/atms/vat/entity/ProfitLossStatement.java

@@ -68,6 +68,17 @@ public class ProfitLossStatement extends BaseEntity implements Serializable {
      */
     private String source;
 
+    /**
+     * Database Column Remarks:
+     *   税务系统期间yyyymm
+     *
+     * This field was generated by MyBatis Generator.
+     * This field corresponds to the database column profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    private Integer tmsPeriod;
+
     /**
      * Database Column Remarks:
      *   期间 yyyymm
@@ -361,6 +372,30 @@ public class ProfitLossStatement extends BaseEntity implements Serializable {
         this.source = source == null ? null : source.trim();
     }
 
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method returns the value of the database column profit_loss_statement.tms_period
+     *
+     * @return the value of profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    public Integer getTmsPeriod() {
+        return tmsPeriod;
+    }
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method sets the value of the database column profit_loss_statement.tms_period
+     *
+     * @param tmsPeriod the value for profit_loss_statement.tms_period
+     *
+     * @mbg.generated
+     */
+    public void setTmsPeriod(Integer tmsPeriod) {
+        this.tmsPeriod = tmsPeriod;
+    }
+
     /**
      * This method was generated by MyBatis Generator.
      * This method returns the value of the database column profit_loss_statement.period
@@ -738,6 +773,7 @@ public class ProfitLossStatement extends BaseEntity implements Serializable {
         sb.append(", projectId=").append(projectId);
         sb.append(", date=").append(date);
         sb.append(", source=").append(source);
+        sb.append(", tmsPeriod=").append(tmsPeriod);
         sb.append(", period=").append(period);
         sb.append(", status=").append(status);
         sb.append(", ledgerId=").append(ledgerId);

atms-dao/src/main/java/pwc/taxtech/atms/vat/entity/ProfitLossStatementExample.java

@@ -526,6 +526,66 @@ public class ProfitLossStatementExample {
             return (Criteria) this;
         }
 
+        public Criteria andTmsPeriodIsNull() {
+            addCriterion("tms_period is null");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodIsNotNull() {
+            addCriterion("tms_period is not null");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodEqualTo(Integer value) {
+            addCriterion("tms_period =", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotEqualTo(Integer value) {
+            addCriterion("tms_period <>", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodGreaterThan(Integer value) {
+            addCriterion("tms_period >", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodGreaterThanOrEqualTo(Integer value) {
+            addCriterion("tms_period >=", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodLessThan(Integer value) {
+            addCriterion("tms_period <", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodLessThanOrEqualTo(Integer value) {
+            addCriterion("tms_period <=", value, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodIn(List<Integer> values) {
+            addCriterion("tms_period in", values, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotIn(List<Integer> values) {
+            addCriterion("tms_period not in", values, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodBetween(Integer value1, Integer value2) {
+            addCriterion("tms_period between", value1, value2, "tmsPeriod");
+            return (Criteria) this;
+        }
+
+        public Criteria andTmsPeriodNotBetween(Integer value1, Integer value2) {
+            addCriterion("tms_period not between", value1, value2, "tmsPeriod");
+            return (Criteria) this;
+        }
+
         public Criteria andPeriodIsNull() {
             addCriterion("period is null");
             return (Criteria) this;

atms-dao/src/main/resources/pwc/taxtech/atms/vat/dao/BalanceSheetMapper.xml

@@ -11,6 +11,7 @@
     <result column="project_id" jdbcType="VARCHAR" property="projectId" />
     <result column="date" jdbcType="TIMESTAMP" property="date" />
     <result column="source" jdbcType="VARCHAR" property="source" />
+    <result column="tms_period" jdbcType="INTEGER" property="tmsPeriod" />
     <result column="period" jdbcType="INTEGER" property="period" />
     <result column="status" jdbcType="VARCHAR" property="status" />
     <result column="ledger_id" jdbcType="VARCHAR" property="ledgerId" />
@@ -98,9 +99,9 @@
       WARNING - @mbg.generated
       This element is automatically generated by MyBatis Generator, do not modify.
     -->
-    id, organization_id, project_id, `date`, `source`, period, `status`, ledger_id, ledger_name, 
-    ledger_currency_code, entity_code, entity_name, category, frequency, item_name, end_bal, 
-    beg_bal, prc_flag, create_time, update_time
+    id, organization_id, project_id, `date`, `source`, tms_period, period, `status`, 
+    ledger_id, ledger_name, ledger_currency_code, entity_code, entity_name, category, 
+    frequency, item_name, end_bal, beg_bal, prc_flag, create_time, update_time
   </sql>
   <select id="selectByExample" parameterType="pwc.taxtech.atms.vat.entity.BalanceSheetExample" resultMap="BaseResultMap">
     <!--
@@ -154,19 +155,21 @@
       This element is automatically generated by MyBatis Generator, do not modify.
     -->
     insert into balance_sheet (id, organization_id, project_id, 
-      `date`, `source`, period, 
-      `status`, ledger_id, ledger_name, 
-      ledger_currency_code, entity_code, entity_name, 
-      category, frequency, item_name, 
-      end_bal, beg_bal, prc_flag, 
-      create_time, update_time)
+      `date`, `source`, tms_period, 
+      period, `status`, ledger_id, 
+      ledger_name, ledger_currency_code, entity_code, 
+      entity_name, category, frequency, 
+      item_name, end_bal, beg_bal, 
+      prc_flag, create_time, update_time
+      )
     values (#{id,jdbcType=BIGINT}, #{organizationId,jdbcType=VARCHAR}, #{projectId,jdbcType=VARCHAR}, 
-      #{date,jdbcType=TIMESTAMP}, #{source,jdbcType=VARCHAR}, #{period,jdbcType=INTEGER}, 
-      #{status,jdbcType=VARCHAR}, #{ledgerId,jdbcType=VARCHAR}, #{ledgerName,jdbcType=VARCHAR}, 
-      #{ledgerCurrencyCode,jdbcType=VARCHAR}, #{entityCode,jdbcType=VARCHAR}, #{entityName,jdbcType=VARCHAR}, 
-      #{category,jdbcType=VARCHAR}, #{frequency,jdbcType=VARCHAR}, #{itemName,jdbcType=VARCHAR}, 
-      #{endBal,jdbcType=DECIMAL}, #{begBal,jdbcType=DECIMAL}, #{prcFlag,jdbcType=BIT}, 
-      #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})
+      #{date,jdbcType=TIMESTAMP}, #{source,jdbcType=VARCHAR}, #{tmsPeriod,jdbcType=INTEGER}, 
+      #{period,jdbcType=INTEGER}, #{status,jdbcType=VARCHAR}, #{ledgerId,jdbcType=VARCHAR}, 
+      #{ledgerName,jdbcType=VARCHAR}, #{ledgerCurrencyCode,jdbcType=VARCHAR}, #{entityCode,jdbcType=VARCHAR}, 
+      #{entityName,jdbcType=VARCHAR}, #{category,jdbcType=VARCHAR}, #{frequency,jdbcType=VARCHAR}, 
+      #{itemName,jdbcType=VARCHAR}, #{endBal,jdbcType=DECIMAL}, #{begBal,jdbcType=DECIMAL}, 
+      #{prcFlag,jdbcType=BIT}, #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}
+      )
   </insert>
   <insert id="insertSelective" parameterType="pwc.taxtech.atms.vat.entity.BalanceSheet">
     <!--
@@ -190,6 +193,9 @@
       <if test="source != null">
         `source`,
       </if>
+      <if test="tmsPeriod != null">
+        tms_period,
+      </if>
       <if test="period != null">
         period,
       </if>
@@ -252,6 +258,9 @@
       <if test="source != null">
         #{source,jdbcType=VARCHAR},
       </if>
+      <if test="tmsPeriod != null">
+        #{tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="period != null">
         #{period,jdbcType=INTEGER},
       </if>
@@ -331,6 +340,9 @@
       <if test="record.source != null">
         `source` = #{record.source,jdbcType=VARCHAR},
       </if>
+      <if test="record.tmsPeriod != null">
+        tms_period = #{record.tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="record.period != null">
         period = #{record.period,jdbcType=INTEGER},
       </if>
@@ -392,6 +404,7 @@
       project_id = #{record.projectId,jdbcType=VARCHAR},
       `date` = #{record.date,jdbcType=TIMESTAMP},
       `source` = #{record.source,jdbcType=VARCHAR},
+      tms_period = #{record.tmsPeriod,jdbcType=INTEGER},
       period = #{record.period,jdbcType=INTEGER},
       `status` = #{record.status,jdbcType=VARCHAR},
       ledger_id = #{record.ledgerId,jdbcType=VARCHAR},
@@ -430,6 +443,9 @@
       <if test="source != null">
         `source` = #{source,jdbcType=VARCHAR},
       </if>
+      <if test="tmsPeriod != null">
+        tms_period = #{tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="period != null">
         period = #{period,jdbcType=INTEGER},
       </if>
@@ -488,6 +504,7 @@
       project_id = #{projectId,jdbcType=VARCHAR},
       `date` = #{date,jdbcType=TIMESTAMP},
       `source` = #{source,jdbcType=VARCHAR},
+      tms_period = #{tmsPeriod,jdbcType=INTEGER},
       period = #{period,jdbcType=INTEGER},
       `status` = #{status,jdbcType=VARCHAR},
       ledger_id = #{ledgerId,jdbcType=VARCHAR},

atms-dao/src/main/resources/pwc/taxtech/atms/vat/dao/ProfitLossStatementMapper.xml

@@ -11,6 +11,7 @@
     <result column="project_id" jdbcType="VARCHAR" property="projectId" />
     <result column="date" jdbcType="TIMESTAMP" property="date" />
     <result column="source" jdbcType="VARCHAR" property="source" />
+    <result column="tms_period" jdbcType="INTEGER" property="tmsPeriod" />
     <result column="period" jdbcType="INTEGER" property="period" />
     <result column="status" jdbcType="VARCHAR" property="status" />
     <result column="ledger_id" jdbcType="VARCHAR" property="ledgerId" />
@@ -98,9 +99,9 @@
       WARNING - @mbg.generated
       This element is automatically generated by MyBatis Generator, do not modify.
     -->
-    id, organization_id, project_id, `date`, `source`, period, `status`, ledger_id, ledger_name, 
-    ledger_currency_code, entity_code, entity_name, category, frequency, item_name, period_amt, 
-    ytd_amt, prc_flag, create_time, update_time
+    id, organization_id, project_id, `date`, `source`, tms_period, period, `status`, 
+    ledger_id, ledger_name, ledger_currency_code, entity_code, entity_name, category, 
+    frequency, item_name, period_amt, ytd_amt, prc_flag, create_time, update_time
   </sql>
   <select id="selectByExample" parameterType="pwc.taxtech.atms.vat.entity.ProfitLossStatementExample" resultMap="BaseResultMap">
     <!--
@@ -154,19 +155,21 @@
       This element is automatically generated by MyBatis Generator, do not modify.
     -->
     insert into profit_loss_statement (id, organization_id, project_id, 
-      `date`, `source`, period, 
-      `status`, ledger_id, ledger_name, 
-      ledger_currency_code, entity_code, entity_name, 
-      category, frequency, item_name, 
-      period_amt, ytd_amt, prc_flag, 
-      create_time, update_time)
+      `date`, `source`, tms_period, 
+      period, `status`, ledger_id, 
+      ledger_name, ledger_currency_code, entity_code, 
+      entity_name, category, frequency, 
+      item_name, period_amt, ytd_amt, 
+      prc_flag, create_time, update_time
+      )
     values (#{id,jdbcType=BIGINT}, #{organizationId,jdbcType=VARCHAR}, #{projectId,jdbcType=VARCHAR}, 
-      #{date,jdbcType=TIMESTAMP}, #{source,jdbcType=VARCHAR}, #{period,jdbcType=INTEGER}, 
-      #{status,jdbcType=VARCHAR}, #{ledgerId,jdbcType=VARCHAR}, #{ledgerName,jdbcType=VARCHAR}, 
-      #{ledgerCurrencyCode,jdbcType=VARCHAR}, #{entityCode,jdbcType=VARCHAR}, #{entityName,jdbcType=VARCHAR}, 
-      #{category,jdbcType=VARCHAR}, #{frequency,jdbcType=VARCHAR}, #{itemName,jdbcType=VARCHAR}, 
-      #{periodAmt,jdbcType=DECIMAL}, #{ytdAmt,jdbcType=DECIMAL}, #{prcFlag,jdbcType=BIT}, 
-      #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})
+      #{date,jdbcType=TIMESTAMP}, #{source,jdbcType=VARCHAR}, #{tmsPeriod,jdbcType=INTEGER}, 
+      #{period,jdbcType=INTEGER}, #{status,jdbcType=VARCHAR}, #{ledgerId,jdbcType=VARCHAR}, 
+      #{ledgerName,jdbcType=VARCHAR}, #{ledgerCurrencyCode,jdbcType=VARCHAR}, #{entityCode,jdbcType=VARCHAR}, 
+      #{entityName,jdbcType=VARCHAR}, #{category,jdbcType=VARCHAR}, #{frequency,jdbcType=VARCHAR}, 
+      #{itemName,jdbcType=VARCHAR}, #{periodAmt,jdbcType=DECIMAL}, #{ytdAmt,jdbcType=DECIMAL}, 
+      #{prcFlag,jdbcType=BIT}, #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}
+      )
   </insert>
   <insert id="insertSelective" parameterType="pwc.taxtech.atms.vat.entity.ProfitLossStatement">
     <!--
@@ -190,6 +193,9 @@
       <if test="source != null">
         `source`,
       </if>
+      <if test="tmsPeriod != null">
+        tms_period,
+      </if>
       <if test="period != null">
         period,
       </if>
@@ -252,6 +258,9 @@
       <if test="source != null">
         #{source,jdbcType=VARCHAR},
       </if>
+      <if test="tmsPeriod != null">
+        #{tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="period != null">
         #{period,jdbcType=INTEGER},
       </if>
@@ -331,6 +340,9 @@
       <if test="record.source != null">
         `source` = #{record.source,jdbcType=VARCHAR},
       </if>
+      <if test="record.tmsPeriod != null">
+        tms_period = #{record.tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="record.period != null">
         period = #{record.period,jdbcType=INTEGER},
       </if>
@@ -392,6 +404,7 @@
       project_id = #{record.projectId,jdbcType=VARCHAR},
       `date` = #{record.date,jdbcType=TIMESTAMP},
       `source` = #{record.source,jdbcType=VARCHAR},
+      tms_period = #{record.tmsPeriod,jdbcType=INTEGER},
       period = #{record.period,jdbcType=INTEGER},
       `status` = #{record.status,jdbcType=VARCHAR},
       ledger_id = #{record.ledgerId,jdbcType=VARCHAR},
@@ -430,6 +443,9 @@
       <if test="source != null">
         `source` = #{source,jdbcType=VARCHAR},
       </if>
+      <if test="tmsPeriod != null">
+        tms_period = #{tmsPeriod,jdbcType=INTEGER},
+      </if>
       <if test="period != null">
         period = #{period,jdbcType=INTEGER},
       </if>
@@ -488,6 +504,7 @@
       project_id = #{projectId,jdbcType=VARCHAR},
       `date` = #{date,jdbcType=TIMESTAMP},
       `source` = #{source,jdbcType=VARCHAR},
+      tms_period = #{tmsPeriod,jdbcType=INTEGER},
       period = #{period,jdbcType=INTEGER},
       `status` = #{status,jdbcType=VARCHAR},
       ledger_id = #{ledgerId,jdbcType=VARCHAR},

atms-dao/src/main/resources/pwc/taxtech/atms/vat/dao/extends/BalanceSheetExtendsMapper.xml

+<?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="pwc.taxtech.atms.vat.dao.BalanceSheetMapper">
+
+  <sql id="QueryCondition">
+    1 = 1
+    <if test="@com.github.pagehelper.util.StringUtil@isNotEmpty(bsCondition.orgId)">
+      AND organization_id= #{bsCondition.orgId,jdbcType=INTEGER}
+    </if>
+    <if test="bsCondition.periodStart!=null">
+      AND period &gt;= #{bsCondition.periodStart,jdbcType=INTEGER}
+    </if>
+    <if test="bsCondition.periodEnd!=null">
+      AND period &lt;= #{bsCondition.periodEnd,jdbcType=INTEGER}
+    </if>
+  </sql>
+
+  <select id="selectByCondition" parameterType="pwc.taxtech.atms.vat.dpo.BalanceSheetCondition" resultMap="BaseResultMap">
+    SELECT
+    bs.*
+    FROM
+    balance_sheet bs
+    WHERE
+    <include refid="QueryCondition"/>
+  </select>
+
+  <insert id="insertBatch" parameterType="java.util.List">
+    insert into balance_sheet
+    (<include refid="Base_Column_List"/>)
+    values
+    <foreach collection="list" item="item" index="index" separator=",">
+      <trim prefix="(" suffix=")" suffixOverrides=",">
+        <choose>
+          <when test="item.id != null">#{item.id,jdbcType=BIGINT},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.organizationId != null">#{item.organizationId,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.projectId != null">#{item.projectId,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.date != null">#{item.date,jdbcType=TIMESTAMP},</when>
+          <otherwise>CURRENT_TIMESTAMP,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.source != null">#{item.source,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.tmsPeriod != null">#{item.tmsPeriod,jdbcType=INTEGER},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.period != null">#{item.period,jdbcType=INTEGER},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.status != null">#{item.status,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.ledgerId != null">#{item.ledgerId,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.ledgerName != null">#{item.ledgerName,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.ledgerCurrencyCode != null">#{item.ledgerCurrencyCode,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.entityCode != null">#{item.entityCode,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.entityName != null">#{item.entityName,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.category != null">#{item.category,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.frequency != null">#{item.frequency,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.itemName != null">#{item.itemName,jdbcType=VARCHAR},</when>
+          <otherwise>'',</otherwise>
+        </choose>
+        <choose>
+          <when test="item.endBal != null">#{item.endBal,jdbcType=DECIMAL},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.begBal != null">#{item.begBal,jdbcType=DECIMAL},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.prcFlag != null">#{item.prcFlag,jdbcType=BIT},</when>
+          <otherwise>0,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.createTime != null">#{item.createTime,jdbcType=TIMESTAMP},</when>
+          <otherwise>CURRENT_TIMESTAMP,</otherwise>
+        </choose>
+        <choose>
+          <when test="item.updateTime != null">#{item.updateTime,jdbcType=TIMESTAMP},</when>
+          <otherwise>CURRENT_TIMESTAMP,</otherwise>
+        </choose>
+      </trim>
+    </foreach>;
+    SELECT 1 FROM DUAL;
+  </insert>
+
+</mapper>
\ No newline at end of file