|
|
@@ -0,0 +1,42 @@
|
|
|
+package work
|
|
|
+
|
|
|
+import (
|
|
|
+ "context"
|
|
|
+ "testing"
|
|
|
+
|
|
|
+ "dashoo.cn/micro/app/dao/work"
|
|
|
+ modelWorkflow "dashoo.cn/micro/app/model/workflow"
|
|
|
+ "dashoo.cn/opms_libary/plugin/dingtalk/message"
|
|
|
+ "github.com/gogf/gf/frame/g"
|
|
|
+ "github.com/smallnest/rpcx/share"
|
|
|
+)
|
|
|
+
|
|
|
+var testTenant = "default"
|
|
|
+
|
|
|
+func fakeCtx(parent context.Context, tenant string) context.Context {
|
|
|
+ ctx := context.WithValue(parent, share.ReqMetaDataKey, map[string]string{
|
|
|
+ "tenant": tenant,
|
|
|
+ })
|
|
|
+ return ctx
|
|
|
+}
|
|
|
+
|
|
|
+func TestWorkOrderNotify(t *testing.T) {
|
|
|
+ // ctx := fakeCtx(context.Background(), testTenant)
|
|
|
+ s := OrderService{}
|
|
|
+ s.Dao = work.NewWorkOrderDao(testTenant)
|
|
|
+
|
|
|
+ instance := modelWorkflow.PlatWorkflow{}
|
|
|
+ err := g.DB(testTenant).Table("plat_workflow").Where("id = ?", 206).Struct(&instance)
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
+ }
|
|
|
+ err = s.WorkOrderNotify(&instance, &message.MixMessage{
|
|
|
+ ProcessType: "finish",
|
|
|
+ // ProcessType: "terminate",
|
|
|
+ Result: "agree",
|
|
|
+ // Result: "refuse",
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
+ }
|
|
|
+}
|