Merge branch 'develop' of http://132.232.206.88:3000/lift-manager/lift-server into feature-bieao

lift-business-service/src/main/java/cn/com/ty/lift/business/maintenance/controller/PropertyMaintenanceController.java

@@ -52,4 +52,9 @@ public class PropertyMaintenanceController {
     public RestResponse<?> project(@RequestBody PropertyVo propertyVo) {
         return propertyService.queryJoinProjectList(propertyVo);
     }
+
+    @PostMapping("repair")
+    public RestResponse<?> repair(@RequestBody PropertyVo propertyVo) {
+        return propertyService.queryRepairList(propertyVo);
+    }
 }

lift-business-service/src/main/java/cn/com/ty/lift/business/maintenance/dao/entity/model/response/RepairResponse.java

@@ -0,0 +1,38 @@
+package cn.com.ty.lift.business.maintenance.dao.entity.model.response;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class RepairResponse {
+    private Long repairId;
+    private String projectName;
+    /**
+     * 是否紧急 0否 1是
+     */
+    private Integer isCritical;
+    /**
+     * 急修原因 0其它 1停电 2故障
+     */
+    private Integer repairReason;
+    /**
+     * 保修来源 1物业 2维保 3物联
+     */
+    private Integer source;
+    /**
+     * 报修时间
+     */
+    private LocalDateTime callerDate;
+    private String registrationCode;
+    /**
+     * 电梯类型 1直梯 2扶梯
+     */
+    private Integer liftType;
+    /**
+     * 电梯类别(1:曳引梯;2:液压梯;3:杂物梯;4:自动扶梯;5:自动人行道)
+     */
+    private Integer category;
+    private String devicePosition;
+    private String workerName;
+}

lift-business-service/src/main/java/cn/com/ty/lift/business/maintenance/dao/mapper/PropertyMaintenanceMapper.java

@@ -1,10 +1,7 @@
 package cn.com.ty.lift.business.maintenance.dao.mapper;
 
 import cn.com.ty.lift.business.maintenance.dao.entity.model.dto.MaintenancePlanMonthTaskNum;
-import cn.com.ty.lift.business.maintenance.dao.entity.model.response.DynamicMessageResponse;
-import cn.com.ty.lift.business.maintenance.dao.entity.model.response.PropertyEvaluateAuthResponse;
-import cn.com.ty.lift.business.maintenance.dao.entity.model.response.PropertyMtResponse;
-import cn.com.ty.lift.business.maintenance.dao.entity.model.response.PropertyProjectListResponse;
+import cn.com.ty.lift.business.maintenance.dao.entity.model.response.*;
 import cn.com.ty.lift.common.constants.SqlConstants;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import org.apache.ibatis.annotations.Select;
@@ -32,5 +29,8 @@ public interface PropertyMaintenanceMapper {
     List<PropertyProjectListResponse> queryJoinProjectList(Long userId);
 
     @Select(SqlConstants.QUERY_EVALUATE_AUTH)
-    List<PropertyEvaluateAuthResponse> queryEvaluateAuth(String table,Long userId);
+    List<PropertyEvaluateAuthResponse> queryEvaluateAuth(String table, Long userId);
+
+    @Select(SqlConstants.QUERY_REPAIR_LIST)
+    List<RepairResponse> queryRepairList(Long userId);
 }

lift-business-service/src/main/java/cn/com/ty/lift/business/maintenance/service/PropertyService.java

@@ -175,4 +175,14 @@ public class PropertyService {
         }
         return RestResponse.success(propertyMaintenanceMapper.queryEvaluateAuth(table, propertyVo.getUserId()));
     }
+
+    /**
+     * 根据用户id查询用户加入的项目的急修列表
+     *
+     * @param propertyVo userId
+     * @return 急修列表
+     */
+    public RestResponse<?> queryRepairList(PropertyVo propertyVo) {
+        return RestResponse.success(propertyMaintenanceMapper.queryRepairList(propertyVo.getUserId()));
+    }
 }

