户用光伏增加权限查询场站接口

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/config/UserEmpowerInterceptor.java

@@ -50,17 +50,12 @@ public class UserEmpowerInterceptor implements Interceptor {
     @Override
     public Object intercept(Invocation invocation) throws Throwable {
         try {
-
-
         StatementHandler statementHandler = PluginUtils.realTarget(invocation.getTarget());
         MetaObject metaObject = SystemMetaObject.forObject(statementHandler);
         MappedStatement mappedStatement = (MappedStatement) metaObject.getValue("delegate.mappedStatement");
         //获取方法注解
         Method method = getTargetDataAuthMethod(mappedStatement);
-
-
         UserEmpower userEmpower = getTargetDataAuthAnnotation(mappedStatement);
-
         if(userEmpower==null){
           return invocation.proceed();
         }
@@ -71,10 +66,7 @@ public class UserEmpowerInterceptor implements Interceptor {
         //获取 参数之间关系
         String fileBetweenCondition=  userEmpower.relationship();
         //获取参数值，
-        Vector<String> orgCode = UserEmpowerThreadLocal.getDataAuthRule();
-
-
-
+        List<String> orgCode = UserEmpowerThreadLocal.getDataAuthRule();
         BoundSql boundSql = (BoundSql) metaObject.getValue("delegate.boundSql");
         //获取sql
         String sql = boundSql.getSql();
@@ -135,7 +127,7 @@ public class UserEmpowerInterceptor implements Interceptor {
     }
 
 
-    private List<String> selectSql(String[] filed,String[] fileCondition, Vector<String> data){
+    private List<String> selectSql(String[] filed,String[] fileCondition, List<String> data){
         List<String> sql=new ArrayList<>();
         if(filed!=null&&filed.length>0&&fileCondition!=null&&fileCondition.length>0&&data!=null&&data.size()>0){
 

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/config/UserEmpowerThreadLocal.java

@@ -2,6 +2,8 @@ package com.yeejoin.amos.boot.module.hygf.api.config;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+
+import java.util.List;
 import java.util.Vector;
 
 /**
@@ -18,11 +20,11 @@ public class UserEmpowerThreadLocal {
             return requestContext.get();
         }
 
-        public static Vector<String> getDataAuthRule() {
+        public static List<String> getDataAuthRule() {
             return getPermissionInterceptorContext().getThreadLocalData();
         }
 
-        public static void setDataAuthRule(Vector<String> dataAuthRule) {
+        public static void setDataAuthRule(List<String> dataAuthRule) {
             getPermissionInterceptorContext().setDataAuthRule(dataAuthRule);
         }
 

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/config/UserEmpowerThreadLocalModel.java

 package com.yeejoin.amos.boot.module.hygf.api.config;
 
 import java.io.Serializable;
+import java.util.List;
 import java.util.Vector;
 
 /**
@@ -11,13 +12,13 @@ import java.util.Vector;
 public class UserEmpowerThreadLocalModel implements Serializable {
     private static final long serialVersionUID = 1L;
 
-    private Vector<String> threadLocalData;
+    private List<String> threadLocalData;
 
-    public Vector<String> getThreadLocalData() {
+    public List<String> getThreadLocalData() {
         return threadLocalData;
     }
 
-    public void setDataAuthRule(Vector<String> threadLocalData) {
+    public void setDataAuthRule(List<String> threadLocalData) {
         this.threadLocalData = threadLocalData;
     }
 

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/config/UserLimitsAdvice.java

@@ -48,17 +48,11 @@ public class UserLimitsAdvice {
         // 获取该方法上的 OpenApi注解
 //        UserLimits aspectAnnotation = method.getAnnotation(UserLimits.class);
 
-//        String userid=RequestContext.getExeUserId();
-//        LambdaQueryWrapper<StdUserEmpower> qu=new LambdaQueryWrapper();
-//        qu.eq(StdUserEmpower::getAmosUserId,userid);
-//        StdUserEmpower list= userEmpowerMapper.selectOne(qu);
-
-        Vector<String> list=new Vector<>();
-
-        list.add("55555");
-        list.add("66666");
-
-        UserEmpowerThreadLocal.setDataAuthRule(list!=null?(Vector<String>) list:null);
+        String userid=RequestContext.getExeUserId();
+        LambdaQueryWrapper<StdUserEmpower> qu=new LambdaQueryWrapper();
+        qu.eq(StdUserEmpower::getAmosUserId,userid);
+        StdUserEmpower list= userEmpowerMapper.selectOne(qu);
+        UserEmpowerThreadLocal.setDataAuthRule(list!=null?list.getAmosOrgCode():null);
         //正常往后执行
         return joinPoint.proceed();
     }

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

@@ -19,8 +19,10 @@ import java.util.Map;
 public interface JpStationMapper extends BaseMapper<JpStation> {
     List<JpStationDto> queryForDealerReviewPage(@Param("dto") JpStationDto reviewDto);
     JpStationDto queryCount(@Param("dto") JpStationDto reviewDto);
-    @UserEmpower(field ={"aaa","bbb"} ,fieldConditions ={"in","in"} ,relationship="and")
     List<Map<String,Object>>  countState(@Param("dto") JpStationDto reviewDto);
     List<Map<String,Double>> getPowerqx(String dateType);
 
+    @UserEmpower(field ={"regional_companies_code","amos_company_code"} ,fieldConditions ={"in","in"} ,relationship="and")
+    List<JpStation> getJpStation();
+
 }

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

@@ -153,4 +153,13 @@
     </select>
 
 
+    <select id="getJpStation"  resultType="com.yeejoin.amos.boot.module.hygf.api.entity.JpStation">
+        select
+        `sequence_nbr` sequenceNbr,
+        third_station_id thirdStationId
+        from hygf_jp_station
+        where is_delete=0
+    </select>
+
+
 </mapper>

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

@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.module.hygf.api.mapper.JpInverterMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.JpPersonStationMapper;
 import com.yeejoin.amos.boot.module.hygf.api.mapper.JpStationMapper;
 import com.yeejoin.amos.boot.module.standard.api.entity.PublicAgencyUser;
+import org.omg.CORBA.OBJ_ADAPTER;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -349,11 +350,10 @@ public class JpStationController extends BaseController {
     @ApiOperation(httpMethod = "GET",value = "工率曲线",   notes = "电站监控电量收益")
     @GetMapping(value = "/test")
     @UserLimits
-    public ResponseModel< Map<String, List<Object>>> getPowerqx() {
+    public Object getPowerqx() {
 
 
-        jpStationMapper.countState(new JpStationDto());
-        return null;
+        return jpStationMapper.getJpStation();
     }
 
 }