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

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/resources/mapper/mysql/PeasantHouseholdMapper.xml

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

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

@@ -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/PreparationMoneyController.java

@@ -71,8 +71,8 @@ public class PreparationMoneyController extends BaseController {
 	@GlobalTransactional
 	public ResponseModel<PreparationMoney> save( @RequestParam("isSubmit") String isSubmit, @RequestBody PreparationMoney model) {
         AgencyUserModel agencyUserModel= getUserInfo();
-	 //   model = preparationMoneyServiceImpl.saveOrUpdateObjectNew(model,agencyUserModel, isSubmit);
-	    model = preparationMoneyServiceImpl.saveOrUpdateObject(model,agencyUserModel);
+	   model = preparationMoneyServiceImpl.saveOrUpdateObjectNew(model,agencyUserModel, isSubmit);
+		//   model = preparationMoneyServiceImpl.saveOrUpdateObject(model,agencyUserModel);
 	    return ResponseHelper.buildResponse(model);
 	}
 
@@ -266,9 +266,10 @@ public class PreparationMoneyController extends BaseController {
 	@PostMapping(value = "/excuteFlow")
 	@ApiOperation(httpMethod = "POST",value = "收货审核",  notes = "收货审核")
 	@GlobalTransactional
-	public ResponseModel excuteFlow(@RequestParam(value = "instanceId") String instanceId, @RequestBody Map<String, Object> kv) {
+	public ResponseModel excuteFlow(@RequestParam(value = "instanceId" ,required = false) String instanceId,
+									@RequestParam(value = "sequenceNbr") Long sequenceNbr,@RequestBody Map<String, Object> kv) {
 
-		preparationMoneyServiceImpl.excuteFlow(instanceId,kv);
+		preparationMoneyServiceImpl.excuteFlow(instanceId,kv,sequenceNbr);
 		return CommonResponseNewUtil.failure();
 	}
 
@@ -276,11 +277,10 @@ public class PreparationMoneyController extends BaseController {
 	@PostMapping(value = "/replenishmentSubmit")
 	@ApiOperation(httpMethod = "POST",value = "补货申请",  notes = "补货申请")
 	@GlobalTransactional
-	public ResponseModel replenishmentSubmit(@RequestParam(value = "sequenceNbr") Long sequenceNbr, @RequestBody HygfReplenishment hygfReplenishment) {
+	public ResponseModel replenishmentSubmit( @RequestBody HygfReplenishment hygfReplenishment) {
 
-		hygfReplenishment.setPreparationMoneyId(sequenceNbr);
 		hygfReplenishmentService.save(hygfReplenishment);
-		preparationMoneyServiceImpl.replenishmentSubmit(sequenceNbr);
+		preparationMoneyServiceImpl.replenishmentSubmit(hygfReplenishment.getPreparationMoneyId());
 		return CommonResponseNewUtil.failure();
 	}
 
@@ -303,4 +303,20 @@ public class PreparationMoneyController extends BaseController {
 		preparationMoneyServiceImpl.replenishmentAudit(sequenceNbr,kv);
 		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/service/impl/PreparationMoneyServiceImpl.java

@@ -37,6 +37,7 @@ import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.typroject.tyboot.core.foundation.context.RequestContext;
 import org.typroject.tyboot.core.foundation.utils.Bean;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
@@ -72,6 +73,8 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
     private PreparationMoneyLogServiceImpl preparationMoneyLogService;
 
     @Autowired
+    private HygfReplenishmentMapper hygfReplenishmentMapper;
+    @Autowired
     RegionalCompaniesMapper regionalCompaniesMapper;
     @Autowired
     DocumentStationMapper documentStationMapper;
@@ -209,6 +212,12 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
         qu.eq(PreparationMoney::getSequenceNbr, sequenceNbr);
         PreparationMoney preparationMoney = preparationMoneyMapper.selectOne(qu);
 
+        LambdaUpdateWrapper<HygfReplenishment> h = new LambdaUpdateWrapper<>();
+        h.eq(HygfReplenishment::getPreparationMoneyId,sequenceNbr);
+        List<HygfReplenishment> hygfReplenishments = hygfReplenishmentMapper.selectList(h);
+        if (CollectionUtil.isNotEmpty(hygfReplenishments) && hygfReplenishments.size()>0 ){
+            map.put("files",hygfReplenishments);
+        }
 
         LambdaUpdateWrapper<DocumentStation> q = new LambdaUpdateWrapper<>();
         q.eq(DocumentStation::getPreparationMoneyId, sequenceNbr);
@@ -849,10 +858,9 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
         }
     }
 
-    public void excuteFlow( String instanceId, Map<String, Object> kv) {
-
-        PreparationMoney model = (PreparationMoney) Bean.mapToBean(kv, PreparationMoney.class);
+    public void excuteFlow( String instanceId, Map<String, Object> kv,Long sequenceNbr) {
 
+        PreparationMoney model = preparationMoneyMapper.selectById(sequenceNbr);
 
         model.setDeliveryState(ArrivalStateeEnum.已收货.getCode());
         //更新电站施工状态
@@ -1013,5 +1021,18 @@ public class PreparationMoneyServiceImpl extends BaseService<PreparationMoneyDto
 
     }
 
+    public IPage<Map<String,Object>> preparationStation(Integer current, Integer size, String preparationMoneyState,String ownersName,String regionalcompaniesSeq,String developerId,String state){
+
+
+         PageHelper.startPage(current,  size);
+         List<Map<String, Object>> resultPage = preparationMoneyMapper.preparationStation(preparationMoneyState,ownersName,regionalcompaniesSeq,developerId,state);
+         PageInfo<Map<String, Object>> page = new PageInfo(resultPage);
+         Page<Map<String, Object>> pagenew = new Page<>();
+         pagenew.setTotal(page.getTotal());
+         pagenew.setSize(size);
+         pagenew.setRecords(page.getList());
+         pagenew.setCurrent(current);
+         return pagenew;
+     }
 
 }
\ No newline at end of file

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

@@ -36,7 +36,7 @@ public class Region  {
     /**
      * 等级
      */
-	@TableField("LEVEL")
+	@TableField("\"LEVEL\"")
     private String level;
 
     /**

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.module.jxiop.biz.service.impl.EnergyAccessServiceImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+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;
+
+    @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) {
+        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) {
+        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

@@ -42,7 +42,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 QueryWrapper<Region>().eq("\"LEVEL\"", 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;
@@ -228,7 +229,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.JSONArray;
+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.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.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class EnergyAccessServiceImpl implements EnergyAccessService {
+
+    @Autowired
+    private HttpRequestUtil httpRequestUtil;
+
+    @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");
+        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()));
+        }
+        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");
+        //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()));
+        }
+        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);
@@ -138,18 +138,22 @@ public class LargeScreenImpl {
 	    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) 
+	    if(data!=null) 
 	    {
-	    	 // 计算昨天日期
-	        LocalDate yesterday = currentDate.minusDays(1);
-	        formattedDate = yesterday.format(formatter);
-	    	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"));
 	    }
-	    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);

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">