package com.xzx.gc.user.controller;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.convert.Convert;
|
import cn.hutool.core.util.NumberUtil;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.constant.CommonEnum;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.dto.log.OperationAppLog;
|
import com.xzx.gc.common.request.BaseController;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.IdUtils;
|
import com.xzx.gc.entity.*;
|
import com.xzx.gc.model.JsonResult;
|
import com.xzx.gc.model.admin.ExportParamModel;
|
import com.xzx.gc.model.admin.StorageModel;
|
import com.xzx.gc.model.admin.UserModel;
|
import com.xzx.gc.model.admin.XzxCityPartnerModel;
|
import com.xzx.gc.model.order.PackageSiteLimitDto;
|
import com.xzx.gc.user.service.*;
|
import com.xzx.gc.util.PreventManyCommit;
|
import com.xzx.gc.util.SessionUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.MediaType;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@RestController
|
@Api(tags = {"合伙人管理"})
|
public class CityPartnerController extends BaseController {
|
|
|
@Autowired
|
private IdUtils idUtils;
|
|
@Autowired
|
private CityPartnerService cityPartnerService;
|
|
@Autowired
|
private SessionUtil sessionUtil;
|
|
@Autowired
|
private PackageSiteService packageSiteService;
|
|
@Autowired
|
private BusinessUtil businessUtil;
|
|
@Autowired
|
private OtherUserService otherUserService;
|
|
@Autowired
|
private AccountService accountService;
|
|
@Autowired
|
private PartnerAccountService partnerAccountService;
|
|
@Autowired
|
private UserService userService;
|
|
@PostMapping( "/admin/front/cityPartner/getCityPartnerName.json")
|
@ApiOperation(value="生成合伙人账号", notes="test: 仅0有正确返回")
|
public JsonResult<String> getCityPartnerName(HttpServletRequest request){
|
String id=idUtils.generate("ZH",4);
|
return JsonResult.success(id);
|
}
|
|
@PostMapping( "/admin/front/cityPartner/addCityPartner.json")
|
@ApiOperation(value="添加合伙人", notes="test: 仅0有正确返回")
|
public JsonResult<String> addCityPartner(@RequestBody XzxCityPartnerModel model, HttpServletRequest request){
|
JsonResult<String> stringJsonResult = cityPartnerService.addPartner(model);
|
if(stringJsonResult.getCode()==0){
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.USER_MODUL_NAME).operateAction("添加合伙人-"+stringJsonResult.getData()).build();
|
mqUtil.sendApp(build);
|
}
|
return stringJsonResult;
|
}
|
|
@PostMapping("/admin/front/cityPartner/queryCityPartner.do")
|
@ApiOperation(value="查询合伙人列表(打包站列表 参数看partnerType)", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "name", value = "姓名、手机号", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "prohibit", value = "是否禁用（1：禁用，0：启用）", required = true, dataType = "Integer"),
|
@ApiImplicitParam(paramType="query", name = "partnerType", value = "合伙类型（1：合伙人。2：打包站）", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "packingStation", value = "打包站名称", required = true, dataType = "String")
|
|
})
|
public JsonResult<Map<String, Object>> queryCityPartner(@RequestBody XzxCityPartnerModel model){
|
Map<String, Object> map = cityPartnerService.queryCityPartner(model);
|
return JsonResult.success(map);
|
}
|
@PostMapping("/admin/front/cityPartner/queryPartnerAccount.json")
|
@ApiOperation(value="查询合伙人账户余额", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "id", value = "合伙人ID(如果不传，需要合伙人登陆)", required = true, dataType = "String"),
|
})
|
public JsonResult<Map<String,Object>> queryPartnerAccount(@RequestBody XzxCityPartnerModel model){
|
Map<String,Object> map = new HashMap<>();
|
|
if(null!=model){
|
if(null!=model.getId()&&!"".equals(model.getId())){
|
map=cityPartnerService.queryPartnerAccount(model.getId());
|
}else{
|
CoreUser user = sessionUtil.getCurrentUser();
|
if(user.getId()==1){
|
return JsonResult.success(map);
|
}else{
|
CoreUser user1 = cityPartnerService.queryPartnerAdmin(user.getId());
|
if(user1!=null){
|
return JsonResult.success(map);
|
}
|
}
|
CityPartner partner = cityPartnerService.queryById(user.getId());
|
if(null!=partner){
|
map=cityPartnerService.queryPartnerAccount(partner.getUserId());
|
}else{
|
return JsonResult.success(map);
|
}
|
|
}
|
}else{
|
CoreUser user = sessionUtil.getCurrentUser();
|
if(user.getId()==1){
|
return JsonResult.success(map);
|
}else{
|
user = cityPartnerService.queryPartnerAdmin(user.getId());
|
if(user!=null){
|
return JsonResult.success(map);
|
}
|
}
|
map=cityPartnerService.queryPartnerAccount(user.getId().toString());
|
}
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping("/admin/front/cityPartner/updateCityPartner.json")
|
@ApiOperation(value="修改合伙人", notes="test: 仅0有正确返回")
|
public JsonResult<String> updateCityPartner(@RequestBody XzxCityPartnerModel model,HttpServletRequest request){
|
JsonResult<String> stringJsonResult = cityPartnerService.updatePartner(model);
|
if(stringJsonResult.getCode()==0){
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.USER_MODUL_NAME).operateAction("修改合伙人-"+model.getId()).build();
|
mqUtil.sendApp(build);
|
}
|
return stringJsonResult;
|
}
|
|
@PostMapping("/admin/front/cityPartner/queryAllPartnerList.do")
|
@ApiOperation(value="查询合伙人和打包站列表", notes="test: 仅0有正确返回")
|
public JsonResult<List<CityPartner>> queryAllPartnerList(){
|
CoreUser user = sessionUtil.getCurrentUser();
|
List<CityPartner> cityPartners = new ArrayList<>();
|
if(user.getId()==1){
|
cityPartners = cityPartnerService.queryAllCityPartnerList(null);
|
}else{
|
CoreUser user1 = cityPartnerService.queryPartnerAdmin(user.getId());
|
//CityPartner partner = new CityPartner();
|
if(user1!=null){
|
|
cityPartners = cityPartnerService.queryAllCityPartnerList(null);
|
}else{
|
//partner.setId(Integer.parseInt(user.getId()+""));
|
cityPartners = cityPartnerService.queryAllCityPartnerList(user.getId()+"");
|
/*CityPartner partner = cityPartnerService.queryById(user.getId());
|
cityPartners.add(partner);*/
|
}
|
}
|
return JsonResult.success(cityPartners);
|
}
|
|
@PostMapping( "/admin/front/cityPartner/updatePartnerProhibit.json")
|
@ApiOperation(value="后台合伙人是否启用接口", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name ="id", value = "合伙人Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType="query", name = "prohibit", value = "是否启用", required = true, dataType = "String")
|
})
|
public JsonResult<String> updatePartnerProhibit(@RequestBody XzxCityPartnerModel model,HttpServletRequest request){
|
JsonResult jsonResult = cityPartnerService.updatePartnerProhibit(model);
|
if(jsonResult.getCode()==0){
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.USER_MODUL_NAME).operateAction("后台合伙人是否启用接口-"+model.getId()).build();
|
mqUtil.sendApp(build);
|
}
|
return jsonResult;
|
}
|
|
|
@PostMapping( "/admin/front/cityPartner/queryPartnerName.json")
|
@ApiOperation(value="查询合伙人姓名", notes="test: 仅0有正确返回")
|
public JsonResult<Map<String,Object>> queryPartnerName(){
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
List<CityPartner> list = cityPartnerService.queryPartnerName(partnerIds);
|
Map<String,Object> map = new HashMap<>();
|
map.put("data",list);
|
map.put("code",0);
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping( "/admin/front/cityPartner/queryPackageByPartner.json")
|
@ApiOperation(value="查询打包站", notes="test: 仅0有正确返回")
|
public JsonResult<Map<String,Object>> queryPackageByPartner(@RequestBody UserModel model){
|
List<String> partnerIds = new ArrayList<>();
|
if(null!=model.getPartnerId()&&!"".equals(model.getPartnerId())){
|
partnerIds.add(model.getPartnerId());
|
}else{
|
partnerIds = cityPartnerService.queryPartnerByCurrent();
|
}
|
List<CityPartner> list = cityPartnerService.queryPackageByPartner(partnerIds);
|
Map<String,Object> map = new HashMap<>();
|
map.put("data",list);
|
map.put("code",0);
|
return JsonResult.success(map);
|
}
|
|
/**
|
* 删除
|
* @param model
|
* @return
|
*/
|
@PostMapping("/admin/front/cityPartner/delPartner.json")
|
@PreventManyCommit(time = 10)
|
@ApiOperation(value="电子围栏管理-删除合伙人", notes="test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType="query", name = "id", value = "合伙人Id", dataType = "Integer")
|
})
|
public JsonResult<String> delPartner(@RequestBody XzxCityPartnerModel model,HttpServletRequest request){
|
|
JsonResult<String> stringJsonResult = cityPartnerService.deletePartner(model);
|
if(stringJsonResult.getCode()==0) {
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("删除合伙人-" + model.getId()).build();
|
mqUtil.sendApp(build);
|
|
}
|
return stringJsonResult;
|
|
}
|
|
@PostMapping("/packageSite/limit")
|
@ApiOperation(value = "额度管理显示")
|
public Result<PackageSiteLimitDto> limit(HttpServletRequest request){
|
String userId=getUserId(request);
|
|
PackageSiteLimitDto packageSiteLimitDto=new PackageSiteLimitDto();
|
List<AccountInfo> list=new ArrayList<>();
|
OtherUserInfo byId = otherUserService.findById(userId);
|
|
AccountInfo byUserId = accountService.findByUserId(userId);
|
byUserId.setName(byId.getName());
|
|
if(byUserId==null){
|
return Result.error(-1,"账户被禁用");
|
}
|
list.add(byUserId);
|
|
//打包站id
|
String partnerId = byId.getPartnerId();
|
|
|
PartnerAccount byPartnerId = partnerAccountService.findByPartnerId(partnerId);
|
|
packageSiteLimitDto.setHbb(businessUtil.changeMoney(byPartnerId.getHbb()));
|
packageSiteLimitDto.setOverdraftLimit(businessUtil.changeMoney(byPartnerId.getOverdraftLimit()));
|
packageSiteLimitDto.setAll(businessUtil.changeMoney(NumberUtil.add(packageSiteLimitDto.getHbb(),packageSiteLimitDto.getOverdraftLimit())));
|
packageSiteLimitDto.setPartnerAccountId(byPartnerId.getAccount());
|
|
List<OtherUserInfo> byUserTypeAndPartner = otherUserService.findByUserTypeAndPartner(CommonEnum.打包员.getValue(), partnerId);
|
|
if(CollUtil.isNotEmpty(byUserTypeAndPartner)){
|
for (OtherUserInfo otherUserInfo : byUserTypeAndPartner) {
|
AccountInfo byUserId1 = accountService.findByUserId(otherUserInfo.getUserId());
|
if(byUserId1!=null){
|
byUserId1.setName(otherUserInfo.getName());
|
byUserId1.setOverdraftLimit(businessUtil.changeMoney(byUserId1.getOverdraftLimit()));
|
list.add(byUserId1);
|
}
|
}
|
}
|
|
packageSiteLimitDto.setAccountInfos(list);
|
return Result.success(packageSiteLimitDto);
|
}
|
|
|
@PostMapping("/packageSite/limitUpdate")
|
@ApiOperation(value = "修改额度管理")
|
public Result limitUpdate(HttpServletRequest request, @Validated @RequestBody PackageSiteLimitDto packageSiteLimitDto){
|
Result result = packageSiteService.updateLimit(packageSiteLimitDto);
|
if(result.getCode()==0){
|
String mobilePhone = userService.findOtherByUserId(getUserId(request),1);
|
OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("修改额度管理-"+packageSiteLimitDto.getPartnerAccountId()).build();
|
mqUtil.sendApp(build);
|
}
|
return result;
|
}
|
|
@PostMapping("/packageSite/find")
|
@ApiOperation(value = "查询所属打包站")
|
public Result<CityPartner> find(HttpServletRequest request){
|
//打包站ID
|
String userId = getUserId(request);
|
OtherUserInfo byId1 = otherUserService.findById(userId);
|
String partnerId = byId1.getPartnerId();
|
CityPartner byId = cityPartnerService.findById(Convert.toInt(partnerId));
|
return Result.success(byId);
|
}
|
|
@PostMapping("/packageSite/limitRecovery")
|
@ApiOperation(value = "打包站恢复额度申请")
|
public Result limitRecovery(HttpServletRequest request){
|
String userId = getUserId(request);
|
OtherUserInfo byId1 = otherUserService.findById(userId);
|
String partnerId = byId1.getPartnerId();
|
Result result = packageSiteService.limitRecovery(partnerId, userId);
|
if(result.getCode()==0){
|
OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(byId1.getMobilePhone())
|
.methodName(Constants.ORDER_MODUL_NAME).operateAction("打包站恢复额度申请-"+partnerId).build();
|
mqUtil.sendApp(build);
|
}
|
return result;
|
}
|
|
|
/**
|
* 查询入库员数据
|
* @param userModel
|
* @return
|
*/
|
@PostMapping("/admin/front/packageSite/queryPackageStorageList.do")
|
@ApiOperation(value="数据统计-打包站数据", notes="test: 仅0有正确返回")
|
public JsonResult<Map<String, Object>> queryPackageStorageList(@RequestBody UserModel userModel){
|
Map<String,Object> resultMap = otherUserService.queryPackageStorageList(userModel);
|
return JsonResult.success(resultMap);
|
}
|
|
|
@ApiOperation(value = "打包站导出",produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
|
@PostMapping(value = "/admin/front/packageSite/export")
|
public void fileExport(@RequestBody ExportParamModel exportParamModel, HttpServletRequest request, HttpServletResponse response) {
|
List<List<String>> rows = new ArrayList<>();
|
//标题
|
List<String> header = CollUtil.newArrayList("打包站", "手机号", "订单量", "订单入库重量", "订单入库金额", "手动入库重量", "手动入库金额");
|
rows.add(header);
|
|
//组装数据
|
UserModel userModel = new UserModel(exportParamModel);
|
Map<String,Object> result = otherUserService.queryPackageStorageList(userModel);
|
List<Map<String,Object>> storageList = ( List<Map<String,Object>>) result.get("data");
|
if (CollUtil.isNotEmpty(storageList)) {
|
for (Map<String,Object> m:storageList) {
|
List<String> list = new ArrayList<>();
|
if(null!=m.get("delFlag")){
|
if(m.get("delFlag").toString().equals("1")){
|
m.put("storageName",m.get("storageName").toString()+"(已删除)");
|
}
|
}
|
list.add(m.get("storageName").toString());
|
list.add(m.get("storageUserPhone").toString());
|
list.add(m.get("orderNum").toString());
|
list.add(m.get("storageweight").toString());
|
list.add(m.get("storagemoney").toString());
|
list.add(m.get("recycleweight").toString());
|
list.add(m.get("storagemoney").toString());
|
rows.add(list);
|
|
}
|
}
|
|
//导出
|
export(rows,response);
|
|
OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
|
.methodName(Constants.USER_MODUL_NAME).operateAction("打包站导出").build();
|
mqUtil.sendApp(build);
|
}
|
|
}
|
