package com.doumee.api.web; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.biz.zbom.ZbomCRMService; import com.doumee.config.annotation.LoginRequired; import com.doumee.core.annotation.trace.Trace; import com.doumee.core.model.ApiResponse; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.dao.business.model.CustomerLog; import com.doumee.dao.business.model.Member; import com.doumee.dao.business.model.Shop; import com.doumee.dao.business.model.Users; import com.doumee.dao.web.reqeust.*; import com.doumee.dao.web.response.AccountResponse; import com.doumee.dao.web.response.BjParamConfigResponse; import com.doumee.service.business.*; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.authz.annotation.RequiresPermissions; import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import javax.imageio.ImageIO; import javax.servlet.http.HttpServletResponse; import javax.validation.Valid; import java.io.InputStream; /** * Created by IntelliJ IDEA. * * @Author : Rk * @create 2024/7/10 14:03 */ @Api(tags = "【C端小程序】用户业务") @Trace(exclude = true) @RestController @RequestMapping("/web/customer") @Slf4j public class CustomerApi extends ApiController{ @Autowired private MemberService memberService; @Autowired private BjParamService bjParamService; @Autowired private CustomerService customerService; @Autowired private ZbomCRMService zbomCRMService; @Autowired private ShopService shopService; @Autowired private UsersService usersService; @Autowired private CustomerUserService customerUserService; @ApiOperation(value = "客户端小程序登陆", notes = "客户端小程序") @GetMapping("/wxLoginCustomer") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", dataType = "String", name = "code", value = "微信code", required = true), }) public ApiResponse wxLoginCustomer(@RequestParam String code) { return ApiResponse.success(memberService.wxLogin(code)); } @LoginRequired @ApiOperation(value = "获取手机号", notes = "客户端小程序") @PostMapping("/getWxMiniPhone") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse getWxMiniPhone(@Valid @RequestBody WxPhoneRequest wxPhoneRequest) { return ApiResponse.success("获取成功",memberService.getWxMiniPhone(wxPhoneRequest)); } @LoginRequired @ApiOperation(value = "更新个人信息", notes = "客户端小程序") @PostMapping("/editMember") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse editMember(@RequestBody EditMemberRequest editMemberRequest) { editMemberRequest.setId(getMemberId()); //同步导购绑定信息 if(StringUtils.isNotBlank(editMemberRequest.getPhone())){ customerUserService.syncByPhone(editMemberRequest.getPhone()); } return ApiResponse.success("更新成功",memberService.updMemberDetail(editMemberRequest)); } @LoginRequired @ApiOperation(value = "绑定手机号信息", notes = "客户端小程序") @PostMapping("/binDingPhone") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse binDingPhone(@RequestBody EditMemberRequest editMemberRequest) { editMemberRequest.setId(getMemberId()); //同步导购绑定信息 if(StringUtils.isNotBlank(editMemberRequest.getPhone())){ customerUserService.syncByPhone(editMemberRequest.getPhone()); } return ApiResponse.success("更新成功",memberService.updMemberPhone(editMemberRequest)); } @LoginRequired @ApiOperation(value = "同步导购绑定信息", notes = "客户端小程序") @GetMapping("/syncCustomerUser") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true), @ApiImplicitParam(paramType = "query", dataType = "String", name = "phone", value = "手机号信息", required = true), }) public ApiResponse syncCustomerUser(@RequestParam String phone) { customerUserService.syncByPhone(phone); return ApiResponse.success("同步成功"); } @LoginRequired @ApiOperation(value = "获取个人信息", notes = "客户端小程序") @GetMapping("/getMemberInfo") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse getMemberInfo() { return ApiResponse.success("获取成功",memberService.getMemberInfo(getMemberId())); } @ApiOperation(value = "获取报价配置", notes = "客户端小程序") @GetMapping("/getBjParamConfig") public ApiResponse getBjParamConfig() { return ApiResponse.success(bjParamService.getBjParamConfig()); } @LoginRequired @ApiOperation(value = "装修计算器信息存储", notes = "客户端小程序") @PostMapping("/saveRenovationCalculator") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse saveRenovationCalculator(@RequestBody RenovationCalculatorDTO renovationCalculatorDTO) { renovationCalculatorDTO.setMemberId(getMemberId()); CustomerLog customerLog =customerService.saveRenovationCalculator(renovationCalculatorDTO); // zbomCRMService.dealCustomerLogData(customerLog); return ApiResponse.success("操作成功"); } @LoginRequired @ApiOperation(value = "0元定制信息", notes = "客户端小程序") @PostMapping("/saveFreeCustomizationApply") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse saveFreeCustomizationApply(@RequestBody FreeCustomizationDTO freeCustomizationDTO) { freeCustomizationDTO.setMemberId(getMemberId()); CustomerLog customerLog = customerService.saveFreeCustomizationApply(freeCustomizationDTO); // zbomCRMService.dealCustomerLogData(customerLog); return ApiResponse.success("操作成功"); } @LoginRequired @ApiOperation(value = "测试装修风格", notes = "客户端小程序") @PostMapping("/saveTestTrimStyle") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse saveTestTrimStyle(@RequestBody TestTrimStyleDTO testTrimStyleDTO) { testTrimStyleDTO.setMemberId(getMemberId()); CustomerLog customerLog = customerService.saveTestTrimStyle(testTrimStyleDTO); // zbomCRMService.dealCustomerLogData(customerLog); return ApiResponse.success("操作成功"); } @LoginRequired @ApiOperation(value = "用户注销", notes = "客户端小程序") @GetMapping("/logOff") public ApiResponse logOff() { memberService.logOff(getMemberId()); return ApiResponse.success("操作成功"); } @LoginRequired @ApiOperation(value = "门店列表", notes = "客户端小程序") @PostMapping("/shopPage") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true), }) public ApiResponse> shopPage (@RequestBody PageWrap pageWrap) { return ApiResponse.success(shopService.queryShopByLL(pageWrap)); } @LoginRequired @ApiOperation(value = "门店详情", notes = "客户端小程序") @GetMapping("/shopDetail") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true), @ApiImplicitParam(paramType = "query", dataType = "Long", name = "shopId", value = "门店主键", required = true) }) public ApiResponse shopDetail (@RequestParam Long shopId) { Long memberId = this.getMemberId(); return ApiResponse.success(shopService.shopDetail(shopId,memberId)); } @LoginRequired @ApiOperation("我的导购列表") @PostMapping("/myUserPage") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse> myUserPage (@RequestBody PageWrap pageWrap) { return ApiResponse.success(usersService.findPage(pageWrap)); } @LoginRequired @ApiOperation(value = "导购详情", notes = "客户端小程序") @GetMapping("/usersDetail") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true), @ApiImplicitParam(paramType = "query", dataType = "Long", name = "userId", value = "导购主键", required = true) }) public ApiResponse usersDetail (@RequestParam Long userId) { return ApiResponse.success(usersService.usersDetail(userId)); } @LoginRequired @ApiOperation(value = "测试小程序Token", notes = "客户端小程序") @GetMapping("/testToken") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public ApiResponse testToken () { memberService.updWxMiniToken(); return ApiResponse.success("更新成功"); } @Autowired private SystemDictDataBiz systemDictDataBiz; @LoginRequired @ApiOperation(value = "获取分享小程序二维码(图片流,img标签src指定)", notes = "客户端小程序") @GetMapping("/generateImg") @ApiImplicitParams({ @ApiImplicitParam(paramType = "header", dataType = "String", name = "token", value = "用户token值", required = true) }) public void generateImg(HttpServletResponse response) { try{ response.setHeader("Cache-Control", "no-store, no-cache"); response.setContentType("image/jpeg"); InputStream inputStream = Constants.generateWxMiniImgStream( systemDictDataBiz.queryByCode(Constants.WX_MINI_CONFIG,Constants.WX_TOKEN_CUSTOMER).getCode(),"123","" ); ImageIO.write(ImageIO.read(inputStream),"png",response.getOutputStream()); }catch (Exception e){ e.printStackTrace(); } } }