| | |
| | | import com.panzhihua.applets.umf.MyAESUtil; |
| | | import com.panzhihua.applets.umf.UmfPayUtil; |
| | | import com.panzhihua.common.model.vos.R; |
| | | import com.panzhihua.common.service.user.UserService; |
| | | import com.panzhihua.common.utlis.DateUtils; |
| | | import com.panzhihua.common.utlis.HttpClientUtil; |
| | | import com.umf.api.service.UmfService; |
| | |
| | | private UmfPayUtil umfPayUtil; |
| | | @Value("${umf.file}") |
| | | private String file; |
| | | @Resource |
| | | private UserService userService; |
| | | |
| | | @PostMapping("wxNotify") |
| | | public void payCallback(HttpServletRequest request, HttpServletResponse response) { |
| | |
| | | } |
| | | |
| | | } |
| | | @ApiOperation("uu洗车推送") |
| | | @PostMapping("/uuPush") |
| | | public R uuPush(@RequestBody String aesString){ |
| | | try { |
| | | Map<String, String> aesMap= (Map<String, String>) JSON.parse(aesString); |
| | | String desString=MyAESUtil.Decrypt(aesMap.get("aesString"),"Ryo7M3n8loC5Abcd"); |
| | | Map<String,String> desMap= (Map) JSON.parse(desString); |
| | | return userService.uuPush(desMap.get("washer_mobile"),desMap.get("phone"),desMap.get("washer_name"),Integer.parseInt(desMap.get("order_status"))); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | return R.fail("推送失败"); |
| | | } |
| | | |
| | | } |
| | | } |
| | |
| | | @GetMapping("/indexData") |
| | | R newIndexData(@RequestParam(value = "type",required = false) Integer type, |
| | | @RequestParam(value = "type",required = false) Long streetId); |
| | | |
| | | /** |
| | | * uu洗车推送 |
| | | * @param washPhone |
| | | * @param phone |
| | | * @param washName |
| | | * @param orderStatus |
| | | * @return |
| | | */ |
| | | @GetMapping("/uuPush") |
| | | R uuPush(@RequestParam("washPhone")String washPhone,@RequestParam("phone")String phone,@RequestParam("washName")String washName,@RequestParam("orderStatus")Integer orderStatus); |
| | | } |
| | |
| | | log.error("危险人员订阅消息推送失败,失败原因:" + e.getMessage()); |
| | | } |
| | | } |
| | | public static void sendUuWash(String openId, String accessToken, String status,String washerName,String washerMobile,String templateId){ |
| | | |
| | | /** |
| | | * uu洗车订单状态更改 |
| | | * @param openId |
| | | * @param accessToken |
| | | * @param status |
| | | * @param washerName |
| | | * @param washerMobile |
| | | * @param phone |
| | | * @param templateId |
| | | */ |
| | | public static void sendUuWash(String openId, String accessToken, String status,String washerName,String washerMobile,String phone,String templateId){ |
| | | WxSubscribeDTO subscribeDTO = new WxSubscribeDTO(); |
| | | subscribeDTO.setTouser(openId); |
| | | subscribeDTO.setTemplate_id(templateId); |
| | | subscribeDTO.setPage("packageD/pages/washer/order/index"); |
| | | List<TemplateParam> paras=new ArrayList<TemplateParam>(); |
| | | paras.add(new TemplateParam("phrase6", "订单状态:"+status)); |
| | | paras.add(new TemplateParam("thing9", washerName)); |
| | | paras.add(new TemplateParam("thing1","车美信息")); |
| | | paras.add(new TemplateParam("thing4", "社区报备数据统计")); |
| | | paras.add(new TemplateParam("thing4", "订单状态:"+status)); |
| | | paras.add(new TemplateParam("thing3", washerName)); |
| | | paras.add(new TemplateParam("thing6",washerMobile)); |
| | | subscribeDTO.setTemplateParamList(paras); |
| | | try { |
| | | sendSubscribe(accessToken,subscribeDTO); |
| | |
| | | public R checkExport(@RequestParam("account")String account,@RequestParam("password")String password,@RequestParam("oldPassword")String oldPassword){ |
| | | return userService.checkExport(account,password,oldPassword); |
| | | } |
| | | |
| | | /** |
| | | * uu洗车推送 |
| | | * @param washPhone |
| | | * @param phone |
| | | * @param washName |
| | | * @param orderStatus |
| | | * @return |
| | | */ |
| | | @GetMapping("/uuPush") |
| | | public R uuPush(@RequestParam("phone")String phone,@RequestParam("orderStatus")Integer orderStatus){ |
| | | return userService.uuPush(phone,orderStatus); |
| | | public R uuPush(@RequestParam("washPhone")String washPhone,@RequestParam("phone")String phone,@RequestParam("washName")String washName,@RequestParam("orderStatus")Integer orderStatus){ |
| | | return userService.uuPush(washPhone,phone,washName,orderStatus); |
| | | } |
| | | } |
| | |
| | | * @param orderStatus |
| | | * @return |
| | | */ |
| | | R uuPush(@RequestParam("phone")String phone,@RequestParam("orderStatus")Integer orderStatus); |
| | | R uuPush(@RequestParam("washPhone")String washPhone,@RequestParam("phone")String phone,@RequestParam("washName")String washName,@RequestParam("orderStatus")Integer orderStatus); |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public R uuPush(String phone, Integer orderStatus) { |
| | | public R uuPush(String washPhone,String phone,String washName,Integer orderStatus) { |
| | | if(StringUtils.isNotEmpty(phone)){ |
| | | SysUserDO sysUserDO=userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone,phone).orderByDesc(SysUserDO::getCreateAt).last("limit 1")); |
| | | if(sysUserDO!=null&&StringUtils.isNotEmpty(sysUserDO.getOpenid())){ |
| | | WxUtil |
| | | String status=""; |
| | | switch (orderStatus){ |
| | | case 2 : status="等待分配车美";break; |
| | | case 3 : status="已分配车美";break; |
| | | case 4 : status="车美已开始服务";break; |
| | | case 5 : status="车美已结束服务";break; |
| | | case 6 : status="订单确认完成";break; |
| | | case 9 : status="订单已取消";break; |
| | | } |
| | | WxXCXTempSend util = new WxXCXTempSend(); |
| | | try { |
| | | String accessToken = util.getAccessToken(); |
| | | WxUtil.sendUuWash(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"Eft5ksvsnOQANy2uNOGY43CC3pb33eDGA_lgCEoxuiw"); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | } |
| | | } |
| | | return null; |
| | | return R.ok(); |
| | | } |
| | | |
| | | /** |
| | |
| | | boolean wxPay = requestURI.contains("wxNotify"); |
| | | boolean kaphtcha = requestURI.contains("kaphtcha"); |
| | | boolean uuRepay = requestURI.contains("uuRepay"); |
| | | boolean uuPush = requestURI.contains("uuPush"); |
| | | boolean wxCgi = requestURI.contains("cgi"); |
| | | boolean isShop = requestURI.contains("isShop"); |
| | | boolean noToken = requestURI.contains("noToken"); |
| | |
| | | SafeboxRequestWrapper safeboxRequestWrapper = new SafeboxRequestWrapper(request); |
| | | if (login || doc || css || js || ui || swagger || ico || docs || error || refreshToken || useragreement || wxPay |
| | | // ||wxCgi||isShop||listadvertisement||noToken||bigscreen) { |
| | | || wxCgi || isShop || listadvertisement || noToken||uuRepay||kaphtcha) { |
| | | || wxCgi || isShop || listadvertisement || noToken||uuRepay||kaphtcha||uuPush) { |
| | | // 什么也不做 |
| | | } else { |
| | | // 获取请求头中JWT的Token |