南昌市物联网技防平台-后台
tangzy
2021-03-22 4bd007805ce8242320c9cf4e477ce87fe1896bb6
1.用户管理
4 files modified
129 ■■■■ changed files
blade-service-api/blade-system-api/src/main/java/org/springblade/system/entity/Tenant.java 8 ●●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyServer/ServerHandler.java 47 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/controller/TenantController.java 51 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/mapper/TenantMapper.xml 23 ●●●●● patch | view | raw | blame | history
blade-service-api/blade-system-api/src/main/java/org/springblade/system/entity/Tenant.java
@@ -101,6 +101,14 @@
     */
    @ApiModelProperty(value = "授权码")
    private String licenseKey;
    private String type;
    private String jd;
    private String wd;
    private String types;
    private String information;
    private String province;
    private String city;
    private String district;
}
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyServer/ServerHandler.java
@@ -457,28 +457,28 @@
                            } else if (fqbm.equals("3")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("扩展模块故障");
                                reason="扩展模块故障";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="扩展模块故障";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("4")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("中继器故障");
                                reason="中继器故障";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="中继器故障";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("5")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("打印机缺纸");
                                reason="打印机缺纸";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="打印机缺纸";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("6")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("打印机故障");
                                reason="打印机故障";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="打印机故障";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("7")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("扩展模块无直流");
                                reason="扩展模块无直流";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="扩展模块无直流";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("8")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("扩展模块低电压");
@@ -487,16 +487,16 @@
                            } else if (fqbm.equals("9")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("扩展模块复位");
                                reason="扩展模块复位";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="扩展模块复位";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            }
                            break;
                        case "34":
                            if (fqbm.equals("1")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("扩展模块防拆触发");
                                reason="扩展模块防拆触发";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="扩展模块防拆触发";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            }
                            break;
                        case "35":
