推送数据 提交

mztb/src/main/java/cc/smtweb/biz/mztb/web/base/FillOut.java

@@ -5,7 +5,7 @@ import cc.smtweb.framework.core.common.SwMap;
 import cc.smtweb.framework.core.db.impl.DefaultEntity;
 
 /**
- * Created by 1 at 2023-12-19 11:07:02
+ * Created by 1 at 2024-01-04 11:08:42
  * 实体【[填报主表](TB_FILL_OUT)】的Entity类
  */
 @SwTable("TB_FILL_OUT")
@@ -79,4 +79,22 @@ public class FillOut extends DefaultEntity {
     public void setDate(long fo_date) {
         put("fo_date", fo_date);
     }
+    /** 填报机构Id */
+    public long getPartyId() {
+        return getLong("fo_party_id");
+    }
+
+    /** 填报机构Id */
+    public void setPartyId(long fo_party_id) {
+        put("fo_party_id", fo_party_id);
+    }
+    /** 读取时间 */
+    public long getReadTime() {
+        return getLong("fo_read_time");
+    }
+
+    /** 读取时间 */
+    public void setReadTime(long fo_read_time) {
+        put("fo_read_time", fo_read_time);
+    }
 }

mztb/src/main/java/cc/smtweb/biz/mztb/web/base/PartyInfo.java

@@ -5,7 +5,7 @@ import cc.smtweb.framework.core.common.SwMap;
 import cc.smtweb.framework.core.db.impl.DefaultEntity;
 
 /**
- * Created by 1 at 2023-12-19 11:07:08
+ * Created by 1 at 2024-01-03 17:14:35
  * 实体【[机构信息](TB_PARTY_INFO)】的Entity类
  */
 @SwTable("TB_PARTY_INFO")
@@ -151,4 +151,13 @@ public class PartyInfo extends DefaultEntity {
     public void setNationalEconomyType(String pi_national_economy_type) {
         put("pi_national_economy_type", pi_national_economy_type);
     }
+    /** 系统机构Id */
+    public long getSysPartyId() {
+        return getLong("pi_sys_party_id");
+    }
+
+    /** 系统机构Id */
+    public void setSysPartyId(long pi_sys_party_id) {
+        put("pi_sys_party_id", pi_sys_party_id);
+    }
 }

mztb/src/main/java/cc/smtweb/biz/mztb/web/base/partyDataFill/PartyDataFillHandler.java

@@ -4,6 +4,7 @@ import cc.smtweb.biz.mztb.web.base.*;
 import cc.smtweb.framework.core.common.SwMap;
 import cc.smtweb.framework.core.db.DbEngine;
 import cc.smtweb.framework.core.db.EntityHelper;
+import cc.smtweb.framework.core.db.cache.DictsCache;
 import cc.smtweb.framework.core.db.impl.DefaultEntity;
 import cc.smtweb.framework.core.util.DateUtil;
 import cc.smtweb.framework.core.util.StringUtil;
@@ -11,6 +12,7 @@ import cc.smtweb.system.bpm.web.engine.dynPage.DynRetBean;
 import cc.smtweb.system.bpm.web.engine.model.common.ModelListHandler;
 import cc.smtweb.system.bpm.web.engine.model.listcard.lcms.LCMsLoadHandler;
 import cc.smtweb.system.bpm.web.engine.model.listcard.lcms.LCMsSaveHandler;
+import cc.smtweb.system.bpm.web.sys.user.user.UserCache;
 
 import java.util.List;
 