lift-common/src/main/java/cn.com.ty.lift.common/constants/SqlConstants.java

@@ -112,4 +112,25 @@ public interface SqlConstants {
                     "         left join project_user pu on pu.project_id = temp.project_id" +
                     "   where user_role in (21, 22)" +
                     "  and user_id =#{userId}";
+
+    //查询用户加入的项目的急修列表
+    String QUERY_REPAIR_LIST =
+            "select         er.id               repairId," +
+                    "       p.project_name      projectName," +
+                    "       er.is_critical      isCritical," +
+                    "       er.repair_reason    repairReason," +
+                    "       er.source           source," +
+                    "       er.caller_date      callerDate," +
+                    "       l.registration_code registrationCode," +
+                    "       l.lift_type         liftType," +
+                    "       l.category          category," +
+                    "       l.device_position   devicePosition," +
+                    "       ui.name             workerName" +
+                    "   from emergency_repair er" +
+                    "         left join project_user pu on er.project_id = pu.project_id" +
+                    "         left join project p on er.project_id = p.id" +
+                    "         left join lift l on er.lift_id = l.id" +
+                    "         left join project_lift_relevance plr on er.lift_id = plr.lift_id" +
+                    "         left join user_info ui on plr.worker_id = ui.user_id" +
+                    "   where pu.user_id = #{userId}";
 }

lift-enterprise-service/pom.xml

@@ -22,10 +22,10 @@
             <artifactId>lift-common</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
-        <!--<dependency>-->
-            <!--<groupId>cn.com.xwy</groupId>-->
-            <!--<artifactId>xwy-cloud-dependencies</artifactId>-->
-        <!--</dependency>-->
+        <dependency>
+            <groupId>cn.com.xwy</groupId>
+            <artifactId>xwy-cloud-dependencies</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

lift-enterprise-service/src/main/java/cn/com/ty/lift/enterprise/custom/service/impl/PropertyCompanyServiceImpl.java

@@ -58,9 +58,6 @@ public class PropertyCompanyServiceImpl extends ServiceImpl<PropertyCompanyMappe
                 propertyCompany.setMailingAddress("未设置地址");
             }
         });
-        if (records.getRecords().isEmpty()) {
-            return RestResponse.success();
-        }
         return RestResponse.success(records);
     }
 

lift-enterprise-service/src/main/java/cn/com/ty/lift/enterprise/option/controller/MaintenanceOptionController.java

