潘钊 / bsth_control · Files

// angular 主程序js，必须先导入，配置一些全局设置

var ScheduleApp = angular.module('ScheduleApp', [
    'ui.router', // ui-route跳转
    'ngAnimate', // ng动画
    'ui.bootstrap', // ui bootstrap封装
    'oc.lazyLoad', // 动态加载模块（html，js，css等）
    'ngSanitize', // 净化html标签，配合ng-bind-html使用
    'ngResource', // resource服务
    'ngHandsontable',
    'ng-sweet-alert'
]);

ScheduleApp.factory('UserPrincipal', [
    '$http',
    function($http) {
        // 登录后获取用户公司信息

        var gsinfos = []; // 原始返回的对象数据
        var gsinfo_strs = []; // 拼装以后的（公司代码_分公司代码）
        var gsinfo_strs_u = []; // 拼装以后的（分公司代码_公司代码）

        $http({
            method: 'GET',
            url: '/user/companyData'
        }).then(function(result) {
            if (angular.isArray(result.data)) {
                gsinfos = result;
                angular.forEach(result.data, function(obj) {
                    var gsbm = obj.companyCode;
                    angular.forEach(obj.children, function(obj2) {
                        var fgsbm = obj2.code;
                        gsinfo_strs.push(gsbm + "_" + fgsbm);
                        gsinfo_strs_u.push(fgsbm + "_" + gsbm);
                    });
                });

            }
            console.log(gsinfos);
            console.log(gsinfo_strs);
        });

        return {
            getGsStrs: function() {
                return gsinfo_strs;
            },
            getGsStrsU: function() {
                return gsinfo_strs_u;
            }
        };
    }
]);

ScheduleApp.factory('DataStore', [
    '$http',
    function($http) {
        // 本地数据存储，如车辆数据，人员数据
        var dataMap = {
            "cl": [],
            "ry": []
        };

        $http({
            method: 'GET',
            url: '/cars_sc/all'
        }).then(function(result) {
            // 简拼数据
            dataMap.cl = result.data.data;
            angular.forEach(result.data.data, function(obj) {
                // 全拼
                obj["$fullChars"] = pinyin.getFullChars(obj.insideCode ? obj.insideCode: "");
                // 简拼
                obj["$camelChars"] = pinyin.getCamelChars(obj.insideCode ? obj.insideCode: "");
                // 原值
                obj["$calcu_str"] = obj.insideCode? obj.insideCode: "";
            });
        });

        $http({
            method: 'GET',
            url: '/ee/all'
        }).then(function(result) {
            // 简拼数据
            dataMap.ry = result.data.data;
            angular.forEach(result.data.data, function(obj) {
                // 全拼
                obj["$fullChars"] = pinyin.getFullChars(obj.personnelName + "-" + obj.jobCode);
                // 简拼
                obj["$camelChars"] = pinyin.getCamelChars(obj.personnelName + "-" + obj.jobCode);
                // 原值
                obj["$calcu_str"] = obj.personnelName + "-" + obj.jobCode;
            });
        });

        return {
            getData: function(type) {
                if (dataMap[type]) {
                    return dataMap[type];
                } else {
                    return [];
                }
            }
        }

    }
]);

/**
 * 用于请求通知。
 */
ScheduleApp.factory('requestNotificationChannel', ['$rootScope', function($rootScope) {
    // 通知消息常量
    var _START_REQUEST_ = '_START_REQUEST_'; // 开始请求通知message
    var _END_REQUEST_ = '_END_REQUEST_'; // 请求结束通知message

    // 计数器
    var activeCalls = 0;

    // 发布开始请求通知
    var requestStarted = function(requestInfo) {
        activeCalls += 1;
        console.log("activeCalls=" + activeCalls);
        $rootScope.$broadcast(_START_REQUEST_, requestInfo);
    };
    // 发布请求结束通知
    var requestEnded = function() {
        activeCalls -= 1;
        console.log("activeCalls=" + activeCalls);
        $rootScope.$broadcast(_END_REQUEST_);
    };

    /**
     * 订阅开始请求通知。
     * @param $scope 作用域
     * @param handler 通知处理器函数
     */
    var onRequestStarted = function($scope, handler) {
        $scope.$on(_START_REQUEST_, function(event, requestInfo) {
            handler(requestInfo);
        });
    };
    /**
     * 订阅请求结束通知。
     * @param $scope 作用域
     * @param handler 通知处理器函数
     */
    var onRequestEnded = function($scope, handler) {
        $scope.$on(_END_REQUEST_, function(event) {
            handler();
        });
    };

    return {
        requestStarted : requestStarted,
        requestEnded : requestEnded,
        onRequestStarted : onRequestStarted,
        onRequestEnded : onRequestEnded
    };

}]);