@@ -76,12 +78,19 @@ public class PartyDataFillHandler {
             ((DynRetBean) card).getForm().put("fo_task_text",beanData.readString("fo_task").contains("99")
                     ? beanData.readString("fo_task").replace("99","年")
                     : String.format("%d年%02d月",beanData.readLong("fo_task") / 100, beanData.readLong("fo_task") % 100));
+            SwMap businessForm = ((DynRetBean) ret.get("businessForm")).getForm();
+            businessForm.put("bi_type_text", DictsCache.getInstance().getItemName("tbBusinessType",businessForm.readString("bi_type")));
+            businessForm.put("bi_property_text",DictsCache.getInstance().getItemName("tbNature",businessForm.readString("bi_property")));
+            businessForm.put("bi_initiate_text",DictsCache.getInstance().getItemName("tbSubject",businessForm.readString("bi_initiate")));
+            businessForm.put("bi_execute_regimen_text",DictsCache.getInstance().getItemName("tbKJZD",businessForm.readString("bi_execute_regimen")));
         }
 
         @Override
         protected void localAdd() {
             super.localAdd();
             bean.setDate(DateUtil.nowDateLong());
+            bean.setPartyId(params.readLong("CUR_PARTY_ID"));
+//            bean.setUser(UserCache.getInstance().getNameById(us.getUserId()));
 //            bean.setUpdateAt(DateUtil.nowDateLong());
             DbEngine instance = DbEngine.getInstance();
 //            bean.setUser(us.getUserId());

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/FillTask.java

@@ -1,6 +1,7 @@
 package cc.smtweb.biz.mztb.web.domian;
 
 import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
 import lombok.Data;
 
 @Data

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/PreBusinessInfo.java

@@ -0,0 +1,243 @@
+package cc.smtweb.biz.mztb.web.domian;
+
+import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
+
+/**
+ * Created by 1 at 2023-12-19 11:07:15
+ * 实体【[业务信息](PRE_BUSINESS_INFO)】的Entity类
+ */
+public class PreBusinessInfo extends DefaultEntity {
+    public static final String ENTITY_NAME = "PRE_BUSINESS_INFO";
+
+    public PreBusinessInfo() {
+        super(ENTITY_NAME);
+    }
+
+    /** 主键 */
+    public long getId() {
+        return getLong("bi_id");
+    }
+
+    /** 主键 */
+    public void setId(long bi_id) {
+        put("bi_id", bi_id);
+    }
+
+    /** 填报主表ID */
+    public long getFoId() {
+        return getLong("bi_fo_id");
+    }
+
+    /** 填报主表ID */
+    public void setFoId(long bi_fo_id) {
+        put("bi_fo_id", bi_fo_id);
+    }
+    /** 类型 */
+    public String getType() {
+        return getStr("bi_type");
+    }
+
+    /** 类型 */
+    public void setType(String bi_type) {
+        put("bi_type", bi_type);
+    }
+    /** 性质 */
+    public String getProperty() {
+        return getStr("bi_property");
+    }
+
+    /** 性质 */
+    public void setProperty(String bi_property) {
+        put("bi_property", bi_property);
+    }
+    /** 兴办主体 */
+    public String getInitiate() {
+        return getStr("bi_initiate");
+    }
+
+    /** 兴办主体 */
+    public void setInitiate(String bi_initiate) {
+        put("bi_initiate", bi_initiate);
+    }
+    /** 是否为所有权、经营权分离办公养老机构 */
+    public int getIsolate() {
+        return getInt("bi_isolate");
+    }
+
+    /** 是否为所有权、经营权分离办公养老机构 */
+    public void setIsolate(int bi_isolate) {
+        put("bi_isolate", bi_isolate);
+    }
+    /** 医疗机构执业许可证登记号 */
+    public String getMedicalCard() {
+        return getStr("bi_medical_card");
+    }
+
+    /** 医疗机构执业许可证登记号 */
+    public void setMedicalCard(String bi_medical_card) {
+        put("bi_medical_card", bi_medical_card);
+    }
+    /** 医疗保险定点医疗机构资格证书编码 */
+    public String getMedicalCode() {
+        return getStr("bi_medical_code");
+    }
+
+    /** 医疗保险定点医疗机构资格证书编码 */
+    public void setMedicalCode(String bi_medical_code) {
+        put("bi_medical_code", bi_medical_code);
+    }
+    /** 单位所在地区行政区划代码 */
+    public String getUnitAddressAreaCode() {
+        return getStr("bi_unit_address_area_code");
+    }
+
+    /** 单位所在地区行政区划代码 */
+    public void setUnitAddressAreaCode(String bi_unit_address_area_code) {
+        put("bi_unit_address_area_code", bi_unit_address_area_code);
+    }
+    /** 邮编 */
+    public String getPostcode() {
+        return getStr("bi_postcode");
+    }
+
+    /** 邮编 */
+    public void setPostcode(String bi_postcode) {
+        put("bi_postcode", bi_postcode);
+    }
+    /** 年末职工人数 */
+    public int getYearEndEmployeeNumber() {
+        return getInt("bi_year_end_employee_number");
+    }
+
+    /** 年末职工人数 */
+    public void setYearEndEmployeeNumber(int bi_year_end_employee_number) {
+        put("bi_year_end_employee_number", bi_year_end_employee_number);
+    }
+    /** 年末职工人数（女） */
+    public int getYearEndEmpMiss() {
+        return getInt("bi_year_end_emp_miss");
+    }
+
+    /** 年末职工人数（女） */
+    public void setYearEndEmpMiss(int bi_year_end_emp_miss) {
+        put("bi_year_end_emp_miss", bi_year_end_emp_miss);
+    }
+    /** 年末职工人数（男） */
+    public int getYearEndEmpMan() {
+        return getInt("bi_year_end_emp_man");
+    }
+
+    /** 年末职工人数（男） */
+    public void setYearEndEmpMan(int bi_year_end_emp_man) {
+        put("bi_year_end_emp_man", bi_year_end_emp_man);
+    }
+    /** 年末职工人数（医护人员） */
+    public int getYearEndMedic() {
+        return getInt("bi_year_end_medic");
+    }
+
+    /** 年末职工人数（医护人员） */
+    public void setYearEndMedic(int bi_year_end_medic) {
+        put("bi_year_end_medic", bi_year_end_medic);
+    }
+    /** 大学专科人数 */
+    public int getYearEndZk() {
+        return getInt("bi_year_end_zk");
+    }
+
+    /** 大学专科人数 */
+    public void setYearEndZk(int bi_year_end_zk) {
+        put("bi_year_end_zk", bi_year_end_zk);
+    }
+    /** 大学本科及以上人数 */
+    public int getYearEndBk() {
+        return getInt("bi_year_end_bk");
+    }
+
+    /** 大学本科及以上人数 */
+    public void setYearEndBk(int bi_year_end_bk) {
+        put("bi_year_end_bk", bi_year_end_bk);
+    }
+    /** 助理社会工作师人数 */
+    public int getAssistant() {
+        return getInt("bi_assistant");
+    }
+
+    /** 助理社会工作师人数 */
+    public void setAssistant(int bi_assistant) {
+        put("bi_assistant", bi_assistant);
+    }
+    /** 社会工作师人数 */
+    public int getEngineer() {
+        return getInt("bi_engineer");
+    }
+
+    /** 社会工作师人数 */
+    public void setEngineer(int bi_engineer) {
+        put("bi_engineer", bi_engineer);
+    }
+    /** 35岁及以下人数 */
+    public int getThirtyFive() {
+        return getInt("bi_thirty_five");
+    }
+
+    /** 35岁及以下人数 */
+    public void setThirtyFive(int bi_thirty_five) {
+        put("bi_thirty_five", bi_thirty_five);
+    }
+    /** 36-45岁人数 */
+    public int getFortyFive() {
+        return getInt("bi_forty_five");
+    }
+
+    /** 36-45岁人数 */
+    public void setFortyFive(int bi_forty_five) {
+        put("bi_forty_five", bi_forty_five);
+    }
+    /** 46-55岁人数 */
+    public int getFiftyFive() {
+        return getInt("bi_fifty_five");
+    }
+
+    /** 46-55岁人数 */
+    public void setFiftyFive(int bi_fifty_five) {
+        put("bi_fifty_five", bi_fifty_five);
+    }
+    /** 56岁以上人数 */
+    public int getFiftyFiveAbove() {
+        return getInt("bi_fifty_five_above");
+    }
+
+    /** 56岁以上人数 */
+    public void setFiftyFiveAbove(int bi_fifty_five_above) {
+        put("bi_fifty_five_above", bi_fifty_five_above);
+    }
+    /** 机构管理人员—专业技术技能人员 */
+    public int getPartyManageSp() {
+        return getInt("bi_party_manage_sp");
+    }
+
+    /** 机构管理人员—专业技术技能人员 */
+    public void setPartyManageSp(int bi_party_manage_sp) {
+        put("bi_party_manage_sp", bi_party_manage_sp);
+    }
+    /** 专业技术技能人员—养老护理员 */
+    public int getSpNursingAssistant() {
+        return getInt("bi_sp_nursing_assistant");
+    }
+
+    /** 专业技术技能人员—养老护理员 */
+    public void setSpNursingAssistant(int bi_sp_nursing_assistant) {
+        put("bi_sp_nursing_assistant", bi_sp_nursing_assistant);
+    }
+    /** 执行会计制度 */
+    public String getExecuteRegimen() {
+        return getStr("bi_execute_regimen");
+    }
+
+    /** 执行会计制度 */
+    public void setExecuteRegimen(String bi_execute_regimen) {
+        put("bi_execute_regimen", bi_execute_regimen);
+    }
+}

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/PreFillOut.java

@@ -0,0 +1,72 @@
+package cc.smtweb.biz.mztb.web.domian;
+
+import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
+
+/**
+ * Created by 1 at 2023-12-19 11:07:02
+ * 实体【[填报主表](PRE_FILL_OUT)】的Entity类
+ */
+public class PreFillOut extends DefaultEntity {
+    public static final String ENTITY_NAME = "PRE_FILL_OUT";
+
+    public PreFillOut() {
+        super(ENTITY_NAME);
+    }
+
+    /** 主键 */
+    public long getId() {
+        return getLong("fo_id");
+    }
+
+    /** 主键 */
+    public void setId(long fo_id) {
+        put("fo_id", fo_id);
+    }
+
+    /** 任务月 */
+    public long getTask() {
+        return getLong("fo_task");
+    }
+
+    /** 任务月 */
+    public void setTask(long fo_task) {
+        put("fo_task", fo_task);
+    }
+    /** 填报类型 */
+    public int getType() {
+        return getInt("fo_type");
+    }
+
+    /** 填报类型 */
+    public void setType(int fo_type) {
+        put("fo_type", fo_type);
+    }
+    /** 状态 */
+    public int getState() {
+        return getInt("fo_state");
+    }
+
+    /** 状态 */
+    public void setState(int fo_state) {
+        put("fo_state", fo_state);
+    }
+    /** 填报人 */
+    public String getUser() {
+        return getStr("fo_user");
+    }
+
+    /** 填报人 */
+    public void setUser(String fo_user) {
+        put("fo_user", fo_user);
+    }
+    /** 填报时间 */
+    public long getDate() {
+        return getLong("fo_date");
+    }
+
+    /** 填报时间 */
+    public void setDate(long fo_date) {
+        put("fo_date", fo_date);
+    }
+}

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/PreFinanceInfo.java

@@ -0,0 +1,567 @@
+package cc.smtweb.biz.mztb.web.domian;
+
+import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
+
+/**
+ * Created by 1 at 2023-12-19 11:07:05
+ * 实体【[财务信息](PRE_FINANCE_INFO)】的Entity类
+ */
+public class PreFinanceInfo extends DefaultEntity {
+    public static final String ENTITY_NAME = "PRE_FINANCE_INFO";
+
+    public PreFinanceInfo() {
+        super(ENTITY_NAME);
+    }
+
+    /** 主键 */
+    public long getId() {
+        return getLong("fi_id");
+    }
+
+    /** 主键 */
+    public void setId(long fi_id) {
+        put("fi_id", fi_id);
+    }
+
+    /** 填报主表ID */
+    public long getFoId() {
+        return getLong("fi_fo_id");
+    }
+
+    /** 填报主表ID */
+    public void setFoId(long fi_fo_id) {
+        put("fi_fo_id", fi_fo_id);
+    }
+    /** 存货 */
+    public long getStock() {
+        return getLong("fi_stock");
+    }
+
+    /** 存货 */
+    public void setStock(long fi_stock) {
+        put("fi_stock", fi_stock);
+    }
+    /** 固定资产原价 */
+    public long getFixedAssets() {
+        return getLong("fi_fixed_assets");
+    }
+
+    /** 固定资产原价 */
+    public void setFixedAssets(long fi_fixed_assets) {
+        put("fi_fixed_assets", fi_fixed_assets);
+    }
+    /** 累计折旧 */
+    public long getGrandTotalDepr() {
+        return getLong("fi_grand_total_depr");
+    }
+
+    /** 累计折旧 */
+    public void setGrandTotalDepr(long fi_grand_total_depr) {
+        put("fi_grand_total_depr", fi_grand_total_depr);
+    }
+    /** 累计折旧（本年折旧） */
+    public long getGtdYear() {
+        return getLong("fi_gtd_year");
+    }
+
+    /** 累计折旧（本年折旧） */
+    public void setGtdYear(long fi_gtd_year) {
+        put("fi_gtd_year", fi_gtd_year);
+    }
+    /** 资产总计 */
+    public long getPropertyTotal() {
+        return getLong("fi_property_total");
+    }
+
+    /** 资产总计 */
+    public void setPropertyTotal(long fi_property_total) {
+        put("fi_property_total", fi_property_total);
+    }
+    /** 负债合计 */
+    public long getLiabilitiesTotal() {
+        return getLong("fi_liabilities_total");
+    }
+
+    /** 负债合计 */
+    public void setLiabilitiesTotal(long fi_liabilities_total) {
+        put("fi_liabilities_total", fi_liabilities_total);
+    }
+    /** 营业收入 */
+    public long getOperationRevenue() {
+        return getLong("fi_operation_revenue");
+    }
+
+    /** 营业收入 */
+    public void setOperationRevenue(long fi_operation_revenue) {
+        put("fi_operation_revenue", fi_operation_revenue);
+    }
+    /** 营业成本 */
+    public long getOperatingCosts() {
+        return getLong("fi_operating_costs");
+    }
+
+    /** 营业成本 */
+    public void setOperatingCosts(long fi_operating_costs) {
+        put("fi_operating_costs", fi_operating_costs);
+    }
+    /** 营业税金及附加 */
+    public long getTaxes() {
+        return getLong("fi_taxes");
+    }
+
+    /** 营业税金及附加 */
+    public void setTaxes(long fi_taxes) {
+        put("fi_taxes", fi_taxes);
+    }
+    /** 销售费用 */
+    public long getSellCost() {
+        return getLong("fi_sell_cost");
+    }
+
+    /** 销售费用 */
+    public void setSellCost(long fi_sell_cost) {
+        put("fi_sell_cost", fi_sell_cost);
+    }
+    /** 管理费用 */
+    public long getManageCost() {
+        return getLong("fi_manage_cost");
+    }
+
+    /** 管理费用 */
+    public void setManageCost(long fi_manage_cost) {
+        put("fi_manage_cost", fi_manage_cost);
+    }
+    /** 管理费用（税金） */
+    public long getMcTaxes() {
+        return getLong("fi_mc_taxes");
+    }
+
+    /** 管理费用（税金） */
+    public void setMcTaxes(long fi_mc_taxes) {
+        put("fi_mc_taxes", fi_mc_taxes);
+    }
+    /** 管理费用（差旅费） */
+    public long getMcTravel() {
+        return getLong("fi_mc_travel");
+    }
+
+    /** 管理费用（差旅费） */
+    public void setMcTravel(long fi_mc_travel) {
+        put("fi_mc_travel", fi_mc_travel);
+    }
+    /** 财务费用 */
+    public long getFinanceCost() {
+        return getLong("fi_finance_cost");
+    }
+
+    /** 财务费用 */
+    public void setFinanceCost(long fi_finance_cost) {
+        put("fi_finance_cost", fi_finance_cost);
+    }
+    /** 财务费用（利息净支出） */
+    public long getFcInterests() {
+        return getLong("fi_fc_interests");
+    }
+
+    /** 财务费用（利息净支出） */
+    public void setFcInterests(long fi_fc_interests) {
+        put("fi_fc_interests", fi_fc_interests);
+    }
+    /** 资产减值损失 */
+    public long getAssetLoss() {
+        return getLong("fi_asset_loss");
+    }
+
+    /** 资产减值损失 */
+    public void setAssetLoss(long fi_asset_loss) {
+        put("fi_asset_loss", fi_asset_loss);
+    }
+    /** 公允价值变动收益 */
+    public long getFairValueChanage() {
+        return getLong("fi_fair_value_chanage");
+    }
+
+    /** 公允价值变动收益 */
+    public void setFairValueChanage(long fi_fair_value_chanage) {
+        put("fi_fair value_chanage", fi_fair_value_chanage);
+    }
+    /** 投资收益 */
+    public long getIncomeFromInvestment() {
+        return getLong("fi_income_from_investment");
+    }
+
+    /** 投资收益 */
+    public void setIncomeFromInvestment(long fi_income_from_investment) {
+        put("fi_income_from_investment", fi_income_from_investment);
+    }
+    /** 营业利润 */
+    public long getOperatingProfit() {
+        return getLong("fi_operating_profit");
+    }
+
+    /** 营业利润 */
+    public void setOperatingProfit(long fi_operating_profit) {
+        put("fi_operating_profit", fi_operating_profit);
+    }
+    /** 营业外收入 */
+    public long getNonbusinessIncome() {
+        return getLong("fi_nonbusiness_income");
+    }
+
+    /** 营业外收入 */
+    public void setNonbusinessIncome(long fi_nonbusiness_income) {
+        put("fi_nonbusiness_income", fi_nonbusiness_income);
+    }
+    /** 营业外收入（政府补助） */
+    public long getNiPublicSubsidy() {
+        return getLong("fi_ni_public_subsidy");
+    }
+
+    /** 营业外收入（政府补助） */
+    public void setNiPublicSubsidy(long fi_ni_public_subsidy) {
+        put("fi_ni_public_subsidy", fi_ni_public_subsidy);
+    }
+    /** 应付职工底薪 */
+    public long getBasePay() {
+        return getLong("fi_base_pay");
+    }
+
+    /** 应付职工底薪 */
+    public void setBasePay(long fi_base_pay) {
+        put("fi_base_pay", fi_base_pay);
+    }
+    /** 本年应交增值税 */
+    public long getPayableMoneyYear() {
+        return getLong("fi_payable_money_year");
+    }
+
+    /** 本年应交增值税 */
+    public void setPayableMoneyYear(long fi_payable_money_year) {
+        put("fi_payable_money_year", fi_payable_money_year);
+    }
+    /** 本年收入合计 */
+    public long getYearIncomeTotal() {
+        return getLong("fi_year_income_total");
+    }
+
+    /** 本年收入合计 */
+    public void setYearIncomeTotal(long fi_year_income_total) {
+        put("fi_year_income_total", fi_year_income_total);
+    }
+    /** 本年收入合计（事业收入） */
+    public long getYitEnterpricse() {
+        return getLong("fi_yit_enterpricse");
+    }
+
+    /** 本年收入合计（事业收入） */
+    public void setYitEnterpricse(long fi_yit_enterpricse) {
+        put("fi_yit_enterpricse", fi_yit_enterpricse);
+    }
+    /** 本年收入合计（捐赠收入） */
+    public long getYitDonation() {
+        return getLong("fi_yit_donation");
+    }
+
+    /** 本年收入合计（捐赠收入） */
+    public void setYitDonation(long fi_yit_donation) {
+        put("fi_yit_donation", fi_yit_donation);
+    }
+    /** 本年收入合计（经营收入） */
+    public long getYitBusiness() {
+        return getLong("fi_yit_business");
+    }
+
+    /** 本年收入合计（经营收入） */
+    public void setYitBusiness(long fi_yit_business) {
+        put("fi_yit_business", fi_yit_business);
+    }
+    /** 本年收入合计（政府补助收入） */
+    public long getYitSubsidy() {
+        return getLong("fi_yit_subsidy");
+    }
+
+    /** 本年收入合计（政府补助收入） */
+    public void setYitSubsidy(long fi_yit_subsidy) {
+        put("fi_yit_subsidy", fi_yit_subsidy);
+    }
+    /** 本年收入合计（会费收入） */
+    public long getYitMembershiopFees() {
+        return getLong("fi_yit_membershiop_fees");
+    }
+
+    /** 本年收入合计（会费收入） */
+    public void setYitMembershiopFees(long fi_yit_membershiop_fees) {
+        put("fi_yit_membershiop_fees", fi_yit_membershiop_fees);
+    }
+    /** 本年支出合计 */
+    public long getYearExpend() {
+        return getLong("fi_year_expend");
+    }
+
+    /** 本年支出合计 */
+    public void setYearExpend(long fi_year_expend) {
+        put("fi_year_expend", fi_year_expend);
+    }
+    /** 本年支出合计（商品和服务支出） */
+    public long getYeCommodityService() {
+        return getLong("fi_ye_commodity_service");
+    }
+
+    /** 本年支出合计（商品和服务支出） */
+    public void setYeCommodityService(long fi_ye_commodity_service) {
+        put("fi_ye_commodity_service", fi_ye_commodity_service);
+    }
+    /** 商品和服务支出（取暖费） */
+    public long getCsHeatingFee() {
+        return getLong("fi_cs_heating_fee");
+    }
+
+    /** 商品和服务支出（取暖费） */
+    public void setCsHeatingFee(long fi_cs_heating_fee) {
+        put("fi_cs_heating_fee", fi_cs_heating_fee);
+    }
+    /** 商品和服务支出（差旅费） */
+    public long getCsTravelExpense() {
+        return getLong("fi_cs_travel_expense");
+    }
+
+    /** 商品和服务支出（差旅费） */
+    public void setCsTravelExpense(long fi_cs_travel_expense) {
+        put("fi_cs_travel_expense", fi_cs_travel_expense);
+    }
+    /** 商品和服务支出（因公出国 / 境费） */
+    public long getCsGoAbroad() {
+        return getLong("fi_cs_go_abroad");
+    }
+
+    /** 商品和服务支出（因公出国 / 境费） */
+    public void setCsGoAbroad(long fi_cs_go_abroad) {
+        put("fi_cs_go_abroad", fi_cs_go_abroad);
+    }
+    /** 商品和服务支出（劳务费） */
+    public long getCsServiceFee() {
+        return getLong("fi_cs_service_fee");
+    }
+
+    /** 商品和服务支出（劳务费） */
+    public void setCsServiceFee(long fi_cs_service_fee) {
+        put("fi_cs_service_fee", fi_cs_service_fee);
+    }
+    /** 商品和服务支出（工会经费） */
+    public long getCsExpend() {
+        return getLong("fi_cs_expend");
+    }
+
+    /** 商品和服务支出（工会经费） */
+    public void setCsExpend(long fi_cs_expend) {
+        put("fi_cs_expend", fi_cs_expend);
+    }
+    /** 商品和服务支出（福利费） */
+    public long getCsWeal() {
+        return getLong("fi_cs_weal");
+    }
+
+    /** 商品和服务支出（福利费） */
+    public void setCsWeal(long fi_cs_weal) {
+        put("fi_cs_weal", fi_cs_weal);
+    }
+    /** 本年支出合计（对个人和家庭补助支出） */
+    public long getYcsPersonageFamilyFee() {
+        return getLong("fi_ycs_personage_family_fee");
+    }
+
+    /** 本年支出合计（对个人和家庭补助支出） */
+    public void setYcsPersonageFamilyFee(long fi_ycs_personage_family_fee) {
+        put("fi_ycs_personage_family_fee", fi_ycs_personage_family_fee);
+    }
+    /** 对个人和家庭补助支出（抚恤金） */
+    public long getPffFuxue() {
+        return getLong("fi_pff_fuxue");
+    }
+
+    /** 对个人和家庭补助支出（抚恤金） */
+    public void setPffFuxue(long fi_pff_fuxue) {
+        put("fi_pff_fuxue", fi_pff_fuxue);
+    }
+    /** 对个人和家庭补助支出（生活补助） */
+    public long getPffLivingSubsidy() {
+        return getLong("fi_pff_living_subsidy");
+    }
+
+    /** 对个人和家庭补助支出（生活补助） */
+    public void setPffLivingSubsidy(long fi_pff_living_subsidy) {
+        put("fi_pff_living_subsidy", fi_pff_living_subsidy);
+    }
+    /** 对个人和家庭补助支出（救济费） */
+    public long getPffRelief() {
+        return getLong("fi_pff_relief");
+    }
+
+    /** 对个人和家庭补助支出（救济费） */
+    public void setPffRelief(long fi_pff_relief) {
+        put("fi_pff_relief", fi_pff_relief);
+    }
+    /** 对个人和家庭补助支出（助学金） */
+    public long getPffStudentGrent() {
+        return getLong("fi_pff_student_grent");
+    }
+
+    /** 对个人和家庭补助支出（助学金） */
+    public void setPffStudentGrent(long fi_pff_student_grent) {
+        put("fi_pff_student_grent", fi_pff_student_grent);
+    }
+    /** 对个人和家庭补助支出（奖励金） */
+    public long getPffBounty() {
+        return getLong("fi_pff_bounty");
+    }
+
+    /** 对个人和家庭补助支出（奖励金） */
+    public void setPffBounty(long fi_pff_bounty) {
+        put("fi_pff_bounty", fi_pff_bounty);
+    }
+    /** 对个人和家庭补助支出（生产补贴） */
+    public long getPffSubsidy() {
+        return getLong("fi_pff_subsidy");
+    }
+
+    /** 对个人和家庭补助支出（生产补贴） */
+    public void setPffSubsidy(long fi_pff_subsidy) {
+        put("fi_pff_subsidy", fi_pff_subsidy);
+    }
+    /** 本年支出合计（工资福利支出） */
+    public long getYcsSalary() {
+        return getLong("fi_ycs_salary");
+    }
+
+    /** 本年支出合计（工资福利支出） */
+    public void setYcsSalary(long fi_ycs_salary) {
+        put("fi_ycs_salary", fi_ycs_salary);
+    }
+    /** 本年支出合计（经营支出） */
+    public long getYcsOperatingExpense() {
+        return getLong("fi_ycs_operating_expense");
+    }
+
+    /** 本年支出合计（经营支出） */
+    public void setYcsOperatingExpense(long fi_ycs_operating_expense) {
+        put("fi_ycs_operating_expense", fi_ycs_operating_expense);
+    }
+    /** 销售税金 */
+    public long getSellFee() {
+        return getLong("fi_sell_fee");
+    }
+
+    /** 销售税金 */
+    public void setSellFee(long fi_sell_fee) {
+        put("fi_sell_fee", fi_sell_fee);
+    }
+    /** 本年费用合计 */
+    public long getYearSumFee() {
+        return getLong("fi_year_sum_fee");
+    }
+
+    /** 本年费用合计 */
+    public void setYearSumFee(long fi_year_sum_fee) {
+        put("fi_year_sum_fee", fi_year_sum_fee);
+    }
+    /** 本年费用合计（业务活动成本） */
+    public long getYsfBusinessFee() {
+        return getLong("fi_ysf_business_fee");
+    }
+
+    /** 本年费用合计（业务活动成本） */
+    public void setYsfBusinessFee(long fi_ysf_business_fee) {
+        put("fi_ysf_business_fee", fi_ysf_business_fee);
+    }
+    /** 业务活动成本（人员费用） */
+    public long getBfStaffCosts() {
+        return getLong("fi_bf_staff_costs");
+    }
+
+    /** 业务活动成本（人员费用） */
+    public void setBfStaffCosts(long fi_bf_staff_costs) {
+        put("fi_bf_staff_costs", fi_bf_staff_costs);
+    }
+    /** 业务活动成本（日常费用） */
+    public long getBfEveryDayFee() {
+        return getLong("fi_bf_every_day_fee");
+    }
+
+    /** 业务活动成本（日常费用） */
+    public void setBfEveryDayFee(long fi_bf_every_day_fee) {
+        put("fi_bf_every_day_fee", fi_bf_every_day_fee);
+    }
+    /** 业务活动成本（固定资产折旧） */
+    public long getBfAssets() {
+        return getLong("fi_bf_assets");
+    }
+
+    /** 业务活动成本（固定资产折旧） */
+    public void setBfAssets(long fi_bf_assets) {
+        put("fi_bf_assets", fi_bf_assets);
+    }
+    /** 业务活动成本（税费） */
+    public long getBfTax() {
+        return getLong("fi_bf_tax");
+    }
+
+    /** 业务活动成本（税费） */
+    public void setBfTax(long fi_bf_tax) {
+        put("fi_bf_tax", fi_bf_tax);
+    }
+    /** 本年费用合计（管理费用） */
+    public long getYsfMenageFee() {
+        return getLong("fi_ysf_menage_fee");
+    }
+
+    /** 本年费用合计（管理费用） */
+    public void setYsfMenageFee(long fi_ysf_menage_fee) {
+        put("fi_ysf_menage_fee", fi_ysf_menage_fee);
+    }
+    /** 管理费用（人员费用） */
+    public long getMfStaffCosts() {
+        return getLong("fi_mf_staff_costs");
+    }
+
+    /** 管理费用（人员费用） */
+    public void setMfStaffCosts(long fi_mf_staff_costs) {
+        put("fi_mf_staff_costs", fi_mf_staff_costs);
+    }
+    /** 管理费用（日常费用） */
+    public long getMfEveryDayFee() {
+        return getLong("fi_mf_every_day_fee");
+    }
+
+    /** 管理费用（日常费用） */
+    public void setMfEveryDayFee(long fi_mf_every_day_fee) {
+        put("fi_mf_every_day_fee", fi_mf_every_day_fee);
+    }
+    /** 管理费用（固定资产折旧） */
+    public long getMfAssets() {
+        return getLong("fi_mf_assets");
+    }
+
+    /** 管理费用（固定资产折旧） */
+    public void setMfAssets(long fi_mf_assets) {
+        put("fi_mf_assets", fi_mf_assets);
+    }
+    /** 管理费用（税费） */
+    public long getMfTax() {
+        return getLong("fi_mf_tax");
+    }
+
+    /** 管理费用（税费） */
+    public void setMfTax(long fi_mf_tax) {
+        put("fi_mf_tax", fi_mf_tax);
+    }
+    /** 净资产变动额 */
+    public long getChangeInNotAssets() {
+        return getLong("fi_change_in_not_assets");
+    }
+
+    /** 净资产变动额 */
+    public void setChangeInNotAssets(long fi_change_in_not_assets) {
+        put("fi_change_in_not_assets", fi_change_in_not_assets);
+    }
+}

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/PrePartyInfo.java

@@ -0,0 +1,154 @@
+package cc.smtweb.biz.mztb.web.domian;
+
+import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.common.SwMap;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
+
+/**
+ * Created by 1 at 2024-01-03 17:14:35
+ * 实体【[机构信息]PrePartyInfo
+ */
+public class PrePartyInfo extends DefaultEntity {
+    public static final String ENTITY_NAME = "PRE_PARTY_INFO";
+
+    public PrePartyInfo() {
+        super(ENTITY_NAME);
+    }
+
+    /** 主键 */
+    public long getId() {
+        return getLong("pi_id");
+    }
+
+    /** 主键 */
+    public void setId(long pi_id) {
+        put("pi_id", pi_id);
+    }
+
+    /** 单位名称 */
+    public String getPartyName() {
+        return getStr("pi_party_name");
+    }
+
+    /** 单位名称 */
+    public void setPartyName(String pi_party_name) {
+        put("pi_party_name", pi_party_name);
+    }
+    /** 信用代码 */
+    public String getCreditCode() {
+        return getStr("pi_credit_code");
+    }
+
+    /** 信用代码 */
+    public void setCreditCode(String pi_credit_code) {
+        put("pi_credit_code", pi_credit_code);
+    }
+    /** 登记部门 */
+    public String getRegDept() {
+        return getStr("pi_reg_dept");
+    }
+
+    /** 登记部门 */
+    public void setRegDept(String pi_reg_dept) {
+        put("pi_reg_dept", pi_reg_dept);
+    }
+    /** 登记时间 */
+    public long getRegTime() {
+        return getLong("pi_reg_time");
+    }
+
+    /** 登记时间 */
+    public void setRegTime(long pi_reg_time) {
+        put("pi_reg_time", pi_reg_time);
+    }
+    /** 机构类型 */
+    public String getPartyType() {
+        return getStr("pi_party_type");
+    }
+
+    /** 机构类型 */
+    public void setPartyType(String pi_party_type) {
+        put("pi_party_type", pi_party_type);
+    }
+    /** 变动类型 */
+    public String getChangeType() {
+        return getStr("pi_change_type");
+    }
+
+    /** 变动类型 */
+    public void setChangeType(String pi_change_type) {
+        put("pi_change_type", pi_change_type);
+    }
+    /** 变动时间 */
+    public long getChangeTime() {
+        return getLong("pi_change_time");
+    }
+
+    /** 变动时间 */
+    public void setChangeTime(long pi_change_time) {
+        put("pi_change_time", pi_change_time);
+    }
+    /** 行政区划代码 */
+    public String getAreaCode() {
+        return getStr("pi_area_code");
+    }
+
+    /** 行政区划代码 */
+    public void setAreaCode(String pi_area_code) {
+        put("pi_area_code", pi_area_code);
+    }
+    /** 法定代表人 */
+    public String getLegalPerson() {
+        return getStr("pi_legal_person");
+    }
+
+    /** 法定代表人 */
+    public void setLegalPerson(String pi_legal_person) {
+        put("pi_legal_person", pi_legal_person);
+    }
+    /** 地址 */
+    public String getAddress() {
+        return getStr("pi_address");
+    }
+
+    /** 地址 */
+    public void setAddress(String pi_address) {
+        put("pi_address", pi_address);
+    }
+    /** 电话 */
+    public String getPhone() {
+        return getStr("pi_phone");
+    }
+
+    /** 电话 */
+    public void setPhone(String pi_phone) {
+        put("pi_phone", pi_phone);
+    }
+    /** 邮编 */
+    public String getPostcode() {
+        return getStr("pi_postcode");
+    }
+
+    /** 邮编 */
+    public void setPostcode(String pi_postcode) {
+        put("pi_postcode", pi_postcode);
+    }
+    /** 国民经济分类 */
+    public String getNationalEconomyType() {
+        return getStr("pi_national_economy_type");
+    }
+
+    /** 国民经济分类 */
+    public void setNationalEconomyType(String pi_national_economy_type) {
+        put("pi_national_economy_type", pi_national_economy_type);
+    }
+    /** 系统机构Id */
+    public long getSysPartyId() {
+        return getLong("pi_sys_party_id");
+    }
+
+    /** 系统机构Id */
+    public void setSysPartyId(long pi_sys_party_id) {
+        put("pi_sys_party_id", pi_sys_party_id);
+    }
+}

mztb/src/main/java/cc/smtweb/biz/mztb/web/domian/PreYearEndPersons.java

@@ -0,0 +1,207 @@
+package cc.smtweb.biz.mztb.web.domian;
+
+import cc.smtweb.framework.core.annotation.SwTable;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
+
+/**
+ * Created by 1 at 2023-12-19 11:07:10
+ * 实体【[年末人数信息](PRE_YEAR_END_PERSONS)】的Entity类
+ */
+public class PreYearEndPersons extends DefaultEntity {
+    public static final String ENTITY_NAME = "PRE_YEAR_END_PERSONS";
+
+    public PreYearEndPersons() {
+        super(ENTITY_NAME);
+    }
+
+    /** 主键 */
+    public long getId() {
+        return getLong("yep_id");
+    }
+
+    /** 主键 */
+    public void setId(long yep_id) {
+        put("yep_id", yep_id);
+    }
+
+    /** 填报主表ID */
+    public long getFoId() {
+        return getLong("yep_fo_id");
+    }
+
+    /** 填报主表ID */
+    public void setFoId(long yep_fo_id) {
+        put("yep_fo_id", yep_fo_id);
+    }
+    /** 年末床位数 */
+    public int getYeBed() {
+        return getInt("yep_ye_bed");
+    }
+
+    /** 年末床位数 */
+    public void setYeBed(int yep_ye_bed) {
+        put("yep_ye_bed", yep_ye_bed);
+    }
+    /** 年末床位数（护理型床位） */
+    public int getYeNurseBed() {
+        return getInt("yep_ye_nurse_bed");
+    }
+
+    /** 年末床位数（护理型床位） */
+    public void setYeNurseBed(int yep_ye_nurse_bed) {
+        put("yep_ye_nurse_bed", yep_ye_nurse_bed);
+    }
+    /** 年在院总人天数 */
+    public int getYeZrts() {
+        return getInt("yep_ye_zrts");
+    }
+
+    /** 年在院总人天数 */
+    public void setYeZrts(int yep_ye_zrts) {
+        put("yep_ye_zrts", yep_ye_zrts);
+    }
+    /** 年末在院人数 */
+    public int getYeNumber() {
+        return getInt("yep_ye_number");
+    }
+
+    /** 年末在院人数 */
+    public void setYeNumber(int yep_ye_number) {
+        put("yep_ye_number", yep_ye_number);
+    }
+    /** 年末在院人数（女性） */
+    public int getYeMissNum() {
+        return getInt("yep_ye_miss_num");
+    }
+
+    /** 年末在院人数（女性） */
+    public void setYeMissNum(int yep_ye_miss_num) {
+        put("yep_ye_miss_num", yep_ye_miss_num);
+    }
+    /** 年末在院人数（其他人员） */
+    public int getYeOtherNum() {
+        return getInt("yep_ye_other_num");
+    }
+
+    /** 年末在院人数（其他人员） */
+    public void setYeOtherNum(int yep_ye_other_num) {
+        put("yep_ye_other_num", yep_ye_other_num);
+    }
+    /** 年末在院人数（特困人员救助供养对象） */
+    public int getYePoverty() {
+        return getInt("yep_ye_poverty");
+    }
+
+    /** 年末在院人数（特困人员救助供养对象） */
+    public void setYePoverty(int yep_ye_poverty) {
+        put("yep_ye_poverty", yep_ye_poverty);
+    }
+    /** 年末在院人数（自费人员） */
+    public int getYeSelfPaying() {
+        return getInt("yep_ye_self_paying");
+    }
+
+    /** 年末在院人数（自费人员） */
+    public void setYeSelfPaying(int yep_ye_self_paying) {
+        put("yep_ye_self_paying", yep_ye_self_paying);
+    }
+    /** 年末在院人数（老年人） */
+    public int getYeOldMan() {
+        return getInt("yep_ye_old_man");
+    }
+
+    /** 年末在院人数（老年人） */
+    public void setYeOldMan(int yep_ye_old_man) {
+        put("yep_ye_old_man", yep_ye_old_man);
+    }
+    /** 年末在院人数（青壮年） */
+    public int getYeYoung() {
+        return getInt("yep_ye_young");
+    }
+
+    /** 年末在院人数（青壮年） */
+    public void setYeYoung(int yep_ye_young) {
+        put("yep_ye_young", yep_ye_young);
+    }
+    /** 年末在院人数（儿童） */
+    public int getYeChild() {
+        return getInt("yep_ye_child");
+    }
+
+    /** 年末在院人数（儿童） */
+    public void setYeChild(int yep_ye_child) {
+        put("yep_ye_child", yep_ye_child);
+    }
+    /** 年末在院人数（能力完好） */
+    public int getYeIntact() {
+        return getInt("yep_ye_intact");
+    }
+
+    /** 年末在院人数（能力完好） */
+    public void setYeIntact(int yep_ye_intact) {
+        put("yep_ye_intact", yep_ye_intact);
+    }
+    /** 年末在院人数（部分失能） */
+    public int getYePartDisability() {
+        return getInt("yep_ye_part_disability");
+    }
+
+    /** 年末在院人数（部分失能） */
+    public void setYePartDisability(int yep_ye_part_disability) {
+        put("yep_ye_part_disability", yep_ye_part_disability);
+    }
+    /** 年末在院人数（完全失能） */
+    public int getYeDisability() {
+        return getInt("yep_ye_disability");
+    }
+
+    /** 年末在院人数（完全失能） */
+    public void setYeDisability(int yep_ye_disability) {
+        put("yep_ye_disability", yep_ye_disability);
+    }
+    /** 康复和医疗门诊人次数 */
+    public int getOutpatientService() {
+        return getInt("yep_outpatient_service");
+    }
+
+    /** 康复和医疗门诊人次数 */
+    public void setOutpatientService(int yep_outpatient_service) {
+        put("yep_outpatient_service", yep_outpatient_service);
+    }
+    /** 家庭寄养儿童数量 */
+    public int getFosterChildren() {
+        return getInt("yep_foster_children");
+    }
+
+    /** 家庭寄养儿童数量 */
+    public void setFosterChildren(int yep_foster_children) {
+        put("yep_foster_children", yep_foster_children);
+    }
+    /** 机构建筑面积（平方米） */
+    public long getAcreage() {
+        return getLong("yep_acreage");
+    }
+
+    /** 机构建筑面积（平方米） */
+    public void setAcreage(long yep_acreage) {
+        put("yep_acreage", yep_acreage);
+    }
+    /** 相关单位统一社会信用代码 */
+    public String getUnitCreditCode() {
+        return getStr("yep_unit_credit_code");
+    }
+
+    /** 相关单位统一社会信用代码 */
+    public void setUnitCreditCode(String yep_unit_credit_code) {
+        put("yep_unit_credit_code", yep_unit_credit_code);
+    }
+    /** 相关单位名称 */
+    public String getUnitName() {
+        return getStr("yep_unit_name");
+    }
+
+    /** 相关单位名称 */
+    public void setUnitName(String yep_unit_name) {
+        put("yep_unit_name", yep_unit_name);
+    }
+}

mztb/src/main/java/cc/smtweb/biz/mztb/web/task/AddNewPartyAndAccountTask.java

@@ -1,21 +1,30 @@
 package cc.smtweb.biz.mztb.web.task;
 
 import cc.smtweb.biz.mztb.web.base.DbSourceConfig;
+import cc.smtweb.biz.mztb.web.base.PartyInfo;
 import cc.smtweb.biz.mztb.web.tool.DbUtil;
 import cc.smtweb.framework.core.common.SwMap;
 import cc.smtweb.framework.core.db.DbEngine;
+import cc.smtweb.framework.core.exception.BizException;
+import cc.smtweb.framework.core.util.DateUtil;
 import cc.smtweb.system.bpm.web.sys.base.job.BaseJob;
+import cc.smtweb.system.bpm.web.sys.user.party.Party;
+import cc.smtweb.system.bpm.web.sys.user.party.PartyCache;
+import cc.smtweb.system.bpm.web.sys.user.user.User;
+import cc.smtweb.system.bpm.web.sys.user.user.UserCache;
+import cc.smtweb.system.bpm.web.sys.user.user.UserParty;
+import cc.smtweb.system.bpm.web.sys.user.user.UserPartyCache;
 import com.alibaba.druid.pool.DruidPooledConnection;
 import com.alibaba.druid.proxy.jdbc.ConnectionProxy;
 import lombok.SneakyThrows;
 
 import java.lang.invoke.SwitchPoint;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-import java.sql.SQLException;
+import java.sql.*;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 public class AddNewPartyAndAccountTask extends BaseJob {
 
@@ -26,22 +35,120 @@ public class AddNewPartyAndAccountTask extends BaseJob {
         DbSourceConfig dbSourceConfig = instance.findDao(DbSourceConfig.class).queryEntityWhere("dsc_use_state = 0");
         Connection connection = null;
         ResultSet resultSet = null;
-        List<SwMap> partys = new ArrayList<>();
+        // 批量处理的数据
+        List<PartyInfo> partysUpdateList = new ArrayList<>();
+        List<PartyInfo> partysInsertList = new ArrayList<>();
+        List<Party> sysPartyList = new ArrayList<>();
+        List<User> userList = new ArrayList<>();
+        List<UserParty> userPartyList = new ArrayList<>();
+
+        // 记录重复数据
+        List<PartyInfo> partysInsertListExist = new ArrayList<>();
+        List<Party> sysPartyListExist = new ArrayList<>();
+        List<User> userListExist = new ArrayList<>();
+        List<UserParty> userPartyListExist = new ArrayList<>();
+
+        SwMap existPartyMap = new SwMap();
+        int insertIndex = 0;
+        // 使用社会信用代码 当做key
+        Map<String, PartyInfo> partyInfoMap = instance.query(PartyInfo.class).stream().collect(Collectors.toMap(PartyInfo::getCreditCode, Function.identity()));
         try {
             connection = DriverManager.getConnection(dbSourceConfig.getWholeUrl(), dbSourceConfig.getUsername(), dbSourceConfig.getPassword());
             DbUtil dbUtil = new DbUtil(connection);
-            resultSet = dbUtil.dbHandSql("", "query"); // 查询机构信息系
-            if(resultSet != null) {
-                while (resultSet.next()) {
-                    SwMap party = new SwMap();
-                    partys.add(party);
+            resultSet = dbUtil.dbHandSql("select * from pre_party_info where state = 0 order by wr_time", "query"); // 查询未读取的机构信息,时间升序 先推送的先读取。
+            if (resultSet == null) return null;
+
+            while (resultSet.next()) {
+                PartyInfo partyInfo = new PartyInfo();
+                SwMap swMap = new SwMap();
+                ResultSetMetaData metaData = resultSet.getMetaData();
+                int columnCount = metaData.getColumnCount();
+                for (int i = 1; i <= columnCount; i++) {
+                    swMap.put(metaData.getColumnName(i), resultSet.getString(i));
+                }
+                // 将查询到的数据转为 填报系统机构表数据
+                partyInfo.getData().putAll(swMap);
+
+                if (partyInfoMap.containsKey(resultSet.getString("pi_credit_code"))) { // 判断该机构是否存在
+                    long piIdOld = partyInfoMap.get(resultSet.getString("pi_credit_code")).getId();
+                    long sysPartyId = partyInfoMap.get(resultSet.getString("pi_credit_code")).getSysPartyId();
+                    partyInfo.setId(piIdOld);
+                    partyInfo.setSysPartyId(sysPartyId);
+                    partysUpdateList.add(partyInfo);
+                } else { // 新增(包括 底层的party 填报系统的 partyInfo 默认的用户)
+                    boolean existParty = existPartyMap.containsKey(resultSet.getString("pi_credit_code"));
+                    if (existParty) {
+                        // 包含就更新机构信息 ,系统机构信息没有可更改的内容故不处理
+                        int index = existPartyMap.readInt(resultSet.getString("pi_credit_code"));
+                        partysInsertListExist.add(partysInsertList.get(index));
+                        userListExist.add(userList.get(index));
+                        userPartyListExist.add(userPartyList.get(index));
+                        sysPartyListExist.add(sysPartyList.get(index));
+                    }
+                    existPartyMap.put(resultSet.getString("pi_credit_code"), insertIndex);
+                    insertIndex++;
+
+                    Party party = new Party(); // 底层机构表
+                    party.init();
+                    long ptId = resultSet.getLong("pi_id"); // 使用前置库的机构id当做 填报系统机构id
+                    party.setId(ptId);
+                    party.setCode(ptId + "");
+                    party.setName(partyInfo.getPartyName());
+                    partyInfo.setSysPartyId(ptId);
+                    sysPartyList.add(party);
+                    partysInsertList.add(partyInfo);
+
+                    User user = new User(); // 底层用户表
+                    user.init();
+                    long userId = instance.nextId();
+                    user.setId(userId);
+                    user.setCode(partyInfo.getCreditCode());
+                    user.setName(partyInfo.getPartyName() + "-填报人员");
+                    user.setNicky(partyInfo.getCreditCode());
+                    user.setLevel(100);
+                    user.setStatu(1);
+                    user.setPwd("13217b04835b4cbceb55edb54a72deb4"); //默认密码 abc@123456
+                    user.setPwdLevel(0);
+                    userList.add(user);
+
+                    // todo 添加部门
+
+                    UserParty userParty = new UserParty(); //用户机构关联表
+                    userParty.setId(instance.nextId());
+                    userParty.setPartyId(ptId);
+                    userParty.setUserId(userId);
+                    userParty.setDeptId(869944043285516288L); // 关联部门表
+                    userPartyList.add(userParty);
+
                 }
-                return null;
             }
+            // 删除重复新增的元素
+            partysInsertList.removeAll(partysInsertListExist);
+            sysPartyList.removeAll(sysPartyListExist);
+            userList.removeAll(userListExist);
+            userPartyList.removeAll(userPartyListExist);
+
+            // 读取完成后 修改前置库推送数据的状态，再进行本系统数据入库处理
+            dbUtil.update("update pre_party_info set state = 1 , rd_time = " + DateUtil.nowDateTimeNumber() + " where state = 0");
+
+            instance.doTrans(() -> {
+                // 处理新增或者修改的数据
+                instance.findDao(PartyInfo.class).batchInsertEntity(partysInsertList);
+                instance.findDao(PartyInfo.class).batchUpdateEntity(partysUpdateList);
+                instance.findDao(Party.class).batchInsertEntity(sysPartyList);
+                instance.findDao(User.class).batchInsertEntity(userList);
+                instance.findDao(UserParty.class).batchInsertEntity(userPartyList);
+                // 将机构、用户信息放入缓存
+                PartyCache.getInstance().putList(sysPartyList);
+                UserCache.getInstance().putList(userList);
+                UserPartyCache.getInstance().putList(userPartyList);
+            });
         } catch (SQLException e) {
             e.printStackTrace();
         }
-
+        // 判断是新增还是修改（如果是修改 将机构信息删除 重新新增，注意维护系统机构表数据）
+        // 新增的机构 自动创建一个登录账号
+        //读取完成后 修改前置库 推送机构表的状态和读取时间
         // 在当前系统 建立机构和账号数据,将账号信息写入缓存
         return null;
     }

mztb/src/main/java/cc/smtweb/biz/mztb/web/task/PushTask.java

@@ -1,10 +1,13 @@
 package cc.smtweb.biz.mztb.web.task;
 
 import cc.smtweb.biz.mztb.web.base.*;
+import cc.smtweb.biz.mztb.web.domian.*;
 import cc.smtweb.biz.mztb.web.tool.DbUtil;
 import cc.smtweb.framework.core.common.SwMap;
 import cc.smtweb.framework.core.db.DbEngine;
 import cc.smtweb.framework.core.db.EntityHelper;
+import cc.smtweb.framework.core.db.dao.EntityColumn;
+import cc.smtweb.framework.core.db.impl.DefaultEntity;
 import cc.smtweb.framework.core.exception.BizException;
 import cc.smtweb.system.bpm.web.sys.base.job.BaseJob;
 
@@ -13,6 +16,24 @@ import java.util.*;
 import java.util.stream.Collectors;
 
 public class PushTask extends BaseJob {
+
+    private String  buildInsertSql(String tableName, DefaultEntity entity) {
+        entity.getData().remove("_def_table_name");
+        StringJoiner key = new StringJoiner(",");
+        StringJoiner value = new StringJoiner(",");
+        StringBuilder sql = new StringBuilder();
+        sql.append(" insert into ").append(tableName).append(" (");
+        for (Map.Entry<String, Object> entry : entity.getData().entrySet()) {
+            key.add(entry.getKey());
+            value.add("'"+entry.getValue()+"'");
+        }
+        sql.append(key);
+        sql.append(") value (");
+        sql.append(value);
+        sql.append(")");
+
+        return sql.toString();
+    }
     @Override
     protected String work() {
         DbEngine instance = DbEngine.getInstance();
@@ -29,70 +50,50 @@ public class PushTask extends BaseJob {
             return null;
         }
         List<String> ids = new ArrayList<>();
-        fillOutList.stream().forEach(temp -> {
-            ids.add(String.valueOf(temp.readLong("fo_id")));
+        fillOutList.forEach(temp -> {
+            ids.add(temp.readString("fo_id"));
         });
         fillOutList.forEach(temp->{
-            List<String> fields = new LinkedList<>();
-            List<String> value = new LinkedList<>();
-            for (String s : temp.keySet()) {
-                fields.add(s);
-                if (s.equals("fo_id")){
-                    value.add(String.valueOf(instance.nextId()));
-                    value.add(temp.readString(s));
-                }
-            }
-            insertSql.add("insert into tb_fill_out ("+fields.stream().collect(Collectors.joining(","))+") VALUES ("+value.stream().collect(Collectors.joining(","))+")");
-
+            temp.remove("fo_update_at");
+            PreFillOut preFillOut = new PreFillOut();
+            preFillOut.getData().putAll(temp);
+            String sql = buildInsertSql(PreFillOut.ENTITY_NAME, preFillOut);
+            insertSql.add(sql);
         });
-
-//        List<BusinessInfo> businessInfos = instance.findDao(BusinessInfo.class).queryWhere("bi_fo_id in (" + ids.stream().collect(Collectors.joining(",")) + ")");
-//        Map<Long, BusinessInfo> businessInfoMap = new HashMap<>();
-//        if (businessInfos.size() != 0) {
-//            businessInfos.forEach(temp -> {
-//                businessInfoMap.put(temp.getFoId(), temp);
-//            });
-//        }
-        List<SwMap> businessInfos = instance.query("select * from "+EntityHelper.getSchemaTableName(BusinessInfo.ENTITY_NAME)+ " where bi_fo_id in (" + ids.stream().collect(Collectors.joining(",")) + ")",SwMap.class);
+        List<SwMap> businessInfos = instance.query("select * from "+EntityHelper.getSchemaTableName(BusinessInfo.ENTITY_NAME)+ " where bi_fo_id in (" + String.join(",", ids) + ")",SwMap.class);
         if (businessInfos.size() !=0){
             businessInfos.forEach(temp->{
-                List<String> fields = new LinkedList<>();
-                List<String> value = new LinkedList<>();
-                for (String s : temp.keySet()) {
-                    fields.add(s);
-                    value.add(temp.readString(s));
-                }
-                insertSql.add("insert into tb_business_info ("+fields.stream().collect(Collectors.joining(","))+") VALUES ("+value.stream().collect(Collectors.joining(","))+")");
+                temp.remove("bi_update_at");
+                temp.remove("bi_party_manage");
+                PreBusinessInfo preBusinessInfo = new PreBusinessInfo();
+                preBusinessInfo.getData().putAll(temp);
+                String sql = buildInsertSql(PreBusinessInfo.ENTITY_NAME, preBusinessInfo);
+                insertSql.add(sql);
             });
         }
-        List<SwMap> financeInfos = instance.query("select * from "+EntityHelper.getSchemaTableName(FinanceInfo.ENTITY_NAME)+" where fi_fo_id in (" + ids.stream().collect(Collectors.joining(",")) + ")",SwMap.class);
+
+        List<SwMap> financeInfos = instance.query("select * from "+EntityHelper.getSchemaTableName(FinanceInfo.ENTITY_NAME)+" where fi_fo_id in (" + String.join(",", ids) + ")",SwMap.class);
         if (financeInfos.size() != 0){
             financeInfos.forEach(temp->{
-                List<String> fields = new LinkedList<>();
-                List<String> value = new LinkedList<>();
-                for (String s : temp.keySet()) {
-                    fields.add(s);
-                    value.add(temp.readString(s));
-                }
-                insertSql.add("insert into tb_finance_info ("+fields.stream().collect(Collectors.joining(","))+") VALUES ("+value.stream().collect(Collectors.joining(","))+")");
+                temp.remove("fi_update_at");
+                PreFinanceInfo preFinanceInfo = new PreFinanceInfo();
+                preFinanceInfo.getData().putAll(temp);
+                String sql = buildInsertSql(PreFinanceInfo.ENTITY_NAME, preFinanceInfo);
+                insertSql.add(sql);
             });
         }
 
-
-        List<SwMap> yearEndPersons = instance.query("select * from "+EntityHelper.getSchemaTableName(YearEndPersons.ENTITY_NAME)+" where yep_fo_id in (" + ids.stream().collect(Collectors.joining(",")) + ")",SwMap.class);
+        List<SwMap> yearEndPersons = instance.query("select * from "+EntityHelper.getSchemaTableName(YearEndPersons.ENTITY_NAME)+" where yep_fo_id in (" + String.join(",", ids) + ")",SwMap.class);
         if (yearEndPersons.size() != 0){
             yearEndPersons.forEach(temp->{
-                List<String> fields = new LinkedList<>();
-                List<String> value = new LinkedList<>();
-                for (String s : temp.keySet()) {
-                    fields.add(s);
-                    value.add(temp.readString(s));
-                }
-                insertSql.add("insert into tb_year_end_persons ("+fields.stream().collect(Collectors.joining(","))+") VALUES ("+value.stream().collect(Collectors.joining(","))+")");
+                temp.remove("yep_update_at");
+                PreYearEndPersons preYearEndPersons = new PreYearEndPersons();
+                preYearEndPersons.getData().putAll(temp);
+                String sql = buildInsertSql(PreYearEndPersons.ENTITY_NAME, preYearEndPersons);
+                insertSql.add(sql);
             });
         }
 
-
         Connection connection = null;
         try {
             connection = DriverManager.getConnection(dbSourceConfig.getWholeUrl(), dbSourceConfig.getUsername(), dbSourceConfig.getPassword());
@@ -102,20 +103,22 @@ public class PushTask extends BaseJob {
         if (connection == null){
             throw new BizException("连接失败！");
         }
+        boolean success =false;
         try {
             connection.setAutoCommit(false);
             try (Statement statement = connection.createStatement()) {
-                for (int i = 0; i <insertSql.size(); i++) {
-                    statement.addBatch(insertSql.get(i)); // 添加到批处理中
+                for (String s : insertSql) {
+                    statement.addBatch(s); // 添加到批处理中
                 }
                 int[] updateCounts = statement.executeBatch(); // 执行批处理
                 if (updateCounts.length != insertSql.size()){
                     throw new BizException("数据数量异常");
                 }
                 connection.commit(); // 提交事务
-                statement.close();
+                success = true;
             } catch (SQLException e) {
                 e.printStackTrace();
+                success = false;
                 try {
                     connection.rollback(); // 回滚事务
                 } catch (SQLException ex) {
@@ -132,6 +135,10 @@ public class PushTask extends BaseJob {
                 e.printStackTrace();
             }
         }
+        // 推送完成后修改填报机构的推送状态
+        if(success) {
+            instance.update("update "+EntityHelper.getSchemaTableName(FillOut.ENTITY_NAME) +" set fo_state = 2 where fo_id in ("+String.join(",",ids)+")");
+        }
         return null;
     }
 

mztb/src/main/java/cc/smtweb/biz/mztb/web/tool/DbUtil.java

@@ -74,6 +74,11 @@ public class DbUtil {
         }
         return stmt.executeQuery(sql);
     }
+    public int update(String sql) throws SQLException {
+        int i = getStatement().executeUpdate(sql);
+        connection.close();
+        return i;
+    }
 
     /**
      * 获取statement 对象

mztb/src/main/resources/static/event/mztb/base/partyDataFill/partyDataFillList.js

@@ -26,6 +26,7 @@ window.$swEvent.setup("mztb.base.partyDataFill.partyDataFillList", {
         $$message.notify.warning("请选择任务")
         return false
       }
+      $api.closeDialog("tb")
       $api.toPage("mztb.partyDataFillCard",{
         $fromAction: 'button:add'
         ,task:$model.ds_1.data.form.task

mztb/target/classes/static/event/mztb/base/partyDataFill/partyDataFillCard.js

@@ -1,58 +0,0 @@
-/**
- * Created by 1 at 2023-12-20 17:03:56
- * 注册事件类【机构数据填报编辑】，参看event.defaultEvent.js
-*/
-window.$swEvent.setup("mztb.base.partyDataFill.partyDataFillCard", {
-  setup(page){
-    const { $params, $refs, $widgets, $model, $utils, $tabRouter, $api, $lifecycle, $engine, $parent } = page || {};
-    const { $$message, $$http, $$sys, $$UtilPub } = $utils || {};
-
-    // 示例
-    const demoFunc = () => {
-
-    };
-
-    $lifecycle.onLoad = () => {
-      if(!$params.id) {
-        $model.card.setFormVal("fo_type",Number($params.type))
-        $model.card.setFormVal("fo_task", Number($params.type) === 2 ? Number($params.task+"99") : Number($params.task)) //如果是年报 年份后面添加标识 99
-        $model.card.setFormVal("fo_task_text",$params.task_text)
-      }
-      $api.loadOne("partyForm")
-      if(Number($model.card.getFormVal("fo_state") === 2) || Number($model.card.getFormVal("fo_state") === 1)) {
-        $refs.saveButton.hide()
-      }
-      if(Number($model.card.getFormVal("fo_type")) === 1) { // 月报
-        $refs.yearEnd.hide()
-      }
-    }
-
-    Object.assign($engine, {
-      buildSaveParams(params) {
-        if(Number($model.card.getFormVal("fo_type")) === 2) { // 年报
-          params.yearEndPersonsForm = {
-            form : $model.yearEndPersonsForm.data.form
-          }
-        }
-        params.financeForm = {
-          form : $model.financeForm.data.form
-        }
-        params.businessForm = {
-          form : $model.businessForm.data.form
-        }
-        params.partyForm = {
-          form : $model.partyForm.data.form
-        }
-      }
-    })
-
-    const loadPageCard = () => {
-      // $api.loadCard()
-    }
-
-
-    return {
-      demoFunc,loadPageCard
-    }
-  }
-});

mztb/target/classes/static/event/mztb/base/partyDataFill/partyDataFillList.js

@@ -1,96 +0,0 @@
-/**
- * Created by 1 at 2023-12-19 11:06:39
- * 注册事件类【机构数据填报列表】，参看event.defaultEvent.js
-*/
-window.$swEvent.setup("mztb.base.partyDataFill.partyDataFillList", {
-  setup(page){
-    const { $params, $refs, $widgets, $model, $utils, $tabRouter, $api, $lifecycle, $engine, $parent } = page || {};
-    const { $$message, $$http, $$sys, $$UtilPub } = $utils || {};
-
-    // 示例
-    const demoFunc = () => {
-
-    };
-
-    let task; // 填报月
-    let task_text; // 填报月格式化
-    let type; // 填报类型(2 年报 1 月报)
-
-    const setValue =(id,data) => {
-      task = data.task;
-      task_text = data.text;
-      type = data.task.includes("99") ? 2 : 1;
-    }
-    const toPageEdit = () =>{
-      if($model.ds_1.data.form.task === undefined) {
-        $$message.notify.warning("请选择任务")
-        return false
-      }
-      $api.toPage("mztb.partyDataFillCard",{
-        $fromAction: 'button:add'
-        ,task:$model.ds_1.data.form.task
-        ,type: $model.ds_1.data.form.month
-        ,task_text : $model.ds_1.data.form.task_text
-        ,outOldData : $model.ds_1.data.form.outOldData })
-    }
-
-    const selectHide =(data) => {
-      if(Number(data) === 1) { //月报
-        $refs.year.hide();
-        $refs.month1.show();
-      }else { // 年报
-        $refs.month1.hide();
-        $refs.year.show();
-      }
-    }
-
-    const setTypeDef =()=> {
-      $model.ds_1.data.form.month = 1
-    }
-
-    // 按钮显示隐藏
-    const edit_del_affirm_Hide = (data) => { // 编辑 删除 确认
-      return Number(data.scope.row.fo_state) === 0
-    }
-    const  affirm_push_CancelHide= (data) => { // 取消确认 推送
-      return Number(data.scope.row.fo_state) === 1
-    }
-
-    // 自定义请求 逻辑删除 填报主表
-    const logicDel = async (data) => {
-      const rt = await $$http.post("mztb/partyDataFill/logicDel", {id: data.row.fo_id})
-      if (rt.code === 0) {
-        $api.loadList()
-        $$message.notify.success("删除完成")
-      }
-    }
-    // 自定义请求 确认
-    const affirm = async (data) => {
-      const rt =await $$http.post("mztb/partyDataFill/affirm",{id : data.row.fo_id})
-      if(rt.code === 0) {
-        $api.loadList()
-        $$message.notify.success("已确认")
-      }
-    }
-    // 自定义请求 取消确认
-    const cancelAffirm =async (data) => {
-      const rt = await $$http.post("mztb/partyDataFill/cancelAffirm",{id : data.row.fo_id})
-      if(rt.code === 0) {
-        $api.loadList()
-        $$message.notify.success("已取消确认")
-      }
-    }
-    // 自定义请求推送 数据
-    const pushData = (data) => {
-      const rt = $$http.post("mztb/partyDataFill/pushData",{id : data.row.fo_id})
-      if(rt.code === 0) {
-        $api.loadList()
-      }
-    }
-
-    return {
-      demoFunc,setValue,toPageEdit,selectHide,setTypeDef,edit_del_affirm_Hide,affirm_push_CancelHide
-      ,logicDel,affirm,cancelAffirm,pushData
-    }
-  }
-});

mztb/target/classes/static/event/mztb/base/prelibraryConfiguration/prelibraryConfigurationList.js

@@ -1,18 +0,0 @@
-/**
- * Created by 1 at 2023-12-18 11:09:35
- * 注册事件类【配置前置库连接列表】，参看event.defaultEvent.js
-*/
-window.$swEvent.setup("mztb.base.prelibraryConfiguration.prelibraryConfigurationList", {
-  setup(page){
-    const { $params, $refs, $widgets, $model, $utils, $tabRouter, $api, $lifecycle, $engine, $parent } = page || {};
-    const { $$message, $$http, $$sys, $$UtilPub } = $utils || {};
-
-    // 示例
-    const demoFunc = () => {
-
-    };
-    return {
-      demoFunc,
-    }
-  }
-});