胖丁用户

.gitignore

+.idea
+*.iml
+*.suo
+.vs
+Debug
+bin
+obj
+target
\ No newline at end of file

demo_dev_reset.sh

+#!/bin/bash
+
+source func.sh
+
+function tFunc(){
+    stopStart "$1" "$2" "$3"
+}
+
+# 对内服务
+tFunc tbd-demo.jar

demo_prod_reset.sh

+#!/bin/bash
+
+source func.sh
+
+function tFunc(){
+    stopStart "$1" "--spring.profiles.active=prod" "$2"
+}
+
+# 对内服务
+tFunc tbd-demo.jar

func.sh

+#!/bin/bash
+basepath=$(cd `dirname $0`; pwd)
+echo "cd "$basepath
+cd $basepath
+
+function stop(){
+    var1=${1/-e"\n"/" "}
+    var2=${2/-e"\n"/" "}
+    var3=${3/-e"\n"/" "}
+    if [ ! -n "${var2/ /}" ] ;then
+    cmdCommand="ps -ef|grep java|grep '"$var1"'|grep -v grep|awk '{print \$2}'"
+    else
+    cmdCommand="ps -ef|grep java|grep '"$var1" "$var2"'|grep -v grep|awk '{print \$2}'"
+    fi
+    echo $cmdCommand
+    eval "pid=\`"$cmdCommand"\`"
+    if [ -n "$pid" ]
+    then
+        #!kill -9 强制终止
+        echo "pid:" $pid
+        # kill -9 $pid
+        for i in $pid
+        do
+            echo "kill -9 的pid:" $i
+            kill -9 $i
+        done
+    fi
+}
+
+function start(){
+    var1=${1/-e"\n"/" "}
+    var2=${2/-e"\n"/" "}
+    var3=${3/-e"\n"/" "}
+    chmod 777 $var1
+    mkdir log
+    javaCommand="nohup java -jar "$var1" "$var2" >log/"$var1"_"$var3".`date +%Y%m%d%H%M%S`.log 2>1&"
+    echo $javaCommand
+    eval $javaCommand
+}
+
+function stopStart(){
+    stop "$1" "$2"
+    start "$1" "$2" "$3"
+}

pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.pangding.web</groupId>
+        <artifactId>pd-util-service</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <groupId>com.pangding.web</groupId>
+    <artifactId>pd-demo</artifactId>
+    <packaging>jar</packaging>
+    <version>1.0-SNAPSHOT</version>
+    <description>DEMO演示</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+
+    <repositories>
+        <repository>
+            <id>pd</id>
+            <url>http://192.168.0.203:8081/repository/pd-group/</url>
+            <snapshots>
+                <enabled>true</enabled>
+                <updatePolicy>always</updatePolicy>
+            </snapshots>
+        </repository>
+    </repositories>
+
+</project>
\ No newline at end of file

src/main/java/com/pangding/web/UserApp.java

+package com.pangding.web;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+/**
+ * 日志自动启动服务
+ */
+@SpringBootApplication(scanBasePackages = {
+        "com.pangding.*",
+        "com.yanzuoguang.*",
+        "org.springframework.jdbc.*"
+})
+@EnableEurekaClient
+@EnableFeignClients
+public class UserApp {
+
+    public static void main(String[] args) {
+        SpringApplication.run(UserApp.class, args);
+    }
+}
\ No newline at end of file

src/main/java/com/pangding/web/demo/dao/pd/DemoDao.java

+package com.pangding.web.demo.dao.pd;
+
+
+import com.pangding.web.demo.vo.tbd.DemoVo;
+import com.yanzuoguang.dao.BaseDao;
+import com.yanzuoguang.util.vo.PageSizeData;
+import com.yanzuoguang.util.vo.PageSizeReqVo;
+
+/**
+ * 日志接口基本操作类
+ */
+public interface DemoDao extends BaseDao {
+    PageSizeData<DemoVo> query(PageSizeReqVo req);
+}

src/main/java/com/pangding/web/demo/dao/pd/impl/DemoDaoImpl.java

+package com.pangding.web.demo.dao.pd.impl;
+
+import com.pangding.web.demo.vo.tbd.DemoVo;
+import com.pangding.web.demo.dao.pd.DemoDao;
+import com.yanzuoguang.dao.DaoConst;
+import com.yanzuoguang.dao.Impl.BaseDaoImpl;
+import com.yanzuoguang.util.vo.PageSizeData;
+import com.yanzuoguang.util.vo.PageSizeReqVo;
+import org.springframework.stereotype.Component;
+
+@Component
+public class DemoDaoImpl extends BaseDaoImpl implements DemoDao {
+    /**
+     * 注册SQL语句
+     */
+    @Override
+    protected void init() {
+        // 根据实体生成增删改查语句
+        register(DemoVo.class);
+
+        Table.add(DaoConst.Query, "SELECT * FROM tbd_demo");
+    }
+
+    @Override
+    public PageSizeData<DemoVo> query(PageSizeReqVo req) {
+        return this.queryPage(DemoVo.class, req, DaoConst.Query, req);
+    }
+}

src/main/java/com/pangding/web/demo/feign/DemoLogFeign.java

