java-自定义sql查询

api

package com.xuecheng.api.nuoyun;

import com.xuecheng.framework.domain.nuoyun.User;
import com.xuecheng.framework.domain.nuoyun.ext.UserNode;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;

/**
 * Created by Administrator.
 */

@Api(value="用户管理接口",description = "用户管理接口，提供课程的增、删、改、查")
public interface UserControllerApi {
    @ApiOperation("用户查询")
    public String findUserList(String openid,String type);

    @GetMapping("单个用户查询")
    String findUserById(@PathVariable("id") String id);

    @ApiOperation("添加")
    UserNode addUser(@RequestBody User user);

}

控制器层

package com.xuecheng.manage_user.controller;

import com.xuecheng.api.nuoyun.UserControllerApi;
import com.xuecheng.framework.domain.nuoyun.User;
import com.xuecheng.framework.domain.nuoyun.ext.UserNode;

import com.xuecheng.manage_user.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/**
 * @author Administrator
 * @version 1.0
 **/
@RestController
@RequestMapping("/nuoyun")
public class UserController implements UserControllerApi {

    @Autowired
    UserService userService;

    @Override
    @GetMapping("/User/list/{openid}/{type}")
    public String findUserList(@PathVariable("openid") String openid, @PathVariable("type") String type) {
        return userService.findUserList(openid,type);

    }

    @Override
    @GetMapping("/User/findUserById/{id}")
    public String findUserById(@PathVariable("id") String id) {
        return userService.findUserById(id);

    }

    @Override
    public UserNode addUser(User user) {
        return null;
    }

}

package com.xuecheng.manage_user.service;
import com.xuecheng.framework.domain.nuoyun.User;
import com.xuecheng.manage_user.dao.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author Administrator
 * @version 1.0
 **/
@Service
public class UserService {


    @Autowired
    UserRepository userRepository;
    //查询课程计划
    public String findUserList(String openid,String type){
        List<User> userList = userRepository.findByOpenidAndType(openid, type);
        if(userList == null || userList.size()<=0){
            //新添加一个课程的根结点
            User user = new User();
            user.setOpenid(openid);
            user.setType("1");
            user.setRegIp("171.11.1.228");
            user.setRegTime("20200228");
            user.setPhoto("1.jpg");
            user.setAuthStatus("1");
            user.setAuthTime("20200228");
            user.setRegTime("20200228");
            user.setWaiterId("2");
            user.setMasterType("2");
            user.setClientType("2");
            user.setRoomLimit("2");
            user.setCreateArea("2");
            user.setSalesman("2");
            user.setIsWebrtc("2");
            user.setCdnSwitch("2");
            user.setPushExtime("20200228");
            user.setConcurrencyLimit("1");
            userRepository.save(user);
            return user.getId();

        }
        return userList.get(0).getId();
    }
    public String findUserById(String id){
        User user = userRepository.findUserById("34993");
        return user.getWechatName();
    }
}

dao层

package com.xuecheng.manage_user.dao;

import com.xuecheng.framework.domain.nuoyun.User;
import org.springframework.data.jpa.repository.JpaRepository;

import java.util.List;

/**
 * Created by Administrator.
 */
public interface UserRepository extends JpaRepository<User,String> {
        List<User> findByOpenidAndType(String openid, String type);
        User findUserById(String id);
}

map

测试

package com.xuecheng.manage_user.dao;

import com.xuecheng.framework.domain.course.CourseBase;
import com.xuecheng.framework.domain.course.Teachplan;
import com.xuecheng.framework.domain.course.ext.TeachplanNode;
import com.xuecheng.framework.domain.nuoyun.User;
import com.xuecheng.framework.domain.nuoyun.ext.UserNode;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;
import java.util.Optional;

/**
 * @author Administrator
 * @version 1.0
 **/
@SpringBootTest
@RunWith(SpringRunner.class)
public class TestDao {
    @Autowired
    UserRepository userRepository;

    @Test
    public void testCourseBaseRepository(){
        Optional<User> optional = userRepository.findById("34993");
        if(optional.isPresent()){
            User user = optional.get();
            System.out.println(user);
        }

    }


    @Test
    public void testFindUser(){
        User user = userRepository.findUserById("34993");
        System.out.println(user);

    }
}