|
@@ -75,6 +75,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
|
|
|
*/
|
|
|
private static final String YEE_SUCCESS_CODE = "200";
|
|
|
|
|
|
+ /**
|
|
|
+ * 正启之星成功code
|
|
|
+ */
|
|
|
+ private static final String ZHENG_QI_ZHI_XING_SUCCESS_CODE = "200";
|
|
|
+
|
|
|
@RabbitHandler
|
|
|
public void onMessage(String jsonStr, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
|
|
|
super.onMessageAck(jsonStr, deliveryTag, channel, (MqListener<String>) (String result, Channel channel1) -> {
|
|
@@ -160,6 +165,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
|
|
|
String certStatus = subjectResult.getStr("certStatus");
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
ZhengQiZhiXingCertStatus zhengQiZhiXingCertStatus = Enum.valueOf(ZhengQiZhiXingCertStatus.class, certStatus);
|
|
|
+
|
|
|
// 拼接更新条件
|
|
|
LambdaUpdateWrapper<SysUserSub> updateWrapper = Wrappers.<SysUserSub>lambdaUpdate()
|
|
|
.eq(SysUserSub::getUserId, user.getUserId())
|
|
@@ -169,8 +175,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
|
|
|
.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED)
|
|
|
.set(SysUserSub::getUpdateTime, now)
|
|
|
.set(SysUserSub::getUpdateUser, 0)
|
|
|
- .set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult))
|
|
|
- .set(SysUserSub::getCertStatus, zhengQiZhiXingCertStatus.getCode());
|
|
|
+ .set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
|
|
|
+
|
|
|
+ if (ZHENG_QI_ZHI_XING_SUCCESS_CODE.equals(code)) {
|
|
|
+ updateWrapper.set(SysUserSub::getCertStatus, zhengQiZhiXingCertStatus.getCode());
|
|
|
+ }
|
|
|
|
|
|
sysUserSubService.update(updateWrapper);
|
|
|
|