update

周伟鹏
1 parent ba18504a
Showing 12 changed files with 1055 additions and 10 deletions
pom.xml
src/main/java/com/cnlive/shenhe/intercept/LoginIntercept.java → src/main/java/com/cnlive/shenhe/config/LoginIntercept.java
src/main/java/com/cnlive/shenhe/intercept/LoginConfiguration.java → src/main/java/com/cnlive/shenhe/config/WebConfiguration.java
src/main/java/com/cnlive/shenhe/controller/UsersController.java
src/main/java/com/cnlive/shenhe/entity/ShyVideos.java
src/main/java/com/cnlive/shenhe/job/UsersJob.java
src/main/java/com/cnlive/shenhe/mapper/ShyVideosMapper.java
src/main/java/com/cnlive/shenhe/serviceImpl/UsersServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/CommonUtils.java
src/main/resources/application.properties
src/main/resources/generatorConfig.xml
src/main/resources/mapper/ShyVideosMapper.xml
@@ -74,6 +74,22 @@
             <artifactId>tomcat-embed-jasper</artifactId>
             <scope>provided</scope>
         </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.33</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+            <version>1.11</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.25</version>
+        </dependency>
     </dependencies>
     <build>
-package com.cnlive.shenhe.intercept;
+package com.cnlive.shenhe.config;
-import org.springframework.stereotype.Component;
 import org.springframework.web.servlet.HandlerInterceptor;
 import javax.servlet.http.HttpServletRequest;
-package com.cnlive.shenhe.intercept;
+package com.cnlive.shenhe.config;
+import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@@ -11,7 +13,9 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
  * @Description:
  */
 @Configuration
