diff --git a/business/partner/purchase/jd/member.go b/business/partner/purchase/jd/member.go index fdd9350f9..41828c6c0 100644 --- a/business/partner/purchase/jd/member.go +++ b/business/partner/purchase/jd/member.go @@ -1 +1,40 @@ package jd + +import ( + "git.rosy.net.cn/baseapi/platformapi/jdapi" + "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/business/model" + "git.rosy.net.cn/jx-callback/business/model/dao" + "git.rosy.net.cn/jx-callback/globals" + "time" +) + +func MemberCreateMsg(msg *jdapi.CallbackMemberMsg) (retVal *jdapi.CallbackResponse) { + globals.SugarLogger.Debugf("MemberCreateMsg msg :%v", utils.Format4Output(msg, true)) + var ( + db = dao.GetDB() + ) + //result, err := api.JdAPI.GetCommonMemberRegisteredInfo(msg.Billid) + userMembers, _ := dao.GetUserMember(db, "", "", msg.Outbillid, model.VendorIDJD, 0, -1) + if len(userMembers) > 0 { + //应该是以前开过卡,后面没开了,现在又开了 + userMembers[0].DeletedAt = time.Now() + dao.UpdateEntity(db, userMembers[0], "DeletedAt") + userMember := &model.UserMember{ + VendorOrderID: msg.Billid, + VendorID: model.VendorIDJD, + Mobile: msg.Outbillid, + MemberType: 1, + } + dao.WrapAddIDCULDEntity(userMember, "jxadmin") + userMember.CreatedAt = utils.Str2Time(msg.Timestamp) + userMember.EndAt = utils.Str2Time(utils.Time2Str(utils.Time2Date(userMember.CreatedAt.AddDate(0, 1, 0))) + " 23:59:59") + dao.CreateEntity(db, userMember) + } + return jdapi.SuccessResponse +} + +func MemberRenewMsg(msg *jdapi.CallbackMemberMsg) (retVal *jdapi.CallbackResponse) { + globals.SugarLogger.Debugf("MemberRenewMsg msg :%v", utils.Format4Output(msg, true)) + return jdapi.SuccessResponse +} diff --git a/controllers/jd_callback.go b/controllers/jd_callback.go index e78ef269e..0b58d0284 100644 --- a/controllers/jd_callback.go +++ b/controllers/jd_callback.go @@ -238,7 +238,7 @@ func (c *DjswController) OrderInfoChange() { func (c *DjswController) MemberCreateCard() { if c.Ctx.Input.Method() == http.MethodPost { callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) { - callbackResponse = jd.OnOrderInfoChangeMsg(obj.(*jdapi.CallbackOrderInfoChangeMsg)) + callbackResponse = jd.MemberCreateMsg(obj.(*jdapi.CallbackMemberMsg)) return callbackResponse }) c.Data["json"] = c.transferResponse("MemberCreateCard", callbackResponse) @@ -251,7 +251,7 @@ func (c *DjswController) MemberCreateCard() { func (c *DjswController) MemberRenewCard() { if c.Ctx.Input.Method() == http.MethodPost { callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) { - callbackResponse = jd.OnOrderInfoChangeMsg(obj.(*jdapi.CallbackOrderInfoChangeMsg)) + callbackResponse = jd.MemberRenewMsg(obj.(*jdapi.CallbackMemberMsg)) return callbackResponse }) c.Data["json"] = c.transferResponse("MemberRenewCard", callbackResponse)