+package com.pangding.web.demo.feign;
+
+import com.yanzuoguang.util.vo.LogVo;
+import com.yanzuoguang.util.vo.ResponseResult;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+/**
+ * LogInterFeign
+ *
+ * @author: Kang
+ * @time: 2018年04月25日 14:00
+ */
+@FeignClient(value = "tbd-log")
+public interface DemoLogFeign {
+
+    /**
+     * 请求日志服务
+     *
+     * @param logVo
+     */
+    @RequestMapping(value = "/log/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    ResponseResult<String> save(LogVo logVo);
+}

src/main/java/com/pangding/web/demo/service/DemoService.java

+package com.pangding.web.demo.service;
+
+
+import com.pangding.web.demo.vo.tbd.DemoVo;
+import com.yanzuoguang.util.vo.PageSizeData;
+import com.yanzuoguang.util.vo.PageSizeReqVo;
+
+/**
+ * 日志服务
+ */
+public interface DemoService {
+    /**
+     * 保存接口请求日志
+     *
+     * @param logVo
+     */
+    String create(DemoVo logVo);
+
+    PageSizeData<DemoVo> query(PageSizeReqVo req);
+}

src/main/java/com/pangding/web/demo/service/impl/DemoServiceImpl.java

+package com.pangding.web.demo.service.impl;
+
+import com.pangding.web.demo.service.DemoService;
+import com.pangding.web.demo.vo.tbd.DemoVo;
+import com.pangding.web.demo.dao.pd.DemoDao;
+import com.yanzuoguang.util.vo.PageSizeData;
+import com.yanzuoguang.util.vo.PageSizeReqVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 日志写入服务类
+ */
+@Component
+@Transactional
+public class DemoServiceImpl implements DemoService {
+
+    @Autowired
+    private DemoDao demoDao;
+
+    /**
+     * 保存接口请求日志
+     *
+     * @param demoVo
+     */
+    public String create(DemoVo demoVo) {
+        return demoDao.create(demoVo);
+    }
+
+    @Override
+    public PageSizeData<DemoVo> query(PageSizeReqVo req) {
+        return demoDao.query(req);
+    }
+
+}

src/main/java/com/pangding/web/demo/vo/tbd/DemoVo.java

+package com.pangding.web.demo.vo.tbd;
+
+
+import com.yanzuoguang.dao.TableAnnotation;
+
+@TableAnnotation("tbd_demo")
+public class DemoVo {
+    /**
+     * 编号,主键请放第一个
+     */
+    // @TableAnnotation("id")   // 假如是一样的字段，则不需要写映射
+    private String id;
+    /**
+     * 接口对象(通联,携程等)
+     */
+    private String name;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}

src/main/java/com/pangding/web/demo/web/DemoController.java

+package com.pangding.web.demo.web;
+
+import com.pangding.web.demo.feign.DemoLogFeign;
+import com.pangding.web.demo.service.DemoService;
+import com.pangding.web.demo.vo.tbd.DemoVo;
+import com.yanzuoguang.util.exception.CodeException;
+import com.yanzuoguang.util.helper.CheckerHelper;
+import com.yanzuoguang.util.vo.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 日志操作控制类
+ */
+@RestController
+@RequestMapping("/demo")
+public class DemoController {
+
+    @Autowired
+    private DemoService logsService;
+
+    @Autowired
+    private DemoLogFeign demoLogFeign;
+
+    /**
+     * 保存演示DEMO
+     *
+     * @param req
+     */
+    @RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    public ResponseResult save(@RequestBody DemoVo req) {
+        CheckerHelper.newInstance()
+                .notBlankCheck("name", req.getName())
+                .checkException(req);
+        return ResponseResult.result(logsService.create(req));
+    }
+
+    /**
+     * 保存演示DEMO
+     *
+     * @param req
+     */
+    @RequestMapping(value = "/save_exception", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    public ResponseResult save_exception(@RequestBody DemoVo req) {
+        throw new CodeException("01", "异常错误");
+    }
+
+    /**
+     * 保存演示DEMO
+     *
+     * @param req
+     */
+    @RequestMapping(value = "/log", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    public ResponseResult<String> log_exception(@RequestBody LogVo req) {
+        demoLogFeign.save(req);
+        return ResponseResult.result("保存成功");
+    }
+
+    /**
+     * 查询
+     * @param req
+     * @return
+     */
+    @RequestMapping(value = "/query", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
+    public ResponseResult<PageSizeData<DemoVo>> query(@RequestBody PageSizeReqVo req){
+        return ResponseResult.result(logsService.query(req));
+    }
+}

src/main/resources/bootstrap-dev.yml

+eureka:
+  client:
+    service-url:
+      defaultZone: http://192.168.0.88:6800/eureka/
+yzg:
+  logAll: true
\ No newline at end of file

src/main/resources/bootstrap.yml

+spring:
+  profiles:
+    active: dev
+  application:
+    name: pd-user
+  cloud:
+    config:
+      # base为所有服务的公共配置，pd-db-system为需要连接的数据库配置,${spring.application.name}为当前程序的配置，3个配置组合才为当前程序的启动配置
+      name: base,pd-db-system,${spring.application.name}
+      label: master
+      fail-fast: true
+      # 设置从服务中拿取配置
+      discovery:
+        enabled: true
+        service-id: pd-config
+      # 设置配置拿取重试次数,可能有错误
+      retry:
+        initial-interval: 1000
+        max-interval: 1000
+        max-attempts: 1000
+        multiplier: 1.1
\ No newline at end of file