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

readme.md

@@ -1,15 +1,47 @@
 # 2021.04.06 V1.0
 ## 更新内容(数据库)
-
+##sms 数据库
 ### sms_monitor_info 添加字段type
 1、ALTER TABLE sms_monitor_info ADD TYPE int;
+2、ALTER TABLE sms_monitor_info ADD OP_TYPE int;
 ### sms_alarm_setting 添加字段START_TIME、END_TIME
 1、ALTER TABLE sms_alarm_setting ADD START_TIME varchar(20) null COMMENT '报警设置开始时间',
   				ADD END_TIME varchar(20) null COMMENT '报警设置结束时间';
+  				
+### sms_device_setup 添加数据表  				
+CREATE TABLE `sms_device_setup_method` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `ATTRIBUTE_ID` int(11) DEFAULT NULL COMMENT '属性ID',
+  `TYPE` int(11) DEFAULT NULL COMMENT '类型(0水泵控制 1压力调节 2水表开关阀)',
+  `METHOD` varchar(200) DEFAULT NULL COMMENT '方法名',
+  `PARAMS` varchar(200) DEFAULT NULL COMMENT '参数(json)',
+ 
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='参数设置指令';
 
 
-## uims数据库
+CREATE TABLE `sms_device_setup_record` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `ATTRIBUTE_ID` int(11) DEFAULT NULL COMMENT '属性ID',
+  `SETUP_METHOD_ID` int(11) DEFAULT NULL COMMENT '设置指令ID',
+  `STATE` varchar(200) DEFAULT NULL COMMENT '执行状态(0执行中 1执行成功 2执行失败)',
+  `PARAMS` varchar(200) DEFAULT NULL COMMENT '参数',
+ 
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='参数设置指令记录';			
 
+
+## uims数据库
 ### uims_user 添加字段
 1、ALTER TABLE uims_user ADD login_account varchar(50) comment '登录第三方账号'
 2、ALTER TABLE uims_user ADD login_secret_key varchar(50) comment '登录第三方密钥'
@@ -17,11 +49,9 @@
 4、ALTER TABLE uims_user ADD login_org_code varchar(50) comment '登录第三方机构编码'
 ### sms_month_report表添加索引
 1.ALTER TABLE sms_month_report ADD  INDEX `index_collect_date`(`COLLECT_DATE`) USING BTREE 
-
 # 创建报表维度配置表 sms_report_dimension_setting
 SET NAMES utf8mb4;
 SET FOREIGN_KEY_CHECKS = 0;
-
 -- ----------------------------
 -- Table structure for sms_report_dimension_setting
 -- ----------------------------
@@ -40,4 +70,127 @@ CREATE TABLE `sms_report_dimension_setting`  (
 `show_latest_value` smallint(6) NULL DEFAULT NULL COMMENT '是否展示最新值',
 PRIMARY KEY (`id`) USING BTREE
 ) ENGINE = InnoDB AUTO_INCREMENT = 72 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
