修改小程序获取token

This commit is contained in:
yangjun 2025-06-18 08:39:17 +08:00
parent eff9b39f10
commit 26b29049d6
8 changed files with 49 additions and 45 deletions

View File

@ -118,13 +118,13 @@ public class WeixinController {
@GetMapping("/wechat/callback") @GetMapping("/wechat/callback")
public Map<String,Object> callback(@RequestParam("code") String code, Model model) { public Map<String,Object> callback(@RequestParam("code") String code, Model model) {
String tokenUrl = String.format( String tokenUrl = String.format(
"https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code", "https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=authorization_code",
wechatpayConfig.getAppid(), wechatpayConfig.getAppsecret(), code wechatpayConfig.getAppid(), wechatpayConfig.getAppsecret(), code
); );
System.out.println(tokenUrl); System.out.println(tokenUrl);
RestTemplate restTemplate = new RestTemplate(); RestTemplate restTemplate = new RestTemplate();
System.out.println("-------------------11111111111111111----------"); System.out.println("-------------------11111111111111111----------"+tokenUrl);
String tokenResponse = restTemplate.getForObject(tokenUrl, String.class); String tokenResponse = restTemplate.getForObject(tokenUrl, String.class);
System.out.println("-------------------22222222222222222----------"+tokenResponse); System.out.println("-------------------22222222222222222----------"+tokenResponse);
@ -135,28 +135,28 @@ public class WeixinController {
System.out.println("-------------------33333333333333----------"); System.out.println("-------------------33333333333333----------");
JsonNode tokenNode = objectMapper.readTree(tokenResponse); JsonNode tokenNode = objectMapper.readTree(tokenResponse);
System.out.println("-------------------444444444444444----------"+tokenNode); System.out.println("-------------------444444444444444----------"+tokenNode);
accessToken = tokenNode.get("access_token").asText(); // accessToken = tokenNode.get("session_key").asText();
System.out.println("-------------------55555555555555----------"+accessToken); // System.out.println("-------------------55555555555555----------"+accessToken);
String openId = tokenNode.get("openid").asText(); // String openId = tokenNode.get("openid").asText();
System.out.println("-------------------666666666666666----------"+openId); // System.out.println("-------------------666666666666666----------"+openId);
//
String userInfoUrl = String.format( // String userInfoUrl = String.format(
"https://api.weixin.qq.com/sns/userinfo?access_token=%s&openid=%s&lang=zh_CN", // "https://api.weixin.qq.com/sns/userinfo?access_token=%s&openid=%s&lang=zh_CN",
accessToken, openId // accessToken, openId
); // );
System.out.println("-------------------777777777777777----------"+userInfoUrl); // System.out.println("-------------------777777777777777----------"+userInfoUrl);
//
String userInfoResponse = restTemplate.getForObject(userInfoUrl, String.class); // String userInfoResponse = restTemplate.getForObject(userInfoUrl, String.class);
System.out.println("-------------------888888888888888----------"+userInfoResponse); // System.out.println("-------------------888888888888888----------"+userInfoResponse);
JsonNode userInfoNode = objectMapper.readTree(userInfoResponse); // JsonNode userInfoNode = objectMapper.readTree(userInfoResponse);
System.out.println("-------------------999999999999999----------"+userInfoNode); // System.out.println("-------------------999999999999999----------"+userInfoNode);
//
model.addAttribute("openid", openId); // model.addAttribute("openid", openId);
System.out.println("-------------------999999999999999----------"+openId); // System.out.println("-------------------999999999999999----------"+openId);
model.addAttribute("nickname", userInfoNode.get("nickname").asText()); // model.addAttribute("nickname", userInfoNode.get("nickname").asText());
model.addAttribute("headimgurl", userInfoNode.get("headimgurl").asText()); // model.addAttribute("headimgurl", userInfoNode.get("headimgurl").asText());
model.addAttribute("code", code); // model.addAttribute("code", code);
retJson = userInfoNode; retJson = tokenNode;
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
model.addAttribute("openid", "Error parsing JSON response"); model.addAttribute("openid", "Error parsing JSON response");

View File

@ -66,10 +66,10 @@ public class TqDeviceInfoServiceImpl extends ServiceImpl<TqDeviceInfoMapper, TqD
WaterMeter entity = waterMeterMapper.getWaterMeter(waterMeter); WaterMeter entity = waterMeterMapper.getWaterMeter(waterMeter);
if(entity == null){ if(entity == null){
if(!isJob){ if(!isJob){
waterMeterMapper.insert(waterMeter); waterMeterMapper.insertWater(waterMeter);
} }
}else{ }else{
waterMeterMapper.update(waterMeter); waterMeterMapper.updateWater(waterMeter);
} }
}else{ }else{
ElectricityMeter electricityMeter = new ElectricityMeter(); ElectricityMeter electricityMeter = new ElectricityMeter();
@ -79,9 +79,9 @@ public class TqDeviceInfoServiceImpl extends ServiceImpl<TqDeviceInfoMapper, TqD
electricityMeter.setRemark(remark); electricityMeter.setRemark(remark);
ElectricityMeter entity = electricityMeterMapper.getElectricityMeter(electricityMeter); ElectricityMeter entity = electricityMeterMapper.getElectricityMeter(electricityMeter);
if(entity == null){ if(entity == null){
electricityMeterMapper.insert(electricityMeter); electricityMeterMapper.insertElectricty(electricityMeter);
}else{ }else{
electricityMeterMapper.update(electricityMeter); electricityMeterMapper.updateElectricty(electricityMeter);
} }
} }
} }