-public class LoginConfiguration implements WebMvcConfigurer {
+@ComponentScan("com.cnlive.shenhe.job")
+@EnableScheduling
+public class WebConfiguration implements WebMvcConfigurer {
     @Override
     public void addInterceptors(InterceptorRegistry registry) {
         registry.addInterceptor(new LoginIntercept()).addPathPatterns("/**");
@@ -23,7 +23,7 @@ public class UsersController {
     @GetMapping(value = "/{id}")
     @ResponseBody
     public Object getTest(@PathVariable Integer id){
-        return  usersService.getAll(id);
+        return  usersService.get(id);
     }
     @GetMapping(value = "/index")
+package com.cnlive.shenhe.entity;
+
+import java.util.Date;
+import javax.persistence.*;
+
+@Table(name = "shy_videos")
+public class ShyVideos {
+    @Id
+    private Integer id;
+
+    private String video_title;
+
+    private Integer spid;
+
+    /**
+     * 点播url
+     */
+    private String video_url;
+
+    /**
+     * 点播封面图图片
+     */
+    private String video_imgs;
+
+    /**
+     * 标签
+     */
+    private String video_tags;
+
+    /**
+     * 更新者
+     */
+    private String updater;
+
+    /**
+     * 审核员id
+     */
+    private Integer auditor;
+
+    /**
+     * 回调地址
+     */
+    private String callback;
+
+    /**
+     * 优先级
+     */
+    private String video_priority;
+
+    /**
+     * 拒绝理由
+     */
+    private String msg;
+
+    /**
+     * 状态:0.未审核,1:已审核,2.拒绝
+     */
+    private Boolean state;
+
+    /**
+     * 上传时间
+     */
+    private Date video_upload_time;
+
+    /**
+     * 关键字
+     */
+    private String video_keyword;
+
+    /**
+     * 介绍
+     */
+    private String video_desc;
+
+    /**
+     * 点播id
+     */
+    private String video_id;
+
+    private Date created_at;
+
+    private Date updated_at;
+
+    /**
+     * @return id
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     * @param id
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    /**
+     * @return video_title
+     */
+    public String getVideo_title() {
+        return video_title;
+    }
+
+    /**
+     * @param video_title
+     */
+    public void setVideo_title(String video_title) {
+        this.video_title = video_title;
+    }
+
+    /**
+     * @return spid
+     */
+    public Integer getSpid() {
+        return spid;
+    }
+
+    /**
+     * @param spid
+     */
+    public void setSpid(Integer spid) {
+        this.spid = spid;
+    }
+
+    /**
+     * 获取点播url
+     *
+     * @return video_url - 点播url
+     */
+    public String getVideo_url() {
+        return video_url;
+    }
+
+    /**
+     * 设置点播url
+     *
+     * @param video_url 点播url
+     */
+    public void setVideo_url(String video_url) {
+        this.video_url = video_url;
+    }
+
+    /**
+     * 获取点播封面图图片
+     *
+     * @return video_imgs - 点播封面图图片
+     */
+    public String getVideo_imgs() {
+        return video_imgs;
+    }
+
+    /**
+     * 设置点播封面图图片
+     *
+     * @param video_imgs 点播封面图图片
+     */
+    public void setVideo_imgs(String video_imgs) {
+        this.video_imgs = video_imgs;
+    }
+
+    /**
+     * 获取标签
+     *
+     * @return video_tags - 标签
+     */
+    public String getVideo_tags() {
+        return video_tags;
+    }
+
+    /**
+     * 设置标签
+     *
+     * @param video_tags 标签
+     */
+    public void setVideo_tags(String video_tags) {
+        this.video_tags = video_tags;
+    }
+
+    /**
+     * 获取更新者
+     *
+     * @return updater - 更新者
+     */
+    public String getUpdater() {
+        return updater;
+    }
+
+    /**
+     * 设置更新者
+     *
+     * @param updater 更新者
+     */
+    public void setUpdater(String updater) {
+        this.updater = updater;
+    }
+
+    /**
+     * 获取审核员id
+     *
+     * @return auditor - 审核员id
+     */
+    public Integer getAuditor() {
+        return auditor;
+    }
+
+    /**
+     * 设置审核员id
+     *
+     * @param auditor 审核员id
+     */
+    public void setAuditor(Integer auditor) {
+        this.auditor = auditor;
+    }
+
+    /**
+     * 获取回调地址
+     *
+     * @return callback - 回调地址
+     */
+    public String getCallback() {
+        return callback;
+    }
+
+    /**
+     * 设置回调地址
+     *
+     * @param callback 回调地址
+     */
+    public void setCallback(String callback) {
+        this.callback = callback;
+    }
+
+    /**
+     * 获取优先级
+     *
+     * @return video_priority - 优先级
+     */
+    public String getVideo_priority() {
+        return video_priority;
+    }
+
+    /**
+     * 设置优先级
+     *
+     * @param video_priority 优先级
+     */
+    public void setVideo_priority(String video_priority) {
+        this.video_priority = video_priority;
+    }
+
+    /**
+     * 获取拒绝理由
+     *
+     * @return msg - 拒绝理由
+     */
+    public String getMsg() {
+        return msg;
+    }
+
+    /**
+     * 设置拒绝理由
+     *
+     * @param msg 拒绝理由
+     */
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    /**
+     * 获取状态:0.未审核,1:已审核,2.拒绝
+     *
+     * @return state - 状态:0.未审核,1:已审核,2.拒绝
+     */
+    public Boolean getState() {
+        return state;
+    }
+
+    /**
+     * 设置状态:0.未审核,1:已审核,2.拒绝
+     *
+     * @param state 状态:0.未审核,1:已审核,2.拒绝
+     */
+    public void setState(Boolean state) {
+        this.state = state;
+    }
+
+    /**
+     * 获取上传时间
+     *
+     * @return video_upload_time - 上传时间
+     */
+    public Date getVideo_upload_time() {
+        return video_upload_time;
+    }
+
+    /**
+     * 设置上传时间
+     *
+     * @param video_upload_time 上传时间
+     */
+    public void setVideo_upload_time(Date video_upload_time) {
+        this.video_upload_time = video_upload_time;
+    }
+
+    /**
+     * 获取关键字
+     *
+     * @return video_keyword - 关键字
+     */
+    public String getVideo_keyword() {
+        return video_keyword;
+    }
+
+    /**
+     * 设置关键字
+     *
+     * @param video_keyword 关键字
+     */
+    public void setVideo_keyword(String video_keyword) {
+        this.video_keyword = video_keyword;
+    }
+
+    /**
+     * 获取介绍
+     *
+     * @return video_desc - 介绍
+     */
+    public String getVideo_desc() {
+        return video_desc;
+    }
+
+    /**
+     * 设置介绍
+     *
+     * @param video_desc 介绍
+     */
+    public void setVideo_desc(String video_desc) {
+        this.video_desc = video_desc;
+    }
+
+    /**
+     * 获取点播id
+     *
+     * @return video_id - 点播id
+     */
+    public String getVideo_id() {
+        return video_id;
+    }
+
+    /**
+     * 设置点播id
+     *
+     * @param video_id 点播id
+     */
+    public void setVideo_id(String video_id) {
+        this.video_id = video_id;
+    }
+
+    /**
+     * @return created_at
+     */
+    public Date getCreated_at() {
+        return created_at;
+    }
+
+    /**
+     * @param created_at
+     */
+    public void setCreated_at(Date created_at) {
+        this.created_at = created_at;
+    }
+
+    /**
+     * @return updated_at
+     */
+    public Date getUpdated_at() {
+        return updated_at;
+    }
+
+    /**
+     * @param updated_at
+     */
+    public void setUpdated_at(Date updated_at) {
+        this.updated_at = updated_at;
+    }
+}
 \ No newline at end of file
+package com.cnlive.shenhe.job;
+
+import com.cnlive.shenhe.entity.ShyUsers;
+import com.cnlive.shenhe.mapper.ShyUsersMapper;
+import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
+
+/**
+ * @Auther: 周伟鹏
+ * @Date: 2018/11/30 11:31
+ * @Description:
+ */
+@Component
+public class UsersJob {
+    private static Logger logger = LoggerFactory.getLogger(UsersJob.class);
+
+
+    @Autowired
+    ShyUsersMapper shyUsersMapper;
+
+    //@Scheduled(fixedRate = 30*60 * 1000)
+    public void syncUsers() {
+        long tm = 0L;
+        Example usersExample = new Example(ShyUsers.class);
+        usersExample.setOrderByClause("tm desc");
+        List<ShyUsers> usersList = shyUsersMapper.selectByExample(usersExample);
+        if(!usersList.isEmpty()){
+            String tmStr = usersList.get(0).getTm();
+        }
+
+    }
+}
+package com.cnlive.shenhe.mapper;
+
+import com.cnlive.shenhe.entity.ShyVideos;
+import tk.mybatis.mapper.common.Mapper;
+
+public interface ShyVideosMapper extends Mapper<ShyVideos> {
+}
 \ No newline at end of file
 package com.cnlive.shenhe.serviceImpl;
+import com.cnlive.shenhe.entity.ShyUsers;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
 /**
  * @Auther: 周伟鹏
@@ -14,7 +16,8 @@ public class UsersServiceImpl {
     @Autowired
     ShyUsersMapper shyUsersMapper;
-    public Object getAll(Integer id){
+    public Object get(Integer id){
         return shyUsersMapper.selectByPrimaryKey(id);
     }
+
 }
+package com.cnlive.shenhe.utils;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.codec.binary.Base32;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+import java.io.UnsupportedEncodingException;
+import java.math.BigDecimal;
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+import java.net.SocketException;
+import java.net.UnknownHostException;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.sql.Timestamp;
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+public class CommonUtils {
+    private static char md5Chars[] = {
+            '0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
+            'a', 'b', 'c', 'd', 'e', 'f'
+    };
+
+    public static boolean isNull(Object object) {
+        if (object == null)
+            return true;
+        return false;
+    }
+
+    public static boolean isNotNull(Object object) {
+        if (object == null)
+            return false;
+        return true;
+    }
+
+    public static Timestamp getCurrentTime() {
+        return new Timestamp(new Date().getTime());
+    }
+
+    public static String getRandowUUID() {
+        UUID uuid = UUID.randomUUID();
+        return uuid.toString().replaceAll("-", "");
+    }
+
+    public static boolean isEmpty(String str) {
+        if (str == null || "".equals(str.trim()))
+            return true;
+        return false;
+    }
+
+    public static boolean isNotEmpty(String str) {
+        if (str != null && !"".equals(str.trim()))
+            return true;
+        return false;
+    }
+
+    public static String formatDate(Date data, String pattern) {
+        SimpleDateFormat dateFormat = new SimpleDateFormat(pattern);
+        return dateFormat.format(data);
+    }
+
+    /**
+     * 解析命令字符串
+     *
+     * @param command
+     * @return
+     * @author fan xiao chun
+     * @date 2016年9月5日
+     */
+    public static Map<String, String> parseCommand(String command) {
+        Map<String, String> cmdMap = new HashMap<String, String>();
+        String[] items = command.split("&");
+        for (String item : items) {
+            int splitIndex = item.indexOf("=");
+            String key = item.substring(0, splitIndex);
+            String value = item.substring(splitIndex + 1);
+            cmdMap.put(key, value);
+        }
+        return cmdMap;
+    }
+
+    /**
+     * 四舍五入
+     *
+     * @param num
+     * @param digit
+     * @return
+     * @author fan xiao chun
+     * @date 2016年9月21日
+     */
+    public static float getRound(float num, int digit) {
+        BigDecimal b = new BigDecimal(num);
+        float f1 = b.setScale(digit, BigDecimal.ROUND_HALF_UP).floatValue();
+        return f1;
+    }
+
+    /**
+     * 获取当前时间戳
+     *
+     * @return
+     */
+    public static long getCurrentMillisecond() {
+        return new Date().getTime();
+    }
+
+    /**
+     * 按指定格式解析日期
+     *
+     * @param date
+     * @param pattern
+     * @return
+     * @throws ParseException
+     */
+    public static Timestamp parseDate(String date, String pattern) throws ParseException {
+        SimpleDateFormat dateFormat = new SimpleDateFormat(pattern);
+        return new Timestamp(dateFormat.parse(date).getTime());
+    }
+
+    /**
+     * 获取本机ip
+     *
+     * @return
+     * @date 2017年3月12日
+     * @author fanxiaochun
+     */
+    public static String getLocalIp() {
+        try {
+            if (isWindowsOS()) {
+                return InetAddress.getLocalHost().getHostAddress();
+            } else {
+                return getLinuxLocalIp();
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+
+    public static String decodeBase32(String str) {
+        Base32 base32 = new Base32();
+        try {
+            return new String(base32.decode(str.getBytes("utf-8")), "utf-8");
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    public static String encodeBase32(String str) {
+        Base32 base32 = new Base32();
+        try {
+            return base32.encodeAsString(str.getBytes("utf-8"));
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    private static String toHexString(byte[] b) {
+        char HEX_DIGITS[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'};
+        StringBuilder sb = new StringBuilder(b.length * 2);
+        for (int i = 0; i < b.length; i++) {
+            sb.append(HEX_DIGITS[(b[i] & 0xf0) >>> 4]);
+            sb.append(HEX_DIGITS[b[i] & 0x0f]);
+        }
+        return sb.toString();
+    }
+
+    public static String Bit32(String SourceString) {
+        try {
+
+            MessageDigest digest = MessageDigest.getInstance("MD5");
+            digest.update(SourceString.getBytes());
+            byte messageDigest[] = digest.digest();
+            return toHexString(messageDigest);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    public static String Bit16(String SourceString) {
+        try {
+            return Bit32(SourceString).substring(8, 24);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return "";
+    }
+
+    public static int getShortSide(String res) {
+        String[] resArr = res.split("x");
+        int width = Integer.parseInt(resArr[0]);
+        int height = Integer.parseInt(resArr[1]);
+
+        if (width > height)
+            return height;
+
+        return width;
+    }
+
+    /**
+     * 获取短边长度
+     *
+     * @param width
+     * @param height
+     * @return
+     */
+    public static int getShortSide(int width, int height) {
+        if (width > height)
+            return height;
+
+        return width;
+    }
+
+    /**
+     * md5加密
+     *
+     * @param str
+     * @return
+     */
+    public static String md5(String str) throws NoSuchAlgorithmException, UnsupportedEncodingException {
+        MessageDigest md5 = MessageDigest.getInstance("MD5");
+        md5.update(str.getBytes("UTF-8"));
+        byte digest[] = md5.digest();
+        char chars[] = toHexChars(digest);
+        return new String(chars);
+    }
+
+    private static char[] toHexChars(byte digest[]) {
+        char chars[] = new char[digest.length * 2];
+        int i = 0;
+        byte abyte0[] = digest;
+        int j = abyte0.length;
+        for (int k = 0; k < j; k++) {
+            byte b = abyte0[k];
+            char c0 = md5Chars[(b & 0xf0) >> 4];
+            chars[i++] = c0;
+            char c1 = md5Chars[b & 0xf];
+            chars[i++] = c1;
+        }
+
+        return chars;
+    }
+
+
+    /**
+     * 判断操作系统是否是Windows
+     *
+     * @return
+     */
+    public static boolean isWindowsOS() {
+        boolean isWindowsOS = false;
+        String osName = System.getProperty("os.name");
+        if (osName.toLowerCase().indexOf("windows") > -1) {
+            isWindowsOS = true;
+        }
+        return isWindowsOS;
+    }
+
+    /**
+     * 获取本地Host名称
+     */
+    public static String getLocalHostName() throws UnknownHostException {
+        return InetAddress.getLocalHost().getHostName();
+    }
+
+    /**
+     * 获取Linux下的IP地址
+     *
+     * @return IP地址
+     * @throws SocketException
+     */
+    private static String getLinuxLocalIp() throws SocketException {
+        String ip = "";
+        for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements(); ) {
+            NetworkInterface intf = en.nextElement();
+            String name = intf.getName();
+            if (!name.contains("docker") && !name.contains("lo")) {
+                for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements(); ) {
+                    InetAddress inetAddress = enumIpAddr.nextElement();
+                    if (!inetAddress.isLoopbackAddress()) {
+                        String ipaddress = inetAddress.getHostAddress().toString();
+                        if (!ipaddress.contains("::") && !ipaddress.contains("0:0:") && !ipaddress.contains("fe80")) {
+                            ip = ipaddress;
+                        }
+                    }
+                }
+            }
+        }
+
+        return ip;
+    }
+
+
+    /**
+     * 文件大小格式化
+     *
+     * @param bSize b单位
+     * @return
+     */
+    public static String sizeFormat(long bSize) {
+        String size = "";
+        float kbSize = bSize / 1024.0f;
+        if (kbSize >= 1.0f) {
+            float mbSize = kbSize / 1024.0f;
+            if (mbSize >= 1.0f) {
+                float gbSize = mbSize / 1024.0f;
+                if (gbSize >= 1.0f) {
+                    size = getRound(gbSize, 2) + "G";
+                } else {
+                    size = getRound(mbSize, 2) + "M";
+                }
+            } else {
+                size = getRound(kbSize, 2) + "K";
+            }
+        } else {
+            size = getRound(bSize, 2) + "B";
+        }
+        return size;
+    }
+
+    /**
+     * 相比返回最大值
+     *
+     * @param width
+     * @param height
+     * @return
+     */
+    public static int max(int width, int height) {
+        if (width > height)
+            return width;
+        return height;
+    }
+
+    /**
+     * 将秒转换成固定格式时分秒输出
+     *
+     * @param second
+     * @param separator
+     * @return
+     * @author fan xiao chun
+     */
+
+    public static String secondTimeFormat(long second, String separator) {
+        int secondCardinal = 1;
+        int minuteCardinal = secondCardinal * 60;
+        int hourCardinal = minuteCardinal * 60;
+
+        String hourStr = null;
+        String minuteStr = null;
+        String secondStr = null;
+
+        long hour = 0;
+        long minute = 0;
+        String timeStr = null;
+
+        if ((hour = second / hourCardinal) > 0)
+            second = second - hourCardinal * hour;
+        if ((minute = second / minuteCardinal) > 0)
+            second = second - minuteCardinal * minute;
+
+        hourStr = (String.valueOf(hour).length() == 1) ? "0" + hour : hour + "";
+        minuteStr = (String.valueOf(minute).length() == 1) ? "0" + minute : minute + "";
+        secondStr = (String.valueOf(second).length() == 1) ? "0" + second : second + "";
+        return hourStr + separator + minuteStr + separator + secondStr;
+    }
+
+    /**
+     * 将固定格式时分秒输出转换成秒
+     *
+     * @param timeStr
+     * @param separator
+     * @return
+     * @author fan xiao chun
+     */
+    public static long timeStrToSecond(String timeStr, String separator) {
+        int secondCardinal = 1;
+        int minuteCardinal = secondCardinal * 60;
+        int hourCardinal = minuteCardinal * 60;
+
+        String[] timeArr = timeStr.split(separator);
+        long hour = Long.parseLong(timeArr[0]);
+        long minute = Long.parseLong(timeArr[1]);
+        long second = Long.parseLong(timeArr[2]);
+        return hour * hourCardinal + minute * minuteCardinal + second;
+    }
+
+    /**
+     * 获取异常日志
+     *
+     * @param ex
+     * @return
+     */
+    public static String getExceptioniInformation(Throwable ex) {
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        PrintStream pout = new PrintStream(out);
+        ex.printStackTrace(pout);
+        String ret = new String(out.toByteArray());
+        pout.close();
+        try {
+            out.close();
+        } catch (Exception e) {
+            return null;
+        }
+        return ret;
+    }
+
+    /**
+     * 将对象转成map形式
+     *
+     * @param o
+     * @return
+     */
+    public static Map objectToMap(Object o) {
+        return (Map) JSONObject.toJSON(o);
+    }
+
+
+    /**
+     * 判断当前json数组是否为空
+     *
+     * @param jsonArray
+     * @return
+     */
+    public static boolean isEmpty(JSONArray jsonArray) {
+        if (isNotNull(jsonArray) && !jsonArray.isEmpty()) {
+            return false;
+        }
+        return true;
+    }
+
+    /**
+     * 返回当前时间,格式HH:mm:ss new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
+     *
+     * @return String 当前时间
+     */
+    public static String getCurrentDate(String formatStr) {
+        String time = null;
+        try {
+            DateFormat myformat = new SimpleDateFormat(formatStr);
+            time = myformat.format(new Date());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return time;
+    }
+
+
+    public static boolean isAjax(HttpServletRequest request) {
+        String requestType = request.getHeader("X-Requested-With");
+        if ("XMLHttpRequest".equals(requestType)) {
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * 将字符串匹配替换成占位符形式
+     *
+     * @param str
+     * @param separator
+     * @return
+     */
+    public static String format(String str, String regex, String separator) {
+        String temp = "";
+        String[] pathArr = null;
+        if (str.startsWith(separator)) {
+            temp = separator;
+            pathArr = str.replaceFirst(separator, "").split(separator);
+        } else {
+            pathArr = str.split(separator);
+        }
+        int perchIndex = 0;
+        String path = null;
+        for (int i = 0; i < pathArr.length; i++) {
+            path = pathArr[i];
+            if (path.matches("\\d+") || path.indexOf("%2C") >= 0 || path.indexOf(",") >= 0) {
+                //path = path.replaceFirst("(\\d+)", String.format("%s%d%s", "{", perchIndex, "}"));
+                path = "{" + perchIndex + "}";
+                perchIndex++;
+            }
+            temp += path;
+            if (i != pathArr.length - 1) {
+                temp += separator;
+            }
+        }
+        return temp;
+    }
+
+    public static <T> T toObject(Object o, Class<T> tClass) {
+        return JSONObject.parseObject(JSONObject.toJSONString(o), tClass);
+    }
+
+    /**
+     * 判断json中是否有该key的json对象，如果没有将该key添加到json中，并返回key代表的json對象
+     *
+     * @param jsonObject
+     * @param key
+     * @return
+     */
+    public static JSONObject getJSONObject(JSONObject jsonObject, String key) {
+        JSONObject obj = jsonObject.getJSONObject(key);
+        if (CommonUtils.isNull(obj)) {
+            obj = new JSONObject();
+            jsonObject.put(key, obj);
+        }
+        return obj;
+    }
+
+    /**
+     * 判断jsonArr中是否有该key的json对象，如果没有将该key添加到json中，并返回key代表的jsonArr對象
+     *
+     * @param jsonObject
+     * @param key
+     * @return
+     */
+    public static JSONArray getJSONArray(JSONObject jsonObject, String key) {
+        JSONArray obj = jsonObject.getJSONArray(key);
+        if (CommonUtils.isNull(obj)) {
+            obj = new JSONArray();
+            jsonObject.put(key, obj);
+        }
+        return obj;
+    }
+
+
+    /**
+     * 判断是否是网络地址
+     *
+     * @param url
+     */
+    public static boolean isHttpUrl(String url) {
+        if (isNotEmpty(url)) {
+            if (url.startsWith("http://") || url.startsWith("https://")) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+    public static Timestamp getTimestamp(String timeStr, String fromPattern) {
+        Timestamp dateTime = null;
+        try {
+            SimpleDateFormat formatter = null;
+            if (isEmpty(fromPattern)) {
+                formatter = new SimpleDateFormat("yyyy-MM-dd");
+            } else {
+                formatter = new SimpleDateFormat(fromPattern);
+            }
+            Date day = formatter.parse(timeStr);
+            dateTime = new Timestamp(day.getTime());
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+        return dateTime;
+    }
+}
-spring.datasource.url=jdbc:mysql://localhost:3307/new_shy?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false
+spring.datasource.url=jdbc:mysql://120.92.102.31:3306/new_shy?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false
 spring.datasource.username=root
-spring.datasource.password=root
+spring.datasource.password=M345sdfss4!
 spring.datasource.driver-class-name=com.mysql.jdbc.Driver
 spring.jpa.properties.hibernate.hbm2ddl.auto=update
@@ -23,9 +23,9 @@
         <jdbcConnection driverClass="com.mysql.jdbc.Driver"
-                        connectionURL="jdbc:mysql://localhost:3307/new_shy??useUnicode=true&amp;characterEncoding=utf8&amp;characterSetResults=utf8"
+                        connectionURL="jdbc:mysql://120.92.102.31:3306/new_shy??useUnicode=true&amp;characterEncoding=utf8&amp;characterSetResults=utf8"
                         userId="root"
-                        password="root">
+                        password="M345sdfss4!">
         </jdbcConnection>
         <javaModelGenerator targetPackage="com.cnlive.shenhe.entity" targetProject="src/main/java"/>
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.cnlive.shenhe.mapper.ShyVideosMapper">
+  <resultMap id="BaseResultMap" type="com.cnlive.shenhe.entity.ShyVideos">
+    <!--
+      WARNING - @mbg.generated
+    -->
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="video_title" jdbcType="VARCHAR" property="video_title" />
+    <result column="spid" jdbcType="INTEGER" property="spid" />
+    <result column="video_url" jdbcType="VARCHAR" property="video_url" />
+    <result column="video_imgs" jdbcType="VARCHAR" property="video_imgs" />
+    <result column="video_tags" jdbcType="VARCHAR" property="video_tags" />
+    <result column="updater" jdbcType="VARCHAR" property="updater" />
+    <result column="auditor" jdbcType="INTEGER" property="auditor" />
+    <result column="callback" jdbcType="VARCHAR" property="callback" />
+    <result column="video_priority" jdbcType="VARCHAR" property="video_priority" />
+    <result column="msg" jdbcType="VARCHAR" property="msg" />
+    <result column="state" jdbcType="BIT" property="state" />
+    <result column="video_upload_time" jdbcType="TIMESTAMP" property="video_upload_time" />
+    <result column="video_keyword" jdbcType="VARCHAR" property="video_keyword" />
+    <result column="video_desc" jdbcType="VARCHAR" property="video_desc" />
+    <result column="video_id" jdbcType="VARCHAR" property="video_id" />
+    <result column="created_at" jdbcType="TIMESTAMP" property="created_at" />
+    <result column="updated_at" jdbcType="TIMESTAMP" property="updated_at" />
+  </resultMap>
+</mapper>
 \ No newline at end of file