moral.git - Gitblit

			@@ -3,28 +3,34 @@

			import io.swagger.annotations.Api;
			import io.swagger.annotations.ApiOperation;
			import io.swagger.annotations.ApiParam;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.codec.digest.DigestUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.http.ResponseEntity;
			import org.springframework.web.bind.annotation.GetMapping;
			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.RequestParam;
			import org.springframework.web.bind.annotation.RestController;
			import org.springframework.web.client.RestTemplate;

			import java.util.HashMap;
			import java.util.Map;

			import javax.validation.Valid;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.toolkit.Wrappers;
			import com.moral.api.entity.AppUser;
			import com.moral.api.exception.BusinessException;
			import com.moral.api.mapper.AppUserMapper;
			import com.moral.api.entity.Allocation;
			import com.moral.api.pojo.query.app.AppAllocationPushUserCond;
			import com.moral.api.service.UserService;


			import com.moral.api.utils.WechatUtils;
			import com.moral.api.vo.WxMssVo;
			import com.moral.constant.ResponseCodeEnum;
			import com.moral.constant.ResultMessage;


			@Slf4j
			@Api(tags = {"小程序用户管理"})
			@@ -35,11 +41,8 @@
			@Autowired
			private UserService userService;

			@Autowired
			private AppUserMapper appUserMapper;

			@ApiOperation(value = "登陆信息", notes = "登陆信息")
			@PostMapping("login")
			@ApiOperation(value = "登陆信息")
			@PostMapping("logins")
			public ResultMessage login(@RequestBody Map<String, Object> parameters) {
			if (!(parameters.containsKey("account") && parameters.containsKey("password"))) {
			return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(),
			@@ -53,46 +56,68 @@
			}


			@PostMapping("/wx/login")
			@ApiOperation(value = "小程序登陆", notes = "小程序登陆")
			public ResultMessage userLogin(@RequestParam(value = "code", required = false) String code,
			@RequestParam(value = "rawData", required = false) String rawData,
			@RequestParam(value = "signature", required = false) String signature) {
			// 用户非敏感信息：rawData
			// 签名：signature
			JSONObject rawDataJson = JSON.parseObject(rawData);
			// 1.接收小程序发送的code
			// 2.开发者服务器登录凭证校验接口 appi + appsecret + code
			JSONObject SessionKeyOpenId = WechatUtils.getSessionKeyOrOpenId(code);
			// 3.接收微信接口服务获取返回的参数
			String openid = SessionKeyOpenId.getString("openid");
			String sessionKey = SessionKeyOpenId.getString("session_key");

			// 4.校验签名小程序发送的签名signature与服务器端生成的签名signature2 = sha1(rawData + sessionKey)
			String signature2 = DigestUtils.sha1Hex(rawData + sessionKey);
			if (!signature.equals(signature2)) {
			// return ResultMessage.ok().message("签名校验失败");
			// return ResultMessage.ok("签名校验失败");
			throw new BusinessException("签名校验失败");
			}
			// 5.根据返回的User实体类，判断用户是否是新用户，是的话，将用户信息存到数据库；
			LambdaQueryWrapper<AppUser> lqw = Wrappers.lambdaQuery();
			lqw.eq(AppUser::getOpenId, openid);
			// User user = userService.getOne(lqw);
			AppUser user = appUserMapper.selectOne(lqw);

			if (user == null) {
			// 用户信息入库
			String nickName = rawDataJson.getString("nickName");
			String avatarUrl = rawDataJson.getString("avatarUrl");
			user = new AppUser();
			user.setOpenId(Integer.parseInt(openid));
			user.setAvatarUrl(avatarUrl);
			user.setNickName(nickName);
			appUserMapper.insert(user);
			}
			return ResultMessage.ok(user);
			@GetMapping("/wx/login")
			@ApiOperation(value = "小程序登陆")
			public ResultMessage userLogin(@RequestParam(value = "code") String code
			) {
			Map<String, Object> result = userService.wxLogin(code);
			return ResultMessage.ok(result);
			}

			@GetMapping("/wx/exit")
			@ApiOperation(value = "小程序退出")
			public ResultMessage updateUserId(@RequestParam @ApiParam(value = "userId",name = "用户主键") Integer userId) {
			userService.updateUserId(userId);
			return ResultMessage.ok();
			}

			@PostMapping("pushOneUser")
			@ApiOperation(value = "小程序推送消息")
			public ResultMessage pushOneUser(@Valid @RequestBody Allocation appAllocationPushUserCond){
			userService.pushOneUser(appAllocationPushUserCond);
			// String body = push("oOCWi6-_hnzSvrMT8HX5D7Dz7tEA");
			return ResultMessage.ok();
			}


			public String push(String openid) {
			RestTemplate restTemplate = new RestTemplate();
			//这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）
			//小程序订阅
			String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + WechatUtils.getAccessToken();
			// String url = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=" + HttpClientUtil.getAccessToken();
			// String url = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send?access_token=" + HttpClientUtil.getAccessToken();
			// String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + HttpClientUtil.getAccessToken();
			//小程序客服
			// String url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=" + HttpClientUtil.getAccessToken();


			//拼接推送的模版
			WxMssVo wxMssVo = new WxMssVo();
			wxMssVo.setTouser(openid);//用户的openid（要发送给那个用户，通常这里应该动态传进来的）
			wxMssVo.setTemplate_id("YNqUZ1MgMvwY3G-NENVbcmIBR5dUotSdnwcz96CWrho");//订阅消息模板id
			wxMssVo.setLang("zh_CN");
			wxMssVo.setMiniprogramState("formal");
			// wxMssVo.setPage("pages/index/index");

			Map<String, Object> m = new HashMap<>();
			HashMap<String, Object> map1 = new HashMap<>();
			HashMap<String, Object> map2 = new HashMap<>();
			HashMap<String, Object> map3 = new HashMap<>();
			HashMap<String, Object> map4 = new HashMap<>();
			map1.put("value","欧阳仑2");
			map2.put("value","ouyanglun");
			map3.put("value","巧克力1");
			map4.put("value","2023-10-16");
			m.put("thing18", map1);
			m.put("character_string1", map2);
			m.put("thing2", map3);
			m.put("date4", map4);
			wxMssVo.setData(JSON.toJSON(m));

			ResponseEntity<String> responseEntity =
			restTemplate.postForEntity(url, wxMssVo, String.class);
			return responseEntity.getBody();
			}

			}