View File

@ -11,8 +11,10 @@ public interface ElectricityMeterMapper extends BaseMapper<ElectricityMeter> {
IPage<ElectricityMeter> findPage(Page<ElectricityMeter> page, @Param("params") ElectricityMeter electricityMeter); IPage<ElectricityMeter> findPage(Page<ElectricityMeter> page, @Param("params") ElectricityMeter electricityMeter);
List<ElectricityMeter> findAllList(); List<ElectricityMeter> findAllList();
ElectricityMeter getElectricityMeter(ElectricityMeter electricityMeter); ElectricityMeter getElectricityMeter(ElectricityMeter electricityMeter);
int insert(ElectricityMeter electricityMeter);
int update(ElectricityMeter electricityMeter);
int updateValue(ElectricityMeter electricityMeter); int updateValue(ElectricityMeter electricityMeter);
int updateRelayState(ElectricityMeter electricityMeter); int updateRelayState(ElectricityMeter electricityMeter);
int insertElectricty(ElectricityMeter electricityMeter);
int updateElectricty(ElectricityMeter electricityMeter);
} }

View File

@ -89,8 +89,8 @@
and address = #{address} and address = #{address}
</select> </select>
<insert id="insert" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter"> <insert id="insertElectricty" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
insert into nu_iot_tq_water_meter( insert into nu_iot_tq_electricity_meter(
cid, cid,
address, address,
relay_state, relay_state,
@ -106,7 +106,7 @@
) )
</insert> </insert>
<update id="update" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter"> <update id="updateElectricty" parameterType="com.nu.modules.tq.electricity.entity.ElectricityMeter">
update nu_iot_tq_electricity_meter update nu_iot_tq_electricity_meter
set set
relay_state = #{relayState}, relay_state = #{relayState},

View File

@ -12,8 +12,10 @@ public interface WaterMeterMapper extends BaseMapper<WaterMeter> {
IPage<WaterMeter> findPage(Page<WaterMeter> page, @Param("params") WaterMeter waterMeter); IPage<WaterMeter> findPage(Page<WaterMeter> page, @Param("params") WaterMeter waterMeter);
List<WaterMeter> findAllList(); List<WaterMeter> findAllList();
WaterMeter getWaterMeter(WaterMeter waterMeter); WaterMeter getWaterMeter(WaterMeter waterMeter);
int insert(WaterMeter waterMeter);
int update(WaterMeter waterMeter);
int updateValue(WaterMeter waterMeter); int updateValue(WaterMeter waterMeter);
int updateRelayState(WaterMeter waterMeter); int updateRelayState(WaterMeter waterMeter);
int insertWater(WaterMeter waterMeter);
int updateWater(WaterMeter waterMeter);
} }

View File

@ -78,7 +78,7 @@
and address = #{address} and address = #{address}
</select> </select>
<insert id="insert" parameterType="com.nu.modules.tq.water.entity.WaterMeter"> <insert id="insertWater" parameterType="com.nu.modules.tq.water.entity.WaterMeter">
insert into nu_iot_tq_water_meter( insert into nu_iot_tq_water_meter(
cid, cid,
address, address,
@ -97,7 +97,7 @@
) )
</insert> </insert>
<update id="update" parameterType="com.nu.modules.tq.water.entity.WaterMeter"> <update id="updateWater" parameterType="com.nu.modules.tq.water.entity.WaterMeter">
update nu_iot_tq_water_meter update nu_iot_tq_water_meter
set set
relay_state = #{relayState}, relay_state = #{relayState},

View File

@ -379,10 +379,10 @@ downloadkey: hP2K9Z!WLuj"M#8,
wxpay: wxpay:
# APIv3密钥 # APIv3密钥
api-v3-key: asdfiuzwe3534565478WETDSAFRWEq1E api-v3-key: asdfiuzwe3534565478WETDSAFRWEq1E
# APPID # APPID(小程序)
appid: wx8fc3e4305d2fbf0b appid: wx53bc8a44e780d26a
# appsecret # appsecret(小程序)
appsecret: 3bf3dd4ec72f591432db6b28c2c044e5 appsecret: 7dfcbf80cb4ff379454a3d6b1f8bd61f
# 商户ID # 商户ID
mch-id: 1717618860 mch-id: 1717618860
# 商户API证书序列号 # 商户API证书序列号

View File

@ -376,10 +376,10 @@ downloadkey: hP2K9Z!WLuj"M#8,
wxpay: wxpay:
# APIv3密钥 # APIv3密钥
api-v3-key: asdfiuzwe3534565478WETDSAFRWEq1E api-v3-key: asdfiuzwe3534565478WETDSAFRWEq1E
# APPID # APPID(小程序)
appid: wx8fc3e4305d2fbf0b appid: wx53bc8a44e780d26a
# appsecret # appsecret(小程序)
appsecret: 3bf3dd4ec72f591432db6b28c2c044e5 appsecret: 7dfcbf80cb4ff379454a3d6b1f8bd61f
# 商户ID # 商户ID
mch-id: 1717618860 mch-id: 1717618860
# 商户API证书序列号 # 商户API证书序列号