@@ -513,8 +513,8 @@
                            } else if (fqbm.equals("2")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("电话接口2故障");
                                reason="电话接口2故障";
                                serverHandler.equipmentService.updateExstate(state,reason,devId);
//                                reason="电话接口2故障";
//                                serverHandler.equipmentService.updateExstate(state,reason,devId);
                            } else if (fqbm.equals("3")) {
                                alarm.setWaringType("通讯故障");
                                alarm.setContent("远距离无线通讯");
@@ -1354,10 +1354,14 @@
                            if (fqbm.equals("0")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("电话线故障-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("1")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("交流电故障-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("2")) {
                                alarm.setWaringType("系统故障");
@@ -1366,6 +1370,7 @@
                            else if (fqbm.equals("3")) {
                                alarm.setWaringType("系统故障");
                                alarm.setContent("警号/继电器故障-通讯故障(转发)");
                            }
                            else if (fqbm.equals("4")) {
                                alarm.setWaringType("系统故障");
@@ -1382,6 +1387,8 @@
                            else if (fqbm.equals("7")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("交流电故障恢复-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("8")) {
                                alarm.setWaringType("系统故障-恢复");
@@ -1394,14 +1401,20 @@
                            else if (fqbm.equals("A")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("电话线故障-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("B")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("回路短路故障恢复-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("C")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("无线监控恢复-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            else if (fqbm.equals("E")) {
                                alarm.setWaringType("系统故障");
@@ -1410,6 +1423,8 @@
                            else if (fqbm.equals("F")) {
                                alarm.setWaringType("系统故障-恢复");
                                alarm.setContent("无线监控故障恢复-通讯故障(转发)");
                                reason="";
                                serverHandler.equipmentService.updateExstate("",reason,devId);
                            }
                            break;
                        case "9B":
blade-service/blade-system/src/main/java/org/springblade/system/controller/TenantController.java
@@ -40,6 +40,8 @@
import springfox.documentation.annotations.ApiIgnore;
import javax.validation.Valid;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
@@ -86,9 +88,29 @@
    @ApiOperationSupport(order = 2)
    @ApiOperation(value = "分页", notes = "传入tenant")
    //@PreAuth(RoleConstant.HAS_ROLE_ADMIN)
    public R<IPage<Tenant>> list(@ApiIgnore @RequestParam Map<String, Object> tenant, Query query, BladeUser bladeUser) {
    public R<IPage<Tenant>> list(@ApiIgnore @RequestParam Map<String, Object> tenant, Query query, BladeUser bladeUser) throws ParseException {
        QueryWrapper<Tenant> queryWrapper = Condition.getQueryWrapper(tenant, Tenant.class);
        IPage<Tenant> pages = tenantService.page(Condition.getPage(query), (!bladeUser.getTenantId().equals(BladeConstant.ADMIN_TENANT_ID)) ? queryWrapper.lambda().eq(Tenant::getTenantId, bladeUser.getTenantId()) : queryWrapper);
        for (int j = 0; j < pages.getRecords().size(); j++) {
            Date expireTime = pages.getRecords().get(j).getExpireTime();
            //1.获取当前时间
            Date dd = new Date();
            SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String end = sim.format(dd);
            //把string类型转换为long类型的
            if (expireTime != null){
                long st = sim.parse(String.valueOf(expireTime)).getTime();
                long en = sim.parse(end).getTime();
                //计算天数
                int day = (int) ((st - en) / 86400000);
                if (day <= 30) {
                    pages.getRecords().get(j).setType("1");
                } else {
                    pages.getRecords().get(j).setType("0");
                }
            }
        }
        return R.data(pages);
    }
@@ -112,8 +134,33 @@
    @ApiOperationSupport(order = 4)
    @ApiOperation(value = "分页", notes = "传入tenant")
    //@PreAuth(RoleConstant.HAS_ROLE_ADMIN)
    public R<IPage<Tenant>> page(Tenant tenant, Query query) {
    public R<IPage<Tenant>> page(Tenant tenant, Query query) throws ParseException {
        IPage<Tenant> pages = tenantService.selectTenantPage(Condition.getPage(query), tenant);
        for (int j = 0; j < pages.getRecords().size(); j++) {
            Date expireTimes = pages.getRecords().get(j).getExpireTime();
            if (expireTimes == null){
                pages.getRecords().get(j).setType("0");
                continue;
            }
            //1.获取当前时间
            Date dd = new Date();
            SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String end = sim.format(dd);
            String expireTime = sim.format(expireTimes);
            //把string类型转换为long类型的
            if (expireTime != null){
                long st = sim.parse(expireTime).getTime();
                long en = sim.parse(end).getTime();
                //计算天数
                int day = (int) ((st - en) / 86400000);
                if (day <= 30) {
                    pages.getRecords().get(j).setType("1");
                } else {
                    pages.getRecords().get(j).setType("0");
                }
            }
        }
        return R.data(pages);
    }
blade-service/blade-system/src/main/java/org/springblade/system/mapper/TenantMapper.xml
@@ -21,11 +21,34 @@
        <result column="account_number" property="accountNumber"/>
        <result column="expire_time" property="expireTime"/>
        <result column="license_key" property="licenseKey"/>
        <result column="type" property="type"/>
        <result column="jd" property="jd"/>
        <result column="wd" property="wd"/>
        <result column="information" property="information"/>
        <result column="types" property="types"/>
        <result column="province" property="province"/>
        <result column="city" property="city"/>
        <result column="district" property="district"/>
    </resultMap>
    <select id="selectTenantPage" resultMap="tenantResultMap">
        select * from blade_tenant where is_deleted = 0
        <if test="tenant.tenantName!=null">
            and tenant_name like concat('%',#{tenant.tenantName},'%')
        </if>
        <if test="tenant.linkman!=null">
            and linkman like concat('%',#{tenant.linkman},'%')
        </if>
        <if test="tenant.district!=null">
            and district like concat('%',#{tenant.district},'%')
        </if>
        <if test="tenant.province!=null">
            and province like concat('%',#{tenant.province},'%')
        </if>
        <if test="tenant.city!=null">
            and city like concat('%',#{tenant.city},'%')
        </if>
    </select>
</mapper>