package com.iplatform.api;
|
|
import com.iplatform.base.PushController;
|
import com.iplatform.base.PushData;
|
import com.iplatform.base.service.UserServiceImpl;
|
import com.iplatform.model.po.S_user_core;
|
import com.walker.db.page.GenericPager;
|
import com.walker.infrastructure.utils.DateUtils;
|
import com.walker.infrastructure.utils.JsonUtils;
|
import com.walker.web.ResponseValue;
|
import com.walker.web.WebRuntimeException;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.core.parameters.P;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.TimeUnit;
|
|
@RestController
|
@RequestMapping("/test/web")
|
public class TestWebController extends PushController {
|
|
// private SchedulerServiceImpl schedulerService;
|
private JdbcTemplate jdbcTemplate;
|
private UserServiceImpl userService;
|
|
@Autowired
|
public TestWebController(JdbcTemplate jdbcTemplate, UserServiceImpl userService){
|
// this.schedulerService = schedulerService;
|
this.jdbcTemplate = jdbcTemplate;
|
this.userService = userService;
|
}
|
|
@RequestMapping("/push_msg")
|
public ResponseValue testPushMessage() throws Exception{
|
|
PushData pushData = new PushData();
|
pushData.setTitle("审批文件事项");
|
pushData.setBusinessType("001");
|
pushData.setBusinessId("123456789");
|
pushData.setUserId("1"); // shikeying
|
|
this.pushMessageNotification(pushData);
|
logger.info("----------- 'msg' end -----------");
|
|
TimeUnit.SECONDS.sleep(2);
|
|
this.pushMailNotification("测试标题", "你好！这是一个邮件信息", "1");
|
logger.info("----------- 'mail' end -----------");
|
return ResponseValue.success();
|
}
|
|
@Transactional
|
@RequestMapping("/rollback")
|
public ResponseValue<String> testTransactionRollback(String error){
|
// 更新记录: 1
|
this.jdbcTemplate.execute("update s_scheduler set status=2 where id=1");
|
if(error != null && error.equals("true")){
|
throw new WebRuntimeException("业务异常，回滚", "data");
|
}
|
// 更新记录: 2
|
this.jdbcTemplate.execute("update s_scheduler set status=2 where id=2");
|
return ResponseValue.success();
|
}
|
|
@RequestMapping("/po")
|
public ResponseValue testPoJson() throws Exception{
|
S_user_core user_core = new S_user_core();
|
user_core.setId(123L);
|
user_core.setUser_name("时克英");
|
user_core.setUpdate_time(20230324103901L);
|
String json = JsonUtils.objectToJsonString(user_core);
|
// JsonUtils
|
return ResponseValue.success(json);
|
}
|
|
@RequestMapping("/jdbc")
|
public ResponseValue testJdbc(){
|
|
// 批量添加
|
// List<S_user_core> user_coreList = new ArrayList<>(8);
|
// user_coreList.add(this.createOneUser(100));
|
// user_coreList.add(this.createOneUser(101));
|
// user_coreList.add(this.createOneUser(102));
|
// int success = this.userService.insertBatch(user_coreList);
|
// System.out.println("--------> 批量写入新用户: " + success);
|
//
|
// List<S_user_core> editList = new ArrayList<>(4);
|
// S_user_core edit100 = new S_user_core();
|
// edit100.setId(100L);
|
// edit100.setNick_name("修改名字100");
|
// S_user_core edit101 = new S_user_core();
|
// edit101.setId(101L);
|
// edit101.setNick_name("修改名字101");
|
// editList.add(edit100);
|
// editList.add(edit101);
|
// success = this.userService.updateBatch(editList);
|
// System.out.println("--------> 批量更新用户（相同属性）: " + success);
|
|
S_user_core selectPo = new S_user_core();
|
selectPo.setStatus(0);
|
selectPo.setDept_id(1670057808440L);
|
// selectPo.setUser_name("login_%");
|
selectPo.setUser_name("13838277463");
|
List<S_user_core> list = this.userService.select(selectPo);
|
if(list != null){
|
for(S_user_core user : list){
|
System.out.println(user);
|
}
|
}
|
System.out.println("--------> 搜索用户集合: ");
|
|
S_user_core userPo = new S_user_core();
|
userPo.setUser_type(2);
|
// userPo.setDept_id(1670057686025L);
|
GenericPager<S_user_core> pager = this.userService.selectSplit(userPo, 2, 6);
|
for(S_user_core s : pager.getDatas()){
|
System.out.println("------- 用户:" + s.getNick_name());
|
}
|
return ResponseValue.success();
|
}
|
|
private S_user_core createOneUser(long id){
|
S_user_core user = new S_user_core();
|
user.setId(id);
|
user.setCreate_by("insertBatch");
|
user.setCreate_time(DateUtils.getDateTimeNumber());
|
user.setUser_name("login_" + id);
|
user.setNick_name("姓名_" + id);
|
user.setUser_type(2);
|
user.setOrg_id(1670031584892L);
|
user.setDept_id(1670057808440L);
|
user.setPassword("$2a$10$9lSwwUFMULR6/KhPsUbTj.0PTZfTnq0fB3OtS6PWoKAibpa8hL1cy");
|
return user;
|
}
|
}
|