// http 拦截器
ScheduleApp.factory(
    'myInterceptor',
    [
        'requestNotificationChannel',
        '$q',
        function(requestNotificationChannel, $q) {
            return {
                request: function(config) {
                    requestNotificationChannel.requestStarted(config);
                    return config;
                },
                requestError: function(rejection) {
                    requestNotificationChannel.requestEnded();
                    return rejection;
                },
                response: function(response) {
                    requestNotificationChannel.requestEnded();

                    var data = response.data;
                    var output = [];
                    if (data.status == '407') {
                        alert("请重新登录！");
                        return $q.reject(response);
                    } else if (data.status == '500') {
                        output.push("状态编码：" + data.status);
                        output.push("访问路径：" + data.path);
                        output.push("错误消息：" + data.message);
                        alert("服务端错误：" + "\n" + output.join("\n"));
                        return $q.reject(response);
                    } else {
                        return response;
                    }

                },
                responseError: function(rejection) {
                    requestNotificationChannel.requestEnded();

                    // 处理错误，springboot会包装返回的错误数据
                    // 如：{"timestamp":1478674739246,"status":500,"error":"Internal Server Error","exception":"java.lang.ClassCastException","message":"java.lang.String cannot be cast to java.lang.Long","path":"/tidc/importfile"}

                    var output = [];
                    if (!rejection.status) {
                        alert("我擦，后台返回连个状态码都没返回，见鬼了，服务器可能重启了");
                    } else if (rejection.status == -1) {
                        // 服务器断开了
                        alert("貌似服务端连接不上");
                    } else {
                        output.push("状态编码：" + rejection.status);
                        output.push("错误内容：" + angular.toJson(rejection.data));
                        if (rejection.status == 500) {
                            alert("服务端错误：" + "\n" + output.join("\n"));
                        } else if (rejection.status == 407) {
                            alert("请重新登录：" + "\n" + output.join("\n"));
                        } else {
                            alert("其他错误：" + "\n" + output.join("\n"));
                        }
                    }

                    return $q.reject(rejection);
                }
            };
        }
    ]
);

ScheduleApp.config(['$httpProvider', function($httpProvider) {
    $httpProvider.defaults.headers.common["X-Requested-With"] = "XMLHttpRequest";
    $httpProvider.interceptors.push('myInterceptor');
}]);

/** ocLazyLoader 配置 */
ScheduleApp.config(['$ocLazyLoadProvider', function($ocLazyLoadProvider) {
    $ocLazyLoadProvider.config({
        // TODO：全局配置在这里
    });
}]);

/** 配置全局配置信息 */
ScheduleApp.factory('settings', ['$rootScope', function($rootScope) {
    // 封装 settings服务，并设置给 $rootScope同名对象
    var settings = {
        // TODO：
    };

    $rootScope.settings = settings;

    return settings;
}]);

/** Schedule App 主应用控制器 */
ScheduleApp.controller('ScheduleAppController', [
    '$scope',
    'UserPrincipal',
    'DataStore',
    function($scope, UserPrincipal, DataStore) {
        $scope.$on('$viewContentLoaded', function(event) {
            console.log("子页面已载入：" + event);
        });

        // 获取一次用户身份信息
        UserPrincipal.getGsStrs();
        // 获取本地数据
        DataStore.getData("cl");
        DataStore.getData("ry");
    }
]);