Commit 82604655 authored by tangfang's avatar tangfang

创建新项目

parent 50d198d9
Pipeline #1025 failed with stages
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
</parent> </parent>
<groupId>com.pangding.web</groupId> <groupId>com.pangding.web</groupId>
<artifactId>pd-user</artifactId> <artifactId>tcm-system</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<description>用户模块</description> <description>用户模块</description>
......
@echo off @echo off
SET SH=docker rm -f pd-user; SET SH=docker rm -f tcm-system;
SET SH=%SH% docker run --name pd-user -it -d --restart always SET SH=%SH% docker run --name tcm-system -it -d --restart always
SET SH=%SH% -v /home/other/home/pangd/conf:/home/java/conf/ -v /home/other/home/cache/:/home/cache/ -v /home/other/home/pangd/:/home/pangd/ --net pd SET SH=%SH% -v /home/other/home/pangd/conf:/home/java/conf/ -v /home/other/home/cache/:/home/cache/ -v /home/other/home/pangd/:/home/pangd/ --net pd
SET SH=%SH% pd-user:latest --spring.profiles.active=prod --yzg.config.url=/home/java/conf/pd_all.properties SET SH=%SH% pd-user:latest --spring.profiles.active=prod --yzg.config.url=/home/java/conf/pd_all.properties
SET SH1_NAME=pd-user SET SH1_NAME=tcm-system
SET SH1=docker rm -f %SH1_NAME%; SET SH1=docker rm -f %SH1_NAME%;
SET SH1=%SH1% docker run --name %SH1_NAME% -it -d --restart always SET SH1=%SH1% docker run --name %SH1_NAME% -it -d --restart always
SET SH1=%SH1% -v /home/other/home/pangd/conf:/home/java/conf/ -v /home/other/home/cache/:/home/cache/ -v /home/other/home/pangd/:/home/pangd/ --net pd SET SH1=%SH1% -v /home/other/home/pangd/conf:/home/java/conf/ -v /home/other/home/cache/:/home/cache/ -v /home/other/home/pangd/:/home/pangd/ --net pd
......
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.AgreementService;
import com.pangding.web.vo.system.req.AgreementTemplateReqVo;
import com.pangding.web.vo.system.res.AgreementTemplateResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import freemarker.cache.ClassTemplateLoader;
import freemarker.template.Configuration;
import freemarker.template.Template;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
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;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
/**
* @author tangfang
* @date 2020-08-31 19:03:23
* 合同模板
*/
@RestController
@RequestMapping(value = "/agreement", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "合同模板类", description = "合同模板的查询,新增,修改,删除等相关操作")
public class AgreementController {
private AgreementService agreementService;
public AgreementController(AgreementService agreementService) {
this.agreementService = agreementService;
}
@RequestMapping(value = "/getListAgreement")
@ApiOperation(value = "获取合同模板列表", notes = "返回合同模板列表")
public ResponseResult getListAgreement(@RequestBody AgreementTemplateReqVo req) {
return ResponseResult.result(agreementService.findAgreemnetList(req));
}
@RequestMapping(value = "/findAgreement")
@ApiOperation(value = "获取合同详情", notes = "返回合同详情")
public ResponseResult<AgreementTemplateResVo> findAgreement(@RequestBody AgreementTemplateReqVo req) {
return ResponseResult.result(agreementService.findAgreementDetail(req));
}
@RequestMapping(value = "/saveAgreementTemplate")
@ApiOperation(value = "保存合同模板", notes = "返回保存合同结果")
public ResponseResult saveAgreementTemplate(@RequestBody AgreementTemplateReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("agreementName", req.getAgreementName())
.notBlankCheck("agreementType", req.getAgreementType())
.notBlankCheck("companyAttribute", req.getCompanyAttribute())
.notBlankCheck("agreementContent", req.getAgreementContent())
.notBlankCheck("agreementFileUrl", req.getAgreementFileUrl())
.checkException();
return ResponseResult.result(agreementService.saveAgreement(req));
}
@RequestMapping(value = "/removeAgreement")
@ApiOperation(value = "删除合同模板", notes = "返回删除结果")
public ResponseResult removeAgreement(@RequestBody AgreementTemplateReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("agreementId", req.getAgreementId())
.checkException();
agreementService.removeAgreement(req);
return ResponseResult.result("");
}
@RequestMapping(value = "/test")
@ApiOperation(value = "测试", notes = "返回删除结果")
public ResponseResult test(@RequestBody AgreementTemplateReqVo req, HttpServletResponse response) {
try{
response.setContentType("application/msword");
response.setCharacterEncoding("utf-8");
String filename = URLEncoder.encode("测试word","utf-8");
response.setHeader("Content-disposition", "attachment;filename=" + filename + ".doc");
Configuration configuration = new Configuration(Configuration.DEFAULT_INCOMPATIBLE_IMPROVEMENTS);
configuration.setDefaultEncoding("utf-8");
configuration.setTemplateLoader(new ClassTemplateLoader(getClass(), "templates"));
Template t = configuration.getTemplate("test.xml", "utf-8");
Writer out = new BufferedWriter(new OutputStreamWriter(response.getOutputStream(), StandardCharsets.UTF_8), 10240);
t.process("", out);
out.close();
}catch (Exception e){
throw new RuntimeException();
}
return ResponseResult.result("");
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.AuthorityService;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.authority.vo.resvo.AuthorityListResVo;
import com.pangding.web.authority.vo.resvo.AuthorityResVo;
import com.pangding.web.authority.vo.resvo.WebAuthorityResVo;
import com.pangding.web.vo.system.pd.authority.AuthorityVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @author zhangjinyao
*/
@RestController
@RequestMapping("/authority")
@Api(value = "权限")
public class AuthorityController {
@Autowired
AuthorityService authorityServiceImpl;
/**
* 新增权限
* 返回权限id
* @param authorityVo
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<AuthorityListResVo> saveAuthority(@RequestBody AuthorityVo authorityVo){
CheckerHelper.newInstance()
.notBlankCheck("authorityName",authorityVo.getName())
.notBlankCheck("type",authorityVo.getType())
.notBlankCheck("alias",authorityVo.getAlias())
.notBlankCheck("openMode",authorityVo.getOpenMode())
.notBlankCheck("remark",authorityVo.getRemark())
.notBlankCheck("sort",authorityVo.getSort())
.checkException();
return ResponseResult.result(authorityServiceImpl.save(authorityVo));
}
/**
* 修改权限信息
* 返回权限id
* @param authorityVo
* @return
*/
@RequestMapping(value = "/update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<AuthorityListResVo> updateAuthority(@RequestBody AuthorityVo authorityVo){
CheckerHelper.newInstance()
.notBlankCheck("authorityName",authorityVo.getName())
.notBlankCheck("type",authorityVo.getType())
.notBlankCheck("alias",authorityVo.getAlias())
// .notBlankCheck("openMode",authorityVo.getOpenMode())
.notBlankCheck("remark",authorityVo.getRemark())
.notBlankCheck("sort",authorityVo.getSort())
.checkException();
return ResponseResult.result(authorityServiceImpl.update(authorityVo));
}
/**
* 查询分页权限列表
* @return
*/
@RequestMapping(value = "/listByPage", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<PageSizeData<WebAuthorityResVo>> listAuthoritys(@RequestBody ListAuthorityByPageReqVo reqVo){
return ResponseResult.result(authorityServiceImpl.getWebAuthorityResVoList(reqVo));
}
/**
* 查询不分页权限列表
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<List<AuthorityVo>> list(@RequestBody AuthorityListReqVo reqVo){
return ResponseResult.result(authorityServiceImpl.getAuthorityList(reqVo));
}
/**
* 按等级返回权限列表
* @param reqVo
* @return
*/
@RequestMapping(value = "/listByLevel", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<AuthorityListResVo> listByLevel(@RequestBody AuthorityListReqVo reqVo){
return ResponseResult.result(authorityServiceImpl.getListByLevel(reqVo));
}
/**
* 根据ID查询权限
* @param reqVo
* @return
*/
@RequestMapping(value = "/role", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<AuthorityResVo> authority(@RequestBody WebAuthorityReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("anthorityId",reqVo.getId())
.checkException();
return ResponseResult.result(authorityServiceImpl.getAuthorityById(reqVo));
}
/**
* 删除权限
* @param reqVo
* @return
*/
@RequestMapping(value = "/delete", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult delete(@RequestBody WebAuthorityReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("anthorityId",reqVo.getId())
.checkException();
authorityServiceImpl.deleteAuthorityById(reqVo);
return new ResponseResult();
}
/**
* 根据公司id找到公司的权限
* @param reqVo
* @return
*/
@RequestMapping(value = "/companyAuthority", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult companyAuthority(@RequestBody CompanyAuthorityReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(authorityServiceImpl.getCompanyAuthority(reqVo));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.CompanyCodeService;
import com.pangding.web.vo.system.pd.company.CompanyCodeVo;
import com.pangding.web.vo.system.req.company.CompanyCodeReqVo;
import com.pangding.web.vo.system.res.company.CompanyCodeResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiModelProperty;
import io.swagger.annotations.ApiOperation;
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;
import java.util.List;
@RestController
@RequestMapping(value = "/companyCode", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "商户二维码相关类", description = "商户二维码新增,修改,删除等相关操作")
public class CompanyCodeController {
@Autowired
private CompanyCodeService companyCodeService;
@RequestMapping(value = "/findCodeLink")
@ApiOperation(value = "查询商户跳转链接地址", notes = "返回商户需要跳转的连接地址.")
public ResponseResult<CompanyCodeResVo> findCodeLink(@RequestBody CompanyCodeReqVo req) {
CheckerHelper.newInstance().notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("codeType", req.getCodeType())
.checkException();
return ResponseResult.result(companyCodeService.findCodeLink(req));
}
@RequestMapping(value = "/findCodeLinkByOldLink")
@ApiOperation(value = "查询商户跳转链接地址", notes = "返回商户需要跳转的连接地址.")
public ResponseResult<CompanyCodeResVo> findCodeLinkByOldLink(@RequestBody CompanyCodeReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("codeType", req.getCodeType())
.checkException();
return ResponseResult.result(companyCodeService.findCodeLink(req));
}
@RequestMapping(value = "/findCodeList")
@ApiOperation(value = "查询商户二维码列表", notes = "返回商户二维码列表")
public ResponseResult<List<CompanyCodeResVo>> findCodeList(@RequestBody CompanyCodeReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
// .notBlankCheck("codeType", req.getCodeType())
.checkException();
return ResponseResult.result(companyCodeService.findCodeList(req));
}
@RequestMapping(value = "/saveCompanyCode")
@ApiModelProperty(value = "保存商户二维码",notes = "返回保存二维码结果")
public ResponseResult<CompanyCodeVo> saveCompanyCode(@RequestBody CompanyCodeReqVo req){
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
// .notBlankCheck("codeLink", req.getCodeLink())
.checkException();
return ResponseResult.resultAllowNull(companyCodeService.saveComapnyCode(req));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.CompanyMsgService;
import com.pangding.web.vo.system.req.CompanyMsgReqVo;
import com.pangding.web.vo.system.res.CompanyMsgResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
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(value = "/companyMsg", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "公司消息类", description = "公司消息等相关操作")
public class CompanyMsgController {
@Autowired
private CompanyMsgService companyMsgService;
@RequestMapping(value = "/getCompanyMsgList")
@ApiOperation(value = "获取公司消息列表", notes = "返回公司消息列表")
public ResponseResult<PageSizeData<CompanyMsgResVo>> getCompanyMsgList(@RequestBody CompanyMsgReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
.checkException();
return ResponseResult.result(companyMsgService.findCompanyMsgList(req));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.CompanyService;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.authority.service.RegisterService;
import com.pangding.web.authority.service.UserService;
import com.pangding.web.authority.vo.resvo.SaveCompanyResVo;
import com.pangding.web.vo.system.pd.company.CompanyVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.commons.CommonsMultipartFile;
import java.io.IOException;
/**
* @Author zhangjinyao
* @create 2019/5/14 16:28
*/
@RestController
@RequestMapping(value="/computerRegister")
public class ComputerRegisterController {
@Autowired
RegisterService registerServiceImpl;
@Autowired
UserService userServiceImpl;
@Autowired
private CompanyService companyServiceImpl;
/**
* 验证注册第一页数据的合法性并保存在pd_user表中
* 生成公司id,pd_company表中存入一条数据
* 返回公司部分信息(id,invitationCompanyId,companyType),携带到基本信息页面
*
* @param registerUserReqVo
* @return
*/
@RequestMapping(value = "/user", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyVo> saveUser(@RequestBody RegisterUserReqVo registerUserReqVo) throws Exception {
CheckerHelper.newInstance()
.notBlankCheck("account",registerUserReqVo.getAccount())
.notBlankCheck("password",registerUserReqVo.getPassword())
.notBlankCheck("confirmPassword",registerUserReqVo.getConfirmPassword())
.notBlankCheck("companyType",registerUserReqVo.getCompanyType())
.notBlankCheck("invitationCode",registerUserReqVo.getInvitationCode())
.checkException();
return ResponseResult.result(registerServiceImpl.saveUser(registerUserReqVo));
}
/**
* 当用户类型选择为“个体”时进入此方法
* 验证注册第二页数据的合法性并保存,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant都增加一条数据
* 并将联系电话更新到pd_user表中
* 返回pd_user,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant表的主键
*
* @param reqVo
* @return
*/
@RequestMapping(value="/individual", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<SaveCompanyResVo> saveIndividual(@RequestBody RegisterIndividualReqVo reqVo){
checkIndividual(reqVo);
return ResponseResult.result(registerServiceImpl.saveIndividual(reqVo));
}
private void checkIndividual(RegisterIndividualReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("contactName",reqVo.getContactName())
.notBlankCheck("contactCode",reqVo.getContactCode())
.checkIdCard("contactCode",reqVo.getContactCode())
.notBlankCheck("companyAttribute",reqVo.getCompanyAttribute())
.notBlankCheck("companyName",reqVo.getCompanyName())
.notBlankCheck("contactPhone",reqVo.getContactPhone())
.checkPhoneNo("contactPhone",reqVo.getContactPhone())
.checkException();
}
/**
* 将通过公司id获取到的公司信息和验证码传到第三方,并将返回的信息用于更新公司状态
* @param reqVo 封装了公司id和验证码的请求对象
* @return
*/
@RequestMapping(value="/individualSubmit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> individualSubmit(@RequestBody IndividualSubmitReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.notBlankCheck("verifyCode",reqVo.getVerifyCode())
.checkException();
String verifyCode = registerServiceImpl.individualSubmit(reqVo);
return ResponseResult.result(verifyCode);
}
/**
* 当用户类型选择为“企业”时进入此方法
* 验证注册第二页数据的合法性并保存,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant都增加一条数据
* 并将联系电话更新到pd_user表中
* 返回pd_user,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant表的主键
* @param reqVo
* @return
*/
@RequestMapping(value="/enterprise", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<SaveCompanyResVo> saveEnterprise(@RequestBody RegisterEnterpriceReqVo reqVo){
checkEnterprice(reqVo);
return ResponseResult.result(registerServiceImpl.saveEnterprice(reqVo));
}
private void checkEnterprice(RegisterEnterpriceReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyName",reqVo.getCompanyName())
.notBlankCheck("companyAddress",reqVo.getAddress())
.notBlankCheck("businessLicenseCode",reqVo.getBusinessLicenseCode())
.notBlankCheck("merchantName",reqVo.getMerchantName())
.notBlankCheck("companyAttribute",reqVo.getCompanyAttribute())
.notBlankCheck("contactName",reqVo.getContactName())
.notBlankCheck("contactCode",reqVo.getContactCode())
.checkIdCard("contactCode",reqVo.getContactCode())
.notBlankCheck("contactPhone",reqVo.getContactPhone())
.notBlankCheck("bankName",reqVo.getBankName())
.notBlankCheck("bankCardCode",reqVo.getBankCardCode())
// .notNumberCheck("bankCardCode",reqVo.getBankCardCode())
.notBlankCheck("bankAddress",reqVo.getBankAddress())
.notBlankCheck("bankCode",reqVo.getBankCode())
// .notNumberCheck("bankCode",reqVo.getBankCode())
.checkException();
};
/**
* 将通过公司id获取到的公司信息和验证码传到第三方,并将返回的信息用于更新公司状态
* @param reqVo 封装了公司id和验证码的请求对象
* @return
*/
@RequestMapping(value="/enterpriceSubmit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> enterpriceSubmit(@RequestBody EnterpriceSubmitReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.notBlankCheck("verifyCode",reqVo.getVerifyCode())
.checkException();
String verifyCode = registerServiceImpl.enterpriceSubmit(reqVo);
return ResponseResult.result(verifyCode);
}
/**
* 上传印业执照图片地址,更新公司表
* @param reqVo
* @return
*/
@RequestMapping(value = "/businessLicenseCode",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult businessLicenseCode(@RequestBody BusinessLicenseCodeReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.notBlankCheck("url",reqVo.getUrl())
.checkException();
registerServiceImpl.businesslicenseCode(reqVo);
return new ResponseResult();
}
@RequestMapping(value = "/fileUpload",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> fileUpload(@RequestBody CommonsMultipartFile file) throws IOException {
return ResponseResult.result(registerServiceImpl.fileUpload(file));
}
/**
* 检查邀请码是否真实存在
* @param reqVo
* @return
*/
@RequestMapping(value = "/checkInvitationCode",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyVo> checkInvitationCode(@RequestBody CheckInvitationCodeReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("invitationCode",reqVo.getInvitationCode())
.checkException();
return ResponseResult.result(companyServiceImpl.checkInvitationCode(reqVo));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.DataService;
import com.pangding.web.authority.vo.reqvo.DataSynReqVo;
import com.pangding.web.authority.vo.resvo.FindResVo;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Author zhangjinyao
* @create 2019/6/12 15:32
*/
@RestController
@RequestMapping(value = "/data")
public class DataController {
@Autowired
DataService dataServiceImpl;
@PostMapping(value = "/save", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult save(@RequestBody FindResVo reqVo){
dataServiceImpl.save(reqVo);
return new ResponseResult();
}
// @PostMapping(value = "/saveOrderStepThree",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
// public ResponseResult saveOrderStepThree(@RequestBody OrderStepThreeResVo reqVo){
// dataServiceImpl.saveOrderStepThree(reqVo);
// return new ResponseResult();
// }
//
// @PostMapping(value = "/saveOrderStepOne",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
// public ResponseResult saveOrderStepOne(@RequestBody OrderStepOneResVo reqVo){
// dataServiceImpl.saveOrderStepOne(reqVo);
// return new ResponseResult();
// }
//
// @PostMapping(value = "/dataSyn",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
// public ResponseResult dataSyn(@RequestBody DataSynReqVo reqVo){
// dataServiceImpl.dataSyn(reqVo);
// return new ResponseResult();
// }
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.DeviceService;
import com.pangding.web.vo.system.req.DeviceReqVo;
import com.pangding.web.vo.system.res.DeviceResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
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;
/**
* @author tangfang
* @date 2020-08-19
*/
@Api(value = "设备类", description = "设备的查询,新增,修改,删除等相关操作")
@RestController
@RequestMapping("/device")
public class DevideController {
@Autowired
private DeviceService deviceService;
@RequestMapping(value = "/findDeviceList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "获取设备列表", notes = "返回设备列表")
public ResponseResult<PageSizeData<DeviceResVo>> findDeviceList(@RequestBody DeviceReqVo req){
// CheckerHelper.newInstance().notBlankCheck("id",req.getId()).checkException();
return deviceService.findDeviceList(req);
}
@RequestMapping(value = "/findDeviceInfo", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "获取设备信息", notes = "返回设备信息")
public ResponseResult<DeviceResVo> findDeviceInfo(@RequestBody DeviceReqVo req){
// CheckerHelper.newInstance().notBlankCheck("id",req.getId()).checkException();
return deviceService.findDeviceInfo(req);
}
@RequestMapping(value = "/findDeviceInfoByCode", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "根据设备编号获取设备信息", notes = "返回设备信息")
public ResponseResult<DeviceResVo> findDeviceInfoByCode(@RequestBody DeviceReqVo req){
CheckerHelper.newInstance().notBlankCheck("deviceCode",req.getDeviceCode()).checkException();
return deviceService.findDeviceInfoByCode(req);
}
@RequestMapping(value = "/saveDevice", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "保存设备信息", notes = "返回保存结果")
public ResponseResult saveDevice(@RequestBody DeviceReqVo req){
// CheckerHelper.newInstance().notBlankCheck("id",req.getId()).checkException();
return deviceService.saveDevice(req);
}
@RequestMapping(value = "/updateDevice", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "修改设备信息", notes = "返回修改结果")
public ResponseResult updateDevice(@RequestBody DeviceReqVo req){
// CheckerHelper.newInstance().notBlankCheck("id",req.getId()).checkException();
return deviceService.updateDevice(req);
}
@RequestMapping(value = "/delDevice", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "删除设备信息", notes = "返回删除结果")
public ResponseResult delDevice(@RequestBody DeviceReqVo req){
// CheckerHelper.newInstance().notBlankCheck("id",req.getId()).checkException();
return deviceService.delDevice(req);
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.CompanyMoneyService;
import com.pangding.web.authority.service.FinanceService;
import com.pangding.web.authority.vo.reqvo.WithdrawalReqVo;
import com.pangding.web.authority.vo.resvo.WithdrawalResVo;
import com.pangding.web.util.DateUtil;
import com.pangding.web.vo.order.req.CapitalFlowReqVo;
import com.pangding.web.vo.order.req.back.CashWithdrawalBackReqVo;
import com.pangding.web.vo.order.res.CapitalFlowListResVo;
import com.pangding.web.vo.order.res.CapitalFlowResVo;
import com.pangding.web.vo.system.pd.company.CompanyMoneyVo;
import com.pangding.web.vo.system.req.company.CompanyMoneyReqVo;
import com.pangding.web.vo.system.res.company.CompanyMoneyTotalResVo;
import com.yanzuoguang.util.exception.CodeException;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.helper.DateHelper;
import com.yanzuoguang.util.helper.StringHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.util.Date;
import java.util.List;
import static com.yanzuoguang.util.helper.DateHelper.getCurDate;
/**
* @Author zhangjinyao
* @create 2019/6/18 19:53
*/
@RestController
@RequestMapping(value = "/finance", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "余额", description = "余额")
public class FinanceController {
@Autowired
private FinanceService financeService;
@Autowired
private CompanyMoneyService companyMoneyService;
/**
* 查询订单列表PageSizeData<CapitalFlowResVo>
*
* @param req
* @return
*/
@RequestMapping(value = "/findCapitalFlowList")
public ResponseResult<CapitalFlowListResVo> findCapitalFlowList(@RequestBody CapitalFlowReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
.checkException();
if ("10001".equals(req.getCompanyId())) {
req.setCompanyId("");
}
if (!StringHelper.isEmpty(req.getDateType()) && 1 == req.getDateType()) {
req.setStartPlayDate(req.getStartDate().substring(0, 10) + " 00:00:00");
req.setEndPlayDate(req.getEndDate().substring(0, 10) + " 23:59:59");
req.setStartDate("");
req.setEndDate("");
}
if (!StringHelper.isEmpty(req.getDateType()) && 0 == req.getDateType()) {
/*入参添加年月日*/
req.setStartOrderTime(req.getStartDate().substring(0, 10) + " 00:00:00");
req.setEndOrderTime(req.getEndDate().substring(0, 10) + " 23:59:59");
req.setStartDate("");
req.setEndDate("");
}
CapitalFlowListResVo capitalFlowListResVo = financeService.findCapitalFlowList(req);
return ResponseResult.result(capitalFlowListResVo);
}
/**
* 查询订单列表PageSizeData<CapitalFlowResVo>
*
* @param req
* @return
*/
@RequestMapping(value = "/findCapitalFlow")
public ResponseResult<CapitalFlowResVo> findCapitalFlow(@RequestBody CapitalFlowReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("id", req.getId())
.checkException();
if ("10001".equals(req.getCompanyId())) {
req.setCompanyId("");
}
CapitalFlowResVo capitalFlowResVo = financeService.findCapitalFlow(req);
return ResponseResult.result(capitalFlowResVo);
}
@RequestMapping(value = "/findCapitalFlowListGroup")
public ResponseResult<List<CapitalFlowResVo>> findCapitalFlowListGroup(@RequestBody CapitalFlowReqVo req) {
// CheckerHelper.newInstance()
// .notBlankCheck("companyId", req.getCompanyId())
// .checkException();
if (!StringHelper.isEmpty(req.getDateType()) && 1 == req.getDateType()) {
req.setStartPlayDate(req.getStartDate().substring(0, 10) + " 00:00:00");
req.setEndPlayDate(req.getEndDate().substring(0, 10) + " 23:59:59");
req.setStartDate("");
req.setEndDate("");
}
if (!StringHelper.isEmpty(req.getDateType()) && 0 == req.getDateType()) {
/*入参添加年月日*/
req.setStartOrderTime(req.getStartDate().substring(0, 10) + " 00:00:00");
req.setEndOrderTime(req.getEndDate().substring(0, 10) + " 23:59:59");
req.setStartDate("");
req.setEndDate("");
}
List<CapitalFlowResVo> list = financeService.findCapitalFlowListGroup(req);
return ResponseResult.result(list);
}
@PostMapping(value = "/withdrawal")
@ApiOperation(value = "公司余额查询", notes = "返回公司余额信息")
public ResponseResult<WithdrawalResVo> withdrawal(@RequestBody WithdrawalReqVo reqVo) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", reqVo.getCompanyId())
.checkException();
return ResponseResult.result(financeService.withdrawal(reqVo));
}
/**
* 提现申请
*
* @param req
* @return
*/
@RequestMapping(value = "/applyWithdrawal")
@ApiOperation(value = "提现申请", notes = "返回提现申请结果")
public ResponseResult<CapitalFlowReqVo> applyWithdrawal(@RequestBody CapitalFlowReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("companyName", req.getCompanyName())
.notBlankCheck("bankId", req.getBankId())
.notBlankCheck("bankCardCode", req.getBankCardCode())
.notBlankCheck("orderMoney", req.getOrderMoney())
// .notBlankCheck("createUserId", req.getCreateUserId())
// .notBlankCheck("createUserName", req.getCreateUserName())
.checkException();
return financeService.applyWithdrawal(req);
}
/**
* 提现回调
*/
@RequestMapping(value = "/withdrawalBack")
public ResponseResult<String> withdrawalBack(@RequestBody CashWithdrawalBackReqVo req) {
return financeService.withdrawalBack(req);
}
/**
* 转账
*
* @param req
* @return
*/
@RequestMapping(value = "/divideSettlment")
@ApiOperation(value = "转账", notes = "返回转账结果")
public ResponseResult<String> divideSettlment(@RequestBody CapitalFlowReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("companyName", req.getCompanyName())
.notBlankCheck("orderMoney", req.getOrderMoney())
.notBlankCheck("category", req.getCategory())
.notBlankCheck("actualMoney", req.getActualMoney())
.checkException();
return ResponseResult.result(financeService.divideSettlement(req));
}
@RequestMapping(value = "findCompanyMoneyList")
@ApiOperation(value = "找到公司资金汇总列表", notes = "返回公司资金汇总列表")
public ResponseResult<CompanyMoneyTotalResVo> findCompanyMoneyList(@RequestBody CompanyMoneyReqVo req) {
// CheckerHelper.newInstance()
// .notBlankCheck("companyId", req.getCompanyId())
// .notBlankCheck("startDate", req.getStartDate())
// .notBlankCheck("endDate", req.getEndDate())
// .checkException();
Date now = DateHelper.getDateTime(DateHelper.toDay(DateHelper.getDateTime(getCurDate())));
if (!StringHelper.isEmpty(req.getStartDate())) {
Date start = DateHelper.getDateTime(DateHelper.toDay(DateHelper.getDateTime(req.getStartDate())));
if (DateHelper.compare(start, now) == 0) {
req.setStartDate(DateUtil.getNextDateStr(req.getStartDate()));
}
}
if (!StringHelper.isEmpty(req.getEndDate())) {
Date end = DateHelper.getDateTime(DateHelper.toDay(DateHelper.getDateTime(req.getEndDate())));
if (DateHelper.compare(end, now) == 0) {
req.setEndDate(DateUtil.getBeforDateStr(req.getEndDate()));
}
}
return ResponseResult.result(companyMoneyService.findCompanyMoney(req));
}
@RequestMapping(value = "/findLastInfo")
@ApiOperation(value = "查询最后一条数据的finalMoney", notes = "查询最后一条数据的finalMoney")
public ResponseResult<CompanyMoneyVo> findLastInfo(@RequestBody CompanyMoneyReqVo req) {
return ResponseResult.result(companyMoneyService.findLastInfo(req));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.IndexService;
import com.pangding.web.authority.vo.reqvo.*;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/27 10:47
*/
@RestController
@RequestMapping(value="/index")
public class IndexController {
@Autowired
IndexService indexServiceImpl;
/**
* 通过公司id获取该公司的可提现余额
* @param reqVo 封装了公司id的请求对象
* @return 可提现的金额
*/
@PostMapping(value = "/withdrawCash", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<Double> withdrawCash(@RequestBody WithdrawCashReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getWithdrawCash(reqVo));
}
/**
* 通过公司id获取该公司累积总收益
* @param reqVo 封装了公司id的请求对象
* @return 累计总收益
*/
@PostMapping(value = "/totalIncome", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<BigDecimal> totalIncome(@RequestBody TotalIncomeReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getTotalIncome(reqVo));
}
/**
* 通过公司id获取该公司的用户沉淀量
* @param reqVo 封装了公司id的请求对象
* @return 用户沉淀量
*/
@PostMapping(value = "/userPrecipitation", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<Integer> userPrecipitation(@RequestBody UserPrecipitationReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getUserPrecipitation(reqVo));
}
/**
* 通过公司id获取该公司今日实收金额
* @param reqVo 封装了公司id的请求对象
* @return 今日实收金额
*/
@PostMapping(value = "/todayIncome", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult todayIncome(@RequestBody TodayIncomeReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getTodayIncome(reqVo));
}
/**
* 通过公司id获取该公司的跨界盈利
* @param reqVo 封装了公司id的请求对象
* @return 跨界盈利
*/
@PostMapping(value = "/transboundaryProfit", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult transboundaryProfit(@RequestBody TransboundaryProfitReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getTransboundaryProfit(reqVo));
}
/**
* 通过公司id获取该公司的用户趋势
* @param reqVo 封装了公司id的请求对象
* @return 用户趋势
*/
@PostMapping(value = "/userTrending", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<List<Long>> userTrending(@RequestBody UserTrendingReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getUserTrending(reqVo));
}
/**
* 通过公司id获取该公司的资金趋势
* @param reqVo 封装了公司id的请求对象
* @return 资金趋势
*/
@PostMapping(value = "/fundTrending", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult fundTrending(@RequestBody FundTrendingReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.checkException();
return ResponseResult.result(indexServiceImpl.getFundTrending(reqVo));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.RegisterService;
import com.pangding.web.authority.service.VerifyCodeService;
import com.pangding.web.authority.vo.code.CodeService;
import com.pangding.web.authority.vo.code.CodeVo;
import com.pangding.web.vo.system.req.LoginReqVo;
import com.pangding.web.vo.system.res.LoginResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.io.IOException;
/**
* @Author zhangjinyao
* @create 2019/5/23 10:49
*/
@RestController
@RequestMapping(value="login")
@Api(value = "用户登录类")
public class LoginController {
@Autowired
RegisterService registerServiceImpl;
@Autowired
VerifyCodeService verifyCodeServiceImpl;
@Autowired
CodeService codeService;
/**
* 登陆,验证用户名或手机号,密码是否正确
* 返回token,account,LoginCompanyResVo对象(id:公司id,status:公司状态,companyAttribute:属性,bankCardCodeList:绑定的银行卡数组)
*
* @param reqVo
* @return
*/
@ApiOperation(value ="登录", notes = "返回登录信息")
@RequestMapping(value = "/login", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<LoginResVo> mobile(@RequestBody LoginReqVo reqVo) throws Exception {
CheckerHelper.newInstance()
.notBlankCheck("account or phone",reqVo.getAccountOrPhone())
.notBlankCheck("password",reqVo.getPassword())
.notBlankCheck("loginType", reqVo.getLoginType())
.checkException();
return ResponseResult.result(registerServiceImpl.login(reqVo));
}
/*@RequestMapping(value = "/computer", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<LoginResVo> computer(@RequestBody ComputerLoginReqVo reqVo, HttpSession session,HttpServletRequest request){
CheckerHelper.newInstance()
.notBlankCheck("account or phone",reqVo.getAccountOrPhone())
.notBlankCheck("password",reqVo.getPassword())
.notBlankCheck("verifyCode",reqVo.getVerifyCode())
.checkException();
return ResponseResult.result(registerServiceImpl.verifyLogin(reqVo,session,request));
}
*//**
* 获取验证码图片
*
* @param request
* @param response
* @throws IOException
*//*
@RequestMapping(value="/getImage",method= RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult getImage(HttpServletRequest request, HttpServletResponse response) throws IOException {
verifyCodeServiceImpl.getImage(request,response);
return new ResponseResult();
}*/
/**
* 获取验证码
*
* @return 登录结果
*/
@GetMapping(value = "/getCode", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "获取验证码", notes = "获取验证码")
public ResponseResult<CodeVo> getCode() {
return ResponseResult.result(codeService.getCode());
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.authority.service.RegisterService;
import com.pangding.web.authority.vo.resvo.SaveCompanyResVo;
import com.pangding.web.vo.system.pd.company.CompanyVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
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;
/**
* @Author zhangjinyao
* @create 2019/5/13 11:26
*/
@RestController
@RequestMapping(value="/mobileRegister")
public class MobileRegisterController {
@Autowired
RegisterService registerServiceImpl;
/**
* 验证注册第一页数据的合法性并保存在pd_user表中
* 生成公司id,pd_company表中存入一条数据
* 返回公司部分信息(id,invitationCompanyId,companyType),携带到基本信息页面
*
* @param registerUserReqVo
* @return
*/
@RequestMapping(value = "/user", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyVo> saveUser(@RequestBody RegisterUserReqVo registerUserReqVo) throws Exception {
CheckerHelper.newInstance()
.notBlankCheck("account",registerUserReqVo.getAccount())
.notBlankCheck("password",registerUserReqVo.getPassword())
.notBlankCheck("confirmPassword",registerUserReqVo.getConfirmPassword())
.notBlankCheck("companyType",registerUserReqVo.getCompanyType())
.notBlankCheck("invitationCode",registerUserReqVo.getInvitationCode())
.checkException();
return ResponseResult.result(registerServiceImpl.saveUser(registerUserReqVo));
}
/**
* 当用户类型选择为“个体”时进入此方法
* 验证注册第二页数据的合法性并保存,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant都增加一条数据
* 并将联系电话更新到pd_user表中
* 返回pd_user,pd_company,pd_company_bank_card,pd_company_extend,pd_merchant表的主键
*
* @param reqVo
* @return
*/
@RequestMapping(value="/individual", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<SaveCompanyResVo> saveIndividual(@RequestBody RegisterIndividualReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("contactName",reqVo.getContactName())
.notBlankCheck("contactCode",reqVo.getContactCode())
.checkIdCard("contactCode",reqVo.getContactCode())
.notBlankCheck("companyAttribute",reqVo.getCompanyAttribute())
.notBlankCheck("companyName",reqVo.getCompanyName())
.notBlankCheck("contactPhone",reqVo.getContactPhone())
.checkPhoneNo("contactPhone",reqVo.getContactPhone())
.checkException();
return ResponseResult.result(registerServiceImpl.saveIndividual(reqVo));
}
@RequestMapping(value="/individualSubmit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> individualSubmit(@RequestBody IndividualSubmitReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getId())
.notBlankCheck("verifyCode",reqVo.getVerifyCode())
.checkException();
String verifyCode = registerServiceImpl.individualSubmit(reqVo);
return ResponseResult.result(verifyCode);
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.PangdingPartnerService;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.authority.vo.resvo.*;
import com.pangding.web.vo.system.pd.company.CompanyBankCardVo;
import com.pangding.web.vo.system.pd.company.CompanyCodeVo;
import com.pangding.web.vo.system.req.company.CompanyBankCardReqVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/6/19 15:26
*/
@RestController
@RequestMapping(value = "/partner")
public class PangdingPartnerController {
@Autowired
PangdingPartnerService pangdingPartnerServiceImpl;
/**
* 胖丁伙伴首页
* @param reqVo 封装了公司id的请求对象
* @return
*/
@PostMapping(value = "/home",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<HomeResVo> home(@RequestBody HomeReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.home(reqVo));
}
/**
* 通过公司id获取该公司的可提现余额以及默认提现银行卡
* @param reqVo 封装了公司id的请求对象
* @return
*/
@PostMapping(value = "/withdrawal",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<MobileWithdrawalResVo> withdrawal(@RequestBody MobileWithdrawalReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.notBlankCheck("withdrawTotalCash",reqVo.getWithdrawTotalCash())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.withdrawal(reqVo));
}
/**
* 通过公司id获取该公司银行卡列表(不分页)
* @param reqVo 封装了公司id的请求对象
* @return
*/
@PostMapping(value = "/bankCardList",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<List<CompanyBankCardVo>> bankCardList(@RequestBody MobileBankCardListReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.bankCardList(reqVo));
}
/**
* 保存/更新银行卡信息,并调用第三方接口发送手机验证码
* @param reqVo 公司银行卡表信息
* @return 银行卡表主键
*/
@PostMapping(value = "/saveBank",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyBankCardVo> saveBank(@RequestBody CompanyBankCardReqVo reqVo){
checkBank(reqVo);
return pangdingPartnerServiceImpl.saveBank(reqVo);
}
private void checkBank(CompanyBankCardReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("bankCardCode",reqVo.getBankCardCode())
.notNumberCheck("bankCardCode",reqVo.getBankCardCode())
.notBlankCheck("bankName",reqVo.getBankName())
.notBlankCheck("name",reqVo.getName())
.notBlankCheck("idCard",reqVo.getIdCard())
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkIdCard("idCard",reqVo.getIdCard())
.notBlankCheck("phone",reqVo.getPhone())
.checkPhoneNo("phone",reqVo.getPhone())
.checkException();
}
/**
* 提交银行卡信息,验证手机验证码,并更新银行卡状态
* @param reqVo 银行卡表数据+验证码
* @return 目前返回验证码
*/
@PostMapping(value = "/bankSubmit",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyBankCardVo> bankSubmit(@RequestBody BankSubmitReqVo reqVo) {
CheckerHelper.newInstance()
.notBlankCheck("bankCardId", reqVo.getId())
.notBlankCheck("verifyCode", reqVo.getVerifyCode())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.bankSubmit(reqVo));
}
/**
* 调用支付服务解绑银行卡,并更新银行卡状态
* @param reqVo 封装了银行卡id的请求对象
* @return
*/
@PostMapping(value = "/deleteBank",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult deleteBank(@RequestBody CompanyBankCardVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyBankCardId",reqVo.getId())
.checkException();
pangdingPartnerServiceImpl.deleteBank(reqVo);
return new ResponseResult();
}
/**
* 设置该银行卡为默认支付,并取消其他银行卡的默认
* @param reqVo 封装了银行卡id的请求对象
* @return
*/
@PostMapping(value = "setDefault",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult setDefault(@RequestBody CompanyBankCardVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("bankCardId",reqVo.getId())
.checkException();
pangdingPartnerServiceImpl.setDefault(reqVo);
return new ResponseResult();
}
/**
* 我的管理页面:通过userId获取用户表,公司表,公司银行卡表数据
* @param reqVo 封装了userId的请求对象
* @return
*/
@PostMapping(value = "/management",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<ManagementResVo> management(@RequestBody ManagementReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("userId",reqVo.getUserId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.management(reqVo));
}
/**
* 根据公司id获取该公司今日用户沉淀量,总沉淀量,沉淀用户列表
* @param reqVo 封装了公司id的请求对象
* @return
*/
@PostMapping(value = "/precipitation",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<PrecipitationResVo> precipitation(@RequestBody PrecipitationReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.precipitation(reqVo));
}
/**
* 根据公司id返回该公司二维码url,若没有则创建
* @param reqVo 封装了公司id和选项(限制为永久)的请求对象
* @return
*/
@PostMapping(value = "/qrCodeUrl",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyCodeVo> qrCodeUrl(@RequestBody GenerateQrCodeUrlReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.notBlankCheck("select",reqVo.getSelect())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.qrCodeUrl(reqVo));
}
/**
* 根据公司id获取该公司的邀请码,若没有则创建
* @param reqVo 封装了公司id的请求对象
* @return
*/
@PostMapping(value = "/invitation",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> invitation(@RequestBody InvitationReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.invitation(reqVo));
}
/**
* 邀请商家列表
* @param reqVo
* @return
*/
@PostMapping(value = "/inviteMembers",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<InviteMembersResVo> inviteMembers(@RequestBody InviteMembersReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("invitationCompanyId",reqVo.getInvitationCompanyId())
.checkException();
return ResponseResult.result(pangdingPartnerServiceImpl.inviteMembers(reqVo));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.vo.reqvo.AddReqVo;
import com.pangding.web.authority.vo.reqvo.CountByRoleReqVo;
import com.pangding.web.authority.vo.reqvo.ListRoleReqVo;
import com.pangding.web.authority.vo.reqvo.WebRoleReqVo;
import com.pangding.web.authority.service.RoleService;
import com.pangding.web.authority.vo.resvo.WebRoleResVo;
import com.pangding.web.vo.system.res.authority.RoleResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @author zhangjinyao
*/
@RestController
@RequestMapping("/roles")
public class RoleController {
@Autowired
private RoleService roleService;
@RequestMapping(value = "/queryList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<PageSizeData<RoleResVo>> queryList(@RequestBody ListRoleReqVo req){
CheckerHelper.newInstance()
.notBlankCheck("companyId",req.getCompanyId())
.checkException();
return ResponseResult.result(roleService.queryList(req));
}
/**
* 新增角色
* 返回角色id
* @param webRoleReqVo
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> saveRole(@RequestBody WebRoleReqVo webRoleReqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleName",webRoleReqVo.getName())
.notBlankCheck("remark",webRoleReqVo.getRemark())
.notBlankCheck("companyId",webRoleReqVo.getCompanyId())
.checkException();
return ResponseResult.result(roleService.saveRole(webRoleReqVo));
}
/**
* 修改角色信息
* 返回角色id
* @param webRoleReqVo
* @return
*/
@RequestMapping(value = "/update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> updateRole(@RequestBody WebRoleReqVo webRoleReqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleName",webRoleReqVo.getName())
.notBlankCheck("remark",webRoleReqVo.getRemark())
.checkException();
return ResponseResult.result(roleService.updateRole(webRoleReqVo));
}
/**
* 查询角色列表
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<PageSizeData<WebRoleResVo>> listRoles(@RequestBody ListRoleReqVo req){
CheckerHelper.newInstance()
.notBlankCheck("companyId",req.getCompanyId())
.checkException();
return ResponseResult.result(roleService.getWebRoleResVoList(req));
}
/**
* 获取该公司该角色已分配的角色列表
* @param reqVo 封装了公司id和权限id的请求对象
* @return 用户列表
*/
@RequestMapping(value = "/countByRole", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult countByRole(@RequestBody CountByRoleReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleId",reqVo.getRoleId())
.notBlankCheck("companyId",reqVo.getCompanyId())
.checkException();
return ResponseResult.result(roleService.countByRole(reqVo));
}
/**
* 根据ID查询角色
* @param
* @return
*/
@RequestMapping(value = "/role", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<WebRoleResVo> getRoleById(@RequestBody WebRoleReqVo webRoleReqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleId",webRoleReqVo.getId())
.checkException();
return ResponseResult.result(roleService.getRoleById(webRoleReqVo));
}
/**
* 删除角色
* @param
* @return
*/
@RequestMapping(value = "/delete", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult delete(@RequestBody WebRoleReqVo webRoleReqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleId",webRoleReqVo.getId())
.checkException();
roleService.delete(webRoleReqVo);
return new ResponseResult();
}
/**
* 给指定角色添加权限
* @param reqVo
* @return
*/
@RequestMapping(value = "/add",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult add(@RequestBody AddReqVo reqVo){
CheckerHelper.newInstance()
.notBlankCheck("roleId",reqVo.getRoleId())
.notBlankCheck("authorityId",reqVo.getAuthorityId())
.checkException();
roleService.add(reqVo);
return new ResponseResult();
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.service.TokenService;
import com.pangding.web.vo.system.pd.LoginTokenVo;
import com.pangding.web.vo.system.req.LoginReqVo;
import com.pangding.web.vo.system.req.company.CompanyKeyReqVo;
import com.pangding.web.vo.system.res.company.CompanyKeyResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.ResponseResult;
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;
/**
* 日志操作控制类
*
* @author tf
*/
@RestController
@RequestMapping("/token")
public class TokenController {
@Autowired
private TokenService tokenService;
/**
* 获取分销商key
*/
@RequestMapping(value = "/getCompanyKey", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<CompanyKeyResVo> getCompanyKey(@RequestBody CompanyKeyReqVo companyKeyReqVo) {
CheckerHelper.newInstance()
.notBlankCheck("companyId", companyKeyReqVo.getCompanyId())
.checkException(companyKeyReqVo);
return ResponseResult.result(tokenService.getCompanyKey(companyKeyReqVo));
}
/**
* 登录实体创建
*
* @param loginVo
*/
@RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> save(@RequestBody LoginReqVo loginVo) {
CheckerHelper.newInstance()
.notBlankCheck("token", loginVo.getToken())
.notBlankCheck("data", loginVo.getData())
.notBlankCheck("expairTime", loginVo.getExpairTime())
.checkDate("expairTime", loginVo.getExpairTime())
.checkException(loginVo);
return ResponseResult.result(tokenService.save(loginVo));
}
/**
* 加载登录信息
*
* @param loginVo 登录信息
*/
@RequestMapping(value = "/load", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<LoginTokenVo> load(@RequestBody LoginReqVo loginVo) {
CheckerHelper.newInstance()
.notBlankCheck("token", loginVo.getToken())
.checkException(loginVo);
return ResponseResult.result(tokenService.load(loginVo));
}
/**
* 加载登录信息
*
* @param loginVo 登录信息
*/
@RequestMapping(value = "/remove", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<Integer> remove(@RequestBody LoginReqVo loginVo) {
CheckerHelper.newInstance()
.notBlankCheck("token", loginVo.getToken())
.checkException(loginVo);
return ResponseResult.result(tokenService.remove(loginVo));
}
}
package com.pangding.web.authority.controller;
import com.pangding.web.authority.util.RsaConstant;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.authority.service.UserService;
import com.pangding.web.authority.vo.resvo.WebUserResVo;
import com.pangding.web.util.RSAUtils;
import com.pangding.web.vo.system.pd.authority.UserVo;
import com.pangding.web.vo.system.req.authority.SaveUserReqVo;
import com.pangding.web.vo.system.req.authority.UserReqVo;
import com.pangding.web.vo.system.req.authority.V2.QueryUserReqVo;
import com.yanzuoguang.util.exception.CodeException;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.helper.StringHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
/**
* @author zhangjinyao
*/
@RestController
@RequestMapping(value = "/user")
@Api(value = "用户相关类", description = "用户新增,修改,删除等相关操作")
public class UserController {
@Autowired
UserService userServiceImpl;
/**
* 新增用户
* 返回用户id
*
* @param webUserReqVo
* @return
*/
@RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> saveUser(@RequestBody WebUserReqVo webUserReqVo) throws Exception {
CheckerHelper.newInstance()
.notBlankCheck("account", webUserReqVo.getAccount())
.notBlankCheck("password", webUserReqVo.getPassword())
.notBlankCheck("confirmPassword", webUserReqVo.getConfirmPassword())
.checkPhoneNo("phone", webUserReqVo.getPhone())
.notBlankCheck("companyId", webUserReqVo.getCompanyId())
.notBlankCheck("email", webUserReqVo.getEmail())
.checkException();
return ResponseResult.result(userServiceImpl.saveUser(webUserReqVo));
}
/**
* 修改用户信息
* 返回用户id
*
* @param
* @return
*/
@RequestMapping(value = "/update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> updateUser(@RequestBody WebUserReqVo webUserReqVo) {
try {
if (!StringHelper.isEmpty(webUserReqVo.getUpdateType()) && 1 == webUserReqVo.getUpdateType()) {
// 修改密码
CheckerHelper.newInstance()
.notBlankCheck("id", webUserReqVo.getId())
.notBlankCheck("password", webUserReqVo.getPassword())
.notBlankCheck("confirmPassword", webUserReqVo.getConfirmPassword())
.notBlankCheck("verifyCode", webUserReqVo.getVerifyCode())
.checkException();
String password = RSAUtils.decryptionByPrivateKey(webUserReqVo.getPassword(), RsaConstant.privateKey);
String confirmPassword = RSAUtils.decryptionByPrivateKey(webUserReqVo.getConfirmPassword(), RsaConstant.privateKey);
if (!StringHelper.compare(password, confirmPassword)) {
throw new CodeException("两次密码输入不一致");
}
webUserReqVo.setPassword(password);
webUserReqVo.setConfirmPassword(confirmPassword);
} else {
CheckerHelper.newInstance()
.notBlankCheck("account", webUserReqVo.getAccount())
.notBlankCheck("password", webUserReqVo.getPassword())
.checkPhoneNo("phone", webUserReqVo.getPhone())
.notBlankCheck("companyId", webUserReqVo.getCompanyId())
.checkException();
}
return ResponseResult.result(userServiceImpl.updateUser(webUserReqVo));
} catch (Exception e) {
return (ResponseResult) ResponseResult.error("99", e.getMessage());
}
}
/**
* 查询用户列表
*
* @return
*/
@RequestMapping(value = "/list", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<PageSizeData<WebUserResVo>> listUsers(@RequestBody QueryUserReqVo reqVo) {
return ResponseResult.result(userServiceImpl.getWebUserResVoList(reqVo));
}
/**
* 查询公司用户列表(新)
*
* @return
*/
@RequestMapping(value = "/userList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询用户列表", notes = "返回用户列表信息.")
public ResponseResult<PageSizeData<UserVo>> userList(@RequestBody QueryUserReqVo reqVo) {
return ResponseResult.result(userServiceImpl.getUserVoList(reqVo));
}
@RequestMapping(value = "/updateUserInfo", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "只修改用户信息", notes = "返回修改结果.")
public ResponseResult updateUserInfo(@RequestBody UserReqVo req) {
CheckerHelper.newInstance().notBlankCheck("id", req.getId()).checkException();
return ResponseResult.result(userServiceImpl.updateUserInfo(req));
}
/**
* 根据ID查询用户
*
* @param //id
* @return
*/
@RequestMapping(value = "/user", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<WebUserResVo> user(@RequestBody WebUserReqVo webUserReqVo) {
CheckerHelper.newInstance()
.notBlankCheck("userId", webUserReqVo.getId())
.checkException();
return ResponseResult.result(userServiceImpl.getUserById(webUserReqVo.getId()));
}
/**
* 注册用户(新)
*
* @param //id
* @return
*/
@ApiOperation(value = "注册", notes = "返回注册信息")
@RequestMapping(value = "/registerUser", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> registerUser(@RequestBody SaveUserReqVo saveUserReqVo) {
CheckerHelper.newInstance()
.notBlankCheck("account", saveUserReqVo.getAccount())
.notBlankCheck("password", saveUserReqVo.getPassword())
.notBlankCheck("confirmPassword", saveUserReqVo.getConfirmPassword())
.notBlankCheck("companyType", saveUserReqVo.getCompanyType())
.notBlankCheck("invitationCode", saveUserReqVo.getInvitationCode())
.checkException();
return userServiceImpl.registerSaveUser(saveUserReqVo);
}
/**
* 分销客户端 注册用户(新)
*
* @param //id
* @return
*/
@ApiOperation(value = "注册", notes = "返回注册信息")
@RequestMapping(value = "/registerUserByDistribution", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> registerUserByDistribution(@RequestBody SaveUserReqVo saveUserReqVo) {
CheckerHelper.newInstance()
.notBlankCheck("registerFrom", saveUserReqVo.getRegisterFrom())
.notBlankCheck("account", saveUserReqVo.getAccount())
.notBlankCheck("password", saveUserReqVo.getPassword())
.notBlankCheck("confirmPassword", saveUserReqVo.getConfirmPassword())
.notBlankCheck("companyType", saveUserReqVo.getCompanyType())
.checkException();
return userServiceImpl.registerSaveUser(saveUserReqVo);
}
/**
* 发送短信验证码
*/
@ApiOperation(value = "发送短信验证码", notes = "发送短信验证码")
@RequestMapping(value = "/sendCode", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult<String> sendCode(@RequestBody SaveUserReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("phone", req.getPhone())
.checkException();
return ResponseResult.result(userServiceImpl.verifyCodeSend(req));
}
}
package com.pangding.web.authority.controller.code;
import com.pangding.web.authority.service.code.CodeModelService;
import com.pangding.web.vo.system.pd.code.CodeModelVo;
import com.pangding.web.vo.system.req.code.CodeModelReqVo;
import com.pangding.web.vo.system.res.code.CodeModelResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiModelProperty;
import io.swagger.annotations.ApiOperation;
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;
import java.util.List;
@RestController
@RequestMapping(value = "/codeModel", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "码模本相关类", description = "码模本新增、修改、删除等操作")
public class CodeModelController {
@Autowired
private CodeModelService codeModelService;
@RequestMapping(value = "/queryCodeModelPageList")
@ApiOperation(value = "分页查询码模板列表", notes = "根据页码返回码模板列表")
public ResponseResult<PageSizeData<CodeModelResVo>> queryCodeModelPageList(@RequestBody CodeModelReqVo req) {
return ResponseResult.result(codeModelService.queryCodeModelPageList(req));
}
@RequestMapping(value = "/queryCodeModelList")
@ApiModelProperty(value = "查询码模板列表", notes = "返回所有码模板")
public ResponseResult<List<CodeModelResVo>> queryCodeModelList(@RequestBody CodeModelReqVo req) {
return ResponseResult.result(codeModelService.queryCodeModelList(req));
}
@RequestMapping(value = "/queryList")
@ApiModelProperty(value = "查询码模板列表包含扩展信息", notes = "返回所有码模板列表包含扩展信息")
public ResponseResult<List<CodeModelResVo>> queryList(@RequestBody CodeModelReqVo req) {
return ResponseResult.result(codeModelService.queryList(req));
}
@RequestMapping(value = "/queryCodeModel")
@ApiModelProperty(value = "查询码模板详情", notes = "返回码模板详细信息")
public ResponseResult<CodeModelResVo> queryCodeModel(@RequestBody CodeModelReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("codeModelId", req.getCodeModelId())
.checkException();
return ResponseResult.result(codeModelService.queryCodeModel(req));
}
@RequestMapping(value = "/saveCodeModel")
@ApiModelProperty(value = "保存或者修改码模板", notes = "返回码模板保存信息")
public ResponseResult<CodeModelVo> saveCodeModel(@RequestBody CodeModelReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("codeType", req.getCodeType())
.notBlankCheck("codeModelName", req.getCodeModelName())
.notBlankCheck("codeModelLink", req.getCodeModelLink())
// .notBlankCheck("codeModelImgUrl", req.getCodeModelImgUrl())
.checkException();
return ResponseResult.result(codeModelService.saveCodeModel(req));
}
@RequestMapping(value = "/removeCodeModel")
@ApiModelProperty(value = "删除码模板", notes = "返回码模板删除信息")
public ResponseResult<CodeModelVo> removeCodeModel(@RequestBody CodeModelReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("codeModelId", req.getCodeModelId())
.checkException();
codeModelService.removeCodeModel(req);
return ResponseResult.resultAllowNull(null);
}
}
package com.pangding.web.authority.controller.company;
import com.pangding.web.authority.service.CompanyAgreementService;
import com.pangding.web.authority.service.CompanyService;
import com.pangding.web.authority.service.company.NewCompanyService;
import com.pangding.web.vo.system.pd.company.CompanyAgreementVo;
import com.pangding.web.vo.system.pd.company.CompanyVo;
import com.pangding.web.vo.system.req.company.CompanyAgreementReqVo;
import com.pangding.web.vo.system.req.company.CompanyReqVo;
import com.pangding.web.vo.system.req.company.SaveCompanyReqVo;
import com.pangding.web.vo.system.res.company.CompanyPageResVo;
import com.pangding.web.vo.system.res.company.CompanyResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping(value = "/newCompany", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class CompanyController {
@Autowired
private NewCompanyService newCompanyService;
@Autowired
private CompanyService companyService;
@Autowired
private CompanyAgreementService companyAgreementService;
@RequestMapping(value = "/findCompanyListPage", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "分页查询公司列表", notes = "返回公司列表,按页数")
public ResponseResult<CompanyPageResVo> findCompanyListPage(@RequestBody CompanyReqVo req) {
return ResponseResult.result(newCompanyService.findCompanyListPage(req));
}
@RequestMapping(value = "/findCompanyList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询公司列表", notes = "返回所有的公司列表")
public ResponseResult<List<CompanyResVo>> findCompanyList(@RequestBody CompanyReqVo req) {
return ResponseResult.result(newCompanyService.findCompanyList(req));
}
@RequestMapping(value = "/findCompany", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询公司信息", notes = "返回公司详细信息")
public ResponseResult<CompanyResVo> findCompany(@RequestBody CompanyReqVo req) {
return ResponseResult.result(newCompanyService.findCompany(req));
}
@RequestMapping(value = "/updateCompanyInfo", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "公司,个人实名制", notes = "返回实名制结果")
public ResponseResult<SaveCompanyReqVo> updateCompanyInfo(@RequestBody SaveCompanyReqVo req) {
CheckerHelper.newInstance().notBlankCheck("id", req.getCompanyVo().getId()).checkException();
return companyService.updateCompanyInfo(req);
}
// @RequestMapping(value = "/examineCompany", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
// @ApiOperation(value = "审核配置公司信息", notes = "返回审核配置的结果")
// public ResponseResult<SaveCompanyReqVo> examineCompany(@RequestBody SaveCompanyReqVo req) {
// CheckerHelper.newInstance().notBlankCheck("id", req.getCompanyVo().getId()).checkException();
// return companyService.updateCompanyInfo(req);
// }
// @RequestMapping(value = "/examineCompany", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
// @ApiOperation(value = "审核配置公司信息", notes = "返回审核配置的结果")
// public ResponseResult<SaveCompanyReqVo> examineCompany(@RequestBody SaveCompanyReqVo req) {
// CheckerHelper.newInstance().notBlankCheck("id", req.getCompanyVo().getId()).checkException();
// return companyService.updateCompanyInfo(req);
// }
/**
* 找到公司余额
*
* @param req
* @return
*/
@RequestMapping(value = "/findCompanyBalance", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public ResponseResult findCompanyBalance(@RequestBody CompanyReqVo req) {
CheckerHelper.newInstance().notBlankCheck("id", req.getId()).checkException();
return ResponseResult.result(companyService.findCompanyBalance(req));
}
@RequestMapping(value = "/findCompanyAgreement")
@ApiOperation(value = "查询某合同详情", notes = "返回合同信息")
public ResponseResult<CompanyAgreementVo> findCompanyAgreement(@RequestBody CompanyAgreementReqVo req) {
CheckerHelper.newInstance()
// .notBlankCheck("companyId", req.getCompanyId())
// .notBlankCheck("agreementId", req.getAgreementId())
.notBlankCheck("companyAgreementId", req.getCompanyAgreementId())
.checkException();
return ResponseResult.result(companyAgreementService.findCompanyAgreement(req));
}
@RequestMapping(value = "/findCompanyAgreementList")
@ApiOperation(value = "查询公司签署的合同列表", notes = "返回合同信息")
public ResponseResult<PageSizeData<CompanyAgreementVo>> findCompanyAgreementList(@RequestBody CompanyAgreementReqVo req) {
CheckerHelper.newInstance().notBlankCheck("companyId", req.getCompanyId())
.checkException();
return ResponseResult.result(companyAgreementService.findCompanyAgreementList(req));
}
@RequestMapping(value = "saveComapnyAgreement")
@ApiOperation(value = "公司签署合同", notes = "返回签署结果")
public ResponseResult saveCompanyAgreement(@RequestBody CompanyAgreementReqVo req){
CheckerHelper.newInstance().notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("agreementId", req.getAgreementId())
.notBlankCheck("agreementCode", req.getAgreementCode())
.checkException();
return ResponseResult.result(companyAgreementService.saveCompanyAgreement(req));
}
@RequestMapping(value = "findCompanyById")
@ApiOperation(value = "找到公司信息", notes = "找到公司信息")
public ResponseResult<CompanyResVo> findCompanyById(@RequestBody CompanyReqVo req){
CheckerHelper.newInstance().notBlankCheck("id", req.getId()).checkException();
return ResponseResult.result(companyService.findCompanyById(req));
}
@RequestMapping(value = "synCompany")
@ApiOperation(value = "找到公司信息", notes = "找到公司信息")
public ResponseResult<String> synCompany(@RequestBody CompanyReqVo req){
return companyService.synCompanyInfo(req);
}
@RequestMapping(value = "findInvitationReward")
@ApiOperation(value = "找到公司邀请奖励信息", notes = "找到公司邀请奖励信息")
public ResponseResult<CompanyResVo> findInvitationReward(@RequestBody CompanyReqVo req){
CheckerHelper.newInstance().notBlankCheck("id", req.getId()).checkException();
return ResponseResult.result(companyService.findCompanyInvitationReward(req));
}
@RequestMapping(value = "/findAllCompany")
@ApiOperation(value = "查询所有公司", notes = "查询所有公司")
public ResponseResult<List<CompanyVo>> findAllCompany(@RequestBody CompanyReqVo req){
CheckerHelper.newInstance()
.checkException();
return ResponseResult.result(companyService.findAllCompany(req));
}
}
package com.pangding.web.authority.controller.company;
import com.pangding.web.authority.service.company.CompanyTollPointService;
import com.pangding.web.vo.system.pd.company.CompanyTollPointVo;
import com.pangding.web.vo.system.req.company.CompanyTollPointReqVo;
import com.pangding.web.vo.system.res.company.CompanyTollPointResVo;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.vo.PageSizeData;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
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;
import java.util.List;
@RestController
@RequestMapping(value = "/companyTollPoint", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(value = "公司收费点相关类", description = "收费点新增、修改、删除等操作")
public class CompanyTollPointController {
private CompanyTollPointService companyTollPointService;
public CompanyTollPointController(CompanyTollPointService companyTollPointService) {
this.companyTollPointService = companyTollPointService;
}
@RequestMapping(value = "/queryPageList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询收费点列表", notes = "返回公司收费点列表信息")
public ResponseResult<PageSizeData<CompanyTollPointResVo>> queryPageList(@RequestBody CompanyTollPointReqVo req) {
return ResponseResult.result(companyTollPointService.queryPageList(req));
}
@RequestMapping(value = "/queryList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询收费点列表", notes = "返回公司收费点列表信息")
public ResponseResult<List<CompanyTollPointVo>> queryList(@RequestBody CompanyTollPointReqVo req) {
return ResponseResult.result(companyTollPointService.queryList(req));
}
@RequestMapping(value = "/save", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "保存公司收费点", notes = "返回公司收费点信息")
public ResponseResult<CompanyTollPointVo> save(@RequestBody CompanyTollPointReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("tollPoints", req.getTollPoints())
.notBlankCheck("companyId", req.getCompanyId())
.notBlankCheck("tollPointsName", req.getTollPointsName())
// .notBlankCheck("tollPointsModel", req.getTollPointsModel())
.checkException();
return ResponseResult.result(companyTollPointService.save(req));
}
@RequestMapping(value = "/queryCompanyTollPoint", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "查询公司收费点详情", notes = "返回公司收费点详情")
public ResponseResult<CompanyTollPointVo> queryCompanyTollPoint(@RequestBody CompanyTollPointReqVo req) {
return ResponseResult.result(companyTollPointService.queryCompanyTollPoint(req));
}
@RequestMapping(value = "/delCompanyTollPoint", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ApiOperation(value = "删除公司收费点", notes = "返回删除结果")
public ResponseResult<String> delCompanyTollPoint(@RequestBody CompanyTollPointReqVo req) {
CheckerHelper.newInstance()
.notBlankCheck("companyPointId", req.getCompanyPointId())
.checkException();
companyTollPointService.delCompanyTollPoint(req);
return ResponseResult.result("处理完成");
}
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
public interface AgreementTemplateDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.vo.system.pd.authority.AuthorityVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
/**
* @author zhangjinyao
*/
public interface AuthorityDao extends BaseDao {
/**
* 检查新建或修改的authorityVo对象是否合法
*
* @param authorityVo authorityVo对象
*/
void checkValid(AuthorityVo authorityVo);
/**
* 获取权限分页对象
*
* @param reqVo
* @return 权限分页对象
*/
PageSizeData<AuthorityVo> getAuthorityList(ListAuthorityByPageReqVo reqVo);
List<AuthorityVo> getLevelOne(AuthorityListReqVo reqVo);
List<AuthorityVo> after(AuthorityAfterReqVo afterReqVo);
List<AuthorityVo> listBySort(AuthorityGetReqVo reqVo);
List<AuthorityVo> getLessBetween(AuthorityBetweenSortReqVo reqVo);
List<AuthorityVo> getMoreBetween(AuthorityBetweenSortReqVo reqVo);
}
package com.pangding.web.authority.dao;
import com.pangding.web.vo.order.req.CapitalFlowReqVo;
import com.pangding.web.vo.order.res.CapitalFlowResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
public interface CapitalFlowDao extends BaseDao {
PageSizeData<CapitalFlowResVo> findCapitalFlowList(CapitalFlowReqVo req);
CapitalFlowResVo findCapitalFlowTotal(CapitalFlowReqVo req);
List<CapitalFlowResVo> findCapitalFlowTotalList(CapitalFlowReqVo req);
}
package com.pangding.web.authority.dao;
import com.pangding.web.vo.system.pd.company.CompanyAgreementVo;
import com.pangding.web.vo.system.req.company.CompanyAgreementReqVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
public interface CompanyAgreementDao extends BaseDao {
PageSizeData<CompanyAgreementVo> findCompanyAgreement(CompanyAgreementReqVo reqVo);
}
package com.pangding.web.authority.dao;
import com.pangding.web.vo.system.req.company.CompanyCodeReqVo;
import com.pangding.web.vo.system.res.company.CompanyCodeResVo;
import com.yanzuoguang.dao.BaseDao;
import java.util.List;
public interface CompanyCodeDao extends BaseDao {
List<CompanyCodeResVo> findCodeList(CompanyCodeReqVo req);
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.resvo.GetCompanyDivideResVo;
import com.pangding.web.vo.system.req.company.GetCompanyReqVo;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyDivideRuleDao extends BaseDao {
GetCompanyDivideResVo findCompanyDivideInfo(GetCompanyReqVo req);
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyInvitationRuleDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyKeyDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.vo.system.pd.company.CompanyMoneyVo;
import com.pangding.web.vo.system.req.company.CompanyMoneyReqVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
public interface CompanyMoneyDao extends BaseDao {
/**
* 查询公司资金每日汇总数据(分页)
* @param req
* @return
*/
PageSizeData<CompanyMoneyVo> findCompanyMoneyPage(CompanyMoneyReqVo req);
List<CompanyMoneyVo> findCompanyMoneyList(CompanyMoneyReqVo req);
/**
* 找到汇总数据
* @param req
* @return
*/
CompanyMoneyVo findReport(CompanyMoneyReqVo req);
/**
* 修改商户资金流水
* @param req
* @return
*/
Integer updateCompanyMoney(CompanyMoneyVo req);
CompanyMoneyVo findLastInfo(CompanyMoneyReqVo req);
List<CompanyMoneyVo> findCompanyMoneyTotalMonthList(CompanyMoneyReqVo req);
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyMoneyDetailDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.resvo.GetCompanyMsgResVo;
import com.pangding.web.vo.system.req.CompanyMsgReqVo;
import com.pangding.web.vo.system.res.CompanyMsgResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
public interface CompanyMsgDao extends BaseDao{
List<GetCompanyMsgResVo> findCompanyMsgList(CompanyMsgReqVo req);
PageSizeData<CompanyMsgResVo> findPageCompanyMsgList(CompanyMsgReqVo req);
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyRuleDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.vo.system.req.DeviceReqVo;
import com.pangding.web.vo.system.res.DeviceResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
public interface DeviceDao extends BaseDao {
PageSizeData<DeviceResVo> findDevicePage(DeviceReqVo req);
DeviceResVo findDeviceInfo(DeviceReqVo req);
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
/**
* @author zhangjinyao
*/
public interface RoleAuthorityDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.reqvo.GetEmptyRolesReqVo;
import com.pangding.web.authority.vo.reqvo.ListRoleReqVo;
import com.pangding.web.authority.vo.reqvo.RoleGetReqVo;
import com.pangding.web.authority.vo.resvo.WebRoleResVo;
import com.pangding.web.vo.system.pd.authority.RoleVo;
import com.pangding.web.vo.system.res.authority.RoleResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
/**
* @author zhangjinyao
*/
public interface RoleDao extends BaseDao {
PageSizeData<RoleResVo> queryList(ListRoleReqVo req);
PageSizeData<RoleVo> query(ListRoleReqVo req);
/**
* 通过主键id获取RoleVo对象
*
* @param roleGetReqVo getRoleByRoleIdReqVo对象
* @return RoleVo对象
*/
RoleVo getRoleById(RoleGetReqVo roleGetReqVo);
/**
* 通过角色名查询RoleVo对象
*
* @param getRoleByRoleNameReqVo 角色名
* @return RoleVo对象
*/
RoleVo getRoleByRoleName(RoleGetReqVo getRoleByRoleNameReqVo);
/**
* 检查用户名是否已存在
* 若返回数据大于0,则已存在,该用户名不可用
* 为0则可用
*
* @param roleVo 需要检查的RoleVo对象
* @return RoleVo对象的用户名在数据库中是否使用过
*/
void checkNameExist(RoleVo roleVo);
/**
* 通过角色id获取子角色列表
*
* @param roleGetReqVo 封装角色id
* @return 角色列表
*/
List<RoleVo> getChild(RoleGetReqVo roleGetReqVo);
List<RoleVo> getEmptyRoles(GetEmptyRolesReqVo getEmptyRolesReqVo);
}
package com.pangding.web.authority.dao;
import com.yanzuoguang.dao.BaseDao;
/**
* 登录接口基本操作类
* @author tf
*/
public interface TokenDao extends BaseDao {
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.reqvo.CountByRoleReqVo;
import com.pangding.web.authority.vo.reqvo.ListUserReqVo;
import com.pangding.web.authority.vo.reqvo.UserGetReqVo;
import com.pangding.web.authority.vo.reqvo.UserGetSuperAdminReqVo;
import com.pangding.web.vo.system.pd.authority.UserVo;
import com.pangding.web.vo.system.req.authority.UserReqVo;
import com.pangding.web.vo.system.req.authority.V2.QueryUserReqVo;
import com.pangding.web.vo.system.res.authority.UserResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
/**
* @author zhangjinyao
*/
public interface UserDao extends BaseDao {
/**
* 检查用户名是否存在
*
* @param account 账户名
* @return UserVo对象
*/
void checkAccount(UserVo account);
/**
* 查询用户是否存在
* @param req
* @return
*/
UserResVo queryUser(UserReqVo req);
/**
* 获取用户分页对象
*
* @param reqVo
* @return 用户分页对象
*/
PageSizeData<UserVo> getUserVoList(QueryUserReqVo reqVo);
UserVo getAdmin(UserGetSuperAdminReqVo reqVo);
/**
* 获取该公司该角色已分配的角色列表
* @param reqVo 封装了公司id和权限id的请求对象
* @return 用户列表
*/
PageSizeData<UserVo> countByRole(CountByRoleReqVo reqVo);
/**
* 获取某角色下的用户数
* @param req
* @return
*/
UserResVo countUserByRole(CountByRoleReqVo req);
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.reqvo.UserRoleGetReqVo;
import com.pangding.web.authority.vo.resvo.WebRoleResVo;
import com.pangding.web.vo.system.pd.authority.UserRoleVo;
import com.yanzuoguang.dao.BaseDao;
import java.util.List;
/**
* @author zhangjinyao
*/
public interface UserRoleDao extends BaseDao {
/**
* 通过userId查询用户角色对应关系列表
*
* @param reqVo 用户id
* @return user和role对应关系对象列表
*/
List<UserRoleVo> getUserRoleList(UserRoleGetReqVo reqVo);
List<WebRoleResVo> getUserNum(UserRoleGetReqVo reqVo);
}
package com.pangding.web.authority.dao;
import com.pangding.web.authority.vo.WechatUserVo;
import com.pangding.web.authority.vo.reqvo.PrecipitationReqVo;
import com.pangding.web.authority.vo.reqvo.WechatUserGetReqVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/29 17:10
*/
public interface WechatUserDao extends BaseDao {
/**
* 根据公司id,和月份获取该公司该月增加的用户数量
* @param getReqVo
* @return
*/
Object getUserNum(WechatUserGetReqVo getReqVo);
PageSizeData<WechatUserVo> getUserList(WechatUserGetReqVo reqVo);
}
package com.pangding.web.authority.dao.code;
import com.pangding.web.vo.system.req.code.CodeModelReqVo;
import com.pangding.web.vo.system.res.code.CodeModelExtendResVo;
import com.pangding.web.vo.system.res.code.CodeModelResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
public interface CodeModelDao extends BaseDao {
/**
* 查询码模板列表(分页)
* @param req
* @return
*/
PageSizeData<CodeModelResVo> queryCodeModelPageList(CodeModelReqVo req);
/**
* 查询码模板列表(不分页)
* @param req
* @return
*/
List<CodeModelResVo> queryCodeModelList(CodeModelReqVo req);
/**
* 查询码模板列表(不分页包含扩展字段)
* @param req
* @return
*/
List<CodeModelExtendResVo> querylList(CodeModelReqVo req);
}
package com.pangding.web.authority.dao.code;
import com.yanzuoguang.dao.BaseDao;
public interface CodeModelExtendDao extends BaseDao {
}
package com.pangding.web.authority.dao.code.Impl;
import com.pangding.web.authority.dao.code.CodeModelDao;
import com.pangding.web.vo.system.pd.code.CodeModelVo;
import com.pangding.web.vo.system.req.code.CodeModelReqVo;
import com.pangding.web.vo.system.res.code.CodeModelExtendResVo;
import com.pangding.web.vo.system.res.code.CodeModelResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class CodeModelDaoImpl extends BaseDaoImpl implements CodeModelDao {
// 查询列表
private static final String QUERY_LIST = "QUERY_LIST";
private static final String QUERY_LIST_EXTEND = "QUERY_LIST_EXTEND";
@Override
protected void init() {
register(CodeModelVo.class);
table.add(QUERY_LIST, "SELECT * FROM pd_code_model WHERE 1=1 ")
.add("codeModelName","AND code_model_name LIKE concat('%', ?,'%') ")
.add("codeType","AND code_type = ? ");
table.add(QUERY_LIST_EXTEND, "select a.*,b.code_model_extend_id,b.param_name,b.param_remark,b.param_sort " +
" from pd_code_model a LEFT JOIN pd_code_model_extend b on a.code_model_id = b.code_model_id" +
" WHERE 1=1 ")
.add("codeModelName","AND code_model_name LIKE concat('%', ?,'%') ")
.add("codeType","AND code_type = ? ");
}
@Override
public PageSizeData<CodeModelResVo> queryCodeModelPageList(CodeModelReqVo req) {
return this.queryPage(CodeModelResVo.class, req, QUERY_LIST, req);
}
@Override
public List<CodeModelResVo> queryCodeModelList(CodeModelReqVo req) {
return this.query(CodeModelResVo.class, QUERY_LIST, req);
}
public List<CodeModelExtendResVo> querylList(CodeModelReqVo req) {
return this.query(CodeModelExtendResVo.class, QUERY_LIST_EXTEND, req);
}
}
package com.pangding.web.authority.dao.code.Impl;
import com.pangding.web.authority.dao.code.CodeModelExtendDao;
import com.pangding.web.vo.system.pd.code.CodeModelExtendVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CodeModelExtendDaoImpl extends BaseDaoImpl implements CodeModelExtendDao {
@Override
protected void init() {
register(CodeModelExtendVo.class);
}
}
package com.pangding.web.authority.dao.company;
import com.pangding.web.authority.vo.reqvo.CompanyBankCardSetNotDefaultReqVo;
import com.pangding.web.vo.system.req.company.CompanyBankCardReqVo;
import com.pangding.web.vo.system.res.company.CompanyBankCardResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/16 19:17
*/
public interface CompanyBankCardDao extends BaseDao {
/**
* 获取银行卡列表分页数据
* @param reqVo
* @return
*/
PageSizeData<CompanyBankCardResVo> getBankCardListPage(CompanyBankCardReqVo reqVo);
/**
* 获取银行卡列表
* @param req
* @return
*/
List<CompanyBankCardResVo> getBankCardList(CompanyBankCardReqVo req);
/**
* 将指定银行卡设置为非默认
* @param req 设置非默认的请求对象
*/
void updateDefault(CompanyBankCardReqVo req);
}
package com.pangding.web.authority.dao.company;
import com.pangding.web.vo.system.req.company.CompanyReqVo;
import com.pangding.web.vo.system.res.company.CompanyNumberResVo;
import com.pangding.web.vo.system.res.company.CompanyResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/13 14:24
*/
public interface CompanyDao extends BaseDao {
/**
* 获取公司列表分页对象
* @param reqVo
* @return
*/
PageSizeData<CompanyResVo> findCompanyListPage(CompanyReqVo reqVo);
/**
* 获取公司列表
* @param req
* @return
*/
List<CompanyResVo> findCompanyList(CompanyReqVo req);
/**
* 找到公司详情
* @param req
* @return
*/
CompanyResVo findCompany(CompanyReqVo req);
/**
* 获取公司总数
* @param req
* @return
*/
CompanyNumberResVo findCompanyTotal(CompanyReqVo req);
}
package com.pangding.web.authority.dao.company;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyExamineDao extends BaseDao {
}
package com.pangding.web.authority.dao.company;
import com.pangding.web.vo.system.req.company.UpdateCompanyMoneyReqVo;
import com.yanzuoguang.dao.BaseDao;
/**
* @Author zhangjinyao
* @create 2019/5/16 17:20
*/
public interface CompanyExtendDao extends BaseDao {
void updateCompanyMoney(UpdateCompanyMoneyReqVo req);
/**
* 修改已邀请人数
* @param req
*/
void updateCompanyInvitedPeople(UpdateCompanyMoneyReqVo req);
}
package com.pangding.web.authority.dao.company;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyMerchantDao extends BaseDao {
}
package com.pangding.web.authority.dao.company;
import com.yanzuoguang.dao.BaseDao;
public interface CompanyRelationDao extends BaseDao {
}
package com.pangding.web.authority.dao.company;
import com.pangding.web.vo.system.req.company.CompanyTollPointReqVo;
import com.pangding.web.vo.system.res.company.CompanyTollPointResVo;
import com.yanzuoguang.dao.BaseDao;
import com.yanzuoguang.util.vo.PageSizeData;
public interface CompanyTollPointDao extends BaseDao {
PageSizeData<CompanyTollPointResVo> queryPageList(CompanyTollPointReqVo req);
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyBankCardDao;
import com.pangding.web.authority.vo.reqvo.CompanyBankCardSetNotDefaultReqVo;
import com.pangding.web.vo.system.pd.company.CompanyBankCardVo;
import com.pangding.web.vo.system.req.company.CompanyBankCardReqVo;
import com.pangding.web.vo.system.res.company.CompanyBankCardResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/16 19:17
*/
@Component
public class CompanyBankCardDaoImpl extends BaseDaoImpl implements CompanyBankCardDao {
private static final String QUERY_BANK_CARD_LIST = "QUERY_BANK_CARD_LIST";
private static final String UPDATE_DEFAULT = "UPDATE_DEFAULT";
@Override
protected void init() {
register(CompanyBankCardVo.class);
table.add(QUERY_BANK_CARD_LIST,"select * from pd_company_bank_card where 1=1 ")
.add("companyId","and company_id = ?");
table.add(UPDATE_DEFAULT,"update pd_company_bank_card a set a.is_default = @isDefault where 1=1 ")
.add("id","and id = ?")
.add("companyId","and company_id = ?");
}
@Override
public PageSizeData<CompanyBankCardResVo> getBankCardListPage(CompanyBankCardReqVo req) {
return this.queryPage(CompanyBankCardResVo.class, req, QUERY_BANK_CARD_LIST, req);
}
@Override
public List<CompanyBankCardResVo> getBankCardList(CompanyBankCardReqVo req) {
return this.query(CompanyBankCardResVo.class, QUERY_BANK_CARD_LIST, req);
}
@Override
public void updateDefault(CompanyBankCardReqVo req) {
this.updateSql(UPDATE_DEFAULT,req);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyDao;
import com.pangding.web.vo.system.pd.company.CompanyVo;
import com.pangding.web.vo.system.req.company.CompanyReqVo;
import com.pangding.web.vo.system.res.company.CompanyNumberResVo;
import com.pangding.web.vo.system.res.company.CompanyResVo;
import com.yanzuoguang.dao.DaoConst;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/13 14:25
*/
@Component
public class CompanyDaoImpl extends BaseDaoImpl implements CompanyDao {
private static final String QUERY_COMPANY = "QUERY_COMPANY";
private static final String QUERY_COMPANY_TOTAL= "QUERY_COMPANY_TOTAL";
@Override
protected void init() {
register(CompanyVo.class);
getSql(DaoConst.LOAD).addCode("{FIELD}", ",b.*", "{INNER}", "INNER JOIN pd_company_extend b ON a.id = b.id");
table.add(QUERY_COMPANY,"select a.*,b.subledger_status,b.subledger_rule,b.subledger_rule_time,b.divide_status,b.scan_code_pay_status," +
"invitation_status,invitation_rule_id,invitation_code,invitees_people,invited_people,activation_status,withdraw_rule,min_withdraw_money," +
"max_withdraw_money,withdraw_fee,withdraw_type,grade,withdraw_total_cash,frozen_money,discount_rule," +
"service_charge_status,service_charge_type,service_charge,late_fee " +
" from pd_company a inner join pd_company_extend b on a.id = b.id " +
"where 1=1 {WHERE} order by create_time desc")
.add("province"," and province = ? ")
.add("city"," and city = ? ")
.add("area"," and area = ? ")
.add("companyName"," and company_name LIKE concat('%', ?,'%') ")
.add("companyType"," and company_type = ? ")
.add("companyAttribute"," and company_attribute = ? ")
.add("examineStatus"," and examine_status = ?")
.add("companyId"," and invitation_company_id = ? ")
.add("invitationCode"," and (invitation_code = ? or child_invitation_code = ?) ")
.add("contactName"," and contact_name LIKE concat('%', ?,'%') ")
.add("contactPhone"," and contact_phone = ? ")
.add("status"," and status = ? ")
.add("withdrawRule"," and withdraw_rule = ? ")
.add("serviceChargeStatus"," and service_charge_status = ? ")
.add("startDate"," and create_time >= ? ")
.add("endDate"," and create_time <= ? ")
.add("search"," and (company_name LIKE concat('%', ?,'%') or (contact_name LIKE concat('%', ?,'%') )");
table.add(QUERY_COMPANY_TOTAL,"select COUNT(a.id) AS company_num," +
"SUM(CASE WHEN examine_status = 2 THEN 1 ELSE 0 END) AS company_use_num " +
" from pd_company a inner join pd_company_extend b on a.id = b.id " +
"where 1=1 {WHERE} order by create_time desc")
.add("province"," and province = ? ")
.add("city"," and city = ? ")
.add("area"," and area = ? ")
.add("companyName"," and company_name LIKE concat('%', ?,'%') ")
.add("companyType"," and company_type = ? ")
.add("companyAttribute"," and company_attribute = ? ")
.add("examineStatus"," and examine_status = ?")
.add("companyId"," and invitation_company_id = ? ")
.add("invitationCode"," and (invitation_code = or chlid_invitation_code) ")
.add("contactName"," and contact_name LIKE concat('%', ?,'%') ")
.add("contactPhone"," and contact_phone = ? ")
.add("status"," and status = ? ")
.add("withdrawRule"," and withdraw_rule = ? ")
.add("serviceChargeStatus"," and service_charge_status = ? ")
.add("startDate"," and create_time >= ? ")
.add("endDate"," and create_time <= ? ")
.add("search"," and (company_name LIKE concat('%', ?,'%') or (contact_name LIKE concat('%', ?,'%') )");
}
@Override
public PageSizeData<CompanyResVo> findCompanyListPage(CompanyReqVo reqVo) {
return this.queryPage(CompanyResVo.class,reqVo,QUERY_COMPANY,reqVo);
}
@Override
public List<CompanyResVo> findCompanyList(CompanyReqVo req) {
return this.query(CompanyResVo.class, QUERY_COMPANY, req);
}
@Override
public CompanyResVo findCompany(CompanyReqVo req) {
return this.queryFirst(CompanyResVo.class, QUERY_COMPANY, req);
}
@Override
public CompanyNumberResVo findCompanyTotal(CompanyReqVo req) {
return this.queryFirst(CompanyNumberResVo.class, QUERY_COMPANY_TOTAL, req);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyExamineDao;
import com.pangding.web.vo.system.pd.company.CompanyExamineVo;
import com.pangding.web.vo.system.pd.company.CompanyExtendVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyExamineDaoImpl extends BaseDaoImpl implements CompanyExamineDao {
@Override
protected void init() {
register(CompanyExamineVo.class);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyExtendDao;
import com.pangding.web.vo.system.pd.company.CompanyExtendVo;
import com.pangding.web.vo.system.req.company.UpdateCompanyMoneyReqVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
/**
* @Author zhangjinyao
* @create 2019/5/16 17:22
*/
@Component
public class CompanyExtendDaoImpl extends BaseDaoImpl implements CompanyExtendDao {
private static final String UPDATE_COMPANY_MONEY = "UPDATE_COMPANY_MONEY";
private static final String UPDATE_COMPANY_INVITED_PEOPLE = "UPDATE_COMPANY_INVITED_PEOPLE";
@Override
protected void init() {
register(CompanyExtendVo.class);
table.add(UPDATE_COMPANY_MONEY, "UPDATE pd_company_extend SET withdraw_total_cash = withdraw_total_cash + @newWithdrawTotalCash {FIELD} " +
"WHERE id = @companyId ")
.addPara("frozenMoney", "{FIELD}",",frozen_money = frozen_money + @frozenMoney")
.addPara("lateFee", "{FIELD}", ",late_fee = late_fee + @lateFee");
table.add(UPDATE_COMPANY_INVITED_PEOPLE, "UPDATE pd_company_extend SET " +
"invited_people = invited_people + @invitedPeople " +
"WHERE id = @companyId ");
}
@Override
public void updateCompanyMoney(UpdateCompanyMoneyReqVo req) {
this.updateSql(UPDATE_COMPANY_MONEY, req);
}
@Override
public void updateCompanyInvitedPeople(UpdateCompanyMoneyReqVo req) {
this.updateSql(UPDATE_COMPANY_INVITED_PEOPLE, req);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyMerchantDao;
import com.pangding.web.vo.system.pd.company.CompanyMerchantVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyMerchantDaoImpl extends BaseDaoImpl implements CompanyMerchantDao {
@Override
protected void init() {
register(CompanyMerchantVo.class);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyRelationDao;
import com.pangding.web.vo.system.pd.company.CompanyRelationVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyRelationDaoImpl extends BaseDaoImpl implements CompanyRelationDao {
@Override
protected void init() {
register(CompanyRelationVo.class);
}
}
package com.pangding.web.authority.dao.company.impl;
import com.pangding.web.authority.dao.company.CompanyTollPointDao;
import com.pangding.web.vo.system.pd.company.CompanyTollPointVo;
import com.pangding.web.vo.system.req.company.CompanyTollPointReqVo;
import com.pangding.web.vo.system.res.company.CompanyTollPointResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
@Component
public class CompanyTollPointDaoImpl extends BaseDaoImpl implements CompanyTollPointDao {
private final String QUERY_PAGE_LIST = "QUERY_PAGE_LIST";
@Override
protected void init() {
register(CompanyTollPointVo.class);
table.add(QUERY_PAGE_LIST,"select a.*,b.company_name from pd_company_point a left join pd_company b on a.company_id = b.id " +
"where 1=1{WHERE} ")
.add("companyId","and a.company_id = ? ");
}
@Override
public PageSizeData<CompanyTollPointResVo> queryPageList(CompanyTollPointReqVo req) {
return this.queryPage(CompanyTollPointResVo.class, req, QUERY_PAGE_LIST, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.AgreementTemplateDao;
import com.pangding.web.vo.system.pd.AgreementTemplateVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class AgreementTemplateDaoImpl extends BaseDaoImpl implements AgreementTemplateDao {
@Override
protected void init() {
register(AgreementTemplateVo.class);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.AuthorityDao;
import com.pangding.web.authority.vo.reqvo.*;
import com.pangding.web.vo.system.pd.authority.AuthorityVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author zhangjinyao
*/
@Component
public class AuthorityDaoImpl extends BaseDaoImpl implements AuthorityDao {
private static final String CHECK_VALID = "CHECK_VALID";
private static final String SELECT = "SELECT";
private static final String GET_LEVEL_ONE = "GET_LEVEL_ONE";
private static final String AFTER = "AFTER";
private static final String LIST_BY_SORT = "LIST_BY_SORT";
private static final String GET_LESS_BETWEEN = "GET_LESS_BETWEEN";
private static final String GET_MORE_BETWEEN = "GET_MORE_BETWEEN";
@Override
protected void init() {
register(AuthorityVo.class);
table.addExist(CHECK_VALID,"name","url");
table.add(SELECT,"select * from pd_authority where 1=1")
.add("id","and pid = ? ")
.add("pid","and pid = ? ")
.add("sort","and sort = ? ")
.add("search", "and (name like concat(?,'%') " +
"or alias like concat(?,'%')) " )
.add("levelOne","and pid = '' order by sort asc");
table.add(GET_LEVEL_ONE,"select * from pd_authority where 1=1 ")
.add("attribute","and attribute = ?")
.add("levelOne","and pid = '' order by sort asc");
table.add(AFTER,"select * from pd_authority where 1=1 ")
.add("pid","and pid = ? ")
.add("sort","and sort >= ? ")
.add("attribute","and attribute = ?");
table.add(LIST_BY_SORT,"select * from pd_authority where 1=1 ")
.add("pid","and pid = ? order by sort asc");
table.add(GET_LESS_BETWEEN,"select * from pd_authority where 1=1 ")
.add("pid","and pid = ?")
.add("smallSort","and sort >= ?")
.add("bigSort","and sort < ?")
.add("attribute","and attribute = ?");
table.add(GET_MORE_BETWEEN,"select * from pd_authority where 1=1")
.add("pid","and pid = ?")
.add("smallSort","and sort > ?")
.add("bigSort","and sort <= ?")
.add("attribute","and attribute = ?");
}
/**
* 检查新建或修改的authorityVo对象是否合法
*
* @param authorityVo authorityVo对象
*/
@Override
public void checkValid(AuthorityVo authorityVo) {
this.checkExist(CHECK_VALID,authorityVo,"该权限不合法,请修改权限名或权限url");
}
/**
* 获取权限分页对象
*
* @param reqVo
* @return 权限分页对象
*/
@Override
public PageSizeData<AuthorityVo> getAuthorityList(ListAuthorityByPageReqVo reqVo) {
return this.queryPage(AuthorityVo.class,reqVo,SELECT,reqVo);
}
@Override
public List<AuthorityVo> getLevelOne(AuthorityListReqVo reqVo) {
return this.query(AuthorityVo.class,GET_LEVEL_ONE,reqVo);
}
@Override
public List<AuthorityVo> after(AuthorityAfterReqVo afterReqVo) {
return this.query(AuthorityVo.class,AFTER,afterReqVo);
}
@Override
public List<AuthorityVo> listBySort(AuthorityGetReqVo reqVo) {
return this.query(AuthorityVo.class,LIST_BY_SORT,reqVo);
}
@Override
public List<AuthorityVo> getLessBetween(AuthorityBetweenSortReqVo reqVo) {
return this.query(AuthorityVo.class,GET_LESS_BETWEEN,reqVo);
}
@Override
public List<AuthorityVo> getMoreBetween(AuthorityBetweenSortReqVo reqVo) {
return this.query(AuthorityVo.class,GET_MORE_BETWEEN,reqVo);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CapitalFlowDao;
import com.pangding.web.vo.order.pd.CapitalFlowVo;
import com.pangding.web.vo.order.req.CapitalFlowReqVo;
import com.pangding.web.vo.order.res.CapitalFlowResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class CapitalFlowDaoImpl extends BaseDaoImpl implements CapitalFlowDao {
private static final String QUERY_LIST = "QUERY_CAPITAL_FLOW_LIST";
private static final String QUERY_LIST_TOTAL = "QUERY_LIST_TOTAL";
@Override
protected void init() {
register(CapitalFlowVo.class);
table.add(QUERY_LIST, "SELECT * FROM pd_capital_flow where 1=1 {WHERE} order by time desc")
.add("companyId"," AND company_id = ? ")
.add("companyName"," AND company_name LIKE concat(?,'%') ")
.add("merchantName"," AND merchant_name LIKE concat(?,'%') ")
.add("productName"," AND product_name LIKE concat(?,'%') ")
.add("orderType"," AND order_type = ? ")
.add("startOrderTime", " AND order_time >= ? ")
.add("endOrderTime", " AND order_time <= ? ")
.add("startPlayDate", " AND play_date >= ? ")
.add("endPlayDate", " AND play_date <= ? ")
.add("startDate", " AND time >= ? ")
.add("endDate", " AND time <= ? ")
.add("orderId", " AND order_id = ? ")
.add("category", " AND category = ? ")
.add("categoryList", " AND category in (?) ")
.add("status"," AND status = ? ");
table.add(QUERY_LIST_TOTAL, "SELECT SUM(CASE WHEN category = 0 THEN order_money ELSE 0 END) AS orderMoney," +
"SUM(CASE WHEN category = 0 THEN order_fee ELSE 0 END) AS orderFee," +
"SUM(CASE WHEN category = 0 THEN actual_money ELSE 0 END) AS realMoney," +
"SUM(CASE WHEN category = 1 and `status` = 1 THEN order_money ELSE 0 END) AS withdrawalAmount," +
"SUM(CASE WHEN category = 3 THEN actual_money ELSE 0 END) AS refundMoney," +
"SUM(CASE WHEN category <> 3 THEN actual_money ELSE 0 END) - " +
"SUM(CASE WHEN category = 1 and `status` = 1 THEN order_money ELSE 0 END) as actualMoney" +
" FROM pd_capital_flow where 1=1 {WHERE} GROUP BY 1{GROUP} order by time desc")
.addPara("companyGroup", "{GROUP}", ",company_id")
.addPara("merchantGroup", "{GROUP}", ",merchant_name")
.addPara("productGroup", "{GROUP}", ",product_name")
.add("companyId"," AND company_id = ? ")
.add("companyName"," AND company_name LIKE concat(?,'%')")
.add("merchantName"," AND merchant_name LIKE concat(?,'%') ")
.add("productName"," AND product_name LIKE concat(?,'%') ")
.add("orderType"," AND order_type = ? ")
.add("startOrderTime", " AND order_time >= ? ")
.add("endOrderTime", " AND order_time <= ? ")
.add("startPlayDate", " AND play_date >= ? ")
.add("endPlayDate", " AND play_date <= ? ")
.add("startDate", " AND time >= ? ")
.add("endDate", " AND time <= ? ")
.add("orderId", " AND order_id = ? ")
.add("category", " AND category = ?")
.add("categoryList", " AND category in (?) ")
.add("status"," AND status = ? ");
}
@Override
public PageSizeData<CapitalFlowResVo> findCapitalFlowList(CapitalFlowReqVo req){
return this.queryPage(CapitalFlowResVo.class, req, QUERY_LIST, req);
}
@Override
public CapitalFlowResVo findCapitalFlowTotal(CapitalFlowReqVo req){
return this.queryFirst(CapitalFlowResVo.class, QUERY_LIST_TOTAL, req);
}
@Override
public List<CapitalFlowResVo> findCapitalFlowTotalList(CapitalFlowReqVo req){
return this.query(CapitalFlowResVo.class, QUERY_LIST_TOTAL, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyAgreementDao;
import com.pangding.web.vo.system.pd.company.CompanyAgreementVo;
import com.pangding.web.vo.system.req.company.CompanyAgreementReqVo;
import com.pangding.web.vo.system.req.company.CompanyReqVo;
import com.pangding.web.vo.system.res.company.CompanyResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
@Component
public class CompanyAgreementDaoImpl extends BaseDaoImpl implements CompanyAgreementDao {
private static final String QUERY_LIST = "QUERY_LIST";
@Override
protected void init() {
register(CompanyAgreementVo.class);
table.add(QUERY_LIST,"select * " +
" from pd_company_agreement " +
"where 1=1 {WHERE} order by create_time desc")
.add("companyId"," and company_id = ? ");
}
@Override
public PageSizeData<CompanyAgreementVo> findCompanyAgreement(CompanyAgreementReqVo reqVo) {
return this.queryPage(CompanyAgreementVo.class,reqVo,QUERY_LIST,reqVo);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyCodeDao;
import com.pangding.web.vo.system.pd.company.CompanyCodeVo;
import com.pangding.web.vo.system.req.company.CompanyCodeReqVo;
import com.pangding.web.vo.system.res.company.CompanyCodeResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class CompanyCodeDaoImpl extends BaseDaoImpl implements CompanyCodeDao {
private final String FIND_CODE_LIST = "FIND_CODE_LIST";
@Override
protected void init() {
register(CompanyCodeVo.class);
table.add(FIND_CODE_LIST, "select a.*,b.enum_value as enumName " +
"from pd_company_code a left join pd_enum b on a.code_type = b.enum_key " +
"where b.child_type = 'code_type'")
.add("companyId","AND company_id = ? ");
}
public List<CompanyCodeResVo> findCodeList(CompanyCodeReqVo req){
return query(CompanyCodeResVo.class, FIND_CODE_LIST, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyDivideRuleDao;
import com.pangding.web.authority.vo.resvo.GetCompanyDivideResVo;
import com.pangding.web.vo.system.pd.company.CompanyDivideRuleVo;
import com.pangding.web.vo.system.req.company.GetCompanyReqVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyDivideRuleDaoImpl extends BaseDaoImpl implements CompanyDivideRuleDao {
private static final String QUERY_LIST = "QUERY_LIST";
@Override
protected void init() {
register(CompanyDivideRuleVo.class);
table.add(QUERY_LIST, "select cdr.*,ce.divide_status,c.company_name,c.pid,c.invitation_company_id from pd_company_divide_rule cdr " +
"left join pd_company c on c.id = cdr.company_id " +
"left join pd_company_extend ce on c.id = ce.id where 1=1 ")
.add("companyId"," and cdr.company_id = ?");
}
@Override
public GetCompanyDivideResVo findCompanyDivideInfo(GetCompanyReqVo req){
return this.queryFirst(GetCompanyDivideResVo.class, QUERY_LIST, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyInvitationRuleDao;
import com.pangding.web.vo.system.pd.company.CompanyInvitationRuleVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyInvitationRuleDaoImpl extends BaseDaoImpl implements CompanyInvitationRuleDao {
@Override
protected void init() {
register(CompanyInvitationRuleVo.class);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyKeyDao;
import com.pangding.web.vo.system.pd.company.CompanyKeyVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyKeyDaoImpl extends BaseDaoImpl implements CompanyKeyDao {
@Override
protected void init() {
register(CompanyKeyVo.class);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyMoneyDao;
import com.pangding.web.vo.system.pd.company.CompanyMoneyVo;
import com.pangding.web.vo.system.req.company.CompanyMoneyReqVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class CompanyMoneyDaoImpl extends BaseDaoImpl implements CompanyMoneyDao {
private final static String QUERY_LIST = "QUERY_LIST";
private final static String QUERT_REPORT = "QUERT_REPORT";
private final static String UPDATE_MONEY = "UPDATE_MONEY";
public static final String LAST_INFO = "LAST_INFO";
public static final String QUERY_TOTAL_MONTH = "QUERY_TOTAL_MONTH";
@Override
protected void init() {
register(CompanyMoneyVo.class);
table.add(QUERY_LIST, "SELECT * FROM pd_company_money WHERE 1=1 {WHERE} order by daily_date ")
.add("companyId", " AND company_id = ? ")
.add("startDate", " AND daily_date >= ?")
.add("endDate", " AND daily_date <= ?")
.add("companyName", " AND company_name like concat('%',?,'%') ");
table.add(QUERY_TOTAL_MONTH, "SELECT DATE_FORMAT(a.daily_date, '%Y-%m') AS daily_date," +
"IFNULL(SUM( a.in_money ),0)AS in_money, IFNULL(SUM( a.refund_money ),0)AS refund_money," +
"IFNULL(SUM( a.in_number ),0)AS in_number,IFNULL(SUM( a.refund_number ),0)AS refund_number " +
"FROM pd_company_money a WHERE 1=1 {WHERE} GROUP BY DATE_FORMAT(a.daily_date,'%Y-%m') order by daily_date ")
.add("companyId", " AND company_id = ? ")
.add("startDate", " AND daily_date >= ?")
.add("endDate", " AND daily_date <= ?")
.add("companyName", " AND company_name like concat('%',?,'%') ");
table.add(QUERT_REPORT, "SELECT SUM(init_money) as init_money,SUM(in_money) as in_money,SUM(out_money) as out_money," +
"SUM(refund_money) as refund_money,SUM(final_money) as final_money,SUM(in_number) as in_number," +
"SUM(out_number) as out_number,SUM(refund_number) as refund_number" +
" FROM pd_company_money WHERE 1=1 {WHERE}")
.add("companyId", " AND company_id = ? ")
.add("startDate", " AND daily_date >= ?")
.add("endDate", " AND daily_date <= ?")
.add("companyName", " AND company_name like concat('%', ?, '%')");
table.add(UPDATE_MONEY, "update pd_company_money set in_money = in_money + @inMoney,in_number= in_number + @inNumber," +
"refund_number = refund_number + @refundNumber,refund_money = refund_money + @refundMoney," +
"divide_number = divide_number + @divideNumber,divide_money = divide_money + @divideMoney," +
"out_number = out_number + @outNumber,out_money = out_money + @outMoney," +
"final_money = init_money + in_money + divide_money + refund_money + out_money " +
" where company_money_id = @companyMoneyId");
table.add(LAST_INFO, "SELECT * FROM pd_company_money WHERE 1=1 {WHERE} order by daily_date desc")
.add("companyId", " AND company_id = ? ")
.add("startDate", " AND daily_date >= ?")
.add("endDate", " AND daily_date <= ?")
.add("companyName", " AND company_name like concat('%',?,'%') ");
}
@Override
public PageSizeData<CompanyMoneyVo> findCompanyMoneyPage(CompanyMoneyReqVo req) {
return this.queryPage(CompanyMoneyVo.class, req, QUERY_LIST, req);
}
@Override
public List<CompanyMoneyVo> findCompanyMoneyList(CompanyMoneyReqVo req) {
return this.query(CompanyMoneyVo.class, QUERY_LIST, req);
}
@Override
public CompanyMoneyVo findReport(CompanyMoneyReqVo req) {
return this.queryFirst(CompanyMoneyVo.class, QUERT_REPORT, req);
}
@Override
public Integer updateCompanyMoney(CompanyMoneyVo req){
return this.updateSql(UPDATE_MONEY, req);
}
@Override
public CompanyMoneyVo findLastInfo(CompanyMoneyReqVo req) {
return this.queryFirst(CompanyMoneyVo.class, LAST_INFO, req);
}
@Override
public List<CompanyMoneyVo> findCompanyMoneyTotalMonthList(CompanyMoneyReqVo req) {
return this.query(CompanyMoneyVo.class, QUERY_TOTAL_MONTH, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyMoneyDetailDao;
import com.pangding.web.vo.system.pd.company.CompanyMoneyDetailVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyMoneyDetailDaoImpl extends BaseDaoImpl implements CompanyMoneyDetailDao {
@Override
protected void init() {
register(CompanyMoneyDetailVo.class);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyMsgDao;
import com.pangding.web.authority.vo.resvo.GetCompanyMsgResVo;
import com.pangding.web.vo.system.pd.CompanyMsgVo;
import com.pangding.web.vo.system.req.CompanyMsgReqVo;
import com.pangding.web.vo.system.res.CompanyMsgResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class CompanyMsgDaoImpl extends BaseDaoImpl implements CompanyMsgDao {
private static final String QUERY_LIST_PAGE = "QUERY_LIST_PAGE";
@Override
protected void init() {
register(CompanyMsgVo.class);
table.add(QUERY_LIST_PAGE, "select m.*,cm.msg_id,cm.company_id,cm.type,cm.merchant_id " +
"from pd_company_msg cm left join pd_msg m on cm.msg_id = m.id where 1=1 ")
.add("companyId", " AND cm.company_id = ? ")
.add("merchantId", " AND cm.merchant_id = ? ")
.add("msgId", " AND cm.msg_id = ? ")
.add("type", " AND cm.type = ? ");
}
@Override
public List<GetCompanyMsgResVo> findCompanyMsgList(CompanyMsgReqVo req) {
return this.query(GetCompanyMsgResVo.class, QUERY_LIST_PAGE, req);
}
@Override
public PageSizeData<CompanyMsgResVo> findPageCompanyMsgList(CompanyMsgReqVo req) {
return this.queryPage(CompanyMsgResVo.class, req, QUERY_LIST_PAGE, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.CompanyRuleDao;
import com.pangding.web.vo.system.pd.company.CompanyRuleVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
@Component
public class CompanyRuleDaoImpl extends BaseDaoImpl implements CompanyRuleDao {
@Override
protected void init() {
register(CompanyRuleVo.class);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.DeviceDao;
import com.pangding.web.vo.system.pd.device.DeviceVo;
import com.pangding.web.vo.system.req.DeviceReqVo;
import com.pangding.web.vo.system.res.DeviceResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
/**
* @author tangfang
* @date 2020-08-19
*/
@Component
public class DeviceDaoImpl extends BaseDaoImpl implements DeviceDao {
private static final String QUERY_LIST = "QUERY_LIST";
private static final String QUERY_INFO = "QUERY_INFO";
@Override
protected void init() {
register(DeviceVo.class);
table.add(QUERY_LIST, "SELECT * FROM pd_device WHERE 1=1 {WHERE}")
.add("deviceId", " AND device_id = ? ")
.add("deviceCode", "AND device_code = ? ")
.add("deviceName", " AND device_name = ? ")
.add("deviceType", " AND device_type = ? ")
.add("companyId", " AND company_id = ? ")
.add("channelId", " AND channel_id = ? ")
.add("merchantId", " AND merchant_id = ? ")
.add("deviceStatus", " AND device_status = ? ");
table.add(QUERY_INFO, "SELECT a.*,b.company_name FROM pd_device a LEFT JOIN pd_company b ON a.company_id = b.id WHERE 1=1 {WHERE")
.add("deviceId", " AND device_id = ? ")
.add("deviceCode", " AND device_code = ? ")
.add("deviceName", " AND device_name = ? ")
.add("deviceType", " AND device_type = ? ")
.add("companyId", " AND company_id = ? ")
.add("channelId", " AND channel_id = ? ")
.add("merchantId", " AND merchant_id = ? ")
.add("deviceStatus", " AND device_status = ? ");
;
}
@Override
public PageSizeData<DeviceResVo> findDevicePage(DeviceReqVo req) {
return queryPage(DeviceResVo.class, req, QUERY_LIST, req);
}
@Override
public DeviceResVo findDeviceInfo(DeviceReqVo req) {
return queryFirst(DeviceResVo.class, QUERY_INFO, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.RoleAuthorityDao;
import com.pangding.web.vo.system.pd.authority.RoleAuthorityVo;
import com.yanzuoguang.dao.DaoConst;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
/**
* @author zhangjinyao
*/
@Component
public class RoleAuthorityDaoImpl extends BaseDaoImpl implements RoleAuthorityDao {
@Override
protected void init() {
register(RoleAuthorityVo.class);
getSql(DaoConst.LOAD).setSql("select ra.role_id,ra.authority_id,a.id,a.pid,a.name," +
"a.type,a.alias,a.url,a.remark,a.open_mode,a.sort,a.attribute from pd_role_authority ra " +
"RIGHT JOIN pd_authority a on ra.authority_id = a.id {INNER} " +
"where 1=1 {WHERE} ORDER BY a.pid,a.sort,a.attribute" )
.add("userId", "AND b.user_id = @userId",
"{INNER}", "INNER JOIN pd_user_role AS b ON ra.role_id = b.role_id")
.add("role", " AND ra.role_id = @role")
.add("authority", " AND ra.authority_id = @authority")
.add("platformType", " AND a.platform_type = @platformType")
;
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.RoleDao;
import com.pangding.web.authority.vo.reqvo.GetEmptyRolesReqVo;
import com.pangding.web.authority.vo.reqvo.ListRoleReqVo;
import com.pangding.web.authority.vo.reqvo.RoleGetReqVo;
import com.pangding.web.authority.vo.resvo.WebRoleResVo;
import com.pangding.web.vo.system.pd.authority.RoleVo;
import com.pangding.web.vo.system.pd.company.CompanyMoneyVo;
import com.pangding.web.vo.system.req.company.CompanyMoneyReqVo;
import com.pangding.web.vo.system.res.authority.RoleResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author zhangjinyao
*/
@Component
public class RoleDaoImpl extends BaseDaoImpl implements RoleDao {
private static final String QUERY_LIST = "QUERY_LIST";
private static final String CHECK_NAME_EXIST = "CHECK_NAME_EXIST";
private static final String SELECT = "SELECT";
private static final String GET_EMPTY_ROLES = "GET_EMPTY_ROLES";
@Override
protected void init() {
register(RoleVo.class);
table.addExist(CHECK_NAME_EXIST, "name");
table.add(SELECT, "select * from pd_role where 1=1 ")
.add("id", " and pid = ? ")
.add("roleName", " and name LIKE concat(?,'%') ")
.add("roleRemark", " and remark LIKE concat(?,'%') ");
table.add(GET_EMPTY_ROLES, "select * from pd_role where 1=1 ");
table.add(QUERY_LIST, "select COUNT(a.id) as userNum,a.* from pd_role a " +
" LEFT JOIN pd_user_role b on a.id = b.role_id where 1=1 {WHERE}" +
"GROUP BY a.id")
.add("id", " and a.id = ? ")
.add("companyId", " and a.company_id = ? ")
.add("roleName", " and (a.name LIKE concat(?,'%') OR a.remark LIKE concat(?,'%') )");
}
@Override
public PageSizeData<RoleVo> query(ListRoleReqVo req) {
return this.queryPage(RoleVo.class, req, SELECT, req);
}
@Override
public PageSizeData<RoleResVo> queryList(ListRoleReqVo req) {
return this.queryPage(RoleResVo.class, req, QUERY_LIST, req);
}
@Override
public RoleVo getRoleById(RoleGetReqVo roleGetReqVo) {
return this.load(roleGetReqVo, RoleVo.class);
}
@Override
public RoleVo getRoleByRoleName(RoleGetReqVo getRoleByRoleNameReqVo) {
return this.load(getRoleByRoleNameReqVo, RoleVo.class);
}
@Override
public void checkNameExist(RoleVo roleVo) {
this.checkExist(CHECK_NAME_EXIST, roleVo, "角色名已存在");
}
@Override
public List<RoleVo> getChild(RoleGetReqVo roleGetReqVo) {
return this.query(RoleVo.class, SELECT, roleGetReqVo);
}
@Override
public List<RoleVo> getEmptyRoles(GetEmptyRolesReqVo getEmptyRolesReqVo) {
return this.query(RoleVo.class, GET_EMPTY_ROLES, getEmptyRolesReqVo);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.TokenDao;
import com.pangding.web.vo.system.pd.LoginTokenVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
/**
* 登录数据库写入实现类
*
* @author tf
*/
@Component
public class TokenDaoImpl extends BaseDaoImpl implements TokenDao {
private static final int TOKEN_MEMORY_CACHE_TIME = 60;
/**
* 注册SQL语句
*/
@Override
protected void init() {
// 根据实体生成增删改查语句
register(LoginTokenVo.class);
cacheList.setClearSecond(TOKEN_MEMORY_CACHE_TIME);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.UserDao;
import com.pangding.web.authority.vo.reqvo.CountByRoleReqVo;
import com.pangding.web.authority.vo.reqvo.ListUserReqVo;
import com.pangding.web.authority.vo.reqvo.UserGetSuperAdminReqVo;
import com.pangding.web.vo.system.pd.authority.UserVo;
import com.pangding.web.vo.system.req.authority.UserReqVo;
import com.pangding.web.vo.system.req.authority.V2.QueryUserReqVo;
import com.pangding.web.vo.system.res.authority.UserResVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
/**
* @author zhangjinyao
*/
@Component
public class UserDaoImpl extends BaseDaoImpl implements UserDao {
private static final String QUERY_USER = "QUERY_USER";
private static final String QUERY_COUNT = "QUERY_COUNT";
private static final String CHECK_ACCOUNT = "CHECK_ACCOUNT";
private static final String GET_ADMIN = "GET_ADMIN";
private static final String COUNT_BY_ROLE = "COUNT_BY_ROLE";
@Override
protected void init() {
register(UserVo.class);
table.add(QUERY_USER,"select * from pd_user where 1=1")
.add("companyId","and company_id = ? ")
.add("account","and account = ? ")
.add("phone","and phone = ? ")
.add("loginAccount","and (account = ? or phone = ?) ")
.add("roleId"," id in (select user_id from pd_user_role where role_id = ? )");
table.addExist(CHECK_ACCOUNT,"account");
table.add(GET_ADMIN,"SELECT u.* FROM pd_user u,pd_user_role ur WHERE u.id = ur.user_id")
.add("superAdminRoleId","and ur.role_id = ?")
.add("companyId","and u.company_id = ? ");
table.add(COUNT_BY_ROLE,"select u.* from pd_user u,pd_user_role ur WHERE u.id = ur.user_id")
.add("companyId","and u.company_id = ? ")
.add("roleId","and ur.role_id = ? ")
.add("query","and u.name = ? or u.account = ? or phone = ?");
table.add(QUERY_COUNT,"select count(u.id) as userNum" +
" from pd_user u,pd_user_role ur WHERE u.id = ur.user_id")
.add("companyId","and u.company_id = ? ")
.add("roleId","and ur.role_id = ? ")
.add("query","and u.name = ? or u.account = ? or phone = ?");
}
@Override
public void checkAccount(UserVo account) {
this.checkExist(CHECK_ACCOUNT,account,"用戶名已存在:"+account.getAccount());
}
@Override
public UserResVo queryUser(UserReqVo req) {
return this.queryFirst(UserResVo.class, QUERY_USER, req);
}
@Override
public PageSizeData<UserVo> getUserVoList(QueryUserReqVo req) {
return this.queryPage(UserVo.class,req,QUERY_USER,req);
}
@Override
public UserVo getAdmin(UserGetSuperAdminReqVo reqVo) {
return this.queryFirst(UserVo.class,GET_ADMIN,reqVo);
}
@Override
public PageSizeData<UserVo> countByRole(CountByRoleReqVo reqVo) {
return this.queryPage(UserVo.class,reqVo,COUNT_BY_ROLE,reqVo);
}
public UserResVo countUserByRole(CountByRoleReqVo req) {
return this.queryFirst(UserResVo.class, QUERY_COUNT, req);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.UserRoleDao;
import com.pangding.web.authority.vo.reqvo.UserRoleGetReqVo;
import com.pangding.web.authority.vo.resvo.WebRoleResVo;
import com.pangding.web.vo.system.pd.authority.UserRoleVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author zhangjinyao
*/
@Component
public class UserRoleDaoImpl extends BaseDaoImpl implements UserRoleDao {
private static final String GET_USER_ROLE_LIST = "GET_USER_ROLE_LIST";
private static final String GET_ROLE_USER_NUMBER = "GET_ROLE_USER_NUMBER";
@Override
protected void init() {
register(UserRoleVo.class);
table.add(GET_USER_ROLE_LIST,"select * from pd_user_role where 1=1 ")
.add("userId","and user_id = ? ")
.add("roleId","and role_id = ? ");
table.add(GET_ROLE_USER_NUMBER,"select count(*),role_id from pd_user_role where 1=1 {WHERE} group by role_id ")
.add("userId","and user_id = ? ")
.add("roleIds","and role_id in ? ");
}
@Override
public List<UserRoleVo> getUserRoleList(UserRoleGetReqVo reqVo) {
return this.query(UserRoleVo.class,GET_USER_ROLE_LIST,reqVo);
}
@Override
public List<WebRoleResVo> getUserNum(UserRoleGetReqVo reqVo) {
return this.query(WebRoleResVo.class,GET_ROLE_USER_NUMBER,reqVo);
}
}
package com.pangding.web.authority.dao.impl;
import com.pangding.web.authority.dao.WechatUserDao;
import com.pangding.web.authority.vo.WechatUserVo;
import com.pangding.web.authority.vo.reqvo.PrecipitationReqVo;
import com.pangding.web.authority.vo.reqvo.WechatUserGetReqVo;
import com.yanzuoguang.dao.impl.BaseDaoImpl;
import com.yanzuoguang.util.vo.MapRow;
import com.yanzuoguang.util.vo.PageSizeData;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/5/29 17:13
*/
@Component
public class WechatUserDaoImpl extends BaseDaoImpl implements WechatUserDao {
private static final String GET_USER_NUM = "GET_USER_NUM";
private static final String GET_USER_LIST = "GET_USER_LIST";
@Override
protected void init() {
register(WechatUserVo.class);
table.add(GET_USER_NUM,"select count(id) as num from pd_wechat_user where 1=1 ")
.add("sourceCompanyId","and source_company_id = ? ")
.add("start","and subscribe_date >= ? ")
.add("end","and subscribe_date < ? ");
table.add(GET_USER_LIST,"select * from pd_wechat_user where 1=1 {WHERE} order by subscribe_date desc")
.add("start","and subscribe_date >= ? ")
.add("end","and subscribe_date < ? ")
.add("sourceCompanyId","and source_company_id = ? ");
}
@Override
public Object getUserNum(WechatUserGetReqVo getReqVo) {
return this.query(GET_USER_NUM,getReqVo);
}
@Override
public PageSizeData<WechatUserVo> getUserList(WechatUserGetReqVo reqVo) {
return this.queryPage(WechatUserVo.class,reqVo,GET_USER_LIST,reqVo);
}
}
package com.pangding.web.authority.feign;
import com.pangding.web.authority.vo.reqvo.FindReqVo;
import com.pangding.web.authority.vo.resvo.FindResVo;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import java.util.List;
/**
* @Author zhangjinyao
* @create 2019/6/12 15:10
*/
@FeignClient(value = "pd-data-old")
@RequestMapping(value = "data")
public interface DataFeign {
@RequestMapping(value = "find")
ResponseResult<List<FindResVo>> find(@RequestBody FindReqVo reqVo);
}
package com.pangding.web.authority.feign;
import com.pangding.web.authority.vo.reqvo.CompanySaveReqVo;
import com.pangding.web.vo.system.req.DeviceReqVo;
import com.pangding.web.vo.system.req.company.CompanyBankCardReqVo;
import com.pangding.web.vo.system.req.company.SaveCompanyReqVo;
import com.yanzuoguang.util.vo.ResponseResult;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
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.ResponseBody;
import java.io.IOException;
/**
* @Author zhangjinyao
* @create 2019/6/2 18:06
*/
@FeignClient(value="pd-interface-pay")
@RequestMapping(value="/userNew")
public interface PayFeign {
/**
* 注册会员
* @param req
* @return
*/
@RequestMapping(value="/register")
ResponseResult<CompanySaveReqVo> setCompanyInfo(@RequestBody CompanySaveReqVo req);
@RequestMapping(value = "/setCompanyInfo", method = RequestMethod.POST)
ResponseResult<SaveCompanyReqVo> setCompanyInfo1(@RequestBody SaveCompanyReqVo req);
/**
* 企业会员绑定对公户
* @param req
* @return
*/
@RequestMapping(value = "/bindCompanyAccount", method = RequestMethod.POST)
ResponseResult<CompanyBankCardReqVo> bindCompanyAccount(@RequestBody CompanyBankCardReqVo req);
/**
* 绑定银行卡
* @param req
* @return
*/
@RequestMapping(value="/bindback")
ResponseResult<CompanyBankCardReqVo> bindBack(@RequestBody CompanyBankCardReqVo req);
/**
* 解绑银行卡
* @param req
* @return
*/
@RequestMapping(value = "/unbindBankCard")
ResponseResult<CompanyBankCardReqVo> unbindBankCard(@RequestBody CompanyBankCardReqVo req);
/**
* 获取签约地址
* @param req
* @return
* @throws IOException
*/
@RequestMapping(value = "/sign")
ResponseResult<CompanySaveReqVo> sign11(@RequestBody CompanySaveReqVo req) throws IOException;
/**
* 绑定设备编号
* @param deviceReqVo
* @return
*/
@ResponseBody
@RequestMapping(value = "/vspTermidService", method = RequestMethod.POST)
ResponseResult<Boolean> vspTermidService(@RequestBody DeviceReqVo deviceReqVo);
/**
* 上传证件相片
* @param req
* @return
*/
@RequestMapping(value = "/uploadPic", method = RequestMethod.POST)
ResponseResult<Boolean> idcardCollect(@RequestBody SaveCompanyReqVo req);
@ResponseBody
@RequestMapping(value = "/vspTermidInfoManage")
@ApiOperation(value = "支付终端信息管理", notes = "支付终端信息管理")
public ResponseResult<String> vspTermidInfoManage(@RequestBody DeviceReqVo req);
}
package com.pangding.web.authority.feign;
import com.pangding.web.authority.vo.reqvo.CompanyScenicInfoReqVo;
import com.pangding.web.authority.vo.reqvo.MerchantCreateReqVo;
import com.pangding.web.vo.product.pd.merchant.MerchantVo;
import com.pangding.web.vo.v2.scenic.merchant.pd.MerchantDeviceVo;
import com.pangding.web.vo.v2.scenic.merchant.req.MerchantDeviceReqVo;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
/**
* @Author zhangjinyao
* @create 2019/5/22 11:55
*/
@FeignClient(value = "pd-scenic")
public interface StoreFeign {
/**
* 新建景区
* @param req
* @return
*/
@RequestMapping("/scenic/merchantCreate")
ResponseResult<MerchantVo> merchantCreate(@RequestBody MerchantCreateReqVo req);
/**
* 通过公司还是id获取商户信息
*
* @param req
* @return
*/
@RequestMapping("/scenic/getCompanyScenicInfo")
ResponseResult<MerchantVo> getCompanyScenicInfo(@RequestBody CompanyScenicInfoReqVo req);
}
package com.pangding.web.authority.feign;
import com.pangding.web.authority.vo.WxVo;
import com.pangding.web.vo.wechat.req.code.QrCodeReqVo;
import com.yanzuoguang.util.vo.ResponseResult;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
/**
* @Author zhangjinyao
* @create 2019/6/6 16:20
*/
@FeignClient(value="pd-interface-wx")
@RequestMapping(value="/wx")
public interface WxFeign {
/**
* 获取二维码
* @param req
* @return
*/
@RequestMapping(value = "/qcCodeGet")
public ResponseResult<WxVo> qcCodeGet(@RequestBody QrCodeReqVo req);
}
package com.pangding.web.authority.mq;
import com.pangding.web.mq.CompanyProducer;
import com.pangding.web.mq.PayProducer;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 消息队列初始化服务,用于重启时,初始化消息队列对象
*
* @author 11488
*/
@Component
public class MqPlan implements InitializingBean {
@Autowired
private CompanyProducer companyProducer;
@Autowired
private PayProducer payProducer;
@Override
public void afterPropertiesSet() throws Exception {
companyProducer.init();
payProducer.init();
}
}
package com.pangding.web.authority.service;
import com.pangding.web.vo.system.req.company.CompanyReqVo;
import com.pangding.web.vo.system.res.company.CompanyResVo;
import com.yanzuoguang.util.vo.PageSizeData;
public interface CompanyNewService {
PageSizeData<CompanyResVo> findCompanyList(CompanyReqVo req);
}
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment