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

amos-boot-biz-common/src/main/java/com/yeejoin/amos/boot/biz/common/utils/MyBatisPlusCodeGenerator.java

@@ -26,29 +26,30 @@ public class MyBatisPlusCodeGenerator {
     /**
      * 项目名称缩写
      */
-    static String projectShortName = "tzs";
+    static String projectShortName = "jxiop";
+    static String projectShortName1 = "hygf";
 
     /**
      * 项目api目录
      */
-    static String apiAddress = "/amos-boot-module/amos-boot-module-api/" + "amos-boot-module-" + projectShortName +
+    static String apiAddress = "/amos-boot-system-" + projectShortName + "/amos-boot-module-" + projectShortName1 +
             "-api/";
 
     /**
      * 项目biz目录
      */
-    static String bizAddress = "/amos-boot-module/amos-boot-module-biz/" + "amos-boot-module-" + projectShortName +
+    static String bizAddress = "/amos-boot-system-" + projectShortName + "/amos-boot-module-" + projectShortName1 +
             "-biz/";
 
     /**
      * 项目api路径
      */
-    static String apiPath = apiAddress + "src/main/java/com/yeejoin/amos/boot/module/" + projectShortName + "/api";
+    static String apiPath = apiAddress + "src/main/java/com/yeejoin/amos/boot/module/" + projectShortName1 + "/api";
 
     /**
      * 项目biz路径
      */
-    static String bizPath = bizAddress + "src/main/java/com/yeejoin/amos/boot/module/" + projectShortName + "/biz";
+    static String bizPath = bizAddress + "src/main/java/com/yeejoin/amos/boot/module/" + projectShortName1 + "/biz";
 
     /**
      * 接口及实体等代码生成路径
@@ -102,12 +103,12 @@ public class MyBatisPlusCodeGenerator {
         gc.setActiveRecord(false);
         // 数据源配置
         DataSourceConfig dsc = new DataSourceConfig();
-        dsc.setUrl("jdbc:mysql://172.16.6.60:3306/amos-tzs-biz?serverTimezone=GMT%2B8");
+        dsc.setUrl("jdbc:mysql://47.92.234.253:3306/amos_project?serverTimezone=GMT%2B8");
         // dsc.setSchemaName("public");
 //        dsc.setDriverName("com.mysql.jdbc.Driver");
         dsc.setDriverName("com.mysql.cj.jdbc.Driver");
         dsc.setUsername("root");
-        dsc.setPassword("root_123");
+        dsc.setPassword("Yeejoin@2020");
 
         dsc.setTypeConvert(new ITypeConvert() {
             @Override
@@ -292,7 +293,8 @@ public class MyBatisPlusCodeGenerator {
         strategy.setControllerMappingHyphenStyle(true);
         strategy.setTablePrefix();
         //去除表名前缀
-        strategy.setTablePrefix("t_", "tb_", "sys_", "other_", "rpm_", "s_", "tcb_", "cb_", "tz_", "jc_", "jcb_");
+        strategy.setTablePrefix("tz_" + projectShortName1 + "_", "t_", "tb_", "sys_", "other_", "rpm_", "s_", "tcb_",
+                "cb_", "tz_", "jc_", "jcb_", "flc_");
         // 设置父级Controller
         strategy.setSuperControllerClass("com.yeejoin.amos.boot.biz.common.controller.BaseController");
         autoGenerator.setStrategy(strategy);

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/Enum/ArrivalStateeEnum.java

@@ -15,6 +15,7 @@ public enum ArrivalStateeEnum {
     待收货("待收货", "待收货"),
 
     已收货("已收货", "已收货"),
+    补货申请("补货申请", "补货申请"),
 
     已作废("已作废", "已作废"),
 
@@ -30,7 +31,8 @@ public enum ArrivalStateeEnum {
     并网完成("并网完成", "并网完成"),
     线上验收("线上验收", "线上验收"),
     线下验收("线下验收", "线下验收"),
-    验收完成("验收完成", "验收完成");
+    验收完成("验收完成", "验收完成"),
+    待发货("待发货", "待发货");
 
 
 

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/Enum/DeliveryStateeEnum.java

@@ -15,6 +15,15 @@ public enum DeliveryStateeEnum {
 
     待发货("待发货", "待发货"),
 
+    暂存发货("暂存发货", "暂存发货"),
+    待提交("待提交", "待提交"),
+    待确认("待确认", "待确认"),
+    待补货("待补货", "待补货"),
+
+    待审核("待审核", "待审核"),
+
+    已完成("已完成", "已完成"),
+
     已发货("已发货", "已发货"),
 
     已作废("已作废", "已作废");

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/HygfPreparationMoneyAuditingDto.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.util.Date;
+
+/**
+ * 投融审核表
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="HygfPreparationMoneyAuditingDto", description="投融审核表")
+public class HygfPreparationMoneyAuditingDto  extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "工作流实例ID")
+    private String instanceId;
+
+    @ApiModelProperty(value = "下一个节点角色权限id")
+    private String nextExecutorIds;
+
+    @ApiModelProperty(value = "任务发起人id")
+    private String promoter;
+
+    @ApiModelProperty(value = "流程下一节点id")
+    private String nextTaskId;
+
+    @ApiModelProperty(value = "下一节点可执行人逗号分割")
+    private String nextExecuteUserIds;
+
+    @ApiModelProperty(value = "工作流发起人id")
+    private String createUserId;
+
+    @ApiModelProperty(value = "下个节点名称")
+    private String nextNodeName;
+
+    @ApiModelProperty(value = "下个节点key")
+    private String nextNodeKey;
+
+    @ApiModelProperty(value = "状态")
+    private String status;
+
+    @ApiModelProperty(value = "农户id")
+    private Long preparationMoneyId;
+
+    @ApiModelProperty(value = " 待执行节点小程序路由")
+    private String nodeRouting;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/HygfReplenishmentDto.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.util.Date;
+
+/**
+ * 
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="HygfReplenishmentDto", description="")
+public class HygfReplenishmentDto  extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "发货单id")
+    private Long preparationMoneyId;
+
+    @ApiModelProperty(value = "补货描述")
+    private String desc;
+
+    @ApiModelProperty(value = "补货文件")
+    private String file;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/PeasantHouseholdPageDto.java

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.Data;
+
+@Data
+public class PeasantHouseholdPageDto extends Page<PeasantHouseholdPageDto> {
+    private String nhUserId;
+    private String peasantHouseholdNo;
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/HygfPreparationMoneyAuditing.java

+package com.yeejoin.amos.boot.module.hygf.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import java.util.Date;
+
+/**
+ * 投融审核表
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("hygf_preparation_money_auditing")
+public class HygfPreparationMoneyAuditing extends BaseEntity {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 工作流实例ID
+     */
+	@TableField("instance_id")
+    private String instanceId;
+
+    /**
+     * 下一个节点角色权限id
+     */
+	@TableField("next_executor_ids")
+    private String nextExecutorIds;
+
+    /**
+     * 任务发起人id
+     */
+	@TableField("promoter")
+    private String promoter;
+
+    /**
+     * 流程下一节点id
+     */
+	@TableField("next_task_id")
+    private String nextTaskId;
+
+    /**
+     * 下一节点可执行人逗号分割
+     */
+	@TableField("next_execute_user_ids")
+    private String nextExecuteUserIds;
+
+    /**
+     * 工作流发起人id
+     */
+	@TableField("create_user_id")
+    private String createUserId;
+
+    /**
+     * 下个节点名称
+     */
+	@TableField("next_node_name")
+    private String nextNodeName;
+
+    /**
+     * 下个节点key
+     */
+	@TableField("next_node_key")
+    private String nextNodeKey;
+
+    /**
+     * 状态
+     */
+	@TableField("status")
+    private String status;
+
+    /**
+     * 农户id
+     */
+	@TableField("preparation_money_id")
+    private Long preparationMoneyId;
+
+    /**
+     *  待执行节点小程序路由
+     */
+	@TableField("node_routing")
+    private String nodeRouting;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/HygfReplenishment.java

+package com.yeejoin.amos.boot.module.hygf.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler;
+import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.Value;
+import lombok.experimental.Accessors;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("hygf_replenishment")
+public class HygfReplenishment extends BaseEntity {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 发货单id
+     */
+	@TableField("preparation_money_id")
+    private Long preparationMoneyId;
+
+    /**
+     * 补货描述
+     */
+	@TableField("desc")
+    private String desc;
+
+    /**
+     * 补货文件
+     */
+	@TableField(value = "file" , typeHandler = FastjsonTypeHandler.class)
+    private List<Object> file;
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/PeasantHousehold.java

@@ -192,6 +192,12 @@ public class PeasantHousehold extends BaseEntity {
     /**
      *  已发货，已收货，
      */
+    @TableField("preparation_money_state")
+    private String preparationMoneyState;
+
+    /**
+     *  备货状态
+     */
     @TableField("construction_state")
     private String constructionState;
 

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/PowerStationConstructionData.java

@@ -180,4 +180,10 @@ public class PowerStationConstructionData extends BaseEntity {
 	@TableField("work_order_power_station_id")
     private Long workOrderPowerStationId;
 
+    /**
+     * 是否提交流程
+     */
+    @TableField(exist = false)
+    private boolean commitFlow;
+
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/PreparationMoney.java

@@ -149,6 +149,10 @@ public class PreparationMoney extends BaseEntity {
     @TableField(exist = false)
     private List<PreparationMoneyLog> preparationMoneyLog;  //发货单流水
 
-
+    @TableField(exist = false)
+    private String instance_id;  //发货单流水
+    //订单状态
+    @TableField("order_status")
+    private String orderStatus;
 
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/HygfPreparationMoneyAuditingMapper.java

+package com.yeejoin.amos.boot.module.hygf.api.mapper;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.HygfPreparationMoneyAuditing;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * 投融审核表 Mapper 接口
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+public interface HygfPreparationMoneyAuditingMapper extends BaseMapper<HygfPreparationMoneyAuditing> {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/HygfReplenishmentMapper.java

+package com.yeejoin.amos.boot.module.hygf.api.mapper;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.HygfReplenishment;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ *  Mapper 接口
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+public interface HygfReplenishmentMapper extends BaseMapper<HygfReplenishment> {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/PeasantHouseholdMapper.java

@@ -31,7 +31,7 @@ public interface PeasantHouseholdMapper extends BaseMapper<PeasantHousehold> {
 
     );
     @UserEmpower(field={},dealerField={"developer_code","regional_companies_code","developer_user_id"} ,fieldConditions ={"eq","in","eq"} ,relationship="and")
-    List<PeasantHousehold> queryForPage( String developerCode,String ownersName,Long developerId,Integer isCertified);
+    List<PeasantHousehold> queryForPage( String developerCode,String ownersName,Long developerId,Integer isCertified,String preparationMoneyState);
 
 
     List<Map<String,Object>> selectUserIsHouse(String telephone);

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/PreparationMoneyMapper.java

@@ -13,6 +13,7 @@ import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 发货单 Mapper 接口
@@ -28,4 +29,11 @@ public interface PreparationMoneyMapper extends BaseMapper<PreparationMoney> {
     @UserEmpower(field ={"regional_companies_code"} ,dealerField={"amos_unit_org_code","regional_companies_code"} ,fieldConditions ={"eq","in"} ,relationship="and")
     List<PreparationMoney> selectPageList(@Param(value = "dto") PreparationDto preparationDto);
 
+    @UserEmpower(field ={"regional_companies_code"} ,dealerField={"amos_unit_org_code","regional_companies_code"} ,fieldConditions ={"eq","in"} ,relationship="and")
+    List<Map<String,Object>> preparationStation (@Param(value = "preparationMoneyState")  String preparationMoneyState,
+                                                 @Param(value = "ownersName") String ownersName,
+                                                 @Param(value = "regionalcompaniesSeq") String regionalcompaniesSeq,
+                                                 @Param(value = "developerId") String developerId,
+                                                 @Param(value = "state") String state);
+
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/service/IHygfPreparationMoneyAuditingService.java

+package com.yeejoin.amos.boot.module.hygf.api.service;
+
+
+/**
+ * 投融审核表接口类
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+public interface IHygfPreparationMoneyAuditingService {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/service/IHygfReplenishmentService.java

+package com.yeejoin.amos.boot.module.hygf.api.service;
+
+
+/**
+ * 接口类
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+public interface IHygfReplenishmentService {
+
+}

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/HygfPreparationMoneyAuditingMapper.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="com.yeejoin.amos.boot.module.hygf.api.mapper.HygfPreparationMoneyAuditingMapper">
+
+</mapper>

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/HygfReplenishmentMapper.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="com.yeejoin.amos.boot.module.hygf.api.mapper.HygfReplenishmentMapper">
+
+</mapper>

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/PeasantHouseholdMapper.xml

@@ -58,6 +58,12 @@ and hygf_document_station.station_id is not null
         <if test="ownersName!=null and ownersName !=''">
             and owners_name like concat ('%',#{ownersName},'%')
         </if>
+        <if test="preparationMoneyState!=null and preparationMoneyState !='' and preparationMoneyState == '0' ">
+            and preparation_money_state in ('待发货','待补货','暂存发货')
+        </if>
+        <if test="preparationMoneyState!=null and preparationMoneyState !='' and preparationMoneyState == '1' ">
+            and preparation_money_state not in  ('待发货','待补货','暂存发货')
+        </if>
         <if test="developerId!=null and developerId !=''">
             and developer_id = #{developerId}
         </if>

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/resources/mapper/mysql/PreparationMoneyMapper.xml

@@ -13,7 +13,7 @@ LEFT JOIN  hygf_document_station on hygf_document_station.station_id=hygf_peasan
 </select>
 
     <select id="selectPageList" resultType="com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney">
-        SELECT * FROM hygf_preparation_money
+        SELECT hygf_preparation_money.*,(select instance_id from hygf_preparation_money_auditing where preparation_money_id = hygf_preparation_money.sequence_nbr limit 1  ) as instanceId FROM hygf_preparation_money
         <where>
             <if test="dto.consigneeRegion != null and dto.consigneeRegion != ''">
                 and hygf_preparation_money.consignee_region like concat ('%',#{dto.consigneeRegion},'%')
@@ -39,4 +39,46 @@ LEFT JOIN  hygf_document_station on hygf_document_station.station_id=hygf_peasan
         </where>
         ORDER BY order_time DESC
     </select>
+
+    <select id="preparationStation" resultType="java.util.Map">
+        select
+        hygf_peasant_household.peasant_household_no as peasantHouseholdNo,
+        hygf_peasant_household.owners_name as ownersName,
+        hygf_peasant_household.regional_companies_name as regionalCompaniesName,
+        hygf_peasant_household.developer_name as developerName,
+        hygf_peasant_household.sequence_nbr  as sequenceNbr,
+        concat_ws('/',project_address_name,project_address_detail) as address,
+        hygf_peasant_household.project_address_name  as sequenceNbr,
+        hygf_peasant_household.preparation_money_state preparationMoneyState,
+        hygf_document_station.preparation_money_id as preparationMoneyId,
+        hygf_power_station.process_instance_id as instanceId
+        from
+        hygf_peasant_household
+        LEFT JOIN hygf_document_station on  hygf_peasant_household.sequence_nbr =   hygf_document_station.station_id
+        LEFT JOIN hygf_power_station on hygf_peasant_household.sequence_nbr = hygf_power_station.peasant_household_id
+        <where>
+        <if test="preparationMoneyState!=null and preparationMoneyState !='' and preparationMoneyState == '0' ">
+            and hygf_peasant_household.preparation_money_state in ('待发货','待补货','暂存发货')
+        </if>
+        <if test="regionalCompaniesSeq!=null and regionalCompaniesSeq !=''  ">
+            and hygf_peasant_household.regional_companies_seq  = #{regionalCompaniesSeq}
+        </if>
+        <if test="developerId!=null and developerId !=''">
+            and hygf_peasant_household.developer_id = #{developerId}
+        </if>
+        <if test="state!=null and state !=''">
+            and hygf_peasant_household.preparation_money_state  = #{state}
+        </if>
+        <if test="ownersName!=null and ownersName !=''">
+            and hygf_peasant_household.owners_name like concat ('%',#{ownersName},'%')
+        </if>
+        <if test="preparationMoneyState!=null and preparationMoneyState !='' and preparationMoneyState == '1' ">
+            and hygf_peasant_household.preparation_money_state not in  ('待发货','待补货','暂存发货') and preparation_money_state is not and preparation_money_state != ''
+        </if>
+
+
+        </where>
+
+
+    </select>
 </mapper>

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/HouseholdContractController.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.hygf.api.Enum.ArrivalStateeEnum;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.HouseholdContractEnum;
 import com.yeejoin.amos.boot.module.hygf.api.Enum.TaskTypeStationEnum;
 import com.yeejoin.amos.boot.module.hygf.api.config.UserLimits;
@@ -229,7 +230,14 @@ public class HouseholdContractController extends BaseController {
         wrapper.eq(ToDoTasks::getState, "待办");
         wrapper.eq(ToDoTasks::getBusinessId, householdContrac.getSequenceNbr());
         ToDoTasks doTasks= toDoTasksMapper.selectOne(wrapper);
-        if(doTasks!=null){
+
+            PeasantHousehold peasantHousehold = peasantHouseholdServiceImpl.getDataByState(householdContrac.getPeasantHouseholdId());
+            if (peasantHousehold != null){
+                peasantHousehold.setPreparationMoneyState(ArrivalStateeEnum.待发货.getCode());
+                peasantHouseholdServiceImpl.getBaseMapper().updateById(peasantHousehold);
+            }
+
+            if(doTasks!=null){
             doTasks.setState("已办");
             doTasks.setCompleteTime(new Date());
             toDoTasksMapper.updateById(doTasks);

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/HygfPreparationMoneyAuditingController.java

+package com.yeejoin.amos.boot.module.hygf.biz.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.Api;
+import org.springframework.web.bind.annotation.RestController;
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import java.util.List;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.HygfPreparationMoneyAuditingServiceImpl;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+import org.springframework.beans.factory.annotation.Autowired;
+import javax.servlet.http.HttpServletRequest;
+import org.springframework.web.bind.annotation.*;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.hygf.api.dto.HygfPreparationMoneyAuditingDto;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+
+/**
+ * 投融审核表
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+@RestController
+@Api(tags = "投融审核表Api")
+@RequestMapping(value = "/hygf-preparation-money-auditing")
+public class HygfPreparationMoneyAuditingController extends BaseController {
+
+    @Autowired
+    HygfPreparationMoneyAuditingServiceImpl hygfPreparationMoneyAuditingServiceImpl;
+
+    /**
+     * 新增投融审核表
+     *
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/save")
+	@ApiOperation(httpMethod = "POST", value = "新增投融审核表", notes = "新增投融审核表")
+	public ResponseModel<HygfPreparationMoneyAuditingDto> save(@RequestBody HygfPreparationMoneyAuditingDto model) {
+	    model = hygfPreparationMoneyAuditingServiceImpl.createWithModel(model);
+	    return ResponseHelper.buildResponse(model);
+	}
+
+	/**
+     * 根据sequenceNbr更新
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PutMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新投融审核表", notes = "根据sequenceNbr更新投融审核表")
+	public ResponseModel<HygfPreparationMoneyAuditingDto> updateBySequenceNbrHygfPreparationMoneyAuditing(@RequestBody HygfPreparationMoneyAuditingDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+	    model.setSequenceNbr(sequenceNbr);
+	    return ResponseHelper.buildResponse(hygfPreparationMoneyAuditingServiceImpl.updateWithModel(model));
+	}
+
+	/**
+     * 根据sequenceNbr删除
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @DeleteMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除投融审核表", notes = "根据sequenceNbr删除投融审核表")
+    public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
+        return ResponseHelper.buildResponse(hygfPreparationMoneyAuditingServiceImpl.removeById(sequenceNbr));
+    }
+
+    /**
+     * 根据sequenceNbr查询
+     *
+	 * @param sequenceNbr  主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个投融审核表",  notes = "根据sequenceNbr查询单个投融审核表")
+	public ResponseModel<HygfPreparationMoneyAuditingDto> selectOne(@PathVariable Long sequenceNbr) {
+	    return ResponseHelper.buildResponse(hygfPreparationMoneyAuditingServiceImpl.queryBySeq(sequenceNbr));
+	}
+
+	/**
+     * 列表分页查询
+     *
+     * @param current 当前页
+     * @param current 每页大小
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/page")
+	@ApiOperation(httpMethod = "GET",value = "投融审核表分页查询",  notes = "投融审核表分页查询")
+	public ResponseModel<Page<HygfPreparationMoneyAuditingDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
+                    (value = "size") int size) {
+	    Page<HygfPreparationMoneyAuditingDto> page = new Page<HygfPreparationMoneyAuditingDto>();
+	    page.setCurrent(current);
+	    page.setSize(size);
+	    return ResponseHelper.buildResponse(hygfPreparationMoneyAuditingServiceImpl.queryForHygfPreparationMoneyAuditingPage(page));
+	}
+
+	/**
+	 * 列表全部数据查询
+     *
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@ApiOperation(httpMethod = "GET",value = "投融审核表列表全部数据查询",   notes = "投融审核表列表全部数据查询")
+	@GetMapping(value = "/list")
+	public ResponseModel<List<HygfPreparationMoneyAuditingDto>> selectForList() {
+	    return ResponseHelper.buildResponse(hygfPreparationMoneyAuditingServiceImpl.queryForHygfPreparationMoneyAuditingList());
+	}
+}

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/HygfReplenishmentController.java

+package com.yeejoin.amos.boot.module.hygf.biz.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.Api;
+import org.springframework.web.bind.annotation.RestController;
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import java.util.List;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.HygfReplenishmentServiceImpl;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+import org.springframework.beans.factory.annotation.Autowired;
+import javax.servlet.http.HttpServletRequest;
+import org.springframework.web.bind.annotation.*;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.hygf.api.dto.HygfReplenishmentDto;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+
+/**
+ * 
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+@RestController
+@Api(tags = "Api")
+@RequestMapping(value = "/hygf-replenishment")
+public class HygfReplenishmentController extends BaseController {
+
+    @Autowired
+    HygfReplenishmentServiceImpl hygfReplenishmentServiceImpl;
+
+    /**
+     * 新增
+     *
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/save")
+	@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
+	public ResponseModel<HygfReplenishmentDto> save(@RequestBody HygfReplenishmentDto model) {
+	    model = hygfReplenishmentServiceImpl.createWithModel(model);
+	    return ResponseHelper.buildResponse(model);
+	}
+
+	/**
+     * 根据sequenceNbr更新
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PutMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新", notes = "根据sequenceNbr更新")
+	public ResponseModel<HygfReplenishmentDto> updateBySequenceNbrHygfReplenishment(@RequestBody HygfReplenishmentDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+	    model.setSequenceNbr(sequenceNbr);
+	    return ResponseHelper.buildResponse(hygfReplenishmentServiceImpl.updateWithModel(model));
+	}
+
+	/**
+     * 根据sequenceNbr删除
+     *
+     * @param sequenceNbr 主键
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @DeleteMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除", notes = "根据sequenceNbr删除")
+    public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
+        return ResponseHelper.buildResponse(hygfReplenishmentServiceImpl.removeById(sequenceNbr));
+    }
+
+    /**
+     * 根据sequenceNbr查询
+     *
+	 * @param sequenceNbr  主键
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/{sequenceNbr}")
+	@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个",  notes = "根据sequenceNbr查询单个")
+	public ResponseModel<HygfReplenishmentDto> selectOne(@PathVariable Long sequenceNbr) {
+	    return ResponseHelper.buildResponse(hygfReplenishmentServiceImpl.queryBySeq(sequenceNbr));
+	}
+
+	/**
+     * 列表分页查询
+     *
+     * @param current 当前页
+     * @param current 每页大小
+     * @return
+     */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/page")
+	@ApiOperation(httpMethod = "GET",value = "分页查询",  notes = "分页查询")
+	public ResponseModel<Page<HygfReplenishmentDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
+                    (value = "size") int size) {
+	    Page<HygfReplenishmentDto> page = new Page<HygfReplenishmentDto>();
+	    page.setCurrent(current);
+	    page.setSize(size);
+	    return ResponseHelper.buildResponse(hygfReplenishmentServiceImpl.queryForHygfReplenishmentPage(page));
+	}
+
+	/**
+	 * 列表全部数据查询
+     *
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@ApiOperation(httpMethod = "GET",value = "列表全部数据查询",   notes = "列表全部数据查询")
+	@GetMapping(value = "/list")
+	public ResponseModel<List<HygfReplenishmentDto>> selectForList() {
+	    return ResponseHelper.buildResponse(hygfReplenishmentServiceImpl.queryForHygfReplenishmentList());
+	}
+}

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/PeasantHouseholdController.java

@@ -208,6 +208,7 @@ public class PeasantHouseholdController extends BaseController {
 	public ResponseModel<Page<PeasantHousehold>> queryForPage(@RequestParam(value = "current") int current,
 															  @RequestParam(value = "size") int size,
 															  @RequestParam(value = "ownersName",required = false)String ownersName,
+															  @RequestParam(value = "preparationMoneyState",required = false)String preparationMoneyState,
 															  @RequestParam(value = "developerId",required = false)Long developerId) {
 	    Page<PeasantHousehold> page = new Page<PeasantHousehold>();
 	    page.setCurrent(current);
@@ -221,7 +222,7 @@ public class PeasantHouseholdController extends BaseController {
 //        String orgCode = userUnitInformationDto.getAmosDealerOrgCode();
 
 		Integer isCertified = PeasantHouseholdEnum.已认证.getCode();
-		return ResponseHelper.buildResponse(peasantHouseholdServiceImpl.queryForPeasantHouseholdPage(page, null,ownersName,developerId,isCertified));
+		return ResponseHelper.buildResponse(peasantHouseholdServiceImpl.queryForPeasantHouseholdPage(page, null,ownersName,developerId,isCertified,preparationMoneyState));
 	}
 
 	/**

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/PreparationMoneyController.java

@@ -10,14 +10,18 @@ import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationMoneyDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.PreparationPageDto;
 import com.yeejoin.amos.boot.module.hygf.api.dto.UserUnitInformationDto;
 import com.yeejoin.amos.boot.module.hygf.api.entity.DesignInformation;
+import com.yeejoin.amos.boot.module.hygf.api.entity.HygfReplenishment;
 import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
 import com.yeejoin.amos.boot.module.hygf.api.entity.PreparationMoney;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.DocumentStationMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.PersonnelBusinessMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.PreparationMoneyMapper;
+import com.yeejoin.amos.boot.module.hygf.api.util.CommonResponseNewUtil;
 import com.yeejoin.amos.boot.module.hygf.biz.service.impl.DesignInformationServiceImpl;
+import com.yeejoin.amos.boot.module.hygf.biz.service.impl.HygfReplenishmentServiceImpl;
 import com.yeejoin.amos.boot.module.hygf.biz.service.impl.PreparationMoneyServiceImpl;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import io.seata.spring.annotation.GlobalTransactional;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -54,6 +58,8 @@ public class PreparationMoneyController extends BaseController {
     PersonnelBusinessMapper personnelBusinessMapper;
     @Autowired
     DocumentStationMapper documentStationMapper;
+    @Autowired
+	HygfReplenishmentServiceImpl hygfReplenishmentService;
     /**
      * 新增发货单
      *
@@ -62,9 +68,11 @@ public class PreparationMoneyController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
 	@PostMapping(value = "/save")
 	@ApiOperation(httpMethod = "POST", value = "新增发货单", notes = "新增发货单")
-	public ResponseModel<PreparationMoney> save( @RequestBody PreparationMoney model) {
+	@GlobalTransactional
+	public ResponseModel<PreparationMoney> save( @RequestParam("isSubmit") String isSubmit, @RequestBody PreparationMoney model) {
         AgencyUserModel agencyUserModel= getUserInfo();
-	    model = preparationMoneyServiceImpl.saveOrUpdateObject(model,agencyUserModel);
+	   model = preparationMoneyServiceImpl.saveOrUpdateObjectNew(model,agencyUserModel, isSubmit);
+		//   model = preparationMoneyServiceImpl.saveOrUpdateObject(model,agencyUserModel);
 	    return ResponseHelper.buildResponse(model);
 	}
 
@@ -216,7 +224,7 @@ public class PreparationMoneyController extends BaseController {
     ) {
         List<PeasantHousehold>  list=preparationMoneyMapper.getPeasantHouseholdData(sequenceNbr,ownersName);
 
-       Page<PeasantHousehold> pagenew = new Page<PeasantHousehold>();
+       Page<PeasantHousehold> pagenew = new Page<>();
         pagenew.setRecords(list);
         pagenew.setTotal(list.size());
         return ResponseHelper.buildResponse(pagenew);
@@ -242,4 +250,84 @@ public class PreparationMoneyController extends BaseController {
 
         return ResponseHelper.buildResponse(preparationMoneyServiceImpl.selectOnePreparationMoney(sequenceNbr));
     }
+
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/uploadVoucher")
+	@ApiOperation(httpMethod = "POST",value = "上传收获凭证",  notes = "上传收获凭证")
+	@GlobalTransactional
+	public ResponseModel uploadVoucher(@RequestParam(value = "instanceId") String instanceId,PreparationMoney model, String isSubmit) {
+
+		preparationMoneyServiceImpl.uploadVoucher(model,instanceId,isSubmit);
+		return CommonResponseNewUtil.failure();
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/excuteFlow")
+	@ApiOperation(httpMethod = "POST",value = "收货审核",  notes = "收货审核")
+	@GlobalTransactional
+	public ResponseModel excuteFlow(@RequestParam(value = "instanceId" ,required = false) String instanceId,
+									@RequestParam(value = "sequenceNbr") Long sequenceNbr,@RequestBody Map<String, Object> kv) {
+
+		preparationMoneyServiceImpl.excuteFlow(instanceId,kv,sequenceNbr);
+		return CommonResponseNewUtil.failure();
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/replenishmentSubmit")
+	@ApiOperation(httpMethod = "POST",value = "补货申请",  notes = "补货申请")
+	@GlobalTransactional
+	public ResponseModel replenishmentSubmit( @RequestBody HygfReplenishment hygfReplenishment) {
+
+		hygfReplenishmentService.save(hygfReplenishment);
+		preparationMoneyServiceImpl.replenishmentSubmit(hygfReplenishment.getPreparationMoneyId());
+		return CommonResponseNewUtil.failure();
+	}
+
+
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PutMapping(value = "/replenishmentRollback")
+	@ApiOperation(httpMethod = "PUT",value = "补货撤回",  notes = "补货撤回")
+
+	public ResponseModel  replenishmentRollback(@RequestParam(value = "sequenceNbr") Long sequenceNbr) {
+		preparationMoneyServiceImpl.replenishmentRollback(sequenceNbr);
+		return CommonResponseNewUtil.failure();
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/replenishmentAudit")
+	@ApiOperation(httpMethod = "POST",value = "补货审核",  notes = "补货审核")
+	@GlobalTransactional
+	public ResponseModel  replenishmentAudit(@RequestParam(value = "sequenceNbr") Long sequenceNbr,@RequestBody Map<String,Object> kv) {
+		preparationMoneyServiceImpl.replenishmentAudit(sequenceNbr,kv);
+		return CommonResponseNewUtil.failure();
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/submitOrder")
+	@ApiOperation(httpMethod = "POST",value = "补货审核",  notes = "补货审核")
+	@GlobalTransactional
+	public ResponseModel  submitOrder(@RequestParam(value = "instanceId") String instanceId,
+									  @RequestParam(value = "isSubmit") String isSubmit,
+									  @RequestBody PreparationMoney model) {
+		preparationMoneyServiceImpl.submitOrder( model,  instanceId,  isSubmit);
+		return CommonResponseNewUtil.failure();
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/preparationStation")
+	@ApiOperation(httpMethod = "GET",value = "发货电站",  notes = "发货电站")
+	@GlobalTransactional
+	public ResponseModel<IPage<Map<String,Object>>> preparationStation(
+			@RequestParam(value = "current") Integer current,
+			@RequestParam(value = "size") Integer size,
+			@RequestParam(value = "ownersName",required = false) String ownersName,
+			@RequestParam(value = "regionalcompaniesSeq",required = false) String regionalcompaniesSeq,
+			@RequestParam(value = "developerId",required = false) String developerId,
+			@RequestParam(value = "state",required = false) String state,
+			@RequestParam(value = "preparationMoneyState") String preparationMoneyState){
+
+		return ResponseHelper.buildResponse(preparationMoneyServiceImpl.preparationStation(current,size,preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state)) ;
+	}
 }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/controller/WorkOrderController.java

@@ -202,7 +202,7 @@ public class WorkOrderController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping (value = "/getPowerStationConstructionData")
     @ApiOperation(httpMethod = "GET",value = "无分页查询",  notes = "无分页查询")
-    public ResponseModel<Map<String,Object>> getPowerStationConstructionData(
+    public ResponseModel<PowerStationConstructionData> getPowerStationConstructionData(
             @RequestBody PowerStationConstructionData  powerStationConstructionData
     ) {
 	    //查询施工信息
@@ -210,10 +210,7 @@ public class WorkOrderController extends BaseController {
         up.eq(PowerStationConstructionData::getWorkOrderId,powerStationConstructionData.getWorkOrderId());
         up.eq(PowerStationConstructionData::getWorkOrderPowerStationId,powerStationConstructionData.getWorkOrderPowerStationId());
         PowerStationConstructionData da=  powerStationConstructionDataMapper.selectOne(up);
-        Map<String,Object> map =new HashMap<>();
-        map.put("powerStationConstructionData",da!=null?da:new PowerStationConstructionData());
-        map.put("powerStationConstructionDatafj",da!=null?da:new PowerStationConstructionData());
-        return ResponseHelper.buildResponse(map);
+        return ResponseHelper.buildResponse(da!=null?da:new PowerStationConstructionData());
     }
 
 
@@ -221,7 +218,7 @@ public class WorkOrderController extends BaseController {
 
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping (value = "/addOrUpdate")
-    @ApiOperation(httpMethod = "GET",value = "无分页查询",  notes = "无分页查询")
+    @ApiOperation(httpMethod = "POST",value = "施工信息添加或者修改",  notes = "施工信息添加或者修改")
     public ResponseModel<PowerStationConstructionData> addOrUpdate(
             @RequestBody PowerStationConstructionData  powerStationConstructionData
     ) {

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/HygfPreparationMoneyAuditingServiceImpl.java

+package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.HygfPreparationMoneyAuditing;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.HygfPreparationMoneyAuditingMapper;
+import com.yeejoin.amos.boot.module.hygf.api.service.IHygfPreparationMoneyAuditingService;
+import com.yeejoin.amos.boot.module.hygf.api.dto.HygfPreparationMoneyAuditingDto;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import java.util.List;
+
+/**
+ * 投融审核表服务实现类
+ *
+ * @author system_generator
+ * @date 2024-06-18
+ */
+@Service
+public class HygfPreparationMoneyAuditingServiceImpl extends BaseService<HygfPreparationMoneyAuditingDto,HygfPreparationMoneyAuditing,HygfPreparationMoneyAuditingMapper> implements IHygfPreparationMoneyAuditingService {
+    /**
+     * 分页查询
+     */
+    public Page<HygfPreparationMoneyAuditingDto> queryForHygfPreparationMoneyAuditingPage(Page<HygfPreparationMoneyAuditingDto> page)   {
+        return this.queryForPage(page, null, false);
+    }
+
+    /**
+     * 列表查询 示例
+     */
+    public List<HygfPreparationMoneyAuditingDto> queryForHygfPreparationMoneyAuditingList()   {
+        return this.queryForList("" , false);
+    }
+}
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/HygfReplenishmentServiceImpl.java

+package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.hygf.api.entity.HygfReplenishment;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.HygfReplenishmentMapper;
+import com.yeejoin.amos.boot.module.hygf.api.service.IHygfReplenishmentService;
+import com.yeejoin.amos.boot.module.hygf.api.dto.HygfReplenishmentDto;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import java.util.List;
+
+/**
+ * 服务实现类
+ *
+ * @author system_generator
+ * @date 2024-07-02
+ */
+@Service
+public class HygfReplenishmentServiceImpl extends BaseService<HygfReplenishmentDto,HygfReplenishment,HygfReplenishmentMapper> implements IHygfReplenishmentService {
+    /**
+     * 分页查询
+     */
+    public Page<HygfReplenishmentDto> queryForHygfReplenishmentPage(Page<HygfReplenishmentDto> page)   {
+        return this.queryForPage(page, null, false);
+    }
+
+    /**
+     * 列表查询 示例
+     */
+    public List<HygfReplenishmentDto> queryForHygfReplenishmentList()   {
+        return this.queryForList("" , false);
+    }
+}
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/PeasantHouseholdServiceImpl.java

@@ -2,9 +2,11 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -59,6 +61,33 @@ import java.util.stream.Collectors;
 @Slf4j
 public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto,PeasantHousehold,PeasantHouseholdMapper> implements IPeasantHouseholdService {
 
+    public static final String SECRETKEY = "qaz";
+    @Autowired
+    SurveyInformationServiceImpl surveyInformationService;
+    @Autowired
+    SurveyDetailsServiceImpl surveyDetailsService;
+    @Autowired
+    InformationServiceImpl informationService;
+    @Autowired
+    ExtendedInformationServiceImpl extendedInformationService;
+    @Autowired
+    CommercialServiceImpl commercialService;
+    @Autowired
+    PeasantHouseholdMapper peasantHouseholdMapper;
+    @Autowired
+    SurveyInformationServiceImpl surveyInformationServiceImpl;
+    @Autowired
+    HouseholdContractServiceImpl householdContractServiceImpl;
+    @Autowired
+    PersonnelBusinessMapper personnelBusinessMapper;
+    @Autowired
+    UnitInfoServiceImpl unitInfoServiceImpl;
+    @Autowired
+    AmosRequestContext requestContext;
+    @Autowired
+    ToDoTasksServiceImpl toDoTasksServiceImpl;
+    @Autowired
+    RegionalCompaniesMapper regionalCompaniesMapper;
     private Long TOKEN_TIME = 1209600l;
 
     @Value("${amos.system.user.product}")
@@ -100,43 +129,7 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
     @Autowired
     private IWxService wxService;
 
-    @Autowired
-    SurveyInformationServiceImpl surveyInformationService;
-
-    @Autowired
-    SurveyDetailsServiceImpl surveyDetailsService;
-
-    @Autowired
-    InformationServiceImpl informationService;
-
-    @Autowired
-    ExtendedInformationServiceImpl extendedInformationService;
-
-    @Autowired
-    CommercialServiceImpl commercialService;
-
-    @Autowired
-    PeasantHouseholdMapper peasantHouseholdMapper;
-
-    @Autowired
-    SurveyInformationServiceImpl surveyInformationServiceImpl;
-
-    @Autowired
-    HouseholdContractServiceImpl householdContractServiceImpl;
-    @Autowired
-    PersonnelBusinessMapper personnelBusinessMapper;
-    @Autowired
-    UnitInfoServiceImpl unitInfoServiceImpl;
-    @Autowired
-    AmosRequestContext requestContext;
-    @Autowired
-    ToDoTasksServiceImpl toDoTasksServiceImpl;
-    @Autowired
-    RegionalCompaniesMapper regionalCompaniesMapper;
-
-    public static final String SECRETKEY = "qaz";
-
-    @Transactional (rollbackFor = Exception.class)
+    @Transactional(rollbackFor = Exception.class)
     public PeasantHouseholdDto savePeasantHousehold(PeasantHouseholdDto model, AgencyUserModel userInfo) {
         SurveyInformationDto surveyInformationDto = new SurveyInformationDto();
         surveyInformationDto.setSurveyNumber(this.getkcNo(model.getRegionalCompaniesSeq()));
@@ -234,12 +227,12 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
      * 分页查询
      */
 
-    public Page<PeasantHousehold> queryForPeasantHouseholdPage(Page<PeasantHousehold> page,String developerCode, String ownersName,Long developerId, Integer isCertified)   {
+    public Page<PeasantHousehold> queryForPeasantHouseholdPage(Page<PeasantHousehold> page,String developerCode, String ownersName,Long developerId, Integer isCertified,String preparationMoneyState)   {
         int current = (int)page.getCurrent();
         int size = (int)page.getSize();
 
         PageHelper.startPage(current,size);
-        List<PeasantHousehold> records = peasantHouseholdMapper.queryForPage( developerCode,ownersName,developerId, isCertified);
+        List<PeasantHousehold> records = peasantHouseholdMapper.queryForPage( developerCode,ownersName,developerId, isCertified,preparationMoneyState);
         PageInfo<PeasantHousehold> objectPageInfo = new PageInfo<PeasantHousehold>(records);
 
 
@@ -830,4 +823,81 @@ public class PeasantHouseholdServiceImpl extends BaseService<PeasantHouseholdDto
     }
 
 
+    public PeasantHousehold getDataByState(Long peasantHouseholdId) {
+        LambdaQueryWrapper<PeasantHousehold> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(PeasantHousehold::getConstructionState,"勘察完成");
+        wrapper.eq(BaseEntity::getSequenceNbr,peasantHouseholdId);
+        return   this.getBaseMapper().selectOne(wrapper);
+    }
+    public Map<String, Object> getJxsAndNhData(String nhUserId, String jxsUserId, String qrCodeType) {
+        QueryWrapper<PeasantHousehold> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("amos_user_id", nhUserId);
+        Map<String, Object> result = new HashMap<>();
+        List<PeasantHousehold> peasantHouseholds = this.getBaseMapper().selectList(queryWrapper);
+        result.put("nh", peasantHouseholds);
+        result.put("jxs", buildDefaultPeasantHouseholdDto(jxsUserId, qrCodeType, null));
+        return result;
+    }
+
+    public List<PeasantHousehold> getPeasantHouseByUserId(String nhUserId) {
+        QueryWrapper<PeasantHousehold> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("amos_user_id", nhUserId);
+        return this.getBaseMapper().selectList(queryWrapper);
+    }
+
+    public PeasantHouseholdDto addNewPeasantHousehold(PeasantHouseholdDto model) {
+        SurveyInformationDto surveyInformationDto = new SurveyInformationDto();
+        surveyInformationDto.setSurveyNumber(this.getkcNo(model.getRegionalCompaniesSeq()));
+        surveyInformationServiceImpl.createWithModel(surveyInformationDto);
+
+        model.setSurveyInformationId(surveyInformationDto.getSequenceNbr());
+        model.setSurveyOrNot(0);
+        model.setReview(0);
+        if (model.getCreationTime() == null) {
+            model.setCreationTime(new Date());
+        }
+        model.setPeasantHouseholdNo(this.getPeasantHouseholdNo(model.getRegionalCompaniesSeq()));
+        model.setIsCertified(model.getIsCertified() == null ? 0 : model.getIsCertified());// 未认证
+
+        PeasantHousehold peasantHousehold = new PeasantHousehold();
+        BeanUtils.copyProperties(model, peasantHousehold);
+        peasantHousehold.setSequenceNbr(null);
+        peasantHousehold.setConstructionState(ArrivalStateeEnum.待勘察.getCode());
+        this.save(peasantHousehold);
+        //生成合同
+        HouseholdContract householdContract = new HouseholdContract();
+        householdContract.setPartyA(peasantHousehold.getOwnersName());
+        householdContract.setPeasantHouseholdNumber(peasantHousehold.getPeasantHouseholdNo());
+        householdContract.setPeasantHouseholdCard(peasantHousehold.getIdCard());
+        householdContract.setDealerId(peasantHousehold.getDeveloperId());
+        householdContract.setDealerCode(peasantHousehold.getDeveloperCode());
+        householdContract.setDealerName(peasantHousehold.getDeveloperName());
+        householdContract.setPeasantHouseholdId(peasantHousehold.getSequenceNbr());
+        householdContract.setRegionalCompaniesCode(peasantHousehold.getRegionalCompaniesCode());
+        householdContract.setRegionalCompaniesName(peasantHousehold.getRegionalCompaniesName());
+        householdContract.setRegionalCompaniesSeq(peasantHousehold.getRegionalCompaniesSeq());
+        householdContract.setPeasantHouseholdPhone(peasantHousehold.getTelephone());
+        householdContract.setProjectAddressDetail(peasantHousehold.getProjectAddressDetail());
+        householdContract.setProjectAddressName(peasantHousehold.getProjectAddressName());
+        householdContract.setPermanentAddressDetail(peasantHousehold.getPermanentAddressDetail());
+        householdContract.setPermanentAddressName(peasantHousehold.getPermanentAddressName());
+        householdContract.setProjectUserId(peasantHousehold.getAmosUserId());
+        householdContractServiceImpl.addHouseholdContract(householdContract);
+
+        //生成待办任务
+        ToDoTasks toDoTasks = new ToDoTasks(TaskTypeStationEnum.电站勘察.getCode(), peasantHousehold.getSequenceNbr(), "用户" + householdContract.getPartyA() + "电站信息勘察", householdContract.getDealerCode());
+        toDoTasksServiceImpl.addToDoTasksByUserId(peasantHousehold.getDeveloperUserId(), toDoTasks, "");
+
+        ToDoTasks toDoTasks1 = new ToDoTasks(TaskTypeStationEnum.合同填报.getCode(), householdContract.getSequenceNbr(), "用户" + householdContract.getPartyA() + "的合同待发起", householdContract.getDealerCode());
+        toDoTasksServiceImpl.addToDoTasksByUserId(peasantHousehold.getDeveloperUserId(), toDoTasks1, "");
+
+        return model;
+    }
+
+    public IPage<PeasantHousehold> getPeasantHousePage(PeasantHouseholdPageDto peasantHouseholdPageDto) {
+        QueryWrapper<PeasantHousehold> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("amos_user_id", peasantHouseholdPageDto.getNhUserId());
+        queryWrapper.like(StrUtil.isNotEmpty(peasantHouseholdPageDto.getPeasantHouseholdNo()),"peasant_household_no", "%"+peasantHouseholdPageDto.getPeasantHouseholdNo()+"%");
+        return this.baseMapper.selectPage(new Page<>(peasantHouseholdPageDto.getCurrent(),peasantHouseholdPageDto.getSize()),queryWrapper);
+    }
 }
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/PowerStationServiceImpl.java

 package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -85,6 +86,8 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
     AmosRequestContext requestContext;
     @Autowired
     WorkflowImpl workflow;
+    @Autowired
+	HouseholdContractMapper householdContractMapper;
 
 	public Page<PowerStationDto> queryForPowerStationUserRoles(Page<PowerStationDto> page, String powerStationCode,
 			String ownersName, AgencyUserModel userInfo, String serviceAgent, String regionalCompaniesName, String processStatus) {
@@ -256,6 +259,7 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
 			switch (nodeByCode) {
 			case 设计审核:
 				powerStation.setTechnologyStatus(resultObj.getName());
+
 				break;
 			case 投融审核:
 				powerStation.setDesignStatus(resultObj.getName());
@@ -347,6 +351,16 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
 						.selectById(Long.valueOf(peasantHouseholdId));
 				peasantHousehold.setSurveyOrNot(3);
 				peasantHousehold.setConstructionState(ArrivalStateeEnum.勘察完成.getCode());
+				//当勘察完成并且合同双方已盖章 则为待发货
+				LambdaQueryWrapper<HouseholdContract> queryWrapper = new LambdaQueryWrapper<>();
+				queryWrapper.eq(HouseholdContract::getStatus,"双方已签署");
+				queryWrapper.eq(HouseholdContract::getPeasantHouseholdId,peasantHousehold.getSequenceNbr());
+				List<HouseholdContract> householdContracts = householdContractMapper.selectList(queryWrapper);
+				if (CollectionUtil.isNotEmpty(householdContracts) &&  householdContracts.size()>0 ){
+					peasantHousehold.setPreparationMoneyState(ArrivalStateeEnum.待发货.getCode());
+				}
+
+
 				peasantHouseholdService.saveOrUpdate(peasantHousehold);
 			}
 			// }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/WorkFlowService.java

@@ -57,6 +57,23 @@ public class WorkFlowService {
      * 执行
      *
      * */
+    public ProcessTaskDTO rollBackTask(String processInstanceId) {
+        ProcessTaskDTO processTaskDTO;
+        try {
+            log.info("工作流撤回任务接口:/rollBackTask},请求参数：{}", processInstanceId);
+            processTaskDTO = workFlowFeignService.rollBackTask(processInstanceId).getResult();
+        } catch (Exception e) {
+            log.error("调用工作流撤回任务接口失败", e);
+            throw new RuntimeException("调用工作流撤回任务接口失败");
+        }
+        return processTaskDTO;
+    }
+
+
+    /***
+     * 执行
+     *
+     * */
     public ProcessTaskDTO complete(String taskId, TaskResultDTO data) {
         ProcessTaskDTO processTaskDTO;
         try {
@@ -70,7 +87,6 @@ public class WorkFlowService {
     }
 
 
-
     public List<WorkflowResultDto> buildWorkFlowInfo(List<ProcessTaskDTO> processTaskDTOS) {
         List<WorkflowResultDto> workflowResultDtoList = new ArrayList<>();
         processTaskDTOS.forEach(item -> {

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/WorkOrderServiceImpl.java

@@ -254,67 +254,70 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto, WorkOrder, W
 
 	@Transactional
 	public PowerStationConstructionData addOrUpdate(PowerStationConstructionData powerStationConstructionData) {
-
+		//如果不是提交进行单独保存
+		if(powerStationConstructionData.isCommitFlow()){
 //        if(powerStationConstructionData.getSequenceNbr()!=null){
-		// 修改施工电站状态
-		LambdaUpdateWrapper<WorkOrderPowerStation> up = new LambdaUpdateWrapper();
-		up.eq(WorkOrderPowerStation::getSequenceNbr, powerStationConstructionData.getWorkOrderPowerStationId());
-		if (powerStationConstructionData.getConstructionStatus().equals("未完成")) {
-			up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.施工中.getCode());
-		} else {
-			up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.待登记.getCode());
+			// 修改施工电站状态
+			LambdaUpdateWrapper<WorkOrderPowerStation> up = new LambdaUpdateWrapper();
+			up.eq(WorkOrderPowerStation::getSequenceNbr, powerStationConstructionData.getWorkOrderPowerStationId());
+			if (powerStationConstructionData.getConstructionStatus().equals("未完成")) {
+				up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.施工中.getCode());
+			} else {
+				up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.待登记.getCode());
 
-			WorkOrderPowerStation basicGridAcceptanc = workOrderPowerStationMapper
-					.selectById(powerStationConstructionData.getWorkOrderPowerStationId());
-			// 施工完成
-			LambdaUpdateWrapper<PeasantHousehold> up1 = new LambdaUpdateWrapper<>();
-			up1.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网完成.getCode());
-			long idsk = basicGridAcceptanc.getPeasantHouseholdId();
-			up1.eq(PeasantHousehold::getSequenceNbr, idsk);
-			peasantHouseholdMapper.update(null, up1);
+				WorkOrderPowerStation basicGridAcceptanc = workOrderPowerStationMapper
+						.selectById(powerStationConstructionData.getWorkOrderPowerStationId());
+				// 施工完成
+				LambdaUpdateWrapper<PeasantHousehold> up1 = new LambdaUpdateWrapper<>();
+				up1.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网完成.getCode());
+				long idsk = basicGridAcceptanc.getPeasantHouseholdId();
+				up1.eq(PeasantHousehold::getSequenceNbr, idsk);
+				peasantHouseholdMapper.update(null, up1);
 
-		}
-		workOrderPowerStationMapper.update(null, up);
-		// 修改派工单状态
-		LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
-		qu.eq(WorkOrderPowerStation::getWorkOrderId, powerStationConstructionData.getWorkOrderId());
-		List<String> d = new ArrayList<>();
-		d.add(WorkOrderEnum.施工中.getCode());
-		d.add(WorkOrderEnum.待施工.getCode());
-		qu.in(WorkOrderPowerStation::getPowerStationConstructionStatus, d);
-		List<WorkOrderPowerStation> list = workOrderPowerStationMapper.selectList(qu);
+			}
+			workOrderPowerStationMapper.update(null, up);
+			// 修改派工单状态
+			LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
+			qu.eq(WorkOrderPowerStation::getWorkOrderId, powerStationConstructionData.getWorkOrderId());
+			List<String> d = new ArrayList<>();
+			d.add(WorkOrderEnum.施工中.getCode());
+			d.add(WorkOrderEnum.待施工.getCode());
+			qu.in(WorkOrderPowerStation::getPowerStationConstructionStatus, d);
+			List<WorkOrderPowerStation> list = workOrderPowerStationMapper.selectList(qu);
+
+			LambdaUpdateWrapper<WorkOrder> upq = new LambdaUpdateWrapper();
+			upq.eq(WorkOrder::getSequenceNbr, powerStationConstructionData.getWorkOrderId());
+			if (list != null && !list.isEmpty()) {
+				upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.施工中.getCode());
+			} else {
+				upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.登记中.getCode());
+			}
+			workOrderMapper.update(null, upq);
 
-		LambdaUpdateWrapper<WorkOrder> upq = new LambdaUpdateWrapper();
-		upq.eq(WorkOrder::getSequenceNbr, powerStationConstructionData.getWorkOrderId());
-		if (list != null && !list.isEmpty()) {
-			upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.施工中.getCode());
-		} else {
-			upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.登记中.getCode());
 		}
-		workOrderMapper.update(null, upq);
+        // 新增施工信息
+        // 防止重复添加
+        LambdaUpdateWrapper<PowerStationConstructionData> psc = new LambdaUpdateWrapper();
+        psc.eq(PowerStationConstructionData::getWorkOrderPowerStationId,
+                powerStationConstructionData.getWorkOrderPowerStationId());
+        psc.eq(PowerStationConstructionData::getWorkOrderId, powerStationConstructionData.getWorkOrderId());
+        powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData, psc);
+        // powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData);
+
+        // 增加操作日志
+        if (powerStationConstructionData.getSequenceNbr() != null) {
+            ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "编辑施工资料",
+                    new Date(), "", powerStationConstructionData.getWorkOrderId(),
+                    powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
+            constructionRecordsServiceImpl.save(da);
+
+        } else {
+            ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "新增施工资料",
+                    new Date(), "", powerStationConstructionData.getWorkOrderId(),
+                    powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
+            constructionRecordsServiceImpl.save(da);
+        }
 
-		// 新增施工信息
-		// 防止重复添加
-		LambdaUpdateWrapper<PowerStationConstructionData> psc = new LambdaUpdateWrapper();
-		psc.eq(PowerStationConstructionData::getWorkOrderPowerStationId,
-				powerStationConstructionData.getWorkOrderPowerStationId());
-		psc.eq(PowerStationConstructionData::getWorkOrderId, powerStationConstructionData.getWorkOrderId());
-		powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData, psc);
-		// powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData);
-
-		// 增加操作日志
-		if (powerStationConstructionData.getSequenceNbr() != null) {
-			ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "编辑施工资料",
-					new Date(), "", powerStationConstructionData.getWorkOrderId(),
-					powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
-			constructionRecordsServiceImpl.save(da);
-
-		} else {
-			ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "新增施工资料",
-					new Date(), "", powerStationConstructionData.getWorkOrderId(),
-					powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
-			constructionRecordsServiceImpl.save(da);
-		}
 
 //        }else{
 //           //修改施工电站状态

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/application-kingbase8.properties

+## DB properties:
+## db1-production database
+spring.db1.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db1.datasource.url=jdbc:mysql://10.20.1.157:54321/production?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db1.datasource.username=root
+spring.db1.datasource.password=Yeejoin@2020
+spring.db1.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+## db2-sync_data
+spring.db2.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db2.datasource.url=jdbc:mysql://10.20.1.157:3306/amos_idx_biz?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db2.datasource.username=root
+spring.db2.datasource.password=Yeejoin@2020
+spring.db2.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+
+## db5-sync_data
+spring.db5.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db5.datasource.url=jdbc:mysql://10.20.1.157:3306/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db5.datasource.username=root
+spring.db5.datasource.password=Yeejoin@2020
+spring.db5.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+## amos-project
+spring.db6.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db6.datasource.url=jdbc:mysql://10.20.1.157:3306/amos_project?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.db6.datasource.username=root
+spring.db6.datasource.password=Yeejoin@2020
+spring.db6.datasource.driver-class-name: com.mysql.cj.jdbc.Driver
+
+## eureka properties:
+eureka.instance.hostname=10.20.1.160
+eureka.client.serviceUrl.defaultZone=http://admin:a1234560@${eureka.instance.hostname}:10001/eureka/
+## redis properties:
+spring.redis.database=1
+spring.redis.host=10.20.1.210
+spring.redis.port=6379
+spring.redis.password=yeejoin@2020
+
+openHealth=false
+spring.cache.type=GENERIC
+j2cache.open-spring-cache=true
+j2cache.cache-clean-mode=passive
+j2cache.allow-null-values=true
+j2cache.redis-client=lettuce
+j2cache.l2-cache-open=true
+j2cache.broadcast=net.oschina.j2cache.cache.support.redis.SpringRedisPubSubPolicy
+j2cache.L1.provider_class=caffeine
+j2cache.L2.provider_class=net.oschina.j2cache.cache.support.redis.SpringRedisProvider
+j2cache.L2.config_section=lettuce
+j2cache.sync_ttl_to_redis=true
+j2cache.default_cache_null_object=false
+j2cache.serialization=fst
+caffeine.properties=/caffeine.properties
+lettuce.mode=single
+lettuce.namespace=
+lettuce.storage=generic
+lettuce.channel=j2cache
+lettuce.scheme=redis
+lettuce.hosts=${spring.redis.host}:${spring.redis.port}
+lettuce.password=${spring.redis.password}
+lettuce.database=${spring.redis.database}
+lettuce.sentinelMasterId=
+lettuce.maxTotal=100
+lettuce.maxIdle=10
+lettuce.minIdle=10
+lettuce.timeout=10000
+
+
+emqx.clean-session=true
+emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
+emqx.broker=tcp://10.20.1.210:2883
+emqx.user-name=admin
+emqx.password=public
+mqtt.scene.host=mqtt://10.20.1.210:8083/mqtt
+mqtt.client.product.id=mqtt
+mqtt.topic=topic_mqtt
+spring.mqtt.completionTimeout=3000
+emqx.max-inflight=1000
+emqx.client-user-name=admin
+emqx.client-password=public
+
+tdengine-server:
+driver-class-name: com.taosdata.jdbc.rs.RestfulDriver
+jdbc-url: jdbc:TAOS-RS://10.20.0.203:6041/iot_data_1?user=root&password=taosdata&timezone=GMT%2b8&allowMultiQueries=true
+username: root
+password: taosdata
+
+
+#spring.db3.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db3.datasource.url=jdbc:TAOS-RS://10.20.0.203:6041/iot_data?user=root&password=taosdata&timezone=GMT%2b8&allowMultiQueries=true
+spring.db3.datasource.username=root
+spring.db3.datasource.password=taosdata
+spring.db3.datasource.driver-class-name: com.taosdata.jdbc.rs.RestfulDriver
+
+
+# ����ר��td���ݿ� analyse_data
+#spring.db4.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db4.datasource.url=jdbc:TAOS-RS://10.20.0.203:6041/analysis_data?user=root&password=taosdata&timezone=GMT%2b8&allowMultiQueries=true
+spring.db4.datasource.username=root
+spring.db4.datasource.password=taosdata
+spring.db4.datasource.driver-class-name: com.taosdata.jdbc.rs.RestfulDriver
+
+
+## influxDB
+#spring.influx.url= http://172.16.3.155:18186
+#spring.influx.password=Yeejoin@2020
+#spring.influx.user=root
+#spring.influx.database=iot_platform
+#spring.influx.retention_policy=default
+#spring.influx.retention_policy_time=30d
+#spring.influx.actions=10000
+#spring.influx.bufferLimit=20000
+
+## influxDB
+#spring.influx.url= http://139.9.171.247:8086
+#spring.influx.password=Yeejoin@2023
+#spring.influx.user=admin
+#spring.influx.database=iot_platform
+#spring.influx.retention_policy=default
+#spring.influx.retention_policy_time=30d
+#spring.influx.actions=10000
+#spring.influx.bufferLimit=20000
+
+
+spring.influx.url=http://139.9.173.44:8086
+spring.influx.password=Yeejoin@2020
+spring.influx.user=root
+spring.influx.database=iot_platform
+spring.influx.retention_policy=default
+spring.influx.retention_policy_time=30d
+spring.influx.actions=10000
+spring.influx.bufferLimit=20000
+
+knife4j.production=false
+knife4j.enable=true
+knife4j.basic.enable=true
+knife4j.basic.username=admin
+knife4j.basic.password=a1234560
+
+management.security.enabled=true
+spring.security.user.name=admin
+spring.security.user.password=a1234560
+
+fire-rescue=123
+
+mybatis-plus.global-config.db-config.update-strategy=ignored
+
+# user-amos setting : This value is the secretkey for person manage moudle accout password encryption.please don't change it!!!
+amos.secret.key=qaz
+# if your service can't be access ,you can use this setting , you need change ip as your.
+#eureka.instance.prefer-ip-address=true
+#eureka.instance.ip-address=172.16.3.122
+
+
+spring.activemq.broker-url=tcp://10.20.1.210:61616
+spring.activemq.user=admin
+spring.activemq.password=admin
+spring.jms.pub-sub-domain=false
+myqueue=amos.privilege.v1.JXIOP.AQSC_FDGL.userBusiness
+
+# ?????????
+fan.statuts.stattuspath=upload/jxiop/device_status
+
+pictureUrl=upload/jxiop/syz/
+
+
+
+
+
+#kafka
+spring.kafka.bootstrap-servers=10.20.0.223:9092,10.20.0.133:9200
+spring.kafka.producer.retries=1
+spring.kafka.producer.bootstrap-servers=10.20.0.223:9092,10.20.0.133:9200
+spring.kafka.producer.batch-size=16384
+spring.kafka.producer.buffer-memory=33554432
+spring.kafka.producer.acks=1
+spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.consumer.group-id=consumerGroup
+spring.kafka.consumer.bootstrap-servers=10.20.0.223:9092,10.20.0.133:9200
+spring.kafka.consumer.enable-auto-commit=false
+spring.kafka.consumer.auto-offset-reset=earliest
+spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
+spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
+spring.kafka.listener.ack-mode=manual_immediate
+spring.kafka.listener.type=batch
+#һ����ȡ���� && �߳�����
+spring.kafka.consumer.max-poll-records=30
+#spring.kafka.consumer.fetch-max-wait= 10000
+
+
+#��ǰʱ����ǰƫ������    ����ʷƫ������
+last.month.num = 12
+
+#����� �㷨����
+base.url.XGX=http://139.9.171.247:8052/intelligent-analysis/correlation
+#�������� �㷨���õ�ַ
+base.url.GKHF=http://139.9.171.247:8052/intelligent-analysis/working-condition-division
+#����� �㷨����
+base.url.ZXZ=http://139.9.171.247:8052/intelligent-analysis/central-value
+#ָ���������㷨����
+base.url.zsfx:http://139.9.171.247:8052/intelligent-analysis/index-analysis
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/entity/Region.java

@@ -2,9 +2,7 @@ package com.yeejoin.amos.boot.module.jxiop.api.entity;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
-import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import lombok.Data;
-import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 import java.util.Date;
 
@@ -36,8 +34,8 @@ public class Region  {
     /**
      * 等级
      */
-	@TableField("LEVEL")
-    private String level;
+	@TableField("LEVEL_")
+    private String level_;
 
     /**
      * 上级编码

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/HouseholdPvMapper.xml

@@ -7,7 +7,7 @@
         hp.sequence_nbr as id,
         hp.platform_company_id AS platformCompanyId,
         hp.number,
-        hp.`name`,
+        hp.name,
         hp.sex,
         hp.ID_number AS idNumber,
         hp.expiry_time AS expiryTime,
@@ -106,7 +106,7 @@
             resultType="com.yeejoin.amos.boot.module.jxiop.api.dto.EquipMessageExport">
         SELECT
         (@i:= @i+1) as numSort,
-        hp.`name`,
+        hp.name,
         hp.ID_number AS idNumber,
         hpd.type,
         hpd.name as equipName,

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/MonitorFanIndicatorMapper.xml

@@ -20,12 +20,12 @@
 
     <select id="getBoosterStationInfo" resultType="java.util.Map">
         select
-            `sequence_nbr` as id,
-            `gateway_id` as gatewayId,
-            `booster_name` as text,
+            sequence_nbr as id,
+            gateway_id as gatewayId,
+            booster_name as text,
              booster_name  as boosterName,
-            `booster_code` as boosterCode,
-            `sort` as value
+            booster_code as boosterCode,
+            sort as value
         from booster_station_info
         <where>
             <if test="gatewayId != null and gatewayId != ''">
@@ -44,12 +44,12 @@
     <select id="getBoosterStationInfo2" resultType="java.util.Map">
         select * from
         ((select
-        `sequence_nbr` as id,
-        `gateway_id` as gatewayId,
-        `booster_name` as text,
+        sequence_nbr as id,
+        gateway_id as gatewayId,
+        booster_name as text,
         booster_name as boosterName,
-        `booster_code` as boosterCode,
-        `sort` as value
+        booster_code as boosterCode,
+        sort as value
         from booster_station_info
         <where>
             sort != 2
@@ -66,7 +66,7 @@
         union all
         (select
         '99999' as id,
-        `gateway_id` as gatewayId,
+        gateway_id as gatewayId,
         '1主变' as text,
         '1主变' as boosterName,
         '2' as boosterCode,
@@ -84,12 +84,12 @@
 
     <select id="getMajorBoosterStationInfo" resultType="java.util.Map">
         select
-        `sequence_nbr` as id,
-        `gateway_id` as gatewayId,
-        `booster_name` as text,
+        sequence_nbr as id,
+        gateway_id as gatewayId,
+        booster_name as text,
         booster_name  as boosterName,
-        `booster_code` as boosterCode,
-        `sort` as value
+        booster_code as boosterCode,
+        sort as value
         from booster_station_info
         <where>
             <if test="gatewayId != null and gatewayId != ''">
@@ -103,12 +103,12 @@
 
     <select id="getMajorBoosterStationInfoBySort" resultType="java.util.Map">
         select
-            `sequence_nbr` as id,
-            `gateway_id` as gatewayId,
-            `booster_name` as text,
+            sequence_nbr as id,
+            gateway_id as gatewayId,
+            booster_name as text,
             booster_name  as boosterName,
-            `booster_code` as boosterCode,
-            `sort` as value
+            booster_code as boosterCode,
+            sort as value
         from booster_station_info
         where
             sort = #{sort}
@@ -119,12 +119,12 @@
 
     <select id="getBoosterStationInfoNormal" resultType="java.util.Map">
         select
-        `sequence_nbr` as id,
-        `gateway_id` as gatewayId,
-        `booster_name` as text,
+        sequence_nbr as id,
+        gateway_id as gatewayId,
+        booster_name as text,
         booster_name as boosterName,
-        `booster_code` as boosterCode,
-        `sort` as value
+        booster_code as boosterCode,
+        sort as value
         from booster_station_info
         <where>
             <if test="gatewayId != null and gatewayId != ''">

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/PersonBasicMapper.xml

@@ -9,7 +9,7 @@
         select
         person_basic.sequence_nbr sequenceNbr,
         person_basic.head_photo headphoto,
-        person_account.`name` name,
+        person_account.name name,
         person_basic.sex,
         person_basic.phone phone,
         person_account.project_name projectName,
@@ -83,7 +83,7 @@
     <select id="getEXPersonUser" resultType="com.yeejoin.amos.boot.module.jxiop.api.dto.EXPersonUser">
 
         select
-        person_account.`name` name,
+        person_account.name name,
         person_account.job_number jobNumber,
         person_account.project_name projectName,
         person_account.project_department_name departmentName,
@@ -116,7 +116,7 @@
     <select id="getEXPersonUserAll" resultType="com.yeejoin.amos.boot.module.jxiop.api.dto.EXPersonUser">
 
         select
-        person_account.`name` name,
+        person_account.name name,
         person_account.job_number jobNumber,
         person_account.project_name projectName,
         person_account.project_department_name departmentName,
@@ -296,7 +296,7 @@
 
     <select id="getPersonStatistics" resultType="com.yeejoin.amos.boot.module.jxiop.api.entity.StationQrCodeStatistics">
         SELECT
-            project_org_code AS `code`,
+            project_org_code AS code,
             count( qrcode_color = 'red' OR NULL ) AS redNum,
             count( qrcode_color = 'yellow' OR NULL ) AS yellowNum,
             count( qrcode_color = 'green' OR NULL ) AS greenNum,
@@ -310,7 +310,7 @@
 
     <select id="getPersonDetailInfoByObjectId" resultType="java.util.Map">
         SELECT
-            IFNULL(b.`name`, '') as `name`,
+            IFNULL(b.name, '') as name,
             IFNULL(a.phone, '') as phone,
             IFNULL(a.post_name, '') as postName,
             IFNULL(b.project_name, '') as stationName,

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/StationBasicMapper.xml

@@ -173,9 +173,9 @@
     <update id="updateYardByProjectOrgCode">
         <foreach collection="list" item="item" separator=";">
             update
-            `station_basic`
+            station_basic
             set
-            `qrcode_color` = #{item.qrcodeColor},
+            qrcode_color = #{item.qrcodeColor},
             <if test="item.level != null and item.level != ''">
             risk_Level = #{item.level},
             </if>

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/amosproject/UserEmpowerMapper.xml

@@ -14,7 +14,7 @@
                 AND privilege_company.COMPANY_TYPE=#{companyType}
             </if>
             <if test="level != null and level != ''">
-                AND privilege_company.`LEVEL`=#{level}
+                AND privilege_company.LEVEL_=#{level}
             </if>
             <if test="companyOrgCode != null ">
                 AND privilege_company.ORG_CODE IN

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/warning/McbWarningMapper.xml

@@ -359,8 +359,8 @@
             )
         SELECT
             a.SEQUENCE_NBR AS sequenceNbr,
-            COALESCE(a.NAME, '') AS `name`,
-            COALESCE(a.CODE, '') AS `code`,
+            COALESCE(a.NAME, '') AS name,
+            COALESCE(a.CODE, '') AS code,
             COALESCE(a.PARENT_ID, '') AS parentId,
             COALESCE(a.LONGITUDE, '') AS longitude,
             COALESCE(a.LATITUDE, '') AS latitude,
@@ -391,7 +391,7 @@
             count( 1 ) AS yearNum
         FROM
             amos_mcb.mcb_warning_warning_info
-                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.`CODE` = mcb_warning_warning_info.SOURCE_ATTRIBUTION
+                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.CODE = mcb_warning_warning_info.SOURCE_ATTRIBUTION
         WHERE
             YEAR(CREATE_DATE) = YEAR(CURDATE())
         <if test="province != null and province != '' ">
@@ -408,7 +408,7 @@
             count( 1 ) AS monNum
         FROM
             amos_mcb.mcb_warning_warning_info
-                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.`CODE` = mcb_warning_warning_info.SOURCE_ATTRIBUTION
+                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.CODE = mcb_warning_warning_info.SOURCE_ATTRIBUTION
         WHERE
             MONTH(CREATE_DATE) = MONTH(CURDATE())
         <if test="province != null and province != '' ">
@@ -425,7 +425,7 @@
             mwbsa.PROVINCE
         FROM
             amos_mcb.mcb_warning_warning_info
-                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.`CODE` = mcb_warning_warning_info.SOURCE_ATTRIBUTION
+                Left join mcb_warning_base_source_attribution mwbsa  on mwbsa.CODE = mcb_warning_warning_info.SOURCE_ATTRIBUTION
         WHERE
             DATE_FORMAT(CREATE_DATE,'%Y-%m-%d') =  CURDATE()
         <if test="province != null and province != '' ">

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/EnergyAccessController.java

+package com.yeejoin.amos.boot.module.jxiop.biz.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.biz.common.interceptors.PermissionInterceptor;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.EnergyAccessServiceImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+
+import java.util.Map;
+
+
+@RestController
+@Api(tags = "能源接入相关接口")
+@RequestMapping(value = "/energyAccess")
+public class EnergyAccessController extends BaseController {
+    @Autowired
+    EnergyAccessServiceImpl energyAccessServiceImpl;
+
+    private final Logger logger = LoggerFactory.getLogger(EnergyAccessController.class);
+
+    @RequestMapping(value = "/getInstalledCapacity", method = RequestMethod.GET)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "获取并网容量", notes = "获取并网容量")
+    public Page<Map<String, Object>> getInstalledCapacity(String current, String pageSize, String code,String sourceStationId,String tp) {
+        logger.info("获取并网容量接口入参：current ={}，pageSize ={}，code = {},sourceStationId = {},tp = {}",current,pageSize,code,sourceStationId,tp);
+        return energyAccessServiceImpl.getInstalledCapacity(current, pageSize, code,sourceStationId,tp);
+    }
+
+    @RequestMapping(value = "/getQuotaCompleteInfo", method = RequestMethod.GET)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "获取片区指标完成情况", notes = "获取片区指标完成情况")
+    public Page<Map<String, Object>> getQuotaCompleteInfo(String current, String pageSize, String code,String sourceStationId,String tp) {
+        logger.info("获取片区指标完成情况入参：current ={}，pageSize ={}，code = {},sourceStationId = {},tp = {}",current,pageSize,code,sourceStationId,tp);
+        return energyAccessServiceImpl.getQuotaCompleteInfo(current, pageSize, code,sourceStationId,tp);
+    }
+}
+
+

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/InstalledCapacity.java

+package com.yeejoin.amos.boot.module.jxiop.biz.dto;
+
+import lombok.Data;
+
+@Data
+public class InstalledCapacity {
+    //片区名
+    String areaName;
+    //场站名
+    String stationName;
+    //场站数量
+    String stationCount;
+    //装机容量
+    String actualInstalledCapacity;
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/initdata/StationCacheDataInit.java

 package com.yeejoin.amos.boot.module.jxiop.biz.initdata;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.MapRegion;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.Region;
@@ -12,16 +24,6 @@ import com.yeejoin.amos.boot.module.jxiop.biz.dto.QueryDto;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.StationCacheInfoDto;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.SjglZsjZsbtzMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.CommonServiceImpl;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.stereotype.Component;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.stream.Collectors;
 
 @Component
 public class StationCacheDataInit implements CommandLineRunner {
@@ -42,7 +44,7 @@ public class StationCacheDataInit implements CommandLineRunner {
     public void run(String... args) throws Exception {
         redisTemplate.delete("station_info_cache_bigscreen");
         List<StationCacheInfoDto> stationCacheInfoDtos = new ArrayList<>();
-        List<Region> regionList = regionMapper.selectList(new QueryWrapper<Region>().eq("LEVEL", 1));
+        List<Region> regionList = regionMapper.selectList(new LambdaQueryWrapper<Region>().eq(Region::getLevel_, 1));
         List<MapRegion> mapRegionList = mapRegionMapper.selectList(new QueryWrapper<MapRegion>().isNotNull("name"));
         List<StationBasic> stationBasicList = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("belong_area").isNotNull("fan_gateway_id"));
         stationBasicList.forEach(stationBasic -> {

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/EnergyAccessService.java

+package com.yeejoin.amos.boot.module.jxiop.biz.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import java.util.Map;
+
+public interface EnergyAccessService {
+    Page<Map<String, Object>> getInstalledCapacity(String current, String pageSize, String code, String sourceStationId, String tp);
+
+    Page<Map<String, Object>> getQuotaCompleteInfo(String current, String pageSize, String code, String sourceStationId, String tp);
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java

 package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
 
-import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.MapRegion;
@@ -18,13 +18,10 @@ import com.yeejoin.amos.boot.module.jxiop.biz.initdata.StationCacheDataInit;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.SjglZsjZsbtzMapper;
 
 import lombok.extern.slf4j.Slf4j;
-import org.elasticsearch.action.search.SearchRequestBuilder;
-import org.elasticsearch.action.search.SearchResponse;
 import org.elasticsearch.index.query.BoolQueryBuilder;
 import org.elasticsearch.index.query.MatchPhraseQueryBuilder;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.search.aggregations.Aggregation;
-import org.elasticsearch.search.aggregations.AggregationBuilder;
 import org.elasticsearch.search.aggregations.AggregationBuilders;
 import org.elasticsearch.search.aggregations.Aggregations;
 import org.elasticsearch.search.aggregations.bucket.terms.ParsedStringTerms;
@@ -228,7 +225,7 @@ public class CommonServiceImpl {
 
     public List<StationCacheInfoDto> getListStationCacheInfoDto() {
         List<StationCacheInfoDto> stationCacheInfoDtos = new ArrayList<>();
-        List<Region> regionList = regionMapper.selectList(new QueryWrapper<Region>().eq("LEVEL", 1));
+        List<Region> regionList = regionMapper.selectList(new LambdaQueryWrapper<Region>().eq(Region::getLevel_, 1));
         List<MapRegion> mapRegionList = mapRegionMapper.selectList(new QueryWrapper<MapRegion>().isNotNull("name"));
         List<StationBasic> stationBasicList = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("belong_area").isNotNull("fan_gateway_id"));
         for (int i = 0; i < stationBasicList.size(); i++) {

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/EnergyAccessServiceImpl.java

+package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.jxiop.api.util.Constants;
+import com.yeejoin.amos.boot.module.jxiop.api.util.HttpRequestUtil;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.EnergyAccessService;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class EnergyAccessServiceImpl implements EnergyAccessService {
+
+    @Autowired
+    private HttpRequestUtil httpRequestUtil;
+
+    private final Logger logger = LoggerFactory.getLogger(EnergyAccessServiceImpl.class);
+
+    @Override
+    public Page<Map<String, Object>> getInstalledCapacity(String current, String pageSize, String code, String sourceStationId, String tp) {
+        //改为部盾接口
+        StringBuilder requestUrl = new StringBuilder(Constants.BASE_URL).append("?").append(Constants.get_station_actual_installed_capacity);
+        if (StringUtils.isNotEmpty(code)) {
+            requestUrl.append("&code=").append(code);
+        }
+
+        if (StringUtils.isNotEmpty(sourceStationId)) {
+            requestUrl.append("&source_station_id=").append(sourceStationId);
+        }
+
+        if (StringUtils.isNotEmpty(tp)) {
+            requestUrl.append("&tp=").append(tp);
+        }
+        JSONObject data = httpRequestUtil.getResPonse(requestUrl.toString(), Constants.REQUEST_GET, "",
+                Constants.resovleRule_data);
+
+        List returnList = data.getJSONArray("data");
+        logger.info("获取并网容量接口调用对端返回结果：{}",returnList.toString());
+        Page<Map<String, Object>> pageIPage;
+
+        int newCurrent = Integer.parseInt(current);
+        int newPageSize = Integer.parseInt(pageSize);
+        if (StringUtils.isBlank(pageSize) || StringUtils.isBlank(pageSize)) {
+            pageIPage = new Page<>(0, Long.MAX_VALUE);
+        } else {
+            pageIPage = new Page<>(newCurrent, newPageSize);
+        }
+
+        if (CollectionUtils.isEmpty(returnList)) {
+            return pageIPage;
+        }
+
+        pageIPage.setTotal(returnList.size());
+        int endIndex = newCurrent * newPageSize;
+        if (returnList.size() > endIndex) {
+            pageIPage.setRecords(returnList.subList(((newCurrent - 1) * newPageSize), endIndex));
+        } else {
+            pageIPage.setRecords(returnList.subList(((newCurrent - 1) * newPageSize), returnList.size()));
+        }
+        logger.info("获取并网容量接口最终返回结果：{}",pageIPage.getRecords());
+        return pageIPage;
+    }
+
+    @Override
+    public Page<Map<String, Object>> getQuotaCompleteInfo(String current, String pageSize, String code, String sourceStationId, String tp) {
+        //改为部盾接口
+        StringBuilder requestUrl = new StringBuilder(Constants.BASE_URL).append("?").append(Constants.get_quota_complate_info);
+        LocalDate currentDate = LocalDate.now();
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        String formattedDate = currentDate.format(formatter);
+        requestUrl.append("&reporting_data=").append(formattedDate);
+        if (StringUtils.isNotEmpty(code)) {
+            requestUrl.append("&code=").append(code);
+        }
+
+        if (StringUtils.isNotEmpty(sourceStationId)) {
+            requestUrl.append("&source_station_id=").append(sourceStationId);
+        }
+
+        if (StringUtils.isNotEmpty(tp)) {
+            requestUrl.append("&tp=").append(tp);
+        }
+        JSONObject data = httpRequestUtil.getResPonse(requestUrl.toString(), Constants.REQUEST_GET, "",
+                Constants.resovleRule_data);
+
+        List returnList = data.getJSONArray("data");
+        logger.info("获取片区指标完成情况调用对端返回结果：{}",returnList.toString());
+        //rate的值去掉百分号，名称字段名统一用name代替
+        Page<Map<String, Object>> pageIPage;
+        int newCurrent = Integer.parseInt(current);
+        int newPageSize = Integer.parseInt(pageSize);
+        if (StringUtils.isBlank(pageSize) || StringUtils.isBlank(pageSize)) {
+            pageIPage = new Page<>(0, Long.MAX_VALUE);
+        } else {
+            pageIPage = new Page<>(newCurrent, newPageSize);
+        }
+        if (CollectionUtils.isEmpty(returnList)) {
+            return pageIPage;
+        }
+        returnList.forEach(result -> {
+            String oldName = "";
+            JSONObject jsonObject = (JSONObject) result;
+            String rate = jsonObject.getString("rate");
+            if (StringUtils.isNotEmpty(rate)) {
+                jsonObject.put("rate", rate.replace("%", ""));
+            }
+            if ("1".equals(tp)) {
+                oldName = jsonObject.getString("station_name");
+                jsonObject.remove("station_name");
+            } else {
+                oldName = jsonObject.getString("area_name");
+                jsonObject.remove("area_name");
+            }
+            jsonObject.put("name", oldName);
+
+        });
+        pageIPage.setTotal(returnList.size());
+        int endIndex = newCurrent * newPageSize;
+        if (returnList.size() > endIndex) {
+            pageIPage.setRecords(returnList.subList(((newCurrent - 1) * newPageSize), endIndex));
+        } else {
+            pageIPage.setRecords(returnList.subList(((newCurrent - 1) * newPageSize), returnList.size()));
+        }
+        logger.info("获取片区指标完成情况最终返回结果：{}",pageIPage.getRecords());
+        return pageIPage;
+    }
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/LargeScreenImpl.java

@@ -87,7 +87,7 @@ public class LargeScreenImpl {
 	 * 全国
 	 */
 	@Scheduled(cron = "0/10 * * * * ?")
-	@PostConstruct
+	//@PostConstruct
 	public Map<String, Double> getqg() {
 		Map<String, Double> mapdta = new HashMap<>();
 		mapdta.put("SS", 0d);
@@ -131,25 +131,26 @@ public class LargeScreenImpl {
 //			}
 //		}
 
-		//改为部盾接口
+		// 改为部盾接口
 		String requestUrl = Constants.BASE_URL + "?" + Constants.get_quota_info;
 		LocalDate currentDate = LocalDate.now();
-	    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-	    String formattedDate = currentDate.format(formatter);
-	    JSONObject data = httpRequestUtil.getResPonse(requestUrl+"&reporting_data="+formattedDate, Constants.REQUEST_GET, "",
-				Constants.resovleRule_data);
-	    //部盾每天十二点才填报,如果十二点前没有数据则获取前一天的数据
-	    if(data.getDouble("sum_irradiance")==0) 
-	    {
-	    	 // 计算昨天日期
-	        LocalDate yesterday = currentDate.minusDays(1);
-	        formattedDate = yesterday.format(formatter);
-	    	data = httpRequestUtil.getResPonse(requestUrl+"&reporting_data="+formattedDate, Constants.REQUEST_GET, "",
-					Constants.resovleRule_data);
-	    }
-	    mapdta.put("SS", data.getDouble("average_wind_speed"));
-		mapdta.put("ZFS", data.getDouble("avg_irradiance"));
-		mapdta.put("ZFSLJ", data.getDouble("sum_irradiance"));
+		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+		String formattedDate = currentDate.format(formatter);
+		JSONObject data = httpRequestUtil.getResPonse(requestUrl + "&reporting_data=" + formattedDate,
+				Constants.REQUEST_GET, "", Constants.resovleRule_data);
+		if (data != null) {
+			// 部盾每天十二点才填报,如果十二点前没有数据则获取前一天的数据
+			if (data.getDouble("sum_irradiance") != null && data.getDouble("sum_irradiance") == 0) {
+				// 计算昨天日期
+				LocalDate yesterday = currentDate.minusDays(1);
+				formattedDate = yesterday.format(formatter);
+				data = httpRequestUtil.getResPonse(requestUrl + "&reporting_data=" + formattedDate,
+						Constants.REQUEST_GET, "", Constants.resovleRule_data);
+			}
+			mapdta.put("SS", data.getDouble("average_wind_speed"));
+			mapdta.put("ZFS", data.getDouble("avg_irradiance"));
+			mapdta.put("ZFSLJ", data.getDouble("sum_irradiance"));
+		}
 
 //        //日发电量
 //        AtomicReference<Double> dailyPower = new AtomicReference<>(0.0);
@@ -242,7 +243,7 @@ public class LargeScreenImpl {
 	}
 
 	@Scheduled(cron = "0/10 * * * * ?")
-	@PostConstruct
+	//@PostConstruct
 	private void sendQYYXZBMqtt() {
 		List<StationCacheInfoDto> listStationCacheInfoDto = commonServiceImpl.getListStationCacheInfoDto();
 		Map<String, List<StationCacheInfoDto>> belongAreaList = listStationCacheInfoDto.stream()
@@ -257,16 +258,16 @@ public class LargeScreenImpl {
 	/**
 	 * 区域
 	 **/
-	public Map<String, Double> getqy(List<StationCacheInfoDto> gatewayId, String s) {
-		Map<String, Double> mapdta = new HashMap<>();
-		mapdta.put("SS", 0d);
-		mapdta.put("ZFS", 0d);
-		mapdta.put("ZFSLJ", 0d);
-		mapdta.put("RSD", 0d);
-		mapdta.put("YFD", 0d);
-		mapdta.put("NFD", 0d);
-		mapdta.put("YJHWC", 0d);
-		mapdta.put("NJHWC", 0d);
+	public Map<String, String> getqy(List<StationCacheInfoDto> gatewayId, String s) {
+		Map<String, String> mapdta = new HashMap<>();
+		mapdta.put("SS", "0");
+		mapdta.put("ZFS", "0");
+		mapdta.put("ZFSLJ", "0");
+		mapdta.put("RSD", "0");
+		mapdta.put("YFD", "0");
+		mapdta.put("NFD", "0");
+		mapdta.put("YJHWC", "0");
+		mapdta.put("NJHWC", "0");
 //		// 平均数
 //		List<String> value = new ArrayList<>();
 //		List<String> ids = new ArrayList<>();
@@ -400,35 +401,46 @@ public class LargeScreenImpl {
 //		Double ybfbn = sumValuen > 0 ? mapdta.get("NFD") / sumValuen * 100 : 0;
 //		ybfbn = new BigDecimal(ybfbn).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
 //		mapdta.put("NJHWC", ybfbn);
-		
 
-		//改为部盾接口
+		// 改为部盾接口
 		String requestUrl = Constants.BASE_URL + "?" + Constants.get_quota_info;
 		LocalDate currentDate = LocalDate.now();
-	    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
-	    String formattedDate = currentDate.format(formatter);
-	    JSONObject data = httpRequestUtil.getResPonse(requestUrl+"&reporting_data="+formattedDate, Constants.REQUEST_GET, "",
-				Constants.resovleRule_data);
-		mapdta.put("Day", data.getDouble("day_generating_capacity"));
-		mapdta.put("Moon", data.getDouble("month_generating_capacity"));
-		mapdta.put("Year", data.getDouble("year_generating_capacity"));
-		mapdta.put("YJHWC", Double.valueOf(data.getString("month_quota_rate").replace("%", "")));
-		mapdta.put("NJHWC", Double.valueOf(data.getString("year_quota_rate").replace("%", "")));
-		
-	    //部盾每天十二点才填报,如果十二点前没有数据则获取前一天的数据
-	    if(data.getDouble("sum_irradiance")==0) 
-	    {
-	    	 // 计算昨天日期
-	        LocalDate yesterday = currentDate.minusDays(1);
-	        formattedDate = yesterday.format(formatter);
-	    	data = httpRequestUtil.getResPonse(requestUrl+"&reporting_data="+formattedDate, Constants.REQUEST_GET, "",
-					Constants.resovleRule_data);
-	    }
-	    mapdta.put("SS", data.getDouble("average_wind_speed"));
-		mapdta.put("ZFS", data.getDouble("avg_irradiance"));
-		mapdta.put("ZFSLJ", data.getDouble("sum_irradiance"));
-
-		
+		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+		String formattedDate = currentDate.format(formatter);
+		JSONObject data = httpRequestUtil.getResPonse(requestUrl + "&reporting_data=" + formattedDate + "&code=" + s,
+				Constants.REQUEST_GET, "", Constants.resovleRule_data);
+		DecimalFormat df = new DecimalFormat("#.0000");
+		if (data.getDouble("day_generating_capacity") != null) {
+			mapdta.put("Day", df.format(Double.valueOf(data.getDouble("day_generating_capacity"))));
+			mapdta.put("RSD", df.format(Double.valueOf(data.getDouble("day_generating_capacity"))));
+		}
+		if (data.getDouble("month_generating_capacity") != null) {
+			mapdta.put("Moon", df.format(Double.valueOf(data.getDouble("month_generating_capacity"))));
+			mapdta.put("YFD", df.format(Double.valueOf(data.getDouble("day_generating_capacity"))));
+		}
+		if (data.getDouble("year_generating_capacity") != null) {
+			mapdta.put("Year", df.format(Double.valueOf(data.getDouble("year_generating_capacity"))));
+			mapdta.put("NFD", df.format(Double.valueOf(data.getDouble("day_generating_capacity"))));
+		}
+		if (data.getString("month_quota_rate") != null) {
+			mapdta.put("YJHWC", data.getString("month_quota_rate").replace("%", ""));
+		}
+		if (data.getString("year_quota_rate") != null) {
+			mapdta.put("NJHWC", data.getString("year_quota_rate").replace("%", ""));
+		}
+
+		// 部盾每天十二点才填报,如果十二点前没有数据则获取前一天的数据
+		if (data.getDouble("sum_irradiance") != null && data.getDouble("sum_irradiance") == 0) {
+			// 计算昨天日期
+			LocalDate yesterday = currentDate.minusDays(1);
+			formattedDate = yesterday.format(formatter);
+			data = httpRequestUtil.getResPonse(requestUrl + "&reporting_data=" + formattedDate, Constants.REQUEST_GET,
+					"", Constants.resovleRule_data);
+		}
+		mapdta.put("SS", data.getString("average_wind_speed"));
+		mapdta.put("ZFS", data.getString("avg_irradiance"));
+		mapdta.put("ZFSLJ", data.getString("sum_irradiance"));
+
 		try {
 			System.out.println(JSON.toJSONString(mapdta));
 			emqKeeper.getMqttClient().publish("qyyxzb/" + s, JSON.toJSONString(mapdta).getBytes(), 1, true);

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/MonitoringServiceImpl.java

@@ -28,6 +28,7 @@ import org.springframework.util.ObjectUtils;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
 import java.math.BigDecimal;
+import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
@@ -1112,11 +1113,23 @@ public class MonitoringServiceImpl {
 	    String formattedDate = currentDate.format(formatter);
 	    JSONObject data = httpRequestUtil.getResPonse(requestUrl+"&reporting_data="+formattedDate, Constants.REQUEST_GET, "",
 				Constants.resovleRule_data);
-	    resultMap.put("Day", data.getString("day_generating_capacity"));
-	    resultMap.put("Moon", data.getString("month_generating_capacity"));
-	    resultMap.put("Year", data.getString("year_generating_capacity"));
-	    resultMap.put("YJHWC", data.getString("month_quota_rate").replace("%", ""));
-	    resultMap.put("NJHWC", data.getString("year_quota_rate").replace("%", ""));
+	    DecimalFormat df = new DecimalFormat("#.0000");
+		if (data.getDouble("day_generating_capacity") != null) {
+			  resultMap.put("Day", df.format(Double.valueOf(data.getDouble("day_generating_capacity"))));
+		}
+		if (data.getDouble("month_generating_capacity") != null) {
+			 resultMap.put("Moon", df.format(Double.valueOf(data.getDouble("month_generating_capacity"))));
+		}
+		if (data.getDouble("year_generating_capacity") != null) {
+			   resultMap.put("Year", df.format(Double.valueOf(data.getDouble("year_generating_capacity"))));
+		}
+		if (data.getString("month_quota_rate") != null) {
+		    resultMap.put("YJHWC", data.getString("month_quota_rate").replace("%", ""));
+		}
+		if (data.getString("year_quota_rate") != null) {
+		    resultMap.put("NJHWC", data.getString("year_quota_rate").replace("%", ""));
+		}
+		
 		try {
 			emqKeeper.getMqttClient().publish("bigscreen_zjrl_topic", JSON.toJSON(page).toString().getBytes("UTF-8"), 1,
 					true);

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/resources/application-dev1.properties

@@ -148,4 +148,5 @@ pictureUrl=upload/jxiop/syz/
 # Ԥ
 idx.predict.serviceUrl=http://10.20.1.157:8095/jxdj/predict-data
 
-forecast.url=
\ No newline at end of file
+forecast.url=
+logic=
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/resources/application-kingbase8.properties

+## DB properties:
+## db1-production database
+spring.db1.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db1.datasource.url=jdbc:kingbase8://10.20.1.176:54321/production?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8&currentSchema=root
+spring.db1.datasource.username=root
+spring.db1.datasource.password=Yeejoin@2020
+spring.db1.datasource.driver-class-name: com.kingbase8.Driver
+## db2-sync_data
+spring.db2.datasource.type: com.alibaba.druid.pool.DruidDataSource
+spring.db2.datasource.url=jdbc:kingbase8://10.20.1.176:54321/jxiop_sync_data?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8&currentSchema=root
+spring.db2.datasource.username=root
+spring.db2.datasource.password=Yeejoin@2020
+spring.db2.datasource.driver-class-name: com.kingbase8.Driver
+##db3
+spring.db3.datasource.url=jdbc:TAOS-RS://10.20.1.157:6041/iot_data?user=root&password=taosdata&timezone=GMT%2b8&allowMultiQueries=true
+spring.db3.datasource.username=root
+spring.db3.datasource.password=taosdata
+spring.db3.datasource.driver-class-name: com.taosdata.jdbc.rs.RestfulDriver
+##db4
+spring.db4.datasource.url=jdbc:TAOS-RS://10.20.1.157:6041/iot_data?user=root&password=taosdata&timezone=GMT%2b8&allowMultiQueries=true
+spring.db4.datasource.username=root
+spring.db4.datasource.password=taosdata
+spring.db4.datasource.driver-class-name: com.taosdata.jdbc.rs.RestfulDriver
+
+# kingbase8 backquote not support
+mybatis-plus.global-config.db-config.table-field-strategy=ignore
+
+## eureka properties:
+eureka.instance.hostname=10.20.1.160
+eureka.client.serviceUrl.defaultZone=http://admin:a1234560@${eureka.instance.hostname}:10001/eureka/
+## redis properties:
+spring.redis.database=1
+spring.redis.host=10.20.1.210
+spring.redis.port=6379
+spring.redis.password=yeejoin@2020
+
+
+spring.cache.type=GENERIC
+j2cache.open-spring-cache=true
+j2cache.cache-clean-mode=passive
+j2cache.allow-null-values=true
+j2cache.redis-client=lettuce
+j2cache.l2-cache-open=true
+j2cache.broadcast=net.oschina.j2cache.cache.support.redis.SpringRedisPubSubPolicy
+j2cache.L1.provider_class=caffeine
+j2cache.L2.provider_class=net.oschina.j2cache.cache.support.redis.SpringRedisProvider
+j2cache.L2.config_section=lettuce
+j2cache.sync_ttl_to_redis=true
+j2cache.default_cache_null_object=false
+j2cache.serialization=fst
+caffeine.properties=/caffeine.properties
+lettuce.mode=single
+lettuce.namespace=
+lettuce.storage=generic
+lettuce.channel=j2cache
+lettuce.scheme=redis
+lettuce.hosts=${spring.redis.host}:${spring.redis.port}
+lettuce.password=${spring.redis.password}
+lettuce.database=${spring.redis.database}
+lettuce.sentinelMasterId=
+lettuce.maxTotal=100
+lettuce.maxIdle=10
+lettuce.minIdle=10
+lettuce.timeout=10000
+
+
+emqx.clean-session=true
+emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
+emqx.broker=tcp://10.20.1.210:2883
+emqx.user-name=admin
+emqx.password=public
+mqtt.scene.host=mqtt://10.20.1.210:8083/mqtt
+mqtt.client.product.id=mqtt
+mqtt.topic=topic_mqtt
+spring.mqtt.completionTimeout=3000
+emqx.max-inflight=1000
+emqx.client-user-name=admin
+emqx.client-password=public
+
+## influxDB
+#spring.influx.url= http://172.16.3.155:18186
+#spring.influx.password=Yeejoin@2020
+#spring.influx.user=root
+#spring.influx.database=iot_platform
+#spring.influx.retention_policy=default
+#spring.influx.retention_policy_time=30d
+#spring.influx.actions=10000
+#spring.influx.bufferLimit=20000
+
+## influxDB
+#spring.influx.url= http://139.9.171.247:8086
+#spring.influx.password=Yeejoin@2023
+#spring.influx.user=admin
+#spring.influx.database=iot_platform
+#spring.influx.retention_policy=default
+#spring.influx.retention_policy_time=30d
+#spring.influx.actions=10000
+#spring.influx.bufferLimit=20000
+
+
+#spring.influx.url=http://10.20.1.157:18086
+#spring.influx.password=Yeejoin@2020
+#spring.influx.user=root
+#spring.influx.database=iot_platform
+#spring.influx.retention_policy=default
+#spring.influx.retention_policy_time=30d
+#spring.influx.actions=10000
+#spring.influx.bufferLimit=20000
+
+knife4j.production=false
+knife4j.enable=true
+knife4j.basic.enable=true
+knife4j.basic.username=admin
+knife4j.basic.password=a1234560
+
+management.security.enabled=true
+spring.security.user.name=admin
+spring.security.user.password=a1234560
+
+fire-rescue=123
+
+mybatis-plus.global-config.db-config.update-strategy=ignored
+
+# user-amos setting : This value is the secretkey for person manage moudle accout password encryption.please don't change it!!!
+amos.secret.key=qaz
+# if your service can't be access ,you can use this setting , you need change ip as your.
+#eureka.instance.prefer-ip-address=true
+#eureka.instance.ip-address=172.16.3.122
+
+
+spring.activemq.broker-url=tcp://10.20.1.210:61616
+spring.activemq.user=admin
+spring.activemq.password=admin
+spring.jms.pub-sub-domain=false
+myqueue=amos.privilege.v1.JXIOP.AQSC_FDGL.userBusiness
+spring.elasticsearch.rest.uris=http://10.20.0.223:9200
+
+spring.elasticsearch.rest.connection-timeout=30000
+
+spring.elasticsearch.rest.username=elastic
+
+spring.elasticsearch.rest.password=Yeejoin@2020
+
+spring.elasticsearch.rest.read-timeout=30000
+
+# ?????????
+fan.statuts.stattuspath=upload/jxiop/device_status
+
+pictureUrl=upload/jxiop/syz/
+
+# Ԥ
+idx.predict.serviceUrl=http://10.20.1.157:8095/jxdj/predict-data
+
+forecast.url=
+logic=
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/resources/application.properties

@@ -2,7 +2,7 @@ spring.application.name=AMOS-JXIOP-BIGSCREEN-WJ
 server.servlet.context-path=/jxiop-bigscreen
 server.port=33300
 server.uri-encoding=UTF-8
-spring.profiles.active=dev1
+spring.profiles.active=kingbase8
 spring.jackson.time-zone=GMT+8
 spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
 logging.config=classpath:logback-${spring.profiles.active}.xml

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/resources/logback-kingbase8.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false">
+<!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+<property name="LOG_HOME" value="log" />
+<property name="LOG_PATTERN" value="%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %-50.50logger{50} - %msg [%file:%line] %n" />
+<!-- 按照每天生成日志文件 -->
+<appender name="FILE"  class="ch.qos.logback.core.rolling.RollingFileAppender">
+    <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+        <!--日志文件输出的文件名-->
+        <FileNamePattern>${LOG_HOME}/ccs.log.%d{yyyy-MM-dd}.log</FileNamePattern>
+        <!--日志文件保留天数-->
+        <MaxHistory>7</MaxHistory>
+    </rollingPolicy>
+    <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+        <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
+        <pattern>${LOG_PATTERN}</pattern>
+    </encoder>
+    <!--日志文件最大的大小-->
+    <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
+        <MaxFileSize>30mb</MaxFileSize>
+    </triggeringPolicy>
+</appender>
+<!-- 控制台输出 -->
+<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+    <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+        <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
+        <pattern>${LOG_PATTERN}</pattern>
+    </encoder>
+</appender>
+<!--myibatis log configure-->
+<logger name="com.apache.ibatis" level="DEBUG"/>
+<logger name="java.sql.Connection" level="DEBUG"/>
+<logger name="java.sql.Statement" level="DEBUG"/>
+<logger name="java.sql.PreparedStatement" level="DEBUG"/>
+<logger name="com.baomidou.mybatisplus" level="DEBUG"/>
+<logger name="org.springframework" level="DEBUG"/>
+<logger name="org.typroject" level="DEBUG"/>
+<logger name="com.yeejoin" level="DEBUG"/>
+<!-- 日志输出级别 -->
+<root level="INFO">
+    <appender-ref ref="FILE" />
+    <appender-ref ref="STDOUT" />
+</root>
+
+</configuration>

amos-boot-system-jxiop/amos-boot-module-jxiop-bigscreen-biz/src/main/resources/mapper/cluster/SjglZsjZsbtzMapper.xml

@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.SjglZsjZsbtzMapper">
     <select id="getStationCapactityByStationWerks" resultType="Double">
-        select SUM(CAPACITYL) from sjgl_zsj_zsbtz where WERKS = #{WERKS}
+        select SUM(IFNULL(trim(CAPACITYL),0)) from sjgl_zsj_zsbtz where WERKS = #{WERKS}
     </select>
 
     <select id="getStationInfoMapByStationWerks" resultType="map">

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/amosprojectmapper/PrivilegeCompanyMapper.java

@@ -10,7 +10,7 @@ import java.util.Map;
 
 public interface PrivilegeCompanyMapper extends BaseMapper<PrivilegeCompany> {
 
-    @Select("select SEQUENCE_NBR as sequenceNbr,ORG_CODE as orgCode,COMPANY_NAME as companyName ,LEVEL as level from privilege_company where COMPANY_TYPE = 'region' and IS_DELETED = 0  ")
+    @Select("select SEQUENCE_NBR as sequenceNbr,ORG_CODE as orgCode,COMPANY_NAME as companyName ,LEVEL_ as level_ from privilege_company where COMPANY_TYPE = 'region' and IS_DELETED = 0  ")
    public List<PrivilegeCompany> getAreaCompany();
 
 

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/amosprojectmapper/UserEmpowerMapper.java

@@ -17,7 +17,7 @@ import java.util.Map;
  * @createDate: 2023/11/9
  */
 public interface UserEmpowerMapper extends BaseMapper<StdUserEmpower> {
-    @Select("select company_name as companyName , level from privilege_company where org_code = #{orgCode}")
+    @Select("select company_name as companyName , level_ from privilege_company where org_code = #{orgCode}")
     Map<String,String> getCompanyInfoByOrgCode(String orgCode);
 
     List<CompanyModel> getCompanyBoList(@Param("companyType") String companyType,

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/PrivilegeCompany.java

@@ -7,8 +7,6 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
-import java.util.List;
-
 @Data
 @EqualsAndHashCode(callSuper = true)
 @Accessors(chain = true)
@@ -24,8 +22,8 @@ public class PrivilegeCompany extends BaseEntity {
     private Long parentId;
     @TableField("REGION_SEQ")
     private String regionSeq;
-    @TableField("LEVEL")
-    private String level;
+    @TableField("LEVEL_")
+    private String level_;
     @TableField("EMAIL")
     private String email;
     @TableField("LONGITUDE")

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/IPermissionServiceImpl.java

@@ -191,9 +191,9 @@ public class IPermissionServiceImpl implements IPermissionService {
 
 		//outer_company 外部公司 当前特殊区域公司标记为 级别为 外部公司来区分
 		if (type.equals("outer_company")){
-			areaCompany= areaCompany.stream().filter(e -> e.getLevel().equals("outer_company")).collect(Collectors.toList());
+			areaCompany= areaCompany.stream().filter(e -> e.getLevel_().equals("outer_company")).collect(Collectors.toList());
 		}else {
-			areaCompany= areaCompany.stream().filter(e -> !e.getLevel().equals("outer_company")).collect(Collectors.toList());
+			areaCompany= areaCompany.stream().filter(e -> !e.getLevel_().equals("outer_company")).collect(Collectors.toList());
 //			PrivilegeCompany all = new PrivilegeCompany();
 //			all.setCompanyName("全部");
 //			all.setOrgCode("all");

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/PersonBasicServiceImpl.java

@@ -185,6 +185,7 @@ public class PersonBasicServiceImpl extends BaseService<PersonBasicDto, PersonBa
         // 人员基础信息
         PersonBasic personBasic = new PersonBasic();
         BeanUtils.copyProperties(personUser, personBasic);
+        personBasic.setRecDate(new Date());
         // 默认红码
         personBasic.setQrcodeColor(QrcodeColorEnum.RED.getCode());
         personBasic.setQrcodeDesc("证书不全");
@@ -442,6 +443,7 @@ public class PersonBasicServiceImpl extends BaseService<PersonBasicDto, PersonBa
 
         // 人员基础信息
         PersonBasic personBasic = personBasicMapper.selectById(sequenceNbr);
+        personBasic.setRecDate(new Date());
         personBasic.setSequenceNbr(sequenceNbr);
         personAccount.setPassword(DesUtil.encode(personAccount.getPassword(), secretKey));
         personAccount.setSecondaryPassword(DesUtil.encode(personAccount.getSecondaryPassword(), secretKey));