@@ -45,7 +45,7 @@ public class MaintenanceOptionController {
                         .in("mt_company_id", 10086L, req.getMtCompanyId())
                         .in(req.getType() != null, "type", type(req))
                         .eq(req.getLiftCategory() != null, "lift_category", req.getLiftCategory())
-                        .eq(req.getStatus() != null, "status", req.getStatus())
+                        .eq( "status",2)
                         .orderByAsc("id"));
         if (page.getRecords().isEmpty()) {
             return RestResponse.success();
@@ -76,7 +76,7 @@ public class MaintenanceOptionController {
                         .in("mt_company_id", 10086L, req.getMtCompanyId())
                         .in(req.getType() != null, "type", type(req))
                         .eq(req.getLiftCategory() != null, "lift_category", req.getLiftCategory())
-                        .eq(req.getStatus() != null, "status", req.getStatus())
+                        .eq("status", 2)
                         .in(sort != null, "sort", sort));
         if (options.isEmpty()) {
             return RestResponse.success();

lift-enterprise-service/src/main/java/cn/com/ty/lift/enterprise/organization/service/OrganizationService.java

@@ -23,7 +23,7 @@ public class OrganizationService {
      * @param project 项目id
      * @return RestResponse 项目相关人员
      */
-    public RestResponse users(Project project) {
+    public RestResponse<?> users(Project project) {
         List<HashMap<String, Object>> projectUsers = projectService.getBaseMapper().users(project.getId());
         if (projectUsers.isEmpty()) {
             return RestResponse.success();
@@ -63,7 +63,7 @@ public class OrganizationService {
      * @return 省，市，区，项目列表
      * @since 2019/12/17 10:05
      */
-    public RestResponse organizationTree(Long mtCompanyId) {
+    public RestResponse<?> organizationTree(Long mtCompanyId) {
         List<Organization> ps = new ArrayList<>();
         List<Organization> cs = new ArrayList<>();
         List<Organization> ds = new ArrayList<>();
@@ -167,6 +167,17 @@ public class OrganizationService {
         }
 
         for (Organization c : cs) {
+            //防止空指针 ---
+            List<Organization> organizations = c.getOrganizations();
+            if (organizations == null || organizations.get(0) == null) {
+                continue;
+            }
+            List<Project> projectsList = organizations.get(0).getProjects();
+            if (projectsList == null || projectsList.get(0) == null) {
+                continue;
+            }
+            //防止空指针 ---
+
             //获取省名
             String province = c.getOrganizations().get(0).getProjects().get(0).getProvince();
             for (Organization p : ps) {
@@ -181,6 +192,6 @@ public class OrganizationService {
         if (ps.isEmpty()) {
             return RestResponse.success();
         }
-        return RestResponse.success(ps, "成功");
+        return RestResponse.success(ps);
     }
 }

lift-enterprise-service/src/main/resources/application.yml

@@ -5,7 +5,7 @@ spring:
   application:
     name: lift-enterprise-service
   profiles:
-    active: test
+    active: prod
 
 #自动添加createTime、isDelete 等字段
 xwy:

lift-push/pom.xml

@@ -35,10 +35,10 @@
             <groupId>cn.com.xwy</groupId>
             <artifactId>xwy-spring-boot</artifactId>
         </dependency>
-<!--        <dependency>-->
-<!--            <groupId>cn.com.xwy</groupId>-->
-<!--            <artifactId>xwy-cloud-dependencies</artifactId>-->
-<!--        </dependency>-->
+        <dependency>
+            <groupId>cn.com.xwy</groupId>
+            <artifactId>xwy-cloud-dependencies</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

lift-push/src/main/resources/application.yml

@@ -1,13 +1,11 @@
 server:
   port: 20233
-  tomcat:
-    basedir: /Users/huangyuan/application/tomcat/data/tomcat_temp
 
 spring:
   application:
     name: lift-push-service
   profiles:
-    active: test
+    active: prod
   datasource:
     hikari:
       max-lifetime: 1200000 # default: 1800000

lift-system-service/src/main/java/cn/com/ty/lift/system/user/service/impl/MtCompanyUserService.java

@@ -275,10 +275,11 @@ public class MtCompanyUserService extends ServiceImpl<MtCompanyUserMapper, MtCom
     @Override
     public RestResponse appGetCompanyMembers(MtCompanyUserRequest mtCompanyUserRequest) {
         IPage companyUserPage = new Page<>(mtCompanyUserRequest.getPageNum(), mtCompanyUserRequest.getPageSize());
-        //分页获取团队信息
+        //分页获取团队成员信息
         companyUserPage = this.page(companyUserPage, new QueryWrapper<MtCompanyUser>()
                 .eq("mt_company_id", mtCompanyUserRequest.getCompanyId())
                 .eq("delete_flag", ApiConstants.DELETE_NO)
+                .eq("status", ApiConstants.ApplicationConstants.APPLY_PASS)
         );
         List<MtCompanyUser> mtCompanyUserList = companyUserPage.getRecords();
         if (mtCompanyUserList != null && mtCompanyUserList.size() > 0) {

lift-system-service/src/main/java/cn/com/ty/lift/system/user/service/impl/UserApplicationService.java

@@ -380,6 +380,9 @@ public class UserApplicationService extends ServiceImpl<UserApplicationMapper, U
         //获取项目所在的区域主管的信息
         ProjectInfo projectInfo = projectService.getProjectById(userApplyRequest.getProjectId());
         if (projectInfo != null) {
+            //将消息推送到app端
+            PushMessage pushMessage = PushMessage.workApplyPermission(applyName, projectInfo.getProjectName(),
+                    permission.get(userApplyRequest.getPowerType()));
             if (projectInfo.getRegionDirectorId() != null) {
                 PushUserInfo regionDirector = pushUserService.getCompanyUserInfoByUserId(companyId,
                         projectInfo.getRegionDirectorId());
@@ -387,20 +390,17 @@ public class UserApplicationService extends ServiceImpl<UserApplicationMapper, U
                     pushUserInfoList.add(regionDirector);
                 }
             }
-        }
-        if (pushUserInfoList != null && pushUserInfoList.size() > 0) {
-            //将消息推送到app端
-            PushMessage pushMessage = PushMessage.workApplyPermission(applyName, projectInfo.getProjectName(),
-                    permission.get(userApplyRequest.getPowerType()));
-            //消息内容
-            String content = pushMessage.getContent();
-            pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfoList);
-            //将消息推送到pc端
-            List<Long> userIdList = pushUserInfoList.stream().map(PushUserInfo::getUserId)
-                    .collect(Collectors.toList());
-            SendMessageUtil.sendMessageToPC(jmsMessagingTemplate, userIdList, content,
-                    WebSocketConstants.MessageType.TEAM_MSG);
-            return true;
+            if (pushUserInfoList != null && pushUserInfoList.size() > 0) {
+                //消息内容
+                String content = pushMessage.getContent();
+                pushMessage.sendTokenOnPlatform(jmsMessagingTemplate, pushUserInfoList);
+                //将消息推送到pc端
+                List<Long> userIdList = pushUserInfoList.stream().map(PushUserInfo::getUserId)
+                        .collect(Collectors.toList());
+                SendMessageUtil.sendMessageToPC(jmsMessagingTemplate, userIdList, content,
+                        WebSocketConstants.MessageType.TEAM_MSG);
+                return true;
+            }
         }
         return false;
     }

lift-system-service/src/main/java/cn/com/ty/lift/system/user/service/impl/UserService.java

@@ -70,8 +70,6 @@ public class UserService implements IUserService {
         //设置账号(小梯号)
         userAccount.setAccount(userRequest.getAccount());
         userAccount.setCreateDate(LocalDateTime.now());
-        //设置用户注册时间
-        userAccount.setCreateDate(LocalDateTime.now());
         //设置用户类型
         userAccount.setType(ApiConstants.UserConstants.TYPE_USER);
         //判断用户是否为物管端注册用户
@@ -141,8 +139,15 @@ public class UserService implements IUserService {
 
     @Override
     public RestResponse addUser(UserRequest userRequest) {
+        if(StringUtils.isBlank(userRequest.getMobile())) {
+            return RestResponse.fail(ApiConstants.RESULT_ERROR, "用户手机号为空");
+        }
+        UserAccount userAccount = userAccountService.getByMobile(userRequest.getMobile());
+        if(userAccount != null) {
+            return  RestResponse.fail(ApiConstants.RESULT_ERROR, "手机号已经存在");
+        }
         //保存用户信息，成功返回用户账户信息，失败返回空
-        UserAccount userAccount = this.saveUserInfo(userRequest);
+        userAccount = this.saveUserInfo(userRequest);
         if (userAccount == null) {
             return RestResponse.fail(ApiConstants.RESULT_ERROR, "新增用户失败");
         }

lift-system-service/src/main/java/cn/com/ty/lift/system/utils/CommonUtil.java

@@ -1,11 +1,13 @@
 package cn.com.ty.lift.system.utils;
 
 import cn.com.ty.lift.common.utils.PojoUtils;
+import cn.com.ty.lift.common.utils.ProjectUtils;
 import cn.com.ty.lift.system.constants.CommonConstants;
 import cn.com.ty.lift.system.homepage.dao.dto.request.PlatformCalendarRequest;
 import org.apache.commons.lang3.StringUtils;
 
 import javax.servlet.http.HttpServletRequest;
+import java.lang.reflect.Method;
 import java.time.Duration;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
@@ -161,23 +163,22 @@ public class CommonUtil {
     public static Map getKeyToDataModel(List dataList, String dateAttrName) {
         Map dayToDataModel = new HashMap();
         if (dataList != null && dataList.size() > 0) {
-            dayToDataModel = (Map) dataList.stream()
-                    .collect(Collectors.groupingBy(obj -> {
-                        try {
-                            Object value = obj.getClass()
-                                    .getMethod(PojoUtils.attrGetMethodName(dateAttrName)).invoke(obj, null);
-                            if (value != null) {
-                                if (value instanceof LocalDate) {
-                                    return getDateDayValue((LocalDate) value);
-                                }
-                                return value;
-                            }
-                            return 0;
-                        } catch (Exception e) {
-                            e.printStackTrace();
-                            return null;
+            dayToDataModel = (Map) dataList.stream().collect(Collectors.groupingBy(obj -> {
+                try {
+                    Method method = obj.getClass().getMethod(PojoUtils.attrGetMethodName(dateAttrName));
+                    Object value = method.invoke(obj);
+                    if (value != null) {
+                        if (value instanceof LocalDate) {
+                            return getDateDayValue((LocalDate) value);
                         }
-                    }));
+                        return value;
+                    }
+                    return 0;
+                } catch (Exception e) {
+                    e.printStackTrace();
+                    return null;
+                }
+            }));
         }
         return dayToDataModel;
     }

lift-system-service/src/main/java/cn/com/ty/lift/system/utils/PasswordUtils.java

@@ -1,7 +1,8 @@
 package cn.com.ty.lift.system.utils;
 
-import cn.hutool.core.codec.Base64;
+import cn.com.ty.lift.common.utils.Base64Encoder;
 
+import java.nio.charset.StandardCharsets;
 import java.security.MessageDigest;
 import java.util.Random;
 
@@ -19,14 +20,14 @@ public class PasswordUtils {
      * @date 2019/11/27 10:03 AM
      */
     public static String randomCode() {
-        String checkCode = "";
+        StringBuilder checkCode = new StringBuilder();
         char[] character = {'0', '1', '2', '3', '4', '5', '6', '8', '9'};
         Random random = new Random();
         //生成验证码字符串
         for (int i = 0; i < 16; i++) {
-            checkCode += character[random.nextInt(character.length)];
+            checkCode.append(character[random.nextInt(character.length)]);
         }
-        return checkCode;
+        return checkCode.toString();
     }
 
     /**
@@ -36,18 +37,18 @@ public class PasswordUtils {
      * @description 对密码进行加盐并进行hash加密
      */
     public static String generatePassword(String password, String salt) {
-        try{
+        try {
             String newPassword = password + salt;
             //sha1加密
-            MessageDigest md = MessageDigest.getInstance("SHA1");
+            MessageDigest md = MessageDigest.getInstance("SHA-1");
             //把字符串转为字节数组
-            byte[] bytePassword = newPassword.getBytes();
+            byte[] bytePassword = newPassword.getBytes(StandardCharsets.UTF_16LE);
             //使用指定的字节来更新我们的摘要
             md.update(bytePassword);
             //获取密文  （完成摘要计算）
             bytePassword = md.digest();
-            return Base64.encode(bytePassword);
-        } catch (Exception e){
+            return new Base64Encoder().encode(bytePassword);
+        } catch (Exception e) {
             e.printStackTrace();
         }
         return "";