-SET FOREIGN_KEY_CHECKS = 1;
+SET FOREIGN_KEY_CHECKS = 1;
+
+## operation_manager 运维管理数据库
+CREATE TABLE `sc_evaluation_grade` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `COMPANY_ORG_ID` int(11) DEFAULT NULL COMMENT '所属公司',
+  `EVALUATION_GRADE` int(11) DEFAULT NULL COMMENT '绩效等级(0A 1B 2C 3D 4E)',
+  `TYPE` int(11) DEFAULT NULL COMMENT '类型(0大于等于 1小于 2介于)',
+  `VALUE_ONE` DECIMAL(18,2) DEFAULT NULL COMMENT '分值1',
+  `VALUE_TWO` DECIMAL(18,2) DEFAULT NULL COMMENT '分值2',
+  `REMARKS` varchar(200) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '备注',
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评等级';
+CREATE TABLE `sc_evaluation_item` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `COMPANY_ORG_ID` int(11) DEFAULT NULL COMMENT '所属公司',
+  `DEPT_ORG_ID` int(11) DEFAULT NULL COMMENT '所属部门',
+  `TYPE` int(11) DEFAULT NULL COMMENT '类型(0任务完成数 1任务按时完成率 2自定义)',
+  `NAME` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '名称',
+  `VALUE` DECIMAL(18,2) DEFAULT NULL COMMENT '分值',
+  `VALUE_CONDITION` DECIMAL(18,2) DEFAULT NULL COMMENT '条件值',
+  `CYCLE` int(11) DEFAULT NULL COMMENT '周期(0月度 1季度 2年度)',
+  `REMARKS` varchar(200) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '评分标准', 
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评项';
+
+CREATE TABLE `sc_evaluation_item_value` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `EVALUATION_ITEM_ID` int(11) NOT NULL COMMENT '考评项ID',
+  `TYPE` int(11) DEFAULT NULL COMMENT '类型(0大于等于 1小于 2介于)',
+  `VALUE_ONE` DECIMAL(18,2) DEFAULT NULL COMMENT '分值1',
+  `VALUE_TWO` DECIMAL(18,2) DEFAULT NULL COMMENT '分值2',
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评项分值';
+
+CREATE TABLE `sc_evaluation_cycle` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `COMPANY_ORG_ID` int(11) DEFAULT NULL COMMENT '所属公司',
+  `TYPE` int(11) DEFAULT NULL COMMENT '类型(0月度 1季度 2年度)',
+  `EVALUATION_DAY` int(11) DEFAULT NULL COMMENT '考评日期',
+  `REMARKS` varchar(200) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '备注',
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评周期';
+
+CREATE TABLE `sc_evaluation_result` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `COMPANY_ORG_ID` int(11) DEFAULT NULL COMMENT '所属公司',
+  `DEPT_ORG_ID` int(11) DEFAULT NULL COMMENT '所属部门',
+  `EVALUATION_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '考评人',
+  `EVALUATION_BE` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '被考评人',
+  `STATE` int(11) DEFAULT NULL COMMENT '考评状态(0未考评 1已考评)',
+  `CYCLE` int(11) DEFAULT NULL COMMENT '周期(0月度 1季度 2年度)',
+  `YEAR` int(11) DEFAULT NULL COMMENT '考评年份',
+  `MONTH` int(11) DEFAULT NULL COMMENT '考评月份',
+  `EVALUATION_GRADE` int(11) DEFAULT NULL COMMENT '绩效等级(0A 1B 2C 3D 4E)',
+  `VALUE` DECIMAL(18,2) DEFAULT NULL COMMENT '考评得分',
+  `DATE_START` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '考评开始时间',
+  `DATE_END` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '考评结束时间',
+  `DATE_EVALUATION` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '考评时间', 
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评结果';
+CREATE TABLE `sc_evaluation_result_task` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `EVALUATION_RESULT_ID` int(11) NOT NULL COMMENT '考评结果ID',
+  `TOTAL_COUNT` int(11) DEFAULT NULL COMMENT '任务总数',
+  `COMPLETE_COUNT` int(11) DEFAULT NULL COMMENT '已完成',
+  `NO_COMPLETE_COUNT` int(11) DEFAULT NULL COMMENT '待完成',
+  `DELAY_COMPLETE_COUNT` int(11) DEFAULT NULL COMMENT '延期完成',
+  `COMPLETION_RATE` decimal(18,2) DEFAULT NULL COMMENT '完成率',
+  `DELAY_RATE` decimal(18,2) DEFAULT NULL COMMENT '延期率',
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评结果任务详情';
+CREATE TABLE `sc_evaluation_result_details` (
+  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `TENANT_ID` varchar(100) DEFAULT NULL COMMENT '租户标识',
+  `EVALUATION_RESULT_ID` int(11) NOT NULL COMMENT '考评结果ID',
+  `EVALUATION_ITEM_ID` int(11) NOT NULL COMMENT '考评项ID',
+  `VALUE` DECIMAL(18,2) DEFAULT NULL COMMENT '考评得分',
+  `STATUS` smallint(6) DEFAULT NULL COMMENT '数据删除标记',
+  `DATE_CREATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `CREATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '创建人',
+  `DATE_UPDATE` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+  `UPDATE_BY` varchar(100) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '更新人',
+  PRIMARY KEY (`ID`)
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1 COMMENT='考评结果任务详情';
+
+
+

user_auth/src/main/java/com/huaxu/service/impl/UserServiceImpl.java

@@ -236,6 +236,7 @@ public class UserServiceImpl implements UserService {
         String key = null;
         try {
             // 验证加密的内容是否正确
+            encryptValue=encryptValue.replaceAll(" ","+");
             key = DESUtil.decrypt(encryptValue,appSecret);
             // 截取里面的时间
             String date = key.substring(key.lastIndexOf("_") + 1, key.length());

user_center/src/main/java/com/huaxu/entity/UserEntity.java

@@ -111,6 +111,9 @@ public class UserEntity implements Serializable {
     /** 备注 */
     @ApiModelProperty(value = "备注")
     private String remark;
+    /** 备注 */
+    @ApiModelProperty(value = "平台用户唯一id")
+    private String uniqId;
 
     /** 用户角色 */
     @ApiModelProperty(value = "用户角色")
@@ -133,4 +136,5 @@ public class UserEntity implements Serializable {
     @ApiModelProperty(value="用户权限类型")
     @TableField(exist = false)
     private Integer permissonType;
+
 }

user_center/src/main/java/com/huaxu/service/UserService.java

@@ -1,6 +1,7 @@
 package com.huaxu.service;
 
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.huaxu.common.ToolUtil;
 import com.huaxu.dao.OrgMapper;
@@ -16,12 +17,18 @@ import com.huaxu.util.ByteArrayUtils;
 import com.huaxu.util.RedisUtil;
 import com.huaxu.util.UserUtil;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import javax.annotation.Resource;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.client.RestTemplate;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -45,6 +52,8 @@ public class UserService extends ServiceImpl<UserMapper,UserEntity> {
 	private OrgMapper orgMapper;
 	@Autowired
 	private RedisUtil redisUtil;
+	@Value("${add_iot_user_url}")
+	private String addIotUserUrl;
 
 	/**
 	 * 自定义分页查询，含关联实体对像
@@ -135,6 +144,7 @@ public class UserService extends ServiceImpl<UserMapper,UserEntity> {
 	 * 保存
 	 */
 	public boolean addUser(UserEntity user) {
+		user.setUniqId(UUID.randomUUID().toString());
 		if (this.save(user)) {
 			Long pkId = user.getId();
 			//添加用户标签
@@ -163,9 +173,30 @@ public class UserService extends ServiceImpl<UserMapper,UserEntity> {
 				userRoleEntity.setUserId(pkId);
 				userRoleService.addUserRole(userRoleEntity);
 			}
+			addIotUser(user);
 			return true;
 		}
 		return false;
+	}
+	private void addIotUser(UserEntity userEntity){
+		try {
+			HttpHeaders headers = new HttpHeaders();
+			JSONObject args=new JSONObject();
+			args.put("username",userEntity.getUsername());
+			args.put("mobilePhone",userEntity.getPhone());
+			args.put("tenantId",userEntity.getTenantId());
+			args.put("uniqId",userEntity.getUniqId());
+			headers.setContentType(MediaType.APPLICATION_JSON);
+			HttpEntity<String> formEntity = new HttpEntity<>(args.toJSONString(), headers);
+
+			RestTemplate restTemplate=new RestTemplate();
+			restTemplate.postForEntity(addIotUserUrl, formEntity,String.class);
+		 }catch (Exception e){
+			log.error("添加物联网用户失败",e);
+		}
+
+
+
 	}
 
 	/**

user_center/src/main/resources/application-dev.properties

@@ -84,13 +84,12 @@ dispath.routing.key=dipathKey
 ribbon.OkToRetryOnAllOperations=false
 ribbon.ReadTimeout=5000:
 ribbon.ConnectTimeout=3000
-
-
-
 # 设置 feign 客户端超时时间（OpenFeign 默认支持 ribbon）
 # 值的是建立连接所用的时间，使用与网络状态正常的情况，两端连接所用的时间
-ribbon.ReadTimeout=5000
+
 # 指的是建立连接后从服务器读取到可用资源所用的时间
 ribbon.ConnectionTimeout=5000
+add_iot_user_url=http://localhost:8090/api/integration/user/savePlatformUser
+
 
 

user_center/src/main/resources/application-sit.properties

@@ -79,7 +79,7 @@ spring.rabbitmq.template.mandatory=true
 receive.exchange.name=messageExchangeTest
 dispath.routing.key=dipathKeyTest1
 dispath.queue=dispathTest1
-
+add_iot_user_url=http://114.135.61.188:58080/api/integration/user/savePlatformUser